pipIrr-SV.git - Gitblit

			@@ -7,12 +7,15 @@
			import com.dy.pipIrrGlobal.pojoPr.PrController;
			import com.dy.pipIrrGlobal.pojoRm.RmAlarmStateHistory;
			import com.dy.pipIrrGlobal.pojoRm.RmAlarmStateLast;
			import com.dy.rtuMw.server.msCenter.MsCenterUnit;
			import com.dy.rtuMw.server.msCenter.MsObj;
			import com.dy.rtuMw.server.rtuData.TaskSurpport;
			import com.dy.rtuMw.server.rtuData.dbSv.DbSv;
			import org.apache.logging.log4j.LogManager;
			import org.apache.logging.log4j.Logger;

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

			/**
			* @Author liurunyu
			@@ -25,6 +28,9 @@
			//类ID，一定与Tree.xml配置文件中配置一致
			public static final String taskId = "TkDealAlarmStatusV202404" ;

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

			/**
			* 执行节点任务：报警及状态
			* @param data 需要处理的数据
			@@ -35,40 +41,148 @@
			DataV202404 dV202404 = (DataV202404)d.getSubData() ;
			Object cdObj = dV202404.subData ;
			//前面任务已经判断cdObj不为null
			boolean toNext = false ;
			try{
			Object[] objs = this.getTaskResults(TkPreGenObjsV202404.taskId) ;
			DbSv sv = (DbSv)objs[0] ;
			PrController controller = (PrController)objs[1] ;
			if(cdObj instanceof DataCd81Vo){
			//设备终端随机自报
			DataCd81Vo cdData = (DataCd81Vo)(cdObj) ;
			this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			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.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			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.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.endDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.endDt, cdData, dV202404.dt) ;
			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.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.openDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.openDt, cdData, dV202404.dt) ;
			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.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ;
			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 ;
			}
			}
			}
			}
			}catch (Exception e){
			log.error("保存控制器报警和状态数据时发生异常", e);
			}
			if(toNext){
			this.toNextTasks(d);
			}
			}

			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 控制器对象
			* @param rtuAddr 控制器地址
			* @param dataV202404 数据对象
			* @param alarmVo 报警+状态对象
			*/
			private void toMsCenter(PrController controller, String rtuAddr, DataV202404 dataV202404, AlarmVo alarmVo, String dt){
			if(alarmVo != null && controller != null){
			if(alarmVo.hasAlarm()){
			MsObj msObj = new MsObj() ;
			msObj.put("name", "报警");
			msObj.put("rtuAddr", rtuAddr);
			msObj.put("intakeId", controller.getIntakeId());
			msObj.put("state", alarmVo.alarmContent());
			msObj.put("dt", dt);
			MsCenterUnit.getInstance().pushMs(msObj);
			}
			if(alarmVo.statePump != null){
			MsObj msObj = new MsObj() ;
			msObj.put("name", "阀态");
			msObj.put("rtuAddr", rtuAddr);
			msObj.put("intakeId", controller.getIntakeId());
			msObj.put("state", alarmVo.statePump);
			msObj.put("stateName", alarmVo.statePump==1?"开":"关");
			msObj.put("dt", dt);
			MsCenterUnit.getInstance().pushMs(msObj);
			}
			}
			}

			/**
			* 保存报警状态最新数据
			* @param sv 服务
			@@ -101,21 +215,20 @@
			alarmVo==null?null:alarmVo.alarmWaterMeterBreak,
			alarmVo==null?null:alarmVo.alarmEleMeterFault,
			alarmVo==null?null:alarmVo.alarm0MoneyRemain,
			alarmVo==null?null:alarmVo.alarmInnerDoor,
			alarmVo==null?null:alarmVo.alarmOuterDoor,
			alarmVo==null?null:alarmVo.alarmDoor,
			alarmVo==null?null:alarmVo.alarmDoor,//2025-02-19机箱外门报警项改为电池电压了
			alarmVo==null?null:alarmVo.alarmEleMiss,
			alarmVo==null?null:alarmVo.alarmEleExceed,
			alarmVo==null?null:alarmVo.alarmEleLowVolt,
			alarmVo==null?null:alarmVo.stateIcEnable,
			(byte)0,//电池电压(1：报警，0：正常)
			(byte)0,//阀门报警(1：报警，0：正常)
			alarmVo==null?null:alarmVo.alarmBatteryVolt,//电池电压(1：报警，0：正常)
			alarmVo==null?null:alarmVo.alarmBlockValve,//阀门堵转报警(1：报警，0：正常)
			(byte)0,//供电方式（0: 220V，1：蓄电池）
			System.currentTimeMillis()
			) ;
			sv.saveRmAlarmStateLast(po) ;
			}else{
			po = this.update(po, controller, rtuDt, alarmVo, receiveDt) ;
			this.updateVirCardNoUseState(sv, controller, alarmVo) ;
			sv.updateRmAlarmStateLast(po);
			}
			}
			@@ -150,14 +263,14 @@
			alarmVo==null?null:alarmVo.alarmWaterMeterBreak,
			alarmVo==null?null:alarmVo.alarmEleMeterFault,
			alarmVo==null?null:alarmVo.alarm0MoneyRemain,
			alarmVo==null?null:alarmVo.alarmInnerDoor,
			alarmVo==null?null:alarmVo.alarmOuterDoor,
			alarmVo==null?null:alarmVo.alarmDoor,
			alarmVo==null?null:alarmVo.alarmDoor,//2025-02-19机箱外门报警项改为电池电压了
			alarmVo==null?null:alarmVo.alarmEleMiss,
			alarmVo==null?null:alarmVo.alarmEleExceed,
			alarmVo==null?null:alarmVo.alarmEleLowVolt,
			alarmVo==null?null:alarmVo.stateIcEnable,
			(byte)0,//电池电压(1：报警，0：正常)
			(byte)0,//阀门报警(1：报警，0：正常)
			alarmVo==null?null:alarmVo.alarmBatteryVolt,//电池电压(1：报警，0：正常)
			alarmVo==null?null:alarmVo.alarmBlockValve,//阀门堵转报警(1：报警，0：正常)
			(byte)0//供电方式（0: 220V，1：蓄电池）
			) ;
			sv.saveRmAlarmStateHistory(po) ;
			@@ -192,32 +305,16 @@
			po.alarmWaterMeterBreak = alarmVo.alarmWaterMeterBreak ;
			po.alarmEleMeterFault = alarmVo.alarmEleMeterFault ;
			po.alarm0MoneyRemain = alarmVo.alarm0MoneyRemain ;
			po.alarmInnerDoor = alarmVo.alarmInnerDoor ;
			po.alarmOuterDoor = alarmVo.alarmOuterDoor ;
			po.alarmInnerDoor = alarmVo.alarmDoor;
			po.alarmOuterDoor = alarmVo.alarmDoor;
			po.alarmEleMiss = alarmVo.alarmEleMiss ;
			po.alarmEleExceed = alarmVo.alarmEleExceed ;
			po.alarmEleLowVolt = alarmVo.alarmEleLowVolt ;
			po.stateIcEnable = alarmVo.stateIcEnable ;
			po.alarmBatteryVolt = alarmVo.alarmBatteryVolt ;
			po.alarmValve = alarmVo.alarmBlockValve;
			}
			return po ;
			}

			/**
			* 虚拟卡在取水中的占用状态改为非应用状态
			*/
			private void updateVirCardNoUseState(DbSv sv,
			PrController controller,
			AlarmVo alarmVo){
			if(alarmVo != null){
			if(alarmVo.statePump != null && alarmVo.statePump.byteValue() == 0){
			//阀门关闭状态
			if(controller != null && controller.getIntakeId() != null){
			//虚拟卡在取水中的占用状态改为非应用状态
			Date now = new Date() ;
			sv.updateVirCardNoUseState(controller.getIntakeId(), now);
			}
			}
			}

			}
			}