From faac93613a997e226998018e1165412b33989f32 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期五, 10 十二月 2021 11:08:04 +0800
Subject: [PATCH] 优化启动后清理过期信息的逻辑
---
src/main/java/com/genersoft/iot/vmp/storager/dao/GbStreamMapper.java | 14 ++++++++++++++
1 files changed, 14 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/storager/dao/GbStreamMapper.java b/src/main/java/com/genersoft/iot/vmp/storager/dao/GbStreamMapper.java
index f159925..9757b13 100644
--- a/src/main/java/com/genersoft/iot/vmp/storager/dao/GbStreamMapper.java
+++ b/src/main/java/com/genersoft/iot/vmp/storager/dao/GbStreamMapper.java
@@ -65,4 +65,18 @@
"SET status=${status} " +
"WHERE mediaServerId=#{mediaServerId} ")
void updateStatusByMediaServerId(String mediaServerId, boolean status);
+
+ @Select("SELECT * FROM gb_stream WHERE mediaServerId=#{mediaServerId}")
+ void delByMediaServerId(String mediaServerId);
+
+ @Delete("DELETE FROM gb_stream WHERE streamType=#{type} AND gbId=NULL AND mediaServerId=#{mediaServerId}")
+ void deleteWithoutGBId(String type, String mediaServerId);
+
+ @Delete("<script> "+
+ "DELETE FROM gb_stream where " +
+ "<foreach collection='streamProxyItemList' item='item' separator='or'>" +
+ "(app=#{item.app} and stream=#{item.stream}) " +
+ "</foreach>" +
+ "</script>")
+ void batchDel(List<StreamProxyItem> streamProxyItemList);
}
--
Gitblit v1.8.0