diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java index a71dffdf..b78c7bc8 100644 --- a/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java +++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/standardComplianceCheck/service/impl/ProcessStandardComplianceCheckServiceImpl.java @@ -212,7 +212,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl { + detailInfoList.parallelStream().forEach(detail -> { detail.setCheckId(checkId); detail.setProcessInstanceId(processInstanceId); }); @@ -360,7 +360,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl needAddDetailInfoList = new ArrayList<>(); - distributeDetailList.forEach(detail -> { + distributeDetailList.parallelStream().forEach(detail -> { String[] engineers = detail.getDesignEngineer().split(","); for (String engineer : engineers) { ProcessStandardComplianceCheckDetail newDetail = BeanCopyUtils. @@ -392,14 +392,14 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl { + detailInfoList.parallelStream().forEach(detail -> { detail.setAssessor(curUserId); detail.setAuthDept(curUserDepartIds); }); // 先删后增 sccDetailService.removeByIds(detailInfoListIds); - detailInfoList.forEach(detail -> detail.setValuationTime(new Date())); - detailInfoList.forEach(detail -> detail.setId(null)); + detailInfoList.parallelStream().forEach(detail -> detail.setValuationTime(new Date())); + detailInfoList.parallelStream().forEach(detail -> detail.setId(null)); sccDetailService.saveBatch(detailInfoList); } runtimeService.setVariable(processInstanceId, DISTRIBUTE, distributeFlag); @@ -408,7 +408,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl { + detailInfoList.parallelStream().forEach(detail -> { detail.setAssessor(curUserId); detail.setAuthDept(curUserDepartIds); detail.setValuationTime(new Date()); @@ -422,7 +422,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl detail.setId(null)); + detailInfoList.parallelStream().forEach(detail -> detail.setId(null)); sccDetailService.saveBatch(detailInfoList); // 不分发直接设置后续审批节点的人员变量 List counterSignUserList = Arrays.asList(standardInfo.getCountersignUser().split(",")); @@ -507,7 +507,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl String regex = "<[^>]*>"; - detailInfoList.forEach(detail -> { + detailInfoList.parallelStream().forEach(detail -> { if (StrUtil.isNotBlank(detail.getTermContent())) { detail.setTermContent(detail.getTermContent().replaceAll(regex, "")); } @@ -562,7 +562,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl String regex = "<[^>]*>"; - detailInfoList.forEach(detail -> { + detailInfoList.parallelStream().forEach(detail -> { if (StrUtil.isNotBlank(detail.getTermContent())) { detail.setTermContent(detail.getTermContent().replaceAll(regex, "")); } @@ -575,7 +575,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl data = BeanCopyUtils .copyBeanList(detailInfoList, WithoutDistributeExcelTemplate.class); // 翻译评估结果和佐证材料字段 - data.forEach(item -> { + data.parallelStream().forEach(item -> { item.setResult(excelUtils.translateDict("evaluation_result", item.getResult(), listDict)); item.setMaterial(excelUtils.translateDictValue("id", "file_name", "oss_file", item.getMaterial(), listDict)); }); @@ -765,7 +765,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl list, List listDict, Map fileMap) { - list.forEach(item -> { + list.parallelStream().forEach(item -> { item.setResult(excelUtils.translateDictValue("evaluation_result", item.getResult(), listDict)); item.setMaterial(excelUtils.uploadFile(item.getMaterial(), fileMap)); }); @@ -1091,7 +1091,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl result = BeanCopyUtils.copyBeanList(splitExcelVOList, ProcessStandardComplianceCheckDetail.class); - result.forEach(detail -> detail.setCheckId(sccId)); + result.parallelStream().forEach(detail -> detail.setCheckId(sccId)); return result; } @@ -1137,7 +1137,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl list, List listDict) { - list.forEach(item -> item.setModelState(excelUtils.translateDictValue("model_status", item.getModelState(), listDict))); + list.parallelStream().forEach(item -> item.setModelState(excelUtils.translateDictValue("model_status", item.getModelState(), listDict))); } @Override