ximon-admin/src/main/java/com/sandu/ximon/admin/config/VnnoxConstant.java
@@ -16,6 +16,7 @@ public static final Long REDIS_MAX_SAVE_TIME = 180 * 24 * 60 * 60L; public static final Long SCREEN_SHOT_TIMEOUT = 30 * 60L; public static final Long STATUS_TIME = 3 * 60 * 60L; public static final String NOTIFY_URL = "http://112.74.63.130:20017/serv/vnnox/progress"; public static final String SCREEN_SHOT_NOTIFY_URL = "http://112.74.63.130:20017/serv/vnnox/screenshot"; // TODO 要改 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/ServVnnoxController.java
@@ -15,8 +15,6 @@ import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.util.concurrent.CountDownLatch; //诺瓦回调 @RestController @RequestMapping("/serv/vnnox") @@ -32,6 +30,7 @@ @PostMapping("/screenshot") public ResponseVO<Object> screenshot(@RequestBody VnnoxScreenShotParam vnnoxScreenShot) { String url = vnnoxScreenShot.getScreenShotUrl().replace("&", "&"); System.out.println(vnnoxScreenShot); redisUtils.set(VnnoxConstant.REDIS_SCREEN_SHOT + vnnoxScreenShot.getPlayerId(), url); return ResponseUtil.success("ok"); } @@ -51,10 +50,10 @@ System.out.println(asyncStatusParam.toString()); if ("brightnessValue".equals(asyncStatusParam.getCommand())) { //亮度 redisUtils.set(VnnoxConstant.REDIS_BRIGHTNESS + asyncStatusParam.getPlayerId(), asyncStatusParam.getData().getRatio()); redisUtils.set(VnnoxConstant.REDIS_BRIGHTNESS + asyncStatusParam.getPlayerId(), asyncStatusParam.getData().getRatio(), VnnoxConstant.STATUS_TIME); } else if ("volumeValue".equals(asyncStatusParam.getCommand())) { //音量 redisUtils.set(VnnoxConstant.REDIS_VOL + asyncStatusParam.getPlayerId(), asyncStatusParam.getData().getRatio()); redisUtils.set(VnnoxConstant.REDIS_VOL + asyncStatusParam.getPlayerId(), asyncStatusParam.getData().getRatio(), VnnoxConstant.STATUS_TIME); } countDownLatchUtil.countDown(asyncStatusParam.getLogid()); return ResponseUtil.success("ok"); ximon-admin/src/main/java/com/sandu/ximon/admin/service/VnnoxService.java
@@ -173,7 +173,7 @@ VnnoxResult vnnoxResult = vnnoxAPIUtil.volChange(playerList.stream().map(item -> item.getPlayerId()).collect(Collectors.toList()), vol); // 根据音量调整REDIS标识位 for (String playerId : vnnoxResult.getSuccess()) { redisUtils.set(VnnoxConstant.REDIS_VOL + playerId, vol); redisUtils.set(VnnoxConstant.REDIS_VOL + playerId, vol,VnnoxConstant.STATUS_TIME); } List<String> success = vnnoxResult.getSuccess(); List<String> fail = vnnoxResult.getFail(); @@ -214,7 +214,7 @@ VnnoxResult vnnoxResult = vnnoxAPIUtil.brightnessChange(playerList.stream().map(item -> item.getPlayerId()).collect(Collectors.toList()), brightness); // 根据亮度调整REDIS标识位 for (String playerId : vnnoxResult.getSuccess()) { redisUtils.set(VnnoxConstant.REDIS_BRIGHTNESS + playerId, brightness); redisUtils.set(VnnoxConstant.REDIS_BRIGHTNESS + playerId, brightness, VnnoxConstant.STATUS_TIME); } List<String> success = vnnoxResult.getSuccess(); List<String> fail = vnnoxResult.getFail();