diff --git a/scripts/fix-prod-all.php b/scripts/fix-prod-all.php new file mode 100644 index 0000000..9703e64 --- /dev/null +++ b/scripts/fix-prod-all.php @@ -0,0 +1,199 @@ + 'pdo_pgsql', + 'host' => 'localhost', + 'port' => 5432, + 'dbname' => 'inventory', + 'user' => 'ferme_user', + 'password' => 'fermerecette', +]); + +echo $dryRun ? "=== DRY RUN MODE ===\n\n" : "=== LIVE MODE ===\n\n"; + +$migratedCount = 0; +$restoredCount = 0; +$deletedOrphanedCfv = 0; +$deletedOrphanedCf = 0; +$skippedCount = 0; + +// ============================================================ +// PART 1: Migrate orphaned CFValues to current CFs +// ============================================================ +echo "--- PART 1: Migrate orphaned CFValues ---\n\n"; + +$entityTypes = [ + ['label' => 'piece', 'entityTable' => 'pieces', 'cfvFk' => 'pieceid', 'modelTypeFk' => 'typepieceid', 'cfModelTypeFk' => 'typepieceid'], + ['label' => 'composant', 'entityTable' => 'composants', 'cfvFk' => 'composantid', 'modelTypeFk' => 'typecomposantid', 'cfModelTypeFk' => 'typecomposantid'], + ['label' => 'product', 'entityTable' => 'products', 'cfvFk' => 'productid', 'modelTypeFk' => 'typeproductid', 'cfModelTypeFk' => 'typeproductid'], +]; + +foreach ($entityTypes as $et) { + // Find orphaned CFValues: the CF has ALL 3 FKs NULL + $orphanedValues = $conn->fetchAllAssociative(" + SELECT cfv.id as cfv_id, cfv.value, cfv.{$et['cfvFk']} as entity_id, + cf_old.id as old_cf_id, cf_old.name as field_name, + e.name as entity_name, e.{$et['modelTypeFk']} as model_type_id + FROM custom_field_values cfv + JOIN custom_fields cf_old ON cf_old.id = cfv.customfieldid + JOIN {$et['entityTable']} e ON e.id = cfv.{$et['cfvFk']} + WHERE cfv.{$et['cfvFk']} IS NOT NULL + AND cf_old.typecomposantid IS NULL + AND cf_old.typepieceid IS NULL + AND cf_old.typeproductid IS NULL + ORDER BY e.name, cf_old.name + "); + + echo sprintf(" %ss: %d orphaned values\n", $et['label'], count($orphanedValues)); + + foreach ($orphanedValues as $ov) { + if (!$ov['model_type_id']) { + ++$skippedCount; + continue; + } + + $currentCf = $conn->fetchAssociative( + "SELECT id FROM custom_fields WHERE {$et['cfModelTypeFk']} = ? AND name = ? LIMIT 1", + [$ov['model_type_id'], $ov['field_name']] + ); + + if (!$currentCf) { + // No matching CF on current ModelType — skip but keep value + ++$skippedCount; + continue; + } + + $existingValue = $conn->fetchAssociative( + "SELECT id, value FROM custom_field_values WHERE {$et['cfvFk']} = ? AND customfieldid = ?", + [$ov['entity_id'], $currentCf['id']] + ); + + if ($existingValue) { + if (('' === $existingValue['value'] || null === $existingValue['value']) && '' !== $ov['value'] && null !== $ov['value']) { + echo sprintf(" MIGRATE: %s '%s' field '%s' = '%s'\n", $et['label'], $ov['entity_name'], $ov['field_name'], $ov['value']); + if (!$dryRun) { + $conn->executeStatement('UPDATE custom_field_values SET value = ? WHERE id = ?', [$ov['value'], $existingValue['id']]); + } + ++$migratedCount; + } + if (!$dryRun) { + $conn->executeStatement('DELETE FROM custom_field_values WHERE id = ?', [$ov['cfv_id']]); + } + ++$deletedOrphanedCfv; + } else { + echo sprintf(" REASSIGN: %s '%s' field '%s' = '%s'\n", $et['label'], $ov['entity_name'], $ov['field_name'], $ov['value']); + if (!$dryRun) { + $conn->executeStatement('UPDATE custom_field_values SET customfieldid = ? WHERE id = ?', [$currentCf['id'], $ov['cfv_id']]); + } + ++$migratedCount; + } + } +} + +// ============================================================ +// PART 2: Restore composant values from audit logs +// ============================================================ +echo "\n--- PART 2: Restore values from audit logs ---\n\n"; + +$deletionLogs = $conn->fetchAllAssociative(" + SELECT al.entityid, al.entitytype, al.diff::text as diff + FROM audit_logs al + WHERE al.diff::text LIKE '%customField%' + AND al.diff::text LIKE '%\"to\":null%' + ORDER BY al.createdat DESC +"); + +echo sprintf(" Found %d audit entries with deleted values\n", count($deletionLogs)); + +foreach ($deletionLogs as $log) { + $diff = json_decode($log['diff'], true); + $entityType = $log['entitytype']; + + $cfvFk = match ($entityType) { + 'piece' => 'pieceid', + 'composant' => 'composantid', + 'product' => 'productid', + default => null, + }; + if (!$cfvFk) { + continue; + } + + foreach ($diff as $key => $change) { + if (!str_starts_with($key, 'customField:')) { + continue; + } + if (null !== $change['to']) { + continue; + } + $oldValue = $change['from']; + if (null === $oldValue || '' === $oldValue) { + continue; + } + + $fieldName = substr($key, strlen('customField:')); + + $cfv = $conn->fetchAssociative( + "SELECT cfv.id, cfv.value FROM custom_field_values cfv JOIN custom_fields cf ON cf.id = cfv.customfieldid WHERE cfv.{$cfvFk} = ? AND cf.name = ?", + [$log['entityid'], $fieldName] + ); + + if (!$cfv) { + continue; + } + + if ('' !== $cfv['value'] && null !== $cfv['value']) { + continue; + } + + echo sprintf(" RESTORE: %s %s field '%s' = '%s'\n", $entityType, $log['entityid'], $fieldName, $oldValue); + if (!$dryRun) { + $conn->executeStatement('UPDATE custom_field_values SET value = ? WHERE id = ?', [$oldValue, $cfv['id']]); + } + ++$restoredCount; + } +} + +// ============================================================ +// PART 3: Clean orphaned CF definitions +// ============================================================ +echo "\n--- PART 3: Clean orphaned CF definitions ---\n\n"; + +$orphanedCfs = $conn->fetchAllAssociative(' + SELECT cf.id FROM custom_fields cf + WHERE cf.typecomposantid IS NULL AND cf.typepieceid IS NULL AND cf.typeproductid IS NULL + AND NOT EXISTS (SELECT 1 FROM custom_field_values cfv WHERE cfv.customfieldid = cf.id) +'); + +echo sprintf(" %d orphaned CF definitions to delete\n", count($orphanedCfs)); +foreach ($orphanedCfs as $cf) { + if (!$dryRun) { + $conn->executeStatement('DELETE FROM custom_fields WHERE id = ?', [$cf['id']]); + } + ++$deletedOrphanedCf; +} + +echo sprintf("\n=== SUMMARY ===\n"); +echo sprintf("Values migrated/reassigned: %d\n", $migratedCount); +echo sprintf("Values restored from audit: %d\n", $restoredCount); +echo sprintf("Orphaned CFValues cleaned: %d\n", $deletedOrphanedCfv); +echo sprintf("Orphaned CF definitions deleted: %d\n", $deletedOrphanedCf); +echo sprintf("Skipped (no matching CF on ModelType): %d\n", $skippedCount); +echo "=== DONE ===\n";