src/MessageHandler/CreateFixtureHandler.php line 68

Open in your IDE?
  1. <?php
  3. namespace App\MessageHandler;
  5. use App\Entity\Campaign;
  6. use App\Entity\CampaignContact;
  7. use App\Entity\CampaignLinkHit;
  8. use App\Entity\Contact;
  9. use App\Entity\SendEvent;
  10. use App\Entity\Task;
  11. use App\Event\CampaignContactUpdateEvent;
  12. use App\Message\BatchSendCampaignMessage;
  13. use App\Message\CreateFixtureMessage;
  14. use App\Service\Api\Api;
  15. use App\Service\Api\Tasks;
  16. use App\Service\Campaign\CampaignEmailContact;
  17. use App\Service\Campaign\Sender\SenderInterface;
  18. use App\Service\Campaign\Sender\SendgridSender;
  19. use Doctrine\ORM\EntityManagerInterface;
  20. use Psr\Container\ContainerInterface;
  21. use Psr\Log\LoggerInterface;
  22. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  23. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  24. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  25. use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
  26. use Symfony\Contracts\Service\ServiceSubscriberInterface;
  28. class CreateFixtureHandler implements MessageHandlerInterface, ServiceSubscriberInterface, EventSubscriberInterface {
  30. /**
  31. * @var EntityManagerInterface
  32. */
  33. private $em;
  34. /**
  35. * @var ContainerInterface
  36. */
  37. private $locator;
  38. /**
  39. * @var Tasks
  40. */
  41. private $tasksApi;
  42. private $logger;
  43. private $dispatcher;
  45. public function __construct(EntityManagerInterface $em, ContainerInterface $locator, LoggerInterface $logger, Api $api, EventDispatcherInterface $dispatcher)
  46. {
  47. $this->em = $em;
  48. $this->locator = $locator;
  49. $this->tasksApi = $api->get(Tasks::class);
  50. $this->logger = $logger;
  51. $this->dispatcher = $dispatcher;
  52. }
  54. static function getSubscribedServices(): array
  55. {
  56. return [];
  57. }
  59. static function getSubscribedEvents(): array
  60. {
  61. return [
  62. WorkerMessageFailedEvent::class => [
  63. ['handleFailed', 10]
  64. ]
  65. ];
  66. }
  68. public function handleFailed(WorkerMessageFailedEvent $event)
  69. {
  70. print_r($event->getReceiverName());
  71. }
  73. public function __invoke(CreateFixtureMessage $message)
  74. {
  75. $iterationNum = $message->getIterationNum();
  76. $batchSize = $message->getBatchSize();
  78. $campaign = $this->em->find(Campaign::class, $message->getCampaignId());
  79. $campaignLinks = $campaign->getCampaignLinks();
  81. $ccRepo = $this->em->getRepository(CampaignContact::class);
  82. $sentCount = $ccRepo->countAllByUserId($campaign->getUser()->getId(), ['campaign' => 25]);
  84. /** @var CampaignContact[] $result */
  85. foreach ($ccRepo->iterateByCampaignId($campaign->getId(), $batchSize, $iterationNum * $batchSize) as $result) {
  86. $cContact = $result[0];
  88. $sendEvents = [];
  90. $sendEvents[] = (new SendEvent())
  91. ->setCreatedAt(new \DateTime())
  92. ->setEvent('processed')
  93. ->setCampaignContact($cContact);
  95. $sendEvents[] = (new SendEvent())
  96. ->setCreatedAt(new \DateTime())
  97. ->setEvent('delivered')
  98. ->setCampaignContact($cContact);
  100. $randInt = random_int(0, 8);
  101. switch ($randInt) {
  102. case 0:
  103. $sendEvents[] = (new SendEvent())
  104. ->setCreatedAt(new \DateTime())
  105. ->setEvent('bounced')
  106. ->setMessage('Spam bounced for testing')
  107. ->setCampaignContact($cContact);
  108. break;
  109. case 1:
  110. $moreRand = random_int(1,5);
  111. for ($i=0; $i<$moreRand; $i++) {
  112. $sendEvents[] = (new SendEvent())
  113. ->setCreatedAt(new \DateTime())
  114. ->setEvent('opened')
  115. ->setMessage('Opened for testing')
  116. ->setCampaignContact($cContact);
  118. $sendEvents[] = (new SendEvent())
  119. ->setCreatedAt(new \DateTime())
  120. ->setEvent('clicked')
  121. ->setCampaignContact($cContact);
  123. $linkHit = new CampaignLinkHit();
  124. $linkHit->setCampaignContact($cContact);
  126. $oneOfTheLinks = $campaignLinks[random_int(0, count($campaignLinks))];
  127. $linkHit->setCampaignLink($oneOfTheLinks);
  128. $linkHit->setDateCreated(new \DateTime());
  129. $this->em->persist($linkHit);
  130. }
  131. break;
  132. }
  134. foreach ($sendEvents as $sendEvent) {
  135. $event = new CampaignContactUpdateEvent($sendEvent);
  136. $this->dispatcher->dispatch($event, $event::NAME);
  137. $sendEventResult = $event->getSendEvent();
  139. $this->em->persist($sendEventResult);
  140. }
  142. $this->em->flush();
  143. }
  145. // Update task if there is one
  146. if ($task = $this->em->find(Task::class, $message->getTaskId())) {
  147. $this->tasksApi->increaseProgress($task);
  148. }
  149. }
  151. }