375 lines
12 KiB
TypeScript
375 lines
12 KiB
TypeScript
import type { AxiosInstance, AxiosResponse, AxiosError, InternalAxiosRequestConfig, AxiosRequestConfig } from 'axios'
|
||
import type { RequestOptions, Result, UploadFileParams } from '@/types/axios'
|
||
import type { CreateAxiosOptions } from './axiosTransform'
|
||
import axios from 'axios'
|
||
import qs from 'qs'
|
||
import { AxiosCanceler } from './axiosCancel'
|
||
import { isFunction } from '@/utils/is'
|
||
import { cloneDeep } from 'lodash-es'
|
||
import { ContentTypeEnum } from '@/enums/httpEnum'
|
||
import { RequestEnum } from '@/enums/httpEnum'
|
||
import { downloadByData } from '@/utils/file/download'
|
||
import { useGlobSetting } from '@/hooks/setting'
|
||
import { setAccessToken, getRefreshToken, getTenantId, getAccessToken } from '@/utils/auth'
|
||
|
||
export * from './axiosTransform'
|
||
const globSetting = useGlobSetting()
|
||
// 请求队列
|
||
let requestList: any[] = []
|
||
// 是否正在刷新中
|
||
let isRefreshToken = false
|
||
|
||
/**
|
||
* @description: axios 模块
|
||
*/
|
||
export class VAxios {
|
||
private axiosInstance: AxiosInstance
|
||
private readonly options: CreateAxiosOptions
|
||
|
||
constructor(options: CreateAxiosOptions) {
|
||
this.options = options
|
||
this.axiosInstance = axios.create(options)
|
||
this.setupInterceptors()
|
||
}
|
||
|
||
/**
|
||
* @description: 创建 axios 实例
|
||
*/
|
||
private createAxios(config: CreateAxiosOptions): void {
|
||
this.axiosInstance = axios.create(config)
|
||
}
|
||
|
||
private getTransform() {
|
||
const { transform } = this.options
|
||
return transform
|
||
}
|
||
|
||
getAxios(): AxiosInstance {
|
||
return this.axiosInstance
|
||
}
|
||
refreshToken() {
|
||
axios.defaults.headers.common['tenant-id'] = getTenantId() as number
|
||
return axios.post(globSetting.apiUrl + '/system/auth/refresh-token?refreshToken=' + getRefreshToken())
|
||
}
|
||
|
||
/**
|
||
* @description: 重新配置 axios
|
||
*/
|
||
configAxios(config: CreateAxiosOptions) {
|
||
if (!this.axiosInstance) {
|
||
return
|
||
}
|
||
this.createAxios(config)
|
||
}
|
||
|
||
/**
|
||
* @description: 设置通用标题
|
||
*/
|
||
setHeader(headers: any): void {
|
||
if (!this.axiosInstance) {
|
||
return
|
||
}
|
||
Object.assign(this.axiosInstance.defaults.headers, headers)
|
||
}
|
||
|
||
/**
|
||
* @description: Interceptor configuration 拦截器配置
|
||
*/
|
||
private setupInterceptors() {
|
||
const transform = this.getTransform()
|
||
if (!transform) {
|
||
return
|
||
}
|
||
const { requestInterceptors, requestInterceptorsCatch, responseInterceptors, responseInterceptorsCatch } = transform
|
||
|
||
const axiosCanceler = new AxiosCanceler()
|
||
|
||
// 请求拦截器配置处理
|
||
this.axiosInstance.interceptors.request.use((config: InternalAxiosRequestConfig) => {
|
||
// 如果开启取消重复请求，则禁止取消重复请求
|
||
// @ts-ignore
|
||
const { ignoreCancelToken } = config.requestOptions
|
||
const ignoreCancel = ignoreCancelToken !== undefined ? ignoreCancelToken : this.options.requestOptions?.ignoreCancelToken
|
||
|
||
!ignoreCancel && axiosCanceler.addPending(config)
|
||
if (requestInterceptors && isFunction(requestInterceptors)) {
|
||
config = requestInterceptors(config, this.options)
|
||
}
|
||
return config
|
||
}, undefined)
|
||
|
||
// 请求拦截器错误捕获
|
||
requestInterceptorsCatch &&
|
||
isFunction(requestInterceptorsCatch) &&
|
||
this.axiosInstance.interceptors.request.use(undefined, requestInterceptorsCatch)
|
||
|
||
// 响应结果拦截器处理
|
||
this.axiosInstance.interceptors.response.use(async (res: AxiosResponse<any>) => {
|
||
const config = res.config
|
||
if (res.data.code === 401) {
|
||
// 如果未认证，并且未进行刷新令牌，说明可能是访问令牌过期了
|
||
if (!isRefreshToken) {
|
||
isRefreshToken = true
|
||
// 1. 获取到刷新token
|
||
if (getRefreshToken()) {
|
||
// 2. 进行刷新访问令牌
|
||
try {
|
||
const refreshTokenRes = await this.refreshToken()
|
||
// 2.1 刷新成功，则回放队列的请求 + 当前请求
|
||
setAccessToken(refreshTokenRes.data.data.accessToken)
|
||
;(config as Recordable).headers.Authorization = 'Bearer ' + getAccessToken()
|
||
requestList.forEach((cb: any) => {
|
||
cb()
|
||
})
|
||
requestList = []
|
||
return new Promise((resolve) => {
|
||
resolve(this.axiosInstance(config))
|
||
})
|
||
// res = await Promise.all([this.axiosInstance(config)])[0]
|
||
} catch (e) {
|
||
console.info(e)
|
||
requestList.forEach((cb: any) => {
|
||
cb()
|
||
})
|
||
} finally {
|
||
requestList = []
|
||
isRefreshToken = false
|
||
}
|
||
}
|
||
} else {
|
||
// 添加到队列，等待刷新获取到新的令牌
|
||
return new Promise((resolve) => {
|
||
requestList.push(() => {
|
||
;(config as Recordable).headers.Authorization = 'Bearer ' + getAccessToken() // 让每个请求携带自定义token 请根据实际情况自行修改
|
||
resolve(this.axiosInstance(config))
|
||
})
|
||
})
|
||
}
|
||
}
|
||
res && axiosCanceler.removePending(res.config)
|
||
if (responseInterceptors && isFunction(responseInterceptors)) {
|
||
res = responseInterceptors(res)
|
||
}
|
||
return res
|
||
}, undefined)
|
||
|
||
// 响应结果拦截器错误捕获
|
||
responseInterceptorsCatch &&
|
||
isFunction(responseInterceptorsCatch) &&
|
||
this.axiosInstance.interceptors.response.use(undefined, (error) => {
|
||
// @ts-ignore
|
||
return responseInterceptorsCatch(this.axiosInstance, error)
|
||
})
|
||
}
|
||
|
||
/**
|
||
* @description: 文件上传
|
||
*/
|
||
uploadFile<T = any>(config: AxiosRequestConfig, params: UploadFileParams) {
|
||
const formData = new window.FormData()
|
||
const customFilename = params.name || 'file'
|
||
|
||
if (params.filename) {
|
||
formData.append(customFilename, params.file, params.filename)
|
||
} else {
|
||
formData.append(customFilename, params.file)
|
||
}
|
||
|
||
if (params.data) {
|
||
Object.keys(params.data).forEach((key) => {
|
||
const value = params.data![key]
|
||
if (Array.isArray(value)) {
|
||
value.forEach((item) => {
|
||
formData.append(`${key}[]`, item)
|
||
})
|
||
return
|
||
}
|
||
|
||
formData.append(key, params.data![key])
|
||
})
|
||
}
|
||
|
||
return this.axiosInstance.request<T>({
|
||
...config,
|
||
method: 'POST',
|
||
data: formData,
|
||
headers: {
|
||
'Content-type': ContentTypeEnum.FORM_DATA,
|
||
// @ts-ignore
|
||
ignoreCancelToken: true
|
||
}
|
||
})
|
||
}
|
||
|
||
// 支持表单数据
|
||
supportFormData(config: AxiosRequestConfig) {
|
||
const headers = config.headers || this.options.headers
|
||
const contentType = headers?.['Content-Type'] || headers?.['content-type']
|
||
|
||
if (
|
||
contentType !== ContentTypeEnum.FORM_URLENCODED ||
|
||
!Reflect.has(config, 'data') ||
|
||
config.method?.toUpperCase() === RequestEnum.GET
|
||
) {
|
||
return config
|
||
}
|
||
|
||
return {
|
||
...config,
|
||
data: qs.stringify(config.data, { arrayFormat: 'brackets' })
|
||
}
|
||
}
|
||
|
||
get<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
|
||
return this.request({ ...config, method: 'GET' }, options)
|
||
}
|
||
|
||
post<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
|
||
return this.request({ ...config, method: 'POST' }, options)
|
||
}
|
||
|
||
put<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
|
||
return this.request({ ...config, method: 'PUT' }, options)
|
||
}
|
||
|
||
delete<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
|
||
return this.request({ ...config, method: 'DELETE' }, options)
|
||
}
|
||
|
||
download<T = any>(config: AxiosRequestConfig, title?: string, options?: RequestOptions): Promise<T> {
|
||
let conf: CreateAxiosOptions = cloneDeep({
|
||
...config,
|
||
method: 'GET',
|
||
responseType: 'blob'
|
||
})
|
||
const transform = this.getTransform()
|
||
|
||
const { requestOptions } = this.options
|
||
|
||
const opt: RequestOptions = Object.assign({}, requestOptions, options)
|
||
|
||
const { beforeRequestHook, requestCatchHook } = transform || {}
|
||
|
||
if (beforeRequestHook && isFunction(beforeRequestHook)) {
|
||
conf = beforeRequestHook(conf, opt)
|
||
}
|
||
conf.requestOptions = opt
|
||
|
||
conf = this.supportFormData(conf)
|
||
|
||
return new Promise((resolve, reject) => {
|
||
this.axiosInstance
|
||
.request<any, AxiosResponse<Result>>(conf)
|
||
.then((res: AxiosResponse<Result>) => {
|
||
resolve(res as unknown as Promise<T>)
|
||
// download file
|
||
if (typeof res != undefined) {
|
||
downloadByData(res?.data as unknown as BlobPart, title || 'export')
|
||
}
|
||
})
|
||
.catch((e: Error | AxiosError) => {
|
||
if (requestCatchHook && isFunction(requestCatchHook)) {
|
||
reject(requestCatchHook(e, opt))
|
||
return
|
||
}
|
||
if (axios.isAxiosError(e)) {
|
||
// rewrite error message from axios in here
|
||
}
|
||
reject(e)
|
||
})
|
||
})
|
||
}
|
||
|
||
export<T = any>(config: AxiosRequestConfig, title: string, options?: RequestOptions): Promise<T> {
|
||
let conf: CreateAxiosOptions = cloneDeep({
|
||
...config,
|
||
method: 'POST',
|
||
responseType: 'blob'
|
||
})
|
||
const transform = this.getTransform()
|
||
|
||
const { requestOptions } = this.options
|
||
|
||
const opt: RequestOptions = Object.assign({}, requestOptions, options)
|
||
|
||
const { beforeRequestHook, requestCatchHook } = transform || {}
|
||
|
||
if (beforeRequestHook && isFunction(beforeRequestHook)) {
|
||
conf = beforeRequestHook(conf, opt)
|
||
}
|
||
conf.requestOptions = opt
|
||
|
||
conf = this.supportFormData(conf)
|
||
|
||
return new Promise((resolve, reject) => {
|
||
this.axiosInstance
|
||
.request<any, AxiosResponse<Result>>(conf)
|
||
.then((res: AxiosResponse<Result>) => {
|
||
resolve(res as unknown as Promise<T>)
|
||
// download file
|
||
if (typeof res != undefined) {
|
||
downloadByData(res?.data as unknown as BlobPart, title)
|
||
}
|
||
})
|
||
.catch((e: Error | AxiosError) => {
|
||
if (requestCatchHook && isFunction(requestCatchHook)) {
|
||
reject(requestCatchHook(e, opt))
|
||
return
|
||
}
|
||
if (axios.isAxiosError(e)) {
|
||
// rewrite error message from axios in here
|
||
}
|
||
reject(e)
|
||
})
|
||
})
|
||
}
|
||
|
||
request<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
|
||
let conf: CreateAxiosOptions = cloneDeep(config)
|
||
// cancelToken 如果被深拷贝，会导致最外层无法使用cancel方法来取消请求
|
||
if (config.cancelToken) {
|
||
conf.cancelToken = config.cancelToken
|
||
}
|
||
const transform = this.getTransform()
|
||
|
||
const { requestOptions } = this.options
|
||
|
||
const opt: RequestOptions = Object.assign({}, requestOptions, options)
|
||
|
||
const { beforeRequestHook, requestCatchHook, transformResponseHook } = transform || {}
|
||
if (beforeRequestHook && isFunction(beforeRequestHook)) {
|
||
conf = beforeRequestHook(conf, opt)
|
||
}
|
||
conf.requestOptions = opt
|
||
|
||
conf = this.supportFormData(conf)
|
||
|
||
return new Promise((resolve, reject) => {
|
||
this.axiosInstance
|
||
.request<any, AxiosResponse<Result>>(conf)
|
||
.then((res: AxiosResponse<Result>) => {
|
||
if (transformResponseHook && isFunction(transformResponseHook)) {
|
||
try {
|
||
const ret = transformResponseHook(res, opt)
|
||
resolve(ret)
|
||
} catch (err) {
|
||
reject(err || new Error('request error!'))
|
||
}
|
||
return
|
||
}
|
||
resolve(res as unknown as Promise<T>)
|
||
})
|
||
.catch((e: Error | AxiosError) => {
|
||
if (requestCatchHook && isFunction(requestCatchHook)) {
|
||
reject(requestCatchHook(e, opt))
|
||
return
|
||
}
|
||
if (axios.isAxiosError(e)) {
|
||
// 在此处重写来自 axios 的错误消息
|
||
}
|
||
reject(e)
|
||
})
|
||
})
|
||
}
|
||
}
|