src/Eccube/Controller/Admin/AbstractCsvImportController.php line 51

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\Admin;
  16. use Eccube\Controller\AbstractController;
  17. use Eccube\Service\CsvImportService;
  18. use Eccube\Util\StringUtil;
  19. use Symfony\Component\Filesystem\Filesystem;
  20. use Symfony\Component\HttpFoundation\File\UploadedFile;
  21. use Symfony\Component\HttpFoundation\Request;
  22. use Symfony\Component\HttpFoundation\StreamedResponse;
  24. class AbstractCsvImportController extends AbstractController
  25. {
  26.     /**
  27.      * アップロードされたCSVファイル名
  28.      *
  29.      * @var string
  30.      */
  31.     protected $csvFileName;
  33.     /**
  34.      * アップロードされたCSVファイルの行ごとの処理
  35.      *
  36.      * @param UploadedFile $formFile
  37.      *
  38.      * @return CsvImportService|bool
  39.      */
  40.     protected function getImportData(UploadedFile $formFile)
  41.     {
  42.         // アップロードされたCSVファイルを一時ディレクトリに保存
  43.         $this->csvFileName = 'upload_'.StringUtil::random().'.'.$formFile->getClientOriginalExtension();
  44.         $formFile->move($this->eccubeConfig['eccube_csv_temp_realdir'], $this->csvFileName);
  46.         $file = new \SplFileObject($this->eccubeConfig['eccube_csv_temp_realdir'].'/'.$this->csvFileName);
  48.         set_time_limit(0);
  50.         // アップロードされたCSVファイルを行ごとに取得
  51.         $data = new CsvImportService($file, $this->eccubeConfig['eccube_csv_import_delimiter'], $this->eccubeConfig['eccube_csv_import_enclosure']);
  53.         return $data->setHeaderRowNumber(0) ? $data : false;
  54.     }
  56.     protected function sendTemplateResponse(Request $request, $columns, $filename)
  57.     {
  58.         set_time_limit(0);
  60.         $response = new StreamedResponse();
  61.         $response->setCallback(function () use ($columns) {
  62.             // ヘッダ行の出力
  63.             $row = [];
  64.             foreach ($columns as $column) {
  65.                 $row[] = mb_convert_encoding($column, $this->eccubeConfig['eccube_csv_export_encoding'], 'UTF-8');
  66.             }
  68.             $fp = fopen('php://output', 'w');
  69.             fputcsv($fp, $row, $this->eccubeConfig['eccube_csv_export_separator']);
  70.             fclose($fp);
  71.         });
  73.         $response->headers->set('Content-Type', 'application/octet-stream');
  74.         $response->headers->set('Content-Disposition', 'attachment; filename='.$filename);
  76.         return $response;
  77.     }
  79.     /**
  80.      * アップロードされたCSVファイルの削除
  81.      */
  82.     protected function removeUploadedFile()
  83.     {
  84.         if (!empty($this->csvFileName)) {
  85.             try {
  86.                 $fs = new Filesystem();
  87.                 $fs->remove($this->eccubeConfig['eccube_csv_temp_realdir'].'/'.$this->csvFileName);
  88.             } catch (\Exception $e) {
  89.                 // エラーが発生しても無視する
  90.             }
  91.         }
  92.     }
  93. }