114 lines
3.5 KiB
JavaScript
114 lines
3.5 KiB
JavaScript
/**
|
||
* 地磅模块 HTTP（裸 JSON，非门户 code/data 信封）
|
||
* 对齐 mobile-h5/src/utils/http/db.ts
|
||
*/
|
||
import { TOKEN_KEY, REFRESH_TOKEN_KEY, USER_INFO_KEY, resolveApiBase } from '@/config/api'
|
||
|
||
const DB_COLLECTION_ROOT = /^\/(plans|inventory|weighing)$/
|
||
|
||
function normalizeDbUrl(url) {
|
||
if (!url || url.endsWith('/')) return url
|
||
return DB_COLLECTION_ROOT.test(url) ? `${url}/` : url
|
||
}
|
||
|
||
function buildQuery(params) {
|
||
if (!params || typeof params !== 'object') return ''
|
||
const parts = []
|
||
Object.keys(params).forEach((key) => {
|
||
const val = params[key]
|
||
if (val === undefined || val === null || val === '') return
|
||
parts.push(`${encodeURIComponent(key)}=${encodeURIComponent(String(val))}`)
|
||
})
|
||
return parts.length ? `?${parts.join('&')}` : ''
|
||
}
|
||
|
||
function parseDetailMessage(data) {
|
||
if (!data || typeof data !== 'object') return ''
|
||
const detail = data.detail
|
||
if (typeof detail === 'string') return detail
|
||
if (Array.isArray(detail)) {
|
||
return detail
|
||
.map((x) => (x && x.msg) || '')
|
||
.filter(Boolean)
|
||
.join('；')
|
||
}
|
||
return data.message || data.msg || ''
|
||
}
|
||
|
||
async function onUnauthorized() {
|
||
uni.removeStorageSync(TOKEN_KEY)
|
||
uni.removeStorageSync(REFRESH_TOKEN_KEY)
|
||
uni.removeStorageSync(USER_INFO_KEY)
|
||
try {
|
||
const { useUserStore } = await import('@/stores/user')
|
||
useUserStore().clearLoginInfo()
|
||
} catch (e) {
|
||
// ignore
|
||
}
|
||
uni.showToast({ title: '登录已过期，请重新登录', icon: 'none' })
|
||
setTimeout(() => {
|
||
uni.reLaunch({ url: '/pages/login/login' })
|
||
}, 800)
|
||
}
|
||
|
||
/**
|
||
* @param {{ url: string, method?: string, data?: any, params?: any, showError?: boolean }} options
|
||
*/
|
||
export function dbRequest(options = {}) {
|
||
const method = String(options.method || 'GET').toUpperCase()
|
||
const showError = options.showError !== false
|
||
const token = uni.getStorageSync(TOKEN_KEY) || ''
|
||
let path = normalizeDbUrl(options.url || '')
|
||
const query = method === 'GET' ? buildQuery(options.params) : buildQuery(options.params)
|
||
const rawUrl = `${path}${query}`
|
||
const url = rawUrl.startsWith('http')
|
||
? rawUrl
|
||
: `${resolveApiBase()}${rawUrl.startsWith('/') ? rawUrl : `/${rawUrl}`}`
|
||
|
||
return new Promise((resolve, reject) => {
|
||
uni.request({
|
||
url,
|
||
method,
|
||
data: method === 'GET' ? undefined : options.data,
|
||
header: {
|
||
'Content-Type': 'application/json',
|
||
...(token ? { Authorization: `Bearer ${token}` } : {})
|
||
},
|
||
success: (res) => {
|
||
const status = res.statusCode
|
||
const data = res.data
|
||
if (status === 401) {
|
||
onUnauthorized()
|
||
reject(new Error('登录已过期'))
|
||
return
|
||
}
|
||
if (status >= 200 && status < 300) {
|
||
resolve(data)
|
||
return
|
||
}
|
||
const message = parseDetailMessage(data) || `请求失败(${status})`
|
||
if (showError) {
|
||
uni.showToast({ title: message.slice(0, 40), icon: 'none' })
|
||
}
|
||
reject(new Error(message))
|
||
},
|
||
fail: (err) => {
|
||
if (showError) {
|
||
uni.showToast({ title: '网络异常', icon: 'none' })
|
||
}
|
||
reject(err)
|
||
}
|
||
})
|
||
})
|
||
}
|
||
|
||
export const db = {
|
||
get: (url, params, opts) => dbRequest({ ...opts, url, method: 'GET', params }),
|
||
post: (url, data, opts) => dbRequest({ ...opts, url, method: 'POST', data }),
|
||
put: (url, data, opts) => dbRequest({ ...opts, url, method: 'PUT', data }),
|
||
patch: (url, data, opts) => dbRequest({ ...opts, url, method: 'PATCH', data }),
|
||
del: (url, opts) => dbRequest({ ...opts, url, method: 'DELETE' })
|
||
}
|
||
|
||
export default db
|