gaoxing/UNIVPLMDataIntegration
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

😎优化微信相关（同步开源库）

Browse Source
This commit is contained in:
zuohuaijun 2025-05-12 14:24:32 +08:00
parent 8d01f335dc
commit d7c68bd816
2 changed files with 131 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
Admin.NET/Admin.NET.Core/Service/Wechat/SysWechatService.cs
View File

@ -119,15 +119,8 @@ public class SysWechatService : IDynamicApiController, ITransient
[DisplayName("获取配置签名参数(wx.config)")]
public async Task<dynamic> GenConfigPara(SignatureInput input)
{
var resCgibinToken = await _wechatApiClient.ExecuteCgibinTokenAsync(new CgibinTokenRequest());
var request = new CgibinTicketGetTicketRequest()
{
AccessToken = resCgibinToken.AccessToken
};
var response = await _wechatApiClient.ExecuteCgibinTicketGetTicketAsync(request);
if (!response.IsSuccessful())
throw Oops.Oh(response.ErrorMessage);
return _wechatApiClient.GenerateParametersForJSSDKConfig(response.Ticket, input.Url);
string ticket = await _wechatApiClientFactory.TryGetWechatJsApiTicketAsync();
return _wechatApiClient.GenerateParametersForJSSDKConfig(ticket, input.Url);
}
/// <summary>

134
Admin.NET/Admin.NET.Core/Service/Wechat/WechatApiHttpClient.cs
View File

@ -15,11 +15,13 @@ public partial class WechatApiClientFactory : ISingleton
{
private readonly IHttpClientFactory _httpClientFactory;
public readonly WechatOptions _wechatOptions;
private readonly SysCacheService _sysCacheService;
public WechatApiClientFactory(IHttpClientFactory httpClientFactory, IOptions<WechatOptions> wechatOptions)
public WechatApiClientFactory(IHttpClientFactory httpClientFactory, IOptions<WechatOptions> wechatOptions, SysCacheService sysCacheService)
{
_httpClientFactory = httpClientFactory ?? throw new ArgumentNullException(nameof(httpClientFactory));
_wechatOptions = wechatOptions.Value ?? throw new ArgumentNullException(nameof(wechatOptions));
_sysCacheService = sysCacheService;
}
/// <summary>
@ -45,8 +47,8 @@ public partial class WechatApiClientFactory : ISingleton
{
JsonSerializerSettings jsonSerializerSettings = NewtonsoftJsonSerializer.GetDefaultSerializerSettings();
jsonSerializerSettings.Formatting = Formatting.Indented;
config.JsonSerializer = new NewtonsoftJsonSerializer(jsonSerializerSettings); // 指定 Newtonsoft.Json JSON序列化
// config.JsonSerializer = new SystemTextJsonSerializer(jsonSerializerSettings); // 指定 System.Text.Json JSON序列化
config.JsonSerializer = new NewtonsoftJsonSerializer(jsonSerializerSettings); // 指定 System.Text.Json JSON序列化
// config.JsonSerializer = new SystemTextJsonSerializer(jsonSerializerOptions); // 指定 Newtonsoft.Json JSON序列化
});
return client;
@ -75,10 +77,132 @@ public partial class WechatApiClientFactory : ISingleton
{
JsonSerializerSettings jsonSerializerSettings = NewtonsoftJsonSerializer.GetDefaultSerializerSettings();
jsonSerializerSettings.Formatting = Formatting.Indented;
config.JsonSerializer = new NewtonsoftJsonSerializer(jsonSerializerSettings); // 指定 Newtonsoft.Json JSON序列化
// config.JsonSerializer = new SystemTextJsonSerializer(jsonSerializerSettings); // 指定 System.Text.Json JSON序列化
config.JsonSerializer = new NewtonsoftJsonSerializer(jsonSerializerSettings); // 指定 System.Text.Json JSON序列化
// config.JsonSerializer = new SystemTextJsonSerializer(jsonSerializerOptions); // 指定 Newtonsoft.Json JSON序列化
});
return client;
}
/// <summary>
/// 获取微信公众号AccessToken
/// </summary>
/// <returns></returns>
public async Task<string> TryGetWechatAccessTokenAsync()
{
if (!_sysCacheService.ExistKey($"WxAccessToken_{_wechatOptions.WechatAppId}") || string.IsNullOrEmpty(_sysCacheService.Get<string>($"WxAccessToken_{_wechatOptions.WechatAppId}")))
{
var client = CreateWechatClient();
var reqCgibinToken = new CgibinTokenRequest();
var resCgibinToken = await client.ExecuteCgibinTokenAsync(reqCgibinToken);
if (resCgibinToken.ErrorCode != (int)WechatReturnCodeEnum.请求成功)
throw Oops.Oh(resCgibinToken.ErrorMessage + " " + resCgibinToken.ErrorCode);
_sysCacheService.Set($"WxAccessToken_{_wechatOptions.WechatAppId}", resCgibinToken.AccessToken, TimeSpan.FromSeconds(resCgibinToken.ExpiresIn - 60));
}
return _sysCacheService.Get<string>($"WxAccessToken_{_wechatOptions.WechatAppId}");
}
/// <summary>
/// 获取微信小程序AccessToken
/// </summary>
/// <returns></returns>
public async Task<string> TryGetWxOpenAccessTokenAsync()
{
if (!_sysCacheService.ExistKey($"WxAccessToken_{_wechatOptions.WxOpenAppId}") || string.IsNullOrEmpty(_sysCacheService.Get<string>($"WxAccessToken_{_wechatOptions.WxOpenAppId}")))
{
var client = CreateWxOpenClient();
var reqCgibinToken = new CgibinTokenRequest();
var resCgibinToken = await client.ExecuteCgibinTokenAsync(reqCgibinToken);
if (resCgibinToken.ErrorCode != (int)WechatReturnCodeEnum.请求成功)
throw Oops.Oh(resCgibinToken.ErrorMessage + " " + resCgibinToken.ErrorCode);
_sysCacheService.Set($"WxAccessToken_{_wechatOptions.WxOpenAppId}", resCgibinToken.AccessToken, TimeSpan.FromSeconds(resCgibinToken.ExpiresIn - 60));
}
return _sysCacheService.Get<string>($"WxAccessToken_{_wechatOptions.WxOpenAppId}");
}
/// <summary>
/// 检查微信公众号AccessToken
/// </summary>
/// <returns></returns>
public async Task CheckWechatAccessTokenAsync()
{
if (string.IsNullOrEmpty(_wechatOptions.WechatAppId) || string.IsNullOrEmpty(_wechatOptions.WechatAppSecret)) return;
var req = new CgibinOpenApiQuotaGetRequest
{
AccessToken = await TryGetWxOpenAccessTokenAsync(),
CgiPath = "/cgi-bin/token"
};
var client = CreateWechatClient();
var res = await client.ExecuteCgibinOpenApiQuotaGetAsync(req);
var originColor = Console.ForegroundColor;
if (res.ErrorCode != (int)WechatReturnCodeEnum.请求成功)
{
_sysCacheService.Remove($"WxAccessToken_{_wechatOptions.WechatAppId}");
Console.ForegroundColor = ConsoleColor.Red;
Console.WriteLine("【" + DateTime.Now + "】" + _wechatOptions.WxOpenAppId + " 微信公众号令牌 无效");
}
else
{
Console.ForegroundColor = ConsoleColor.Magenta;
Console.WriteLine("【" + DateTime.Now + "】" + _wechatOptions.WxOpenAppId + " 微信公众号令牌 有效");
}
Console.ForegroundColor = originColor;
}
/// <summary>
/// 检查微信小程序AccessToken
/// </summary>
/// <returns></returns>
public async Task CheckWxOpenAccessTokenAsync()
{
if (string.IsNullOrEmpty(_wechatOptions.WxOpenAppId) || string.IsNullOrEmpty(_wechatOptions.WxOpenAppSecret)) return;
var req = new CgibinOpenApiQuotaGetRequest
{
AccessToken = await TryGetWxOpenAccessTokenAsync(),
CgiPath = "/cgi-bin/token"
};
var client = CreateWxOpenClient();
var res = await client.ExecuteCgibinOpenApiQuotaGetAsync(req);
var originColor = Console.ForegroundColor;
if (res.ErrorCode != (int)WechatReturnCodeEnum.请求成功)
{
_sysCacheService.Remove($"WxAccessToken_{_wechatOptions.WxOpenAppId}");
Console.ForegroundColor = ConsoleColor.Red;
Console.WriteLine("【" + DateTime.Now + "】" + _wechatOptions.WxOpenAppId + " 微信小程序令牌 无效");
}
else
{
Console.ForegroundColor = ConsoleColor.Magenta;
Console.WriteLine("【" + DateTime.Now + "】" + _wechatOptions.WxOpenAppId + " 微信小程序令牌 有效");
}
Console.ForegroundColor = originColor;
}
/// <summary>
/// 获取微信JS接口临时票据jsapi_ticket
/// </summary>
/// <returns></returns>
public async Task<string> TryGetWechatJsApiTicketAsync()
{
if (!_sysCacheService.ExistKey($"WxJsApiTicket_{_wechatOptions.WechatAppId}") || string.IsNullOrEmpty(_sysCacheService.Get<string>($"WxJsApiTicket_{_wechatOptions.WechatAppId}")))
{
var accessToken = await TryGetWechatAccessTokenAsync();
var client = CreateWechatClient();
var request = new CgibinTicketGetTicketRequest()
{
AccessToken = accessToken
};
var response = await client.ExecuteCgibinTicketGetTicketAsync(request);
if (!response.IsSuccessful())
throw Oops.Oh(response.ErrorMessage + " " + response.ErrorCode);
_sysCacheService.Set($"WxJsApiTicket_{_wechatOptions.WechatAppId}", response.Ticket, TimeSpan.FromSeconds(response.ExpiresIn - 60));
}
return _sysCacheService.Get<string>($"WxJsApiTicket_{_wechatOptions.WechatAppId}");
}
}