有关表阀一体机（王江海制定）通信协议： 1、根据新版本协议，解析部分更新； 2、根据测试一体阀协议数据处理需求与逻辑，进行表阀一体机数据处理。

liurunyu

2025-02-24 70aeac289c132085e91d59dc82bc1facd41889fa

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

@@ -3,9 +3,13 @@
import com.dy.common.mw.protocol.Data;
import com.dy.common.mw.protocol.p206V202404.DataV202404;
import com.dy.common.mw.protocol.p206V202404.upVos.DataCd84Vo;
import com.dy.common.util.DateTime;
import com.dy.pipIrrGlobal.pojoPr.PrController;
import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseHistory;
import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseLast;
import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory;
import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast;
import com.dy.pipIrrGlobal.pojoSe.SeClient;
import com.dy.rtuMw.server.msCenter.MsCenterUnit;
import com.dy.rtuMw.server.msCenter.MsObj;
import com.dy.rtuMw.server.rtuData.TaskSurpport;
import com.dy.rtuMw.server.rtuData.dbSv.DbSv;
import org.apache.logging.log4j.LogManager;
@@ -33,72 +37,272 @@
        Data d = (Data) data;
        DataV202404 dV202404 = (DataV202404) d.getSubData();
        Object cdObj = dV202404.subData;
        if (cdObj != null) {
        if (cdObj != null && cdObj instanceof DataCd84Vo) {
            try {
                Object[] objs = this.getTaskResults(TkPreGenObjsV202404.taskId);
                DbSv sv = (DbSv) objs[0];
                PrController controller = (PrController) objs[1];
                if (cdObj instanceof DataCd84Vo) {
                    DataCd84Vo cdData = (DataCd84Vo) (cdObj);
                    this.doDeal(sv, controller, d.getRtuAddr(), dV202404, (DataCd84Vo)cdObj);
                }
                SeClient clientVo = (SeClient)objs[3] ;//这个值对象中只有id和name会有值
                this.toMsCenter(clientVo, controller, d.getRtuAddr(), dV202404, (DataCd84Vo)cdObj) ;
                this.doDeal(sv, clientVo, controller, d.getRtuAddr(), dV202404, (DataCd84Vo)cdObj);
            } catch (Exception e) {
                log.error("保存控制器开阀报数据时发生异常", e);
            }
        }
    }
    /**
     * 处理开阀报数据
     * @param sv 服务
     * @param controller 控制器对象
     * @param rtuAddr 控制器地址
     * @param dataV202404 协议数据
     * @param cdData 功能数据
     */
    private void doDeal(DbSv sv, 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 功能数据
     * 把开阀消息存入消息中心
     * @param clientVo
     * @param controller
     * @param rtuAddr
     * @param dataV202404
     * @param dataCd84Vo
     */
    private void saveOrUpdateLast(DbSv sv, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd84Vo cdData)throws Exception {
        RmOpenCloseLast po = sv.getRmOpenCloseLast(rtuAddr);
        if(po == null){
            po = new RmOpenCloseLast();
            po.controllerId = controller==null?null:controller.getId();
            po.intakeId = controller==null?null:controller.getIntakeId();
            po.rtuAddr = rtuAddr;
            po.valueFrom84(dataV202404, cdData);
            sv.saveRmOpenCloseLast(po);
        }else{
            po.controllerId = controller==null?null:controller.getId();
            po.intakeId = controller==null?null:controller.getIntakeId();
            po.valueFrom84(dataV202404, cdData);
            sv.updateRmOpenCloseLast(po);
    private void toMsCenter(SeClient clientVo, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd84Vo dataCd84Vo){
        if(clientVo != null && controller != null){
            MsObj msObj = new MsObj() ;
            msObj.put("name", "开阀");
            msObj.put("clientId", clientVo.getId());
            msObj.put("clientName", clientVo.getName());
            msObj.put("clientAddress", clientVo.getAddress());
            msObj.put("icCardNo", dataCd84Vo.icCardNo);
            msObj.put("rtuAddr", rtuAddr);
            msObj.put("intakeId", controller.getIntakeId());
            msObj.put("dt", dataV202404.dt);
            MsCenterUnit.getInstance().pushMs(msObj);
        }
    }

    /**
     * 保存控制器工作报历史数据
     * @param sv 服务bean
     * 业务处理
     * @param sv 服务
     * @param clientVo 农户对象（不为空时，只有id和name有值）
     * @param controller 控制器对象
     * @param rtuAddr 控制器地址
     * @param dataV202404 协议数据
     * @param cdData 功能数据
     * @param dataV202404 上报数据
     * @param dataCd84Vo 开阀上报数据对象
     */
    private void saveHistory(DbSv sv, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd84Vo cdData)throws Exception {
        RmOpenCloseHistory po = new RmOpenCloseHistory();
        po.controllerId = controller==null?null:controller.getId();
        po.intakeId = controller==null?null:controller.getIntakeId();
        po.rtuAddr = rtuAddr;
        po.valueFrom84(dataV202404, cdData);
        sv.saveRmOpenCloseHistory(po); ;
    private void doDeal(DbSv sv, SeClient clientVo, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd84Vo dataCd84Vo) throws Exception {
        RmOpenCloseValveLast poLast = sv.getRmOpenCloseValveLast(controller.getIntakeId()) ;
        if(poLast == null){
            //数据库中不存在该控制器的开关阀数据
            //首先生成开关阀的最新数据及历史数据，并先保存
            poLast = this.newRmOpenCloseValveLast(clientVo, controller, rtuAddr, dataV202404, dataCd84Vo);
            this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dataV202404, dataCd84Vo, poLast);
            sv.saveRmOpenCloseValveLast(poLast);
        }else{
            //数据库中存在该控制器的开关阀数据
            if(poLast.openDt != null && poLast.opIcCardAddr != null && poLast.opIcCardNo != null){
                if(poLast.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))
                        && poLast.opIcCardAddr.equals(dataCd84Vo.icCardAddr)
                        && poLast.opIcCardNo.equals(dataCd84Vo.icCardNo)){
                    //重复上报，原因是下行数据处理慢了，就重复上报了
                    return ;
                }
            }
            if(poLast.opType != null){
                //原记录存在开阀数据，首先进行时间对比
                if(poLast.openDt != null && poLast.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){
                    //重复上报的开阀数据，不进行处理
                }else if(poLast.openDt != null && poLast.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){
                    //补报的许久之前的开阀数据(对于after:等于或晚于都返回true)
                    this.dealSupplyReport() ;
                }else {
                    //当前开阀上报是新的一次开阀，不管原记录是否存在关阀数据，一律清空关阀数据
                    this.updateOpenValve(clientVo, controller, poLast, null, dataV202404, dataCd84Vo, true) ;
                    //生成并保存新的开阀上报历史数据记录
                    this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dataV202404, dataCd84Vo, poLast);
                }
            }else if(poLast.clType != null){
                //原记录不存在开阀数据，但存在关阀数据，首先进行时间比对
                if(poLast.clOpenDt != null && poLast.clOpenDt.before(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){
                    //当前上报是新的开阀数据，把最新(last)数据中的关阀内容清空
                    this.updateOpenValve(clientVo, controller, poLast, null, dataV202404, dataCd84Vo, true) ;
                    //生成并保存新的开阀上报历史数据记录
                    this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dataV202404, dataCd84Vo, poLast);
                }else if(poLast.clOpenDt != null && poLast.clOpenDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){
                    //补报的许久之前的开阀报数据(对于after:等于或晚于都返回true)
                    this.dealSupplyReport() ;
                }else {
                    //当前上报的开阀数据与原来的关阀数据同一时间，这种情况应该不存在，但也处理
                    RmOpenCloseValveHistory poHistory = null ;
                    if(poLast.lastHistoryId != null){
                        poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId) ;
                    }
                    this.updateOpenValve(clientVo, controller, poLast, poHistory, dataV202404, dataCd84Vo, false) ;
                    if(poHistory != null){
                        sv.updateRmOpenCloseValveHistory(poHistory);
                    }
                }
            }else{
                //if(poLast.opType == null && po.clType == null)
                //原记录不存在开阀数据也不存在关阀数据，这种情况不存在，但为安全也进行处理
                this.updateOpenValve(clientVo, controller, poLast, null, dataV202404, dataCd84Vo, true) ;
                //生成并保存新的开阀上报历史数据记录
                this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dataV202404, dataCd84Vo, poLast);
            }

            sv.updateRmOpenCloseValveLast(poLast);
        }
    }

    /**
     * 处理补报，暂时无逻辑
     */
    private void dealSupplyReport(){
    }

    /**
     * 保存新的开阀上报历史数据记录，并把ID赋值给最新记录的 lastHistoryId
     * @param sv
     * @param clientVo
     * @param controller
     * @param rtuAddr
     * @param dataV202404
     * @param dataCd84Vo
     * @param poLast
     * @throws Exception
     */
    private void newHistoryDataDeal(DbSv sv, SeClient clientVo, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd84Vo dataCd84Vo, RmOpenCloseValveLast poLast)throws Exception {
        RmOpenCloseValveHistory poHistory = this.newRmOpenCloseValveHistory(clientVo, controller, rtuAddr, dataV202404, dataCd84Vo) ;
        sv.saveRmOpenCloseValveHistory(poHistory);
        //由最新数据持有历史数据中的最新记录ID，以方便快速查询
        poLast.lastHistoryId = poHistory == null ? null: poHistory.id ;
    }

    /**
     * 生成新的开阀上报最新数据记录
     * @param clientVo
     * @param controller
     * @param rtuAddr
     * @param dataV202404
     * @param dataCd84Vo
     * @return
     * @throws Exception
     */
    private RmOpenCloseValveLast newRmOpenCloseValveLast(SeClient clientVo, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd84Vo dataCd84Vo)throws Exception {
        RmOpenCloseValveLast po = new RmOpenCloseValveLast() ;
        po.clientId = clientVo==null?null:clientVo.getId() ;
        po.clientName = clientVo==null?null:clientVo.getName() ;
        po.controllerId = controller==null?null:controller.getId() ;
        po.intakeId = controller==null?null:controller.getIntakeId() ;
        po.rtuAddr = rtuAddr ;
        po.valueFrom84(dataV202404, dataCd84Vo);
        return po ;
    }


    /**
     * 生成新的开阀上报历史数据记录
     * @param clientVo
     * @param controller
     * @param rtuAddr
     * @param dataV202404
     * @param dataCd84Vo
     * @return
     * @throws Exception
     */
    private RmOpenCloseValveHistory newRmOpenCloseValveHistory(SeClient clientVo, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd84Vo dataCd84Vo)throws Exception {
        RmOpenCloseValveHistory po = new RmOpenCloseValveHistory() ;
        po.clientId = clientVo==null?null:clientVo.getId() ;
        po.clientName = clientVo==null?null:clientVo.getName() ;
        po.controllerId = controller==null?null:controller.getId() ;
        po.intakeId = controller==null?null:controller.getIntakeId() ;
        po.rtuAddr = rtuAddr ;
        po.valueFrom84(dataV202404, dataCd84Vo);
        return po ;
    }


    /**
     * 更新数据
     * @param clientVo
     * @param controller
     * @param poLast
     * @param poHistory
     * @param dataV202404
     * @param dataCd84Vo
     * @param clearLastCloseValve
     * @throws Exception
     */
    private void updateOpenValve(SeClient clientVo,
                                 PrController controller,
                                 RmOpenCloseValveLast poLast,
                                 RmOpenCloseValveHistory poHistory,
                                 DataV202404 dataV202404,
                                 DataCd84Vo dataCd84Vo,
                                 boolean clearLastCloseValve) throws Exception {
        poLast.clientId = clientVo==null?null:clientVo.getId() ;
        poLast.clientName = clientVo==null?null:clientVo.getName() ;
        poLast.controllerId = controller==null?null:controller.getId();
        poLast.intakeId = controller==null?null:controller.getIntakeId();
        poLast.updateFrom(dataV202404, dataCd84Vo, clearLastCloseValve);

        if(poHistory != null){
            poLast.clientId = clientVo==null?null:clientVo.getId() ;
            poLast.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);
        }
    }


//
//    /**
//     * 处理开阀报数据
//     * @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); ;
//    }
}