import { useStore } from "../store";
|
import { router } from "../router";
|
import { isDev, config } from "../../config";
|
import { storage } from "../utils";
|
import { getLocale, t } from "/@/locale";
|
|
// 请求队列
|
let requests: any[] = [];
|
|
// Token 是否刷新中
|
let isRefreshing = false;
|
|
let reloginTask: Promise<boolean> | null = null;
|
|
function dropToken() {
|
const { user } = useStore();
|
user.token = "";
|
storage.remove("token");
|
storage.remove("token_deadtime");
|
storage.remove("refreshToken");
|
storage.remove("refreshToken_deadtime");
|
}
|
|
function recoverLogin() {
|
if (reloginTask) {
|
return reloginTask;
|
}
|
reloginTask = import("../mini-login")
|
.then(({ miniAutoLogin }) => {
|
dropToken();
|
return miniAutoLogin(true);
|
})
|
.catch(() => false)
|
.finally(() => {
|
reloginTask = null;
|
});
|
return reloginTask;
|
}
|
|
export default function request(options: any) {
|
const { user } = useStore();
|
|
// 标识
|
let Authorization = user.token || "";
|
|
// 忽略标识
|
config.ignore.token.forEach((e) => {
|
if (options.url.includes(e)) {
|
Authorization = "";
|
}
|
});
|
|
if (isDev) {
|
console.log(`[${options.method || "GET"}] ${options.url}`);
|
}
|
|
return new Promise(async (resolve, reject) => {
|
// 继续请求
|
function next() {
|
uni.request({
|
...options,
|
|
header: {
|
Authorization,
|
language: getLocale(),
|
...options.header,
|
},
|
|
success(res: any) {
|
const { code, data, message } = res.data as {
|
code: number;
|
message: string;
|
data: any;
|
};
|
|
const invalid = res.statusCode === 401 || message === "登录失效~";
|
const skipRelogin = /miniAuto|refreshToken/.test(options.url || "");
|
if (invalid && !skipRelogin && !options.__retried) {
|
options.__retried = true;
|
recoverLogin()
|
.then((ok) => {
|
if (!ok) {
|
reject({ message: message || "登录失效~", code: code || 1001 });
|
return;
|
}
|
Authorization = useStore().user.token || "";
|
next();
|
})
|
.catch((err) => reject(err));
|
return;
|
}
|
|
// 无权限
|
if (res.statusCode === 401) {
|
if (router.info()?.path == router.pages.login) {
|
return reject({ message });
|
} else {
|
user.logout();
|
}
|
}
|
|
// 服务异常
|
if (res.statusCode === 502) {
|
return reject({
|
message: t("服务异常"),
|
});
|
}
|
|
// 未找到
|
if (res.statusCode === 404) {
|
return reject({
|
message: `[404] ${options.url}`,
|
});
|
}
|
|
// 成功
|
if (res.statusCode === 200) {
|
switch (code) {
|
case 1000:
|
resolve(data);
|
break;
|
default:
|
reject({ message, code });
|
}
|
} else {
|
reject({ message: t("服务异常") });
|
}
|
},
|
|
fail(err: any) {
|
reject({ message: err.errMsg });
|
},
|
});
|
}
|
|
// 刷新token处理
|
if (!options.url.includes("refreshToken")) {
|
if (Authorization) {
|
// 判断 token 是否过期
|
if (storage.isExpired("token")) {
|
// 判断 refreshToken 是否过期
|
if (!storage.get("refreshToken") || storage.isExpired("refreshToken")) {
|
recoverLogin()
|
.then((ok) => {
|
if (!ok) {
|
reject({ message: "登录失效~", code: 1001 });
|
return;
|
}
|
Authorization = useStore().user.token || "";
|
next();
|
})
|
.catch((err) => reject(err));
|
return;
|
}
|
|
// 是否在刷新中
|
if (!isRefreshing) {
|
isRefreshing = true;
|
user.refreshToken()
|
.then((token) => {
|
requests.forEach((cb) => cb(token));
|
requests = [];
|
isRefreshing = false;
|
})
|
.catch(() => {
|
isRefreshing = false;
|
requests = [];
|
recoverLogin()
|
.then((ok) => {
|
if (!ok) {
|
reject({ message: "登录失效~", code: 1001 });
|
return;
|
}
|
Authorization = useStore().user.token || "";
|
next();
|
})
|
.catch((err) => reject(err));
|
});
|
}
|
|
return new Promise((resolve) => {
|
// 继续请求
|
requests.push((token: string) => {
|
// 重新设置 token
|
Authorization = token;
|
next();
|
resolve();
|
});
|
});
|
}
|
}
|
}
|
|
next();
|
});
|
}
|
