From 5701eb6693c654d53f1bba460eb3a417d495b344 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期三, 11 六月 2025 17:31:53 +0800
Subject: [PATCH] bug修复；下发任务给rcs携带货架码

---
 src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java |   53 ++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 42 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
index f7791fb..a01cb80 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
@@ -58,14 +58,18 @@
         List<AgvWrkDetl> agvWrkDetls = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", taskCode));
         long flowId = snowflakeIdWorker.nextId();
         agvWrkDetls.stream().map(agvWrkDetl -> {
-            AgvLocDetl agvLocDetl = new AgvLocDetl();
-            //log.info("agvWrkDetl: " + agvLocDetl.getBarcode());
-            BeanUtils.copyProperties(agvWrkDetl, agvLocDetl);
-            agvLocDetl.setLocNo(locNo);
-            //log.info("zc娣诲姞搴撳瓨鏃ュ織:{}", JSON.toJSON(agvLocDetl));
-            this.insert(agvLocDetl);
-            // 娴佹按 -- 鏂板璁㈠崟鏄庣粏
-            OrderDetl orderDetl = orderDetlService.selectItem(agvWrkDetl.getOrderNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode());
+            AgvLocDetl agvLocDetl = this.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo).eq("matnr", agvWrkDetl.getMatnr()).eq("three_code", agvWrkDetl.getThreeCode()));
+            if (agvLocDetl != null) {
+                this.updateAnfme(agvLocDetl.getAnfme() + agvWrkDetl.getAnfme(), agvLocDetl.getLocNo(), agvLocDetl.getMatnr(), agvLocDetl.getBatch(), agvLocDetl.getThreeCode(), agvLocDetl.getDeadTime());
+            } else {
+                agvLocDetl = new AgvLocDetl();
+                //log.info("agvWrkDetl: " + agvLocDetl.getBarcode());
+                BeanUtils.copyProperties(agvWrkDetl, agvLocDetl);
+                agvLocDetl.setLocNo(locNo);
+                //log.info("zc娣诲姞搴撳瓨鏃ュ織:{}", JSON.toJSON(agvLocDetl));
+                this.insert(agvLocDetl);
+                // 娴佹按 -- 鏂板璁㈠崟鏄庣粏
+                //OrderDetl orderDetl = orderDetlService.selectItem(agvWrkDetl.getOrderNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode());
 //            FlowLog flowLog = new FlowLog();
 //            flowLog.setFid(String.valueOf(flowId));
 //            flowLog.setSpare2(String.valueOf(taskCode));
@@ -91,6 +95,7 @@
 //            if (!flowLogService.insert(flowLog)) {
 //                throw new CoolException("鍚屾鍗婃垚鍝佽皟鎷ㄥ崟娴佹按璁板綍澶辫触");
 //            }
+            }
             return agvLocDetl;
         }).collect(Collectors.toList());
 
@@ -105,6 +110,7 @@
             } else {
                 if (matnr.startsWith("401") || matnr.startsWith("402")) {
                     //wrapper.notLike("loc_no", "F3");
+                    wrapper.notLike("loc_no", "F1");
                 } else {
                     wrapper.notLike("loc_no", "F1");
                 }
@@ -193,8 +199,12 @@
     /*
     鏇存柊搴撳瓨鏄庣粏
      */
-    public void updateStock(String sourceLoc, String targetLoc) {
-        this.baseMapper.updateStock(sourceLoc, targetLoc);
+    public void updateStock(String sourceLoc, String targetLoc,Long userId) {
+        if (Cools.isEmpty(userId)){
+            this.baseMapper.updateStock(sourceLoc, targetLoc);
+        }else {
+            this.baseMapper.updateStock2(sourceLoc, targetLoc, userId);
+        }
     }
 
     public Page<AgvLocDetl> getStockStatis(Page<AgvLocDetl> page) {
@@ -209,8 +219,19 @@
     }
 
     @Override
+    public Double getSumAnfme2(String matnr, String threeCode) {
+        return this.baseMapper.selectSumAnfmeByMatnr2(matnr, threeCode);
+    }
+
+
+    @Override
     public AgvLocDetl selectItem(String locNo, String matnr, String batch, String csocode, String isoCode) {
         return this.baseMapper.selectItemByOrderNo(locNo, matnr, batch, csocode, isoCode);
+    }
+
+    @Override
+    public List<AgvLocDetl> selectItem2(String locNo, String matnr, String batch, String csocode, String isoCode) {
+        return this.baseMapper.selectItemByOrderNo2(locNo, matnr, batch, csocode, isoCode);
     }
 
     @Override
@@ -224,8 +245,18 @@
     }
 
     @Override
+    public Double getSumAnfmeProcessed2(String matnr, String threeCode) {
+        return this.baseMapper.selectSumAnfmeByMatnrProcessed2(matnr, threeCode);
+    }
+
+    @Override
     public Double getSumAnfmeDb(String matnr, String threeCode, Integer floor) {
-        return this.baseMapper.selectSumAnfmeByMatnr2(matnr, threeCode, floor);
+        return this.baseMapper.selectSumAnfmeByMatnr22(matnr, threeCode, floor);
+    }
+
+    @Override
+    public Double getSumAnfmeDb2(String matnr, String threeCode, Integer floor) {
+        return this.baseMapper.selectSumAnfmeByMatnr3(matnr, threeCode, floor);
     }
 
     @Override

--
Gitblit v1.9.1