修复自动点播

648540858

2021-08-08 f4aa3e0ee8c988c0d7535ad1c76e68e23e400194

 src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java

@@ -1,8 +1,7 @@
package com.genersoft.iot.vmp.storager;

import com.genersoft.iot.vmp.common.RealVideo;
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.SendRtpItem;
@@ -38,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);

@@ -81,6 +67,8 @@

    void delPlatformRegisterInfo(String callId);

    void cleanPlatformRegisterInfos();

    void updateSendRTPSever(SendRtpItem sendRtpItem);

    /**
@@ -90,6 +78,8 @@
     * @return sendRtpItem
     */
    SendRtpItem querySendRTPServer(String platformGbId, String channelId);

    List<SendRtpItem> querySendRTPServer(String platformGbId);

    /**
     * 删除RTP推送信息缓存
@@ -105,14 +95,30 @@
    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
     */
    List<Object> getMediaList(int start, int end);
//    MediaServerItem getMediaInfo(String mediaServerId);

    /**
     * 设置所有设备离线
     */
    void outlineForAll();

    /**
     * 获取所有在线的
     */
    List<String> getOnlineForAll();

    /**
     * 在redis添加wvp的信息
     */
    void updateWVPInfo(JSONObject jsonObject);
}