From 82065a03737fa1370eb9f4f01ab5332933baf08a Mon Sep 17 00:00:00 2001
From: chen.lin <1442464845@qq.com>
Date: 星期四, 05 三月 2026 09:23:37 +0800
Subject: [PATCH] 云仓WMS+RCS+自动入库临时方法配置

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/AsnOrderServiceImpl.java |   25 ++++++++++++++++++++++++-
 1 files changed, 24 insertions(+), 1 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/AsnOrderServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/AsnOrderServiceImpl.java
index 1f39b07..1eb0a76 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/AsnOrderServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/AsnOrderServiceImpl.java
@@ -17,6 +17,7 @@
 import com.vincent.rsf.server.manager.controller.params.BatchUpdateParam;
 import com.vincent.rsf.server.manager.entity.*;
 import com.vincent.rsf.server.manager.enums.*;
+import com.vincent.rsf.server.common.utils.QuantityUtils;
 import com.vincent.rsf.server.manager.mapper.AsnOrderMapper;
 import com.vincent.rsf.server.manager.service.*;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -383,7 +384,7 @@
     public R removeOrders(List<Long> ids) {
         // 宸茬粍鎵樹笉鍙垹闄わ紝闇�鍏堣В闄ょ粍鎵�
         long palletizedCount = waitPakinItemService.count(new LambdaQueryWrapper<WaitPakinItem>()
-                .in(WaitPakinItem::getAsnId, ids));
+                .in(WaitPakinItem::getAsnId, ids).eq(WaitPakinItem::getDeleted, 0));
         if (palletizedCount > 0) {
             throw new CoolException("鍗曟嵁宸茬粍鎵橈紝璇峰厛瑙i櫎缁勬墭鍚庡啀鍒犻櫎锛侊紒");
         }
@@ -560,4 +561,26 @@
             throw new CoolException("鍘熷崟鎹垹闄ゅけ璐ワ紒锛�");
         }
     }
+
+    @Override
+    public void fillPalletQty(List<WkOrder> orders) {
+        if (orders == null || orders.isEmpty()) {
+            return;
+        }
+        List<Long> orderIds = orders.stream().map(WkOrder::getId).filter(Objects::nonNull).collect(Collectors.toList());
+        if (orderIds.isEmpty()) {
+            return;
+        }
+        List<WaitPakinItem> allItems = waitPakinItemService.list(
+                new LambdaQueryWrapper<WaitPakinItem>().in(WaitPakinItem::getAsnId, orderIds).eq(WaitPakinItem::getDeleted, 0));
+        Map<Long, Double> sumByAsnId = allItems.stream()
+                .collect(Collectors.groupingBy(WaitPakinItem::getAsnId,
+                        Collectors.summingDouble(w -> w.getAnfme() != null ? w.getAnfme() : 0.0)));
+        sumByAsnId.replaceAll((k, v) -> QuantityUtils.roundToScale(v));
+        for (WkOrder order : orders) {
+            if (order.getId() != null) {
+                order.setPalletQty(sumByAsnId.getOrDefault(order.getId(), 0.0));
+            }
+        }
+    }
 }

--
Gitblit v1.9.1