js/Common/awsupload.js

@@ -0,0 +1,228 @@
+let bucket; //aws上传接口
+let bucketname = "ccrb"; //桶
+const partsize = 1 * 1024 * 1024; // 1MB
+
+//--------------------------分断上传保证稳定性
+//初始化上传
+async function init() {
+    const credentials = {
+        accessKeyId: "AKIATLPEDU37QV5CHLMH",
+        secretAccessKey: "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",
+    }; //秘钥形式的登录上传
+    window.AWS.config.update(credentials);
+    window.AWS.config.region = "cn-northwest-1"; //设置区域
+    //桶的设置
+    bucket = new window.AWS.S3({
+        params: {
+            Bucket: bucketname
+        }
+    });
+    return bucket;
+}
+
+//初始化上传入口
+async function initMultipartUpload(file, folderid) {
+    const params = {
+        Bucket: bucketname,
+        Key: folderid + "/" + file.name
+    };
+    //创建一个续传通道
+    const data = await bucket.createMultipartUpload(params).promise();
+    return data.UploadId;
+}
+
+// 上传文件的某一部分
+async function uploadPart(file, keyname, uploadid, pn, start, end) {
+    //key可以设置为桶的相对路径，Body为文件， ACL最好要设置
+    var params = {
+        Bucket: bucketname,
+        Key: keyname,
+        ContentType: file.type,
+        PartNumber: pn,
+        UploadId: uploadid,
+        Body: file.slice(start, end),
+        "Access-Control-Allow-Credentials": "*",
+        ACL: "public-read",
+    };
+    const result = await bucket.uploadPart(params).promise()
+        .then((data) => {
+            return { ETag: result.ETag, PartNumber: pn };
+        })
+        .catch((err) => {
+            return err;
+        });
+}
+
+// 完成分块上传
+async function completeMultipartUpload(parts, keyname) {
+    const params = {
+        Bucket: bucketname,
+        Key: keyname,
+        MultipartUpload: { Parts: parts },
+        UploadId: uploadid
+    };
+    await bucket.completeMultipartUpload(params).promise();
+}
+
+//中止分块上传
+async function abortMultipartUpload(key, uploadid) {
+    const params = {
+        Bucket: bucketname,
+        Key: key,
+        UploadId: uploadid
+    };
+    await bucket.abortMultipartUpload(params).promise();
+}
+
+// 实际的上传逻辑
+async function uploadFile(file, folderid) {
+    folderid = folderid || window.Guid.newGuid(); //分配到一个随机的id里
+    var keyname = folderid + "/" + file.name; //保存在指定的文件夹里
+    var uploadid = "";
+    try {
+        init(); // 初始化aws接口
+        // 初始化分块上传
+        uploadid = await initMultipartUpload(file, folderid);
+        // 分块上传文件
+        let parts = [];
+        let start = 0;
+        let end = 0;
+        let len = Math.ceil(file.length / partsize); //循环的长度
+        //循环上传
+        for (let i = 0; i < len; i++) {
+            start = i * partsize;
+            end = (i + 1) * partsize;
+            parts.push(await uploadPart(file, keyname, uploadid, i, start, end));
+        }
+        // 完成分块上传
+        await completeMultipartUpload(parts, uploadid);
+        return uploadid;
+    }
+    catch (error) {
+        // 如果出现错误，中止分块上传
+        console.error('An error occurred during file upload:', error);
+        await abortMultipartUpload(keyname, uploadid);
+    }
+}
+
+//--------------------------------下面支持断点续传
+
+//初始化亚马逊参数
+async function init() {
+    //秘钥形式的登录上传
+    const credentials = {
+        accessKeyId: "AKIATLPEDU37QV5CHLMH",
+        secretAccessKey: "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",
+        region: "cn-northwest-1"
+    };
+    window.AWS.config.update(credentials);
+    // window.AWS.config.region = "cn-northwest-1"; //设置区域
+    //桶的设置
+    bucket = new window.AWS.S3({
+        params: {
+            Bucket: bucketname
+        }
+    });
+    return bucket;
+}
+
+//获取当前文件是否有已上传断点信息
+async function getawscheckpoint(key) {
+    let partsinfo;
+    try {
+        const result = await bucket.listMultipartUploads({ Bucket: bucketname, Prefix: key }).promise();
+        //获取具体分片信息
+        if (result.Uploads.length) {
+            uploadid = result.Uploads[result.Uploads.length - 1].UploadId;
+            partsinfo = await bucket.listParts({ Bucket: bucketname, Key: key, UploadId: uploadid, }).promise();
+        }
+    } catch (err) {
+        console.log(err);
+    }
+    return { uploadid, partsinfo };
+}
+
+//分段上传
+async function awsuploadpart(filestate, file, uploadid, parts, key) {
+    var partarr = [];//已完成的数组
+    //已完成的分片,转化成提交格式
+    const completeparts = parts.map((_) => {
+        partarr.push(_.PartNumber);
+        return { PartNumber: _.PartNumber, ETag: _.ETag };
+    });
+    // 分块上传文件
+    let parts = [];
+    let uploadpart;
+    let start = 0;
+    let end = 0;
+    let len = Math.ceil(file.length / partsize); //循环的长度
+    if (partarr.length) {
+        filestate.status = "processing";
+        filestate.percent = parseInt((completeparts.length * 100) / count);
+    }
+    //循环上传
+    for (let i = 0; i < len; i++) {
+        start = i * partsize;
+        end = (i + 1) * partsize;
+        if (!partarr.includes(i)) {
+            uploadpart = await uploadPart(file, key, uploadid, i, start, end);
+            if (uploadpart.ETag != null) {
+                completeparts.push(uploadpart);
+                filestate.percent = parseInt((completeparts.length * 100) / count);
+            }
+
+            else {
+                filestate.status = "fail";
+                return;
+            }
+        }
+    }
+    //提交上传成功信息
+    await completeMultipartUpload(completeparts, uploadid);
+}
+
+//上传的接口
+async function awsupload(file, folderid, filestate) {
+    init(); //初始化桶
+    const key = (folderid || window.Guid.newGuid()) + "/" + file.name; //需要上传的文件名
+    filestate.percent = 0;
+    filestate.status = "start";
+    //上传的参数
+    var params = {
+        Bucket: bucketname,
+        Key: key
+    };
+    //设置桶上传文件
+    try {
+        //检查文件是否已上传
+        bucket.headObject(params, async (err, data) => {
+            // 没有上传成功，head方法会返回失败
+            if (err) {
+                //检查是否部分上传
+                const { uploadid, partsinfo } = await getawscheckpoint(key, bucket);
+                //如果已经部分存在，那么直接在节点续传
+                if (uploadid) {
+                    //断点续传
+                    awsuploadpart(filestate, file, uploadid, partsinfo.Parts, key);
+                }
+                //不存在，上传新的
+                else {
+                    const uploadid = await initMultiPartUpload(bucket, params); //初始化文件上传
+                    awsuploadpart(filestate, file, uploadid, [], key);
+                }
+            }
+            //如果已经上传成功了，那么直接返回状态百分百
+            else if (data) {
+                //data存在，上传成功
+                filestate.percent = 100;
+                filestate.status = "success";
+            }
+        });
+    }
+    catch (err) {
+        filestate.status = "error";
+        console.log(err);
+    }
+    return filestate;
+}
+