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