| | |
| | | StatisticalService statisticalService = SpringUtils.getBean(StatisticalService.class); |
| | | statisticalService.data(new String(message.getPayload(), StandardCharsets.UTF_8)); |
| | | } |
| | | //接收雷达强制引导数据 |
| | | if (topic.equals("radarForceGuide")) |
| | | { |
| | | ArdRadarService ardRadarService = SpringUtils.getBean(ArdRadarService.class); |
| | | ardRadarService.forceGuide(new String(message.getPayload(), StandardCharsets.UTF_8)); |
| | | } |
| | | //接收雷达引导追踪数据 |
| | | if (topic.equals("radarFollowGuide")) |
| | | { |
| | | ArdRadarService ardRadarService = SpringUtils.getBean(ArdRadarService.class); |
| | | ardRadarService.followGuide(new String(message.getPayload(), StandardCharsets.UTF_8)); |
| | | } |
| | | } catch (Exception e) { |
| | | log.debug("处理mqtt消息异常:" + e); |
| | | } |