app/Plugin/NZOrderLink42/EventSubscriber/OrderLinkSubscriber.php line 51

Open in your IDE?
  1. <?php
  3. namespace Plugin\NZOrderLink42\EventSubscriber;
  5. use Eccube\Entity\Customer;
  6. use Eccube\Entity\Order;
  7. use Eccube\Event\EccubeEvents;
  8. use Eccube\Event\EventArgs;
  9. use Eccube\Repository\OrderRepository;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Psr\Log\LoggerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class OrderLinkSubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var OrderRepository
  18.      */
  19.     private $orderRepository;
  21.     /**
  22.      * @var EntityManagerInterface
  23.      */
  24.     private $entityManager;
  26.     /**
  27.      * @var LoggerInterface
  28.      */
  29.     private $logger;
  31.     public function __construct(
  32.         OrderRepository $orderRepository,
  33.         EntityManagerInterface $entityManager,
  34.         LoggerInterface $logger
  35.     ) {
  36.         $this->orderRepository = $orderRepository;
  37.         $this->entityManager = $entityManager;
  38.         $this->logger = $logger;
  39.     }
  41.     public static function getSubscribedEvents()
  42.     {
  43.         return [
  44.             EccubeEvents::FRONT_ENTRY_INDEX_COMPLETE => 'onEntryComplete',
  45.         ];
  46.     }
  48.     /**
  49.      * 会員登録完了時に同じメールアドレスの非会員注文を紐付け
  50.      */
  51.     public function onEntryComplete(EventArgs $event)
  52.     {
  53.         /** @var Customer $customer */
  54.         $customer = $event->getArgument('Customer');
  55.         
  56.         if (!$customer || !$customer->getEmail()) {
  57.             return;
  58.         }
  60.         $email = $customer->getEmail();
  62.         // 同じメールアドレスの非会員注文を取得
  63.         $qb = $this->orderRepository->createQueryBuilder('o');
  64.         $orders = $qb
  65.             ->where('o.email = :email')
  66.             ->andWhere('o.Customer IS NULL')
  67.             ->setParameter('email', $email)
  68.             ->getQuery()
  69.             ->getResult();
  71.         if (empty($orders)) {
  72.             $this->logger->info('[NZOrderLink42] 紐付け対象の注文なし', [
  73.                 'customer_id' => $customer->getId(),
  74.                 'email' => $email,
  75.             ]);
  76.             return;
  77.         }
  79.         $linkedCount = 0;
  80.         /** @var Order $order */
  81.         foreach ($orders as $order) {
  82.             $order->setCustomer($customer);
  83.             $linkedCount++;
  84.             
  85.             $this->logger->info('[NZOrderLink42] 注文を会員に紐付け', [
  86.                 'order_id' => $order->getId(),
  87.                 'order_no' => $order->getOrderNo(),
  88.                 'customer_id' => $customer->getId(),
  89.             ]);
  90.         }
  92.         $this->entityManager->flush();
  94.         $this->logger->info('[NZOrderLink42] 紐付け完了', [
  95.             'customer_id' => $customer->getId(),
  96.             'email' => $email,
  97.             'linked_count' => $linkedCount,
  98.         ]);
  99.     }
  100. }