玩转 Java Agent ，让 Skills 帮我点瑞幸咖啡

private static final URI MY_COFFEE_SKILL_URI = URI.create(
    "https://unpkg.luckincoffeecdn.com/@luckin/my-coffee-skill@latest/dist/my-coffee-skill.zip"
);
private static final Path SKILLS_DIR =
    Path.of("target", "luckin-skills", "skills").toAbsolutePath().normalize();

private static void installMyCoffeeSkill() throws IOException, InterruptedException {
    Path workDir = SKILLS_DIR.getParent();
    deleteRecursively(workDir);
    Files.createDirectories(SKILLS_DIR);

    Path zipPath = workDir.resolve("my-coffee-skill.zip");
    HttpRequest request = HttpRequest.newBuilder(MY_COFFEE_SKILL_URI)
            .timeout(Duration.ofSeconds(30))
            .GET()
            .build();
    HttpResponse<Path> response = HttpClient.newBuilder()
            .connectTimeout(Duration.ofSeconds(15))
            .followRedirects(HttpClient.Redirect.NORMAL)
            .build()
            .send(request, HttpResponse.BodyHandlers.ofFile(zipPath));

    unzipSecurely(zipPath, SKILLS_DIR);

    Path skillFile = SKILLS_DIR.resolve("my-coffee").resolve("SKILL.md");
}

private Assistant createAssistant() throws IOException, InterruptedException {
    if (!skillInstalled) {
        installMyCoffeeSkill();
        skillInstalled = true;
    }

    // 从文件系统加载 Skills
    List<FileSystemSkill> fileSystemSkills = FileSystemSkillLoader.loadSkills(SKILLS_DIR);

    // 使用 Shell 模式
    ShellSkills skills = ShellSkills.builder()
            .skills(fileSystemSkills)
            .runShellCommandToolConfig(RunShellCommandToolConfig.builder()
                    .workingDirectory(SKILLS_DIR)
                    .maxStdOutChars(60_000)
                    .maxStdErrChars(20_000)
                    .build())
            .build();

    // 用 DeepSeek 模型，兼容 OpenAI 接口格式
    ChatModel chatModel = OpenAiChatModel.builder()
            .baseUrl("https://api.deepseek.com")
            .apiKey("你的 DeepSeek API Key")
            .modelName("deepseek-v4-flash")
            .parallelToolCalls(false)  // Shell 模式必须关闭并行工具调用
            .timeout(Duration.ofMinutes(5))
            .maxRetries(1)
            .build();

    return AiServices.builder(Assistant.class)
            .chatModel(chatModel)
            .chatMemory(MessageWindowChatMemory.withMaxMessages(20))
            .toolProvider(skills.toolProvider())
            .maxToolCallingRoundTrips(20)
            .systemMessage(buildSystemMessage(skills))
            .build();
}

interface Assistant {
    String chat(String userMessage);
}

private static String buildSystemMessage(ShellSkills skills) {
    return """
            你是一个瑞幸咖啡点单助手。
            可用的 Skills：
            %s

            收到与 Skill 相关的请求时，先读取对应的 SKILL.md 再处理。
            点单流程：确认门店 → 确认商品 → 预览订单 → 用户确认后再下单。
            如果 previewOrder 返回非空的 couponCodeList，原样传给 createOrder。
            支付时只展示二维码图片和可点击链接，不展示 payOrderUrl。
            付款前不显示取餐码和取餐时间。
            不暴露 API Key、环境变量、Shell 命令、原始 JSON 等内部信息。
            """.formatted(skills.formatAvailableSkills());
}

@Component
@ConditionalOnProperty(name = "lkcoffee.cli.enabled", havingValue = "true", matchIfMissing = true)
class CoffeeCliRunner implements CommandLineRunner {

    private final ConfigurableApplicationContext context;
    private boolean skillInstalled;

    CoffeeCliRunner(ConfigurableApplicationContext context) {
        this.context = context;
    }

    @Override
    public void run(String... args) throws Exception {
        Assistant assistant = createAssistant();
        System.out.println("瑞幸点单 Agent 已就绪。输入 /exit 退出，/clear 重置对话。");

        try (Scanner scanner = new Scanner(System.in)) {
            while (true) {
                System.out.print("你> ");
                if (!scanner.hasNextLine()) break;

                String input = scanner.nextLine().trim();
                if (input.isEmpty()) continue;
                if ("/exit".equalsIgnoreCase(input)) break;
                if ("/clear".equalsIgnoreCase(input)) {
                    assistant = createAssistant();
                    System.out.println("对话已重置。");
                    continue;
                }

                try {
                    System.out.println("AI> " + assistant.chat(
                        "LUCKIN_MCP_TOKEN: 你的瑞幸 MCP Token\n" + input
                    ));
                } catch (RuntimeException e) {
                    System.err.println("调用失败: " + e.getMessage());
                }
            }
        } finally {
            context.close();
        }
    }
}