vendor/shopware/core/Content/ProductExport/ScheduledTask/ProductExportGenerateTaskHandler.php line 91

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\ProductExport\ScheduledTask;
  5. use Shopware\Core\Content\ProductExport\ProductExportEntity;
  6. use Shopware\Core\Defaults;
  7. use Shopware\Core\Framework\Context;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  12. use Shopware\Core\Framework\Log\Package;
  13. use Shopware\Core\Framework\MessageQueue\ScheduledTask\ScheduledTaskHandler;
  14. use Shopware\Core\Framework\Uuid\Uuid;
  15. use Shopware\Core\System\SalesChannel\Context\AbstractSalesChannelContextFactory;
  16. use Symfony\Component\Messenger\MessageBusInterface;
  18. /**
  19.  * @deprecated tag:v6.5.0 - reason:becomes-internal - MessageHandler will be internal and final starting with v6.5.0.0
  20.  */
  21. #[Package('inventory')]
  22. class ProductExportGenerateTaskHandler extends ScheduledTaskHandler
  23. {
  24.     /**
  25.      * @var AbstractSalesChannelContextFactory
  26.      */
  27.     private $salesChannelContextFactory;
  29.     /**
  30.      * @var EntityRepositoryInterface
  31.      */
  32.     private $salesChannelRepository;
  34.     /**
  35.      * @var EntityRepositoryInterface
  36.      */
  37.     private $productExportRepository;
  39.     /**
  40.      * @var MessageBusInterface
  41.      */
  42.     private $messageBus;
  44.     /**
  45.      * @internal
  46.      */
  47.     public function __construct(
  48.         EntityRepositoryInterface $scheduledTaskRepository,
  49.         AbstractSalesChannelContextFactory $salesChannelContextFactory,
  50.         EntityRepositoryInterface $salesChannelRepository,
  51.         EntityRepositoryInterface $productExportRepository,
  52.         MessageBusInterface $messageBus
  53.     ) {
  54.         parent::__construct($scheduledTaskRepository);
  56.         $this->salesChannelContextFactory = $salesChannelContextFactory;
  57.         $this->salesChannelRepository = $salesChannelRepository;
  58.         $this->productExportRepository = $productExportRepository;
  59.         $this->messageBus = $messageBus;
  60.     }
  62.     /**
  63.      * @return iterable<class-string>
  64.      */
  65.     public static function getHandledMessages(): iterable
  66.     {
  67.         return [
  68.             ProductExportGenerateTask::class,
  69.         ];
  70.     }
  72.     public function run(): void
  73.     {
  74.         $salesChannelIds = $this->fetchSalesChannelIds();
  76.         foreach ($salesChannelIds as $salesChannelId) {
  77.             $productExports = $this->fetchProductExports($salesChannelId);
  79.             if (\count($productExports) === 0) {
  80.                 continue;
  81.             }
  83.             $now = new \DateTimeImmutable('now');
  85.             foreach ($productExports as $productExport) {
  86.                 if (!$this->shouldBeRun($productExport, $now)) {
  87.                     continue;
  88.                 }
  90.                 $this->messageBus->dispatch(
  91.                     new ProductExportPartialGeneration($productExport->getId(), $salesChannelId)
  92.                 );
  93.             }
  94.         }
  95.     }
  97.     /**
  98.      * @return array<string>
  99.      */
  100.     private function fetchSalesChannelIds(): array
  101.     {
  102.         $criteria = new Criteria();
  103.         $criteria
  104.             ->addFilter(new EqualsFilter('typeId', Defaults::SALES_CHANNEL_TYPE_STOREFRONT))
  105.             ->addFilter(new EqualsFilter('active', true));
  107.         /**
  108.          * @var array<string>
  109.          */
  110.         return $this->salesChannelRepository
  111.             ->searchIds($criteria, Context::createDefaultContext())
  112.             ->getIds();
  113.     }
  115.     /**
  116.      * @return array<ProductExportEntity>
  117.      */
  118.     private function fetchProductExports(string $salesChannelId): array
  119.     {
  120.         $salesChannelContext = $this->salesChannelContextFactory->create(Uuid::randomHex(), $salesChannelId);
  122.         $criteria = new Criteria();
  123.         $criteria
  124.             ->addAssociation('salesChannel')
  125.             ->addFilter(
  126.                 new MultiFilter(
  127.                     'AND',
  128.                     [
  129.                         new EqualsFilter('generateByCronjob', true),
  130.                         new EqualsFilter('salesChannel.active', true),
  131.                     ]
  132.                 )
  133.             )
  134.             ->addFilter(
  135.                 new MultiFilter(
  136.                     'OR',
  137.                     [
  138.                         new EqualsFilter('storefrontSalesChannelId', $salesChannelId),
  139.                         new EqualsFilter('salesChannelDomain.salesChannel.id', $salesChannelId),
  140.                     ]
  141.                 )
  142.             );
  144.         /**
  145.          * @var array<ProductExportEntity>
  146.          */
  147.         return $this->productExportRepository->search($criteria, $salesChannelContext->getContext())->getElements();
  148.     }
  150.     private function shouldBeRun(ProductExportEntity $productExport, \DateTimeImmutable $now): bool
  151.     {
  152.         if ($productExport->getIsRunning()) {
  153.             return false;
  154.         }
  156.         if ($productExport->getGeneratedAt() === null) {
  157.             return true;
  158.         }
  160.         return $now->getTimestamp() - $productExport->getGeneratedAt()->getTimestamp() >= $productExport->getInterval();
  161.     }
  162. }