|
@@ -17,29 +17,12 @@ Vue.component('tenMinutes', tenMinutes);
|
|
|
|
|
|
Vue.prototype.$http = http;
|
|
|
|
|
|
-// 等待 userId
|
|
|
-function waitForUserId(callback) {
|
|
|
- let timer = setInterval(() => {
|
|
|
- const userId = uni.getStorageSync("userId");
|
|
|
- if (userId) {
|
|
|
- clearInterval(timer);
|
|
|
- callback(userId);
|
|
|
- }
|
|
|
- }, 2000);
|
|
|
-}
|
|
|
-
|
|
|
-// 初始化 MQTT
|
|
|
-waitForUserId((userId) => {
|
|
|
- const mqttClient = createMqttClient();
|
|
|
- Vue.prototype.$mqttClient = mqttClient;
|
|
|
-
|
|
|
- const mqttClientData = createMqttData();
|
|
|
- Vue.prototype.$mqttClientData = mqttClientData;
|
|
|
- uni.$emit("mqtt-ready", mqttClient);
|
|
|
- uni.$emit("mqttData-ready", mqttClientData);
|
|
|
-});
|
|
|
// 全局方法:初始化 MQTT(登录成功时调用)
|
|
|
Vue.prototype.$initMqtt = function () {
|
|
|
+ if (!uni.getStorageSync("userId")) {
|
|
|
+ console.warn("MQTT 初始化失败:缺少 userId");
|
|
|
+ return;
|
|
|
+ }
|
|
|
const mqttClient = createMqttClient()
|
|
|
Vue.prototype.$mqttClient = mqttClient
|
|
|
const mqttClientData = createMqttData()
|