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