wangzhibo
4 天以前 10595d8632f959d0954d1939243196f4eed02372
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
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;
 
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;
                    };
 
                    // 无权限
                    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.isExpired("refreshToken")) {
                        // 退出登录
                        return user.logout();
                    }
 
                    // 是否在刷新中
                    if (!isRefreshing) {
                        isRefreshing = true;
                        user.refreshToken()
                            .then((token) => {
                                requests.forEach((cb) => cb(token));
                                requests = [];
                                isRefreshing = false;
                            })
                            .catch((err) => {
                                user.logout();
                                reject(err);
                            });
                    }
 
                    return new Promise((resolve) => {
                        // 继续请求
                        requests.push((token: string) => {
                            // 重新设置 token
                            Authorization = token;
                            next();
                            resolve();
                        });
                    });
                }
            }
        }
 
        next();
    });
}