Merge branch 'mqy20260511' of http://114.215.146.132:3000/Mqy/Wisdom-Data into mqy20260511

.env

+# IoT 平台环境变量配置
+# 启动前自动加载：./start.sh start
+# 或手动加载：source .env
+
+# MySQL 数据库（主从共用）
+MYSQL_USERNAME=root
+MYSQL_PASSWORD="Zhu059300()__"
+
+# Redis
+REDIS_PASSWORD=
+
+# MQTT Broker
+MQTT_USERNAME=NjniyrEO
+MQTT_PASSWORD=2b577892f4824d466dbc323a1ee4dfe1902c55bb
+
+# TDengine 时序数据库
+TDENGINE_USERNAME=root
+TDENGINE_PASSWORD=taosdata
+
+# Druid 监控（生产环境建议设为 false 关闭）
+DRUID_STAT_ENABLED=true
+DRUID_USERNAME=ruoyi
+DRUID_PASSWORD=123456
+REDIS_HOST=172.21.185.173

.gitignore

 .claude/
 
 # Environment variables
-.env
+# .env is now tracked in git per user request
+# .env
 !.env.example

CLAUDE.md

 - **Backend**: Spring Boot 2.5.15, Java 8, Spring Security 5.7.12, JWT authentication
 - **Frontend**: Vue 2 + Element UI (separate repository, not in this workspace)
 - **Database**: MySQL 8 (dual datasource via Druid), TDengine 3.x for time-series
-- **Cache**: Redis (localhost:6379)
+- **Cache**: Redis (`${REDIS_HOST:localhost}:6379`)
 - **Message Broker**: MQTT (EMQX on 47.104.204.180:1883)
 
 ## Build & Run Commands
 ### TDengine (Time-Series Database)
 - Used for high-frequency IoT telemetry ingestion
 - Connection pool: HikariCP via `TDengineService`
-- Connects to `jdbc:TAOS://127.0.0.1:6031/`
+- Connects to `jdbc:TAOS://172.21.185.173:6031/` (host network, via host IP)
 - Super-table pattern with column caching (`stableColumnCache`)
 
 ### Redis
-- Host: `localhost:6379`
+- 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
 MYSQL_USERNAME=root
 MYSQL_PASSWORD="..."
 REDIS_PASSWORD=
+REDIS_HOST=172.21.185.173
 MQTT_USERNAME=...
 MQTT_PASSWORD=...
 TDENGINE_USERNAME=root

deploy/.env

+# IoT 平台环境变量配置
+# 启动前自动加载：./start.sh start
+# 或手动加载：source .env
+
+# MySQL 数据库（主从共用）
+MYSQL_USERNAME=root
+MYSQL_PASSWORD="Zhu059300()__"
+
+# Redis
+REDIS_PASSWORD=
+
+# MQTT Broker
+MQTT_USERNAME=NjniyrEO
+MQTT_PASSWORD=2b577892f4824d466dbc323a1ee4dfe1902c55bb
+
+# TDengine 时序数据库
+TDENGINE_USERNAME=root
+TDENGINE_PASSWORD=taosdata
+
+# Druid 监控（生产环境建议设为 false 关闭）
+DRUID_STAT_ENABLED=true
+DRUID_USERNAME=ruoyi
+DRUID_PASSWORD=123456
+REDIS_HOST=172.21.185.173

deploy/Dockerfile

+FROM tdengine/tdengine:3.3.6.13
+
+ENV DEBIAN_FRONTEND=noninteractive
+RUN apt-get update && apt-get install -y --no-install-recommends openjdk-8-jre-headless && rm -rf /var/lib/apt/lists/*
+
+WORKDIR /opt/iot-platform
+
+COPY iot-platform.jar .
+COPY .env .
+COPY start-container.sh .
+RUN chmod +x start-container.sh
+
+EXPOSE 8887
+
+ENTRYPOINT ["./start-container.sh"]

deploy/README.md

 
 ## 概述
 
-本项目使用 Podman 容器化部署，通过 `deploy.sh` 脚本实现一键构建、上传、构建镜像、健康检查和自动回滚。
+本项目使用 Podman 容器化部署，通过 `deploy.sh` 脚本实现一键构建、上传、构建镜像、健康检查。
 
 ## 服务器环境
 
 - **OS**: Alibaba Cloud Linux 3
 - **容器运行时**: Podman 4.9.4 (docker 兼容)
 - **Java**: OpenJDK 1.8 (容器内)
-- **安装目录**: `/opt/iot-platform/`
+- **安装目录**: `/mnt/iot-platform/`（兼容软链接 `/opt/iot-platform`）
 - **容器名称**: `iot-platform`
 
 ## 目录结构
 
 ```
-/opt/iot-platform/
+/mnt/iot-platform/
 ├── iot-platform.jar          # 当前运行版本
 ├── Dockerfile                # 容器镜像构建定义
 ├── start-container.sh        # 容器启动脚本（加载 .env）
 └── logs/                     # 日志输出（宿主机挂载）
 ```
 
+## 容器架构
+
+| 容器 | 网络模式 | 端口映射 | 数据持久化 |
+|------|---------|---------|-----------|
+| `tdengine-operator` | host | 6031, 6041 | `/mnt/tdengine-operator/data` |
+| `taos-explorer` | bridge | `127.0.0.1:6060->6060` | `/mnt/taos-explorer-data` |
+| `iot-platform` | bridge | `0.0.0.0:8887->8887` | `/mnt/iot-platform/logs` |
+
 ## 快速开始
 
 ### 首次部署（服务器初始化）
 
-确保服务器上已有 `/opt/iot-platform/` 目录，并包含 `Dockerfile`、`.env`、`start-container.sh`：
+确保服务器上已有 `/mnt/iot-platform/` 目录，并包含 `Dockerfile`、`.env`、`start-container.sh`：
 
 ```bash
 # 从本地同步必要文件到服务器
-scp deploy/setup-server.sh root@47.104.204.180:/opt/iot-platform/
-scp .env root@47.104.204.180:/opt/iot-platform/
-scp Dockerfile root@47.104.204.180:/opt/iot-platform/
-scp start-container.sh root@47.104.204.180:/opt/iot-platform/
-ssh root@47.104.204.180 "chmod +x /opt/iot-platform/start-container.sh"
+scp deploy/setup-server.sh root@47.104.204.180:/mnt/iot-platform/
+scp .env root@47.104.204.180:/mnt/iot-platform/
+scp deploy/Dockerfile root@47.104.204.180:/mnt/iot-platform/
+scp deploy/start-container.sh root@47.104.204.180:/mnt/iot-platform/
+ssh root@47.104.204.180 "chmod +x /mnt/iot-platform/start-container.sh"
 ```
 
 然后执行首次部署：
 
 流程：
 1. 本地执行 `mvn clean package`
-2. 上传 jar 到服务器
+2. 上传 jar 到服务器 `/mnt/iot-platform/`
 3. 备份当前版本（带时间戳）
 4. 停止并删除旧容器
 5. 替换 jar 并构建新镜像
-6. 启动容器（host 网络模式）
+6. 启动容器（bridge 网络模式，端口映射 `8887:8887`）
 7. 健康检查（`/actuator/health`）
-8. 失败则自动回滚到上一个版本
+8. 失败时保留容器用于排查（不再自动回滚）
 
 #### 方式二：指定 jar 部署
 
 
 ## 环境变量
 
-`.env` 文件位于项目根目录和服务器 `/opt/iot-platform/.env`，包含所有敏感凭据：
+`.env` 文件位于项目根目录和服务器 `/mnt/iot-platform/.env`，包含所有环境变量：
 
 ```bash
 # MySQL
 
 # Redis
 REDIS_PASSWORD=
+REDIS_HOST=172.21.185.173
 
 # MQTT
 MQTT_USERNAME=...
 DRUID_PASSWORD=...
 ```
 
-**注意**：`.env` 文件已加入 `.gitignore`，**切勿提交到 Git**。
-
 ## 服务器管理
 
 ```bash
 # 查看容器状态
-podman ps | grep iot-platform
+podman ps
 
 # 查看实时日志
 podman logs -f iot-platform
 podman logs --tail 100 iot-platform
 
 # 查看宿主机上的日志文件（和容器内同步）
-tail -f /opt/iot-platform/logs/iot-platform.$(date +%Y-%m-%d).*.log
+tail -f /mnt/iot-platform/logs/iot-platform.$(date +%Y-%m-%d).*.log
 
 # 停止容器
 podman stop iot-platform
 
 ```bash
 # 在服务器上执行
-bash /opt/iot-platform/bin/health-check.sh localhost 8887 30
+bash /mnt/iot-platform/bin/health-check.sh localhost 8887 30
 
 # 或从本地检查
 curl -s http://47.104.204.180:8887/actuator/health
 
 ## 回滚
 
-如果部署失败，`deploy.sh` 会自动回滚到上一个版本。
-
-手动回滚：
+部署失败时容器会保留用于排查，需手动回滚：
 
 ```bash
 ssh root@47.104.204.180
 podman stop iot-platform && podman rm iot-platform
 
 # 恢复旧版本 jar
-ls /opt/iot-platform/backup/          # 查看可用备份
-cp /opt/iot-platform/backup/iot-platform-XXXX.jar /opt/iot-platform/iot-platform.jar
+ls /mnt/iot-platform/backup/          # 查看可用备份
+cp /mnt/iot-platform/backup/iot-platform-XXXX.jar /mnt/iot-platform/iot-platform.jar
 
 # 重新构建镜像并启动
-cd /opt/iot-platform && podman build -t iot-platform:latest .
+cd /mnt/iot-platform && podman build -t iot-platform:latest .
 podman run -d \
     --name iot-platform \
-    --network host \
+    --network bridge \
     --restart unless-stopped \
-    -v /opt/iot-platform/logs:/opt/iot-platform/logs \
+    -p 8887:8887 \
+    -v /mnt/iot-platform/logs:/opt/iot-platform/logs \
     localhost/iot-platform:latest
 ```
 
 | `Dockerfile` | 容器镜像构建定义 |
 | `start-container.sh` | 容器内启动脚本（加载 .env） |
 | `iot-platform.service` | systemd 服务定义（已废弃，保留备用） |
+| `config/taos.cfg` | TDengine 服务端配置 |
+| `config/explorer.toml` | taos-explorer 配置 |
+| `config/tdengine-explorer.conf` | nginx 代理配置 |

deploy/config/explorer.toml

+# This is a automacically generated configuration file for Explorer in [TOML](https://toml.io/) format.
+#
+# Here is a full list of available options.
+
+# Explorer server port to listen on.
+# Default is 6060.
+#
+port = 6060
+
+# IPv4 listen address.
+# Default is 0.0.0.0
+addr = "0.0.0.0"
+
+# IPv6 listen address.
+
+# ipv6 = "::1"
+
+# explorer server instance id
+# 
+# The instanceId of each instance is unique on the host
+# instanceId = 1
+
+# Explorer server log level.
+# Default is "info"
+# 
+# Deprecated: use log.level instead
+log_level = "info"
+
+# All data files are stored in this directory
+# data_dir = "/var/lib/taos/explorer" # Default for Linux
+# data_dir = "C:\\TDengine\\data\\explorer" # Default for Windows
+
+# REST API endpoint to connect to the cluster.
+# This configuration is also the target for data migration tasks.
+# 
+# Default is "http://localhost:6041" - the default endpoint for REST API.
+#
+cluster = "http://172.21.185.173:6041"
+
+# native endpoint to connect to the cluster.
+# Default is disabled. To enable it, set it to the native API URL like "taos://localhost:6030" and uncomment it.
+# If you enable it, you will get more performance for data migration tasks.
+# If modify this config item, you must relogin to clear the cache in browser local storage.
+#
+# cluster_native = "taos://localhost:6030"
+
+# API endpoint for data replication/backup/data sources. No default option.
+#   Set it to API URL like "http://localhost:6050".
+#
+x_api = "http://localhost:6050"
+
+# Please set it to same as the "grpc" parameter used by taosX Service; 
+# If "grpc" parameter is not set explicitly in taosX service, please set it to the default grpc address of taosX
+grpc = "http://localhost:6055"
+
+# CORS configuration switch, it allows cross-origin access
+cors = true
+
+# cloud open api.
+# cloud_open_api = "https://pre.ali.cloud.taosdata.com/openapi"
+
+# Enable ssl
+# If the following two files exist, enable ssl protocol
+#
+[ssl]
+
+# SSL certificate
+#
+# certificate = "/path/to/ca.file" # on linux/macOS
+# certificate = "C:\\path\\to\\ca.file" # on windows
+
+# SSL certificate key
+#
+# certificate_key = "/path/to/key.file" # on linux/macOS
+# certificate_key = "C:\\path\\to\\key.file" # on windows
+
+# log configuration
+[log]
+# All log files are stored in this directory
+# 
+# path = "/var/log/taos" # on linux/macOS
+# path = "C:\\TDengine\\log" # on windows
+
+# log filter level
+#
+# level = "info"
+
+# Compress archived log files or not
+# 
+# compress = false
+
+# The number of log files retained by the current explorer server instance in the `path` directory
+# 
+# rotationCount = 30
+
+# Rotate when the log file reaches this size
+# 
+# rotationSize = "1GB"
+
+# Log downgrade when the remaining disk space reaches this size, only logging `ERROR` level logs
+# 
+# reservedDiskSize = "1GB"
+
+# The number of days log files are retained
+#
+# keepDays = 30
+
+# integrated with Grafana
+[grafana]
+# The token of the Grafana server, which is used to access the Grafana server.
+#token = ""
+
+# The URL of the Grafana dashboard, which is used to display the monitoring data of the TDengine cluster.
+# You can configure multiple Grafana dashboards.
+[grafana.dashboards]
+#TDengine3 = "http://localhost:3000/d/000000001/tdengine3"
+#taosX = "http://localhost:3000/d/000000002/taosx"

deploy/config/taos.cfg

+fqdn 172.21.185.173
+serverPort 6031

deploy/config/tdengine-explorer.conf

+server {
+    listen 172.21.185.173:6060;
+    server_name 47.104.204.180;
+
+    location / {
+        proxy_pass http://127.0.0.1:6060;
+        proxy_set_header Host $host;
+        proxy_set_header X-Real-IP $remote_addr;
+        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
+        proxy_read_timeout 300s;
+
+        proxy_http_version 1.1;
+        proxy_set_header Upgrade $http_upgrade;
+        proxy_set_header Connection "upgrade";
+    }
+}

deploy/deploy.sh

 # 配置
 SERVER_HOST="${SERVER_HOST:-47.104.204.180}"
 SERVER_USER="${SERVER_USER:-root}"
-REMOTE_DIR="${REMOTE_DIR:-/opt/iot-platform}"
+REMOTE_DIR="${REMOTE_DIR:-/mnt/iot-platform}"
 APP_NAME="iot-platform"
 LOCAL_JAR=""
 DO_BUILD=false
         cp -a ${REMOTE_DIR}/${APP_NAME}.jar ${REMOTE_DIR}/backup/${BACKUP_NAME}
         echo '  已备份: ${BACKUP_NAME}'
         ls -lh ${REMOTE_DIR}/backup/ | tail -5
+        # 清理旧备份，保留最近 10 个
+        BACKUP_COUNT=\$(ls -1t ${REMOTE_DIR}/backup/${APP_NAME}-*.jar 2>/dev/null | wc -l)
+        if [ "\$BACKUP_COUNT" -gt 10 ]; then
+            ls -1t ${REMOTE_DIR}/backup/${APP_NAME}-*.jar | tail -n +11 | xargs -r rm -f
+            echo "  已清理旧备份，保留最近 10 个"
+        fi
     else
         echo '  无现有版本，跳过备份'
     fi
     echo '  构建镜像...'
     cd ${REMOTE_DIR} && podman build -t ${APP_NAME}:latest . >/dev/null 2>&1
     echo '  镜像构建完成'
+    podman image prune -f >/dev/null 2>&1
+    echo '  已清理 dangling 镜像'
     podman images | grep ${APP_NAME}
 "
 echo -e "${GREEN}[4/6] 镜像构建完成${NC}"
 ssh "${SERVER_USER}@${SERVER_HOST}" "
     podman run -d \
         --name ${APP_NAME} \
-        --network host \
+        --network bridge \
         --restart unless-stopped \
-        -v ${REMOTE_DIR}/logs:/opt/iot-platform/logs \
+        -p 8887:8887 \
+        -v /mnt/iot-platform/logs:/opt/iot-platform/logs \
         localhost/${APP_NAME}:latest >/dev/null 2>&1
 "
 sleep 5
     exit 0
 else
     echo -e "${RED}[6/6] 健康检查失败!${NC}"
-
-    if [ "$NO_ROLLBACK" = true ]; then
-        echo -e "${YELLOW}[no-rollback] 已启用不回滚模式，保留新版本用于排查${NC}"
-        echo -e "${YELLOW}排查命令:${NC}"
-        echo "  ssh ${SERVER_USER}@${SERVER_HOST} 'podman logs -f ${APP_NAME}'"
-        echo "  ssh ${SERVER_USER}@${SERVER_HOST} 'podman ps | grep ${APP_NAME}'"
-        exit 1
-    fi
-
-    echo -e "${YELLOW}[rollback] 执行回滚...${NC}"
-    ssh "${SERVER_USER}@${SERVER_HOST}" "podman stop ${APP_NAME} >/dev/null 2>&1 && podman rm ${APP_NAME} >/dev/null 2>&1 || true"
-
-    if ssh "${SERVER_USER}@${SERVER_HOST}" "test -f ${REMOTE_DIR}/backup/${BACKUP_NAME}"; then
-        echo -e "${YELLOW}[rollback] 恢复旧版本...${NC}"
-        ssh "${SERVER_USER}@${SERVER_HOST}" "
-            cp ${REMOTE_DIR}/backup/${BACKUP_NAME} ${REMOTE_DIR}/${APP_NAME}.jar
-            cd ${REMOTE_DIR} && podman build -t ${APP_NAME}:latest . >/dev/null 2>&1
-            podman run -d \
-                --name ${APP_NAME} \
-                --network host \
-                --restart unless-stopped \
-                -v ${REMOTE_DIR}/logs:/opt/iot-platform/logs \
-                localhost/${APP_NAME}:latest >/dev/null 2>&1
-        "
-        sleep 5
-
-        if ssh "${SERVER_USER}@${SERVER_HOST}" "bash ${REMOTE_DIR}/bin/health-check.sh localhost 8887 60"; then
-            echo -e "${GREEN}[rollback] 回滚成功，旧版本已恢复${NC}"
-        else
-            echo -e "${RED}[rollback] 回滚后健康检查仍失败，请手动排查!${NC}"
-        fi
-    else
-        echo -e "${RED}[rollback] 无备份可回滚，请手动修复!${NC}"
-    fi
-
+    echo -e "${YELLOW}保留容器用于排查，不自动回滚${NC}"
+    echo ""
+    echo "排查命令:"
+    echo "  ssh ${SERVER_USER}@${SERVER_HOST} 'podman logs -f ${APP_NAME}'"
+    echo "  ssh ${SERVER_USER}@${SERVER_HOST} 'podman ps | grep ${APP_NAME}'"
+    echo "  ssh ${SERVER_USER}@${SERVER_HOST} 'curl -s http://localhost:8887/actuator/health'"
     exit 1
 fi

deploy/start-container.sh

+#!/bin/bash
+set -a
+source /opt/iot-platform/.env
+set +a
+
+cd /opt/iot-platform
+exec java -server -Duser.timezone=Asia/Shanghai -Dfile.encoding=UTF-8 -Xms1g -Xmx2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=256m -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=/opt/iot-platform/logs/heapdump.hprof -XX:+UseG1GC -XX:MaxGCPauseMillis=200 -jar iot-platform.jar --spring.profiles.include=online

iot-platform/src/main/java/com/iot/platform/config/IotProperties.java

      * TDengine配置
      */
     public static class TDengine {
-        private String url = "jdbc:TAOS://127.0.0.1:6031/";
+        private String url = "jdbc:TAOS://172.21.185.173:6031/";
         private String username = "";
         private String password = "";
 

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

                            //deviceid_controllerid
         String tableName = superTable + "_" +dbName;
 
-        //拆分出数据库名称
-
-        //拆分出对于看哪个的超级表的名称
-
-        //字表名称公式
-
 //        int i = ((int) "g".getBytes("UTF-8")[0]) % 10;
 
         tdengineService.insertBatch(dbNamePrefix, superTable,tableName, batchToInsert);
     }
-}
+}

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

     // 每批次最大列数（防止 TDengine 行超限）
     private static final int MAX_COLUMNS_PER_INSERT = 100;
 
+    // 拆分超级表的列数阈值
+    private static final int SPLIT_STABLE_COLUMN_THRESHOLD = 100;
+
     // 默认 VARCHAR 字段长度限制
     private static final int DEFAULT_VARCHAR_LENGTH = 128;
 
         return name != null && name.matches(ALLOWED_TABLE_NAME);
     }
 
-    private boolean isNumeric(String str) {
-        if (str == null || str.isEmpty()) {
-            return false;
-        }
-        try {
-            Double.parseDouble(str);
-            return true;
-        } catch (NumberFormatException e) {
-            return false;
-        }
-    }
-
     // === 缓存工具方法 ===
     private String getStableKey(String dbName, String stableName) {
         return dbName + "." + stableName;
     // ==========================================
     // 批量插入（按列存储）
     // ==========================================
-    public void insertBatch(String dbName, String superTable,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()) {
             return;
         }
 
-//        String superTableName = extractSuperTableName(table);
+        Map<String, String> columnTypes = collectColumnTypes(dataList);
 
-        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, superTable, table, batch);
+        // 所有数据都走拆分逻辑：按首字符 UTF-8 值模 10 分组到不同的超级表
+        splitAndInsertToMultipleStables(dbName, superTable, table, dataList, columnTypes);
+
+        log.info("批量写入完成: {} | 条数: {}", table, dataList.size());
+    }
+
+    /**
+     * 根据列 key 首字符的 UTF-8 值拆分到多个超级表
+     */
+    private void splitAndInsertToMultipleStables(String dbName, String baseSuperTable, String baseTable,
+                                                 List<Map<String, Object>> dataList,
+                                                 Map<String, String> columnTypes) throws SQLException {
+        // 按首字符 UTF-8 值分组
+        Map<Integer, Map<String, String>> groupColumnTypes = new LinkedHashMap<>();
+        for (Map.Entry<String, String> entry : columnTypes.entrySet()) {
+            int groupId = getFirstCharGroupId(entry.getKey());
+            groupColumnTypes.computeIfAbsent(groupId, k -> new LinkedHashMap<>()).put(entry.getKey(), entry.getValue());
+        }
+
+        log.info("拆分后超级表数量: {} | 分组: {}", groupColumnTypes.size(), groupColumnTypes.keySet());
+
+        // 每个分组作为一个超级表，处理其对应的列和数据
+        for (Map.Entry<Integer, Map<String, String>> group : groupColumnTypes.entrySet()) {
+            int groupId = group.getKey();
+            String stableName = "device_" + groupId;
+            String tableName = baseTable + "_" + groupId;
+
+            // 筛选出该组列的数据
+            List<Map<String, Object>> filteredData = filterDataByColumnGroup(dataList, group.getValue().keySet());
+
+            // 按普通逻辑插入
+            int batchSize = DEFAULT_BATCH_SIZE;
+            for (int i = 0; i < filteredData.size(); i += batchSize) {
+                List<Map<String, Object>> batch = filteredData.subList(i, Math.min(i + batchSize, filteredData.size()));
+                insertBatchInternal(dbName, stableName, tableName, batch);
+            }
+            log.info("分组插入完成: stable={}, table={}, 列数={}, 数据条数={}",
+                    stableName, tableName, group.getValue().size(), filteredData.size());
         }
+    }
+
+    /**
+     * 获取列名首字符的 UTF-8 值模 10，作为分组 ID
+     */
+    private int getFirstCharGroupId(String columnName) {
+        if (columnName == null || columnName.isEmpty()) {
+            return 0;
+        }
+        String firstChar = columnName.substring(0, 1);
+        byte[] bytes = firstChar.getBytes(java.nio.charset.StandardCharsets.UTF_8);
+        return (int) bytes[0] % 10;
+    }
 
-        log.info("批量写入成功: {} | 条数: {}", table, dataList.size());
+    /**
+     * 筛选出指定列的数据
+     */
+    private List<Map<String, Object>> filterDataByColumnGroup(List<Map<String, Object>> dataList, Set<String> columns) {
+        List<Map<String, Object>> filtered = new ArrayList<>();
+        for (Map<String, Object> data : dataList) {
+            if (data == null) continue;
+            Map<String, Object> filteredRow = new LinkedHashMap<>();
+            for (String col : columns) {
+                if (data.containsKey(col)) {
+                    filteredRow.put(col, data.get(col));
+                }
+            }
+            filtered.add(filteredRow);
+        }
+        return filtered;
     }
 
     private String extractSuperTableName(String table) {

iot-platform/src/main/resources/application.yml

     restart:
       enabled: false
   redis:
-    host: localhost
+    host: ${REDIS_HOST:localhost}
     port: 6379
     database: 0
     password: ${REDIS_PASSWORD:}
     password: ${MQTT_PASSWORD:}
     charge-station-topic: ${MQTT_CHARGE_STATION_TOPIC:station/ChargeStation/device/+/post/json}
   tdengine:
-    url: jdbc:TAOS://127.0.0.1:6031/
+    url: jdbc:TAOS://172.21.185.173:6031/
     username: ${TDENGINE_USERNAME:}
     password: ${TDENGINE_PASSWORD:}