diff --git a/src/main/java/neatlogic/module/process/service/ProcessTaskCreatePublicServiceImpl.java b/src/main/java/neatlogic/module/process/service/ProcessTaskCreatePublicServiceImpl.java index 42f5b8ce345f78933bfd56b83fce62df1bffd7c3..9929a6e1c9a3827297d5813f06edd39b534dacb7 100644 --- a/src/main/java/neatlogic/module/process/service/ProcessTaskCreatePublicServiceImpl.java +++ b/src/main/java/neatlogic/module/process/service/ProcessTaskCreatePublicServiceImpl.java @@ -346,7 +346,7 @@ public class ProcessTaskCreatePublicServiceImpl implements ProcessTaskCreatePubl throw new ProcessTaskNextStepOverOneException(processTaskId); } saveResultObj.put("nextStepId", nextStepIdList.get(0)); - + saveResultObj.put("assignWorkerList", processTaskCreateVo.getAssignWorkerList()); //流转 processTaskService.startProcessProcessTask(saveResultObj); // } diff --git a/src/main/java/neatlogic/module/process/stephandler/component/AutomaticProcessComponent.java b/src/main/java/neatlogic/module/process/stephandler/component/AutomaticProcessComponent.java index f232306cb19e08b2acd74d76e0376f319265b94e..8466e60860e5e52fafd10b9b9003d62820f520fc 100644 --- a/src/main/java/neatlogic/module/process/stephandler/component/AutomaticProcessComponent.java +++ b/src/main/java/neatlogic/module/process/stephandler/component/AutomaticProcessComponent.java @@ -112,6 +112,7 @@ public class AutomaticProcessComponent extends ProcessStepHandlerBase { @Override protected int myActive(ProcessTaskStepVo currentProcessTaskStepVo) throws ProcessTaskException { + currentProcessTaskStepVo.setStatus(ProcessTaskStepStatus.RUNNING.getValue()); try { AutomaticConfigVo automaticConfigVo = processTaskAutomaticService.getAutomaticConfigVoByProcessTaskStepId(currentProcessTaskStepVo.getId()); JSONObject requestAudit = new JSONObject(); @@ -274,7 +275,8 @@ public class AutomaticProcessComponent extends ProcessStepHandlerBase { @Override protected int myAssign(ProcessTaskStepVo currentProcessTaskStepVo, Set workerSet) throws ProcessTaskException { - return defaultAssign(currentProcessTaskStepVo, workerSet); + defaultAssign(currentProcessTaskStepVo, workerSet); + return 1; } @Override diff --git a/src/main/java/neatlogic/module/process/stephandler/component/TimerProcessComponent.java b/src/main/java/neatlogic/module/process/stephandler/component/TimerProcessComponent.java index 6af5af3820deb61836f66c6f7f902ba66f7f10f0..f1633512a66a5d9cc3039a646d6eb962664199a8 100644 --- a/src/main/java/neatlogic/module/process/stephandler/component/TimerProcessComponent.java +++ b/src/main/java/neatlogic/module/process/stephandler/component/TimerProcessComponent.java @@ -130,6 +130,7 @@ public class TimerProcessComponent extends ProcessStepHandlerBase { @Override protected int myActive(ProcessTaskStepVo currentProcessTaskStepVo) throws ProcessTaskException { + currentProcessTaskStepVo.setStatus(ProcessTaskStepStatus.RUNNING.getValue()); try { String configHash = currentProcessTaskStepVo.getConfigHash(); String stepConfig = selectContentByHashMapper.getProcessTaskStepConfigByHash(configHash); @@ -268,7 +269,8 @@ public class TimerProcessComponent extends ProcessStepHandlerBase { @Override protected int myAssign(ProcessTaskStepVo currentProcessTaskStepVo, Set workerSet) throws ProcessTaskException { - return defaultAssign(currentProcessTaskStepVo, workerSet); + defaultAssign(currentProcessTaskStepVo, workerSet); + return 1; } @Override