package com.dy.rtuMw.server.rtuData.p206V202404; import com.dy.common.mw.protocol.Data; import com.dy.common.mw.protocol.p206V202404.DataV202404; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd80_5BVo; import com.dy.pipIrrGlobal.pojoPr.PrController; 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; /** * @author ZhuBaoMin * @date 2024-06-14 11:23 * @LastEditTime 2024-06-14 11:23 * @Description 控制器阀开工作上报数据 */ public class TkDealWorkReportV202404 extends TaskSurpport { private static final Logger log = LogManager.getLogger(TkDealTimingReportV202404.class.getName()); //类ID,一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkDealWorkReportV202404"; /** * 执行节点任务:处理阀控器阀开工作上报数据 * @param data 需要处理的数据 */ @Override public void execute(Object data) { Data d = (Data) data; DataV202404 dV202404 = (DataV202404) d.getSubData();//前面任务已经判断不为null //Object cdObj = dV202404.subData; //if (cdObj != null) { // try { // Object[] objs = this.getTaskResults(TkPreGenObjsV202404.taskId); // DbSv sv = (DbSv) objs[0]; // PrController controller = (PrController) objs[1]; // if (cdObj instanceof DataCd83Vo) { // //设备终端定点上报, 每天12点上报数据 // DataCd83Vo cdData = (DataCd83Vo) (cdObj); // //this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt); // //this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt); // } // } catch (Exception e) { // log.error("保存控制器报警和状态数据时发生异常", e); // } //} } /** * 保存阀开工作报历史数据 * @param sv * @param controller * @param rtuAddr * @param dV202404 * @param dataCd80_5BVo */ private void saveHistory(DbSv sv, PrController controller, String rtuAddr, DataV202404 dV202404, DataCd80_5BVo dataCd80_5BVo) { } }