首页会话功能修改

src/layouts/default/sider/bottomSider2.vue

@@ -39,15 +39,13 @@
               }"
             ></span>
             <span v-if="!isFold" class="btn-text">历史对话</span>
-            <a-list style="width: 100px" :split="false" :data-source="historySessions" :scroll="{ y: 400 }" class="custom-list">
+            <a-list style="width: 110px" :split="false" :data-source="historySessions" class="custom-list">
               <template #renderItem="{ item }">
                 <a-list-item
                   :style="{
-                    padding: '5px 0 0 30px',
+                    padding: '5px 0 0 10px',
                     color: '#5e7081',
                     fontSize: '12px',
-                    whiteSpace: 'nowrap',
-                    textOverflow: 'ellipsis',
                   }"
                   @click="sessionsHistory(item.id)"
                 >
@@ -110,7 +108,8 @@
 </template>
 
 <script lang="ts" setup>
-import { ref, onMounted, nextTick, computed } from 'vue';
+import { ref, onMounted, unref, nextTick, computed } from 'vue';
+import { useUserStore } from '/@/store/modules/user';
 // 响应式变量声明
 const dialogVisible = ref(false);
 const isFold = ref(false); // 是否折叠
@@ -121,24 +120,20 @@ const systemMessage = ref(''); // 系统返回信息
 const session_id = ref(''); // 会话id
 const hasCreated = ref(false); // 标志位，防止重复调用create接口
 const hasAdd = ref(false); // 标志位，防止重复调用create接口
-
+const userStore = useUserStore(); //获取用户信息
+let userId = unref(userStore.getUserInfo).id;
+// const userId = ref(0);
 type MessageItem = {
   id: string; // 唯一标识（可用时间戳生成）
   type: 'user' | 'system';
   content: string;
   timestamp: number; // 排序依据
 };
-
 const messageList = ref<MessageItem[]>([]);
 const sortedMessages = computed(() => {
   return messageList.value.sort((a, b) => a.timestamp - b.timestamp);
 });
-// const scrollToBottom = () => {
-//   nextTick(() => {
-//     const container = document.querySelector('.dialog-area');
-//     container.scrollTop = container.scrollHeight;
-//   });
-// };
+
 const openMenu = () => {
   dialogVisible.value = !dialogVisible.value;
   if (dialogVisible.value) {
@@ -155,11 +150,15 @@ const fold = () => {
 //创建新对话
 async function addNew() {
   hasAdd.value = !hasAdd.value;
+  const params = {
+    user_id: userId,
+  };
   let response = await fetch('http://182.92.126.35:6005/sessions/create', {
     method: 'post',
     headers: {
       'Content-Type': 'application/json',
     },
+    body: JSON.stringify(params),
   });
   const data = await response.json();
   session_id.value = data.id;
@@ -170,10 +169,10 @@ async function handleSend() {
   if (session_id.value === '') {
     await addNew();
     createSessionTitle({ session_id: session_id.value, title: inputText.value });
-    sendMessage();
+    sendMessage1();
   } else {
     createSessionTitle({ session_id: session_id.value, title: inputText.value });
-    sendMessage();
+    sendMessage1();
   }
 }
 //发送消息
@@ -228,7 +227,55 @@ async function sendMessage() {
     spinning.value = false; // 无论请求成功与否，都停止加载指示器
   }
 }
+//发送消息  流式响应
+async function sendMessage1() {
+  spinning.value = true;
+  // 添加用户消息
+  messageList.value.push({
+    id: `user_${Date.now()}`,
+    type: 'user',
+    content: inputText.value,
+    timestamp: Date.now(),
+  });
+  const params = {
+    chat_session_id: session_id.value,
+    prompt: inputText.value,
+    ref_file_ids: [],
+    thinking_enabled: false,
+  };
+  inputText.value = ''; // 清空输入框
+  //将用户输入的内容发送到后端
+  try {
+    // 将用户输入的内容发送到后端;
+    let response = await fetch('http://182.92.126.35:6005/chat_stream', {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'text/event-stream; charset=utf-8',
+      },
+      body: JSON.stringify(params),
+    });
 
+    if (!response.ok) {
+      throw new Error('Network response was not ok');
+    }
+    const data = await response.json();
+    const assistantReply = data.reply.content; // 获取助手回复
+    systemMessage.value = assistantReply;
+    // 添加系统回答
+    messageList.value.push({
+      id: `system_${Date.now()}`,
+      type: 'system',
+      content: systemMessage.value,
+      timestamp: Date.now(),
+    });
+  } catch (error) {
+    // 请求失败时设置系统消息为"服务器异常"
+    systemMessage.value = '服务器异常';
+    console.error('请求失败:', error);
+  } finally {
+    spinning.value = false; // 无论请求成功与否，都停止加载指示器
+  }
+}
 //创建标题
 async function createSessionTitle({ session_id, title }) {
   const params = {
@@ -246,7 +293,7 @@ async function createSessionTitle({ session_id, title }) {
 }
 //获取会话历史
 async function sessionsHistoryList() {
-  let response = await fetch('http://182.92.126.35:6005/sessions', {
+  let response = await fetch(`http://182.92.126.35:6005/sessions/?user_id=${userId}`, {
     method: 'get',
     headers: {
       'Content-Type': 'application/json',
@@ -320,16 +367,14 @@ onMounted(() => {
     height: 100vh;
   }
 }
-::v-deep .zxm-list-items {
-  height: 260px !important;
-  overflow-y: auto !important;
+.custom-list {
+  height: 360px;
+  overflow-y: auto;
 }
-
 /* 穿透组件作用域 */
-::v-deep .custom-list .zxm-list-items {
+::v-deep .custom-list {
   scrollbar-width: thin;
   scrollbar-color: #1890ff #f0f0f0;
-
   &::-webkit-scrollbar {
     width: 4px;
     height: 6px;
@@ -345,11 +390,11 @@ onMounted(() => {
     border-radius: 4px;
   }
 }
-
+::v-deep .zxm-list-item {
+  white-space: normal; /* 禁止文本换行 */
+}
 ::v-deep .zxm-list-items {
   color: #1890ff;
-  white-space: nowrap;
-  text-overflow: ellipsis;
 }
 ::v-deep .zxm-list-item:hover {
   text-decoration: underline;