1、根据江海调整，功能码92、A2的应答中的日期时间去除； 2、表阀一体机的开关阀上行数据（84、85）处理逻辑进行修改。

liurunyu

2 天以前 b218f31bb202cffa656fa4ee09bdd8d67f8ed0ef

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

@@ -70,6 +70,7 @@
            msObj.put("icCardNo", dataCd83OpenVo.icCardNo);
            msObj.put("rtuAddr", rtuAddr);
            msObj.put("intakeId", controller.getIntakeId());
            msObj.put("dt", dV1.dt);
            MsCenterUnit.getInstance().pushMs(msObj);
        }
    }
@@ -95,33 +96,33 @@
            //数据库中存在该控制器的开关阀数据
            if(poLast.openDt != null && poLast.opIcCardAddr != null && poLast.opIcCardNo != null){
                if(poLast.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))
                    && poLast.opIcCardAddr.equals(dataCd83OpenVo.icCardAddr)
                    && poLast.opIcCardNo.equals(dataCd83OpenVo.icCardNo)){
                        && poLast.opIcCardAddr.equals(dataCd83OpenVo.icCardAddr)
                        && poLast.opIcCardNo.equals(dataCd83OpenVo.icCardNo)){
                    //重复上报，原因是下行数据处理慢了，就重复上报了
                    return ;
                }
            }
             if(poLast.opType != null){
            if(poLast.opType != null){
                //原记录存在开阀数据，首先进行时间对比
                 if(poLast.openDt != null && poLast.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){
                     //重复上报的开阀数据，不进行处理
                 }else if(poLast.openDt != null && poLast.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){
                if(poLast.openDt != null && poLast.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){
                    //重复上报的开阀数据，不进行处理
                }else if(poLast.openDt != null && poLast.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){
                    //补报的许久之前的开阀数据(对于after:等于或晚于都返回true)
                    this.dealSupplyReport() ;
                }else {
                    //当前开阀上报是新的一次开阀，不管原记录是否存在关阀数据，一律清空关阀数据
                    this.updateOpenValve(clientVo, controller, poLast, null, dV1, dataCd83OpenVo, true) ;
                    this.updateOpenValve(clientVo, controller, rtuAddr, poLast, null, dV1, dataCd83OpenVo, true) ;
                    //生成并保存新的开阀上报历史数据记录
                    this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV1, dataCd83OpenVo, poLast);
                }
            }else if(poLast.clType != null){
                //原记录不存在开阀数据，但存在关阀数据，首先进行时间比对
                 if(poLast.clOpenDt != null && poLast.clOpenDt.before(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){
                     //当前上报是新的开阀数据，把最新(last)数据中的关阀内容清空
                     this.updateOpenValve(clientVo, controller, poLast, null, dV1, dataCd83OpenVo, true) ;
                     //生成并保存新的开阀上报历史数据记录
                     this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV1, dataCd83OpenVo, poLast);
                 }else if(poLast.clOpenDt != null && poLast.clOpenDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){
                if(poLast.clOpenDt != null && poLast.clOpenDt.before(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){
                    //当前上报是新的开阀数据，把最新(last)数据中的关阀内容清空
                    this.updateOpenValve(clientVo, controller, rtuAddr, poLast, null, dV1, dataCd83OpenVo, true) ;
                    //生成并保存新的开阀上报历史数据记录
                    this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV1, dataCd83OpenVo, poLast);
                }else if(poLast.clOpenDt != null && poLast.clOpenDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){
                    //补报的许久之前的开阀报数据(对于after:等于或晚于都返回true)
                    this.dealSupplyReport() ;
                }else {
@@ -130,7 +131,7 @@
                    if(poLast.lastHistoryId != null){
                        poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId) ;
                    }
                    this.updateOpenValve(clientVo, controller, poLast, poHistory, dV1, dataCd83OpenVo, false) ;
                    this.updateOpenValve(clientVo, controller, rtuAddr, poLast, poHistory, dV1, dataCd83OpenVo, false) ;
                    if(poHistory != null){
                        sv.updateRmOpenCloseValveHistory(poHistory);
                    }
@@ -138,7 +139,7 @@
            }else{
                //if(poLast.opType == null && po.clType == null)
                //原记录不存在开阀数据也不存在关阀数据，这种情况不存在，但为安全也进行处理
                this.updateOpenValve(clientVo, controller, poLast, null, dV1, dataCd83OpenVo, true) ;
                this.updateOpenValve(clientVo, controller, rtuAddr, poLast, null, dV1, dataCd83OpenVo, true) ;
                //生成并保存新的开阀上报历史数据记录
                this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV1, dataCd83OpenVo, poLast);
            }
@@ -228,6 +229,7 @@
     */
    private void updateOpenValve(SeClient clientVo,
                                 PrController controller,
                                 String rtuAddr,
                                 RmOpenCloseValveLast poLast,
                                 RmOpenCloseValveHistory poHistory,
                                 DataV1 dV1,
@@ -237,13 +239,14 @@
        poLast.clientName = clientVo==null?null:clientVo.getName() ;
        poLast.controllerId = controller==null?null:controller.getId();
        poLast.intakeId = controller==null?null:controller.getIntakeId();
        poLast.rtuAddr = rtuAddr;
        poLast.updateFrom(dV1, dataCd83OpenVo, clearLastCloseValve);

        if(poHistory != null){
            poLast.clientId = clientVo==null?null:clientVo.getId() ;
            poLast.clientName = clientVo==null?null:clientVo.getName() ;
            poHistory.clientId = clientVo==null?null:clientVo.getId() ;
            poHistory.clientName = clientVo==null?null:clientVo.getName() ;
            poHistory.controllerId = controller==null?null:controller.getId();
            poHistory.intakeId = controller==null?null:controller.getIntakeId();
            poHistory.rtuAddr = rtuAddr;
            poHistory.updateFrom(dV1, dataCd83OpenVo, false);
        }
    }