From 78251c2769417cdc5d7eb4c78842afe4c17fe860 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=BB=ABUmbrella?= <2539020564@qq.com>
Date: Wed, 29 Apr 2026 09:46:30 +0800
Subject: [PATCH] =?UTF-8?q?mes=E6=8E=A5=E5=8F=A3=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../iot/controller/IotWebApiController.java   | 27 +++++++++++++++++++
 1 file changed, 27 insertions(+)

diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/iot/controller/IotWebApiController.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/iot/controller/IotWebApiController.java
index 27923fd8..0101016a 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/iot/controller/IotWebApiController.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/iot/controller/IotWebApiController.java
@@ -16,6 +16,8 @@ import org.springblade.desk.quality.service.IIotThicknessService;
 import org.springblade.desk.quality.service.IQcWithstandVoltageIotService;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.Date;
+
 
 @Slf4j
 @RestController
@@ -32,6 +34,31 @@ public class IotWebApiController {
     private final IQcHardnessIotService qcHardnessIotService;
     private final IQcWithstandVoltageIotService qcWithstandVoltageIotService;
 
+    @PostMapping("/saveLargeEquipment")
+    @Operation(summary = "大设备数据转换并保存产线电量")
+    public R saveLargeEquipment(@RequestBody JSONObject data) {
+        if (data == null || data.isEmpty()) {
+            throw new ServiceException("参数传递异常!");
+        }
+        JSONObject largeEquipment = data.getJSONObject("largeEquipment");
+        if (largeEquipment == null) {
+            throw new ServiceException("largeEquipment参数异常!");
+        }
+        String bathListenStr = largeEquipment.getString("bathListen");
+        if (bathListenStr == null || bathListenStr.isEmpty()) {
+            return R.success();
+        }
+        log.info("大设备数据转换: deviceCode={}, bathListen={}", data.getString("deviceCode"), bathListenStr);
+
+        JSONObject ahmData = new JSONObject();
+        ahmData.put("pushTm", new Date());
+        ahmData.put("deviceId", data.getString("deviceCode"));
+        ahmData.put("ahmItems", JSONArray.parseArray(bathListenStr));
+
+        lineElectricService.saveDeviceAhm(ahmData);
+        return R.success();
+    }
+
     @Operation(summary = "产线电量信息调用接口")
     @RequestMapping(value = "/saveDeviceAhm", method = RequestMethod.POST)
     public R saveDeviceAhm(@RequestBody JSONObject data) throws Exception {