using Shared.Common;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using ZigBee.Device;

namespace Shared.Phone.UserCenter
{
    /// <summary>
    /// 网关业务的逻辑类
    /// </summary>
    public class HdlGatewayLogic
    {
        #region ■ 变量声明___________________________

        /// <summary>
        /// 备份业务的逻辑
        /// </summary>
        private static HdlGatewayLogic m_Current = null;
        /// <summary>
        /// 备份业务的逻辑
        /// </summary>
        public static HdlGatewayLogic Current
        {
            get
            {
                if (m_Current == null)
                {
                    m_Current = new HdlGatewayLogic();
                }
                return m_Current;
            }
        }
        /// <summary>
        /// 备份用的网关ID
        /// </summary>
        private List<string> listBackupGwId = new List<string>();

        #endregion

        #region ■ 从云端获取全部网关列表ID___________

        /// <summary>
        /// 从云端获取全部网关列表ID
        /// </summary>
        /// <returns>从云端获取全部网关列表ID</returns>
        public Dictionary<string, GatewayResult> GetGateWayListFromDataBase()
        {
            Dictionary<string, GatewayResult> dicDbGateway = null;
            if (UserCenterResourse.UserInfo.AuthorityNo == 3)
            {
                //成员
                return dicDbGateway;
            }

            bool canBreak = false;
            new System.Threading.Thread(async () =>
            {
                List<string> list = new List<string>() { "NotSetAgain" };

                //这个接口非常特殊
                bool nowfalge = Config.Instance.isAdministrator;
                if (UserCenterResourse.UserInfo.AuthorityNo == 2)
                {
                    //必须启用管理员权限
                    Config.Instance.isAdministrator = true;
                }
                //设置访问接口的参数
                var pra = new GetGatewayPra();
                pra.ReqDto.PageSetting.Page = 1;
                pra.ReqDto.PageSetting.PageSize = 999;
                var result = await UserCenterLogic.GetResponseDataByRequestHttps("App/GetSingleHomeGatewayPagger", pra, list);
                //权限复原
                Config.Instance.isAdministrator = nowfalge;
                if (string.IsNullOrEmpty(result) == true)
                {
                    canBreak = true;
                    return;
                }
                var infoResult = Newtonsoft.Json.JsonConvert.DeserializeObject<GetGatewayResult>(result);

                Dictionary<string, GatewayResult> dic = new Dictionary<string, GatewayResult>();
                foreach (var data in infoResult.PageData)
                {
                    dic[data.GatewayUniqueId] = data;
                }
                dicDbGateway = dic;
                canBreak = true;
            })
            { IsBackground = true }.Start();

            int count = 0;
            while (canBreak == false)
            {
                System.Threading.Thread.Sleep(200);
                count++;
                if (count == 25)
                {
                    //如果5秒还不能获取得到数据，则中断此次操作
                    break;
                }
            }

            return dicDbGateway;
        }

        #endregion

        #region ■ 解绑云端网关_______________________

        /// <summary>
        /// 解绑云端绑定的网关
        /// </summary>
        /// <param name="strWayId"></param>
        public async Task<bool> DeleteDataBaseGateway(string strWayId)
        {
            var Pra = new DeleteGatewayPra();
            Pra.BindGateways.Add(strWayId);

            List<string> listNotShowError = new List<string>() { "NoExist", "NoBind", "NoRecord" };

            bool result = await UserCenterLogic.GetResultStatuByRequestHttps("App/ReleaseGatewayToHome", Pra, listNotShowError);
            if (result == false)
            {
                return false;
            }
            return true;
        }

        #endregion

        #region ■ 断网备份及绑定网关ID_______________

        /// <summary>
        /// 在没网的情况下备份网关ID
        /// </summary>
        /// <param name="zbGateway"></param>
        public void BackupGatewayIdOnNotNetwork(ZbGateway zbGateway)
        {
            var strId = Common.LocalGateway.Current.GetGatewayId(zbGateway);
            if (listBackupGwId.Contains(strId) == false)
            {
                listBackupGwId.Add(strId);

                //备份
                var strData = Newtonsoft.Json.JsonConvert.SerializeObject(listBackupGwId);
                var byteData = System.Text.Encoding.UTF8.GetBytes(strData);
                Global.WriteFileToDirectoryByBytes(DirNameResourse.LocalMemoryDirectory, DirNameResourse.BackupGatewayIdFile, byteData);
            }
        }

        /// <summary>
        /// 重新发送命令去绑定断网情况下备份的网关
        /// </summary>
        public void ResetComandToBindBackupGateway()
        {
            new System.Threading.Thread(async () =>
            {
                var fileData = Global.ReadFileByDirectory(DirNameResourse.LocalMemoryDirectory, DirNameResourse.BackupGatewayIdFile);
                if (fileData == null)
                {
                    return;
                }
                this.listBackupGwId = Newtonsoft.Json.JsonConvert.DeserializeObject<List<string>>(System.Text.Encoding.UTF8.GetString(fileData));
                var listTempId = new List<string>();
                listTempId.AddRange(this.listBackupGwId);

                //不显示已经被绑定过的信息,NotSetAgain:假如断网时,不二次发送
                List<string> listNotShow = new List<string>() { "NotSetAgain" };
                //调用接口，绑定网关
                var bindGateway = new BindGatewayPra();
                foreach (var gwId in listTempId)
                {
                    bindGateway.BindGateways.Clear();
                    bindGateway.BindGateways.Add(gwId);
                    var result = await UserCenterLogic.GetResultCodeByRequestHttps("App/BindGatewayToHome", bindGateway, listNotShow);
                    if (result == "Success")
                    {
                        this.listBackupGwId.Remove(gwId);
                    }
                    if (result == "Error" || result == "ErrorEx")
                    {
                        break;
                    }
                }

                if (this.listBackupGwId.Count == 0)
                {
                    //如果没有了内容,则删除文件
                    string file = UserCenterLogic.CombinePath(DirNameResourse.LocalMemoryDirectory, DirNameResourse.BackupGatewayIdFile);
                    if (System.IO.File.Exists(file) == true)
                    {
                        System.IO.File.Delete(file);
                    }
                }
                else
                {
                    //备份
                    var strData = Newtonsoft.Json.JsonConvert.SerializeObject(listBackupGwId);
                    var byteData = System.Text.Encoding.UTF8.GetBytes(strData);
                    Global.WriteFileToDirectoryByBytes(DirNameResourse.LocalMemoryDirectory, DirNameResourse.BackupGatewayIdFile, byteData);
                }
            })
            { IsBackground = true }.Start();
        }

        #endregion

        #region ■ 上传设备备份到网关_________________

        /// <summary>
        /// 上传设备备份到网关(最好不要去理它的返回结果)
        /// </summary>
        /// <param name="device">设备对象</param>
        /// <param name="backupEnum">备份类型</param>
        /// <param name="upLaodData">备份的数据</param>
        /// <returns></returns>
        public async Task<bool> UpLoadDeviceBackupDataToGateway(CommonDevice device, GatewayBackupEnum backupEnum, object upLaodData)
        {
            //ZbGateway realWay = null;
            //if (Common.LocalGateway.Current.GetRealGateway(ref realWay, device.CurrentGateWayId) == false)
            //{
            //    //没有找到真实物理网关
            //    return false;
            //}
            //string fileName = ((int)backupEnum).ToString().PadLeft(5, '0') + device.FilePath;
            ////创建文件对象
            //var result = await realWay.CreateFileAsync(fileName);
            //if (result == null || result.Result != 0)
            //{
            //    return false;
            //}
            ////发送数据流
            //var data = Newtonsoft.Json.JsonConvert.SerializeObject(upLaodData);
            //var byteData = System.Text.Encoding.UTF8.GetBytes(data);
            //var result2 = await realWay.SendFileAsync(byteData);
            //if (result2 == null || result2.Result != 0)
            //{
            //    return false;
            //}
            return true;
        }

        #endregion

        #region ■ 恢复网关___________________________

        /// <summary>
        /// 恢复网关配置
        /// </summary>
        /// <param name="zbGateway">网关对象</param>
        /// <param name="listGatewayFile">网关里面拥有的文件</param>
        /// <param name="backDirectory">云端下载的备份数据的文件夹名字</param>
        /// <returns></returns>
        public async Task<bool> RecoverGatewaySettion(ZbGateway zbGateway, List<string> listGatewayFile, string backDirectory)
        {
            //获取从云端那里得来的全部文件
            var listBackFile = HdlAutoBackupLogic.GetFileFromDirectory(UserCenterLogic.CombinePath(backDirectory));
            //添加附加情报:还原设备配置
            ProgressBar.SetAppendText(Language.StringByID(R.MyInternationalizationString.uRecoverDeviceSettion));
            ProgressBar.SetMaxValue(listBackFile.Count);
            ProgressBar.Show();

            var listSaveFile = new HashSet<string>();
            foreach (string fileName in listBackFile)
            {
                if (fileName.Length > 12)
                {
                    //恢复设备配置
                    var result = await this.RecoverDeviceSettion(backDirectory, fileName);
                    if (result == -1)
                    {
                        ProgressBar.Close();
                        return false;
                    }
                    if (result == 1 || result == 2)
                    {
                        listSaveFile.Add(fileName);
                    }
                }
                ProgressBar.SetValue(1);
                listGatewayFile.Remove(fileName);
            }
            //添加附加情报:覆盖网关备份中
            ProgressBar.SetAppendText(Language.StringByID(R.MyInternationalizationString.uGatewayBackupDataIsCovering));
            foreach (var file in listSaveFile)
            {
                //创建文件对象
                var result = await zbGateway.CreateFileAsync(file);
                if (result == null || result.Result != 0)
                {
                    Application.RunOnMainThread(() =>
                    {
                        //覆盖网关备份失败
                        string msg = Language.StringByID(R.MyInternationalizationString.uCoverGatewayBackupDataFail);
                        var tipView = new TipViewControl(msg);
                        tipView.ShowView();
                    });
                    ProgressBar.Close();
                    return false;
                }
                //发送数据流
                var byteData = Shared.Common.Global.ReadFileByDirectory(backDirectory, file);
                var result2 = await zbGateway.SendFileAsync(byteData);
                if (result2 == null || result2.Result != 0)
                {
                    Application.RunOnMainThread(() =>
                    {
                        //覆盖网关备份失败
                        string msg = Language.StringByID(R.MyInternationalizationString.uCoverGatewayBackupDataFail);
                        var tipView = new TipViewControl(msg);
                        tipView.ShowView();
                    });
                    ProgressBar.Close();
                    return false;
                }
            }
            //删除多余的文件
            foreach (var deleteFile in listGatewayFile)
            {
                if (deleteFile.Length > 12)
                {
                    string deviceFileName = deleteFile.Substring(5);
                    if (deviceFileName.StartsWith(Common.LocalDevice.deviceFirstName) == false)
                    {
                        //不是设备文件
                        continue;
                    }
                    string[] strArry = deviceFileName.Split(new string[] { "_" }, StringSplitOptions.RemoveEmptyEntries);
                    if (strArry.Length < 4 || listSaveFile.Contains(deleteFile) == true)
                    {
                        //我也不知道它是什么文件,或者这个文件是覆盖的
                        continue;
                    }
                    //这个或许可以不理他
                    var result = await zbGateway.DelFileOrDirAsync("/etc/hdlDat/" + deleteFile);
                }
            }
            ProgressBar.Close();

            return true;
        }

        /// <summary>
        /// 恢复设备配置
        /// </summary>
        /// <param name="backDirectory">云端下载的备份数据的文件夹名字</param>
        /// <param name="backFileName">网关的设备备份名字</param>
        /// <returns></returns>
        private async Task<int> RecoverDeviceSettion(string backDirectory, string backFileName)
        {
            string deviceFileName = backFileName.Substring(5);
            if (deviceFileName.StartsWith(Common.LocalDevice.deviceFirstName) == false)
            {
                //不是设备文件
                return 0;
            }
            string[] strArry = deviceFileName.Split(new string[] { "_" }, StringSplitOptions.RemoveEmptyEntries);
            if (strArry.Length < 4)
            {
                //我也不知道它是什么文件
                return 0;
            }
            var device = Common.LocalDevice.Current.GetDevice(strArry[2], Convert.ToInt32(strArry[3]));
            if (device == null)
            {
                //这个设备不见了
                return 2;
            }

            var byteData = Shared.Common.Global.ReadFileByDirectory(backDirectory, backFileName);
            var backType = (GatewayBackupEnum)Convert.ToInt32(backFileName.Substring(0, 5));

            bool result = true;
            if (backType == GatewayBackupEnum.AMac名称)
            {
                var recoverData = Newtonsoft.Json.JsonConvert.DeserializeObject<string>(System.Text.Encoding.UTF8.GetString(byteData));
                result = await Common.LocalDevice.Current.ReMacName(new List<CommonDevice>() { device }, recoverData);
            }
            else if (backType == GatewayBackupEnum.A端点名称)
            {
                var recoverData = Newtonsoft.Json.JsonConvert.DeserializeObject<string>(System.Text.Encoding.UTF8.GetString(byteData));
                result = await Common.LocalDevice.Current.ReName(device, recoverData);
            }
            else if (backType == GatewayBackupEnum.APir灯光配置)
            {
                var recoverData = Newtonsoft.Json.JsonConvert.DeserializeObject<IASZone.ConfigureParamates>(System.Text.Encoding.UTF8.GetString(byteData));
                result = await Common.LocalDevice.Current.SetPirSensorLightSettion((IASZone)device, recoverData);
            }
            else if (backType == GatewayBackupEnum.A按键面板亮度调节)
            {
                var recoverData = Newtonsoft.Json.JsonConvert.DeserializeObject<Newtonsoft.Json.Linq.JObject>(System.Text.Encoding.UTF8.GetString(byteData));
                int directionsLevel = Convert.ToInt32(recoverData["directionsLevel"]);
                int backlightLevel = Convert.ToInt32(recoverData["backlightLevel"]);
                result = await Common.LocalDevice.Current.SetPanelSwitchLightSettion((Panel)device, directionsLevel, backlightLevel);
            }
            else if (backType == GatewayBackupEnum.A按键面板节能模式)
            {
                var recoverData = Newtonsoft.Json.JsonConvert.DeserializeObject<Newtonsoft.Json.Linq.JObject>(System.Text.Encoding.UTF8.GetString(byteData));
                bool modeEnable = Convert.ToBoolean(recoverData["modeEnable"]);
                int modeTime = Convert.ToInt32(recoverData["modeTime"]);
                int level = Convert.ToInt32(recoverData["level"]);
                result = await Common.LocalDevice.Current.SetPanelEnergyConservationMode((Panel)device, modeEnable, modeTime, level);
            }
            else if (backType == GatewayBackupEnum.A按键面板颜色调节)
            {
                var recoverData = Newtonsoft.Json.JsonConvert.DeserializeObject<Panel.KeyColorData>(System.Text.Encoding.UTF8.GetString(byteData));
                result = await Common.LocalDevice.Current.SetPanelEpointColorInfo((Panel)device, recoverData);
            }
            return result == true ? 1 : -1;
        }

        

        #endregion
    }
}