~wjc/HomeApp.git

			@@ -7,18 +7,18 @@
			namespace Shared.Phone.UserCenter
			{
			/// <summary>
			/// 设备属性上报的逻辑类
			/// 设备属性的逻辑类
			/// </summary>
			public class HdlDeviceAttributeLogic : ZigBee.Common.IStatus
			public class HdlDeviceAttributeLogic
			{
			#region ■ 变量声明___________________________

			/// <summary>
			/// 属性上报的逻辑
			/// 属性的逻辑
			/// </summary>
			private static HdlDeviceAttributeLogic m_Current = null;
			/// <summary>
			/// 属性上报的逻辑
			/// 属性的逻辑
			/// </summary>
			public static HdlDeviceAttributeLogic Current
			{
			@@ -36,159 +36,458 @@
			}
			}

			/// <summary>
			/// 事件集合
			/// </summary>
			private Dictionary<string, Action<CommonDevice>> dicEvent = new Dictionary<string, Action<CommonDevice>>();
			/// <summary>
			/// 命令区分
			/// </summary>
			private Dictionary<string, string> dicCommandDiv = new Dictionary<string, string>();

			#endregion

			#region ■ 添加事件___________________________
			#region ■ 写入设备属性_______________________

			/// <summary>
			/// 添加获取设备属性的事件(属性上报的对象：device.DeviceStatusReport)
			/// 获取更改设备私有属性的命令
			/// </summary>
			/// <param name="mainKeys">标识事件的主键(可以随便填,主要是针对多个界面一起使用的情况)</param>
			/// <param name="comand">命令区分,比如：DeviceStatusReport,IASInfoReport等等</param>
			/// <param name="action">当接收到网关回复之后的回调函数,属性上报的对象：device.DeviceStatusReport</param>
			public void AddAttributeEvent(string mainKeys, string comand, Action<CommonDevice> action)
			/// <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)
			{
			lock (this.dicEvent)
			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)
			{
			if (this.dicEvent.Count == 0)
			{
			ZbGateway.StatusList.Add(this);
			}
			this.dicEvent[mainKeys] = action;
			this.dicCommandDiv[mainKeys] = comand;
			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 ■ 移除监听___________________________
			#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="mainKeys">标识事件的主键(可以随便填,主要是针对多个界面一起使用的情况)</param>
			public void RemoveEvent(string mainKeys)
			/// <param name="device">设备</param>
			public void SendThermostatStatuComand(CommonDevice device)
			{
			lock (this.dicEvent)
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			if (this.dicEvent.ContainsKey(mainKeys) == true)
			{
			var action = this.dicEvent[mainKeys];
			this.dicEvent.Remove(mainKeys);
			this.dicCommandDiv.Remove(mainKeys);

			action = null;
			}
			if (this.dicEvent.Count == 0)
			{
			ZbGateway.StatusList.Remove(this);
			}
			}
			}

			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.Thermostat },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			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>
			public void RemoveAllEvent()
			/// <param name="device">设备</param>
			private void SendFanStatuComand(CommonDevice device)
			{
			lock (this.dicEvent)
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			var list = new HashSet<string>();
			foreach (var keys in this.dicEvent.Keys)
			{
			list.Add(keys);
			}
			foreach (var keys in list)
			{
			//需要慢慢一个一个的释放Action,听说
			this.RemoveEvent(keys);
			}
			}
			}

			#endregion

			#region ■ 实现接口___________________________

			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.FanControl },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			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="common"></param>
			/// <param name="typeTag"></param>
			public void DeviceInfoChange(CommonDevice common, string typeTag)
			/// <param name="device">设备</param>
			public void SendFreshAirStatuComand(CommonDevice device)
			{
			if (common == null \|\| string.IsNullOrEmpty(common.DeviceAddr) == true)
			if (device == null)
			{
			//我也不知道这有没有可能
			return;
			}

			lock (this.dicEvent)
			new System.Threading.Thread(() =>
			{
			var list = new List<Action<CommonDevice>>();
			foreach (string keys in this.dicEvent.Keys)
			{
			if (this.dicCommandDiv[keys] != typeTag)
			{
			//命令区分不一致，则不调用回调函数
			continue;
			}
			//命令区分一致时，则调用回调函数
			list.Add(this.dicEvent[keys]);
			}
			//有可能在回调函数中移除了事件，导致报错，所以先收集，再调用
			foreach (var action in list)
			{
			action(common);
			}
			list.Clear();
			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
			{
			{ "DeviceAddr",device.DeviceAddr },
			{ "Epoint", device.DeviceEpoint },
			{ "Cluster_ID", (int)Cluster_ID.FanControl },
			{ "Command", 108 }
			};
			var attriBute = new Newtonsoft.Json.Linq.JArray
			{
			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="common"></param>
			public void Changed(CommonDevice common)
			/// <param name="device">设备</param>
			private void SendPmSensorStatuComand(CommonDevice device)
			{
			if (device == null)
			{
			return;
			}
			var jObject = new Newtonsoft.Json.Linq.JObject
			{
			{ "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());
			}

			/// <summary>
			/// 不使用
			/// </summary>
			public void ChangedILogicStatus(ZigBee.Device.Logic logic)
			{
			}

			/// <summary>
			/// 不使用
			/// </summary>
			public void ChangedISceneStatus(Scene scene)
			{
			}
			#endregion

			#region ■ 一般方法___________________________

			#region ■ 窗帘_______________________________
			/// <summary>
			/// 是否存在指定的事件
			/// 发送获取窗帘状态命令
			/// </summary>
			/// <param name="mainkeys"></param>
			/// <returns></returns>
			public bool IsEsixt(string mainkeys)
			/// <param name="device">窗帘</param>
			public void SendCurtainStatuComand(CommonDevice device)
			{
			return this.dicCommandDiv.ContainsKey(mainkeys);
			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>
			private 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();
			})
			{ 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
			}
			}