package com.dy.aceMw.server.rtuData.p206V1_0_0; import com.dy.aceMw.server.rtuData.TaskSurpport; import com.dy.aceMw.server.rtuData.dbSv.DbSv; import com.dy.common.mw.protocol.Data; import com.dy.common.mw.protocol.p206V1_0_0.DataCd83OpenVo; import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1; import com.dy.common.util.DateTime; import com.dy.pipIrrGlobal.pojoPr.PrController; import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory; import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; /** * @Author liurunyu * @Date 2024/1/16 17:16 * @LastEditTime 2024/1/16 17:16 * @Description * 处理控制器开阀上报 */ public class TkDealOpenValveReport extends TaskSurpport { private static final Logger log = LogManager.getLogger(TkDealOpenValveReport.class.getName()) ; //类ID，一定与Tree.xml配置文件中配置一致 public static final String taskId = "TkDealOpenValveReport" ; /** * 执行节点任务: 处理控制器开阀上报 * @param data 需要处理的数据 */ @Override public void execute(Object data) { Data d = (Data) data; Object subD = d.getSubData(); if (subD != null) { DataV1_0_1 dV1_0_1 = (DataV1_0_1) subD; if (dV1_0_1 != null && dV1_0_1.dataCd83OpenVo != null) { Object[] objs = this.getTaskResults(TkPreGenObjs.taskId) ; DbSv sv = (DbSv)objs[0] ; PrController controller = (PrController)objs[1] ; try{ this.dealSave(sv, controller, d.getRtuAddr(), dV1_0_1, dV1_0_1.dataCd83OpenVo) ; }catch (Exception e){ log.error("保存控制器开阀上报时发生异常", e); } } } } /** * 保存数据 * @param sv 服务 * @param controller 控制器对象 * @param rtuAddr 控制器地址 * @param dV1_0_1 上报数据 * @param dataCd83OpenVo 开阀上报数据对象 */ private void dealSave(DbSv sv, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, DataCd83OpenVo dataCd83OpenVo) throws Exception { RmOpenCloseValveLast poLast = sv.getRmOpenCloseValveLast(rtuAddr) ; if(poLast == null){ //首先生成历史数据，并保存 poLast = this.newRmOpenCloseValveLast(controller, rtuAddr, dV1_0_1, dataCd83OpenVo); this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast); sv.saveRmOpenCloseValveLast(poLast); }else{ if(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt).equals(poLast.openDt)){ //时间一致，重复上报数据，不进行任何处理 }else{ if(poLast.opType != null){ //原记录存在开阀数据，首先进行时间对比 if(poLast.openDt != null && poLast.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ //补报的许久之前的开阀数据，不进行处理 }else if(poLast.openDt != null && poLast.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ //重复上报的开阀数据，不进行处理 }else{ //当前开阀上报是新的一次开阀，不管原记录是否存在关阀数据，一律清空关阀数据 this.updateOpenValve(poLast, null, dV1_0_1, dataCd83OpenVo, true) ; //生成并保存新的开阀上报历史数据记录 this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast); } }else if(poLast.clType != null){ //原记录不存在开阀数据，但存在关阀数据，首先进行时间比对 if(poLast.closeDt != null && poLast.closeDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ //当前上报是补报的开阀数据 RmOpenCloseValveHistory poHistory = null ; if(poLast.lastHistoryId != null){ poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId) ; } this.updateOpenValve(poLast, poHistory, dV1_0_1, dataCd83OpenVo, false) ; if(poHistory != null){ sv.updateRmOpenCloseValveHistory(poHistory); } }else if(poLast.closeDt != null && poLast.closeDt.before(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ //当前上报是新的开阀数据 this.updateOpenValve(poLast, null, dV1_0_1, dataCd83OpenVo, true) ; //生成并保存新的开阀上报历史数据记录 this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast); }else { //当前上报的开阀数据与原来的关阀数据同一时间，这种情况应该不存在，但也处理 RmOpenCloseValveHistory poHistory = null ; if(poLast.lastHistoryId != null){ poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId) ; } this.updateOpenValve(poLast, poHistory, dV1_0_1, dataCd83OpenVo, false) ; if(poHistory != null){ sv.updateRmOpenCloseValveHistory(poHistory); } } }else{ //if(po.clType == null) //原记录不存在开阀数据也不存在关阀数据，这种情况不存在，但为安全也进行处理 this.updateOpenValve(poLast, null, dV1_0_1, dataCd83OpenVo, true) ; //生成并保存新的开阀上报历史数据记录 this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast); } sv.updateRmOpenCloseValveLast(poLast); } } } /** * 保存新的开阀上报历史数据记录，并把ID赋值给最新记录的 lastHistoryId * @param sv * @param controller * @param rtuAddr * @param dV1_0_1 * @param dataCd83OpenVo * @param poLast * @throws Exception */ private void newHistoryDataDeal(DbSv sv, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, DataCd83OpenVo dataCd83OpenVo, RmOpenCloseValveLast poLast)throws Exception { RmOpenCloseValveHistory poHistory = this.newRmOpenCloseValveHistory(controller, rtuAddr, dV1_0_1, dataCd83OpenVo) ; sv.saveRmOpenCloseValveHistory(poHistory); //由最新数据持有历史数据中的最新记录ID，以方便快速查询 poLast.lastHistoryId = poHistory == null ? null: poHistory.id ; } /** * 生成新的开阀上报最新数据记录 * @param controller * @param rtuAddr * @param dV1_0_1 * @param dataCd83OpenVo * @return * @throws Exception */ private RmOpenCloseValveLast newRmOpenCloseValveLast(PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, DataCd83OpenVo dataCd83OpenVo)throws Exception { RmOpenCloseValveLast po = new RmOpenCloseValveLast(null, null, controller==null?null:controller.getId(), controller==null?null:controller.getIntakeId(), rtuAddr, DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt), dataCd83OpenVo.type, dataCd83OpenVo.totalAmount, dataCd83OpenVo.icCardNo, dataCd83OpenVo.icCardAddr, dataCd83OpenVo.remainMoney, DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt), null, null, null, null, null, null, null, null, null, null, null) ; return po ; } /** * 生成新的开阀上报历史数据记录 * @param controller * @param rtuAddr * @param dV1_0_1 * @param dataCd83OpenVo * @return * @throws Exception */ private RmOpenCloseValveHistory newRmOpenCloseValveHistory(PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, DataCd83OpenVo dataCd83OpenVo)throws Exception { RmOpenCloseValveHistory po = new RmOpenCloseValveHistory(null, controller==null?null:controller.getId(), controller==null?null:controller.getIntakeId(), rtuAddr, DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt), dataCd83OpenVo.type, dataCd83OpenVo.totalAmount, dataCd83OpenVo.icCardNo, dataCd83OpenVo.icCardAddr, dataCd83OpenVo.remainMoney, DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt), null, null, null, null, null, null, null, null, null, null, null) ; return po ; } /** * 更新数据 * @param poLast * @param poHistory * @param dV1_0_1 * @param dataCd83OpenVo * @param clearCloseValve * @throws Exception */ private void updateOpenValve(RmOpenCloseValveLast poLast, RmOpenCloseValveHistory poHistory, DataV1_0_1 dV1_0_1, DataCd83OpenVo dataCd83OpenVo, boolean clearCloseValve) throws Exception { poLast.opDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt); poLast.opType = dataCd83OpenVo.type ; poLast.opTotalAmount = dataCd83OpenVo.totalAmount ; poLast.opIcCardNo = dataCd83OpenVo.icCardNo ; poLast.opIcCardAddr = dataCd83OpenVo.icCardAddr ; poLast.opRemainMoney = dataCd83OpenVo.remainMoney ; poLast.openDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt) ; if(poHistory != null){ poHistory.opDt = poLast.opDt; poHistory.opType = dataCd83OpenVo.type ; poHistory.opTotalAmount = dataCd83OpenVo.totalAmount ; poHistory.opIcCardNo = dataCd83OpenVo.icCardNo ; poHistory.opIcCardAddr = dataCd83OpenVo.icCardAddr ; poHistory.opRemainMoney = dataCd83OpenVo.remainMoney ; poHistory.openDt = poLast.openDt ; } if(clearCloseValve){ poLast.clDt = null ; poLast.clType = null ; poLast.clTotalAmount = null ; poLast.clIcCardNo = null ; poLast.clIcCardAddr = null ; poLast.clRemainMoney = null ; poLast.clThisAmount = null ; poLast.clThisMoney = null ; poLast.clThisTime = null ; poLast.clOpenDt = null ; poLast.closeDt = null ; if(poHistory != null) { poHistory.clDt = null; poHistory.clType = null; poHistory.clTotalAmount = null; poHistory.clIcCardNo = null; poHistory.clIcCardAddr = null; poHistory.clRemainMoney = null; poHistory.clThisAmount = null; poHistory.clThisMoney = null; poHistory.clThisTime = null; poHistory.clOpenDt = null; poHistory.closeDt = null; } } } }