油井数量

aijinhui

2024-04-12 5b992c91e2794311d5fc7cfc91cd68d9aed2573a

 ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java

@@ -137,7 +137,8 @@
        }
        //记录well表中oil_production为抽油机的数据有多少条
        QueryWrapper<ArdAlarmpointsWell> queryWrapperWell = new QueryWrapper<>();
        queryWrapperWell.eq("oil_production","抽油机");
//        queryWrapperWell.eq("oil_production","抽油机");
        queryWrapperWell.eq("well_type","1");
        int num = wellMapper.selectCount(queryWrapperWell);
        jsonObject.put("well",String.valueOf(num));
        return Results.succeed(jsonObject);
@@ -278,42 +279,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;
    }