src/EventSubscriber/AnalyticsEventSubscriber.php line 34

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Core\EventListener\EventPriorities;
  6. use App\Entity\Veterinary\Analytic;
  7. use App\Entity\Veterinary\VeterinaryAnimalWeight;
  8. use App\Entity\Veterinary\VeterinaryCheckin;
  9. use App\Entity\Veterinary\VeterinaryClientUpdates;
  10. use App\Enumerators\AnalyticsClientType;
  11. use App\Enumerators\AnalyticsEventType;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Psr\Log\LoggerInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Symfony\Component\HttpKernel\Event\ViewEvent;
  17. use Symfony\Component\HttpKernel\KernelEvents;
  19. final class AnalyticsEventSubscriber implements EventSubscriberInterface {
  20.     private $entityManager;
  21.     private $logger;
  23.     public function __construct(EntityManagerInterface $entityManager, LoggerInterface $logger) {
  24.         $this->entityManager = $entityManager;
  25.         $this->logger = $logger;
  26.     }
  28.     public static function getSubscribedEvents() {
  29.         return [
  30.             KernelEvents::VIEW => ['storeUpdate', EventPriorities::POST_WRITE],
  31.         ];
  32.     }
  34.     public function storeUpdate(ViewEvent $event) {
  35.         $entity = $event->getControllerResult();
  36.         $request = $event->getRequest();
  37.         $method = $request->getMethod();
  39.         // Parse request content
  40.         $requestContent = $request->getContent();
  41.         if (empty($requestContent)) {
  42.             return;
  43.         }
  44.         $params = json_decode($requestContent);
  45.         if (empty($params->site)) {
  46.             return;
  47.         }
  48.         $analyticsEntry = new Analytic();
  49.         $analyticsEntry->site = $params->site;
  50.         if ($entity instanceof VeterinaryClientUpdates && $method == Request::METHOD_PUT) {
  51.             // Client update event
  52.             $analyticsEntry->eventType = AnalyticsEventType::DATAUPDATE;
  53.             $analyticsEntry->clientType = AnalyticsClientType::EXISTING_CLIENT;
  54.             $analyticsEntry->clinic = $entity->clinic->name;
  55.             $analyticsEntry->client = $entity->clientFirstName . ' ' . $entity->clientLastName;
  56.         } elseif ($entity instanceof VeterinaryCheckin && $method == Request::METHOD_POST) {
  57.             // Checkin event
  58.             $analyticsEntry->eventType = AnalyticsEventType::CHECKIN;
  59.             $analyticsEntry->clientType = AnalyticsClientType::EXISTING_CLIENT;
  60.             $analyticsEntry->clinic = $entity->clinic->name;
  61.             $analyticsEntry->client = $entity->clientFirstName . ' ' . $entity->clientLastName;
  62.             $analyticsEntry->animalKind = $entity->animalSpecies;
  63.             $analyticsEntry->animalBreed = $entity->animalBreed;
  64.             $analyticsEntry->checkinReason = $entity->getReason();
  66.         } elseif ($entity instanceof VeterinaryAnimalWeight && $method === Request::METHOD_POST) {
  67.             // Weight update event
  68.             $analyticsEntry->eventType = AnalyticsEventType::WEIGHTUPDATE;
  69.             $analyticsEntry->clientType = AnalyticsClientType::EXISTING_CLIENT;
  70.             $analyticsEntry->isWithAnimal = true;
  71.             $analyticsEntry->clinic = $entity->clinic->name;
  72.             $analyticsEntry->client = $entity->clientFirstName . ' ' . $entity->clientLastName;
  73.             $analyticsEntry->animalKind = $entity->animalSpecies;
  74.             $analyticsEntry->animalBreed = $entity->animalBreed;
  75.         } else {
  76.             return;
  77.         }
  78.         $this->entityManager->persist($analyticsEntry);
  79.         $this->entityManager->flush();
  80.     }
  81. }