dashboard_route(),
'/admin/settings' => admin_settings_route(),
'/admin/templates' => admin_templates_route(),
'/admin/logs' => admin_logs_route(),
'/csv' => csv_route(),
'/manual' => manual_route(),
'/send' => send_route(),
'/history' => history_route(),
'/message' => message_route(),
default => not_found_route(),
};
}
function login_route(): void
{
if (!empty($_GET['token'])) {
try {
Auth::loginWithDrupalToken((string) $_GET['token']);
flash('success', 'Ingreso correcto.');
$return = safe_panel_return($_GET['return'] ?? '');
if ($return !== '') {
header('Location: ' . url($return));
exit;
}
redirect_to('/dashboard');
} catch (Throwable $e) {
flash('error', $e->getMessage());
}
} elseif (Auth::user()) {
$return = safe_panel_return($_GET['return'] ?? '');
if ($return !== '') {
header('Location: ' . url($return));
exit;
}
redirect_to('/dashboard');
} else {
$return = safe_panel_return($_GET['return'] ?? '');
$returnUrl = $return !== '' ? absolute_url($return) : absolute_url('/dashboard');
Auth::redirectToDrupalAccess($returnUrl);
}
render('Ingreso', function (): void {
?>
Ingreso
Este sistema se abre desde Drupal mediante token firmado.
Si llegaste aqui manualmente, vuelve al enlace configurado en Drupal.
query('SELECT status, COUNT(*) total FROM email_recipients GROUP BY status')->fetchAll();
$pending = (int) $pdo->query("SELECT COUNT(*) FROM email_recipients WHERE status = 'pendiente'")->fetchColumn();
$templates = (int) $pdo->query('SELECT COUNT(*) FROM templates WHERE is_active = 1')->fetchColumn();
$events = (int) $pdo->query('SELECT COUNT(*) FROM email_events')->fetchColumn();
render('Inicio', function () use ($statuses, $pending, $templates, $events): void {
?>
Pendientes
Plantillas activas
Eventos Postmark
Estados
Aun no hay registros cargados.
$keys));
flash('success', 'Configuracion guardada.');
redirect_to('/admin/settings');
}
render('Configuracion', function (): void {
?>
prepare('UPDATE templates SET is_active = IF(is_active = 1, 0, 1) WHERE id = ?');
$stmt->execute(array((int) $_POST['id']));
Audit::log('template_toggle', 'templates', (string) $_POST['id']);
flash('success', 'Estado de plantilla actualizado.');
redirect_to('/admin/templates');
}
if (trim((string) ($_POST['name'] ?? '')) === '' || trim((string) ($_POST['postmark_template_key'] ?? '')) === '') {
flash('error', 'Nombre e ID/Alias Postmark son obligatorios.');
redirect_to('/admin/templates');
}
$id = Templates::save($_POST);
Audit::log('template_save', 'templates', (string) $id);
flash('success', 'Plantilla guardada.');
redirect_to('/admin/templates');
}
if (!empty($_GET['edit'])) {
$edit = Templates::find((int) $_GET['edit']);
}
$templates = Templates::all();
render('Plantillas', function () use ($templates, $edit): void {
?>
Plantillas Postmark
Registra solo referencias a plantillas existentes. La plantilla se edita en Postmark.
Plantillas registradas
| Nombre | ID/Alias Postmark | Variables | Estado | Acciones |
|---|
|
|
|
|
Editar
|
getMessage());
redirect_to('/csv');
}
}
render('Cargar CSV', function () use ($templates): void {
?>
Cargar CSV
Primero registra una plantilla activa en administracion.
beginTransaction();
$user = Auth::user();
$stmt = $pdo->prepare(
'INSERT INTO email_batches (source, template_id, total_rows, valid_rows, created_by_uid, created_by_name)
VALUES (?, ?, 1, 1, ?, ?)'
);
$stmt->execute(array('manual', $selectedId, $user['uid'] ?? null, $user['username'] ?? null));
$batchId = (int) $pdo->lastInsertId();
$stmt = $pdo->prepare(
'INSERT INTO email_recipients (batch_id, template_id, email, display_name, status, template_model_json)
VALUES (?, ?, ?, ?, ?, ?)'
);
$stmt->execute(array($batchId, $selectedId, $email, trim((string) ($_POST['display_name'] ?? '')), 'pendiente', json_encode($model, JSON_UNESCAPED_UNICODE)));
$recipientId = (int) $pdo->lastInsertId();
$pdo->commit();
Audit::log('manual_create', 'email_recipients', (string) $recipientId, array('template_id' => $selectedId));
flash('success', 'Registro manual creado como pendiente.');
redirect_to('/send');
}
render('Ingreso manual', function () use ($templates, $selectedId, $template): void {
$variables = $template ? Templates::variables($template) : array();
?>
query("SELECT id FROM email_recipients WHERE status = 'pendiente'")->fetchAll(PDO::FETCH_COLUMN);
}
if (!$ids) {
flash('warning', 'No hay registros seleccionados para enviar.');
redirect_to('/send');
}
$sent = 0;
$errors = 0;
$client = new PostmarkClient();
$stmtSelect = $pdo->prepare(
'SELECT r.*, t.name template_name, t.postmark_template_key
FROM email_recipients r INNER JOIN templates t ON t.id = r.template_id
WHERE r.id = ? AND r.status = \'pendiente\''
);
$stmtMsg = $pdo->prepare(
'INSERT INTO email_messages (recipient_id, postmark_message_id, message_stream, status, response_json, sent_by_uid, sent_by_name)
VALUES (?, ?, ?, ?, ?, ?, ?)'
);
$stmtUpdate = $pdo->prepare('UPDATE email_recipients SET status = ?, error_message = ? WHERE id = ?');
$user = Auth::user();
foreach ($ids as $id) {
$stmtSelect->execute(array($id));
$recipient = $stmtSelect->fetch();
if (!$recipient) {
continue;
}
$template = array(
'postmark_template_key' => $recipient['postmark_template_key'],
'name' => $recipient['template_name'],
);
try {
[$response, $stream] = $client->sendTemplate($template, $recipient);
$messageId = $response['MessageID'] ?? null;
$stmtMsg->execute(array($id, $messageId, $stream, 'enviado', json_encode($response, JSON_UNESCAPED_UNICODE), $user['uid'] ?? null, $user['username'] ?? null));
$stmtUpdate->execute(array('enviado', null, $id));
$sent++;
} catch (Throwable $e) {
$stmtMsg->execute(array($id, null, Settings::get('postmark_message_stream', 'outbound'), 'error', json_encode(array('error' => $e->getMessage()), JSON_UNESCAPED_UNICODE), $user['uid'] ?? null, $user['username'] ?? null));
$stmtUpdate->execute(array('error', $e->getMessage(), $id));
$errors++;
}
}
Audit::log('send_pending', 'email_recipients', null, array('requested' => count($ids), 'sent' => $sent, 'errors' => $errors));
flash($errors ? 'warning' : 'success', 'Envio terminado. Enviados: ' . $sent . ', errores: ' . $errors . '.');
redirect_to('/send');
}
$pending = $pdo->query(
'SELECT r.*, t.name template_name
FROM email_recipients r INNER JOIN templates t ON t.id = r.template_id
WHERE r.status = \'pendiente\'
ORDER BY r.created_at ASC
LIMIT 100'
)->fetchAll();
render('Enviar pendientes', function () use ($pending): void {
?>
0) {
$where[] = 'r.template_id = ?';
$params[] = $templateId;
}
$stmtTotal = Database::pdo()->prepare(
'SELECT COUNT(*)
FROM email_recipients r
WHERE ' . implode(' AND ', $where)
);
$stmtTotal->execute($params);
$total = (int) $stmtTotal->fetchColumn();
$page = min($page, max(1, (int) ceil($total / $perPage)));
$offset = ($page - 1) * $perPage;
$stmt = Database::pdo()->prepare(
'SELECT r.*, t.name template_name,
(SELECT m.postmark_message_id
FROM email_messages m
WHERE m.recipient_id = r.id
ORDER BY m.sent_at DESC
LIMIT 1) postmark_message_id
FROM email_recipients r
INNER JOIN templates t ON t.id = r.template_id
WHERE ' . implode(' AND ', $where) . '
ORDER BY r.created_at DESC
LIMIT ? OFFSET ?'
);
foreach (array_values($params) as $idx => $value) {
$stmt->bindValue($idx + 1, $value);
}
$stmt->bindValue(count($params) + 1, $perPage, PDO::PARAM_INT);
$stmt->bindValue(count($params) + 2, $offset, PDO::PARAM_INT);
$stmt->execute();
$rows = $stmt->fetchAll();
$templates = Templates::all();
render('Historial', function () use ($rows, $templates, $month, $year, $status, $email, $templateId, $page, $total, $perPage): void {
$statuses = array('', 'pendiente', 'enviado', 'procesado', 'entregado', 'abierto', 'click', 'rebote', 'error');
$paginationQuery = array(
'month' => $month,
'year' => $year,
'status' => $status,
'template_id' => $templateId,
'email' => $email,
);
?>
| Fecha | Correo | Plantilla | Estado | MessageID | |
|---|
|
|
|
|
|
Detalle |
prepare(
'SELECT r.*, t.name template_name FROM email_recipients r INNER JOIN templates t ON t.id = r.template_id WHERE r.id = ?'
);
$stmt->execute(array($id));
$recipient = $stmt->fetch();
if (!$recipient) {
not_found_route();
return;
}
$stmt = Database::pdo()->prepare('SELECT * FROM email_messages WHERE recipient_id = ? ORDER BY sent_at DESC');
$stmt->execute(array($id));
$messages = $stmt->fetchAll();
$stmt = Database::pdo()->prepare('SELECT * FROM email_events WHERE recipient_id = ? ORDER BY COALESCE(event_at, created_at) DESC');
$stmt->execute(array($id));
$events = $stmt->fetchAll();
Audit::log('message_view', 'email_recipients', (string) $id);
render('Detalle', function () use ($recipient, $messages, $events): void {
?>
Detalle del correo
Correo:
Plantilla:
Estado:
TemplateModel
Mensajes
| Fecha | MessageID | Stream | Estado | Respuesta |
|---|
|
|
|
|
JSON |
Eventos
| Fecha | Evento | Estado | JSON |
|---|
|
|
|
Ver JSON |
'forbidden'), 403);
}
$raw = file_get_contents('php://input') ?: '';
$payload = json_decode($raw, true);
if (!is_array($payload)) {
json_response(array('error' => 'invalid_json'), 400);
}
$messageId = (string) ($payload['MessageID'] ?? $payload['MessageId'] ?? '');
$recordType = (string) ($payload['RecordType'] ?? $payload['Type'] ?? 'unknown');
$status = StatusMapper::fromPostmarkEvent($recordType);
$eventAt = $payload['ReceivedAt'] ?? $payload['DeliveredAt'] ?? $payload['BouncedAt'] ?? $payload['ClickedAt'] ?? $payload['OpenedAt'] ?? null;
$recipientId = null;
$storedStream = null;
if ($messageId !== '') {
$stmt = Database::pdo()->prepare('SELECT recipient_id, message_stream FROM email_messages WHERE postmark_message_id = ? ORDER BY id DESC LIMIT 1');
$stmt->execute(array($messageId));
$messageRow = $stmt->fetch();
if ($messageRow) {
$recipientId = $messageRow['recipient_id'] ?: null;
$storedStream = $messageRow['message_stream'] ?: null;
}
}
$acceptedStream = trim(Settings::get('webhook_message_stream_filter', ''));
$payloadStream = webhook_payload_stream($payload);
if ($acceptedStream !== '') {
$streamToCheck = $payloadStream !== '' ? $payloadStream : (string) $storedStream;
if ($streamToCheck === '' || strcasecmp($streamToCheck, $acceptedStream) !== 0) {
json_response(array('ok' => true, 'ignored' => true, 'reason' => 'message_stream_mismatch'));
}
}
$stmt = Database::pdo()->prepare(
'INSERT INTO email_events (postmark_message_id, recipient_id, event_type, event_status, event_at, raw_json)
VALUES (?, ?, ?, ?, ?, ?)'
);
$stmt->execute(array($messageId ?: null, $recipientId, $recordType, $status, $eventAt ? date('Y-m-d H:i:s', strtotime((string) $eventAt)) : null, json_encode($payload, JSON_UNESCAPED_UNICODE)));
if ($recipientId) {
$stmt = Database::pdo()->prepare('UPDATE email_recipients SET status = ? WHERE id = ?');
$stmt->execute(array($status, $recipientId));
$stmt = Database::pdo()->prepare('UPDATE email_messages SET status = ? WHERE postmark_message_id = ?');
$stmt->execute(array($status, $messageId));
}
Audit::log('postmark_webhook', 'email_messages', $messageId ?: null, array('event' => $recordType, 'status' => $status));
json_response(array('ok' => true));
}
function webhook_payload_stream(array $payload): string
{
foreach (array('MessageStream', 'MessageStreamID', 'MessageStreamId', 'MessageStreamName') as $key) {
if (!empty($payload[$key])) {
return trim((string) $payload[$key]);
}
}
return '';
}
function admin_logs_route(): void
{
Auth::requireAdmin();
$date = trim((string) ($_GET['date'] ?? ''));
$username = trim((string) ($_GET['username'] ?? ''));
$action = trim((string) ($_GET['action'] ?? ''));
$entity = trim((string) ($_GET['entity'] ?? ''));
$perPage = 50;
$page = max(1, (int) ($_GET['page'] ?? 1));
$where = array('1 = 1');
$params = array();
if ($date !== '') {
$where[] = 'DATE(created_at) = ?';
$params[] = $date;
}
if ($username !== '') {
$where[] = 'username LIKE ?';
$params[] = '%' . $username . '%';
}
if ($action !== '') {
$where[] = 'action LIKE ?';
$params[] = '%' . $action . '%';
}
if ($entity !== '') {
$where[] = "CONCAT(COALESCE(entity_type, ''), ' ', COALESCE(entity_id, '')) LIKE ?";
$params[] = '%' . $entity . '%';
}
$stmtTotal = Database::pdo()->prepare('SELECT COUNT(*) FROM audit_logs WHERE ' . implode(' AND ', $where));
$stmtTotal->execute($params);
$total = (int) $stmtTotal->fetchColumn();
$page = min($page, max(1, (int) ceil($total / $perPage)));
$offset = ($page - 1) * $perPage;
$stmt = Database::pdo()->prepare(
'SELECT * FROM audit_logs
WHERE ' . implode(' AND ', $where) . '
ORDER BY created_at DESC
LIMIT ? OFFSET ?'
);
foreach (array_values($params) as $idx => $value) {
$stmt->bindValue($idx + 1, $value);
}
$stmt->bindValue(count($params) + 1, $perPage, PDO::PARAM_INT);
$stmt->bindValue(count($params) + 2, $offset, PDO::PARAM_INT);
$stmt->execute();
$rows = $stmt->fetchAll();
render('Logs', function () use ($rows, $date, $username, $action, $entity, $page, $total, $perPage): void {
$paginationQuery = array(
'date' => $date,
'username' => $username,
'action' => $action,
'entity' => $entity,
);
?>
| Fecha | Usuario | Accion | Entidad | Metadata |
|---|
|
|
|
|
JSON |
No encontrado
La pagina solicitada no existe.
';
});
}