src/Core/Content/ProductStream/ScheduledTask/UpdateProductStreamMappingTaskHandler.php line 41

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\ProductStream\ScheduledTask;
  5. use Shopware\Core\Framework\Context;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  10. use Shopware\Core\Framework\Log\Package;
  11. use Shopware\Core\Framework\MessageQueue\ScheduledTask\ScheduledTaskHandler;
  12. use Symfony\Component\Messenger\Attribute\AsMessageHandler;
  14. /**
  15.  * @internal
  16.  */
  17. #[AsMessageHandler(handles: UpdateProductStreamMappingTask::class)]
  18. #[Package('business-ops')]
  19. final class UpdateProductStreamMappingTaskHandler extends ScheduledTaskHandler
  20. {
  21.     /**
  22.      * @internal
  23.      */
  24.     public function __construct(
  25.         EntityRepository $repository,
  26.         private readonly EntityRepository $productStreamRepository
  27.     ) {
  28.         parent::__construct($repository);
  29.     }
  31.     public function run(): void
  32.     {
  33.         $context = Context::createDefaultContext();
  34.         $criteria = new Criteria();
  35.         $criteria->addFilter(new MultiFilter(MultiFilter::CONNECTION_OR, [
  36.             new EqualsFilter('filters.type', 'until'),
  37.             new EqualsFilter('filters.type', 'since'),
  38.         ]));
  40.         /** @var array<string> $streamIds */
  41.         $streamIds = $this->productStreamRepository->searchIds($criteria, $context)->getIds();
  42.         $data = array_map(fn (string $id) => ['id' => $id], $streamIds);
  44.         $this->productStreamRepository->update($data, $context);
  45.     }
  46. }