From c255a17d7ef4fabb37c1ac84b212768e73c42915 Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期四, 29 五月 2025 16:57:17 +0800
Subject: [PATCH] Merge branch 'devlop' of http://47.97.1.152:5880/r/wms-master into devlop

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/WaitPakinServiceImpl.java |   37 +++++++++++++++++++++----------------
 1 files changed, 21 insertions(+), 16 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 6ef56c2..988d27a 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
@@ -63,9 +63,8 @@
         if (StringUtils.isBlank(waitPakin.getBarcode())) {
             throw new CoolException("鍙傛暟閿欒锛氭墭鐩樼爜涓虹┖锛侊紒");
         }
-        List<Short> asList = Arrays.asList(Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val), Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val));
+//        List<Short> asList = Arrays.asList(Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val), Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val));
         WaitPakin pakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>()
-                .notIn(WaitPakin::getIoStatus, asList)
                 .eq(WaitPakin::getBarcode, waitPakin.getBarcode()));
         if (!Objects.isNull(pakin)) {
             throw new CoolException("鎵樼洏鐮侊細" + waitPakin.getBarcode() + "宸茶缁勬墭鍗曪細" + pakin.getCode() + "浣跨敤锛侊紒");
@@ -85,7 +84,7 @@
         }
         waitPakin1.setCode(ruleCode)
                 //鐘舵�佷慨鏀逛负鍏ュ簱涓�
-                .setIoStatus(Short.parseShort(PakinIOStatus.PAKIN_IO_STATUS_DONE.val))
+                .setIoStatus(PakinIOStatus.PAKIN_IO_STATUS_DONE.val)
                 .setAnfme(sum)
                 .setUpdateBy(userId)
                 .setCreateBy(userId)
@@ -119,6 +118,10 @@
                     .setAsnCode(warehouseAreasItems.getAsnCode())
                     .setAsnItemId(warehouseAreasItems.getAsnItemId())
                     .setIsptResult(warehouseAreasItems.getIsptResult())
+                    .setPlatItemId(warehouseAreasItems.getPlatItemId())
+                    .setPlatOrderCode(warehouseAreasItems.getPlatOrderCode())
+                    .setPlatWorkCode(warehouseAreasItems.getPlatWorkCode())
+                    .setProjectCode(warehouseAreasItems.getProjectCode())
                     .setBatch(warehouseAreasItems.getSplrBatch())
                     .setUnit(warehouseAreasItems.getStockUnit())
                     .setFieldsIndex(warehouseAreasItems.getFieldsIndex())
@@ -146,7 +149,7 @@
 
         }
 
-        double sum1 = items.stream().mapToDouble(WaitPakinItem::getAnfme).sum();
+        Double sum1 = items.stream().mapToDouble(WaitPakinItem::getAnfme).sum();
 
         if (!waitPakinItemService.saveBatch(items)) {
             throw new CoolException("缁勬墭鏄庣粏淇濆瓨澶辫触锛侊紒");
@@ -158,9 +161,10 @@
             if (Objects.isNull(one)) {
                 throw new CoolException("鏀惰揣鍖烘暟鎹敊璇紒锛�");
             }
-//            one.setAnfme(one.getAnfme() - pakinItem.getAnfme())
-            one.setWorkQty(one.getWorkQty() + pakinItem.getAnfme() + one.getQty());
-            if (one.getWorkQty() > one.getAnfme()) {
+            Double workQty = Math.round((one.getWorkQty() + pakinItem.getAnfme()) * 10000) / 10000.0;
+            Double qty = Math.round((workQty + one.getQty()) * 10000) / 10000.0;
+            one.setWorkQty(workQty);
+            if (qty.compareTo(one.getAnfme()) > 0) {
                 throw new CoolException("缁勬墭鏁伴噺涓嶈兘澶т簬鏀惰揣鏁伴噺锛侊紒");
             }
             if (!warehouseAreasItemService.saveOrUpdate(one)) {
@@ -172,9 +176,6 @@
         if (!this.updateById(waitPakin1)) {
             throw new CoolException("缁勬墭鏁伴噺淇敼澶辫触锛侊紒");
         }
-
-        //TODO 缁勬墭瀹屾垚鍚庯紝鎵e噺鏀惰揣鍖哄簱瀛�
-
         return pakin;
     }
 
@@ -219,10 +220,13 @@
                             if (item.getReceiptQty().compareTo(0.00) == 0) {
                                 throw new CoolException("瑙g粦鏁伴噺涓嶈兘涓洪浂锛侊紒");
                             }
-                            if (item.getReceiptQty().compareTo(pakinItems.get(i1).getAnfme() - pakinItems.get(i1).getWorkQty() - pakinItems.get(i1).getQty()) > 0) {
+                            Double reslt = Math.round((pakinItems.get(i1).getAnfme() - pakinItems.get(i1).getWorkQty() - pakinItems.get(i1).getQty()) * 10000) / 10000.0;
+                            if (item.getReceiptQty().compareTo(reslt) > 0) {
                                 throw new CoolException("瑙g粦鏁伴噺涓嶈兘澶т簬鍓╀綑鍙墽琛屾暟锛侊紒");
                             }
-                           pakinItems.get(i1).setAnfme(pakinItems.get(i1).getAnfme() - item.getReceiptQty());
+
+                            Double anfme = Math.round((pakinItems.get(i1).getAnfme() - item.getReceiptQty()) * 10000) / 10000.0;
+                           pakinItems.get(i1).setAnfme(anfme);
                            if (!waitPakinItemService.updateById(pakinItems.get(i1))) {
                                throw new CoolException("缁勬墭鏄庣粏鏁伴噺淇敼澶辫触锛侊紒");
                            }
@@ -233,7 +237,7 @@
                         }
                         for (int i = 0; i < warehouseAreasItems.size(); i++) {
                             if (warehouseAreasItems.get(i).getId().equals(pakinItems.get(i1).getSource())) {
-                                double v = warehouseAreasItems.get(i).getWorkQty() - item.getReceiptQty();
+                                double v = Math.round((warehouseAreasItems.get(i).getWorkQty() - item.getReceiptQty()) * 10000) / 10000.0;
                                 warehouseAreasItems.get(i).setWorkQty(v);
                                 if (!warehouseAreasItemService.updateById(warehouseAreasItems.get(i))) {
                                     throw new CoolException("鏀惰揣鍖烘暟閲忎慨鏀瑰け璐ワ紒锛�");
@@ -251,7 +255,8 @@
                     throw new CoolException("缁勬墭鍒犻櫎澶辫触锛侊紒");
                 }
             } else {
-                waitPakins.setAnfme(waitPakins.getAnfme() - anfmes);
+                Double anfme = Math.round((waitPakins.getAnfme() - anfmes) * 10000) / 10000.0;
+                waitPakins.setAnfme(anfme);
                 if (!waitPakinService.updateById(waitPakins)) {
                     throw new CoolException("缁勬墭鏁版嵁淇敼澶辫触锛侊紒");
                 }
@@ -295,8 +300,8 @@
                     continue;
                 }
                 double sum = pakin.stream().mapToDouble(WaitPakinItem::getAnfme).sum();
-                item.setWorkQty(item.getWorkQty() - sum)
-                        .setAnfme(item.getAnfme() + sum);
+                Double workQty = Math.round((item.getWorkQty() - sum) * 10000) / 10000.0;
+                item.setWorkQty(workQty);
                 if (!warehouseAreasItemService.updateById(item)) {
                     throw new CoolException("鏀惰揣鍖烘暟鎹洖婊氬け璐ワ紒锛�");
                 }

--
Gitblit v1.9.1