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

namespace Shared.Phone.UserCenter.Device
{
    /// <summary>
    /// 搜索设备的界面
    /// </summary>
    public class SearchDeviceForm : UserCenterCommonForm
    {
        #region ■ 变量声明___________________________

        /// <summary>
        /// 新上报的设备
        /// </summary>
        private Dictionary<string, List<CommonDevice>> dicNewDevice = new Dictionary<string, List<CommonDevice>>();
        /// <summary>
        /// 线程是否已经开启
        /// </summary>
        private bool isThreadStart = false;
        /// <summary>
        /// 锁
        /// </summary>
        private object objLock = new object();
        /// <summary>
        /// 设备上报的主题标识
        /// </summary>
        private string deviceComingTopic = string.Empty;
        /// <summary>
        /// 等待设备的回馈的超时时间(单位：100毫秒)
        /// </summary>
        private int waitDeviceTimeOut = 30;

        #endregion

        #region ■ 初始化_____________________________

        /// <summary>
        /// 画面显示(底层会固定调用此方法，借以完成画面创建)
        /// </summary>
        public void ShowForm()
        {
            //设置标题信息
            base.SetTitleText(Language.StringByID(R.MyInternationalizationString.uAddDevice));

            this.deviceComingTopic = Common.LocalGateway.Current.GetGatewayId(GatewayResourse.NowSelectGateway) + "/" + "DeviceInComingRespon";

            //初始化中部控件
            this.InitMiddleFrame();
        }

        /// <summary>
        /// 初始化中部控件
        /// </summary>
        private void InitMiddleFrame()
        {
            //显示配置中的文本信息
            this.ShowDeviceSettingMsg();

            new System.Threading.Thread(() =>
            {
                //蓝才刚说有时候网关会收不到入网的命令,所以发三次
                for (int i = 0; i < 3; i++)
                {
                    lock (objLock)
                    {
                        if (this.Parent == null)
                        {
                            return;
                        }
                        //让网关允许入网
                        GatewayResourse.NowSelectGateway.AddNewDeviceToGateway(255);
                    }
                    System.Threading.Thread.Sleep(1000);
                }
            })
            { IsBackground = true }.Start();

            //添加监视设备新上报的事件
            GatewayResourse.NowSelectGateway.GwResDataAction += this.AdjustGatewayResultData;
        }

        /// <summary>
        /// 显示配置中的文本信息
        /// </summary>
        private void ShowDeviceSettingMsg()
        {
            //进度条一样的东西,没什么逻辑
            var line = new ProgressLine();
            bodyFrameLayout.AddChidren(line);
            line.SetValue(45);

            var frameMsg = new FrameLayout();
            frameMsg.Height = Application.GetRealHeight(200);
            frameMsg.Y = Application.GetRealHeight(500);
            frameMsg.Gravity = Gravity.CenterHorizontal;
            bodyFrameLayout.AddChidren(frameMsg);

            //正在发现设备···
            var button1 = new MsgViewControl(frameMsg.Width, Application.GetRealHeight(100));
            button1.TextID = R.MyInternationalizationString.uDeviceSearching;
            frameMsg.AddChidren(button1);

            //请稍候
            var button2 = new MsgViewControl(frameMsg.Width, Application.GetRealHeight(100));
            button2.TextID = R.MyInternationalizationString.uPleaseWait;
            button2.Y = button1.Bottom;
            frameMsg.AddChidren(button2);

            //停止配置
            var btnStop = new BottomClickButton();
            btnStop.TextID = R.MyInternationalizationString.uBreakSettion;
            bodyFrameLayout.AddChidren(btnStop);
            btnStop.MouseUpEventHandler += (sender, e) =>
            {
                this.CloseForm();
            };
        }

        #endregion

        #region ■ 新设备入网接收_____________________

        /// <summary>
        /// 处理网关主题上报
        /// </summary>
        /// <param name="topic">主题</param>
        /// <param name="resultData">上报数据</param>
        private void AdjustGatewayResultData(string topic, string resultData)
        {
            if (topic != this.deviceComingTopic)
            {
                //不是设备上报主题
                return;
            }
            lock (objLock)
            {
                var jobject = Newtonsoft.Json.Linq.JObject.Parse(resultData);
                CommonDevice.DeviceInfoData info = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.DeviceInfoData>(jobject["Data"].ToString());
                if (info.DriveCode != 0)
                {
                    //不需要虚拟设备
                    return;
                }
                //根据设备Type创建对应的设备对象
                var device = Common.LocalDevice.Current.NewDeviceObjectByDeviceId((DeviceType)jobject.Value<int>("Device_ID"));
                if (device == null)
                {
                    return;
                }
                //给新设备设置主键属性
                Common.LocalDevice.Current.SetNewDeviceMainKeys(device, jobject);
                device.CurrentGateWayId = Common.LocalGateway.Current.GetGatewayId(GatewayResourse.NowSelectGateway);
                //将DeviceInfo的属性设置到主属性中
                Common.LocalDevice.Current.SetDeviceInfoToMain(device, device);

                //添加设备的缓存(Ota的话，重置镜像类型)
                Common.LocalDevice.Current.AddDeviceToMemory(ref device, true);
                device.IsOnline = 1;

                if (this.dicNewDevice.ContainsKey(device.DeviceAddr) == false)
                {
                    this.dicNewDevice[device.DeviceAddr] = new List<CommonDevice>();
                }

                //刷新超时时间
                this.waitDeviceTimeOut = 30;

                if ((device is OTADevice) == false)
                {
                    //不需要200端点的那个设备
                    this.dicNewDevice[device.DeviceAddr].Add(device);

                    //有新设备，开启显示设备信息界面的线程(里面会等待三秒这样)
                    this.StartShowDeviceMacInfoAddFormThread();
                }
            }
        }

        #endregion

        #region ■ 显示设备信息画面___________________

        /// <summary>
        /// 开启显示设备信息界面的线程
        /// </summary>
        private void StartShowDeviceMacInfoAddFormThread()
        {
            if (this.isThreadStart == true)
            {
                //线程已经开启
                return;
            }
            this.isThreadStart = true;

            new System.Threading.Thread(() =>
            {
                while (this.waitDeviceTimeOut >= 0)
                {
                    System.Threading.Thread.Sleep(100);
                    this.waitDeviceTimeOut--;
                }
                lock (objLock)
                {
                    //停止接收
                    GatewayResourse.NowSelectGateway.GwResDataAction -= this.AdjustGatewayResultData;
                    foreach (var listDevice in this.dicNewDevice.Values)
                    {
                        if (listDevice[0].ModelIdentifier == string.Empty)
                        {
                            //没有模块ID的话,再等等呗
                            System.Threading.Thread.Sleep(1500);
                        }
                        //重新变更UI
                        foreach (var device in listDevice)
                        {
                            var ui = Common.LocalDevice.Current.GetDeviceUI(device);
                            ui.IconPath = string.Empty;
                            ui.ReSave();
                        }
                        //目前就弄一个
                        Application.RunOnMainThread(() =>
                        {
                            //显示设备信息画面
                            this.ShowDeviceMacInfoAddForm(listDevice);
                        });
                        break;
                    }
                }
            })
            { IsBackground = true }.Start();
        }

        /// <summary>
        /// 显示设备信息画面
        /// </summary>
        /// <param name="listMacDevice">新设备列表</param>
        private void ShowDeviceMacInfoAddForm(List<CommonDevice> listMacDevice)
        {
            if (this.Parent == null)
            {
                return;
            }
            //关闭自身
            this.CloseForm();
            //再关闭设备入网指导界面
            this.CloseFormByFormName("AddDeviceDirectionForm");
            //添加设备
            var form = new DeviceMacInfoAddForm();
            this.AddForm(form, listMacDevice);
        }

        #endregion

        #region ■ 画面关闭___________________________

        /// <summary>
        /// 画面关闭
        /// </summary>
        /// <param name="isCloseForm">是否关闭界面,false的时候,只会调用关闭函数里面的附加功能</param>
        public override void CloseForm(bool isCloseForm = true)
        {
            base.CloseForm(isCloseForm);

            lock (objLock)
            {
                //关闭入网模式
                GatewayResourse.NowSelectGateway.AddNewDeviceToGateway(0);
                //停止接收
                GatewayResourse.NowSelectGateway.GwResDataAction -= this.AdjustGatewayResultData;
            }

        }

        #endregion
    }
}