src/EventSubscriber/EasyAdminSubscriber.php line 50

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\ImportFile;
  6. use App\Entity\AggregatedTrueUp;
  7. use App\Entity\ManualPayment;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use Vich\UploaderBundle\Storage\StorageInterface;
  10. use EasyCorp\Bundle\EasyAdminBundle\Event\AfterEntityPersistedEvent;
  11. use EasyCorp\Bundle\EasyAdminBundle\Event\BeforeEntityPersistedEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class EasyAdminSubscriber implements EventSubscriberInterface
  15. {
  16.     public function __construct(
  17.         private EntityManagerInterface $em,
  18.         private StorageInterface $storage
  19.     )
  20.     {
  21.     }
  23.     public static function getSubscribedEvents()
  24.     {
  25.         return [
  26.            # BeforeEntityPersistedEvent::class => ['setManualPaymentAggregatedTrueUp'],
  27.             BeforeEntityPersistedEvent::class => ['prePersist'],
  28.             #AfterEntityPersistedEvent::class => ['prePersist']
  29.         ];
  30.     }
  32.     public function setManualPaymentAggregatedTrueUp(BeforeEntityPersistedEvent $event)
  33.         {
  34.             $entity = $event->getEntityInstance();
  35.             // easy admin only passed the entity to this event and not the original form data
  36.             if (!($entity instanceof ManualPayment)) {
  37.                 return;
  38.             }
  39.             if (isset($_POST['ManualPayment']['closeOutAggregatedTrueUp']) && ($_POST['ManualPayment']['closeOutAggregatedTrueUp'])) {
  40.                 $lookup = $this->em->getRepository(AggregatedTrueUp::class)->findOneBy([
  41.                     'user' => $entity->getUserPaymentPeriod()->getUser(),
  42.                     'amtInPennies' => $entity->getAmtInPennies(),
  43.                 ]);
  44.                 if (!$lookup) {
  45.                     throw new \Exception('this user has no aggregated true ups!');
  46.                 }
  47.                 $entity->setAggregatedTrueUp($lookup);
  48.             }
  49.         }
  50.     public function prePersist(BeforeEntityPersistedEvent $event): void
  51.     {
  52.         $entity = $event->getEntityInstance();
  54.         if (!$entity instanceof ImportFile) {
  55.             return;
  56.         }
  58.         $importFilePath = $entity->getUploadedFile()->getRealPath();
  59.         if ($importFilePath) {
  60.             $lineCount = 0;
  61.             $insideQuotes = false;
  63.             // Open the file in read mode
  64.             $handle = fopen($importFilePath, 'r');
  66.             // Loop through each character until end of file
  67.             while (!feof($handle)) {
  68.                 $char = fgetc($handle);
  70.                 // If it's a newline character and not inside quotes, increment line count
  71.                 if ($char === "\n" && !$insideQuotes) {
  72.                     $lineCount++;
  73.                 }
  75.                 // Toggle $insideQuotes when encountering a quote character
  76.                 if ($char === '"') {
  77.                     $insideQuotes = !$insideQuotes;
  78.                 }
  79.             }
  80.             fclose($handle);
  82.             // Set the total number of rows (excluding the header)
  83.             $entity->setTotal($lineCount - 1);
  85.             $this->em->persist($entity);
  86.             $this->em->flush();
  87.         }
  88.     }
  89. }