feat: 去除异步发送待办

This commit is contained in:
2024-09-20 16:19:06 +08:00
parent ed0ad26eb3
commit 2eaa74e032
@@ -35,7 +35,6 @@ import java.util.*;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/** /**
* @author liJiaRao * @author liJiaRao
@@ -173,12 +172,8 @@ public class MyGlobalEventListener implements ActivitiEventListener {
hiworkTodoAdd.setRecordId(approvalRecord.getId()); hiworkTodoAdd.setRecordId(approvalRecord.getId());
hiworkTodoAdd.setProcessDefinitionId(processDefinitionId); hiworkTodoAdd.setProcessDefinitionId(processDefinitionId);
list.add(hiworkTodoAdd); list.add(hiworkTodoAdd);
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
// 调度5秒后执行异步任务 // 调度5秒后执行异步任务
scheduler.schedule(() -> pushWorkflowIntegrationAPI.sendTodoTask(list);
CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list)),
5, TimeUnit.SECONDS
);
} }
private void taskAssigned(ActivitiEvent event) { private void taskAssigned(ActivitiEvent event) {
@@ -306,13 +301,7 @@ public class MyGlobalEventListener implements ActivitiEventListener {
hiworkTodoAdd.setRecordId(approvalRecord.getId()); hiworkTodoAdd.setRecordId(approvalRecord.getId());
hiworkTodoAdd.setProcessDefinitionId(processDefinitionId); hiworkTodoAdd.setProcessDefinitionId(processDefinitionId);
list.add(hiworkTodoAdd); 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) { private void entityDeleted(ActivitiEvent event) {