src/MessageHandler/BatchSendPendingCampaignHandler.php line 63

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