liurunyu
2025-01-09 ee243ee6a7cd9715fa84442e27b17816750033b5
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1/TkDealIntakeAmountDay.java
@@ -137,7 +137,7 @@
    }
    /**
     * 生成新的控制器漏损日统计最新记录
     * 生成新的取水口用水统计最新记录
     * @param controller
     * @param rtuAddr
     * @param dV1
@@ -153,13 +153,21 @@
        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
@@ -177,8 +185,12 @@
        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 ;
@@ -206,7 +218,7 @@
    /**
     * 生成新的控制器漏损日统计最新记录
     * 取水口更换了控制器,此时只更新部分属性
     * @param controller
     * @param rtuAddr
     * @param dV1
@@ -227,7 +239,7 @@
    }
    /**
     * 更新最新记录
     * 收到同一天的新的数据,进行更新数据
     * @param controller
     * @param rtuAddr
     * @param dV1
@@ -262,6 +274,22 @@
                //本次置量值不变,下次再上报时,就能正常计算了。
                //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 ;
        }
@@ -269,7 +297,7 @@
    }
    /**
     * 更新最新记录
     * 因收到新的一天的新的数据后,进行更新数据
     * @param controller
     * @param rtuAddr
     * @param dV1
@@ -304,12 +332,20 @@
            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
@@ -326,6 +362,8 @@
        po.rtuDtLast = lastPo.rtuDtLast;
        po.amount = lastPo.amount ;
        po.money = lastPo.money ;
        po.times = lastPo.times ;
        po.totalAmountLast = lastPo.totalAmountLast ;
        return po ;
@@ -349,6 +387,8 @@
        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 ;
@@ -357,6 +397,9 @@
    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){
@@ -371,6 +414,9 @@
                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 ;
            }
        }