mirror of
https://github.com/qaiu/netdisk-fast-download.git
synced 2026-08-26 11:32:02 +00:00
q
761 lines
34 KiB
Java
761 lines
34 KiB
Java
package cn.qaiu.parser.impl;
|
||
|
||
import cn.qaiu.entity.FileInfo;
|
||
import cn.qaiu.entity.ShareLinkInfo;
|
||
import cn.qaiu.parser.PanBase;
|
||
import cn.qaiu.parser.TokenCache;
|
||
import cn.qaiu.util.CommonUtils;
|
||
import cn.qaiu.util.FileSizeConverter;
|
||
import cn.qaiu.util.YeShareHostUtil;
|
||
import io.vertx.core.Future;
|
||
import io.vertx.core.MultiMap;
|
||
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.ext.web.client.WebClient;
|
||
import io.vertx.uritemplate.UriTemplate;
|
||
import org.apache.commons.lang3.StringUtils;
|
||
|
||
import java.net.MalformedURLException;
|
||
import java.time.OffsetDateTime;
|
||
import java.time.format.DateTimeFormatter;
|
||
import java.util.ArrayList;
|
||
import java.util.Base64;
|
||
import java.util.List;
|
||
import java.util.Map;
|
||
import java.util.Random;
|
||
import java.util.zip.CRC32;
|
||
|
||
import static cn.qaiu.util.RandomStringGenerator.gen36String;
|
||
|
||
/**
|
||
* 123盘解析器 v2 - 使用Android平台API
|
||
* 支持账号密码或token配置
|
||
*
|
||
* @author <a href="https://qaiu.top">QAIU</a>
|
||
*/
|
||
public class Ye2Tool extends PanBase {
|
||
|
||
private static final String API_BASE = "https://api.123278.com";
|
||
private static final String GET_SHARE_INFO_URL = API_BASE + "/b/api/share/get?limit=100&next=1&orderBy=share_id&orderDirection=desc&shareKey={shareKey}&SharePwd={pwd}&ParentFileId={ParentFileId}&Page=1";
|
||
private static final String DOWNLOAD_API_URL = API_BASE + "/b/api/file/download_info";
|
||
private static final String DOWNLOAD_API_V2_BASE = "https://api.123278.com";
|
||
private static final String DOWNLOAD_API_V2_PATH = "/b/api/v2/share/download/info";
|
||
private static final String BATCH_DOWNLOAD_API_URL = API_BASE + "/b/api/file/batch_download_share_info";
|
||
private static final String LOGIN_URL = "https://login.123pan.com/api/user/sign_in";
|
||
|
||
private static final String CHAR_MAP = "adefghlmyijnopkqrstubcvwsz";
|
||
|
||
private final MultiMap header = MultiMap.caseInsensitiveMultiMap();
|
||
private final String cacheKey;
|
||
|
||
public Ye2Tool(ShareLinkInfo shareLinkInfo) {
|
||
super(shareLinkInfo);
|
||
this.cacheKey = TokenCache.key("ye2", resolveAccountId());
|
||
header.set("Accept-Language", "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6");
|
||
header.set("App-Version", "55");
|
||
header.set("Cache-Control", "no-cache");
|
||
header.set("Connection", "keep-alive");
|
||
header.set("LoginUuid", gen36String());
|
||
header.set("Pragma", "no-cache");
|
||
header.set("Referer", shareLinkInfo.getStandardUrl());
|
||
header.set("Sec-Fetch-Dest", "empty");
|
||
header.set("Sec-Fetch-Mode", "cors");
|
||
header.set("Sec-Fetch-Site", "same-origin");
|
||
header.set("User-Agent", "Mozilla/5.0 (Linux; Android 13) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127.0.0.0 Mobile Safari/537.36");
|
||
header.set("platform", "android");
|
||
header.set("Content-Type", "application/json");
|
||
}
|
||
|
||
private String resolveAccountId() {
|
||
String accountId = "_default";
|
||
if (!shareLinkInfo.getOtherParam().containsKey("auths")) {
|
||
return accountId;
|
||
}
|
||
MultiMap auths = (MultiMap) shareLinkInfo.getOtherParam().get("auths");
|
||
if (auths.contains("_configId")) {
|
||
accountId = auths.get("_configId");
|
||
} else if (auths.contains("username")) {
|
||
accountId = auths.get("username");
|
||
} else {
|
||
String token = resolveProvidedToken(auths);
|
||
if (StringUtils.isNotEmpty(token)) {
|
||
accountId = token.substring(0, Math.min(16, token.length()));
|
||
}
|
||
}
|
||
return accountId;
|
||
}
|
||
|
||
/**
|
||
* 从配置/临时认证参数中取出可直接使用的 Bearer token。
|
||
* 兼容两种 key：
|
||
* - token：URLParamUtil 处理 auth= 临时参数(authType=accesstoken/authorization)时写入的字段名
|
||
* - authorization：app-dev.yml 静态配置中更符合直觉的写法（auths.ye.authorization: xxx）
|
||
*/
|
||
private String resolveProvidedToken(MultiMap auths) {
|
||
if (auths == null) {
|
||
return null;
|
||
}
|
||
String token = auths.get("token");
|
||
if (StringUtils.isEmpty(token)) {
|
||
token = auths.get("authorization");
|
||
}
|
||
return stripBearerPrefix(token);
|
||
}
|
||
|
||
/**
|
||
* 用户/捐赠账号提供的 token 经常是从浏览器开发者工具里连同 "Bearer " 前缀一起复制过来的，
|
||
* 如果不做清理，后续 header.set("Authorization", "Bearer " + token) 会拼出
|
||
* "Bearer Bearer xxx"，导致123网盘接口报错 tokenstring should not contain 'bearer '。
|
||
*/
|
||
private String stripBearerPrefix(String token) {
|
||
if (StringUtils.isBlank(token)) {
|
||
return token;
|
||
}
|
||
String trimmed = token.trim();
|
||
if (trimmed.regionMatches(true, 0, "Bearer ", 0, 7)) {
|
||
trimmed = trimmed.substring(7).trim();
|
||
}
|
||
return trimmed;
|
||
}
|
||
|
||
private boolean isTokenExpired() {
|
||
return TokenCache.isExpired(cacheKey);
|
||
}
|
||
|
||
private String crc32(String data) {
|
||
CRC32 crc32 = new CRC32();
|
||
crc32.update(data.getBytes());
|
||
long value = crc32.getValue();
|
||
return String.format("%08x", value);
|
||
}
|
||
|
||
private long hexToInt(String hexStr) {
|
||
return Long.parseLong(hexStr, 16);
|
||
}
|
||
|
||
private String encode123(String url, String way, String version, String timestamp) {
|
||
Random random = new Random();
|
||
int randomInt = random.nextInt(10000000) + 1;
|
||
long a = (10000000L * randomInt) / 10000;
|
||
|
||
long timeLong = Long.parseLong(timestamp) / 1000;
|
||
java.time.LocalDateTime dateTime = java.time.Instant.ofEpochSecond(timeLong)
|
||
.atZone(java.time.ZoneId.systemDefault())
|
||
.toLocalDateTime();
|
||
String timeStr = dateTime.format(DateTimeFormatter.ofPattern("yyyyMMddHHmm"));
|
||
|
||
StringBuilder g = new StringBuilder();
|
||
for (char c : timeStr.toCharArray()) {
|
||
int digit = Character.getNumericValue(c);
|
||
if (digit == 0) {
|
||
g.append(CHAR_MAP.charAt(0));
|
||
} else {
|
||
g.append(CHAR_MAP.charAt(digit - 1));
|
||
}
|
||
}
|
||
|
||
String y = String.valueOf(hexToInt(crc32(g.toString())));
|
||
String finalCrcInput = String.format("%d|%d|%s|%s|%s|%s", timeLong, a, url, way, version, y);
|
||
String finalCrc = String.valueOf(hexToInt(crc32(finalCrcInput)));
|
||
return String.format("?%s=%d-%d-%s", y, timeLong, a, finalCrc);
|
||
}
|
||
|
||
public Future<String> parse() {
|
||
Future<String> tokenFuture = resolveTokenFuture();
|
||
|
||
tokenFuture.onSuccess(token -> {
|
||
if (!token.equals("nologin")) {
|
||
TokenCache.putToken(cacheKey, token);
|
||
header.set("Authorization", "Bearer " + token);
|
||
}
|
||
|
||
final String dataKey = YeShareHostUtil.normalizeShareKey(shareLinkInfo.getShareKey());
|
||
final String pwd = shareLinkInfo.getSharePassword();
|
||
final String shareOrigin = resolveYeShareOrigin(dataKey);
|
||
final String shareReferer = buildShareReferer(shareOrigin, dataKey, pwd);
|
||
|
||
client.getAbs(UriTemplate.of(GET_SHARE_INFO_URL))
|
||
.setTemplateParam("shareKey", dataKey)
|
||
.setTemplateParam("pwd", StringUtils.isEmpty(pwd) ? "" : pwd)
|
||
.setTemplateParam("ParentFileId", "0")
|
||
.putHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36")
|
||
.putHeader("Referer", shareReferer)
|
||
.putHeader("Origin", shareOrigin)
|
||
.send()
|
||
.onSuccess(res -> {
|
||
JsonObject shareInfoJson = asJson(res);
|
||
if (shareInfoJson.getInteger("code") != 0) {
|
||
fail("获取分享信息失败: " + shareInfoJson.getString("message"));
|
||
return;
|
||
}
|
||
|
||
if (!shareInfoJson.containsKey("data") || !shareInfoJson.getJsonObject("data").containsKey("InfoList")) {
|
||
fail("返回数据格式错误");
|
||
return;
|
||
}
|
||
|
||
JsonObject data = shareInfoJson.getJsonObject("data");
|
||
if (data.getJsonArray("InfoList").size() == 0) {
|
||
fail("分享中没有文件");
|
||
return;
|
||
}
|
||
|
||
JsonObject fileInfo = data.getJsonArray("InfoList").getJsonObject(0);
|
||
if (token.equals("nologin")) {
|
||
fail("该分享需要登录才能下载，请配置认证信息");
|
||
return;
|
||
}
|
||
|
||
if (fileInfo.getInteger("Type", 0) == 1) {
|
||
getZipDownUrl(client, fileInfo);
|
||
} else {
|
||
getDownUrl(client, fileInfo);
|
||
}
|
||
})
|
||
.onFailure(this.handleFail(GET_SHARE_INFO_URL));
|
||
}).onFailure(err -> fail("123盘解析异常: {}", err.getMessage()));
|
||
|
||
return promise.future();
|
||
}
|
||
|
||
private Future<String> resolveTokenFuture() {
|
||
MultiMap auths = (MultiMap) shareLinkInfo.getOtherParam().get("auths");
|
||
if (auths != null) {
|
||
// 当同时提供了用户名+密码时，优先走真实登录流程。
|
||
// 注：前端/auth参数中 authType=password|username_password 时，URLParamUtil 出于兼容旧解析器的目的
|
||
// 会把 authToken(用户名) 同时写入 token 字段，如果这里无条件信任 token，会把用户名当成
|
||
// Bearer token 使用，导致真实的账号密码登录被跳过。
|
||
boolean hasCredential = StringUtils.isNotEmpty(auths.get("username"))
|
||
&& StringUtils.isNotEmpty(auths.get("password"));
|
||
String providedToken = resolveProvidedToken(auths);
|
||
if (!hasCredential && StringUtils.isNotEmpty(providedToken)) {
|
||
TokenCache.putToken(cacheKey, providedToken);
|
||
return Future.succeededFuture(providedToken);
|
||
}
|
||
}
|
||
|
||
String cached = TokenCache.getToken(cacheKey);
|
||
if (cached == null || isTokenExpired()) {
|
||
return loginAndGetToken();
|
||
}
|
||
return Future.succeededFuture(cached);
|
||
}
|
||
|
||
private Future<String> loginAndGetToken() {
|
||
MultiMap auths = (MultiMap) shareLinkInfo.getOtherParam().get("auths");
|
||
if (auths == null) {
|
||
return Future.succeededFuture("nologin");
|
||
}
|
||
|
||
String username = auths.get("username");
|
||
String password = auths.get("password");
|
||
|
||
if (username == null || password == null) {
|
||
return Future.succeededFuture("nologin");
|
||
}
|
||
|
||
Promise<String> promise = Promise.promise();
|
||
String loginUuid = gen36String();
|
||
|
||
JsonObject loginBody = new JsonObject()
|
||
.put("passport", username)
|
||
.put("password", password)
|
||
.put("remember", true);
|
||
|
||
client.postAbs(LOGIN_URL)
|
||
.putHeader("Content-Type", "application/json")
|
||
.putHeader("LoginUuid", loginUuid)
|
||
.putHeader("App-Version", "55")
|
||
.putHeader("platform", "web")
|
||
.sendJsonObject(loginBody)
|
||
.onSuccess(res -> {
|
||
JsonObject json = res.bodyAsJsonObject();
|
||
if (json == null) {
|
||
promise.fail("登录响应格式异常: " + res.bodyAsString());
|
||
return;
|
||
}
|
||
if (!json.containsKey("code")) {
|
||
promise.fail("登录响应格式异常: " + res.bodyAsString());
|
||
return;
|
||
}
|
||
if (json.getInteger("code") != 200) {
|
||
promise.fail("登录失败: " + json.getString("message"));
|
||
return;
|
||
}
|
||
JsonObject data = json.getJsonObject("data");
|
||
if (data == null || !data.containsKey("token")) {
|
||
promise.fail("未获取到token");
|
||
return;
|
||
}
|
||
String ssoToken = data.getString("token");
|
||
String expireStr = data.getString("expire");
|
||
long expireMs;
|
||
if (StringUtils.isNotEmpty(expireStr)) {
|
||
expireMs = OffsetDateTime.parse(expireStr)
|
||
.toInstant().toEpochMilli() - 60_000;
|
||
} else {
|
||
expireMs = System.currentTimeMillis() + 3600_000;
|
||
}
|
||
TokenCache.putToken(cacheKey, ssoToken);
|
||
TokenCache.putExpire(cacheKey, expireMs);
|
||
log.info("登录成功，token: {}", ssoToken);
|
||
promise.complete(ssoToken);
|
||
})
|
||
.onFailure(promise::fail);
|
||
return promise.future();
|
||
}
|
||
|
||
private void getDownUrl(WebClient client, JsonObject fileInfo) {
|
||
setFileInfo(fileInfo);
|
||
|
||
String normalizedShareKey = YeShareHostUtil.normalizeShareKey(shareLinkInfo.getShareKey());
|
||
if (StringUtils.isNotEmpty(normalizedShareKey)) {
|
||
JsonObject v2Body = new JsonObject()
|
||
.put("ShareKey", normalizedShareKey)
|
||
.put("FileID", fileInfo.getInteger("FileId"))
|
||
.put("S3keyFlag", fileInfo.getString("S3KeyFlag"))
|
||
.put("Size", fileInfo.getLong("Size"))
|
||
.put("Etag", fileInfo.getString("Etag"));
|
||
requestShareV2Download(normalizedShareKey, v2Body).onSuccess(v2Url -> {
|
||
if (StringUtils.isNotEmpty(v2Url)) {
|
||
complete(v2Url);
|
||
return;
|
||
}
|
||
requestLegacyDownUrl(client, fileInfo);
|
||
}).onFailure(err -> {
|
||
log.warn("Ye2 v2分享下载接口失败，回退旧接口: {}", err.getMessage());
|
||
requestLegacyDownUrl(client, fileInfo);
|
||
});
|
||
return;
|
||
}
|
||
|
||
requestLegacyDownUrl(client, fileInfo);
|
||
}
|
||
|
||
private void requestLegacyDownUrl(WebClient client, JsonObject fileInfo) {
|
||
JsonObject jsonObject = new JsonObject();
|
||
jsonObject.put("driveId", 0);
|
||
jsonObject.put("etag", fileInfo.getString("Etag"));
|
||
jsonObject.put("fileId", fileInfo.getInteger("FileId"));
|
||
jsonObject.put("fileName", fileInfo.getString("FileName"));
|
||
jsonObject.put("s3keyFlag", fileInfo.getString("S3KeyFlag"));
|
||
jsonObject.put("size", fileInfo.getLong("Size"));
|
||
jsonObject.put("type", 0);
|
||
|
||
String timestamp = String.valueOf(System.currentTimeMillis());
|
||
String encryptedParams = encode123("/b/api/file/download_info", "android", "55", timestamp);
|
||
String apiUrl = DOWNLOAD_API_URL + encryptedParams;
|
||
|
||
log.info("Ye2 API URL: {}", apiUrl);
|
||
|
||
HttpRequest<Buffer> bufferHttpRequest = client.postAbs(apiUrl);
|
||
bufferHttpRequest.putHeader("platform", "android");
|
||
bufferHttpRequest.putHeader("App-Version", "55");
|
||
bufferHttpRequest.putHeader("Authorization", "Bearer " + TokenCache.getToken(cacheKey));
|
||
bufferHttpRequest.putHeader("User-Agent", "Mozilla/5.0 (Linux; Android 13) AppleWebKit/537.36");
|
||
bufferHttpRequest.putHeader("Content-Type", "application/json");
|
||
|
||
bufferHttpRequest
|
||
.sendJsonObject(jsonObject)
|
||
.onSuccess(res2 -> handleDownloadUrlResponse(client, asJson(res2), "Ye2"))
|
||
.onFailure(err -> fail("下载接口失败: " + err.getMessage()));
|
||
}
|
||
|
||
private Future<String> requestShareV2Download(String shareKey, JsonObject body) {
|
||
Promise<String> promise = Promise.promise();
|
||
String timestamp = String.valueOf(System.currentTimeMillis());
|
||
String encryptedParams = encode123(DOWNLOAD_API_V2_PATH, "web", "3", timestamp);
|
||
String apiUrl = DOWNLOAD_API_V2_BASE + DOWNLOAD_API_V2_PATH + encryptedParams;
|
||
String shareOrigin = resolveYeShareOrigin(shareKey);
|
||
String shareReferer = buildShareReferer(shareOrigin, shareKey, shareLinkInfo.getSharePassword());
|
||
|
||
HttpRequest<Buffer> request = client.postAbs(apiUrl);
|
||
request.putHeader("Accept", "*/*");
|
||
request.putHeader("Authorization", "Bearer " + TokenCache.getToken(cacheKey));
|
||
request.putHeader("App-Version", "3");
|
||
request.putHeader("platform", "web");
|
||
request.putHeader("Origin", shareOrigin);
|
||
request.putHeader("Referer", shareReferer);
|
||
request.putHeader("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/149.0.0.0 Safari/537.36");
|
||
request.putHeader("Content-Type", "application/json;charset=UTF-8");
|
||
|
||
request.sendJsonObject(body).onSuccess(resp -> {
|
||
JsonObject json = asJson(resp);
|
||
if (json == null || json.getInteger("code", -1) != 0) {
|
||
promise.fail("v2接口返回异常: " + (json == null ? "null" : json.encode()));
|
||
return;
|
||
}
|
||
JsonObject data = json.getJsonObject("data", new JsonObject());
|
||
JsonArray dispatchList = data.getJsonArray("dispatchList", new JsonArray());
|
||
String downloadPath = data.getString("downloadPath");
|
||
if (StringUtils.isBlank(downloadPath)) {
|
||
promise.complete("");
|
||
return;
|
||
}
|
||
String prefix = "";
|
||
if (dispatchList.size() > 0) {
|
||
JsonObject firstDispatch = dispatchList.getJsonObject(0);
|
||
if (firstDispatch != null) {
|
||
prefix = firstDispatch.getString("prefix", "");
|
||
}
|
||
}
|
||
if (StringUtils.isBlank(prefix)) {
|
||
promise.complete(downloadPath);
|
||
return;
|
||
}
|
||
String finalUrl = prefix.endsWith("/") ? prefix.substring(0, prefix.length() - 1) : prefix;
|
||
finalUrl += downloadPath.startsWith("/") ? downloadPath : "/" + downloadPath;
|
||
promise.complete(finalUrl);
|
||
}).onFailure(promise::fail);
|
||
|
||
return promise.future();
|
||
}
|
||
|
||
private void getZipDownUrl(WebClient client, JsonObject fileInfo) {
|
||
JsonObject jsonObject = new JsonObject();
|
||
jsonObject.put("shareKey", YeShareHostUtil.normalizeShareKey(shareLinkInfo.getShareKey()));
|
||
jsonObject.put("fileIdList", new JsonArray().add(JsonObject.of("fileId", fileInfo.getInteger("FileId"))));
|
||
|
||
String timestamp = String.valueOf(System.currentTimeMillis());
|
||
String encryptedParams = encode123("/b/api/file/batch_download_share_info", "android", "55", timestamp);
|
||
String apiUrl = BATCH_DOWNLOAD_API_URL + encryptedParams;
|
||
|
||
log.info("Ye2 Batch Download API URL: {}", apiUrl);
|
||
|
||
HttpRequest<Buffer> bufferHttpRequest = client.postAbs(apiUrl);
|
||
bufferHttpRequest.putHeader("platform", "android");
|
||
bufferHttpRequest.putHeader("App-Version", "55");
|
||
bufferHttpRequest.putHeader("Authorization", "Bearer " + TokenCache.getToken(cacheKey));
|
||
bufferHttpRequest.putHeader("User-Agent", "Mozilla/5.0 (Linux; Android 13) AppleWebKit/537.36");
|
||
bufferHttpRequest.putHeader("Content-Type", "application/json");
|
||
|
||
bufferHttpRequest
|
||
.sendJsonObject(jsonObject)
|
||
.onSuccess(res2 -> handleDownloadUrlResponse(client, asJson(res2), "Ye2: 文件夹打包下载"))
|
||
.onFailure(err -> fail("文件夹打包下载接口失败: " + err.getMessage()));
|
||
}
|
||
|
||
private void handleDownloadUrlResponse(WebClient client, JsonObject downURLJson, String failPrefix) {
|
||
try {
|
||
if (downURLJson.getInteger("code") != 0) {
|
||
fail(failPrefix + "返回值异常->" + downURLJson);
|
||
return;
|
||
}
|
||
} catch (Exception ignored) {
|
||
fail(failPrefix + "格式异常->" + downURLJson);
|
||
return;
|
||
}
|
||
|
||
String downURL = downURLJson.getJsonObject("data").getString("DownloadUrl");
|
||
if (StringUtils.isEmpty(downURL)) {
|
||
downURL = downURLJson.getJsonObject("data").getString("DownloadURL");
|
||
}
|
||
|
||
if (StringUtils.isEmpty(downURL)) {
|
||
fail(failPrefix + "未获取到下载链接");
|
||
return;
|
||
}
|
||
|
||
try {
|
||
Map<String, String> urlParams = CommonUtils.getURLParams(downURL);
|
||
String params = urlParams.get("params");
|
||
if (StringUtils.isEmpty(params)) {
|
||
complete(downURL);
|
||
return;
|
||
}
|
||
|
||
byte[] decodeByte = Base64.getDecoder().decode(params);
|
||
String downUrl2 = new String(decodeByte);
|
||
|
||
clientNoRedirects.getAbs(downUrl2).putHeaders(header).send().onSuccess(res3 -> {
|
||
if (res3.statusCode() == 302 || res3.statusCode() == 301) {
|
||
String redirectUrl = res3.getHeader("Location");
|
||
if (StringUtils.isBlank(redirectUrl)) {
|
||
fail("重定向链接为空");
|
||
return;
|
||
}
|
||
complete(redirectUrl);
|
||
return;
|
||
}
|
||
JsonObject res3Json = asJson(res3);
|
||
try {
|
||
if (res3Json.getInteger("code") != 0) {
|
||
fail(failPrefix + "重定向返回值异常->" + res3Json);
|
||
return;
|
||
}
|
||
} catch (Exception ignored) {
|
||
fail(failPrefix + "重定向格式异常->" + downURLJson);
|
||
return;
|
||
}
|
||
String redirectUrl = res3Json.getJsonObject("data").getString("redirect_url");
|
||
if (StringUtils.isNotEmpty(redirectUrl)) {
|
||
complete(redirectUrl);
|
||
} else {
|
||
complete(downUrl2);
|
||
}
|
||
}).onFailure(err -> fail("获取直链失败: " + err.getMessage()));
|
||
} catch (MalformedURLException e) {
|
||
complete(downURL);
|
||
} catch (Exception e) {
|
||
fail("urlParams解析异常: " + e.getMessage());
|
||
}
|
||
}
|
||
|
||
void setFileInfo(JsonObject reqBodyJson) {
|
||
FileInfo fileInfo = new FileInfo();
|
||
fileInfo.setFileId(reqBodyJson.getInteger("FileId").toString());
|
||
fileInfo.setFileName(reqBodyJson.getString("FileName"));
|
||
fileInfo.setSize(reqBodyJson.getLong("Size"));
|
||
fileInfo.setHash(reqBodyJson.getString("Etag"));
|
||
|
||
String createAt = reqBodyJson.getString("CreateAt");
|
||
if (StringUtils.isNotEmpty(createAt)) {
|
||
fileInfo.setCreateTime(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")
|
||
.format(OffsetDateTime.parse(createAt).toLocalDateTime()));
|
||
}
|
||
|
||
String updateAt = reqBodyJson.getString("UpdateAt");
|
||
if (StringUtils.isNotEmpty(updateAt)) {
|
||
fileInfo.setUpdateTime(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")
|
||
.format(OffsetDateTime.parse(updateAt).toLocalDateTime()));
|
||
}
|
||
|
||
shareLinkInfo.getOtherParam().put("fileInfo", fileInfo);
|
||
}
|
||
|
||
@Override
|
||
public Future<List<FileInfo>> parseFileList() {
|
||
Promise<List<FileInfo>> promise = Promise.promise();
|
||
|
||
String shareKey = YeShareHostUtil.normalizeShareKey(shareLinkInfo.getShareKey());
|
||
String pwd = shareLinkInfo.getSharePassword();
|
||
String parentFileId = "0";
|
||
|
||
String dirId = (String) shareLinkInfo.getOtherParam().get("dirId");
|
||
if (StringUtils.isNotBlank(dirId)) {
|
||
parentFileId = dirId;
|
||
}
|
||
|
||
Future<String> tokenFuture = resolveTokenFuture();
|
||
String finalParentFileId = parentFileId;
|
||
tokenFuture.onSuccess(token -> {
|
||
if (token.equals("nologin")) {
|
||
promise.fail("该分享需要登录才能访问，请配置认证信息");
|
||
return;
|
||
}
|
||
|
||
String normalizedShareKey = YeShareHostUtil.normalizeShareKey(shareKey);
|
||
String shareOrigin = resolveYeShareOrigin(normalizedShareKey);
|
||
String shareReferer = buildShareReferer(shareOrigin, normalizedShareKey, pwd);
|
||
|
||
client.getAbs(UriTemplate.of(GET_SHARE_INFO_URL))
|
||
.setTemplateParam("shareKey", shareKey)
|
||
.setTemplateParam("pwd", StringUtils.isEmpty(pwd) ? "" : pwd)
|
||
.setTemplateParam("ParentFileId", finalParentFileId)
|
||
.putHeader("Authorization", "Bearer " + token)
|
||
.putHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36")
|
||
.putHeader("Referer", shareReferer)
|
||
.putHeader("Origin", shareOrigin)
|
||
.send().onSuccess(res -> {
|
||
JsonObject response = asJson(res);
|
||
if (response.getInteger("code") != 0) {
|
||
promise.fail("API错误: " + response.getString("message"));
|
||
return;
|
||
}
|
||
|
||
if (!response.containsKey("data") || !response.getJsonObject("data").containsKey("InfoList")) {
|
||
promise.fail("返回数据格式错误");
|
||
return;
|
||
}
|
||
|
||
JsonArray infoList = response.getJsonObject("data").getJsonArray("InfoList");
|
||
List<FileInfo> result = new ArrayList<>();
|
||
|
||
for (int i = 0; i < infoList.size(); i++) {
|
||
JsonObject item = infoList.getJsonObject(i);
|
||
FileInfo fileInfo = new FileInfo();
|
||
|
||
JsonObject postData = JsonObject.of()
|
||
.put("shareKey", shareLinkInfo.getShareKey())
|
||
.put("driveId", 0)
|
||
.put("etag", item.getString("Etag"))
|
||
.put("fileId", item.getInteger("FileId"))
|
||
.put("fileName", item.getString("FileName"))
|
||
.put("s3keyFlag", item.getString("S3KeyFlag"))
|
||
.put("size", item.getLong("Size"))
|
||
.put("type", 0);
|
||
|
||
String param = CommonUtils.urlBase64Encode(postData.encode());
|
||
|
||
if (item.getInteger("Type") == 0) {
|
||
fileInfo.setFileName(item.getString("FileName"))
|
||
.setFileId(item.getInteger("FileId").toString())
|
||
.setFileType("file")
|
||
.setSize(item.getLong("Size"))
|
||
.setHash(item.getString("Etag"))
|
||
.setSizeStr(FileSizeConverter.convertToReadableSize(item.getLong("Size")));
|
||
|
||
setFileTimes(item, fileInfo);
|
||
|
||
fileInfo.setParserUrl(String.format("%s/v2/redirectUrl/%s/%s", getDomainName(),
|
||
shareLinkInfo.getType(), param))
|
||
.setPreviewUrl(String.format("%s/v2/viewUrl/%s/%s", getDomainName(),
|
||
shareLinkInfo.getType(), param));
|
||
result.add(fileInfo);
|
||
} else if (item.getInteger("Type") == 1) {
|
||
fileInfo.setFileName(item.getString("FileName"))
|
||
.setFileId(item.getInteger("FileId").toString())
|
||
.setFileType("folder")
|
||
.setSize(0L);
|
||
|
||
setFileTimes(item, fileInfo);
|
||
|
||
fileInfo.setParserUrl(
|
||
String.format("%s/v2/getFileList?url=%s&dirId=%s&pwd=%s",
|
||
getDomainName(),
|
||
shareLinkInfo.getShareUrl(),
|
||
item.getInteger("FileId"),
|
||
pwd)
|
||
);
|
||
result.add(fileInfo);
|
||
}
|
||
}
|
||
promise.complete(result);
|
||
}).onFailure(promise::fail);
|
||
}).onFailure(err -> promise.fail("123盘解析异常: " + err.getMessage()));
|
||
|
||
return promise.future();
|
||
}
|
||
|
||
@Override
|
||
public Future<String> parseById() {
|
||
JsonObject paramJson = (JsonObject) shareLinkInfo.getOtherParam().get("paramJson");
|
||
Future<String> tokenFuture = resolveTokenFuture();
|
||
|
||
tokenFuture.onSuccess(token -> {
|
||
if (token.equals("nologin")) {
|
||
fail("该分享需要登录才能下载，请配置认证信息");
|
||
return;
|
||
}
|
||
|
||
String rawShareKey = paramJson.getString("shareKey");
|
||
if (StringUtils.isBlank(rawShareKey)) {
|
||
rawShareKey = paramJson.getString("ShareKey");
|
||
}
|
||
if (StringUtils.isBlank(rawShareKey)) {
|
||
rawShareKey = shareLinkInfo.getShareKey();
|
||
}
|
||
String normalizedShareKey = YeShareHostUtil.normalizeShareKey(rawShareKey);
|
||
if (StringUtils.isNotEmpty(normalizedShareKey)) {
|
||
JsonObject v2Body = new JsonObject()
|
||
.put("ShareKey", normalizedShareKey)
|
||
.put("FileID", paramJson.getInteger("fileId", paramJson.getInteger("FileID", 0)))
|
||
.put("S3keyFlag", paramJson.getString("s3keyFlag", paramJson.getString("S3keyFlag", "")))
|
||
.put("Size", paramJson.getLong("size", paramJson.getLong("Size", 0L)))
|
||
.put("Etag", paramJson.getString("etag", paramJson.getString("Etag", "")));
|
||
requestShareV2Download(normalizedShareKey, v2Body).onSuccess(v2Url -> {
|
||
if (StringUtils.isNotEmpty(v2Url)) {
|
||
complete(v2Url);
|
||
return;
|
||
}
|
||
parseByIdLegacy(token, paramJson);
|
||
}).onFailure(err -> {
|
||
log.warn("Ye2 parseById v2接口失败，回退旧接口: {}", err.getMessage());
|
||
parseByIdLegacy(token, paramJson);
|
||
});
|
||
return;
|
||
}
|
||
|
||
parseByIdLegacy(token, paramJson);
|
||
}).onFailure(err -> fail("123盘解析异常: " + err.getMessage()));
|
||
|
||
return promise.future();
|
||
}
|
||
|
||
private void parseByIdLegacy(String token, JsonObject paramJson) {
|
||
if (paramJson.containsKey("FileID") && !paramJson.containsKey("fileId")) {
|
||
paramJson.put("fileId", paramJson.getValue("FileID"));
|
||
}
|
||
if (paramJson.containsKey("S3keyFlag") && !paramJson.containsKey("s3keyFlag")) {
|
||
paramJson.put("s3keyFlag", paramJson.getValue("S3keyFlag"));
|
||
}
|
||
if (paramJson.containsKey("Size") && !paramJson.containsKey("size")) {
|
||
paramJson.put("size", paramJson.getValue("Size"));
|
||
}
|
||
if (paramJson.containsKey("Etag") && !paramJson.containsKey("etag")) {
|
||
paramJson.put("etag", paramJson.getValue("Etag"));
|
||
}
|
||
|
||
String timestamp = String.valueOf(System.currentTimeMillis());
|
||
String encryptedParams = encode123("/b/api/file/download_info", "android", "55", timestamp);
|
||
String apiUrl = DOWNLOAD_API_URL + encryptedParams;
|
||
|
||
log.info("Ye2 parseById API URL: {}", apiUrl);
|
||
|
||
HttpRequest<Buffer> bufferHttpRequest = client.postAbs(apiUrl);
|
||
bufferHttpRequest.putHeader("platform", "android");
|
||
bufferHttpRequest.putHeader("App-Version", "55");
|
||
bufferHttpRequest.putHeader("Authorization", "Bearer " + token);
|
||
bufferHttpRequest.putHeader("User-Agent", "Mozilla/5.0 (Linux; Android 13) AppleWebKit/537.36");
|
||
bufferHttpRequest.putHeader("Content-Type", "application/json");
|
||
|
||
bufferHttpRequest
|
||
.sendJsonObject(paramJson)
|
||
.onSuccess(res2 -> handleDownloadUrlResponse(client, asJson(res2), "Ye2"))
|
||
.onFailure(err -> fail("下载接口失败: " + err.getMessage()));
|
||
}
|
||
|
||
private void setFileTimes(JsonObject item, FileInfo fileInfo) {
|
||
String createAt = item.getString("CreateAt");
|
||
if (StringUtils.isNotEmpty(createAt)) {
|
||
fileInfo.setCreateTime(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")
|
||
.format(OffsetDateTime.parse(createAt).toLocalDateTime()));
|
||
}
|
||
|
||
String updateAt = item.getString("UpdateAt");
|
||
if (StringUtils.isNotEmpty(updateAt)) {
|
||
fileInfo.setUpdateTime(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")
|
||
.format(OffsetDateTime.parse(updateAt).toLocalDateTime()));
|
||
}
|
||
}
|
||
|
||
private String resolveYeShareOrigin(String shareKey) {
|
||
String origin = extractYeShareOrigin(shareLinkInfo.getShareUrl());
|
||
if (StringUtils.isNotBlank(origin)) {
|
||
return origin;
|
||
}
|
||
origin = extractYeShareOrigin(shareLinkInfo.getStandardUrl());
|
||
if (StringUtils.isNotBlank(origin)) {
|
||
return origin;
|
||
}
|
||
String uid = YeShareHostUtil.getNumericSubdomainIdByShareKey(shareKey);
|
||
if (StringUtils.isNotBlank(uid)) {
|
||
return "https://" + uid + ".share.123pan.cn";
|
||
}
|
||
return "https://www.123pan.com";
|
||
}
|
||
|
||
private String extractYeShareOrigin(String url) {
|
||
if (StringUtils.isBlank(url) || !url.matches("^https?://[a-zA-Z\\d-]+\\.(?:mshare|share)\\.123pan\\.cn(?:[:/].*)?$")) {
|
||
return "";
|
||
}
|
||
int idx = url.indexOf('/', url.indexOf("//") + 2);
|
||
return idx > 0 ? url.substring(0, idx) : url;
|
||
}
|
||
|
||
private String buildShareReferer(String shareOrigin, String shareKey, String pwd) {
|
||
String key = YeShareHostUtil.normalizeShareKey(shareKey);
|
||
if (StringUtils.isBlank(key)) {
|
||
return shareOrigin + "/";
|
||
}
|
||
String referer = shareOrigin + "/123pan/" + key;
|
||
if (StringUtils.isNotBlank(pwd)) {
|
||
referer += "?pwd=" + pwd;
|
||
}
|
||
return referer;
|
||
}
|
||
}
|