72 lines
2.5 KiB
JavaScript
72 lines
2.5 KiB
JavaScript
|
import { refresh } from '@/api/auth.js'
|
||
|
|
import { session, replaceTokens } from '@/stores/session.js'
|
||
|
|
|
||
|
|
let refreshPromise = null
|
||
|
|
|
||
|
|
function errorFrom(response, fallback) {
|
||
|
|
const body = response?.data || {}
|
||
|
|
const error = new Error(body.message || fallback)
|
||
|
|
error.code = body.code || response?.statusCode
|
||
|
|
error.requestId = body.requestId || response?.header?.['x-request-id'] || response?.header?.['X-Request-Id']
|
||
|
|
error.traceId = body.traceId || response?.header?.['x-trace-id'] || response?.header?.['X-Trace-Id']
|
||
|
|
return error
|
||
|
|
}
|
||
|
|
|
||
|
|
function unauthorized(response) {
|
||
|
|
const code = String(response?.data?.code || response?.statusCode || '')
|
||
|
|
return response?.statusCode === 401 || code === 'A0401'
|
||
|
|
}
|
||
|
|
|
||
|
|
async function refreshOverseasToken() {
|
||
|
|
if (!session.refreshToken) throw new Error('登录状态已过期，请重新登录')
|
||
|
|
if (!refreshPromise) {
|
||
|
|
refreshPromise = refresh(session.refreshToken).then((tokens) => { replaceTokens(tokens); return session.token })
|
||
|
|
.finally(() => { refreshPromise = null })
|
||
|
|
}
|
||
|
|
return refreshPromise
|
||
|
|
}
|
||
|
|
|
||
|
|
function rawRequest(method, path, data, token) {
|
||
|
|
return new Promise((resolve, reject) => {
|
||
|
|
uni.request({
|
||
|
|
url: `${session.apiBase}${path}`,
|
||
|
|
method,
|
||
|
|
data,
|
||
|
|
header: { Accept: 'application/json', Authorization: `Bearer ${token}` },
|
||
|
|
success: resolve,
|
||
|
|
fail: (cause) => reject(Object.assign(new Error(cause.errMsg || '海外服务网络连接失败'), { network: true }))
|
||
|
|
})
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
export async function overseasRequest(method, path, data, retry = true) {
|
||
|
|
let response = await rawRequest(method, path, data, session.token)
|
||
|
|
if (retry && unauthorized(response)) {
|
||
|
|
await refreshOverseasToken()
|
||
|
|
response = await rawRequest(method, path, data, session.token)
|
||
|
|
}
|
||
|
|
const body = response?.data || {}
|
||
|
|
if (response.statusCode !== 200 || String(body.code) !== '200') throw errorFrom(response, '海外作业请求失败')
|
||
|
|
return body.data
|
||
|
|
}
|
||
|
|
|
||
|
|
export function overseasUpload(path, filePath, name = 'file') {
|
||
|
|
return new Promise((resolve, reject) => {
|
||
|
|
uni.uploadFile({
|
||
|
|
url: `${session.apiBase}${path}`,
|
||
|
|
filePath,
|
||
|
|
name,
|
||
|
|
header: { Authorization: `Bearer ${session.token}` },
|
||
|
|
success(response) {
|
||
|
|
let body = null
|
||
|
|
try { body = JSON.parse(response.data || '{}') } catch (_) { /* handled below */ }
|
||
|
|
if (response.statusCode !== 200 || String(body?.code) !== '200') {
|
||
|
|
reject(errorFrom({ ...response, data: body }, '卸柜照片上传失败')); return
|
||
|
|
}
|
||
|
|
resolve(body.data)
|
||
|
|
},
|
||
|
|
fail: (cause) => reject(Object.assign(new Error(cause.errMsg || '卸柜照片上传失败'), { network: true }))
|
||
|
|
})
|
||
|
|
})
|
||
|
|
}
|