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