OSSService.js 8.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238
  1. import OSS from 'ali-oss'
  2. import { ElMessage } from 'element-plus'
  3. import request from '@/utils/httpRequest'
  4. import { PUBLIC_MODULES_PATH as prefix } from "../AppPath";
  5. export default class OSSSerive {
  6. saveMsg (param) {
  7. return request({
  8. url: prefix + '/oss/file/saveMsg',
  9. method: 'post',
  10. data: param
  11. })
  12. }
  13. findFileList (attachmentId) {
  14. return request({
  15. url: prefix + '/oss/file/findFileList',
  16. method: 'get',
  17. params: {attachmentId: attachmentId}
  18. })
  19. }
  20. getTemporaryUrl (url) {
  21. return request({
  22. url: prefix + '/oss/file/getTemporaryUrl',
  23. method: 'get',
  24. params: {url: url}
  25. })
  26. }
  27. getFileSizeByUrl (url) {
  28. return request({
  29. url: prefix + '/oss/file/getFileSizeByUrl',
  30. method: 'get',
  31. params: {url: url}
  32. })
  33. }
  34. deleteMsgById (id) {
  35. return request({
  36. url: prefix + '/oss/file/deleteMsgById',
  37. method: 'get',
  38. params: {id: id}
  39. })
  40. }
  41. downLoadAttach (url) {
  42. return request({
  43. url: prefix + '/oss/file/downLoadAttach',
  44. method: 'get',
  45. responseType: 'blob',
  46. params: {file: url}
  47. })
  48. }
  49. }
  50. export const client = new OSS({
  51. region: 'oss-cn-hangzhou', // oss地址
  52. accessKeyId: 'LTAI5tQDWoM9c1WyJNPs86rX', // 通过阿里云控制台创建的AccessKey ID。
  53. accessKeySecret: '84dDIx4edT1n78KUOqqSmDZ35pchJv', // 通过阿里云控制台创建的AccessKey Secret。
  54. bucket: 'xgxm-test', // 仓库名字
  55. // bucket: 'xg-pg', // 仓库名字
  56. useFetch: true, // 支持上传大于100KB的文件
  57. secure: false // 返回的url为https
  58. })
  59. export const headers = {
  60. // 指定该Object被下载时网页的缓存行为。
  61. 'Cache-Control': 'no-cache',
  62. // 指定该Object被下载时的名称。
  63. 'Content-Disposition': 'inline',
  64. // 指定该Object被下载时的内容编码格式。
  65. 'Content-Encoding': 'UTF-8',
  66. // 指定过期时间。
  67. Expires: 'Wed, 08 Jul 2023 16:57:01 GMT',
  68. // 指定Object的存储类型。
  69. 'x-oss-storage-class': 'Standard',
  70. // 指定Object的访问权限。
  71. // 'x-oss-object-acl': 'private',
  72. // 设置Object的标签,可同时设置多个标签。
  73. 'x-oss-tagging': 'Tag1=1&Tag2=2',
  74. // 指定CopyObject操作时是否覆盖同名目标Object。此处设置为true,表示禁止覆盖同名Object。
  75. 'x-oss-forbid-overwrite': 'true'
  76. // 'secure': 'true'
  77. }
  78. export function onChange (file, files) {
  79. // console.log(file, 'file', files, 'Filest')
  80. return files
  81. }
  82. // eslint-disable-next-line no-unused-vars
  83. export function handleUploadSuccess (response, file, fileS) {
  84. // console.log(response, file, fileS, 'response, file, fileList')
  85. }
  86. export function handleRemove (e, files) {
  87. return files
  88. }
  89. export function fileName (file) {
  90. // console.log('文件名称处理')
  91. const tmpcnt = file.file.name.lastIndexOf('.')
  92. let fileName = file.file.name.substring(0, tmpcnt)
  93. // 将单引号‘’都转换成',将双引号“”都转换成"
  94. fileName = fileName.replace(/’|‘/g, '\'').replace(/“|”/g, '')
  95. // 将中括号【】转换成[],将大括号{}转换成{}
  96. fileName = fileName.replace(/【/g, '(').replace(/】/g, ')').replace(/{/g, '(').replace(/}/g, ')')
  97. fileName = fileName.replace(/\[/g, '(').replace(/]/g, ')').replace(/{/g, '(').replace(/}/g, ')')
  98. // 将逗号,转换成,,将:转换成:
  99. fileName = fileName.replace(/,/g, ',').replace(/:/g, ':')
  100. // 将中文——转换为英文-
  101. fileName = fileName.replace(/—/g, '-')
  102. fileName = fileName.replace(/……/g, '')
  103. fileName = fileName.replace(/±/g, '')
  104. fileName = fileName.replace(/#/g, '')
  105. fileName = fileName.replace(/%/g, '')
  106. fileName = fileName.replace(/Π/g, '')
  107. fileName = fileName.replace(/π/g, '')
  108. fileName = fileName.replace(/·/g, '.')
  109. // console.log('文件名处理结果', fileName)
  110. return fileName
  111. }
  112. export function beforeAvatarUpload (file, fileList, maxValue) {
  113. // 文件大小校验
  114. const isLt2M = file.size / 1024 / 1024 < maxValue
  115. if (!isLt2M) {
  116. fileList.splice(fileList.length - 1, 1)
  117. // console.log('文件大小不能超过 ' + maxValue + ' MB!')
  118. }
  119. return isLt2M
  120. }
  121. export function exnameFix (file, isShow, names) {
  122. // console.log('格式校验')
  123. const tmpcnt = file.name.lastIndexOf('.')
  124. const exname = file.name.substring(tmpcnt + 1) // 获取后缀名
  125. if (names.indexOf(exname) < 0) {
  126. if (isShow === '1') {
  127. ElMessage({
  128. message: '不支持的格式!',
  129. type: 'error',
  130. })
  131. }
  132. return false
  133. }
  134. return true
  135. }
  136. export async function httpRequest (file, name, type, maxValue) { // 阿里云OSS上传
  137. if (!beforeAvatarUpload(file.file, [], maxValue)) {
  138. return
  139. }
  140. // console.log('开始上传')
  141. // 判断扩展名
  142. const tmpcnt = file.file.name.lastIndexOf('.') // 获取.的下标
  143. const exname = file.file.name.substring(tmpcnt + 1) // 获取后缀名
  144. // console.log(exname, '后缀名')
  145. const now = new Date()
  146. const year = now.getFullYear()
  147. const month = now.getMonth() + 1
  148. const day = now.getDate() > 10 ? now.getDate() : '0' + now.getDate()
  149. const filePath = '/attachment-file/assess/' + type + '/' + year + '/' + month + '/' + day + '/' + now.getTime()
  150. // console.log(filePath, '文件存储路径')
  151. const fileName = filePath + name + '.' + exname
  152. // console.log(fileName, '文件名')
  153. await client.multipartUpload(fileName, file.file, {
  154. // eslint-disable-next-line no-unused-vars
  155. progress: await function (p, checkpoint) {
  156. file.onProgress({percent: Math.floor(p * 100)}) // 触发el-upload组件的onProgress方法
  157. }
  158. // mime: type,
  159. }).then(await function (result) {
  160. // console.log(result)
  161. if (result.res.status === 200) {
  162. // file.onSuccess(result) // 触发el-upload组件的onSuccess方法
  163. file.file.url = fileName
  164. }
  165. // eslint-disable-next-line handle-callback-err,no-unused-vars
  166. }).catch(function (err) {
  167. // console.log(err)
  168. file.onError('上传失败') // 触发el-upload组件的onError方法,此方法会移除文件列表
  169. })
  170. }
  171. // eslint-disable-next-line no-unused-vars
  172. function getTemporaryByUrl (url) {
  173. return request({
  174. url: prefix + '/oss/file/getTemporaryUrl',
  175. method: 'get',
  176. params: {url: url}
  177. })
  178. }
  179. export async function openWindowOnUrl (row) {
  180. if (row.url === undefined || row.url === null || row.url === '') {
  181. // Message.error('没有获取到文件的url')
  182. return
  183. }
  184. let rowUrl = ''
  185. let suffix = row.name.substring(row.name.lastIndexOf('.') + 1)
  186. if (suffix === 'jpg' || suffix === 'png' || suffix === 'gif' || suffix === 'bmp' || suffix === 'jpeg') {
  187. await getTemporaryByUrl(row.url).then((data) => {
  188. // eslint-disable-next-line no-undef
  189. onPreview(data.data)
  190. })
  191. return
  192. }
  193. await getTemporaryByUrl(row.url).then((data) => {
  194. rowUrl = data.data
  195. })
  196. if (suffix === 'pdf') {
  197. window.open('https://view.xdocin.com/xdoc?_xdoc=' + encodeURIComponent(rowUrl), '_blank')
  198. } else if (suffix === 'rar' || suffix === 'zip' || suffix === 'jar' || suffix === '7z') {
  199. window.open('http://ow365.cn/?i=30045&furl=' + encodeURIComponent(rowUrl), '_blank')
  200. } else {
  201. window.open('https://view.officeapps.live.com/op/view.aspx?src=' + encodeURIComponent(rowUrl), '_blank')
  202. }
  203. }
  204. export async function toHref (row) {
  205. if (row.url === null || row.url === undefined || row.url === '') {
  206. // Message.error('没有获取到文件的url')
  207. return
  208. }
  209. const link = document.createElement('a')
  210. await getTemporaryByUrl(row.url).then((data) => {
  211. const url = data // 完整的url则直接使用
  212. // 这里是将url转成blob地址,
  213. fetch(url).then(res => res.blob()).then(blob => { // 将链接地址字符内容转变成blob地址
  214. link.href = URL.createObjectURL(blob)
  215. link.download = row.name || '' // 下载文件的名字
  216. // a.download = url.split('/')[url.split('/').length -1] // // 下载文件的名字
  217. document.body.appendChild(link)
  218. link.click()
  219. // 在资源下载完成后 清除 占用的缓存资源
  220. window.URL.revokeObjectURL(link.href)
  221. document.body.removeChild(link)
  222. })
  223. })
  224. }