From 58365ea8a02e8adee1b56948085998107f9a80b3 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 26 九月 2023 20:46:10 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/LiftThread.java |   32 +++++++++++++++++++++++++-------
 1 files changed, 25 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/LiftThread.java b/src/main/java/com/zy/core/thread/LiftThread.java
index 83f3c8d..ccc0864 100644
--- a/src/main/java/com/zy/core/thread/LiftThread.java
+++ b/src/main/java/com/zy/core/thread/LiftThread.java
@@ -125,14 +125,14 @@
         try {
             readStatus();
 
-            //鎻愬崌鏈哄浜庤繍琛岀姸鎬侊紝灏嗘爣璁扮疆涓簍rue
+            //鎻愬崌鏈哄浜庤繍琛岀姸鎬侊紝灏嗘爣璁扮疆涓篺alse
             if (liftProtocol.getBusy()) {
-                liftProtocol.setPakMk(true);
+                liftProtocol.setPakMk(false);
             }
 
             //鎻愬崌鏈哄浜庢湭杩愯銆佸氨缁�佹爣璁皌rue銆佹湁浠诲姟鍙�
             if (!liftProtocol.getBusy()
-                    && liftProtocol.getPakMk()
+                    && !liftProtocol.getPakMk()
                     && liftProtocol.getTaskNo() != 0) {
                 //杩樻湁鏈畬鎴愮殑鍛戒护
                 executeWork(liftProtocol.getTaskNo());
@@ -184,7 +184,13 @@
                 //宸插畬鎴愪换鍔″彿
                 liftProtocol.setCompleteTaskNo(siemensS7Net.getByteTransform().TransInt16(result1.Content, 6));
                 //褰撳墠妤煎眰
-                liftProtocol.setLev(siemensS7Net.getByteTransform().TransInt16(result1.Content, 8));
+                short lev = siemensS7Net.getByteTransform().TransInt16(result1.Content, 8);
+                if (lev >= 7 && lev <= 9) {
+                    lev -= 2;
+                } else if (lev >= 12 && lev <= 14) {
+                    lev -= 4;
+                }
+                liftProtocol.setLev(lev);
 
                 //灏嗘彁鍗囨満鐘舵�佷繚瀛樿嚦鏁版嵁搴�
                 BasLiftService liftService = SpringUtils.getBean(BasLiftService.class);
@@ -355,10 +361,11 @@
             return false;
         }
 
+        liftProtocol.setProtocolStatus(LiftProtocolStatusType.WORKING);
         News.info("鎻愬崌鏈哄懡浠や笅鍙戞垚鍔燂紝鎻愬崌鏈哄彿={}锛屼换鍔℃暟鎹�={}", command.getLiftNo(), JSON.toJSON(command));
 
-        //灏嗘爣璁扮疆涓篺alse(闃叉閲嶅彂)
-        liftProtocol.setPakMk(false);
+        //灏嗘爣璁扮疆涓簍rue(闃叉閲嶅彂)
+        liftProtocol.setPakMk(true);
 
         //淇濆瓨鏁版嵁鍒版暟鎹簱鍋氭祦姘�
         BasLiftOptService liftOptService = SpringUtils.getBean(BasLiftOptService.class);
@@ -372,7 +379,6 @@
                     null,
                     null,
                     JSON.toJSONString(command),
-                    JSON.toJSONString(commandArr),
                     JSON.toJSONString(liftProtocol)
             );
             liftOptService.insert(opt);
@@ -396,6 +402,18 @@
             News.info("鎻愬崌鏈轰换鍔℃墽琛屼笅鍙戝畬鎴愮瓑寰呮墽琛岀粨鏉燂紝鎻愬崌鏈哄彿={}锛屼换鍔℃暟鎹�={}", command.getLiftNo(), JSON.toJSON(command));
         }
 
+        if (redisCommand.getAssignCommand().getTaskMode() == NyLiftTaskModelType.RESET.id.shortValue()) {
+            //澶嶄綅鍛戒护
+            //宸ヤ綔鍙锋竻闆�
+            liftProtocol.setTaskNo((short) 0);
+            //浠ょ墝娓呴浂
+            liftProtocol.setToken(0);
+            //璁剧疆鎻愬崌鏈轰负绌洪棽鐘舵��
+            liftProtocol.setProtocolStatus(LiftProtocolStatusType.IDLE);
+            //浠诲姟鎸囦护娓呴浂
+            liftProtocol.setAssignCommand(null);
+        }
+
         return true;
     }
 

--
Gitblit v1.9.1