规范数据库，添加必要约束，优化通道批量导入功能

648540858

2022-02-24 a42dda2bd3cc1cf8c20cc61e7ad9211eadecbaf3

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

@@ -3,7 +3,9 @@
import com.alibaba.fastjson.JSONObject;
import com.genersoft.iot.vmp.common.StreamInfo;
import com.genersoft.iot.vmp.gb28181.bean.*;
import com.genersoft.iot.vmp.media.zlm.dto.MediaItem;
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.ThirdPartyGB;

@@ -143,7 +145,7 @@
     * @param app
     * @param streamId
     */
    void addStream(MediaServerItem mediaServerItem, String type, String app, String streamId, StreamInfo streamInfo);
    void addStream(MediaServerItem mediaServerItem, String type, String app, String streamId, MediaItem item);

    /**
     * 移除流信息从redis
@@ -175,7 +177,7 @@
     */
    ThirdPartyGB queryMemberNoGBId(String queryKey);

    List<StreamInfo> getStreams(String mediaServerId, String pull);
    List<MediaItem> getStreams(String mediaServerId, String pull);

    /**
     * 将device信息写入redis
@@ -206,4 +208,16 @@
    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);
}