torsten/yourpart3
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

Enhance syncDatabase function to include cleanup for orphaned promotional_gift entries, removing invalid sender and recipient character references, and improve logging for orphaned entry detection.

Browse Source
This commit is contained in:
Torsten Schulz (local)
2025-12-18 15:49:34 +01:00
parent addb8e9a6d
commit 346a326bfd
1 changed files with 43 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
backend/utils/syncDatabase.js
View File

@@ -96,21 +96,35 @@ const syncDatabase = async () => {
console.log(`✅ ${deletedCount3} verwaiste knowledge Einträge entfernt`); console.log(`✅ ${deletedCount3} verwaiste knowledge Einträge entfernt`);
} }
// Cleanup notification mit ungültigen user_id // Cleanup notification mit ungültigen user_id
const result4 = await sequelize.query(` const result4 = await sequelize.query(`
DELETE FROM falukant_log.notification DELETE FROM falukant_log.notification
WHERE user_id NOT IN ( WHERE user_id NOT IN (
SELECT id FROM falukant_data.falukant_user SELECT id FROM falukant_data.falukant_user
); );
`); `);
const deletedCount4 = result4[1] || 0; const deletedCount4 = result4[1] || 0;
if (deletedCount4 > 0) { if (deletedCount4 > 0) {
console.log(`✅ ${deletedCount4} verwaiste notification Einträge entfernt`); console.log(`✅ ${deletedCount4} verwaiste notification Einträge entfernt`);
} }
if (deletedCount1 === 0 && deletedCount2 === 0 && deletedCount3 === 0 && deletedCount4 === 0) { // Cleanup promotional_gift mit ungültigen sender_character_id oder recipient_character_id
console.log("✅ Keine verwaisten Einträge gefunden"); const result5 = await sequelize.query(`
} DELETE FROM falukant_log.promotional_gift
WHERE sender_character_id NOT IN (
SELECT id FROM falukant_data.character
) OR recipient_character_id NOT IN (
SELECT id FROM falukant_data.character
);
`);
const deletedCount5 = result5[1] || 0;
if (deletedCount5 > 0) {
console.log(`✅ ${deletedCount5} verwaiste promotional_gift Einträge entfernt`);
}
if (deletedCount1 === 0 && deletedCount2 === 0 && deletedCount3 === 0 && deletedCount4 === 0 && deletedCount5 === 0) {
console.log("✅ Keine verwaisten Einträge gefunden");
}
} catch (e) { } catch (e) {
console.warn('⚠️ Konnte verwaiste Einträge nicht bereinigen:', e?.message || e); console.warn('⚠️ Konnte verwaiste Einträge nicht bereinigen:', e?.message || e);
} }
@@ -287,7 +301,21 @@ const syncDatabaseForDeployment = async () => {
console.log(`✅ ${deletedCount4} verwaiste notification Einträge entfernt`); console.log(`✅ ${deletedCount4} verwaiste notification Einträge entfernt`);
} }
if (deletedCount1 === 0 && deletedCount2 === 0 && deletedCount3 === 0 && deletedCount4 === 0) { // Cleanup promotional_gift mit ungültigen sender_character_id oder recipient_character_id
const result5 = await sequelize.query(`
DELETE FROM falukant_log.promotional_gift
WHERE sender_character_id NOT IN (
SELECT id FROM falukant_data.character
) OR recipient_character_id NOT IN (
SELECT id FROM falukant_data.character
);
`);
const deletedCount5 = result5[1] || 0;
if (deletedCount5 > 0) {
console.log(`✅ ${deletedCount5} verwaiste promotional_gift Einträge entfernt`);
}
if (deletedCount1 === 0 && deletedCount2 === 0 && deletedCount3 === 0 && deletedCount4 === 0 && deletedCount5 === 0) {
console.log("✅ Keine verwaisten Einträge gefunden"); console.log("✅ Keine verwaisten Einträge gefunden");
} }
} catch (e) { } catch (e) {