das mit oob war nix
This commit is contained in:
yaba-source
@@ -5,90 +5,34 @@ import json
|
|||||||
import time
|
import time
|
||||||
import urequests
|
import urequests
|
||||||
|
|
||||||
class CoffeeMachine:
|
# MQTT-Konfiguration
|
||||||
def __init__(self):
|
MQTT_BROKER = "lires.de"
|
||||||
# --- Eingänge ---
|
MQTT_PORT = 1883
|
||||||
self.an = Pin(5, Pin.IN, Pin.PULL_UP)
|
MQTT_CLIENT_ID = "esp8266_coffee"
|
||||||
self.bereit = Pin(4, Pin.IN, Pin.PULL_UP)
|
MQTT_TOPIC_STATUS = b"coffee/status"
|
||||||
self.fehler = Pin(14, Pin.IN, Pin.PULL_UP)
|
MQTT_TOPIC_COMMAND = b"coffee/command"
|
||||||
self.bohnen_voll = Pin(12, Pin.IN, Pin.PULL_UP)
|
MQTT_TOPIC_RETURN = b"coffee/return"
|
||||||
self.wasser_voll = Pin(13, Pin.IN, Pin.PULL_UP)
|
|
||||||
|
|
||||||
# --- Ausgänge ---
|
# Other Constants
|
||||||
self.toggle_machine = Pin(0, Pin.OUT)
|
SERVER_URL = "http://lires.de/unsecure/esp/online"
|
||||||
self.starten = Pin(15, Pin.OUT)
|
|
||||||
|
|
||||||
# --- Status ---
|
# --- Eingänge ---
|
||||||
self.kaffee_machen = 0
|
an = Pin(5, Pin.IN)
|
||||||
self.vorbereitung = 0
|
bereit = Pin(4, Pin.IN)
|
||||||
self.kaffee_fertig = 0
|
fehler = Pin(14, Pin.IN)
|
||||||
self.gestartet = 0
|
bohnen_voll = Pin(12, Pin.IN)
|
||||||
|
Wasser_voll = Pin(13, Pin.IN)
|
||||||
|
|
||||||
def get_status(self):
|
# --- Ausgänge ---
|
||||||
return {
|
toggle_machine = Pin(0, Pin.OUT)
|
||||||
"an": self.an.value(),
|
starten = Pin(15, Pin.OUT)
|
||||||
"bereit": self.bereit.value(),
|
|
||||||
"fehler": self.fehler.value(),
|
|
||||||
"bohnen_voll": self.bohnen_voll.value(),
|
|
||||||
"wasser_voll": self.wasser_voll.value(),
|
|
||||||
"einschalten": self.toggle_machine.value(),
|
|
||||||
"starten": self.starten.value(),
|
|
||||||
"kaffee_machen": self.kaffee_machen,
|
|
||||||
"vorbereitung": self.vorbereitung,
|
|
||||||
"kaffee_fertig": self.kaffee_fertig
|
|
||||||
}
|
|
||||||
|
|
||||||
def make_coffee(self):
|
# --- Status ---
|
||||||
if self.kaffee_machen == 1:
|
kaffee_machen = 0
|
||||||
self.toggle_machine.value(1)
|
vorbereitung = 0
|
||||||
time.sleep(1)
|
kaffee_fertig = 0
|
||||||
self.toggle_machine.value(0)
|
|
||||||
|
|
||||||
if (self.kaffee_machen == 1 and
|
def mqtt_callback(topic, msg):
|
||||||
self.an.value() == 1 and
|
|
||||||
self.bereit.value() == 1 and
|
|
||||||
self.fehler.value() == 0):
|
|
||||||
self.starten.value(1)
|
|
||||||
time.sleep(1)
|
|
||||||
self.starten.value(0)
|
|
||||||
self.gestartet = 1
|
|
||||||
else:
|
|
||||||
self.starten.value(0)
|
|
||||||
self.gestartet = 0
|
|
||||||
|
|
||||||
def update_status(self):
|
|
||||||
if self.bereit.value() == 0 and self.an.value() == 1 and self.fehler.value() == 0:
|
|
||||||
self.vorbereitung = 1
|
|
||||||
|
|
||||||
if (self.bereit.value() == 1 and
|
|
||||||
self.an.value() == 1 and
|
|
||||||
self.fehler.value() == 0 and
|
|
||||||
self.gestartet == 1):
|
|
||||||
self.kaffee_fertig = 1
|
|
||||||
self.gestartet = 0
|
|
||||||
else:
|
|
||||||
self.kaffee_fertig = 0
|
|
||||||
|
|
||||||
class MQTTHandler:
|
|
||||||
BROKER = "lires.de"
|
|
||||||
PORT = 1883
|
|
||||||
CLIENT_ID = "esp8266_coffee"
|
|
||||||
TOPIC_STATUS = b"coffee/status"
|
|
||||||
TOPIC_COMMAND = b"coffee/command"
|
|
||||||
TOPIC_RETURN = b"coffee/return"
|
|
||||||
|
|
||||||
def __init__(self, coffee_machine):
|
|
||||||
self.coffee_machine = coffee_machine
|
|
||||||
self.client = None
|
|
||||||
|
|
||||||
def connect(self):
|
|
||||||
self.client = MQTTClient(self.CLIENT_ID, self.BROKER, port=self.PORT)
|
|
||||||
self.client.set_callback(self._callback)
|
|
||||||
self.client.connect()
|
|
||||||
print('MQTT verbunden')
|
|
||||||
self.client.subscribe(self.TOPIC_COMMAND)
|
|
||||||
|
|
||||||
def _callback(self, topic, msg):
|
|
||||||
print('-------------------------')
|
print('-------------------------')
|
||||||
print('MQTT Nachricht empfangen:')
|
print('MQTT Nachricht empfangen:')
|
||||||
print(f'Topic: {topic.decode()}')
|
print(f'Topic: {topic.decode()}')
|
||||||
@@ -96,48 +40,131 @@ class MQTTHandler:
|
|||||||
print('-------------------------')
|
print('-------------------------')
|
||||||
try:
|
try:
|
||||||
command = json.loads(msg.decode())
|
command = json.loads(msg.decode())
|
||||||
if topic == self.TOPIC_COMMAND:
|
if topic == MQTT_TOPIC_COMMAND:
|
||||||
self._handle_command(command)
|
if command['command']=='toggle_machine':
|
||||||
|
if starten.value() == 0:
|
||||||
|
command['status']='served'
|
||||||
|
|
||||||
|
print(command)
|
||||||
|
client.publish(MQTT_TOPIC_RETURN, json.dumps(command))
|
||||||
|
|
||||||
|
if command['command']=='make_coffee':
|
||||||
|
# Kaffe maschine antworten @TODO
|
||||||
|
if kaffee_fertig==1:
|
||||||
|
print(command)
|
||||||
|
client.publish(MQTT_TOPIC_RETURN, json.dumps(command))
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print('Fehler bei Kommando-Verarbeitung:', e)
|
print('Fehler bei Kommando-Verarbeitung:', e)
|
||||||
|
|
||||||
def _handle_command(self, command):
|
def connect_mqtt():
|
||||||
if command.get('command') == 'toggle_machine':
|
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, port=MQTT_PORT)
|
||||||
if self.coffee_machine.starten.value() == 0:
|
client.set_callback(mqtt_callback)
|
||||||
command['status'] = 'served'
|
client.connect()
|
||||||
self.client.publish(self.TOPIC_RETURN, json.dumps(command))
|
print('MQTT verbunden')
|
||||||
|
client.subscribe(MQTT_TOPIC_COMMAND)
|
||||||
|
return client
|
||||||
|
|
||||||
elif command.get('command') == 'make_coffee':
|
def send_online_status():
|
||||||
self.coffee_machine.kaffee_machen = 1
|
try:
|
||||||
self.client.publish(self.TOPIC_RETURN, json.dumps(command))
|
ip = network.WLAN(network.STA_IF).ifconfig()
|
||||||
|
payload = json.dumps({"ip": ip})
|
||||||
|
headers = {'Content-Type': 'application/json'}
|
||||||
|
response = urequests.post(SERVER_URL, data=payload, headers=headers)
|
||||||
|
print("Antwort vom Server:", response.text)
|
||||||
|
response.close()
|
||||||
|
except Exception as e:
|
||||||
|
print("Fehler beim Senden:", e)
|
||||||
|
|
||||||
def publish_status(self):
|
|
||||||
if self.client:
|
|
||||||
status = self.coffee_machine.get_status()
|
|
||||||
self.client.publish(self.TOPIC_STATUS, json.dumps(status))
|
|
||||||
|
|
||||||
def check_messages(self):
|
|
||||||
if self.client:
|
|
||||||
self.client.check_msg()
|
|
||||||
|
|
||||||
# Objekte erstellen
|
|
||||||
coffee_machine = CoffeeMachine()
|
|
||||||
mqtt_handler = MQTTHandler(coffee_machine)
|
|
||||||
|
|
||||||
# MQTT-Verbindung herstellen
|
# MQTT-Verbindung herstellen
|
||||||
try:
|
try:
|
||||||
mqtt_handler.connect()
|
client = connect_mqtt()
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print('MQTT Verbindungsfehler:', e)
|
print('MQTT Verbindungsfehler:', e)
|
||||||
|
client = None
|
||||||
|
|
||||||
|
send_online_status()
|
||||||
# Hauptschleife
|
# Hauptschleife
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
mqtt_handler.check_messages()
|
if client:
|
||||||
mqtt_handler.publish_status()
|
client.check_msg() # Prüfe auf neue MQTT-Nachrichten
|
||||||
coffee_machine.make_coffee()
|
|
||||||
coffee_machine.update_status()
|
# Status senden
|
||||||
time.sleep(5)
|
status = {
|
||||||
|
# ---IOs---
|
||||||
|
"an": an.value(),
|
||||||
|
"bereit": bereit.value(),
|
||||||
|
"fehler": fehler.value(),
|
||||||
|
"bohnen_voll": bohnen_voll.value(),
|
||||||
|
"Wasser_voll": Wasser_voll.value(),
|
||||||
|
"einschalten": toggle_machine.value(),
|
||||||
|
"starten": starten.value(),
|
||||||
|
|
||||||
|
# ---komunikation---
|
||||||
|
"kaffee_machen": kaffee_machen,
|
||||||
|
"vorbereitung": vorbereitung,
|
||||||
|
"kaffee_fertig": kaffee_fertig,
|
||||||
|
|
||||||
|
}
|
||||||
|
client.publish(MQTT_TOPIC_STATUS, json.dumps(status))
|
||||||
|
else:
|
||||||
|
# Versuche Neuverbindung
|
||||||
|
try:
|
||||||
|
client = connect_mqtt()
|
||||||
|
except:
|
||||||
|
pass
|
||||||
|
|
||||||
|
time.sleep(5) # Warte 5 Sekunden zwischen den Status-Updates
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print('Fehler in Hauptschleife:', e)
|
print('Fehler in Hauptschleife:', e)
|
||||||
time.sleep(5)
|
time.sleep(5)
|
||||||
|
client = None
|
||||||
|
|
||||||
|
# Einschalten der Kaffeemaschine
|
||||||
|
if kaffee_machen == 1:
|
||||||
|
toggle_machine(1)
|
||||||
|
time.sleep(1)
|
||||||
|
toggle_machine(0)
|
||||||
|
|
||||||
|
|
||||||
|
# Starten der Kaffeemaschine
|
||||||
|
if kaffee_machen == 1 and an() == 1 and bereit() == 1 and fehler() == 0:
|
||||||
|
starten(1)
|
||||||
|
time.sleep(1)
|
||||||
|
starten(0)
|
||||||
|
gestartet = 1
|
||||||
|
else:
|
||||||
|
starten(0)
|
||||||
|
gestartet = 0
|
||||||
|
#Vorbereitung der Kaffeemaschine
|
||||||
|
if bereit == 0 and an==1 and fehler==0 :
|
||||||
|
|
||||||
|
vorbereitung=1
|
||||||
|
|
||||||
|
# Vorbereitung der Kaffeemaschine
|
||||||
|
if bereit() == 0 and an() == 1 and fehler() == 0:
|
||||||
|
vorbereitung = 1
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
# Kaffeemaschine fertig
|
||||||
|
if bereit() == 1 and an() == 1 and fehler() == 0 and gestartet == 1:
|
||||||
|
kaffee_fertig=1
|
||||||
|
gestartet = 0
|
||||||
|
else:
|
||||||
|
kaffee_fertig=0
|
||||||
|
|
||||||
|
# Fehlerbehandlung
|
||||||
|
if fehler() == 1:
|
||||||
|
fehler(1)
|
||||||
|
else:
|
||||||
|
fehler(0)
|
||||||
|
|
||||||
|
if bohnen_voll() == 1:
|
||||||
|
bohnen_voll(1)
|
||||||
|
|
||||||
|
if Wasser_voll() == 1:
|
||||||
|
Wasser_voll(1)
|
||||||
Reference in New Issue
Block a user