From 52cd0fe6f2224b0bd17b19ddaf475406a92b9ed4 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期五, 09 五月 2025 13:42:00 +0800
Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV
---
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V2/TkDealHearBeatV2.java | 77 ++++++++++++++++++++++++++++++++++++++
1 files changed, 77 insertions(+), 0 deletions(-)
diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V2/TkDealHearBeatV2.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V2/TkDealHearBeatV2.java
new file mode 100644
index 0000000..f55f3b6
--- /dev/null
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V2/TkDealHearBeatV2.java
@@ -0,0 +1,77 @@
+package com.dy.rtuMw.server.rtuData.p206V2;
+
+import com.dy.common.mw.protocol.Data;
+import com.dy.common.mw.protocol.p206V2.DataV2;
+import com.dy.common.mw.protocol.p206V2.upVos.DataCd02Vo;
+import com.dy.rtuMw.server.rtuData.TaskSurpport;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+import java.text.ParseException;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @Author: liurunyu
+ * @Date: 2024/11/1 9:16
+ * @Description
+ */
+public class TkDealHearBeatV2 extends TaskSurpport {
+
+ private static final Map<String, String> onceUpDataRtus = new HashMap<>();
+
+ private static final Logger log = LogManager.getLogger(TkPreGenObjsV2.class.getName()) ;
+
+ //绫籌D锛屼竴瀹氫笌Tree.xml閰嶇疆鏂囦欢涓厤缃竴鑷�
+ public static final String taskId = "TkDealHearBeatV2" ;
+
+ /**
+ * 鎵ц鑺傜偣浠诲姟
+ * @param data 闇�瑕佸鐞嗙殑鏁版嵁
+ */
+ @Override
+ public void execute(Object data) throws ParseException {
+ Data d = (Data)data ;
+ String rtuAddr = d.getRtuAddr() ;//TkRtuData閲屽垽鏂簡rtuAddr涓虹┖
+ DataCd02Vo cd02Vo = null ;
+ if(d.subData != null && d.subData instanceof DataV2){
+ DataV2 dataV2 = (DataV2)d.subData ;
+ if(dataV2.subData != null && dataV2.subData instanceof DataCd02Vo){
+ cd02Vo = (DataCd02Vo)dataV2.subData ;
+ }
+ }
+ boolean toNext = true ;
+ if(!onceUpDataRtus.containsKey(rtuAddr)){
+ //鍒濇涓婅鏁版嵁锛屼笉璁烘槸鍚︽槸蹇冭烦锛岄兘瑕佽繘琛屼换鍔℃爲澶勭悊
+ //toNext = true ;
+ if(cd02Vo != null){
+ //鏄績璺虫暟鎹�
+ onceUpDataRtus.put(rtuAddr, (cd02Vo.alarmVo == null?"":cd02Vo.alarmVo.to1010()) +
+ (cd02Vo.stateVo == null?"":cd02Vo.stateVo.to1010())) ;
+ }else{
+ //涓嶆槸蹇冭烦鏁版嵁
+ onceUpDataRtus.put(rtuAddr, "") ;
+ }
+ }else{
+ if(cd02Vo != null){
+ //鏄績璺虫暟鎹紝
+ String alarmStateOld = onceUpDataRtus.get(rtuAddr) ;
+ String alarmStateNew = (cd02Vo.alarmVo == null?"":cd02Vo.alarmVo.to1010()) +
+ (cd02Vo.stateVo == null?"":cd02Vo.stateVo.to1010()) ;
+ if(alarmStateOld.equals(alarmStateNew)){
+ toNext = false ;//鏄績璺虫暟鎹紝骞朵笖鎶ヨ涓庣姸鎬佹湭鏀瑰彉锛屼笉杩涜浠诲姟鏍戝鐞嗭紝涓嶇紦瀛樻湭鍙樺寲鐨勬姤璀︿笌鐘舵��
+ }else{
+ //鏄績璺虫暟鎹紝骞朵笖鎶ヨ涓庣姸鎬佷篃鏀瑰彉浜嗭紝杩涜浠诲姟鏍戝鐞�
+ //toNext = true ;
+ onceUpDataRtus.put(rtuAddr, alarmStateNew) ;//缂撳瓨鏂版姤璀︿笌鐘舵��
+ }
+ }else{
+ //涓嶆槸蹇冭烦鏁版嵁锛岃杩涜浠诲姟鏍戝鐞�
+ //toNext = true ;
+ }
+ }
+ if(toNext){
+ this.toNextTasks(data);
+ }
+ }
+}
--
Gitblit v1.8.0