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/AsnOrderServiceImpl.java |   45 ++++++++++++++++++++++++++++++---------------
 1 files changed, 30 insertions(+), 15 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 011bd52..576f97b 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
@@ -254,6 +254,7 @@
      * @version 1.0
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public R createByPo(Map<String, Object> params) {
         Long purchaseId = Long.parseLong(params.get("purchaseId").toString());
         List<PurchaseItem> itemList = JSONArray.parseArray(JSONObject.toJSONString(params.get("items")), PurchaseItem.class);
@@ -287,6 +288,12 @@
             if (StringUtils.isBlank(trackCode)) {
                 throw new CoolException("鍗曟嵁璺熻釜鐮佺敓鎴愬け璐ワ細璇锋鏌ャ�宻ys_asn_mantr_label銆嶆槸鍚﹂厤缃畬鎴愶紒锛�");
             }
+
+            PurchaseItem service = purchaseItemService.getById(item.getId());
+            Double qty = Math.round((service.getQty() + item.getAnfme()) * 10000) / 10000.0;
+            if (qty.compareTo(service.getAnfme()) > 0) {
+                throw new CoolException("鏂板缓鍗曟嵁鏁伴噺涓嶈兘澶т簬璁″垝鏁伴噺锛侊紒");
+            }
             orderItem.setAnfme(item.getAnfme())
                     .setAsnId(order.getId())
                     .setSplrName(item.getSplrName())
@@ -309,7 +316,9 @@
             if (Objects.isNull(purchaseItem)) {
                 throw new CoolException("鍗曟嵁涓嶅瓨鍦紒锛�");
             }
-            purchaseItem.setQty(purchaseItem.getQty() +  item.getAnfme());
+
+            Double toQty = Math.round((purchaseItem.getQty() + item.getAnfme()) * 10000) / 10000.0;
+            purchaseItem.setQty(toQty);
             if (!purchaseItemService.updateById(purchaseItem)) {
                 throw new CoolException("PO鍗曟槑缁嗕慨鏀瑰け璐ワ紒锛�");
             }
@@ -321,7 +330,8 @@
             throw new CoolException(("Asn鍗曟嵁鏄庣粏淇濆瓨澶辫触锛侊紒"));
         }
         //浠诲姟鎵ц瀹屾垚锛屼慨鏀瑰凡瀹屾垚鏁伴噺鍜孭O鍗曟墽琛岀姸鎬�
-        purchase.setQty(sum + purchase.getQty())
+        Double qty = Math.round((sum + purchase.getQty()) * 10000) / 10000.0;
+        purchase.setQty(qty)
                 .setExceStatus(POExceStatus.PO_EXCE_STATUS_EXCE_ING.val);
 
         if (!purchaseService.saveOrUpdate(purchase)) {
@@ -354,10 +364,11 @@
             list.forEach(item -> {
                 PurchaseItem purchaseItem = purchaseItemService.getById(item.getPoDetlId());
                 if (!Objects.isNull(purchaseItem)) {
-                    purchaseItem.setQty(purchaseItem.getQty() - item.getAnfme());
-                }
-                if (!purchaseItemService.updateById(purchaseItem)) {
-                    throw new CoolException("PO鍗曟槑缁嗘洿鏂板け璐ワ紒锛�");
+                    Double minusQty = Math.round((purchaseItem.getQty() - item.getAnfme()) * 10000) / 10000.0;
+                    purchaseItem.setQty(minusQty);
+                    if (!purchaseItemService.updateById(purchaseItem)) {
+                        throw new CoolException("PO鍗曟槑缁嗘洿鏂板け璐ワ紒锛�");
+                    }
                 }
             });
 
@@ -365,17 +376,15 @@
 
             Purchase purchase = purchaseService.getOne(new LambdaQueryWrapper<Purchase>()
                     .eq(Purchase::getCode, list.stream().findFirst().get().getPoCode()));
-            purchase.setQty(purchase.getQty() - sum)
-                    .setExceStatus(POExceStatus.PO_EXCE_STATUS_EXCE_ING.val);
+            if (!Objects.isNull(purchase)) {
+                Double qty = Math.round((purchase.getQty() - sum) * 10000) / 10000.0;
+                purchase.setQty(qty)
+                        .setExceStatus(POExceStatus.PO_EXCE_STATUS_EXCE_ING.val);
 
-            if (!purchaseService.updateById(purchase)) {
-                throw new CoolException("PO鍗曟嵁鏇存柊澶辫触锛侊紒");
+                if (!purchaseService.updateById(purchase)) {
+                    throw new CoolException("PO鍗曟嵁鏇存柊澶辫触锛侊紒");
+                }
             }
-        }
-
-        if (!asnOrderItemService.remove(new LambdaQueryWrapper<AsnOrderItem>()
-                .in(AsnOrderItem::getAsnId, ids))) {
-            throw new CoolException("Details Delete Fail");
         }
 
         if (!this.remove(new LambdaQueryWrapper<AsnOrder>()
@@ -384,6 +393,12 @@
             throw new CoolException("浠诲姟涓崟鎹笉鍙垹闄わ紒锛�");
         }
 
+
+        if (!asnOrderItemService.remove(new LambdaQueryWrapper<AsnOrderItem>()
+                .in(AsnOrderItem::getAsnId, ids))) {
+//            throw new CoolException("Details Delete Fail");
+        }
+
         return R.ok("鎿嶄綔鎴愬姛锛侊紒");
     }
 

--
Gitblit v1.9.1