fix: 设备状态

e62fb0ce · 罗志长 · 10270423 · e62fb0ce
Commit e62fb0ce authored Mar 04, 2024 by 罗志长
Showing with 4 additions and 5 deletions
server-web/src/main/java/com/makeit/mqtt/PushCallback.java
--- a/server-web/src/main/java/com/makeit/mqtt/PushCallback.java
+++ b/server-web/src/main/java/com/makeit/mqtt/PushCallback.java
@@ -277,12 +277,11 @@ public class PushCallback implements MqttCallbackExtended {
     * 处理设备状态
     */
    public void handleStatus(DeviceInfo device) {
-        if (!REPORT_PROPERTY.equals(device.getMessageType())) {
-            return;
-        }
        CompletableFuture.runAsync(() -> {
-            // 处理设备故障
-            platDeviceService.handleFault(device);
+            if (REPORT_PROPERTY.equals(device.getMessageType())) {
+                // 处理设备故障
+                platDeviceService.handleFault(device);
+            }
            // 更新设备状态
            platDeviceService.updateDeviceStatus(device.getMessageType(), device.getDeviceId(), "");
        }, taskExecutor);