Eskimue/skyview.astronomiemuseum.de
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

import Meteorschauers fertig

Browse Source
This commit is contained in:
Eskimue
2026-04-03 18:40:59 +02:00
parent b2462f6512
commit 5d5901c623
7 changed files with 425 additions and 1130 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/import/import_meteorshowers.php
+198 -68
View File
@@ -1,6 +1,8 @@
<php
<?php
declare(strict_types=1);
// Die Datei MeteorShowers.json stammt aus Stellarium und dient hier als Importquelle.
session_start();
$loggedIn = isset($_SESSION['user_id']);
@@ -46,33 +48,123 @@ function toNullableInt(mixed $value): ?int
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(),
"CREATE TABLE IF NOT EXISTS `meteorshowers` (
`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'Eindeutige interne ID des Meteorstroms',
`shower_code` varchar(16) NOT NULL COMMENT 'Kurzer IAU- oder Projektcode des Meteorstroms, z. B. PER oder GEM',
`iau_no` smallint(5) unsigned DEFAULT NULL COMMENT 'Offizielle IAU-Nummer des Meteorstroms, falls vorhanden',
`designation` varchar(255) NOT NULL COMMENT 'Vollstaendige Bezeichnung des Meteorstroms',
`speed_kms` decimal(6,2) DEFAULT NULL COMMENT 'Geozentrische Eintrittsgeschwindigkeit der Meteore in km/s',
`radiant_alpha_deg` decimal(7,3) DEFAULT NULL COMMENT 'Rektaszension des Radianten in Grad',
`radiant_delta_deg` decimal(7,3) DEFAULT NULL COMMENT 'Deklination des Radianten in Grad',
`drift_alpha_deg` decimal(7,3) DEFAULT NULL COMMENT 'Taegliche Aenderung der Radianten-Rektaszension in Grad',
`drift_delta_deg` decimal(7,3) DEFAULT NULL COMMENT 'Taegliche Aenderung der Radianten-Deklination in Grad',
`parent_object` varchar(255) DEFAULT NULL COMMENT 'Vermuteter oder bekannter Mutterkoerper, z. B. ein Komet oder Asteroid',
`population_index` decimal(4,2) DEFAULT NULL COMMENT 'Populationsindex r als Mass fuer die Helligkeitsverteilung der Meteore',
`active_start_sol` decimal(6,2) DEFAULT NULL COMMENT 'Beginn der Aktivitaet in Sonnenlaenge (Grad, 0-360)',
`active_finish_sol` decimal(6,2) DEFAULT NULL COMMENT 'Ende der Aktivitaet in Sonnenlaenge (Grad, 0-360)',
`peak_sol` decimal(6,2) DEFAULT NULL COMMENT 'Maximum des Meteorstroms in Sonnenlaenge (Grad, 0-360)',
`zhr` int(11) DEFAULT NULL COMMENT 'Zenithal Hourly Rate des generischen Aktivitaetseintrags',
`zhr_variable` varchar(32) DEFAULT NULL COMMENT 'Textuelle variable ZHR-Angabe, z. B. 5-20 oder 20-700',
`disttype` tinyint(3) unsigned DEFAULT NULL COMMENT 'Typ der Aktivitaetsverteilung aus der Quelldatei',
`b1` decimal(8,4) DEFAULT NULL COMMENT 'Parameter b1 fuer das Aktivitaetsprofil aus der Quelldatei',
`b2` decimal(8,4) DEFAULT NULL COMMENT 'Parameter b2 fuer das Aktivitaetsprofil aus der Quelldatei',
`activity_json` json DEFAULT NULL COMMENT 'Komplettes activity-Array aus der JSON-Datei mit generischen und jahresspezifischen Aktivitaetsdaten',
`colors_json` json DEFAULT NULL COMMENT 'Optionale Farbverteilung der Meteore aus der JSON-Datei',
`source_entry_json` json DEFAULT NULL COMMENT 'Originaler kompletter JSON-Eintrag des Meteorstroms zur Nachvollziehbarkeit',
`has_yearly_variants` tinyint(1) NOT NULL DEFAULT 0 COMMENT '1, wenn neben generic auch jahresspezifische Aktivitaetseintraege vorhanden sind',
`dataset_version` int(10) unsigned DEFAULT NULL COMMENT 'Versionsnummer des importierten Quelldatensatzes',
`updated_at` timestamp NOT NULL DEFAULT current_timestamp() ON UPDATE current_timestamp() COMMENT 'Zeitpunkt der letzten Aktualisierung des Datensatzes',
`created_at` timestamp NOT NULL DEFAULT current_timestamp() COMMENT 'Zeitpunkt der Erstellung des Datensatzes',
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"
UNIQUE KEY `uq_meteorshowers_code` (`shower_code`),
UNIQUE KEY `uq_meteorshowers_iau_no` (`iau_no`),
KEY `idx_meteorshowers_designation` (`designation`),
KEY `idx_meteorshowers_active_start` (`active_start_sol`),
KEY `idx_meteorshowers_active_finish` (`active_finish_sol`),
KEY `idx_meteorshowers_peak` (`peak_sol`),
KEY `idx_meteorshowers_zhr` (`zhr`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci
COMMENT='Meteorstroeme mit Stammdaten sowie generischen und historischen Aktivitaetsinformationen'"
);
$requiredColumns = [
'shower_code',
'iau_no',
'designation',
'speed_kms',
'radiant_alpha_deg',
'radiant_delta_deg',
'drift_alpha_deg',
'drift_delta_deg',
'parent_object',
'population_index',
'active_start_sol',
'active_finish_sol',
'peak_sol',
'zhr',
'zhr_variable',
'disttype',
'b1',
'b2',
'activity_json',
'colors_json',
'source_entry_json',
'has_yearly_variants',
'dataset_version',
];
$stmt = $pdo->query('SHOW COLUMNS FROM `meteorshowers`');
$existingColumns = $stmt->fetchAll(PDO::FETCH_COLUMN);
$missingColumns = array_values(array_diff($requiredColumns, $existingColumns));
if ($missingColumns !== []) {
throw new RuntimeException(
'Tabelle `meteorshowers` hat nicht das erwartete Schema. Fehlende Spalten: '
. implode(', ', $missingColumns)
);
}
}
function findGenericActivity(array $activity): ?array
{
foreach ($activity as $entry) {
if (!is_array($entry)) {
continue;
}
if (strtolower(trim((string)($entry['year'] ?? ''))) === 'generic') {
return $entry;
}
}
return null;
}
function hasYearlyVariants(array $activity): bool
{
foreach ($activity as $entry) {
if (!is_array($entry)) {
continue;
}
$year = strtolower(trim((string)($entry['year'] ?? '')));
if ($year !== '' && $year !== 'generic') {
return true;
}
}
return false;
}
function toNullableString(mixed $value): ?string
{
if ($value === null) {
return null;
}
$value = trim((string)$value);
return $value === '' ? null : $value;
}
$defaultJsonPath = realpath(__DIR__ . '/MeteorShowers.json') ?: (__DIR__ . '/MeteorShowers.json');
@@ -123,56 +215,83 @@ if ($canUseImportPage && $_SERVER['REQUEST_METHOD'] === 'POST') {
throw new RuntimeException('Ungueltige JSON-Struktur: "showers" fehlt oder ist kein Objekt.');
}
$datasetName = isset($data['shortName']) ? trim((string)$data['shortName']) : null;
$datasetName = toNullableString($data['shortName'] ?? null);
$datasetVersion = toNullableInt($data['version'] ?? null);
$selectStmt = $pdo->prepare('SELECT `id` FROM `meteoshowers` WHERE `shower_code` = :shower_code LIMIT 1');
$selectStmt = $pdo->prepare('SELECT `id` FROM `meteorshowers` WHERE `shower_code` = :shower_code LIMIT 1');
$upsertStmt = $pdo->prepare(
"INSERT INTO `meteoshowers` (
"INSERT INTO `meteorshowers` (
`shower_code`,
`designation`,
`iau_no`,
`speed`,
`radiant_alpha`,
`radiant_delta`,
`drift_alpha`,
`drift_delta`,
`parent_obj`,
`pidx`,
`speed_kms`,
`radiant_alpha_deg`,
`radiant_delta_deg`,
`drift_alpha_deg`,
`drift_delta_deg`,
`parent_object`,
`population_index`,
`active_start_sol`,
`active_finish_sol`,
`peak_sol`,
`zhr`,
`zhr_variable`,
`disttype`,
`b1`,
`b2`,
`activity_json`,
`colors_json`,
`source_entry_json`,
`source_dataset_name`,
`source_dataset_version`
`has_yearly_variants`,
`dataset_version`
) VALUES (
:shower_code,
:designation,
:iau_no,
:speed,
:radiant_alpha,
:radiant_delta,
:drift_alpha,
:drift_delta,
:parent_obj,
:pidx,
:speed_kms,
:radiant_alpha_deg,
:radiant_delta_deg,
:drift_alpha_deg,
:drift_delta_deg,
:parent_object,
:population_index,
:active_start_sol,
:active_finish_sol,
:peak_sol,
:zhr,
:zhr_variable,
:disttype,
:b1,
:b2,
:activity_json,
:colors_json,
:source_entry_json,
:source_dataset_name,
:source_dataset_version
:has_yearly_variants,
: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`),
`speed_kms` = VALUES(`speed_kms`),
`radiant_alpha_deg` = VALUES(`radiant_alpha_deg`),
`radiant_delta_deg` = VALUES(`radiant_delta_deg`),
`drift_alpha_deg` = VALUES(`drift_alpha_deg`),
`drift_delta_deg` = VALUES(`drift_delta_deg`),
`parent_object` = VALUES(`parent_object`),
`population_index` = VALUES(`population_index`),
`active_start_sol` = VALUES(`active_start_sol`),
`active_finish_sol` = VALUES(`active_finish_sol`),
`peak_sol` = VALUES(`peak_sol`),
`zhr` = VALUES(`zhr`),
`zhr_variable` = VALUES(`zhr_variable`),
`disttype` = VALUES(`disttype`),
`b1` = VALUES(`b1`),
`b2` = VALUES(`b2`),
`activity_json` = VALUES(`activity_json`),
`colors_json` = VALUES(`colors_json`),
`source_entry_json` = VALUES(`source_entry_json`),
`source_dataset_name` = VALUES(`source_dataset_name`),
`source_dataset_version` = VALUES(`source_dataset_version`),
`has_yearly_variants` = VALUES(`has_yearly_variants`),
`dataset_version` = VALUES(`dataset_version`),
`updated_at` = CURRENT_TIMESTAMP()"
);
@@ -200,22 +319,33 @@ if ($canUseImportPage && $_SERVER['REQUEST_METHOD'] === 'POST') {
}
$activity = isset($entry['activity']) && is_array($entry['activity']) ? $entry['activity'] : [];
$genericActivity = findGenericActivity($activity);
$colors = isset($entry['colors']) && is_array($entry['colors']) ? $entry['colors'] : [];
$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),
':speed_kms' => toNullableFloat($entry['speed'] ?? null),
':radiant_alpha_deg' => toNullableFloat($entry['radiantAlpha'] ?? null),
':radiant_delta_deg' => toNullableFloat($entry['radiantDelta'] ?? null),
':drift_alpha_deg' => toNullableFloat($entry['driftAlpha'] ?? null),
':drift_delta_deg' => toNullableFloat($entry['driftDelta'] ?? null),
':parent_object' => toNullableString($entry['parentObj'] ?? null),
':population_index' => toNullableFloat($entry['pidx'] ?? null),
':active_start_sol' => toNullableFloat($genericActivity['start'] ?? null),
':active_finish_sol' => toNullableFloat($genericActivity['finish'] ?? null),
':peak_sol' => toNullableFloat($genericActivity['peak'] ?? null),
':zhr' => toNullableInt($genericActivity['zhr'] ?? null),
':zhr_variable' => toNullableString($genericActivity['variable'] ?? null),
':disttype' => toNullableInt($genericActivity['disttype'] ?? null),
':b1' => toNullableFloat($genericActivity['b1'] ?? null),
':b2' => toNullableFloat($genericActivity['b2'] ?? null),
':activity_json' => json_encode($activity, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES),
':colors_json' => $colors !== [] ? json_encode($colors, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES) : null,
':source_entry_json' => json_encode($entry, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES),
':source_dataset_name' => $datasetName !== null && $datasetName !== '' ? $datasetName : null,
':source_dataset_version' => $datasetVersion,
':has_yearly_variants' => hasYearlyVariants($activity) ? 1 : 0,
':dataset_version' => $datasetVersion,
]);
$processed++;
@@ -227,7 +357,7 @@ if ($canUseImportPage && $_SERVER['REQUEST_METHOD'] === 'POST') {
}
$pdo->commit();
$tableCount = (int)$pdo->query('SELECT COUNT(*) FROM `meteoshowers`')->fetchColumn();
$tableCount = (int)$pdo->query('SELECT COUNT(*) FROM `meteorshowers`')->fetchColumn();
$report = [
'json_path' => $jsonPath,
'dataset_name' => $datasetName,
@@ -256,7 +386,7 @@ if ($canUseImportPage && $_SERVER['REQUEST_METHOD'] === 'POST') {
<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>.
Importiert <code>MeteorShowers.json</code> in die Tabelle <code>meteorshowers</code>.
Die Tabelle wird bei Bedarf automatisch angelegt.
</p>
@@ -297,7 +427,7 @@ if ($canUseImportPage && $_SERVER['REQUEST_METHOD'] === 'POST') {
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']) ?>
Zeilen in `meteorshowers`: <?= h((string)$report['table_count']) ?>
</div>
<?php endif; ?>
<?php endif; ?>