{
  "DingTalk": {
    "ClientId": "dingxxxxxxxx",
    "ClientSecret": "xxxxxxxx"
  },
  "Ai": {
    "ApiKey": "sk-xxxxxxxx",
    "Endpoint": "https://api.deepseek.com",
    "Model": "deepseek-chat"
  },
  "Yunxiao": {
    "OrganizationId": "xxxxxxxx",
    "PersonalAccessToken": "pt-xxxxxxxx"
  }
}

public abstract class RobotMessageHandlerBase : IDingtalkStreamMessageHandler
{
    public async Task HandleMessage(MessageEventHanderArgs e)
    {
        if (!CanHandle(e)) return;                          // 1. 只处理机器人消息回调
        var message = e.GetRobotMessageData();
        var content = GetTextContent(message);             // 2. 提取消息文本
        var answer = await ProcessAsync(message, content); // 3. 生成回答（子类实现）
        await ReplyAsync(message, answer);                 // 4. sessionWebhook 回复
        await AckAsync(e);                                 // 5. ack 应答，否则服务端会重推
    }
    protected abstract Task<string> ProcessAsync(ReceivedRobotMessage message, string content);
}

protected virtual string GetTextContent(ReceivedRobotMessage message)
    => message.MsgType?.ToLowerInvariant() switch
    {
        "text" => message.GetTextContent().Content ?? "",
        "richText" => string.Concat(message.GetRichTextContent().RichText?.Select(r => r.Text) ?? []),
        _ => "",
    };

public class DingTalkRobotMessageHandler(DingTalkRobotAgent agent)
    : RobotMessageHandlerBase
{
    protected override Task<string> ProcessAsync(ReceivedRobotMessage message, string content)
        => agent.AskAsync(message.ConversationId, content, message.SenderNick);
}

public DingTalkRobotAgent(IChatClient chatClient, YunxiaoClient yunxiao,
    ILogger<DingTalkRobotAgent> logger)
{
    _agent = new ChatClientAgent(
        chatClient,
        instructions: DefaultInstructions,   // 系统提示词：角色 + 参数提取规则 + 追问策略
        name: "dingtalk-robot-agent",
        description: "钉钉群机器人助手……",
        tools: YunxiaoAgentTools.Create(yunxiao));  // 云效工具集
}

services.AddSingleton<IChatClient>(_ =>
    new OpenAIClient(new ApiKeyCredential(ai.ApiKey), new OpenAIClientOptions
    {
        Endpoint = new Uri(ai.Endpoint),
    }).GetChatClient(ai.Model).AsIChatClient());

你是钉钉群里的「云效项目助手」，帮助团队成员把口语化的反馈落地成云效工作项。
处理用户消息的规则：
1. 从消息中提取：项目名、工作项类型（Bug 缺陷 / Req 需求 / Task 任务）、标题、负责人、描述。
2. 信息不全时优先用合理默认值，不要向用户二次确认：
   - 类型未提及 → 默认 Bug；
   - 描述未提及 → 把用户的原话整理成描述；
   - 负责人未提及 → 默认用消息标注的「发起人」（@机器人的用户）。
3. 只有当「项目名」完全无法确定时，才回复用户请他补充是哪个项目；
   用户补充后必须结合上下文继续处理，不要重复追问。
4. 不确定项目名是否真实存在时，先调用 ListProjects 核对（宁可多查一次，不要猜）。
5. 创建成功后，回复一句话结果并附上工作项地址（URL）。

private async Task<AgentSession> GetOrCreateSessionAsync(string conversationId, CancellationToken ct)
{
    if (_sessions.TryGetValue(conversationId, out var session))
    {
        // 未超上限直接复用
        if (!session.TryGetInMemoryChatHistory(out var history) || history.Count <= MaxSessionMessages)
            return session;
        // 超过上限：丢弃最旧的消息，保留最近 N 条（滑动窗口）
        var trimmed = history.Skip(history.Count - MaxSessionMessages).ToList();
        // 截断处可能落在「工具调用 / 工具结果」中间，开头的孤儿 tool 消息会被接口拒绝，
        // 因此向前推进到第一条用户消息
        var firstUser = trimmed.FindIndex(m => m.Role == ChatRole.User);
        session.SetInMemoryChatHistory(firstUser > 0 ? trimmed.Skip(firstUser).ToList() : trimmed);
        return session;
    }
    session = await _agent.CreateSessionAsync(ct);   // 注意：必须无参
    session.SetInMemoryChatHistory([]);              // 应用侧托管聊天历史
    return _sessions[conversationId] = session;
}

public YunxiaoClient(YunxiaoOptions options)
{
    if (!string.IsNullOrEmpty(options.AccessKeyId) && !string.IsNullOrEmpty(options.AccessKeySecret))
        _akClient = new Client(new Config { ... });   // 方案一
    else if (!string.IsNullOrEmpty(options.PersonalAccessToken))
        { }                                            // 方案二：PAT，无签名
    else
        throw new ArgumentException("必须提供 AK（方案一）或 PersonalAccessToken（方案二）");
}

// 方案一：POST /organization/{orgId}/workitems/create
body["space"] = spaceId; body["spaceIdentifier"] = spaceId; body["spaceType"] = "Project";
body["descriptionFormat"] = "MARKDOWN";
// 方案二：POST /oapi/v1/projex/organizations/{orgId}/workitems
body["spaceId"] = spaceId;
body["formatType"] = "MARKDOWN";

public async Task<string> QuickCreateWorkItemAsync(
    YunxiaoWorkItemCategory category, string subject, string projectName,
    string? assignedTo = null, string? description = null, CancellationToken ct = default)
{
    // 1. 按名称找项目 → spaceId
    // 2. 负责人：传用户 ID 或姓名都行，自动解析；不传取项目第一个成员
    // 3. 类型：该大类下的默认类型
    // 4. 必填自定义字段（严重程度等）：统一取字段配置的默认选项
    // 5. 创建并回查，返回工作项地址（可直接点开）
}

public static IList<AITool> Create(YunxiaoClient client)
{
    var functions = new YunxiaoToolFunctions(client);
    return
    [
        AIFunctionFactory.Create(functions.ListProjects),
        AIFunctionFactory.Create(functions.ListProjectMembers),
        AIFunctionFactory.Create(functions.CreateWorkItem),
        AIFunctionFactory.Create(functions.ListWorkItems),
    ];
}
private sealed class YunxiaoToolFunctions(YunxiaoClient client)
{
    [Description("在云效创建工作项（Bug 缺陷 / Req 需求 / Task 任务），成功后返回可直接打开的工作项地址。")]
    public async Task<string> CreateWorkItem(
        [Description("工作项类型：Bug=缺陷、Req=需求、Task=任务")] string category,
        [Description("标题：一句话概括问题或需求")] string subject,
        [Description("项目名称：必须是云效中真实存在的项目名，不确定时先用 ListProjects 查询")] string projectName,
        [Description("负责人姓名，可不传，默认取消息标注的发起人（@机器人的用户）")] string? assignedTo = null,
        [Description("详细描述（Markdown），可不传")] string? description = null)
    {
        if (!TryParseCategory(category, out var parsed))
            return $"创建失败：无法识别的工作项类型「{category}」";
        try
        {
            var url = await client.QuickCreateWorkItemAsync(parsed, subject, projectName, assignedTo, description);
            return $"创建成功，工作项地址：{url}";
        }
        catch (YunxiaoException ex)
        {
            return $"创建失败：{ex.Message}";   // 失败原因转成文本，模型会转告用户
        }
    }
}

var host = Host.CreateDefaultBuilder(args)
    .ConfigureServices((ctx, services) => services
        .AddYunxiao(o =>
        {
            o.OrganizationId = ctx.Configuration["Yunxiao:OrganizationId"]!;
            o.PersonalAccessToken = ctx.Configuration["Yunxiao:PersonalAccessToken"]!;
        })
        .AddDingTalkRobotAgent(ai =>
        {
            ai.ApiKey = ctx.Configuration["Ai:ApiKey"]!;
            ai.Endpoint = ctx.Configuration["Ai:Endpoint"]!;
            ai.Model = ctx.Configuration["Ai:Model"]!;
        })
        .AddDingTalkRobot<DingTalkRobotMessageHandler>(dingTalk =>
        {
            dingTalk.ClientId = ctx.Configuration["DingTalk:ClientId"]!;
            dingTalk.ClientSecret = ctx.Configuration["DingTalk:ClientSecret"]!;
        }))
    .Build();
Console.WriteLine("DingTalk Stream 机器人已启动（云效 AI Agent）");
await host.RunAsync();