using HH.WMS.Client.Common;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Net;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace HH.WMS.Client
|
{
|
public class WebApiManager
|
{
|
|
public static string HttpWMS_Post(string apiPath, string data)
|
{
|
string url = GetWMSAddress() + apiPath;
|
return Post(url, data);
|
}
|
|
public static string HttpWMS_Get(string apiPath, string paramStr = "")
|
{
|
string url = GetWMSAddress() + apiPath;
|
return Get(url, paramStr);
|
}
|
|
#region 获得WMS的地址
|
/// <summary>
|
/// 获得webapi的地址 不包括后面的控制器等
|
/// </summary>
|
/// <returns></returns>
|
public static string GetWMSAddress()
|
{
|
//获得配置文件中ERP的IP和端口
|
string autoBomAddress = StaticUtil.ServiceUrl;
|
string url = "http://"+autoBomAddress + "/";
|
return url;
|
}
|
#endregion
|
|
|
private static string Post(string url, string data)
|
{
|
string returnStr = "";
|
try
|
{
|
//对所有代码产生的垃圾资源进行强制回收-慎用
|
//System.GC.Collect();
|
//请求地址获取用户授权信息
|
WebRequest webRequest = System.Net.WebRequest.Create(url);
|
webRequest.Timeout = 1000000;//设置请求超时时间10秒
|
|
HttpWebRequest httpRequest = webRequest as System.Net.HttpWebRequest;
|
httpRequest.Method = "post";
|
httpRequest.ContentType = "application/json";
|
httpRequest.KeepAlive = false;//设置不是常连接
|
|
System.Text.Encoding encoding = System.Text.Encoding.UTF8;
|
byte[] bytesToPost = encoding.GetBytes(data);
|
httpRequest.ContentLength = bytesToPost.Length;
|
System.IO.Stream requestStream = httpRequest.GetRequestStream();
|
requestStream.Write(bytesToPost, 0, bytesToPost.Length);
|
requestStream.Close();
|
|
HttpWebResponse response = (HttpWebResponse)webRequest.GetResponse();
|
Stream stream = response.GetResponseStream();
|
StreamReader Reader = new StreamReader(stream, Encoding.UTF8);
|
returnStr = Reader.ReadToEnd();
|
if (!string.IsNullOrEmpty(returnStr))
|
{
|
returnStr = returnStr.Replace("\\", "");
|
returnStr = returnStr.TrimEnd('\"');
|
returnStr = returnStr.TrimStart('\"');
|
}
|
|
if (webRequest != null)
|
{
|
webRequest.Abort();
|
}
|
if (httpRequest != null)
|
{
|
httpRequest.Abort();
|
}
|
if (response != null)
|
{
|
response.Dispose();
|
response.Close();
|
}
|
if (stream != null)
|
{
|
stream.Dispose();
|
stream.Close();
|
}
|
if (Reader != null)
|
{
|
Reader.Dispose();
|
Reader.Close();
|
}
|
}
|
catch (Exception ex)
|
{
|
returnStr = JsonConvert.SerializeObject(OperateResult.Error(ex.Message));
|
}
|
return returnStr;
|
}
|
|
private static string Get(string url, string paramStr = "")
|
{
|
string Data = url + (paramStr == "" ? "" : "?") + paramStr;
|
|
if (Data.IndexOf("?") > 0)
|
{
|
//包含参数
|
Data += "&tokenId=" +StaticUtil.TokenId;
|
}
|
else
|
{
|
Data += "?tokenId=" + StaticUtil.TokenId;
|
}
|
|
try
|
{
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(Data);
|
request.Method = "GET";
|
request.ContentType = "application/json";
|
request.KeepAlive = false;//设置不是常连接
|
|
HttpWebResponse response = (HttpWebResponse)request.GetResponse();
|
Stream myResponseStream = response.GetResponseStream();
|
StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.GetEncoding("utf-8"));
|
string retString = myStreamReader.ReadToEnd();
|
if (!string.IsNullOrEmpty(retString))
|
{
|
retString = retString.Replace("\\", "");
|
retString = retString.TrimEnd('\"');
|
retString = retString.TrimStart('\"');
|
}
|
|
myStreamReader.Close();
|
|
myResponseStream.Close();
|
if (request != null)
|
{
|
request.Abort();
|
}
|
if (response != null)
|
{
|
response.Dispose();
|
response.Close();
|
}
|
if (myResponseStream != null)
|
{
|
myResponseStream.Dispose();
|
myResponseStream.Close();
|
}
|
if (myStreamReader != null)
|
{
|
myStreamReader.Dispose();
|
myStreamReader.Close();
|
}
|
|
return retString;
|
}
|
catch (Exception ex)
|
{
|
return JsonConvert.SerializeObject(OperateResult.Error(ex.Message));
|
}
|
}
|
}
|
}
|
