app/Plugin/CustomerRank42/Event/CsvImportProductExtEvent.php line 57

Open in your IDE?
  1. <?php
  2. /*
  3. * Plugin Name : CustomerRank
  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\CustomerRank42\Event;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Eccube\Event\EventArgs;
  16. use Plugin\CustomerRank42\Entity\CustomerPrice;
  17. use Plugin\CustomerRank42\Repository\CustomerPriceRepository;
  18. use Plugin\CustomerRank42\Repository\CustomerRankRepository;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class CsvImportProductExtEvent implements EventSubscriberInterface
  22. {
  24.     private $entityManager;
  26.     private $customerRankRepository;
  28.     private $customerPriceRepository;
  30.     /**
  31.      * CustomerRankController constructor.
  32.      * @param CustomerRankRepository $customerRankRepository
  33.      */
  34.     public function __construct(
  35.             EntityManagerInterface $entityManager,
  36.             CustomerRankRepository $customerRankRepository,
  37.             CustomerPriceRepository $customerPriceRepository
  38.             )
  39.     {
  40.         $this->entityManager = $entityManager;
  41.         $this->customerRankRepository = $customerRankRepository;
  42.         $this->customerPriceRepository = $customerPriceRepository;
  43.     }
  45.     /**
  46.      * @return array
  47.      */
  48.     public static function getSubscribedEvents()
  49.     {
  50.         return [
  51.             'csvimportproductext.admin.product.csv.import.product.descriptions' => 'hookAdminProductCsvImportProductDescriptions',
  52.             'csvimportproductext.admin.product.csv.import.product.check'=> 'hookAdminProductCsvImportProductCheck',
  53.             'csvimportproductext.admin.product.csv.import.product.process' => 'hookAdminProductCsvImportProductProcess',
  54.         ];
  55.     }
  57.     public function hookAdminProductCsvImportProductDescriptions(EventArgs $event)
  58.     {
  59.         $header = $event->getArgument('header');
  60.         $key = $event->getArgument('key');
  61.         $CustomerRanks = $this->customerRankRepository->findAll();
  62.         foreach($CustomerRanks as $CustomerRank){
  63.             if($key == $CustomerRank->getName() . trans('customerrank.common.customer_price')){
  64.                 $header['description'] = trans('customerrank.admin.product.product_csv.customer_price_description');
  65.                 $header['required'] = false;
  66.             }
  67.         }
  69.         $event->setArgument('header',$header);
  70.     }
  72.     public function hookAdminProductCsvImportProductCheck(EventArgs $event)
  73.     {
  74.         $row = $event->getArgument('row');
  75.         $lineNo = $event->getArgument('lineNo');
  76.         $errors = $event->getArgument('errors');
  78.         $CustomerRanks = $this->customerRankRepository->findAll();
  79.         foreach($CustomerRanks as $CustomerRank){
  80.             if(isset($row[$CustomerRank->getName(). trans('customerrank.common.customer_price')])){
  81.                 if($row[$CustomerRank->getName(). trans('customerrank.common.customer_price')] !== '' && !is_numeric($row[$CustomerRank->getName(). trans('customerrank.common.customer_price')])){
  82.                     $message = trans('admin.common.csv_invalid_greater_than_zero', [
  83.                         '%line%' => $lineNo,
  84.                         '%name%' => $CustomerRank->getName(). trans('customerrank.common.customer_price'),
  85.                     ]);
  86.                     $errors[] = $message;
  87.                 }
  88.             }
  89.         }
  91.         $event->setArgument('errors',$errors);
  92.     }
  94.     public function hookAdminProductCsvImportProductProcess(EventArgs $event)
  95.     {
  96.         $row = $event->getArgument('row');
  97.         $ProductClass = $event->getArgument('ProductClass');
  99.         $CustomerRanks = $this->customerRankRepository->findAll();
  100.         foreach($CustomerRanks as $CustomerRank){
  101.             if(isset($row[$CustomerRank->getName() . trans('customerrank.common.customer_price')])){
  102.                 $plgPrice = $this->customerPriceRepository->findOneBy(['ProductClass' => $ProductClass, 'CustomerRank' => $CustomerRank]);
  103.                 if($row[$CustomerRank->getName() . trans('customerrank.common.customer_price')] != ''){
  104.                     if(is_null($plgPrice)){
  105.                         $plgPrice = new CustomerPrice();
  106.                         $plgPrice->setProductClass($ProductClass);
  107.                         $plgPrice->setCustomerRank($CustomerRank);
  108.                     }
  109.                     $plgPrice->setPrice($row[$CustomerRank->getName() . trans('customerrank.common.customer_price')]);
  110.                     $this->entityManager->persist($plgPrice);
  111.                 }else{
  112.                     if(isset($plgPrice))$this->entityManager->remove($plgPrice);
  113.                 }
  114.             }
  115.             if(isset($plgPrice))unset($plgPrice);
  116.         }
  117.     }
  118. }