mirror of
https://github.com/qaiu/netdisk-fast-download.git
synced 2026-07-12 06:21:15 +00:00
Compare commits
3 Commits
v3.0.4
..
65d518373d
| Author | SHA1 | Date | |
|---|---|---|---|
 qaiu
|
65d518373d | ||
|
yukaidi
|
bca4da4b6c | ||
|
qaiu
|
0fd78defcb |
@@ -249,7 +249,13 @@ public enum PanDomainTemplate {
|
||||
CT("城通网盘",
|
||||
compile("https://(?:[a-zA-Z\\d-]+\\.)?(ctfile|545c|u062|ghpym|474b)\\.com/f(ile)?/" +
|
||||
"(?<KEY>[0-9a-zA-Z_-]+)(\\?p=(?<PWD>\\w+))?"),
|
||||
"https://474b.com/file/{shareKey}",
|
||||
"https://ctfile.com/file/{shareKey}",
|
||||
CtTool.class),
|
||||
// https://url94.ctfile.com/d/64115194-164803691-48508c?p=7609&d=164803691&fk=decb36
|
||||
CTD("城通网盘-目录",
|
||||
compile("https://(?:[a-zA-Z\\d-]+\\.)?(ctfile|545c|u062|ghpym|474b)\\.com/d/" +
|
||||
"(?<KEY>[0-9a-zA-Z_-]+)(\\?p=(?<PWD>\\w+))?"),
|
||||
"https://ctfile.com/d/{shareKey}",
|
||||
CtTool.class),
|
||||
// https://www.vyuyun.com/s/QMa6ie?password=I4KG7H
|
||||
// https://www.vyuyun.com/s/QMa6ie/file?password=I4KG7H
|
||||
|
||||
@@ -1,16 +1,23 @@
|
||||
package cn.qaiu.parser.impl;
|
||||
|
||||
import cn.qaiu.entity.FileInfo;
|
||||
import cn.qaiu.entity.ShareLinkInfo;
|
||||
import cn.qaiu.parser.PanBase;
|
||||
import cn.qaiu.util.RandomStringGenerator;
|
||||
import cn.qaiu.util.FileSizeConverter;
|
||||
import io.vertx.core.Future;
|
||||
import io.vertx.core.Promise;
|
||||
import io.vertx.core.buffer.Buffer;
|
||||
import io.vertx.core.json.JsonArray;
|
||||
import io.vertx.core.json.JsonObject;
|
||||
import io.vertx.ext.web.client.HttpRequest;
|
||||
import io.vertx.uritemplate.UriTemplate;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.regex.Matcher;
|
||||
import java.util.regex.Pattern;
|
||||
|
||||
/**
|
||||
* <a href="https://www.ctfile.com">诚通网盘</a>
|
||||
@@ -18,19 +25,34 @@ import java.util.Map;
|
||||
public class CtTool extends PanBase {
|
||||
private static final String API_URL_PREFIX = "https://webapi.ctfile.com";
|
||||
|
||||
// https://webapi.ctfile.com/getfile.php?path=f&f=55050874-1246660795-6464f6&
|
||||
// passcode=7548&token=30wiijxs1fzhb6brw0p9m6&r=0.5885881231735761&
|
||||
// ref=&url=https%3A%2F%2F474b.com%2Ff%2F55050874-1246660795-6464f6%3Fp%3D7548
|
||||
// https://webapi.ctfile.com/getfile.php?path=f&f=64115194-17569800420720-06c697&
|
||||
// passcode=7609&r=0.6611183001986635&ref=&url=https%3A%2F%2Furl94.ctfile.com%2Ff%2F64115194-17569800420720-06c697%3Fp%3D7609
|
||||
private static final String API1 = API_URL_PREFIX + "/getfile.php?path={path}" +
|
||||
"&f={shareKey}&passcode={pwd}&token={token}&r={rand}&ref=";
|
||||
"&f={shareKey}&passcode={pwd}&r={rand}&ref=&url={url}";
|
||||
|
||||
//https://webapi.ctfile.com/get_file_url.php?uid=55050874&fid=1246660795&folder_id=0&
|
||||
// file_chk=054bc20461f5c63ff82015b9e69fb7fc&mb=1&token=30wiijxs1fzhb6brw0p9m6&app=0&
|
||||
// acheck=1&verifycode=&rd=0.965929071503574
|
||||
// https://webapi.ctfile.com/get_file_url.php?uid=64115194&fid=17569800420720&folder_id=0&
|
||||
// share_id=&file_chk=af5c8757a49cbc69a557eb3da59b246c&start_time=1780471868&wait_seconds=0&
|
||||
// mb=0&app=0&acheck=1&verifycode=1780471868.2951fe63abedf36ec02f34ed5711ce70&rd=0.36350981353622636
|
||||
private static final String API2 = API_URL_PREFIX + "/get_file_url.php?" +
|
||||
"uid={uid}&fid={fid}&folder_id=0&file_chk={file_chk}&mb=0&token={token}&app=0&acheck=0&verifycode=" +
|
||||
"&rd={rand}";
|
||||
"uid={uid}&fid={fid}&folder_id=0&share_id=&file_chk={file_chk}" +
|
||||
"&start_time={start_time}&wait_seconds={wait_seconds}&mb=0&app=0&acheck=1" +
|
||||
"&verifycode={verifycode}&rd={rand}";
|
||||
|
||||
// https://webapi.ctfile.com/getdir.php?path=d&d=64115194-164803691-48508c&
|
||||
// folder_id=164803691&fk=decb36&passcode=7609&r=0.23...&ref=&url=https://url94.ctfile.com/d/...
|
||||
private static final String API_GETDIR = API_URL_PREFIX + "/getdir.php?path={path}" +
|
||||
"&d={shareKey}&folder_id={folder_id}&fk={fk}&passcode={pwd}&r={rand}&ref=&url={url}";
|
||||
|
||||
// DataTables参数，用于获取目录文件列表
|
||||
private static final String FILE_LIST_PARAMS = "&sEcho=1&iColumns=4&sColumns=%2C%2C%2C" +
|
||||
"&iDisplayStart=0&iDisplayLength=500&mDataProp_0=0&mDataProp_1=1&mDataProp_2=2&mDataProp_3=3" +
|
||||
"&iSortCol_0=3&sSortDir_0=desc&iSortingCols=1";
|
||||
|
||||
// 文件列表HTML解析正则
|
||||
private static final Pattern FILE_ID_PATTERN = Pattern.compile("value=\"f(\\d+)\"");
|
||||
private static final Pattern FILE_HREF_PATTERN = Pattern.compile("href=\"#/f/([^\"]+)\"");
|
||||
private static final Pattern FILE_NAME_PATTERN = Pattern.compile(">([^<]+)</a>");
|
||||
private static final Pattern FILE_ICON_PATTERN = Pattern.compile("alt=\"([^\"]+)\"");
|
||||
|
||||
/**
|
||||
* 子类重写此构造方法不需要添加额外逻辑
|
||||
@@ -57,7 +79,6 @@ public class CtTool extends PanBase {
|
||||
}
|
||||
String[] split = shareKey.split("-");
|
||||
String uid = split[0], fid = split[1];
|
||||
String token = RandomStringGenerator.generateRandomString();
|
||||
// 获取url path
|
||||
int i1 = shareLinkInfo.getShareUrl().indexOf("com/");
|
||||
int i2 = shareLinkInfo.getShareUrl().lastIndexOf("/");
|
||||
@@ -67,8 +88,8 @@ public class CtTool extends PanBase {
|
||||
.setTemplateParam("path", path)
|
||||
.setTemplateParam("shareKey", shareKey)
|
||||
.setTemplateParam("pwd", shareLinkInfo.getSharePassword())
|
||||
.setTemplateParam("token", token)
|
||||
.setTemplateParam("r", Math.random() + "");
|
||||
.setTemplateParam("rand", String.valueOf(Math.random()))
|
||||
.setTemplateParam("url", shareLinkInfo.getShareUrl());
|
||||
|
||||
bufferHttpRequest1
|
||||
.send().onSuccess(res -> {
|
||||
@@ -77,23 +98,40 @@ public class CtTool extends PanBase {
|
||||
var fileJson = resJson.getJsonObject("file");
|
||||
if (fileJson.containsKey("file_chk")) {
|
||||
var file_chk = fileJson.getString("file_chk");
|
||||
String startTime = fileJson.getValue("start_time").toString();
|
||||
String waitSeconds = fileJson.getValue("wait_seconds").toString();
|
||||
String verifycode = fileJson.getString("verifycode");
|
||||
|
||||
// 提取文件信息并存储
|
||||
FileInfo fileInfo = new FileInfo()
|
||||
.setFileName(fileJson.getString("file_name"))
|
||||
.setFileId(String.valueOf(fileJson.getLong("file_id", 0L)))
|
||||
.setSizeStr(fileJson.getString("file_size"))
|
||||
.setCreateTime(fileJson.getString("file_time"))
|
||||
.setCreateBy(fileJson.getString("username"))
|
||||
.setFileType("file")
|
||||
.setPanType(shareLinkInfo.getType());
|
||||
shareLinkInfo.getOtherParam().put("fileInfo", fileInfo);
|
||||
|
||||
HttpRequest<Buffer> bufferHttpRequest2 = clientSession.getAbs(UriTemplate.of(API2))
|
||||
.setTemplateParam("uid", uid)
|
||||
.setTemplateParam("fid", fid)
|
||||
.setTemplateParam("file_chk", file_chk)
|
||||
.setTemplateParam("token", token)
|
||||
.setTemplateParam("rd", Math.random() + "");
|
||||
.setTemplateParam("start_time", startTime)
|
||||
.setTemplateParam("wait_seconds", waitSeconds)
|
||||
.setTemplateParam("verifycode", verifycode)
|
||||
.setTemplateParam("rand", String.valueOf(Math.random()));
|
||||
bufferHttpRequest2
|
||||
.send().onSuccess(res2 -> {
|
||||
JsonObject resJson2 = asJson(res2);
|
||||
if (resJson2.containsKey("downurl")) {
|
||||
String downloadUrl = resJson2.getString("downurl");
|
||||
|
||||
|
||||
// 存储下载元数据，包括必要的请求头
|
||||
Map<String, String> headers = new HashMap<>();
|
||||
headers.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36");
|
||||
headers.put("Referer", shareLinkInfo.getShareUrl());
|
||||
|
||||
|
||||
// 使用新的 completeWithMeta 方法
|
||||
completeWithMeta(downloadUrl, headers);
|
||||
} else {
|
||||
@@ -109,4 +147,132 @@ public class CtTool extends PanBase {
|
||||
}).onFailure(handleFail(bufferHttpRequest1.queryParams().toString()));
|
||||
return promise.future();
|
||||
}
|
||||
|
||||
@Override
|
||||
public Future<List<FileInfo>> parseFileList() {
|
||||
Promise<List<FileInfo>> listPromise = Promise.promise();
|
||||
|
||||
final String shareKey = shareLinkInfo.getShareKey();
|
||||
final String shareUrl = shareLinkInfo.getShareUrl();
|
||||
final String pwd = shareLinkInfo.getSharePassword();
|
||||
|
||||
// shareKey格式: uid-folder_id-hash (例如 64115194-164803691-48508c)
|
||||
String[] split = shareKey.split("-");
|
||||
if (split.length < 2) {
|
||||
listPromise.fail(baseMsg() + " shareKey格式不正确: " + shareKey);
|
||||
return listPromise.future();
|
||||
}
|
||||
String folderId = split[1];
|
||||
|
||||
// 从分享URL中提取fk参数
|
||||
String fk = extractQueryParam(shareUrl, "fk");
|
||||
|
||||
// 从URL中提取path (例如从 "https://url94.ctfile.com/d/xxx?p=..." 中提取 "d")
|
||||
int comIdx = shareUrl.indexOf("com/");
|
||||
int qIdx = shareUrl.indexOf('?');
|
||||
String pathAndKey = qIdx > 0 ? shareUrl.substring(comIdx + 4, qIdx) : shareUrl.substring(comIdx + 4);
|
||||
int slashIdx = pathAndKey.indexOf('/');
|
||||
String path = slashIdx > 0 ? pathAndKey.substring(0, slashIdx) : pathAndKey;
|
||||
|
||||
clientSession.getAbs(UriTemplate.of(API_GETDIR))
|
||||
.setTemplateParam("path", path)
|
||||
.setTemplateParam("shareKey", shareKey)
|
||||
.setTemplateParam("folder_id", folderId)
|
||||
.setTemplateParam("fk", fk != null ? fk : "")
|
||||
.setTemplateParam("pwd", pwd != null ? pwd : "")
|
||||
.setTemplateParam("rand", String.valueOf(Math.random()))
|
||||
.setTemplateParam("url", shareUrl)
|
||||
.send().onSuccess(res -> {
|
||||
var resJson = asJson(res);
|
||||
if (!resJson.containsKey("file")) {
|
||||
listPromise.fail(baseMsg() + " 目录解析失败: " + resJson.encode());
|
||||
return;
|
||||
}
|
||||
var dirInfo = resJson.getJsonObject("file");
|
||||
String fileListRelUrl = dirInfo.getString("url");
|
||||
if (fileListRelUrl == null) {
|
||||
listPromise.fail(baseMsg() + " 文件列表URL为空");
|
||||
return;
|
||||
}
|
||||
|
||||
String fileListUrl = API_URL_PREFIX + fileListRelUrl + FILE_LIST_PARAMS;
|
||||
clientSession.getAbs(fileListUrl)
|
||||
.send().onSuccess(res2 -> {
|
||||
var listJson = asJson(res2);
|
||||
JsonArray aaData = listJson.getJsonArray("aaData");
|
||||
if (aaData == null) {
|
||||
listPromise.fail(baseMsg() + " 文件列表为空");
|
||||
return;
|
||||
}
|
||||
List<FileInfo> fileList = new ArrayList<>();
|
||||
String panType = shareLinkInfo.getType();
|
||||
for (int i = 0; i < aaData.size(); i++) {
|
||||
var row = aaData.getJsonArray(i);
|
||||
try {
|
||||
String checkboxHtml = row.getString(0);
|
||||
String nameCellHtml = row.getString(1);
|
||||
String sizeStr = row.getString(2).trim();
|
||||
|
||||
// 从checkbox HTML中提取文件ID
|
||||
String fileId = null;
|
||||
Matcher idMatcher = FILE_ID_PATTERN.matcher(checkboxHtml);
|
||||
if (idMatcher.find()) fileId = idMatcher.group(1);
|
||||
|
||||
// 从文件名单元格HTML中提取临时分享key
|
||||
String fileShareKey = null;
|
||||
Matcher hrefMatcher = FILE_HREF_PATTERN.matcher(nameCellHtml);
|
||||
if (hrefMatcher.find()) fileShareKey = hrefMatcher.group(1);
|
||||
|
||||
// 提取文件名
|
||||
String fileName = null;
|
||||
Matcher nameMatcher = FILE_NAME_PATTERN.matcher(nameCellHtml);
|
||||
if (nameMatcher.find()) fileName = nameMatcher.group(1).trim();
|
||||
|
||||
// 提取文件图标/类型
|
||||
String fileIcon = null;
|
||||
Matcher iconMatcher = FILE_ICON_PATTERN.matcher(nameCellHtml);
|
||||
if (iconMatcher.find()) fileIcon = iconMatcher.group(1);
|
||||
|
||||
if (fileName == null || fileShareKey == null) continue;
|
||||
|
||||
long sizeBytes = 0;
|
||||
try {
|
||||
sizeBytes = FileSizeConverter.convertToBytes(sizeStr);
|
||||
} catch (Exception ignored) {}
|
||||
|
||||
FileInfo fileInfo = new FileInfo()
|
||||
.setFileName(fileName)
|
||||
.setFileId(fileId)
|
||||
.setSizeStr(sizeStr)
|
||||
.setSize(sizeBytes)
|
||||
.setFileType(fileIcon)
|
||||
.setFileIcon(fileIcon)
|
||||
.setPanType(panType)
|
||||
.setParserUrl(String.format("%s/v2/redirectUrl/%s/%s",
|
||||
getDomainName(), panType, fileShareKey));
|
||||
fileList.add(fileInfo);
|
||||
} catch (Exception e) {
|
||||
log.warn("解析文件行失败: {}", e.getMessage());
|
||||
}
|
||||
}
|
||||
listPromise.complete(fileList);
|
||||
}).onFailure(listPromise::fail);
|
||||
}).onFailure(listPromise::fail);
|
||||
|
||||
return listPromise.future();
|
||||
}
|
||||
|
||||
private String extractQueryParam(String url, String paramName) {
|
||||
if (url == null) return null;
|
||||
int qIdx = url.indexOf('?');
|
||||
if (qIdx < 0) return null;
|
||||
String query = url.substring(qIdx + 1);
|
||||
for (String param : query.split("&")) {
|
||||
int eqIdx = param.indexOf('=');
|
||||
if (eqIdx > 0 && param.substring(0, eqIdx).equals(paramName)) {
|
||||
return param.substring(eqIdx + 1);
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -15,6 +15,7 @@ import java.net.URLEncoder;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Base64;
|
||||
import java.util.List;
|
||||
import java.util.Random;
|
||||
import java.util.UUID;
|
||||
|
||||
/**
|
||||
@@ -24,6 +25,7 @@ public class LeTool extends PanBase {
|
||||
private static final String API_URL_PREFIX = "https://lecloud.lenovo.com/mshare/api/clouddiskapi/share/public/v1/";
|
||||
private static final String DEFAULT_FILE_TYPE = "file";
|
||||
private static final int FILE_TYPE_DIRECTORY = 0; // 目录类型
|
||||
private static final Random RANDOM = new Random();
|
||||
|
||||
private static final MultiMap HEADERS;
|
||||
|
||||
@@ -100,8 +102,8 @@ public class LeTool extends PanBase {
|
||||
}
|
||||
|
||||
String fileId = fileInfoJson.getString("fileId");
|
||||
// 根据文件ID获取跳转链接
|
||||
getDownURL(dataKey, fileId);
|
||||
// 根据文件ID获取跳转链接（随机选择方式，失败自动fallback）
|
||||
getDownURLWithFallback(dataKey, fileId);
|
||||
}
|
||||
} else {
|
||||
fail("{}: {}", resJson.getString("errcode"), resJson.getString("errmsg"));
|
||||
@@ -260,8 +262,8 @@ public class LeTool extends PanBase {
|
||||
String shareId = paramJson.getString("shareId");
|
||||
String fileId = paramJson.getString("fileId");
|
||||
|
||||
// 调用获取下载链接
|
||||
getDownURLForById(shareId, fileId, parsePromise);
|
||||
// 调用获取下载链接（随机选择方式，失败自动fallback）
|
||||
getDownURLWithFallbackForById(shareId, fileId, parsePromise);
|
||||
|
||||
} catch (Exception e) {
|
||||
parsePromise.fail("解析参数失败: " + e.getMessage());
|
||||
@@ -304,14 +306,22 @@ public class LeTool extends PanBase {
|
||||
}).onFailure(err -> promise.fail(err));
|
||||
}
|
||||
|
||||
private void getDownURL(String key, String fileId) {
|
||||
/**
|
||||
* 通过 packageDownloadWithFileIds 接口获取下载链接
|
||||
* 需要两步：先获取 downloadUrl，再请求 302 跳转
|
||||
*
|
||||
* @param shareId 分享ID
|
||||
* @param fileId 文件ID
|
||||
* @param promise 完成时会写入此 promise
|
||||
*/
|
||||
private void getDownURL(String shareId, String fileId, Promise<String> promise) {
|
||||
String uuid = UUID.randomUUID().toString();
|
||||
JsonArray fileIds = JsonArray.of(fileId);
|
||||
String apiUrl2 = API_URL_PREFIX + "packageDownloadWithFileIds";
|
||||
String apiUrl = API_URL_PREFIX + "packageDownloadWithFileIds";
|
||||
// {"fileIds":[123],"shareId":"xxx","browserId":"uuid"}
|
||||
client.postAbs(apiUrl2)
|
||||
client.postAbs(apiUrl)
|
||||
.putHeaders(HEADERS)
|
||||
.sendJsonObject(JsonObject.of("fileIds", fileIds, "shareId", key, "browserId", uuid))
|
||||
.sendJsonObject(JsonObject.of("fileIds", fileIds, "shareId", shareId, "browserId", uuid))
|
||||
.onSuccess(res -> {
|
||||
JsonObject resJson = asJson(res);
|
||||
if (resJson.containsKey("result")) {
|
||||
@@ -320,20 +330,107 @@ public class LeTool extends PanBase {
|
||||
// 获取重定向链接跳转链接
|
||||
String downloadUrl = dataJson.getString("downloadUrl");
|
||||
if (downloadUrl == null) {
|
||||
fail("Result JSON数据异常: downloadUrl不存在");
|
||||
promise.fail("Result JSON数据异常: downloadUrl不存在");
|
||||
return;
|
||||
}
|
||||
// 获取重定向链接跳转链接
|
||||
clientNoRedirects.getAbs(downloadUrl).send()
|
||||
.onSuccess(res2 -> promise.complete(res2.headers().get("Location")))
|
||||
.onFailure(handleFail(downloadUrl));
|
||||
.onFailure(err -> promise.fail(err));
|
||||
} else {
|
||||
fail("{}: {}", resJson.getString("errcode"), resJson.getString("errmsg"));
|
||||
promise.fail(resJson.getString("errcode") + ": " + resJson.getString("errmsg"));
|
||||
}
|
||||
} else {
|
||||
fail("Result JSON数据异常: result字段不存在");
|
||||
promise.fail("Result JSON数据异常: result字段不存在");
|
||||
}
|
||||
}).onFailure(handleFail(apiUrl2));
|
||||
}).onFailure(err -> promise.fail(err));
|
||||
}
|
||||
|
||||
/**
|
||||
* 通过 directDownload 接口获取下载链接
|
||||
* 相比 packageDownloadWithFileIds 少一次请求，直接返回302
|
||||
*
|
||||
* @param shareId 分享ID
|
||||
* @param fileId 文件ID
|
||||
* @param promise 完成时会写入此 promise
|
||||
*/
|
||||
private void getDownURLDirect(String shareId, String fileId, Promise<String> promise) {
|
||||
String uuid = UUID.randomUUID().toString();
|
||||
String apiUrl = API_URL_PREFIX + "directDownload"
|
||||
+ "?shareId=" + shareId
|
||||
+ "&fileId=" + fileId
|
||||
+ "&browserId=" + uuid;
|
||||
|
||||
clientNoRedirects.getAbs(apiUrl)
|
||||
.putHeaders(HEADERS)
|
||||
.send()
|
||||
.onSuccess(res -> {
|
||||
String location = res.headers().get("Location");
|
||||
if (location != null && !location.isEmpty()) {
|
||||
promise.complete(location);
|
||||
} else {
|
||||
log.warn("directDownload 返回非302响应: shareId={}, fileId={}, statusCode={}", shareId, fileId, res.statusCode());
|
||||
promise.fail("directDownload 未返回有效的 Location, statusCode=" + res.statusCode());
|
||||
}
|
||||
})
|
||||
.onFailure(err -> {
|
||||
log.warn("directDownload 请求失败: shareId={}, fileId={}, error={}", shareId, fileId, err.getMessage());
|
||||
promise.fail(err);
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* 随机选择下载方式并带 fallback（用于 parse）
|
||||
* 先随机选择 directDownload 或 packageDownloadWithFileIds，失败则尝试另一个
|
||||
*/
|
||||
private void getDownURLWithFallback(String shareId, String fileId) {
|
||||
boolean useDirect = RANDOM.nextBoolean();
|
||||
log.info("乐云下载方式选择: shareId={}, fileId={}, method={}", shareId, fileId, useDirect ? "directDownload" : "packageDownloadWithFileIds");
|
||||
|
||||
Promise<String> fallbackPromise = Promise.promise();
|
||||
fallbackPromise.future().onSuccess(url -> {
|
||||
promise.complete(url);
|
||||
}).onFailure(err -> {
|
||||
log.warn("乐云第一种下载方式失败，尝试另一种: {}", err.getMessage());
|
||||
if (useDirect) {
|
||||
getDownURL(shareId, fileId, promise);
|
||||
} else {
|
||||
getDownURLDirect(shareId, fileId, promise);
|
||||
}
|
||||
});
|
||||
|
||||
if (useDirect) {
|
||||
getDownURLDirect(shareId, fileId, fallbackPromise);
|
||||
} else {
|
||||
getDownURL(shareId, fileId, fallbackPromise);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 随机选择下载方式并带 fallback（用于 parseById）
|
||||
* 先随机选择 directDownload 或 packageDownloadWithFileIds，失败则尝试另一个
|
||||
*/
|
||||
private void getDownURLWithFallbackForById(String shareId, String fileId, Promise<String> promise) {
|
||||
boolean useDirect = RANDOM.nextBoolean();
|
||||
log.info("乐云下载方式选择(parseById): shareId={}, fileId={}, method={}", shareId, fileId, useDirect ? "directDownload" : "packageDownloadWithFileIds");
|
||||
|
||||
Promise<String> fallbackPromise = Promise.promise();
|
||||
fallbackPromise.future().onSuccess(url -> {
|
||||
promise.complete(url);
|
||||
}).onFailure(err -> {
|
||||
log.warn("乐云第一种下载方式失败，尝试另一种: {}", err.getMessage());
|
||||
if (useDirect) {
|
||||
getDownURLForById(shareId, fileId, promise);
|
||||
} else {
|
||||
getDownURLDirect(shareId, fileId, promise);
|
||||
}
|
||||
});
|
||||
|
||||
if (useDirect) {
|
||||
getDownURLDirect(shareId, fileId, fallbackPromise);
|
||||
} else {
|
||||
getDownURLForById(shareId, fileId, fallbackPromise);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -74,28 +74,54 @@ cache:
|
||||
type: h2db
|
||||
# 默认时长: 单位分钟，大部分网盘未严格验证，建议不要太大
|
||||
defaultDuration: 5
|
||||
# 具体网盘的缓存配置，如果不加配置则不缓存，每次请求都会请求网盘API，格式：网盘标识: 时长
|
||||
# 具体网盘的缓存配置（单位：分钟）
|
||||
# - 配置 key 且有值（如 le: 2879）：使用指定时长
|
||||
# - 配置 key 但无值（如 fc:）：使用上面的 defaultDuration
|
||||
# - 未配置的 key：不缓存，每次都请求网盘API
|
||||
# 格式：网盘标识: 时长
|
||||
duration:
|
||||
ce: 5
|
||||
cow: 5
|
||||
ec: 5
|
||||
fc:
|
||||
fj: 20
|
||||
iz: 20
|
||||
le: 2879
|
||||
lz: 20
|
||||
qq: 9999999
|
||||
qqw: 30
|
||||
ws: 10
|
||||
ye: -1
|
||||
mne: 30
|
||||
mqq: 30
|
||||
mkg: 30
|
||||
p115: 30
|
||||
ct: 30
|
||||
qishui_music: 5
|
||||
baidu_photo: 5
|
||||
migu: 5
|
||||
# ---- 网盘类 ----
|
||||
ce: 5 # Cloudreve
|
||||
cow: 5 # 奶牛快传
|
||||
ct: 30 # 城通网盘
|
||||
ec: 5 # 移动云空间
|
||||
fc: # 亿方云
|
||||
fj: 20 # 小飞机网盘
|
||||
fs: # 飞书云盘
|
||||
iz: 20 # 蓝奏云优享
|
||||
kd: # 可道云
|
||||
le: 2879 # 联想乐云
|
||||
lz: 20 # 蓝奏云
|
||||
other: # 其他网盘
|
||||
p115: 30 # 115网盘
|
||||
pdb: # Dropbox
|
||||
pcx: # 超星云盘（需要 referer 头）
|
||||
pgd: # Google Drive
|
||||
pic: # iCloud
|
||||
pod: # OneDrive
|
||||
pvyy: # 微雨云存储
|
||||
pwps: # WPS云文档
|
||||
qk: # 夸克网盘
|
||||
qq: 9999999 # QQ邮箱中转站 (iwx.mail.qq.com/ftn/download)
|
||||
qqsc: # QQ闪传 (qfile.qq.com)
|
||||
qqw: 30 # QQ邮箱云盘 (wx.mail.qq.com/s)
|
||||
uc: # UC网盘
|
||||
ws: 10 # 文叔叔
|
||||
ye: -1 # 123网盘
|
||||
|
||||
# ---- 音乐类 ----
|
||||
baidu_photo: 5 # 百度网盘相册
|
||||
migu: 5 # 咪咕音乐
|
||||
mkg: 30 # 酷狗音乐
|
||||
mkgs: # 酷狗音乐分享短链
|
||||
mkgs2: # 酷狗音乐分享2（share/*.html）
|
||||
mkws: # 酷我音乐分享
|
||||
mmgs: # 咪咕音乐分享短链
|
||||
mne: 30 # 网易云音乐
|
||||
mnes: # 网易云音乐分享短链
|
||||
mqq: 30 # QQ音乐
|
||||
mqqs: # QQ音乐分享短链
|
||||
qishui_music: 5 # 汽水音乐
|
||||
|
||||
# httpClient静态代理服务器配置(外网代理)
|
||||
proxy:
|
||||
|
||||
Reference in New Issue
Block a user