using HL_FristAidPlatform_DTO;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.IO;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Runtime.Serialization.Json;
using System.Text.RegularExpressions;
using System.Web.Script.Serialization;

namespace HL_FristAidPlatform_Public
{
    /// <summary>
    /// HttpClient
    /// 访问实体类
    /// </summary>
    public class HttpClientInstance<T> : Client<T>
    {
        /// <summary>
        /// 急危重症区域管理平台地址
        /// </summary>
        public static string WebApiUrl = ConfigurationManager.AppSettings["WebApiUrl"];

        /// <summary>
        /// 首辰健康大平台地址
        /// </summary>
        public static string SCJK_WebApiUrl = ConfigurationManager.AppSettings["SCJK_WebApiUrl"];

        /// <summary>
        /// IP地址
        /// </summary>
        private static string ip = PublicHelp.GetLocalIp();

        /// <summary>
        /// 重置TokenAPI
        /// </summary>
        private static string resetJWTURL = "/api/admin/T_SYS_User/ResetJWT?jwtStr={0}&deviceIP=" + ip + "";

        /// <summary>
        /// 刷新token
        /// </summary>
        /// <param name="oldToken"></param>
        /// <returns></returns>
        public static bool ResetJWT(string oldToken)
        {
            Uri urlPath = new Uri(WebApiUrl);
            HttpClient client = new HttpClient
            {
                BaseAddress = urlPath
            };
            client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
            HttpResponseMessage message = client.GetAsync(string.Format(resetJWTURL, oldToken)).Result;
            if (message.IsSuccessStatusCode)
            {
                var itemJson = message.Content.ReadAsStringAsync().Result.Replace("\"", "");
                Information.User.Token = itemJson;
                return true;
            }
            else
            {
                return false;
            }
        }

        /// <summary>
        /// Get 访问方法
        /// 查询
        /// </summary>
        /// <param name="url">方法详细地址</param>
        /// <returns></returns>
        public override DataTable Get(string Url)
        {
            DataTable dataTable = new DataTable();
            try
            {
                Uri urlPath = new Uri(WebApiUrl);
                string token = Information.User.Token;
                HttpClient client = new HttpClient
                {
                    BaseAddress = urlPath
                };
                client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token);
                HttpResponseMessage responseMessage = client.GetAsync(Url).Result;
                if (responseMessage.IsSuccessStatusCode)
                {
                    var itemJson = responseMessage.Content.ReadAsStringAsync().Result;
                    dataTable = JsonToDataTable(itemJson, out int i);
                    return dataTable;
                }
                else
                {
                    if (responseMessage.StatusCode.ToString() == "Unauthorized")
                    {
                        if (ResetJWT(token))
                        {
                            return Get(Url);
                        }
                    }
                    else
                    {
                        PublicClass.WriteLog(DateTime.Now.ToString(PublicClass.TimeToString) + responseMessage.RequestMessage + responseMessage.Content.ReadAsStringAsync().Result);//写入一条新log
                    }
                }
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("HttpClient", "Get：\r\n" + ex);
            }
            return dataTable;
        }

        /// <summary>
        /// Get 访问方法
        /// 查询
        /// </summary>
        /// <param name="url">方法详细地址</param>
        /// <returns>返回DataSet</returns>
        public override DataSet GetDataSet(string Url)
        {
            DataSet dataSet = new DataSet();
            try
            {
                Uri urlPath = new Uri(WebApiUrl);
                string token = Information.User.Token;
                HttpClient client = new HttpClient
                {
                    BaseAddress = urlPath
                };
                client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token);
                HttpResponseMessage responseMessage = client.GetAsync(Url).Result;
                if (responseMessage.IsSuccessStatusCode)
                {
                    var itemJson = responseMessage.Content.ReadAsStringAsync().Result;
                    return dataSet = JsonToDataSet(itemJson);
                }
                else
                {
                    if (responseMessage.StatusCode.ToString() == "Unauthorized")
                    {
                        if (ResetJWT(token))
                        {
                            return GetDataSet(Url);
                        }
                    }
                    else
                    {
                        PublicClass.WriteLog(DateTime.Now.ToString(PublicClass.TimeToString) + responseMessage.RequestMessage + responseMessage.Content.ReadAsStringAsync().Result);//写入一条新log
                    }
                }
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("HttpClient", "Get：\r\n" + ex);
            }
            return dataSet;
        }

        /// <summary>
        /// Get 访问方法
        /// 查询
        /// </summary>
        /// <param name="url">方法详细地址</param>
        /// <param name="platform">API链接地址类型</param>
        /// <param name="totalNumber">分页时返回总条数</param>
        /// <returns></returns>
        public override DataTable Get(string Url, Enumerate.Platform platform, out int totalNumber)
        {
            totalNumber = 0;//先赋值为0

            DataTable dataTable = new DataTable();
            try
            {
                #region 区分请求的地址

                string ApiUrl = string.Empty;
                switch (platform)
                {
                    case Enumerate.Platform.急危重症:
                        ApiUrl = WebApiUrl;
                        break;

                    case Enumerate.Platform.首辰健康:
                        ApiUrl = SCJK_WebApiUrl;
                        break;

                    default:
                        ApiUrl = WebApiUrl;
                        break;
                }

                #endregion 区分请求的地址

                Uri urlPath = new Uri(ApiUrl);
                string token = Information.User.Token;
                HttpClient client = new HttpClient
                {
                    BaseAddress = urlPath
                };
                client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token);
                HttpResponseMessage responseMessage = client.GetAsync(Url).Result;
                if (responseMessage.IsSuccessStatusCode)
                {
                    var itemJson = responseMessage.Content.ReadAsStringAsync().Result;
                    return dataTable = JsonToDataTable(itemJson, out totalNumber);
                }
                else
                {
                    if (responseMessage.StatusCode.ToString() == "Unauthorized")
                    {
                        if (ResetJWT(token))
                        {
                            return Get(Url);
                        }
                    }
                    else
                    {
                        PublicClass.WriteLog(DateTime.Now.ToString(PublicClass.TimeToString) + responseMessage.RequestMessage + responseMessage.Content.ReadAsStringAsync().Result);//写入一条新log
                    }
                }
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("HttpClient", "Get：\r\n" + ex);
            }
            return dataTable;
        }

        /// <summary>
        /// Post
        /// </summary>
        /// <param name="url"></param>
        /// <param name="t"></param>
        /// <returns></returns>
        public override ListEntity<T> Post(string url, List<T> list)
        {
            try
            {
                //创建一个处理序列化的DataContractJsonSerializer
                DataContractJsonSerializer serializer = new DataContractJsonSerializer(typeof(List<T>));
                MemoryStream ms = new MemoryStream();
                //将资料写入MemoryStream
                serializer.WriteObject(ms, list[0]);
                //一定要在这设定Position
                ms.Position = 0;
                string UrlPath = WebApiUrl + url;
                //将MemoryStream转成HttpContent
                HttpContent content = new StreamContent(ms);
                //content.Headers.ContentType = new MediaTypeHeaderValue("application/json") { CharSet = Encoding.UTF8.WebName };
                content.Headers.ContentType = new MediaTypeHeaderValue("application/json");
                ListEntity<T> returnT = new ListEntity<T>();
                HttpClient client = new HttpClient();
                //client.DefaultRequestHeaders.Add("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:97.0) Gecko/20100101 Firefox/97.0");
                //client.DefaultRequestHeaders.Add("Connection", "Keep-Alive");
                //client.DefaultRequestHeaders.Add("Accept", "*/*");
                string token = Information.User.Token;
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token);
                //由HttxpClient发出Post Method
                HttpResponseMessage response = client.PostAsync(UrlPath, content).Result;
                if (response.IsSuccessStatusCode)
                {
                    var itemJson = response.Content.ReadAsStringAsync().Result;
                    returnT.Success = response.IsSuccessStatusCode;
                    returnT.Msg = response.RequestMessage.ToString();
                    returnT.DataString = itemJson;
                    return returnT;
                }
                else
                {
                    if (response.StatusCode.ToString() == "Unauthorized")
                    {
                        returnT.Msg = "该请求未认证";
                        if (ResetJWT(token))
                        {
                            return Post(url, list);
                        }
                    }
                    else if (response.StatusCode.ToString() == "Forbidden")
                    {
                        returnT.Msg = "没有权限操作";
                    }
                    else
                    {
                        PublicClass.WriteErrorLog("HL_FristAidPlatform_Public", "HttpClientInstance  Post：\r\n API地址：" + url + "\r\n错误消息：\r\n" + response.ToString() + "\r\n" + response.Content.ReadAsStringAsync().Result);
                    }
                }
                return returnT;
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("HttpClientInstance", "Post：\r\n" + ex);
                return null;
            }
        }

        public override bool ExternalInterfacePost(string url, Dictionary<string, string> list)
        {
            try
            {
                string UrlPath = WebApiUrl + url;
                //将MemoryStream转成HttpContent
                HttpClient client = new HttpClient();
                var postContent = new MultipartFormDataContent();
                string boundary = string.Format("--{0}", DateTime.Now.Ticks.ToString("x"));
                postContent.Headers.Add("ContentType", $"multipart/form-data,boundary={boundary}");
                foreach (var item in list.Keys)
                {
                    postContent.Add(new StringContent(list[item].ToString()), item);
                }
                //由HttxpClient发出Post Method
                HttpResponseMessage response = client.PostAsync(UrlPath, postContent).Result;
                if (response.IsSuccessStatusCode)
                {
                    var itemJson = response.Content.ReadAsStringAsync().Result;
                    return Convert.ToBoolean(itemJson.ToString());
                }
                else
                {
                    PublicClass.WriteErrorLog("HL_FristAidPlatform_Public", "HttpClientInstance  Post：\r\n API地址：" + url + "\r\n错误消息：\r\n" + response.ToString() + "\r\n" + response.Content.ReadAsStringAsync().Result);
                    return false;
                }
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("HttpClientInstance", "Post：\r\n" + ex);
                return false;
            }
        }

        /// <summary>
        /// Post请求并返回更新后的数据
        /// </summary>
        /// <param name="url"></param>
        /// <param name="t"></param>
        /// <returns></returns>
        public override ListEntity<T> PostReturnTable(string url, List<T> list)
        {
            try
            {
                //创建一个处理序列化的DataContractJsonSerializer
                DataContractJsonSerializer serializer = new DataContractJsonSerializer(typeof(T));
                MemoryStream ms = new MemoryStream();

                //将资料写入MemoryStream
                serializer.WriteObject(ms, list[0]);

                //一定要在这设定Position
                ms.Position = 0;
                string UrlPath = WebApiUrl + url;
                string token = Information.User.Token;
                //将MemoryStream转成HttpContent
                HttpContent content = new StreamContent(ms);
                content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");

                ListEntity<T> returnT = new ListEntity<T>();
                HttpClient client = new HttpClient();
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token);

                //由HttpClient发出Post Method
                HttpResponseMessage response = client.PostAsync(UrlPath, content).Result;

                if (response.IsSuccessStatusCode)
                {
                    var itemJson = response.Content.ReadAsStringAsync().Result;
                    returnT.Success = response.IsSuccessStatusCode;
                    returnT.Msg = response.RequestMessage.ToString();
                    returnT.DataString = itemJson;
                    returnT.DataTable = JsonToDataTable(itemJson, out int i);
                    return returnT;
                }
                else
                {
                    if (response.StatusCode.ToString() == "Unauthorized")
                    {
                        if (ResetJWT(token))
                        {
                            return PostReturnTable(url, list);
                        }
                    }
                    else
                    {
                        PublicClass.WriteErrorLog("HL_FristAidPlatform_Public", "HttpClientInstance  Post：\r\n API地址：" + url + "\r\n错误消息：\r\n" + response.ToString() + "\r\n" + response.Content.ReadAsStringAsync().Result);
                    }
                }
                return returnT;
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("HttpClientInstance", "PostReturnTable：\r\n" + ex);
                return null;
            }
        }

        /// <summary>
        /// 删
        /// </summary>
        /// <param name="url">地址</param>
        /// <returns></returns>
        public override bool Delete(string url)
        {
            try
            {
                Uri urlPath = new Uri(WebApiUrl);
                HttpClient client = new HttpClient();
                client.BaseAddress = urlPath;
                string token = Information.User.Token;
                client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token);
                HttpResponseMessage responseMessage = client.DeleteAsync(url).Result;
                if (responseMessage.IsSuccessStatusCode)
                {
                    return true;
                }
                else
                {
                    if (responseMessage.StatusCode.ToString() == "Unauthorized")
                    {
                        if (ResetJWT(token))
                        {
                            return Delete(url);
                        }
                    }
                    else
                    {
                        return false;
                    }
                }
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("HttpClientInstance", "Delete：\r\n" + ex);
            }
            return false;
        }

        /// <summary>
        /// Json转DataTable
        /// </summary>
        /// <param name="strJson">Json字符</param>
        /// <param name="totalNumber">分页时返回总条数</param>
        /// <returns></returns>
        private static DataTable JsonToDataTable(string strJson, out int totalNumber)
        {
            int PageCount = 0;//当前页的总条数
            totalNumber = 0;//先赋值为0

            DataTable tb = new DataTable();
            try
            {
                #region 新版本

                JObject jobject = JObject.Parse(strJson);

                //判断是否存在对应的键值
                if (jobject.Property("TotalNumber") != null)
                {
                    int.TryParse(jobject["TotalNumber"].ToString(), out totalNumber);
                }
                if (jobject.Property("totalNumber") != null)
                {
                    int.TryParse(jobject["totalNumber"].ToString(), out totalNumber);
                }

                //判断是否存在对应的键值
                if (jobject.Property("PageCount") != null)
                {
                    int.TryParse(jobject["PageCount"].ToString(), out PageCount);
                }
                if (jobject.Property("pageCount") != null)
                {
                    int.TryParse(jobject["pageCount"].ToString(), out PageCount);
                }

                if (totalNumber > 0)
                {
                    //创建表
                    string dataJson = string.Empty;
                    if (jobject.Property("Data") != null)
                    {
                        var dataObj = jobject["Data"][0];
                        dataJson = Regex.Replace(dataObj.ToString(), @"\s", " ");//空白字符替换
                    }
                    if (jobject.Property("data") != null)
                    {
                        var dataObj = jobject["data"][0];
                        dataJson = Regex.Replace(dataObj.ToString(), @"\s", " ");//空白字符替换
                    }

                    JObject dataobj = JObject.Parse(dataJson);

                    tb.TableName = "";
                    foreach (var item in dataobj)
                    {
                        DataColumn dc = new DataColumn(item.Key, Type.GetType("System.String"));
                        tb.Columns.Add(dc);
                    }

                    if (PageCount == 0)
                        PageCount = totalNumber;

                    for (int i = 0; i < PageCount; i++)
                    {
                        string dataJson1 = string.Empty;
                        if (jobject.Property("Data") != null)
                        {
                            var DataObj1 = jobject["Data"][i];
                            dataJson1 = Regex.Replace(DataObj1.ToString(), @"\s", " ");
                        }
                        if (jobject.Property("data") != null)
                        {
                            var DataObj1 = jobject["data"][i];
                            dataJson1 = Regex.Replace(DataObj1.ToString(), @"\s", " ");
                        }

                        JObject dataobj1 = JObject.Parse(dataJson1);
                        DataRow dr = tb.NewRow();
                        foreach (var item in dataobj1)
                        {
                            dr[item.Key] = item.Value;
                        }
                        tb.Rows.Add(dr);
                    }
                }

                #endregion 新版本
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("HttpClientInstance", "JsonToDataTable：\r\n" + ex);
            }
            return tb;
        }

        /// <summary>
        /// 将JSON解析成DataSet只限标准的JSON数据
        /// 例如：Json＝{t1:[{name:'数据name',type:'数据type'}]}
        /// 或 Json＝{t1:[{name:'数据name',type:'数据type'}],t2:[{id:'数据id',gx:'数据gx',val:'数据val'}]}
        /// </summary>
        /// <param name="Json">Json字符串</param>
        /// <returns>DataSet</returns>
        public static DataSet JsonToDataSet(string Json)
        {
            DataSet ds = new DataSet();
            try
            {
                JsonReader reader = new JsonTextReader(new StringReader(Json));
                while (reader.Read())
                {
                    Json = reader.Value.ToString();
                }

                if (!string.IsNullOrEmpty(Json))
                {
                    JavaScriptSerializer JSS = new JavaScriptSerializer();
                    object obj = JSS.DeserializeObject(Json);
                    Dictionary<string, object> datajson = (Dictionary<string, object>)obj;
                    foreach (var item in datajson)
                    {
                        DataTable dt = new DataTable(item.Key);
                        object[] rows = (object[])item.Value;
                        foreach (var row in rows)
                        {
                            Dictionary<string, object> val = (Dictionary<string, object>)row;
                            DataRow dr = dt.NewRow();
                            foreach (KeyValuePair<string, object> sss in val)
                            {
                                if (!dt.Columns.Contains(sss.Key))
                                {
                                    dt.Columns.Add(sss.Key.ToString());
                                    dr[sss.Key] = sss.Value;
                                }
                                else
                                    dr[sss.Key] = sss.Value;
                            }
                            dt.Rows.Add(dr);
                        }
                        ds.Tables.Add(dt);
                    }
                }
                return ds;
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("JsonToDataSet", "JsonToDataSet：\r\n" + ex);
            }
            return ds;
        }

        /// <summary>
        /// 批量 (传递json格式数据)
        /// </summary>
        /// <param name="parameterData"></param>
        /// <param name="serviceUrl"></param>
        /// <returns></returns>
        public override ListEntity<T> BatchPost(string parameterData, string serviceUrl)
        {
            try
            {
                string UrlPath = WebApiUrl + serviceUrl;
                HttpWebRequest hwr = (HttpWebRequest)WebRequest.Create(UrlPath);
                HttpContent content = new StringContent(parameterData);
                content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");

                ListEntity<T> returnT = new ListEntity<T>();
                HttpClient client = new HttpClient();
                string token = Information.User.Token;
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token);

                //由HttpClient发出Post Method
                HttpResponseMessage response = client.PostAsync(UrlPath, content).Result;
                var itemJson = response.Content.ReadAsStringAsync().Result;
                if (response.IsSuccessStatusCode)
                {
                    returnT.Success = response.IsSuccessStatusCode;
                    returnT.Msg = response.RequestMessage.ToString();
                    returnT.DataString = itemJson;
                    return returnT;
                }
                else
                {
                    if (response.StatusCode.ToString() == "Unauthorized")
                    {
                        if (ResetJWT(token))
                        {
                            return BatchPost(parameterData, serviceUrl);
                        }
                    }
                    else
                    {
                        PublicClass.WriteErrorLog("HL_FristAidPlatform_Public", "HttpClientInstance  Post：\r\n API地址：" + serviceUrl + "\r\n错误消息：\r\n" + response.ToString() + "\r\n" + itemJson);
                        return null;
                    }
                }
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("HttpClientInstance", "Post：\r\n" + ex);
            }
            return null;
        }

        public override ListEntity<T> JsonPost(string parameterData, string serviceUrl)
        {
            try
            {
                string UrlPath = WebApiUrl + serviceUrl;
                HttpWebRequest hwr = (HttpWebRequest)WebRequest.Create(UrlPath);
                HttpContent content = new StringContent(parameterData);
                content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");

                ListEntity<T> returnT = new ListEntity<T>();
                HttpClient client = new HttpClient();
                string token = Information.User.Token;
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token);

                //由HttpClient发出Post Method
                HttpResponseMessage response = client.PostAsync(UrlPath, content).Result;
                var itemJson = response.Content.ReadAsStringAsync().Result;
                if (response.IsSuccessStatusCode)
                {
                    returnT.Success = response.IsSuccessStatusCode;
                    returnT.Msg = response.RequestMessage.ToString();
                    returnT.DataString = itemJson;
                    return returnT;
                }
                else
                {
                    if (response.StatusCode.ToString() == "Unauthorized")
                    {
                        if (ResetJWT(token))
                        {
                            return BatchPost(parameterData, serviceUrl);
                        }
                    }
                    else
                    {
                        PublicClass.WriteErrorLog("HL_FristAidPlatform_Public", "HttpClientInstance  Post：\r\n API地址：" + serviceUrl + "\r\n错误消息：\r\n" + response.ToString() + "\r\n" + itemJson);
                        return null;
                    }
                }
            }
            catch (Exception ex)
            {
                PublicClass.WriteErrorLog("HttpClientInstance", "Post：\r\n" + ex);
            }
            return null;
        }
    }
}