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

  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(
  29.         private readonly EntityRepository $customerRepository,
  30.         private readonly SalesChannelContextServiceInterface $salesChannelContextService,
  31.         private readonly EventDispatcherInterface $eventDispatcher
  32.     ) {
  33.     }
  35.     /**
  36.      * @return array<string, string>
  37.      */
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             BeforeDeleteEvent::class => 'beforeDelete',
  42.         ];
  43.     }
  45.     public function beforeDelete(BeforeDeleteEvent $event): void
  46.     {
  47.         $context = $event->getContext();
  49.         $ids = $event->getIds(CustomerDefinition::ENTITY_NAME);
  51.         if (empty($ids)) {
  52.             return;
  53.         }
  55.         $source = $context->getSource();
  56.         $salesChannelId = null;
  58.         if ($source instanceof SalesChannelApiSource) {
  59.             $salesChannelId = $source->getSalesChannelId();
  60.         }
  62.         /** @var CustomerCollection $customers */
  63.         $customers = $this->customerRepository->search(new Criteria($ids), $context);
  65.         $event->addSuccess(function () use ($customers, $context, $salesChannelId): void {
  66.             foreach ($customers->getElements() as $customer) {
  67.                 $salesChannelContext = $this->salesChannelContextService->get(
  68.                     new SalesChannelContextServiceParameters(
  69.                         $salesChannelId ?? $customer->getSalesChannelId(),
  70.                         Random::getAlphanumericString(32),
  71.                         $customer->getLanguageId(),
  72.                         null,
  73.                         null,
  74.                         $context,
  75.                     )
  76.                 );
  78.                 $this->eventDispatcher->dispatch(new CustomerDeletedEvent($salesChannelContext, $customer));
  79.             }
  80.         });
  81.     }
  82. }