custom/plugins/rapi1Connector/src/Subscribers/UpdatedCustomerOrderEntitySubscriber.php line 39

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Rapidmail\Shopware\Subscribers;
  7. use Psr\Log\LoggerInterface;
  8. use Shopware\Core\Checkout\Order\Aggregate\OrderCustomer\OrderCustomerEntity;
  9. use Shopware\Core\Checkout\Order\OrderEntity;
  10. use Shopware\Core\Checkout\Order\OrderEvents;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  17. class UpdatedCustomerOrderEntitySubscriber extends UpdatedCustomerRelatedEntitySubscriber
  18. {
  19.     public const SUBSCRIBED_TO_ENTITY_NAME = 'order';
  21.     private EntityRepositoryInterface $orderRepository;
  23.     public function __construct(
  24.         EntityRepositoryInterface $customerRepository,
  25.         EntityRepositoryInterface $orderRepository,
  26.         LoggerInterface $logger
  27.     ) {
  28.         parent::__construct($customerRepository, $logger);
  29.         $this->orderRepository = $orderRepository;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             OrderEvents::ORDER_WRITTEN_EVENT => 'onWrittenOrder',
  36.         ];
  37.     }
  39.     public function onWrittenOrder(EntityWrittenEvent $event): void
  40.     {
  41.         $context = $event->getContext();
  42.         $writeResult = $event->getWriteResults()[0] ?? null;
  44.         if (!($writeResult instanceof EntityWriteResult)) {
  45.             return;
  46.         }
  48.         $payload = $writeResult->getPayload();
  50.         if ($this->isAllowed($event, $payload)) {
  51.             $customerId = $this->getCustomerId($payload['id'], $context);
  53.             if ($customerId) {
  54.                 $this->updateCustomer($customerId, $context);
  55.             }
  56.         }
  57.     }
  59.     protected function isAllowed(EntityWrittenEvent $event, ?array $data): bool
  60.     {
  61.         return (
  62.             $event->getEntityName() === self::SUBSCRIBED_TO_ENTITY_NAME &&
  63.             is_array($data) &&
  64.             !empty($data['id'])
  65.         );
  66.     }
  68.     private function getCustomerId(string $orderId, Context $context): ?string
  69.     {
  70.         $criteria = new Criteria([$orderId]);
  71.         $criteria->addAssociation('orderCustomer');
  73.         $order = $this->orderRepository
  74.             ->search($criteria, $context)
  75.             ->first();
  77.         if ($order instanceof OrderEntity) {
  78.             $orderCustomer = $order->getOrderCustomer();
  80.             if ($orderCustomer instanceof OrderCustomerEntity) {
  81.                 return $orderCustomer->getCustomerId();
  82.             }
  83.         }
  85.         return null;
  86.     }
  87. }