mirror of
https://github.com/qaiu/netdisk-fast-download.git
synced 2026-08-30 05:22:01 +00:00
yukaidi
7b5900aae4
- 替换 System.out.println/printStackTrace 为 Logger: MkgsTool, PodTool, WsTool, IpExtractor, ReqIpUtil, LogStatistics - JsPlaygroundLogger 日志列表限制最大 1000 条防止内存泄漏 - JsScriptLoader JarFile 改用 try-with-resources 防止文件句柄泄漏 - DbServiceImpl Thread.sleep 改为 vertx.setTimer 避免阻塞 event loop - 删除未使用的 api.js，删除空的 ParserApiClientLinkTest - 移除前端未使用的导入和死代码 (downloaderService, monacoTypes) - 提取 previewBaseUrl 到 constants.js 常量文件
158 lines
8.7 KiB
Java
158 lines
8.7 KiB
Java
package cn.qaiu.parser.impl;
|
|
|
|
import cn.qaiu.entity.ShareLinkInfo;
|
|
import cn.qaiu.parser.PanBase;
|
|
import io.vertx.core.Future;
|
|
import io.vertx.core.MultiMap;
|
|
import io.vertx.core.json.DecodeException;
|
|
import io.vertx.core.json.JsonObject;
|
|
import io.vertx.ext.web.client.WebClient;
|
|
|
|
import java.net.URLDecoder;
|
|
import java.nio.charset.StandardCharsets;
|
|
|
|
/**
|
|
* <a href="https://www.wenshushu.cn/">文叔叔</a>
|
|
*/
|
|
public class WsTool extends PanBase {
|
|
|
|
public static final String SHARE_URL_PREFIX = "www.wenshushu.cn/f/";
|
|
public static final String SHARE_URL_API = "https://www.wenshushu.cn/ap/";
|
|
|
|
public WsTool(ShareLinkInfo shareLinkInfo) {
|
|
super(shareLinkInfo);
|
|
}
|
|
|
|
public Future<String> parse() {
|
|
|
|
WebClient httpClient = this.client;
|
|
final String key = shareLinkInfo.getShareKey();
|
|
final String pwd = shareLinkInfo.getSharePassword();
|
|
|
|
|
|
// 设置基础HTTP头部
|
|
var userAgent2 = "Mozilla/5.0 (Linux; Android 6.0; Nexus 5 Build/MRA58N) AppleWebKit/537.36 (KHTML, " +
|
|
"like " +
|
|
"Gecko) Chrome/111.0.0.0 Mobile Safari/537.36";
|
|
|
|
MultiMap headers = MultiMap.caseInsensitiveMultiMap();
|
|
headers.set("User-Agent", userAgent2);
|
|
headers.set("sec-ch-ua-platform", "Android");
|
|
headers.set("Accept-Language", "zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2");
|
|
headers.set("sec-ch-ua-mobile", "sec-ch-ua-mobile");
|
|
|
|
// 获取匿名登录token
|
|
httpClient.postAbs(SHARE_URL_API + "login/anonymous").putHeaders(headers)
|
|
.sendJsonObject(JsonObject.of("dev_info", "{}"))
|
|
.onSuccess(res -> {
|
|
|
|
if (res.statusCode() == 200) {
|
|
try {
|
|
// 设置匿名登录token
|
|
String token = asJson(res).getJsonObject("data").getString("token");
|
|
headers.set("X-Token", token);
|
|
|
|
// 获取文件夹信息
|
|
httpClient.postAbs(SHARE_URL_API + "task/mgrtask").putHeaders(headers)
|
|
.sendJsonObject(JsonObject.of(
|
|
"tid", key,
|
|
"password", pwd
|
|
)).onSuccess(res2 -> {
|
|
|
|
if (res2.statusCode() == 200) {
|
|
try {
|
|
// 获取文件夹信息
|
|
String filetime = asJson(res2).getJsonObject("data").getString("expire"); // 文件夹剩余时间
|
|
String filesize = asJson(res2).getJsonObject("data").getString("file_size"); // 文件夹大小
|
|
String filepid = asJson(res2).getJsonObject("data").getString("ufileid"); // 文件夹pid
|
|
String filebid = asJson(res2).getJsonObject("data").getString("boxid"); // 文件夹bid
|
|
|
|
log.debug("文件夹期限: {}, 大小: {}, pid: {}, bid: {}", filetime, filesize, filepid, filebid);
|
|
|
|
// 获取文件信息
|
|
httpClient.postAbs(SHARE_URL_API + "ufile/list").putHeaders(headers)
|
|
.sendJsonObject(JsonObject.of(
|
|
"start", 0,
|
|
"sort", JsonObject.of(
|
|
"name", "asc"
|
|
),
|
|
"bid", filebid,
|
|
"pid", filepid,
|
|
"type", 1,
|
|
"options", JsonObject.of(
|
|
"uploader", "true"
|
|
),
|
|
"size", 50
|
|
)).onSuccess(res3 -> {
|
|
|
|
if (res3.statusCode() == 200) {
|
|
try {
|
|
// 获取文件信息
|
|
String filename = asJson(res3).getJsonObject("data")
|
|
.getJsonArray("fileList").getJsonObject(0).getString("fname"); // 文件名称
|
|
String filefid = asJson(res3).getJsonObject("data")
|
|
.getJsonArray("fileList").getJsonObject(0).getString("fid"); // 文件fid
|
|
|
|
log.debug("文件名称: {}, fid: {}", filename, filefid);
|
|
|
|
// 检查文件是否失效
|
|
httpClient.postAbs(SHARE_URL_API + "dl/sign").putHeaders(headers)
|
|
.sendJsonObject(JsonObject.of(
|
|
"consumeCode", 0,
|
|
"type", 1,
|
|
"ufileid", filefid
|
|
)).onSuccess(res4 -> {
|
|
|
|
if (res4.statusCode() == 200) {
|
|
try {
|
|
// 获取直链
|
|
String fileurl = asJson(res4).getJsonObject("data").getString("url");
|
|
|
|
log.debug("文件直链: {}", fileurl);
|
|
|
|
if (!fileurl.equals("")) {
|
|
promise.complete(URLDecoder.decode(fileurl, StandardCharsets.UTF_8));
|
|
} else {
|
|
this.fail("文件已失效");
|
|
}
|
|
|
|
} catch (DecodeException | NullPointerException e) {
|
|
this.fail("获取文件信息失败，可能是分享链接的方式已更新，或者对方的文件已失效");
|
|
}
|
|
} else {
|
|
this.fail("HTTP状态不正确，可能是分享链接的方式已更新");
|
|
}
|
|
|
|
});
|
|
|
|
} catch (DecodeException | NullPointerException e) {
|
|
this.fail("获取文件信息失败，可能是分享链接的方式已更新");
|
|
}
|
|
} else {
|
|
this.fail("HTTP状态不正确，可能是分享链接的方式已更新");
|
|
}
|
|
|
|
});
|
|
|
|
} catch (DecodeException | NullPointerException e) {
|
|
this.fail("获取文件夹信息失败，可能是分享链接的方式已更新");
|
|
}
|
|
} else {
|
|
this.fail("HTTP状态不正确，可能是分享链接的方式已更新");
|
|
}
|
|
|
|
}).onFailure(this.handleFail(key));
|
|
|
|
} catch (DecodeException | NullPointerException e) {
|
|
this.fail("token获取失败，可能是分享链接的方式已更新");
|
|
}
|
|
} else {
|
|
this.fail("HTTP状态不正确，可能是分享链接的方式已更新");
|
|
}
|
|
|
|
}).onFailure(this.handleFail(key));
|
|
|
|
return promise.future();
|
|
}
|
|
}
|