diff --git a/src/main/java/com/ruoyi/device/service/impl/FlightStateChangeListener.java b/src/main/java/com/ruoyi/device/service/impl/FlightStateChangeListener.java index 8ac1f0c..5d2e327 100644 --- a/src/main/java/com/ruoyi/device/service/impl/FlightStateChangeListener.java +++ b/src/main/java/com/ruoyi/device/service/impl/FlightStateChangeListener.java @@ -36,28 +36,28 @@ public class FlightStateChangeListener implements StateChangeListener { @Override public void onStateChange(String sn, MachineStates newStates) { - try { - DroneState droneState = newStates.getDroneState(); - if (droneState == DroneState.UNKNOWN) { - return; - } - - FlightEntity flight = flightService.getOrCreateCurrentFlight(sn); - if (flight == null) { - return; - } - - String currentStatus = flight.getStatus(); - String newStatus = mapDroneStateToFlightStatus(droneState); - - if (!currentStatus.equals(newStatus)) { - flightService.updateFlightStatus(flight.getFlightId(), newStatus); - log.info("状态变化更新飞行状态: sn={}, droneState={}, flightStatus={}", - sn, droneState, newStatus); - } - } catch (Exception e) { - log.error("状态变化监听器处理失败: sn={}, error={}", sn, e.getMessage(), e); - } +// try { +// DroneState droneState = newStates.getDroneState(); +// if (droneState == DroneState.UNKNOWN) { +// return; +// } +// +// FlightEntity flight = flightService.getOrCreateCurrentFlight(sn); +// if (flight == null) { +// return; +// } +// +// String currentStatus = flight.getStatus(); +// String newStatus = mapDroneStateToFlightStatus(droneState); +// +// if (!currentStatus.equals(newStatus)) { +// flightService.updateFlightStatus(flight.getFlightId(), newStatus); +// log.info("状态变化更新飞行状态: sn={}, droneState={}, flightStatus={}", +// sn, droneState, newStatus); +// } +// } catch (Exception e) { +// log.error("状态变化监听器处理失败: sn={}, error={}", sn, e.getMessage(), e); +// } } private String mapDroneStateToFlightStatus(DroneState droneState) {