src/EventListener/ApiOrderPlacedListener.php line 41

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Entity\Gos\AdditionalAccess\AdditionalAccessBeneficiary;
  6. use App\Entity\Gos\AdditionalAccess\UserAdditionalAccessOffer;
  7. use App\Entity\Gos\OrderPart;
  8. use App\Entity\Gos\OrderProductVariant;
  9. use App\Entity\Gos\Orders;
  10. use App\Entity\Gos\RenewalOffer\UserRenewalOffer;
  11. use App\Event\ApiOrderPlacedEvent;
  12. use App\Utils\RenewalOffer\RenewalOfferUtils;
  13. use App\Utils\SyncNadzorService;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class ApiOrderPlacedListener implements EventSubscriberInterface
  18. {
  19.     private $entityManager;
  20.     private $renewalOfferUtils;
  22.     public function __construct(
  23.         EntityManagerInterface $entityManager,
  24.         RenewalOfferUtils      $renewalOfferUtils
  25.     )
  26.     {
  27.         $this->entityManager     = $entityManager;
  28.         $this->renewalOfferUtils = $renewalOfferUtils;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             ApiOrderPlacedEvent::API_ORDER_PLACED => [
  35.                 ['assignNextOrderToUserRenewalOffer', 10],
  36.                 ['createAdditionalAccessBeneficiary', 0],
  37.             ],
  38.         ];
  39.     }
  41.     public function assignNextOrderToUserRenewalOffer(ApiOrderPlacedEvent $event): void
  42.     {
  43.         $orderId = $event->getOrderId();
  44.         $session = $event->getRequest()->getSession();
  46.         if (null === $userRenewalOfferHash = $session->get('renewalOfferHash'))
  47.         {
  48.             return;
  49.         }
  51.         $session->remove('renewalOfferHash');
  53.         $order            = $this->entityManager->getRepository(Orders::class)->find($orderId);
  54.         $userRenewalOffer = $this->entityManager->getRepository(UserRenewalOffer::class)->findOneByHash($userRenewalOfferHash);
  56.         $possibleVariants = $this->renewalOfferUtils->getPossibleVariantsAccordingToOrderedItem(
  57.             $userRenewalOffer->getRenewalOffer()->getSuggestedVariants(),
  58.             $userRenewalOffer->getProductVariantNoComplete()
  59.         );
  61.         $possiblePvNo = array_map(function (array $productVariant) {
  62.             return $productVariant['pvNo'];
  63.         }, $possibleVariants);
  65.         /** @var OrderPart $orderPart */
  66.         foreach ($order->getOrderPart() as $orderPart)
  67.         {
  68.             /** @var OrderProductVariant $orderProductVariant */
  69.             foreach ($orderPart->getOrderProductVariant() as $orderProductVariant)
  70.             {
  71.                 if (in_array($orderProductVariant->getProductVariantNoComplete(), $possiblePvNo, true))
  72.                 {
  73.                     $userRenewalOffer->setNextOrder($order);
  75.                     $this->entityManager->persist($userRenewalOffer);
  76.                     $this->entityManager->flush();
  78.                     return;
  79.                 }
  80.             }
  81.         }
  82.     }
  84.     public function createAdditionalAccessBeneficiary(ApiOrderPlacedEvent $event): void
  85.     {
  86.         $session = $event->getRequest()->getSession();
  88.         if (
  89.             empty($event->getRequest()->request->get('additionalAccessUsers'))
  90.             || null === $userAdditionalAccessOfferHash = $session->get('additionalAccessOfferHash')
  91.         )
  92.         {
  93.             return;
  94.         }
  96.         $session->remove('additionalAccessOfferHash');
  98.         $order                     = $this->entityManager->getRepository(Orders::class)
  99.                                                          ->find($event->getOrderId());
  100.         $userAdditionalAccessOffer = $this->entityManager->getRepository(UserAdditionalAccessOffer::class)
  101.                                                          ->findOneByHash($userAdditionalAccessOfferHash);
  103.         $order->setUserAdditionalAccessOffer($userAdditionalAccessOffer);
  105.         foreach ($event->getRequest()->request->get('additionalAccessUsers') as $beneficiary)
  106.         {
  107.             $beneficiary = (new AdditionalAccessBeneficiary())
  108.                 ->setOrders($order)
  109.                 ->setFirstName($beneficiary['firstname'])
  110.                 ->setLastName($beneficiary['lastname'])
  111.                 ->setEmail($beneficiary['email'])
  112.                 ->setPhoneNumber($beneficiary['phone'])
  113.                 ->setPosition($beneficiary['position']);
  115.             $this->entityManager->persist($beneficiary);
  116.         }
  118.         $this->entityManager->flush();
  119.     }
  120. }