From eca1e05aeed3c51cce36bbce80c71bc3cbcea87d Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期五, 12 十一月 2021 14:40:39 +0800 Subject: [PATCH] 维护目录订阅消息与接口 --- src/main/java/com/genersoft/iot/vmp/conf/SipDeviceRunner.java | 11 +++++++++-- 1 files changed, 9 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/conf/SipDeviceRunner.java b/src/main/java/com/genersoft/iot/vmp/conf/SipDeviceRunner.java index 2b7ab1a..da1664b 100644 --- a/src/main/java/com/genersoft/iot/vmp/conf/SipDeviceRunner.java +++ b/src/main/java/com/genersoft/iot/vmp/conf/SipDeviceRunner.java @@ -7,6 +7,8 @@ import org.springframework.core.annotation.Order; import org.springframework.stereotype.Component; +import java.util.List; + /** * 绯荤粺鍚姩鏃舵帶鍒惰澶囩绾� @@ -23,9 +25,14 @@ @Override public void run(String... args) throws Exception { + // 璇诲彇redis娌℃湁蹇冭烦淇℃伅鐨勫垯璁剧疆涓虹绾匡紝绛夋敹鍒颁笅娆″績璺宠缃负鍦ㄧ嚎 // 璁剧疆鎵�鏈夎澶囩绾� storager.outlineForAll(); - // 璁剧疆鎵�鏈夎澶囩绾� - redisCatchStorage.outlineForAll(); + List<String> onlineForAll = redisCatchStorage.getOnlineForAll(); + for (String deviceId : onlineForAll) { + storager.online(deviceId); + } + + // TODO 鏌ヨ鍦ㄧ嚎璁惧閭d簺寮�鍚簡璁㈤槄锛屼负璁惧寮�鍚畾鏃剁殑鐩綍璁㈤槄 } } -- Gitblit v1.8.0