using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;

namespace HH.WCS.Mobox3.AnGang.util {
    public class HttpHelper {
        public string WebPost(string url, string postData, string cotentType = "application/json")
        {
            Console.WriteLine(url);
            WebRequest request = WebRequest.Create(url);
            request.Method = "POST";
            //string postData = JsonConvert.SerializeObject(data); ;
            byte[] byteArray = Encoding.UTF8.GetBytes(postData);
            request.ContentType = cotentType;
            request.ContentLength = byteArray.Length;
            request.Timeout = 3000;
            StreamReader reader = null;
            Stream dataStream = null;
            WebResponse response = null;

            try
            {
                dataStream = request.GetRequestStream();
                dataStream.Write(byteArray, 0, byteArray.Length);
                dataStream.Close();
                response = request.GetResponse();
                //Console.WriteLine(((HttpWebResponse)response).StatusDescription);
                dataStream = response.GetResponseStream();
                reader = new StreamReader(dataStream, Encoding.UTF8);
                string responseFromServer = reader.ReadToEnd();
                return responseFromServer;
            }
            catch (Exception e)
            {
                LogHelper.Info($"WebPost res={e.Message}", "API");
                return "";
            }
            finally
            {
                // 释放资源
                if (reader != null) reader.Close();
                if (dataStream != null) dataStream.Close();
                if (response != null) response.Close();
            }
        }

        public string WebGet(string url) {
            WebRequest request = WebRequest.Create(url);
            request.Timeout = 6000;
            request.Method = "GET";
            StreamReader reader = null;
            Stream dataStream = null;
            WebResponse response = null;
            try {
                response = request.GetResponse();
                dataStream = response.GetResponseStream();
                reader = new StreamReader(dataStream);
                string responseFromServer = reader.ReadToEnd();

                Console.WriteLine(responseFromServer);
                return responseFromServer;
            }
            catch (Exception e) {
                LogHelper.Info($"WebGet res={e.Message}", "API");
                return "";
            }
            finally
            {
                // 释放资源
                if (reader != null) reader.Close();
                if (dataStream != null) dataStream.Close();
                if (response != null) response.Close();
            }
        }

        public string Get(string url, string contentType = "application/x-www-form-urlencoded") {
            WebRequest request = WebRequest.Create(url);
            request.Method = "Get";
            request.ContentType = contentType;
            StreamReader reader = null;
            Stream stream = null;
            WebResponse rsp = null;
            try {

                rsp = request.GetResponse();
                stream = rsp.GetResponseStream();
                reader = new StreamReader(stream);
                return reader.ReadToEnd();
            }
            catch (Exception e)
            {
                LogHelper.Info($"Get res={e.Message}", "API");
                return "";
            }
            finally {
                // 释放资源
                if (reader != null) reader.Close();
                if (stream != null) stream.Close();
                if (rsp != null) rsp.Close();
            }
        }
        
        public string Post(string url, string postData, string contentType = "application/json", string sessionId = "") {
            Console.WriteLine(url);
            WebRequest request = WebRequest.Create(url);
            request.Method = "POST";
            byte[] byteArray = Encoding.UTF8.GetBytes(postData);
            request.ContentType = contentType;
            request.ContentLength = byteArray.Length;
            request.Timeout = 3000;
            if (sessionId != "") {
                request.Headers.Set("ASP.NET_SessionId", sessionId);
            }
            StreamReader reader = null;
            Stream stream = null;
            WebResponse rsp = null;
            try {
                stream = request.GetRequestStream();
                stream.Write(byteArray, 0, byteArray.Length);
                stream.Close();
                rsp = request.GetResponse();
                stream = rsp.GetResponseStream();
                reader = new StreamReader(stream);
                return reader.ReadToEnd();
            }
            catch (Exception ex) {
                LogHelper.Info($"Post res={ex.Message}", "API");
                return "";
            }
            finally {
                // 释放资源
                if (reader != null) reader.Close();
                if (stream != null) stream.Close();
                if (rsp != null) rsp.Close();
            }

        }

        public string Post(string url, Dictionary<string, string> dic) {
            var param = dic.Select(a => { return string.Format("{0}={1}", a.Key, a.Value); }).ToList();
            return Post(url, string.Join("&", param), "application/x-www-form-urlencoded");
        }

        public string PostWithCookie(string url, string sessinId) {
            return PostWithCookie(url, "", "", sessinId);
        }

        public string PostWithCookie(string url, string postData, string contentType = "application/json", string sessionId = "") {
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
            request.Method = "POST";
            byte[] byteArray = Encoding.UTF8.GetBytes(postData);
            request.ContentType = contentType;
            request.ContentLength = byteArray.Length;
            if (sessionId != "") {
                request.CookieContainer = new CookieContainer();
                request.CookieContainer.SetCookies(new Uri("http://" + request.RequestUri.Authority), "ASP.NET_SessionId=" + sessionId);
            }
            StreamReader reader = null;
            Stream stream = null;
            WebResponse rsp = null;
            try {
                stream = request.GetRequestStream();
                stream.Write(byteArray, 0, byteArray.Length);
                stream.Close();
                rsp = request.GetResponse();
                stream = rsp.GetResponseStream();
                reader = new StreamReader(stream);
                return reader.ReadToEnd();
            }
            catch (Exception e)
            {

                LogHelper.Info($"PostWithCookie res={e.Message}", "API");
                return "";
            }
            finally {
                // 释放资源
                if (reader != null) reader.Close();
                if (stream != null) stream.Close();
                if (rsp != null) rsp.Close();
            }

        }

        public string Put(string url, string postData, string contentType = "application/json", string sessionId = "")
        {
            WebRequest request = WebRequest.Create(url);
            request.Method = "Put";
            byte[] byteArray = Encoding.UTF8.GetBytes(postData);
            request.ContentType = contentType;
            request.ContentLength = byteArray.Length;
            if (sessionId != "")
            {
                request.Headers.Set("ASP.NET_SessionId", sessionId);
            }
            StreamReader reader = null;
            Stream stream = null;
            WebResponse rsp = null;
            try
            {
                stream = request.GetRequestStream();
                stream.Write(byteArray, 0, byteArray.Length);
                stream.Close();
                rsp = request.GetResponse();
                stream = rsp.GetResponseStream();
                reader = new StreamReader(stream);
                return reader.ReadToEnd();
            }
            catch (Exception e)
            {
                LogHelper.Info($"Put res={e.Message}", "API");
                return "";
            }
            finally
            {
                // 释放资源
                if (reader != null) reader.Close();
                if (stream != null) stream.Close();
                if (rsp != null) rsp.Close();
            }
        }

        public string WebPostWithMD5(string url, string postData, string contentType = "application/json")
        {
            // 新增授权参数
            string appKey = ""; // 假设配置类中有AppKey和AppSecret
            string appSecret = "";
            string reqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
            string reqVerify = CalculateMD5Hash($"{appKey}{appSecret}{reqTime}");

            WebRequest request = WebRequest.Create(url);
            request.Method = "POST";
            request.Headers.Add("AppKey", appKey);
            request.Headers.Add("ReqTime", reqTime);
            request.Headers.Add("ReqVerify", reqVerify);

            byte[] byteArray = Encoding.UTF8.GetBytes(postData);
            request.ContentType = contentType;
            request.ContentLength = byteArray.Length;
            request.Timeout = 3000;
            StreamReader reader = null;
            Stream dataStream = null;
            WebResponse response = null;

            try
            {
                dataStream = request.GetRequestStream();
                dataStream.Write(byteArray, 0, byteArray.Length);
                dataStream.Close();
                response = request.GetResponse();
                //Console.WriteLine(((HttpWebResponse)response).StatusDescription);
                dataStream = response.GetResponseStream();
                reader = new StreamReader(dataStream, Encoding.UTF8);
                string responseFromServer = reader.ReadToEnd();
                return responseFromServer;
            }
            catch (Exception e)
            {
                LogHelper.Info($"WebPost res={e.Message}", "API");
                return "";
            }
            finally
            {
                // 释放资源
                if (reader != null) reader.Close();
                if (dataStream != null) dataStream.Close();
                if (response != null) response.Close();
            }
        }

        // MD5计算辅助方法
        private static string CalculateMD5Hash(string input)
        {
            using (var md5 = System.Security.Cryptography.MD5.Create())
            {
                byte[] inputBytes = Encoding.UTF8.GetBytes(input);
                byte[] hashBytes = md5.ComputeHash(inputBytes);
                return BitConverter.ToString(hashBytes).Replace("-", "").ToLower();
            }
        }
    }
}