vendor/bluue/products-bundle/migrations/Version20221227131457.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace ProductsBundleMigrations;
  7. use Doctrine\DBAL\Schema\Schema;
  8. use Symfony\Component\Uid\UuidV6;
  9. use Doctrine\Migrations\AbstractMigration;
  11. final class Version20221227131457 extends AbstractMigration
  12. {
  13.     public function up(Schema $schema): void
  14.     {
  15.         $this->addSql('SET FOREIGN_KEY_CHECKS=0');
  16.         $this->addSql('ALTER TABLE products_bundle__declination_context ADD reference VARCHAR(128) DEFAULT NULL, ADD wholesale_price NUMERIC(20, 6) DEFAULT NULL, ADD sell_price NUMERIC(20, 6) DEFAULT NULL, ADD is_active TINYINT(1) DEFAULT 1 NOT NULL');
  17.         $this->addSql('CREATE INDEX reference ON products_bundle__declination_context (reference)');
  18.         $this->addSql('CREATE INDEX wholesale_price ON products_bundle__declination_context (wholesale_price)');
  19.         $this->addSql('CREATE INDEX sell_price ON products_bundle__declination_context (sell_price)');
  20.         $this->addSql('CREATE INDEX is_active ON products_bundle__declination_context (is_active)');
  22.         $this->addSql('ALTER TABLE products_bundle__product_context ADD eco_part_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\', ADD tax_rule_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\', ADD currency_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\', ADD name VARCHAR(255) DEFAULT \'\' NOT NULL, ADD description LONGTEXT DEFAULT NULL, ADD summary LONGTEXT DEFAULT NULL, ADD reference VARCHAR(255) DEFAULT NULL, ADD eco_part_amount NUMERIC(20, 6) DEFAULT NULL, ADD changeable_tax_rule TINYINT(1) DEFAULT 0 NOT NULL, ADD wholesale_price NUMERIC(20, 6) DEFAULT NULL, ADD sell_price NUMERIC(20, 6) DEFAULT NULL, ADD is_active TINYINT(1) DEFAULT 1 NOT NULL, ADD source VARCHAR(255) DEFAULT NULL');
  23.         $this->addSql('ALTER TABLE products_bundle__product_context ADD CONSTRAINT FK_F37E0B8CAE870F68 FOREIGN KEY (eco_part_id) REFERENCES products_bundle__eco_part (id)');
  24.         $this->addSql('ALTER TABLE products_bundle__product_context ADD CONSTRAINT FK_F37E0B8C3506A35B FOREIGN KEY (tax_rule_id) REFERENCES tax_rule (id)');
  25.         $this->addSql('ALTER TABLE products_bundle__product_context ADD CONSTRAINT FK_F37E0B8C38248176 FOREIGN KEY (currency_id) REFERENCES currency (id)');
  26.         $this->addSql('CREATE INDEX IDX_F37E0B8CAE870F68 ON products_bundle__product_context (eco_part_id)');
  27.         $this->addSql('CREATE INDEX IDX_F37E0B8C3506A35B ON products_bundle__product_context (tax_rule_id)');
  28.         $this->addSql('CREATE INDEX IDX_F37E0B8C38248176 ON products_bundle__product_context (currency_id)');
  29.         $this->addSql('CREATE INDEX reference ON products_bundle__product_context (reference)');
  30.         $this->addSql('CREATE INDEX name ON products_bundle__product_context (name)');
  31.         $this->addSql('CREATE INDEX wholesale_price ON products_bundle__product_context (wholesale_price)');
  32.         $this->addSql('CREATE INDEX sell_price ON products_bundle__product_context (sell_price)');
  33.         $this->addSql('CREATE INDEX is_active ON products_bundle__product_context (is_active)');
  34.         $this->addSql('ALTER TABLE products_bundle__declination_context ADD created_by_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\', ADD updated_by_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\', ADD deleted_by_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\', ADD created_at DATETIME DEFAULT NULL, ADD updated_at DATETIME DEFAULT NULL, ADD deleted_at DATETIME DEFAULT NULL');
  35.         $this->addSql('ALTER TABLE products_bundle__declination_context ADD CONSTRAINT FK_B1F3A380B03A8386 FOREIGN KEY (created_by_id) REFERENCES user (id)');
  36.         $this->addSql('ALTER TABLE products_bundle__declination_context ADD CONSTRAINT FK_B1F3A380896DBBDE FOREIGN KEY (updated_by_id) REFERENCES user (id)');
  37.         $this->addSql('ALTER TABLE products_bundle__declination_context ADD CONSTRAINT FK_B1F3A380C76F1F52 FOREIGN KEY (deleted_by_id) REFERENCES user (id)');
  38.         $this->addSql('CREATE INDEX IDX_B1F3A380B03A8386 ON products_bundle__declination_context (created_by_id)');
  39.         $this->addSql('CREATE INDEX IDX_B1F3A380896DBBDE ON products_bundle__declination_context (updated_by_id)');
  40.         $this->addSql('CREATE INDEX IDX_B1F3A380C76F1F52 ON products_bundle__declination_context (deleted_by_id)');
  41.         $this->addSql('ALTER TABLE products_bundle__product_context ADD created_by_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\', ADD updated_by_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\', ADD deleted_by_id BINARY(16) DEFAULT NULL COMMENT \'(DC2Type:uuid)\', ADD created_at DATETIME DEFAULT NULL, ADD updated_at DATETIME DEFAULT NULL, ADD deleted_at DATETIME DEFAULT NULL');
  42.         $this->addSql('ALTER TABLE products_bundle__product_context ADD CONSTRAINT FK_F37E0B8CB03A8386 FOREIGN KEY (created_by_id) REFERENCES user (id)');
  43.         $this->addSql('ALTER TABLE products_bundle__product_context ADD CONSTRAINT FK_F37E0B8C896DBBDE FOREIGN KEY (updated_by_id) REFERENCES user (id)');
  44.         $this->addSql('ALTER TABLE products_bundle__product_context ADD CONSTRAINT FK_F37E0B8CC76F1F52 FOREIGN KEY (deleted_by_id) REFERENCES user (id)');
  45.         $this->addSql('CREATE INDEX IDX_F37E0B8CB03A8386 ON products_bundle__product_context (created_by_id)');
  46.         $this->addSql('CREATE INDEX IDX_F37E0B8C896DBBDE ON products_bundle__product_context (updated_by_id)');
  47.         $this->addSql('CREATE INDEX IDX_F37E0B8CC76F1F52 ON products_bundle__product_context (deleted_by_id)');
  48.         $this->addSql('UPDATE products_bundle__declination_context SET created_at = CURRENT_TIMESTAMP WHERE created_at IS NULL');
  49.         $this->addSql('UPDATE products_bundle__declination_context SET updated_at = CURRENT_TIMESTAMP WHERE updated_at IS NULL');
  50.         $this->addSql('UPDATE products_bundle__product_context SET created_at = CURRENT_TIMESTAMP WHERE created_at IS NULL');
  51.         $this->addSql('UPDATE products_bundle__product_context SET updated_at = CURRENT_TIMESTAMP WHERE updated_at IS NULL');
  52.         $this->addSql('ALTER TABLE products_bundle__declination_context CHANGE created_at created_at DATETIME NOT NULL, CHANGE updated_at updated_at DATETIME NOT NULL');
  53.         $this->addSql('ALTER TABLE products_bundle__product_context CHANGE created_at created_at DATETIME NOT NULL, CHANGE updated_at updated_at DATETIME NOT NULL');
  55.         $this->addSql('ALTER TABLE products_bundle__product_translations DROP FOREIGN KEY FK_9017C31B232D562B');
  56.         $this->addSql('ALTER TABLE products_bundle__product_translations ADD CONSTRAINT FK_9017C31B232D562B FOREIGN KEY (object_id) REFERENCES products_bundle__product_context (id) ON DELETE CASCADE');
  57.         $this->addSql('SET FOREIGN_KEY_CHECKS=1');
  58.     }
  60.     public function postUp(Schema $schema): void
  61.     {
  62.         parent::postUp($schema);
  63.         $conn = $this->connection;
  64.         $contexts = $conn->executeQuery("SELECT id FROM context")->fetchAllAssociative();
  65.         echo "debut declinations \n";
  66.         $declinations = $conn->executeQuery('SELECT id, reference, wholesale_price, sell_price, is_active FROM products_bundle__declination WHERE deleted_at IS NULL')->fetchAllAssociative();
  67.         foreach ($declinations as $decli) {
  68.             $keys = 'created_at, updated_at, ';
  69.             $values = '\'2023-01-01 00:00:00\', \'2023-01-01 00:00:00\', ';
  70.             foreach ($decli as $key => $el) {
  71.                 $keys .= ($key == 'id' ? 'declination_id' : $key) . ', ';
  72.                 if ($key == 'id') {
  73.                     $value = UuidV6::fromBinary($el)->toRfc4122();
  74.                     $value = '0x' . str_replace('-', '', $value);
  75.                 } elseif (!$el) {
  76.                     $value = 'NULL';
  77.                 } else {
  78.                     $value = "'" . $el . "'";
  79.                 }
  80.                 $values .= $value . ', ';
  81.             }
  83.             foreach ($contexts as $c) {
  84.                 $id = (new UuidV6())->toRfc4122();
  85.                 $cId = UuidV6::fromBinary($c['id'])->toRfc4122();
  86.                 $query = 'INSERT INTO products_bundle__declination_context (' . $keys . 'context_id, id) VALUES (' . $values . '0x' . str_replace('-', '', $cId) . ', 0x' . str_replace('-', '', $id) . ')';
  87.                 $conn->executeStatement($query);
  88.             }
  89.         }
  90.         echo "fin declinations \n";
  92.         // partie products
  93.         echo "debut products \n";
  94.         $products = $conn->executeQuery('SELECT id, name, summary, description, source, reference, eco_part_id, eco_part_amount, tax_rule_id, changeable_tax_rule, currency_id, wholesale_price, sell_price, is_active FROM products_bundle__product WHERE deleted_at IS NULL')->fetchAllAssociative();
  95.         foreach ($products as $p) {
  96.             $p_uuid = UuidV6::fromBinary($p['id'])->toRfc4122();
  97.             $keys = 'created_at, updated_at, ';
  98.             $values = '\'2023-01-01 00:00:00\', \'2023-01-01 00:00:00\', ';
  99.             foreach ($p as $key => $el) {
  100.                 $keys .= ($key == 'id' ? 'product_id' : $key) . ', ';
  101.                 if ($key == 'id') {
  102.                     $value = UuidV6::fromBinary($el)->toRfc4122();
  103.                     $value = '0x' . str_replace('-', '', $value);
  104.                 } elseif (!$el) {
  105.                     $value = 'NULL';
  106.                 } elseif (str_contains($key, '_id')) {
  107.                     $value = UuidV6::fromBinary($el)->toRfc4122();
  108.                     $value = '0x' . str_replace('-', '', $value);
  109.                 } else {
  110.                     $el = addslashes($el);
  111.                     $value = "'" . $el . "'";
  112.                 }
  113.                 $values .= $value . ', ';
  114.             }
  116.             foreach ($contexts as $c) {
  117.                 $id = (new UuidV6())->toRfc4122();
  118.                 $cId = UuidV6::fromBinary($c['id'])->toRfc4122();
  119.                 $query = 'INSERT INTO products_bundle__product_context (' . $keys . 'context_id, id) VALUES (' . $values . '0x' . str_replace('-', '', $cId) . ', 0x' . str_replace('-', '', $id) . ')';
  120.                 $conn->executeStatement($query);
  121.             }
  123.             // traitement traductions
  124.             $productTranslations = $conn->executeQuery("SELECT id, object_id, locale, field FROM products_bundle__product_translations WHERE object_id = UNHEX(CONCAT('', REPLACE('" . $p_uuid . "', '-', '')))")->fetchAllAssociative();
  125.             $products_contexts = $conn->executeQuery("SELECT id, name, summary, description, source FROM products_bundle__product_context WHERE product_id = UNHEX(CONCAT('', REPLACE('" . $p_uuid . "', '-', '')))")->fetchAllAssociative();
  126.             $first = true;
  127.             foreach ($products_contexts as $pc) {
  128.                 $pc_uuid = UuidV6::fromBinary($pc['id'])->toRfc4122();
  129.                 $pc_uuid = '0x' . str_replace('-', '', $pc_uuid);
  130.                 $name_fr = false;
  131.                 $summary_fr = false;
  132.                 $description_fr = false;
  133.                 $source_fr = false;
  134.                 if ($first) {
  135.                     foreach ($productTranslations as $pt) {
  136.                         if ($pt['locale'] == 'fr') {
  137.                             if ($pt['field'] == 'name') {
  138.                                 $name_fr = true;
  139.                             } elseif ($pt['field'] == 'summary') {
  140.                                 $summary_fr = true;
  141.                             } elseif ($pt['field'] == 'description') {
  142.                                 $description_fr = true;
  143.                             } elseif ($pt['field'] == 'source') {
  144.                                 $source_fr = true;
  145.                             }
  146.                         }
  147.                         $pt_id = $pt['id'];
  148.                         $conn->executeStatement("UPDATE products_bundle__product_translations SET object_id = " . $pc_uuid . " WHERE id = " . $pt_id);
  149.                     }
  150.                     $first = false;
  151.                 }
  152.                 if (!$name_fr) {
  153.                     $value = $pc['name'];
  154.                     if (!$value) {
  155.                         $value = 'NULL';
  156.                     } else {
  157.                         $value = addslashes($value);
  158.                         $value = "'" . $value . "'";
  159.                     }
  160.                     $conn->executeStatement("INSERT INTO products_bundle__product_translations (id, object_id, locale, field, content) VALUES (NULL, " . $pc_uuid . ", 'fr', 'name', " . $value . ")");
  161.                 }
  162.                 if (!$summary_fr) {
  163.                     $value = $pc['summary'];
  164.                     if (!$value) {
  165.                         $value = 'NULL';
  166.                     } else {
  167.                         $value = addslashes($value);
  168.                         $value = "'" . $value . "'";
  169.                     }
  170.                     $conn->executeStatement("INSERT INTO products_bundle__product_translations (id, object_id, locale, field, content) VALUES (NULL, " . $pc_uuid . ", 'fr', 'summary', " . $value . ")");
  171.                 }
  172.                 if (!$description_fr) {
  173.                     $value = $pc['description'];
  174.                     if (!$value) {
  175.                         $value = 'NULL';
  176.                     } else {
  177.                         $value = addslashes($value);
  178.                         $value = "'" . $value . "'";
  179.                     }
  180.                     $conn->executeStatement("INSERT INTO products_bundle__product_translations (id, object_id, locale, field, content) VALUES (NULL, " . $pc_uuid . ", 'fr', 'description', " . $value . ")");
  181.                 }
  182.                 if (!$source_fr) {
  183.                     $value = $pc['source'];
  184.                     if (!$value) {
  185.                         $value = 'NULL';
  186.                     } else {
  187.                         $value = addslashes($value);
  188.                         $value = "'" . $value . "'";
  189.                     }
  190.                     $conn->executeStatement("INSERT INTO products_bundle__product_translations (id, object_id, locale, field, content) VALUES (NULL, " . $pc_uuid . ", 'fr', 'source', " . $value . ")");
  191.                 }
  192.             }
  193.         }
  194.         echo "fin products \n";
  195.     }
  197.     public function down(Schema $schema): void
  198.     {
  199.     }
  200. }