648540858
2023-08-18 b63a89a0a83dfddab0d714bb9aad90114ab9d514
src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java
@@ -5,9 +5,9 @@
import com.genersoft.iot.vmp.common.SystemAllInfo;
import com.genersoft.iot.vmp.gb28181.bean.*;
import com.genersoft.iot.vmp.media.zlm.dto.*;
import com.genersoft.iot.vmp.media.zlm.dto.hook.OnStreamChangedHookParam;
import com.genersoft.iot.vmp.service.bean.GPSMsgInfo;
import com.genersoft.iot.vmp.service.bean.MessageForPushChannel;
import com.genersoft.iot.vmp.service.bean.SSRCInfo;
import com.genersoft.iot.vmp.service.bean.ThirdPartyGB;
import com.genersoft.iot.vmp.storager.dao.dto.PlatformRegisterInfo;
@@ -131,7 +131,7 @@
     * @param app
     * @param streamId
     */
    void addStream(MediaServerItem mediaServerItem, String type, String app, String streamId, MediaItem item);
    void addStream(MediaServerItem mediaServerItem, String type, String app, String streamId, OnStreamChangedHookParam item);
    /**
     * 移除流信息从redis
@@ -165,7 +165,7 @@
     */
    ThirdPartyGB queryMemberNoGBId(String queryKey);
    List<MediaItem> getStreams(String mediaServerId, String pull);
    List<OnStreamChangedHookParam> getStreams(String mediaServerId, String pull);
    /**
     * 将device信息写入redis
@@ -191,7 +191,7 @@
    void resetAllSN();
    MediaItem getStreamInfo(String app, String streamId, String mediaServerId);
    OnStreamChangedHookParam getStreamInfo(String app, String streamId, String mediaServerId);
    void addCpuInfo(double cpuInfo);
@@ -233,6 +233,8 @@
     */
    StreamAuthorityInfo getStreamAuthorityInfo(String app, String stream);
    List<StreamAuthorityInfo> getAllStreamAuthorityInfo();
    /**
     * 发送redis消息 查询所有推流设备的状态
     */
@@ -256,4 +258,13 @@
    List<SendRtpItem> queryAllSendRTPServer();
    List<Device> getAllDevices();
    void removeAllDevice();
    void sendDeviceOrChannelStatus(String deviceId, String channelId, boolean online);
    void sendPlatformStartPlayMsg(MessageForPushChannel messageForPushChannel);
    void sendPlatformStopPlayMsg(MessageForPushChannel messageForPushChannel);
}