From baf11d9f195732cfc0cc45a66b58ec2c1633cd4d Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期三, 19 七月 2023 09:03:11 +0800
Subject: [PATCH] command write
---
src/main/java/com/zy/core/thread/ShuttleThread.java | 56 +++++++++++++++++++++-----------------------------------
1 files changed, 21 insertions(+), 35 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/ShuttleThread.java b/src/main/java/com/zy/core/thread/ShuttleThread.java
index 2354ce3..5a9cec5 100644
--- a/src/main/java/com/zy/core/thread/ShuttleThread.java
+++ b/src/main/java/com/zy/core/thread/ShuttleThread.java
@@ -64,7 +64,7 @@
switch (step) {
// 璇绘暟鎹�
case 1:
- readStatus();
+ read();
break;
// 鍐欏叆鏁版嵁
case 2:
@@ -108,6 +108,23 @@
@Override
public void close() {
modbusTcpNet.ConnectClose();
+ }
+
+ private void read() {
+ try {
+ readStatus();
+ //鍥涘悜绌挎杞︾┖闂层�佹湁浠诲姟銆佹爣璁颁负true銆佸瓨鍦ㄤ换鍔℃寚浠わ紝闇�瑕佹墽琛屼换鍔＄殑涓嬩竴鏉℃寚浠�
+ if (shuttleProtocol.getBusyStatusType() == ShuttleStatusType.IDLE
+ && shuttleProtocol.getTaskNo() != 0
+ && shuttleProtocol.getPakMk()) {
+ //鎵ц涓嬩竴姝ユ寚浠�
+ executeWork(shuttleProtocol.getTaskNo());
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ OutputQueue.SHUTTLE.offer(MessageFormat.format("銆恵0}銆戝洓鍚戠┛姊溅plc鐘舵�佷俊鎭け璐� ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
+ initShuttle();
+ }
}
private void readStatus() {
@@ -172,40 +189,6 @@
if (shuttleProtocol.getBusyStatusType() == ShuttleStatusType.BUSY) {
shuttleProtocol.setPakMk(true);
}
-
-// if (shuttleProtocol.getErrorCode() != 0 && shuttleProtocol.getProtocolStatusType() == ShuttleProtocolStatusType.WORKING) {
-// //鍑虹幇閿欒
-// resetAndTryFix(shuttleProtocol.getTaskNo());
-// }
-//
-// if(shuttleProtocol.getProtocolStatusType() == ShuttleProtocolStatusType.FIXING
-// && shuttleProtocol.getTaskNo() != 0
-// && shuttleProtocol.getBusyStatusType() == ShuttleStatusType.IDLE){
-// //澶勪簬鏁呴殰淇鐘舵��
-// //鎵ц涓嬩竴姝ユ寚浠�
-// executeWork(shuttleProtocol.getTaskNo());
-// }
-
- //鍥涘悜绌挎杞︾┖闂层�佹湁浠诲姟銆佹爣璁颁负true銆佸瓨鍦ㄤ换鍔℃寚浠わ紝闇�瑕佹墽琛屼换鍔＄殑涓嬩竴鏉℃寚浠�
- if (shuttleProtocol.getBusyStatusType() == ShuttleStatusType.IDLE
- && shuttleProtocol.getTaskNo() != 0
- && shuttleProtocol.getPakMk()) {
- //鎵ц涓嬩竴姝ユ寚浠�
- executeWork(shuttleProtocol.getTaskNo());
- }
-
-// //妫�娴嬫槸鍚︽湁鎻愬崌鏈洪攣瀹氭爣璁帮紝鏈夊垯妫�娴嬫彁鍗囨満鏄惁鍒颁綅锛屾槸鍚﹁兘璧颁笅涓�姝ュ懡浠�
-// if (shuttleProtocol.getBusyStatusType() == ShuttleStatusType.IDLE
-// && shuttleProtocol.getTaskNo() != 0) {
-// Object o = redisUtil.get("shuttle_wrk_no_" + shuttleProtocol.getTaskNo());
-// if (o != null) {
-// ShuttleRedisCommand redisCommand = JSON.parseObject(o.toString(), ShuttleRedisCommand.class);
-// if (redisCommand.getLiftSecurityMk()) {
-// //鎵ц涓嬩竴姝ユ寚浠�
-// executeWork(shuttleProtocol.getTaskNo());
-// }
-// }
-// }
//灏嗗洓鍚戠┛姊溅鐘舵�佷繚瀛樿嚦鏁版嵁搴�
BasShuttleService shuttleService = SpringUtils.getBean(BasShuttleService.class);
@@ -304,6 +287,9 @@
}
for (int i = 0; i < 5; i++) {
+ if (command.getCommandWord().intValue() == 5 || command.getCommandWord().intValue() == 6) {
+ break;//鍏呯數寮�鍏冲拰绯荤粺澶嶄綅涓嶉渶瑕侀噸鍙戞満鍒�
+ }
readStatus();//閲嶆柊璇诲彇鐘舵��
if (shuttleProtocol.getBusyStatusType().equals(ShuttleStatusType.BUSY)) {
break;
--
Gitblit v1.9.1