From 7f1ee24bca80d28851a95ee2019ea6faeb70d81c Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期一, 29 十二月 2025 17:34:39 +0800
Subject: [PATCH] 1.新增agv状态反馈

---
 src/main/java/com/zy/core/thread/SiemensDevpThread.java |   43 +++++++++++++++++++++++++++++++++++--------
 1 files changed, 35 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 880a0ad..1c6ae47 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -131,6 +131,9 @@
                     case 2:
                         write((StaProtocol)task.getData());
                         break;
+                    case 3:
+                        write1((StaProtocol)task.getData());
+                        break;
                     default:
                         break;
                 }
@@ -217,14 +220,15 @@
                 staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*8 + 4));   // 鐩爣绔�
 
                 boolean[] status = siemensS7Net.getByteTransform().TransBool(result.Content, i*8 + 6, 2);
-                staProtocol.setAutoing(status[0]);  // 鑷姩
-                staProtocol.setLoading(status[1]);  // 鏈夌墿
-                staProtocol.setInEnable(status[2]); // 鍙叆
-                staProtocol.setOutEnable(status[3]);// 鍙嚭
-                staProtocol.setEmptyMk(status[4]);  // 绌烘澘淇″彿
-                staProtocol.setFullPlt(status[5]);  // 婊℃墭鐩�
-                staProtocol.setHigh(status[6]);     // 楂樺簱浣�
-                staProtocol.setLow(status[7]);      // 浣庡簱浣�
+                staProtocol.setAutoing(status[0]);      // 鑷姩
+                staProtocol.setLoading(status[1]);      // 鏈夌墿
+                staProtocol.setInEnable(status[2]);     // 鍙叆
+                staProtocol.setOutEnable(status[3]);    // 鍙嚭
+                staProtocol.setEmptyMk(status[4]);      // 绌烘澘淇″彿
+                staProtocol.setFullPlt(status[5]);      // 婊℃墭鐩�
+                staProtocol.setHigh(status[6]);         // 楂樺簱浣�
+                staProtocol.setLow(status[7]);          // 浣庡簱浣�
+                staProtocol.setEmptyOutType(status[8]); //绌烘枡鏋�
 
                 if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
                     staProtocol.setPakMk(true);
@@ -339,6 +343,29 @@
         }
     }
 
+    /**
+     * 鎵爜鍣ㄨЕ鍙�
+     */
+    private void write1(StaProtocol staProtocol) throws InterruptedException {
+        if (null == staProtocol) {
+            return;
+        }
+        ArrayList<Integer> staNos = getStaNo();
+        int index = staNos.indexOf(staProtocol.getSiteId());
+        if(staProtocol.getSiteId() == 307){
+            index = 0;
+        }
+        OperateResult writeResult1 = siemensS7Net.Write("DB100.500" + index,  1);    // 鎵爜鍣ㄨЕ鍙�
+        if (!writeResult1.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)));
+            log.info("杈撻�佺嚎鍛戒护涓嬪彂 [id:{}] >>>>> 鍛戒护涓嬪彂锛� {}",  slave.getId(), JSON.toJSON(staProtocol));
+        }
+    }
+
     // 鏇存柊鍏ュ嚭搴撴ā寮�
     private void updateIoMode() throws InterruptedException {
         if (this.ioModeOf2F != IoModeType.NONE) {

--
Gitblit v1.9.1