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;
|
|
/**
|
* @author van
|
* @version 1.0
|
* msg：
|
* @date 2022/11/11 14:18
|
*/
|
@RestController
|
@RequestMapping("/localMQTT")
|
@Slf4j
|
public class localMQTTTestController {
|
|
|
@RequestMapping("/test")
|
public String localMQTT() throws InterruptedException {
|
|
for (int i = 0; i < 1; i++) {
|
|
/*
|
* 开灯100
|
* FEA501000BFE010003FFFF0045971477B6D8C2CA
|
* 10
|
* FEA501000BFE010003FFFF0AA542FD69D4E6194E
|
* 关灯
|
* FEA501000BFE0100030001007130ECA9150640E6
|
* 查询心跳时间
|
* FEA501000AFE110002FFFF26008FBE3DAC7C0D
|
* 设置心跳30秒
|
* FEA501000CFE210004FFFF001E9BB444E9C75BDB49
|
* 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);
|
//// 心跳查询
|
// 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);
|
|
// 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+"次循环,结束");
|
}
|
|
|
}
|
|
|
return "OK";
|
}
|
}
|
