Merge remote-tracking branch 'origin/mqy20260511'

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

@@ -44,6 +44,9 @@ public class TdEngineService {
     // 默认批量大小
     private static final int DEFAULT_BATCH_SIZE = 50;
 
+    // 每批次最大列数（防止 TDengine 行超限）
+    private static final int MAX_COLUMNS_PER_INSERT = 100;
+
     // 默认 VARCHAR 字段长度限制
     private static final int DEFAULT_VARCHAR_LENGTH = 255;
 
@@ -420,7 +423,32 @@ public class TdEngineService {
 
         try (Connection conn = getConnection(); Statement stmt = conn.createStatement()) {
             stmt.setQueryTimeout(30);
-            stmt.executeUpdate(sql);
+
+            // 如果列数过多，拆分成多个 INSERT
+            int totalCols = columnTypes.size();
+            if (totalCols > MAX_COLUMNS_PER_INSERT) {
+                log.warn("列数({})超过单次插入限制({})，开始拆分插入", totalCols, MAX_COLUMNS_PER_INSERT);
+                List<String> allColumns = new ArrayList<>(columnTypes.keySet());
+                int insertedCount = 0;
+                for (int i = 0; i < allColumns.size(); i += MAX_COLUMNS_PER_INSERT) {
+                    int end = Math.min(i + MAX_COLUMNS_PER_INSERT, allColumns.size());
+                    List<String> batchCols = allColumns.subList(i, end);
+
+                    Map<String, String> subColumnTypes = new LinkedHashMap<>();
+                    for (String col : batchCols) {
+                        subColumnTypes.put(col, columnTypes.get(col));
+                    }
+
+                    String subSql = buildInsertSql(dbName, table, superTableName, subColumnTypes, dataList);
+                    if (subSql != null) {
+                        stmt.executeUpdate(subSql);
+                        insertedCount += dataList.size();
+                    }
+                }
+                log.info("拆分插入完成 | 总列数: {} | 拆分批次数: {} | 插入行数: {}", totalCols, (totalCols + MAX_COLUMNS_PER_INSERT - 1) / MAX_COLUMNS_PER_INSERT, insertedCount);
+            } else {
+                stmt.executeUpdate(sql);
+            }
         } catch (SQLException e) {
             if (!isRetry && e.getMessage().contains("Table does not exist")) {
                 log.warn("表不存在，重建并重试: {}", table);