src/Core/Framework/App/ScheduledTask/DeleteCascadeAppsHandler.php line 45

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\App\ScheduledTask;
  5. use Shopware\Core\Defaults;
  6. use Shopware\Core\Framework\Context;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  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: DeleteCascadeAppsTask::class)]
  18. #[Package('core')]
  20. final class DeleteCascadeAppsHandler extends ScheduledTaskHandler
  21. {
  22.     private const HARD_DELETE_AFTER_DAYS = 1;
  24.     /**
  25.      * @internal
  26.      */
  27.     public function __construct(
  28.         EntityRepository $scheduledTaskRepository,
  29.         private readonly EntityRepository $aclRoleRepository,
  30.         private readonly EntityRepository $integrationRepository
  31.     ) {
  32.         parent::__construct($scheduledTaskRepository);
  33.     }
  35.     public function run(): void
  36.     {
  37.         $context = Context::createDefaultContext();
  38.         $timeExpired = (new \DateTimeImmutable())->modify(sprintf('-%s day', self::HARD_DELETE_AFTER_DAYS))->format(Defaults::STORAGE_DATE_TIME_FORMAT);
  40.         $criteria = new Criteria();
  41.         $criteria->addFilter(new RangeFilter('deletedAt', [
  42.             RangeFilter::LTE => $timeExpired,
  43.         ]));
  45.         $this->deleteIds($this->aclRoleRepository, $criteria, $context);
  46.         $this->deleteIds($this->integrationRepository, $criteria, $context);
  47.     }
  49.     private function deleteIds(EntityRepository $repository, Criteria $criteria, Context $context): void
  50.     {
  51.         $data = $repository->searchIds($criteria, $context)->getData();
  53.         if (empty($data)) {
  54.             return;
  55.         }
  57.         $deleteIds = array_values($data);
  59.         $repository->delete($deleteIds, $context);
  60.     }
  61. }