~wjc/HomeApp.git

old mode 100755 new mode 100644

			@@ -5,118 +5,576 @@
			using ZigBee.Device;

			namespace Shared.Phone.UserCenter
			{
			{
			/// <summary>
			/// 设备属性的逻辑类
			/// </summary>
			public class HdlDeviceAttributeLogic
			{
			#region ■ 变量声明___________________________

			/// <summary>
			/// 设备属性的逻辑类
			/// 属性的逻辑
			/// </summary>
			private static HdlDeviceAttributeLogic m_Current = null;
			/// <summary>
			/// 属性的逻辑
			/// </summary>
			public static HdlDeviceAttributeLogic Current
			{
			get
			{
			if (m_Current == null)
			{
			m_Current = new HdlDeviceAttributeLogic();
			}
			return m_Current;
			}
			set
			{
			m_Current = value;
			}
			}

			#endregion

			#region ■ 写入设备属性_______________________

			/// <summary>
			/// 获取更改设备私有属性的命令
			/// </summary>
			public class HdlDeviceAttributeLogic
			{
			#region ■ 变量声明___________________________

			/// <summary>
			/// 属性的逻辑
			/// </summary>
			private static HdlDeviceAttributeLogic m_Current = null;
			/// <summary>
			/// 属性的逻辑
			/// </summary>
			public static HdlDeviceAttributeLogic Current
			{
			get
			/// <param name="clusterId"></param>
			/// <param name="attributeId"></param>
			/// <param name="attributeDataType"></param>
			/// <param name="attributeData"></param>
			/// <returns></returns>
			public string GetWriteDeviceAttributeText(string DeviceAddr, int DeviceEpoint, int clusterId, int attributeId, int attributeDataType, object attributeData)
			{
			var jObject = new Newtonsoft.Json.Linq.JObject { { "DeviceAddr", DeviceAddr }, { "Epoint", DeviceEpoint }, { "Cluster_ID", clusterId }, { "Command", 120 } };
			Newtonsoft.Json.Linq.JObject data = null;
			if (attributeData is int)
			{
			data = new Newtonsoft.Json.Linq.JObject { { "Undivided", 0 }, { "AttributeId", attributeId }, { "AttributeDataType", attributeDataType }, { "AttributeData", Convert.ToInt32(attributeData) } };
			}
			else
			{
			data = new Newtonsoft.Json.Linq.JObject { { "Undivided", 0 }, { "AttributeId", attributeId }, { "AttributeDataType", attributeDataType }, { "AttributeData", attributeData.ToString() } };
			}
			jObject.Add("Data", data);

			return jObject.ToString();
			}

			#endregion

			#region ■ 空调_______________________________

			/// <summary>
			/// SendACStatuComand
			/// </summary>
			/// <param name="device">设备</param>
			public void SendACStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			new System.Threading.Thread(() =>
			{
			SendFanStatuComand(device);
			System.Threading.Thread.Sleep(300);
			SendThermostatStatuComand(device);
			})
			{ IsBackground = true }.Start();
			}

			/// <summary>
			/// SendThermostatStatuComand
			/// </summary>
			/// <param name="device">设备</param>
			public void SendThermostatStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			if (m_Current == null)
			{
			m_Current = new HdlDeviceAttributeLogic();
			}
			return m_Current;
			}
			set
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.Thermostat },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			m_Current = value;
			}
			}

			#endregion

			#region ■ 写入设备属性_______________________

			/// <summary>
			/// 设置空调的自定义模式
			/// </summary>
			/// <param name="device">设备对象</param>
			/// <param name="clusterId">镞ID</param>
			/// <param name="attributeId">属性ID</param>
			/// <param name="attributeDataType">数据类型</param>
			/// <param name="attributeData">需要写入的数据</param>
			/// <returns></returns>
			public async System.Threading.Tasks.Task<CommonDevice.SetWritableValueResponAllData> WriteDeviceAttribute(CommonDevice device, int clusterId, int attributeId, int attributeDataType, int attributeData)
			{
			var MyGateway = device.Gateway;
			if (MyGateway == null)
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.LocalTemperature}
			},
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.CoolingSetpoint}
			},
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.HeatingSetpoint}
			},
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.AutoSetpoint}
			},
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.SystemMode}
			},
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.AcModeSupport}
			},
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.CleanStatu}
			}
			};
			var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
			jObject.Add("Data", data);
			device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
			}

			/// <summary>
			/// SendFanStatuComand
			/// </summary>
			/// <param name="device">设备</param>
			private void SendFanStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			return null;
			}

			CommonDevice.SetWritableValueResponAllData d = null;
			Action<string, string> action = (topic, message) =>
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.FanControl },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			var gatewayID = topic.Split('/')[0];
			var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			if (temp == null)
			{
			d = new CommonDevice.SetWritableValueResponAllData { errorMessageBase = "网关错误回复，且数据是空" };
			}
			else
			{
			d = new CommonDevice.SetWritableValueResponAllData { errorResponData = temp, errorMessageBase = HdlCheckLogic.Current.CheckCommonErrorCode(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "SetWritableValue_Respon")
			{
			var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.SetWritableValueResponData>(jobject["Data"].ToString());
			if (tempData == null)
			{
			d = new CommonDevice.SetWritableValueResponAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			d = new CommonDevice.SetWritableValueResponAllData { setWritableValueResponData = tempData };
			}
			}
			};
			MyGateway.Actions += action;
			try
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.FanMode}
			},
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.FanSwing}
			}
			};
			var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
			jObject.Add("Data", data);
			device.Gateway?.Send("GetDeviceStatus", jObject.ToString());
			}

			#endregion

			#region ■ 新风_______________________________
			/// <summary>
			/// SendFreshAirStatuComand
			/// </summary>
			/// <param name="device">设备</param>
			public void SendFreshAirStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			new System.Threading.Thread(() =>
			{
			SendFreshAirFanStatuComand(device);
			System.Threading.Thread.Sleep(300);
			})
			{ IsBackground = true }.Start();
			}

			/// <summary>
			/// SendFanStatuComand
			/// </summary>
			/// <param name="device">设备</param>
			private void SendFreshAirFanStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			var jObject = new Newtonsoft.Json.Linq.JObject { { "DeviceAddr", device.DeviceAddr }, { "Epoint", device.DeviceEpoint }, { "Cluster_ID", clusterId }, { "Command", 120 } };
			var data = new Newtonsoft.Json.Linq.JObject { { "Undivided", 0 }, { "AttributeId", attributeId }, { "AttributeDataType", attributeDataType }, { "AttributeData", attributeData } };
			jObject.Add("Data", data);
			MyGateway.Send("SetWritableValue", jObject.ToString());
			}
			catch { }

			var timeOut = 0;
			while (timeOut <= 30)
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.FanControl },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			await System.Threading.Tasks.Task.Delay(100);
			if (d != null)
			{
			break;
			}
			timeOut++;
			}
			if (timeOut > 30 && d == null)
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.FanMode}
			}
			};
			var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
			jObject.Add("Data", data);
			device.Gateway?.Send("GetDeviceStatus", jObject.ToString());
			}

			#endregion

			#region ■ PM2.5_______________________________
			/// <summary>
			/// SendPmSensorComand
			/// </summary>
			/// <param name="device">设备</param>
			public void SendPmSensorComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			new System.Threading.Thread(() =>
			{
			SendPmSensorStatuComand(device);
			//读取Pm2.5传感器的温度数据
			HdlDeviceAttributeLogic.Current.SendTemperatureStatuComand(device);
			//读取Pm2.5传感器的湿度数据
			HdlDeviceAttributeLogic.Current.SendHumidityStatuComand(device);
			System.Threading.Thread.Sleep(300);
			})
			{ IsBackground = true }.Start();
			}

			/// <summary>
			/// SendFanStatuComand
			/// </summary>
			/// <param name="device">设备</param>
			private void SendPmSensorStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			d = new CommonDevice.SetWritableValueResponAllData { errorMessageBase = " 回复超时，请重新操作" };
			}
			MyGateway.Actions -= action;
			return d;
			}

			#endregion
			}
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.PmTwoPointFiveMeasurement },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.MeasuredValue}
			}
			};
			var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
			jObject.Add("Data", data);
			device.Gateway?.Send("GetDeviceStatus", jObject.ToString());
			}

			#endregion

			#region ■ 晾衣架_______________________________
			/// <summary>
			/// SendAirerComand
			///回路2:读取照明开关状态
			///回路3:读取风干开关状态和时间值
			///回路4:读取烘干开关状态和时间值
			///回路5:读取消毒开关状态和时间值
			/// </summary>
			/// <param name="device">设备</param>
			/// <param name="ctrlEpoint">控制端点</param>
			public void SendAirerComand(CommonDevice device, int ctrlEpoint)
			{
			if (device == null)
			{
			return;
			}
			new System.Threading.Thread(() =>
			{
			SendAirerStatuComand(device, ctrlEpoint);
			System.Threading.Thread.Sleep(300);
			})
			{ IsBackground = true }.Start();
			}

			/// <summary>
			/// SendAirerStatuComand
			/// </summary>
			/// <param name="device">设备</param>
			private void SendAirerStatuComand(CommonDevice device, int ctrlEpoint = 1)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", ctrlEpoint },
			{ "Cluster_ID", (int)Cluster_ID.Switch},
			{ "Command", 108 }
			};
			Newtonsoft.Json.Linq.JArray attriBute = new Newtonsoft.Json.Linq.JArray();

			//晾衣架的晾衣架的（烘干，风干，消毒,照明状态读取）
			attriBute = new Newtonsoft.Json.Linq.JArray
			{
			new Newtonsoft.Json.Linq.JObject
			{
			//晾衣架的照明开关状态
			{ "AttriButeId", (int)AttriButeId.Switch}
			}
			};

			//if (device.DeviceEpoint != 2)
			//{
			//由于设备不支持时间功能，后期才支持，注意处理时间要根据烘干，风干，消毒是否开才发送相应大时间读取数据
			//attriBute = new Newtonsoft.Json.Linq.JArray {
			// new Newtonsoft.Json.Linq.JObject
			// {
			// //晾衣架的开关状态（烘干，风干，消毒）
			// { "AttriButeId", (int)AttriButeId.Switch}
			// },
			// new Newtonsoft.Json.Linq.JObject
			// {
			// //晾衣架的晾衣架的（烘干，风干，消毒）剩余时间
			// { "AttriButeId", (int)AttriButeId.AirerRemainTime}
			// },
			// new Newtonsoft.Json.Linq.JObject
			// {
			// //晾衣架的（烘干，风干，消毒）时间
			// { "AttriButeId", (int)AttriButeId.AirerTime}
			// }
			// };
			//}
			var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
			jObject.Add("Data", data);
			device.Gateway?.Send("GetDeviceStatus", jObject.ToString());
			}

			#endregion

			#region ■ 窗帘_______________________________
			/// <summary>
			/// 发送获取窗帘状态命令
			/// </summary>
			/// <param name="device">窗帘</param>
			public void SendCurtainStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.WindowCovering },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.CurrentPositionLiftPercentage}
			}
			};
			var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
			jObject.Add("Data", data);
			device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
			}

			#endregion

			#region ■ 灯光_______________________________

			/// <summary>
			/// Light
			/// </summary>
			/// <param name="device"></param>
			public void SendLightStatuComand(CommonDevice device)
			{
			SendSwitchStatuComand(device);
			}

			/// <summary>
			/// Light
			/// </summary>
			/// <param name="device"></param>
			public void SendDimmableLightStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			new System.Threading.Thread(() =>
			{
			SendSwitchStatuComand(device);
			System.Threading.Thread.Sleep(300);
			SendLevelStatuComand(device);
			})
			{ IsBackground = true }.Start();
			}

			/// <summary>
			/// 发送获取灯光状态命令
			/// </summary>
			/// <param name="device">窗帘</param>
			private void SendSwitchStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.Switch },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.Switch}
			}
			};
			var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
			jObject.Add("Data", data);
			device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
			}

			/// <summary>
			/// 发送获取灯光状态命令
			/// </summary>
			/// <param name="device">窗帘</param>
			public void SendLevelStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.LevelControl },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.LevelControl}
			}
			};
			var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
			jObject.Add("Data", data);
			device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
			}

			#endregion

			#region ■ 色温灯_____________________________

			/// <summary>
			/// 发送获取色温灯状态命令
			/// </summary>
			/// <param name="device"></param>
			public void SendColorTemperatureLightStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var colorDevice = (ColorTemperatureLight)device;
			new System.Threading.Thread(() =>
			{
			colorDevice.ReadOnOffStatus();
			System.Threading.Thread.Sleep(300);
			colorDevice.ReadLevel();
			System.Threading.Thread.Sleep(300);
			colorDevice.ReadColorTemperature();
			if (LocalDevice.Current.IsMiniLight(device) == true)
			{
			//mini夜灯需要读取蜂鸣器状态
			System.Threading.Thread.Sleep(300);
			colorDevice.ReadBuzzerStatu();
			}
			})
			{ IsBackground = true }.Start();
			}

			#endregion

			#region ■ 温湿度_____________________________

			/// <summary>
			/// 读取温度
			/// </summary>
			/// <param name="device"></param>
			public void SendTemperatureStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.TemperatureMeasurement },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.MeasuredValue}
			}
			};
			var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
			jObject.Add("Data", data);
			device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
			}

			/// <summary>
			/// 读取湿度
			/// </summary>
			/// <param name="device"></param>
			public void SendHumidityStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.RelativeHumidityMeasurement },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			new Newtonsoft.Json.Linq.JObject
			{
			{ "AttriButeId", (int)AttriButeId.MeasuredValue}
			}
			};
			var data = new Newtonsoft.Json.Linq.JObject { { "AttriBute", attriBute } };
			jObject.Add("Data", data);
			device.Gateway?.Send(("GetDeviceStatus"), jObject.ToString());
			}

			#endregion
			}
			}