From 9bf87971e7dc6e0bccc0cf9a2301e9c89f9a0ba6 Mon Sep 17 00:00:00 2001
From: panlinlin <648540858@qq.com>
Date: 星期四, 07 一月 2021 14:56:10 +0800
Subject: [PATCH] 完成向上级联->启动时自动注册
---
src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java | 11 +++++
src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java | 1
src/main/java/com/genersoft/iot/vmp/conf/SipPlatformRunner.java | 55 +++++++++++++++++++++++++++
src/main/java/com/genersoft/iot/vmp/storager/dao/ParentPlatformMapper.java | 6 +++
src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java | 9 ++++
5 files changed, 82 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/conf/SipPlatformRunner.java b/src/main/java/com/genersoft/iot/vmp/conf/SipPlatformRunner.java
new file mode 100644
index 0000000..eae4547
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/conf/SipPlatformRunner.java
@@ -0,0 +1,55 @@
+package com.genersoft.iot.vmp.conf;
+
+import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;
+import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch;
+import com.genersoft.iot.vmp.gb28181.event.EventPublisher;
+import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform;
+import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
+import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 绯荤粺鍚姩鏃舵帶鍒朵笂绾у钩鍙伴噸鏂版敞鍐�
+ */
+@Component
+@Order(value=3)
+public class SipPlatformRunner implements CommandLineRunner {
+
+ @Autowired
+ private IVideoManagerStorager storager;
+
+ @Autowired
+ private IRedisCatchStorage redisCatchStorage;
+
+ @Autowired
+ private EventPublisher publisher;
+
+ @Override
+ public void run(String... args) throws Exception {
+ // 璁剧疆鎵�鏈夊钩鍙扮绾�
+ storager.outlineForAllParentPlatform();
+
+ List<ParentPlatform> parentPlatforms = storager.queryEnableParentPlatformList(true);
+
+ for (ParentPlatform parentPlatform : parentPlatforms) {
+
+ redisCatchStorage.updatePlatformRegister(parentPlatform);
+
+ redisCatchStorage.updatePlatformKeepalive(parentPlatform);
+
+ ParentPlatformCatch parentPlatformCatch = new ParentPlatformCatch();
+
+ parentPlatformCatch.setParentPlatform(parentPlatform);
+ parentPlatformCatch.setId(parentPlatform.getDeviceGBId());
+ redisCatchStorage.updatePlatformCatchInfo(parentPlatformCatch);
+
+ // 鍙戦�佸钩鍙版湭娉ㄥ唽娑堟伅
+ publisher.platformNotRegisterEventPublish(parentPlatform.getDeviceGBId());
+ }
+ }
+}
diff --git a/src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java b/src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java
index 0dad453..b868919 100644
--- a/src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java
+++ b/src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java
@@ -169,9 +169,20 @@
PageInfo<ParentPlatform> queryParentPlatformList(int page, int count);
/**
+ * 鑾峰彇鎵�鏈夊凡鍚敤鐨勫钩鍙�
+ * @return
+ */
+ List<ParentPlatform> queryEnableParentPlatformList(boolean enable);
+
+ /**
* 鑾峰彇涓婄骇骞冲彴
* @param platformGbId
* @return
*/
ParentPlatform queryParentPlatById(String platformGbId);
+
+ /**
+ * 鎵�鏈夊钩鍙扮绾�
+ */
+ void outlineForAllParentPlatform();
}
diff --git a/src/main/java/com/genersoft/iot/vmp/storager/dao/ParentPlatformMapper.java b/src/main/java/com/genersoft/iot/vmp/storager/dao/ParentPlatformMapper.java
index 4e7cd45..efc7426 100644
--- a/src/main/java/com/genersoft/iot/vmp/storager/dao/ParentPlatformMapper.java
+++ b/src/main/java/com/genersoft/iot/vmp/storager/dao/ParentPlatformMapper.java
@@ -49,6 +49,12 @@
@Select("SELECT * FROM parent_platform")
List<ParentPlatform> getParentPlatformList();
+ @Select("SELECT * FROM parent_platform WHERE enable=#{enable}")
+ List<ParentPlatform> getEnableParentPlatformList(boolean enable);
+
@Select("SELECT * FROM parent_platform WHERE deviceGBId=#{platformGbId}")
ParentPlatform getParentPlatById(String platformGbId);
+
+ @Update("UPDATE parent_platform SET status=false" )
+ void outlineForAllParentPlatform();
}
diff --git a/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java b/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java
index 92de14a..1513296 100644
--- a/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java
+++ b/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java
@@ -33,6 +33,7 @@
@Autowired
private ParentPlatformMapper platformMapper;
+
@Autowired
private IRedisCatchStorage redisCatchStorage;
@@ -252,5 +253,13 @@
return platformMapper.getParentPlatById(platformGbId);
}
+ @Override
+ public List<ParentPlatform> queryEnableParentPlatformList(boolean enable) {
+ return platformMapper.getEnableParentPlatformList(enable);
+ }
+ @Override
+ public void outlineForAllParentPlatform() {
+ platformMapper.outlineForAllParentPlatform();
+ }
}
diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java
index 950d8f5..ee77f01 100644
--- a/src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java
+++ b/src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java
@@ -25,6 +25,7 @@
@Autowired
private IVideoManagerStorager storager;
+
@Autowired
private IRedisCatchStorage redisCatchStorage;
--
Gitblit v1.8.0