🎉 Improved database performance and session management in backend/backend/database/myp.db, backend/blueprints/__pycache__/tapo_control.cpython-313.pyc, backend/blueprints/tapo_control.py, backend/config/settings.py

This commit is contained in:
2025-06-12 11:32:34 +02:00
parent 57715ce04d
commit 774f52b67e
71 changed files with 1413 additions and 886 deletions

View File

@@ -26,69 +26,141 @@ tapo_logger = get_logger("tapo_control")
@login_required
@require_permission(Permission.CONTROL_PRINTER)
def tapo_dashboard():
"""Haupt-Dashboard für Tapo-Steckdosen-Steuerung."""
"""Haupt-Dashboard für Tapo-Steckdosen-Steuerung - zeigt immer alle 6 Mercedes-Benz Arbeitsplätze."""
try:
tapo_logger.info(f"Tapo Dashboard aufgerufen von Benutzer: {current_user.name}")
# Alle konfigurierten Tapo-Steckdosen aus der Datenbank laden
# Importiere die festen Konfigurationen
try:
from config.settings import DEFAULT_TAPO_IPS, PRINTERS, FIXED_PRINTER_COUNT, ALWAYS_SHOW_ALL_SOCKETS
except ImportError:
# Fallback-Konfiguration
DEFAULT_TAPO_IPS = ["192.168.1.201", "192.168.1.202", "192.168.1.203", "192.168.1.204", "192.168.1.205", "192.168.1.206"]
FIXED_PRINTER_COUNT = 6
ALWAYS_SHOW_ALL_SOCKETS = True
tapo_logger.warning("Fallback-Konfiguration verwendet da config.settings nicht importiert werden konnte")
# Alle Drucker aus der Datenbank laden
db_session = get_db_session()
printers_with_tapo = db_session.query(Printer).filter(
db_printers = {printer.plug_ip: printer for printer in db_session.query(Printer).filter(
Printer.active == True,
Printer.plug_ip.isnot(None)
).all()
).all()}
# Status aller Steckdosen abrufen - auch wenn sie nicht erreichbar sind
# Status aller 6 konfigurierten Steckdosen abrufen
outlets_status = {}
online_count = 0
for printer in printers_with_tapo:
# Gehe durch alle 6 festen Steckdosen-IPs
for i, tapo_ip in enumerate(DEFAULT_TAPO_IPS[:FIXED_PRINTER_COUNT], 1):
try:
tapo_logger.debug(f"Prüfe Tapo-Steckdose für Drucker {printer.name} ({printer.plug_ip})")
reachable, status = tapo_controller.check_outlet_status(
printer.plug_ip,
printer_id=printer.id
)
# Prüfe ob Drucker in der Datenbank existiert
db_printer = db_printers.get(tapo_ip)
if reachable:
online_count += 1
tapo_logger.info(f"✅ Tapo-Steckdose {printer.plug_ip} erreichbar - Status: {status}")
if db_printer:
# Drucker ist in der Datenbank - verwende echte Daten
printer_name = db_printer.name
printer_id = db_printer.id
location = db_printer.location or f"Arbeitsplatz {i}"
model = db_printer.model or "3D-Drucker"
else:
tapo_logger.warning(f"⚠️ Tapo-Steckdose {printer.plug_ip} nicht erreichbar")
# Drucker nicht in der Datenbank - verwende Standardnamen
printer_name = f"3D-Drucker {i}"
printer_id = None
location = f"Arbeitsplatz {i} (nicht konfiguriert)"
model = "3D-Drucker"
outlets_status[printer.plug_ip] = {
'printer_name': printer.name,
'printer_id': printer.id,
'ip': printer.plug_ip,
tapo_logger.debug(f"Prüfe Tapo-Steckdose {i}: {tapo_ip} für {printer_name}")
# Status der Steckdose prüfen
try:
reachable, status = tapo_controller.check_outlet_status(
tapo_ip,
printer_id=printer_id
)
if reachable:
online_count += 1
tapo_logger.info(f"✅ Steckdose {i} ({tapo_ip}) erreichbar - Status: {status}")
else:
tapo_logger.warning(f"⚠️ Steckdose {i} ({tapo_ip}) nicht erreichbar")
except Exception as status_error:
tapo_logger.error(f"❌ Fehler beim Status-Check für Steckdose {i} ({tapo_ip}): {status_error}")
reachable = False
status = 'error'
# Steckdose zu den Ergebnissen hinzufügen
outlets_status[tapo_ip] = {
'printer_name': printer_name,
'printer_id': printer_id,
'ip': tapo_ip,
'status': status,
'reachable': reachable,
'location': printer.location or "Unbekannt"
'location': location,
'model': model,
'position': i, # Position für Sortierung
'configured_in_db': db_printer is not None
}
# Fehlermeldung hinzufügen falls nicht erreichbar
if not reachable:
outlets_status[tapo_ip]['error'] = f"Steckdose {i} ist offline oder nicht erreichbar"
except Exception as e:
tapo_logger.error(f"❌ Fehler beim Status-Check für {printer.plug_ip}: {e}")
outlets_status[printer.plug_ip] = {
'printer_name': printer.name,
'printer_id': printer.id,
'ip': printer.plug_ip,
tapo_logger.error(f"❌ Fehler beim Verarbeiten von Steckdose {i} ({tapo_ip}): {e}")
outlets_status[tapo_ip] = {
'printer_name': f"3D-Drucker {i}",
'printer_id': None,
'ip': tapo_ip,
'status': 'error',
'reachable': False,
'location': printer.location or "Unbekannt",
'error': str(e)
'location': f"Arbeitsplatz {i} (Fehler)",
'model': "3D-Drucker",
'position': i,
'configured_in_db': False,
'error': f"Systemfehler: {str(e)}"
}
db_session.close()
tapo_logger.info(f"Dashboard geladen: {len(outlets_status)} Steckdosen, {online_count} online")
# Sortiere die Outlets nach Position
sorted_outlets = dict(sorted(outlets_status.items(), key=lambda x: x[1]['position']))
tapo_logger.info(f"Dashboard geladen: {len(sorted_outlets)} Steckdosen konfiguriert, {online_count} online")
return render_template('tapo_control.html',
outlets=outlets_status,
total_outlets=len(outlets_status),
online_outlets=online_count)
outlets=sorted_outlets,
total_outlets=len(sorted_outlets),
online_outlets=online_count,
fixed_layout=True) # Flag für festes Layout
except Exception as e:
tapo_logger.error(f"Fehler beim Laden des Tapo-Dashboards: {e}")
flash(f"Fehler beim Laden der Tapo-Steckdosen: {str(e)}", "error")
return render_template('tapo_control.html', outlets={}, total_outlets=0, online_outlets=0)
# Auch bei Fehlern die 6 Standard-Steckdosen anzeigen
error_outlets = {}
for i in range(1, 7):
tapo_ip = f"192.168.1.20{i}"
error_outlets[tapo_ip] = {
'printer_name': f"3D-Drucker {i}",
'printer_id': None,
'ip': tapo_ip,
'status': 'error',
'reachable': False,
'location': f"Arbeitsplatz {i}",
'model': "3D-Drucker",
'position': i,
'configured_in_db': False,
'error': "Systemfehler beim Laden"
}
return render_template('tapo_control.html',
outlets=error_outlets,
total_outlets=6,
online_outlets=0,
fixed_layout=True)
@tapo_blueprint.route("/control", methods=["POST"])
@login_required
@@ -382,4 +454,85 @@ def manual_control():
except Exception as e:
tapo_logger.error(f"Fehler bei manueller Steuerung: {e}")
flash(f'Fehler: {str(e)}', 'error')
return redirect(url_for('tapo.manual_control'))
return redirect(url_for('tapo.manual_control'))
@tapo_blueprint.route("/control-form", methods=["POST"])
@login_required
@require_permission(Permission.CONTROL_PRINTER)
def control_outlet_form():
"""Formular-basierte Steckdosen-Steuerung ohne JavaScript."""
try:
ip = request.form.get('ip')
action = request.form.get('action') # 'on' oder 'off'
if not ip or not action:
flash('IP-Adresse und Aktion sind erforderlich', 'error')
return redirect(url_for('tapo.tapo_dashboard'))
# IP-Adresse validieren
try:
ipaddress.ip_address(ip)
except ValueError:
flash('Ungültige IP-Adresse', 'error')
return redirect(url_for('tapo.tapo_dashboard'))
if action not in ['on', 'off']:
flash('Ungültige Aktion. Nur "on" oder "off" erlaubt.', 'error')
return redirect(url_for('tapo.tapo_dashboard'))
# Steckdose schalten
state = action == 'on'
success = tapo_controller.toggle_plug(ip, state)
if success:
action_text = "eingeschaltet" if state else "ausgeschaltet"
flash(f'Steckdose {ip} erfolgreich {action_text}', 'success')
tapo_logger.info(f"✅ Steckdose {ip} erfolgreich {action_text} durch {current_user.name} (Formular)")
else:
action_text = "einschalten" if state else "ausschalten"
flash(f'Fehler beim {action_text} der Steckdose {ip}', 'error')
tapo_logger.error(f"❌ Fehler beim {action_text} der Steckdose {ip} durch {current_user.name}")
return redirect(url_for('tapo.tapo_dashboard'))
except Exception as e:
tapo_logger.error(f"Unerwarteter Fehler bei Formular-Steckdosen-Steuerung: {e}")
flash(f'Systemfehler: {str(e)}', 'error')
return redirect(url_for('tapo.tapo_dashboard'))
@tapo_blueprint.route("/test-connection-form", methods=["POST"])
@login_required
@require_permission(Permission.CONTROL_PRINTER)
def test_connection_form():
"""Formular-basierter Verbindungstest ohne JavaScript."""
try:
ip = request.form.get('ip')
if not ip:
flash('IP-Adresse ist erforderlich', 'error')
return redirect(url_for('tapo.tapo_dashboard'))
# IP-Adresse validieren
try:
ipaddress.ip_address(ip)
except ValueError:
flash('Ungültige IP-Adresse', 'error')
return redirect(url_for('tapo.tapo_dashboard'))
# Verbindung testen
test_result = tapo_controller.test_connection(ip)
if test_result.get('success', False):
flash(f'✅ Verbindung zu {ip} erfolgreich!', 'success')
tapo_logger.info(f"✅ Verbindungstest zu {ip} erfolgreich - {current_user.name}")
else:
error_msg = test_result.get('error', 'Unbekannter Fehler')
flash(f'❌ Verbindung zu {ip} fehlgeschlagen: {error_msg}', 'error')
tapo_logger.warning(f"❌ Verbindungstest zu {ip} fehlgeschlagen - {current_user.name}: {error_msg}")
return redirect(url_for('tapo.tapo_dashboard'))
except Exception as e:
tapo_logger.error(f"Fehler beim Formular-Verbindungstest: {e}")
flash(f'Fehler beim Verbindungstest: {str(e)}', 'error')
return redirect(url_for('tapo.tapo_dashboard'))