| | |
| | | import axios from 'axios'
|
| | | import { ElNotification , ElMessageBox, ElMessage, ElLoading } from 'element-plus'
|
| | | import { getToken } from '@/utils/auth'
|
| | | import errorCode from '@/utils/errorCode'
|
| | | import { tansParams, blobValidate } from '@/utils/ruoyi'
|
| | | import cache from '@/plugins/cache'
|
| | | import { saveAs } from 'file-saver'
|
| | | import useUserStore from '@/store/modules/user'
|
| | |
|
| | | let downloadLoadingInstance
|
| | | // 是否显示重新登录
|
| | | export let isRelogin = { show: false }
|
| | |
|
| | | axios.defaults.headers['Content-Type'] = 'application/json;charset=utf-8'
|
| | | // 创建axios实例
|
| | | const service = axios.create({
|
| | | // axios中请求配置有baseURL选项,表示请求URL公共部分
|
| | | baseURL: import.meta.env.VITE_APP_BASE_API,
|
| | | // 超时
|
| | | timeout: 60000
|
| | | })
|
| | |
|
| | | // request拦截器
|
| | | service.interceptors.request.use(config => {
|
| | | // 是否需要设置 token
|
| | | const isToken = (config.headers || {}).isToken === false
|
| | | // 是否需要防止数据重复提交
|
| | | const isRepeatSubmit = (config.headers || {}).repeatSubmit === false
|
| | | if (getToken() && !isToken) {
|
| | | config.headers['Authorization'] = 'Bearer ' + getToken() // 让每个请求携带自定义token 请根据实际情况自行修改
|
| | | }
|
| | | // get请求映射params参数
|
| | | if (config.method === 'get' && config.params) {
|
| | | let url = config.url + '?' + tansParams(config.params)
|
| | | url = url.slice(0, -1)
|
| | | config.params = {}
|
| | | config.url = url
|
| | | }
|
| | | if (!isRepeatSubmit && (config.method === 'post' || config.method === 'put')) {
|
| | | const requestObj = {
|
| | | url: config.url,
|
| | | data: typeof config.data === 'object' ? JSON.stringify(config.data) : config.data,
|
| | | time: new Date().getTime()
|
| | | }
|
| | | const requestSize = Object.keys(JSON.stringify(requestObj)).length // 请求数据大小
|
| | | const limitSize = 5 * 1024 * 1024 // 限制存放数据5M
|
| | | if (requestSize >= limitSize) {
|
| | | console.warn(`[${config.url}]: ` + '请求数据大小超出允许的5M限制,无法进行防重复提交验证。')
|
| | | return config
|
| | | }
|
| | | const sessionObj = cache.session.getJSON('sessionObj')
|
| | | if (sessionObj === undefined || sessionObj === null || sessionObj === '') {
|
| | | cache.session.setJSON('sessionObj', requestObj)
|
| | | } else {
|
| | | const s_url = sessionObj.url // 请求地址
|
| | | const s_data = sessionObj.data // 请求数据
|
| | | const s_time = sessionObj.time // 请求时间
|
| | | const interval = 1000 // 间隔时间(ms),小于此时间视为重复提交
|
| | | if (s_data === requestObj.data && requestObj.time - s_time < interval && s_url === requestObj.url) {
|
| | | const message = '数据正在处理,请勿重复提交'
|
| | | console.warn(`[${s_url}]: ` + message)
|
| | | return Promise.reject(new Error(message))
|
| | | } else {
|
| | | cache.session.setJSON('sessionObj', requestObj)
|
| | | }
|
| | | }
|
| | | }
|
| | | return config
|
| | | }, error => {
|
| | | console.log(error)
|
| | | Promise.reject(error)
|
| | | })
|
| | |
|
| | | // 响应拦截器
|
| | | service.interceptors.response.use(res => {
|
| | | // 未设置状态码则默认成功状态
|
| | | const code = res.data.code || 200
|
| | | // 获取错误信息
|
| | | const msg = errorCode[code] || res.data.msg || errorCode['default']
|
| | | // 二进制数据则直接返回
|
| | | if (res.request.responseType === 'blob' || res.request.responseType === 'arraybuffer') {
|
| | | return res.data
|
| | | }
|
| | | if (code === 401) {
|
| | | if (!isRelogin.show) {
|
| | | isRelogin.show = true
|
| | | ElMessageBox.confirm('登录状态已过期,您可以继续留在该页面,或者重新登录', '系统提示', { confirmButtonText: '重新登录', cancelButtonText: '取消', type: 'warning' }).then(() => {
|
| | | isRelogin.show = false
|
| | | useUserStore().logOut().then(() => {
|
| | | location.href = '/index'
|
| | | })
|
| | | }).catch(() => {
|
| | | isRelogin.show = false
|
| | | })
|
| | | }
|
| | | return Promise.reject('无效的会话,或者会话已过期,请重新登录。')
|
| | | } else if (code === 500) {
|
| | | ElMessage({ message: msg, type: 'error' })
|
| | | return Promise.reject(new Error(msg))
|
| | | } else if (code === 601) {
|
| | | ElMessage({ message: msg, type: 'warning' })
|
| | | return Promise.reject(new Error(msg))
|
| | | } else if (code !== 200) {
|
| | | ElNotification.error({ title: msg })
|
| | | return Promise.reject('error')
|
| | | } else {
|
| | | return Promise.resolve(res.data)
|
| | | }
|
| | | },
|
| | | error => {
|
| | | console.log('err' + error)
|
| | | let { message } = error
|
| | | if (message == "Network Error") {
|
| | | message = "后端接口连接异常"
|
| | | } else if (message.includes("timeout")) {
|
| | | message = "系统接口请求超时"
|
| | | } else if (message.includes("Request failed with status code")) {
|
| | | message = "系统接口" + message.substr(message.length - 3) + "异常"
|
| | | }
|
| | | ElMessage({ message: message, type: 'error', duration: 5 * 1000 })
|
| | | return Promise.reject(error)
|
| | | }
|
| | | )
|
| | |
|
| | | // 通用下载方法
|
| | | export function download(url, params, filename, config) {
|
| | | downloadLoadingInstance = ElLoading.service({ text: "正在下载数据,请稍候", background: "rgba(0, 0, 0, 0.7)", })
|
| | | return service.post(url, params, {
|
| | | transformRequest: [(params) => { return tansParams(params) }],
|
| | | headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
|
| | | responseType: 'blob',
|
| | | ...config
|
| | | }).then(async (data) => {
|
| | | const isBlob = blobValidate(data)
|
| | | if (isBlob) {
|
| | | const blob = new Blob([data])
|
| | | saveAs(blob, filename)
|
| | | } else {
|
| | | const resText = await data.text()
|
| | | const rspObj = JSON.parse(resText)
|
| | | const errMsg = errorCode[rspObj.code] || rspObj.msg || errorCode['default']
|
| | | ElMessage.error(errMsg)
|
| | | }
|
| | | downloadLoadingInstance.close()
|
| | | }).catch((r) => {
|
| | | console.error(r)
|
| | | ElMessage.error('下载文件出现错误,请联系管理员!')
|
| | | downloadLoadingInstance.close()
|
| | | })
|
| | | }
|
| | |
|
| | | export default service
|
| | | /** |
| | | * 请求封装(基于 uni.request,支持 token、错误统一处理) |
| | | */ |
| | | import config from '@/config.js' |
| | | |
| | | // 存储 token 的 key |
| | | const TOKEN_KEY = 'cj_student_token' |
| | | |
| | | export function getToken() { |
| | | return uni.getStorageSync(TOKEN_KEY) |
| | | } |
| | | export function setToken(t) { |
| | | uni.setStorageSync(TOKEN_KEY, t) |
| | | } |
| | | export function clearToken() { |
| | | uni.removeStorageSync(TOKEN_KEY) |
| | | } |
| | | |
| | | function request(method, url, data = {}, options = {}) { |
| | | return new Promise((resolve, reject) => { |
| | | const token = getToken() |
| | | uni.request({ |
| | | url: config.baseUrl + url, |
| | | method, |
| | | data, |
| | | header: { |
| | | 'Content-Type': 'application/json', |
| | | ...(token ? { Authorization: 'Bearer ' + token } : {}), |
| | | ...(options.header || {}), |
| | | }, |
| | | success: (res) => { |
| | | if (res.statusCode === 401) { |
| | | clearToken() |
| | | uni.showToast({ title: '请重新登录', icon: 'none' }) |
| | | uni.reLaunch({ url: '/pages/login/login' }) |
| | | reject(res.data) |
| | | return |
| | | } |
| | | if (res.data && res.data.code === 200) { |
| | | resolve(res.data) |
| | | } else { |
| | | // 后端以 HTTP 200 + body.code 401 表达登录失效:同步清 token,跳登录页 |
| | | if (res.data && res.data.code === 401) { |
| | | clearToken() |
| | | uni.showToast({ title: '登录已失效,请重新登录', icon: 'none' }) |
| | | uni.reLaunch({ url: '/pages/login/login' }) |
| | | } else { |
| | | uni.showToast({ title: (res.data && res.data.msg) || '请求失败', icon: 'none' }) |
| | | } |
| | | reject(res.data) |
| | | } |
| | | }, |
| | | fail: (err) => { |
| | | uni.showToast({ title: '网络异常,请检查后端连接', icon: 'none' }) |
| | | reject(err) |
| | | }, |
| | | }) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * 上传单个文件到 /miniapp/upload。 |
| | | * H5 可传 file(input[type=file] 选中的 File 对象);小程序/App 传 filePath(临时路径)。 |
| | | * 后端响应为 { code, msg, data: { fileName, originalName } }; |
| | | * 成功时 resolve 内层 data({ fileName, originalName }),兼容个别旧结构的顶层 fileName。 |
| | | */ |
| | | export function uploadFile({ filePath, file }) { |
| | | return new Promise((resolve, reject) => { |
| | | const token = getToken() |
| | | // uni-h5 的 uploadFile 缺 filePath 会先 reject("file error")(但 XHR 仍会发出,导致 |
| | | // 「后端传成功、前端报失败」);H5 传 File 对象时补一个 blob URL 兜底。 |
| | | let fp = filePath |
| | | if (!fp && file) { |
| | | try { fp = URL.createObjectURL(file) } catch (e) { /* 非浏览器环境忽略 */ } |
| | | } |
| | | uni.uploadFile({ |
| | | url: config.baseUrl + '/miniapp/upload', |
| | | filePath: fp, |
| | | file, |
| | | name: 'file', |
| | | header: token ? { Authorization: 'Bearer ' + token } : {}, |
| | | success: (res) => { |
| | | let d = res.data |
| | | try { d = JSON.parse(res.data) } catch (e) { /* 保留原始文本 */ } |
| | | if (res.statusCode === 401) { |
| | | clearToken() |
| | | uni.showToast({ title: '请重新登录', icon: 'none' }) |
| | | uni.reLaunch({ url: '/pages/login/login' }) |
| | | reject(d) |
| | | return |
| | | } |
| | | if (d && d.code === 200) { |
| | | // 真正有用的是 data 内层;旧代码直接 resolve 整个响应体导致 res.fileName 恒为 undefined |
| | | resolve(d.data || d) |
| | | } else { |
| | | uni.showToast({ title: (d && d.msg) || '上传失败', icon: 'none' }) |
| | | reject(d) |
| | | } |
| | | }, |
| | | fail: (err) => { |
| | | uni.showToast({ title: '上传失败,请检查网络', icon: 'none' }) |
| | | reject(err) |
| | | }, |
| | | }) |
| | | }) |
| | | } |
| | | |
| | | export default { |
| | | get: (url, data, opts) => request('GET', url, data, opts), |
| | | post: (url, data, opts) => request('POST', url, data, opts), |
| | | put: (url, data, opts) => request('PUT', url, data, opts), |
| | | delete: (url, data, opts) => request('DELETE', url, data, opts), |
| | | upload: uploadFile, |
| | | } |