120 lines
3.7 KiB
C#
120 lines
3.7 KiB
C#
using System.Diagnostics;
|
||
using System.Net.Http.Headers;
|
||
using System.Text;
|
||
using ApiTool.Dto;
|
||
using Newtonsoft.Json;
|
||
|
||
|
||
namespace ApiTool;
|
||
|
||
public class WebApiPost
|
||
{
|
||
/*
|
||
* 作者：菻蔃
|
||
*
|
||
* 版本时间：2024年5月10日
|
||
*
|
||
*/
|
||
|
||
public WebApiPost() { }
|
||
|
||
private string? _baseUrl = string.Empty;
|
||
|
||
private Action<ApiResponseInfo>? _apiAction;
|
||
|
||
public WebApiPost(Action<ApiResponseInfo> apiAction)
|
||
{
|
||
_apiAction = apiAction;
|
||
}
|
||
|
||
public WebApiPost(string url, Action<ApiResponseInfo> action)
|
||
{
|
||
_baseUrl = url;
|
||
_apiAction = action;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设置响应事件，
|
||
/// </summary>
|
||
/// <param name="action"></param>
|
||
public void SetResponseAction(Action<ApiResponseInfo> action)
|
||
{
|
||
_apiAction = action;
|
||
}
|
||
public void SetBaseUrl(string url)
|
||
{
|
||
_baseUrl = url;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 执行POST请求
|
||
/// </summary>
|
||
/// <typeparam name="TRequest"></typeparam>
|
||
/// <typeparam name="TResponse"></typeparam>
|
||
/// <param name="requestEntity"></param>
|
||
/// <param name="method"></param>
|
||
/// <param name="time"></param>
|
||
/// <returns></returns>
|
||
public ApiResponseInfo<TResponse> HttpPost<TRequest, TResponse>(TRequest requestEntity, string method = "", int time = 10000) where TRequest : class where TResponse : class, new()
|
||
{
|
||
ApiResponseInfo<TResponse> result = new()
|
||
{
|
||
RequestMethod = "POST"
|
||
};
|
||
string address = _baseUrl + method;
|
||
Encoding encoding = Encoding.UTF8;
|
||
Stopwatch sw = new();
|
||
string sendMes = JsonConvert.SerializeObject(requestEntity);
|
||
sw.Start();
|
||
try
|
||
{
|
||
HttpContent content = new StringContent(sendMes, encoding, "application/json");
|
||
HttpClient client = new();
|
||
client.DefaultRequestHeaders.Accept.Clear();
|
||
client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
|
||
client.Timeout = new TimeSpan(0, 0, 0, 0, time);
|
||
result.RequestTime = DateTime.Now;
|
||
var requestTask = client.PostAsync(address, content);
|
||
requestTask.Wait();
|
||
var responseResult = requestTask.Result;
|
||
if (responseResult.IsSuccessStatusCode)
|
||
{
|
||
var responseRead = responseResult.Content.ReadAsStringAsync();
|
||
responseRead.Wait();
|
||
string responseString = responseRead.Result;
|
||
result.IsSend = true;
|
||
result.RequestMsg = sendMes;
|
||
result.RequestUrl = address;
|
||
result.ResponseMsg = responseString;
|
||
result.ResponseEntity = JsonConvert.DeserializeObject<TResponse>(responseString);
|
||
}
|
||
else
|
||
{
|
||
var responseCode = responseResult.StatusCode;
|
||
var responseRead = responseResult.Content.ReadAsStringAsync();
|
||
responseRead.Wait();
|
||
string responseString = responseRead.Result;
|
||
result.IsSend = false;
|
||
result.RequestMsg = sendMes;
|
||
result.RequestUrl = address;
|
||
result.RequestException = new Exception($"[{responseCode}]{responseString}");
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
result.IsSend = false;
|
||
result.RequestMsg = sendMes;
|
||
result.RequestUrl = address;
|
||
result.RequestException = ex;
|
||
}
|
||
result.ResponseTime = DateTime.Now;
|
||
sw.Stop();
|
||
result.ResponseTime = DateTime.Now;
|
||
TimeSpan ts = sw.Elapsed;
|
||
result.UseTime = ts.TotalMilliseconds;
|
||
_apiAction?.Invoke(result);
|
||
return result;
|
||
}
|
||
|
||
|
||
} |