| New file |
| | |
|---|
| | | 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.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.HashMap; |
|---|
| | | import java.util.Map; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @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" ; |
|---|
| | | |
|---|
| | | //是否在某个时刻（年月日时）保存了报警状态数据 |
|---|
| | | private static final Map<String, Long> onceSaveAlarmData4Rtus = new HashMap<>(); |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 执行节点任务：报警及状态 |
|---|
| | | * @param data 需要处理的数据 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public void execute(Object data) { |
|---|
| | | Data d = (Data)data ; |
|---|
| | | Object subD = d.getSubData() ; |
|---|
| | | if(subD != null){ |
|---|
| | | boolean toNext = false ; |
|---|
| | | 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) { |
|---|
| | | if(this.needSave2Db( d.getRtuAddr())){ |
|---|
| | | //在一个小时内没有存储报警数据 |
|---|
| | | Object[] objs = this.getTaskResults(TkPreGenObjsV2.taskId); |
|---|
| | | DbSv sv = (DbSv) objs[0]; |
|---|
| | | PrController controller = (PrController) objs[1]; |
|---|
| | | //心跳没有时钟，并且RTU针对心跳数据的机制是上报不成功不重发，所以时间采用本地时间 |
|---|
| | | String now = DateTime.yyyy_MM_dd_HH_mm_ss() ; |
|---|
| | | this.toMsCenter(controller, d.getRtuAddr(), dV2, dataCd02Vo.alarmVo, dataCd02Vo.stateVo); |
|---|
| | | this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), now, dV2, dataCd02Vo.alarmVo, dataCd02Vo.stateVo); |
|---|
| | | this.saveHistory(sv, controller, d.getRtuAddr(), now, dV2, dataCd02Vo.alarmVo, dataCd02Vo.stateVo); |
|---|
| | | this.cacheSaveTime(d.getRtuAddr()); |
|---|
| | | 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} ; |
|---|
| | | toNext = true ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else if (cdObj instanceof DataCd81Vo) { |
|---|
| | | //随机自报报 |
|---|
| | | DataCd81Vo dataCd81Vo = (DataCd81Vo)cdObj ; |
|---|
| | | if (dataCd81Vo.alarmVo != null || dataCd81Vo.stateVo != null) { |
|---|
| | | if(this.needSave2Db( d.getRtuAddr())) { |
|---|
| | | //在一个小时内没有存储报警数据 |
|---|
| | | Object[] objs = this.getTaskResults(TkPreGenObjsV2.taskId); |
|---|
| | | DbSv sv = (DbSv) objs[0]; |
|---|
| | | PrController controller = (PrController) objs[1]; |
|---|
| | | this.toMsCenter(controller, d.getRtuAddr(), dV2, dataCd81Vo.alarmVo, dataCd81Vo.stateVo); |
|---|
| | | 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); |
|---|
| | | 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 ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else if (cdObj instanceof DataCd84Vo) { |
|---|
| | | //阀开工作报 |
|---|
| | | DataCd84Vo dataCd84Vo = (DataCd84Vo)cdObj ; |
|---|
| | | if (dataCd84Vo.alarmVo != null || dataCd84Vo.stateVo != null) { |
|---|
| | | if(this.needSave2Db( d.getRtuAddr())) { |
|---|
| | | //在一个小时内没有存储报警数据 |
|---|
| | | Object[] objs = this.getTaskResults(TkPreGenObjsV2.taskId); |
|---|
| | | DbSv sv = (DbSv) objs[0]; |
|---|
| | | PrController controller = (PrController) objs[1]; |
|---|
| | | this.toMsCenter(controller, d.getRtuAddr(), dV2, dataCd84Vo.alarmVo, dataCd84Vo.stateVo); |
|---|
| | | 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); |
|---|
| | | 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} ; |
|---|
| | | } |
|---|
| | | }*/ |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else if (cdObj instanceof DataCdC0Vo) { |
|---|
| | | //整点报 |
|---|
| | | DataCdC0Vo dataCdC0Vo = (DataCdC0Vo)cdObj ; |
|---|
| | | if (dataCdC0Vo.alarmVo != null || dataCdC0Vo.stateVo != null) { |
|---|
| | | if(this.needSave2Db( d.getRtuAddr())) { |
|---|
| | | //在一个小时内没有存储报警数据 |
|---|
| | | Object[] objs = this.getTaskResults(TkPreGenObjsV2.taskId); |
|---|
| | | DbSv sv = (DbSv) objs[0]; |
|---|
| | | PrController controller = (PrController) objs[1]; |
|---|
| | | this.toMsCenter(controller, d.getRtuAddr(), dV2, dataCdC0Vo.alarmVo, dataCdC0Vo.stateVo); |
|---|
| | | 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); |
|---|
| | | 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 ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } 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 dV12 数据对象 |
|---|
| | | * @param alarmVo 报警对象 |
|---|
| | | * @param stateVo 状态对象 |
|---|
| | | */ |
|---|
| | | private void toMsCenter(PrController controller, String rtuAddr, DataV2 dV12, 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", dV12.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", dV12.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, 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); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
