vendor/shopware/core/Checkout/Promotion/Subscriber/PromotionIndividualCodeRedeemer.php line 39

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace Shopware\Core\Checkout\Promotion\Subscriber;
  6. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderCustomer\OrderCustomerEntity;
  8. use Shopware\Core\Checkout\Promotion\Aggregate\PromotionIndividualCode\PromotionIndividualCodeCollection;
  9. use Shopware\Core\Checkout\Promotion\Aggregate\PromotionIndividualCode\PromotionIndividualCodeEntity;
  10. use Shopware\Core\Checkout\Promotion\Cart\PromotionProcessor;
  11. use Shopware\Core\Checkout\Promotion\Exception\PromotionCodeNotFoundException;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class PromotionIndividualCodeRedeemer implements EventSubscriberInterface
  19. {
  20.     /** @var EntityRepositoryInterface */
  21.     private $codesRepository;
  23.     public function __construct(EntityRepositoryInterface $codesRepository)
  24.     {
  25.         $this->codesRepository = $codesRepository;
  26.     }
  28.     public static function getSubscribedEvents()
  29.     {
  30.         return [
  31.             CheckoutOrderPlacedEvent::class => 'onOrderPlaced',
  32.         ];
  33.     }
  35.     /**
  36.      * @throws \Shopware\Core\Checkout\Promotion\Exception\CodeAlreadyRedeemedException
  37.      * @throws \Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException
  38.      */
  39.     public function onOrderPlaced(CheckoutOrderPlacedEvent $event): void
  40.     {
  41.         foreach ($event->getOrder()->getLineItems() as $item) {
  42.             // only update promotions in here
  43.             if ($item->getType() !== PromotionProcessor::LINE_ITEM_TYPE) {
  44.                 continue;
  45.             }
  47.             /** @var string $code */
  48.             $code = $item->getPayload()['code'];
  50.             /** @var PromotionIndividualCodeEntity|null $individualCode */
  51.             $individualCode = null;
  53.             try {
  54.                 // first try if its an individual
  55.                 // if not, then it might be a global promotion
  56.                 $individualCode = $this->getIndividualCode($code, $event->getContext());
  57.             } catch (PromotionCodeNotFoundException $ex) {
  58.                 $individualCode = null;
  59.             }
  61.             // if we did not use an individual code we might have
  62.             // just used a global one or anything else, so just quit in this case.
  63.             if (!$individualCode instanceof PromotionIndividualCodeEntity) {
  64.                 return;
  65.             }
  67.             /** @var OrderCustomerEntity $customer */
  68.             $customer = $event->getOrder()->getOrderCustomer();
  70.             // set the code to be redeemed
  71.             // and assign all required meta data
  72.             // for later needs
  73.             $individualCode->setRedeemed(
  74.                 $item->getOrderId(),
  75.                 $customer->getCustomerId(),
  76.                 $customer->getFirstName() . ' ' . $customer->getLastName()
  77.             );
  79.             // save in database
  80.             $this->codesRepository->update(
  81.                 [
  82.                     [
  83.                         'id' => $individualCode->getId(),
  84.                         'payload' => $individualCode->getPayload(),
  85.                     ],
  86.                 ],
  87.                 $event->getContext()
  88.             );
  89.         }
  90.     }
  92.     /**
  93.      * Gets all individual code entities for the provided code value.
  94.      *
  95.      * @throws PromotionCodeNotFoundException
  96.      * @throws \Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException
  97.      */
  98.     private function getIndividualCode(string $code, Context $context): PromotionIndividualCodeEntity
  99.     {
  100.         $criteria = new Criteria();
  101.         $criteria->addFilter(
  102.             new EqualsFilter('code', $code)
  103.         );
  105.         /** @var PromotionIndividualCodeCollection $result */
  106.         $result = $this->codesRepository->search($criteria, $context)->getEntities();
  108.         if (count($result->getElements()) <= 0) {
  109.             throw new PromotionCodeNotFoundException($code);
  110.         }
  112.         // return first element
  113.         return $result->first();
  114.     }
  115. }