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:45:18 +08:00
parent 784506fcec
commit 27c5da93aa
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -84,13 +84,16 @@ public class AggregateProcessInstanceService {
if (Objects.nonNull(initiator)) {
BpmnTaskDelegateAssigner fullAssigner = null;
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(initiator.parsePersonId(), null);
}
log.info("insert es check fullAssigner: {}", Objects.nonNull(fullAssigner));
if (Objects.nonNull(fullAssigner)) {
fullAssigner.setAssignerName(StringUtils.hasText(initiator.getAssignerName()) ? initiator.getAssignerName() : "未知");
processInstanceDocument.setInitiatorName(fullAssigner.getAssignerName());
processInstanceDocument.setInitiatorJsonStr(JSON.toJSONString(fullAssigner));
} else {
processInstanceDocument.setInitiatorName(StringUtils.hasText(initiator.getAssignerName()) ? initiator.getAssignerName() : "未知");
processInstanceDocument.setInitiatorJsonStr(JSON.toJSONString(initiator));
}
}