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

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