using LifePayment.Domain.Models;
|
using LifePayment.Domain.Shared;
|
using Microsoft.Extensions.Configuration;
|
using System;
|
using System.Net;
|
using System.Net.Http;
|
using System.Net.Http.Headers;
|
using System.Text;
|
using System.Text.Json;
|
using System.Threading.Tasks;
|
using Volo.Abp;
|
using Volo.Abp.Domain.Repositories;
|
using ZeroD.Util;
|
using System.Text.Json.Serialization;
|
using System.Text.Json;
|
using Aliyun.OSS.Util;
|
using Aliyun.OSS;
|
using Nest;
|
using System.IO;
|
|
namespace LifePayment.Domain
|
{
|
public class CommonManager : ICommonManager
|
{
|
private readonly IConfiguration _configuration;
|
private readonly IHttpClientFactory _httpClientFactory;
|
|
public CommonManager(
|
IConfiguration configuration,
|
IHttpClientFactory httpClientFactory)
|
{
|
_configuration = configuration;
|
_httpClientFactory = httpClientFactory;
|
}
|
|
public string GetOssUrl(string path, string fileName, byte[] bytes, string ext)
|
{
|
var ossHelper = new OssHelper(_configuration);
|
return ossHelper.GetOssUrl($"{path}{fileName}.{ext}", bytes);
|
}
|
|
public string GetOssUrl(string path, string fileName, string base64Str, string ext)
|
{
|
var ossHelper = new OssHelper(_configuration);
|
return ossHelper.GetOssUrl($"{path}{fileName}.{ext}", Convert.FromBase64String(base64Str.Replace("data:image/png;base64,", string.Empty)));
|
}
|
|
public async Task<TResult> PostAsync<TResult>(string url, dynamic input, int? timeout = null)
|
{
|
TimeSpan defaultTimeout = TimeSpan.FromSeconds(90);
|
var cookieContainer = new CookieContainer();
|
using (var handler = new HttpClientHandler { CookieContainer = cookieContainer })
|
{
|
using (var apiClient = new HttpClient(handler))
|
{
|
apiClient.Timeout = timeout.HasValue ? TimeSpan.FromMilliseconds(timeout.Value) : defaultTimeout;
|
apiClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
|
using (var requestContent = new StringContent(JsonString.Object2Json(input), Encoding.UTF8, "application/json"))
|
{
|
using (var response = await apiClient.PostAsync(url, requestContent))
|
{
|
if (!response.IsSuccessStatusCode)
|
{
|
return default;
|
}
|
|
if (typeof(TResult) == typeof(byte[]))
|
{
|
using (var res = await response.Content.ReadAsStreamAsync())
|
{
|
int counts = (int)res.Length;
|
int offset = 0;
|
byte[] returnByte = new byte[counts];
|
while (counts > 0)
|
{
|
int n = res.Read(returnByte, offset, counts);
|
if (n == 0)
|
{
|
break;
|
}
|
|
counts -= n;
|
offset += n;
|
}
|
|
return (TResult)Convert.ChangeType(returnByte, typeof(TResult));
|
}
|
}
|
|
var ajaxResponse = JsonString.JsonString2Object<TResult>(await response.Content.ReadAsStringAsync());
|
return ajaxResponse;
|
}
|
}
|
}
|
}
|
}
|
|
}
|
}
|
