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

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