Symfony Profiler

<?php
namespace App\Controller;
use DateTime;
use Carbon\Carbon;
use Knp\Snappy\Pdf;
use App\Model\UserModel;
use Pimcore\Model\Asset;
use App\Service\RedisCache;
use App\Model\ReportLogModel;
use App\Service\EmailService;
use App\Service\ReportService;
use App\Service\UserPermission;
use App\Model\OrganizationModel;
use Pimcore\Log\ApplicationLogger;
use App\Service\NotificationService;
use Pimcore\Model\DataObject\Report;
use Pimcore\Model\DataObject\ReportType;
use Pimcore\Model\DataObject\Customer;
use PhpOffice\PhpSpreadsheet\Spreadsheet;
use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
use PhpOffice\PhpSpreadsheet\Style\Fill;
use PhpOffice\PhpSpreadsheet\Style\Alignment;
use App\Service\MeteomaticsWeatherService;
use App\Service\MarineReportService;
use Pimcore\Controller\FrontendController;
use Knp\Component\Pager\PaginatorInterface;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\Annotation\Route;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Contracts\Translation\TranslatorInterface;
use Symfony\Component\HttpFoundation\ResponseHeaderBag;
use Symfony\Component\Security\Core\User\UserInterface;
use Symfony\Component\HttpFoundation\BinaryFileResponse;
use Lexik\Bundle\JWTAuthenticationBundle\Services\JWTTokenManagerInterface;
use Pimcore\Model\DataObject\EwsNotification;
use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
use App\Model\EwsNotificationModel;
use Symfony\Contracts\HttpClient\HttpClientInterface;
/**
* Matches
*
* @Route("/api/ncm/report")
*/
class ReportController extends FrontendController
{
private $organizationModel;
private $userModel;
private $lang;
private $reportModel;
public function __construct(
private TokenStorageInterface $tokenStorageInterface,
private JWTTokenManagerInterface $jwtManager,
private UserPermission $userPermission,
protected TranslatorInterface $translator,
private ApplicationLogger $logger,
private RedisCache $redisCache,
private MeteomaticsWeatherService $meteomaticsWeatherService,
private Pdf $snappy,
private ReportService $reportService,
private NotificationService $notificationService,
private EmailService $emailService,
private HttpClientInterface $httpClient,
private MarineReportService $marineReportService
) {
$this->reportModel = new ReportLogModel();
// header('Content-Type: application/json; charset=UTF-8');
//header("Access-Control-Allow-Origin: *");
}
/**
* @Route("/weather_forecast_report", name="api_ncm_report_weather_forecast_report", methods={"POST"})
*/
public function weatherForecastReport(Request $request, UserInterface $user): JsonResponse
{
$response = [];
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['format'])) {
throw new \InvalidArgumentException('Missing "format" parameter');
}
if ($params['format'] == "json") {
if (
!isset($params['startdate']) ||
!isset($params['enddate']) ||
!isset($params['resolution']) ||
!isset($params['parameters']) ||
!isset($params['lat']) ||
!isset($params['lon']) ||
!isset($params['format'])
) {
throw new \Exception('Missing required parameters');
}
//$hour = $params['hour'];
$format = $params['format'];
$startDate = $params['startdate'];
$endDate = $params['enddate'];
$resolution = $params['resolution'];
$parameters = $params['parameters'];
$model = $params['model'];
$lat = $params['lat'];
$lon = $params['lon'];
$response = $this->reportService->getWeatherForecastReport(
$startDate,
$endDate,
$resolution,
$parameters,
$model,
$lat,
$lon,
$format,
$this->translator
);
}
return $this->json($response);
}
/**
* @Route("/special_report", name="api_ncm_report_special_report", methods={"POST"})
*/
public function specialReport(Request $request, UserInterface $user): JsonResponse
{
$response = [];
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['format'])) {
throw new \InvalidArgumentException('Missing "format" parameter');
}
if ($params['format'] == "json") {
if (
!isset($params['startdate']) ||
!isset($params['enddate']) ||
!isset($params['resolution']) ||
!isset($params['parameters']) ||
!isset($params['lat']) ||
!isset($params['lon']) ||
!isset($params['format'])
) {
throw new \Exception('Missing required parameters');
}
//$hour = $params['hour'];
$format = $params['format'];
$startDate = $params['startdate'];
$endDate = $params['enddate'];
$resolution = $params['resolution'];
$parameters = $params['parameters'];
$model = $params['model'];
$lat = $params['lat'];
$lon = $params['lon'];
$response = $this->reportService->getSpecialReport(
$startDate,
$endDate,
$resolution,
$parameters,
$model,
$lat,
$lon,
$format,
$this->translator
);
}
return $this->json($response);
}
/**
* @Route("/save_data", name="api_ncm_report_save_data", methods={"POST"})
*/
public function saveData(Request $request, UserInterface $user): JsonResponse
{
$response = [];
try {
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (
!isset($params['startdate']) ||
!isset($params['enddate']) ||
!isset($params['lat']) ||
!isset($params['lon']) ||
!isset($params['type_of_report']) ||
!isset($params['key']) ||
!isset($params['data'])
) {
throw new \Exception('Missing required parameters');
}
$startDate = $params['startdate'];
$endDate = $params['enddate'];
$typeOfReport = $params['type_of_report'];
$key = $params['key'];
$lat = $params['lat'];
$lon = $params['lon'];
$data = $params['data'];
$response = $this->reportService->saveData($key, $typeOfReport, $startDate, $endDate, $lat, $lon, $data);
} catch (\Exception $ex) {
$response = ["success" => false, "message" => $ex->getMessage()];
}
return $this->json($response);
}
/**
* @Route("/generate-report", name="api_ncm_report_generate_report", methods={"POST"})
*/
public function generateReport(Request $request): JsonResponse
{
try {
$response = [];
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (
!isset($params['from_date']) ||
!isset($params['to_date']) ||
!isset($params['parameters_24h']) ||
!isset($params['parameters_12h']) ||
!isset($params['is_governate']) ||
!isset($params['locations'])
) {
throw new \Exception('Missing required parameters');
}
if (!is_array($params['parameters_12h'])) {
throw new \Exception('Parameters 12 h should be array');
}
if (!is_array($params['parameters_24h'])) {
throw new \Exception('Parameters 24 h should be array');
}
if (empty($params['locations'] || !is_array($params['locations']))) {
throw new \Exception('Locations should be non empty array');
}
$model = isset($params['model']) ? $params['model'] : 'mix';
$redisKey = md5('generate_city_report-' . $params['from_date'] . '-' . $params['to_date'] . implode('_', $params['locations'])) . '-' . implode('_', $params['parameters_12h']) . '-' . implode('_', $params['parameters_24h']) . '-' . $model;
$data = $this->redisCache->get($redisKey);
if (!$data) {
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$cities = new \Pimcore\Model\DataObject\Governorate\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('governoteId IN (?)', [$params['locations']]);
}
} else {
$cities = new \Pimcore\Model\DataObject\City\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('o_id IN (?)', [$params['locations']]);
}
}
$cities->load();
if ($cities->getCount() > 0) {
$params['coordinates'] = []; // Initialize an empty array for coordinates
$result = [];
$citiesArr = [];
foreach ($cities as $city) {
$params['coordinates'][] = [$city->getLatitude(), $city->getLongitude()];
// Append the coordinates for each city
$long = number_format($city->getLongitude(), 6, '.', '');
$lat = number_format($city->getLatitude(), 6, '.', '');
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getName("ar");
} else {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getCityName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getCityName("ar");
}
}
$result = $this->meteomaticsWeatherService->getAdminReportForecastData($params['coordinates'], $params['from_date'], $params['to_date'], $model, $params['parameters_12h'], $params['parameters_24h'], $this->translator, $citiesArr, $params);
$response[] = $result;
$jsonResponse = ['success' => true, 'data' => $response];
$this->redisCache->set($redisKey, $jsonResponse, REDIS_CACHE_TIME);
return $this->json($jsonResponse);
} else {
return $this->json(['success' => true, 'message' => $this->translator->trans('no_city_found')]);
}
} else {
return $this->json($data);
}
} catch (\Exception $ex) {
// throw new \Exception($ex);
// $this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/create-arabian-gulf-report", name="api_ncm_report_create_arabian_gulf_report", methods={"POST"})
*/
public function createArabianGulfReport(Request $request): JsonResponse
{
try {
$response = [];
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (
!isset($params['from_date']) ||
!isset($params['to_date']) ||
!isset($params['parameters_24h']) ||
!isset($params['parameters_12h']) ||
!isset($params['is_governate']) ||
!isset($params['locations'])
) {
throw new \Exception('Missing required parameters');
}
if (!is_array($params['parameters_12h'])) {
throw new \Exception('Parameters 12 h should be array');
}
if (!is_array($params['parameters_24h'])) {
throw new \Exception('Parameters 24 h should be array');
}
if (empty($params['locations'] || !is_array($params['locations']))) {
throw new \Exception('Locations should be non empty array');
}
$model = isset($params['model']) ? $params['model'] : 'mix';
$redisKey = md5('generate_city_report-' . $params['from_date'] . '-' . $params['to_date'] . implode('_', $params['locations'])) . '-' . implode('_', $params['parameters_12h']) . '-' . implode('_', $params['parameters_24h']) . '-' . $model;
$data = $this->redisCache->get($redisKey);
if (!$data) {
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$cities = new \Pimcore\Model\DataObject\Governorate\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('governoteId IN (?)', [$params['locations']]);
}
} else {
$cities = new \Pimcore\Model\DataObject\City\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('o_id IN (?)', [$params['locations']]);
}
}
$cities->load();
if ($cities->getCount() > 0) {
$params['coordinates'] = []; // Initialize an empty array for coordinates
$result = [];
$citiesArr = [];
foreach ($cities as $city) {
$params['coordinates'][] = [$city->getLatitude(), $city->getLongitude()];
// Append the coordinates for each city
$long = number_format($city->getLongitude(), 6, '.', '');
$lat = number_format($city->getLatitude(), 6, '.', '');
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getName("ar");
} else {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getCityName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getCityName("ar");
}
}
$result = $this->meteomaticsWeatherService->getAdminReportForecastData($params['coordinates'], $params['from_date'], $params['to_date'], $model, $params['parameters_12h'], $params['parameters_24h'], $this->translator, $citiesArr, $params);
$response[] = $result;
$jsonResponse = ['success' => true, 'data' => $response];
$this->redisCache->set($redisKey, $jsonResponse, REDIS_CACHE_TIME);
return $this->json($jsonResponse);
} else {
return $this->json(['success' => true, 'message' => $this->translator->trans('no_city_found')]);
}
} else {
return $this->json($data);
}
} catch (\Exception $ex) {
// throw new \Exception($ex);
// $this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/create-today-weather-report", name="api_ncm_report_create_today_weather_report", methods={"POST"})
*/
public function createTodayWeatherReport(Request $request): JsonResponse
{
try {
$response = [];
// $permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
// if (isset($permissions['code']) && $permissions['code'] === 401) {
// return $this->json($permissions, 401);
// } elseif ($permissions['success'] === false) {
// return $this->json($permissions);
// }
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (
!isset($params['from_date']) ||
!isset($params['to_date']) ||
!isset($params['parameters_24h']) ||
!isset($params['parameters_12h']) ||
!isset($params['is_governate']) ||
!isset($params['locations'])
) {
throw new \Exception('Missing required parameters');
}
if (!is_array($params['parameters_12h'])) {
throw new \Exception('Parameters 12 h should be array');
}
if (!is_array($params['parameters_24h'])) {
throw new \Exception('Parameters 24 h should be array');
}
if (empty($params['locations'] || !is_array($params['locations']))) {
throw new \Exception('Locations should be non empty array');
}
$model = isset($params['model']) ? $params['model'] : 'mix';
$redisKey = md5('generate_city_report-' . $params['from_date'] . '-' . $params['to_date'] . implode('_', $params['locations'])) . '-' . implode('_', $params['parameters_12h']) . '-' . implode('_', $params['parameters_24h']) . '-' . $model;
$data = $this->redisCache->get($redisKey);
if (!$data) {
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$cities = new \Pimcore\Model\DataObject\Governorate\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('governoteId IN (?)', [$params['locations']]);
}
} else {
$cities = new \Pimcore\Model\DataObject\City\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('o_id IN (?)', [$params['locations']]);
}
}
$cities->load();
if ($cities->getCount() > 0) {
$params['coordinates'] = []; // Initialize an empty array for coordinates
$result = [];
$citiesArr = [];
foreach ($cities as $city) {
$params['coordinates'][] = [$city->getLatitude(), $city->getLongitude()];
// Append the coordinates for each city
$long = number_format($city->getLongitude(), 6, '.', '');
$lat = number_format($city->getLatitude(), 6, '.', '');
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getName("ar");
} else {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getCityName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getCityName("ar");
}
}
$result = $this->meteomaticsWeatherService->getAdminReportForecastData($params['coordinates'], $params['from_date'], $params['to_date'], $model, $params['parameters_12h'], $params['parameters_24h'], $this->translator, $citiesArr, $params);
$response[] = $result;
$jsonResponse = ['success' => true, 'data' => $response];
$this->redisCache->set($redisKey, $jsonResponse, REDIS_CACHE_TIME);
return $this->json($jsonResponse);
} else {
return $this->json(['success' => true, 'message' => $this->translator->trans('no_city_found')]);
}
} else {
return $this->json($data);
}
} catch (\Exception $ex) {
// throw new \Exception($ex);
// $this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/create-red-sea-report", name="api_ncm_report_create_red_sea_report", methods={"POST"})
*/
public function createRedSeaReport(Request $request): JsonResponse
{
try {
$response = [];
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (
!isset($params['from_date']) ||
!isset($params['to_date']) ||
!isset($params['parameters_24h']) ||
!isset($params['parameters_12h']) ||
!isset($params['is_governate']) ||
!isset($params['locations'])
) {
throw new \Exception('Missing required parameters');
}
if (!is_array($params['parameters_12h'])) {
throw new \Exception('Parameters 12 h should be array');
}
if (!is_array($params['parameters_24h'])) {
throw new \Exception('Parameters 24 h should be array');
}
if (empty($params['locations'] || !is_array($params['locations']))) {
throw new \Exception('Locations should be non empty array');
}
$model = isset($params['model']) ? $params['model'] : 'mix';
$redisKey = md5('generate_city_report-' . $params['from_date'] . '-' . $params['to_date'] . implode('_', $params['locations'])) . '-' . implode('_', $params['parameters_12h']) . '-' . implode('_', $params['parameters_24h']) . '-' . $model;
$data = $this->redisCache->get($redisKey);
if (!$data) {
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$cities = new \Pimcore\Model\DataObject\Governorate\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('governoteId IN (?)', [$params['locations']]);
}
} else {
$cities = new \Pimcore\Model\DataObject\City\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('o_id IN (?)', [$params['locations']]);
}
}
$cities->load();
if ($cities->getCount() > 0) {
$params['coordinates'] = []; // Initialize an empty array for coordinates
$result = [];
$citiesArr = [];
foreach ($cities as $city) {
$params['coordinates'][] = [$city->getLatitude(), $city->getLongitude()];
// Append the coordinates for each city
$long = number_format($city->getLongitude(), 6, '.', '');
$lat = number_format($city->getLatitude(), 6, '.', '');
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getName("ar");
} else {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getCityName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getCityName("ar");
}
}
$result = $this->meteomaticsWeatherService->getAdminReportForecastData($params['coordinates'], $params['from_date'], $params['to_date'], $model, $params['parameters_12h'], $params['parameters_24h'], $this->translator, $citiesArr, $params);
$response[] = $result;
$jsonResponse = ['success' => true, 'data' => $response];
$this->redisCache->set($redisKey, $jsonResponse, REDIS_CACHE_TIME);
return $this->json($jsonResponse);
} else {
return $this->json(['success' => true, 'message' => $this->translator->trans('no_city_found')]);
}
} else {
return $this->json($data);
}
} catch (\Exception $ex) {
// throw new \Exception($ex);
// $this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/create-custom-weather-report", name="api_ncm_report_create_custom_weather_report", methods={"POST"})
*/
public function createCustomWeatherReport(Request $request): JsonResponse
{
try {
$response = [];
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (
!isset($params['from_date']) ||
!isset($params['to_date']) ||
!isset($params['parameters_24h']) ||
!isset($params['parameters_12h']) ||
!isset($params['is_governate']) ||
!isset($params['locations'])
) {
throw new \Exception('Missing required parameters');
}
if (!is_array($params['parameters_12h'])) {
throw new \Exception('Parameters 12 h should be array');
}
if (!is_array($params['parameters_24h'])) {
throw new \Exception('Parameters 24 h should be array');
}
if (empty($params['locations'] || !is_array($params['locations']))) {
throw new \Exception('Locations should be non empty array');
}
$model = isset($params['model']) ? $params['model'] : 'mix';
$redisKey = md5('generate_city_report-' . $params['from_date'] . '-' . $params['to_date'] . implode('_', $params['locations'])) . '-' . implode('_', $params['parameters_12h']) . '-' . implode('_', $params['parameters_24h']) . '-' . $model;
$data = $this->redisCache->get($redisKey);
if (!$data) {
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$cities = new \Pimcore\Model\DataObject\Governorate\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('governoteId IN (?)', [$params['locations']]);
}
} else {
$cities = new \Pimcore\Model\DataObject\City\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('o_id IN (?)', [$params['locations']]);
}
}
$cities->load();
if ($cities->getCount() > 0) {
$params['coordinates'] = []; // Initialize an empty array for coordinates
$result = [];
$citiesArr = [];
foreach ($cities as $city) {
$params['coordinates'][] = [$city->getLatitude(), $city->getLongitude()];
// Append the coordinates for each city
$long = number_format($city->getLongitude(), 6, '.', '');
$lat = number_format($city->getLatitude(), 6, '.', '');
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getName("ar");
} else {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getCityName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getCityName("ar");
}
}
$result = $this->meteomaticsWeatherService->getAdminReportForecastData($params['coordinates'], $params['from_date'], $params['to_date'], $model, $params['parameters_12h'], $params['parameters_24h'], $this->translator, $citiesArr, $params);
$response[] = $result;
$jsonResponse = ['success' => true, 'data' => $response];
$this->redisCache->set($redisKey, $jsonResponse, REDIS_CACHE_TIME);
return $this->json($jsonResponse);
} else {
return $this->json(['success' => true, 'message' => $this->translator->trans('no_city_found')]);
}
} else {
return $this->json($data);
}
} catch (\Exception $ex) {
// throw new \Exception($ex);
// $this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/create-mashaer-weather-report", name="api_ncm_report_create_mashaer_weather_report", methods={"POST"})
*/
public function createMashaerWeatherReport(Request $request): JsonResponse
{
try {
$response = [];
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (
!isset($params['from_date']) ||
!isset($params['to_date']) ||
!isset($params['parameters_24h']) ||
!isset($params['parameters_12h']) ||
!isset($params['is_governate']) ||
!isset($params['locations'])
) {
throw new \Exception('Missing required parameters');
}
if (!is_array($params['parameters_12h'])) {
throw new \Exception('Parameters 12 h should be array');
}
if (!is_array($params['parameters_24h'])) {
throw new \Exception('Parameters 24 h should be array');
}
if (empty($params['locations'] || !is_array($params['locations']))) {
throw new \Exception('Locations should be non empty array');
}
$model = isset($params['model']) ? $params['model'] : 'mix';
$redisKey = md5('generate_city_report-' . $params['from_date'] . '-' . $params['to_date'] . implode('_', $params['locations'])) . '-' . implode('_', $params['parameters_12h']) . '-' . implode('_', $params['parameters_24h']) . '-' . $model;
$data = $this->redisCache->get($redisKey);
if (!$data) {
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$cities = new \Pimcore\Model\DataObject\Governorate\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('governoteId IN (?)', [$params['locations']]);
}
} else {
$cities = new \Pimcore\Model\DataObject\City\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('o_id IN (?)', [$params['locations']]);
}
}
$cities->load();
if ($cities->getCount() > 0) {
$params['coordinates'] = []; // Initialize an empty array for coordinates
$result = [];
$citiesArr = [];
foreach ($cities as $city) {
$params['coordinates'][] = [$city->getLatitude(), $city->getLongitude()];
// Append the coordinates for each city
$long = number_format($city->getLongitude(), 6, '.', '');
$lat = number_format($city->getLatitude(), 6, '.', '');
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getName("ar");
} else {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getCityName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getCityName("ar");
}
}
$result = $this->meteomaticsWeatherService->getAdminReportForecastData($params['coordinates'], $params['from_date'], $params['to_date'], $model, $params['parameters_12h'], $params['parameters_24h'], $this->translator, $citiesArr, $params);
$response[] = $result;
$jsonResponse = ['success' => true, 'data' => $response];
$this->redisCache->set($redisKey, $jsonResponse, REDIS_CACHE_TIME);
return $this->json($jsonResponse);
} else {
return $this->json(['success' => true, 'message' => $this->translator->trans('no_city_found')]);
}
} else {
return $this->json($data);
}
} catch (\Exception $ex) {
// throw new \Exception($ex);
// $this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/create-10-day-forecast-report", name="api_ncm_report_create_10_day_forecast_report", methods={"POST"})
*/
public function create10DayForecastReport(Request $request): JsonResponse
{
try {
$response = [];
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (
!isset($params['from_date']) ||
!isset($params['to_date']) ||
!isset($params['parameters_24h']) ||
!isset($params['parameters_12h']) ||
!isset($params['is_governate']) ||
!isset($params['locations'])
) {
throw new \Exception('Missing required parameters');
}
if (!is_array($params['parameters_12h'])) {
throw new \Exception('Parameters 12 h should be array');
}
if (!is_array($params['parameters_24h'])) {
throw new \Exception('Parameters 24 h should be array');
}
if (empty($params['locations'] || !is_array($params['locations']))) {
throw new \Exception('Locations should be non empty array');
}
$model = isset($params['model']) ? $params['model'] : 'mix';
$redisKey = md5('generate_city_report-' . $params['from_date'] . '-' . $params['to_date'] . implode('_', $params['locations'])) . '-' . implode('_', $params['parameters_12h']) . '-' . implode('_', $params['parameters_24h']) . '-' . $model;
$data = $this->redisCache->get($redisKey);
if (!$data) {
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$cities = new \Pimcore\Model\DataObject\Governorate\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('governoteId IN (?)', [$params['locations']]);
}
} else {
$cities = new \Pimcore\Model\DataObject\City\Listing();
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
if (!empty($params['locations'])) {
$cities->setCondition('o_id IN (?)', [$params['locations']]);
}
}
$cities->load();
if ($cities->getCount() > 0) {
$params['coordinates'] = []; // Initialize an empty array for coordinates
$result = [];
$citiesArr = [];
foreach ($cities as $city) {
$params['coordinates'][] = [$city->getLatitude(), $city->getLongitude()];
// Append the coordinates for each city
$long = number_format($city->getLongitude(), 6, '.', '');
$lat = number_format($city->getLatitude(), 6, '.', '');
// if governorate is true then get the cities from governorate else get the cities from city
if ($params['is_governate']) {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getName("ar");
} else {
$citiesArr[$lat . '|' . $long]["id"] = $city->getId();
$citiesArr[$lat . '|' . $long]["en"] = $city->getCityName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getCityName("ar");
}
}
$result = $this->meteomaticsWeatherService->getAdminReportForecastData($params['coordinates'], $params['from_date'], $params['to_date'], $model, $params['parameters_12h'], $params['parameters_24h'], $this->translator, $citiesArr, $params);
$response[] = $result;
$jsonResponse = ['success' => true, 'data' => $response];
$this->redisCache->set($redisKey, $jsonResponse, REDIS_CACHE_TIME);
return $this->json($jsonResponse);
} else {
return $this->json(['success' => true, 'message' => $this->translator->trans('no_city_found')]);
}
} else {
return $this->json($data);
}
} catch (\Exception $ex) {
// throw new \Exception($ex);
// $this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/create-report", name="api_ncm_report_create_report", methods={"POST"})
*/
public function createReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
if (in_array('twitter', $params['channels'])) {
if (!isset($params['xCaption']) || empty($params['xCaption'])) {
throw new \Exception($this->translator->trans('xCaption should be non empty'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/publish-arabian-gulf-report", name="api_ncm_report_publish_arabian_gulf", methods={"POST"})
*/
public function publishArabianGulfReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
if (in_array('twitter', $params['channels'])) {
if (!isset($params['xCaption']) || empty($params['xCaption'])) {
throw new \Exception($this->translator->trans('xCaption should be non empty'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/publish-today-weather-report", name="api_ncm_report_publish_today_weather_report", methods={"POST"})
*/
public function publishTodayWeatherReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
// if (isset($permissions['code']) && $permissions['code'] === 401) {
// return $this->json($permissions, 401);
// } elseif ($permissions['success'] === false) {
// return $this->json($permissions);
// }
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang']) || !isset($params['imageEn']) || !isset($params['imageAr'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
if (in_array('twitter', $params['channels'])) {
if (!isset($params['xCaption']) || empty($params['xCaption'])) {
throw new \Exception($this->translator->trans('xCaption should be non empty'), 400);
}
}
}
$result = $this->reportModel->createTodayWeatherReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* Marine report payload (preferred): redSeaWind, redSeaWaveHight, redSeaStatus, arabianGulfWind, arabianGulfWaveHight, arabianGulfSeaStatus (non-empty strings).
* Alternate: redSea, arabianGulf objects (WindAr/WaveHightAr/SeaStatusAr or windSpeed, windDirection, waveHeight, visibility, weather).
* Optional weatherDate (UTC); display { dayNameArabic, gregorian, hijri } is built server-side via MarineReportService::buildDateDisplay (or "now" in Riyadh when omitted).
* Required infographicImageBase64: client image (PNG/JPEG/GIF/WebP), plain base64 or data:image/...;base64,.
* Optional apiUrl, lang, Authorization (JWT in body when validateAPI is enabled).
*
* @Route("/publish-marine-report", name="api_ncm_report_publish_marine_report", methods={"POST"})
*/
public function publishMarineReport(Request $request, UserInterface $user): JsonResponse
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
}
if (($permissions['success'] ?? false) === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
if (!\is_array($params)) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
$this->translator->setlocale($params['lang'] ?? DEFAULT_LOCALE);
$flatMarineKeys = [
'redSeaWind',
'redSeaWaveHight',
'redSeaStatus',
'arabianGulfWind',
'arabianGulfWaveHight',
'arabianGulfSeaStatus',
'infographicImageBase64',
'twitterDescription',
];
$useFlatPayload = true;
foreach ($flatMarineKeys as $key) {
if (!isset($params[$key]) || trim((string) $params[$key]) === '') {
$useFlatPayload = false;
break;
}
}
if ($useFlatPayload) {
$redSea = $this->marineReportService->normalizeMarineRegionForInfographic([
'WindAr' => trim((string) $params['redSeaWind']),
'WaveHightAr' => trim((string) $params['redSeaWaveHight']),
'SeaStatusAr' => trim((string) $params['redSeaStatus']),
]);
$gulf = $this->marineReportService->normalizeMarineRegionForInfographic([
'WindAr' => trim((string) $params['arabianGulfWind']),
'WaveHightAr' => trim((string) $params['arabianGulfWaveHight']),
'SeaStatusAr' => trim((string) $params['arabianGulfSeaStatus']),
]);
}
if (!$this->marineReportService->regionHasContent($redSea) && !$this->marineReportService->regionHasContent($gulf)) {
return $this->json([
'success' => true,
'message' => $this->translator->trans('marine_report_skipped_empty'),
'data' => null,
]);
}
$clientInfographicB64 = null;
if (isset($params['infographicImageBase64']) && trim((string) $params['infographicImageBase64']) !== '') {
$clientInfographicB64 = trim((string) $params['infographicImageBase64']);
}
if ($clientInfographicB64 === null) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
$decodedImage = $this->reportModel->decodeImageBase64String($clientInfographicB64);
if ($decodedImage === false || @getimagesizefromstring($decodedImage) === false) {
return $this->json(['success' => false, 'message' => $this->translator->trans('marine_report_invalid_image')]);
}
$result = $this->reportModel->createMarineReport($user, [
'redSea' => $redSea,
'gulf' => $gulf,
'weatherDate' => $params['weatherDate'] ?? null,
'infographicImageBase64' => $decodedImage,
'twitterDescription' => $params['twitterDescription'] ?? '',
], $this->translator, $this->marineReportService);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* Fetches upstream marine-reports JSON, then responds with { redSea, arabianGulf, display, apiUrl } (same shape as publish-marine-report body).
* Upstream may be a list of rows or already that object. Forwards query string to upstream (except lang). Optional ?lang= for error messages.
*
* @Route("/get-marine-reports", name="api_ncm_report_get_marine_reports", methods={"POST"})
*/
public function getMarineReports(Request $request, UserInterface $user): JsonResponse
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
}
if (($permissions['success'] ?? false) === false) {
return $this->json($permissions);
}
$this->translator->setlocale($request->query->get('lang') ?: DEFAULT_LOCALE);
$url = NCM_PUBLIC_PORTAL_URL . 'api/ncm/internal/marine-reports';
$forwardQuery = $request->query->all();
unset($forwardQuery['lang']);
if ($forwardQuery !== []) {
$url .= (str_contains($url, '?') ? '&' : '?') . http_build_query($forwardQuery);
}
$response = $this->httpClient->request('GET', $url, [
'timeout' => 120,
'headers' => ['Accept' => 'application/json'],
]);
$status = $response->getStatusCode();
$body = $response->getContent(false);
if ($status < 200 || $status >= 300) {
$this->logger->error('Marine reports upstream HTTP ' . $status . ' for ' . $url);
return $this->json([
'success' => false,
'message' => $this->translator->trans('marine_reports_fetch_failed'),
'httpStatus' => $status,
], $status >= 400 && $status < 600 ? $status : 502);
}
$decoded = json_decode($body, true);
if (!\is_array($decoded)) {
return $this->json([
'success' => false,
'message' => $this->translator->trans('marine_reports_invalid_upstream_json'),
], 502);
}
$envelope = $this->marineReportService->buildEnvelope($decoded, $url);
if ($envelope === null) {
return $this->json([
'success' => false,
'message' => $this->translator->trans('marine_reports_envelope_failed'),
], 422);
}
return $this->json($envelope);
} catch (\Throwable $ex) {
$this->logger->error('Marine reports fetch: ' . $ex->getMessage());
return $this->json([
'success' => false,
'message' => $this->translator->trans('marine_reports_fetch_failed'),
], 502);
}
}
/**
* @Route("/publish-10-day-forecast-report", name="api_ncm_report_publish_10_day_forecast", methods={"POST"})
*/
public function publish10DayForecastReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
if (in_array('twitter', $params['channels'])) {
if (!isset($params['xCaption']) || empty($params['xCaption'])) {
throw new \Exception($this->translator->trans('xCaption should be non empty'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/publish-red-sea-report", name="api_ncm_report_publish_red_sea", methods={"POST"})
*/
public function publishRedSeaReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
if (in_array('twitter', $params['channels'])) {
if (!isset($params['xCaption']) || empty($params['xCaption'])) {
throw new \Exception($this->translator->trans('xCaption should be non empty'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/publish-custom-weather-report", name="api_ncm_report_publish_custom_weather", methods={"POST"})
*/
public function publishCustomWeatherReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
if (in_array('twitter', $params['channels'])) {
if (!isset($params['xCaption']) || empty($params['xCaption'])) {
throw new \Exception($this->translator->trans('xCaption should be non empty'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/publish-mashaer-weather-report", name="api_ncm_report_publish_mashaer_weather", methods={"POST"})
*/
public function publishMashaerWeatherReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
if (in_array('twitter', $params['channels'])) {
if (!isset($params['xCaption']) || empty($params['xCaption'])) {
throw new \Exception($this->translator->trans('xCaption should be non empty'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/get-city-list", name="api_ncm_report_get_city_list")
*/
public function getCityListAction(Request $request)
{
try {
$result = [];
$lang = ($request->headers->has('lang')) ? $request->headers->get('lang') : "en";
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
$reportTypeId = $params['report_type_id'] ?? null;
$cities = new \Pimcore\Model\DataObject\City\Listing();
if ($reportTypeId) {
$cities->setCondition("reportType REGEXP CONCAT('(^|,)', REPLACE('" . $reportTypeId . "', ',', '|'), '(,|$)')");
} else {
$db = \Pimcore\Db::get();
$selectedLocalities = $db->fetchAllAssociative("SELECT oo_id FROM `object_query_ReportType` WHERE (`isAutomaticReport` = 0)");
$ooIds = array_column($selectedLocalities, 'oo_id');
$cities->setCondition("reportType REGEXP CONCAT('(^|,)', REPLACE('" . implode(',', $ooIds) . "', ',', '|'), '(,|$)')");
}
$cities->setOrderKey('orderId');
$cities->setOrder('asc');
$cities->load();
if ($cities->getCount() > 0) {
foreach ($cities as $city) {
$result[] = [
"id" => $city->getId(),
"name" => $city->getCityName($lang),
"nameEn" => $city->getCityName('en'),
"nameAr" => $city->getCityName('ar'),
"lat" => $city->getLatitude(),
"long" => $city->getLongitude(),
"googlePlaceName" => $city->getGooglePlaceName(),
];
}
return $this->json(["success" => true, "data" => $result]);
}
return $this->json(["success" => false, "message" => $this->translator->trans("no_city_is_available")]);
} catch (\Exception $ex) {
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/list-report", name="api_ncm_report_list_report", methods={"POST"})
*/
public function getReportListAction(Request $request, PaginatorInterface $paginator, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['page']) || !isset($params['limit'])) {
throw new \Exception('Missing required page_no or page_limit');
}
$report_type = isset($params['report_type']) ? $params['report_type'] : null;
$lang = isset($params['lang']) ? $params['lang'] : DEFAULT_LOCALE;
$page = $params['page'];
$limit = $params['limit'];
$result = $this->reportModel->reportList($params, $page, $limit, $this->translator, $paginator, $report_type, $user, $lang, false);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/list-reports-by-type", name="api_ncm_report_list_reports_by_type", methods={"POST"})
*/
public function listReportsByType(Request $request, PaginatorInterface $paginator, UserInterface $user)
{
try {
// $permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
// if (isset($permissions['code']) && $permissions['code'] === 401) {
// return $this->json($permissions, 401);
// } elseif ($permissions['success'] === false) {
// return $this->json($permissions);
// }
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['page']) || !isset($params['limit'])) {
throw new \Exception('Missing required page or limit');
}
// Getting current JWT Token
$decodedJwtToken = null;
if ($this->tokenStorageInterface->getToken()) {
$decodedJwtToken = $this->jwtManager->decode($this->tokenStorageInterface->getToken());
}
// Array to store permissions
$allowedReportTypes = [];
// Check if the permissions are true and store them in the array
$permissionsList = [
'view_red_sea_report',
'view_arabian_gulf_report',
'view_10_day_forecast_report',
'view_custom_weather_report',
'view_advance_custom_weather_report',
'view_mashaer_weather_report',
'view_today_weather_report'
];
// Loop through each permission and check if it's true
foreach ($permissionsList as $permission) {
$permissionStatus = $this->userPermission->getUserPermissions($decodedJwtToken, $this->translator);
if (isset($permissionStatus['grants'][$permission]) && $permissionStatus['grants'][$permission] === true) {
// Convert permission names to report type keys
$reportTypeKey = '';
switch ($permission) {
case 'view_arabian_gulf_report':
$reportTypeKey = 'arabian-gulf-report';
break;
case 'view_red_sea_report':
$reportTypeKey = 'red-sea-report';
break;
case 'view_custom_weather_report':
$reportTypeKey = 'custom-weather-report';
break;
case 'view_10_day_forecast_report':
$reportTypeKey = '10-day-forecast-report';
break;
case 'view_mashaer_weather_report':
$reportTypeKey = 'mashaer-weather-report';
break;
case 'view_advance_custom_weather_report':
$reportTypeKey = 'advance-custom-weather-report';
break;
case 'view_today_weather_report':
$reportTypeKey = 'today-weather-report';
break;
}
if (!empty($reportTypeKey)) {
$allowedReportTypes[] = $reportTypeKey;
}
}
}
$params['allowedReportTypes'] = $allowedReportTypes;
$params['decodedJwtToken'] = $decodedJwtToken;
$params['userPermission'] = $this->userPermission;
$result = $this->reportModel->listReportsByType($params, $this->translator, $paginator);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/view-10-day-forecast-report", name="api_ncm_report_view_10_day_forecast_report", methods={"POST"})
*/
public function view10DayForecastReport(Request $request, PaginatorInterface $paginator, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['page']) || !isset($params['limit'])) {
throw new \Exception('Missing required page_no or page_limit');
}
$report_type = isset($params['report_type']) ? $params['report_type'] : null;
$lang = isset($params['lang']) ? $params['lang'] : DEFAULT_LOCALE;
$page = $params['page'];
$limit = $params['limit'];
$result = $this->reportModel->reportList($params, $page, $limit, $this->translator, $paginator, $report_type, $user, $lang, false);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/view-red-sea-report", name="api_ncm_report_view_red_sea_report", methods={"POST"})
*/
public function viewRedSeaReport(Request $request, PaginatorInterface $paginator, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['page']) || !isset($params['limit'])) {
throw new \Exception('Missing required page_no or page_limit');
}
$report_type = isset($params['report_type']) ? $params['report_type'] : null;
$lang = isset($params['lang']) ? $params['lang'] : DEFAULT_LOCALE;
$page = $params['page'];
$limit = $params['limit'];
$result = $this->reportModel->reportList($params, $page, $limit, $this->translator, $paginator, $report_type, $user, $lang, false);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/view-custom-weather-report", name="api_ncm_report_view_custom_weather_report", methods={"POST"})
*/
public function viewCustomWeatherReport(Request $request, PaginatorInterface $paginator, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['page']) || !isset($params['limit'])) {
throw new \Exception('Missing required page_no or page_limit');
}
$report_type = isset($params['report_type']) ? $params['report_type'] : null;
$lang = isset($params['lang']) ? $params['lang'] : DEFAULT_LOCALE;
$page = $params['page'];
$limit = $params['limit'];
$result = $this->reportModel->reportList($params, $page, $limit, $this->translator, $paginator, $report_type, $user, $lang, false);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/view-mashaer-weather-report", name="api_ncm_report_view_mashaer_weather_report", methods={"POST"})
*/
public function viewMashaerWeatherReport(Request $request, PaginatorInterface $paginator, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['page']) || !isset($params['limit'])) {
throw new \Exception('Missing required page_no or page_limit');
}
$report_type = isset($params['report_type']) ? $params['report_type'] : null;
$lang = isset($params['lang']) ? $params['lang'] : DEFAULT_LOCALE;
$page = $params['page'];
$limit = $params['limit'];
$result = $this->reportModel->reportList($params, $page, $limit, $this->translator, $paginator, $report_type, $user, $lang, false);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/generate-report-pdf", name="api_ncm_report_generate_report_pdf", methods={"POST"})
*/
public function generateReportPdf(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
$result = $this->reportModel->generatePdfReport($request, $user, $this->snappy, $this->translator);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/get-report-types", name="api_ncm_report_get_report_types", methods={"POST"})
*/
public function getReportTypes(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
if (!$user) {
throw new \Exception('User is not authenticated');
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['automatic'])) {
throw new \Exception('missing_required_parameters');
}
$result = [];
$automatic = $params['automatic'] ? true : false;
$reportTypes = new \Pimcore\Model\DataObject\ReportType\Listing();
$reportTypes->setCondition('isAutomaticReport = ?', [$automatic]);
$reportTypes->load();
if ($reportTypes->getCount() > 0) {
foreach ($reportTypes as $reportType) {
$result[] = [
"id" => $reportType->getId(),
"key" => $reportType->getReportKey(),
"nameEn" => $reportType->getName('en'),
"nameAr" => $reportType->getName('ar'),
"descriptionEn" => $reportType->getDescription('en'),
"descriptionAr" => $reportType->getDescription('ar'),
"titleEn" => $reportType->getTitle('en'),
"titleAr" => $reportType->getTitle('ar'),
"automatic" => $reportType->getIsAutomaticReport()
];
}
return $this->json(["success" => true, "data" => $result]);
}
return $this->json(["success" => false, "message" => $this->translator->trans("no_reportType_is_available")]);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/get-weather-params-list", name="api_ncm_report_get_weather_params_list", methods={"POST"})
*/
public function getWeatherParamsListAction(Request $request)
{
try {
$result = [];
$lang = ($request->headers->has('lang')) ? $request->headers->get('lang') : "en";
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['report_type_id'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
$reportTypeId = $params['report_type_id'];
$parameters = new \Pimcore\Model\DataObject\ReportWeatherParameters\Listing();
$parameters->setCondition("reportType REGEXP CONCAT('(^|,)', REPLACE('" . $reportTypeId . "', ',', '|'), '(,|$)')");
$parameters->load();
if ($parameters->getCount() > 0) {
foreach ($parameters as $paramter) {
$result[] = [
"id" => $paramter->getId(),
"nameEn" => $paramter->getName('en'),
"nameAr" => $paramter->getName('ar'),
"meteoMaticsKey" => $paramter->getMeteoMaticsKey(),
"units" => $paramter->getUnits(),
"unitTitle" => $paramter->getUnitTitle()
];
}
return $this->json(["success" => true, "data" => $result]);
}
return $this->json(["success" => false, "message" => $this->translator->trans("no_weather_parameter_is_available")]);
} catch (\Exception $ex) {
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/generate-excel", name="api_ncm_report_generate_excel")
*/
public function generateExcelReport(Request $request, UserInterface $user)
{
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['id'])) {
throw new \Exception('missing_required_parameters');
}
$report = Report::getById($params['id'], true);
if (!$report instanceof Report) {
throw new \Exception('no_report_found');
}
// Replace this with the actual data you want to use
$jsonData = json_decode($report->getJsonData(), true);
// Create a new PhpSpreadsheet instance
$spreadsheet = new Spreadsheet();
// Create a worksheet
$sheet = $spreadsheet->getActiveSheet();
// Determine headers dynamically based on the first item in the data
$firstItem = reset($jsonData);
$parameters = $firstItem['parameters'] ?? [];
$headers = [$this->translator->trans('Location'), $this->translator->trans('Latitude'), $this->translator->trans('Longitude'), $this->translator->trans('Date')]; // Initialize headers with common columns
// Extract parameter names and add them to headers
foreach ($parameters as $parameter) {
if ($parameter['parameter'] == 'prob_precip_24h:p') {
$headers[] = $this->translator->trans('Precipitation Probability (%)');
} elseif ($parameter['parameter'] == 'precip_24h:mm') {
$headers[] = $this->translator->trans('Precipitation Amount (mm)');
} elseif ($parameter['parameter'] == 'wind_speed_mean_10m_24h:kmh') {
$headers[] = $this->translator->trans('Wind Speed (km/h)');
} elseif ($parameter['parameter'] == 't_2m:C') {
$headers[] = $this->translator->trans('Temperature (°C)');
} else {
$headers[] = $parameter['parameter'];
}
}
// Add headers to the worksheet
foreach ($headers as $index => $header) {
$sheet->setCellValueByColumnAndRow($index + 1, 1, $header);
}
// Style headers
$headerStyle = [
'font' => [
'bold' => true,
'color' => ['rgb' => 'FFFFFF'], // White text
],
'fill' => [
'fillType' => Fill::FILL_SOLID,
'startColor' => ['rgb' => '16365c'], // Blue background
],
'alignment' => [
'horizontal' => Alignment::HORIZONTAL_CENTER,
'vertical' => Alignment::VERTICAL_CENTER,
],
];
$sheet->getStyle('A1:H1')->applyFromArray($headerStyle);
// Initialize row counter
$row = 2;
foreach ($jsonData as $item) {
// Extract city-related data
$cityData = [$item['city'] ?? '', $item['lat'] ?? '', $item['lon'] ?? ''];
// Loop through each date for all parameters
foreach ($item['parameters'][0]['dates'] as $dateIndex => $date) {
// Initialize row data with city-related data and date
$rowData = array_merge($cityData, [date('Y-m-d', strtotime($date['date']))]);
// Loop through each parameter
foreach ($item['parameters'] as $parameter) {
// Check if the value is set for the current date, otherwise set it to 0
$value = isset($parameter['dates'][$dateIndex]['value']) ? $parameter['dates'][$dateIndex]['value'] : 0;
// Add parameter value for the current date to the row data
$rowData[] = $value;
}
// Set cell values explicitly
foreach ($rowData as $colIndex => $cellValue) {
$sheet->setCellValueByColumnAndRow($colIndex + 1, $row, $cellValue);
}
// Increment the row counter
$row++;
}
}
foreach (range('A', $sheet->getHighestColumn()) as $columnID) {
$sheet->getColumnDimension($columnID)->setAutoSize(true);
}
// Save the Excel file to a temporary file
$tempFile = tempnam(sys_get_temp_dir(), 'weather_report');
$writer = new Xlsx($spreadsheet);
$writer->save($tempFile);
// Store the file in Pimcore Assets
$assetFolder = '/report/ExcelReports'; // Change this to your actual asset folder path
$filename = $user->getId() . '_' . time() . '_' . 'weather_report.xlsx';
$assetPath = API_BASE_URL . '/' . $assetFolder . '/' . $filename;
// Create a new asset
$asset = new \Pimcore\Model\Asset();
$asset->setFilename($filename);
$asset->setData(file_get_contents($tempFile));
$asset->setParent(\Pimcore\Model\Asset\Service::createFolderByPath($assetFolder));
$asset->save();
// Remove the temporary file
unlink($tempFile);
$report->setAsset($asset);
$report->setIsHistorical(true);
$report->save();
// Return the path to the stored Excel file in Pimcore
return $this->json(['success' => true, 'data' => $assetPath]);
}
/**
* @Route("/generate-historical-report", name="api_ncm_report_generate_historical_report", methods={"POST"})
*/
public function generateHistoricalReport(Request $request): JsonResponse
{
try {
$response = [];
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (
!isset($params['from_date']) ||
!isset($params['to_date']) ||
!isset($params['hours']) ||
!isset($params['parameters']) ||
!isset($params['locations'])
) {
throw new \Exception('Missing required parameters');
}
if (empty($params['parameters'] || !is_array($params['parameters']))) {
throw new \Exception('Parameters should be non empty array');
}
if (empty($params['locations'] || !is_array($params['locations']))) {
throw new \Exception('Locations should be non empty array');
}
if ($params['to_date'] > date('Y-m-d', strtotime(Carbon::now()))) {
$daysadd = date('Y-m-d', strtotime(Carbon::now()->addDays('17')));
if ($params['to_date'] >= $daysadd) {
throw new \Exception('End date limit exceeded');
}
}
$model = isset($params['model']) ? $params['model'] : 'mix';
$redisKey = md5('generate_city_report-' . $params['from_date'] . '-' . $params['to_date'] . '-' . $params['hours'] . '-' . implode('_', $params['locations'])) . '-' . implode('_', $params['parameters']) . '-' . $model;
$data = $this->redisCache->get($redisKey);
if (!$data) {
$cities = new \Pimcore\Model\DataObject\Location\Listing();
if (!empty($params['locations'])) {
$cities->setCondition('o_id IN (?)', [$params['locations']]);
}
$cities->load();
if ($cities->getCount() > 0) {
$params['coordinates'] = []; // Initialize an empty array for coordinates
$result = [];
$citiesArr = [];
foreach ($cities as $city) {
$cityLocations = json_decode($city->getCoordinates(), true);
foreach ($cityLocations as $coordinates) {
$long = number_format($coordinates[1], 6, '.', '');
$lat = number_format($coordinates[0], 6, '.', '');
$params['coordinates'][] = $coordinates;
$citiesArr[$lat . '|' . $long] = $city->getName();
}
}
$result = $this->meteomaticsWeatherService->getReportForecastData($params['coordinates'], $params['from_date'], $params['to_date'], $params['hours'], $model, $params['parameters'], $this->translator, $citiesArr, $params);
$response[] = $result;
$jsonResponse = ['success' => true, 'data' => $response];
$this->redisCache->set($redisKey, $jsonResponse, REDIS_CACHE_TIME);
return $this->json($jsonResponse);
} else {
return $this->json(['success' => true, 'message' => $this->translator->trans('no_city_found')]);
}
} else {
return $this->json($data);
}
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/get-report-detail", name="api_ncm_report_get_report_detail")
*/
public function getReportDetails(Request $request)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (
!isset($params['id'])
) {
throw new \Exception('Missing required parameters');
}
$report = Report::getById($params['id'], true);
if (!$report instanceof Report) {
throw new \Exception('no_report_found');
} else {
$asset_path = $report->getAsset()?->getPath() . $report->getAsset()?->getFileName() ? API_BASE_URL . $report->getAsset()?->getPath() . $report->getAsset()?->getFileName() : '';
$data = [
'name' => $report->getCreatedBy()?->getId(),
'email' => $report->getCreatedBy()?->getEmail(),
'jsonData' => json_decode($report->getJsonData(), true),
'asset_path' => $asset_path,
'createdOn' => $report->getCreatedOn(),
];
}
return $this->json(['success' => true, 'data' => $data]);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/get-latest-report", name="api_ncm_report_get_latest_report")
*/
public function getLatestReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
if (!$user) {
throw new \Exception('User is not authenticated');
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
$reportType = (isset($params['report_type']) && !empty($params['report_type'])) ? $params['report_type'] : '10-day-forecast-report';
$result = $this->reportModel->getLatestReport($reportType, $this->translator);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/generate-manned-report", name="api_ncm_report_generate_manned_report" , methods={"POST"})
*/
public function generateMannedReport(Request $request, UserInterface $user): JsonResponse
{
try {
$response = [];
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
$requiredParameters = [
'titleEn',
'titleAr',
'descriptionEn',
'descriptionAr',
'channels',
'report_type_id',
'fileName',
'file',
'type'
];
foreach ($requiredParameters as $param) {
if (!isset($params[$param]) || empty($params[$param])) {
$missingParams[] = $param;
}
}
if (!empty($missingParams)) {
// Throw an exception with a message that includes the missing parameters
$parameterList = implode(", ", $missingParams);
return $this->json(['success' => false, 'message' => sprintf($this->translator->trans("missing_required_parameters: %s"), $parameterList)]);
}
// Check if 'type' is either 'video' or 'pdf'
if (isset($params['type']) && !in_array($params['type'], ['video', 'pdf'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans("Type must be either video or pdf")]);
}
$result = $this->reportModel->createMannedReport($request, $this->translator, $params, $user);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/get-automatic-reports", name="api_ncm_report_get_automatic_reports")
*/
public function getAutomaticReports(Request $request, UserInterface $user, PaginatorInterface $paginator)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
if (!$user) {
throw new \Exception('User is not authenticated');
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
if (!isset($params['page']) || !isset($params['limit']) || !isset($params['lang'])) {
throw new \Exception('Missing required parameters');
}
$search = isset($params['search']) ? $params['search'] : null;
$orderKey = isset($params['orderKey']) ? $params['orderKey'] : 'createdOn';
$order = isset($params['order']) ? $params['order'] : 'desc';
$result = $this->reportModel->listAutomaticReports($params, $user, $search, $orderKey, $order, $this->translator, $paginator);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/generate-automatic-report-pdf", name="api_ncm_report_generate_automatic_report_pdf")
*/
public function generateAutomaticReportPdf(Request $request, UserInterface $user)
{
try {
$result = $this->reportModel->generatePdfReport($request, $user, $this->snappy, $this->translator);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/generate-history-report-pdf", name="api_ncm_report_generate_history_report_pdf")
*/
public function generateHistoryReportPdf(Request $request, UserInterface $user)
{
try {
return $this->getEWSHistoryPDF($request, $user, 'pdf/history_report_pdf.html.twig', $this->translator, '_history_report.pdf');
} catch (\Exception $ex) {
p_r($ex->getMessage());
exit;
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
public function getEWSHistoryPDF($request, $user, $template, $translator, $report_type)
{
$params = json_decode($request->getContent(), true);
if (!isset($params['id'])) {
return $this->json(["success" => false, "message" => $translator->trans("missing_required_parameters")]);
}
$ewsId = $params['id'];
$lang = isset($params['lang']) ? $params['lang'] : "en";
$ews = \Pimcore\Model\DataObject::getById($ewsId);
if (!$ews instanceof EwsNotification) {
return $this->json(["success" => false, "message" => $translator->trans("no_report_found")]);
}
$ewsNotificationModel = new EwsNotificationModel();
$fileName = '_ews_history_report.pdf';
$reportPath = '/report/ReportPdf/' . $params['id'];
$template = 'pdf/history_report_pdf.html.twig';
$data = $ewsNotificationModel->viewNotification($params, $translator);
$parameter = [
'data' => $data,
'reportTitleEn' => "EWS Notification History",
'template' => $template,
'lang' => $lang
];
// return $this->render('pdf/automatic_report_pdf_template_copy.html.twig',$parameter);
$pdf = \App\Lib\Utility::generatePdf($parameter, $this->snappy);
// $tempFilePath = tempnam(sys_get_temp_dir(), 'image_');
// file_put_contents($tempFilePath, $pdf);
// Create a BinaryFileResponse and set headers
// $response = new BinaryFileResponse($tempFilePath);
// $response->headers->set('Content-Type', 'application/pdf');
// $response->setContentDisposition(ResponseHeaderBag::DISPOSITION_INLINE, 'image.pdf');
// Return the response
// return $responseReport;
$asset = \App\Lib\Utility::createAsset($pdf, 'Alert_History_Report_' . date('Y-m-d') . '-' . $params['id'] . '.pdf', $reportPath);
$pdfasset = '';
if ($asset instanceof Asset) {
$pdfasset = API_BASE_URL . $asset->getPath() . $asset->getFilename();
}
return $this->json(['success' => true, 'data' => $pdfasset]);
}
public function getPdfReport($request, $user, $template, $translator, $report_type)
{
$params = json_decode($request->getContent(), true);
if (!isset($params['id'])) {
return $this->json(["success" => false, "message" => $translator->trans("missing_required_parameters")]);
}
$report = Report::getById($params['id'], true);
$lang = isset($params['lang']) ? $params['lang'] : "en";
if (!$report instanceof Report) {
return $this->json(["success" => false, "message" => $translator->trans("no_report_found")]);
}
$asset = $lang == 'ar' ? $report->getAssetAr() : $report->getAsset();
if ($asset) {
$pdfasset = API_BASE_URL . $asset->getPath() . $asset->getFilename();
return $this->json(['success' => true, 'data' => $pdfasset]);
}
//$template=$report->getReportType()?->getKey() == 'MannForecastReport'?'pdf/report_pdf_template.html.twig':'pdf/automatic_report_pdf_template.html.twig';
$fileName = '_custom_weather_report.pdf';
$reportPath = '/report/ReportPdf';
if ($report->getReportType()?->getKey() == 'MannForecastReport') {
$template = 'pdf/report_pdf_template.html.twig';
} elseif ($report->getReportType()?->getKey() == 'advance-custom-weather-report') {
$template = 'pdf/advance_custom_report_pdf_template.html.twig';
// $fileName = '_advance_custom_weather_report.pdf';
$reportPath = '/report/advanceCustomReportPdf';
} else {
$template = 'pdf/automatic_report_pdf_template.html.twig';
}
$parameter = [
'data' => $report,
'reportTitleEn' => $report->getReportTitle('en'),
'reportTitleAr' => $report->getReportTitle('ar'),
'reportDescriptionEn' => $report->getDescription('en'),
'reportDescriptionAr' => $report->getDescription('ar'),
'reportDisclaimerEn' => $report->getReportDisclaimer('en'), // new
'reportDisclaimerAr' => $report->getReportDisclaimer('ar'), // new
'additionalNoteEn' => $report->getAdditionalNote('en'), // new
'additionalNoteAr' => $report->getAdditionalNote('ar'), // new
'stateOfTheSeaEn' => $report->getStateOfTheSea('en'), // new
'stateOfTheSeaAr' => $report->getStateOfTheSea('ar'), // new
'waveHeightEn' => $report->getWaveHeight('en'), // new
'waveHeightAr' => $report->getWaveHeight('ar'), // new
'surfaceWindEn' => $report->getSurfaceWind('en'), // new
'surfaceWindAr' => $report->getSurfaceWind('ar'), // new
'publishOnPdf' => $report->getPublishOnPdf() == true ? true : false, // new
'reportType' => $report->getReportType()?->getReportkey(),
'template' => $template,
'lang' => $lang
];
// return $this->render('pdf/automatic_report_pdf_template_copy.html.twig',$parameter);
$pdf = \App\Lib\Utility::generatePdf($parameter, $this->snappy);
// $tempFilePath = tempnam(sys_get_temp_dir(), 'image_');
// file_put_contents($tempFilePath, $pdf);
// Create a BinaryFileResponse and set headers
// $response = new BinaryFileResponse($tempFilePath);
// $response->headers->set('Content-Type', 'application/pdf');
// $response->setContentDisposition(ResponseHeaderBag::DISPOSITION_INLINE, 'image.pdf');
// Return the response
// return $response;
// set the asset path and title
$pdfReportName = $report->getReportType() ? $report->getReportType()->getName($lang) : $report_type;
$pdfReportName = $pdfReportName . '_' . date('d-m-Y') . '.pdf';
$reportPath = $reportPath . '/' . $report->getId();
$asset = \App\Lib\Utility::createAsset($pdf, $pdfReportName, $reportPath);
$pdfasset = '';
if ($asset instanceof Asset) {
$pdfasset = API_BASE_URL . $asset->getPath() . $asset->getFilename();
}
if ($lang == 'ar') {
$report->setAssetAr($asset);
} else {
$report->setAsset($asset);
}
$report->save();
return $this->json(['success' => true, 'data' => $pdfasset]);
}
/**
* @Route("/get-today-weather-report", name="api_ncm_report_get_today_weather_report")
*/
public function getTodayWeatherReports(Request $request, UserInterface $user, PaginatorInterface $paginator)
{
try {
if (!$user) {
throw new \Exception('User is not authenticated');
}
$params = json_decode($request->getContent(), true);
if (!isset($params['page']) || !isset($params['limit']) || !isset($params['lang'])) {
throw new \Exception('Missing required parameters');
}
$result = $this->reportModel->getTodayWeatherReports($params, $this->translator, $paginator);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/preview-advance-custom-report", name="api_ncm_report_preview_advance_custom_report" , methods={"POST"})
*/
public function previewAdvanceCustomReport(Request $request): JsonResponse
{
try {
$response = [];
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
$locations = (isset($params['locations']) && !empty($params['locations'])) || (isset($params['weather_stations']) && !empty($params['weather_stations']));
if (
!isset($params['from_date']) ||
!isset($params['to_date']) ||
!isset($params['parameters']) ||
!isset($locations)
) {
throw new \Exception('Missing required parameters');
}
if (empty($params['parameters'] || !is_array($params['parameters']))) {
throw new \Exception('Parameters should be non empty array');
}
if ((!isset($params['locations']) || empty($params['locations']) || !is_array($params['locations'])) && (!isset($params['weather_stations']) || empty($params['weather_stations']) || !is_array($params['weather_stations']))) {
throw new \Exception('Either locations or weather_stations should be non empty array');
}
// Set default values for new parameters
$params['isAWSReport'] = isset($params['isAWSReport']) ? $params['isAWSReport'] : false;
$params['hours'] = isset($params['hours']) ? $params['hours'] : 24;
$params['weather_stations'] = isset($params['weather_stations']) ? $params['weather_stations'] : [];
$params['locations'] = isset($params['locations']) ? $params['locations'] : [];
$model = isset($params['model']) ? $params['model'] : 'mix';
// $redisKey = md5('generate_city_report-' . $params['from_date'] . '-' . $params['to_date'] . '-' . $params['hours'] . '-' . ($params['isAWSReport'] ? 'aws_' . implode('_', $params['weather_stations']) : implode('_', $params['locations']))) . '-' . implode('_', $params['parameters']) . '-' . $model;
// $data = $this->redisCache->get($redisKey);
// if (!$data) {
$params['coordinates'] = []; // Initialize an empty array for coordinates
$result = [];
$citiesArr = [];
if ($params['isAWSReport']) {
// Handle AWS Weather Station report
$stations = new \Pimcore\Model\DataObject\WeatherStations\Listing();
if (!empty($params['weather_stations'])) {
$stations->setCondition('o_id IN (?)', [$params['weather_stations']]);
}
$stations->load();
if ($stations->getCount() > 0) {
$hashArr = [];
foreach ($stations as $station) {
$params['coordinates'][] = [$station->getlatitude(), $station->getlongitude()];
$hash = $station->getHash();
// Append the coordinates for each station
$long = number_format($station->getlongitude(), 6, '.', '');
$lat = number_format($station->getlatitude(), 6, '.', '');
$citiesArr[$hash]["en"] = $station->getName("en");
$citiesArr[$hash]["ar"] = $station->getName("ar");
$citiesArr[$hash]["lat"] = $lat;
$citiesArr[$hash]["long"] = $long;
$hashArr[] = $hash;
}
$result = $this->meteomaticsWeatherService->getWeatherStationReportData($params['from_date'], $params['to_date'], $params['parameters'], $hashArr, false, $this->translator, 'PT' . $params['hours'] . 'H', $citiesArr);
} else {
return $this->json(['success' => true, 'message' => $this->translator->trans('no_weather_station_found')]);
}
} else {
// Handle regular Governorate report
$cities = new \Pimcore\Model\DataObject\Governorate\Listing();
if (isset($params['locations']) && !empty($params['locations'])) {
$cities->setCondition('governoteId IN (?)', [$params['locations']]);
}
$cities->load();
if ($cities->getCount() > 0) {
foreach ($cities as $city) {
$params['coordinates'][] = [$city->getLatitude(), $city->getLongitude()];
// Append the coordinates for each city
$long = number_format($city->getLongitude(), 6, '.', '');
$lat = number_format($city->getLatitude(), 6, '.', '');
$citiesArr[$lat . '|' . $long]["en"] = $city->getName("en");
$citiesArr[$lat . '|' . $long]["ar"] = $city->getName("ar");
}
$result = $this->meteomaticsWeatherService->getReportForecastData($params['coordinates'], $params['from_date'], $params['to_date'], $params['hours'], $model, $params['parameters'], $this->translator, $citiesArr, array_merge($params, ['skip_service_cache' => true]));
} else {
return $this->json(['success' => true, 'message' => $this->translator->trans('no_city_found')]);
}
}
$response[] = $result;
$jsonResponse = ['success' => true, 'data' => $response];
// $this->redisCache->set($redisKey, $jsonResponse, REDIS_CACHE_TIME);
return $this->json($jsonResponse);
// } else {
// return $this->json($data);
// }
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/publish-advance-custom-report", name="api_ncm_report_publish_advance_custom_report" , methods={"POST"})
*/
public function publishAdvanceCustomReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
}
$result = $this->reportModel->publishAdvanceCustomReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/archive-weather-report", name="api_ncm_report_archive_weather_report")
*/
public function archiveWeatherReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
if (!$user) {
throw new \Exception('User is not authenticated');
}
$params = json_decode($request->getContent(), true);
if (!isset($params['report_id'])) {
throw new \Exception('Missing required parameters');
}
$result = $this->reportModel->archiveWeatherReport($this->translator, $user, $params['report_id']);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/delete-arabian-gulf-report", name="api_ncm_report_delete_arabian_gulf_report")
*/
public function deleteArabianGulfReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
if (!$user) {
throw new \Exception('User is not authenticated');
}
$params = json_decode($request->getContent(), true);
if (!isset($params['report_id'])) {
throw new \Exception('Missing required parameters');
}
$result = $this->reportModel->archiveWeatherReport($this->translator, $user, $params['report_id']);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/delete-10-day-forecast-report", name="api_ncm_report_delete_10_day_forecast_report")
*/
public function delete10DayForecastReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
if (!$user) {
throw new \Exception('User is not authenticated');
}
$params = json_decode($request->getContent(), true);
if (!isset($params['report_id'])) {
throw new \Exception('Missing required parameters');
}
$result = $this->reportModel->archiveWeatherReport($this->translator, $user, $params['report_id']);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/delete-red-sea-report", name="api_ncm_report_delete_red_sea_report")
*/
public function deleteRedSeaReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
if (!$user) {
throw new \Exception('User is not authenticated');
}
$params = json_decode($request->getContent(), true);
if (!isset($params['report_id'])) {
throw new \Exception('Missing required parameters');
}
$result = $this->reportModel->archiveWeatherReport($this->translator, $user, $params['report_id']);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/delete-custom-weather-report", name="api_ncm_report_delete_custom_weather_report")
*/
public function deleteCustomWeatherReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
if (!$user) {
throw new \Exception('User is not authenticated');
}
$params = json_decode($request->getContent(), true);
if (!isset($params['report_id'])) {
throw new \Exception('Missing required parameters');
}
$result = $this->reportModel->archiveWeatherReport($this->translator, $user, $params['report_id']);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/delete-mashaer-weather-report", name="api_ncm_report_delete_mashaer_weather_report")
*/
public function deleteMashaerWeatherReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
if (!$user) {
throw new \Exception('User is not authenticated');
}
$params = json_decode($request->getContent(), true);
if (!isset($params['report_id'])) {
throw new \Exception('Missing required parameters');
}
$result = $this->reportModel->archiveWeatherReport($this->translator, $user, $params['report_id']);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/update-advance-custom-report", name="api_ncm_report_update_advance_custom_report" , methods={"POST"})
*/
public function updateAdvanceCustomReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang']) || !isset($params['report_id'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
}
$result = $this->reportModel->publishAdvanceCustomReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/update-report", name="api_ncm_report_update_report", methods={"POST"})
*/
public function updateReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang']) || !isset($params['report_id'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/update-arabian-gulf-report", name="api_ncm_report_update_arabian_gulf_report", methods={"POST"})
*/
public function updateArabianGulfReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang']) || !isset($params['report_id'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/update-10-day-forecast-report", name="api_ncm_report_update_10_day_forecast_report", methods={"POST"})
*/
public function update10DayForecastReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang']) || !isset($params['report_id'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/update-red-sea-report", name="api_ncm_report_update_red_sea_report", methods={"POST"})
*/
public function updateRedSeaReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang']) || !isset($params['report_id'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/update-custom-weather-report", name="api_ncm_report_update_custom_weather_report", methods={"POST"})
*/
public function updateCustomWeatherReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang']) || !isset($params['report_id'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
/**
* @Route("/update-mashaer-weather-report", name="api_ncm_report_update_mashaer_weather_report", methods={"POST"})
*/
public function updateMashaerWeatherReport(Request $request, UserInterface $user)
{
try {
$permissions = $this->userPermission->validateAPI($request, $this->tokenStorageInterface, $this->jwtManager, $this->translator);
if (isset($permissions['code']) && $permissions['code'] === 401) {
return $this->json($permissions, 401);
} elseif ($permissions['success'] === false) {
return $this->json($permissions);
}
$params = json_decode($request->getContent(), true);
$this->translator->setlocale(isset($params["lang"]) ? $params["lang"] : DEFAULT_LOCALE);
// Perform parameter validation here
// || !isset($params['locations'])
if (!isset($params['data']) || !isset($params['start_date']) || !isset($params['end_date']) || !isset($params['lang']) || !isset($params['report_id'])) {
return $this->json(['success' => false, 'message' => $this->translator->trans('missing_required_parameters')]);
}
if (isset($params['organizations'])) {
if (!is_array($params['organizations'])) {
throw new \Exception($this->translator->trans('Organizations should be non empty array'), 400);
}
}
if (isset($params['channels'])) {
if (!is_array($params['channels']) || empty($params['channels'])) {
throw new \Exception($this->translator->trans('Channels should be non empty array'), 400);
}
if (in_array('email', $params['channels'])) {
if (!isset($params['emails']) || !is_array($params['emails']) || empty($params['emails'])) {
throw new \Exception($this->translator->trans('Emails should be non empty array'), 400);
}
}
}
$result = $this->reportModel->editReport($user, $params, $this->translator, $this->logger);
return $this->json($result);
} catch (\Exception $ex) {
$this->logger->error($ex->getMessage());
return $this->json(['success' => false, 'message' => $ex->getMessage()]);
}
}
}

src/Controller/ReportController.php line 48