src/Core/Checkout/Customer/Subscriber/CustomerBeforeDeleteSubscriber.php line 42

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