src/EventSubscriber/CustomApiUtsListener.php line 29

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Ucs;
  6. use App\Entity\Uts;
  7. use App\EventSubscriber\Events\ApiEvent;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use App\EventSubscriber\Events\ApiEvents;
  10. use Symfony\Component\Serializer\Serializer;
  11. use Symfony\Component\HttpFoundation\JsonResponse;
  12. use Symfony\Component\Serializer\SerializerInterface;
  13. use Symfony\Component\EventDispatcher\Attribute\AsEventListener;
  14. use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
  15. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  17. final class CustomApiUtsListener
  18. {
  19.     private $serializer;
  20.     private $em;
  22.     public function __construct(SerializerInterface $serializer, EntityManagerInterface $em)
  23.     {
  24.         $this->serializer = $serializer;
  25.         $this->em = $em;
  26.     }
  28.     #[AsEventListener(event: ApiEvents::GET_UTS_BY_CODE)]
  29.     public function onGetUtsByCode(ApiEvent $event)
  30.     {
  31.         $request = $event->getRequest();
  32.         $uts_availables = $event->getData()[2];
  34.         if($request->query->has('ucs')) {
  35.           $ucs = $this->em->getRepository(Ucs::class)->find($request->query->get('ucs'));
  36.           // find surface for each UTS
  37.           foreach ($uts_availables as $u) {
  38.               $u->surface = $this->getSurfacePercentage($u, $ucs);
  39.           }
  40.           // order by surface
  41.           usort($uts_availables, function($a, $b) {return $a->surface < $b->surface;});
  42.           // get biggest surface
  43.           $uts = $uts_availables[0];
  45.           // build response
  46.           $response = new JsonResponse([
  47.             'uts' => $this->serializer->normalize($uts, 'json', ['groups' => 'api'])
  48.           ]);
  49.           // send response
  50.           $event->setResponse($response);
  51.         }
  53.     }
  55.     private function getSurfacePercentage(Uts $uts, Ucs $ucs)
  56.     {
  57.         $sql = "SELECT pourcent FROM bzh_cor_ucs_uts WHERE no_ucs = '".$ucs->getId()."' AND no_uts = '".$uts->getId()."';";
  58.         $stmt = $this->em->getConnection()->prepare($sql);
  59.         $query = $stmt->executeQuery();
  60.         $result = $query->fetch();
  61.         return $result['pourcent'] ?? null;
  62.     }
  64.         #[AsEventListener(event: ApiEvents::GET_UTS_BY_DEFAULT)]
  65.     public function onGetUtsByDefault(ApiEvent $event)
  66.     {
  67.         $data = $event->getData();
  68.         $ucs = $data[0];
  69.         $childrenUts = $data[3];
  71.         // here we request a default utt from current ucs & position in the branch
  72.         // we do that by calling SQL getuttmaj()
  73.         try {
  74.           // build json
  75.           $json = json_encode([
  76.             'ucs' => $ucs->getId(),
  77.             'uts' => array_map(function($u) { return $u['id']; }, $childrenUts)
  78.           ]);
  79.           // call sql fn
  80.           $sql = "select bzh.getuttmaj('$json')";
  81.           $stmt = $this->em->getConnection()->prepare($sql);
  82.           $query = $stmt->executeQuery();
  83.           $res = $query->fetch();
  84.           // get utt id
  85.           $utt = $res['getuttmaj'];
  86.           $id = json_decode($utt)->utt;
  87.           // find uts in db
  88.           $uts = $this->em->getRepository(Uts::class)->find($id);
  89.         }
  90.         catch(\Exception $e) {
  91.           throw new BadRequestHttpException("Error while retrieving default Uts... (".$e->getMessage()." at line ".$e->getLine().")");
  92.         }
  94.         // build response
  95.         $response = new JsonResponse([
  96.             'uts' => $this->serializer->normalize($uts, 'json', ['groups' => 'api'])
  97.         ]);
  98.         // send response
  99.         $event->setResponse($response);
  101.     }
  104. }