1

api/middleware/mqtt/mqttDispatcher.js

@@ -192,7 +192,7 @@ class MqttDispatcher {
                 heartbeatData = JSON.parse(message);
             }
 
-            const { sn_code, timestamp, status, memory, platform_status, platform_login_status } = heartbeatData;
+            const { sn_code, timestamp, status, memory, platform_status, platform_login_status,clientId } = heartbeatData;
 
             if (!sn_code) {
                 console.warn('[MQTT心跳] 心跳消息中未找到设备SN码');
@@ -232,6 +232,7 @@ class MqttDispatcher {
                 loggedInUsername = platform_login_status.username || '';
                 loggedInUserId = platform_login_status.user_id || null;
              
+
                 if (platform_login_status.timestamp) {
                     loginTime = new Date(platform_login_status.timestamp);
                 }
@@ -270,6 +271,7 @@ class MqttDispatcher {
                 // 创建新设备记录
                 await device_status.create({
                     sn_code,
+                    device_id: clientId,
                     deviceName: `设备_${sn_code}`,
                     deviceType: 'node_mqtt_client',
                     ...updateData,