(function(){
//选择符API note: suite for IE 9+
var $ = document.querySelectorAll.bind(document);
//事件监听
Element.prototype.on = Element.prototype.addEventListener;
//在NodeList对象上通过forEach部署监听函数
NodeList.prototype.on = function (event, fn) {
// this 为 NodeList
[].forEach.call(this, function (el) {
el.on(event, fn);
});
return this;
};
/**
* 上传文件示例
* @type {HTMLElement}
*/
Ks3.config.AK = '+vB0RuO22DeeanAAb0ig'; //TODO： 请替换为您的AK
Ks3.config.SK = '3kbTp8pg+LymO84/ZyxG/od/3FeVDjWt+8/m5iBc'; //TODO: 测试时请填写您的secret key 注意：前端计算signature不安全
Ks3.config.region = 'BEIJING'; //TODO: 需要设置bucket所在region， 如杭州region： HANGZHOU,北京region：BEIJING，香港region：HONGKONG，上海region: SHANGHAI ，美国region:AMERICA ；如果region设置和实际不符，则会返回301状态码； region的endpoint参见：http://ks3.ksyun.com/doc/api/index.html
Ks3.config.bucket = 'teaseyoulearn'; // TODO : 设置默认bucket name
var bucketName = Ks3.config.bucket; //TODO: 请替换为您需要上传文件的bucket名称
var filelistNode = document.getElementById('filelist');
/*
* 如果bucket不是公开读写的，需要先鉴权，即提供policy和signature表单
* policy的conditions中需要指明请求体的form中用户添加的字段
*/
var policy = {
"expiration": new Date(getExpires(3600)*1000).toISOString(), //一小时后
"conditions": [
["eq","$bucket", bucketName],
["starts-with", "$key", ""],
["starts-with","$acl", "public-read"],
["starts-with", "$name", ""], //表单中传了name字段，也需要加到policy中
["starts-with", "$x-kss-meta-custom-param1",""],
["starts-with", "$x-kss-newfilename-in-body",""],//必须只包含小写字符
["starts-with", "$Cache-Control",""],
["starts-with", "$Expires", ""],
["starts-with", "$Content-Disposition", ""],
["starts-with", "$Content-Type",""],
["starts-with", "$Content-Encoding",""]
]
};
//policy stringify再经过BASE64加密后的字符串（utf8编码格式）
var stringToSign = Ks3.Base64.encode(JSON.stringify(policy));
//建议从后端sdk获取signature签名 算法为：Signature = Base64(HMAC-SHA1(YourSecretKey, stringToSign ) );
var signatureFromPolicy = Ks3.b64_hmac_sha1(Ks3.config.SK, stringToSign);
console.log('signatureFromPolicy:' + signatureFromPolicy);
var ks3UploadUrl;
//支持https 上传
if (window.location.protocol === 'https:') {
Ks3.config.protocol = 'https';
} else {
Ks3.config.protocol = 'http';
}
ks3UploadUrl = Ks3.config.protocol + '://' + Ks3.ENDPOINT[Ks3.config.region] + '/';
var ks3Options = {
KSSAccessKeyId: Ks3.config.AK,
policy: stringToSign,
signature: signatureFromPolicy,
bucket_name: bucketName,
key: '${filename}',
acl: "public-read",
uploadDomain: ks3UploadUrl + bucketName,
autoStart: false,
'x-kss-meta-custom-param1': 'Hello',
'x-kss-newfilename-in-body': true,
'Cache-Control': 'max-age=600', //设置缓存多少秒后过期
'Expires': new Date(getExpires(600) * 1000), //设置缓存过期时间
'Content-Disposition' :'attachment;filename=', // 触发浏览器下载文件
//'Content-Type' :' application/octet-stream',
onUploadProgressCallBack: function(uploader, obj){
var itemNode = document.getElementById(obj.id);
var resultNode = itemNode.querySelector('span');
resultNode.innerHTML = obj.percent + "%";
},
onFileUploadedCallBack: function(uploader, obj){ //obj是当前上传的文件对象
var itemNode = document.getElementById(obj.id);
var resultNode = itemNode.querySelector('span');
resultNode.innerHTML = "完成";
//显示上传的文件的链接
var linkNode = itemNode.querySelector('a');
linkNode.href = ks3Options.uploadDomain + "/" + obj.name;
linkNode.innerHTML = obj.name;
//增加加水印按钮
var adpBtn = document.createElement("button");
adpBtn.innerHTML = '添加水印';
adpBtn.onclick = function(){
var objKey = encodeURIComponent(obj.name);
var url = ks3UploadUrl + bucketName + '/' + objKey + '?adp' ;
var kssHeaders = {
'kss-async-process': 'tag=imgWaterMark&type=2&dissolve=65&gravity=NorthEast&text=6YeR5bGx5LqR&font=5b6u6L2v6ZuF6buR&fill=I2JmMTcxNw==&fontsize=500&dy=10&dx=20|tag=saveas&bucket=' + bucketName + '&object=imgWaterMark-' + obj.name,
'kss-notifyurl': 'http://10.4.2.38:19090/'
};
var signature = Ks3.generateToken(Ks3.config.SK, bucketName, objKey + '?adp', 'PUT','', kssHeaders, '');
var xhr = new XMLHttpRequest();
xhr.onreadystatechange = function() {
if (xhr.readyState == 4) {
if(xhr.status >= 200 && xhr.status < 300 || xhr.status == 304){
alert("put请求成功");
var waterMarkImgLink = document.createElement('a');
waterMarkImgLink.setAttribute('target','_blank');
waterMarkImgLink.style.marginLeft = "30px";
var processedImgName = "imgWaterMark-" + obj.name;
waterMarkImgLink.innerHTML = processedImgName;
//10分钟后的时间戳
var timeStamp = getExpires(600);
//根据Expires过期时间戳计算外链signature
var expiresSignature = Ks3.generateToken(Ks3.config.SK, bucketName, processedImgName, 'GET', '' ,kssHeaders, timeStamp);
setTimeout(function(){ //异步任务，等1秒再看处理结果
waterMarkImgLink.href = ks3UploadUrl + bucketName + '/imgWaterMark-' + obj.name + '?KSSAccessKeyId=' + encodeURIComponent(Ks3.config.AK) + '&Expires=' + timeStamp + '&Signature=' + encodeURIComponent(expiresSignature);
itemNode.appendChild(waterMarkImgLink);
},1000);
} else{
//alert('Request was unsuccessful: ' + xhr.status);
}
}
};
xhr.open("put", url, true);
xhr.setRequestHeader('Authorization','KSS ' + Ks3.config.AK + ':' + signature );
xhr.setRequestHeader('kss-async-process', kssHeaders['kss-async-process']);
xhr.setRequestHeader('kss-notifyurl',kssHeaders['kss-notifyurl']); //替换成您接收异步处理任务完成通知的url地址
xhr.send(null);
};
itemNode.appendChild(adpBtn);
},
onFilesAddedCallBack: function(uploader, objArray){ // objArray是等待上传的文件对象的数组
for (var i = 0 ; i < objArray.length ; i++){
var itemNode = document.createElement("li");
itemNode.innerHTML = objArray[i].name + "<span style='margin:5px 20px;'></span><a style='margin-right: 20px;' target='_blank'></a>";
itemNode.id = objArray[i].id;
filelistNode.appendChild(itemNode);
}
},
onBeforeUploadCallBack: function(uploader, obj) {
//可以在这里更新object key
//var newObjectKey = 'yourRenamedFileName_' + obj.name;
//uploader.settings.multipart_params['key'] = newObjectKey;
//obj.name = newObjectKey;
},
onErrorCallBack: function(uploader, errObject){
if(errObject.status === 413 || errObject.status === 415){
var responseXML = Ks3.parseStringToXML(errObject.response );
alert(Ks3.xmlToJson(responseXML)['Error']['Message']);
}else{
alert(errObject.code + " : Error happened in uploading " + errObject.file.name + " ( " + errObject.message + " )");
}
}
};
var pluploadOptions = {
browse_button: 'browse', //触发对话框的DOM元素自身或者其ID
drop_element: document.body, //指定了使用拖拽方式来选择上传文件时的拖拽区域，即可以把文件拖拽到这个区域的方式来选择文件。该参数的值可以为一个DOM元素的id,也可是DOM元素本身，还可以是一个包括多个DOM元素的数组。如果不设置该参数则拖拽上传功能不可用。目前只有html5上传方式才支持拖拽上传。
filters: {
mime_types : [ //只允许上传图片和zip文件
{ title : "Video files", extensions : "mp4,mov,qt,ts,rmvb,rm,avi,flv,mkv,wmv,mpg,mpeg,m2v,m4v,3gp,3g2,webm,vob,ogv,ogg" }
],
max_file_size : '2gb', //最大只能上传2GB的文件
prevent_duplicates : true //不允许选取重复文件
}
}
var tempUpload = new ks3FileUploader(ks3Options, pluploadOptions);
document.getElementById('start-upload').onclick = function (){
console.log("start...");
tempUpload.uploader.start();
}
/**
* GET Bucket （List Objects)
* 获取bucket（空间）中object（文件对象）示例
* 参见：http://ks3.ksyun.com/doc/api/bucket/get.html
*/
document.getElementById('get-bucket').onclick = function() {
Ks3.listObject({
'max-keys': '15'
},function(json) {
document.getElementById('responsexml').innerHTML = JSON.stringify(json, null, 4);
});
};
/**
* Delete Object
* 删除指定文件
*/
(function listObjects() {
Ks3.listObject(
{
Bucket: bucketName,
'max-keys': '10',
delimiter:'|'
},function(json) {
/**
* 以表格展示bucket中的object
*/
var tableEle = document.getElementById('exampleForDeleteFile');
var objectArray = json['ListBucketResult']['Contents'];
for(var i= 0, len = objectArray.length; i< len; i++) {
var item = document.createElement("tr");
var objKey = objectArray[i]['Key'];
item.id = objKey;
item.innerHTML = '<td>' + objKey + '</td><td>' + objectArray[i]['Size']/1024 + ' KB </td>' + '<td>' + new Date(objectArray[i]['LastModified']).toLocaleString() + '</td>' + '<td class="del-opt">删除</td>';
tableEle.appendChild(item);
};
$('.del-opt').on('click', function(e) {
var key = this.parentNode.firstChild.innerHTML;
Ks3.delObject(
{
Key: key
}, function(status) {
if( status === 204) {
alert( key + " 删除成功");
var ele = document.getElementById(key);
ele.parentNode.removeChild(ele);
}
});
});
});
})();
/**
* PUT Object 上传触发处理示例(上传图片增加水印,后端计算签名，转发请求到Ks3 API）
* 参见：http://ks3.ksyun.com/doc/api/async/trigger.html
* 注： 这里使用了FormData序列化表单中选取的文件，XMLHttpRequest 2级定义了FormData类型，
* 支持的浏览器有Firefox 4+，Safari 5+，Chrome 和 Android 3+版的WebKit
*/
document.getElementById('utp').onclick = function() {
var imgFile = document.getElementById('imgFile').files[0]; //获取文件对象
var formData = new FormData();
var objKey = imgFile.name;
formData.append("key", objKey);
formData.append("file", imgFile);
//10分钟后的时间戳，以秒为单位
var timeStamp = getExpires( 10 * 60 );
var url = 'http://127.0.0.1:3000/' + bucketName + '?t=' + timeStamp ;
var kssHeaders = {
'kss-async-process': 'tag=imgWaterMark&type=2&dissolve=65&gravity=NorthEast&text=6YeR5bGx5LqR&font=5b6u6L2v6ZuF6buR&fill=I2JmMTcxNw==&fontsize=500&dy=10&dx=20|tag=saveas&bucket=' + bucketName + '&object=imgWaterMark-' + objKey,
'kss-notifyurl': 'http://10.4.2.38:19090/',
'x-kss-storage-class' : 'STANDARD' // STANDARD | STANDARD_IA 即标准存储和低频访问存储（主要用于备份）
};
var xhr = new XMLHttpRequest();
xhr.onreadystatechange = function() {
if (xhr.readyState == 4) {
if(xhr.status >= 200 && xhr.status < 300 || xhr.status == 304){
alert("上传触发处理成功");
var waterMarkImg = document.getElementById('display-adp-result').firstChild;
console.log('Signature:' + xhr.responseText);
console.log('timestamp:' + timeStamp);
waterMarkImg.src = 'http://kss.ksyun.com/' + bucketName + '/imgWaterMark-' + objKey + '?KSSAccessKeyId=' + encodeURIComponent(Ks3.config.AK) + '&Expires=' + timeStamp + '&Signature=' + encodeURIComponent(xhr.responseText);
}else{
//alert('Request was unsuccessful: ' + xhr.status);
}
}
};
function progressFunction(e) {
var progressBar = document.getElementById("progressBar");
if (e.lengthComputable) {
progressBar.max = e.total;
progressBar.value = e.loaded;
}
}
xhr.upload.addEventListener("progress", progressFunction, false);
xhr.open("put", url, true);
//xhr.setRequestHeader('Content-Length',imgFile.size);
xhr.setRequestHeader('Authorization','KSS ' + Ks3.config.AK );
xhr.setRequestHeader('kss-async-process', kssHeaders['kss-async-process']);
xhr.setRequestHeader('kss-notifyurl',kssHeaders['kss-notifyurl']); //替换成您接收异步处理任务完成通知的url地址
xhr.setRequestHeader('x-kss-storage-class', kssHeaders['x-kss-storage-class']);
xhr.send(formData);
};
/**
* PUT Object 上传文件
* 前端计算signature，put请求直传到ks3 API
* 注意：前端计算signature容易泄露SK, 只用于调试，生产环境需要从后端获取签名，作为第一个参数params的Signature属性传入sdk api函数
*
*/
document.getElementById('utp2').onclick = function() {
var file = document.getElementById('imgFile2').files[0]; //获取文件对象
var objKey = Ks3.encodeKey(file.name);
var contentType = file.type;
Ks3.putObject({
Key: 'image/'+objKey,
File: file,
ACL: 'public-read',
ProgressListener: progressFunction,
Sinature: ''
},function(err) {
if(err) {
alert(JSON.stringify(err));
}else{
alert('put上传成功');
}
});
function progressFunction(e) {
var progressBar = document.getElementById("progressBar2");
if (e.lengthComputable) {
progressBar.max = e.total;
progressBar.value = e.loaded;
}
}
};
/**
* 下载文件（支持断点续传）
*/
document.getElementById('downloadBigFileBtn').onclick = function() {
blockDownload(
{
Bucket: 'sanrui',
Key:'jssdk/book.pdf'
},
function(err, results) {
if(err) {
console.log(err);
}
console.log(JSON.stringify(results));
});
}
document.getElementById('stopDownload').onclick = function() {
Ks3.config.stopFlag = true;
};
/**
* 上传文件（支持断点续传）
*/
var fileToBeUpload; //被上传的文件的文件名
document.getElementById('uploadBigFile').onclick = function() {
/**
* 文件名，最后修改时间，bucket和object key都没变化的情况，续传
*/
var file = document.getElementById('bigFile').files[0];
fileToBeUpload = file.name;
//设置分块大小
//Ks3.config.chunkSize = 6*1024*1024; //最小（默认）为5 MB，增大分块会增加部分浏览器崩溃的风险
multipartUpload({
Bucket: bucketName,
Key: fileToBeUpload,
//region: 'BEIJING',
ACL: 'public-read',
//ContentType : 'video/mp4',
File: file,
TotalSize: file.size,
Signature: '',
}, function(err, res){
if(err) {
if(err.msg != 'stop') {
console.error(err);
alert(err.msg);
}else{
console.log(err);
}
}else{
console.log('res: ' + JSON.stringify(res));
}
});
}
document.getElementById('suspendMultipartUpload').onclick = function() {
Ks3.config.stopFlag = true;
};
document.getElementById('cancelMultipartUpload').onclick = function() {
//前端暂停
Ks3.config.stopFlag = true;
//通知ks3取消上传
if(Ks3.config.currentUploadId) {
Ks3.abort_multipart_upload({
Bucket: bucketName,
Key:fileToBeUpload,
UploadId: Ks3.config.currentUploadId
},function(err,res) {
if(err) {
console.log(err);
}else{
console.log('res: ' + JSON.stringify(res));
//清理前端缓存与重置界面进度条
var len = localStorage.length;
for(var i=0; i< len; i++) {
var itemKey = localStorage.key(i);
//自动创建一个临时String对象封装itemKey在IE下会导致内存泄露，故显示转换
if(typeof itemKey === 'string' && (new String(itemKey)).endWith(bucketName + '-' + Ks3.encodeKey(fileToBeUpload))) {
localStorage.removeItem(itemKey);
}
}
var progressBar = document.getElementById("multipartUploadProgressBar");
progressBar.value = 0;
}
});
}
};
})();
/**
* 上传文件
* 根据文件大小,进行简单上传和分块上传
* @param params
* {
* Bucket: '' not required, bucket name
* Key: '' Required object key
* region : '' not required bucket所在region
* ContentType: '' not required content type of object key
* ACL: '' not required private | public-read
* File: object required, 需要上传的文件
* TotalSize: not required, 需要限定文件总大小时使用
* Signature: '' not required, 请求签名,从服务端获取
* callbackurl: '' not required, 回调url
* callbackbody: '' not require, 回调自定义参数
* }
* @param cb
*/
function multipartUpload (params, cb) {
var config;
var bucketName = params.Bucket || Ks3.config.bucket || '';
var key = params.Key || params.File.name;
key = Ks3.encodeKey(key);
var region = params.region || Ks3.config.region;
if (region ) {
Ks3.config.baseUrl = Ks3.ENDPOINT[region];
}
var file = params.File;
var totalSize = file.size; //文件总大小
var progressKey = getProgressKey(file.name, file.lastModified, bucketName, key);
console.log(progressKey);
// 会根据文件大小,进行简单上传和分块上传
var contentType = params.ContentType || '';
var progressBar = document.getElementById("multipartUploadProgressBar");
// 分块上传
console.log(async);
async.auto({
/**
* 初始化配置文件,如果没有就新建一个
*/
init: function(callback) {
//重置暂停标识
Ks3.config.stopFlag = false;
if ( !localStorage[progressKey]) {
configInit(file, progressKey, function(err) {
callback(err);
})
} else {
callback(null);
}
},
show: ['init', function(callback) {
console.log(' 开始上传文件: ' + progressKey)
config = JSON.parse(localStorage.getItem(progressKey));
progressBar.max = config['count'];
progressBar.value = config['index'];
callback(null);
}],
/**
* 获取uploadId,如果有就直接读取,没有就从服务器获取一个
*/
getUploadId: ['init', function(callback) {
config = JSON.parse(localStorage.getItem(progressKey));
var uploadId = config['uploadId'];
if ( !! uploadId) {
callback(null, uploadId);
} else {
Ks3.multitpart_upload_init(params, function(err, uploadId) {
if(err) {
callback(err);
}else {
config['uploadId'] = uploadId;
localStorage.setItem(progressKey, JSON.stringify(config));
callback(null, uploadId);
}
});
}
}],
/**
* 对文件进行上传
* 上传后要把信息写到本地存储配置文件中
* 如果都上传完了,就把相关本地存储信息删除
* 并通知服务器,合并分块文件
*/
upload: ['getUploadId', function(callback, result) {
if(result.getUploadId) {
var uploadId = result.getUploadId;
Ks3.config.currentUploadId = uploadId;
config = JSON.parse(localStorage.getItem(progressKey));
var count = config['count'];
var index = config['index'];
var chunkSize = config['chunkSize'];
var currentRetries = config['retries'];
up();
}else {
callback({'msg':'no uploadId'});
}
// 在报错的时候重试
function retry(err) {
console.log('upload ERROR:', err);
if (currentRetries > Ks3.config.retries) {
throw err;
} else {
currentRetries = currentRetries + 1;
config['retries'] = currentRetries;
localStorage.setItem(progressKey, JSON.stringify(config));
console.log('第 ' + currentRetries + ' 次重试');
up();
}
}
// 真正往服务端传递数据
function up() {
console.log('正在上传 ', 'index: ' + index);
var start = (index - 1) * chunkSize;
// 判断是否已经全部都传完了
if (index <= count) {
getFileContent(file, chunkSize, start, function(body) {
delete params.File;
params.UploadId = uploadId;
params.PartNumber = index;
params.body = body;
params.type = contentType;
console.log('正在上传第 ', index, ' 块,总共: ', + count + ' 块');
try {
Ks3.upload_part(params, function(err, partNumber, etag) {
if (err) {
if(err.status == 413 || err.status == 415) {
callback(err);
}else {
retry(err);
}
} else {
if(!Ks3.config.stopFlag) {
config['index'] = index;
progressBar.value = config['index'];
config['etags'][index] = etag;
localStorage.setItem(progressKey, JSON.stringify(config));
index = index + 1;
up();
}else {
callback({
msg: "stop"
});
}
}
});
} catch(e) {
retry(e);
}
})
} else {
console.log('发送合并请求');
delete params.File;
params.UploadId = uploadId;
params.body = generateCompleteXML(progressKey);
Ks3.upload_complete(params, function(err, res) {
if (err) throw err;
callback(err, res);
})
}
};
}]
},
function(err, results) {
if (err) {
//throw err;
}else{
//删除配置
localStorage.removeItem(progressKey);
}
if (cb) {
cb(err, results);
}
});
}
/**
* 计算用于记录上传任务进度的key
* @param name
* @param lastModified
* @param bucket
* @param key
*/
function getProgressKey(name, lastModified, bucket, key) {
var result = name + "-" + lastModified + "-" + bucket + "-" + key;
return result;
}
/**
* 把配置信息写到localStorage里,作为缓存
* @param file 上传文件的句柄
* @param progressKey 文件上传进度缓存在localStorage中的标记key
* @param cb
*/
function configInit(file, progressKey, cb) {
var fileSize = file.size;
var count = parseInt(fileSize / Ks3.config.chunkSize) + ((fileSize % Ks3.config.chunkSize == 0 ? 0: 1));
if (count == 0) {
cb({
msg: 'The file is empty.'
})
} else {
config = {
name: file.name,
size: fileSize,
chunkSize: Ks3.config.chunkSize,
count:count,
index: 1,
etags:{},
retries: 0
}
localStorage.setItem(progressKey, JSON.stringify(config));
if(cb) {
cb(null);
}
}
}
/**
* 获取指定的文件部分内容
*/
function getFileContent(file, chunkSize, start, cb) {
var start = start;
var bufferSize = file.size;
var index = start / chunkSize;
console.log('正在读取下一个块的文件内容 index:' + index);
if (start + chunkSize > bufferSize) {
chunkSize = bufferSize - start;
}
console.log('分块大小:', chunkSize);
if(file.slice) {
var blob = file.slice(start, start + Ks3.config.chunkSize);
}else if(file.webkitSlice) {
var blob = file.webkitSlice(start, start + Ks3.config.chunkSize);
}else if(file.mozSlice) {
var blob = file.mozSlice(start, start + Ks3.config.chunkSize);
}else{
throw new Error("blob API doesn't work!");
}
var reader = new FileReader();
reader.onload = function(e) {
cb(e.target.result);
};
reader.readAsArrayBuffer(blob);
}
/**
* 生成合并分块上传使用的xml
*/
function generateCompleteXML(progressKey) {
var content = JSON.parse(localStorage.getItem(progressKey));
var index = content.index;
var str = '';
if (index > 0) {
str = '<CompleteMultipartUpload>';
for (var i = 1; i <= index; i++) {
str += '<Part><PartNumber>' + i + '</PartNumber><ETag>' + content.etags[i] + '</ETag></Part>'
}
str += '</CompleteMultipartUpload>';
}
return str;
}
/**
* 断点续传下载
* 文件分片下载进度存储于localStorage（以filePath做关键字索引文件）
* @param {object} params
* {
* Bucket: '' not required, bucket name
* Key : '' Required , object key
* filePath: '' Required, file path to save
* chunk: '' not required, chunk size by bytes, default is 100 * 1024 B
* }
*/
function blockDownload (params, cb) {
var bucketName = params.Bucket || Ks3.config.bucket;
// 这个地方不能进行encode
var key = params.Key;
var filePath = params.filePath || bucketName + '-' + key.replace('/','-') ; //因为浏览器文件系统不能在不存在的目录下直接创建文件，故将目录转为文件名的前缀
if (!key) {
alert('require the object Key');
}
var TEMP_SPACE = 1024 * 1024 * 1024 ; // 1GB
window.requestFileSystem = window.requestFileSystem || window.webkitRequestFileSystem;
function onError(e) {
console.log('Error', e);
}
// 用户要下载生成的文件
var downFileName = filePath + '.download';
var config = null; //配置信息集合
// 分块大小
var chunk = params.chunk || 1 * 1024 * 100;
var count = 0;
var index = 0;
async.auto({
/**
* 初始化或者读取configFile
* 1. 获取文件大小
* 2. 并且根据分块大小计算出总共请求次数
*/
init: function(callback) {
/**
* 重置记录进度的配置文件，删除下载了部分的重名文件
* @param config
*/
function resetConfig(conf) {
localStorage.setItem(filePath, JSON.stringify(conf));
index = 0;
//如果有重名文件downFileName，删除
window.requestFileSystem(window.TEMPORARY, TEMP_SPACE, function(fs) {
fs.root.getFile(downFileName, {create: false}, function(fileEntry) {
fileEntry.remove(function() {
console.log(downFileName + ' File removed.');
}, onError);
}, onError);
}, onError);
};
//重置暂停标示
Ks3.config.stopFlag = false;
/**
* 从云端获取文件元数据
*/
console.log('远程获取元数据');
Ks3.headObject(params, function(err, res) {
if (err) {
callback(err);
} else {
var length = res.getResponseHeader('content-length');
count = parseInt(length / chunk) + (length % chunk == 0 ? 0 : 1);
if (count == 0) {
callback({
msg: '文件大小为0'
})
} else if (localStorage && localStorage[filePath]) { // 之前已经有配置信息了
config = JSON.parse(localStorage.getItem(filePath));
if (config['lastModifyTime'] == res.getResponseHeader('Last-Modified')) {
console.log('本地读取数据');
count = config['count'];
index = config['index'];
} else {
config = {
"BUCKET": bucketName,
"KEY": key,
"path": filePath,
"chunk": chunk,
"count": count,
"index": 0,
"lastModifyTime": res.getResponseHeader('Last-Modified')
};
resetConfig(config);
}
} else { //无配置信息
config = {
"BUCKET": bucketName,
"KEY": key,
"path": filePath,
"chunk": chunk,
"count": count,
"index": 0,
"lastModifyTime": res.getResponseHeader('Last-Modified')
};
resetConfig(config);
}
callback(null);
}
});
},
/**
* 下载分块数据,并追加到文件末尾
*/
down: ['init', function(callback, result) {
// 下载逻辑
var progressBar = document.getElementById("downloadProgressBar");
progressBar.max = count;
function writeToFileSystem(blob, path) {
window.requestFileSystem(window.TEMPORARY, TEMP_SPACE, function(fs) {
fs.root.getFile(path, {create: true}, function(fileEntry) {
fileEntry.createWriter(function(writer) {
var len = writer.length;
writer.seek(len); // Start write position at EOF.
console.log('download file length: ' + len);
writer.write(blob);
}, onError);
}, onError);
}, onError);
}
var downHandler = function() {
if(Ks3.config.stopFlag) {
callback({
msg: 'stop'
});
}else{
//更新下载进度
progressBar.value = index;
var percent = index + '/' + count;
document.getElementById('downloadPercent').innerText = percent;
if (index + 1 > count) { // 下载结束
console.log('下载结束')
callback(null);
} else { // 还没下载完,继续进行下载
console.log('进行下载:', index, '/', count);
Ks3.getObject({
Bucket:bucketName,
Key: key,
range: 'bytes=' + index * chunk + '-' + ((index + 1) * chunk - 1)
},
function(err, data, res) {
if (err) {
callback(err, data);
} else {
writeToFileSystem(data, downFileName);
index = index + 1;
config['index'] = index;
localStorage.setItem(filePath, JSON.stringify(config));
downHandler();
}
});
}
}
};
downHandler();
}]
},
function(err, results) {
/**
* 将浏览器文件系统中的文件拷贝到用户文件系统中
*/
function copyFileInBrowserRootToUserOS(fromFilePath, toFilePath) {
window.requestFileSystem(window.TEMPORARY, TEMP_SPACE, function(fs) {
fs.root.getFile(fromFilePath, {create: false}, function(fileEntry) {
fileEntry.file(function(file) {
//downloadFile
var aLink = document.createElement('a');
var evt = document.createEvent("HTMLEvents");
evt.initEvent("click", false, false);//initEvent 不加后两个参数在FF下会报错
aLink.download = toFilePath;
window.URL = window.URL || window.webkitURL;
aLink.href = window.URL.createObjectURL(file);
aLink.dispatchEvent(evt);
}, onError);
}, onError);
}, onError);
}
if (err) {
if (cb) {
cb(err, results);
}
} else {
localStorage.removeItem(filePath);
copyFileInBrowserRootToUserOS(downFileName, filePath);
if (cb) {
cb(err, {msg:'success',path:filePath});
}
}
})
}