src/Eccube/Controller/Install/InstallController.php line 116

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of EC-CUBE
  5.  *
  6.  * Copyright(c) EC-CUBE CO.,LTD. All Rights Reserved.
  7.  *
  8.  * http://www.ec-cube.co.jp/
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace Eccube\Controller\Install;
  16. use Doctrine\Common\Annotations\AnnotationReader;
  17. use Doctrine\DBAL\Connection;
  18. use Doctrine\DBAL\DriverManager;
  19. use Doctrine\DBAL\Types\Type;
  20. use Doctrine\DBAL\Types\Types;
  21. use Doctrine\ORM\EntityManager;
  22. use Doctrine\ORM\Tools\SchemaTool;
  23. use Doctrine\ORM\Tools\Setup;
  24. use Eccube\Common\Constant;
  25. use Eccube\Controller\AbstractController;
  26. use Eccube\Doctrine\DBAL\Types\UTCDateTimeType;
  27. use Eccube\Doctrine\DBAL\Types\UTCDateTimeTzType;
  28. use Eccube\Doctrine\ORM\Mapping\Driver\AnnotationDriver;
  29. use Eccube\Form\Type\Install\Step1Type;
  30. use Eccube\Form\Type\Install\Step3Type;
  31. use Eccube\Form\Type\Install\Step4Type;
  32. use Eccube\Form\Type\Install\Step5Type;
  33. use Eccube\Security\Core\Encoder\PasswordEncoder;
  34. use Eccube\Util\CacheUtil;
  35. use Eccube\Util\StringUtil;
  36. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
  37. use Symfony\Component\Filesystem\Filesystem;
  38. use Symfony\Component\Finder\Finder;
  39. use Symfony\Component\HttpFoundation\Request;
  40. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  41. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  42. use Symfony\Component\Routing\Annotation\Route;
  44. class InstallController extends AbstractController
  45. {
  46.     /**
  47.      * default value of auth magic
  48.      */
  49.     public const DEFAULT_AUTH_MAGIC = '<change.me>';
  51.     /** @var string */
  52.     public const TRANSACTION_CHECK_FILE = '/var/.httransaction';
  54.     protected $requiredModules = [
  55.         'pdo',
  56.         'phar',
  57.         'mbstring',
  58.         'zlib',
  59.         'ctype',
  60.         'session',
  61.         'JSON',
  62.         'xml',
  63.         'libxml',
  64.         'OpenSSL',
  65.         'zip',
  66.         'cURL',
  67.         'fileinfo',
  68.         'intl',
  69.     ];
  71.     protected $recommendedModules = [
  72.         'hash',
  73.     ];
  75.     protected $eccubeDirs = [
  76.         'app/Plugin',
  77.         'app/PluginData',
  78.         'app/proxy',
  79.         'app/template',
  80.         'html',
  81.         'var',
  82.         'vendor',
  83.     ];
  85.     protected $eccubeFiles = [
  86.         'composer.json',
  87.         'composer.lock',
  88.     ];
  90.     /**
  91.      * @var PasswordEncoder
  92.      */
  93.     protected $encoder;
  95.     /**
  96.      * @var CacheUtil
  97.      */
  98.     protected $cacheUtil;
  100.     public function __construct(PasswordEncoder $encoder, CacheUtil $cacheUtil)
  101.     {
  102.         $this->encoder = $encoder;
  103.         $this->cacheUtil = $cacheUtil;
  104.     }
  106.     /**
  107.      * 最初からやり直す場合、SESSION情報をクリア.
  108.      *
  109.      * @Route("/", name="homepage", methods={"GET"})
  110.      * @Route("/install", name="install", methods={"GET"})
  111.      *
  112.      * @Template("index.twig")
  113.      *
  114.      * @return \Symfony\Component\HttpFoundation\RedirectResponse
  115.      */
  116.     public function index()
  117.     {
  118.         if (!$this->isInstallEnv()) {
  119.             throw new NotFoundHttpException();
  120.         }
  122.         $this->removeSessionData($this->session);
  124.         return $this->redirectToRoute('install_step1');
  125.     }
  127.     /**
  128.      * ようこそ.
  129.      *
  130.      * @Route("/install/step1", name="install_step1", methods={"GET", "POST"})
  131.      * @Template("step1.twig")
  132.      *
  133.      * @return array|\Symfony\Component\HttpFoundation\RedirectResponse
  134.      */
  135.     public function step1(Request $request)
  136.     {
  137.         if (!$this->isInstallEnv()) {
  138.             throw new NotFoundHttpException();
  139.         }
  141.         $form = $this->formFactory
  142.             ->createBuilder(Step1Type::class)
  143.             ->getForm();
  145.         $form->setData($this->getSessionData($this->session));
  146.         $form->handleRequest($request);
  148.         if ($form->isSubmitted() && $form->isValid()) {
  149.             $this->setSessionData($this->session, $form->getData());
  151.             return $this->redirectToRoute('install_step2');
  152.         }
  154.         $this->checkModules();
  156.         $authmagic = $this->getParameter('eccube_auth_magic');
  157.         if ($authmagic === self::DEFAULT_AUTH_MAGIC) {
  158.             $authmagic = StringUtil::random(32);
  159.         }
  160.         $this->setSessionData($this->session, ['authmagic' => $authmagic]);
  162.         return [
  163.             'form' => $form->createView(),
  164.         ];
  165.     }
  167.     /**
  168.      * ディレクトリとファイルの書き込み権限をチェック.
  169.      *
  170.      * @Route("/install/step2", name="install_step2", methods={"GET"})
  171.      * @Template("step2.twig")
  172.      *
  173.      * @return array
  174.      */
  175.     public function step2()
  176.     {
  177.         if (!$this->isInstallEnv()) {
  178.             throw new NotFoundHttpException();
  179.         }
  181.         $noWritePermissions = [];
  183.         $projectDir = $this->getParameter('kernel.project_dir');
  185.         $eccubeDirs = array_map(function ($dir) use ($projectDir) {
  186.             return $projectDir.'/'.$dir;
  187.         }, $this->eccubeDirs);
  189.         $eccubeFiles = array_map(function ($file) use ($projectDir) {
  190.             return $projectDir.'/'.$file;
  191.         }, $this->eccubeFiles);
  193.         // ルートディレクトリの書き込み権限をチェック
  194.         if (!is_writable($projectDir)) {
  195.             $noWritePermissions[] = $projectDir;
  196.         }
  198.         // 対象ディレクトリの書き込み権限をチェック
  199.         foreach ($eccubeDirs as $dir) {
  200.             if (!is_writable($dir)) {
  201.                 $noWritePermissions[] = $dir;
  202.             }
  203.         }
  205.         // 対象ディレクトリ配下のディレクトリ・ファイルの書き込み権限をチェック
  206.         $finder = Finder::create()->in($eccubeDirs);
  207.         foreach ($finder as $file) {
  208.             if (!is_writable($file->getRealPath())) {
  209.                 $noWritePermissions[] = $file;
  210.             }
  211.         }
  213.         // composer.json, composer.lockの書き込み権限をチェック
  214.         foreach ($eccubeFiles as $file) {
  215.             if (!is_writable($file)) {
  216.                 $noWritePermissions[] = $file;
  217.             }
  218.         }
  220.         $faviconPath = '/assets/img/common/favicon.ico';
  221.         if (!file_exists($this->getParameter('eccube_html_dir').'/user_data'.$faviconPath)) {
  222.             $file = new Filesystem();
  223.             $file->copy(
  224.                 $this->getParameter('eccube_html_front_dir').$faviconPath,
  225.                 $this->getParameter('eccube_html_dir').'/user_data'.$faviconPath
  226.             );
  227.         }
  229.         $logoPath = '/assets/pdf/logo.png';
  230.         if (!file_exists($this->getParameter('eccube_html_dir').'/user_data'.$logoPath)) {
  231.             $file = new Filesystem();
  232.             $file->copy(
  233.                 $this->getParameter('eccube_html_admin_dir').$logoPath,
  234.                 $this->getParameter('eccube_html_dir').'/user_data'.$logoPath
  235.             );
  236.         }
  238.         return [
  239.             'noWritePermissions' => $noWritePermissions,
  240.         ];
  241.     }
  243.     /**
  244.      * サイトの設定.
  245.      *
  246.      * @Route("/install/step3", name="install_step3", methods={"GET", "POST"})
  247.      * @Template("step3.twig")
  248.      *
  249.      * @return array|\Symfony\Component\HttpFoundation\RedirectResponse
  250.      *
  251.      * @throws \Doctrine\DBAL\DBALException
  252.      * @throws \Exception
  253.      */
  254.     public function step3(Request $request)
  255.     {
  256.         if (!$this->isInstallEnv()) {
  257.             throw new NotFoundHttpException();
  258.         }
  260.         $sessionData = $this->getSessionData($this->session);
  262.         // 再インストールの場合は環境変数から復旧
  263.         if ($this->isInstalled()) {
  264.             // ショップ名/メールアドレス
  265.             $conn = $this->entityManager->getConnection();
  266.             $stmt = $conn->query('SELECT shop_name, email01 FROM dtb_base_info WHERE id = 1;');
  267.             $row = $stmt->fetch();
  268.             $sessionData['shop_name'] = $row['shop_name'];
  269.             $sessionData['email'] = $row['email01'];
  271.             $databaseUrl = $this->getParameter('eccube_database_url');
  272.             $sessionData = array_merge($sessionData, $this->extractDatabaseUrl($databaseUrl));
  274.             // 管理画面ルーティング
  275.             $sessionData['admin_dir'] = $this->getParameter('eccube_admin_route');
  277.             // 管理画面許可IP
  278.             $sessionData['admin_allow_hosts'] = implode($this->getParameter('eccube_admin_allow_hosts'));
  280.             // 強制SSL
  281.             $sessionData['admin_force_ssl'] = $this->getParameter('eccube_force_ssl');
  283.             // メール
  284.             $mailerUrl = $this->getParameter('eccube_mailer_dsn');
  285.             $sessionData = array_merge($sessionData, $this->extractMailerUrl($mailerUrl));
  286.         } else {
  287.             // 初期値設定
  288.             if (!isset($sessionData['admin_allow_hosts'])) {
  289.                 $sessionData['admin_allow_hosts'] = '';
  290.             }
  291.             if (!isset($sessionData['smtp_host'])) {
  292.                 $sessionData = array_merge($sessionData, $this->extractMailerUrl('smtp://localhost:25'));
  293.             }
  294.         }
  296.         $form = $this->formFactory
  297.             ->createBuilder(Step3Type::class)
  298.             ->getForm();
  300.         $form->setData($sessionData);
  301.         $form->handleRequest($request);
  303.         if ($form->isSubmitted() && $form->isValid()) {
  304.             $this->setSessionData($this->session, $form->getData());
  306.             return $this->redirectToRoute('install_step4');
  307.         }
  309.         return [
  310.             'form' => $form->createView(),
  311.             'request' => $request,
  312.         ];
  313.     }
  315.     /**
  316.      * データベースの設定.
  317.      *
  318.      * @Route("/install/step4", name="install_step4", methods={"GET", "POST"})
  319.      * @Template("step4.twig")
  320.      *
  321.      * @return array|\Symfony\Component\HttpFoundation\RedirectResponse
  322.      *
  323.      * @throws \Exception
  324.      */
  325.     public function step4(Request $request)
  326.     {
  327.         if (!$this->isInstallEnv()) {
  328.             throw new NotFoundHttpException();
  329.         }
  331.         $sessionData = $this->getSessionData($this->session);
  333.         if (empty($sessionData['database'])) {
  334.             // 再インストールの場合は環境変数から復旧.
  335.             if ($this->isInstalled()) {
  336.                 $databaseUrl = $this->getParameter('eccube_database_url');
  337.                 $sessionData = array_merge($sessionData, $this->extractDatabaseUrl($databaseUrl));
  338.             }
  339.         }
  341.         $form = $this->formFactory
  342.             ->createBuilder(Step4Type::class)
  343.             ->getForm();
  345.         $form->setData($sessionData);
  346.         $form->handleRequest($request);
  348.         if ($form->isSubmitted() && $form->isValid()) {
  349.             $data = $form->getData();
  350.             if ($data['database'] === 'pdo_sqlite') {
  351.                 $data['database_name'] = '/var/eccube.db';
  352.             }
  354.             $this->setSessionData($this->session, $data);
  356.             return $this->redirectToRoute('install_step5');
  357.         }
  359.         return [
  360.             'form' => $form->createView(),
  361.         ];
  362.     }
  364.     /**
  365.      * データベースの初期化.
  366.      *
  367.      * @Route("/install/step5", name="install_step5", methods={"GET", "POST"})
  368.      * @Template("step5.twig")
  369.      *
  370.      * @return array|\Symfony\Component\HttpFoundation\RedirectResponse
  371.      *
  372.      * @throws \Exception
  373.      */
  374.     public function step5(Request $request)
  375.     {
  376.         if (!$this->isInstallEnv()) {
  377.             throw new NotFoundHttpException();
  378.         }
  380.         $form = $this->formFactory
  381.             ->createBuilder(Step5Type::class)
  382.             ->getForm();
  384.         $sessionData = $this->getSessionData($this->session);
  385.         $form->setData($sessionData);
  386.         $form->handleRequest($request);
  388.         if ($form->isSubmitted() && $form->isValid()) {
  389.             $noUpdate = $form['no_update']->getData();
  391.             $url = $this->createDatabaseUrl($sessionData);
  393.             try {
  394.                 $conn = $this->createConnection(['url' => $url]);
  395.                 $em = $this->createEntityManager($conn);
  397.                 if ($noUpdate) {
  398.                     $this->update($conn, [
  399.                         'auth_magic' => $sessionData['authmagic'],
  400.                         'login_id' => $sessionData['login_id'],
  401.                         'login_pass' => $sessionData['login_pass'],
  402.                         'shop_name' => $sessionData['shop_name'],
  403.                         'email' => $sessionData['email'],
  404.                     ]);
  405.                 } else {
  406.                     $this->dropTables($em);
  407.                     $this->createTables($em);
  408.                     $this->importCsv($em);
  409.                     $this->insert($conn, [
  410.                         'auth_magic' => $sessionData['authmagic'],
  411.                         'login_id' => $sessionData['login_id'],
  412.                         'login_pass' => $sessionData['login_pass'],
  413.                         'shop_name' => $sessionData['shop_name'],
  414.                         'email' => $sessionData['email'],
  415.                     ]);
  416.                 }
  417.             } catch (\Exception $e) {
  418.                 log_error($e->getMessage());
  419.                 $this->addError($e->getMessage());
  421.                 return [
  422.                     'form' => $form->createView(),
  423.                 ];
  424.             }
  426.             if (isset($sessionData['agree']) && $sessionData['agree']) {
  427.                 $host = $request->getSchemeAndHttpHost();
  428.                 $basePath = $request->getBasePath();
  429.                 $params = [
  430.                     'http_url' => $host.$basePath,
  431.                     'shop_name' => $sessionData['shop_name'],
  432.                 ];
  433.                 $this->sendAppData($params, $em);
  434.             }
  435.             $version = $this->getDatabaseVersion($em);
  436.             $this->setSessionData($this->session, ['database_version' => $version]);
  438.             return $this->redirectToRoute('install_complete');
  439.         }
  441.         return [
  442.             'form' => $form->createView(),
  443.         ];
  444.     }
  446.     /**
  447.      * インストール完了
  448.      *
  449.      * @Route("/install/complete", name="install_complete", methods={"GET"})
  450.      * @Template("complete.twig")
  451.      */
  452.     public function complete(Request $request)
  453.     {
  454.         if (!$this->isInstallEnv()) {
  455.             throw new NotFoundHttpException();
  456.         }
  458.         $sessionData = $this->getSessionData($this->session);
  459.         $databaseUrl = $this->createDatabaseUrl($sessionData);
  460.         $mailerUrl = $this->createMailerUrl($sessionData);
  461.         $forceSSL = isset($sessionData['admin_force_ssl']) ? (bool) $sessionData['admin_force_ssl'] : false;
  462.         if ($forceSSL === false) {
  463.             $forceSSL = '0';
  464.         } elseif ($forceSSL === true) {
  465.             $forceSSL = '1';
  466.         }
  467.         $env = file_get_contents(__DIR__.'/../../../../.env.dist');
  468.         $replacement = [
  469.             'APP_ENV' => 'prod',
  470.             'APP_DEBUG' => '0',
  471.             'DATABASE_URL' => $databaseUrl,
  472.             'MAILER_DSN' => $mailerUrl,
  473.             'ECCUBE_AUTH_MAGIC' => $sessionData['authmagic'],
  474.             'DATABASE_SERVER_VERSION' => isset($sessionData['database_version']) ? $sessionData['database_version'] : '3',
  475.             'ECCUBE_ADMIN_ALLOW_HOSTS' => $this->convertAdminAllowHosts($sessionData['admin_allow_hosts']),
  476.             'ECCUBE_FORCE_SSL' => $forceSSL,
  477.             'ECCUBE_ADMIN_ROUTE' => isset($sessionData['admin_dir']) ? $sessionData['admin_dir'] : 'admin',
  478.             'ECCUBE_COOKIE_PATH' => $request->getBasePath() ? $request->getBasePath() : '/',
  479.             'ECCUBE_TEMPLATE_CODE' => 'default',
  480.             'ECCUBE_LOCALE' => 'ja',
  481.             'TRUSTED_HOSTS' => '^'.str_replace('.', '\\.', $request->getHost()).'$',
  482.             'DATABASE_CHARSET' => \str_starts_with($databaseUrl, 'mysql') ? 'utf8mb4' : 'utf8',
  483.         ];
  485.         $env = StringUtil::replaceOrAddEnv($env, $replacement);
  487.         if ($this->getParameter('kernel.environment') === 'install') {
  488.             file_put_contents(__DIR__.'/../../../../.env', $env);
  489.         }
  490.         $host = $request->getSchemeAndHttpHost();
  491.         $basePath = $request->getBasePath();
  492.         $adminUrl = $host.$basePath.'/'.$replacement['ECCUBE_ADMIN_ROUTE'];
  494.         $this->removeSessionData($this->session);
  496.         // 有効化URLのトランザクションチェックファイルを生成する
  497.         $token = StringUtil::random(32);
  498.         file_put_contents($this->getParameter('kernel.project_dir').self::TRANSACTION_CHECK_FILE, time() + (60 * 10).':'.$token);
  500.         $this->cacheUtil->clearCache('prod');
  502.         return [
  503.             'admin_url' => $adminUrl,
  504.             'is_sqlite' => strpos($databaseUrl, 'sqlite') !== false,
  505.             'token' => $token,
  506.         ];
  507.     }
  509.     protected function getSessionData(SessionInterface $session)
  510.     {
  511.         return $session->get('eccube.session.install', []);
  512.     }
  514.     protected function removeSessionData(SessionInterface $session)
  515.     {
  516.         $session->clear();
  517.     }
  519.     protected function setSessionData(SessionInterface $session, $data = [])
  520.     {
  521.         $data = array_replace_recursive($this->getSessionData($session), $data);
  522.         $session->set('eccube.session.install', $data);
  523.     }
  525.     protected function checkModules()
  526.     {
  527.         foreach ($this->requiredModules as $module) {
  528.             if (!extension_loaded($module)) {
  529.                 $this->addDanger(trans('install.required_extension_disabled', ['%module%' => $module]), 'install');
  530.             }
  531.         }
  532.         if (!extension_loaded('pdo_mysql') && !extension_loaded('pdo_pgsql')) {
  533.             $this->addDanger(trans('install.required_database_extension_disabled'), 'install');
  534.         }
  535.         foreach ($this->recommendedModules as $module) {
  536.             if (!extension_loaded($module)) {
  537.                 $this->addInfo(trans('install.recommend_extension_disabled', ['%module%' => $module]), 'install');
  538.             }
  539.         }
  540.         if ('\\' === DIRECTORY_SEPARATOR) { // for Windows
  541.             if (!extension_loaded('wincache')) {
  542.                 $this->addInfo(trans('install.recommend_extension_disabled', ['%module%' => 'wincache']), 'install');
  543.             }
  544.         } else {
  545.             if (!extension_loaded('apc')) {
  546.                 $this->addInfo(trans('install.recommend_extension_disabled', ['%module%' => 'apc']), 'install');
  547.             }
  548.         }
  549.         if (isset($_SERVER['SERVER_SOFTWARE']) && strpos($_SERVER['SERVER_SOFTWARE'], 'Apache') !== false) {
  550.             if (!function_exists('apache_get_modules')) {
  551.                 $this->addWarning(trans('install.mod_rewrite_unknown'), 'install');
  552.             } elseif (!in_array('mod_rewrite', apache_get_modules())) {
  553.                 $this->addDanger(trans('install.mod_rewrite_disabled'), 'install');
  554.             }
  555.         } elseif (isset($_SERVER['SERVER_SOFTWARE']) && strpos($_SERVER['SERVER_SOFTWARE'], 'Microsoft-IIS') !== false) {
  556.             // iis
  557.         } elseif (isset($_SERVER['SERVER_SOFTWARE']) && strpos($_SERVER['SERVER_SOFTWARE'], 'nginx') !== false) {
  558.             // nginx
  559.         }
  560.     }
  562.     protected function createConnection(array $params)
  563.     {
  564.         if (strpos($params['url'], 'mysql') !== false) {
  565.             $params['charset'] = 'utf8mb4';
  566.             $params['defaultTableOptions'] = [
  567.                 'charset' => 'utf8mb4',
  568.                 'collation' => 'utf8mb4_bin',
  569.             ];
  570.         }
  572.         Type::overrideType('datetime', UTCDateTimeType::class);
  573.         Type::overrideType('datetimetz', UTCDateTimeTzType::class);
  575.         $conn = DriverManager::getConnection($params);
  576.         $conn->executeQuery('select 1');
  578.         $platform = $conn->getDatabasePlatform();
  579.         $platform->markDoctrineTypeCommented('datetime');
  580.         $platform->markDoctrineTypeCommented('datetimetz');
  582.         return $conn;
  583.     }
  585.     protected function createEntityManager(Connection $conn)
  586.     {
  587.         $paths = [
  588.             $this->getParameter('kernel.project_dir').'/src/Eccube/Entity',
  589.             $this->getParameter('kernel.project_dir').'/app/Customize/Entity',
  590.         ];
  591.         $config = Setup::createConfiguration(true);
  592.         $driver = new AnnotationDriver(new AnnotationReader(), $paths);
  593.         $driver->setTraitProxiesDirectory($this->getParameter('kernel.project_dir').'/app/proxy/entity');
  594.         $config->setMetadataDriverImpl($driver);
  596.         $em = EntityManager::create($conn, $config);
  598.         return $em;
  599.     }
  601.     /**
  602.      * @return string
  603.      */
  604.     public function createDatabaseUrl(array $params)
  605.     {
  606.         if (!isset($params['database'])) {
  607.             return null;
  608.         }
  610.         $url = '';
  611.         switch ($params['database']) {
  612.             case 'pdo_sqlite':
  613.                 $url = 'sqlite://'.$params['database_name'];
  614.                 break;
  616.             case 'pdo_mysql':
  617.             case 'pdo_pgsql':
  618.                 $url = str_replace('pdo_', '', $params['database']);
  619.                 $url .= '://';
  620.                 if (isset($params['database_user'])) {
  621.                     $url .= $params['database_user'];
  622.                     if (isset($params['database_password'])) {
  623.                         $url .= ':'.\rawurlencode($params['database_password']);
  624.                     }
  625.                     $url .= '@';
  626.                 }
  627.                 if (isset($params['database_host'])) {
  628.                     $url .= $params['database_host'];
  629.                     if (isset($params['database_port'])) {
  630.                         $url .= ':'.$params['database_port'];
  631.                     }
  632.                     $url .= '/';
  633.                 }
  634.                 $url .= $params['database_name'];
  635.                 break;
  636.         }
  638.         return $url;
  639.     }
  641.     /**
  642.      * @param string $url
  643.      *
  644.      * @return array
  645.      */
  646.     public function extractDatabaseUrl($url)
  647.     {
  648.         if (preg_match('|^sqlite://(.*)$|', $url, $matches)) {
  649.             return [
  650.                 'database' => 'pdo_sqlite',
  651.                 'database_name' => $matches[1],
  652.             ];
  653.         }
  655.         $parsed = parse_url($url);
  657.         if ($parsed === false) {
  658.             throw new \Exception('Malformed parameter "url".');
  659.         }
  661.         return [
  662.             'database' => 'pdo_'.$parsed['scheme'],
  663.             'database_name' => ltrim($parsed['path'], '/'),
  664.             'database_host' => $parsed['host'],
  665.             'database_port' => isset($parsed['port']) ? $parsed['port'] : null,
  666.             'database_user' => isset($parsed['user']) ? $parsed['user'] : null,
  667.             'database_password' => isset($parsed['pass']) ? $parsed['pass'] : null,
  668.         ];
  669.     }
  671.     /**
  672.      * @return string
  673.      *
  674.      * @see https://github.com/symfony/swiftmailer-bundle/blob/9728097df87e76e2db71fc41fd7d211c06daea3e/DependencyInjection/SwiftmailerTransportFactory.php#L80-L142
  675.      */
  676.     public function createMailerUrl(array $params)
  677.     {
  678.         if (isset($params['transport'])) {
  679.             $url = $params['transport'].'://';
  680.         } else {
  681.             $url = 'smtp://';
  682.         }
  683.         if (isset($params['smtp_username'])) {
  684.             $url .= $params['smtp_username'];
  685.             if (isset($params['smtp_password'])) {
  686.                 $url .= ':'.$params['smtp_password'];
  687.             }
  688.             $url .= '@';
  689.         }
  691.         $queryStrings = [];
  692.         if (isset($params['encryption'])) {
  693.             $queryStrings['encryption'] = $params['encryption'];
  694.             if ($params['encryption'] === 'ssl' && !isset($params['smtp_port'])) {
  695.                 $params['smtp_port'] = 465;
  696.             }
  697.         }
  698.         if (isset($params['auth_mode'])) {
  699.             $queryStrings['auth_mode'] = $params['auth_mode'];
  700.         } else {
  701.             if (isset($params['smtp_username'])) {
  702.                 $queryStrings['auth_mode'] = 'plain';
  703.             }
  704.         }
  705.         ksort($queryStrings, SORT_STRING);
  707.         if (isset($params['smtp_host'])) {
  708.             $url .= $params['smtp_host'];
  709.             if (isset($params['smtp_port'])) {
  710.                 $url .= ':'.$params['smtp_port'];
  711.             }
  712.         }
  714.         if (isset($params['smtp_username']) || array_values($queryStrings)) {
  715.             $url .= '?';
  716.             $i = count($queryStrings);
  717.             foreach ($queryStrings as $key => $value) {
  718.                 $url .= $key.'='.$value;
  719.                 if ($i > 1) {
  720.                     $url .= '&';
  721.                 }
  722.                 $i--;
  723.             }
  724.         }
  726.         return $url;
  727.     }
  729.     /**
  730.      * @param string $url
  731.      *
  732.      * @return array
  733.      */
  734.     public function extractMailerUrl($url)
  735.     {
  736.         $options = [
  737.             'transport' => null,
  738.             'smtp_username' => null,
  739.             'smtp_password' => null,
  740.             'smtp_host' => null,
  741.             'smtp_port' => null,
  742.             'encryption' => null,
  743.             'auth_mode' => null,
  744.         ];
  746.         if ($url) {
  747.             $parts = parse_url($url);
  748.             if (isset($parts['scheme'])) {
  749.                 $options['transport'] = $parts['scheme'];
  750.             }
  751.             if (isset($parts['user'])) {
  752.                 $options['smtp_username'] = $parts['user'];
  753.             }
  754.             if (isset($parts['pass'])) {
  755.                 $options['smtp_password'] = $parts['pass'];
  756.             }
  757.             if (isset($parts['host'])) {
  758.                 $options['smtp_host'] = $parts['host'];
  759.             }
  760.             if (isset($parts['port'])) {
  761.                 $options['smtp_port'] = $parts['port'];
  762.             }
  763.             if (isset($parts['query'])) {
  764.                 parse_str($parts['query'], $query);
  765.                 foreach (array_keys($options) as $key) {
  766.                     if (isset($query[$key]) && $query[$key] != '') {
  767.                         $options[$key] = $query[$key];
  768.                     }
  769.                 }
  770.             }
  771.         }
  772.         if (!isset($options['transport'])) {
  773.             $options['transport'] = 'smtp';
  774.         } elseif ('gmail' === $options['transport']) {
  775.             $options['encryption'] = 'ssl';
  776.             $options['auth_mode'] = 'login';
  777.             $options['smtp_host'] = 'smtp.gmail.com';
  778.             $options['transport'] = 'smtp';
  779.         }
  780.         if (!isset($options['smtp_port'])) {
  781.             $options['smtp_port'] = 'ssl' === $options['encryption'] ? 465 : 25;
  782.         }
  783.         if (isset($options['smtp_username']) && !isset($options['auth_mode'])) {
  784.             $options['auth_mode'] = 'plain';
  785.         }
  786.         ksort($options, SORT_STRING);
  788.         return $options;
  789.     }
  791.     protected function dropTables(EntityManager $em)
  792.     {
  793.         $metadatas = $em->getMetadataFactory()->getAllMetadata();
  794.         $schemaTool = new SchemaTool($em);
  795.         $schemaTool->dropSchema($metadatas);
  796.         $em->getConnection()->executeQuery('DROP TABLE IF EXISTS doctrine_migration_versions');
  797.     }
  799.     protected function createTables(EntityManager $em)
  800.     {
  801.         $metadatas = $em->getMetadataFactory()->getAllMetadata();
  802.         $schemaTool = new SchemaTool($em);
  803.         $schemaTool->createSchema($metadatas);
  804.     }
  806.     protected function importCsv(EntityManager $em)
  807.     {
  808.         // for full locale code cases
  809.         $locale = env('ECCUBE_LOCALE', 'ja_JP');
  810.         $locale = str_replace('_', '-', $locale);
  811.         $locales = \Locale::parseLocale($locale);
  812.         $localeDir = is_null($locales) ? 'ja' : $locales['language'];
  814.         $loader = new \Eccube\Doctrine\Common\CsvDataFixtures\Loader();
  815.         $loader->loadFromDirectory($this->getParameter('kernel.project_dir').'/src/Eccube/Resource/doctrine/import_csv/'.$localeDir);
  816.         $executer = new \Eccube\Doctrine\Common\CsvDataFixtures\Executor\DbalExecutor($em);
  817.         $fixtures = $loader->getFixtures();
  818.         $executer->execute($fixtures);
  819.     }
  821.     protected function insert(Connection $conn, array $data)
  822.     {
  823.         $conn->beginTransaction();
  824.         try {
  825.             $salt = StringUtil::random(32);
  826.             $this->encoder->setAuthMagic($data['auth_magic']);
  827.             $password = $this->encoder->encodePassword($data['login_pass'], $salt);
  829.             $id = ('postgresql' === $conn->getDatabasePlatform()->getName())
  830.                 ? $conn->fetchOne("select nextval('dtb_base_info_id_seq')")
  831.                 : null;
  833.             $conn->insert('dtb_base_info', [
  834.                 'id' => $id,
  835.                 'shop_name' => $data['shop_name'],
  836.                 'email01' => $data['email'],
  837.                 'email02' => $data['email'],
  838.                 'email03' => $data['email'],
  839.                 'email04' => $data['email'],
  840.                 'update_date' => new \DateTime(),
  841.                 'discriminator_type' => 'baseinfo',
  842.             ], [
  843.                 'update_date' => Types::DATETIMETZ_MUTABLE,
  844.             ]);
  846.             $member_id = ('postgresql' === $conn->getDatabasePlatform()->getName())
  847.                 ? $conn->fetchOne("select nextval('dtb_member_id_seq')")
  848.                 : null;
  850.             $conn->insert('dtb_member', [
  851.                 'id' => $member_id,
  852.                 'login_id' => $data['login_id'],
  853.                 'password' => $password,
  854.                 'salt' => $salt,
  855.                 'work_id' => 1,
  856.                 'authority_id' => 0,
  857.                 'creator_id' => 1,
  858.                 'sort_no' => 1,
  859.                 'update_date' => new \DateTime(),
  860.                 'create_date' => new \DateTime(),
  861.                 'name' => trans('install.member_name'),
  862.                 'department' => $data['shop_name'],
  863.                 'discriminator_type' => 'member',
  864.             ], [
  865.                 'update_date' => Types::DATETIMETZ_MUTABLE,
  866.                 'create_date' => Types::DATETIMETZ_MUTABLE,
  867.             ]);
  868.             $conn->commit();
  869.         } catch (\Exception $e) {
  870.             $conn->rollback();
  871.             throw $e;
  872.         }
  873.     }
  875.     protected function update(Connection $conn, array $data)
  876.     {
  877.         $conn->beginTransaction();
  878.         try {
  879.             $salt = StringUtil::random(32);
  880.             $stmt = $conn->prepare('SELECT id FROM dtb_member WHERE login_id = :login_id;');
  881.             $stmt->bindParam(':login_id', $data['login_id']);
  882.             $row = $stmt->executeQuery();
  883.             $this->encoder->setAuthMagic($data['auth_magic']);
  884.             $password = $this->encoder->encodePassword($data['login_pass'], $salt);
  885.             if ($row) {
  886.                 // 同一の管理者IDであればパスワードのみ更新
  887.                 $sth = $conn->prepare('UPDATE dtb_member set password = :password, salt = :salt, update_date = current_timestamp WHERE login_id = :login_id;');
  888.                 $sth->execute([
  889.                     ':password' => $password,
  890.                     ':salt' => $salt,
  891.                     ':login_id' => $data['login_id'],
  892.                 ]);
  893.             } else {
  894.                 // 新しい管理者IDが入力されたらinsert
  895.                 $sth = $conn->prepare("INSERT INTO dtb_member (login_id, password, salt, work_id, authority_id, creator_id, sort_no, update_date, create_date,name,department,discriminator_type) VALUES (:login_id, :password , :salt , '1', '0', '1', '1', current_timestamp, current_timestamp,'管理者','EC-CUBE SHOP', 'member');");
  896.                 $sth->execute([
  897.                     ':login_id' => $data['login_id'],
  898.                     ':password' => $password,
  899.                     ':salt' => $salt,
  900.                 ]);
  901.             }
  902.             $stmt = $conn->prepare('UPDATE dtb_base_info set
  903.                 shop_name = :shop_name,
  904.                 email01 = :admin_mail,
  905.                 email02 = :admin_mail,
  906.                 email03 = :admin_mail,
  907.                 email04 = :admin_mail,
  908.                 update_date = current_timestamp
  909.             WHERE id = 1;');
  910.             $stmt->execute([
  911.                 ':shop_name' => $data['shop_name'],
  912.                 ':admin_mail' => $data['email'],
  913.             ]);
  914.             $conn->commit();
  915.         } catch (\Exception $e) {
  916.             $conn->rollback();
  917.             throw $e;
  918.         }
  919.     }
  921.     /**
  922.      * @param array $params
  923.      *
  924.      * @return array
  925.      */
  926.     public function createAppData($params, EntityManager $em)
  927.     {
  928.         $platform = $em->getConnection()->getDatabasePlatform()->getName();
  929.         $version = $this->getDatabaseVersion($em);
  930.         $data = [
  931.             'site_url' => $params['http_url'],
  932.             'shop_name' => $params['shop_name'],
  933.             'cube_ver' => Constant::VERSION,
  934.             'php_ver' => phpversion(),
  935.             'db_ver' => $platform.' '.$version,
  936.             'os_type' => php_uname(),
  937.         ];
  939.         return $data;
  940.     }
  942.     /**
  943.      * @param array $params
  944.      */
  945.     protected function sendAppData($params, EntityManager $em)
  946.     {
  947.         try {
  948.             $query = http_build_query($this->createAppData($params, $em));
  949.             $header = [
  950.                 'Content-Type: application/x-www-form-urlencoded',
  951.                 'Content-Length: '.strlen($query),
  952.             ];
  953.             $context = stream_context_create(
  954.                 [
  955.                     'http' => [
  956.                         'method' => 'POST',
  957.                         'header' => $header,
  958.                         'content' => $query,
  959.                     ],
  960.                 ]
  961.             );
  962.             file_get_contents('https://www.ec-cube.net/mall/use_site.php', false, $context);
  963.         } catch (\Exception $e) {
  964.             // 送信に失敗してもインストールは継続できるようにする
  965.             log_error($e->getMessage());
  966.         }
  968.         return $this;
  969.     }
  971.     /**
  972.      * @return string
  973.      */
  974.     public function getDatabaseVersion(EntityManager $em)
  975.     {
  976.         $rsm = new \Doctrine\ORM\Query\ResultSetMapping();
  977.         $rsm->addScalarResult('server_version', 'server_version');
  979.         $platform = $em->getConnection()->getDatabasePlatform()->getName();
  980.         switch ($platform) {
  981.             case 'sqlite':
  982.                 $sql = 'SELECT sqlite_version() AS server_version';
  983.                 break;
  985.             case 'mysql':
  986.                 $sql = 'SELECT version() AS server_version';
  987.                 break;
  989.             case 'postgresql':
  990.             default:
  991.                 $sql = 'SHOW server_version';
  992.         }
  994.         $version = $em->createNativeQuery($sql, $rsm)
  995.             ->getSingleScalarResult();
  997.         // postgresqlのバージョンが10.x以降の場合に、getSingleScalarResult()で取得される不要な文字列を除く処理
  998.         if ($platform === 'postgresql') {
  999.             preg_match('/\A([\d+\.]+)/', $version, $matches);
  1000.             $version = $matches[1];
  1001.         }
  1003.         return $version;
  1004.     }
  1006.     /**
  1007.      * @param string
  1008.      *
  1009.      * @return string
  1010.      */
  1011.     public function convertAdminAllowHosts($adminAllowHosts)
  1012.     {
  1013.         if (empty($adminAllowHosts)) {
  1014.             return '[]';
  1015.         }
  1017.         $adminAllowHosts = \json_encode(
  1018.             \explode("\n", StringUtil::convertLineFeed($adminAllowHosts))
  1019.         );
  1021.         return "'$adminAllowHosts'";
  1022.     }
  1024.     /**
  1025.      * @return bool
  1026.      */
  1027.     protected function isInstalled()
  1028.     {
  1029.         return self::DEFAULT_AUTH_MAGIC !== $this->getParameter('eccube_auth_magic');
  1030.     }
  1032.     /**
  1033.      * @return bool
  1034.      */
  1035.     protected function isInstallEnv()
  1036.     {
  1037.         $env = $this->getParameter('kernel.environment');
  1039.         if ($env === 'install' || $env === 'test') {
  1040.             return true;
  1041.         }
  1043.         return false;
  1044.     }
  1045. }