~xm/HomeApp.git

			@@ -1,4 +1,5 @@
			using System;
			using Newtonsoft.Json.Linq;
			using System;
			using System.Collections.Generic;
			using System.Text;
			using System.Threading.Tasks;
			@@ -151,6 +152,47 @@

			#endregion

			#region ■ 设置启用空调的摆风功能_____________

			/// <summary>
			/// 设置启用空调的摆风功能
			/// </summary>
			/// <param name="device">空调对象</param>
			/// <param name="data">从二进制转换的十进制值</param>
			/// <returns></returns>
			public async Task<bool> SetUseAcSwingFunctionStatu(AC device, int data)
			{
			var result = await HdlDeviceAttributeLogic.Current.WriteDeviceAttribute(device, 514, 4097, 25, data.ToString());
			//检测网关返回的共通错误状态码
			string error = HdlCheckLogic.Current.CheckCommonErrorCode(result);
			if (error != null)
			{
			this.ShowTipMsg(error);
			return false;
			}
			if (result == null \|\| result.setWritableValueResponData == null)
			{
			//设置空调摆风失败
			string msg = Language.StringByID(R.MyInternationalizationString.uSetAirConditionerSwingFunctionFail);
			//拼接上【网关回复超时】的Msg
			msg = UserCenterLogic.CombineGatewayTimeOutMsg(msg, result);
			this.ShowTipMsg(msg);
			return false;
			}
			if (result.setWritableValueResponData.Status != 0)
			{
			//设置空调摆风失败
			string msg = Language.StringByID(R.MyInternationalizationString.uSetAirConditionerSwingFunctionFail);
			this.ShowTipMsg(msg);
			return false;
			}
			await HdlGatewayLogic.Current.UpLoadDeviceBackupDataToGateway(device, GatewayBackupEnum.A空调摆风功能, data);

			return true;
			}

			#endregion

			#region ■ 一般方法___________________________

			/// <summary>
			@@ -180,5 +222,597 @@
			}

			#endregion


			#region ■ 升级空调第三方模块的接口___________

			#region 读取IRACC模块固件版本（APP -> Zigbee MCU）
			///<summary >
			///读取IRACC模块固件版本
			/// </summary>
			public async System.Threading.Tasks.Task<ReadACFirewareVersionResponAllData> ReadACFirewareVersionAsync(CommonDevice device)
			{
			ReadACFirewareVersionResponAllData result = null;
			var Gateway = device.Gateway;
			if (Gateway == null)
			{
			result = new ReadACFirewareVersionResponAllData { errorMessageBase = "当前没有网关" };
			return result;
			}
			return await System.Threading.Tasks.Task.Run(async () =>
			{
			Action<string, string> action = (topic, message) =>
			{
			var gatewayID = topic.Split('/')[0];
			var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);

			if (topic == gatewayID + "/" + "ZbDataPassthrough")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.clientDataPassthroughResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ClientDataPassthroughResponseData>(jobject["Data"].ToString());

			if (gatewayTemp.clientDataPassthroughResponseData == null)
			{
			result = new ReadACFirewareVersionResponAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			if (gatewayTemp.clientDataPassthroughResponseData?.PassData != null)
			{
			var data = gatewayTemp.clientDataPassthroughResponseData.PassData;
			var command = data[4].ToString() + data[5].ToString() + data[2].ToString() + data[3].ToString();
			if (command == "0259")
			{
			var tempD = new ReadACFirewareVersionResponData();
			tempD.Status = Convert.ToInt32(data[10].ToString() + data[11].ToString(), 16);
			if (data.Length == 82)
			{
			var firewareString = data.Substring(12);
			var aa = firewareString.Length;
			firewareVersion = firewareString;
			var bytes = new byte[firewareString.Length / 2];
			for (int i = 0; i < bytes.Length; i++)
			{
			bytes[i] = Convert.ToByte(firewareString.Substring(i * 2, 2), 16);
			}

			var firewareVersionTemp = System.Text.Encoding.ASCII.GetString(bytes);
			tempD.FirewareVersion = firewareVersionTemp.Replace('\0', ' ').Trim();
			}
			result = new ReadACFirewareVersionResponAllData { readACFirewareVersionResponData = tempD };
			System.Console.WriteLine($"UI收到通知后的主题_command:0258_{topic}");
			}
			}
			}
			}
			};

			Gateway.Actions += action;
			System.Console.WriteLine("ClientDataPassthrough_Actions 启动" + System.DateTime.Now.ToString());

			try
			{
			var passData = ReadACFirewareVersionData("01");
			var jObject = new JObject { { "DeviceAddr", device.DeviceAddr }, { "Epoint", 200 }, { "Cluster_ID", 64513 }, { "Command", 0 } };
			var data = new JObject { { "PassData", passData } };
			jObject.Add("Data", data);
			Gateway.Send(("ClientDataPassthrough"), jObject.ToString());
			}
			catch { }

			var dateTime = DateTime.Now;
			while ((DateTime.Now - dateTime).TotalMilliseconds < 3000)
			{
			await System.Threading.Tasks.Task.Delay(10);
			if (result != null)
			{
			break;
			}
			}
			if ((DateTime.Now - dateTime).TotalMilliseconds > 3000)
			{
			result = new ReadACFirewareVersionResponAllData { errorMessageBase = " 回复超时，请重新操作" };
			}
			Gateway.Actions -= action;
			System.Console.WriteLine("ClientDataPassthrough_Actions 退出" + System.DateTime.Now.ToString());

			return result;
			});
			}

			/// <summary>
			/// 读取IRACC模块固件版本
			/// </summary>
			string ReadACFirewareVersionData(string reserve)
			{
			string data = "";
			string dataLength = "05";
			string dataComand1 = "58";
			string dataComand2 = "02";
			string dataSerialNum = "01";
			string addDataLength = "01";
			string reserveData = reserve;

			try
			{
			data = dataLength + dataComand1 + dataComand2 + dataSerialNum + addDataLength +
			reserveData;
			}
			catch { };

			return data;
			}

			/// <summary>
			/// IRACC模块固件版本,网关反馈信息
			/// </summary>
			public ReadACFirewareVersionResponAllData readACFirewareVersionResponAllData;
			/// <summary>
			/// IRACC模块固件版本,网关反馈信息
			/// </summary>
			[System.Serializable]
			public class ReadACFirewareVersionResponAllData
			{
			/// <summary>
			/// 错误信息
			/// </summary>
			public string errorMessageBase;
			/// <summary>
			/// 网关信息错误反馈
			/// <para>当网关接收到客户端信息后，出现以下异常情况将反馈错误。</para>
			/// </summary>
			public CommonDevice.ErrorResponData errorResponData;
			/// <summary>
			/// IRACC模块固件版本信息
			/// </summary>
			public ReadACFirewareVersionResponData readACFirewareVersionResponData;
			}

			/// <summary>
			/// IRACC模块固件版本的数据
			/// </summary>
			[System.Serializable]
			public class ReadACFirewareVersionResponData
			{
			/// <summary>
			/// 状态
			///<para>0--成功</para>
			///<para>1--失败</para>
			///<para>ff--无效</para>
			/// </summary>
			public int Status;
			/// <summary>
			/// 固件版本
			/// </summary>
			public string FirewareVersion;
			}
			#endregion

			#region 升级IRACC模块通知（APP -> Zigbee MCU）
			///<summary >
			///升级IRACC模块通知
			/// <para>firewareVer:固件版本</para>
			/// <para>firewareSize:固件大小</para>
			/// </summary>
			public async System.Threading.Tasks.Task<ResponseAllData> UpggradeACNotificationAsync(CommonDevice device, string firewareVer, long firewareSize)
			{
			ResponseAllData result = null;
			var Gateway = device.Gateway;
			if (Gateway == null)
			{
			result = new ResponseAllData { errorMessageBase = "当前没有网关" };
			return result;
			}
			return await System.Threading.Tasks.Task.Run(async () =>
			{
			Action<string, string> action = (topic, message) =>
			{
			var gatewayID = topic.Split('/')[0];
			var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);

			if (topic == gatewayID + "/" + "ZbDataPassthrough")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.clientDataPassthroughResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ClientDataPassthroughResponseData>(jobject["Data"].ToString());

			if (gatewayTemp.clientDataPassthroughResponseData == null)
			{
			result = new ResponseAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			if (gatewayTemp.clientDataPassthroughResponseData?.PassData != null)
			{
			var data = gatewayTemp.clientDataPassthroughResponseData.PassData;
			var command = data[4].ToString() + data[5].ToString() + data[2].ToString() + data[3].ToString();
			if (command == "025b")
			{
			var tempD = new ResponseData();
			if (data.Length == 12)
			{
			tempD.status = Convert.ToInt32(data[10].ToString() + data[11].ToString(), 16);
			}
			result = new ResponseAllData { responseData = tempD };
			System.Console.WriteLine($"UI收到通知后的主题_{ topic}");
			}
			}
			}
			}
			};

			Gateway.Actions += action;
			System.Console.WriteLine("ClientDataPassthrough_Actions 启动" + System.DateTime.Now.ToString());

			try
			{
			var passData = UpggradeACNotificationData(firewareVer, firewareSize);
			var jObject = new JObject { { "DeviceAddr", device.DeviceAddr }, { "Epoint", 200 }, { "Cluster_ID", 64513 }, { "Command", 0 } };
			var data = new JObject { { "PassData", passData } };
			jObject.Add("Data", data);
			Gateway.Send(("ClientDataPassthrough"), jObject.ToString());
			}
			catch { }

			var dateTime = DateTime.Now;
			while ((DateTime.Now - dateTime).TotalMilliseconds < 3000)
			{
			await System.Threading.Tasks.Task.Delay(10);
			if (result != null)
			{
			break;
			}
			}
			if ((DateTime.Now - dateTime).TotalMilliseconds > 3000)
			{
			result = new ResponseAllData { errorMessageBase = " 回复超时，请重新操作" };
			}
			Gateway.Actions -= action;
			System.Console.WriteLine("ClientDataPassthrough_Actions 退出" + System.DateTime.Now.ToString());

			return result;
			});
			}

			private string firewareVersion = string.Empty;
			/// <summary>
			/// 升级IRACC模块通知返回
			/// </summary>
			string UpggradeACNotificationData(string firewareVer, long firewareSize)
			{
			string data = "";
			string dataLength = "2C";
			string dataComand1 = "5A";
			string dataComand2 = "02";
			string dataSerialNum = "01";
			string addDataLength = "28";
			string deviceUpgradeMethod = "01";
			string firewareVersionData = "";
			string firewareSizeData = "";

			try
			{
			//固件版本
			var firewareVerBytes = System.Text.Encoding.ASCII.GetBytes(firewareVer);
			for (int i = 0; i < firewareVerBytes.Length; i++)
			{
			var fw = Convert.ToString(firewareVerBytes[i], 16);
			if (fw.Length == 1)
			{
			fw = "0" + fw;
			}
			firewareVersionData += fw;
			}

			var aa = firewareVersionData.Length;
			firewareVersionData = firewareVersionData.PadRight(70, '0');

			//固件尺寸
			var tempFwSize = Convert.ToString(firewareSize, 16);
			tempFwSize = tempFwSize.PadLeft(8, '0');
			for (int i = 6; i >= 0; i = i - 2)
			{
			firewareSizeData += tempFwSize.Substring(i, 2);
			}

			data = dataLength + dataComand1 + dataComand2 + dataSerialNum + addDataLength +
			deviceUpgradeMethod + firewareVersionData + firewareSizeData;

			}
			catch { };

			return data;
			}

			/// <summary>
			///升级IRACC模块通知回复
			/// </summary>
			public ResponseAllData keyColorDataResponseAllData;
			[System.Serializable]
			public class ResponseAllData
			{
			/// <summary>
			/// 错误信息
			/// </summary>
			public string errorMessageBase;
			/// <summary>
			/// 网关信息错误反馈
			/// <para>当网关接收到客户端信息后，出现以下异常情况将反馈错误。</para>
			/// </summary>
			public CommonDevice.ErrorResponData errorResponData;
			/// <summary>
			/// 升级IRACC模块通知信息
			/// </summary>
			public ResponseData responseData;
			}

			/// <summary>
			/// 升级IRACC模块通知回复（Zigbee MCU -> APP）
			/// </summary>
			[System.Serializable]
			public class ResponseData
			{
			/// <summary>
			/// 状态值
			/// <para>0--版本号不一致（可以升级</para>
			/// <para>1--版本号一致（不用升级</para>
			/// <para>2--预留（暂时不用到</para>
			/// <para>ff--无效（暂时不用到）</para>
			/// </summary>
			public int status = -1;
			}
			#endregion

			#region 设备请求APP获取升级数据（Zigbee MCU -> APP,主动上报）
			/// <summary>
			///设备请求APP获取升级数据（Zigbee MCU -> APP,主动上报）
			/// </summary>
			[System.Serializable]
			public class DeviceRequestUpgradeResponseData
			{
			/// <summary>
			/// 数据偏移量，每个分包偏移量+（1-43）
			/// </summary>
			public string offset = string.Empty;
			/// <summary>
			/// 数据长度len
			/// </summary>
			public int dataLength = -1;
			}
			#endregion

			#region 发升级数据到设备（APP -> Zigbee MCU）
			///<summary >
			///读取IRACC模块固件版本
			/// <para>reserve:0-ff</para>
			/// </summary>
			public async void UpgradeAsync(CommonDevice device, SendUpgradeData upgradeData)
			{
			var Gateway = device.Gateway;
			if (Gateway == null)
			{
			return;
			}
			Action<string, string> action = (topic, message) => { };
			Gateway.Actions += action;
			System.Console.WriteLine("ClientDataPassthrough_Actions 启动" + System.DateTime.Now.ToString());

			try
			{
			string passData = "";
			if (upgradeData != null)
			{
			passData = SendUpgrade(upgradeData);
			}

			var jObject = new JObject { { "DeviceAddr", device.DeviceAddr }, { "Epoint", 200 }, { "Cluster_ID", 64513 }, { "Command", 0 } };
			var data = new JObject { { "PassData", passData } };
			jObject.Add("Data", data);
			Gateway.Send(("ClientDataPassthrough"), jObject.ToString());
			}
			catch { }

			Gateway.Actions -= action;
			System.Console.WriteLine("ClientDataPassthrough_Actions 退出" + System.DateTime.Now.ToString());
			}

			/// <summary>
			/// 发升级数据到设备
			/// </summary>
			string SendUpgrade(SendUpgradeData upgradeData)
			{
			string data = "";
			string dataLength = "";
			string dataComand1 = "5D";
			string dataComand2 = "02";
			string dataSerialNum = "01";
			string addDataLength = "";

			string status = "";
			string offset = "";
			string upgradeDataLength = "";
			string dataString = "";

			try
			{
			var len = 4 + 1 + 4 + 1 + upgradeData.dataLength;
			dataLength = Convert.ToString(len, 16);
			if (dataLength.Length == 1)
			{
			dataLength = "0" + dataLength;
			}

			addDataLength = Convert.ToString(6 + upgradeData.dataLength, 16);
			if (addDataLength.Length == 1)
			{
			addDataLength = "0" + addDataLength;
			}

			if (upgradeData.status == 0)
			{
			status = "00";
			}
			else if (upgradeData.status == 1)
			{
			status = "01";
			}
			else
			{
			status = "ff";
			}


			offset = upgradeData.offset;

			var dl = Convert.ToString(upgradeData.dataLength, 16);
			if (dl.Length == 1)
			{
			upgradeDataLength = "0" + dl;
			}
			else
			{
			upgradeDataLength = dl;
			}

			for (int i = 0; i < upgradeData.databytes.Length; i++)
			{
			var dataB = Convert.ToString(upgradeData.databytes[i], 16);
			if (dataB.Length == 1)
			{
			dataB = "0" + dataB;
			}
			dataString += dataB;
			}

			data = dataLength + dataComand1 + dataComand2 + dataSerialNum + addDataLength +
			status + offset + upgradeDataLength + dataString;
			}
			catch { };

			return data;
			}

			/// <summary>
			/// 发送升级数据到设备（APP -> Zigbee MCU）
			/// </summary>
			[System.Serializable]
			public class SendUpgradeData
			{
			/// <summary>
			/// 0--成功
			///<para>1--失败</para>
			///<para>ff--无效</para>
			/// </summary>
			public int status = 0;
			/// <summary>
			/// 数据偏移量，每个分包偏移量+（1-43）
			/// </summary>
			public string offset;
			/// <summary>
			/// 数据长度len
			/// </summary>
			public int dataLength = -1;

			/// <summary>
			/// 分包数据
			/// </summary>
			public byte[] databytes;
			}
			#endregion

			#region 分包结束（Zigbee MCU -> APP,主动上报）
			/// <summary>
			/// 设备请求APP获取分包结束命令（Zigbee MCU -> APP）
			/// </summary>
			[System.Serializable]
			public class DeviceRequestFinishResponseData
			{
			/// <summary>
			/// 0-ff
			/// </summary>
			public int reserve = -1;
			}
			#endregion

			#region 分包结束（APP -> Zigbee MCU）
			///<summary >
			///读取IRACC模块固件版本
			/// <para>status:0--成功;1--失败;ff--无效 .</para>
			/// </summary>
			public async void SendFinishAsync(CommonDevice device, int status)
			{
			var Gateway = device.Gateway;
			if (Gateway == null)
			{
			return;
			}
			Action<string, string> action = (topic, message) => { };
			Gateway.Actions += action;
			System.Console.WriteLine("ClientDataPassthrough_Actions 启动" + System.DateTime.Now.ToString());

			try
			{
			var passData = SendFinishDataString(status);
			var jObject = new JObject { { "DeviceAddr", device.DeviceAddr }, { "Epoint", 200 }, { "Cluster_ID", 64513 }, { "Command", 0 } };
			var data = new JObject { { "PassData", passData } };
			jObject.Add("Data", data);
			Gateway.Send(("ClientDataPassthrough"), jObject.ToString());
			}
			catch { }

			Gateway.Actions -= action;
			System.Console.WriteLine("ClientDataPassthrough_Actions 退出" + System.DateTime.Now.ToString());
			}

			/// <summary>
			/// 发升级数据到设备
			/// </summary>
			string SendFinishDataString(int status)
			{
			string data = "";
			string dataLength = "05";
			string dataComand1 = "5F";
			string dataComand2 = "02";
			string dataSerialNum = "01";
			string addDataLength = "01";
			string statusString = "";
			try
			{
			if (status == 0)
			{
			statusString = "00";
			}
			else if (status == 1)
			{
			statusString = "01";
			}
			else
			{
			statusString = "ff";
			}
			data = dataLength + dataComand1 + dataComand2 + dataSerialNum + addDataLength +
			statusString;
			}
			catch { };

			return data;
			}

			/// <summary>
			/// 分包结束返回（APP -> Zigbee MCU
			/// </summary>
			//[System.Serializable]
			public class SendFinishData
			{
			/// <summary>
			/// 状态：成功/失败
			///<para>0--成功<<para>
			///<para>1--失败<<para>
			///<para>ff--无效<<para>
			/// </summary>
			public int status = -1;
			}

			#endregion
			#endregion
			}
			}