using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Net;
|
using System.Text;
|
using WIDESEA_Core.Utilities;
|
using WIDESEA_Core.Utilities.Response;
|
using WIDESEA_Entity.CustomModels.RGVModel;
|
using static WIDESEA_Core.Utilities.Response.WebResponseFromWMS;
|
|
namespace WIDESEA_Core.Utilities
|
{
|
public class HttpHelper<T>
|
{
|
|
public static WebResponseContent GetHttpRequestData(T postData, string address)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
string tmp = JsonConvert.SerializeObject(postData);
|
byte[] param = Encoding.UTF8.GetBytes(tmp);
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(address);
|
request.Method = "POST";
|
request.ContentType = "application/json";
|
request.GetRequestStream().Write(param, 0, param.Length);
|
using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
|
{
|
Stream stream = response.GetResponseStream();
|
StreamReader streamReader = new StreamReader(stream);
|
string webResponse = streamReader.ReadToEnd();
|
content = JsonConvert.DeserializeObject<WebResponseContent>(webResponse);
|
}
|
}
|
catch (Exception ex)
|
{
|
content.Status = false;
|
content.Message = ex.Message;
|
}
|
return content;
|
}
|
|
|
public static WebResponseContent GetHttpRequestDataFromWMS(List<Dictionary<string, object>> postData, string address)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
Dictionary<string, object> dataDic = new Dictionary<string, object>();
|
Dictionary<string, object> headerDic = new Dictionary<string, object>();
|
headerDic.Add("header", postData);
|
dataDic.Add("xmldata",headerDic);
|
string tmp = JsonConvert.SerializeObject(dataDic,new JsonSerializerSettings
|
{
|
DateFormatString = "yyyy-MM-dd HH:MM:ss",
|
});
|
Console.WriteLine($"address = {address},postData = {tmp}");
|
byte[] param = Encoding.UTF8.GetBytes(tmp);
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(address);
|
request.Method = "POST";
|
request.ContentType = "application/json";
|
request.GetRequestStream().Write(param, 0, param.Length);
|
using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
|
{
|
Stream stream = response.GetResponseStream();
|
StreamReader streamReader = new StreamReader(stream);
|
string webResponse = streamReader.ReadToEnd();
|
Console.WriteLine($"webResponse webResponse = {webResponse}");
|
webResponse = webResponse.Replace("return", "ret");
|
WebResponseFromWMS wmsData = JsonConvert.DeserializeObject<WebResponseFromWMS>(webResponse);
|
if (wmsData.Response.ret.retCode == "0000")
|
{
|
content.OK(wmsData.Response.ret.retDesc);
|
}
|
else
|
{
|
content.Error(wmsData.Response.ret.retDesc);
|
}
|
Console.WriteLine($"wmsData result == {JsonConvert.SerializeObject(wmsData)}");
|
}
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
Console.WriteLine($"ex === {ex.Message}");
|
}
|
return content;
|
}
|
|
|
public static WebResponseContent PostHttpRequestDataToAGV(Dictionary<string, object> postData, string address)
|
{
|
WebResponseContent content = new WebResponseContent();
|
|
string paramData = JsonConvert.SerializeObject(postData);
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(address);
|
request.Method = "POST";
|
byte[] bytes = Encoding.UTF8.GetBytes(paramData);
|
request.ContentType = "application/json";
|
request.Headers.Add("token", "123456");
|
request.Headers.Add("name", "mengx");
|
request.ContentLength = bytes.Length;
|
try
|
{
|
Stream myResponseStream = request.GetRequestStream();
|
myResponseStream.Write(bytes, 0, bytes.Length);
|
HttpWebResponse response = (HttpWebResponse)request.GetResponse();
|
StreamReader myStreamReader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
|
string retString = myStreamReader.ReadToEnd();
|
WebResponseFromAGV agvData = JsonConvert.DeserializeObject<WebResponseFromAGV>(retString);
|
content.Data = agvData;
|
|
Console.WriteLine($"agvData result == {JsonConvert.SerializeObject(agvData)}");
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
|
|
public static WebResponseContent GetHttpRequestDataFromAGV(List<string> chains,string address)
|
{
|
WebResponseContent content = new WebResponseContent();
|
|
address = address + "?taskChainIds=" + string.Join(',',chains);
|
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(address);
|
request.Method = "GET";
|
request.ContentType = "application/json";
|
request.Headers.Add("token", "123456");
|
request.Headers.Add("name", "mengx");
|
try
|
{
|
HttpWebResponse response = (HttpWebResponse)request.GetResponse();
|
StreamReader myStreamReader = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
|
string retString = myStreamReader.ReadToEnd();
|
|
//具体返回的数据结果待确认
|
//todo...
|
//WebResponseFromAGV agvData = JsonConvert.DeserializeObject<WebResponseFromAGV>(retString);
|
//content.Data = agvData;
|
|
Console.WriteLine($"retString result == {retString}");
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
|
|
public static WebResponseContent PostHttpRequestDataToRGV(T postData, string address)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
string tmp = JsonConvert.SerializeObject(postData);
|
byte[] param = Encoding.UTF8.GetBytes(tmp);
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(address);
|
request.Method = "POST";
|
request.ContentType = "application/json";
|
request.GetRequestStream().Write(param, 0, param.Length);
|
using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
|
{
|
Stream stream = response.GetResponseStream();
|
StreamReader streamReader = new StreamReader(stream);
|
string webResponse = streamReader.ReadToEnd();
|
|
if (address.Contains("getRgvInfos"))
|
{
|
RgvDeviceStatusModel rgvData = JsonConvert.DeserializeObject<RgvDeviceStatusModel>(webResponse);
|
content.OK();
|
content.Data = rgvData;
|
}
|
else
|
{
|
if (webResponse.Contains("500"))
|
{
|
content.Error(webResponse);
|
}
|
else
|
{
|
RgvReturnModel rgvData = JsonConvert.DeserializeObject<RgvReturnModel>(webResponse);
|
content.OK();
|
content.Data = rgvData;
|
}
|
}
|
|
}
|
}
|
catch (Exception ex)
|
{
|
content.Status = false;
|
content.Message = ex.Message;
|
}
|
return content;
|
}
|
|
|
}
|
}
|
