vendor/shopware/core/Checkout/Customer/Subscriber/CustomerBeforeDeleteSubscriber.php line 48

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Checkout\Customer\Subscriber;
  5. use Shopware\Core\Checkout\Customer\CustomerDefinition;
  6. use Shopware\Core\Checkout\Customer\Event\CustomerDeletedEvent;
  7. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\BeforeDeleteEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\Util\Random;
  12. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextServiceInterface;
  13. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextServiceParameters;
  14. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class CustomerBeforeDeleteSubscriber implements EventSubscriberInterface
  18. {
  19.     private EntityRepositoryInterface $customerRepository;
  21.     private SalesChannelContextServiceInterface $salesChannelContextService;
  23.     private EventDispatcherInterface $eventDispatcher;
  25.     /**
  26.      * @internal
  27.      */
  28.     public function __construct(
  29.         EntityRepositoryInterface $customerRepository,
  30.         SalesChannelContextServiceInterface $salesChannelContextService,
  31.         EventDispatcherInterface $eventDispatcher
  32.     ) {
  33.         $this->customerRepository = $customerRepository;
  34.         $this->salesChannelContextService = $salesChannelContextService;
  35.         $this->eventDispatcher = $eventDispatcher;
  36.     }
  38.     /**
  39.      * @return array<string, string>
  40.      */
  41.     public static function getSubscribedEvents()
  42.     {
  43.         return [
  44.             BeforeDeleteEvent::class => 'beforeDelete',
  45.         ];
  46.     }
  48.     public function beforeDelete(BeforeDeleteEvent $event): void
  49.     {
  50.         $context = $event->getContext();
  52.         $ids = $event->getIds(CustomerDefinition::ENTITY_NAME);
  54.         if (empty($ids)) {
  55.             return;
  56.         }
  58.         $source = $context->getSource();
  59.         $salesChannelId = null;
  61.         if ($source instanceof SalesChannelApiSource) {
  62.             $salesChannelId = $source->getSalesChannelId();
  63.         }
  65.         $customers = $this->customerRepository->search(new Criteria($ids), $context);
  67.         $event->addSuccess(function () use ($customers, $context, $salesChannelId): void {
  68.             foreach ($customers->getElements() as $customer) {
  69.                 $salesChannelContext = $this->salesChannelContextService->get(
  70.                     new SalesChannelContextServiceParameters(
  71.                         $salesChannelId ?? $customer->getSalesChannelId(),
  72.                         Random::getAlphanumericString(32),
  73.                         $customer->getLanguageId(),
  74.                         null,
  75.                         null,
  76.                         $context,
  77.                     )
  78.                 );
  80.                 $this->eventDispatcher->dispatch(new CustomerDeletedEvent($salesChannelContext, $customer));
  81.             }
  82.         });
  83.     }
  84. }