using System;
|
using System.Collections;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Net;
|
using System.Reflection;
|
using System.Text;
|
using System.Xml;
|
using Newtonsoft.Json;
|
|
namespace Utility.Tools
|
{
|
public class HttpHelper
|
{
|
private static HttpWebRequest GetHttpWebRequest(string url, Dictionary<string, string> headerDic, string method)
|
{
|
HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
|
request.Method = method;
|
if (headerDic != null && headerDic.Count > 0)
|
{
|
foreach (var h in headerDic)
|
{
|
request.Headers.Add(h.Key, h.Value);
|
}
|
}
|
return request;
|
}
|
private static string GetUrlParamString(Dictionary<string, string> paramDic)
|
{
|
StringBuilder sb = new StringBuilder();
|
if (paramDic == null || paramDic.Count() < 1)
|
{
|
return string.Empty;
|
}
|
foreach (var d in paramDic)
|
{
|
if (sb.Length < 1)
|
{
|
sb.AppendFormat("{0}={1}", d.Key, d.Value);
|
}
|
else
|
{
|
sb.AppendFormat("&{0}={1}", d.Key, d.Value);
|
}
|
}
|
sb.Insert(0, "?");
|
return sb.ToString();
|
}
|
private static string GetResponseString(HttpWebRequest request)
|
{
|
try
|
{
|
using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
|
{
|
using (StreamReader reader = new StreamReader(response.GetResponseStream(), Encoding.UTF8))
|
{
|
return reader.ReadToEnd();
|
}
|
}
|
}
|
catch (WebException ex)
|
{
|
throw ex;
|
}
|
}
|
|
public static string DoGet(string url, Dictionary<string, string> paramDic = null, Dictionary<string, string> headerDic = null)
|
{
|
var paramString = GetUrlParamString(paramDic);
|
var request = GetHttpWebRequest(url + paramString, headerDic, "GET");
|
request.ContentType = "application/json";
|
try
|
{
|
return GetResponseString(request);
|
}
|
catch (WebException ex)
|
{
|
throw ex;
|
}
|
}
|
|
public static string DoPost(string url, string jsonData, string logStr,string str, Dictionary<string, string> headerDic = null)
|
{
|
var request = GetHttpWebRequest(url, headerDic, "POST");
|
request.ContentType = "application/json";
|
request.ContentLength = 0;
|
//log路径
|
var logStr2 = $@".\log\{str}\{logStr}" + DateTime.Now.ToString("yyyyMMdd") + ".txt";
|
if (!string.IsNullOrWhiteSpace(jsonData))
|
{
|
byte[] buffer = Encoding.UTF8.GetBytes(jsonData);
|
request.ContentLength = buffer.Length;
|
try
|
{
|
request.GetRequestStream().Write(buffer, 0, buffer.Length);
|
//记录log
|
LogFile.SaveLogToFile($"{logStr}：( {jsonData} ),", logStr2);
|
}
|
catch (WebException ex)
|
{
|
LogFile.SaveLogToFile($"{logStr}：( {ex.Message} ),", logStr2);
|
throw ex;
|
}
|
}
|
try
|
{
|
var requestData = GetResponseString(request);
|
LogFile.SaveLogToFile($"{logStr}反馈：( {requestData} ),", logStr2);
|
return requestData;
|
}
|
catch (WebException ex)
|
{
|
LogFile.SaveLogToFile($"{logStr}反馈：( {ex.Message} ),", logStr2);
|
throw ex;
|
}
|
}
|
|
public static string DoPost(string url, Dictionary<string, string> paramDic, string logStr,string str, Dictionary<string, string> headerDic = null)
|
{
|
string jsonStr = null;
|
if (paramDic != null && paramDic.Count() > 0)
|
{
|
jsonStr = JsonConvert.SerializeObject(paramDic);
|
}
|
return DoPost(url, jsonStr, logStr,str,headerDic);
|
}
|
|
|
|
|
/// <summary>
|
/// post调用webservice接口
|
/// </summary>
|
/// <param name="url">地址</param>
|
/// <param name="method">方法名称</param>
|
/// <param name="pars">数据参数</param>
|
/// <returns></returns>
|
public static XmlDocument HttpPostWebService(string url, string method, Hashtable pars, string xmlName, string strValue = "")
|
{
|
try
|
{
|
HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(url + method);
|
request.Method = "POST";
|
request.ContentType = @"text/xml;charset=UTF-8";
|
//request.Headers.Add("Accept-Language", "zh;");
|
//request.Accept = @"gzip,deflate,br";
|
//request.UserAgent = @"xml";
|
//request.PreAuthenticate = true;
|
//request.AllowWriteStreamBuffering = false;
|
//request.SendChunked = false;
|
//request.KeepAlive = false;
|
//request.Credentials = CredentialCache.DefaultCredentials;
|
request.Timeout = int.MaxValue; // 毫秒
|
|
//byte[] data;
|
XmlDocument data;
|
if (xmlName.Contains("MES"))
|
{
|
request.Headers.Add("SOAPAction", @"http://tempuri.org/ITransferService/TransferMessageForMagic");
|
data = MesEncodeParsToSap(strValue, xmlName);
|
}
|
else
|
{
|
data = MesEncodeParsToSap(strValue, xmlName);
|
//data = EncodeParsToFuMa(pars, method, xmlName);
|
}
|
|
//WriteRequestData(request, data);//将处理成字节组的XML写到流中发送到服务端
|
//XmlDocument doc = ReadXmlResponse(request.GetResponse());//读取服务端返回的结果
|
|
return data;
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
|
/// <summary>
|
/// 将数据插入到 xml文件中
|
/// </summary>
|
/// <param name="Pars"></param>
|
/// <param name="method"></param>
|
/// <param name="xmlName"></param>
|
/// <returns></returns>
|
public static XmlDocument EncodeParsToFuMa(List<string> Pars, string method, string xmlName)
|
{
|
try
|
{
|
XmlDocument xml = null;
|
var str = $"Utility.XML.{xmlName}.xml";
|
//从资源文件得到文件流
|
Stream stream = Assembly.GetExecutingAssembly().GetManifestResourceStream(str);
|
if (stream == null)
|
{
|
throw new Exception("未找到Xml文件流");
|
}
|
|
xml = new XmlDocument();
|
xml.Load(stream);
|
|
XmlNamespaceManager nsmgr = new XmlNamespaceManager(xml.NameTable);
|
nsmgr.AddNamespace("xsi", @"http://www.w3.org/2001/XMLSchema-instance");
|
|
//修改参数的值
|
foreach (var de in Pars)
|
{
|
string subNode = "DataList/Product/Batch";// + de.Key.ToString();
|
|
XmlNode node = xml.SelectSingleNode(subNode, nsmgr);
|
if (de != null)
|
{
|
XmlNode createNode = xml.CreateNode(XmlNodeType.Element, "Data", "");
|
XmlAttribute attr = xml.CreateAttribute("code");
|
attr.Value = de;
|
createNode.Attributes.Append(attr);
|
node.AppendChild(createNode);
|
}
|
|
}
|
//xml.Save("ceshi.xml");
|
//byte[] buffer = Encoding.UTF8.GetBytes(xml.InnerXml);
|
|
return xml;
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
|
/// <summary>
|
/// 将数据插入到MES xml文件中
|
/// </summary>
|
/// <param name="Pars"></param>
|
/// <param name="strValue"></param>
|
/// <param name="xmlName"></param>
|
/// <returns></returns>
|
public static XmlDocument MesEncodeParsToSap(string strValue, string xmlName)
|
{
|
try
|
{
|
XmlDocument xml = null;
|
//从资源文件得到文件流
|
Stream stream = Assembly.GetExecutingAssembly().GetManifestResourceStream("Utility.XML." + xmlName + ".xml");
|
xml = new XmlDocument();
|
xml.Load(stream);
|
|
XmlNamespaceManager nsmgr = new XmlNamespaceManager(xml.NameTable);
|
nsmgr.AddNamespace("soapenv", @"http://schemas.xmlsoap.org/soap/envelope/");
|
nsmgr.AddNamespace("tem", @"http://tempuri.org/");
|
string subNode = "soapenv:Envelope/soapenv:Body/tem:TransferMessageForMagic/tem:message";
|
XmlNode node = xml.SelectSingleNode(subNode, nsmgr);
|
node.InnerText = strValue;
|
|
//byte[] buffer = Encoding.UTF8.GetBytes(xml.InnerXml);
|
return xml;
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
|
#region xml 接口传输
|
|
///// <summary>
|
///// post调用webservice接口
|
///// </summary>
|
///// <param name="url">地址</param>
|
///// <param name="method">方法名称</param>
|
///// <param name="pars">数据参数</param>
|
///// <returns></returns>
|
//public static XmlDocument HttpPostWebService(string url, string method, Hashtable pars, string xmlName, string strValue = "")
|
//{
|
// try
|
// {
|
// HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(url + method);
|
// request.Method = "POST";
|
// request.ContentType = @"text/xml;charset=UTF-8";
|
// //request.Headers.Add("Accept-Language", "zh;");
|
// //request.Accept = @"gzip,deflate,br";
|
// //request.UserAgent = @"xml";
|
// //request.PreAuthenticate = true;
|
// //request.AllowWriteStreamBuffering = false;
|
// //request.SendChunked = false;
|
// //request.KeepAlive = false;
|
// //request.Credentials = CredentialCache.DefaultCredentials;
|
// request.Timeout = int.MaxValue; // 毫秒
|
|
// byte[] data;
|
// if (xmlName.Contains("MES"))
|
// {
|
// request.Headers.Add("SOAPAction", @"http://tempuri.org/ITransferService/TransferMessageForMagic");
|
// data = MesEncodeParsToSoap(strValue, xmlName);
|
// }
|
// else
|
// {
|
// data = EncodeParsToSoap(pars, method, xmlName);
|
// }
|
|
// WriteRequestData(request, data);//将处理成字节组的XML写到流中发送到服务端
|
// XmlDocument doc = ReadXmlResponse(request.GetResponse());//读取服务端返回的结果
|
|
// return doc;
|
// }
|
// catch (Exception ex)
|
// {
|
// throw ex;
|
// }
|
//}
|
|
///// <summary>
|
///// 将数据插入到sap xml文件中
|
///// </summary>
|
///// <param name="Pars"></param>
|
///// <param name="method"></param>
|
///// <param name="xmlName"></param>
|
///// <returns></returns>
|
//private static byte[] EncodeParsToSoap(Hashtable Pars, string method, string xmlName)
|
//{
|
// try
|
// {
|
// XmlDocument xml = null;
|
// //从资源文件得到文件流
|
// Stream stream = Assembly.GetExecutingAssembly().GetManifestResourceStream("Utility.XML." + xmlName + ".xml");
|
// xml = new XmlDocument();
|
// xml.Load(stream);
|
|
// //修改参数的值
|
// foreach (DictionaryEntry de in Pars)
|
// {
|
// XmlNamespaceManager nsmgr = new XmlNamespaceManager(xml.NameTable);
|
// nsmgr.AddNamespace("soapenv", @"http://schemas.xmlsoap.org/soap/envelope/");
|
// nsmgr.AddNamespace("zcib", @"http://zcibp.com.cn/");
|
// Hashtable subpars = de.Value as Hashtable;
|
// if (subpars == null)
|
// {
|
// string subNode = "soapenv:Envelope/soapenv:Body/zcib:SAPMM_" + xmlName + "/DATA/" + de.Key.ToString();
|
// if (xmlName == "RDATA009" || xmlName == "RDATA011" || xmlName == "RDATA016")
|
// {
|
// subNode = "soapenv:Envelope/soapenv:Body/zcib:SAPPP_" + xmlName + "/DATA/" + de.Key.ToString();
|
// }
|
|
// XmlNode node = xml.SelectSingleNode(subNode, nsmgr);
|
// if (de.Value != null)
|
// {
|
// node.InnerText = de.Value.ToString();
|
// }
|
// else
|
// {
|
// node.InnerText = "";
|
// }
|
// }
|
// else
|
// {
|
// foreach (DictionaryEntry subde in subpars)
|
// {
|
// string subNode = "soapenv:Envelope/soapenv:Body/zcib:SAPMM_" + xmlName + "/DATA/" + de.Key.ToString() + "/" + subde.Key.ToString();
|
// if (xmlName == "RDATA009" || xmlName == "RDATA011" || xmlName == "RDATA016")
|
// {
|
// subNode = "soapenv:Envelope/soapenv:Body/zcib:SAPPP_" + xmlName + "/DATA/" + de.Key.ToString() + "/" + subde.Key.ToString();
|
// }
|
// XmlNode node = xml.SelectSingleNode(subNode, nsmgr);
|
|
// if (subde.Value != null)
|
// {
|
// node.InnerText = subde.Value.ToString();
|
// }
|
// else
|
// {
|
// node.InnerText = "";
|
// }
|
// }
|
// }
|
// }
|
|
// byte[] buffer = Encoding.UTF8.GetBytes(xml.InnerXml);
|
|
// return buffer;
|
// }
|
// catch (Exception ex)
|
// {
|
// throw ex;
|
// }
|
//}
|
|
///// <summary>
|
///// 将数据插入到MES xml文件中
|
///// </summary>
|
///// <param name="Pars"></param>
|
///// <param name="strValue"></param>
|
///// <param name="xmlName"></param>
|
///// <returns></returns>
|
//private static byte[] MesEncodeParsToSoap(string strValue, string xmlName)
|
//{
|
// try
|
// {
|
// XmlDocument xml = null;
|
// //从资源文件得到文件流
|
// Stream stream = Assembly.GetExecutingAssembly().GetManifestResourceStream("Utility.XML." + xmlName + ".xml");
|
// xml = new XmlDocument();
|
// xml.Load(stream);
|
|
// XmlNamespaceManager nsmgr = new XmlNamespaceManager(xml.NameTable);
|
// nsmgr.AddNamespace("soapenv", @"http://schemas.xmlsoap.org/soap/envelope/");
|
// nsmgr.AddNamespace("tem", @"http://tempuri.org/");
|
// string subNode = "soapenv:Envelope/soapenv:Body/tem:TransferMessageForMagic/tem:message";
|
// XmlNode node = xml.SelectSingleNode(subNode, nsmgr);
|
// node.InnerText = strValue;
|
|
// byte[] buffer = Encoding.UTF8.GetBytes(xml.InnerXml);
|
// return buffer;
|
// }
|
// catch (Exception ex)
|
// {
|
// throw ex;
|
// }
|
//}
|
|
///// <summary>
|
///// 写到流中，发送给服务端
|
///// </summary>
|
///// <param name="request">HttpWebRequest连接对象</param>
|
///// <param name="data">要写入连接流发给服务端的内容</param>
|
//private static void WriteRequestData(HttpWebRequest request, byte[] data)
|
//{
|
// try
|
// {
|
// request.ContentLength = data.Length;
|
// Stream writer = request.GetRequestStream();
|
// writer.Write(data, 0, data.Length);
|
// writer.Close();
|
// }
|
// catch (Exception ex)
|
// {
|
// throw ex;
|
// }
|
//}
|
|
///// <summary>
|
///// 读取服务端返回的结果
|
///// </summary>
|
//private static XmlDocument ReadXmlResponse(WebResponse response)
|
//{
|
// try
|
// {
|
// StreamReader sr = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
|
// String retXml = sr.ReadToEnd();
|
// sr.Close();
|
// XmlDocument doc = new XmlDocument();
|
// doc.LoadXml(retXml);
|
// return doc;
|
// }
|
// catch (Exception ex)
|
// {
|
// throw ex;
|
// }
|
//}
|
|
#endregion
|
|
|
}
|
}
|
