手把手教你用C#对接爱发电API：基于Afdian.Sdk的完整开发指南

在独立开发者和小团队的项目中，赞助功能正逐渐成为可持续运营的重要支撑。爱发电作为国内知名的创作者赞助平台，其API的集成能让项目快速获得资金支持。本文将带你从零开始，在.NET生态中使用Afdian.Sdk实现完整的赞助功能集成，涵盖从基础配置到生产级封装的完整流程。

1. 环境准备与基础配置

1.1 创建项目与安装SDK

首先创建一个新的控制台应用或ASP.NET Core项目，通过NuGet包管理器添加Afdian.Sdk依赖：

dotnet add package Afdian.Sdk

或者直接在Visual Studio的NuGet包管理界面搜索"Afdian.Sdk"进行安装。SDK支持.NET Standard 2.0+，这意味着它可以运行在大多数.NET平台上。

1.2 获取API凭证

在爱发电开发者后台获取必要的认证信息：

• UserId ：开发者账户的唯一标识
• Token ：用于API调用的密钥

建议将这些敏感信息存储在安全配置中。对于ASP.NET Core项目，可以使用 appsettings.json 配合Secret Manager：

// appsettings.Development.json
{
  "Afdian": {
    "UserId": "your_user_id",
    "Token": "your_api_token"
  }
}

2. 核心API调用实战

2.1 初始化客户端与服务测试

创建 AfdianClient 实例并进行连通性测试：

using Afdian.Sdk;

var client = new AfdianClient(
    userId: Configuration["Afdian:UserId"],
    token: Configuration["Afdian:Token"]
);

// 测试API连通性
var pingResult = client.Ping();
Console.WriteLine($"API连通性测试结果: {pingResult}");

2.2 订单查询与数据处理

查询赞助订单并处理返回数据：

// 查询第一页订单
var orderResponse = client.QueryOrderModel(page: 1);

// 处理分页数据
if (orderResponse.Success)
{
    Console.WriteLine($"总订单数: {orderResponse.Data.TotalCount}");
    foreach (var order in orderResponse.Data.List)
    {
        Console.WriteLine($"""
            订单ID: {order.OutTradeNo}
            赞助金额: {order.TotalAmount} 元
            赞助时间: {order.CreateTime}
            """);
    }
}

3. 高级封装与最佳实践

3.1 创建可复用服务层

建议将SDK调用封装为服务类，提高代码复用性：

public class AfdianService
{
    private readonly AfdianClient _client;
    
    public AfdianService(string userId, string token)
    {
        _client = new AfdianClient(userId, token);
    }

    public async Task<IEnumerable<Order>> GetRecentOrdersAsync(int days = 7)
    {
        var result = new List<Order>();
        int currentPage = 1;
        
        do {
            var response = await _client.QueryOrderModelAsync(page: currentPage);
            if (!response.Success) break;
            
            result.AddRange(response.Data.List
                .Where(o => o.CreateTime >= DateTime.Now.AddDays(-days)));
                
            currentPage++;
        } while (currentPage <= response.Data.TotalPage);
        
        return result.OrderByDescending(o => o.CreateTime);
    }
}

3.2 异常处理与重试机制

实现健壮的错误处理和自动重试：

public async Task<QueryOrderResponse> QueryOrdersWithRetryAsync(int page, int maxRetries = 3)
{
    int retryCount = 0;
    while (true)
    {
        try
        {
            return await _client.QueryOrderModelAsync(page);
        }
        catch (HttpRequestException ex) when (retryCount < maxRetries)
        {
            retryCount++;
            await Task.Delay(1000 * retryCount);
            continue;
        }
    }
}

4. 生产环境集成方案

4.1 ASP.NET Core依赖注入配置

在Startup.cs中配置服务：

public void ConfigureServices(IServiceCollection services)
{
    services.AddSingleton<AfdianClient>(provider => 
        new AfdianClient(
            Configuration["Afdian:UserId"],
            Configuration["Afdian:Token"]
        ));
    
    services.AddScoped<AfdianService>();
}

4.2 Webhook集成与实时通知

处理爱发电的Webhook通知：

[ApiController]
[Route("api/webhook")]
public class AfdianWebhookController : ControllerBase
{
    [HttpPost]
    public IActionResult HandleWebhook([FromBody] AfdianWebhookPayload payload)
    {
        if (payload.IsValid(Configuration["Afdian:Token"]))
        {
            // 处理赞助通知
            switch (payload.Type)
            {
                case "order.new":
                    // 新订单处理逻辑
                    break;
                case "order.update":
                    // 订单更新处理
                    break;
            }
            return Ok();
        }
        return Unauthorized();
    }
}

5. 性能优化与监控

5.1 响应缓存实现

对不常变动的数据实施缓存：

public class CachedAfdianService
{
    private readonly AfdianService _afdianService;
    private readonly IMemoryCache _cache;
    
    public CachedAfdianService(AfdianService afdianService, IMemoryCache cache)
    {
        _afdianService = afdianService;
        _cache = cache;
    }
    
    public async Task<IEnumerable<Sponsor>> GetSponsorsAsync(bool forceRefresh = false)
    {
        return await _cache.GetOrCreateAsync("afdian_sponsors", async entry =>
        {
            entry.AbsoluteExpirationRelativeToNow = TimeSpan.FromHours(1);
            return await _afdianService.GetSponsorsAsync();
        });
    }
}

5.2 健康检查与监控

添加健康检查端点监控API状态：

public class AfdianHealthCheck : IHealthCheck
{
    private readonly AfdianClient _client;
    
    public AfdianHealthCheck(AfdianClient client)
    {
        _client = client;
    }
    
    public async Task<HealthCheckResult> CheckHealthAsync(
        HealthCheckContext context, 
        CancellationToken cancellationToken = default)
    {
        try
        {
            var result = await _client.PingAsync();
            return result.Contains("pong") 
                ? HealthCheckResult.Healthy() 
                : HealthCheckResult.Degraded();
        }
        catch
        {
            return HealthCheckResult.Unhealthy();
        }
    }
}

在项目中实际使用这些组件时，建议结合日志系统记录关键操作，并考虑为高频访问的数据实现本地缓存策略。根据项目规模，可以进一步将服务拆分为独立的微服务，通过消息队列处理赞助通知事件。