| | |
| | | package com.genersoft.iot.vmp.storager; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.genersoft.iot.vmp.common.RealVideo; |
| | | 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.SendRtpItem; |
| | |
| | | |
| | | 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); |
| | | |
| | |
| | | */ |
| | | SendRtpItem querySendRTPServer(String platformGbId, String channelId); |
| | | |
| | | List<SendRtpItem> querySendRTPServer(String platformGbId); |
| | | |
| | | /** |
| | | * 删除RTP推送信息缓存 |
| | | * @param platformGbId |
| | |
| | | boolean isChannelSendingRTP(String channelId); |
| | | |
| | | /** |
| | | * 更新媒体流列表 |
| | | * @param mediaList |
| | | * 清空某个设备的所有缓存 |
| | | * @param deviceId 设备ID |
| | | */ |
| | | void updateMediaList(List<RealVideo> mediaList); |
| | | void clearCatchByDeviceId(String deviceId); |
| | | |
| | | /** |
| | | * 获取当前媒体流列表 |
| | | * @return List<RealVideo> |
| | | * 获取mediaServer节点 |
| | | * @param mediaServerId |
| | | * @return |
| | | */ |
| | | JSONObject getMediaList(int start, int end); |
| | | // MediaServerItem getMediaInfo(String mediaServerId); |
| | | |
| | | /** |
| | | * 设置所有设备离线 |
| | | */ |
| | | void outlineForAll(); |
| | | |
| | | /** |
| | | * 获取所有在线的 |
| | | */ |
| | | List<String> getOnlineForAll(); |
| | | |
| | | /** |
| | | * 在redis添加wvp的信息 |
| | | */ |
| | | void updateWVPInfo(JSONObject jsonObject); |
| | | } |