添加报警功能

utils/mqtt.js

@@ -171,7 +171,7 @@ class MqttClient {
 			potentialJsons.forEach(jsonString => {
 				if (jsonString.trim() === '') return;
 				if (this.messageCallbacks.has(topic)) {
-					this.messageCallbacks.get(topic)(jsonString);
+					this.messageCallbacks.get(topic)(jsonString,message);
 				}
 			});
 		};
@@ -285,8 +285,10 @@ class MqttClient {
 			mqttMessage.qos = 1;
 			this.client.send(mqttMessage);
 			console.log(`成功发布消息到主题 ${topic}: ${message}`);
+			return true;
 		} else {
 			console.error('MQTT未连接，无法发布');
+			return false;
 		}
 	}