eta_mobile_front/src/hooks/useUploadFileToOSS.js

// 上传文件到阿里云oss
import OSS from 'ali-oss'
import {apiGetOSSSign} from '@/api/common'
/* const Minio = require('minio')
const stream = require('stream') */
import * as Minio from 'minio-es'
import * as stream from 'stream'
import * as buffer from 'buffer'
const Buffer = buffer.Buffer

/**
 * 上传到oss
 * @param data 文件数据
 * @param fileName 存放在oss中的文件路径包含文件名
 * @param isMultipart 是否分片上传
 * @returns fileUrl 返回文件在阿里云上的地址
 */
export async function useUploadFileToOSS(data,fileName,isMultipart=false){
    const signRes=await apiGetOSSSign({StorageSource:1})
    if(signRes.Ret!==200) return
    const accessKeyId=signRes.Data.AccessKeyId
    const accessKeySecret=signRes.Data.AccessKeySecret
    const stsToken=signRes.Data.SecurityToken

    const ALOSSINS=new OSS({
        // yourRegion填写Bucket所在地域。以华东1（杭州）为例，Region填写为oss-cn-hangzhou。
        region: "oss-cn-shanghai",
        // 从STS服务获取的临时访问密钥（AccessKey ID和AccessKey Secret）。
        accessKeyId: accessKeyId,
        accessKeySecret: accessKeySecret,
        // 从STS服务获取的安全令牌（SecurityToken）。
        stsToken: stsToken,
        // 填写Bucket名称，例如examplebucket。
        bucket: "hzchart",
        endpoint:'hzstatic.hzinsights.com',
        cname:true,
        timeout:6000000
    });

    let res=null,resUrl='';
    try {
        if(isMultipart){
            const options = {
                // 获取分片上传进度、断点和返回值。
                progress: (p, cpt, res) => {
                    // console.log(p);
                    // ALOSSAbortCheckpoint=cpt
                    // this.percentage=parseInt(p*100)
                },
                // 设置并发上传的分片数量。
                parallel: 10,
                // 设置分片大小。默认值为1 MB，最小值为100 KB。
                partSize: 1024 * 1024 * 10, // 10MB
            };
            res=await ALOSSINS.multipartUpload(fileName,data,{...options})
        }else{
            res=await ALOSSINS.put(fileName,data)
        }

        if(res.res.status===200){
            resUrl='https://hzstatic.hzinsights.com/'+res.name
        }
    } catch (error) {
        console.log('阿里云上传失败',error);
    }
    

    return resUrl
}

//vite 不支持Buffer 代替Buffer.form方法
const toBinary = (data)=>{
    const length = data.length
    let buf = new ArrayBuffer(length)
    let view  = new Uint8Array(buf)
    for(let i=0;i<length;++i){
        view[i] = data[i]
    }
    let blob = new Blob([buf],{type:'application/x-tra'})
    const url = URL.createObjectURL(blob)
    return url
}
//上传到minio
// minio sdk 文档 https://min.io/docs/minio/linux/developers/javascript/API.html
export async function useUploadToMinIO (file, fileName, options = {}){
    const res = await apiGetOSSSign({StorageSource:2})
    if (res.Ret !== 200) {
        console.log("获取minio临时签名错误,res.Ret=" + res.Ret)
        return
    }
    const minioClient = new Minio.Client({
        endPoint: res.Data.Endpoint.split(':')[0],
        port: Number(res.Data.Port) || undefined,
        useSSL: res.Data.UseSSL.toLocaleLowerCase() == "false" ? false : true,
        accessKey: res.Data.AccessKeyId,
        secretKey: res.Data.SecretKeyId,
    })
    console.log(minioClient);
    try {
        var metaData = {
            ...{
                'Content-Type': file.type || 'application/octet-stream',
                "Content-Length": file.size,
            },
            ...options
        }

        minioClient.bucketExists(res.Data.Bucketname, function (err, exists) {
            if (err) {
                return console.log("minio 查看桶是否存在失败" + err)
            }
            if (!exists) {
                // 不存在桶，创建桶
                console.log("桶不存在，先创建桶", res.Data.Bucketname);
                minioClient.makeBucket(res.Data.Bucketname, res.Data.RegionId, function (err) {
                    if (err) {
                        console.log("minio 创建桶失败" + err)
                        return 
                    }
                    let reader = new FileReader();
                    // console.log(reader);
                    reader.readAsArrayBuffer(file);
                    reader.onloadend = function (e) {
                        const dataurl = e.target.result;
                        let bufferStream = new stream.PassThrough();
                        // 转化成数据流  minio接受数据流格式
                        bufferStream.end(Buffer.from(dataurl))
                        //bufferStream.end(toBinary(dataurl))
                        // console.log(bufferStream);
                        const bufferUrl = toBinary(dataurl)
                        minioClient.putObject(res.Data.Bucketname, fileName, bufferStream, file.size, metaData, function (err, etag) {
                            if (err) {
                                return console.log("上传到minio失败：" + err)
                            }
                            let fileUrl = fileName.startsWith('/') ? res.Data.ImgHost + fileName : res.Data.ImgHost + "/" + fileName
                            return fileUrl
                        })
                    }
                })
            }
            if (exists) {
                // console.log("桶存在",res.Data.Bucketname);
                let reader = new FileReader();
                console.log('reader',reader);
                reader.readAsArrayBuffer(file);
                reader.onloadend = function (e) {
                    const dataurl = e.target.result;
                    let bufferStream = new stream.PassThrough();
                    bufferStream.end(Buffer.from(dataurl))
                    //bufferStream.end(toBinary(dataurl))
                    const bufferUrl = toBinary(dataurl)
                    minioClient.putObject(res.Data.Bucketname, fileName, bufferStream, metaData, function (err, etag) {
                        if (err) {
                            console.log("上传到minio失败：" + err)
                            return 
                        }
                        let fileUrl = fileName.startsWith('/') ? res.Data.ImgHost + fileName : res.Data.ImgHost + "/" + fileName
                        console.log('test',fileUrl)
                        return fileUrl
                    })
                }
            }
        })
    } catch (error) {
        console.error(error);
        if (error.name !== "cancel") {
            //不是取消上传的则给错误提示
            this.$message.warning("上传失败，请刷新重试");
        }
    }
}