From c0bd1fc2ac4029a300feb56930c1d4e6d4829894 Mon Sep 17 00:00:00 2001
From: MercuryZ <zdmisif@126.com>
Date: 星期三, 07 九月 2022 14:06:09 +0800
Subject: [PATCH] 调整超时时间
---
ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java | 201 ++++++++++++++++++++++++++++++++++++++------------
1 files changed, 153 insertions(+), 48 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 276dbe1..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
@@ -1,8 +1,10 @@
package com.sandu.ximon.admin.utils;
import com.alibaba.fastjson.JSON;
+import com.sandu.common.util.SpringContextHolder;
import com.sandu.ximon.admin.config.VnnoxConstant;
import com.sandu.ximon.admin.config.VnnoxUrl;
+import com.sandu.ximon.admin.service.LedPlayerEntityService;
import com.sandu.ximon.admin.utils.request.*;
import com.sandu.ximon.admin.utils.response.*;
import com.sandu.ximon.dao.domain.LedPlayerEntity;
@@ -13,7 +15,11 @@
import java.net.URISyntaxException;
import java.util.ArrayList;
+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
@@ -22,6 +28,8 @@
//@Autowired
private RedisUtils redisUtils;
+ private CountDownLatchUtil countDownLatchUtil;
+
public static VnnoxAPIUtil getBean() {
return (VnnoxAPIUtil) SpringContextUtil.getBean("VnnoxAPIUtil");
}
@@ -29,39 +37,32 @@
/**
* 鑾峰彇token
*/
- public void getToken () {
- String result = VnnoxRequestUtil.PostWithHeader(
- VnnoxUrl.getUrl(VnnoxUrl.GET_TOKEN),
- new VnnoxGetTokenRequest().toJson(),
- new CommonHeader(CommonHeader.FORM, false)
- );
+ public void getToken() {
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.GET_TOKEN), new VnnoxGetTokenRequest().toJson(), new CommonHeader(CommonHeader.FORM, false));
- CommonResponse commonResponse = JSON.parseObject(result,CommonResponse.class);
+ CommonResponse commonResponse = JSON.parseObject(result, CommonResponse.class);
VnnoxGetTokenResponse response = new VnnoxGetTokenResponse().parse(commonResponse);
// 灏唗oken淇濆瓨鍒皉edis缂撳瓨涓�
- redisUtils.set(VnnoxConstant.REDIS_TOKEN_NAME,response.getToken(),(long)(response.getExpire()-30));
+ redisUtils.set(VnnoxConstant.REDIS_TOKEN_NAME, response.getToken(), (long) (response.getExpire() - 30));
}
/**
* 鑾峰彇鎾斁鍣ㄥ垪琛�
+ *
* @param count 姣忔璇诲彇鏁伴噺锛岄粯璁�20锛屽彇鍊艰寖鍥达細1~100
* @param start 浠庣鍑犳潯璁板綍寮�濮嬭鍙栵紝榛樿0
* @return
*/
- public VnnoxPlayerListResponse getPlayerList(Integer count, Integer start,String name) throws URISyntaxException {
+ public VnnoxPlayerListResponse getPlayerList(Integer count, Integer start, String name) throws URISyntaxException {
List<NameValuePair> urlParameters = new ArrayList<>();
- urlParameters.add(new BasicNameValuePair("count",count.toString()));
- urlParameters.add(new BasicNameValuePair("start",start.toString()));
- urlParameters.add(new BasicNameValuePair("name",name));
+ urlParameters.add(new BasicNameValuePair("count", count.toString()));
+ 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)
- );
- return new VnnoxPlayerListResponse().parse(JSON.parseObject(result,CommonResponse.class));
+ 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));
}
/**
@@ -72,6 +73,9 @@
*/
public List<LedPlayerEntity> syncCurrentInfo(List<LedPlayerEntity> list) {
List<String> playerIds = new ArrayList<>();
+ if (list.isEmpty()) {
+ return list;
+ }
for (LedPlayerEntity playerEntity : list) {
playerIds.add(playerEntity.getPlayerId());
@@ -80,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);
@@ -118,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);
@@ -143,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();
@@ -166,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();
@@ -189,14 +177,42 @@
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();
+ }
+
+
+ /**
+ * 鎵归噺灞忓箷鎴浘
+ *
+ * @param players
+ * @return
+ */
+ public VnnoxResult screenShot(List<String> players) {
+ VnnoxBaseRequest request = new VnnoxBaseRequest();
+ 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));
+
+ if (result.startsWith("{") && result.endsWith("}")) {
+ VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
+ if (response.getStatus() == 0) {
+ return response.getData();
+ } else {
+ System.out.println(response.getErrmsg());
+ VnnoxResult vnnoxResult = new VnnoxResult();
+ vnnoxResult.getFail().addAll(players);
+ return vnnoxResult;
+ }
+ } else {
+ System.out.println("鏁版嵁瑙ｆ瀽寮傚父!");
+ VnnoxResult vnnoxResult = new VnnoxResult();
+ vnnoxResult.getFail().addAll(players);
+ return vnnoxResult;
+ }
}
/**
@@ -210,14 +226,103 @@
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();
}
+ /**
+ * 鍚屾鎾斁
+ */
+ public VnnoxResult syncPlay(List<String> playerId, Integer option) {
+ VnnoxBaseRequest request = new VnnoxBaseRequest();
+ request.setPlayerIds(playerId);
+ 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));
+ VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
+
+ return response.getData();
+ }
+
+ /**
+ * NTP_SYNC
+ */
+ public VnnoxResult ntpSync(List<String> playerId, boolean enable) {
+// VnnoxBaseRequest request = new VnnoxBaseRequest();
+// request.setPlayerIds(playerId);
+// request.setEnable(enable);
+// request.setServer("ntp1.aliyun.com");
+// request.setNoticeUrl(VnnoxConstant.SCREEN_SHOT_NOTIFY_URL);
+ Map map = new HashMap();
+ map.put("server", "ntp1.aliyun.com");
+ map.put("enable", enable);
+ 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));
+ VnnoxResultResponse response = JSON.parseObject(result, VnnoxResultResponse.class);
+
+ return response.getData();
+ }
+
+
+ public List<LedPlayerEntity> saveCurrentInfo(List<LedPlayerEntity> list) {
+ List<String> playerIds = new ArrayList<>();
+ if (list.isEmpty()) {
+ return null;
+ }
+
+ for (LedPlayerEntity playerEntity : list) {
+ playerIds.add(playerEntity.getPlayerId());
+ }
+
+ VnnoxSyncCurrentInfoRequest vnnoxSyncCurrentInfoRequest = new VnnoxSyncCurrentInfoRequest();
+ vnnoxSyncCurrentInfoRequest.setPlayerIds(playerIds);
+
+ String result = VnnoxRequestUtil.PostWithHeader(VnnoxUrl.getUrl(VnnoxUrl.SYNC_CURRENT_INFO), vnnoxSyncCurrentInfoRequest.toJson(), new CommonHeader(CommonHeader.JSON, true));
+
+ VnnoxSyncCurrentInfoResponse response = JSON.parseObject(result, VnnoxSyncCurrentInfoResponse.class);
+
+ for (LedPlayerEntity playerEntity : list) {
+ for (VnnoxPlayerInfoResponse res : response.getData()) {
+ if (res.getPlayerId().equals(playerEntity.getPlayerId())) {
+ playerEntity.setResolution(res.getWidth() + " * " + res.getHeight());
+ break;
+ }
+ }
+ }
+ 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