From cfaa77861170237f07da3113c7d505c70bf371be Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期三, 18 六月 2025 10:50:15 +0800
Subject: [PATCH] S7通讯部署版本代码提交

---
 hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcHollowRemoveTask.java |   35 +++++++++++++++++++++++++++++++++++
 1 files changed, 35 insertions(+), 0 deletions(-)

diff --git a/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcHollowRemoveTask.java b/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcHollowRemoveTask.java
index e84ccad..9149b28 100644
--- a/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcHollowRemoveTask.java
+++ b/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcHollowRemoveTask.java
@@ -41,6 +41,33 @@
     private Integer offset = 40001;
 
     /**
+     * 闄よ啘鏈鸿仈鏈虹姸鎬�
+     *
+     * @throws Exception
+     */
+    @Scheduled(fixedDelay = 3000)
+    public void filmRemoveStateOne() throws Exception {
+        ModbusTcp modbusTcp = CMJ1ModbusTcp;
+        try {
+            modbusTcp.readUInt16(42001 - offset);
+            log.info("闄よ啘鏈�1鑱旀満鐘舵�佹甯�");
+        } catch (Exception e) {
+            log.error("闄よ啘鏈�1鑱旀満鐘舵�佸紓甯�", e);
+        }
+    }
+
+    @Scheduled(fixedDelay = 3000)
+    public void filmRemoveStateTwo() throws Exception {
+        ModbusTcp modbusTcp = CMJ2ModbusTcp;
+        try {
+            modbusTcp.readUInt16(42001 - offset);
+            log.info("闄よ啘鏈�2鑱旀満鐘舵�佹甯�");
+        } catch (Exception e) {
+            log.error("闄よ啘鏈�2鑱旀満鐘舵�佸紓甯�", e);
+        }
+    }
+
+    /**
      * 鏀跺埌闄よ啘鏈鸿姹傚強鐜荤拑id
      *
      * @throws Exception
@@ -61,6 +88,10 @@
             modbusTcp = CMJ1ModbusTcp;
         } else {
             modbusTcp = CMJ2ModbusTcp;
+        }
+        if (!modbusTcp.checkConnected()) {
+            log.info("闄よ啘鏈簕}鏈繛鎺�", cell);
+            return;
         }
         Integer requestEntity = modbusTcp.readUInt16(42001 - offset);
 //        ReadWriteEntity requestEntity = miloService.readFromOpcUa(cell + "mesControl");
@@ -158,6 +189,10 @@
         } else {
             modbusTcp = CMJ2ModbusTcp;
         }
+        if (!modbusTcp.checkConnected()) {
+            log.info("闄よ啘鏈簕}鏈繛鎺�", cell);
+            return;
+        }
         int requestEntity = modbusTcp.readUInt16(42001 - offset);
         int request = requestEntity;
         int flagRequest = request & 9;

--
Gitblit v1.8.0