# update
This commit is contained in:
@@ -39,4 +39,7 @@ public class DevicePlanTask extends OrgBaseDO {
|
||||
|
||||
private LocalDateTime canExecuteTime; // 这个时间之前都不能执行
|
||||
|
||||
@TableField(exist = false)
|
||||
private boolean taskAccepted = false; //任务被上位机接收
|
||||
|
||||
}
|
||||
|
||||
@@ -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));
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user