using Aop.Api.Domain;
|
using ApiTools.Core.Entities.Common;
|
using Furion;
|
using Furion.DatabaseAccessor;
|
using Furion.DependencyInjection;
|
using Furion.DistributedIDGenerator;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.Extensions.Logging;
|
using Microsoft.Extensions.Options;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using Org.BouncyCastle.Ocsp;
|
using pingan.openbank.api.sdk.client;
|
using pingan.openbank.api.sdk.common.helper;
|
using pingan.openbank.api.sdk.common.http;
|
using pingan.openbank.api.sdk.common.util;
|
using pingan.openbank.api.sdk.entity;
|
using pingan.openbank.api.sdk.exception;
|
using System;
|
using System.Collections.Generic;
|
using System.Diagnostics;
|
using System.IO;
|
using System.Linq;
|
using System.Reflection.Metadata;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace ApiTools.Core
|
{
|
/// <summary>
|
/// 平安支付工具
|
/// </summary>
|
public class PingAnPayUtils(
|
ILogger<PingAnPayUtils> logger,
|
IOptions<PingAnPayOptions> options,
|
IRepository<ThreeResourceLog, LogDbContextLocator> repThreeResourceLog
|
) : ITransient
|
{
|
private readonly ILogger<PingAnPayUtils> logger = logger;
|
private readonly IOptions<PingAnPayOptions> options = options;
|
private readonly IRepository<ThreeResourceLog, LogDbContextLocator> repThreeResourceLog = repThreeResourceLog;
|
|
/// <summary>
|
/// 企业账户余额查询_银企直联此接口适应银行所有币种的活期账户的余额查询，其中的可用余额只包含自身的资金状况，而不包括集团内部的资金池。账面余额，也只是自身账号的账面金额。
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public async Task<CorAcctBalanceQueryResponse> CorAcctBalanceQuery(CorAcctBalanceQueryRequest request)
|
{
|
return await Send<CorAcctBalanceQueryRequest, CorAcctBalanceQueryResponse>(request, "/V1.0/bedl/CorAcctBalanceQuery");
|
}
|
|
/// <summary>
|
/// 历史余额查询_银企直联
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public async Task<HistoryBalanceQueryResponse> HistoryBalanceQuery(HistoryBalanceQueryRequest request)
|
{
|
return await Send<HistoryBalanceQueryRequest, HistoryBalanceQueryResponse>(request, "/V1.0/bedl/HistoryBalanceQuery");
|
}
|
|
/// <summary>
|
/// 查询账户当日历史交易明细_银企直联
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public async Task<InquiryAccountDayHistoryTransactionDetailsResponse> InquiryAccountDayHistoryTransactionDetails(InquiryAccountDayHistoryTransactionDetailsRequest request)
|
{
|
return await Send<InquiryAccountDayHistoryTransactionDetailsRequest, InquiryAccountDayHistoryTransactionDetailsResponse>(request, "/V1.0/bedl/InquiryAccountDayHistoryTransactionDetails");
|
}
|
|
/// <summary>
|
/// 账户止付和解止付_银企直联 对公账户层的止付、解除止付
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public async Task<StopPaymentAndSettlementAccountsResponse> StopPaymentAndSettlementAccounts(StopPaymentAndSettlementAccountsRequest request)
|
{
|
return await Send<StopPaymentAndSettlementAccountsRequest, StopPaymentAndSettlementAccountsResponse>(request, "/V1.0/bedl/StopPaymentAndSettlementAccounts");
|
}
|
|
/// <summary>
|
/// 账户止付详情查询_银企直联 对公账户层的冻结/止付详情查询，每页最大100条。
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public async Task<InquiryAccountStopPaymentDetailsResponse> InquiryAccountStopPaymentDetails(InquiryAccountStopPaymentDetailsRequest request)
|
{
|
return await Send<InquiryAccountStopPaymentDetailsRequest, InquiryAccountStopPaymentDetailsResponse>(request, "/V1.0/bedl/InquiryAccountStopPaymentDetails");
|
}
|
|
/// <summary>
|
/// 单笔监管止付支付申请_银企直联
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public async Task<SingleApplicationSuspensionPaymentResponse> SingleApplicationSuspensionPayment(SingleApplicationSuspensionPaymentRequest request)
|
{
|
return await Send<SingleApplicationSuspensionPaymentRequest, SingleApplicationSuspensionPaymentResponse>(request, "/V1.0/bedl/SingleApplicationSuspensionPayment");
|
}
|
|
/// <summary>
|
/// 单笔转账指令查询_银企直联
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public async Task<CorSingleTransferQueryResponse> CorSingleTransferQuery(CorSingleTransferQueryRequest request)
|
{
|
return await Send<CorSingleTransferQueryRequest, CorSingleTransferQueryResponse>(request, "/V1.0/bedl/CorSingleTransferQuery");
|
}
|
|
/// <summary>
|
/// 当日历史回单数据查询接口_银企直联
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public async Task<SingleDataQueryResponse> SingleDataQuery(SingleDataQueryRequest request)
|
{
|
return await Send<SingleDataQueryRequest, SingleDataQueryResponse>(request, "/V1.0/bedl/SingleDataQuery");
|
}
|
|
/// <summary>
|
/// 当日历史回单数据查询接口_银企直联
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public async Task<SameDayHistoryReceiptDataQueryResponse> SameDayHistoryReceiptDataQuery(SameDayHistoryReceiptDataQueryRequest request)
|
{
|
return await Send<SameDayHistoryReceiptDataQueryRequest, SameDayHistoryReceiptDataQueryResponse>(request, "/V1.0/bedl/SameDayHistoryReceiptDataQuery");
|
}
|
|
/// <summary>
|
/// 单笔或多笔回单PDF合并下载（新）_银企直联
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public async Task<SingleOrBatchReceiptPDFMergeDownloadNewResponse> SingleOrBatchReceiptPDFMergeDownloadNew(SingleOrBatchReceiptPDFMergeDownloadNewRequest request)
|
{
|
return await Send<SingleOrBatchReceiptPDFMergeDownloadNewRequest, SingleOrBatchReceiptPDFMergeDownloadNewResponse>(request, "/V1.0/bedl/SingleOrBatchReceiptPDFMergeDownloadNew");
|
}
|
|
/// <summary>
|
/// 发送请求
|
/// </summary>
|
/// <typeparam name="TRequest"></typeparam>
|
/// <typeparam name="TResponse"></typeparam>
|
/// <param name="request"></param>
|
/// <param name="path"></param>
|
/// <returns></returns>
|
public async Task<TResponse> Send<TRequest, TResponse>(TRequest request, string path)
|
where TRequest : PingAnPayBaseRequest, new()
|
where TResponse : PingAnPayBaseResponse, new()
|
{
|
var logier = JwtUtils.GetCurrentLogier();
|
var sdkRequest = new SdkRequest();
|
sdkRequest.SetInterfaceName(path);
|
if (request.CnsmrSeqNo.IsNull())
|
{
|
request.CnsmrSeqNo = $"{DateTime.Now:yyyyMMddHHmmssfff}{new Random(IDGen.NextID().GetHashCode()).Next(100, 999)}";
|
}
|
request.MrChCode = options.Value.MrChCode;
|
var body = JObject.FromObject(request);
|
sdkRequest.SetBody(body);
|
sdkRequest.SetExtraHeaders(null);
|
//string text = sdkRequest.GetAppId();
|
//if (text.IsNull())
|
//{
|
// string configFilePath = sdkRequest.GetConfigFilePath();
|
// text = ((!configFilePath.IsNull()) ? configFilePath : AbstractApiClient.CheckAppIdOnlyOne());
|
//}
|
var log = new ThreeResourceLog
|
{
|
CreatedTime = DateTimeOffset.Now,
|
Id = IDGen.NextID(),
|
TraceId = App.GetTraceId(),
|
Method = EnumResourceMethod.Post,
|
//Domain = AbstractApiClient.GetOpenBankConfig(text).GetBaseUrl(),
|
Path = path,
|
CreatedUserId = logier?.Id,
|
CreatedChannelId = logier?.ChannelId,
|
Request = request.ToJson(),
|
};
|
await repThreeResourceLog.InsertNowAsync(log);
|
var stopwatch = Stopwatch.StartNew();
|
HttpResult httpResult = GetClient().Invoke<HttpResult>(sdkRequest);
|
var sdkReturn = httpResult.GetData();
|
stopwatch.Stop();
|
|
var result = sdkReturn.JsonTo<TResponse>();
|
|
log.UpdatedTime = DateTimeOffset.Now;
|
log.Response = sdkReturn;
|
log.IsSuccess = result.Code.IsNotNull();
|
log.ElapsedMilliseconds = stopwatch.ElapsedMilliseconds;
|
await repThreeResourceLog.UpdateNowAsync(log);
|
|
return result;
|
}
|
|
public string DownloadFile(string documentId, string fileName)
|
{
|
try
|
{
|
var path = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "UserFiles", "PingAnPay");
|
if (!Directory.Exists(path))
|
{
|
Directory.CreateDirectory(path);
|
}
|
path += Path.DirectorySeparatorChar;
|
|
var fileRequest = new FileRequest();
|
fileRequest.SetFileNo(documentId);
|
fileRequest.SetFilePathName(path);
|
GetClient().FileDownLoad(fileRequest);
|
return $"{path}{documentId}.zip";
|
}
|
catch (OpenBankSdkException ex)
|
{
|
Console.WriteLine(ex);
|
throw;
|
}
|
}
|
|
private ApiClient GetClient()
|
{
|
var path = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "PingAnPayCert", "config.properties");
|
var propertyOper = new PropertyOper(path);
|
var client = ApiClient.GetInstance(propertyOper);
|
return client;
|
}
|
}
|
}
|
