【Python】如何写一个锅炉温控系统

Python学习交流Q群：906715085###
  隐藏代码
from machine import Pin,reset
import onewire
from ds18x20 import DS18X20
import time
import tm1637
from umqtt.simple import MQTTClient

def main():
    client_id = "esp_temperature"
    mserver = "192.168.0.99"
    #mserver = "192.168.3.200"
    #mserver = "mq.tongxinmao.com"

    tm = tm1637.TM1637(clk=Pin(14), dio=Pin(12))
    ow=onewire.OneWire(Pin(4))
    d = DS18X20(ow)
    rom = d.scan()

    def sub_callback(topic, msg):
        # print((topic, msg))
        nonlocal setTemperature
        nonlocal lowTemperature
        nonlocal startTime
        nonlocal scanTime
        nonlocal step

        nonlocal startTimeTemp
        nonlocal scanTimeTemp
        nonlocal switchStatus

        data = int(msg.decode())
        if topic == b"setTemperature":
            setTemperature = data
        elif topic == b"setLowTemperature":
            lowTemperature = data
        elif topic == b"setStartTime":
            startTime = data
            startTimeTemp = startTime

        elif topic == b"setScanTime":
            scanTime = data*60
            scanTimeTemp = scanTime

        elif topic == b"setStep":
            step = data
        elif topic == b"switchWell":
            switchStatus = data
        else:
            print("错误")

    def publishInfo():
        nonlocal client
        client.publish("setTemperatureR",str(setTemperature),retain=True)
        client.publish("setLowTemperatureR",str(lowTemperature),retain=True)
        client.publish("setStartTimeR",str(startTime),retain=True)
        client.publish("setScanTimeR",str(int(scanTime/60)),retain=True)
        client.publish("setStepR",str(step),retain=True)

    client = MQTTClient(client_id, mserver, 0)
    client.set_callback(sub_callback)
    client.connect()
    client.subscribe(b"setTemperature")
    client.subscribe(b"setLowTemperature")
    client.subscribe(b"setStartTime")
    client.subscribe(b"setScanTime")
    client.subscribe(b"setStep")
    client.subscribe(b"switchWell")

    showSet = True
    setTemperature = 40
    lowTemperature = 40
    startTime = 120 #启动时间
    scanTime = 1800 #30分钟
    step = 7

    switchStatus = 0 # 0表示关闭，1表示开启

    startTimeTemp = startTime
    scanTimeTemp = scanTime

    while True:
        try:
            d.convert_temp()
            # 显示温度和设定温度
            nowTemperature = d.read_temp(rom[0])
            if showSet:
                tm.temperature(int(setTemperature))
            else:
                tm.number(int(nowTemperature*10))

            if int(nowTemperature) >= setTemperature and (not switchStatus) and int(nowTemperature) > lowTemperature:#高于设定温度启动
                client.publish("switch","1",retain=True)
                startTimeTemp = startTime

            if (int(nowTemperature) <= setTemperature - step) and switchStatus:
                client.publish("switch","0",retain=True)

            if startTimeTemp <= 0: #如果时间超过3分钟，自动停止，并提高设定温度
                client.publish("switch","0",retain=True)
                setTemperature = int(nowTemperature + step)
                startTimeTemp = startTime

            if switchStatus:
                startTimeTemp -= 1

            client.check_msg()
            client.publish("temperature",str(round(nowTemperature,2)),retain=True)
            publishInfo()

            if scanTimeTemp <= 0:
                setTemperature = int(nowTemperature - step) #回调降温
                scanTimeTemp = scanTime
            scanTimeTemp -= 1 

        except Exception as e:
            reset()

        time.sleep(1)
        showSet = not showSet

Python学习交流Q群：906715085###
  隐藏代码
from machine import Pin
from umqtt.simple import MQTTClient
import time

def main():
    def sub_callback(topic, msg):
        nonlocal client
        nonlocal pin
        """
        收到订阅消息回调
        """
        if msg == b"0":
            pin.off()
        else:
            pin.on()
        client.publish("switchWell",str(pin.value()),retain=True)

    client_id = "switch_id"
    mserver = "192.168.0.99"
    #mserver = "mq.tongxinmao.com"        
    pin = Pin(0,Pin.OUT)

    client = MQTTClient(client_id, mserver, 0)
    client.set_callback(sub_callback)
    client.connect()
    client.subscribe(b"switch")
    while True:
        client.check_msg()
        client.publish("switchStatus",str(pin.value()),retain=True)