超级表传输

iot-platform/pom.xml

@@ -198,7 +198,7 @@
                         </configuration>
                     </execution>
                 </executions>
-            </plugin>
+            </plugin><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><configuration><source>8</source><target>8</target></configuration></plugin>
         </plugins>
         <finalName>${project.artifactId}</finalName>
     </build>

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

@@ -73,6 +73,6 @@ public class MqttChargeStationConsumer extends AbstractDynamicMqttConsumer {
         String superTable = topicParts[3];
         LocalDate date = LocalDate.now();
         String tableName = superTable + "_" + date.getYear() + String.format("%02d", date.getMonthValue());
-        tdengineService.insertBatch(dbName, tableName, batchToInsert);
+        tdengineService.insertBatch(dbName, superTable,tableName, batchToInsert);
     }
 }

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

@@ -110,7 +110,7 @@ public class MqttDynamicConsumer extends AbstractDynamicMqttConsumer {
         String tableName = ctx.superTable + "_" + date.getYear() + String.format("%02d", date.getMonthValue());
 
         List<Map<String, Object>> batch = Collections.singletonList(data);
-        tdengineService.insertBatch(ctx.dbName, tableName, batch);
+        tdengineService.insertBatch(ctx.dbName, ctx.superTable,tableName, batch);
     }
 
     private void writeToRedis(MessageContext ctx) {

iot-platform/src/main/java/com/iot/platform/service/TdEngineAlarm.java

@@ -43,6 +43,7 @@ public class TdEngineAlarm {
      * 记录告警数据到 TdEngine 时序数据库
      */
     public void recordFailure(Map<String, Object> data, String superTableName, String table) throws SQLException {
+
         validateNames(superTableName, table);
 
         List<String> validKeys = data.keySet().stream()

iot-platform/src/main/java/com/iot/platform/service/TdEngineService.java

@@ -225,7 +225,7 @@ public class TdEngineService {
     // ==========================================
     // 批量插入（按列存储）
     // ==========================================
-    public void insertBatch(String dbName, String table, List<Map<String, Object>> dataList)
+    public void insertBatch(String dbName, String superTable,String table, List<Map<String, Object>> dataList)
             throws SQLException {
 
         if (dataList == null || dataList.isEmpty()) {
@@ -233,12 +233,12 @@ public class TdEngineService {
             return;
         }
 
-        String superTableName = extractSuperTableName(table);
+//        String superTableName = extractSuperTableName(table);
 
         int batchSize = DEFAULT_BATCH_SIZE;
         for (int i = 0; i < dataList.size(); i += batchSize) {
             List<Map<String, Object>> batch = dataList.subList(i, Math.min(i + batchSize, dataList.size()));
-            insertBatchInternal(dbName, superTableName, table, batch);
+            insertBatchInternal(dbName, superTable, table, batch);
         }
 
         log.info("批量写入成功: {} | 条数: {}", table, dataList.size());

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

@@ -101,7 +101,7 @@ class MqttChargeStationConsumerTest {
 
         method.invoke(consumer, dataList, topic);
 
-        verify(tdengineService).insertBatch(eq("myDb"), eq(expectedTable), anyList());
+        verify(tdengineService).insertBatch(eq("myDb"), "mySuperTable_",eq(expectedTable), anyList());
     }
 
     @Test
@@ -113,7 +113,7 @@ class MqttChargeStationConsumerTest {
 
         method.invoke(consumer, Collections.emptyList(), "prefix/db/suffix/table/extra");
 
-        verify(tdengineService, never()).insertBatch(anyString(), anyString(), anyList());
+        verify(tdengineService, never()).insertBatch(anyString(), "mySuperTable_",anyString(), anyList());
     }
 
     @Test
@@ -151,6 +151,6 @@ class MqttChargeStationConsumerTest {
 
         method.invoke(consumer, dataList, topic);
 
-        verify(tdengineService).insertBatch(eq("myDb"), eq(expectedTable), argThat(list -> list.size() == 1));
+        verify(tdengineService).insertBatch(eq("myDb"), "mySuperTable_",eq(expectedTable), argThat(list -> list.size() == 1));
     }
 }

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

@@ -305,8 +305,8 @@ class TDengineServiceTest {
     @Test
     @DisplayName("insertBatch: 空列表应直接返回不抛异常")
     void insertBatch_emptyList_returnsWithoutError() throws Exception {
-        tdengineService.insertBatch("db", "table", Collections.emptyList());
-        tdengineService.insertBatch("db", "table", null);
+        tdengineService.insertBatch("db", "supertable","table", Collections.emptyList());
+        tdengineService.insertBatch("db", "supertable","table", null);
     }
 
     @Test