From 1a2b07f01ba4616fd9e894dddf474b56d020158c Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期一, 07 四月 2025 15:18:51 +0800
Subject: [PATCH] 整理版本
---
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