vendor/shopware/platform/src/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.             $orderCustomer = $order->getOrderCustomer();
  74.             if ($orderCustomer === null) {
  75.                 continue;
  76.             }
  77.             $customerId = $orderCustomer->getCustomerId();
  79.             // happens if the customer was deleted
  80.             if (!$customerId) {
  81.                 continue;
  82.             }
  84.             $orderCount = 0;
  86.             $customerResult = $this->customerRepository->search(
  87.                 (new Criteria([$customerId]))->addAssociation('orderCustomers'),
  88.                 $context
  89.             );
  91.             /** @var CustomerEntity $customer */
  92.             $customer = $customerResult->first();
  94.             if ($customer !== null && $customer->getOrderCustomers()) {
  95.                 $orderCount = $customer->getOrderCustomers()->count();
  96.             }
  98.             $data = [
  99.                 [
  100.                     'id' => $customerId,
  101.                     'orderCount' => $orderCount,
  102.                     'lastOrderDate' => $orderDate->format('Y-m-d H:i:s.v'),
  103.                 ],
  104.             ];
  106.             $context->scope(Context::SYSTEM_SCOPE, function () use ($data, $context): void {
  107.                 $this->customerRepository->update($data, $context);
  108.             });
  109.         }
  110.     }
  111. }