add(ems and moudle): 新增能源类型设备数量统计和能源数据查询功能

- 在 EmsBaseMonitorInfoController 中添加了获取指定能源类型设备数量的接口
- 在 EmsBaseMonitorInfoMapper 和 XML 中添加了相应的 SQL 查询方法
- 在 EmsBaseMonitorInfoServiceImpl 和 IEmsBaseMonitorInfoService 中实现了获取能源类型设备数量的方法
- 在 RecordBusbarAlarmController 中添加了记录母排近七天巡检记录次数的接口
- 新增 RecordBusbarAlarmCountResult 类用于记录母排报警统计结果- 在 RecordBusbarAlarmMapper.xml 中添加了记录母排报警统计的 SQL 查询
- 在 TWTempertureDataController 中添加了查询最新温度数据的接口
- 在 TWTempertureDataMapper 和 TWTempertureDataServiceImpl 中实现了查询最新温度数据的方法

ruoyi-ems/src/main/java/com/ruoyi/ems/base/controller/EmsBaseMonitorInfoController.java

@@ -112,4 +112,15 @@ public class EmsBaseMonitorInfoController extends BaseController
     {
         return toAjax(emsBaseMonitorInfoService.deleteEmsBaseMonitorInfoByObjIds(objIds));
     }
+
+
+    /**
+     * 获取指定能源类型的设备数量。
+     * @param energyType 需要查询的能源类型。
+     * @return 返回指定能源类型的数量。
+     */
+    @PostMapping("/getEnergyTypeCount/{energyType}")
+    public int getEnergyTypeCount(@PathVariable("energyType")String energyType){
+        return emsBaseMonitorInfoService.getEnergyTypeCount(energyType);
+    }
 }

ruoyi-ems/src/main/java/com/ruoyi/ems/base/mapper/EmsBaseMonitorInfoMapper.java

@@ -65,4 +65,11 @@ public interface EmsBaseMonitorInfoMapper
      * @return
      */
     public String selectEmsBaseMonitorTypeByMonitorCode(String monitorCode);
+
+    /**
+     * 获取指定能源类型的设备数量。
+     * @param energyType 需要查询的能源类型。
+     * @return 返回指定能源类型的数量。
+     */
+    public int getEnergyTypeCount(String energyType);
 }

ruoyi-ems/src/main/java/com/ruoyi/ems/base/service/IEmsBaseMonitorInfoService.java

@@ -86,4 +86,11 @@ public interface IEmsBaseMonitorInfoService
      * @return 树结构列表
      */
     public List<EmsBaseMonitorInfo> buildMonitorInfoTree(List<EmsBaseMonitorInfo> baseMonitorInfos);
+
+    /**
+     * 获取指定能源类型的设备数量。
+     * @param energyType 需要查询的能源类型。
+     * @return 返回指定能源类型的数量。
+     */
+    public int getEnergyTypeCount(String energyType);
 }

ruoyi-ems/src/main/java/com/ruoyi/ems/base/service/impl/EmsBaseMonitorInfoServiceImpl.java

@@ -200,4 +200,14 @@ public class EmsBaseMonitorInfoServiceImpl implements IEmsBaseMonitorInfoService
         return getChildList(list, t).size() > 0;
     }
 
+
+    /**
+     * 获取指定能源类型的设备数量。
+     * @param energyType 需要查询的能源类型。
+     * @return 返回指定能源类型的数量。
+     */
+    public int getEnergyTypeCount(String energyType){
+        return emsBaseMonitorInfoMapper.getEnergyTypeCount(energyType);
+    }
+
 }

ruoyi-ems/src/main/java/com/ruoyi/ems/record/controller/TWTempertureDataController.java

@@ -207,4 +207,13 @@ public class TWTempertureDataController extends BaseController
         return getDataTable(list);
     }
 
+    /**
+     * 查询最新的温度数据。
+     * @param tWTempertureData 需要查询的温度数据对象。
+     * @return 如果数据库中存在对应的温度数据，返回包含最新数据的列表；如果不存在或查询过程中发生异常，返回空列表。
+     */
+    @PostMapping("/selectLastTWTempertureData")
+    public List<TWTempertureData> selectLastTWTempertureData(@RequestBody TWTempertureData tWTempertureData){
+        return tWTempertureDataService.selectLastTWTempertureData(tWTempertureData)   ;
+        }
 }

ruoyi-ems/src/main/java/com/ruoyi/ems/record/mapper/TWTempertureDataMapper.java

@@ -78,5 +78,5 @@ public interface TWTempertureDataMapper
      * @param tWTempertureData
      * @return
      */
-    List<TWTempertureData> selectLastTWTempertureDataList(TWTempertureData tWTempertureData);
+    public List<TWTempertureData> selectLastTWTempertureDataList(TWTempertureData tWTempertureData);
 }

ruoyi-ems/src/main/java/com/ruoyi/ems/record/service/ITWTempertureDataService.java

@@ -78,5 +78,12 @@ public interface ITWTempertureDataService
      * @param tWTempertureData
      * @return
      */
-    List<TWTempertureData> selectLastTWTempertureDataList(TWTempertureData tWTempertureData);
+    public List<TWTempertureData> selectLastTWTempertureDataList(TWTempertureData tWTempertureData);
+
+    /**
+     * 查询最新的温度数据。
+     * @param tWTempertureData 需要查询的温度数据对象。
+     * @return 如果数据库中存在对应的温度数据，返回包含最新数据的列表；如果不存在或查询过程中发生异常，返回空列表。
+     */
+    public List<TWTempertureData> selectLastTWTempertureData(TWTempertureData tWTempertureData);
 }

ruoyi-ems/src/main/java/com/ruoyi/ems/record/service/impl/TWTempertureDataServiceImpl.java

@@ -1,6 +1,10 @@
 package com.ruoyi.ems.record.service.impl;
 
+import java.lang.reflect.Method;
+import java.util.Collections;
 import java.util.List;
+import java.util.ListIterator;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.ruoyi.ems.record.mapper.TWTempertureDataMapper;
@@ -120,4 +124,103 @@ public class TWTempertureDataServiceImpl implements ITWTempertureDataService
         // 按monitorName分组并获取每个分组的最新记录
         return tWTempertureDataMapper.selectLastTWTempertureDataList(tWTempertureData);
     }
+
+  /**
+   * 查询最新的温度数据。
+   * @param tWTempertureData 需要查询的温度数据对象。
+   * @return 如果数据库中存在对应的温度数据，返回包含最新数据的列表；如果不存在或查询过程中发生异常，返回空列表。
+   */
+  public List<TWTempertureData> selectLastTWTempertureData(TWTempertureData tWTempertureData) {
+      try {
+          // 从数据库中查询温度数据列表
+          List<TWTempertureData> twlist = tWTempertureDataMapper.selectTWTempertureDataList(tWTempertureData);
+          if (twlist == null || twlist.isEmpty()) {
+              // 如果查询结果为空或列表为空，返回一个空列表
+              return Collections.emptyList();
+          }
+
+          // 创建一个新的TWTempertureData对象用于存储最终的数据
+          TWTempertureData data = new TWTempertureData();
+          // 获取列表的反向迭代器，从最后一个元素开始遍历
+          ListIterator<TWTempertureData> iterator = twlist.listIterator(twlist.size());
+          while (iterator.hasPrevious()) {
+              // 获取当前元素
+              TWTempertureData t = iterator.previous();
+              // 如果当前元素的tempreture属性不为空，则设置到data对象中
+              setIfNotNull(t, data, "tempreture");
+              // 如果当前元素的humidity属性不为空，则设置到data对象中
+              setIfNotNull(t, data, "humidity");
+              // 如果当前元素的illuminance属性不为空，则设置到data对象中
+              setIfNotNull(t, data, "illuminance");
+              // 如果当前元素的noise属性不为空，则设置到data对象中
+              setIfNotNull(t, data, "noise");
+              // 设置PM值到data对象中
+              setPmValues(t, data);
+          }
+
+          // 返回包含最终数据的单元素列表
+          return Collections.singletonList(data);
+      } catch (Exception e) {
+          // 异常处理，打印堆栈跟踪并返回空列表
+          e.printStackTrace();
+          return Collections.emptyList();
+      }
+  }
+
+
+/**
+ * 将源对象中指定字段的值设置到目标对象的相应字段中，如果该值不为空且目标对象的对应字段为空。
+ *
+ * @param source 源对象，从中获取字段值
+ * @param target 目标对象，将字段值设置到此对象中
+ * @param fieldName 要操作的字段名称
+ */
+private void setIfNotNull(TWTempertureData source, TWTempertureData target, String fieldName) {
+    try {
+        // 获取源对象中指定字段的getter方法
+        Method getMethod = TWTempertureData.class.getMethod("get" + capitalize(fieldName));
+        // 获取目标对象中指定字段的setter方法，参数类型与getter方法返回类型一致
+        Method setMethod = TWTempertureData.class.getMethod("set" + capitalize(fieldName), getMethod.getReturnType());
+        // 调用getter方法获取源对象中的字段值
+        Object value = getMethod.invoke(source);
+        // 如果字段值不为空且目标对象中的对应字段值为空，则调用setter方法将值设置到目标对象中
+        if (value != null && getMethod.invoke(target) == null) {
+            setMethod.invoke(target, value);
+        }
+    } catch (Exception e) {
+        // 捕获并打印异常信息
+        e.printStackTrace();
+    }
+}
+
+/**
+ * 设置PM值。
+ * @param source 源TWTempertureData对象，用于提供PM值。
+ * @param target 目标TWTempertureData对象，用于接收PM值。
+ */
+private void setPmValues(TWTempertureData source, TWTempertureData target) {
+    setIfNotNull(source, target, "pm1");
+    if (target.getPm1() == null) {
+        setIfNotNull(source, target, "pm2");
+    }
+    if (target.getPm2() == null) {
+        setIfNotNull(source, target, "pm10");
+    }
+}
+
+/**
+ * 将字符串的首字母大写。
+ *
+ * @param str 要处理的字符串
+ * @return 首字母大写的字符串，如果输入为空或长度为0，则返回原字符串
+ */
+private String capitalize(String str) {
+    // 如果字符串为null或者长度为0，直接返回原字符串
+    if (str == null || str.length() == 0) {
+        return str;
+    }
+    // 将字符串的第一个字符转换为大写，并与剩余部分拼接后返回
+    return str.substring(0, 1).toUpperCase() + str.substring(1);
+}
+
 }

ruoyi-ems/src/main/resources/mapper/ems/base/EmsBaseMonitorInfoMapper.xml

@@ -171,4 +171,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             #{objId}
         </foreach>
     </delete>
+
+    <select id="getEnergyTypeCount" parameterType="String" resultType="java.lang.Integer">
+            select count(1) from ems_base_monitor_info where monitor_type = #{energyType}
+        </select>
 </mapper>

ruoyi-module/src/main/java/com/ruoyi/record/controller/RecordBusbarAlarmController.java

@@ -115,4 +115,11 @@ public class RecordBusbarAlarmController extends BaseController
         List<RecordBusbarAlarm> list = recordBusbarAlarmService.selectRecordBusbarAlarmList(recordBusbarAlarm);
         return success(list);
     }
+
+
+   //记录母排近七天每天一天的巡检记录次数。
+    @PostMapping("/recordBusbarAlarmCount")
+    public AjaxResult recordBusbarAlarmCount(@RequestBody RecordBusbarAlarm recordBusbarAlarm) {
+        return AjaxResult.success(recordBusbarAlarmService.recordBusbarAlarmCount(recordBusbarAlarm));
+        }
 }

ruoyi-module/src/main/java/com/ruoyi/record/domain/VO/RecordBusbarAlarmCountResult.java

@@ -0,0 +1,36 @@
+package com.ruoyi.record.domain.VO;
+
+import com.ruoyi.record.domain.RecordBusbarAlarm;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import java.util.Date;
+
+
+public class RecordBusbarAlarmCountResult extends RecordBusbarAlarm {
+    private Date recordDate;
+    private int alarmCount;
+
+    public Date getRecordDate() {
+        return recordDate;
+    }
+    public void setRecordDate(Date recordDate) {
+        this.recordDate = recordDate;
+    }
+    public int getAlarmCount() {
+        return alarmCount;
+    }
+
+    public void setAlarmCount(int alarmCount) {
+        this.alarmCount = alarmCount;
+    }
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
+
+                .append("recordDate", getRecordDate())
+                .append("alarmCount", getAlarmCount())
+                .toString();
+    }
+}

ruoyi-module/src/main/java/com/ruoyi/record/service/IRecordBusbarAlarmService.java

@@ -58,4 +58,6 @@ public interface IRecordBusbarAlarmService
      * @return 结果
      */
     public int deleteRecordBusbarAlarmByObjId(Long objId);
+
+    int recordBusbarAlarmCount(RecordBusbarAlarm recordBusbarAlarm);
 }

ruoyi-module/src/main/resources/mapper/record/RecordBusbarAlarmMapper.xml

@@ -19,6 +19,11 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <result property="recordTime"    column="record_time"    />
     </resultMap>
 
+    <resultMap type="RecordBusbarAlarmCountResult" id="RecordBusbarAlarmCountResult">
+        <result property="recordDate" column="record_date" />
+        <result property="alarmCount" column="alarm_count" />
+    </resultMap>
+
     <sql id="selectRecordBusbarAlarmVo">
         select objId, busbar_code, cabinet_code, temp_max, temp_min, temp_avg, temp_diff, file_path, alarm_type, alarm_value, is_flag, record_time from record_busbar_alarm
     </sql>
@@ -106,4 +111,18 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             #{objId}
         </foreach>
     </delete>
+
+
+
+    <select id="selectRecordBusbarAlarmListByDay" parameterType="RecordBusbarAlarm" resultMap="RecordBusbarAlarmCountResult">
+        SELECT
+            DATE(record_time) AS record_date,
+            COUNT(*) AS alarm_count
+        FROM
+            record_busbar_alarm
+        WHERE
+            record_time >= date_sub(CURDATE(), INTERVAL 7 DAY)
+        GROUP BY
+            DATE(record_time)
+    </select>
 </mapper>