| | |
| | | |
| | | SubscribeInfo subscribe = redisCatchStorage.getSubscribe(key); |
| | | if (subscribe != null) { |
| | | System.out.println("发送GPS消息"); |
| | | ParentPlatform parentPlatform = storager.queryParentPlatByServerGBId(platformId); |
| | | if (parentPlatform == null || parentPlatform.isStatus()) { |
| | | // TODO 暂时只处理视频流的回复,后续增加对国标设备的支持 |
| | |
| | | if (gbStream.isStatus()) { |
| | | if (gpsMsgInfo != null) { |
| | | // 发送GPS消息 |
| | | sipCommanderForPlatform.sendMobilePosition(parentPlatform, gpsMsgInfo, subscribe); |
| | | sipCommanderForPlatform.sendNotifyMobilePosition(parentPlatform, gpsMsgInfo, subscribe); |
| | | }else { |
| | | // 没有在redis找到新的消息就使用数据库的消息 |
| | | gpsMsgInfo = new GPSMsgInfo(); |
| | |
| | | gpsMsgInfo.setLat(gbStream.getLongitude()); |
| | | gpsMsgInfo.setLng(gbStream.getLongitude()); |
| | | // 发送GPS消息 |
| | | sipCommanderForPlatform.sendMobilePosition(parentPlatform, gpsMsgInfo, subscribe); |
| | | sipCommanderForPlatform.sendNotifyMobilePosition(parentPlatform, gpsMsgInfo, subscribe); |
| | | } |
| | | } |
| | | |