From 1060d645b41edf14d57266015008b41c56edacea Mon Sep 17 00:00:00 2001
From: zc <zyzc>
Date: 星期二, 18 十一月 2025 20:54:25 +0800
Subject: [PATCH] 11

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/WaitPakinServiceImpl.java |   39 +++++++++++++++++++++------------------
 1 files changed, 21 insertions(+), 18 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/WaitPakinServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/WaitPakinServiceImpl.java
index 2fb0faf..00b16df 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/WaitPakinServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/WaitPakinServiceImpl.java
@@ -68,18 +68,20 @@
         if (!tasks.isEmpty()) {
             throw new CoolException("褰撳墠鎵樼洏宸叉湁浠诲姟妗e湪鎵ц锛屼笉鑳藉啀娆$粍鎵橈紒锛�");
         }
-        List<WaitPakinItem> waitPakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().eq(WaitPakinItem::getPakinId, pakin.getId()));
-        waitPakinItems.forEach(item -> {
-            for (PakinItem pakinItem : waitPakin.getItems()) {
-                WarehouseAreasItem warehouseAreasItems = warehouseAreasItemService.getById(pakinItem.getId());
-                if (Objects.isNull(warehouseAreasItems)) {
-                    throw new CoolException("鐗╂枡鏈�佽嚦鏀惰揣鍖烘垨宸茬粍鎵樺畬鎴愮Щ鍑烘敹璐у尯锛侊紒");
+        if (!Objects.isNull(pakin)) {
+            List<WaitPakinItem> waitPakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().eq(!Objects.isNull(pakin.getId()) ,WaitPakinItem::getPakinId, pakin.getId()));
+            waitPakinItems.forEach(item -> {
+                for (PakinItem pakinItem : waitPakin.getItems()) {
+                    WarehouseAreasItem warehouseAreasItems = warehouseAreasItemService.getById(pakinItem.getId());
+                    if (Objects.isNull(warehouseAreasItems)) {
+                        throw new CoolException("鐗╂枡鏈�佽嚦鏀惰揣鍖烘垨宸茬粍鎵樺畬鎴愮Щ鍑烘敹璐у尯锛侊紒");
+                    }
+                    if (item.getFieldsIndex().equals(warehouseAreasItems.getFieldsIndex())) {
+                        throw new CoolException("绁ㄥ彿锛�" + item.getExtendFields().get("crushNo") + "宸茬粍鎵橈紝涓嶅彲閲嶅缁勬墭锛侊紒");
+                    }
                 }
-                if (item.getFieldsIndex().equals(warehouseAreasItems.getFieldsIndex())) {
-                    throw new CoolException("绁ㄥ彿锛�" + item.getExtendFields().get("crushNo") + "宸茬粍鎵橈紝涓嶅彲閲嶅缁勬墭锛侊紒");
-                }
-            }
-        });
+            });
+        }
 
         List<Loc> locs = locService.list(new LambdaQueryWrapper<Loc>().eq(Loc::getBarcode, waitPakin.getBarcode()));
         if (!locs.isEmpty()) {
@@ -88,11 +90,6 @@
             throw new CoolException("鎵樼洏鐮侊細" + waitPakin.getBarcode() + "宸茶搴撲綅锛�" + join + "浣跨敤锛侊紒");
         }
         double sum = waitPakin.getItems().stream().mapToDouble(PakinItem::getReceiptQty).sum();
-        Double waitSum = 0.0;
-        if (!waitPakinItems.isEmpty()) {
-             waitSum = waitPakinItems.stream().mapToDouble(WaitPakinItem::getAnfme).sum();
-        }
-        Double total = Math.round((sum + waitSum) * 100) / 100.0;
 
         WaitPakin waitPakin1 = new WaitPakin();
         if (Objects.isNull(pakin)) {
@@ -162,7 +159,13 @@
         if (!waitPakinItemService.saveBatch(items)) {
             throw new CoolException("缁勬墭鏄庣粏淇濆瓨澶辫触锛侊紒");
         }
-//        Double sum1 = items.stream().mapToDouble(WaitPakinItem::getAnfme).sum();
+
+        List<WaitPakinItem> pakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().eq(WaitPakinItem::getPakinId, waitPakin1.getId()));
+        Double waitSum = 0.0;
+        if (!pakinItems.isEmpty()) {
+            waitSum = pakinItems.stream().mapToDouble(WaitPakinItem::getAnfme).sum();
+        }
+//        Double total = Math.round((sum + waitSum) * 100) / 100.0;
 
         for (WaitPakinItem pakinItem : items) {
             WarehouseAreasItem one = warehouseAreasItemService.getOne(new LambdaQueryWrapper<WarehouseAreasItem>()
@@ -181,7 +184,7 @@
             }
         }
 
-        waitPakin1.setAnfme(total);
+        waitPakin1.setAnfme(waitSum);
         if (!this.updateById(waitPakin1)) {
             throw new CoolException("缁勬墭鏁伴噺淇敼澶辫触锛侊紒");
         }

--
Gitblit v1.9.1