From 1cf7590b223651d17120db0888808ce7aa6a9dbe Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期四, 23 十月 2025 09:00:08 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/MelsecCrnThread.java | 27 +++++++++++++++++++++++++--
1 files changed, 25 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/MelsecCrnThread.java b/src/main/java/com/zy/core/thread/MelsecCrnThread.java
index fb24a86..649fe9b 100644
--- a/src/main/java/com/zy/core/thread/MelsecCrnThread.java
+++ b/src/main/java/com/zy/core/thread/MelsecCrnThread.java
@@ -48,6 +48,10 @@
*/
private boolean backHpFlag = false;
+ public Long sign = System.currentTimeMillis();
+
+ public boolean isRunning = true;
+
public MelsecCrnThread(CrnSlave slave) {
this.slave = slave;
}
@@ -55,13 +59,15 @@
@Override
@SuppressWarnings("InfiniteLoopStatement")
public void run() {
+ System.out.println("绾跨▼鍚姩");
+ System.out.println("crnProtocol:"+crnProtocol);
this.connect();
// try {
// Thread.sleep(2000);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
- while (true) {
+ while (isRunning) {
try {
int step = 1;
Task task = MessageQueue.poll(SlaveType.Crn, slave.getId());
@@ -104,7 +110,8 @@
} catch (Exception e) {
e.printStackTrace();
}
-
+// System.out.println("绗�"+slave.getId()+"涓爢鍨涙満绾跨▼杩愯涓�杞細"+(System.currentTimeMillis()-sign));
+ sign = System.currentTimeMillis();
}
}
@@ -168,6 +175,7 @@
crnProtocol = new CrnProtocol();
crnProtocol.setCrnNo(slave.getId());
}
+ crnProtocol.setCrnNo(slave.getId());
crnProtocol.setMode(melsecMcNet.getByteTransform().TransInt16(result.Content, 0));
crnProtocol.setTaskNo(melsecMcNet.getByteTransform().TransInt16(result.Content, 2));
crnProtocol.setStatus(melsecMcNet.getByteTransform().TransInt16(result.Content, 4));
@@ -226,6 +234,8 @@
OutputQueue.CRN.offer(MessageFormat.format("銆恵0}銆戣鍙栧爢鍨涙満plc鐘舵�佷俊鎭け璐� ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
News.error("MelsecCrn"+" - 5"+" - 璇诲彇鍫嗗灈鏈簆lc鐘舵�佷俊鎭け璐� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
initCrn();
+ } finally {
+ sign = System.currentTimeMillis();
}
}
@@ -473,4 +483,17 @@
}
+ // 鎻愪緵涓�涓柟娉曟潵鍋滄绾跨▼
+ public void requestStop() {
+ isRunning = false;
+ }
+
+ // 鎻愪緵涓�涓柟娉曟潵閲嶅惎绾跨▼
+ public Thread restartThread() {
+ isRunning = true;
+ Thread newThread = new Thread(this);
+ newThread.start();
+ return newThread;
+ }
+
}
--
Gitblit v1.9.1