using LifePayment.Domain.Shared;
|
using Microsoft.Extensions.Logging;
|
using Microsoft.Extensions.Options;
|
using Newtonsoft.Json;
|
using System;
|
using System.Linq;
|
using System.Net.Http;
|
using System.Security.Cryptography;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Volo.Abp.Domain.Services;
|
|
namespace LifePayment.Domain
|
{
|
public class ACOOLYClient : DomainService
|
{
|
private const string ACOOLYClientName = "ACOOLYClientName";
|
private readonly ILogger<ACOOLYClient> _logger;
|
private readonly ACOOLYOption options;
|
private readonly JsonSerializerSettings jsonSetting = new JsonSerializerSettings
|
{
|
NullValueHandling = NullValueHandling.Ignore
|
};
|
|
public ACOOLYClient(ILogger<ACOOLYClient> logger, IOptionsMonitor<ACOOLYOption> optionsMonitor)
|
{
|
_logger = logger;
|
options = optionsMonitor.CurrentValue;
|
}
|
|
protected IHttpClientFactory HttpClientFactory => LazyServiceProvider.LazyGetRequiredService<IHttpClientFactory>();
|
|
public async Task<TResult> PostAsync<TInput, TResult>(TInput input)
|
{
|
try
|
{
|
var client = HttpClientFactory.CreateClient(ACOOLYClientName);
|
client.DefaultRequestHeaders.Add("x-api-accesskey", options.Accesskey);
|
client.DefaultRequestHeaders.Add("x-api-signType", "MD5");
|
// ToDo 参数可能存在排序后再加密，需要联调确认
|
var body = JsonConvert.SerializeObject(input, jsonSetting);
|
if (body.Length < 2000)
|
{
|
_logger.LogError("请求ACOOLY接口：" + body);
|
}
|
var data = new StringContent(body, Encoding.UTF8, "application/json");
|
data.Headers.Add("x-api-sign", GetMD5Data(body));
|
var responseMessage = await client.PostAsync(options.ServerHost, data);
|
var str = await responseMessage.Content.ReadAsStringAsync();
|
if (!body.Contains(ACOOLYConstant.Sevice.ElectricSupportArea))
|
{
|
_logger.LogError("ACOOLY接口返回：" + str);
|
}
|
|
var result = JsonConvert.DeserializeObject<TResult>(str);
|
|
return result;
|
}
|
catch (Exception ex)
|
{
|
_logger.LogError("ACOOLY接口错误：" + ex.Message);
|
return default(TResult);
|
}
|
|
}
|
|
public string GetMD5Data(string jsonData) //POST请求接口，使用此方法计算签名
|
{
|
string dataMD5 = "";
|
if (!string.IsNullOrEmpty(jsonData))
|
{
|
var str = jsonData + options.SecrtKey;
|
dataMD5 = CreateMD5Hash(str);
|
}
|
|
return dataMD5;
|
}
|
|
#region 私有方法
|
|
private string CreateMD5Hash(string input)
|
{
|
MD5 md5 = System.Security.Cryptography.MD5.Create();
|
byte[] inputBytes = System.Text.Encoding.UTF8.GetBytes(input);
|
byte[] hashBytes = md5.ComputeHash(inputBytes);
|
StringBuilder sb = new StringBuilder();
|
for (int i = 0; i < hashBytes.Length; i++)
|
{
|
sb.Append(hashBytes[i].ToString("x2"));
|
}
|
|
return sb.ToString();
|
}
|
#endregion
|
}
|
|
}
|
