@Autowired
private AiChat chat;

String result = chat.ask("你好");

String result = chat.system("你是Java专家").ask("如何设计单例模式？");

@GetMapping(value = "/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<String> stream(@RequestParam String q) {
    return chat.stream(q);
}

String result = chat.provider("glm").ask("你好");

@Autowired
private ChatMemory memory;

memory.addMessage("user-123", AiMessage.user("我叫小明"));
List<AiMessage> history = memory.getMessages("user-123");

@Component
public class WeatherTool {

    @AiTool("查询天气")
    public String getWeather(
        @ToolParam(description = "城市名称") String city
    ) {
        return "晴天，25度";
    }
}

@Autowired
private RagPipeline ragPipeline;

List<Document> docs = List.of(
    new Document("公司规定年假为15天"),
    new Document("加班费按每小时100元计算")
);
ragPipeline.ingest(docs);

String answer = ragPipeline.query("年假有多少天？");

Agent agent = new Agent("助手", "你是一个专业的助手", chat)
    .addToolBean(new WeatherTool())
    .addToolBean(new SearchTool());

String result = agent.execute("北京天气如何？");

ChatMemory memory = new InMemoryChatMemory();
AgentLongTermMemory longTermMemory = new AgentLongTermMemory("assistant-1", memory);

// 记住关键信息
longTermMemory.rememberFact("用户姓名：张三");
longTermMemory.rememberFact("用户偏好：Java开发");

Agent agent = new Agent("助手", "你是专业助手", chat)
    .longTermMemory(longTermMemory);

AgentBus bus = new AgentBus();
bus.register("研究员", researcherAgent);
bus.register("写手", writerAgent);
bus.register("审核员", reviewerAgent);

// 链式执行：研究员->写手->审核员
String report = bus.chainExecute(
    List.of("研究员", "写手", "审核员"),
    "研究AI趋势并写报告"
);

// 并行执行
String results = bus.parallelExecute(Map.of(
    "研究员", "研究技术趋势",
    "写手", "写文章摘要"
));

FileSkill fileSkill = new FileSkill("/workspace");

// 读写文件
fileSkill.writeFile("notes.txt", "重要笔记");
String content = fileSkill.readFile("notes.txt");

// 列出目录
String dirList = fileSkill.listDirectory("");

HttpSkill httpSkill = new HttpSkill()
    .setDefaultHeader("Authorization", "Bearer token");

// GET 请求
String response = httpSkill.httpGet("https://api.example.com/data", null);

// POST 请求
String postResult = httpSkill.httpPost(
    "https://api.example.com/submit",
    null,
    "{\"key\": \"value\"}"
);

// 使用 H2 内存数据库示例
DatabaseSkill dbSkill = new DatabaseSkill(
    "jdbc:h2:mem:testdb", "sa", ""
);

// SQL 查询
String results = dbSkill.executeQuery("SELECT * FROM users");

// 获取表列表
String tables = dbSkill.listTables();

// 查看表结构
String schema = dbSkill.describeTable("users");

TimeSkill timeSkill = new TimeSkill();

// 获取当前时间
String now = timeSkill.getCurrentDateTime("Asia/Shanghai");
String date = timeSkill.getCurrentDate();
String time = timeSkill.getCurrentTime();

// 格式化时间戳
String formatted = timeSkill.formatTimestamp(1700000000, "yyyy-MM-dd HH:mm:ss");

MemorySkill memorySkill = new MemorySkill();

// 记住信息
memorySkill.remember("用户名", "张三");
memorySkill.remember("年龄", "25");

// 查询记忆
String name = memorySkill.recall("用户名");

// 查询所有记忆
String allMemories = memorySkill.recall(null);

// 忘记信息
memorySkill.forget("年龄");

// 清空记忆
memorySkill.clearMemory();