From cdeb9e9559783cae56cbc6581b2e7aef893429b7 Mon Sep 17 00:00:00 2001
From: tqs <56479841@qq.com>
Date: 星期一, 27 三月 2023 17:02:51 +0800
Subject: [PATCH] Merge remote-tracking branch 'gitbit/xzjlwcs' into xzjlwcs

---
 src/main/java/com/zy/core/thread/ShuttleThread.java |   15 +++++++++++----
 1 files changed, 11 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/ShuttleThread.java b/src/main/java/com/zy/core/thread/ShuttleThread.java
index e5ecf37..03e30b5 100644
--- a/src/main/java/com/zy/core/thread/ShuttleThread.java
+++ b/src/main/java/com/zy/core/thread/ShuttleThread.java
@@ -288,7 +288,7 @@
     }
 
     //鍒嗛厤浠诲姟
-    private void assignWork(ShuttleAssignCommand assignCommand) {
+    private void assignWork(ShuttleAssignCommand assignCommand) throws Exception {
         //灏嗘map瀛樺叆redis涓�
         HashMap<String, Object> map = new HashMap<>();
 
@@ -299,6 +299,13 @@
             ArrayList<ArrayList<NavigateNode>> data = NavigateUtils.getSectionPath(calc);
             //璺緞鏁版嵁
             map.put("path", data);
+            //璺緞娆℃暟
+            map.put("pathSize", data.size());
+        }else {
+            if (assignCommand.getTaskMode() == ShuttleTaskModeType.PAK_IN.id.shortValue() || assignCommand.getTaskMode() == ShuttleTaskModeType.PAK_OUT.id.shortValue()) {
+                //灞炰簬鍏ュ簱鍑哄簱锛屽繀椤昏璁$畻璺緞锛屽垯鎶涘嚭寮傚父
+                throw new Exception("鏈兘鎵惧埌杩愯璺緞");
+            }
         }
 
         //宸ヤ綔鍙�
@@ -336,11 +343,11 @@
                 Object o1 = pathList.get(commandStep);
                 ArrayList path = JSON.parseObject(o1.toString(), ArrayList.class);
 
-                size = path.size();
+                size = Integer.parseInt(map.get("pathSize").toString());
                 //寮�濮嬭矾寰�
                 JSONObject startPath = JSON.parseObject(path.get(0).toString());
                 //鐩爣璺緞
-                JSONObject endPath = JSON.parseObject(path.get(size - 1).toString());
+                JSONObject endPath = JSON.parseObject(path.get(path.size() - 1).toString());
 
                 command.setCommandWord((short) 1);
                 command.setStartCodeNum(NavigatePositionConvert.xyToPosition(startPath.getIntValue("x"), startPath.getIntValue("y")));
@@ -393,7 +400,7 @@
             shuttleProtocol.setPakMk(false);
 
             //鍒ゆ柇鏁版嵁鏄惁鎵ц瀹屾垚
-            if (commandStep < size) {
+            if (commandStep < size - 1) {
                 //鏇存柊redis鏁版嵁
                 //姝ュ簭澧炲姞
                 commandStep++;

--
Gitblit v1.9.1