wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-4418) - 同步 ES 动作添加日志记录

Browse Source
This commit is contained in:
wangli 2025-08-22 15:15:32 +08:00
parent c1541c8027
commit 784506fcec
2 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/service/aggregation/AggregateProcessInstanceService.java
View File

@ -86,6 +86,7 @@ public class AggregateProcessInstanceService {
if (Objects.nonNull(function) && !StringUtils.hasText(initiator.getAssignerName()) && NumberUtil.isNumber(initiator.getPersonId())) { if (Objects.nonNull(function) && !StringUtils.hasText(initiator.getAssignerName()) && NumberUtil.isNumber(initiator.getPersonId())) {
fullAssigner = function.apply(Lists.newArrayList(initiator)).getOrDefault(Long.parseLong(initiator.getPersonId()), null); fullAssigner = function.apply(Lists.newArrayList(initiator)).getOrDefault(Long.parseLong(initiator.getPersonId()), null);
} }
log.info("insert es check fullAssigner: {}", Objects.nonNull(fullAssigner));
if (Objects.nonNull(fullAssigner)) { if (Objects.nonNull(fullAssigner)) {
fullAssigner.setAssignerName(StringUtils.hasText(initiator.getAssignerName()) ? initiator.getAssignerName() : "未知"); fullAssigner.setAssignerName(StringUtils.hasText(initiator.getAssignerName()) ? initiator.getAssignerName() : "未知");
processInstanceDocument.setInitiatorName(fullAssigner.getAssignerName()); processInstanceDocument.setInitiatorName(fullAssigner.getAssignerName());

2
workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/service/impl/EsProcessInstanceServiceImpl.java
View File

@ -7,6 +7,7 @@ import cn.axzo.workflow.es.mapper.EsProcessInstanceMapper;
import cn.axzo.workflow.es.model.ProcessInstanceDocument; import cn.axzo.workflow.es.model.ProcessInstanceDocument;
import cn.axzo.workflow.es.model.ProcessTaskDocument; import cn.axzo.workflow.es.model.ProcessTaskDocument;
import cn.axzo.workflow.es.service.EsProcessInstanceService; import cn.axzo.workflow.es.service.EsProcessInstanceService;
import com.alibaba.fastjson.JSON;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.dromara.easyes.annotation.IndexName; import org.dromara.easyes.annotation.IndexName;
@ -93,6 +94,7 @@ public class EsProcessInstanceServiceImpl implements EsProcessInstanceService {
*/ */
@Override @Override
public Integer insert(String routing, ProcessInstanceDocument processInstanceDocument) { public Integer insert(String routing, ProcessInstanceDocument processInstanceDocument) {
log.info("insert es document: {}", JSON.toJSONString(processInstanceDocument));
return esProcessInstanceMapper.insert(routing, processInstanceDocument); return esProcessInstanceMapper.insert(routing, processInstanceDocument);
} }