src/Core/Content/Newsletter/ScheduledTask/NewsletterRecipientTaskHandler.php line 32

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Newsletter\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\RangeFilter;
  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: NewsletterRecipientTask::class)]
  18. #[Package('customer-order')]
  19. final class NewsletterRecipientTaskHandler extends ScheduledTaskHandler
  20. {
  21.     /**
  22.      * @internal
  23.      */
  24.     public function __construct(EntityRepository $scheduledTaskRepository, private readonly EntityRepository $newsletterRecipientRepository)
  25.     {
  26.         parent::__construct($scheduledTaskRepository);
  27.     }
  29.     public function run(): void
  30.     {
  31.         $criteria = $this->getExpiredNewsletterRecipientCriteria();
  32.         $emailRecipient = $this->newsletterRecipientRepository->searchIds($criteria, Context::createDefaultContext());
  34.         if (empty($emailRecipient->getIds())) {
  35.             return;
  36.         }
  38.         $emailRecipientIds = array_map(fn ($id) => ['id' => $id], $emailRecipient->getIds());
  40.         $this->newsletterRecipientRepository->delete($emailRecipientIds, Context::createDefaultContext());
  41.     }
  43.     private function getExpiredNewsletterRecipientCriteria(): Criteria
  44.     {
  45.         $criteria = new Criteria();
  47.         $dateTime = (new \DateTime())->add(\DateInterval::createFromDateString('-30 days'));
  49.         $criteria->addFilter(new RangeFilter(
  50.             'createdAt',
  51.             [
  52.                 RangeFilter::LTE => $dateTime->format(\DATE_ATOM),
  53.             ]
  54.         ));
  56.         $criteria->addFilter(new EqualsFilter('status', 'notSet'));
  58.         $criteria->setLimit(999);
  60.         return $criteria;
  61.     }
  62. }