bundle/w3des/NewsletterBundle/src/Command/SendCommand.php line 71

Open in your IDE?
  1. <?php
  2. namespace w3des\NewsletterBundle\Command;
  4. use Symfony\Component\Console\Input\InputArgument;
  5. use Symfony\Component\Console\Input\InputInterface;
  6. use Symfony\Component\Console\Output\OutputInterface;
  7. use w3des\AdminBundle\Entity\User;
  8. use w3des\NewsletterBundle\Util;
  9. use Symfony\Component\Console\Input\InputOption;
  10. use w3des\NewsletterBundle\Entity\NewsletterContent;
  11. use Symfony\Component\Console\Command\Command;
  12. use Doctrine\ORM\EntityManagerInterface;
  14. class SendCommand extends Command
  15. {
  17. /**
  18. * @var string|null The default command name
  19. */
  20. protected static $defaultName = 'admin:newsletter:send';
  22. /**
  23. * @var string|null The default command description
  24. */
  25. protected static $defaultDescription = 'Send newsletter';
  27. private EntityManagerInterface $em;
  29. private Util $mailer;
  31. public function __construct(EntityManagerInterface $em, Util $mailer)
  32. {
  33. parent::__construct();
  34. $this->em = $em;
  35. $this->mailer = $mailer;
  36. }
  38. protected function configure()
  39. {
  40. $this->addOption('content', null, InputOption::VALUE_OPTIONAL)
  41. ->addOption('test', null, InputOption::VALUE_OPTIONAL)
  42. ->addOption('all', null, InputOption::VALUE_NONE);
  43. }
  45. protected function execute(InputInterface $input, OutputInterface $output)
  46. {
  47. ini_set("memory_limit", "-1");
  48. set_time_limit(0);
  49. if (! $input->getOption('test') && ! $input->getOption('all')) {
  50. $output->writeln('<error>Podaj e-mail testowy</error>');
  51. return self::FAILURE;
  52. }
  53. if ($input->getOption('content')) {
  54. $content = $this->em->find(NewsletterContent::class, $input->getOption('content'));
  55. if ($content) {
  56. $this->process($content, $input->getOption('test'), $output);
  57. } else {
  58. $output->writeln('<error>Nie istnieje</error>');
  59. }
  60. } else {
  61. foreach ($this->em->createQuery('select c from w3desNewsletterBundle:NewsletterContent c where c.sendAt is not null and (c.sent != :send or c.sent is null)')->execute([
  62. 'send' => true
  63. ]) as $cnt) {
  64. $this->process($cnt, $input->getOption('test'), $output);
  65. }
  66. }
  68. return self::SUCCESS;
  69. }
  71. protected function process(NewsletterContent $content, $email = null, OutputInterface $output)
  72. {
  73. $output->writeln('<info>Wysyłka ' . $content->getTitle() . ':</info>');
  74. $this->mailer
  75. ->send($content, $email, $output);
  76. if ($email == null) {
  77. $content->setSent(true);
  78. $this->em->persist($content);
  79. $this->em->flush();
  80. }
  81. }
  82. }