using System.Text;
|
using NewPdaSqlServer.entity;
|
using Newtonsoft.Json;
|
|
namespace NewPdaSqlServer.service.@base;
|
|
public class GetErpParametersServer
|
{
|
// private readonly MesInvItemInCDetailsManager _invItemInCDetailsServer =
|
// new();
|
//
|
// private readonly MesInvItemOutsManager _invItemOutsServer =
|
// new();
|
|
private readonly MessageCenterManager _messageCenterServer = new();
|
|
|
private async Task<string> sendHttp(List<MessageCenter> requestList)
|
{
|
var sortedRequests = requestList.OrderBy(r => r.Seq).ToList();
|
|
using var httpClient = new HttpClient();
|
|
var responses = "";
|
|
foreach (var request in sortedRequests)
|
{
|
var httpRequestMessage = new HttpRequestMessage
|
{
|
Method = new HttpMethod(request.Method),
|
RequestUri = new Uri(request.Url),
|
Content = new StringContent(request.Data, Encoding.UTF8,
|
request.ContentType)
|
};
|
|
var response =
|
await httpClient.SendAsync(httpRequestMessage);
|
var responseData = await response.Content.ReadAsStringAsync();
|
|
var result = JsonConvert.DeserializeObject<Result>(responseData);
|
|
responses += result.msg + "!!!";
|
responses += result.message + "!!!";
|
|
if ("500".Equals(result.state))
|
{
|
responses = "返回报错：" + responses;
|
return responses;
|
}
|
|
if ("1".Equals(result.status))
|
{
|
responses = "返回报错：" + responses;
|
return responses;
|
}
|
|
request.Result = 1;
|
request.ResultData = result.msg;
|
request.Status = 1;
|
request.DealWith = 1;
|
|
_messageCenterServer.ResetUpdate(request);
|
}
|
|
responses = "重推成功：" + responses;
|
return responses;
|
}
|
}
|
|
public class Result
|
{
|
public string? state { get; set; }
|
public string? msg { get; set; }
|
|
public string? status { get; set; }
|
|
public string? message { get; set; }
|
}
|
