From bab376712985ae408f4886dc004be53e6eb46ff3 Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期五, 14 三月 2025 14:56:48 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/impl/NyShuttleThread.java |   32 ++++++++++++++++++++++++++------
 1 files changed, 26 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/impl/NyShuttleThread.java b/src/main/java/com/zy/core/thread/impl/NyShuttleThread.java
index 52f5643..31abb43 100644
--- a/src/main/java/com/zy/core/thread/impl/NyShuttleThread.java
+++ b/src/main/java/com/zy/core/thread/impl/NyShuttleThread.java
@@ -120,6 +120,9 @@
 //                    //灏忚溅绌洪棽涓旀湁璺戝簱绋嬪簭
 //                    shuttleAction.moveLoc(slave.getId());
 
+                    //婕旂ず妯″紡
+                    shuttleAction.demo(slave.getId());
+
                     Thread.sleep(200);
                 } catch (Exception e) {
                     e.printStackTrace();
@@ -455,13 +458,17 @@
             }
 
             for (NyShuttleHttpCommand requestCommand : commandList) {
-                JSONObject result = requestCommand(requestCommand);
-                if (result == null) {
-                    return response;//璇锋眰澶辫触
+                while (true) {
+                    JSONObject result = requestCommand(requestCommand);
+                    if (result == null) {
+//                        return response;//璇锋眰澶辫触
+                        continue;//璇锋眰澶辫触灏濊瘯閲嶆柊璇锋眰
+                    }
+                    this.shuttleProtocol.setSendTime(System.currentTimeMillis());//鎸囦护涓嬪彂鏃堕棿
+                    response.setMessage(JSON.toJSONString(result));
+                    response.setResult(true);
+                    break;
                 }
-                this.shuttleProtocol.setSendTime(System.currentTimeMillis());//鎸囦护涓嬪彂鏃堕棿
-                response.setMessage(JSON.toJSONString(result));
-                response.setResult(true);
             }
             return response;
         } catch (Exception e) {
@@ -804,6 +811,19 @@
     }
 
     @Override
+    public boolean enableDemo(boolean enable) {
+        shuttleProtocol.setDemo(enable);
+        return true;
+    }
+
+    @Override
+    public boolean offerSystemMsg(String format, Object... arguments) {
+        String msg = News.replace(format, arguments);
+        shuttleProtocol.setSystemMsg(msg);
+        return true;
+    }
+
+    @Override
     public ShuttleCommand getMoveCommand(Integer taskNo, String startCodeNum, String distCodeNum, Integer allDistance, Integer runDirection, Integer runSpeed, List<NavigateNode> nodes) {
         NavigateMapData navigateMapData = SpringUtils.getBean(NavigateMapData.class);
         NyShuttleHttpCommand httpStandard = getHttpStandard(slave.getId(), taskNo);

--
Gitblit v1.9.1