QR/laws_chery_serve
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf: 88136 scc流程发起并发性能

Browse Source
This commit is contained in:
mzaxd
2024-08-13 17:06:11 +08:00
parent 297472ae02
commit 102b94faa4
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/controller/ProcessStandardComplianceCheckController.java
+2 -1
View File
@@ -40,6 +40,7 @@ import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.CompletableFuture;
/** /**
* 流程-测试流程(process_demo)表控制层 * 流程-测试流程(process_demo)表控制层
@@ -63,7 +64,7 @@ public class ProcessStandardComplianceCheckController extends JeroController<Pro
@ApiOperation(value = "法规符合性排查流程-发起流程", notes = "法规符合性排查流程-发起流程") @ApiOperation(value = "法规符合性排查流程-发起流程", notes = "法规符合性排查流程-发起流程")
@PostMapping(value = "/start") @PostMapping(value = "/start")
public Result<T> startProcess(@Validated @RequestBody ProcessInfoVO<ProcessSccVO> processInfoVO) { public Result<T> startProcess(@Validated @RequestBody ProcessInfoVO<ProcessSccVO> processInfoVO) {
sccService.startProcess(processInfoVO); CompletableFuture.runAsync(() -> sccService.startProcess(processInfoVO));
return Result.OK(); return Result.OK();
} }
laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java
+3 -2
View File
@@ -85,6 +85,7 @@ import java.io.InputStream;
import java.nio.file.Files; import java.nio.file.Files;
import java.nio.file.Path; import java.nio.file.Path;
import java.util.*; import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import static com.jero.modules.activiti.common.ActivitiCommon.*; import static com.jero.modules.activiti.common.ActivitiCommon.*;
@@ -164,7 +165,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl<Proce
processInfo.setProcessDefinitionId(processDefinitionId); processInfo.setProcessDefinitionId(processDefinitionId);
processInfo.setProcessType(ProcessTypeEnum.STANDARD_COMPLIANCE_CHECK.getValue()); processInfo.setProcessType(ProcessTypeEnum.STANDARD_COMPLIANCE_CHECK.getValue());
// 第一个节点业务数据处理 // 第一个节点业务数据处理
this.startNodeBusProcess(processInfoVO); CompletableFuture.runAsync(() -> this.startNodeBusProcess(processInfoVO));
// 保存选人信息 // 保存选人信息
processNodeLinkService.saveNodeUserLink(processDefinitionId, processInstanceId, userInfoMap); processNodeLinkService.saveNodeUserLink(processDefinitionId, processInstanceId, userInfoMap);
// 获取第一个任务的taskId // 获取第一个任务的taskId
@@ -234,7 +235,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl<Proce
detail.setCheckId(checkId); detail.setCheckId(checkId);
detail.setProcessInstanceId(processInstanceId); detail.setProcessInstanceId(processInstanceId);
}); });
sccDetailService.saveBatch(detailInfoList); sccDetailService.saveBatch(detailInfoList, detailInfoList.size());
} }
private Map<String, Object> setVariables(ProcessInfoVO<ProcessSccVO> businessInfoDTO) { private Map<String, Object> setVariables(ProcessInfoVO<ProcessSccVO> businessInfoDTO) {