From dbfff7dac9d409c63b36747325dc0bb455dd9342 Mon Sep 17 00:00:00 2001
From: "1437892690@qq.com" <1437892690@qq.com>
Date: Tue, 9 Jul 2024 18:41:20 +0800
Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E8=87=AA=E5=8A=A8?=
 =?UTF-8?q?=E5=8C=96=E8=8A=82=E7=82=B9-=E6=94=AF=E6=8C=81=E4=B8=8D?=
 =?UTF-8?q?=E5=88=86=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

关联 #[1197145892290560]自动化节点-支持不分派处理人 http://192.168.0.96:8090/demo/rdm.html#/task-detail/939050947543040/939050947543050/1197145892290560
---
 .../component/CreateJobProcessComponent.java      | 15 +++++++++++++++
 .../component/AutoexecProcessComponent.java       | 14 ++++++++++++++
 2 files changed, 29 insertions(+)

diff --git a/src/main/java/neatlogic/module/autoexec/process/stephandler/component/CreateJobProcessComponent.java b/src/main/java/neatlogic/module/autoexec/process/stephandler/component/CreateJobProcessComponent.java
index d590889c..39c1c836 100644
--- a/src/main/java/neatlogic/module/autoexec/process/stephandler/component/CreateJobProcessComponent.java
+++ b/src/main/java/neatlogic/module/autoexec/process/stephandler/component/CreateJobProcessComponent.java
@@ -39,6 +39,7 @@ import neatlogic.framework.process.exception.processtask.ProcessTaskException;
 import neatlogic.framework.process.exception.processtask.ProcessTaskNoPermissionException;
 import neatlogic.framework.process.stephandler.core.IProcessStepHandler;
 import neatlogic.framework.process.stephandler.core.ProcessStepHandlerBase;
+import neatlogic.framework.process.stephandler.core.ProcessStepHandlerFactory;
 import neatlogic.framework.process.stephandler.core.ProcessStepThread;
 import neatlogic.module.autoexec.constvalue.FailPolicy;
 import neatlogic.module.autoexec.dao.mapper.AutoexecCombopVersionMapper;
@@ -237,6 +238,15 @@ public class CreateJobProcessComponent extends ProcessStepHandlerBase {
                     } else {
                         processTaskStepComplete(currentProcessTaskStepVo.getId());
                     }
+                } else {
+                    IProcessStepHandler processStepHandler = ProcessStepHandlerFactory.getHandler(currentProcessTaskStepVo.getHandler());
+                    if (processStepHandler != null) {
+                        try {
+                            processStepHandler.assign(currentProcessTaskStepVo);
+                        } catch (ProcessTaskException e) {
+                            logger.error(e.getMessage(), e);
+                        }
+                    }
                 }
             }
         } catch (Exception e) {
@@ -500,4 +510,9 @@ public class CreateJobProcessComponent extends ProcessStepHandlerBase {
     protected int myRedo(ProcessTaskStepVo currentProcessTaskStepVo) throws ProcessTaskException {
         return 0;
     }
+
+    @Override
+    public boolean disableAssign() {
+        return true;
+    }
 }
diff --git a/src/main/java/neatlogic/module/autoexec/stephandler/component/AutoexecProcessComponent.java b/src/main/java/neatlogic/module/autoexec/stephandler/component/AutoexecProcessComponent.java
index d61b6175..56d0160d 100644
--- a/src/main/java/neatlogic/module/autoexec/stephandler/component/AutoexecProcessComponent.java
+++ b/src/main/java/neatlogic/module/autoexec/stephandler/component/AutoexecProcessComponent.java
@@ -285,6 +285,15 @@ public class AutoexecProcessComponent extends ProcessStepHandlerBase {
                     } else {
                         processTaskStepComplete(currentProcessTaskStepVo.getId(), null);
                     }
+                } else {
+                    IProcessStepHandler processStepHandler = ProcessStepHandlerFactory.getHandler(currentProcessTaskStepVo.getHandler());
+                    if (processStepHandler != null) {
+                        try {
+                            processStepHandler.assign(currentProcessTaskStepVo);
+                        } catch (ProcessTaskException e) {
+                            logger.error(e.getMessage(), e);
+                        }
+                    }
                 }
             }
         } catch (Exception e) {
@@ -1681,4 +1690,9 @@ public class AutoexecProcessComponent extends ProcessStepHandlerBase {
     protected int myRedo(ProcessTaskStepVo currentProcessTaskStepVo) throws ProcessTaskException {
         return 0;
     }
+
+    @Override
+    public boolean disableAssign() {
+        return true;
+    }
 }
-- 
Gitee