加载中...
';try{const e=await $(1,50,pn.userId,pn.integrateId);Ln=e.list.map(n=>({id:n.conversationId||"",chatId:n.conversationId||"",messageCount:n.messageCount,lastMessageTime:n.lastMessageTime,lastMessagePreview:n.lastMessagePreview,createdAt:n.firstMessageTime||n.createdAt})),Sn="",wn&&(wn.value=""),Z(n,Ln,n=>{On(n)},n=>{window.open(S(n),"_blank")},async n=>{confirm(m("history_delete_confirm"))&&await L(n)&&(n===f()&&(un=[],kn&&kn.querySelectorAll(".csk-msg, .csk-loading").forEach(n=>n.remove()),bn&&(bn.style.display="none"),Hn()),Ln=Ln.filter(e=>(e.chatId||e.id)!==n),qn())},f())}catch(e){o.error(m("history_load_error"),e),n.innerHTML=` {
+ if (!currentConfig) return false;
+ const url = buildUrl('/feedback');
+ try {
+ const response = await safeFetch(url, {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({
+ messageId: String(messageId),
+ conversationId: currentConfig.chatId,
+ feedbackType,
+ }),
+ });
+ if (!response.ok) {
+ logger.error(`反馈提交失败 status=${response.status}`);
+ return false;
+ }
+ const json: ApiResponse = await response.json();
+ return json.success || false;
+ } catch (err) {
+ logger.error('反馈提交异常', err);
+ return false;
+ }
+}
+
// ==================== P2: 会话管理 + chatId 初始化 ====================
/** 会话列表项 */
diff --git a/client/src/chat.ts b/client/src/chat.ts
index b432c97..ae247f5 100644
--- a/client/src/chat.ts
+++ b/client/src/chat.ts
@@ -20,6 +20,7 @@ import {
updateChatId,
getChatId,
saveCachedChatId,
+ submitFeedbackApi,
CskError,
} from './api';
import {
@@ -342,8 +343,7 @@ function announceMessage(text: string): void {
/**
* 处理消息反馈：切换 AI 消息的点赞/点踩状态
- * 当前仅前端状态持久化（存入 messages 数组 + localStorage），
- * 预留后端对接位：TODO 接口 POST /conversation/message/feedback
+ * 前端状态持久化（存入 messages 数组 + localStorage）+ 调用后端 API 记录反馈
*/
export function handleFeedback(msgId: string, value: 'up' | 'down'): void {
if (!messagesContainer) return;
@@ -362,7 +362,19 @@ export function handleFeedback(msgId: string, value: 'up' | 'down'): void {
// 持久化（localStorage）
if (config) saveMessages(config.integrateId, messages);
- logger.info(`消息反馈 msgId=${msgId} value=${newValue || 'cleared'}`);
+ // 调用后端 API 记录反馈
+ if (newValue) {
+ const feedbackType = newValue === 'up' ? 'THUMBS_UP' : 'THUMBS_DOWN';
+ submitFeedbackApi(String(msgId), feedbackType).then(success => {
+ if (success) {
+ logger.info(`消息反馈已提交 msgId=${msgId} value=${newValue}`);
+ } else {
+ logger.warn(`消息反馈提交失败 msgId=${msgId}（本地状态已更新）`);
+ }
+ });
+ } else {
+ logger.info(`消息反馈已取消 msgId=${msgId}`);
+ }
}
function autoResizeInput(): void {
if (!inputEl) return;
diff --git a/src/main/java/com/wok/supportbot/advisor/ContentSafetyAdvisor.java b/src/main/java/com/wok/supportbot/advisor/ContentSafetyAdvisor.java
new file mode 100644
index 0000000..8201889
--- /dev/null
+++ b/src/main/java/com/wok/supportbot/advisor/ContentSafetyAdvisor.java
@@ -0,0 +1,228 @@
+package com.wok.supportbot.advisor;
+
+import com.wok.supportbot.dao.ContentAuditLogMapper;
+import com.wok.supportbot.entity.ContentAuditLog;
+import com.wok.supportbot.service.ContentSafetyService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.ai.chat.client.ChatClientRequest;
+import org.springframework.ai.chat.client.ChatClientResponse;
+import org.springframework.ai.chat.client.advisor.api.AdvisorChain;
+import org.springframework.ai.chat.client.advisor.api.BaseAdvisor;
+import org.springframework.ai.chat.messages.AssistantMessage;
+import org.springframework.ai.chat.messages.Message;
+import org.springframework.ai.chat.messages.UserMessage;
+import org.springframework.ai.chat.model.ChatResponse;
+import org.springframework.ai.chat.model.Generation;
+import org.springframework.ai.chat.prompt.Prompt;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.Ordered;
+import org.springframework.stereotype.Component;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * 内容安全过滤 Advisor
+ *
+ * 在对话链路的最外层拦截，对用户输入和 AI 输出进行敏感词检测与脱敏/拦截处理。
+ * 使用 Ordered.HIGHEST_PRECEDENCE 确保最先执行 before、最后执行 after。
+ */
+@Slf4j
+@Component
+public class ContentSafetyAdvisor implements BaseAdvisor {
+
+ /** 安全提示文本 —— 当用户消息被 BLOCK 时替换原始内容 */
+ private static final String SAFE_USER_PROMPT = "系统检测到不当内容";
+
+ /** 安全提示文本 —— 当 AI 输出被拦截时替换原始内容 */
+ private static final String SAFE_AI_RESPONSE = "抱歉，该内容无法展示。如有问题请联系管理员。";
+
+ @Autowired
+ private ContentSafetyService contentSafetyService;
+
+ @Autowired
+ private ContentAuditLogMapper contentAuditLogMapper;
+
+ @Override
+ public String getName() {
+ return this.getClass().getSimpleName();
+ }
+
+ @Override
+ public int getOrder() {
+ return Ordered.HIGHEST_PRECEDENCE;
+ }
+
+ // ==================== before：检查用户输入 ====================
+
+ @Override
+ public ChatClientRequest before(ChatClientRequest request, AdvisorChain chain) {
+ try {
+ Prompt originalPrompt = request.prompt();
+ List messages = new ArrayList<>(originalPrompt.getInstructions());
+
+ // 提取最后一条用户消息进行检测
+ String userText = null;
+ int lastUserIndex = -1;
+ for (int i = messages.size() - 1; i >= 0; i--) {
+ if (messages.get(i) instanceof UserMessage) {
+ userText = messages.get(i).getText();
+ lastUserIndex = i;
+ break;
+ }
+ }
+
+ if (userText == null || userText.isBlank()) {
+ return request;
+ }
+
+ // 执行 DFA 检测
+ List hits = contentSafetyService.detect(userText);
+ if (hits.isEmpty()) {
+ return request;
+ }
+
+ boolean hasBlocking = contentSafetyService.hasBlockingHit(hits);
+ String sessionId = extractSessionId(request);
+
+ if (hasBlocking) {
+ // BLOCK 级别：替换用户消息为安全提示，记录审计日志
+ log.warn("内容安全拦截（BLOCK）- 会话：{}，命中词：{}", sessionId,
+ hits.stream().map(ContentSafetyService.HitResult::getWord).collect(Collectors.joining(", ")));
+
+ messages.set(lastUserIndex, new UserMessage(SAFE_USER_PROMPT));
+ Prompt newPrompt = new Prompt(messages, originalPrompt.getOptions());
+
+ saveAuditLog(sessionId, "INPUT", truncate(userText), hits, "BLOCK");
+
+ return ChatClientRequest.builder()
+ .prompt(newPrompt)
+ .context(request.context())
+ .build();
+ } else {
+ // WARN 级别：脱敏后替换用户消息，记录审计日志
+ String maskedText = contentSafetyService.mask(userText);
+ log.info("内容安全脱敏（MASK）- 会话：{}，命中词：{}", sessionId,
+ hits.stream().map(ContentSafetyService.HitResult::getWord).collect(Collectors.joining(", ")));
+
+ messages.set(lastUserIndex, new UserMessage(maskedText));
+ Prompt newPrompt = new Prompt(messages, originalPrompt.getOptions());
+
+ saveAuditLog(sessionId, "INPUT", truncate(userText), hits, "MASK");
+
+ return ChatClientRequest.builder()
+ .prompt(newPrompt)
+ .context(request.context())
+ .build();
+ }
+ } catch (Exception e) {
+ log.error("内容安全 before 检查异常，放行请求", e);
+ return request;
+ }
+ }
+
+ // ==================== after：检查 AI 输出 ====================
+
+ @Override
+ public ChatClientResponse after(ChatClientResponse response, AdvisorChain chain) {
+ try {
+ ChatResponse chatResponse = response.chatResponse();
+ if (chatResponse == null || chatResponse.getResult() == null) {
+ return response;
+ }
+
+ String aiText = chatResponse.getResult().getOutput().getText();
+ if (aiText == null || aiText.isBlank()) {
+ return response;
+ }
+
+ // 执行 DFA 检测
+ List hits = contentSafetyService.detect(aiText);
+ if (hits.isEmpty()) {
+ return response;
+ }
+
+ boolean hasBlocking = contentSafetyService.hasBlockingHit(hits);
+ String actionTaken = hasBlocking ? "BLOCK" : "MASK";
+
+ log.warn("AI 输出内容安全拦截（{}）- 命中词：{}", actionTaken,
+ hits.stream().map(ContentSafetyService.HitResult::getWord).collect(Collectors.joining(", ")));
+
+ // 构建替换后的 AI 响应
+ String safeText = hasBlocking ? SAFE_AI_RESPONSE : contentSafetyService.mask(aiText);
+ AssistantMessage safeAssistantMessage = new AssistantMessage(safeText);
+ Generation safeGeneration = new Generation(safeAssistantMessage, chatResponse.getResult().getMetadata());
+ ChatResponse safeChatResponse = new ChatResponse(
+ Collections.singletonList(safeGeneration),
+ chatResponse.getMetadata()
+ );
+
+ // 保存审计日志（此处 sessionId 可能为空，因为 after 阶段不一定能获取到）
+ saveAuditLog("", "OUTPUT", truncate(aiText), hits, actionTaken);
+
+ return ChatClientResponse.builder()
+ .chatResponse(safeChatResponse)
+ .context(response.context())
+ .build();
+ } catch (Exception e) {
+ log.error("内容安全 after 检查异常，放行响应", e);
+ return response;
+ }
+ }
+
+ // ==================== 辅助方法 ====================
+
+ /**
+ * 从请求上下文中提取会话ID
+ */
+ private String extractSessionId(ChatClientRequest request) {
+ Map context = request.context();
+ if (context != null && context.containsKey("chatMemoryConversationId")) {
+ return String.valueOf(context.get("chatMemoryConversationId"));
+ }
+ return "";
+ }
+
+ /**
+ * 截断文本至指定长度
+ */
+ private String truncate(String text) {
+ if (text == null) {
+ return "";
+ }
+ return text.length() > 50 ? text.substring(0, 50) + "..." : text;
+ }
+
+ /**
+ * 保存审计日志
+ */
+ private void saveAuditLog(String sessionId, String direction, String originalText,
+ List hits, String actionTaken) {
+ try {
+ // 将命中结果转为 Map 列表存入 JSONB
+ List> hitWordsList = hits.stream().map(hit -> {
+ Map m = new LinkedHashMap<>();
+ m.put("word", hit.getWord());
+ m.put("category", hit.getCategory());
+ m.put("level", hit.getLevel());
+ return m;
+ }).collect(Collectors.toList());
+
+ Map hitWordsMap = new LinkedHashMap<>();
+ hitWordsMap.put("hits", hitWordsList);
+
+ ContentAuditLog auditLog = ContentAuditLog.builder()
+ .sessionId(sessionId)
+ .direction(direction)
+ .originalText(originalText)
+ .hitWords(hitWordsMap)
+ .actionTaken(actionTaken)
+ .createTime(new Date())
+ .build();
+
+ contentAuditLogMapper.insert(auditLog);
+ } catch (Exception e) {
+ log.error("保存审计日志失败", e);
+ }
+ }
+}
diff --git a/src/main/java/com/wok/supportbot/app/AssistantApp.java b/src/main/java/com/wok/supportbot/app/AssistantApp.java
index 76031c3..0b2e505 100644
--- a/src/main/java/com/wok/supportbot/app/AssistantApp.java
+++ b/src/main/java/com/wok/supportbot/app/AssistantApp.java
@@ -1,5 +1,6 @@
package com.wok.supportbot.app;
+import com.wok.supportbot.advisor.ContentSafetyAdvisor;
import com.wok.supportbot.advisor.MyLoggerAdvisor;
import com.wok.supportbot.advisor.ReReadingAdvisor;
import com.wok.supportbot.chatmemory.DatabaseChatMemory;
@@ -56,6 +57,9 @@ public class AssistantApp {
@Resource
private VectorStore pgVectorVectorStore;
+ @Resource
+ private ContentSafetyAdvisor contentSafetyAdvisor;
+
private final ChatModelFactory chatModelFactory;
private final DatabaseChatMemory chatMemory;
@@ -81,6 +85,7 @@ public class AssistantApp {
return ChatClient.builder(chatModel)
.defaultSystem(SYSTEM_PROMPT)
.defaultAdvisors(
+ contentSafetyAdvisor,
MessageChatMemoryAdvisor.builder(chatMemory).build(),
new MyLoggerAdvisor()
)
diff --git a/src/main/java/com/wok/supportbot/config/DatabaseInitConfig.java b/src/main/java/com/wok/supportbot/config/DatabaseInitConfig.java
index f734574..89bf3ae 100644
--- a/src/main/java/com/wok/supportbot/config/DatabaseInitConfig.java
+++ b/src/main/java/com/wok/supportbot/config/DatabaseInitConfig.java
@@ -3,6 +3,7 @@ package com.wok.supportbot.config;
import jakarta.annotation.PostConstruct;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
@@ -17,6 +18,9 @@ public class DatabaseInitConfig {
@Autowired
private JdbcTemplate jdbcTemplate;
+ @Value("${knowledge.vector.dimension:1024}")
+ private int vectorDimension;
+
@PostConstruct
public void init() {
try {
@@ -75,6 +79,40 @@ public class DatabaseInitConfig {
syncDefaultCustomerServiceRoles();
syncDefaultCustomerAccounts();
+ // ==================== P0 阶段新增表 ====================
+
+ // P0-004: 内容安全过滤
+ if (!checkTableExists("sensitive_word")) {
+ log.info("创建敏感词表 sensitive_word");
+ createSensitiveWordTable();
+ }
+ if (!checkTableExists("content_audit_log")) {
+ log.info("创建内容审计日志表 content_audit_log");
+ createContentAuditLogTable();
+ }
+
+ // P0-002: 用户反馈
+ if (!checkTableExists("message_feedback")) {
+ log.info("创建消息反馈表 message_feedback");
+ createMessageFeedbackTable();
+ }
+
+ // P0-003: FAQ 知识库
+ if (!checkTableExists("knowledge_faq")) {
+ log.info("创建 FAQ 知识库表 knowledge_faq");
+ createKnowledgeFaqTable();
+ }
+ if (!checkTableExists("faq_embedding")) {
+ log.info("创建 FAQ 向量索引表 faq_embedding");
+ createFaqEmbeddingTable();
+ }
+
+ // P0-001: 混合检索 - 为 vector_store 添加全文检索列
+ initVectorStoreFullTextSearch();
+
+ // 为所有表添加注释（幂等，可重复执行）
+ applyTableComments();
+
log.info("数据库初始化完成");
} catch (Exception e) {
log.error("数据库初始化失败", e);
@@ -348,4 +386,317 @@ public class DatabaseInitConfig {
}
}
+ // ==================== P0-004: 内容安全过滤 ====================
+
+ private void createSensitiveWordTable() {
+ String sql = """
+ CREATE TABLE IF NOT EXISTS sensitive_word (
+ id BIGSERIAL PRIMARY KEY,
+ word VARCHAR(256) NOT NULL,
+ category VARCHAR(64) NOT NULL DEFAULT 'custom',
+ level INTEGER NOT NULL DEFAULT 1,
+ is_active BOOLEAN NOT NULL DEFAULT TRUE,
+ remark VARCHAR(512),
+ create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ update_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ is_delete BOOLEAN DEFAULT FALSE NOT NULL
+ )
+ """;
+ jdbcTemplate.execute(sql);
+ jdbcTemplate.execute("CREATE UNIQUE INDEX IF NOT EXISTS uk_sensitive_word_word_category ON sensitive_word (word, category) WHERE is_delete = false");
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_sensitive_word_active ON sensitive_word (is_active) WHERE is_delete = false");
+ }
+
+ private void createContentAuditLogTable() {
+ String sql = """
+ CREATE TABLE IF NOT EXISTS content_audit_log (
+ id BIGSERIAL PRIMARY KEY,
+ session_id VARCHAR(64),
+ direction VARCHAR(16) NOT NULL,
+ original_text TEXT NOT NULL,
+ hit_words JSONB DEFAULT '[]' NOT NULL,
+ action_taken VARCHAR(32) NOT NULL,
+ create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL
+ )
+ """;
+ jdbcTemplate.execute(sql);
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_audit_log_created ON content_audit_log (create_time DESC)");
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_audit_log_session ON content_audit_log (session_id)");
+ }
+
+ // ==================== P0-002: 用户反馈 ====================
+
+ private void createMessageFeedbackTable() {
+ String sql = """
+ CREATE TABLE IF NOT EXISTS message_feedback (
+ id BIGSERIAL PRIMARY KEY,
+ message_id VARCHAR(128) NOT NULL,
+ conversation_id VARCHAR(64) NOT NULL,
+ feedback_type VARCHAR(16) NOT NULL,
+ reason_category VARCHAR(64),
+ reason_comment TEXT,
+ create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ update_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ is_delete BOOLEAN DEFAULT FALSE NOT NULL
+ )
+ """;
+ jdbcTemplate.execute(sql);
+ jdbcTemplate.execute("CREATE UNIQUE INDEX IF NOT EXISTS uk_message_feedback_message ON message_feedback (message_id) WHERE is_delete = false");
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_feedback_conversation ON message_feedback (conversation_id)");
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_feedback_type ON message_feedback (feedback_type) WHERE is_delete = false");
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_feedback_created ON message_feedback (create_time DESC)");
+ }
+
+ // ==================== P0-003: FAQ 知识库 ====================
+
+ private void createKnowledgeFaqTable() {
+ String sql = """
+ CREATE TABLE IF NOT EXISTS knowledge_faq (
+ id BIGSERIAL PRIMARY KEY,
+ question TEXT NOT NULL,
+ answer TEXT NOT NULL,
+ similar_questions TEXT DEFAULT '[]' NOT NULL,
+ category VARCHAR(128),
+ status VARCHAR(20) NOT NULL DEFAULT 'ENABLED',
+ priority INTEGER NOT NULL DEFAULT 0,
+ hit_count BIGINT NOT NULL DEFAULT 0,
+ source VARCHAR(64) DEFAULT 'manual',
+ create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ update_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL,
+ is_delete BOOLEAN DEFAULT FALSE NOT NULL
+ )
+ """;
+ jdbcTemplate.execute(sql);
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_faq_status ON knowledge_faq (status) WHERE is_delete = false");
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_faq_category ON knowledge_faq (category)");
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_faq_priority ON knowledge_faq (priority DESC)");
+ }
+
+ private void createFaqEmbeddingTable() {
+ String sql = """
+ CREATE TABLE IF NOT EXISTS faq_embedding (
+ id BIGSERIAL PRIMARY KEY,
+ faq_id BIGINT NOT NULL,
+ embedding vector(%d) NOT NULL,
+ model_name VARCHAR(64) NOT NULL,
+ create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL
+ )
+ """.formatted(vectorDimension);
+ jdbcTemplate.execute(sql);
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_faq_emb_faq_id ON faq_embedding (faq_id)");
+ }
+
+ // ==================== P0-001: 混合检索 - 全文检索 ====================
+
+ /**
+ * 为 vector_store 表添加全文检索支持（tsvector 列 + GIN 索引 + 触发器）
+ * 幂等操作：已存在则跳过
+ */
+ private void initVectorStoreFullTextSearch() {
+ try {
+ // 检查 vector_store 表是否存在
+ if (!checkTableExists("vector_store")) {
+ log.debug("vector_store 表尚未创建，跳过全文检索初始化");
+ return;
+ }
+
+ // 检查 content_tsvector 列是否已存在
+ String checkSql = "SELECT COUNT(*) FROM information_schema.columns WHERE table_name = 'vector_store' AND column_name = 'content_tsvector'";
+ Integer count = jdbcTemplate.queryForObject(checkSql, Integer.class);
+ if (count != null && count > 0) {
+ return; // 已初始化
+ }
+
+ log.info("为 vector_store 添加全文检索支持");
+
+ // 添加 tsvector 列
+ jdbcTemplate.execute("ALTER TABLE vector_store ADD COLUMN content_tsvector tsvector");
+
+ // 填充已有数据
+ jdbcTemplate.execute("UPDATE vector_store SET content_tsvector = to_tsvector('simple', coalesce(content, '')) WHERE content_tsvector IS NULL");
+
+ // GIN 索引
+ jdbcTemplate.execute("CREATE INDEX IF NOT EXISTS idx_vector_store_tsvector ON vector_store USING gin(content_tsvector)");
+
+ // 触发器函数
+ jdbcTemplate.execute("""
+ CREATE OR REPLACE FUNCTION update_content_tsvector() RETURNS trigger AS $$
+ BEGIN
+ NEW.content_tsvector := to_tsvector('simple', coalesce(NEW.content, ''));
+ RETURN NEW;
+ END;
+ $$ LANGUAGE plpgsql
+ """);
+
+ // 绑定触发器
+ jdbcTemplate.execute("DROP TRIGGER IF EXISTS trg_update_content_tsvector ON vector_store");
+ jdbcTemplate.execute("""
+ CREATE TRIGGER trg_update_content_tsvector
+ BEFORE INSERT OR UPDATE ON vector_store
+ FOR EACH ROW EXECUTE FUNCTION update_content_tsvector()
+ """);
+
+ log.info("vector_store 全文检索初始化完成");
+ } catch (Exception e) {
+ log.warn("初始化 vector_store 全文检索时出错（可稍后手动执行）", e);
+ }
+ }
+
+ /**
+ * 为所有自动创建的表添加注释（COMMENT ON）。
+ * 所有语句均为幂等操作，可安全重复执行。
+ */
+ private void applyTableComments() {
+ try {
+ // ===== chat_message =====
+ executeComment("TABLE chat_message", "聊天消息表（存储用户与 AI 助手的对话历史）");
+ executeComment("COLUMN chat_message.id", "主键（雪花算法生成）");
+ executeComment("COLUMN chat_message.conversation_id", "会话 ID（标识同一次对话）");
+ executeComment("COLUMN chat_message.message_type", "消息类型: USER(用户消息) / ASSISTANT(AI回复) / SYSTEM(系统消息)");
+ executeComment("COLUMN chat_message.content", "消息内容（实际对话文本）");
+ executeComment("COLUMN chat_message.metadata", "元数据（JSON 格式，存储额外信息）");
+ executeComment("COLUMN chat_message.create_time", "创建时间");
+ executeComment("COLUMN chat_message.update_time", "更新时间");
+ executeComment("COLUMN chat_message.is_delete", "逻辑删除: FALSE=正常 TRUE=已删除");
+
+ // ===== knowledge_category =====
+ executeComment("TABLE knowledge_category", "知识库分类表（支持树形结构）");
+ executeComment("COLUMN knowledge_category.id", "主键（雪花算法生成）");
+ executeComment("COLUMN knowledge_category.name", "分类名称");
+ executeComment("COLUMN knowledge_category.description", "分类描述");
+ executeComment("COLUMN knowledge_category.parent_id", "父分类 ID（0 表示顶级分类）");
+ executeComment("COLUMN knowledge_category.sort_order", "排序权重（数值越大越靠前）");
+ executeComment("COLUMN knowledge_category.document_count", "关联文档数量（冗余字段，定期更新）");
+ executeComment("COLUMN knowledge_category.create_time", "创建时间");
+ executeComment("COLUMN knowledge_category.is_delete", "逻辑删除: FALSE=正常 TRUE=已删除");
+
+ // ===== knowledge_document =====
+ executeComment("TABLE knowledge_document", "知识文档表（记录上传的文档元信息）");
+ executeComment("COLUMN knowledge_document.id", "主键（雪花算法生成）");
+ executeComment("COLUMN knowledge_document.title", "文档标题");
+ executeComment("COLUMN knowledge_document.source_name", "原始文件名");
+ executeComment("COLUMN knowledge_document.file_type", "文件类型: pdf / md / json / txt / word / excel 等");
+ executeComment("COLUMN knowledge_document.file_size", "文件大小（字节）");
+ executeComment("COLUMN knowledge_document.content", "原文内容（截断预览）");
+ executeComment("COLUMN knowledge_document.category_id", "所属分类 ID（0 表示未分类）");
+ executeComment("COLUMN knowledge_document.tags", "标签（JSON 格式）");
+ executeComment("COLUMN knowledge_document.chunk_count", "分块数量");
+ executeComment("COLUMN knowledge_document.status", "处理状态: PROCESSING / READY / FAILED");
+ executeComment("COLUMN knowledge_document.error_message", "处理失败时的错误信息");
+ executeComment("COLUMN knowledge_document.content_hash", "内容 SHA-256 哈希值（用于文档去重）");
+ executeComment("COLUMN knowledge_document.create_time", "创建时间");
+ executeComment("COLUMN knowledge_document.update_time", "更新时间");
+ executeComment("COLUMN knowledge_document.is_delete", "逻辑删除: FALSE=正常 TRUE=已删除");
+
+ // ===== customer_service_role =====
+ executeComment("TABLE customer_service_role", "客服角色表（定义客服角色的身份与系统提示词）");
+ executeComment("COLUMN customer_service_role.id", "主键");
+ executeComment("COLUMN customer_service_role.role_key", "角色标识符（唯一）");
+ executeComment("COLUMN customer_service_role.name", "角色名称");
+ executeComment("COLUMN customer_service_role.description", "角色描述");
+ executeComment("COLUMN customer_service_role.prompt", "系统提示词（角色人设与行为规范）");
+ executeComment("COLUMN customer_service_role.sort_order", "排序权重");
+ executeComment("COLUMN customer_service_role.enabled", "是否启用");
+ executeComment("COLUMN customer_service_role.create_time", "创建时间");
+ executeComment("COLUMN customer_service_role.update_time", "更新时间");
+ executeComment("COLUMN customer_service_role.is_delete", "逻辑删除: FALSE=正常 TRUE=已删除");
+
+ // ===== customer_service_role_category =====
+ executeComment("TABLE customer_service_role_category", "客服角色知识库关联表（角色与知识库分类的多对多关系）");
+ executeComment("COLUMN customer_service_role_category.id", "主键");
+ executeComment("COLUMN customer_service_role_category.role_id", "角色 ID（关联 customer_service_role.id）");
+ executeComment("COLUMN customer_service_role_category.category_id", "分类 ID（关联 knowledge_category.id）");
+ executeComment("COLUMN customer_service_role_category.create_time", "创建时间");
+ executeComment("COLUMN customer_service_role_category.is_delete", "逻辑删除: FALSE=正常 TRUE=已删除");
+
+ // ===== customer_account =====
+ executeComment("TABLE customer_account", "客服账号表（对外暴露的客服入口账号）");
+ executeComment("COLUMN customer_account.id", "主键");
+ executeComment("COLUMN customer_account.account_key", "账号标识符（唯一）");
+ executeComment("COLUMN customer_account.name", "账号名称");
+ executeComment("COLUMN customer_account.description", "账号描述");
+ executeComment("COLUMN customer_account.role_id", "关联角色 ID（关联 customer_service_role.id）");
+ executeComment("COLUMN customer_account.enabled", "是否启用");
+ executeComment("COLUMN customer_account.create_time", "创建时间");
+ executeComment("COLUMN customer_account.update_time", "更新时间");
+ executeComment("COLUMN customer_account.is_delete", "逻辑删除: FALSE=正常 TRUE=已删除");
+
+ // ===== conversation_session =====
+ executeComment("TABLE conversation_session", "会话归属表（记录每个会话归属的账号和角色）");
+ executeComment("COLUMN conversation_session.conversation_id", "会话 ID（主键）");
+ executeComment("COLUMN conversation_session.account_id", "归属账号 ID（关联 customer_account.id）");
+ executeComment("COLUMN conversation_session.role_id", "归属角色 ID（关联 customer_service_role.id）");
+ executeComment("COLUMN conversation_session.create_time", "创建时间");
+ executeComment("COLUMN conversation_session.update_time", "更新时间");
+
+ // ===== sensitive_word =====
+ executeComment("TABLE sensitive_word", "敏感词表（DFA 引擎驱动的内容安全过滤）");
+ executeComment("COLUMN sensitive_word.id", "主键（雪花算法生成）");
+ executeComment("COLUMN sensitive_word.word", "敏感词内容");
+ executeComment("COLUMN sensitive_word.category", "分类: politics / porn / abuse / custom，默认 custom");
+ executeComment("COLUMN sensitive_word.level", "级别: 1=脱敏(MASK) / 2=拦截(BLOCK)");
+ executeComment("COLUMN sensitive_word.is_active", "是否启用");
+ executeComment("COLUMN sensitive_word.remark", "备注说明");
+ executeComment("COLUMN sensitive_word.create_time", "创建时间");
+ executeComment("COLUMN sensitive_word.update_time", "更新时间");
+ executeComment("COLUMN sensitive_word.is_delete", "逻辑删除: FALSE=正常 TRUE=已删除");
+
+ // ===== content_audit_log =====
+ executeComment("TABLE content_audit_log", "内容审计日志表（记录敏感词命中事件，只追加不删除）");
+ executeComment("COLUMN content_audit_log.id", "主键（雪花算法生成）");
+ executeComment("COLUMN content_audit_log.session_id", "会话 ID（关联 conversation_session）");
+ executeComment("COLUMN content_audit_log.direction", "检测方向: INPUT(用户输入) / OUTPUT(AI 输出)");
+ executeComment("COLUMN content_audit_log.original_text", "原始违规内容（截断至前 50 字）");
+ executeComment("COLUMN content_audit_log.hit_words", "命中词列表（JSON 数组）");
+ executeComment("COLUMN content_audit_log.action_taken", "采取的动作: PASS(放行) / MASK(脱敏) / BLOCK(拦截)");
+ executeComment("COLUMN content_audit_log.create_time", "创建时间（事件发生时间）");
+
+ // ===== message_feedback =====
+ executeComment("TABLE message_feedback", "消息反馈表（用户对 AI 回复的点赞/点踩反馈）");
+ executeComment("COLUMN message_feedback.id", "主键（雪花算法生成）");
+ executeComment("COLUMN message_feedback.message_id", "AI 消息 ID（唯一索引，重复提交覆盖）");
+ executeComment("COLUMN message_feedback.conversation_id", "会话 ID");
+ executeComment("COLUMN message_feedback.feedback_type", "反馈类型: THUMBS_UP(有帮助) / THUMBS_DOWN(没帮助)");
+ executeComment("COLUMN message_feedback.reason_category", "点踩原因分类: inaccurate / irrelevant / incomplete / other");
+ executeComment("COLUMN message_feedback.reason_comment", "自由文本补充说明");
+ executeComment("COLUMN message_feedback.create_time", "创建时间");
+ executeComment("COLUMN message_feedback.update_time", "更新时间（重复提交时覆盖）");
+ executeComment("COLUMN message_feedback.is_delete", "逻辑删除: FALSE=正常 TRUE=已删除");
+
+ // ===== knowledge_faq =====
+ executeComment("TABLE knowledge_faq", "FAQ 知识库表（用于意图路由后的精准问答匹配）");
+ executeComment("COLUMN knowledge_faq.id", "主键（雪花算法生成）");
+ executeComment("COLUMN knowledge_faq.question", "标准问题");
+ executeComment("COLUMN knowledge_faq.answer", "标准答案");
+ executeComment("COLUMN knowledge_faq.similar_questions", "相似问题列表（JSON 字符串数组）");
+ executeComment("COLUMN knowledge_faq.category", "FAQ 分类");
+ executeComment("COLUMN knowledge_faq.status", "状态: ENABLED(启用) / DISABLED(禁用)");
+ executeComment("COLUMN knowledge_faq.priority", "优先级（数值越大越优先匹配）");
+ executeComment("COLUMN knowledge_faq.hit_count", "命中次数统计");
+ executeComment("COLUMN knowledge_faq.source", "来源: manual(手动录入) / import(批量导入)");
+ executeComment("COLUMN knowledge_faq.create_time", "创建时间");
+ executeComment("COLUMN knowledge_faq.update_time", "更新时间");
+ executeComment("COLUMN knowledge_faq.is_delete", "逻辑删除: FALSE=正常 TRUE=已删除");
+
+ // ===== faq_embedding =====
+ executeComment("TABLE faq_embedding", "FAQ 向量索引表（存储 FAQ 语义向量，用于相似问题匹配）");
+ executeComment("COLUMN faq_embedding.id", "主键");
+ executeComment("COLUMN faq_embedding.faq_id", "关联 FAQ ID（对应 knowledge_faq.id）");
+ executeComment("COLUMN faq_embedding.embedding", "向量嵌入（维度由 knowledge.vector.dimension 配置）");
+ executeComment("COLUMN faq_embedding.model_name", "使用的 Embedding 模型名称");
+ executeComment("COLUMN faq_embedding.create_time", "创建时间");
+
+ log.info("数据库表注释已应用");
+ } catch (Exception e) {
+ log.warn("应用数据库表注释时出错", e);
+ }
+ }
+
+ /**
+ * 执行单条 COMMENT ON 语句
+ */
+ private void executeComment(String target, String comment) {
+ jdbcTemplate.execute(String.format("COMMENT ON %s IS '%s'", target, comment.replace("'", "''")));
+ }
+
}
diff --git a/src/main/java/com/wok/supportbot/controller/AiController.java b/src/main/java/com/wok/supportbot/controller/AiController.java
index f8395ef..539ba90 100644
--- a/src/main/java/com/wok/supportbot/controller/AiController.java
+++ b/src/main/java/com/wok/supportbot/controller/AiController.java
@@ -8,6 +8,7 @@ import com.wok.supportbot.service.CustomerAccountService.AccountScope;
import com.wok.supportbot.service.CustomerServiceRoleService;
import com.wok.supportbot.service.CustomerServiceRoleService.RoleScope;
import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.ai.document.Document;
import org.springframework.http.MediaType;
import org.springframework.http.codec.ServerSentEvent;
@@ -29,6 +30,7 @@ import java.util.Map;
@RestController
+@Slf4j
@RequestMapping("/ai")
public class AiController {
@@ -146,9 +148,14 @@ public class AiController {
if (isKbDenied(scope) || shouldBypassKnowledgeRetrieval(message)) {
return assistantApp.doChat(message, chatId, sys);
}
- return assistantApp.doChatWithRagStrategy(
- message, chatId, normalizeStrategy(rewriteStrategy),
- resolveCategoryIds(scope, categoryId, categoryIds), sys);
+ try {
+ return assistantApp.doChatWithRagStrategy(
+ message, chatId, normalizeStrategy(rewriteStrategy),
+ resolveCategoryIds(scope, categoryId, categoryIds), sys);
+ } catch (Exception e) {
+ log.error("RAG 对话失败 [strategy={}, chatId={}]: {}", rewriteStrategy, chatId, e.getMessage(), e);
+ return "抱歉，知识库检索出现异常，请稍后重试。";
+ }
}
/**
@@ -190,22 +197,27 @@ public class AiController {
if (message == null || message.isBlank() || isKbDenied(scope) || shouldBypassKnowledgeRetrieval(message)) {
return Map.of("success", true, "data", List.of());
}
- List cats = resolveCategoryIds(scope, categoryId, categoryIds);
- List docs = assistantApp.retrieveRagSources(message, chatId, normalizeStrategy(rewriteStrategy), cats);
- List> out = new ArrayList<>();
- for (Document doc : docs) {
- Map meta = doc.getMetadata();
- Map item = new LinkedHashMap<>();
- item.put("documentId", meta.get("documentId"));
- item.put("title", meta.get("title"));
- item.put("sourceName", meta.get("sourceName"));
- item.put("chunkIndex", meta.get("chunkIndex"));
- item.put("score", meta.get("distance"));
- String text = doc.getText();
- item.put("snippet", text != null && text.length() > 160 ? text.substring(0, 160) + "…" : text);
- out.add(item);
+ try {
+ List cats = resolveCategoryIds(scope, categoryId, categoryIds);
+ List docs = assistantApp.retrieveRagSources(message, chatId, normalizeStrategy(rewriteStrategy), cats);
+ List> out = new ArrayList<>();
+ for (Document doc : docs) {
+ Map meta = doc.getMetadata();
+ Map item = new LinkedHashMap<>();
+ item.put("documentId", meta.get("documentId"));
+ item.put("title", meta.get("title"));
+ item.put("sourceName", meta.get("sourceName"));
+ item.put("chunkIndex", meta.get("chunkIndex"));
+ item.put("score", meta.get("distance"));
+ String text = doc.getText();
+ item.put("snippet", text != null && text.length() > 160 ? text.substring(0, 160) + "…" : text);
+ out.add(item);
+ }
+ return Map.of("success", true, "data", out);
+ } catch (Exception e) {
+ log.error("获取 RAG 引用来源失败 [strategy={}]: {}", rewriteStrategy, e.getMessage(), e);
+ return Map.of("success", true, "data", List.of());
}
- return Map.of("success", true, "data", out);
}
/**
diff --git a/src/main/java/com/wok/supportbot/controller/DocumentController.java b/src/main/java/com/wok/supportbot/controller/DocumentController.java
index aa8e712..d8a8da9 100644
--- a/src/main/java/com/wok/supportbot/controller/DocumentController.java
+++ b/src/main/java/com/wok/supportbot/controller/DocumentController.java
@@ -468,8 +468,14 @@ public class DocumentController {
if (categoryIds.isEmpty() && categoryId != null) {
categoryIds = List.of(categoryId);
}
+ String searchMode = (String) body.get("searchMode");
- List results = documentService.searchDocuments(query, topK, similarityThreshold, categoryIds);
+ List results;
+ if (searchMode != null && !searchMode.isEmpty()) {
+ results = documentService.searchDocuments(query, topK, similarityThreshold, categoryIds, searchMode);
+ } else {
+ results = documentService.searchDocuments(query, topK, similarityThreshold, categoryIds);
+ }
return ResponseEntity.ok(Map.of(
"success", true,
"data", results,
diff --git a/src/main/java/com/wok/supportbot/controller/FaqController.java b/src/main/java/com/wok/supportbot/controller/FaqController.java
new file mode 100644
index 0000000..c8a6a91
--- /dev/null
+++ b/src/main/java/com/wok/supportbot/controller/FaqController.java
@@ -0,0 +1,277 @@
+package com.wok.supportbot.controller;
+
+import com.wok.supportbot.entity.KnowledgeFaq;
+import com.wok.supportbot.service.FaqService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * FAQ 知识库管理控制器
+ * 提供 FAQ 的 CRUD、批量导入/导出、匹配统计等功能
+ */
+@RestController
+@RequestMapping("/faq")
+@Slf4j
+public class FaqController {
+
+ @Autowired
+ private FaqService faqService;
+
+ // ==================== 分页列表 ====================
+
+ /**
+ * 分页查询 FAQ 列表
+ */
+ @GetMapping("/list")
+ public ResponseEntity> list(
+ @RequestParam(defaultValue = "1") int page,
+ @RequestParam(defaultValue = "20") int size,
+ @RequestParam(required = false) String keyword,
+ @RequestParam(required = false) String category,
+ @RequestParam(required = false) String status) {
+ try {
+ Map data = faqService.list(page, size, keyword, category, status);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "查询成功",
+ "data", data
+ ));
+ } catch (Exception e) {
+ log.error("FAQ 列表查询失败", e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "查询失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ // ==================== 新增 ====================
+
+ /**
+ * 新增 FAQ
+ */
+ @PostMapping
+ public ResponseEntity> create(@RequestBody KnowledgeFaq faq) {
+ try {
+ if (faq.getQuestion() == null || faq.getQuestion().isBlank()) {
+ return ResponseEntity.status(400).body(Map.of(
+ "success", false,
+ "message", "问题内容不能为空"
+ ));
+ }
+ if (faq.getAnswer() == null || faq.getAnswer().isBlank()) {
+ return ResponseEntity.status(400).body(Map.of(
+ "success", false,
+ "message", "答案内容不能为空"
+ ));
+ }
+
+ KnowledgeFaq created = faqService.create(faq);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "创建成功",
+ "data", created
+ ));
+ } catch (Exception e) {
+ log.error("FAQ 创建失败", e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "创建失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ // ==================== 修改 ====================
+
+ /**
+ * 修改 FAQ
+ */
+ @PutMapping("/{id}")
+ public ResponseEntity> update(@PathVariable Long id, @RequestBody KnowledgeFaq faq) {
+ try {
+ KnowledgeFaq updated = faqService.update(id, faq);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "更新成功",
+ "data", updated
+ ));
+ } catch (IllegalArgumentException e) {
+ return ResponseEntity.status(400).body(Map.of(
+ "success", false,
+ "message", e.getMessage()
+ ));
+ } catch (Exception e) {
+ log.error("FAQ 更新失败: id={}", id, e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "更新失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ // ==================== 删除 ====================
+
+ /**
+ * 删除 FAQ（逻辑删除）
+ */
+ @DeleteMapping("/{id}")
+ public ResponseEntity> delete(@PathVariable Long id) {
+ try {
+ faqService.delete(id);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "删除成功"
+ ));
+ } catch (IllegalArgumentException e) {
+ return ResponseEntity.status(400).body(Map.of(
+ "success", false,
+ "message", e.getMessage()
+ ));
+ } catch (Exception e) {
+ log.error("FAQ 删除失败: id={}", id, e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "删除失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ // ==================== 启用/禁用 ====================
+
+ /**
+ * 切换 FAQ 启用/禁用状态
+ */
+ @PutMapping("/{id}/toggle")
+ public ResponseEntity> toggleStatus(
+ @PathVariable Long id,
+ @RequestParam String status) {
+ try {
+ faqService.toggleStatus(id, status);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "状态切换成功"
+ ));
+ } catch (IllegalArgumentException e) {
+ return ResponseEntity.status(400).body(Map.of(
+ "success", false,
+ "message", e.getMessage()
+ ));
+ } catch (Exception e) {
+ log.error("FAQ 状态切换失败: id={}", id, e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "状态切换失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ // ==================== 批量导入 ====================
+
+ /**
+ * 批量导入 FAQ
+ * 请求体格式: {"faqs": [{"question":"...", "answer":"...", "similarQuestions":"[...]", "category":"...", "priority":0}]}
+ */
+ @PostMapping("/batch-import")
+ public ResponseEntity> batchImport(@RequestBody Map> body) {
+ try {
+ List faqs = body.get("faqs");
+ if (faqs == null || faqs.isEmpty()) {
+ return ResponseEntity.status(400).body(Map.of(
+ "success", false,
+ "message", "导入数据不能为空"
+ ));
+ }
+
+ int count = faqService.batchImport(faqs);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "批量导入成功，共导入 " + count + " 条",
+ "data", Map.of("importedCount", count)
+ ));
+ } catch (Exception e) {
+ log.error("FAQ 批量导入失败", e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "批量导入失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ // ==================== 导出 ====================
+
+ /**
+ * 导出所有启用的 FAQ（返回 JSON 列表，后续可扩展为 Excel）
+ */
+ @GetMapping("/export")
+ public ResponseEntity> exportAll() {
+ try {
+ List faqs = faqService.exportAll();
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "导出成功",
+ "data", faqs
+ ));
+ } catch (Exception e) {
+ log.error("FAQ 导出失败", e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "导出失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ // ==================== 统计 ====================
+
+ /**
+ * 获取 FAQ 匹配统计信息
+ */
+ @GetMapping("/stats")
+ public ResponseEntity> getStats() {
+ try {
+ Map stats = faqService.getStats();
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "查询成功",
+ "data", stats
+ ));
+ } catch (Exception e) {
+ log.error("FAQ 统计查询失败", e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "统计查询失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ // ==================== 手动重算向量 ====================
+
+ /**
+ * 手动重新计算某条 FAQ 的向量嵌入
+ */
+ @PostMapping("/{id}/recompute-embedding")
+ public ResponseEntity> recomputeEmbedding(@PathVariable Long id) {
+ try {
+ faqService.recomputeEmbedding(id);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "向量重新计算完成"
+ ));
+ } catch (IllegalArgumentException e) {
+ return ResponseEntity.status(400).body(Map.of(
+ "success", false,
+ "message", e.getMessage()
+ ));
+ } catch (Exception e) {
+ log.error("FAQ 向量重算失败: id={}", id, e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "向量重算失败：" + e.getMessage()
+ ));
+ }
+ }
+}
diff --git a/src/main/java/com/wok/supportbot/controller/MessageFeedbackController.java b/src/main/java/com/wok/supportbot/controller/MessageFeedbackController.java
new file mode 100644
index 0000000..f6618dc
--- /dev/null
+++ b/src/main/java/com/wok/supportbot/controller/MessageFeedbackController.java
@@ -0,0 +1,146 @@
+package com.wok.supportbot.controller;
+
+import com.wok.supportbot.entity.MessageFeedback;
+import com.wok.supportbot.service.MessageFeedbackService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+
+/**
+ * 消息反馈控制器
+ * 提供反馈提交、统计、查询等 API
+ */
+@RestController
+@Slf4j
+public class MessageFeedbackController {
+
+ @Autowired
+ private MessageFeedbackService messageFeedbackService;
+
+ /**
+ * 提交/修改反馈（upsert）
+ *
+ * @param feedback 反馈信息（messageId, conversationId, feedbackType, reasonCategory, reasonComment）
+ * @return 操作结果
+ */
+ @PostMapping("/feedback")
+ public ResponseEntity> submitFeedback(@RequestBody MessageFeedback feedback) {
+ try {
+ // messageId 缺失时自动生成，保证 upsert 索引不冲突
+ if (feedback.getMessageId() == null || feedback.getMessageId().isBlank()) {
+ feedback.setMessageId("auto_" + UUID.randomUUID().toString().replace("-", ""));
+ log.warn("反馈请求缺少 messageId，已自动生成: {}", feedback.getMessageId());
+ }
+ if (feedback.getFeedbackType() == null || feedback.getFeedbackType().isBlank()) {
+ return ResponseEntity.badRequest().body(Map.of(
+ "success", false,
+ "message", "feedbackType 不能为空"
+ ));
+ }
+ String type = feedback.getFeedbackType().toUpperCase();
+ if (!type.equals("THUMBS_UP") && !type.equals("THUMBS_DOWN")) {
+ return ResponseEntity.badRequest().body(Map.of(
+ "success", false,
+ "message", "feedbackType 必须为 THUMBS_UP 或 THUMBS_DOWN"
+ ));
+ }
+ feedback.setFeedbackType(type);
+
+ MessageFeedback saved = messageFeedbackService.submitFeedback(feedback);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "data", saved,
+ "message", "反馈提交成功"
+ ));
+ } catch (Exception e) {
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "反馈提交失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ /**
+ * 获取反馈统计数据
+ *
+ * @param startDate 开始日期（yyyy-MM-dd），可选
+ * @param endDate 结束日期（yyyy-MM-dd），可选
+ * @return 统计结果
+ */
+ @GetMapping("/feedback/stats")
+ public ResponseEntity> getStats(
+ @RequestParam(required = false) String startDate,
+ @RequestParam(required = false) String endDate) {
+ try {
+ Map stats = messageFeedbackService.getStats(startDate, endDate);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "data", stats
+ ));
+ } catch (Exception e) {
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "查询统计失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ /**
+ * 按会话ID查询反馈列表
+ *
+ * @param conversationId 会话ID
+ * @return 反馈列表
+ */
+ @GetMapping("/feedback/by-conversation/{conversationId}")
+ public ResponseEntity> getByConversation(
+ @PathVariable String conversationId) {
+ try {
+ List feedbacks = messageFeedbackService.getByConversationId(conversationId);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "data", feedbacks
+ ));
+ } catch (Exception e) {
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "查询失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ /**
+ * 批量查询反馈状态（供 SDK 回显使用）
+ *
+ * @param messageIds 逗号分隔的消息ID列表
+ * @return 反馈列表
+ */
+ @GetMapping("/feedback/batch")
+ public ResponseEntity> getBatchByMessageIds(
+ @RequestParam String messageIds) {
+ try {
+ if (messageIds == null || messageIds.isBlank()) {
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "data", List.of()
+ ));
+ }
+ List idList = Arrays.asList(messageIds.split(","));
+ List feedbacks = messageFeedbackService.getBatchByMessageIds(idList);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "data", feedbacks
+ ));
+ } catch (Exception e) {
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "批量查询失败：" + e.getMessage()
+ ));
+ }
+ }
+}
diff --git a/src/main/java/com/wok/supportbot/controller/SensitiveWordController.java b/src/main/java/com/wok/supportbot/controller/SensitiveWordController.java
new file mode 100644
index 0000000..d182b56
--- /dev/null
+++ b/src/main/java/com/wok/supportbot/controller/SensitiveWordController.java
@@ -0,0 +1,239 @@
+package com.wok.supportbot.controller;
+
+import com.wok.supportbot.entity.SensitiveWord;
+import com.wok.supportbot.service.SensitiveWordService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 敏感词管理 & 审计日志查询接口
+ */
+@Slf4j
+@RestController
+@RequestMapping("/sensitive-word")
+public class SensitiveWordController {
+
+ @Autowired
+ private SensitiveWordService sensitiveWordService;
+
+ @Autowired
+ private JdbcTemplate jdbcTemplate;
+
+ // ==================== 敏感词 CRUD ====================
+
+ /**
+ * 分页查询敏感词列表
+ */
+ @GetMapping("/list")
+ public ResponseEntity> list(
+ @RequestParam(defaultValue = "1") int page,
+ @RequestParam(defaultValue = "10") int size,
+ @RequestParam(required = false) String keyword,
+ @RequestParam(required = false) String category) {
+ try {
+ Map result = sensitiveWordService.list(page, size, keyword, category);
+
+ Map data = new HashMap<>();
+ data.put("success", true);
+ data.put("data", result.get("records"));
+ data.put("total", result.get("total"));
+ data.put("page", result.get("page"));
+ data.put("size", result.get("size"));
+ data.put("pages", result.get("pages"));
+ return ResponseEntity.ok(data);
+ } catch (Exception e) {
+ log.error("查询敏感词列表失败", e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "查询失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ /**
+ * 新增敏感词
+ */
+ @PostMapping
+ public ResponseEntity> create(@RequestBody SensitiveWord word) {
+ try {
+ SensitiveWord created = sensitiveWordService.create(word);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "新增成功",
+ "data", created
+ ));
+ } catch (IllegalArgumentException e) {
+ return ResponseEntity.badRequest().body(Map.of(
+ "success", false,
+ "message", e.getMessage()
+ ));
+ } catch (Exception e) {
+ log.error("新增敏感词失败", e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "新增失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ /**
+ * 修改敏感词
+ */
+ @PutMapping("/{id}")
+ public ResponseEntity> update(@PathVariable Long id, @RequestBody SensitiveWord word) {
+ try {
+ SensitiveWord updated = sensitiveWordService.update(id, word);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "修改成功",
+ "data", updated
+ ));
+ } catch (IllegalArgumentException e) {
+ return ResponseEntity.badRequest().body(Map.of(
+ "success", false,
+ "message", e.getMessage()
+ ));
+ } catch (Exception e) {
+ log.error("修改敏感词失败", e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "修改失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ /**
+ * 删除敏感词（逻辑删除）
+ */
+ @DeleteMapping("/{id}")
+ public ResponseEntity> delete(@PathVariable Long id) {
+ try {
+ sensitiveWordService.delete(id);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "删除成功"
+ ));
+ } catch (IllegalArgumentException e) {
+ return ResponseEntity.badRequest().body(Map.of(
+ "success", false,
+ "message", e.getMessage()
+ ));
+ } catch (Exception e) {
+ log.error("删除敏感词失败", e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "删除失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ /**
+ * 批量导入敏感词
+ *
+ * 请求体格式：{ "words": ["词1", "词2"], "category": "custom", "level": 1 }
+ */
+ @SuppressWarnings("unchecked")
+ @PostMapping("/batch-import")
+ public ResponseEntity> batchImport(@RequestBody Map body) {
+ try {
+ List words = (List) body.get("words");
+ String category = (String) body.getOrDefault("category", "custom");
+ int level = body.containsKey("level") ? ((Number) body.get("level")).intValue() : 1;
+
+ if (words == null || words.isEmpty()) {
+ return ResponseEntity.badRequest().body(Map.of(
+ "success", false,
+ "message", "words 列表不能为空"
+ ));
+ }
+
+ int imported = sensitiveWordService.batchImport(words, category, level);
+ return ResponseEntity.ok(Map.of(
+ "success", true,
+ "message", "批量导入完成，成功 " + imported + " 个",
+ "data", Map.of("imported", imported, "total", words.size())
+ ));
+ } catch (Exception e) {
+ log.error("批量导入敏感词失败", e);
+ return ResponseEntity.status(500).body(Map.of(
+ "success", false,
+ "message", "批量导入失败：" + e.getMessage()
+ ));
+ }
+ }
+
+ /**
+ * 将 Map 的 key 从 snake_case 转为 camelCase
+ */
+ private Map snakeToCamelKeys(Map map) {
+ Map result = new HashMap<>();
+ map.forEach((key, value) -> {
+ String camelKey = key;
+ int idx;
+ while ((idx = camelKey.indexOf('_')) != -1 && idx + 1 < camelKey.length()) {
+ camelKey = camelKey.substring(0, idx) + Character.toUpperCase(camelKey.charAt(idx + 1)) + camelKey.substring(idx + 2);
+ }
+ result.put(camelKey, value);
+ });
+ return result;
+ }
+
+ // ==================== 审计日志查询 ====================
+
+ /**
+ * 分页查询内容审计日志（使用 JdbcTemplate 直接查询，因为审计日志表无逻辑删除字段）
+ */
+ @GetMapping("/audit-log")
+ public ResponseEntity> auditLog(
+ @RequestParam(defaultValue = "1") int page,
+ @RequestParam(defaultValue = "10") int size,
+ @RequestParam(required = false) String sessionId) {
+ try {
+ // 构建 WHERE 子句
+ StringBuilder whereClause = new StringBuilder("WHERE 1=1");
+ List