YD_Event.Admin/YD_Event.Core/Infrastructure/WeChat/WeChatService.cs

using System.Net.Http.Json;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Newtonsoft.Json;
using Polly;
using Polly.Retry;
using YD_Event.Core.Options;
using Furion.DependencyInjection;
using System.Net.Http;
using System.Threading.Tasks;
using Furion.FriendlyException;

namespace YD_Event.Core.Infrastructure.WeChat;

public class WeChatService : ITransient
{
    private readonly IHttpClientFactory _httpClientFactory;
    private readonly ILogger<WeChatService> _logger;
    private readonly WeChatOptions _options;

    public WeChatService(IHttpClientFactory httpClientFactory, ILogger<WeChatService> logger, IOptions<WeChatOptions> options)
    {
        _httpClientFactory = httpClientFactory;
        _logger = logger;
        _options = options.Value;
    }

    /// <summary>
    /// code换取session_key
    /// </summary>
    /// <param name="code"></param>
    /// <returns></returns>
    public async Task<WeChatCode2SessionResponse> Code2Session(string code)
    {
        var url = $"https://api.weixin.qq.com/sns/jscode2session?appid={_options.AppId}&secret={_options.Secret}&js_code={code}&grant_type=authorization_code";

        // 定义重试策略：3秒超时，重试2次
        var retryPolicy = Policy
            .Handle<HttpRequestException>()
            .Or<TaskCanceledException>()
            .WaitAndRetryAsync(2, retryAttempt => TimeSpan.FromSeconds(1), (exception, timeSpan, retryCount, context) =>
            {
                _logger.LogWarning($"WeChat API Request Failed. Retry {retryCount}. Error: {exception.Message}");
            });

        var timeoutPolicy = Policy.TimeoutAsync(3); // 3秒超时

        var policyWrap = Policy.WrapAsync(retryPolicy, timeoutPolicy);

        try
        {
            return await policyWrap.ExecuteAsync(async () =>
            {
                var client = _httpClientFactory.CreateClient();
                var response = await client.GetAsync(url);
                response.EnsureSuccessStatusCode();
                var content = await response.Content.ReadAsStringAsync();
                var result = JsonConvert.DeserializeObject<WeChatCode2SessionResponse>(content);
                
                if (result == null || result.ErrCode != 0)
                {
                    _logger.LogError($"WeChat Code2Session Error: {content}");
                    throw Oops.Bah($"微信接口调用失败: {result?.ErrMsg ?? "未知错误"}");
                }
                
                return result;
            });
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "WeChat Code2Session Exception");
            throw Oops.Bah("微信服务暂不可用，请稍后重试");
        }
    }
}

public class WeChatCode2SessionResponse
{
    [JsonProperty("openid")]
    public string OpenId { get; set; }

    [JsonProperty("session_key")]
    public string SessionKey { get; set; }

    [JsonProperty("unionid")]
    public string UnionId { get; set; }

    [JsonProperty("errcode")]
    public int ErrCode { get; set; }

    [JsonProperty("errmsg")]
    public string ErrMsg { get; set; }
}