custom/plugins/MeteorPromotionGift/src/Subscribers/FreeGiftRedemptionUpdater.php line 36

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Meteor\PromotionGift\Subscribers;
  7. use Meteor\PromotionGift\Checker\LineItemIsFreeGiftInterface;
  8. use Meteor\PromotionGift\Core\Checkout\Promotion\Cart\GiftProcessor;
  9. use Meteor\PromotionGift\Dal\FetchCustomerCountsForPromotionsInterface;
  10. use Meteor\PromotionGift\Dal\UpdatePromotionCountInterface;
  11. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  12. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  13. use Shopware\Core\Framework\Uuid\Uuid;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class FreeGiftRedemptionUpdater implements EventSubscriberInterface
  17. {
  18.     private LineItemIsFreeGiftInterface $lineItemIsFreeGift;
  19.     private FetchCustomerCountsForPromotionsInterface $fetchCustomerCountsForPromotions;
  20.     private UpdatePromotionCountInterface $updatePromotionCount;
  22.     public function __construct(LineItemIsFreeGiftInterface $lineItemIsFreeGift, FetchCustomerCountsForPromotionsInterface $fetchCustomerCountsForPromotions, UpdatePromotionCountInterface $updatePromotionCount)
  23.     {
  24.         $this->lineItemIsFreeGift = $lineItemIsFreeGift;
  25.         $this->fetchCustomerCountsForPromotions = $fetchCustomerCountsForPromotions;
  26.         $this->updatePromotionCount = $updatePromotionCount;
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             CheckoutOrderPlacedEvent::class => '__invoke',
  33.         ];
  34.     }
  36.     public function __invoke(CheckoutOrderPlacedEvent $event): void
  37.     {
  38.         $lineItems = $event->getOrder()->getLineItems();
  39.         $customer = $event->getOrder()->getOrderCustomer();
  41.         if (!$lineItems || !$customer) {
  42.             return;
  43.         }
  44.         $customerId = $customer->getCustomerId();
  45.         $promotionIds = [];
  46.         foreach ($lineItems as $lineItem) {
  47.             if (!($this->lineItemIsFreeGift)($lineItem)) {
  48.                 continue;
  49.             }
  51.             $promotionId = $this->fetchPromotionId($lineItem);
  53.             if (!$promotionId) {
  54.                 continue;
  55.             }
  57.             $promotionIds[] = $promotionId;
  58.         }
  60.         if (0 === count($promotionIds)) {
  61.             return;
  62.         }
  64.         $promotionsUsedByCustomersCount = ($this->fetchCustomerCountsForPromotions)($promotionIds);
  66.         $calculatedPromotionsUsedByCustomer = [];
  68.         foreach ($promotionIds as $promotionId) {
  69.             $calculatedPromotionsUsedByCustomer[$promotionId] = $this->calculatePromotionUsedByCustomer(
  70.                 $promotionsUsedByCustomersCount,
  71.                 $promotionId,
  72.                 $customerId
  73.             );
  74.         }
  75.         ($this->updatePromotionCount)($promotionIds, $calculatedPromotionsUsedByCustomer);
  76.     }
  78.     private function calculatePromotionUsedByCustomer(array $allCustomerCounts, $promotionId, $customerId): array
  79.     {
  80.         $promotionUsedByCustomers = $allCustomerCounts[$promotionId] ?? null;
  82.         if (null === $promotionUsedByCustomers) {
  83.             // Prepare array if code isn't used yet
  84.             $allCustomerCounts[$promotionId] = [];
  85.         }
  87.         $promotionUsedByCurrentCustomer = $promotionUsedByCustomers[$customerId] ?? null;
  89.         if (null === $promotionUsedByCurrentCustomer) {
  90.             // initiate count if customer hasn't used promotion yet
  91.             $promotionUsedByCustomers[$customerId] = 1;
  93.             return $promotionUsedByCustomers;
  94.         }
  96.         // +1 if customer has used this code before
  97.         $promotionUsedByCustomers[$customerId] = $promotionUsedByCurrentCustomer + 1;
  99.         return $promotionUsedByCustomers;
  100.     }
  102.     private function fetchPromotionId(OrderLineItemEntity $lineItem): ?string
  103.     {
  104.         $payload = $lineItem->getPayload();
  105.         $payloadPromotionIdKey = $payload[GiftProcessor::PAYLOAD_PROMOTION_ID_KEY] ?? null;
  107.         if (null === $payloadPromotionIdKey) {
  108.             return null;
  109.         }
  111.         $promotionId = $payload[GiftProcessor::PAYLOAD_PROMOTION_ID_KEY] ?? null;
  113.         if (!Uuid::isValid((string) $promotionId)) {
  114.             return null;
  115.         }
  117.         return (string) $promotionId;
  118.     }
  119. }