From b6fa459bc3ae287abcb3292a873718fd08297e61 Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期五, 10 十二月 2021 18:38:58 +0800 Subject: [PATCH] 修复推流列表大数据量时批量删除的错误,修复推流列表分页查询错误 --- src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java | 23 ++++++++++++++++++++--- 1 files changed, 20 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java b/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java index 172213d..4f240d8 100644 --- a/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java @@ -6,6 +6,7 @@ import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch; import com.genersoft.iot.vmp.gb28181.bean.SendRtpItem; import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; +import com.genersoft.iot.vmp.service.bean.ThirdPartyGB; import java.util.List; import java.util.Map; @@ -121,7 +122,7 @@ /** * 鍦╮edis娣诲姞wvp鐨勪俊鎭� */ - void updateWVPInfo(String id, JSONObject jsonObject, int time); + void updateWVPInfo(JSONObject jsonObject, int time); /** * 鍙戦�佹帹娴佺敓鎴愪笌鎺ㄦ祦娑堝け娑堟伅 @@ -139,11 +140,18 @@ /** * 绉婚櫎娴佷俊鎭粠redis - * @param mediaServerItem + * @param mediaServerId * @param app * @param streamId */ - void removeStream(MediaServerItem mediaServerItem, String type, String app, String streamId); + void removeStream(String mediaServerId, String type, String app, String streamId); + + + /** + * 绉婚櫎娴佷俊鎭粠redis + * @param mediaServerId + */ + void removeStream(String mediaServerId, String type); /** * 寮�濮嬩笅杞藉綍鍍忔椂瀛樺叆 @@ -152,4 +160,13 @@ boolean startDownload(StreamInfo streamInfo); StreamInfo queryDownloadByStreamId(String streamId); + + /** + * 鏌ユ壘绗笁鏂圭郴缁熺暀涓嬬殑鍥芥爣棰勮鍊� + * @param queryKey + * @return + */ + ThirdPartyGB queryMemberNoGBId(String queryKey); + + List<StreamInfo> getStreams(String mediaServerId, String pull); } -- Gitblit v1.8.0