From 59c8b08ce2025c0f4a947ec313d8229eaf464c3d Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期五, 21 八月 2020 11:06:44 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/DevpThread.java | 60 ++++++++++++++++++++++++++++++++++++++++++++++++++----------
1 files changed, 50 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/DevpThread.java b/src/main/java/com/zy/core/thread/DevpThread.java
index d0493ed..b75d3f5 100644
--- a/src/main/java/com/zy/core/thread/DevpThread.java
+++ b/src/main/java/com/zy/core/thread/DevpThread.java
@@ -54,9 +54,17 @@
case 1:
read();
break;
- // 鍐欐暟鎹�
+ // 鍐欐暟鎹� ID+鐩爣绔�
case 2:
write((StaProtocol)task.getData());
+ break;
+ // 鍐欐暟鎹� ID
+ case 3:
+ writeId((StaProtocol)task.getData());
+ break;
+ // 鍐欐暟鎹� 鐩爣绔�
+ case 4:
+ writeStaNo((StaProtocol)task.getData());
break;
default:
break;
@@ -129,7 +137,7 @@
}
/**
- * 鍐欏叆 =====> 鍗曠珯鐐瑰啓鍏�
+ * 鍐欏叆 ID+鐩爣绔� =====> 鍗曠珯鐐瑰啓鍏�
*/
private void write(StaProtocol staProtocol){
if (null == staProtocol) {
@@ -137,14 +145,46 @@
}
OperateResult write = siemensS7Net.Write("DB100." + (staProtocol.getSiteId() - 1) * 2, staProtocol.getWorkNo()); // 宸ヤ綔鍙�
OperateResult write1 = siemensS7Net.Write("DB100." + ((staProtocol.getSiteId() - 1) * 2 + 20), staProtocol.getStaNo()); // 鐩爣绔�
- boolean[] status = new boolean[8];
- status[0] = staProtocol.isAutoing();
- status[1] = staProtocol.isLoading();
- status[2] = staProtocol.isInEnable();
- status[3] = staProtocol.isOutEnable();
- status[4] = staProtocol.isEmptyMk();
- OperateResult write2 = siemensS7Net.Write("DB100." + ((staProtocol.getSiteId() - 1) + 40), status); // 鐘舵��
- if (!write.IsSuccess || !write1.IsSuccess || !write2.IsSuccess) {
+// boolean[] status = new boolean[8];
+// status[0] = staProtocol.isAutoing();
+// status[1] = staProtocol.isLoading();
+// status[2] = staProtocol.isInEnable();
+// status[3] = staProtocol.isOutEnable();
+// status[4] = staProtocol.isEmptyMk();
+// OperateResult write2 = siemensS7Net.Write("DB100." + ((staProtocol.getSiteId() - 1) + 40), status); // 鐘舵��
+ if (!write.IsSuccess || !write1.IsSuccess) {
+ OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆戝啓鍏ヨ緭閫佺嚎绔欑偣鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={1}锛岀珯鐐规暟鎹�={2}", slave.getId(), JSON.toJSON(staProtocol)));
+ log.error("鍐欏叆杈撻�佺嚎绔欑偣鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={}锛岀珯鐐规暟鎹�={}", slave.getId(), JSON.toJSON(staProtocol));
+ } else {
+ OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> 鍛戒护涓嬪彂锛� {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(staProtocol)));
+ }
+ }
+
+ /**
+ * 鍐欏叆 ID =====> 鍗曠珯鐐瑰啓鍏�
+ */
+ private void writeId(StaProtocol staProtocol){
+ if (null == staProtocol) {
+ return;
+ }
+ OperateResult write = siemensS7Net.Write("DB100." + (staProtocol.getSiteId() - 1) * 2, staProtocol.getWorkNo()); // 宸ヤ綔鍙�
+ if (!write.IsSuccess ) {
+ OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆戝啓鍏ヨ緭閫佺嚎绔欑偣鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={1}锛岀珯鐐规暟鎹�={2}", slave.getId(), JSON.toJSON(staProtocol)));
+ log.error("鍐欏叆杈撻�佺嚎绔欑偣鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={}锛岀珯鐐规暟鎹�={}", slave.getId(), JSON.toJSON(staProtocol));
+ } else {
+ OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(staProtocol)));
+ }
+ }
+
+ /**
+ * 鍐欏叆 鐩爣绔� =====> 鍗曠珯鐐瑰啓鍏�
+ */
+ private void writeStaNo(StaProtocol staProtocol){
+ if (null == staProtocol) {
+ return;
+ }
+ OperateResult write = siemensS7Net.Write("DB100." + ((staProtocol.getSiteId() - 1) * 2 + 20), staProtocol.getStaNo()); // 鐩爣绔�
+ if (!write.IsSuccess ) {
OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆戝啓鍏ヨ緭閫佺嚎绔欑偣鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={1}锛岀珯鐐规暟鎹�={2}", slave.getId(), JSON.toJSON(staProtocol)));
log.error("鍐欏叆杈撻�佺嚎绔欑偣鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={}锛岀珯鐐规暟鎹�={}", slave.getId(), JSON.toJSON(staProtocol));
} else {
--
Gitblit v1.9.1