service.js 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394
  1. import Request from 'luch-request'
  2. import Global from "./global.js"
  3. import crypto from '@/utils/crypto.js'
  4. let baseURL = Global.baseUrl
  5. let tokenUrl = Global.tokenUrl
  6. //获取token
  7. const getTokenStorage = () => {
  8. let token = ''
  9. try {
  10. token = uni.getStorageSync('token')
  11. } catch (e) {}
  12. return token
  13. }
  14. const http = new Request()
  15. http.setConfig((config) => {
  16. /* 设置全局配置 */
  17. config.baseURL = baseURL /* 根域名不同 */
  18. config.header = {
  19. ...config.header,
  20. }
  21. return config
  22. })
  23. http.interceptors.request.use((config) => {
  24. /* 请求之前拦截器。可以使用async await 做异步操作 */
  25. config.header = {
  26. ...config.header,
  27. "Blade-Auth": getTokenStorage()
  28. }
  29. if (Global.enabledCrypto && config.method == 'POST' && config.data) {
  30. //报文加密
  31. let encrypt= crypto.encrypt(JSON.stringify(config.data))
  32. config.data=encrypt
  33. }
  34. return config
  35. }, (config) => {
  36. return Promise.reject(config)
  37. })
  38. // 是否正在刷新的标记
  39. let isRefreshing = false
  40. // 重试队列,每一项将是一个待执行的函数形式
  41. let requests = []
  42. http.interceptors.response.use(async (response) => {
  43. /* 请求之后拦截器。可以使用async await 做异步操作 */
  44. //toekn过期处理
  45. //200 返回数据成功 0
  46. if (response.data.code != 200 && response.data.code !=400) {
  47. return Promise.reject(response)
  48. }
  49. return response.data
  50. }, async (err) => { // 请求错误做点什么
  51. if (err.data.code == 401) {
  52. let {
  53. config
  54. } = err
  55. if (!isRefreshing) {
  56. isRefreshing = true
  57. let token = uni.getStorageSync('token')
  58. let [, res] = await uni.request({
  59. url: tokenUrl,
  60. method: 'POST',
  61. header: {
  62. Authorization: "Basic c2FiZXI6c2FiZXJfc2VjcmV0"
  63. },
  64. })
  65. //否则保存新的token
  66. token = res.data.token_type + " " + res.data.access_token
  67. uni.setStorageSync('token', token)
  68. requests.forEach(cb => cb())
  69. // 重试完了清空这个队列
  70. requests = []
  71. isRefreshing = false
  72. return http.request(config)
  73. } else {
  74. return new Promise((resolve) => {
  75. // 将resolve放进队列,用一个函数形式来保存,等token刷新后直接执行
  76. requests.push(() => {
  77. resolve(http.request(config))
  78. })
  79. })
  80. }
  81. }
  82. uni.showToast({
  83. icon: 'none',
  84. position: 'bottom',
  85. title: '网络异常'
  86. })
  87. return Promise.reject(err)
  88. })
  89. export {
  90. http
  91. }