src/EventSubscriber/InvoiceSubscriber.php line 130

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\CheckInformation;
  6. use App\Entity\InvoiceReview;
  7. use App\Entity\InvoiceSupportTicket;
  8. use App\Entity\LatePaymentChargeLogs;
  9. use App\Entity\Municipality;
  10. use App\Entity\MunicipalityFeePeriod;
  11. use App\Entity\MunicipalityLateFees;
  12. use App\Entity\MunicipalityLateFeesPeriod;
  13. use App\Entity\RegistrationForm;
  14. use App\Entity\RenewalForm;
  15. use App\Entity\SupportTicket;
  16. use App\Entity\User;
  17. use App\Event\AppEvents;
  18. use App\Event\FormCreatedEvent;
  19. use App\Event\FormsDeletedEvent;
  20. use App\Event\Support\InvoiceEvent as InvoiceSupportEvent;
  21. use App\Event\InvoiceEvent;
  22. use App\Helper\PropertyHelper;
  23. use App\Repository\LatePaymentChargeLogsRepository;
  24. use App\ValueObject\MunicipalityLateFeesType;
  25. use App\ValueObject\SearchCriteria\MunicipalityFeeSearchCriteria;
  26. use App\ValueObject\InvoicePaymentTypes;
  27. use App\ValueObject\InvoiceStatuses;
  28. use Doctrine\ORM\EntityManagerInterface;
  29. use App\Entity\Form;
  30. use App\Entity\Invoice;
  31. use App\Entity\MunicipalityFee;
  32. use App\ValueObject\InvoiceTypes;
  33. use App\ValueObject\SearchCriteria\RenewalFormSearchCriteria;
  34. use App\Lib\EmailSenderInterface;
  35. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  37. /**
  38. * Class InvoiceListener
  39. */
  40. class InvoiceSubscriber implements EventSubscriberInterface
  41. {
  42. /**
  43. * @var EntityManagerInterface
  44. */
  45. private $em;
  47. /**
  48. * @var EmailSenderInterface
  49. */
  50. private $emailSender;
  51. private LatePaymentChargeLogsRepository $latePaymentChargeLogsRepository;
  53. public function __construct(
  54. EntityManagerInterface $entityManager,
  55. EmailSenderInterface $emailSender,
  56. LatePaymentChargeLogsRepository $latePaymentChargeLogsRepository
  57. )
  58. {
  59. $this->em = $entityManager;
  60. $this->emailSender = $emailSender;
  61. $this->latePaymentChargeLogsRepository = $latePaymentChargeLogsRepository;
  62. }
  64. /**
  65. * {@inheritdoc}
  66. */
  67. public static function getSubscribedEvents(): array
  68. {
  69. return [
  70. AppEvents::FORMS_DELETED => 'onFormsDeleted',
  71. AppEvents::INVOICE_CREATED => 'onInvoiceCreated',
  72. AppEvents::INVOICE_DISPUTE_CREATED => 'onDisputeCreated',
  73. AppEvents::FORM_CREATED => 'onFormCreated'
  74. ];
  75. }
  77. /**
  78. * @param FormsDeletedEvent $event
  79. */
  80. public function onFormsDeleted(FormsDeletedEvent $event): void
  81. {
  82. $formIds = $event->getForms();
  84. if (count($formIds)) {
  85. //Delete Invoices for the forms.
  86. $invoiceIds = $this->em->getRepository(Invoice::class)->deleteInIds($formIds);
  88. if (count($invoiceIds)) {
  89. //Delete Invoices Reviews.
  90. $this->em->getRepository(InvoiceReview::class)->deleteInIds($invoiceIds);
  91. //Delete Invoices Dispute and Support.
  92. $invoiceTicketIds = $this->em->getRepository(InvoiceSupportTicket::class)->getTicketsInIds($invoiceIds);
  94. if (count($invoiceTicketIds)) {
  95. $this->em->getRepository(SupportTicket::class)->deleteInIds($invoiceTicketIds);
  96. }
  97. }
  98. }
  99. }
  101. /**
  102. * @param InvoiceEvent $event
  103. */
  104. public function onInvoiceCreated(InvoiceEvent $event): void
  105. {
  106. $invoice = $event->getInvoice();
  107. /** @var Form $form */
  108. $form = $invoice->getForm();
  109. $form->setFeeAmount($invoice->getInvoiceAmount());
  110. $form->setDueAmount($invoice->getInvoiceAmount());
  112. $this->em->persist($form);
  113. $this->em->flush();
  114. }
  116. /**
  117. * @param InvoiceSupportEvent $event
  118. */
  119. public function onDisputeCreated(InvoiceSupportEvent $event): void
  120. {
  121. //Set Invoice In Dispute.
  122. $invoice = $event->getTicket()->getInvoice();
  124. $invoice->inDispute();
  125. $this->em->persist($invoice);
  127. $this->em->flush();
  128. }
  130. public function onFormCreated(FormCreatedEvent $event): void
  131. {
  133. // try {
  134. // UPDATE property p JOIN ( SELECT f.property_id, COUNT(*) AS totalRenewal FROM `renewal_form` rf INNER JOIN form f ON f.id = rf.id GROUP BY f.property_id ) rc ON p.id = rc.property_id SET p.renewal_number = rc.totalRenewal + 1;
  136. $checkInformation = $event->getCheckInformation();
  137. $usedPayByCheck = $event->getUsedPayByCheck();
  138. $form = $event->getForm();
  139. $property = $form->getProperty();
  140. $municipality = $property->getMunicipality();
  141. $lateFeesTriggerType = '';
  142. if ($event->getType() == InvoiceTypes::VPR_REGISTRATION) {
  143. $zone = $form->getZonesPropertyUse()[0];
  144. } elseif ($event->getType() == InvoiceTypes::VPR_RENEWAL) {
  145. $zone = $form->getProperty()->getZonesPropertyUse()->first();
  146. }
  148. $criteria = new MunicipalityFeeSearchCriteria();
  149. $criteria->industrialType = strtolower($zone ? $zone->getName() : '');
  150. $criteria->municipalityId = $municipality->getId();
  151. $municipalityFee = null;
  152. $municipalityFees = $this->em->getRepository(MunicipalityFee::class)->search($criteria);
  153. $municipalityFee = $municipalityFees[0];
  154. $amount = 0;
  155. $invoiceDate = new \DateTime('now');
  156. $dueDate = new \DateTime('now');
  157. $description = '';
  158. $nextRenewalNumber = $property->getRenewalNumber();
  160. if ($event->getType() == InvoiceTypes::VPR_REGISTRATION) {
  161. $dueDate = new \DateTime($property->getRegistrationDate() ? $property->getRegistrationDate()->format('Y-m-d H:i:s') : 'now'); // Y-m-d
  162. $amount = $municipalityFee->getRegistrationFee();
  163. $description = 'Registration Invoice for '.$property->getAddress().' registered on '.$invoiceDate->format('Y-m-d H:i:s');
  164. } elseif ($event->getType() == InvoiceTypes::VPR_RENEWAL) {
  165. // count past renewals
  166. $criteria = new RenewalFormSearchCriteria();
  167. $criteria->property = $property;
  168. $countRenewals = $this->em->getRepository(RenewalForm::class)->countByCriteria($criteria);
  170. if (count($municipalityFee->getPeriods()) && $countRenewals > 1) {
  171. // count total periods including base charge for renewal
  172. $feesIndex = $countRenewals - 1;
  173. $nextRenewalNumber = $countRenewals + 1;
  175. /** @var MunicipalityFee $municipalityFee*/
  176. $feesArray = [$municipalityFee->getRenewalBaseFee()];
  177. if (count($municipalityFee->getPeriods())) {
  178. foreach ($municipalityFee->getPeriods() as $period) {
  179. $feesArray[] = $period->getTotalFee();
  180. }
  181. }
  182. $type = '';
  183. switch ($municipalityFee->getPeriodFixedRecurrenceType()) {
  184. case 'year':
  185. $type = 'Y';
  186. break;
  187. case 'month':
  188. $type = 'M';
  189. break;
  190. case 'day':
  191. $type = 'D';
  192. break;
  193. }
  194. $invoiceDate = new \DateTime();
  195. $dueDate = new \DateTime();
  197. if ($type == 'Y') {
  198. $dueDate->modify('+'.PropertyHelper::DUE_YEAR_RENEW.' day');
  199. }
  200. else if ($type == 'M') {
  201. $dueDate->modify('+'.PropertyHelper::DUE_MONTH_RENEW.' day');
  202. }
  203. $renewalDate = $property->getRenewalDate() ? $property->getRenewalDate()->format('Y-m-d H:i:s') : (new \DateTime())->format('Y-m-d H:i:s');
  205. $description = 'Renewal Invoice for '.$property->getAddress().' registered on '.$renewalDate;
  206. if (array_key_exists($feesIndex, $feesArray)) {
  207. $amount = $feesArray[$feesIndex];
  208. } else {
  209. $amount = end($feesArray);
  210. }
  211. } else {
  212. $dueDate = new \DateTime($property->getRegistrationDate() ? $property->getRegistrationDate()->format('Y-m-d H:i:s') : 'now'); // Y-m-d
  213. $description = 'Renewal Invoice for '.$property->getAddress().' registered on '.$invoiceDate->format('Y-m-d H:i:s');
  214. $amount = $municipalityFee->getRenewalBaseFee();
  215. $nextRenewalNumber = $property->getRenewalNumber() + 1;
  216. }
  218. $municipalityLateFees = $this->em->getRepository(MunicipalityLateFees::class)->findOneBy(
  219. ['municipality' => $municipality->getId(), 'type' => MunicipalityLateFeesType::RENEWAL_TYPE]
  220. );
  221. $currentUser = $this->em->getRepository(User::class)->findOneBy(['email' => $form->getCreatedBy()]);
  223. if ($municipalityLateFees instanceof MunicipalityLateFees) {
  224. $lateFeesTriggerType = $municipalityLateFees->getFeesTriggerType();
  225. $lateFeesTriggerAfter = $municipalityLateFees->getFeesTriggerAfter();
  226. $nextRenewalDate = $property->getNextRenewalDate();
  227. $currentDate = new \DateTime();
  228. $dateDiff = $currentDate->diff($nextRenewalDate);
  229. $charge = '';
  230. $usersLatePaymentChargeLogsCount = count($this->latePaymentChargeLogsRepository->findBy(['user' => $currentUser, 'municipality' => $municipality]));
  231. $lateFeeBaseCharge = $municipalityLateFees->getFeesAmount();
  232. $lateChargesArray = [];
  233. $periods = $municipalityLateFees->getPeriods()->getValues();
  235. if (!empty($periods)) {
  237. /**@var MunicipalityLateFeesPeriod $period */
  238. foreach ($periods as $period) {
  239. $municipalityLateFeesId = $period->getMunicipalityLateFees()->getId();
  240. $lateChargesArray[(int) $municipalityLateFeesId][] = (float) $period->getTotalFee();
  241. }
  243. if (array_key_exists($municipalityLateFees->getId(), $lateChargesArray)) {
  244. array_unshift($lateChargesArray[$municipalityLateFees->getId()], $municipalityLateFees->getFeesAmount());
  245. }
  246. if ($usersLatePaymentChargeLogsCount == 0) {
  247. $charge = (float) $municipalityLateFees->getFeesAmount();
  248. } elseif (array_key_exists($municipalityLateFees->getId(), $lateChargesArray) && array_key_exists($usersLatePaymentChargeLogsCount, $lateChargesArray[$municipalityLateFees->getId()])) {
  249. $charge = $lateChargesArray[$municipalityLateFees->getId()][$usersLatePaymentChargeLogsCount];
  250. } else {
  251. $charge = end($lateChargesArray[$municipalityLateFees->getId()]);
  252. }
  253. }
  256. }
  257. }
  259. $property->setRenewalNumber($nextRenewalNumber);
  260. $this->em->persist($property);
  261. $this->em->flush();
  262. $totalAmount = $dueAmount = $amount;
  264. $invoice = new Invoice(
  265. $form->getRegistrant(),
  266. $event->getType(),
  267. $invoiceDate,
  268. $dueDate,
  269. $amount,
  270. );
  271. $invoice->setPaymentType(InvoicePaymentTypes::CREDIT_CARD);
  273. $invoice->setDescription($description);
  274. $invoice->setForm($form);
  275. if ($checkInformation instanceof CheckInformation) {
  276. $invoice->setCheckInformation($checkInformation);
  277. $checkAmount = $checkInformation->getAmount();
  278. if ($checkAmount >= $totalAmount) {
  279. $invoiceStatus = InvoiceStatuses::PAID;
  280. $dueAmount = 0;
  281. } else {
  282. $invoiceStatus = InvoiceStatuses::UNPAID;
  283. $dueAmount = $totalAmount - $checkAmount;
  284. }
  285. $invoice->setStatus($invoiceStatus);
  286. $invoice->setPaymentDate(new \DateTime());
  287. $invoice->setPaymentType(InvoicePaymentTypes::CHECK);
  288. $form->setPaidAmount($checkAmount);
  289. }
  291. if ($usedPayByCheck) {
  292. $invoice->setPaymentType(InvoicePaymentTypes::CHECK);
  293. }
  295. $this->em->persist($invoice);
  296. $this->em->flush();
  298. if ($lateFeesTriggerType == 'day') {
  299. $daysDiff = $dateDiff->days;
  300. if ($daysDiff >= $lateFeesTriggerAfter) {
  301. $this->generateLatePaymentLog($currentUser, $municipality, $invoice, $charge);
  302. }
  303. } else if ($lateFeesTriggerType == 'month') {
  304. $monthsDiff = $dateDiff->m;
  305. if ($monthsDiff >= $lateFeesTriggerAfter) {
  306. $this->generateLatePaymentLog($currentUser, $municipality, $invoice, $charge);
  307. }
  308. }
  310. if ($form instanceof RegistrationForm || $form instanceof RenewalForm) {
  311. $form->setFeeAmount($totalAmount);
  312. $form->setDueAmount($dueAmount);
  313. $this->em->persist($form);
  314. }
  315. $this->em->flush();
  316. }
  318. public function generateLatePaymentLog(User $user,Municipality $municipality,Invoice $invoice, $charge): void
  319. {
  320. $latePaymentChargeLog = $this->latePaymentChargeLogsRepository->findOneBy(['invoice' => $invoice]);
  321. if (!$latePaymentChargeLog instanceof LatePaymentChargeLogs) {
  322. $latePaymentChargeLog = new LatePaymentChargeLogs();
  323. $latePaymentChargeLog->setUser($user);
  324. $latePaymentChargeLog->setMunicipality($municipality);
  325. $latePaymentChargeLog->setInvoice($invoice);
  326. $latePaymentChargeLog->setMunicipalityLateFeesCharge($charge);
  327. $this->em->persist($latePaymentChargeLog);
  328. $this->em->flush();
  329. }
  330. }
  331. }