From 2d7fb296336fac40eecbcedffebcd0003c89627a Mon Sep 17 00:00:00 2001
From: wangsixiang <2970484253@qq.com>
Date: Fri, 18 Apr 2025 14:03:36 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BC=80=E9=97=A8=E8=AE=BE=E5=A4=87=E5=88=97?=
 =?UTF-8?q?=E8=A1=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../business/controller/DcDeviceController.java   |  9 +++++++++
 .../com/zc/business/mapper/DcDeviceMapper.java    |  3 +++
 .../com/zc/business/service/IDcDeviceService.java |  3 +++
 .../service/impl/DcDeviceServiceImpl.java         |  5 +++++
 .../resources/mapper/business/DcDeviceMapper.xml  | 15 +++++++++++++++
 5 files changed, 35 insertions(+)

diff --git a/zc-business/src/main/java/com/zc/business/controller/DcDeviceController.java b/zc-business/src/main/java/com/zc/business/controller/DcDeviceController.java
index d8dd0029..7f7542f2 100644
--- a/zc-business/src/main/java/com/zc/business/controller/DcDeviceController.java
+++ b/zc-business/src/main/java/com/zc/business/controller/DcDeviceController.java
@@ -1862,6 +1862,15 @@ private VideoController videoController;
         List<DcDoor> list = dcDeviceService.selectDcDoorList(dcDoor);
         return getDataTable(list);
     }
+    //查询开门的设备列表
+    @GetMapping("/dcDoorOpen")
+    public TableDataInfo dcDoorOpen(){
+        startPage();
+        Map<String, Object> redisCacheCacheMap = redisCache.getCacheMap(DOORSTATUS);
+        Set<String> strings = redisCacheCacheMap.keySet();
+        List<DcDoor> list = dcDeviceService.selectDcDoorOpen(strings);
+        return getDataTable(list);
+    }
     //一体机柜空调定时调用,采数据
     //@PostMapping("/integratedCabinetAir2")
     @Scheduled(cron = "0 7 * * * *")
diff --git a/zc-business/src/main/java/com/zc/business/mapper/DcDeviceMapper.java b/zc-business/src/main/java/com/zc/business/mapper/DcDeviceMapper.java
index 173d07f4..07f601d5 100644
--- a/zc-business/src/main/java/com/zc/business/mapper/DcDeviceMapper.java
+++ b/zc-business/src/main/java/com/zc/business/mapper/DcDeviceMapper.java
@@ -9,6 +9,7 @@ import org.apache.ibatis.annotations.Param;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 
 /**
  * 设备Mapper接口
@@ -50,4 +51,6 @@ public interface DcDeviceMapper extends BaseMapper<DcDevice> {
     Integer insertDoorMonitor(DcDoor dcDoor);
     //查询电子门锁记录
     List<DcDoor> selectDcDoorList(DcDoor dcDoor);
+    //查询状态为开的设备
+    List<DcDoor> selectDcDoorOpen(@Param("iotIds")Set<String> strings);
 }
diff --git a/zc-business/src/main/java/com/zc/business/service/IDcDeviceService.java b/zc-business/src/main/java/com/zc/business/service/IDcDeviceService.java
index 28d8a681..19f87669 100644
--- a/zc-business/src/main/java/com/zc/business/service/IDcDeviceService.java
+++ b/zc-business/src/main/java/com/zc/business/service/IDcDeviceService.java
@@ -16,6 +16,7 @@ import java.io.IOException;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 
 /**
  * 设备Service接口
@@ -138,4 +139,6 @@ public interface IDcDeviceService extends IService<DcDevice> {
     Integer insertDoorMonitor(DcDoor dcDoor);
     //查询电子门锁记录
     List<DcDoor> selectDcDoorList(DcDoor dcDoor);
+    //查询状态为开的设备
+    List<DcDoor> selectDcDoorOpen(Set<String> strings);
 }
diff --git a/zc-business/src/main/java/com/zc/business/service/impl/DcDeviceServiceImpl.java b/zc-business/src/main/java/com/zc/business/service/impl/DcDeviceServiceImpl.java
index 29eab03c..c837d3a4 100644
--- a/zc-business/src/main/java/com/zc/business/service/impl/DcDeviceServiceImpl.java
+++ b/zc-business/src/main/java/com/zc/business/service/impl/DcDeviceServiceImpl.java
@@ -682,5 +682,10 @@ public class DcDeviceServiceImpl extends ServiceImpl<DcDeviceMapper, DcDevice> i
         return dcDeviceMapper.selectDcDoorList(dcDoor);
     }
 
+    @Override
+    public List<DcDoor> selectDcDoorOpen(Set<String> strings) {
+        return dcDeviceMapper.selectDcDoorOpen(strings);
+    }
+
 }
 
diff --git a/zc-business/src/main/resources/mapper/business/DcDeviceMapper.xml b/zc-business/src/main/resources/mapper/business/DcDeviceMapper.xml
index c9554416..82c59493 100644
--- a/zc-business/src/main/resources/mapper/business/DcDeviceMapper.xml
+++ b/zc-business/src/main/resources/mapper/business/DcDeviceMapper.xml
@@ -237,4 +237,19 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         </where>
       order by create_time desc
     </select>
+    <select id="selectDcDoorOpen" resultType="com.zc.business.domain.DcDoor">
+        select id,device_name,device_type,direction,stake_mark,operate,create_time  from dc_door_monitor as a
+          INNER JOIN (
+            SELECT
+                iot_device_id,
+                MAX(create_time) AS latest_time
+            FROM dc_door_monitor
+            WHERE iot_device_id IN
+             <foreach item="item" collection="iotIds" open="(" separator="," close=")">
+             #{item}
+             </foreach>
+            GROUP BY iot_device_id
+        ) b ON a.iot_device_id = b.iot_device_id AND a.create_time = b.latest_time
+        ORDER BY a.create_time DESC
+    </select>
 </mapper>