From f1d3f8d339f3eb138833cca0f73557d72cc1ea83 Mon Sep 17 00:00:00 2001
From: tqs <56479841@qq.com>
Date: 星期二, 07 三月 2023 08:30:45 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/SteThread.java           |    8 +++++++-
 src/main/java/com/zy/core/model/protocol/SteProtocol.java |    1 +
 src/main/java/com/zy/asrs/controller/SteController.java   |   15 ++++++++++++++-
 3 files changed, 22 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/SteController.java b/src/main/java/com/zy/asrs/controller/SteController.java
index 409c972..ff4d8a6 100644
--- a/src/main/java/com/zy/asrs/controller/SteController.java
+++ b/src/main/java/com/zy/asrs/controller/SteController.java
@@ -79,7 +79,20 @@
             }
             vo.setTaskNo(steProtocol.getTaskNo().intValue());  //  浠诲姟鍙�
             vo.setStatusVal(steProtocol.getMode().intValue());  // 鍦ㄧ嚎鐘舵��
-            vo.setStatusType(steProtocol.mode == 0 ? "绂荤嚎" : "鍦ㄧ嚎");   //  妯″紡鐘舵��
+            String modeName = "绂荤嚎";
+            switch (steProtocol.mode){
+                case -1:
+                    modeName = "绂荤嚎";
+                    break;
+                case 0:
+                    modeName = "鑴辨満";
+                    break;
+                case 1:
+                    modeName = "鑱旀満";
+                    break;
+            }
+            vo.setStatusType(modeName);   //  妯″紡
+//            vo.setStatusType(steProtocol.mode == 0 ? "绂荤嚎" : "鍦ㄧ嚎");   //  妯″紡鐘舵��
             if (!Cools.isEmpty(steProtocol.getStatus())) {
                 vo.setStatus(steProtocol.getStatusType().desc);     //  鐘舵��
             }
diff --git a/src/main/java/com/zy/core/model/protocol/SteProtocol.java b/src/main/java/com/zy/core/model/protocol/SteProtocol.java
index 6e65744..cda2621 100644
--- a/src/main/java/com/zy/core/model/protocol/SteProtocol.java
+++ b/src/main/java/com/zy/core/model/protocol/SteProtocol.java
@@ -24,6 +24,7 @@
     private Short steNo;
 
     /**
+     * -1 = 绂荤嚎
      * 1 = 鑱旀満妯″紡
      * 0 = 鑴辨満妯″紡
      */
diff --git a/src/main/java/com/zy/core/thread/SteThread.java b/src/main/java/com/zy/core/thread/SteThread.java
index ad7edf6..42f7440 100644
--- a/src/main/java/com/zy/core/thread/SteThread.java
+++ b/src/main/java/com/zy/core/thread/SteThread.java
@@ -89,7 +89,7 @@
             steProtocol = new SteProtocol();
         }
         steProtocol.setSteNo(slave.getId().shortValue());
-        steProtocol.setMode((short) 0);
+        steProtocol.setMode((short) -1);
         steProtocol.setStatus(SteStatusType.OFF_LINE);
         steProtocol.setTaskNo((short) 0);
         steProtocol.setExecute(false);
@@ -340,6 +340,12 @@
         } else {
             OutputQueue.STE.offer(MessageFormat.format("銆恵0}銆戝啓鍏ョ┛姊溅plc鏁版嵁澶辫触 ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
             News.error("鍐欏叆绌挎杞lc鏁版嵁澶辫触 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+
+            //鍐欏叆澶辫触鍚庯紝閲嶆柊娣诲姞commanddao 浠诲姟闃熷垪涓�,骞剁珛鍗冲洖璇讳竴娆¤澶囩姸鎬�
+            MessageQueue.offer(SlaveType.Ste, slave.getId(), new Task(2, command));
+            readStatus();
+
+            initSte();
             return false;
         }
     }

--
Gitblit v1.9.1