From 27f4796c55355d9c59e4460da04b7ce2a804879a Mon Sep 17 00:00:00 2001 From: rqian <1206436827@qq.com> Date: Fri, 21 Aug 2026 09:20:08 +0800 Subject: [PATCH] # update --- .../src/main/java/com/maibu/core/business/DevicePlanTask.java | 3 +++ .../src/main/java/com/maibu/mqtt/HostMessageHandler.java | 2 ++ 2 files changed, 5 insertions(+) diff --git a/maibu-common/src/main/java/com/maibu/core/business/DevicePlanTask.java b/maibu-common/src/main/java/com/maibu/core/business/DevicePlanTask.java index fb83995..96c9e60 100644 --- a/maibu-common/src/main/java/com/maibu/core/business/DevicePlanTask.java +++ b/maibu-common/src/main/java/com/maibu/core/business/DevicePlanTask.java @@ -39,4 +39,7 @@ public class DevicePlanTask extends OrgBaseDO { private LocalDateTime canExecuteTime; // 这个时间之前都不能执行 + @TableField(exist = false) + private boolean taskAccepted = false; //任务被上位机接收 + } diff --git a/maibu-common/src/main/java/com/maibu/mqtt/HostMessageHandler.java b/maibu-common/src/main/java/com/maibu/mqtt/HostMessageHandler.java index 8022b73..89e4998 100644 --- a/maibu-common/src/main/java/com/maibu/mqtt/HostMessageHandler.java +++ b/maibu-common/src/main/java/com/maibu/mqtt/HostMessageHandler.java @@ -129,6 +129,8 @@ public class HostMessageHandler implements CustomMqttMessageHandler { } } } + //todo 推送实时位置和状态消息到外部 + //todo 记录到内存 开线程池队列 逐一转发 // GlobalMemory.customMqttDeviceMonitor.publish(mqttClientId, String.format(MqttTopic.DEVICE_LOCATION_TOPIC, deviceId), // JsonUtils.toJsonString(dto)); }