using log4net;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.NetworkInformation;
using System.Net.Security;
using System.Reflection;
using System.Text;

namespace OnlineStore.Common
{
    public class MyWebClient : WebClient
    {
        private int _timeout;

        /// <summary>
        /// 超时时间(毫秒)
        /// </summary>
        public int Timeout
        {
            get
            {
                return _timeout;
            }
            set
            {
                _timeout = value;
            }
        }

        public MyWebClient()
        {
            this._timeout = 60000;
        }

        public MyWebClient(int timeout)
        {
            this._timeout = timeout;
        }

        protected override WebRequest GetWebRequest(Uri address)
        {
            HttpWebRequest result =(HttpWebRequest) base.GetWebRequest(address);
            result.Timeout = this._timeout;
           // result.KeepAlive = false;
            result.ServicePoint.Expect100Continue = false;
            return result;
        }
    }
    public class HttpHelper
    {
        public static Operation PostOperation(string url, Operation operation, bool simulate = false)
        {
            try
            {
                if (operation == null)
                {
                    return null;
                }
                if (simulate)
                {//模拟服务器返回
                    operation.status = 200;
                    operation.data.Clear();
                    operation.data.Add("posId", "A001");
                    string pos = "D100-111#D102-222#D104-333";
                    operation.data.Add("pos", pos);
                    if (operation.op == 1 || operation.op == 2)
                    {//入库或出库

                        string json = JsonHelper.SerializeObject(operation);
                        LogUtil.error("模拟HTTP服务器返回出库入库信息：" + json);
                        return operation;
                    }
                    return null;
                }

                try
                {
                    if (url.ToLower().IndexOf("https", System.StringComparison.Ordinal) > -1)
                    {
                        ServicePointManager.ServerCertificateValidationCallback =
                                       new RemoteCertificateValidationCallback((sender, certificate, chain, errors) => { return true; });
                    }
                    string json = JsonHelper.SerializeObject(operation);
                    var wc = new MyWebClient(5000);
                    if (string.IsNullOrEmpty(wc.Headers["Content-Type"]))
                        wc.Headers.Add("Content-Type", "application/json;charset=UTF-8");
                    wc.Encoding = Encoding.UTF8;

                    string result = wc.UploadString(url, "POST", json);

                    if (!string.IsNullOrEmpty(result))
                    {
                        try
                        {
                            Operation reOP = JsonHelper.DeserializeJsonToObject<Operation>(result);
                            if (isLog == 1 || reOP.op > 0)
                            {
                                //LogUtil.info("【"+url+"】发送【" + json  + "】收到【" + result + "】");
                            }
                            return reOP;
                        }
                        catch (Exception ex)
                        {
                            LogUtil.error("JsonHelper.DeserializeJsonToObject 出错【result=" + result + "】" + ex);
                        }
                    }
                }
                catch (WebException ex)
                {
                    LogUtil.error("POST [" + url + "] WebException :" + ex.ToString(), 101);
                }
                catch (Exception e)
                {
                    LogUtil.error("POST [" + url + "] ERROR:" + e.ToString(), 101);
                }
            }

            catch (Exception ex)
            {
                LogUtil.error("Post 出错【operation.op=" + operation.op + "】：" + ex);
            }
            return null;
        }
        public static bool PingURLIP(string url, int ms = 100)
        {
            string[] urlArray = url.Split('/');
            if (urlArray.Length > 3)
            {
                string ip = urlArray[2];

                Ping pingSender = new Ping();
                PingReply reply = pingSender.Send(ip, ms);//第一个参数为ip地址，第二个参数为ping的时间 
                if (reply.Status == IPStatus.Success)
                {
                    //通
                    return true;
                }
                else
                {
                    LogUtil.error("Ping IP " + ip + " : false");
                    //不通 
                    return false;
                }
            }
            return true;
        }
        //public static readonly ILog LOGGER = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
        public static string Post(string url, string paramData, int timeOut = 5000)
        {
            bool IsTimeOut = false;
            return Post(url, paramData, Encoding.UTF8, timeOut,out IsTimeOut);
        }
        public static T Post<T>(string url, T operation, bool printlog = false)
        {
            try
            {
                string json = JsonHelper.SerializeObject(operation);
                var wc = new MyWebClient(5000);
                if (string.IsNullOrEmpty(wc.Headers["Content-Type"]))
                    wc.Headers.Add("Content-Type", "application/json;charset=UTF-8");
                wc.Encoding = Encoding.UTF8;

                string result = wc.UploadString(url, "POST", json);
                T op = JsonConvert.DeserializeObject<T>(result);

                if (printlog)
                {
                    LogUtil.info("Send [" + json + "]  Revice [" + result + "]");
                }
                return op;

            }
            catch (Exception ex)
            {
                LogUtil.error("Post 出错：" + ex);
            }
            return default;
        }

        private static int isLog = ConfigAppSettings.GetIntValue(Setting_Init.Server_Log_Open);
        public static string Post(string url, string paramData, Encoding encoding, int timeOut, out bool IsTimeOut)
        {

            if (paramData.Equals(""))
            {
                int index = url.IndexOf("?");
                if (index > 0)
                {
                    paramData = url.Substring(index + 1, url.Length - index - 1);
                    url = url.Substring(0, index);
                }
            }

            IsTimeOut = false;
            if (isLog == 1)
            {
                LogUtil.info("给服务器发送数据【"+url+"】【" + paramData + "】 ");
            }
            string result = "";

            if (url.ToLower().IndexOf("https", System.StringComparison.Ordinal) > -1)
            {
                ServicePointManager.ServerCertificateValidationCallback =
                               new RemoteCertificateValidationCallback((sender, certificate, chain, errors) => { return true; });
            }

            try
            {
                using (var wc = new MyWebClient(timeOut))
                {
                    if (string.IsNullOrEmpty(wc.Headers["Content-Type"]))
                        wc.Headers.Add("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");
                    wc.Encoding = encoding;

                    result = wc.UploadString(url, "POST", paramData);
                }      //LogUtil.info(result);
            }
            catch (WebException ex)
            {
                IsTimeOut = true;
                LogUtil.error("POST [" + url + "] WebException :" + ex.ToString(), 101);
            }
            catch (Exception e)
            {
                LogUtil.error("POST [" + url + "] ERROR:" + e.ToString(), 101);
            }
            if (!result.Contains("null") && result.Length != 0)
            {
                //LogUtil.debug(LOGGER,"receive << " + result);
            }
            if (isLog == 1)
            {
                LogUtil.info("收到服务器数据【" + result + "】");
            }
            return result;
        }
              
        public static string Get(string url)
        {
            return Get(url, Encoding.UTF8);
        }

        public static string Get(string url, Encoding encoding)
        {
            try
            {
                LogUtil.info( "HTTP GET FROM: " + url);
                using (var wc = new WebClient { Encoding = encoding })
                {
                    var readStream = wc.OpenRead(url);
                    using (var sr = new StreamReader(readStream, encoding))
                    {
                        var result = sr.ReadToEnd();
                        LogUtil.info("receive << " + result);
                        return result;
                    }
                }
            }
            catch (Exception e)
            {
                LogUtil.error("HTTP GET ERROR:" + e.Message, 102);
            }
            return "";
        }
        public static string GetPostApi(string api)
        {
            var host = ConfigAppSettings.GetValue(Setting_Init.http_server);
            if (!host.StartsWith("http://"))
            {
                host = "http://" + host;
            }
            if (!host.EndsWith("/"))
            {
                host = host + "/";
            }
            if (api.StartsWith("/"))
            {
                api = api.Substring(1);
            }
            return host + api;
        }
    }
}