test: 修复 MqttFaultConsumerTest 和 MqttStatusConsumerTest 编译与测试失败

- MqttFaultConsumerTest: 同步主代码重构后的方法签名
  - insertAlarm 调用在主代码中已注释掉，移除对应 verify
  - insertFault → insertAlertData (9 参数)
  - updateFault → updateAlertData (7 参数)
- MqttStatusConsumerTest: 同步 MqttStatusConsumer 重构
  - ValueOperations mock → HashOperations mock
  - opsForValue().set() → opsForHash().putAll()
  - 移除 fleet_id 相关测试数据（主代码已不再使用）
- CLAUDE.md: 更新 Redis key patterns 和 TDengine 连接说明

CLAUDE.md

 ### TDengine (Time-Series Database)
 - Used for high-frequency IoT telemetry ingestion
 - Connection pool: HikariCP via `TDengineService`
-- Connects to `jdbc:TAOS://172.21.185.173:6031/` (host network, via host IP)
+- Connects to `jdbc:TAOS://host.containers.internal:6031/` (container bridge network via host gateway)
 - Super-table pattern with column caching (`stableColumnCache`)
 
 ### Redis
 - Host: `${REDIS_HOST:localhost}:6379` (production overrides via `REDIS_HOST` env var)
 - Key patterns (defined in `common/RedisKeys.java`):
-  - `DSB:active:devices` — Set of active IoT device keys
-  - `DSB:<controllerId>:<metricName>` — Hash storing device telemetry
-  - `workorder:coordinate:<controllerId>` — GPS coordinates
-  - `<controllerId>:<topicName>` — MQTT topic metadata
+  - `iot:dsb:active:devices` — Set of active IoT device keys
+  - `iot:dsb:<controllerId>:<metricName>` — Hash storing device telemetry
+  - `iot:workorder:coordinate:<controllerId>` — GPS coordinates
+  - `iot:controller:<controllerId>:status` — Controller status hash (MqttStatusConsumer)
+  - `iot:controller:<controllerId>:<topicName>` — MQTT topic metadata
+  - `iot:controller:<controllerId>_fault:<topicName>` — Fault topic metadata
 
 ## Key Configuration Files
 
     ↓  subscribes to "+/generics", "+/status", "+/fault"
 MqttGenericConsumer / MqttStatusConsumer / MqttFaultConsumer
     ↓  parse JSON → ControllerData
-    ├─→ Redis (DSB:active:devices, DSB:<id>:<metric> hashes)
+    ├─→ Redis
+    │     ├─ iot:dsb:active:devices (active device set)
+    │     ├─ iot:dsb:<id>:<metric> (telemetry hashes)
+    │     └─ iot:controller:<id>:status (status hashes, MqttStatusConsumer)
     ├─→ MySQL (sys_controller, sys_device tables)
     └─→ TDengine (time-series telemetry tables)
 

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

 
         mqttFaultConsumer.triggerMethod(topic, faultData);
 
-        verify(sysAlarmService).insertAlarm(anyString(), eq("GJ123456789"), eq("overtemperature"), eq("0"), anyString(), eq("0"), eq("ctrl1"), eq("dev1"), eq("116.3974"), eq("39.9093"));
-        verify(sysFaultService).insertFault(eq("GJ123456789"), eq("overtemperature"), eq("0"), anyString(), eq("0"), eq("ctrl1"), eq("dev1"), eq("116.3974"), eq("39.9093"), eq(""));
+        verify(sysFaultService).insertAlertData(eq("GJ123456789"), eq("overtemperature"), eq("0"), anyString(), eq("0"), eq("ctrl1"), eq("dev1"), eq(""), anyString());
     }
 
     @Test
 
         mqttFaultConsumer.triggerMethod(topic, faultData);
 
-        verify(sysAlarmService).insertAlarm(anyString(), eq("GJ987654321"), eq("overtemperature recovered"), eq("1"), anyString(), eq("0"), eq("ctrl1"), eq("dev1"), eq("116.3974"), eq("39.9093"));
-        verify(sysFaultService).updateFault(eq("1"), eq("0"), eq("116.3974"), eq("39.9093"), eq("overtemperature recovered"), eq("ctrl1"), eq("dev1"), anyString());
+        verify(sysFaultService).updateAlertData(eq("1"), eq("0"), eq("overtemperature recovered"), eq("ctrl1"), eq("dev1"), anyString(), anyString());
     }
 }

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

 import org.junit.jupiter.api.extension.ExtendWith;
 import org.mockito.Mock;
 import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.data.redis.core.HashOperations;
 import org.springframework.data.redis.core.StringRedisTemplate;
-import org.springframework.data.redis.core.ValueOperations;
 
+import java.util.Collections;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.lenient;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.verify;
     private StringRedisTemplate stringRedisTemplate;
 
     @Mock
-    private ValueOperations<String, String> valueOperations;
+    private HashOperations<String, Object, Object> hashOperations;
 
     @Mock
     private IotProperties iotProperties;
     @BeforeEach
     void setUp() {
         mqttStatusConsumer = new MqttStatusConsumer(executorService, iotProperties, stringRedisTemplate, sysStatusService);
-        lenient().when(stringRedisTemplate.opsForValue()).thenReturn(valueOperations);
+        lenient().when(stringRedisTemplate.opsForHash()).thenReturn(hashOperations);
+        lenient().when(hashOperations.entries(anyString())).thenReturn(Collections.emptyMap());
     }
 
     @Test
     @Test
     @DisplayName("handleMessage with valid JSON writes status to Redis")
     void handleMessage_validJson_writesStatusToRedis() throws Exception {
-        String json = "{\"controller_id\":\"CTRL_001\",\"fleet_id\":\"FLEET_001\",\"status\":\"online\"}";
+        String json = "{\"controller_id\":\"CTRL_001\",\"status\":\"online\"}";
 
         mqttStatusConsumer.handleMessage("+/status", json);
 
-        verify(valueOperations).set("CTRL_001_FLEET_001", "online");
+        verify(hashOperations).putAll(eq("status_CTRL_001"), any());
     }
 
     @Test
 
         mqttStatusConsumer.handleMessage("+/status", invalidJson);
 
-        verify(valueOperations, never()).set(anyString(), anyString());
+        verify(hashOperations, never()).putAll(anyString(), any());
     }
 
     @Test
     @DisplayName("handleMessage with blank controllerId skips processing")
     void handleMessage_blankControllerId_skipsProcessing() throws Exception {
-        String json = "{\"controller_id\":\"\",\"fleet_id\":\"FLEET_001\",\"status\":\"online\"}";
+        String json = "{\"controller_id\":\"\",\"status\":\"online\"}";
 
         mqttStatusConsumer.handleMessage("+/status", json);
 
-        verify(valueOperations, never()).set(anyString(), anyString());
+        verify(hashOperations, never()).putAll(anyString(), any());
     }
 
     @Test
-    @DisplayName("handleMessage with null fleetId skips processing")
-    void handleMessage_nullFleetId_skipsProcessing() throws Exception {
-        JSONObject payload = new JSONObject();
-        payload.put("controller_id", "CTRL_001");
-        payload.put("fleet_id", null);
-        payload.put("status", "online");
+    @DisplayName("handleMessage without fleetId still processes normally")
+    void handleMessage_withoutFleetId_stillProcesses() throws Exception {
+        String json = "{\"controller_id\":\"CTRL_001\",\"status\":\"online\"}";
 
-        mqttStatusConsumer.handleMessage("+/status", payload.toJSONString());
+        mqttStatusConsumer.handleMessage("+/status", json);
 
-        verify(valueOperations, never()).set(anyString(), anyString());
+        verify(hashOperations).putAll(eq("status_CTRL_001"), any());
     }
 
     @Test
     @DisplayName("handleMessage with blank status skips processing")
     void handleMessage_blankStatus_skipsProcessing() throws Exception {
-        String json = "{\"controller_id\":\"CTRL_001\",\"fleet_id\":\"FLEET_001\",\"status\":\"   \"}";
+        String json = "{\"controller_id\":\"CTRL_001\",\"status\":\"   \"}";
 
         mqttStatusConsumer.handleMessage("+/status", json);
 
-        verify(valueOperations, never()).set(anyString(), anyString());
+        verify(hashOperations, never()).putAll(anyString(), any());
     }
 }