| | |
| | | } |
| | | |
| | | /** |
| | | * 生成新的控制器漏损日统计最新记录 |
| | | * 生成新的取水口用水统计最新记录 |
| | | * @param controller |
| | | * @param rtuAddr |
| | | * @param dV1 |
| | |
| | | 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 = 0.0D ; |
| | | 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 ; |
| | | } |
| | | |
| | | /** |
| | | * 生成新的控制器漏损日统计历史记录 |
| | | * 生成新的取水口用水统计历史记录 |
| | | * @param controller |
| | | * @param rtuAddr |
| | | * @param dV1 |
| | |
| | | po.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt); |
| | | if(lastPo != null){ |
| | | po.amount = lastPo.amount ; |
| | | po.money = lastPo.money ; |
| | | po.times = lastPo.times ; |
| | | }else{ |
| | | po.amount = 0.0D ; |
| | | po.money = 0.0D ; |
| | | po.times = 0 ; |
| | | } |
| | | po.totalAmountLast = cdData.totalAmount ; |
| | | return po ; |
| | |
| | | |
| | | |
| | | /** |
| | | * 生成新的控制器漏损日统计最新记录 |
| | | * 取水口更换了控制器,此时只更新部分属性 |
| | | * @param controller |
| | | * @param rtuAddr |
| | | * @param dV1 |
| | |
| | | } |
| | | |
| | | /** |
| | | * 更新最新记录 |
| | | * 收到同一天的新的数据,进行更新数据 |
| | | * @param controller |
| | | * @param rtuAddr |
| | | * @param dV1 |
| | |
| | | //本次置量值不变,下次再上报时,就能正常计算了。 |
| | | //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{ |
| | | lastPo.money = 0.0D ; |
| | | lastPo.times = 1 ; |
| | | } |
| | | lastPo.totalAmountLast = cdData.totalAmount ; |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | /** |
| | | * 更新最新记录 |
| | | * 因收到新的一天的新的数据后,进行更新数据 |
| | | * @param controller |
| | | * @param rtuAddr |
| | | * @param dV1 |
| | |
| | | lastPo.totalAmountLast = cdData.totalAmount ; |
| | | } |
| | | |
| | | if(cdData.isCloseValve != null && cdData.isCloseValve.booleanValue()){ |
| | | //是从关阀报中得到的数据 |
| | | lastPo.money = cdData.money ; |
| | | lastPo.times = 1 ; |
| | | }else{ |
| | | lastPo.money = 0.0D ; |
| | | lastPo.times = 0 ; |
| | | } |
| | | |
| | | return lastPo ; |
| | | } |
| | | |
| | | /** |
| | | * 生成新的控制器漏损日统计最新记录 |
| | | * 取水口更换了控制器在,此时只更新部分属性 |
| | | * @param controller |
| | | * @param rtuAddr |
| | | * @param dV1 |
| | |
| | | po.rtuDtLast = lastPo.rtuDtLast; |
| | | |
| | | po.amount = lastPo.amount ; |
| | | po.money = lastPo.money ; |
| | | po.times = lastPo.times ; |
| | | po.totalAmountLast = lastPo.totalAmountLast ; |
| | | |
| | | return po ; |
| | |
| | | po.rtuDtLast = lastPo.rtuDtLast; |
| | | |
| | | po.amount = lastPo.amount ;//此时lastPo.amount已经增加上了增量 |
| | | po.money = lastPo.money ;//此时lastPo.money已经增加上了增量 |
| | | po.times = lastPo.times ;//此时lastPo.times已经增加上了增量 |
| | | po.totalAmountLast = lastPo.totalAmountLast ; |
| | | |
| | | 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){ |
| | |
| | | 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 ; |
| | | } |
| | | } |