|
@@ -303,12 +303,13 @@ onActivated(() => {
|
|
|
// 连接 MQTT 并处理回调
|
|
// 连接 MQTT 并处理回调
|
|
|
const connectMqtt = async () => {
|
|
const connectMqtt = async () => {
|
|
|
try {
|
|
try {
|
|
|
- if (!mqttTool.client) {
|
|
|
|
|
|
|
+ getList();
|
|
|
|
|
+ // 先查询列表再连接mqtt
|
|
|
|
|
+ if (!mqttTool.client) {
|
|
|
await mqttTool.connect();
|
|
await mqttTool.connect();
|
|
|
}
|
|
}
|
|
|
mqttTool.client?.on('connect', () => {
|
|
mqttTool.client?.on('connect', () => {
|
|
|
- mqttCallback(); // 连接成功后再执行回调
|
|
|
|
|
- getList();
|
|
|
|
|
|
|
+ mqttCallback();
|
|
|
});
|
|
});
|
|
|
} catch (error) {
|
|
} catch (error) {
|
|
|
console.error('MQTT 连接失败:', error);
|
|
console.error('MQTT 连接失败:', error);
|