2021与蓝度共同重构项目，服务端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
Van333
2022-12-15 5e94332935da62448c17f89a807acf46a5ae3e75 
 ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java


@@ -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(3000);


//            关


            String result2 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",


                    "FEA501000BFE0100030001007130ECA9150640E6");


            log.info("关灯返回结果:"+result2);


            sleep(3000);


////            开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",


//            String result3 = MqttClientUtil.sendMqttMsg("363832544e5008ff4734ffff",


//                    "FEA501000AFE110002FFFF26008FBE3DAC7C0D");


//            log.info("心跳查询返回结果:"+result3);


//            sleep(3000);


//            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(localMqttConnectStatusMap.get("363832544e5008ff3a32ffff"));


//            sleep(10000);


//            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+"次循环,结束");


            }






        }