From ffee4b305f9ab02f828555100d44cba6b3c043fb Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期一, 10 十一月 2025 14:12:57 +0800
Subject: [PATCH] *
---
src/main/java/com/zy/core/thread/SiemensDevpThread.java | 30 ++++++++++++++++--------------
1 files changed, 16 insertions(+), 14 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 9075073..d908f64 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -86,20 +86,6 @@
@SuppressWarnings("InfiniteLoopStatement")
public void run() {
initSite();
- try{
- Thread.sleep(2000);
- } catch (Exception e){
-
- }
- connectDev = connect();
- while(!connectDev){
- try {
- connectDev = this.connect();
- Thread.sleep(100);
- } catch (Exception e){
-
- }
- }
// 鍚姩绾跨▼鑷姩閲嶈繛
new Thread(this::devConnect).start();
@@ -324,6 +310,10 @@
if (!staProtocol.isPakMkRun() && !staProtocol.isLoading()) {
staProtocol.setPakMkRun(true);
+ }
+
+ if (!staProtocol.isPakMkTask() && !staProtocol.isLoading()) {
+ staProtocol.setPakMkTask(true);
}
}
}
@@ -625,6 +615,18 @@
* 璁剧疆鍏ュ簱鏍囪
*/
@Override
+ public void setPakMkTask(Integer siteId, boolean pakMk) {
+ StaProtocol staProtocol = station.get(siteId);
+ if (null != staProtocol) {
+ staProtocol.setPakMkTask(pakMk);
+ }
+ }
+
+
+ /**
+ * 璁剧疆鍏ュ簱鏍囪
+ */
+ @Override
public void setPakMkRun(Integer siteId, boolean pakMk) {
StaProtocol staProtocol = station.get(siteId);
if (null != staProtocol) {
--
Gitblit v1.9.1