using System; using System.Net.Http; using System.Threading; using System.Threading.Tasks; using Flurl; using Flurl.Http; namespace SKIT.FlurlHttpClient.Wechat.TenpayV3 { public static class WechatTenpayClientExecutePayTransactionsExtensions { /// /// 异步调用 [POST] /pay/transactions/app 接口。 /// /// REF:
/// ///
///
/// /// /// /// public static async Task ExecuteCreatePayTransactionAppAsync(this WechatTenpayClient client, Models.CreatePayTransactionAppRequest request, CancellationToken cancellationToken = default) { if (client is null) throw new ArgumentNullException(nameof(client)); if (request is null) throw new ArgumentNullException(nameof(request)); if (request.MerchantId is null) request.MerchantId = client.Credentials.MerchantId; IFlurlRequest flurlReq = client .CreateFlurlRequest(request, HttpMethod.Post, "pay", "transactions", "app"); return await client.SendFlurlRequestAsJsonAsync(flurlReq, data: request, cancellationToken: cancellationToken).ConfigureAwait(false); } /// /// 异步调用 [POST] /pay/transactions/jsapi 接口。 /// /// REF:
///
/// ///
///
/// /// /// /// public static async Task ExecuteCreatePayTransactionJsapiAsync(this WechatTenpayClient client, Models.CreatePayTransactionJsapiRequest request, CancellationToken cancellationToken = default) { if (client is null) throw new ArgumentNullException(nameof(client)); if (request is null) throw new ArgumentNullException(nameof(request)); if (request.MerchantId is null) request.MerchantId = client.Credentials.MerchantId; IFlurlRequest flurlReq = client .CreateFlurlRequest(request, HttpMethod.Post, "pay", "transactions", "jsapi"); return await client.SendFlurlRequestAsJsonAsync(flurlReq, data: request, cancellationToken: cancellationToken).ConfigureAwait(false); } /// /// 异步调用 [POST] /pay/transactions/h5 接口。 /// /// REF:
/// ///
///
/// /// /// /// public static async Task ExecuteCreatePayTransactionH5Async(this WechatTenpayClient client, Models.CreatePayTransactionH5Request request, CancellationToken cancellationToken = default) { if (client is null) throw new ArgumentNullException(nameof(client)); if (request is null) throw new ArgumentNullException(nameof(request)); if (request.MerchantId is null) request.MerchantId = client.Credentials.MerchantId; IFlurlRequest flurlReq = client .CreateFlurlRequest(request, HttpMethod.Post, "pay", "transactions", "h5"); return await client.SendFlurlRequestAsJsonAsync(flurlReq, data: request, cancellationToken: cancellationToken).ConfigureAwait(false); } /// /// 异步调用 [POST] /pay/transactions/native 接口。 /// /// REF:
/// ///
///
/// /// /// /// public static async Task ExecuteCreatePayTransactionNativeAsync(this WechatTenpayClient client, Models.CreatePayTransactionNativeRequest request, CancellationToken cancellationToken = default) { if (client is null) throw new ArgumentNullException(nameof(client)); if (request is null) throw new ArgumentNullException(nameof(request)); if (request.MerchantId is null) request.MerchantId = client.Credentials.MerchantId; IFlurlRequest flurlReq = client .CreateFlurlRequest(request, HttpMethod.Post, "pay", "transactions", "native"); return await client.SendFlurlRequestAsJsonAsync(flurlReq, data: request, cancellationToken: cancellationToken).ConfigureAwait(false); } /// /// 异步调用 [POST] /pay/transactions/codepay 接口。 /// /// REF:
/// ///
///
/// /// /// /// public static async Task ExecuteCreatePayTransactionCodePayAsync(this WechatTenpayClient client, Models.CreatePayTransactionCodePayRequest request, CancellationToken cancellationToken = default) { if (client is null) throw new ArgumentNullException(nameof(client)); if (request is null) throw new ArgumentNullException(nameof(request)); if (request.MerchantId is null) request.MerchantId = client.Credentials.MerchantId; IFlurlRequest flurlReq = client .CreateFlurlRequest(request, HttpMethod.Post, "pay", "transactions", "codepay"); return await client.SendFlurlRequestAsJsonAsync(flurlReq, data: request, cancellationToken: cancellationToken).ConfigureAwait(false); } /// /// 异步调用 [GET] /pay/transactions/out-trade-no/{out_trade_no} 接口。 /// /// REF:
///
///
///
///
/// ///
///
/// /// /// /// public static async Task ExecuteGetPayTransactionByOutTradeNumberAsync(this WechatTenpayClient client, Models.GetPayTransactionByOutTradeNumberRequest request, CancellationToken cancellationToken = default) { if (client is null) throw new ArgumentNullException(nameof(client)); if (request is null) throw new ArgumentNullException(nameof(request)); if (request.MerchantId is null) request.MerchantId = client.Credentials.MerchantId; IFlurlRequest flurlReq = client .CreateFlurlRequest(request, HttpMethod.Get, "pay", "transactions", "out-trade-no", request.OutTradeNumber) .SetQueryParam("mchid", request.MerchantId); return await client.SendFlurlRequestAsJsonAsync(flurlReq, data: request, cancellationToken: cancellationToken).ConfigureAwait(false); } /// /// 异步调用 [GET] /pay/transactions/id/{transaction_id} 接口。 /// /// REF:
///
///
///
///
/// ///
///
/// /// /// /// public static async Task ExecuteGetPayTransactionByIdAsync(this WechatTenpayClient client, Models.GetPayTransactionByIdRequest request, CancellationToken cancellationToken = default) { if (client is null) throw new ArgumentNullException(nameof(client)); if (request is null) throw new ArgumentNullException(nameof(request)); if (request.MerchantId is null) request.MerchantId = client.Credentials.MerchantId; IFlurlRequest flurlReq = client .CreateFlurlRequest(request, HttpMethod.Get, "pay", "transactions", "id", request.TransactionId) .SetQueryParam("mchid", request.MerchantId); return await client.SendFlurlRequestAsJsonAsync(flurlReq, data: request, cancellationToken: cancellationToken).ConfigureAwait(false); } /// /// 异步调用 [POST] /pay/transactions/out-trade-no/{out_trade_no}/close 接口。 /// /// REF:
///
///
///
///
/// ///
///
/// /// /// /// public static async Task ExecuteClosePayTransactionAsync(this WechatTenpayClient client, Models.ClosePayTransactionRequest request, CancellationToken cancellationToken = default) { if (client is null) throw new ArgumentNullException(nameof(client)); if (request is null) throw new ArgumentNullException(nameof(request)); if (request.MerchantId is null) request.MerchantId = client.Credentials.MerchantId; IFlurlRequest flurlReq = client .CreateFlurlRequest(request, HttpMethod.Post, "pay", "transactions", "out-trade-no", request.OutTradeNumber, "close"); return await client.SendFlurlRequestAsJsonAsync(flurlReq, data: request, cancellationToken: cancellationToken).ConfigureAwait(false); } /// /// 异步调用 [POST] /pay/transactions/out-trade-no/{out_trade_no}/reverse 接口。 /// /// REF:
/// ///
///
/// /// /// /// public static async Task ExecuteReversePayTransactionAsync(this WechatTenpayClient client, Models.ReversePayTransactionRequest request, CancellationToken cancellationToken = default) { if (client is null) throw new ArgumentNullException(nameof(client)); if (request is null) throw new ArgumentNullException(nameof(request)); if (request.MerchantId is null) request.MerchantId = client.Credentials.MerchantId; IFlurlRequest flurlReq = client .CreateFlurlRequest(request, HttpMethod.Post, "pay", "transactions", "out-trade-no", request.OutTradeNumber, "reverse"); return await client.SendFlurlRequestAsJsonAsync(flurlReq, data: request, cancellationToken: cancellationToken).ConfigureAwait(false); } #region Exposure /// /// 异步调用 [POST] /pay/transactions/exposure 接口。 /// /// REF:
/// ///
///
/// /// /// /// public static async Task ExecuteCreatePayTransactionExposureAsync(this WechatTenpayClient client, Models.CreatePayTransactionExposureRequest request, CancellationToken cancellationToken = default) { if (client is null) throw new ArgumentNullException(nameof(client)); if (request is null) throw new ArgumentNullException(nameof(request)); if (request.MerchantId is null) request.MerchantId = client.Credentials.MerchantId; IFlurlRequest flurlReq = client .CreateFlurlRequest(request, HttpMethod.Post, "pay", "transactions", "exposure"); return await client.SendFlurlRequestAsJsonAsync(flurlReq, data: request, cancellationToken: cancellationToken).ConfigureAwait(false); } #endregion } }