~wxr/HDL_APP_Project.git

			@@ -197,10 +197,17 @@
			Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.RegionID}/app/thing/topo/found",
			QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce
			};
			//App订阅遥控器自学按键学习成功通知
			var study = new MqttTopicFilter()
			{
			Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.RegionID}/app/thing/event/irCodeStudyDone/up",
			QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce
			};

			Utlis.WriteLine("开始订阅！");
			var result = await RemoteMqttClient.SubscribeAsync(new MqttTopicFilter[] {
			pirStatus,
			study,
			topicFilterPush2, topicAlinkStatus });
			if (result.Items[0].ResultCode == MQTTnet.Client.Subscribing.MqttClientSubscribeResultCode.GrantedQoS0)
			{
			@@ -238,7 +245,7 @@

			Utlis.WriteLine($"StartCloudMqtt: 开始");

			await Task.Factory.StartNew(async () => {
			await Task.Factory.StartNew((Func<Task>)(async () => {
			try
			{
			#region 初始化远程Mqtt
			@@ -250,7 +257,7 @@
			if (RemoteMqttClient.ApplicationMessageReceivedHandler == null)
			{
			//处理接收到的数据
			RemoteMqttClient.UseApplicationMessageReceivedHandler((e) => {
			RemoteMqttClient.UseApplicationMessageReceivedHandler((Action<MqttApplicationMessageReceivedEventArgs>)((e) => {
			try
			{
			var topic = e.ApplicationMessage.Topic;
			@@ -280,12 +287,6 @@
			}
			}

			//一些特殊的主题处理(为了执行速度,尽可能的别加耗时的操作 true:执行了特殊处理 false:没有执行特殊处理)
			if (Stan.HdlCloudReceiveLogic.Current.CloudOverallMsgReceiveEx(topic, e.ApplicationMessage.Payload, mqttEncryptKey, tuyaEncryptKey) == true)
			{
			return;
			}

			if (topic == $"/BusGateWayToClient/{UserInfo.Current.ID}" + PushNotifySqueeze)
			{
			var mMes = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
			@@ -297,7 +298,16 @@
			{
			var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, tuyaEncryptKey);
			var revString = Encoding.UTF8.GetString(bytes);
			HDL_ON.UI.UI2.PersonalCenter.PirDevice.Method.addcontronsid = revString;
			HDL_ON.UI.UI2.PersonalCenter.PirDevice.Method.controldata = revString;
			//ReceiveCheckGateway(ss);
			//return;
			}
			//App订阅遥控器自学按键学习成功通知
			else if (topic == $"/user/{DB_ResidenceData.Instance.CurrentRegion.RegionID}/app/thing/event/irCodeStudyDone/up")
			{
			var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, tuyaEncryptKey);
			var revString = Encoding.UTF8.GetString(bytes);
			HDL_ON.UI.UI2.PersonalCenter.PirDevice.Method.buttondata = revString;
			//ReceiveCheckGateway(ss);
			//return;
			}
			@@ -312,7 +322,7 @@
			else
			{
			//SetGatewayOnlineResetCheck();
			//var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, mqttEncryptKey);
			var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, mqttEncryptKey);
			//bus数据解析
			var packet = new Packet();

			@@ -328,7 +338,7 @@
			}
			}
			catch { }
			});
			}));
			}

			//(2)DisconnectedHandler
			@@ -379,7 +389,7 @@
			Utlis.WriteLine($"StartCloudMqtt: 结束");
			}

			});
			}));
			}