src/EventSubscriber/NotificationSubscriber.php line 246

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\EmailNotifications;
  6. use App\Event\AppEvents;
  7. use App\Event\FormEvent;
  8. use App\Event\PropertyEvent;
  9. use App\Entity\Form;
  10. use App\Entity\Property;
  11. use App\Entity\RenewalForm;
  12. use App\Entity\User;
  13. use App\Entity\UserNotification;
  14. use App\Lib\NotificationEmailSender;
  15. use App\ValueObject\UserNotificationTypes;
  16. use App\ValueObject\UserTypes;
  17. use App\Lib\EmailSenderInterface;
  18. use Doctrine\ORM\EntityManagerInterface;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. /**
  22. * Class NotificationListener
  23. */
  24. class NotificationSubscriber implements EventSubscriberInterface
  25. {
  26. const bool ENABLED = true;
  27. const string FORM_NOTIFICATION = 'form_notification';
  28. /**
  29. * @var EmailSenderInterface
  30. */
  31. private $emailSender;
  33. /**
  34. * @var EntityManagerInterface
  35. */
  36. private $entityManager;
  37. private NotificationEmailSender $notificationEmailSender;
  39. /**
  40. * NotificationSubscriber constructor.
  41. *
  42. * @param EmailSenderInterface $emailSender
  43. * @param EntityManagerInterface $entityManager
  44. */
  45. public function __construct(
  46. EmailSenderInterface $emailSender,
  47. EntityManagerInterface $entityManager,
  48. NotificationEmailSender $notificationEmailSender
  49. ) {
  50. $this->emailSender = $emailSender;
  51. $this->entityManager = $entityManager;
  52. $this->notificationEmailSender = $notificationEmailSender;
  53. }
  55. /**
  56. * {@inheritdoc}
  57. */
  58. public static function getSubscribedEvents(): array
  59. {
  60. return [
  61. AppEvents::PROPERTY_CREATED => 'onPropertyCreated',
  62. AppEvents::REGISTRATION_FORM_CREATED => 'onRegistrationFormCreated',
  63. AppEvents::DEREGISTRATION_FORM_CREATED => 'onDeregistrationFormCreated',
  64. AppEvents::RENEWAL_FORM_CREATED => 'onRenewalCreated',
  65. AppEvents::RENEWAL_FORM_DUE => 'onRenewalFormDue',
  66. AppEvents::RENEWAL_FORM_UPCOMING => 'onRenewalFormUpcoming'
  67. ];
  68. }
  70. /**
  71. * @param PropertyEvent $event
  72. */
  73. public function onPropertyCreated(PropertyEvent $event): void
  74. {
  75. $property = $event->getProperty();
  76. $viewName = 'Notification/candidate_notification.html.twig';
  78. $notifications = $this->entityManager->getRepository(UserNotification::class)->findBy([
  79. 'type' => UserNotificationTypes::NEW_CANDIDATES,
  80. 'value' => self::ENABLED
  81. ]);
  83. $emailNotification = $this->getEmailNotification(UserNotificationTypes::NEW_CANDIDATES);
  85. foreach ($notifications as $notification) {
  86. /** @var UserNotification $notification */
  87. $user = $notification->getUser();
  88. if ($this->shouldNotifyRegister($user, $property))
  89. {
  90. $address = $this->getPropertyFullAddress($property);
  91. $parameters = [];
  92. $parameters['##userName##'] = $user->getFullname();
  93. $parameters['##address##'] = $address;
  94. $this->notificationEmailSender->sendNotificationMail($emailNotification, $user, $parameters);
  95. // $this->notifyRegister($property, $user, $viewName, 'New Candidate Property');
  96. }
  97. }
  98. }
  100. /**
  101. * @param FormEvent $event
  102. */
  103. public function onRegistrationFormCreated(FormEvent $event): void
  104. {
  105. $form = $event->getForm();
  106. $property = $form->getProperty();
  107. $superAdmins = $this->getSuperAdmins();
  108. $registeredUser = null;
  109. if (!empty($form->getCreatedBy())) {
  110. $registeredUser = $this->entityManager->getRepository(User::class)->findOneByEmail($form->getCreatedBy());
  111. }
  112. $notifications = $this->entityManager->getRepository(UserNotification::class)->findBy([
  113. 'type' => UserNotificationTypes::REGISTRATIONS,
  114. 'value' => self::ENABLED
  115. ]);
  116. $emailNotification = $this->getEmailNotification();
  118. foreach ($notifications as $notification) {
  119. /** @var UserNotification $notification */
  120. $user = $notification->getUser();
  121. if ($this->shouldNotifyMunicipal($user, $property))
  122. {
  123. $address = $this->getPropertyFullAddress($property);
  124. $parameters = [];
  125. $parameters['##userName##'] = $user->getFullname();
  126. $parameters['##address##'] = $address;
  127. $parameters['##subject##'] = "Notification For ".ucfirst(UserNotificationTypes::REGISTRATIONS);
  128. $parameters['##formType##'] = ucfirst(UserNotificationTypes::REGISTRATIONS);
  129. $this->notificationEmailSender->sendNotificationMail($emailNotification, $user, $parameters);
  131. // $this->notifyMunicipalSuperAdminAndRegistrant($form, 'Registration', $user);
  132. }
  133. }
  134. $this->notifySuperAdminAndRegistrant($form, $superAdmins, ucfirst(UserNotificationTypes::REGISTRATIONS), $registeredUser, $emailNotification);
  135. }
  137. /**
  138. * @param FormEvent $event
  139. */
  140. public function onDeregistrationFormCreated(FormEvent $event): void
  141. {
  142. $form = $event->getForm();
  143. $property = $form->getProperty();
  144. $superAdmins = $this->getSuperAdmins();
  145. $registeredUser = null;
  147. if (!empty($form->getCreatedBy())) {
  148. $registeredUser = $this->entityManager->getRepository(User::class)->findOneByEmail($form->getCreatedBy());
  149. }
  151. $notifications = $this->entityManager->getRepository(UserNotification::class)->findBy([
  152. 'type' => UserNotificationTypes::DEREGISTRATIONS,
  153. 'value' => self::ENABLED
  154. ]);
  155. $emailNotification = $this->getEmailNotification();
  157. foreach ($notifications as $notification) {
  158. /** @var UserNotification $notification */
  159. $user = $notification->getUser();
  160. if ($this->shouldNotifyMunicipal($user, $property))
  161. {
  162. $address = $this->getPropertyFullAddress($property);
  163. $parameters = [];
  164. $parameters['##userName##'] = $user->getFullname();
  165. $parameters['##address##'] = $address;
  166. $parameters['##subject##'] = "Notification For ".ucfirst(UserNotificationTypes::DEREGISTRATIONS);
  167. $parameters['##formType##'] = ucfirst(UserNotificationTypes::DEREGISTRATIONS);
  168. $this->notificationEmailSender->sendNotificationMail($emailNotification, $user, $parameters);
  170. // $this->notifyMunicipalSuperAdminAndRegistrant($form, 'Deregistration', $user);
  171. }
  172. }
  173. $this->notifySuperAdminAndRegistrant($form, $superAdmins, ucfirst(UserNotificationTypes::DEREGISTRATIONS), $registeredUser, $emailNotification);
  174. }
  176. /**
  177. * @param FormEvent $event
  178. */
  179. public function onRenewalCreated(FormEvent $event): void
  180. {
  181. $form = $event->getForm();
  182. $property = $form->getProperty();
  183. $superAdmins = $this->getSuperAdmins();
  184. $registeredUser = null;
  185. if (!empty($form->getCreatedBy())) {
  186. $registeredUser = $this->entityManager->getRepository(User::class)->findOneByEmail($form->getCreatedBy());
  187. }
  189. $notifications = $this->entityManager->getRepository(UserNotification::class)->findBy([
  190. 'type' => UserNotificationTypes::RENEWALS,
  191. 'value' => self::ENABLED
  192. ]);
  193. $emailNotification = $this->getEmailNotification();
  195. foreach ($notifications as $notification) {
  196. /** @var UserNotification $notification */
  197. $user = $notification->getUser();
  198. if ($this->shouldNotifyMunicipal($user, $property))
  199. {
  200. $address = $this->getPropertyFullAddress($property);
  201. $parameters = [];
  202. $parameters['##userName##'] = $user->getFullname();
  203. $parameters['##address##'] = $address;
  204. $parameters['##subject##'] = "Notification For ".ucfirst(UserNotificationTypes::RENEWALS);
  205. $parameters['##formType##'] = ucfirst(UserNotificationTypes::RENEWALS);
  206. $this->notificationEmailSender->sendNotificationMail($emailNotification, $user, $parameters);
  208. // $this->notifyMunicipalSuperAdminAndRegistrant($form, 'Renewal', $user);
  209. }
  210. }
  211. $this->notifySuperAdminAndRegistrant($form, $superAdmins, ucfirst(UserNotificationTypes::RENEWALS), $registeredUser, $emailNotification);
  212. }
  214. /**
  215. * @param FormEvent $event
  216. */
  217. public function onRenewalFormUpcoming(FormEvent $event): void
  218. {
  219. /** @var RenewalForm $form */
  220. $form = $event->getForm();
  221. $property = $form->getProperty();
  222. $viewName = 'Notification/upcoming_renewal_notification.html.twig';
  224. $notifications = $this->entityManager->getRepository(UserNotification::class)->findBy([
  225. 'type' => UserNotificationTypes::UPCOMING_RENEWALS,
  226. 'value' => self::ENABLED
  227. ]);
  228. $emailNotification = $this->getEmailNotification(UserNotificationTypes::UPCOMING_RENEWALS);
  229. foreach ($notifications as $notification) {
  230. /** @var UserNotification $notification */
  231. $user = $notification->getUser();
  232. if ($this->shouldNotifyUpcomingRenewal($user, $form))
  233. {
  234. $address = $this->getPropertyFullAddress($property);
  235. $parameters = [];
  236. $parameters['##userName##'] = $user->getFullname();
  237. $parameters['##address##'] = $address;
  238. $this->notificationEmailSender->sendNotificationMail($emailNotification, $user, $parameters);
  239. }
  240. }
  241. }
  243. /**
  244. * @param FormEvent $event
  245. */
  246. public function onRenewalFormDue(FormEvent $event): void
  247. {
  248. /** @var RenewalForm $form */
  249. $form = $event->getForm();
  250. $viewName = 'Notification/due_renewal_notification.html.twig';
  251. $property = $form->getProperty();
  253. $notifications = $this->entityManager->getRepository(UserNotification::class)->findBy([
  254. 'type' => UserNotificationTypes::DUE_RENEWALS,
  255. 'value' => self::ENABLED
  256. ]);
  257. $emailNotification = $this->getEmailNotification(UserNotificationTypes::DUE_RENEWALS);
  259. foreach ($notifications as $notification) {
  260. /** @var UserNotification $notification */
  261. $user = $notification->getUser();
  262. if ($this->shouldNotifyDueRenewal($user, $form))
  263. {
  264. $address = $this->getPropertyFullAddress($property);
  265. $parameters = [];
  266. $parameters['##userName##'] = $user->getFullname();
  267. $parameters['##address##'] = $address;
  268. $this->notificationEmailSender->sendNotificationMail($emailNotification, $user, $parameters);
  269. // $this->notifyRegister($form->getProperty(), $user, $viewName, 'Due Renewal');
  270. }
  271. }
  272. }
  274. /**
  275. * @param User $user
  276. * @param Property $property
  277. *
  278. * @return bool
  279. */
  280. private function shouldNotifyMunicipal(User $user, Property $property): bool
  281. {
  282. if ($user->getType() === UserTypes::MUNICIPALITY) {
  283. return ($property->getMunicipality() === $user->getMunicipality());
  284. }
  286. return false;
  287. }
  289. /**
  290. * @param User $user
  291. * @param Property $property
  292. *
  293. * @return bool
  294. */
  295. private function shouldNotifyRegister(User $user, Property $property): bool
  296. {
  297. if ($user->getType() === UserTypes::REGISTER_PARTY) {
  298. $isOwner = ($property->getRegistrant() === $user->getOrganization());
  299. $requireRegistration = ($property->getRegistrationDate() == null);
  301. return ($isOwner && $requireRegistration);
  302. }
  304. return false;
  305. }
  307. /**
  308. * @param User $user
  309. * @param RenewalForm $renewal
  310. *
  311. * @return bool
  312. */
  313. private function shouldNotifyUpcomingRenewal(User $user, RenewalForm $renewal): bool
  314. {
  315. if ($user->getType() === UserTypes::REGISTER_PARTY) {
  316. return ($renewal->getRegistrant() === $user->getOrganization());
  317. }
  319. return false;
  320. }
  322. /**
  323. * @param User $user
  324. * @param RenewalForm $renewal
  325. *
  326. * @return bool
  327. */
  328. private function shouldNotifyDueRenewal(User $user, RenewalForm $renewal): bool
  329. {
  330. if ($user->getType() === UserTypes::REGISTER_PARTY) {
  331. $isOwner = ($renewal->getRegistrant() === $user->getOrganization());;
  333. return ($isOwner && $renewal->hasDue());
  334. }
  336. return false;
  337. }
  339. // /**
  340. // * @param Form $form
  341. // * @param $formType
  342. // * @param User $user
  343. // */
  344. // private function notifyMunicipalSuperAdminAndRegistrant(Form $form, $formType, User $user)
  345. // {
  346. // $viewName = 'Notification/form_notification.html.twig';
  347. // $subject = 'Notification for '.$formType;
  348. // $parameters = [
  349. // 'property' => $form->getProperty(),
  350. // 'user' => $user,
  351. // 'formType' => $formType
  352. // ];
  353. //
  354. // $this->emailSender->sendEmail($viewName, $parameters, $subject, $user->getEmail());
  355. // }
  357. /**
  358. * @param Property $property
  359. * @param $viewName
  360. * @param User $user
  361. * @param $subject
  362. */
  363. private function notifyRegister(Property $property, User $user, $viewName, $subject): void
  364. {
  365. $parameters = [
  366. 'property' => $property,
  367. 'user' => $user,
  368. ];
  370. $this->emailSender->sendEmail($viewName, $parameters, $subject, $user->getEmail());
  371. }
  373. public function getSuperAdmins(): array
  374. {
  375. return $this->entityManager->getRepository(User::class)->findBy(['isSuperAdmin' => true, 'isVerified' => true]);
  376. }
  378. public function getEmailNotification($type = null)
  379. {
  380. return $this->entityManager->getRepository(EmailNotifications::class)->findOneBy([
  381. 'notificationType' => $type != null ? $type : self::FORM_NOTIFICATION
  382. ]);
  383. }
  385. public function getPropertyFullAddress(Property $property): string
  386. {
  387. $address = $property->getAddress();
  388. $address .= $property->getZipCode() ? ', '.$property->getZipCode() : '';
  389. $address .= $property->getCity() ? ', '.$property->getCity() : '';
  390. $address .= $property->getState() ? ', '.$property->getState() : '';
  392. return $address;
  393. }
  395. public function notifySuperAdminAndRegistrant($form, array $superAdmins, $type, ?User $registrant = null, ?EmailNotifications $emailNotification = null): void
  396. {
  397. $property = $form->getProperty();
  398. $address = $this->getPropertyFullAddress($property);
  399. $parameters = [];
  400. $parameters['##address##'] = $address;
  401. $parameters['##formType##'] = ucfirst($type);
  402. $parameters['##subject##'] = "Notification For ".ucfirst($type);
  404. foreach ($superAdmins as $superAdmin) {
  405. if ($superAdmin !== $registrant) {
  406. continue;
  407. }
  408. $parameters['##userName##'] = $superAdmin->getFullname();
  409. $this->notificationEmailSender->sendNotificationMail($emailNotification, $superAdmin, $parameters);
  410. // $this->notifyMunicipalSuperAdminAndRegistrant($form, $type, $superAdmin);
  411. }
  412. $parameters['##userName##'] = $registrant->getFullname();
  413. $this->notificationEmailSender->sendNotificationMail($emailNotification, $registrant, $parameters);
  414. }
  415. }