src/Model/ReportLogModel.php line 435

Open in your IDE?
  1. <?php
  3. namespace App\Model;
  5. use Carbon\Carbon;
  6. use App\Lib\Utility;
  7. use App\Service\EmailService;
  8. use Pimcore\Model\DataObject;
  9. use App\Service\UserPermission;
  10. use Pimcore\Model\DataObject\Report;
  11. use Pimcore\Model\DataObject\Customer;
  12. use Pimcore\Model\DataObject\Location;
  13. use Symfony\Component\Process\Process;
  14. use Pimcore\Model\DataObject\ReportLog;
  15. use Pimcore\Model\DataObject\ReportType;
  16. use Pimcore\Model\DataObject\Organization;
  17. use Symfony\Component\HttpFoundation\Request;
  18. use Symfony\Component\Process\Exception\ProcessFailedException;
  19. use Pimcore\Model\Asset;
  21. class ReportLogModel
  22. {
  24.     public function create(string $reportKey, array $param, array $response)
  25.     {
  26.         try {
  28.             // Define an array to store missing parameters
  29.             $missingParameters = [];
  31.             // Define an array of required parameters
  32.             $requiredParameters = [
  33.                 'type_of_report',
  34.                 'lon',
  35.                 'lat',
  36.                 'start_date',
  37.                 'end_date'
  38.             ];
  40.             // Check for missing required parameters
  41.             foreach ($requiredParameters as $parameter) {
  42.                 if (!isset($param[$parameter])) {
  43.                     $missingParameters[] = $parameter;
  44.                 }
  45.             }
  47.             // If there are missing parameters, return them
  48.             if (!empty($missingParameters)) {
  49.                 throw new \Exception("Missing parameters " . implode(",", $missingParameters));
  50.             }
  52.             if (!$response) {
  53.                 throw new \Exception("Response data not available");
  54.             }
  56.             $reportLog = \Pimcore\Model\DataObject\ReportLog::getByReportKey($reportKey, true);
  58.             if (!$reportLog) {
  59.                 $reportLog = new ReportLog();
  60.                 $reportLog->setKey($reportKey);
  61.                 $reportLog->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("ReportLog"));
  62.             }
  63.             $reportLog->setTypeOfReport($param['type_of_report']);
  64.             $reportLog->setLon($param['lon']);
  65.             $reportLog->setLat($param['lat']);
  66.             $reportLog->setStartDate(Carbon::parse(new \DateTime($param['start_date'])));
  67.             $reportLog->setEndDate(Carbon::parse(new \Datetime($param['end_date'])));
  68.             $reportLog->setIsPublished(true);
  69.             $reportLog->setPublished(true);
  70.             $reportLog->setReportKey($reportKey);
  71.             $reportLog->setResponseData(json_encode($response));
  72.             $reportLog->save();
  73.             return ["success" => true, "data" => $reportLog->getReportKey()];
  74.         } catch (\Exception $ex) {
  75.             return ["success" => false, "message" => $ex->getMessage()];
  76.         }
  77.     }
  80.     public function getReportLog($param)
  81.     {
  82.         $key = $this->createKey($param);
  83.         $reportLog = \Pimcore\Model\DataObject\ReportLog::getByReportKey($key, true);
  84.         return $reportLog;
  85.     }
  87.     public function deleteReport($param)
  88.     {
  89.         $reportLog = $this->getReportLog($param);
  90.         if ($reportLog) {
  91.             $reportLog->delete();
  92.             return true;
  93.         }
  94.         return false;
  95.     }
  97.     public function createKey($param)
  98.     {
  99.         return md5(implode(",", $param));
  100.     }
  101.     public function editReport($user, $params, $translator, $logger)
  102.     {
  103.         try {
  104.             $cityNames = '';
  106.             if (!empty($params['locations'])) {
  108.                 // if governorate is true then get the cities from governorate else get the cities from city
  109.                 if (isset($params['is_governate']) && $params['is_governate']) {
  110.                     $cities = new \Pimcore\Model\DataObject\Governorate\Listing();
  111.                     if (!empty($params['locations'])) {
  112.                         $cities->setCondition('governoteId IN (?)', [$params['locations']]);
  113.                     }
  114.                 } else {
  115.                     $cities = new \Pimcore\Model\DataObject\City\Listing();
  116.                     if (!empty($params['locations'])) {
  117.                         $cities->setCondition('o_id IN (?)', [$params['locations']]);
  118.                     }
  119.                 }
  121.                 $cities->load();
  123.                 $locations = new \Pimcore\Model\DataObject\Location\Listing();
  124.                 $locations->setCondition('o_id IN (?)', [$params['locations']]);
  125.                 $locations->load();
  127.                 if ($cities->getCount() > 0) {
  128.                     foreach ($cities as $city) {
  129.                         // if governorate is true then get the cities from governorate else get the cities from city
  130.                         if ($params['is_governate']) {
  131.                             $nameEN = $city->getName('en');
  132.                             $nameAR = $city->getName('ar');
  133.                         } else {
  135.                             $nameEN = $city->getCityName('en');
  136.                             $nameAR = $city->getCityName('ar');
  137.                         }
  139.                         $cityNames .= !empty($nameEN) ? $nameEN . ',' : '';
  140.                         $cityNames .= !empty($nameAR) ? $nameAR . ',' : '';
  141.                     }
  142.                 } elseif ($locations->getCount() > 0) {
  143.                     foreach ($locations as $location) {
  144.                         $cityNames .= !empty($location->getName()) ? $location->getName() . ',' : '';
  145.                     }
  146.                 } else {
  147.                     return ["success" => false, "message" => "invalid_location"];
  148.                 }
  150.                 // Remove the trailing comma
  151.                 $cityNames = rtrim($cityNames, ',');
  152.             }
  153.             if (isset($params['report_id'])) {
  154.                 $report = Report::getById($params['report_id'], true);
  155.                 if (!$report instanceof Report) {
  156.                     return ["success" => false, "message" => "invalid_report_id"];
  157.                 }
  158.             } else {
  160.                 $report = new Report();
  161.                 $report->setKey(\Pimcore\Model\Element\Service::getValidKey($user->getEmail() . time(), 'object'));
  162.                 $report->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Report/Report"));
  163.             }
  164.             $reportType = '';
  165.             $report->setCreatedBy($user);
  166.             $report->setCreatedOn(Carbon::now());
  167.             $report->setStartDate(Carbon::parse(new \DateTime($params['start_date'])));
  168.             $report->setEndDate(Carbon::parse(new \Datetime($params['end_date'])));
  169.             $report->setSearchData($cityNames);
  170.             $report->setLang($params['lang']);
  171.             // $report->setEmail($user->getEmail());
  172.             $report->setJsonData(json_encode($params['data']));
  173.             if (isset($params['report_title'])) {
  174.                 $report->setReportTitle($params['report_title'], "en");
  175.             }
  176.             if (isset($params['report_title_ar'])) {
  177.                 $report->setReportTitle($params['report_title_ar'], "ar");
  178.             }
  179.             if (isset($params['surface_wind'])) {
  180.                 $report->setSurfaceWind($params['surface_wind'], "en");
  181.             }
  182.             if (isset($params['wave_height'])) {
  183.                 $report->setWaveHeight($params['wave_height'], "en");
  184.             }
  185.             if (isset($params['state_of_the_sea'])) {
  186.                 $report->setStateOfTheSea($params['state_of_the_sea'], "en");
  187.             }
  188.             if (isset($params['surface_wind_ar'])) {
  189.                 $report->setSurfaceWind($params['surface_wind_ar'], "ar");
  190.             }
  191.             if (isset($params['wave_height_ar'])) {
  192.                 $report->setWaveHeight($params['wave_height_ar'], "ar");
  193.             }
  194.             if (isset($params['state_of_the_sea_ar'])) {
  195.                 $report->setStateOfTheSea($params['state_of_the_sea_ar'], "ar");
  196.             }
  198.             if (isset($params['reportDisclaimerEn'])) {
  199.                 $report->setReportDisclaimer($params['reportDisclaimerEn'], "en");
  200.             }
  201.             if (isset($params['reportDisclaimerAr'])) {
  202.                 $report->setReportDisclaimer($params['reportDisclaimerAr'], "ar");
  203.             }
  205.             if (isset($params['additionalNoteEn'])) {
  206.                 $report->setAdditionalNote($params['additionalNoteEn'], "en");
  207.             }
  208.             if (isset($params['additionalNoteAr'])) {
  209.                 $report->setAdditionalNote($params['additionalNoteAr'], "ar");
  210.             }
  212.             if (isset($params['publishOnPdf'])) {
  213.                 $report->setPublishOnPdf($params['publishOnPdf'] == true  ? true : false);
  214.             }
  216.             if (isset($params['is_governate']) && $params['is_governate']) {
  217.                 $report->setIsGovernorates(true);
  218.             }
  219.             if (!empty($params['xCaption'])) {
  220.                 $report->setTwitterDescription($params['xCaption']);
  221.             }
  223.             if (isset($params['report_type_id'])) {
  224.                 $reportType = ReportType::getById($params['report_type_id'], true);
  225.                 if ($reportType instanceof ReportType) {
  226.                     $report->setReportType($reportType);
  227.                     // if ($reportType->getKey() != 'CustomWeatherReport' || $reportType->getKey() != 'MashaerWeatherReport') {
  228.                     //     $report->setForPublicPortal(true);
  229.                     //     $report->setForAjwaaPortal(true);
  230.                     // }
  232.                     if ($reportType->getReportKey() != 'arabian-gulf-report' || $reportType->getKey() != 'red-sea-report') {
  233.                         $report->setForPublicPortal(true);
  234.                         $report->setForAjwaaPortal(true);
  235.                     }
  236.                 }
  237.             }
  238.             if (!empty($params['organizations'])) {
  239.                 $selectedOrganizations = [];
  240.                 if ($params['organizations'][0] == 0) {
  241.                     $organizations = new Organization\Listing();
  242.                     if ($organizations->count() > 0) {
  243.                         foreach ($organizations as $organization) {
  244.                             if ($organization) {
  245.                                 $selectedOrganizations[] = $organization;
  246.                             }
  247.                         }
  248.                         $report->setOrganization($selectedOrganizations);
  249.                     }
  250.                 } else {
  251.                     foreach ($params['organizations'] as $organization) {
  252.                         $organizationObject = Organization::getById($organization, true);
  253.                         if ($organizationObject) {
  254.                             $selectedOrganizations[] = $organizationObject;
  255.                         }
  256.                     }
  258.                     $report->setOrganization($selectedOrganizations);
  259.                 }
  260.             }
  261.             $emails = "";
  262.             if (!empty($params['channels'])) {
  263.                 $channels = ['public_portal', 'ajwaa_portal', 'email', 'twitter', 'sms'];
  264.                 foreach ($params['channels'] as $channel) {
  265.                     if ($channel == 'public_portal') {
  266.                         $report->setForPublicPortal(true);
  267.                     } elseif ($channel == 'ajwaa_portal') {
  268.                         $report->setForAjwaaPortal(true);
  269.                         if (isset($params['send_email'])) {
  270.                             $report->setSendEmail(true);
  271.                         }
  272.                     } elseif ($channel == 'email') {
  273.                         $report->setForEmailChannel(true);
  274.                         $emails .= implode(",", $params['emails']);
  275.                     } elseif ($channel == 'twitter') {
  276.                         $report->setForTwitterChannel(true);
  277.                     }
  278.                 }
  279.             }
  280.             $emailArray = [];
  281.             if (isset($params['user_group_ids']) && !empty($params['user_group_ids'])) {
  282.                 $userGroupIds = ($params['user_group_ids']);
  284.                 foreach ($userGroupIds as $userGroupId) {
  285.                     if ($userGroupId) {
  287.                         $userGroup = \Pimcore\Model\DataObject\EwsAndReportUserGroup::getById($userGroupId, true);
  288.                         if ($userGroup instanceof \Pimcore\Model\DataObject\EwsAndReportUserGroup) {
  290.                             foreach (json_decode($userGroup->getJsonData()) as $currentUser) {
  292.                                 if (isset($currentUser->email)) {
  293.                                     $report->setForEmailChannel(true);
  295.                                     $emailArray[] = $currentUser->email;
  296.                                 }
  297.                             }
  298.                         }
  299.                     }
  300.                 }
  301.             }
  302.             if (!empty($emailArray)) {
  303.                 if (!empty($emails)) {
  304.                     $emails .= ',' . implode(',', $emailArray);
  305.                 } else {
  306.                     $emails = implode(',', $emailArray);
  307.                 }
  308.             }
  309.             $report->setEmails($emails);
  310.             $report->setPublished(true);
  312.             //schedule report
  313.             if (isset($params['is_schedule']) && $params['is_schedule'] && isset($params['schedule_date'])) {
  314.                 $report->setIsSchedule($params['is_schedule']);
  316.                 //  dd($params['schedule_date']);
  317.                 //  dd(Carbon::parse($params['schedule_date'], 'Asia/Riyadh'));
  318.                 //exit;
  319.                 $report->setScheduleDate(Carbon::parse($params['schedule_date'])->subHours(5));
  320.                 $report->setPublished(false);
  321.             } else {
  322.                 $report->setPublished(true);
  323.             }
  324.             // just to show title in public portal as description
  325.             $report->setShowPublicDescription(isset($params['show_public_description']) && $params['show_public_description'] === true);
  327.             // delete the existing pdf if report is updated
  328.             if (isset($params['report_id'])) {
  329.                 $pdfEn = $report->getAsset();
  330.                 $pdfAr = $report->getAssetAr();
  332.                 if ($pdfEn instanceof Asset) {
  333.                     $pdfEn->delete();
  334.                 }
  335.                 if ($pdfAr instanceof Asset) {
  336.                     $pdfAr->delete();
  337.                 }
  338.             }
  339.             $report->save();
  340.             //$phpPath = 'D:\laragon\bin\php\php-8.1.10-Win32-vs16-x64\php.exe'; // Adjust to the actual PHP path on your system
  341.             $consolePath = 'bin\console'; // Use backslashes for Windows paths
  343.             $commandArguments = ['bin/console', 'app:today-weather-pdf'];
  344.             if (!empty($reportType)) {
  345.                 if ($reportType->getKey() != 'CustomWeatherReport' || $reportType->getKey() != 'MashaerWeatherReport') {
  346.                     $process = new Process($commandArguments);
  347.                     $process->setWorkingDirectory(PIMCORE_PROJECT_ROOT);
  348.                     try {
  349.                         $process->mustRun();
  350.                         $logger->info("Today Weather command executed successfully: " . $process->getOutput());
  351.                         // p_r("Today Weather command executed successfully: " . $process->getOutput());exit;
  352.                         $result['success'] = true;
  353.                         $result['message'] = $process->getOutput();
  354.                     } catch (ProcessFailedException $exception) {
  355.                         $logger->error("Today Weather command failed: " . $exception->getMessage());
  356.                         // p_r("Today Weather command failed: " . $exception->getMessage());exit;
  358.                         $result['success'] = false;
  359.                         $result['message'] = "Failed to execute notification command.";
  360.                     }
  361.                 }
  362.             }
  365.             if (isset($params['report_id'])) {
  366.                 return ["success" => true, "message" => $translator->trans("report_updated_successfully"), "data" => $report->getId()];
  367.             } else {
  368.                 return ["success" => true, "message" => $translator->trans("report_published_successfully"), "data" => $report->getId()];
  369.             }
  370.         } catch (\Exception $ex) {
  371.             return ["success" => false, "message" => $ex->getMessage()];
  372.         }
  373.     }
  374.     public function reportList($params, $page, $limit, $translator, $paginator, $report_type, $user, $lang, $is_public = true): array
  375.     {
  377.         $result = [];
  378.         try {
  379.             // Load blog listing
  380.             $reportList = new DataObject\Report\Listing();
  381.             $search = isset($params['search']) ? $params['search'] : '';
  383.             if ($report_type == 'mannforecast') {
  384.                 if (!empty($search)) {
  386.                     $db = \Pimcore\Db::get();
  387.                     $selectedLocalities = $db->fetchAllAssociative(
  388.                         "SELECT oo_id FROM `object_query_customer` WHERE (`name` LIKE ? OR `email` LIKE ?)",
  389.                         ["%" . $search . "%", "%" . $search . "%"]
  390.                     );
  391.                     $ooIds = array_column($selectedLocalities, 'oo_id');
  392.                     $reportList->setCondition(
  393.                         "((reportType__id IS NULL) AND (isHistorical IN (?)) AND (createdBy__id IN (?) OR searchData LIKE ?))",
  394.                         [
  395.                             [false, null],
  396.                             $ooIds,
  397.                             '%' . $search . '%',
  398.                         ]
  399.                     );
  400.                 } else {
  401.                     $reportList->setCondition(
  402.                         "((reportType__id IS NULL) AND (isHistorical IN (?)))",
  403.                         [
  404.                             [false, null]
  406.                         ]
  407.                     );
  408.                 }
  409.             } elseif ($report_type == 'historical') {
  410.                 if (!empty($search)) {
  411.                     $db = \Pimcore\Db::get();
  412.                     $selectedLocalities = $db->fetchAllAssociative(
  413.                         "SELECT oo_id FROM `object_query_customer` WHERE (`name` LIKE ? OR `email` LIKE ?)",
  414.                         ["%" . $search . "%", "%" . $search . "%"]
  415.                     );
  416.                     $ooIds = array_column($selectedLocalities, 'oo_id');
  417.                     $reportList->setCondition(
  418.                         "((reportType__id IS NULL) AND (isHistorical = ?) AND (createdBy__id = ?) AND  (searchData LIKE ?) )",
  419.                         [
  420.                             true,
  421.                             $user->getId(),
  422.                             '%' . $search . '%'
  423.                         ]
  424.                     );
  425.                 } else {
  426.                     $reportList->setCondition("((reportType__id IS NULL)  AND (createdBy__id = ?) AND (isHistorical = ?))", [$user->getId(), true]);
  427.                 }
  428.             } elseif ($report_type == 'advamced_report_and_custom_report') {
  429.                 // Define the report keys you want to check
  430.                 $reportKeys = ['advance-custom-weather-report', 'custom-weather-report'];
  431.                 $reportTypeIds = [];
  433.                 // Loop through each report key and fetch the report type if it exists
  434.                 foreach ($reportKeys as $key) {
  435.                     $reportType = ReportType::getByReportKey($key, true);
  436.                     if ($reportType instanceof ReportType) {
  437.                         $reportTypeIds[] = $reportType->getId();
  438.                     }
  439.                 }
  441.                 // If there are any valid report type IDs, set the condition with them
  442.                 if (!empty($reportTypeIds)) {
  443.                     $reportList->setCondition(
  444.                         "(reportType__id IN (?))",
  445.                         [$reportTypeIds]
  446.                     );
  447.                 }
  448.             } elseif ($is_public) {
  450.                 // this if logic is totally build for public portal to get all reports according to the report type key here we are sening the array in report_type variable except other report type whic is string
  451.                 // Define the report keys you want to check
  452.                 foreach ($report_type as $key) {
  453.                     $reportType = ReportType::getByReportKey($key, true);
  454.                     if ($reportType instanceof ReportType) {
  455.                         $reportTypeIds[] = $reportType->getId();
  456.                     }
  457.                 }
  459.                 // If there are any valid report type IDs, set the condition with them
  460.                 if (!empty($reportTypeIds)) {
  461.                     $reportList->setCondition(
  462.                         "(reportType__id IN (?)) AND forPublicPortal = ?",
  463.                         [$reportTypeIds, true]
  464.                     );
  465.                 } else {
  467.                     $reportList->setCondition(
  468.                         "forPublicPortal = ?",
  469.                         [true]
  470.                     );
  471.                 }
  472.             } else {
  474.                 if (!empty($search)) {
  475.                     $db = \Pimcore\Db::get();
  476.                     $selectedLocalities = $db->fetchAllAssociative(
  477.                         "SELECT oo_id FROM `object_query_customer` WHERE (`name` LIKE ? OR `email` LIKE ?)",
  478.                         ["%" . $search . "%", "%" . $search . "%"]
  479.                     );
  480.                     $selectedReportTypes = new ReportType\Listing();
  481.                     $selectedReportTypes->setLocale($lang);
  482.                     $selectedReportTypes->setCondition(
  483.                         "(name LIKE ?)",
  484.                         [
  485.                             '%' . $search . '%'
  486.                         ]
  487.                     );
  488.                     $selectedReportTypes->load();
  489.                     $report_types = [];
  490.                     foreach ($selectedReportTypes as $reportType) {
  491.                         array_push($report_types, $reportType->getId());
  492.                     }
  493.                     // p_r($selectedReportTypes);exit;
  494.                     $organization = $user->getOrganization()?->getId();
  495.                     $ooIds = array_column($selectedLocalities, 'oo_id');
  496.                     $reportList->setLocale($params['lang']);
  497.                     $reportList->addConditionParam(
  498.                         "((reportType__id IS NOT NULL) AND (createdBy__id IN (?) OR reportType__id IN (?) OR reportTitle LIKE ?))",
  499.                         [
  501.                             $ooIds,
  502.                             $report_types,
  503.                             '%' . $search . '%'
  504.                         ]
  505.                     );
  506.                     if ($is_public) {
  507.                         $reportList->addConditionParam(
  508.                             "(forPublicPortal = ?)",
  509.                             [
  510.                                 true
  511.                             ]
  512.                         );
  513.                     }
  514.                 } else {
  515.                     $organization = $user->getOrganization()?->getId();
  516.                     $reportList->addConditionParam("reportType__id IS NOT NULL");
  517.                     if ($is_public) {
  518.                         $reportList->addConditionParam(
  519.                             "(forPublicPortal = ?)",
  520.                             [
  521.                                 true
  522.                             ]
  523.                         );
  524.                     }
  525.                 }
  526.             }
  528.             $sortOrderCreatedAt = $params['sortByCreated'] ?? 'desc';
  529.             $reportList->setOrderKey('createdOn')
  530.                 ->setOrder($sortOrderCreatedAt);
  531.             if (count($reportList) > 0) {
  532.                 // set pagination
  533.                 $paginate = $paginator->paginate(
  534.                     $reportList,
  535.                     $page,
  536.                     $limit
  537.                 );
  538.                 return $this->getReportListData($paginate);
  539.             }
  541.             return ["success" => false, "message" => $translator->trans("no_report_is_available")];
  542.         } catch (\Exception $ex) {
  543.             throw new \Exception($ex->getMessage());
  544.         }
  545.         return $result;
  546.     }
  549.     public function listReportsByType($params, $translator, $paginator): array
  550.     {
  553.         $page = $params['page'];
  554.         $limit = $params['limit'];
  555.         $lang = $params['lang'] ?? 'en';
  556.         $search = isset($params['search']) ? $params['search'] : '';
  557.         $db = \Pimcore\Db::get();
  559.         // Define the report keys you want to check
  560.         $reportTypeIds = [];
  562.         // Loop through each report key and fetch the report type if it exists
  563.         foreach ($params['allowedReportTypes'] as $key) {
  564.             $reportType = ReportType::getByReportKey($key, true);
  565.             if ($reportType instanceof ReportType) {
  566.                 $reportTypeIds[] = $reportType->getId();
  567.             }
  568.         }
  570.         // If no allowed report types resolved, return empty result to avoid IN (NULL)
  571.         if (empty($reportTypeIds)) {
  572.             $paginate = $paginator->paginate([], $page, $limit);
  573.             return ["success" => true, "data" => [], "paginationVariables" => $paginate->getPaginationData()];
  574.         }
  576.         // Resolve class ids
  577.         $class = new \Pimcore\Model\DataObject\ClassDefinition();
  578.         $reportClassId = $class->getDao()->getIdByName('Report');
  579.         $reportTypeClassId = $class->getDao()->getIdByName('ReportType');
  581.         // Build query with proper joins for localized and relation fields
  582.         $select = $db->createQueryBuilder();
  583.         $select->select('report.oo_id')
  584.             ->from('object_' . $reportClassId, 'report')
  585.             ->where('report.reportType__id IS NOT NULL AND o_published =1')
  586.             ->andWhere('report.reportType__id IN (:reportTypeIds)')
  587.             ->setParameter('reportTypeIds', $reportTypeIds, \Doctrine\DBAL\Connection::PARAM_INT_ARRAY);
  589.         // Title search (localized)
  590.         if (!empty($search)) {
  591.             $select->leftJoin('report', 'object_localized_query_' . $reportClassId . '_' . $lang, 'rq', 'rq.ooo_id = report.oo_id');
  592.             $select->andWhere('rq.reportTitle LIKE ' . $db->quote('%' . $search . '%'));
  593.         }
  595.         // Sorting
  596.         $sortBy = $params['orderKey'] ?? ($params['sortBy'] ?? 'createdOn');
  597.         $sortOrder = strtoupper($params['order'] ?? ($params['sortByCreated'] ?? 'desc')) === 'ASC' ? 'ASC' : 'DESC';
  599.         switch ($sortBy) {
  600.             case 'reportType':
  601.                 $select->leftJoin('report', 'object_localized_query_' . $reportTypeClassId . '_' . $lang, 'rtq', 'rtq.ooo_id = report.reportType__id');
  602.                 $select->addSelect('rtq.name AS reportType_name');
  603.                 $select->orderBy('reportType_name', $sortOrder);
  604.                 break;
  605.             case 'title':
  606.                 $select->leftJoin('report', 'object_localized_query_' . $reportClassId . '_' . $lang, 'rq_sort', 'rq_sort.ooo_id = report.oo_id');
  607.                 $select->addSelect('rq_sort.reportTitle AS localized_title');
  608.                 $select->orderBy('localized_title', $sortOrder);
  609.                 break;
  610.             case 'email':
  611.                 $select->leftJoin('report', 'object_query_customer', 'cbq', 'cbq.oo_id = report.createdBy__id');
  612.                 $select->addSelect('cbq.email AS createdBy_email');
  613.                 $select->orderBy('createdBy_email', $sortOrder);
  614.                 break;
  615.             case 'createdOn':
  616.             default:
  617.                 $select->orderBy('report.createdOn', $sortOrder);
  618.                 break;
  619.         }
  621.         // Avoid duplicates
  622.         $select->groupBy('report.oo_id');
  624.         $paginate = $paginator->paginate($select, $page, $limit);
  625.         return $this->getReportTypeListData($params['decodedJwtToken'], $params['userPermission'], $paginate, $translator);
  626.     }
  627.     public function listAutomaticReports($params, $user, $search, $orderKey, $order, $translator, $paginator)
  628.     {
  629.         $result = [];
  630.         try {
  632.             $organization = $user->getOrganization();
  633.             if (!$organization instanceof Organization) {
  634.                 return ["success" => false, "message" => $translator->trans("no_organization_is_available_to_this_user")];
  635.             }
  637.             $organizationId = $user->getOrganization()?->getId();
  638.             $reportList = new DataObject\Report\Listing();
  639.             if (isset($params['report_type_id'])) {
  640.                 $reportList->addConditionParam("(reportType__id = ?) AND (forAjwaaPortal = ?) AND (organization IS NULL OR organization LIKE ?)", [$params['report_type_id'], true, '%' . $organizationId . '%']);
  641.             } else {
  642.                 $reportList->addConditionParam("(reportType__id IS NOT NULL) AND (forAjwaaPortal = ?) AND (organization IS NULL OR organization LIKE ?)", [true, '%' . $organizationId . '%']);
  643.             }
  644.             if ($search) {
  645.                 $reportList->setLocale($params['lang']);
  646.                 $reportList->addConditionParam(
  647.                     "reportTitle LIKE ?",
  648.                     ['%' . $search . '%']
  649.                 );
  650.             }
  652.             if (isset($params['startDate']) && isset($params['endDate']) && !empty($params['startDate']) && !empty($params['endDate'])) {
  653.                 $startDate = new \DateTime($params['startDate']);
  654.                 $endDate = new \DateTime($params['endDate']);
  656.                 // Ensure the dates are in the correct format
  657.                 $startDateStr = strtotime($startDate->format('Y-m-d H:i:s'));
  658.                 $endDateStr = strtotime($endDate->format('Y-m-d') . ' 23:59:59');
  660.                 $reportList->addConditionParam(
  661.                     "(createdOn >= ? AND createdOn <= ?)",
  662.                     [$startDateStr, $endDateStr]
  663.                 );
  664.             }
  665.             $reportList->setOrderKey($orderKey)
  666.                 ->setOrder($order);
  667.             if (count($reportList) > 0) {
  668.                 // set pagination
  669.                 $paginate = $paginator->paginate(
  670.                     $reportList,
  671.                     $params['page'],
  672.                     $params['limit']
  673.                 );
  674.                 return $this->getReportListData($paginate);
  675.             }
  676.             return ["success" => false, "message" => $translator->trans("no_report_is_available")];
  677.         } catch (\Exception $ex) {
  678.             throw new \Exception($ex->getMessage());
  679.         }
  680.         return $result;
  681.     }
  683.     public function listAutomaticPublicReports($params, $user, $search, $orderKey, $order, $translator, $paginator)
  684.     {
  685.         $result = [];
  686.         try {
  688.             $organization = $user->getOrganization();
  689.             if (!$organization instanceof Organization) {
  690.                 return ["success" => false, "message" => $translator->trans("no_organization_is_available_to_this_user")];
  691.             }
  693.             $organizationId = $user->getOrganization()?->getId();
  694.             $reportList = new DataObject\Report\Listing();
  695.             if (isset($params['report_type_id'])) {
  696.                 $reportList->addConditionParam("(reportType__id = ?) AND (forAjwaaPortal = ?)", [$params['report_type_id'], true]);
  697.             } else {
  698.                 $reportList->addConditionParam("(reportType__id IS NOT NULL) AND (forAjwaaPortal = ?)", [true]);
  699.             }
  700.             if ($search) {
  701.                 $reportList->setLocale($params['lang']);
  702.                 $reportList->addConditionParam(
  703.                     "reportTitle LIKE ?",
  704.                     ['%' . $search . '%']
  705.                 );
  706.             }
  708.             if (isset($params['startDate']) && isset($params['endDate']) && !empty($params['startDate']) && !empty($params['endDate'])) {
  709.                 $startDate = new \DateTime($params['startDate']);
  710.                 $endDate = new \DateTime($params['endDate']);
  712.                 // Ensure the dates are in the correct format
  713.                 $startDateStr = strtotime($startDate->format('Y-m-d H:i:s'));
  714.                 $endDateStr = strtotime($endDate->format('Y-m-d') . ' 23:59:59');
  716.                 $reportList->addConditionParam(
  717.                     "(createdOn >= ? AND createdOn <= ?)",
  718.                     [$startDateStr, $endDateStr]
  719.                 );
  720.             }
  721.             $reportList->setOrderKey($orderKey)
  722.                 ->setOrder($order);
  723.             if (count($reportList) > 0) {
  724.                 // set pagination
  725.                 $paginate = $paginator->paginate(
  726.                     $reportList,
  727.                     $params['page'],
  728.                     $params['limit']
  729.                 );
  730.                 return $this->getReportListData($paginate);
  731.             }
  732.             return ["success" => false, "message" => $translator->trans("no_report_is_available")];
  733.         } catch (\Exception $ex) {
  734.             throw new \Exception($ex->getMessage());
  735.         }
  736.         return $result;
  737.     }
  739.     /**
  740.      * Get Latest MannForecastReport
  741.      */
  742.     public function getLatestReport($reportType, $translator, $isPublic = true)
  743.     {
  745.         $mannforecastReportType = ReportType::getByReportKey($reportType, true);
  746.         if (!$mannforecastReportType) {
  747.             return ["success" => false, "message" => $translator->trans("report_type_not_created")];
  748.         }
  749.         $mannforecastReport = new Report\Listing();
  750.         $mannforecastReport->addConditionParam(
  751.             "reportType__id = ?",
  752.             [$mannforecastReportType->getId()]
  753.         );
  754.         if (!$isPublic) {
  755.             $mannforecastReport->addConditionParam(
  756.                 "(forPublicPortal = ?)",
  757.                 [
  758.                     true
  759.                 ]
  760.             );
  761.         }
  763.         $mannforecastReport->setOrderKey('createdOn');
  764.         $mannforecastReport->setOrder('desc');
  765.         $latestReport = $mannforecastReport->current();
  766.         if (!$latestReport) {
  767.             return ["success" => false, "message" => $translator->trans("no_latest_report_found")];
  768.         } else {
  769.             $data = [];
  770.             $data = [
  771.                 'id' => $latestReport->getId(),
  772.                 'name' => $latestReport->getCreatedBy()?->getName(),
  773.                 'email' => $latestReport->getCreatedBy()?->getEmail(),
  774.                 'jsonData' => json_decode($latestReport->getJsonData(), true),
  775.                 'createdOn' => $latestReport->getCreatedOn(),
  776.                 'reportTitle' => $latestReport->getReportTitle("en"),
  777.                 'stateOfTheSea' => $latestReport->getStateOfTheSea("en"),
  778.                 'waveHeight' => $latestReport->getWaveHeight("en"),
  779.                 'surfaceWind' => $latestReport->getSurfaceWind("en"),
  780.                 'reportTitleAr' => $latestReport->getReportTitle("ar"),
  781.                 'stateOfTheSeaAr' => $latestReport->getStateOfTheSea("ar"),
  782.                 'waveHeightAr' => $latestReport->getWaveHeight("ar"),
  783.                 'surfaceWindAr' => $latestReport->getSurfaceWind("ar"),
  784.                 'showTenDayDescription' => $latestReport->getShowPublicDescription(),
  785.                 'isGovernorates' => $latestReport->getIsGovernorates() == true ? true : false
  786.             ];
  788.             return ['success' => true, 'data' => $data];
  789.         }
  790.     }
  792.     public function getReportListData($paginate)
  793.     {
  794.         $reportListData = [];
  795.         foreach ($paginate as $key => $reportlist) {
  796.             $asset_path = $reportlist->getAsset()?->getPath() . $reportlist->getAsset()?->getFileName() ? API_BASE_URL . $reportlist->getAsset()?->getPath() . $reportlist->getAsset()?->getFileName() : '';
  797.             $asset_path_ar = $reportlist->getAssetAr()?->getPath() . $reportlist->getAssetAr()?->getFileName() ? API_BASE_URL . $reportlist->getAssetAr()?->getPath() . $reportlist->getAssetAr()?->getFileName() : '';
  799.             $reportTitleEn = $reportlist->getReportType()?->getReportKey() == "10-day-forecast-report" ? "10-Day Forecast Report" : $reportlist->getReportTitle('en');
  800.             $reportTitleAr = $reportlist->getReportType()?->getReportKey() == "10-day-forecast-report" ? "توقعات Ù„مدة 10 Ø£ÙŠØ§Ù…" : $reportlist->getReportTitle('ar');
  803.             if ($reportlist->getReportType()?->getReportKey() == "advance-custom-weather-report") {
  804.                 if ($reportlist->getIsMannedReport()) {
  805.                     $isMannedReport = true;
  806.                 } else {
  807.                     $isMannedReport = false;
  808.                 }
  809.             } else {
  810.                 $isMannedReport = null;
  811.             }
  813.             $reportListData[$key] = [
  814.                 'id' => $reportlist->getId(),
  815.                 'createdBy' => $reportlist->getCreatedBy()?->getName(),
  816.                 'email' => $reportlist->getCreatedBy()?->getEmail(),
  817.                 'createdOn' => $reportlist->getCreatedOn(),
  818.                 'startDate' => $reportlist->getStartDate('Y-m-d H:i:s'),
  819.                 'endDate' => $reportlist->getEndDate('Y-m-d H:i:s'),
  820.                 'report' => json_decode($reportlist->getJsonData(), true),
  821.                 'reportTypeEn' => $reportlist->getReportType()?->getName('en'),
  822.                 'reportTypeAr' => $reportlist->getReportType()?->getName('ar'),
  823.                 'reportTypeId' => $reportlist->getReportType()?->getId(),
  824.                 'reportTypeKey' => $reportlist->getReportType()?->getReportKey(),
  825.                 'reportTitleEn' => $reportTitleEn,
  826.                 'reportTitleAr' => $reportTitleAr,
  827.                 'reportDescriptionAr' => $reportlist->getDescription('ar'),
  828.                 'reportDescriptionEn' => $reportlist->getDescription('en'),
  829.                 'isMannedAdvanceCustomReport' => $isMannedReport,
  830.                 'stateOfTheSeaEn' => $reportlist->getStateOfTheSea('en'),
  831.                 'stateOfTheSeaAr' => $reportlist->getStateOfTheSea('ar'),
  832.                 'surfaceWindEn' => $reportlist->getSurfaceWind('en'),
  833.                 'surfaceWindAr' => $reportlist->getSurfaceWind('ar'),
  834.                 'waveHeightEn' => $reportlist->getWaveHeight('en'),
  835.                 'waveHeightAr' => $reportlist->getWaveHeight('ar'),
  836.                 'asset' => $asset_path,
  837.                 'assetAr' => $asset_path_ar,
  838.                 'isAWSReport' => $reportlist->getIsAWSReport(),
  840.             ];
  842.             // 15-Day Forecast Report
  843.             if ($reportlist->getReportType()?->getReportKey() == "15-day-forecast-report") {
  844.                 $reportListData[$key]['reportDescriptionEn']  = $reportlist->getReportTitle('en');
  845.                 $reportListData[$key]['reportDescriptionAr']  = $reportlist->getReportTitle('ar');
  846.             }
  847.         }
  848.         return ["success" => true, "data" => $reportListData, "paginationVariables" => $paginate->getPaginationData()];
  849.     }
  852.     public function getReportTypeListData($decodedJwtToken, $userPermission, $paginate, $translator)
  853.     {
  854.         $reportListData = [];
  855.         foreach ($paginate as $key => $row) {
  856.             $reportlist = \Pimcore\Model\DataObject\Report::getById($row['oo_id'], true);
  857.             if (!$reportlist instanceof \Pimcore\Model\DataObject\Report) {
  858.                 continue;
  859.             }
  860.             $asset_path = $reportlist->getAsset()?->getPath() . $reportlist->getAsset()?->getFileName() ? API_BASE_URL . $reportlist->getAsset()?->getPath() . $reportlist->getAsset()?->getFileName() : '';
  861.             $asset_path_ar = $reportlist->getAssetAr()?->getPath() . $reportlist->getAssetAr()?->getFileName() ? API_BASE_URL . $reportlist->getAssetAr()?->getPath() . $reportlist->getAssetAr()?->getFileName() : '';
  863.             $reportTitleEn = $reportlist->getReportType()?->getReportKey() == "10-day-forecast-report" ? "10-Day Forecast Report" : $reportlist->getReportTitle('en');
  864.             $reportTitleAr = $reportlist->getReportType()?->getReportKey() == "10-day-forecast-report" ? "توقعات Ù„مدة 10 Ø£ÙŠØ§Ù…" : $reportlist->getReportTitle('ar');
  867.             if ($reportlist->getReportType()?->getReportKey() == "advance-custom-weather-report") {
  868.                 if ($reportlist->getIsMannedReport()) {
  869.                     $isMannedReport = true;
  870.                 } else {
  871.                     $isMannedReport = false;
  872.                 }
  873.             } else {
  874.                 $isMannedReport = null;
  875.             }
  877.             $reportListData[$key] = [
  878.                 'id' => $reportlist->getId(),
  879.                 'createdBy' => $reportlist->getCreatedBy()?->getName(),
  880.                 'email' => $reportlist->getCreatedBy()?->getEmail(),
  881.                 'createdOn' => $reportlist->getCreatedOn(),
  882.                 'startDate' => $reportlist->getStartDate('Y-m-d H:i:s'),
  883.                 'endDate' => $reportlist->getEndDate('Y-m-d H:i:s'),
  884.                 'report' => json_decode($reportlist->getJsonData(), true),
  885.                 'reportTypeEn' => $reportlist->getReportType()?->getName('en'),
  886.                 'reportTypeAr' => $reportlist->getReportType()?->getName('ar'),
  887.                 'reportTypeId' => $reportlist->getReportType()?->getId(),
  888.                 'reportTypeKey' => $reportlist->getReportType()?->getReportKey(),
  889.                 'reportTitleEn' => $reportTitleEn,
  890.                 'reportTitleAr' => $reportTitleAr,
  891.                 'reportDescriptionAr' => $reportlist->getDescription('ar'),
  892.                 'reportDescriptionEn' => $reportlist->getDescription('en'),
  893.                 'isMannedAdvanceCustomReport' => $isMannedReport,
  894.                 'stateOfTheSeaEn' => $reportlist->getStateOfTheSea('en'),
  895.                 'stateOfTheSeaAr' => $reportlist->getStateOfTheSea('ar'),
  896.                 'surfaceWindEn' => $reportlist->getSurfaceWind('en'),
  897.                 'surfaceWindAr' => $reportlist->getSurfaceWind('ar'),
  898.                 'waveHeightEn' => $reportlist->getWaveHeight('en'),
  899.                 'waveHeightAr' => $reportlist->getWaveHeight('ar'),
  900.                 'asset' => $asset_path,
  901.                 'assetAr' => $asset_path_ar,
  902.                 'isAWSReport' => $reportlist->getIsAWSReport(),
  903.                 'fileType' => $reportlist->getFileType() == 'video' ? 'Video' : 'pdf',
  905.             ];
  909.             // Initialize edit and delete flags
  910.             $editFlag = false;
  911.             $deleteFlag = false;
  913.             // Get the current report's type key
  914.             $currentReportTypeKey = $reportlist->getReportType()?->getReportKey();
  916.             // Map report type keys to permission names
  917.             $permissionMapping = [
  918.                 'red-sea-report' => 'red_sea_report',
  919.                 'arabian-gulf-report' => 'arabian_gulf_report',
  920.                 '10-day-forecast-report' => '10_day_forecast_report',
  921.                 'custom-weather-report' => 'custom_weather_report',
  922.                 'advance-custom-weather-report' => 'advance_custom_weather_report',
  923.                 'mashaer-weather-report' => 'mashaer_weather_report'
  924.             ];
  926.             // Check permissions only for the current report type
  927.             if ($currentReportTypeKey && isset($permissionMapping[$currentReportTypeKey])) {
  928.                 $permissionName = $permissionMapping[$currentReportTypeKey];
  929.                 $permissionStatus = $userPermission->getUserPermissions($decodedJwtToken, $translator);
  931.                 // Check edit permission
  932.                 if (isset($permissionStatus['grants']["update_$permissionName"]) && $permissionStatus['grants']["update_$permissionName"] === true) {
  933.                     $editFlag = true;
  934.                 }
  936.                 // Check delete permission
  937.                 if (isset($permissionStatus['grants']["delete_$permissionName"]) && $permissionStatus['grants']["delete_$permissionName"] === true) {
  938.                     $deleteFlag = true;
  939.                 }
  940.             }
  941.             $reportListData[$key]['canEdit'] = $editFlag;
  942.             $reportListData[$key]['canDelete'] = $deleteFlag;
  944.             // 15-Day Forecast Report
  945.             if ($reportlist->getReportType()?->getReportKey() == "15-day-forecast-report") {
  946.                 $reportListData[$key]['reportDescriptionEn']  = $reportlist->getReportTitle('en');
  947.                 $reportListData[$key]['reportDescriptionAr']  = $reportlist->getReportTitle('ar');
  948.             }
  949.         }
  950.         return ["success" => true, "data" => $reportListData, "paginationVariables" => $paginate->getPaginationData()];
  951.     }
  953.     public function getTodayWeatherReports($params, $translator, $paginator)
  954.     {
  955.         $lang = $param['lang'] ?? "en";
  956.         $reports = new \Pimcore\Model\DataObject\ReportTodayWeather\Listing();
  957.         $reports->setLocale($lang);
  958.         if (isset($params['search'])) {
  959.             $reports->setCondition(
  960.                 "(title LIKE ?)",
  961.                 [
  962.                     '%' . $params['search'] . '%'
  963.                 ]
  964.             );
  965.         }
  966.         $sortOrderCreatedAt = $params['sortByCreated'] ?? "desc";
  967.         $reports->setOrderKey("o_id")
  968.             ->setOrder($sortOrderCreatedAt);
  969.         if (count($reports) > 0) {
  970.             // set pagination
  971.             $paginate = $paginator->paginate(
  972.                 $reports,
  973.                 $params['page'],
  974.                 $params['limit']
  975.             );
  976.             $data = [];
  977.             foreach ($paginate as $report) {
  978.                 $data[] = [
  979.                     'reportNameEn' => $report->getTitle("en"),
  980.                     'reportNameAr' => $report->getTitle("ar"),
  981.                     'reportPathEn' => $report->getPdfReport() ? API_BASE_URL . $report->getPdfReport()->getPath() . $report->getPdfReport()->getFilename() : '',
  982.                     'reportPathAr' => $report->getPdfReportAr() ? API_BASE_URL . $report->getPdfReportAr()->getPath() . $report->getPdfReportAr()->getFilename() : '',
  983.                     'generatedAt' => $report->getGeneratedAt()
  984.                 ];
  985.             }
  986.             return ['success' => true, 'data' => $data, "paginationVariables" => $paginate->getPaginationData()];
  987.         }
  988.         return ["success" => false, "message" => $translator->trans("no_report_is_available")];
  989.     }
  992.     public function getTodayWeatherReportData($request, $translator)
  993.     {
  995.         $reportData = [];
  997.         $todaysDate = new \Carbon\Carbon(); // Assuming you are using Carbon\Carbon for $todaysDate
  998.         $todaysDate->setTime(0, 0, 0); // Set the time to midnight for comparison
  1000.         $todaysDateString = $todaysDate->format('Y-m-d');
  1003.         // get 15 day forecast report
  1004.         $mannforecast_report = new Report\Listing();
  1005.         $mannforecast_report_type = ReportType::getByKey('MannForecastReport', true);
  1006.         if (!$mannforecast_report_type) {
  1007.             return ["success" => false, "message" => $translator->trans('mannforecast_report_type_not_created')];
  1008.         }
  1009.         $mannforecast_report->setCondition(
  1010.             "((reportType__id = ?) AND (isHistorical IN (?)))",
  1011.             [$mannforecast_report_type->getId(), [false, null]]
  1012.         );
  1013.         $mannforecast_report->setOrderKey("o_creationDate");
  1014.         $mannforecast_report->setOrder("desc");
  1015.         $mann_forecast_report = $mannforecast_report->current();
  1017.         if (!$mann_forecast_report) {
  1018.             return ["success" => false, "message" => $translator->trans('mannforecast_report_not_created')];
  1019.         }
  1021.         // get 15 red sea report
  1022.         $redsea_report = new Report\Listing();
  1023.         $redsea_report_type = ReportType::getByKey('RedSeaReport', true);
  1024.         if (!$redsea_report_type) {
  1025.             return ["success" => false, "message" => $translator->trans('redsea_report_type_not_created')];
  1026.         }
  1027.         $redsea_report->setCondition(
  1028.             "((reportType__id = ?) AND (isHistorical IN (?)))",
  1029.             [$redsea_report_type->getId(), [false, null]]
  1030.         );
  1031.         $redsea_report->setOrderKey("o_creationDate");
  1032.         $redsea_report->setOrder("desc");
  1033.         $red_sea_report = $redsea_report->current();
  1034.         if (!$red_sea_report) {
  1035.             return ["success" => false, "message" => $translator->trans('redsea_report_not_created')];
  1036.         }
  1038.         // get 15 arabiangulf_report 
  1039.         $arabiangulf_report = new Report\Listing();
  1040.         $arabiangulf_report_type = ReportType::getByKey('ArabianGulfReport', true);
  1041.         if (!$arabiangulf_report_type) {
  1042.             return ["success" => false, "message" => $translator->trans('arabiangulf_report_type_not_created')];
  1043.         }
  1044.         $arabiangulf_report->setCondition(
  1045.             "((reportType__id = ?) AND (isHistorical IN (?)))",
  1046.             [$arabiangulf_report_type->getId(), [false, null]]
  1047.         );
  1049.         $arabiangulf_report->setOrderKey("o_creationDate");
  1050.         $arabiangulf_report->setOrder("desc");
  1051.         $arabian_gulf_report = $arabiangulf_report->current();
  1052.         if (!$arabian_gulf_report) {
  1053.             return ["success" => false, "message" => $translator->trans('arabiangulf_report_not_created')];
  1054.         }
  1055.         $red_sea_list = [
  1056.             // 'reportTitleEn' => $red_sea_report->getReportTitle('en'),
  1057.             // 'reportTitleAr' => $red_sea_report->getReportTitle('ar'),
  1058.             'surfaceWindEn' => $red_sea_report->getSurfaceWind('en'),
  1059.             'surfaceWindAr' => $red_sea_report->getSurfaceWind('ar'),
  1060.             'waveHeightEn' => $red_sea_report->getWaveHeight('en'),
  1061.             'waveHeightAr' => $red_sea_report->getWaveHeight('ar'),
  1062.             'stateOfTheSeaEn' => $red_sea_report->getStateOfTheSea('en'),
  1063.             'stateOfTheSeaAr' => $red_sea_report->getStateOfTheSea('ar'),
  1064.         ];
  1066.         $json_data = [];
  1068.         foreach (json_decode($mann_forecast_report->getJsonData()) as $data) {
  1069.             $cityEn = $data->cityEn;
  1070.             if (!isset($json_data[$cityEn])) {
  1071.                 $json_data[$cityEn] = [];
  1072.             }
  1073.             foreach ($data->parameters as $parameter) {
  1074.                 $first_date = $parameter->dates[0];
  1075.                 $json_data[$cityEn][] = [
  1076.                     'cityAr' => $data->cityAr,
  1077.                     'lat' => $data->lat,
  1078.                     'lon' => $data->lon,
  1079.                     'parameter' => $parameter->parameter,
  1080.                     'date' => $first_date->date,
  1081.                     'value' => $first_date->value
  1082.                 ];
  1083.             }
  1084.         }
  1086.         $mannforeacast_list = [
  1087.             'reportTitleEn' => $mann_forecast_report->getReportTitle(),
  1088.             'reportTitleAr' => $mann_forecast_report->getReportTitle(),
  1089.             'jsonData' => $json_data,
  1090.             'createdOn' => $mann_forecast_report->getCreatedOn(),
  1091.             // 'lang' => $mann_forecast_report->getLang()
  1092.         ];
  1093.         $arabian_gulf_list = [
  1094.             // 'reportTitleEn' => $arabian_gulf_report->getReportTitle('en'),
  1095.             // 'reportTitleAr' => $arabian_gulf_report->getReportTitle('ar'),
  1096.             'surfaceWindEn' => $arabian_gulf_report->getSurfaceWind('en'),
  1097.             'surfaceWindAr' => $arabian_gulf_report->getSurfaceWind('ar'),
  1098.             'waveHeightEn' => $arabian_gulf_report->getWaveHeight('en'),
  1099.             'waveHeightAr' => $arabian_gulf_report->getWaveHeight('ar'),
  1100.             'stateOfTheSeaEn' => $arabian_gulf_report->getStateOfTheSea('en'),
  1101.             'stateOfTheSeaAr' => $arabian_gulf_report->getStateOfTheSea('ar'),
  1102.         ];
  1104.         $reportData = [
  1105.             'redSea' => $red_sea_list,
  1106.             'fifteenDay' => $mannforeacast_list,
  1107.             'arabianGulf' => $arabian_gulf_list
  1108.         ];
  1109.         return ['success' => true, 'data' => $reportData];
  1110.     }
  1112.     public function getAllWeatherReportData($request, $translator)
  1113.     {
  1115.         $json_data = [];
  1116.         $report_listing_data = [
  1117.             'reports' => [
  1118.                 'customWeather' => [],
  1119.                 'mashaerWeather' => [],
  1120.                 'todayWeather' => [],
  1121.                 'redSea' => [],
  1122.                 'arabianGulf' => [],
  1123.             ],
  1124.         ];
  1126.         $todaysDate = new \Carbon\Carbon(); // Assuming you are using Carbon\Carbon for $todaysDate
  1127.         $todaysDate->setTime(0, 0, 0); // Set the time to midnight for comparison
  1128.         $todaysDateString = $todaysDate->format('Y-m-d');
  1130.         // get Custom Weather report
  1131.         $customWeatherReport = new Report\Listing();
  1132.         $customWeatherReport_type = ReportType::getByKey('CustomWeatherReport', true);
  1134.         if (!is_null($customWeatherReport_type)) {
  1135.             $customWeatherReport->setCondition(
  1136.                 "((reportType__id = ?) AND (isHistorical IN (?))) AND (DATE(FROM_UNIXTIME(createdOn)) = ?)",
  1137.                 [$customWeatherReport_type->getId(), [false, null], $todaysDateString]
  1138.             );
  1140.             $customWeatherReport->setOrderKey("o_creationDate");
  1141.             $customWeatherReport->setOrder("desc");
  1142.             $custom_Weather_Report = $customWeatherReport->current();
  1145.             $json_data = [];
  1146.             if (!empty($custom_Weather_Report) and !is_null($custom_Weather_Report)) {
  1147.                 if (!empty($custom_Weather_Report->getJsonData()) and !is_null($custom_Weather_Report->getJsonData())) {
  1150.                     foreach (json_decode($custom_Weather_Report->getJsonData()) as $data) {
  1151.                         $cityEn = $data->cityEn;
  1152.                         if (!isset($json_data[$cityEn])) {
  1153.                             $json_data[$cityEn] = [];
  1154.                         }
  1157.                         $json_data[$cityEn] = [
  1158.                             'cityEn' => $data->cityEn,
  1159.                             'cityAr' => $data->cityAr,
  1160.                             'lat' => $data->lat,
  1161.                             'lon' => $data->lon,
  1162.                             'data'  =>  $data->parameters
  1163.                         ];
  1164.                     }
  1165.                 }
  1167.                 $report_listing_data['reports']['customWeather'] = [
  1168.                     'id' => $custom_Weather_Report->getId(),
  1169.                     'reportTitleEn' => $custom_Weather_Report->getReportTitle('en'),
  1170.                     'reportTitleAr' => $custom_Weather_Report->getReportTitle('ar'),
  1171.                     'jsonData' => $json_data,
  1172.                     'createdOn' => $custom_Weather_Report->getCreatedOn()->format('Y-m-d H:i:s')
  1173.                 ];
  1174.             }
  1175.         }
  1178.         // get Mashaer Weather report
  1179.         $mashaerWeatherReport = new Report\Listing();
  1180.         $mashaerWeatherReport_type = ReportType::getByKey('MashaerWeatherReport', true);
  1181.         if (!is_null($mashaerWeatherReport_type)) {
  1182.             $mashaerWeatherReport->setCondition(
  1183.                 "((reportType__id = ?) AND (isHistorical IN (?))) AND (DATE(FROM_UNIXTIME(createdOn)) = ?)",
  1184.                 [$mashaerWeatherReport_type->getId(), [false, null], $todaysDateString]
  1185.             );
  1186.             $mashaerWeatherReport->setOrderKey("o_creationDate");
  1187.             $mashaerWeatherReport->setOrder("desc");
  1188.             $mashaer_Weather_Report = $mashaerWeatherReport->current();
  1189.             $json_data = [];
  1191.             if (!empty($mashaer_Weather_Report) and !is_null($mashaer_Weather_Report)) {
  1192.                 if (!empty($mashaer_Weather_Report->getJsonData()) and !is_null($mashaer_Weather_Report->getJsonData())) {
  1196.                     foreach (json_decode($mashaer_Weather_Report->getJsonData()) as $data) {
  1197.                         $cityEn = $data->cityEn;
  1198.                         if (!isset($json_data[$cityEn])) {
  1199.                             $json_data[$cityEn] = [];
  1200.                         }
  1203.                         $json_data[$cityEn] = [
  1204.                             'cityEn' => $data->cityEn,
  1205.                             'cityAr' => $data->cityAr,
  1206.                             'lat' => $data->lat,
  1207.                             'lon' => $data->lon,
  1208.                             'data'  =>  $data->parameters
  1209.                         ];
  1210.                     }
  1211.                 }
  1213.                 $report_listing_data['reports']['mashaerWeather'] = [
  1214.                     'id' => $mashaer_Weather_Report->getId(),
  1215.                     'reportTitleEn' => $mashaer_Weather_Report->getReportTitle('en'),
  1216.                     'reportTitleAr' => $mashaer_Weather_Report->getReportTitle('ar'),
  1217.                     'jsonData' => $json_data,
  1218.                     'createdOn' => $mashaer_Weather_Report->getCreatedOn()->format('Y-m-d H:i:s')
  1219.                 ];
  1220.             }
  1221.         }
  1228.         // get 15 red sea report
  1229.         $redsea_report = new Report\Listing();
  1230.         $redsea_report_type = ReportType::getByKey('RedSeaReport', true);
  1232.         if (!is_null($redsea_report_type)) {
  1234.             $redsea_report->setCondition(
  1235.                 "((reportType__id = ?) AND (isHistorical IN (?))) AND (DATE(FROM_UNIXTIME(createdOn)) = ?)",
  1236.                 [$redsea_report_type->getId(), [false, null], $todaysDate]
  1237.             );
  1238.             $redsea_report->setOrderKey("o_creationDate");
  1239.             $redsea_report->setOrder("desc");
  1240.             $redsea_report->setLimit(10);
  1241.             $red_sea_report = $redsea_report->current();
  1243.             $json_data = [];
  1245.             if (!empty($red_sea_report) and !is_null($red_sea_report)) {
  1246.                 if (!empty($red_sea_report->getJsonData()) and !is_null($red_sea_report->getJsonData())) {
  1248.                     foreach (json_decode($red_sea_report->getJsonData()) as $data) {
  1249.                         $cityEn = $data->cityEn;
  1250.                         if (!isset($json_data[$cityEn])) {
  1251.                             $json_data[$cityEn] = [];
  1252.                         }
  1254.                         $json_data[$cityEn] = [
  1255.                             'cityEn' => $data->cityEn,
  1256.                             'cityAr' => $data->cityAr,
  1257.                             'lat' => $data->lat,
  1258.                             'lon' => $data->lon,
  1259.                             'data'  =>  $data->parameters
  1260.                         ];
  1261.                     }
  1262.                 }
  1264.                 $report_listing_data['reports']['redSea'] = [
  1265.                     'id' => $red_sea_report->getId(),
  1266.                     'surfaceWindEn' => $red_sea_report->getSurfaceWind('en'),
  1267.                     'surfaceWindAr' => $red_sea_report->getSurfaceWind('ar'),
  1268.                     'waveHeightEn' => $red_sea_report->getWaveHeight('en'),
  1269.                     'waveHeightAr' => $red_sea_report->getWaveHeight('ar'),
  1270.                     'stateOfTheSeaEn' => $red_sea_report->getStateOfTheSea('en'),
  1271.                     'stateOfTheSeaAr' => $red_sea_report->getStateOfTheSea('ar'),
  1272.                     'reportTitleEn' => $red_sea_report->getReportTitle('en'),
  1273.                     'reportTitleAr' => $red_sea_report->getReportTitle('ar'),
  1274.                     'jsonData' => $json_data,
  1275.                     'createdOn' => $red_sea_report->getCreatedOn()->format('Y-m-d H:i:s')
  1276.                 ];
  1277.             }
  1278.         }
  1281.         // get 15 arabiangulf_report 
  1282.         $arabiangulf_report = new Report\Listing();
  1283.         $arabiangulf_report_type = ReportType::getByKey('ArabianGulfReport', true);
  1284.         if (!is_null($arabiangulf_report_type)) {
  1285.             $arabiangulf_report->setCondition(
  1286.                 "((reportType__id = ?) AND (isHistorical IN (?))) AND (DATE(FROM_UNIXTIME(createdOn)) = ?)",
  1287.                 [$arabiangulf_report_type->getId(), [false, null], $todaysDate]
  1288.             );
  1290.             $arabiangulf_report->setOrderKey("o_creationDate");
  1291.             $arabiangulf_report->setOrder("desc");
  1292.             $arabian_gulf_report = $arabiangulf_report->current();
  1293.             $json_data = [];
  1295.             if (!empty($arabian_gulf_report) and !is_null($arabian_gulf_report)) {
  1296.                 if (!empty($arabian_gulf_report->getJsonData()) and !is_null($arabian_gulf_report->getJsonData())) {
  1299.                     foreach (json_decode($arabian_gulf_report->getJsonData()) as $data) {
  1300.                         $cityEn = $data->cityEn;
  1301.                         if (!isset($json_data[$cityEn])) {
  1302.                             $json_data[$cityEn] = [];
  1303.                         }
  1305.                         $json_data[$cityEn] = [
  1306.                             'cityEn' => $data->cityEn,
  1307.                             'cityAr' => $data->cityAr,
  1308.                             'lat' => $data->lat,
  1309.                             'lon' => $data->lon,
  1310.                             'data'  =>  $data->parameters
  1311.                         ];
  1312.                     }
  1313.                 }
  1315.                 $report_listing_data['reports']['arabianGulf'] = [
  1316.                     'id' => $arabian_gulf_report->getId(),
  1317.                     'surfaceWindEn' => $arabian_gulf_report->getSurfaceWind('en'),
  1318.                     'surfaceWindAr' => $arabian_gulf_report->getSurfaceWind('ar'),
  1319.                     'waveHeightEn' => $arabian_gulf_report->getWaveHeight('en'),
  1320.                     'waveHeightAr' => $arabian_gulf_report->getWaveHeight('ar'),
  1321.                     'stateOfTheSeaEn' => $arabian_gulf_report->getStateOfTheSea('en'),
  1322.                     'stateOfTheSeaAr' => $arabian_gulf_report->getStateOfTheSea('ar'),
  1323.                     'reportTitleEn' => $arabian_gulf_report->getReportTitle('en'),
  1324.                     'reportTitleAr' => $arabian_gulf_report->getReportTitle('ar'),
  1325.                     'jsonData' => $json_data,
  1326.                     'createdOn' => $arabian_gulf_report->getCreatedOn()->format('Y-m-d H:i:s')
  1327.                 ];
  1328.             }
  1329.         }
  1332.         // get 15 day forecast report'
  1336.         $mannforecast_report = new Report\Listing();
  1337.         $mannforecast_report_type = ReportType::getByKey('MannForecastReport', true);
  1338.         if (!is_null($mannforecast_report_type)) {
  1339.             $mannforecast_report->setCondition(
  1340.                 "((reportType__id = ?) AND (isHistorical IN (?))) AND (DATE(FROM_UNIXTIME(createdOn)) = ?)",
  1341.                 [$mannforecast_report_type->getId(), [false, null], $todaysDateString]
  1342.             );
  1343.             $mannforecast_report->setOrderKey("o_creationDate");
  1344.             $mannforecast_report->setOrder("desc");
  1345.             $mann_forecast_report = $mannforecast_report->current();
  1346.             $json_data = [];
  1348.             if (!empty($mann_forecast_report) and !is_null($mann_forecast_report)) {
  1349.                 foreach (json_decode($mann_forecast_report->getJsonData()) as $data) {
  1350.                     $cityEn = $data->cityEn;
  1351.                     if (!isset($json_data[$cityEn])) {
  1352.                         $json_data[$cityEn] = [];
  1353.                     }
  1354.                     foreach ($data->parameters as $parameter) {
  1355.                         $first_date = $parameter->dates[0];
  1356.                         $json_data[$cityEn][] = [
  1357.                             'cityAr' => $data->cityAr,
  1358.                             'lat' => $data->lat,
  1359.                             'lon' => $data->lon,
  1360.                             'parameter' => $parameter->parameter,
  1361.                             'date' => $first_date->date,
  1362.                             'value' => $first_date->value
  1363.                         ];
  1364.                     }
  1365.                 }
  1367.                 $report_listing_data['reports']['todayWeather']['todayWeatherData'] = [
  1368.                     'id' => $mann_forecast_report->getId(),
  1369.                     'reportTitleEn' => $mann_forecast_report->getReportTitle('en'),
  1370.                     'reportTitleAr' => $mann_forecast_report->getReportTitle('ar'),
  1371.                     'jsonData' => $json_data,
  1372.                     'createdOn' => $mann_forecast_report->getCreatedOn()->format('Y-m-d H:i:s')
  1373.                 ];
  1375.                 if ($red_sea_report) {
  1376.                     $report_listing_data['reports']['todayWeather']['redSeaData'] = [
  1377.                         'surfaceWindEn' => $red_sea_report->getSurfaceWind('en'),
  1378.                         'surfaceWindAr' => $red_sea_report->getSurfaceWind('ar'),
  1379.                         'waveHeightEn' => $red_sea_report->getWaveHeight('en'),
  1380.                         'waveHeightAr' => $red_sea_report->getWaveHeight('ar'),
  1381.                         'stateOfTheSeaEn' => $red_sea_report->getStateOfTheSea('en'),
  1382.                         'stateOfTheSeaAr' => $red_sea_report->getStateOfTheSea('ar'),
  1383.                         'reportTitleEn' => $red_sea_report->getReportTitle('en'),
  1384.                         'reportTitleAr' => $red_sea_report->getReportTitle('ar'),
  1385.                     ];
  1386.                 }
  1388.                 if ($arabian_gulf_report) {
  1389.                     $report_listing_data['reports']['todayWeather']['arabianGulfData'] = [
  1390.                         'surfaceWindEn' => $arabian_gulf_report->getSurfaceWind('en'),
  1391.                         'surfaceWindAr' => $arabian_gulf_report->getSurfaceWind('ar'),
  1392.                         'waveHeightEn' => $arabian_gulf_report->getWaveHeight('en'),
  1393.                         'waveHeightAr' => $arabian_gulf_report->getWaveHeight('ar'),
  1394.                         'stateOfTheSeaEn' => $arabian_gulf_report->getStateOfTheSea('en'),
  1395.                         'stateOfTheSeaAr' => $arabian_gulf_report->getStateOfTheSea('ar'),
  1396.                         'reportTitleEn' => $arabian_gulf_report->getReportTitle('en'),
  1397.                         'reportTitleAr' => $arabian_gulf_report->getReportTitle('ar'),
  1398.                     ];
  1399.                 }
  1400.             }
  1401.         }
  1404.         return ['success' => true, 'data' => $report_listing_data];
  1405.     }
  1408.     public function createMannedReport($request, $translator, $params, $user)
  1409.     {
  1410.         try {
  1411.             $reportType = ReportType::getById($params['report_type_id'], true);
  1412.             if (!$reportType instanceof ReportType) {
  1413.                 return ["success" => true, "message" => $translator->trans("report_type_does_not_exists")];
  1414.             }
  1416.             $report = new Report();
  1417.             $report->setPublished(true);
  1418.             $report->setParent(DataObject\Service::createFolderByPath('/Report/Report/' . $reportType->getReportKey() . '/'));
  1419.             $report->setKey($params['titleEn'] . '-' . uniqid());
  1420.             $report->setReportType($reportType);
  1421.             $report->setIsMannedReport(true);
  1422.             $report->setCreatedBy($user);
  1423.             $report->setCreatedOn(Carbon::now());
  1424.             $report->setReportTitle($params['titleEn'], 'en');
  1425.             $report->setReportTitle($params['titleAr'], 'ar');
  1426.             $report->setDescription($params['descriptionEn'], 'en');
  1427.             $report->setDescription($params['descriptionAr'], 'ar');
  1428.             $report->setLang($params['lang']);
  1430.             if (!empty($params['file'])) {
  1432.                 // Set the filename from the input
  1433.                 $filename = $params['fileName'];
  1435.                 // Check if the file type is video or pdf, and if so, append a unique ID
  1436.                 if ($params['type'] == 'video' || $params['type'] == 'pdf') {
  1437.                     // Append a unique ID before the extension (to ensure uniqueness)
  1438.                     $filename = pathinfo($filename, PATHINFO_FILENAME) . '_' . uniqid() . '.' . pathinfo($filename, PATHINFO_EXTENSION);
  1439.                 }
  1440.                  $asset = $this->createAsset($params['file'], $filename, $params['type']);
  1441.                 if ($asset) {
  1442.                     $report->setAsset($asset);
  1443.                     $report->setFileType($params['type']);
  1444.                 }
  1445.             }
  1447.             if (isset($params['organizations']) && !empty($params['organizations'])) {
  1448.                 $selectedOrganizations = [];
  1449.                 if ($params['organizations'][0] == 0) {
  1450.                     // $organizations = new Organization\Listing();
  1451.                     // if ($organizations->count() > 0) {
  1452.                     //     foreach ($organizations as $organization) {
  1453.                     //         if ($organization) {
  1454.                     //             $selectedOrganizations[] = $organization;
  1455.                     //         }
  1456.                     //     }
  1457.                     //     $report->setOrganization($selectedOrganizations);
  1458.                     // }
  1459.                 } else {
  1460.                     foreach ($params['organizations'] as $organization) {
  1461.                         $organizationObject = Organization::getById($organization, true);
  1462.                         if ($organizationObject) {
  1463.                             $selectedOrganizations[] = $organizationObject;
  1464.                         }
  1465.                     }
  1467.                     $report->setOrganization($selectedOrganizations);
  1468.                 }
  1469.             }
  1470.             $emails = "";
  1471.             if (!empty($params['channels'])) {
  1472.                 $channels = ['public_portal', 'ajwaa_portal', 'email', 'twitter', 'sms'];
  1473.                 foreach ($params['channels'] as $channel) {
  1474.                     if ($channel == 'public_portal') {
  1475.                         $report->setForPublicPortal(true);
  1476.                     } elseif ($channel == 'ajwaa_portal') {
  1477.                         $report->setForAjwaaPortal(true);
  1478.                         if (isset($params['send_email'])) {
  1479.                             $report->setSendEmail(true);
  1480.                         }
  1481.                     } elseif ($channel == 'email') {
  1482.                         $report->setForEmailChannel(true);
  1483.                         $emails .= implode(",", $params['emails']);
  1484.                     } elseif ($channel == 'twitter') {
  1485.                         $report->setForTwitterChannel(true);
  1486.                     }
  1487.                 }
  1488.             }
  1489.             $emailArray = [];
  1490.             if (isset($params['user_group_ids']) && !empty($params['user_group_ids'])) {
  1491.                 $userGroupIds = ($params['user_group_ids']);
  1493.                 foreach ($userGroupIds as $userGroupId) {
  1494.                     if ($userGroupId) {
  1496.                         $userGroup = \Pimcore\Model\DataObject\EwsAndReportUserGroup::getById($userGroupId, true);
  1497.                         if ($userGroup instanceof \Pimcore\Model\DataObject\EwsAndReportUserGroup) {
  1499.                             foreach (json_decode($userGroup->getJsonData()) as $currentUser) {
  1501.                                 if (isset($currentUser->email)) {
  1502.                                     $report->setForEmailChannel(true);
  1504.                                     $emailArray[] = $currentUser->email;
  1505.                                 }
  1506.                             }
  1507.                         }
  1508.                     }
  1509.                 }
  1510.             }
  1511.             if (!empty($emailArray)) {
  1512.                 if (!empty($emails)) {
  1513.                     $emails .= ',' . implode(',', $emailArray);
  1514.                 } else {
  1515.                     $emails = implode(',', $emailArray);
  1516.                 }
  1517.             }
  1518.             $report->setEmails($emails);
  1519.             $report->save();
  1522.             return ["success" => true, "message" => $translator->trans("report_generated_successfully"), "report_id" => $report->getId()];
  1523.         } catch (\Exception $ex) {
  1524.             return ["success" => false, "message" => $ex->getMessage()];
  1525.         }
  1526.     }
  1530.     public function createAsset($fileData, $filename, $type = null)
  1531.     {
  1532.         // Validate the file data
  1533.         if (preg_match('/^data:(image\/(png|jpe?g)|application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel)|video\/(mp4|webm|x-msvideo|quicktime|x-matroska|x-flv|x-ms-wmv|mpeg|3gpp));base64,/', $fileData) !== 1) {
  1534.             return false; // Invalid file data or MIME type
  1535.         }
  1537.         // Extract the file extension from the MIME type
  1538.         $extension = '';
  1539.         if (preg_match('/^data:image\/(png|jpe?g);base64,/', $fileData)) {
  1540.             $extension = 'jpg'; // Assume JPG for base64-encoded image data (PNG or JPEG)
  1541.         } elseif (preg_match('/^data:application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel);base64,/', $fileData)) {
  1542.             $extension = 'pdf'; // PDF, DOCX, or Excel
  1543.         } elseif (preg_match('/^data:video\/(mp4|webm|x-msvideo|quicktime|x-matroska|x-flv|x-ms-wmv|mpeg|3gpp);base64,/', $fileData)) {
  1544.             // Added more video extensions
  1545.             if (preg_match('/^data:video\/mp4;base64,/', $fileData)) {
  1546.                 $extension = 'mp4'; // MP4
  1547.             } elseif (preg_match('/^data:video\/webm;base64,/', $fileData)) {
  1548.                 $extension = 'webm'; // WebM
  1549.             } elseif (preg_match('/^data:video\/x-msvideo;base64,/', $fileData)) {
  1550.                 $extension = 'avi'; // AVI
  1551.             } elseif (preg_match('/^data:video\/quicktime;base64,/', $fileData)) {
  1552.                 $extension = 'mov'; // MOV
  1553.             } elseif (preg_match('/^data:video\/x-matroska;base64,/', $fileData)) {
  1554.                 $extension = 'mkv'; // MKV
  1555.             } elseif (preg_match('/^data:video\/x-flv;base64,/', $fileData)) {
  1556.                 $extension = 'flv'; // FLV
  1557.             } elseif (preg_match('/^data:video\/x-ms-wmv;base64,/', $fileData)) {
  1558.                 $extension = 'wmv'; // WMV
  1559.             } elseif (preg_match('/^data:video\/mpeg;base64,/', $fileData)) {
  1560.                 $extension = 'mpeg'; // MPEG
  1561.             } elseif (preg_match('/^data:video\/3gpp;base64,/', $fileData)) {
  1562.                 $extension = '3gp'; // 3GP
  1563.             }
  1564.         }
  1566.         // Remove the "data:image/png;base64," or "data:application/pdf;base64," prefix to get the actual base64-encoded content
  1567.         $base64Content = preg_replace('/^data:(image\/png|application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel)|video\/(mp4|webm|x-msvideo|quicktime|x-matroska|x-flv|x-ms-wmv|mpeg|3gpp));base64,/', '', $fileData);
  1569.         // Decode the base64-encoded content
  1570.         $fileContent = base64_decode($base64Content);
  1572.         // Validate the decoded content
  1573.         if ($fileContent === false) {
  1574.             return false; // Invalid base64-encoded content
  1575.         }
  1576.         
  1577.         // Create the Pimcore asset
  1578.         $asset = new \Pimcore\Model\Asset();
  1579.         $parent = Asset\Service::createFolderByPath('/Reports/uploaded_files/'. ($type ?? '')); // General folder path
  1580.         $asset->setFilename($filename); // Replace with the desired filename and extension
  1581.         $asset->setParent($parent);
  1582.         $asset->setData($fileContent);
  1584.         // Set the MIME type based on the file extension
  1585.         $mimeType = '';
  1586.         if ($extension === 'pdf') {
  1587.             $mimeType = 'application/pdf';
  1588.         } elseif ($extension === 'jpg') {
  1589.             $mimeType = 'image/jpeg';
  1590.         } elseif ($extension === 'png') {
  1591.             $mimeType = 'image/png';
  1592.         } elseif ($extension === 'docx') {
  1593.             $mimeType = 'application/vnd.openxmlformats-officedocument.wordprocessingml.document';
  1594.         } elseif ($extension === 'xlsx') {
  1595.             $mimeType = 'application/vnd.ms-excel';
  1596.         } elseif ($extension === 'mp4') {
  1597.             $mimeType = 'video/mp4'; // Video MP4
  1598.         } elseif ($extension === 'webm') {
  1599.             $mimeType = 'video/webm'; // Video WebM
  1600.         } elseif ($extension === 'avi') {
  1601.             $mimeType = 'video/x-msvideo'; // Video AVI
  1602.         } elseif ($extension === 'mov') {
  1603.             $mimeType = 'video/quicktime'; // Video MOV
  1604.         } elseif ($extension === 'mkv') {
  1605.             $mimeType = 'video/x-matroska'; // Video MKV
  1606.         } elseif ($extension === 'flv') {
  1607.             $mimeType = 'video/x-flv'; // Video FLV
  1608.         } elseif ($extension === 'wmv') {
  1609.             $mimeType = 'video/x-ms-wmv'; // Video WMV
  1610.         } elseif ($extension === 'mpeg') {
  1611.             $mimeType = 'video/mpeg'; // Video MPEG
  1612.         } elseif ($extension === '3gp') {
  1613.             $mimeType = 'video/3gpp'; // Video 3GP
  1614.         }
  1616.         // Validate the MIME type
  1617.         if (!in_array($mimeType, ['image/jpeg', 'image/png', 'application/pdf', 'application/vnd.openxmlformats-officedocument.wordprocessingml.document', 'application/vnd.ms-excel', 'video/mp4', 'video/webm', 'video/x-msvideo', 'video/quicktime', 'video/x-matroska', 'video/x-flv', 'video/x-ms-wmv', 'video/mpeg', 'video/3gpp'])) {
  1618.             return false; // Invalid MIME type
  1619.         }
  1621.         $asset->setType($mimeType);
  1623.         // Save the asset
  1624.         $asset->save();
  1626.         return $asset;
  1627.     }
  1631.     public function publishAdvanceCustomReport($user, $params, $translator, $logger)
  1632.     {
  1633.         try {
  1634.             $cityNames = '';
  1636.             // Set default values for new parameters
  1637.             $params['isAWSReport'] = isset($params['isAWSReport']) ? $params['isAWSReport'] : false;
  1638.             $params['weather_stations'] = isset($params['weather_stations']) ? $params['weather_stations'] : [];
  1640.             if ($params['isAWSReport']) {
  1641.                 // Handle AWS Weather Station report
  1642.                 if (!empty($params['weather_stations'])) {
  1643.                     $stations = new \Pimcore\Model\DataObject\WeatherStations\Listing();
  1644.                     $stations->setCondition('o_id IN (?)', [$params['weather_stations']]);
  1645.                     $stations->load();
  1647.                     if ($stations->getCount() > 0) {
  1648.                         foreach ($stations as $station) {
  1649.                             $nameEN = $station->getName('en');
  1650.                             $nameAR = $station->getName('ar');
  1652.                             $cityNames .= !empty($nameEN) ? $nameEN . ',' : '';
  1653.                             $cityNames .= !empty($nameAR) ? $nameAR . ',' : '';
  1654.                         }
  1655.                     } else {
  1656.                         return ["success" => false, "message" => "invalid_weather_station"];
  1657.                     }
  1659.                     // Remove the trailing comma
  1660.                     $cityNames = rtrim($cityNames, ',');
  1661.                 }
  1662.             } else {
  1663.                 // Handle regular Governorate report
  1664.                 if (!empty($params['locations'])) {
  1665.                     $cities = new \Pimcore\Model\DataObject\Governorate\Listing();
  1666.                     $cities->setCondition('governoteId IN (?)', [$params['locations']]);
  1667.                     $cities->load();
  1669.                     if ($cities->getCount() > 0) {
  1670.                         foreach ($cities as $city) {
  1671.                             $nameEN = $city->getCityName('en');
  1672.                             $nameAR = $city->getCityName('ar');
  1674.                             $cityNames .= !empty($nameEN) ? $nameEN . ',' : '';
  1675.                             $cityNames .= !empty($nameAR) ? $nameAR . ',' : '';
  1676.                         }
  1677.                     } else {
  1678.                         return ["success" => false, "message" => "invalid_location"];
  1679.                     }
  1681.                     // Remove the trailing comma
  1682.                     $cityNames = rtrim($cityNames, ',');
  1683.                 }
  1684.             }
  1685.             if (isset($params['report_id'])) {
  1686.                 $report = Report::getById($params['report_id'], true);
  1687.                 if (!$report instanceof Report) {
  1688.                     return ["success" => false, "message" => "invalid_report_id"];
  1689.                 }
  1690.             } else {
  1691.                 $report = new Report();
  1692.                 $report->setKey(\Pimcore\Model\Element\Service::getValidKey($user->getEmail() . uniqid(), 'object'));
  1693.                 $report->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Report/Report/advance_custom_report/"));
  1694.             }
  1695.             $reportType = '';
  1696.             $report->setCreatedBy($user);
  1697.             $report->setCreatedOn(Carbon::now());
  1698.             $report->setStartDate(Carbon::parse(new \DateTime($params['start_date'])));
  1699.             $report->setEndDate(Carbon::parse(new \Datetime($params['end_date'])));
  1700.             $report->setSearchData($cityNames);
  1701.             $report->setLang($params['lang']);
  1702.             // $report->setEmail($user->getEmail());
  1703.             $report->setJsonData(json_encode($params['data']));
  1704.             if (isset($params['titleEn'])) {
  1705.                 $report->setReportTitle($params['titleEn'], "en");
  1706.             }
  1707.             if (isset($params['titleAr'])) {
  1708.                 $report->setReportTitle($params['titleAr'], "ar");
  1709.             }
  1710.             if (isset($params['descriptionEn'])) {
  1711.                 $report->setDescription($params['descriptionEn'], "en");
  1712.             }
  1713.             if (isset($params['descriptionAr'])) {
  1714.                 $report->setDescription($params['descriptionAr'], "ar");
  1715.             }
  1716.             if (isset($params['reportDisclaimerEn'])) {
  1717.                 $report->setReportDisclaimer($params['reportDisclaimerEn'], "en");
  1718.             }
  1719.             if (isset($params['reportDisclaimerAr'])) {
  1720.                 $report->setReportDisclaimer($params['reportDisclaimerAr'], "ar");
  1721.             }
  1723.             if (isset($params['additionalNoteEn'])) {
  1724.                 $report->setAdditionalNote($params['additionalNoteEn'], "en");
  1725.             }
  1726.             if (isset($params['additionalNoteAr'])) {
  1727.                 $report->setAdditionalNote($params['additionalNoteAr'], "ar");
  1728.             }
  1730.             if (isset($params['publishOnPdf'])) {
  1731.                 $report->setPublishOnPdf($params['publishOnPdf'] == true  ? true : false);
  1732.             }
  1734.             if (isset($params['report_type_id'])) {
  1735.                 $reportType = ReportType::getById($params['report_type_id'], true);
  1736.                 if ($reportType instanceof ReportType) {
  1737.                     $report->setReportType($reportType);
  1738.                     // if($reportType->getKey()!='CustomWeatherReport'|| $reportType->getKey()!='MashaerWeatherReport'){
  1739.                     //     $report->setForPublicPortal(true);
  1740.                     //     $report->setForAjwaaPortal(true);
  1741.                     // }
  1742.                 }
  1743.             }
  1744.             if (!empty($params['organizations'])) {
  1745.                 $selectedOrganizations = [];
  1746.                 if ($params['organizations'][0] == 0) {
  1748.                     // $organizations= new Organization\Listing();
  1749.                     // if ( $organizations->count() > 0) {
  1750.                     //     foreach ($organizations as $organization) {
  1751.                     //         if ($organization) {
  1752.                     //             $selectedOrganizations[] = $organization;
  1753.                     //         }
  1755.                     //     }
  1756.                     //     $report->setOrganization($selectedOrganizations);
  1757.                     // }
  1759.                 } else {
  1760.                     foreach ($params['organizations'] as $organization) {
  1761.                         $organizationObject = Organization::getById($organization, true);
  1762.                         if ($organizationObject) {
  1763.                             $selectedOrganizations[] = $organizationObject;
  1764.                         }
  1765.                     }
  1767.                     $report->setOrganization($selectedOrganizations);
  1768.                 }
  1769.             }
  1770.             $emails = "";
  1771.             if (!empty($params['channels'])) {
  1772.                 $channels = ['public_portal', 'ajwaa_portal', 'email', 'twitter', 'sms'];
  1773.                 foreach ($params['channels'] as $channel) {
  1774.                     if ($channel == 'public_portal') {
  1775.                         $report->setForPublicPortal(true);
  1776.                     } elseif ($channel == 'ajwaa_portal') {
  1777.                         $report->setForAjwaaPortal(true);
  1778.                         if (isset($params['send_email'])) {
  1779.                             $report->setSendEmail(true);
  1780.                         }
  1781.                     } elseif ($channel == 'email') {
  1782.                         $report->setForEmailChannel(true);
  1783.                         $emails .= implode(",", $params['emails']);
  1784.                     } elseif ($channel == 'twitter') {
  1785.                         $report->setForTwitterChannel(true);
  1786.                     }
  1787.                 }
  1788.             }
  1789.             $emailArray = [];
  1790.             if (isset($params['user_group_ids']) && !empty($params['user_group_ids'])) {
  1791.                 $userGroupIds = ($params['user_group_ids']);
  1793.                 foreach ($userGroupIds as $userGroupId) {
  1794.                     if ($userGroupId) {
  1796.                         $userGroup = \Pimcore\Model\DataObject\EwsAndReportUserGroup::getById($userGroupId, true);
  1797.                         if ($userGroup instanceof \Pimcore\Model\DataObject\EwsAndReportUserGroup) {
  1799.                             foreach (json_decode($userGroup->getJsonData()) as $currentUser) {
  1801.                                 if (isset($currentUser->email)) {
  1802.                                     $report->setForEmailChannel(true);
  1804.                                     $emailArray[] = $currentUser->email;
  1805.                                 }
  1806.                             }
  1807.                         }
  1808.                     }
  1809.                 }
  1810.             }
  1811.             if (!empty($emailArray)) {
  1812.                 if (!empty($emails)) {
  1813.                     $emails .= ',' . implode(',', $emailArray);
  1814.                 } else {
  1815.                     $emails = implode(',', $emailArray);
  1816.                 }
  1817.             }
  1818.             $report->setIsAWSReport($params['isAWSReport']);
  1819.             $report->setEmails($emails);
  1820.             $report->setPublished(true);
  1822.             // delete the existing pdf if report is updated
  1823.             if (isset($params['report_id'])) {
  1824.                 $pdfEn = $report->getAsset();
  1825.                 $pdfAr = $report->getAssetAr();
  1827.                 if ($pdfEn instanceof Asset) {
  1828.                     $pdfEn->delete();
  1829.                 }
  1830.                 if ($pdfAr instanceof Asset) {
  1831.                     $pdfAr->delete();
  1832.                 }
  1833.             }
  1835.             $report->save();
  1837.             // //$phpPath = 'D:\laragon\bin\php\php-8.1.10-Win32-vs16-x64\php.exe'; // Adjust to the actual PHP path on your system
  1838.             // $consolePath = 'bin\console'; // Use backslashes for Windows paths
  1840.             // $commandArguments = ['bin/console', 'app:today-weather-pdf'];
  1841.             // if(!empty($reportType)){
  1842.             //     if($reportType->getKey()!='CustomWeatherReport' || $reportType->getKey()!='MashaerWeatherReport'){
  1843.             //         $process = new Process($commandArguments);
  1844.             //         $process->setWorkingDirectory(PIMCORE_PROJECT_ROOT);
  1845.             //         try {
  1846.             //             $process->mustRun();
  1847.             //             $logger->info("Today Weather command executed successfully: " . $process->getOutput());
  1848.             //             // p_r("Today Weather command executed successfully: " . $process->getOutput());exit;
  1849.             //             $result['success'] = true;
  1850.             //             $result['message'] = $process->getOutput();
  1851.             //         } catch (ProcessFailedException $exception) {
  1852.             //             $logger->error("Today Weather command failed: " . $exception->getMessage());
  1853.             //             // p_r("Today Weather command failed: " . $exception->getMessage());exit;
  1855.             //             $result['success'] = false;
  1856.             //             $result['message'] = "Failed to execute notification command.";
  1858.             //         }
  1859.             //     }
  1860.             // }
  1863.             if (isset($params['report_id'])) {
  1864.                 return ["success" => true, "message" => $translator->trans("report_updated_successfully"), "data" => $report->getId()];
  1865.             } else {
  1866.                 return ["success" => true, "message" => $translator->trans("report_published_successfully"), "data" => $report->getId()];
  1867.             }
  1868.         } catch (\Exception $ex) {
  1869.             return ["success" => false, "message" => $ex->getMessage()];
  1870.         }
  1871.     }
  1872.     public function archiveWeatherReport($translator, $user, $reportId)
  1873.     {
  1875.         $report = Report::getById($reportId);
  1876.         if ($report->getPublished()) {
  1877.             $report->setPublished(false);
  1878.             $report->setSoftDelete(true);
  1879.             $report->save();
  1880.             return ["success" => true, "message" => $translator->trans("archive_weather_report")];
  1881.         } else {
  1882.             return ["success" => false, "message" => $translator->trans("report_not_found")];
  1883.         }
  1884.     }
  1887.     public function generatePdfReport($request, $user, $snappy, $translator)
  1888.     {
  1889.         // Parse request parameters
  1890.         $params = json_decode($request->getContent(), true);
  1891.         if (empty($params['id'])) {
  1892.             return [
  1893.                 "success" => false,
  1894.                 "message" => $translator->trans("missing_required_parameters")
  1895.             ];
  1896.         }
  1898.         // Fetch the report
  1899.         $report = Report::getById($params['id'], true);
  1900.         $lang = $params['lang'] ?? "en";
  1901.         if (!$report instanceof Report) {
  1902.             return [
  1903.                 "success" => false,
  1904.                 "message" => $translator->trans("no_report_found")
  1905.             ];
  1906.         }
  1908.         // Check for existing asset
  1909.         $asset = $lang === 'ar' ? $report->getAssetAr() : $report->getAsset();
  1910.         if ($asset) {
  1911.             $pdfUrl = API_BASE_URL . $asset->getPath() . $asset->getFilename();
  1912.             return ['success' => true, 'data' => $pdfUrl];
  1913.         }
  1915.         // Determine the template and path based on the report type
  1916.         $templates = [
  1917.             'arabian-gulf-report' => 'pdfReportTemplates/arabian-gulf-report.html.twig',
  1918.             'red-sea-report' => 'pdfReportTemplates/red-sea-report.html.twig',
  1919.             'custom-weather-report' => 'pdfReportTemplates/custom-weather-report.html.twig',
  1920.             '10-day-forecast-report' => 'pdfReportTemplates/ten-day-forecast-report.html.twig',
  1921.             'mashaer-weather-report' => 'pdfReportTemplates/mashaer-weather-report.html.twig',
  1922.             'advance-custom-weather-report' => 'pdfReportTemplates/advance-custom-weather-report.html.twig',
  1923.         ];
  1925.         $defaultTemplate = 'pdfReportTemplates/automatic_report_pdf_template.html.twig';
  1926.         $reportKey = $report->getReportType()?->getReportkey();
  1927.         $template = $templates[$reportKey] ?? $defaultTemplate;
  1929.         // Determine report path
  1930.         $reportPaths = [
  1931.             'red-sea-report' => '/report/advanceCustomReportPdf',
  1932.             'custom-weather-report' => '/report/advanceCustomReportPdf',
  1933.             '10-day-forecast-report' => '/report/advanceCustomReportPdf',
  1934.             'mashaer-weather-report' => '/report/advanceCustomReportPdf',
  1935.             'advance-custom-weather-report' => '/report/advanceCustomReportPdf',
  1936.         ];
  1937.         $reportPath = $reportPaths[$reportKey] ?? '/report/ReportPdf';
  1939.         // Prepare parameters for PDF generation
  1940.         $parameter = [
  1941.             'data' => $report,
  1942.             'reportTitleEn' => $report->getReportTitle('en'),
  1943.             'reportTitleAr' => $report->getReportTitle('ar'),
  1944.             'reportDescriptionEn' => $report->getDescription('en'),
  1945.             'reportDescriptionAr' => $report->getDescription('ar'),
  1946.             'reportDisclaimerEn' => $report->getReportDisclaimer('en'),
  1947.             'reportDisclaimerAr' => $report->getReportDisclaimer('ar'),
  1948.             'additionalNoteEn' => $report->getAdditionalNote('en'),
  1949.             'additionalNoteAr' => $report->getAdditionalNote('ar'),
  1950.             'stateOfTheSeaEn' => $report->getStateOfTheSea('en'),
  1951.             'stateOfTheSeaAr' => $report->getStateOfTheSea('ar'),
  1952.             'waveHeightEn' => $report->getWaveHeight('en'),
  1953.             'waveHeightAr' => $report->getWaveHeight('ar'),
  1954.             'surfaceWindEn' => $report->getSurfaceWind('en'),
  1955.             'surfaceWindAr' => $report->getSurfaceWind('ar'),
  1956.             'publishOnPdf' => (bool)$report->getPublishOnPdf(),
  1957.             'reportTypeNameEn' => $report->getReportType()?->getName('en'),
  1958.             'reportTypeNameAr' => $report->getReportType()?->getName('ar'),
  1959.             'reportType' => $reportKey,
  1960.             'template' => $template,
  1961.             'lang' => $lang,
  1962.         ];
  1964.         // Generate PDF
  1965.         try {
  1966.             $pdf = \App\Lib\Utility::generatePdf($parameter, $snappy);
  1967.         } catch (\Exception $e) {
  1968.             return [
  1969.                 'success' => false,
  1970.                 'message' => $translator->trans("pdf_generation_failed"),
  1971.                 'error' => $e->getMessage(),
  1972.             ];
  1973.         }
  1975.         // Set file name and report path
  1976.         $pdfReportName = ($report->getReportType()?->getName($lang) ?? 'Report') . '_' . date('d-m-Y') . '.pdf';
  1977.         $reportPath .= '/' . $report->getId();
  1979.         // Create asset
  1980.         $asset = \App\Lib\Utility::createAsset($pdf, $pdfReportName, $reportPath);
  1981.         if (!$asset instanceof Asset) {
  1982.             return [
  1983.                 'success' => false,
  1984.                 'message' => $translator->trans("asset_creation_failed"),
  1985.             ];
  1986.         }
  1988.         // Save the asset to the report
  1989.         if ($lang === 'ar') {
  1990.             $report->setAssetAr($asset);
  1991.         } else {
  1992.             $report->setAsset($asset);
  1993.         }
  1994.         $report->save();
  1996.         // Return the asset URL
  1997.         $pdfUrl = API_BASE_URL . $asset->getPath() . $asset->getFilename();
  1998.         return ['success' => true, 'data' => $pdfUrl];
  1999.     }
  2000. }