pipIrr-SV.git - Gitblit

			@@ -1,6 +1,7 @@
			package com.dy.rtuMw.server.rtuData.p206V1;

			import com.dy.common.mw.protocol.p206V1.upVos.*;
			import com.dy.common.util.DateTime;
			import com.dy.pipIrrGlobal.pojoRm.RmAlarmStateHistory;
			import com.dy.rtuMw.server.ServerProperties;
			import com.dy.rtuMw.server.forMs.SendMsCache;
			@@ -15,6 +16,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/6/11 17:19
			@@ -26,6 +30,10 @@

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

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


			/**
			* 执行节点任务：报警及状态
			@@ -46,16 +54,20 @@
			//随机自报报
			DataCd81Vo dataCd81Vo = (DataCd81Vo)cdObj ;
			if (dataCd81Vo.alarmVo != null \|\| dataCd81Vo.stateVo != null) {
			Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
			DbSv sv = (DbSv) objs[0];
			PrController controller = (PrController) objs[1];
			this.toMsCenter(controller, d.getRtuAddr(), dV1, dataCd81Vo.alarmVo, dataCd81Vo.stateVo);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCd81Vo.rtuDt, dV1, dataCd81Vo.alarmVo, dataCd81Vo.stateVo);
			this.saveHistory(sv, controller, d.getRtuAddr(), dataCd81Vo.rtuDt, dV1, dataCd81Vo.alarmVo, dataCd81Vo.stateVo);
			if(dataCd81Vo.stateVo != null && dataCd81Vo.stateVo.valveState != null && dataCd81Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
			toNext = true ;
			if(this.needSave2Db( d.getRtuAddr())){
			//在一个小时内没有存储报警数据
			Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
			DbSv sv = (DbSv) objs[0];
			PrController controller = (PrController) objs[1];
			this.toMsCenter(controller, d.getRtuAddr(), dV1, dataCd81Vo.alarmVo, dataCd81Vo.stateVo);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCd81Vo.rtuDt, dV1, dataCd81Vo.alarmVo, dataCd81Vo.stateVo);
			this.saveHistory(sv, controller, d.getRtuAddr(), dataCd81Vo.rtuDt, dV1, dataCd81Vo.alarmVo, dataCd81Vo.stateVo);
			this.cacheSaveTime(d.getRtuAddr());
			if(dataCd81Vo.stateVo != null && dataCd81Vo.stateVo.valveState != null && dataCd81Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
			toNext = true ;
			}
			}
			}
			}
			@@ -63,34 +75,42 @@
			//阀开工作报
			DataCd84Vo dataCd84Vo = (DataCd84Vo)cdObj ;
			if (dataCd84Vo.alarmVo != null \|\| dataCd84Vo.stateVo != null) {
			Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
			DbSv sv = (DbSv) objs[0];
			PrController controller = (PrController) objs[1];
			this.toMsCenter(controller, d.getRtuAddr(), dV1, dataCd84Vo.alarmVo, dataCd84Vo.stateVo);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCd84Vo.rtuDt, dV1, dataCd84Vo.alarmVo, dataCd84Vo.stateVo);
			this.saveHistory(sv, controller, d.getRtuAddr(), dataCd84Vo.rtuDt, dV1, dataCd84Vo.alarmVo, dataCd84Vo.stateVo);
			/** 阀开工作报，阀门状态一定是打开状态，所以不设置下面数据以备后续任务设置虚拟卡状态
			if(dataCd84Vo.stateVo != null && dataCd84Vo.stateVo.valveState != null && dataCd84Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
			toNext = true ;
			}
			}*/
			if(this.needSave2Db( d.getRtuAddr())) {
			//在一个小时内没有存储报警数据
			Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
			DbSv sv = (DbSv) objs[0];
			PrController controller = (PrController) objs[1];
			this.toMsCenter(controller, d.getRtuAddr(), dV1, dataCd84Vo.alarmVo, dataCd84Vo.stateVo);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCd84Vo.rtuDt, dV1, dataCd84Vo.alarmVo, dataCd84Vo.stateVo);
			this.saveHistory(sv, controller, d.getRtuAddr(), dataCd84Vo.rtuDt, dV1, dataCd84Vo.alarmVo, dataCd84Vo.stateVo);
			this.cacheSaveTime(d.getRtuAddr());
			/** 阀开工作报，阀门状态一定是打开状态，所以不设置下面数据以备后续任务设置虚拟卡状态
			if(dataCd84Vo.stateVo != null && dataCd84Vo.stateVo.valveState != null && dataCd84Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
			toNext = true ;
			}
			}*/
			}
			}
			} else if (cdObj instanceof DataCdC0Vo) {
			//整点报
			DataCdC0Vo dataCdC0Vo = (DataCdC0Vo)cdObj ;
			if (dataCdC0Vo.alarmVo != null \|\| dataCdC0Vo.stateVo != null) {
			Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
			DbSv sv = (DbSv) objs[0];
			PrController controller = (PrController) objs[1];
			this.toMsCenter(controller, d.getRtuAddr(), dV1, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCdC0Vo.rtuDt, dV1, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo);
			this.saveHistory(sv, controller, d.getRtuAddr(), dataCdC0Vo.rtuDt, dV1, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo);
			if(dataCdC0Vo.stateVo != null && dataCdC0Vo.stateVo.valveState != null && dataCdC0Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
			toNext = true ;
			if(this.needSave2Db( d.getRtuAddr())) {
			//在一个小时内没有存储报警数据
			Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
			DbSv sv = (DbSv) objs[0];
			PrController controller = (PrController) objs[1];
			this.toMsCenter(controller, d.getRtuAddr(), dV1, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo);
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCdC0Vo.rtuDt, dV1, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo);
			this.saveHistory(sv, controller, d.getRtuAddr(), dataCdC0Vo.rtuDt, dV1, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo);
			this.cacheSaveTime(d.getRtuAddr());
			if(dataCdC0Vo.stateVo != null && dataCdC0Vo.stateVo.valveState != null && dataCdC0Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){
			if(controller != null && controller.getIntakeId() != null){
			this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ;
			toNext = true ;
			}
			}
			}
			}
			@@ -105,6 +125,24 @@
			}
			}

			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 控制器对象
			@@ -114,7 +152,7 @@
			* @param stateVo 状态对象
			*/
			private void toMsCenter(PrController controller, String rtuAddr, DataV1 dV1, DataAlarmVo alarmVo, DataStateVo stateVo){
			if(alarmVo != null && controller != null){
			if(alarmVo != null && controller != null && alarmVo.hasAlarm()){
			MsObj msObj = new MsObj() ;
			msObj.put("name", "报警");
			msObj.put("rtuAddr", rtuAddr);
			@@ -123,6 +161,16 @@
			msObj.put("dt", dV1.dt);
			MsCenterUnit.getInstance().pushMs(msObj);
			}
			if(stateVo != null && controller != null && stateVo.valveState != null){
			MsObj msObj = new MsObj() ;
			msObj.put("name", "阀态");
			msObj.put("rtuAddr", rtuAddr);
			msObj.put("intakeId", controller.getIntakeId());
			msObj.put("state", stateVo.valveState);
			msObj.put("stateName", stateVo.valveState==0?"开":"关");
			msObj.put("dt", dV1.dt);
			MsCenterUnit.getInstance().pushMs(msObj);
			}
			}

			/**