搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2023-03-17 c3ce2bc5d069ba57309567aee4ae418bc0cf75ed 
 src/main/java/com/genersoft/iot/vmp/storager/impl/RedisCatchStorageImpl.java


@@ -1,13 +1,13 @@


package com.genersoft.iot.vmp.storager.impl;




import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONObject;


import com.alibaba.fastjson2.JSON;


import com.alibaba.fastjson2.JSONObject;


import com.genersoft.iot.vmp.common.StreamInfo;


import com.genersoft.iot.vmp.common.SystemAllInfo;


import com.genersoft.iot.vmp.common.VideoManagerConstants;


import com.genersoft.iot.vmp.conf.UserSetting;


import com.genersoft.iot.vmp.gb28181.bean.*;


import com.genersoft.iot.vmp.media.zlm.dto.MediaItem;


import com.genersoft.iot.vmp.media.zlm.dto.hook.OnStreamChangedHookParam;


import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;


import com.genersoft.iot.vmp.media.zlm.dto.StreamAuthorityInfo;


import com.genersoft.iot.vmp.service.bean.GPSMsgInfo;


@@ -17,6 +17,7 @@


import com.genersoft.iot.vmp.storager.dao.DeviceChannelMapper;


import com.genersoft.iot.vmp.storager.dao.dto.PlatformRegisterInfo;


import com.genersoft.iot.vmp.utils.DateUtil;


import com.genersoft.iot.vmp.utils.JsonUtil;


import com.genersoft.iot.vmp.utils.SystemInfoUtils;


import com.genersoft.iot.vmp.utils.redis.RedisUtil;


import org.slf4j.Logger;


@@ -157,7 +158,10 @@


        }


        for (Object player : players) {


            String key = (String) player;


            StreamInfo streamInfo = (StreamInfo) RedisUtil.get(key);


            StreamInfo streamInfo = JsonUtil.redisJsonToObject(key, StreamInfo.class);


            if (Objects.isNull(streamInfo)) {


                continue;


            }


            streamInfos.put(streamInfo.getDeviceID() + "_" + streamInfo.getChannelId(), streamInfo);


        }


        return streamInfos;


@@ -173,12 +177,14 @@


    @Override


    public boolean startDownload(StreamInfo stream, String callId) {


        boolean result;


        String key=String.format("%S_%s_%s_%s_%s_%s_%s", VideoManagerConstants.DOWNLOAD_PREFIX,


                userSetting.getServerId(), stream.getMediaServerId(), stream.getDeviceID(), stream.getChannelId(), stream.getStream(), callId);


        if (stream.getProgress() == 1) {


            result = RedisUtil.set(String.format("%S_%s_%s_%s_%s_%s_%s", VideoManagerConstants.DOWNLOAD_PREFIX,


                    userSetting.getServerId(), stream.getMediaServerId(), stream.getDeviceID(), stream.getChannelId(), stream.getStream(), callId), stream);


            logger.debug("添加下载缓存==已完成下载=》{}",key);


            result = RedisUtil.set(key, stream);


        }else {


            result = RedisUtil.set(String.format("%S_%s_%s_%s_%s_%s_%s", VideoManagerConstants.DOWNLOAD_PREFIX,


                    userSetting.getServerId(), stream.getMediaServerId(), stream.getDeviceID(), stream.getChannelId(), stream.getStream(), callId), stream, 60*60);


            logger.debug("添加下载缓存==未完成下载=》{}",key);


            result = RedisUtil.set(key, stream, 60*60);


        }


        return result;


    }


@@ -573,14 +579,14 @@


    }




    @Override


    public void addStream(MediaServerItem mediaServerItem, String type, String app, String streamId, MediaItem mediaItem) {


    public void addStream(MediaServerItem mediaServerItem, String type, String app, String streamId, OnStreamChangedHookParam onStreamChangedHookParam) {


        // 查找是否使用了callID


        StreamAuthorityInfo streamAuthorityInfo = getStreamAuthorityInfo(app, streamId);


        String key = VideoManagerConstants.WVP_SERVER_STREAM_PREFIX  + userSetting.getServerId() + "_" + type + "_" + app + "_" + streamId + "_" + mediaServerItem.getId();


        if (streamAuthorityInfo != null) {


            mediaItem.setCallId(streamAuthorityInfo.getCallId());


            onStreamChangedHookParam.setCallId(streamAuthorityInfo.getCallId());


        }


        RedisUtil.set(key, mediaItem);


        RedisUtil.set(key, onStreamChangedHookParam);


    }




    @Override


@@ -613,7 +619,7 @@


                stream,


                callId


        );


        List<Object> streamInfoScan = RedisUtil.scan(key);


        List<Object> streamInfoScan = RedisUtil.scan2(key);


        if (streamInfoScan.size() > 0) {


            return (StreamInfo) RedisUtil.get((String) streamInfoScan.get(0));


        }else {


@@ -624,8 +630,7 @@


    @Override


    public ThirdPartyGB queryMemberNoGBId(String queryKey) {


        String key = VideoManagerConstants.WVP_STREAM_GB_ID_PREFIX + queryKey;


        JSONObject jsonObject = (JSONObject)RedisUtil.get(key);


        return  JSONObject.toJavaObject(jsonObject, ThirdPartyGB.class);


        return JsonUtil.redisJsonToObject(key, ThirdPartyGB.class);


    }




    @Override


@@ -638,13 +643,13 @@


    }




    @Override


    public List<MediaItem> getStreams(String mediaServerId, String type) {


        List<MediaItem> result = new ArrayList<>();


    public List<OnStreamChangedHookParam> getStreams(String mediaServerId, String type) {


        List<OnStreamChangedHookParam> result = new ArrayList<>();


        String key = VideoManagerConstants.WVP_SERVER_STREAM_PREFIX + userSetting.getServerId() + "_" + type + "_*_*_" + mediaServerId;


        List<Object> streams = RedisUtil.scan(key);


        for (Object stream : streams) {


            MediaItem mediaItem = (MediaItem)RedisUtil.get((String) stream);


            result.add(mediaItem);


            OnStreamChangedHookParam onStreamChangedHookParam = (OnStreamChangedHookParam)RedisUtil.get((String) stream);


            result.add(onStreamChangedHookParam);


        }


        return result;


    }


@@ -662,9 +667,34 @@


    }




    @Override


    public void removeAllDevice() {


        String scanKey = VideoManagerConstants.DEVICE_PREFIX + userSetting.getServerId() + "_*";


        List<Object> keys = RedisUtil.scan(scanKey);


        for (Object key : keys) {


            RedisUtil.del((String) key);


        }


    }




    @Override


    public List<Device> getAllDevices() {


        String scanKey = VideoManagerConstants.DEVICE_PREFIX + userSetting.getServerId() + "_*";


        List<Device> result = new ArrayList<>();


        List<Object> keys = RedisUtil.scan(scanKey);


        for (Object o : keys) {


            String key = (String) o;


            Device device = JsonUtil.redisJsonToObject(key, Device.class);


            if (Objects.nonNull(device)) { // 只取没有存过得


                result.add(JsonUtil.redisJsonToObject(key, Device.class));


            }


        }




        return result;


    }




    @Override


    public Device getDevice(String deviceId) {


        String key = VideoManagerConstants.DEVICE_PREFIX + userSetting.getServerId() + "_" + deviceId;


        return (Device)RedisUtil.get(key);


        return JsonUtil.redisJsonToObject(key, Device.class);


    }




    @Override


@@ -676,7 +706,7 @@


    @Override


    public GPSMsgInfo getGpsMsgInfo(String gbId) {


        String key = VideoManagerConstants.WVP_STREAM_GPS_MSG_PREFIX + userSetting.getServerId() + "_" + gbId;


        return (GPSMsgInfo)RedisUtil.get(key);


        return JsonUtil.redisJsonToObject(key, GPSMsgInfo.class);


    }




    @Override


@@ -686,9 +716,9 @@


        List<Object> keys = RedisUtil.scan(scanKey);


        for (Object o : keys) {


            String key = (String) o;


            GPSMsgInfo gpsMsgInfo = (GPSMsgInfo) RedisUtil.get(key);


            if (!gpsMsgInfo.isStored()) { // 只取没有存过得


                result.add((GPSMsgInfo) RedisUtil.get(key));


            GPSMsgInfo gpsMsgInfo = JsonUtil.redisJsonToObject(key, GPSMsgInfo.class);


            if (Objects.nonNull(gpsMsgInfo) && !gpsMsgInfo.isStored()) { // 只取没有存过得


                result.add(JsonUtil.redisJsonToObject(key, GPSMsgInfo.class));


            }


        }




@@ -710,20 +740,32 @@


    @Override


    public StreamAuthorityInfo getStreamAuthorityInfo(String app, String stream) {


        String key = VideoManagerConstants.MEDIA_STREAM_AUTHORITY + userSetting.getServerId() + "_" + app+ "_" + stream ;


        return (StreamAuthorityInfo) RedisUtil.get(key);


        return JsonUtil.redisJsonToObject(key, StreamAuthorityInfo.class);




    }




    @Override


    public List<StreamAuthorityInfo> getAllStreamAuthorityInfo() {


        String scanKey = VideoManagerConstants.MEDIA_STREAM_AUTHORITY + userSetting.getServerId() + "_*_*" ;


        List<StreamAuthorityInfo> result = new ArrayList<>();


        List<Object> keys = RedisUtil.scan(scanKey);


        for (Object o : keys) {


            String key = (String) o;


            result.add(JsonUtil.redisJsonToObject(key, StreamAuthorityInfo.class));


        }


        return result;


    }






    @Override


    public MediaItem getStreamInfo(String app, String streamId, String mediaServerId) {


    public OnStreamChangedHookParam getStreamInfo(String app, String streamId, String mediaServerId) {


        String scanKey = VideoManagerConstants.WVP_SERVER_STREAM_PREFIX  + userSetting.getServerId() + "_*_" + app + "_" + streamId + "_" + mediaServerId;




        MediaItem result = null;


        OnStreamChangedHookParam result = null;


        List<Object> keys = RedisUtil.scan(scanKey);


        if (keys.size() > 0) {


            String key = (String) keys.get(0);


            result = (MediaItem)RedisUtil.get(key);


            result = JsonUtil.redisJsonToObject(key, OnStreamChangedHookParam.class);


        }




        return result;


@@ -815,7 +857,7 @@




    @Override


    public void sendAlarmMsg(AlarmChannelMessage msg) {


        String key = VideoManagerConstants.VM_MSG_SUBSCRIBE_ALARM;


        String key = VideoManagerConstants.VM_MSG_SUBSCRIBE_ALARM_RECEIVE;


        logger.info("[redis发送通知] 报警{}: {}", key, JSON.toJSON(msg));


        RedisUtil.convertAndSend(key, (JSONObject)JSON.toJSON(msg));


    }