From 2f11026c2bf0da100c27b8f60c9d9d7d31a7256e Mon Sep 17 00:00:00 2001 From: tianyuan <2861334240@qq.com> Date: Thu, 25 Dec 2025 10:03:48 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9E=E6=97=B6=E6=95=B0=E6=8D=AE=E6=9F=A5?= =?UTF-8?q?=E8=AF=A2=E6=8E=A5=E5=8F=A3=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/WaterRealtimeController.java | 33 ++++ .../service/StudentWaterDataService.java | 150 ++++++++++++++++++ .../campus/water/util/DeviceMappingUtil.java | 43 +++++ 3 files changed, 226 insertions(+) create mode 100644 src/main/java/com/campus/water/controller/WaterRealtimeController.java create mode 100644 src/main/java/com/campus/water/service/StudentWaterDataService.java create mode 100644 src/main/java/com/campus/water/util/DeviceMappingUtil.java diff --git a/src/main/java/com/campus/water/controller/WaterRealtimeController.java b/src/main/java/com/campus/water/controller/WaterRealtimeController.java new file mode 100644 index 0000000..a44ae19 --- /dev/null +++ b/src/main/java/com/campus/water/controller/WaterRealtimeController.java @@ -0,0 +1,33 @@ +package com.campus.water.controller; + +import com.campus.water.service.StudentWaterDataService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Map; + +/** + * 实时数据查询控制器 + * 负责终端关联的制水机/供水机实时数据查询接口 + */ +@RestController +@RequestMapping("/api/water/realtime") +public class WaterRealtimeController { + + @Autowired + private StudentWaterDataService waterDataService; + + /** + * 实时查询终端关联的制水机+供水机数据 + * 调用示例：GET http://localhost:8080/api/water/realtime/TERM001 + * @param terminalId 终端ID（路径参数） + * @return 制水机+供水机实时数据 + */ + @GetMapping("/{terminalId}") + public Map getRealtimeData(@PathVariable String terminalId) { + return waterDataService.queryRealtimeData(terminalId); + } +} \ No newline at end of file diff --git a/src/main/java/com/campus/water/service/StudentWaterDataService.java b/src/main/java/com/campus/water/service/StudentWaterDataService.java new file mode 100644 index 0000000..244900d --- /dev/null +++ b/src/main/java/com/campus/water/service/StudentWaterDataService.java @@ -0,0 +1,150 @@ +package com.campus.water.service; + +import com.campus.water.entity.DeviceTerminalMapping; +import com.campus.water.mapper.DeviceTerminalMappingRepository; +import com.campus.water.util.DeviceMappingUtil; // 硬编码映射工具类（之前定义的） +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; +import java.util.HashMap; +import java.util.Map; +import java.util.Optional; +import java.util.Random; + +@Service +public class StudentWaterDataService { + + @Autowired + private DeviceTerminalMappingRepository terminalMappingRepo; + + // 随机数工具（模拟实时数据） + private static final Random RANDOM = new Random(); + // 时间格式化器 + private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + + /** + * 核心：实时查询终端关联的制水机+供水机数据 + * @param terminalId 终端ID（如TERM001） + * @return 包含制水机、供水机实时数据的完整结果 + */ + public Map queryRealtimeData(String terminalId) { + Map result = new HashMap<>(); + try { + // 1. 校验终端ID非空 + if (terminalId == null || terminalId.trim().isEmpty()) { + result.put("code", 400); + result.put("msg", "终端ID不能为空"); + return result; + } + + // 2. 通过终端ID查询映射关系（核心：终端→制水机） + Optional mappingOpt = terminalMappingRepo.findByTerminalId(terminalId); + if (mappingOpt.isEmpty()) { + result.put("code", 404); + result.put("msg", "终端设备不存在或未配置映射关系"); + return result; + } + DeviceTerminalMapping mapping = mappingOpt.get(); + String makerDeviceId = mapping.getDeviceId(); // 制水机ID（WM开头） + // 从硬编码映射工具类获取供水机ID（替代数据库字段） + String supplyDeviceId = DeviceMappingUtil.getSupplyDeviceId(makerDeviceId); + + // 3. 生成制水机实时数据（调用模拟生成服务） + Map makerRealtimeData = new HashMap<>(); + if (makerDeviceId != null && makerDeviceId.startsWith("WM")) { + makerRealtimeData = generateMakerRealtimeData(makerDeviceId); + } else { + result.put("makerWarn", "终端未绑定有效制水机（ID格式需以WM开头）"); + } + + // 4. 生成供水机实时数据（调用模拟生成服务） + Map supplyRealtimeData = new HashMap<>(); + if (supplyDeviceId != null && supplyDeviceId.startsWith("WS")) { + supplyRealtimeData = generateSupplyRealtimeData(supplyDeviceId); + } else { + result.put("supplyWarn", "制水机未关联有效供水机（ID格式需以WS开头）"); + } + + // 5. 封装最终返回结果（包含终端、制水机、供水机全量数据） + result.put("code", 200); + result.put("msg", "实时数据查询成功"); + // 终端基础信息 + result.put("terminalInfo", Map.of( + "terminalId", terminalId, + "terminalName", mapping.getTerminalName(), + "terminalStatus", mapping.getTerminalStatus().name(), + "installDate", mapping.getInstallDate() != null ? mapping.getInstallDate().toString() : "未配置" + )); + // 制水机数据 + result.put("makerDevice", Map.of( + "deviceId", makerDeviceId, + "realtimeData", makerRealtimeData + )); + // 供水机数据 + result.put("supplyDevice", Map.of( + "deviceId", supplyDeviceId, + "realtimeData", supplyRealtimeData + )); + // 数据更新时间（统一时间戳） + result.put("updateTime", LocalDateTime.now().format(DATE_FORMATTER)); + + } catch (Exception e) { + // 全局异常捕获，保证接口不抛错 + result.put("code", 500); + result.put("msg", "实时数据查询失败：" + e.getMessage()); + result.put("errorDetail", e.getStackTrace()[0].toString()); // 调试用，生产可移除 + } + return result; + } + + /** + * 模拟生成制水机实时数据（独立服务方法，可单独调用） + * @param makerDeviceId 制水机ID + * @return 制水机实时数据 + */ + public Map generateMakerRealtimeData(String makerDeviceId) { + Map makerData = new HashMap<>(); + // 基础设备信息 + makerData.put("deviceId", makerDeviceId); + makerData.put("deviceType", "校园直饮矿化制水机"); + makerData.put("onlineStatus", RANDOM.nextBoolean() ? "在线" : "离线"); // 模拟在线状态 + // 核心水质参数（符合直饮水标准） + makerData.put("tdsValue", RANDOM.nextInt(50) + 10); // TDS值：10-60mg/L + makerData.put("phValue", String.format("%.1f", RANDOM.nextDouble() * 0.8 + 7.0)); // pH值：7.0-7.8 + makerData.put("temperature", RANDOM.nextInt(15) + 30); // 出水温度：30-45℃ + makerData.put("filterLife", 100 - RANDOM.nextInt(10)); // 滤芯寿命：90-100% + makerData.put("flowRate", String.format("%.2f", RANDOM.nextDouble() * 2 + 1)); // 流量：1.00-3.00L/min + // 运行数据 + makerData.put("totalUsage", RANDOM.nextInt(5000) + 10000); // 累计用水量：10000-15000L + makerData.put("faultCode", RANDOM.nextInt(100) > 95 ? "E01" : "无"); // 模拟故障码（5%概率故障） + makerData.put("updateTime", LocalDateTime.now().format(DATE_FORMATTER)); + return makerData; + } + + /** + * 模拟生成供水机实时数据（独立服务方法，可单独调用） + * @param supplyDeviceId 供水机ID + * @return 供水机实时数据 + */ + public Map generateSupplyRealtimeData(String supplyDeviceId) { + Map supplyData = new HashMap<>(); + // 基础设备信息 + supplyData.put("deviceId", supplyDeviceId); + supplyData.put("deviceType", "配套供水增压机"); + supplyData.put("onlineStatus", RANDOM.nextBoolean() ? "在线" : "离线"); + // 核心运行参数 + supplyData.put("waterPressure", String.format("%.2f", RANDOM.nextDouble() * 0.5 + 0.8)); // 水压：0.80-1.30MPa + supplyData.put("waterLevel", RANDOM.nextInt(30) + 70); // 水箱水位：70-100% + supplyData.put("pumpStatus", RANDOM.nextBoolean() ? "运行中" : "待机"); // 水泵状态 + supplyData.put("voltage", RANDOM.nextInt(10) + 220); // 工作电压：220-230V + // 运行数据 + supplyData.put("runHours", RANDOM.nextInt(1000) + 5000); // 累计运行时长：5000-6000h + supplyData.put("faultCode", RANDOM.nextInt(100) > 98 ? "P02" : "无"); // 模拟故障码（2%概率故障） + supplyData.put("updateTime", LocalDateTime.now().format(DATE_FORMATTER)); + return supplyData; + } + + // 原有其他方法（扫码用水、水质查询等）保持不变... +} \ No newline at end of file diff --git a/src/main/java/com/campus/water/util/DeviceMappingUtil.java b/src/main/java/com/campus/water/util/DeviceMappingUtil.java new file mode 100644 index 0000000..c17834c --- /dev/null +++ b/src/main/java/com/campus/water/util/DeviceMappingUtil.java @@ -0,0 +1,43 @@ +package com.campus.water.util; + +import java.util.HashMap; +import java.util.Map; + +/** + * 制水机-供水机映射工具类（替代数据库字段关联） + */ +public class DeviceMappingUtil { + // 单例模式，避免重复初始化 + private static final DeviceMappingUtil INSTANCE = new DeviceMappingUtil(); + private final Map makerToSupplyMap; + + private DeviceMappingUtil() { + makerToSupplyMap = new HashMap<>(); + // 配置制水机→供水机的关联关系（根据实际业务调整） + makerToSupplyMap.put("WM001", "WS001"); + makerToSupplyMap.put("WM002", "WS002"); + makerToSupplyMap.put("WM003", "WS003"); + makerToSupplyMap.put("WM004", "WS004"); + } + + /** + * 根据制水机ID获取对应的供水机ID + * @param makerDeviceId 制水机ID（WM开头） + * @return 供水机ID（WS开头），无关联则返回null + */ + public static String getSupplyDeviceId(String makerDeviceId) { + if (makerDeviceId == null) { + return null; + } + return INSTANCE.makerToSupplyMap.get(makerDeviceId); + } + + // 可选：动态添加/删除映射关系（便于扩展） + public static void addMapping(String makerDeviceId, String supplyDeviceId) { + INSTANCE.makerToSupplyMap.put(makerDeviceId, supplyDeviceId); + } + + public static void removeMapping(String makerDeviceId) { + INSTANCE.makerToSupplyMap.remove(makerDeviceId); + } +} \ No newline at end of file -- 2.34.1