package com.dy.rtuMw.server.rtuData.p206V1_0_0; import com.dy.common.mw.protocol.Data; import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1; import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd83CloseVo; import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd83OpenVo; import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd84Vo; import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCdC0Vo; import com.dy.common.util.DateTime; import com.dy.pipIrrGlobal.pojoPr.PrController; import com.dy.pipIrrGlobal.pojoRm.RmIntakeAmountDay; import com.dy.pipIrrGlobal.pojoRm.RmIntakeAmountDayLast; 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: liurunyu * @Date: 2024/7/8 19:00 * @Description 取水口日用水量和漏损量 */ public class TkDealIntakeAmountDay extends TaskSurpport { private static final Logger log = LogManager.getLogger(TkDealLoss.class.getName()); //类ID，一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkDealIntakeAmountDay"; /** * 执行节点任务: 取水口日用水量和漏损量 * * @param data 需要处理的数据 */ @Override public void execute(Object data) { Data d = (Data) data; DataV1_0_1 dV1_0_1 = (DataV1_0_1) d.getSubData();//前面任务已经判断不为null Object cdObj = dV1_0_1.subData; if (cdObj != null && (cdObj instanceof DataCdC0Vo || cdObj instanceof DataCd84Vo || cdObj instanceof DataCd83OpenVo || cdObj instanceof DataCd83CloseVo)){ Object[] objs = this.getTaskResults(TkPreGenObjs.taskId) ; DbSv sv = (DbSv)objs[0] ; PrController controller = (PrController)objs[1] ; try{ UpDataVo vo = new UpDataVo() ; if(cdObj instanceof DataCdC0Vo){ vo.valueFrom((DataCdC0Vo)cdObj, null, null, null); }else if(cdObj instanceof DataCd84Vo){ vo.valueFrom(null, (DataCd84Vo)cdObj, null, null); }else if(cdObj instanceof DataCd83OpenVo){ vo.valueFrom(null,null, (DataCd83OpenVo)cdObj,null); }else if(cdObj instanceof DataCd83CloseVo){ vo.valueFrom(null,null,null, (DataCd83CloseVo)cdObj); } this.doDeal(sv, controller, d.getRtuAddr(), dV1_0_1, vo); }catch (Exception e){ log.error("保存取水口日用水量和漏损量数据时发生异常", e); } } } /** * 业务处理 * @param sv 服务 * @param controller 控制器对象 * @param rtuAddr 控制器地址 * @param dV1_0_1 上报数据 * @param dataVo 上报数据对象 */ private void doDeal(DbSv sv, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, UpDataVo dataVo) throws Exception { RmIntakeAmountDayLast poLast = sv.getRmIntakeAmountLast(controller.getIntakeId()); if (poLast == null) { //数据库中不存在该取水口的漏损数据 //首先生成最新数据及历史数据，并先保存 poLast = this.newRmIntakeAmountLast(controller, rtuAddr, dV1_0_1, dataVo); this.newAndSaveHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataVo, poLast); sv.saveRmIntakeAmountLast(poLast); } else { if(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataVo.rtuDt).before(poLast.rtuDtLast)){ //RTU时钟早于本地RTU时钟，是补报，补报没法计算取水口日累计取水量，因为采用的是累计流量相差的计算方法 }else if(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataVo.rtuDt).equals(poLast.rtuDtLast)){ //RTU时钟等于本地RTU时钟，重复上报数据，不进行任何处理 }else{ //上行数据中的日期时间符合可计算的条件 if(!rtuAddr.equals(poLast.rtuAddrLast)){ //更换了控制器，只更换控制器地址，不进行水量计算 poLast = this.updateRmIntakeAmountLastByControllerChange(poLast, controller, rtuAddr, dV1_0_1, dataVo); //因为上行数据中的日期时间是可进行计算的，所以新生成一个历史记录 this.newAndSaveHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataVo, poLast); sv.saveRmIntakeAmountLast(poLast); }else{ //未更换控制器 if(DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt).equals(poLast.dt)){ //同一天数据 poLast = this.updateRmIntakeAmountLastBySameDateNewData(poLast, controller, rtuAddr, dV1_0_1, dataVo); RmIntakeAmountDay poHistory = null ; if(poLast.lastHistoryId != null){ poHistory = sv.getRmIntakeAmountDay(poLast.lastHistoryId) ; } if(poHistory == null){ this.newAndSaveHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataVo, poLast); }else{ poHistory = this.updateRmIntakeAmountBySameDateNewData(poHistory, poLast, controller, rtuAddr, dV1_0_1, dataVo); sv.updateRmIntakeAmountDay(poHistory); } sv.saveRmIntakeAmountLast(poLast); }else if(DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt).after(poLast.dt)){ //新的日期 poLast = this.updateRmIntakeAmountLastByNewDateNewData(poLast, controller, rtuAddr, dV1_0_1, dataVo); this.newAndSaveHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataVo, poLast); sv.saveRmIntakeAmountLast(poLast); }else{ //这种情况不存在 } } } } } /** * 生成新的控制器漏损日统计最新记录 * @param controller * @param rtuAddr * @param dV1_0_1 * @param cdData * @return * @throws Exception */ private RmIntakeAmountDayLast newRmIntakeAmountLast(PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, UpDataVo cdData)throws Exception { RmIntakeAmountDayLast po = new RmIntakeAmountDayLast() ; po.intakeId = controller==null?null:controller.getIntakeId(); po.controllerIdLast = controller==null?null:controller.getId(); po.totalAmountLast = cdData.totalAmount ; po.dt = DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt); po.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt); po.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); po.amount = 0.0D ; po.rtuAddrLast = rtuAddr; return po ; } /** * 生成新的控制器漏损日统计历史记录 * @param controller * @param rtuAddr * @param dV1_0_1 * @param cdData * @return * @throws Exception */ private RmIntakeAmountDay newRmIntakeAmountDay(PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, UpDataVo cdData, RmIntakeAmountDayLast lastPo)throws Exception { RmIntakeAmountDay po = new RmIntakeAmountDay() ; po.intakeId = controller==null?null:controller.getIntakeId(); po.controllerIdLast = controller==null?null:controller.getId(); po.rtuAddrLast = rtuAddr; po.dt = DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt); po.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt); po.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); if(lastPo != null){ po.amount = lastPo.amount ; }else{ po.amount = 0.0D ; } po.amount = lastPo==null?0.0D:lastPo.amount ; po.totalAmountLast = cdData.totalAmount ; return po ; } /** * 保存新的开阀上报历史数据记录，并把ID赋值给最新记录的 lastHistoryId * @param sv * @param controller * @param rtuAddr * @param dV1_0_1 * @param dataCdC0Vo * @param poLast * @throws Exception * @return RmIntakeAmountDay */ private RmIntakeAmountDay newAndSaveHistoryDataDeal(DbSv sv, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, UpDataVo dataCdC0Vo, RmIntakeAmountDayLast poLast)throws Exception { RmIntakeAmountDay poHistory = this.newRmIntakeAmountDay(controller, rtuAddr, dV1_0_1, dataCdC0Vo, poLast) ; sv.saveRmIntakeAmountDay(poHistory); //由最新数据持有历史数据中的最新记录ID，以方便快速查询 poLast.lastHistoryId = poHistory == null ? null: poHistory.id ; return poHistory ; } /** * 生成新的控制器漏损日统计最新记录 * @param controller * @param rtuAddr * @param dV1_0_1 * @param cdData * @return * @throws Exception */ private RmIntakeAmountDayLast updateRmIntakeAmountLastByControllerChange(RmIntakeAmountDayLast lastPo, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, UpDataVo cdData)throws Exception { lastPo.intakeId = controller==null?null:controller.getIntakeId(); lastPo.controllerIdLast = controller==null?null:controller.getId(); lastPo.rtuAddrLast = rtuAddr; lastPo.dt = DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt); lastPo.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt); lastPo.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); //lastPo.amount = lastPo.amount ; //累计取水量不变 lastPo.totalAmountLast = cdData.totalAmount ; return lastPo ; } /** * 更新最新记录 * @param controller * @param rtuAddr * @param dV1_0_1 * @param cdData * @return * @throws Exception */ private RmIntakeAmountDayLast updateRmIntakeAmountLastBySameDateNewData(RmIntakeAmountDayLast lastPo, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, UpDataVo cdData)throws Exception { lastPo.intakeId = controller==null?null:controller.getIntakeId(); lastPo.controllerIdLast = controller==null?null:controller.getId(); lastPo.rtuAddrLast = rtuAddr; //lastPo.dt = DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt);//日期没变 lastPo.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt); lastPo.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); Double difference = cdData.totalAmount - lastPo.totalAmountLast ; if(difference > 0){ lastPo.amount = difference; }else{ //po.amount = po.amount ; //累计取水量不变 } lastPo.totalAmountLast = cdData.totalAmount ; return lastPo ; } /** * 更新最新记录 * @param controller * @param rtuAddr * @param dV1_0_1 * @param cdData * @return * @throws Exception */ private RmIntakeAmountDayLast updateRmIntakeAmountLastByNewDateNewData(RmIntakeAmountDayLast lastPo, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, UpDataVo cdData)throws Exception { lastPo.intakeId = controller==null?null:controller.getIntakeId(); lastPo.controllerIdLast = controller==null?null:controller.getId(); lastPo.rtuAddrLast = rtuAddr; lastPo.dt = DateTime.dateFrom_yyyy_MM_dd1(dV1_0_1.dt);//日期变了 lastPo.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt); lastPo.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); Double difference = cdData.totalAmount - lastPo.totalAmountLast ; if(difference > 0){ lastPo.amount = difference; }else{ lastPo.amount = 0.0D; //日累计水量归0 } lastPo.totalAmountLast = cdData.totalAmount ; return lastPo ; } /** * 更新历史记录 * @param controller * @param rtuAddr * @param dV1_0_1 * @param cdData * @return * @throws Exception */ private RmIntakeAmountDay updateRmIntakeAmountBySameDateNewData(RmIntakeAmountDay po, RmIntakeAmountDayLast lastPo, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, UpDataVo cdData)throws Exception { po.intakeId = controller==null?null:controller.getIntakeId(); po.controllerIdLast = controller==null?null:controller.getId(); po.rtuAddrLast = rtuAddr; po.dt = lastPo.dt ; po.dtLast = lastPo.dtLast; po.rtuDtLast = lastPo.rtuDtLast; po.amount = lastPo.amount ; po.totalAmountLast = lastPo.totalAmountLast ; return po ; } public class UpDataVo{ public Double totalAmount; //累计流量：5字节BCD码，取值范围0~9999999999，单位为m3。 public String rtuDt ;//控制器时钟 public void valueFrom(DataCdC0Vo voC0, DataCd84Vo vo84, DataCd83OpenVo vo83Op, DataCd83CloseVo vo83Cl){ if(voC0 != null){ this.totalAmount = voC0.totalAmount ; this.rtuDt = voC0.rtuDt ; }else if(vo84 != null){ this.totalAmount = vo84.totalAmount ; this.rtuDt = vo84.rtuDt ; }else if(vo83Op != null){ this.totalAmount = vo83Op.totalAmount ; this.rtuDt = vo83Op.rtuDt ; }else if(vo83Cl != null){ this.totalAmount = vo83Cl.totalAmount ; this.rtuDt = vo83Cl.rtuDt ; } } } }