ahdoawhfo/netdisk-fast-download
1
0
Fork 0
mirror of https://github.com/qaiu/netdisk-fast-download.git synced 2025-12-17 04:43:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/main'

Browse Source
This commit is contained in:
QAIU
2023-06-21 15:40:42 +08:00
parent 998c6e4627 e284dfca63
commit e07d427f85
3 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
.vscode/settings.json vendored Normal file
View File

@@ -0,0 +1,3 @@
{
"java.compile.nullAnalysis.mode": "automatic"
}

2
web-service/src/main/java/cn/qaiu/lz/AppMain.java
View File

@@ -10,7 +10,7 @@ import io.vertx.core.json.JsonObject;
* 程序入口 * 程序入口
* <br>Create date 2021-05-08 13:00:01 * <br>Create date 2021-05-08 13:00:01
* *
* @author qiu * @author qaiu
*/ */
public class AppMain { public class AppMain {

6
web-service/src/main/java/cn/qaiu/lz/common/parser/impl/CowTool.java
View File

@@ -2,9 +2,9 @@ package cn.qaiu.lz.common.parser.impl;
import cn.qaiu.lz.common.parser.IPanTool; import cn.qaiu.lz.common.parser.IPanTool;
import cn.qaiu.lz.common.util.CommonUtils; import cn.qaiu.lz.common.util.CommonUtils;
import cn.qaiu.vx.core.util.VertxHolder;
import io.vertx.core.Future; import io.vertx.core.Future;
import io.vertx.core.Promise; import io.vertx.core.Promise;
import io.vertx.core.Vertx;
import io.vertx.core.json.JsonObject; import io.vertx.core.json.JsonObject;
import io.vertx.ext.web.client.WebClient; import io.vertx.ext.web.client.WebClient;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@@ -24,7 +24,7 @@ public class CowTool implements IPanTool {
public Future<String> parse(String data, String code) { public Future<String> parse(String data, String code) {
Promise<String> promise = Promise.promise(); Promise<String> promise = Promise.promise();
WebClient client = WebClient.create(Vertx.vertx()); WebClient client = WebClient.create(VertxHolder.getVertxInstance());
String key = CommonUtils.adaptShortPaths(SHARE_URL_PREFIX, data); String key = CommonUtils.adaptShortPaths(SHARE_URL_PREFIX, data);
client.getAbs(API_REQUEST_URL + "?uniqueUrl=" + key).send().onSuccess(res -> { client.getAbs(API_REQUEST_URL + "?uniqueUrl=" + key).send().onSuccess(res -> {
JsonObject resJson = res.bodyAsJsonObject(); JsonObject resJson = res.bodyAsJsonObject();
@@ -44,10 +44,12 @@ public class CowTool implements IPanTool {
} }
} else { } else {
log.error("cow parse fail: {}; json: {}", url2, res2Json); log.error("cow parse fail: {}; json: {}", url2, res2Json);
promise.fail("cow parse fail: " + url2 + "; json:" + res2Json);
} }
}); });
} else { } else {
log.error("cow parse fail: {}; json: {}", key, resJson); log.error("cow parse fail: {}; json: {}", key, resJson);
promise.fail("cow parse fail: " + key + "; json:" + resJson);
} }
}); });
return promise.future(); return promise.future();