feat(device): 添加设备告警统计功能

- 在 DeviceServiceImpl 类中的 overview 方法中增加了设备告警相关的统计信息
- 新增 warningCount 字段用于统计当前所有处于告警状态的设备数量
- 新增 todayWarningCount 字段用于统计今日内处于告警状态的设备数量

src/main/java/com/zsc/edu/gateway/modules/attachment/entity/Attachment.java

@@ -10,6 +10,7 @@ import org.springframework.format.annotation.DateTimeFormat;
 
 import java.io.Serializable;
 import java.time.LocalDateTime;
+import java.util.Objects;
 
 /**
  * 附件

src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java

@@ -33,6 +33,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.time.LocalDateTime;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -203,6 +204,8 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceRepository, Device> imp
                 .directCount(productRepo.selectCount(new LambdaQueryWrapper<Product>().eq(Product::getLink, Product.LinkType.HTTP)))
                 .gatewayCount(productRepo.selectCount(new LambdaQueryWrapper<Product>().eq(Product::getLink, Product.LinkType.TCP)))
                 .gatewaySubCount(productRepo.selectCount(new LambdaQueryWrapper<Product>().eq(Product::getLink, Product.LinkType.MQTT)))
+                .warningCount(baseMapper.selectCount(new LambdaQueryWrapper<Device>().eq(Device::getDeviceState, false)))
+                .todayWarningCount(baseMapper.selectCount(new LambdaQueryWrapper<Device>().eq(Device::getDeviceState, false).between(Device::getCreateTime, LocalDateTime.now().withHour(0).withMinute(0).withSecond(0), LocalDateTime.now())))
                 .build();
     }
 

src/main/java/com/zsc/edu/gateway/modules/iot/device/vo/DeviceStatusVo.java

@@ -59,4 +59,13 @@ public class DeviceStatusVo {
      */
     public Long gatewaySubCount;
 
+    /**
+     * 报警数
+     */
+    public Long warningCount;
+
+    /**
+     * 今日新增
+     */
+    public Long todayWarningCount;
 }

src/main/java/com/zsc/edu/gateway/modules/iot/device/vo/DeviceVo.java

@@ -110,22 +110,12 @@ public class DeviceVo {
      */
     public String iconId;
 
-    /**
-     * 设备图标附件
-     */
-    public Attachment icon;
-
 
     /**
      * 设备预览图附件ID
      */
     public String previewId;
 
-    /**
-     * 设备预览图附件
-     */
-    public Attachment preview;
-
     /**
      * 所属产品ID
      */

src/main/java/com/zsc/edu/gateway/modules/iot/record/entity/RecordDataStatusVo.java

@@ -19,13 +19,4 @@ public class RecordDataStatusVo {
      */
     public Long dataCount;
 
-    /**
-     * 告警总数
-     */
-    private Long warningCount;
-
-    /**
-     * 今日新增
-     */
-    private Long todayWarningCount;
 }

src/main/java/com/zsc/edu/gateway/modules/iot/record/repo/RecordDataRepository.java

@@ -12,14 +12,6 @@ import java.util.List;
  * @author zhuang
  */
 public interface RecordDataRepository extends BaseMapper<RecordData> {
-    @Select("SELECT COUNT(*) FROM iot_record_data WHERE content::jsonb->>'warning' IS NOT NULL AND (content::jsonb->>'warning')::int & 1 = 0 AND ((content::jsonb->>'warning')::int & ~1) > 0")
-    long countWarnings();
-
-    @Select("SELECT COUNT(*) FROM iot_record_data WHERE content::jsonb->>'warning' IS NOT NULL AND ((content::jsonb->>'warning')::int & 1 = 0) AND ((content::jsonb->>'warning')::int & ~1) > 0 AND record_time >= #{todayStart}")
-    long countTodayWarnings(@Param("todayStart") LocalDateTime todayStart);
-
-    @Select("SELECT COUNT(*) FROM iot_record_data WHERE content::jsonb->>'warning' IS NOT NULL AND (content::jsonb->>'warning')::int & #{bitPosition} = #{bitPosition}")
-    long countWarningsByBit(@Param("bitPosition") int bitPosition);
 
     List<RecordData> selectByClientId(@Param("clientId") String clientId);
 }

src/main/java/com/zsc/edu/gateway/modules/iot/record/service/impl/RecordDataServiceImpl.java

@@ -72,11 +72,7 @@ public class RecordDataServiceImpl extends ServiceImpl<RecordDataRepository, Rec
      */
     @Override
     public RecordDataStatusVo recordDataStatus() {
-        LocalDateTime todayStart = LocalDateTime.now().withHour(0).withMinute(0).withSecond(0);
-
         return RecordDataStatusVo.builder()
-                .warningCount(baseMapper.countWarnings())
-                .todayWarningCount(baseMapper.countTodayWarnings(todayStart))
                 .recordCount(baseMapper.selectCount(new LambdaQueryWrapper<>()))
                 .dataCount(baseMapper.selectCount(new LambdaQueryWrapper<RecordData>().isNotNull(RecordData::getContent)))
                 .build();

src/main/resources/mappers/iot/DeviceMapper.xml

@@ -36,18 +36,6 @@
         <result column="update_time" jdbcType="DATE" property="updateTime"/>
         <result column="remark" jdbcType="VARCHAR" property="remark"/>
         <result column="enabled" jdbcType="BOOLEAN" property="enabled"/>
-        <association property="icon" javaType="com.zsc.edu.gateway.modules.attachment.entity.Attachment"
-                     autoMapping="true"
-                     columnPrefix="icon_">
-            <id column="id" property="id"/>
-            <result column="file_name" property="fileName"/>
-        </association>
-        <association property="preview" javaType="com.zsc.edu.gateway.modules.attachment.entity.Attachment"
-                     autoMapping="true"
-                     columnPrefix="preview_">
-            <id column="id" property="id"/>
-            <result column="file_name" property="fileName"/>
-        </association>
         <collection property="params" ofType="com.zsc.edu.gateway.modules.iot.tsl.entity.Param" autoMapping="true"
                     columnPrefix="param_">
             <id column="id" property="id"/>