From 6282c81bc5d3da22eaa304ad564d15014bcc4a79 Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期二, 23 十一月 2021 11:35:23 +0800 Subject: [PATCH] 移除onvif实现 --- src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java | 72 ++++++++++++++++++++++++++++-------- 1 files changed, 56 insertions(+), 16 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 4ca25e2..e4313d9 100644 --- a/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java @@ -1,12 +1,12 @@ package com.genersoft.iot.vmp.storager; +import com.alibaba.fastjson.JSONObject; import com.genersoft.iot.vmp.common.StreamInfo; -import com.genersoft.iot.vmp.conf.MediaServerConfig; import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform; import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch; -import com.genersoft.iot.vmp.gb28181.bean.PlatformRegister; import com.genersoft.iot.vmp.gb28181.bean.SendRtpItem; +import java.util.List; import java.util.Map; public interface IRedisCatchStorage { @@ -37,20 +37,7 @@ StreamInfo queryPlaybackByStreamId(String steamId); - StreamInfo queryPlayByDevice(String deviceId, String code); - - /** - * 鏇存柊娴佸獟浣撲俊鎭� - * @param mediaServerConfig - * @return - */ - boolean updateMediaInfo(MediaServerConfig mediaServerConfig); - - /** - * 鑾峰彇娴佸獟浣撲俊鎭� - * @return - */ - MediaServerConfig getMediaInfo(); + StreamInfo queryPlayByDevice(String deviceId, String channelId); Map<String, StreamInfo> queryPlayByDeviceId(String deviceId); @@ -80,5 +67,58 @@ void delPlatformRegisterInfo(String callId); + void cleanPlatformRegisterInfos(); + void updateSendRTPSever(SendRtpItem sendRtpItem); + + /** + * 鏌ヨRTP鎺ㄩ�佷俊鎭紦瀛� + * @param platformGbId + * @param channelId + * @return sendRtpItem + */ + SendRtpItem querySendRTPServer(String platformGbId, String channelId); + + List<SendRtpItem> querySendRTPServer(String platformGbId); + + /** + * 鍒犻櫎RTP鎺ㄩ�佷俊鎭紦瀛� + * @param platformGbId + * @param channelId + */ + void deleteSendRTPServer(String platformGbId, String channelId); + + /** + * 鏌ヨ鏌愪釜閫氶亾鏄惁瀛樺湪涓婄骇鐐规挱锛圧TP鎺ㄩ�侊級 + * @param channelId + */ + boolean isChannelSendingRTP(String channelId); + + /** + * 娓呯┖鏌愪釜璁惧鐨勬墍鏈夌紦瀛� + * @param deviceId 璁惧ID + */ + void clearCatchByDeviceId(String deviceId); + + /** + * 鑾峰彇mediaServer鑺傜偣 + * @param mediaServerId + * @return + */ +// MediaServerItem getMediaInfo(String mediaServerId); + + /** + * 璁剧疆鎵�鏈夎澶囩绾� + */ + void outlineForAll(); + + /** + * 鑾峰彇鎵�鏈夊湪绾跨殑 + */ + List<String> getOnlineForAll(); + + /** + * 鍦╮edis娣诲姞wvp鐨勪俊鎭� + */ + void updateWVPInfo(JSONObject jsonObject); } -- Gitblit v1.8.0