using Microsoft.AspNetCore.Hosting;
using Newtonsoft.Json;
using Steeltoe.Common.Discovery;
using System;
using System.Collections.Generic;
using System.IO;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text;
using System.Threading.Tasks;

namespace CommonUtil.Web
{
    /// <summary>
    /// 
    /// </summary>
    public class ServiceUtil
    {
        private readonly HttpClient client = new HttpClient();
        private readonly IHostingEnvironment hostingEnv;
        private IDiscoveryClient discClient;

        /// <summary>
        /// 
        /// </summary>
        /// <param name="discoveryClient"></param>
        /// <param name="hostingEnvironment"></param>
        public ServiceUtil(IDiscoveryClient discoveryClient, IHostingEnvironment hostingEnvironment)
        {
            DiscoveryHttpClientHandler _handler = new DiscoveryHttpClientHandler(discoveryClient);
            client = new HttpClient(_handler, false);
            hostingEnv = hostingEnvironment;
            discClient = discoveryClient;
        }

        /// <summary>
        /// Post请求
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="service"></param>
        /// <param name="url"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public async Task<T> PostAsync<T>(ServiceType service, string url, object data) where T : class, new()
        {
            try
            {
                string issandbox = ConfigUtil.Configuration["issandbox"] == null ? "" : ConfigUtil.Configuration["issandbox"];
                //请求地址
                if (hostingEnv.IsDevelopment() || (issandbox == "1"))
                {
                    url = ConfigUtil.Configuration[service.ToString()] + (url.StartsWith("/") ? "" : "/") + url;
                }
                else
                {
                    IList<IServiceInstance> disservice = discClient.GetInstances(service.ToString());
                    if (disservice.Count > 0)
                    {
                        int index = new Random().Next(0, disservice.Count);
                        url = "http://" + disservice[index].Host + ":" + disservice[index].Port + (url.StartsWith("/") ? "" : "/") + url;
                    }
                    else
                    {
                        url = "http://" + service.ToString() + (url.StartsWith("/") ? "" : "/") + url;
                    }
                    //url = "http://" + service.ToString() + (url.StartsWith("/") ? "" : "/") + url;
                }
                string content = "";
                if (data is string)
                {
                    content = data.ToString();
                }
                else
                {
                    content = JsonConvert.SerializeObject(data);
                }

                ByteArrayContent byteContent = null;
                if (service.ToString().StartsWith("wx."))
                {
                    Dictionary<string, object> dicJsonData = JsonConvert.DeserializeObject<Dictionary<string, object>>(content);
                    string postcontent = "";
                    foreach (string k in dicJsonData.Keys)
                    {
                        if (postcontent == "")
                        {
                            postcontent = k + "=" + (dicJsonData[k] == null ? "" : dicJsonData[k].ToString());
                        }
                        else
                        {
                            postcontent += "&" + k + "=" + (dicJsonData[k] == null ? "" : dicJsonData[k].ToString());
                        }
                    }
                    var buffer = Encoding.UTF8.GetBytes(postcontent);
                    byteContent = new ByteArrayContent(buffer);
                    byteContent.Headers.ContentType = new MediaTypeHeaderValue("application/x-www-form-urlencoded");
                }
                else
                {
                    var buffer = Encoding.UTF8.GetBytes(content);
                    byteContent = new ByteArrayContent(buffer);
                    byteContent.Headers.ContentType = new MediaTypeHeaderValue("application/json");
                }
                var response = await client.PostAsync(url, byteContent).ConfigureAwait(false);
                string result = await response.Content.ReadAsStringAsync();
                if (response.StatusCode != HttpStatusCode.OK)
                {
                    return new T();
                }
                return JsonConvert.DeserializeObject<T>(result);
            }
            catch (WebException ex)
            {
                throw new Exception("请求url：" + url + ",错误信息：" + ex.Message);
            }
        }


        /// <summary>
        /// Post请求
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="url"></param>
        /// <param name="data"></param>
        /// <returns></returns>
        public async Task<T> PostAsync<T>(string url, object data) where T : class, new()
        {
            try
            {
                string content = JsonConvert.SerializeObject(data);
                var buffer = Encoding.UTF8.GetBytes(content);
                var byteContent = new ByteArrayContent(buffer);
                byteContent.Headers.ContentType = new MediaTypeHeaderValue("application/x-www-form-urlencoded");
                var response = await client.PostAsync(url, byteContent).ConfigureAwait(false);
                string result = await response.Content.ReadAsStringAsync();
                if (response.StatusCode != HttpStatusCode.OK)
                {
                    return new T();
                }
                return JsonConvert.DeserializeObject<T>(result);
            }
            catch (WebException ex)
            {
                if (ex.Response != null)
                {
                    string responseContent = new StreamReader(ex.Response.GetResponseStream()).ReadToEnd();
                    throw new System.Exception($"response :{responseContent}", ex);
                }
                throw;
            }
        }


        /// <summary>
        /// 公共微服务类型
        /// </summary>
        public enum ServiceType
        {
            /// <summary>
            /// 文件服务
            /// </summary>
            crmfile,
            /// <summary>
            /// MQ服务
            /// </summary>
            crmrabbitmq,
            /// <summary>
            /// 缓存服务
            /// </summary>
            crm_memcache
        }
    }
}