From 47143d29a5f150e8904aa22ba6c15aa7b562ac00 Mon Sep 17 00:00:00 2001
From: root <root@localhost>
Date: Wed, 12 Mar 2025 11:11:08 +0100
Subject: [PATCH] Automatisches Ausschalten der Steckdosen nach Jobende
 implementiert
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- Neue API zur Statusüberprüfung für Frontend hinzugefügt
- Automatisches Ausschalten der Steckdosen bei Jobende implementiert
- Zurücksetzen des Steckdosenstatus nach Jobende verbessert
- check-jobs CLI-Befehl optimiert

🤖 Generated with [Claude Code](https://claude.ai/code)
Co-Authored-By: Claude <noreply@anthropic.com>
---
 backend/app.py | 73 ++++++++++++++++++++++++++++++++++++++++++++------
 1 file changed, 65 insertions(+), 8 deletions(-)

diff --git a/backend/app.py b/backend/app.py
index cbce604..b7387e5 100755
--- a/backend/app.py
+++ b/backend/app.py
@@ -838,7 +838,28 @@ def job_remaining_time(job_id):
         return jsonify({'message': 'Job nicht gefunden!'}), 404
     
     remaining = calculate_remaining_time(job)
-    return jsonify({'remaining_minutes': remaining})
+    
+    # Wenn die verbleibende Zeit 0 ist und der Job nicht manuell abgebrochen wurde,
+    # automatisch die Steckdose ausschalten und Status aktualisieren
+    if remaining == 0 and not job['aborted']:
+        socket = get_socket_by_id(job['socket_id'])
+        if socket and socket['status'] == 1:  # busy
+            update_socket(socket['id'], status=0)  # available
+            app.logger.info(f"Job {job['id']} abgelaufen. Steckdose {socket['id']} auf verfügbar gesetzt.")
+            
+            # Steckdose ausschalten, falls IP-Adresse hinterlegt ist
+            if socket['ip_address']:
+                try:
+                    turn_off_socket(socket['ip_address'])
+                    app.logger.info(f"Steckdose {socket['ip_address']} für abgelaufenen Job {job['id']} automatisch ausgeschaltet.")
+                except Exception as e:
+                    app.logger.error(f"Fehler beim Ausschalten der Steckdose {socket['ip_address']}: {e}")
+    
+    return jsonify({
+        'remaining_minutes': remaining,
+        'job_status': 'completed' if remaining == 0 else 'active',
+        'socket_status': 'available' if remaining == 0 else 'busy'
+    })
 
 @app.route('/api/users', methods=['GET'])
 @login_required
@@ -954,16 +975,52 @@ def check_jobs():
                 update_socket(socket['id'], status=0)  # available
                 app.logger.info(f"Job {job['id']} abgelaufen. Steckdose {socket['id']} auf verfügbar gesetzt.")
             
-            # Steckdose ausschalten, falls IP-Adresse hinterlegt ist
-            if socket and socket['ip_address']:
-                try:
-                    turn_off_socket(socket['ip_address'])
-                    app.logger.info(f"Steckdose {socket['ip_address']} für abgelaufenen Job {job['id']} ausgeschaltet.")
-                except Exception as e:
-                    app.logger.error(f"Fehler beim Ausschalten der Steckdose {socket['ip_address']}: {e}")
+                # Steckdose ausschalten, falls IP-Adresse hinterlegt ist
+                if socket['ip_address']:
+                    try:
+                        turn_off_socket(socket['ip_address'])
+                        app.logger.info(f"Steckdose {socket['ip_address']} für abgelaufenen Job {job['id']} ausgeschaltet.")
+                    except Exception as e:
+                        app.logger.error(f"Fehler beim Ausschalten der Steckdose {socket['ip_address']}: {e}")
         
         app.logger.info(f"{len(expired_jobs)} abgelaufene Jobs überprüft und Steckdosen aktualisiert.")
 
+@app.route('/api/job/<job_id>/status', methods=['GET'])
+def job_status(job_id):
+    """Endpunkt zum Überprüfen des Status eines Jobs für Frontend-Polling."""
+    job = get_job_by_id(job_id)
+    if not job:
+        return jsonify({'message': 'Job nicht gefunden!'}), 404
+    
+    remaining = calculate_remaining_time(job)
+    socket = get_socket_by_id(job['socket_id'])
+    socket_status = socket['status'] if socket else None
+    
+    # Wenn die verbleibende Zeit 0 ist und der Job nicht manuell abgebrochen wurde,
+    # automatisch die Steckdose ausschalten und Status aktualisieren
+    if remaining == 0 and not job['aborted'] and socket and socket['status'] == 1:
+        # Update socket status to available
+        update_socket(socket['id'], status=0)
+        socket_status = 0
+        app.logger.info(f"Job {job['id']} abgelaufen. Steckdose {socket['id']} auf verfügbar gesetzt.")
+        
+        # Steckdose ausschalten, falls IP-Adresse hinterlegt ist
+        if socket['ip_address']:
+            try:
+                turn_off_socket(socket['ip_address'])
+                app.logger.info(f"Steckdose {socket['ip_address']} für abgelaufenen Job {job['id']} automatisch ausgeschaltet.")
+            except Exception as e:
+                app.logger.error(f"Fehler beim Ausschalten der Steckdose {socket['ip_address']}: {e}")
+    
+    job_status = 'aborted' if job['aborted'] else ('completed' if remaining == 0 else 'active')
+    
+    return jsonify({
+        'job': job_to_dict(job),
+        'status': job_status,
+        'socketStatus': 'available' if socket_status == 0 else 'busy',
+        'remainingMinutes': remaining
+    })
+
 @app.route('/api/test', methods=['GET'])
 def test():
     return jsonify({'message': 'MYP Backend API funktioniert!'})