using Newtonsoft.Json;
using RestSharp;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;

namespace Shared.Phone
{
    /// <summary>
    /// Http访问逻辑
    /// </summary>
    public class HdlHttpLogic
    {
        //2020.08.04 为什么访问云端弄的那么复杂？我也不知道云端的意义为何
        //总之,云端就是弄得这么复杂,没办法

        #region ■ 变量声明___________________________

        /// <summary>
        /// http请求逻辑
        /// </summary>
        private static HdlHttpLogic m_Current = null;
        /// <summary>
        /// http请求逻辑
        /// </summary>
        public static HdlHttpLogic Current
        {
            get
            {
                if (m_Current == null)
                {
                    m_Current = new HdlHttpLogic();
                }
                return m_Current;
            }
        }

        /// <summary>
        /// 请求地址
        /// </summary>
        public string RequestHttpsHost = "https://test-gz.hdlcontrol.com";
        /// <summary>
        /// 默认的访问地址(上面的那个会变的)
        /// </summary>
        private const string DefultHttpsHost = "https://test-gz.hdlcontrol.com";

        #endregion

        #region ■ Http请求实行_______________________

        /// <summary>
        /// 请求服务器方法
        /// </summary>
        /// <param name="i_RequestName">访问地址</param>
        /// <param name="i_method">POST 或者 GET 等等</param>
        /// <param name="i_bodyObj">承载在body里面的类对象</param>
        /// <param name="i_dicQueryTip">存放文档上标签为【query】的变量,无此标签,则请设置为null</param>
        /// <param name="i_dicPathTip">存放文档上标签为【path】的变量,无此标签,则请设置为null</param>
        /// <param name="i_checkMode">当接口需要区分【主账号】和【管理员】时,请选择【A账号权限】</param>
        /// <param name="i_setAgain">当发送失败时,是否重发,默认不重发</param>
        /// <param name="i_timeout">超时(秒),默认3秒</param>
        /// <param name="i_isBasicService">是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)</param>
        /// <returns>得到响应的数据</returns>
        public ResponsePack RequestResponseFromZigbeeHttps(string i_RequestName, Method i_method,
            object i_bodyObj, Dictionary<string, object> i_dicQueryTip = null, Dictionary<string, object> i_dicPathTip = null,
            CheckMode i_checkMode = CheckMode.A不检测, bool i_setAgain = false, int i_timeout = 3, bool i_isBasicService = false)
        {
            //请求Url的完成路径
            var result = this.RequestByteFromZigbeeHttps(i_RequestName, i_method, i_bodyObj, i_dicQueryTip, i_dicPathTip, i_checkMode, i_setAgain, i_timeout, i_isBasicService);
            //转换数据为 ResponsePack
            return this.ConvertData(result);
        }

        /// <summary>
        /// 访问指定接口，并直接返回接口返回的比特，存在错误信息时，返回null
        /// </summary>
        /// <returns>返回：并直接返回接口返回的比特，存在错误信息时，返回null</returns>
        /// <param name="i_RequestName">访问地址</param>
        /// <param name="i_method">POST 或者 GET 等等</param>
        /// <param name="i_bodyObj">承载在body里面的类对象</param>
        /// <param name="i_dicQueryTip">存放文档上标签为【query】的变量,无此标签,则请设置为null</param>
        /// <param name="i_dicPathTip">存放文档上标签为【path】的变量,无此标签,则请设置为null</param>
        /// <param name="i_checkMode">当接口需要区分【主账号】和【管理员】时,请选择【A账号权限】</param>
        /// <param name="i_setAgain">当发送失败时,是否重发,默认不重发</param>
        /// <param name="i_timeout">超时(秒),默认3秒</param>
        /// <param name="i_isBasicService">是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)</param>
        public byte[] RequestByteFromZigbeeHttps(string i_RequestName, Method i_method,
            object i_bodyObj, Dictionary<string, object> i_dicQueryTip = null, Dictionary<string, object> i_dicPathTip = null,
            CheckMode i_checkMode = CheckMode.A不检测, bool i_setAgain = false, int i_timeout = 3, bool i_isBasicService = false)
        {
            //请求Url的完成路径
            var fullUrl = RequestHttpsHost + "/" + i_RequestName;
            //请求token
            var httpToken = this.GetHttpToken(i_checkMode);
            //获取从接口那里取到的比特数据
            var revertObj = this.DoRequestZigbeeHttps(fullUrl, httpToken, i_method, i_bodyObj, i_dicQueryTip, i_dicPathTip, i_checkMode, i_timeout, i_isBasicService);

            if (revertObj == null)
            {
                if (i_setAgain == false)
                {
                    //当前无法访问网络
                    return null;
                }
                revertObj = RequestByteFromZigbeeHttpsAgain(fullUrl, i_method, httpToken, i_bodyObj, i_dicQueryTip, i_dicPathTip, i_checkMode, i_timeout, i_isBasicService);
                if (revertObj == null)
                {
                    return null;
                }
            }
            return revertObj;
        }

        /// <summary>
        /// 私有类型:从新发送(懂的人自然懂，很难解释清楚)
        /// </summary>
        /// <param name="i_fullUrl">请求Url的完成路径</param>
        /// <param name="i_method">POST 或者 GET 等等</param>
        /// <param name="i_token">token</param>
        /// <param name="i_bodyObj">承载在body里面的类对象</param>
        /// <param name="i_dicQueryTip">云端文档上标签为【query】的变量,无此标签,则请设置为null</param>
        /// <param name="i_dicPathTip">云端文档上标签为【path】的变量,无此标签,则请设置为null</param>
        /// <param name="i_checkMode">当接口需要区分【主账号】和【管理员】时,请选择【A账号权限】</param>
        /// <param name="i_timeout">超时(秒)</param>
        /// <param name="i_isBasicService">是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)</param>
        /// <returns></returns>
        private byte[] RequestByteFromZigbeeHttpsAgain(string i_fullUrl, Method i_method, string i_token,
            object i_bodyObj, Dictionary<string, object> i_dicQueryTip, Dictionary<string, object> i_dicPathTip,
             CheckMode i_checkMode, int i_timeout, bool i_isBasicService)
        {
            byte[] responsePack = null;
            int count = 0;
            while (true)
            {
                System.Threading.Thread.Sleep(2000);

                if (HdlCheckLogic.Current.IsAccountLoginOut() == true)
                {
                    //如果已经退出了登录
                    return null;
                }
                //调用接口
                responsePack = this.DoRequestZigbeeHttps(i_fullUrl, i_token, i_method, i_bodyObj, i_dicQueryTip, i_dicPathTip, i_checkMode, i_timeout, i_isBasicService);
                if (responsePack != null)
                {
                    break;
                }
                count++;
                if (count == 1)
                {
                    //算了,目前就只重发一次好了
                    break;
                }
            }
            return responsePack;
        }

        /// <summary>
        /// 请求服务器方法,指定一个Url,和请求方法，数据，Cookie，得到响应的数据
        /// </summary>
        /// <param name="i_requestFullUrl">请求Url的完成路径</param>
        /// <param name="i_token">token(请勿传入长度为0的字符串,兼顾访问非河东的网址,这里如果为null,代表访问的是非河东的网址)</param>
        /// <param name="i_method">POST 或者 GET 等等</param>
        /// <param name="i_bodyObj">承载在body里面的类对象</param>
        /// <param name="i_dicQueryTip">存放文档上标签为【query】的变量,无此标签,则请设置为null</param>
        /// <param name="i_dicPathTip">存放文档上标签为【path】的变量,无此标签,则请设置为null</param>
        /// <param name="i_checkMode">当接口需要区分【主账号】和【管理员】时,请选择【A账号权限】</param>
        /// <param name="i_timeout">超时(秒)</param>
        /// <param name="i_isBasicService">是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)</param>
        /// <returns>得到响应的数据</returns>
        public byte[] DoRequestZigbeeHttps(string i_requestFullUrl, string i_token, Method i_method,
            object i_bodyObj, Dictionary<string, object> i_dicQueryTip, Dictionary<string, object> i_dicPathTip,
            CheckMode i_checkMode, int i_timeout, bool i_isBasicService)
        {
            //HttpWebRequest的超时时间,如果设置低于15秒,在没网的情况下，很大几率它的超时时间大于15秒
            //所以才这样整
            byte[] result = null;
            bool canBreak = false;

            new System.Threading.Thread(() =>
            {
                try
                {
                    RestClient client = new RestClient(i_requestFullUrl);
                    RestRequest request = new RestRequest(i_method);
                    request.Timeout = i_timeout * 1000;
                    request.AddHeader("content-type", "application/json");
                    //这个东西是token
                    if (i_token != null)
                    {
                        //Token前面要加上这个东西
                        request.AddHeader("authorization", Common.Config.Instance.HeaderPrefix + i_token);
                        //固定为2,代表是zigbeeApp
                        request.AddHeader("clientType", "2");
                    }

                    //加入到Body里面的数据
                    if (i_bodyObj != null)
                    {
                        if (i_bodyObj is byte[])
                        {
                            //这个东西应该是文件,不能反序列化,不然数据可能会丢失
                            request.AddParameter("application/json", i_bodyObj, ParameterType.RequestBody);
                        }
                        else if (i_isBasicService == true)
                        {
                            //访问基础服务接口(为了避免过多的装箱和拆箱,这样整一个else if出来)
                            string strBody = this.GetSignRequestJson(JsonConvert.SerializeObject(i_bodyObj));
                            request.AddParameter("application/json", strBody, ParameterType.RequestBody);
                        }
                        else
                        {
                            string strBody = JsonConvert.SerializeObject(i_bodyObj);
                            request.AddParameter("application/json", strBody, ParameterType.RequestBody);
                        }
                    }
                    else
                    {
                        if (i_isBasicService == true)
                        {
                            //访问基础服务接口(为了避免过多的装箱和拆箱,这样整一个else if出来)
                            string strBody = this.GetSignRequestJson("{}");
                            request.AddParameter("application/json", strBody, ParameterType.RequestBody);
                        }
                    }

                    //添加到参数里面的数据
                    if (i_dicQueryTip != null)
                    {
                        foreach (string dataKey in i_dicQueryTip.Keys)
                        {
                            if (i_dicQueryTip[dataKey] != null)
                            {
                                request.AddQueryParameter(dataKey.Trim(), i_dicQueryTip[dataKey].ToString());
                            }
                        }
                    }
                    //拼接到地址上的数据
                    if (i_dicPathTip != null)
                    {
                        foreach (var dataKey in i_dicPathTip.Keys)
                        {
                            if (i_dicPathTip[dataKey] != null)
                            {
                                request.AddUrlSegment(dataKey.Trim(), i_dicPathTip[dataKey].ToString());
                            }
                        }
                    }

                    IRestResponse response = client.Execute(request);
                    if (response != null && response.StatusCode == HttpStatusCode.OK)
                    {
                        result = response.RawBytes;
                    }
                    canBreak = true;
                }
                catch (WebException e)
                {
                    if (e.Status == WebExceptionStatus.ConnectFailure//由有网络切换到无网络时触发
                        || e.Status == WebExceptionStatus.Timeout//超时
                        || e.Status == WebExceptionStatus.NameResolutionFailure)//本身就是无网络时启动时触发
                    {
                    }
                    canBreak = true;
                }
                catch (Exception e)
                {
                    canBreak = true;
                }
            })
            { IsBackground = true }.Start();

            int timeCount = (i_timeout * 1000) / 20;
            while (canBreak == false && timeCount > 0)
            {
                System.Threading.Thread.Sleep(20);
                timeCount--;
            }
            //自动检测Token是否已经过期
            return this.CheckTokenIsTimeOut(i_requestFullUrl, i_method, i_bodyObj, i_dicQueryTip, i_dicPathTip, i_checkMode, i_timeout, i_isBasicService, result);
        }

        #endregion

        #region ■ 第三方接口访问_____________________

        /// <summary>
        /// 第三方接口访问
        /// </summary>
        /// <param name="requestFullUrl">请求Url的完成路径</param>
        /// <param name="contentType">text/html 或者 application/json</param>
        /// <param name="requestMethod">POST 或者 GET 等等</param>
        /// <param name="timeout">超时,默认5秒</param>
        /// <returns>得到响应的数据</returns>
        public byte[] RequestThridPartyHttps(string requestFullUrl, string contentType = "text/html", string requestMethod = "GET", int timeout = 5)
        {
            try
            {
                //初始化新的webRequst
                //1． 创建httpWebRequest对象
                var webRequest = (HttpWebRequest)WebRequest.Create(new Uri(requestFullUrl));

                //2． 初始化HttpWebRequest对象
                webRequest.Method = requestMethod;
                webRequest.Timeout = timeout * 1000;
                //取消使用代理访问
                webRequest.Proxy = null;
                webRequest.UseDefaultCredentials = false;
                webRequest.ContentType = contentType;

                //4． 读取服务器的返回信息
                var response = (HttpWebResponse)webRequest.GetResponse();
                using (var stream = response.GetResponseStream())
                {
                    if (stream == null)
                    {
                        return null;
                    }
                    var ms = new System.IO.MemoryStream();
                    var bytes = new byte[1024];
                    var len = int.MaxValue;
                    while (stream.CanRead && 0 < len)
                    {
                        len = stream.Read(bytes, 0, bytes.Length);
                        ms.Write(bytes, 0, len);
                    }
                    return ms.ToArray();
                }
            }
            catch
            {
                return null;
            }
        }

        #endregion

        #region ■ 云端访问密匙_______________________

        /// <summary>
        /// appKey(访问云端固定的东西)
        /// </summary>
        private const string APP_KEY = "HDL-HOME-APP-TEST";
        /// <summary>
        /// 我也不知道这是什么鬼东西
        /// </summary>
        private const string SECRET_KEY = "WeJ8TY88vbakCcnvH8G1tDUqzLWY8yss";
        /// <summary>
        /// 获取当前时间戳值(访问云端使用)
        /// </summary>
        /// <returns></returns>
        private string GetTimestamp()
        {
            System.DateTime startTime = TimeZone.CurrentTimeZone.ToLocalTime(new System.DateTime(1970, 1, 1)); // 当地时区
            return ((long)(DateTime.Now - startTime).TotalSeconds).ToString(); // 相差秒数
        }

        /// <summary>
        /// MD5加密
        /// </summary>
        /// <param name="signstr"></param>
        /// <returns></returns>
        private string SignMD5Encrypt(string s)
        {
            byte[] sign = System.Security.Cryptography.MD5.Create().ComputeHash(Encoding.UTF8.GetBytes(s));
            string signstr = string.Empty;
            foreach (byte item in sign)
            {
                signstr += item.ToString("X2");
            }
            return signstr.ToLower();
        }

        /// <summary>
        /// 基础服务的接口都要校验sign,计算sign签名
        /// </summary>
        /// <param name="i_BodyData">body的数据</param>
        /// <returns></returns>
        private string GetSignRequestJson(string i_BodyData)
        {
            try
            {
                //1. 将model实体转为Dictionary<string, object>
                var paramDictionary = JsonConvert.DeserializeObject<Dictionary<string, object>>(i_BodyData);
                //2. 计算sign
                if (paramDictionary != null)
                {
                    paramDictionary.Add("appKey", APP_KEY);
                    paramDictionary.Add("timestamp", GetTimestamp());
                    //2.1 字典升序
                    paramDictionary = paramDictionary.OrderBy(o => o.Key).ToDictionary(o => o.Key, p => p.Value);
                    //2.2 拼接按URL键值对
                    string str = string.Empty;
                    foreach (KeyValuePair<string, object> item in paramDictionary)
                    {
                        if (item.Value == null)
                        {
                            //不校验
                            continue;
                        }
                        string myValue = item.Value.ToString();
                        if (myValue == string.Empty)
                        {
                            //空字符也不校验
                            continue;
                        }
                        if (item.Value is bool)
                        {
                            //云端那帮沙雕说bool类型必须用小写
                            myValue = myValue.ToLower();
                        }
                        str += item.Key + "=" + myValue + "&";
                    }
                    //2.3 拼接SECRET_KEY
                    str = str.Substring(0, str.Length - 1) + SECRET_KEY;
                    //2.4 MD5转换+转小写
                    var signstr = SignMD5Encrypt(str);
                    paramDictionary.Add("sign", signstr);
                    return JsonConvert.SerializeObject(paramDictionary);
                }
                else
                {
                    return "";
                }
            }
            catch
            {
                return "";
            }
        }

        #endregion

        #region ■ 自动检测Token______________________

        /// <summary>
        /// 自动检测Token是否已经过期
        /// </summary>
        /// <param name="i_requestFullUrl">请求Url的完成路径</param>
        /// <param name="i_method">POST 或者 GET 等等</param>
        /// <param name="i_bodyObj">承载在body里面的类对象</param>
        /// <param name="i_dicQueryTip">存放文档上标签为【query】的变量,无此标签,则请设置为null</param>
        /// <param name="i_dicPathTip">存放文档上标签为【path】的变量,无此标签,则请设置为null</param>
        /// <param name="i_checkMode">当接口需要区分【主账号】和【管理员】时,请选择【A账号权限】</param>
        /// <param name="i_timeout">超时(秒)</param>
        /// <param name="i_isBasicService">是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)</param>
        /// <param name="i_result">接口返回的数据</param>
        private byte[] CheckTokenIsTimeOut(string i_requestFullUrl, Method i_method,
            object i_bodyObj, Dictionary<string, object> i_dicQueryTip, Dictionary<string, object> i_dicPathTip,
            CheckMode i_checkMode, int i_timeout, bool i_isBasicService, byte[] i_result)
        {
            if (i_result == null || i_result.Length == 0 || i_result[0] != '{' || i_result[i_result.Length - 1] != '}')
            {
                //以上都不是正规的json
                return i_result;
            }
            var result = this.ConvertData(i_result);
            if (result == null)
            {
                return i_result;
            }
            if (result.Code == HttpMessageEnum.A繁忙 || result.Code == HttpMessageEnum.A超时)
            {
                HdlMessageLogic.Current.ShowNetCodeTipMsg(ShowNetCodeMode.YES, result);
                return null;
            }

            if (result.Code == HttpMessageEnum.A40001  //这个是token过期
                || result.Code == HttpMessageEnum.A10006) //这个是token不对劲
            {
                bool seccess = false;
                if (i_checkMode == CheckMode.A账号权限)
                {
                    //重新刷新主人的token
                    seccess = HdlAccountLogic.Current.InitMasterToken();
                }
                else
                {
                    //这个是token过期
                    var reponse = HdlAccountLogic.Current.LoginByRefreshToken();
                    if (reponse == null || reponse.Code != HttpMessageEnum.A成功)
                    {
                        seccess = false;
                    }
                }
                //如果刷新token失败,则重新登陆
                if (seccess == false)
                {
                    HdlThreadLogic.Current.RunMain(() =>
                    {
                        //登陆Token已经过期,请重新登陆
                        string msg = Language.StringByID(R.MyInternationalizationString.uLoginTokenIsTimeOutPleaseLoginAgain);
                        HdlMessageLogic.Current.ShowMassage(ShowMsgType.Tip, msg);

                        HdlAccountLogic.Current.ReLoginAgain(HdlUserCenterResourse.UserInfo.Account);
                    });
                    return null;
                }

                //重新调用接口
                var httpToken = this.GetHttpToken(i_checkMode);
                return this.DoRequestZigbeeHttps(i_requestFullUrl, Common.Config.Instance.Token, i_method, i_bodyObj, i_dicQueryTip, i_dicPathTip, i_checkMode, i_timeout, i_isBasicService);
            }
            return i_result;
        }

        #endregion

        #region ■ 一般方法___________________________

        /// <summary>
        /// 获取接口访问的token
        /// </summary>
        /// <param name="i_checkMode">是否检测权限</param>
        /// <returns></returns>
        public string GetHttpToken(CheckMode i_checkMode)
        {
            if (i_checkMode == CheckMode.A不检测)
            {
                return Common.Config.Instance.Token;
            }

            if (HdlUserCenterResourse.ResidenceOption.AuthorityNo == 2)
            {
                //管理员则使用主人的token
                return Common.Config.Instance.MasterToken;
            }
            return Common.Config.Instance.Token;
        }

        /// <summary>
        /// 重置云端默认的访问地址
        /// </summary>
        public void ResetDefultHttpsHost()
        {
            this.RequestHttpsHost = DefultHttpsHost;
        }

        /// <summary>
        /// 转换数据
        /// </summary>
        /// <param name="i_result">云端访问的byte数据(不是json数据不要调用)</param>
        /// <returns></returns>
        public ResponsePack ConvertData(byte[] i_result)
        {
            if (i_result == null)
            {
                return null;
            }
            try
            {
                var resultData = Encoding.UTF8.GetString(i_result);
                var data = JsonConvert.DeserializeObject<ResponsePack>(resultData);
                return data;
            }
            catch { }

            return null;
        }

        #endregion
    }
}