app/Plugin/CustomerClassPrice42/Event.php line 92

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of CustomerClassPrice
  5.  *
  6.  * Copyright(c) Akira Kurozumi <info@a-zumi.net>
  7.  *
  8.  * https://a-zumi.net
  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 Plugin\CustomerClassPrice42;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Eccube\Entity\Customer;
  18. use Eccube\Entity\Master\OrderItemType;
  19. use Eccube\Entity\OrderItem;
  20. use Eccube\Entity\Shipping;
  21. use Eccube\Event\EccubeEvents;
  22. use Eccube\Event\EventArgs;
  23. use Eccube\Event\TemplateEvent;
  24. use Eccube\Repository\Master\OrderItemTypeRepository;
  25. use Eccube\Request\Context;
  26. use Plugin\CustomerClassPrice42\Entity\CustomerClassPrice;
  27. use Plugin\CustomerClassPrice42\Repository\CustomerClassPriceRepository;
  28. use Plugin\ProductOption42\Entity\OrderItemOption;
  29. use Plugin\ProductOption42\Entity\OrderItemOptionCategory;
  30. use Symfony\Component\DependencyInjection\ParameterBag\ContainerBagInterface;
  31. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  33. class Event implements EventSubscriberInterface
  34. {
  35.     /**
  36.      * @var Context
  37.      */
  38.     private Context $context;
  40.     /**
  41.      * @var EntityManagerInterface
  42.      */
  43.     private EntityManagerInterface $entityManager;
  45.     /**
  46.      * @var OrderItemTypeRepository
  47.      */
  48.     private OrderItemTypeRepository $orderItemTypeRepository;
  50.     /**
  51.      * @var ContainerBagInterface
  52.      */
  53.     private ContainerBagInterface $container;
  55.     /**
  56.      * @var CustomerClassPriceRepository
  57.      */
  58.     private CustomerClassPriceRepository $customerClassPriceRepository;
  60.     public function __construct(
  61.         Context $context,
  62.         EntityManagerInterface $entityManager,
  63.         OrderItemTypeRepository $orderItemTypeRepository,
  64.         ContainerBagInterface $container,
  65.         CustomerClassPriceRepository $customerClassPriceRepository
  66.     ) {
  67.         $this->context = $context;
  68.         $this->entityManager = $entityManager;
  69.         $this->orderItemTypeRepository = $orderItemTypeRepository;
  70.         $this->container = $container;
  71.         $this->customerClassPriceRepository = $customerClassPriceRepository;
  72.     }
  74.     /**
  75.      * {@inheritDoc}
  76.      */
  77.     public static function getSubscribedEvents()
  78.     {
  79.         return [
  80.             'Product/detail.twig' => 'onTemplateProductDetail',
  81.             '@admin/Product/product.twig' => 'onRenderAdminProduct',
  82.             EccubeEvents::FRONT_SHOPPING_SHIPPING_MULTIPLE_COMPLETE => [
  83.                 ['onFrontShoppingShippingMultipleComplete', -999999],
  84.             ],
  85.         ];
  86.     }
  88.     /**
  89.      * @param TemplateEvent $event
  90.      * @return void
  91.      */
  92.     public function onTemplateProductDetail(TemplateEvent $event): void
  93.     {
  94.         $event->addAsset('@CustomerClassPrice42/Product/assets/css/detail.twig');
  95.         $event->addSnippet('@CustomerClassPrice42/Product/assets/js/detail.twig');
  96.     }
  98.     /**
  99.      * @param TemplateEvent $event
  100.      * @return void
  101.      */
  102.     public function onRenderAdminProduct(TemplateEvent $event): void
  103.     {
  104.         $event->addSnippet('@CustomerClassPrice42/admin/Product/product.twig');
  105.     }
  107.     /**
  108.      * 商品オプションプラグインのためどうしようもなく対応。
  109.      * なぜかイベント内でDoctrineのイベントが発火しない
  110.      *
  111.      * @param EventArgs $event
  112.      * @return void
  113.      */
  114.     public function onFrontShoppingShippingMultipleComplete(EventArgs $event): void
  115.     {
  116.         $enabled = $this->container->get('eccube.plugins.enabled');
  118.         if (false === in_array('ProductOption42', $enabled, true)) {
  119.             return;
  120.         }
  122.         $form = $event->getArgument('form');
  123.         $Order = $event->getArgument('Order');
  125.         if ($form->isSubmitted() && $form->isValid()) {
  126.             $data = $form['shipping_multiple'];
  128.             // フォームの入力から、送り先ごとに商品の数量を集計する
  129.             $arrOrderItemTemp = [];
  130.             foreach ($data as $multiples) {
  131.                 $OrderItem = $multiples->getData();
  132.                 foreach ($multiples as $items) {
  133.                     foreach ($items as $item) {
  134.                         $CustomerAddress = $item['customer_address']->getData();
  135.                         $customerAddressName = $CustomerAddress->getShippingMultipleDefaultName();
  137.                         $itemId = $OrderItem->getProductClass()->getId().'_'.$OrderItem->getOptionSerial();
  138.                         $quantity = $item['quantity']->getData();
  140.                         if (isset($arrOrderItemTemp[$customerAddressName]) && array_key_exists($itemId, $arrOrderItemTemp[$customerAddressName])) {
  141.                             $arrOrderItemTemp[$customerAddressName][$itemId] = $arrOrderItemTemp[$customerAddressName][$itemId] + $quantity;
  142.                         } else {
  143.                             $arrOrderItemTemp[$customerAddressName][$itemId] = $quantity;
  144.                         }
  145.                     }
  146.                 }
  147.             }
  149.             // -- ここから先がお届け先を再生成する処理 --
  151.             // お届け先情報をすべて削除
  152.             /** @var Shipping $Shipping */
  153.             foreach ($Order->getShippings() as $Shipping) {
  154.                 foreach ($Shipping->getOrderItems() as $OrderItem) {
  155.                     $Shipping->removeOrderItem($OrderItem);
  156.                     $Order->removeOrderItem($OrderItem);
  157.                     $this->entityManager->remove($OrderItem);
  158.                 }
  159.                 $Order->removeShipping($Shipping);
  160.                 $this->entityManager->remove($Shipping);
  161.             }
  163.             // お届け先のリストを作成する
  164.             $ShippingList = [];
  165.             foreach ($data as $multiples) {
  166.                 $OrderItem = $multiples->getData();
  167.                 $ProductClass = $OrderItem->getProductClass();
  168.                 $Delivery = $OrderItem->getShipping()->getDelivery();
  169.                 $saleTypeId = $ProductClass->getSaleType()->getId();
  171.                 foreach ($multiples as $items) {
  172.                     foreach ($items as $item) {
  173.                         $CustomerAddress = $item['customer_address']->getData();
  174.                         $customerAddressName = $CustomerAddress->getShippingMultipleDefaultName();
  176.                         if (isset($ShippingList[$customerAddressName][$saleTypeId])) {
  177.                             continue;
  178.                         }
  179.                         $Shipping = new Shipping();
  180.                         $Shipping
  181.                             ->setOrder($Order)
  182.                             ->setFromCustomerAddress($CustomerAddress)
  183.                             ->setDelivery($Delivery);
  184.                         $Order->addShipping($Shipping);
  185.                         $ShippingList[$customerAddressName][$saleTypeId] = $Shipping;
  186.                     }
  187.                 }
  188.             }
  189.             // お届け先のリストを保存
  190.             foreach ($ShippingList as $ShippingListByAddress) {
  191.                 foreach ($ShippingListByAddress as $Shipping) {
  192.                     $this->entityManager->persist($Shipping);
  193.                 }
  194.             }
  196.             $ProductOrderType = $this->orderItemTypeRepository->find(OrderItemType::PRODUCT);
  198.             // お届け先に、配送商品の情報(OrderItem)を関連付ける
  199.             foreach ($data as $multiples) {
  200.                 /** @var OrderItem $OrderItem */
  201.                 $OrderItem = $multiples->getData();
  202.                 $ProductClass = $OrderItem->getProductClass();
  203.                 $Product = $OrderItem->getProduct();
  204.                 $saleTypeId = $ProductClass->getSaleType()->getId();
  205.                 $itemId = $OrderItem->getProductClass()->getId().'_'.$OrderItem->getOptionSerial();
  206.                 $optionSerial = $OrderItem->getOptionSerial();
  207.                 $OrderItemOptions = $OrderItem->getOrderItemOptions();
  208.                 $optionPrice = $OrderItem->getOptionPrice();
  209.                 $optionTax = $OrderItem->getOptionTax();
  211.                 foreach ($multiples as $items) {
  212.                     foreach ($items as $item) {
  213.                         $CustomerAddress = $item['customer_address']->getData();
  214.                         $customerAddressName = $CustomerAddress->getShippingMultipleDefaultName();
  216.                         // お届け先から商品の数量を取得
  217.                         $quantity = 0;
  218.                         if (isset($arrOrderItemTemp[$customerAddressName]) && array_key_exists($itemId, $arrOrderItemTemp[$customerAddressName])) {
  219.                             $quantity = $arrOrderItemTemp[$customerAddressName][$itemId];
  220.                             unset($arrOrderItemTemp[$customerAddressName][$itemId]);
  221.                         } else {
  222.                             // この配送先には送る商品がないのでスキップ（通常ありえない）
  223.                             continue;
  224.                         }
  226.                         // 関連付けるお届け先のインスタンスを取得
  227.                         $Shipping = $ShippingList[$customerAddressName][$saleTypeId];
  229.                         $Price02 = $ProductClass->getPrice02();
  230.                         $customerClass = $this->getCustomerClass();
  231.                         if (null !== $customerClass) {
  232.                             /** @var CustomerClassPrice $customerClassPrice */
  233.                             $customerClassPrice = $this->customerClassPriceRepository->findOneBy([
  234.                                 'customerClass' => $customerClass,
  235.                                 'productClass' => $ProductClass,
  236.                             ]);
  238.                             if ($customerClassPrice) {
  239.                                 $Price02 = $customerClassPrice->getPrice();
  240.                             }
  241.                         }
  243.                         // インスタンスを生成して保存
  244.                         $OrderItem = new OrderItem();
  245.                         $OrderItem->setShipping($Shipping)
  246.                             ->setOrder($Order)
  247.                             ->setProductClass($ProductClass)
  248.                             ->setProduct($Product)
  249.                             ->setProductName($Product->getName())
  250.                             ->setProductCode($ProductClass->getCode())
  251.                             ->setPrice($Price02)
  252.                             ->setQuantity($quantity)
  253.                             ->setOrderItemType($ProductOrderType)
  254.                             ->setOptionSerial($optionSerial);
  256.                         $ClassCategory1 = $ProductClass->getClassCategory1();
  257.                         if (!is_null($ClassCategory1)) {
  258.                             $OrderItem->setClasscategoryName1($ClassCategory1->getName());
  259.                             $OrderItem->setClassName1($ClassCategory1->getClassName()->getName());
  260.                         }
  261.                         $ClassCategory2 = $ProductClass->getClassCategory2();
  262.                         if (!is_null($ClassCategory2)) {
  263.                             $OrderItem->setClasscategoryName2($ClassCategory2->getName());
  264.                             $OrderItem->setClassName2($ClassCategory2->getClassName()->getName());
  265.                         }
  266.                         foreach ($OrderItemOptions as $OrderItemOption) {
  267.                             $newOrderItemOption = new OrderItemOption();
  268.                             $newOrderItemOption->setOptionId($OrderItemOption->getOptionId())
  269.                                 ->setOrderItem($OrderItem)
  270.                                 ->setLabel($OrderItemOption->getLabel())
  271.                                 ->setSortNo($OrderItemOption->getSortNo());
  272.                             foreach ($OrderItemOption->getOrderItemOptionCategories() as $OrderItemOptionCategory) {
  273.                                 $newOrderItemOptionCategory = new OrderItemOptionCategory();
  274.                                 $newOrderItemOptionCategory->setOptionCategoryId($OrderItemOptionCategory->getOptionCategoryId())
  275.                                     ->setOrderItemOption($newOrderItemOption)
  276.                                     ->setValue($OrderItemOptionCategory->getValue())
  277.                                     ->setPrice($OrderItemOptionCategory->getPrice())
  278.                                     ->setTax($OrderItemOptionCategory->getTax())
  279.                                     ->setDeliveryFreeFlg($OrderItemOptionCategory->getDeliveryFreeFlg())
  280.                                     ->setSortNo($OrderItemOptionCategory->getSortNo());
  281.                                 $newOrderItemOption->addOrderItemOptionCategory($newOrderItemOptionCategory);
  282.                             }
  283.                             $OrderItem->addOrderItemOption($newOrderItemOption);
  284.                         }
  285.                         $OrderItem->setPrice($OrderItem->getPrice() + $optionPrice);
  286.                         $OrderItem->setTax($OrderItem->getTax() + $optionTax);
  287.                         $Shipping->addOrderItem($OrderItem);
  288.                         $Order->addOrderItem($OrderItem);
  289.                         $this->entityManager->persist($OrderItem);
  290.                     }
  291.                 }
  292.             }
  294.             $this->entityManager->flush();
  295.         }
  296.     }
  298.     /**
  299.      * @return false|CustomerClass
  300.      */
  301.     protected function getCustomerClass()
  302.     {
  303.         if (!$this->context->getCurrentUser() instanceof Customer) {
  304.             return false;
  305.         }
  307.         $customerClass = $this->context->getCurrentUser()->getPlgCcpCustomerClass();
  309.         if (null === $customerClass) {
  310.             return false;
  311.         }
  313.         return $customerClass;
  314.     }
  315. }