From c42614978ff12013a1eabebd0289b27169a5784f Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期二, 06 五月 2025 17:25:56 +0800
Subject: [PATCH] 1、实现万功能token(0000-0000-1234-9876-5); 2、web端单独实现命令结果等待器,并相应修改相关部分; 3、web端实现透传命令; 4、修改一些不当注释; 5、优化一些代码。

---
 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuStateFrProt/RtuInfoNotify.java |   42 ++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 42 insertions(+), 0 deletions(-)

diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuStateFrProt/RtuInfoNotify.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuStateFrProt/RtuInfoNotify.java
new file mode 100644
index 0000000..1762b7c
--- /dev/null
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuStateFrProt/RtuInfoNotify.java
@@ -0,0 +1,42 @@
+package com.dy.rtuMw.server.rtuStateFrProt;
+
+import com.dy.common.mw.protocol.Notify;
+import com.dy.common.mw.protocol.NotifyInfo;
+import com.dy.common.mw.protocol.rtuState.ValveStateInfo;
+import com.dy.rtuMw.server.forTcp.RtuStatusDealer;
+
+/**
+ * @Author: liurunyu
+ * @Date: 2024/11/3 13:30
+ * @Description 浠庡崗璁В鏋愭暟鎹腑寰楀埌鐨凴TU鐘舵�佸苟閫氱煡鍑哄幓
+ */
+public class RtuInfoNotify implements Notify {
+    /**
+     * RTU淇℃伅閫氱煡
+     * @param rtuAddr
+     * @param protocolName
+     * @param protocolVersion
+     * @param infos
+     */
+    @Override
+    public void notify(String rtuAddr,
+                       String protocolName,
+                       Short protocolVersion,
+                       NotifyInfo...infos
+                       ) {
+        if(infos != null && infos.length > 0){
+            for (NotifyInfo anInfo : infos) {
+                if(anInfo != null){
+                    if(anInfo instanceof ValveStateInfo){
+                        ValveStateInfo valveStateInfo = (ValveStateInfo) anInfo;
+                        if(valveStateInfo.openTrueCloseFalse.booleanValue()){
+                            RtuStatusDealer.valveOpen(rtuAddr);
+                        }else{
+                            RtuStatusDealer.valveClose(rtuAddr);
+                        }
+                    }
+                }
+            }
+        }
+    }
+}

--
Gitblit v1.8.0