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 0cc49dd7eaaae86f31b9f9f2bb85c3425cc27bf4..2c72b57aad866640af7163872a9abde33f59e7d7 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; + } }