| | |
|---|
| | | import com.genersoft.iot.vmp.conf.UserSetup; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.bean.*; |
|---|
| | | import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; |
|---|
| | | import com.genersoft.iot.vmp.service.bean.ThirdPartyGB; |
|---|
| | | 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.slf4j.LoggerFactory; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import org.springframework.util.StringUtils; |
|---|
| | | |
|---|
| | | import java.text.SimpleDateFormat; |
|---|
| | | import java.util.*; |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void sendStreamChangeMsg(String type, JSONObject jsonObject) { |
|---|
| | | String key = VideoManagerConstants.WVP_MSG_STREAM_CHANGE__PREFIX + type; |
|---|
| | | String key = VideoManagerConstants.WVP_MSG_STREAM_CHANGE_PREFIX + type; |
|---|
| | | logger.debug("[redis 流变化事件] {}: {}", key, jsonObject.toString()); |
|---|
| | | redis.convertAndSend(key, jsonObject); |
|---|
| | | } |
|---|
| | |
|---|
| | | if (playLeys == null || playLeys.size() == 0) return null; |
|---|
| | | return (StreamInfo)redis.get(playLeys.get(0).toString()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public ThirdPartyGB queryMemberNoGBId(String queryKey) { |
|---|
| | | String key = VideoManagerConstants.WVP_STREAM_GB_ID_PREFIX + queryKey; |
|---|
| | | JSONObject jsonObject = (JSONObject)redis.get(key); |
|---|
| | | return JSONObject.toJavaObject(jsonObject, ThirdPartyGB.class); |
|---|
| | | } |
|---|
| | | } |
|---|
