custom/static-plugins/extended-customer-list/src/Subscriber/Customer/Checkout/CustomerOrderAmountSubscriber.php line 44

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Wexo\ExtendedCustomerList\Subscriber\Customer\Checkout;
  5. use Wexo\ExtendedCustomerList\Helpers\Helper;
  6. use Shopware\Core\Checkout\Customer\CustomerEntity;
  7. use Shopware\Core\Checkout\Order\OrderDefinition;
  8. use Shopware\Core\Checkout\Order\OrderEntity;
  9. use Shopware\Core\Checkout\Order\OrderEvents;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class CustomerOrderAmountSubscriber implements EventSubscriberInterface
  17. {
  18.     private Helper $helper;
  20.     /**
  21.      * @param EntityRepositoryInterface $orderRepository
  22.      * @param EntityRepositoryInterface $customerRepository
  23.      */
  24.     public function __construct(
  25.         protected EntityRepositoryInterface $orderRepository,
  26.         protected EntityRepositoryInterface $customerRepository
  27.     ) {
  28.         $this->helper = new Helper($customerRepository, Context::createDefaultContext());
  29.     }
  31.     /**
  32.      * @return array|string[]
  33.      */
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             OrderEvents::ORDER_WRITTEN_EVENT => 'fillCustomerMetaDataFields',
  38.         ];
  39.     }
  41.     /**
  42.      * @param EntityWrittenEvent $event
  43.      */
  44.     public function fillCustomerMetaDataFields(EntityWrittenEvent $event): void
  45.     {
  46.         if ($event->getEntityName() !== OrderDefinition::ENTITY_NAME) {
  47.             return;
  48.         }
  50.         $context = $event->getContext();
  52.         foreach ($event->getWriteResults() as $writeResult) {
  53.             if ($writeResult->getExistence() !== null && $writeResult->getExistence()->exists()) {
  54.                 break;
  55.             }
  57.             $payload = $writeResult->getPayload();
  58.             if (empty($payload)) {
  59.                 continue;
  60.             }
  62.             $orderResult = $this->orderRepository->search(
  63.                 (new Criteria([$payload['id']]))->addAssociation('orderCustomer'),
  64.                 $context
  65.             );
  67.             /** @var OrderEntity|null $order */
  68.             $order = $orderResult->first();
  70.             if (!($order instanceof OrderEntity)) {
  71.                 continue;
  72.             }
  74.             $customerId = $order->getOrderCustomer()->getCustomerId();
  75.             // happens if the customer was deleted
  76.             if (!$customerId) {
  77.                 continue;
  78.             }
  80.             $this->helper->calculate($customerId);
  81.         }
  82.     }
  83. }