各轮灌组开阀时间提前2分钟，第一组除外

zhubaomin

2025-04-23 026447959141110afd24d18b61da953c62aa2209

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

@@ -8,6 +8,8 @@
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;
@@ -42,12 +44,37 @@
            PrController controller = (PrController)objs[1] ;
            SeClient clientVo = (SeClient)objs[3] ;//这个值对象中只有id和name会有值
            try{
                this.toMsCenter(clientVo, controller, d.getRtuAddr(), dV1, (DataCd83OpenVo)cdObj) ;
                this.doDeal(sv, clientVo, controller, d.getRtuAddr(), dV1, (DataCd83OpenVo)cdObj) ;
            }catch (Exception e){
                log.error("保存控制器开阀上报时发生异常", e);
            }
        }
    }

    /**
     * 把开阀消息存入消息中心
     * @param clientVo
     * @param controller
     * @param rtuAddr
     * @param dV1
     * @param dataCd83OpenVo
     */
    private void toMsCenter(SeClient clientVo, PrController controller, String rtuAddr, DataV1 dV1, DataCd83OpenVo dataCd83OpenVo){
        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", dataCd83OpenVo.icCardNo);
            msObj.put("rtuAddr", rtuAddr);
            msObj.put("intakeId", controller.getIntakeId());
            msObj.put("dt", dV1.dt);
            MsCenterUnit.getInstance().pushMs(msObj);
        }
    }

    /**
     * 业务处理
     * @param sv 服务
@@ -69,17 +96,17 @@
            //数据库中存在该控制器的开关阀数据
            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 {
@@ -90,12 +117,12 @@
                }
            }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, 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 {