# 匯入所需的函式庫
from machine import Pin      # 從machine模組引入Pin類別
import network               # 引入network模組，用於連接Wi-Fi
import time                  # 引入time模組，用於時間延遲
from umqtt.simple import MQTTClient
import dht                   # 引入dht模組，用於操作DHT22溫濕度傳感器
# asynchronous processing library
import uasyncio as asyncio

# 連接到 Wi-Fi 網絡
sta = network.WLAN(network.STA_IF) # 建立Wi-Fi station(STA)物件
sta.active(True)                   # 啟用Wi-Fi介面
sta.connect('Wokwi-GUEST','')      # 連接到指定的Wi-Fi網絡，請替換成你的Wi-Fi SSID和密碼
print('Linking...')
while not sta.isconnected():       # 等待直到連接成功
    pass
print('Link OK')

# 初始化 DHT22 溫濕度傳感器和連接的引腳
p0 = Pin(13, Pin.IN)               # 創建Pin物件，將GPIO13設為資料腳，給定別名為p0，用於連接DHT22溫濕度傳感器
dht22 = dht.DHT22(p0)              # 創建DHT22物件，並指定並指定使用p0物件來連接DHT22溫溼度傳感器

LED_Temp = Pin(18, Pin.OUT)        # 創建 Pin 物件，指定引腳 18 為輸出引腳，並給定別名為LED_Temp
LED_Hum = Pin(19, Pin.OUT)         # 創建 Pin 物件，指定引腳 19 為輸出引腳，並給定別名為LED_Hum

def handle_callback(topic, msg):
    m = msg.decode("utf-8")
    print('我是m',m)
    if "field2" in topic:  # 溫度資料
        temp = float(m)
        if temp > 35:
            print("溫度過高！")
            LED_Temp.value(1)  # 点亮溫度 LED
        else:
            LED_Temp.value(0)
    elif "field3" in topic:  # 濕度資料
        hum = float(m)
        if hum > 80:
            print("濕度過高！")
            LED_Hum.value(1)  # 点亮濕度 LED
        else:
            LED_Hum.value(0)

# key noi den broker
client_id = "JSEOKS8fBAknNBM4PA0xKzY"
user_name = "JSEOKS8fBAknNBM4PA0xKzY"
password = "6lYlTrEioZr6lSqCg6tgyMyS"
server = "mqtt3.thingspeak.com"

client = MQTTClient(client_id = client_id,
            server = server,
            user = user_name,
            password = password,)

client.set_callback(handle_callback)
client.connect()

client.subscribe(b"channels/2493946/subscribe/fields/+")
publish_topic = b"channels/2493946/publish"

# Task1:Publish data to MQTT broker each 5s
async def task1():
    while True:
        print("Update temperature and humidity!")
        total_temp = 0
        total_hum = 0
        for i in range(8):
            dht22.measure()
            t = dht22.temperature()
            h = dht22.humidity()
            total_temp += t
            total_hum += h
            await asyncio.sleep_ms(1000)  # 等待1秒再取下一筆資料
        avg_temp = total_temp / 8
        avg_hum = total_hum / 8
        payload = f"field2={avg_temp}&field3={avg_hum}&status=MQTTPUBLISH"
        client.publish(publish_topic,payload.encode("utf-8"))
        await asyncio.sleep_ms(5000)

# Task2:0.5s check if any data is sent from MQTT Broker?
async def task2():
    while True:
        client.check_msg()
        await asyncio.sleep_ms(500)

if __name__=="__main__":
    loop = asyncio.get_event_loop()
    loop.create_task(task1())
    loop.create_task(task2())
    loop.run_forever()