-
- 
-
+
-
+
+
-
-
+
+
- 正在加载历史记录...
+
- 加载历史记录中...
- 没有更多历史记录了
+
+
-
- 没有更多历史记录了
- ![]()
-
-
-
- {{ item.content }}
+
+
+
+ ![]()
+
+
+
+
-
-
+ ![用户头像]()
+
+ U
+
+
+ ![AI头像]()
+
+ AI
+
+
+
智水AI辅导员
-
-
-
-
- 引用来源：
-
diff --git a/src/utils/ai_request.js b/src/utils/ai_request.js
index b4cba65..43f9947 100644
--- a/src/utils/ai_request.js
+++ b/src/utils/ai_request.js
@@ -1,11 +1,11 @@
import axios from 'axios'
-import { getToken } from './auth'
+import { getTokenKeySessionStorage } from './auth'
import { useRouter } from 'vue-router'
import { showToast } from '@/utils/toast' // 请替换为你的Toast组件
// 创建axios实例
const service = axios.create({
- baseURL: process.env.VUE_APP_API_BASE_URL || 'http://localhost:8088/aitutor/aichat',
+ baseURL: process.env.VUE_APP_API_BASE_URL || 'http://localhost:8088',
timeout: 15000,
headers: {
'Content-Type': 'application/json'
@@ -16,7 +16,7 @@ const service = axios.create({
service.interceptors.request.use(
config => {
// 从本地存储获取token
- const token = getToken()
+ const token = getTokenKeySessionStorage()
if (token) {
config.headers.Authorization = `Bearer ${token}`
}
diff --git a/src/utils/ai_stream.js b/src/utils/ai_stream.js
index a60941b..a3c19ca 100644
--- a/src/utils/ai_stream.js
+++ b/src/utils/ai_stream.js
@@ -1,7 +1,7 @@
-import { getToken } from '@/utils/auth'
+import { getTokenKeySessionStorage } from "@/utils/auth";
// 使用环境变量配置基础URL
-const BASE_URL = process.env.VUE_APP_API_BASE_URL || 'http://localhost:8088'
+const BASE_URL = process.env.VUE_APP_API_BASE_URL || "http://localhost:8088";
/**
* 创建聊天流式连接
@@ -13,54 +13,55 @@ const BASE_URL = process.env.VUE_APP_API_BASE_URL || 'http://localhost:8088'
* @returns {Object} 包含stream和cancel方法的对象
*/
export function createChatStream(params) {
- const requestId = `req-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`
- const url = `${BASE_URL}/aitutor/aichat/stream`
- const token = getToken()
+ const requestId = `req-${Date.now()}-${Math.random()
+ .toString(36)
+ .slice(2, 8)}`;
+ const url = `${BASE_URL}/aitutor/aichat/stream`;
+ const token = getTokenKeySessionStorage();
- if (!token) {
- throw new Error('请先登录')
+ if (!token) {
+ throw new Error("请先登录");
+ }
+
+ const controller = new AbortController();
+
+ const fetchPromise = fetch(url, {
+ method: "POST",
+ headers: {
+ "Content-Type": "application/json",
+ Authorization: `Bearer ${token}`,
+ "X-Request-ID": requestId,
+ },
+ body: JSON.stringify({
+ query: params.prompt,
+ user_id: params.userId,
+ user_name: params.userName,
+ user_token: params.user_token || "123",
+ user_role: "student",
+ conversation_id: params.conversationId || null,
+ }),
+ signal: controller.signal,
+ }).then((response) => {
+ if (!response.ok) {
+ throw new Error(`HTTP ${response.status}`);
+ }
+ if (!response.body) {
+ throw new Error("Response body is null");
}
-
- const controller = new AbortController()
-
- const fetchPromise = fetch(url, {
- method: 'POST',
- headers: {
- 'Content-Type': 'application/json',
- 'Authorization': `Bearer ${token}`,
- 'X-Request-ID': requestId
- },
- body: JSON.stringify({
- query: params.prompt,
- user_id: params.userId,
- user_name: params.userName,
- user_token: params.user_token || '123',
- user_role: 'student',
- conversation_id: params.conversationId || null,
- }),
- signal: controller.signal
- })
- .then(response => {
- if (!response.ok) {
- throw new Error(`HTTP ${response.status}`)
- }
- if (!response.body) {
- throw new Error('Response body is null')
- }
- return {
- reader: response.body.getReader(),
- decoder: new TextDecoder('utf-8')
- }
- })
-
return {
- stream: fetchPromise,
- cancel: (reason) => {
- if (!controller.signal.aborted) {
- controller.abort(reason)
- }
- }
- }
+ reader: response.body.getReader(),
+ decoder: new TextDecoder("utf-8"),
+ };
+ });
+
+ return {
+ stream: fetchPromise,
+ cancel: (reason) => {
+ if (!controller.signal.aborted) {
+ controller.abort(reason);
+ }
+ },
+ };
}
/**
@@ -71,40 +72,44 @@ export function createChatStream(params) {
* @param {Function} onError 错误回调
* @param {Function} onComplete 完成回调
*/
-export async function processStream(reader, decoder, { onMessage, onError, onComplete }) {
- let buffer = ''
+export async function processStream(
+ reader,
+ decoder,
+ { onMessage, onError, onComplete }
+) {
+ let buffer = "";
- try {
- while (true) {
- const { done, value } = await reader.read()
- if (done) break
+ try {
+ while (true) {
+ const { done, value } = await reader.read();
+ if (done) break;
- buffer += decoder.decode(value, { stream: true })
- const lines = buffer.split('\n')
- buffer = lines.pop() || ''
+ buffer += decoder.decode(value, { stream: true });
+ const lines = buffer.split("\n");
+ buffer = lines.pop() || "";
- for (const line of lines) {
- if (!line.trim()) continue
+ for (const line of lines) {
+ if (!line.trim()) continue;
- try {
- const data = JSON.parse(line)
- if (typeof onMessage === 'function') {
- onMessage(data)
- }
- } catch (e) {
- console.warn('解析消息失败:', line, e)
- }
- }
+ try {
+ const data = JSON.parse(line);
+ if (typeof onMessage === "function") {
+ onMessage(data);
+ }
+ } catch (e) {
+ console.warn("解析消息失败:", line, e);
}
-
- if (typeof onComplete === 'function') {
- onComplete()
- }
- } catch (error) {
- if (error.name !== 'AbortError' && typeof onError === 'function') {
- onError(error)
- }
- } finally {
- reader.releaseLock()
+ }
}
-}
\ No newline at end of file
+
+ if (typeof onComplete === "function") {
+ onComplete();
+ }
+ } catch (error) {
+ if (error.name !== "AbortError" && typeof onError === "function") {
+ onError(error);
+ }
+ } finally {
+ reader.releaseLock();
+ }
+}
-
- {{ ref.document_name }}
-
+
+
-
-
- {{ ref.content }}
+
+
-
-
+
-
- 引用来源：
+
+
+ {{ group.docName }} ({{ group.items.length }})
+
+
+
+
{{ item.content }}
+
+
- 回答由AI生成
-
- 
- 
+
+
@@ -67,704 +84,1152 @@
-
+
+
+
AI回答也可能会犯错。请核查重要信息。
+
- 
- 
+
+
-
+
diff --git a/src/layout/index.vue b/src/layout/index.vue
index 1b091d8..17e87ae 100644
--- a/src/layout/index.vue
+++ b/src/layout/index.vue
@@ -21,10 +21,11 @@
-
+
+
+
+
+
+
-
+ AI
+
-