From e13a9980ce617db1394a76944186c5d5bd595d5d Mon Sep 17 00:00:00 2001 From: wei <kaede@kaededeMacBook-Air.local> Date: 星期三, 02 六月 2021 14:37:12 +0800 Subject: [PATCH] 5月需求bug修复 --- HDL_ON/DAL/Mqtt/MqttClient.cs | 317 +++++++++++++++++++++++++++++++++++++--------------- 1 files changed, 224 insertions(+), 93 deletions(-) diff --git a/HDL_ON/DAL/Mqtt/MqttClient.cs b/HDL_ON/DAL/Mqtt/MqttClient.cs index 2a7d9d5..85177d4 100644 --- a/HDL_ON/DAL/Mqtt/MqttClient.cs +++ b/HDL_ON/DAL/Mqtt/MqttClient.cs @@ -11,6 +11,7 @@ using HDL_ON.DriverLayer; using HDL_ON.Entity; using HDL_ON.UI; +using HDL_ON.DAL.Server; namespace HDL_ON.DAL.Mqtt { @@ -71,11 +72,6 @@ Utlis.WriteLine($"Remote涓诲姩鏂紑_{s}"); //await RemoteMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None); await RemoteMqttClient.DisconnectAsync(); - - if (Control.Ins.IsRemote) - { - Control.Ins.GatewayOnline = false; - } } } catch (Exception e) @@ -137,10 +133,13 @@ { try { - System.Threading.Thread.Sleep(500); - //if (!Control.Ins.IsRemote) continue; + System.Threading.Thread.Sleep(2000); //杩涘叆鍚庡彴涓嶅鐞� if (MainPage.IsEnterBackground) continue; + if (MqttInfoConfig.Current.HomeGatewayInfo == null) + { + continue; + } await StartCloudMqtt(); await SubscribeTopics(); @@ -190,22 +189,52 @@ }; var topicAlinkStatus = new MqttTopicFilter() { - Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.RegionID}/app/thing/property/send", + Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/property/send", QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce }; + //App璁㈤槄绾㈠瀹� / 缃戝叧閬ユ帶鍣ㄦ坊鍔犳垚鍔熼�氱煡 + var pirStatus = new MqttTopicFilter() + { + Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/topo/found", + QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce + }; + //App璁㈤槄閬ユ帶鍣ㄨ嚜瀛︽寜閿涔犳垚鍔熼�氱煡 + var pirStudy = new MqttTopicFilter() + { + Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/event/irCodeStudyDone/up", + QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce + }; + #region 鏁版嵁鏇存柊鎺ㄩ�佷富棰� + //appHomeRefresh锛氫綇瀹呮暟鎹埛鏂伴�氱煡 + var appHomeRefresh = new MqttTopicFilter() + { + Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/event/appHomeRefresh/up", + QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce + }; + //appRoomRefresh锛氭埧闂存暟鎹埛鏂伴�氱煡 + var appRoomRefresh = new MqttTopicFilter() + { + Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/event/appRoomRefresh/up", + QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce + }; + //appDeviceRefresh锛氳澶囨暟鎹埛鏂伴�氱煡 + var appDeviceRefresh = new MqttTopicFilter() + { + Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/event/appDeviceRefresh/up", + QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce + }; + #endregion + Utlis.WriteLine("寮�濮嬭闃咃紒"); - var result = await RemoteMqttClient.SubscribeAsync(new MqttTopicFilter[] { topicFilterPush2, topicAlinkStatus }); + var result = await RemoteMqttClient.SubscribeAsync(new MqttTopicFilter[] { + pirStatus,pirStudy, + appDeviceRefresh,appHomeRefresh,appRoomRefresh, + topicFilterPush2, topicAlinkStatus }); if (result.Items[0].ResultCode == MQTTnet.Client.Subscribing.MqttClientSubscribeResultCode.GrantedQoS0) { - Control.Ins.GatewayOnline = true; isSubscribeSuccess = true; Utlis.WriteLine("璁㈤槄鎴愬姛锛�"); - if (MqttInfoConfig.Current.HomeGatewayInfo != null && MqttInfoConfig.Current.HomeGatewayInfo.mac == Entity.DB_ResidenceData.Instance.residenceGatewayMAC) - { - Control.Ins.IsRemote = true; - } - MqttRemoteSend(new byte[] { 0 }, 3); } } catch (Exception ex) @@ -229,6 +258,10 @@ { return; } + if (DB_ResidenceData.Instance.CurrentRegion == null || DB_ResidenceData.Instance.CurrentRegion.id == null) + { + return; + } //杩藉姞锛氭病鏈夎繙绋嬭繛鎺ョ殑鏉冮檺 if (RemoteMqttIsConnecting || remoteIsConnected) @@ -238,7 +271,7 @@ Utlis.WriteLine($"StartCloudMqtt: 寮�濮�"); - await Task.Factory.StartNew(async () => { + await Task.Factory.StartNew((Func<Task>)(async () => { try { #region 鍒濆鍖栬繙绋婱qtt @@ -250,11 +283,11 @@ if (RemoteMqttClient.ApplicationMessageReceivedHandler == null) { //澶勭悊鎺ユ敹鍒扮殑鏁版嵁 - RemoteMqttClient.UseApplicationMessageReceivedHandler((e) => { + RemoteMqttClient.UseApplicationMessageReceivedHandler((Action<MqttApplicationMessageReceivedEventArgs>)((e) => { try { var topic = e.ApplicationMessage.Topic; - MainPage.Log($"鏀跺埌mqtt涓婚:{topic}"); + //MainPage.Log($"鏀跺埌mqtt涓婚:{topic}"); //涓�绔彛涓婚澶勭悊 if (DB_ResidenceData.Instance.GatewayType == 0 && !DB_ResidenceData.Instance.CheckWhetherGatewayIdIsNull()) { @@ -275,9 +308,15 @@ else if (topic == $"/BusGateWayToClient/{MqttInfoConfig.Current.HomeGatewayInfo.gatewayId}/Common/CheckGateway") { var ss = Encoding.UTF8.GetString(e.ApplicationMessage.Payload); - ReceiveCheckGateway(ss); + //ReceiveCheckGateway(ss); return; } + } + + //涓�浜涚壒娈婄殑涓婚澶勭悊(涓轰簡鎵ц閫熷害,灏藉彲鑳界殑鍒姞鑰楁椂鐨勬搷浣� true:鎵ц浜嗙壒娈婂鐞� false:娌℃湁鎵ц鐗规畩澶勭悊) + if (Stan.HdlCloudReceiveLogic.Current.CloudOverallMsgReceiveEx(topic, e.ApplicationMessage.Payload, mqttEncryptKey, tuyaEncryptKey) == true) + { + return; } if (topic == $"/BusGateWayToClient/{UserInfo.Current.ID}" + PushNotifySqueeze) @@ -286,18 +325,109 @@ //鏂版尋涓嬬嚎涓婚鏂规 鏀跺埌鎸や笅绾夸富棰� ReceiveNotifySqueezeAsync(mMes); } - //A缃戝叧璁惧鐘舵��-鍖呭惈娑傞甫璁惧 - else if (topic == $"/user/{DB_ResidenceData.Instance.CurrentRegion.RegionID}/app/thing/property/send") + //App璁㈤槄绾㈠瀹�/缃戝叧閬ユ帶鍣ㄦ坊鍔犳垚鍔熼�氱煡 + else if (topic == $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/topo/found") { var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, tuyaEncryptKey); var revString = Encoding.UTF8.GetString(bytes); - Control.Ins.UpdataFunctionStatus(revString, null); + HDL_ON.UI.UI2.PersonalCenter.PirDevice.PirMethod.controldata = revString; + } + //App璁㈤槄閬ユ帶鍣ㄨ嚜瀛︽寜閿涔犳垚鍔熼�氱煡 + else if (topic == $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/event/irCodeStudyDone/up") + { + var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, tuyaEncryptKey); + var revString = Encoding.UTF8.GetString(bytes); + UI.UI2.PersonalCenter.PirDevice.PirMethod.buttondata = revString; + } + #region 鏁版嵁鏇存柊鎺ㄩ�佷富棰� + //appHomeRefresh锛氫綇瀹呮暟鎹埛鏂伴�氱煡 + else if (topic == $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/event/appHomeRefresh/up") + { + MainPage.Log("浣忓畢鏁版嵁鍒锋柊閫氱煡"); + new HttpServerRequest().GetHomePager(); + } + //appRoomRefresh锛氭埧闂存暟鎹埛鏂伴�氱煡 + else if (topic == $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/event/appRoomRefresh/up") + { + MainPage.Log("鎴块棿鏁版嵁鍒锋柊閫氱煡"); + var roomResult = new HttpServerRequest().GetRoomList(); + if (roomResult.Code == StateCode.SUCCESS) + { + MainPage.Log($"璇诲彇鎴块棿淇℃伅鎴愬姛"); + var revData = Newtonsoft.Json.JsonConvert.DeserializeObject<SpatialApiPack>(roomResult.Data.ToString()); + if (revData == null) + { + revData = new SpatialApiPack(); + } + { + SpatialInfo.CurrentSpatial.UpdateSpatialList(revData.list); + } + } + else + { + MainPage.Log($"璇诲彇鎴块棿鏁版嵁澶辫触:Code:{roomResult.Code}; msg:{roomResult.message}"); + } + } + //appDeviceRefresh锛氳澶囨暟鎹埛鏂伴�氱煡 + else if (topic == $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/event/appDeviceRefresh/up") + { + MainPage.Log("璁惧鏁版嵁鍒锋柊閫氱煡"); + var deviceResult = new HttpServerRequest().GetDeviceList(); + if (deviceResult.Code == StateCode.SUCCESS) + { + MainPage.Log($"璇诲彇璁惧淇℃伅鎴愬姛"); + var deviceList = Newtonsoft.Json.JsonConvert.DeserializeObject<DevcieApiPack>(deviceResult.Data.ToString()); + if (deviceList == null) + { + deviceList = new DevcieApiPack(); + } + string delFile = ""; + if (FunctionList.List.GetDeviceFunctionList().Count > 0) + { + for (int i = 0; i < FunctionList.List.GetDeviceFunctionList().Count;) + { + var localFunction = FunctionList.List.GetDeviceFunctionList()[i]; + if (localFunction.Spk_Prefix == FunctionCategory.Music || string.IsNullOrEmpty(localFunction.Spk_Prefix)) + { + i++; + continue; + } + var newFunction = deviceList.list.Find((obj) => obj.deviceId == localFunction.deviceId); + + if (delFile == localFunction.savePath) + { + i++; + continue; + } + delFile = localFunction.savePath; + FunctionList.List.DeleteFunction(localFunction); + } + } + //澶勭悊鍓╀笅鐨勬柊澧炲姛鑳� + foreach (var newFunction in deviceList.list) + { + newFunction.SaveFunctionFile(); + FunctionList.List.IniFunctionList(newFunction.savePath); + } + } + else + { + MainPage.Log($"璇诲彇浜戠璁惧鏁版嵁澶辫触:Code:{deviceResult.Code}; Msg:{deviceResult.message}"); + } + } + #endregion + //A缃戝叧璁惧鐘舵��-鍖呭惈娑傞甫璁惧 + 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); + Control.Ins.UpdataFunctionStatus(revString, null, true); } //涓�绔彛鏁版嵁瑙f瀽 else { - SetGatewayOnlineResetCheck(); - var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, mqttEncryptKey); + //SetGatewayOnlineResetCheck(); + //var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, mqttEncryptKey); //bus鏁版嵁瑙f瀽 var packet = new Packet(); @@ -313,7 +443,7 @@ } } catch { } - }); + })); } //(2)DisconnectedHandler @@ -331,6 +461,7 @@ RemoteMqttClient.UseConnectedHandler(async (e) => { IfNeedReadAllDeviceStatus = true; + Control.Ins.GatewayOnline_Cloud = true; Utlis.WriteLine($"============>Mqtt杩滅▼杩炴帴鎴愬姛"); SendPushSignOut(); }); @@ -354,6 +485,8 @@ catch (Exception ex) { Utlis.WriteLine($"error:" + ex.Message); + //mqtt杩炴帴寮傚父锛屾竻绌烘湰鍦癿qtt淇℃伅锛屽彲鑳介渶瑕侀噸鏂拌幏鍙栵細wxr + MqttInfoConfig.Current.Refresh(); } finally { @@ -363,7 +496,7 @@ Utlis.WriteLine($"StartCloudMqtt: 缁撴潫"); } - }); + })); } @@ -411,11 +544,6 @@ /// <returns></returns> static async Task StartMQTTGetInfo() { - //if (!Control.Ins.IsRemote) - //{ - // return; - //} - await GetMqttInfoAndMQTTConnectAsync(); ////--鍒ゆ柇鏄綋鍓嶆槸鍚﹀垎浜殑浣忓畢 @@ -434,12 +562,6 @@ /// </summary> static async Task MQTTConnectAsync() { - - //if (!Control.Ins.IsRemote) - //{ - // return; - //} - //if (MqttInfoConfig.Current.HomeGatewayInfo != null && MqttInfoConfig.Current.mMqttInfo != null) //娌℃湁缃戝叧鎯呭喌涓嬶紝涔熼渶瑕佽繛鎺qtt锛屾秱楦︾涓夋柟璁惧涓嶉渶瑕佺綉鍏� if (MqttInfoConfig.Current.mMqttInfo != null) @@ -461,16 +583,13 @@ MqttInfoConfig.Current.Save(); - if (MqttInfoConfig.Current.HomeGatewayInfo == null) - { - MqttInfoConfig.Current.HomeGatewayInfo = new Server.HomeGatewayInfo(); - } + mqttEncryptKey = MqttInfoConfig.Current.HomeGatewayInfo.aesKey; //瑙e瘑瀵嗛挜瑙勫垯锛氬凡鐜版湁鐨勪綇瀹匢D涓哄熀鍑�,浠庡彸杈逛竴涓�鑾峰彇鍊�,鏈�鍚庡鏋滀笉澶�16浣�,鍒欏線鍙宠ˉ闆� string aesKey = string.Empty; - for (int i = DB_ResidenceData.Instance.CurrentRegion.RegionID.Length - 1; i >= 0; i--) + for (int i = DB_ResidenceData.Instance.CurrentRegion.id.Length - 1; i >= 0; i--) { - aesKey += DB_ResidenceData.Instance.CurrentRegion.RegionID[i].ToString(); + aesKey += DB_ResidenceData.Instance.CurrentRegion.id[i].ToString(); if (aesKey.Length == 16) { break; } } aesKey = aesKey.PadRight(16, '0'); @@ -509,6 +628,8 @@ //閲嶆柊涓績鏈嶅姟鍣ㄨ幏鍙栧弬鏁版爣璁� MqttInfoConfig.Current.IfGetMqttInfoSuccess = false; Console.WriteLine("Connect error: " + ex.Message); + //mqtt杩炴帴寮傚父锛屾竻绌烘湰鍦癿qtt淇℃伅锛屽彲鑳介渶瑕侀噸鏂拌幏鍙栵細wxr + MqttInfoConfig.Current.Refresh(); } finally { @@ -530,12 +651,11 @@ { try { - SetGatewayOnlineResetCheck(); - if (Control.Ins.IsRemote) + //SetGatewayOnlineResetCheck(); + if (Control.Ins.GatewayOnline_Cloud) { CheckIfNeedReadAllDeviceStatus(); } - } catch { } } @@ -545,22 +665,35 @@ /// </summary> static void ReceiveNotifyGateWayOffline() { - if (Control.Ins.IsRemote) - { - Control.Ins.GatewayOnline = false; - } + Control.Ins.GatewayOnline_Cloud = false; } - /// <summary> /// 鏀跺埌鎸や笅绾挎帹閫� /// </summary> static void ReceiveNotifySqueezeAsync(string mMes) { - if (mMes == PushSignStr) return;//鏄嚜宸辩殑鐧诲綍鎺ㄩ�佷笉澶勭悊 + if (mMes == PushSignStr) return;//鏄嚜宸辩殑鐧诲綍鎺ㄩ�佷笉澶勭悊//鎴栬�呭綋鍓嶄笉鏄繙绋嬮摼鎺ョ姸鎬� + //娴嬭瘯璐﹀彿锛屼笉鎸や笅绾� + switch (UserInfo.Current.AccountString) + { + case "13415629083": + case "18316120654": + case "15622703419": + case "18824864143": + case "464027401@qq.com": + case "2791308028@qq.com": + case "13697499568": + case "18666455392": + case "13375012446": + case "13602944661": + case "18778381374": + case "18316672920": + case "15971583093": + case "15626203746": + return; + } - //鏂紑杩滅▼杩炴帴 - Control.Ins.IsRemote = false; if (!UserInfo.Current.IsLogin) { return; @@ -587,20 +720,20 @@ //HDLRequest.Current.PushserivceSignOut (); } - /// <summary> - /// 鏀跺埌CheckGateway涓婚 - /// </summary> - static void ReceiveCheckGateway(string mMes) - { - if (!Control.Ins.IsRemote) return; + ///// <summary> + ///// 鏀跺埌CheckGateway涓婚 + ///// </summary> + //static void ReceiveCheckGateway(string mMes) + //{ + // if (!Control.Ins.IsRemote) return; - Utlis.WriteLine("ReceiveCheckGateway锛�"); + // Utlis.WriteLine("ReceiveCheckGateway锛�"); - //CheckIfNeedReadAllDeviceStatus (); + // //CheckIfNeedReadAllDeviceStatus (); - //var obj = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(mMes); - Control.Ins.GatewayOnline = true; - } + // //var obj = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(mMes); + // Control.Ins.GatewayOnline = true; + //} /// <summary> /// 鎺ㄩ�佹尋涓嬬嚎涓婚 @@ -632,11 +765,6 @@ } await RemoteMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topicName, Payload = message, Retain = false, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce }); break; - case 3: - topicName = $"/ClientToBusGateWay/{MqttInfoConfig.Current.HomeGatewayInfo.gatewayId}/Common/CheckGateway"; - Utlis.WriteLine("CheckGateway"); - await RemoteMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topicName, Retain = false, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce }); - break; case 4://鍙戝竷鏂版柟妗堢殑鎸や笅绾夸富棰� topicName = $"/BusGateWayToClient/{UserInfo.Current.ID}" + PushNotifySqueeze; //message = Encoding.UTF8.GetBytes (PushSignStr); @@ -665,27 +793,27 @@ /// </summary> static bool IfNeedReadAllDeviceStatus = true; - /// <summary> - /// 璁剧疆缃戝叧鍦ㄧ嚎鏍囧織锛屽苟閲嶇疆CheckGateway鍙傛暟 - /// </summary> - static void SetGatewayOnlineResetCheck() - { - if (Control.Ins.IsRemote) - { - if (!Control.Ins.GatewayOnline) - { - try - { - if (DB_ResidenceData.Instance.HomeGateway != null) - { - DB_ResidenceData.Instance.HomeGateway.gatewayStatus = true; - } - Control.Ins.GatewayOnline = true; - } - catch { } - } - } - } + ///// <summary> + ///// 璁剧疆缃戝叧鍦ㄧ嚎鏍囧織锛屽苟閲嶇疆CheckGateway鍙傛暟 + ///// </summary> + //static void SetGatewayOnlineResetCheck() + //{ + // if (Control.Ins.IsRemote) + // { + // if (!Control.Ins.GatewayOnline) + // { + // try + // { + // if (DB_ResidenceData.Instance.HomeGateway != null) + // { + // DB_ResidenceData.Instance.HomeGateway.gatewayStatus = true; + // } + // Control.Ins.GatewayOnline = true; + // } + // catch { } + // } + // } + //} /// <summary> @@ -694,9 +822,12 @@ /// <returns></returns> static async Task GetMqttInfoAndMQTTConnectAsync() { - var mqttInfoRequestResult_Obj = new Server.HttpServerRequest().GetMqttRemoteInfo(GetRandomKey()); + var mqttInfoRequestResult_Obj = new HttpServerRequest().GetMqttRemoteInfo(GetRandomKey()); if (mqttInfoRequestResult_Obj != null) { + MainPage.Log($"鑾峰彇mqtt info 鎴愬姛 /r/n clientId:{mqttInfoRequestResult_Obj.clientId}/r/n passWord:{mqttInfoRequestResult_Obj.passWord} /r/n url:{mqttInfoRequestResult_Obj.url}/r/n userName:{mqttInfoRequestResult_Obj.userName}"); + + MqttInfoConfig.Current.mMqttInfo = mqttInfoRequestResult_Obj; await MQTTConnectAsync(); //1.鍒ゆ柇鏄惁缁戝畾浜嗙綉鍏筹紝鑾峰彇缃戝叧杩滅▼杩炴帴鐨勫姞瀵咾EY @@ -865,4 +996,4 @@ } -} +} \ No newline at end of file -- Gitblit v1.8.0