pda-overseas-uniapp/src/api/overseas.js

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'
}

function successful(response, body) {
	return response?.statusCode === 200 && ['00000', '200'].includes(String(body?.code))
}

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 (!successful(response, body)) throw errorFrom(response, '海外作业请求失败')
	return body.data
}

function rawUpload(path, filePath, name, token) {
	return new Promise((resolve, reject) => {
		uni.uploadFile({
			url: `${session.apiBase}${path}`,
			filePath,
			name,
			header: { Authorization: `Bearer ${token}` },
			success: resolve,
			fail: (cause) => reject(Object.assign(new Error(cause.errMsg || '卸柜照片上传失败'), { network: true }))
		})
	})
}

export async function overseasUpload(path, filePath, name = 'file', retry = true) {
	let response = await rawUpload(path, filePath, name, session.token)
	let body = null
	try { body = JSON.parse(response.data || '{}') } catch (_) { /* handled below */ }
	if (retry && unauthorized({ ...response, data: body })) {
		await refreshOverseasToken()
		response = await rawUpload(path, filePath, name, session.token)
		try { body = JSON.parse(response.data || '{}') } catch (_) { body = null }
	}
	if (!successful(response, body)) throw errorFrom({ ...response, data: body }, '卸柜照片上传失败')
	return body.data
}