From 913d4bdc8fbf74782b155b5e20dbda2398400c1f Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Tue, 19 Dec 2023 23:17:58 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=8B=89=E6=B5=81=E4=BB=A3?=
=?UTF-8?q?=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../iot/vmp/common/CommonGbChannel.java | 10 +-
.../cmd/impl/SIPCommanderFroPlatform.java | 8 +-
.../vmp/storager/dao/CommonChannelMapper.java | 132 +++++++++---------
.../vmp/storager/dao/StreamProxyMapper.java | 4 +-
.../vmp/storager/dao/StreamPushMapper.java | 2 +-
5 files changed, 79 insertions(+), 77 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/common/CommonGbChannel.java b/src/main/java/com/genersoft/iot/vmp/common/CommonGbChannel.java
index 009c1bf0..a8916ff4 100644
--- a/src/main/java/com/genersoft/iot/vmp/common/CommonGbChannel.java
+++ b/src/main/java/com/genersoft/iot/vmp/common/CommonGbChannel.java
@@ -299,7 +299,7 @@ public class CommonGbChannel {
* 时域编码能力,取值0:不支持;1:1级增强;2:2级增强;3:3级增强(可选)
*/
@Schema(description = "空域编码能力,取值0:不支持;1:1级增强(1个增强层);2:2级增强(2个增强层);3:3级增强(3个增强层)(可选)")
- private Integer SVCSpaceSupportMode;
+ private Integer commonGbSVCSpaceSupportMode;
/**
* 时域编码能力,取值0:不支持;1:1级增强;2:2级增强;3:3级增强(可选)
@@ -786,11 +786,11 @@ public class CommonGbChannel {
return commonGbChannel;
}
- public Integer getSVCSpaceSupportMode() {
- return SVCSpaceSupportMode;
+ public Integer getCommonGbSVCSpaceSupportMode() {
+ return commonGbSVCSpaceSupportMode;
}
- public void setSVCSpaceSupportMode(Integer SVCSpaceSupportMode) {
- this.SVCSpaceSupportMode = SVCSpaceSupportMode;
+ public void setCommonGbSVCSpaceSupportMode(Integer commonGbSVCSpaceSupportMode) {
+ this.commonGbSVCSpaceSupportMode = commonGbSVCSpaceSupportMode;
}
}
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderFroPlatform.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderFroPlatform.java
index ce4086a8..ac6bc43b 100755
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderFroPlatform.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderFroPlatform.java
@@ -295,8 +295,8 @@ public class SIPCommanderFroPlatform implements ISIPCommanderForPlatform {
if (!ObjectUtils.isEmpty(channel.getCommonGbDownloadSpeed())) {
catalogXml.append("" + channel.getCommonGbDownloadSpeed() + "\r\n");
}
- if (!ObjectUtils.isEmpty(channel.getSVCSpaceSupportMode())) {
- catalogXml.append("" + channel.getSVCSpaceSupportMode() + "\r\n");
+ if (!ObjectUtils.isEmpty(channel.getCommonGbSVCSpaceSupportMode())) {
+ catalogXml.append("" + channel.getCommonGbSVCSpaceSupportMode() + "\r\n");
}
if (!ObjectUtils.isEmpty(channel.getCommonGbSVCTimeSupportMode())) {
catalogXml.append("" + channel.getCommonGbSVCTimeSupportMode() + "\r\n");
@@ -654,8 +654,8 @@ public class SIPCommanderFroPlatform implements ISIPCommanderForPlatform {
if (!ObjectUtils.isEmpty(channel.getCommonGbDownloadSpeed())) {
catalogXml.append("" + channel.getCommonGbDownloadSpeed() + "\r\n");
}
- if (!ObjectUtils.isEmpty(channel.getSVCSpaceSupportMode())) {
- catalogXml.append("" + channel.getSVCSpaceSupportMode() + "\r\n");
+ if (!ObjectUtils.isEmpty(channel.getCommonGbSVCSpaceSupportMode())) {
+ catalogXml.append("" + channel.getCommonGbSVCSpaceSupportMode() + "\r\n");
}
if (!ObjectUtils.isEmpty(channel.getCommonGbSVCTimeSupportMode())) {
catalogXml.append("" + channel.getCommonGbSVCTimeSupportMode() + "\r\n");
diff --git a/src/main/java/com/genersoft/iot/vmp/storager/dao/CommonChannelMapper.java b/src/main/java/com/genersoft/iot/vmp/storager/dao/CommonChannelMapper.java
index 237977d9..1be3b8e9 100644
--- a/src/main/java/com/genersoft/iot/vmp/storager/dao/CommonChannelMapper.java
+++ b/src/main/java/com/genersoft/iot/vmp/storager/dao/CommonChannelMapper.java
@@ -76,82 +76,84 @@ public interface CommonChannelMapper {
@Insert(value = "")
@Options(useGeneratedKeys=true, keyProperty="commonGbId", keyColumn="common_gb_id")
- int add(CommonGbChannel channel);
+ int add(CommonGbChannel commonGbChannel);
@Delete("delete from wvp_common_channel where common_gb_device_id = #{channelId}")
int deleteByDeviceID(String channelId);
diff --git a/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamProxyMapper.java b/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamProxyMapper.java
index eee3bfb9..07275b92 100755
--- a/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamProxyMapper.java
+++ b/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamProxyMapper.java
@@ -14,10 +14,10 @@ public interface StreamProxyMapper {
@Insert("INSERT INTO wvp_stream_proxy (type, name, app, stream,media_server_id, url, src_url, dst_url, " +
"timeout_ms, ffmpeg_cmd_key, rtp_type, enable_audio, enable_mp4, enable, status, stream_key, " +
- "enable_remove_none_reader, enable_disable_none_reader, create_time) VALUES " +
+ "enable_remove_none_reader, enable_disable_none_reader, create_time, longitude, latitude, common_gb_channel_id) VALUES " +
"(#{type}, #{name}, #{app}, #{stream}, #{mediaServerId}, #{url}, #{srcUrl}, #{dstUrl}, " +
"#{timeoutMs}, #{ffmpegCmdKey}, #{rtpType}, #{enableAudio}, #{enableMp4}, #{enable}, #{status}, #{streamKey}, " +
- "#{enableRemoveNoneReader}, #{enableDisableNoneReader}, #{createTime} )")
+ "#{enableRemoveNoneReader}, #{enableDisableNoneReader}, #{createTime} , #{longitude} , #{latitude}, #{commonGbChannelId} )")
int add(StreamProxy streamProxy);
@Update("UPDATE wvp_stream_proxy " +
diff --git a/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamPushMapper.java b/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamPushMapper.java
index a9dbe79e..c5884d89 100755
--- a/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamPushMapper.java
+++ b/src/main/java/com/genersoft/iot/vmp/storager/dao/StreamPushMapper.java
@@ -109,7 +109,7 @@ public interface StreamPushMapper {
@Select("SELECT * FROM wvp_stream_push WHERE media_server_id=#{mediaServerId}")
List selectAllByMediaServerId(String mediaServerId);
- @Select("SELECT sp.* FROM wvp_stream_push sp WHERE sp.media_server_id=#{mediaServerId} and sp.gb_id is null")
+ @Select("SELECT * FROM wvp_stream_push WHERE media_server_id=#{mediaServerId} and gb_id is null")
List selectAllByMediaServerIdWithOutGbID(String mediaServerId);
@Update("UPDATE wvp_stream_push " +