liurunyu
2025-04-03 297cb72f286bb6171db59f1bebae141316b519bc
通信中间件增加阀态消息推送测试。
1个文件已修改
14 ■■■■■ 已修改文件
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/msCenter/TestMsResource.java 14 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/msCenter/TestMsResource.java
@@ -46,6 +46,19 @@
    // 设置定时N秒一次
    @Scheduled(cron = "0/10 * * * * ?")
    public void test4() throws Exception {
        MsObj msObj = new MsObj() ;
        msObj.put("name", "阀态");
        msObj.put("rtuAddr","123456789");
        msObj.put("intakeId", 2024090517395800007L);
        msObj.put("state", 0);
        msObj.put("stateName", "开");
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
        MsCenterUnit.getInstance().pushMs(msObj);
    }
    // 设置定时N秒一次
    @Scheduled(cron = "0/15 * * * * ?")
    public void test3() throws Exception {
        MsObj msObj = new MsObj() ;
        msObj.put("name", "报警");
@@ -56,4 +69,5 @@
        MsCenterUnit.getInstance().pushMs(msObj);
    }
}