From 1ee59d5b4eba3605d4cd804a08887caaebb6e577 Mon Sep 17 00:00:00 2001
From: blank <2649084208@qq.com>
Date: Tue, 6 Dec 2022 15:08:52 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/ruoyi/api/app/DapingController.java   |  5 ++++
 .../com/ruoyi/api/mapper/DapingMapper.java    | 16 +++++++++++
 .../com/ruoyi/api/service/DapingService.java  |  5 ++++
 .../api/service/impl/DapingServiceImpl.java   | 27 +++++++++++++++++++
 .../resources/mapper/api/DapingMapper.xml     | 14 ++++++++++
 5 files changed, 67 insertions(+)

diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/app/DapingController.java b/ruoyi-api/src/main/java/com/ruoyi/api/app/DapingController.java
index b6655ed..73c707f 100644
--- a/ruoyi-api/src/main/java/com/ruoyi/api/app/DapingController.java
+++ b/ruoyi-api/src/main/java/com/ruoyi/api/app/DapingController.java
@@ -41,4 +41,9 @@ public class DapingController {
         return dapingService.getStationByStatus();
     }
 
+    @RequestMapping("/station/count")
+    public R getCount(){
+        return dapingService.getCount();
+    }
+
 }
diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/mapper/DapingMapper.java b/ruoyi-api/src/main/java/com/ruoyi/api/mapper/DapingMapper.java
index f220685..1a3b09b 100644
--- a/ruoyi-api/src/main/java/com/ruoyi/api/mapper/DapingMapper.java
+++ b/ruoyi-api/src/main/java/com/ruoyi/api/mapper/DapingMapper.java
@@ -48,4 +48,20 @@ public interface DapingMapper extends BaseMapper<WaterPhotoInfo> {
      * @return
      */
     Map<String,Object> selectStationByOfflineStatus();
+
+    /**
+     * 查询所有的区域
+     * @return
+     */
+    List<Map<String,Object>> selectAllAlea();
+
+    /**
+     * 查询某个区域的所有在线或者离线的设备数量
+     *  1 在线
+     *  0 离线
+     * @param status
+     * @param aleaId
+     * @return
+     */
+    Integer selectZXAndLXCount(@Param("status") Integer status,@Param("aleaId") Integer aleaId);
 }
diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/service/DapingService.java b/ruoyi-api/src/main/java/com/ruoyi/api/service/DapingService.java
index a3a82c1..c5ff551 100644
--- a/ruoyi-api/src/main/java/com/ruoyi/api/service/DapingService.java
+++ b/ruoyi-api/src/main/java/com/ruoyi/api/service/DapingService.java
@@ -29,4 +29,9 @@ public interface DapingService extends IService<WaterPhotoInfo> {
      * @return
      */
     R getStationByStatus();
+
+    /**
+     * 水位计分布
+     */
+    R getCount();
 }
diff --git a/ruoyi-api/src/main/java/com/ruoyi/api/service/impl/DapingServiceImpl.java b/ruoyi-api/src/main/java/com/ruoyi/api/service/impl/DapingServiceImpl.java
index 8bc4349..84f9bd7 100644
--- a/ruoyi-api/src/main/java/com/ruoyi/api/service/impl/DapingServiceImpl.java
+++ b/ruoyi-api/src/main/java/com/ruoyi/api/service/impl/DapingServiceImpl.java
@@ -85,4 +85,31 @@ public class DapingServiceImpl extends ServiceImpl<DapingMapper, WaterPhotoInfo>
         return R.ok().put("data",resultList);
     }
 
+    @Override
+    public R getCount() {
+        List<Map<String, Object>> map = baseMapper.selectAllAlea();
+        Map<String, Object> result = new HashMap<>();
+        // 区域名称
+        List<String> stnms = new ArrayList<>();
+        // 各个区域在线的设备
+        List<Integer> zx = new ArrayList<>();
+        // 各个区域离线的设备
+        List<Integer> lx = new ArrayList<>();
+        for (Map<String, Object> m : map) {
+            Integer aleaId = (Integer)m.get("alea_id");
+            // 查询各个区域在线的设备
+            Integer zxCount = baseMapper.selectZXAndLXCount(1,aleaId);
+            // 查询各个区域离线的设备
+            Integer lxCount = baseMapper.selectZXAndLXCount(0,aleaId);
+            zx.add(zxCount);
+            lx.add(lxCount);
+            stnms.add((String) m.get("alea_name"));
+        }
+
+        result.put("stnms",stnms);
+        result.put("zx",zx);
+        result.put("lx",lx);
+        return R.ok().put("data",result);
+    }
+
 }
diff --git a/ruoyi-api/src/main/resources/mapper/api/DapingMapper.xml b/ruoyi-api/src/main/resources/mapper/api/DapingMapper.xml
index 415ef13..e44b7e6 100644
--- a/ruoyi-api/src/main/resources/mapper/api/DapingMapper.xml
+++ b/ruoyi-api/src/main/resources/mapper/api/DapingMapper.xml
@@ -77,4 +77,18 @@
     <select id="selectStationByOfflineStatus" resultType="java.util.Map">
         select count(1) as value , '不在线' as name from camera where status = '0' and first_time is not null
     </select>
+
+    <select id="selectAllAlea" resultType="java.util.Map">
+        select * from sc_station_alea
+    </select>
+
+    <select id="selectZXAndLXCount" resultType="java.lang.Integer">
+        SELECT
+            count( 1 )
+        FROM
+            camera
+        WHERE
+            `status` = #{status}
+          AND devsn IN ( SELECT camera_sn FROM sc_station_info WHERE del_flag = '0' AND alea_id = #{aleaId} )
+    </select>
 </mapper>