| | |
|---|
| | | SubscribeInfo subscribe = subscribeHolder.getMobilePositionSubscribe(platform.getServerGBId()); |
|---|
| | | if (subscribe != null) { |
|---|
| | | |
|---|
| | | // if (!parentPlatform.isStatus()) { |
|---|
| | | // logger.info("发送订阅时发现平台已经离线：{}", platformId); |
|---|
| | | // return; |
|---|
| | | // } |
|---|
| | | // TODO 暂时只处理视频流的回复,后续增加对国标设备的支持 |
|---|
| | | List<GbStream> gbStreams = storager.queryGbStreamListInPlatform(platform.getServerGBId()); |
|---|
| | | List<DeviceChannel> gbStreams = storager.queryGbStreamListInPlatform(platform.getServerGBId()); |
|---|
| | | if (gbStreams.size() == 0) { |
|---|
| | | logger.info("发送订阅时发现平台已经没有关联的直播流：{}", platform.getServerGBId()); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | for (GbStream gbStream : gbStreams) { |
|---|
| | | String gbId = gbStream.getGbId(); |
|---|
| | | for (DeviceChannel deviceChannel : gbStreams) { |
|---|
| | | String gbId = deviceChannel.getChannelId(); |
|---|
| | | GPSMsgInfo gpsMsgInfo = redisCatchStorage.getGpsMsgInfo(gbId); |
|---|
| | | if (gpsMsgInfo != null) { // 无最新位置不发送 |
|---|
| | | if (logger.isDebugEnabled()) { |
|---|
| | | logger.debug("无最新位置不发送"); |
|---|
| | | } |
|---|
| | | // 无最新位置不发送 |
|---|
| | | if (gpsMsgInfo != null) { |
|---|
| | | // 经纬度都为0不发送 |
|---|
| | | if (gpsMsgInfo.getLng() == 0 && gpsMsgInfo.getLat() == 0) { |
|---|
| | | continue; |
|---|
