From ee1fcbd729e22329594a609919ae26ce8343f421 Mon Sep 17 00:00:00 2001
From: zc <zc@123>
Date: 星期六, 17 五月 2025 20:04:50 +0800
Subject: [PATCH] 123
---
src/main/java/com/zy/core/thread/impl/FyDevpThread.java | 58 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 58 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/impl/FyDevpThread.java b/src/main/java/com/zy/core/thread/impl/FyDevpThread.java
index 64edd4f..c13f926 100644
--- a/src/main/java/com/zy/core/thread/impl/FyDevpThread.java
+++ b/src/main/java/com/zy/core/thread/impl/FyDevpThread.java
@@ -99,6 +99,10 @@
write((StaProtocol) task.getData());
read();
break;
+ // 鎶ヨ
+ case 3:
+ writeError((Integer) task.getData());
+ break;
default:
break;
}
@@ -252,6 +256,60 @@
}
/**
+ * 鎶ヨ
+ */
+ private void writeError(Integer staNo) throws InterruptedException {
+ if (null == staNo) {
+ return;
+ }
+
+ ArrayList<Integer> lift1 = new ArrayList<Integer>() {{
+ add(1011);
+ add(1012);
+ }};
+
+ ArrayList<Integer> lift2 = new ArrayList<Integer>() {{
+ add(1021);
+ add(1022);
+ add(1023);
+ }};
+
+ ArrayList<Integer> devp1 = new ArrayList<Integer>() {{
+ add(1013);
+ add(1014);
+ add(1015);
+ }};
+
+ ArrayList<Integer> devp2 = new ArrayList<Integer>() {{
+ add(1024);
+ add(1025);
+ add(1026);
+ }};
+
+ String dbAddress = "DB82.48";
+ if (lift1.contains(staNo)) {
+ dbAddress = "DB82.48";
+ } else if (lift2.contains(staNo)) {
+ dbAddress = "DB82.178";
+ } else if (devp1.contains(staNo)) {
+ dbAddress = "DB82.100";
+ } else if (devp2.contains(staNo)) {
+ dbAddress = "DB82.256";
+ }else {
+ return;
+ }
+
+ OperateResult write1 = siemensS7Net.Write(dbAddress, (short) 1);
+ if (!write1.IsSuccess) {
+ OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆戝啓鍏ヨ緭閫佺嚎绔欑偣鎶ヨ鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={1}锛岀珯鐐规暟鎹�={2}", slave.getId(), JSON.toJSON(true)));
+ log.error("鍐欏叆杈撻�佺嚎绔欑偣鎶ヨ鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={}锛岀珯鐐规暟鎹�={}", slave.getId(), JSON.toJSON(true));
+ return;
+ }
+ OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆戝啓鍏ヨ緭閫佺嚎绔欑偣鎶ヨ鏁版嵁鎴愬姛銆傝緭閫佺嚎plc缂栧彿={1}锛岀珯鐐规暟鎹�={2}", slave.getId(), JSON.toJSON(true)));
+ log.info("鍐欏叆杈撻�佺嚎绔欑偣鎶ヨ鏁版嵁鎴愬姛銆傝緭閫佺嚎plc缂栧彿={}锛岀珯鐐规暟鎹�={}", slave.getId(), JSON.toJSON(true));
+ }
+
+ /**
* 蹇冭烦
*/
private void heartbeat() {
--
Gitblit v1.9.1