From 01c27425e5d90cde219a9352a3974e2250758901 Mon Sep 17 00:00:00 2001
From: caihaohan <caihaohan0712@foxmail.com>
Date: Fri, 20 Sep 2024 09:52:34 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=BE=85=E5=8A=9E=E5=8F=91=E9=80=81?=
 =?UTF-8?q?=E6=94=B9=E4=B8=BA=E5=BC=82=E6=AD=A5=E5=BB=B6=E8=BF=9F5?=
 =?UTF-8?q?=E7=A7=92?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../listener/MyGlobalEventListener.java       | 25 +++++++++++++++----
 1 file changed, 20 insertions(+), 5 deletions(-)

diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/listener/MyGlobalEventListener.java b/laws-modules/src/main/java/com/jero/modules/activiti/listener/MyGlobalEventListener.java
index 8de61ba7..8d0a817f 100644
--- a/laws-modules/src/main/java/com/jero/modules/activiti/listener/MyGlobalEventListener.java
+++ b/laws-modules/src/main/java/com/jero/modules/activiti/listener/MyGlobalEventListener.java
@@ -33,6 +33,9 @@ import org.springframework.stereotype.Component;
 
 import java.util.*;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
 
 /**
  * @author liJiaRao
@@ -170,7 +173,12 @@ public class MyGlobalEventListener implements ActivitiEventListener {
         hiworkTodoAdd.setRecordId(approvalRecord.getId());
         hiworkTodoAdd.setProcessDefinitionId(processDefinitionId);
         list.add(hiworkTodoAdd);
-        CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
+        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
+        // 调度5秒后执行异步任务
+        scheduler.schedule(() ->
+                        CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list)),
+                5, TimeUnit.SECONDS
+        );
     }
 
     private void taskAssigned(ActivitiEvent event) {
@@ -189,7 +197,7 @@ public class MyGlobalEventListener implements ActivitiEventListener {
             return;
         }
         String userId = approvalRecord.getUserId();
-
+        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
         if (!Objects.equals(assignee,userId)) {
             log.info("由"+userId+"转办给"+assignee);
             // 对接统一平台生成完成任务
@@ -200,7 +208,8 @@ public class MyGlobalEventListener implements ActivitiEventListener {
             hiworkTodoAdd.setType("2");
             hiworkTodoAdd.setProcessDefinitionId(processDefinitionId);
             list.add(hiworkTodoAdd);
-            CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
+            // 调度5秒后执行异步任务
+            pushWorkflowIntegrationAPI.sendTodoTask(list);
 
             //更新转办任务id
             LambdaUpdateWrapper<ProcessApprovalRecord> update = new LambdaUpdateWrapper<>();
@@ -212,7 +221,8 @@ public class MyGlobalEventListener implements ActivitiEventListener {
             hiworkTodoAdd.setToUserId(assignee);
             hiworkTodoAdd.setType("1");
             list.add(hiworkTodoAdd);
-            CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
+            // 调度5秒后执行异步任务
+            pushWorkflowIntegrationAPI.sendTodoTask(list);
         }
 
     }
@@ -297,7 +307,12 @@ public class MyGlobalEventListener implements ActivitiEventListener {
         hiworkTodoAdd.setProcessDefinitionId(processDefinitionId);
         list.add(hiworkTodoAdd);
         // 异步发送待办
-        CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
+        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
+        // 调度5秒后执行异步任务
+        scheduler.schedule(() ->
+                        CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list)),
+                5, TimeUnit.SECONDS
+        );
     }
 
     private void entityDeleted(ActivitiEvent event) {