From c3a6ba2467b3afdedfb7418344110e0f96ec96a5 Mon Sep 17 00:00:00 2001
From: Timer <@>
Date: Thu, 12 Mar 2026 00:48:28 +0800
Subject: [PATCH] getAsyncMqttHandle

---
 .../service/mqtt/impl/MqttServiceImpl.java      | 17 +++++++++--------
 1 file changed, 9 insertions(+), 8 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 0baf699..3ea2345 100644
--- a/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java
+++ b/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java
@@ -126,34 +126,35 @@ public class MqttServiceImpl implements MqttService {
             String deviceName = deviceEnum == null ? device : deviceEnum.getDeviceName();
             // 遍历数据条目
             for (String key : data.keySet()) {
-                System.out.println("key=" + key + " value=" + data.getString(key));
                 String valueStr = data.getString(key);
+                System.out.println("源 key=" + key + " value=" + data.getString(key));
                 // 过滤无效值
                 if (!isValidValue(valueStr)) {
-                    loggger.warn("值无效，跳过: key={} raw={} @{}", key, valueStr, date);
+                    loggger.warn("值无效，跳过:源 key={} raw={} @{}", key, valueStr, date);
                     continue;
                 }
+                if ("SSLL".equals(key) || "LJLL".equals(key)) {
+                    // 场外点位（定制化）
+                    key = device + "_" + key;
+                }
+                System.out.println("标准 key=" + key + " value=" + data.getString(key));
                 // 获取点位信息
                 MPoint mPoint = getMPointCacheOrES(bizId, key);
                 if (mPoint == null) {
                     boolean inNotFound = notFoundKeys.contains(key);
-                    loggger.warn("点位不存在，跳过: key={} notFoundCache={} @{}", key, inNotFound, date);
+                    loggger.warn("点位不存在，跳过:标准  key={} notFoundCache={} @{}", key, inNotFound, date);
                     continue;
                 }
                 // 处理数值转换、倍率计算、取反操作、推报警信息、发送Kafka消息
                 BigDecimal value = handleValueConversion(bizId, valueStr, key, date, vueList);
                 if (value == null) {
-                    loggger.warn("数值转换失败，跳过: key={} raw={} @{}", key, valueStr, date);
+                    loggger.warn("数值转换失败，跳过:标准  key={} raw={} @{}", key, valueStr, date);
                     continue;
                 }
                 // 处理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);