mirror of
https://github.com/qaiu/netdisk-fast-download.git
synced 2026-04-19 07:06:55 +00:00
Compare commits
9 Commits
copilot/vs
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b967c7a1bb | ||
|
|
519dbe1f77 | ||
|
|
c64855d4ad | ||
|
|
d50d10ba89 | ||
|
|
e79478c421 | ||
|
|
c401a84eb8 | ||
|
|
a9978a6202 | ||
|
|
a45a64380c | ||
|
|
df7442c3dd |
@@ -86,6 +86,7 @@ https://nfd-parser.github.io/nfd-preview/preview.html?src=https%3A%2F%2Flz.qaiu.
|
|||||||
- [Cloudreve自建网盘-ce](https://github.com/cloudreve/Cloudreve)
|
- [Cloudreve自建网盘-ce](https://github.com/cloudreve/Cloudreve)
|
||||||
- ~[微雨云存储-pvvy](https://www.vyuyun.com/)~
|
- ~[微雨云存储-pvvy](https://www.vyuyun.com/)~
|
||||||
- [超星云盘(需要referer: https://pan-yz.chaoxing.com)-pcx](https://pan-yz.chaoxing.com)
|
- [超星云盘(需要referer: https://pan-yz.chaoxing.com)-pcx](https://pan-yz.chaoxing.com)
|
||||||
|
- [飞书云盘-fs](https://www.feishu.cn/)
|
||||||
- [WPS云文档-pwps](https://www.kdocs.cn/)
|
- [WPS云文档-pwps](https://www.kdocs.cn/)
|
||||||
- [汽水音乐-qishui_music](https://music.douyin.com/qishui/)
|
- [汽水音乐-qishui_music](https://music.douyin.com/qishui/)
|
||||||
- [咪咕音乐-migu](https://music.migu.cn/)
|
- [咪咕音乐-migu](https://music.migu.cn/)
|
||||||
@@ -340,6 +341,7 @@ json返回数据格式示例:
|
|||||||
| WPS云文档 | √ | X | 5G(免费) | 10M(免费)/2G(会员) |
|
| WPS云文档 | √ | X | 5G(免费) | 10M(免费)/2G(会员) |
|
||||||
| 夸克网盘 | x | √ | 10G | 不限大小 |
|
| 夸克网盘 | x | √ | 10G | 不限大小 |
|
||||||
| UC网盘 | x | √ | 10G | 不限大小 |
|
| UC网盘 | x | √ | 10G | 不限大小 |
|
||||||
|
| 飞书云盘 | √ | X | 15G | 不限大小 |
|
||||||
|
|
||||||
# 打包部署
|
# 打包部署
|
||||||
|
|
||||||
|
|||||||
@@ -115,9 +115,9 @@ public enum PanDomainTemplate {
|
|||||||
"https://www.feijix.com/s/{shareKey}",
|
"https://www.feijix.com/s/{shareKey}",
|
||||||
FjTool.class),
|
FjTool.class),
|
||||||
|
|
||||||
// https://lecloud.lenovo.com/share/
|
// https://lecloud.lenovo.com/share/ https://lecloud.lenovo.com/mshare/
|
||||||
LE("联想乐云",
|
LE("联想乐云",
|
||||||
compile("https://lecloud\\.lenovo\\.com/share/(?<KEY>.+)"),
|
compile("https://lecloud\\.lenovo\\.com/m?share/(?<KEY>.+)"),
|
||||||
"https://lecloud.lenovo.com/share/{shareKey}",
|
"https://lecloud.lenovo.com/share/{shareKey}",
|
||||||
LeTool.class),
|
LeTool.class),
|
||||||
|
|
||||||
@@ -313,6 +313,14 @@ public enum PanDomainTemplate {
|
|||||||
"https://pan.quark.cn/s/{shareKey}",
|
"https://pan.quark.cn/s/{shareKey}",
|
||||||
QkTool.class),
|
QkTool.class),
|
||||||
|
|
||||||
|
// https://xxx.feishu.cn/file/VnCxbt35KoowKoxldO3c3C7VnMc
|
||||||
|
// https://xxx.feishu.cn/drive/folder/RQSKf8EQ4l7dMedqzHucpMbancg
|
||||||
|
FS("飞书云盘",
|
||||||
|
compile("https://[^.]+\\.feishu\\.cn/(?:file|drive/folder)/(?<KEY>[A-Za-z0-9_-]+)(\\?.*)?"),
|
||||||
|
"https://feishu.cn/file/{shareKey}",
|
||||||
|
"https://www.feishu.cn/",
|
||||||
|
FsTool.class),
|
||||||
|
|
||||||
// =====================音乐类解析 分享链接标志->MxxS (单歌曲/普通音质)==========================
|
// =====================音乐类解析 分享链接标志->MxxS (单歌曲/普通音质)==========================
|
||||||
// http://163cn.tv/xxx
|
// http://163cn.tv/xxx
|
||||||
MNES("网易云音乐分享",
|
MNES("网易云音乐分享",
|
||||||
|
|||||||
492
parser/src/main/java/cn/qaiu/parser/impl/FsTool.java
Normal file
492
parser/src/main/java/cn/qaiu/parser/impl/FsTool.java
Normal file
@@ -0,0 +1,492 @@
|
|||||||
|
package cn.qaiu.parser.impl;
|
||||||
|
|
||||||
|
import cn.qaiu.entity.FileInfo;
|
||||||
|
import cn.qaiu.entity.ShareLinkInfo;
|
||||||
|
import cn.qaiu.parser.PanBase;
|
||||||
|
import cn.qaiu.util.CommonUtils;
|
||||||
|
import io.vertx.core.Future;
|
||||||
|
import io.vertx.core.Promise;
|
||||||
|
import io.vertx.core.json.JsonArray;
|
||||||
|
import io.vertx.core.json.JsonObject;
|
||||||
|
|
||||||
|
import java.net.URLDecoder;
|
||||||
|
import java.nio.charset.StandardCharsets;
|
||||||
|
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.feishu.cn/">飞书云盘</a>
|
||||||
|
* <p>
|
||||||
|
* 支持飞书公开分享文件和文件夹的解析。
|
||||||
|
* <ul>
|
||||||
|
* <li>文件链接: https://xxx.feishu.cn/file/{token}</li>
|
||||||
|
* <li>文件夹链接: https://xxx.feishu.cn/drive/folder/{token}</li>
|
||||||
|
* </ul>
|
||||||
|
* 飞书下载需要先获取匿名会话Cookie,然后使用Cookie请求下载接口。
|
||||||
|
* </p>
|
||||||
|
*/
|
||||||
|
public class FsTool extends PanBase {
|
||||||
|
|
||||||
|
private static final String UA = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) "
|
||||||
|
+ "AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125.0.0.0 Safari/537.36";
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 飞书 obj_type: type=12 表示上传文件可下载
|
||||||
|
*/
|
||||||
|
private static final int OBJ_TYPE_FILE = 12;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* v3 列表 API 支持的 obj_type
|
||||||
|
*/
|
||||||
|
private static final int[] LIST_OBJ_TYPES = {
|
||||||
|
0, 2, 22, 44, 3, 30, 8, 11, 12, 84, 123, 124
|
||||||
|
};
|
||||||
|
|
||||||
|
/** 每页返回条目数 */
|
||||||
|
private static final int PAGE_SIZE = 50;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 从分享链接中提取 tenant 的正则
|
||||||
|
*/
|
||||||
|
private static final Pattern TENANT_PATTERN =
|
||||||
|
Pattern.compile("https://([^.]+)\\.feishu\\.cn/");
|
||||||
|
|
||||||
|
/** 解析 Content-Disposition: filename*=UTF-8''xxx */
|
||||||
|
private static final Pattern CD_FILENAME_STAR_PATTERN =
|
||||||
|
Pattern.compile("filename\\*=UTF-8''(.+?)(?:;|$)");
|
||||||
|
|
||||||
|
/** 解析 Content-Disposition: filename="xxx" 或 filename=xxx */
|
||||||
|
private static final Pattern CD_FILENAME_PATTERN =
|
||||||
|
Pattern.compile("filename=\"?([^\";]+)\"?");
|
||||||
|
|
||||||
|
/** 解析 Content-Range 中的总大小 */
|
||||||
|
private static final Pattern CONTENT_RANGE_SIZE_PATTERN =
|
||||||
|
Pattern.compile("/(\\d+)");
|
||||||
|
|
||||||
|
public FsTool(ShareLinkInfo shareLinkInfo) {
|
||||||
|
super(shareLinkInfo);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Future<String> parse() {
|
||||||
|
String shareUrl = shareLinkInfo.getShareUrl();
|
||||||
|
String tenant = extractTenant(shareUrl);
|
||||||
|
String token = shareLinkInfo.getShareKey();
|
||||||
|
|
||||||
|
if (tenant == null || token == null) {
|
||||||
|
fail("无法从链接中提取tenant或token: {}", shareUrl);
|
||||||
|
return promise.future();
|
||||||
|
}
|
||||||
|
|
||||||
|
boolean isFolder = shareUrl.contains("/drive/folder/");
|
||||||
|
if (isFolder) {
|
||||||
|
fetchSessionAndParseFolder(tenant, token, shareUrl);
|
||||||
|
} else {
|
||||||
|
fetchSessionAndParseFile(tenant, token, shareUrl);
|
||||||
|
}
|
||||||
|
|
||||||
|
return promise.future();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取匿名session后解析文件
|
||||||
|
*/
|
||||||
|
private void fetchSessionAndParseFile(String tenant, String token, String shareUrl) {
|
||||||
|
clientSession.getAbs(shareUrl)
|
||||||
|
.putHeader("User-Agent", UA)
|
||||||
|
.putHeader("Accept", "text/html,*/*")
|
||||||
|
.send()
|
||||||
|
.onSuccess(res -> {
|
||||||
|
String dlUrl = buildDownloadUrl(tenant, token);
|
||||||
|
|
||||||
|
// Range探测获取文件名和大小
|
||||||
|
clientSession.getAbs(dlUrl)
|
||||||
|
.putHeader("User-Agent", UA)
|
||||||
|
.putHeader("Referer", shareUrl)
|
||||||
|
.putHeader("Range", "bytes=0-0")
|
||||||
|
.send()
|
||||||
|
.onSuccess(probeRes -> {
|
||||||
|
String fileName = parseFileNameFromContentDisposition(
|
||||||
|
probeRes.getHeader("Content-Disposition"));
|
||||||
|
|
||||||
|
Map<String, String> headers = new HashMap<>();
|
||||||
|
headers.put("Referer", shareUrl);
|
||||||
|
headers.put("User-Agent", UA);
|
||||||
|
|
||||||
|
String cookies = extractCookiesFromResponse(probeRes);
|
||||||
|
if (cookies != null && !cookies.isEmpty()) {
|
||||||
|
headers.put("Cookie", cookies);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (fileName != null) {
|
||||||
|
FileInfo fileInfo = new FileInfo();
|
||||||
|
fileInfo.setFileName(fileName);
|
||||||
|
fileInfo.setFileId(token);
|
||||||
|
fileInfo.setFileType("file");
|
||||||
|
fileInfo.setPanType(shareLinkInfo.getType());
|
||||||
|
fileInfo.setParserUrl(buildRedirectUrl(shareUrl, token));
|
||||||
|
parseSizeFromContentRange(
|
||||||
|
probeRes.getHeader("Content-Range"), fileInfo);
|
||||||
|
shareLinkInfo.getOtherParam().put("fileInfo", fileInfo);
|
||||||
|
}
|
||||||
|
|
||||||
|
completeWithMeta(dlUrl, headers);
|
||||||
|
})
|
||||||
|
.onFailure(handleFail("探测文件信息失败"));
|
||||||
|
})
|
||||||
|
.onFailure(handleFail("获取匿名会话失败"));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取匿名session后解析文件夹(取第一个可下载文件)
|
||||||
|
*/
|
||||||
|
private void fetchSessionAndParseFolder(String tenant, String folderToken,
|
||||||
|
String shareUrl) {
|
||||||
|
clientSession.getAbs(shareUrl)
|
||||||
|
.putHeader("User-Agent", UA)
|
||||||
|
.putHeader("Accept", "text/html,*/*")
|
||||||
|
.send()
|
||||||
|
.onSuccess(res ->
|
||||||
|
listFolderAll(tenant, folderToken, "").onSuccess(items -> {
|
||||||
|
if (items.isEmpty()) {
|
||||||
|
fail("文件夹中没有可下载的文件");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
FileInfo first = items.get(0);
|
||||||
|
String objToken = first.getFileId();
|
||||||
|
String dlUrl = buildDownloadUrl(tenant, objToken);
|
||||||
|
String referer = "https://" + tenant
|
||||||
|
+ ".feishu.cn/drive/folder/" + folderToken;
|
||||||
|
|
||||||
|
Map<String, String> headers = new HashMap<>();
|
||||||
|
headers.put("Referer", referer);
|
||||||
|
headers.put("User-Agent", UA);
|
||||||
|
|
||||||
|
shareLinkInfo.getOtherParam().put("fileInfo", first);
|
||||||
|
completeWithMeta(dlUrl, headers);
|
||||||
|
}).onFailure(t -> fail("列出文件夹内容失败: {}", t.getMessage())))
|
||||||
|
.onFailure(handleFail("获取匿名会话失败"));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Future<List<FileInfo>> parseFileList() {
|
||||||
|
Promise<List<FileInfo>> listPromise = Promise.promise();
|
||||||
|
String shareUrl = shareLinkInfo.getShareUrl();
|
||||||
|
String tenant = extractTenant(shareUrl);
|
||||||
|
String token = shareLinkInfo.getShareKey();
|
||||||
|
|
||||||
|
if (tenant == null || token == null) {
|
||||||
|
listPromise.fail("无法从链接中提取tenant或token: " + shareUrl);
|
||||||
|
return listPromise.future();
|
||||||
|
}
|
||||||
|
|
||||||
|
boolean isFolder = shareUrl.contains("/drive/folder/");
|
||||||
|
|
||||||
|
clientSession.getAbs(shareUrl)
|
||||||
|
.putHeader("User-Agent", UA)
|
||||||
|
.putHeader("Accept", "text/html,*/*")
|
||||||
|
.send()
|
||||||
|
.onSuccess(res -> {
|
||||||
|
if (isFolder) {
|
||||||
|
listFolderAll(tenant, token, "")
|
||||||
|
.onSuccess(listPromise::complete)
|
||||||
|
.onFailure(listPromise::fail);
|
||||||
|
} else {
|
||||||
|
probeSingleFile(tenant, token, shareUrl)
|
||||||
|
.onSuccess(fileInfo -> {
|
||||||
|
List<FileInfo> list = new ArrayList<>();
|
||||||
|
list.add(fileInfo);
|
||||||
|
listPromise.complete(list);
|
||||||
|
})
|
||||||
|
.onFailure(listPromise::fail);
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.onFailure(t -> listPromise.fail("获取匿名会话失败: " + t.getMessage()));
|
||||||
|
|
||||||
|
return listPromise.future();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 分页获取文件夹所有可下载文件
|
||||||
|
*/
|
||||||
|
private Future<List<FileInfo>> listFolderAll(String tenant, String folderToken,
|
||||||
|
String pageLabel) {
|
||||||
|
Promise<List<FileInfo>> p = Promise.promise();
|
||||||
|
|
||||||
|
listFolderPage(tenant, folderToken, pageLabel).onSuccess(pageResult -> {
|
||||||
|
List<FileInfo> items = new ArrayList<>(pageResult.items);
|
||||||
|
if (pageResult.hasMore) {
|
||||||
|
listFolderAll(tenant, folderToken, pageResult.nextLabel)
|
||||||
|
.onSuccess(moreItems -> {
|
||||||
|
items.addAll(moreItems);
|
||||||
|
p.complete(items);
|
||||||
|
})
|
||||||
|
.onFailure(p::fail);
|
||||||
|
} else {
|
||||||
|
p.complete(items);
|
||||||
|
}
|
||||||
|
}).onFailure(p::fail);
|
||||||
|
|
||||||
|
return p.future();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 列出文件夹内容(单页)
|
||||||
|
*/
|
||||||
|
private Future<FolderPageResult> listFolderPage(String tenant, String folderToken,
|
||||||
|
String pageLabel) {
|
||||||
|
Promise<FolderPageResult> p = Promise.promise();
|
||||||
|
String baseUrl = "https://" + tenant + ".feishu.cn";
|
||||||
|
|
||||||
|
StringBuilder urlBuilder = new StringBuilder();
|
||||||
|
urlBuilder.append(baseUrl)
|
||||||
|
.append("/space/api/explorer/v3/children/list/")
|
||||||
|
.append("?length=").append(PAGE_SIZE)
|
||||||
|
.append("&asc=1&rank=5&token=").append(folderToken);
|
||||||
|
|
||||||
|
for (int type : LIST_OBJ_TYPES) {
|
||||||
|
urlBuilder.append("&obj_type=").append(type);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (pageLabel != null && !pageLabel.isEmpty()) {
|
||||||
|
urlBuilder.append("&last_label=").append(pageLabel);
|
||||||
|
}
|
||||||
|
|
||||||
|
String url = urlBuilder.toString();
|
||||||
|
String referer = baseUrl + "/drive/folder/" + folderToken;
|
||||||
|
|
||||||
|
clientSession.getAbs(url)
|
||||||
|
.putHeader("User-Agent", UA)
|
||||||
|
.putHeader("Accept", "application/json, text/plain, */*")
|
||||||
|
.putHeader("Referer", referer)
|
||||||
|
.send()
|
||||||
|
.onSuccess(res -> {
|
||||||
|
try {
|
||||||
|
JsonObject json = asJson(res);
|
||||||
|
int code = json.getInteger("code", -1);
|
||||||
|
if (code != 0) {
|
||||||
|
p.fail("飞书API错误: " + json.getString("msg"));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
JsonObject data = json.getJsonObject("data");
|
||||||
|
JsonObject entities = data.getJsonObject("entities",
|
||||||
|
new JsonObject());
|
||||||
|
JsonObject nodes = entities.getJsonObject("nodes",
|
||||||
|
new JsonObject());
|
||||||
|
JsonArray nodeList = data.getJsonArray("node_list",
|
||||||
|
new JsonArray());
|
||||||
|
|
||||||
|
List<FileInfo> items = new ArrayList<>();
|
||||||
|
for (int i = 0; i < nodeList.size(); i++) {
|
||||||
|
String nid = nodeList.getString(i);
|
||||||
|
JsonObject node = nodes.getJsonObject(nid,
|
||||||
|
new JsonObject());
|
||||||
|
int objType = node.getInteger("type", -1);
|
||||||
|
String objToken = node.getString("obj_token", "");
|
||||||
|
String name = node.getString("name", "unknown");
|
||||||
|
|
||||||
|
// 排除文件夹自身节点
|
||||||
|
if (objToken.equals(folderToken)) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 只返回可下载的文件(type=12)
|
||||||
|
if (objType == OBJ_TYPE_FILE) {
|
||||||
|
FileInfo fileInfo = new FileInfo();
|
||||||
|
fileInfo.setFileName(name);
|
||||||
|
fileInfo.setFileId(objToken);
|
||||||
|
fileInfo.setPanType(shareLinkInfo.getType());
|
||||||
|
fileInfo.setFileType("file");
|
||||||
|
|
||||||
|
JsonObject extra = node.getJsonObject("extra",
|
||||||
|
new JsonObject());
|
||||||
|
try {
|
||||||
|
long size = Long.parseLong(
|
||||||
|
extra.getString("size", "0"));
|
||||||
|
fileInfo.setSize(size);
|
||||||
|
} catch (NumberFormatException e) {
|
||||||
|
log.warn("无法解析文件大小: {}", extra.getString("size"), e);
|
||||||
|
}
|
||||||
|
|
||||||
|
fileInfo.setParserUrl(buildRedirectUrl(
|
||||||
|
shareLinkInfo.getShareUrl(), objToken));
|
||||||
|
|
||||||
|
// 添加下载所需的请求头到extParameters
|
||||||
|
Map<String, Object> extParams = new HashMap<>();
|
||||||
|
Map<String, String> downloadHeaders = new HashMap<>();
|
||||||
|
downloadHeaders.put("Referer", referer);
|
||||||
|
downloadHeaders.put("User-Agent", UA);
|
||||||
|
extParams.put("downloadHeaders", downloadHeaders);
|
||||||
|
fileInfo.setExtParameters(extParams);
|
||||||
|
|
||||||
|
items.add(fileInfo);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
boolean hasMore = data.getBoolean("has_more", false);
|
||||||
|
String nextLabel = data.getString("last_label", "");
|
||||||
|
|
||||||
|
p.complete(new FolderPageResult(items, hasMore, nextLabel));
|
||||||
|
} catch (Exception e) {
|
||||||
|
p.fail("解析文件列表响应失败: " + e.getMessage());
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.onFailure(t -> p.fail("请求文件列表失败: " + t.getMessage()));
|
||||||
|
|
||||||
|
return p.future();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 探测单个文件信息
|
||||||
|
*/
|
||||||
|
private Future<FileInfo> probeSingleFile(String tenant, String token,
|
||||||
|
String referer) {
|
||||||
|
Promise<FileInfo> p = Promise.promise();
|
||||||
|
String dlUrl = buildDownloadUrl(tenant, token);
|
||||||
|
|
||||||
|
clientSession.getAbs(dlUrl)
|
||||||
|
.putHeader("User-Agent", UA)
|
||||||
|
.putHeader("Referer", referer)
|
||||||
|
.putHeader("Range", "bytes=0-0")
|
||||||
|
.send()
|
||||||
|
.onSuccess(probeRes -> {
|
||||||
|
FileInfo fileInfo = new FileInfo();
|
||||||
|
String fileName = parseFileNameFromContentDisposition(
|
||||||
|
probeRes.getHeader("Content-Disposition"));
|
||||||
|
if (fileName != null) {
|
||||||
|
fileInfo.setFileName(fileName);
|
||||||
|
}
|
||||||
|
parseSizeFromContentRange(
|
||||||
|
probeRes.getHeader("Content-Range"), fileInfo);
|
||||||
|
fileInfo.setFileId(token);
|
||||||
|
fileInfo.setPanType(shareLinkInfo.getType());
|
||||||
|
fileInfo.setFileType("file");
|
||||||
|
fileInfo.setParserUrl(buildRedirectUrl(referer, token));
|
||||||
|
|
||||||
|
// 添加下载所需的请求头到extParameters
|
||||||
|
Map<String, Object> extParams = new HashMap<>();
|
||||||
|
Map<String, String> downloadHeaders = new HashMap<>();
|
||||||
|
downloadHeaders.put("Referer", referer);
|
||||||
|
downloadHeaders.put("User-Agent", UA);
|
||||||
|
extParams.put("downloadHeaders", downloadHeaders);
|
||||||
|
fileInfo.setExtParameters(extParams);
|
||||||
|
|
||||||
|
p.complete(fileInfo);
|
||||||
|
})
|
||||||
|
.onFailure(t -> p.fail("探测文件失败: " + t.getMessage()));
|
||||||
|
|
||||||
|
return p.future();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Future<String> parseById() {
|
||||||
|
Promise<String> parsePromise = Promise.promise();
|
||||||
|
|
||||||
|
try {
|
||||||
|
JsonObject paramJson = (JsonObject) shareLinkInfo.getOtherParam().get("paramJson");
|
||||||
|
String shareUrl = paramJson.getString("shareUrl");
|
||||||
|
String objToken = paramJson.getString("objToken");
|
||||||
|
String tenant = extractTenant(shareUrl);
|
||||||
|
|
||||||
|
if (shareUrl == null || objToken == null || tenant == null) {
|
||||||
|
parsePromise.fail("飞书目录文件下载参数不完整");
|
||||||
|
return parsePromise.future();
|
||||||
|
}
|
||||||
|
|
||||||
|
parsePromise.complete(buildDownloadUrl(tenant, objToken));
|
||||||
|
} catch (Exception e) {
|
||||||
|
parsePromise.fail("解析飞书目录文件参数失败: " + e.getMessage());
|
||||||
|
}
|
||||||
|
|
||||||
|
return parsePromise.future();
|
||||||
|
}
|
||||||
|
|
||||||
|
// ─── 工具方法 ────────────────────────────────────────
|
||||||
|
|
||||||
|
private String buildRedirectUrl(String shareUrl, String objToken) {
|
||||||
|
JsonObject paramJson = new JsonObject()
|
||||||
|
.put("shareUrl", shareUrl)
|
||||||
|
.put("objToken", objToken);
|
||||||
|
return String.format("%s/v2/redirectUrl/%s/%s",
|
||||||
|
getDomainName(),
|
||||||
|
shareLinkInfo.getType(),
|
||||||
|
CommonUtils.urlBase64Encode(paramJson.encode()));
|
||||||
|
}
|
||||||
|
|
||||||
|
private String buildDownloadUrl(String tenant, String objToken) {
|
||||||
|
return "https://" + tenant
|
||||||
|
+ ".feishu.cn/space/api/box/stream/download/all/" + objToken;
|
||||||
|
}
|
||||||
|
|
||||||
|
private String extractTenant(String url) {
|
||||||
|
if (url == null) return null;
|
||||||
|
Matcher m = TENANT_PATTERN.matcher(url);
|
||||||
|
if (m.find()) {
|
||||||
|
return m.group(1);
|
||||||
|
}
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 从Content-Disposition头解析文件名。
|
||||||
|
* 支持 filename*=UTF-8''xxx 和 filename="xxx" 两种格式。
|
||||||
|
*/
|
||||||
|
private String parseFileNameFromContentDisposition(String cd) {
|
||||||
|
if (cd == null || cd.isEmpty()) return null;
|
||||||
|
|
||||||
|
// 优先解析 filename*=UTF-8''xxx
|
||||||
|
Matcher m1 = CD_FILENAME_STAR_PATTERN.matcher(cd);
|
||||||
|
if (m1.find()) {
|
||||||
|
try {
|
||||||
|
return URLDecoder.decode(m1.group(1).trim(), StandardCharsets.UTF_8);
|
||||||
|
} catch (Exception ignored) {
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 降级解析 filename="xxx" 或 filename=xxx
|
||||||
|
Matcher m2 = CD_FILENAME_PATTERN.matcher(cd);
|
||||||
|
if (m2.find()) {
|
||||||
|
try {
|
||||||
|
return URLDecoder.decode(m2.group(1).trim(), StandardCharsets.UTF_8);
|
||||||
|
} catch (Exception ignored) {
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void parseSizeFromContentRange(String cr, FileInfo fileInfo) {
|
||||||
|
if (cr != null) {
|
||||||
|
Matcher m = CONTENT_RANGE_SIZE_PATTERN.matcher(cr);
|
||||||
|
if (m.find()) {
|
||||||
|
fileInfo.setSize(Long.parseLong(m.group(1)));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private String extractCookiesFromResponse(
|
||||||
|
io.vertx.ext.web.client.HttpResponse<?> response) {
|
||||||
|
List<String> setCookies = response.cookies();
|
||||||
|
if (setCookies == null || setCookies.isEmpty()) return null;
|
||||||
|
|
||||||
|
StringBuilder sb = new StringBuilder();
|
||||||
|
for (String cookie : setCookies) {
|
||||||
|
String nameValue = cookie.split(";")[0].trim();
|
||||||
|
if (!sb.isEmpty()) sb.append("; ");
|
||||||
|
sb.append(nameValue);
|
||||||
|
}
|
||||||
|
return sb.toString();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 文件夹分页结果
|
||||||
|
*/
|
||||||
|
private record FolderPageResult(List<FileInfo> items, boolean hasMore,
|
||||||
|
String nextLabel) {
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -161,14 +161,23 @@ public class PanDomainTemplateTest {
|
|||||||
public void testLePatternFix() {
|
public void testLePatternFix() {
|
||||||
Pattern lePattern = PanDomainTemplate.LE.getPattern();
|
Pattern lePattern = PanDomainTemplate.LE.getPattern();
|
||||||
|
|
||||||
// lecloud.lenovo.com 应匹配
|
// /share/ 格式应匹配
|
||||||
Matcher m1 = lePattern.matcher("https://lecloud.lenovo.com/share/abc123");
|
Matcher m1 = lePattern.matcher("https://lecloud.lenovo.com/share/abc123");
|
||||||
assertTrue("LE should match lecloud.lenovo.com", m1.find());
|
assertTrue("LE should match /share/ format", m1.find());
|
||||||
assertEquals("abc123", m1.group("KEY"));
|
assertEquals("abc123", m1.group("KEY"));
|
||||||
|
|
||||||
// leclou.lenovo.com (去掉'd') 不应匹配(原 lecloud? 的 bug)
|
// /mshare/ 格式应匹配
|
||||||
|
Matcher m2 = lePattern.matcher("https://lecloud.lenovo.com/mshare/xyz789");
|
||||||
|
assertTrue("LE should match /mshare/ format", m2.find());
|
||||||
|
assertEquals("xyz789", m2.group("KEY"));
|
||||||
|
|
||||||
|
// leclou.lenovo.com (去掉'd') 不应匹配
|
||||||
assertFalse("LE should NOT match leclou.lenovo.com",
|
assertFalse("LE should NOT match leclou.lenovo.com",
|
||||||
lePattern.matcher("https://leclou.lenovo.com/share/abc123").find());
|
lePattern.matcher("https://leclou.lenovo.com/share/abc123").find());
|
||||||
|
|
||||||
|
// 错误路径不应匹配
|
||||||
|
assertFalse("LE should NOT match wrong path",
|
||||||
|
lePattern.matcher("https://lecloud.lenovo.com/s/abc123").find());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
@@ -250,6 +259,72 @@ public class PanDomainTemplateTest {
|
|||||||
assertEquals("151bR-nk-tOBm9QAFaozJIVt2WYyCMkoz", m2.group("KEY"));
|
assertEquals("151bR-nk-tOBm9QAFaozJIVt2WYyCMkoz", m2.group("KEY"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testFsPatternMatching() {
|
||||||
|
Pattern fsPattern = PanDomainTemplate.FS.getPattern();
|
||||||
|
|
||||||
|
// 文件链接
|
||||||
|
Matcher m1 = fsPattern.matcher(
|
||||||
|
"https://kcncuknojm60.feishu.cn/file/VnCxbt35KoowKoxldO3c3C7VnMc");
|
||||||
|
assertTrue("FS should match file link", m1.matches());
|
||||||
|
assertEquals("VnCxbt35KoowKoxldO3c3C7VnMc", m1.group("KEY"));
|
||||||
|
|
||||||
|
// 文件链接带 ?from=from_copylink
|
||||||
|
Matcher m2 = fsPattern.matcher(
|
||||||
|
"https://kcncuknojm60.feishu.cn/file/VnCxbt35KoowKoxldO3c3C7VnMc?from=from_copylink");
|
||||||
|
assertTrue("FS should match file link with query param", m2.matches());
|
||||||
|
assertEquals("VnCxbt35KoowKoxldO3c3C7VnMc", m2.group("KEY"));
|
||||||
|
|
||||||
|
// 文件夹链接
|
||||||
|
Matcher m3 = fsPattern.matcher(
|
||||||
|
"https://kcncuknojm60.feishu.cn/drive/folder/RQSKf8EQ4l7dMedqzHucpMbancg");
|
||||||
|
assertTrue("FS should match folder link", m3.matches());
|
||||||
|
assertEquals("RQSKf8EQ4l7dMedqzHucpMbancg", m3.group("KEY"));
|
||||||
|
|
||||||
|
// 文件夹链接带 ?from=from_copylink
|
||||||
|
Matcher m4 = fsPattern.matcher(
|
||||||
|
"https://kcncuknojm60.feishu.cn/drive/folder/RQSKf8EQ4l7dMedqzHucpMbancg?from=from_copylink");
|
||||||
|
assertTrue("FS should match folder link with query param", m4.matches());
|
||||||
|
assertEquals("RQSKf8EQ4l7dMedqzHucpMbancg", m4.group("KEY"));
|
||||||
|
|
||||||
|
// 不同的 tenant 子域名
|
||||||
|
Matcher m5 = fsPattern.matcher(
|
||||||
|
"https://pokepangle.feishu.cn/file/VW30bpK74ontiTxvRg1cZcgvnGg");
|
||||||
|
assertTrue("FS should match different tenant", m5.matches());
|
||||||
|
assertEquals("VW30bpK74ontiTxvRg1cZcgvnGg", m5.group("KEY"));
|
||||||
|
|
||||||
|
// 负例: 非feishu域名不匹配
|
||||||
|
assertFalse("FS should NOT match non-feishu domain",
|
||||||
|
fsPattern.matcher("https://evil.com/file/abc123").matches());
|
||||||
|
|
||||||
|
// 负例: feishu.cn上的其他路径不匹配
|
||||||
|
assertFalse("FS should NOT match other feishu paths",
|
||||||
|
fsPattern.matcher("https://xxx.feishu.cn/docs/abc123").matches());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testFsFromShareUrl() {
|
||||||
|
// 测试文件链接解析
|
||||||
|
String fileUrl = "https://kcncuknojm60.feishu.cn/file/VnCxbt35KoowKoxldO3c3C7VnMc?from=from_copylink";
|
||||||
|
ParserCreate parserCreate = ParserCreate.fromShareUrl(fileUrl);
|
||||||
|
ShareLinkInfo info = parserCreate.getShareLinkInfo();
|
||||||
|
|
||||||
|
assertNotNull("ShareLinkInfo should not be null", info);
|
||||||
|
assertEquals("fs", info.getType());
|
||||||
|
assertEquals("飞书云盘", info.getPanName());
|
||||||
|
assertEquals("VnCxbt35KoowKoxldO3c3C7VnMc", info.getShareKey());
|
||||||
|
|
||||||
|
// 测试文件夹链接解析
|
||||||
|
String folderUrl = "https://kcncuknojm60.feishu.cn/drive/folder/RQSKf8EQ4l7dMedqzHucpMbancg";
|
||||||
|
ParserCreate parserCreate2 = ParserCreate.fromShareUrl(folderUrl);
|
||||||
|
ShareLinkInfo info2 = parserCreate2.getShareLinkInfo();
|
||||||
|
|
||||||
|
assertNotNull("ShareLinkInfo should not be null", info2);
|
||||||
|
assertEquals("fs", info2.getType());
|
||||||
|
assertEquals("飞书云盘", info2.getPanName());
|
||||||
|
assertEquals("RQSKf8EQ4l7dMedqzHucpMbancg", info2.getShareKey());
|
||||||
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void verifyDuplicates() {
|
public void verifyDuplicates() {
|
||||||
|
|
||||||
|
|||||||
@@ -11,6 +11,8 @@
|
|||||||
content="Netdisk fast download 网盘直链解析工具">
|
content="Netdisk fast download 网盘直链解析工具">
|
||||||
<!-- Font Awesome 图标库 - 使用国内CDN -->
|
<!-- Font Awesome 图标库 - 使用国内CDN -->
|
||||||
<link rel="stylesheet" href="https://cdn.bootcdn.net/ajax/libs/font-awesome/6.4.0/css/all.min.css">
|
<link rel="stylesheet" href="https://cdn.bootcdn.net/ajax/libs/font-awesome/6.4.0/css/all.min.css">
|
||||||
|
<!-- 迅雷 JS-SDK -->
|
||||||
|
<script src="//open.thunderurl.com/thunder-link.js"></script>
|
||||||
<style>
|
<style>
|
||||||
.page-loading-wrap {
|
.page-loading-wrap {
|
||||||
padding: 120px;
|
padding: 120px;
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
266
web-front/src/components/DownloadDialog.vue
Normal file
266
web-front/src/components/DownloadDialog.vue
Normal file
@@ -0,0 +1,266 @@
|
|||||||
|
<template>
|
||||||
|
<el-dialog
|
||||||
|
title="文件下载"
|
||||||
|
v-model="dialogVisible"
|
||||||
|
width="600px"
|
||||||
|
:close-on-click-modal="false"
|
||||||
|
@close="$emit('update:visible', false)"
|
||||||
|
>
|
||||||
|
<div v-if="info" class="download-info-content">
|
||||||
|
<div class="download-file-header">
|
||||||
|
<i class="fas fa-file" style="margin-right: 8px; color: #409eff;"></i>
|
||||||
|
<strong>{{ info.fileName || '未命名文件' }}</strong>
|
||||||
|
</div>
|
||||||
|
<el-alert
|
||||||
|
title="该文件需要特殊请求头才能下载,无法直接通过浏览器下载。请使用以下方式之一:"
|
||||||
|
type="warning"
|
||||||
|
:closable="false"
|
||||||
|
show-icon
|
||||||
|
style="margin-bottom: 16px;"
|
||||||
|
/>
|
||||||
|
<el-tabs v-model="activeTab">
|
||||||
|
<el-tab-pane label="发送到下载器" name="downloader">
|
||||||
|
<div class="downloader-section">
|
||||||
|
<template v-if="isThunder">
|
||||||
|
<p v-if="thunderNeedsCookie" style="color: #f56c6c; margin-bottom: 12px;">
|
||||||
|
<i class="fas fa-exclamation-circle"></i>
|
||||||
|
该文件需要 Cookie 认证,迅雷不支持自定义 Cookie,请切换到 Aria2/Motrix/Gopeed
|
||||||
|
</p>
|
||||||
|
<p v-else-if="thunderNeedsUa" style="color: #e6a23c; margin-bottom: 12px;">
|
||||||
|
<i class="fas fa-exclamation-triangle"></i>
|
||||||
|
该文件需要特殊 User-Agent 才能下载,迅雷客户端可能不支持自定义 UA,下载可能失败。建议切换到 Aria2/Motrix/Gopeed
|
||||||
|
</p>
|
||||||
|
<p v-else style="color: #909399; margin-bottom: 12px;">
|
||||||
|
<i class="fas fa-bolt"></i>
|
||||||
|
迅雷将通过浏览器唤起本地客户端下载
|
||||||
|
</p>
|
||||||
|
</template>
|
||||||
|
<template v-else>
|
||||||
|
<p v-if="!connected" style="color: #e6a23c; margin-bottom: 12px;">
|
||||||
|
<i class="fas fa-exclamation-triangle"></i>
|
||||||
|
未检测到下载器连接,请先在首页配置下载器(Aria2/Motrix/Gopeed/迅雷)
|
||||||
|
</p>
|
||||||
|
<p v-else style="color: #67c23a; margin-bottom: 12px;">
|
||||||
|
<i class="fas fa-check-circle"></i>
|
||||||
|
下载器已连接 ({{ downloaderVersion }})
|
||||||
|
</p>
|
||||||
|
</template>
|
||||||
|
<el-button
|
||||||
|
type="success"
|
||||||
|
@click="sendToDownloader"
|
||||||
|
:disabled="(isThunder && thunderNeedsCookie) || (!isThunder && !connected)"
|
||||||
|
:loading="sending"
|
||||||
|
>
|
||||||
|
<i class="fas fa-paper-plane"></i> 发送到下载器
|
||||||
|
</el-button>
|
||||||
|
<el-button
|
||||||
|
v-if="!isThunder"
|
||||||
|
size="small"
|
||||||
|
@click="doTestConnection"
|
||||||
|
style="margin-left: 8px;"
|
||||||
|
>
|
||||||
|
测试连接
|
||||||
|
</el-button>
|
||||||
|
</div>
|
||||||
|
</el-tab-pane>
|
||||||
|
<el-tab-pane label="Aria2 命令" name="aria2">
|
||||||
|
<el-input
|
||||||
|
type="textarea"
|
||||||
|
:model-value="info.aria2Command"
|
||||||
|
:rows="4"
|
||||||
|
readonly
|
||||||
|
resize="none"
|
||||||
|
class="download-command-textarea"
|
||||||
|
/>
|
||||||
|
<div class="download-actions">
|
||||||
|
<el-button type="primary" size="small" @click="copyText(info.aria2Command)">
|
||||||
|
<i class="fas fa-copy"></i> 复制 Aria2 命令
|
||||||
|
</el-button>
|
||||||
|
</div>
|
||||||
|
</el-tab-pane>
|
||||||
|
<el-tab-pane label="Curl 命令" name="curl">
|
||||||
|
<el-input
|
||||||
|
type="textarea"
|
||||||
|
:model-value="info.curlCommand"
|
||||||
|
:rows="4"
|
||||||
|
readonly
|
||||||
|
resize="none"
|
||||||
|
class="download-command-textarea"
|
||||||
|
/>
|
||||||
|
<div class="download-actions">
|
||||||
|
<el-button type="primary" size="small" @click="copyText(info.curlCommand)">
|
||||||
|
<i class="fas fa-copy"></i> 复制 Curl 命令
|
||||||
|
</el-button>
|
||||||
|
</div>
|
||||||
|
</el-tab-pane>
|
||||||
|
</el-tabs>
|
||||||
|
<div style="margin-top: 16px; text-align: right;">
|
||||||
|
<el-button size="small" type="warning" @click="doDirectDownload">
|
||||||
|
直接打开链接(可能失败)
|
||||||
|
</el-button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</el-dialog>
|
||||||
|
</template>
|
||||||
|
|
||||||
|
<script>
|
||||||
|
import { testConnection, addDownload, getConfig, hasCookieHeader, hasCustomUaHeader } from '@/utils/downloaderService'
|
||||||
|
|
||||||
|
export default {
|
||||||
|
name: 'DownloadDialog',
|
||||||
|
props: {
|
||||||
|
/** v-model:visible 控制弹窗显示 */
|
||||||
|
visible: {
|
||||||
|
type: Boolean,
|
||||||
|
default: false
|
||||||
|
},
|
||||||
|
/**
|
||||||
|
* 下载信息对象
|
||||||
|
* { downloadUrl, fileName, downloadHeaders, aria2Command, curlCommand, aria2JsonRpc, needDownloader }
|
||||||
|
*/
|
||||||
|
downloadInfo: {
|
||||||
|
type: Object,
|
||||||
|
default: null
|
||||||
|
}
|
||||||
|
},
|
||||||
|
emits: ['update:visible', 'close'],
|
||||||
|
data() {
|
||||||
|
return {
|
||||||
|
activeTab: 'downloader',
|
||||||
|
connected: false,
|
||||||
|
downloaderVersion: '',
|
||||||
|
sending: false
|
||||||
|
}
|
||||||
|
},
|
||||||
|
computed: {
|
||||||
|
dialogVisible: {
|
||||||
|
get() { return this.visible },
|
||||||
|
set(val) { this.$emit('update:visible', val) }
|
||||||
|
},
|
||||||
|
info() { return this.downloadInfo },
|
||||||
|
isThunder() { return getConfig().downloaderType === 'thunder' },
|
||||||
|
thunderNeedsCookie() { return this.isThunder && this.info && hasCookieHeader(this.info.downloadHeaders) },
|
||||||
|
thunderNeedsUa() { return this.isThunder && this.info && hasCustomUaHeader(this.info.downloadHeaders) }
|
||||||
|
},
|
||||||
|
watch: {
|
||||||
|
visible(val) {
|
||||||
|
if (val) {
|
||||||
|
this.activeTab = 'downloader'
|
||||||
|
this.checkConnection()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
methods: {
|
||||||
|
/** 检测下载器连接状态 */
|
||||||
|
async checkConnection() {
|
||||||
|
const result = await testConnection()
|
||||||
|
this.connected = result.connected
|
||||||
|
this.downloaderVersion = result.version
|
||||||
|
},
|
||||||
|
|
||||||
|
/** 手动测试连接 */
|
||||||
|
async doTestConnection() {
|
||||||
|
const result = await testConnection()
|
||||||
|
this.connected = result.connected
|
||||||
|
this.downloaderVersion = result.version
|
||||||
|
if (result.connected) {
|
||||||
|
this.$message.success(`下载器连接正常 (${result.version})`)
|
||||||
|
} else {
|
||||||
|
this.$message.error('无法连接到下载器,请检查配置')
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
/** 发送到 Aria2/Motrix/Gopeed */
|
||||||
|
async sendToDownloader() {
|
||||||
|
if (!this.info) return
|
||||||
|
this.sending = true
|
||||||
|
try {
|
||||||
|
const gid = await addDownload(
|
||||||
|
this.info.downloadUrl,
|
||||||
|
this.info.downloadHeaders,
|
||||||
|
this.info.fileName
|
||||||
|
)
|
||||||
|
this.$message.success('已发送到下载器,任务ID: ' + gid)
|
||||||
|
this.dialogVisible = false
|
||||||
|
} catch (error) {
|
||||||
|
console.error('发送到下载器失败:', error)
|
||||||
|
this.$message.error('发送到下载器失败: ' + (error.message || '未知错误'))
|
||||||
|
} finally {
|
||||||
|
this.sending = false
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
/** 直接打开下载链接(可能因缺请求头而失败) */
|
||||||
|
doDirectDownload() {
|
||||||
|
if (this.info && this.info.downloadUrl) {
|
||||||
|
const a = document.createElement('a')
|
||||||
|
a.href = this.info.downloadUrl
|
||||||
|
a.target = '_blank'
|
||||||
|
a.rel = 'noopener noreferrer'
|
||||||
|
document.body.appendChild(a)
|
||||||
|
a.click()
|
||||||
|
document.body.removeChild(a)
|
||||||
|
this.dialogVisible = false
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
/** 复制文本到剪贴板 */
|
||||||
|
async copyText(text) {
|
||||||
|
if (!text) return
|
||||||
|
try {
|
||||||
|
await navigator.clipboard.writeText(text)
|
||||||
|
this.$message.success('已复制到剪贴板')
|
||||||
|
} catch {
|
||||||
|
const textarea = document.createElement('textarea')
|
||||||
|
textarea.value = text
|
||||||
|
textarea.style.position = 'fixed'
|
||||||
|
textarea.style.opacity = '0'
|
||||||
|
document.body.appendChild(textarea)
|
||||||
|
textarea.select()
|
||||||
|
document.execCommand('copy')
|
||||||
|
document.body.removeChild(textarea)
|
||||||
|
this.$message.success('已复制到剪贴板')
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<style scoped>
|
||||||
|
.download-info-content {
|
||||||
|
padding: 0 4px;
|
||||||
|
}
|
||||||
|
.download-file-header {
|
||||||
|
font-size: 16px;
|
||||||
|
margin-bottom: 12px;
|
||||||
|
padding: 10px 14px;
|
||||||
|
background: #f0f7ff;
|
||||||
|
border-radius: 8px;
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
word-break: break-all;
|
||||||
|
}
|
||||||
|
:deep(.dark) .download-file-header,
|
||||||
|
.dark-theme .download-file-header {
|
||||||
|
background: #1a3350;
|
||||||
|
}
|
||||||
|
.download-command-textarea :deep(.el-textarea__inner) {
|
||||||
|
font-family: 'Courier New', Courier, monospace;
|
||||||
|
font-size: 12px;
|
||||||
|
background: #f5f5f5;
|
||||||
|
color: #333;
|
||||||
|
}
|
||||||
|
:deep(.dark) .download-command-textarea :deep(.el-textarea__inner),
|
||||||
|
.dark-theme .download-command-textarea :deep(.el-textarea__inner) {
|
||||||
|
background: #1e1e1e;
|
||||||
|
color: #d4d4d4;
|
||||||
|
}
|
||||||
|
.download-actions {
|
||||||
|
margin-top: 10px;
|
||||||
|
display: flex;
|
||||||
|
gap: 8px;
|
||||||
|
}
|
||||||
|
.downloader-section {
|
||||||
|
padding: 16px 0;
|
||||||
|
}
|
||||||
|
</style>
|
||||||
463
web-front/src/utils/downloaderService.js
Normal file
463
web-front/src/utils/downloaderService.js
Normal file
@@ -0,0 +1,463 @@
|
|||||||
|
/**
|
||||||
|
* 下载器服务 - 统一管理 Aria2/Motrix/Gopeed/迅雷 的配置读取、连接检测、RPC 调用
|
||||||
|
* 供 Home.vue、DirectoryTree.vue、DownloadDialog.vue 等共用
|
||||||
|
*/
|
||||||
|
import axios from 'axios'
|
||||||
|
|
||||||
|
const STORAGE_KEY = 'nfd-aria2-local-config'
|
||||||
|
|
||||||
|
const DEFAULT_CONFIG = {
|
||||||
|
downloaderType: 'aria2',
|
||||||
|
rpcUrl: 'http://localhost:6800/jsonrpc',
|
||||||
|
rpcSecret: '',
|
||||||
|
downloadDir: ''
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 从 localStorage 读取下载器配置
|
||||||
|
* @returns {{ downloaderType: string, rpcUrl: string, rpcSecret: string, downloadDir: string }}
|
||||||
|
*/
|
||||||
|
export function getConfig() {
|
||||||
|
try {
|
||||||
|
const raw = localStorage.getItem(STORAGE_KEY)
|
||||||
|
if (raw) {
|
||||||
|
const parsed = JSON.parse(raw)
|
||||||
|
return {
|
||||||
|
downloaderType: parsed.downloaderType || DEFAULT_CONFIG.downloaderType,
|
||||||
|
rpcUrl: parsed.rpcUrl || DEFAULT_CONFIG.rpcUrl,
|
||||||
|
rpcSecret: parsed.rpcSecret || '',
|
||||||
|
downloadDir: parsed.downloadDir || ''
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
console.warn('读取下载器配置失败', e)
|
||||||
|
}
|
||||||
|
return { ...DEFAULT_CONFIG }
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 保存下载器配置到 localStorage
|
||||||
|
* @param {{ downloaderType?: string, rpcUrl?: string, rpcSecret?: string, downloadDir?: string }} config
|
||||||
|
*/
|
||||||
|
export function saveConfig(config) {
|
||||||
|
localStorage.setItem(STORAGE_KEY, JSON.stringify(config))
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 构建 RPC 参数数组(自动添加 token)
|
||||||
|
* @param {string} rpcSecret
|
||||||
|
* @param {Array} extraParams
|
||||||
|
* @returns {Array}
|
||||||
|
*/
|
||||||
|
function buildRpcParams(rpcSecret, extraParams = []) {
|
||||||
|
const params = []
|
||||||
|
if (rpcSecret && rpcSecret.trim()) {
|
||||||
|
params.push(`token:${rpcSecret}`)
|
||||||
|
}
|
||||||
|
if (extraParams && extraParams.length > 0) {
|
||||||
|
params.push(...extraParams)
|
||||||
|
}
|
||||||
|
return params
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 调用 Aria2 JSON-RPC 接口
|
||||||
|
* @param {string} rpcUrl
|
||||||
|
* @param {string} rpcSecret
|
||||||
|
* @param {string} method - 例如 'aria2.getVersion', 'aria2.addUri'
|
||||||
|
* @param {Array} [extraParams] - 除 token 外的参数
|
||||||
|
* @param {number} [timeout=5000]
|
||||||
|
* @returns {Promise<Object>} RPC 响应的 data
|
||||||
|
*/
|
||||||
|
export async function callRpc(rpcUrl, rpcSecret, method, extraParams = [], timeout = 5000) {
|
||||||
|
const requestBody = {
|
||||||
|
jsonrpc: '2.0',
|
||||||
|
id: Date.now().toString(),
|
||||||
|
method,
|
||||||
|
params: buildRpcParams(rpcSecret, extraParams)
|
||||||
|
}
|
||||||
|
const response = await axios.post(rpcUrl, requestBody, {
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
timeout
|
||||||
|
})
|
||||||
|
if (response.data && response.data.error) {
|
||||||
|
throw new Error(response.data.error.message || 'Aria2 RPC 错误')
|
||||||
|
}
|
||||||
|
return response.data
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 判断 rpcUrl 是否指向 Gopeed(端口 9999 或 URL 含 /api/v1)
|
||||||
|
* @param {string} url
|
||||||
|
* @returns {boolean}
|
||||||
|
*/
|
||||||
|
function isGopeedUrl(url) {
|
||||||
|
if (!url) return false
|
||||||
|
return url.includes(':9999') || url.includes('/api/v1')
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 从 Gopeed rpcUrl 中提取 baseUrl(去掉 /jsonrpc 或 /api/v1 后缀)
|
||||||
|
* 例如 "http://localhost:9999/jsonrpc" → "http://localhost:9999"
|
||||||
|
* @param {string} rpcUrl
|
||||||
|
* @returns {string}
|
||||||
|
*/
|
||||||
|
function gopeedBaseUrl(rpcUrl) {
|
||||||
|
return rpcUrl.replace(/\/jsonrpc$/, '').replace(/\/api\/v1.*$/, '')
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 调用 Gopeed REST API
|
||||||
|
* @param {string} baseUrl - 例如 "http://localhost:9999"
|
||||||
|
* @param {string} rpcSecret - Bearer token
|
||||||
|
* @param {string} method - 'GET' | 'POST'
|
||||||
|
* @param {string} path - 例如 '/api/v1/version'
|
||||||
|
* @param {Object} [body] - POST body
|
||||||
|
* @param {number} [timeout=5000]
|
||||||
|
* @returns {Promise<Object>} 响应 data
|
||||||
|
*/
|
||||||
|
async function callGopeedApi(baseUrl, rpcSecret, method, path, body, timeout = 5000) {
|
||||||
|
const headers = { 'Content-Type': 'application/json' }
|
||||||
|
if (rpcSecret && rpcSecret.trim()) {
|
||||||
|
headers['X-Api-Token'] = rpcSecret
|
||||||
|
}
|
||||||
|
const url = baseUrl.replace(/\/$/, '') + path
|
||||||
|
const response = await axios({ method, url, headers, data: body, timeout })
|
||||||
|
return response.data
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 测试下载器连接(自动识别 迅雷 / Gopeed / Aria2 / Motrix)
|
||||||
|
* @param {string} [rpcUrl] - 不传则自动读取配置
|
||||||
|
* @param {string} [rpcSecret] - 不传则自动读取配置
|
||||||
|
* @returns {Promise<{ connected: boolean, version: string }>}
|
||||||
|
*/
|
||||||
|
export async function testConnection(rpcUrl, rpcSecret) {
|
||||||
|
if (!rpcUrl) {
|
||||||
|
const config = getConfig()
|
||||||
|
// 迅雷不需要 RPC,直接检测 JS SDK
|
||||||
|
if (config.downloaderType === 'thunder') {
|
||||||
|
const available = typeof window !== 'undefined' && window.thunderLink && typeof window.thunderLink.newTask === 'function'
|
||||||
|
return { connected: available, version: available ? 'JS-SDK' : '' }
|
||||||
|
}
|
||||||
|
rpcUrl = config.rpcUrl
|
||||||
|
rpcSecret = rpcSecret ?? config.rpcSecret
|
||||||
|
}
|
||||||
|
try {
|
||||||
|
if (isGopeedUrl(rpcUrl)) {
|
||||||
|
// Gopeed 使用 REST API:GET /api/v1/info
|
||||||
|
const base = gopeedBaseUrl(rpcUrl)
|
||||||
|
const res = await callGopeedApi(base, rpcSecret || '', 'GET', '/api/v1/info', undefined, 3000)
|
||||||
|
const d = (res && res.code === 0 && res.data) ? res.data : {}
|
||||||
|
const version = [d.version, d.runtime].filter(Boolean).join(' + ') || ''
|
||||||
|
return { connected: true, version }
|
||||||
|
} else {
|
||||||
|
// Aria2 / Motrix 使用 JSON-RPC
|
||||||
|
const res = await callRpc(rpcUrl, rpcSecret || '', 'aria2.getVersion', [], 3000)
|
||||||
|
if (res && res.result && res.result.version) {
|
||||||
|
return { connected: true, version: res.result.version }
|
||||||
|
}
|
||||||
|
return { connected: false, version: '' }
|
||||||
|
}
|
||||||
|
} catch {
|
||||||
|
return { connected: false, version: '' }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 自动检测本地下载器(依次尝试 Motrix/Gopeed/Aria2)
|
||||||
|
* @param {string} [rpcSecret] - 可选密钥
|
||||||
|
* @returns {Promise<{ found: boolean, type: string, rpcUrl: string, version: string }>}
|
||||||
|
*/
|
||||||
|
export async function autoDetect(rpcSecret = '') {
|
||||||
|
const candidates = [
|
||||||
|
{ type: 'motrix', port: 16800, path: '/jsonrpc' },
|
||||||
|
{ type: 'gopeed', port: 9999, path: '/api/v1/info', gopeed: true },
|
||||||
|
{ type: 'aria2', port: 6800, path: '/jsonrpc' }
|
||||||
|
]
|
||||||
|
for (const c of candidates) {
|
||||||
|
try {
|
||||||
|
if (c.gopeed) {
|
||||||
|
// Gopeed:直接调 REST GET /api/v1/info
|
||||||
|
const base = `http://localhost:${c.port}`
|
||||||
|
const res = await callGopeedApi(base, rpcSecret || '', 'GET', '/api/v1/info', undefined, 3000)
|
||||||
|
const d = (res && res.code === 0 && res.data) ? res.data : {}
|
||||||
|
const version = [d.version, d.runtime].filter(Boolean).join(' + ') || 'unknown'
|
||||||
|
return { found: true, type: c.type, rpcUrl: `${base}/api/v1`, version }
|
||||||
|
} else {
|
||||||
|
const url = `http://localhost:${c.port}${c.path}`
|
||||||
|
const result = await testConnection(url, rpcSecret)
|
||||||
|
if (result.connected) {
|
||||||
|
return { found: true, type: c.type, rpcUrl: url, version: result.version }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch {
|
||||||
|
// 该端口未响应,继续下一个
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return { found: false, type: '', rpcUrl: '', version: '' }
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 发送下载任务到下载器(自动识别 迅雷 / Gopeed / Aria2 / Motrix)
|
||||||
|
* @param {string} downloadUrl - 文件下载地址
|
||||||
|
* @param {Object} [headers] - 请求头 {cookie, referer, user-agent, ...}
|
||||||
|
* @param {string} [fileName] - 输出文件名
|
||||||
|
* @param {{ rpcUrl?: string, rpcSecret?: string, downloadDir?: string, downloaderType?: string }} [configOverride] - 覆盖配置
|
||||||
|
* @returns {Promise<string>} 任务 ID / GID
|
||||||
|
*/
|
||||||
|
export async function addDownload(downloadUrl, headers, fileName, configOverride) {
|
||||||
|
const config = { ...getConfig(), ...configOverride }
|
||||||
|
|
||||||
|
if (config.downloaderType === 'thunder') {
|
||||||
|
return addThunderDownload([{ url: downloadUrl, headers, fileName }], config)
|
||||||
|
}
|
||||||
|
|
||||||
|
if (isGopeedUrl(config.rpcUrl)) {
|
||||||
|
// Gopeed REST API:POST /api/v1/tasks
|
||||||
|
const base = gopeedBaseUrl(config.rpcUrl)
|
||||||
|
const extraHeader = {}
|
||||||
|
if (headers && typeof headers === 'object') {
|
||||||
|
for (const [key, value] of Object.entries(headers)) {
|
||||||
|
if (key && value) extraHeader[key] = value
|
||||||
|
}
|
||||||
|
}
|
||||||
|
const body = {
|
||||||
|
req: { url: downloadUrl, extra: { header: extraHeader } },
|
||||||
|
opt: {}
|
||||||
|
}
|
||||||
|
if (config.downloadDir) body.opt.path = config.downloadDir
|
||||||
|
const res = await callGopeedApi(base, config.rpcSecret, 'POST', '/api/v1/tasks', body, 10000)
|
||||||
|
// Gopeed 返回 { code: 0, data: "task-id" }
|
||||||
|
if (res && res.code !== undefined && res.code !== 0) throw new Error(res.message || 'Gopeed 发送失败')
|
||||||
|
if (res && res.data) return typeof res.data === 'string' ? res.data : JSON.stringify(res.data)
|
||||||
|
return 'ok'
|
||||||
|
}
|
||||||
|
|
||||||
|
// Aria2 / Motrix JSON-RPC
|
||||||
|
const options = {}
|
||||||
|
if (headers && typeof headers === 'object') {
|
||||||
|
const headerArray = []
|
||||||
|
for (const [key, value] of Object.entries(headers)) {
|
||||||
|
if (key && value) headerArray.push(`${key}: ${value}`)
|
||||||
|
}
|
||||||
|
if (headerArray.length > 0) options.header = headerArray
|
||||||
|
}
|
||||||
|
if (fileName) options.out = fileName
|
||||||
|
if (config.downloadDir) options.dir = config.downloadDir
|
||||||
|
|
||||||
|
const res = await callRpc(config.rpcUrl, config.rpcSecret, 'aria2.addUri', [[downloadUrl], options], 10000)
|
||||||
|
if (res && res.result) return res.result // GID
|
||||||
|
throw new Error('未知错误')
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 批量发送下载任务到下载器(aria2 用 system.multicall,gopeed 用 batch API,迅雷用 JS-SDK newTask)
|
||||||
|
* @param {{ url: string, headers?: Object, fileName?: string }[]} tasks - 下载任务列表
|
||||||
|
* @param {{ rpcUrl?: string, rpcSecret?: string, downloadDir?: string, downloaderType?: string }} [configOverride]
|
||||||
|
* @returns {Promise<{ succeeded: number, failed: number, errors: string[] }>}
|
||||||
|
*/
|
||||||
|
export async function batchAddDownload(tasks, configOverride) {
|
||||||
|
if (!tasks || tasks.length === 0) return { succeeded: 0, failed: 0, errors: [] }
|
||||||
|
if (tasks.length === 1) {
|
||||||
|
try {
|
||||||
|
await addDownload(tasks[0].url, tasks[0].headers, tasks[0].fileName, configOverride)
|
||||||
|
return { succeeded: 1, failed: 0, errors: [] }
|
||||||
|
} catch (e) {
|
||||||
|
return { succeeded: 0, failed: 1, errors: [e.message || '未知错误'] }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const config = { ...getConfig(), ...configOverride }
|
||||||
|
|
||||||
|
if (config.downloaderType === 'thunder') {
|
||||||
|
try {
|
||||||
|
await addThunderDownload(tasks, config)
|
||||||
|
return { succeeded: tasks.length, failed: 0, errors: [] }
|
||||||
|
} catch (e) {
|
||||||
|
return { succeeded: 0, failed: tasks.length, errors: [e.message || '迅雷下载失败'] }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (isGopeedUrl(config.rpcUrl)) {
|
||||||
|
return batchAddGopeed(tasks, config)
|
||||||
|
} else {
|
||||||
|
return batchAddAria2(tasks, config)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
async function batchAddAria2(tasks, config) {
|
||||||
|
const calls = tasks.map(task => {
|
||||||
|
const options = {}
|
||||||
|
if (task.headers && typeof task.headers === 'object') {
|
||||||
|
const headerArray = []
|
||||||
|
for (const [key, value] of Object.entries(task.headers)) {
|
||||||
|
if (key && value) headerArray.push(`${key}: ${value}`)
|
||||||
|
}
|
||||||
|
if (headerArray.length > 0) options.header = headerArray
|
||||||
|
}
|
||||||
|
if (task.fileName) options.out = task.fileName
|
||||||
|
if (config.downloadDir) options.dir = config.downloadDir
|
||||||
|
|
||||||
|
const params = []
|
||||||
|
if (config.rpcSecret && config.rpcSecret.trim()) {
|
||||||
|
params.push(`token:${config.rpcSecret}`)
|
||||||
|
}
|
||||||
|
params.push([task.url], options)
|
||||||
|
return { methodName: 'aria2.addUri', params }
|
||||||
|
})
|
||||||
|
|
||||||
|
try {
|
||||||
|
const requestBody = {
|
||||||
|
jsonrpc: '2.0',
|
||||||
|
id: Date.now().toString(),
|
||||||
|
method: 'system.multicall',
|
||||||
|
params: [calls]
|
||||||
|
}
|
||||||
|
const response = await axios.post(config.rpcUrl, requestBody, {
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
timeout: Math.max(10000, tasks.length * 500)
|
||||||
|
})
|
||||||
|
const results = response.data && response.data.result
|
||||||
|
if (!Array.isArray(results)) {
|
||||||
|
throw new Error(response.data?.error?.message || 'system.multicall 返回异常')
|
||||||
|
}
|
||||||
|
let succeeded = 0, failed = 0
|
||||||
|
const errors = []
|
||||||
|
for (let i = 0; i < results.length; i++) {
|
||||||
|
const r = results[i]
|
||||||
|
if (Array.isArray(r) && r.length > 0 && typeof r[0] === 'string') {
|
||||||
|
succeeded++
|
||||||
|
} else if (r && r.faultCode) {
|
||||||
|
failed++
|
||||||
|
errors.push(`${tasks[i].fileName || tasks[i].url}: ${r.faultString || '未知错误'}`)
|
||||||
|
} else {
|
||||||
|
succeeded++
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return { succeeded, failed, errors }
|
||||||
|
} catch (e) {
|
||||||
|
return { succeeded: 0, failed: tasks.length, errors: [e.message || 'multicall 请求失败'] }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
async function batchAddGopeed(tasks, config) {
|
||||||
|
const base = gopeedBaseUrl(config.rpcUrl)
|
||||||
|
const reqs = tasks.map(task => {
|
||||||
|
const extraHeader = {}
|
||||||
|
if (task.headers && typeof task.headers === 'object') {
|
||||||
|
for (const [key, value] of Object.entries(task.headers)) {
|
||||||
|
if (key && value) extraHeader[key] = value
|
||||||
|
}
|
||||||
|
}
|
||||||
|
const item = { req: { url: task.url, extra: { header: extraHeader } } }
|
||||||
|
if (task.fileName) {
|
||||||
|
item.opts = { name: task.fileName }
|
||||||
|
}
|
||||||
|
return item
|
||||||
|
})
|
||||||
|
|
||||||
|
const body = { reqs }
|
||||||
|
if (config.downloadDir) body.opts = { path: config.downloadDir }
|
||||||
|
|
||||||
|
try {
|
||||||
|
const res = await callGopeedApi(base, config.rpcSecret, 'POST', '/api/v1/tasks/batch', body,
|
||||||
|
Math.max(10000, tasks.length * 500))
|
||||||
|
if (res && res.code !== undefined && res.code !== 0) {
|
||||||
|
return { succeeded: 0, failed: tasks.length, errors: [res.message || 'Gopeed batch 失败'] }
|
||||||
|
}
|
||||||
|
const ids = Array.isArray(res?.data) ? res.data : []
|
||||||
|
return { succeeded: ids.length || tasks.length, failed: 0, errors: [] }
|
||||||
|
} catch (e) {
|
||||||
|
return { succeeded: 0, failed: tasks.length, errors: [e.message || 'Gopeed batch 请求失败'] }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 通过迅雷 JS-SDK 发送下载任务
|
||||||
|
* @param {{ url: string, headers?: Object, fileName?: string }[]} tasks
|
||||||
|
* @param {{ downloadDir?: string }} config
|
||||||
|
* @returns {Promise<string>}
|
||||||
|
*/
|
||||||
|
function addThunderDownload(tasks, config) {
|
||||||
|
if (typeof window === 'undefined' || !window.thunderLink || typeof window.thunderLink.newTask !== 'function') {
|
||||||
|
return Promise.reject(new Error('迅雷客户端未检测到,请确认已安装并启动迅雷'))
|
||||||
|
}
|
||||||
|
// 迅雷 JS-SDK 不支持自定义 Cookie,含 Cookie 的下载链接无法通过迅雷下载
|
||||||
|
const firstHeaders = (tasks[0] && tasks[0].headers) || {}
|
||||||
|
if (firstHeaders.cookie || firstHeaders.Cookie) {
|
||||||
|
return Promise.reject(new Error('该文件需要 Cookie 认证,迅雷不支持自定义 Cookie,请使用 Aria2/Motrix/Gopeed'))
|
||||||
|
}
|
||||||
|
|
||||||
|
// 遍历所有 header key 大小写不敏感地提取 referer / user-agent
|
||||||
|
let referer = ''
|
||||||
|
let userAgent = ''
|
||||||
|
for (const [key, value] of Object.entries(firstHeaders)) {
|
||||||
|
const lk = key.toLowerCase()
|
||||||
|
if (lk === 'referer' && value) referer = value
|
||||||
|
if (lk === 'user-agent' && value) userAgent = value
|
||||||
|
}
|
||||||
|
|
||||||
|
const taskParam = {
|
||||||
|
tasks: tasks.map(t => {
|
||||||
|
const item = { url: t.url }
|
||||||
|
if (t.fileName) item.name = t.fileName
|
||||||
|
return item
|
||||||
|
})
|
||||||
|
}
|
||||||
|
if (config.downloadDir) taskParam.downloadDir = config.downloadDir
|
||||||
|
if (referer) taskParam.referer = referer
|
||||||
|
if (userAgent) taskParam.userAgent = userAgent
|
||||||
|
taskParam.threadCount = '1'
|
||||||
|
|
||||||
|
console.log('[Thunder SDK] newTask params:', JSON.stringify(taskParam))
|
||||||
|
window.thunderLink.newTask(taskParam)
|
||||||
|
return Promise.resolve('thunder-ok')
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 根据 RPC URL 猜测下载器类型
|
||||||
|
* @param {string} url
|
||||||
|
* @returns {string}
|
||||||
|
*/
|
||||||
|
export function guessDownloaderType(url) {
|
||||||
|
if (!url) return 'aria2'
|
||||||
|
if (url.includes(':16800')) return 'motrix'
|
||||||
|
if (url.includes(':9999')) return 'gopeed'
|
||||||
|
return 'aria2'
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 检查下载头中是否含有 Cookie(迅雷不支持)
|
||||||
|
* @param {Object} [headers]
|
||||||
|
* @returns {boolean}
|
||||||
|
*/
|
||||||
|
export function hasCookieHeader(headers) {
|
||||||
|
if (!headers || typeof headers !== 'object') return false
|
||||||
|
return !!(headers.cookie || headers.Cookie)
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 检查下载头中是否含有自定义 User-Agent(迅雷客户端可能不支持)
|
||||||
|
* @param {Object} [headers]
|
||||||
|
* @returns {boolean}
|
||||||
|
*/
|
||||||
|
export function hasCustomUaHeader(headers) {
|
||||||
|
if (!headers || typeof headers !== 'object') return false
|
||||||
|
for (const key of Object.keys(headers)) {
|
||||||
|
if (key.toLowerCase() === 'user-agent' && headers[key]) return true
|
||||||
|
}
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
export default {
|
||||||
|
getConfig,
|
||||||
|
saveConfig,
|
||||||
|
callRpc,
|
||||||
|
testConnection,
|
||||||
|
autoDetect,
|
||||||
|
addDownload,
|
||||||
|
batchAddDownload,
|
||||||
|
guessDownloaderType,
|
||||||
|
hasCookieHeader
|
||||||
|
}
|
||||||
@@ -35,15 +35,12 @@
|
|||||||
<i class="fas fa-server feedback-icon"></i>
|
<i class="fas fa-server feedback-icon"></i>
|
||||||
部署
|
部署
|
||||||
</a>
|
</a>
|
||||||
<a href="javascript:void(0)" class="feedback-link mini donate-link" @click="showDonateDialog = true">
|
|
||||||
<i class="fas fa-gift feedback-icon" style="color: #e74c3c;"></i>
|
|
||||||
捐赠账号
|
|
||||||
</a>
|
|
||||||
</div>
|
</div>
|
||||||
<el-row :gutter="20" style="margin-left: 0; margin-right: 0;">
|
<el-row :gutter="20" style="margin-left: 0; margin-right: 0;">
|
||||||
<el-card class="box-card">
|
<el-card class="box-card">
|
||||||
<div style="text-align: right; display: flex; justify-content: space-between; align-items: center;">
|
<div style="display: flex; justify-content: space-between; align-items: center;">
|
||||||
<!-- 左侧认证配置按钮 -->
|
<!-- 左侧:认证配置 + 捐赠账号 按钮组 -->
|
||||||
|
<div style="display: flex; gap: 6px; align-items: center;">
|
||||||
<el-tooltip content="配置临时认证信息" placement="bottom">
|
<el-tooltip content="配置临时认证信息" placement="bottom">
|
||||||
<el-button
|
<el-button
|
||||||
:type="hasAuthConfig ? 'primary' : 'default'"
|
:type="hasAuthConfig ? 'primary' : 'default'"
|
||||||
@@ -54,9 +51,21 @@
|
|||||||
<el-icon><Key /></el-icon>
|
<el-icon><Key /></el-icon>
|
||||||
</el-button>
|
</el-button>
|
||||||
</el-tooltip>
|
</el-tooltip>
|
||||||
<!-- 右侧暗色模式切换 -->
|
<el-tooltip content="捐赠网盘账号" placement="bottom">
|
||||||
|
<el-button circle size="small" type="warning" @click="showDonateDialog = true">
|
||||||
|
<el-icon><Present /></el-icon>
|
||||||
|
</el-button>
|
||||||
|
</el-tooltip>
|
||||||
|
</div>
|
||||||
|
<!-- 右侧:下载器 + 暗色模式 -->
|
||||||
|
<div style="display: flex; gap: 8px; align-items: center;">
|
||||||
|
<el-button link type="primary" @click="openAria2Dialog" style="position: relative;">
|
||||||
|
<span :class="['aria2-status-dot', aria2Connected ? 'connected' : 'disconnected']"></span>
|
||||||
|
{{ aria2Connected ? ('已连接 - ' + downloaderTypeName) : '下载器' }}
|
||||||
|
</el-button>
|
||||||
<DarkMode @theme-change="handleThemeChange" />
|
<DarkMode @theme-change="handleThemeChange" />
|
||||||
</div>
|
</div>
|
||||||
|
</div>
|
||||||
<div class="demo-basic--circle">
|
<div class="demo-basic--circle">
|
||||||
<div class="block" style="text-align: center;">
|
<div class="block" style="text-align: center;">
|
||||||
<img :height="150" src="../../public/images/lanzou111.png" alt="lz">
|
<img :height="150" src="../../public/images/lanzou111.png" alt="lz">
|
||||||
@@ -107,7 +116,7 @@
|
|||||||
<el-button style="margin-left: 20px" @click="generateMarkdown">生成Markdown</el-button>
|
<el-button style="margin-left: 20px" @click="generateMarkdown">生成Markdown</el-button>
|
||||||
<el-button style="margin-left: 20px" @click="generateQRCode">扫码下载</el-button>
|
<el-button style="margin-left: 20px" @click="generateQRCode">扫码下载</el-button>
|
||||||
<el-button style="margin-left: 20px" @click="getStatistics">分享统计</el-button>
|
<el-button style="margin-left: 20px" @click="getStatistics">分享统计</el-button>
|
||||||
<el-button style="margin-left: 20px" @click="goToClientLinks" type="primary">生成命令行链接</el-button>
|
|
||||||
</p>
|
</p>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
@@ -115,31 +124,92 @@
|
|||||||
<div v-if="parseResult.code" style="margin-top: 10px">
|
<div v-if="parseResult.code" style="margin-top: 10px">
|
||||||
<strong>解析结果: </strong>
|
<strong>解析结果: </strong>
|
||||||
<json-viewer :value="parseResult" :expand-depth="5" copyable boxed sort />
|
<json-viewer :value="parseResult" :expand-depth="5" copyable boxed sort />
|
||||||
<!-- 文件信息美化展示区 -->
|
<!-- 下载链接卡片 -->
|
||||||
<div v-if="downloadUrl" class="file-meta-info-card">
|
<div v-if="downloadUrl" style="margin-top: 15px;">
|
||||||
<div class="file-meta-row">
|
<el-card shadow="hover" class="download-result-card">
|
||||||
<span class="file-meta-label">下载链接:</span>
|
<template #header>
|
||||||
<a :href="downloadUrl" target="_blank" class="file-meta-link" rel="noreferrer noopener">点击下载</a>
|
<div style="display: flex; align-items: center; justify-content: space-between;">
|
||||||
</div>
|
<span>下载链接</span>
|
||||||
<div class="file-meta-row" v-if="parseResult.data?.downloadShortUrl">
|
<div style="display: flex; gap: 8px;">
|
||||||
<span class="file-meta-label">下载短链:</span>
|
<el-button @click="openUrl(downloadUrl)" type="primary" size="small">
|
||||||
<a :href="parseResult.data.downloadShortUrl" target="_blank" class="file-meta-link">{{ parseResult.data.downloadShortUrl }}</a>
|
<el-icon style="margin-right: 4px;"><Download /></el-icon> 下载
|
||||||
</div>
|
</el-button>
|
||||||
<div class="file-meta-row">
|
<el-button @click="openUrl(getPreviewLink())" type="default" size="small">
|
||||||
<span class="file-meta-label">文件预览:</span>
|
<el-icon style="margin-right: 4px;"><View /></el-icon> 预览
|
||||||
<a :href="getPreviewLink()" target="_blank" class="file-meta-link">点击预览</a>
|
</el-button>
|
||||||
</div>
|
<el-tooltip :disabled="aria2Connected"
|
||||||
<div class="file-meta-row">
|
content="下载器未连接,请点击右上角「下载器」配置" placement="top">
|
||||||
<span class="file-meta-label">文件名:</span>{{ extractFileNameAndExt(downloadUrl).name }}
|
<el-button
|
||||||
</div>
|
@click="handleAria2Download" :loading="aria2Downloading"
|
||||||
<div class="file-meta-row">
|
type="success" size="small" :disabled="!aria2Connected">
|
||||||
<span class="file-meta-label">文件类型:</span>{{ getFileTypeClass({ fileName: extractFileNameAndExt(downloadUrl).name }) }}
|
<el-icon style="margin-right: 4px;"><Download /></el-icon> 发送到下载器
|
||||||
</div>
|
</el-button>
|
||||||
<div class="file-meta-row" v-if="parseResult.data?.sizeStr">
|
</el-tooltip>
|
||||||
<span class="file-meta-label">文件大小:</span>{{ parseResult.data.sizeStr }}
|
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
</template>
|
||||||
|
<el-input :value="downloadUrl" readonly>
|
||||||
|
<template #append>
|
||||||
|
<el-button v-clipboard:copy="downloadUrl" v-clipboard:success="onCopy"
|
||||||
|
v-clipboard:error="onError" style="padding: 0 14px;">
|
||||||
|
<el-icon><CopyDocument/></el-icon>
|
||||||
|
</el-button>
|
||||||
|
</template>
|
||||||
|
</el-input>
|
||||||
|
<!-- 文件元信息 -->
|
||||||
|
<div style="margin-top: 10px; font-size: 13px; color: var(--el-text-color-secondary);">
|
||||||
|
<span v-if="parseResult.data?.sizeStr" style="margin-right: 16px;">
|
||||||
|
大小: <strong>{{ parseResult.data.sizeStr }}</strong>
|
||||||
|
</span>
|
||||||
|
<span v-if="parseResult.data?.downloadShortUrl" style="margin-right: 16px;">
|
||||||
|
短链: <a :href="parseResult.data.downloadShortUrl" target="_blank" class="file-meta-link">{{ parseResult.data.downloadShortUrl }}</a>
|
||||||
|
</span>
|
||||||
</div>
|
</div>
|
||||||
|
<!-- 调试命令区(默认折叠) -->
|
||||||
|
<div v-if="aria2Command || aria2JsonRpc || curlCommand" style="margin-top: 12px;">
|
||||||
|
<el-collapse v-model="activeDebugCommands">
|
||||||
|
<el-collapse-item name="debug">
|
||||||
|
<template #title>
|
||||||
|
<span style="font-size: 13px; color: var(--el-text-color-secondary);">命令行 / 调试参数</span>
|
||||||
|
</template>
|
||||||
|
<div v-if="aria2Command" class="debug-cmd-section">
|
||||||
|
<div class="debug-cmd-label">Aria2 下载命令</div>
|
||||||
|
<el-input :value="aria2Command" type="textarea" :rows="2" readonly />
|
||||||
|
<div style="text-align: right; margin-top: 6px;">
|
||||||
|
<el-button v-clipboard:copy="aria2Command" v-clipboard:success="onCopy"
|
||||||
|
v-clipboard:error="onError" size="small">
|
||||||
|
<el-icon><CopyDocument/></el-icon> 复制
|
||||||
|
</el-button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<div v-if="aria2JsonRpc" class="debug-cmd-section">
|
||||||
|
<div class="debug-cmd-label">Aria2 JSON-RPC</div>
|
||||||
|
<el-input :value="aria2JsonRpc" type="textarea" :rows="2" readonly />
|
||||||
|
<div style="text-align: right; margin-top: 6px;">
|
||||||
|
<el-button v-clipboard:copy="aria2JsonRpc" v-clipboard:success="onCopy"
|
||||||
|
v-clipboard:error="onError" size="small">
|
||||||
|
<el-icon><CopyDocument/></el-icon> 复制
|
||||||
|
</el-button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<div v-if="curlCommand" class="debug-cmd-section">
|
||||||
|
<div class="debug-cmd-label">curl 下载命令</div>
|
||||||
|
<el-input :value="curlCommand" type="textarea" :rows="2" readonly />
|
||||||
|
<div style="text-align: right; margin-top: 6px;">
|
||||||
|
<el-button v-clipboard:copy="curlCommand" v-clipboard:success="onCopy"
|
||||||
|
v-clipboard:error="onError" size="small">
|
||||||
|
<el-icon><CopyDocument/></el-icon> 复制
|
||||||
|
</el-button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</el-collapse-item>
|
||||||
|
</el-collapse>
|
||||||
|
</div>
|
||||||
|
</el-card>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<!-- 文件需要下载器弹窗 -->
|
||||||
|
<DownloadDialog v-model:visible="downloadDialogVisible" :download-info="downloadDialogInfo" />
|
||||||
|
|
||||||
<!-- Markdown链接 -->
|
<!-- Markdown链接 -->
|
||||||
<div v-if="markdownText" style="text-align: center">
|
<div v-if="markdownText" style="text-align: center">
|
||||||
@@ -335,27 +405,85 @@
|
|||||||
</el-card>
|
</el-card>
|
||||||
</el-row>
|
</el-row>
|
||||||
|
|
||||||
|
<!-- 下载器设置 Dialog -->
|
||||||
|
<el-dialog v-model="aria2DialogVisible" title="下载器设置" width="min(500px, 92vw)" :close-on-click-modal="false">
|
||||||
|
<div class="aria2-config-section">
|
||||||
|
<div class="aria2-config-title">
|
||||||
|
<el-icon><Setting /></el-icon>
|
||||||
|
<span>下载器类型</span>
|
||||||
|
</div>
|
||||||
|
<el-select v-model="aria2ConfigForm.downloaderType" style="width: 100%;" @change="onDownloaderTypeChange">
|
||||||
|
<el-option label="Motrix (推荐)" value="motrix" />
|
||||||
|
<el-option label="Gopeed" value="gopeed" />
|
||||||
|
<el-option label="Aria2" value="aria2" />
|
||||||
|
<el-option label="迅雷" value="thunder" />
|
||||||
|
</el-select>
|
||||||
|
<el-alert
|
||||||
|
v-if="aria2ConfigForm.downloaderType !== 'thunder'"
|
||||||
|
title="Motrix: 端口 16800 | Gopeed: 端口 9999 | Aria2: 端口 6800"
|
||||||
|
type="info" :closable="false" show-icon style="margin-top: 8px;"
|
||||||
|
/>
|
||||||
|
<el-alert
|
||||||
|
v-else
|
||||||
|
title="迅雷通过 JS-SDK 调用本地客户端,无需配置 RPC"
|
||||||
|
type="info" :closable="false" show-icon style="margin-top: 8px;"
|
||||||
|
/>
|
||||||
|
<div style="margin-top: 10px; font-size: 13px; color: var(--el-text-color-secondary);">
|
||||||
|
没有下载器?
|
||||||
|
<el-link type="primary" href="https://motrix.app" target="_blank" rel="noopener noreferrer">Motrix</el-link> /
|
||||||
|
<el-link type="primary" href="https://github.com/GopeedLab/gopeed/releases" target="_blank" rel="noopener noreferrer">Gopeed</el-link> /
|
||||||
|
<el-link type="primary" href="https://www.xunlei.com" target="_blank" rel="noopener noreferrer">迅雷</el-link>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<div v-show="aria2ConfigForm.downloaderType !== 'thunder'" class="aria2-config-section">
|
||||||
|
<div class="aria2-config-title"><el-icon><Monitor /></el-icon><span>RPC 地址</span></div>
|
||||||
|
<el-input v-model="aria2ConfigForm.rpcUrl" placeholder="http://localhost:6800/jsonrpc" clearable />
|
||||||
|
</div>
|
||||||
|
<div v-show="aria2ConfigForm.downloaderType !== 'thunder'" class="aria2-config-section">
|
||||||
|
<div class="aria2-config-title"><el-icon><Key /></el-icon><span>RPC 密钥 (可选)</span></div>
|
||||||
|
<el-input v-model="aria2ConfigForm.rpcSecret" placeholder="如果设置了密钥请输入" show-password clearable autocomplete="new-password" />
|
||||||
|
</div>
|
||||||
|
<div class="aria2-config-section">
|
||||||
|
<el-button link type="primary" @click="aria2ShowAdvanced = !aria2ShowAdvanced">
|
||||||
|
{{ aria2ShowAdvanced ? '收起选项 ▲' : '更多选项 ▼' }}
|
||||||
|
</el-button>
|
||||||
|
<el-collapse-transition>
|
||||||
|
<div v-show="aria2ShowAdvanced" style="margin-top: 10px;">
|
||||||
|
<div class="aria2-config-title"><el-icon><Folder /></el-icon><span>下载目录</span></div>
|
||||||
|
<el-input v-model="aria2ConfigForm.downloadDir" placeholder="留空使用默认下载目录" clearable />
|
||||||
|
</div>
|
||||||
|
</el-collapse-transition>
|
||||||
|
</div>
|
||||||
|
<div v-if="aria2Version && aria2ConfigForm.downloaderType !== 'thunder'" class="aria2-config-section" style="text-align: center;">
|
||||||
|
<el-tag type="success" size="small">
|
||||||
|
<el-icon style="vertical-align: middle;"><SuccessFilled /></el-icon>
|
||||||
|
已连接 - {{ downloaderTypeName }} {{ aria2Version }}
|
||||||
|
</el-tag>
|
||||||
|
</div>
|
||||||
|
<div v-if="aria2ConfigForm.downloaderType === 'thunder'" class="aria2-config-section" style="text-align: center;">
|
||||||
|
<el-tag type="info" size="small">迅雷通过浏览器唤起本地客户端,无需测试连接</el-tag>
|
||||||
|
</div>
|
||||||
|
<div v-show="aria2ConfigForm.downloaderType !== 'thunder'" class="aria2-config-section" style="display: flex; gap: 12px; justify-content: center; flex-wrap: wrap;">
|
||||||
|
<el-button :loading="aria2Testing" @click="testAria2Connection(false)" type="primary" plain>
|
||||||
|
<el-icon><Download /></el-icon> 测试连接
|
||||||
|
</el-button>
|
||||||
|
<el-button :loading="aria2AutoDetecting" @click="autoDetectDownloader" type="success" plain>
|
||||||
|
<el-icon><Search /></el-icon> 自动检测
|
||||||
|
</el-button>
|
||||||
|
</div>
|
||||||
|
<div style="text-align: center; margin-top: 12px;">
|
||||||
|
<el-button type="primary" @click="saveAria2Config" style="min-width: 180px;">
|
||||||
|
<el-icon><Select /></el-icon> 保存设置
|
||||||
|
</el-button>
|
||||||
|
</div>
|
||||||
|
</el-dialog>
|
||||||
|
|
||||||
<!-- 版本号显示 -->
|
<!-- 版本号显示 -->
|
||||||
<div class="version-info">
|
<div class="version-info">
|
||||||
<span class="version-text">内部版本: {{ buildVersion }}</span>
|
<span class="version-text">内部版本: {{ buildVersion }}</span>
|
||||||
<el-link v-if="playgroundEnabled" :href="'/playground'" class="playground-link">脚本演练场</el-link>
|
<el-link v-if="playgroundEnabled" :href="'/playground'" class="playground-link">脚本演练场</el-link>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<!-- 文件解析结果区下方加分享按钮 -->
|
|
||||||
<!-- <div v-if="parseResult.code && downloadUrl" style="margin-top: 10px; text-align: right;">-->
|
|
||||||
<!-- <el-button type="primary" @click="copyShowFileLink">分享文件直链</el-button>-->
|
|
||||||
<!-- </div>-->
|
|
||||||
<!-- 目录解析结果区下方加分享按钮 -->
|
|
||||||
<!-- <div v-if="showDirectoryTree && directoryData.length" style="margin-top: 10px; text-align: right;">-->
|
|
||||||
<!-- <el-input :value="showListLink" readonly style="width: 350px; margin-right: 10px;">-->
|
|
||||||
<!-- <template #append>-->
|
|
||||||
<!-- <el-button v-clipboard:copy="showListLink" v-clipboard:success="onCopy" v-clipboard:error="onError">-->
|
|
||||||
<!-- <el-icon><CopyDocument /></el-icon>复制分享链接-->
|
|
||||||
<!-- </el-button>-->
|
|
||||||
<!-- </template>-->
|
|
||||||
<!-- </el-input>-->
|
|
||||||
<!-- </div>-->
|
|
||||||
|
|
||||||
<!-- 捐赠账号弹窗 -->
|
<!-- 捐赠账号弹窗 -->
|
||||||
<el-dialog
|
<el-dialog
|
||||||
v-model="showDonateDialog"
|
v-model="showDonateDialog"
|
||||||
@@ -461,16 +589,18 @@ import axios from 'axios'
|
|||||||
import QRCode from 'qrcode'
|
import QRCode from 'qrcode'
|
||||||
import DarkMode from '@/components/DarkMode'
|
import DarkMode from '@/components/DarkMode'
|
||||||
import DirectoryTree from '@/components/DirectoryTree'
|
import DirectoryTree from '@/components/DirectoryTree'
|
||||||
|
import DownloadDialog from '@/components/DownloadDialog'
|
||||||
import parserUrl from '../parserUrl1'
|
import parserUrl from '../parserUrl1'
|
||||||
import fileTypeUtils from '@/utils/fileTypeUtils'
|
import fileTypeUtils from '@/utils/fileTypeUtils'
|
||||||
import { ElMessage } from 'element-plus'
|
import { ElMessage } from 'element-plus'
|
||||||
import { playgroundApi } from '@/utils/playgroundApi'
|
import { playgroundApi } from '@/utils/playgroundApi'
|
||||||
|
import { testConnection, autoDetect, addDownload, getConfig, saveConfig } from '@/utils/downloaderService'
|
||||||
|
|
||||||
export const previewBaseUrl = 'https://nfd-parser.github.io/nfd-preview/preview.html?src=';
|
export const previewBaseUrl = 'https://nfd-parser.github.io/nfd-preview/preview.html?src=';
|
||||||
|
|
||||||
export default {
|
export default {
|
||||||
name: 'App',
|
name: 'App',
|
||||||
components: { DarkMode, DirectoryTree },
|
components: { DarkMode, DirectoryTree, DownloadDialog },
|
||||||
mixins: [fileTypeUtils],
|
mixins: [fileTypeUtils],
|
||||||
data() {
|
data() {
|
||||||
return {
|
return {
|
||||||
@@ -553,7 +683,32 @@ export default {
|
|||||||
donateAccountCounts: {
|
donateAccountCounts: {
|
||||||
active: { total: 0 },
|
active: { total: 0 },
|
||||||
inactive: { total: 0 }
|
inactive: { total: 0 }
|
||||||
}
|
},
|
||||||
|
|
||||||
|
// 下载器相关
|
||||||
|
aria2Connected: false,
|
||||||
|
aria2Version: '',
|
||||||
|
aria2DialogVisible: false,
|
||||||
|
aria2ShowAdvanced: false,
|
||||||
|
aria2Testing: false,
|
||||||
|
aria2AutoDetecting: false,
|
||||||
|
aria2Downloading: false,
|
||||||
|
aria2ConfigForm: {
|
||||||
|
downloaderType: 'aria2',
|
||||||
|
rpcUrl: 'http://localhost:6800/jsonrpc',
|
||||||
|
rpcSecret: '',
|
||||||
|
downloadDir: ''
|
||||||
|
},
|
||||||
|
// 下载命令
|
||||||
|
aria2Command: '',
|
||||||
|
aria2JsonRpc: '',
|
||||||
|
curlCommand: '',
|
||||||
|
activeDebugCommands: [],
|
||||||
|
// 下载器特殊头对话框
|
||||||
|
downloadDialogVisible: false,
|
||||||
|
downloadDialogInfo: null,
|
||||||
|
// 目录解析支持的网盘列表
|
||||||
|
directoryParseSupportedPans: []
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
computed: {
|
computed: {
|
||||||
@@ -566,6 +721,16 @@ export default {
|
|||||||
// 获取已配置认证的网盘数量
|
// 获取已配置认证的网盘数量
|
||||||
authConfigCount() {
|
authConfigCount() {
|
||||||
return Object.keys(this.allAuthConfigs).length
|
return Object.keys(this.allAuthConfigs).length
|
||||||
|
},
|
||||||
|
// 下载器类型名称
|
||||||
|
downloaderTypeName() {
|
||||||
|
const map = {
|
||||||
|
motrix: 'Motrix',
|
||||||
|
gopeed: 'Gopeed',
|
||||||
|
aria2: 'Aria2',
|
||||||
|
thunder: '迅雷'
|
||||||
|
}
|
||||||
|
return map[this.aria2ConfigForm.downloaderType] || 'Aria2'
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
methods: {
|
methods: {
|
||||||
@@ -967,8 +1132,27 @@ export default {
|
|||||||
const result = await this.callAPI('/json/parser', params)
|
const result = await this.callAPI('/json/parser', params)
|
||||||
this.parseResult = result
|
this.parseResult = result
|
||||||
this.downloadUrl = result.data?.directLink
|
this.downloadUrl = result.data?.directLink
|
||||||
|
// 提取命令行参数
|
||||||
|
const otherParam = result.data?.otherParam || {}
|
||||||
|
this.aria2Command = otherParam.aria2Command || ''
|
||||||
|
this.aria2JsonRpc = otherParam.aria2JsonRpc || ''
|
||||||
|
this.curlCommand = otherParam.curlCommand || ''
|
||||||
|
this.activeDebugCommands = []
|
||||||
// 更新智能直链(包含认证参数)
|
// 更新智能直链(包含认证参数)
|
||||||
this.updateDirectLink()
|
this.updateDirectLink()
|
||||||
|
// 如果需要下载器(含特殊头),弹出下载器对话框
|
||||||
|
if (result.data?.needDownloader) {
|
||||||
|
this.downloadDialogInfo = {
|
||||||
|
downloadUrl: result.data.directLink,
|
||||||
|
fileName: result.data.fileName || '',
|
||||||
|
downloadHeaders: result.data.downloadHeaders || {},
|
||||||
|
aria2Command: this.aria2Command,
|
||||||
|
curlCommand: this.curlCommand,
|
||||||
|
aria2JsonRpc: this.aria2JsonRpc,
|
||||||
|
needDownloader: true
|
||||||
|
}
|
||||||
|
this.downloadDialogVisible = true
|
||||||
|
}
|
||||||
this.$message.success('文件解析成功!')
|
this.$message.success('文件解析成功!')
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error('文件解析失败:', error)
|
console.error('文件解析失败:', error)
|
||||||
@@ -982,17 +1166,7 @@ export default {
|
|||||||
const params = { url: this.link }
|
const params = { url: this.link }
|
||||||
if (this.password) params.pwd = this.password
|
if (this.password) params.pwd = this.password
|
||||||
|
|
||||||
const result = await this.callAPI('/v2/linkInfo', params)
|
// 直接调用 getFileList,让后端返回错误(不做客户端类型检查)
|
||||||
const data = result.data
|
|
||||||
|
|
||||||
// 检查是否支持目录解析
|
|
||||||
const supportedPans = ["iz", "lz", "fj", "ye", "le"]
|
|
||||||
if (!supportedPans.includes(data.shareLinkInfo.type)) {
|
|
||||||
this.$message.error("当前网盘不支持目录解析")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
// 获取目录数据
|
|
||||||
const directoryResult = await this.callAPI('/v2/getFileList', params)
|
const directoryResult = await this.callAPI('/v2/getFileList', params)
|
||||||
this.directoryData = directoryResult.data || []
|
this.directoryData = directoryResult.data || []
|
||||||
this.showDirectoryTree = true
|
this.showDirectoryTree = true
|
||||||
@@ -1363,6 +1537,117 @@ export default {
|
|||||||
} catch (e) {
|
} catch (e) {
|
||||||
console.error('加载捐赠账号统计失败:', e)
|
console.error('加载捐赠账号统计失败:', e)
|
||||||
}
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
// ===== 下载器相关方法 =====
|
||||||
|
openAria2Dialog() {
|
||||||
|
this.aria2DialogVisible = true
|
||||||
|
},
|
||||||
|
onDownloaderTypeChange() {
|
||||||
|
const defaults = {
|
||||||
|
motrix: 'http://localhost:16800/jsonrpc',
|
||||||
|
gopeed: 'http://localhost:9999/api/v1',
|
||||||
|
aria2: 'http://localhost:6800/jsonrpc',
|
||||||
|
thunder: ''
|
||||||
|
}
|
||||||
|
if (defaults[this.aria2ConfigForm.downloaderType] !== undefined) {
|
||||||
|
this.aria2ConfigForm.rpcUrl = defaults[this.aria2ConfigForm.downloaderType]
|
||||||
|
}
|
||||||
|
},
|
||||||
|
async testAria2Connection(silent = false) {
|
||||||
|
this.aria2Testing = true
|
||||||
|
try {
|
||||||
|
if (this.aria2ConfigForm.downloaderType === 'thunder') {
|
||||||
|
const result = await testConnection()
|
||||||
|
this.aria2Connected = result.connected
|
||||||
|
this.aria2Version = result.version || 'JS-SDK'
|
||||||
|
if (!silent) {
|
||||||
|
if (result.connected) this.$message.success('迅雷 JS-SDK 已就绪')
|
||||||
|
else this.$message.error('迅雷客户端未检测到,请确认已安装并启动迅雷')
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
const result = await testConnection(
|
||||||
|
this.aria2ConfigForm.rpcUrl,
|
||||||
|
this.aria2ConfigForm.rpcSecret
|
||||||
|
)
|
||||||
|
if (result.connected) {
|
||||||
|
this.aria2Connected = true
|
||||||
|
this.aria2Version = result.version || ''
|
||||||
|
if (!silent) this.$message.success(`连接成功:${this.downloaderTypeName} ${this.aria2Version}`)
|
||||||
|
} else {
|
||||||
|
this.aria2Connected = false
|
||||||
|
this.aria2Version = ''
|
||||||
|
if (!silent) this.$message.error('连接失败:请检查下载器是否启动')
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
this.aria2Connected = false
|
||||||
|
this.aria2Version = ''
|
||||||
|
if (!silent) this.$message.error('连接失败:' + e.message)
|
||||||
|
} finally {
|
||||||
|
this.aria2Testing = false
|
||||||
|
}
|
||||||
|
},
|
||||||
|
async autoDetectDownloader() {
|
||||||
|
this.aria2AutoDetecting = true
|
||||||
|
try {
|
||||||
|
const result = await autoDetect(this.aria2ConfigForm.rpcSecret)
|
||||||
|
if (result.found) {
|
||||||
|
this.aria2ConfigForm.rpcUrl = result.rpcUrl
|
||||||
|
this.aria2ConfigForm.downloaderType = result.type || 'aria2'
|
||||||
|
this.aria2Connected = true
|
||||||
|
this.aria2Version = result.version || ''
|
||||||
|
this.$message.success(`检测到 ${this.downloaderTypeName} ${this.aria2Version}`)
|
||||||
|
} else {
|
||||||
|
this.$message.warning('未检测到本地下载器,请确认 Motrix/Gopeed/Aria2 正在运行')
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
this.$message.error('自动检测失败:' + e.message)
|
||||||
|
} finally {
|
||||||
|
this.aria2AutoDetecting = false
|
||||||
|
}
|
||||||
|
},
|
||||||
|
saveAria2Config() {
|
||||||
|
saveConfig(this.aria2ConfigForm)
|
||||||
|
this.$message.success('下载器配置已保存')
|
||||||
|
this.aria2DialogVisible = false
|
||||||
|
// 保存后自动测试连接
|
||||||
|
this.testAria2Connection(true)
|
||||||
|
},
|
||||||
|
getAria2Config() {
|
||||||
|
const cfg = getConfig()
|
||||||
|
if (cfg) {
|
||||||
|
this.aria2ConfigForm = { ...this.aria2ConfigForm, ...cfg }
|
||||||
|
// 启动后静默测试连接
|
||||||
|
this.testAria2Connection(true)
|
||||||
|
}
|
||||||
|
},
|
||||||
|
async handleAria2Download() {
|
||||||
|
if (!this.downloadUrl) return
|
||||||
|
this.aria2Downloading = true
|
||||||
|
try {
|
||||||
|
const headers = this.parseResult.data?.otherParam?.downloadHeaders || {}
|
||||||
|
const fileName = this.parseResult.data?.fileInfo?.fileName || ''
|
||||||
|
await addDownload(this.downloadUrl, headers, fileName, this.aria2ConfigForm)
|
||||||
|
this.$message.success('已发送到下载器')
|
||||||
|
} catch (e) {
|
||||||
|
this.$message.error('发送失败:' + e.message)
|
||||||
|
} finally {
|
||||||
|
this.aria2Downloading = false
|
||||||
|
}
|
||||||
|
},
|
||||||
|
openUrl(url) {
|
||||||
|
if (url) window.open(url, '_blank', 'noopener,noreferrer')
|
||||||
|
},
|
||||||
|
async loadDirectoryParseSupportedPans() {
|
||||||
|
try {
|
||||||
|
const result = await this.callAPI('/v2/supportedParsePans', {})
|
||||||
|
if (result.data && Array.isArray(result.data)) {
|
||||||
|
this.directoryParseSupportedPans = result.data.map(p => (typeof p === 'string' ? p.toLowerCase() : p))
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
// 静默失败,使用默认列表
|
||||||
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
|
||||||
@@ -1388,6 +1673,9 @@ export default {
|
|||||||
// 检查演练场是否启用
|
// 检查演练场是否启用
|
||||||
this.checkPlaygroundEnabled()
|
this.checkPlaygroundEnabled()
|
||||||
|
|
||||||
|
// 初始化下载器配置
|
||||||
|
this.getAria2Config()
|
||||||
|
|
||||||
// 自动读取剪切板
|
// 自动读取剪切板
|
||||||
if (this.autoReadClipboard) {
|
if (this.autoReadClipboard) {
|
||||||
this.getPaste()
|
this.getPaste()
|
||||||
@@ -1662,6 +1950,45 @@ hr {
|
|||||||
color: #eee !important;
|
color: #eee !important;
|
||||||
border-color: #444 !important;
|
border-color: #444 !important;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* 下载器状态指示点 */
|
||||||
|
.aria2-status-dot {
|
||||||
|
display: inline-block;
|
||||||
|
width: 8px;
|
||||||
|
height: 8px;
|
||||||
|
border-radius: 50%;
|
||||||
|
margin-right: 5px;
|
||||||
|
}
|
||||||
|
.aria2-status-dot.connected { background: #67c23a; }
|
||||||
|
.aria2-status-dot.disconnected { background: #909399; }
|
||||||
|
|
||||||
|
/* 下载器配置区块 */
|
||||||
|
.aria2-config-section {
|
||||||
|
margin-bottom: 14px;
|
||||||
|
}
|
||||||
|
.aria2-config-title {
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
gap: 6px;
|
||||||
|
font-size: 13px;
|
||||||
|
color: var(--el-text-color-secondary);
|
||||||
|
margin-bottom: 6px;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* 下载结果卡片 */
|
||||||
|
.download-result-card {
|
||||||
|
margin-top: 10px;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* 调试命令区 */
|
||||||
|
.debug-cmd-section {
|
||||||
|
margin-bottom: 14px;
|
||||||
|
}
|
||||||
|
.debug-cmd-label {
|
||||||
|
font-size: 12px;
|
||||||
|
color: var(--el-text-color-secondary);
|
||||||
|
margin-bottom: 4px;
|
||||||
|
}
|
||||||
#app.dark-theme .jv-key {
|
#app.dark-theme .jv-key {
|
||||||
color: #4a9eff !important;
|
color: #4a9eff !important;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -19,19 +19,19 @@ module.exports = {
|
|||||||
port: 6444,
|
port: 6444,
|
||||||
proxy: {
|
proxy: {
|
||||||
'/parser': {
|
'/parser': {
|
||||||
target: 'http://127.0.0.1:6400/', // 请求本地
|
target: 'http://127.0.0.1:6401/', // 请求本地
|
||||||
ws: false
|
ws: false
|
||||||
},
|
},
|
||||||
'/v2': {
|
'/v2': {
|
||||||
target: 'http://127.0.0.1:6400/', // 请求本地
|
target: 'http://127.0.0.1:6401/', // 请求本地
|
||||||
ws: false
|
ws: false
|
||||||
},
|
},
|
||||||
'/json': {
|
'/json': {
|
||||||
target: 'http://127.0.0.1:6400/', // 请求本地
|
target: 'http://127.0.0.1:6401/', // 请求本地
|
||||||
ws: false
|
ws: false
|
||||||
},
|
},
|
||||||
'/d': {
|
'/d': {
|
||||||
target: 'http://127.0.0.1:6400/', // 请求本地
|
target: 'http://127.0.0.1:6401/', // 请求本地
|
||||||
ws: false
|
ws: false
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user