From 4dd900d3ba36d12adf860eb5a28a40589f55e0a2 Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期三, 07 九月 2022 18:29:47 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java | 105 ++++++++++++++++++++++------------------------------
1 files changed, 44 insertions(+), 61 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java
index a4ab9d8..b2d19f2 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java
@@ -18,6 +18,8 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
@Component("VnnoxAPIUtil")
@AllArgsConstructor
@@ -25,6 +27,8 @@
//@Autowired
private RedisUtils redisUtils;
+
+ private CountDownLatchUtil countDownLatchUtil;
public static VnnoxAPIUtil getBean() {
return (VnnoxAPIUtil) SpringContextUtil.getBean("VnnoxAPIUtil");
@@ -34,11 +38,7 @@
* 鑾峰彇token
*/
public void getToken() {
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.GET_TOKEN),
- new VnnoxGetTokenRequest().toJson(),
- new CommonHeader(CommonHeader.FORM, false)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.GET_TOKEN), new VnnoxGetTokenRequest().toJson(), new CommonHeader(CommonHeader.FORM, false));
CommonResponse commonResponse = JSON.parseObject(result, CommonResponse.class);
VnnoxGetTokenResponse response = new VnnoxGetTokenResponse().parse(commonResponse);
@@ -61,11 +61,7 @@
urlParameters.add(new BasicNameValuePair("start", start.toString()));
urlParameters.add(new BasicNameValuePair("name", name));
- String result = VnnoxRequestUtil.GetWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.GET_PLAYER_LIST),
- urlParameters,
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.GetWithHeader(VnnoxUrl.getUrl(VnnoxUrl.GET_PLAYER_LIST), urlParameters, new CommonHeader(CommonHeader.JSON, true));
return new VnnoxPlayerListResponse().parse(JSON.parseObject(result, CommonResponse.class));
}
@@ -88,11 +84,7 @@
VnnoxSyncCurrentInfoRequest vnnoxSyncCurrentInfoRequest = new VnnoxSyncCurrentInfoRequest();
vnnoxSyncCurrentInfoRequest.setPlayerIds(playerIds);
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.SYNC_CURRENT_INFO),
- vnnoxSyncCurrentInfoRequest.toJson(),
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.SYNC_CURRENT_INFO), vnnoxSyncCurrentInfoRequest.toJson(), new CommonHeader(CommonHeader.JSON, true));
VnnoxSyncCurrentInfoResponse response = JSON.parseObject(result, VnnoxSyncCurrentInfoResponse.class);
@@ -126,11 +118,7 @@
vnnoxScreenStatusRequest.setPlayerIds(playerIds);
vnnoxScreenStatusRequest.setStatus(type);
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.SCREEN_STATUS),
- vnnoxScreenStatusRequest.toJson(),
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.SCREEN_STATUS), vnnoxScreenStatusRequest.toJson(), new CommonHeader(CommonHeader.JSON, true));
VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
@@ -151,11 +139,7 @@
request.setPlayerIds(playerIds);
request.setValue(vol);
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.CHANGE_VOL),
- request.toJson(),
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.CHANGE_VOL), request.toJson(), new CommonHeader(CommonHeader.JSON, true));
VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
return response.getData();
@@ -174,11 +158,7 @@
request.setPlayerIds(playerIds);
request.setValue(brightness);
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.CHANGE_BRIGHTNESS),
- request.toJson(),
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.CHANGE_BRIGHTNESS), request.toJson(), new CommonHeader(CommonHeader.JSON, true));
VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
return response.getData();
@@ -197,11 +177,7 @@
request.setPlayerIds(players);
request.setNoticeUrl(VnnoxConstant.SCREEN_SHOT_NOTIFY_URL);
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.SCREEN_SHOT),
- request.toJson(),
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.SCREEN_SHOT), request.toJson(), new CommonHeader(CommonHeader.JSON, true));
VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
return response.getData();
@@ -219,11 +195,7 @@
request.setPlayerIds(players);
request.setNoticeUrl(VnnoxConstant.SCREEN_SHOT_NOTIFY_URL);
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.SCREEN_SHOT),
- request.toJson(),
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.SCREEN_SHOT), request.toJson(), new CommonHeader(CommonHeader.JSON, true));
if (result.startsWith("{") && result.endsWith("}")) {
VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
@@ -254,11 +226,7 @@
request.setPlayerIds(playerIdList);
request.setNoticeUrl(VnnoxConstant.SCREEN_SHOT_NOTIFY_URL);
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.REBOOT),
- request.toJson(),
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.REBOOT), request.toJson(), new CommonHeader(CommonHeader.JSON, true));
VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
return response.getData();
@@ -273,11 +241,7 @@
request.setOption(option);
request.setNoticeUrl(VnnoxConstant.SCREEN_SHOT_NOTIFY_URL);
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.SIMU_LCAST),
- request.toJson(),
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.SIMU_LCAST), request.toJson(), new CommonHeader(CommonHeader.JSON, true));
VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
return response.getData();
@@ -298,11 +262,7 @@
map.put("noticeUrl", VnnoxConstant.SCREEN_SHOT_NOTIFY_URL);
map.put("playerIds", playerId);
String s = JSON.toJSONString(map);
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.NTP_SYNC),
- s,
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.NTP_SYNC), s, new CommonHeader(CommonHeader.JSON, true));
VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
return response.getData();
@@ -322,11 +282,7 @@
VnnoxSyncCurrentInfoRequest vnnoxSyncCurrentInfoRequest = new VnnoxSyncCurrentInfoRequest();
vnnoxSyncCurrentInfoRequest.setPlayerIds(playerIds);
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.SYNC_CURRENT_INFO),
- vnnoxSyncCurrentInfoRequest.toJson(),
- new CommonHeader(CommonHeader.JSON, true)
- );
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.SYNC_CURRENT_INFO), vnnoxSyncCurrentInfoRequest.toJson(), new CommonHeader(CommonHeader.JSON, true));
VnnoxSyncCurrentInfoResponse response = JSON.parseObject(result, VnnoxSyncCurrentInfoResponse.class);
@@ -338,8 +294,35 @@
}
}
}
- return list;
+ return list;
}
+ /**
+ * 鑾峰彇闊抽噺,浜害
+ */
+ public VnnoxResultResponse asyncStatus(List<String> playerId) {
+ List<String> commands = new ArrayList<>();
+ commands.add("volumeValue");
+ commands.add("brightnessValue");
+ VnnoxBaseRequest request = new VnnoxBaseRequest();
+ request.setPlayerIds(playerId);
+ request.setCommands(commands);
+ request.setNoticeUrl(VnnoxConstant.STATUS_NOTIFY_URL);
+
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.ASYNCURRENTSTATUS), request.toJson(), new CommonHeader(CommonHeader.JSON, true));
+ VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
+ System.out.println(response.toString());
+ int size = response.getData().getSuccess().size();
+ CountDownLatch countDownLatch = new CountDownLatch(size * 2);
+ countDownLatchUtil.push(response.getLogid(), countDownLatch);
+ try {
+ countDownLatch.await(10000, TimeUnit.MILLISECONDS);
+ countDownLatchUtil.remove(response.getLogid());
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
+
+ return response;
+ }
}
\ No newline at end of file
--
Gitblit v1.9.3