新諾瓦批量截圖改成同步獲取截圖

MercuryZ

2022-12-05 c104ea8b0bb99e058633770016abebe117d53d00

 ximon-admin/src/main/java/com/sandu/ximon/admin/newnova/utils/NovaAPIUtil.java

@@ -53,7 +53,28 @@
        System.out.println("nvInit(sdk 初始化):");
        System.out.println(instance.nvInit(rootDir, companyInfo));

        StatusVO searchVO = new StatusVO();
        System.out.println("ViplexCore Demo nvSearchTerminalAsync(搜索) begin... ");

        CountDownLatch countDownLatch1 = new CountDownLatch(1);
        instance.nvSearchTerminalAsync(new ViplexCore.CallBack() {

            @Override
            public void dataCallBack(int code, String data) {
                searchVO.setStatusCode(code);
                searchVO.setStatusData(data);
                loginInfo = data;
                System.out.println("\nViplexCore 搜索 code:" + code);
                System.out.println("\nViplexCore 搜索 data:" + data);
                countDownLatch1.countDown();
            }
        });

        try {
            countDownLatch1.await(10000, TimeUnit.MILLISECONDS);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
//        login("MZVA51930N2113017308");
    }

@@ -78,28 +99,6 @@
     * 5：公网SDK登录
     */
    public StatusVO login(String sn, Integer loginType) {

        StatusVO searchVO = new StatusVO();
        System.out.println("ViplexCore Demo nvSearchTerminalAsync(搜索) begin... ");

        CountDownLatch countDownLatch1 = new CountDownLatch(1);
        instance.nvSearchTerminalAsync(new ViplexCore.CallBack() {

            @Override
            public void dataCallBack(int code, String data) {
                searchVO.setStatusCode(code);
                searchVO.setStatusData(data);
                loginInfo = data;
                System.out.println("\nViplexCore 搜索 code:" + code);
                System.out.println("\nViplexCore 搜索 data:" + data);
                countDownLatch1.countDown();
            }
        });
        try {
            countDownLatch1.await(10000, TimeUnit.MILLISECONDS);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }

        if (loginSn.get(sn) != null && loginSn.get(sn) && loginType == 0) {
            return new StatusVO(0);
@@ -822,6 +821,7 @@
                            System.out.println("\nViplexCore 重启 data:" + data);
                            if (code == 0) {
                                newNova.setStatus(true);
                                loginSn.remove(newNova.getSn());
                            }
                            countDownLatch.countDown();
                        }
@@ -837,7 +837,6 @@
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }

        return param.getNovaList();
    }

@@ -871,7 +870,7 @@
                    "        \"action\":4,\n" +
                    "        \"data\":{\n" +
                    "          \"enable\":" + param.isNtp() + ",\n" +
                    "          \"server\":\"ntp1.aliyun.com\"\n" +
                    "          \"server\":\"http://ntp1.aliyun.com\"\n" +
                    "        }\n" +
                    "      }\n" +
                    "    ]\n" +
@@ -896,7 +895,7 @@
            });
        });
        try {
            countDownLatch.await(20000, TimeUnit.MILLISECONDS);
            countDownLatch.await(30000, TimeUnit.MILLISECONDS);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
@@ -912,14 +911,12 @@
        System.out.println("ViplexCore Demo nvDownLoadScreenshotAsync(截屏) begin... ");
        NovaFileConfig config = SpringContextHolder.getBean(NovaFileConfig.class);
        String shotPath = config.getScreenShotPath();
        CountDownLatch countDownLatch = new CountDownLatch(param.getScreenShotList().size());
        param.getScreenShotList().forEach(newNova -> {

        for(NewNovaStatusParam.NovascreenShotDTO newNova:param.getScreenShotList()){
            StatusVO login = login(newNova.getSn(), 0);
            if (login.getStatusCode() != 0) {
                countDownLatch.countDown();
                return;
                continue;
            }
            CountDownLatch countDownLatch = new CountDownLatch(1);
            String pictureName = newNova.getSn() + ".png";
            String str = "{\n" +
                    "  \"sn\":\"" + newNova.getSn() + "\",\n" +
@@ -947,14 +944,13 @@
                    countDownLatch.countDown();
                }
            });

        });
        try {
            countDownLatch.await(30000, TimeUnit.MILLISECONDS);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
            //等待設備回調信息
            try {
                countDownLatch.await(5000, TimeUnit.MILLISECONDS);
            } catch (InterruptedException ex) {
                throw new RuntimeException(ex);
            }
        }

        return param.getScreenShotList();
    }