wangliwen
/
share-platform
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

西海岸的处理

This commit is contained in:
wangliwen 2022-06-24 15:01:40 +08:00
parent ce43a9fced
commit bb8e2e5759
1 changed files with 18 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
renren-admin/src/main/java/io/renren/common/controller/CensusControllerV2.java
View File

@ -291,11 +291,11 @@ public class CensusControllerV2 {
}); });
}); });
CompletableFuture<Void> allKnowledgeVisitsAmount = CompletableFuture.supplyAsync(() -> { // 获取平台知识库浏览量 CompletableFuture<Void> allKnowledgeVisitsAmount = CompletableFuture.supplyAsync(() -> { // 获取平台知识库浏览量
return jdbcTemplate.queryForObject("SELECT SUM(visits)visits FROM tb_data_resource WHERE type ='知识库' AND del_flag = 0;", Long.class); return jdbcTemplate.queryForObject("SELECT SUM(visits) visits FROM tb_data_resource WHERE type ='知识库' AND del_flag = 0;", Long.class);
}).thenAccept(sum -> { }).thenAccept(sum -> {
result.add(new HashMap<String, Object>() { result.add(new HashMap<String, Object>() {
{ {
put("amount", sum); put("amount", sum == null ? 0L : sum);
put("type", "知识库总浏览量"); put("type", "知识库总浏览量");
} }
}); });
@ -336,45 +336,22 @@ public class CensusControllerV2 {
case TSINGTAO_XHA: { // 青岛西海岸 case TSINGTAO_XHA: { // 青岛西海岸
allAmount = CompletableFuture.supplyAsync(() -> { // 获取平台总基础设施数目 allAmount = CompletableFuture.supplyAsync(() -> { // 获取平台总基础设施数目
List<Long> result_ = new CopyOnWriteArrayList<>(); List<Long> result_ = new CopyOnWriteArrayList<>();
CompletableFuture cloud = OkHttpClient client = new OkHttpClient();
CompletableFuture.runAsync(() -> { // 云脑专网 String url = String.format(tsingtao_xhaProperties.getCloudcam(), "", 1, 10);
OkHttpClient client = new OkHttpClient(); logger.info(url);
String url = String.format(tsingtao_xhaProperties.getCloudcam(), "", 1, 10); Request request = new Request.Builder().url(url).build();
logger.info(url); try (Response response = client.newCall(request).execute()) {
Request request = new Request.Builder().url(url).build(); if (response.isSuccessful()) {
try (Response response = client.newCall(request).execute()) { JSONObject jsonObject = JSON.parseObject(response.body().string());
if (response.isSuccessful()) { if (jsonObject.containsKey("data")) {
JSONObject jsonObject = JSON.parseObject(response.body().string()); result_.add(jsonObject.getJSONObject("data").getLongValue("total"));
if (jsonObject.containsKey("data")) { }
result_.add(jsonObject.getJSONObject("data").getLongValue("total")); } else {
} logger.error("青岛西海岸获取失败");
} else { }
logger.error("青岛西海岸获取失败"); } catch (Exception exception) {
} logger.error("青岛西海岸失败", exception);
} catch (Exception exception) { }
logger.error("青岛西海岸失败", exception);
}
});
CompletableFuture local =
CompletableFuture.runAsync(() -> { // 金宏网
OkHttpClient client = new OkHttpClient();
String url = String.format(tsingtao_xhaProperties.getLocalcam(), "", 1, 10);
logger.info(url);
Request request = new Request.Builder().url(url).build();
try (Response response = client.newCall(request).execute()) {
if (response.isSuccessful()) {
JSONObject jsonObject = JSON.parseObject(response.body().string());
if (jsonObject.containsKey("data")) {
result_.add(jsonObject.getJSONObject("data").getLongValue("total"));
}
} else {
logger.error("青岛西海岸获取失败");
}
} catch (Exception exception) {
logger.error("青岛西海岸失败", exception);
}
});
CompletableFuture.allOf(cloud, local);
return result_.stream().filter(index -> index != null).findAny().orElse(0l); return result_.stream().filter(index -> index != null).findAny().orElse(0l);
}).thenAccept(sum -> { }).thenAccept(sum -> {
result.add(new HashMap<String, Object>() { result.add(new HashMap<String, Object>() {