From 60201c8530488c402b8b44b215b8d48c60d6679a Mon Sep 17 00:00:00 2001
From: cpT <1@123>
Date: 星期四, 19 六月 2025 19:43:21 +0800
Subject: [PATCH] #改造

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   27 +++------------------------
 1 files changed, 3 insertions(+), 24 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 ff462b8..bf37cde 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -516,7 +516,7 @@
                     log.error("{}鍙稲GV灏氭湭鍦ㄦ暟鎹簱杩涜缁存姢锛�", rgvSlave.getId());
                     continue;
                 }
-                if (rgvProtocol.getStatusType() == RgvStatusType.WAITING || rgvProtocol.getStatusType() == RgvStatusType.WAITING101) {
+                if (rgvProtocol.getStatusType() == RgvStatusType.WAITING) {
                     log.info("{}鍙峰皬杞︾瓑寰厀cs纭锛岀姸鎬亄}锛屽弬鏁皗}", rgvProtocol.getRgvNo(), rgvProtocol.getStatusType(), rgvProtocol);
                 }
                 // 鍙湁褰揜GV绛夊緟WCS纭銆佽嚜鍔�
@@ -577,15 +577,6 @@
                         }
                     } catch (Exception e){}
                     wrkMastService.updateById(wrkMast);
-                } else if (rgvProtocol.getStatusType() == RgvStatusType.WAITING101
-                        && rgvProtocol.getModeType() == RgvModeType.AUTO
-                        && rgvProtocol.getTaskNo1() != 0
-                ){
-                    boolean rgvComplete = rgvComplete(rgvProtocol.getRgvNo());
-                    if (!rgvComplete) {
-                        log.error("灏忚溅澶嶄綅澶辫触锛屽皬杞﹀彿{}锛�", rgvProtocol.getRgvNo());
-                        break;
-                    }
                 }
             } catch (Exception e) {
                 log.error("灏忚溅澶嶄綅绾跨▼鎶ラ敊锛�" + e);
@@ -610,20 +601,9 @@
                 ) {
 
                     RgvCommand rgvCommand = new RgvCommand();
-                    rgvCommand.setRgvNo(rgvProtocol.getRgvNo());
-                    rgvCommand.setAckFinish1((short) 0);  // 宸ヤ綅1浠诲姟瀹屾垚纭浣�
-                    rgvCommand.setTaskNo1(rgvProtocol.getTaskNo1());
-                    rgvCommand.setTaskMode1(RgvTaskModeType.CANCEL); // 宸ヤ綅1浠诲姟妯″紡:  鍙栨秷
-                    rgvCommand.setSourceStaNo1((short)-1);   //宸ヤ綅1璧风偣
-                    rgvCommand.setDestinationStaNo1((short)-1);   //宸ヤ綅1鐩爣绔欑偣
-                    rgvCommand.setCommand((short) 1);   //宸ヤ綅1浠诲姟纭
-                    rgvCommand.setRgvSome((short) 1);
-                    if (!MessageQueue.offer(SlaveType.Rgv, rgvProtocol.getRgvNo(), new Task(4, rgvCommand))) {
+                    if (!MessageQueue.offer(SlaveType.Rgv, rgvProtocol.getRgvNo(), new Task(6, rgvCommand))) {
                         //
                         log.error("RGV鍙栨秷鍛戒护涓嬪彂澶辫触锛孯GV鍙�={}锛屼换鍔℃暟鎹�={}", rgvProtocol.getRgvNo(), JSON.toJSON(rgvCommand));
-//                        wrkMast.setLogErrTime(new Date());
-//                        wrkMast.setLogErrMemo("RGV鍙栨秷鍛戒护涓嬪彂澶辫触锛孯GV鍙�={"+rgvProtocol.getRgvNo()+"}===>璺宠繃");
-//                        wrkMastService.updateById(wrkMast);
                         continue;
                     }
                     log.info("RGV鍙栨秷鍛戒护涓嬪彂鎴愬姛锛孯GV鍙�={}锛屼换鍔℃暟鎹�={}", rgvProtocol.getRgvNo(), JSON.toJSON(rgvCommand));
@@ -636,10 +616,9 @@
 
                     Date now = new Date();
                     wrkMast.setWrkSts(1L);
-                    wrkMast.setRgvNo(null);
+                    wrkMast.setRgvNo(0);
                     wrkMast.setAppeTime(now);
                     wrkMast.setLogErrTime(now);
-                    wrkMast.setRgvNo(null);
 
                     wrkMast.setLogErrMemo("RGV鐢宠鍙栨秷浠诲姟锛孯GV鍙�={"+rgvProtocol.getRgvNo()+"}锛屽彇娑堟椂闂达細"+now);
 

--
Gitblit v1.9.1