aijinhui
2024-03-27 de8081cc012993d350cf2f06457527b76750c34d
ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java
@@ -278,42 +278,45 @@
    @Override
    public UnitVo unit() {
        UnitVo unitVo = new UnitVo();
        //雷达在线数量
        List<ArdEquipRadar> radarList = radarMapper.selectList(null);
        Timer timer = new Timer();
        TimerTask timerTask =new TimerTask(){
            @Override
            public void run(){
                Para.setI(0);
               for (int i = 0; i < radarList.size(); i++) {
                   ArdEquipRadar radar = radarList.get(i);
                   String host = radar.getIp();
                   String port = radar.getPort();
                    Thread thread = new Thread(){
                        @Override
                        public void run(){
                            try {
                                Socket socket = new Socket(host,Integer.valueOf(port));
                            } catch (Exception e) {
                                int num = Para.getI();
                                num++;
                            }
                        }
                    };
                    thread.start();
                }
                int n = Para.getI();
                Para.setJ(radarList.size() - Para.getI());
            }
        };
        Date date = new Date();
        timer.scheduleAtFixedRate(timerTask,date,5000);
        unitVo.setRadar(Para.getJ());
        //光电数量
        QueryWrapper<ArdCameras> queryWrapper = new QueryWrapper<>();
        queryWrapper.select("id").eq("gdtype","0").eq("state","1");
        List<ArdCameras> ardCameras = camerasMapper.selectList(queryWrapper);
        QueryWrapper<ArdEquipRadar> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("state",1);
        List<ArdEquipRadar> radarList = radarMapper.selectList(queryWrapper);
        unitVo.setRadar(radarList.size());
        QueryWrapper<ArdCameras> queryWrapperC = new QueryWrapper<>();
        queryWrapperC.select("id").eq("gdtype","0").eq("state","1");
        List<ArdCameras> ardCameras = camerasMapper.selectList(queryWrapperC);
        unitVo.setCamera(ardCameras.size());
//        //雷达在线数量
//        List<ArdEquipRadar> radarList = radarMapper.selectList(null);
//        Timer timer = new Timer();
//        TimerTask timerTask =new TimerTask(){
//            @Override
//            public void run(){
//                Para.setI(0);
//               for (int i = 0; i < radarList.size(); i++) {
//                   ArdEquipRadar radar = radarList.get(i);
//                   String host = radar.getIp();
//                   String port = radar.getPort();
//                    Thread thread = new Thread(){
//                        @Override
//                        public void run(){
//                            try {
//                                Socket socket = new Socket(host,Integer.valueOf(port));
//                            } catch (Exception e) {
//                                int num = Para.getI();
//                                num++;
//                            }
//                        }
//                    };
//                    thread.start();
//                }
//                int n = Para.getI();
//                Para.setJ(radarList.size() - Para.getI());
//            }
//        };
//        Date date = new Date();
//        timer.scheduleAtFixedRate(timerTask,date,5000);
//        unitVo.setRadar(Para.getJ());
        return unitVo;
    }