From 9fef8f18ea1ff43566005419731ea90488bfbfe3 Mon Sep 17 00:00:00 2001
From: welsir <1824379011@qq.com>
Date: Thu, 21 Aug 2025 00:07:38 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E4=BC=9A=E8=AF=9D=E8=81=94=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 prompto-lab-app/pom.xml                       |   2 +
 .../timemachinelab/config/CorsConfig.java     |   9 +-
 .../controller/UserInteractionController.java | 148 +++-
 .../core/question/QuestionParser.java         |   7 +-
 .../application/ConversationService.java      |  91 +--
 .../application/MessageProcessingService.java |  41 ++
 .../application/SessionManagementService.java | 167 +++++
 .../impl/DefaultMessageProcessingService.java | 100 +++
 .../domain/entity/ConversationSession.java    |  30 +-
 .../ai/QuestionGenerationOperation.java       |  14 +-
 .../web/ConversationController.java           |  55 +-
 .../web/dto/MessageRequest.java               |  12 +-
 .../web/dto/MessageResponse.java              |   9 +
 .../web/dto/UnifiedAnswerRequest.java         | 205 ++++++
 .../controller/AICallLogController.java       |   1 -
 .../sfchain/controller/AIModelController.java |  81 +--
 .../src/main/resources/application.yml        |   2 +-
 .../src/components/Chat/AIChatPage.vue        | 179 ++---
 .../src/services/conversationApi.ts           | 114 +--
 .../src/services/userInteractionApi.ts        | 229 ++++++
 prompto-lab-ui/src/views/ApiConfigView.vue    | 676 ++++++++++--------
 prompto-lab-ui/vite.config.ts                 |   3 +-
 22 files changed, 1568 insertions(+), 607 deletions(-)
 create mode 100644 prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/MessageProcessingService.java
 create mode 100644 prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/SessionManagementService.java
 create mode 100644 prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/impl/DefaultMessageProcessingService.java
 create mode 100644 prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/UnifiedAnswerRequest.java
 create mode 100644 prompto-lab-ui/src/services/userInteractionApi.ts

diff --git a/prompto-lab-app/pom.xml b/prompto-lab-app/pom.xml
index 7581912..6942066 100644
--- a/prompto-lab-app/pom.xml
+++ b/prompto-lab-app/pom.xml
@@ -15,6 +15,8 @@
     <description>提示词工程</description>
     <properties>
         <java.version>17</java.version>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
     </properties>
     <dependencies>
         <dependency>
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/config/CorsConfig.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/config/CorsConfig.java
index 6f93d68..f179e39 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/config/CorsConfig.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/config/CorsConfig.java
@@ -27,8 +27,13 @@ public void addCorsMappings(CorsRegistry registry) {
     public CorsConfigurationSource corsConfigurationSource() {
         CorsConfiguration configuration = new CorsConfiguration();
         
-        // 允许的源
-        configuration.setAllowedOriginPatterns(Arrays.asList("http://localhost:*", "http://127.0.0.1:*"));
+        // 允许的源 - 使用具体的域名模式而不是通配符
+        configuration.setAllowedOriginPatterns(Arrays.asList(
+            "http://localhost:*", 
+            "http://127.0.0.1:*",
+            "https://localhost:*",
+            "https://127.0.0.1:*"
+        ));
         
         // 允许的HTTP方法
         configuration.setAllowedMethods(Arrays.asList("GET", "POST", "PUT", "DELETE", "OPTIONS"));
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/controller/UserInteractionController.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/controller/UserInteractionController.java
index a3b2955..6b9bf46 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/controller/UserInteractionController.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/controller/UserInteractionController.java
@@ -1,14 +1,26 @@
 package io.github.timemachinelab.controller;
 
+import io.github.timemachinelab.core.session.application.ConversationService;
+import io.github.timemachinelab.core.session.application.MessageProcessingService;
+import io.github.timemachinelab.core.session.application.SessionManagementService;
+import io.github.timemachinelab.core.session.domain.entity.ConversationSession;
+import io.github.timemachinelab.core.session.infrastructure.web.dto.UnifiedAnswerRequest;
+import io.github.timemachinelab.core.session.infrastructure.web.dto.MessageResponse;
 import io.github.timemachinelab.entity.req.RetryRequest;
 import io.github.timemachinelab.entity.resp.ApiResult;
 import io.github.timemachinelab.entity.resp.RetryResponse;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
+import javax.annotation.Resource;
 import javax.validation.Valid;
+import java.io.IOException;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * 用户交互控制器
@@ -23,6 +35,52 @@
 @Validated
 public class UserInteractionController {
 
+    @Resource
+    private ConversationService conversationService;
+    @Resource
+    private MessageProcessingService messageProcessingService;
+    @Resource
+    private SessionManagementService sessionManagementService;
+    private final Map<String, SseEmitter> sseEmitters = new ConcurrentHashMap<>();
+    
+    /**
+     * 建立SSE连接
+     */
+    @GetMapping(value = "/sse/{sessionId}", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    public SseEmitter streamConversation(@PathVariable String sessionId) {
+        log.info("建立SSE连接 - 会话ID: {}", sessionId);
+        
+        SseEmitter emitter = new SseEmitter(Long.MAX_VALUE);
+        sseEmitters.put(sessionId, emitter);
+        
+        // 连接建立时发送欢迎消息
+        try {
+            emitter.send(SseEmitter.event()
+                .name("connected")
+                .data("SSE连接已建立，会话ID: " + sessionId));
+        } catch (IOException e) {
+            log.error("发送欢迎消息失败: {}", e.getMessage());
+        }
+        
+        // 设置连接事件处理
+        emitter.onCompletion(() -> {
+            log.info("SSE连接完成: {}", sessionId);
+            sseEmitters.remove(sessionId);
+        });
+        
+        emitter.onTimeout(() -> {
+            log.info("SSE连接超时: {}", sessionId);
+            sseEmitters.remove(sessionId);
+        });
+        
+        emitter.onError((ex) -> {
+            log.error("SSE连接错误: {} - {}", sessionId, ex.getMessage());
+            sseEmitters.remove(sessionId);
+        });
+        
+        return emitter;
+    }
+
     /**
      * 重试接口
      * 
@@ -34,7 +92,9 @@ public ResponseEntity<ApiResult<RetryResponse>> retry(@Valid @RequestBody RetryR
         try {
             log.info("收到重试请求 - nodeId: {}, sessionId: {}, whyretry: {}", 
                     request.getNodeId(), request.getSessionId(), request.getWhyretry());
-            
+
+
+
             // 构建响应数据
             RetryResponse response = RetryResponse.builder()
                     .nodeId(request.getNodeId())
@@ -53,4 +113,90 @@ public ResponseEntity<ApiResult<RetryResponse>> retry(@Valid @RequestBody RetryR
             return ResponseEntity.badRequest().body(ApiResult.serverError("重试请求处理失败: " + e.getMessage()));
         }
     }
+
+    /**
+     * 处理统一答案请求
+     * 支持单选、多选、输入框、表单等多种问题类型的回答
+     */
+    @PostMapping("/message")
+    public ResponseEntity<String> processAnswer(@Validated @RequestBody UnifiedAnswerRequest request) {
+        try {
+            log.info("接收到答案请求 - 会话ID: {}, 节点ID: {}, 问题类型: {}",
+                    request.getSessionId(),
+                    request.getNodeId(),
+                    request.getQuestionType());
+
+            // 1. 会话管理和验证
+            String userId = request.getUserId();
+
+            ConversationSession session = sessionManagementService.getOrCreateSession(userId, request.getSessionId());
+
+            // 2. 验证nodeId是否属于该会话
+            if (request.getNodeId() != null && !sessionManagementService.validateNodeId(session.getSessionId(), request.getNodeId())) {
+                log.warn("无效的节点ID - 会话: {}, 节点: {}", session.getSessionId(), request.getNodeId());
+                return ResponseEntity.badRequest().body("无效的节点ID");
+            }
+
+            // 3. 验证答案格式
+            if (!messageProcessingService.validateAnswer(request)) {
+                log.warn("答案格式验证失败: {}", request);
+                return ResponseEntity.badRequest().body("答案格式不正确");
+            }
+
+            // 4. 处理答案并转换为消息
+            String processedMessage = messageProcessingService.preprocessMessage(
+                    null, // 没有额外的原始消息
+                    request,
+                    session
+            );
+
+            // 5. 发送处理后的消息给AI服务
+            conversationService.processUserMessage(
+                    session.getUserId(),
+                    processedMessage,
+                    response -> sendSseMessage(session.getSessionId(), response)
+            );
+
+            return ResponseEntity.ok("答案处理成功");
+
+        } catch (Exception e) {
+            log.error("处理答案失败 - 会话ID: {}, 错误: {}", request.getSessionId(), e.getMessage(), e);
+            return ResponseEntity.internalServerError().body("答案处理失败: " + e.getMessage());
+        }
+    }
+    
+    /**
+     * 通过SSE发送消息给客户端
+     * 
+     * @param sessionId 会话ID
+     * @param response 消息响应对象
+     */
+    private void sendSseMessage(String sessionId, MessageResponse response) {
+        SseEmitter emitter = sseEmitters.get(sessionId);
+        if (emitter != null) {
+            try {
+                emitter.send(SseEmitter.event()
+                    .name("message")
+                    .data(response));
+                log.debug("SSE消息发送成功 - 会话: {}, 消息类型: {}", sessionId, response.getType());
+            } catch (IOException e) {
+                log.error("SSE消息发送失败 - 会话: {}, 错误: {}", sessionId, e.getMessage());
+                sseEmitters.remove(sessionId);
+            }
+        } else {
+            log.warn("SSE连接不存在 - 会话: {}", sessionId);
+        }
+    }
+    
+    /**
+     * 获取SSE连接状态
+     */
+    @GetMapping("/sse-status")
+    public ResponseEntity<Map<String, Object>> getSseStatus() {
+        Map<String, Object> status = new ConcurrentHashMap<>();
+        status.put("connectedSessions", sseEmitters.keySet());
+        status.put("totalConnections", sseEmitters.size());
+        status.put("timestamp", System.currentTimeMillis());
+        return ResponseEntity.ok(status);
+    }
 }
\ No newline at end of file
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/question/QuestionParser.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/question/QuestionParser.java
index 3afca5c..16b7d06 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/question/QuestionParser.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/question/QuestionParser.java
@@ -3,6 +3,7 @@
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONException;
 import com.alibaba.fastjson2.JSONObject;
+import io.github.timemachinelab.core.session.infrastructure.ai.QuestionGenerationOperation;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.Arrays;
@@ -37,7 +38,7 @@ public class QuestionParser {
      * @return BaseQuestion对象
      * @throws QuestionParseException 解析失败时抛出异常
      */
-    public static BaseQuestion parseQuestion(String jsonStr) throws QuestionParseException {
+    public static QuestionGenerationOperation.QuestionGenerationResponse parseQuestion(String jsonStr) throws QuestionParseException {
         if (jsonStr == null || jsonStr.trim().isEmpty()) {
             throw new QuestionParseException("JSON字符串不能为空", jsonStr, "输入为空或null");
         }
@@ -52,7 +53,7 @@ public static BaseQuestion parseQuestion(String jsonStr) throws QuestionParseExc
         
         // 收集所有解析失败的原因
         List<String> failureReasons = new ArrayList<>();
-        
+        String parentId = jsonObject.getString("parentId");
         // 依次尝试解析成不同类型
         for (Class<? extends BaseQuestion> questionType : QUESTION_TYPES) {
             try {
@@ -61,7 +62,7 @@ public static BaseQuestion parseQuestion(String jsonStr) throws QuestionParseExc
                     String validationResult = validateQuestion(question, jsonObject);
                     if (validationResult == null) {
                         log.info("成功解析为: {}", questionType.getSimpleName());
-                        return question;
+                        return new QuestionGenerationOperation.QuestionGenerationResponse(question,parentId);
                     } else {
                         failureReasons.add(questionType.getSimpleName() + ": " + validationResult);
                     }
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/ConversationService.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/ConversationService.java
index 95959b7..80fcd9b 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/ConversationService.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/ConversationService.java
@@ -1,6 +1,13 @@
 package io.github.timemachinelab.core.session.application;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import io.github.timemachinelab.core.qatree.QaTree;
+import io.github.timemachinelab.core.qatree.QaTreeDomain;
+import io.github.timemachinelab.core.qatree.QaTreeNode;
+import io.github.timemachinelab.core.question.BaseQuestion;
 import io.github.timemachinelab.core.session.domain.entity.ConversationSession;
+import io.github.timemachinelab.core.session.infrastructure.ai.QuestionGenerationOperation;
 import io.github.timemachinelab.core.session.infrastructure.web.dto.MessageResponse;
 import io.github.timemachinelab.core.session.infrastructure.ai.ConversationOperation;
 import io.github.timemachinelab.sfchain.core.AIService;
@@ -8,6 +15,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.Map;
 import java.util.List;
@@ -18,94 +26,43 @@
 @RequiredArgsConstructor
 @Slf4j
 public class ConversationService {
-    
+
+    @Resource
     private final AIService aiService;
+    @Resource
+    private SessionManagementService sessionManagementService;
+    private final QaTreeDomain qaTreeDomain;
 
-    private final Map<String, ConversationSession> sessions = new ConcurrentHashMap<>();
     
-    public ConversationSession createSession(String userId) {
-        ConversationSession session = new ConversationSession(userId);
-        sessions.put(session.getSessionId(), session);
-        return session;
-    }
-    
-    public ConversationSession getSession(String sessionId) {
-        return sessions.get(sessionId);
-    }
-    
-    public void processUserMessage(String sessionId, String userMessage, Consumer<MessageResponse> sseCallback) {
-        ConversationSession session = sessions.get(sessionId);
+    public void processUserMessage(String userId, String userMessage, Consumer<MessageResponse> sseCallback) {
+        ConversationSession session = sessionManagementService.getUserCurrentSession(userId);
         if (session == null) {
-            log.warn("会话不存在: {}", sessionId);
+            log.warn("会话不存在");
             return;
         }
-        
-        // 1. 添加用户消息到会话历史
-        session.addMessage(userMessage, "user");
-        
-        // 2. 发送用户消息确认
-        sseCallback.accept(MessageResponse.userAnswer("user_" + System.currentTimeMillis(), userMessage));
-        
-        // 3. 调用AI服务获取回复
-        processAIResponse(session, userMessage, sseCallback);
+
+        processAIResponse(userMessage, sseCallback);
     }
     
-    private void processAIResponse(ConversationSession session, String userMessage, Consumer<MessageResponse> sseCallback) {
+    private void processAIResponse(String userMessage, Consumer<MessageResponse> sseCallback) {
         try {
-            // 构建对话历史
-            List<ConversationOperation.ConversationHistory> history = buildConversationHistory(session);
-            
+
+            JSONObject object = JSON.parseObject(userMessage);
+
             // 创建AI请求
-            ConversationOperation.ConversationRequest request = new ConversationOperation.ConversationRequest(
-                session.getSessionId(),
-                "current",
-                userMessage
-            );
-            request.setConversationHistory(history);
-            
+            QuestionGenerationOperation.QuestionGenerationRequest request = new QuestionGenerationOperation.QuestionGenerationRequest(object.getString("prompt"),object.getString("tree"),object.getString("input"));
             // 调用AI服务
-            ConversationOperation.ConversationResponse aiResponse = aiService.execute("CONVERSATION_OP", request);
+            QuestionGenerationOperation.QuestionGenerationResponse aiResponse = aiService.execute("QUESTION_GENERATION_OP", request);
             log.info("AI服务调用成功: {}", aiResponse);
-
-            // 添加AI回复到会话历史
-            session.addMessage(aiResponse.getAnswer(), "assistant");
-            
-            // 根据响应类型处理AI回复
-            String nodeId = "ai_" + System.currentTimeMillis();
-            sseCallback.accept(MessageResponse.aiAnswer("ai_" + System.currentTimeMillis(), aiResponse.getAnswer()));
-//            if (aiResponse.getResponseType() == ConversationOperation.ResponseType.SELECTION) {
-//                // 选择题类型
-//                sseCallback.accept(MessageResponse.aiSelectionQuestion(nodeId, aiResponse.getAnswer(), aiResponse.getOptions()));
-//            } else {
-//                // 普通文本回复
-//                sseCallback.accept(MessageResponse.aiQuestion(nodeId, aiResponse.getAnswer()));
-//            }
             
         } catch (Exception e) {
             log.error("AI服务调用失败: {}", e.getMessage(), e);
             // 降级处理
             String fallbackResponse = "抱歉，我暂时无法处理您的请求，请稍后再试。";
-            session.addMessage(fallbackResponse, "assistant");
             String nodeId = "ai_" + System.currentTimeMillis();
             sseCallback.accept(MessageResponse.aiQuestion(nodeId, fallbackResponse));
         }
     }
-    
-    private List<ConversationOperation.ConversationHistory> buildConversationHistory(ConversationSession session) {
-        List<ConversationOperation.ConversationHistory> history = new ArrayList<>();
-        
-        // 从会话消息构建对话历史
-        for (ConversationSession.ConversationMessage message : session.getMessages()) {
-            ConversationOperation.ConversationHistory historyItem = new ConversationOperation.ConversationHistory(
-                message.getRole(),
-                message.getContent(),
-                message.getRole() + "_" + message.getTimestamp().toString()
-            );
-            history.add(historyItem);
-        }
-        
-        return history;
-    }
 
 
 }
\ No newline at end of file
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/MessageProcessingService.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/MessageProcessingService.java
new file mode 100644
index 0000000..2d86c89
--- /dev/null
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/MessageProcessingService.java
@@ -0,0 +1,41 @@
+package io.github.timemachinelab.core.session.application;
+
+import io.github.timemachinelab.core.session.domain.entity.ConversationSession;
+import io.github.timemachinelab.core.session.infrastructure.web.dto.UnifiedAnswerRequest;
+
+/**
+ * 消息处理服务接口
+ * 用于处理和加工用户消息，然后传递给大模型
+ * 
+ * @author suifeng
+ * 日期: 2025/1/27
+ */
+public interface MessageProcessingService {
+    
+    /**
+     * 处理统一答案请求
+     * 将用户的回答转换为适合大模型处理的格式
+     * 
+     * @param request 统一答案请求
+     * @return 处理后的消息内容
+     */
+    String processAnswer(UnifiedAnswerRequest request);
+    
+    /**
+     * 预处理消息
+     * 在发送给大模型之前对消息进行加工
+     *
+     * @param originalMessage 原始消息
+     * @param answerRequest 答案请求（可能为null）
+     * @return 加工后的消息
+     */
+    String preprocessMessage(String originalMessage, UnifiedAnswerRequest answerRequest, ConversationSession conversationSession);
+    
+    /**
+     * 验证答案格式
+     * 
+     * @param request 答案请求
+     * @return 是否有效
+     */
+    boolean validateAnswer(UnifiedAnswerRequest request);
+}
\ No newline at end of file
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/SessionManagementService.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/SessionManagementService.java
new file mode 100644
index 0000000..b498aef
--- /dev/null
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/SessionManagementService.java
@@ -0,0 +1,167 @@
+package io.github.timemachinelab.core.session.application;
+
+import io.github.timemachinelab.core.qatree.QaTree;
+import io.github.timemachinelab.core.qatree.QaTreeDomain;
+import io.github.timemachinelab.core.session.domain.entity.ConversationSession;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
+
+import javax.annotation.Resource;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.Map;
+import java.util.UUID;
+
+/**
+ * 会话管理服务
+ * 负责用户与会话的映射管理、nodeId验证等功能
+ * 
+ * @author suifeng
+ * 日期: 2025/1/27
+ */
+@Service
+@Slf4j
+public class SessionManagementService {
+    
+    // 用户ID到会话ID的映射
+    private final Map<String, String> userSessionMap = new ConcurrentHashMap<>();
+    
+    // 会话存储
+    private final Map<String, ConversationSession> sessions = new ConcurrentHashMap<>();
+
+    @Resource
+    private QaTreeDomain qaTreeDomain;
+    /**
+     * 创建或获取用户会话
+     * 如果sessionId为null，创建新会话；否则验证并返回现有会话
+     * 
+     * @param userId 用户ID
+     * @param sessionId 会话ID（可为null）
+     * @return 会话对象
+     */
+    public ConversationSession getOrCreateSession(String userId, String sessionId) {
+        if (sessionId == null || sessionId.trim().isEmpty()) {
+            // 创建新会话
+            return createNewSession(userId);
+        } else {
+            // 验证现有会话
+            return validateAndGetSession(userId, sessionId);
+        }
+    }
+    
+    /**
+     * 验证nodeId是否属于指定会话
+     * 
+     * @param sessionId 会话ID
+     * @param nodeId 节点ID
+     * @return 是否有效
+     */
+    public boolean validateNodeId(String sessionId, String nodeId) {
+        ConversationSession session = sessions.get(sessionId);
+        if (session == null) {
+            log.warn("会话不存在: {}", sessionId);
+            return false;
+        }
+        
+        // 检查节点是否存在于qaTree中
+        boolean exists = session.getQaTree().getNodeById(nodeId) != null;
+        if (!exists) {
+            log.warn("节点不存在 - 会话: {}, 节点: {}", sessionId, nodeId);
+        }
+        
+        return exists;
+    }
+    
+    /**
+     * 获取用户当前会话
+     * 
+     * @param userId 用户ID
+     * @return 会话对象
+     */
+    public ConversationSession getUserCurrentSession(String userId) {
+        String sessionId = userSessionMap.get(userId);
+        return sessionId != null ? sessions.get(sessionId) : null;
+    }
+
+    /**
+     * 创建新会话
+     */
+    private ConversationSession createNewSession(String userId) {
+        // 如果用户已有会话，先清理旧的映射
+        String oldSessionId = userSessionMap.get(userId);
+        if (oldSessionId != null) {
+            sessions.remove(oldSessionId);
+            log.info("清理用户旧会话 - 用户: {}, 旧会话: {}", userId, oldSessionId);
+        }
+        
+        // 生成新的sessionId
+        String newSessionId = UUID.randomUUID().toString();
+        QaTree tree = createDefaultQaTree();
+        
+        // 创建新会话
+        ConversationSession session = new ConversationSession(userId, newSessionId, tree);
+
+        // 建立映射关系
+        userSessionMap.put(userId, session.getSessionId());
+        sessions.put(session.getSessionId(), session);
+
+        log.info("创建新会话 - 用户: {}, 会话: {}", userId, session.getSessionId());
+        return session;
+    }
+    
+    /**
+     * 验证并获取现有会话
+     */
+    public ConversationSession validateAndGetSession(String userId, String sessionId) {
+        ConversationSession session = sessions.get(sessionId);
+        
+        if (session == null) {
+            log.warn("会话不存在，创建新会话 - 用户: {}, 请求会话: {}", userId, sessionId);
+            return createNewSession(userId);
+        }
+        
+        // 验证会话是否属于该用户
+        if (!session.getUserId().equals(userId)) {
+            log.warn("会话不属于该用户，创建新会话 - 用户: {}, 会话: {}, 会话所有者: {}", 
+                    userId, sessionId, session.getUserId());
+            return createNewSession(userId);
+        }
+        
+        // 更新用户会话映射（防止映射不一致）
+        userSessionMap.put(userId, sessionId);
+        
+        log.debug("验证会话成功 - 用户: {}, 会话: {}", userId, sessionId);
+        return session;
+    }
+    
+    /**
+     * 清理会话
+     * 
+     * @param sessionId 会话ID
+     */
+    public void removeSession(String sessionId) {
+        ConversationSession session = sessions.remove(sessionId);
+        if (session != null) {
+            userSessionMap.remove(session.getUserId());
+            log.info("清理会话 - 用户: {}, 会话: {}", session.getUserId(), sessionId);
+        }
+    }
+    
+    /**
+     * 获取会话统计信息
+     */
+    public Map<String, Object> getSessionStats() {
+        Map<String, Object> stats = new ConcurrentHashMap<>();
+        stats.put("totalSessions", sessions.size());
+        stats.put("activeUsers", userSessionMap.size());
+        stats.put("timestamp", System.currentTimeMillis());
+        return stats;
+    }
+
+    private QaTree createDefaultQaTree() {
+
+        QaTree tree = qaTreeDomain.createTree("default");
+
+        return tree;
+    }
+}
\ No newline at end of file
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/impl/DefaultMessageProcessingService.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/impl/DefaultMessageProcessingService.java
new file mode 100644
index 0000000..e39aef2
--- /dev/null
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/impl/DefaultMessageProcessingService.java
@@ -0,0 +1,100 @@
+package io.github.timemachinelab.core.session.application.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.google.gson.JsonObject;
+import dev.langchain4j.internal.Json;
+import io.github.timemachinelab.core.constant.AllPrompt;
+import io.github.timemachinelab.core.qatree.QaTree;
+import io.github.timemachinelab.core.qatree.QaTreeDomain;
+import io.github.timemachinelab.core.session.application.MessageProcessingService;
+import io.github.timemachinelab.core.session.application.SessionManagementService;
+import io.github.timemachinelab.core.session.domain.entity.ConversationSession;
+import io.github.timemachinelab.core.session.infrastructure.web.dto.UnifiedAnswerRequest;
+import io.github.timemachinelab.util.QaTreeSerializeUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+/**
+ * 默认消息处理服务实现
+ * 提供基础的消息处理逻辑，可根据需要进行扩展
+ * 
+ * @author suifeng
+ * 日期: 2025/1/27
+ */
+@Service
+@Slf4j
+public class DefaultMessageProcessingService implements MessageProcessingService {
+
+    @Resource
+    SessionManagementService sessionManagementService;
+    @Resource
+    QaTreeDomain qaTreeDomain;
+
+    @Override
+    public String processAnswer(UnifiedAnswerRequest request) {
+        if (!validateAnswer(request)) {
+            log.warn("无效的答案请求: {}", request);
+            return "无效的回答格式";
+        }
+        
+        // 将答案转换为可读文本
+        String readableText = request.toReadableText();
+        
+        // 构建完整的回答消息
+        StringBuilder message = new StringBuilder();
+        message.append("用户回答了问题: ");
+        message.append(readableText);
+        
+        log.info("处理答案请求 - 问题类型: {}, 内容: {}", request.getQuestionType(), readableText);
+        
+        return message.toString();
+    }
+    
+    @Override
+    public String preprocessMessage(String originalMessage, UnifiedAnswerRequest answerRequest,ConversationSession conversationSession) {
+        try {
+
+            JSONObject object = new JSONObject();
+            object.put("prompt",AllPrompt.GLOBAL_PROMPT);
+            object.put("tree", QaTreeSerializeUtil.serialize(conversationSession.getQaTree()));
+            object.put("input", answerRequest.getAnswerString());
+            return object.toString();
+        } catch (JsonProcessingException e) {
+            throw new RuntimeException("输入加工失败",e);
+        }
+
+    }
+    
+    @Override
+    public boolean validateAnswer(UnifiedAnswerRequest request) {
+        if (request == null) {
+            return false;
+        }
+        
+        if (request.getQuestionType() == null || request.getAnswer() == null) {
+            return false;
+        }
+        
+        // 根据问题类型验证答案格式
+        switch (request.getQuestionType().toLowerCase()) {
+            case "single":
+            case "multi":
+                return request.getChoiceAnswer() != null && !request.getChoiceAnswer().isEmpty();
+                
+            case "input":
+                String input = request.getInputAnswer();
+                return input != null && !input.trim().isEmpty();
+                
+            case "form":
+                return request.getFormAnswer() != null && !request.getFormAnswer().isEmpty();
+                
+            default:
+                log.warn("未知的问题类型: {}", request.getQuestionType());
+                return false;
+        }
+    }
+
+}
\ No newline at end of file
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/domain/entity/ConversationSession.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/domain/entity/ConversationSession.java
index 9e77f51..33d4642 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/domain/entity/ConversationSession.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/domain/entity/ConversationSession.java
@@ -1,45 +1,25 @@
 package io.github.timemachinelab.core.session.domain.entity;
 
+import io.github.timemachinelab.core.qatree.*;
 import lombok.Getter;
 
 import java.time.LocalDateTime;
 import java.util.UUID;
-import java.util.List;
-import java.util.ArrayList;
 
 @Getter
 public class ConversationSession {
     
     private final String sessionId;
     private final String userId;
+    private final QaTree qaTree;
     private final LocalDateTime createTime;
     private LocalDateTime updateTime;
-    private final List<ConversationMessage> messages;
     
-    public ConversationSession(String userId) {
-        this.sessionId = UUID.randomUUID().toString();
+    public ConversationSession(String userId, String sessionId, QaTree qaTree) {
+        this.qaTree = qaTree;
+        this.sessionId = sessionId;
         this.userId = userId;
         this.createTime = LocalDateTime.now();
         this.updateTime = LocalDateTime.now();
-        this.messages = new ArrayList<>();
-    }
-    
-    public void addMessage(String content, String role) {
-        ConversationMessage message = new ConversationMessage(content, role);
-        this.messages.add(message);
-        this.updateTime = LocalDateTime.now();
-    }
-    
-    @Getter
-    public static class ConversationMessage {
-        private final String content;
-        private final String role; // "user" or "assistant"
-        private final LocalDateTime timestamp;
-        
-        public ConversationMessage(String content, String role) {
-            this.content = content;
-            this.role = role;
-            this.timestamp = LocalDateTime.now();
-        }
     }
 }
\ No newline at end of file
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/ai/QuestionGenerationOperation.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/ai/QuestionGenerationOperation.java
index fb3c2b0..4a48c92 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/ai/QuestionGenerationOperation.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/ai/QuestionGenerationOperation.java
@@ -5,6 +5,7 @@
 import io.github.timemachinelab.core.question.QuestionParseException;
 import io.github.timemachinelab.sfchain.annotation.AIOp;
 import io.github.timemachinelab.sfchain.core.BaseAIOperation;
+import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
@@ -14,7 +15,7 @@
 )
 @Component
 @Slf4j
-public class QuestionGenerationOperation extends BaseAIOperation<QuestionGenerationOperation.QuestionGenerationRequest, BaseQuestion> {
+public class QuestionGenerationOperation extends BaseAIOperation<QuestionGenerationOperation.QuestionGenerationRequest, QuestionGenerationOperation.QuestionGenerationResponse> {
 
     @Override
     public String buildPrompt(QuestionGenerationRequest input) {
@@ -41,10 +42,10 @@ public String buildPrompt(QuestionGenerationRequest input) {
     }
 
     @Override
-    protected BaseQuestion parseResult(String jsonContent, QuestionGenerationRequest input) {
+    protected QuestionGenerationOperation.QuestionGenerationResponse parseResult(String jsonContent, QuestionGenerationRequest input) {
         try {
             // 使用QuestionParser解析AI返回的JSON
-            BaseQuestion question = QuestionParser.parseQuestion(jsonContent);
+            QuestionGenerationResponse question = QuestionParser.parseQuestion(jsonContent);
             log.info("成功生成问题，类型: {}", question.getClass().getSimpleName());
             return question;
             
@@ -90,4 +91,11 @@ public QuestionGenerationRequest(String globalPrompt, String conversationTree, S
             this.userInput = userInput;
         }
     }
+
+    @Data
+    @AllArgsConstructor
+    public static class QuestionGenerationResponse {
+        private BaseQuestion question;
+        private String parentId;
+    }
 }
\ No newline at end of file
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/ConversationController.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/ConversationController.java
index a010ff3..c8f6bef 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/ConversationController.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/ConversationController.java
@@ -1,12 +1,17 @@
 package io.github.timemachinelab.core.session.infrastructure.web;
 
 import io.github.timemachinelab.core.session.application.ConversationService;
+import io.github.timemachinelab.core.session.application.MessageProcessingService;
+import io.github.timemachinelab.core.session.application.SessionManagementService;
 import io.github.timemachinelab.core.session.domain.entity.ConversationSession;
 import io.github.timemachinelab.core.session.infrastructure.web.dto.MessageRequest;
-
+import io.github.timemachinelab.core.session.infrastructure.web.dto.UnifiedAnswerRequest;
 import io.github.timemachinelab.core.session.infrastructure.web.dto.MessageResponse;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
@@ -17,16 +22,14 @@
 @RestController
 @RequestMapping("/api/conversation")
 @RequiredArgsConstructor
+@Slf4j
 public class ConversationController {
     
     private final ConversationService conversationService;
+    private final MessageProcessingService messageProcessingService;
+    private final SessionManagementService sessionManagementService;
     private final Map<String, SseEmitter> sseEmitters = new ConcurrentHashMap<>();
     
-    @PostMapping("/start")
-    public ConversationSession startConversation(@RequestParam String userId) {
-        return conversationService.createSession(userId);
-    }
-    
     @GetMapping(value = "/sse/{sessionId}", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
     public SseEmitter streamConversation(@PathVariable String sessionId) {
         SseEmitter emitter = new SseEmitter(Long.MAX_VALUE);
@@ -39,30 +42,28 @@ public SseEmitter streamConversation(@PathVariable String sessionId) {
         return emitter;
     }
     
-    @PostMapping("/message")
-    public void addMessage(@RequestBody MessageRequest request) {
-        // 核心业务流程：用户消息 -> AI服务 -> SSE流式返回
-        conversationService.processUserMessage(
-                request.getSessionId(),
-                request.getContent(),
-                response -> sendSseMessage(request.getSessionId(), response)
-        );
-//        switch (request.getType()) {
-//            case USER_TEXT:
-//
-//
-//            case USER_SELECTION:
-//                conversationService.handleUserSelection(request.getSessionId(), request.getQuestionId(), request.getSelectedOption());
-//                sendSseMessage(request.getSessionId(), MessageResponse.userAnswer(request.getQuestionId(), "选择了选项: " + request.getSelectedOption()));
-//                break;
-//        }
-    }
+
     
-    @GetMapping("/session/{sessionId}")
-    public ConversationSession getSession(@PathVariable String sessionId) {
-        return conversationService.getSession(sessionId);
+    /**
+     * 从MessageRequest中提取用户ID
+     */
+    private String extractUserIdFromMessageRequest(MessageRequest request) {
+        // 临时实现：使用会话ID作为用户ID（仅用于演示）
+        return request.getSessionId() != null ? "user_" + request.getSessionId().hashCode() : "anonymous_" + System.currentTimeMillis();
     }
     
+    /**
+     * 从请求中提取用户ID
+     * TODO: 根据您的认证机制实现此方法
+     */
+    private String extractUserIdFromRequest(UnifiedAnswerRequest request) {
+        // 这里需要根据您的认证机制来实现
+        // 可能从JWT token、session、或其他方式获取用户ID
+        
+        // 临时实现：使用会话ID作为用户ID（仅用于演示）
+        return request.getSessionId() != null ? "user_" + request.getSessionId().hashCode() : "anonymous_" + System.currentTimeMillis();
+    }
+
     private void sendSseMessage(String sessionId, MessageResponse response) {
         SseEmitter emitter = sseEmitters.get(sessionId);
         if (emitter != null) {
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/MessageRequest.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/MessageRequest.java
index 064d7c5..bedbd8b 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/MessageRequest.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/MessageRequest.java
@@ -5,12 +5,12 @@
 @Data
 public class MessageRequest {
     private String sessionId;
+    private String nodeId;
     private String content;
-    
-    public enum MessageType {
-        USER_TEXT,
-        USER_SELECTION,
-        AI_QUESTION,
-        AI_SELECTION_QUESTION
+
+    public enum ContentType {
+        FORM,
+        TEXT,
+        OPTIONS
     }
 }
\ No newline at end of file
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/MessageResponse.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/MessageResponse.java
index b336773..269d3f2 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/MessageResponse.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/MessageResponse.java
@@ -15,6 +15,7 @@ public class MessageResponse {
     public enum MessageType {
         USER_ANSWER,
         AI_QUESTION,
+        AI_SELECTION_QUESTION,
         AI_ANSWER,
         SYSTEM_INFO
     }
@@ -30,4 +31,12 @@ public static MessageResponse aiQuestion(String nodeId, String content) {
     public static MessageResponse aiAnswer(String nodeId, String content) {
         return new MessageResponse(nodeId, content, MessageType.AI_ANSWER, null, System.currentTimeMillis());
     }
+    
+    public static MessageResponse aiSelectionQuestion(String nodeId, String content, String[] options) {
+        return new MessageResponse(nodeId, content, MessageType.AI_SELECTION_QUESTION, options, System.currentTimeMillis());
+    }
+    
+    public static MessageResponse systemInfo(String nodeId, String content) {
+        return new MessageResponse(nodeId, content, MessageType.SYSTEM_INFO, null, System.currentTimeMillis());
+    }
 }
\ No newline at end of file
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/UnifiedAnswerRequest.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/UnifiedAnswerRequest.java
new file mode 100644
index 0000000..368a548
--- /dev/null
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/infrastructure/web/dto/UnifiedAnswerRequest.java
@@ -0,0 +1,205 @@
+package io.github.timemachinelab.core.session.infrastructure.web.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+import lombok.NonNull;
+import lombok.NoArgsConstructor;
+import lombok.AllArgsConstructor;
+
+import javax.validation.constraints.NotBlank;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 统一答案请求DTO
+ * 用于接收前端传来的各种类型的问题回答
+ * 
+ * @author suifeng
+ * 日期: 2025/1/27
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class UnifiedAnswerRequest {
+    
+    /**
+     * 会话ID
+     */
+    private String sessionId;
+    
+    /**
+     * 节点ID
+     */
+    private String nodeId;
+    
+    /**
+     * 问题类型：single, multi, input, form
+     */
+    @NotBlank(message = "问题类型不能为空")
+    private String questionType;
+    
+    /**
+     * 原始答案数据
+     * - 单选/多选：List<String>
+     * - 输入框：String
+     * - 表单：List<FormAnswerItem>
+     */
+    @NonNull
+    private Object answer;
+    
+    /**
+     * 额外的上下文信息
+     */
+    private Map<String, Object> context;
+
+    /**
+     * 用户ID
+     */
+    @NotBlank(message = "用户ID不能为空")
+    private String userId;
+    /**
+     * 表单答案项
+     */
+    @Data
+    @NoArgsConstructor
+    @AllArgsConstructor
+    public static class FormAnswerItem {
+        /**
+         * 字段ID
+         */
+        private String id;
+        
+        /**
+         * 字段值
+         */
+        private List<String> value;
+    }
+    
+    /**
+     * 获取单选/多选答案
+     */
+    @SuppressWarnings("unchecked")
+    public List<String> getChoiceAnswer() {
+        if (answer instanceof List) {
+            return (List<String>) answer;
+        }
+        return null;
+    }
+    
+    /**
+     * 获取输入框答案
+     */
+    public String getInputAnswer() {
+        if (answer instanceof String) {
+            return (String) answer;
+        }
+        return null;
+    }
+    
+    /**
+     * 获取表单答案
+     */
+    @SuppressWarnings("unchecked")
+    public List<FormAnswerItem> getFormAnswer() {
+        if (answer instanceof List) {
+            List<?> list = (List<?>) answer;
+            if (!list.isEmpty() && list.get(0) instanceof Map) {
+                // 处理JSON反序列化的Map格式
+                return list.stream()
+                    .map(item -> {
+                        if (item instanceof Map) {
+                            Map<String, Object> map = (Map<String, Object>) item;
+                            FormAnswerItem formItem = new FormAnswerItem();
+                            formItem.setId((String) map.get("id"));
+                            formItem.setValue((List<String>) map.get("value"));
+                            return formItem;
+                        }
+                        return (FormAnswerItem) item;
+                    })
+                    .collect(java.util.stream.Collectors.toList());
+            }
+            return (List<FormAnswerItem>) answer;
+        }
+        return null;
+    }
+    
+    /**
+     * 根据问题类型获取对应的答案字符串
+     * 
+     * @return 答案字符串
+     */
+    public String getAnswerString() {
+        if (questionType == null) {
+            return "";
+        }
+        
+        switch (questionType.toLowerCase()) {
+            case "single":
+            case "multi":
+                List<String> choices = getChoiceAnswer();
+                return choices != null && !choices.isEmpty() ? String.join(", ", choices) : "";
+                
+            case "input":
+                String input = getInputAnswer();
+                return input != null ? input : "";
+                
+            case "form":
+                List<FormAnswerItem> formItems = getFormAnswer();
+                if (formItems != null && !formItems.isEmpty()) {
+                    StringBuilder sb = new StringBuilder();
+                    for (int i = 0; i < formItems.size(); i++) {
+                        FormAnswerItem item = formItems.get(i);
+                        if (item.getValue() != null && !item.getValue().isEmpty()) {
+                            sb.append(item.getId()).append(": ")
+                              .append(String.join(", ", item.getValue()));
+                            if (i < formItems.size() - 1) {
+                                sb.append("; ");
+                            }
+                        }
+                    }
+                    return sb.toString();
+                }
+                return "";
+                
+            default:
+                return "";
+        }
+    }
+    
+    /**
+     * 转换为可读的文本格式
+     */
+    public String toReadableText() {
+        StringBuilder sb = new StringBuilder();
+        
+        switch (questionType.toLowerCase()) {
+            case "single":
+            case "multi":
+                List<String> choices = getChoiceAnswer();
+                if (choices != null && !choices.isEmpty()) {
+                    sb.append("选择了：").append(String.join(", ", choices));
+                }
+                break;
+                
+            case "input":
+                String input = getInputAnswer();
+                if (input != null) {
+                    sb.append(input);
+                }
+                break;
+                
+            case "form":
+                List<FormAnswerItem> formItems = getFormAnswer();
+                if (formItems != null) {
+                    for (FormAnswerItem item : formItems) {
+                        sb.append(item.getId()).append(": ")
+                          .append(String.join(", ", item.getValue()))
+                          .append("; ");
+                    }
+                }
+                break;
+        }
+        
+        return sb.toString();
+    }
+}
\ No newline at end of file
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/sfchain/controller/AICallLogController.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/sfchain/controller/AICallLogController.java
index e723ff7..61723d4 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/sfchain/controller/AICallLogController.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/sfchain/controller/AICallLogController.java
@@ -15,7 +15,6 @@
  */
 @RestController
 @RequestMapping("/sf/api/ai-logs")
-@CrossOrigin(origins = "*")
 public class AICallLogController {
     
     @Resource
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/sfchain/controller/AIModelController.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/sfchain/controller/AIModelController.java
index 47b7610..ed34b96 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/sfchain/controller/AIModelController.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/sfchain/controller/AIModelController.java
@@ -92,12 +92,8 @@ public ResponseEntity<Map<String, Object>> saveModel(
         Map<String, Object> result = new HashMap<>();
         String modelName = config.getModelName();
         try {
-            // 检查模型是否已存在
-            Map<String, ModelConfigData> existingModels = persistenceManager.getAllModelConfigs();
-            boolean modelExists = existingModels.containsKey(modelName);
-            
-            // 验证模型配置（临时验证，不影响现有模型）
-            boolean validationResult = validateModelConfig(modelName, config, true);
+            // 验证模型配置
+            boolean validationResult = validateModelConfig(modelName, config);
             
             if (!validationResult) {
                 result.put("success", false);
@@ -105,6 +101,10 @@ public ResponseEntity<Map<String, Object>> saveModel(
                 return ResponseEntity.badRequest().body(result);
             }
             
+            // 检查模型是否已存在
+            Map<String, ModelConfigData> existingModels = persistenceManager.getAllModelConfigs();
+            boolean modelExists = existingModels.containsKey(modelName);
+            
             // 根据模型是否存在选择添加或更新
             if (modelExists) {
                 persistenceManager.updateModelConfig(modelName, config);
@@ -131,12 +131,31 @@ public ResponseEntity<Map<String, Object>> saveModel(
         }
     }
     
+    /**
+     * 删除模型配置
+     */
+    @DeleteMapping("/{modelName}")
+    public ResponseEntity<Map<String, Object>> deleteModel(@PathVariable String modelName) {
+        Map<String, Object> result = new HashMap<>();
+        try {
+            persistenceManager.deleteModelConfig(modelName);
+            result.put("success", true);
+            result.put("message", "模型配置删除成功");
+            result.put("modelName", modelName);
+            return ResponseEntity.ok(result);
+        } catch (Exception e) {
+            log.error("删除模型配置失败: {} - {}", modelName, e.getMessage());
+            result.put("success", false);
+            result.put("message", "删除失败: " + e.getMessage());
+            return ResponseEntity.badRequest().body(result);
+        }
+    }
+    
     /**
      * 测试模型连接
      */
-    @PostMapping("/test")
-    public ResponseEntity<Map<String, Object>> testModel(@RequestBody Map<String, String> request) {
-        String modelName = request.get("modelName");
+    @PostMapping("/{modelName}/test")
+    public ResponseEntity<Map<String, Object>> testModel(@PathVariable String modelName) {
         Map<String, Object> result = new HashMap<>();
         try {
             Map<String, ModelConfigData> models = persistenceManager.getAllModelConfigs();
@@ -148,8 +167,7 @@ public ResponseEntity<Map<String, Object>> testModel(@RequestBody Map<String, St
                 return ResponseEntity.notFound().build();
             }
             
-            // 测试已存在的模型，不需要临时注册
-            boolean testResult = validateModelConfig(modelName, config, false);
+            boolean testResult = validateModelConfig(modelName, config);
             result.put("success", testResult);
             result.put("message", testResult ? "模型连接测试成功" : "模型连接测试失败");
             result.put("modelName", modelName);
@@ -167,14 +185,11 @@ public ResponseEntity<Map<String, Object>> testModel(@RequestBody Map<String, St
     
     /**
      * 验证模型配置是否可用
-     * @param modelName 模型名称
-     * @param config 模型配置
-     * @param isTemporaryValidation 是否为临时验证（true: 验证后移除临时模型，false: 验证已存在的模型）
      */
-    private boolean validateModelConfig(String modelName, ModelConfigData config, boolean isTemporaryValidation) {
+    private boolean validateModelConfig(String modelName, ModelConfigData config) {
         boolean tempRegistered = false;
         try {
-            log.info("开始验证模型配置: {} (临时验证: {})", modelName, isTemporaryValidation);
+            log.info("开始验证模型配置: {}", modelName);
             
             ModelValidationOperation validationOp = (ModelValidationOperation) operationRegistry.getOperation(MODEL_VALIDATION_OP);
             if (validationOp == null) {
@@ -182,12 +197,9 @@ private boolean validateModelConfig(String modelName, ModelConfigData config, bo
                 return true;
             }
             
-            // 如果是临时验证，需要临时注册模型
-            if (isTemporaryValidation) {
-                OpenAIModelConfig tempConfig = convertToOpenAIConfig(config);
-                modelFactory.registerModel(tempConfig);
-                tempRegistered = true;
-            }
+            OpenAIModelConfig tempConfig = convertToOpenAIConfig(config);
+            modelFactory.registerModel(tempConfig);
+            tempRegistered = true;
             
             ModelValidationOperation.ValidationRequest request = 
                 new ModelValidationOperation.ValidationRequest("请回答：2+3等于几？");
@@ -200,38 +212,15 @@ private boolean validateModelConfig(String modelName, ModelConfigData config, bo
             log.error("模型验证失败: {} - {}", modelName, e.getMessage());
             return false;
         } finally {
-            // 只有在临时验证时才清理临时模型
-            if (tempRegistered && isTemporaryValidation) {
+            if (tempRegistered) {
                 try {
                     modelFactory.removeModel(modelName);
-                    log.debug("已清理临时模型配置: {}", modelName);
                 } catch (Exception e) {
                     log.warn("清理临时模型配置失败: {}", e.getMessage());
                 }
             }
         }
     }
-
-    
-    /**
-     * 删除模型配置
-     */
-    @DeleteMapping("/{modelName}")
-    public ResponseEntity<Map<String, Object>> deleteModel(@PathVariable String modelName) {
-        Map<String, Object> result = new HashMap<>();
-        try {
-            persistenceManager.deleteModelConfig(modelName);
-            result.put("success", true);
-            result.put("message", "模型配置删除成功");
-            result.put("modelName", modelName);
-            return ResponseEntity.ok(result);
-        } catch (Exception e) {
-            log.error("删除模型配置失败: {} - {}", modelName, e.getMessage());
-            result.put("success", false);
-            result.put("message", "删除失败: " + e.getMessage());
-            return ResponseEntity.badRequest().body(result);
-        }
-    }
     
     /**
      * 转换配置格式
diff --git a/prompto-lab-app/src/main/resources/application.yml b/prompto-lab-app/src/main/resources/application.yml
index 0422c4b..64ee53e 100644
--- a/prompto-lab-app/src/main/resources/application.yml
+++ b/prompto-lab-app/src/main/resources/application.yml
@@ -7,7 +7,7 @@ spring:
   application:
     name: poet-agent
   datasource:
-    url: ${SPRING_DATASOURCE_URL:ENC(74AA8WeNmewtlYjGh4jIWPh8E6cxGrZ0M7zg+1wAfBJLR36B6GTw4cvCfA/EhuZiy0oSbrnGRERv5IxzsxfOFA==)}a
+    url: ${SPRING_DATASOURCE_URL:ENC(74AA8WeNmewtlYjGh4jIWPh8E6cxGrZ0M7zg+1wAfBJLR36B6GTw4cvCfA/EhuZiy0oSbrnGRERv5IxzsxfOFA==)}
     username: ${SPRING_DATASOURCE_USERNAME:ENC(nOfIk0lODnZFZinDkKMeEX5zHzXpOoIj)}
     password: ${SPRING_DATASOURCE_PASSWORD:ENC(W52dd0i/Q8pT/yEJIKs6Zc/brOr6KjXBPVcwdjoe4g4=)}
     driver-class-name: ${SPRING_DATASOURCE_DRIVER_CLASS_NAME:org.postgresql.Driver}
diff --git a/prompto-lab-ui/src/components/Chat/AIChatPage.vue b/prompto-lab-ui/src/components/Chat/AIChatPage.vue
index 631d338..f8cc3c7 100644
--- a/prompto-lab-ui/src/components/Chat/AIChatPage.vue
+++ b/prompto-lab-ui/src/components/Chat/AIChatPage.vue
@@ -9,7 +9,7 @@
         <div class="particle" v-for="i in 15" :key="i"></div>
       </div>
     </div>
-    
+
     <!-- 左侧栏 -->
     <div class="left-sidebar">
       <div class="sidebar-content">
@@ -33,19 +33,19 @@
         </div>
       </div>
     </div>
-    
+
     <!-- 中间对话主页面 -->
     <div class="main-content" :style="{ width: mainContentWidth + 'px' }">
-      <ChatMain 
+      <ChatMain
         :messages="currentBranchMessages"
         :is-loading="isLoading"
         :streaming-node-id="streamingNodeId"
         @send-message="handleSendMessage"
       />
     </div>
-    
+
     <!-- 可拖拽的分隔条 -->
-    <div 
+    <div
       class="resizer"
       @mousedown="startResize"
       @touchstart="startResize"
@@ -59,10 +59,10 @@
         </div>
       </div>
     </div>
-    
+
     <!-- 右侧思维导图 -->
     <div class="right-sidebar" :style="{ width: rightSidebarWidth + 'px' }">
-      <MindMapTree 
+      <MindMapTree
         :conversation-tree="conversationTree"
         :current-node-id="currentNodeId"
         @node-selected="handleNodeSelected"
@@ -132,23 +132,23 @@ const isLoading = ref(false)
 // 初始化会话
 const initializeSession = async () => {
   if (isInitializing.value) return
-  
+
   isInitializing.value = true
-  
+
   try {
     // 创建新会话
     const userId = 'demo-user-' + Date.now() // 临时用户ID
     session.value = await startConversation(userId)
-    
+
     // 建立SSE连接
     eventSource.value = connectSSE(
       session.value.sessionId,
       handleSSEMessage,
       handleSSEError
     )
-    
+
     isConnected.value = true
-    
+
     // 初始化根节点
     const rootNode: ConversationNode = {
       id: 'root',
@@ -158,16 +158,16 @@ const initializeSession = async () => {
       children: [],
       isActive: true
     }
-    
+
     conversationTree.value.set('root', rootNode)
     currentNodeId.value = 'root'
-    
+
     toast.success({
       title: '会话已建立',
       message: '已成功连接到AI助手',
       duration: 2000
     })
-    
+
   } catch (error: any) {
     console.error('初始化会话失败:', error)
     toast.error({
@@ -183,7 +183,7 @@ const initializeSession = async () => {
 // 处理SSE消息
 const handleSSEMessage = (response: MessageResponse) => {
   console.log('收到SSE消息:', response)
-  
+
   switch (response.type) {
     case 'AI_QUESTION':
     case 'AI_ANSWER':
@@ -209,7 +209,7 @@ const handleSSEMessage = (response: MessageResponse) => {
 const startStreamingMessage = (nodeId: string) => {
   streamingNodeId.value = nodeId
   streamingContent.value = ''
-  
+
   const aiNode: ConversationNode = {
     id: nodeId,
     content: '',
@@ -219,12 +219,12 @@ const startStreamingMessage = (nodeId: string) => {
     children: [],
     isActive: true
   }
-  
+
   const currentNode = conversationTree.value.get(currentNodeId.value)
   if (currentNode) {
     currentNode.children.push(nodeId)
   }
-  
+
   conversationTree.value.set(nodeId, aiNode)
   currentNodeId.value = nodeId
   isLoading.value = false
@@ -234,7 +234,7 @@ const startStreamingMessage = (nodeId: string) => {
 const appendStreamingContent = (nodeId: string, chunk: string) => {
   if (streamingNodeId.value === nodeId) {
     streamingContent.value += chunk
-    
+
     // 更新节点内容
     const node = conversationTree.value.get(nodeId)
     if (node) {
@@ -255,17 +255,17 @@ const finishStreamingMessage = (nodeId: string) => {
 const handleSSEError = (error: Event) => {
   console.error('SSE连接错误:', error)
   isConnected.value = false
-  
+
   toast.error({
     title: '连接中断',
     message: '与AI助手的连接已中断，正在尝试重连...',
     duration: 3000
   })
-  
+
   // 尝试重连
   setTimeout(() => {
     if (session.value && !isConnected.value) {
-      eventSource.value = connectSSE(
+      eventSource.value = connectUserInteractionSSE(
         session.value.sessionId,
         handleSSEMessage,
         handleSSEError
@@ -291,12 +291,12 @@ const addAIMessage = (nodeId: string, content: string, isStreaming = false) => {
     children: [],
     isActive: true
   }
-  
+
   const currentNode = conversationTree.value.get(currentNodeId.value)
   if (currentNode) {
     currentNode.children.push(nodeId)
   }
-  
+
   conversationTree.value.set(nodeId, aiNode)
   currentNodeId.value = nodeId
   isLoading.value = false
@@ -313,23 +313,23 @@ const addAISelectionMessage = (nodeId: string, content: string, options: string[
 const currentBranchMessages = computed(() => {
   const messages: Message[] = []
   const visited = new Set<string>()
-  
+
   const buildPath = (nodeId: string): string[] => {
     const path: string[] = []
     let current = nodeId
-    
+
     while (current && !visited.has(current)) {
       visited.add(current)
       path.unshift(current)
       const node = conversationTree.value.get(current)
       current = node?.parentId || ''
     }
-    
+
     return path
   }
-  
+
   const path = buildPath(currentNodeId.value)
-  
+
   path.forEach(nodeId => {
     const node = conversationTree.value.get(nodeId)
     if (node) {
@@ -341,56 +341,56 @@ const currentBranchMessages = computed(() => {
       })
     }
   })
-  
+
   return messages
 })
 
 // 拖拽开始
 const startResize = (event: MouseEvent | TouchEvent) => {
   isResizing.value = true
-  
+
   const clientX = 'touches' in event ? event.touches[0].clientX : event.clientX
   startX.value = clientX
   startRightWidth.value = rightSidebarWidth.value
-  
+
   document.addEventListener('mousemove', handleResize)
   document.addEventListener('mouseup', stopResize)
   document.addEventListener('touchmove', handleResize)
   document.addEventListener('touchend', stopResize)
-  
+
   // 防止文本选择
   document.body.style.userSelect = 'none'
   document.body.style.cursor = 'col-resize'
-  
+
   event.preventDefault()
 }
 
 // 拖拽过程中
 const handleResize = (event: MouseEvent | TouchEvent) => {
   if (!isResizing.value) return
-  
+
   const clientX = 'touches' in event ? event.touches[0].clientX : event.clientX
   const deltaX = startX.value - clientX // 注意方向：向左拖拽为正值
   const newWidth = startRightWidth.value + deltaX
-  
+
   // 限制在最小和最大宽度之间
   rightSidebarWidth.value = Math.max(
     minRightSidebarWidth,
     Math.min(maxRightSidebarWidth, newWidth)
   )
-  
+
   event.preventDefault()
 }
 
 // 拖拽结束
 const stopResize = () => {
   isResizing.value = false
-  
+
   document.removeEventListener('mousemove', handleResize)
   document.removeEventListener('mouseup', stopResize)
   document.removeEventListener('touchmove', handleResize)
   document.removeEventListener('touchend', stopResize)
-  
+
   document.body.style.userSelect = ''
   document.body.style.cursor = ''
 }
@@ -413,7 +413,7 @@ onUnmounted(() => {
     closeSSE(eventSource.value)
     eventSource.value = null
   }
-  
+
   window.removeEventListener('resize', updateContainerWidth)
   stopResize() // 确保清理事件监听器
 })
@@ -428,7 +428,7 @@ const handleSendMessage = async (content: string) => {
     })
     return
   }
-  
+
   const userNodeId = `user_${Date.now()}`
   const userNode: ConversationNode = {
     id: userNodeId,
@@ -439,7 +439,7 @@ const handleSendMessage = async (content: string) => {
     children: [],
     isActive: true
   }
-  
+
   const currentNode = conversationTree.value.get(currentNodeId.value)
   if (currentNode) {
     // 将当前节点的其他子节点设为非活跃状态
@@ -449,38 +449,47 @@ const handleSendMessage = async (content: string) => {
         setNodeAndDescendantsInactive(childId)
       }
     })
-    
+
     currentNode.children.push(userNodeId)
   }
-  
+
   conversationTree.value.set(userNodeId, userNode)
   currentNodeId.value = userNodeId
-  
+
   isLoading.value = true
-  
+
   try {
-    // 发送消息到后端
-    const messageRequest: MessageRequest = {
-      sessionId: session.value.sessionId,
-      content,
-      type: 'USER_TEXT'
-    }
-    
-    await sendMessage(messageRequest)
-    
+    // 使用统一答案请求格式调用您的/message接口
+    const userId = 'user_' + Date.now() // 临时用户ID，实际应用中应从认证系统获取
+
+    // 按照您的要求，直接设为null
+    const sessionId = null
+    const nodeId = null
+
+    const answerRequest = createAnswerRequest.input(
+      sessionId,
+      nodeId,
+      userId,
+      content.trim()
+    )
+
+    console.log('发送答案请求:', answerRequest)
+
+    await sendAnswer(answerRequest)
+
     // 消息发送成功，等待SSE返回AI回复
-    console.log('消息已发送，等待AI回复...')
-    
+    console.log('消息已发送到/message接口，等待AI回复...')
+
   } catch (error: any) {
     console.error('发送消息失败:', error)
     isLoading.value = false
-    
+
     toast.error({
       title: '发送失败',
       message: error.message || '消息发送失败，请重试',
       duration: 4000
     })
-    
+
     // 发送失败时移除用户消息节点
     conversationTree.value.delete(userNodeId)
     if (currentNode) {
@@ -510,7 +519,7 @@ const handleNodeSelected = (nodeId: string) => {
     conversationTree.value.forEach(node => {
       node.isActive = false
     })
-    
+
     const activatePath = (currentNodeId: string) => {
       const node = conversationTree.value.get(currentNodeId)
       if (node) {
@@ -520,7 +529,7 @@ const handleNodeSelected = (nodeId: string) => {
         }
       }
     }
-    
+
     activatePath(nodeId)
     currentNodeId.value = nodeId
   }
@@ -533,20 +542,20 @@ const handleBranchDeleted = (nodeId: string) => {
       node.children.forEach(childId => {
         deleteNodeAndDescendants(childId)
       })
-      
+
       if (node.parentId) {
         const parentNode = conversationTree.value.get(node.parentId)
         if (parentNode) {
           parentNode.children = parentNode.children.filter(childId => childId !== id)
         }
       }
-      
+
       conversationTree.value.delete(id)
     }
   }
-  
+
   deleteNodeAndDescendants(nodeId)
-  
+
   if (!conversationTree.value.has(currentNodeId.value)) {
     let newCurrentId = 'root'
     conversationTree.value.forEach((node, id) => {
@@ -677,7 +686,7 @@ const handleBranchDeleted = (nodeId: string) => {
   flex-shrink: 0;
   position: relative;
   z-index: 2;
-  box-shadow: 
+  box-shadow:
     inset -1px 0 0 rgba(212, 175, 55, 0.1),
     0 0 32px rgba(0, 0, 0, 0.3);
 }
@@ -699,7 +708,7 @@ const handleBranchDeleted = (nodeId: string) => {
   border: 1px solid rgba(212, 175, 55, 0.2);
   border-radius: 12px;
   backdrop-filter: blur(10px);
-  box-shadow: 
+  box-shadow:
     0 8px 32px rgba(0, 0, 0, 0.3),
     inset 0 1px 0 rgba(255, 255, 255, 0.08);
 }
@@ -712,7 +721,7 @@ const handleBranchDeleted = (nodeId: string) => {
   display: flex;
   align-items: center;
   justify-content: center;
-  box-shadow: 
+  box-shadow:
     0 8px 24px rgba(212, 175, 55, 0.4),
     inset 0 1px 0 rgba(255, 255, 255, 0.3);
 }
@@ -782,7 +791,7 @@ const handleBranchDeleted = (nodeId: string) => {
   border-left: 1px solid rgba(212, 175, 55, 0.15);
   position: relative;
   z-index: 2;
-  box-shadow: 
+  box-shadow:
     inset 1px 0 0 rgba(212, 175, 55, 0.1),
     0 0 32px rgba(0, 0, 0, 0.3);
 }
@@ -803,11 +812,11 @@ const handleBranchDeleted = (nodeId: string) => {
   .left-sidebar {
     width: 220px; /* 在较小屏幕上适当减少 */
   }
-  
+
   .right-sidebar {
     min-width: 450px;
   }
-  
+
   .main-content {
     min-width: 350px;
   }
@@ -817,7 +826,7 @@ const handleBranchDeleted = (nodeId: string) => {
   .left-sidebar {
     width: 200px; /* 更小的屏幕进一步调整 */
   }
-  
+
   .right-sidebar {
     min-width: 400px;
   }
@@ -893,7 +902,7 @@ const handleBranchDeleted = (nodeId: string) => {
 
 .resizer:hover {
   background: linear-gradient(180deg, rgba(212, 175, 55, 0.3), rgba(212, 175, 55, 0.6), rgba(212, 175, 55, 0.3));
-  box-shadow: 
+  box-shadow:
     0 0 20px rgba(212, 175, 55, 0.4),
     inset 0 0 20px rgba(212, 175, 55, 0.2);
   border-color: rgba(212, 175, 55, 0.5);
@@ -926,7 +935,7 @@ const handleBranchDeleted = (nodeId: string) => {
   opacity: 0;
   transition: all 0.3s cubic-bezier(0.4, 0, 0.2, 1);
   backdrop-filter: blur(10px);
-  box-shadow: 
+  box-shadow:
     0 4px 16px rgba(0, 0, 0, 0.3),
     inset 0 1px 0 rgba(255, 255, 255, 0.1);
 }
@@ -935,7 +944,7 @@ const handleBranchDeleted = (nodeId: string) => {
   opacity: 1;
   transform: scale(1.05);
   border-color: rgba(212, 175, 55, 0.6);
-  box-shadow: 
+  box-shadow:
     0 8px 24px rgba(0, 0, 0, 0.4),
     0 0 20px rgba(212, 175, 55, 0.3),
     inset 0 1px 0 rgba(255, 255, 255, 0.2);
@@ -972,7 +981,7 @@ const handleBranchDeleted = (nodeId: string) => {
   border-left: 1px solid rgba(212, 175, 55, 0.15);
   position: relative;
   z-index: 2;
-  box-shadow: 
+  box-shadow:
     inset 1px 0 0 rgba(212, 175, 55, 0.1),
     0 0 32px rgba(0, 0, 0, 0.3);
 }
@@ -988,7 +997,7 @@ body.resizing {
   .left-sidebar {
     width: 200px;
   }
-  
+
   .sidebar-content {
     padding: 24px 16px;
   }
@@ -998,23 +1007,23 @@ body.resizing {
   .ai-chat-page {
     flex-direction: column;
   }
-  
+
   .left-sidebar,
   .right-sidebar {
     width: 100% !important;
     height: 200px;
   }
-  
+
   .main-content {
     width: 100% !important;
     flex: 1;
     min-height: 400px;
   }
-  
+
   .resizer {
     display: none;
   }
-  
+
   .dynamic-background {
     display: none;
   }
@@ -1025,17 +1034,17 @@ body.resizing {
     padding: 16px 12px;
     gap: 20px;
   }
-  
+
   .sidebar-header {
     padding: 16px;
     gap: 12px;
   }
-  
+
   .icon-wrapper {
     width: 40px;
     height: 40px;
   }
-  
+
   .icon {
     font-size: 20px;
   }
diff --git a/prompto-lab-ui/src/services/conversationApi.ts b/prompto-lab-ui/src/services/conversationApi.ts
index 5c718e8..6dd2c90 100644
--- a/prompto-lab-ui/src/services/conversationApi.ts
+++ b/prompto-lab-ui/src/services/conversationApi.ts
@@ -1,4 +1,4 @@
-import { apiJsonRequest, apiRequest } from './apiUtils'
+import { apiRequest } from './apiUtils'
 import { API_CONFIG } from './apiConfig'
 
 // 类型定义
@@ -13,10 +13,9 @@ export interface MessageRequest {
 export interface MessageResponse {
   nodeId: string
   content: string
-  type: 'USER_ANSWER' | 'AI_QUESTION' | 'AI_SELECTION_QUESTION' | 'SYSTEM_INFO' | 'AI_STREAM_START' | 'AI_STREAM_CHUNK' | 'AI_STREAM_END' | 'AI_ANSWER'
+  type: 'USER_ANSWER' | 'AI_QUESTION' | 'AI_SELECTION_QUESTION' | 'SYSTEM_INFO'
   options?: string[]
   timestamp: number
-  isComplete?: boolean  // 标识消息是否完整
 }
 
 export interface ConversationSession {
@@ -27,103 +26,112 @@ export interface ConversationSession {
   createdAt: string
 }
 
-// API基础URL - 使用ConversationController接口
-const API_BASE = `${API_CONFIG.BASE_URL}/api/conversation`
+// API基础URL - 使用SSE Demo接口
+const API_BASE = `${API_CONFIG.BASE_URL}/api/demo`
 
 /**
- * 创建新的会话 - 对应ConversationController.startConversation
+ * 创建新的会话（Demo版本 - 直接返回模拟数据）
  */
 export const startConversation = async (userId: string): Promise<ConversationSession> => {
-  const url = `${API_BASE}/start?userId=${encodeURIComponent(userId)}`
-  return await apiJsonRequest<ConversationSession>(url, {
-    method: 'POST',
-    requireAuth: false
-  })
+  // Demo版本：直接返回模拟的会话数据
+  return {
+    sessionId: userId,
+    userId: userId,
+    qaTree: null,
+    currentNodeId: 'root',
+    createdAt: new Date().toISOString()
+  }
 }
 
 /**
- * 发送消息 - 对应ConversationController.addMessage
+ * 发送消息（Demo版本 - 使用SSE Demo的发送接口）
  */
 export const sendMessage = async (request: MessageRequest): Promise<void> => {
-  const url = `${API_BASE}/message`
+  const url = `${API_BASE}/send/${request.sessionId}?message=${encodeURIComponent(request.content)}`
   await apiRequest(url, {
     method: 'POST',
-    body: JSON.stringify(request),
     requireAuth: false
   })
 }
 
 /**
- * 获取会话信息
+ * 获取会话信息（Demo版本）
  */
 export const getSession = async (sessionId: string): Promise<ConversationSession> => {
-  const url = `${API_BASE}/session/${sessionId}`
-  return await apiJsonRequest<ConversationSession>(url, {
-    method: 'GET',
-    requireAuth: false
-  })
+  return {
+    sessionId: sessionId,
+    userId: sessionId,
+    qaTree: null,
+    currentNodeId: 'root',
+    createdAt: new Date().toISOString()
+  }
 }
 
 /**
- * 建立SSE连接 - 对应ConversationController.streamConversation
- */
-/**
- * 建立SSE连接 - 支持流式响应
+ * 建立SSE连接（Demo版本 - 使用SSE Demo接口）
  */
 export const connectSSE = (sessionId: string, onMessage: (response: MessageResponse) => void, onError?: (error: Event) => void): EventSource => {
   const url = `${API_BASE}/sse/${sessionId}`
   const eventSource = new EventSource(url)
-  
-  // 监听默认message事件
+
+  // 监听连接建立事件
+  eventSource.addEventListener('connected', (event: MessageEvent) => {
+    console.log('SSE连接已建立:', event.data)
+  })
+
+  // 监听普通消息
   eventSource.addEventListener('message', (event: MessageEvent) => {
     try {
-      const response: MessageResponse = JSON.parse(event.data)
+      // Demo版本：将SSE消息转换为MessageResponse格式
+      const response: MessageResponse = {
+        nodeId: `ai_${Date.now()}`,
+        content: event.data,
+        type: 'AI_QUESTION',
+        timestamp: Date.now()
+      }
       onMessage(response)
     } catch (error) {
       console.error('解析SSE消息失败:', error)
     }
   })
-  
-  // 监听流式开始事件
-  eventSource.addEventListener('stream_start', (event: MessageEvent) => {
-    try {
-      const response: MessageResponse = JSON.parse(event.data)
-      response.type = 'AI_STREAM_START'
-      onMessage(response)
-    } catch (error) {
-      console.error('解析流式开始消息失败:', error)
-    }
-  })
-  
-  // 监听流式数据块事件
-  eventSource.addEventListener('stream_chunk', (event: MessageEvent) => {
+
+  // 监听流式数据
+  eventSource.addEventListener('stream', (event: MessageEvent) => {
     try {
-      const response: MessageResponse = JSON.parse(event.data)
-      response.type = 'AI_STREAM_CHUNK'
+      const response: MessageResponse = {
+        nodeId: `stream_${Date.now()}`,
+        content: event.data,
+        type: 'AI_QUESTION',
+        timestamp: Date.now()
+      }
       onMessage(response)
     } catch (error) {
-      console.error('解析流式数据块失败:', error)
+      console.error('解析流式消息失败:', error)
     }
   })
-  
-  // 监听流式结束事件
-  eventSource.addEventListener('stream_end', (event: MessageEvent) => {
+
+  // 监听广播消息
+  eventSource.addEventListener('broadcast', (event: MessageEvent) => {
     try {
-      const response: MessageResponse = JSON.parse(event.data)
-      response.type = 'AI_STREAM_END'
+      const response: MessageResponse = {
+        nodeId: `broadcast_${Date.now()}`,
+        content: `[广播] ${event.data}`,
+        type: 'SYSTEM_INFO',
+        timestamp: Date.now()
+      }
       onMessage(response)
     } catch (error) {
-      console.error('解析流式结束消息失败:', error)
+      console.error('解析广播消息失败:', error)
     }
   })
-  
+
   eventSource.onerror = (error: Event) => {
     console.error('SSE连接错误:', error)
     if (onError) {
       onError(error)
     }
   }
-  
+
   return eventSource
 }
 
@@ -134,4 +142,4 @@ export const closeSSE = (eventSource: EventSource | null) => {
   if (eventSource) {
     eventSource.close()
   }
-}
\ No newline at end of file
+}
diff --git a/prompto-lab-ui/src/services/userInteractionApi.ts b/prompto-lab-ui/src/services/userInteractionApi.ts
new file mode 100644
index 0000000..a6a395a
--- /dev/null
+++ b/prompto-lab-ui/src/services/userInteractionApi.ts
@@ -0,0 +1,229 @@
+import { apiJsonRequest, apiRequest } from './apiUtils'
+import { API_CONFIG } from './apiConfig'
+
+// 表单答案项类型
+export interface FormAnswerItem {
+  id: string
+  value: string[]
+}
+
+// 统一答案请求类型
+export interface UnifiedAnswerRequest {
+  sessionId: string | null
+  nodeId: string | null
+  userId: string
+  questionType: 'single' | 'multi' | 'input' | 'form'
+  answer: string | string[] | FormAnswerItem[]
+  context?: Record<string, any>
+}
+
+// API响应类型
+export interface ApiResponse {
+  success: boolean
+  message: string
+  data?: any
+  timestamp?: number
+}
+
+// 消息响应类型
+export interface MessageResponse {
+  nodeId: string
+  content: string
+  type: 'USER_ANSWER' | 'AI_QUESTION' | 'AI_SELECTION_QUESTION' | 'SYSTEM_INFO'
+  options?: string[]
+  timestamp: number
+}
+
+// SSE状态类型
+export interface SseStatus {
+  connectedSessions: string[]
+  totalConnections: number
+  timestamp: number
+}
+
+// API基础URL
+const API_BASE = `${API_CONFIG.BASE_URL}/api/user-interaction`
+
+/**
+ * 发送统一答案请求
+ * 支持单选、多选、输入框、表单等多种问题类型的回答
+ */
+export const sendAnswer = async (request: UnifiedAnswerRequest): Promise<string> => {
+  const url = `${API_BASE}/message`
+  
+  try {
+    const response = await apiRequest(url, {
+      method: 'POST',
+      body: JSON.stringify(request),
+      headers: {
+        'Content-Type': 'application/json'
+      },
+      requireAuth: false
+    })
+    
+    if (!response.ok) {
+      throw new Error(`HTTP error! status: ${response.status}`)
+    }
+    
+    return await response.text()
+  } catch (error) {
+    console.error('发送答案请求失败:', error)
+    throw error
+  }
+}
+
+/**
+ * 建立SSE连接
+ */
+export const connectUserInteractionSSE = (
+  sessionId: string, 
+  onMessage: (response: MessageResponse) => void, 
+  onError?: (error: Event) => void
+): EventSource => {
+  const url = `${API_BASE}/sse/${sessionId}`
+  const eventSource = new EventSource(url)
+  
+  // 监听连接建立事件
+  eventSource.addEventListener('connected', (event: MessageEvent) => {
+    console.log('用户交互SSE连接已建立:', event.data)
+  })
+  
+  // 监听消息事件
+  eventSource.addEventListener('message', (event: MessageEvent) => {
+    try {
+      const response: MessageResponse = JSON.parse(event.data)
+      onMessage(response)
+    } catch (error) {
+      console.error('解析SSE消息失败:', error)
+      // 如果JSON解析失败，创建一个简单的响应
+      const fallbackResponse: MessageResponse = {
+        nodeId: `fallback_${Date.now()}`,
+        content: event.data,
+        type: 'AI_QUESTION',
+        timestamp: Date.now()
+      }
+      onMessage(fallbackResponse)
+    }
+  })
+  
+  // 错误处理
+  eventSource.onerror = (error: Event) => {
+    console.error('用户交互SSE连接错误:', error)
+    if (onError) {
+      onError(error)
+    }
+  }
+  
+  return eventSource
+}
+
+/**
+ * 获取SSE连接状态
+ */
+export const getSseStatus = async (): Promise<SseStatus> => {
+  const url = `${API_BASE}/sse-status`
+  
+  try {
+    const response = await apiJsonRequest<SseStatus>(url, {
+      method: 'GET',
+      requireAuth: false
+    })
+    
+    return response
+  } catch (error) {
+    console.error('获取SSE状态失败:', error)
+    throw error
+  }
+}
+
+/**
+ * 重试请求
+ */
+export const retryRequest = async (request: {
+  nodeId: string
+  sessionId: string
+  whyretry: string
+}): Promise<any> => {
+  const url = `${API_BASE}/retry`
+  
+  try {
+    const response = await apiJsonRequest<any>(url, {
+      method: 'POST',
+      body: JSON.stringify(request),
+      headers: {
+        'Content-Type': 'application/json'
+      },
+      requireAuth: false
+    })
+    
+    return response
+  } catch (error) {
+    console.error('重试请求失败:', error)
+    throw error
+  }
+}
+
+/**
+ * 关闭SSE连接
+ */
+export const closeUserInteractionSSE = (eventSource: EventSource | null) => {
+  if (eventSource) {
+    eventSource.close()
+    console.log('用户交互SSE连接已关闭')
+  }
+}
+
+// 工具函数：创建不同类型的答案请求
+export const createAnswerRequest = {
+  /**
+   * 创建单选题答案请求
+   */
+  single: (sessionId: string | null, nodeId: string | null, userId: string, selectedOption: string): UnifiedAnswerRequest => ({
+    sessionId,
+    nodeId,
+    userId,
+    questionType: 'single',
+    answer: [selectedOption]
+  }),
+  
+  /**
+   * 创建多选题答案请求
+   */
+  multi: (sessionId: string | null, nodeId: string | null, userId: string, selectedOptions: string[]): UnifiedAnswerRequest => ({
+    sessionId,
+    nodeId,
+    userId,
+    questionType: 'multi',
+    answer: selectedOptions
+  }),
+  
+  /**
+   * 创建输入框答案请求
+   */
+  input: (sessionId: string | null, nodeId: string | null, userId: string, inputText: string): UnifiedAnswerRequest => ({
+    sessionId,
+    nodeId,
+    userId,
+    questionType: 'input',
+    answer: inputText
+  }),
+  
+  /**
+   * 创建表单答案请求
+   */
+  form: (sessionId: string | null, nodeId: string | null, userId: string, formAnswers: FormAnswerItem[]): UnifiedAnswerRequest => ({
+    sessionId,
+    nodeId,
+    userId,
+    questionType: 'form',
+    answer: formAnswers
+  })
+}
+
+// 导出所有类型和函数
+export {
+  type UnifiedAnswerRequest as UnifiedAnswerRequestType,
+  type FormAnswerItem as FormAnswerItemType,
+  type MessageResponse as MessageResponseType,
+  type SseStatus as SseStatusType
+}
\ No newline at end of file
diff --git a/prompto-lab-ui/src/views/ApiConfigView.vue b/prompto-lab-ui/src/views/ApiConfigView.vue
index f08be12..5c791a0 100644
--- a/prompto-lab-ui/src/views/ApiConfigView.vue
+++ b/prompto-lab-ui/src/views/ApiConfigView.vue
@@ -1,9 +1,20 @@
 <template>
   <div class="api-config">
-    <!-- 简化的页面头部 -->
+    <!-- 动态背景 -->
+    <div class="background-container">
+      <div class="gradient-orb orb-1"></div>
+      <div class="gradient-orb orb-2"></div>
+      <div class="gradient-orb orb-3"></div>
+      <div class="floating-particles">
+        <div class="particle" v-for="i in 8" :key="i" :style="getParticleStyle(i)"></div>
+      </div>
+    </div>
+
+    <!-- 页面头部 -->
     <div class="page-header">
       <div class="header-content">
         <button @click="goBack" class="back-btn">
+          <div class="btn-background"></div>
           <span class="back-icon">←</span>
           <span>返回设置</span>
         </button>
@@ -15,8 +26,9 @@
 
     <!-- 主要内容区域 -->
     <div class="main-content">
-      <!-- 左侧Tab导航栏 (15%) -->
+      <!-- 左侧Tab导航栏 -->
       <div class="sidebar">
+        <div class="sidebar-background"></div>
         <div class="tab-navigation">
           <div class="tab-header">
             <h3>配置导航</h3>
@@ -29,7 +41,7 @@
               @click="switchTab(tab.key)"
             >
               <div class="tab-icon">
-                <div class="icon-svg" v-html="tab.icon"></div>
+                <div v-html="tab.icon"></div>
               </div>
               <div class="tab-content">
                 <div class="tab-title">{{ tab.title }}</div>
@@ -42,6 +54,7 @@
 
         <!-- 系统状态卡片 -->
         <div class="status-card">
+          <div class="card-background"></div>
           <div class="status-header">
             <span class="status-icon">📊</span>
             <span class="status-title">系统状态</span>
@@ -58,8 +71,9 @@
           </div>
         </div>
 
-        <!-- 紧凑的统计信息卡片 -->
+        <!-- 统计信息卡片 -->
         <div class="stats-card">
+          <div class="card-background"></div>
           <div class="stats-header">
             <span class="stats-icon">📈</span>
             <span class="stats-title">统计信息</span>
@@ -82,10 +96,13 @@
       </div>
 
       <!-- 分隔线 -->
-      <div class="divider"></div>
+      <div class="divider">
+        <div class="divider-glow"></div>
+      </div>
 
-      <!-- 右侧内容区域 (85%) -->
+      <!-- 右侧内容区域 -->
       <div class="content-area">
+        <div class="content-background"></div>
         <!-- API信息配置组件 -->
         <ApiInfoConfig
           v-if="activeTab === 'api'"
@@ -100,13 +117,6 @@
           @update-overview="handleOverviewUpdate"
         />
 
-        <!-- AI调用日志组件 -->
-        <AICallLogViewer
-          v-if="activeTab === 'logs'"
-          :system-overview="systemOverview"
-          @update-overview="handleOverviewUpdate"
-        />
-
         <!-- 系统管理组件 -->
         <SystemManagement
           v-if="activeTab === 'system'"
@@ -121,16 +131,14 @@
 <script setup lang="ts">
 import { ref, onMounted } from 'vue'
 import { useRouter } from 'vue-router'
-import ApiInfoConfig from '@/components/SFChain/ApiInfoConfig.vue'
-import AiNodeConfig from '@/components/Chat/AiNodeConfig.vue'
-import SystemManagement from '@/components/SFChain/SystemManagement.vue'
-import AICallLogViewer from '@/components/SFChain/AICallLogViewer.vue'
-import { systemApi } from '@/services/systemApi' // 导入系统API服务
-import type { SystemOverview } from '@/types/system'
+import ApiInfoConfig from '@/components/ApiInfoConfig.vue'
+import AiNodeConfig from '@/components/AiNodeConfig.vue'
+import SystemManagement from '@/components/SystemManagement.vue'
+import type { SystemOverview, ApiResponse } from '@/types/system'
 
 const router = useRouter()
 
-// Tab配置 - 优化后的图标
+// Tab配置
 const tabs = [
   {
     key: 'api',
@@ -167,17 +175,20 @@ const tabs = [
     </svg>`
   },
   {
-    key: 'logs',
-    title: 'AI日志',
-    description: '查看AI调用日志',
+    key: 'system',
+    title: '系统管理',
+    description: '系统维护操作',
     icon: `<svg viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg">
-      <path d="M14 2H6a2 2 0 0 0-2 2v16a2 2 0 0 0 2 2h12a2 2 0 0 0 2-2V8z" stroke="currentColor" stroke-width="2" stroke-linejoin="round"/>
-      <polyline points="14,2 14,8 20,8" stroke="currentColor" stroke-width="2" stroke-linejoin="round"/>
-      <line x1="16" y1="13" x2="8" y2="13" stroke="currentColor" stroke-width="2" stroke-linecap="round"/>
-      <line x1="16" y1="17" x2="8" y2="17" stroke="currentColor" stroke-width="2" stroke-linecap="round"/>
-      <polyline points="10,9 9,9 8,9" stroke="currentColor" stroke-width="2" stroke-linecap="round"/>
-      <circle cx="12" cy="13" r="1" fill="currentColor" opacity="0.6"/>
-      <circle cx="12" cy="17" r="1" fill="currentColor" opacity="0.6"/>
+      <circle cx="12" cy="12" r="3" stroke="currentColor" stroke-width="2"/>
+      <path d="M19.4 15A1.65 1.65 0 0 0 21 13.09A1.65 1.65 0 0 0 19.4 9" stroke="currentColor" stroke-width="2"/>
+      <path d="M4.6 9A1.65 1.65 0 0 0 3 10.91A1.65 1.65 0 0 0 4.6 15" stroke="currentColor" stroke-width="2"/>
+      <path d="M15 4.6A1.65 1.65 0 0 0 13.09 3A1.65 1.65 0 0 0 9 4.6" stroke="currentColor" stroke-width="2"/>
+      <path d="M9 19.4A1.65 1.65 0 0 0 10.91 21A1.65 1.65 0 0 0 15 19.4" stroke="currentColor" stroke-width="2"/>
+      <circle cx="12" cy="12" r="1" fill="currentColor"/>
+      <path d="M12 8V7" stroke="currentColor" stroke-width="1.5" stroke-linecap="round" opacity="0.7"/>
+      <path d="M12 17V16" stroke="currentColor" stroke-width="1.5" stroke-linecap="round" opacity="0.7"/>
+      <path d="M16 12H17" stroke="currentColor" stroke-width="1.5" stroke-linecap="round" opacity="0.7"/>
+      <path d="M7 12H8" stroke="currentColor" stroke-width="1.5" stroke-linecap="round" opacity="0.7"/>
     </svg>`
   }
 ]
@@ -191,13 +202,28 @@ const systemOverview = ref<SystemOverview>({
   enabledModels: 0,
   configuredOperations: 0,
   totalOperations: 0,
-  enabledOperations: 0,  // 添加这个字段
   lastUpdate: Date.now()
 })
 
 // API基础URL
 const API_BASE = '/sf/api'
 
+// 粒子样式生成
+const getParticleStyle = (index: number) => {
+  const size = Math.random() * 3 + 1
+  const left = Math.random() * 100
+  const animationDelay = Math.random() * 6
+  const animationDuration = Math.random() * 3 + 4
+
+  return {
+    width: `${size}px`,
+    height: `${size}px`,
+    left: `${left}%`,
+    animationDelay: `${animationDelay}s`,
+    animationDuration: `${animationDuration}s`
+  }
+}
+
 // Tab切换
 const switchTab = (tabKey: string) => {
   activeTab.value = tabKey
@@ -214,11 +240,14 @@ const formatTime = (timestamp: number) => {
   return new Date(timestamp).toLocaleString()
 }
 
-// 获取系统概览 - 使用API服务
+// 获取系统概览
 const fetchSystemOverview = async () => {
   try {
-    const data = await systemApi.getSystemOverview()
-    systemOverview.value = data
+    const response = await fetch(`${API_BASE}/overview`)
+    const result: ApiResponse<SystemOverview> = await response.json()
+    if (result.success && result.data) {
+      systemOverview.value = result.data
+    }
   } catch (error: unknown) {
     const errorMessage = error instanceof Error ? error.message : '获取系统概览失败'
     console.error('Failed to fetch system overview:', errorMessage)
@@ -237,44 +266,105 @@ onMounted(() => {
 </script>
 
 <style scoped>
-/* 基础样式 - 黑金主题 */
 .api-config {
   min-height: 100vh;
   background: linear-gradient(135deg, #0a0a0a 0%, #1a1a1a 100%);
-  color: #ffffff;
-  padding: 1rem;
+  color: #e8e8e8;
+  font-family: 'Inter', 'SF Pro Display', -apple-system, BlinkMacSystemFont, sans-serif;
   position: relative;
-  overflow-x: hidden;
+  overflow: hidden;
 }
 
-/* 动态背景效果 */
-.api-config::before {
-  content: '';
+/* 动态背景 */
+.background-container {
   position: fixed;
   top: 0;
   left: 0;
   width: 100%;
   height: 100%;
-  background:
-    radial-gradient(circle at 20% 20%, rgba(212, 175, 55, 0.1) 0%, transparent 50%),
-    radial-gradient(circle at 80% 80%, rgba(255, 215, 0, 0.08) 0%, transparent 50%),
-    radial-gradient(circle at 40% 60%, rgba(184, 134, 11, 0.06) 0%, transparent 50%);
-  pointer-events: none;
   z-index: 1;
+  pointer-events: none;
+}
+
+.gradient-orb {
+  position: absolute;
+  border-radius: 50%;
+  filter: blur(60px);
+  opacity: 0.2;
+  animation: float 20s ease-in-out infinite;
+}
+
+.orb-1 {
+  width: 300px;
+  height: 300px;
+  background: linear-gradient(45deg, #d4af37, #ffd700);
+  top: 15%;
+  left: 15%;
+  animation-delay: 0s;
+}
+
+.orb-2 {
+  width: 250px;
+  height: 250px;
+  background: linear-gradient(45deg, #c0c0c0, #ffffff);
+  top: 50%;
+  right: 15%;
+  animation-delay: -10s;
+}
+
+.orb-3 {
+  width: 180px;
+  height: 180px;
+  background: linear-gradient(45deg, #d4af37, #b8860b);
+  bottom: 25%;
+  left: 60%;
+  animation-delay: -5s;
 }
 
-/* 页面头部样式 */
+@keyframes float {
+  0%, 100% {
+    transform: translate(0, 0) rotate(0deg);
+  }
+  33% {
+    transform: translate(20px, -20px) rotate(120deg);
+  }
+  66% {
+    transform: translate(-15px, 15px) rotate(240deg);
+  }
+}
+
+.floating-particles {
+  position: absolute;
+  width: 100%;
+  height: 100%;
+}
+
+.particle {
+  position: absolute;
+  background: linear-gradient(45deg, #d4af37, #ffd700);
+  border-radius: 50%;
+  opacity: 0.4;
+  animation: particle-float 6s ease-in-out infinite;
+}
+
+@keyframes particle-float {
+  0%, 100% {
+    transform: translateY(0) rotate(0deg);
+    opacity: 0;
+  }
+  10%, 90% {
+    opacity: 0.4;
+  }
+  50% {
+    transform: translateY(-80px) rotate(180deg);
+    opacity: 0.8;
+  }
+}
+
+/* 页面头部 */
 .page-header {
-  background: rgba(26, 26, 26, 0.9);
-  border: 1px solid rgba(212, 175, 55, 0.2);
-  border-radius: 16px;
-  padding: 1rem 2rem;
-  margin-bottom: 1.5rem;
-  box-shadow:
-    0 8px 32px rgba(0, 0, 0, 0.3),
-    0 0 0 1px rgba(212, 175, 55, 0.1),
-    inset 0 1px 0 rgba(255, 255, 255, 0.1);
-  backdrop-filter: blur(20px);
+  padding: 40px 40px 0;
+  margin-bottom: 40px;
   position: relative;
   z-index: 2;
 }
@@ -282,165 +372,217 @@ onMounted(() => {
 .header-content {
   display: flex;
   align-items: center;
-  gap: 2rem;
+  gap: 32px;
+  background: rgba(8, 8, 8, 0.85);
+  backdrop-filter: blur(24px) saturate(180%);
+  border: 1px solid rgba(212, 175, 55, 0.2);
+  border-radius: 20px;
+  padding: 24px 32px;
+  box-shadow:
+    0 8px 32px rgba(0, 0, 0, 0.4),
+    0 0 0 1px rgba(255, 255, 255, 0.02),
+    inset 0 1px 0 rgba(255, 255, 255, 0.08);
+  max-width: 1400px;
+  margin: 0 auto;
+  position: relative;
+  overflow: hidden;
+}
+
+.header-content::before {
+  content: '';
+  position: absolute;
+  top: 0;
+  left: 0;
+  right: 0;
+  bottom: 0;
+  background: linear-gradient(135deg,
+    rgba(212, 175, 55, 0.03) 0%,
+    transparent 30%,
+    transparent 70%,
+    rgba(212, 175, 55, 0.03) 100%
+  );
+  animation: header-shimmer 8s ease-in-out infinite;
+}
+
+@keyframes header-shimmer {
+  0%, 100% { opacity: 0.5; }
+  50% { opacity: 1; }
 }
 
 .back-btn {
-  background: rgba(212, 175, 55, 0.1);
-  border: 1px solid rgba(212, 175, 55, 0.3);
+  background: none;
+  border: none;
   display: flex;
   align-items: center;
-  gap: 0.5rem;
+  gap: 12px;
   color: #d4af37;
   font-weight: 600;
   cursor: pointer;
-  padding: 0.75rem 1.5rem;
+  padding: 12px 20px;
   border-radius: 12px;
   transition: all 0.3s ease;
   flex-shrink: 0;
+  position: relative;
+  overflow: hidden;
+  border: 1px solid rgba(212, 175, 55, 0.2);
+  z-index: 2;
+}
+
+.btn-background {
+  position: absolute;
+  top: 0;
+  left: 0;
+  right: 0;
+  bottom: 0;
+  background: linear-gradient(135deg, rgba(212, 175, 55, 0.1), transparent);
+  opacity: 0;
+  transition: opacity 0.3s ease;
 }
 
 .back-btn:hover {
-  background: rgba(212, 175, 55, 0.2);
-  border-color: rgba(212, 175, 55, 0.5);
-  transform: translateX(-2px);
+  border-color: rgba(212, 175, 55, 0.4);
+  transform: translateX(-4px);
   box-shadow: 0 4px 16px rgba(212, 175, 55, 0.2);
 }
 
+.back-btn:hover .btn-background {
+  opacity: 1;
+}
+
 .back-icon {
   font-size: 1.2rem;
-  color: #d4af37;
+  transition: transform 0.3s ease;
+}
+
+.back-btn:hover .back-icon {
+  transform: translateX(-2px);
 }
 
 .header-text {
   flex: 1;
+  z-index: 2;
+  position: relative;
 }
 
 .header-text h1 {
-  font-size: 1.8rem;
+  font-size: 2rem;
   font-weight: 700;
-  background: linear-gradient(135deg, #ffffff, #d4af37);
+  background: linear-gradient(135deg, #ffffff 0%, #d4af37 50%, #f4d03f 100%);
   -webkit-background-clip: text;
   -webkit-text-fill-color: transparent;
   background-clip: text;
-  margin: 0;
+  margin: 0 0 4px 0;
   letter-spacing: -0.5px;
 }
 
+.header-text p {
+  font-size: 0.95rem;
+  color: #a0a0a0;
+  margin: 0;
+  font-weight: 400;
+}
+
 /* 主要内容区域 */
 .main-content {
   display: flex;
   gap: 0;
-  height: calc(100vh - 140px);
+  height: calc(100vh - 200px);
+  padding: 0 40px 40px;
   position: relative;
   z-index: 2;
 }
 
 /* 左侧导航栏 */
 .sidebar {
-  width: 15%;
-  background: rgba(26, 26, 26, 0.9);
+  width: 320px;
+  background: rgba(8, 8, 8, 0.85);
+  backdrop-filter: blur(24px) saturate(180%);
   border: 1px solid rgba(212, 175, 55, 0.2);
-  border-radius: 16px 0 0 16px;
-  padding: 2rem 1.5rem;
+  border-radius: 20px 0 0 20px;
+  padding: 32px 24px;
   box-shadow:
-    0 8px 32px rgba(0, 0, 0, 0.3),
-    inset 0 1px 0 rgba(255, 255, 255, 0.1);
-  backdrop-filter: blur(20px);
+    0 8px 32px rgba(0, 0, 0, 0.4),
+    0 0 0 1px rgba(255, 255, 255, 0.02),
+    inset 0 1px 0 rgba(255, 255, 255, 0.08);
   border-right: none;
   overflow-y: auto;
   display: flex;
   flex-direction: column;
+  position: relative;
+}
+
+.sidebar-background {
+  position: absolute;
+  top: 0;
+  left: 0;
+  right: 0;
+  bottom: 0;
+  background: linear-gradient(135deg,
+    rgba(212, 175, 55, 0.03) 0%,
+    transparent 30%,
+    transparent 70%,
+    rgba(212, 175, 55, 0.03) 100%
+  );
+  animation: sidebar-shimmer 10s ease-in-out infinite;
+}
+
+@keyframes sidebar-shimmer {
+  0%, 100% { opacity: 0.3; }
+  50% { opacity: 0.7; }
 }
 
 .tab-navigation {
   flex: 1;
+  position: relative;
+  z-index: 2;
 }
 
 .tab-header {
-  margin-bottom: 1.5rem;
+  margin-bottom: 24px;
 }
 
 .tab-header h3 {
   font-size: 1.25rem;
   font-weight: 600;
-  background: linear-gradient(135deg, #ffffff, #d4af37);
-  -webkit-background-clip: text;
-  -webkit-text-fill-color: transparent;
-  background-clip: text;
+  color: #ffffff;
   margin: 0;
 }
 
 .tab-list {
   display: flex;
   flex-direction: column;
-  gap: 0.5rem;
+  gap: 8px;
 }
 
 .tab-item {
   position: relative;
-  padding: 1rem;
-  border-radius: 12px;
+  padding: 16px;
+  border-radius: 16px;
   cursor: pointer;
   transition: all 0.3s ease;
   border: 1px solid transparent;
   display: flex;
   align-items: center;
-  gap: 1rem;
+  gap: 16px;
   background: rgba(255, 255, 255, 0.02);
 }
 
 .tab-item:hover {
   background: rgba(212, 175, 55, 0.1);
-  border-color: rgba(212, 175, 55, 0.3);
+  border-color: rgba(212, 175, 55, 0.2);
   transform: translateX(4px);
-  box-shadow: 0 4px 16px rgba(212, 175, 55, 0.1);
 }
 
 .tab-item.active {
-  background: linear-gradient(135deg, rgba(212, 175, 55, 0.15), rgba(255, 215, 0, 0.1));
-  border-color: #d4af37;
-  box-shadow:
-    0 8px 24px rgba(212, 175, 55, 0.2),
-    inset 0 1px 0 rgba(255, 255, 255, 0.1);
+  background: linear-gradient(135deg, rgba(212, 175, 55, 0.15), rgba(212, 175, 55, 0.05));
+  border-color: rgba(212, 175, 55, 0.4);
+  box-shadow: 0 4px 16px rgba(212, 175, 55, 0.2);
 }
 
 .tab-icon {
-  min-width: 2rem;
+  font-size: 1.25rem;
+  min-width: 24px;
   text-align: center;
-  display: flex;
-  align-items: center;
-  justify-content: center;
-}
-
-.icon-svg {
-  width: 24px;
-  height: 24px;
-  color: #a0a0a0;
-  transition: all 0.3s ease;
-  display: flex;
-  align-items: center;
-  justify-content: center;
-}
-
-.icon-svg svg {
-  width: 100%;
-  height: 100%;
-  transition: all 0.3s ease;
-}
-
-.tab-item:hover .icon-svg {
-  color: #d4af37;
-  transform: scale(1.1);
-}
-
-.tab-item.active .icon-svg {
-  color: #d4af37;
-  transform: scale(1.15);
-}
-
-.tab-item.active .icon-svg svg {
-  filter: drop-shadow(0 2px 8px rgba(212, 175, 55, 0.4));
 }
 
 .tab-content {
@@ -450,80 +592,98 @@ onMounted(() => {
 .tab-title {
   font-weight: 600;
   color: #ffffff;
-  margin-bottom: 0.25rem;
-  font-size: 0.9rem;
+  margin-bottom: 4px;
+  font-size: 0.95rem;
 }
 
 .tab-description {
-  font-size: 0.75rem;
+  font-size: 0.8rem;
   color: #a0a0a0;
   line-height: 1.3;
 }
 
-.tab-item.active .tab-title {
-  color: #d4af37;
-}
-
 .tab-indicator {
   position: absolute;
-  right: 0.5rem;
+  right: 8px;
   top: 50%;
   transform: translateY(-50%);
-  width: 4px;
-  height: 20px;
-  background: linear-gradient(135deg, #d4af37, #ffd700);
+  width: 3px;
+  height: 16px;
+  background: linear-gradient(135deg, #d4af37, #f4d03f);
   border-radius: 2px;
   opacity: 0;
   transition: opacity 0.3s ease;
-  box-shadow: 0 0 8px rgba(212, 175, 55, 0.5);
 }
 
 .tab-item.active .tab-indicator {
   opacity: 1;
 }
 
-/* 系统状态卡片 */
-.status-card {
-  background: rgba(26, 26, 26, 0.8);
-  border: 1px solid rgba(212, 175, 55, 0.2);
-  border-radius: 12px;
-  padding: 1rem;
-  margin-bottom: 0.75rem;
-  box-shadow:
-    0 4px 16px rgba(0, 0, 0, 0.2),
-    inset 0 1px 0 rgba(255, 255, 255, 0.1);
+/* 状态和统计卡片 */
+.status-card,
+.stats-card {
+  background: rgba(255, 255, 255, 0.05);
+  border: 1px solid rgba(255, 255, 255, 0.1);
+  border-radius: 16px;
+  padding: 20px;
+  margin-bottom: 16px;
+  position: relative;
+  z-index: 2;
   backdrop-filter: blur(10px);
+  transition: all 0.3s ease;
 }
 
-.status-card:hover {
-  border-color: rgba(212, 175, 55, 0.4);
-  box-shadow:
-    0 8px 24px rgba(0, 0, 0, 0.3),
-    0 0 0 1px rgba(212, 175, 55, 0.1),
-    inset 0 1px 0 rgba(255, 255, 255, 0.1);
+.status-card:hover,
+.stats-card:hover {
+  background: rgba(212, 175, 55, 0.08);
+  border-color: rgba(212, 175, 55, 0.2);
 }
 
-.status-header {
+.card-background {
+  position: absolute;
+  top: 0;
+  left: 0;
+  right: 0;
+  bottom: 0;
+  background: linear-gradient(135deg, rgba(212, 175, 55, 0.05), transparent);
+  border-radius: 16px;
+  opacity: 0;
+  transition: opacity 0.3s ease;
+}
+
+.status-card:hover .card-background,
+.stats-card:hover .card-background {
+  opacity: 1;
+}
+
+.status-header,
+.stats-header {
   display: flex;
   align-items: center;
-  gap: 0.5rem;
-  margin-bottom: 0.75rem;
+  gap: 8px;
+  margin-bottom: 16px;
+  position: relative;
+  z-index: 2;
 }
 
-.status-icon {
+.status-icon,
+.stats-icon {
   font-size: 1rem;
 }
 
-.status-title {
+.status-title,
+.stats-title {
   font-weight: 600;
-  color: #d4af37;
-  font-size: 0.85rem;
+  color: #ffffff;
+  font-size: 0.9rem;
 }
 
 .status-content {
   display: flex;
   flex-direction: column;
-  gap: 0.5rem;
+  gap: 12px;
+  position: relative;
+  z-index: 2;
 }
 
 .status-item {
@@ -533,80 +693,43 @@ onMounted(() => {
 }
 
 .status-label {
-  font-size: 0.75rem;
+  font-size: 0.8rem;
   color: #a0a0a0;
 }
 
 .status-value {
-  font-size: 0.75rem;
+  font-size: 0.8rem;
   font-weight: 600;
   color: #ffffff;
 }
 
 .status-value.running {
-  color: #d4af37;
-  text-shadow: 0 0 8px rgba(212, 175, 55, 0.3);
-}
-
-/* 统计信息卡片 */
-.stats-card {
-  background: rgba(26, 26, 26, 0.8);
-  border: 1px solid rgba(212, 175, 55, 0.2);
-  border-radius: 12px;
-  padding: 1rem;
-  box-shadow:
-    0 4px 16px rgba(0, 0, 0, 0.2),
-    inset 0 1px 0 rgba(255, 255, 255, 0.1);
-  backdrop-filter: blur(10px);
-}
-
-.stats-card:hover {
-  border-color: rgba(212, 175, 55, 0.4);
-  box-shadow:
-    0 8px 24px rgba(0, 0, 0, 0.3),
-    0 0 0 1px rgba(212, 175, 55, 0.1),
-    inset 0 1px 0 rgba(255, 255, 255, 0.1);
-}
-
-.stats-header {
-  display: flex;
-  align-items: center;
-  gap: 0.5rem;
-  margin-bottom: 0.75rem;
-}
-
-.stats-icon {
-  font-size: 1rem;
-}
-
-.stats-title {
-  font-weight: 600;
-  color: #d4af37;
-  font-size: 0.85rem;
+  color: #22c55e;
 }
 
 .stats-grid {
   display: grid;
   grid-template-columns: 1fr;
-  gap: 0.5rem;
+  gap: 12px;
+  position: relative;
+  z-index: 2;
 }
 
 .stat-item {
   display: flex;
   justify-content: space-between;
   align-items: center;
-  padding: 0.5rem 0.75rem;
+  padding: 12px 16px;
   background: rgba(212, 175, 55, 0.1);
   border: 1px solid rgba(212, 175, 55, 0.2);
-  border-radius: 8px;
+  border-radius: 12px;
   transition: all 0.3s ease;
 }
 
 .stat-item:hover {
   background: rgba(212, 175, 55, 0.15);
-  border-color: rgba(212, 175, 55, 0.4);
-  transform: translateY(-1px);
-  box-shadow: 0 4px 12px rgba(212, 175, 55, 0.1);
+  border-color: rgba(212, 175, 55, 0.3);
+  transform: scale(1.02);
 }
 
 .stat-value {
@@ -614,72 +737,48 @@ onMounted(() => {
   font-weight: 700;
   color: #d4af37;
   line-height: 1;
-  text-shadow: 0 0 8px rgba(212, 175, 55, 0.3);
 }
 
 .stat-label {
-  font-size: 0.7rem;
+  font-size: 0.75rem;
   color: #a0a0a0;
   font-weight: 500;
 }
 
 /* 分隔线 */
 .divider {
-  width: 4px;
+  width: 2px;
   background: linear-gradient(
     45deg,
-    rgba(212, 175, 55, 0.3) 0%,
-    rgba(255, 215, 0, 0.5) 25%,
-    rgba(212, 175, 55, 0.7) 50%,
-    rgba(255, 215, 0, 0.5) 75%,
-    rgba(212, 175, 55, 0.3) 100%
+    rgba(212, 175, 55, 0.2) 0%,
+    rgba(212, 175, 55, 0.4) 25%,
+    rgba(212, 175, 55, 0.6) 50%,
+    rgba(212, 175, 55, 0.4) 75%,
+    rgba(212, 175, 55, 0.2) 100%
   );
   position: relative;
   overflow: hidden;
-  box-shadow:
-    0 0 20px rgba(212, 175, 55, 0.3),
-    inset 0 0 20px rgba(255, 215, 0, 0.2);
 }
 
-.divider::before {
-  content: '';
+.divider-glow {
   position: absolute;
   top: 0;
-  left: -2px;
-  right: -2px;
+  left: -1px;
+  right: -1px;
   bottom: 0;
   background: linear-gradient(
     45deg,
     transparent 0%,
-    rgba(255, 255, 255, 0.8) 25%,
-    rgba(255, 255, 255, 0.9) 50%,
-    rgba(255, 255, 255, 0.8) 75%,
+    rgba(212, 175, 55, 0.3) 25%,
+    rgba(212, 175, 55, 0.5) 50%,
+    rgba(212, 175, 55, 0.3) 75%,
     transparent 100%
   );
   filter: blur(2px);
-  animation: golden-shimmer 3s ease-in-out infinite;
-}
-
-.divider::after {
-  content: '';
-  position: absolute;
-  top: 0;
-  left: 0;
-  right: 0;
-  bottom: 0;
-  background: linear-gradient(
-    90deg,
-    rgba(212, 175, 55, 0.1) 0%,
-    rgba(255, 215, 0, 0.3) 50%,
-    rgba(212, 175, 55, 0.1) 100%
-  );
-  box-shadow:
-    0 0 10px rgba(212, 175, 55, 0.4),
-    0 0 20px rgba(255, 215, 0, 0.3),
-    0 0 30px rgba(212, 175, 55, 0.2);
+  animation: divider-pulse 3s ease-in-out infinite;
 }
 
-@keyframes golden-shimmer {
+@keyframes divider-pulse {
   0%, 100% {
     opacity: 0.5;
     transform: translateY(-100%);
@@ -693,51 +792,52 @@ onMounted(() => {
 /* 右侧内容区域 */
 .content-area {
   flex: 1;
-  width: 85%;
-  background: rgba(26, 26, 26, 0.9);
+  background: rgba(8, 8, 8, 0.85);
+  backdrop-filter: blur(24px) saturate(180%);
   border: 1px solid rgba(212, 175, 55, 0.2);
-  border-radius: 0 16px 16px 0;
-  padding: 2rem;
+  border-radius: 0 20px 20px 0;
+  padding: 32px;
   box-shadow:
-    0 8px 32px rgba(0, 0, 0, 0.3),
-    inset 0 1px 0 rgba(255, 255, 255, 0.1);
-  backdrop-filter: blur(20px);
+    0 8px 32px rgba(0, 0, 0, 0.4),
+    0 0 0 1px rgba(255, 255, 255, 0.02),
+    inset 0 1px 0 rgba(255, 255, 255, 0.08);
   border-left: none;
   overflow-y: auto;
   position: relative;
 }
 
-/* 内容区域背景效果 */
-.content-area::before {
-  content: '';
+.content-background {
   position: absolute;
   top: 0;
   left: 0;
   right: 0;
   bottom: 0;
-  background:
-    radial-gradient(circle at 10% 10%, rgba(212, 175, 55, 0.05) 0%, transparent 50%),
-    radial-gradient(circle at 90% 90%, rgba(255, 215, 0, 0.03) 0%, transparent 50%);
-  pointer-events: none;
-  border-radius: 0 16px 16px 0;
+  background: linear-gradient(135deg,
+    rgba(212, 175, 55, 0.02) 0%,
+    transparent 30%,
+    transparent 70%,
+    rgba(212, 175, 55, 0.02) 100%
+  );
+  animation: content-shimmer 12s ease-in-out infinite;
+}
+
+@keyframes content-shimmer {
+  0%, 100% { opacity: 0.3; }
+  50% { opacity: 0.8; }
 }
 
 /* 响应式设计 */
 @media (max-width: 1200px) {
   .sidebar {
-    width: 20%;
+    width: 280px;
   }
 
-  .content-area {
-    width: 80%;
-  }
-
-  .tab-title {
-    font-size: 0.85rem;
+  .main-content {
+    padding: 0 24px 40px;
   }
 
-  .tab-description {
-    font-size: 0.7rem;
+  .page-header {
+    padding: 40px 24px 0;
   }
 }
 
@@ -745,13 +845,24 @@ onMounted(() => {
   .main-content {
     flex-direction: column;
     height: auto;
+    padding: 0 16px 40px;
+  }
+
+  .page-header {
+    padding: 40px 16px 0;
+  }
+
+  .header-content {
+    flex-direction: column;
+    gap: 16px;
+    text-align: center;
   }
 
   .sidebar {
     width: 100%;
-    border-radius: 16px;
+    border-radius: 20px;
     border: 1px solid rgba(212, 175, 55, 0.2);
-    margin-bottom: 1rem;
+    margin-bottom: 20px;
   }
 
   .divider {
@@ -760,33 +871,28 @@ onMounted(() => {
 
   .content-area {
     width: 100%;
-    border-radius: 16px;
+    border-radius: 20px;
     border: 1px solid rgba(212, 175, 55, 0.2);
   }
 
-  .header-content {
-    flex-direction: column;
-    gap: 1rem;
-  }
-
   .stats-grid {
     grid-template-columns: repeat(3, 1fr);
-    gap: 0.25rem;
+    gap: 8px;
   }
 
   .stat-item {
     flex-direction: column;
     text-align: center;
-    padding: 0.5rem;
+    padding: 8px;
   }
 
   .stat-value {
     font-size: 1rem;
-    margin-bottom: 0.25rem;
+    margin-bottom: 4px;
   }
 
   .stat-label {
-    font-size: 0.65rem;
+    font-size: 0.7rem;
   }
 }
 </style>
diff --git a/prompto-lab-ui/vite.config.ts b/prompto-lab-ui/vite.config.ts
index 84bc658..4217010 100644
--- a/prompto-lab-ui/vite.config.ts
+++ b/prompto-lab-ui/vite.config.ts
@@ -12,8 +12,7 @@ export default defineConfig({
   ],
   resolve: {
     alias: {
-      '@': fileURLToPath(new URL('./src', import.meta.url)),
-      'vue': 'vue/dist/vue.esm-bundler.js'
+      '@': fileURLToPath(new URL('./src', import.meta.url))
     },
   },
 })

From 8847d1e56a98d37e5ab17a77db0c6fd5dafa9de3 Mon Sep 17 00:00:00 2001
From: welsir <1824379011@qq.com>
Date: Thu, 21 Aug 2025 01:23:43 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=E4=BC=9A=E8=AF=9D=E8=81=94=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/UserInteractionController.java |  29 +++--
 .../application/ConversationService.java      |   7 +-
 .../src/components/Chat/AIChatPage.vue        |  59 ++++++---
 .../src/services/conversationApi.ts           | 112 +++++++++++++++++-
 .../src/services/userInteractionApi.ts        |   3 +-
 5 files changed, 175 insertions(+), 35 deletions(-)

diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/controller/UserInteractionController.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/controller/UserInteractionController.java
index 6b9bf46..0417800 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/controller/UserInteractionController.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/controller/UserInteractionController.java
@@ -4,6 +4,7 @@
 import io.github.timemachinelab.core.session.application.MessageProcessingService;
 import io.github.timemachinelab.core.session.application.SessionManagementService;
 import io.github.timemachinelab.core.session.domain.entity.ConversationSession;
+import io.github.timemachinelab.core.session.infrastructure.ai.QuestionGenerationOperation;
 import io.github.timemachinelab.core.session.infrastructure.web.dto.UnifiedAnswerRequest;
 import io.github.timemachinelab.core.session.infrastructure.web.dto.MessageResponse;
 import io.github.timemachinelab.entity.req.RetryRequest;
@@ -20,6 +21,7 @@
 import javax.validation.Valid;
 import java.io.IOException;
 import java.util.Map;
+import java.util.UUID;
 import java.util.concurrent.ConcurrentHashMap;
 
 /**
@@ -46,10 +48,13 @@ public class UserInteractionController {
     /**
      * 建立SSE连接
      */
-    @GetMapping(value = "/sse/{sessionId}", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
-    public SseEmitter streamConversation(@PathVariable String sessionId) {
+    @GetMapping(value = "/sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    public SseEmitter streamConversation(@RequestParam(required = false) String sessionId) {
         log.info("建立SSE连接 - 会话ID: {}", sessionId);
-        
+
+        if(sessionId == null || sessionId.isEmpty()) {
+            sessionId = UUID.randomUUID().toString();
+        }
         SseEmitter emitter = new SseEmitter(Long.MAX_VALUE);
         sseEmitters.put(sessionId, emitter);
         
@@ -63,19 +68,19 @@ public SseEmitter streamConversation(@PathVariable String sessionId) {
         }
         
         // 设置连接事件处理
+        String finalSessionId = sessionId;
         emitter.onCompletion(() -> {
-            log.info("SSE连接完成: {}", sessionId);
-            sseEmitters.remove(sessionId);
+            log.info("SSE连接完成: {}", finalSessionId);
         });
-        
+
         emitter.onTimeout(() -> {
-            log.info("SSE连接超时: {}", sessionId);
-            sseEmitters.remove(sessionId);
+            log.info("SSE连接超时: {}", finalSessionId);
+            sseEmitters.remove(finalSessionId);
         });
         
         emitter.onError((ex) -> {
-            log.error("SSE连接错误: {} - {}", sessionId, ex.getMessage());
-            sseEmitters.remove(sessionId);
+            log.error("SSE连接错误: {} - {}", finalSessionId, ex.getMessage());
+            sseEmitters.remove(finalSessionId);
         });
         
         return emitter;
@@ -171,14 +176,14 @@ public ResponseEntity<String> processAnswer(@Validated @RequestBody UnifiedAnswe
      * @param sessionId 会话ID
      * @param response 消息响应对象
      */
-    private void sendSseMessage(String sessionId, MessageResponse response) {
+    private void sendSseMessage(String sessionId, QuestionGenerationOperation.QuestionGenerationResponse response) {
         SseEmitter emitter = sseEmitters.get(sessionId);
         if (emitter != null) {
             try {
                 emitter.send(SseEmitter.event()
                     .name("message")
                     .data(response));
-                log.debug("SSE消息发送成功 - 会话: {}, 消息类型: {}", sessionId, response.getType());
+                log.info("SSE消息发送成功 - 会话: {}, 消息: {}", sessionId, response);
             } catch (IOException e) {
                 log.error("SSE消息发送失败 - 会话: {}, 错误: {}", sessionId, e.getMessage());
                 sseEmitters.remove(sessionId);
diff --git a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/ConversationService.java b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/ConversationService.java
index 80fcd9b..3bc82d3 100644
--- a/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/ConversationService.java
+++ b/prompto-lab-app/src/main/java/io/github/timemachinelab/core/session/application/ConversationService.java
@@ -34,7 +34,7 @@ public class ConversationService {
     private final QaTreeDomain qaTreeDomain;
 
     
-    public void processUserMessage(String userId, String userMessage, Consumer<MessageResponse> sseCallback) {
+    public void processUserMessage(String userId, String userMessage, Consumer<QuestionGenerationOperation.QuestionGenerationResponse> sseCallback) {
         ConversationSession session = sessionManagementService.getUserCurrentSession(userId);
         if (session == null) {
             log.warn("会话不存在");
@@ -44,7 +44,7 @@ public void processUserMessage(String userId, String userMessage, Consumer<Messa
         processAIResponse(userMessage, sseCallback);
     }
     
-    private void processAIResponse(String userMessage, Consumer<MessageResponse> sseCallback) {
+    private void processAIResponse(String userMessage, Consumer<QuestionGenerationOperation.QuestionGenerationResponse> sseCallback) {
         try {
 
             JSONObject object = JSON.parseObject(userMessage);
@@ -53,6 +53,8 @@ private void processAIResponse(String userMessage, Consumer<MessageResponse> sse
             QuestionGenerationOperation.QuestionGenerationRequest request = new QuestionGenerationOperation.QuestionGenerationRequest(object.getString("prompt"),object.getString("tree"),object.getString("input"));
             // 调用AI服务
             QuestionGenerationOperation.QuestionGenerationResponse aiResponse = aiService.execute("QUESTION_GENERATION_OP", request);
+
+            sseCallback.accept(aiResponse);
             log.info("AI服务调用成功: {}", aiResponse);
             
         } catch (Exception e) {
@@ -60,7 +62,6 @@ private void processAIResponse(String userMessage, Consumer<MessageResponse> sse
             // 降级处理
             String fallbackResponse = "抱歉，我暂时无法处理您的请求，请稍后再试。";
             String nodeId = "ai_" + System.currentTimeMillis();
-            sseCallback.accept(MessageResponse.aiQuestion(nodeId, fallbackResponse));
         }
     }
 
diff --git a/prompto-lab-ui/src/components/Chat/AIChatPage.vue b/prompto-lab-ui/src/components/Chat/AIChatPage.vue
index 07a5407..605a681 100644
--- a/prompto-lab-ui/src/components/Chat/AIChatPage.vue
+++ b/prompto-lab-ui/src/components/Chat/AIChatPage.vue
@@ -74,10 +74,10 @@
 
 <script setup lang="ts">
 import { ref, computed, onMounted, onUnmounted } from 'vue'
-import QuestionRenderer from './QuestionRenderer.vue'
+import QuestionRenderer from '../QuestionRenderer.vue'
 import ChatTree from './ChatTree.vue'
 import MindMapTree from './MindMapTree.vue'
-import { startConversation, sendMessage, connectSSE, closeSSE, type MessageRequest, type MessageResponse, type ConversationSession } from '@/services/conversationApi'
+import { startConversation, sendMessage, sendUserMessage, connectSSE, closeSSE, processAnswer, connectUserInteractionSSE, type MessageRequest, type MessageResponse, type ConversationSession, type UnifiedAnswerRequest, type FormAnswerItem } from '@/services/conversationApi'
 import { toast } from '@/utils/toast'
 
 interface Message {
@@ -140,7 +140,7 @@ const initializeSession = async () => {
     session.value = await startConversation(userId)
 
     // 建立SSE连接
-    eventSource.value = connectSSE(
+    eventSource.value = connectUserInteractionSSE(
       session.value.sessionId,
       handleSSEMessage,
       handleSSEError
@@ -236,7 +236,7 @@ const handleSSEError = (error: Event) => {
   // 尝试重连
   setTimeout(() => {
     if (session.value && !isConnected.value) {
-      eventSource.value = connectSSE(
+      eventSource.value = connectUserInteractionSSE(
         session.value.sessionId,
         handleSSEMessage,
         handleSSEError
@@ -267,7 +267,6 @@ const addAIMessage = (nodeId: string, content: string) => {
   isLoading.value = false
 }
 
-// 添加AI选择题消息
 const addAISelectionMessage = (nodeId: string, content: string, options: string[]) => {
   // 暂时作为普通消息处理，后续可以扩展选择题UI
   const fullContent = content + '\n\n选项：\n' + options.map((opt, idx) => `${idx + 1}. ${opt}`).join('\n')
@@ -434,7 +433,7 @@ const handleSendMessage = async (content: string) => {
       type: 'USER_TEXT'
     }
 
-    await sendMessage(messageRequest)
+    await sendUserMessage(messageRequest)
 
     // 消息发送成功，等待SSE返回AI回复
     console.log('消息已发送，等待AI回复...')
@@ -462,10 +461,10 @@ const handleSendMessage = async (content: string) => {
 
 // 处理答案提交
 const handleSubmitAnswer = async (answerData: any) => {
-  if (!session.value || !isConnected.value || !currentQuestion.value) {
+  if (!session.value || !currentQuestion.value) {
     toast.error({
       title: '提交失败',
-      message: '会话状态异常，请重新开始',
+      message: '会话未建立或没有当前问题',
       duration: 3000
     })
     return
@@ -474,9 +473,23 @@ const handleSubmitAnswer = async (answerData: any) => {
   isLoading.value = true
 
   try {
-    // 构建答案消息
-    let answerContent = ''
+    // 构建统一答案请求
+    const request: UnifiedAnswerRequest = {
+      sessionId: session.value.sessionId,
+      nodeId: currentNodeId.value,
+      questionType: currentQuestion.value.type,
+      answer: answerData,
+      userId: session.value.userId
+    }
+
+    // 调用新的processAnswer接口
+    await processAnswer(request)
 
+    // 添加用户答案到对话树
+    const userNodeId = `user_${Date.now()}`
+    let answerContent = ''
+    
+    // 根据问题类型格式化答案内容
     switch (currentQuestion.value.type) {
       case 'input':
         answerContent = `回答：${answerData}`
@@ -506,14 +519,30 @@ const handleSubmitAnswer = async (answerData: any) => {
         break
     }
 
-    // 发送答案到后端
-    const messageRequest: MessageRequest = {
-      sessionId: session.value.sessionId,
+    const userNode: ConversationNode = {
+      id: userNodeId,
       content: answerContent,
-      type: 'USER_ANSWER'
+      type: 'user',
+      timestamp: new Date(),
+      parentId: currentNodeId.value,
+      children: [],
+      isActive: true
+    }
+
+    const currentNode = conversationTree.value.get(currentNodeId.value)
+    if (currentNode) {
+      // 将当前节点的其他子节点设为非活跃状态
+      currentNode.children.forEach(childId => {
+        const childNode = conversationTree.value.get(childId)
+        if (childNode) {
+          setNodeAndDescendantsInactive(childId)
+        }
+      })
+      currentNode.children.push(userNodeId)
     }
 
-    await sendMessage(messageRequest)
+    conversationTree.value.set(userNodeId, userNode)
+    currentNodeId.value = userNodeId
 
     // 清除当前问题状态
     currentQuestion.value = null
diff --git a/prompto-lab-ui/src/services/conversationApi.ts b/prompto-lab-ui/src/services/conversationApi.ts
index 6dd2c90..491d5c2 100644
--- a/prompto-lab-ui/src/services/conversationApi.ts
+++ b/prompto-lab-ui/src/services/conversationApi.ts
@@ -13,7 +13,7 @@ export interface MessageRequest {
 export interface MessageResponse {
   nodeId: string
   content: string
-  type: 'USER_ANSWER' | 'AI_QUESTION' | 'AI_SELECTION_QUESTION' | 'SYSTEM_INFO'
+  type: 'USER_ANSWER' | 'AI_QUESTION' | 'AI_SELECTION_QUESTION' | 'SYSTEM_INFO' | 'AI_ANSWER'
   options?: string[]
   timestamp: number
 }
@@ -26,13 +26,46 @@ export interface ConversationSession {
   createdAt: string
 }
 
-// API基础URL - 使用SSE Demo接口
+// 统一答案请求接口
+export interface UnifiedAnswerRequest {
+  sessionId: string
+  nodeId?: string
+  questionType: 'single' | 'multi' | 'input' | 'form'
+  answer: any // 根据questionType不同，类型不同
+  context?: Record<string, any>
+  userId: string
+}
+
+// 表单答案项
+export interface FormAnswerItem {
+  id: string
+  value: string[]
+}
+
+// API基础URL
 const API_BASE = `${API_CONFIG.BASE_URL}/api/demo`
+const USER_INTERACTION_BASE = `${API_CONFIG.BASE_URL}/api/user-interaction`
 
 /**
- * 创建新的会话（Demo版本 - 直接返回模拟数据）
+ * 创建新的会话（真实版本 - 对接后端会话管理）
  */
 export const startConversation = async (userId: string): Promise<ConversationSession> => {
+  // 生成真实的会话ID
+  
+  // 返回会话信息
+  return {
+    sessionId: "",
+    userId: userId,
+    qaTree: null,
+    currentNodeId: 'root',
+    createdAt: new Date().toISOString()
+  }
+}
+
+/**
+ * 创建新的会话（Demo版本 - 直接返回模拟数据）
+ */
+export const startConversationDemo = async (userId: string): Promise<ConversationSession> => {
   // Demo版本：直接返回模拟的会话数据
   return {
     sessionId: userId,
@@ -135,6 +168,79 @@ export const connectSSE = (sessionId: string, onMessage: (response: MessageRespo
   return eventSource
 }
 
+/**
+ * 发送用户消息到用户交互接口
+ * 对接后端的用户交互消息接口
+ */
+export const sendUserMessage = async (request: MessageRequest): Promise<void> => {
+  // 构建统一答案请求格式
+  const unifiedRequest: UnifiedAnswerRequest = {
+    sessionId: request.sessionId,
+    questionType: 'input', // 普通文本消息作为input类型
+    answer: request.content,
+    userId: request.sessionId // 使用sessionId作为userId
+  }
+  
+  const url = `${USER_INTERACTION_BASE}/message`
+  await apiRequest(url, {
+    method: 'POST',
+    body: JSON.stringify(unifiedRequest),
+    headers: {
+      'Content-Type': 'application/json'
+    },
+    requireAuth: false
+  })
+}
+
+/**
+ * 处理统一答案请求
+ * 对接后端的processAnswer接口
+ */
+export const processAnswer = async (request: UnifiedAnswerRequest): Promise<void> => {
+  const url = `${USER_INTERACTION_BASE}/message`
+  await apiRequest(url, {
+    method: 'POST',
+    body: JSON.stringify(request),
+    headers: {
+      'Content-Type': 'application/json'
+    },
+    requireAuth: false
+  })
+}
+
+/**
+ * 建立用户交互SSE连接
+ * 对接后端的用户交互SSE接口
+ */
+export const connectUserInteractionSSE = (sessionId: string, onMessage: (response: MessageResponse) => void, onError?: (error: Event) => void): EventSource => {
+  const url = `${USER_INTERACTION_BASE}/sse/${sessionId}`
+  const eventSource = new EventSource(url)
+
+  // 监听连接建立事件
+  eventSource.addEventListener('connected', (event: MessageEvent) => {
+    console.log('用户交互SSE连接已建立:', event.data)
+  })
+
+  // 监听消息事件
+  eventSource.addEventListener('message', (event: MessageEvent) => {
+    try {
+      const response: MessageResponse = JSON.parse(event.data)
+      onMessage(response)
+    } catch (error) {
+      console.error('解析用户交互SSE消息失败:', error)
+    }
+  })
+
+  eventSource.onerror = (error: Event) => {
+    console.error('用户交互SSE连接错误:', error)
+    if (onError) {
+      onError(error)
+    }
+  }
+
+  return eventSource
+}
+
 /**
  * 关闭SSE连接
  */
diff --git a/prompto-lab-ui/src/services/userInteractionApi.ts b/prompto-lab-ui/src/services/userInteractionApi.ts
index a6a395a..85b72cd 100644
--- a/prompto-lab-ui/src/services/userInteractionApi.ts
+++ b/prompto-lab-ui/src/services/userInteractionApi.ts
@@ -76,11 +76,10 @@ export const sendAnswer = async (request: UnifiedAnswerRequest): Promise<string>
  * 建立SSE连接
  */
 export const connectUserInteractionSSE = (
-  sessionId: string, 
   onMessage: (response: MessageResponse) => void, 
   onError?: (error: Event) => void
 ): EventSource => {
-  const url = `${API_BASE}/sse/${sessionId}`
+  const url = `${API_BASE}/sse`
   const eventSource = new EventSource(url)
   
   // 监听连接建立事件