| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // logger.info("[收到移动位置订阅通知]：{}/{}->{}.{}, 时间： {}", mobilePosition.getDeviceId(), mobilePosition.getChannelId(), |
|---|
| | | // mobilePosition.getLongitude(), mobilePosition.getLatitude(), System.currentTimeMillis() - startTime); |
|---|
| | | logger.debug("[收到移动位置订阅通知]：{}/{}->{}.{}, 时间： {}", mobilePosition.getDeviceId(), mobilePosition.getChannelId(), |
|---|
| | | mobilePosition.getLongitude(), mobilePosition.getLatitude(), System.currentTimeMillis() - startTime); |
|---|
| | | mobilePosition.setReportSource("Mobile Position"); |
|---|
| | | |
|---|
| | | mobilePositionService.add(mobilePosition); |
|---|
| | |
|---|
| | | }catch (Exception e) { |
|---|
| | | logger.error("[向上级转发移动位置失败] ", e); |
|---|
| | | } |
|---|
| | | if (mobilePosition.getChannelId() == null || mobilePosition.getChannelId().equals(mobilePosition.getDeviceId()) ) { |
|---|
| | | if (mobilePosition.getChannelId() == null || mobilePosition.getChannelId().equals(mobilePosition.getDeviceId())) { |
|---|
| | | List<DeviceChannel> channels = deviceChannelService.queryChaneListByDeviceId(mobilePosition.getDeviceId()); |
|---|
| | | channels.forEach(channel -> { |
|---|
| | | // 发送redis消息。 通知位置信息的变化 |
|---|
