YG-PVC-WCS/WCS.WMSWorkflow/WebApi/WebApiHelper.cs

using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Runtime.Serialization.Json;
using System.Text;
using System.Threading;
using System.Web;
using WCS.Data;

namespace WCS.WMSWorkflow
{
    public enum RequestMethod
    {
        Get = 1,//获取
        Post = 2,//投寄
        OPTIONS = 3,//选项
        HEAD = 4,//头
        PUT = 5,//放置
        DELETE = 6,//删除
        TRACE = 7,//跟踪
        CONNECT = 8,//连接
    }
    public class WebApiHelper
    {

        //internal static string MesBlankDownAddress = Convert.ToString(System.Configuration.ConfigurationManager.AppSettings["MesBlankDown"]);

        //application/x-www-form-urlencoded//application/json
        /// <summary>
        /// webapi地址调用函数
        /// </summary>
        /// <param name="url">地址</param>
        /// <param name="user_Id">验证用户</param>
        /// <param name="reqMethod">请求方式</param>
        /// <param name="param">参数(json)</param>
        /// <returns></returns>
        internal static JObject SendInfoToWebAPI(string url, string user_Id = null, string reqMethod = "Get", JArray param = null)
        {
            //JArray jsonobj =new JArray();
            JObject jobj = null;
            HttpWebRequest webRequest = null;
            HttpWebResponse webResponse = null;
            try
            {
                webRequest = (HttpWebRequest)HttpWebRequest.Create(url);
                //webRequest.ContentType = "application/x-www-form-urlencoded";
                webRequest.ContentType = "application/json";
                //webRequest.UserAgent = "Mozilla/4.0   (compatible;   MSIE   6.0;   Windows   NT   5.1;   SV1;   .NET   CLR  2.0.50727) ";
                webRequest.Method = reqMethod;
                webRequest.AllowAutoRedirect = false;
                webRequest.Timeout = 50000;
                byte[] PostData = null;
                if (user_Id != null)
                    webRequest.Headers.Add("Authorization", user_Id);
                //webRequest.Headers.Add("Authorization", "A1203016");
                if (param != null)
                {
                    //string paraUrlCoded = System.Web.HttpUtility.UrlEncode("paramaters");
                    //paraUrlCoded += "=" + System.Web.HttpUtility.UrlEncode(jsonParas);
                    PostData = Encoding.UTF8.GetBytes(param[0].ToString());
                    webRequest.ContentLength = PostData.Length;
                }
                if (reqMethod == RequestMethod.Post.ToString())
                {
                    Stream RequestStream = webRequest.GetRequestStream();
                    if (PostData != null)
                    {
                        RequestStream.Write(PostData, 0, PostData.Length);
                    }
                    RequestStream.Close();
                    RequestStream.Dispose();
                }
                webResponse = (HttpWebResponse)webRequest.GetResponse();
                Stream ResponseStrem = webResponse.GetResponseStream();
                StreamReader reader = new StreamReader(ResponseStrem);
                string ValueString = reader.ReadToEnd();
                jobj = JObject.Parse(ValueString);
                //jsonobj = JArray.Parse(ValueString);
                ResponseStrem.Dispose();
                webResponse.Close();
            }
            catch (ThreadInterruptedException threx)
            {
                string messge = string.Format("调用接口超时，线程被中断,Url=[{0}]", url);
                Log4netHelper.Logger_Error.Error(messge);
            }
            catch (WebException webex)
            {
                //webResponse = (HttpWebResponse)webex.Response;
                //StreamReader sr = new StreamReader(webResponse.GetResponseStream());
                //string temp = sr.ReadToEnd();
                string messge = string.Format("通信接口错误[{0}],Url=[{1}]", webex.Message, url);
                Log4netHelper.Logger_Error.Error(messge);
            }
            catch (Exception ex)
            {
                //string messge = string.Format("通信接口错误,Url={0}", url);
                Log4netHelper.Logger_Error.Error(ex.ToString());
            }
            finally
            {
                if (webResponse != null)
                {
                    webResponse.Close();
                    webResponse = null;
                }
                if (webRequest != null)
                {
                    webRequest.Abort();
                    webRequest = null;
                }
            }
            return jobj;
        }

        internal static JObject SendInfoToAPI(string url, string user_Id = null, string reqMethod = "Get", JArray param = null)
        {
            JObject jobj = null;
            HttpWebRequest webRequest = null;
            HttpWebResponse webResponse = null;
            try
            {
                webRequest = (HttpWebRequest)WebRequest.Create(url);
                //webRequest.ContentType = "application/x-www-form-urlencoded";
                webRequest.ContentType = "application/json";
                //webRequest.UserAgent = "Mozilla/4.0   (compatible;   MSIE   6.0;   Windows   NT   5.1;   SV1;   .NET   CLR  2.0.50727) ";
                webRequest.Method = reqMethod;
                webRequest.AllowAutoRedirect = false;
                webRequest.Timeout = 500000;
                byte[] PostData = null;
                if (user_Id != null)
                    webRequest.Headers.Add("Authorization", user_Id);
                //webRequest.Headers.Add("Authorization", "A1203016");
                if (param != null)
                {
                    //string paraUrlCoded = System.Web.HttpUtility.UrlEncode("paramaters");
                    //paraUrlCoded += "=" + System.Web.HttpUtility.UrlEncode(jsonParas);
                    PostData = Encoding.UTF8.GetBytes(param[0].ToString());
                    webRequest.ContentLength = PostData.Length;
                }
                if (reqMethod == RequestMethod.Post.ToString())
                {
                    Stream RequestStream = webRequest.GetRequestStream();
                    if (PostData != null)
                    {
                        RequestStream.Write(PostData, 0, PostData.Length);
                    }
                    RequestStream.Close();
                    RequestStream.Dispose();
                }
                webResponse = (HttpWebResponse)webRequest.GetResponse();
                Stream ResponseStrem = webResponse.GetResponseStream();
                StreamReader reader = new StreamReader(ResponseStrem);
                string ValueString = reader.ReadToEnd();
                jobj = JObject.Parse(ValueString);
                //jsonobj = JArray.Parse(ValueString);
                ResponseStrem.Dispose();
                webResponse.Close();
            }
            catch (ThreadInterruptedException threx)
            {
                string messge = string.Format("调用接口超时，线程被中断,Url=[{0}]", url);
                Log4netHelper.Logger_Error.Error(messge);

                throw new Exception(messge);
            }
            catch (WebException webex)
            {
                string messge = string.Format("通信接口错误[{0}],Url=[{1}]", webex.Message, url);
                Log4netHelper.Logger_Error.Error(messge);

                throw new Exception(messge);
            }
            catch (Exception ex)
            {
                Log4netHelper.Logger_Error.Error(ex.ToString());

                throw new Exception(ex.Message);
            }
            finally
            {
                if (webResponse != null)
                {
                    webResponse.Close();
                    webResponse = null;
                }
                if (webRequest != null)
                {
                    webRequest.Abort();
                    webRequest = null;
                }
            }
            return jobj;
        }
        internal static JObject SendAsyncInfoToWebAPI(string url, string user_Id = null, string reqMethod = "Get", JArray param = null)
        {
            //JArray jsonobj =new JArray();
            JObject jobj = null;
            HttpWebRequest webRequest = null;
            HttpWebResponse webResponse = null;
            try
            {
                webRequest = (HttpWebRequest)HttpWebRequest.Create(url);
                webRequest.ContentType = "application/x-www-form-urlencoded";
                webRequest.Method = reqMethod;
                webRequest.AllowAutoRedirect = false;
                webRequest.Timeout = 5000;
                byte[] PostData = null;
                if (user_Id != null)
                    webRequest.Headers.Add("Authorization", user_Id);
                //webRequest.Headers.Add("Authorization", "A1203016");
                if (param != null)
                {
                    //string paraUrlCoded = System.Web.HttpUtility.UrlEncode("paramaters");
                    //paraUrlCoded += "=" + System.Web.HttpUtility.UrlEncode(jsonParas);
                    PostData = Encoding.UTF8.GetBytes(param[0].ToString());
                    webRequest.ContentLength = PostData.Length;
                }
                if (reqMethod == RequestMethod.Post.ToString())
                {
                    Stream RequestStream = webRequest.GetRequestStream();
                    if (PostData != null)
                    {
                        RequestStream.Write(PostData, 0, PostData.Length);
                    }
                    RequestStream.Close();
                    RequestStream.Dispose();
                }
                //webResponse = (HttpWebResponse)webRequest.GetResponse();
                webRequest.BeginGetResponse(AsyncCallbackResponse, webRequest);


                //Stream ResponseStrem = webResponse.GetResponseStream();
                //StreamReader reader = new StreamReader(ResponseStrem);
                //string ValueString = reader.ReadToEnd();
                //jobj = JObject.Parse(ValueString);
                //jsonobj = JArray.Parse(ValueString);
                //ResponseStrem.Dispose();
                webResponse.Close();
            }
            catch (WebException webex)
            {
                webResponse = (HttpWebResponse)webex.Response;
                StreamReader sr = new StreamReader(webResponse.GetResponseStream());
                string temp = sr.ReadToEnd();
                string messge = string.Format("通信接口错误,Url={0}", url);
            }
            catch (Exception ex)
            {
                string messge = string.Format("通信接口错误,Url={0}", url);
            }
            finally
            {
                if (webResponse != null)
                {
                    webResponse.Close();
                    webResponse = null;
                }
                if (webRequest != null)
                {
                    webRequest.Abort();
                    webRequest = null;
                }
            }
            return jobj;
        }

        internal static JArray SendInfoToWebAPIList(string url, string user_Id = null, string reqMethod = "Get", JArray param = null)
        {
            JArray jsonobj =new JArray();
            //JObject jobj = null;
            HttpWebRequest webRequest = null;
            HttpWebResponse webResponse = null;
            try
            {
                webRequest = (HttpWebRequest)HttpWebRequest.Create(url);
                //webRequest.ContentType = "application/x-www-form-urlencoded";
                webRequest.ContentType = "application/json";
                //webRequest.UserAgent = "Mozilla/4.0   (compatible;   MSIE   6.0;   Windows   NT   5.1;   SV1;   .NET   CLR  2.0.50727) ";
                webRequest.Method = reqMethod;
                webRequest.AllowAutoRedirect = false;
                webRequest.Timeout = 50000;
                byte[] PostData = null;
                if (user_Id != null)
                    webRequest.Headers.Add("Authorization", user_Id);
                //webRequest.Headers.Add("Authorization", "A1203016");
                if (param != null)
                {
                    //string paraUrlCoded = System.Web.HttpUtility.UrlEncode("paramaters");
                    //paraUrlCoded += "=" + System.Web.HttpUtility.UrlEncode(jsonParas);
                    PostData = Encoding.UTF8.GetBytes(param[0].ToString());
                    webRequest.ContentLength = PostData.Length;
                }
                if (reqMethod == RequestMethod.Post.ToString())
                {
                    Stream RequestStream = webRequest.GetRequestStream();
                    if (PostData != null)
                    {
                        RequestStream.Write(PostData, 0, PostData.Length);
                    }
                    RequestStream.Close();
                    RequestStream.Dispose();
                }
                webResponse = (HttpWebResponse)webRequest.GetResponse();
                Stream ResponseStrem = webResponse.GetResponseStream();
                StreamReader reader = new StreamReader(ResponseStrem);
                string ValueString = reader.ReadToEnd();
                //jobj = JObject.Parse(ValueString);
                jsonobj = JArray.Parse(ValueString);
                ResponseStrem.Dispose();
                webResponse.Close();
            }
            catch (WebException webex)
            {
                //webResponse = (HttpWebResponse)webex.Response;
                //StreamReader sr = new StreamReader(webResponse.GetResponseStream());
                //string temp = sr.ReadToEnd();
                string messge = string.Format("通信接口错误,Url={0}", url);
            }
            catch (Exception ex)
            {
                string messge = string.Format("通信接口错误,Url={0}", url);
            }
            finally
            {
                if (webResponse != null)
                {
                    webResponse.Close();
                    webResponse = null;
                }
                if (webRequest != null)
                {
                    webRequest.Abort();
                    webRequest = null;
                }
            }
            return jsonobj;
        }

        private static void AsyncCallbackResponse(IAsyncResult ar)
        {
            HttpWebRequest webrequest = ar.AsyncState as HttpWebRequest;
            var webresponse = webrequest.EndGetResponse(ar) as HttpWebResponse;
            Stream ResponseStrem = webresponse.GetResponseStream();
            using (StreamReader reader = new StreamReader(ResponseStrem))
            {
                string ValueString = reader.ReadToEnd();
            }
        }

        /// <summary>  
        /// 生成Json格式  
        /// </summary>  
        public static string GetJson(object obj)
        {
            DataContractJsonSerializer json = new DataContractJsonSerializer(obj.GetType());
            using (MemoryStream stream = new MemoryStream())
            {
                json.WriteObject(stream, obj);
                string szJson = Encoding.UTF8.GetString(stream.ToArray());
                return szJson;
            }
        }

        /// <summary>  
        /// 生成Json格式  
        /// </summary>  
        public static string GetJson_2<T>(T t)
        {
            DataContractJsonSerializer json = new DataContractJsonSerializer(typeof(T));
            using (MemoryStream stream = new MemoryStream())
            {
                json.WriteObject(stream, t);
                string szJson = Encoding.UTF8.GetString(stream.ToArray());
                return szJson;
            }
        }
        /// <summary>  
        /// Json转Model  
        /// </summary>  
        public static T ParseFromJson<T>(string szJson)
        {
            T obj = Activator.CreateInstance<T>();
            using (MemoryStream ms = new MemoryStream(Encoding.UTF8.GetBytes(szJson)))
            {
                DataContractJsonSerializer serializer = new DataContractJsonSerializer(obj.GetType());
                return (T)serializer.ReadObject(ms);
            }
        }
        /// <summary>  
        /// Json转List
        /// </summary>  
        public static List<T> ParseToListFromJson<T>(JArray ja)
        {
            var result = new List<T>();
            foreach (var item in ja)
            {
                result.Add(ParseFromJson<T>(item.ToString()));
            }
            return result;
        }
    }
}