WuPeng
2022-11-05 ab909feedf43a44780a6198cbd4772e9d7713fdf
src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java
@@ -1,13 +1,15 @@
package com.genersoft.iot.vmp.storager;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson2.JSONObject;
import com.genersoft.iot.vmp.common.StreamInfo;
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.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;
import java.util.List;
import java.util.Map;
@@ -55,23 +57,21 @@
    StreamInfo queryPlayback(String deviceId, String channelID, String stream, String callId);
    String queryPlaybackForKey(String deviceId, String channelId, String stream, String callId);
    void updatePlatformCatchInfo(ParentPlatformCatch parentPlatformCatch);
    ParentPlatformCatch queryPlatformCatchInfo(String platformGbId);
    void delPlatformCatchInfo(String platformGbId);
    void updatePlatformKeepalive(ParentPlatform parentPlatform);
    void delPlatformKeepalive(String platformGbId);
    void updatePlatformRegister(ParentPlatform parentPlatform);
    void delPlatformRegister(String platformGbId);
    void updatePlatformRegisterInfo(String callId, String platformGbId);
    void updatePlatformRegisterInfo(String callId, PlatformRegisterInfo platformRegisterInfo);
    String queryPlatformRegisterInfo(String callId);
    PlatformRegisterInfo queryPlatformRegisterInfo(String callId);
    void delPlatformRegisterInfo(String callId);
@@ -197,7 +197,7 @@
    void addMemInfo(double memInfo);
    void addNetInfo(Map<String, String> networkInterfaces);
    void addNetInfo(Map<String, Double> networkInterfaces);
    void sendMobilePositionMsg(JSONObject jsonObject);
@@ -239,4 +239,21 @@
    void sendStreamPushRequestedMsgForStatus();
    List<SendRtpItem> querySendRTPServerByChnnelId(String channelId);
    List<SendRtpItem> querySendRTPServerByStream(String stream);
    SystemAllInfo getSystemInfo();
    int getPushStreamCount(String id);
    int getProxyStreamCount(String id);
    int getGbReceiveCount(String id);
    int getGbSendCount(String id);
    void addDiskInfo(List<Map<String, Object>> diskInfo);
    List<SendRtpItem> queryAllSendRTPServer();
}