| New file |
| | |
|---|
| | | package com.dy.rtuMw.server.rtuData.p206V1; |
|---|
| | | |
|---|
| | | import com.dy.common.mw.protocol.Data; |
|---|
| | | import com.dy.common.mw.protocol.p206V1.DataV1; |
|---|
| | | import com.dy.common.mw.protocol.p206V1.upVos.DataCd83CloseVo; |
|---|
| | | import com.dy.common.mw.protocol.p206V1.upVos.DataCd83OpenVo; |
|---|
| | | import com.dy.common.mw.protocol.p206V1.upVos.DataCd84Vo; |
|---|
| | | import com.dy.common.mw.protocol.p206V1.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(TkDealIntakeAmountDay.class.getName()); |
|---|
| | | |
|---|
| | | //类ID，一定与Tree.xml配置文件中配置一致 |
|---|
| | | public static final String taskId = "TkDealIntakeAmountDay"; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 执行节点任务: 取水口日用水量和漏损量 |
|---|
| | | * |
|---|
| | | * @param data 需要处理的数据 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public void execute(Object data) { |
|---|
| | | Data d = (Data) data; |
|---|
| | | DataV1 dV1 = (DataV1) d.getSubData();//前面任务已经判断不为null |
|---|
| | | Object cdObj = dV1.subData; |
|---|
| | | /** |
|---|
| | | * 2025-01-11 |
|---|
| | | * 原来实现本任务功能，数据从84，83，C0功能码数据中获得统计数据，但后来数据中增加了金额与开关阀次数， |
|---|
| | | * 从而使得从三种数据中统计数据相当困难与自相矛盾，所以修改实现方式，只从83数据中统计本数据，并且从几 |
|---|
| | | * 个月来运行数据看，只要设备能上线，基本上各种上报数据都能上报上来，所以没有必须从84及C0数据中统计数据了 |
|---|
| | | * 至此，本实现方式主永久实现方式，不再修改回去了，实践证明，以前的实现方式数据是统计不准确的。 |
|---|
| | | */ |
|---|
| | | 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, vo); |
|---|
| | | }catch (Exception e){ |
|---|
| | | log.error("保存取水口日用水量和漏损量数据时发生异常", e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 业务处理 |
|---|
| | | * @param sv 服务 |
|---|
| | | * @param controller 控制器对象 |
|---|
| | | * @param rtuAddr 控制器地址 |
|---|
| | | * @param dV1 上报数据 |
|---|
| | | * @param dataVo 上报数据对象 |
|---|
| | | */ |
|---|
| | | private void doDeal(DbSv sv, PrController controller, String rtuAddr, DataV1 dV1, UpDataVo dataVo) throws Exception { |
|---|
| | | RmIntakeAmountDayLast poLast = sv.getRmIntakeAmountLast(controller.getIntakeId()); |
|---|
| | | if (poLast == null) { |
|---|
| | | //数据库中不存在该取水口的日取水量数据 |
|---|
| | | //首先生成最新数据及历史数据，并先保存 |
|---|
| | | poLast = this.newRmIntakeAmountLast(controller, rtuAddr, dV1, dataVo); |
|---|
| | | this.newAndSaveRmIntakeAmountHistory(sv, controller, rtuAddr, dV1, 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)){ |
|---|
| | | //更换了控制器，处理方法：只更换控制器地址，不进行水量计算 |
|---|
| | | //因为上行数据中的日期时间是可进行计算的 |
|---|
| | | if(DateTime.dateFrom_yyyy_MM_dd1(dV1.dt).equals(poLast.dt)){ |
|---|
| | | //同一天数据 |
|---|
| | | poLast = this.updateRmIntakeAmountLastBySameDateByControllerChange(poLast, controller, rtuAddr, dV1, dataVo); |
|---|
| | | RmIntakeAmountDay poHistory = null ; |
|---|
| | | if(poLast.lastHistoryId != null){ |
|---|
| | | poHistory = sv.getRmIntakeAmountDay(poLast.lastHistoryId) ; |
|---|
| | | } |
|---|
| | | if(poHistory == null){ |
|---|
| | | this.newAndSaveRmIntakeAmountHistory(sv, controller, rtuAddr, dV1, dataVo, poLast); |
|---|
| | | }else{ |
|---|
| | | poHistory = this.updateRmIntakeAmountBySameDateByControllerChange(poHistory, poLast, controller, rtuAddr, dV1, dataVo); |
|---|
| | | sv.updateRmIntakeAmountDay(poHistory); |
|---|
| | | } |
|---|
| | | }else{ |
|---|
| | | //非同一天，所以新生成一个历史记录 |
|---|
| | | poLast = this.updateRmIntakeAmountLastByNewDateByControllerChange(poLast, controller, rtuAddr, dV1, dataVo); |
|---|
| | | this.newAndSaveRmIntakeAmountHistory(sv, controller, rtuAddr, dV1, dataVo, poLast); |
|---|
| | | } |
|---|
| | | }else{ |
|---|
| | | //未更换控制器 |
|---|
| | | if(DateTime.dateFrom_yyyy_MM_dd1(dV1.dt).equals(poLast.dt)){ |
|---|
| | | //同一天数据 |
|---|
| | | poLast = this.updateRmIntakeAmountLastBySameDateNewData(poLast, controller, rtuAddr, dV1, dataVo); |
|---|
| | | RmIntakeAmountDay poHistory = null ; |
|---|
| | | if(poLast.lastHistoryId != null){ |
|---|
| | | poHistory = sv.getRmIntakeAmountDay(poLast.lastHistoryId) ; |
|---|
| | | } |
|---|
| | | if(poHistory == null){ |
|---|
| | | this.newAndSaveRmIntakeAmountHistory(sv, controller, rtuAddr, dV1, dataVo, poLast); |
|---|
| | | }else{ |
|---|
| | | poHistory = this.updateRmIntakeAmountBySameDateNewData(poHistory, poLast, controller, rtuAddr, dV1, dataVo); |
|---|
| | | sv.updateRmIntakeAmountDay(poHistory); |
|---|
| | | } |
|---|
| | | }else if(DateTime.dateFrom_yyyy_MM_dd1(dV1.dt).after(poLast.dt)){ |
|---|
| | | //新的日期 |
|---|
| | | poLast = this.updateRmIntakeAmountLastByNewDateNewData(poLast, controller, rtuAddr, dV1, dataVo); |
|---|
| | | this.newAndSaveRmIntakeAmountHistory(sv, controller, rtuAddr, dV1, dataVo, poLast); |
|---|
| | | }else{ |
|---|
| | | //这种情况不存在 |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //更新最新数据 |
|---|
| | | sv.updateRmIntakeAmountLast(poLast); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 生成新的取水口用水统计最新记录 |
|---|
| | | * @param controller |
|---|
| | | * @param rtuAddr |
|---|
| | | * @param dV1 |
|---|
| | | * @param cdData |
|---|
| | | * @return |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | private RmIntakeAmountDayLast newRmIntakeAmountLast(PrController controller, String rtuAddr, DataV1 dV1, 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.dt); |
|---|
| | | po.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1.dt); |
|---|
| | | po.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); |
|---|
| | | |
|---|
| | | po.amount = cdData.amount ; |
|---|
| | | po.money = cdData.money ; |
|---|
| | | po.times = 1 ; |
|---|
| | | /* 2025-01-11 |
|---|
| | | if(cdData.isCloseValve != null && cdData.isCloseValve){ |
|---|
| | | po.amount = cdData.amount ; |
|---|
| | | po.money = cdData.money ; |
|---|
| | | po.times = 1 ; |
|---|
| | | }else{ |
|---|
| | | po.amount = 0.0D ; |
|---|
| | | po.money = 0.0D ; |
|---|
| | | po.times = 0 ; |
|---|
| | | }*/ |
|---|
| | | po.rtuAddrLast = rtuAddr; |
|---|
| | | return po ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 保存新的历史数据记录，并把ID赋值给最新记录的 lastHistoryId |
|---|
| | | * @param sv |
|---|
| | | * @param controller |
|---|
| | | * @param rtuAddr |
|---|
| | | * @param dV1 |
|---|
| | | * @param cdData |
|---|
| | | * @param poLast |
|---|
| | | * @throws Exception |
|---|
| | | * @return RmIntakeAmountDay |
|---|
| | | */ |
|---|
| | | private RmIntakeAmountDay newAndSaveRmIntakeAmountHistory(DbSv sv, PrController controller, String rtuAddr, DataV1 dV1, UpDataVo cdData, RmIntakeAmountDayLast poLast)throws Exception { |
|---|
| | | RmIntakeAmountDay poHistory = new RmIntakeAmountDay() ; |
|---|
| | | poHistory.intakeId = controller==null?null:controller.getIntakeId(); |
|---|
| | | poHistory.controllerIdLast = controller==null?null:controller.getId(); |
|---|
| | | poHistory.rtuAddrLast = rtuAddr; |
|---|
| | | poHistory.dt = DateTime.dateFrom_yyyy_MM_dd1(dV1.dt); |
|---|
| | | poHistory.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1.dt); |
|---|
| | | poHistory.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); |
|---|
| | | poHistory.totalAmountLast = cdData.totalAmount ; |
|---|
| | | |
|---|
| | | //2025-01-11 |
|---|
| | | if(poLast != null){ |
|---|
| | | poHistory.amount = poLast.amount ; |
|---|
| | | poHistory.money = poLast.money ; |
|---|
| | | poHistory.times = poLast.times ; |
|---|
| | | }else{ |
|---|
| | | poHistory.amount = 0.0D ; |
|---|
| | | poHistory.money = 0.0D ; |
|---|
| | | poHistory.times = 0 ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | sv.saveRmIntakeAmountDay(poHistory); |
|---|
| | | //由最新数据持有历史数据中的最新记录ID，以方便快速查询 |
|---|
| | | poLast.lastHistoryId = poHistory == null ? null: poHistory.id ; |
|---|
| | | return poHistory ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 取水口更换了控制器，同一天数据，此时只更新部分属性 |
|---|
| | | * @param controller |
|---|
| | | * @param rtuAddr |
|---|
| | | * @param dV1 |
|---|
| | | * @param cdData |
|---|
| | | * @return |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | private RmIntakeAmountDayLast updateRmIntakeAmountLastBySameDateByControllerChange(RmIntakeAmountDayLast lastPo, PrController controller, String rtuAddr, DataV1 dV1, 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.dt); |
|---|
| | | lastPo.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1.dt); |
|---|
| | | lastPo.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); |
|---|
| | | lastPo.totalAmountLast = cdData.totalAmount ; |
|---|
| | | //阀控器更换了，并且是同一天数据 |
|---|
| | | //只有关阀报数据（2025-01-11） |
|---|
| | | if(lastPo.amount == null){ |
|---|
| | | lastPo.amount = cdData.amount ; |
|---|
| | | }else{ |
|---|
| | | lastPo.amount += cdData.amount ; |
|---|
| | | } |
|---|
| | | if(lastPo.money == null){ |
|---|
| | | lastPo.money = cdData.money ; |
|---|
| | | }else{ |
|---|
| | | lastPo.money += cdData.money ; |
|---|
| | | } |
|---|
| | | if(lastPo.times == null){ |
|---|
| | | lastPo.times = 1 ; |
|---|
| | | }else{ |
|---|
| | | lastPo.times += 1 ; |
|---|
| | | } |
|---|
| | | /* |
|---|
| | | if(cdData.isCloseValve != null && cdData.isCloseValve.booleanValue()){ |
|---|
| | | //是从关阀报中得到的数据 |
|---|
| | | if(lastPo.amount == null){ |
|---|
| | | lastPo.amount = cdData.amount ; |
|---|
| | | }else{ |
|---|
| | | lastPo.amount += cdData.amount ; |
|---|
| | | } |
|---|
| | | if(lastPo.money == null){ |
|---|
| | | lastPo.money = cdData.money ; |
|---|
| | | }else{ |
|---|
| | | lastPo.money += cdData.money ; |
|---|
| | | } |
|---|
| | | if(lastPo.times == null){ |
|---|
| | | lastPo.times = 1 ; |
|---|
| | | }else{ |
|---|
| | | lastPo.times += 1 ; |
|---|
| | | } |
|---|
| | | }else{ |
|---|
| | | //非关阀报数据 |
|---|
| | | //不作为 |
|---|
| | | }*/ |
|---|
| | | return lastPo ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 取水口更换了控制器在，此时只更新部分属性 |
|---|
| | | * @param controller |
|---|
| | | * @param rtuAddr |
|---|
| | | * @param dV1 |
|---|
| | | * @param cdData |
|---|
| | | * @return |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | private RmIntakeAmountDay updateRmIntakeAmountBySameDateByControllerChange(RmIntakeAmountDay po, RmIntakeAmountDayLast lastPo, PrController controller, String rtuAddr, DataV1 dV1, 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.totalAmountLast = lastPo.totalAmountLast ; |
|---|
| | | |
|---|
| | | //阀控器更换了，并且是同一天数据 |
|---|
| | | //只有关阀报数据（2025-01-11） |
|---|
| | | po.amount = lastPo.amount ; |
|---|
| | | po.money = lastPo.money ; |
|---|
| | | po.times = lastPo.times ; |
|---|
| | | |
|---|
| | | return po ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 取水口更换了控制器，非同一天数据，此时更新部分属性 |
|---|
| | | * @param controller |
|---|
| | | * @param rtuAddr |
|---|
| | | * @param dV1 |
|---|
| | | * @param cdData |
|---|
| | | * @return |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | private RmIntakeAmountDayLast updateRmIntakeAmountLastByNewDateByControllerChange(RmIntakeAmountDayLast lastPo, PrController controller, String rtuAddr, DataV1 dV1, 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.dt); |
|---|
| | | lastPo.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1.dt); |
|---|
| | | lastPo.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); |
|---|
| | | lastPo.totalAmountLast = cdData.totalAmount ; |
|---|
| | | |
|---|
| | | //阀控器更换了，并且是新一天数据 2025-01-11 |
|---|
| | | lastPo.amount = cdData.amount ; |
|---|
| | | lastPo.money = cdData.money ; |
|---|
| | | lastPo.times = 1 ; |
|---|
| | | |
|---|
| | | return lastPo ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 收到同一天的新的数据，进行更新数据 |
|---|
| | | * @param controller |
|---|
| | | * @param rtuAddr |
|---|
| | | * @param dV1 |
|---|
| | | * @param cdData |
|---|
| | | * @return |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | private RmIntakeAmountDayLast updateRmIntakeAmountLastBySameDateNewData(RmIntakeAmountDayLast lastPo, PrController controller, String rtuAddr, DataV1 dV1, 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.dt);//日期没变 |
|---|
| | | lastPo.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1.dt); |
|---|
| | | lastPo.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); |
|---|
| | | if(cdData.totalAmount == 0.0F){ |
|---|
| | | //发现阀控器一个bug，经常上报累计流量为0，推测是阀控器未能从水表采集到数据时会上报0值 |
|---|
| | | //这种情况数据不做处理 |
|---|
| | | //如果水表初安装，未进行过任务取水，那么累计流量会是0，这种情况当bug处理也无防 |
|---|
| | | //上面时标作了更新，也正常，相当于本次上报的累计流量与上次上报的累计流量数值相等 |
|---|
| | | //lastPo.totalAmountLast = lastPo.totalAmountLast ; |
|---|
| | | //lastPo.amount = lastPo.amount; //本日的日累计水量保持不变 |
|---|
| | | }else { |
|---|
| | | lastPo.totalAmountLast = cdData.totalAmount; |
|---|
| | | } |
|---|
| | | //是同一天数据 |
|---|
| | | //只有关阀报数据（2025-01-11） |
|---|
| | | if(lastPo.amount == null){ |
|---|
| | | lastPo.amount = cdData.amount ; |
|---|
| | | }else{ |
|---|
| | | lastPo.amount += cdData.amount ; |
|---|
| | | } |
|---|
| | | if(lastPo.money == null){ |
|---|
| | | lastPo.money = cdData.money ; |
|---|
| | | }else{ |
|---|
| | | lastPo.money += cdData.money ; |
|---|
| | | } |
|---|
| | | if(lastPo.times == null){ |
|---|
| | | lastPo.times = 1 ; |
|---|
| | | }else{ |
|---|
| | | lastPo.times += 1 ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /* 2025-01-11 |
|---|
| | | Double added = cdData.totalAmount - lastPo.totalAmountLast ; |
|---|
| | | if(added > 0){ |
|---|
| | | if(lastPo.amount == null){ |
|---|
| | | lastPo.amount = added ; |
|---|
| | | }else{ |
|---|
| | | lastPo.amount += added ; |
|---|
| | | } |
|---|
| | | }else{ |
|---|
| | | //可能是更换水表了，新表底值比原表底值小。 |
|---|
| | | //本次置量值不变，下次再上报时，就能正常计算了。 |
|---|
| | | //lastPo.amount = lastPo.amount ; //日累计取水量不变 |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(cdData.isCloseValve != null && cdData.isCloseValve.booleanValue()){ |
|---|
| | | //是从关阀报中得到的数据 |
|---|
| | | if(lastPo.money == null){ |
|---|
| | | lastPo.money = cdData.money ; |
|---|
| | | }else{ |
|---|
| | | lastPo.money += cdData.money ; |
|---|
| | | } |
|---|
| | | if(lastPo.times == null){ |
|---|
| | | lastPo.times = 1 ; |
|---|
| | | }else{ |
|---|
| | | lastPo.times += 1 ; |
|---|
| | | } |
|---|
| | | }else{ |
|---|
| | | //非关阀报数据 |
|---|
| | | //不作为 |
|---|
| | | } |
|---|
| | | */ |
|---|
| | | |
|---|
| | | return lastPo ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 因收到新的一天的新的数据后，进行更新数据 |
|---|
| | | * @param controller |
|---|
| | | * @param rtuAddr |
|---|
| | | * @param dV1 |
|---|
| | | * @param cdData |
|---|
| | | * @return |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | private RmIntakeAmountDayLast updateRmIntakeAmountLastByNewDateNewData(RmIntakeAmountDayLast lastPo, PrController controller, String rtuAddr, DataV1 dV1, 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.dt);//日期变了 |
|---|
| | | lastPo.dtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1.dt); |
|---|
| | | lastPo.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); |
|---|
| | | lastPo.totalAmountLast = cdData.totalAmount ; |
|---|
| | | |
|---|
| | | //新的一天数据 2025-01-11 |
|---|
| | | lastPo.amount = cdData.amount ; |
|---|
| | | lastPo.money = cdData.money ; |
|---|
| | | lastPo.times = 1 ; |
|---|
| | | |
|---|
| | | /* |
|---|
| | | if(cdData.totalAmount == 0.0F){ |
|---|
| | | //发现阀控器一个bug，经常上报累计流量为0，推测是阀控器未能从水表采集到数据时会上报0值 |
|---|
| | | //这种情况数据不做处理 |
|---|
| | | //如果水表初安装，未进行过任务取水，那么累计流量会是0，这种情况当bug处理也无防 |
|---|
| | | //上面时标作了更新，也正常，相当于本次上报的累计流量与上次上报的累计流量数值相等 |
|---|
| | | //lastPo.totalAmountLast = lastPo.totalAmountLast ; |
|---|
| | | lastPo.amount = 0.0D; //新的一天的日累计水量置0 |
|---|
| | | }else{ |
|---|
| | | Double added = cdData.totalAmount - lastPo.totalAmountLast ; |
|---|
| | | if(added > 0){ |
|---|
| | | //新的一天的处理方式与同一天的处理方式不一样 |
|---|
| | | lastPo.amount = added; |
|---|
| | | }else{ |
|---|
| | | //可能是更换水表了，新表底值比原表底值小。 |
|---|
| | | //本次置0，下次再上报时，就能正常计算了。 |
|---|
| | | lastPo.amount = 0.0D; //日累计水量归0 |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if(cdData.isCloseValve != null && cdData.isCloseValve.booleanValue()){ |
|---|
| | | //是从关阀报中得到的数据 |
|---|
| | | lastPo.money = cdData.money ; |
|---|
| | | lastPo.times = 1 ; |
|---|
| | | }else{ |
|---|
| | | //非关阀报数据 |
|---|
| | | //不作为 |
|---|
| | | } |
|---|
| | | */ |
|---|
| | | |
|---|
| | | return lastPo ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 更新历史记录 |
|---|
| | | * @param controller |
|---|
| | | * @param rtuAddr |
|---|
| | | * @param dV1 |
|---|
| | | * @param cdData |
|---|
| | | * @return |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | private RmIntakeAmountDay updateRmIntakeAmountBySameDateNewData(RmIntakeAmountDay po, RmIntakeAmountDayLast lastPo, PrController controller, String rtuAddr, DataV1 dV1, 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.totalAmountLast = lastPo.totalAmountLast ; |
|---|
| | | |
|---|
| | | po.amount = lastPo.amount ;//此时lastPo.amount已经增加上了增量 |
|---|
| | | po.money = lastPo.money ;//此时lastPo.money已经增加上了增量 |
|---|
| | | po.times = lastPo.times ;//此时lastPo.times已经增加上了增量 |
|---|
| | | |
|---|
| | | return po ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | public class UpDataVo{ |
|---|
| | | public Double totalAmount; //累计流量：5字节BCD码，取值范围0~9999999999，单位为m3。 |
|---|
| | | public Double amount; //农户用水量 |
|---|
| | | public Double money ;//农户消费金额 |
|---|
| | | public Boolean isCloseValve ;//是否是关阀上报 |
|---|
| | | 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.amount = vo83Cl.thisAmount ; |
|---|
| | | this.money = vo83Cl.thisMoney ; |
|---|
| | | this.isCloseValve = true ; |
|---|
| | | this.rtuDt = vo83Cl.rtuDt ; |
|---|
| | | /*} */ |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
