metadata = new HashMap<>();
-
- metadata.put("projectName", projectRoot.getFileName().toString());
- metadata.put("projectType", projectType.name());
- metadata.put("primaryLanguage", projectType.getPrimaryLanguage());
- metadata.put("packageManager", projectType.getPackageManager());
- metadata.put("analysisTimestamp", System.currentTimeMillis());
-
- // 检查版本控制
- if (Files.exists(projectRoot.resolve(".git"))) {
- metadata.put("versionControl", "Git");
- }
-
- // 检查CI/CD配置
- if (Files.exists(projectRoot.resolve(".github"))) {
- metadata.put("cicd", "GitHub Actions");
- } else if (Files.exists(projectRoot.resolve(".gitlab-ci.yml"))) {
- metadata.put("cicd", "GitLab CI");
- }
-
- // 检查Docker支持
- if (Files.exists(projectRoot.resolve("Dockerfile"))) {
- metadata.put("containerization", "Docker");
- }
-
- return metadata;
- }
-
- /**
- * 生成编辑上下文
- */
- public String buildEditContext(Path projectRoot, String editDescription) {
- logger.debug("Building edit context for: {}", projectRoot);
-
- ProjectContext context = analyzeProject(projectRoot);
-
- StringBuilder contextBuilder = new StringBuilder();
- contextBuilder.append("=== EDIT CONTEXT ===\n");
- contextBuilder.append("Edit Request: ").append(editDescription).append("\n\n");
- contextBuilder.append(context.generateContextSummary());
-
- return contextBuilder.toString();
- }
-
- // 辅助方法
- private boolean shouldSkipDirectory(String dirName) {
- return dirName.equals(".git") || dirName.equals("node_modules") ||
- dirName.equals("target") || dirName.equals("build") ||
- dirName.equals("dist") || dirName.equals("__pycache__") ||
- dirName.startsWith(".");
- }
-
- private String getFileExtension(String fileName) {
- int lastDot = fileName.lastIndexOf('.');
- return lastDot > 0 ? fileName.substring(lastDot) : "";
- }
-
- private boolean isCodeFile(String extension, ProjectType projectType) {
- return extension.equals(".java") || extension.equals(".js") || extension.equals(".ts") ||
- extension.equals(".py") || extension.equals(".html") || extension.equals(".css") ||
- extension.equals(".jsx") || extension.equals(".tsx") || extension.equals(".vue") ||
- extension.equals(".go") || extension.equals(".rs") || extension.equals(".php") ||
- extension.equals(".cs") || extension.equals(".cpp") || extension.equals(".c");
- }
-
- private boolean isCommentLine(String line, String extension) {
- switch (extension) {
- case ".java":
- case ".js":
- case ".ts":
- case ".jsx":
- case ".tsx":
- case ".css":
- return line.startsWith("//") || line.startsWith("/*") || line.startsWith("*");
- case ".py":
- return line.startsWith("#");
- case ".html":
- return line.startsWith("
-
- `;
- return container;
- }
-
- // 添加到页面
- appendToPage() {
- messagesContainer.appendChild(this.container);
- messagesContainer.scrollTop = messagesContainer.scrollHeight;
- }
-
- // 显示连接状态
- showConnectionStatus(status) {
- const statusElement = this.container.querySelector('.connection-status');
- if (statusElement) {
- statusElement.textContent = status;
- statusElement.className = `connection-status ${status === '已连接' ? 'connected' : 'error'}`;
- }
- }
-
- // 添加工具开始执行
- addToolStart(logEvent) {
- // 移除等待状态卡片（如果存在）
- removeWaitingToolCard();
-
- const toolCard = this.createToolCard(logEvent);
- const content = this.container.querySelector('.tool-log-content');
- content.appendChild(toolCard);
-
- this.toolCards.set(logEvent.toolName, toolCard);
- this.scrollToBottom();
- }
-
- // 更新工具执行成功
- updateToolSuccess(logEvent) {
- const toolCard = this.toolCards.get(logEvent.toolName);
- if (toolCard) {
- this.updateToolCard(toolCard, logEvent, 'success');
- }
- }
-
- // 更新工具执行失败
- updateToolError(logEvent) {
- const toolCard = this.toolCards.get(logEvent.toolName);
- if (toolCard) {
- this.updateToolCard(toolCard, logEvent, 'error');
- }
- }
-
- // 创建工具卡片
- createToolCard(logEvent) {
- const card = document.createElement('div');
- card.className = 'tool-card running';
- card.innerHTML = `
-
- 📁 ${this.getFileName(logEvent.filePath)}
- ${logEvent.message}
- 开始时间: ${logEvent.timestamp}
- `;
- return card;
- }
-
- // 更新工具卡片
- updateToolCard(toolCard, logEvent, status) {
- toolCard.className = `tool-card ${status}`;
-
- const statusElement = toolCard.querySelector('.tool-status');
- const messageElement = toolCard.querySelector('.tool-message');
- const timeElement = toolCard.querySelector('.tool-time');
-
- if (status === 'success') {
- statusElement.innerHTML = '✅ 完成';
- statusElement.className = 'tool-status success';
- } else if (status === 'error') {
- statusElement.innerHTML = '❌ 失败';
- statusElement.className = 'tool-status error';
- }
-
- messageElement.textContent = logEvent.message;
-
- if (logEvent.executionTime) {
- timeElement.textContent = `完成时间: ${logEvent.timestamp} (耗时: ${logEvent.executionTime}ms)`;
- }
-
- this.scrollToBottom();
- }
-
- // 显示任务完成
- showTaskComplete() {
- const header = this.container.querySelector('.tool-log-header');
- header.innerHTML = `
- 🎉 任务执行完成
- 已完成
- `;
- }
-
- // 淡出效果
- fadeOut() {
- this.container.style.transition = 'opacity 1s ease-out';
- this.container.style.opacity = '0.5';
-
- setTimeout(() => {
- if (this.container.parentNode) {
- this.container.parentNode.removeChild(this.container);
- }
- }, 10000); // 10秒后移除
- }
-
- // 滚动到底部
- scrollToBottom() {
- messagesContainer.scrollTop = messagesContainer.scrollHeight;
- }
-
- // 获取文件名
- getFileName(filePath) {
- if (!filePath) return '未知文件';
- const parts = filePath.split(/[/\\]/);
- return parts[parts.length - 1] || filePath;
- }
-}
diff --git a/ruoyi-extend/ruoyi-ai-copilot/src/main/resources/templates/index.html b/ruoyi-extend/ruoyi-ai-copilot/src/main/resources/templates/index.html
deleted file mode 100644
index 02d6e9a6..00000000
--- a/ruoyi-extend/ruoyi-ai-copilot/src/main/resources/templates/index.html
+++ /dev/null
@@ -1,116 +0,0 @@
-
-
-
-
-
- Copilot
-
-
-
-
-
-
-
-
-
-
-
-
Assistant
-
- 👋 Hello! I'm your AI file operations assistant. I can help you:
-
- 📁 Read files - View file contents with pagination support
-
✏️ Write files - Create new files or overwrite existing ones
-
🔧 Edit files - Make precise edits with diff preview
-
📋 List directories - Browse directory structure
-
- Try asking me to create a simple project, read a file, or explore the workspace!
-
- Workspace: /workspace
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
💡 Tips
-
- • Ask for step-by-step project creation
- • Request file content before editing
- • Use specific file paths
- • Ask for directory structure first
- • Try continuous operations
-
-
-
-
+ * 处理 enableThinking=true 的场景，使用 Agent 进行深度思考和工具调用
+ *
+ * @author ageerle@163.com
+ * @date 2025/12/13
+ */
+@Slf4j
+@Component
+@Order(3)
+@RequiredArgsConstructor
+public class AgentChatHandler implements ChatHandler {
+
+ private final ToolProviderFactory toolProviderFactory;
+ private final IChatMessageService chatMessageService;
+
+ @Override
+ public boolean supports(ChatContext context) {
+ Boolean enableThinking = context.getChatRequest().getEnableThinking();
+ return enableThinking != null && enableThinking;
+ }
+
+ @Override
+ public SseEmitter handle(ChatContext context) {
+ log.info("处理 Agent 深度思考，用户: {}", context.getUserId());
+
+ Long userId = context.getUserId();
+ String tokenValue = context.getTokenValue();
+ ChatModelVo chatModelVo = context.getChatModelVo();
+
+ try {
+ // 1. 保存用户消息
+ String content = extractUserContent(context);
+ saveChatMessage(context.getChatRequest(), userId, content,
+ RoleType.USER.getName(), chatModelVo);
+
+ // 2. 执行 Agent 任务
+ String result = doAgent(content, chatModelVo);
+
+ // 3. 发送结果并保存
+ SseMessageUtils.sendMessage(userId, result);
+ SseMessageUtils.completeConnection(userId, tokenValue);
+ saveChatMessage(context.getChatRequest(), userId, result,
+ RoleType.ASSISTANT.getName(), chatModelVo);
+
+ } catch (Exception e) {
+ log.error("Agent 执行失败: {}", e.getMessage(), e);
+ SseMessageUtils.sendMessage(userId, "Agent 执行失败：" + e.getMessage());
+ SseMessageUtils.completeConnection(userId, tokenValue);
+ }
+
+ return context.getEmitter();
+ }
+
+ /**
+ * 执行 Agent 任务
+ */
+ private String doAgent(String userMessage, ChatModelVo chatModelVo) {
+ log.info("执行 Agent 任务，消息: {}", userMessage);
+
+ try {
+ // 1. 加载 LLM 模型
+ QwenChatModel qwenChatModel = QwenChatModel.builder()
+ .apiKey(chatModelVo.getApiKey())
+ .modelName(chatModelVo.getModelName())
+ .build();
+
+ // 2. 获取内置工具
+ List