diff --git a/src/main/java/com/ruoyi/device/service/impl/TuohengService.java b/src/main/java/com/ruoyi/device/service/impl/TuohengService.java index 921799b..5a746e0 100644 --- a/src/main/java/com/ruoyi/device/service/impl/TuohengService.java +++ b/src/main/java/com/ruoyi/device/service/impl/TuohengService.java @@ -66,6 +66,12 @@ public class TuohengService { @Autowired private MqttCallbackRegistry mqttCallbackRegistry; + @Autowired + private FlightEventCallback flightEventCallback; + + @Autowired + private FlightLogCallback flightLogCallback; + private final ObjectMapper objectMapper = new ObjectMapper(); /** @@ -183,9 +189,9 @@ public class TuohengService { } }); - handler.registerDroneRealTimeCallback(new FlightLogCallback()); + handler.registerDroneRealTimeCallback(flightLogCallback); - handler.registerAirportFlyControlDataCallback(new FlightEventCallback()); + handler.registerAirportFlyControlDataCallback(flightEventCallback); log.info("TuohengService 初始化完成,已注册所有回调"); }