using Newtonsoft.Json;
|
using System;
|
using System.Net.Http;
|
using System.Text;
|
using WIDESEA_Common.Tools;
|
using WIDESEA_Core.Configuration;
|
using WIDESEA_Core.Extensions;
|
using WIDESEA_Entity.DomainModels;
|
|
namespace WIDESEA_WCS.SchedulerExecute
|
{
|
public class SendMESTask
|
{
|
public static async void SendMesTask(dt_agvtask agvtask, int type)
|
{
|
try
|
{
|
string lot = "";
|
if (!string.IsNullOrEmpty(agvtask.agv_materbarcode))
|
{
|
string[] lots = agvtask.agv_materbarcode.Split("*");
|
lot = lots[0];
|
}
|
|
dynamic body = new
|
{
|
CmdID = 10101,
|
TaskNo = agvtask.agv_tasknum,
|
Type = type,
|
EID = "",
|
UploadTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
|
Data = new
|
{
|
DevidGet = agvtask.agv_fromaddress,
|
DevidPut = agvtask.agv_toaddress,
|
LotNo = lot,
|
MaterialType= "1",
|
StartTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
|
EndTime = type > 0 ? DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") : ""
|
}
|
};
|
HttpClient client = new HttpClient();
|
var url = AppSetting.Configuration["MESURL"];
|
var content = new StringContent(JsonConvert.SerializeObject(body), Encoding.UTF8, "application/json");
|
var response = await client.PostAsync(url, content).Result.Content.ReadAsStringAsync();
|
WriteLog.Info("MES接口数据").Write($"调用接口成功，发送数据:{JsonConvert.SerializeObject(body)}返回数据：{response} 时间：{DateTime.Now}", "MES接口数据");
|
//if (response.IsNullOrEmpty())
|
//{
|
// for (int i = 0; i < 2; i++)
|
// {
|
// response = await client.PostAsync(url, content).Result.Content.ReadAsStringAsync();
|
// if (!response.IsNullOrEmpty())
|
// {
|
// var resp = JsonConvert.DeserializeObject<Response>(response);
|
// if ( resp.Data.Status != 1)//resp.Code != 200 ||
|
// {
|
// for (int j = 0; j < 2; j++)
|
// {
|
// response = await client.PostAsync(url, content).Result.Content.ReadAsStringAsync();
|
// resp = JsonConvert.DeserializeObject<Response>(response);
|
|
// if (resp.Code == 200 || resp.Data.Status == 1) break;
|
// }
|
// }
|
// }
|
// }
|
//}
|
//else
|
//{
|
// var resp = JsonConvert.DeserializeObject<Response>(response);
|
// if (resp.Data.Status != 1)//resp.Code != 200 ||
|
// {
|
// for (int i = 0; i < 2; i++)
|
// {
|
// response = await client.PostAsync(url, content).Result.Content.ReadAsStringAsync();
|
// resp = JsonConvert.DeserializeObject<Response>(response);
|
|
// if (resp.Code == 200 && resp.Data.Status == 1) break;
|
// }
|
// }
|
//}
|
|
var result = JsonConvert.DeserializeObject<Data>(response);
|
WriteLog.Info("MES接口数据").Write($"调用接口1：{DateTime.Now}", "MES接口数据");
|
if (result.Status != 1)
|
{
|
WriteLog.Info("MES接口数据").Write($"调用接口失败：重新发送 时间：{DateTime.Now}", "MES接口数据");
|
for (int i = 0; i < 2; i++)
|
{
|
response = await client.PostAsync(url, content).Result.Content.ReadAsStringAsync();
|
result = JsonConvert.DeserializeObject<Data>(response);
|
|
if (result.Status == 1) break;
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
WriteLog.Info("MES接口数据").Write($"调用接口失败，返回数据：{ex.Message} 时间：{DateTime.Now}", "MES接口数据");
|
}
|
|
}
|
}
|
|
public class Data
|
{
|
public int Status { get; set; }
|
public string Msg { get; set; }
|
}
|
|
public class Response
|
{
|
public int Code { get; set; }
|
public string Msg { get; set; }
|
public Data Data { get; set; }
|
}
|
}
|
