from thingscloud_mqtt_lib import ThingsCloudMQTTClient
import time

# 创建客户端
client = ThingsCloudMQTTClient(
    project_key="YOUR_PROJECT_KEY",
    server="YOUR_MQTT_HOST",
    port=1883,
    access_token="YOUR_ACCESS_TOKEN"
)

# 连接到 ThingsCloud
client.connect()

# 上报属性
client.report_attributes({
    "temperature": 25.5,
    "humidity": 60
})

# 保持连接并处理消息
while True:
    client.check_msg()
    time.sleep(1)

from thingscloud_mqtt_lib import ThingsCloudMQTTClient

# 创建客户端（不需要 access_token）
client = ThingsCloudMQTTClient(
    project_key="YOUR_PROJECT_KEY",
    server="YOUR_MQTT_HOST",
    port=1883
)

# 使用一型一密模式连接
# 设备会自动在平台创建并获取 AccessToken
client.connect_with_device_cert(
    device_key="your_device_key",       # 设备唯一标识
    type_key="your_type_key",           # 设备类型标识
    api_endpoint="your_api_endpoint"
)

# 连接成功后即可正常使用
client.report_attributes({"temperature": 25.5})

# 上报单个属性
client.report_attributes({"temperature": 25.5})

# 上报多个属性
client.report_attributes({
    "temperature": 25.5,
    "humidity": 60,
    "status": "online"
})

# 设置上报响应回调（可选）
def on_attributes_response(response):
    if response.get("result") == 1:
        print("上报成功")
    else:
        print("上报失败:", response)

client.on_attributes_response(on_attributes_response)

def on_attributes_push(attributes):
    print("收到下发属性:", attributes)

    # 处理下发的属性
    if "switch" in attributes:
        switch_state = attributes["switch"]
        print(f"设置开关状态: {switch_state}")
        # 执行开关控制逻辑...

    if "report_interval" in attributes:
        interval = attributes["report_interval"]
        print(f"更新上报间隔: {interval}秒")

# 设置属性下发回调
client.on_attributes_push(on_attributes_push)

def on_command(command):
    method = command.get("method")
    params = command.get("params")
    cmd_id = command.get("id")

    print(f"收到命令: {method}, 参数: {params}")

    # 执行命令逻辑...

    # 回复命令
    client.reply_command(method, {"status": "success"}, reply_id=cmd_id)

# 设置命令回调
client.on_command_send(on_command)

# 上报告警事件
client.report_event("alert", {
    "level": "warning",
    "message": "温度过高"
})

import network
import time
from thingscloud_mqtt_lib import ThingsCloudMQTTClient

# WiFi 配置
WIFI_SSID = "your_wifi_ssid"
WIFI_PASSWORD = "your_wifi_password"

# ThingsCloud 配置
PROJECT_KEY = "YOUR_PROJECT_KEY"
MQTT_HOST = "YOUR_MQTT_HOST"
ACCESS_TOKEN = "YOUR_ACCESS_TOKEN"

# 连接 WiFi
def connect_wifi():
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    if not wlan.isconnected():
        print("正在连接 WiFi...")
        wlan.connect(WIFI_SSID, WIFI_PASSWORD)
        while not wlan.isconnected():
            time.sleep(1)
    print("WiFi 已连接:", wlan.ifconfig())

# 属性下发回调
def on_attributes_push(attributes):
    print("收到下发属性:", attributes)

# 命令回调
def on_command(command):
    method = command.get("method")
    params = command.get("params")
    cmd_id = command.get("id")
    print(f"收到命令: {method}, 参数: {params}")
    # 回复命令
    client.reply_command(method, {"status": "success"}, reply_id=cmd_id)

# 主程序
def main():
    # 连接 WiFi
    connect_wifi()

    # 创建 MQTT 客户端
    global client
    client = ThingsCloudMQTTClient(
        project_key=PROJECT_KEY,
        server=MQTT_HOST,
        port=1883,
        access_token=ACCESS_TOKEN
    )

    # 设置回调
    client.on_attributes_push(on_attributes_push)
    client.on_command_send(on_command)

    # 连接到 ThingsCloud
    client.connect()
    print("已连接到 ThingsCloud")

    # 主循环
    while True:
        # 模拟读取传感器数据
        temperature = 25.5  # 实际使用时替换为传感器读取代码
        humidity = 60.0

        # 上报属性
        client.report_attributes({
            "temperature": temperature,
            "humidity": humidity
        })
        print(f"已上报: 温度={temperature}°C, 湿度={humidity}%")

        # 等待并检查消息
        for _ in range(10):  # 每 10 秒上报一次
            client.check_msg()
            time.sleep(1)

if __name__ == "__main__":
    main()

client = ThingsCloudMQTTClient(
    project_key,      # 项目 ProjectKey（必需）
    server,           # MQTT 服务器地址（必需）
    port=1883,        # 端口号
    access_token=None # 设备 AccessToken（可选，用于一型一密模式）
)