From d09ee0c2ff93c799b0c19481f0890a5be5a2db03 Mon Sep 17 00:00:00 2001 From: 64850858 <648540858@qq.com> Date: 星期五, 18 六月 2021 19:44:55 +0800 Subject: [PATCH] 解决启动设置所有设备离线未删除redis记录 --- src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java | 23 ++++++++++++++++++----- 1 files changed, 18 insertions(+), 5 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 c1b42bc..649fb71 100644 --- a/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java @@ -1,11 +1,12 @@ package com.genersoft.iot.vmp.storager; import com.genersoft.iot.vmp.common.StreamInfo; -import com.genersoft.iot.vmp.conf.MediaServerConfig; +import com.genersoft.iot.vmp.media.zlm.ZLMServerConfig; import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform; import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch; import com.genersoft.iot.vmp.gb28181.bean.SendRtpItem; +import java.util.List; import java.util.Map; public interface IRedisCatchStorage { @@ -36,20 +37,20 @@ StreamInfo queryPlaybackByStreamId(String steamId); - StreamInfo queryPlayByDevice(String deviceId, String code); + StreamInfo queryPlayByDevice(String deviceId, String channelId); /** * 鏇存柊娴佸獟浣撲俊鎭� - * @param mediaServerConfig + * @param ZLMServerConfig * @return */ - boolean updateMediaInfo(MediaServerConfig mediaServerConfig); + boolean updateMediaInfo(ZLMServerConfig ZLMServerConfig); /** * 鑾峰彇娴佸獟浣撲俊鎭� * @return */ - MediaServerConfig getMediaInfo(); + ZLMServerConfig getMediaInfo(); Map<String, StreamInfo> queryPlayByDeviceId(String deviceId); @@ -91,6 +92,8 @@ */ SendRtpItem querySendRTPServer(String platformGbId, String channelId); + List<SendRtpItem> querySendRTPServer(String platformGbId); + /** * 鍒犻櫎RTP鎺ㄩ�佷俊鎭紦瀛� * @param platformGbId @@ -104,4 +107,14 @@ */ boolean isChannelSendingRTP(String channelId); + /** + * 娓呯┖鏌愪釜璁惧鐨勬墍鏈夌紦瀛� + * @param deviceId 璁惧ID + */ + void clearCatchByDeviceId(String deviceId); + + /** + * 璁剧疆鎵�鏈夎澶囩绾� + */ + void outlineForAll(); } -- Gitblit v1.8.0