using Newtonsoft.Json;
|
using Org.BouncyCastle.Ocsp;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Net;
|
using System.Security.Cryptography;
|
using System.Text;
|
using static HH.WCS.DaYang.api.ApiModel;
|
|
namespace HH.WCS.DaYang.util
|
{
|
public class HttpHelper
|
{
|
public string WebPost(string url, string postData, string cotentType = "application/json")
|
{
|
Console.WriteLine(url);
|
WebRequest request = WebRequest.Create(url);
|
request.Method = "POST";
|
//string postData = JsonConvert.SerializeObject(data); ;
|
byte[] byteArray = Encoding.UTF8.GetBytes(postData);
|
request.ContentType = cotentType;
|
request.ContentLength = byteArray.Length;
|
request.Timeout = 3000;
|
|
try
|
{
|
Stream dataStream = request.GetRequestStream();
|
dataStream.Write(byteArray, 0, byteArray.Length);
|
dataStream.Close();
|
WebResponse response = request.GetResponse();
|
//Console.WriteLine(((HttpWebResponse)response).StatusDescription);
|
dataStream = response.GetResponseStream();
|
StreamReader reader = new StreamReader(dataStream, Encoding.UTF8);
|
string responseFromServer = reader.ReadToEnd();
|
reader.Close();
|
dataStream.Close();
|
response.Close();
|
return responseFromServer;
|
}
|
catch (Exception e)
|
{
|
Console.WriteLine(e.Message);
|
return "";
|
}
|
}
|
public string WebPostMobox(string url, string postData, string cotentType = "application/json")
|
{
|
Console.WriteLine(url);
|
WebRequest request = WebRequest.Create(url);
|
request.Method = "POST";
|
//string postData = JsonConvert.SerializeObject(data); ;
|
byte[] byteArray = Encoding.UTF8.GetBytes(postData);
|
|
|
request.ContentType = cotentType;
|
request.ContentLength = byteArray.Length;
|
request.Timeout = 3000;
|
|
|
string appkey = "OpenInfo";
|
|
//获取ReqVerify
|
|
var AppKey = Settings.AppKey;
|
var AppSecret = Settings.AppSecret;
|
//获取时间戳
|
var ReqTime = DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString();
|
//var ReqTime = GetTimeStamp(DateTime.Now.AddHours(-8), 1, 2);
|
LogHelper.Info($"加密前 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime} ");
|
LogHelper.Info($"地址：{url},内容：{postData}");
|
var ReqVerify = GetMd5FromString(AppKey + AppSecret + ReqTime);
|
LogHelper.Info($"加密后 AppKey={AppKey} AppSecret={AppSecret} ReqTime={ReqTime} ReqVerify={ReqVerify} url={url} req={postData}");
|
|
request.Headers.Add("ReqTime", ReqTime.ToString());
|
request.Headers.Add("ReqVerify", ReqVerify);
|
request.Headers.Add("AppKey", appkey);
|
|
|
|
try
|
{
|
Stream dataStream = request.GetRequestStream();
|
dataStream.Write(byteArray, 0, byteArray.Length);
|
dataStream.Close();
|
WebResponse response = request.GetResponse();
|
//Console.WriteLine(((HttpWebResponse)response).StatusDescription);
|
dataStream = response.GetResponseStream();
|
StreamReader reader = new StreamReader(dataStream, Encoding.UTF8);
|
string responseFromServer = reader.ReadToEnd();
|
reader.Close();
|
dataStream.Close();
|
response.Close();
|
return responseFromServer;
|
}
|
catch (Exception e)
|
{
|
Console.WriteLine(e.Message);
|
return "";
|
}
|
}
|
/// <summary>
|
/// MD5加密
|
/// </summary>
|
/// <param name="sInput"></param>
|
/// <returns></returns>
|
public static string GetMd5FromString(string sInput)
|
{
|
var lstData = Encoding.GetEncoding("utf-8").GetBytes(sInput);
|
var lstHash = new MD5CryptoServiceProvider().ComputeHash(lstData);
|
var result = new StringBuilder(32);
|
for (int i = 0; i < lstHash.Length; i++)
|
{
|
result.Append(lstHash[i].ToString("x2").ToUpper());
|
}
|
return result.ToString();
|
}
|
public string WebGet(string url)
|
{
|
//using (var client = new HttpClient()) {
|
// //请求结果
|
// string result = client.GetAsync(url).Result.Content.ReadAsStringAsync().Result;
|
|
// Console.WriteLine(result);
|
// return result;
|
|
//}
|
//Console.WriteLine(url);
|
WebRequest request = WebRequest.Create(url);
|
request.Timeout = 6000;
|
request.Method = "GET";
|
|
try
|
{
|
WebResponse response = request.GetResponse();
|
Stream dataStream = response.GetResponseStream();
|
StreamReader reader = new StreamReader(dataStream);
|
string responseFromServer = reader.ReadToEnd();
|
|
reader.Close();
|
dataStream.Close();
|
response.Close();
|
Console.WriteLine(responseFromServer);
|
return responseFromServer;
|
}
|
catch (Exception e)
|
{
|
return "";
|
}
|
}
|
|
public string Get(string url, string contentType = "application/x-www-form-urlencoded")
|
{
|
WebRequest request = WebRequest.Create(url);
|
request.Method = "Get";
|
request.ContentType = contentType;
|
StreamReader reader = null;
|
Stream stream = null;
|
WebResponse rsp = null;
|
try
|
{
|
|
rsp = request.GetResponse();
|
stream = rsp.GetResponseStream();
|
reader = new StreamReader(stream);
|
return reader.ReadToEnd();
|
}
|
catch
|
{
|
return "";
|
}
|
finally
|
{
|
// 释放资源
|
if (reader != null) reader.Close();
|
if (stream != null) stream.Close();
|
if (rsp != null) rsp.Close();
|
}
|
|
}
|
|
public string Post(string url, string postData, string contentType = "application/json", string sessionId = "")
|
{
|
Console.WriteLine(url);
|
WebRequest request = WebRequest.Create(url);
|
request.Method = "POST";
|
byte[] byteArray = Encoding.UTF8.GetBytes(postData);
|
request.ContentType = contentType;
|
request.ContentLength = byteArray.Length;
|
request.Timeout = 3000;
|
if (sessionId != "")
|
{
|
request.Headers.Set("ASP.NET_SessionId", sessionId);
|
}
|
StreamReader reader = null;
|
Stream stream = null;
|
WebResponse rsp = null;
|
try
|
{
|
stream = request.GetRequestStream();
|
stream.Write(byteArray, 0, byteArray.Length);
|
stream.Close();
|
rsp = request.GetResponse();
|
stream = rsp.GetResponseStream();
|
reader = new StreamReader(stream);
|
return reader.ReadToEnd();
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"{url} err={ex.Message}");
|
return "";
|
}
|
finally
|
{
|
// 释放资源
|
if (reader != null) reader.Close();
|
if (stream != null) stream.Close();
|
if (rsp != null) rsp.Close();
|
}
|
|
}
|
|
|
public string Post(string url, Dictionary<string, string> dic)
|
{
|
var param = dic.Select(a => { return string.Format("{0}={1}", a.Key, a.Value); }).ToList();
|
return Post(url, string.Join("&", param), "application/x-www-form-urlencoded");
|
|
}
|
|
public string PostWithCookie(string url, string sessinId)
|
{
|
return PostWithCookie(url, "", "", sessinId);
|
}
|
public string PostWithCookie(string url, string postData, string contentType = "application/json", string sessionId = "")
|
{
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
|
request.Method = "POST";
|
byte[] byteArray = Encoding.UTF8.GetBytes(postData);
|
request.ContentType = contentType;
|
request.ContentLength = byteArray.Length;
|
if (sessionId != "")
|
{
|
request.CookieContainer = new CookieContainer();
|
request.CookieContainer.SetCookies(new Uri("http://" + request.RequestUri.Authority), "ASP.NET_SessionId=" + sessionId);
|
}
|
StreamReader reader = null;
|
Stream stream = null;
|
WebResponse rsp = null;
|
try
|
{
|
stream = request.GetRequestStream();
|
stream.Write(byteArray, 0, byteArray.Length);
|
stream.Close();
|
rsp = request.GetResponse();
|
stream = rsp.GetResponseStream();
|
reader = new StreamReader(stream);
|
return reader.ReadToEnd();
|
}
|
catch
|
{
|
return "";
|
}
|
finally
|
{
|
// 释放资源
|
if (reader != null) reader.Close();
|
if (stream != null) stream.Close();
|
if (rsp != null) rsp.Close();
|
}
|
|
}
|
|
/// <summary>
|
/// 获取设备状态
|
/// </summary>
|
/// <param name="Locs">货位</param>
|
/// <param name="url">地址</param>
|
public Result<DeviceStatusModel> GetDeviceStatus(string[] Locs, string url)
|
{
|
//返回信息
|
Result<DeviceStatusModel> deviceStatus = new Result<DeviceStatusModel>();
|
try
|
{
|
string date = JsonConvert.SerializeObject(Locs);
|
LogHelper.Info($"获取设备状态：地址:{url}，内容：{date}");
|
var r = WebPost(url, date);
|
LogHelper.Info($"获取设备状态：返回内容：{r}");
|
deviceStatus = JsonConvert.DeserializeObject<Result<DeviceStatusModel>>(r);
|
if (deviceStatus != null && deviceStatus.Code == 200)
|
{
|
LogHelper.Info($"获取设备状态成功");
|
}
|
else
|
{
|
LogHelper.Info($"获取设备状态失败=>msg:{deviceStatus.Msg}");
|
}
|
return deviceStatus;
|
}
|
catch (Exception ex)
|
{
|
|
LogHelper.Info($"获取设备状态错误：error：{ex.Message}，行号:{ex.StackTrace}");
|
return deviceStatus;
|
}
|
|
}
|
|
/// <summary>
|
/// 下发任务
|
/// </summary>
|
/// <param name="task">任务</param>
|
/// <param name="url">地址</param>
|
public Result<Empty> TaskAssignment(WCSTask task, string url)
|
{
|
//返回信息
|
Result<Empty> result = new Result<Empty>();
|
try
|
{
|
TaskPushModel taskPushModel = new TaskPushModel();
|
taskPushModel.From = task.S_START_LOC;
|
taskPushModel.To = task.S_END_LOC;
|
taskPushModel.TaskNo = task.S_CODE;
|
taskPushModel.TaskType = task.S_TYPE;
|
taskPushModel.CntrNo = task.S_CNTR_CODE;
|
|
string date = JsonConvert.SerializeObject(taskPushModel);
|
LogHelper.Info($"下发任务：地址:{url}，内容：{date}");
|
var r = WebPost(url, date);
|
LogHelper.Info($"下发任务：返回内容：{r}");
|
result = JsonConvert.DeserializeObject<Result<Empty>>(r);
|
if (result!=null&&result.Code == 200)
|
{
|
LogHelper.Info($"下发任务成功");
|
}
|
else
|
{
|
LogHelper.Info($"下发任务失败=>msg:{result.Msg}");
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
|
LogHelper.Info($"下发任务=>错误：error：{ex.Message}，行号:{ex.StackTrace}");
|
return result;
|
}
|
|
}
|
|
/// <summary>
|
/// 任务取消
|
/// </summary>
|
/// <param name="task">任务</param>
|
/// <param name="url">地址</param>
|
public Result<Empty> CancelTask(WCSTask task, string url)
|
{
|
//返回信息
|
Result<Empty> result = new Result<Empty>();
|
try
|
{
|
string taskno=task.S_CODE;
|
string date = JsonConvert.SerializeObject(taskno);
|
LogHelper.Info($"任务取消：地址:{url}，内容：{date}");
|
var r = WebPost(url, date);
|
LogHelper.Info($"任务取消：返回内容：{r}");
|
result = JsonConvert.DeserializeObject<Result<Empty>>(r);
|
if (result != null && result.Code == 200)
|
{
|
LogHelper.Info($"任务取消成功");
|
}
|
else
|
{
|
LogHelper.Info($"任务取消失败=>msg:{result.Msg}");
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
|
LogHelper.Info($"任务取消=>错误：error：{ex.Message}，行号:{ex.StackTrace}");
|
return result;
|
}
|
|
}
|
|
/// <summary>
|
/// 设备状态切换
|
/// </summary>
|
/// <param name="task"></param>
|
/// <param name="url"></param>
|
/// <returns></returns>
|
public Result<Empty> ChangeStatus(string type, string url)
|
{
|
//返回信息
|
Result<Empty> result = new Result<Empty>();
|
try
|
{
|
ChangeStatusModel changeStatusModel=new ChangeStatusModel();
|
|
changeStatusModel.Type = type;
|
changeStatusModel.DeviceNo = "2";
|
string date = JsonConvert.SerializeObject(changeStatusModel);
|
LogHelper.Info($"设备状态切换：地址:{url}，内容：{date}");
|
var r = WebPost(url, date);
|
LogHelper.Info($"设备状态切换：返回内容：{r}");
|
result = JsonConvert.DeserializeObject<Result<Empty>>(r);
|
if (result != null && result.Code == 200)
|
{
|
LogHelper.Info($"设备状态切换成功");
|
}
|
else
|
{
|
LogHelper.Info($"设备状态切换失败=>msg:{result.Msg}");
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
|
LogHelper.Info($"设备状态切换=>错误：error：{ex.Message}，行号:{ex.StackTrace}");
|
return result;
|
}
|
|
}
|
|
/// <summary>
|
/// 修改任务优先级
|
/// </summary>
|
/// <param name="task"></param>
|
/// <param name="url"></param>
|
/// <returns></returns>
|
public Result<Empty> ChangePriority(string taskno,int priority, string url)
|
{
|
//返回信息
|
Result<Empty> result = new Result<Empty>();
|
try
|
{
|
ChangePriorityModel model = new ChangePriorityModel();
|
|
model.TaskNo = taskno;
|
model.Priority = priority;
|
string date = JsonConvert.SerializeObject(model);
|
LogHelper.Info($"修改任务优先级：地址:{url}，内容：{date}");
|
var r = WebPost(url, date);
|
LogHelper.Info($"修改任务优先级：返回内容：{r}");
|
result = JsonConvert.DeserializeObject<Result<Empty>>(r);
|
if (result != null && result.Code == 200)
|
{
|
LogHelper.Info($"修改任务优先级成功");
|
}
|
else
|
{
|
LogHelper.Info($"修改任务优先级失败=>msg:{result.Msg}");
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
|
LogHelper.Info($"修改任务优先级=>错误：error：{ex.Message}，行号:{ex.StackTrace}");
|
return result;
|
}
|
|
}
|
}
|
}
|
