using System;
using System.Collections.Generic;
using System.Threading;
using System.Net.NetworkInformation;
using System.Net;
using System.Text;

namespace Shared.SimpleControl.Phone
{
    public class AccountSelectServer : FrameLayout
    {

        List<EmqServerInfoRes> mEmqServerList;
        VerticalScrolViewLayout mVerticalScrolViewLayout;
        Thread readSpeedThead;


        public AccountSelectServer ()
        {
            BackgroundColor = SkinStyle.Current.MainColor;
        }

        public override void RemoveFromParent ()
        {

            IsReadSpeed = false;
            if (readSpeedThead != null)
                readSpeedThead.Abort ();

            MainPage.Loading.Hide ();
            base.RemoveFromParent ();
        }

        public void ShowView ()
        {
            #region 标题
            var topView = new FrameLayout () {
                Y = Application.GetRealHeight (36),
                Height = Application.GetRealHeight (90),
            };
            AddChidren (topView);

            var title = new Button () {
                TextAlignment = TextAlignment.Center,
                Text = Language.StringByID (R.MyInternationalizationString.SelectServer),
                TextSize = 19,
                TextColor = SkinStyle.Current.TextColor1
            };
            topView.AddChidren (title);

            var logo = new Button () {
                Width = Application.GetRealWidth (154),
                Height = Application.GetRealHeight (90),
                X = Application.GetRealWidth (486),
                UnSelectedImagePath = MainPage.LogoString,
                Gravity = Gravity.CenterVertical,
            };
            topView.AddChidren (logo);
            var back = new Button () {
                Height = Application.GetRealHeight (90),
                Width = Application.GetRealWidth (85),
                UnSelectedImagePath = "Item/Back.png",
                Gravity = Gravity.CenterVertical,
            };
            topView.AddChidren (back);
            back.MouseUpEventHandler += (sender, e) => {
                UserMiddle.SettingPageView.PageIndex = UserMiddle.SettingPageView.ChildrenCount - 2;
            };
            #endregion

            var BodyView = new FrameLayout () {
                Width = LayoutParams.MatchParent,
                Height = Application.GetRealHeight (Application.DesignHeight - 126 - 60),
                Y = topView.Bottom,
                BackgroundColor = SkinStyle.Current.ViewColor,
            };
            AddChidren (BodyView);

            mVerticalScrolViewLayout = new VerticalScrolViewLayout ();
            BodyView.AddChidren (mVerticalScrolViewLayout);


            var TipView = new Button () {
                Width = LayoutParams.MatchParent,
                Y = Application.GetRealHeight (Application.DesignHeight - 60),
                Height = Application.GetRealHeight (60),
                BackgroundColor = 0xFFFFFFE0,
                TextSize = 11,
                //Text = "温馨提示，使用该功能需确保当前网关固件程序支持！",
                TextID = R.MyInternationalizationString.TipsSelectServer,
                TextColor = 0xFF1F1F1F,
                IsMoreLines = true

            };
            AddChidren (TipView);

            //加载服务器列表
            GetServerList ();
        }


        void GetServerList ()
        {
            Application.RunOnMainThread (() => {
                MainPage.Loading.Start (Language.StringByID (R.MyInternationalizationString.load));
            });

            System.Threading.Tasks.Task.Run (() => {

                var requestJson = Newtonsoft.Json.JsonConvert.SerializeObject (new BaseRequestObj () { LoginAccessToken = MainPage.LoginUser.LoginTokenString });
                var revertObj = MainPage.RequestHttps ("", requestJson, false, false, API.GetAllRegionEmqServerList);
                if (revertObj.StateCode.ToUpper () == "SUCCESS") {

                    var responseDataObj = Newtonsoft.Json.JsonConvert.DeserializeObject<List<EmqServerInfoRes>> (revertObj.ResponseData.ToString ());

                    Application.RunOnMainThread (() => {
                        ShowServerListView (responseDataObj);
                    });
                } else {
                    Application.RunOnMainThread (() => {
                        new Alert (Language.StringByID (R.MyInternationalizationString.Tip), Language.StringByID (R.MyInternationalizationString.FailureToServer),
                                           Language.StringByID (R.MyInternationalizationString.Close)).Show ();
                    });
                }

                Application.RunOnMainThread (() => {
                    MainPage.Loading.Hide ();
                });


            });


        }


        void ShowServerListView (List<EmqServerInfoRes> mServerList)
        {
        
            mVerticalScrolViewLayout.RemoveAll ();
            mEmqServerList = mServerList;

            if (mServerList == null) return;

            foreach (var mServerInfo in mServerList) {

                AddServerView (mServerInfo, mVerticalScrolViewLayout);
            }
            //开启检测服务器响应速度线程
            StartCheckServerSpeed ();
        }


        void AddServerView (EmqServerInfoRes mServerInfo, VerticalScrolViewLayout VerticalScrolViewMiddle)
        {
            
            var rowView = new RowLayout () {
                Height = Application.GetRealHeight (110),
            };
            rowView.AddTag ("ID", mServerInfo.Id);
            VerticalScrolViewMiddle.AddChidren (rowView);

            Button btnRowLine = new Button () {
                Y = Application.GetRealHeight (107),
                Height = Application.GetRealHeight (3),
                BackgroundColor = SkinStyle.Current.Black50Transparent
            };
            rowView.AddChidren (btnRowLine);

            var btnPoint = new Button () {
                Width = Application.GetRealWidth (10),
                Height = Application.GetRealHeight (10),
                X = Application.GetRealWidth (50),
                Gravity = Gravity.CenterVertical,
                UnSelectedImagePath = "Item/Point.png",
                SelectedImagePath = "Item/Point.png",
                Visible = !mServerInfo.IsCurrentSelect
            };
            rowView.AddChidren (btnPoint);

            var btnName = new Button () {
                Width = Application.GetRealWidth (370),
                Text = mServerInfo.EmqDomainOrIp,
                TextAlignment = TextAlignment.CenterLeft,
                X = Application.GetRealWidth (90),
                TextColor = SkinStyle.Current.TextColor1,
                TextSize = 14,
            };
            rowView.AddChidren (btnName);

            //btnName.MouseUpEventHandler += (ss, ee) => {
            //    //点击切换
            //};

            Button mSpeedButton = new Button () {
                X = Application.GetRealWidth (470),
                Width = Application.GetRealWidth (108),
                Height = Application.GetRealHeight (40),
                Gravity = Gravity.CenterRight,
                //Text = "0ms",
                TextColor = 0xFF00FF00,
                TextSize = 12,


            };
            mSpeedButton.AddTag ("ID", mServerInfo.Id);
            rowView.AddChidren (mSpeedButton);

            EventHandler<MouseEventArgs> eHandler = (sender, e) => {
                
                if (mServerInfo.IsCurrentSelect) return;

                ShowConfirmAlter (mServerInfo.Id);
            };
            rowView.MouseUpEventHandler += eHandler;
            btnName.MouseUpEventHandler += eHandler;

            if (mServerInfo.IsCurrentSelect) {
                Button btnCheck = new Button () {
                    X = Application.GetRealWidth (20),
                    Y = Application.GetRealHeight (25),
                    Width = Application.GetRealWidth (72),
                    Height = Application.GetRealHeight (61),
                    UnSelectedImagePath = "Skin/Check.png",
                };
                rowView.AddChidren (btnCheck);
            }


          
        }


        bool IsReadSpeed = false;
        void StartCheckServerSpeed () {
            IsReadSpeed = true;
            readSpeedThead = new Thread ((obj) => {
                while (IsReadSpeed) {
                    try {
                        foreach (var mServerInfo in mEmqServerList) {
                            long mTime = PingServerAddress (mServerInfo.EmqDomainOrIp);
                            Application.RunOnMainThread (() => {
                                System.Console.WriteLine ($"ping：{mServerInfo.EmqDomainOrIp}  {mTime}");
                                UpdateCheckTime (mServerInfo.Id, mTime);
                            });
                            System.Threading.Thread.Sleep (100);
                        }


                        System.Threading.Thread.Sleep (5000);
                    } catch { }
                }
            }) { IsBackground = true};
            readSpeedThead.Start ();

        }

        /// <summary>
        /// UpdateCheckTime
        /// </summary>
        /// <param name="ID"></param>
        /// <param name="mTime"></param>
        void UpdateCheckTime (string ID, long mTime) {

            for (int j = 0; j < mVerticalScrolViewLayout.ChildrenCount; j++) {
                if (mVerticalScrolViewLayout.GetChildren (j).GetType () == typeof (RowLayout)) {
                    RowLayout frameView = (RowLayout)mVerticalScrolViewLayout.GetChildren (j);
                    if (frameView.GetTagByKey ("ID").ToString () == ID) {
                        for (int k = 0; k < frameView.ChildrenCount; k++) {
                            if (frameView.GetChildren (k).GetType () == typeof (Button)) {
                                Button btn = (Button)frameView.GetChildren (k);
                                if (btn.GetTagByKey ("ID") != null && btn.GetTagByKey ("ID").ToString () == ID) {

                                    UpdateCheckTimeWithButton (btn, mTime);
                                }
                            }
                        }
                    }
                }
            }

        }

        /// <summary>
        /// UpdateCheckTimeWithButton
        /// </summary>
        /// <param name="mButton"></param>
        /// <param name="mTime"></param>
        void UpdateCheckTimeWithButton (Button mButton, long mTime)
        {

            if (mTime > 1000) {
                if (mTime >= 2000) {
                    mButton.Text = ">2s";
                } else {
                    mButton.Text = mTime + "ms";
                }
                //mButton.Text = ">1s";
                mButton.TextColor = 0xFFFF0000;
            } else {
                mButton.Text = mTime + "ms";
                if (mTime < 200) {
                    mButton.TextColor = 0xFF00FF00;
                } else {
                    mButton.TextColor = 0xFFFFA500;
                }
            }

        }

        /// <summary>
        /// HTTP请求响应方法
        /// </summary>
        /// <param name="serverAddress"></param>
        /// <returns></returns>
        static long PingServerAddressIos (string serverAddress)
        {
            string mAddress = "http://" + serverAddress + ":18083";
            try {
                //1． 创建httpWebRequest对象
                var webRequest = (HttpWebRequest)WebRequest.Create (new Uri (mAddress));
                webRequest.Timeout = 2000; 
                var dateTime = DateTime.Now;
                using (var response = (HttpWebResponse)webRequest.GetResponse ()) {
                    return (long)(DateTime.Now - dateTime).TotalMilliseconds;
                }
            } catch (Exception ex) {
                System.Console.WriteLine ($"PingServerAddressIos catch：{ex.ToString ()}");
            }

            return 2000;
        }

        /// <summary>
        /// Ping 方法
        /// </summary>
        /// <param name="serverAddress"></param>
        /// <returns></returns>
        static long PingServerAddressAndroid (string serverAddress)
        {

            long mRoundtripTime = 2000;
            try {
                Ping pingSender = new Ping ();
                byte [] buffer = Encoding.ASCII.GetBytes (string.Empty);
                PingReply reply = pingSender.Send (serverAddress, 2000, buffer);
                if (reply.Status == IPStatus.Success) {
                    Console.WriteLine ("Address: {0}", reply.Address.ToString ());
                    mRoundtripTime = reply.RoundtripTime;
                }
            } catch (Exception ex) {
                System.Console.WriteLine ($"Ping catch：{ex.ToString ()}");
            }

            return mRoundtripTime;
        }

        /// <summary>
        /// 检测服务器响应速度
        /// </summary>
        /// <param name="serverAddress"></param>
        /// <returns></returns>
        static long PingServerAddress (string serverAddress)
        {

#if __IOS__
                return PingServerAddressIos (serverAddress);
#else
                return PingServerAddressAndroid (serverAddress);
#endif

        }

        /// <summary>
        /// 切换到该服务器
        /// </summary>
        /// <param name="mEmqServerId"></param>
        void ShowConfirmAlter (string mEmqServerId)
        {
            //是否选择该服务器为远程连接默认服务器？
            var alert = new Alert ("", Language.StringByID (R.MyInternationalizationString.IfConfirmSelectEmqRegion),
                                                    Language.StringByID (R.MyInternationalizationString.Cancel), Language.StringByID (R.MyInternationalizationString.Confrim));
            alert.Show ();
            alert.ResultEventHandler += (sender1, e1) => {
                if (e1) {
                    ConfirmSelectEmqRegion (mEmqServerId);
                }
            };
        }

        /// <summary>
        /// 选择切换该服务器
        /// </summary>
        /// <param name="mEmqServerId"></param>
        void ConfirmSelectEmqRegion (string mEmqServerId) {
            Application.RunOnMainThread (() => {
                MainPage.Loading.Start (Language.StringByID (R.MyInternationalizationString.Send));
            });

            System.Threading.Tasks.Task.Run (() => {

                var mConfirmSelectEmqRegionRequestObj = new ConfirmSelectEmqRegionRequestObj () {
                    LoginAccessToken = MainPage.LoginUser.LoginTokenString,
                    EmqServerId = mEmqServerId
                };
                var requestJson = Newtonsoft.Json.JsonConvert.SerializeObject (mConfirmSelectEmqRegionRequestObj);
                var revertObj = MainPage.RequestHttps ("", requestJson, false, false, API.ConfirmSelectEmqRegion);
                if (revertObj.StateCode.ToUpper () == "SUCCESS") {
                    MainPage.LoginUser.EmqServerId = mEmqServerId;
                    //切换成功，断开远程 重新连接一次远程
                    if (CommonPage.IsRemote) {
                        SmartHome.MqttCommon.DisConnectRemoteMqttClient ("SelectEmqRegionSuccess");
                    }
                    Application.RunOnMainThread (() => {

                        //提示选择切换服务器成功，请重启网关！
                        new Alert ("", Language.StringByID (R.MyInternationalizationString.SelectEmqRegionSuccess),
                                            Language.StringByID (R.MyInternationalizationString.Close)).Show ();
                        //关闭页面
                        UserMiddle.SettingPageView.PageIndex = UserMiddle.SettingPageView.ChildrenCount - 2;
                    });
                } else {
                    Application.RunOnMainThread (() => {
                        //提示选择切换失败
                        new Alert ("", Language.StringByID (R.MyInternationalizationString.SelectEmqRegionFail),
                                           Language.StringByID (R.MyInternationalizationString.Close)).Show ();
                    });
                }

                Application.RunOnMainThread (() => {
                    MainPage.Loading.Hide ();
                });


            });


        }

        /// <summary>
        /// 判断是否需要自动选择服务器
        /// </summary>
        /// <param name="mEmqServerId"></param>
        public static void CheckIfAutoSelectServer (string mEmqServerId) {
            if (string.IsNullOrEmpty (mEmqServerId)) {
                System.Console.WriteLine ($"ConfirmSelectEmqRegion");
                GetServerListAndAutoSelect ();
            } 


        }

        /// <summary>
        /// 获取服务器列表，并且切换选择到响应速度最快的服务器
        /// </summary>
        static void GetServerListAndAutoSelect ()
        {

            System.Threading.Tasks.Task.Run (() => {
                //1.获取服务器列表
                var requestJson = Newtonsoft.Json.JsonConvert.SerializeObject (new BaseRequestObj () { LoginAccessToken = MainPage.LoginUser.LoginTokenString });
                var revertObj = MainPage.RequestHttps ("", requestJson, false, false, API.GetAllRegionEmqServerList);
                if (revertObj.StateCode.ToUpper () == "SUCCESS") {

                    var mList = Newtonsoft.Json.JsonConvert.DeserializeObject<List<EmqServerInfoRes>> (revertObj.ResponseData.ToString ());
                    //2.服务器列表数2个以上
                    if (mList != null && mList.Count > 1) {
                        //int mCount = 0;
                        string MinDelayEmqServerId = "";
                        long mPingTime = 3000;
                        bool isAlreadySelected = false;

                        foreach (var mServerInfo in mList) {
                            if (mServerInfo.IsCurrentSelect) {
                                isAlreadySelected = true;
                                continue;
                            }

                            long mTime = PingServerAddress (mServerInfo.EmqDomainOrIp);
                            if (mTime < mPingTime) {
                                mPingTime = mTime;
                                MinDelayEmqServerId = mServerInfo.Id;
                            }
                            System.Threading.Thread.Sleep (100);
                        }

                        //3.所有服务器都没被选择过,才调用选择切换接口
                        if (!isAlreadySelected) {
                            var mConfirmSelectEmqRegionRequestObj = new ConfirmSelectEmqRegionRequestObj () {
                                LoginAccessToken = MainPage.LoginUser.LoginTokenString,
                                EmqServerId = MinDelayEmqServerId
                            };
                            var requestJson2 = Newtonsoft.Json.JsonConvert.SerializeObject (mConfirmSelectEmqRegionRequestObj);
                            var revertObj2 = MainPage.RequestHttps ("", requestJson2, false, false, API.ConfirmSelectEmqRegion);
                            if (revertObj2.StateCode.ToUpper () == "SUCCESS") {
                                MainPage.LoginUser.EmqServerId = MinDelayEmqServerId;
                                //4.切换成功，断开远程 重新连接一次远程
                                if (CommonPage.IsRemote) {
                                    SmartHome.MqttCommon.DisConnectRemoteMqttClient ("SelectEmqRegionSuccess");
                                }
                            }

                        }
                    }
                }


            });


        }

    }
}