From 24bc9aa5888c7b98cf0a7d1bf05ec6c5624d3719 Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期一, 03 三月 2025 16:02:29 +0800
Subject: [PATCH] 四期

---
 src/main/java/com/zy/asrs/task/handler/AutoMoveHandler.java |  120 +++++++++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 110 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/handler/AutoMoveHandler.java b/src/main/java/com/zy/asrs/task/handler/AutoMoveHandler.java
index 344ef5b..9b17b0a 100644
--- a/src/main/java/com/zy/asrs/task/handler/AutoMoveHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/AutoMoveHandler.java
@@ -155,7 +155,8 @@
         //璐ф灦缂栫爜
         mast.setBarcode(agvLocMast.getBarcode());
         //璐ф灦绫诲瀷
-        mast.setWhsType(30);
+        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0,2)));
+
         // 鐩爣妤煎眰
         mast.setPauseMk(agvLocMast.getLocType3().toString());
 
@@ -191,10 +192,19 @@
         return SUCCESS;
     }
 
+
     private ReturnT<String> doAutoMove2(AgvWrkMast agvWrkMast) {
         Date now = new Date();
-        //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅
-        AgvLocMast locMast = agvCommonService.getLocNo(3, agvWrkMast.getCrnNo(), false, true);
+        String barcode = agvWrkMast.getBarcode();
+        AgvLocMast locMast;
+        if (Integer.parseInt(barcode.substring(0, 2)) == 31) {
+            //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅
+            locMast = agvCommonService.getLocByLocRule(6, 2, 1);
+        } else {
+            //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅
+            locMast = agvCommonService.getLocNo(3, agvWrkMast.getCrnNo(), false, true);
+        }
+
         if (Cools.isEmpty(locMast)) {
             log.info("鏆傛棤搴撲綅");
             return FAIL;
@@ -315,7 +325,8 @@
         //璐ф灦缂栫爜
         mast.setBarcode(agvLocMast.getBarcode());
         //璐ф灦绫诲瀷
-        mast.setWhsType(30);
+        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0,2)));
+
 
         mast.setAppeUser(9527L);
         mast.setAppeTime(now);
@@ -452,7 +463,8 @@
         //璐ф灦缂栫爜
         mast.setBarcode(agvLocMast.getBarcode());
         //璐ф灦绫诲瀷
-        mast.setWhsType(30);
+        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0,2)));
+
 
         mast.setAppeUser(9527L);
         mast.setAppeTime(now);
@@ -536,7 +548,8 @@
         //璐ф灦缂栫爜
         mast.setBarcode(agvLocMast.getBarcode());
         //璐ф灦绫诲瀷
-        mast.setWhsType(30);
+        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0,2)));
+
 
         mast.setAppeUser(9527L);
         mast.setAppeTime(now);
@@ -577,7 +590,8 @@
         //璐ф灦缂栫爜
         mast.setBarcode(agvBasDevp.getBarcode());
         //璐ф灦绫诲瀷
-        mast.setWhsType(30);
+        mast.setWhsType(Integer.parseInt(agvBasDevp.getBarcode().substring(0,2)));
+
         mast.setAppeUser(9527L);
         mast.setAppeTime(now);
         mast.setModiUser(9527L);
@@ -634,7 +648,8 @@
         //璐ф灦缂栫爜
         mast.setBarcode(agvBasDevp.getBarcode());
         //璐ф灦绫诲瀷
-        mast.setWhsType(30);
+        mast.setWhsType(Integer.parseInt(agvBasDevp.getBarcode().substring(0,2)));
+
         mast.setAppeUser(9527L);
         mast.setAppeTime(now);
         mast.setModiUser(9527L);
@@ -666,7 +681,8 @@
         //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅
         AgvLocMast LocMast = agvCommonService.getLocNo(3, 1, false, false);
         if (LocMast.getLev1() != 2) {
-            throw new CoolException("鐩爣妤煎眰涓嶆槸鍚稿浜屾ゼ");
+            //throw new CoolException("鐩爣妤煎眰涓嶆槸鍚稿浜屾ゼ");
+            return FAIL;
         }
         List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().like("loc_no", "02F1").like("source_loc_no", "F1").eq("io_type", 12));
         if (agvWrkMasts.size() >= maxTansk) {
@@ -688,7 +704,8 @@
         //璐ф灦缂栫爜
         mast.setBarcode(agvLocMast.getBarcode());
         //璐ф灦绫诲瀷
-        mast.setWhsType(30);
+        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0,2)));
+
 
         mast.setAppeUser(9527L);
         mast.setAppeTime(now);
@@ -722,4 +739,87 @@
 
         return SUCCESS;
     }
+
+    /**
+     * 鍥涙湡锛岃法灞傜Щ搴擄紝1妤煎埌2妤硷紝2妤煎埌1妤�
+     *
+     * @param agvLocMast
+     * @param maxTansk
+     * @return
+     */
+    public ReturnT<String> autoTransfersV2(AgvLocMast agvLocMast, Integer maxTansk) {
+        Date now = new Date();
+        List<AgvLocDetl> locDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo()));
+        locDetls.forEach(agvLocDetl -> {
+            if (agvLocDetl.getProcessSts().equals(1)) {
+                throw new CoolException("褰撳墠搴撲綅鏈夊簱瀛樻湭鍔犲伐");
+            }
+        });
+        //鏌ヨ宸ヤ綔妗�
+        AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode());
+        if (!Cools.isEmpty(agvWrkMast)) {
+            throw new CoolException("褰撳墠" + agvLocMast.getBarcode() + "璐ф灦鐮佸凡鍦ㄥ伐浣滄。涓�");
+        }
+        AgvLocMast LocMast;
+        if (agvLocMast.getLev1() == 1) {
+            //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅
+            LocMast = agvCommonService.getLocByLocRule(3, 1, 2);
+        } else {
+            LocMast = agvCommonService.getLocByLocRule(3, 1, 1);
+        }
+        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 12));
+        if (agvWrkMasts.size() >= maxTansk) {
+            throw new CoolException("鑷姩绉诲簱浠诲姟宸插埌璁惧畾鏈�澶у�硷細" + maxTansk);
+        }
+        //鐢熸垚宸ヤ綔妗�
+        AgvWrkMast mast = new AgvWrkMast();
+        //宸ヤ綔鐘舵��
+        mast.setWrkSts(201L);
+        //鍏ュ嚭搴撶被鍨�
+        mast.setIoType(12);
+        mast.setIoTime(now);
+        //浼樺厛绾�
+        mast.setIoPri(300.0);
+        //婧愮珯鐐�
+        mast.setSourceLocNo(agvLocMast.getLocNo());
+        //鐩爣绔欑偣
+        mast.setLocNo(LocMast.getLocNo());
+        //璐ф灦缂栫爜
+        mast.setBarcode(agvLocMast.getBarcode());
+        //璐ф灦绫诲瀷
+        mast.setWhsType(Integer.parseInt(agvLocMast.getBarcode().substring(0,2)));
+
+
+        mast.setAppeUser(9527L);
+        mast.setAppeTime(now);
+        mast.setModiUser(9527L);
+        mast.setModiTime(now);
+        mast.setLogErrMemo("doAutoMoveV4");
+        if (!agvWrkMastService.insertByIncrease(mast)) {
+            throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�");
+        }
+
+        AgvWrkMast mast1 = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", LocMast.getLocNo()).eq("source_loc_no", agvLocMast.getLocNo()));
+        //鐢熸垚宸ヤ綔妗f槑缁�
+        List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo()));
+        agvLocDetls.forEach(agvLocDetl -> {
+            AgvWrkDetl wrkDetl = new AgvWrkDetl();
+            wrkDetl.setWrkNo(mast1.getWrkNo());
+            wrkDetl.sync(agvLocDetl);
+            wrkDetl.setSuppCode(agvLocDetl.getSuppCode());
+            wrkDetl.setIoTime(now);
+            wrkDetl.setAppeUser(9527L);
+            wrkDetl.setAppeTime(now);
+            wrkDetl.setModiUser(9527L);
+            wrkDetl.setModiTime(now);
+            if (!agvWrkDetlService.insert(wrkDetl)) {
+                throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触");
+            }
+        });
+        //鏇存柊鐩爣搴撲綅鐘舵��
+        updateAgvLocMast(agvLocMast, "R");
+        updateAgvLocMast(LocMast, "S");
+
+        return SUCCESS;
+    }
 }

--
Gitblit v1.9.1