update
This commit is contained in:
@@ -352,6 +352,14 @@ async function syncFahrgenehmigungen(
|
||||
): Promise<{ neu: number; updated: number; skipped: number }> {
|
||||
let neu = 0, updated = 0, skipped = 0;
|
||||
|
||||
// One-time cleanup: remove wrongly-stored records from broken parsing
|
||||
const cleaned = await client.query(
|
||||
`DELETE FROM fahrgenehmigungen WHERE klasse = 'Ausstellungsdatum'`
|
||||
);
|
||||
if (cleaned.rowCount && cleaned.rowCount > 0) {
|
||||
log(`Cleaned up ${cleaned.rowCount} invalid Fahrgenehmigung records (klasse='Ausstellungsdatum')`);
|
||||
}
|
||||
|
||||
for (const f of fahrgenehmigungen) {
|
||||
const result = await client.query<{ user_id: string }>(
|
||||
`SELECT user_id FROM mitglieder_profile WHERE fdisk_standesbuch_nr = $1`,
|
||||
|
||||
Reference in New Issue
Block a user