From d2bb7362d92f0809572e15f8299ac608fe263a87 Mon Sep 17 00:00:00 2001
From: whycq <123456>
Date: 星期一, 21 四月 2025 16:23:47 +0800
Subject: [PATCH] 输送线命令下发失败重新推送队列
---
src/main/java/com/zy/core/thread/SiemensDevpThread.java | 4 ++++
1 files changed, 4 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index e637f82..2f6fcd1 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -338,6 +338,10 @@
if (!write.IsSuccess) {
log.warn("鐩樼偣鍐嶅叆搴撶粰杈撻�佺嚎涓嬪彂鍛戒护瀹屾垚锛歿}",JSON.toJSON(staProtocol));
+ boolean result = MessageQueue.offer(SlaveType.Devp, slave.getId(), new Task(2, staProtocol));
+ if (!result) {
+ log.error("鐩樼偣鍐嶅叆搴撳啓鍏ヨ緭閫佺嚎绔欑偣鏁版嵁澶辫触锛岄噸鏂版帹閫侀槦鍒楀け璐ワ紒锛侊紒 [plc缂栧彿锛歿}]", slave.getId());
+ }
staProtocol = station.get(staProtocol.getSiteId());
if (staProtocol.getWorkNo() == 0 && staProtocol.getStaNo() ==0) {
staProtocol.setPakMk(true);
--
Gitblit v1.9.1