diff --git a/src/main/java/neatlogic/framework/process/stephandler/core/ProcessStepHandlerBase.java b/src/main/java/neatlogic/framework/process/stephandler/core/ProcessStepHandlerBase.java index 7e4f5aae13f6fcb15b619fcab9cbbaead68d0069..2a7aefa45e414f853238cbf1fecd3c1554543c1c 100644 --- a/src/main/java/neatlogic/framework/process/stephandler/core/ProcessStepHandlerBase.java +++ b/src/main/java/neatlogic/framework/process/stephandler/core/ProcessStepHandlerBase.java @@ -120,7 +120,6 @@ public abstract class ProcessStepHandlerBase implements IProcessStepHandler { private int updateProcessTaskStatus(Long processTaskId) { IProcessTaskCrossoverMapper processTaskCrossoverMapper = CrossoverServiceFactory.getApi(IProcessTaskCrossoverMapper.class); List processTaskStepList = processTaskCrossoverMapper.getProcessTaskStepBaseInfoByProcessTaskId(processTaskId); - int runningCount = 0, succeedCount = 0, failedCount = 0, abortedCount = 0, draftCount = 0, hangCount = 0; for (ProcessTaskStepVo processTaskStepVo : processTaskStepList) { if (ProcessTaskStepStatus.DRAFT.getValue().equals(processTaskStepVo.getStatus()) @@ -132,9 +131,12 @@ public abstract class ProcessStepHandlerBase implements IProcessStepHandler { runningCount += 1; } else if (processTaskStepVo.getIsActive().equals(-1)) { abortedCount += 1; - } else if (processTaskStepVo.getStatus().equals(ProcessTaskStepStatus.SUCCEED.getValue()) - && ProcessStepHandlerType.END.getHandler().equals(processTaskStepVo.getHandler())) { - succeedCount += 1; + } else if (processTaskStepVo.getStatus().equals(ProcessTaskStepStatus.SUCCEED.getValue())) { + if (ProcessStepHandlerType.END.getHandler().equals(processTaskStepVo.getHandler())) { + succeedCount += 1; + } else { + runningCount += 1; + } } else if (processTaskStepVo.getStatus().equals(ProcessTaskStepStatus.FAILED.getValue())) { failedCount += 1; }