custom/plugins/SelfdelveCms/src/Subscriber/CustomerLoadedSubscriber.php line 51

Open in your IDE?
  1. <?php
  2. namespace Selfdelve\Cms\Subscriber;
  4. use Shopware\Core\Checkout\Customer\CustomerEvents;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use Shopware\Core\Checkout\Customer\CustomerEntity;
  7. use Shopware\Core\Checkout\Customer\Aggregate\CustomerGroup\CustomerGroupEntity;
  8. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  13. class CustomerLoadedSubscriber implements EventSubscriberInterface
  14. {
  15.     const UNVERIFIED_PATTERN = '***%s***UNVERIFIED***';
  17.     private EntityRepositoryInterface $customerRepository;
  19.     private EntityRepositoryInterface $customerGroupRepository;
  21.     /**
  22.      * @param EntityRepositoryInterface $customerRepository
  23.      * @param EntityRepositoryInterface $customerGroupRepository
  24.      */
  25.     public function __construct(
  26.         EntityRepositoryInterface $customerRepository,
  27.         EntityRepositoryInterface $customerGroupRepository
  28.     )
  29.     {
  30.         $this->customerRepository = $customerRepository;
  31.         $this->customerGroupRepository = $customerGroupRepository;
  32.     }
  34.     /**
  35.      * @return array
  36.      */
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             CustomerEvents::CUSTOMER_LOADED_EVENT => 'onCustomerLoaded',
  41.         ];
  42.     }
  44.     /**
  45.      * If a business user requested membership in a business customer group and
  46.      * the request is still pending, then mask the given vat ids in order to avoid illegitimate orders.
  47.      *
  48.      * @param EntityLoadedEvent $event
  49.      * @return void
  50.      */
  51.     public function onCustomerLoaded(EntityLoadedEvent $event)
  52.     {
  53.         // Ignore in backend
  54.         if ($event->getContext()->getSource() instanceof AdminApiSource) {
  55.             return;
  56.         }
  58.         if (0 === count($event->getEntities())) {
  59.             return;
  60.         }
  62.         foreach ($event->getEntities() as $entity) {
  63.             if (!$entity instanceof CustomerEntity || '' === (string) $entity->getRequestedGroupId()) {
  64.                 continue;
  65.             }
  67.             /** @var CustomerGroupEntity $customerGroup */
  68.             $customerGroup = $this->customerGroupRepository->search(
  69.                 new Criteria([$entity->getRequestedGroupId()]),
  70.                 $event->getContext()
  71.             )->first();
  73.             if (!$customerGroup instanceof CustomerGroupEntity || false === $customerGroup->getRegistrationOnlyCompanyRegistration()) {
  74.                 continue;
  75.             }
  77.             // Business customer group requested
  78.             $vatIds = $entity->getVatIds();
  79.             foreach ($vatIds as &$vatId) {
  80.                 $vatId = sprintf(self::UNVERIFIED_PATTERN, $vatId);
  81.             }
  82.             $entity->setVatIds($vatIds);
  83.         }
  84.     }
  85. }