1、江海测试系统设备类型默认为阀； 2、完善通信中间件测试消息推送代码； 3、增加队列数据结构注释； 4、121服务器相关的初始化配置文件bug修改；...

liurunyu

6 天以前 eb5a6e5a54efa997971beffc909bcadc06dc8886

1、江海测试系统设备类型默认为阀；
2、完善通信中间件测试消息推送代码；
3、增加队列数据结构注释；
4、121服务器相关的初始化配置文件bug修改；
5、其他注释完善。

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/queue/Node.java

@@ -2,7 +2,8 @@


public class Node {
    public Node pre ;
    public Node next ;
    public NodeObj obj ;
    public Node pre ;//前置结点
    public Node next ;//后置结点
    public NodeObj obj ;//本结点数据对象
}


 pipIrr-platform/pipIrr-global/src/main/resources/init-config(121·þÎñÆ÷).xml

@@ -254,7 +254,7 @@
                <item3 typeName="设备保养"/>
            </taskType>
        </org4>
        <org4 tag="lz" name="凉州" enable="true">
        <org5 tag="lz" name="凉州" enable="true">
            <districts>
                <province name="甘肃省" num="62" level="0">
                    <city name="武威市" num="06" level="1">
@@ -316,8 +316,8 @@
                <item2 typeName="设备维修"/>
                <item3 typeName="设备保养"/>
            </taskType>
        </org4>
        <org5 tag="jc" name="金川" enable="true">
        </org5>
        <org6 tag="jc" name="金川" enable="true">
            <districts>
                <province name="甘肃省" num="62" level="0">
                    <city name="金昌市" num="03" level="1">
@@ -379,6 +379,6 @@
                <item2 typeName="设备维修"/>
                <item3 typeName="设备保养"/>
            </taskType>
        </org5>
        </org6>
    </orgs>
</config>

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/msCenter/TestMsResource.java

@@ -17,30 +17,15 @@
    @Scheduled(cron = "0/4 * * * * ?")
    public void test1() throws Exception {
        MsObj msObj = new MsObj() ;
        msObj.put("name", "开阀");
        msObj.put("clientId", 2024090517284400002L);
        msObj.put("clientName", "田仁春");
        msObj.put("clientAddress", "元谋县元马镇清和村委会挨那望村");
        msObj.put("icCardNo", "123456789");
        msObj.put("rtuAddr", "123456789");
        msObj.put("intakeId", 2024090517395800007L);
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
        setAttr4OpenCloseValve("开阀", msObj) ;
        MsCenterUnit.getInstance().pushMs(msObj);
    }


    // è®¾ç½®å®šæ—¶N秒一次
    @Scheduled(cron = "0/6 * * * * ?")
    public void test2() throws Exception {
        MsObj msObj = new MsObj() ;
        msObj.put("name", "关阀");
        msObj.put("clientId", 2024090517284400002L);
        msObj.put("clientName", "田仁春");
        msObj.put("clientAddress", "元谋县元马镇清和村委会挨那望村");
        msObj.put("icCardNo", "123456789");
        msObj.put("rtuAddr", "123456789");
        msObj.put("intakeId", 2024090517395800007L);
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
        setAttr4OpenCloseValve("关阀", msObj) ;
        MsCenterUnit.getInstance().pushMs(msObj);
    }

@@ -48,12 +33,9 @@
    @Scheduled(cron = "0/10 * * * * ?")
    public void test4() throws Exception {
        MsObj msObj = new MsObj() ;
        msObj.put("name", "阀态");
        msObj.put("rtuAddr","123456789");
        msObj.put("intakeId", 2024090517395800007L);
        setAttr4StateAlarm("阀态", msObj) ;
        msObj.put("state", 0);
        msObj.put("stateName", "开");
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
        MsCenterUnit.getInstance().pushMs(msObj);
    }

@@ -61,13 +43,33 @@
    @Scheduled(cron = "0/15 * * * * ?")
    public void test3() throws Exception {
        MsObj msObj = new MsObj() ;
        msObj.put("name", "报警");
        msObj.put("rtuAddr","123456789");
        msObj.put("intakeId", 2024090517395800007L);
        setAttr4StateAlarm("阀态", msObj) ;
        msObj.put("alarm", "流量计故障报警、漏损报警");
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
        MsCenterUnit.getInstance().pushMs(msObj);
    }

    private void setAttr4OpenCloseValve(String name, MsObj msObj){
        msObj.put("name", name);
        msObj.put("clientId", clientId);
        msObj.put("clientName", clientName);
        msObj.put("clientAddress", clientAddress);
        msObj.put("icCardNo", icCardNo);
        msObj.put("rtuAddr", rtuAddr);
        msObj.put("intakeId", intakeId);
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
    }

    private void setAttr4StateAlarm(String name, MsObj msObj){
        msObj.put("name", name);
        msObj.put("rtuAddr", rtuAddr);
        msObj.put("intakeId", intakeId);
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
    }

    private static final String clientName = "田仁春";
    private static final String clientAddress = "元谋县元马镇清和村委会挨那望村";
    private static final Long clientId = 2024090517284400002L;
    private static final Long intakeId = 2024090517395800007L;
    private static final String rtuAddr = "123456789";
    private static final String icCardNo = "123456789";
}

 pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/p206V202404test/ComSupportP206V202404.java

@@ -31,7 +31,7 @@
    protected static String rtuAddr = "37142501020100229" ;
    protected static String rtuResultSendWebUrl = "http://127.0.0.1:65535/test/comRes/receive" ;

    protected static String controllerType = "57" ;//控制器类型
    protected static String controllerType = "02" ;//控制器类型 57水泵，02阀门
    protected static Integer projectNo = 10 ;//项目编码

    protected static String icCardAddr = "04BEA5BB" ;//IC卡地址

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/monitor/MonitorSv.java

@@ -61,7 +61,7 @@
    }

    /**
     * æŸ¥è¯¢RTU在通信中间件中的在线状态
     * æŸ¥è¯¢RTU在通信中间件中的状态
     * @param rtuAddr
     * @return
     */