src/MessageHandler/BatchSendCampaignHandler.php line 61

Open in your IDE?
  1. <?php
  3. namespace App\MessageHandler;
  5. use App\Entity\Contact;
  6. use App\Entity\Task;
  7. use App\Message\BatchSendCampaignMessage;
  8. use App\Service\Api\Api;
  9. use App\Service\Api\Tasks;
  10. use App\Service\Campaign\CampaignEmailContact;
  11. use App\Service\Campaign\Sender\SenderInterface;
  12. use App\Service\Campaign\Sender\SendgridSender;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Psr\Container\ContainerInterface;
  15. use Psr\Log\LoggerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  18. use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
  19. use Symfony\Contracts\Service\ServiceSubscriberInterface;
  21. class BatchSendCampaignHandler implements MessageHandlerInterface, ServiceSubscriberInterface, EventSubscriberInterface {
  23. /**
  24. * @var EntityManagerInterface
  25. */
  26. private $em;
  27. /**
  28. * @var ContainerInterface
  29. */
  30. private $locator;
  31. /**
  32. * @var Tasks
  33. */
  34. private $tasksApi;
  35. private $logger;
  37. public function __construct(EntityManagerInterface $em, ContainerInterface $locator, LoggerInterface $logger, Api $api)
  38. {
  39. $this->em = $em;
  40. $this->locator = $locator;
  41. $this->tasksApi = $api->get(Tasks::class);
  42. $this->logger = $logger;
  43. }
  45. static function getSubscribedServices(): array
  46. {
  47. return [
  48. SendgridSender::class
  49. ];
  50. }
  52. static function getSubscribedEvents(): array
  53. {
  54. return [
  55. WorkerMessageFailedEvent::class => [
  56. ['handleFailed', 10]
  57. ]
  58. ];
  59. }
  61. public function handleFailed(WorkerMessageFailedEvent $event)
  62. {
  63. print_r($event->getReceiverName());
  64. }
  66. public function __invoke(BatchSendCampaignMessage $message)
  67. {
  68. $campaignEmail = $message->getCampaignEmail();
  69. /** @var SenderInterface $sender */
  70. $sender = $this->locator->get($message->getSenderClass());
  72. $groups = $message->getGroups();
  73. $jsonRules = $message->getJsonRules();
  74. $iterationNum = $message->getIterationNum();
  75. $batchSize = $message->getBatchSize();
  78. // Get contacts batch
  79. $cCount = 0;
  80. $contactsRepo = $this->em->getRepository(Contact::class);
  81. /** @var Contact[] $result */
  82. foreach ($contactsRepo->iterateByQueryBuilder($groups, $jsonRules, $batchSize, $iterationNum * $batchSize) as $result) {
  83. $contact = $result[0];
  84. $campaignEmailContact = new CampaignEmailContact($contact->getEmail(), $contact->getId());
  85. $campaignEmail->addContact($campaignEmailContact);
  86. $cCount++;
  87. }
  89. $this->logger->debug('Campaign '.$campaignEmail->getCampaignId().' batch '.$iterationNum.': ' . json_encode([
  90. 'from' => $campaignEmail->getFrom(),
  91. 'from_address' => $campaignEmail->getFromAddress(),
  92. 'subject' => $campaignEmail->getSubject(),
  93. 'count' => $cCount
  94. ]));
  96. // Send batch
  97. $sender->sendCampaign($campaignEmail);
  99. // Update task if there is one
  100. if ($task = $this->em->find(Task::class, $message->getTaskId())) {
  101. $this->tasksApi->increaseProgress($task);
  102. }
  103. }
  105. }