XMPoleManager.git

			@@ -1,12 +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 static com.sandu.ximon.admin.localMQTT.callback.StatusMqttCallBack.localMqttConnectStatusMap;
			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;

			/**
			@@ -24,7 +33,7 @@
			@RequestMapping("/test")
			public String localMQTT() throws InterruptedException {

			for (int i = 0; i < 100; i++) {
			for (int i = 0; i < 1; i++) {

			/*
			* 开灯100
			@@ -40,29 +49,99 @@
			* 5分钟
			* FEA501000CFE210004FFFF012C4A7824285825CB53
			* */
			// 开10
			String result1 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
			"FEA501000BFE010003FFFF0AA542FD69D4E6194E");
			log.info("开灯返回结果:"+result1);
			sleep(5000);
			// 关
			String result2 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
			"FEA501000BFE0100030001007130ECA9150640E6");
			log.info("关灯返回结果:"+result2);
			sleep(5000);
			//// 开10
			// String result1 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
			// "FEA501000BFE010003FFFF0AA542FD69D4E6194E");
			// log.info("开灯返回结果:"+result1);
			// sleep(5000);
			//// 关
			// String result2 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
			// "FEA501000BFE0100030001007130ECA9150640E6");
			// log.info("关灯返回结果:"+result2);
			// sleep(5000);
			//// 心跳查询
			String result3 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
			"FEA501000AFE110002FFFF26008FBE3DAC7C0D");
			log.info("心跳查询返回结果:"+result3);
			sleep(3000);
			String result4 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
			"FEA501001AFE230012FE23000A00017F1019647F111E005428F600EC64EC194EA28A7C");
			log.info("定时任务返回结果:"+result4);
			sleep(3000);
			// String result3 = MqttClientUtil.sendMqttMsg("363832544e5008ff4734ffff",
			// "FEA501000AFE110002FFFF26008FBE3DAC7C0D");
			// log.info("心跳查询返回结果:"+result3);
			// sleep(1000);
			// String result = MqttClientUtil.sendMqttMsg("363832544e5008ff4734ffff",
			// "FEA501000CFE210004FFFF001E9BB444E9C75BDB49");
			// log.info("心跳设置返回结果:"+result);
			// sleep(1000);
			//// 设置心跳30秒
			// String result4 = MqttClientUtil.sendMqttMsg("363832544e5008ff4734ffff",
			// "FEA501000AFE110002FFFF26008FBE3DAC7C0D");
			// log.info("心跳查询返回结果:"+result4);
			// sleep(1000);
			// String result5 = MqttClientUtil.sendMqttMsg("363832544e5008ff4734ffff",
			// "FEA501000CFE210004FFFF001E9BB444E9C75BDB49");
			// log.info("心跳查询返回结果:"+result5);
			// sleep(1000);
			// String result4 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
			// "FEA501001AFE230012FE23000A00017F1019647F111E005428F600EC64EC194EA28A7C");
			// log.info("定时任务返回结果:"+result4);
			// sleep(3000);

			System.out.println("链接状态：---"+i+"---:");
			System.out.println(localMqttConnectStatusMap.get("363832544e5008ff3a32ffff"));
			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("------------");

			// System.out.println("链接状态：---"+i+"---:");
			// System.out.println(RedisUtils.getBean().get(localMqttConnectStatus+"363832544e5008ff4734ffff"));
			// 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+"次循环,结束");
			}


			}