From 0eee65bc424cbdb348052ba4ef6b91add28bc6a4 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期三, 24 十一月 2021 10:02:47 +0800
Subject: [PATCH] 保存拉流代理返回结果添加streamInfo
---
src/main/java/com/genersoft/iot/vmp/storager/dao/MediaServerMapper.java | 22 +++++++++++++++++-----
1 files changed, 17 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/storager/dao/MediaServerMapper.java b/src/main/java/com/genersoft/iot/vmp/storager/dao/MediaServerMapper.java
index 475ec6d..8cd5d6a 100644
--- a/src/main/java/com/genersoft/iot/vmp/storager/dao/MediaServerMapper.java
+++ b/src/main/java/com/genersoft/iot/vmp/storager/dao/MediaServerMapper.java
@@ -1,7 +1,5 @@
package com.genersoft.iot.vmp.storager.dao;
-import com.genersoft.iot.vmp.conf.MediaConfig;
-import com.genersoft.iot.vmp.media.zlm.dto.IMediaServerItem;
import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
@@ -34,7 +32,9 @@
"streamNoneReaderDelayMS, " +
"rtpEnable, " +
"rtpPortRange, " +
+ "sendRtpPortRange, " +
"recordAssistPort, " +
+ "defaultServer, " +
"createTime, " +
"updateTime" +
") VALUES " +
@@ -56,10 +56,12 @@
"${streamNoneReaderDelayMS}, " +
"${rtpEnable}, " +
"'${rtpPortRange}', " +
+ "'${sendRtpPortRange}', " +
"${recordAssistPort}, " +
+ "${defaultServer}, " +
"'${createTime}', " +
"'${updateTime}')")
- int add(IMediaServerItem mediaServerItem);
+ int add(MediaServerItem mediaServerItem);
@Update(value = {" <script>" +
"UPDATE media_server " +
@@ -79,11 +81,12 @@
"<if test=\"streamNoneReaderDelayMS != null\">, streamNoneReaderDelayMS=${streamNoneReaderDelayMS}</if>" +
"<if test=\"rtpEnable != null\">, rtpEnable=${rtpEnable}</if>" +
"<if test=\"rtpPortRange != null\">, rtpPortRange='${rtpPortRange}'</if>" +
+ "<if test=\"sendRtpPortRange != null\">, sendRtpPortRange='${sendRtpPortRange}'</if>" +
"<if test=\"secret != null\">, secret='${secret}'</if>" +
"<if test=\"recordAssistPort != null\">, recordAssistPort=${recordAssistPort}</if>" +
"WHERE id='${id}'"+
" </script>"})
- int update(IMediaServerItem mediaServerItem);
+ int update(MediaServerItem mediaServerItem);
@Select("SELECT * FROM media_server WHERE id='${id}'")
MediaServerItem queryOne(String id);
@@ -92,8 +95,17 @@
List<MediaServerItem> queryAll();
@Select("DELETE FROM media_server WHERE id='${id}'")
- int delOne(String secret);
+ void delOne(String id);
+
+ @Select("DELETE FROM media_server WHERE ip='${host}' and httpPort=${port}")
+ void delOneByIPAndPort(String host, int port);
+
+ @Select("DELETE FROM media_server WHERE defaultServer=1;")
+ void delDefault();
@Select("SELECT * FROM media_server WHERE ip='${host}' and httpPort=${port}")
MediaServerItem queryOneByHostAndPort(String host, int port);
+
+ @Select("SELECT * FROM media_server WHERE defaultServer=1")
+ MediaServerItem queryDefault();
}
--
Gitblit v1.8.0