修改配置

f334acf4 · 赵灿灿 · 94111bc4 · f334acf4 · f334acf4 · f334acf4
Commit f334acf4 authored Apr 23, 2025 by 赵灿灿
8 changed files
--- a/src/main/java/com/infoepoch/pms/dispatchassistant/controller/langchain/LangChainController.java
+++ b/src/main/java/com/infoepoch/pms/dispatchassistant/controller/langchain/LangChainController.java
@@ -378,9 +378,7 @@ public class LangChainController {
                chatService.updateMessage(messagesContent);
                if (connection != null) {
                    connection.disconnect();
-                    logger.info("关闭成功1");
                }
-                logger.info("关闭成功2");
            }
        }).start();

@@ -754,4 +752,18 @@ public class LangChainController {
        List<Messages> mapList= chatService.conversationMessages(sessionId);
        return Result.successData(mapList);
    }
+
+    //删除历史对话
+
+    /**
+     * 会话记录列表
+     *
+     * @param
+     * @return
+     */
+    @PostMapping("/deleteChat")
+    public Result deleteChat(@RequestBody String sessionId) {
+        chatService.deleteChat(sessionId);
+        return Result.successData("删除成功");
+    }
 }
--- a/src/main/java/com/infoepoch/pms/dispatchassistant/domain/langchain/chat/ChatService.java
+++ b/src/main/java/com/infoepoch/pms/dispatchassistant/domain/langchain/chat/ChatService.java
@@ -284,6 +284,17 @@ public class ChatService {
        return messagesList;
    }

+    //删除会话内容通过会话id
+    public void deleteChat(String sessionId)
+    {
+        try {
+            iMessagesRepository.deleteBySessionId(sessionId);
+            iConversationsRepository.deleteBySessionId(sessionId);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+

    public Date getToday()
    {

--- a/src/main/java/com/infoepoch/pms/dispatchassistant/domain/langchain/history/IConversationsRepository.java
+++ b/src/main/java/com/infoepoch/pms/dispatchassistant/domain/langchain/history/IConversationsRepository.java
@@ -41,7 +41,11 @@ public interface IConversationsRepository {
     * @param: [id]
     */
    boolean delete(String id);
-
+    /**
+     * 删除
+     * @param: [id]
+     */
+    boolean deleteBySessionId(String sessionId);
    // region select

    /**

--- a/src/main/java/com/infoepoch/pms/dispatchassistant/domain/langchain/history/IMessagesRepository.java
+++ b/src/main/java/com/infoepoch/pms/dispatchassistant/domain/langchain/history/IMessagesRepository.java
@@ -41,6 +41,12 @@ public interface IMessagesRepository {
     */
    boolean delete(String id);

+    /**
+     * 删除
+     * @param: [id]
+     */
+    boolean deleteBySessionId(String sessionId);
+
    // region select

    /**

--- a/src/main/java/com/infoepoch/pms/dispatchassistant/infractructure/langchain/ConversationsRepository.java
+++ b/src/main/java/com/infoepoch/pms/dispatchassistant/infractructure/langchain/ConversationsRepository.java
@@ -154,6 +154,21 @@ public class ConversationsRepository implements IConversationsRepository {
        return result > 0;
    }

+    /**
+     * 删除
+     */
+    @Override
+    public boolean deleteBySessionId(String sessionId) {
+        String sql = "DELETE FROM T_CONVERSATIONS WHERE C_SESSION_ID = ?";
+        int result=0;
+        try {
+            result = jdbcTemplate.update(sql, sessionId);
+        } catch (Exception e) {
+            LogHelper.info(e.getMessage());
+            //throw new ServiceException("删除  数据 失败。");
+        }
+        return result > 0;
+    }
    /**
     * 根据Id查询
     */

--- a/src/main/java/com/infoepoch/pms/dispatchassistant/infractructure/langchain/MessagesRepository.java
+++ b/src/main/java/com/infoepoch/pms/dispatchassistant/infractructure/langchain/MessagesRepository.java
@@ -151,6 +151,22 @@ public class MessagesRepository implements IMessagesRepository {
        return result > 0;
    }

+    /**
+     * 删除
+     */
+    @Override
+    public boolean deleteBySessionId(String sessionId) {
+        String sql = "DELETE FROM T_MESSAGES WHERE M_SESSION_ID = ?";
+        int result=0;
+        try {
+            result = jdbcTemplate.update(sql, sessionId);
+        } catch (Exception e) {
+            LogHelper.info(e.getMessage());
+            //throw new ServiceException("删除  数据 失败。");
+        }
+        return result > 0;
+    }
+
    /**
     * 根据Id查询
     */

--- a/src/main/resources/static/pages/langchain/ai-chat.html
+++ b/src/main/resources/static/pages/langchain/ai-chat.html
@@ -2,7 +2,7 @@
 <html lang="zh-CN">
 <head>
    <meta charset="UTF-8">
-    <title>AI智能对话</title>
+    <title>推荐专家智能助手</title>
    <link rel="stylesheet" href="style/ai-chat.css">
    <style>
        [v-cloak] {
@@ -15,7 +15,7 @@
    <!-- 左侧历史对话列表 -->
    <div class="sidebar">
        <div class="sidebar-header">
-            <h1>专家推荐智能助手</h1>
+            <h1>推荐专家智能助手</h1>
            <!-- 添加主题切换按钮 -->
            <div id="theme-toggle" class="theme-toggle" title="切换主题" @click="toggleTheme">
                <svg id="light-icon" viewBox="0 0 24 24" :style="{display: isDarkTheme ? 'block' : 'none'}">

--- a/src/main/resources/static/pages/langchain/js/ai-chat-vue.js
+++ b/src/main/resources/static/pages/langchain/js/ai-chat-vue.js
@@ -233,7 +233,7 @@ require(['jquery', 'vue', 'utils','marked','markdown', 'global'], function ($, V
                    const data = JSON.parse(event.data);
                    const content = data.dataToSend[1].data;
                    if (content !== "stop") {
-                        const match = content.match(/SUGGEST#\[(.*?)\]#SUGGEST/);
+                        const match = content.match(/SUGGEST\[(.*?)\]SUGGEST/);
                        if (match) {
                            const suggestionsJson = `[${match[1]}]`;
                            const suggestions = JSON.parse(suggestionsJson);
@@ -372,6 +372,16 @@ require(['jquery', 'vue', 'utils','marked','markdown', 'global'], function ($, V
                if (isActiveChat) {
                    this.clearChat();
                }
+                $.ajax({
+                    url: "../../api/langchain/deleteChat",
+                    type: "post",
+                    dataType: "json",
+                    contentType: "application/json;charset=UTF-8",
+                    data: chatId,
+                    async: false,
+                    success: function (data) {
+                    }
+                });
            },
            // 专家选择相关方法
            toggleExpertDropdown() {