ZQ/laws-sinotruk-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 将待办发送改为异步调用

Browse Source
This commit is contained in:
mzaxd
2024-09-19 14:14:39 +08:00
parent 29d442678d
commit 6f20c28155
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
laws-modules/src/main/java/com/jero/modules/activiti/listener/MyGlobalEventListener.java
+6 -4
View File
@@ -32,6 +32,7 @@ import org.activiti.engine.impl.persistence.entity.TaskEntity;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.util.*; import java.util.*;
import java.util.concurrent.CompletableFuture;
/** /**
* @author liJiaRao * @author liJiaRao
@@ -169,7 +170,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);
pushWorkflowIntegrationAPI.sendTodoTask(list); CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
} }
private void taskAssigned(ActivitiEvent event) { private void taskAssigned(ActivitiEvent event) {
@@ -199,7 +200,7 @@ public class MyGlobalEventListener implements ActivitiEventListener {
hiworkTodoAdd.setType("2"); hiworkTodoAdd.setType("2");
hiworkTodoAdd.setProcessDefinitionId(processDefinitionId); hiworkTodoAdd.setProcessDefinitionId(processDefinitionId);
list.add(hiworkTodoAdd); list.add(hiworkTodoAdd);
pushWorkflowIntegrationAPI.sendTodoTask(list); CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
//更新转办任务id //更新转办任务id
LambdaUpdateWrapper<ProcessApprovalRecord> update = new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<ProcessApprovalRecord> update = new LambdaUpdateWrapper<>();
@@ -211,7 +212,7 @@ public class MyGlobalEventListener implements ActivitiEventListener {
hiworkTodoAdd.setToUserId(assignee); hiworkTodoAdd.setToUserId(assignee);
hiworkTodoAdd.setType("1"); hiworkTodoAdd.setType("1");
list.add(hiworkTodoAdd); 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.setRecordId(approvalRecord.getId());
hiworkTodoAdd.setProcessDefinitionId(processDefinitionId); hiworkTodoAdd.setProcessDefinitionId(processDefinitionId);
list.add(hiworkTodoAdd); list.add(hiworkTodoAdd);
pushWorkflowIntegrationAPI.sendTodoTask(list); // 异步发送待办
CompletableFuture.runAsync(() -> pushWorkflowIntegrationAPI.sendTodoTask(list));
} }
private void entityDeleted(ActivitiEvent event) { private void entityDeleted(ActivitiEvent event) {