src/EventSubscriber/ReviewSubscriber.php line 263

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Organization;
  6. use App\Helper\CustomFieldHelper;
  7. use App\Model\Builder\InspectionFormBuilder;
  8. use App\Model\Builder\RegistrationFormBuilder;
  9. use App\Event\AppEvents;
  10. use App\Event\FormCreatedEvent;
  11. use App\Event\FormEvent;
  12. use App\Event\Municipality\FeeEvent;
  13. use App\Event\Review\FeeEvent as ReviewFeeEvent;
  14. use App\Event\Review\FormEvent as ReviewFormEvent;
  15. use App\Event\Municipality\MunicipalityEvent;
  16. use App\Event\OrganizationEvent;
  17. use App\Event\Review\NotifyReviewEvent;
  18. use App\Event\Review\UserEvent;
  19. use App\Event\ReviewEvent;
  20. use App\Entity\RegistrationForm as EntityRegistrationForm;
  21. use App\Helper\PropertyHelper;
  22. use App\Model\Parser\ReviewDeregistrationForm;
  23. use App\Model\Parser\ReviewInspection;
  24. use App\Model\Parser\ReviewInvoice;
  25. use App\Model\Parser\ReviewMunicipality;
  26. use App\Model\Parser\ReviewMunicipalityFee;
  27. use App\Model\Parser\ReviewOrganization;
  28. use App\Model\Parser\ReviewProperty;
  29. use App\Model\Parser\ReviewRegistrationForm;
  30. use App\Model\Parser\ReviewRenewalForm;
  31. use App\Model\Parser\ReviewUser;
  32. use App\ValueObject\UserRoles;
  33. use Doctrine\ORM\EntityManagerInterface;
  34. use App\Entity\DeregistrationForm;
  35. use App\Entity\DeregistrationFormReview;
  36. use App\Entity\InspectionForm;
  37. use App\Entity\InspectionFormReview;
  38. use App\Entity\InvoiceReview;
  39. use App\Entity\MunicipalityFeeReview;
  40. use App\Entity\MunicipalityReview;
  41. use App\Entity\OrganizationReview;
  42. use App\Entity\PropertyReview;
  43. use App\Entity\RegistrationForm;
  44. use App\Entity\RegistrationFormReview;
  45. use App\Entity\RenewalForm;
  46. use App\Entity\RenewalFormReview;
  47. use App\Entity\User;
  48. use App\Entity\UserReview;
  49. use App\ValueObject\InvoiceTypes;
  50. use App\ValueObject\ReviewStatuses;
  51. use App\ValueObject\UserTypes;
  52. use App\ValueObject\FormTypes;
  53. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  54. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  55. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  57. /**
  58. * Class ReviewListener
  59. */
  60. class ReviewSubscriber implements EventSubscriberInterface
  61. {
  62. const ADMIN_REVIEW = true;
  64. /**
  65. * @var EntityManagerInterface
  66. */
  67. private $em;
  69. /**
  70. * @var CustomFieldHelper
  71. */
  72. protected $customFieldHelper;
  74. /**
  75. * @var TokenStorageInterface
  76. */
  77. private $tokenStorage;
  79. /**
  80. * @var EventDispatcherInterface
  81. */
  82. private $eventDispatcher;
  84. /**
  85. * @var PropertyHelper
  86. */
  87. private $propertyHelper;
  89. /**
  90. * ReviewListener constructor.
  91. *
  92. * @param EntityManagerInterface $em
  93. * @param CustomFieldHelper $customFieldHelper
  94. * @param TokenStorageInterface $tokenStorage
  95. * @param EventDispatcherInterface $eventDispatcher
  96. * @param PropertyHelper $propertyHelper
  97. */
  98. public function __construct(
  99. EntityManagerInterface $em,
  100. CustomFieldHelper $customFieldHelper,
  101. TokenStorageInterface $tokenStorage,
  102. EventDispatcherInterface $eventDispatcher,
  103. PropertyHelper $propertyHelper
  104. ) {
  105. $this->em = $em;
  106. $this->customFieldHelper = $customFieldHelper;
  107. $this->tokenStorage = $tokenStorage;
  108. $this->eventDispatcher = $eventDispatcher;
  109. $this->propertyHelper = $propertyHelper;
  110. }
  112. /**
  113. * {@inheritdoc}
  114. */
  115. public static function getSubscribedEvents(): array
  116. {
  117. return [
  118. AppEvents::REVIEW_USER_CREATED => ['onUserCreated'],
  119. AppEvents::REVIEW_APPROVED => ['onReviewApproved'],
  120. AppEvents::REVIEW_DENIED => ['onReviewDenied'],
  121. AppEvents::REVIEW_INSPECTION_CREATED => ['onInspectionCreated'],
  122. AppEvents::REVIEW_MUNICIPALITY_CREATED => ['onMunicipalityCreated'],
  123. AppEvents::REVIEW_MUNICIPALITY_FEE_CREATED => ['onMunicipalityFeeCreated'],
  124. AppEvents::REVIEW_ORGANIZATION_CREATED => ['onOrganizationCreated'],
  125. AppEvents::REVIEW_REGISTRATION_FORM_CREATED => ['onRegistrationFormCreated'],
  126. AppEvents::REVIEW_RENEWAL_FORM_CREATED => ['onRenewalFormCreated'],
  127. AppEvents::REVIEW_DEREGISTRATION_FORM_CREATED => ['onDeregistrationFormCreated']
  128. ];
  129. }
  131. /**
  132. * @param UserEvent $event
  133. */
  134. public function onUserCreated(UserEvent $event): void
  135. {
  136. $currentUser = $this->getCurrentUser();
  137. $user = $event->getUser();
  139. if ($user->getType() === UserTypes::REGISTER_PARTY) {
  140. $userReview = new UserReview($user, [], ReviewStatuses::PENDING, $currentUser);
  142. $this->em->persist($userReview);
  143. $this->em->flush();
  144. }
  145. }
  147. /**
  148. * @param OrganizationEvent $event
  149. */
  150. public function onOrganizationCreated(OrganizationEvent $event): void
  151. {
  152. $currentUser = $this->getCurrentUser();
  153. $organization = $event->getOrganization();
  155. $organizationReview = new OrganizationReview($organization, [], ReviewStatuses::PENDING, self::ADMIN_REVIEW, $currentUser);
  157. $this->em->persist($organizationReview);
  158. $this->em->flush();
  159. }
  161. /**
  162. * @param ReviewFormEvent $event
  163. */
  164. public function onInspectionCreated(ReviewFormEvent $event): void
  165. {
  166. $currentUser = $this->getCurrentUser();
  167. /** @var InspectionForm $inspection */
  168. $inspection = $event->getForm();
  170. if ($currentUser->hasRole($currentUser, UserRoles::ROLE_ADMIN_MUNICIPAL) || $currentUser->hasRole($currentUser, UserRoles::ROLE_MUNICIPAL)) {
  171. $defaultOrg = $this->em->getRepository(Organization::class)->findOneBy(['name' => 'A -- PLEASE SELECT IF NON-REGISTERING ORGANIZATION']);
  172. $inspection->setRegistrant($defaultOrg);
  173. }
  175. $this->em->persist($inspection);
  176. $this->em->flush();
  177. $inspection->setStatus(ReviewStatuses::PENDING);
  178. $needAdmin = $event->getNeedAdmin();
  180. $inspectionReview = new InspectionFormReview($inspection, [], ReviewStatuses::PENDING, $needAdmin, $currentUser);
  182. $this->em->persist($inspectionReview);
  183. $this->em->persist($inspection);
  184. $this->em->flush();
  185. }
  187. /**
  188. * @param ReviewFormEvent $event
  189. */
  190. public function onRegistrationFormCreated(ReviewFormEvent $event): void
  191. {
  192. $currentUser = $this->getCurrentUser();
  193. /** @var RegistrationForm $form */
  194. $form = $event->getForm();
  195. $form->setStatus(ReviewStatuses::PENDING);
  196. $builder = $event->getBuilder();
  197. $customFields = json_encode($builder->customFields);
  198. $needAdmin = $event->getNeedAdmin();
  199. $formReview = new RegistrationFormReview($form, [], ReviewStatuses::PENDING, $needAdmin, $currentUser, $customFields);
  200. if ($event->getPayByCheck()) {
  201. $this->addPayByCheckToFormReview($formReview);
  202. }
  203. $formReview->setForm($form);
  204. $this->em->persist($form);
  205. $this->em->persist($formReview);
  206. $this->em->flush();
  208. }
  210. /**
  211. * @param ReviewFormEvent $event
  212. */
  213. public function onDeregistrationFormCreated(ReviewFormEvent $event): void
  214. {
  215. $currentUser = $this->getCurrentUser();
  216. /** @var DeregistrationForm $form */
  217. $form = $event->getForm();
  218. $form->setStatus(ReviewStatuses::PENDING);
  219. $builder = $event->getBuilder();
  220. $customFields = json_encode($builder->customFields);
  221. $needAdmin = $event->getNeedAdmin();
  223. $formReview = new DeregistrationFormReview($form, [], ReviewStatuses::PENDING, $needAdmin, $currentUser, $customFields);
  224. $formReview->setForm($form);
  225. $this->em->persist($formReview);
  226. $this->em->persist($form);
  227. $this->em->flush();
  228. }
  230. /**
  231. * @param ReviewFormEvent $event
  232. */
  233. public function onRenewalFormCreated(ReviewFormEvent $event): void
  234. {
  235. $currentUser = $this->getCurrentUser();
  236. /** @var RenewalForm $form */
  237. $form = $event->getForm();
  238. $form->setStatus(ReviewStatuses::PENDING);
  239. $needAdmin = $event->getNeedAdmin();
  240. $builder = $event->getBuilder();
  241. $customFields = json_encode($builder->customFields);
  242. $formReview = new RenewalFormReview($form, [], ReviewStatuses::PENDING, $needAdmin, $currentUser, $customFields);
  243. if ($event->getPayByCheck()) {
  244. $this->addPayByCheckToFormReview($formReview);
  245. }
  246. $formReview->setForm($form);
  247. $this->em->persist($formReview);
  248. $this->em->persist($form);
  249. $this->em->flush();
  250. }
  251. public function addPayByCheckToFormReview($formReview): void
  252. {
  253. $customFields = $formReview->getCustomFields();
  254. $customFieldsData = json_decode($customFields, true);
  255. $customFieldsData['pay_by_check'] = true;
  256. $customFieldsData = json_encode($customFieldsData);
  257. $formReview->setCustomFields($customFieldsData);
  258. }
  260. /**
  261. * @param MunicipalityEvent $event
  262. */
  263. public function onMunicipalityCreated(MunicipalityEvent $event): void
  264. {
  265. $currentUser = $this->getCurrentUser();
  266. $municipality = $event->getMunicipality();
  268. $municipalityReview = new MunicipalityReview($municipality, [], ReviewStatuses::PENDING, $currentUser, self::ADMIN_REVIEW);
  270. $this->em->persist($municipalityReview);
  271. $this->em->flush();
  272. }
  274. /**
  275. * @param ReviewFeeEvent $event
  276. */
  277. public function onMunicipalityFeeCreated(ReviewFeeEvent $event): void
  278. {
  279. $currentUser = $this->getCurrentUser();
  280. $fee = $event->getFee();
  282. $feeReview = new MunicipalityFeeReview($fee, [], ReviewStatuses::PENDING, self::ADMIN_REVIEW, $currentUser);
  284. $this->em->persist($feeReview);
  285. $this->em->flush();
  286. }
  288. /**
  289. * @param ReviewEvent $event
  290. */
  291. public function onReviewApproved(ReviewEvent $event): void
  292. {
  293. $entity = null;
  294. $eventType = null;
  295. $newEntityEvent = null;
  296. $review = $event->getReview();
  297. $usedPayByCheckInRegistrationAndRenewal = false;
  299. if ($review instanceof UserReview) {
  300. $entity = ReviewUser::parse($review, $review->getUser());
  302. if ($review->getType() == UserTypes::REGISTER_PARTY
  303. && $review->getReviewCreator() == null
  304. ) {
  305. //registered user.
  306. $eventType = AppEvents::USER_REGISTRATION_APPROVED;
  307. $newEntityEvent = new UserEvent($entity);
  308. }
  309. }
  311. if ($review instanceof MunicipalityReview) {
  312. $entity = ReviewMunicipality::parse($review, $review->getMunicipality());
  314. if ($review->getMunicipality() == null) {
  315. //Is a new Municipality.
  316. $eventType = AppEvents::MUNICIPALITY_CREATED;
  317. $newEntityEvent = new MunicipalityEvent($entity);
  318. }
  319. }
  321. if ($review instanceof OrganizationReview) {
  322. $entity = ReviewOrganization::parse($review, $review->getOrganization());
  323. }
  325. if ($review instanceof InspectionFormReview) {
  326. $entity = ReviewInspection::parse($review, $review->getForm());
  327. $entity->setStatus(ReviewStatuses::APPROVED);
  328. $eventType = AppEvents::INSPECTION_FORM_CREATED;
  329. $newEntityEvent = new FormEvent($entity);
  330. // if ($review->getForm() !== null) $review->setForm(null);
  331. //
  332. // if ($review->getForm() == null) {
  333. // //Is a new Inspection
  334. // $eventType = AppEvents::INSPECTION_FORM_CREATED;
  335. // $newEntityEvent = new FormEvent($entity);
  336. // }
  337. }
  339. if ($review instanceof PropertyReview) {
  340. $entity = ReviewProperty::parse($review, $review->getProperty());
  341. }
  343. if ($review instanceof MunicipalityFeeReview) {
  344. $entity = ReviewMunicipalityFee::parse($review, $review->getMunicipalityFee());
  346. if ($review->getMunicipalityFee() == null) {
  347. //Is a new MunicipalityFee.
  348. $eventType = AppEvents::MUNICIPALITY_FEE_CREATED;
  349. } else {
  350. $eventType = AppEvents::MUNICIPALITY_FEE_UPDATED;
  351. }
  353. $newEntityEvent = new FeeEvent($entity);
  354. }
  356. if ($review instanceof InvoiceReview) {
  357. $entity = ReviewInvoice::parse($review, $review->getInvoice());
  358. }
  360. if ($review instanceof RegistrationFormReview) {
  361. $entity = ReviewRegistrationForm::parse($review, $review->getForm(), true);
  362. if ($review->getForm() !== null) $review->setForm(null);
  363. $reviewCustomFields = json_decode($review->getCustomFields(), true);
  364. $usedPayByCheckInRegistrationAndRenewal = array_key_exists('pay_by_check', $reviewCustomFields) ? $reviewCustomFields['pay_by_check'] : false;
  365. $property = $entity->getProperty();
  366. $registrationForm = new EntityRegistrationForm($property);
  367. $customFields = $this->customFieldHelper->getCustomFields($property->getMunicipality(), FormTypes::REGISTRATION);
  368. $builder = RegistrationFormBuilder::fromEntity($registrationForm, $customFields);
  369. $builder->customFields = json_decode($review->getCustomFields(), true);
  371. $entity->setStartDate(new \DateTime(PropertyHelper::DELAY_FOR_INVOICE));
  372. if ($this->propertyHelper->getNextRenewalDate($entity->getProperty()))
  373. $entity->setEndDate($this->propertyHelper->getNextRenewalDate($entity->getProperty()));
  375. if ($review->getForm() == null) {
  376. $eventType = AppEvents::REGISTRATION_FORM_CREATED;
  377. $invoiceEvent = new FormCreatedEvent($entity, InvoiceTypes::VPR_REGISTRATION, null, $usedPayByCheckInRegistrationAndRenewal);
  378. } else {
  379. $eventType = AppEvents::REGISTRATION_FORM_UPDATED;
  380. }
  381. $newEntityEvent = new FormEvent($entity);
  382. }
  384. if ($review instanceof RenewalFormReview) {
  385. $entity = ReviewRenewalForm::parse($review, $review->getForm(), true);
  386. $reviewCustomFields = json_decode($review->getCustomFields(), true);
  387. $usedPayByCheckInRegistrationAndRenewal = array_key_exists('pay_by_check', $reviewCustomFields) ? $reviewCustomFields['pay_by_check'] : false;
  388. if ($review->getForm() !== null) $review->setForm(null);
  389. $entity->setStartDate(new \DateTime(PropertyHelper::DELAY_FOR_INVOICE));
  390. $entity->setEndDate($this->propertyHelper->getNextRenewalDate($entity->getProperty()));
  392. if ($review->getForm() == null) {
  393. $eventType = AppEvents::RENEWAL_FORM_CREATED;
  394. $invoiceEvent = new FormCreatedEvent($entity, InvoiceTypes::VPR_RENEWAL, null, $usedPayByCheckInRegistrationAndRenewal);
  395. } else {
  396. $eventType = AppEvents::RENEWAL_FORM_UPDATED;
  397. }
  399. //TODO handle custom fields.
  400. $newEntityEvent = new FormEvent($entity);
  401. }
  403. if ($review instanceof DeregistrationFormReview) {
  404. $entity = ReviewDeregistrationForm::parse($review, $review->getForm(), true);
  405. if ($review->getForm() !== null) $review->setForm(null);
  407. if ($review->getForm() == null) {
  408. $eventType = AppEvents::DEREGISTRATION_FORM_CREATED;
  409. } else {
  410. $eventType = AppEvents::DEREGISTRATION_FORM_UPDATED;
  411. }
  413. //TODO handle custom fields.
  414. $newEntityEvent = new FormEvent($entity);
  415. }
  417. if ($entity) {
  418. $this->em->persist($entity);
  419. $this->em->flush();
  421. if ($review instanceof RegistrationFormReview) {
  422. $this->customFieldHelper->saveFormCustomFields($entity, FormTypes::REGISTRATION, $builder);
  423. }
  426. if ($newEntityEvent) {
  427. $this->eventDispatcher->dispatch($newEntityEvent, $eventType);
  428. }
  429. }
  431. if(isset($invoiceEvent)) {
  432. $this->eventDispatcher->dispatch($invoiceEvent, AppEvents::FORM_CREATED);
  434. //TODO PAYMENT
  435. }
  436. }
  437. /**
  438. * @param ReviewEvent $event
  439. */
  440. public function onReviewDenied(ReviewEvent $event): void
  441. {
  442. $review = $event->getReview();
  443. $reason = $event->getReason();
  444. if (!empty($event->getReview()->getForm())) {
  445. $form = $event->getReview()->getForm();
  446. $form->setStatus(ReviewStatuses::DECLINED);
  447. $this->em->persist($form);
  448. $this->em->flush();
  449. }
  450. // if ($review->notifyUser()) {
  451. $event = new NotifyReviewEvent($review, [], $reason);
  452. $this->eventDispatcher->dispatch($event, AppEvents::REVIEW_NOTIFY_DENIED);
  453. // }
  454. }
  456. /**
  457. * @return User|null
  458. */
  459. protected function getCurrentUser(): ?User
  460. {
  461. $currentUser = null;
  462. if ($this->tokenStorage->getToken()
  463. && $this->tokenStorage->getToken()->getUser() instanceof User
  464. ) {
  465. $currentUser = $this->tokenStorage->getToken()->getUser();
  466. }
  468. return $currentUser;
  469. }
  470. }