vendor/shopware/core/Checkout/Customer/Subscriber/CustomerMetaFieldSubscriber.php line 40

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Checkout\Customer\Subscriber;
  5. use Shopware\Core\Checkout\Customer\CustomerEntity;
  6. use Shopware\Core\Checkout\Order\OrderDefinition;
  7. use Shopware\Core\Checkout\Order\OrderEntity;
  8. use Shopware\Core\Checkout\Order\OrderEvents;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class CustomerMetaFieldSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var EntityRepositoryInterface
  19.      */
  20.     private $orderRepository;
  22.     /**
  23.      * @var EntityRepositoryInterface
  24.      */
  25.     private $customerRepository;
  27.     public function __construct(EntityRepositoryInterface $orderRepository, EntityRepositoryInterface $customerRepository)
  28.     {
  29.         $this->orderRepository = $orderRepository;
  30.         $this->customerRepository = $customerRepository;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             OrderEvents::ORDER_WRITTEN_EVENT => 'fillCustomerMetaDataFields',
  37.         ];
  38.     }
  40.     public function fillCustomerMetaDataFields(EntityWrittenEvent $event): void
  41.     {
  42.         if ($event->getEntityName() !== OrderDefinition::ENTITY_NAME) {
  43.             return;
  44.         }
  46.         $context = $event->getContext();
  48.         foreach ($event->getWriteResults() as $writeResult) {
  49.             if ($writeResult->getExistence() !== null && $writeResult->getExistence()->exists()) {
  50.                 break;
  51.             }
  53.             $payload = $writeResult->getPayload();
  54.             if (empty($payload)) {
  55.                 continue;
  56.             }
  58.             /** @var \DateTimeInterface $orderDate */
  59.             $orderDate = $payload['orderDateTime'];
  61.             $orderResult = $this->orderRepository->search(
  62.                 (new Criteria([$payload['id']]))->addAssociation('orderCustomer'),
  63.                 $context
  64.             );
  66.             /** @var OrderEntity|null $order */
  67.             $order = $orderResult->first();
  69.             if (!($order instanceof OrderEntity)) {
  70.                 continue;
  71.             }
  73.             $customerId = $order->getOrderCustomer()->getCustomerId();
  74.             // happens if the customer was deleted
  75.             if (!$customerId) {
  76.                 continue;
  77.             }
  79.             $orderCount = 0;
  81.             $customerResult = $this->customerRepository->search(
  82.                 (new Criteria([$customerId]))->addAssociation('orderCustomers'),
  83.                 $context
  84.             );
  86.             /** @var CustomerEntity $customer */
  87.             $customer = $customerResult->first();
  89.             if ($customer !== null && $customer->getOrderCustomers()) {
  90.                 $orderCount = $customer->getOrderCustomers()->count();
  91.             }
  93.             $data = [
  94.                 [
  95.                     'id' => $customerId,
  96.                     'orderCount' => $orderCount,
  97.                     'lastOrderDate' => $orderDate->format('Y-m-d H:i:s.v'),
  98.                 ],
  99.             ];
  101.             $context->scope(Context::SYSTEM_SCOPE, function () use ($data, $context): void {
  102.                 $this->customerRepository->update($data, $context);
  103.             });
  104.         }
  105.     }
  106. }