休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ this.cnt = 0;
+ }
+
+ //发送请求
+ res=await this.getFilesByOnce(file,undefined);
+
+ //请求失败
+ if(res?.errno){
+ return message.error(`提示：休息 3 秒...
`);
- await base.sleep(3000);
- cnt = 0;
- }
- }
- return files;
+ //获取文件目录结构（递归）
+ for (let file of selectList) {
+ //遍历选中文件
+ //统一变量名
+ fileList = fileList.concat(await this.fetchFiles(file,fileTree));
}
- let files = selectList.filter(f => !f.isdir);
-
- if (selectList.some(f => f.isdir)) {
- files = files.concat(await fetchFiles(selectList.filter(f => f.isdir)));
- }
- if (!files.length) {
+ //文件夹为空
+ if (!fileList.length) {
return message.error('提示：休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ };
+
+ //累加批次
+ i += batchSize;
+ batchSize = globalBatchsize+Math.ceil(Math.random()*5)
}
if (linkList.length) {
+ for (let i = 0; i < linkList.length; i++) {//重写下载路径
+ linkList[i]._path = filesDict[linkList[i].fs_id]._path;
+ }
base.showMainDialog(config.base.dom.button[mode].title, this.generateDom(linkList), config.base.dom.button[mode].footer);
} else {
return message.error('提示：
${filename}
@@ -3845,8 +4075,8 @@
if (mode === 'api') {
alinkAllText += dlink + '\r\n';
content += `
-
${filename}
-
增强下载(基于浏览器文件流)
+
${filename}
+
增强下载(基于浏览器文件流)
直接下载(基于浏览器链接)
复制链接
@@ -3864,37 +4094,47 @@
}
let BDUSS = this.getBDUSS();
if (mode === 'aria') {
- let alink = base.convertLinkToAria(dlink, filename, `--header "User-Agent: ${config.$baidu.api.ua.downloadLink}" --header "Cookie: BDUSS=${BDUSS}"`);
+ let alink = base.convertLinkToAria(dlink, filename, dpath, `--header "User-Agent: ${config.$baidu.api.ua.downloadLink}" --header "Cookie: BDUSS=${BDUSS}"`);
if (typeof (alink) === 'object') {
content += `
`;
} else {
alinkAllText += alink + '\r\n';
content += `
`;
}
}
if (mode === 'rpc') {
content += `
-
${filename}
-
将 ${filename} 推送到 RPC 下载器
-
`;
+
${filename}
+
+
+
+
+
+ 将 ${filename} 推送到 RPC 下载器
+
+
`;
}
if (mode === 'curl') {
- let alink = base.convertLinkToCurl(dlink, filename, `-A "${config.$baidu.api.ua.downloadLink}" -b "BDUSS=${BDUSS}"`);
+ let alink = base.convertLinkToCurl(dlink, filename, dpath, `-A "${config.$baidu.api.ua.downloadLink}" -b "BDUSS=${BDUSS}"`);
if (typeof (alink) === 'object') {
content += `
`;
} else {
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -3904,13 +4144,13 @@
if (typeof (alink) === 'object') {
alinkAllText += decodeURIComponent(alink.text) + '\r\n';
content += `
`;
} else {
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -4134,8 +4374,13 @@
* 阿里云盘
* @author 油小猴
* @author hmjz100
+ * @author KanouAo
*/
let $aliyun = {
+ cnt:0,//计数器，用于控制随机延迟
+ fileCount:0,//文件计数
+ authorization:"",
+
addPageListener() {
/*
防止代码因其他原因被执行多次
@@ -4225,11 +4470,12 @@
const $width = o.item.find('.pl-progress-inner');
const $text = o.item.find('.pl-progress-inner-text');
const filename = o.link[0].dataset.filename;
+ const path=o.link[0].dataset.path;
const index = o.link[0].dataset.index;
const size = Number(o.link[0].dataset.size) || 0;
base._resetData(index);
- base.get(e.currentTarget.dataset.link, { "Referer": `https://${location.host}/` }, 'blob', { filename, index });
+ base.get(e.currentTarget.dataset.link, { "Referer": `https://${location.host}/` }, 'blob', { filename, index, path});
let startTime = Date.now();
let prevLoaded = 0;
@@ -4335,7 +4581,7 @@
target.find('.pl-loading').remove();
target.prepend(base.createLoading());
- let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename, [`Referer: https://${location.host}/`]);
+ let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename,e.currentTarget.dataset.path, [`Referer: https://${location.host}/`]);
if (res === 'success') {
$('.listener-rpc-task').show();
target.removeClass('pl-btn-danger').html('发送成功了!快去看看吧~').animate({ opacity: '0.5' }, "slow");
@@ -4349,7 +4595,10 @@
$('.listener-link-rpc').click();
$(e.target).text('发送完成，发送结果见上方按钮哦~').animate({ opacity: '0.5' }, "slow");
});
- doc.on('click', '.listener-download-all.blob', function (e) {
+ doc.on('click', '.listener-download-all',async function (e) {//TODO 这你原本写的是//.listener-download-all.blob，怕你写错改了下
+ if(navigator.userAgent.match(/Chrom(e|ium)/)){//Chromium内核
+ globalDirHandle = await window.showDirectoryPicker();
+ }
$('.pl-item-link.blob').each(function () {
if ($(this).css('display') !== 'none') {
$(this).click();
@@ -4383,26 +4632,6 @@
}, true);
},
- async getFileUrlByOnce(d, f) {
- let authorization = `${base.getStorage('token').token_type} ${base.getStorage('token').access_token}`;
- let res = await base.post(config.$aliyun.api.getLink, {
- drive_id: d,
- file_id: f
- }, {
- authorization,
- "content-type": "application/json;charset=utf-8",
- "referer": "https://www.aliyundrive.com/",
- "x-canary": "client=windows,app=adrive,version=v6.0.0"
- });
- if (res.code === 'AccessTokenInvalid') {
- return message.error('提示：
访问令牌过期了，请刷新网页后再试');
- }
- if (res.url) {
- return res.url;
- }
- return '';
- },
-
greenerPage() {
base.waitForKeyElements('[class*="share-list-banner"]', function (tag) {
tag.fadeOut();
@@ -4460,6 +4689,110 @@
})
},
+ async getFilesByOnce(file,params){
+ let res;
+ if(page=="home"||page=="main"){
+ res = await base.post(config.$aliyun.api.getFiles.home, {
+ "all": false,//TODO 取得全部文件，默认是false，但测试时突然取不到了，不知道是不是阿里改了
+ "drive_id": params.drive_id,
+ "fields": "*",
+ "limit": 100,//TODO 第一次20，之后100。省事先统一100看看,以后有问题再改
+ "marker":params.marker,
+ "order_by": "name",
+ "order_direction": "DESC",
+ "parent_file_id": params.parent_file_id,
+ "url_expire_sec": 14400//4小时后链接失效
+ }, {
+ "authorization":this.authorization,
+ "content-type": "application/json",
+ "referer": "https://www.aliyundrive.com/",
+ "x-canary": "client=windows,app=adrive,version=v6.0.0"
+ }
+ );
+ }else if(page=="share"){
+ }else{
+ return message.error(`提示：
网站页面错误`);
+ }
+ return res;
+ },
+
+ async getFileUrlByOnce(d, f) {
+ let res = await base.post(config.$aliyun.api.getLink.home, {
+ drive_id: d,
+ file_id: f
+ }, {
+ "authorization":this.authorization,
+ "content-type": "application/json;charset=utf-8",
+ "referer": "https://www.aliyundrive.com/",
+ "x-canary": "client=windows,app=adrive,version=v6.0.0"
+ });
+ if (res.code === 'AccessTokenInvalid') {
+ return message.error('提示：
访问令牌过期了，请刷新网页后再试');
+ }
+ if (res.url) {
+ return res.url;
+ }
+ return '';
+ },
+
+ async fetchAllPages(file) {
+ //分页获取文件夹内文件数据
+ let files=[];//文件数据列表
+ let marker='';//文件夹内下一段数据的令牌
+ let res;
+
+ while (true) {
+ //随机停顿防反爬
+ this.cnt++;
+ if (this.cnt >= 50+Math.random()*10) {
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${this.fileCount} 个文件~
休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ this.cnt = 0;
+ }
+
+ //发送请求
+ let param={"drive_id":file.drive_id,"parent_file_id":file.file_id,"marker":marker};
+ res=await this.getFilesByOnce(file,param);
+
+ //请求失败
+ if(!res?.items){
+ return message.error(`提示：
请求失败`);
+ }
+
+ //请求成功
+ files=files.concat(res.items)
+ marker=res.next_marker;
+ if (!marker)
+ break;
+ }
+ return files;
+ },
+
+ async fetchFiles(file,pNode) {
+ //节点
+ let fileNode={
+ name:file.name,//注意变量名
+ path:pNode.name === 'root' ? `` : (pNode.path === '' ? pNode.name : `${pNode.path}/${pNode.name}`),//一般来说，路径不要特别特别长，不然可能会出问题，不过正常是不会的
+ children:[]
+ }
+ pNode.children.push(fileNode);
+ file.path=fileNode.path;
+
+ //判断是否文件夹
+ if (file?.type!='folder') {//注意变量名
+ this.fileCount++;
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${this.fileCount} 个文件~
`);
+ return file;
+ }
+
+ //文件夹内文件遍历
+ let files=[];
+ for (let f of await this.fetchAllPages(file)) {
+ files= files.concat(await this.fetchFiles(f,fileNode));
+ }
+ return files;
+ },
+
async getLink() {
Swal.fire({
showConfirmButton: false,
@@ -4486,55 +4819,81 @@
if (selectList.length === 0) {
return message.error('提示：
请勾选要下载的文件哦~');
}
- if (this.isOnlyFolder()) {
- return message.error('提示：
请打开文件夹后再勾选文件~');
+
+ if(page === 'home'){
+ }else if(page=="share"){
+ //分享页面所需的变量
+ }else{
+ return message.error('提示：
页面错误~');
}
+
+ this.authorization= `${base.getStorage('token').token_type} ${base.getStorage('token').access_token}`;
+ this.cnt=0; //计数器，用于控制随机延迟
+ this.fileCount=0;//文件计数
+ let fileList=[];//文件列表，只有文件没有文件夹
+ let fileTree = { name: "root", path: ``, children: [] }; // 文件目录树
if (page === 'home') {
- selectList = selectList.filter(item => item.type === 'file')
- let batchSize = 15;
- let processed = 0;
+ //获取文件目录结构（递归）
+ for (let file of selectList) {
+ //遍历选中文件
+ //统一变量名
+ file.drive_id=file.drive_id||file.driveId;//driveId、fileId全统一成drive_id、file_id
+ file.file_id=file.file_id||file.fileId;
+ fileList = fileList.concat(await this.fetchFiles(file,fileTree));
+ }
+ //文件夹为空
+ if (!fileList.length) {
+ return message.error('提示：
文件夹是空的哦~');
+ }
+
+ //获取下载链接
doc.find('.loading-popup .loading-title').html(`链接获取中`);
doc.find('.loading-popup .swal2-html-container').html(`
正在获取文件对应的下载链接~
`);
- for (let i = 0; i < selectList.length; i += batchSize) {
- // 当前批次文件
- let batch = selectList.slice(i, i + batchSize);
+ let batchSize = 15+Math.ceil(Math.random()*5);
+ let i=0;
+ while (i < fileList.length){
+ // 分批获取链接
+ let batch = fileList.slice(i, i + batchSize);
// 过滤掉已有 URL 的文件
- let noUrlSelectList = batch.filter(v => !Boolean(v.url));
- let hasUrlSelectList = batch.filter(v => Boolean(v.url));
- let queue = [];
+ let noUrlList = batch.filter(v => !Boolean(v.url))
// 为没有 URL 的文件生成请求队列
- noUrlSelectList.forEach((item) => {
- queue.push(this.getFileUrlByOnce(item.driveId, item.fileId)
- .then(val => {
- processed++;
- doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
- return val;
- }));
- });
-
- hasUrlSelectList.forEach((item) => {
- processed++;
- doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
- });
+ let queue = [];
+ noUrlList.forEach( (item, index) => {
+ queue.push(this.getFileUrlByOnce(item.drive_id, item.file_id));//浏览器千万别在这附近下断点，不然直接过不去，卡在这的。
+ }
+ );
// 等待本批次的请求结果
- const res = await Promise.all(queue);
- res.forEach((val, index) => {
- noUrlSelectList[index].url = val;
- });
+ let res = await Promise.all(queue);
+ res.forEach( (val, index) => {
+ noUrlList[index].url = val;
+ }
+ );
- // 每次处理完一个批次后，等待 1 秒
- await base.sleep(1000);
+ // 每次处理完一个批次后，等待
+ if (i + batchSize < fileList.length){
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${i} / ${fileList.length} 个链接,请耐心等待哦~
休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ };
+
+ //累加批次
+ i += batchSize;
+ batchSize = 15+Math.ceil(Math.random()*5)
}
} else {
return message.error('提示：
页面错误~');
}
- let html = this.generateDom(selectList);
- base.showMainDialog(config.base.dom.button[mode].title, html, config.base.dom.button[mode].footer);
+ //显示下载GUI
+ if (fileList.length) {
+ let html = this.generateDom(fileList);
+ base.showMainDialog(config.base.dom.button[mode].title, html, config.base.dom.button[mode].footer);
+ } else {
+ return message.error('提示：
获取下载链接失败，刷新网页后再试试吧~');
+ }
},
generateDom(list) {
@@ -4550,6 +4909,7 @@
let did = v.driveId;
let size = base.sizeFormat(v.size);
let dlink = v.downloadUrl || v.url;
+ let dpath=v.path;
if (!dlink || !dlink.includes("http")) {
content += `
${filename}
@@ -4559,9 +4919,9 @@
if (mode === 'api') {
alinkAllText += dlink + '\r\n';
content += `
-
${filename}
-
增强下载(基于浏览器文件流)
-
直接下载(基于浏览器链接)
+
${filename}
+
增强下载(基于浏览器文件流)
+
直接下载(基于浏览器链接)
复制名称
复制链接
返回
@@ -4578,24 +4938,35 @@
`;
}
if (mode === 'aria') {
- let alink = base.convertLinkToAria(dlink, filename, `--header "Referer: https://${location.host}/"`);
+ let alink = base.convertLinkToAria(dlink, filename, dpath, `--header "Referer: https://${location.host}/"`);
alinkAllText += alink + '\r\n';
content += `
`;
- }
+ }
if (mode === 'rpc') {
+ dlink=dlink.replace(' ', '%20')
content += `
-
${filename}
-
将 ${filename} 推送到 RPC 下载器
-
`;
+
${filename}
+
+
+
+
+
+ 将 ${filename} 推送到 RPC 下载器
+
+
`;
}
if (mode === 'curl') {
- let alink = base.convertLinkToCurl(dlink, filename, `&refer=${encodeURIComponent(`https://${location.host}/`)}`);
+ let alink = base.convertLinkToCurl(dlink, filename, dpath, `&refer=${encodeURIComponent(`https://${location.host}/`)}`);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -4603,7 +4974,7 @@
let alink = base.convertLinkToBC(dlink, filename, `-e "https://${location.host}/"`);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -4691,8 +5062,13 @@
* 中国移动云盘 / 和彩云
* @author 油小猴
* @author hmjz100
+ * @author KanouAo
*/
let $mcloud = {
+ cnt:0,//计数器，用于控制随机延迟
+ fileCount:0,//文件计数
+ authorization:"",//cookies
+
addPageListener() {
/*
防止代码因其他原因被执行多次
@@ -4748,11 +5124,12 @@
const $width = o.item.find('.pl-progress-inner');
const $text = o.item.find('.pl-progress-inner-text');
const filename = o.link[0].dataset.filename;
+ const path=o.link[0].dataset.path;
const index = o.link[0].dataset.index;
const size = Number(o.link[0].dataset.size) || 0;
base._resetData(index);
- base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index });
+ base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index, path});
let startTime = Date.now();
let prevLoaded = 0;
@@ -4836,7 +5213,10 @@
o.stop.hide();
o.back.hide();
});
- doc.on('click', '.listener-download-all', function (e) {
+ doc.on('click', '.listener-download-all',async function (e) {
+ if(navigator.userAgent.match(/Chrom(e|ium)/)){//Chromium内核
+ globalDirHandle = await window.showDirectoryPicker();
+ }
$('.pl-item-link.blob').each(function () {
if ($(this).css('display') !== 'none') {
$(this).click();
@@ -4862,7 +5242,7 @@
target.find('.pl-loading').remove();
target.prepend(base.createLoading());
- let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename);
+ let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename,e.currentTarget.dataset.path);
if (res === 'success') {
$('.listener-rpc-task').show();
target.removeClass('pl-btn-danger').html('发送成功了!快去看看吧~').animate({ opacity: '0.5' }, "slow");
@@ -4995,6 +5375,61 @@
return md5(A + l).toUpperCase();
},
+ async getFilesByOnce(item,params){
+ try {
+ let res;
+ if(page=="home"){
+ let body = {
+ "pageInfo": {
+ "pageSize": 100,
+ "pageCursor": params.pageCursor,
+ },
+ "orderBy": "updated_at",
+ "orderDirection": "DESC",
+ "parentFileId": item.fileId,
+ "imageThumbnailStyleList": [
+ "Small",
+ "Large"
+ ]
+ };
+ let time = new Date(+new Date() + 8 * 3600 * 1000).toJSON().substr(0, 19).replace('T', ' ');
+ let key = this.getRandomString(16);
+ let sign = this.getSign(undefined, body, time, key);
+ res = await base.post(config.$mcloud.api.getFiles.home, body, {
+ 'Authorization': this.authorization,
+ 'Caller': 'web',
+ 'CMS-DEVICE': 'default',
+ 'Content-Type': "application/json;charset=UTF-8",
+ 'mcloud-channel': '1000101',
+ 'mcloud-client': '10701',
+ 'mcloud-sign': time + "," + key + "," + sign,
+ 'mcloud-version': '7.14.2',
+ 'Origin': 'https://yun.139.com',
+ 'Referer': 'https://yun.139.com/',
+ 'X-DeviceInfo': '||9|7.14.2|chrome|119.0.0.0|||windows 10||zh-CN|||',
+ 'X-Huawei-ChannelSrc': '10000034',
+ 'X-Inner-Ntwk': '2',
+ 'X-M4C-Caller': 'PC',
+ 'X-M4C-Src': '10002',
+ 'X-SvcType': '1',
+ 'X-Yun-Api-Version': 'v1',
+ 'X-Yun-App-Channel': '10000034',
+ 'X-Yun-Channel-Source': '10000034',
+ 'X-Yun-Client-Info': '||9|7.14.2|chrome|119.0.0.0|||windows 10||zh-CN|||||',
+ 'X-Yun-Module-Type': '100',
+ 'X-Yun-Svc-Type': '1'
+ }
+ );
+ }else if(page=="share"){
+ }else{
+ return message.error(`提示：
网站页面错误`);
+ }
+ return res;
+ } catch (e) {
+ return message.error(`提示：
文件获取请求失败`);
+ }
+ },
+
async getFileUrlByOnce(item, index) {
try {
if (item.downloadUrl) return {
@@ -5004,13 +5439,13 @@
if (this.detectPage() === 'home') {
let body = {
- fileId: item.contentID
+ fileId: item.fileId
}
let time = new Date(+new Date() + 8 * 3600 * 1000).toJSON().substr(0, 19).replace('T', ' ');
let key = this.getRandomString(16);
let sign = this.getSign(undefined, body, time, key);
- let res = await base.post(config.$mcloud.api.getLink, body, {
+ let res = await base.post(config.$mcloud.api.getLink.home, body, {
'Authorization': base.getCookie('authorization'),
'Caller': 'web',
'CMS-DEVICE': 'default',
@@ -5071,6 +5506,64 @@
};
}
},
+
+ async fetchAllPages(file) {
+ //分页获取文件夹内文件数据
+ let files=[];//文件数据列表
+ let nextPageCursor='';//文件夹内下一段数据的令牌
+ let res;
+ while (true) {
+ //随机停顿防反爬
+ this.cnt++;
+ if (this.cnt >= 50+Math.random()*10) {
+ doc.find('.loading-popup .swal2-html-container').html(`
正遍历到的大型文件夹（非全部）已获取 ${files.length} 个文件~
休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ this.cnt = 0;
+ }
+
+ //发送请求
+ let params={"parent_file_id":file.fileId,"pageCursor":nextPageCursor};
+ res=await this.getFilesByOnce(file,params);
+
+ //请求失败
+ if(!res.success){//注意变量名
+ return message.error(`提示：
请求失败，失败码： ${res?.code} 失败信息：${res.message}`);
+ }
+
+ //请求成功
+ files=files.concat(res.data.items)//注意变量名
+ nextPageCursor=res.data.nextPageCursor;
+ if (!nextPageCursor)
+ break;
+ }
+ return files;
+ },
+
+ async fetchFiles(file,pNode) {
+ //获取文件目录结构（递归）
+ //节点
+ let fileNode={
+ name:file.name,//注意变量名
+ path:pNode.name === 'root' ? `` : (pNode.path === '' ? pNode.name : `${pNode.path}/${pNode.name}`),//一般来说，路径不要特别特别长，不然可能会出问题，不过正常是不会的
+ children:[]
+ }
+ pNode.children.push(fileNode);
+ file.path=fileNode.path;
+
+ //判断是否文件夹
+ if (file?.type!="folder") {//注意变量名
+ this.fileCount++;
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${this.fileCount} 个文件~
`);
+ return file;
+ }
+
+ //文件夹内文件遍历
+ let files=[];
+ for (let f of await this.fetchAllPages(file)) {
+ files= files.concat(await this.fetchFiles(f,fileNode));
+ }
+ return files;
+ },
async getLink() {
Swal.fire({
@@ -5098,42 +5591,69 @@
if (selectList.length === 0) {
return message.error('提示：
请勾选要下载的文件哦~');
}
- if (this.isOnlyFolder()) {
- return message.error('提示：
请打开文件夹后再勾选文件~');
- }
+ this.cnt=0;
+ this.fileCount=0;//文件计数
+ this.authorization = base.getCookie('authorization');
+ let fileList=[];//文件列表，只有文件没有文件夹
+ let fileTree = { name: "root", path: ``, children: [] }; // 文件目录树
if (page === 'home') {
- selectList = selectList.filter(item => item.contentID && item.contentName && item.contentSuffix);
- let batchSize = 15;
- let processed = 0;
+ //获取文件目录结构（递归）
+ for (let file of selectList) {
+ //遍历选中文件
+ //统一变量名
+ file.name=file.name||file.catalogName;
+ file.fileId=file.fileId||file.catalogID;
+ if(file.catalogID)file.type="folder";
+ fileList = fileList.concat(await this.fetchFiles(file,fileTree));
+ }
+
+ //文件夹为空
+ if (!fileList.length) {
+ return message.error('提示：
文件夹是空的哦~');
+ }
+
+ //获取下载链接
doc.find('.loading-popup .loading-title').html(`链接获取中`);
doc.find('.loading-popup .swal2-html-container').html(`
正在获取文件对应的下载链接~
`);
- for (let i = 0; i < selectList.length; i += batchSize) {
- let batch = selectList.slice(i, i + batchSize);
- let queue = [];
+ let batchSize = 15+Math.ceil(Math.random()*5);
+ let i=0;
+ while (i < fileList.length){
+ // 分批获取链接
+ let batch = fileList.slice(i, i + batchSize);
+ // 生成请求队列
+ let queue = [];
batch.forEach((item, localIndex) => {
let globalIndex = i + localIndex;
queue.push(this.getFileUrlByOnce(item, globalIndex)
.then(val => {
- processed++;
- doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
return val;
}));
});
+ // 等待本批次的请求结果
let res = await Promise.all(queue);
res.forEach(val => {
- selectList[val.index].downloadUrl = val.downloadUrl;
+ fileList[val.index].downloadUrl = val.downloadUrl;
});
- await base.sleep(1000);
+ // 每次处理完一个批次后，等待
+ if (i + batchSize < fileList.length){
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${i} / ${fileList.length} 个链接,请耐心等待哦~
休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ };
+
+ //累加批次
+ i += batchSize;
+ batchSize = 15+Math.ceil(Math.random()*5)
}
} else {
return message.error('提示：
页面错误~');
}
- let html = this.generateDom(selectList);
+ //显示下载GUI
+ let html = this.generateDom(fileList);
base.showMainDialog(config.base.dom.button[mode].title, html, config.base.dom.button[mode].footer);
},
@@ -5145,9 +5665,10 @@
let alinkAllText = '';
list.forEach((v, i) => {
if (v.dirEtag || v.caName) return;
- let filename = v.contentName || v.coName;
- let size = base.sizeFormat(v.contentSize || v.coSize);
+ let filename = v.contentName || v.coName||v.name;
+ let size = base.sizeFormat(v.contentSize || v.coSize||v.size);
let dlink = v.downloadUrl;
+ let dpath=v.path;
if (!dlink || !dlink.includes("http")) {
content += `
${filename}
@@ -5157,8 +5678,8 @@
if (mode === 'api') {
alinkAllText += dlink + '\r\n';
content += `
-
${filename}
-
增强下载(基于浏览器文件流)
+
${filename}
+
增强下载(基于浏览器文件流)
直接下载(基于浏览器链接)
复制链接
@@ -5174,24 +5695,34 @@
`;
}
if (mode === 'aria') {
- let alink = base.convertLinkToAria(dlink, filename);
+ let alink = base.convertLinkToAria(dlink, filename, dpath);
alinkAllText += alink + '\r\n';
content += `
`;
}
if (mode === 'rpc') {
content += `
-
${filename}
-
将 ${filename} 推送到 RPC 下载器
-
`;
+
${filename}
+
+
+
+
+
+ 将 ${filename} 推送到 RPC 下载器
+
+
`;
}
if (mode === 'curl') {
- let alink = base.convertLinkToCurl(dlink, filename);
+ let alink = base.convertLinkToCurl(dlink, filename, dpath);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -5199,7 +5730,7 @@
let alink = base.convertLinkToBC(dlink, filename);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -5285,8 +5816,15 @@
* 天翼云盘
* @author 油小猴
* @author hmjz100
+ * @author KanouAo
*/
let $tcloud = {
+ cnt:0,//计数器，用于控制随机延迟
+ fileCount:0,//文件计数
+ shareId:0,//分享id
+ accessCode:"",//访问码
+
+
addPageListener() {
/*
防止代码因其他原因被执行多次
@@ -5329,11 +5867,12 @@
const $width = o.item.find('.pl-progress-inner');
const $text = o.item.find('.pl-progress-inner-text');
const filename = o.link[0].dataset.filename;
+ const path=o.link[0].dataset.path;
const index = o.link[0].dataset.index;
const size = Number(o.link[0].dataset.size) || 0;
base._resetData(index);
- base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index });
+ base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index, path});
let startTime = Date.now();
let prevLoaded = 0;
@@ -5417,7 +5956,10 @@
o.stop.hide();
o.back.hide();
});
- doc.on('click', '.listener-download-all', function (e) {
+ doc.on('click', '.listener-download-all',async function (e) {
+ if(navigator.userAgent.match(/Chrom(e|ium)/)){//Chromium内核
+ globalDirHandle = await window.showDirectoryPicker();
+ }
$('.pl-item-link.blob').each(function () {
if ($(this).css('display') !== 'none') {
$(this).click();
@@ -5443,7 +5985,7 @@
target.find('.pl-loading').remove();
target.prepend(base.createLoading());
- let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename);
+ let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename,e.currentTarget.dataset.path);
if (res === 'success') {
$('.listener-rpc-task').show();
target.removeClass('pl-btn-danger').html('发送成功了!快去看看吧~').animate({ opacity: '0.5' }, "slow");
@@ -5529,48 +6071,79 @@
return accessToken;
},
+ async getFilesByOnce(item,params){
+ let res;
+ try {
+ if(page=="home"){
+ //TODO 我调试过程中res出现过check ip error - curIp=2409::xxxx:xxxx:xxxx:xxxx:xxxx:xxxx, cookiesIp=120.xxx.xxx.xxx，不知是不是抓IP注意下
+ let url = `${config.$tcloud.api.getFiles.home}?noCache=${Math.random()}&pageSize=${60}&pageNum=${params.pageNum}&mediaType=0&folderId=${params.id}&iconOption=5&orderBy=lastOpTime&descending=true`;
+ res= await base.get(url, {
+ "accept": "application/json;charset=UTF-8",
+ "sign-type": 1,
+ "accept-encoding": "gzip, deflate, br, zstd",
+ "accept-language": "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6",
+ "priority":"u=1, i",
+ });
+ }else if(page=="share"){//别从自己盘进自己的分享，不然都拿不到自己的密钥（不过也没有这么怪的用户吧……）
+ let url = `${config.$tcloud.api.getFiles.share}?noCache=${Math.random()}&pageSize=${60}&pageNum=${params.pageNum}&fileId=${params.id}&shareDirFileId=${params.id}&isFolder=true&shareId=${this.shareId}&shareMode=1&iconOption=5&orderBy=lastOpTime&descending=true&accessCode=${this.accessCode}`;
+ res=await base.get(url, {
+ "accept": "application/json;charset=UTF-8",
+ "sign-type": 1,
+ });
+ }else{
+ return message.error(`提示：
网站页面错误`);
+ }
+ return res;
+ } catch (e) {
+ return message.error(`提示：
文件获取请求失败`);
+ }
+ },
+
async getFileUrlByOnce(item, index, token) {
try {
- if (item.downloadUrl) return {
- index,
- downloadUrl: item.downloadUrl
- };
- let time = Date.now(),
- fileId = item.fileId,
- o = "AccessToken=" + token + "&Timestamp=" + time + "&fileId=" + fileId,
- url = config.$tcloud.api.getLink + '?fileId=' + fileId;
- if (item.shareId) {
- o = "AccessToken=" + token + "&Timestamp=" + time + "&dt=1&fileId=" + fileId + "&shareId=" + item.shareId;
- url += '&dt=1&shareId=' + item.shareId;
- }
- let sign = md5(o).toString();
- let res = await base.get(url, {
- "accept": "application/json;charset=UTF-8",
- "sign-type": 1,
- "accesstoken": token,
- "timestamp": time,
- "signature": sign
- });
- if (res.res_code === 0) {
- return {
- index,
- downloadUrl: res.fileDownloadUrl
- };
- } else if (res.errorCode === 'InvalidSessionKey') {
- return {
- index,
- downloadUrl: '提示：
请先登录网盘~'
- };
- } else if (res.res_code === 'ShareNotFoundFlatDir') {
- return {
- index,
- downloadUrl: '提示：
请[转存]文件，之后再👉前往[我的网盘]中下载哦~'
- };
- } else {
- return {
+ let res;
+ if(page=="home"){
+ if (item.downloadUrl) return {
index,
- downloadUrl: '获取下载地址失败，刷新后再试试吧~' + (res.res_code ? res.res_code : "")
+ downloadUrl: item.downloadUrl
};
+ let time = Date.now(),
+ fileId = item.id,
+ o = "AccessToken=" + token + "&Timestamp=" + time + "&fileId=" + fileId,
+ url = config.$tcloud.api.getLink.home + '?fileId=' + fileId;
+ if (this.shareId) {
+ o = "AccessToken=" + token + "&Timestamp=" + time + "&dt=1&fileId=" + fileId + "&shareId=" + this.shareId;
+ url += '&dt=1&shareId=' + this.shareId;
+ }
+ let sign = md5(o).toString();
+ res = await base.get(url, {
+ "accept": "application/json;charset=UTF-8",
+ "sign-type": 1,
+ "accesstoken": token,
+ "timestamp": time,
+ "signature": sign
+ });
+ if (res.res_code === 0) {
+ return {
+ index,
+ downloadUrl: res.fileDownloadUrl
+ };
+ } else if (res.errorCode === 'InvalidSessionKey') {
+ return {
+ index,
+ downloadUrl: '提示：
请先登录网盘~'
+ };
+ } else if (res.res_code === 'ShareNotFoundFlatDir') {
+ return {
+ index,
+ downloadUrl: '提示：
请[转存]文件，之后再👉前往[我的网盘]中下载哦~'
+ };
+ } else {
+ return {
+ index,
+ downloadUrl: '获取下载地址失败，刷新后再试试吧~' + (res.res_code ? res.res_code : "")
+ };
+ }
}
} catch (e) {
return {
@@ -5579,6 +6152,63 @@
};
}
},
+
+ async fetchAllPages(file) {
+ //分页获取文件夹内文件数据
+ let res;
+ let files=[];//文件数据列表
+ let folders=[];//文件夹数据列表
+ let path = file.path ? `${file.path}/${file.name}` : file.name;
+ // let pageCount=Math.ceil(file.fileCount/60);//总页数
+ let pageCount=1;//总页数，先设1，之后根据res返回的值修改//share没有file.fileCount，兼容适配
+ for (let pageNum=1;pageNum<=pageCount;pageNum++) {
+ //随机停顿防反爬
+ this.cnt++;
+ if (this.cnt >= 50+Math.random()*10) {
+ doc.find('#loadingText').html(`
文件获取中
已获取 ${this.fileCount} 个文件，请耐心等待哦~
>休息 ${globalSleep} 毫秒...
`);
+ await base.sleep(globalSleep+Math.random()*globalSleepRandSeed);
+ this.cnt = 0;
+ }
+ //发送请求
+ let param={"pageNum":pageNum,"id":file.id};
+ res=await this.getFilesByOnce(file,param);
+
+ //请求失败
+ if(!(res?.res_code==0&&res?.res_message=="成功")){
+ return message.error(`提示：
请求失败，失败码： ${res?.res_code} 失败信息：${res.res_message}`);
+ }
+ //请求成功
+ if(pageCount==1)pageCount=Math.ceil(res.fileListAO.count/60);
+ files=files.concat(res.fileListAO.fileList);//注意别占用fileList的变量名字
+ folders=folders.concat(res.fileListAO.folderList);
+ this.fileCount+=res.fileListAO.fileList.length;
+ files.forEach(f => {f.path=path;});
+ }
+ return {files,folders};
+ },
+
+ async fetchFiles(file,pNode) {
+ //获取文件目录结构（递归）
+ //节点 这的节点树因为不怎么需要就没做完整
+ let fileNode={
+ name:file.name,//注意变量名
+ path:pNode.name === 'root' ? `` : (pNode.path === '' ? pNode.name : `${pNode.path}/${pNode.name}`),//一般来说，路径不要特别特别长，不然可能会出问题，不过正常是不会的
+ children:[]
+ }
+ pNode.children.push(fileNode);
+ file.path=fileNode.path;
+
+ //判断是否文件夹
+ //这个不用判断是否文件夹，返回的数据已经分开了
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${this.fileCount} 个文件~
`);
+
+ //文件夹内文件遍历
+ let { files, folders }=await this.fetchAllPages(file);
+ for (let f of folders) {
+ files= files.concat(await this.fetchFiles(f,fileNode));
+ }
+ return files;
+ },
async getLink() {
Swal.fire({
@@ -5606,10 +6236,47 @@
if (selectList.length === 0) {
return message.error('提示：
请勾选要下载的文件哦~');
}
- if (this.isOnlyFolder()) {
- return message.error('提示：
请打开文件夹后再勾选文件~');
+
+ if(page=="home"){
+ this.shareId=0;
+ this.accessCode="";
+ }else if(page=="share"){
+ //分享页面所需的变量
+ this.shareId=selectList[0].shareId;//分享内容的id
+ let share_link=location.search.substring(6);//分享的链接，地址带上访问码也可比如code=MFNRJ3bAfe6r（访问码：9lik）也太怪了吧？
+ const percentIndex = share_link.indexOf('%');
+ if (percentIndex !== -1) share_link = share_link.substring(0, percentIndex);
+ this.accessCode=base.getCookie(`share_${share_link}`);//访问密钥，在cookie里有，但不同的分享的密钥都堆一起了
+ }else{
+ return message.error('提示：
页面错误~');
}
- selectList = selectList.filter(item => !item.isFolder)
+
+ this.cnt=0;
+ this.fileCount=0;//文件计数
+ let fileList=[];//文件列表，只有文件没有文件夹
+ let fileTree = { name: "root", path: ``, children: [] }; // 文件目录树
+ //获取文件目录结构（递归）
+ for (let file of selectList) {
+ //遍历选中文件
+ //统一变量名
+ file.name=file.name||file.fileName;
+ file.id=file.id||file.fileId;
+ file.size=file.size||file.fileSize;
+ if(!file?.isFolder){//非文件夹
+ fileList = fileList.concat(file);
+ this.fileCount++;
+ continue;
+ }
+ file.fileCount=file.fileData;
+ fileList = fileList.concat(await this.fetchFiles(file,fileTree));
+ }
+
+ //文件夹为空
+ if (!fileList.length) {
+ return message.error('提示：
文件夹是空的哦~');
+ }
+
+ //获取下载链接
doc.find('.loading-popup .loading-title').html(`令牌获取中`);
doc.find('.loading-popup .swal2-html-container').html(`
正在获取状态~
`);
let token = base.getStorage('accessToken') || await this.getToken();
@@ -5618,34 +6285,42 @@
}
doc.find('.loading-popup .loading-title').html(`令牌获取中`);
doc.find('.loading-popup .swal2-html-container').html(`
获取缓存成功~
`);
-
- let batchSize = 15;
- let processed = 0;
doc.find('.loading-popup .loading-title').html(`链接获取中`);
doc.find('.loading-popup .swal2-html-container').html(`
正在获取文件对应的下载链接~
`);
- for (let i = 0; i < selectList.length; i += batchSize) {
- let batch = selectList.slice(i, i + batchSize);
- let queue = [];
+ let batchSize = globalBatchsize+Math.ceil(Math.random()*5);
+ let i=0;
+ while (i < fileList.length){
+ // 分批获取链接
+ let batch = fileList.slice(i, i + batchSize);
+ // 生成请求队列
+ let queue = [];
batch.forEach((item, localIndex) => {
let globalIndex = i + localIndex;
queue.push(this.getFileUrlByOnce(item, globalIndex, token)
.then(val => {
- processed++;
- doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
return val;
}));
});
+ // 等待本批次的请求结果
let res = await Promise.all(queue);
res.forEach(val => {
- selectList[val.index].downloadUrl = val.downloadUrl;
+ fileList[val.index].downloadUrl = val.downloadUrl;
});
- await base.sleep(1000);
- }
+ // 每次处理完一个批次后，等待
+ if (i + batchSize < fileList.length){
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${i+batch.length} / ${fileList.length} 个链接,请耐心等待哦~
休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ };
+
+ //累加批次
+ i += batchSize;
+ batchSize = globalBatchsize+Math.ceil(Math.random()*5)
+ }
- let html = this.generateDom(selectList);
+ let html = this.generateDom(fileList);
base.showMainDialog(config.base.dom.button[mode].title, html, config.base.dom.button[mode].footer);
},
@@ -5657,10 +6332,11 @@
let content = '
';
let alinkAllText = '';
list.forEach((v, i) => {
- if (v.isFolder) return;
- let filename = v.fileName;
+ if (v?.isFolder) return;
+ let filename = v.name;
let size = base.sizeFormat(v.size);
let dlink = v.downloadUrl;
+ let dpath=v.path;
if (!dlink || !dlink.includes("http")) {
content += `
${filename}
@@ -5670,8 +6346,8 @@
if (mode === 'api') {
alinkAllText += dlink + '\r\n';
content += `
-
${filename}
-
增强下载(基于浏览器文件流)
+
${filename}
+
增强下载(基于浏览器文件流)
直接下载(基于浏览器链接)
复制链接
@@ -5687,24 +6363,34 @@
`;
}
if (mode === 'aria') {
- let alink = base.convertLinkToAria(dlink, filename);
+ let alink = base.convertLinkToAria(dlink, filename, dpath);
alinkAllText += alink + '\r\n';
content += `
`;
}
if (mode === 'rpc') {
content += `
-
${filename}
-
将 ${filename} 推送到 RPC 下载器
-
`;
+
${filename}
+
+
+
+
+
+ 将 ${filename} 推送到 RPC 下载器
+
+
`;
}
if (mode === 'curl') {
- let alink = base.convertLinkToCurl(dlink, filename);
+ let alink = base.convertLinkToCurl(dlink, filename, dpath);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -5712,7 +6398,7 @@
let alink = base.convertLinkToBC(dlink, filename);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -5788,8 +6474,14 @@
* 迅雷云盘
* @author 油小猴
* @author hmjz100
+ * @author KanouAo
*/
let $xunlei = {
+ cnt:0,//计数器，用于控制随机延迟
+ fileCount:0,//文件计数
+ authorization:"",
+ token:{},
+
addPageListener() {
/*
防止代码因其他原因被执行多次
@@ -5842,11 +6534,12 @@
const $width = o.item.find('.pl-progress-inner');
const $text = o.item.find('.pl-progress-inner-text');
const filename = o.link[0].dataset.filename;
+ const path=o.link[0].dataset.path;
const index = o.link[0].dataset.index;
const size = Number(o.link[0].dataset.size) || 0;
base._resetData(index);
- base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index });
+ base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index, path});
let startTime = Date.now();
let prevLoaded = 0;
@@ -5930,7 +6623,10 @@
o.stop.hide();
o.back.hide();
});
- doc.on('click', '.listener-download-all', function (e) {
+ doc.on('click', '.listener-download-all',async function (e) {
+ if(navigator.userAgent.match(/Chrom(e|ium)/)){//Chromium内核
+ globalDirHandle = await window.showDirectoryPicker();
+ }
$('.pl-item-link.blob').each(function () {
if ($(this).css('display') !== 'none') {
$(this).click();
@@ -5972,7 +6668,7 @@
target.find('.pl-loading').remove();
target.prepend(base.createLoading());
- let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename);
+ let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename,e.currentTarget.dataset.path);
if (res === 'success') {
$('.listener-rpc-task').show();
target.removeClass('pl-btn-danger').html('发送成功了!快去看看吧~').animate({ opacity: '0.5' }, "slow");
@@ -6077,33 +6773,121 @@
return token;
},
+ async getFilesByOnce(item,params){
+ let res;
+ try {
+ if(page=="home"){
+ //limit最多只能获取到200，res返回参数里有个 next_page_token 是令牌，如果是空的就说明不需要下一页
+ //中间奇怪的那段是URL编码的JSON字符串,第1次请求是不带parent_id之前的&的，后面请求是带parent_id前的&的，但都适用
+ let url=`${config.$xunlei.api.getFiles.home}page_token=${params.next_page_token}&parent_id=${params.parent_id}&filters=%7B%22phase%22%3A%7B%22eq%22%3A%22PHASE_TYPE_COMPLETE%22%7D%2C%22trashed%22%3A%7B%22eq%22%3Afalse%7D%7D&with_audit=true&limit=50`;
+ res = await base.get(url, {
+ 'Authorization': this.authorization,
+ 'content-type': "application/json",
+ 'x-captcha-token': this.token.captcha.token,
+ 'x-device-id': this.token.deviceid,
+ });
+ }else if(page=="share"){
+ }else{
+ return message.error(`提示：
网站页面错误`);
+ }
+ return res;
+ } catch (e) {
+ return message.error('提示：
请先登录网盘后再刷新页面呢~');
+ }
+ },
+
async getFileUrlByOnce(item, index, token) {
+ let res;
try {
- if (item.downloadUrl) return {
- index,
- downloadUrl: item.downloadUrl
- };
- let res = await base.get(config.$xunlei.api.getLink + item.id, {
- 'Authorization': `${token.credentials.token_type} ${token.credentials.access_token}`,
- 'content-type': "application/json",
- 'x-captcha-token': token.captcha.token,
- 'x-device-id': token.deviceid,
- });
- if (res.web_content_link) {
- return {
+ if(page=="home"){
+ if (item.downloadUrl) return {
index,
- downloadUrl: res.web_content_link
- };
- } else {
- return {
- index,
- downloadUrl: '获取下载地址失败，刷新后再试试吧~'
+ downloadUrl: item.downloadUrl
};
+ res = await base.get(config.$xunlei.api.getLink.home + item.id, {
+ 'Authorization': `${token.credentials.token_type} ${token.credentials.access_token}`,
+ 'content-type': "application/json",
+ 'x-captcha-token': token.captcha.token,
+ 'x-device-id': token.deviceid,
+ });
+ if (res.web_content_link) {
+ return {
+ index,
+ downloadUrl: res.web_content_link
+ };
+ } else {
+ return {
+ index,
+ downloadUrl: '获取下载地址失败，刷新后再试试吧~'
+ };
+ }
+ }else if(page=="share"){
+ }else{
+ return message.error(`提示：
网站页面错误`);
}
+ return res;
} catch (e) {
return message.error('提示：
请先登录网盘后再刷新页面呢~');
}
},
+
+ async fetchAllPages(file) {
+ //分页获取文件夹内文件数据
+ let files=[];//文件数据列表
+ let next_page_token='';//文件夹内下一段数据的令牌
+ let res;
+ while (true) {
+ //随机停顿防反爬
+ this.cnt++;
+ if (this.cnt >= 50+Math.random()*10) {
+ doc.find('.loading-popup .swal2-html-container').html(`
正遍历到的大型文件夹（非全部）已获取 ${files.length} 个文件~
休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ this.cnt = 0;
+ }
+
+ //发送请求
+ let param={"next_page_token":next_page_token,"parent_id":file.id};
+ res=await this.getFilesByOnce(file,param);
+
+ //请求失败
+ if(!res?.files){//注意变量名
+ return message.error(`提示：
请求失败，失败码： ${res?.code} 失败信息：${res.message}`);
+ }
+
+ //请求成功
+ files=files.concat(res.files)//注意变量名
+ next_page_token=res.next_page_token;
+ if (!next_page_token)
+ break;
+ }
+ return files;
+ },
+
+ async fetchFiles(file,pNode) {
+ //获取文件目录结构（递归）
+ //节点
+ let fileNode={
+ name:file.name,//注意变量名
+ path:pNode.name === 'root' ? `` : (pNode.path === '' ? pNode.name : `${pNode.path}/${pNode.name}`),//一般来说，路径不要特别特别长，不然可能会出问题，不过正常是不会的
+ children:[]
+ }
+ pNode.children.push(fileNode);
+ file.path=fileNode.path;
+
+ //判断是否文件夹
+ if (file?.kind!='drive#folder') {//注意变量名
+ this.fileCount++;
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${this.fileCount} 个文件~
`);
+ return file;
+ }
+
+ //文件夹内文件遍历
+ let files=[];
+ for (let f of await this.fetchAllPages(file)) {
+ files= files.concat(await this.fetchFiles(f,fileNode));
+ }
+ return files;
+ },
async getLink() {
Swal.fire({
@@ -6131,40 +6915,72 @@
if (selectList.length === 0) {
return message.error('提示：
请勾选要下载的文件哦~');
}
- if (this.isOnlyFolder()) {
- return message.error('提示：
请打开文件夹后再勾选文件~');
+
+ if(page=="home"){
+ }else if(page=="share"){
+ //分享页面所需的变量
+ }else{
+ return message.error('提示：
页面错误~');
}
+ this.token = this.getToken();
+ this.authorization = `${this.token.credentials.token_type} ${this.token.credentials.access_token}`;
+
+ this.cnt=0;
+ this.fileCount=0;//文件计数
+ let fileList=[];//文件列表，只有文件没有文件夹
+ let fileTree = { name: "root", path: ``, children: [] }; // 文件目录树
if (page === 'home') {
- let token = this.getToken();
- let batchSize = 15;
- let processed = 0;
+ //获取文件目录结构（递归）
+ for (let file of selectList) {
+ //遍历选中文件
+ //统一变量名
+ fileList = fileList.concat(await this.fetchFiles(file,fileTree));
+ }
+
+ //文件夹为空
+ if (!fileList.length) {
+ return message.error('提示：
文件夹是空的哦~');
+ }
+
+ //获取下载链接
doc.find('.loading-popup .loading-title').html(`链接获取中`);
doc.find('.loading-popup .swal2-html-container').html(`
正在获取文件对应的下载链接~
`);
- for (let i = 0; i < selectList.length; i += batchSize) {
- let batch = selectList.slice(i, i + batchSize);
- let queue = [];
+ let batchSize = globalBatchsize+Math.ceil(Math.random()*5);
+ let i=0;
+ while (i < fileList.length){
+ // 分批获取链接
+ let batch = fileList.slice(i, i + batchSize);
+ // 生成请求队列
+ let queue = [];
batch.forEach((item, localIndex) => {
let globalIndex = i + localIndex;
- queue.push(this.getFileUrlByOnce(item, globalIndex, token)
+ queue.push(this.getFileUrlByOnce(item, globalIndex, this.token)
.then(val => {
- processed++;
- doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
+ // doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
return val;
}));
});
let res = await Promise.all(queue);
res.forEach(val => {
- selectList[val.index].downloadUrl = val.downloadUrl;
+ fileList[val.index].downloadUrl = val.downloadUrl;
});
- await base.sleep(1000);
+ // 每次处理完一个批次后，等待
+ if (i + batchSize < fileList.length){
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${i+batch.length} / ${fileList.length} 个链接,请耐心等待哦~
休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ };
+
+ //累加批次
+ i += batchSize;
+ batchSize = globalBatchsize+Math.ceil(Math.random()*5)
}
} else {
return message.error('提示：
页面错误~');
}
- let html = this.generateDom(selectList);
+ let html = this.generateDom(fileList);
base.showMainDialog(config.base.dom.button[mode].title, html, config.base.dom.button[mode].footer);
},
@@ -6180,6 +6996,7 @@
let filename = v.name;
let size = base.sizeFormat(+v.size);
let dlink = v.downloadUrl;
+ let dpath=v.path;
if (!dlink || !dlink.includes("http")) {
content += `
${filename}
@@ -6189,8 +7006,8 @@
if (mode === 'api') {
alinkAllText += dlink + '\r\n';
content += `
-
${filename}
-
增强下载(基于浏览器文件流)
+
${filename}
+
增强下载(基于浏览器文件流)
直接下载(基于浏览器链接)
复制名称
复制链接
@@ -6207,24 +7024,34 @@
`;
}
if (mode === 'aria') {
- let alink = base.convertLinkToAria(dlink, filename);
+ let alink = base.convertLinkToAria(dlink, filename, dpath);
alinkAllText += alink + '\r\n';
content += `
`;
}
if (mode === 'rpc') {
content += `
-
${filename}
-
将 ${filename} 推送到 RPC 下载器
-
`;
+
${filename}
+
+
+
+
+
+ 将 ${filename} 推送到 RPC 下载器
+
+
`;
}
if (mode === 'curl') {
- let alink = base.convertLinkToCurl(dlink, filename);
+ let alink = base.convertLinkToCurl(dlink, filename, dpath);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -6232,7 +7059,7 @@
let alink = base.convertLinkToBC(dlink, filename);
alinkAllText += alink + '\r\n';
content += `
`;
@@ -6316,8 +7143,12 @@
* 夸克网盘
* @author 油小猴
* @author hmjz100
+ * @author KanouAo
*/
let $quark = {
+ cnt:0,//计数器，用于控制随机延迟
+ fileCount:0,//文件计数
+
addPageListener() {
/*
防止代码因其他原因被执行多次
@@ -6389,11 +7220,12 @@
const $width = o.item.find('.pl-progress-inner');
const $text = o.item.find('.pl-progress-inner-text');
const filename = o.link[0].dataset.filename;
+ const path=o.link[0].dataset.path;
const index = o.link[0].dataset.index;
const size = Number(o.link[0].dataset.size) || 0;
base._resetData(index);
- base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index });
+ base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index, path});
let startTime = Date.now();
let prevLoaded = 0;
@@ -6477,7 +7309,10 @@
o.stop.hide();
o.back.hide();
});
- doc.on('click', '.listener-download-all', function (e) {
+ doc.on('click', '.listener-download-all',async function (e) {
+ if(navigator.userAgent.match(/Chrom(e|ium)/)){//Chromium内核
+ globalDirHandle = await window.showDirectoryPicker();
+ }
$('.pl-item-link.blob').each(function () {
if ($(this).css('display') !== 'none') {
$(this).click();
@@ -6503,7 +7338,7 @@
target.find('.pl-loading').remove();
target.prepend(base.createLoading());
- let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename, [`Cookie: ${document.cookie}`]);
+ let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename,e.currentTarget.dataset.path, [`Cookie: ${document.cookie}`]);
if (res === 'success') {
$('.listener-rpc-task').show();
target.removeClass('pl-btn-danger').html('发送成功了!快去看看吧~').animate({ opacity: '0.5' }, "slow");
@@ -6629,6 +7464,91 @@
})
},
+ async getFilesByOnce(item,params){
+ try {
+ let res;
+ if(page=="home"){
+ let url=`${config.$quark.api.getFiles.home}&uc_param_str=&pdir_fid=${item.fid}&_page=${params.pageNum}&_size=50&_fetch_total=1&_fetch_sub_dirs=0&_sort=file_type:asc,file_name:asc`;
+ res = await base.get(url, { "User-Agent": config.$quark.api.ua.downloadLink });
+ }else if(page=="share"){
+ }else{
+ return message.error(`提示：
网站页面错误`);
+ }
+ return res;
+ } catch (e) {
+ return message.error(`提示：
文件获取请求失败`);
+ }
+ },
+
+ async getFileUrlByOnce(item, params) {
+ try {
+ let res;
+ if(page=="home"){
+ res = await base.post(config.$quark.api.getLink.home, { "fids": params.fids }, { "content-type": "application/json;charset=utf-8", "user-agent": config.$quark.api.ua.downloadLink });
+ }else if(page=="share"){
+ }else{
+ return message.error(`提示：
网站页面错误`);
+ }
+ return res;
+ } catch (e) {
+ return message.error(`提示：
文件下载链接请求失败`);
+ }
+ },
+
+ async fetchAllPages(file) {
+ //分页获取文件夹内文件数据
+ let files=[];//文件数据列表
+ let pageCount=Math.ceil(file.include_items/50);//总页数
+ for (let pageNum=1;pageNum<=pageCount;pageNum++) {
+ //随机停顿防反爬
+ this.cnt++;
+ if (this.cnt >= 50+Math.random()*10) {
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${this.fileCount} 个文件~
休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ this.cnt = 0;
+ }
+ //发送请求
+ let param={"page":pageNum};
+ let res=await this.getFilesByOnce(file,param);
+ //请求失败
+ if (res.code === 31001) {//TODO 可能是这样，没测试，可能要等很久账号掉了，我没时间等
+ return message.error('提示：
请先登录网盘~
代码：' + res.code);
+ }
+ if (res.code !== 0) {
+ return message.error('提示：
获取链接失败了~
代码：' + res.code);
+ }
+ //请求成功
+ files=files.concat(res.data.list)
+ }
+ return files;
+ },
+
+ async fetchFiles(file,pNode) {
+ //获取文件目录结构（递归）
+ //节点
+ let fileNode={
+ name:file.file_name,
+ path:pNode.name === 'root' ? `` : (pNode.path === '' ? pNode.name : `${pNode.path}/${pNode.name}`),//一般来说，路径不要特别特别长，不然可能会出问题，不过正常是不会的
+ children:[]
+ }
+ pNode.children.push(fileNode)
+ file.path=fileNode.path;
+
+ //判断是否文件夹
+ if (!file?.dir) {
+ this.fileCount++;
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${this.fileCount} 个文件~
`);
+ return file;
+ }
+
+ //文件夹内文件遍历
+ let files=[];
+ for (let f of await this.fetchAllPages(file)) {
+ files= files.concat(await this.fetchFiles(f,fileNode));
+ }
+ return files;
+ },
+
async getLink() {
Swal.fire({
showConfirmButton: false,
@@ -6655,46 +7575,53 @@
if (selectList.length === 0) {
return message.error('提示：
请勾选要下载的文件哦~');
}
- if (this.isOnlyFolder()) {
- return message.error('提示：
请打开文件夹后再勾选文件~');
- }
- if (page === 'home') {
- let data = [];
- let batchSize = 15;
- let processed = 0;
- selectList = selectList.filter(item => item.file === true)
-
- for (let i = 0; i < selectList.length; i += batchSize) {
- // 获取当前批次文件
- let batch = selectList.slice(i, i + batchSize);
- console.log()
- let fids = batch.map(item => item.fid);
-
- // 发起请求获取链接
- let res = await base.post(config.$quark.api.getLink, { "fids": fids }, { "content-type": "application/json;charset=utf-8", "user-agent": config.$quark.api.ua.downloadLink });
-
- if (res?.code === 31001) {
- return message.error('提示：
请先登录网盘~
代码：' + res.code);
- }
- if (res?.code !== 0) {
- return message.error('提示：
获取链接失败了~
代码：' + res.code);
- }
- // 合并响应数据
- if (res?.data) {
- data.push(...res.data);
- }
+ if(page=="home"){
+ }else if(page=="share"){
+ //分享页面所需的变量
+ }else{
+ return message.error('提示：
页面错误~');
+ }
+
+ this.cnt=0; //计数器，用于控制随机延迟
+ this.fileCount=0;//文件计数
+ let fileList=[];//文件列表，只有文件没有文件夹
+ let fileTree = { name: "root", path: ``, children: [] }; // 文件目录树
- // 更新处理进度
- processed += batch.length;
+ if (page === 'home') {
+ //获取文件目录结构（递归）
+ for (let file of selectList) {
+ //遍历选中文件
+ //统一变量名
+ fileList = fileList.concat(await this.fetchFiles(file,fileTree));
+ }
- // 更新UI显示
- doc.find('.loading-popup .loading-title').html(`链接获取中`);
- doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
+ //文件夹为空
+ if (!fileList.length) {
+ return message.error('提示：
文件夹是空的哦~');
+ }
- // 请求间隔节流
- await base.sleep(1000);
+ //获取下载链接
+ //TODO 我认为连续访问网盘的接口不如直接拿全部ID合适，post协议本身不作数据长度上限，即使后台限制为1M，也有65536个文件ID了，你如果觉得不合适可以修改
+ let fids = fileList.map(item => item.fid);
+ let params={"fids":fids};
+ let res = await this.getFileUrlByOnce(undefined,params);
+ if (res.code === 31001) {
+ return message.error('提示：
请先登录网盘~
代码：' + res.code);
}
+ if (res.code !== 0) {
+ return message.error('提示：
获取链接失败了~
代码：' + res.code);
+ }
+ if (res.data.length!=fids.length)
+ return message.error('提示：
获取下载链接数目不对，请重新尝试，若文件数目太多，如好几万个文件，请联系作者修改
');
+
+ //显示下载GUI
+ let data = res.data.map((element, index) => {
+ return {
+ ...element,
+ path: fileList[index].path//TODO 请求的ID和返回的ID的列表顺序是一一对应的，如果有问题请告诉我或自行修改
+ };
+ });
let html = this.generateDom(data);
base.showMainDialog(config.base.dom.button[mode].title, html, config.base.dom.button[mode].footer);
} else {
@@ -6714,6 +7641,7 @@
let fid = v.fid;
let size = base.sizeFormat(v.size);
let dlink = v.download_url;
+ let dpath=v.path;
if (!dlink || !dlink.includes("http")) {
content += `
${filename}
@@ -6723,8 +7651,8 @@
if (mode === 'api') {
alinkAllText += dlink + '\r\n';
content += `
-
${filename}
-
增强下载(基于浏览器文件流)
+
${filename}
+
增强下载(基于浏览器文件流)
直接下载(基于浏览器链接)
复制链接
@@ -6740,24 +7668,34 @@
`;
}
if (mode === 'aria') {
- let alink = base.convertLinkToAria(dlink, filename, `--header "Cookie: ${document.cookie}"`);
+ let alink = base.convertLinkToAria(dlink, filename, dpath, `--header "Cookie: ${document.cookie}"`);
alinkAllText += alink + '\r\n';
content += `
`;
}
if (mode === 'rpc') {
content += `
-
${filename}
-
将 ${filename} 推送到 RPC 下载器
-
`;
+
${filename}
+
+
+
+
+
+ 将 ${filename} 推送到 RPC 下载器
+
+
`;
}
if (mode === 'curl') {
- let alink = base.convertLinkToCurl(dlink, filename, `-b "${document.cookie}"`);
+ let alink = base.convertLinkToCurl(dlink, filename, dpath, `-b "${document.cookie}"`);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -6765,7 +7703,7 @@
let alink = base.convertLinkToBC(dlink, filename, `cookie=${encodeURIComponent(document.cookie)}`);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -6853,8 +7791,12 @@
* UC网盘
* @author 油小猴
* @author hmjz100
+ * @author KanouAo
*/
let $uc = {
+ cnt:0,//计数器，用于控制随机延迟
+ fileCount:0,//文件计数
+
addPageListener() {
/*
防止代码因其他原因被执行多次
@@ -6919,11 +7861,12 @@
const $width = o.item.find('.pl-progress-inner');
const $text = o.item.find('.pl-progress-inner-text');
const filename = o.link[0].dataset.filename;
+ const path=o.link[0].dataset.path;
const index = o.link[0].dataset.index;
const size = Number(o.link[0].dataset.size) || 0;
base._resetData(index);
- base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index });
+ base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index, path});
let startTime = Date.now();
let prevLoaded = 0;
@@ -7007,7 +7950,10 @@
o.stop.hide();
o.back.hide();
});
- doc.on('click', '.listener-download-all', function (e) {
+ doc.on('click', '.listener-download-all',async function (e) {
+ if(navigator.userAgent.match(/Chrom(e|ium)/)){//Chromium内核
+ globalDirHandle = await window.showDirectoryPicker();
+ }
$('.pl-item-link.blob').each(function () {
if ($(this).css('display') !== 'none') {
$(this).click();
@@ -7033,7 +7979,7 @@
target.find('.pl-loading').remove();
target.prepend(base.createLoading());
- let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename, [`Cookie: ${document.cookie}`]);
+ let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename,e.currentTarget.dataset.path, [`Cookie: ${document.cookie}`]);
if (res === 'success') {
$('.listener-rpc-task').show();
target.removeClass('pl-btn-danger').html('发送成功了!快去看看吧~').animate({ opacity: '0.5' }, "slow");
@@ -7128,6 +8074,110 @@
})
},
+ async getFilesByOnce(item,params){
+ try {
+ let res;
+ if(page=="home"){
+ let url=`${config.$uc.api.getFiles.home}?pr=UCBrowser&fr=pc&pdir_fid=${params.fid}&_page=${params.pageNum}&_size=50&_fetch_total=1&_fetch_sub_dirs=0&_sort=file_type:asc,updated_at:desc`;
+ res = await base.get(url, {
+ "content-type": "application/json;charset=utf-8",
+ // "user-agent": config.$quark.api.ua.downloadLink //TODO 怎么是夸克的？
+ "user-agent": config.$uc.api.ua.downloadLink
+ });
+ }else if(page=="share"){
+
+ }else{
+ return message.error(`提示：
网站页面错误`);
+ }
+ return res;
+ } catch (e) {
+ return message.error(`提示：
文件获取请求失败`);
+ }
+ },
+
+ async getFileUrlByOnce(item, index, token) {
+ try {
+ if (item.downloadUrl) return {
+ index,
+ downloadUrl: item.downloadUrl
+ };
+ let res = await base.get(config.$xunlei.api.getLink.home + item.id, {
+ 'Authorization': `${token.credentials.token_type} ${token.credentials.access_token}`,
+ 'content-type': "application/json",
+ 'x-captcha-token': token.captcha.token,
+ 'x-device-id': token.deviceid,
+ });
+ if (res.web_content_link) {
+ return {
+ index,
+ downloadUrl: res.web_content_link
+ };
+ } else {
+ return {
+ index,
+ downloadUrl: '获取下载地址失败，刷新后再试试吧~'
+ };
+ }
+ } catch (e) {
+ return message.error('提示：
请先登录网盘后再刷新页面呢~');
+ }
+ },
+
+ async fetchAllPages(file) {
+ //分页获取文件夹内文件数据
+ let res;
+ let files=[];//文件数据列表
+ let pageCount=Math.ceil(file.include_items/50);//总页数
+ for (let pageNum=1;pageNum<=pageCount;pageNum++) {
+ //随机停顿防反爬
+ this.cnt++;
+ if (this.cnt >= 50+Math.random()*10) {
+ doc.find('.loading-popup .swal2-html-container').html(`
正遍历到的大型文件夹（非全部）已获取 ${files.length} 个文件~
休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ this.cnt = 0;
+ }
+
+ //发送请求
+ let param={"fid":file.fid,"pageNum":pageNum};
+ res=await this.getFilesByOnce(file,param);
+
+ //请求失败
+ if(res?.code){//注意变量名
+ return message.error(`提示：
请求失败，失败码： ${res?.code} 失败信息：${res.message}`);
+ }
+
+ //请求成功
+ files=files.concat(res.data.list)//注意变量名
+ }
+ return files;
+ },
+
+ async fetchFiles(file,pNode) {
+ //获取文件目录结构（递归）
+ //节点
+ let fileNode={
+ name:file.file_name,//注意变量名
+ path:pNode.name === 'root' ? `` : (pNode.path === '' ? pNode.name : `${pNode.path}/${pNode.name}`),//一般来说，路径不要特别特别长，不然可能会出问题，不过正常是不会的
+ children:[]
+ }
+ pNode.children.push(fileNode);
+ file.path=fileNode.path;
+
+ //判断是否文件夹
+ if (!file?.dir) {//注意变量名
+ this.fileCount++;
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${this.fileCount} 个文件~
`);
+ return file;
+ }
+
+ //文件夹内文件遍历
+ let files=[];
+ for (let f of await this.fetchAllPages(file)) {
+ files= files.concat(await this.fetchFiles(f,fileNode));
+ }
+ return files;
+ },
+
async getLink() {
Swal.fire({
showConfirmButton: false,
@@ -7154,46 +8204,49 @@
if (selectList.length === 0) {
return message.error('提示：
请勾选要下载的文件哦~');
}
- if (this.isOnlyFolder()) {
- return message.error('提示：
请打开文件夹后再勾选文件~');
- }
- if (page === 'home') {
- let data = [];
- let batchSize = 15;
- let processed = 0;
- selectList = selectList.filter(item => item.file === true)
-
- for (let i = 0; i < selectList.length; i += batchSize) {
- // 获取当前批次文件
- let batch = selectList.slice(i, i + batchSize);
- console.log()
- let fids = batch.map(item => item.fid);
-
- // 发起请求获取链接
- let res = await base.post(config.$uc.api.getLink, { "fids": fids }, { "content-type": "application/json;charset=utf-8", "user-agent": config.$quark.api.ua.downloadLink });
-
- if (res?.code === 31001) {
- return message.error('提示：
请先登录网盘~
代码：' + res.code);
- }
- if (res?.code !== 0) {
- return message.error('提示：
获取链接失败了~
代码：' + res.code);
- }
- // 合并响应数据
- if (res?.data) {
- data.push(...res.data);
- }
-
- // 更新处理进度
- processed += batch.length;
-
- // 更新UI显示
- doc.find('.loading-popup .loading-title').html(`链接获取中`);
- doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
+ if(page=="home"){
+ }else if(page=="share"){
+ //分享页面所需的变量
+ }else{
+ return message.error('提示：
页面错误~');
+ }
- // 请求间隔节流
- await base.sleep(1000);
+ this.cnt=0;
+ this.fileCount=0;//文件计数
+ let fileList=[];//文件列表，只有文件没有文件夹
+ let fileTree = { name: "root", path: ``, children: [] }; // 文件目录树
+ if (page === 'home') {
+ //获取文件目录结构（递归）
+ for (let file of selectList) {
+ //遍历选中文件
+ //统一变量名
+ fileList = fileList.concat(await this.fetchFiles(file,fileTree));
+ }
+
+ //文件夹为空
+ if (!fileList.length) {
+ return message.error('提示：
文件夹是空的哦~');
}
+
+ //获取下载链接
+ //TODO 我认为连续访问网盘的接口不如直接拿全部ID合适，post协议本身不作数据长度上限，即使后台限制为1M，也有65536个文件ID了，你如果觉得不合适可以修改
+ let fids = fileList.map(item => item.fid);
+ // 发起请求获取链接
+ let res = await base.post(config.$uc.api.getLink.home, { "fids": fids }, { "content-type": "application/json;charset=utf-8", "user-agent": config.$uc.api.ua.downloadLink });
+ if (res.code !== 0) {
+ return message.error(`提示：
请求失败，失败码： ${res?.code} 失败信息：${res.message}`);
+ }
+ if (res.data.length!=fids.length)
+ return message.error('提示：
获取下载链接数目不对，请重新尝试，若文件数目太多，如好几万个文件，请联系作者修改
');
+
+ //显示下载GUI
+ let data = res.data.map((element, index) => {
+ return {
+ ...element,
+ path: fileList[index].path//TODO 请求的ID和返回的ID的列表顺序是一一对应的，如果有问题请告诉我或自行修改
+ };
+ });
let html = this.generateDom(data);
base.showMainDialog(config.base.dom.button[mode].title, html, config.base.dom.button[mode].footer);
} else {
@@ -7213,6 +8266,7 @@
let fid = v.fid;
let size = base.sizeFormat(v.size);
let dlink = v.download_url;
+ let dpath=v.path;
if (!dlink || !dlink.includes("http")) {
content += `
${filename}
@@ -7222,8 +8276,8 @@
if (mode === 'api') {
alinkAllText += dlink + '\r\n';
content += `
-
${filename}
-
增强下载(基于浏览器文件流)
+
${filename}
+
增强下载(基于浏览器文件流)
直接下载(基于浏览器链接)
复制链接
@@ -7239,24 +8293,34 @@
`;
}
if (mode === 'aria') {
- let alink = base.convertLinkToAria(dlink, filename, `--header "Cookie: ${document.cookie}"`);
+ let alink = base.convertLinkToAria(dlink, filename, dpath, `--header "Cookie: ${document.cookie}"`);
alinkAllText += alink + '\r\n';
content += `
`;
}
if (mode === 'rpc') {
content += `
-
${filename}
-
将 ${filename} 推送到 RPC 下载器
-
`;
+
${filename}
+
+
+
+
+
+ 将 ${filename} 推送到 RPC 下载器
+
+
`;
}
if (mode === 'curl') {
- let alink = base.convertLinkToCurl(dlink, filename, `-b "${document.cookie}"`);
+ let alink = base.convertLinkToCurl(dlink, filename, dpath, `-b "${document.cookie}"`);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -7264,7 +8328,7 @@
let alink = base.convertLinkToBC(dlink, filename, `cookie=${encodeURIComponent(document.cookie)}`);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -7352,8 +8416,14 @@
* 123云盘
* @author 油小猴
* @author hmjz100
+ * @author KanouAo
*/
let $123pan = {
+ cnt:0,//计数器，用于控制随机延迟
+ fileCount:0,//文件计数
+ token:{},
+ ShareKey:"",
+
addPageListener() {
/*
防止代码因其他原因被执行多次
@@ -7406,11 +8476,12 @@
const $width = o.item.find('.pl-progress-inner');
const $text = o.item.find('.pl-progress-inner-text');
const filename = o.link[0].dataset.filename;
+ const path=o.link[0].dataset.path;
const index = o.link[0].dataset.index;
const size = Number(o.link[0].dataset.size) || 0;
base._resetData(index);
- base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index });
+ base.get(e.currentTarget.dataset.link, undefined, 'blob', { filename, index, path});
let startTime = Date.now();
let prevLoaded = 0;
@@ -7494,7 +8565,10 @@
o.stop.hide();
o.back.hide();
});
- doc.on('click', '.listener-download-all', function (e) {
+ doc.on('click', '.listener-download-all',async function (e) {
+ if(navigator.userAgent.match(/Chrom(e|ium)/)){//Chromium内核
+ globalDirHandle = await window.showDirectoryPicker();
+ }
$('.pl-item-link.blob').each(function () {
if ($(this).css('display') !== 'none') {
$(this).click();
@@ -7520,7 +8594,7 @@
target.find('.pl-loading').remove();
target.prepend(base.createLoading());
- let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename);
+ let res = await base.sendLinkToRPC(e.currentTarget.dataset.link, e.currentTarget.dataset.filename,e.currentTarget.dataset.path);
if (res === 'success') {
$('.listener-rpc-task').show();
target.removeClass('pl-btn-danger').html('发送成功了!快去看看吧~').animate({ opacity: '0.5' }, "slow");
@@ -7609,6 +8683,171 @@
let token = base.getStorage("authorToken");
return token;
},
+
+ getRandomNum(len) {
+ len = len || 16;
+ let $chars = '0123456789';
+ let maxPos = $chars.length;
+ let pwd = '';
+ for (let i = 0; i < len; i++) {
+ pwd += $chars.charAt(Math.floor(Math.random() * maxPos));
+ }
+ return pwd;
+ },
+
+ async getFilesByOnce(item,params){
+ try {
+ let res;
+ params.driveId=0;//TODO 看起来是个变量，但我定值是0，也没细看这变量怎么产生的，以后出问题再看。
+ params.operateType=8;//文件夹初次打开拿第1页数据时是4，鼠标下滑增加数据是8
+ params.next=0;//如何文件100个以内不用拉数据的是0，超过100的是-1，都填0都适配
+ let time = Date.now();
+ if(page=="home"){
+ //TODO 这URL中间有XXX=时间戳-XXX-XXX的格式，我发觉那放3个随机数竟然也行，如果不合适你就找下。
+ let url=`${config.$123pan.api.getFiles.home}?${this.getRandomNum()}=${time}-${this.getRandomNum()}-${this.getRandomNum()}&driveId=${params.driveId}&limit=100&next=${params.next}&orderBy=update_time&orderDirection=desc&parentFileId=${params.FileId}&trashed=false&SearchData=&Page=${params.pageNum}&OnlyLookAbnormalFile=0&event=homeListFile&operateType=${params.operateType}&inDirectSpace=false`;
+ res = await base.get(url, {
+ "content-type": "application/json;charset=utf-8",
+ "authorization": `Bearer ${this.token}`,
+ "platform": "web"//TODO ios？打错？不合适就换回来
+ });
+ }else if(page=="share"){
+ //TODO 这URL中间有XXX=时间戳-XXX-XXX的格式，我发觉那放3个随机数竟然也行，如果不合适你就找下。
+ let url=`${config.$123pan.api.getFiles.share}?${this.getRandomNum()}=${time}-${this.getRandomNum()}-${this.getRandomNum()}&limit=100&next=${params.next}&orderBy=file_name&orderDirection=asc&shareKey=${this.ShareKey}&ParentFileId=${params.FileId}&Page=${params.pageNum}&event=homeListFile&operateType=${params.operateType}`;
+ res = await base.get(url, {
+ "content-type": "application/json;charset=utf-8",
+ "authorization": `Bearer ${this.token}`,
+ "platform": "web"//TODO ios？打错？不合适就换回来
+ });
+ }else{
+ return message.error(`提示：
网站页面错误`);
+ }
+ return res;
+ } catch (e) {
+ return message.error(`提示：
文件获取请求失败`);
+ }
+ },
+
+ async getFileUrlByOnce(item, index) {
+ try {
+ if (item.DownloadUrl) return {
+ index,
+ downloadUrl: item.DownloadUrl
+ };
+ let res = null;
+ if (this.ShareKey) {
+ res = await base.post(config.$123pan.api.getLink.share, {
+ "ShareKey": this.ShareKey,
+ "FileID": item.FileId,
+ "S3keyFlag": item.S3KeyFlag,
+ "Size": item.Size,
+ "Etag": item.Etag
+ }, {
+ "content-type": "application/json;charset=utf-8",
+ "authorization": `Bearer ${this.token}`,
+ "platform": "ios"//为啥IOS不是WEB？IOS更好点？
+ });
+ } else {
+ res = await base.post(config.$123pan.api.getLink.home, {
+ "driveId": 0,
+ "etag": item.Etag,
+ "fileId": item.FileId,
+ "s3keyFlag": item.S3KeyFlag,
+ "type": item.Type,
+ "fileName": item.FileName,
+ "size": item.Size
+ }, {
+ "content-type": "application/json;charset=utf-8",
+ "authorization": `Bearer ${this.token}`,
+ "platform": "web"//TODO ios？打错？不合适就换回来
+ });
+ }
+ if (res.data?.DownloadUrl) {
+ let url = res.data.DownloadUrl;
+ let surl = new URL(url).searchParams.get("params");
+ if (surl) url = base.decodeBase(surl);
+ url = await base.getFinalUrl(url);
+ return {
+ index,
+ downloadUrl: url
+ };
+ } else if (res.data?.DownloadURL) {
+ let url = res.data.DownloadURL;
+ let surl = new URL(url).searchParams.get("params");
+ if (surl) url = base.decodeBase(surl);
+ url = await base.getFinalUrl(url);
+ return {
+ index,
+ downloadUrl: url
+ };
+ } else if (res?.code === 5112) {
+ return message.error('提示：
请先登录网盘后再获取链接呢~');
+ } else {
+ return {
+ index,
+ downloadUrl: '获取下载地址失败，刷新后再试试吧~'
+ };
+ }
+ } catch (e) {
+ return {
+ index,
+ downloadUrl: '获取下载地址失败，刷新后再试试吧~'
+ };
+ }
+ },
+
+ async fetchAllPages(file) {
+ //分页获取文件夹内文件数据
+ let res;
+ let files=[];//文件数据列表
+ let pageCount=1;//总页数，先设1，之后根据res返回的值修改//share没有file.fileCount，兼容适配
+ for (let pageNum=1;pageNum<=pageCount;pageNum++) {
+ //随机停顿防反爬
+ this.cnt++;
+ if (this.cnt >= 50+Math.random()*10) {
+ doc.find('#loadingText').html(`
文件获取中
已获取 ${this.fileCount} 个文件，请耐心等待哦~
>休息 ${globalSleep} 毫秒...
`);
+ await base.sleep(globalSleep+Math.random()*globalSleepRandSeed);
+ this.cnt = 0;
+ }
+ //发送请求
+ let param={"pageNum":pageNum,"FileId":file.FileId};
+ res=await this.getFilesByOnce(file,param);
+
+ //请求失败
+ if(!(res?.code==0&&res?.message=="ok")){
+ return message.error(`提示：
请求失败，失败码： ${res?.res_code} 失败信息：${res.res_message}`);
+ }
+ //请求成功
+ if(pageCount==1)pageCount=Math.ceil(res.data.Total/100);
+ files=files.concat(res.data.InfoList);//注意变量名
+ }
+ return files;
+ },
+
+ async fetchFiles(file,pNode) {
+ //获取文件目录结构（递归）
+ //节点
+ let fileNode={
+ name:file.FileName,//注意变量名
+ path:pNode.name === 'root' ? `` : (pNode.path === '' ? pNode.name : `${pNode.path}/${pNode.name}`),//一般来说，路径不要特别特别长，不然可能会出问题，不过正常是不会的
+ children:[]
+ }
+ pNode.children.push(fileNode);
+ file.path=fileNode.path;
+
+ //判断是否文件夹
+ if (file.Type === 0) {//注意变量名
+ this.fileCount++;
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${this.fileCount} 个文件~
`);
+ return file;
+ }
+
+ //文件夹内文件遍历
+ let files=[];
+ for (let f of await this.fetchAllPages(file)) {
+ files= files.concat(await this.fetchFiles(f,fileNode));
+ }
+ return files;
+ },
async getLink() {
Swal.fire({
@@ -7636,137 +8875,106 @@
if (selectList.length === 0) {
return message.error('提示：
请勾选要下载的文件哦~');
}
- if (this.isOnlyFolder()) {
- return message.error('提示：
请打开文件夹后再勾选文件~');
- }
- console.log(selectList);
- if (page === 'home') {
- let token = this.getToken();
- let batchSize = 15;
- let processed = 0;
- selectList = selectList.filter(item => item.Type === 0);
- for (let i = 0; i < selectList.length; i += batchSize) {
- let batch = selectList.slice(i, i + batchSize);
- let queue = [];
- doc.find('.loading-popup .loading-title').html(`链接获取中`);
- doc.find('.loading-popup .swal2-html-container').html(`
正在获取文件对应的下载链接~
`);
- batch.forEach((item, localIndex) => {
- let globalIndex = i + localIndex;
- queue.push(this.getFileUrlByOnce(item, globalIndex, token)
- .then(val => {
- processed++;
- doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
- return val;
- }));
- });
-
- let res = await Promise.all(queue);
- res.forEach(val => {
- selectList[val.index].DownloadUrl = val.downloadUrl;
- });
-
- await base.sleep(1000);
- }
- let html = this.generateDom(selectList);
- base.showMainDialog(config.base.dom.button[mode].title, html, config.base.dom.button[mode].footer);
- } else if (page === 'share') {
- let token = this.getToken();
- let batchSize = 15;
- let processed = 0;
- selectList = selectList.filter(item => item.Type === 0);
+ if(page=="home"){
+ }else if(page=="share"){
+ //分享页面所需的变量
let pathSplit = location.pathname.split('/').filter(Boolean);
- let ShareKey = pathSplit[1];
- console.log(selectList)
- for (let i = 0; i < selectList.length; i += batchSize) {
- let batch = selectList.slice(i, i + batchSize);
- let queue = [];
+ this.ShareKey = pathSplit[1];
+ }else{
+ return message.error('提示：
页面错误~');
+ }
+ this.token = this.getToken();
+
+ this.cnt=0;
+ this.fileCount=0;//文件计数
+ let fileList=[];//文件列表，只有文件没有文件夹
+ let fileTree = { name: "root", path: ``, children: [] }; // 文件目录树
+ // if (page === 'home') {
+ //获取文件目录结构（递归）
+ for (let file of selectList) {
+ //遍历选中文件
+ //统一变量名
+ fileList = fileList.concat(await this.fetchFiles(file,fileTree));
+ }
+
+ //文件夹为空
+ if (!fileList.length) {
+ return message.error('提示：
文件夹是空的哦~');
+ }
+
+ //获取下载链接
+ doc.find('.loading-popup .loading-title').html(`链接获取中`);
+ doc.find('.loading-popup .swal2-html-container').html(`
正在获取文件对应的下载链接~
`);
+ let batchSize = globalBatchsize+Math.ceil(Math.random()*5);
+ let i=0;
+ while (i < fileList.length){
+ // 分批获取链接
+ let batch = fileList.slice(i, i + batchSize);
- doc.find('.loading-popup .loading-title').html(`链接获取中`);
- doc.find('.loading-popup .swal2-html-container').html(`
正在获取文件对应的下载链接~
`);
+ // 生成请求队列
+ let queue = [];
batch.forEach((item, localIndex) => {
let globalIndex = i + localIndex;
- queue.push(this.getFileUrlByOnce(item, globalIndex, token, ShareKey)
+ queue.push(this.getFileUrlByOnce(item, globalIndex)
.then(val => {
- processed++;
- doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
+ // processed++;
+ // doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
return val;
}));
});
+ // 等待本批次的请求结果
let res = await Promise.all(queue);
res.forEach(val => {
- selectList[val.index].DownloadUrl = val.downloadUrl;
+ fileList[val.index].DownloadUrl = val.downloadUrl;
});
- await base.sleep(1000);
+ // 每次处理完一个批次后，等待
+ if (i + batchSize < fileList.length){
+ doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${i+batch.length} / ${fileList.length} 个链接,请耐心等待哦~
休息 ${globalSleep} 毫秒...
`);
+ await base.customSleep();
+ };
+
+ //累加批次
+ i += batchSize;
+ batchSize = globalBatchsize+Math.ceil(Math.random()*5)
}
- let html = this.generateDom(selectList);
+ let html = this.generateDom(fileList);
base.showMainDialog(config.base.dom.button[mode].title, html, config.base.dom.button[mode].footer);
- } else {
- return message.error('提示：
页面错误~');
- }
- },
-
- async getFileUrlByOnce(item, index, token, ShareKey) {
- if (item.DownloadUrl) return {
- index,
- downloadUrl: item.DownloadUrl
- };
- let res = null;
- if (ShareKey) {
- res = await base.post(config.$123pan.api.getShareLink, {
- "ShareKey": ShareKey,
- "FileID": item.FileId,
- "S3keyFlag": item.S3KeyFlag,
- "Size": item.Size,
- "Etag": item.Etag
- }, {
- "content-type": "application/json;charset=utf-8",
- "authorization": `Bearer ${token}`,
- "platform": "ios"
- });
- } else {
- res = await base.post(config.$123pan.api.getLink, {
- "driveId": 0,
- "etag": item.Etag,
- "fileId": item.FileId,
- "s3keyFlag": item.S3KeyFlag,
- "type": item.Type,
- "fileName": item.FileName,
- "size": item.Size
- }, {
- "content-type": "application/json;charset=utf-8",
- "authorization": `Bearer ${token}`,
- "platform": "ios"
- });
- }
- if (res.data?.DownloadUrl) {
- let url = res.data.DownloadUrl;
- let surl = new URL(url).searchParams.get("params");
- if (surl) url = base.decodeBase(surl);
- url = await base.getFinalUrl(url);
- return {
- index,
- downloadUrl: url
- };
- } else if (res.data?.DownloadURL) {
- let url = res.data.DownloadURL;
- let surl = new URL(url).searchParams.get("params");
- if (surl) url = base.decodeBase(surl);
- url = await base.getFinalUrl(url);
- return {
- index,
- downloadUrl: url
- };
- } else if (res?.code === 5112) {
- return message.error('提示：
请先登录网盘后再获取链接呢~');
- } else {
- return {
- index,
- downloadUrl: '获取下载地址失败，刷新后再试试吧~'
- };
- }
+ // } else if (page === 'share') {
+ // let batchSize = 15;
+ // let processed = 0;
+ // selectList = selectList.filter(item => item.Type === 0);
+ // console.log(selectList)
+ // for (let i = 0; i < selectList.length; i += batchSize) {
+ // let batch = selectList.slice(i, i + batchSize);
+ // let queue = [];
+
+ // doc.find('.loading-popup .loading-title').html(`链接获取中`);
+ // doc.find('.loading-popup .swal2-html-container').html(`
正在获取文件对应的下载链接~
`);
+ // batch.forEach((item, localIndex) => {
+ // let globalIndex = i + localIndex;
+ // queue.push(this.getFileUrlByOnce(item, globalIndex)
+ // .then(val => {
+ // processed++;
+ // doc.find('.loading-popup .swal2-html-container').html(`
已获取 ${processed} / ${selectList.length} 个链接~
`);
+ // return val;
+ // }));
+ // });
+
+ // let res = await Promise.all(queue);
+ // res.forEach(val => {
+ // selectList[val.index].DownloadUrl = val.downloadUrl;
+ // });
+
+ // await base.sleep(1000);
+ // }
+ // let html = this.generateDom(selectList);
+ // base.showMainDialog(config.base.dom.button[mode].title, html, config.base.dom.button[mode].footer);
+ // } else {
+ // return message.error('提示：
页面错误~');
+ // }
},
generateDom(list) {
@@ -7781,6 +8989,7 @@
let fileid = v.FileId;
let size = base.sizeFormat(v.Size);
let dlink = v.DownloadUrl || v.DownloadURL;
+ let dpath=v.path;
if (!dlink || !dlink.includes("http")) {
content += `
${filename}
@@ -7790,8 +8999,8 @@
if (mode === 'api') {
alinkAllText += dlink + '\r\n';
content += `
-
${filename}
-
增强下载(基于浏览器文件流)
+
${filename}
+
增强下载(基于浏览器文件流)
直接下载(基于浏览器链接)
复制链接
@@ -7807,24 +9016,34 @@
`;
}
if (mode === 'aria') {
- let alink = base.convertLinkToAria(dlink, filename);
+ let alink = base.convertLinkToAria(dlink, filename, dpath);
alinkAllText += alink + '\r\n';
content += `
`;
}
if (mode === 'rpc') {
content += `
-
${filename}
-
将 ${filename} 推送到 RPC 下载器
-
`;
+
${filename}
+
+
+
+
+
+ 将 ${filename} 推送到 RPC 下载器
+
+
`;
}
if (mode === 'curl') {
- let alink = base.convertLinkToCurl(dlink, filename);
+ let alink = base.convertLinkToCurl(dlink, filename, dpath);
alinkAllText += alink + '\r\n';
content += `
`;
}
@@ -7832,7 +9051,7 @@
let alink = base.convertLinkToBC(dlink, filename);
alinkAllText += alink + '\r\n';
content += `
`;
}