src/Controller/DigiEntityController.php line 34

Open in your IDE?
  1. <?php
  2. // src/Controller/DigiEntityController.php
  3. namespace App\Controller;
  5. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  7. use Symfony\Component\HttpFoundation\Request;
  8. use Symfony\Component\HttpFoundation\Response;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\Routing\Annotation\Route;
  12. use Doctrine\Persistence\ManagerRegistry;
  13. use Doctrine\ORM\EntityManagerInterface;
  15. use Symfony\Component\Validator\Validator\ValidatorInterface;
  17. use Symfony\Contracts\HttpClient\HttpClientInterface;
  18. use Symfony\Component\HttpClient\HttpOptions;
  20. use Symfony\Component\DependencyInjection\ContainerInterface;
  22. use App\Repository\EntityRepository;
  23. use App\Repository\DigiEntityRepository;
  25. /**
  26.  * @Route("/entity", name="entity_")
  27.  */
  28. abstract class DigiEntityController extends EntityController
  29. {
  30.     /** @var DigiEntityRepository $repository */
  31.     protected ?EntityRepository $repository;
  32.     protected HttpClientInterface $client;
  34.     public function __construct(ContainerInterface $container, EntityManagerInterface $em, HttpClientInterface $client)
  35.     {
  36.         parent::__construct($container, $em);
  37.         
  38.         $this->client = $client;
  39.         $this->repository::__setClient($client);
  40.     }
  41.     
  42.     /**
  43.     * @Route("/api/list", name="api_list")
  44.     */
  45.     public function APIListAction() :Response
  46.     {
  47.         $data = $this->repository->api_list();
  48.         //var_dump($api_response);
  49.         if (false) foreach($data as $row) {
  50.             var_dump($row);
  51.             echo '<hr />';
  52.             //json_encode($row);
  53.         }
  54.         
  55.         return new JsonResponse(['r'=>true, 'data'=>$data]);
  56.     }
  58.     /**
  59.     * @Route("/api/sync_all", name="api_sync_all")
  60.     */
  61.     public function APISyncAllAction(Request $request)
  62.     {
  63.         $options=[];
  64.         $options['fromlast'] = !empty($request->query->get('fromlast'));
  65.         $limit = $request->query->get('limit');
  66.         if (!is_numeric($limit) || (int)$limit != $limit || $limit<0)
  67.             $limit = $this->repository::API_SYNC_LIMIT;
  68.         $page = $request->query->get('page');
  69.         if (!is_numeric($page) || (int)$page != $page || $page<0)
  70.             $page = 0;
  71.         //var_dump($page, $limit); die();
  72.         
  73.         $data = $this->repository->api_sync_all($this->repository::API_QUERY_LIST, $limit, $page, $options);
  75.         return new JsonResponse(['r'=>true, 'data'=>$data]);
  76.     }
  77.     
  78.     /**
  79.     * @Route("/api/read", name="api_read")
  80.     */
  81.     public function APIReadAction(Request $request, int $digi_id=NULL) :Response
  82.     {
  83.         $digi_id = $request->query->get('digi_id');
  84.         $data = $this->repository->api_read($this->repository::API_QUERY_ID, $digi_id);
  86.         return new JsonResponse(['r'=>true, 'data'=>$data]);
  87.     }
  88.     
  89.     /**
  90.     * @Route("/api/sync", name="api_sync")
  91.     */
  92.     public function APISyncAction(Request $request, int $digi_id=NULL) :Response
  93.     {
  94.         $digi_id = $request->query->get('digi_id');
  95.         $data = $this->repository->api_sync($this->repository::API_QUERY_ID, $digi_id);
  96.         //var_dump($data); die();
  98.         return new JsonResponse(['r'=>true, 'data'=>$data]);
  99.     }
  100.     
  101.     /**
  102.     * @Route("/api/{id}/save", name="api_save")
  103.     */
  104.     public function APISaveAction(Request $request, int $id) :Response
  105.     {
  106.         //$id = $request->query->get('id');
  107.         //var_dump($id); die();
  109.         $data = $this->repository->api_save($this->repository::API_QUERY_SAVE, $id);
  110.         
  111.         return new JsonResponse(['r'=>true, 'redirect'=>$this->generateUrl(static::REF.'_read', ['id'=>$id]), 'data'=>$data]);
  112.     }
  113.     
  114.     /**
  115.     * @Route("/api/{id}/update", name="api_update")
  116.     */
  117.     public function APIUpdateAction(Request $request, int $id) :Response
  118.     {
  119.         $data = $this->repository->api_update($this->repository::API_QUERY_UPDATE, $id);
  121.         return new JsonResponse(['r'=>true, 'data'=>$data]);
  122.     }
  123.     
  124.     /**
  125.     * @Route("/api/delete", name="api_delete")
  126.     */
  127.     public function APIDeleteAction(Request $request, int $digi_id=NULL) :Response
  128.     {
  129.         $digi_id = $request->query->get('digi_id');
  130.         $data = $this->repository->api_delete($this->repository::API_QUERY_DELETE, $digi_id);
  132.         return new JsonResponse(['r'=>true, 'redirect'=>'', 'data'=>$data]);
  133.     }
  135.     /* PARAMS */
  136.     
  137.     public function params()
  138.     {
  139.         parent::params();
  141.         $this->params['api'] = [
  142.             'id' => $this->repository::API_ID,
  143.             'name' => $this->repository::API_NAME,
  144.             'map' => $this->repository::API_MAP,
  145.         ];
  146.         $this->params['route'] = array_merge($this->params['route'], [
  147.             'api_read' => static::REF.'_api_read',
  148.             'api_sync' => static::REF.'_api_sync',
  149.             'api_update' => static::REF.'_api_update',
  150.             'api_delete' => static::REF.'_api_delete',
  151.         ]);
  152.     }
  153. }