using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.IO;
using System.Net;
using System.Net.Security;
using System.Text;
using XImaging.Automation.Library.HxDriverLib;

namespace XImaging.Automation.Service
{
    public class PostServerConfig : ConfigurationElement
    {
        [ConfigurationProperty("name", IsRequired = true)]
        public string Name
        {
            get { return (string)this["name"]; }
        }

        [ConfigurationProperty("method", IsRequired = true)]
        public string Method
        {
            get { return (string)this["method"]; }
        }

        [ConfigurationProperty("uri", IsRequired = true)]
        public string URI
        {
            get { return (string)this["uri"]; }
        }
    }

    public class PostServerSection : ConfigurationSection
    {
        [ConfigurationProperty("server", IsRequired = true)]
        public PostServerConfig Server
        {
            get { return this["server"] as PostServerConfig; }
        }
    }

    public class MessageConfig : ConfigurationElement
    {
        [ConfigurationProperty("enabled", IsRequired = true)]
        public bool Enabled
        {
            get { return (bool)this["enabled"]; }
        }

        [ConfigurationProperty("timeout", IsRequired = true)]
        public int Timeout
        {
            get { return (int)this["timeout"]; }
        }
    }

    public class MessageSection : ConfigurationSection
    {
        [ConfigurationProperty("heartbeat", IsRequired = true)]
        public MessageConfig Heartbeat
        {
            get { return this["heartbeat"] as MessageConfig; }
        }
    }

    public class HttpRequestClient
    {
        /// <summary>
        /// 获取或设置数据字符编码, 默认使用<see cref="System.Text.Encoding.UTF8"/>
        /// </summary>
        public Encoding Encoding { get; set; } = Encoding.UTF8;

        /// <summary>
        /// 获取或设置 UserAgent
        /// </summary>
        public string UserAgent { get; set; } = "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/68.0.3440.106 Safari/537.36";

        /// <summary>
        /// 获取或设置 Accept
        /// </summary>
        public string Accept { get; set; } = "*/*";

        /// <summary>
        /// 获取或设置 Referer
        /// </summary>
        public string Referer { get; set; }

        /// <summary>
        /// 获取或设置 Cookie 容器
        /// </summary>
        public CookieContainer CookieContainer { get; set; } = new CookieContainer();

        public virtual string Post(string url)
        {
            return null;
        }
        /// <summary>
        /// 初始化一个用于以 POST 方式向目标地址提交不包含文件表单数据<see cref="HttpPostRequestClient"/>实例
        /// </summary>
        public HttpRequestClient()
        {
        }
    }

    internal sealed class BiosenHttpRequestClient : HttpRequestClient
    {
        public static string Uri { set; get; }

        private JObject _postDatas;
        private static string SO_DELIMITER = "#!HxSEP!#";
        private string m_strName;
        private string m_strPayload;

        public static void Init()
        {
            PostServerSection section = ConfigurationManager.GetSection("dataServer") as PostServerSection;
            BiosenHttpRequestClient.Uri = section.Server.URI;
        }

        public BiosenHttpRequestClient() : base()
        {
            this._postDatas = JObject.FromObject(new { });
        }

        /// <summary>
        /// 以POST方式向目标地址提交表单数据
        /// </summary>
        /// <param name="url">目标地址, http(s)://sample.com</param>
        /// <returns>目标地址的响应</returns>
        public override string Post(string url)
        {
            if (string.IsNullOrWhiteSpace(url))
                throw new ArgumentNullException(nameof(url));

            HttpWebRequest request = null;
            if (url.ToLowerInvariant().StartsWith("https"))
            {
                request = WebRequest.Create(url) as HttpWebRequest;
                ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback((s, c, ch, ss) => { return true; });
                request.ProtocolVersion = HttpVersion.Version11;
                ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls;
                request.KeepAlive = true;
                ServicePointManager.CheckCertificateRevocationList = true; ServicePointManager.DefaultConnectionLimit = 100;
                ServicePointManager.Expect100Continue = false;
            }
            else
            {
                request = WebRequest.Create(url) as HttpWebRequest;
            }
            
            request.Timeout = 3000;
            request.Method = "POST";
            request.ContentType = "application/json";
            request.UserAgent = this.UserAgent;
            request.Accept = this.Accept;
            request.Referer = this.Referer;
            request.CookieContainer = this.CookieContainer;

            string postData = this._postDatas.ToString();
            try
            {
                using (var streamWriter = new StreamWriter(request.GetRequestStream()))
                {
                    streamWriter.Write(postData);
                }
            }
            catch(Exception ex)
            {
                LogConstant.logger.Print(string.Format("[Post][Exception]{0}", ex.ToString()));
            }

            LogConstant.logger.Print(string.Format("[Post][Data]准备向[{0}]发送消息: {1}", url, postData));
            string resContent = "";
            try
            {
                HttpWebResponse response = request.GetResponse() as HttpWebResponse;
                using (Stream resStream = response.GetResponseStream())
                {
                    using (StreamReader streamReader = new StreamReader(resStream, Encoding.UTF8))
                    {
                        resContent = streamReader.ReadToEnd().ToString();
                    }
                }

                LogConstant.logger.Print(string.Format("[Post][Data]消息发送成功，从[{0}]收到返回消息: {1}", url, resContent));
                return resContent;
            }
            catch (Exception ex)
            {
                LogConstant.logger.Print("[Post][Data]消息发送失败，未收到返回消息:" + ex.Message);
                throw ex;
            }
        }

        public static void Send(string data)
        {
            BiosenHttpRequestClient client = new BiosenHttpRequestClient();
            client.Payload = data;
            string t_response = client.Post(BiosenHttpRequestClient.Uri + "?name=" + client.m_strName);
            return;
        }

        public string Payload
        {
            set
            {
                this.m_strPayload = value;
                this.m_strName = XImaging.Automation.Library.HxDriverLib.Encrypt.md5(this.m_strPayload + SO_DELIMITER);
                this._postDatas = JObject.Parse(this.m_strPayload);
            }
            get
            {
                return m_strPayload;
            }
        }
    }

    internal sealed class BiosenErrorRequestClient : HttpRequestClient
    {
        public static string Uri { set; get; }

        private JObject _postDatas;
        private static string SO_DELIMITER = "#!HxSEP!#";
        private string m_strName;
        private string m_strPayload;

        public static void Init()
        {
            PostServerSection section = ConfigurationManager.GetSection("errorServer") as PostServerSection;
            BiosenErrorRequestClient.Uri = section.Server.URI;
        }

        public BiosenErrorRequestClient() : base()
        {
            this._postDatas = JObject.FromObject(new { });
        }

        /// <summary>
        /// 以POST方式向目标地址提交表单数据
        /// </summary>
        /// <param name="url">目标地址, http(s)://sample.com</param>
        /// <returns>目标地址的响应</returns>
        public override string Post(string url)
        {
            if (string.IsNullOrWhiteSpace(url))
                throw new ArgumentNullException(nameof(url));

            HttpWebRequest request = null;
            if (url.ToLowerInvariant().StartsWith("https"))
            {
                request = WebRequest.Create(url) as HttpWebRequest;
                ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback((s, c, ch, ss) => { return true; });
                request.ProtocolVersion = HttpVersion.Version11;
                ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls;
                request.KeepAlive = true;
                ServicePointManager.CheckCertificateRevocationList = true; ServicePointManager.DefaultConnectionLimit = 100;
                ServicePointManager.Expect100Continue = false;
            }
            else
            {
                request = WebRequest.Create(url) as HttpWebRequest;
            }

            request.Timeout = 3000;
            request.Method = "POST";
            request.ContentType = "application/json";
            request.UserAgent = this.UserAgent;
            request.Accept = this.Accept;
            request.Referer = this.Referer;
            request.CookieContainer = this.CookieContainer;

            string postData = this._postDatas.ToString();
            try
            {
                using (var streamWriter = new StreamWriter(request.GetRequestStream()))
                {
                    streamWriter.Write(postData);
                }
            }
            catch (Exception ex)
            {
                LogConstant.logger.Print("[Post][Exception]" + ex.ToString());
            }

            LogConstant.logger.Print(string.Format("[Post][Error]准备向[{0}]发送错误消息: {1}", url, postData));
            string resContent = "";
            try
            {
                HttpWebResponse response = request.GetResponse() as HttpWebResponse;
                using (Stream resStream = response.GetResponseStream())
                {
                    using (StreamReader streamReader = new StreamReader(resStream, Encoding.UTF8))
                    {
                        resContent = streamReader.ReadToEnd().ToString();
                    }
                }

                LogConstant.logger.Print(string.Format("[Post][Error]错误消息发送成功，从[{0}]收到返回消息: {1}", url, resContent));
                return resContent;
            }
            catch(Exception ex)
            {
                LogConstant.logger.Print("[Post][Error]错误消息发送失败，未收到返回消息:" + ex.Message);
                throw ex;
            }
        }

        public static void Send(string data)
        {
            BiosenErrorRequestClient client = new BiosenErrorRequestClient();
            client.Payload = data;
            string t_response = client.Post(BiosenErrorRequestClient.Uri + "?name=" + client.m_strName);
            return;
        }

        public string Payload
        {
            set
            {
                this.m_strPayload = value;
                this.m_strName = XImaging.Automation.Library.HxDriverLib.Encrypt.md5(this.m_strPayload + SO_DELIMITER);
                this._postDatas = JObject.Parse(this.m_strPayload);
            }
            get
            {
                return m_strPayload;
            }
        }
    }

    public class UploadParameterType
    {
        public UploadParameterType()
        {
            Encoding = Encoding.UTF8;
            PostParameters = new Dictionary<string, string>();
        }
        /// <summary>
        /// 上传地址
        /// </summary>
        public string Url { get; set; }
        /// <summary>
        /// 文件名称key
        /// </summary>
        public string FileName { get; set; }
        /// <summary>
        /// 编码格式
        /// </summary>
        public Encoding Encoding { get; set; }
        /// <summary>
        /// 上传文件的流
        /// </summary>
        public Stream UploadStream { get; set; }
        /// <summary>
        /// 上传文件 携带的参数集合
        /// </summary>
        public IDictionary<string, string> PostParameters { get; set; }
    }

    public  class BiosenFileRequestClient : HttpRequestClient
    {
        public static string Uri { set; get; }
        
        private UploadParameterType parameters;
        public static void Init()
        {
            PostServerSection section = ConfigurationManager.GetSection("fileServer") as PostServerSection;
            BiosenFileRequestClient.Uri = section.Server.URI;
        }

        public override string Post(string url)
        {
            if (string.IsNullOrWhiteSpace(url))
                throw new ArgumentNullException(nameof(url));

            string boundary = DateTime.Now.Ticks.ToString("x");          // 边界符
            byte[] beginBoundaryBytes = Encoding.UTF8.GetBytes("--" + boundary + "\r\n");
            byte[] endBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "--\r\n");
            byte[] newLineBytes = Encoding.UTF8.GetBytes("\r\n");

            MemoryStream memoryStream = new MemoryStream();
            if (this.parameters.PostParameters != null && parameters.PostParameters.Count > 0)
            {
                foreach (KeyValuePair<string, string> keyValuePair in parameters.PostParameters)
                {
                    string parameterHeaderTemplate = string.Format("Content-Disposition: form-data; name=\"{0}\"\r\n\r\n{1}\r\n", keyValuePair.Key, keyValuePair.Value);
                    byte[] parameterHeaderBytes = parameters.Encoding.GetBytes(parameterHeaderTemplate);

                    memoryStream.Write(beginBoundaryBytes, 0, beginBoundaryBytes.Length);
                    memoryStream.Write(parameterHeaderBytes, 0, parameterHeaderBytes.Length);
                }
            }

            const string filePartHeaderTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\n" +
            "Content-Type: application/octet-stream\r\n\r\n";
            int i = 0;

            if (this.parameters.FileName != null)
            {
                FileInfo fileInfo = new FileInfo(this.parameters.FileName);
                string fileName = fileInfo.Name;

                string fileHeaderItem = string.Format(filePartHeaderTemplate, "files", fileName);
                byte[] fileHeaderItemBytes = Encoding.UTF8.GetBytes(fileHeaderItem);

                if (i > 0)
                {
                    memoryStream.Write(newLineBytes, 0, newLineBytes.Length);
                }
                memoryStream.Write(beginBoundaryBytes, 0, beginBoundaryBytes.Length);
                memoryStream.Write(fileHeaderItemBytes, 0, fileHeaderItemBytes.Length);

                int bytesRead;
                byte[] buffer = new byte[1024];

                FileStream fileStream = new FileStream(this.parameters.FileName, FileMode.Open, FileAccess.Read);
                while ((bytesRead = fileStream.Read(buffer, 0, buffer.Length)) != 0)
                {
                    memoryStream.Write(buffer, 0, bytesRead);        // 2.3 将文件流写入FormData项中
                }

                i++;
            }

            memoryStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);

            HttpWebRequest request = null;
            if (url.ToLowerInvariant().StartsWith("https"))
            {
                request = WebRequest.Create(url) as HttpWebRequest;
                ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback((s, c, ch, ss) => { return true; });
                request.ProtocolVersion = HttpVersion.Version11;
                ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls;
                request.KeepAlive = true;
                ServicePointManager.CheckCertificateRevocationList = true; ServicePointManager.DefaultConnectionLimit = 100;
                ServicePointManager.Expect100Continue = false;
            }
            else
            {
                request = WebRequest.Create(url) as HttpWebRequest;
            }

            request.Timeout = 10000;
            request.Method = "POST";
            request.ContentType = string.Format("multipart/form-data; boundary={0}", boundary);
            request.UserAgent = this.UserAgent;
            request.Accept = this.Accept;
            request.Referer = this.Referer;
            request.ContentLength = memoryStream.Length;
            request.CookieContainer = this.CookieContainer;

            memoryStream.Position = 0;
            byte[] tempBuffer = new byte[memoryStream.Length];
            memoryStream.Read(tempBuffer, 0, tempBuffer.Length);
            memoryStream.Close();

            using (var streamWriter = request.GetRequestStream())
            {
                streamWriter.Write(tempBuffer, 0, tempBuffer.Length);
            }

            string resContent = "";
            HttpWebResponse response = request.GetResponse() as HttpWebResponse;
            using (Stream resStream = response.GetResponseStream())
            {
                using (StreamReader streamReader = new StreamReader(resStream, Encoding.UTF8))
                {
                    resContent = streamReader.ReadToEnd().ToString();
                }
            }

            return resContent;
        }

        public static string Send(UploadParameterType parameters)
        {
            BiosenFileRequestClient client = new BiosenFileRequestClient();
            client.parameters = parameters;
            LogConstant.logger.Print(string.Format("[Post][File]准备上传文件[{0}]到数据服务器", parameters.FileName));
            string t_response = client.Post(BiosenFileRequestClient.Uri);
            JObject res = JObject.Parse(t_response);
            if (res["status"].ToString().Equals("0"))
            {
                string url = res["data"].ToString();
                LogConstant.logger.Print(string.Format("[Post][File]文件上传到数据服务器的保存地址:[{0}]", t_response));
                return url;
            }
            else
            {
                LogConstant.logger.Print(string.Format("[Post][File]文件上传数据服务器失败:{0}", res["message"].ToString()));
                throw new Exception(res["message"].ToString());
            }
        }
    }

    internal sealed class BiosenBatchFilesRequestClient : HttpRequestClient
    {
        public static string Uri { set; get; }

        private UploadParameterType parameters;
        public static void Init()
        {
            PostServerSection section = ConfigurationManager.GetSection("fileServer") as PostServerSection;
            BiosenBatchFilesRequestClient.Uri = section.Server.URI;
        }

        public override string Post(string url)
        {
            if (string.IsNullOrWhiteSpace(url))
                throw new ArgumentNullException(nameof(url));

            string boundary = DateTime.Now.Ticks.ToString("x");          // 边界符
            byte[] beginBoundaryBytes = Encoding.UTF8.GetBytes("--" + boundary + "\r\n");
            byte[] endBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "--\r\n");
            byte[] newLineBytes = Encoding.UTF8.GetBytes("\r\n");

            MemoryStream memoryStream = new MemoryStream();
            if (this.parameters.PostParameters != null && parameters.PostParameters.Count > 0)
            {
                foreach (KeyValuePair<string, string> keyValuePair in parameters.PostParameters)
                {
                    string parameterHeaderTemplate = string.Format("Content-Disposition: form-data; name=\"{0}\"\r\n\r\n{1}\r\n", keyValuePair.Key, keyValuePair.Value);
                    byte[] parameterHeaderBytes = parameters.Encoding.GetBytes(parameterHeaderTemplate);

                    memoryStream.Write(beginBoundaryBytes, 0, beginBoundaryBytes.Length);
                    memoryStream.Write(parameterHeaderBytes, 0, parameterHeaderBytes.Length);
                }
            }

            const string filePartHeaderTemplate = "Content-Disposition: form-data; name=\"{0}\"; filename=\"{1}\"\r\n" +
            "Content-Type: application/octet-stream\r\n\r\n";
            int i = 0;

            if (this.parameters.FileName != null)
            {
                FileInfo fileInfo = new FileInfo(this.parameters.FileName);
                string fileName = fileInfo.Name;

                string fileHeaderItem = string.Format(filePartHeaderTemplate, "files", fileName);
                byte[] fileHeaderItemBytes = Encoding.UTF8.GetBytes(fileHeaderItem);

                if (i > 0)
                {
                    memoryStream.Write(newLineBytes, 0, newLineBytes.Length);
                }
                memoryStream.Write(beginBoundaryBytes, 0, beginBoundaryBytes.Length);
                memoryStream.Write(fileHeaderItemBytes, 0, fileHeaderItemBytes.Length);

                int bytesRead;
                byte[] buffer = new byte[1024];

                FileStream fileStream = new FileStream(this.parameters.FileName, FileMode.Open, FileAccess.Read);
                while ((bytesRead = fileStream.Read(buffer, 0, buffer.Length)) != 0)
                {
                    memoryStream.Write(buffer, 0, bytesRead);        // 2.3 将文件流写入FormData项中
                }

                i++;
            }

            memoryStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);

            HttpWebRequest request = null;
            if (url.ToLowerInvariant().StartsWith("https"))
            {
                request = WebRequest.Create(url) as HttpWebRequest;
                ServicePointManager.ServerCertificateValidationCallback = new RemoteCertificateValidationCallback((s, c, ch, ss) => { return true; });
                request.ProtocolVersion = HttpVersion.Version11;
                ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls;
                request.KeepAlive = true;
                ServicePointManager.CheckCertificateRevocationList = true; ServicePointManager.DefaultConnectionLimit = 100;
                ServicePointManager.Expect100Continue = false;
            }
            else
            {
                request = WebRequest.Create(url) as HttpWebRequest;
            }


            request.Method = "POST";
            request.ContentType = string.Format("multipart/form-data; boundary={0}", boundary);
            request.UserAgent = this.UserAgent;
            request.Accept = this.Accept;
            request.Referer = this.Referer;
            request.ContentLength = memoryStream.Length;
            request.CookieContainer = this.CookieContainer;

            memoryStream.Position = 0;
            byte[] tempBuffer = new byte[memoryStream.Length];
            memoryStream.Read(tempBuffer, 0, tempBuffer.Length);
            memoryStream.Close();

            using (var streamWriter = request.GetRequestStream())
            {
                streamWriter.Write(tempBuffer, 0, tempBuffer.Length);
            }

            string resContent = "";
            HttpWebResponse response = request.GetResponse() as HttpWebResponse;
            using (Stream resStream = response.GetResponseStream())
            {
                using (StreamReader streamReader = new StreamReader(resStream, Encoding.UTF8))
                {
                    resContent = streamReader.ReadToEnd().ToString();
                }
            }
            return resContent;
        }

        public static string Send(UploadParameterType parameters)
        {

            BiosenBatchFilesRequestClient client = new BiosenBatchFilesRequestClient();
            client.parameters = parameters;
            LogConstant.logger.Print(string.Format("[Post][File]准备上传文件[{0}]到数据服务器", parameters.FileName));
            string t_response = client.Post(BiosenFileRequestClient.Uri);
            JObject res = JObject.Parse(t_response);
            if (res["status"].ToString().Equals("0"))
            {
                string url = res["data"].ToString();
                LogConstant.logger.Print(string.Format("[Post][File]文件上传到数据服务器的保存地址:[{0}]", t_response));
                return url;
            }
            else
            {
                LogConstant.logger.Print(string.Format("[Post][File]文件上传数据服务器失败:{0}", res["message"].ToString()));
                throw new Exception(res["message"].ToString());
            }
        }
    }
}