diff --git a/ruoyi-ems/src/main/java/org/dromara/ems/record/controller/IotEnvMonitorDataController.java b/ruoyi-ems/src/main/java/org/dromara/ems/record/controller/IotEnvMonitorDataController.java
new file mode 100644
index 0000000..1ed3108
--- /dev/null
+++ b/ruoyi-ems/src/main/java/org/dromara/ems/record/controller/IotEnvMonitorDataController.java
@@ -0,0 +1,207 @@
+package org.dromara.ems.record.controller;
+
+import cn.dev33.satoken.annotation.SaCheckPermission;
+import lombok.RequiredArgsConstructor;
+import org.dromara.common.core.domain.R;
+import org.dromara.common.core.exception.ServiceException;
+import org.dromara.common.log.annotation.Log;
+import org.dromara.common.log.enums.BusinessType;
+import org.dromara.ems.common.web.EmsBaseController;
+import org.dromara.ems.record.domain.bo.IotEnvMonitorQuery;
+import org.dromara.ems.record.service.IIotEnvMonitorDataService;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 物联网环境监测数据按日分表查询 Controller
+ *
+ * 独立新增，不修改已有 RecordIotenvInstantController。
+ * 提供以下接口能力：
+ * 1. 查询指定日期指定设备最新一条数据（GET /latest）
+ * 2. 查询指定日期设备数据列表，支持多条件过滤（GET /list）
+ * 3. 批量查询指定日期多设备最新数据（POST /latestBatch，支持较大 monitorIds 列表）
+ * 4. 按设备类型查询指定日期数据（GET /byType）
+ *
+ *
+ * 接口权限复用已有权限标识 ems/record:recordIotenvInstant:list，
+ * 待根据项目实际权限体系调整为独立权限标识。
+ *
+ * @author zch
+ * @date 2026-04-09
+ */
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/ems/record/iotEnvMonitorData")
+public class IotEnvMonitorDataController extends EmsBaseController {
+
+ private final IIotEnvMonitorDataService iotEnvMonitorDataService;
+
+ /**
+ * 无参查询所有设备各自的最新一条监测数据。
+ *
+ * 前端无需传任何参数，后端会自动：
+ * 1. 从设备主数据表收集全部 monitorIds
+ * 2. 回退到最近存在的日分表中取每个设备最新一条
+ * 3. 按 monitor_type 裁剪字段后返回 Map 列表
+ *
+ * @return 所有设备最新值列表；若暂无有效分表则返回设备骨架列表
+ */
+ @SaCheckPermission("ems/record:recordIotenvInstant:list")
+ @Log(title = "物联环境监测-所有设备最新值查询", businessType = BusinessType.OTHER)
+ @GetMapping("/latestAll")
+ public R getLatestAllMonitorData() {
+ try {
+ List> list = iotEnvMonitorDataService.queryLatestAllMonitorData();
+ return success(list);
+ } catch (ServiceException e) {
+ logger.warn("查询所有设备最新数据失败，原因：{}", e.getMessage());
+ return error(e.getMessage());
+ } catch (Exception e) {
+ logger.error("查询所有设备最新数据异常", e);
+ return error("查询失败，请稍后重试或联系管理员");
+ }
+ }
+
+ /**
+ * 查询指定日期指定设备的最新一条监测数据。
+ *
+ * 适用于设备详情页、实时监控面板展示单设备当前最新状态的场景。
+ *
+ * 请求示例：
+ * GET /ems/record/iotEnvMonitorData/latest?date=2026-04-09&monitorId=E0001_2200
+ *
+ * 返回示例（温度设备 type=5）：
+ * {
+ * "code": 200,
+ * "data": {
+ * "objid": 2042107207071436800,
+ * "monitorId": "E0001_2200",
+ * "monitorCode": "E0001_2200",
+ * "monitorName": "7.47.01",
+ * "monitorType": 5,
+ * "energyName": "温度",
+ * "temperature": 44.87,
+ * "collectTime": "2026-04-09 13:08:20",
+ * "recodeTime": "2026-04-09 13:07:53"
+ * }
+ * }
+ *
+ * @param query 查询参数（必传字段：date、monitorId）
+ * @return 裁剪后的设备数据 Map，分表不存在或无数据时返回空 Map
+ */
+ @SaCheckPermission("ems/record:recordIotenvInstant:list")
+ @Log(title = "物联环境监测-按日分表查询", businessType = BusinessType.OTHER)
+ @GetMapping("/latest")
+ public R getLatestByMonitorIdAndDate(IotEnvMonitorQuery query) {
+ try {
+ Map data = iotEnvMonitorDataService.queryLatestByMonitorIdAndDate(query);
+ return success(data);
+ } catch (ServiceException e) {
+ // 业务异常（参数校验失败、日期格式错误等）直接返回给前端
+ logger.warn("查询单设备最新数据失败，参数：{}，原因：{}", query, e.getMessage());
+ return error(e.getMessage());
+ } catch (Exception e) {
+ // 非预期异常统一脱敏，避免将表名、SQL 信息暴露给前端
+ logger.error("查询单设备最新数据异常，参数：{}", query, e);
+ return error("查询失败，请稍后重试或联系管理员");
+ }
+ }
+
+ /**
+ * 查询指定日期的监测数据列表。
+ *
+ * 支持按 monitorId / monitorType / 时间范围等条件组合查询，
+ * 每条记录根据各自的 monitor_type 动态裁剪返回字段。
+ *
+ * 请求示例（按设备类型查询）：
+ * GET /ems/record/iotEnvMonitorData/list?date=2026-04-09&monitorType=5
+ *
+ * 请求示例（按时间范围查询）：
+ * GET /ems/record/iotEnvMonitorData/list?date=2026-04-09&startTime=2026-04-09 08:00:00&endTime=2026-04-09 18:00:00
+ *
+ * @param query 查询参数（必传字段：date，其余条件选传）
+ * @return 裁剪后的数据列表，分表不存在时返回空列表
+ */
+ @SaCheckPermission("ems/record:recordIotenvInstant:list")
+ @Log(title = "物联环境监测-按日分表查询", businessType = BusinessType.OTHER)
+ @GetMapping("/list")
+ public R getDataListByDate(IotEnvMonitorQuery query) {
+ try {
+ List> list = iotEnvMonitorDataService.queryDataListByDate(query);
+ return success(list);
+ } catch (ServiceException e) {
+ logger.warn("查询日期数据列表失败，参数：{}，原因：{}", query, e.getMessage());
+ return error(e.getMessage());
+ } catch (Exception e) {
+ logger.error("查询日期数据列表异常，参数：{}", query, e);
+ return error("查询失败，请稍后重试或联系管理员");
+ }
+ }
+
+ /**
+ * 批量查询指定日期多个设备各自的最新一条监测数据。
+ *
+ * 使用 POST 方式以支持较大的 monitorIds 列表，避免 GET 请求 URL 超长限制。
+ * 适用于看板页需要同时展示多个设备最新状态的场景。
+ *
+ * 请求示例：
+ * POST /ems/record/iotEnvMonitorData/latestBatch
+ * Content-Type: application/json
+ * Body:
+ * {
+ * "date": "2026-04-09",
+ * "monitorIds": ["E0001_2200", "E0001_1900", "E0001_1400"]
+ * }
+ *
+ * @param query 查询参数（必传字段：date、monitorIds，通过 RequestBody 传入）
+ * @return 每个设备最新一条裁剪后的数据列表
+ */
+ @SaCheckPermission("ems/record:recordIotenvInstant:list")
+ @Log(title = "物联环境监测-按日分表批量查询", businessType = BusinessType.OTHER)
+ @PostMapping("/latestBatch")
+ public R getLatestBatchByDate(@RequestBody IotEnvMonitorQuery query) {
+ try {
+ List> list = iotEnvMonitorDataService.queryLatestByMonitorIdsAndDate(query);
+ return success(list);
+ } catch (ServiceException e) {
+ logger.warn("批量查询设备最新数据失败，原因：{}", e.getMessage());
+ return error(e.getMessage());
+ } catch (Exception e) {
+ logger.error("批量查询设备最新数据异常", e);
+ return error("查询失败，请稍后重试或联系管理员");
+ }
+ }
+
+ /**
+ * 按设备类型查询指定日期的监测数据列表。
+ *
+ * 适用于历史曲线页面按设备类型筛选展示数据的场景，
+ * 返回字段集合完全由 monitorType 决定（纯净返回，无无关字段）。
+ *
+ * 请求示例（查询振动设备数据）：
+ * GET /ems/record/iotEnvMonitorData/byType?date=2026-04-09&monitorType=10
+ *
+ * 请求示例（查询振动设备指定参数，如只查速度）：
+ * GET /ems/record/iotEnvMonitorData/byType?date=2026-04-09&monitorType=10&vibrationParam=vibrationSpeed
+ *
+ * @param query 查询参数（必传字段：date、monitorType）
+ * @return 该类型设备的数据列表，分表不存在时返回空列表
+ */
+ @SaCheckPermission("ems/record:recordIotenvInstant:list")
+ @Log(title = "物联环境监测-按类型按日分表查询", businessType = BusinessType.OTHER)
+ @GetMapping("/byType")
+ public R getDataListByMonitorType(IotEnvMonitorQuery query) {
+ try {
+ List> list = iotEnvMonitorDataService.queryDataListByMonitorType(query);
+ return success(list);
+ } catch (ServiceException e) {
+ logger.warn("按设备类型查询数据失败，原因：{}", e.getMessage());
+ return error(e.getMessage());
+ } catch (Exception e) {
+ logger.error("按设备类型查询数据异常", e);
+ return error("查询失败，请稍后重试或联系管理员");
+ }
+ }
+}
diff --git a/ruoyi-ems/src/main/java/org/dromara/ems/record/domain/bo/IotEnvMonitorQuery.java b/ruoyi-ems/src/main/java/org/dromara/ems/record/domain/bo/IotEnvMonitorQuery.java
new file mode 100644
index 0000000..1626e1b
--- /dev/null
+++ b/ruoyi-ems/src/main/java/org/dromara/ems/record/domain/bo/IotEnvMonitorQuery.java
@@ -0,0 +1,72 @@
+package org.dromara.ems.record.domain.bo;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 物联网环境监测数据查询参数封装对象（按日分表查询专用）
+ *
+ * 该对象作为新增独立接口的入参，不依赖原 RecordIotenvInstant 实体，
+ * 职责单一，仅用于"按日分表查询"场景，避免与已有查询逻辑产生耦合。
+ *
+ * @author zch
+ * @date 2026-04-09
+ */
+@Data
+public class IotEnvMonitorQuery {
+
+ /**
+ * 查询日期（必传）
+ * 支持格式：yyyy-MM-dd 或 yyyyMMdd
+ * 服务端根据此字段自动路由到对应分表 record_iotenv_instant_yyyyMMdd
+ * 禁止前端直接传分表名，分表名由服务端根据日期格式化生成
+ */
+ private String date;
+
+ /**
+ * 单设备编号精确查询（选传）
+ * 对应 ems_base_monitor_info.monitor_code / record_iotenv_instant.monitorId
+ * 与 monitorIds 同时传入时，以 monitorIds 列表为主，monitorId 会被忽略
+ */
+ private String monitorId;
+
+ /**
+ * 批量设备编号查询列表（选传）
+ * 对应 ems_base_monitor_info.monitor_code 列表
+ * 当 monitorIds 非空时，优先级高于 monitorId，避免条件叠加导致误过滤
+ * 当列表较大时建议使用 POST 接口传参，避免 URL 长度超限
+ */
+ private List monitorIds;
+
+ /**
+ * 设备类型筛选（选传）
+ * 对应 ems_base_monitor_info.monitor_type
+ * 5=温度 / 6=温湿度 / 7=噪声 / 8=照度 / 9=气体浓度 / 10=振动
+ * 不传则不按设备类型过滤，返回所有设备类型数据（仍按各自类型裁剪字段）
+ */
+ private Integer monitorType;
+
+ /**
+ * 记录时间范围查询起始（选传）
+ * 格式：yyyy-MM-dd HH:mm:ss
+ * 仅在单日表内按 recodeTime 范围过滤，不支持跨天查询
+ * 跨天查询请多次调用接口或使用已有 selectRecordIotenvInstantList 接口
+ */
+ private String startTime;
+
+ /**
+ * 记录时间范围查询结束（选传）
+ * 格式：yyyy-MM-dd HH:mm:ss
+ * 与 startTime 配合使用，两者均为空时不按时间范围过滤
+ */
+ private String endTime;
+
+ /**
+ * 振动参数选择（选传，仅振动设备 type=10 有效）
+ * 可选值：vibrationSpeed / vibrationDisplacement / vibrationAcceleration / vibrationTemp
+ * 不传则按振动设备返回全部四个振动字段
+ * 传入后 Service 层会在裁剪字段时只保留该参数对应的振动字段
+ */
+ private String vibrationParam;
+}
diff --git a/ruoyi-ems/src/main/java/org/dromara/ems/record/enums/IotEnvMonitorTypeEnum.java b/ruoyi-ems/src/main/java/org/dromara/ems/record/enums/IotEnvMonitorTypeEnum.java
new file mode 100644
index 0000000..42f3c66
--- /dev/null
+++ b/ruoyi-ems/src/main/java/org/dromara/ems/record/enums/IotEnvMonitorTypeEnum.java
@@ -0,0 +1,87 @@
+package org.dromara.ems.record.enums;
+
+/**
+ * 物联网环境监测设备类型枚举
+ * 用于按设备类型裁剪返回字段，并提供 energyName 中文名称映射
+ *
+ * 设备类型编码对应 ems_base_monitor_info.monitor_type 字段
+ *
+ * @author zch
+ * @date 2026-04-09
+ */
+public enum IotEnvMonitorTypeEnum {
+
+ /** 温度设备（只采集 temperature） */
+ TEMPERATURE(5, "温度"),
+
+ /** 温湿度设备（采集 temperature + humidity） */
+ TEMPERATURE_HUMIDITY(6, "温湿度"),
+
+ /** 噪声设备（只采集 noise） */
+ NOISE(7, "噪声"),
+
+ /** 照度设备（只采集 illuminance） */
+ ILLUMINANCE(8, "照度"),
+
+ /** 气体浓度设备（只采集 concentration） */
+ CONCENTRATION(9, "气体浓度"),
+
+ /** 振动设备（采集 vibration_speed / vibration_displacement / vibration_acceleration / vibration_temp） */
+ VIBRATION(10, "振动"),
+
+ /**
+ * 未知设备类型兜底枚举值。
+ * 出现此值时 Service 层会返回全量字段，避免新设备类型上线前数据全部被过滤丢失。
+ */
+ UNKNOWN(-1, "未知");
+
+ /** 设备类型编码（对应 ems_base_monitor_info.monitor_type） */
+ private final int code;
+
+ /** 设备类型中文名称（用于接口返回 energyName 字段） */
+ private final String energyName;
+
+ IotEnvMonitorTypeEnum(int code, String energyName) {
+ this.code = code;
+ this.energyName = energyName;
+ }
+
+ public int getCode() {
+ return code;
+ }
+
+ public String getEnergyName() {
+ return energyName;
+ }
+
+ /**
+ * 根据设备类型编码获取对应枚举值。
+ * 若编码为 null 或不在已知列表中，则返回 UNKNOWN，
+ * 保证调用方不会因为新设备类型抛 NPE 或漏数据。
+ *
+ * @param code 设备类型编码（来自 ems_base_monitor_info.monitor_type）
+ * @return 匹配的枚举值，未匹配时返回 UNKNOWN
+ */
+ public static IotEnvMonitorTypeEnum fromCode(Integer code) {
+ if (code == null) {
+ return UNKNOWN;
+ }
+ for (IotEnvMonitorTypeEnum item : values()) {
+ if (item.code == code) {
+ return item;
+ }
+ }
+ // 未识别类型返回兜底枚举，业务层按 UNKNOWN 处理
+ return UNKNOWN;
+ }
+
+ /**
+ * 根据设备类型编码直接获取中文名称（快捷方法）。
+ *
+ * @param code 设备类型编码
+ * @return 中文名称，未匹配时返回"未知"
+ */
+ public static String getEnergyNameByCode(Integer code) {
+ return fromCode(code).getEnergyName();
+ }
+}
diff --git a/ruoyi-ems/src/main/java/org/dromara/ems/record/mapper/IotEnvMonitorDataMapper.java b/ruoyi-ems/src/main/java/org/dromara/ems/record/mapper/IotEnvMonitorDataMapper.java
new file mode 100644
index 0000000..be5f06a
--- /dev/null
+++ b/ruoyi-ems/src/main/java/org/dromara/ems/record/mapper/IotEnvMonitorDataMapper.java
@@ -0,0 +1,102 @@
+package org.dromara.ems.record.mapper;
+
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 物联网环境监测数据按日分表查询 Mapper 接口
+ *
+ * 独立新增，不修改已有 RecordIotenvInstantMapper。
+ * 所有方法均使用 Map 作为返回类型，由 Service 层根据 monitor_type 动态裁剪字段后再返回前端。
+ *
+ * 动态表名安全说明：
+ * tableName 参数在 Service 层经过严格的日期格式解析和白名单正则校验后才传入，
+ * 格式固定为 record_iotenv_instant_yyyyMMdd，拒绝任何外部原始字符串直接注入。
+ *
+ * @author zch
+ * @date 2026-04-09
+ */
+public interface IotEnvMonitorDataMapper {
+
+ /**
+ * 检查指定日分表是否存在于数据库（SQL Server INFORMATION_SCHEMA 查询）
+ *
+ * 查询前必须先做此判断，分表不存在时直接返回空集合，
+ * 避免动态 SQL 执行时因表名不存在而抛出 SQL 异常。
+ *
+ * @param tableName 已经白名单校验的分表名（格式：record_iotenv_instant_yyyyMMdd）
+ * @return 存在则返回 1，不存在返回 0
+ */
+ Integer checkDailyTableExists(@Param("tableName") String tableName);
+
+ /**
+ * 查询指定日分表中的原始数据列表，关联 ems_base_monitor_info 获取设备信息。
+ *
+ * 返回全量字段原始数据，Service 层根据每行的 monitor_type 按需裁剪字段，
+ * 此方式比在 SQL 中做 CASE WHEN 裁剪更稳妥、更易维护。
+ *
+ * @param tableName 已校验合法的分表名（格式：record_iotenv_instant_yyyyMMdd）
+ * @param monitorId 单设备编号精确过滤（为 null 时不按此字段过滤）
+ * @param monitorIds 批量设备编号过滤（为空时不按此字段过滤）
+ * @param monitorType 设备类型过滤（为 null 时不按此字段过滤）
+ * @param startTime 记录时间起始过滤（由 Service 层严格解析成时间对象后传入，为 null 时不过滤）
+ * @param endTime 记录时间结束过滤（由 Service 层严格解析成时间对象后传入，为 null 时不过滤）
+ * @return 原始数据 Map 列表，包含设备基础信息字段；结果为空时返回空列表
+ */
+ List> selectRawDataByDate(
+ @Param("tableName") String tableName,
+ @Param("monitorId") String monitorId,
+ @Param("monitorIds") List monitorIds,
+ @Param("monitorType") Integer monitorType,
+ @Param("startTime") Date startTime,
+ @Param("endTime") Date endTime
+ );
+
+ /**
+ * 查询指定日分表中单个设备的最新一条原始数据（TOP 1，按 recodeTime DESC, objid DESC）。
+ *
+ * 适用于实时监控面板展示单设备最新状态的场景。
+ *
+ * @param tableName 已校验合法的分表名
+ * @param monitorId 设备编号（精确匹配 monitorId 字段）
+ * @return 该设备最新一条数据 Map；分表中无该设备数据时返回 null
+ */
+ Map selectLatestRawByMonitorId(
+ @Param("tableName") String tableName,
+ @Param("monitorId") String monitorId
+ );
+
+ /**
+ * 批量查询指定日分表中多个设备各自的最新一条原始数据。
+ *
+ * 使用 ROW_NUMBER() OVER (PARTITION BY monitorId ORDER BY recodeTime DESC, objid DESC)
+ * 在一条 SQL 中完成各设备取最新行的操作，避免对每个设备单独发起查询造成 N+1 问题。
+ *
+ * @param tableName 已校验合法的分表名
+ * @param monitorIds 设备编号列表（至少需要包含一个元素，空列表由 Service 层拦截）
+ * @return 每个设备最新一条数据 Map 列表，按 monitorId 升序排列
+ */
+ List> selectLatestRawByMonitorIds(
+ @Param("tableName") String tableName,
+ @Param("monitorIds") List monitorIds
+ );
+
+ /**
+ * 从多个最近可用分表中批量查询多个设备各自的最新一条原始数据。
+ *
+ * 该方法主要服务于“无参获取所有设备最新值”的新接口：
+ * 先由 Service 层收集设备主数据里的 monitorIds，再在最近存在的分表中做跨表聚合，
+ * 最终为每个设备取 recodeTime 最新的一条，避免前端自己感知回退到哪张分表。
+ *
+ * @param tableNames 已校验合法的分表名列表，顺序通常为“当天 -> 往前回退”
+ * @param monitorIds 设备编号列表，由 Service 层从设备主数据表收集并去重
+ * @return 命中最新数据的原始 Map 列表；未命中的设备由 Service 层补设备骨架
+ */
+ List> selectLatestRawByMonitorIdsFromTables(
+ @Param("tableNames") List tableNames,
+ @Param("monitorIds") List monitorIds
+ );
+}
diff --git a/ruoyi-ems/src/main/java/org/dromara/ems/record/service/IIotEnvMonitorDataService.java b/ruoyi-ems/src/main/java/org/dromara/ems/record/service/IIotEnvMonitorDataService.java
new file mode 100644
index 0000000..8ba7ada
--- /dev/null
+++ b/ruoyi-ems/src/main/java/org/dromara/ems/record/service/IIotEnvMonitorDataService.java
@@ -0,0 +1,76 @@
+package org.dromara.ems.record.service;
+
+import org.dromara.ems.record.domain.bo.IotEnvMonitorQuery;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 物联网环境监测数据按日分表查询 Service 接口
+ *
+ * 独立新增，不修改已有 IRecordIotenvInstantService 及其实现。
+ * 所有方法返回 Map 类型，Service 层负责根据 monitor_type 动态裁剪字段，
+ * 避免不同设备类型的无关字段出现在接口响应中。
+ *
+ * @author zch
+ * @date 2026-04-09
+ */
+public interface IIotEnvMonitorDataService {
+
+ /**
+ * 无参查询所有设备各自最新一条监测数据。
+ *
+ * 接口内部会先从设备主数据表中收集 monitorIds，再参考现有
+ * RecordIotenvInstantServiceImpl 的“最近可用分表回退”策略，
+ * 从最近存在的日分表中为每个设备取最新一条数据，并按 monitor_type 裁剪字段。
+ *
+ * @return 所有设备最新一条裁剪后的数据列表；若暂无有效分表则返回设备骨架列表
+ */
+ List> queryLatestAllMonitorData();
+
+ /**
+ * 查询指定日期指定设备的最新一条监测数据。
+ *
+ * 根据 date 参数自动路由到对应日分表（record_iotenv_instant_yyyyMMdd），
+ * 取该设备 recodeTime 最新的一条记录，并按 monitor_type 裁剪返回字段。
+ *
+ * @param query 查询参数（必传字段：date、monitorId）
+ * @return 裁剪后的设备数据 Map；分表不存在或该设备无数据时返回空 Map
+ */
+ Map queryLatestByMonitorIdAndDate(IotEnvMonitorQuery query);
+
+ /**
+ * 查询指定日期的监测数据列表。
+ *
+ * 支持按 monitorId / monitorIds / monitorType / 时间范围等条件组合过滤，
+ * 每条记录按各自的 monitor_type 独立裁剪返回字段。
+ *
+ * 第一阶段只支持单天查询（date 对应一张分表）；
+ * 跨天聚合查询可在第二阶段通过多次调用或扩展新接口实现。
+ *
+ * @param query 查询参数（必传字段：date，其余条件选传）
+ * @return 裁剪后的数据列表；分表不存在时返回空列表
+ */
+ List> queryDataListByDate(IotEnvMonitorQuery query);
+
+ /**
+ * 批量查询指定日期多个设备各自的最新一条监测数据。
+ *
+ * 使用 ROW_NUMBER() 分区取最新行，一次 SQL 查询完成多个设备的最新数据获取，
+ * 避免 N+1 查询问题。每条记录按各自 monitor_type 裁剪返回字段。
+ *
+ * @param query 查询参数（必传字段：date、monitorIds）
+ * @return 每个设备最新一条裁剪后的数据列表；分表不存在时返回空列表
+ */
+ List> queryLatestByMonitorIdsAndDate(IotEnvMonitorQuery query);
+
+ /**
+ * 按设备类型查询指定日期的监测数据列表。
+ *
+ * 仅返回该设备类型对应的字段，返回结果字段集合由 monitorType 决定。
+ *
+ * @param query 查询参数（必传字段：date、monitorType）
+ * @return 该类型设备的数据列表；分表不存在时返回空列表
+ */
+ List> queryDataListByMonitorType(IotEnvMonitorQuery query);
+}
diff --git a/ruoyi-ems/src/main/java/org/dromara/ems/record/service/impl/IotEnvMonitorDataServiceImpl.java b/ruoyi-ems/src/main/java/org/dromara/ems/record/service/impl/IotEnvMonitorDataServiceImpl.java
new file mode 100644
index 0000000..67ba004
--- /dev/null
+++ b/ruoyi-ems/src/main/java/org/dromara/ems/record/service/impl/IotEnvMonitorDataServiceImpl.java
@@ -0,0 +1,673 @@
+package org.dromara.ems.record.service.impl;
+
+import lombok.RequiredArgsConstructor;
+import org.dromara.common.core.exception.ServiceException;
+import org.dromara.ems.base.domain.EmsBaseMonitorInfo;
+import org.dromara.ems.base.mapper.EmsBaseMonitorInfoMapper;
+import org.dromara.ems.record.domain.bo.IotEnvMonitorQuery;
+import org.dromara.ems.record.enums.IotEnvMonitorTypeEnum;
+import org.dromara.ems.record.mapper.IotEnvMonitorDataMapper;
+import org.dromara.ems.record.service.IIotEnvMonitorDataService;
+import org.dromara.ems.record.service.RecordIotenvPartitionService;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.time.format.DateTimeFormatter;
+import java.time.format.DateTimeFormatterBuilder;
+import java.time.format.DateTimeParseException;
+import java.time.format.ResolverStyle;
+import java.util.*;
+
+/**
+ * 物联网环境监测数据按日分表查询 Service 实现
+ *
+ * 核心职责：
+ * 1. 校验查询参数（必填项、格式合法性）
+ * 2. 将前端传入的日期字符串解析为 LocalDate，再通过 RecordIotenvPartitionService 生成白名单分表名
+ * 3. 判断目标分表是否存在（不存在时优雅返回空集合，不报 SQL 异常）
+ * 4. 调用 Mapper 查询原始数据（全量字段）
+ * 5. 根据每条记录的 monitor_type 裁剪返回字段，补充 energyName 中文名称
+ * 6. 组装并返回 Map 类型结果
+ *
+ *
+ * @author zch
+ * @date 2026-04-09
+ */
+@Service
+@RequiredArgsConstructor
+public class IotEnvMonitorDataServiceImpl implements IIotEnvMonitorDataService {
+
+ /** 复用现有最新值回退策略，只回看最近 7 天内存在的日分表 */
+ private static final int LATEST_TABLE_LOOKBACK_DAYS = 7;
+
+ /** 严格日期格式：前端若传 2026-02-29 这类非法日期，必须直接报错，不能被静默纠正 */
+ private static final DateTimeFormatter STRICT_DATE_FORMATTER = new DateTimeFormatterBuilder()
+ .appendPattern("uuuu-MM-dd")
+ .toFormatter()
+ .withResolverStyle(ResolverStyle.STRICT);
+
+ /** 紧凑日期格式同样使用严格解析，避免非法日期被自动回滚到上一个月末 */
+ private static final DateTimeFormatter STRICT_COMPACT_DATE_FORMATTER = new DateTimeFormatterBuilder()
+ .appendPattern("uuuuMMdd")
+ .toFormatter()
+ .withResolverStyle(ResolverStyle.STRICT);
+
+ /** 时间范围只接受秒级完整格式，避免不同页面传参粒度不一致导致查询口径漂移 */
+ private static final DateTimeFormatter STRICT_DATE_TIME_FORMATTER = new DateTimeFormatterBuilder()
+ .appendPattern("uuuu-MM-dd HH:mm:ss")
+ .toFormatter()
+ .withResolverStyle(ResolverStyle.STRICT);
+
+ /** 与现有 RecordIotenvInstantServiceImpl 保持一致，统一按系统时区把时间对象落库查询 */
+ private static final ZoneId SYSTEM_ZONE_ID = ZoneId.systemDefault();
+
+ /** 独立新增的 Mapper，不复用 RecordIotenvInstantMapper，保持职责隔离 */
+ private final IotEnvMonitorDataMapper iotEnvMonitorDataMapper;
+
+ /** 设备主数据来源，用于无参接口先收集 monitorIds，并在缺实时数据时补设备骨架 */
+ private final EmsBaseMonitorInfoMapper emsBaseMonitorInfoMapper;
+
+ /**
+ * 复用已有分区路由服务的 buildTableName() 方法，保证分表名生成规则与全系统一致，
+ * 避免出现两套命名规则导致分表路由口径不一致的问题。
+ */
+ private final RecordIotenvPartitionService recordIotenvPartitionService;
+
+ // ======================================================================
+ // 接口方法实现
+ // ======================================================================
+
+ /**
+ * 无参查询所有设备各自最新一条监测数据
+ */
+ @Override
+ public List> queryLatestAllMonitorData() {
+ // 先从设备主数据表收集 monitorIds，保证“全设备最新值”与现有首页口径一致
+ List baseMonitorInfos = listAllMonitorInfos();
+ if (baseMonitorInfos.isEmpty()) {
+ return Collections.emptyList();
+ }
+
+ List monitorIds = extractMonitorIds(baseMonitorInfos);
+ if (monitorIds.isEmpty()) {
+ return Collections.emptyList();
+ }
+
+ // 参考现有实时看板做法：优先当天，若当天无表则向前回退到最近存在分表
+ List tableNames = recordIotenvPartitionService.resolveLatestAvailableTables(LATEST_TABLE_LOOKBACK_DAYS);
+ if (tableNames.isEmpty()) {
+ // 没有有效分表时仍返回设备骨架，避免前端因为空集合导致整页结构断层
+ return buildLatestSnapshot(baseMonitorInfos, Collections.emptyMap());
+ }
+
+ List> rawList = iotEnvMonitorDataMapper.selectLatestRawByMonitorIdsFromTables(
+ tableNames, monitorIds
+ );
+ return buildLatestSnapshot(baseMonitorInfos, indexRawDataByMonitorId(rawList));
+ }
+
+ /**
+ * 查询指定日期指定设备的最新一条监测数据
+ */
+ @Override
+ public Map queryLatestByMonitorIdAndDate(IotEnvMonitorQuery query) {
+ // 校验必填参数
+ validateDateRequired(query);
+ String monitorId = trimToNull(query.getMonitorId());
+ if (monitorId == null) {
+ throw new ServiceException("设备编号 monitorId 不能为空");
+ }
+
+ // 解析日期并生成经过白名单校验的分表名
+ String tableName = buildAndValidateTableName(query.getDate());
+
+ // 分表不存在时优雅返回空 Map，避免直接抛 SQL 异常暴露内部结构
+ if (!isDailyTableExists(tableName)) {
+ return Collections.emptyMap();
+ }
+
+ // 查询原始数据（单条，TOP 1）
+ Map rawData = iotEnvMonitorDataMapper.selectLatestRawByMonitorId(
+ tableName, monitorId
+ );
+ if (rawData == null || rawData.isEmpty()) {
+ return Collections.emptyMap();
+ }
+
+ // 按设备类型裁剪字段并补充 energyName
+ return trimFieldsByMonitorType(rawData, query.getVibrationParam());
+ }
+
+ /**
+ * 查询指定日期的监测数据列表（支持多条件过滤）
+ */
+ @Override
+ public List> queryDataListByDate(IotEnvMonitorQuery query) {
+ validateDateRequired(query);
+ MonitorFilter monitorFilter = resolveMonitorFilter(query);
+ TimeRange timeRange = resolveOptionalRecordTimeRange(query);
+
+ String tableName = buildAndValidateTableName(query.getDate());
+ if (!isDailyTableExists(tableName)) {
+ return Collections.emptyList();
+ }
+
+ // 调用 Mapper 查询原始数据列表
+ List> rawList = iotEnvMonitorDataMapper.selectRawDataByDate(
+ tableName,
+ monitorFilter.monitorId,
+ monitorFilter.monitorIds,
+ query.getMonitorType(),
+ timeRange.startTime,
+ timeRange.endTime
+ );
+
+ // 对每条记录按设备类型裁剪字段
+ return trimListByMonitorType(rawList, query.getVibrationParam());
+ }
+
+ /**
+ * 批量查询指定日期多个设备各自最新一条监测数据
+ */
+ @Override
+ public List> queryLatestByMonitorIdsAndDate(IotEnvMonitorQuery query) {
+ validateDateRequired(query);
+ List monitorIds = normalizeMonitorIds(query.getMonitorIds());
+ if (monitorIds.isEmpty()) {
+ throw new ServiceException("设备编号列表 monitorIds 不能为空");
+ }
+
+ String tableName = buildAndValidateTableName(query.getDate());
+ if (!isDailyTableExists(tableName)) {
+ return Collections.emptyList();
+ }
+
+ List> rawList = iotEnvMonitorDataMapper.selectLatestRawByMonitorIds(
+ tableName, monitorIds
+ );
+ return trimListByMonitorType(rawList, query.getVibrationParam());
+ }
+
+ /**
+ * 按设备类型查询指定日期的监测数据列表
+ */
+ @Override
+ public List> queryDataListByMonitorType(IotEnvMonitorQuery query) {
+ validateDateRequired(query);
+ if (query.getMonitorType() == null) {
+ throw new ServiceException("设备类型 monitorType 不能为空");
+ }
+ TimeRange timeRange = resolveOptionalRecordTimeRange(query);
+
+ String tableName = buildAndValidateTableName(query.getDate());
+ if (!isDailyTableExists(tableName)) {
+ return Collections.emptyList();
+ }
+
+ List> rawList = iotEnvMonitorDataMapper.selectRawDataByDate(
+ tableName,
+ null,
+ null,
+ query.getMonitorType(),
+ timeRange.startTime,
+ timeRange.endTime
+ );
+ return trimListByMonitorType(rawList, query.getVibrationParam());
+ }
+
+ // ======================================================================
+ // 私有工具方法
+ // ======================================================================
+
+ /**
+ * 校验 date 参数是否存在且非空
+ */
+ private void validateDateRequired(IotEnvMonitorQuery query) {
+ if (query == null) {
+ throw new ServiceException("查询参数不能为空");
+ }
+ if (isBlank(query.getDate())) {
+ throw new ServiceException("查询日期 date 不能为空，支持格式：yyyy-MM-dd 或 yyyyMMdd");
+ }
+ }
+
+ /**
+ * 解析日期字符串并通过 RecordIotenvPartitionService 生成经白名单校验的分表名。
+ *
+ * 安全说明：
+ * 分表名永远由服务端根据合法日期自动生成，绝不允许前端原始字符串直接拼入 SQL。
+ * RecordIotenvPartitionService.buildTableName() 内部有正则白名单双重校验
+ * （格式：^record_iotenv_instant_\d{8}$），任何不符合格式的输入都会抛出 ServiceException。
+ *
+ * @param dateStr 前端传入的日期字符串（yyyy-MM-dd 或 yyyyMMdd）
+ * @return 已校验合法的分表名
+ */
+ private String buildAndValidateTableName(String dateStr) {
+ LocalDate localDate = parseDateString(dateStr);
+ // buildTableName 内部会再次做正则校验，双重保险
+ return recordIotenvPartitionService.buildTableName(localDate);
+ }
+
+ /**
+ * 解析日期字符串，支持 yyyy-MM-dd 和 yyyyMMdd 两种格式。
+ * 严格解析，非法日期（如 2026-13-01、20261301）会直接抛出 ServiceException。
+ *
+ * @param dateStr 日期字符串
+ * @return LocalDate 对象
+ */
+ private LocalDate parseDateString(String dateStr) {
+ String trimmed = dateStr.trim();
+ // 先尝试 yyyy-MM-dd 格式（前端日期选择器最常见输出格式）
+ try {
+ return LocalDate.parse(trimmed, STRICT_DATE_FORMATTER);
+ } catch (DateTimeParseException ignored) {
+ // 继续尝试 yyyyMMdd 格式
+ }
+ // 再尝试 yyyyMMdd 格式（紧凑型日期字符串）
+ try {
+ return LocalDate.parse(trimmed, STRICT_COMPACT_DATE_FORMATTER);
+ } catch (DateTimeParseException e) {
+ throw new ServiceException(
+ "日期格式不正确，仅支持 yyyy-MM-dd 或 yyyyMMdd，实际收到：" + dateStr
+ );
+ }
+ }
+
+ /**
+ * 检查指定分表是否存在于数据库。
+ * 使用新 Mapper 的 checkDailyTableExists 方法查询 INFORMATION_SCHEMA.TABLES。
+ *
+ * @param tableName 已经白名单校验过的分表名
+ * @return true 表示分表存在
+ */
+ private boolean isDailyTableExists(String tableName) {
+ Integer count = iotEnvMonitorDataMapper.checkDailyTableExists(tableName);
+ return count != null && count > 0;
+ }
+
+ /**
+ * 归一化 monitor 条件。
+ *
+ * 评审要求明确了“以 monitorIds 列表为主”，因此当列表非空时会主动忽略 monitorId，
+ * 避免出现 monitorId = ? AND monitorId IN (?) 叠加后误过滤为空的情况。
+ */
+ private MonitorFilter resolveMonitorFilter(IotEnvMonitorQuery query) {
+ List monitorIds = normalizeMonitorIds(query.getMonitorIds());
+ if (!monitorIds.isEmpty()) {
+ return new MonitorFilter(null, monitorIds);
+ }
+ return new MonitorFilter(trimToNull(query.getMonitorId()), Collections.emptyList());
+ }
+
+ /**
+ * 规范化 monitorIds：去空白、去重、保序。
+ *
+ * 这样做的业务价值是：既能减少 SQL IN 条件里的重复值，又能避免前端数组里夹杂空串时
+ * 误判为“有值但查不到数据”，排查起来更直接。
+ */
+ private List normalizeMonitorIds(List monitorIds) {
+ if (monitorIds == null || monitorIds.isEmpty()) {
+ return Collections.emptyList();
+ }
+ LinkedHashSet normalized = new LinkedHashSet<>();
+ for (String monitorId : monitorIds) {
+ String trimmedMonitorId = trimToNull(monitorId);
+ if (trimmedMonitorId != null) {
+ normalized.add(trimmedMonitorId);
+ }
+ }
+ if (normalized.isEmpty()) {
+ return Collections.emptyList();
+ }
+ return new ArrayList<>(normalized);
+ }
+
+ /**
+ * 解析可选的记录时间范围。
+ *
+ * 这里参照现有 RecordIotenvInstantServiceImpl 的思路，在 Service 层先把字符串解析成时间对象，
+ * 再校验起止顺序，避免把格式错误或颠倒顺序的问题拖到数据库层才暴露。
+ */
+ private TimeRange resolveOptionalRecordTimeRange(IotEnvMonitorQuery query) {
+ Date startTime = parseOptionalDateTime(query.getStartTime(), "开始记录时间");
+ Date endTime = parseOptionalDateTime(query.getEndTime(), "结束记录时间");
+ if (startTime != null && endTime != null && startTime.after(endTime)) {
+ throw new ServiceException("开始记录时间不能晚于结束记录时间");
+ }
+ return new TimeRange(startTime, endTime);
+ }
+
+ /**
+ * 严格解析时间范围参数。
+ *
+ * 仅接受 yyyy-MM-dd HH:mm:ss，像 2026-04-09 8:00、2026/04/09 08:00:00
+ * 这类非约定格式都直接 Fail Fast，避免接口口径被不同前端页面偷偷拉歪。
+ */
+ private Date parseOptionalDateTime(String dateTimeStr, String fieldName) {
+ String trimmed = trimToNull(dateTimeStr);
+ if (trimmed == null) {
+ return null;
+ }
+ try {
+ LocalDateTime localDateTime = LocalDateTime.parse(trimmed, STRICT_DATE_TIME_FORMATTER);
+ return Date.from(localDateTime.atZone(SYSTEM_ZONE_ID).toInstant());
+ } catch (DateTimeParseException e) {
+ throw new ServiceException(fieldName + "格式不正确，请使用 yyyy-MM-dd HH:mm:ss");
+ }
+ }
+
+ /**
+ * 查询设备主数据表并去掉空编码、重复编码。
+ */
+ private List listAllMonitorInfos() {
+ List monitorInfos = emsBaseMonitorInfoMapper.selectEmsBaseMonitorInfoList(
+ new EmsBaseMonitorInfo()
+ );
+ if (monitorInfos == null || monitorInfos.isEmpty()) {
+ return Collections.emptyList();
+ }
+
+ LinkedHashMap distinctMonitorMap = new LinkedHashMap<>();
+ for (EmsBaseMonitorInfo monitorInfo : monitorInfos) {
+ String monitorCode = trimToNull(monitorInfo.getMonitorCode());
+ if (monitorCode == null || distinctMonitorMap.containsKey(monitorCode)) {
+ continue;
+ }
+ monitorInfo.setMonitorCode(monitorCode);
+ distinctMonitorMap.put(monitorCode, monitorInfo);
+ }
+ return new ArrayList<>(distinctMonitorMap.values());
+ }
+
+ /**
+ * 从设备主数据中提取 monitorIds 列表。
+ */
+ private List extractMonitorIds(List baseMonitorInfos) {
+ List monitorIds = new ArrayList<>(baseMonitorInfos.size());
+ for (EmsBaseMonitorInfo baseMonitorInfo : baseMonitorInfos) {
+ if (trimToNull(baseMonitorInfo.getMonitorCode()) != null) {
+ monitorIds.add(baseMonitorInfo.getMonitorCode());
+ }
+ }
+ return monitorIds;
+ }
+
+ /**
+ * 将原始实时数据按 monitorId 建索引，方便后续与设备主数据做一一补齐。
+ */
+ private Map> indexRawDataByMonitorId(List> rawList) {
+ if (rawList == null || rawList.isEmpty()) {
+ return Collections.emptyMap();
+ }
+ Map> rawDataMap = new HashMap<>(rawList.size());
+ for (Map raw : rawList) {
+ String monitorId = trimToNull(raw.get("monitorId") == null ? null : raw.get("monitorId").toString());
+ if (monitorId != null) {
+ rawDataMap.putIfAbsent(monitorId, raw);
+ }
+ }
+ return rawDataMap;
+ }
+
+ /**
+ * 按设备主数据顺序构建“所有设备最新值”结果。
+ *
+ * 即便某设备当前没有实时数据，也会保留设备骨架并按 monitor_type 裁剪字段，
+ * 这样前端调用无参接口时可以稳定拿到完整设备集合。
+ */
+ private List> buildLatestSnapshot(
+ List baseMonitorInfos, Map> rawDataMap
+ ) {
+ List> result = new ArrayList<>(baseMonitorInfos.size());
+ for (EmsBaseMonitorInfo baseMonitorInfo : baseMonitorInfos) {
+ Map raw = buildSnapshotRawData(baseMonitorInfo, rawDataMap.get(baseMonitorInfo.getMonitorCode()));
+ result.add(trimFieldsByMonitorType(raw, null));
+ }
+ return result;
+ }
+
+ /**
+ * 合并设备主数据与实时原始数据。
+ *
+ * 主数据负责补足 monitorCode/monitorName/monitorType，实时数据负责补测量值和时间戳；
+ * 这样可以兼容“设备存在但当前无最新值”的场景。
+ */
+ private Map buildSnapshotRawData(EmsBaseMonitorInfo baseMonitorInfo, Map latestRaw) {
+ String monitorCode = baseMonitorInfo.getMonitorCode();
+ String monitorName = trimToNull(baseMonitorInfo.getMonitorName());
+ if (monitorName == null && latestRaw != null && latestRaw.get("monitorName") != null) {
+ monitorName = latestRaw.get("monitorName").toString();
+ }
+ Object monitorType = baseMonitorInfo.getMonitorType() != null
+ ? baseMonitorInfo.getMonitorType()
+ : getRawValue(latestRaw, "monitorType");
+
+ Map raw = new LinkedHashMap<>();
+ raw.put("objid", getRawValue(latestRaw, "objid"));
+ raw.put("monitorId", monitorCode);
+ raw.put("monitorCode", monitorCode);
+ raw.put("monitorName", monitorName != null ? monitorName : monitorCode);
+ raw.put("monitorType", monitorType);
+ raw.put("temperature", getRawValue(latestRaw, "temperature"));
+ raw.put("humidity", getRawValue(latestRaw, "humidity"));
+ raw.put("illuminance", getRawValue(latestRaw, "illuminance"));
+ raw.put("noise", getRawValue(latestRaw, "noise"));
+ raw.put("concentration", getRawValue(latestRaw, "concentration"));
+ raw.put("vibrationSpeed", getRawValue(latestRaw, "vibrationSpeed"));
+ raw.put("vibrationDisplacement", getRawValue(latestRaw, "vibrationDisplacement"));
+ raw.put("vibrationAcceleration", getRawValue(latestRaw, "vibrationAcceleration"));
+ raw.put("vibrationTemp", getRawValue(latestRaw, "vibrationTemp"));
+ raw.put("collectTime", getRawValue(latestRaw, "collectTime"));
+ raw.put("recodeTime", getRawValue(latestRaw, "recodeTime"));
+ return raw;
+ }
+
+ /**
+ * 读取原始 Map 值，兼容 latestRaw 为空的设备骨架场景。
+ */
+ private Object getRawValue(Map raw, String key) {
+ return raw == null ? null : raw.get(key);
+ }
+
+ /**
+ * 批量裁剪：对列表中每条记录按各自的 monitor_type 裁剪字段。
+ *
+ * @param rawList 原始数据列表
+ * @param vibrationParam 振动参数选择（仅振动设备有效）
+ * @return 裁剪后的数据列表
+ */
+ private List> trimListByMonitorType(
+ List> rawList, String vibrationParam
+ ) {
+ if (rawList == null || rawList.isEmpty()) {
+ return Collections.emptyList();
+ }
+ List> result = new ArrayList<>(rawList.size());
+ for (Map raw : rawList) {
+ result.add(trimFieldsByMonitorType(raw, vibrationParam));
+ }
+ return result;
+ }
+
+ /**
+ * 按设备类型裁剪返回字段的核心方法。
+ *
+ * 设计原则：
+ * 1. 先提取公共字段（设备标识 + 时间字段），所有设备类型都包含
+ * 2. 再根据 monitor_type 追加对应的测量字段
+ * 3. 不相关的测量字段不放入结果 Map，避免前端渲染时处理大量 null 值
+ * 4. 兜底逻辑：未识别类型返回全量字段，保证新设备类型接入后不丢数据
+ *
+ * 纯净返回方案（默认）：仅返回对应设备类型的测量字段。
+ * 若需要兼容旧前端（旧接口期望全量字段），可在此方法中补充 null 填充逻辑（兼容方案）。
+ *
+ * @param raw 原始数据行（含所有字段）
+ * @param vibrationParam 振动参数选择（vibrationSpeed/vibrationDisplacement/vibrationAcceleration/vibrationTemp）
+ * @return 裁剪后只包含该设备类型有业务意义字段的 Map
+ */
+ private Map trimFieldsByMonitorType(
+ Map raw, String vibrationParam
+ ) {
+ // 从原始数据中读取设备类型编码
+ Object monitorTypeObj = raw.get("monitorType");
+ Integer monitorType = (monitorTypeObj == null) ? null : ((Number) monitorTypeObj).intValue();
+ IotEnvMonitorTypeEnum typeEnum = IotEnvMonitorTypeEnum.fromCode(monitorType);
+
+ // 构建结果 Map，使用 LinkedHashMap 保持字段顺序（便于前端调试和日志可读性）
+ Map result = new LinkedHashMap<>();
+
+ // ---- 公共标识字段：所有设备类型都必须返回 ----
+ result.put("objid", raw.get("objid"));
+ result.put("monitorId", raw.get("monitorId"));
+ result.put("monitorCode", raw.get("monitorCode"));
+ result.put("monitorName", raw.get("monitorName"));
+ result.put("monitorType", monitorType);
+ // energyName 由枚举根据 monitor_type 自动映射，不依赖数据库字段
+ result.put("energyName", typeEnum.getEnergyName());
+
+ // ---- 按设备类型追加对应测量字段（纯净返回方案）----
+ switch (typeEnum) {
+ case TEMPERATURE:
+ // 温度设备（type=5）：只返回温度字段
+ result.put("temperature", raw.get("temperature"));
+ break;
+
+ case TEMPERATURE_HUMIDITY:
+ // 温湿度设备（type=6）：返回温度和湿度两个字段
+ result.put("temperature", raw.get("temperature"));
+ result.put("humidity", raw.get("humidity"));
+ break;
+
+ case NOISE:
+ // 噪声设备（type=7）：只返回噪声字段
+ result.put("noise", raw.get("noise"));
+ break;
+
+ case ILLUMINANCE:
+ // 照度设备（type=8）：只返回照度字段
+ result.put("illuminance", raw.get("illuminance"));
+ break;
+
+ case CONCENTRATION:
+ // 气体浓度设备（type=9）：只返回浓度字段
+ result.put("concentration", raw.get("concentration"));
+ break;
+
+ case VIBRATION:
+ // 振动设备（type=10）：若指定了 vibrationParam 则只返回该单一振动参数，
+ // 否则返回全部四个振动字段
+ if (!isBlank(vibrationParam)) {
+ appendSingleVibrationField(result, raw, vibrationParam);
+ } else {
+ result.put("vibrationSpeed", raw.get("vibrationSpeed"));
+ result.put("vibrationDisplacement", raw.get("vibrationDisplacement"));
+ result.put("vibrationAcceleration", raw.get("vibrationAcceleration"));
+ result.put("vibrationTemp", raw.get("vibrationTemp"));
+ }
+ break;
+
+ default:
+ // 兜底：未识别类型返回全量测量字段，避免新设备类型上线后数据全部被过滤丢失。
+ // 此处统一记录到日志中，便于后续排查是否有新设备类型未在枚举中登记。
+ result.put("temperature", raw.get("temperature"));
+ result.put("humidity", raw.get("humidity"));
+ result.put("illuminance", raw.get("illuminance"));
+ result.put("noise", raw.get("noise"));
+ result.put("concentration", raw.get("concentration"));
+ result.put("vibrationSpeed", raw.get("vibrationSpeed"));
+ result.put("vibrationDisplacement", raw.get("vibrationDisplacement"));
+ result.put("vibrationAcceleration", raw.get("vibrationAcceleration"));
+ result.put("vibrationTemp", raw.get("vibrationTemp"));
+ break;
+ }
+
+ // ---- 公共时间字段：所有设备类型都必须返回 ----
+ result.put("collectTime", raw.get("collectTime"));
+ result.put("recodeTime", raw.get("recodeTime"));
+
+ return result;
+ }
+
+ /**
+ * 仅追加振动设备指定的单一振动参数字段。
+ * 若 vibrationParam 不在已知列表中，则退化为返回全部振动字段（兜底保护）。
+ *
+ * @param result 待填充的结果 Map
+ * @param raw 原始数据行
+ * @param vibrationParam 振动参数名称
+ */
+ private void appendSingleVibrationField(
+ Map result, Map raw, String vibrationParam
+ ) {
+ switch (vibrationParam) {
+ case "vibrationSpeed":
+ result.put("vibrationSpeed", raw.get("vibrationSpeed"));
+ break;
+ case "vibrationDisplacement":
+ result.put("vibrationDisplacement", raw.get("vibrationDisplacement"));
+ break;
+ case "vibrationAcceleration":
+ result.put("vibrationAcceleration", raw.get("vibrationAcceleration"));
+ break;
+ case "vibrationTemp":
+ result.put("vibrationTemp", raw.get("vibrationTemp"));
+ break;
+ default:
+ // 未知振动参数名时返回全部振动字段，避免前端拿到空 Map 报错
+ result.put("vibrationSpeed", raw.get("vibrationSpeed"));
+ result.put("vibrationDisplacement", raw.get("vibrationDisplacement"));
+ result.put("vibrationAcceleration", raw.get("vibrationAcceleration"));
+ result.put("vibrationTemp", raw.get("vibrationTemp"));
+ break;
+ }
+ }
+
+ /**
+ * 判断字符串是否为空（null 或纯空白字符）
+ *
+ * @param str 待判断字符串
+ * @return true 表示空
+ */
+ private boolean isBlank(String str) {
+ return str == null || str.trim().isEmpty();
+ }
+
+ /**
+ * 去掉首尾空白后返回非空字符串；若为空则统一返回 null。
+ */
+ private String trimToNull(String str) {
+ if (str == null) {
+ return null;
+ }
+ String trimmed = str.trim();
+ return trimmed.isEmpty() ? null : trimmed;
+ }
+
+ /**
+ * monitor 条件归一化结果。
+ */
+ private static final class MonitorFilter {
+ private final String monitorId;
+ private final List monitorIds;
+
+ private MonitorFilter(String monitorId, List monitorIds) {
+ this.monitorId = monitorId;
+ this.monitorIds = monitorIds;
+ }
+ }
+
+ /**
+ * 可选时间范围解析结果。
+ */
+ private static final class TimeRange {
+ private final Date startTime;
+ private final Date endTime;
+
+ private TimeRange(Date startTime, Date endTime) {
+ this.startTime = startTime;
+ this.endTime = endTime;
+ }
+ }
+}
diff --git a/ruoyi-ems/src/main/resources/mapper/ems/record/IotEnvMonitorDataMapper.xml b/ruoyi-ems/src/main/resources/mapper/ems/record/IotEnvMonitorDataMapper.xml
new file mode 100644
index 0000000..0ba1c73
--- /dev/null
+++ b/ruoyi-ems/src/main/resources/mapper/ems/record/IotEnvMonitorDataMapper.xml
@@ -0,0 +1,238 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+