src/Controller/V1/SeatPlanController.php line 93

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace App\Controller\V1;
  6. use App\Entity\Local\Response\SeatPlanResponse;
  7. use App\Entity\Local\SeatPlanJson;
  8. use App\Entity\Vista\SeatPlan;
  9. use App\Manager\SeatPlanManager;
  10. use App\Repository\OrderRepositoryInterface;
  11. use FOS\RestBundle\Controller\Annotations as Rest;
  12. use FOS\RestBundle\Controller\Annotations\Route;
  13. use FOS\RestBundle\Controller\Annotations\View;
  14. use Nelmio\ApiDocBundle\Annotation\Model;
  15. use Swagger\Annotations as SWG;
  16. use Symfony\Component\HttpFoundation\Response;
  17. use Symfony\Component\HttpFoundation\Request;
  18. use App\Repository\SeatPlanRepository;
  19. use App\Repository\SeatPlanLocalRepository;
  20. use App\Repository\CinemaRepository;
  21. use App\Repository\LocationRepository;
  22. use App\Repository\SessionRepositoryInterface as SessionLocalRepository;
  23. use Symfony\Component\Serializer\SerializerInterface;
  25. /**
  26.  * @Route("/seat-plan")
  27.  * @SWG\Tag(name="Order_v1")
  28.  */
  29. class SeatPlanController
  30. {
  31.     /**
  32.      * @var SeatPlanManager
  33.      */
  34.     protected $seatPlanManager;
  36.     /**
  37.      * @var OrderRepositoryInterface
  38.      */
  39.     protected $orderRepository;
  41.     /** @var SeatPlanRepository */
  42.     protected $seatPlanRepository;
  44.     /** @var SeatPlanLocalRepository */
  45.     protected $seatPlanLocalRepository;
  47.     /** @var CinemaRepository */
  48.     protected $cinemaRepository;
  50.     /** @var LocationRepository */
  51.     protected $locationRepository;
  53.     /** @var SessionLocalRepository */
  54.     private $sessionLocalRepository;
  56.     /** @var SerializerInterface $serializer */
  57.     protected $serializer;
  59.     /**
  60.      * SeatPlanController constructor.
  61.      *
  62.      * @param SeatPlanManager          $seatPlanManager
  63.      * @param OrderRepositoryInterface $orderRepository
  64.      */
  65.     public function __construct(SeatPlanManager $seatPlanManager, OrderRepositoryInterface $orderRepository, SeatPlanRepository $seatPlanRepository,
  66.             SeatPlanLocalRepository $seatPlanLocalRepository, CinemaRepository $cinemaRepository, LocationRepository $locationRepository, SessionLocalRepository $sessionLocalRepository,
  67.             SerializerInterface $serializer) {
  68.         $this->seatPlanManager = $seatPlanManager;
  69.         $this->orderRepository = $orderRepository;
  70.         $this->seatPlanRepository = $seatPlanRepository;
  71.         $this->seatPlanLocalRepository = $seatPlanLocalRepository;
  72.         $this->cinemaRepository = $cinemaRepository;
  73.         $this->locationRepository = $locationRepository;
  74.         $this->sessionLocalRepository = $sessionLocalRepository;
  75.         $this->serializer = $serializer;
  76.     }
  78.     /**
  79.      * @Route("/{cinemaId}/{sessionId}", methods="GET")
  80.      * @Rest\QueryParam(name="orderId", allowBlank=true)
  81.      * @View()
  82.      *
  83.      * @SWG\Response(
  84.      *     response=200,
  85.      *     description="A seatPlan",
  86.      *     @Model(type=\App\Entity\Local\Response\SeatPlanResponse::class))
  87.      *
  88.      * @param string      $cinemaId
  89.      * @param string      $sessionId
  90.      * @param string|null $orderId
  91.      * @return object
  92.      */
  93.     public function getAction(string $cinemaId, string $sessionId, ?string $orderId = null) {
  94.         // http://10.15.20.177:8080/api/v1/seat-plan/1007/49019
  95.         // http://10.15.20.177:8080/api/v1/seat-plan/raw/processed/1007/1
  96.         $order = $orderId ? $this->orderRepository->findBySessionId($orderId) : null;
  97.         $selection = $order ? ($order->getSelection() ?: []) : [];
  98.         $result = $this->seatPlanManager->getSeatPlan($cinemaId, $sessionId, null);
  99.         // if($result->getRows() && $result->getRows()[0]->getSeats())error_log(sprintf("%s %s(%s) cinemaId $cinemaId sessionId $sessionId ", date('Y-m-d H:i:s'), __METHOD__, __LINE__) . var_export($result->getRows()[0]->getSeats()[0]->getPosition(), true));
  100.         $this->seatPlanManager->getNormalized($result->getRows(), null, $selection);
  101.         //$this->seatPlanManager->setColumnRender($result->getRows());
  102.         return $result;
  103.     }
  105.     /**
  106.      * @Route("/raw/{cinemaId}/{screenNumber}", methods="GET")
  107.      * @View()
  108.      *
  109.      * @SWG\Response(response=200,
  110.      *     description="Success")
  111.      *
  112.      * @param string      $cinemaId
  113.      * @param string      $screenNumber
  114.      * @return Response
  115.      */
  116.     public function getRaw(string $cinemaId, string $screenNumber) {
  117.         $session = $this->sessionLocalRepository->findByScreenNumber($cinemaId, $screenNumber);
  118.         $seatPlanOutput = '{}';
  119.         if ($session != null) {
  120.             $sessionId = $session['sessionId'];
  121.             $seatPlanInput = $this->seatPlanRepository->getSeatPlanRaw($cinemaId, $sessionId);
  122.             //error_log(sprintf("%s %s(%s) cinemaId $cinemaId screenNumber $screenNumber sessionId $sessionId ", date('Y-m-d H:i:s'), __METHOD__, __LINE__));
  124.             /** @var string $seatPlanExists */
  125.             $seatPlanExists = $this->seatPlanLocalRepository->findBy(['cinemaId' => $cinemaId, 'screenNumber' => $screenNumber]) != null ? "1" : "";
  126.             $seatPlanOutput = $this->seatPlanManager->processRaw($seatPlanInput, $cinemaId, $screenNumber, $seatPlanExists, $sessionId);
  127.         }
  128.         $response = new Response($seatPlanOutput);
  129.         $response->headers->set('Content-Type', 'application/json; charset=UTF-8');
  130.         return $response;
  131.     }
  133.     /**
  134.      * @Route("/raw/processed/{cinemaId}/{screenNumber}", methods="GET")
  135.      * @View()
  136.      *
  137.      * @SWG\Response(response=200,
  138.      *     description="Success")
  139.      *
  140.      * @param string      $cinemaId
  141.      * @param string      $screenNumber
  142.      * @return object
  143.      */
  144.     public function getRawProcessed(string $cinemaId, string $screenNumber) {
  146.         $seatPlanJson = $this->seatPlanLocalRepository->findOneBy(['cinemaId' => $cinemaId, 'screenNumber' => $screenNumber]);
  147.         $seatPlanInputObj = null;
  148.         $seatPlanOutput = null;
  149.         if ($seatPlanExists = $seatPlanJson ? "1" : "") {
  150.             $seatPlanInput = $seatPlanJson->getSeatPlanJson();
  151.             $seatPlanInputObj = json_decode($seatPlanInput);
  152.             $seatPlanInputObj->seatPlanSaved = '1';
  153.             //error_log(sprintf("%s %s(%s) ", date('Y-m-d H:i:s'), __METHOD__, __LINE__) . var_export($seatPlanInputObj, true));
  154.             foreach($seatPlanInputObj->rows as &$row) {
  155.                 if (isset($row->seats)) {
  156.                     foreach($row->seats as &$seat) {
  157.                         $seat->position->columnIndex = $seat->position->columnIndexRender;
  158.                     }
  159.                 }
  160.             }
  161.             $seatPlanOutput = json_encode($seatPlanInputObj);
  162.             //$response = new Response($seatPlanOutput);
  163.             //$response->headers->set('Content-Type', 'application/json; charset=UTF-8');
  164.             //return $response;
  165.         }
  166.         if (($session = $this->sessionLocalRepository->findByScreenNumber($cinemaId, $screenNumber)) != null || $seatPlanOutput) {
  167.             $sessionId = $session ? $session['sessionId'] : null;
  168.             $seatPlanInputObj = $this->seatPlanManager->getSeatPlan($cinemaId, $sessionId, $seatPlanOutput);
  169.                 $this->seatPlanManager->getNormalized($seatPlanInputObj->getRows(), null, []);
  170.             } else {
  171.                 $seatPlanInputObj = new SeatPlanResponse();
  172.             }
  173.             $seatPlanInputObj->setSeatPlanSaved($seatPlanExists);
  174.             return $seatPlanInputObj;
  175.         }
  177.     /**
  178.      * @Route("/edited/{cinemaId}/{screenNumber}", methods="GET")
  179.      * @View()
  180.      *
  181.      * @SWG\Response(
  182.      *     response=200,
  183.      *     description="A seatPlan",
  184.      *     @Model(type=\App\Entity\Local\SeatPlanJson::class))
  185.      *
  186.      * @param string      $cinemaId
  187.      * @param string      $screenNumber
  188.      * @return Response
  189.      */
  190.     public function getEdited(string $cinemaId, string $screenNumber) {
  191.         
  192.         $seatPlanJson = $this->seatPlanLocalRepository->findBy(['cinemaId' => $cinemaId, 'screenNumber' => $screenNumber]);
  194.         $seatPlanJson = $seatPlanJson ? $seatPlanJson[0]->getSeatPlanJson() : '{}';
  195.         $response = new Response($seatPlanJson);
  196.         $response->headers->set('Content-Type', 'application/json; charset=UTF-8');
  197.         return $response;
  198.     }
  199.     
  200.     /**
  201.      * @Route("/save/processed/{cinemaId}/{screenNumber}", methods="POST")
  202.      * @View()
  203.      *
  204.      * @SWG\Response(response=200,
  205.      *     description="Success")
  206.      *
  207.      *
  208.      * @param string      $cinemaId
  209.      * @param int         $screenNumber
  210.      * @param Request     $request
  211.      * @return Response
  212.      */
  213.     public function saveSeatPlan(string $cinemaId, int $screenNumber, Request $request) {
  214.         $seatPlanJsons = $this->seatPlanLocalRepository->findBy(['cinemaId' => $cinemaId, 'screenNumber' => $screenNumber]);
  215.         if ($seatPlanJsons == null) {
  216.             $seatPlanJson = new SeatPlanJson();
  217.             $seatPlanJson->setCinemaId($cinemaId);
  218.             $seatPlanJson->setScreenNumber($screenNumber);
  219.             $seatPlanJson->setCreatedAt(new \DateTimeImmutable());
  220.             $seatPlanJson->setModifiedAt(new \DateTimeImmutable());
  221.         } else {
  222.             $seatPlanJson = $seatPlanJsons[0];
  223.             $seatPlanJson->setModifiedAt(new \DateTimeImmutable());
  224.         }
  225.         $seatPlanInput = $request->request->get('seatPlan');
  226.         $responseJsonObj = json_decode($seatPlanInput);
  227.         foreach($responseJsonObj->rows as &$row) {
  228.             if (isset($row->seats)) {
  229.                 foreach($row->seats as &$seat) {
  230.                     $seat->position->columnIndexRender = $seat->position->columnIndex;
  231.                 }
  232.             }
  233.         }
  234.         $seatPlanOutput = json_encode($responseJsonObj);
  235.         $seatPlanJson->setSeatPlanJson($seatPlanOutput);
  236.         $this->seatPlanLocalRepository->save($seatPlanJson);
  238.         return new Response();
  239.     }
  241.     /**
  242.      * @Route("/delete/{cinemaId}/{screenNumber}", methods="DELETE")
  243.      * @View()
  244.      *
  245.      * @SWG\Response(response=200,
  246.      *     description="Success")
  247.      *
  248.      * @param string      $cinemaId
  249.      * @param int         $screenNumber
  250.      * @return Response
  251.      */
  252.     public function deleteSeatPlan(string $cinemaId, int $screenNumber) {
  254.         if ($seatPlanJsons = $this->seatPlanLocalRepository->findBy(['cinemaId' => $cinemaId, 'screenNumber' => $screenNumber])) {
  255.             $this->seatPlanLocalRepository->delete($seatPlanJsons[0]);
  256.         }
  258.         return new Response();
  259.     }
  261.     /**
  262.      * @Route("/cinemas", methods="GET")
  263.      * @View()
  264.      *
  265.      * @SWG\Response(response=200,
  266.      *     description="Success")
  267.      *
  268.      * @return Response
  269.      */
  270.     public function getSavedCinemas() {
  272.         $seatPlanCinemaIds = [];
  274.         $seatPlanCinemas = $this->seatPlanLocalRepository->getCinemasSaved();
  275.         foreach ($seatPlanCinemas as $seatPlanCinema) {
  276.             $seatPlanCinemaIds[$seatPlanCinema['cinemaId']] = null;
  277.         }
  278.         
  279.         $json = '';
  280.         if ($seatPlanCinemaIds) {
  281.             $filter = ['id' => $this->locationRepository->findLocationIds()];
  282.             $cinemas = $this->cinemaRepository->findBy($filter, ['name' => 'ASC']);
  283.             foreach ($cinemas as $cinema) {
  284.                 if (array_key_exists($cinema->getId(), $seatPlanCinemaIds)) {
  285.                     if ($json) { $json .= ','; }
  286.                     $json .= "{\"id\":\"{$cinema->getId()}\",\"name\":\"{$cinema->getName()}\"}";
  287.                 }
  288.             }
  289.         }
  290.         
  291.         //error_log(sprintf("%s %s(%s) ", date('Y-m-d H:i:s'), __METHOD__, __LINE__) . ' seatPlanCinemaIds ' . var_export($seatPlanCinemaIds, true) . ' cinemas ' . var_export($cinemas, true));
  293.         $response = new Response("[$json]");
  294.         $response->headers->set('Content-Type', 'application/json; charset=UTF-8');
  295.         return $response;
  296.     }
  298.     /**
  299.      * @Route("/cinemas/{cinemaId}/halls", methods="GET")
  300.      * @View()
  301.      *
  302.      * @SWG\Response(response=200,
  303.      *     description="Success")
  304.      *
  305.      * @param string      $cinemaId
  306.      * @return Response
  307.      */
  308.     public function getSavedCinemaHalls(string $cinemaId) {
  309.         $seatPlanCinemaHalls = $this->seatPlanLocalRepository->findBy(['cinemaId' => $cinemaId], ['screenNumber' => 'ASC']);
  310.         $json = '';
  311.         if ($seatPlanCinemaHalls) {
  312.             $screensAll = $this->sessionLocalRepository->findScreens($cinemaId);
  313.             $screens = [];
  314.             if ($screensAll) {
  315.                 foreach ($screensAll as $screen) {
  316.                     $screens[intval($screen['screenNumber'])] = $screen['screenName'];
  317.                 }
  318.             }
  319.             //error_log(sprintf("%s %s(%s) ", date('Y-m-d H:i:s'), __METHOD__, __LINE__) . ' screens ' . var_export($screens, true) . ' screensAll ' . var_export($screensAll, true));
  320.             foreach ($seatPlanCinemaHalls as $seatPlanCinemaHall) {
  321.                 if ($json) { $json .= ','; }
  322.                 $screenName = array_key_exists(intval($seatPlanCinemaHall->getScreenNumber()), $screens) ? $screens[intval($seatPlanCinemaHall->getScreenNumber())]: null;
  323.                 $json .= "{\"cinemaId\":\"{$seatPlanCinemaHall->getCinemaId()}\",\"screenNumber\":\"{$seatPlanCinemaHall->getScreenNumber()}\",\"screenName\":\"{$screenName}\"}";
  324.             }
  325.         }
  326.         $response = new Response("[$json]");
  327.         $response->headers->set('Content-Type', 'application/json; charset=UTF-8');
  328.         return $response;
  329.     }
  330. }