Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

zhubaomin

2024-10-31 007bb91e70a5129304de1837f60161c6f5f3ad4f

Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/parse/Cd_83_Up.java

@@ -196,7 +196,7 @@
        //cdData.rtuDt = GlParse.parseTp(bs, index) ;
        //2024-10-27 刘润玉：苏有勋把协议中的控制器时钟给删除掉了（目的是节约存储空间）
        //处理办法是把关阀时间作为控制器时钟，这两个时间相差不到一分钟
        //cdData.rtuDt = cdData.closeDt ;
        cdData.rtuDt = cdData.closeDt ;
        //index += 6 ;
    }


 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java

@@ -68,9 +68,9 @@
    private RmTimingReportLastMapper rmTimingReportLastDao; // 定点上报最新数据DAO

    @Autowired
    private RmOnHourReportHistoryMapper rmOnHourReportHistoryDao; // 整点上报历史数据DAO
    private RmOnHourReportHistoryMapper rmOnHourReportHistoryDao; // 定点上报历史数据DAO
    @Autowired
    private RmOnHourReportLastMapper rmOnHourReportLastDao; // 整点上报最新数据DAO
    private RmOnHourReportLastMapper rmOnHourReportLastDao; // 定点上报最新数据DAO


    //@Autowired
@@ -268,12 +268,12 @@

    /////////////////////////////////////////////////
    //
    // 整点上报实时数据功能(只在靳总的协议有此数据)
    // 定点上报实时数据功能(只在靳总的协议有此数据)
    //
    ////////////////////////////////////////////////

    /**
     * 保存控制器整点上报历史数据
     * 保存控制器定点上报历史数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
@@ -282,7 +282,7 @@
    }

    /**
     * 根据阀控器地址获取整点上报最新数据
     * 根据阀控器地址获取定点上报最新数据
     * @param intakeId
     * @return
     */
@@ -296,7 +296,7 @@
    }

    /**
     * 保存控制器整点上报最新数据
     * 保存控制器定点上报最新数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
@@ -305,7 +305,7 @@
    }

    /**
     * 保存控制器整点上报罪行数据
     * 保存控制器定点上报罪行数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkDealOnHourReport.java

@@ -22,7 +22,7 @@
 * @Author liurunyu
 * @Date 2024/1/16 14:11
 * @LastEditTime 2024/1/16 14:11
 * @Description 控制器自报实时数据（功能码为C0）（整点上报）
 * @Description 控制器自报实时数据（功能码为C0）（定点上报）
 */
public class TkDealOnHourReport extends TaskSurpport {

@@ -47,7 +47,7 @@
            try{
                this.doDeal(sv, controller, d.getRtuAddr(), dV1_0_1, (DataCdC0Vo)cdObj);
            }catch (Exception e){
                log.error("保存控制器整点上报数据时发生异常", e);
                log.error("保存控制器定点上报数据时发生异常", e);
            }
        }
    }

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/RtuDataDealTree.xml

@@ -18,7 +18,7 @@
                            <task id="TkDealAlarmStatus" name="控制器报警与状态及向钉钉发送报警信息" enable="true" class="com.dy.rtuMw.server.rtuData.p206V1_0_0.TkDealAlarmStatus">
                                <task id="TkDealVirCardState" name="虚拟卡占用状态恢复" enable="true" class="com.dy.rtuMw.server.rtuData.p206V1_0_0.TkDealVirCardState" />
                            </task>
                            <task id="TkDealOnHourReport" name="控制器自报数据（整点报）(功能码C0)" enable="true" class="com.dy.rtuMw.server.rtuData.p206V1_0_0.TkDealOnHourReport" />
                            <task id="TkDealOnHourReport" name="控制器自报数据（定点报）(功能码C0)" enable="true" class="com.dy.rtuMw.server.rtuData.p206V1_0_0.TkDealOnHourReport" />
                            <task id="TkDealWorkReport" name="控制器阀开工作上报(功能码84)" enable="true" class="com.dy.rtuMw.server.rtuData.p206V1_0_0.TkDealWorkReport" />
                            <task id="TkDealOpenValveReport" name="控制器开阀上报(功能码83)" enable="true" class="com.dy.rtuMw.server.rtuData.p206V1_0_0.TkDealOpenValveReport" />
                            <task id="TkDealCloseValveReport" name="控制器关阀上报(功能码83)" enable="true" class="com.dy.rtuMw.server.rtuData.p206V1_0_0.TkDealCloseValveReport" />

 pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/p206V1_0_0/CommandP206V1_0_0Ctrl.java

@@ -37,6 +37,8 @@
                    rt = this.recoverTcpSv() ;
                }else if(com.equals(CodeLocal.mwState)){
                    rt = this.mwState() ;
                }else if(com.equals(CodeLocal.onLine)){
                    rt = this.mwAllOnLine() ;
                }else if(com.equals("10")){
                    rt = this.cd10() ;
                }else if(com.equals("21")){
@@ -114,6 +116,10 @@
        return this.sendCom2Mw(this.commandLocal(CodeLocal.mwState, null, null)) ;
    }

    private BaseResponse mwAllOnLine(){
        return this.sendCom2Mw(this.commandLocal(CodeLocal.onLine, null, null)) ;
    }

    private BaseResponse cd10(){
        Com10Vo comVo = new Com10Vo() ;
        comVo.rtuAddr = "532328059995" ;//前6位是行政区划码，后6位是序列号最大是065535