Merge pull request #1559 from koisi-io/fix

648540858

2024-08-10 baeffa4311622a8f087fd20b5fe47ed9d6fccf41

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

@@ -3,7 +3,9 @@
import com.alibaba.fastjson2.JSONObject;
import com.genersoft.iot.vmp.common.SystemAllInfo;
import com.genersoft.iot.vmp.gb28181.bean.*;
import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
import com.genersoft.iot.vmp.media.bean.MediaInfo;
import com.genersoft.iot.vmp.media.bean.MediaServer;
import com.genersoft.iot.vmp.media.event.media.MediaArrivalEvent;
import com.genersoft.iot.vmp.media.zlm.dto.StreamAuthorityInfo;
import com.genersoft.iot.vmp.media.zlm.dto.hook.OnStreamChangedHookParam;
import com.genersoft.iot.vmp.service.bean.GPSMsgInfo;
@@ -88,7 +90,7 @@
     * @param app
     * @param streamId
     */
    void addStream(MediaServerItem mediaServerItem, String type, String app, String streamId, OnStreamChangedHookParam item);
    void addStream(MediaServer mediaServerItem, String type, String app, String streamId, MediaInfo item);

    /**
     * 移除流信息从redis
@@ -105,7 +107,7 @@
     */
    void removeStream(String mediaServerId, String type);

    List<OnStreamChangedHookParam> getStreams(String mediaServerId, String pull);
    List<MediaInfo> getStreams(String mediaServerId, String pull);

    /**
     * 将device信息写入redis
@@ -131,7 +133,9 @@

    void resetAllSN();

    OnStreamChangedHookParam getStreamInfo(String app, String streamId, String mediaServerId);
    MediaInfo getStreamInfo(String app, String streamId, String mediaServerId);

    MediaInfo getProxyStream(String app, String streamId);

    void addCpuInfo(double cpuInfo);

@@ -206,11 +210,11 @@

    void sendChannelAddOrDelete(String deviceId, String channelId, boolean add);

    void sendPlatformStartPlayMsg(MessageForPushChannel messageForPushChannel);
    void sendPlatformStartPlayMsg(SendRtpItem sendRtpItem, ParentPlatform platform);

    void sendPlatformStopPlayMsg(SendRtpItem sendRtpItem, ParentPlatform platform);

    void addPushListItem(String app, String stream, OnStreamChangedHookParam param);
    void addPushListItem(String app, String stream, MediaArrivalEvent param);

    OnStreamChangedHookParam getPushListItem(String app, String stream);