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

feat(REQ-4418) - 添加日志

Browse Source
This commit is contained in:
wangli 2025-08-28 18:42:49 +08:00
parent d03fd9cc17
commit 5bf44ee2cb
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/service/impl/CheckApproverServiceImpl.java
View File

@ -32,6 +32,7 @@ import java.util.List;
import java.util.Objects; import java.util.Objects;
import java.util.Optional; import java.util.Optional;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
import java.util.stream.Collectors;
import static cn.axzo.workflow.common.constant.BpmnConstants.INTERNAL_INITIATOR; import static cn.axzo.workflow.common.constant.BpmnConstants.INTERNAL_INITIATOR;
import static cn.axzo.workflow.common.constant.BpmnConstants.NO_ASSIGNEE; import static cn.axzo.workflow.common.constant.BpmnConstants.NO_ASSIGNEE;
@ -89,13 +90,23 @@ public class CheckApproverServiceImpl implements CheckApproverService {
return exists.get(); return exists.get();
} }
ProcessEngineConfigurationImpl processEngineConfiguration = CommandContextUtil.getProcessEngineConfiguration(); ProcessEngineConfigurationImpl processEngineConfiguration = CommandContextUtil.getProcessEngineConfiguration();
processEngineConfiguration.getActivityInstanceEntityManager() List<ActivityInstanceEntity> actInsts = processEngineConfiguration.getActivityInstanceEntityManager()
.findActivityInstancesByProcessInstanceId(delegateTask.getProcessInstanceId(), false) .findActivityInstancesByProcessInstanceId(delegateTask.getProcessInstanceId(), false);
actInsts.stream().map(i -> new StringBuilder()
.append(i.getActivityId()).append(":")
.append(i.getActivityType()).append(":")
.append(i.getEndTime()))
.collect(Collectors.toList())
.forEach(i -> log.info("checkApproveServiceImpl inst: {}", i.toString()));
actInsts
.stream() .stream()
.filter(i -> !Objects.equals(i.getActivityId(), userTask.getId())) .filter(i -> !Objects.equals(i.getActivityId(), userTask.getId()))
.filter(i -> !Objects.equals(i.getActivityType(), "exclusiveGateway")) .filter(i -> !Objects.equals(i.getActivityType(), "exclusiveGateway"))
.filter(i -> !Objects.equals(i.getActivityType(), "sequenceFlow")) .filter(i -> !Objects.equals(i.getActivityType(), "sequenceFlow"))
.filter(i -> !Objects.equals(i.getActivityType(), "startEvent")) .filter(i -> !Objects.equals(i.getActivityType(), "startEvent"))
.filter(i -> Objects.nonNull(i.getEndTime()))
.max(Comparator.comparing(ActivityInstanceEntity::getEndTime)) .max(Comparator.comparing(ActivityInstanceEntity::getEndTime))
.ifPresent(i -> { .ifPresent(i -> {
log.info("CheckApproverServiceImpl#checkApproverExists...上一个节点ID:{},类型:{}", i.getActivityId(), i.getActivityType()); log.info("CheckApproverServiceImpl#checkApproverExists...上一个节点ID:{},类型:{}", i.getActivityId(), i.getActivityType());