From b5f5d11e518ac4ef7eafb4c5c5f3e9c710c55e38 Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期一, 08 九月 2025 21:29:24 +0800
Subject: [PATCH] agv对接,许可证更新

---
 src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java |   75 ++++++++++++++++++++++++++++++++-----
 1 files changed, 65 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
index 54c52e1..48110f9 100644
--- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -26,10 +26,7 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.Iterator;
-import java.util.List;
+import java.util.*;
 
 /**
  * 绉诲姩绔湇鍔℃牳蹇冪被
@@ -88,17 +85,35 @@
         // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁
         if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>().
                 eq("zpallet", param.getBarcode()).eq("io_status", "N")) > 0) {
-            throw new CoolException(param.getBarcode() + "鏁版嵁姝e湪杩涜鍏ュ簱");
+            throw new CoolException(param.getBarcode() + "鏁版嵁缁勬墭妗d腑宸插瓨鍦�");
         }
 
         int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet",param.getBarcode()));
         int countWrk = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("zpallet",param.getBarcode()));
-        if (countLoc > 0 || countWrk > 0) {
-            throw new CoolException("宸ヤ綔妗�/搴撳瓨鏉$爜鏁版嵁宸插瓨鍦�===>>" + param.getBarcode());
+//        int countWrk = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("zpallet",param.getBarcode())
+//                                            .last(" wrk_no IN ( SELECT wrk_no FROM asr_wrk_mast WHERE wrk_sts != 15 )"));
+
+        if (countLoc > 0 ) {
+            throw new CoolException("搴撳瓨鏉$爜鏁版嵁宸插瓨鍦�===>>" + param.getBarcode());
+        }
+        if (countWrk > 0) {
+            throw new CoolException("宸ヤ綔妗f潯鐮佹暟鎹凡瀛樺湪===>>" + param.getBarcode());
         }
 
         Date now = new Date();
 
+        Set<String> batchs=new  HashSet<>();
+
+        for(CombParam.CombMat mat : param.getCombMats()){
+            if(Cools.isEmpty(mat.getBatch())){
+                throw new CoolException("鐗╂枡鎵瑰彿涓嶈兘涓虹┖");
+            }
+            batchs.add(mat.getBatch());
+        }
+        if(batchs.size()<param.getCombMats().size()){
+            throw new CoolException("鏈夐噸澶嶇殑鐗╂枡鎵瑰彿");
+        }
+        int i =1;
         // 鏃犲崟缁勬墭
         if (Cools.isEmpty(param.getOrderNo())) {
 
@@ -118,6 +133,9 @@
 
             for (DetlDto detlDto : detlDtos) {
                 Mat mat = matService.selectByMatnr(detlDto.getMatnr());
+                if (Cools.isEmpty(detlDto.getBatch())){
+                    detlDto.setBatch("");
+                }
                 if (Cools.isEmpty(mat)) {
                     throw new CoolException(detlDto.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�");
                 }
@@ -132,7 +150,26 @@
                 waitPakin.setAppeTime(now);
                 waitPakin.setModiUser(userId);
                 waitPakin.setModiTime(now);
-                if (!waitPakinService.insert(waitPakin)) {
+                waitPakin.setBrand(param.getCk());//浠撳簱
+                if(i==1){
+//                0锛氫笉闇�瑕佽ˉ绌烘墭鐩�
+//                1锛氬皬鎵樼洏
+//                2锛氬ぇ鎵樼洏
+                    waitPakin.setItemNum(param.getBarcodeSize());
+                    waitPakin.setMemo(Cools.isEmpty(param.getRsta()) ? "" : param.getRsta());//婧愮珯鐐�
+                    /**
+                     * agv鐘舵��
+                     * 0锛氭棤闇�璋冪敤AGV
+                     * 1锛氱瓑寰呰皟鐢ˋGV
+                     * 2锛欰GV浠诲姟涓嬪彂鎴愬姛
+                     * 3锛欰GV浠诲姟瀹屾垚
+                     * 4锛氱粰杈撻�佺嚎涓嬪彂鍏ュ簱鎸囦护
+                     */
+                    waitPakin.setBeBatch(param.getBeBatch());
+                    waitPakin.setSuppCode(param.getBarcode());
+                }
+                i++;
+            if (!waitPakinService.insert(waitPakin)) {
                     throw new CoolException("淇濆瓨鍏ュ簱閫氱煡妗eけ璐�");
                 }
             }
@@ -182,6 +219,24 @@
                 waitPakin.setAppeTime(now);
                 waitPakin.setModiUser(userId);
                 waitPakin.setModiTime(now);
+                if(i==1){
+//                0锛氫笉闇�瑕佽ˉ绌烘墭鐩�
+//                1锛氬皬鎵樼洏
+//                2锛氬ぇ鎵樼洏
+                    waitPakin.setItemNum(param.getBarcodeSize());
+                    waitPakin.setMemo(Cools.isEmpty(param.getRsta()) ? "" : param.getRsta());//婧愮珯鐐�
+                    /**
+                     * agv鐘舵��
+                     * 0锛氭棤闇�璋冪敤AGV
+                     * 1锛氱瓑寰呰皟鐢ˋGV
+                     * 2锛欰GV浠诲姟涓嬪彂鎴愬姛
+                     * 3锛欰GV浠诲姟瀹屾垚
+                     * 4锛氱粰杈撻�佺嚎涓嬪彂鍏ュ簱鎸囦护
+                     */
+                    waitPakin.setBeBatch(param.getBeBatch());
+                    waitPakin.setSuppCode(param.getBarcode());
+                }
+                i++;
                 if (!waitPakinService.insert(waitPakin)) {
                     throw new CoolException("淇濆瓨鍏ュ簱閫氱煡妗eけ璐�");
                 }
@@ -212,14 +267,14 @@
                 throw new CoolException(combMat.getMatnr() + ":鍟嗗搧鏁伴噺鏈夎锛�");
             }
             if (Cools.isEmpty(combMat.getBatch())){
-                throw new CoolException(combMat.getMatnr() + ":鍟嗗搧鎵瑰彿鏈夎锛�");
+//                throw new CoolException(combMat.getMatnr() + ":鍟嗗搧鎵瑰彿鏈夎锛�");
             }
             ManLocDetl manLocDetl = new ManLocDetl();
             manLocDetl.setLocNo(locno);
             manLocDetl.setNodeId(node.getId());
             manLocDetl.setMaktx(mat.getMaktx());
             manLocDetl.setMatnr(mat.getMatnr());
-            manLocDetl.setBatch(combMat.getBatch());
+            manLocDetl.setBatch(Cools.isEmpty(combMat.getBatch()) ? "" : combMat.getBatch());
             manLocDetl.setAnfme(combMat.getAnfme());
             manLocDetl.setModiTime(now);
             if (!manLocDetlService.insert(manLocDetl)) {

--
Gitblit v1.9.1