app/Plugin/ProductOption42/Event/CsvImportProductExtEvent.php line 52

Open in your IDE?
  1. <?php
  2. /*
  3. * Plugin Name : ProductOption
  4. *
  5. * Copyright (C) BraTech Co., Ltd. All Rights Reserved.
  6. * http://www.bratech.co.jp/
  7. *
  8. * For the full copyright and license information, please view the LICENSE
  9. * file that was distributed with this source code.
  10. */
  12. namespace Plugin\ProductOption42\Event;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Eccube\Event\EventArgs;
  16. use Plugin\ProductOption42\Entity\ProductOption;
  17. use Plugin\ProductOption42\Repository\OptionRepository;
  18. use Plugin\ProductOption42\Repository\ProductOptionRepository;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class CsvImportProductExtEvent implements EventSubscriberInterface
  22. {
  23.     private $entityManager;
  25.     private $optionRepository;
  27.     private $productOptionRepository;
  29.     public function __construct(
  30.             EntityManagerInterface $entityManager,
  31.             OptionRepository $optionRepository,
  32.             ProductOptionRepository $productOptionRepository
  33.             )
  34.     {
  35.         $this->entityManager = $entityManager;
  36.         $this->optionRepository = $optionRepository;
  37.         $this->productOptionRepository = $productOptionRepository;
  38.     }
  40.     /**
  41.      * @return array
  42.      */
  43.     public static function getSubscribedEvents()
  44.     {
  45.         return [
  46.             'csvimportproductext.admin.product.csv.import.product.descriptions' => 'hookAdminProductCsvImportProductDescriptions',
  47.             'csvimportproductext.admin.product.csv.import.product.check'=> 'hookAdminProductCsvImportProductCheck',
  48.             'csvimportproductext.admin.product.csv.import.product.process' => 'hookAdminProductCsvImportProductProcess',
  49.         ];
  50.     }
  52.     public function hookAdminProductCsvImportProductDescriptions(EventArgs $event)
  53.     {
  54.         $header = $event->getArgument('header');
  55.         $key = $event->getArgument('key');
  56.         if($key == trans('productoption.csv.product.label.id')){
  57.             $header['description'] = trans('productoption.admin.product.product_csv.product_assign_description');
  58.             $header['required'] = false;
  59.         }
  61.         $event->setArgument('header',$header);
  62.     }
  64.     public function hookAdminProductCsvImportProductCheck(EventArgs $event)
  65.     {
  66.         $row = $event->getArgument('row');
  67.         $lineNo = $event->getArgument('lineNo');
  68.         $errors = $event->getArgument('errors');
  70.         if(isset($row[trans('productoption.csv.product.label.id')])){
  71.             if($row[trans('productoption.csv.product.label.id')] !== '' && preg_match("/[^0-9,]/", $row[trans('productoption.csv.product.label.id')])){
  72.                 $message = trans('productoption.admin.product.product_csv.not_correct', [
  73.                     '%line%' => $lineNo,
  74.                     '%name%' => trans('productoption.csv.product.label.id'),
  75.                 ]);
  76.                 $errors[] = $message;
  77.             }
  78.         }
  80.         $event->setArgument('errors',$errors);
  81.     }
  83.     public function hookAdminProductCsvImportProductProcess(EventArgs $event)
  84.     {
  85.         $row = $event->getArgument('row');
  86.         $ProductClass = $event->getArgument('ProductClass');
  87.         $Product = $ProductClass->getProduct();
  89.         if(isset($row[trans('productoption.csv.product.label.id')])){
  90.             // 一旦クリア
  91.             $currentProductOptions = $Product->getProductOptions();
  92.             foreach ($currentProductOptions as $currentProductOption) {
  93.                 $this->entityManager->remove($currentProductOption);
  94.                 $Product->removeProductOption($currentProductOption);
  95.             }
  96.             $this->entityManager->persist($Product);
  97.             $this->entityManager->flush();
  98.         }
  100.         if(isset($row[trans('productoption.csv.product.label.id')]) && strlen($row[trans('productoption.csv.product.label.id')]) > 0){
  101.             $productOptions = explode(',', $row[trans('productoption.csv.product.label.id')]);
  102.             foreach($productOptions as $option_id){
  103.                 if(is_numeric($option_id)){
  104.                     $Option = $this->optionRepository->find($option_id);
  105.                     if($Option){
  106.                         $ProductOption = new ProductOption();
  107.                         $ProductOption->setProduct($Product);
  108.                         $ProductOption->setOption($Option);
  109.                         $this->productOptionRepository->save($ProductOption);
  110.                         $Product->addProductOption($ProductOption);
  111.                     }
  112.                 }
  113.             }
  114.         }
  115.     }
  116. }