From 31290bdc487e80c26b2e81d55e46ca27d80e385c Mon Sep 17 00:00:00 2001
From: wangmengzhao <1036088376@qq.com>
Date: 星期二, 28 十一月 2023 23:46:02 +0800
Subject: [PATCH] 设备安装单/维修单优化，一级联营商合伙人登录之后可以看到别人给他创建的安装单和他给别人创建的安装单20231128wmz
---
wumei-smart-master/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxCallback.java | 16 +++++++++++++++-
1 files changed, 15 insertions(+), 1 deletions(-)
diff --git a/wumei-smart-master/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxCallback.java b/wumei-smart-master/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxCallback.java
index 4e6dee6..d321e4e 100644
--- a/wumei-smart-master/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxCallback.java
+++ b/wumei-smart-master/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxCallback.java
@@ -1,6 +1,5 @@
package com.ruoyi.iot.mqtt;
-import com.ruoyi.framework.web.domain.server.Sys;
import org.eclipse.paho.client.mqttv3.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -23,12 +22,27 @@
@Autowired
private EmqxService emqxService;
+ /**
+ * 瀹㈡埛绔涪澶变簡瀵规湇鍔＄鐨勮繛鎺ュ悗瑙﹀彂鐨勬柟娉曞洖璋�
+ *
+ * @param throwable
+ */
@Override
public void connectionLost(Throwable throwable) {
+ //璧勬簮鐨勬竻鐞� 閲嶈繛
logger.info("mqtt鏂紑杩炴帴--");
}
+ /**
+ * messageArrived-鍚屾鐨勫洖璋�
+ * 鍚屾璋冪敤灏辨槸鍦ㄨ繖涓猰essageArrived鏂规硶鏈墽琛屾纭繑鍥炰箣鍓嶏紝杩欎釜mqtt瀹㈡埛绔槸涓嶄細瀵规湇鍔＄鍋氬嚭杩欎釜浠讳綍纭鐨�
+ * 涓�鏃﹁鏂规硶鍚戝鎶涘嚭浜嗗紓甯稿鎴风灏嗗紓甯稿叧闂紝褰撳啀娆¤繛鎺ユ椂锛涙墍鏈塓oS1,QoS2涓斿鎴风鏈繘琛宎ck纭鐨勬秷鎭兘灏嗙敱broker鏈嶅姟鍣ㄥ啀娆″彂閫佸埌瀹㈡埛绔�
+ *
+ * @param topic
+ * @param mqttMessage
+ * @throws Exception
+ */
@Override
public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {
emqxService.subscribeCallback(topic, mqttMessage);
--
Gitblit v1.8.0