修复未结束的推流无法下载

648540858

2021-12-07 381b3d15caa30e99c75f58a366b3b75cbbf01450

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

@@ -6,6 +6,7 @@
import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch;
import com.genersoft.iot.vmp.gb28181.bean.SendRtpItem;
import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
import com.genersoft.iot.vmp.service.bean.ThirdPartyGB;

import java.util.List;
import java.util.Map;
@@ -121,13 +122,13 @@
    /**
     * 在redis添加wvp的信息
     */
    void updateWVPInfo(String id, JSONObject jsonObject, int time);
    void updateWVPInfo(JSONObject jsonObject, int time);

    /**
     * 发送推流生成与推流消失消息
     * @param jsonObject 消息内容
     */
    void sendStreamChangeMsg(JSONObject jsonObject);
    void sendStreamChangeMsg(String type, JSONObject jsonObject);

    /**
     * 添加流信息到redis
@@ -135,7 +136,7 @@
     * @param app
     * @param streamId
     */
    void addPushStream(MediaServerItem mediaServerItem, String app, String streamId, StreamInfo streamInfo);
    void addStream(MediaServerItem mediaServerItem, String type, String app, String streamId, StreamInfo streamInfo);

    /**
     * 移除流信息从redis
@@ -143,7 +144,7 @@
     * @param app
     * @param streamId
     */
    void removePushStream(MediaServerItem mediaServerItem, String app, String streamId);
    void removeStream(MediaServerItem mediaServerItem, String type, String app, String streamId);

    /**
     * 开始下载录像时存入
@@ -152,4 +153,11 @@
    boolean startDownload(StreamInfo streamInfo);

    StreamInfo queryDownloadByStreamId(String streamId);

    /**
     * 查找第三方系统留下的国标预设值
     * @param queryKey
     * @return
     */
    ThirdPartyGB queryMemberNoGBId(String queryKey);
}