forked from gxwebsoft/mp-10550
提交代码
This commit is contained in:
101
src/api/system/file/index.ts
Normal file
101
src/api/system/file/index.ts
Normal file
@@ -0,0 +1,101 @@
|
||||
import request from '@/utils/request';
|
||||
import Taro from '@tarojs/taro'
|
||||
import dayjs from 'dayjs';
|
||||
import crypto from 'crypto-js';
|
||||
import {Base64} from 'js-base64';
|
||||
import {FileRecord} from "@/api/system/file/model";
|
||||
import {TenantId} from "@/utils/config";
|
||||
|
||||
export async function uploadOssByPath(filePath: string) {
|
||||
return new Promise(async (resolve) => {
|
||||
const date = new Date();
|
||||
date.setMinutes(date.getMinutes() + 1);
|
||||
const policyText = {
|
||||
expiration: date.toISOString(), // 设置policy过期时间。
|
||||
conditions: [
|
||||
// 限制上传大小。
|
||||
["content-length-range", 0, 1024 * 1024 * 1024],
|
||||
],
|
||||
};
|
||||
let sts = Taro.getStorageSync('sts');
|
||||
let stsExpired = Taro.getStorageSync('stsExpiredAt');
|
||||
if (!sts || (stsExpired && dayjs().isBefore(dayjs(stsExpired)))) {
|
||||
// @ts-ignore
|
||||
const {data: {data: {credentials}}} = await request.get(`https://server.gxwebsoft.com/api/oss/getSTSToken`)
|
||||
Taro.setStorageSync('sts', credentials)
|
||||
Taro.setStorageSync('stsExpiredAt', credentials.expiration)
|
||||
sts = credentials
|
||||
}
|
||||
console.log(sts)
|
||||
const [filename, ext] = filePath.split('.')
|
||||
const key = `headers/${filename + (Math.random() * 100000)}.${ext}`
|
||||
const policy = Base64.encode(JSON.stringify(policyText))
|
||||
const signature = computeSignature(sts.accessKeySecret, policy)
|
||||
Taro.uploadFile({
|
||||
url: 'https://oss.wsdns.cn',
|
||||
name: 'file',
|
||||
filePath,
|
||||
formData: {
|
||||
key,
|
||||
policy,
|
||||
OSSAccessKeyId: sts.accessKeyId,
|
||||
signature,
|
||||
'x-oss-security-token': sts.securityToken
|
||||
},
|
||||
success: () => {
|
||||
resolve(`https://oss.wsdns.cn/${key}`)
|
||||
}
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
const computeSignature = (accessKeySecret, canonicalString) => {
|
||||
return crypto.enc.Base64.stringify(crypto.HmacSHA1(canonicalString, accessKeySecret));
|
||||
}
|
||||
|
||||
/**
|
||||
* 上传阿里云OSS
|
||||
*/
|
||||
export async function uploadFile() {
|
||||
return new Promise(async (resolve: (result: FileRecord) => void, reject) => {
|
||||
Taro.chooseImage({
|
||||
count: 1,
|
||||
sizeType: ['compressed'],
|
||||
sourceType: ['album', 'camera'],
|
||||
success: async (res) => {
|
||||
const tempFilePath = res.tempFilePaths[0];
|
||||
// 上传图片到OSS
|
||||
Taro.uploadFile({
|
||||
url: 'https://server.gxwebsoft.com/api/oss/upload',
|
||||
filePath: tempFilePath,
|
||||
name: 'file',
|
||||
header: {
|
||||
'content-type': 'application/json',
|
||||
TenantId
|
||||
},
|
||||
success: (res) => {
|
||||
try {
|
||||
const data = JSON.parse(res.data);
|
||||
if (data.code === 0) {
|
||||
resolve(data.data)
|
||||
} else {
|
||||
reject(new Error(data.message || '上传失败'))
|
||||
}
|
||||
} catch (error) {
|
||||
reject(new Error('解析响应数据失败'))
|
||||
}
|
||||
},
|
||||
fail: (err) => {
|
||||
console.log('上传请求失败', err);
|
||||
reject(new Error('上传请求失败'))
|
||||
}
|
||||
})
|
||||
},
|
||||
fail: (err) => {
|
||||
console.log('选择图片失败', err);
|
||||
reject(new Error('选择图片失败'))
|
||||
}
|
||||
});
|
||||
})
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user