From de5a82d0a701a65585d064f83c4a84ce5ed57761 Mon Sep 17 00:00:00 2001
From: Joshi <3040996759@qq.com>
Date: Sun, 21 Jun 2026 15:40:25 +0800
Subject: [PATCH] =?UTF-8?q?refactor(TsComplaintAcceptService):=20=E4=BC=98?=
 =?UTF-8?q?=E5=8C=96=E9=92=A2=E5=8D=B7=E5=85=B3=E8=81=94=E6=8F=92=E5=85=A5?=
 =?UTF-8?q?=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将单条插入改为批量插入以提升性能
- 使用Stream API重构钢卷关联数据构建过程
- 减少了数据库操作次数，提高处理效率
---
 .../flow/service/impl/TsComplaintAcceptServiceImpl.java  | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/klp-flow/src/main/java/com/klp/flow/service/impl/TsComplaintAcceptServiceImpl.java b/klp-flow/src/main/java/com/klp/flow/service/impl/TsComplaintAcceptServiceImpl.java
index 320c9ac7..6460336a 100644
--- a/klp-flow/src/main/java/com/klp/flow/service/impl/TsComplaintAcceptServiceImpl.java
+++ b/klp-flow/src/main/java/com/klp/flow/service/impl/TsComplaintAcceptServiceImpl.java
@@ -101,14 +101,15 @@ public class TsComplaintAcceptServiceImpl implements ITsComplaintAcceptService {
         boolean flag = baseMapper.insert(add) > 0;
         if (flag) {
             bo.setAcceptId(add.getAcceptId());
-            // 插入关联钢卷
+            // 批量插入关联钢卷
             if (bo.getCoilIds() != null && !bo.getCoilIds().isEmpty()) {
-                for (Long coilId : bo.getCoilIds()) {
+                List<TsAcceptCoilRel> relList = bo.getCoilIds().stream().map(coilId -> {
                     TsAcceptCoilRel rel = new TsAcceptCoilRel();
                     rel.setAcceptId(add.getAcceptId());
                     rel.setCoilId(coilId);
-                    tsAcceptCoilRelMapper.insert(rel);
-                }
+                    return rel;
+                }).collect(java.util.stream.Collectors.toList());
+                tsAcceptCoilRelMapper.insertBatch(relList);
             }
         }
         return flag;