From e22952465f1ab08a58f84c2f01e7d4e89b6bd61e Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期一, 18 八月 2025 17:10:34 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   33 +++++++++++++++++++--------------
 1 files changed, 19 insertions(+), 14 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index 61d6d09..ef9d076 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -749,7 +749,7 @@
 //            }
 
             //鍫嗗灈鏈哄洖鍘熺偣浠诲姟涓�
-            Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK);
+            Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK + crn.getId());
             if (object != null) {
                 continue;
             }
@@ -821,7 +821,7 @@
                     continue;
                 }
 
-                Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK);
+                Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK + crn.getId());
                 if (object != null) {
                     continue;
                 }
@@ -893,7 +893,7 @@
                     continue;
                 }
 
-                Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK);
+                Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK + crn.getId());
                 if (object != null) {
                     continue;
                 }
@@ -1650,6 +1650,7 @@
                 if (crnProtocol.getTaskNo() == 9999) {
                     // 鍫嗗灈鏈哄浣�
                     crnThread.setResetFlag(true);
+                    redisUtil.set(RedisConstantType.CRN_MOVE_LOCK + crn.getId(), "lock", 8);//闃叉鍥炲師鐐瑰悗涓嬪彂鎸囦护杩囧揩
                     continue;
                 }
 
@@ -2142,22 +2143,26 @@
 
                     if (!wrkDetls.isEmpty()) {
                         WrkDetl wrkDetl = wrkDetls.get(0);
+                        double anfme = 0D;
+                        double weight = 0D;
                         for (WrkDetl detl : wrkDetls) {
-                            double anfme = wrkDetl.getAnfme() + detl.getAnfme();
-                            double weight = wrkDetl.getWeight() + detl.getWeight();
-                            if (wrkDetl.getStockNum() != null) {
-                                double stockNum = wrkDetl.getStockNum() + detl.getStockNum();
-                                wrkDetl.setStockNum(stockNum);
-                            }
-
-                            if (wrkDetl.getStockNum2() != null) {
-                                double stockNum2 = wrkDetl.getStockNum2() + detl.getStockNum2();
-                                wrkDetl.setStockNum2(stockNum2);
-                            }
+                            anfme += detl.getAnfme();
+                            weight += detl.getWeight();
                             wrkDetl.setAnfme(anfme);
                             wrkDetl.setWeight(weight);
                         }
 
+                        List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>()
+                                .eq("loc_no", wrkMast.getSourceLocNo()));
+                        double totalAnfme = 0D;
+                        double totalWeight = 0D;
+                        for (LocDetl locDetl : locDetls) {
+                            totalAnfme += locDetl.getAnfme();
+                            totalWeight += locDetl.getWeight();
+                        }
+                        wrkDetl.setStockNum(totalAnfme);
+                        wrkDetl.setStockNum2(totalWeight);
+
                         ledCommand.getMatDtos().add(new MatDto(
                                 wrkDetl.getMatnr()
                                 , wrkDetl.getMaktx()

--
Gitblit v1.9.1