app/DoctrineMigrations/Version20230928014611.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace DoctrineMigrations;
  7. use Doctrine\DBAL\Schema\Schema;
  8. use Doctrine\Migrations\AbstractMigration;
  10. /**
  11. * Auto-generated Migration: Please modify to your needs!
  12. */
  13. final class Version20230928014611 extends AbstractMigration
  14. {
  15. public function getDescription(): string
  16. {
  17. return '';
  18. }
  20. public function up(Schema $schema): void
  21. {
  22. // 重複した在庫がdtb_product_stockにあるのか確認する。
  23. $exists = $this->connection->fetchAllKeyValue("
  24. SELECT product_class_id, product_class_id_count
  25. FROM (
  26. SELECT
  27. product_class_id,
  28. COUNT(product_class_id) AS product_class_id_count
  29. FROM
  30. dtb_product_stock
  31. GROUP BY
  32. product_class_id
  33. ) AS subquery
  34. WHERE product_class_id_count > 1;
  35. ");
  37. // 重複在庫がある場合、dtb_product_class.stockを正として、それ以外の在庫情報は削除する
  38. if (count($exists) != 0) {
  39. foreach ($exists as $pc_id => $value) {
  40. $stock = $this->connection->fetchOne("SELECT stock FROM dtb_product_class WHERE id = :id", ["id" => $pc_id]);
  41. $this->addSql("DELETE FROM dtb_product_stock WHERE product_class_id = :pc_id", ["pc_id" => $pc_id]);
  42. $this->addSql("INSERT INTO dtb_product_stock (product_class_id, creator_id, stock, create_date, update_date, discriminator_type) VALUES (:pc_id, NULL, :stock, CURRENT_TIMESTAMP, CURRENT_TIMESTAMP, 'productstock')", ["pc_id" => $pc_id, "stock" => $stock]);
  43. }
  44. }
  45. }
  47. public function down(Schema $schema): void
  48. {
  49. }
  50. }