migrations/Version20250109222633.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 Version20250109222633 extends AbstractMigration
  14. {
  15.     public function getDescription(): string
  16.     {
  17.         return '';
  18.     }
  20.     public function up(Schema $schema): void
  21.     {
  22.         // this up() migration is auto-generated, please modify it to your needs
  23.         $this->addSql('CREATE TABLE user_join_level (user_id INT NOT NULL, level_id INT NOT NULL, INDEX IDX_B4CF7952A76ED395 (user_id), INDEX IDX_B4CF79525FB14BA7 (level_id), PRIMARY KEY(user_id, level_id)) DEFAULT CHARACTER SET utf8mb4 COLLATE `utf8mb4_unicode_ci` ENGINE = InnoDB');
  24.         $this->addSql('ALTER TABLE user_join_level ADD CONSTRAINT FK_B4CF7952A76ED395 FOREIGN KEY (user_id) REFERENCES user (id) ON DELETE CASCADE');
  25.         $this->addSql('ALTER TABLE user_join_level ADD CONSTRAINT FK_B4CF79525FB14BA7 FOREIGN KEY (level_id) REFERENCES config_level (id) ON DELETE CASCADE');
  27.         $users = $this->connection->fetchAllAssociative('SELECT id, levels FROM user WHERE levels IS NOT NULL');
  29.         foreach ($users as $user) {
  30.             $userId = $user['id'];
  31.             $levelsArray = unserialize($user['levels']);
  33.             if (!\is_array($levelsArray)) {
  34.                 continue;
  35.             }
  37.             foreach ($levelsArray as $levelName) {
  38.                 switch ($levelName) {
  39.                     case 'red': $levelName = 'ruby'; break;
  40.                     case 'copper': $levelName = 'sapphire'; break;
  41.                     case 'bronze': $levelName = 'emerald'; break;
  42.                 }
  44.                 $levelId = $this->connection->fetchOne('SELECT id FROM config_level WHERE name = ?', [$levelName]);
  46.                 if ($levelId) {
  47.                     $this->addSql('INSERT INTO user_join_level (user_id, level_id) VALUES (?, ?)', [$userId, $levelId]);
  48.                 }
  49.             }
  50.         }
  52.         $this->addSql('ALTER TABLE user DROP levels');
  53.     }
  55.     public function down(Schema $schema): void
  56.     {
  57.         // this down() migration is auto-generated, please modify it to your needs
  58.         $this->addSql('ALTER TABLE user ADD levels LONGTEXT DEFAULT NULL COLLATE `utf8mb4_general_ci` COMMENT \'(DC2Type:array)\'');
  60.         $userLevels = $this->connection->fetchAllAssociative('SELECT user_id, level_id FROM user_join_level');
  62.         $reverseMapping = [
  63.             'ruby' => 'red',
  64.             'sapphire' => 'copper',
  65.             'emerald' => 'bronze',
  66.         ];
  68.         $userLevelsMap = [];
  70.         foreach ($userLevels as $userLevel) {
  71.             $userId = $userLevel['user_id'];
  72.             $levelName = $this->connection->fetchOne('SELECT name FROM config_level WHERE id = ?', [$userLevel['level_id']]);
  74.             if ($levelName) {
  75.                 $levelName = strtolower($levelName);
  76.                 $levelName = $reverseMapping[$levelName] ?? $levelName;
  78.                 if (!isset($userLevelsMap[$userId])) {
  79.                     $userLevelsMap[$userId] = [];
  80.                 }
  81.                 $userLevelsMap[$userId][] = $levelName;
  82.             }
  83.         }
  85.         foreach ($userLevelsMap as $userId => $levels) {
  86.             $serializedLevels = serialize($levels);
  87.             $this->addSql('UPDATE user SET levels = ? WHERE id = ?', [$serializedLevels, $userId]);
  88.         }
  90.         $this->addSql('DROP TABLE user_join_level');
  91.     }
  92. }