先上行关闭报,后上行开阀报,此种情况,历史数据赋值补充几个遗失的属性值
2个文件已修改
9 ■■■■■ 已修改文件
pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveHistory.java 3 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V202404/TkDealOpenValveReportV202404.java 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/pojoRm/RmOpenCloseValveHistory.java
@@ -458,6 +458,9 @@
        this.opIcCardNo = dataCd84Vo.icCardNo;
        this.opIcCardAddr = dataCd84Vo.icCardAddr;
        this.opRemainMoney = dataCd84Vo.moneyRemainUser;
        this.opOrderNo = dataCd84Vo.orderNo; //江海协议特有
        this.opEleTotalAmount = dataCd84Vo.eleTotalAmount; //江海协议特有
        this.opWaterRemainUser = dataCd84Vo.waterRemainUser; //江海协议特有
        this.openDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt);
        if (clearCloseValve != null && clearCloseValve.booleanValue()) {
            this.clDt = null;
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V202404/TkDealOpenValveReportV202404.java
@@ -103,7 +103,7 @@
                }
            }
            if(poLast.opType != null){
                //原记录存在开阀数据,首先进行时间对比
                //原记录存在开阀数据,首先进行订单号对比
                if(poLast.opOrderNo != null && poLast.opOrderNo.equals(dataCd84Vo.orderNo)){
                    //重复上报的开阀数据,不进行处理
                }else if(poLast.openDt != null && poLast.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){
@@ -116,7 +116,7 @@
                    this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dataV202404, dataCd84Vo, poLast);
                }
            }else if(poLast.clType != null){
                //原记录不存在开阀数据,但存在关阀数据,首先进行时间比对
                //原记录不存在开阀数据,但存在关阀数据,首先进行订单号比对
                if(poLast.clOrderNo != null && poLast.clOrderNo.equals(dataCd84Vo.orderNo)){
                    //当前上报的开阀数据与原来的关阀数据匹配
                    RmOpenCloseValveHistory poHistory = null ;
@@ -253,7 +253,7 @@
            poHistory.controllerId = controller==null?null:controller.getId();
            poHistory.intakeId = controller==null?null:controller.getIntakeId();
            poHistory.rtuAddr = rtuAddr;
            poHistory.updateFrom(dataV202404, dataCd84Vo, false);
            poHistory.updateFrom(dataV202404, dataCd84Vo, clearLastCloseValve);
        }
    }
}