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

namespace BatchService.Framework.Utility
{
    /// <summary>
    /// 向远程Url Post/Get数据类
    /// </summary>
    public class NetHelper
    {
        public static T HttpPost<T>(string uri, object data, SerializationType serializationType)
        {
            string responseText = HttpPost(uri, data, serializationType);

            T t = default(T);
            if (serializationType == SerializationType.Xml)
            {
                t = (T)SerializationHelper.XmlDeserialize(typeof(T), responseText);
            }
            else if (serializationType == SerializationType.Json)
            {
                t = (T)SerializationHelper.JsonDeserialize(typeof(T), responseText);
            }
            return t;
        }

        public static string HttpPost(string uri, object data, SerializationType serializationType)
        {
            HttpWebRequest request = HttpWebRequest.Create(uri) as HttpWebRequest;
            request.Method = "POST";
            request.ContentType = "application/x-www-form-urlencoded;charset=utf-8";

            string dataStr = string.Empty;
            if (data is string)
            {
                dataStr = (string)data;
            }
            else
            {
                if (serializationType == SerializationType.Xml)
                {
                    dataStr = SerializationHelper.XmlSerialize(data);
                    object o = SerializationHelper.XmlDeserialize(data.GetType(), dataStr);
                }
                else if (serializationType == SerializationType.Json)
                {
                    dataStr = SerializationHelper.JsonSerialize(data);
                }
            }
            CNNWebClient wc = new CNNWebClient();
            wc.Timeout = 300;
            LogHelper.Debug(String.Format("uri:{0},data:{1}", uri, data));
            var t = wc.UploadData(uri, "POST", Encoding.UTF8.GetBytes(dataStr));
            string tText = Encoding.UTF8.GetString(t);
            /*
            System.Diagnostics.Debug.WriteLine(tText);
            byte[] buffer;
            Stream stream;
            if (!string.IsNullOrWhiteSpace(dataStr))
            {
                buffer = Encoding.UTF8.GetBytes(dataStr);
                stream = request.GetRequestStream();
                stream.Write(buffer, 0, buffer.Length);
            }
            //request.d
            HttpWebResponse response = request.GetResponse() as HttpWebResponse;

            stream = response.GetResponseStream();
            buffer = new byte[response.ContentLength];
            stream.Read(buffer, 0, (int)response.ContentLength);
            //string encoding = string.IsNullOrWhiteSpace(response.ContentEncoding) ? "uft-8" : response.ContentEncoding;
            string responseText = Encoding.UTF8.GetString(buffer);
            System.Diagnostics.Debug.WriteLine(responseText);
            return responseText;
             */
            return tText;
        }

        public static string HttpPost(string uri, System.Collections.Specialized.NameValueCollection data)
        {
            CNNWebClient wc = new CNNWebClient();
            wc.Encoding = Encoding.UTF8;
            wc.Timeout = 300;
            var t = wc.UploadValues(uri, "POST", data);
            string tText = Encoding.UTF8.GetString(t);
            return tText;
        }


        public static T HttpGet<T>(string uri, SerializationType serializationType)
        {
            string responseText = HttpGet(uri);

            T t = default(T);
            if (serializationType == SerializationType.Xml)
            {
                t = (T)SerializationHelper.XmlDeserialize(typeof(T), responseText);
            }
            else if (serializationType == SerializationType.Json)
            {
                t = (T)SerializationHelper.JsonDeserialize(typeof(T), responseText);
            }
            return t;
        }

        public static string HttpGet(string uri)
        {
            StringBuilder respBody = new StringBuilder();
            HttpWebRequest request = HttpWebRequest.Create(uri) as HttpWebRequest;
            request.Method = "GET";
            request.ContentType = "application/x-www-form-urlencoded;charset=utf-8";

            HttpWebResponse response = request.GetResponse() as HttpWebResponse;

            byte[] buffer = new byte[8192];
            Stream stream;
            stream = response.GetResponseStream();
            int count = 0;
            do
            {
                count = stream.Read(buffer, 0, buffer.Length);
                if (count != 0)
                    respBody.Append(Encoding.UTF8.GetString(buffer, 0, count));
            }
            while (count > 0);
            string responseText = respBody.ToString();
            return responseText;
        }

        public class CNNWebClient : WebClient
        {

            private int _timeOut = 200;

            /// <summary>
            /// 过期时间
            /// </summary>
            public int Timeout
            {
                get
                {
                    return _timeOut;
                }
                set
                {
                    if (value <= 0)
                        _timeOut = 200;
                    _timeOut = value;
                }
            }

            /// <summary>
            /// 重写GetWebRequest,添加WebRequest对象超时时间
            /// </summary>
            /// <param name="address"></param>
            /// <returns></returns>
            protected override WebRequest GetWebRequest(Uri address)
            {
                HttpWebRequest request = (HttpWebRequest)base.GetWebRequest(address);
                request.Timeout = 1000 * Timeout;
                request.ReadWriteTimeout = 1000 * Timeout;
                return request;
            }
        }
    }
}