From deac851d71b074885553f538a396936815073fc1 Mon Sep 17 00:00:00 2001 From: zhubaomin <zhubaomin> Date: 星期二, 15 四月 2025 08:46:01 +0800 Subject: [PATCH] 优化命令发布接口(6个),重复时使用新的commandId --- pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/msCenter/TestMsResource.java | 20 +++++++++++++++++--- 1 files changed, 17 insertions(+), 3 deletions(-) diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/msCenter/TestMsResource.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/msCenter/TestMsResource.java index 5521116..da5dd1f 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/msCenter/TestMsResource.java +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/msCenter/TestMsResource.java @@ -13,7 +13,7 @@ @Component public class TestMsResource { - // 璁剧疆瀹氭椂鍗佺涓�娆� + // 璁剧疆瀹氭椂N绉掍竴娆� @Scheduled(cron = "0/4 * * * * ?") public void test1() throws Exception { MsObj msObj = new MsObj() ; @@ -29,7 +29,7 @@ } - // 璁剧疆瀹氭椂鍗佺涓�娆� + // 璁剧疆瀹氭椂N绉掍竴娆� @Scheduled(cron = "0/6 * * * * ?") public void test2() throws Exception { MsObj msObj = new MsObj() ; @@ -44,8 +44,21 @@ MsCenterUnit.getInstance().pushMs(msObj); } - // 璁剧疆瀹氭椂鍗佺涓�娆� + // 璁剧疆瀹氭椂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); } + } -- Gitblit v1.8.0