From 464b7e1a0fc7931c9010510d1fdbd336e19a5396 Mon Sep 17 00:00:00 2001
From: Timer <@>
Date: Tue, 24 Mar 2026 20:14:39 +0800
Subject: [PATCH] selectByMPointID/Code

---
 .../java/com/sipai/service/mqtt/impl/MqttServiceImpl.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java b/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java
index c8edece..cbc5abc 100644
--- a/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java
+++ b/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java
@@ -138,7 +138,7 @@ public class MqttServiceImpl implements MqttService {
                     key = device + "_" + key;
                 }
                 System.out.println("标准 key=" + key + " value=" + data.getString(key));
-                // 获取点位信息
+                // 获取点位信息 通过MPointID
                 MPoint mPoint = getMPointCacheOrES(bizId, key);
                 if (mPoint == null) {
                     boolean inNotFound = notFoundKeys.contains(key);
@@ -154,7 +154,7 @@ public class MqttServiceImpl implements MqttService {
                 // 处理ES数据
                 MPointES esPoint = buildEsPoint(mPoint, value, date);
                 redisList.add(esPoint);
-                String tableName = "tb_mp_" + key;
+                String tableName = "tb_mp_" + mPoint.getMpointcode(); // 建表使用code，确保表名唯一
                 MPointHistory mPointHistory = new MPointHistory();
                 mPointHistory.setMeasuredt(date);
                 mPointHistory.setParmvalue(value);