From 4c586bb23cdcae56ae4e4c62e90e148dc10b9d90 Mon Sep 17 00:00:00 2001 From: wxr <464027401@qq.com> Date: 星期二, 17 五月 2022 14:19:31 +0800 Subject: [PATCH] Merge branch 'Dev-Branch' into wxr1215 --- HDL_ON/DAL/Mqtt/MqttClient.cs | 31 +++++++++++++++++-------------- 1 files changed, 17 insertions(+), 14 deletions(-) diff --git a/HDL_ON/DAL/Mqtt/MqttClient.cs b/HDL_ON/DAL/Mqtt/MqttClient.cs index 2adbeba..1f26a36 100644 --- a/HDL_ON/DAL/Mqtt/MqttClient.cs +++ b/HDL_ON/DAL/Mqtt/MqttClient.cs @@ -357,20 +357,20 @@ { try { - var mMes = Encoding.UTF8.GetString(e.ApplicationMessage.Payload); - Newtonsoft.Json.Linq.JObject pairs = Newtonsoft.Json.Linq.JObject.Parse(mMes); - var pairSid = pairs.GetValue("sid").ToString(); - var pairOnline = pairs.GetValue("online"); - if (!string.IsNullOrEmpty(pairSid.ToString())) - { - var function_online = FunctionList.List.Functions.Find((obj) => obj.sid == pairSid); - if (function_online != null){ - function_online.online = (bool)pairOnline; - HomePage.LoadEvent_RefreshDevcieOnline(function_online); - FunctionPage.UpdataOnline(function_online); - RoomPage.UpdataOnline(function_online); - } - } + //var mMes = Encoding.UTF8.GetString(e.ApplicationMessage.Payload); + //Newtonsoft.Json.Linq.JObject pairs = Newtonsoft.Json.Linq.JObject.Parse(mMes); + //var pairSid = pairs.GetValue("sid").ToString(); + //var pairOnline = pairs.GetValue("online"); + //if (!string.IsNullOrEmpty(pairSid.ToString())) + //{ + // var function_online = FunctionList.List.Functions.Find((obj) => obj.sid == pairSid); + // if (function_online != null){ + // function_online.online = (bool)pairOnline; + // HomePage.LoadEvent_RefreshDevcieOnline(function_online); + // FunctionPage.UpdataOnline(function_online); + // RoomPage.UpdataOnline(function_online); + // } + //} } catch(Exception ex) @@ -511,12 +511,15 @@ } #endregion //A缃戝叧璁惧鐘舵��-鍖呭惈娑傞甫璁惧 + //Tag 缃戠粶鐘舵�佽В鏋� else if (topic == $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/property/send") { var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, tuyaEncryptKey); var revString = Encoding.UTF8.GetString(bytes); MainPage.Log($"mqtt 鐘舵�佹洿鏂�:{revString}"); Control.Ins.UpdataFunctionStatus(revString, null, true); + //Control.Ins.MsgInfoList.Add($"mqtt 鐘舵�佹洿鏂�:{revString}"); + //Control.Ins.MsgInfoList.Add(revString + "\r\n"); } //涓�绔彛鏁版嵁瑙f瀽 -- Gitblit v1.8.0