package com.genersoft.iot.vmp.storager.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.genersoft.iot.vmp.common.RealVideo;
|
import com.genersoft.iot.vmp.common.StreamInfo;
|
import com.genersoft.iot.vmp.common.VideoManagerConstants;
|
import com.genersoft.iot.vmp.conf.MediaServerConfig;
|
import com.genersoft.iot.vmp.gb28181.bean.*;
|
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
|
import com.genersoft.iot.vmp.storager.dao.DeviceChannelMapper;
|
import com.genersoft.iot.vmp.utils.redis.RedisUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.*;
|
|
@SuppressWarnings("rawtypes")
|
@Component
|
public class RedisCatchStorageImpl implements IRedisCatchStorage {
|
|
@Autowired
|
private RedisUtil redis;
|
|
@Autowired
|
private DeviceChannelMapper deviceChannelMapper;
|
|
|
/**
|
* 开始播放时将流存入redis
|
*
|
* @return
|
*/
|
@Override
|
public boolean startPlay(StreamInfo stream) {
|
return redis.set(String.format("%S_%s_%s_%s", VideoManagerConstants.PLAYER_PREFIX, stream.getStreamId(),stream.getDeviceID(), stream.getChannelId()),
|
stream);
|
}
|
|
/**
|
* 停止播放时从redis删除
|
*
|
* @return
|
*/
|
@Override
|
public boolean stopPlay(StreamInfo streamInfo) {
|
if (streamInfo == null) return false;
|
return redis.del(String.format("%S_%s_%s_%s", VideoManagerConstants.PLAYER_PREFIX,
|
streamInfo.getStreamId(),
|
streamInfo.getDeviceID(),
|
streamInfo.getChannelId()));
|
}
|
|
/**
|
* 查询播放列表
|
* @return
|
*/
|
@Override
|
public StreamInfo queryPlay(StreamInfo streamInfo) {
|
return (StreamInfo)redis.get(String.format("%S_%s_%s_%s",
|
VideoManagerConstants.PLAYER_PREFIX,
|
streamInfo.getStreamId(),
|
streamInfo.getDeviceID(),
|
streamInfo.getChannelId()));
|
}
|
@Override
|
public StreamInfo queryPlayByStreamId(String steamId) {
|
List<Object> playLeys = redis.scan(String.format("%S_%s_*", VideoManagerConstants.PLAYER_PREFIX, steamId));
|
if (playLeys == null || playLeys.size() == 0) return null;
|
return (StreamInfo)redis.get(playLeys.get(0).toString());
|
}
|
|
@Override
|
public StreamInfo queryPlaybackByStreamId(String steamId) {
|
List<Object> playLeys = redis.scan(String.format("%S_%s_*", VideoManagerConstants.PLAY_BLACK_PREFIX, steamId));
|
if (playLeys == null || playLeys.size() == 0) return null;
|
return (StreamInfo)redis.get(playLeys.get(0).toString());
|
}
|
|
@Override
|
public StreamInfo queryPlayByDevice(String deviceId, String code) {
|
// List<Object> playLeys = redis.keys(String.format("%S_*_%s_%s", VideoManagerConstants.PLAYER_PREFIX,
|
List<Object> playLeys = redis.scan(String.format("%S_*_%s_%s", VideoManagerConstants.PLAYER_PREFIX,
|
deviceId,
|
code));
|
if (playLeys == null || playLeys.size() == 0) return null;
|
return (StreamInfo)redis.get(playLeys.get(0).toString());
|
}
|
|
/**
|
* 更新流媒体信息
|
* @param mediaServerConfig
|
* @return
|
*/
|
@Override
|
public boolean updateMediaInfo(MediaServerConfig mediaServerConfig) {
|
mediaServerConfig.setUpdateTime(System.currentTimeMillis());
|
return redis.set(VideoManagerConstants.MEDIA_SERVER_PREFIX,mediaServerConfig);
|
}
|
|
/**
|
* 获取流媒体信息
|
* @return
|
*/
|
@Override
|
public MediaServerConfig getMediaInfo() {
|
return (MediaServerConfig)redis.get(VideoManagerConstants.MEDIA_SERVER_PREFIX);
|
}
|
|
@Override
|
public Map<String, StreamInfo> queryPlayByDeviceId(String deviceId) {
|
Map<String, StreamInfo> streamInfos = new HashMap<>();
|
// List<Object> playLeys = redis.keys(String.format("%S_*_%S_*", VideoManagerConstants.PLAYER_PREFIX, deviceId));
|
List<Object> players = redis.scan(String.format("%S_*_%S_*", VideoManagerConstants.PLAYER_PREFIX, deviceId));
|
if (players.size() == 0) return streamInfos;
|
for (int i = 0; i < players.size(); i++) {
|
String key = (String) players.get(i);
|
StreamInfo streamInfo = (StreamInfo)redis.get(key);
|
streamInfos.put(streamInfo.getDeviceID() + "_" + streamInfo.getChannelId(), streamInfo);
|
}
|
return streamInfos;
|
}
|
|
|
@Override
|
public boolean startPlayback(StreamInfo stream) {
|
return redis.set(String.format("%S_%s_%s_%s", VideoManagerConstants.PLAY_BLACK_PREFIX, stream.getStreamId(),stream.getDeviceID(), stream.getChannelId()),
|
stream);
|
}
|
|
|
@Override
|
public boolean stopPlayback(StreamInfo streamInfo) {
|
if (streamInfo == null) return false;
|
DeviceChannel deviceChannel = deviceChannelMapper.queryChannel(streamInfo.getDeviceID(), streamInfo.getChannelId());
|
if (deviceChannel != null) {
|
deviceChannel.setStreamId(null);
|
deviceChannel.setDeviceId(streamInfo.getDeviceID());
|
deviceChannelMapper.update(deviceChannel);
|
}
|
return redis.del(String.format("%S_%s_%s_%s", VideoManagerConstants.PLAY_BLACK_PREFIX,
|
streamInfo.getStreamId(),
|
streamInfo.getDeviceID(),
|
streamInfo.getChannelId()));
|
}
|
|
@Override
|
public StreamInfo queryPlaybackByDevice(String deviceId, String code) {
|
// String format = String.format("%S_*_%s_%s", VideoManagerConstants.PLAY_BLACK_PREFIX,
|
// deviceId,
|
// code);
|
List<Object> playLeys = redis.scan(String.format("%S_*_%s_%s", VideoManagerConstants.PLAY_BLACK_PREFIX,
|
deviceId,
|
code));
|
if (playLeys == null || playLeys.size() == 0) {
|
playLeys = redis.scan(String.format("%S_*_*_%s", VideoManagerConstants.PLAY_BLACK_PREFIX,
|
deviceId));
|
}
|
if (playLeys == null || playLeys.size() == 0) return null;
|
return (StreamInfo)redis.get(playLeys.get(0).toString());
|
}
|
|
@Override
|
public void updatePlatformCatchInfo(ParentPlatformCatch parentPlatformCatch) {
|
String key = VideoManagerConstants.PLATFORM_CATCH_PREFIX + parentPlatformCatch.getId();
|
redis.set(key, parentPlatformCatch);
|
}
|
|
@Override
|
public void updatePlatformKeepalive(ParentPlatform parentPlatform) {
|
String key = VideoManagerConstants.PLATFORM_KEEPLIVEKEY_PREFIX + parentPlatform.getServerGBId();
|
redis.set(key, "", Integer.parseInt(parentPlatform.getKeepTimeout()));
|
}
|
|
@Override
|
public void updatePlatformRegister(ParentPlatform parentPlatform) {
|
String key = VideoManagerConstants.PLATFORM_REGISTER_PREFIX + parentPlatform.getServerGBId();
|
redis.set(key, "", Integer.parseInt(parentPlatform.getExpires()));
|
}
|
|
@Override
|
public ParentPlatformCatch queryPlatformCatchInfo(String platformGbId) {
|
return (ParentPlatformCatch)redis.get(VideoManagerConstants.PLATFORM_CATCH_PREFIX + platformGbId);
|
}
|
|
@Override
|
public void delPlatformCatchInfo(String platformGbId) {
|
redis.del(VideoManagerConstants.PLATFORM_CATCH_PREFIX + platformGbId);
|
}
|
|
@Override
|
public void delPlatformKeepalive(String platformGbId) {
|
redis.del(VideoManagerConstants.PLATFORM_KEEPLIVEKEY_PREFIX + platformGbId);
|
}
|
|
@Override
|
public void delPlatformRegister(String platformGbId) {
|
redis.del(VideoManagerConstants.PLATFORM_REGISTER_PREFIX + platformGbId);
|
}
|
|
|
@Override
|
public void updatePlatformRegisterInfo(String callId, String platformGbId) {
|
String key = VideoManagerConstants.PLATFORM_REGISTER_INFO_PREFIX + callId;
|
redis.set(key, platformGbId);
|
}
|
|
|
@Override
|
public String queryPlatformRegisterInfo(String callId) {
|
return (String)redis.get(VideoManagerConstants.PLATFORM_REGISTER_INFO_PREFIX + callId);
|
}
|
|
@Override
|
public void delPlatformRegisterInfo(String callId) {
|
redis.del(VideoManagerConstants.PLATFORM_REGISTER_INFO_PREFIX + callId);
|
}
|
|
@Override
|
public void cleanPlatformRegisterInfos() {
|
List regInfos = redis.scan(VideoManagerConstants.PLATFORM_REGISTER_INFO_PREFIX + "*");
|
for (Object key : regInfos) {
|
redis.del(key.toString());
|
}
|
}
|
|
@Override
|
public void updateSendRTPSever(SendRtpItem sendRtpItem) {
|
String key = VideoManagerConstants.PLATFORM_SEND_RTP_INFO_PREFIX + sendRtpItem.getPlatformId() + "_" + sendRtpItem.getChannelId();
|
redis.set(key, sendRtpItem);
|
}
|
|
@Override
|
public SendRtpItem querySendRTPServer(String platformGbId, String channelId) {
|
String key = VideoManagerConstants.PLATFORM_SEND_RTP_INFO_PREFIX + platformGbId + "_" + channelId;
|
return (SendRtpItem)redis.get(key);
|
}
|
|
/**
|
* 删除RTP推送信息缓存
|
* @param platformGbId
|
* @param channelId
|
*/
|
@Override
|
public void deleteSendRTPServer(String platformGbId, String channelId) {
|
String key = VideoManagerConstants.PLATFORM_SEND_RTP_INFO_PREFIX + platformGbId + "_" + channelId;
|
redis.del(key);
|
}
|
|
/**
|
* 查询某个通道是否存在上级点播（RTP推送）
|
* @param channelId
|
*/
|
@Override
|
public boolean isChannelSendingRTP(String channelId) {
|
String key = VideoManagerConstants.PLATFORM_SEND_RTP_INFO_PREFIX + "*_" + channelId;
|
List<Object> RtpStreams = redis.scan(key);
|
if (RtpStreams.size() > 0) {
|
return true;
|
} else {
|
return false;
|
}
|
}
|
|
|
/**
|
* 更新媒体流列表
|
* @param mediaList
|
*/
|
@Override
|
public void updateMediaList(List<RealVideo> mediaList) {
|
String key = VideoManagerConstants.MEDIA_STREAM_PREFIX;
|
redis.del(key);
|
for (int i = 0; i < mediaList.size(); i++) {
|
RealVideo realVideo = mediaList.get(i);
|
redis.zAdd(key, realVideo, realVideo.getCreateStamp());
|
}
|
}
|
|
|
/**
|
* 获取当前媒体流列表
|
* @return List<RealVideo>
|
*/
|
@Override
|
public JSONObject getMediaList(int start, int end) {
|
String key = VideoManagerConstants.MEDIA_STREAM_PREFIX;
|
Set<Object> realVideos = redis.ZRange(key, start, end);
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("list", new ArrayList(realVideos));
|
jsonObject.put("total", redis.zSize(key));
|
|
return jsonObject;
|
}
|
}
|
