# -*- coding: utf-8 -*-
# cython: language_level=3
import json
import paho.mqtt.client as mqtt

# 创建MQTT客户端
client = mqtt.Client(protocol=mqtt.MQTTv311)

# 连接服务器
broker_address = "139.159.185.67"
port = 1881
client.connect(broker_address, port)

# 发布消息
topic = "/maintain/room/master/client/"
message = {
    "data": {
        "roomBindData": {
            "alias": "1111",
            "appToken": "AND-HW-P1OK",
            "cnum": "27981f71989f8ce04e0f74d577ce8b72",
            "companyNumber": "CN-HW-V3LR",
            "conferenceId": 108,
            "conferenceNumber": "27981f71989f8ce04e0f74d577ce8b72",
            "roomName": "C1120",
            "serverUrl": "http://139.159.185.67:8998"
        },
        "attendants": {
            "isCanSign": True,
            "mid": "2024-0921052238733",
            "name": "于治-普通用户2",
            "uid": "122626"
        }
    },
    "action": "attendantCloseAllDevices",
    "device_udid": "ef43f26aead65ec1f230fdd5e5f5c367ee3f23306171f3cfdc9f97b90fe9b5f4"
}
client.publish(topic, json.dumps(message), qos=0)

# 断开连接
client.disconnect()