From 5e94332935da62448c17f89a807acf46a5ae3e75 Mon Sep 17 00:00:00 2001
From: Van333 <van666666@foxmail.com>
Date: 星期四, 15 十二月 2022 10:08:22 +0800
Subject: [PATCH] 本地诺瓦调整
---
ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java | 73 +++++++++++++++++++++++++++++++++---
1 files changed, 66 insertions(+), 7 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java
index cc8661a..5d72bb8 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java
@@ -1,13 +1,21 @@
package com.sandu.ximon.admin.localMQTT.controller;
import com.sandu.ximon.admin.localMQTT.util.MqttClientUtil;
+import com.sandu.ximon.admin.newnova.param.NewNovaStatusParam;
+import com.sandu.ximon.admin.newnova.utils.NovaAPIUtil;
import com.sandu.ximon.admin.utils.RedisUtils;
+import com.sandu.ximon.dao.domain.NewNovaLed;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+import java.util.ArrayList;
+import java.util.List;
+
import static com.sandu.ximon.admin.localMQTT.callback.StatusMqttCallBack.localMqttConnectStatus;
+import static com.sandu.ximon.admin.newnova.utils.NovaAPIUtil.loginSn;
+import static com.sandu.ximon.admin.newnova.utils.NovaAPIUtil.searchStatus;
import static java.lang.Thread.sleep;
/**
@@ -25,7 +33,7 @@
@RequestMapping("/test")
public String localMQTT() throws InterruptedException {
- for (int i = 0; i < 1000; i++) {
+ for (int i = 0; i < 1; i++) {
/*
* 寮�鐏�100
@@ -74,15 +82,66 @@
// log.info("瀹氭椂浠诲姟杩斿洖缁撴灉:"+result4);
// sleep(3000);
- boolean set = RedisUtils.getBean().set(localMqttConnectStatus+"363832544e5008ff4734ffff",0);
- System.out.println(set);
- System.out.println(RedisUtils.getBean().get(localMqttConnectStatus+"363832544e5008ff4734ffff"));
- System.out.println("1".equals(RedisUtils.getBean().get(localMqttConnectStatus+"363832544e5008ff4734ffff")));
- System.out.println("------------");
+// boolean set = RedisUtils.getBean().set(localMqttConnectStatus+"363832544e5008ff4734ffff",0);
+// System.out.println(set);
+// System.out.println(RedisUtils.getBean().get(localMqttConnectStatus+"363832544e5008ff4734ffff"));
+// System.out.println("1".equals(RedisUtils.getBean().get(localMqttConnectStatus+"363832544e5008ff4734ffff")));
+// System.out.println("------------");
// System.out.println("閾炬帴鐘舵�侊細---"+i+"---:");
// System.out.println(RedisUtils.getBean().get(localMqttConnectStatus+"363832544e5008ff4734ffff"));
- sleep(1000);
+// sleep(1000);
+ NovaAPIUtil instanceUtil = NovaAPIUtil.getInstanceUtil();
+ System.out.println(instanceUtil);
+
+
+// System.out.println("寰幆閲嶅鐧诲綍锛�");
+// for (int j = 0; j < 1; j++) {
+// System.out.println(j+"娆″惊鐜�,寮�濮�");
+// loginSn.forEach(
+// (sn,data)->{
+// instanceUtil.login(sn, 0);
+// }
+// );
+// System.out.println(j+"娆″惊鐜�,缁撴潫");
+// }
+
+ System.out.println("寰幆閲嶅鎴浘锛�");
+ NewNovaStatusParam newNovaStatusParam = new NewNovaStatusParam();
+ List<NewNovaStatusParam.NovascreenShotDTO> list = new ArrayList<>();
+ NewNovaStatusParam.NovascreenShotDTO dto = new NewNovaStatusParam.NovascreenShotDTO();
+ List<NewNovaStatusParam.NovaDTO> novaList = new ArrayList<>();
+
+
+ loginSn.forEach(
+ (sn,data)->{
+ dto.setSn(sn);
+ list.add(dto);
+ }
+ );
+
+// instanceUtil.reboot();
+
+ newNovaStatusParam.setScreenShotList(list);
+ System.out.println("list涓竴鍏�"+list.size()+"涓睆骞�");
+ System.out.println("loginSn"+loginSn.size()+"涓睆骞�");
+ for (int j = 0; j < 1; j++) {
+ System.out.println(j+"娆″惊鐜�,寮�濮�");
+ List<NewNovaLed> newNovaLedList = new ArrayList<>();
+ loginSn.forEach(
+ (sn,data)->{
+ instanceUtil.screenShot(newNovaStatusParam);
+ NewNovaLed newNovaLed = new NewNovaLed();
+ newNovaLed.setSn(sn);
+ instanceUtil.getInfo(newNovaLed);
+ newNovaLedList.add(newNovaLed);
+ }
+
+ );
+ instanceUtil.getOnlineStatus(newNovaLedList,false);
+ System.out.println(j+"娆″惊鐜�,缁撴潫");
+ }
+
}
--
Gitblit v1.9.3