From 37ce9bc880973975a92b97221dd27893e8032a32 Mon Sep 17 00:00:00 2001 From: "1437892690@qq.com" <1437892690@qq.com> Date: Tue, 9 Jul 2024 18:44:49 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E8=8A=82=E7=82=B9-=E6=94=AF=E6=8C=81=E4=B8=8D=E5=88=86?= =?UTF-8?q?=E6=B4=BE=E5=A4=84=E7=90=86=E4=BA=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 关联 #[1197146680819712]定时节点-支持不分派处理人 http://192.168.0.96:8090/demo/rdm.html#/task-detail/939050947543040/939050947543050/1197146680819712 --- .../component/TimerProcessComponent.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) 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 0cc49dd7e..2c72b57aa 100644 --- a/src/main/java/neatlogic/module/process/stephandler/component/TimerProcessComponent.java +++ b/src/main/java/neatlogic/module/process/stephandler/component/TimerProcessComponent.java @@ -247,6 +247,15 @@ public class TimerProcessComponent extends ProcessStepHandlerBase { thread.setSupplier(() -> processTaskMapper.deleteProcessTaskStepInOperationById(processTaskStepInOperationVo.getId())); TransactionSynchronizationPool.execute(thread); } + } else { + IProcessStepHandler processStepHandler = ProcessStepHandlerFactory.getHandler(currentProcessTaskStepVo.getHandler()); + if (processStepHandler != null) { + try { + processStepHandler.assign(currentProcessTaskStepVo); + } catch (ProcessTaskException e) { + logger.error(e.getMessage(), e); + } + } } } } @@ -401,4 +410,9 @@ public class TimerProcessComponent extends ProcessStepHandlerBase { public int getBackwardOutputQuantity() { return 0; } + + @Override + public boolean disableAssign() { + return true; + } } -- Gitee