From 3b6b02d38ad77ab13694a22afa71c27a2e7d6363 Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期二, 24 六月 2025 20:31:51 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   21 ++++++++++++++-------
 1 files changed, 14 insertions(+), 7 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 9702348..458f54a 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -233,9 +233,14 @@
                             LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
                                     .eq("loc_no", dto.getLocNo()));
 
+                            short staNo = dto.getStaNo().shortValue();
+                            if (inSta.getStaNo() == 1002) {
+                                staNo = 2002;
+                            }
+
                             barcodeThread.setBarcode("");
                             staProtocol.setWorkNo(dto.getWorkNo().shortValue());
-                            staProtocol.setStaNo(dto.getStaNo().shortValue());
+                            staProtocol.setStaNo(staNo);
                             staProtocol.setPalletSize(locMast.getLocType2());
                             devpThread.setPakMk(staProtocol.getSiteId(), false);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -2199,16 +2204,16 @@
 
     // RGV  ===>> 鎵ц瀵筊GV鎿嶄綔
     public synchronized void rgvExecute(Integer mark) {
-        ArrayList<Integer> list = new ArrayList<Integer>(){{add(1090);add(1091);}};
+        ArrayList<Integer> list = new ArrayList<Integer>(){{add(2003);add(2002);}};
         for (Integer staNo : list) {
             Integer devpId = null;
             Integer rgvStaNo = null;
-            if (staNo == 1090) {
+            if (staNo == 2003) {
                 devpId = 1;
-                rgvStaNo = 1091;
+                rgvStaNo = 2002;
             }else {
                 devpId = 2;
-                rgvStaNo = 1090;
+                rgvStaNo = 2003;
             }
 
             SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devpId);
@@ -2224,7 +2229,7 @@
 
             if (staProtocol.isAutoing()
                     && staProtocol.isLoading()
-                    && staProtocol.isInEnable()
+//                    && staProtocol.isInEnable()
                     && staProtocol.getWorkNo() > 0
             ) {
                 WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>()
@@ -2269,7 +2274,7 @@
             }
 
             //  鐘舵�侊細绛夊緟纭 骞朵笖  浠诲姟瀹屾垚浣� = 1
-            if (rgvProtocol.statusType == RgvStatusType.WAITING && rgvProtocol.getTaskNo1() != 0) {
+            if (rgvProtocol.statusType1 == RgvStatusType.WAITING && rgvProtocol.getTaskNo1() != 0) {
                 News.warnNoLog(""+mark+" - 0"+" - 寮�濮嬫墽琛屽RGV宸ヤ綔妗g殑瀹屾垚鎿嶄綔");
                 // 鑾峰彇鍏ュ簱寰呯‘璁ゅ伐浣滄。
                 WrkMast wrkMast = wrkMastMapper.selectPakInStep3(rgvProtocol.getTaskNo1().intValue());
@@ -2327,6 +2332,8 @@
                     Date now = new Date();
                     wrkMast.setModiTime(now);
                     wrkMastMapper.updateById(wrkMast);
+
+                    rgvThread.setResetFlag1(true);
                 }
             }
         }

--
Gitblit v1.9.1