From abb914f4761cedcfc89eb3dcdd2cf377490d09bc Mon Sep 17 00:00:00 2001
From: 1 <1@123>
Date: 星期三, 14 五月 2025 14:41:40 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/RgvThread.java |   18 +++++++++++++++++-
 1 files changed, 17 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/RgvThread.java b/src/main/java/com/zy/core/thread/RgvThread.java
index d0e09bd..5379142 100644
--- a/src/main/java/com/zy/core/thread/RgvThread.java
+++ b/src/main/java/com/zy/core/thread/RgvThread.java
@@ -14,6 +14,7 @@
 import com.zy.asrs.service.BasRgvService;
 import com.zy.asrs.utils.RouteUtils;
 import com.zy.asrs.utils.TrackRangeUtils;
+import com.zy.core.DevpThread;
 import com.zy.core.ThreadHandler;
 import com.zy.core.cache.*;
 import com.zy.core.enums.RgvModeType;
@@ -25,6 +26,7 @@
 import com.zy.core.model.command.RgvCommand;
 import com.zy.core.model.protocol.RgvProtocol;
 import com.zy.core.model.protocol.RgvTaskProtocol;
+import com.zy.core.model.protocol.StaProtocol;
 import com.zy.core.model.protocol.TaskProtocol;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
@@ -293,7 +295,21 @@
                         }
                         if (taskProtocol.getTargetPosition()<=rgvProtocol.getRgvPos()+50
                                 && taskProtocol.getTargetPosition()>=rgvProtocol.getRgvPos()-50){
-//                            Thread.sleep(100);
+                            Thread.sleep(100);
+                            if (taskProtocol.getTaskStatus()==3){
+                                DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, taskProtocol.getTargetPositionStaNoPlcId());
+                                StaProtocol staProtocol = devpThread.getStation().get(taskProtocol.getTargetPositionStaNo());
+                                if (staProtocol == null ) {
+                                    continue;
+                                }
+                                // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢
+                                if (!staProtocol.isAutoing() || staProtocol.isLoading()
+                                        || staProtocol.getWorkNo() != 0
+                                ){
+                                    System.out.println("<鏀捐揣鐩爣绔�>" + taskProtocol.getTargetPositionStaNo() + "<闈炶嚜鍔ㄦ垨鑰呮湁鐗╂垨鑰呭瓨鍦ㄥ伐浣滃彿锛侊紒锛�>");
+                                    continue;
+                                }
+                            }
                             TaskProtocol issued = new TaskProtocol(taskProtocol);
                             write(issued);
                             taskProtocolCache.removeTaskProtocol(taskProtocol.getTaskNoDirection());

--
Gitblit v1.9.1