Compare commits
7 Commits
dev
...
3b7acfbac1
| Author | SHA1 | Date | |
|---|---|---|---|
| 3b7acfbac1 | |||
| a09454211b | |||
| ba11861336 | |||
| df000eace9 | |||
| 74617a1e0f | |||
| bc80b5fcf1 | |||
| 0c82ce6100 |
@@ -3,9 +3,8 @@ from flask import Flask, render_template, request, redirect, url_for, flash
|
||||
from flask_login import LoginManager, login_user, login_required, logout_user, UserMixin, current_user
|
||||
from flask_bcrypt import Bcrypt
|
||||
from cryptography.fernet import Fernet
|
||||
from datetime import datetime
|
||||
from collections import defaultdict
|
||||
import sqlite3, glob, os, re
|
||||
import sqlite3
|
||||
import glob, os, re
|
||||
|
||||
app = Flask(__name__)
|
||||
app.secret_key = "309cc4d5ce1fe7486ae25cbd232bbdfe6a72539c03f0127d372186dbdc0fc928"
|
||||
@@ -82,34 +81,6 @@ def logout():
|
||||
logout_user()
|
||||
return redirect(url_for('login'))
|
||||
|
||||
def get_last_seen(dev_name: str):
|
||||
"""Letztes Mal, dass ein Gerät erreichbar war."""
|
||||
log_files = glob.glob("/var/log/rpi-*.log")
|
||||
if not log_files:
|
||||
return None
|
||||
|
||||
latest_time = None
|
||||
|
||||
# alle Logs durchgehen
|
||||
for logfile in sorted(log_files):
|
||||
with open(logfile, "r") as f:
|
||||
for line in f:
|
||||
line = line.strip()
|
||||
if f"{dev_name} ist erreichbar!" in line:
|
||||
try:
|
||||
ts_str = line.split(" ")[0] + " " + line.split(" ")[1] # "YYYY-MM-DD HH:MM:SS"
|
||||
ts = datetime.strptime(ts_str, "%Y-%m-%d %H:%M:%S")
|
||||
if latest_time is None or ts > latest_time:
|
||||
latest_time = ts
|
||||
except Exception:
|
||||
continue
|
||||
|
||||
if latest_time:
|
||||
datetime_str = latest_time.strftime("Zuletzt Online am %d.%m.%Y um %H:%M Uhr")
|
||||
return f"{datetime_str}"
|
||||
|
||||
return None
|
||||
|
||||
@app.route("/")
|
||||
@login_required
|
||||
def index():
|
||||
@@ -119,47 +90,26 @@ def index():
|
||||
c.execute("SELECT mac, name, is_active FROM devices ORDER BY name ASC")
|
||||
devices = c.fetchall()
|
||||
|
||||
devices = sorted(devices, key=lambda d: d[1][0].upper())
|
||||
|
||||
grouped_devices = defaultdict(list)
|
||||
for d in devices:
|
||||
first_letter = d[1][:2].upper()
|
||||
grouped_devices[first_letter].append(d)
|
||||
|
||||
# Intervall aus DB laden
|
||||
# Intervall aus DB (Minuten) laden
|
||||
c.execute("SELECT value FROM settings WHERE key='interval'")
|
||||
row = c.fetchone()
|
||||
interval = int(row[0]) if row else 5
|
||||
interval = int(row[0]) if row else 5 # Default 5 Minuten
|
||||
conn.close()
|
||||
|
||||
# Status aus Logdateien ermitteln
|
||||
# Status aus letztem Log ermitteln
|
||||
import glob, os
|
||||
log_files = glob.glob("/var/log/rpi-*.log")
|
||||
status_dict = {}
|
||||
last_seen_dict = {}
|
||||
|
||||
if log_files:
|
||||
latest_log = max(log_files, key=os.path.getctime)
|
||||
with open(latest_log, "r") as f:
|
||||
lines = f.readlines()
|
||||
|
||||
for line in f:
|
||||
for dev in devices:
|
||||
last_status = None
|
||||
for line in reversed(lines):
|
||||
if f"{dev[1]} ist erreichbar!" in line:
|
||||
last_status = "online"
|
||||
break
|
||||
elif f"{dev[1]} ist nicht erreichbar!" in line:
|
||||
last_status = "offline"
|
||||
break
|
||||
if dev[1] in line:
|
||||
status_dict[dev[0]] = "online" if "erreichbar" in line else "offline"
|
||||
|
||||
if last_status:
|
||||
status_dict[dev[0]] = last_status
|
||||
if last_status == "offline":
|
||||
last_seen_dict[dev[0]] = get_last_seen(dev[1])
|
||||
else:
|
||||
status_dict[dev[0]] = "unbekannt"
|
||||
|
||||
return render_template("index.html", grouped_devices=grouped_devices, devices=devices, status=status_dict, last_seen=last_seen_dict, interval=interval)
|
||||
# Template rendern mit Devices, Status und Intervall
|
||||
return render_template("index.html", devices=devices, status=status_dict, interval=interval)
|
||||
|
||||
@app.route("/settings", methods=["GET", "POST"])
|
||||
@login_required
|
||||
@@ -229,7 +179,7 @@ def devices():
|
||||
switch_hostname = request.form.get('switch_hostname')
|
||||
is_active = 1 if 'is_active' in request.form else 0
|
||||
|
||||
if not all([mac, rpi_ip, name]):
|
||||
if not all([mac, rpi_ip, port, name, switch_hostname]):
|
||||
flash("Alle Felder müssen ausgefüllt sein!")
|
||||
return redirect(url_for('devices'))
|
||||
|
||||
@@ -266,22 +216,22 @@ def devices():
|
||||
old_mac = request.form.get('old_mac')
|
||||
mac = request.form.get('mac')
|
||||
rpi_ip = request.form.get('rpi_ip')
|
||||
port = request.form.get('port') or None
|
||||
port = request.form.get('port')
|
||||
name = request.form.get('name')
|
||||
switch_hostname = request.form.get('switch_hostname') or None
|
||||
is_active = 1 if 'is_active' in request.form else 0
|
||||
|
||||
# --- Nur Switch ändern ---
|
||||
# Prüfen, ob nur das Switch-Feld gesendet wurde und die anderen Felder leer sind
|
||||
if 'switch_hostname' in request.form and all(not f for f in [mac, rpi_ip, name]):
|
||||
# --- Prüfen, ob es sich um eine Switch-Änderung handelt ---
|
||||
if mac is None and rpi_ip is None and port is None and name is None and switch_hostname:
|
||||
# Nur den Switch ändern
|
||||
device = conn.execute("SELECT name, switch_hostname FROM devices WHERE mac=?", (old_mac,)).fetchone()
|
||||
|
||||
if not device:
|
||||
flash("Gerät nicht gefunden!")
|
||||
return redirect(url_for('devices'))
|
||||
|
||||
old_switch = device['switch_hostname'] or "unbekannt"
|
||||
device_name = device['name']
|
||||
switch_hostname = request.form.get('switch_hostname') or ""
|
||||
|
||||
try:
|
||||
conn.execute("""
|
||||
@@ -290,36 +240,27 @@ def devices():
|
||||
WHERE mac=?
|
||||
""", (switch_hostname, old_mac))
|
||||
conn.commit()
|
||||
flash(f"Switch von {device_name} geändert: {old_switch} → {switch_hostname or 'Kein Switch'}")
|
||||
flash(f"Switch von {device_name} geändert: {old_switch} → {switch_hostname}")
|
||||
except sqlite3.IntegrityError:
|
||||
flash("Fehler beim Ändern des Switch!")
|
||||
return redirect(url_for('devices'))
|
||||
|
||||
# --- Normales Gerät bearbeiten ---
|
||||
# Pflichtfelder prüfen
|
||||
if not all([old_mac, mac, rpi_ip, name]):
|
||||
flash("Felder 'MAC', 'IP' und 'Name' müssen ausgefüllt sein!")
|
||||
if not all([old_mac, mac, rpi_ip, port, name]):
|
||||
flash("Alle Felder müssen ausgefüllt sein!")
|
||||
return redirect(url_for('devices'))
|
||||
|
||||
# Prüfen auf doppelte IP außer das aktuelle Gerät
|
||||
ip_device = conn.execute(
|
||||
"SELECT name FROM devices WHERE rpi_ip=? AND mac<>?",
|
||||
(rpi_ip, old_mac)
|
||||
).fetchone()
|
||||
ip_device = conn.execute("SELECT name FROM devices WHERE rpi_ip=? AND mac<>?", (rpi_ip, old_mac)).fetchone()
|
||||
if ip_device:
|
||||
flash(f"IP-Adresse existiert bereits für Gerät '{ip_device['name']}'!")
|
||||
return redirect(url_for('devices'))
|
||||
|
||||
# Prüfen auf doppelte MAC außer das aktuelle Gerät
|
||||
mac_device = conn.execute(
|
||||
"SELECT name FROM devices WHERE mac=? AND mac<>?",
|
||||
(mac, old_mac)
|
||||
).fetchone()
|
||||
mac_device = conn.execute("SELECT name FROM devices WHERE mac=? AND mac<>?", (mac, old_mac)).fetchone()
|
||||
if mac_device:
|
||||
flash(f"MAC-Adresse existiert bereits für Gerät '{mac_device['name']}'!")
|
||||
return redirect(url_for('devices'))
|
||||
|
||||
# Update durchführen
|
||||
try:
|
||||
conn.execute("""
|
||||
UPDATE devices
|
||||
@@ -331,7 +272,6 @@ def devices():
|
||||
except sqlite3.IntegrityError:
|
||||
flash("Fehler beim Aktualisieren des Geräts!")
|
||||
|
||||
|
||||
# -----------------------
|
||||
# Gerät löschen
|
||||
# -----------------------
|
||||
@@ -360,7 +300,7 @@ def devices():
|
||||
switches.hostname AS switch_hostname
|
||||
FROM devices
|
||||
LEFT JOIN switches ON devices.switch_hostname = switches.hostname
|
||||
ORDER BY switches.hostname ASC, devices.name ASC
|
||||
ORDER BY switches.hostname ASC
|
||||
""").fetchall()
|
||||
|
||||
conn.close()
|
||||
@@ -494,43 +434,36 @@ def logs():
|
||||
return render_template('logs.html', log_content=log_content, log_name=os.path.basename(latest_log), interval=interval)
|
||||
|
||||
def load_device_status():
|
||||
"""
|
||||
Liest das aktuellste rpi-Logfile und extrahiert den letzten Status jedes Devices.
|
||||
Gibt ein Dictionary zurück: {Device-Name: 'online'/'offline'}
|
||||
"""
|
||||
status = {}
|
||||
|
||||
# Devices aus DB laden (Name → MAC)
|
||||
conn = sqlite3.connect("sqlite.db")
|
||||
conn.row_factory = sqlite3.Row
|
||||
devices = conn.execute("SELECT mac, name FROM devices").fetchall()
|
||||
name_to_mac = {d['name']: d['mac'] for d in devices}
|
||||
conn.close()
|
||||
|
||||
# Logfile
|
||||
log_files = glob.glob("/var/log/rpi-*.log")
|
||||
if not log_files:
|
||||
return status
|
||||
|
||||
latest_log = max(log_files, key=os.path.getctime)
|
||||
|
||||
# Jede Zeile des Logs lesen
|
||||
with open(latest_log, "r") as f:
|
||||
lines = f.readlines()
|
||||
|
||||
# Regex für Ping-Ergebnisse
|
||||
online_re = re.compile(r"(\S+) ist erreichbar!")
|
||||
offline_re = re.compile(r"(\S+) ist nicht erreichbar!")
|
||||
|
||||
with open(latest_log, "r") as f:
|
||||
for line in f:
|
||||
for line in lines:
|
||||
line = line.strip()
|
||||
m_online = online_re.search(line)
|
||||
m_offline = offline_re.search(line)
|
||||
if m_online:
|
||||
name = m_online.group(1)
|
||||
mac = name_to_mac.get(name)
|
||||
if mac:
|
||||
status[mac] = 'online'
|
||||
status[m_online.group(1)] = 'online'
|
||||
elif m_offline:
|
||||
name = m_offline.group(1)
|
||||
mac = name_to_mac.get(name)
|
||||
if mac:
|
||||
status[mac] = 'offline'
|
||||
status[m_offline.group(1)] = 'offline'
|
||||
|
||||
return status
|
||||
|
||||
|
||||
@app.route("/users", methods=["GET", "POST"])
|
||||
@login_required
|
||||
def users():
|
||||
|
||||
@@ -6,10 +6,7 @@ def generate_ips_list():
|
||||
conn = sqlite3.connect(DB_PATH)
|
||||
conn.row_factory = sqlite3.Row
|
||||
|
||||
switches = {row['hostname']: row for row in conn.execute(
|
||||
"SELECT hostname, ip, username, password FROM switches"
|
||||
)}
|
||||
|
||||
switches = {row['hostname']: row for row in conn.execute("SELECT hostname, ip, username, password FROM switches")}
|
||||
devices = conn.execute("""
|
||||
SELECT mac, rpi_ip, port, name, switch_hostname
|
||||
FROM devices
|
||||
@@ -19,17 +16,11 @@ def generate_ips_list():
|
||||
|
||||
for dev in devices:
|
||||
switch = switches.get(dev['switch_hostname'])
|
||||
if switch:
|
||||
switch_ip = switch['ip']
|
||||
switch_user = switch['username']
|
||||
switch_pass = decrypt_password(switch['password'])
|
||||
else:
|
||||
switch_ip = ""
|
||||
switch_user = ""
|
||||
switch_pass = ""
|
||||
|
||||
if not switch:
|
||||
continue
|
||||
password = decrypt_password(switch['password'])
|
||||
port = dev['port'] or ""
|
||||
print(f"{dev['rpi_ip']}:{dev['name']}:{switch_ip}:{dev['switch_hostname'] or 'kein Switch'}:{port}:{switch_user}:{switch_pass}")
|
||||
print(f"{dev['rpi_ip']}:{dev['name']}:{switch['ip']}:{switch['hostname']}:{port}:{switch['username']}:{password}")
|
||||
|
||||
if __name__ == "__main__":
|
||||
generate_ips_list()
|
||||
|
||||
Binary file not shown.
@@ -87,33 +87,25 @@ pre {
|
||||
|
||||
#log-container {
|
||||
position: relative;
|
||||
height: calc(100vh - 252px); /* Füllt die Seite minus Header */
|
||||
padding: 1rem; /* optional, Abstand innen */
|
||||
box-sizing: border-box; /* damit Padding nicht die Höhe sprengt */
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
height: calc(100vh - 150px); /* Füllt die Seite minus Header */
|
||||
}
|
||||
|
||||
#log-box {
|
||||
flex: 1 1 auto; /* füllt den Container, berücksichtigt Header/Padding */
|
||||
height: 97%;
|
||||
overflow: auto;
|
||||
white-space: pre-wrap;
|
||||
font-family: monospace;
|
||||
border: 1px solid #dee2e6;
|
||||
border: 1px solid #dee2e6; /* Bootstrap-like border */
|
||||
padding: 1rem;
|
||||
background-color: #f8f9fa;
|
||||
padding: 0.5rem;
|
||||
}
|
||||
|
||||
#refresh-timer {
|
||||
position: absolute;
|
||||
bottom: 18px;
|
||||
right: 30px;
|
||||
bottom: 10px;
|
||||
right: 10px;
|
||||
font-size: 0.9em;
|
||||
color: gray;
|
||||
background-color: rgba(255,255,255,0.7); /* optional, besser lesbar */
|
||||
padding: 2px 4px;
|
||||
border-radius: 3px;
|
||||
pointer-events: none; /* damit Scrollbar nicht blockiert wird */
|
||||
}
|
||||
|
||||
/* Tabelle anpassen */
|
||||
|
||||
@@ -8,7 +8,7 @@
|
||||
<button class="btn btn-success mb-3" data-bs-toggle="modal" data-bs-target="#deviceModal" onclick="openDeviceModal()">Neues Gerät hinzufügen</button>
|
||||
{% endif %}
|
||||
|
||||
<table class="table table-striped">
|
||||
<table class="table table-bordered">
|
||||
<thead>
|
||||
<tr>
|
||||
<th>Hostname</th>
|
||||
@@ -89,12 +89,11 @@
|
||||
</div>
|
||||
<div class="mb-3">
|
||||
<label>Port</label>
|
||||
<input type="text" name="port" class="form-control" placeholder="z.B. 3">
|
||||
<input type="text" name="port" class="form-control" required placeholder="z.B. 3">
|
||||
</div>
|
||||
<div class="mb-3">
|
||||
<label>Switch (optional)</label>
|
||||
<select name="switch_hostname" class="form-select">
|
||||
<option value="">Kein Switch</option>
|
||||
<label>Switch</label>
|
||||
<select name="switch_hostname" class="form-select" required>
|
||||
{% for sw in switches %}
|
||||
<option value="{{ sw['hostname'] }}">{{ sw['hostname'] }}</option>
|
||||
{% endfor %}
|
||||
@@ -138,7 +137,7 @@
|
||||
</div>
|
||||
<div class="mb-3">
|
||||
<label>Port</label>
|
||||
<input type="text" name="port" id="edit_port" class="form-control" placeholder="z.B. 3">
|
||||
<input type="text" name="port" id="edit_port" class="form-control" required placeholder="z.B. 3">
|
||||
</div>
|
||||
</div>
|
||||
<div class="modal-footer">
|
||||
@@ -162,8 +161,7 @@
|
||||
<button type="button" class="btn-close" data-bs-dismiss="modal"></button>
|
||||
</div>
|
||||
<div class="modal-body">
|
||||
<select name="switch_hostname" id="switch_select" class="form-select">
|
||||
<option value="">Kein Switch</option>
|
||||
<select name="switch_hostname" id="switch_select" class="form-select" required>
|
||||
{% for sw in switches %}
|
||||
<option value="{{ sw['hostname'] }}">{{ sw['hostname'] }}</option>
|
||||
{% endfor %}
|
||||
|
||||
@@ -7,22 +7,15 @@
|
||||
Nächste Prüfung in -- Sekunden
|
||||
</span>
|
||||
</h2>
|
||||
<div class="row g-3">
|
||||
{% for letter, group in grouped_devices.items() %}
|
||||
<div class="row g-3">
|
||||
{% for d in group %}
|
||||
<div class="col-6 col-md-4 col-lg-3 col-xl-2">
|
||||
<div class="card text-center p-2"
|
||||
{% if last_seen.get(d[0]) %}
|
||||
title="{{ last_seen[d[0]] }}"
|
||||
{% elif status[d[0]] == 'offline' %}
|
||||
title="Noch nie online"
|
||||
{% endif %}>
|
||||
<div class="row row-cols-1 row-cols-md-6 g-3">
|
||||
{% for d in devices %}
|
||||
<div class="col">
|
||||
<div class="card text-center p-2">
|
||||
<div class="card-header">{{ d[1] }}</div>
|
||||
<div class="card-body">
|
||||
<span class="fw-bold" style="color:
|
||||
{% if d[2] == 0 %}gray
|
||||
{% elif status[d[0]] == 'online' %}green
|
||||
{% elif status[d[0]]=='online' %}green
|
||||
{% else %}red
|
||||
{% endif %};">
|
||||
{% if d[2] == 0 %}
|
||||
@@ -35,9 +28,8 @@
|
||||
</div>
|
||||
</div>
|
||||
{% endfor %}
|
||||
</div>
|
||||
{% endfor %}
|
||||
</div>
|
||||
|
||||
<script>
|
||||
document.addEventListener("DOMContentLoaded", () => {
|
||||
const intervalMinutes = {{ interval | int }}; // aus DB
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<!-- Button zum Hinzufügen -->
|
||||
<button class="btn btn-success mb-3" data-bs-toggle="modal" data-bs-target="#addSwitchModal">Neuen Switch hinzufügen</button>
|
||||
|
||||
<table class="table table-striped">
|
||||
<table class="table table-bordered">
|
||||
<thead>
|
||||
<tr>
|
||||
<th>Hostname</th>
|
||||
|
||||
@@ -8,7 +8,7 @@
|
||||
<button class="btn btn-success mb-3" data-bs-toggle="modal" data-bs-target="#userModal" onclick="openUserModal()">Neuen Benutzer</button>
|
||||
{% endif %}
|
||||
|
||||
<table class="table table-striped">
|
||||
<table class="table table-bordered">
|
||||
<thead>
|
||||
<tr>
|
||||
<th class="col-ip">Username</th>
|
||||
|
||||
@@ -87,27 +87,16 @@ EOF
|
||||
|
||||
echo "" > "$LOGFILE"
|
||||
|
||||
MAX_PARALLEL=10 # maximal gleichzeitig laufende Geräte
|
||||
|
||||
while true; do
|
||||
echo "--------------------------------------------------------------------" >> "$LOGFILE"
|
||||
python3 /srv/poe_manager/generate_ips.py | while IFS=: read -r rpi_ip dev_name switch_ip switch_hostname switch_port switch_user switch_pass; do
|
||||
# Funktion für ein Gerät
|
||||
check_device() {
|
||||
local rpi_ip="$1"
|
||||
local dev_name="$2"
|
||||
local switch_ip="$3"
|
||||
local switch_hostname="$4"
|
||||
local switch_port="$5"
|
||||
local switch_user="$6"
|
||||
local switch_pass="$7"
|
||||
|
||||
if ping -c 4 -W 1 "$rpi_ip" &> /dev/null; then
|
||||
if ping -c 1 -W 2 "$rpi_ip" &> /dev/null; then
|
||||
echo "$(date '+%Y-%m-%d %H:%M:%S') $dev_name ist erreichbar!" >> "$LOGFILE"
|
||||
else
|
||||
echo "$(date '+%Y-%m-%d %H:%M:%S') $dev_name ist nicht erreichbar!" >> "$LOGFILE"
|
||||
|
||||
if [ -n "$switch_port" ] && [ "$switch_port" != "None" ]; then
|
||||
# Nur PoE neu starten, wenn Port vorhanden ist
|
||||
if [ -n "$switch_port" ]; then
|
||||
disable_poe "$switch_ip" "$switch_port" "$switch_user" "$switch_pass"
|
||||
echo "$(date '+%Y-%m-%d %H:%M:%S') $dev_name PoE auf Port $switch_port am Switch $switch_hostname deaktiviert." >> "$LOGFILE"
|
||||
sleep 2
|
||||
@@ -115,17 +104,6 @@ while true; do
|
||||
echo "$(date '+%Y-%m-%d %H:%M:%S') $dev_name PoE auf Port $switch_port am Switch $switch_hostname aktiviert." >> "$LOGFILE"
|
||||
fi
|
||||
fi
|
||||
}
|
||||
|
||||
# Job in Hintergrund starten
|
||||
check_device "$rpi_ip" "$dev_name" "$switch_ip" "$switch_hostname" "$switch_port" "$switch_user" "$switch_pass" &
|
||||
|
||||
# Limit auf MAX_PARALLEL Jobs
|
||||
while [ "$(jobs -rp | wc -l)" -ge "$MAX_PARALLEL" ]; do
|
||||
sleep 0.2
|
||||
done
|
||||
done
|
||||
|
||||
wait # alle Hintergrundjobs beenden, bevor sleep
|
||||
sleep "$SLEEP"
|
||||
done
|
||||
|
||||
Reference in New Issue
Block a user