src/Controller/GenericMateoMaticsController.php line 28

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Model\EwsNotificationModel;
  6. use DateTime;
  7. use Pimcore\Db;
  8. use App\Service\UserPermission;
  9. use Pimcore\Log\ApplicationLogger;
  10. use App\Service\MeteomaticApiService;
  11. use App\Service\MeteomaticsWeatherService;
  12. use App\Service\BassicAuthService;
  13. use App\Service\PublicUserPermissionService;
  14. use Pimcore\Controller\FrontendController;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Symfony\Component\HttpFoundation\Response;
  17. use Symfony\Component\Routing\Annotation\Route;
  18. use Symfony\Component\HttpFoundation\JsonResponse;
  19. use Symfony\Contracts\Translation\TranslatorInterface;
  20. use Lexik\Bundle\JWTAuthenticationBundle\Services\JWTTokenManagerInterface;
  21. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  23. /**
  24.  * Matches /blog exactly
  25.  *
  26.  * @Route("/api/ncm")
  27.  */
  28. class GenericMateoMaticsController extends FrontendController
  29. {
  30.     private $organizationModel;
  31.     private $userModel;
  32.     private $lang;
  33.     private $ewsNotificationModel;
  35.     public function __construct(
  36.         private TokenStorageInterface $tokenStorageInterface,
  37.         private JWTTokenManagerInterface $jwtManager,
  38.         private UserPermission $userPermission,
  39.         private PublicUserPermissionService $publicUserPermissionService,
  40.         protected TranslatorInterface $translator,
  41.         private ApplicationLogger $logger,
  42.         private MeteomaticApiService $meteomaticApiService,
  43.         private MeteomaticsWeatherService $meteomaticsWeatherService,
  44.         private BassicAuthService $bassicAuthService
  47.     ) {
  48.         header('Content-Type: application/json; charset=UTF-8');
  49.         header("Access-Control-Allow-Origin: *");
  50.         $this->meteomaticApiService = $meteomaticApiService;
  51.         $this->ewsNotificationModel = new EwsNotificationModel();
  52.         $this->publicUserPermissionService = $publicUserPermissionService;
  53.     }
  55.     /**
  56.      * @Route("/query", name="query", methods={"POST"})
  57.      */
  58.     public function fetchMeteomaticData(Request $request): JsonResponse
  59.     {
  60.         $params = json_decode($request->getContent(), true);
  61.         $this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
  63.         // check user credentials and expiry
  64.         $response = $this->publicUserPermissionService->isAuthorized($request, $this->translator);
  65.         if ($response['success'] !== true) {
  66.             return $this->json($response);
  67.         }
  69.         if (!isset($params['format'])) {
  70.             throw new \InvalidArgumentException('Missing "format" parameter');
  71.         }
  73.         if ($params['format'] == "json") {
  74.             if (
  75.                 !isset($params['startdate']) ||
  76.                 !isset($params['enddate']) ||
  77.                 !isset($params['resolution']) ||
  78.                 !isset($params['parameters']) ||
  79.                 !isset($params['lat']) ||
  80.                 !isset($params['lon']) ||
  81.                 !isset($params['format'])
  82.             ) {
  83.                 throw new \Exception('Missing required parameters');
  84.             }
  85.             // date_default_timezone_set('UTC');
  87.             //$hour = $params['hour'];
  88.             $format = $params['format'];
  89.             // $startDate = new DateTime($params['startdate']);
  90.             // $endDate = new DateTime($params['enddate']);
  91.             $startDate = $params['startdate'];
  92.             $endDate = $params['enddate'];
  93.             $resolution = $params['resolution'];
  94.             $parameters = $params['parameters'];
  95.             $model = $params['model'];
  96.             $lat = $params['lat'];
  97.             $lon = $params['lon'];
  100.             $response = $this->meteomaticApiService->timeSeriesQuery(
  101.                 $startDate,
  102.                 $endDate,
  103.                 $resolution,
  104.                 $parameters,
  105.                 $model,
  106.                 $lat,
  107.                 $lon,
  108.                 $format,
  109.                 $this->translator
  110.             );
  111.         } else {
  112.             $mandatoryParams = ['version', 'request', 'layers', 'crs', 'bbox', 'format', 'width', 'height', 'tiled'];
  113.             foreach ($mandatoryParams as $param) {
  114.                 if (!isset($params[$param]) || empty($params[$param])) {
  115.                     $missingParams[] = $param;
  116.                 }
  117.             }
  119.             if (!empty($missingParams)) {
  120.                 // Throw an exception with a message that includes the missing parameters
  121.                 $parameterList = implode(", ", $missingParams);
  122.                 throw new \InvalidArgumentException(sprintf($this->translator->trans("missing_or_empty_mandatory_parameter: %s"), $parameterList));
  123.             }
  125.             header('Content-Type: image/png');
  126.             $result = $this->meteomaticsWeatherService->getWeatherMap($params['version'], $params['request'], $params['layers'], $params['crs'], $params['bbox'], $params['format'], $params['width'], $params['height'], $params['tiled']);
  128.             echo $result;
  129.             exit;
  130.         }
  132.         // You can return or process the $data as needed
  133.         // For demonstration purposes, we will just return a JSON response
  134.         return $this->json($response);
  135.     }
  137.     /**
  138.      * @Route("/public-query", name="public_query", methods={"POST"})
  139.      */
  140.     public function publicMetarQuery(Request $request): JsonResponse
  141.     {
  142.         try {
  143.             $params = json_decode($request->getContent(), true);
  144.             $this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
  146.             //check user credentials and expiry
  147.             $response = $this->publicUserPermissionService->isAuthorized($request, $this->translator);
  149.             if ($response['success'] !== true) {
  150.                 return $this->json($response);
  151.             }
  153.             if (
  154.                 !isset($params['startdate']) ||
  155.                 !isset($params['enddate']) ||
  156.                 !isset($params['resolution']) ||
  157.                 !isset($params['parameters']) ||
  158.                 !isset($params['coordinate']) ||
  159.                 !isset($params['format'])
  160.             ) {
  161.                 throw new \Exception('Missing required parameters');
  162.             }
  163.             // date_default_timezone_set('UTC');
  165.             //$hour = $params['hour'];
  166.             $format = $params['format'];
  167.             $startDate = $params['startdate'];
  168.             $endDate = $params['enddate'];
  169.             $resolution = $params['resolution'];
  170.             $parametersArray = $params['parameters'];
  172.             $coordinate = $params['coordinate'];
  173.             $parameters = implode(',', $parametersArray);
  175.             $model = '';
  176.             if (isset($params['model']) && !empty($params['model'])) {
  177.                 $model = $params['model'];
  178.             }
  179.             $source = '';
  180.             if (isset($params['source']) && !empty($params['source'])) {
  181.                 $source = $params['source'];
  182.             }
  183.             $onInvalid = '';
  184.             if (isset($params['on_invalid']) && !empty($params['on_invalid'])) {
  185.                 $onInvalid = $params['on_invalid'];
  186.             }
  188.             // Convert dates to the desired format (assuming start time is 00:00:00 and end time is 23:59:59)
  189.             $startDate = new DateTime($params['startdate']);
  190.             $endDate = new DateTime($params['enddate']);
  192.             // $startDateStr = $startDate->format(DateTime::ISO8601);
  193.             // $endDateStr = $endDate->format(DateTime::ISO8601);
  195.             // $dateRange = $startDateStr . "--" . $endDateStr . ':' . $resolution;
  196.             $response = $this->meteomaticApiService->publicRouteQuery(
  197.                 $startDate,
  198.                 $endDate,
  199.                 $resolution,
  200.                 $parametersArray,
  201.                 $coordinate,
  202.                 $format,
  203.                 $model,
  204.                 $source,
  205.                 $onInvalid,
  207.             );
  208.             // You can return or process the $data as needed
  209.             // For demonstration purposes, we will just return a JSON response
  210.             return $this->json($response);
  211.         } catch (\Exception $ex) {
  212.             $this->logger->error($ex->getMessage());
  213.             return $this->json(['success' => false, 'message' => $ex->getMessage()]);
  214.         }
  215.     }
  217.     /**
  218.      * @Route("/industry/query", name="industry_query", methods={"POST"})
  219.      */
  220.     public function fetchIndustryMeteomaticData(Request $request): JsonResponse
  221.     {
  222.         try {
  223.             $params = json_decode($request->getContent(), true);
  224.             $this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
  226.             // check user credentials and expiry
  227.             $response = $this->publicUserPermissionService->isAuthorized($request, $this->translator);
  228.             if ($response['success'] !== true) {
  229.                 return $this->json($response);
  230.             }
  232.             $user = $response['user'];
  234.             // Varify user allowed permissions
  235.             $reslult = $this->publicUserPermissionService->publicUserPermissionCheck($user, $params['parameters'], $this->translator);
  236.             if ($reslult['success'] !== true) {
  237.                 return $this->json($reslult);
  238.             }
  240.             if (!isset($params['format'])) {
  241.                 throw new \InvalidArgumentException('Missing "format" parameter');
  242.             }
  244.             if ($params['format'] == "json") {
  245.                 if (
  246.                     !isset($params['startdate']) ||
  247.                     !isset($params['enddate']) ||
  248.                     !isset($params['resolution']) ||
  249.                     !isset($params['parameters']) ||
  250.                     !isset($params['lat']) ||
  251.                     !isset($params['lon']) ||
  252.                     !isset($params['format'])
  253.                 ) {
  254.                     throw new \Exception('Missing required parameters');
  255.                 }
  256.                 // date_default_timezone_set('UTC');
  258.                 //$hour = $params['hour'];
  259.                 $format = $params['format'];
  260.                 $startDate = new DateTime($params['startdate']);
  261.                 $endDate = new DateTime($params['enddate']);
  262.                 $resolution = $params['resolution'];
  263.                 $parameters = $params['parameters'];
  264.                 $model = $params['model'];
  265.                 $lat = $params['lat'];
  266.                 $lon = $params['lon'];
  269.                 $response = $this->meteomaticApiService->timeSeriesQuery(
  270.                     $startDate,
  271.                     $endDate,
  272.                     $resolution,
  273.                     $parameters,
  274.                     $model,
  275.                     $lat,
  276.                     $lon,
  277.                     $format,
  278.                     $this->translator
  279.                 );
  280.             } else {
  281.                 $mandatoryParams = ['version', 'request', 'layers', 'crs', 'bbox', 'format', 'width', 'height', 'tiled'];
  282.                 foreach ($mandatoryParams as $param) {
  283.                     if (!isset($params[$param]) || empty($params[$param])) {
  284.                         $missingParams[] = $param;
  285.                     }
  286.                 }
  288.                 if (!empty($missingParams)) {
  289.                     // Throw an exception with a message that includes the missing parameters
  290.                     $parameterList = implode(", ", $missingParams);
  291.                     throw new \InvalidArgumentException(sprintf($this->translator->trans("missing_or_empty_mandatory_parameter: %s"), $parameterList));
  292.                 }
  294.                 header('Content-Type: image/png');
  295.                 $result = $this->meteomaticsWeatherService->getWeatherMap($params['version'], $params['request'], $params['layers'], $params['crs'], $params['bbox'], $params['format'], $params['width'], $params['height'], $params['tiled']);
  297.                 echo $result;
  298.                 exit;
  299.             }
  301.             // You can return or process the $data as needed
  302.             // For demonstration purposes, we will just return a JSON response
  303.             return $this->json($response);
  304.         } catch (\Exception $ex) {
  305.             $this->logger->error($ex->getMessage());
  306.             return $this->json(['success' => false, 'message' => $ex->getMessage()]);
  307.         }
  308.     }
  310.     /**
  311.      * @Route("/governorate", methods={"GET"})
  312.      */
  313.     public function getGovernorateAction(Request $request)
  314.     {
  315.         try {
  317.             // check user credentials and expiry
  318.             $response = $this->publicUserPermissionService->isAuthorized($request, $this->translator);
  319.             if ($response['success'] !== true) {
  320.                 return $this->json($response);
  321.             }
  323.             $result = $this->ewsNotificationModel->getGovernorates();
  325.             return $this->json($result);
  326.         } catch (\Exception $ex) {
  327.             $this->logger->error($ex->getMessage());
  328.             return $this->json(['success' => false, 'message' => $ex->getMessage()]);
  329.         }
  330.     }
  332.     /**
  333.      * @Route("/municipality", methods={"GET"})
  334.      */
  335.     public function getMunicipalityAction(Request $request)
  336.     {
  337.         try {
  339.             // check user credentials and expiry
  340.             $response = $this->publicUserPermissionService->isAuthorized($request, $this->translator);
  341.             if ($response['success'] !== true) {
  342.                 return $this->json($response);
  343.             }
  345.             $result = $this->ewsNotificationModel->getMunicipality();
  347.             return $this->json($result);
  348.         } catch (\Exception $ex) {
  349.             $this->logger->error($ex->getMessage());
  350.             return $this->json(['success' => false, 'message' => $ex->getMessage()]);
  351.         }
  352.     }
  353. }