From ba387a493bcf2751274d344fdbb9ec97f8c29365 Mon Sep 17 00:00:00 2001
From: Timer <@>
Date: Sat, 7 Mar 2026 23:43:49 +0800
Subject: [PATCH] =?UTF-8?q?=E5=9C=BA=E5=A4=96=E7=82=B9=E4=BD=8D=EF=BC=88?=
 =?UTF-8?q?=E5=AE=9A=E5=88=B6=E5=8C=96=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/sipai/service/mqtt/impl/MqttServiceImpl.java | 8 ++++++--
 1 file changed, 6 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 a0df572..0baf699 100644
--- a/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java
+++ b/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java
@@ -149,11 +149,15 @@ public class MqttServiceImpl implements MqttService {
                 // 处理ES数据
                 MPointES esPoint = buildEsPoint(mPoint, value, date);
                 redisList.add(esPoint);
-
+                String tableName = "tb_mp_" + key;
+                if ("SSLL".equals(key) || "LJLL".equals(key)) {
+                    // 场外点位（定制化）
+                    tableName = "tb_mp_" + device + "_" + key;
+                }
                 MPointHistory mPointHistory = new MPointHistory();
                 mPointHistory.setMeasuredt(date);
                 mPointHistory.setParmvalue(value);
-                mPointHistory.setTbName("tb_mp_" + device + "_" + key);
+                mPointHistory.setTbName(tableName);
                 mPointHistory.setUserid(deviceName);
                 mPointHistory.setInsdt(new Date());
                 insertInsert(mPointHistory);