From fe81b5844ad478a1b909026c9a0b1da6aacfc78f Mon Sep 17 00:00:00 2001
From: aijinhui <aijinhui>
Date: 星期一, 09 十月 2023 14:52:01 +0800
Subject: [PATCH] 24小时报警兴趣点前十

---
 ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java |  118 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 115 insertions(+), 3 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java b/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java
index c65b702..3920294 100644
--- a/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java
@@ -17,17 +17,23 @@
 import com.ruoyi.alarmpoints.well.mapper.ArdAlarmpointsWellMapper;
 import com.ruoyi.common.core.domain.entity.SysConfig;
 import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.device.camera.domain.ArdCameras;
+import com.ruoyi.device.camera.mapper.ArdCamerasMapper;
+import com.ruoyi.device.radar.domain.ArdEquipRadar;
+import com.ruoyi.device.radar.mapper.ArdEquipRadarMapper;
 import com.ruoyi.statistical.param.ESParam;
+import com.ruoyi.statistical.param.Para;
 import com.ruoyi.statistical.service.StatisticalService;
 import com.ruoyi.statistical.vo.CountVo;
+import com.ruoyi.statistical.vo.TenVo;
+import com.ruoyi.statistical.vo.UnitVo;
 import com.ruoyi.system.mapper.SysConfigMapper;
 import com.ruoyi.utils.result.Results;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.Calendar;
-import java.util.List;
-import java.util.Map;
+import java.net.Socket;
+import java.util.*;
 
 /**
  * @author Administrator
@@ -61,6 +67,10 @@
     private ArdAlarmDigitization3Mapper digitization3Mapper;
     @Autowired
     private ArdAlarmTubeMapper tubeMapper;
+    @Autowired
+    private ArdEquipRadarMapper radarMapper;
+    @Autowired
+    private ArdCamerasMapper camerasMapper;
 
 
     @Override
@@ -261,6 +271,108 @@
         return esMonth(list,esParam.getEnd());
     }
 
+    @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);
+        unitVo.setCamera(ardCameras.size());
+        return unitVo;
+    }
+
+    @Override
+    public int stealelecNum() {
+        return stealelecMapper.selectCount(null);
+    }
+
+    @Override
+    public int cameraNum() {
+        return cameraMapper.selectCount(null);
+    }
+
+    @Override
+    public int moveNum() {
+        return moveMapper.selectCount(null);
+    }
+
+    @Override
+    public int fireNum() {
+        return fireMapper.selectCount(null);
+    }
+
+    @Override
+    public int externalNum() {
+        return externalMapper.selectCount(null);
+    }
+
+    @Override
+    public int accessNum() {
+        return accessMapper.selectCount(null);
+    }
+
+    @Override
+    public int apponekeyNum() {
+        return apponekeyMapper.selectCount(null);
+    }
+
+    @Override
+    public int pumpNum() {
+        return pumpMapper.selectCount(null);
+    }
+
+    @Override
+    public int wallNum() {
+        return wallMapper.selectCount(null);
+    }
+
+    @Override
+    public int digitizationNum() {
+        return digitization3Mapper.selectCount(null);
+    }
+
+    @Override
+    public int tubeNum() {
+        return tubeMapper.selectCount(null);
+    }
+
+    @Override
+    public List<TenVo> ten() {
+        return moveMapper.ten();
+    }
+
     public List<CountVo> es(List<CountVo> list){
         for (int i = 1; i <= 12 ; i++) {
             String month;

--
Gitblit v1.9.3