docs: 更新示例项目

This commit is contained in:
Fu Diwei
2025-06-04 23:53:34 +08:00
parent ac925f87cf
commit 56ed274c40
45 changed files with 800 additions and 492 deletions

View File

@@ -0,0 +1,65 @@
using System;
using System.Diagnostics;
using System.Threading.Tasks;
namespace SKIT.FlurlHttpClient.Wechat.TenpayV3.Sample.Services.BackgroundJobs
{
using SKIT.FlurlHttpClient.Wechat.TenpayV3;
using SKIT.FlurlHttpClient.Wechat.TenpayV3.Models;
using SKIT.FlurlHttpClient.Wechat.TenpayV3.Settings;
internal class TenpayCertificateRefreshingBackgroundJob
{
private readonly HttpClients.IWechatTenpayClientFactory _wechatTenpayClientFactory;
public TenpayCertificateRefreshingBackgroundJob(
HttpClients.IWechatTenpayClientFactory wechatTenpayClientFactory)
{
_wechatTenpayClientFactory = wechatTenpayClientFactory;
}
public async Task ExecuteAsync()
{
// NOTICE:
// 2024-10-01 后微信支付新增了基于微信支付公钥的验证身份方式,
// 如果你已切换至使用平台公钥,则不再需要下载平台证书,可删除此定时任务。
foreach (var tenpayMerchantOptions in Options.TenpayOptions.Instance.Value.Merchants)
{
try
{
const string ALGORITHM_TYPE = "RSA";
using (var client = _wechatTenpayClientFactory.Create(tenpayMerchantOptions.MerchantId))
{
var request = new QueryCertificatesRequest() { AlgorithmType = ALGORITHM_TYPE };
var response = await client.ExecuteQueryCertificatesAsync(request);
if (response.IsSuccessful())
{
// NOTICE:
// 如果构造 Client 时启用了 `AutoDecryptResponseSensitiveProperty` 配置项,则无需再执行下面一行的手动解密方法:
response = client.DecryptResponseSensitiveProperty(response);
foreach (var certificate in response.CertificateList)
{
client.PlatformCertificateManager.AddEntry(CertificateEntry.Parse(ALGORITHM_TYPE, certificate));
}
Debug.WriteLine("刷新微信商户平台证书成功。");
}
else
{
Debug.WriteLine(
"刷新微信商户平台证书失败(状态码:{0},错误代码:{1},错误描述:{2})。",
response.GetRawStatus(), response.ErrorCode, response.ErrorMessage
);
}
}
}
catch (Exception ex)
{
Debug.WriteLine("刷新微信商户平台证书遇到异常。\r\n{0}", ex);
}
}
}
}
}

View File

@@ -0,0 +1,9 @@
namespace SKIT.FlurlHttpClient.Wechat.TenpayV3.Sample.Services.HttpClients
{
using SKIT.FlurlHttpClient.Wechat.TenpayV3.Settings;
public interface IWechatTenpayCertificateManagerFactory
{
ICertificateManager Create(string merchantId);
}
}

View File

@@ -0,0 +1,7 @@
namespace SKIT.FlurlHttpClient.Wechat.TenpayV3.Sample.Services.HttpClients
{
public interface IWechatTenpayClientFactory
{
WechatTenpayClient Create(string merchantId);
}
}

View File

@@ -0,0 +1,9 @@
namespace SKIT.FlurlHttpClient.Wechat.TenpayV3.Sample.Services.HttpClients
{
using SKIT.FlurlHttpClient.Wechat.TenpayV3.Settings;
public interface IWechatTenpayPublicKeyManagerFactory
{
IPublicKeyManager Create(string merchantId);
}
}

View File

@@ -0,0 +1,25 @@
using System.Collections.Concurrent;
namespace SKIT.FlurlHttpClient.Wechat.TenpayV3.Sample.Services.HttpClients.Implements
{
using SKIT.FlurlHttpClient.Wechat.TenpayV3.Settings;
internal partial class WechatTenpayCertificateManagerFactory : IWechatTenpayCertificateManagerFactory
{
private readonly ConcurrentDictionary<string, ICertificateManager> _dict;
public WechatTenpayCertificateManagerFactory()
{
_dict = new ConcurrentDictionary<string, ICertificateManager>();
}
public ICertificateManager Create(string merchantId)
{
// NOTICE:
// 这里的工厂方法是为了演示多租户而存在的,可根据商户号生成不同的证书管理器。
// 如果你的项目只存在唯一一个租户,那么直接注入 `PlatformCertificateManager` 即可。
return _dict.GetOrAdd(merchantId, new InMemoryCertificateManager());
}
}
}

View File

@@ -0,0 +1,50 @@
using System;
using System.Linq;
namespace SKIT.FlurlHttpClient.Wechat.TenpayV3.Sample.Services.HttpClients.Implements
{
using SKIT.FlurlHttpClient.Wechat.TenpayV3.Settings;
internal partial class WechatTenpayClientFactory : IWechatTenpayClientFactory
{
private readonly IWechatTenpayCertificateManagerFactory _tenpayCertificateManagerFactory;
private readonly IWechatTenpayPublicKeyManagerFactory _tenpayPublicKeyManagerFactory;
public WechatTenpayClientFactory(
IWechatTenpayCertificateManagerFactory tenpayCertificateManagerFactory,
IWechatTenpayPublicKeyManagerFactory tenpayPublicKeyManagerFactory)
{
_tenpayCertificateManagerFactory = tenpayCertificateManagerFactory;
_tenpayPublicKeyManagerFactory = tenpayPublicKeyManagerFactory;
}
public WechatTenpayClient Create(string merchantId)
{
// NOTICE:
// 这里的工厂方法是为了演示多租户而存在的,可根据商户号生成不同的 API 客户端。
// 如果你的项目只存在唯一一个租户,那么直接注入 `WechatTenpayClient` 即可。
var tenpayMerchantOptions = Options.TenpayOptions.Instance.Value.Merchants?.FirstOrDefault(e => string.Equals(merchantId, e.MerchantId));
if (tenpayMerchantOptions == null)
throw new Exception("未在配置项中找到该 MerchantId 对应的微信商户号。");
return new WechatTenpayClient(new WechatTenpayClientOptions()
{
MerchantId = tenpayMerchantOptions.MerchantId,
MerchantV3Secret = tenpayMerchantOptions.SecretV3,
MerchantCertificateSerialNumber = tenpayMerchantOptions.CertificateSerialNumber,
MerchantCertificatePrivateKey = tenpayMerchantOptions.CertificatePrivateKey,
AutoEncryptRequestSensitiveProperty = false,
AutoDecryptResponseSensitiveProperty = false,
// 基于平台证书的认证方式还需设置以下参数:
PlatformAuthScheme = PlatformAuthScheme.Certificate,
PlatformCertificateManager = _tenpayCertificateManagerFactory.Create(tenpayMerchantOptions.MerchantId),
// 基于平台公钥的认证方式还需设置以下参数:
//PlatformAuthScheme = PlatformAuthScheme.PublicKey,
//PlatformPublicKeyManager = _tenpayPublicKeyManagerFactory.Create(tenpayMerchantOptions.MerchantId)
});
}
}
}

View File

@@ -0,0 +1,36 @@
using System;
using System.Collections.Concurrent;
using System.Linq;
namespace SKIT.FlurlHttpClient.Wechat.TenpayV3.Sample.Services.HttpClients.Implements
{
using SKIT.FlurlHttpClient.Wechat.TenpayV3.Settings;
internal partial class WechatTenpayPublicKeyManagerFactory : IWechatTenpayPublicKeyManagerFactory
{
private readonly ConcurrentDictionary<string, IPublicKeyManager> _dict;
public WechatTenpayPublicKeyManagerFactory()
{
_dict = new ConcurrentDictionary<string, IPublicKeyManager>();
}
public IPublicKeyManager Create(string merchantId)
{
// NOTICE:
// 这里的工厂方法是为了演示多租户而存在的,可根据商户号生成不同的公钥管理器。
// 如果你的项目只存在唯一一个租户,那么直接注入 `PlatformPublicKeyManager` 即可。
var tenpayMerchantOptions = Options.TenpayOptions.Instance.Value.Merchants?.FirstOrDefault(e => string.Equals(merchantId, e.MerchantId));
if (tenpayMerchantOptions == null)
throw new Exception("未在配置项中找到该 MerchantId 对应的微信商户号。");
return _dict.GetOrAdd(merchantId, (_) =>
{
var manager = new InMemoryPublicKeyManager();
manager.AddEntry(new PublicKeyEntry(PublicKeyEntry.ALGORITHM_TYPE_RSA, tenpayMerchantOptions.PlatformPublicKeyId, tenpayMerchantOptions.PlatformPublicKey));
return manager;
});
}
}
}