app/DoctrineMigrations/Version20210412073123.php line 45

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * This file is part of EC-CUBE
  7.  *
  8.  * Copyright(c) EC-CUBE CO.,LTD. All Rights Reserved.
  9.  *
  10.  * http://www.ec-cube.co.jp/
  11.  *
  12.  * For the full copyright and license information, please view the LICENSE
  13.  * file that was distributed with this source code.
  14.  */
  16. namespace DoctrineMigrations;
  18. use Doctrine\DBAL\Schema\Schema;
  19. use Doctrine\Migrations\AbstractMigration;
  20. use Eccube\Entity\Master\LoginHistoryStatus;
  21. use Eccube\Util\StringUtil;
  23. /**
  24.  * Auto-generated Migration: Please modify to your needs!
  25.  */
  26. final class Version20210412073123 extends AbstractMigration
  27. {
  28.     public function up(Schema $schema): void
  29.     {
  30.         if ($schema->hasTable('plg_admin_record_config')) {
  31.             $denyHostsPlugin = $this->connection->fetchOne('select admin_deny_hosts FROM plg_admin_record_config') ?: '';
  32.             $denyHostsPlugin = array_filter(\explode("\n", StringUtil::convertLineFeed($denyHostsPlugin)), function ($str) {
  33.                 return StringUtil::isNotBlank($str);
  34.             });
  36.             $denyHosts = array_merge(env('ECCUBE_ADMIN_DENY_HOSTS', []), $denyHostsPlugin);
  37.             $denyHosts = array_values(array_unique($denyHosts));
  39.             $denyHosts = \json_encode($denyHosts);
  41.             $envFile = __DIR__.'/../../.env';
  42.             $env = file_get_contents($envFile);
  44.             $env = StringUtil::replaceOrAddEnv($env, [
  45.                 'ECCUBE_ADMIN_DENY_HOSTS' => "'${denyHosts}'",
  46.             ]);
  48.             file_put_contents($envFile, $env);
  49.         }
  51.         if ($schema->hasTable('plg_admin_record')) {
  52.             $stmt = $this->connection->createQueryBuilder()
  53.                 ->select('*')
  54.                 ->from('plg_admin_record')
  55.                 ->orderBy('id', 'ASC')
  56.                 ->execute();
  58.             while ($row = $stmt->fetch()) {
  59.                 $this->addSql(
  60.                     "INSERT INTO dtb_login_history (user_name, client_ip, create_date, update_date, login_history_status_id, member_id, discriminator_type) VALUES (?, ?, ?, ?, ?, ?, 'loginhistory')",
  61.                     [
  62.                         $row['user_name'],
  63.                         $row['client_ip'],
  64.                         $row['create_date'],
  65.                         $row['update_date'],
  66.                         $row['success_flg'] ? LoginHistoryStatus::SUCCESS : LoginHistoryStatus::FAILURE,
  67.                         $row['member_id'],
  68.                     ]
  69.                 );
  70.             }
  71.         }
  72.     }
  74.     public function down(Schema $schema): void
  75.     {
  76.         if ($schema->hasTable('dtb_login_history')) {
  77.             $this->addSql('DELETE FROM dtb_login_history');
  78.         }
  79.     }
  80. }