648540858
2022-05-06 5d901b5e3f033e8b04e53420d68626cbd87431c8
src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java
@@ -7,6 +7,8 @@
import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
import com.genersoft.iot.vmp.media.zlm.dto.StreamPushItem;
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 java.util.List;
@@ -46,17 +48,15 @@
    StreamInfo queryPlayByStreamId(String steamId);
    StreamInfo queryPlaybackByStreamId(String steamId);
    StreamInfo queryPlayByDevice(String deviceId, String channelId);
    Map<String, StreamInfo> queryPlayByDeviceId(String deviceId);
    boolean startPlayback(StreamInfo stream);
    boolean startPlayback(StreamInfo stream, String callId);
    boolean stopPlayback(StreamInfo streamInfo);
    boolean stopPlayback(String deviceId, String channelId, String stream, String callId);
    StreamInfo queryPlaybackByDevice(String deviceId, String code);
    StreamInfo queryPlayback(String deviceId, String channelID, String stream, String callId);
    void updatePlatformCatchInfo(ParentPlatformCatch parentPlatformCatch);
@@ -88,7 +88,7 @@
     * @param channelId
     * @return sendRtpItem
     */
    SendRtpItem querySendRTPServer(String platformGbId, String channelId);
    SendRtpItem querySendRTPServer(String platformGbId, String channelId, String streamId, String callId);
    List<SendRtpItem> querySendRTPServer(String platformGbId);
@@ -97,7 +97,7 @@
     * @param platformGbId
     * @param channelId
     */
    void deleteSendRTPServer(String platformGbId, String channelId);
    void deleteSendRTPServer(String platformGbId, String channelId, String callId, String streamId);
    /**
     * 查询某个通道是否存在上级点播(RTP推送)
@@ -140,6 +140,12 @@
    void sendStreamChangeMsg(String type, JSONObject jsonObject);
    /**
     * 发送报警消息
     * @param msg 消息内容
     */
    void sendAlarmMsg(AlarmChannelMessage msg);
    /**
     * 添加流信息到redis
     * @param mediaServerItem
     * @param app
@@ -166,9 +172,11 @@
     * 开始下载录像时存入
     * @param streamInfo
     */
    boolean startDownload(StreamInfo streamInfo);
    boolean startDownload(StreamInfo streamInfo, String callId);
    StreamInfo queryDownloadByStreamId(String streamId);
    StreamInfo queryDownload(String deviceId, String channelId, String stream, String callId);
    boolean stopDownload(String deviceId, String channelId, String stream, String callId);
    /**
     * 查找第三方系统留下的国标预设值
@@ -203,21 +211,23 @@
    void resetAllSN();
    void updateSubscribe(String key, SubscribeInfo subscribeInfo);
    SubscribeInfo getSubscribe(String key);
    void delSubscribe(String key);
    MediaItem getStreamInfo(String app, String streamId, String mediaServerId);
    List<SubscribeInfo> getAllSubscribe();
    List<String> getAllSubscribePlatform();
    void addCpuInfo(double cpuInfo);
    void addMemInfo(double memInfo);
    void addNetInfo(Map<String, String> networkInterfaces);
    void sendMobilePositionMsg(JSONObject jsonObject);
    void sendStreamPushRequestedMsg(MessageForPushChannel messageForPushChannel);
    /**
     * 判断设备状态
     * @param deviceId 设备ID
     * @return
     */
    public boolean deviceIsOnline(String deviceId);
}