From 5367444e3423598f9f9c804fc5eb26fed8d28eb8 Mon Sep 17 00:00:00 2001 From: "1437892690@qq.com" <1437892690@qq.com> Date: Wed, 26 Mar 2025 18:24:00 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E5=80=BC=E7=8F=AD?= =?UTF-8?q?=E5=8A=A9=E6=89=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 关联 #[1299362674606080]值班助手 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1299362674606080 --- .../process/service/ProcessTaskCreatePublicServiceImpl.java | 2 +- .../stephandler/component/AutomaticProcessComponent.java | 4 +++- .../process/stephandler/component/TimerProcessComponent.java | 4 +++- 3 files changed, 7 insertions(+), 3 deletions(-) diff --git a/src/main/java/neatlogic/module/process/service/ProcessTaskCreatePublicServiceImpl.java b/src/main/java/neatlogic/module/process/service/ProcessTaskCreatePublicServiceImpl.java index 42f5b8ce3..9929a6e1c 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 f232306cb..8466e6086 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 6af5af382..f1633512a 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 -- Gitee