using Shared.Common;
using System;
using System.Collections.Generic;
using System.Text;
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>
        /// <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, object attributeData)
        {
            var MyGateway = device.Gateway;
            if (MyGateway == null)
            {
                return null;
            }

            CommonDevice.SetWritableValueResponAllData d = null;
            Action<string, string> action = (topic, message) =>
            {
                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
            {
                var jObject = new Newtonsoft.Json.Linq.JObject { { "DeviceAddr", device.DeviceAddr }, { "Epoint", device.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);
                MyGateway.Send("SetWritableValue", jObject.ToString());
            }
            catch { }

            var timeOut = 0;
            while (timeOut <= 30)
            {
                await System.Threading.Tasks.Task.Delay(100);
                if (d != null)
                {
                    break;
                }
                timeOut++;
            }
            if (timeOut > 30 && d == null)
            {
                d = new CommonDevice.SetWritableValueResponAllData { errorMessageBase = " 回复超时，请重新操作" };
            }
            MyGateway.Actions -= action;
            return d;
        }

        #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
            {
                { "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>
        /// <param name="device">设备</param>
        private void SendFanStatuComand(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}
               },
               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>
        /// 发送获取窗帘状态命令
        /// </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>
        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 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
    }
}