From 2ccb4fd908b8deffb1f3874e92fd3ac0f40059c1 Mon Sep 17 00:00:00 2001
From: caihaohan <caihaohan0712@foxmail.com>
Date: Tue, 13 Aug 2024 17:42:34 +0800
Subject: [PATCH] =?UTF-8?q?perf:=2088136=20scc=E6=B5=81=E7=A8=8B=E5=88=86?=
 =?UTF-8?q?=E5=8F=91=E8=8A=82=E7=82=B9=E6=80=A7=E8=83=BD=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/ProcessStandardComplianceCheckServiceImpl.java    | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

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 dfff9998..1fd0e38d 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
@@ -85,6 +85,7 @@ import java.io.InputStream;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.util.*;
+import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.stream.Collectors;
 
 import static com.jero.modules.activiti.common.ActivitiCommon.*;
@@ -378,7 +379,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl<Proce
                             .distinct()
                             .collect(Collectors.toList());
                     // 分发给多个人的需要复制数据并保存
-                    List<ProcessStandardComplianceCheckDetail> needAddDetailInfoList = new ArrayList<>();
+                    Queue<ProcessStandardComplianceCheckDetail> needAddDetailInfoQueue = new ConcurrentLinkedQueue<>();
                     distributeDetailList.parallelStream().forEach(detail -> {
                         String[] engineers = detail.getDesignEngineer().split(",");
                         for (String engineer : engineers) {
@@ -387,12 +388,12 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl<Proce
                             newDetail.setId(null);
                             newDetail.setDesignEngineer(engineer);
                             newDetail.setBatchId(batchId);
-                            needAddDetailInfoList.add(newDetail);
+                            needAddDetailInfoQueue.add(newDetail);
                         }
                     });
                     // 先删后增
                     sccDetailService.removeByIds(ids);
-                    sccDetailService.saveBatch(needAddDetailInfoList);
+                    sccDetailService.saveBatch(needAddDetailInfoQueue, needAddDetailInfoQueue.size());
                     runtimeService.setVariable(processInstanceId, DESIGNER_LIST, designEngineerList);
                     runtimeService.setVariable(processInstanceId, BATCH_ID, batchId);
                     userMap.put(DESIGNER_LIST, String.join(",", designEngineerList));