using Shared.Common;
using System;
using System.Collections.Generic;
using System.Text;
using ZigBee.Device;

namespace Shared.Phone.UserCenter
{
    /// <summary>
    /// 设备属性上报的逻辑类
    /// </summary>
    public class HdlDeviceAttributeLogic : ZigBee.Common.IStatus
    {
        #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;
            }
        }

        /// <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 ■ 添加事件___________________________

        /// <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)
        {
            lock (this.dicEvent)
            {
                if (this.dicEvent.Count == 0)
                {
                    ZbGateway.StatusList.Add(this);
                }
                this.dicEvent[mainKeys] = action;
                this.dicCommandDiv[mainKeys] = comand;
            }
        }

        #endregion

        #region ■ 移除监听___________________________

        /// <summary>
        /// 移除事件
        /// </summary>
        /// <param name="mainKeys">标识事件的主键(可以随便填,主要是针对多个界面一起使用的情况)</param>
        public void RemoveEvent(string mainKeys)
        {
            lock (this.dicEvent)
            {
                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);
                }
            }
        }

        /// <summary>
        /// 移除全部的事件
        /// </summary>
        public void RemoveAllEvent()
        {
            lock (this.dicEvent)
            {
                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 ■ 实现接口___________________________

        /// <summary>
        /// 设备状态通知
        /// </summary>
        /// <param name="common"></param>
        /// <param name="typeTag"></param>
        public void DeviceInfoChange(CommonDevice common, string typeTag)
        {
            if (common == null || string.IsNullOrEmpty(common.DeviceAddr) == true)
            {
                //我也不知道这有没有可能
                return;
            }

            lock (this.dicEvent)
            {
                var list = new List<Action<CommonDevice>>();
                foreach (string keys in this.dicEvent.Keys)
                {
                    if (this.dicCommandDiv[keys] != typeTag)
                    {
                        //命令区分不一致，则不调用回调函数
                        continue;
                    }
                    //命令区分一致时，则调用回调函数
                    list.Add(this.dicEvent[keys]);
                }
                //有可能在回调函数中移除了事件，导致报错，所以先收集，再调用
                Application.RunOnMainThread(() =>
                {
                    foreach (var action in list)
                    {
                        try
                        {
                            action?.Invoke(common);
                        }
                        catch (Exception ex)
                        {
                            //Log出力
                            string msg = "当前激活的界面[" + UserCenterResourse.NowActionFormID + "]";
                            HdlLogLogic.Current.WriteLog(-1, msg);
                            HdlLogLogic.Current.WriteLog(ex);
                        }

                    }
                });
            }
        }

        /// <summary>
        /// 不使用
        /// </summary>
        /// <param name="common"></param>
        public void Changed(CommonDevice common)
        {
        }

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

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

        #region ■ 一般方法___________________________

        /// <summary>
        /// 是否存在指定的事件
        /// </summary>
        /// <param name="mainkeys"></param>
        /// <returns></returns>
        public bool IsEsixt(string mainkeys)
        {
            return this.dicCommandDiv.ContainsKey(mainkeys);
        }

        #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)
            {
                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 } };
                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)
            {
                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
    }
}