<?php
header('Content-Type: application/json; charset=UTF-8');

try {
    // Conexión con manejo de errores
    $pdo = new PDO("mysql:host=localhost;dbname=CORREOS;charset=utf8mb4", "root", "root", [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION
    ]);

    // Recibir datos del POST
    $idCorreo = $_POST['id_correo'] ?? null;
    $remitente = $_POST['remitente'] ?? '';
    $asunto = $_POST['asunto'] ?? '';
    $mensaje = $_POST['mensaje'] ?? '';
    $area = $_POST['area'] ?? ''; // 👈 Nuevo campo área
    $leido = 'N';

    // Validar
    if (!$idCorreo) {
        throw new Exception("Falta ID_CORREO");
    }

    // Insertar notificación incluyendo el área
    $stmt = $pdo->prepare("
        INSERT INTO NOTIFICACION (
            ID_CORREO, REMITENTE, ASUNTO, MENSAJE, AREA, FECHA_ENVIO, LEIDO, CREADO_EN
        ) VALUES (
            :id, :remitente, :asunto, :mensaje, :area, NOW(), :leido, NOW()
        )
    ");

    $stmt->execute([
        ':id' => $idCorreo,
        ':remitente' => $remitente,
        ':asunto' => $asunto,
        ':mensaje' => $mensaje,
        ':area' => $area,
        ':leido' => $leido
    ]);

    echo json_encode(['success' => true]);

} catch (Exception $e) {
    echo json_encode(['success' => false, 'error' => $e->getMessage()]);
}
