1、实现参数设置模块pipIrr-param-set; 2、相关模块配置文件适应性调整。

liurunyu

2025-05-29 fcc1cf275578bd3aa08ef50c6a611fb206b7aac9

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1/TkDealClientAmountDay.java

@@ -40,8 +40,8 @@
        if (cdObj != null && cdObj instanceof DataCd83CloseVo) {
            /*
            只能采用DataCd83CloseVo来计算农户日用水量的原因：
            1、如果采用DataCd84Vo来计算农户日用水量，必须采用本次累计流量减上次累流量的差值作为阶段农户用水量，
               然后各个阶段相加，得到本次农户用水量，这个用水量还没加到农户日用水量中，因为只有收不到DataCd83CloseVo
            1、如果采用DataCd84Vo(开阀工作报)来计算农户日用水量，必须采用本次累计流量减上次累流量的差值作为阶段农户用水量，
               然后各个阶段相加，得到本次农户用水量，这个用水量还没加到农户日用水量中，因为只有收不到DataCd83CloseVo(关阀报)
               上报数据时才能加到农户用水量中，否则就会重复计算，但什么时候及能否收到DataCd83CloseVo不可预知。
            2、如果农户有多张IC卡，同时在多个取水口取水，将会是更复杂的计算，许多情形更不可预测，且时间复杂度
               必然很高，这样程序运行时间更长，将会造成上行数据堵塞现象。
@@ -51,7 +51,7 @@
             补报DataCd83CloseVo处理方法：
             采用DataCd83CloseVo数据中的关阀时间closeDt计算出农户用水日期，不能用数据接收日期时间作为农户用水日期，
             但这种计算方法可能会有重复上报情况发生，即重复计算了，如果要判断重复，必然要增加一个关阀时间数据库表，增加时间
             复杂度，计算用时将会长，本系统假设只要RTU上报上来数据了，说明当前网络较好，必然能收到下行应答，不会发行重复补报。
             复杂度，计算用时将会长，本系统假设只要RTU上报上来数据了，说明当前网络较好，必然能收到下行应答，不会发生重复补报。
             */
            Object[] objs = this.getTaskResults(TkPreGenObjs.taskId);
            DbSv sv = (DbSv) objs[0];
@@ -173,6 +173,7 @@
            }else{
                poHistory.money = lastPo.money ;
            }
            poHistory.times = 1 ;
            poHistory.dt = lastPo.dt ;
            poHistory.openDtLast = lastPo.openDtLast ;
            poHistory.closeDtLast = lastPo.closeDtLast ;
@@ -183,6 +184,7 @@
        }else{
            poHistory.amount = cdData.thisAmount ;
            poHistory.money = cdData.thisMoney ;
            poHistory.times = 1 ;
            poHistory.dt = DateTime.dateFrom_yyyy_MM_dd1(cdData.closeDt);//采用关阀日期作为统计日期
            poHistory.openDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.openDt);
            poHistory.closeDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.closeDt);
@@ -289,6 +291,11 @@
        }else{
            poHistory.money = cdData.thisMoney ;
        }
        if(poHistory.times != null){
            poHistory.times += 1 ;
        }else{
            poHistory.times = 1 ;
        }
        poHistory.dt = lastPo.dt ;
        poHistory.openDtLast = lastPo.openDtLast ;
        poHistory.closeDtLast = lastPo.closeDtLast ;
@@ -320,6 +327,11 @@
        }else{
            poHistory.money = cdData.thisMoney ;
        }
        if(poHistory.times != null){
            poHistory.times += 1 ;
        }else{
            poHistory.times = 1 ;
        }
        poHistory.dt = DateTime.dateFrom_yyyy_MM_dd1(cdData.closeDt);//采用关阀日期作为统计日期
        poHistory.openDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.openDt) ;
        poHistory.closeDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.closeDt) ;
@@ -329,8 +341,4 @@
        poHistory.rtuDtLast = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(cdData.rtuDt) ;
        return poHistory ;
    }




}