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

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

        /// <summary>
        /// 备份业务的逻辑
        /// </summary>
        private static HdlGatewayBackupLogic m_Current = null;
        /// <summary>
        /// 备份业务的逻辑
        /// </summary>
        public static HdlGatewayBackupLogic Current
        {
            get
            {
                if (m_Current == null)
                {
                    m_Current = new HdlGatewayBackupLogic();
                }
                return m_Current;
            }
        }

        #endregion

        #region ■ 网关备份___________________________

        /// <summary>
        /// 网关执行备份
        /// </summary>
        /// <param name="realGateway">真实物理网关对象</param>
        /// <param name="backupName">需要创建的备份的名字</param>
        public async void DoBackupGateway(ZbGateway realGateway, string backupName)
        {
            //展开进度条
            ProgressFormBar.Current.Start();
            //创建备份文件
            ProgressFormBar.Current.SetMsg(Language.StringByID(R.MyInternationalizationString.uCreatBackupFile));
            await System.Threading.Tasks.Task.Delay(1000);

            //创建一个备份名字
            string backupClassId = await HdlBackupLogic.Current.CreatNewBackupNameToDB(backupName, 2, HdlGatewayLogic.Current.GetGatewayId(realGateway));
            if (backupClassId == null)
            {
                //关闭进度条
                ProgressFormBar.Current.Close();
                return;
            }

            //保存协调器的nv分区组网信息
            bool result = this.SaveNVFile(realGateway);
            if (result == false)
            {
                //如果上传失败的话，就把它删除
                await HdlBackupLogic.Current.DeleteDbBackupData(backupClassId);
                //关闭进度条
                ProgressFormBar.Current.Close();
                return;
            }

            //打开协调器串口发送功能
            result = this.OpenZbMsComSend(realGateway);
            if (result == false)
            {
                //如果上传失败的话，就把它删除
                await HdlBackupLogic.Current.DeleteDbBackupData(backupClassId);
                //关闭进度条
                ProgressFormBar.Current.Close();
                return;
            }

            //开始上传数据
            result = this.StartUpLoadData(realGateway, backupClassId);
            if (result == false)
            {
                //如果上传失败的话，就把它删除
                await HdlBackupLogic.Current.DeleteDbBackupData(backupClassId);
                //关闭进度条
                ProgressFormBar.Current.Close();
                return;
            }
            //关闭进度条
            ProgressFormBar.Current.Close();
        }

        #endregion

        #region ■ 保存协调器的nv分区组网信息_________

        /// <summary>
        /// 保存协调器的nv分区组网信息
        /// </summary>
        /// <param name="realGateway"></param>
        /// <returns></returns>
        private bool SaveNVFile(ZbGateway realGateway)
        {
            //正在保存协调器nv分区组网信息
            ProgressFormBar.Current.SetMsg(Language.StringByID(R.MyInternationalizationString.uGatewayNVFileSaving));
            ProgressFormBar.Current.SetValue(0);
            System.Threading.Thread.Sleep(1000);

            int result = -1;
            Action<string, string> action = (topic, message) =>
            {
                var gatewayID = topic.Split('/')[0];
                if (topic == gatewayID + "/" + "ZbGwOperation/SaveNVFile_Respon")
                {
                    var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
                    result = Convert.ToInt32(jobject["Data"]["Flag"].ToString());
                }
            };
            realGateway.Actions += action;

            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 500 } };
            var data = new Newtonsoft.Json.Linq.JObject { { "ImageName", "NVImage.bin" }, { "ImagePath", "/etc/hdlDat/" } };
            jObject.Add("Data", data);
            realGateway.Send("ZbGwOperation/SaveNVFile", jObject.ToString());

            int TimeOut = 0;
            while (result == -1 && TimeOut < 60)
            {
                System.Threading.Thread.Sleep(1000);
                TimeOut++;
                ProgressFormBar.Current.SetValue2(TimeOut, 60);
            }
            realGateway.Actions -= action;
            if (result != 0)
            {
                //保存协调器的nv分区组网信息失败
                string msg = Language.StringByID(R.MyInternationalizationString.uSaveGatewayNVFileFail);
                if (result == -1)
                {
                    msg = UserCenterLogic.CombineGatewayTimeOutMsg(msg, null, "回复超时");
                }
                this.ShowErrorMsg(msg);
                return false;
            }

            return true;
        }

        #endregion

        #region ■ 打开协调器串口发送功能_____________

        /// <summary>
        /// 打开协调器串口发送功能
        /// </summary>
        /// <param name="realGateway"></param>
        /// <returns></returns>
        private bool OpenZbMsComSend(ZbGateway realGateway)
        {
            //正在打开协调器串口发送功能
            ProgressFormBar.Current.SetMsg(Language.StringByID(R.MyInternationalizationString.uZbMsComSendOpening));
            ProgressFormBar.Current.SetValue(0);
            System.Threading.Thread.Sleep(1000);

            int result = -1;
            Action<string, string> action = (topic, message) =>
            {
                var gatewayID = topic.Split('/')[0];
                if (topic == gatewayID + "/" + "OpenZbMsComSend_Respon")
                {
                    var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
                    result = Convert.ToInt32(jobject["Data"]["Status"].ToString());
                }
            };
            realGateway.Actions += action;

            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 6119 } };
            realGateway.Send("OpenZbMsComSend", jObject.ToString());

            int TimeOut = 0;
            while (result == -1 && TimeOut < 30)
            {
                System.Threading.Thread.Sleep(100);
                TimeOut++;
            }
            realGateway.Actions -= action;
            if (result != 0)
            {
                //打开协调器串口发送功能失败
                string msg = Language.StringByID(R.MyInternationalizationString.uOpenZbMsComSendFail);
                if (result == -1)
                {
                    msg = UserCenterLogic.CombineGatewayTimeOutMsg(msg, null, "回复超时");
                }
                this.ShowErrorMsg(msg);
                return false;
            }

            return true;
        }

        #endregion

        #region ■ 开始网关数据备份___________________

        /// <summary>
        /// 开始上传数据
        /// </summary>
        /// <param name="realGateway"></param>
        /// <param name="backupClassId"></param>
        private bool StartUpLoadData(ZbGateway realGateway, string backupClassId)
        {
            //开始备份网关数据
            ProgressFormBar.Current.SetMsg(Language.StringByID(R.MyInternationalizationString.uStartBackupgatewayData));
            ProgressFormBar.Current.SetValue(0);
            System.Threading.Thread.Sleep(1000);

            bool threadAction = true;
            bool success = false;
            //等待时间
            int waitime = 60;
            //计时时间
            int TimeOut = 0;

            Action<string, string> action = (topic, message) =>
            {
                var gatewayID = topic.Split('/')[0];
                if (topic == gatewayID + "/BackupGwDataFile_Respon")
                {
                    var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
                    var statu = Convert.ToInt32(jobject["Data"]["Status"].ToString());
                    if (statu == 1)
                    {
                        threadAction = false;
                        //网关数据备份失败
                        this.ShowErrorMsg(Language.StringByID(R.MyInternationalizationString.uBackupgatewayDataFail));
                        return;
                    }
                    if (statu == 2)
                    {
                        threadAction = false;
                        success = true;
                        //上传数据成功
                        string msg2 = Language.StringByID(R.MyInternationalizationString.uUploadDataSuccess);
                        this.ShowTipMsg(msg2);
                    }
                    //将时间刷新,然后等待时间变更为30秒
                    TimeOut = 0;
                    waitime = 300;
                }
                else if (topic == gatewayID + "/BackupGwDataFileProgress_Respon")
                {
                    //刷新等待时间
                    TimeOut = 0;
                    //上传进度百分比
                    var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
                    var statu = Convert.ToInt32(jobject["Data"]["Status"].ToString());
                    if (statu != 0)
                    {
                        threadAction = false;
                        //网关数据备份失败
                        this.ShowErrorMsg(Language.StringByID(R.MyInternationalizationString.uBackupgatewayDataFail));
                        return;
                    }
                    //设置进度百分比
                    var persent = Convert.ToInt32(jobject["Data"]["BackupPercent"].ToString());
                    ProgressFormBar.Current.SetValue2(persent, 100);
                }
            };
            realGateway.Actions += action;

            //获取接口的连接模式
            string fullUrl = string.Empty;
            var connectMode = UserCenterLogic.GetHttpConnectMode(true);
            if (connectMode == HttpConnectMode.Normal)
            {
                //普通访问
                fullUrl = $"{Common.CommonPage.RequestHttpsHost}/{"App/UploadHomeAppGatewaySubFiles"}";
            }
            else if (connectMode == HttpConnectMode.Admin)
            {
                //以管理员的身份访问，自身是成员
                fullUrl = $"{Common.Config.Instance.AdminRequestBaseUrl}/{"App/UploadHomeAppGatewaySubFiles"}";
            }

            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 6200 } };
            var data = new Newtonsoft.Json.Linq.JObject {
                { "url", fullUrl }, { "RequestVersion", Common.CommonPage.RequestVersion },
                { "LoginAccessToken", UserCenterLogic.GetConnectMainToken() }, { "BackupClassId", backupClassId },
                { "ManualBackupType", 2 },{ "IsOtherAccountCtrl",connectMode == HttpConnectMode.Admin?1:0}
            };
            jObject.Add("Data", data);
            realGateway.Send("BackupGwDataFile", jObject.ToString());

            while (threadAction == true && TimeOut < waitime)
            {
                System.Threading.Thread.Sleep(100);
                TimeOut++;
            }
            realGateway.Actions -= action;
            if (TimeOut >= waitime)
            {
                //响应超时,网关数据备份失败
                string msg = Language.StringByID(R.MyInternationalizationString.uResponseTimeoutsAndBackupgatewayDataFail);
                this.ShowErrorMsg(msg);
                return false;
            }
            return success;
        }

        #endregion

        #region ■ 一般方法___________________________

        /// <summary>
        /// 显示错误信息窗口
        /// </summary>
        /// <param name="msg"></param>
        private void ShowErrorMsg(string msg)
        {
            Application.RunOnMainThread(() =>
            {
                var contr = new ShowMsgControl(ShowMsgType.Error, msg);
                contr.Show();
            });
        }

        /// <summary>
        /// 显示Tip信息窗口
        /// </summary>
        /// <param name="msg"></param>
        private void ShowTipMsg(string msg)
        {
            Application.RunOnMainThread(() =>
            {
                var contr = new ShowMsgControl(ShowMsgType.Tip, msg);
                contr.Show();
            });
        }

        #endregion
    }
}