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 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) {