解决开关阀记录数据因重绑定或改RTU地址而引起的地址变更问题

liurunyu

5 天以前 02d965a2ff0cb5d415cedceacd2ae90c7ec1ac39

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V202404/TkDealCloseValveReportV202404.java

@@ -119,7 +119,7 @@
                                if(poHistory.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.startDt))){
                                    //匹配成功
                                    //当前关阀是原记录中开阀的对应关阀
                                    this.updateCloseValve(clientVo, controller, poLast, poHistory, dV202404, dataCd85Vo, false) ;
                                    this.updateCloseValve(clientVo, controller, rtuAddr, poLast, poHistory, dV202404, dataCd85Vo, false) ;
                                    sv.updateRmOpenCloseValveHistory(poHistory);
                                }else if(poHistory.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.startDt))){
                                    //匹配失败(对于after:等于或晚于都返回true)
@@ -160,28 +160,28 @@
                        if (poHistory != null) {
                            if(poHistory.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.startDt))){
                                //匹配上了
                                this.updateCloseValve(clientVo, controller, poLast, poHistory, dV202404, dataCd85Vo, false) ;
                                this.updateCloseValve(clientVo, controller, rtuAddr, poLast, poHistory, dV202404, dataCd85Vo, false) ;
                                sv.updateRmOpenCloseValveHistory(poHistory);
                            }else{
                                //上个关阀报未上报
                                this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
                                this.updateCloseValve(clientVo, controller, rtuAddr, poLast, null, dV202404, dataCd85Vo, true) ;
                                this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
                            }
                        }else{
                            //这种情况不存在，但为安全也进行处理，也认为上个关阀报未上报
                            this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
                            this.updateCloseValve(clientVo, controller, rtuAddr, poLast, null, dV202404, dataCd85Vo, true) ;
                            this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
                        }
                    }else{
                        //这种情况不存在，但为安全也进行处理，也认为上个关阀报未上报
                        this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
                        this.updateCloseValve(clientVo, controller, rtuAddr, poLast, null, dV202404, dataCd85Vo, true) ;
                        this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
                    }
                }
            }else{
                //if(po.opType == null)
                //原记录不存在开阀数据也不存在关阀数据，这种情况不存在，但为安全也进行处理，也认为上个关阀报未上报
                this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
                this.updateCloseValve(clientVo, controller, rtuAddr, poLast, null, dV202404, dataCd85Vo, true) ;
                //生成并保存新的关阀上报历史数据记录，没有对应的开发数据
                this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
            }
@@ -289,6 +289,7 @@
     */
    private void updateCloseValve(SeClient clientVo,
                                  PrController controller,
                                  String rtuAddr,
                                  RmOpenCloseValveLast poLast,
                                  RmOpenCloseValveHistory poHistory,
                                  DataV202404 dV202404,
@@ -298,73 +299,16 @@
        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(dV202404, dataCd85Vo, clearLastOpenValue);

        if(poHistory != null){
            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(dV202404, dataCd85Vo, false);
        }
    }


//    /**
//     * 处理关阀报数据
//     * @param sv 服务
//     * @param clientVo 农户对象（不为空时，只有id和name有值）
//     * @param controller 控制器对象
//     * @param rtuAddr 控制器地址
//     * @param dataV202404 协议数据
//     * @param cdData 功能数据
//     */
//    private void doDeal(DbSv sv, SeClient clientVo, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd85Vo cdData) throws Exception {
//        this.saveOrUpdateLast(sv, controller, rtuAddr, dataV202404, cdData);
//        this.saveHistory(sv, controller, rtuAddr, dataV202404, cdData);
//    }
//
//    /**
//     * 保存或更新控制器关阀报最新数据
//     * @param sv 服务bean
//     * @param controller 控制器对象
//     * @param rtuAddr 控制器地址
//     * @param dataV202404 协议数据
//     * @param cdData 功能数据
//     */
//    private void saveOrUpdateLast(DbSv sv, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd85Vo cdData)throws Exception {
//        RmOpenCloseValveLast po = sv.getRmOpenCloseValveLast(controller.getIntakeId());
//        if(po == null){
//            po = new RmOpenCloseValveLast();
//            po.controllerId = controller==null?null:controller.getId();
//            po.intakeId = controller==null?null:controller.getIntakeId();
//            po.rtuAddr = rtuAddr;
//            po.valueFrom85(dataV202404, cdData);
//            sv.saveRmOpenCloseValveLast(po);
//        }else{
//            po.controllerId = controller==null?null:controller.getId();
//            po.intakeId = controller==null?null:controller.getIntakeId();
//            po.valueFrom85(dataV202404, cdData);
//            sv.updateRmOpenCloseValveLast(po);
//        }
//    }
//
//    /**
//     * 保存控制器关阀报历史数据
//     * @param sv 服务bean
//     * @param controller 控制器对象
//     * @param rtuAddr 控制器地址
//     * @param dataV202404 协议数据
//     * @param cdData 功能数据
//     */
//    private void saveHistory(DbSv sv, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd85Vo cdData)throws Exception {
//        RmOpenCloseValveHistory po = new RmOpenCloseValveHistory();
//        po.controllerId = controller==null?null:controller.getId();
//        po.intakeId = controller==null?null:controller.getIntakeId();
//        po.rtuAddr = rtuAddr;
//        po.valueFrom85(dataV202404, cdData);
//        sv.saveRmOpenCloseValveHistory(po); ;
//    }
}