src/EventSubscriber/ForoEventSubscriber.php line 34

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Aviso;
  6. use App\Enum\TipoAvisoEnum;
  7. use App\Interfaces\AvisoRepositoryInterface;
  8. use App\Interfaces\PropietarioContenidoRepositoryInterface;
  9. use App\Services\AsymmetricEncryptionService;
  10. use App\Services\EventDomain\ForoChangedEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  13. use Symfony\Component\Translation\Translator;
  15. class ForoEventSubscriber implements EventSubscriberInterface
  16. {
  17. public function __construct(
  18. private AsymmetricEncryptionService $asymmetricEncryptionService,
  19. private PropietarioContenidoRepositoryInterface $propietarioContenidoRepository,
  20. private AvisoRepositoryInterface $avisoRepository,
  21. private Translator $translator,
  22. private UrlGeneratorInterface $urlGenerator,
  23. )
  24. {
  25. }
  27. public static function getSubscribedEvents()
  28. {
  29. return [
  30. ForoChangedEvent::class => 'onChangedForo',
  31. ];
  32. }
  34. public function onChangedForo(ForoChangedEvent $event): void
  35. {
  36. $mensaje = $event->getMensajeForo();
  37. $tema = $event->getMensajeForo()->getTema();
  38. $propietariosForo = $this->propietarioContenidoRepository->getPropietariosByTema($tema);
  39. $propietariosAvisos = $this->avisoRepository->getPropietariosByObjectDeleted($tema);
  41. $propietarios = array_diff($propietariosForo, $propietariosAvisos, [$mensaje->getPropietarioContenido()]);
  43. //Obtener avisos
  44. foreach ($propietarios as $propietario) {
  45. $avisosPropietario = $this->avisoRepository->getAvisosForoByPropietarioTema($propietario, $tema);
  47. $i = 0;
  48. $aviso = new Aviso();
  49. foreach ($avisosPropietario as $avisoPropietario)
  50. {
  51. if($i !== 0)
  52. {
  53. $this->avisoRepository->delete($avisoPropietario, true);
  54. }
  55. else
  56. {
  57. $aviso = $avisoPropietario;
  58. }
  60. $i++;
  61. }
  63. $aviso->setTipo(TipoAvisoEnum::AVISO_FORO);
  64. $aviso->setFecha($mensaje->getCreatedAt());
  65. $aviso->setAsunto($this->translator->trans('new.ads.foro', ['%tema%' => $tema], 'ads'));
  66. $aviso->setPropietarioContenido($propietario);
  67. $aviso->setObject($mensaje);
  68. $aviso->setTema($tema);
  69. $aviso->setDeletedAt(null);
  71. $token = $this->asymmetricEncryptionService->hybridEncrypt([
  72. 'tipoAviso' => TipoAvisoEnum::AVISO_FORO,
  73. 'propietarioId' => $aviso->getPropietarioContenido()?->getId(),
  74. 'url' => $this->urlGenerator->generate('mensaje_foro_list', ['id' => $tema->getId()], UrlGeneratorInterface::ABSOLUTE_URL),
  75. ]);
  77. $aviso->setTokenHash($token);
  79. $this->avisoRepository->save($aviso);
  80. }
  81. }
  82. }