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
@@ -221,13 +233,13 @@
        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.amount = lastPo.amount ; //日累计取水量不变
        //lastPo.amount = lastPo.amount ; //日累计取水量保持不变,
        lastPo.totalAmountLast = cdData.totalAmount ;
        return lastPo ;
    }
    /**
     * 更新最新记录
     * 收到同一天的新的数据,进行更新数据
     * @param controller
     * @param rtuAddr
     * @param dV1
@@ -242,22 +254,50 @@
        //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);
        Double added = cdData.totalAmount - lastPo.totalAmountLast ;
        if(added > 0){
            if(lastPo.amount == null){
                lastPo.amount = added ;
            }else{
                lastPo.amount += added ;
            }
        if(cdData.totalAmount == 0.0F){
            //发现阀控器一个bug,经常上报累计流量为0,推测是阀控器未能从水表采集到数据时会上报0值
            //这种情况数据不做处理
            //如果水表初安装,未进行过任务取水,那么累计流量会是0,这种情况当bug处理也无防
            //上面时标作了更新,也正常,相当于本次上报的累计流量与上次上报的累计流量数值相等
            //lastPo.totalAmountLast = lastPo.totalAmountLast ;
            //lastPo.amount = lastPo.amount; //本日的日累计水量保持不变
        }else{
            //po.amount = po.amount ; //日累计取水量不变
            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{
                lastPo.money = 0.0D ;
                lastPo.times = 1 ;
            }
            lastPo.totalAmountLast = cdData.totalAmount ;
        }
        lastPo.totalAmountLast = cdData.totalAmount ;
        return lastPo ;
    }
    /**
     * 更新最新记录
     * 因收到新的一天的新的数据后,进行更新数据
     * @param controller
     * @param rtuAddr
     * @param dV1
@@ -272,19 +312,40 @@
        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);
        Double added = cdData.totalAmount - lastPo.totalAmountLast ;
        if(added > 0){
            //新的一天的处理方式与同一天的处理方式不一样
            lastPo.amount = added;
        if(cdData.totalAmount == 0.0F){
            //发现阀控器一个bug,经常上报累计流量为0,推测是阀控器未能从水表采集到数据时会上报0值
            //这种情况数据不做处理
            //如果水表初安装,未进行过任务取水,那么累计流量会是0,这种情况当bug处理也无防
            //上面时标作了更新,也正常,相当于本次上报的累计流量与上次上报的累计流量数值相等
            //lastPo.totalAmountLast = lastPo.totalAmountLast ;
            lastPo.amount = 0.0D; //新的一天的日累计水量置0
        }else{
            lastPo.amount = 0.0D; //日累计水量归0
            Double added = cdData.totalAmount - lastPo.totalAmountLast ;
            if(added > 0){
                //新的一天的处理方式与同一天的处理方式不一样
                lastPo.amount = added;
            }else{
                //可能是更换水表了,新表底值比原表底值小。
                //本次置0,下次再上报时,就能正常计算了。
                lastPo.amount = 0.0D; //日累计水量归0
            }
            lastPo.totalAmountLast = cdData.totalAmount ;
        }
        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
@@ -301,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 ;
@@ -324,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 ;
@@ -332,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){
@@ -346,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 ;
            }
        }