Änderung main bzgl Kommunikation
This commit is contained in:
yaba-source
45
micropython/boot.py
Normal file
45
micropython/boot.py
Normal file
@@ -0,0 +1,45 @@
|
||||
import network
|
||||
import time
|
||||
import gc
|
||||
|
||||
gc.collect()
|
||||
|
||||
# (SSID: Passwort)
|
||||
known_networks = {
|
||||
"Vodafone-9454": "AchXHta93YCTgC3M",
|
||||
"WGLan": "2Bierund1Pizza!",
|
||||
"No": "",
|
||||
"placeholder2": "placeholder2"
|
||||
}
|
||||
|
||||
def connect_wifi():
|
||||
wlan = network.WLAN(network.STA_IF)
|
||||
wlan.active(True)
|
||||
|
||||
# Suche nach verfügbaren Netzwerken
|
||||
print("Scanne nach WLAN-Netzwerken...")
|
||||
available_networks = wlan.scan()
|
||||
print(f"Gefundene Netzwerke: {(available_networks)}")
|
||||
for net in available_networks:
|
||||
ssid = net[0].decode('utf-8') if isinstance(net[0], bytes) else net[0]
|
||||
if ssid in known_networks:
|
||||
password = known_networks[ssid]
|
||||
print(f"Versuche Verbindung mit '{ssid}'...")
|
||||
wlan.connect(ssid, password)
|
||||
|
||||
while not wlan.isconnected():
|
||||
time.sleep(1)
|
||||
print(".", end="")
|
||||
|
||||
if wlan.isconnected():
|
||||
print(f"\nVerbunden mit '{ssid}'")
|
||||
print("IP-Adresse:", wlan.ifconfig()[0])
|
||||
return True
|
||||
else:
|
||||
print(f"\n❌ Verbindung mit '{ssid}' fehlgeschlagen.")
|
||||
|
||||
print("Kein bekanntes Netzwerk verfügbar oder Verbindung fehlgeschlagen.")
|
||||
return False
|
||||
|
||||
# Verbindung herstellen beim Boot
|
||||
connect_wifi()
|
||||
164
micropython/main.py
Normal file
164
micropython/main.py
Normal file
@@ -0,0 +1,164 @@
|
||||
import network
|
||||
from umqtt.simple import MQTTClient
|
||||
from machine import Pin
|
||||
import json
|
||||
import time
|
||||
import urequests
|
||||
|
||||
# MQTT-Konfiguration
|
||||
MQTT_BROKER = "lires.de"
|
||||
MQTT_PORT = 1883
|
||||
MQTT_CLIENT_ID = "esp8266_coffee"
|
||||
MQTT_TOPIC_STATUS = b"coffee/status"
|
||||
MQTT_TOPIC_COMMAND = b"coffee/command"
|
||||
MQTT_TOPIC_RETURN = b"coffee/return"
|
||||
|
||||
# Other Constants
|
||||
SERVER_URL = "http://lires.de/unsecure/esp/online"
|
||||
|
||||
# --- Eingänge ---
|
||||
an = Pin(5, Pin.IN)
|
||||
bereit = Pin(4, Pin.IN)
|
||||
fehler = Pin(14, Pin.IN)
|
||||
bohnen_voll = Pin(12, Pin.IN)
|
||||
Wasser_voll = Pin(13, Pin.IN)
|
||||
|
||||
# --- Ausgänge ---
|
||||
einschalten = Pin(0, Pin.OUT)
|
||||
starten = Pin(15, Pin.OUT)
|
||||
|
||||
# --- Status ---
|
||||
toggle_machine=0
|
||||
gestartet = 0
|
||||
|
||||
make_coffee= 0
|
||||
|
||||
kaffee_fertig = 0
|
||||
in_process = 0
|
||||
|
||||
|
||||
def mqtt_callback(topic, msg):
|
||||
print('-------------------------')
|
||||
print('MQTT Nachricht empfangen:')
|
||||
print(f'Topic: {topic.decode()}')
|
||||
print(f'Payload: {msg.decode()}')
|
||||
print('-------------------------')
|
||||
try:
|
||||
command = json.loads(msg.decode())
|
||||
if topic == MQTT_TOPIC_COMMAND:
|
||||
if command['command']=='toggle_machine':
|
||||
toggle_machine=1
|
||||
if gestartet.value() == 1:
|
||||
command['status']='served'
|
||||
|
||||
print(command)
|
||||
client.publish(MQTT_TOPIC_RETURN, json.dumps(command))
|
||||
|
||||
if command['command']=='make_coffee':
|
||||
kaffee_machen=1
|
||||
|
||||
if kaffee_fertig==1:
|
||||
print(command)
|
||||
client.publish(MQTT_TOPIC_RETURN, json.dumps(command))
|
||||
|
||||
except Exception as e:
|
||||
print('Fehler bei Kommando-Verarbeitung:', e)
|
||||
|
||||
def connect_mqtt():
|
||||
client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, port=MQTT_PORT)
|
||||
client.set_callback(mqtt_callback)
|
||||
client.connect()
|
||||
print('MQTT verbunden')
|
||||
client.subscribe(MQTT_TOPIC_COMMAND)
|
||||
return client
|
||||
|
||||
def send_online_status():
|
||||
try:
|
||||
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)
|
||||
|
||||
|
||||
# MQTT-Verbindung herstellen
|
||||
try:
|
||||
client = connect_mqtt()
|
||||
except Exception as e:
|
||||
print('MQTT Verbindungsfehler:', e)
|
||||
client = None
|
||||
|
||||
send_online_status()
|
||||
|
||||
|
||||
# Hauptschleife
|
||||
while True:
|
||||
try:
|
||||
if client:
|
||||
client.check_msg() # Prüfe auf neue MQTT-Nachrichten
|
||||
|
||||
# Status senden
|
||||
status = {
|
||||
# ---IOs---
|
||||
"an": an.value(),
|
||||
"bereit": bereit.value(),
|
||||
"fehler": fehler.value(),
|
||||
"bohnen_voll": bohnen_voll.value(),
|
||||
"Wasser_voll": Wasser_voll.value(),
|
||||
"einschalten": einschalten.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(3) # Warte 5 Sekunden zwischen den Status-Updates
|
||||
|
||||
except Exception as e:
|
||||
print('Fehler in Hauptschleife:', e)
|
||||
time.sleep(5)
|
||||
client = None
|
||||
# Einschalten der Kaffeemaschine per remote
|
||||
if toggle_machine.value() == 1 and an.value() == 0 and bereit.value() == 0 and fehler.value() == 0:
|
||||
einschalten=1
|
||||
time.sleep(1)
|
||||
einschalten=0
|
||||
gestartet = 1
|
||||
|
||||
#Starten der Kaffeemaschine per remote
|
||||
if make_coffee() == 1 and an() == 1 and bereit() == 1 and fehler() == 0 and gestartet == 1:
|
||||
starten=1
|
||||
time.sleep(1)
|
||||
starten=0
|
||||
make_coffee = 0
|
||||
in_process = 1
|
||||
|
||||
|
||||
# Kaffee fertig
|
||||
if bereit() == 1 and an() == 1 and fehler() == 0 and in_process == 1:
|
||||
kaffee_fertig=1
|
||||
in_process = 0
|
||||
else:
|
||||
kaffee_fertig=0
|
||||
|
||||
# Fehlerbehandlung
|
||||
if fehler() == 1:
|
||||
fehler(1)
|
||||
else:
|
||||
fehler(0)
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user