$tabs Schlüssel => Beschriftung */
+function datenschutz_tabs(string $active, array $tabs): string
+{
+ $html = '';
+}
+
+/** „30 Tage“, „1 Monat“ usw. für Texte. */
+function datenschutz_frist_label(array $cfg): string
+{
+ $one = ['days' => 'Tag', 'weeks' => 'Woche', 'months' => 'Monat', 'years' => 'Jahr'];
+ $many = datenschutz_units();
+ return (int) $cfg['amount'] . ' ' . ((int) $cfg['amount'] === 1 ? $one[$cfg['unit']] : $many[$cfg['unit']]);
+}
+
+function datenschutz_config(): array
+{
+ $labels = datenschutz_field_labels();
+ $raw = plugin_setting(DATENSCHUTZ, 'fields', null);
+ $fields = $raw === null ? datenschutz_presets()['standard'][1] : array_values(array_intersect(array_keys($labels), array_filter(explode(',', (string) $raw))));
+ $unit = (string) plugin_setting(DATENSCHUTZ, 'unit', 'days');
+ $unit = isset(datenschutz_units()[$unit]) ? $unit : 'days';
+ $max = ['days' => 3650, 'weeks' => 520, 'months' => 120, 'years' => 10][$unit];
+ return [
+ 'enabled' => plugin_setting(DATENSCHUTZ, 'enabled', '0') === '1',
+ 'amount' => max(1, min($max, (int) plugin_setting(DATENSCHUTZ, 'amount', '30'))),
+ 'unit' => $unit,
+ 'basis' => plugin_setting(DATENSCHUTZ, 'basis', 'closed') === 'created' ? 'created' : 'closed',
+ 'include_open' => plugin_setting(DATENSCHUTZ, 'include_open', '0') === '1',
+ 'fields' => $fields,
+ ];
+}
+/** Nicht rückrechenbare Ersatzadresse (Zufallswert, keine Ableitung aus der echten Adresse). */
+function datenschutz_anon_email(): string
+{
+ return 'anon_' . bin2hex(random_bytes(10)) . '@deleted.local';
+}
+
+/** Adresse für das Protokoll: nur Anfangsbuchstaben, damit das Protokoll selbst keine Kundendaten enthält. */
+function datenschutz_mask(string $email): string
+{
+ [$local, $domain] = array_pad(explode('@', $email, 2), 2, '');
+ $dom = $domain !== '' ? mb_substr($domain, 0, 1) . '***' . (str_contains($domain, '.') ? substr($domain, strrpos($domain, '.')) : '') : '';
+ return mb_substr($local, 0, 1) . '***' . ($dom !== '' ? '@' . $dom : '');
+}
+
+function datenschutz_log(PDO $pdo, string $kind, int $tickets, int $accounts, string $note, ?int $staffId = null): void
+{
+ $pdo->prepare('INSERT INTO plugin_datenschutz_log (kind, tickets, accounts, note, staff_id, created_at) VALUES (?,?,?,?,?,?)')
+ ->execute([$kind, $tickets, $accounts, mb_substr($note, 0, 250), $staffId, db_now()]);
+}
+
+/** WHERE-Teil für Tickets ohne Registrierung, die anonymisiert werden sollen. @return array{0:string,1:array} */
+function datenschutz_candidate_sql(array $cfg): array
+{
+ $cut = datenschutz_cutoff($cfg);
+ $closed = "status IN ('closed','resolved')";
+ $notDone = "requester_email NOT LIKE 'anon!_%' ESCAPE '!' AND id NOT IN (SELECT ticket_id FROM plugin_datenschutz_done)";
+ if ($cfg['basis'] === 'closed') {
+ $sql = "(({$closed} AND COALESCE(closed_at, resolved_at, updated_at) < ?)" . ($cfg['include_open'] ? " OR (status NOT IN ('closed','resolved') AND updated_at < ?)" : '') . ')';
+ $params = $cfg['include_open'] ? [$cut, $cut] : [$cut];
+ } else {
+ $sql = "(({$closed} AND created_at < ?)" . ($cfg['include_open'] ? " OR (status NOT IN ('closed','resolved') AND created_at < ? AND updated_at < ?)" : '') . ')';
+ $params = $cfg['include_open'] ? [$cut, $cut, $cut] : [$cut];
+ }
+ return ["user_id IS NULL AND {$notDone} AND {$sql}", $params];
+}
+
+function datenschutz_candidate_count(PDO $pdo): int
+{
+ [$where, $params] = datenschutz_candidate_sql(datenschutz_config());
+ $s = $pdo->prepare("SELECT COUNT(*) FROM tickets WHERE {$where}");
+ $s->execute($params);
+ return (int) $s->fetchColumn();
+}
+
+/** Entfernt die gewählten Kundendaten eines Tickets unwiderruflich. */
+function datenschutz_anonymize_ticket(PDO $pdo, int $ticketId, array $cfg): void
+{
+ $f = $cfg['fields'];
+ $sets = [];
+ $params = [];
+ if (in_array('name', $f, true)) $sets[] = "requester_name = 'Anonymisiert'";
+ if (in_array('email', $f, true)) { $sets[] = 'requester_email = ?'; $params[] = datenschutz_anon_email(); }
+ if (in_array('ip', $f, true)) $sets[] = "requester_ip = '0.0.0.0'";
+ if ($sets) $pdo->prepare('UPDATE tickets SET ' . implode(', ', $sets) . ' WHERE id = ?')->execute(array_merge($params, [$ticketId]));
+ if (in_array('collaborators', $f, true)) $pdo->prepare('DELETE FROM ticket_collaborators WHERE ticket_id = ?')->execute([$ticketId]);
+ if (in_array('tokens', $f, true)) $pdo->prepare('DELETE FROM ticket_access_tokens WHERE ticket_id = ?')->execute([$ticketId]);
+ if (in_array('fieldvalues', $f, true)) $pdo->prepare('UPDATE ticket_field_values SET value = NULL WHERE ticket_id = ?')->execute([$ticketId]);
+ if (in_array('rating', $f, true)) $pdo->prepare('UPDATE ticket_ratings SET comment = NULL, user_id = NULL WHERE ticket_id = ?')->execute([$ticketId]);
+ if (in_array('email', $f, true) || in_array('name', $f, true)) {
+ try { $pdo->prepare('DELETE FROM plugin_communitybot_links WHERE ticket_id = ?')->execute([$ticketId]); } catch (Throwable $e) { /* Plugin nicht installiert */ }
+ }
+ if (in_array('messages', $f, true)) {
+ $pdo->prepare("UPDATE ticket_threads SET message = ? WHERE ticket_id = ? AND author_type = 'customer'")->execute([DATENSCHUTZ_TEXT_REMOVED, $ticketId]);
+ }
+ if (in_array('attachments', $f, true)) {
+ $dir = realpath(rtrim((string) (config()['uploads']['path'] ?? dirname(__DIR__, 2) . '/uploads'), '/\\'));
+ $q = $pdo->prepare("SELECT a.id, a.stored_name FROM ticket_attachments a JOIN ticket_threads t ON t.id = a.thread_id WHERE t.ticket_id = ? AND t.author_type = 'customer'");
+ $q->execute([$ticketId]);
+ foreach ($q->fetchAll() as $a) {
+ if ($dir && !in_array($a['stored_name'], ['gesperrt', 'geloescht'], true)) {
+ foreach ([$dir . '/' . basename((string) $a['stored_name']), $dir . '/quarantaene/' . basename((string) $a['stored_name'])] as $file) if (is_file($file)) @unlink($file);
+ }
+ $pdo->prepare("UPDATE ticket_attachments SET original_name = '[Anhang aus Datenschutzgründen gelöscht]', stored_name = 'geloescht' WHERE id = ?")->execute([$a['id']]);
+ }
+ }
+ $has = $pdo->prepare('SELECT COUNT(*) FROM plugin_datenschutz_done WHERE ticket_id = ?');
+ $has->execute([$ticketId]);
+ if (!(int) $has->fetchColumn()) $pdo->prepare('INSERT INTO plugin_datenschutz_done (ticket_id, done_at) VALUES (?,?)')->execute([$ticketId, db_now()]);
+ $labels = datenschutz_field_labels();
+ log_activity($pdo, $ticketId, null, 'Kundendaten aus Datenschutzgründen anonymisiert (' . implode(', ', array_map(fn($k) => $labels[$k], $f)) . ')');
+}
+
+/** Anonymisiert fällige Tickets ohne Registrierung. @return int Zahl der Tickets */
+function datenschutz_run(PDO $pdo, int $limit = 200, string $kind = 'auto', ?int $staffId = null): int
+{
+ $cfg = datenschutz_config();
+ if (!$cfg['enabled'] || !$cfg['fields']) return 0;
+ [$where, $params] = datenschutz_candidate_sql($cfg);
+ $s = $pdo->prepare("SELECT id FROM tickets WHERE {$where} ORDER BY id LIMIT " . max(1, $limit));
+ $s->execute($params);
+ $n = 0;
+ foreach ($s->fetchAll(PDO::FETCH_COLUMN) as $id) {
+ try {
+ datenschutz_anonymize_ticket($pdo, (int) $id, $cfg);
+ $n++;
+ } catch (Throwable $e) {
+ error_log('datenschutz ticket ' . $id . ': ' . $e->getMessage());
+ }
+ }
+ plugin_set_setting(DATENSCHUTZ, 'last_run', db_now());
+ if ($n > 0) datenschutz_log($pdo, $kind, $n, 0, 'Tickets ohne Registrierung nach ' . datenschutz_frist_label($cfg) . ' anonymisiert (' . count($cfg['fields']) . ' Datenarten)', $staffId);
+ return $n;
+}
+
+/** Hintergrundlauf: höchstens einmal pro Stunde. */
+function datenschutz_tick(PDO $pdo): int
+{
+ if (!datenschutz_config()['enabled']) return 0;
+ if (time() - (int) plugin_setting(DATENSCHUTZ, 'last_tick', '0') < 3600) return 0;
+ plugin_set_setting(DATENSCHUTZ, 'last_tick', (string) time());
+ return datenschutz_run($pdo, 200, 'auto');
+}
+/** Registrierten Kunden suchen. @return array{user:array,tickets:int,open:int,already:bool}|null */
+function datenschutz_find_customer(PDO $pdo, string $email): ?array
+{
+ $email = strtolower(trim($email));
+ if ($email === '') return null;
+ $s = $pdo->prepare('SELECT id, name, email, organization_id FROM users WHERE LOWER(email) = ?');
+ $s->execute([$email]);
+ $u = $s->fetch();
+ if (!$u) return null;
+ $c = $pdo->prepare("SELECT COUNT(*), SUM(CASE WHEN status NOT IN ('closed','resolved') THEN 1 ELSE 0 END) FROM tickets WHERE user_id = ? OR LOWER(requester_email) = ?");
+ $c->execute([(int) $u['id'], $email]);
+ [$total, $open] = array_map('intval', array_values($c->fetch(PDO::FETCH_NUM)));
+ return ['user' => $u, 'tickets' => $total, 'open' => $open, 'already' => str_starts_with((string) $u['email'], 'anon_')];
+}
+
+/** Löscht die Daten eines registrierten Kunden auf dessen Antrag unwiderruflich. @return array{ok:bool,error?:string,tickets?:int} */
+function datenschutz_delete_customer(PDO $pdo, array $staff, int $userId, bool $closeOpen): array
+{
+ if (($staff['role'] ?? '') !== 'admin') return ['ok' => false, 'error' => 'Das darf nur ein Administrator.'];
+ $s = $pdo->prepare('SELECT * FROM users WHERE id = ?');
+ $s->execute([$userId]);
+ $u = $s->fetch();
+ if (!$u) return ['ok' => false, 'error' => 'Der Kunde wurde nicht gefunden.'];
+ if (str_starts_with((string) $u['email'], 'anon_')) return ['ok' => false, 'error' => 'Dieser Kunde ist bereits anonymisiert.'];
+ $email = strtolower((string) $u['email']);
+ $t = $pdo->prepare('SELECT id, status FROM tickets WHERE user_id = ? OR LOWER(requester_email) = ?');
+ $t->execute([$userId, $email]);
+ $tickets = $t->fetchAll();
+ $open = array_filter($tickets, fn($x) => !in_array($x['status'], ['closed', 'resolved'], true));
+ if ($open && !$closeOpen) return ['ok' => false, 'error' => 'Der Kunde hat noch ' . count($open) . ' offene Tickets. Bitte die Option „Offene Tickets schließen“ wählen oder die Tickets zuerst bearbeiten.'];
+ $cfg = datenschutz_config();
+ // Bei einer Löschung auf Antrag werden Nachrichten und Anhänge des Kunden immer mit entfernt: er hat die Löschung seiner Daten verlangt
+ $cfg['fields'] = array_keys(datenschutz_field_labels());
+ $now = db_now();
+ foreach ($tickets as $row) {
+ if (in_array($row['id'], array_column($open, 'id'), true)) {
+ $pdo->prepare("UPDATE tickets SET status = 'closed', closed_at = ?, updated_at = ? WHERE id = ?")->execute([$now, $now, $row['id']]);
+ log_activity($pdo, (int) $row['id'], null, 'Ticket auf Antrag des Kunden auf Löschung geschlossen');
+ }
+ datenschutz_anonymize_ticket($pdo, (int) $row['id'], $cfg);
+ $pdo->prepare('UPDATE tickets SET user_id = NULL WHERE id = ?')->execute([$row['id']]);
+ }
+ $pdo->prepare('UPDATE ticket_threads SET user_id = NULL WHERE user_id = ?')->execute([$userId]);
+ $pdo->prepare('DELETE FROM customer_notes WHERE user_id = ?')->execute([$userId]);
+ try { $pdo->prepare('DELETE FROM password_resets WHERE LOWER(email) = ?')->execute([$email]); } catch (Throwable $e) {}
+ $pdo->prepare("UPDATE users SET name = 'Anonymisiert', email = ?, phone = NULL, organization_id = NULL, password_hash = ? WHERE id = ?")
+ ->execute([datenschutz_anon_email(), password_hash(bin2hex(random_bytes(24)), PASSWORD_DEFAULT), $userId]);
+ datenschutz_log($pdo, 'request', count($tickets), 1, 'Löschung auf Antrag: ' . datenschutz_mask($email), (int) $staff['id']);
+ return ['ok' => true, 'tickets' => count($tickets)];
+}
+
+plugin_add_hook('plugin.uninstall.' . DATENSCHUTZ, function () {
+ try {
+ get_db()->exec('DROP TABLE IF EXISTS plugin_datenschutz_log');
+ get_db()->exec('DROP TABLE IF EXISTS plugin_datenschutz_done');
+ } catch (Throwable $e) {
+ }
+});
diff --git a/Plugins/plugins/datenschutz/migrations/001_protokoll.mysql.sql b/Plugins/plugins/datenschutz/migrations/001_protokoll.mysql.sql
new file mode 100644
index 00000000..e5c7d032
--- /dev/null
+++ b/Plugins/plugins/datenschutz/migrations/001_protokoll.mysql.sql
@@ -0,0 +1,9 @@
+CREATE TABLE IF NOT EXISTS plugin_datenschutz_log (
+ id INT AUTO_INCREMENT PRIMARY KEY,
+ kind VARCHAR(12) NOT NULL,
+ tickets INT NOT NULL DEFAULT 0,
+ accounts INT NOT NULL DEFAULT 0,
+ note VARCHAR(250) NOT NULL DEFAULT '',
+ staff_id INT NULL,
+ created_at DATETIME NOT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
diff --git a/Plugins/plugins/datenschutz/migrations/001_protokoll.sqlite.sql b/Plugins/plugins/datenschutz/migrations/001_protokoll.sqlite.sql
new file mode 100644
index 00000000..5741a2d7
--- /dev/null
+++ b/Plugins/plugins/datenschutz/migrations/001_protokoll.sqlite.sql
@@ -0,0 +1,9 @@
+CREATE TABLE IF NOT EXISTS plugin_datenschutz_log (
+ id INTEGER PRIMARY KEY AUTOINCREMENT,
+ kind TEXT NOT NULL,
+ tickets INTEGER NOT NULL DEFAULT 0,
+ accounts INTEGER NOT NULL DEFAULT 0,
+ note TEXT NOT NULL DEFAULT '',
+ staff_id INTEGER NULL,
+ created_at TEXT NOT NULL
+)
diff --git a/Plugins/plugins/datenschutz/migrations/002_erledigt.mysql.sql b/Plugins/plugins/datenschutz/migrations/002_erledigt.mysql.sql
new file mode 100644
index 00000000..4a5ce026
--- /dev/null
+++ b/Plugins/plugins/datenschutz/migrations/002_erledigt.mysql.sql
@@ -0,0 +1,4 @@
+CREATE TABLE IF NOT EXISTS plugin_datenschutz_done (
+ ticket_id INT PRIMARY KEY,
+ done_at DATETIME NOT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
diff --git a/Plugins/plugins/datenschutz/migrations/002_erledigt.sqlite.sql b/Plugins/plugins/datenschutz/migrations/002_erledigt.sqlite.sql
new file mode 100644
index 00000000..21f2bbfb
--- /dev/null
+++ b/Plugins/plugins/datenschutz/migrations/002_erledigt.sqlite.sql
@@ -0,0 +1,4 @@
+CREATE TABLE IF NOT EXISTS plugin_datenschutz_done (
+ ticket_id INTEGER PRIMARY KEY,
+ done_at TEXT NOT NULL
+)
diff --git a/Plugins/plugins/datenschutz/pages/datenschutz.php b/Plugins/plugins/datenschutz/pages/datenschutz.php
new file mode 100644
index 00000000..a141ac93
--- /dev/null
+++ b/Plugins/plugins/datenschutz/pages/datenschutz.php
@@ -0,0 +1,179 @@
+DatenschutzDiese Seite ist nur für Administratoren zugänglich.
'; return; }
+$message = null;
+$error = null;
+$found = null;
+$searched = '';
+
+if ($_SERVER['REQUEST_METHOD'] === 'POST') {
+ verify_csrf();
+ $action = $_POST['action'] ?? '';
+ if ($action === 'settings') {
+ $unit = isset(datenschutz_units()[$_POST['unit'] ?? '']) ? $_POST['unit'] : 'days';
+ $picked = array_values(array_intersect(array_keys(datenschutz_field_labels()), (array) ($_POST['fields'] ?? [])));
+ if (!$picked) {
+ $error = 'Bitte mindestens eine Datenart zum Anonymisieren wählen.';
+ } else {
+ plugin_set_setting(DATENSCHUTZ, 'amount', (string) max(1, (int) ($_POST['amount'] ?? 30)));
+ plugin_set_setting(DATENSCHUTZ, 'unit', $unit);
+ plugin_set_setting(DATENSCHUTZ, 'basis', ($_POST['basis'] ?? '') === 'created' ? 'created' : 'closed');
+ plugin_set_setting(DATENSCHUTZ, 'include_open', !empty($_POST['include_open']) ? '1' : '0');
+ plugin_set_setting(DATENSCHUTZ, 'fields', implode(',', $picked));
+ $message = 'Einstellungen gespeichert.';
+ }
+ } elseif ($action === 'enable') {
+ if (empty($_POST['confirm'])) $error = 'Bitte bestätigen, dass Sie die unwiderrufliche Anonymisierung einschalten wollen.';
+ else { plugin_set_setting(DATENSCHUTZ, 'enabled', '1'); datenschutz_log($pdo, 'manual', 0, 0, 'Automatische Anonymisierung eingeschaltet', (int) $staff['id']); $message = 'Die automatische Anonymisierung ist eingeschaltet. Sie läuft ab jetzt im Hintergrund.'; }
+ } elseif ($action === 'disable') {
+ plugin_set_setting(DATENSCHUTZ, 'enabled', '0');
+ datenschutz_log($pdo, 'manual', 0, 0, 'Automatische Anonymisierung ausgeschaltet', (int) $staff['id']);
+ $message = 'Die automatische Anonymisierung ist ausgeschaltet.';
+ } elseif ($action === 'run') {
+ $n = datenschutz_run($pdo, 500, 'manual', (int) $staff['id']);
+ $message = $n . ' Ticket(s) anonymisiert.';
+ } elseif ($action === 'core_off') {
+ set_setting('retention_enabled', '0');
+ audit_log($staff['id'], 'Automatische Datenlöschung des Kerns ausgeschaltet (Plugin Datenschutz übernimmt)');
+ $message = 'Die automatische Datenlöschung des Kerns ist ausgeschaltet.';
+ } elseif ($action === 'find') {
+ $searched = trim((string) ($_POST['email'] ?? ''));
+ $found = datenschutz_find_customer($pdo, $searched);
+ if (!$found) $error = 'Unter dieser Adresse gibt es keinen registrierten Kunden.';
+ } elseif ($action === 'delete_customer') {
+ if (empty($_POST['confirm'])) $error = 'Bitte die Löschung bestätigen.';
+ else {
+ $r = datenschutz_delete_customer($pdo, $staff, (int) ($_POST['user_id'] ?? 0), !empty($_POST['close_open']));
+ if ($r['ok']) $message = 'Die Daten des Kunden wurden unwiderruflich gelöscht (' . $r['tickets'] . ' Ticket(s) anonymisiert, Konto anonymisiert, Nachrichten und Anhänge entfernt).';
+ else { $error = $r['error']; $searched = trim((string) ($_POST['email'] ?? '')); $found = datenschutz_find_customer($pdo, $searched); }
+ }
+ }
+}
+
+$cfg = datenschutz_config();
+$count = datenschutz_candidate_count($pdo);
+$tabs = ['uebersicht' => 'Übersicht', 'einstellungen' => 'Einstellungen', 'antrag' => 'Löschung auf Antrag', 'protokoll' => 'Protokoll'];
+$tab = (string) ($_GET['tab'] ?? 'uebersicht');
+if (!isset($tabs[$tab])) $tab = 'uebersicht';
+// Nach einer Suche bzw. Löschung bleibt man im Reiter „Löschung auf Antrag“
+if ($_SERVER['REQUEST_METHOD'] === 'POST' && in_array($_POST['action'] ?? '', ['find', 'delete_customer'], true)) $tab = 'antrag';
+$log = [];
+$logTotal = 0;
+$perPage = 50;
+$seite = 1;
+if ($tab === 'protokoll') {
+ $logTotal = (int) $pdo->query('SELECT COUNT(*) FROM plugin_datenschutz_log')->fetchColumn();
+ $pages = max(1, (int) ceil($logTotal / $perPage));
+ $seite = min($pages, max(1, (int) ($_GET['seite'] ?? 1)));
+ $log = $pdo->query('SELECT l.*, s.name AS staff_name FROM plugin_datenschutz_log l LEFT JOIN staff s ON s.id = l.staff_id ORDER BY l.id DESC LIMIT ' . $perPage . ' OFFSET ' . (($seite - 1) * $perPage))->fetchAll();
+}
+$coreOn = get_setting('retention_enabled', '0') === '1';
+$kinds = ['auto' => 'Automatisch', 'manual' => 'Von Hand', 'request' => 'Löschung auf Antrag'];
+?>
+Datenschutz
+
+
+
+
+
+
+
+ Die automatische Datenlöschung von DeskHub (Einstellungen → Datenschutz) ist eingeschaltet. Sie anonymisiert nach ihrer Frist auch registrierte Kunden. Das widerspricht der Regel „Daten registrierter Kunden bleiben bis zur Löschung auf Antrag“. Schalten Sie sie aus, dieses Plugin übernimmt die Aufgabe.
+
+
+
+
+
+
+
Regeln
+
+ - Tickets ohne Registrierung: Nach werden unwiderruflich entfernt: datenschutz_field_labels()[$k], $cfg['fields']))) ?>. Eine Wiederherstellung ist nicht möglich.
+ - Registrierte Kunden: Die Daten bleiben gespeichert, bis der Kunde die Löschung beantragt. Sie führen die Löschung unten aus.
+
+
+ ✓ Automatische Anonymisierung ist eingeschaltet. Zurzeit fällig: Ticket(s). Letzter Lauf: .
+ Die automatische Anonymisierung ist noch ausgeschaltet. Beim Einschalten würden sofort vorhandene Ticket(s) anonymisiert.
+
+
+
+
+
+
+
+
+
Löschung auf Antrag eines registrierten Kunden
+
Der Kunde hat die Löschung seiner Daten verlangt. Das Konto wird anonymisiert und kann sich nicht mehr anmelden. Seine Tickets verlieren Name, Adresse, Nachrichten und Anhänge. Das ist nicht rückgängig zu machen.
+
+
+
+
Dieser Kunde ist bereits anonymisiert.
+
+
Protokoll
+
Noch keine Einträge. Das Protokoll enthält keine Kundendaten, bei Löschanträgen nur eine verkürzte Adresse.
+
| Wann | Art | Tickets | Hinweis | Von |
|---|
+
+ | | | | |
+
+
+ 1): ?>
+
+ 1): ?>← Neuere ·
+ Seite von
+ · Ältere →
+
+
+
+
' . nl2br(e($text)) . '
'
+ . 'Sie erhalten diese Nachricht, weil Sie bei uns ein offenes Ticket haben bzw. zur genannten Kundengruppe gehören. Bitte antworten Sie bei Fragen auf Ihr Ticket.
';
+ if (function_exists('email_wrap')) $html = email_wrap($html);
+ return [(string) $msg['subject'], $html];
+}
+
+/** Versand einer einzelnen Mail (für Tests austauschbar über $GLOBALS['rundmail_send']). */
+function rundmail_send(string $to, string $subject, string $html): bool
+{
+ if (isset($GLOBALS['rundmail_send']) && is_callable($GLOBALS['rundmail_send'])) return (bool) ($GLOBALS['rundmail_send'])($to, $subject, $html);
+ return (bool) send_mail($to, $subject, $html);
+}
+
+/** Prüft Betreff und Text. */
+function rundmail_validate(string $subject, string $body): ?string
+{
+ if (trim($subject) === '' || mb_strlen($subject) > 150) return 'Bitte einen Betreff angeben (höchstens 150 Zeichen).';
+ if (trim($body) === '' || mb_strlen($body) > 5000) return 'Bitte einen Text angeben (höchstens 5000 Zeichen).';
+ if (preg_match('/[\r\n]/', $subject)) return 'Der Betreff darf nur eine Zeile sein.';
+ return null;
+}
+
+/** Legt die Nachricht an und startet den Versand. @return array{ok:bool,error?:string,id?:int,total?:int} */
+function rundmail_create(PDO $pdo, array $staff, string $groupKey, string $subject, string $body): array
+{
+ if ($err = rundmail_validate($subject, $body)) return ['ok' => false, 'error' => $err];
+ $group = rundmail_parse_group($pdo, $groupKey);
+ if (!$group) return ['ok' => false, 'error' => 'Bitte eine Empfängergruppe wählen.'];
+ $isAdmin = ($staff['role'] ?? '') === 'admin';
+ $recent = $pdo->prepare('SELECT COUNT(*) FROM plugin_rundmail_messages WHERE sender_id = ? AND created_at >= ?');
+ $recent->execute([(int) $staff['id'], date('Y-m-d H:i:s', time() - 3600)]);
+ if ((int) $recent->fetchColumn() >= ($isAdmin ? 20 : 5)) return ['ok' => false, 'error' => 'Sie haben in der letzten Stunde schon viele Rundmails verschickt. Bitte später noch einmal.'];
+ $rcpt = rundmail_recipients($pdo, $staff, $group['type'], $group['id']);
+ if (!$rcpt) return ['ok' => false, 'error' => 'In dieser Gruppe gibt es keine Empfänger (oder Sie dürfen ihr nicht schreiben).'];
+ $max = $isAdmin ? 2000 : 200;
+ if (count($rcpt) > $max) return ['ok' => false, 'error' => 'Zu viele Empfänger (' . count($rcpt) . '). Erlaubt sind höchstens ' . $max . '.' . ($isAdmin ? '' : ' Größere Verteiler darf nur ein Administrator senden.')];
+ $pdo->prepare("INSERT INTO plugin_rundmail_messages (subject, body, group_type, group_id, group_label, sender_id, sender_name, status, total, created_at) VALUES (?,?,?,?,?,?,?,'sending',?,?)")
+ ->execute([trim($subject), trim($body), $group['type'], $group['id'], mb_substr($group['label'], 0, 190), (int) $staff['id'], mb_substr((string) $staff['name'], 0, 120), count($rcpt), db_now()]);
+ $id = (int) $pdo->lastInsertId();
+ $ins = $pdo->prepare('INSERT INTO plugin_rundmail_queue (message_id, email, name) VALUES (?,?,?)');
+ foreach ($rcpt as $r) $ins->execute([$id, $r['email'], mb_substr($r['name'], 0, 120)]);
+ rundmail_process($pdo, $id, RUNDMAIL_BATCH);
+ return ['ok' => true, 'id' => $id, 'total' => count($rcpt)];
+}
+
+/** Verschickt die nächsten Mails (einer Nachricht oder der ältesten offenen). @return int Zahl der bearbeiteten Empfänger */
+function rundmail_process(PDO $pdo, ?int $messageId = null, int $batch = RUNDMAIL_BATCH): int
+{
+ if ($messageId === null) {
+ $messageId = (int) $pdo->query("SELECT id FROM plugin_rundmail_messages WHERE status = 'sending' ORDER BY id LIMIT 1")->fetchColumn();
+ if (!$messageId) return 0;
+ }
+ $m = $pdo->prepare("SELECT * FROM plugin_rundmail_messages WHERE id = ? AND status = 'sending'");
+ $m->execute([$messageId]);
+ $msg = $m->fetch();
+ if (!$msg) return 0;
+ $q = $pdo->prepare("SELECT * FROM plugin_rundmail_queue WHERE message_id = ? AND status = 'pending' ORDER BY id LIMIT " . max(1, $batch));
+ $q->execute([$messageId]);
+ $n = 0;
+ foreach ($q->fetchAll() as $row) {
+ [$subject, $html] = rundmail_render($msg, (string) $row['name']);
+ try {
+ $ok = rundmail_send((string) $row['email'], $subject, $html);
+ $err = $ok ? null : 'Versand fehlgeschlagen (E-Mail-Versand eingerichtet?)';
+ } catch (Throwable $e) {
+ $ok = false;
+ $err = mb_substr($e->getMessage(), 0, 240);
+ }
+ $pdo->prepare('UPDATE plugin_rundmail_queue SET status = ?, error = ?, sent_at = ? WHERE id = ?')->execute([$ok ? 'sent' : 'failed', $err, db_now(), $row['id']]);
+ $n++;
+ }
+ $c = $pdo->prepare("SELECT SUM(CASE WHEN status = 'sent' THEN 1 ELSE 0 END), SUM(CASE WHEN status = 'failed' THEN 1 ELSE 0 END), SUM(CASE WHEN status = 'pending' THEN 1 ELSE 0 END) FROM plugin_rundmail_queue WHERE message_id = ?");
+ $c->execute([$messageId]);
+ [$sent, $failed, $pending] = array_map('intval', array_values($c->fetch(PDO::FETCH_NUM)));
+ if ($pending === 0) $pdo->prepare("UPDATE plugin_rundmail_messages SET sent = ?, failed = ?, status = 'done', finished_at = ? WHERE id = ?")->execute([$sent, $failed, db_now(), $messageId]);
+ else $pdo->prepare('UPDATE plugin_rundmail_messages SET sent = ?, failed = ? WHERE id = ?')->execute([$sent, $failed, $messageId]);
+ return $n;
+}
+
+/** Hintergrundlauf: nächste Mails der laufenden Nachrichten versenden. */
+function rundmail_tick(PDO $pdo): int
+{
+ return rundmail_process($pdo, null, RUNDMAIL_BATCH);
+}
+
+/** Bricht den Versand ab (noch nicht gesendete Mails entfallen). Verfasser oder Administrator. */
+function rundmail_cancel(PDO $pdo, array $staff, int $id): bool
+{
+ $s = $pdo->prepare("SELECT sender_id FROM plugin_rundmail_messages WHERE id = ? AND status = 'sending'");
+ $s->execute([$id]);
+ $owner = $s->fetchColumn();
+ if ($owner === false || (($staff['role'] ?? '') !== 'admin' && (int) $owner !== (int) $staff['id'])) return false;
+ $pdo->prepare("UPDATE plugin_rundmail_queue SET status = 'cancelled' WHERE message_id = ? AND status = 'pending'")->execute([$id]);
+ $c = $pdo->prepare("SELECT SUM(CASE WHEN status = 'sent' THEN 1 ELSE 0 END), SUM(CASE WHEN status = 'failed' THEN 1 ELSE 0 END) FROM plugin_rundmail_queue WHERE message_id = ?");
+ $c->execute([$id]);
+ [$sent, $failed] = array_map('intval', array_values($c->fetch(PDO::FETCH_NUM)));
+ $pdo->prepare("UPDATE plugin_rundmail_messages SET status = 'cancelled', sent = ?, failed = ?, finished_at = ? WHERE id = ?")->execute([$sent, $failed, db_now(), $id]);
+ return true;
+}
+
+/** Probemail an den angemeldeten Mitarbeiter. */
+function rundmail_test(array $staff, string $subject, string $body): array
+{
+ if ($err = rundmail_validate($subject, $body)) return ['ok' => false, 'error' => $err];
+ [$s, $html] = rundmail_render(['subject' => '[TEST] ' . trim($subject), 'body' => trim($body)], (string) $staff['name']);
+ $ok = rundmail_send((string) $staff['email'], $s, $html);
+ return $ok ? ['ok' => true] : ['ok' => false, 'error' => 'Die Probemail konnte nicht gesendet werden (E-Mail-Versand eingerichtet?).'];
+}
+
+/** Verlauf: Administratoren sehen alle, Mitarbeiter ihre eigenen. */
+function rundmail_history(PDO $pdo, array $staff, int $limit = 40): array
+{
+ if (($staff['role'] ?? '') === 'admin') return $pdo->query('SELECT * FROM plugin_rundmail_messages ORDER BY id DESC LIMIT ' . max(1, $limit))->fetchAll();
+ $s = $pdo->prepare('SELECT * FROM plugin_rundmail_messages WHERE sender_id = ? ORDER BY id DESC LIMIT ' . max(1, $limit));
+ $s->execute([(int) $staff['id']]);
+ return $s->fetchAll();
+}
diff --git a/Plugins/plugins/rundmail/migrations/001_rundmail.mysql.sql b/Plugins/plugins/rundmail/migrations/001_rundmail.mysql.sql
new file mode 100644
index 00000000..48b93915
--- /dev/null
+++ b/Plugins/plugins/rundmail/migrations/001_rundmail.mysql.sql
@@ -0,0 +1,27 @@
+CREATE TABLE IF NOT EXISTS plugin_rundmail_messages (
+ id INT AUTO_INCREMENT PRIMARY KEY,
+ subject VARCHAR(200) NOT NULL,
+ body TEXT NOT NULL,
+ group_type VARCHAR(20) NOT NULL,
+ group_id INT NULL,
+ group_label VARCHAR(190) NOT NULL DEFAULT '',
+ sender_id INT NULL,
+ sender_name VARCHAR(120) NOT NULL DEFAULT '',
+ status VARCHAR(12) NOT NULL DEFAULT 'sending',
+ total INT NOT NULL DEFAULT 0,
+ sent INT NOT NULL DEFAULT 0,
+ failed INT NOT NULL DEFAULT 0,
+ created_at DATETIME NOT NULL,
+ finished_at DATETIME NULL,
+ KEY idx_plugin_rundmail_msg_status (status)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
+CREATE TABLE IF NOT EXISTS plugin_rundmail_queue (
+ id INT AUTO_INCREMENT PRIMARY KEY,
+ message_id INT NOT NULL,
+ email VARCHAR(190) NOT NULL,
+ name VARCHAR(120) NOT NULL DEFAULT '',
+ status VARCHAR(10) NOT NULL DEFAULT 'pending',
+ error VARCHAR(250) NULL,
+ sent_at DATETIME NULL,
+ KEY idx_plugin_rundmail_queue (message_id, status)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
diff --git a/Plugins/plugins/rundmail/migrations/001_rundmail.sqlite.sql b/Plugins/plugins/rundmail/migrations/001_rundmail.sqlite.sql
new file mode 100644
index 00000000..220163b9
--- /dev/null
+++ b/Plugins/plugins/rundmail/migrations/001_rundmail.sqlite.sql
@@ -0,0 +1,27 @@
+CREATE TABLE IF NOT EXISTS plugin_rundmail_messages (
+ id INTEGER PRIMARY KEY AUTOINCREMENT,
+ subject TEXT NOT NULL,
+ body TEXT NOT NULL,
+ group_type TEXT NOT NULL,
+ group_id INTEGER NULL,
+ group_label TEXT NOT NULL DEFAULT '',
+ sender_id INTEGER NULL,
+ sender_name TEXT NOT NULL DEFAULT '',
+ status TEXT NOT NULL DEFAULT 'sending',
+ total INTEGER NOT NULL DEFAULT 0,
+ sent INTEGER NOT NULL DEFAULT 0,
+ failed INTEGER NOT NULL DEFAULT 0,
+ created_at TEXT NOT NULL,
+ finished_at TEXT NULL
+);
+CREATE INDEX IF NOT EXISTS idx_plugin_rundmail_msg_status ON plugin_rundmail_messages (status);
+CREATE TABLE IF NOT EXISTS plugin_rundmail_queue (
+ id INTEGER PRIMARY KEY AUTOINCREMENT,
+ message_id INTEGER NOT NULL,
+ email TEXT NOT NULL,
+ name TEXT NOT NULL DEFAULT '',
+ status TEXT NOT NULL DEFAULT 'pending',
+ error TEXT NULL,
+ sent_at TEXT NULL
+);
+CREATE INDEX IF NOT EXISTS idx_plugin_rundmail_queue ON plugin_rundmail_queue (message_id, status)
diff --git a/Plugins/plugins/rundmail/pages/rundmail.php b/Plugins/plugins/rundmail/pages/rundmail.php
new file mode 100644
index 00000000..1f9ae23c
--- /dev/null
+++ b/Plugins/plugins/rundmail/pages/rundmail.php
@@ -0,0 +1,110 @@
+ (string) ($_POST['group'] ?? ''), 'subject' => (string) ($_POST['subject'] ?? ''), 'body' => (string) ($_POST['body'] ?? '')];
+$preview = null;
+
+if ($_SERVER['REQUEST_METHOD'] === 'POST') {
+ verify_csrf();
+ $action = $_POST['action'] ?? '';
+ if ($action === 'preview') {
+ $g = rundmail_parse_group($pdo, $form['group']);
+ $err = rundmail_validate($form['subject'], $form['body']);
+ if (!$g) $error = 'Bitte eine Empfängergruppe wählen.';
+ elseif ($err) $error = $err;
+ else {
+ $rcpt = rundmail_recipients($pdo, $staff, $g['type'], $g['id']);
+ if (!$rcpt) $error = 'In dieser Gruppe gibt es keine Empfänger (oder Sie dürfen ihr nicht schreiben).';
+ else $preview = ['group' => $g, 'rcpt' => $rcpt];
+ }
+ } elseif ($action === 'send') {
+ if (empty($_POST['confirm'])) { $error = 'Bitte bestätigen, dass Text und Empfänger geprüft sind.'; }
+ else {
+ $r = rundmail_create($pdo, $staff, $form['group'], $form['subject'], $form['body']);
+ if ($r['ok']) {
+ $message = 'Die Nachricht geht an ' . $r['total'] . ' Empfänger. Der Versand läuft im Hintergrund, den Stand sehen Sie unten.';
+ $form = ['group' => '', 'subject' => '', 'body' => ''];
+ } else $error = $r['error'];
+ }
+ } elseif ($action === 'test') {
+ $r = rundmail_test($staff, $form['subject'], $form['body']);
+ if ($r['ok']) $message = 'Die Probemail ist an ' . $staff['email'] . ' unterwegs.'; else $error = $r['error'];
+ } elseif ($action === 'cancel') {
+ if (rundmail_cancel($pdo, $staff, (int) ($_POST['id'] ?? 0))) $message = 'Der Versand wurde abgebrochen.'; else $error = 'Dieser Versand lässt sich nicht abbrechen.';
+ }
+}
+// Offene Versände weiterschieben, damit der Stand beim Ansehen nicht stehen bleibt
+if ($_SERVER['REQUEST_METHOD'] !== 'POST') rundmail_tick($pdo);
+
+$groups = rundmail_groups($pdo, $staff);
+$history = rundmail_history($pdo, $staff);
+$presets = rundmail_presets();
+$statusLabels = ['sending' => 'Läuft', 'done' => 'Fertig', 'cancelled' => 'Abgebrochen'];
+?>
+Störungsmitteilung und Rundmail
+
+
+
+
+
+
+
+
+
+
+
+
Noch nichts gesendet.
+
+ | Wann | Betreff | Empfänger | Von | Stand | |
|---|
+
+
+
+ |
+ |
+ |
+ |
+ von gesendet' . (int) $h['failed'] . ' fehlgeschlagen' : '' ?> |
+ |
+
+
+
+
+
+
Wichtige Schichtübergabe
';
+ foreach (array_slice($notes, 0, 3) as $n) {
+ $who = !empty($n['own']) ? 'Ihre Notiz' : (string) $n['author'];
+ $readers = !empty($n['own']) ? count(array_filter(schicht_readers($pdo, (int) $n['id']), fn($r) => $r !== (string) ($staff['name'] ?? ''))) : null;
+ $html .= '
' . e($who) . ' ' . e(format_dt((string) $n['created_at'])) . ($readers !== null ? ' · von ' . $readers . ' gelesen' : '') . '
' . nl2br(e(mb_strimwidth((string) $n['message'], 0, 300, '…'))) . '
';
+ }
+ $html .= '
Alle Notizen öffnen'
+ . '
'
+ . '
' . ($important ? '⚠ ' : '') . 'Schichtübergabe: ' . $count . ($count === 1 ? ' neue Notiz' : ' neue Notizen') . ($important ? ' (' . $important . ' wichtig)' : '') . ''
+ . '
';
+ foreach (array_slice($notes, 0, 3) as $n) {
+ $html .= '
' . e((string) $n['author']) . ''
+ . ' ' . e(format_dt((string) $n['created_at'])) . ((int) $n['is_important'] ? ' · wichtig' : '') . '
'
+ . nl2br(e(mb_strimwidth((string) $n['message'], 0, 400, '…'))) . '
';
+ }
+ if ($count > 3) $html .= '
… und ' . ($count - 3) . ' weitere
';
+ $html .= '
'
+ . '
'
+ . '
Ihre Notiz an die nächste Schicht' . ((int) $n['is_important'] ? ' (wichtig)' : '') . ' · ' . ($n['department'] ? 'Abteilung ' . e((string) $n['department']) : 'alle Mitarbeiter') . ''
+ . '
'
+ . '
' . nl2br(e(mb_strimwidth((string) $n['message'], 0, 400, '…'))) . '
'
+ . '
' . e(format_dt((string) $n['created_at'])) . ' · ' . ($readers ? 'Gelesen von: ' . e(implode(', ', $readers)) : 'noch von niemandem gelesen') . '
Schichtübergabe
+
+
+
+
+
+
+
+
Notizen der letzten Tage
+
+
+
Noch keine Notizen.
+
+
+
+
+
+ · ·
+ neu
+ von Ihnen
+ wichtig
+
+
+
+
+
+
+
+
+
+
+
+
+
Gelesen von:
+
+
+
+
Spamfilter
'
+ . '
' . e($label) . ' · ' . (int) $row['score'] . ' Punkte
';
+ if ($reasons) {
+ $html .= '
';
+ foreach (array_slice($reasons, 0, 6) as $r) $html .= '- ' . e((string) $r) . '
';
+ $html .= '
';
+ }
+ return $html . '
Spamfilter
+
+
+
+
+
Die letzten 30 Tage
+
+ Spam abgelegt ·
+ im Verdacht ·
+ unauffällig ·
+ von Hand freigegeben
+
+
Ab Punkten gilt ein Ticket als Spam, ab bekommt es den Tag „Spam-Verdacht“. Die Filterung ist ausgeschaltet' ?>.
+
+
Protokoll
+
Noch keine Tickets bewertet.
+
+ | Ticket | Absender | Punkte | Entscheidung | Gründe | |
|---|
+
+
+
+ | # |
+ |
+ |
+ |
+ |
+
+
+
+
+
+
+ |
+
+
+
+
+
+