From afbec289067cc7f284dd135366b0f6febf13126b Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期一, 11 七月 2022 16:21:01 +0800 Subject: [PATCH] 增加推流鉴权。保护服务安全 --- src/main/java/com/genersoft/iot/vmp/storager/dao/GbStreamMapper.java | 12 +----------- 1 files changed, 1 insertions(+), 11 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 fa8381c..e8d23a8 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 @@ -68,7 +68,7 @@ List<GbStream> selectAll(String platformId, String catalogId, String query, Boolean pushing, String mediaServerId); @Select("SELECT * FROM gb_stream WHERE app=#{app} AND stream=#{stream}") - StreamProxyItem selectOne(String app, String stream); + GbStream selectOne(String app, String stream); @Select("SELECT * FROM gb_stream WHERE gbId=#{gbId}") List<GbStream> selectByGBId(String gbId); @@ -87,16 +87,6 @@ @Select("SELECT gs.* FROM gb_stream gs LEFT JOIN platform_gb_stream pgs " + "ON gs.gbStreamId = pgs.gbStreamId WHERE pgs.gbStreamId is NULL") List<GbStream> queryStreamNotInPlatform(); - - @Update("UPDATE gb_stream " + - "SET status=${status} " + - "WHERE app=#{app} AND stream=#{stream}") - int setStatus(String app, String stream, boolean status); - - @Update("UPDATE gb_stream " + - "SET status=${status} " + - "WHERE mediaServerId=#{mediaServerId} ") - void updateStatusByMediaServerId(String mediaServerId, boolean status); @Delete("DELETE FROM gb_stream WHERE streamType=#{type} AND gbId=NULL AND mediaServerId=#{mediaServerId}") void deleteWithoutGBId(String type, String mediaServerId); -- Gitblit v1.8.0