From 567c40e962e3377f045fd025494789703e0ab4f8 Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Tue, 2 Apr 2024 10:19:17 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E5=AE=8C=E5=96=84mqtt=E8=8E=B7?=
 =?UTF-8?q?=E5=8F=96=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/mqtt/client.py | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/apps/mqtt/client.py b/apps/mqtt/client.py
index 60673dbb..c1bf6b96 100644
--- a/apps/mqtt/client.py
+++ b/apps/mqtt/client.py
@@ -6,6 +6,7 @@ import logging
 import json
 from django.conf import settings
 import traceback
+from apps.enm.services import insert_mplogx_from_king_realdata
 
 BASE_DIR = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 sys.path.insert(0, BASE_DIR)
@@ -25,12 +26,10 @@ def on_connect(mqttc, userdata, flags, rc, properties):
         _logger.error('Mqtt Bad connection. Code:', rc)
 
 def on_message(mqttc: mqtt, userdata, msg):
-    print(f'Received message on topic: {msg.topic} with payload: {msg.payload}')
     topic = msg.topic
-    payload = json.loads(msg.payload)
     if topic == 'datachange_S_KIO_Project':
-        print(payload)
-        mqttc.publish('testtopic', 'ok')
+        payload = json.loads(msg.payload)
+        insert_mplogx_from_king_realdata(payload, settings.KING_MQTT_OFFSET)
 
 def start_mqtt():
     if settings.MQTT_ENABLED: