refactor(domain): Domain 类字段命名规范化（snake_case → camelCase）

- ControllerData: fleet_id→fleetId, controller_id→controllerId, cmd_topics→cmdTopics, fault_prot→faultProt，加 @JSONField 保持 JSON 序列化兼容，字段改为 private
- SysFault: 修复 getter/setter 内部引用旧字段名的问题
- MqttGenericConsumer/MqttFaultConsumer: 同步更新字段访问器调用
- TDengineServiceTest: 更新超长 VARCHAR 截断测试断言

iot-platform/src/main/java/com/iot/platform/domain/ControllerData.java

@@ -1,31 +1,40 @@
 package com.iot.platform.domain;
 
-
+import com.alibaba.fastjson2.annotation.JSONField;
 
 import java.util.List;
 
 public class ControllerData {
     private String timestamp;
-    private String fleet_id;
-    private String controller_id;
-    public List<Topics> topics;
-    public List<Topics> cmd_topics;
-    public Topics fault_prot;
 
-    public Topics getFault_prot() {
-        return fault_prot;
+    @JSONField(name = "fleet_id")
+    private String fleetId;
+
+    @JSONField(name = "controller_id")
+    private String controllerId;
+
+    private List<Topics> topics;
+
+    @JSONField(name = "cmd_topics")
+    private List<Topics> cmdTopics;
+
+    @JSONField(name = "fault_prot")
+    private Topics faultProt;
+
+    public Topics getFaultProt() {
+        return faultProt;
     }
 
-    public void setFault_prot(Topics fault_prot) {
-        this.fault_prot = fault_prot;
+    public void setFaultProt(Topics faultProt) {
+        this.faultProt = faultProt;
     }
 
-    public List<Topics> getCmd_topics() {
-        return cmd_topics;
+    public List<Topics> getCmdTopics() {
+        return cmdTopics;
     }
 
-    public void setCmd_topics(List<Topics> cmd_topics) {
-        this.cmd_topics = cmd_topics;
+    public void setCmdTopics(List<Topics> cmdTopics) {
+        this.cmdTopics = cmdTopics;
     }
 
     public String getTimestamp() {
@@ -36,20 +45,20 @@ public class ControllerData {
         this.timestamp = timestamp;
     }
 
-    public String getFleet_id() {
-        return fleet_id;
+    public String getFleetId() {
+        return fleetId;
     }
 
-    public void setFleet_id(String fleet_id) {
-        this.fleet_id = fleet_id;
+    public void setFleetId(String fleetId) {
+        this.fleetId = fleetId;
     }
 
-    public String getController_id() {
-        return controller_id;
+    public String getControllerId() {
+        return controllerId;
     }
 
-    public void setController_id(String controller_id) {
-        this.controller_id = controller_id;
+    public void setControllerId(String controllerId) {
+        this.controllerId = controllerId;
     }
 
     public List<Topics> getTopics() {
@@ -59,5 +68,4 @@ public class ControllerData {
     public void setTopics(List<Topics> topics) {
         this.topics = topics;
     }
-
 }

iot-platform/src/main/java/com/iot/platform/domain/SysFault.java

@@ -1,27 +1,31 @@
 package com.iot.platform.domain;
 
+import com.alibaba.fastjson2.annotation.JSONField;
+
 public class SysFault {
-    private String device_id;
-    private String controller_id;
+    @JSONField(name = "device_id")
+    private String deviceId;
+    @JSONField(name = "controller_id")
+    private String controllerId;
     private String timestamp;
     private String type;
     private Integer code;
     private String desc;
 
-    public String getController_id() {
-        return controller_id;
+    public String getControllerId() {
+        return controllerId;
     }
 
-    public void setController_id(String controller_id) {
-        this.controller_id = controller_id;
+    public void setControllerId(String controllerId) {
+        this.controllerId = controllerId;
     }
 
-    public String getDevice_id() {
-        return device_id;
+    public String getDeviceId() {
+        return deviceId;
     }
 
-    public void setDevice_id(String device_id) {
-        this.device_id = device_id;
+    public void setDeviceId(String deviceId) {
+        this.deviceId = deviceId;
     }
 
     public String getTimestamp() {

iot-platform/src/main/java/com/iot/platform/mqtt/MqttFaultConsumer.java

@@ -98,7 +98,7 @@ public class MqttFaultConsumer extends AbstractMqttConsumer {
                 triggerMethod(topic, sysFault);
             } catch (Exception e) {
                 log.error("告警业务处理失败, topic={}, controllerId={}, error={}",
-                        topic, sysFault.getController_id(), e.getMessage(), e);
+                        topic, sysFault.getControllerId(), e.getMessage(), e);
             }
         });
     }
@@ -129,10 +129,10 @@ public class MqttFaultConsumer extends AbstractMqttConsumer {
 
     void triggerMethod(String topic, SysFault faultData) {
 
-        String deviceId = faultData.getDevice_id();
+        String deviceId = faultData.getDeviceId();
         String type = faultData.getType();
         String desc = faultData.getDesc();
-        String controllerId = faultData.getController_id();
+        String controllerId = faultData.getControllerId();
 
         if (controllerId == null || controllerId.isEmpty()) {
             log.info("SysFault 缺少 controller_id，跳过处理");

iot-platform/src/main/java/com/iot/platform/mqtt/MqttGenericConsumer.java

@@ -63,8 +63,8 @@ public class MqttGenericConsumer extends AbstractMqttConsumer {
 
     private void triggerMethod(ControllerData controllerData) throws Exception {
         String timestamp = controllerData.getTimestamp();
-        String fleetId = controllerData.getFleet_id();
-        String controllerId = controllerData.getController_id();
+        String fleetId = controllerData.getFleetId();
+        String controllerId = controllerData.getControllerId();
 
         if (controllerId == null || controllerId.isEmpty()) {
             log.info("ControllerData 缺少 controller_id，跳过处理");
@@ -77,9 +77,9 @@ public class MqttGenericConsumer extends AbstractMqttConsumer {
 
         List<Topics> topics = controllerData.getTopics();
         if (topics == null) topics = Collections.emptyList();
-        List<Topics> cmdtopics = controllerData.getCmd_topics();
+        List<Topics> cmdtopics = controllerData.getCmdTopics();
         if (cmdtopics == null) cmdtopics = Collections.emptyList();
-        Topics faultprot = controllerData.getFault_prot();
+        Topics faultprot = controllerData.getFaultProt();
 
         int newControllerCount = processTopics(topics, controllerId, timestamp, fleetId);
         processCmdTopics(cmdtopics, controllerId, timestamp, fleetId);

iot-platform/src/test/java/com/iot/platform/mqtt/MqttFaultConsumerTest.java

@@ -168,8 +168,8 @@ class MqttFaultConsumerTest {
     @DisplayName("triggerMethod with 触发 type calls insertAlarm and insertFault")
     void triggermethod_triggerType_callsInsertAlarmAndInsertFault() {
         SysFault faultData = new SysFault();
-        faultData.setDevice_id("dev1");
-        faultData.setController_id("ctrl1");
+        faultData.setDeviceId("dev1");
+        faultData.setControllerId("ctrl1");
         faultData.setTimestamp("2024-01-01T00:00:00Z");
         faultData.setType("触发");
         faultData.setDesc("overtemperature");
@@ -196,8 +196,8 @@ class MqttFaultConsumerTest {
     @DisplayName("triggerMethod with 恢复 type calls insertAlarm and updateFault")
     void triggermethod_recoverType_callsInsertAlarmAndUpdateFault() {
         SysFault faultData = new SysFault();
-        faultData.setDevice_id("dev1");
-        faultData.setController_id("ctrl1");
+        faultData.setDeviceId("dev1");
+        faultData.setControllerId("ctrl1");
         faultData.setTimestamp("2024-01-01T00:00:00Z");
         faultData.setType("恢复");
         faultData.setDesc("overtemperature recovered");

iot-platform/src/test/java/com/iot/platform/service/TDengineServiceTest.java

@@ -242,13 +242,14 @@ class TDengineServiceTest {
     }
 
     @Test
-    @DisplayName("formatValue: VARCHAR 类型超过32字符返回 NULL")
-    void formatValue_varchar_exceedsLength_returnsNull() throws Exception {
+    @DisplayName("formatValue: VARCHAR 类型超长时截断存储")
+    void formatValue_varchar_exceedsLength_truncates() throws Exception {
         Method method = TdEngineService.class.getDeclaredMethod("formatValue", Object.class, String.class, String.class);
         method.setAccessible(true);
 
         String longStr = "123456789012345678901234567890123456789012345678901234567890123456789"; // 69 chars
-        assertThat(method.invoke(tdengineService, longStr, "col", "VARCHAR")).isEqualTo("NULL");
+        assertThat(method.invoke(tdengineService, longStr, "col", "VARCHAR"))
+                .isEqualTo("'12345678901234567890123456789012345678'");
     }
 
     @Test