|
|
|
@@ -13,7 +13,7 @@ Phase 1 ergänzte Lizenzsystem selbst (licensing.py). Das Dashboard ("/")
|
|
|
|
|
ist aktuell nur ein Platzhalter -- die eigentliche Kunden-/
|
|
|
|
|
Lizenzübersicht folgt in einem späteren Schritt.
|
|
|
|
|
"""
|
|
|
|
|
from flask import Flask, render_template, request, redirect, url_for, flash, jsonify, send_file, abort
|
|
|
|
|
from flask import Flask, render_template, request, redirect, url_for, flash, jsonify, send_file, abort, session
|
|
|
|
|
from flask_login import LoginManager, login_user, login_required, logout_user, UserMixin, current_user
|
|
|
|
|
from flask_bcrypt import Bcrypt
|
|
|
|
|
from werkzeug.utils import secure_filename
|
|
|
|
@@ -21,7 +21,7 @@ from cryptography.fernet import Fernet
|
|
|
|
|
from cryptography.hazmat.primitives.kdf.pbkdf2 import PBKDF2HMAC
|
|
|
|
|
from cryptography.hazmat.primitives import hashes, serialization
|
|
|
|
|
from cryptography import x509
|
|
|
|
|
from datetime import datetime
|
|
|
|
|
from datetime import datetime, timedelta
|
|
|
|
|
import base64, io, ipaddress, logging, math, shutil, socket, sqlite3, glob, json, os, re, secrets, subprocess, threading, time, traceback, zipfile
|
|
|
|
|
import yaml
|
|
|
|
|
import ssl
|
|
|
|
@@ -212,6 +212,10 @@ PERMISSIONS = {
|
|
|
|
|
"label": "Kunden",
|
|
|
|
|
"rows": {"view": "customers.view", "create": "customers.create", "edit": "customers.edit"},
|
|
|
|
|
},
|
|
|
|
|
"tickets": {
|
|
|
|
|
"label": "Tickets",
|
|
|
|
|
"rows": {"view": "tickets.view", "create": "tickets.create", "edit": "tickets.edit"},
|
|
|
|
|
},
|
|
|
|
|
"licenses": {
|
|
|
|
|
"label": "Lizenzen",
|
|
|
|
|
"rows": {"view": "licenses.view", "create": "licenses.create", "edit": "licenses.edit"},
|
|
|
|
@@ -251,6 +255,10 @@ PERMISSIONS = {
|
|
|
|
|
"label": "Systemeinstellungen",
|
|
|
|
|
"rows": {"view": "settings_system.view", "edit": "settings_system.edit"},
|
|
|
|
|
},
|
|
|
|
|
"settings_license": {
|
|
|
|
|
"label": "Lizenz",
|
|
|
|
|
"rows": {"view": "settings_license.view", "edit": "settings_license.edit"},
|
|
|
|
|
},
|
|
|
|
|
"settings_importexport": {
|
|
|
|
|
"label": "Im-/Export",
|
|
|
|
|
"rows": {
|
|
|
|
@@ -275,6 +283,8 @@ PERMISSION_LABELS = {
|
|
|
|
|
"licensing_group.view": "Lizenzierung-Bereich anzeigen",
|
|
|
|
|
"customers.view": "Kunden lesen", "customers.create": "Kunden anlegen",
|
|
|
|
|
"customers.edit": "Kunden ändern (inkl. Löschen)",
|
|
|
|
|
"tickets.view": "Tickets lesen", "tickets.create": "Tickets anlegen",
|
|
|
|
|
"tickets.edit": "Tickets ändern (Eckdaten, Sperren/Entsperren, Löschen)",
|
|
|
|
|
"licenses.view": "Lizenzen und Aktivierungsstatus lesen",
|
|
|
|
|
"licenses.create": "Lizenzen ausstellen",
|
|
|
|
|
"licenses.edit": "Lizenzen ändern (Deaktivieren/Widerrufen, erneut versenden)",
|
|
|
|
@@ -288,6 +298,8 @@ PERMISSION_LABELS = {
|
|
|
|
|
"groups.view": "Gruppen lesen", "groups.create": "Gruppen anlegen",
|
|
|
|
|
"groups.edit": "Gruppen ändern (inkl. Löschen)",
|
|
|
|
|
"settings_system.view": "Systemeinstellungen lesen", "settings_system.edit": "Systemeinstellungen ändern",
|
|
|
|
|
"settings_license.view": "Lizenzstatus ansehen",
|
|
|
|
|
"settings_license.edit": "Lizenzdatei hochladen sowie Lizenz aktivieren/deaktivieren (online oder per Code)",
|
|
|
|
|
"settings_importexport.view": "Im-/Export-Seite ansehen",
|
|
|
|
|
"settings_importexport.edit": "Daten importieren",
|
|
|
|
|
"settings_importexport.export": "Daten exportieren (Export-Datei enthält Passwörter im Klartext)",
|
|
|
|
@@ -320,8 +332,12 @@ DEFAULT_GROUP_PERMISSIONS = [
|
|
|
|
|
|
|
|
|
|
NAV_ITEMS = [
|
|
|
|
|
{"key": "index", "label": "Dashboard", "icon": "grid", "endpoint": "index"},
|
|
|
|
|
{"key": "tickets", "label": "Tickets", "icon": "key", "endpoint": "tickets_list"},
|
|
|
|
|
# Reihenfolge spiegelt bewusst die fachliche Hierarchie Kunde -> Ticket
|
|
|
|
|
# -> Lizenz wider -- jede Ebene eine eigene, direkt ueber die Navigation
|
|
|
|
|
# erreichbare Seite statt ineinander verschachtelter Detailansichten.
|
|
|
|
|
{"key": "customers", "label": "Kunden", "icon": "users", "endpoint": "customers"},
|
|
|
|
|
{"key": "tickets", "label": "Tickets", "icon": "key", "endpoint": "tickets_list"},
|
|
|
|
|
{"key": "licenses", "label": "Lizenzen", "icon": "shield", "endpoint": "licenses_list"},
|
|
|
|
|
{"key": "users", "label": "Benutzer", "icon": "users", "endpoint": "users"},
|
|
|
|
|
{"key": "groups", "label": "Gruppen", "icon": "groups", "endpoint": "groups"},
|
|
|
|
|
{"key": "settings_group", "label": "Einstellungen", "icon": "sliders", "children": [
|
|
|
|
@@ -345,6 +361,8 @@ def _nav_key_visible(key, user):
|
|
|
|
|
if key == "index":
|
|
|
|
|
return True
|
|
|
|
|
if key == "tickets":
|
|
|
|
|
return user.has_permission("tickets.view")
|
|
|
|
|
if key == "licenses":
|
|
|
|
|
return user.has_permission("licenses.view")
|
|
|
|
|
if key == "customers":
|
|
|
|
|
return user.can_manage_customers
|
|
|
|
@@ -355,10 +373,11 @@ def _nav_key_visible(key, user):
|
|
|
|
|
if key == "settings_system":
|
|
|
|
|
return user.can_view_settings_system
|
|
|
|
|
if key == "settings_license":
|
|
|
|
|
# Immer erreichbar für jeden mit Systemeinstellungen-Leserecht --
|
|
|
|
|
# muss auch OHNE Lizenz sichtbar bleiben, sonst könnte niemand
|
|
|
|
|
# jemals eine erste Lizenz hochladen/aktivieren.
|
|
|
|
|
return user.can_view_settings_system
|
|
|
|
|
# Eigenes Recht (settings_license.view), unabhängig von
|
|
|
|
|
# settings_system -- muss auch OHNE eine aktive Lizenz sichtbar
|
|
|
|
|
# bleiben (das ist eine andere Prüfung, siehe license_active()),
|
|
|
|
|
# sonst könnte niemand jemals eine erste Lizenz hochladen/aktivieren.
|
|
|
|
|
return user.can_view_settings_license
|
|
|
|
|
if key == "settings_importexport":
|
|
|
|
|
return user.can_view_settings_importexport
|
|
|
|
|
if key == "settings_ldap":
|
|
|
|
@@ -531,6 +550,12 @@ class User(UserMixin):
|
|
|
|
|
["customers.view", "customers.create", "customers.edit"]
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
@property
|
|
|
|
|
def can_manage_tickets(self):
|
|
|
|
|
return self.has_any_permission(
|
|
|
|
|
["tickets.view", "tickets.create", "tickets.edit"]
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
@property
|
|
|
|
|
def can_manage_licenses(self):
|
|
|
|
|
return self.has_any_permission(
|
|
|
|
@@ -553,6 +578,10 @@ class User(UserMixin):
|
|
|
|
|
def can_view_settings_system(self):
|
|
|
|
|
return self.has_permission("settings_system.view")
|
|
|
|
|
|
|
|
|
|
@property
|
|
|
|
|
def can_view_settings_license(self):
|
|
|
|
|
return self.has_permission("settings_license.view")
|
|
|
|
|
|
|
|
|
|
@property
|
|
|
|
|
def can_view_settings_importexport(self):
|
|
|
|
|
return self.has_any_permission([
|
|
|
|
@@ -580,7 +609,14 @@ class User(UserMixin):
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def get_db_connection():
|
|
|
|
|
conn = sqlite3.connect(DB_PATH)
|
|
|
|
|
# timeout=15 statt Python-Default 5s: reine Verteidigungslinie gegen
|
|
|
|
|
# kurze, legitime Ueberschneidungen zweier Schreibzugriffe (SQLite
|
|
|
|
|
# erlaubt nur EINEN Schreiber gleichzeitig) -- ersetzt NICHT die
|
|
|
|
|
# eigentliche Regel, niemals eine zweite Verbindung waehrend einer noch
|
|
|
|
|
# offenen Schreibtransaktion auf derselben zu committen (siehe
|
|
|
|
|
# _process_activate für ein Beispiel, wo genau das den Fehler
|
|
|
|
|
# "database is locked" ausgeloest hat).
|
|
|
|
|
conn = sqlite3.connect(DB_PATH, timeout=15)
|
|
|
|
|
conn.row_factory = sqlite3.Row
|
|
|
|
|
return conn
|
|
|
|
|
|
|
|
|
@@ -705,11 +741,14 @@ def _ensure_schema():
|
|
|
|
|
):
|
|
|
|
|
if _col not in customer_cols:
|
|
|
|
|
conn.execute(_ddl)
|
|
|
|
|
# Jeder Kunde braucht einen eigenen, dauerhaften Portal-Token fuer den
|
|
|
|
|
# kundenweiten Magic-Link (Kundenportal-Login ohne Passwort, siehe
|
|
|
|
|
# customer_portal()) -- bestehende Kunden (vor Einfuehrung dieses
|
|
|
|
|
# Felds) bekommen hier rueckwirkend einen zugewiesen, statt bis zur
|
|
|
|
|
# naechsten manuellen Bearbeitung ohne Portal-Zugang dazustehen.
|
|
|
|
|
# Historisch: ein dauerhafter Portal-Token pro Kunde (vorher Basis
|
|
|
|
|
# eines UNBEFRISTETEN Magic-Links). Dieser direkte, permanente Zugang
|
|
|
|
|
# wurde bewusst wieder entfernt -- der einzige Weg ins Kundenportal
|
|
|
|
|
# ist jetzt der zeitlich begrenzte Ablauf über portal_request() /
|
|
|
|
|
# portal_access() (siehe dort). Die Spalte samt Backfill bleibt
|
|
|
|
|
# bestehen (keine riskante Schema-Ruecknahme fuer reine Aufraeum-
|
|
|
|
|
# zwecke), wird aber fuer die Zugriffsentscheidung selbst nicht mehr
|
|
|
|
|
# herangezogen.
|
|
|
|
|
for _row in conn.execute("SELECT id FROM license_customers WHERE portal_token IS NULL OR portal_token=''").fetchall():
|
|
|
|
|
conn.execute(
|
|
|
|
|
"UPDATE license_customers SET portal_token=? WHERE id=?",
|
|
|
|
@@ -800,10 +839,10 @@ def _ensure_schema():
|
|
|
|
|
"Konnte idx_one_open_license_per_ticket nicht anlegen -- vermutlich hat mindestens ein "
|
|
|
|
|
"Ticket bereits mehr als eine offene Lizenz. Bitte manuell bereinigen (siehe licenses-Tabelle)."
|
|
|
|
|
)
|
|
|
|
|
# Analoger Backstop fuer den Kundenportal-Magic-Link: portal_token
|
|
|
|
|
# autorisiert komplett ohne Login (siehe customer_portal()), ein
|
|
|
|
|
# doppelt vergebener oder NULL-Token wuerde sonst stillschweigend die
|
|
|
|
|
# falsche Kundenzeile zurueckgeben bzw. den Kunden dauerhaft aussperren.
|
|
|
|
|
# Historisch (siehe Kommentar beim Backfill oben) -- portal_token wird
|
|
|
|
|
# fuer die eigentliche Zugriffsentscheidung nicht mehr genutzt, der
|
|
|
|
|
# Unique-Index bleibt trotzdem als harmlose Datenintegritaets-
|
|
|
|
|
# Absicherung bestehen.
|
|
|
|
|
try:
|
|
|
|
|
conn.execute(
|
|
|
|
|
"CREATE UNIQUE INDEX IF NOT EXISTS idx_customers_portal_token "
|
|
|
|
@@ -815,6 +854,25 @@ def _ensure_schema():
|
|
|
|
|
"portal_token. Bitte manuell bereinigen (siehe license_customers-Tabelle)."
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
# Kurzlebige, EINMAL nutzbare Zugangs-Tokens fuer /portal/request (siehe
|
|
|
|
|
# dortiger Docstring): anders als der dauerhafte portal_token (oben,
|
|
|
|
|
# von Admins ueber die Ticket-/Kundenseite verteilt, bewusst
|
|
|
|
|
# unbefristet) ist DIESER Weg oeffentlich von JEDEM auf blossen
|
|
|
|
|
# Zuruf einer E-Mail-Adresse ausloesbar -- ein zusaetzliches
|
|
|
|
|
# zeitliches Sicherheitsnetz ist hier angemessen, waehrend die
|
|
|
|
|
# bereits etablierten, admin-verteilten Links (Ticket-Seite,
|
|
|
|
|
# Lizenz-per-E-Mail) unveraendert dauerhaft bleiben.
|
|
|
|
|
conn.execute("""
|
|
|
|
|
CREATE TABLE IF NOT EXISTS portal_access_tokens (
|
|
|
|
|
token TEXT PRIMARY KEY,
|
|
|
|
|
customer_id INTEGER NOT NULL,
|
|
|
|
|
created_at TEXT NOT NULL,
|
|
|
|
|
expires_at TEXT NOT NULL,
|
|
|
|
|
used_at TEXT,
|
|
|
|
|
FOREIGN KEY (customer_id) REFERENCES license_customers(id)
|
|
|
|
|
)
|
|
|
|
|
""")
|
|
|
|
|
|
|
|
|
|
# Rückwirkend ein Ticket für jede Lizenz nachbilden, die vor Einführung
|
|
|
|
|
# des Ticket-Konzepts direkt ausgestellt wurde (ticket_id noch NULL) --
|
|
|
|
|
# sonst würden genau diese Lizenzen (auf einer echten Installation z.B.
|
|
|
|
@@ -842,6 +900,64 @@ def _ensure_schema():
|
|
|
|
|
conn.execute("UPDATE licenses SET ticket_id=? WHERE license_id=?", (ticket_id, lic["license_id"]))
|
|
|
|
|
conn.execute("INSERT OR IGNORE INTO settings (key, value) VALUES (?, '1')", (_migration_key_tickets,))
|
|
|
|
|
|
|
|
|
|
_migration_key_license_perm = "_migrated_settings_license_permission_v1"
|
|
|
|
|
if not conn.execute("SELECT 1 FROM settings WHERE key=?", (_migration_key_license_perm,)).fetchone():
|
|
|
|
|
# "Lizenz" (settings_license) hatte bislang KEIN eigenes Recht --
|
|
|
|
|
# die Seite lief komplett über settings_system.view/.edit mit.
|
|
|
|
|
# Backfill: jede Gruppe, die settings_system.view/.edit bereits
|
|
|
|
|
# hatte, bekommt automatisch das neue, gespiegelte
|
|
|
|
|
# settings_license.view/.edit dazu -- ohne diesen Schritt würden
|
|
|
|
|
# bestehende Gruppen beim Update stillschweigend den Zugriff auf
|
|
|
|
|
# die Lizenzseite verlieren, den sie vorher implizit hatten.
|
|
|
|
|
_system_to_license = {
|
|
|
|
|
"settings_system.view": "settings_license.view",
|
|
|
|
|
"settings_system.edit": "settings_license.edit",
|
|
|
|
|
}
|
|
|
|
|
for system_perm, license_perm in _system_to_license.items():
|
|
|
|
|
rows = conn.execute(
|
|
|
|
|
"SELECT DISTINCT group_id FROM group_permissions WHERE permission=?", (system_perm,)
|
|
|
|
|
).fetchall()
|
|
|
|
|
for row in rows:
|
|
|
|
|
conn.execute(
|
|
|
|
|
"INSERT OR IGNORE INTO group_permissions (group_id, permission) VALUES (?, ?)",
|
|
|
|
|
(row["group_id"], license_perm),
|
|
|
|
|
)
|
|
|
|
|
conn.execute(
|
|
|
|
|
"INSERT OR IGNORE INTO settings (key, value) VALUES (?, '1')", (_migration_key_license_perm,)
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
_migration_key_tickets_perm = "_migrated_tickets_permission_v1"
|
|
|
|
|
if not conn.execute("SELECT 1 FROM settings WHERE key=?", (_migration_key_tickets_perm,)).fetchone():
|
|
|
|
|
# "Tickets" hatte bislang KEIN eigenes Recht -- Ticketverwaltung
|
|
|
|
|
# (anlegen/bearbeiten/sperren/loeschen) lief komplett ueber
|
|
|
|
|
# licenses.view/.create/.edit mit, obwohl Tickets ein eigener,
|
|
|
|
|
# gleichberechtigter Navigationspunkt neben Kunden und Lizenzen
|
|
|
|
|
# ist (genau wie bei TESM Clients/Switche/Zugangsdaten trotz enger
|
|
|
|
|
# fachlicher Verwandtschaft jeweils eigene Rechte haben). Backfill:
|
|
|
|
|
# jede Gruppe mit licenses.view/.create/.edit bekommt automatisch
|
|
|
|
|
# das gespiegelte tickets.view/.create/.edit dazu -- das
|
|
|
|
|
# Ausstellen einer Lizenz AUS einem Ticket heraus bleibt bewusst
|
|
|
|
|
# weiterhin an licenses.edit gebunden (siehe ticket_detail()),
|
|
|
|
|
# nur Sperren/Entsperren/Bearbeiten/Loeschen des Tickets selbst
|
|
|
|
|
# wandert auf das neue, unabhaengige Recht.
|
|
|
|
|
_license_to_ticket = {
|
|
|
|
|
"licenses.view": "tickets.view",
|
|
|
|
|
"licenses.create": "tickets.create",
|
|
|
|
|
"licenses.edit": "tickets.edit",
|
|
|
|
|
}
|
|
|
|
|
for license_perm, ticket_perm in _license_to_ticket.items():
|
|
|
|
|
rows = conn.execute(
|
|
|
|
|
"SELECT DISTINCT group_id FROM group_permissions WHERE permission=?", (license_perm,)
|
|
|
|
|
).fetchall()
|
|
|
|
|
for row in rows:
|
|
|
|
|
conn.execute(
|
|
|
|
|
"INSERT OR IGNORE INTO group_permissions (group_id, permission) VALUES (?, ?)",
|
|
|
|
|
(row["group_id"], ticket_perm),
|
|
|
|
|
)
|
|
|
|
|
conn.execute(
|
|
|
|
|
"INSERT OR IGNORE INTO settings (key, value) VALUES (?, '1')", (_migration_key_tickets_perm,)
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
_migration_key_old_logs = "_cleaned_up_legacy_rpi_log_files_v1"
|
|
|
|
|
if not conn.execute("SELECT 1 FROM settings WHERE key=?", (_migration_key_old_logs,)).fetchone():
|
|
|
|
|
for stale_log in glob.glob("/var/log/rpi-*.log"):
|
|
|
|
@@ -1942,6 +2058,23 @@ def _get_master_endpoint():
|
|
|
|
|
return get_setting("master_endpoint", "")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def _customer_facing_url(endpoint, **values):
|
|
|
|
|
"""Baut eine externe URL fuer an KUNDEN gerichtete Magic-Links (Self-
|
|
|
|
|
Service, Kundenportal-Anfrage/-Zugang, Lizenz-per-E-Mail) auf Basis
|
|
|
|
|
des admin-gepflegten Lizenzserver-Endpunkts (siehe _get_master_endpoint(),
|
|
|
|
|
Einstellungen -> Lizenz -> Anbieter & Lizenzserver) -- NICHT per
|
|
|
|
|
url_for(..., _external=True), das stattdessen den Host-Header der
|
|
|
|
|
GERADE laufenden Anfrage verwendet und damit z.B. die interne IP
|
|
|
|
|
zeigt, ueber die zufaellig der Admin gerade eingeloggt ist, statt der
|
|
|
|
|
fuer Kunden eigentlich gedachten oeffentlichen Domain. Faellt auf die
|
|
|
|
|
normale request-basierte externe URL zurueck, wenn der Endpunkt noch
|
|
|
|
|
nicht konfiguriert ist (z.B. auf einer frischen Installation)."""
|
|
|
|
|
base = _get_master_endpoint().rstrip("/")
|
|
|
|
|
if not base:
|
|
|
|
|
return url_for(endpoint, _external=True, **values)
|
|
|
|
|
return base + url_for(endpoint, **values)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def _customer_row(conn, customer_id):
|
|
|
|
|
return conn.execute("SELECT * FROM license_customers WHERE id=?", (customer_id,)).fetchone()
|
|
|
|
|
|
|
|
|
@@ -2202,19 +2335,33 @@ def _process_activate(data):
|
|
|
|
|
"SELECT license_id, customer_id FROM licenses WHERE fingerprint=? AND status='active' AND license_id!=?",
|
|
|
|
|
(fingerprint, license_id),
|
|
|
|
|
).fetchall()
|
|
|
|
|
# log_action_system() oeffnet INTERN eine EIGENE, zweite Verbindung und
|
|
|
|
|
# committet sofort -- solange `conn` hier noch eine offene Schreib-
|
|
|
|
|
# transaktion haelt (erstes UPDATE oben, noch nicht committet), wuerde
|
|
|
|
|
# dieser zweite Commit-Versuch auf sich selbst warten (SQLite erlaubt
|
|
|
|
|
# nur EINEN Schreiber gleichzeitig) und nach Ablauf des Busy-Timeouts
|
|
|
|
|
# mit "database is locked" fehlschlagen -- live reproduziert beim
|
|
|
|
|
# Aktivieren einer Lizenz, die eine andere fuer denselben Fingerprint
|
|
|
|
|
# ersetzt. Deshalb werden die Log-Eintraege hier nur VORGEMERKT (reine
|
|
|
|
|
# Lesezugriffe auf `conn` sind unproblematisch, nur der schreibende
|
|
|
|
|
# log_action_system()-Aufruf selbst muss warten) und dann als allerletzter
|
|
|
|
|
# Schritt nach `conn.commit()`/`conn.close()` unten nachgeholt.
|
|
|
|
|
superseded_logs = []
|
|
|
|
|
for old in superseded:
|
|
|
|
|
conn.execute(
|
|
|
|
|
"UPDATE licenses SET status='deactivated', deactivated_at=? WHERE license_id=?",
|
|
|
|
|
(now, old["license_id"]),
|
|
|
|
|
)
|
|
|
|
|
old_customer = _customer_row(conn, old["customer_id"])
|
|
|
|
|
log_action_system(
|
|
|
|
|
"license.superseded", old_customer["name"] if old_customer else old["license_id"],
|
|
|
|
|
superseded_logs.append((
|
|
|
|
|
old_customer["name"] if old_customer else old["license_id"],
|
|
|
|
|
f"Automatisch deaktiviert -- Fingerprint {fingerprint} hat jetzt Lizenz {license_id} aktiviert.",
|
|
|
|
|
)
|
|
|
|
|
))
|
|
|
|
|
conn.commit()
|
|
|
|
|
customer = _customer_row(conn, row["customer_id"])
|
|
|
|
|
conn.close()
|
|
|
|
|
for target, details in superseded_logs:
|
|
|
|
|
log_action_system("license.superseded", target, details)
|
|
|
|
|
log_action_system("license.activated_remote", customer["name"] if customer else license_id, f"Fingerprint {fingerprint}")
|
|
|
|
|
return licensing.build_master_response("activated", license_id, fingerprint, MASTER_PRIVATE_KEY, status="ok"), 200
|
|
|
|
|
|
|
|
|
@@ -2439,9 +2586,11 @@ def customers():
|
|
|
|
|
return redirect(url_for("customers"))
|
|
|
|
|
|
|
|
|
|
customers_rows = conn.execute("""
|
|
|
|
|
SELECT license_customers.*, COUNT(DISTINCT license_tickets.id) AS ticket_count
|
|
|
|
|
SELECT license_customers.*, COUNT(DISTINCT license_tickets.id) AS ticket_count,
|
|
|
|
|
COUNT(DISTINCT licenses.id) AS license_count
|
|
|
|
|
FROM license_customers
|
|
|
|
|
LEFT JOIN license_tickets ON license_tickets.customer_id = license_customers.id
|
|
|
|
|
LEFT JOIN licenses ON licenses.customer_id = license_customers.id
|
|
|
|
|
GROUP BY license_customers.id
|
|
|
|
|
ORDER BY license_customers.name COLLATE NOCASE
|
|
|
|
|
""").fetchall()
|
|
|
|
@@ -2460,7 +2609,7 @@ def ticket_new():
|
|
|
|
|
Lizenz mit bestimmten Eckdaten. Erstellt bewusst noch KEINE Lizenz;
|
|
|
|
|
das übernimmt ein separater Schritt auf der Ticket-Detailseite (durch
|
|
|
|
|
Admin ODER Kunde per Self-Service)."""
|
|
|
|
|
if not current_user.has_permission("licenses.create"):
|
|
|
|
|
if not current_user.has_permission("tickets.create"):
|
|
|
|
|
flash("Keine Berechtigung, Tickets anzulegen.", "danger")
|
|
|
|
|
return redirect(url_for("index"))
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
@@ -2531,7 +2680,7 @@ def ticket_new():
|
|
|
|
|
@app.route("/tickets/<ticket_id>", methods=["GET", "POST"])
|
|
|
|
|
@login_required
|
|
|
|
|
def ticket_detail(ticket_id):
|
|
|
|
|
if not current_user.can_manage_licenses:
|
|
|
|
|
if not current_user.can_manage_tickets:
|
|
|
|
|
flash("Keine Berechtigung.", "danger")
|
|
|
|
|
return redirect(url_for("index"))
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
@@ -2542,10 +2691,14 @@ def ticket_detail(ticket_id):
|
|
|
|
|
return redirect(url_for("index"))
|
|
|
|
|
|
|
|
|
|
if request.method == "POST":
|
|
|
|
|
if not current_user.has_permission("licenses.edit"):
|
|
|
|
|
flash("Keine Berechtigung.", "danger")
|
|
|
|
|
elif "issue_license" in request.form:
|
|
|
|
|
if not license_active():
|
|
|
|
|
if "issue_license" in request.form:
|
|
|
|
|
# Ausstellen erzeugt eine LIZENZ (nicht nur eine Ticket-Aenderung)
|
|
|
|
|
# -- bewusst weiterhin ueber das Lizenz-Recht gegated, nicht ueber
|
|
|
|
|
# tickets.edit, damit sich "Tickets verwalten" und "Lizenzen
|
|
|
|
|
# ausstellen" unabhaengig voneinander vergeben lassen.
|
|
|
|
|
if not current_user.has_permission("licenses.edit"):
|
|
|
|
|
flash("Keine Berechtigung, Lizenzen auszustellen.", "danger")
|
|
|
|
|
elif not license_active():
|
|
|
|
|
flash("Der Lizenzserver selbst hat keine gültige Lizenz -- Ausstellen ist deaktiviert.", "danger")
|
|
|
|
|
elif ticket["status"] != "open":
|
|
|
|
|
flash("Ticket ist gesperrt.", "danger")
|
|
|
|
@@ -2558,15 +2711,18 @@ def ticket_detail(ticket_id):
|
|
|
|
|
flash("Lizenz ausgestellt.", "success")
|
|
|
|
|
return redirect(url_for("license_detail", license_id=license_file["license_id"]))
|
|
|
|
|
elif "toggle_block" in request.form:
|
|
|
|
|
new_status = "blocked" if ticket["status"] == "open" else "open"
|
|
|
|
|
conn.execute("UPDATE license_tickets SET status=? WHERE id=?", (new_status, ticket_id))
|
|
|
|
|
conn.commit()
|
|
|
|
|
customer = _customer_row(conn, ticket["customer_id"])
|
|
|
|
|
log_action(
|
|
|
|
|
"ticket.block" if new_status == "blocked" else "ticket.unblock",
|
|
|
|
|
customer["name"] if customer else ticket_id,
|
|
|
|
|
)
|
|
|
|
|
flash("Ticket gesperrt." if new_status == "blocked" else "Ticket entsperrt.", "success")
|
|
|
|
|
if not current_user.has_permission("tickets.edit"):
|
|
|
|
|
flash("Keine Berechtigung, Tickets zu sperren/entsperren.", "danger")
|
|
|
|
|
else:
|
|
|
|
|
new_status = "blocked" if ticket["status"] == "open" else "open"
|
|
|
|
|
conn.execute("UPDATE license_tickets SET status=? WHERE id=?", (new_status, ticket_id))
|
|
|
|
|
conn.commit()
|
|
|
|
|
customer = _customer_row(conn, ticket["customer_id"])
|
|
|
|
|
log_action(
|
|
|
|
|
"ticket.block" if new_status == "blocked" else "ticket.unblock",
|
|
|
|
|
customer["name"] if customer else ticket_id,
|
|
|
|
|
)
|
|
|
|
|
flash("Ticket gesperrt." if new_status == "blocked" else "Ticket entsperrt.", "success")
|
|
|
|
|
conn.close()
|
|
|
|
|
return redirect(url_for("ticket_detail", ticket_id=ticket_id))
|
|
|
|
|
|
|
|
|
@@ -2584,9 +2740,10 @@ def ticket_detail(ticket_id):
|
|
|
|
|
license_types=licensing.LICENSE_TYPES, all_modules=licensing.ALL_MODULES,
|
|
|
|
|
type_labels=LICENSE_TYPE_LABELS, module_labels=MODULE_LABELS,
|
|
|
|
|
master_licensed=license_active(),
|
|
|
|
|
self_service_url=url_for("self_service", ticket_id=ticket_id, _external=True),
|
|
|
|
|
portal_url=url_for("customer_portal", token=customer["portal_token"], _external=True) if customer and customer["portal_token"] else None,
|
|
|
|
|
can_edit=current_user.has_permission("licenses.edit"),
|
|
|
|
|
self_service_url=_customer_facing_url("self_service", ticket_id=ticket_id),
|
|
|
|
|
portal_request_url=_customer_facing_url("portal_request"),
|
|
|
|
|
can_edit_ticket=current_user.has_permission("tickets.edit"),
|
|
|
|
|
can_issue_license=current_user.has_permission("licenses.edit"),
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@@ -2602,7 +2759,7 @@ def ticket_edit(ticket_id):
|
|
|
|
|
hier bewusst nicht vorgesehen (das Self-Service-Ticket ist an genau
|
|
|
|
|
diesen Kunden gebunden, u.a. weil er ueber dessen Portal-Token
|
|
|
|
|
erreichbar ist)."""
|
|
|
|
|
if not current_user.has_permission("licenses.edit"):
|
|
|
|
|
if not current_user.has_permission("tickets.edit"):
|
|
|
|
|
flash("Keine Berechtigung, Tickets zu bearbeiten.", "danger")
|
|
|
|
|
return redirect(url_for("tickets_list"))
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
@@ -2655,7 +2812,7 @@ def ticket_delete(ticket_id):
|
|
|
|
|
System verschwinden). Etwaige bereits widerrufene/deaktivierte
|
|
|
|
|
Lizenzen darunter sind reine Historie und werden mitgeloescht, sonst
|
|
|
|
|
blieben verwaiste Zeilen mit einer toten ticket_id zurueck."""
|
|
|
|
|
if not current_user.has_permission("licenses.edit"):
|
|
|
|
|
if not current_user.has_permission("tickets.edit"):
|
|
|
|
|
flash("Keine Berechtigung, Tickets zu löschen.", "danger")
|
|
|
|
|
return redirect(url_for("tickets_list"))
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
@@ -2825,14 +2982,16 @@ def license_send_email(license_id):
|
|
|
|
|
return redirect(url_for("license_detail", license_id=license_id))
|
|
|
|
|
self_service_note = ""
|
|
|
|
|
if row["ticket_id"]:
|
|
|
|
|
self_service_url = url_for("self_service", ticket_id=row["ticket_id"], _external=True)
|
|
|
|
|
self_service_url = _customer_facing_url("self_service", ticket_id=row["ticket_id"])
|
|
|
|
|
self_service_note = (
|
|
|
|
|
f"\nÜber diesen Link können Sie Ihre Lizenz jederzeit selbst herunterladen, "
|
|
|
|
|
f"widerrufen oder (z.B. nach einem Systemwechsel) neu erstellen:\n{self_service_url}\n"
|
|
|
|
|
)
|
|
|
|
|
if customer["portal_token"]:
|
|
|
|
|
portal_url = url_for("customer_portal", token=customer["portal_token"], _external=True)
|
|
|
|
|
self_service_note += f"\nEine Übersicht all Ihrer Tickets/Lizenzen finden Sie hier:\n{portal_url}\n"
|
|
|
|
|
portal_request_url = _customer_facing_url("portal_request")
|
|
|
|
|
self_service_note += (
|
|
|
|
|
f"\nEine Übersicht all Ihrer Tickets/Lizenzen können Sie sich jederzeit unter folgendem Link per "
|
|
|
|
|
f"E-Mail zuschicken lassen:\n{portal_request_url}\n"
|
|
|
|
|
)
|
|
|
|
|
valid_until = "unbegrenzt (Lifetime)" if row["lifetime"] else row["expires_at"]
|
|
|
|
|
try:
|
|
|
|
|
_graph_send_mail(
|
|
|
|
@@ -2927,7 +3086,7 @@ def self_service(ticket_id):
|
|
|
|
|
license=_license_dict_for_display(current) if current else None,
|
|
|
|
|
can_issue_new=can_issue_new,
|
|
|
|
|
type_labels=LICENSE_TYPE_LABELS, module_labels=MODULE_LABELS,
|
|
|
|
|
portal_url=url_for("customer_portal", token=customer["portal_token"]) if customer and customer["portal_token"] else None,
|
|
|
|
|
portal_request_url=url_for("portal_request"),
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@@ -2993,25 +3152,84 @@ def self_service_issue(ticket_id):
|
|
|
|
|
return redirect(url_for("self_service", ticket_id=ticket_id))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@app.route("/portal/<token>", methods=["GET", "POST"])
|
|
|
|
|
def customer_portal(token):
|
|
|
|
|
"""Kundenweites Self-Service-Portal -- anders als /self-service/<ticket_id>
|
|
|
|
|
(ein Magic-Link PRO TICKET) ist dieser Link PRO KUNDE: zeigt alle
|
|
|
|
|
eigenen Tickets samt aktueller Lizenz auf einen Blick und erlaubt dem
|
|
|
|
|
Kunden, seine eigenen Kontakt-/Anschriftdaten selbst zu pflegen.
|
|
|
|
|
Bewusst NICHT bearbeitbar: Firmenname sowie die kommerziellen
|
|
|
|
|
Ticket-Eckdaten (Typ/Module/Laufzeit) -- das bleibt Sache des Anbieters.
|
|
|
|
|
Fuer die eigentlichen Lizenzaktionen (herunterladen/widerrufen/neu
|
|
|
|
|
erstellen) verlinkt jede Ticket-Zeile auf deren bestehende
|
|
|
|
|
/self-service/<ticket_id>-Seite, statt die Logik hier zu duplizieren.
|
|
|
|
|
Kein Login noetig -- Autorisierung ausschliesslich durch Besitz des
|
|
|
|
|
unerratbaren Tokens (siehe license_customers.portal_token)."""
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
|
customer = conn.execute("SELECT * FROM license_customers WHERE portal_token=?", (token,)).fetchone()
|
|
|
|
|
if not customer:
|
|
|
|
|
conn.close()
|
|
|
|
|
abort(404)
|
|
|
|
|
@app.route("/portal/request", methods=["GET", "POST"])
|
|
|
|
|
def portal_request():
|
|
|
|
|
"""Oeffentlich erreichbar (kein Login): fuer einen Kunden, der seinen
|
|
|
|
|
Magic-Link verloren hat oder nie einen bekommen hat (z.B. weil er nur
|
|
|
|
|
telefonisch beim Anbieter bekannt ist), gibt es sonst KEINEN Weg
|
|
|
|
|
zurueck ins Kundenportal ausser einen Admin zu kontaktieren -- diese
|
|
|
|
|
Seite schliesst die Luecke: E-Mail-Adresse eingeben, Link wird (falls
|
|
|
|
|
hinterlegt) zugeschickt. Werkzeug routet die literale Regel
|
|
|
|
|
/portal/request bevorzugt vor der dynamischen /portal/<token> weiter
|
|
|
|
|
unten -- keine Kollisionsgefahr mit einem Kunden, dessen Token
|
|
|
|
|
zufaellig 'request' laeutet waere ohnehin praktisch ausgeschlossen
|
|
|
|
|
(192 Bit Zufall).
|
|
|
|
|
|
|
|
|
|
Zeigt IMMER dieselbe generische Erfolgsmeldung, unabhaengig davon, ob
|
|
|
|
|
die eingegebene Adresse tatsaechlich zu einem Kunden gehoert --
|
|
|
|
|
verhindert, dass sich ueber die Antwort erraten laesst, welche
|
|
|
|
|
E-Mail-Adressen im System hinterlegt sind.
|
|
|
|
|
|
|
|
|
|
Bewusst OHNE dauerhaften Portal-Link (der wurde entfernt, genau weil
|
|
|
|
|
dieser Weg OEFFENTLICH von jedem auf blossen Zuruf einer E-Mail-
|
|
|
|
|
Adresse ausloesbar ist): stattdessen ein frischer, einmalig nutzbarer,
|
|
|
|
|
nur PORTAL_ACCESS_LINK_MINUTES gueltiger Zugangs-Token (siehe
|
|
|
|
|
portal_access())."""
|
|
|
|
|
if request.method == "POST":
|
|
|
|
|
email = request.form.get("email", "").strip()
|
|
|
|
|
if email:
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
|
customer = conn.execute(
|
|
|
|
|
"SELECT * FROM license_customers WHERE contact_email IS NOT NULL AND lower(contact_email) = lower(?)",
|
|
|
|
|
(email,),
|
|
|
|
|
).fetchone()
|
|
|
|
|
if customer:
|
|
|
|
|
now = datetime.now()
|
|
|
|
|
grant_token = secrets.token_urlsafe(32)
|
|
|
|
|
conn.execute(
|
|
|
|
|
"INSERT INTO portal_access_tokens (token, customer_id, created_at, expires_at) VALUES (?, ?, ?, ?)",
|
|
|
|
|
(grant_token, customer["id"], now.strftime("%Y-%m-%d %H:%M:%S"),
|
|
|
|
|
(now + timedelta(minutes=PORTAL_ACCESS_LINK_MINUTES)).strftime("%Y-%m-%d %H:%M:%S")),
|
|
|
|
|
)
|
|
|
|
|
conn.commit()
|
|
|
|
|
access_url = _customer_facing_url("portal_access", token=grant_token)
|
|
|
|
|
try:
|
|
|
|
|
_graph_send_mail(
|
|
|
|
|
customer["contact_email"],
|
|
|
|
|
"Ihr Zugang zum TESM-Kundenportal",
|
|
|
|
|
"Hallo,\n\n"
|
|
|
|
|
"über folgenden Link erreichen Sie für kurze Zeit eine Übersicht Ihrer Tickets und Lizenzen "
|
|
|
|
|
"und können Ihre Kontaktdaten selbst pflegen:\n"
|
|
|
|
|
f"{access_url}\n\n"
|
|
|
|
|
f"Dieser Link ist nur {PORTAL_ACCESS_LINK_MINUTES} Minuten lang gültig und danach nicht "
|
|
|
|
|
"mehr nutzbar -- falls er abläuft, fordern Sie bitte einfach einen neuen an. "
|
|
|
|
|
"Bitte nicht an Dritte weitergeben.",
|
|
|
|
|
)
|
|
|
|
|
log_action_system("customer.portal_link_requested", customer["name"])
|
|
|
|
|
except Exception:
|
|
|
|
|
# Absichtlich NICHT an den Nutzer durchgereicht (siehe Docstring,
|
|
|
|
|
# Anti-Enumeration) -- aber fuer den Admin sichtbar loggen, sonst
|
|
|
|
|
# merkt niemand, dass z.B. Microsoft Graph nicht konfiguriert ist.
|
|
|
|
|
app.logger.error("Versand des Kundenportal-Links fehlgeschlagen:\n%s", traceback.format_exc())
|
|
|
|
|
conn.close()
|
|
|
|
|
flash(
|
|
|
|
|
"Falls diese E-Mail-Adresse bei uns hinterlegt ist, wurde soeben eine Nachricht mit einem "
|
|
|
|
|
f"{PORTAL_ACCESS_LINK_MINUTES} Minuten gültigen Zugangslink verschickt.",
|
|
|
|
|
"success",
|
|
|
|
|
)
|
|
|
|
|
return redirect(url_for("portal_request"))
|
|
|
|
|
return render_template("portal_request.html")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def _render_customer_portal(customer):
|
|
|
|
|
"""GET/POST-Logik des Kundenportals -- Zugriff ausschliesslich ueber
|
|
|
|
|
die zeitlich begrenzte Session nach einem frisch angeforderten
|
|
|
|
|
Magic-Link (siehe portal_request()/portal_access()/
|
|
|
|
|
customer_portal_session()). Es gibt bewusst KEINEN dauerhaften,
|
|
|
|
|
direkt aufrufbaren Portal-Link mehr -- `customer` ist hier bereits
|
|
|
|
|
als authentisch geprueft (Aufrufer hat eine gueltige Session
|
|
|
|
|
verifiziert), diese Funktion selbst prueft nichts mehr davon."""
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
|
if request.method == "POST":
|
|
|
|
|
contact_email = request.form.get("contact_email", "").strip()
|
|
|
|
|
if not _EMAIL_RE.match(contact_email):
|
|
|
|
@@ -3028,7 +3246,7 @@ def customer_portal(token):
|
|
|
|
|
log_action_system("customer.update", customer["name"], "Kunde hat eigene Kontaktdaten im Portal aktualisiert")
|
|
|
|
|
flash("Ihre Daten wurden aktualisiert.", "success")
|
|
|
|
|
conn.close()
|
|
|
|
|
return redirect(url_for("customer_portal", token=token))
|
|
|
|
|
return redirect(url_for("customer_portal_session"))
|
|
|
|
|
|
|
|
|
|
now = time.time()
|
|
|
|
|
tickets_view = []
|
|
|
|
@@ -3045,6 +3263,81 @@ def customer_portal(token):
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
PORTAL_ACCESS_LINK_MINUTES = 30
|
|
|
|
|
PORTAL_SESSION_MINUTES = 60
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@app.route("/portal/access/<token>")
|
|
|
|
|
def portal_access(token):
|
|
|
|
|
"""Loest den kurzlebigen, EINMAL nutzbaren Link aus einer per
|
|
|
|
|
portal_request() angeforderten E-Mail ein -- gueltig fuer
|
|
|
|
|
PORTAL_ACCESS_LINK_MINUTES ab Anforderung, danach oder nach dem
|
|
|
|
|
ersten Aufruf nicht mehr nutzbar. Bei Erfolg wird eine Session
|
|
|
|
|
gesetzt, die ihrerseits nach PORTAL_SESSION_MINUTES ohne neue
|
|
|
|
|
Anforderung automatisch ablaeuft (siehe customer_portal_session()) --
|
|
|
|
|
zwei getrennte Zeitfenster: eines fuer den Link selbst (muss zeitnah
|
|
|
|
|
angeklickt werden), eines fuer die resultierende Sitzung (muss danach
|
|
|
|
|
zeitnah genutzt werden)."""
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
|
grant = conn.execute("SELECT * FROM portal_access_tokens WHERE token=?", (token,)).fetchone()
|
|
|
|
|
valid = bool(grant) and not grant["used_at"]
|
|
|
|
|
if valid:
|
|
|
|
|
try:
|
|
|
|
|
valid = datetime.now() < datetime.strptime(grant["expires_at"], "%Y-%m-%d %H:%M:%S")
|
|
|
|
|
except ValueError:
|
|
|
|
|
valid = False
|
|
|
|
|
if not valid:
|
|
|
|
|
conn.close()
|
|
|
|
|
flash("Dieser Link ist ungültig oder abgelaufen. Bitte fordern Sie einen neuen an.", "danger")
|
|
|
|
|
return redirect(url_for("portal_request"))
|
|
|
|
|
conn.execute(
|
|
|
|
|
"UPDATE portal_access_tokens SET used_at=? WHERE token=?",
|
|
|
|
|
(datetime.now().strftime("%Y-%m-%d %H:%M:%S"), token),
|
|
|
|
|
)
|
|
|
|
|
conn.commit()
|
|
|
|
|
customer = _customer_row(conn, grant["customer_id"])
|
|
|
|
|
conn.close()
|
|
|
|
|
if not customer:
|
|
|
|
|
flash("Dieser Zugang ist nicht mehr gültig.", "danger")
|
|
|
|
|
return redirect(url_for("portal_request"))
|
|
|
|
|
session["portal_customer_id"] = customer["id"]
|
|
|
|
|
session["portal_session_expires_at"] = (
|
|
|
|
|
datetime.now() + timedelta(minutes=PORTAL_SESSION_MINUTES)
|
|
|
|
|
).strftime("%Y-%m-%d %H:%M:%S")
|
|
|
|
|
log_action_system("customer.portal_link_used", customer["name"])
|
|
|
|
|
return redirect(url_for("customer_portal_session"))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@app.route("/portal/me", methods=["GET", "POST"])
|
|
|
|
|
def customer_portal_session():
|
|
|
|
|
"""Session-basierter Kundenportal-Zugang nach einem frisch
|
|
|
|
|
angeforderten Magic-Link (portal_request() -> portal_access()) --
|
|
|
|
|
laeuft PORTAL_SESSION_MINUTES nach dem Anklicken des Links automatisch
|
|
|
|
|
ab, im Unterschied zum dauerhaften /portal/<token> (siehe dortiger
|
|
|
|
|
Docstring)."""
|
|
|
|
|
customer_id = session.get("portal_customer_id")
|
|
|
|
|
expires_at_str = session.get("portal_session_expires_at")
|
|
|
|
|
valid = False
|
|
|
|
|
if customer_id and expires_at_str:
|
|
|
|
|
try:
|
|
|
|
|
valid = datetime.now() < datetime.strptime(expires_at_str, "%Y-%m-%d %H:%M:%S")
|
|
|
|
|
except ValueError:
|
|
|
|
|
valid = False
|
|
|
|
|
if not valid:
|
|
|
|
|
session.pop("portal_customer_id", None)
|
|
|
|
|
session.pop("portal_session_expires_at", None)
|
|
|
|
|
flash("Ihre Sitzung ist abgelaufen -- bitte fordern Sie einen neuen Zugangslink an.", "danger")
|
|
|
|
|
return redirect(url_for("portal_request"))
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
|
customer = _customer_row(conn, customer_id)
|
|
|
|
|
conn.close()
|
|
|
|
|
if not customer:
|
|
|
|
|
session.pop("portal_customer_id", None)
|
|
|
|
|
session.pop("portal_session_expires_at", None)
|
|
|
|
|
abort(404)
|
|
|
|
|
return _render_customer_portal(customer)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def _audit_archive_loop():
|
|
|
|
|
"""Prüft einmal täglich (siehe AUDIT_ARCHIVE_CHECK_INTERVAL_SECONDS), ob
|
|
|
|
|
die audit_log-Tabelle den Schwellenwert überschritten hat, und
|
|
|
|
@@ -3417,6 +3710,7 @@ def inject_license_topbar():
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@app.route("/")
|
|
|
|
|
@login_required
|
|
|
|
|
def index():
|
|
|
|
|
"""Dashboard des Master-Lizenzservers -- eine rein informative Kachel-
|
|
|
|
|
uebersicht der gerade AKTIVEN Lizenzen (analog zur Geraete-Kachel-
|
|
|
|
@@ -3426,8 +3720,15 @@ def index():
|
|
|
|
|
mit status='active' -- alles andere (Tickets anlegen/bearbeiten/
|
|
|
|
|
loeschen, Lizenzen ausstellen/widerrufen/loeschen) ist Verwaltung und
|
|
|
|
|
lebt seit der Kachel-Umstellung auf der eigenen Tickets-Seite
|
|
|
|
|
(tickets_list())."""
|
|
|
|
|
if not current_user.is_authenticated or not current_user.has_permission("licenses.view"):
|
|
|
|
|
(tickets_list()).
|
|
|
|
|
|
|
|
|
|
@login_required (anders als bei TESM selbst, wo das Geraete-Dashboard
|
|
|
|
|
bewusst auch ohne Login als reines Status-Board sichtbar bleibt): der
|
|
|
|
|
Lizenzserver ist reines internes Verwaltungswerkzeug -- ein anonymer
|
|
|
|
|
Besuch auf '/' soll immer zuerst auf die Login-Seite treffen (via
|
|
|
|
|
login_manager.login_view), nicht auf einen 'bitte anmelden'-Platzhalter
|
|
|
|
|
innerhalb der Dashboard-Huelle."""
|
|
|
|
|
if not current_user.has_permission("licenses.view"):
|
|
|
|
|
return render_template("index.html", buckets=None)
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
|
active_rows = conn.execute("""
|
|
|
|
@@ -3463,7 +3764,7 @@ def tickets_list():
|
|
|
|
|
Dashboards auf eine rein informative Kacheluebersicht (siehe index())
|
|
|
|
|
lebt die eigentliche Verwaltung hier, eigenstaendig ueber die
|
|
|
|
|
Navigation erreichbar."""
|
|
|
|
|
if not current_user.has_permission("licenses.view"):
|
|
|
|
|
if not current_user.has_permission("tickets.view"):
|
|
|
|
|
flash("Keine Berechtigung, Tickets anzusehen.", "danger")
|
|
|
|
|
return redirect(url_for("index"))
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
@@ -3496,7 +3797,55 @@ def tickets_list():
|
|
|
|
|
return render_template(
|
|
|
|
|
"tickets.html", tickets=tickets_view, type_labels=LICENSE_TYPE_LABELS, module_labels=MODULE_LABELS,
|
|
|
|
|
all_modules=licensing.ALL_MODULES, license_types=licensing.LICENSE_TYPES,
|
|
|
|
|
can_create=current_user.has_permission("licenses.create"),
|
|
|
|
|
can_create=current_user.has_permission("tickets.create"),
|
|
|
|
|
can_edit=current_user.has_permission("tickets.edit"),
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@app.route("/licenses")
|
|
|
|
|
@login_required
|
|
|
|
|
def licenses_list():
|
|
|
|
|
"""Eigenstaendige Lizenzuebersicht -- zeigt ALLE ausgestellten Lizenzen
|
|
|
|
|
flach in einer Tabelle (statt nur ueber die Historie eines einzelnen
|
|
|
|
|
Tickets erreichbar zu sein). Ergaenzt Kunden/Tickets/Lizenzen zu drei
|
|
|
|
|
gleichberechtigten, direkt ueber die Navigation erreichbaren Ebenen --
|
|
|
|
|
vorher war eine Lizenz nur durch Kunde -> gefilterte Tickets -> Ticket-
|
|
|
|
|
Detail -> eingebettete Historie auffindbar. Optional gefiltert nach
|
|
|
|
|
?ticket_id=... oder ?customer_id=... (von Ticket- bzw. Kundenseite aus
|
|
|
|
|
verlinkt)."""
|
|
|
|
|
if not current_user.has_permission("licenses.view"):
|
|
|
|
|
flash("Keine Berechtigung, Lizenzen anzusehen.", "danger")
|
|
|
|
|
return redirect(url_for("index"))
|
|
|
|
|
conn = get_db_connection()
|
|
|
|
|
filter_ticket_id = request.args.get("ticket_id")
|
|
|
|
|
filter_customer_id = request.args.get("customer_id", type=int)
|
|
|
|
|
query = """
|
|
|
|
|
SELECT licenses.*, license_customers.name AS customer_name
|
|
|
|
|
FROM licenses
|
|
|
|
|
JOIN license_customers ON license_customers.id = licenses.customer_id
|
|
|
|
|
WHERE 1=1
|
|
|
|
|
"""
|
|
|
|
|
params = []
|
|
|
|
|
if filter_ticket_id:
|
|
|
|
|
query += " AND licenses.ticket_id = ?"
|
|
|
|
|
params.append(filter_ticket_id)
|
|
|
|
|
if filter_customer_id:
|
|
|
|
|
query += " AND licenses.customer_id = ?"
|
|
|
|
|
params.append(filter_customer_id)
|
|
|
|
|
query += " ORDER BY licenses.created_at DESC"
|
|
|
|
|
rows = conn.execute(query, params).fetchall()
|
|
|
|
|
now = time.time()
|
|
|
|
|
licenses_view = []
|
|
|
|
|
for row in rows:
|
|
|
|
|
d = _license_dict_for_display(row, now)
|
|
|
|
|
d["customer_name"] = row["customer_name"]
|
|
|
|
|
licenses_view.append(d)
|
|
|
|
|
filter_ticket = _ticket_row(conn, filter_ticket_id) if filter_ticket_id else None
|
|
|
|
|
filter_customer = _customer_row(conn, filter_customer_id) if filter_customer_id else None
|
|
|
|
|
conn.close()
|
|
|
|
|
return render_template(
|
|
|
|
|
"licenses.html", licenses=licenses_view, type_labels=LICENSE_TYPE_LABELS,
|
|
|
|
|
filter_ticket=filter_ticket, filter_customer=filter_customer,
|
|
|
|
|
can_edit=current_user.has_permission("licenses.edit"),
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
@@ -4439,7 +4788,7 @@ def settings():
|
|
|
|
|
@app.route("/settings/license")
|
|
|
|
|
@login_required
|
|
|
|
|
def settings_license():
|
|
|
|
|
if not current_user.can_view_settings_system:
|
|
|
|
|
if not current_user.can_view_settings_license:
|
|
|
|
|
flash("Keine Berechtigung, die Lizenz anzusehen.", "danger")
|
|
|
|
|
return redirect(url_for("index"))
|
|
|
|
|
pending_raw = get_setting("license_pending_request", "")
|
|
|
|
@@ -4462,7 +4811,7 @@ def settings_license():
|
|
|
|
|
@app.route("/settings/license/upload", methods=["POST"])
|
|
|
|
|
@login_required
|
|
|
|
|
def license_upload():
|
|
|
|
|
if not current_user.has_permission("settings_system.edit"):
|
|
|
|
|
if not current_user.has_permission("settings_license.edit"):
|
|
|
|
|
flash("Keine Berechtigung, die Lizenz zu ändern.", "danger")
|
|
|
|
|
return redirect(url_for("settings_license"))
|
|
|
|
|
uploaded = request.files.get("license_file")
|
|
|
|
@@ -4555,7 +4904,7 @@ def _license_handshake_confirm(action, success_setting_fn, success_log_action, s
|
|
|
|
|
@app.route("/settings/license/activate", methods=["POST"])
|
|
|
|
|
@login_required
|
|
|
|
|
def license_activate():
|
|
|
|
|
if not current_user.has_permission("settings_system.edit"):
|
|
|
|
|
if not current_user.has_permission("settings_license.edit"):
|
|
|
|
|
flash("Keine Berechtigung, die Lizenz zu aktivieren.", "danger")
|
|
|
|
|
return redirect(url_for("settings_license"))
|
|
|
|
|
if not _license_state.get("file") or not _license_state.get("valid"):
|
|
|
|
@@ -4572,7 +4921,7 @@ def license_activate():
|
|
|
|
|
@app.route("/settings/license/activate/confirm", methods=["POST"])
|
|
|
|
|
@login_required
|
|
|
|
|
def license_activate_confirm():
|
|
|
|
|
if not current_user.has_permission("settings_system.edit"):
|
|
|
|
|
if not current_user.has_permission("settings_license.edit"):
|
|
|
|
|
flash("Keine Berechtigung, die Lizenz zu aktivieren.", "danger")
|
|
|
|
|
return redirect(url_for("settings_license"))
|
|
|
|
|
|
|
|
|
@@ -4586,7 +4935,7 @@ def license_activate_confirm():
|
|
|
|
|
@app.route("/settings/license/deactivate", methods=["POST"])
|
|
|
|
|
@login_required
|
|
|
|
|
def license_deactivate():
|
|
|
|
|
if not current_user.has_permission("settings_system.edit"):
|
|
|
|
|
if not current_user.has_permission("settings_license.edit"):
|
|
|
|
|
flash("Keine Berechtigung, die Lizenz zu deaktivieren.", "danger")
|
|
|
|
|
return redirect(url_for("settings_license"))
|
|
|
|
|
if not _license_state.get("file") or not license_activated():
|
|
|
|
@@ -4606,7 +4955,7 @@ def license_deactivate():
|
|
|
|
|
@app.route("/settings/license/deactivate/confirm", methods=["POST"])
|
|
|
|
|
@login_required
|
|
|
|
|
def license_deactivate_confirm():
|
|
|
|
|
if not current_user.has_permission("settings_system.edit"):
|
|
|
|
|
if not current_user.has_permission("settings_license.edit"):
|
|
|
|
|
flash("Keine Berechtigung, die Lizenz zu deaktivieren.", "danger")
|
|
|
|
|
return redirect(url_for("settings_license"))
|
|
|
|
|
|
|
|
|
|