wvp-pro.git - Gitblit

package com.genersoft.iot.vmp.storager;
 
import com.alibaba.fastjson2.JSONObject;
import com.genersoft.iot.vmp.common.SystemAllInfo;
import com.genersoft.iot.vmp.gb28181.bean.AlarmChannelMessage;
import com.genersoft.iot.vmp.gb28181.bean.Device;
import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch;
import com.genersoft.iot.vmp.gb28181.bean.SendRtpItem;
import com.genersoft.iot.vmp.media.event.MediaArrivalEvent;
import com.genersoft.iot.vmp.media.zlm.dto.MediaServer;
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;
import com.genersoft.iot.vmp.service.bean.MessageForPushChannel;
import com.genersoft.iot.vmp.storager.dao.dto.PlatformRegisterInfo;
 
import java.util.List;
import java.util.Map;
 
public interface IRedisCatchStorage {
 
    /**
     * 计数器。为cseq进行计数
     *
     * @return
     */
    Long getCSEQ();
 
    void updatePlatformCatchInfo(ParentPlatformCatch parentPlatformCatch);
 
    ParentPlatformCatch queryPlatformCatchInfo(String platformGbId);
 
    void delPlatformCatchInfo(String platformGbId);
 
    void delPlatformKeepalive(String platformGbId);
 
    void delPlatformRegister(String platformGbId);
 
    void updatePlatformRegisterInfo(String callId, PlatformRegisterInfo platformRegisterInfo);
 
    PlatformRegisterInfo queryPlatformRegisterInfo(String callId);
 
    void delPlatformRegisterInfo(String callId);
 
    void updateSendRTPSever(SendRtpItem sendRtpItem);
 
    /**
     * 查询RTP推送信息缓存
     * @param platformGbId
     * @param channelId
     * @return sendRtpItem
     */
    SendRtpItem querySendRTPServer(String platformGbId, String channelId, String streamId, String callId);
 
    List<SendRtpItem> querySendRTPServer(String platformGbId);
 
    /**
     * 删除RTP推送信息缓存
     * @param platformGbId
     * @param channelId
     */
    void deleteSendRTPServer(String platformGbId, String channelId, String callId, String streamId);
 
    /**
     * 查询某个通道是否存在上级点播（RTP推送）
     * @param channelId
     */
    boolean isChannelSendingRTP(String channelId);
 
    /**
     * 在redis添加wvp的信息
     */
    void updateWVPInfo(JSONObject jsonObject, int time);
 
    /**
     * 发送推流生成与推流消失消息
     * @param jsonObject 消息内容
     */
    void sendStreamChangeMsg(String type, JSONObject jsonObject);
 
    /**
     * 发送报警消息
     * @param msg 消息内容
     */
    void sendAlarmMsg(AlarmChannelMessage msg);
 
    /**
     * 添加流信息到redis
     * @param mediaServerItem
     * @param app
     * @param streamId
     */
    void addStream(MediaServer mediaServerItem, String type, String app, String streamId, OnStreamChangedHookParam item);
 
    /**
     * 移除流信息从redis
     * @param mediaServerId
     * @param app
     * @param streamId
     */
    void removeStream(String mediaServerId, String type, String app, String streamId);
 
 
    /**
     * 移除流信息从redis
     * @param mediaServerId
     */
    void removeStream(String mediaServerId, String type);
 
    List<OnStreamChangedHookParam> getStreams(String mediaServerId, String pull);
 
    /**
     * 将device信息写入redis
     * @param device
     */
    void updateDevice(Device device);
 
    void removeDevice(String deviceId);
 
    /**
     * 获取Device
     */
    Device getDevice(String deviceId);
 
    void resetAllCSEQ();
 
    void updateGpsMsgInfo(GPSMsgInfo gpsMsgInfo);
 
    GPSMsgInfo getGpsMsgInfo(String gbId);
    List<GPSMsgInfo> getAllGpsMsgInfo();
 
    Long getSN(String method);
 
    void resetAllSN();
 
    OnStreamChangedHookParam getStreamInfo(String app, String streamId, String mediaServerId);
 
    void addCpuInfo(double cpuInfo);
 
    void addMemInfo(double memInfo);
 
    void addNetInfo(Map<String, Double> networkInterfaces);
 
    void sendMobilePositionMsg(JSONObject jsonObject);
 
    void sendStreamPushRequestedMsg(MessageForPushChannel messageForPushChannel);
 
    /**
     * 判断设备状态
     * @param deviceId 设备ID
     * @return
     */
    public boolean deviceIsOnline(String deviceId);
 
    /**
     * 存储推流的鉴权信息
     * @param app 应用名
     * @param stream 流
     * @param streamAuthorityInfo 鉴权信息
     */
    void updateStreamAuthorityInfo(String app, String stream, StreamAuthorityInfo streamAuthorityInfo);
 
    /**
     * 移除推流的鉴权信息
     * @param app 应用名
     * @param streamId 流
     */
    void removeStreamAuthorityInfo(String app, String streamId);
 
    /**
     * 获取推流的鉴权信息
     * @param app 应用名
     * @param stream 流
     * @return
     */
    StreamAuthorityInfo getStreamAuthorityInfo(String app, String stream);
 
    List<StreamAuthorityInfo> getAllStreamAuthorityInfo();
 
    /**
     * 发送redis消息 查询所有推流设备的状态
     */
    void sendStreamPushRequestedMsgForStatus();
 
    List<SendRtpItem> querySendRTPServerByChannelId(String channelId);
 
    List<SendRtpItem> querySendRTPServerByStream(String stream);
 
    SystemAllInfo getSystemInfo();
 
    int getPushStreamCount(String id);
 
    int getProxyStreamCount(String id);
 
    int getGbSendCount(String id);
 
    void addDiskInfo(List<Map<String, Object>> diskInfo);
 
    List<SendRtpItem> queryAllSendRTPServer();
 
    List<Device> getAllDevices();
 
    void removeAllDevice();
 
    void sendDeviceOrChannelStatus(String deviceId, String channelId, boolean online);
 
    void sendChannelAddOrDelete(String deviceId, String channelId, boolean add);
 
    void sendPlatformStartPlayMsg(MessageForPushChannel messageForPushChannel);
 
    void sendPlatformStopPlayMsg(MessageForPushChannel messageForPushChannel);
 
    void addPushListItem(String app, String stream, MediaArrivalEvent param);
 
    void removePushListItem(String app, String stream, String mediaServerId);
}