src/Command/DraftManageCommand.php line 20

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: Grigor
  5.  * Date: 12/24/19
  6.  * Time: 12:35 PM
  7.  */
  9. namespace App\Command;
  11. use App\Entity\Draft;
  12. use App\Entity\DraftFile;
  13. use Doctrine\ORM\EntityManager;
  14. use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
  15. use Symfony\Component\Console\Command\LockableTrait;
  16. use Symfony\Component\Console\Input\InputInterface;
  17. use Symfony\Component\Console\Output\OutputInterface;
  18. use Symfony\Component\Console\Style\SymfonyStyle;
  20. class DraftManageCommand extends ContainerAwareCommand
  21. {
  22.     use LockableTrait;
  24.     protected static $defaultName = 'state:delete-published-drafts';
  26.     /** @var EntityManager $em */
  27.     private $em;
  29.     /** @var SymfonyStyle $io */
  30.     private $io;
  33.     protected function configure()
  34.     {
  35.         $this->setDescription('Delete drafts published a day ago');
  36.     }
  38.     protected function initialize(InputInterface $input, OutputInterface $output)
  39.     {
  40.         parent::initialize($input, $output);
  41.         $this->em = $this->getContainer()->get('doctrine.orm.entity_manager');
  43.         // DISABLE SQL LOGGING, CAUSE IT CAUSES MEMORY SHORTAGE on large inserts
  44.         $this->em->getConnection()->getConfiguration()->setSQLLogger(null);
  45.         $this->io = new SymfonyStyle($input, $output);
  46.     }
  48.     /**
  49.      * @param InputInterface $input
  50.      * @param OutputInterface $output
  51.      * @return int|null
  52.      * @throws \Exception
  53.      */
  54.     protected function execute(InputInterface $input, OutputInterface $output)
  55.     {
  56.         if (!$this->lock()) {
  57.             $output->writeln('The command is already running in another process.');
  59.             return 0;
  60.         }
  62.         /**
  63.          * @var Draft[] $drafts
  64.          */
  65.         $drafts = $this->em->getRepository(Draft::class)->getPublishedDrafts();
  66.         if ($drafts) {
  67.             foreach ($drafts as $draft) {
  68.                 //  get local files & delete
  69.                 /**
  70.                  * @var DraftFile[] $draftFiles
  71.                  */
  72.                 $draftFiles = $this->em->getRepository(DraftFile::class)->findBy(['draft' => $draft]);
  73.                 if ($draftFiles) {
  74.                     foreach ($draftFiles as $draftFile) {
  75.                         $uri = $draftFile->getUri();
  76.                         $fileUsages = $this->em->getRepository(DraftFile::class)->getFileUsagesWithException($uri, $draft);
  77.                         if (!$fileUsages && file_exists(getcwd() . '/public/' . $draftFile->getPath())) {
  78.                             unlink(getcwd() . '/public/' . $draftFile->getPath());
  79.                         }
  80.                     }
  81.                 }
  83.                 $this->em->remove($draft);
  84.                 $this->em->flush();
  85.             }
  86.         }
  88.         $this->io->success('Done');
  89.         $this->release();
  91.         return null;
  92.     }
  93. }