fix

2026-03-07 01:34:48 +08:00
parent adc511cfdc
commit 94c3473958
1211 changed files with 599405 additions and 322105 deletions
--- a/src/api/knowledge/aiBill.ts
+++ b/src/api/knowledge/aiBill.ts
@@ -1,50 +1,48 @@
-import request from "/@/utils/request"
+import request from '/@/utils/request';

 export function fetchList(query?: Object) {
-  return request({
-    url: '/knowledge/aiBill/page',
-    method: 'get',
-    params: query
-  })
+	return request({
+		url: '/knowledge/aiBill/page',
+		method: 'get',
+		params: query,
+	});
 }

 export function addObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiBill',
-    method: 'post',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiBill',
+		method: 'post',
+		data: obj,
+	});
 }

 export function getObj(id?: string) {
-  return request({
-    url: '/knowledge/aiBill/' + id,
-    method: 'get'
-  })
+	return request({
+		url: '/knowledge/aiBill/' + id,
+		method: 'get',
+	});
 }

 export function delObjs(ids?: Object) {
-  return request({
-    url: '/knowledge/aiBill',
-    method: 'delete',
-    data: ids
-  })
+	return request({
+		url: '/knowledge/aiBill',
+		method: 'delete',
+		data: ids,
+	});
 }

 export function putObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiBill',
-    method: 'put',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiBill',
+		method: 'put',
+		data: obj,
+	});
 }

 export const getSum = (params?: Object) => {
-  return request({
-    url: '/knowledge/aiBill/sum',
-    method: 'get',
-    params,
-  });
+	return request({
+		url: '/knowledge/aiBill/sum',
+		method: 'get',
+		params,
+	});
 };
-
-
--- a/src/api/knowledge/aiChatRecord.ts
+++ b/src/api/knowledge/aiChatRecord.ts
@@ -1,41 +1,40 @@
-import request from "/@/utils/request"
+import request from '/@/utils/request';

 export function fetchList(query?: Object) {
-  return request({
-    url: '/knowledge/aiChatRecord/page',
-    method: 'get',
-    params: query
-  })
+	return request({
+		url: '/knowledge/aiChatRecord/page',
+		method: 'get',
+		params: query,
+	});
 }

 export function addObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiChatRecord',
-    method: 'post',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiChatRecord',
+		method: 'post',
+		data: obj,
+	});
 }

 export function getObj(id?: string) {
-  return request({
-    url: '/knowledge/aiChatRecord/' + id,
-    method: 'get'
-  })
+	return request({
+		url: '/knowledge/aiChatRecord/' + id,
+		method: 'get',
+	});
 }

 export function delObjs(ids?: Object) {
-  return request({
-    url: '/knowledge/aiChatRecord',
-    method: 'delete',
-    data: ids
-  })
+	return request({
+		url: '/knowledge/aiChatRecord',
+		method: 'delete',
+		data: ids,
+	});
 }

 export function putObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiChatRecord',
-    method: 'put',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiChatRecord',
+		method: 'put',
+		data: obj,
+	});
 }
-
--- a/src/api/knowledge/aiData.ts
+++ b/src/api/knowledge/aiData.ts
@@ -1,41 +1,40 @@
-import request from "/@/utils/request"
+import request from '/@/utils/request';

 export function fetchList(query?: Object) {
-  return request({
-    url: '/knowledge/aiData/page',
-    method: 'get',
-    params: query
-  })
+	return request({
+		url: '/knowledge/aiData/page',
+		method: 'get',
+		params: query,
+	});
 }

 export function addObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiData',
-    method: 'post',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiData',
+		method: 'post',
+		data: obj,
+	});
 }

 export function getObj(id?: string) {
-  return request({
-    url: '/knowledge/aiData/' + id,
-    method: 'get'
-  })
+	return request({
+		url: '/knowledge/aiData/' + id,
+		method: 'get',
+	});
 }

 export function delObjs(ids?: Object) {
-  return request({
-    url: '/knowledge/aiData',
-    method: 'delete',
-    data: ids
-  })
+	return request({
+		url: '/knowledge/aiData',
+		method: 'delete',
+		data: ids,
+	});
 }

 export function putObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiData',
-    method: 'put',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiData',
+		method: 'put',
+		data: obj,
+	});
 }
-
--- a/src/api/knowledge/aiDatasetUser.ts
+++ b/src/api/knowledge/aiDatasetUser.ts
@@ -1,4 +1,4 @@
-import request from "/@/utils/request"
+import request from '/@/utils/request';

 /**
 * 根据分页查询参数获取列表数据。
@@ -6,11 +6,11 @@ import request from "/@/utils/request"
 * @returns {Promise} 请求的 Promise 分页对象。
 */
 export function fetchList(query?: Object) {
-  return request({
-    url: '/knowledge/aiDatasetUser/page',
-    method: 'get',
-    params: query
-  })
+	return request({
+		url: '/knowledge/aiDatasetUser/page',
+		method: 'get',
+		params: query,
+	});
 }

 /**
@@ -19,11 +19,11 @@ export function fetchList(query?: Object) {
 * @returns {Promise} 请求的 Promise 对象 （true/false）。
 */
 export function addObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiDatasetUser',
-    method: 'post',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiDatasetUser',
+		method: 'post',
+		data: obj,
+	});
 }

 /**
@@ -32,11 +32,11 @@ export function addObj(obj?: Object) {
 * @returns {Promise} 请求的 Promise 对象数组。
 */
 export function getObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiDatasetUser/details',
-    method: 'get',
-    params: obj
-  })
+	return request({
+		url: '/knowledge/aiDatasetUser/details',
+		method: 'get',
+		params: obj,
+	});
 }

 /**
@@ -45,11 +45,11 @@ export function getObj(obj?: Object) {
 * @returns {Promise} 请求的 Promise 对象。
 */
 export function delObjs(ids?: Object) {
-  return request({
-    url: '/knowledge/aiDatasetUser',
-    method: 'delete',
-    data: ids
-  })
+	return request({
+		url: '/knowledge/aiDatasetUser',
+		method: 'delete',
+		data: ids,
+	});
 }

 /**
@@ -58,11 +58,11 @@ export function delObjs(ids?: Object) {
 * @returns {Promise} 请求的 Promise 对象。
 */
 export function putObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiDatasetUser',
-    method: 'put',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiDatasetUser',
+		method: 'put',
+		data: obj,
+	});
 }

 /**
@@ -71,7 +71,7 @@ export function putObj(obj?: Object) {
 * @param {*} value - 要验证的值。
 * @param {Function} callback - 验证完成后的回调函数。
 * @param {boolean} isEdit - 当前操作是否为编辑。
- * 
+ *
 * 示例用法：
 * 字段名: [
 *   {
@@ -83,18 +83,16 @@ export function putObj(obj?: Object) {
 * ]
 */
 export function validateExist(rule: any, value: any, callback: any, isEdit: boolean) {
-  if (isEdit) {
-    return callback();
-  }
+	if (isEdit) {
+		return callback();
+	}

-  getObj({ [rule.field]: value }).then((response) => {
-    const result = response.data;
-    if (result !== null && result.length > 0) {
-      callback(new Error('数据已经存在'));
-    } else {
-      callback();
-    }
-  });
+	getObj({ [rule.field]: value }).then((response) => {
+		const result = response.data;
+		if (result !== null && result.length > 0) {
+			callback(new Error('数据已经存在'));
+		} else {
+			callback();
+		}
+	});
 }
-
-
--- a/src/api/knowledge/aiFlow.ts
+++ b/src/api/knowledge/aiFlow.ts
@@ -279,7 +279,7 @@ export interface FlowExecutionCallbacks {

 export function executeFlow(data: { id: string; params: any; envs: any; stream?: boolean }) {
 	return request.post(`/knowledge/aiFlow/execute`, data, {
-		timeout: 300000 // 设置超时时间为300秒 (300000毫秒)
+		timeout: 300000, // 设置超时时间为300秒 (300000毫秒)
 	});
 }

@@ -295,7 +295,7 @@ export async function executeFlowSSE(
 ): Promise<FlowExecutionResult> {
 	const token = Session.getToken();
 	const tenant = Session.getTenant();
-	
+
 	return new Promise<FlowExecutionResult>((resolve, reject) => {
 		let controller: AbortController | null = new AbortController();
 		let result: FlowExecutionResult | null = null;
@@ -311,7 +311,7 @@ export async function executeFlowSSE(
 		const parseSSEResponse = (eventData: string) => {
 			try {
 				const parsed = JSON.parse(eventData);
-				
+
 				// 处理聊天格式的数据: {"data":{"content":"...", "tokens": 123, "duration": 22986, "nodes": [...]}}
 				if (parsed.data && parsed.data.content !== undefined) {
 					return {
@@ -320,10 +320,10 @@ export async function executeFlowSSE(
 						tokens: parsed.data.tokens, // 添加 tokens 字段
 						duration: parsed.data.duration, // 添加 duration 字段
 						nodes: parsed.data.nodes, // 添加 nodes 字段
-						isStreaming: true
+						isStreaming: true,
 					} as FlowExecutionEvent;
 				}
-				
+
 				// 处理标准的FlowExecutionEvent格式
 				return parsed as FlowExecutionEvent;
 			} catch (e) {
@@ -361,26 +361,26 @@ export async function executeFlowSSE(
 					case 'chat_message':
 						// 处理聊天消息流
 						if (parsed.content !== undefined) {
-												// 检查是否收到完成标记
-					if (parsed.content === '[DONE]') {
-						// 标记聊天消息完成并关闭连接，传递 tokens、duration 和 nodes 信息
-						callbacks?.onChatMessage?.('', true, parsed.tokens, parsed.duration, parsed.nodes);
-						cleanup();
-						// 如果没有正式的结果，创建一个默认结果
-						if (!result) {
-							result = {
-								nodes: parsed.nodes || [],
-								executed: true,
-								result: {},
-								duration: parsed.duration || 0,
-								totalTokens: parsed.tokens || 0
-							};
-							callbacks?.onComplete?.(result);
-							resolve(result);
-						}
-						return;
-					}
-					callbacks?.onChatMessage?.(parsed.content, false, parsed.tokens, parsed.duration, parsed.nodes);
+							// 检查是否收到完成标记
+							if (parsed.content === '[DONE]') {
+								// 标记聊天消息完成并关闭连接，传递 tokens、duration 和 nodes 信息
+								callbacks?.onChatMessage?.('', true, parsed.tokens, parsed.duration, parsed.nodes);
+								cleanup();
+								// 如果没有正式的结果，创建一个默认结果
+								if (!result) {
+									result = {
+										nodes: parsed.nodes || [],
+										executed: true,
+										result: {},
+										duration: parsed.duration || 0,
+										totalTokens: parsed.tokens || 0,
+									};
+									callbacks?.onComplete?.(result);
+									resolve(result);
+								}
+								return;
+							}
+							callbacks?.onChatMessage?.(parsed.content, false, parsed.tokens, parsed.duration, parsed.nodes);
 						}
 						break;
 					case 'complete':
@@ -414,15 +414,14 @@ export async function executeFlowSSE(
 		};

 		// 启动SSE连接
-		fetchEventSource(`${request.defaults.baseURL}${other.adaptationUrl('/knowledge/aiFlow/execute')}`, fetchOptions)
-			.catch((error) => {
-				cleanup();
-				if (error.name === 'AbortError') {
-					reject(new Error('Request was cancelled'));
-				} else {
-					reject(error);
-				}
-			});
+		fetchEventSource(`${request.defaults.baseURL}${other.adaptationUrl('/knowledge/aiFlow/execute')}`, fetchOptions).catch((error) => {
+			cleanup();
+			if (error.name === 'AbortError') {
+				reject(new Error('Request was cancelled'));
+			} else {
+				reject(error);
+			}
+		});

 		// 返回清理函数以便外部可以取消请求
 		return cleanup;
@@ -447,11 +446,11 @@ export async function cancelFlowExecution(executionId: string) {
 export async function executeFlowSSEWithChat(
 	data: { id: string; conversationId: string; params: any; envs: any; stream?: boolean },
 	callbacks?: FlowExecutionCallbacks
-): Promise<{chatMessage: string, result: any}> {
+): Promise<{ chatMessage: string; result: any }> {
 	const token = Session.getToken();
 	const tenant = Session.getTenant();
-	
-	return new Promise<{chatMessage: string, result: any}>((resolve, reject) => {
+
+	return new Promise<{ chatMessage: string; result: any }>((resolve, reject) => {
 		let controller: AbortController | null = new AbortController();
 		let chatMessageContent = '';
 		let hasReceivedData = false;
@@ -482,35 +481,35 @@ export async function executeFlowSSEWithChat(
 			onmessage(event: { data: string }) {
 				try {
 					const parsed = JSON.parse(event.data);
-					
+
 					// 处理聊天格式的数据: {"data":{"content":"...", "tokens": 123, "duration": 22986}}
 					if (parsed.data && parsed.data.content !== undefined) {
 						hasReceivedData = true;
-						
-										// 检查是否收到完成标记
-				if (parsed.data.content === '[DONE]') {
-					const result = {
-						chatMessage: chatMessageContent,
-						result: {
-							nodes: parsed.data.nodes || [],
-							executed: true,
-							result: {},
-							duration: parsed.data.duration || 0,
-							totalTokens: parsed.data.tokens || 0
+
+						// 检查是否收到完成标记
+						if (parsed.data.content === '[DONE]') {
+							const result = {
+								chatMessage: chatMessageContent,
+								result: {
+									nodes: parsed.data.nodes || [],
+									executed: true,
+									result: {},
+									duration: parsed.data.duration || 0,
+									totalTokens: parsed.data.tokens || 0,
+								},
+							};
+							callbacks?.onChatMessage?.('', true, parsed.data.tokens, parsed.data.duration, parsed.data.nodes); // 标记聊天消息完成，传递 tokens、duration 和 nodes
+							callbacks?.onComplete?.(result.result);
+							cleanup();
+							resolve(result);
+							return;
 						}
-					};
-					callbacks?.onChatMessage?.('', true, parsed.data.tokens, parsed.data.duration, parsed.data.nodes); // 标记聊天消息完成，传递 tokens、duration 和 nodes
-					callbacks?.onComplete?.(result.result);
-					cleanup();
-					resolve(result);
-					return;
-				}
-				
-				chatMessageContent += parsed.data.content;
-				callbacks?.onChatMessage?.(parsed.data.content, false, parsed.data.tokens, parsed.data.duration, parsed.data.nodes);
+
+						chatMessageContent += parsed.data.content;
+						callbacks?.onChatMessage?.(parsed.data.content, false, parsed.data.tokens, parsed.data.duration, parsed.data.nodes);
 						return;
 					}
-					
+
 					// 处理其他类型的事件
 					if (parsed.type) {
 						switch (parsed.type) {
@@ -523,7 +522,7 @@ export async function executeFlowSSEWithChat(
 							case 'complete':
 								const result = {
 									chatMessage: chatMessageContent,
-									result: parsed.result || {}
+									result: parsed.result || {},
 								};
 								callbacks?.onChatMessage?.('', true); // 标记聊天消息完成
 								callbacks?.onComplete?.(parsed.result);
@@ -545,7 +544,7 @@ export async function executeFlowSSEWithChat(
 				if (hasReceivedData) {
 					const result = {
 						chatMessage: chatMessageContent,
-						result: {}
+						result: {},
 					};
 					callbacks?.onChatMessage?.('', true);
 					resolve(result);
@@ -562,14 +561,13 @@ export async function executeFlowSSEWithChat(
 		};

 		// 启动SSE连接
-		fetchEventSource(`${request.defaults.baseURL}${other.adaptationUrl('/knowledge/aiFlow/execute')}`, fetchOptions)
-			.catch((error) => {
-				cleanup();
-				if (error.name === 'AbortError') {
-					reject(new Error('Request was cancelled'));
-				} else {
-					reject(error);
-				}
-			});
+		fetchEventSource(`${request.defaults.baseURL}${other.adaptationUrl('/knowledge/aiFlow/execute')}`, fetchOptions).catch((error) => {
+			cleanup();
+			if (error.name === 'AbortError') {
+				reject(new Error('Request was cancelled'));
+			} else {
+				reject(error);
+			}
+		});
 	});
-}
+}
--- a/src/api/knowledge/aiMaterialLog.ts
+++ b/src/api/knowledge/aiMaterialLog.ts
@@ -1,41 +1,40 @@
-import request from "/@/utils/request"
+import request from '/@/utils/request';

 export function fetchList(query?: Object) {
-  return request({
-    url: '/knowledge/aiMaterialLog/page',
-    method: 'get',
-    params: query
-  })
+	return request({
+		url: '/knowledge/aiMaterialLog/page',
+		method: 'get',
+		params: query,
+	});
 }

 export function addObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiMaterialLog',
-    method: 'post',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiMaterialLog',
+		method: 'post',
+		data: obj,
+	});
 }

 export function getObj(id?: string) {
-  return request({
-    url: '/knowledge/aiMaterialLog/' + id,
-    method: 'get'
-  })
+	return request({
+		url: '/knowledge/aiMaterialLog/' + id,
+		method: 'get',
+	});
 }

 export function delObjs(ids?: Object) {
-  return request({
-    url: '/knowledge/aiMaterialLog',
-    method: 'delete',
-    data: ids
-  })
+	return request({
+		url: '/knowledge/aiMaterialLog',
+		method: 'delete',
+		data: ids,
+	});
 }

 export function putObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiMaterialLog',
-    method: 'put',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiMaterialLog',
+		method: 'put',
+		data: obj,
+	});
 }
-
--- a/src/api/knowledge/aiSlice.ts
+++ b/src/api/knowledge/aiSlice.ts
@@ -1,49 +1,48 @@
-import request from "/@/utils/request"
+import request from '/@/utils/request';

 export function fetchList(query?: Object) {
-  return request({
-    url: '/knowledge/aiSlice/page',
-    method: 'get',
-    params: query
-  })
+	return request({
+		url: '/knowledge/aiSlice/page',
+		method: 'get',
+		params: query,
+	});
 }

 export function fetchRecall(query?: Object) {
-  return request({
-    url: '/knowledge/aiSlice/recall',
-    method: 'get',
-    params: query
-  })
+	return request({
+		url: '/knowledge/aiSlice/recall',
+		method: 'get',
+		params: query,
+	});
 }

 export function addObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiSlice',
-    method: 'post',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiSlice',
+		method: 'post',
+		data: obj,
+	});
 }

 export function getObj(id?: string) {
-  return request({
-    url: '/knowledge/aiSlice/' + id,
-    method: 'get'
-  })
+	return request({
+		url: '/knowledge/aiSlice/' + id,
+		method: 'get',
+	});
 }

 export function delObjs(ids?: Object) {
-  return request({
-    url: '/knowledge/aiSlice',
-    method: 'delete',
-    data: ids
-  })
+	return request({
+		url: '/knowledge/aiSlice',
+		method: 'delete',
+		data: ids,
+	});
 }

 export function putObj(obj?: Object) {
-  return request({
-    url: '/knowledge/aiSlice',
-    method: 'put',
-    data: obj
-  })
+	return request({
+		url: '/knowledge/aiSlice',
+		method: 'put',
+		data: obj,
+	});
 }
-