From 8041ff1c93a86f2f1b9e4ed2b61fa65a01562665 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期五, 21 七月 2023 14:47:31 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   13 +++++++++----
 1 files changed, 9 insertions(+), 4 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 46291f8..ca57d80 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -534,6 +534,7 @@
             RgvThread rgvThread = (RgvThread) SlaveConnection.get(SlaveType.Rgv, rgv.getId());
             RgvProtocol rgvProtocol = rgvThread.getRgvProtocol();
             if (rgvProtocol == null) {
+
                 continue;
             }
             BasRgv basRgv = basRgvService.selectById(rgv.getId());
@@ -647,7 +648,7 @@
                             continue;
                         }
                         //琛岃蛋璺緞绌洪棽锛岄攣瀹氳矾寰�
-                        RgvUtils.lockPath(startPath, endPath, rgvProtocol.getRgvNo(), true);
+                        RgvUtils.lockPath(startPath, endPath, rgvProtocol.getRgvNo(), wrkMast.getWrkNo(), true);
 
                         //  鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
                         RgvCommand rgvCommand = new RgvCommand();
@@ -693,7 +694,7 @@
                             continue;
                         }
                         //琛岃蛋璺緞绌洪棽锛岄攣瀹氳矾寰�
-                        RgvUtils.lockPath(startPath, endPath, rgvProtocol.getRgvNo(), true);
+                        RgvUtils.lockPath(startPath, endPath, rgvProtocol.getRgvNo(), wrkMast.getWrkNo(), true);
 
                         //  鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
                         RgvCommand rgvCommand = new RgvCommand();
@@ -736,7 +737,7 @@
                             continue;
                         }
                         //琛岃蛋璺緞绌洪棽锛岄攣瀹氳矾寰�
-                        RgvUtils.lockPath(startPath, endPath, rgvProtocol.getRgvNo(), true);
+                        RgvUtils.lockPath(startPath, endPath, rgvProtocol.getRgvNo(), wrkMast.getWrkNo(), true);
 
                         //  鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
                         RgvCommand rgvCommand = new RgvCommand();
@@ -782,7 +783,7 @@
                             continue;
                         }
                         //琛岃蛋璺緞绌洪棽锛岄攣瀹氳矾寰�
-                        RgvUtils.lockPath(startPath, endPath, rgvProtocol.getRgvNo(), true);
+                        RgvUtils.lockPath(startPath, endPath, rgvProtocol.getRgvNo(), wrkMast.getWrkNo(), true);
 
                         //  鍛戒护涓嬪彂鍖� --------------------------------------------------------------------------
                         RgvCommand rgvCommand = new RgvCommand();
@@ -811,6 +812,10 @@
         }
     }
 
+    private boolean rgvIoExecuteWrk2To3() {
+        return false;
+    }
+
     /**
      * 鍥炲師鐐癸紝鍫嗗灈鏈烘病鏈夋墽琛屼腑浠诲姟锛岃澶囧瓨鍦ㄥ叆搴撲换鍔℃椂鍙洖鍘熺偣
      */

--
Gitblit v1.9.1