huangyicao/banban
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: use device id for mqtt parent message

Browse Source
This commit is contained in:
stu2not
2026-05-09 16:54:27 +08:00
parent b611c2aca9
commit 3fe495096a
2 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
talkingq-url/config.py
View File

@@ -68,10 +68,6 @@ class Settings(BaseSettings):
talkingq_mqtt_qos: int = Field(default=1, validation_alias="TALKINGQ_MQTT_QOS")
talkingq_mqtt_keepalive: int = Field(default=60, validation_alias="TALKINGQ_MQTT_KEEPALIVE")
talkingq_mqtt_nfc_notice_interval: int = Field(default=600, validation_alias="TALKINGQ_MQTT_NFC_NOTICE_INTERVAL")
talkingq_parent_message_uuid: str = Field(
default="TalkingQ_xxx",
validation_alias="TALKINGQ_PARENT_MESSAGE_UUID",
)
admin_api_key: str = Field(default="", validation_alias="ADMIN_API_KEY")
client_api_key: str = Field(default="", validation_alias="CLIENT_API_KEY")

6
talkingq-url/handlers/mqtt_handler.py
View File

@@ -337,14 +337,14 @@ class TalkingQMQTTService:
params = payload.get("params", {})
nfc_uuid = str(params.get("uuid") or "").strip()
logger.info(device_id, "", f"[短按留言] 设备 {device_id} 短按发送留言, UUID={nfc_uuid}")
if nfc_uuid == settings.talkingq_parent_message_uuid:
if nfc_uuid == device_id:
await device_target_cache.set_parent_target(device_id, nfc_uuid)
response_payload = {
"msg_id": "011",
"status": "success",
"type": 0,
"params": {
"url": "http://101.35.224.118:8080/assets/audio/message_ok.mp3"
"url": "http://101.35.224.118:8080/assets/audio/parent_online_zh.mp3"
},
}
await self._publish(f"device/{device_id}/event_resp", response_payload)
@@ -371,7 +371,7 @@ class TalkingQMQTTService:
"status": "success",
"type": 0,
"params": {
"url": "http://101.35.224.118:8080/assets/audio/message_ok.mp3"
"url": "http://101.35.224.118:8080/assets/audio/parent_online_zh.mp3"
},
},
)