vendor/shopware/administration/System/SalesChannel/Subscriber/SalesChannelUserConfigSubscriber.php line 39

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Administration\System\SalesChannel\Subscriber;
  5. use Shopware\Core\Framework\Context;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\Framework\Log\Package;
  11. use Shopware\Core\System\User\Aggregate\UserConfig\UserConfigCollection;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. /**
  15. * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  16. */
  17. #[Package('system-settings')]
  18. class SalesChannelUserConfigSubscriber implements EventSubscriberInterface
  19. {
  20. public const CONFIG_KEY = 'sales-channel-favorites';
  22. private EntityRepositoryInterface $userConfigRepository;
  24. /**
  25. * @internal
  26. */
  27. public function __construct(EntityRepositoryInterface $userConfigRepository)
  28. {
  29. $this->userConfigRepository = $userConfigRepository;
  30. }
  32. public static function getSubscribedEvents(): array
  33. {
  34. return [
  35. 'sales_channel.deleted' => 'onSalesChannelDeleted',
  36. ];
  37. }
  39. public function onSalesChannelDeleted(EntityDeletedEvent $deletedEvent): void
  40. {
  41. $context = $deletedEvent->getContext();
  43. $deletedSalesChannelIds = $deletedEvent->getIds();
  45. $writeUserConfigs = [];
  46. foreach ($this->getAllFavoriteUserConfigs($context) as $userConfigEntity) {
  47. $salesChannelIds = $userConfigEntity->getValue();
  49. if ($salesChannelIds === null) {
  50. continue;
  51. }
  53. // Find matching IDs
  54. $matchingIds = array_intersect($deletedSalesChannelIds, $salesChannelIds);
  56. if (!$matchingIds) {
  57. continue;
  58. }
  60. // Removes the IDs from $matchingIds from the array
  61. $newUserConfigArray = array_diff($salesChannelIds, $matchingIds);
  62. $writeUserConfigs[] = [
  63. 'id' => $userConfigEntity->getId(),
  64. 'value' => array_values($newUserConfigArray),
  65. ];
  66. }
  68. $this->userConfigRepository->upsert($writeUserConfigs, $context);
  69. }
  71. private function getAllFavoriteUserConfigs(Context $context): UserConfigCollection
  72. {
  73. $criteria = new Criteria();
  74. $criteria->addFilter(new EqualsFilter('key', self::CONFIG_KEY));
  76. /** @var UserConfigCollection $result */
  77. $result = $this->userConfigRepository->search($criteria, $context)->getEntities();
  79. return $result;
  80. }
  81. }