From 0acf13445a2e3120f3d3599238401c9f2885d711 Mon Sep 17 00:00:00 2001 From: lawrencehj <1934378145@qq.com> Date: 星期三, 23 六月 2021 16:21:12 +0800 Subject: [PATCH] 改为fmp4截图 --- src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java | 72 +++++++++++++++++++++++++++++++++-- 1 files changed, 67 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 8bc78b9..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,8 +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 { @@ -33,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); @@ -55,4 +59,62 @@ boolean stopPlayback(StreamInfo streamInfo); StreamInfo queryPlaybackByDevice(String deviceId, String code); + + void updatePlatformCatchInfo(ParentPlatformCatch parentPlatformCatch); + + ParentPlatformCatch queryPlatformCatchInfo(String platformGbId); + + void delPlatformCatchInfo(String platformGbId); + + void updatePlatformKeepalive(ParentPlatform parentPlatform); + + void delPlatformKeepalive(String platformGbId); + + void updatePlatformRegister(ParentPlatform parentPlatform); + + void delPlatformRegister(String platformGbId); + + void updatePlatformRegisterInfo(String callId, String platformGbId); + + String queryPlatformRegisterInfo(String callId); + + 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); + + /** + * 璁剧疆鎵�鏈夎澶囩绾� + */ + void outlineForAll(); } -- Gitblit v1.8.0