From 724b288232e1614de1b789d0910fe3e3db765e52 Mon Sep 17 00:00:00 2001
From: 648540858 <18010473990@163.com>
Date: 星期三, 04 八月 2021 18:00:22 +0800
Subject: [PATCH] 优化内存溢出的问题 优化zlm集群默认zlm的存储 添加报警的存储以及相关接口 添加单元测试
---
src/main/java/com/genersoft/iot/vmp/storager/dao/MediaServerMapper.java | 16 +++++++++++-----
1 files changed, 11 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..2167c55 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;
@@ -35,6 +33,7 @@
"rtpEnable, " +
"rtpPortRange, " +
"recordAssistPort, " +
+ "defaultServer, " +
"createTime, " +
"updateTime" +
") VALUES " +
@@ -57,9 +56,10 @@
"${rtpEnable}, " +
"'${rtpPortRange}', " +
"${recordAssistPort}, " +
+ "${defaultServer}, " +
"'${createTime}', " +
"'${updateTime}')")
- int add(IMediaServerItem mediaServerItem);
+ int add(MediaServerItem mediaServerItem);
@Update(value = {" <script>" +
"UPDATE media_server " +
@@ -83,7 +83,7 @@
"<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,7 +92,13 @@
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);
--
Gitblit v1.8.0