From 9fb4e68cdb138ae3ac4026f875c84c04747873f3 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期三, 31 五月 2023 13:57:34 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 94dfa29..6213f93 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -80,6 +80,10 @@
                     case 2:
                         write((StaProtocol)task.getData());
                         break;
+                    // 鍐欐暟鎹� 103绔欑偣鍐欏叆PACK鐮�
+                    case 4:
+                        write103((String)task.getData());
+                        break;
                     //澶嶄綅娴嬭瘯淇″彿
                     case 3:
                         StaProtocol staProtocol = (StaProtocol)task.getData();
@@ -238,6 +242,24 @@
     }
 
     /**
+     * 鍐欏叆 pack鐮� =====> 鍗曠珯鐐瑰啓鍏�
+     */
+    private void write103(String packNo){
+        try{
+            OperateResult write = siemensS7Net.Write("DB100.", packNo);
+            if (!write.IsSuccess) {
+                OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆戝啓鍏ヨ緭閫佺嚎绔欑偣鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={1}锛岀珯鐐规暟鎹�={2}", slave.getId(), JSON.toJSON(packNo)));
+                log.error("鍐欏叆杈撻�佺嚎绔欑偣鏁版嵁澶辫触銆傝緭閫佺嚎plc缂栧彿={}锛岀珯鐐规暟鎹�={}", slave.getId(), JSON.toJSON(packNo));
+            } else {
+                OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆� 杈撻�佺嚎鍛戒护涓嬪彂 [id:{1}] >>>>> {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(packNo)));
+                log.info("杈撻�佺嚎鍛戒护涓嬪彂 [id:{}] >>>>> 鍛戒护涓嬪彂锛� {}",  slave.getId(), JSON.toJSON(packNo));
+            }
+        }catch (Exception e){
+            log.error("103绔欑偣鍐欏叆鏁版嵁澶辫触锛岃緭閫佺嚎绾跨▼write103");
+        }
+    }
+
+    /**
      * 鍐欏叆 ID+鐩爣绔� =====> 鍗曠珯鐐瑰啓鍏�
      */
     private void write(StaProtocol staProtocol) throws InterruptedException {

--
Gitblit v1.9.1