Skip to content

七牛上传更新 #85

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 1 commit into from
Closed

七牛上传更新 #85

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
40 changes: 19 additions & 21 deletions core/utils/common.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -206,29 +206,27 @@ common.getBlobDownloadUrl = function (blobUrl) {

common.uploadFileToQiniu = function (key, filePath) {
return new Promise((resolve, reject) => {
qiniu.conf.ACCESS_KEY = _.get(config, "qiniu.accessKey");
qiniu.conf.SECRET_KEY = _.get(config, "qiniu.secretKey");
var accessKey = _.get(config, "qiniu.accessKey");
var secretKey = _.get(config, "qiniu.secretKey");
var bucket = _.get(config, "qiniu.bucketName", "");
var client = new qiniu.rs.Client();
client.stat(bucket, key, (err, ret) => {
if (!err) {
resolve(ret.hash);
var mac = new qiniu.auth.digest.Mac(accessKey, secretKey);
var options = {
scope: bucket,
};
var putPolicy = new qiniu.rs.PutPolicy(options);
var uploadToken=putPolicy.uploadToken(mac);
var formUploader = new qiniu.form_up.FormUploader();
var putExtra = new qiniu.form_up.PutExtra();
formUploader.putFile(uploadToken, key, filePath, putExtra, function(respErr, respBody, respInfo) {
log.debug(`respErr ${respErr}`)
log.debug(`respBody ${JSON.stringify(respBody)}`)
if (respErr) {
reject(new AppError.AppError(JSON.stringify(respErr)));
}
if (respInfo.statusCode == 200) {
resolve(respBody.hash);
} else {
try {
var uptoken = common.uptoken(bucket, key);
} catch (e) {
return reject(e);
}
var extra = new qiniu.io.PutExtra();
qiniu.io.putFile(uptoken, key, filePath, extra, (err, ret) => {
if(!err) {
// 上传成功， 处理返回值
resolve(ret.hash);
} else {
// 上传失败， 处理返回代码
reject(new AppError.AppError(JSON.stringify(err)));
}
});
log.debug(respInfo.statusCode);
}
});
});
Expand Down