<php
declare(strict_types=1);

session_start();

$loggedIn = isset($_SESSION['user_id']);
$isAdmin = $loggedIn && (($_SESSION['role'] ?? '') === 'admin');
$remoteAddr = (string)($_SERVER['REMOTE_ADDR'] ?? '');
$serverName = strtolower((string)($_SERVER['SERVER_NAME'] ?? ''));
$isLocalRequest = in_array($remoteAddr, ['127.0.0.1', '::1'], true)
    || in_array($serverName, ['localhost', '127.0.0.1', '::1'], true);
$canUseImportPage = $isAdmin || $isLocalRequest;
$pageTitle = 'Meteor-Import';

function h(string $value): string
{
    return htmlspecialchars($value, ENT_QUOTES, 'UTF-8');
}

function toNullableFloat(mixed $value): ?float
{
    if ($value === null || $value === '') {
        return null;
    }

    if (is_string($value)) {
        $value = str_replace(',', '.', trim($value));
    }

    return is_numeric($value) ? (float)$value : null;
}

function toNullableInt(mixed $value): ?int
{
    if ($value === null || $value === '') {
        return null;
    }

    if (is_string($value)) {
        $value = trim($value);
    }

    return preg_match('/^\d+$/', (string)$value) ? (int)$value : null;
}

function ensureMeteorShowersTable(PDO $pdo): void
{
    $pdo->exec(
        "CREATE TABLE IF NOT EXISTS `meteoshowers` (
          `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,
          `shower_code` varchar(16) NOT NULL,
          `designation` varchar(255) NOT NULL,
          `iau_no` int(10) unsigned DEFAULT NULL,
          `speed` double DEFAULT NULL,
          `radiant_alpha` double DEFAULT NULL,
          `radiant_delta` double DEFAULT NULL,
          `drift_alpha` double DEFAULT NULL,
          `drift_delta` double DEFAULT NULL,
          `parent_obj` varchar(255) DEFAULT NULL,
          `pidx` double DEFAULT NULL,
          `activity_json` longtext CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL CHECK (json_valid(`activity_json`)),
          `source_entry_json` longtext CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL CHECK (json_valid(`source_entry_json`)),
          `source_dataset_name` varchar(128) DEFAULT NULL,
          `source_dataset_version` int(10) unsigned DEFAULT NULL,
          `created_at` datetime NOT NULL DEFAULT current_timestamp(),
          `updated_at` datetime NOT NULL DEFAULT current_timestamp() ON UPDATE current_timestamp(),
          PRIMARY KEY (`id`),
          UNIQUE KEY `uq_meteoshowers_shower_code` (`shower_code`),
          UNIQUE KEY `uq_meteoshowers_iau_no` (`iau_no`),
          KEY `idx_meteoshowers_designation` (`designation`),
          KEY `idx_meteoshowers_parent_obj` (`parent_obj`),
          KEY `idx_meteoshowers_speed` (`speed`),
          KEY `idx_meteoshowers_pidx` (`pidx`)
        ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci"
    );
}

$defaultJsonPath = realpath(__DIR__ . '/MeteorShowers.json') ?: (__DIR__ . '/MeteorShowers.json');
$selectedJsonPath = (string)$defaultJsonPath;
$report = null;
$errorMessage = null;

if ($canUseImportPage && $_SERVER['REQUEST_METHOD'] === 'POST') {
    $jsonPath = trim((string)($_POST['json_path'] ?? ''));
    if ($jsonPath === '') {
        $jsonPath = (string)$defaultJsonPath;
    }
    $selectedJsonPath = $jsonPath;

    try {
        if (!is_file($jsonPath)) {
            throw new RuntimeException('JSON-Datei nicht gefunden: ' . $jsonPath);
        }

        $config = require __DIR__ . '/../../config/database.php';
        $dsn = sprintf(
            'mysql:host=%s;dbname=%s;charset=%s',
            $config['host'],
            $config['dbname'],
            $config['charset'] ?? 'utf8mb4'
        );

        $pdo = new PDO(
            $dsn,
            $config['user'],
            $config['pass'],
            [
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
            ]
        );

        ensureMeteorShowersTable($pdo);

        $json = file_get_contents($jsonPath);
        if ($json === false) {
            throw new RuntimeException('JSON-Datei konnte nicht gelesen werden.');
        }

        $data = json_decode($json, true, 512, JSON_THROW_ON_ERROR);
        $showers = $data['showers'] ?? null;
        if (!is_array($showers)) {
            throw new RuntimeException('Ungueltige JSON-Struktur: "showers" fehlt oder ist kein Objekt.');
        }

        $datasetName = isset($data['shortName']) ? trim((string)$data['shortName']) : null;
        $datasetVersion = toNullableInt($data['version'] ?? null);

        $selectStmt = $pdo->prepare('SELECT `id` FROM `meteoshowers` WHERE `shower_code` = :shower_code LIMIT 1');
        $upsertStmt = $pdo->prepare(
            "INSERT INTO `meteoshowers` (
                `shower_code`,
                `designation`,
                `iau_no`,
                `speed`,
                `radiant_alpha`,
                `radiant_delta`,
                `drift_alpha`,
                `drift_delta`,
                `parent_obj`,
                `pidx`,
                `activity_json`,
                `source_entry_json`,
                `source_dataset_name`,
                `source_dataset_version`
            ) VALUES (
                :shower_code,
                :designation,
                :iau_no,
                :speed,
                :radiant_alpha,
                :radiant_delta,
                :drift_alpha,
                :drift_delta,
                :parent_obj,
                :pidx,
                :activity_json,
                :source_entry_json,
                :source_dataset_name,
                :source_dataset_version
            )
            ON DUPLICATE KEY UPDATE
                `designation` = VALUES(`designation`),
                `iau_no` = VALUES(`iau_no`),
                `speed` = VALUES(`speed`),
                `radiant_alpha` = VALUES(`radiant_alpha`),
                `radiant_delta` = VALUES(`radiant_delta`),
                `drift_alpha` = VALUES(`drift_alpha`),
                `drift_delta` = VALUES(`drift_delta`),
                `parent_obj` = VALUES(`parent_obj`),
                `pidx` = VALUES(`pidx`),
                `activity_json` = VALUES(`activity_json`),
                `source_entry_json` = VALUES(`source_entry_json`),
                `source_dataset_name` = VALUES(`source_dataset_name`),
                `source_dataset_version` = VALUES(`source_dataset_version`),
                `updated_at` = CURRENT_TIMESTAMP()"
        );

        $processed = 0;
        $inserted = 0;
        $updated = 0;

        $pdo->beginTransaction();
        foreach ($showers as $code => $entry) {
            if (!is_array($entry)) {
                continue;
            }

            $showerCode = strtoupper(trim((string)$code));
            if ($showerCode === '') {
                continue;
            }

            $selectStmt->execute([':shower_code' => $showerCode]);
            $exists = $selectStmt->fetchColumn() !== false;

            $designation = trim((string)($entry['designation'] ?? $showerCode));
            if ($designation === '') {
                $designation = $showerCode;
            }

            $activity = isset($entry['activity']) && is_array($entry['activity']) ? $entry['activity'] : [];

            $upsertStmt->execute([
                ':shower_code' => $showerCode,
                ':designation' => $designation,
                ':iau_no' => toNullableInt($entry['IAUNo'] ?? null),
                ':speed' => toNullableFloat($entry['speed'] ?? null),
                ':radiant_alpha' => toNullableFloat($entry['radiantAlpha'] ?? null),
                ':radiant_delta' => toNullableFloat($entry['radiantDelta'] ?? null),
                ':drift_alpha' => toNullableFloat($entry['driftAlpha'] ?? null),
                ':drift_delta' => toNullableFloat($entry['driftDelta'] ?? null),
                ':parent_obj' => isset($entry['parentObj']) && trim((string)$entry['parentObj']) !== '' ? trim((string)$entry['parentObj']) : null,
                ':pidx' => toNullableFloat($entry['pidx'] ?? null),
                ':activity_json' => json_encode($activity, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES),
                ':source_entry_json' => json_encode($entry, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES),
                ':source_dataset_name' => $datasetName !== null && $datasetName !== '' ? $datasetName : null,
                ':source_dataset_version' => $datasetVersion,
            ]);

            $processed++;
            if ($exists) {
                $updated++;
            } else {
                $inserted++;
            }
        }
        $pdo->commit();

        $tableCount = (int)$pdo->query('SELECT COUNT(*) FROM `meteoshowers`')->fetchColumn();
        $report = [
            'json_path' => $jsonPath,
            'dataset_name' => $datasetName,
            'dataset_version' => $datasetVersion,
            'processed' => $processed,
            'inserted' => $inserted,
            'updated' => $updated,
            'table_count' => $tableCount,
        ];
    } catch (Throwable $e) {
        if (isset($pdo) && $pdo instanceof PDO && $pdo->inTransaction()) {
            $pdo->rollBack();
        }
        $errorMessage = $e->getMessage();
    }
}
?>
<!DOCTYPE html>
<html lang="de">
<head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title><?= h($pageTitle) ?></title>
</head>
<body style="margin:0;padding:24px;font-family:Arial,sans-serif;background:#f5f5f5;color:#111;">
    <div style="max-width:900px;margin:0 auto;background:#fff;border:1px solid #ccc;padding:24px;">
        <h1 style="margin:0 0 12px;">Meteor-Import</h1>
        <p style="margin:0 0 18px;">
            Importiert <code>MeteorShowers.json</code> in die Tabelle <code>meteoshowers</code>.
            Die Tabelle wird bei Bedarf automatisch angelegt.
        </p>

        <?php if (!$canUseImportPage): ?>
            <div style="border:1px solid #c33;background:#fff3f3;color:#900;padding:14px;">
                Diese Seite ist nur fuer Admins oder lokale Aufrufe auf localhost freigegeben.
            </div>
        <?php else: ?>
            <form method="post" style="display:grid;gap:12px;">
                <label style="display:grid;gap:6px;">
                    <span>JSON-Pfad</span>
                    <input
                        type="text"
                        name="json_path"
                        value="<?= h($selectedJsonPath) ?>"
                        style="width:100%;padding:10px 12px;border:1px solid #999;color:#111;"
                    >
                </label>
                <div>
                    <button type="submit" style="padding:10px 16px;border:1px solid #333;background:#eee;color:#111;cursor:pointer;">
                        Import Starten
                    </button>
                </div>
            </form>

            <?php if ($errorMessage !== null): ?>
                <div style="margin-top:18px;border:1px solid #c33;background:#fff3f3;color:#900;padding:14px;">
                    <strong>Fehler:</strong> <?= h($errorMessage) ?>
                </div>
            <?php endif; ?>

            <?php if (is_array($report)): ?>
                <div style="margin-top:18px;border:1px solid #3a7a3a;background:#f1fff1;color:#145214;padding:14px;line-height:1.7;">
                    <strong>Import abgeschlossen.</strong><br>
                    Datei: <?= h((string)$report['json_path']) ?><br>
                    Datensatz: <?= h((string)($report['dataset_name'] ?? '-')) ?><br>
                    Version: <?= h((string)($report['dataset_version'] ?? '-')) ?><br>
                    Verarbeitet: <?= h((string)$report['processed']) ?><br>
                    Neu: <?= h((string)$report['inserted']) ?><br>
                    Aktualisiert: <?= h((string)$report['updated']) ?><br>
                    Zeilen in `meteoshowers`: <?= h((string)$report['table_count']) ?>
                </div>
            <?php endif; ?>
        <?php endif; ?>
    </div>
</body>
</html>