增加文件流下载方法

src/main.js

@@ -10,7 +10,7 @@ import router from './router'
 import directive from './directive' // directive
 // 注册指令
 import plugins from './plugins' // plugins
-// import { download } from '@/utils/request'
+import { downFile } from '@/utils/request'
 import signalR from '@/utils/signalR'
 import vueI18n from './i18n/index'
 import pinia from '@/store/index'
@@ -48,6 +48,7 @@ app.config.globalProperties.signalr = signalR
 app.config.globalProperties.getConfigKey = getConfigKey
 app.config.globalProperties.getDicts = getDicts
 app.config.globalProperties.download = download
+app.config.globalProperties.downFile = downFile
 app.config.globalProperties.parseTime = parseTime
 app.config.globalProperties.resetForm = resetForm
 app.config.globalProperties.handleTree = handleTree

src/utils/request.js

@@ -2,6 +2,8 @@ import axios from 'axios'
 import { ElMessageBox, ElMessage } from 'element-plus'
 import { getToken } from '@/utils/auth'
 import useUserStore from '@/store/modules/user'
+import { tansParams, blobValidate } from '@/utils/ruoyi'
+import { saveAs } from 'file-saver'
 
 // 解决后端跨域获取不到cookie问题
 // axios.defaults.withCredentials = true
@@ -15,27 +17,31 @@ const service = axios.create({
 })
 
 // request拦截器
-service.interceptors.request.use(config => {
+service.interceptors.request.use(
+  (config) => {
     // 是否需要设置 token
     if (getToken()) {
       //将token放到请求头发送给服务器,将tokenkey放在请求头中
-    config.headers['Authorization'] = 'Bearer ' + getToken();
+      config.headers['Authorization'] = 'Bearer ' + getToken()
-    config.headers['userid'] = useUserStore().userId;
+      config.headers['userid'] = useUserStore().userId
     }
-  return config;
+    return config
-}, error => {
+  },
+  (error) => {
     console.log(error)
     Promise.reject(error)
-})
+  }
+)
 
 // 响应拦截器
-service.interceptors.response.use(res => {
+service.interceptors.response.use(
+  (res) => {
     if (res.status !== 200) {
-      Promise.reject('network error');
+      Promise.reject('network error')
-      return;
+      return
     }
     // 未设置状态码则默认成功状态
-    const { code, msg } = res.data;
+    const { code, msg } = res.data
     // 二进制数据则直接返回
     if (res.request.responseType === 'blob' || res.request.responseType === 'arraybuffer') {
       return res.data
@@ -46,9 +52,10 @@ service.interceptors.response.use(res => {
         cancelButtonText: '取消',
         type: 'warning'
       }).then(() => {
-        useUserStore().logOut().then(() => {
+        useUserStore()
-          location.href =
+          .logOut()
-            import.meta.env.VITE_APP_ROUTER_PREFIX + 'index';
+          .then(() => {
+            location.href = import.meta.env.VITE_APP_ROUTER_PREFIX + 'index'
           })
       })
 
@@ -61,20 +68,20 @@ service.interceptors.response.use(res => {
       return Promise.reject(res.data)
     } else {
       //返回标准 code/msg/data字段
-      return res.data;
+      return res.data
     }
   },
-  error => {
+  (error) => {
     console.log('err' + error)
-    let { message } = error;
+    let { message } = error
-    if (message == "Network Error") {
+    if (message == 'Network Error') {
-      message = "后端接口连接异常";
+      message = '后端接口连接异常'
-    } else if (message.includes("timeout")) {
+    } else if (message.includes('timeout')) {
-      message = "系统接口请求超时";
+      message = '系统接口请求超时'
-    } else if (message.includes("Request failed with status code 429")) {
+    } else if (message.includes('Request failed with status code 429')) {
-      message = "请求过于频繁，请稍后再试";
+      message = '请求过于频繁，请稍后再试'
-    } else if (message.includes("Request failed with status code")) {
+    } else if (message.includes('Request failed with status code')) {
-      message = "系统接口" + message.substr(message.length - 3) + "异常";
+      message = '系统接口' + message.substr(message.length - 3) + '异常'
     }
     ElMessage({
       message: message,
@@ -96,10 +103,10 @@ export function get(url, params) {
       .get(url, {
         params: params
       })
-      .then(res => {
+      .then((res) => {
         resolve(res.data)
       })
-      .catch(err => {
+      .catch((err) => {
         reject(err)
       })
   })
@@ -111,10 +118,10 @@ export function post(url, params) {
       .post(url, {
         params: params
       })
-      .then(res => {
+      .then((res) => {
         resolve(res.data)
       })
-      .catch(err => {
+      .catch((err) => {
         reject(err)
       })
   })
@@ -127,39 +134,56 @@ export function post(url, params) {
  */
 export function postForm(url, data, config) {
   return new Promise((resolve, reject) => {
-    axios.post(url, data, config).then(res => {
+    axios
+      .post(url, data, config)
+      .then((res) => {
         resolve(res.data)
-    }).catch(err => {
+      })
+      .catch((err) => {
         reject(err)
       })
   })
 }
 
-
 // 通用下载方法
-// export function download(url, params, filename) {
+export function downFile(url, params, filename, config) {
-//   //downloadLoadingInstance = Loading.service({ text: "正在下载数据，请稍候", spinner: "el-icon-loading", background: "rgba(0, 0, 0, 0.7)", })
+  //downloadLoadingInstance = Loading.service({ text: '正在下载数据，请稍候', spinner: 'el-icon-loading', background: 'rgba(0, 0, 0, 0.7)' })
-//   return service.post(url, params, {
+  return service
-//     //transformRequest: [(params) => { return tansParams(params) }],
+    .get(url, params, {
-//     headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
+      transformRequest: [
-//     responseType: 'blob'
+        (params) => {
-//   }).then(async (data) => {
+          return tansParams(params)
-//     const isLogin = await blobValidate(data);
+        }
-//     if (isLogin) {
+      ],
-//       const blob = new Blob([data])
+      headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
-//       saveAs(blob, filename)
+      responseType: 'blob',
-//     } else {
+      ...config
-//       const resText = await data.text();
+    })
-//       const rspObj = JSON.parse(resText);
+    .then(async (data) => {
-//       const errMsg = "出錯了";// errorCode[rspObj.code] || rspObj.msg || errorCode['default']
+      const isLogin = await blobValidate(data)
-//       Message.error(errMsg);
+      if (isLogin) {
-//     }
+        const blob = new Blob([data])
-//     // downloadLoadingInstance.close();
+        saveAs(blob, filename)
-//   }).catch((r) => {
+      } else {
-//     console.error(r)
+        const resText = await data.text()
-//     Message.error('下载文件出现错误，请联系管理员！')
+        const rspObj = JSON.parse(resText)
-//     // downloadLoadingInstance.close();
+        const errMsg = errorCode[rspObj.code] || rspObj.msg || errorCode['default']
-//   })
+
-// }
+        ElMessage({
+          message: errMsg,
+          type: 'error'
+        })
+      }
+      // downloadLoadingInstance.close()
+    })
+    .catch((r) => {
+      console.error(r)
+      ElMessage({
+        message: '下载文件出现错误，请联系管理员！',
+        type: 'error'
+      })
+      // downloadLoadingInstance.close()
+    })
+}
 
 export default service