From c2c7d3c66be938892edaa77d96d8af7f98a66c6d Mon Sep 17 00:00:00 2001
From: yangyin <1850366751@qq.com>
Date: 星期五, 08 十一月 2024 10:57:20 +0800
Subject: [PATCH] 修改样式显示还是隐藏

---
 src/utils/request.ts |   83 ++++++++++++++++++++++++++++++++++-------
 1 files changed, 68 insertions(+), 15 deletions(-)

diff --git a/src/utils/request.ts b/src/utils/request.ts
index bf97f7c..666feaf 100644
--- a/src/utils/request.ts
+++ b/src/utils/request.ts
@@ -1,10 +1,11 @@
-import type { AxiosInstance, AxiosRequestConfig } from 'axios';
+import type { AxiosInstance, AxiosRequestConfig, CreateAxiosDefaults } from 'axios';
 import axios from 'axios';
 import { ElMessage } from 'element-plus';
 import { NO_AUTH_API_LIST } from '../api/ai/chat';
 import { LOGIN_URL, TEL_LOGIN_URL } from '../api/ai/user';
+import { Logger } from '../model/logger/Logger';
 import emitter from './mitt';
-import { debounce } from './util';
+import { debounce, decodeFormData } from './util';
 import { AUTH_URL, MAIN_URL, SECONDARY_URL } from '/@/constants';
 import { Local, LoginInfo, Session } from '/@/utils/storage';
 // import JSONbig from 'json-bigint';
@@ -34,7 +35,7 @@
 	return !!accessSession;
 };
 
-const handleNoAuth = debounce(() => {
+export const handleNoAuth = debounce(() => {
 	emitNoAuth();
 });
 const initRequestInterceptor = (request: AxiosInstance) => {
@@ -43,15 +44,14 @@
 		(config) => {
 			// 鑾峰彇鏈湴鐨� token
 			const accessSession = Local.get(accessSessionKey);
+			if (accessSession) {
+				// 灏� token 娣诲姞鍒拌姹傛姤鏂囧ご涓�
+				config.headers['hswatersession'] = accessSession;
+			}
 			if (!NO_AUTH_API_LIST.includes(config.url)) {
-				if (accessSession) {
-					// 灏� token 娣诲姞鍒拌姹傛姤鏂囧ご涓�
-					config.headers['hswatersession'] = accessSession;
-				} else {
-					if (config.url !== LOGIN_URL && config.url !== TEL_LOGIN_URL) {
-						handleNoAuth(config.url);
-						throw '鏉冮檺楠岃瘉澶辫触';
-					}
+				if (!accessSession && config.url !== LOGIN_URL && config.url !== TEL_LOGIN_URL) {
+					handleNoAuth(config.url);
+					throw '鏉冮檺楠岃瘉澶辫触';
 				}
 			}
 
@@ -94,8 +94,10 @@
 						}
 						break;
 					case ErrorCode.Exception:
+						const param = res.config.data ? `\n    璇锋眰鍙傛暟锛�${JSON.stringify(decodeFormData(res.config.data))}\n` : '';
 						ElMessage.error('鍐呴儴閿欒锛�');
-						throw '鍐呴儴閿欒';
+						Logger.error(`${res.config.url} 鍝嶅簲澶辫触${param}`, serveData?.json_msg && new Error(serveData?.json_msg));
+						return res.data;
 				}
 			}
 			return res.data;
@@ -126,18 +128,69 @@
 	);
 };
 // 閰嶇疆鏂板缓涓�涓� axios 瀹炰緥
-const createAxiosInstance = () => {
+const createAxiosInstance = (option: Partial<CreateAxiosDefaults<any>> = {}) => {
 	return axios.create({
 		baseURL: MAIN_URL,
-		timeout: 50000,
-		headers: { 'Content-Type': 'application/json;charset=utf-8 ' },
+		timeout: 1200000,
+		headers: {
+			'Content-Type': 'application/x-www-form-urlencoded',
+		},
+		...option,
 	});
 };
+
 const service = createAxiosInstance();
 
 export const mainRequest = service;
 
+//#region ====================== 娴佸搷搴旀暟鎹� ======================
+const streamInstance = createAxiosInstance({
+	adapter: 'fetch',
+	responseType: 'stream',
+});
+const decoder = new TextDecoder();
+const readStream = async (stream: ReadableStream, cb: (value) => void): Promise<any> => {
+	const reader = stream.getReader();
+	let lastValue = '';
+	const p = new Promise(async (resolve, reject) => {
+		let fullValue = '';
+		while (1) {
+			const { done, value } = await reader.read();
+			if (done) {
+				break;
+			}
+			// const txt = decoder.decode(Uint8Array.from([...lastValue, ...value]));
+			const txt = decoder.decode(value);
+			const txtArr = txt.split('\n');
+			txtArr[0] = lastValue + txtArr[0];
+			txtArr.forEach((value, index, array) => {
+				// 涓�鑸笉浼氬嚭鐜拌繛缁崲琛岋紝鍙彲鑳芥渶鍚庝竴涓槸鎹㈣
+				if (index === array.length - 1) {
+					lastValue = value;
+				} else {
+					const decodeValue = decodeURIComponent(value);
+					fullValue += decodeValue;
+					cb(decodeValue);
+				}
+			});
+		}
+		resolve(fullValue);
+	});
+	return p;
+};
+
+export const streamReq = async (config: AxiosRequestConfig<any>, callback: (value) => void) => {
+	const response = await streamInstance(config);
+	const stream = response as unknown as ReadableStream;
+	return readStream(stream, (value) => {
+		const jsonValue = JSON.parse(value);
+		callback(jsonValue);
+	});
+};
+//#endregion
+
 initRequestInterceptor(service);
+initRequestInterceptor(streamInstance);
 
 export function secondaryRequest(config: AxiosRequestConfig<any>) {
 	return service({

--
Gitblit v1.9.3