From af954b34ffad38c3b11bd82caa54d5fb0c36e6ec Mon Sep 17 00:00:00 2001
From: mac <user@users-MacBook-Pro.local>
Date: 星期三, 13 十二月 2023 16:19:12 +0800
Subject: [PATCH] 2023年12月13日16:18:38

---
 HDL_ON/DAL/Mqtt/MqttClient.cs |   11 ++++-------
 1 files changed, 4 insertions(+), 7 deletions(-)

diff --git a/HDL_ON/DAL/Mqtt/MqttClient.cs b/HDL_ON/DAL/Mqtt/MqttClient.cs
index 3b1d20a..4353a7f 100644
--- a/HDL_ON/DAL/Mqtt/MqttClient.cs
+++ b/HDL_ON/DAL/Mqtt/MqttClient.cs
@@ -111,7 +111,7 @@
             {
                 MqttInfoConfig.Current.IfGetMqttInfoSuccess = false;
             }
-            Control.Ins.GatewayOnline_Cloud = Control.Ins.GatewayOnline_Local = false;
+            //Control.Ins.GatewayOnline_Cloud = Control.Ins.GatewayOnline_Local = false;
             await DisConnectRemoteMqttClient(s);
         }
 
@@ -133,10 +133,6 @@
             new System.Threading.Thread(async () => {
                 while (true)
                 {
-                    if (!UserInfo.Current.IsLogin)
-                    {
-                        return;
-                    }
                     try
                     {
                         System.Threading.Thread.Sleep(2000);
@@ -149,6 +145,7 @@
 
                         await StartCloudMqtt();
                         await SubscribeTopics();
+
                     }
                     catch { }
                 }
@@ -553,7 +550,7 @@
                                 {
                                     var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, tuyaEncryptKey);
                                     var revString = Encoding.UTF8.GetString(bytes);
-                                    MainPage.Log($"mqtt 鐘舵�佹洿鏂�:{revString}");
+                                    //MainPage.Log($"mqtt 鐘舵�佹洿鏂�:{revString}");
                                     Control.Ins.UpdataFunctionStatus(revString, null, true);
                                     //Control.Ins.MsgInfoList.Add($"mqtt 鐘舵�佹洿鏂�:{revString}");
                                     //Control.Ins.MsgInfoList.Add(revString + "\r\n");
@@ -984,7 +981,7 @@
 
 
                 MqttInfoConfig.Current.mMqttInfo = mqttInfoRequestResult_Obj;
-                await MQTTConnectAsync();
+                //await MQTTConnectAsync();
                 //1.鍒ゆ柇鏄惁缁戝畾浜嗙綉鍏筹紝鑾峰彇缃戝叧杩滅▼杩炴帴鐨勫姞瀵咾EY
                 //if (DB_ResidenceData.Instance.CheckWhetherGatewayIsBound())
                 {

--
Gitblit v1.8.0