From 1a9e49d9ff210e39f6297150db758906a4f02e6f Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Fri, 19 Aug 2022 17:11:51 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BE=9D=E8=B5=96=E5=8C=85=E7=89=88=E6=9C=AC?=
=?UTF-8?q?=E5=8D=87=E7=BA=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
pom.xml | 44 ++--
.../genersoft/iot/vmp/VManageBootstrap.java | 2 -
.../genersoft/iot/vmp/common/StreamInfo.java | 1 -
.../genersoft/iot/vmp/conf/DynamicTask.java | 17 +-
.../iot/vmp/conf/{ => redis}/RedisConfig.java | 177 ++++++++--------
.../iot/vmp/gb28181/bean/Device.java | 33 ++-
.../iot/vmp/gb28181/bean/DeviceAlarm.java | 19 +-
.../iot/vmp/gb28181/bean/DeviceChannel.java | 46 ++++-
.../iot/vmp/gb28181/bean/GbStream.java | 15 ++
.../iot/vmp/gb28181/bean/ParentPlatform.java | 36 ++++
.../iot/vmp/gb28181/bean/PlatformCatalog.java | 14 ++
.../vmp/gb28181/bean/PlatformGbStream.java | 8 +
.../iot/vmp/gb28181/bean/SyncStatus.java | 8 +-
.../KeepaliveTimeoutListenerForPlatform.java | 81 --------
.../iot/vmp/gb28181/session/SsrcConfig.java | 8 +
.../session/VideoStreamSessionManager.java | 23 +--
.../vmp/media/zlm/dto/MediaServerItem.java | 30 +++
.../vmp/media/zlm/dto/StreamProxyItem.java | 23 ++-
.../iot/vmp/media/zlm/dto/StreamPushItem.java | 22 +-
.../service/impl/MediaServerServiceImpl.java | 73 +++----
.../service/impl/RedisGbPlayMsgListener.java | 14 +-
.../service/impl/RedisStreamMsgListener.java | 9 -
.../storager/impl/RedisCatchStorageImpl.java | 190 +++++++++---------
.../iot/vmp/utils/redis/RedisUtil.java | 137 ++++++-------
.../vmp/vmanager/bean/BatchGBStreamParam.java | 6 +
.../iot/vmp/vmanager/bean/WVPResult.java | 6 +
.../MobilePositionController.java | 51 ++---
.../gb28181/SseController/SseController.java | 12 +-
.../gb28181/alarm/AlarmController.java | 156 +++++++-------
.../vmanager/gb28181/device/DeviceConfig.java | 35 ++--
.../gb28181/device/DeviceControl.java | 115 +++++------
.../vmanager/gb28181/device/DeviceQuery.java | 180 +++++++----------
.../gb28181/gbStream/GbStreamController.java | 37 ++--
.../gb28181/gbStream/bean/GbStreamParam.java | 5 +
.../gb28181/media/MediaController.java | 25 +--
.../gb28181/platform/PlatformController.java | 122 ++++-------
.../gb28181/platform/bean/ChannelReduce.java | 11 +
.../platform/bean/UpdateChannelParam.java | 13 ++
.../vmanager/gb28181/play/PlayController.java | 48 ++---
.../gb28181/playback/PlaybackController.java | 70 +++----
.../vmanager/gb28181/ptz/PtzController.java | 53 +++--
.../gb28181/record/GBRecordController.java | 60 +++---
.../iot/vmp/vmanager/log/LogController.java | 29 ++-
.../vmp/vmanager/record/RecordController.java | 6 +-
.../vmp/vmanager/server/ServerController.java | 104 +++++-----
.../streamProxy/StreamProxyController.java | 57 +++---
.../streamPush/StreamPushController.java | 63 ++----
.../iot/vmp/vmanager/user/RoleController.java | 27 +--
.../iot/vmp/vmanager/user/UserController.java | 75 +++----
src/main/resources/all-application.yml | 2 +-
src/main/resources/application-docker.yml | 2 +-
.../impl/DeviceAlarmServiceImplTest.java | 120 -----------
.../vmp/service/impl/RoleServiceImplTest.java | 56 ------
.../vmp/service/impl/UserServiceImplTest.java | 66 ------
54 files changed, 1153 insertions(+), 1489 deletions(-)
rename src/main/java/com/genersoft/iot/vmp/conf/{ => redis}/RedisConfig.java (89%)
delete mode 100644 src/main/java/com/genersoft/iot/vmp/gb28181/event/offline/KeepaliveTimeoutListenerForPlatform.java
delete mode 100644 src/test/java/com/genersoft/iot/vmp/service/impl/DeviceAlarmServiceImplTest.java
delete mode 100644 src/test/java/com/genersoft/iot/vmp/service/impl/RoleServiceImplTest.java
delete mode 100644 src/test/java/com/genersoft/iot/vmp/service/impl/UserServiceImplTest.java
diff --git a/pom.xml b/pom.xml
index 2abd9d8c..2b9a838c 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,7 +6,7 @@
org.springframework.boot
spring-boot-starter-parent
- 2.3.5.RELEASE
+ 2.7.2
com.genersoft
@@ -47,7 +47,6 @@
UTF-8
MMddHHmm
3.1.1
- 3.1.0
${project.build.directory}/generated-snippets
@@ -74,7 +73,7 @@
org.mybatis.spring.boot
mybatis-spring-boot-starter
- 2.1.4
+ 2.2.2
com.zaxxer
@@ -91,36 +90,35 @@
com.alibaba
druid-spring-boot-starter
- 1.1.22
+ 1.2.11
mysql
mysql-connector-java
- 8.0.22
+ 8.0.30
com.github.pagehelper
pagehelper-spring-boot-starter
- 1.4.1
+ 1.4.3
-
- io.springfox
- springfox-boot-starter
- 3.0.0
-
-
- com.github.xiaoymin
- knife4j-spring-boot-starter
- 3.0.2
+ org.springdoc
+ springdoc-openapi-ui
+ 1.6.10
+
+ com.github.xiaoymin
+ knife4j-springdoc-ui
+ 3.0.3
+
@@ -145,7 +143,7 @@
org.slf4j
log4j-over-slf4j
- 1.7.35
+ 1.7.36
@@ -167,14 +165,14 @@
com.squareup.okhttp3
okhttp
- 4.9.0
+ 4.10.0
com.squareup.okhttp3
logging-interceptor
- 4.9.0
+ 4.10.0
@@ -183,7 +181,7 @@
io.github.rburgst
okhttp-digest
- 2.5
+ 2.7
@@ -197,21 +195,21 @@
org.mitre.dsmiley.httpproxy
smiley-http-proxy-servlet
- 1.12
+ 1.12.1
com.alibaba
easyexcel
- 3.0.4
+ 3.1.1
com.github.oshi
oshi-core
- 6.1.0
+ 6.2.2
@@ -231,7 +229,7 @@
com.google.guava
guava
- 31.0.1-jre
+ 31.1-jre
diff --git a/src/main/java/com/genersoft/iot/vmp/VManageBootstrap.java b/src/main/java/com/genersoft/iot/vmp/VManageBootstrap.java
index 3bac82d6..21002c41 100644
--- a/src/main/java/com/genersoft/iot/vmp/VManageBootstrap.java
+++ b/src/main/java/com/genersoft/iot/vmp/VManageBootstrap.java
@@ -8,7 +8,6 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletComponentScan;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.scheduling.annotation.EnableScheduling;
-import springfox.documentation.oas.annotations.EnableOpenApi;
/**
* 启动类
@@ -16,7 +15,6 @@ import springfox.documentation.oas.annotations.EnableOpenApi;
@ServletComponentScan("com.genersoft.iot.vmp.conf")
@SpringBootApplication
@EnableScheduling
-@EnableOpenApi
@EnableDruidSupport
public class VManageBootstrap extends LogManager {
private static String[] args;
diff --git a/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java b/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java
index b5788aed..4f717f05 100644
--- a/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java
+++ b/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java
@@ -1,6 +1,5 @@
package com.genersoft.iot.vmp.common;
-import com.alibaba.fastjson.JSONArray;
public class StreamInfo {
diff --git a/src/main/java/com/genersoft/iot/vmp/conf/DynamicTask.java b/src/main/java/com/genersoft/iot/vmp/conf/DynamicTask.java
index 1885632a..b2c23580 100644
--- a/src/main/java/com/genersoft/iot/vmp/conf/DynamicTask.java
+++ b/src/main/java/com/genersoft/iot/vmp/conf/DynamicTask.java
@@ -9,6 +9,7 @@ import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.stereotype.Component;
+import javax.annotation.PostConstruct;
import java.time.Instant;
import java.util.Map;
import java.util.Set;
@@ -25,20 +26,18 @@ public class DynamicTask {
private final Logger logger = LoggerFactory.getLogger(DynamicTask.class);
- @Autowired
private ThreadPoolTaskScheduler threadPoolTaskScheduler;
private final Map> futureMap = new ConcurrentHashMap<>();
private final Map runnableMap = new ConcurrentHashMap<>();
- @Bean
- public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
- ThreadPoolTaskScheduler schedulerPool = new ThreadPoolTaskScheduler();
- schedulerPool.setPoolSize(300);
- schedulerPool.setWaitForTasksToCompleteOnShutdown(true);
- schedulerPool.setAwaitTerminationSeconds(10);
- return schedulerPool;
-
+ @PostConstruct
+ public void DynamicTask() {
+ threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
+ threadPoolTaskScheduler.setPoolSize(300);
+ threadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true);
+ threadPoolTaskScheduler.setAwaitTerminationSeconds(10);
+ threadPoolTaskScheduler.initialize();
}
/**
diff --git a/src/main/java/com/genersoft/iot/vmp/conf/RedisConfig.java b/src/main/java/com/genersoft/iot/vmp/conf/redis/RedisConfig.java
similarity index 89%
rename from src/main/java/com/genersoft/iot/vmp/conf/RedisConfig.java
rename to src/main/java/com/genersoft/iot/vmp/conf/redis/RedisConfig.java
index 449a0181..7bdeab46 100644
--- a/src/main/java/com/genersoft/iot/vmp/conf/RedisConfig.java
+++ b/src/main/java/com/genersoft/iot/vmp/conf/redis/RedisConfig.java
@@ -1,90 +1,87 @@
-package com.genersoft.iot.vmp.conf;
-
-import com.alibaba.fastjson.parser.ParserConfig;
-import com.genersoft.iot.vmp.common.VideoManagerConstants;
-import com.genersoft.iot.vmp.service.impl.*;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.cache.annotation.CachingConfigurerSupport;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.listener.PatternTopic;
-import org.springframework.data.redis.listener.RedisMessageListenerContainer;
-import org.springframework.data.redis.serializer.StringRedisSerializer;
-
-import com.genersoft.iot.vmp.utils.redis.FastJsonRedisSerializer;
-
-
-/**
- * @description:Redis中间件配置类,使用spring-data-redis集成,自动从application.yml中加载redis配置
- * @author: swwheihei
- * @date: 2019年5月30日 上午10:58:25
- *
- */
-@Configuration
-public class RedisConfig extends CachingConfigurerSupport {
-
- @Autowired
- private RedisGpsMsgListener redisGPSMsgListener;
-
- @Autowired
- private RedisAlarmMsgListener redisAlarmMsgListener;
-
- @Autowired
- private RedisStreamMsgListener redisStreamMsgListener;
-
- @Autowired
- private RedisGbPlayMsgListener redisGbPlayMsgListener;
-
- @Autowired
- private RedisPushStreamStatusMsgListener redisPushStreamStatusMsgListener;
-
- @Autowired
- private RedisPushStreamListMsgListener redisPushStreamListMsgListener;
-
- @Bean
- public RedisTemplate