From bc0a69ea4a4fb49dadc02bf548d8f3fd3f60d18a Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期三, 19 八月 2020 09:22:09 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/DevpThread.java |   26 ++++++++++++++++++++------
 1 files changed, 20 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/DevpThread.java b/src/main/java/com/zy/core/thread/DevpThread.java
index b339974..2c86663 100644
--- a/src/main/java/com/zy/core/thread/DevpThread.java
+++ b/src/main/java/com/zy/core/thread/DevpThread.java
@@ -31,12 +31,12 @@
 
     public DevpThread(Slave slave) {
         this.slave = slave;
-        connect();
     }
 
     @Override
     @SuppressWarnings("InfiniteLoopStatement")
     public void run() {
+        connect();
         while (true) {
             try {
                 int step = 1;
@@ -56,6 +56,9 @@
                     default:
                         break;
                 }
+
+                // 蹇冭烦
+                heartbeat();
                 Thread.sleep(400);
             } catch (Exception e) {
                 e.printStackTrace();
@@ -82,7 +85,7 @@
     }
 
     /**
-     * 璇诲彇鐘舵��
+     * 璇诲彇鐘舵�� ====> 鏁村潡plc
      */
     private void read(){
         OperateResultExOne<byte[]> result = siemensS7Net.Read("DB100.0", (short) 40);
@@ -111,7 +114,7 @@
     }
 
     /**
-     * 鍐欏叆
+     * 鍐欏叆 =====> 鍗曠珯鐐瑰啓鍏�
      */
     private void write(StaProtocol staProtocol){
         if (null == staProtocol) {
@@ -131,6 +134,16 @@
         }
     }
 
+    /**
+     * 蹇冭烦
+     */
+    private void heartbeat(){
+        OperateResult write = siemensS7Net.Write("DB100.50", (short) 1);
+        if (!write.IsSuccess) {
+            log.error("杈撻�佺嚎plc缂栧彿={} 蹇冭烦澶辫触", slave.getId());
+        }
+    }
+
     @Override
     public void close() {
         siemensS7Net.ConnectClose();
@@ -140,11 +153,12 @@
         Slave slave = new Slave();
         slave.setIp("192.168.2.125");
         DevpThread devpThread = new DevpThread(slave);
+        devpThread.connect();
         devpThread.read();
         // 鍐�
-        StaProtocol staProtocol = devpThread.getStation().get(2);
-        staProtocol.setWorkNo((short) 0);
-        staProtocol.setStaNo((short) 1001);
+        StaProtocol staProtocol = devpThread.getStation().get(1);
+        staProtocol.setWorkNo((short) 232);
+        staProtocol.setStaNo((short) 6);
         staProtocol.setAutoing(true);
         staProtocol.setEmptyMk(true);
         staProtocol.setInEnable(true);

--
Gitblit v1.9.1