HttpHelper.cs 5.5 KB
using System;
using System.IO;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Web;
using System.Collections;
using System.Net;
using System.Net.Security;
using System.Security;
using System.Security.Cryptography;
using System.Security.Cryptography.X509Certificates;
using System.Reflection;
using log4net;
using System.Net.NetworkInformation;

namespace OnlineStore.Common
{
    public class HttpHelper
    {
       public static readonly ILog LOGGER = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);

        public static Operation PostOP(string url, Operation operation,out  bool isTimeOut)
        {
            isTimeOut = false;
            try
            { 
                string json = "";
                try
                {
                    json = JsonHelper.SerializeObject(operation);
                }
                catch (Exception ex)
                {
                    LogUtil.error("JsonHelper.SerializeObject(operation) 出错【operation.op=" + operation.op + "】" + ex);
                }

                string result = PostJson(url, json, Encoding.UTF8, out isTimeOut);


                if (!string.IsNullOrEmpty(result))
                {
                    try
                    {
                        return JsonHelper.DeserializeJsonToObject<Operation>(result);
                    }
                    catch (Exception ex)
                    {
                        LogUtil.error("JsonHelper.DeserializeJsonToObject 出错【result=" + result + "】" + ex);
                    }
                } 
            }
            catch (Exception ex)
            {
                LogUtil.error("Post 出错【operation.op=" + operation.op + "】:" + ex);
            }
            return null;
        }
        private static int isLog = ConfigAppSettings.GetIntValue(Setting_Init.Server_Log_Open); 
        private  static string PostJson(string url, string paramData, Encoding encoding, out bool IsTimeOut)
        {
            IsTimeOut = false;
            if (isLog == 1)
            {
                LOGGER.Info("给服务器发送数据【" + paramData + "】 ");
            }
          
            string result = "";

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

            try
            {
                var wc = new MyWebClient(3000);
                if (string.IsNullOrEmpty(wc.Headers["Content-Type"]))
                    wc.Headers.Add("Content-Type", "application/json;charset=UTF-8");
                wc.Encoding = encoding;

                result = wc.UploadString(url, "POST", paramData); 
            }
            catch (WebException ex)
            {
                IsTimeOut = true;
                LogUtil.error(LOGGER, "POST WebException :" + ex.ToString(), 101);
            }
            catch (Exception e)
            {
                LogUtil.error(LOGGER, "POST ERROR:" + e.ToString(), 1);
            } 
            if (isLog == 1)
            {
                LogUtil.info("收到服务器数据【" + result + "】");
            }
            return result;
        }

        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 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
            {
                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() );
            }
            catch (Exception e)
            {
                LogUtil.error("POST [" + url + "] ERROR:" + e.ToString() );
            }
            if (!result.Contains("null") && result.Length != 0)
            {
                //LogUtil.debug(LOGGER,"receive << " + result);
            }
            if (isLog == 1)
            {
                LogUtil.info("收到服务器数据【" + result + "】");
            }
            return result;
        }

    }
}