src/Core/Checkout/Promotion/Subscriber/PromotionIndividualCodeRedeemer.php line 45

  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\CodeAlreadyRedeemedException;
  12. use Shopware\Core\Checkout\Promotion\Exception\PromotionCodeNotFoundException;
  13. use Shopware\Core\Framework\Context;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  18. use Shopware\Core\Framework\Log\Package;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. /**
  22.  * @internal
  23.  */
  24. #[Package('checkout')]
  25. class PromotionIndividualCodeRedeemer implements EventSubscriberInterface
  26. {
  27.     /**
  28.      * @internal
  29.      */
  30.     public function __construct(private readonly EntityRepository $codesRepository)
  31.     {
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             CheckoutOrderPlacedEvent::class => 'onOrderPlaced',
  38.         ];
  39.     }
  41.     /**
  42.      * @throws CodeAlreadyRedeemedException
  43.      * @throws InconsistentCriteriaIdsException
  44.      */
  45.     public function onOrderPlaced(CheckoutOrderPlacedEvent $event): void
  46.     {
  47.         foreach ($event->getOrder()->getLineItems() ?? [] as $item) {
  48.             // only update promotions in here
  49.             if ($item->getType() !== PromotionProcessor::LINE_ITEM_TYPE) {
  50.                 continue;
  51.             }
  53.             /** @var string $code */
  54.             $code = $item->getPayload()['code'] ?? '';
  56.             try {
  57.                 // first try if its an individual
  58.                 // if not, then it might be a global promotion
  59.                 $individualCode = $this->getIndividualCode($code, $event->getContext());
  60.             } catch (PromotionCodeNotFoundException) {
  61.                 $individualCode = null;
  62.             }
  64.             // if we did not use an individual code we might have
  65.             // just used a global one or anything else, so just quit in this case.
  66.             if (!($individualCode instanceof PromotionIndividualCodeEntity)) {
  67.                 return;
  68.             }
  70.             /** @var OrderCustomerEntity $customer */
  71.             $customer = $event->getOrder()->getOrderCustomer();
  73.             // set the code to be redeemed
  74.             // and assign all required meta data
  75.             // for later needs
  76.             $individualCode->setRedeemed(
  77.                 $item->getOrderId(),
  78.                 $customer->getCustomerId() ?? '',
  79.                 $customer->getFirstName() . ' ' . $customer->getLastName()
  80.             );
  82.             // save in database
  83.             $this->codesRepository->update(
  84.                 [
  85.                     [
  86.                         'id' => $individualCode->getId(),
  87.                         'payload' => $individualCode->getPayload(),
  88.                     ],
  89.                 ],
  90.                 $event->getContext()
  91.             );
  92.         }
  93.     }
  95.     /**
  96.      * Gets all individual code entities for the provided code value.
  97.      *
  98.      * @throws PromotionCodeNotFoundException
  99.      * @throws InconsistentCriteriaIdsException
  100.      */
  101.     private function getIndividualCode(string $code, Context $context): PromotionIndividualCodeEntity
  102.     {
  103.         $criteria = new Criteria();
  104.         $criteria->addFilter(
  105.             new EqualsFilter('code', $code)
  106.         );
  108.         /** @var PromotionIndividualCodeCollection $result */
  109.         $result = $this->codesRepository->search($criteria, $context)->getEntities();
  111.         if (\count($result->getElements()) <= 0) {
  112.             throw new PromotionCodeNotFoundException($code);
  113.         }
  115.         // return first element
  116.         return $result->first();
  117.     }
  118. }