refactor: ♻️ 字典调整按需加载,api、store和枚举文件命名优化

This commit is contained in:
Ray.Hao
2025-03-24 08:17:31 +08:00
parent 6204deb7cb
commit 3c9cf67961
84 changed files with 989 additions and 1108 deletions

View File

@@ -1,7 +1,7 @@
import axios, { type InternalAxiosRequestConfig, type AxiosResponse } from "axios";
import qs from "qs";
import { useUserStoreHook } from "@/store/modules/user";
import { ResultEnum } from "@/enums/ResultEnum";
import { useUserStoreHook } from "@/store/modules/user.store";
import { ResultEnum } from "@/enums/api/result.enum";
import { getAccessToken } from "@/utils/auth";
import router from "@/router";
@@ -12,12 +12,11 @@ const service = axios.create({
headers: { "Content-Type": "application/json;charset=utf-8" },
paramsSerializer: (params) => qs.stringify(params),
});
// 请求拦截器
service.interceptors.request.use(
(config: InternalAxiosRequestConfig) => {
const accessToken = getAccessToken();
// 如果 Authorization 设置为 no-auth则不携带 Token,用于登录、刷新 Token 等接口
// 如果 Authorization 设置为 no-auth则不携带 Token
if (config.headers.Authorization !== "no-auth" && accessToken) {
config.headers.Authorization = `Bearer ${accessToken}`;
} else {
@@ -27,7 +26,6 @@ service.interceptors.request.use(
},
(error) => Promise.reject(error)
);
// 响应拦截器
service.interceptors.response.use(
(response: AxiosResponse) => {
@@ -35,18 +33,15 @@ service.interceptors.response.use(
if (response.config.responseType === "blob") {
return response;
}
const { code, data, msg } = response.data;
if (code === ResultEnum.SUCCESS) {
return data;
}
ElMessage.error(msg || "系统出错");
return Promise.reject(new Error(msg || "Error"));
},
async (error) => {
console.error("request error", error); // for debug
// 非 2xx 状态码处理 401、403、500 等
const { config, response } = error;
if (response) {
const { code, msg } = response.data;
@@ -54,6 +49,8 @@ service.interceptors.response.use(
// Token 过期,刷新 Token
return handleTokenRefresh(config);
} else if (code === ResultEnum.REFRESH_TOKEN_INVALID) {
// 刷新 Token 过期,跳转登录页
await handleSessionExpired();
return Promise.reject(new Error(msg || "Error"));
} else {
ElMessage.error(msg || "系统出错");
@@ -62,29 +59,22 @@ service.interceptors.response.use(
return Promise.reject(error.message);
}
);
export default service;
// 是否正在刷新标识,避免重复刷新
let isRefreshing = false;
// 因 Token 过期导致的请求等待队列
const waitingQueue: Array<() => void> = [];
// 刷新 Token 处理
async function handleTokenRefresh(config: InternalAxiosRequestConfig) {
return new Promise((resolve) => {
// 封装需要重试的请求
const retryRequest = () => {
config.headers.Authorization = getAccessToken();
config.headers.Authorization = `Bearer ${getAccessToken()}`;
resolve(service(config));
};
waitingQueue.push(retryRequest);
if (!isRefreshing) {
isRefreshing = true;
// 刷新 Token
useUserStoreHook()
.refreshToken()
.then(() => {
@@ -92,19 +82,10 @@ async function handleTokenRefresh(config: InternalAxiosRequestConfig) {
waitingQueue.forEach((callback) => callback());
waitingQueue.length = 0;
})
.catch((error: any) => {
console.log("handleTokenRefresh error", error);
.catch(async (error) => {
console.error("handleTokenRefresh error", error);
// 刷新 Token 失败,跳转登录页
ElNotification({
title: "提示",
message: "您的会话已过期,请重新登录",
type: "info",
});
useUserStoreHook()
.clearUserData()
.then(() => {
router.push("/login");
});
await handleSessionExpired();
})
.finally(() => {
isRefreshing = false;
@@ -112,3 +93,13 @@ async function handleTokenRefresh(config: InternalAxiosRequestConfig) {
}
});
}
// 处理会话过期
async function handleSessionExpired() {
ElNotification({
title: "提示",
message: "您的会话已过期,请重新登录",
type: "info",
});
await useUserStoreHook().clearSessionAndCache();
router.push("/login");
}