pipIrr-SV.git - Gitblit

			@@ -14,6 +14,9 @@
			import org.apache.logging.log4j.LogManager;
			import org.apache.logging.log4j.Logger;

			import java.util.HashMap;
			import java.util.Map;

			/**
			* @Author liurunyu
			* @Date 2024/5/8 14:18
			@@ -24,6 +27,9 @@

			//类ID，一定与Tree.xml配置文件中配置一致
			public static final String taskId = "TkDealAlarmStatusV202404" ;

			//是否在某个时刻（年月日时）保存了报警状态数据
			private static final Map<String, Long> onceSaveAlarmData4Rtus = new HashMap<>();

			/**
			* 执行节点任务：报警及状态
			@@ -42,62 +48,82 @@
			PrController controller = (PrController)objs[1] ;
			if(cdObj instanceof DataCd81Vo){
			//设备终端随机自报
			DataCd81Vo cdData = (DataCd81Vo)(cdObj) ;
			this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ;
			toNext = true ;
			if(this.needSave2Db( d.getRtuAddr())) {
			//在一个小时内没有存储报警数据
			DataCd81Vo cdData = (DataCd81Vo)(cdObj) ;
			this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.cacheSaveTime(d.getRtuAddr());
			if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ;
			toNext = true ;
			}
			}
			}
			}else if(cdObj instanceof DataCd80_5BVo){
			//设备终端工作上报 + 查询设备终端实时值
			DataCd80_5BVo cdData = (DataCd80_5BVo)(cdObj) ;
			this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ;
			toNext = true ;
			if(this.needSave2Db( d.getRtuAddr())) {
			//在一个小时内没有存储报警数据
			DataCd80_5BVo cdData = (DataCd80_5BVo)(cdObj) ;
			this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.cacheSaveTime(d.getRtuAddr());
			if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ;
			toNext = true ;
			}
			}
			}
			}else if(cdObj instanceof DataCd93_A3Vo){
			//平台/APP远程关闭水泵/阀门 + 刷卡关泵/阀上报
			DataCd93_A3Vo cdData = (DataCd93_A3Vo)(cdObj) ;
			this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.endDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.endDt, cdData, dV202404.dt) ;
			if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ;
			toNext = true ;
			if(this.needSave2Db( d.getRtuAddr())) {
			//在一个小时内没有存储报警数据
			DataCd93_A3Vo cdData = (DataCd93_A3Vo)(cdObj) ;
			this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.endDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.endDt, cdData, dV202404.dt) ;
			this.cacheSaveTime(d.getRtuAddr());
			if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ;
			toNext = true ;
			}
			}
			}
			}else if(cdObj instanceof DataCd84Vo){
			//设备终端刷卡开泵/阀上报
			DataCd84Vo cdData = (DataCd84Vo)(cdObj) ;
			this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.openDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.openDt, cdData, dV202404.dt) ;
			if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ;
			toNext = true ;
			if(this.needSave2Db( d.getRtuAddr())) {
			//在一个小时内没有存储报警数据
			DataCd84Vo cdData = (DataCd84Vo)(cdObj) ;
			this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.openDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.openDt, cdData, dV202404.dt) ;
			this.cacheSaveTime(d.getRtuAddr());
			if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ;
			toNext = true ;
			}
			}
			}
			}else if(cdObj instanceof DataCdC2Vo){
			//设备终端开关水泵/阀门成功/失败上报
			DataCdC2Vo cdData = (DataCdC2Vo)(cdObj) ;
			this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ;
			toNext = true ;
			if(this.needSave2Db( d.getRtuAddr())) {
			//在一个小时内没有存储报警数据
			DataCdC2Vo cdData = (DataCdC2Vo)(cdObj) ;
			this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.cacheSaveTime(d.getRtuAddr());
			if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ;
			toNext = true ;
			}
			}
			}
			}
			@@ -109,6 +135,23 @@
			}
			}

			private boolean needSave2Db(String rtuAddr){
			if(!onceSaveAlarmData4Rtus.containsKey(rtuAddr)){
			return true ;
			}else{
			Long time = onceSaveAlarmData4Rtus.get(rtuAddr) ;
			Long ymdh = Long.parseLong(DateTime.yyyyMMddHH()) ;
			if(ymdh.longValue() == time.longValue()){
			//同一个小时内
			return false ;
			}else{
			return true ;
			}
			}
			}
			private void cacheSaveTime(String rtuAddr){
			onceSaveAlarmData4Rtus.put(rtuAddr, Long.parseLong(DateTime.yyyyMMddHH()));
			}
			/**
			* 报警状态数据存入消息中心
			* @param controller 控制器对象