vendor/bluue/recurring-invoices-bundle/migrations/Version20240710092649.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace RecurringInvoicesBundleMigrations;
  7. use Doctrine\DBAL\Schema\Schema;
  8. use Doctrine\Migrations\AbstractMigration;
  9. use Symfony\Component\Uid\UuidV6;
  11. final class Version20240710092649 extends AbstractMigration
  12. {
  13.     private array $lines;
  15.     public function preUp(Schema $schema): void
  16.     {
  17.         parent::preUp($schema);
  18.         $this->lines = $this->connection->executeQuery(
  19.             'SELECT * FROM recurring_invoices_bundle__recurring_invoice_line'
  20.         )->fetchAllAssociative();
  21.     }
  23.     public function up(Schema $schema): void
  24.     {
  25.         $this->addSql('ALTER TABLE recurring_invoices_bundle__recurring_invoice_line ADD product_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\', ADD declination_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\'');
  26.         $this->addSql('ALTER TABLE recurring_invoices_bundle__recurring_invoice_line ADD CONSTRAINT FK_BD96F0684584665A FOREIGN KEY (product_id) REFERENCES products_bundle__product (id)');
  27.         $this->addSql('ALTER TABLE recurring_invoices_bundle__recurring_invoice_line ADD CONSTRAINT FK_BD96F0689941A932 FOREIGN KEY (declination_id) REFERENCES products_bundle__declination (id)');
  28.         $this->addSql('CREATE INDEX IDX_BD96F0684584665A ON recurring_invoices_bundle__recurring_invoice_line (product_id)');
  29.         $this->addSql('CREATE INDEX IDX_BD96F0689941A932 ON recurring_invoices_bundle__recurring_invoice_line (declination_id)');
  30.     }
  32.     public function postUp(Schema $schema): void
  33.     {
  34.         parent::postUp($schema);
  35.         foreach ($this->lines as $line) {
  36.             $lineId = UuidV6::fromBinary($line['id'])->toRfc4122();
  37.             $options = json_decode($line['options'], true);
  38.             if (!empty($options['product'])) {
  39.                 $productOptions = $options['product'];
  40.                 $decliId = !empty($productOptions['declination_id']) ?
  41.                     '0x' . str_replace('-', '', $productOptions['declination_id']) : null
  42.                 ;
  43.                 $productId = '0x' . str_replace('-', '', $productOptions['id']);
  45.                 $query = "UPDATE recurring_invoices_bundle__recurring_invoice_line SET product_id = " . $productId;
  46.                 if ($decliId) {
  47.                     $query .= ", declination_id = " . $decliId;
  48.                 }
  49.                 $query .= " WHERE id = UNHEX(CONCAT('', REPLACE('" . $lineId . "', '-', '')))";
  50.                 $this->connection->executeStatement($query);
  51.             }
  52.         }
  53.     }
  55.     public function down(Schema $schema): void
  56.     {
  57.         $this->addSql('ALTER TABLE recurring_invoices_bundle__recurring_invoice_line DROP FOREIGN KEY FK_BD96F0684584665A');
  58.         $this->addSql('ALTER TABLE recurring_invoices_bundle__recurring_invoice_line DROP FOREIGN KEY FK_BD96F0689941A932');
  59.         $this->addSql('DROP INDEX IDX_BD96F0684584665A ON recurring_invoices_bundle__recurring_invoice_line');
  60.         $this->addSql('DROP INDEX IDX_BD96F0689941A932 ON recurring_invoices_bundle__recurring_invoice_line');
  61.         $this->addSql('ALTER TABLE recurring_invoices_bundle__recurring_invoice_line DROP product_id, DROP declination_id');
  62.     }
  63. }