From 96c02a0f71f1f42db5f235bc380103bb667ba30a Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期一, 09 十二月 2024 15:53:05 +0800
Subject: [PATCH] wcs调试修改

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   65 ++++++++++++++++++++++----------
 1 files changed, 45 insertions(+), 20 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 f5d8190..f2e9c42 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -270,7 +270,7 @@
                         param.setLocType1(locTypeDto.getLocType1());
                         if (inSta.getStaNo() == 102) {
                             param.setLocType2((short) 3);
-                        } else if (inSta.getStaNo() == 211) {
+                        } else if (inSta.getStaNo() == 211 || inSta.getStaNo() == 104) {
                             param.setLocType1((short) 5);
                             param.setLocType2((short) 4);
                         } else if (inSta.getStaNo() == 201) {
@@ -310,16 +310,17 @@
                             staProtocol.setWorkNo((short) 9999);
                             staProtocol.setStaNo(inSta.getBackSta().shortValue());
                             devpThread.setPakMk(staProtocol.getSiteId(), false);
-                            boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
-                            if (!result) {
-                                throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
-                            }
-
                             // led 寮傚父鏄剧ず
                             if (ledThread != null) {
                                 String errorMsg = jsonObject.getString("msg");
                                 MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg));
                             }
+                            boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                            if (!result) {
+                                throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
+                            }
+
+
                         }
 
                     } catch (Exception e) {
@@ -417,10 +418,20 @@
                     staProtocol = staProtocol.clone();
                 }
 
-                if (barcodeThread == null) {
+                String barcode = "";
+                if (barcodeThread == null && staProtocol.getSiteId() != 104) {
                     continue;
+                } else if (staProtocol.getSiteId() == 104) {
+                    if (staProtocol.getWorkNo() == 9996) {
+                        // 鑾峰彇鍒版嫞鏂欎换鍔$殑鎵樼洏鐮�
+                        WrkMast wrkMast = wrkMastMapper.selectOne(new QueryWrapper<WrkMast>().eq("wrk_sts", 14).eq("io_type", 103).eq("source_sta_no", 104));
+                        if (wrkMast != null) {
+                            barcode = wrkMast.getBarcode();
+                        }
+                    }
+                } else {
+                    barcode = barcodeThread.getBarcode();
                 }
-                String barcode = barcodeThread.getBarcode();
                 // 灏哄妫�娴嬪紓甯�
                 boolean back = false;
                 String errMsg = "";
@@ -530,7 +541,7 @@
                     StaDesc staDesc = staDescService.getOne(wrapper);
                     if (Cools.isEmpty(staDesc)) {
                         News.error("" + mark + " - 2" + " - 鍏ュ簱璺緞涓嶅瓨鍦紒type_no={},stn_no={},crn_no={}", wrkMast.getIoType(), pickSta.getStaNo(), wrkMast.getCrnNo());
-                        staProtocol.setWorkNo((short) 9989);
+                        staProtocol.setWorkNo((short) 9999);
                         staProtocol.setStaNo((short) (pickSta.getStaNo().shortValue() - (short) 1));
                         devpThread.setPakMk(staProtocol.getSiteId(), false);
                         MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -879,7 +890,7 @@
                         wrkMast.setIoPri(14D);
                         wrkMastMapper.updateById(wrkMast);
                         // 鐢熸垚宸ヤ綔妗�,灏嗘祬搴撲綅绉昏浆鍒版柊鐨勫簱浣嶄腑
-                        moveLocForDeepLoc(slave, shallowLoc, mark);
+                        moveLocForDeepLoc(slave, shallowLoc, mark,wrkMast.getTenant());
                         // 鐢熸垚宸ヤ綔妗c�佹敼鍙樻祬搴撲綅鐨勬簮搴�/鐩爣搴� 搴撲綅鐘舵�併�佷笅鍙戝爢鍨涙満鍛戒护锛堢珛椹墽琛�)
 //                        moveLocForDeepLocPakin(slave, shallowLoc, wrkMast);
                     }
@@ -909,6 +920,9 @@
                 crnCommand.setDestinationPosXTwo(locMast.getRow1().shortValue());     // 鐩爣搴撲綅鎺�
                 crnCommand.setDestinationPosYTwo(locMast.getBay1().shortValue());     // 鐩爣搴撲綅鍒�
                 crnCommand.setDestinationPosZTwo(locMast.getLev1().shortValue());     // 鐩爣搴撲綅灞�
+                if (crnStn.getStaNo() == 202) {
+                    crnCommand.setSourcePosYTwo((short) 6);     // 婧愬簱浣嶅垪
+                }
             } else {
                 if (workMode == 1) {
                     crnCommand.setTaskMode(CrnTaskModeType.PAKIN);
@@ -921,6 +935,9 @@
                 crnCommand.setDestinationPosX(locMast.getRow1().shortValue());     // 鐩爣搴撲綅鎺�
                 crnCommand.setDestinationPosY(locMast.getBay1().shortValue());     // 鐩爣搴撲綅鍒�
                 crnCommand.setDestinationPosZ(locMast.getLev1().shortValue());     // 鐩爣搴撲綅灞�
+                if (workMode == 1 && crnStn.getStaNo() == 202) {
+                    crnCommand.setSourcePosY((short) 6);     // 婧愬簱浣嶅垪
+                }
             }
 //            crnCommand.setAckFinish((short) 0);  // 浠诲姟瀹屾垚纭浣�
 
@@ -1048,7 +1065,7 @@
                                 wrkMast.setUpdMk("Y");
                                 wrkMastMapper.updateById(wrkMast);
                                 // 鐢熸垚宸ヤ綔妗�,灏嗘祬搴撲綅绉昏浆鍒版柊鐨勫簱浣嶄腑
-                                moveLocForDeepLoc(slave, shallowLoc, mark);
+                                moveLocForDeepLoc(slave, shallowLoc, mark,wrkMast.getTenant());
                             }
                             News.error("{}浠诲姟鍑哄簱澶辫触锛屾祬搴撲綅鍫靛锛佹祬搴撲綅鍙�:{}", wrkMast.getWrkNo(), shallowLocNo);
                             continue;
@@ -1087,6 +1104,9 @@
                         crnCommand.setDestinationPosXTwo(crnStn.getRow().shortValue());     // 鐩爣搴撲綅鎺�
                         crnCommand.setDestinationPosYTwo(crnStn.getBay().shortValue());     // 鐩爣搴撲綅鍒�
                         crnCommand.setDestinationPosZTwo(crnStn.getLev().shortValue());     // 鐩爣搴撲綅灞�
+                        if (crnStn.getStaNo() == 202) {
+                            crnCommand.setDestinationPosYTwo((short) 6);     // 婧愬簱浣嶅垪
+                        }
                     } else {
                         if (workMode == 1) {
                             crnCommand.setTaskMode(CrnTaskModeType.PAKIN);
@@ -1099,6 +1119,9 @@
                         crnCommand.setDestinationPosX(crnStn.getRow().shortValue());     // 鐩爣搴撲綅鎺�
                         crnCommand.setDestinationPosY(crnStn.getBay().shortValue());     // 鐩爣搴撲綅鍒�
                         crnCommand.setDestinationPosZ(crnStn.getLev().shortValue());     // 鐩爣搴撲綅灞�
+                        if (workMode == 1 && crnStn.getStaNo() == 202) {
+                            crnCommand.setDestinationPosY((short) 6);     // 婧愬簱浣嶅垪
+                        }
                     }
 
                     if (!MessageQueue.offer(SlaveType.Crn, wrkMast.getCrnNo(), new Task(2, crnCommand))) {
@@ -1539,10 +1562,10 @@
                     staProtocol = staProtocol.clone();
                 }
 
-                if (barcodeThread == null) {
-                    continue;
-                }
-                String barcode = barcodeThread.getBarcode();
+//                if (barcodeThread == null) {
+//                    continue;
+//                }
+//                String barcode = barcodeThread.getBarcode();
                 // 灏哄妫�娴嬪紓甯�
                 boolean back = false;
                 String errMsg = "";
@@ -1583,9 +1606,9 @@
                     if (!staProtocol.isLoading()) {
                         continue;
                     }
-                    if (!staProtocol.isPakMk()) {
-                        continue;
-                    }
+//                    if (!staProtocol.isPakMk()) {
+//                        continue;
+//                    }
                     staProtocol.setWorkNo((short) 9999);
                     News.info("{}鍏ュ簱鍥為��锛歿}锛屼换鍔″彿锛歿}", emptyInSta.getStaNo(), errMsg, (short) 9999);
                     staProtocol.setStaNo(emptyInSta.getBackSta().shortValue());
@@ -1617,7 +1640,7 @@
                         param.setLocType1(locTypeDto.getLocType1());
                         if (emptyInSta.getStaNo() == 102) {
                             param.setLocType2((short) 3);
-                        } else if (emptyInSta.getStaNo() == 211) {
+                        } else if (emptyInSta.getStaNo() == 211 || emptyInSta.getStaNo() == 104) {
                             param.setLocType1((short) 5);
                             param.setLocType2((short) 4);
                         } else if (emptyInSta.getStaNo() == 201) {
@@ -1930,7 +1953,7 @@
      * 鍥犲弻娣卞簱浣嶉樆濉烇紝瀵规祬搴撲綅杩涜绉昏浆锛堢珛鍗虫墽琛岀増)
      * tip锛氬悓姝�
      */
-    private synchronized void moveLocForDeepLoc(CrnSlave crn, LocMast shallowLoc, Integer mark) {
+    private synchronized void moveLocForDeepLoc(CrnSlave crn, LocMast shallowLoc, Integer mark,Long tenant) {
 
         try {
             News.warnNoLog("" + mark + "moveLocForDeepLoc" + " - 0" + " - 寮�濮嬫墽琛�:鍥犲弻娣卞簱浣嶉樆濉烇紝瀵规祬搴撲綅杩涜绉昏浆锛堢珛鍗虫墽琛岀増)");
@@ -2022,6 +2045,7 @@
             wrkMast.setLinkMis("N");
             wrkMast.setAppeTime(new Date());
             wrkMast.setModiTime(new Date());
+            wrkMast.setTenant(tenant);
             int res = wrkMastMapper.insert(wrkMast);
             if (res == 0) {
                 News.errorNoLog("" + mark + "moveLocForDeepLoc" + " - 2" + " - 淇濆瓨宸ヤ綔妗eけ璐�");
@@ -2038,6 +2062,7 @@
                     VersionUtils.setWrkDetl(wrkDetl, locDetl); // 鐗堟湰鎺у埗
                     wrkDetl.setAppeTime(new Date());
                     wrkDetl.setModiTime(new Date());
+                    wrkDetl.setTenant(tenant);
                     if (!wrkDetlService.save(wrkDetl)) {
                         News.errorNoLog("" + mark + "moveLocForDeepLoc" + " - 3" + " - 淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
                         throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");

--
Gitblit v1.9.1