1、表阀一体机新协议开阀报关阀报数据处理逻辑修改； 2、农户月用水统计查询中，缺少农户姓名，进行SQL修改。

liurunyu

2025-03-01 595b66ae8800511fab34e503f94d173613088c08

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

@@ -240,8 +240,8 @@
        poLast.updateFrom(dataV202404, dataCd84Vo, 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.updateFrom(dataV202404, dataCd84Vo, false);
@@ -249,60 +249,4 @@
    }


//
//    /**
//     * 处理开阀报数据
//     * @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, DataCd84Vo 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, DataCd84Vo 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.valueFrom84(dataV202404, cdData);
//            sv.saveRmOpenCloseValveLast(po);
//        }else{
//            po.controllerId = controller==null?null:controller.getId();
//            po.intakeId = controller==null?null:controller.getIntakeId();
//            po.valueFrom84(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, DataCd84Vo 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.valueFrom84(dataV202404, cdData);
//        sv.saveRmOpenCloseValveHistory(po); ;
//    }
}