Microsoft.SemanticKernel.Agents.Core
Microsoft.SemanticKernel.Agents.OpenAI (Preview版(ban)本）
Microsoft.SemanticKernel.Agents.Orchestration (Preview版(ban)本）
Microsoft.SemanticKernel.Agents.Runtime.InProcess (Preview版(ban)本）

<PropertyGroup>
  <NoWarn>$(NoWarn);CA2007;IDE1006;SKEXP0001;SKEXP0110;OPENAI001</NoWarn>
</PropertyGroup>

{
  "LLM": {
    "BASE_URL": "//api.siliconflow.cn",
    "API_KEY": "******************************",
    "MODEL_ID": "Qwen/Qwen2.5-32B-Instruct"
  }
}

Console.WriteLine("Now loading the configuration...");
var config = new ConfigurationBuilder()
    .AddJsonFile($"appsettings.json", optional: false, reloadOnChange: true)
    .Build();
Console.WriteLine("Now loading the chat client...");
var chattingApiConfiguration = new OpenAiConfiguration(
    config.GetSection("LLM:MODEL_ID").Value,
    config.GetSection("LLM:BASE_URL").Value,
    config.GetSection("LLM:API_KEY").Value);
var openAiChattingClient = new HttpClient(new OpenAiHttpHandler(chattingApiConfiguration.EndPoint));
var kernel = Kernel.CreateBuilder()
    .AddOpenAIChatCompletion(chattingApiConfiguration.ModelId, chattingApiConfiguration.ApiKey, httpClient: openAiChattingClient)
    .Build();

var triageAgent = new ChatCompletionAgent()
{
    Name = "TriageAgent",
    Description = "處理客戶請求",
    Instructions = "一個(ge)負責分流客戶問題的客服智能體",
    Kernel = kernel.Clone()
};

var statusAgent = new ChatCompletionAgent()
{
    Name = "OrderStatusAgent",
    Description = "一個負責查詢訂單狀態的客(ke)服智能體",
    Instructions = "處理訂單(dan)狀態請求",
    Kernel = kernel.Clone()
};
statusAgent.Kernel.Plugins.Add(KernelPluginFactory.CreateFromObject(new OrderStatusPlugin()));

var returnAgent = new ChatCompletionAgent()
{
    Name = "OrderReturnAgent",
    Description = "一個負責處理(li)訂單退貨的客服智(zhi)能體",
    Instructions = "處理訂(ding)單(dan)退貨并記錄退貨原因(yin)（用戶需確認原因(yin)：不(bu)想要了 或 7天(tian)無(wu)理由(you)退換 或 沒有時間消(xiao)費）",
    Kernel = kernel.Clone()
};
returnAgent.Kernel.Plugins.Add(KernelPluginFactory.CreateFromObject(new OrderReturnPlugin()));

var refundAgent = new ChatCompletionAgent()
{
    Name = "OrderRefundAgent",
    Description = "一個負(fu)責處理訂(ding)單(dan)退款(kuan)的客服(fu)智能(neng)體",
    Instructions = "處理訂單(dan)退(tui)款請(qing)求并記(ji)錄退(tui)款原因(yin)（用戶(hu)需確認原因(yin)：不想(xiang)要(yao)了 或 7天無理由退(tui)換(huan) 或 沒有(you)時間(jian)消費）",
    Kernel = kernel.Clone()
};
refundAgent.Kernel.Plugins.Add(KernelPluginFactory.CreateFromObject(new OrderRefundPlugin()));

public sealed class OrderRefundPlugin
{
    [KernelFunction]
    public string ProcessReturn(string orderId, string reason) => $"訂單 {orderId} 的退款申請已通(tong)過(guo)！退款理由：{reason}";
}
public sealed class OrderReturnPlugin
{
    [KernelFunction]
    public string ProcessReturn(string orderId, string reason) => $"訂單 {orderId} 的退(tui)(tui)貨(huo)申(shen)請(qing)已通過！退(tui)(tui)貨(huo)理由(you)：{reason} ";
}
public sealed class OrderStatusPlugin
{
    [KernelFunction]
    public string CheckOrderStatus(string orderId) => $"訂(ding)單 {orderId} 已發貨(huo) 并將于 2-3日(ri)內送(song)達(da)！";
}

var handoffs = OrchestrationHandoffs
        .StartWith(triageAgent)
        .Add(source: triageAgent, targets: [statusAgent, returnAgent, refundAgent]) // 分流客服可交接(jie)給(gei)狀態、退貨、退款智能體
        .Add(source: statusAgent, target: triageAgent, "如非訂單狀態相關(guan)問題則(ze)交回分(fen)流客(ke)服")
        .Add(source: returnAgent, target: triageAgent, "如非(fei)退貨相關問題則交(jiao)回分流客服")
        .Add(source: refundAgent, target: triageAgent, "如非退款相關(guan)問題則交回分(fen)流客服(fu)");

public sealed class OrchestrationMonitor
{
    public ChatHistory History { get; } = new ChatHistory();
    public ValueTask ResponseCallback(ChatMessageContent response)
    {
        History.Add(response);
        return ValueTask.CompletedTask;
    }
}

// -- Create the HandoffOrchestration
var orchestration = new HandoffOrchestration(
  handoffs, 
  members: [triageAgent, statusAgent, returnAgent, refundAgent])
{
    Name = "CustomerSupportOrchestration",
    Description = "處理客戶請求并根(gen)據問題類(lei)型交(jiao)接(jie)給對應的智能體",
    InteractiveCallback = () =>
    {
        var lastMessage = monitor.History.LastOrDefault();
        Console.WriteLine($"# Agent: \n{lastMessage?.Content}\n");
        Console.WriteLine($"# User:");
        var userInput = Console.ReadLine();
        Console.WriteLine();
        var message = new ChatMessageContent(AuthorRole.User, userInput);
        monitor.History.Add(message);
        return ValueTask.FromResult(message);
    },
    ResponseCallback = monitor.ResponseCallback
};

// Start the Runtime
var runtime = new InProcessRuntime();
await runtime.StartAsync();

// Start the Chat
Console.WriteLine($"Welcome to use CustomerSupport!\n");
var task = "你好(hao)，我需要訂單上的幫助";
Console.WriteLine($"# User: \n{task}\n");
try
{
    // Invoke the Orchestration
    var result = await orchestration.InvokeAsync(task, runtime);
    // Collect Results from multi Agents
    var output = await result.GetValueAsync(TimeSpan.FromSeconds(100 * 3));
    // Print the Results
    Console.WriteLine($"# 處理結(jie)果總(zong)結(jie): \n{output}\n");
}
catch (HttpOperationException ex)
{
    Console.WriteLine($"Exception: {ex.Message}");
}
finally
{
    await runtime.RunUntilIdleAsync();
    Console.WriteLine($"\n----------See you next time!----------");
    Console.ReadKey();
}