bundle/w3des/SmsBundle/src/EventSubscriber/NodeEventSubscriber.php line 27

Open in your IDE?
  1. <?php
  3. namespace w3des\SmsBundle\EventSubscriber;
  5. use Doctrine\Common\EventSubscriber;
  6. use Doctrine\ORM\Events;
  7. use Doctrine\ORM\Event\LifecycleEventArgs;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use w3des\AdminBundle\Entity\Node;
  10. use w3des\AdminBundle\Model\NodeView;
  11. use w3des\AdminBundle\Service\Nodes;
  12. use w3des\SmsBundle\Entity\SmsSubscribers;
  13. use Symfony\Contracts\Translation\TranslatorInterface;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Component\Messenger\MessageBusInterface;
  16. use w3des\SmsBundle\Message\SendSmsMessage;
  18. class NodeEventSubscriber implements EventSubscriber
  19. {
  20. private Nodes $nodes;
  21. private EntityManagerInterface $em;
  22. private SmsService $sms;
  23. private TranslatorInterface $translator;
  24. private LoggerInterface $logger;
  27. public function __construct(
  28. Nodes $nodes,
  29. EntityManagerInterface $em,
  30. MessageBusInterface $bus,
  31. TranslatorInterface $translator,
  32. LoggerInterface $logger
  33. ) {
  34. $this->nodes = $nodes;
  35. $this->em = $em;
  36. $this->bus = $bus;
  37. $this->translator = $translator;
  38. $this->logger = $logger;
  39. }
  41. public function getSubscribedEvents(): array
  42. {
  43. return [
  44. Events::postPersist,
  45. ];
  46. }
  48. public function postPersist(LifecycleEventArgs $args): void
  49. {
  50. $entity = $args->getObject();
  52. if (!$entity instanceof Node) {
  53. return;
  54. }
  56. if ($entity->getType() !== 'failures') {
  57. return;
  58. }
  60. $nodeView = new NodeView($this->nodes, $entity);
  61. $nodeView->_fetch();
  63. if (!isset($nodeView->vars)) {
  64. return;
  65. }
  67. $vars = $nodeView->vars;
  68. $sendSms = $vars->has('send_sms') ? (bool) $vars->send_sms : false;
  69. $smsBody = $vars->has('sms_content') ? trim((string) $vars->sms_content) : null;
  70. $city = $vars->has('city') ? $vars->city : [];
  72. if (!$sendSms) {
  73. return;
  74. }
  76. if (!$smsBody) {
  77. $this->logger->warning('send_sms checked but sms_content empty', [
  78. 'node' => $entity->getId(),
  79. ]);
  80. return;
  81. }
  83. $cities = is_array($city) ? $city : [$city];
  85. $subscribers = $this->em
  86. ->getRepository(SmsSubscribers::class)
  87. ->createQueryBuilder('s')
  88. ->where('s.active = true')
  89. ->andWhere('s.city IN (:cities)')
  90. ->setParameter('cities', $cities)
  91. ->getQuery()
  92. ->getResult();
  94. if (!$subscribers) {
  95. return;
  96. }
  98. foreach ($subscribers as $subscriber) {
  99. $this->bus->dispatch(
  100. new SendSmsMessage(
  101. $subscriber->getPhone(),
  102. $smsBody,
  103. $entity->getId(),
  104. $cities
  105. )
  106. );
  107. }
  108. }
  109. }