From 6f20c281554a6ab2c33a3c51118afdddf5bf83eb Mon Sep 17 00:00:00 2001
From: caihaohan <caihaohan0712@foxmail.com>
Date: Thu, 19 Sep 2024 14:14:39 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E5=B0=86=E5=BE=85=E5=8A=9E=E5=8F=91?=
 =?UTF-8?q?=E9=80=81=E6=94=B9=E4=B8=BA=E5=BC=82=E6=AD=A5=E8=B0=83=E7=94=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../activiti/listener/MyGlobalEventListener.java       | 10 ++++++----
 1 file changed, 6 insertions(+), 4 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 9af9e051..8de61ba7 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
@@ -32,6 +32,7 @@ import org.activiti.engine.impl.persistence.entity.TaskEntity;
 import org.springframework.stereotype.Component;
 
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
 
 /**
  * @author liJiaRao
@@ -169,7 +170,7 @@ public class MyGlobalEventListener implements ActivitiEventListener {
         hiworkTodoAdd.setRecordId(approvalRecord.getId());
         hiworkTodoAdd.setProcessDefinitionId(processDefinitionId);
         list.add(hiworkTodoAdd);
-        pushWorkflowIntegrationAPI.sendTodoTask(list);
+        CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
     }
 
     private void taskAssigned(ActivitiEvent event) {
@@ -199,7 +200,7 @@ public class MyGlobalEventListener implements ActivitiEventListener {
             hiworkTodoAdd.setType("2");
             hiworkTodoAdd.setProcessDefinitionId(processDefinitionId);
             list.add(hiworkTodoAdd);
-            pushWorkflowIntegrationAPI.sendTodoTask(list);
+            CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
 
             //更新转办任务id
             LambdaUpdateWrapper<ProcessApprovalRecord> update = new LambdaUpdateWrapper<>();
@@ -211,7 +212,7 @@ public class MyGlobalEventListener implements ActivitiEventListener {
             hiworkTodoAdd.setToUserId(assignee);
             hiworkTodoAdd.setType("1");
             list.add(hiworkTodoAdd);
-            pushWorkflowIntegrationAPI.sendTodoTask(list);
+            CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
         }
 
     }
@@ -295,7 +296,8 @@ public class MyGlobalEventListener implements ActivitiEventListener {
         hiworkTodoAdd.setRecordId(approvalRecord.getId());
         hiworkTodoAdd.setProcessDefinitionId(processDefinitionId);
         list.add(hiworkTodoAdd);
-        pushWorkflowIntegrationAPI.sendTodoTask(list);
+        // 异步发送待办
+        CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
     }
 
     private void entityDeleted(ActivitiEvent event) {