From 88b3f09a702f8f8515af43bc14242ecca2a667db Mon Sep 17 00:00:00 2001
From: zhou zhou <3272660260@qq.com>
Date: 星期四, 19 三月 2026 11:10:45 +0800
Subject: [PATCH] #AI2. 对话执行链路治理
---
rsf-server/src/main/java/com/vincent/rsf/server/ai/controller/AiChatController.java | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/ai/controller/AiChatController.java b/rsf-server/src/main/java/com/vincent/rsf/server/ai/controller/AiChatController.java
index 63a2073..64e9f06 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/ai/controller/AiChatController.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/ai/controller/AiChatController.java
@@ -5,12 +5,17 @@
import com.vincent.rsf.server.ai.service.AiChatService;
import com.vincent.rsf.server.system.controller.BaseController;
import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.http.MediaType;
import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+import java.util.UUID;
+
@RestController
+@Slf4j
@RequiredArgsConstructor
public class AiChatController extends BaseController {
@@ -39,6 +44,12 @@
@PreAuthorize("isAuthenticated()")
@PostMapping(value = "/ai/chat/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public SseEmitter stream(@RequestBody AiChatRequest request) {
+ String requestId = StringUtils.hasText(request.getRequestId())
+ ? request.getRequestId().trim()
+ : UUID.randomUUID().toString().replace("-", "");
+ request.setRequestId(requestId);
+ log.info("AI chat request accepted, requestId={}, userId={}, tenantId={}, sessionId={}",
+ requestId, getLoginUserId(), getTenantId(), request.getSessionId());
return aiChatService.stream(request, getLoginUserId(), getTenantId());
}
}
--
Gitblit v1.9.1