From 0af4b65fbbee1cf5594842f6f682fdbc11813db9 Mon Sep 17 00:00:00 2001
From: xianfx <xianfx@pxing.com>
Date: Wed, 13 Mar 2024 23:48:21 +0800
Subject: [PATCH] =?UTF-8?q?chore:=20mqtt=20=E6=8C=81=E7=BB=AD=E8=AE=A2?=
 =?UTF-8?q?=E9=98=85=E6=95=B0=E6=8D=AE=E4=BE=8B=E5=AD=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/counter/tests.py | 41 +++++++++++++++++++++++++++++++++++++----
 1 file changed, 37 insertions(+), 4 deletions(-)

diff --git a/apps/counter/tests.py b/apps/counter/tests.py
index 6a8989a..2d03cd6 100644
--- a/apps/counter/tests.py
+++ b/apps/counter/tests.py
@@ -1,5 +1,38 @@
-import paho.mqtt.subscribe as subscribe
+import paho.mqtt.client as mqtt
 
-topic = f'solarmosquitolamp/devices/861959064988699/state'
-msg = subscribe.simple(topic, hostname='8.217.112.255', port=1883)
-print("%s %s" % (msg.topic, msg.payload))
+# MQTT 配置
+MQTT_BROKER = "8.217.112.255"
+MQTT_PORT = 1883
+
+
+# 当我们从MQTT服务器接收到消息时调用此函数
+def on_message(client, userdata, message):
+    # 提取消息的主题
+    topic = message.topic
+    print(f"Message received on topic: {topic}")
+
+    # 从主题中解析 device_id
+    # 假定主题格式为: "solarmosquitolamp/devices/{device_id}/data" 或 "state"
+    topic_parts = topic.split('/')
+    device_id = topic_parts[2]
+
+    # 将消息打印到控制台（或处理数据，例如存入数据库）
+    print(f"Device ID: {device_id}")
+    payload = message.payload.decode('utf-8')
+    print(f"Message Payload: {payload}")
+
+    # 根据device_id和payload处理数据库的记录...
+
+
+# 初始化MQTT客户端
+client = mqtt.Client()
+client.on_message = on_message
+
+client.connect(MQTT_BROKER, MQTT_PORT, 60)
+
+# 订阅所有设备的主题
+client.subscribe("solarmosquitolamp/devices/+/data")
+client.subscribe("solarmosquitolamp/devices/+/state")
+
+# 开始MQTT客户端
+client.loop_forever()