From 196e628665f908228a6f90ea7ff569ba01e6d825 Mon Sep 17 00:00:00 2001
From: Joshi <3040996759@qq.com>
Date: Thu, 11 Jun 2026 10:24:55 +0800
Subject: [PATCH] =?UTF-8?q?feat(WmsCoilAbnormal):=20=E6=B7=BB=E5=8A=A0?=
 =?UTF-8?q?=E9=92=A2=E5=8D=B7ID=E9=9B=86=E5=90=88=E6=89=B9=E9=87=8F?=
 =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 在WmsCoilAbnormalBo中新增coilIds字段用于批量查询
- 实现逗号分隔的coilIds批量查询逻辑
- 使用Stream API处理字符串分割和类型转换
- 添加空值过滤确保查询条件的有效性
- 集成到现有的查询条件构建流程中
---
 .../java/com/klp/domain/bo/WmsCoilAbnormalBo.java   |  5 +++++
 .../service/impl/WmsCoilAbnormalServiceImpl.java    | 13 +++++++++++++
 2 files changed, 18 insertions(+)

diff --git a/klp-wms/src/main/java/com/klp/domain/bo/WmsCoilAbnormalBo.java b/klp-wms/src/main/java/com/klp/domain/bo/WmsCoilAbnormalBo.java
index 6c6c8647..cd8d793f 100644
--- a/klp-wms/src/main/java/com/klp/domain/bo/WmsCoilAbnormalBo.java
+++ b/klp-wms/src/main/java/com/klp/domain/bo/WmsCoilAbnormalBo.java
@@ -30,6 +30,11 @@ public class WmsCoilAbnormalBo extends BaseEntity {
      */
     private Long coilId;
 
+    /**
+     * 钢卷ID集合（逗号分隔，用于批量查询）
+     */
+    private String coilIds;
+
     /**
      * 产线名称
      */
diff --git a/klp-wms/src/main/java/com/klp/service/impl/WmsCoilAbnormalServiceImpl.java b/klp-wms/src/main/java/com/klp/service/impl/WmsCoilAbnormalServiceImpl.java
index 5145767c..46071a4a 100644
--- a/klp-wms/src/main/java/com/klp/service/impl/WmsCoilAbnormalServiceImpl.java
+++ b/klp-wms/src/main/java/com/klp/service/impl/WmsCoilAbnormalServiceImpl.java
@@ -20,6 +20,8 @@ import java.util.Date;
 import java.util.List;
 import java.util.Map;
 import java.util.Collection;
+import java.util.stream.Collectors;
+import java.util.Arrays;
 
 /**
  * 钢卷异常信息Service业务层处理
@@ -64,6 +66,17 @@ public class WmsCoilAbnormalServiceImpl implements IWmsCoilAbnormalService {
         Map<String, Object> params = bo.getParams();
         LambdaQueryWrapper<WmsCoilAbnormal> lqw = Wrappers.lambdaQuery();
         lqw.eq(bo.getCoilId() != null, WmsCoilAbnormal::getCoilId, bo.getCoilId());
+        // 逗号分隔的 coilIds 批量查询
+        if (StringUtils.isNotBlank(bo.getCoilIds())) {
+            List<Long> ids = Arrays.stream(bo.getCoilIds().split(","))
+                .map(String::trim)
+                .filter(s -> !s.isEmpty())
+                .map(Long::valueOf)
+                .collect(Collectors.toList());
+            if (!ids.isEmpty()) {
+                lqw.in(WmsCoilAbnormal::getCoilId, ids);
+            }
+        }
         lqw.eq(StringUtils.isNotBlank(bo.getProductionLine()), WmsCoilAbnormal::getProductionLine, bo.getProductionLine());
         lqw.eq(StringUtils.isNotBlank(bo.getPosition()), WmsCoilAbnormal::getPosition, bo.getPosition());
         lqw.eq(StringUtils.isNotBlank(bo.getPlateSurface()), WmsCoilAbnormal::getPlateSurface, bo.getPlateSurface());