aliyunOSSUtil.js

/**
 * 阿里云oss工具类
 */
var aliyunOSSUtil = {};
var counterNum = 0;

/**
 * 上传至阿里云oss
vk.callFunctionUtil.uploadFile({
	filePath:tempFilePath,
	fileType:"image",
	provider:"aliyun",
	index,
	onUploadProgress:function(res){
		// 上传过程中
		if (res.progress > 0) {
			if(list[index]){
				list[index].progress = res.progress;

			}
		}
	},
	success:function(res){
		// 上传成功

	},
	fail:function(res){
		// 上传失败

	}
});
 */
aliyunOSSUtil.uploadFile = function(obj) {
	let {
		filePath,
		name = "file",
		header = {
			"x-oss-forbid-overwrite": true,
		},
		index = 0,
		file = {},
		needSave = false
	} = obj;
	let vk = getApp().globalData.vk;
	let fileNameObj = createFileName(obj);
	let aliyunOSS = getConfig();
	let fileName = fileNameObj.fileFullName;
	let formData = vk.pubfn.copyObject(aliyunOSS.uploadData);
	formData["key"] = fileName; // 存储在oss的文件路径
	/**
	 * 特别说明
	 * 若已知本地图片,则使用formData["name"] = filePath
	 * 若已知base64,则是用formData["file"] = file;// file base64字符串转成blob对象
	 */
	if (filePath.indexOf(";base64,") > -1) {
		formData["file"] = dataURLtoBlob(filePath);
	} else {
		formData["name"] = filePath;
	}
	let Logger = {};
	Logger.startTime = new Date().getTime();
	Logger.filePath = filePath;
	let uploadTask = uni.uploadFile({
		url: aliyunOSS.action,
		filePath,
		name,
		header,
		formData: formData,
		success: function(res) {
			if (![200, 201].includes(res.statusCode)) {
				if (typeof obj.fail === "function") obj.fail(res);
				Logger.error = res;
			} else {
				// 上传成功
				res.fileID = fileNameObj.url;
				if (typeof obj.success === "function") obj.success(res);
				Logger.result = res;
				if (needSave) {
					// 保存文件记录到数据库
					vk.userCenter.addUploadRecord({
						data: {
							url: res.fileID,
							name: file.name,
							size: file.size,
							file_id: res.fileID,
							provider: "aliyun"
						}
					});
				}
			}
		},
		fail: function(res) {
			Logger.error = res;
			if (typeof obj.fail === "function") obj.fail(res);
		},
		complete: function() {
			let vk = getApp().globalData.vk;
			let config = vk.callFunctionUtil.config;
			if (config.debug) {
				Logger.endTime = new Date().getTime();
				Logger.runTime = (Logger.endTime - Logger.startTime);
				let colorArr = config.logger.colorArr;
				let colorStr = colorArr[counterNum % colorArr.length];
				counterNum++;
				console.log("%c--------【开始】【阿里云oss文件上传】--------", 'color: ' + colorStr +
					';font-size: 12px;font-weight: bold;');
				console.log("【本地文件】: ", Logger.filePath);
				console.log("【返回数据】: ", Logger.result);
				console.log("【预览地址】: ", Logger.result.fileID);
				console.log("【上传耗时】: ", Logger.runTime, "毫秒");
				console.log("【上传时间】: ", vk.pubfn.timeFormat(Logger.startTime, "yyyy-MM-dd hh:mm:ss"));
				if (Logger.error) console.error("【error】:", Logger.error);
				console.log("%c--------【结束】【阿里云oss文件上传】--------", 'color: ' + colorStr +
					';font-size: 12px;font-weight: bold;');
			}
		}
	});
	uploadTask.onProgressUpdate((res) => {
		if (res.progress > 0) {
			if (typeof obj.onUploadProgress === "function") obj.onUploadProgress(res);
		}
	});
	return uploadTask;
};


module.exports = aliyunOSSUtil;


// 获取配置
function getConfig() {
	let vk = getApp().globalData.vk;
	let config = vk.callFunctionUtil.getConfig();
	let aliyunOSS = vk.pubfn.getData(config, "service.aliyunOSS");
	let configData = {};
	if (aliyunOSS && aliyunOSS.uploadData && aliyunOSS.uploadData.OSSAccessKeyId) {
		try {
			if (aliyunOSS.groupUserId && typeof vk.getVuex === "function") {
				let userInfo = vk.getVuex("$user.userInfo");
				if (vk.pubfn.isNotNull(userInfo) && userInfo._id) {
					aliyunOSS.dirname += `/${userInfo._id}`;
				}
			}
		} catch (err) {}
		configData = {
			uploadData: {
				OSSAccessKeyId: aliyunOSS.uploadData.OSSAccessKeyId,
				policy: aliyunOSS.uploadData.policy,
				signature: aliyunOSS.uploadData.signature,
				success_action_status: 200,
				key: "test.png"
			},
			action: aliyunOSS.action,
			dirname: aliyunOSS.dirname,
			host: aliyunOSS.host,
		};
	}
	return configData;
}
// 生成文件名
function createFileName(obj = {}) {
	let {
		index = 0,
			filePath,
			suffix = "png"
	} = obj;
	let vk = getApp().globalData.vk;
	let aliyunOSS = getConfig();
	let dirname = aliyunOSS.dirname;
	let host = aliyunOSS.host;
	let fileObj = {};

	if (filePath) {
		let suffixName = filePath.substring(filePath.lastIndexOf(".") + 1);
		if (suffixName && suffixName.length < 5) suffix = suffixName;
	}
	let oldName = index + "." + suffix;

	let date = new Date();
	let dateYYYYMMDD = vk.pubfn.timeFormat(date, "yyyy/MM/dd");
	let dateTime = date.getTime().toString(); // 时间戳
	// 时间戳后8位
	let dateTimeEnd8 = dateTime.substring(dateTime.length - 8, dateTime.length);
	let randomNumber = vk.pubfn.random(8); // 8位随机数
	// 文件路径 = 固定路径名 + 业务路径
	let servicePath = "";
	let newFilePath = dirname + "/" + servicePath + dateYYYYMMDD + "/";
	// 文件名 = 时间戳后8位 - 随机数8位 + 后缀名
	let fileNickName = dateTimeEnd8 + randomNumber + "-" + oldName;
	// 文件名全称(包含文件路径) = 外网域名 + 文件路径 + 文件名
	let fileFullName = newFilePath + fileNickName;
	// 外网地址 = 外网域名 + 文件路径 + 文件名
	let url = host + "/" + fileFullName;
	fileObj.url = url;
	fileObj.fileFullName = fileFullName;
	fileObj.fileNickName = fileNickName;
	return fileObj;
}

function dataURLtoBlob(dataurl) {
	let arr = dataurl.split(','),
		mime = arr[0].match(/:(.*?);/)[1],
		bstr = atob(arr[1]),
		n = bstr.length,
		u8arr = new Uint8Array(n);
	while (n--) {
		u8arr[n] = bstr.charCodeAt(n);
	}
	return new Blob([u8arr], { type: mime });
}