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.*; import com.dy.common.util.DateTime; import com.dy.pipIrrGlobal.pojoPr.PrController; import com.dy.pipIrrGlobal.pojoRm.RmAlarmStateHistory; import com.dy.pipIrrGlobal.pojoRm.RmAlarmStateLast; import com.dy.rtuMw.server.ServerProperties; import com.dy.rtuMw.server.forMs.SendMsCache; import com.dy.rtuMw.server.rtuData.TaskSurpport; import com.dy.rtuMw.server.rtuData.dbSv.DbSv; import com.dy.rtuMw.server.rtuData.p206V1.TkPreGenObjs; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; /** * @Author liurunyu * @Date 2024/6/11 17:19 * @Description */ public class TkDealAlarmStatusV2 extends TaskSurpport { private static final Logger log = LogManager.getLogger(TkDealAlarmStatusV2.class.getName()) ; //类ID，一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkDealAlarmStatusV2" ; /** * 执行节点任务：报警及状态 * @param data 需要处理的数据 */ @Override public void execute(Object data) { Data d = (Data)data ; Object subD = d.getSubData() ; if(subD != null){ DataV2 dV2 = (DataV2)subD ; if(dV2 != null && dV2.subData != null){ //dV2.dataCd81Vo、 dV2.dataCd84Vo 与 dV2.dataCdC0Vo 不会同时有值 Object cdObj = dV2.subData ; try { if (cdObj instanceof DataCd02Vo) { //心跳数据，根据任务TkDealHearBeatV2,这里收到的心跳时，一定是报警或状态发生了改变 DataCd02Vo dataCd02Vo = (DataCd02Vo)cdObj ; if (dataCd02Vo.alarmVo != null || dataCd02Vo.stateVo != null) { Object[] objs = this.getTaskResults(TkPreGenObjs.taskId); DbSv sv = (DbSv) objs[0]; PrController controller = (PrController) objs[1]; //心跳没有时钟，并且RTU针对心跳数据的机制是上报不成功不重发，所以时间采用本地时间 String now = DateTime.yyyy_MM_dd_HH_mm_ss() ; this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), now, dV2, dataCd02Vo.alarmVo, dataCd02Vo.stateVo); this.saveHistory(sv, controller, d.getRtuAddr(), now, dV2, dataCd02Vo.alarmVo, dataCd02Vo.stateVo); if(dataCd02Vo.stateVo != null && dataCd02Vo.stateVo.valveState != null && dataCd02Vo.stateVo.valveState.byteValue() == DataStateVo.ValveCloseState){ if(controller != null && controller.getIntakeId() != null){ this.taskResult = new Object[]{controller.getIntakeId(), DataStateVo.ValveCloseState} ; } } } } else if (cdObj instanceof DataCd81Vo) { //随机自报报 DataCd81Vo dataCd81Vo = (DataCd81Vo)cdObj ; if (dataCd81Vo.alarmVo != null || dataCd81Vo.stateVo != null) { Object[] objs = this.getTaskResults(TkPreGenObjsV2.taskId); DbSv sv = (DbSv) objs[0]; PrController controller = (PrController) objs[1]; this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCd81Vo.rtuDt, dV2, dataCd81Vo.alarmVo, dataCd81Vo.stateVo); this.saveHistory(sv, controller, d.getRtuAddr(), dataCd81Vo.rtuDt, dV2, 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} ; } } } } else if (cdObj instanceof DataCd84Vo) { //阀开工作报 DataCd84Vo dataCd84Vo = (DataCd84Vo)cdObj ; if (dataCd84Vo.alarmVo != null || dataCd84Vo.stateVo != null) { Object[] objs = this.getTaskResults(TkPreGenObjsV2.taskId); DbSv sv = (DbSv) objs[0]; PrController controller = (PrController) objs[1]; this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCd84Vo.rtuDt, dV2, dataCd84Vo.alarmVo, dataCd84Vo.stateVo); this.saveHistory(sv, controller, d.getRtuAddr(), dataCd84Vo.rtuDt, dV2, 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} ; } }*/ } } else if (cdObj instanceof DataCdC0Vo) { //整点报 DataCdC0Vo dataCdC0Vo = (DataCdC0Vo)cdObj ; if (dataCdC0Vo.alarmVo != null || dataCdC0Vo.stateVo != null) { Object[] objs = this.getTaskResults(TkPreGenObjsV2.taskId); DbSv sv = (DbSv) objs[0]; PrController controller = (PrController) objs[1]; this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dataCdC0Vo.rtuDt, dV2, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo); this.saveHistory(sv, controller, d.getRtuAddr(), dataCdC0Vo.rtuDt, dV2, 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} ; } } } } } catch (Exception e) { log.error("保存控制器报警和状态数据时发生异常", e); } } } } /** * 保存报警状态最新数据 * @param sv 服务 * @param controller 控制器对象 * @param rtuAddr 控制器地址 * @param rtuDt 控制器时钟 * @param alarmVo 报警对象 * @param stateVo 状态对象 */ private void saveOrUpdateLast(DbSv sv, PrController controller, String rtuAddr, String rtuDt, DataV2 dV2, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception { RmAlarmStateLast po = sv.getRmAlarmStateLast(controller.getIntakeId()) ; if(po == null){ po = new RmAlarmStateLast(); po.controllerId = controller==null?null:controller.getId() ; po.intakeId = controller==null?null:controller.getIntakeId() ; po.rtuAddr = rtuAddr ; po.valueFrom(dV2, rtuDt, alarmVo, stateVo); if(alarmVo.hasAlarmExcludeLoss()){ po.sendMsTime = System.currentTimeMillis() ; this.sendMessage(controller, alarmVo); } sv.saveRmAlarmStateLast(po) ; }else{ if(po.sendMsTime == null){ if(alarmVo.hasAlarmExcludeLoss()) { po.sendMsTime = System.currentTimeMillis(); this.sendMessage(controller, alarmVo); } }else{ if(alarmVo.hasAlarmExcludeLoss()){ Long now = System.currentTimeMillis() ; if(((now - po.sendMsTime) / (1000 * 60)) > ServerProperties.sendDingDingAlarmMsInterval){ //大于规定的间隔时间 po.sendMsTime = System.currentTimeMillis() ; this.sendMessage(controller, alarmVo); } } } po = this.update(controller, po, rtuDt, dV2, alarmVo, stateVo) ; sv.updateRmAlarmStateLast(po); } } /** * 保存报警状态历史记录 * @param sv 服务 * @param controller 控制器对象 * @param rtuAddr 控制器地址 * @param rtuDt 控制器时钟 * @param alarmVo 报警对象 * @param stateVo 状态对象 */ private void saveHistory(DbSv sv, PrController controller, String rtuAddr, String rtuDt, DataV2 dV2, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception { RmAlarmStateHistory po = new RmAlarmStateHistory() ; po.controllerId = controller==null?null:controller.getId() ; po.intakeId = controller==null?null:controller.getIntakeId() ; po.rtuAddr = rtuAddr ; po.valueFrom(dV2, rtuDt, alarmVo, stateVo); sv.saveRmAlarmStateHistory(po) ; } private RmAlarmStateLast update(PrController controller, RmAlarmStateLast po, String rtuDt, DataV2 dV2, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception { po.controllerId = controller==null?null:controller.getId() ; po.intakeId = controller==null?null:controller.getIntakeId() ; po.updateFrom(dV2, rtuDt, alarmVo, stateVo); return po ; } /** * 向钉钉发送消息 * @param controller * @param alarmVo */ private void sendMessage(PrController controller, DataAlarmVo alarmVo){ String ms = "取水口“" + controller.getIntakeName() + "”产生报警：" + alarmVo.alarmContentExcludeLoss() ; try{ SendMsCache.cacheMs(ms); }catch (Exception e){ log.error("缓存钉钉消息异常：", e); } } }