{
  "SenparcWeixinSetting": {
    // 公众号配置
    "Token": "你的Token",
    "EncodingAESKey": "你的EncodingAESKey",
    "AppId": "你的AppId",
    "AppSecret": "你的AppSecret",
    
    // 是否为沙盒模式（开发环境设为 true）
    "IsDebug": true
  }
}

/// <summary>
/// 自定义消息处理器
/// </summary>
public class CustomMessageHandler : MessageHandler
{
    public CustomMessageHandler(
        Stream inputStream, 
        PostModel postModel, 
        int maxRecordCount = -1,
        bool outputApiXml = false,
        IServiceProvider serviceProvider = null) 
        : base(inputStream, postModel, maxRecordCount, outputApiXml, serviceProvider)
    {
    }

    public override async Task<IResponseMessageBase> OnTextRequestAsync(RequestMessageText requestMessage)
    {
        var responseMessage = requestMessage.CreateResponseMessage<ResponseMessageText>();
        
        switch (requestMessage.Content.ToUpper())
        {
            case "你好":
                responseMessage.Content = "您好！很高兴为您服务！";
                break;
            case "帮助":
                responseMessage.Content = "发送\"你好\"打招呼，发送\"帮助\"查看功能";
                break;
            default:
                responseMessage.Content = $"您发送了：{requestMessage.Content}\n\n" +
                    "这是一条自动回复消息。";
                break;
        }
        
        return responseMessage;
    }

    public override async Task<IResponseMessageBase> OnImageRequestAsync(RequestMessageImage requestMessage)
    {
        var responseMessage = requestMessage.CreateResponseMessage<ResponseMessageText>();
        responseMessage.Content = "收到图片！";
        return responseMessage;
    }
}

[Route("api/[controller]")]
[ApiController]
public class WeixinController : Controller
{
    [HttpPost]
    public async Task<IActionResult> Post()
    {
        var messageHandler = new CustomMessageHandler(
            Request.Body, 
            Request.GetPostModel());
        
        await messageHandler.ExecuteAsync();
        return Content(messageHandler.ResponseMessage.ToXml(), "text/xml");
    }
}

{
  "SenparcWeixinSetting": {
    "TenPayV3_AppId": "商户 AppId",
    "TenPayV3_AppSecret": "商户 AppSecret",
    "TenPayV3_MchId": "商户号",
    "TenPayV3_SubMchId": "子商户号（可选）",
    "TenPayV3_Key": "商户API密钥",
    "TenPayV3_CertPath": "证书路径",
    "TenPayV3_CertPassword": "证书密码"
  }
}

// 创建订单
var orderData = new
{
    appid = "AppId",
    mchid = "商户号",
    description = "商品描述",
    out_trade_no = "商户订单号",
    time_expire = DateTimeOffset.UtcNow.AddHours(2).ToUnixTimeSeconds(),
    amount = new { total = 1, currency = "CNY" },
    payer = new { openid = "用户 OpenId" },
    notify_url = "https://yourdomain.com/api/tenpay/notify"
};

var result = await TenPayApiV3.UnifiedOrderAsync(orderData);
var prepayId = result.prepay_id;

public async Task<IActionResult> Notify()
{
    var stream = await Request.Body.ReadToEndAsync();
    var response = await TenPayApiV3Notify.ParseAsync(Request, stream);
    
    if (response.TradeState == TradeState.SUCCESS)
    {
        // 支付成功，处理订单
        var order = await _orderService.GetByTradeNoAsync(response.OutTradeNo);
        if (order != null && order.Status == OrderStatus.Pending)
        {
            order.Status = OrderStatus.Paid;
            order.PaidAt = DateTime.UtcNow;
            await _orderService.UpdateAsync(order);
        }
        
        return Json(new { code = "SUCCESS", message = "成功" });
    }
    
    return Json(new { code = "FAIL", message = "失败" });
}

public class CustomWxOpenMessageHandler : MessageHandler
{
    public CustomWxOpenMessageHandler(
        Stream inputStream, 
        PostModel postModel,
        int maxRecordCount = -1,
        IServiceProvider serviceProvider = null)
        : base(inputStream, postModel, maxRecordCount, false, serviceProvider)
    {
    }

    public override async Task<IResponseMessageBase> OnTextRequestAsync(
        RequestMessageText requestMessage)
    {
        var responseMessage = requestMessage.CreateResponseMessage<ResponseMessageText>();
        responseMessage.Content = $"收到消息：{requestMessage.Content}";
        return responseMessage;
    }
}

public class CustomCache : ICache
{
    private readonly Dictionary<string, CacheEntry> _store = new();
    
    public T Get<T>(string key) where T : class
    {
        if (_store.TryGetValue(key, out var entry) && !entry.IsExpired)
        {
            return entry.Value as T;
        }
        return null;
    }
    
    public void Set(string key, object value, TimeSpan expiry)
    {
        _store[key] = new CacheEntry(value, expiry);
    }
    
    public void Remove(string key)
    {
        _store.Remove(key);
    }
}

builder.Services.AddSenparcWeixinServices(
    builder.Configuration,
    null, // 使用默认缓存
    null, // 使用默认日志
    (register, weixinSetting) => {
#if DEBUG
        register.RegisterMpAccount(weixinSetting, "测试公众号");
#else
        register.RegisterMpAccount(weixinSetting, "正式公众号");
#endif
    });

public override async Task<IResponseMessageBase> OnTextRequestAsync(
    RequestMessageText requestMessage)
{
    try
    {
        // 业务逻辑
        var result = await SomeService.ProcessAsync(requestMessage.Content);
        
        var responseMessage = requestMessage.CreateResponseMessage<ResponseMessageText>();
        responseMessage.Content = result;
        return responseMessage;
    }
    catch (WeixinException ex)
    {
        // 记录日志
        Logger.LogError(ex, "处理消息失败");
        
        // 返回友好提示
        var responseMessage = requestMessage.CreateResponseMessage<ResponseMessageText>();
        responseMessage.Content = "处理失败，请稍后重试。";
        return responseMessage;
    }
}

public override async Task<IResponseMessageBase> OnTextRequestAsync(
    RequestMessageText requestMessage)
{
    // 使用缓存存储用户状态
    var cache = Cache.GetCache();
    var userState = cache.Get<UserState>($"user_{requestMessage.FromUserName}");
    
    if (userState == null)
    {
        userState = new UserState { Step = 1 };
        cache.Set($"user_{requestMessage.FromUserName}", userState, TimeSpan.FromDays(7));
    }
    
    // 处理业务...
}

// 集成 Senparc.AI
dotnet add package Senparc.AI

// 在 MessageHandler 中使用 AI（示例，具体 API 请参考 Senparc.AI 文档）
public override async Task<IResponseMessageBase> OnTextRequestAsync(
    RequestMessageText requestMessage)
{
    // 使用 AI 处理消息
    var aiContext = new Senparc.AI.Context.ConversationContext();
    aiContext.Messages.Add(new Senparc.AI.Messages.UserMessage(requestMessage.Content));
    
    var aiResult = await _chatService.ChatAsync(aiContext);
    var reply = aiResult.Content;
    
    var responseMessage = requestMessage.CreateResponseMessage<ResponseMessageText>();
    responseMessage.Content = reply;
    return responseMessage;
}