package com.dy.rtuMw.server.rtuData.p206V1; import com.dy.common.mw.protocol.p206V1.upVos.*; import com.dy.pipIrrGlobal.pojoRm.RmAlarmStateHistory; import com.dy.rtuMw.server.ServerProperties; import com.dy.rtuMw.server.forMs.SendMsCache; 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 com.dy.common.mw.protocol.Data; import com.dy.common.mw.protocol.p206V1.DataV1; import com.dy.pipIrrGlobal.pojoPr.PrController; import com.dy.pipIrrGlobal.pojoRm.RmAlarmStateLast; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; /** * @Author liurunyu * @Date 2024/6/11 17:19 * @Description */ public class TkDealAlarmStatus extends TaskSurpport { private static final Logger log = LogManager.getLogger(TkDealAlarmStatus.class.getName()) ; //类ID，一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkDealAlarmStatus" ; /** * 执行节点任务：报警及状态 * @param data 需要处理的数据 */ @Override public void execute(Object data) { Data d = (Data)data ; Object subD = d.getSubData() ; if(subD != null){ boolean toNext = false ; DataV1 dV1 = (DataV1)subD ; if(dV1 != null && dV1.subData != null){ //dV1.dataCd81Vo、 dV1.dataCd84Vo 与 dV1.dataCdC0Vo 不会同时有值 Object cdObj = dV1.subData ; try { if (cdObj instanceof DataCd81Vo) { //随机自报报 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 ; } } } } else if (cdObj instanceof DataCd84Vo) { //阀开工作报 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 ; } }*/ } } 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 ; } } } } } catch (Exception e) { log.error("保存控制器报警和状态数据时发生异常", e); } } if(toNext){ this.toNextTasks(d); } } } /** * 报警状态数据存入消息中心 * @param controller 控制器对象 * @param rtuAddr 控制器地址 * @param dV1 数据对象 * @param alarmVo 报警对象 * @param stateVo 状态对象 */ private void toMsCenter(PrController controller, String rtuAddr, DataV1 dV1, DataAlarmVo alarmVo, DataStateVo stateVo){ if(alarmVo != null && controller != null && alarmVo.hasAlarm()){ MsObj msObj = new MsObj() ; msObj.put("name", "报警"); msObj.put("rtuAddr", rtuAddr); msObj.put("intakeId", controller.getIntakeId()); msObj.put("alarm", alarmVo.alarmContent()); msObj.put("dt", dV1.dt); MsCenterUnit.getInstance().pushMs(msObj); } } /** * 保存报警状态最新数据 * @param sv 服务 * @param controller 控制器对象 * @param rtuAddr 控制器地址 * @param rtuDt 控制器时钟 * @param alarmVo 报警对象 * @param stateVo 状态对象 */ private void saveOrUpdateLast(DbSv sv, PrController controller, String rtuAddr, String rtuDt, DataV1 dV1, 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(dV1, 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, dV1, 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, DataV1 dV1, 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(dV1, rtuDt, alarmVo, stateVo); sv.saveRmAlarmStateHistory(po) ; } private RmAlarmStateLast update(PrController controller, RmAlarmStateLast po, String rtuDt, DataV1 dV1, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception { po.controllerId = controller==null?null:controller.getId() ; po.intakeId = controller==null?null:controller.getIntakeId() ; po.updateFrom(dV1, 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); } } }