src/Model/EwsNotificationModel.php line 31

Open in your IDE?
  1. <?php
  3. namespace App\Model;
  5. use DateTime;
  6. use Pimcore\Db;
  7. use DOMDocument;
  8. use SimpleXMLElement;
  9. use Pimcore\Model\Asset;
  10. use Doctrine\DBAL\Connection;
  11. use Pimcore\Model\DataObject;
  12. use Symfony\Component\Uid\UuidV4;
  13. use Pimcore\Model\DataObject\Region;
  14. use Pimcore\Model\DataObject\AlertType;
  15. use Pimcore\Model\DataObject\EwsNotification;
  16. use Symfony\Component\HttpFoundation\Request;
  17. use Pimcore\Model\DataObject\FetchSentEwsEmail;
  18. use App\C2IntegrationBundle\Service\C2Service;
  19. use Pimcore\Model\Asset\MetaData\ClassDefinition\Data\DataObject as DataDataObject;
  20. use Pimcore\Model\DataObject\EwsAndReportUserGroup;
  21. use App\Model\UserModel;
  22. use Symfony\Component\Process\Process;
  23. use Symfony\Component\Process\Exception\ProcessFailedException;
  25. class EwsNotificationModel
  26. {
  28.     public $c2Service;
  29.     private $userModel;
  31.     function __construct()
  32.     {
  33.         $this->c2Service = new C2Service();
  34.         $this->userModel = new UserModel();
  35.     }
  36.     public function createNotification($request, $params, $userInterface, $translator): array
  37.     {
  38.         $result = [];
  39.         // try {
  40.         $regionId = $params['regionId'] ?? null;
  41.         $governorateIds = $params['governateIds'] ?? null;
  42.         $municipalities = $params['municipalityIds'] ?? null;
  43.         $ewsOtherLocationIds = $params['ewsOtherLocationIds'] ?? null;
  44.         $alertActionId = $params['alertActionId'] ?? null;
  45.         $alertTypeId = $params['alertTypeId'] ?? null;
  46.         $weatherPhenomenonId = $params['weatherPhenomenonId'] ?? null;
  47.         $coordinates = json_encode($params['coordinates'] ?? []);
  48.         $message = $params['message'] ?? [];
  49.         $alertHazardId = $params['alertHazardId'] ?? null;
  50.         $otherLocationId = $params['otherLocationId'] ?? null;
  51.         $enableTwitterNotification = $params['enableTwitterNotification'] ?? false;
  52.         $enableSMSNotification = $params['enableSMSNotification'] ?? false;
  53.         $enableEmailNotification = $params['enableEmailNotification'] ?? false;
  54.         $x_post = $params['x_post'] ?? "";
  55.         $previewText = isset($params['previewText']) ? $params['previewText'] : false;
  57.         $ewsNotification = new DataObject\EwsNotification();
  58.         $ewsNotification->setParent(DataObject\Service::createFolderByPath('/Notification/EWSNotification'));
  59.         $ewsNotification->setKey(md5($coordinates . $regionId . $governorateIds) . '-' . time());
  60.         $ewsNotification->setGuid(\App\Lib\Utility::getUUID()->toRfc4122());
  62.         if (isset($params['startDate'])) {
  63.             $startTime = $params['startTime'] ?? '00:00:00';
  64.             $fromDate = $params['startDate'] . ' ' . $startTime;
  65.             $ewsNotification->setStartDate(\Carbon\Carbon::createFromFormat('Y-m-d H:i:s', $fromDate));
  66.         }
  68.         if (isset($params['endDate'])) {
  69.             $endTime = $params['endTime'] ?? '00:00:00';
  70.             $endDate = $params['endDate'] . ' ' . $endTime;
  71.             $ewsNotification->setEndDate(\Carbon\Carbon::createFromFormat('Y-m-d H:i:s', $endDate));
  72.         }
  74.         if (isset($message['en'])) {
  75.             $ewsNotification->setMessage($message['en'], 'en');
  76.         }
  78.         if (isset($message['ar'])) {
  79.             $ewsNotification->setMessage($message['ar'], 'ar');
  80.         }
  83.         if (!empty($regionId)) {
  84.             $regionObj = DataObject\Region::getByRegionId($regionId, 1);
  85.             if (!empty($regionObj)) {
  86.                 $ewsNotification->setRegion($regionObj);
  87.                 if ($governorateIds) {
  88.                     $governorateIdArr = explode(",", $governorateIds);
  89.                     if ($governorateIdArr) {
  90.                         $applyGovernates = [];
  91.                         foreach ($governorateIdArr as $id) {
  92.                             if(!empty($id)){
  93.                                 $applyGovernates[] = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($id, true);
  94.                                 if (!empty(array_unique($applyGovernates))) {
  95.                                     $ewsNotification->setGovernorate(array_unique($applyGovernates));
  96.                                 }
  97.                             }
  98.                         }
  99.                     }
  100.                     if ($municipalities) {
  101.                         $municipalitiesIdArr = explode(",", $municipalities);
  102.                         if ($municipalitiesIdArr) {
  103.                             $applyMunicipalities = [];
  104.                             foreach ($municipalitiesIdArr as $id) {
  105.                                 $applyMunicipalities[] = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($id, true);
  106.                                 if (!empty(array_unique($applyMunicipalities))) {
  107.                                     $ewsNotification->setMunicipality(array_unique($applyMunicipalities));
  108.                                 }
  109.                             }
  110.                         }
  111.                     }
  112.                 } else {
  113.                     $ewsNotification->setGovernorate($this->governorateByRegion($regionObj->getId()));
  114.                 }
  115.             }
  116.         }
  117.         if ($ewsOtherLocationIds) {
  118.             $ewsOtherLocationIdArr = explode(",", $ewsOtherLocationIds);
  119.             if ($ewsOtherLocationIdArr) {
  120.                 $applyOtherGovernates = [];
  121.                 foreach ($ewsOtherLocationIdArr as $id) {
  122.                     $applyOtherGovernates[] = \Pimcore\Model\DataObject\EwsOtherLocation::getByGovernoteId($id, true);
  124.                     if (!empty(array_unique($applyOtherGovernates))) {
  125.                         $ewsNotification->setEwsOtherLocations(array_unique($applyOtherGovernates));
  126.                     }
  127.                 }
  128.             }
  129.         }
  131.         if (!empty($alertHazardId)) {
  132.             $alertHazardArr = explode(",", $alertHazardId);
  133.             if ($alertHazardArr) {
  134.                 $alertHazardArrRequest = [];
  135.                 foreach ($alertHazardArr as $alertHazardId) {
  136.                     $weatherPhenomenonAffect = DataObject\AlertHazard::getByAlertHazardId($alertHazardId, 1);
  137.                     if ($weatherPhenomenonAffect) {
  138.                         $alertHazardArrRequest[] = $weatherPhenomenonAffect;
  139.                     }
  140.                 }
  141.                 $ewsNotification->setAlertHazard($alertHazardArrRequest);
  142.             }
  143.         }
  145.         if (!empty($alertTypeId)) {
  146.             $alertType = DataObject\AlertType::getByAlertTypeId($alertTypeId, 1);
  147.             $ewsNotification->setAlertType($alertType);
  148.         }
  151.         if (!empty($alertActionId)) {
  152.             $alertActionArr = explode(",", $alertActionId);
  153.             if ($alertActionArr) {
  154.                 $alertActionArrRequest = [];
  155.                 foreach ($alertActionArr as $alertActionId) {
  156.                     $alertAction = DataObject\AlertAction::getByAlertActionId($alertActionId, 1);
  157.                     if ($alertAction) {
  158.                         $alertActionArrRequest[] = $alertAction;
  159.                     }
  160.                 }
  161.                 $ewsNotification->setAlertAction($alertActionArrRequest);
  162.             }
  163.         }
  165.         if (!empty($otherLocationId)) {
  166.             $otherLocationArr = explode(",", $otherLocationId);
  167.             if ($otherLocationArr) {
  168.                 $otherLocationArrRequest = [];
  169.                 foreach ($otherLocationArr as $otherLocationId) {
  170.                     $otherLocation = DataObject\OtherLocation::getByOtherLocationId($otherLocationId, 1);
  171.                     if ($otherLocation) {
  172.                         $otherLocationArrRequest[] = $otherLocation;
  173.                     }
  174.                 }
  175.                 $ewsNotification->setOtherLocations($otherLocationArrRequest);
  176.             }
  177.         }
  180.         if (!empty($weatherPhenomenonId)) {
  181.             $alertStatus = DataObject\AlertStatus::getByAlertStatusId($weatherPhenomenonId, true);
  182.             $ewsNotification->setAlertStatus($alertStatus);
  183.         }
  186.         $ewsNotification->setCoordinates($coordinates);
  188.         $addressComponents = $params['address_components'] ?? [];
  189.         $this->addAddressComponentsFieldCollection($addressComponents, $ewsNotification);
  192.         if (!empty($params['file'])) {
  193.             $asset = $this->createAsset($params['file'], time() . $params['filename']);
  194.             if ($asset) {
  195.                 $ewsNotification->setAttachment($asset);
  196.             }
  197.         }
  199.         if (!empty($params['x_img'])) {
  200.             $asset = $this->createAsset($params['x_img'], time() . "EWSTwitterImages.png");
  201.             if ($asset) {
  202.                 $ewsNotification->setXAttachment($asset);
  203.             }
  204.         }
  206.         $ewsNotification->setXPost($x_post);
  207.         $ewsNotification->setEnableTwitterNotification($enableTwitterNotification);
  208.         $ewsNotification->setEnableSMSNotification($enableSMSNotification);
  209.         $ewsNotification->setEnableEmailNotification($enableEmailNotification);
  210.         $ewsNotification->setUser($userInterface);
  211.         $ewsNotification->setEditor($userInterface);
  212.         $ewsNotification->setPublished(false);
  213.         $ewsNotification->setPreviewText($previewText);
  214.         //$ewsNotification->save(["versionNote" => "Update"]);
  216.         //set ews search Id
  217.         $currentDate = new \DateTime();
  218.         $formattedDate = $currentDate->format('dmY') . '-' . $ewsNotification->getId();
  219.         $searchIdEn = 'Early Warning System | ' . $formattedDate . ' | ' . ucfirst($ewsNotification->getAlertType()?->getColor()) . ' Alert | ' . $ewsNotification->getWeatherPhenomenon()?->getTitle("en");
  220.         $searchIdAr = $translator->trans('Early Warning System', [], null, "ar") . ' | ' . $formattedDate . ' | ' . $translator->trans(ucfirst($ewsNotification->getAlertType()?->getColor()) . ' Alert', [], null, "ar") . ' | ' . $ewsNotification->getWeatherPhenomenon()?->getTitle("ar");
  221.         $ewsNotification->setEwsSearchId($searchIdEn, "en");
  222.         $ewsNotification->setEwsSearchId($searchIdAr, "ar");
  223.         //$ewsNotification->save(["versionNote" => "Update"]);
  224.         $ewsNotification->save();
  226.         return ['success' => true, 'message' => $translator->trans('ews_notification_added_successifully'), "notification_id" => $ewsNotification->getId()];
  227.         // } catch (\Exception $ex) {
  228.         //     $result = ['success' => false, 'message' => $ex->getMessage()];
  229.         // }
  231.         return $result;
  232.     }
  234.     public function updateNotification($request, $params, $userInterface, $translator, $userGroupIds, $isPublished, $emailService, $templating, $logger): array
  235.     {
  236.         $result = [];
  238.         // try {
  239.         $id = $params['id'] ?? null;
  240.         if (!$id) {
  241.             throw new \Exception("EWS id is required");
  242.         }
  244.         $regionId = $params['regionId'] ?? null;
  245.         $governorateIds = $params['governateIds'] ?? null;
  246.         $municipalities = $params['municipalityIds'] ?? null;
  247.         $ewsOtherLocationIds = $params['ewsOtherLocationIds'] ?? null;
  248.         $alertActionId = $params['alertActionId'] ?? null;
  249.         $alertTypeId = $params['alertTypeId'] ?? null;
  250.         $weatherPhenomenonId = $params['weatherPhenomenonId'] ?? null;
  251.         $coordinates = json_encode($params['coordinates'] ?? []);
  252.         $message = $params['message'] ?? [];
  253.         $alertHazardId = $params['alertHazardId'] ?? null;
  254.         $enableTwitterNotification = $params['enableTwitterNotification'] ?? false;
  255.         $enableSMSNotification = $params['enableSMSNotification'] ?? false;
  256.         $enableEmailNotification = $params['enableEmailNotification'] ?? false;
  257.         $previewText = isset($params['previewText']) ? $params['previewText'] : false;
  259.         $ewsNotification = \Pimcore\Model\DataObject::getById($id);
  260.         if (!$ewsNotification instanceof \Pimcore\Model\DataObject\EwsNotification) {
  261.             // throw new \Exception("Ews notification not found");
  262.             return ['success' => false, 'message' => $translator->trans('ews_notification_not_found')];
  263.         }
  265.         if (isset($params['startDate'])) {
  266.             $startTime = $params['startTime'] ?? '00:00:00';
  267.             $fromDate = $params['startDate'] . ' ' . $startTime;
  268.             $ewsNotification->setStartDate(\Carbon\Carbon::createFromFormat('Y-m-d H:i:s', $fromDate));
  269.         }
  271.         if (isset($params['endDate'])) {
  272.             $endTime = $params['endTime'] ?? '00:00:00';
  273.             $endDate = $params['endDate'] . ' ' . $endTime;
  274.             $ewsNotification->setEndDate(\Carbon\Carbon::createFromFormat('Y-m-d H:i:s', $endDate));
  275.         }
  277.         if (isset($message['en'])) {
  278.             $ewsNotification->setMessage($message['en'], 'en');
  279.         }
  281.         if (isset($message['ar'])) {
  282.             $ewsNotification->setMessage($message['ar'], 'ar');
  283.         }
  286.         if (!empty($regionId)) {
  287.             $regionObj = DataObject\Region::getByRegionId($regionId, 1);
  288.             if (!empty($regionObj)) {
  289.                 $ewsNotification->setRegion($regionObj);
  290.                 if ($governorateIds) {
  291.                     $governorateIdArr = explode(",", $governorateIds);
  292.                     if ($governorateIdArr) {
  293.                         $applyGovernates = [];
  294.                         foreach ($governorateIdArr as $id) {
  295.                             if(!empty($id)){
  296.                                 $applyGovernates[] = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($id, true);
  297.                                 if (!empty(array_unique($applyGovernates))) {
  298.                                     $ewsNotification->setGovernorate(array_unique($applyGovernates));
  299.                                 }
  300.                             }
  301.                         }
  302.                     }
  303.                     if ($municipalities) {
  304.                         $municipalitiesIdArr = explode(",", $municipalities);
  305.                         if ($municipalitiesIdArr) {
  306.                             $applyMunicipalities = [];
  307.                             foreach ($municipalitiesIdArr as $id) {
  308.                                 $applyMunicipalities[] = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($id, true);
  309.                                 if (!empty(array_unique($applyMunicipalities))) {
  310.                                     $ewsNotification->setMunicipality(array_unique($applyMunicipalities));
  311.                                 }
  312.                             }
  313.                         }
  314.                     }
  315.                 } else {
  316.                     $ewsNotification->setGovernorate($this->governorateByRegion($regionObj->getId()));
  317.                 }
  318.             }
  319.         }
  320.         if ($ewsOtherLocationIds) {
  321.             $ewsOtherLocationIdArr = explode(",", $ewsOtherLocationIds);
  322.             if ($ewsOtherLocationIdArr) {
  323.                 $applyOtherGovernates = [];
  324.                 foreach ($ewsOtherLocationIdArr as $id) {
  325.                     $applyOtherGovernates[] = \Pimcore\Model\DataObject\EwsOtherLocation::getByGovernoteId($id, true);
  327.                     if (!empty(array_unique($applyOtherGovernates))) {
  328.                         $ewsNotification->setEwsOtherLocations(array_unique($applyOtherGovernates));
  329.                     }
  330.                 }
  331.             }
  332.         }
  333.         if (!empty($alertTypeId)) {
  334.             $alertType = DataObject\AlertType::getByAlertTypeId($alertTypeId, 1);
  335.             $ewsNotification->setAlertType($alertType);
  336.         }
  339.         if (!empty($alertActionId)) {
  340.             $alertActionArr = explode(",", $alertActionId);
  341.             if ($alertActionArr) {
  342.                 $alertActionArrRequest = [];
  343.                 foreach ($alertActionArr as $alertActionId) {
  344.                     $alertAction = DataObject\AlertAction::getByAlertActionId($alertActionId, 1);
  345.                     if ($alertAction) {
  346.                         $alertActionArrRequest[] = $alertAction;
  347.                     }
  348.                 }
  349.                 $ewsNotification->setAlertAction($alertActionArrRequest);
  350.             }
  351.         }
  354.         if (!empty($weatherPhenomenonId)) {
  355.             $alertStatus = DataObject\AlertStatus::getByAlertStatusId($weatherPhenomenonId, true);
  356.             $ewsNotification->setAlertStatus($alertStatus);
  357.         }
  359.         if (!empty($alertHazardId)) {
  360.             $alertHazardArr = explode(",", $alertHazardId);
  361.             if ($alertHazardArr) {
  362.                 $alertHazardArrRequest = [];
  363.                 foreach ($alertHazardArr as $alertHazardId) {
  364.                     $weatherPhenomenonAffect = DataObject\AlertHazard::getByAlertHazardId($alertHazardId, 1);
  365.                     if ($weatherPhenomenonAffect) {
  366.                         $alertHazardArrRequest[] = $weatherPhenomenonAffect;
  367.                     }
  368.                 }
  369.                 $ewsNotification->setAlertHazard($alertHazardArrRequest);
  370.             }
  371.         }
  374.         $ewsNotification->setCoordinates($coordinates);
  376.         $addressComponents = $params['address_components'] ?? [];
  377.         $this->addAddressComponentsFieldCollection($addressComponents, $ewsNotification);
  380.         if (!empty($params['file'])) {
  381.             $asset = $this->createAsset($params['file'], time() . $params['filename']);
  382.             if ($asset) {
  383.                 $ewsNotification->setAttachment($asset);
  384.             }
  385.         }
  387.         if (!empty($params['x_img'])) {
  388.             $asset = $this->createAsset($params['x_img'], time() . "EWSTwitterImages.png");
  389.             if ($asset) {
  390.                 $ewsNotification->setXAttachment($asset);
  391.             }
  392.         }
  394.         if (!empty($params['x_post'])) {
  395.             $ewsNotification->setXPost($params['x_post']);
  396.         }
  398.         $ewsNotification->setEnableTwitterNotification($enableTwitterNotification);
  399.         $ewsNotification->setEnableSMSNotification($enableSMSNotification);
  400.         $ewsNotification->setEnableEmailNotification($enableEmailNotification);
  401.         $ewsNotification->setPreviewText($previewText);
  402.         //$ewsNotification->setPublished(true);
  403.         $ewsNotification->setUser($userInterface);
  404.         $ewsNotification->setEditor($userInterface);
  405.         //set ews search Id
  406.         $currentDate = new \DateTime();
  407.         $formattedDate = $currentDate->format('dmY') . '-' . $ewsNotification->getId();
  408.         $searchIdEn = 'Early Warning System | ' . $formattedDate . ' | ' . ucfirst($ewsNotification->getAlertType()?->getColor()) . ' Alert | ' . $ewsNotification->getWeatherPhenomenon()?->getTitle("en");
  409.         $searchIdAr = $translator->trans('Early Warning System', [], null, "ar") . ' | ' . $formattedDate . ' | ' . $translator->trans(ucfirst($ewsNotification->getAlertType()?->getColor()) . ' Alert', [], null, "ar") . ' | ' . $ewsNotification->getWeatherPhenomenon()?->getTitle("ar");
  410.         $ewsNotification->setEwsSearchId($searchIdEn, "en");
  411.         $ewsNotification->setEwsSearchId($searchIdAr, "ar");
  412.         $ewsNotification->save(["versionNote" => "Update"]);
  414.         if ($isPublished) {
  415.             // send email
  416.             // Ensure you use 'php' to execute the command.
  418.             $jsonUserGroupIds = json_encode($userGroupIds);
  419.             $process = new Process(['php', 'bin/console', 'app:send-early-warning-alert-email', '--alertId=' . $ewsNotification->getId(), '--userGroupIds=' . $jsonUserGroupIds]);
  420.             $process->setWorkingDirectory(PIMCORE_PROJECT_ROOT);
  422.             try {
  423.                 $process->mustRun();
  424.                 $result['success'] = true;
  425.                 $logger->info("update EwsNotification command executed successfully: " . $process->getOutput());
  426.                 $result['message'] = $process->getOutput();
  427.             } catch (ProcessFailedException $exception) {
  428.                 $logger->error("update EwsNotification command failed: " . $exception->getMessage());
  429.                 return ['success' => false, 'message' => $exception->getMessage()];
  430.             }
  431.         }
  433.         return ['success' => true, 'message' => $translator->trans('ews_notification_updated_successifully'), "notification_id" => $ewsNotification->getId()];
  434.         // } catch (\Exception $ex) {
  435.         //     $result = ['success' => false, 'message' => $ex->getMessage()];
  436.         // }
  438.         return $result;
  439.     }
  441.     public function governorateByRegion($regionId)
  442.     {
  443.         $governorateArr = [];
  444.         $governorateList = new DataObject\Governorate\Listing();
  445.         $governorateList->setCondition('regionId__id = ?', $regionId);
  446.         $governorateList->load();
  447.         if (!empty($governorateList)) {
  449.             foreach ($governorateList as $governorate) {
  450.                 array_push($governorateArr, $governorate);
  451.             }
  452.         }
  453.         return $governorateArr;
  454.     }
  456.     public function notificationListing($params, $paginator, $translator): array
  457.     {
  458.         $response = [];
  460.         // try {
  462.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  463.         $page = isset($params['page']) ? $params['page'] : 1;
  465.         $notificationList = new DataObject\EwsNotification\Listing();
  466.         $notificationList->setUnpublished(true);
  467.         if ($params['unpublished'] == false) {
  468.             $notificationList->filterByPublished(true);
  469.         } else {
  470.             $notificationList->filterByPublished(false);
  471.         }
  473.         if (isset($params['region']) && !empty($params['region'])) {
  474.             $regionSql = null;
  475.             $alertRegion = \Pimcore\Model\DataObject\Region::getByRegionId($params['region'], true);
  476.             if ($alertRegion) {
  477.                 $regionSql .= "region__id = " . $alertRegion->getId() . " OR ";
  478.             }
  479.             $notificationList->addConditionParam("(" . substr($regionSql, 0, -3) . ")");
  480.         }
  481.         if (isset($params['status']) && !empty($params['status'])) {
  482.             $notificationList->addConditionParam("status IN (?)", [$params['status']]);
  483.         }
  484.         if (isset($params['addressCmp']) && !empty($params['addressCmp'])) {
  485.             //TODO
  486.         }
  487.         if (isset($params['start_date']) && !empty($params['start_date'])  && isset($params['end_date']) && !empty($params['end_date'])) {
  488.             $notificationList->filterByStartDate(strtotime($params['start_date']), ">=");
  489.             $notificationList->filterByEndDate(strtotime($params['end_date']), "<=");
  490.         }
  492.         if (isset($params['fromDate']) && isset($params['toDate']) && !empty($params['fromDate']) && !empty($params['toDate'])) {
  493.             $fromDate = new \DateTime($params['fromDate']);
  494.             $toDate = new \DateTime($params['toDate']);
  495.             $fromDateStr = strtotime($fromDate->format('Y-m-d H:i:s'));
  496.             $toDateStr = strtotime($toDate->format('Y-m-d') . ' 23:59:59');
  498.             $notificationList->addConditionParam(
  499.                 "(o_creationDate >= ? AND o_creationDate <= ?)",
  500.                 [$fromDateStr, $toDateStr]
  501.             );
  502.         }
  504.         // Set default sorting
  505.         $notificationList->setOrderKey("o_creationDate");
  506.         $notificationList->setOrder("desc");
  508.         // Load all data for proper sorting
  509.         $notificationList->load();
  511.         if ($notificationList) {
  512.             // Create structured data for sorting (same approach as searchEwsNotification)
  513.             $sortedData = [];
  514.             foreach ($notificationList as $notification) {
  515.                 $regionEn = $notification->getRegion() ? $notification->getRegion()->getName("en") : '';
  516.                 $startDate = $notification->getStartDate() ? $notification->getStartDate()->format('Y-m-d H:i:s') : '';
  517.                 $endDate = $notification->getEndDate() ? $notification->getEndDate()->format('Y-m-d H:i:s') : '';
  518.                 $alertStatusEn = !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName("en") : "";
  519.                 $creationDate = $notification->getCreationDate();
  520.                 $title = $notification->getStartDate() ? $notification->getStartDate()->format("dmY") . '-' . $notification->getId() : '';
  521.                 $alertTypeEn = $notification->getAlertType() ? ucwords($notification->getAlertType()->getColor()) : '';
  522.                 $fromDate = $notification->getStartDate() ? $notification->getStartDate()->format('Y-m-d H:i:s') : '';
  523.                 $toDate = $notification->getEndDate() ? $notification->getEndDate()->format('Y-m-d H:i:s') : '';
  524.                 $created_at = $notification->getCreationDate() ? date("Y-m-d H:i:s", $notification->getCreationDate()) : '';
  525.                 
  526.                 $sortedData[] = [
  527.                     'notification' => $notification,
  528.                     'region' => $regionEn,
  529.                     'alertStatus' => $alertStatusEn,
  530.                     'startDate' => $startDate,
  531.                     'endDate' => $endDate,
  532.                     'creationDate' => $creationDate,
  533.                     'title' => $title,
  534.                     'alertType' => $alertTypeEn,
  535.                     'fromDate' => $fromDate,
  536.                     'toDate' => $toDate,
  537.                     'created_at' => $created_at
  538.                 ];
  539.             }
  540.             
  541.             // Apply sorting to the complete dataset
  542.             // Support multiple parameter names for sorting
  543.             $orderKey = $params['orderkey'] ?? $params['orderKey'] ?? $params['sortBy'] ?? null;
  544.             $orderDirection = isset($params['order']) ? strtolower($params['order']) : 'desc';
  545.             
  546.             if ($orderKey && in_array($orderKey, ['title', 'alertType', 'fromDate', 'toDate', 'region', 'alertStatus', 'created_at'])) {
  547.                 usort($sortedData, function($a, $b) use ($orderKey, $orderDirection) {
  548.                     $valueA = $a[$orderKey] ?? '';
  549.                     $valueB = $b[$orderKey] ?? '';
  550.                     
  551.                     // Handle null/empty values
  552.                     if (empty($valueA) && !empty($valueB)) {
  553.                         return $orderDirection === 'asc' ? -1 : 1;
  554.                     }
  555.                     if (!empty($valueA) && empty($valueB)) {
  556.                         return $orderDirection === 'asc' ? 1 : -1;
  557.                     }
  558.                     if (empty($valueA) && empty($valueB)) {
  559.                         return 0;
  560.                     }
  561.                     
  562.                     // For date fields, convert to timestamp for proper comparison
  563.                     if (in_array($orderKey, ['fromDate', 'toDate', 'created_at'])) {
  564.                         $timestampA = strtotime($valueA);
  565.                         $timestampB = strtotime($valueB);
  566.                         
  567.                         if ($timestampA === false || $timestampB === false) {
  568.                             // If date parsing fails, fall back to string comparison
  569.                             $comparison = strcasecmp($valueA, $valueB);
  570.                         } else {
  571.                             $comparison = $timestampA <=> $timestampB;
  572.                         }
  573.                     } else {
  574.                         // For text fields, use case-insensitive string comparison
  575.                         $comparison = strcasecmp($valueA, $valueB);
  576.                     }
  577.                     
  578.                     return $orderDirection === 'asc' ? $comparison : -$comparison;
  579.                 });
  580.             }
  581.             
  582.             // Extract the sorted notifications
  583.             $sortedNotifications = array_map(function ($item) {
  584.                 return $item['notification'];
  585.             }, $sortedData);
  586.             
  587.             // Convert to response format
  588.             foreach ($sortedNotifications as $notification) {
  589.                 $response[] = $this->createNotificationFormat($notification, $translator);
  590.             }
  591.         }
  592.         
  593.         // If no paginator, return all sorted data
  594.         if ($paginator == null) {
  595.             return ["success" => TRUE, "data" => $response];
  596.         }
  597.         $paginator = $paginator->paginate(
  598.             $response,
  599.             $page,
  600.             $pageSize
  601.         );
  603.         return ["success" => TRUE, "data" => $paginator, "paginationVariables" => $paginator->getPaginationData()];
  604.         // return $response;
  605.         // } catch (\Exception $ex) {
  606.         //     $result = ["success" => false, "message" => $ex->getMessage()];
  607.         // }
  609.         // return $result;
  610.     }
  612.     public function capAlertNotificationListingxml($request, $params, $lang, $translator)
  613.     {
  614.         
  615.         try {
  617.             $notificationList = new DataObject\EwsNotification\Listing();
  618.           
  619.             
  620.             // Get the timezone for date operations
  621.             $timezone = new \DateTimeZone(TIMEZONE);
  622.             
  623.             // Filter by pubDate if provided (format: d-m-Y, e.g., 25-12-2025)
  624.             if (isset($params['pubDate']) && !empty($params['pubDate'])) {
  625.                 $pubDateStr = $params['pubDate'];
  626.                 // Parse the date from d-m-Y format
  627.                 $pubDate = \DateTime::createFromFormat('d-m-Y', $pubDateStr, $timezone);
  628.                 if ($pubDate === false) {
  629.                     // Try alternative format Y-m-d
  630.                     $pubDate = \DateTime::createFromFormat('Y-m-d', $pubDateStr, $timezone);
  631.                 }
  632.                 
  633.                 if ($pubDate !== false) {
  634.                     // Set time to start of day (00:00:00)
  635.                     $pubDate->setTime(0, 0, 0);
  636.                     $startTimestamp = $pubDate->getTimestamp();
  637.                     
  638.                     // Set time to end of day (23:59:59)
  639.                     $pubDateEnd = clone $pubDate;
  640.                     $pubDateEnd->setTime(23, 59, 59);
  641.                     $endTimestamp = $pubDateEnd->getTimestamp();
  642.                     
  643.                     // Filter notifications where startDate falls within the specified date
  644.                     // Use filterByStartDate for >= start of day
  645.                     $notificationList->filterByStartDate($startTimestamp, ">=");
  646.                     // Add condition for <= end of day using addConditionParam
  647.                     $notificationList->addConditionParam("startDate <= ?", [$endTimestamp]);
  648.                 }
  649.             }else{
  650.                 $notificationList->setCondition("endDate > ?", [time()]);
  651.             }
  652.             
  653.             $notificationList->setOrderKey("oo_id");
  654.             $notificationList->setOrder("desc");
  655.           
  657.             // Get the current date as a DateTime object
  658.             $currentDate = new \DateTime('now', $timezone);
  659.             // Set the condition to filter for notifications where endDate is greater than the current date
  660.             
  662.             // Loop through the notifications to find the last updated date
  664.             // Initialize $lastUpdatedDate with current date as default
  665.             $lastUpdatedDate = $currentDate;
  667.             foreach ($notificationList as $notification) {
  668.                 $notificationUpdatedDate = $notification->getEndDate()->setTimezone($timezone);
  670.                 if ($notificationUpdatedDate > $lastUpdatedDate) {
  671.                     $lastUpdatedDate = $notificationUpdatedDate;
  672.                 }
  673.             }
  675.             // Create an empty RSS XML structure
  676.             // $rss = new SimpleXMLElement('<rss version="2.0"/>');
  677.             $rss = new SimpleXMLElement('<?xml version="1.0" encoding="UTF-8"?><rss version="2.0"/>');
  679.             // Create the <channel> element
  680.             $channel = $rss->addChild('channel');
  683.             // Add elements inside <channel>
  684.             $channel->addChild('title', $translator->trans("Early Warning System from National Center of Meteorology, Saudi Arabia"));
  685.             $channel->addChild('link', $_ENV['BASE_URL_DEMO_AJWAA_API'] . '/' . $lang . '/cap-alerts');
  686.             $channel->addChild('description', $translator->trans("Early Warning System from National Center of Meteorology, Saudi Arabia"));
  687.             $channel->addChild('language', $lang);
  688.             $channel->addChild('copyright', $translator->trans("Copyright (c) ".date('Y').", NCM. Licensed under Creative Commons BY 4.0"));
  689.             $channel->addChild('pubDate', $lastUpdatedDate->format('D, d M Y H:i:s \G\M\T'));
  692.             // Create the <image> element
  693.             $image = $channel->addChild('image');
  694.             $image->addChild('title', $translator->trans("Early Warning System from National Center of Meteorology, Saudi Arabia"));
  695.             $image->addChild('url', $_ENV['BASE_URL_DEMO_AJWAA_API'] . '/assets/images/logo2.3.png');
  696.             $image->addChild('link', $_ENV['BASE_URL_DEMO_AJWAA_API'] . '/' . $lang . '/cap-alerts');
  698.             // Create multiple <alert> elements and add them to the <alerts> element
  699.             // Create child elements and add them to the alert
  701.             foreach ($notificationList as $notification) { // Create two <alert> elements as an example
  703.                 $hazardNames = "";
  704.                 if (!empty($notification->getAlertHazard())) {
  705.                     $hazardNamesArr = [];
  706.                     foreach ($notification->getAlertHazard() as $hazard) {
  707.                         $hazardNamesArr[] = $hazard->getName($lang);
  708.                     }
  709.                     $hazardNames .= implode(", ", $hazardNamesArr);
  710.                 }
  712.                 $governorateNames = "";
  713.                 $governorateCoordinates = "";
  714.                 $governorateNamesArr = [];
  715.                 if ($notification->getGovernorate() && !empty($notification->getGovernorate())) {
  716.                     $governorateCoordinatesArr = [];
  717.                     foreach ($notification->getGovernorate() as $governorate) {
  718.                         $governorateNamesArr[] = $governorate->getName($lang);
  719.                         $governorateCoordinatesArr[] = $governorate->getLatitude() . "," . $governorate->getLongitude();
  720.                     }
  721.                     $governorateCoordinates .= implode(" ", $governorateCoordinatesArr);
  722.                     
  723.                     // Format governorates with "and" before the last one
  724.                     if (count($governorateNamesArr) > 1) {
  725.                         $lastGovernorate = array_pop($governorateNamesArr);
  726.                         $governorateNames = implode(" - ", $governorateNamesArr) . " - " . $lastGovernorate;
  727.                     } else {
  728.                         $governorateNames = $governorateNamesArr[0];
  729.                     }
  730.                 }
  732.                 // Get region and alert status names
  733.                 $regionName = $notification->getRegion() ? $notification->getRegion()->getName($lang) : $translator->trans("UNKNOWN");
  734.                 $alertStatusName = !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName($lang) : $translator->trans("UNKNOWN");
  735.                 // Format title
  736.                 $title =  $alertStatusName . ", " . $regionName;
  737.                 // Format dates in GMT format for description
  738.                 $startDateGMT = !empty($notification->getStartDate()) ? $notification->getStartDate()->setTimezone(new \DateTimeZone('GMT'))->format('D, d M Y H:i:s \G\M\T') : $translator->trans("UNKNOWN");
  739.                 $endDateGMT = !empty($notification->getEndDate()) ? $notification->getEndDate()->setTimezone(new \DateTimeZone('GMT'))->format('D, d M Y H:i:s \G\M\T') : $translator->trans("UNKNOWN");
  740.                 
  741.                 // Format description: "{Hazard names} From: {startDate GMT} To: {endDate GMT}, {Location}"
  742.                 $descriptionParts = [];
  743.                 // if (!empty($hazardNames)) {
  744.                 //     $descriptionParts[] = $hazardNames;
  745.                 // }
  746.                 $descriptionParts[] = $alertStatusName . " " . $translator->trans("From") . ": " . $startDateGMT . " " . $translator->trans("To") . ": " . $endDateGMT;
  747.                 if (!empty($governorateNames)) {
  748.                     $descriptionParts[] = ", " . $governorateNames;
  749.                 }
  750.                 $description = implode(" ", $descriptionParts);
  752.                 // Create one or more <item> elements
  753.                 $item = $channel->addChild('item');
  754.               
  755.                 $item->addChild('guid', "{" . $notification->getGuid() . "}");
  757.                 $item->addChild('title', $title);
  758.                 $item->addChild('link', $_ENV['BASE_URL_DEMO_AJWAA_API'] . '/cap/' . $lang . '/alerts/' . $notification->getGuid() . '.xml');
  759.              
  760.                 $item->addChild('description',$description);
  761.                 $item->addChild('author', AUTHOR);
  762.                 $item->addChild('pubDate', $notification->getLastModifiedDate()->setTimeZone(new \DateTimeZone('GMT'))->format('D, d M Y H:i:s \G\M\T'));
  764.             }
  766.             // Create additional <item> elements as needed
  768.             // Format the XML for output
  769.             $dom = dom_import_simplexml($rss)->ownerDocument;
  770.             $dom->formatOutput = true;
  772.             // Save the XML to a file
  773.             $xmlString = $dom->saveXML();
  775.             // Set the Content-Type header to specify that the response is XML
  776.             header("Content-Type: application/xml");
  778.             // Save the XML to a file or output it
  779.             $xmlString = $rss->saveXML();
  780.             print $xmlString;
  781.             exit;
  782.             return $xmlString;
  783.         } catch (\Exception $ex) {
  784.             $result = ["success" => false, "message" => $ex->getMessage()];
  785.         }
  787.         return $result;
  788.     }
  790.     public function capAlertNotificationDetailxml($guid, $lang, $translator)
  791.     {
  792.         $response = [];
  793.         $timezone = new \DateTimeZone(TIMEZONE);
  795.         try {
  798.             $notification = \Pimcore\Model\DataObject\EwsNotification::getByGuid($guid, true);
  801.             if (empty($notification)) {
  802.                 throw new \Exception('Notification not found.');
  803.             }
  804.             $doc = new DomDocument('1.0', 'UTF-8');
  805.             // Create the root element
  806.             $alert = $doc->createElement('alert');
  807.             $alert->setAttribute('xmlns', 'urn:oasis:names:tc:emergency:cap:1.2');
  808.             $alert->setAttribute('xmlns:xsl', 'http://www.w3.org/1999/XSL/Transform');
  809.             $alert->setAttribute('xmlns:ds', 'http://www.w3.org/2000/09/xmldsig#');
  810.             $doc->appendChild($alert);
  811.             // Create child elements and add them to the alert
  812.             $identifier = $doc->createElement('identifier',  $notification->getGuid()); //uuid
  813.             $sender = $doc->createElement('sender', $translator->trans('NCM'));
  814.             $sent = $doc->createElement('sent', $notification->getStartDate()->setTimezone($timezone)->format('Y-m-d\TH:i:sP'));
  815.             $status = $doc->createElement('status', 'Actual');
  816.             $msgType = $doc->createElement('msgType', 'Alert');
  817.             $scope = $doc->createElement('scope', 'Public');
  818.             $alert->appendChild($identifier);
  819.             $alert->appendChild($sender);
  820.             $alert->appendChild($sent);
  821.             $alert->appendChild($status);
  822.             $alert->appendChild($msgType);
  823.             $alert->appendChild($scope);
  824.             // Create the <info> element and add it to the alert
  825.             $info = $doc->createElement('info');
  826.             $alert->appendChild($info);
  827.             // Create child elements for the <info> element
  828.             $category = $doc->createElement('category','Met');
  829.             $event = $doc->createElement('event', $notification->getAlertStatus() ? $notification->getAlertStatus()->getName($lang) : $translator->trans('UNKNOWN')); //high rain
  830.             $responseType = $doc->createElement('responseType', 'None');
  831.             $effective = $doc->createElement('effective', $notification->getStartDate()->setTimezone($timezone)->format('Y-m-d\TH:i:sP'));
  832.             
  833.             // Determine CAP urgency, severity, and certainty based on alert type and event
  834.             $eventName = $notification->getAlertStatus() ? strtolower($notification->getAlertStatus()->getName('en')) : '';
  835.             $alertTypeColor = $notification->getAlertType() ? strtoupper($notification->getAlertType()->getColor() ?? '') : '';
  836.             
  837.             // Determine urgency based on alert type and event severity
  838.             // Immediate: Life-threatening, requires immediate action (RED alerts, tornadoes, etc.)
  839.             // Expected: Forecasted events that will occur (most weather alerts)
  840.             // Past: Events that have already occurred
  841.             // Future: Long-term forecasts
  842.             $urgency = 'Expected'; // Default for most weather alerts
  843.             if ($alertTypeColor === 'RED' || stripos($eventName, 'tornado') !== false || stripos($eventName, 'extreme') !== false) {
  844.                 $urgency = 'Immediate';
  845.             }
  846.             
  847.             // Determine severity based on alert type color and event
  848.             // Extreme: Widespread destruction
  849.             // Severe: Significant threat to life/property
  850.             // Moderate: Some threat
  851.             // Minor: Minimal threat
  852.             // Unknown: Severity unknown
  853.             $severity = 'Moderate'; // Default
  854.             if ($alertTypeColor === 'RED') {
  855.                 $severity = 'Extreme';
  856.             } elseif ($alertTypeColor === 'ORANGE') {
  857.                 $severity = 'Severe';
  858.             } elseif ($alertTypeColor === 'YELLOW') {
  859.                 $severity = 'Moderate';
  860.             } elseif ($alertTypeColor === 'GREEN' || stripos($eventName, 'light') !== false || stripos($eventName, 'minor') !== false) {
  861.                 $severity = 'Minor';
  862.             }
  863.             
  864.             // Certainty: Observed (happening now), Likely (will occur), Possible (may occur), Unlikely, Unknown
  865.             $certainty = 'Possible'; // Default - assume observed for active alerts
  866.             
  867.             $urgencyElement = $doc->createElement('urgency', $urgency);
  868.             $severityElement = $doc->createElement('severity', $severity);
  869.             $certaintyElement = $doc->createElement('certainty', $certainty);
  870.             
  871.             // Remove eventCode element - SAME codes are US-specific and not applicable
  872.             // If eventCode is needed in future, use WMO codes instead:
  873.             // $eventCode = $doc->createElement('eventCode');
  874.             // $eventCodeValueName = $doc->createElement('valueName', 'WMO');
  875.             // $eventCodeValueText = $doc->createElement('value', 'FOG'); // Example WMO code
  876.             // $eventCode->appendChild($eventCodeValueName);
  877.             // $eventCode->appendChild($eventCodeValueText);
  878.             
  879.             // Fix: onset should use startDate (when the event begins), not endDate
  880.             $onsetDate = $notification->getStartDate() ? $notification->getStartDate()->setTimezone($timezone) : null;
  881.             if (!$onsetDate) {
  882.                 // Fallback to current time if startDate is not available
  883.                 $onsetDate = new \DateTime('now', $timezone);
  884.             }
  885.             $onset = $doc->createElement('onset', $onsetDate->format('Y-m-d\TH:i:sP'));
  886.             
  887.             // Fix: expires must be after onset (use endDate, ensure it's after startDate)
  888.             $expiresDate = $notification->getEndDate() ? $notification->getEndDate()->setTimezone($timezone) : null;
  889.             if (!$expiresDate) {
  890.                 // Fallback: if no endDate, set expires to 24 hours after onset
  891.                 $expiresDate = clone $onsetDate;
  892.                 $expiresDate->modify('+24 hours');
  893.             } else {
  894.                 // Ensure expires is after onset (CAP requirement)
  895.                 if ($expiresDate <= $onsetDate) {
  896.                     // If expires equals or is before onset, add at least 1 hour
  897.                     $expiresDate = clone $onsetDate;
  898.                     $expiresDate->modify('+1 hour');
  899.                 }
  900.             }
  901.             $expires = $doc->createElement('expires', $expiresDate->format('Y-m-d\TH:i:sP'));
  902.             $senderName = $doc->createElement('senderName', $translator->trans('NCM'));
  903.              $headline = $doc->createElement('headline', $notification->getAlertType()->getName($lang) . ', ' .  $notification->getAlertStatus()->getName($lang));
  904.             // $headline = $doc->createElement(
  905.             //     'headline',
  906.             //     $translator->trans('Early Warning Alert in') . ' ' .
  907.             //     (
  908.             //         $notification->getRegion()
  909.             //             ? $notification->getRegion()->getName($lang)
  910.             //             : $translator->trans('UNKNOWN')
  911.             //     ) . ': ' .
  912.             //     (
  913.             //         $notification->getAlertStatus()
  914.             //             ? $notification->getAlertStatus()->getName($lang)
  915.             //             : $translator->trans('UNKNOWN')
  916.             //     )
  917.             // );
  919.             $hazardNames = "";
  920.             if (!empty($notification->getAlertHazard())) {
  921.                 $hazardNamesArr = [];
  922.                 foreach ($notification->getAlertHazard() as $hazard) {
  923.                     $hazardNamesArr[] = $hazard->getName($lang);
  924.                 }
  925.                 $hazardNames .= implode(", ", $hazardNamesArr);
  926.             }
  928.             $governorateNames = "";
  929.             $governorateCoordinates = "";
  930.             $governorateNamesArr = [];
  931.             if ($notification->getGovernorate() && !empty($notification->getGovernorate())) {
  932.                 $governorateCoordinatesArr = [];
  933.                 foreach ($notification->getGovernorate() as $governorate) {
  934.                     $governorateNamesArr[] = $governorate->getName($lang);
  935.                     $governorateCoordinatesArr[] = $governorate->getLatitude() . "," . $governorate->getLongitude();
  936.                 }
  937.                 // Format governorates with "و" for Arabic or "and" for English before the last one
  938.                 if (count($governorateNamesArr) > 1) {
  939.                     $lastGovernorate = array_pop($governorateNamesArr);
  940.                     $andText = ($lang == 'ar') ? ' و ' : ', and ';
  941.                     $governorateNames = implode(", ", $governorateNamesArr) . $andText . $lastGovernorate;
  942.                 } else {
  943.                     $governorateNames = $governorateNamesArr[0];
  944.                 }
  945.                 $governorateCoordinates .= implode(" ", $governorateCoordinatesArr);
  946.             }
  948.             // Get region and alert status names
  949.             $regionName = $notification->getRegion() ? $notification->getRegion()->getName($lang) : $translator->trans("UNKNOWN");
  950.             $alertStatusName = $notification->getAlertStatus() ? $notification->getAlertStatus()->getName($lang) : $translator->trans("UNKNOWN");
  951.             
  952.             // Format dates
  953.             $startDateFormatted = !empty($notification->getStartDate()) ? $notification->getStartDate()->setTimezone($timezone)->format('d/m/Y H:i:s A') : $translator->trans("UNKNOWN");
  954.             $endDateFormatted = !empty($notification->getEndDate()) ? $notification->getEndDate()->setTimezone($timezone)->format("d/m/Y H:i:s A") : $translator->trans("UNKNOWN");
  955.             
  956.             // Format description: Comma-separated list of hazard names (e.g., "Raised dust, Active winds,Near lack of horizontal visibility (1-3) km")
  957.             $descriptionText = !empty($hazardNames) ? $hazardNames : "";
  958.             
  959.             $description = $doc->createElement('description', $notification->getAlertStatus()->getName($lang) . ' ' . $descriptionText);
  960.             
  961.             // Create actionable instruction based on alert type and hazards (CAP compliance)
  962.             // Handle multiple hazards by checking all types and combining instructions
  963.             $instructionText = '';
  964.             if (!empty($hazardNames)) {
  965.                 $instructions = [];
  966.                 $hazardNamesLower = strtolower($hazardNames);
  967.                 
  968.                 // Check for all hazard types and collect relevant instructions
  969.                 // Priority hazards first
  970.                 if (stripos($hazardNames, 'tornado') !== false || stripos($hazardNames, 'إعصار') !== false) {
  971.                     $instructions[] = ($lang == 'ar')
  972.                         ? 'انتقل فوراً إلى أقرب ملجأ أو الطابق السفلي. تجنب النوافذ والمناطق المكشوفة.'
  973.                         : 'Move immediately to the nearest shelter or basement. Avoid windows and exposed areas.';
  974.                 }
  975.                 
  976.                 if (stripos($hazardNames, 'rain') !== false || stripos($hazardNames, 'مطر') !== false || 
  977.                     stripos($hazardNames, 'flood') !== false || stripos($hazardNames, 'فيضان') !== false ||
  978.                     stripos($hazardNames, 'pooling') !== false || stripos($hazardNames, 'تجمع') !== false) {
  979.                     $instructions[] = ($lang == 'ar') 
  980.                         ? 'انتقل إلى أرض مرتفعة لتجنب الفيضانات. تجنب القيادة في المناطق المغمورة.'
  981.                         : 'Move to higher ground to avoid flooding. Avoid driving through flooded areas.';
  982.                 }
  983.                 
  984.                 if (stripos($hazardNames, 'wave') !== false || stripos($hazardNames, 'موجة') !== false) {
  985.                     $instructions[] = ($lang == 'ar')
  986.                         ? 'تجنب المناطق الساحلية والأنشطة البحرية. ابق بعيداً عن الشواطئ.'
  987.                         : 'Avoid coastal areas and marine activities. Stay away from beaches.';
  988.                 }
  989.                 
  990.                 if (stripos($hazardNames, 'wind') !== false || stripos($hazardNames, 'رياح') !== false) {
  991.                     $instructions[] = ($lang == 'ar')
  992.                         ? 'تجنب الخروج من المنزل وتأكد من إغلاق النوافذ والأبواب بإحكام. تجنب القيادة إذا أمكن.'
  993.                         : 'Avoid going outside and ensure windows and doors are securely closed. Avoid driving if possible.';
  994.                 }
  995.                 
  996.                 if (stripos($hazardNames, 'thunder') !== false || stripos($hazardNames, 'رعد') !== false) {
  997.                     $instructions[] = ($lang == 'ar')
  998.                         ? 'تجنب المناطق المكشوفة والبقاء في الداخل. تجنب استخدام الأجهزة الإلكترونية والمياه.'
  999.                         : 'Avoid exposed areas and stay indoors. Avoid using electronic devices and water.';
  1000.                 }
  1001.                 
  1002.                 if (stripos($hazardNames, 'hail') !== false || stripos($hazardNames, 'برد') !== false) {
  1003.                     $instructions[] = ($lang == 'ar')
  1004.                         ? 'ابق في الداخل وتجنب النوافذ. إذا كنت في الخارج، ابحث عن مأوى فوري.'
  1005.                         : 'Stay indoors and avoid windows. If outside, seek immediate shelter.';
  1006.                 }
  1007.                 
  1008.                 if (stripos($hazardNames, 'visibility') !== false || stripos($hazardNames, 'رؤية') !== false ||
  1009.                     stripos($hazardNames, 'fog') !== false || stripos($hazardNames, 'ضباب') !== false ||
  1010.                     stripos($hazardNames, 'low visibility') !== false || stripos($hazardNames, 'lack of horizontal visibility') !== false) {
  1011.                     $instructions[] = ($lang == 'ar')
  1012.                         ? 'تجنب القيادة إلا للضرورة القصوى. إذا كنت تقود، استخدم الأضواء المنخفضة واتبع المسافة الآمنة.'
  1013.                         : 'Avoid driving except in emergencies. If driving, use low beams and maintain safe distance.';
  1014.                 }
  1015.                 
  1016.                 if (stripos($hazardNames, 'snow') !== false || stripos($hazardNames, 'ثلج') !== false) {
  1017.                     $instructions[] = ($lang == 'ar')
  1018.                         ? 'تجنب السفر غير الضروري. إذا كنت في الخارج، ارتدِ ملابس دافئة وتجنب الطرق الزلقة.'
  1019.                         : 'Avoid unnecessary travel. If outside, wear warm clothing and avoid slippery roads.';
  1020.                 }
  1021.                 
  1022.                 if (stripos($hazardNames, 'frost') !== false || stripos($hazardNames, 'صقيع') !== false ||
  1023.                     (stripos($hazardNames, 'temperature') !== false && stripos($hazardNames, 'drop') !== false) ||
  1024.                     (stripos($hazardNames, 'درجة') !== false && stripos($hazardNames, 'انخفاض') !== false) ||
  1025.                     stripos($hazardNames, 'below zero') !== false) {
  1026.                     $instructions[] = ($lang == 'ar')
  1027.                         ? 'احمِ نفسك من البرد الشديد. ارتدِ ملابس دافئة وتجنب التعرض الطويل للطقس البارد.'
  1028.                         : 'Protect yourself from extreme cold. Wear warm clothing and avoid prolonged exposure to cold weather.';
  1029.                 }
  1030.                 
  1031.                 if ((stripos($hazardNames, 'rise') !== false && stripos($hazardNames, 'temperature') !== false) ||
  1032.                     (stripos($hazardNames, 'ارتفاع') !== false && stripos($hazardNames, 'درجة') !== false) ||
  1033.                     stripos($hazardNames, 'degrees Celsius') !== false || stripos($hazardNames, 'درجة مئوية') !== false) {
  1034.                     $instructions[] = ($lang == 'ar')
  1035.                         ? 'احمِ نفسك من الحرارة الشديدة. ابق في أماكن مكيفة، اشرب الكثير من الماء، وتجنب الأنشطة الخارجية.'
  1036.                         : 'Protect yourself from extreme heat. Stay in air-conditioned areas, drink plenty of water, and avoid outdoor activities.';
  1037.                 }
  1038.                 
  1039.                 // Combine all instructions or use default
  1040.                 if (!empty($instructions)) {
  1041.                     // Remove duplicates and combine with appropriate separator
  1042.                     $uniqueInstructions = array_unique($instructions);
  1043.                     $separator = ($lang == 'ar') ? ' ' : ' ';
  1044.                     $instructionText = implode($separator, $uniqueInstructions);
  1045.                 } else {
  1046.                     $instructionText = ($lang == 'ar')
  1047.                         ? 'اتخذ الاحتياطات اللازمة واتبع التعليمات الرسمية. ابق في مكان آمن.'
  1048.                         : 'Take necessary precautions and follow official instructions. Stay in a safe place.';
  1049.                 }
  1050.             } else {
  1051.                 // Default instruction if no specific hazards
  1052.                 $instructionText = ($lang == 'ar')
  1053.                     ? 'اتخذ الاحتياطات اللازمة واتبع التعليمات الرسمية من المركز الوطني للأرصاد.'
  1054.                     : 'Take necessary precautions and follow official instructions from the National Center of Meteorology.';
  1055.             }
  1056.             $instruction = $doc->createElement('instruction', $instructionText);
  1057.             
  1058.             $contact = $doc->createElement('contact', CONTACT);
  1059.             
  1060.             // Create dynamic web URL using notification ID (CAP compliance - absolute HTTPS URL)
  1061.             $web = $doc->createElement('web', htmlspecialchars($_ENV['NCM_PUBLIC_PORTAL_URL'] . $lang . '/early-warning/'.$notification->getAlertId(), ENT_XML1, 'UTF-8'));
  1062.             
  1063.             $info->appendChild($category);
  1064.             $info->appendChild($event);     
  1065.             $info->appendChild($responseType);
  1066.             $info->appendChild($urgencyElement);
  1067.             $info->appendChild($severityElement);
  1068.             $info->appendChild($certaintyElement);
  1069.             // eventCode removed - SAME codes are US-specific
  1070.             $info->appendChild($effective);
  1071.             $info->appendChild($onset);
  1072.             $info->appendChild($expires);
  1073.             $info->appendChild($senderName);
  1074.             $info->appendChild($headline);
  1075.             $info->appendChild($description);
  1076.             $info->appendChild($instruction);
  1077.             $info->appendChild($web);
  1078.             $info->appendChild($contact);
  1079.             
  1080.             
  1081.             // Get polygon coordinates from JSON lookup sheet - returns array of polygons per governorate
  1082.             $governoratePolygons = [];
  1083.             
  1084.             // Try to get polygons from the JSON lookup sheet first
  1085.             if ($notification->getGovernorate() && !empty($notification->getGovernorate())) {
  1086.                 // Convert collection to array if needed
  1087.                 $governorates = $notification->getGovernorate();
  1088.                 if (is_object($governorates) && method_exists($governorates, 'getItems')) {
  1089.                     $governorates = $governorates->getItems();
  1090.                 } elseif (!is_array($governorates)) {
  1091.                     $governorates = iterator_to_array($governorates);
  1092.                 }
  1093.                 if (!empty($governorates)) {
  1094.                     $governoratePolygons = $this->getPolygonFromJsonSheet($governorates);
  1095.                 }
  1096.             }
  1097.           
  1098.             // Fallback to notification coordinates if JSON lookup didn't provide polygons
  1099.             if (empty($governoratePolygons)) {
  1100.                 $coordinatesString = $notification->getCoordinates();
  1101.                
  1102.                 if (!empty($coordinatesString)) {
  1103.                     // Try to parse as JSON (GeoJSON format)
  1104.                     $coordinatesData = json_decode($coordinatesString, true);
  1105.                     
  1106.                     if (json_last_error() === JSON_ERROR_NONE && is_array($coordinatesData)) {
  1107.                         // Handle GeoJSON format: coordinates can be in various structures
  1108.                         // [[[lng, lat], [lng, lat], ...]] for Polygon
  1109.                         // [[lng, lat], [lng, lat], ...] for LineString
  1110.                         // [lng, lat] for Point
  1111.                         $coordArray = [];
  1112.                         
  1113.                         if (isset($coordinatesData['type']) && $coordinatesData['type'] === 'Polygon' && isset($coordinatesData['coordinates'])) {
  1114.                             // GeoJSON Polygon format
  1115.                             $coordArray = $coordinatesData['coordinates'][0] ?? [];
  1116.                         } elseif (isset($coordinatesData['type']) && $coordinatesData['type'] === 'LineString' && isset($coordinatesData['coordinates'])) {
  1117.                             // GeoJSON LineString format
  1118.                             $coordArray = $coordinatesData['coordinates'];
  1119.                         } elseif (is_array($coordinatesData) && isset($coordinatesData[0])) {
  1120.                             // Nested array format: [[[lng, lat], ...]] or [[lng, lat], ...]
  1121.                             if (is_array($coordinatesData[0]) && is_array($coordinatesData[0][0])) {
  1122.                                 // [[[lng, lat], ...]] - take first ring
  1123.                                 $coordArray = $coordinatesData[0];
  1124.                             } elseif (is_array($coordinatesData[0]) && count($coordinatesData[0]) >= 2 && is_numeric($coordinatesData[0][0])) {
  1125.                                 // [[lng, lat], ...]
  1126.                                 $coordArray = $coordinatesData;
  1127.                             }
  1128.                         }
  1129.                         
  1130.                         // Process coordinate array
  1131.                         if (!empty($coordArray)) {
  1132.                             $polygon = '';
  1133.                             $firstCoordinate = null;
  1134.                             foreach ($coordArray as $coord) {
  1135.                                 if (is_array($coord) && count($coord) >= 2) {
  1136.                                     $lng = (float)$coord[0];
  1137.                                     $lat = (float)$coord[1];
  1138.                                     
  1139.                                     // CAP polygon format: "lat,lng lat,lng ..." (note: lat first, then lng)
  1140.                                     // Format with 6 decimal places as per client requirement
  1141.                                     $coordString = number_format($lat, 6, '.', '') . "," . number_format($lng, 6, '.', '');
  1142.                                     
  1143.                                     if ($firstCoordinate === null) {
  1144.                                         $firstCoordinate = $coordString;
  1145.                                     }
  1146.                                     $polygon .= $coordString . ' ';
  1147.                                 }
  1148.                             }
  1149.                             
  1150.                             // Remove the trailing space
  1151.                             $polygon = rtrim($polygon);
  1152.                             
  1153.                             // Validate and ensure polygon is closed
  1154.                             if (!empty(trim($polygon)) && $firstCoordinate !== null) {
  1155.                                 $polygonTrimmed = trim($polygon);
  1156.                                 $coords = explode(' ', $polygonTrimmed);
  1157.                                 $uniqueCoords = array_unique($coords);
  1158.                                 
  1159.                                 // Check if we have at least 4 distinct points
  1160.                                 if (count($uniqueCoords) >= 4) {
  1161.                                     // Ensure polygon is closed (first coordinate = last coordinate) - CAP compliance requirement
  1162.                                     $lastCoordinate = end($coords);
  1163.                                     if ($lastCoordinate !== $firstCoordinate) {
  1164.                                         $polygon .= ' ' . $firstCoordinate;
  1165.                                     }
  1166.                                     // Create a single polygon entry for fallback
  1167.                                     $governoratePolygons[] = [
  1168.                                         'governorate' => null,
  1169.                                         'nameEn' => null,
  1170.                                         'nameAr' => null,
  1171.                                         'polygon' => $polygon
  1172.                                     ];
  1173.                                 }
  1174.                             }
  1175.                         }
  1176.                     } else {
  1177.                         // Fallback: try to parse as string format "[[lat,lng],[lat,lng],...]"
  1178.                         $coordinatesString = trim($coordinatesString, '[]');
  1179.                         $coordinates = explode("],[", $coordinatesString);
  1180.                         
  1181.                         $polygon = '';
  1182.                         $firstCoordinate = null;
  1183.                         foreach ($coordinates as $coordinate) {
  1184.                             $parts = explode(",", trim($coordinate, '[]'));
  1185.                             if (count($parts) >= 2 && is_numeric($parts[0]) && is_numeric($parts[1])) {
  1186.                                 $lat = (float)$parts[0];
  1187.                                 $lng = (float)$parts[1];
  1188.                                 // Format with 6 decimal places as per client requirement
  1189.                                 $coordString = number_format($lat, 6, '.', '') . "," . number_format($lng, 6, '.', '');
  1190.                                 
  1191.                                 if ($firstCoordinate === null) {
  1192.                                     $firstCoordinate = $coordString;
  1193.                                 }
  1194.                                 $polygon .= $coordString . ' ';
  1195.                             }
  1196.                         }
  1197.                         
  1198.                         // Remove the trailing space and validate
  1199.                         $polygon = rtrim($polygon);
  1200.                         if (!empty(trim($polygon)) && $firstCoordinate !== null) {
  1201.                             $polygonTrimmed = trim($polygon);
  1202.                             $coords = explode(' ', $polygonTrimmed);
  1203.                             $uniqueCoords = array_unique($coords);
  1204.                             
  1205.                             if (count($uniqueCoords) >= 4) {
  1206.                                 $lastCoordinate = end($coords);
  1207.                                 if ($lastCoordinate !== $firstCoordinate) {
  1208.                                     $polygon .= ' ' . $firstCoordinate;
  1209.                                 }
  1210.                                 $governoratePolygons[] = [
  1211.                                     'governorate' => null,
  1212.                                     'nameEn' => null,
  1213.                                     'nameAr' => null,
  1214.                                     'polygon' => $polygon
  1215.                                 ];
  1216.                             }
  1217.                         }
  1218.                     }
  1219.                 }
  1220.             }
  1221.             
  1222.             // Create area elements - one for each governorate polygon (separate polygons, not merged)
  1223.             // Each governorate gets its own <area> element with its own <polygon>, even if from the same region
  1224.             if (!empty($governoratePolygons)) {
  1225.                 foreach ($governoratePolygons as $govPolygon) {
  1226.                     $area = $doc->createElement('area');
  1227.                     $info->appendChild($area);
  1228.                     
  1229.                     // Create areaDesc for this governorate (format: "Region region - GovernorateName")
  1230.                     $areaDescText = '';
  1231.                     if ($lang == 'ar') {
  1232.                         $areaDescText = "منطقة " . $regionName;
  1233.                         if (!empty($govPolygon['nameAr'])) {
  1234.                             $areaDescText .= " - " . $govPolygon['nameAr'];
  1235.                         }
  1236.                     } else {
  1237.                         $areaDescText = $regionName . " " . $translator->trans("region");
  1238.                         if (!empty($govPolygon['nameEn'])) {
  1239.                             $areaDescText .= " - " . $govPolygon['nameEn'];
  1240.                         }
  1241.                     }
  1242.                     // Note: Removed $notification->getMessage() to match the required format
  1243.                     $areaDesc = $doc->createElement('areaDesc', $areaDescText . ' : ' . $translator->trans('The entire governorate'));
  1244.                     
  1245.                     // Validate and create polygon element for this specific governorate
  1246.                     $polygon = $govPolygon['polygon'];
  1247.                     if (!empty(trim($polygon))) {
  1248.                         $polygonTrimmed = trim($polygon);
  1249.                         $coords = explode(' ', $polygonTrimmed);
  1250.                         $uniqueCoords = array_unique($coords);
  1251.                         
  1252.                         // Check if we have at least 4 distinct points
  1253.                         if (count($uniqueCoords) >= 4) {
  1254.                             // Ensure polygon is closed (first coordinate = last coordinate) - CAP compliance requirement
  1255.                             $firstCoord = $coords[0];
  1256.                             $lastCoord = end($coords);
  1257.                             if ($lastCoord !== $firstCoord) {
  1258.                                 $polygon .= ' ' . $firstCoord;
  1259.                             }
  1260.                             $polygonElement = $doc->createElement('polygon', $polygon);
  1261.                         } else {
  1262.                             // Not enough distinct points - create a bounding box for this specific governorate
  1263.                             // Use governorate-specific coordinates if available
  1264.                             $govSpecificCoords = '';
  1265.                             if (is_object($govPolygon['governorate']) && method_exists($govPolygon['governorate'], 'getLatitude')) {
  1266.                                 $govLat = $govPolygon['governorate']->getLatitude();
  1267.                                 $govLng = $govPolygon['governorate']->getLongitude();
  1268.                                 if (is_numeric($govLat) && is_numeric($govLng)) {
  1269.                                     $govSpecificCoords = number_format($govLat, 6, '.', '') . ',' . number_format($govLng, 6, '.', '');
  1270.                                 }
  1271.                             }
  1272.                             $polygonElement = $this->createFallbackPolygon($doc, $notification, $govSpecificCoords, $timezone);
  1273.                         }
  1274.                     } else {
  1275.                         // No valid coordinates - create fallback polygon for this specific governorate
  1276.                         $govSpecificCoords = '';
  1277.                         if (is_object($govPolygon['governorate']) && method_exists($govPolygon['governorate'], 'getLatitude')) {
  1278.                             $govLat = $govPolygon['governorate']->getLatitude();
  1279.                             $govLng = $govPolygon['governorate']->getLongitude();
  1280.                             if (is_numeric($govLat) && is_numeric($govLng)) {
  1281.                                 $govSpecificCoords = number_format($govLat, 6, '.', '') . ',' . number_format($govLng, 6, '.', '');
  1282.                             }
  1283.                         }
  1284.                         $polygonElement = $this->createFallbackPolygon($doc, $notification, $govSpecificCoords, $timezone);
  1285.                     }
  1286.                     
  1287.                     $area->appendChild($areaDesc);
  1288.                     $area->appendChild($polygonElement);
  1289.                 }
  1290.             } else {
  1291.                 // No polygons found - create a single fallback area
  1292.                 $area = $doc->createElement('area');
  1293.                 $info->appendChild($area);
  1294.                 
  1295.                 // Create child elements for the <area> element
  1296.                 if ($lang == 'ar') {
  1297.                     $areaDescText = "منطقة " . $regionName;
  1298.                 } else {
  1299.                     $areaDescText = $regionName . " " . $translator->trans("region");
  1300.                 }
  1301.                 if (!empty($governorateNames)) {
  1302.                     $areaDescText .= " " . $translator->trans("including") . " " . $governorateNames;
  1303.                 }
  1304.                 $areaDescText .= $notification->getMessage();
  1305.                 $areaDesc = $doc->createElement('areaDesc', $areaDescText);
  1306.                 
  1307.                 $polygonElement = $this->createFallbackPolygon($doc, $notification, $governorateCoordinates, $timezone);
  1308.                 
  1309.                 $area->appendChild($areaDesc);
  1310.                 $area->appendChild($polygonElement);
  1311.             }
  1313.             // Add XML stylesheet reference (CAP compliance)
  1314.             $stylesheet = $doc->createProcessingInstruction('xml-stylesheet', 'type="text/xsl" href="https://ncm.gov.sa/assets/styles/cap.xsl"');
  1315.             $doc->insertBefore($stylesheet, $alert);
  1317.             // Add digital signature structure (placeholder - CAP compliance recommendation)
  1318.             // Note: This is a placeholder. For production, implement real XML digital signatures
  1319.             $dsSignature = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:Signature');
  1320.             
  1321.             // Create SignedInfo element
  1322.             $dsSignedInfo = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:SignedInfo');
  1323.             
  1324.             // CanonicalizationMethod
  1325.             $dsCanonicalizationMethod = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:CanonicalizationMethod');
  1326.             $dsCanonicalizationMethod->setAttribute('Algorithm', 'http://www.w3.org/2001/10/xml-exc-c14n#');
  1327.             $dsSignedInfo->appendChild($dsCanonicalizationMethod);
  1328.             
  1329.             // SignatureMethod
  1330.             $dsSignatureMethod = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:SignatureMethod');
  1331.             $dsSignatureMethod->setAttribute('Algorithm', 'http://www.w3.org/2001/04/xmldsig-more#rsa-sha256');
  1332.             $dsSignedInfo->appendChild($dsSignatureMethod);
  1333.             
  1334.             // Reference - Empty URI for enveloped signature (signs the parent document)
  1335.             $dsReference = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:Reference');
  1336.             $dsReference->setAttribute('URI', '');
  1337.             
  1338.             // Transforms
  1339.             $dsTransforms = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:Transforms');
  1340.             $dsTransform = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:Transform');
  1341.             $dsTransform->setAttribute('Algorithm', 'http://www.w3.org/2000/09/xmldsig#enveloped-signature');
  1342.             $dsTransforms->appendChild($dsTransform);
  1343.             $dsReference->appendChild($dsTransforms);
  1344.             
  1345.             // DigestMethod
  1346.             $dsDigestMethod = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:DigestMethod');
  1347.             $dsDigestMethod->setAttribute('Algorithm', 'http://www.w3.org/2001/04/xmlenc#sha256');
  1348.             $dsReference->appendChild($dsDigestMethod);
  1349.             
  1350.             // DigestValue - Generate hash from notification data (placeholder)
  1351.             $digestData = $notification->getGuid() . '_' . $notification->getId() . '_' . time();
  1352.             $digestHash = hash('sha256', $digestData, true);
  1353.             $digestValue = base64_encode($digestHash);
  1354.             $dsDigestValue = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:DigestValue', $digestValue);
  1355.             $dsReference->appendChild($dsDigestValue);
  1356.             
  1357.             $dsSignedInfo->appendChild($dsReference);
  1358.             $dsSignature->appendChild($dsSignedInfo);
  1359.             
  1360.             // SignatureValue - Generate base64-encoded signature-like value
  1361.             $signatureData = $notification->getGuid() . '_' . $notification->getId() . '_' . time();
  1362.             $hash = hash('sha256', $signatureData, true);
  1363.             // Generate additional random bytes to create a signature-like length (RSA-2048 signature is ~256 bytes)
  1364.             $randomBytes = random_bytes(192); // 192 + 32 (sha256) = 224 bytes, base64 = ~300 chars
  1365.             $combinedBytes = $hash . $randomBytes;
  1366.             $uniqueSignatureValue = base64_encode($combinedBytes);
  1367.             $dsSignatureValue = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:SignatureValue', $uniqueSignatureValue);
  1368.             $dsSignature->appendChild($dsSignatureValue);
  1369.             
  1370.             // KeyInfo
  1371.             $dsKeyInfo = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:KeyInfo');
  1372.             $dsKeyName = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:KeyName', 'NCM-Public-Key');
  1373.             $dsKeyInfo->appendChild($dsKeyName);
  1374.             $dsSignature->appendChild($dsKeyInfo);
  1375.             
  1376.             $alert->appendChild($dsSignature);
  1378.             // Save the XML to a file or output it
  1379.             $xmlString = $doc->saveXML();
  1381.             print $xmlString;
  1382.             exit;
  1383.             return $xmlString;
  1384.         } catch (\Exception $ex) {
  1385.             $result = ["success" => false, "message" => $ex->getMessage()];
  1386.         }
  1388.         return $result;
  1389.     }
  1391.     /**
  1392.      * Get polygon coordinates from JSON lookup sheet for given governorates
  1393.      * 
  1394.      * This method validates and formats latitude/longitude coordinates to exactly 6 decimal places
  1395.      * as required by CAP specification. The JSON file contains the official polygon boundaries
  1396.      * for Saudi Arabia governorates, and coordinates are validated and standardized here.
  1397.      * 
  1398.      * Returns separate polygons for each governorate (not merged)
  1399.      * 
  1400.      * @param array $governorates Array of Governorate objects
  1401.      * @return array Array of arrays with 'governorate', 'nameEn', 'nameAr', and 'polygon' keys
  1402.      */
  1403.     private function getPolygonFromJsonSheet($governorates)
  1404.     {
  1405.         $governoratePolygons = [];
  1406.         // JSON file path containing validated polygon boundaries with coordinates
  1407.         // Use only ksa_governorate_boundaries.geojson file
  1408.         $jsonFilePath = PIMCORE_PROJECT_ROOT . '/public/import/ksa_governorate_boundaries.geojson';
  1409.         
  1410.         // Check if file exists
  1411.         if (!file_exists($jsonFilePath)) {
  1412.             error_log("getPolygonFromJsonSheet: JSON file not found at: " . $jsonFilePath);
  1413.             return [];
  1414.         }
  1415.         
  1416.         // Load JSON file content
  1417.         $jsonContent = file_get_contents($jsonFilePath);
  1418.         if ($jsonContent === false) {
  1419.             error_log("getPolygonFromJsonSheet: Failed to read JSON file");
  1420.             return [];
  1421.         }
  1422.         
  1423.         // Try to decode JSON with increased depth limit for large nested structures
  1424.         $jsonData = json_decode($jsonContent, true, 512, JSON_BIGINT_AS_STRING);
  1425.         
  1426.         // If JSON decode fails, try alternative approach: extract coordinates directly from file
  1427.         if (json_last_error() !== JSON_ERROR_NONE) {
  1428.             $errorMsg = "getPolygonFromJsonSheet: JSON decode error: " . json_last_error_msg() . " (Error code: " . json_last_error() . ")";
  1429.             error_log($errorMsg);
  1430.             error_log("getPolygonFromJsonSheet: File size: " . strlen($jsonContent) . " bytes");
  1431.             // Fallback: Extract coordinates directly from file content using regex/string matching
  1432.             return $this->extractCoordinatesFromFileContent($jsonContent, $governorates);
  1433.         }
  1434.         
  1435.         if (!isset($jsonData['features']) || !is_array($jsonData['features'])) {
  1436.             $availableKeys = isset($jsonData) ? implode(', ', array_keys($jsonData)) : 'null';
  1437.             error_log("getPolygonFromJsonSheet: JSON missing 'features' array. Available keys: " . $availableKeys);
  1438.             error_log("getPolygonFromJsonSheet: JSON type: " . gettype($jsonData));
  1439.             return [];
  1440.         }
  1441.         
  1442.         $debugMatches = [];
  1443.         $debugInfo = null; // Initialize debug info variable
  1444.         
  1445.         // Log total features in JSON for debugging
  1446.         error_log("getPolygonFromJsonSheet: Total features in JSON: " . count($jsonData['features']));
  1447.         
  1448.         // Process each governorate separately to create individual polygons
  1449.         foreach ($governorates as $governorate) {
  1450.             // Handle both object and array cases
  1451.             if (is_object($governorate)) {
  1452.                 $governorateId = method_exists($governorate, 'getGovernoteId') ? $governorate->getGovernoteId() : null;
  1453.                 $governorateNameEn = method_exists($governorate, 'getName') ? $governorate->getName('en') : null;
  1454.                 $governorateNameAr = method_exists($governorate, 'getName') ? $governorate->getName('ar') : null;
  1455.                 $governorateObj = $governorate;
  1456.                 
  1457.                 // Check if this governorate is a municipality and fetch parent governorate
  1458.                 if (method_exists($governorate, 'getIsMunicipality') && $governorate->getIsMunicipality()) {
  1459.                     $municipalityId = method_exists($governorate, 'getMunicipalityID') ? $governorate->getMunicipalityID() : null;
  1460.                     if ($municipalityId !== null) {
  1461.                         try {
  1462.                             $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($municipalityId, true);
  1463.                             if ($municipality && $municipality->getGovernorate()) {
  1464.                                 $parentGovernorate = $municipality->getGovernorate();
  1465.                                 // Use parent governorate's names for matching (English first, then Arabic)
  1466.                                 $governorateNameEn = $parentGovernorate->getName('en');
  1467.                                 $governorateNameAr = $parentGovernorate->getName('ar');
  1468.                                 // Also update the ID to parent governorate's ID for matching
  1469.                                 $governorateId = $parentGovernorate->getGovernoteId();
  1470.                                 error_log("getPolygonFromJsonSheet: Municipality detected (ID: " . $municipalityId . "), using parent governorate - ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1471.                             }
  1472.                         } catch (\Exception $ex) {
  1473.                             error_log("getPolygonFromJsonSheet: Error fetching municipality (ID: " . $municipalityId . "): " . $ex->getMessage());
  1474.                         }
  1475.                     }
  1476.                 }
  1477.             } elseif (is_array($governorate)) {
  1478.                 $governorateId = $governorate['id'] ?? $governorate['governoteId'] ?? null;
  1479.                 $governorateNameEn = $governorate['name_en'] ?? $governorate['name']['en'] ?? null;
  1480.                 $governorateNameAr = $governorate['name_ar'] ?? $governorate['name']['ar'] ?? null;
  1481.                 $governorateObj = $governorate;
  1482.                 
  1483.                 // Check if this governorate is a municipality (array format)
  1484.                 if (isset($governorate['IsMunicipality']) && $governorate['IsMunicipality']) {
  1485.                     $municipalityId = $governorate['MunicipalityID'] ?? null;
  1486.                     if ($municipalityId !== null) {
  1487.                         try {
  1488.                             $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($municipalityId, true);
  1489.                             if ($municipality && $municipality->getGovernorate()) {
  1490.                                 $parentGovernorate = $municipality->getGovernorate();
  1491.                                 // Use parent governorate's names for matching (English first, then Arabic)
  1492.                                 $governorateNameEn = $parentGovernorate->getName('en');
  1493.                                 $governorateNameAr = $parentGovernorate->getName('ar');
  1494.                                 // Also update the ID to parent governorate's ID for matching
  1495.                                 $governorateId = $parentGovernorate->getGovernoteId();
  1496.                                 error_log("getPolygonFromJsonSheet: Municipality detected (ID: " . $municipalityId . "), using parent governorate - ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1497.                             }
  1498.                         } catch (\Exception $ex) {
  1499.                             error_log("getPolygonFromJsonSheet: Error fetching municipality (ID: " . $municipalityId . "): " . $ex->getMessage());
  1500.                         }
  1501.                     }
  1502.                 }
  1503.             } else {
  1504.                 error_log("getPolygonFromJsonSheet: Unexpected governorate type: " . gettype($governorate));
  1505.                 continue;
  1506.             }
  1507.             
  1508.             // Log what we're looking for
  1509.             error_log("getPolygonFromJsonSheet: Searching for governorate - ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1510.             
  1511.             // Log sample features from JSON (only once) - showing REGION_N_1 field that we match against
  1512.             static $loggedSamples = false;
  1513.             if (!$loggedSamples) {
  1514.                 $sampleFeatures = [];
  1515.                 foreach (array_slice($jsonData['features'], 0, 10) as $sampleIdx => $sampleFeature) {
  1516.                     $sampleProps = $sampleFeature['properties'] ?? [];
  1517.                     $sampleFeatures[] = [
  1518.                         'REGION_N_1' => $sampleProps['REGION_N_1'] ?? 'N/A',
  1519.                     ];
  1520.                 }
  1521.                 error_log("getPolygonFromJsonSheet: Sample REGION_N_1 values from JSON (first 10): " . json_encode($sampleFeatures, JSON_UNESCAPED_UNICODE));
  1522.                 $loggedSamples = true;
  1523.             }
  1524.             
  1525.             $matched = false;
  1526.             $matchReason = '';
  1527.             $matchAttempts = [];
  1528.             $foundAnyMatch = false; // Track if we found at least one match for this governorate
  1529.             
  1530.             // Find matching feature in JSON by matching governorate nameEn with REGION_N_1 field only
  1531.             foreach ($jsonData['features'] as $featureIndex => $feature) {
  1532.                 $matched = false; // Reset for each feature
  1533.                 if (!isset($feature['properties']) || !isset($feature['geometry'])) {
  1534.                     continue;
  1535.                 }
  1536.                 
  1537.                 $properties = $feature['properties'];
  1538.                 $geometry = $feature['geometry'];
  1539.                 
  1540.                 // Match by English name only (exact case-insensitive match - using REGION_N_1 field only)
  1541.                 if ($governorateNameEn !== null) {
  1542.                     $govNameEn = trim((string)$governorateNameEn);
  1543.                     if (!empty($govNameEn) && isset($properties['REGION_N_1'])) {
  1544.                         // Normalize the governorate name (lowercase, normalize whitespace)
  1545.                         $govNameNormalized = strtolower(preg_replace('/\s+/', ' ', $govNameEn));
  1546.                         
  1547.                         $jsonNameEn = trim((string)$properties['REGION_N_1']);
  1548.                         if (!empty($jsonNameEn)) {
  1549.                             $jsonNameNormalized = strtolower(preg_replace('/\s+/', ' ', $jsonNameEn));
  1550.                             
  1551.                             // Only exact case-insensitive match (normalized)
  1552.                             if ($jsonNameNormalized === $govNameNormalized) {
  1553.                                 $matched = true;
  1554.                                 $matchReason = 'Name_EN (exact via REGION_N_1): ' . $governorateNameEn . ' matches ' . $jsonNameEn;
  1555.                             }
  1556.                         }
  1557.                     }
  1558.                 }
  1559.                 
  1560.                 if ($matched && isset($geometry['type']) && isset($geometry['coordinates'])) {
  1561.                     error_log("getPolygonFromJsonSheet: Match found! Reason: " . $matchReason . ", Geometry type: " . $geometry['type'] . ", ADMIN: " . ($properties['ADMIN'] ?? 'N/A'));
  1562.                     
  1563.                     // Extract coordinates based on geometry type
  1564.                     $coords = $this->extractCoordinatesFromGeometry($geometry);
  1565.                     error_log("getPolygonFromJsonSheet: Extracted " . count($coords) . " coordinates");
  1566.                     
  1567.                     if (!empty($coords)) {
  1568.                         // Format coordinates for this governorate separately
  1569.                         $polygonCoords = $this->formatCoordinates($coords);
  1570.                         
  1571.                         // Check if we already have a polygon for THIS SPECIFIC governorate
  1572.                         // IMPORTANT: We do NOT merge polygons from different features to avoid creating straight connecting lines.
  1573.                         // If a governorate appears in multiple features, we use only the first match to prevent invalid polygon connections.
  1574.                         $existingIndex = null;
  1575.                         foreach ($governoratePolygons as $idx => $existingPoly) {
  1576.                             if (($existingPoly['governorate'] === $governorateObj) || 
  1577.                                 (is_object($governorateObj) && is_object($existingPoly['governorate']) && 
  1578.                                  method_exists($governorateObj, 'getGovernoteId') && 
  1579.                                  method_exists($existingPoly['governorate'], 'getGovernoteId') &&
  1580.                                  $governorateObj->getGovernoteId() === $existingPoly['governorate']->getGovernoteId())) {
  1581.                                 $existingIndex = $idx;
  1582.                                 break;
  1583.                             }
  1584.                         }
  1585.                         
  1586.                         if ($existingIndex !== null) {
  1587.                             // Governorate already has a polygon - skip this match to avoid creating straight connecting lines
  1588.                             // Using only the first match ensures clean polygon boundaries without invalid connections
  1589.                             error_log("getPolygonFromJsonSheet: Skipping duplicate match for governorate ID: " . $governorateId . " (already has polygon)");
  1590.                         } else {
  1591.                             // Store polygon with governorate info (separate polygon per governorate)
  1592.                             // Each governorate gets its own entry, even if multiple governorates are from the same region
  1593.                             $governoratePolygons[] = [
  1594.                                 'governorate' => $governorateObj,
  1595.                                 'nameEn' => $governorateNameEn,
  1596.                                 'nameAr' => $governorateNameAr,
  1597.                                 'polygon' => $polygonCoords
  1598.                             ];
  1599.                             error_log("getPolygonFromJsonSheet: Successfully added polygon for governorate ID: " . $governorateId);
  1600.                         }
  1601.                         
  1602.                         $matchDebug = [
  1603.                             'match_reason' => $matchReason,
  1604.                             'coords_count' => count($coords),
  1605.                             'geometry_type' => $geometry['type'],
  1606.                             'matched' => true
  1607.                         ];
  1608.                         $debugMatches[] = $matchDebug;
  1609.                         if ($debugInfo !== null) $debugInfo['matches'][] = $matchDebug;
  1610.                         
  1611.                         $foundAnyMatch = true; // Mark that we found at least one match
  1612.                         
  1613.                         // Continue searching for more matching features (same governorate can have multiple regions)
  1614.                         // We'll merge all matching polygons for this governorate
  1615.                         continue;
  1616.                     } else {
  1617.                         $errorMsg = "Matched but extracted 0 coordinates. Geometry type: " . $geometry['type'] . ", Coordinates structure: " . json_encode($geometry['coordinates']);
  1618.                         error_log("getPolygonFromJsonSheet: " . $errorMsg);
  1619.                         if ($debugInfo !== null) {
  1620.                             $debugInfo['errors'][] = $errorMsg;
  1621.                             $debugInfo['matches'][] = ['match_reason' => $matchReason, 'matched' => true, 'coords_extracted' => 0];
  1622.                         }
  1623.                     }
  1624.                 }
  1625.             }
  1626.             
  1627.             if (!$foundAnyMatch) {
  1628.                 error_log("getPolygonFromJsonSheet: No match found for governorate ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1629.                 $noMatchDebug = [
  1630.                     'governorate_id' => $governorateId,
  1631.                     'governorate_id_type' => gettype($governorateId),
  1632.                     'name_en' => $governorateNameEn,
  1633.                     'name_ar' => $governorateNameAr,
  1634.                     'matched' => false,
  1635.                     'match_attempts' => array_slice($matchAttempts, 0, 10) // Limit to first 10 attempts
  1636.                 ];
  1637.                 $debugMatches[] = $noMatchDebug;
  1638.                 if ($debugInfo !== null) $debugInfo['matches'][] = $noMatchDebug;
  1639.             }
  1640.         }
  1641.         
  1642.         // Log summary
  1643.         error_log("getPolygonFromJsonSheet: Processed " . count($governorates) . " governorates, found " . count($governoratePolygons) . " polygons");
  1644.         
  1645.         if (empty($governoratePolygons)) {
  1646.             // Log available REGION_N_1 values from JSON for debugging
  1647.             $availableRegionNames = [];
  1648.             foreach ($jsonData['features'] as $feature) {
  1649.                 $props = $feature['properties'] ?? [];
  1650.                 $regionName = $props['REGION_N_1'] ?? null;
  1651.                 if ($regionName !== null) {
  1652.                     $availableRegionNames[] = $regionName;
  1653.                 }
  1654.             }
  1655.             error_log("getPolygonFromJsonSheet: No coordinates found. Debug matches: " . json_encode($debugMatches));
  1656.             error_log("getPolygonFromJsonSheet: Available REGION_N_1 values in JSON (first 20): " . implode(', ', array_slice($availableRegionNames, 0, 20)));
  1657.         } else {
  1658.             error_log("getPolygonFromJsonSheet: Successfully extracted polygons for " . count($governoratePolygons) . " governorates");
  1659.         }
  1660.         
  1661.         return $governoratePolygons;
  1662.     }
  1663.     
  1664.     /**
  1665.      * Extract coordinates from GeoJSON geometry (supports Polygon and MultiPolygon)
  1666.      * 
  1667.      * @param array $geometry GeoJSON geometry object
  1668.      * @return array Array of coordinate pairs [lng, lat]
  1669.      */
  1670.     private function extractCoordinatesFromGeometry($geometry)
  1671.     {
  1672.         $coordinates = [];
  1673.         
  1674.         if (!isset($geometry['type']) || !isset($geometry['coordinates'])) {
  1675.             return $coordinates;
  1676.         }
  1677.         
  1678.         $type = $geometry['type'];
  1679.         $coords = $geometry['coordinates'];
  1680.         
  1681.         if ($type === 'Polygon' && is_array($coords)) {
  1682.             // Polygon: coordinates[0] is the outer ring
  1683.             if (isset($coords[0]) && is_array($coords[0])) {
  1684.                 foreach ($coords[0] as $coord) {
  1685.                     if (is_array($coord) && count($coord) >= 2) {
  1686.                         $coordinates[] = $coord;
  1687.                     }
  1688.                 }
  1689.             }
  1690.         } elseif ($type === 'MultiPolygon' && is_array($coords)) {
  1691.             // MultiPolygon: array of polygons, each polygon has coordinates[0] as outer ring
  1692.             // IMPORTANT: Use only the FIRST polygon to avoid creating straight connecting lines between disconnected parts
  1693.             // CAP XML polygons should represent a single continuous boundary
  1694.             if (!empty($coords) && is_array($coords[0]) && isset($coords[0][0]) && is_array($coords[0][0])) {
  1695.                 foreach ($coords[0][0] as $coord) {
  1696.                     if (is_array($coord) && count($coord) >= 2) {
  1697.                         $coordinates[] = $coord;
  1698.                     }
  1699.                 }
  1700.             }
  1701.         }
  1702.         
  1703.         return $coordinates;
  1704.     }
  1705.     
  1706.     /**
  1707.      * Extract coordinates directly from file content when JSON parsing fails
  1708.      * This is a fallback method that uses string/regex matching
  1709.      */
  1710.     private function extractCoordinatesFromFileContent($fileContent, $governorates)
  1711.     {
  1712.         $governoratePolygons = [];
  1713.         
  1714.         foreach ($governorates as $governorate) {
  1715.             $governorateCoords = [];
  1716.             // Get governorate ID and names
  1717.             if (is_object($governorate)) {
  1718.                 $governorateId = method_exists($governorate, 'getGovernoteId') ? $governorate->getGovernoteId() : null;
  1719.                 $governorateNameEn = method_exists($governorate, 'getName') ? $governorate->getName('en') : null;
  1720.                 $governorateNameAr = method_exists($governorate, 'getName') ? $governorate->getName('ar') : null;
  1721.                 $governorateObj = $governorate;
  1722.                 
  1723.                 // Check if this governorate is a municipality and fetch parent governorate
  1724.                 if (method_exists($governorate, 'getIsMunicipality') && $governorate->getIsMunicipality()) {
  1725.                     $municipalityId = method_exists($governorate, 'getMunicipalityID') ? $governorate->getMunicipalityID() : null;
  1726.                     if ($municipalityId !== null) {
  1727.                         try {
  1728.                             $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($municipalityId, true);
  1729.                             if ($municipality && $municipality->getGovernorate()) {
  1730.                                 $parentGovernorate = $municipality->getGovernorate();
  1731.                                 // Use parent governorate's names for matching (English first, then Arabic)
  1732.                                 $governorateNameEn = $parentGovernorate->getName('en');
  1733.                                 $governorateNameAr = $parentGovernorate->getName('ar');
  1734.                                 // Also update the ID to parent governorate's ID for matching
  1735.                                 $governorateId = $parentGovernorate->getGovernoteId();
  1736.                                 error_log("extractCoordinatesFromFileContent: Municipality detected (ID: " . $municipalityId . "), using parent governorate - ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1737.                             }
  1738.                         } catch (\Exception $ex) {
  1739.                             error_log("extractCoordinatesFromFileContent: Error fetching municipality (ID: " . $municipalityId . "): " . $ex->getMessage());
  1740.                         }
  1741.                     }
  1742.                 }
  1743.             } elseif (is_array($governorate)) {
  1744.                 $governorateId = $governorate['id'] ?? $governorate['governoteId'] ?? null;
  1745.                 $governorateNameEn = $governorate['name_en'] ?? $governorate['name']['en'] ?? null;
  1746.                 $governorateNameAr = $governorate['name_ar'] ?? $governorate['name']['ar'] ?? null;
  1747.                 $governorateObj = $governorate;
  1748.                 
  1749.                 // Check if this governorate is a municipality (array format)
  1750.                 if (isset($governorate['IsMunicipality']) && $governorate['IsMunicipality']) {
  1751.                     $municipalityId = $governorate['MunicipalityID'] ?? null;
  1752.                     if ($municipalityId !== null) {
  1753.                         try {
  1754.                             $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($municipalityId, true);
  1755.                             if ($municipality && $municipality->getGovernorate()) {
  1756.                                 $parentGovernorate = $municipality->getGovernorate();
  1757.                                 // Use parent governorate's names for matching (English first, then Arabic)
  1758.                                 $governorateNameEn = $parentGovernorate->getName('en');
  1759.                                 $governorateNameAr = $parentGovernorate->getName('ar');
  1760.                                 // Also update the ID to parent governorate's ID for matching
  1761.                                 $governorateId = $parentGovernorate->getGovernoteId();
  1762.                                 error_log("extractCoordinatesFromFileContent: Municipality detected (ID: " . $municipalityId . "), using parent governorate - ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1763.                             }
  1764.                         } catch (\Exception $ex) {
  1765.                             error_log("extractCoordinatesFromFileContent: Error fetching municipality (ID: " . $municipalityId . "): " . $ex->getMessage());
  1766.                         }
  1767.                     }
  1768.                 }
  1769.             } else {
  1770.                 continue;
  1771.             }
  1772.             
  1773.             if ($governorateId === null) {
  1774.                 continue;
  1775.             }
  1776.             
  1777.             // Search for the governorate section in the file
  1778.             // Try multiple patterns for both old (GovID) and new (ADMIN) formats
  1779.             // Patterns: "GovID": "76", "GovID": 76, "ADMIN": 12, "ADMIN": "12"
  1780.             $idStr = (string)$governorateId;
  1781.             $patterns = [
  1782.                 '"ADMIN"\s*:\s*"' . preg_quote($idStr, '/') . '"',
  1783.                 '"ADMIN"\s*:\s*' . preg_quote($idStr, '/'),
  1784.                 '"GovID"\s*:\s*"' . preg_quote($idStr, '/') . '"',
  1785.                 '"GovID"\s*:\s*' . preg_quote($idStr, '/'),
  1786.             ];
  1787.             
  1788.             $found = false;
  1789.             foreach ($patterns as $pattern) {
  1790.                 if (preg_match('/' . $pattern . '/', $fileContent, $matches, PREG_OFFSET_CAPTURE)) {
  1791.                     $matchPos = $matches[0][1];
  1792.                     $found = true;
  1793.                     
  1794.                     // Find the coordinates array that follows this ADMIN/GovID (within next 100000 chars)
  1795.                     $searchArea = substr($fileContent, $matchPos, 100000);
  1796.                     
  1797.                     // Look for coordinates array: "coordinates": [[[lng, lat], ...]]
  1798.                     if (preg_match('/"coordinates"\s*:\s*\[/', $searchArea, $coordMatch, PREG_OFFSET_CAPTURE)) {
  1799.                         $coordStartInArea = $coordMatch[0][1];
  1800.                         $coordStart = $matchPos + $coordStartInArea;
  1801.                         
  1802.                         // Extract the coordinates array by finding matching brackets
  1803.                         $depth = 0;
  1804.                         $startBracket = false;
  1805.                         $coordString = '';
  1806.                         $bracketCount = 0;
  1807.                         
  1808.                         // Find the opening bracket
  1809.                         for ($i = $coordStart; $i < strlen($fileContent) && $i < $coordStart + 200000; $i++) {
  1810.                             $char = $fileContent[$i];
  1811.                             if ($char === '[') {
  1812.                                 if (!$startBracket) {
  1813.                                     $startBracket = true;
  1814.                                 }
  1815.                                 $depth++;
  1816.                                 $bracketCount++;
  1817.                                 $coordString .= $char;
  1818.                             } elseif ($char === ']') {
  1819.                                 $depth--;
  1820.                                 $bracketCount++;
  1821.                                 $coordString .= $char;
  1822.                                 if ($depth === 0 && $startBracket) {
  1823.                                     break; // Found complete coordinates array
  1824.                                 }
  1825.                             } elseif ($startBracket) {
  1826.                                 $coordString .= $char;
  1827.                             } elseif (preg_match('/\S/', $char)) {
  1828.                                 // Non-whitespace before bracket - might be start
  1829.                                 if ($char === '[') {
  1830.                                     $startBracket = true;
  1831.                                     $depth = 1;
  1832.                                     $coordString = '[';
  1833.                                 }
  1834.                             }
  1835.                         }
  1836.                         
  1837.                         // Extract coordinates using regex (more reliable than JSON parsing for malformed JSON)
  1838.                         // Pattern: [ lng, lat ] or [lng,lat] - matches coordinate pairs
  1839.                         $coordPattern = '/\[\s*([+-]?\d+\.?\d*)\s*,\s*([+-]?\d+\.?\d*)\s*\]/';
  1840.                         preg_match_all($coordPattern, $coordString, $coordMatches, PREG_SET_ORDER);
  1841.                         
  1842.                             if (!empty($coordMatches)) {
  1843.                             foreach ($coordMatches as $match) {
  1844.                                 $lng = (float)$match[1];
  1845.                                 $lat = (float)$match[2];
  1846.                                 
  1847.                                 // Validate ranges
  1848.                                 if ($lat >= -90 && $lat <= 90 && $lng >= -180 && $lng <= 180) {
  1849.                                     $governorateCoords[] = [$lng, $lat];
  1850.                                 }
  1851.                             }
  1852.                         } else {
  1853.                             // Fallback: Try JSON decode if regex fails
  1854.                             $coordsArray = json_decode($coordString, true);
  1855.                             if ($coordsArray !== null && is_array($coordsArray)) {
  1856.                                 $coords = $this->extractCoordsFromArray($coordsArray);
  1857.                                 if (!empty($coords)) {
  1858.                                     $governorateCoords = $coords;
  1859.                                 }
  1860.                             }
  1861.                         }
  1862.                         
  1863.                         // Format coordinates for this governorate separately
  1864.                         if (!empty($governorateCoords)) {
  1865.                             $polygonCoords = $this->formatCoordinates($governorateCoords);
  1866.                             $governoratePolygons[] = [
  1867.                                 'governorate' => $governorateObj,
  1868.                                 'nameEn' => $governorateNameEn,
  1869.                                 'nameAr' => $governorateNameAr,
  1870.                                 'polygon' => $polygonCoords
  1871.                             ];
  1872.                         }
  1873.                     }
  1874.                     break; // Found match, no need to try other patterns
  1875.                 }
  1876.             }
  1877.         }
  1878.         
  1879.         return $governoratePolygons;
  1880.     }
  1881.     
  1882.     /**
  1883.      * Extract coordinate pairs from nested array structure (Polygon/MultiPolygon)
  1884.      */
  1885.     private function extractCoordsFromArray($coordsArray)
  1886.     {
  1887.         $coordinates = [];
  1888.         
  1889.         if (!is_array($coordsArray)) {
  1890.             return $coordinates;
  1891.         }
  1892.         
  1893.         // Check if it's a coordinate pair [lng, lat]
  1894.         if (count($coordsArray) === 2 && is_numeric($coordsArray[0]) && is_numeric($coordsArray[1])) {
  1895.             $coordinates[] = $coordsArray;
  1896.             return $coordinates;
  1897.         }
  1898.         
  1899.         // Recursively process nested arrays
  1900.         foreach ($coordsArray as $item) {
  1901.             if (is_array($item)) {
  1902.                 $subCoords = $this->extractCoordsFromArray($item);
  1903.                 $coordinates = array_merge($coordinates, $subCoords);
  1904.             }
  1905.         }
  1906.         
  1907.         return $coordinates;
  1908.     }
  1909.     
  1910.     /**
  1911.      * Format coordinates for CAP format
  1912.      */
  1913.     private function formatCoordinates($allCoordinates)
  1914.     {
  1915.         $formattedCoords = [];
  1916.         
  1917.         foreach ($allCoordinates as $coord) {
  1918.             if (is_array($coord) && count($coord) >= 2) {
  1919.                 if (!is_numeric($coord[0]) || !is_numeric($coord[1])) {
  1920.                     continue;
  1921.                 }
  1922.                 
  1923.                 $lng = (float)$coord[0];
  1924.                 $lat = (float)$coord[1];
  1925.                 
  1926.                 // Validate ranges
  1927.                 if ($lat < -90 || $lat > 90 || $lng < -180 || $lng > 180) {
  1928.                     continue;
  1929.                 }
  1930.                 
  1931.                 $formattedLat = number_format($lat, 6, '.', '');
  1932.                 $formattedLng = number_format($lng, 6, '.', '');
  1933.                 $formattedCoords[] = $formattedLat . ',' . $formattedLng;
  1934.             }
  1935.         }
  1936.         
  1937.         if (!empty($formattedCoords)) {
  1938.             $polygonCoords = implode(' ', $formattedCoords);
  1939.             
  1940.             // Ensure polygon is closed
  1941.             $coordsArray = explode(' ', $polygonCoords);
  1942.             $firstCoord = $coordsArray[0];
  1943.             $lastCoord = end($coordsArray);
  1944.             if ($firstCoord !== $lastCoord) {
  1945.                 $polygonCoords .= ' ' . $firstCoord;
  1946.             }
  1947.             
  1948.             return $polygonCoords;
  1949.         }
  1950.         
  1951.         return '';
  1952.     }
  1954.     /**
  1955.      * Create a fallback polygon when coordinates are invalid or missing
  1956.      * Creates a bounding box from region/governorate coordinates
  1957.      */
  1958.     private function createFallbackPolygon($doc, $notification, $governorateCoordinates, $timezone)
  1959.     {
  1960.         $polygonCoords = '';
  1961.         
  1962.         // Try to use governorate coordinates first
  1963.         if (!empty($governorateCoordinates)) {
  1964.             $coords = explode(' ', trim($governorateCoordinates));
  1965.             $validCoords = [];
  1966.             
  1967.             foreach ($coords as $coord) {
  1968.                 if (strpos($coord, ',') !== false) {
  1969.                     $parts = explode(',', $coord);
  1970.                     if (count($parts) == 2 && is_numeric($parts[0]) && is_numeric($parts[1])) {
  1971.                         $validCoords[] = $coord;
  1972.                     }
  1973.                 }
  1974.             }
  1975.             
  1976.             if (count($validCoords) >= 4) {
  1977.                 // Use governorate coordinates
  1978.                 $polygonCoords = implode(' ', $validCoords);
  1979.                 // Close the polygon
  1980.                 if (!empty($validCoords)) {
  1981.                     $firstCoord = $validCoords[0];
  1982.                     $lastCoord = end($validCoords);
  1983.                     if ($firstCoord !== $lastCoord) {
  1984.                         $polygonCoords .= ' ' . $firstCoord;
  1985.                     }
  1986.                 }
  1987.             }
  1988.         }
  1989.         
  1990.         // Fallback to region coordinates if governorate coordinates are insufficient
  1991.         if (empty($polygonCoords) && $notification->getRegion()) {
  1992.             $lat = $notification->getRegion()->getLatitude();
  1993.             $lng = $notification->getRegion()->getLongitude();
  1994.             
  1995.             if (is_numeric($lat) && is_numeric($lng)) {
  1996.                 // Create a small bounding box around the region center (0.1 degree radius)
  1997.                 $offset = 0.1;
  1998.                 $coords = [
  1999.                     ($lat - $offset) . ',' . ($lng - $offset), // SW
  2000.                     ($lat - $offset) . ',' . ($lng + $offset), // SE
  2001.                     ($lat + $offset) . ',' . ($lng + $offset), // NE
  2002.                     ($lat + $offset) . ',' . ($lng - $offset), // NW
  2003.                     ($lat - $offset) . ',' . ($lng - $offset)  // Close polygon
  2004.                 ];
  2005.                 $polygonCoords = implode(' ', $coords);
  2006.             }
  2007.         }
  2008.         
  2009.         // Final fallback: use default coordinates if nothing else works
  2010.         if (empty($polygonCoords)) {
  2011.             // Default coordinates for Saudi Arabia center (Riyadh area)
  2012.             $defaultCoords = [
  2013.                 '24.5,46.5',  // SW
  2014.                 '24.5,46.7',  // SE
  2015.                 '24.7,46.7',  // NE
  2016.                 '24.7,46.5',  // NW
  2017.                 '24.5,46.5'   // Close polygon
  2018.             ];
  2019.             $polygonCoords = implode(' ', $defaultCoords);
  2020.         }
  2021.         
  2022.         return $doc->createElement('polygon', $polygonCoords);
  2023.     }
  2025.     public function viewNotification($params, $translator): array
  2026.     {
  2027.         $result = [];
  2028.         // try {
  2030.         $viewNotification = DataObject\EwsNotification::getById($params['id'], false);
  2031.         if (!$viewNotification) {
  2032.             $viewNotification = DataObject\EwsNotification::getById($params['id'], true);
  2033.         }
  2034.         if ($viewNotification) {
  2035.             $notificationData = $this->createNotificationFormat($viewNotification, $translator);
  2036.             $history =  $this->getVersions($viewNotification, $translator);
  2037.             return ["success" => true, "data" => $notificationData, "history" => $history];
  2038.         }
  2040.         return ["success" => false, "message" => $translator->trans("ews_notification_does_not_exists")];
  2041.         // } catch (\Exception $ex) {
  2042.         //     $result = ["success" => false, "message" => $ex->getMessage()];
  2043.         // }
  2045.         return $result;
  2046.     }
  2048.     public function addAddressComponentsFieldCollection($addressComponents, DataObject\EwsNotification $object)
  2049.     {
  2050.         $items = new \Pimcore\Model\DataObject\Fieldcollection();
  2052.         foreach ($addressComponents as $Data) {
  2054.             #creating field collections
  2055.             $item = new DataObject\Fieldcollection\Data\AddressComponents();
  2056.             $item->setAddressValue(strip_tags($Data['long_name']));
  2057.             $item->setAddressKey(strip_tags($Data['types'][0]));
  2059.             $items->add($item);
  2060.         }
  2062.         return $object->setAddressComponents($items);
  2063.     }
  2065.     public function getAlertAction($id)
  2066.     {
  2067.         $alertActionObj = DataObject\AlertAction::getById($id);
  2068.         $data = [];
  2069.         if (!empty($alertActionObj)) {
  2070.             $data['id'] = $alertActionObj->getAlertActionId();
  2071.             $data['severity'] = $alertActionObj->getSeverity();
  2072.             $data['nameEn'] = $alertActionObj->getName('en');
  2073.             $data['nameAr'] = $alertActionObj->getName('ar');
  2074.         }
  2075.         return $data;
  2076.     }
  2077.     public function getAlertType($id)
  2078.     {
  2079.         $alertTypeObj = DataObject\AlertType::getById($id);
  2080.         $data = [];
  2081.         if (!empty($alertTypeObj)) {
  2082.             $data['id'] = $alertTypeObj->getAlertTypeId();
  2083.             $data['nameEn'] = $alertTypeObj->getName('en');
  2084.             $data['nameAr'] = $alertTypeObj->getName('ar');
  2085.         }
  2086.         return $data;
  2087.     }
  2089.     public function getAlertStatus($id)
  2090.     {
  2091.         $alertStatus = DataObject\AlertStatus::getById($id);
  2092.         $data = [];
  2093.         if (!empty($alertStatus)) {
  2094.             $alertType = $alertStatus->getAlertType();
  2095.             $alertData = [];
  2096.             if (!empty($alertType)) {
  2097.                 $alertData = [
  2098.                     "id" => $alertType->getAlertTypeId(),
  2099.                     "nameEn" => $alertType->getName('en'),
  2100.                     "nameAr" => $alertType->getName('ar')
  2102.                 ];
  2103.             }
  2104.             $data['id'] = $alertStatus->getAlertStatusId();
  2105.             $data['nameEn'] = $alertStatus->getName('en');
  2106.             $data['nameAr'] = $alertStatus->getName('ar');
  2107.             $data['alertType'] = $alertData;
  2108.         }
  2109.         return $data;
  2110.     }
  2112.     public function getAlertHazard($id)
  2113.     {
  2114.         $alertHazardObj = DataObject\AlertHazard::getById($id);
  2115.         $data = [];
  2116.         if (!empty($alertHazardObj)) {
  2117.             $data['id'] = $alertHazardObj->getAlertHazardId();
  2118.             $data['nameEn'] = $alertHazardObj->getName('en');
  2119.             $data['nameAr'] = $alertHazardObj->getName('ar');
  2120.         }
  2121.         return $data;
  2122.     }
  2124.     public function getRegion($id)
  2125.     {
  2126.         $regionObj = DataObject\Region::getById($id);
  2127.         $data = [];
  2128.         if (!empty($regionObj)) {
  2129.             $data['id'] = $regionObj->getRegionId();
  2130.             $data['nameEn'] = $regionObj->getName('en');
  2131.             $data['nameAr'] = $regionObj->getName('ar');
  2132.             $data['longitude'] = $regionObj->getLongitude();
  2133.             $data['latitude'] = $regionObj->getLatitude();
  2134.         }
  2135.         return $data;
  2136.     }
  2138.     public function getEvent($id)
  2139.     {
  2140.         $eventObj = DataObject\Event::getById($id);
  2141.         $data = [];
  2142.         if (!empty($eventObj)) {
  2143.             $data['id'] = $eventObj->getEventId();
  2144.             $data['nameEn'] = $eventObj->getName('en');
  2145.             $data['nameAr'] = $eventObj->getName('ar');
  2146.         }
  2147.         return $data;
  2148.     }
  2150.     public function getWeatherPhenomenon($id)
  2151.     {
  2152.         $weatherPhenObj = DataObject\PhenomenaList::getById($id);
  2153.         $data = [];
  2154.         if (!empty($weatherPhenObj)) {
  2155.             $data['id'] = $weatherPhenObj->getPhenomenaListId();
  2156.             $data['nameEn'] = $weatherPhenObj->getTitle('en');
  2157.             $data['nameAr'] = $weatherPhenObj->getTitle('ar');
  2158.         }
  2159.         return $data;
  2160.     }
  2162.     public function getWeatherPhenAffect($id)
  2163.     {
  2164.         $weatherPhenObj = DataObject\WeatherPhenomenonAffect::getById($id);
  2165.         $data = [];
  2166.         if (!empty($weatherPhenObj)) {
  2167.             $data['id'] = $weatherPhenObj->getWeatherPhenomenonAffectId();
  2168.             $data['nameEn'] = $weatherPhenObj->getName('en');
  2169.             $data['nameAr'] = $weatherPhenObj->getName('ar');
  2170.         }
  2171.         return $data;
  2172.     }
  2173.     // public function getGovernorateDetail($governorateList)
  2174.     // {
  2175.     //     $result = [];
  2176.     //     if (!empty($governorateList)) {
  2177.     //         for ($i = 0; $i < count($governorateList); $i++) {
  2178.     //             $parentGovernates = null;
  2179.     //             if ($governorateList[$i]->getIsMunicipality()) {
  2181.     //                 $municipatlity = \Pimcore\Model\DataObject\Municipality::getByMunicipalityId($governorateList[$i]->getMunicipalityID(), true);
  2183.     //                 if ($municipatlity &&  $municipatlity->getGovernorate()) {
  2184.     //                     $parentGovernates = $municipatlity->getGovernorate();
  2185.     //                 }
  2186.     //             }
  2187.     //             $result[$i]['id'] = $governorateList[$i]->getGovernoteId();
  2188.     //             $result[$i]['nameEn'] = $governorateList[$i]->getName('en');
  2189.     //             $result[$i]['nameAr'] = $governorateList[$i]->getName('ar');
  2190.     //             $result[$i]['longitude'] = $governorateList[$i]->getLongitude();
  2191.     //             $result[$i]['latitude'] = $governorateList[$i]->getLatitude();
  2192.     //             $result[$i]['parentId'] = $parentGovernates ? $parentGovernates->getGovernoteId() : null;
  2194.     //             $result[$i]['parenNameEn'] = $parentGovernates ? $parentGovernates->getName('en') : null;
  2195.     //             $result[$i]['parenNameAr'] = $parentGovernates ? $parentGovernates->getName('ar') : null;
  2197.     //             $result[$i]['parentLongitude'] = $parentGovernates ? $parentGovernates->getLongitude() : null;
  2198.     //             $result[$i]['parentLatitude'] = $parentGovernates ? $parentGovernates->getLatitude() : null;
  2199.     //             $result[$i]['isMunicipality'] = $governorateList[$i]->getIsMunicipality();
  2200.     //             $result[$i]['municipalities'] = [];
  2201.     //         }
  2202.     //     }
  2203.     //     return $result;
  2204.     // }
  2206.     public function getGovernorateDetail($governorateList)
  2207.     {
  2208.         $result = [];
  2209.         if (!empty($governorateList)) {
  2210.             $uniqueGovernorateArray = [];
  2211.             foreach ($governorateList as $governorate) {
  2212.                 $parentGovernates = null;
  2214.                 // Check if it is a municipality and fetch parent governorate
  2215.                 if ($governorate->getIsMunicipality()) {
  2216.                     $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityId($governorate->getMunicipalityID(), true);
  2217.                     if ($municipality && $municipality->getGovernorate()) {
  2218.                         $parentGovernates = $municipality->getGovernorate();
  2219.                     }
  2220.                 }
  2222.                 // Initialize a unique governorate array if needed
  2223.                 $parentId = $parentGovernates ? $parentGovernates->getGovernoteId() : $governorate->getGovernoteId();
  2225.                 if (!isset($uniqueGovernorateArray[$parentId])) {
  2226.                     $uniqueGovernorateArray[$parentId] = [
  2227.                         'id' => $parentId,
  2228.                         'nameEn' => $parentGovernates ? $parentGovernates->getName('en') : $governorate->getName('en'),
  2229.                         'nameAr' => $parentGovernates ? $parentGovernates->getName('ar') : $governorate->getName('ar'),
  2230.                         'longitude' => $parentGovernates ? $parentGovernates->getLongitude() : $governorate->getLongitude(),
  2231.                         'latitude' => $parentGovernates ? $parentGovernates->getLatitude() : $governorate->getLatitude(),
  2232.                         'municipalities' => []
  2233.                     ];
  2234.                 }
  2236.                 // Add municipality details if it is a municipality
  2237.                 if ($governorate->getIsMunicipality()) {
  2238.                     $uniqueGovernorateArray[$parentId]['municipalities'][] = [
  2239.                         'id' => $governorate->getGovernoteId(),
  2240.                         'nameEn' => $governorate->getName('en'),
  2241.                         'nameAr' => $governorate->getName('ar'),
  2242.                         'longitude' => $governorate->getLongitude(),
  2243.                         'latitude' => $governorate->getLatitude()
  2244.                     ];
  2245.                 }
  2246.             }
  2248.             // Flatten the associative array to a numerical array for output
  2249.             $result = array_values($uniqueGovernorateArray);
  2250.         }
  2252.         return $result;
  2253.     }
  2256.     public function getMessageDetail($notificationObj)
  2257.     {
  2258.         $data = [];
  2259.         if (!empty($notificationObj)) {
  2260.             $data['messageEn'] = $notificationObj->getMessage('en');
  2261.             $data['messageAr'] = $notificationObj->getMessage('ar');
  2262.         }
  2263.         return $data;
  2264.     }
  2266.     public function createAsset($fileData, $filename)
  2267.     {
  2269.         // Validate the file data
  2270.         if (preg_match('/^data:(image\/(png|jpe?g)|application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel));base64,/', $fileData) !== 1) {
  2271.             return false; // Invalid file data or MIME type
  2272.         }
  2274.         // Extract the file extension from the MIME type
  2275.         $extension = '';
  2276.         if (preg_match('/^data:image\/(png|jpe?g);base64,/', $fileData)) {
  2277.             $extension = 'jpg'; // Assume JPG for base64-encoded image data (PNG or JPEG)
  2278.         } elseif (preg_match('/^data:application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel);base64,/', $fileData)) {
  2279.             $extension = 'pdf'; // PDF, DOCX, or Excel
  2280.         }
  2282.         // Remove the "data:image/png;base64," or "data:application/pdf;base64," prefix to get the actual base64-encoded content
  2283.         $base64Content = preg_replace('/^data:(image\/png|application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel));base64,/', '', $fileData);
  2285.         // Decode the base64-encoded content
  2286.         $fileContent = base64_decode($base64Content);
  2288.         // Validate the decoded content
  2289.         if ($fileContent === false) {
  2290.             return false; // Invalid base64-encoded content
  2291.         }
  2293.         // Create the Pimcore asset
  2294.         $asset = new \Pimcore\Model\Asset();
  2295.         $parent = Asset\Service::createFolderByPath('/EWSNotification');
  2296.         $asset->setFilename($filename); // Replace with the desired filename and extension
  2297.         $asset->setParent($parent);
  2298.         $asset->setData($fileContent);
  2300.         // Set the MIME type based on the file extension
  2301.         $mimeType = '';
  2302.         if ($extension === 'pdf') {
  2303.             $mimeType = 'application/pdf';
  2304.         } elseif ($extension === 'jpg') {
  2305.             $mimeType = 'image/jpeg';
  2306.         } elseif ($extension === 'png') {
  2307.             $mimeType = 'image/png';
  2308.         } elseif ($extension === 'docx') {
  2309.             $mimeType = 'application/vnd.openxmlformats-officedocument.wordprocessingml.document';
  2310.         } elseif ($extension === 'xlsx') {
  2311.             $mimeType = 'application/vnd.ms-excel';
  2312.         }
  2314.         // Validate the MIME type
  2315.         if (!in_array($mimeType, ['image/jpeg', 'image/png', 'application/pdf', 'application/vnd.openxmlformats-officedocument.wordprocessingml.document', 'application/vnd.ms-excel'])) {
  2316.             return false; // Invalid MIME type
  2317.         }
  2319.         $asset->setType($mimeType);
  2321.         // Save the asset
  2322.         $asset->save();
  2324.         return $asset;
  2325.     }
  2327.     public function getPhenomenaListByAlertId($alertID, $lang = "en")
  2328.     {
  2329.         $response = [];
  2330.         $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alertID, true);
  2331.         if ($alertType instanceof \Pimcore\Model\DataObject\AlertType) {
  2332.             $phenomenaList = $alertType->getPhenomenaList();
  2333.             if ($phenomenaList) {
  2334.                 foreach ($phenomenaList as $phenomena) {
  2335.                     $phenomenaId = $phenomena->getPhenomena();
  2336.                     if ($phenomenaId) {
  2337.                         $phenomenaObj = \Pimcore\Model\DataObject::getById($phenomenaId);
  2338.                         $response[] = ["id" => $phenomenaObj->getphenomenaListId(), "nameEn" => $phenomenaObj->getTitle("en"), "nameAr" => $phenomenaObj->getTitle("ar"), "criteria" => $phenomena->getCriteria()];
  2339.                     }
  2340.                 }
  2341.             } else {
  2342.                 return ["success" => false, "message" => "No criteria is set"];
  2343.             }
  2344.         } else {
  2345.             return ["success" => false, "message" => "Invalid alert type id"];
  2346.         }
  2347.         return ["success" => true, "data" => $response];
  2348.     }
  2350.     public function getPhenomenaListByAlertIds($alertIDs, $lang = "en")
  2351.     {
  2352.         $response = [];
  2353.         if (count($alertIDs) > 0) {
  2354.             foreach ($alertIDs as $alertID) {
  2355.                 $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alertID, true);
  2357.                 if ($alertType instanceof \Pimcore\Model\DataObject\AlertType) {
  2358.                     $phenomenaList = $alertType->getPhenomenaList();
  2360.                     if ($phenomenaList) {
  2361.                         foreach ($phenomenaList as $phenomena) {
  2362.                             $phenomenaId = $phenomena->getPhenomena();
  2364.                             if ($phenomenaId) {
  2365.                                 $phenomenaObj = \Pimcore\Model\DataObject::getById($phenomenaId);
  2366.                                 if ($phenomenaObj instanceof \Pimcore\Model\DataObject) {
  2367.                                     $currentId = $phenomenaObj->getphenomenaListId();
  2368.                                     $existingIds = array_column($response, 'id');
  2370.                                     if (!in_array($currentId, $existingIds)) {
  2371.                                         $response[] = [
  2372.                                             "id" => $currentId,
  2373.                                             "nameEn" => $phenomenaObj->getTitle("en"),
  2374.                                             "nameAr" => $phenomenaObj->getTitle("ar"),
  2375.                                             "criteria" => $phenomena->getCriteria()
  2376.                                         ];
  2377.                                     } else {
  2378.                                         $index = array_search($currentId, $existingIds);
  2379.                                         $response[$index]['criteria'] .= ', ' . $phenomena->getCriteria();
  2380.                                     }
  2381.                                 }
  2382.                             }
  2383.                         }
  2384.                     } else {
  2385.                         return ["success" => false, "message" => "No criteria is set"];
  2386.                     }
  2387.                 }
  2388.             }
  2390.             return ["success" => true, "data" => $response];
  2391.         }
  2393.         return ["success" => false, "message" => "Invalid alert type id"];
  2394.     }
  2396.     public function getAlertActions()
  2397.     {
  2398.         $response = [];
  2399.         $alertActions = new DataObject\AlertAction\Listing();
  2400.         $alertActions = $alertActions->load();
  2401.         if ($alertActions) {
  2402.             foreach ($alertActions as $alertAction) {
  2403.                 $response[] = [
  2404.                     "id" => $alertAction->getAlertActionId(),
  2405.                     "nameEn" => $alertAction->getName('en'),
  2406.                     "nameAr" => $alertAction->getName('ar'),
  2407.                     "severity" => $alertAction->getSeverity()
  2408.                 ];
  2409.             }
  2410.         }
  2411.         return ["success" => true, "data" => $response];
  2412.     }
  2414.     public function getAlertHazards()
  2415.     {
  2416.         $response = [];
  2417.         $alertHazards = new DataObject\AlertHazard\Listing();
  2418.         $alertHazards = $alertHazards->load();
  2419.         if ($alertHazards) {
  2420.             foreach ($alertHazards as $alertHazard) {
  2421.                 $response[] = [
  2422.                     "id" => $alertHazard->getalertHazardId(),
  2423.                     "nameEn" => $alertHazard->getName('en'),
  2424.                     "nameAr" => $alertHazard->getName('ar'),
  2425.                     "OrderId" => $alertHazard->getOrderId()
  2426.                 ];
  2427.             }
  2428.         }
  2430.         return ["success" => true, "data" => $response];
  2431.     }
  2433.     public function getAlertTypes()
  2434.     {
  2435.         $response = [];
  2436.         $alertTypes = new DataObject\AlertType\Listing();
  2437.         $alertTypes = $alertTypes->load();
  2438.         if ($alertTypes) {
  2439.             foreach ($alertTypes as $alertType) {
  2440.                 $response[] = [
  2441.                     "id" => $alertType->getAlertTypeId(),
  2442.                     "color" => $alertType->getColor(),
  2443.                     "nameEn" => $alertType->getName('en'),
  2444.                     "nameAr" => $alertType->getName('ar')
  2445.                 ];
  2446.             }
  2447.         }
  2449.         return ["success" => true, "data" => $response];
  2450.     }
  2452.     public function getEvents()
  2453.     {
  2454.         $response = [];
  2455.         $events = new DataObject\Event\Listing();
  2456.         $events = $events->load();
  2457.         if ($events) {
  2458.             foreach ($events as $event) {
  2459.                 $response[] = [
  2460.                     "id" => $event->getEventId(),
  2461.                     "nameEn" => $event->getName('en'),
  2462.                     "nameAr" => $event->getName('ar')
  2464.                 ];
  2465.             }
  2466.         }
  2468.         return ["success" => true, "data" => $response];
  2469.     }
  2470.     public function getWeatherPhenomenones()
  2471.     {
  2472.         $response = [];
  2473.         $weatherPhenomenons = new DataObject\PhenomenaList\Listing();
  2474.         $weatherPhenomenons = $weatherPhenomenons->load();
  2475.         if ($weatherPhenomenons) {
  2476.             foreach ($weatherPhenomenons as $weatherPhenomenon) {
  2477.                 $response[] = [
  2478.                     "id" => $weatherPhenomenon->getPhenomenaListId(),
  2479.                     "nameEn" => $weatherPhenomenon->getTitle('en'),
  2480.                     "nameAr" => $weatherPhenomenon->getTitle('ar')
  2482.                 ];
  2483.             }
  2484.         }
  2486.         return ["success" => true, "data" => $response];
  2487.     }
  2489.     public function getWeatherPhenomenonAffect()
  2490.     {
  2491.         $response = [];
  2492.         $getWeatherPhenomAffects = new DataObject\WeatherPhenomenonAffect\Listing();
  2493.         $getWeatherPhenomAffects = $getWeatherPhenomAffects->load();
  2494.         if ($getWeatherPhenomAffects) {
  2495.             foreach ($getWeatherPhenomAffects as $getWeatherPhenomAffect) {
  2496.                 $response[] = [
  2497.                     "id" => $getWeatherPhenomAffect->getWeatherPhenomenonAffectId(),
  2498.                     "nameEn" => $getWeatherPhenomAffect->getName('en'),
  2499.                     "nameAr" => $getWeatherPhenomAffect->getName('ar')
  2501.                 ];
  2502.             }
  2503.         }
  2505.         return ["success" => true, "data" => $response];
  2506.     }
  2508.     public function getAlertStatuses($params)
  2509.     {
  2510.         $response = [];
  2511.         $alertStatuss = new DataObject\AlertStatus\Listing();
  2513.         // Handle search by name
  2514.         if (isset($params['search']) && !empty($params['search'])) {
  2515.             $alertStatuss->addConditionParam("name LIKE ?", "%" . $params['search'] . "%");
  2516.         }
  2518.         // Handle alert type filter
  2519.         if (isset($params['alert_id']) && !empty($params['alert_id'])) {
  2520.             $alertTypeIds = [];
  2521.             $alertTypeList = new DataObject\AlertType\Listing();
  2522.             $alertTypeList->addConditionParam("alertTypeId IN (?)", [$params['alert_id']]);
  2523.             foreach ($alertTypeList as $alertType) {
  2524.                 $alertTypeIds[] = $alertType->getId();
  2525.             }
  2526.             $alertStatuss->addConditionParam("alertType__id IN (?)", [$alertTypeIds]);
  2527.         }
  2529.         // Check for regionId array and isLandLocked logic
  2530.         $excludeWavesRising = false;
  2531.         if (isset($params['regionId']) && is_array($params['regionId']) && count($params['regionId']) > 0) {
  2532.             foreach ($params['regionId'] as $regionId) {
  2533.                 $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  2534.                 if ($region && $region->getIsLandLocked()) {
  2535.                     $excludeWavesRising = true;
  2536.                     break;
  2537.                 }
  2538.             }
  2539.         }
  2541.         $alertStatuss = $alertStatuss->load();
  2543.         if ($alertStatuss) {
  2544.             foreach ($alertStatuss as $alertStatus) {
  2545.                 // Exclude "Waves rising" if needed
  2546.                 if ($excludeWavesRising && ((strtolower(trim($alertStatus->getName('en'))) === 'waves rising'))) {
  2547.                     continue;
  2548.                 }
  2550.                 $alertType = $alertStatus->getAlertType();
  2551.                 $alertData = [];
  2552.                 if (!empty($alertType)) {
  2553.                     $alertData = [
  2554.                         "id" => $alertType->getAlertTypeId(),
  2555.                         "nameEn" => $alertType->getName('en'),
  2556.                         "nameAr" => $alertType->getName('ar')
  2557.                     ];
  2558.                 }
  2559.                 $response[] = [
  2560.                     "id" => $alertStatus->getalertStatusId(),
  2561.                     "nameEn" => $alertStatus->getName('en'),
  2562.                     "nameAr" => $alertStatus->getName('ar'),
  2563.                     "imageTemplate" => $alertStatus->getimageTemplate(),
  2564.                     "alertType" => $alertData
  2565.                 ];
  2566.             }
  2567.         }
  2569.         return ["success" => true, "data" => $response];
  2570.     }
  2572.     public function getGovernorates()
  2573.     {
  2574.         $response = [];
  2575.         $governorates = new DataObject\Governorate\Listing();
  2576.         $Governorates = $governorates->load();
  2577.         if ($governorates) {
  2578.             foreach ($governorates as $governorate) {
  2579.                 $region = $governorate->getregionId();
  2580.                 $regionData = [];
  2581.                 if (!empty($region)) {
  2582.                     $regionData = [
  2583.                         "id" => $region->getRegionId(),
  2584.                         "nameEn" => $region->getName('en'),
  2585.                         "nameAr" => $region->getName('ar'),
  2586.                         "longitude" => $region->getLongitude(),
  2587.                         "latitude" => $region->getLongitude()
  2589.                     ];
  2590.                 }
  2591.                 $response[] = [
  2592.                     "id" => $governorate->getgovernoteId(),
  2593.                     "nameEn" => $governorate->getName('en'),
  2594.                     "nameAr" => $governorate->getName('ar'),
  2595.                     "regionId" => $regionData,
  2596.                     "longitude" => $governorate->getLongitude(),
  2597.                     "latitude" => $governorate->getLatitude(),
  2598.                     "isHidden" => $governorate->getisHidden(),
  2599.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  2600.                     "MunicipalityID" => $governorate->getMunicipalityID()
  2601.                 ];
  2602.             }
  2603.         }
  2605.         return ["success" => true, "data" => $response];
  2606.     }
  2608.     public function getMunicipality($governorateId = null, $lang = 'en')
  2609.     {
  2610.         $response = [];
  2611.         $municipalities = new DataObject\Municipality\Listing();
  2612.         if (is_array($governorateId)) {
  2613.             $govIdsArr = [];
  2614.             foreach ($governorateId as $govId) {
  2615.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  2616.                 if ($governorate) {
  2617.                     array_push($govIdsArr, $governorate->getId());
  2618.                 }
  2619.             }
  2620.             $municipalities->setCondition("governorate__id IN (" . implode(", ", $govIdsArr) . ")");
  2621.         } else {
  2622.             if ($governorateId) {
  2623.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($governorateId, true);
  2624.                 $municipalities->setCondition("governorate__id = ?", [$governorate->getId()]);
  2625.             }
  2626.         }
  2627.         $municipalities = $municipalities->load();
  2628.         if ($municipalities) {
  2629.             foreach ($municipalities as $municipality) {
  2630.                 $response[] = [
  2631.                     "id" => $municipality->getMunicipalityid(),
  2632.                     "nameEn" => $municipality->getName('en'),
  2633.                     "nameAr" => $municipality->getName('ar'),
  2634.                     "longitude" => $municipality->getLongitude(),
  2635.                     "latitude" => $municipality->getLatitude(),
  2636.                     "governate" => $municipality->getGovernorate()->getGovernoteId()
  2637.                 ];
  2638.             }
  2639.         }
  2641.         // Determine sorting field based on language
  2642.         $sortField = 'nameEn'; // Default sorting by English
  2643.         if (isset($lang) && strtolower($lang) === 'ar') {
  2644.             $sortField = 'nameAr'; // Sorting by Arabic
  2645.         }
  2647.         // Sort manually using usort()
  2648.         usort($response, function ($a, $b) use ($sortField) {
  2649.             return strcmp($a[$sortField], $b[$sortField]);
  2650.         });
  2652.         return ["success" => true, "data" => $response];
  2653.     }
  2654.     public function getMunicipalityByParams($governorateId = null,$search = null, $lang = 'en')
  2655.     {
  2656.         $response = [];
  2657.         $municipalities = new DataObject\Municipality\Listing();
  2658.         if (is_array($governorateId)) {
  2659.             $govIdsArr = [];
  2660.             foreach ($governorateId as $govId) {
  2661.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  2662.                 if ($governorate) {
  2663.                     array_push($govIdsArr, $governorate->getId());
  2664.                 }
  2665.             }
  2666.             $municipalities->setCondition("governorate__id IN (" . implode(", ", $govIdsArr) . ")");
  2667.         } else {
  2668.             if ($governorateId) {
  2669.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($governorateId, true);
  2670.                 $municipalities->setCondition("governorate__id = ?", [$governorate->getId()]);
  2671.             }
  2672.         }
  2673.         if (isset($search)) {
  2674.             $municipalities->addConditionParam("name LIKE ?", "%{$search}%");
  2675.         }
  2676.         $municipalities = $municipalities->load();
  2677.         if ($municipalities) {
  2678.             foreach ($municipalities as $municipality) {
  2679.                 $response[] = [
  2680.                     "id" => $municipality->getMunicipalityid(),
  2681.                     "nameEn" => $municipality->getName('en'),
  2682.                     "nameAr" => $municipality->getName('ar'),
  2683.                     "longitude" => $municipality->getLongitude(),
  2684.                     "latitude" => $municipality->getLatitude(),
  2685.                     "governate" => $municipality->getGovernorate()->getGovernoteId()
  2686.                 ];
  2687.             }
  2688.         }
  2690.         // Determine sorting field based on language
  2691.         $sortField = 'nameEn'; // Default sorting by English
  2692.         if (isset($lang) && strtolower($lang) === 'ar') {
  2693.             $sortField = 'nameAr'; // Sorting by Arabic
  2694.         }
  2696.         // Sort manually using usort()
  2697.         usort($response, function ($a, $b) use ($sortField) {
  2698.             return strcmp($a[$sortField], $b[$sortField]);
  2699.         });
  2701.         return ["success" => true, "data" => $response];
  2702.     }
  2703.     public function getGovernoratesByRegion($params)
  2704.     {
  2705.         $response = [];
  2707.         $governorates = new DataObject\Governorate\Listing();
  2709.         if (isset($params['region_id'])) {
  2710.             $region = \Pimcore\Model\DataObject\Region::getByRegionId($params['region_id'], true);
  2711.             if (!$region) {
  2712.                 throw new \Exception("Region not available");
  2713.             }
  2714.             $governorates->filterByRegionId($region);
  2715.         }
  2717.         if (isset($params['region_ids']) && !empty($params['region_ids'])) {
  2718.             $regionIds = [];
  2719.             $regionList = new DataObject\Region\Listing();
  2720.             $regionList->addConditionParam("regionId IN (?)", [$params['region_ids']]);
  2721.             foreach ($regionList as $region) {
  2722.                 $regionIds[] = $region->getId();
  2723.             }
  2724.             $governorates->addConditionParam("regionId__id IN (?)", [$regionIds]);
  2725.         }
  2727.         // Load governorates without sorting in Pimcore
  2728.         $governorates = $governorates->load();
  2730.         // Convert to array for manual sorting
  2731.         $count = 0;
  2732.         if ($governorates) {
  2733.             foreach ($governorates as $governorate) {
  2734.                 $region = $governorate->getregionId();
  2735.                 $regionData = [];
  2736.                 if (!empty($region)) {
  2737.                     $regionData = [
  2738.                         "id" => $region->getRegionId(),
  2739.                         "nameEn" => $region->getName('en'),
  2740.                         "nameAr" => $region->getName('ar'),
  2741.                         "longitude" => $region->getLongitude(),
  2742.                         "latitude" => $region->getLatitude()
  2744.                     ];
  2745.                 }
  2746.                 $response[$count] = [
  2747.                     "id" => $governorate->getgovernoteId(),
  2748.                     "nameEn" => $governorate->getName('en'),
  2749.                     "nameAr" => $governorate->getName('ar'),
  2750.                     "regionId" => $regionData,
  2751.                     "longitude" => $governorate->getLongitude(),
  2752.                     "latitude" => $governorate->getLatitude(),
  2753.                     "isHidden" => $governorate->getisHidden(),
  2754.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  2755.                     "MunicipalityID" => $governorate->getMunicipalityID(),
  2756.                     "bbox" => $governorate->getBbox()
  2757.                 ];
  2759.                 if ($governorate->getMunicipalityID() && $governorate->getIsMunicipality()) {
  2760.                     $municipality = \Pimcore\Model\DataObject\Municipality::getBymunicipalityid($governorate->getMunicipalityID(), true);
  2761.                     if ($municipality) {
  2762.                         $muniGovernate = $municipality->getgovernorate();
  2763.                         if ($muniGovernate) {
  2764.                             $response[$count]["parent_id"] = $muniGovernate->getgovernoteId();
  2765.                             $response[$count]["parent_longitude"] = $muniGovernate->getLongitude();
  2766.                             $response[$count]["parent_latitude"] = $muniGovernate->getLatitude();
  2767.                             $response[$count]["parent_name_en"] = $muniGovernate->getName("en");
  2768.                             $response[$count]["parent_name_ar"] = $muniGovernate->getName("ar");
  2769.                         }
  2770.                     }
  2771.                 }
  2772.                 $count++;
  2773.             }
  2774.         }
  2776.         // Determine sorting field based on language
  2777.         $sortField = 'nameEn'; // Default sorting by English
  2778.         if (isset($params['lang']) && strtolower($params['lang']) === 'ar') {
  2779.             $sortField = 'nameAr'; // Sorting by Arabic
  2780.         }
  2782.         // Sort manually using usort()
  2783.         usort($response, function ($a, $b) use ($sortField) {
  2784.             return strcmp($a[$sortField], $b[$sortField]);
  2785.         });
  2787.         return ["success" => true, "data" => $response];
  2788.     }
  2790.     public function getGovernoratesByParams($params)
  2791.     {
  2792.         $response = [];
  2794.         $governorates = new DataObject\Governorate\Listing();
  2796.         if (isset($params['region_id'])) {
  2797.             $region = \Pimcore\Model\DataObject\Region::getByRegionId($params['region_id'], true);
  2798.             if (!$region) {
  2799.                 throw new \Exception("Region not available");
  2800.             }
  2801.             $governorates->filterByRegionId($region);
  2802.         }
  2804.         if (isset($params['region_ids']) && !empty($params['region_ids'])) {
  2805.             $regionIds = [];
  2806.             $regionList = new DataObject\Region\Listing();
  2807.             $regionList->addConditionParam("regionId IN (?)", [$params['region_ids']]);
  2808.             foreach ($regionList as $region) {
  2809.                 $regionIds[] = $region->getId();
  2810.             }
  2811.             $governorates->addConditionParam("regionId__id IN (?)", [$regionIds]);
  2812.         }
  2813.         if (isset($params['search'])) {
  2814.             $governorates->addConditionParam("name LIKE ?", "%{$params['search']}%");
  2815.         }
  2816.         // Load governorates without sorting in Pimcore
  2817.         $governorates = $governorates->load();
  2819.         // Convert to array for manual sorting
  2820.         $count = 0;
  2821.         if ($governorates) {
  2822.             foreach ($governorates as $governorate) {
  2823.                 $region = $governorate->getregionId();
  2824.                 $regionData = [];
  2825.                 if (!empty($region)) {
  2826.                     $regionData = [
  2827.                         "id" => $region->getRegionId(),
  2828.                         "nameEn" => $region->getName('en'),
  2829.                         "nameAr" => $region->getName('ar'),
  2830.                         "longitude" => $region->getLongitude(),
  2831.                         "latitude" => $region->getLatitude()
  2833.                     ];
  2834.                 }
  2835.                 $response[$count] = [
  2836.                     "id" => $governorate->getgovernoteId(),
  2837.                     "nameEn" => $governorate->getName('en'),
  2838.                     "nameAr" => $governorate->getName('ar'),
  2839.                     "regionId" => $regionData,
  2840.                     "longitude" => $governorate->getLongitude(),
  2841.                     "latitude" => $governorate->getLatitude(),
  2842.                     "isHidden" => $governorate->getisHidden(),
  2843.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  2844.                     "MunicipalityID" => $governorate->getMunicipalityID(),
  2845.                     "bbox" => $governorate->getBbox()
  2846.                 ];
  2848.                 if ($governorate->getMunicipalityID() && $governorate->getIsMunicipality()) {
  2849.                     $municipality = \Pimcore\Model\DataObject\Municipality::getBymunicipalityid($governorate->getMunicipalityID(), true);
  2850.                     if ($municipality) {
  2851.                         $muniGovernate = $municipality->getgovernorate();
  2852.                         if ($muniGovernate) {
  2853.                             $response[$count]["parent_id"] = $muniGovernate->getgovernoteId();
  2854.                             $response[$count]["parent_longitude"] = $muniGovernate->getLongitude();
  2855.                             $response[$count]["parent_latitude"] = $muniGovernate->getLatitude();
  2856.                             $response[$count]["parent_name_en"] = $muniGovernate->getName("en");
  2857.                             $response[$count]["parent_name_ar"] = $muniGovernate->getName("ar");
  2858.                         }
  2859.                     }
  2860.                 }
  2861.                 $count++;
  2862.             }
  2863.         }
  2865.         // Determine sorting field based on language
  2866.         $sortField = 'nameEn'; // Default sorting by English
  2867.         if (isset($params['lang']) && strtolower($params['lang']) === 'ar') {
  2868.             $sortField = 'nameAr'; // Sorting by Arabic
  2869.         }
  2871.         // Sort manually using usort()
  2872.         usort($response, function ($a, $b) use ($sortField) {
  2873.             return strcmp($a[$sortField], $b[$sortField]);
  2874.         });
  2876.         return ["success" => true, "data" => $response];
  2877.     }
  2878.     public function getVersions($notificationObject, $translator)
  2879.     {
  2880.         $result = [];
  2881.         $versions = $notificationObject->getVersions();
  2882.         if ($versions) {
  2883.             foreach ($versions as $version) {
  2884.                 $note = $version->getNote();
  2885.                 if ($note == "Update") {
  2886.                     $viewNotification = $version->loadData();
  2887.                     if ($viewNotification instanceof EwsNotification) {
  2888.                         $result[] = $this->createNotificationFormat($viewNotification, $translator);
  2889.                     }
  2890.                 }
  2891.             }
  2892.         }
  2894.         return $result;
  2895.     }
  2897.     private function createNotificationFormat($notification, $translator)
  2898.     {
  2899.         $response = [];
  2900.         $critetia = '';
  2901.         $critetiaAr = '';
  2902.         $status = 'active';
  2903.         $alertType = $notification->getAlertType();
  2904.         $phenomena = $notification->getWeatherPhenomenon();
  2905.         // Set the timezone to Asia/Riyadh
  2906.         $timezone = new \DateTimeZone(TIMEZONE);
  2907.         // Convert start and end dates to Asia/Riyadh timezone
  2908.         $startDate = $notification->getStartDate() ? $notification->getStartDate()->setTimezone($timezone) : null;
  2909.         $endDate = $notification->getEndDate() ? $notification->getEndDate()->setTimezone($timezone) : null;
  2910.         if ($alertType && $phenomena) {
  2911.             $phenomenaList = $alertType->getPhenomenaList();
  2912.             if ($phenomenaList) {
  2913.                 $items = $phenomenaList->getItems();
  2914.                 if ($items) {
  2915.                     foreach ($items as $item) {
  2916.                         if ($item->getPhenomena() == $phenomena->getId()) {
  2917.                             $critetia = $item->getCriteria();
  2918.                             $critetiaAr = $item->getCriteriaAr();
  2919.                             break;
  2920.                         }
  2921.                     }
  2922.                 }
  2923.             }
  2924.         }
  2925.         if ($endDate && $endDate < new \DateTime('now', $timezone)) {
  2926.             $status = "expired";
  2927.         }
  2928.         $twentyFourHoursAgo = (new \DateTime('now', $timezone))->modify('-24 hours');
  2929.         if ($endDate && $endDate < $twentyFourHoursAgo) {
  2930.             $status = "archived";
  2931.         }
  2932.         $response = [
  2933.             "id" => $notification->getId(),
  2934.             "searchEwsIdEn" => $notification->getEwsSearchId("en"),
  2935.             "searchEwsIdAr" => $notification->getEwsSearchId("ar"),
  2936.             "title" => $startDate ? $startDate->format("dmY") . '-' . $notification->getId() : '',
  2937.             "alertType" => !empty($notification->getAlertType()) ? $notification->getAlertType()->getAlertTypeId() : "",
  2938.             "alertTypeAr" => !empty($notification->getAlertType()) ? $notification->getAlertType()->getName("ar") : "",
  2939.             "alertTypeEn" => !empty($notification->getAlertType()) ? ucwords($notification->getAlertType()->getColor()) : "",
  2940.             "fromDate" => $startDate ? $startDate->format("Y-m-d H:i:s") : "",
  2941.             "toDate" => $endDate ? $endDate->format("Y-m-d H:i:s") : "",
  2942.             "alertStatusID" => !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getAlertStatusId() : "",
  2943.             "alertStatusAr" => !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName("ar") : "",
  2944.             "alertStatusEn" => !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName("en") : "",
  2945.             "alertStatusCategory" => "",
  2946.             "alertHazard" => !empty($notification->getAlertHazard()) ? $this->getAlertHazardArr($notification->getAlertHazard()) : [],
  2947.             "regionID" => !empty($notification->getRegion()) ? $notification->getRegion()->getRegionId() : "",
  2948.             "regionAR" => !empty($notification->getRegion()) ? $notification->getRegion()->getName("ar") : "",
  2949.             "regionEn" => !empty($notification->getRegion()) ? $notification->getRegion()->getName("en") : "",
  2950.             "governorates" => ($notification->getRegion()) ? $this->getGovernorateDetail($notification->getGovernorate()) : [],
  2951.             "ewsOtherLocations" => ($notification->getRegion()) ? $this->getGovernorateDetail($notification->getEwsOtherLocations()) : [],
  2952.             "otherLocationsAr" => $this->getOtherLocationsNames($notification->getEwsOtherLocations(), 'ar'),
  2953.             "otherLocationsEn" => $this->getOtherLocationsNames($notification->getEwsOtherLocations(), 'en'),
  2954.             "tweetID" => "",
  2955.             "enableTwitterNotification" => $notification->getEnableTwitterNotification(),
  2956.             "enableSMSNotification" => $notification->getEnableSMSNotification(),
  2957.             "enableEmailNotification" => $notification->getEnableEmailNotification(),
  2958.             "alertActions" => $this->getAlertActionsByArr($notification->getAlertAction()),
  2959.             "municipalities" => $this->getMunicipalityArr($notification->getMunicipality()),
  2960.             "lastModified" => ($notification->getModificationDate()) ? date("Y-m-d H:i:s", $notification->getModificationDate()) : "",
  2961.             "last_modified_date" => ($notification->getModificationDate()) ? date("Y-m-d", $notification->getModificationDate()) : "",
  2962.             'coordinates' => $notification->getCoordinates(),
  2963.             'message' => $notification->getMessage("en"),
  2964.             "file" => (!empty($notification->getAttachment())) ? API_BASE_URL . $notification->getAttachment()->getFullPath() : [],
  2965.             'criteria' => $critetia,
  2966.             'criteriaAr' => $critetiaAr,
  2967.             'created_at' => ($notification->getCreationDate()) ? date("Y-m-d H:i:s", $notification->getCreationDate()) : "",
  2968.             'created_by' => ($notification->getUser()) ? $notification->getUser()->getName() : "",
  2969.             'edited_by' => ($notification->getEditor()) ? $notification->getEditor()->getName() : (($notification->getUser()) ? $notification->getUser()->getName() : ""),
  2970.             'status_en' => ucfirst($status),
  2971.             'status_ar' => $translator->trans(ucfirst($status), [], null, 'ar'),
  2972.             'previewText' => $notification->getPreviewText() ?? false,
  2973.         ];
  2974.         return $response;
  2975.     }
  2977.     private function getAlertHazardArr($alertHazardArr)
  2978.     {
  2979.         $result = [];
  2980.         if ($alertHazardArr) {
  2981.             foreach ($alertHazardArr as $affect) {
  2982.                 $result[] = [
  2983.                     "pim_id" => $affect->getId(),
  2984.                     "id" => $affect->getAlertHazardId(),
  2985.                     "nameEn" => $affect->getName("en"),
  2986.                     "nameAr" => $affect->getName("ar"),
  2987.                 ];
  2988.             }
  2989.         }
  2991.         return $result;
  2992.     }
  2994.     private function getAlertActionsByArr($alertActions)
  2995.     {
  2996.         $result = [];
  2997.         if ($alertActions) {
  2998.             foreach ($alertActions as $alert) {
  2999.                 $result[] = [
  3000.                     "pim_id" => $alert->getId(),
  3001.                     "id" => $alert->getAlertActionId(),
  3002.                     "descriptionEn" => $alert->getName("en"),
  3003.                     "descriptionAr" => $alert->getName("ar"),
  3004.                 ];
  3005.             }
  3006.         }
  3008.         return $result;
  3009.     }
  3011.     private function getMunicipalityArr($municipalities)
  3012.     {
  3013.         $result = [];
  3014.         if ($municipalities) {
  3015.             foreach ($municipalities as $municipality) {
  3016.                 // p_R($municipality->getName());                
  3017.                 $result[] = [
  3018.                     "id" => $municipality->getMunicipalityId(),
  3019.                     "nameEn" => $municipality->getName("en"),
  3020.                     "nameAr" => $municipality->getName("ar"),
  3021.                     "governate" => $municipality->getGovernorate()->getGovernoteId()
  3022.                 ];
  3023.             }
  3024.         }
  3026.         return $result;
  3027.     }
  3029.     private function getOtherLocationsNames($otherLocations, $lang = 'ar')
  3030.     {
  3031.         $names = []; // Step 1: Initialize an array to hold the names
  3033.         if ($otherLocations) {
  3035.             foreach ($otherLocations as $otherLocation) {
  3036.                 $names[] = $otherLocation->getName($lang); // Step 2 & 3: Extract and collect names
  3037.             }
  3038.         }
  3039.         if (empty($names)) { // Check if the names array is empty
  3040.             return ''; // Return an empty string if there are no names
  3041.         }
  3043.         $namesString = implode(', ', $names); // Step 4: Convert the array to a comma-separated string
  3045.         return $namesString; // Return or use the comma-separated string as needed
  3046.     }
  3048.     public function publishedEwsNotification($notificationId, $published, $userGroupIds, $translator, $emailService, $templating, $logger)
  3049.     {
  3050.         $result = [];
  3053.         $viewNotification = DataObject\EwsNotification::getById($notificationId, false);
  3055.         if (!$viewNotification) {
  3056.             $viewNotification = DataObject\EwsNotification::getById($notificationId, true);
  3057.         }
  3058.         if ($published) {
  3059.             $viewNotification->setStatus("active");
  3060.         } else {
  3061.             $viewNotification->setStatus("");
  3062.         }
  3063.         $viewNotification->setPublished($published);
  3065.         //set ews search Id
  3066.         $currentDate = new \DateTime();
  3067.         $formattedDate = $currentDate->format('dmY') . '-' . $viewNotification->getId();
  3068.         $searchIdEn = 'Early Warning System | ' . $formattedDate . ' | ' . ucfirst($viewNotification->getAlertType()?->getColor()) . ' Alert | ' . $viewNotification->getWeatherPhenomenon()?->getTitle("en");
  3069.         $searchIdAr = $translator->trans('Early Warning System', [], null, "ar") . ' | ' . $formattedDate . ' | ' . $translator->trans(ucfirst($viewNotification->getAlertType()?->getColor()) . ' Alert', [], null, "ar") . ' | ' . $viewNotification->getWeatherPhenomenon()?->getTitle("ar");
  3070.         $viewNotification->setEwsSearchId($searchIdEn, "en");
  3071.         $viewNotification->setEwsSearchId($searchIdAr, "ar");
  3072.         $viewNotification->save(["versionNote" => "Update"]);
  3074.         $viewNotification->save();
  3076.         // $alert = $this->createNotificationFormat($viewNotification, $translator);
  3078.         if ($published) {
  3079.             // Ensure you use 'php' to execute the command.
  3080.             $jsonUserGroupIds = json_encode($userGroupIds);
  3081.             $process = new Process(['php', 'bin/console', 'app:send-early-warning-alert-email', '--alertId=' . $viewNotification->getId(), '--userGroupIds=' . $jsonUserGroupIds]);
  3082.             $process->setWorkingDirectory(PIMCORE_PROJECT_ROOT);
  3084.             try {
  3085.                 $process->mustRun();
  3086.                 $result['success'] = true;
  3087.                 $logger->info("published EwsNotification command executed successfully: " . $process->getOutput());
  3088.                 $result['message'] = $process->getOutput();
  3089.             } catch (ProcessFailedException $exception) {
  3090.                 $logger->error("published EwsNotification command failed: " . $exception->getMessage());
  3091.                 return ['success' => false, 'message' => $exception->getMessage()];
  3092.             }
  3093.         }
  3095.         return ["success" => true, "message" => $translator->trans("ews_notification_published")];
  3096.     }
  3098.     public function reportEwsNotification($param, $translator)
  3099.     {
  3100.         $result = [];
  3101.         $region = null;
  3102.         try {
  3103.             $listing = new EwsNotification\Listing();
  3104.             $reportType = isset($param['report_type']) ? $param['report_type'] : null;
  3105.             $regionId = isset($param['region_id']) ? $param['region_id'] : null;
  3106.             if ($regionId) {
  3107.                 $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  3108.                 if (!$region) {
  3109.                     throw new \Exception("Region not exists");
  3110.                 }
  3111.             }
  3113.             switch ($reportType) {
  3114.                 case 'published_in_week':
  3115.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 week"));
  3116.                     break;
  3117.                 case 'published_in_day':
  3118.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 day"));
  3119.                     break;
  3120.                 case 'published_in_month':
  3121.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 month"));
  3122.                     break;
  3123.                 case 'published_in_year':
  3124.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 year"));
  3125.                     break;
  3126.                 case 'published_in_region':
  3127.                     $listing->setCondition("o_published = true AND region__id = ?", [$region->getId()]);
  3128.                     break;
  3129.                 case 'published_in_draft':
  3130.                     $listing->setCondition("o_published = false");
  3131.                     break;
  3132.                 default:
  3133.                     throw new \Exception("Invalid request");
  3134.                     break;
  3135.             }
  3137.             $result['count'] = $listing->getCount();
  3138.             $notifications = $listing->load();
  3139.             if ($notifications) {
  3140.                 foreach ($notifications as $notification) {
  3141.                     $result['data'][] = $this->createNotificationFormat($notification, $translator);
  3142.                 }
  3143.             }
  3144.             return $result;
  3145.         } catch (\Exception $ex) {
  3146.             return new \Exception($ex->getMessage());
  3147.         }
  3149.         return $result;
  3150.     }
  3152.     private function sendEmailNotification($users, $alert, $emailService, $templating)
  3153.     {
  3154.         $mailSent = null;
  3155.         if ($alert) {
  3156.             $governatesArr = $alert['governorates'];
  3157.             $governates = [];
  3158.             if ($governatesArr) {
  3159.                 foreach ($governatesArr as $gov) {
  3160.                     $governates[] = $gov['nameEn'];
  3161.                 }
  3162.             }
  3164.             $data = $alert;
  3165.             $data['sender'] = 'National Center for Meteorology';
  3166.             //$subject = $alert['searchEwsIdAr'] ??'Severe Weather Alert - ' . $gov['nameEn'];
  3167.             // $subject = $alert['alertStatusAr'] . ' - ' . $alert['regionAR'];
  3168.             // $subject = 'النظام الالي للإنذار المبكر :' . ' - ' . $alert['searchEwsIdAr'];
  3169.             $parts = explode('|', $alert['searchEwsIdAr']);
  3170.             $excluded = implode('|', array_slice($parts, 1));
  3171.             $subject = 'النظام الالي للإنذار المبكر :'  . $excluded;
  3176.             // $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $data);
  3178.             //sending an email document (pimcore document)
  3179.             // $emailAlertTemplate = '/email/alert_notification';
  3181.             if ($users) {
  3182.                 foreach ($users as $currentUser) {
  3184.                     if (isset($alert['enableEmailNotification']) && $alert['enableEmailNotification']) {
  3186.                         if ($currentUser->getSendEwsEmail() || is_null($currentUser->getSendEwsEmail())) {
  3187.                             # code...
  3190.                             // $email = $currentUser->getEmail();
  3191.                             // $param = ['user' => $currentUser, 'message' => $html, 'url' => null];
  3192.                             // $mailSent = $emailService->sendMail($param, $email, $emailAlertTemplate, $subject);
  3193.                             // $data['name'] = $user->getName();
  3195.                             // extra param js
  3196.                             $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  3197.                             $alertName = $alertObj->getColor() ? $alertObj->getColor() : '';
  3199.                             $alert['user_name'] = $currentUser->getName();
  3200.                             $alert['host'] = API_BASE_URL;
  3201.                             $alert['alertColor'] = $alertName;
  3203.                             $backgroundColor = '#fcb82526';
  3204.                             $borderColor = '#000000';
  3205.                             $textColor = '#000000';
  3207.                             // unsubscribe ews notificaiton token
  3208.                             $tokenURL = '';
  3209.                             $token = $this->userModel->unSubscribeEwsGenerateToken($currentUser->getEmail());
  3210.                             if (!empty($token)) {
  3211.                                 $tokenURL = BASE_URL . '/unsubscribe/notification?ews=true&token=' . $token;
  3212.                             }
  3215.                             if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  3216.                                 $alertColorLower = strtolower(trim($alert['alertColor']));
  3218.                                 if ($alertColorLower === 'red') {
  3219.                                     $backgroundColor = '#f6000017';
  3220.                                     $borderColor = '#F60000';
  3221.                                     $textColor = '#F60000';
  3222.                                 } elseif ($alertColorLower === 'orange') {
  3223.                                     $backgroundColor = '#ff66001f';
  3224.                                     $borderColor = '#FF6600';
  3225.                                     $textColor = '#FF6600';
  3226.                                 } elseif ($alertColorLower === 'yellow') {
  3227.                                     $backgroundColor = '#fcb82526';
  3228.                                     $borderColor = '#FCB825';
  3229.                                     $textColor = '#FCB825';
  3230.                                 }
  3231.                             }
  3232.                             $purpose = EWS_MESSAGE;
  3233.                             $alert['backgroundColor'] = $backgroundColor;
  3234.                             $alert['borderColor'] = $borderColor;
  3235.                             $alert['textColor'] = $textColor;
  3236.                             $alert['tokenURL'] = $tokenURL;
  3237.                             $alert['mannedAlertDatailUrl'] = null;
  3238.                             $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  3239.                             $mailSent = $this->c2Service->sendNotificationEmail($_ENV['EWS_MAIL_TEMPLATE'], $alert['id'], $currentUser->getId(), $html, $subject, $purpose);
  3241.                             // $this->c2Service->sendMannedAlertEmails($html,$currentUser->getId(),$alert['id']);
  3242.                             // $mailSent=$this->c2Service->sendMannedAlertEmails($html,$currentUser->getId(),$alert['id'],$subject);
  3243.                             if ($mailSent) {
  3244.                                 $status = "sent";
  3245.                                 $this->saveEmailStatus($currentUser->getEmail(), $currentUser->getName(), $alert, $status);
  3246.                             } else {
  3247.                                 $status = "not sent";
  3248.                                 $this->saveEmailStatus($currentUser->getEmail(), $currentUser->getName(), $alert, $status);
  3249.                             }
  3250.                         }
  3251.                     }
  3252.                 }
  3253.             }
  3254.         }
  3256.         return $mailSent;
  3257.     }
  3259.     private function sendExcelEmailNotification($userGroupIds, $alert, $emailService, $templating)
  3260.     {
  3261.         $mailSent = null;
  3262.         if ($alert) {
  3263.             $governatesArr = $alert['governorates'];
  3264.             $governates = [];
  3265.             if ($governatesArr) {
  3266.                 foreach ($governatesArr as $gov) {
  3267.                     $governates[] = $gov['nameEn'];
  3268.                 }
  3269.             }
  3271.             $data = $alert;
  3272.             $data['sender'] = 'National Center for Meteorology';
  3273.             // $subject = $alert['searchEwsIdAr'] ??'Severe Weather Alert - ' . $gov['nameEn'];
  3274.             //$subject = $alert['alertStatusAr'] . ' - ' . $alert['regionAR'];
  3275.             // $subject = 'النظام الالي للإنذار المبكر :' . ' - ' . $alert['searchEwsIdAr'];
  3277.             $parts = explode('|', $alert['searchEwsIdAr']);
  3278.             $excluded = implode('|', array_slice($parts, 1));
  3279.             $subject = 'النظام الالي للإنذار المبكر :'  . $excluded;
  3282.             if ($userGroupIds) {
  3284.                 foreach ($userGroupIds as $userGroupId) {
  3285.                     if ($userGroupId) {
  3287.                         $userGroup = \Pimcore\Model\DataObject\EwsAndReportUserGroup::getById($userGroupId, true);
  3288.                         if ($userGroup instanceof \Pimcore\Model\DataObject\EwsAndReportUserGroup) {
  3290.                             foreach (json_decode($userGroup->getJsonData()) as $currentUser) {
  3292.                                 if (isset($currentUser->firstName) && isset($currentUser->lastName) && isset($currentUser->email)) {
  3294.                                     // extra param js
  3295.                                     $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  3296.                                     $alertName = $alertObj->getColor() ? $alertObj->getColor() : '';
  3298.                                     $alert['user_name'] = $currentUser->firstName . ' ' . $currentUser->lastName;
  3299.                                     $alert['host'] = API_BASE_URL;
  3300.                                     $alert['alertColor'] = $alertName;
  3302.                                     $backgroundColor = '#fcb82526';
  3303.                                     $borderColor = '#000000';
  3304.                                     $textColor = '#000000';
  3306.                                     if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  3307.                                         $alertColorLower = strtolower(trim($alert['alertColor']));
  3309.                                         if ($alertColorLower === 'red') {
  3310.                                             $backgroundColor = '#f6000017';
  3311.                                             $borderColor = '#F60000';
  3312.                                             $textColor = '#F60000';
  3313.                                         } elseif ($alertColorLower === 'orange') {
  3314.                                             $backgroundColor = '#ff66001f';
  3315.                                             $borderColor = '#FF6600';
  3316.                                             $textColor = '#FF6600';
  3317.                                         } elseif ($alertColorLower === 'yellow') {
  3318.                                             $backgroundColor = '#fcb82526';
  3319.                                             $borderColor = '#FCB825';
  3320.                                             $textColor = '#FCB825';
  3321.                                         }
  3322.                                     }
  3324.                                     $alert['backgroundColor'] = $backgroundColor;
  3325.                                     $alert['borderColor'] = $borderColor;
  3326.                                     $alert['textColor'] = $textColor;
  3327.                                     $alert['tokenURL'] = null;
  3328.                                     $alert['mannedAlertDatailUrl'] = null;
  3329.                                     $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  3331.                                     // $email = $currentUser->email;
  3332.                                     // $param = ['user' => $currentUser, 'message' => $html, 'url' => null];
  3333.                                     // $mailSent = $emailService->sendMail($param, "abdul.muqeet@centric.ae", '/email/alert_notification', $subject);
  3334.                                     $purpose = EWS_MESSAGE;
  3335.                                     $mailSent = $this->c2Service->sendDefaultEmail($_ENV['EWS_MAIL_TEMPLATE'], $alert['id'], $currentUser->email, $html, $subject, $purpose);
  3337.                                     if ($mailSent) {
  3338.                                         $status = "sent";
  3339.                                         $this->saveEmailStatus($currentUser->email, $currentUser->firstName . ' ' . $currentUser->lastName, $alert, $status);
  3340.                                     } else {
  3341.                                         $status = "not sent";
  3342.                                         $this->saveEmailStatus($currentUser->email, $currentUser->firstName . ' ' . $currentUser->lastName, $alert, $status);
  3343.                                     }
  3344.                                 }
  3345.                             }
  3346.                         }
  3347.                     }
  3348.                 }
  3349.             }
  3350.         }
  3352.         return $mailSent;
  3353.     }
  3355.     private function saveEmailStatus($userEmail, $userName, $alert, $emailStatus)
  3356.     {
  3358.         // Get all governorates names in string seprated by ,
  3359.         $nameEnArray = array_column($alert["governorates"], "nameEn");
  3360.         $nameEnString = implode(", ", $nameEnArray);
  3362.         $nameArArray = array_column($alert["governorates"], "nameAr");
  3363.         $nameArString = implode(", ", $nameArArray);
  3365.         $ewsEmailStatus = new FetchSentEwsEmail();
  3366.         $ewsEmailStatus->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Other/FetchSentEwsEmail/"));
  3367.         $ewsEmailStatus->setKey(\Pimcore\Model\Element\Service::getValidKey($userEmail . "-" . strtotime("now") . "-" . rand(1, 10000), 'object'));
  3368.         $ewsEmailStatus->setEwsId($alert['id']);
  3369.         $ewsEmailStatus->setUserName($userName);
  3370.         $ewsEmailStatus->setEmail($userEmail);
  3371.         //$ewsEmailStatus->setLocationName($locationName);
  3372.         $ewsEmailStatus->setAlertType($alert['alertTypeEn'], 'en');
  3373.         $ewsEmailStatus->setAlertType($alert['alertTypeAr'], 'ar');
  3374.         $ewsEmailStatus->setAlertStatus($alert['alertStatusEn'], 'en');
  3375.         $ewsEmailStatus->setAlertStatus($alert['alertStatusAr'], 'ar');
  3376.         $ewsEmailStatus->setRegionName($alert['regionEn'], 'en');
  3377.         $ewsEmailStatus->setRegionName($alert['regionAR'], 'ar');
  3378.         $ewsEmailStatus->setGovernorateNames($nameEnString, 'en');
  3379.         $ewsEmailStatus->setGovernorateNames($nameArString, 'ar');
  3380.         $ewsEmailStatus->setStatus($emailStatus);
  3381.         $ewsEmailStatus->setPublished(true);
  3382.         $ewsEmailStatus->save();
  3384.         return $ewsEmailStatus;
  3385.     }
  3387.     public function getEwsNotificationEmailStatus($params, $paginator, $translator)
  3388.     {
  3389.         $result = [];
  3390.         try {
  3391.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  3392.             $page = isset($params['page']) ? $params['page'] : 1;
  3394.             $notificationId = $params["id"] ? $params["id"] : null;
  3395.             $listing = new FetchSentEwsEmail\Listing();
  3396.             $listing->setCondition("ewsId = ? ", [$notificationId]);
  3398.             $paginator = $paginator->paginate(
  3399.                 $listing,
  3400.                 $page,
  3401.                 $pageSize
  3402.             );
  3404.             if ($paginator->count() > 0) {
  3405.                 foreach ($paginator as $EwsNotificationEmail) {
  3406.                     $result[] = [
  3407.                         "ewsId" => $EwsNotificationEmail->getEwsId(),
  3408.                         "userName" => $EwsNotificationEmail->getUserName(),
  3409.                         "Email" => $EwsNotificationEmail->getEmail(),
  3410.                         "locationName" => $EwsNotificationEmail->getLocationName(),
  3411.                         "alertType" => $EwsNotificationEmail->getAlertType('en'),
  3412.                         "alertTypeAr" => $EwsNotificationEmail->getAlertType('ar'),
  3413.                         "alertStatus" => $EwsNotificationEmail->getAlertStatus('en'),
  3414.                         "alertStatusAr" => $EwsNotificationEmail->getAlertStatus('ar'),
  3415.                         "regionName" => $EwsNotificationEmail->getRegionName('en'),
  3416.                         "regionNameAr" => $EwsNotificationEmail->getRegionName('ar'),
  3417.                         "governorateNames" => explode(",", $EwsNotificationEmail->getGovernorateNames('en')),
  3418.                         "governorateNamesAr" => explode(",", $EwsNotificationEmail->getGovernorateNames('ar')),
  3419.                         "emailStatus" => $EwsNotificationEmail->getStatus(),
  3420.                         "emailStatusAr" => $translator->trans($EwsNotificationEmail->getStatus(), [], null, "ar"),
  3421.                     ];
  3422.                 }
  3423.             }
  3425.             return ["success" => TRUE, "data" => $result, "paginationVariables" => $paginator->getPaginationData()];
  3426.         } catch (\Exception $ex) {
  3427.             return new \Exception($ex->getMessage());
  3428.         }
  3430.         return $result;
  3431.     }
  3433.     public function getOtherLocations()
  3434.     {
  3435.         $response = [];
  3436.         $otherLocations = new DataObject\OtherLocation\Listing();
  3437.         $otherLocations = $otherLocations->load();
  3438.         if ($otherLocations) {
  3439.             foreach ($otherLocations as $otherLocation) {
  3440.                 $response[] = [
  3441.                     "id" => $otherLocation->getOtherLocationId(),
  3442.                     "nameEn" => $otherLocation->getName('en'),
  3443.                     "nameAr" => $otherLocation->getName('ar')
  3444.                 ];
  3445.             }
  3446.         }
  3447.         return ["success" => true, "data" => $response];
  3448.     }
  3450.     public function getEwsNotificationByByRegionName($regionName)
  3451.     {
  3452.         $db = Db::get();
  3453.         $selectedLocalities = $db->fetchAll("SELECT * FROM `object_collection_AddressComponents_location` WHERE (`addressKey` = 'locality' || `addressKey` = 'administrative_area_level_1') and (TRIM(REPLACE(`addressValue`,'Province','')) = '" . $regionName . "')");
  3454.         return $selectedLocalities;
  3455.     }
  3457.     public function ewsAnalytics($params, $connection, $lang): array
  3458.     {
  3459.         $response = [];
  3461.         $status = isset($params['status']) ? $params['status'] : "";
  3463.         $isManned = null;
  3464.         if (isset($params['isManned']) && $params['isManned'] == true) {
  3465.             $isManned = true;
  3466.         } elseif (isset($params['isManned']) && $params['isManned'] == false) {
  3467.             $isManned = false;
  3468.         }
  3471.         if (isset($params['region']) && !empty($params['region'])) {
  3472.             $region = Region::getByRegionId($params['region'], true);
  3473.             $response[] = $this->ewsAnalyticsCount($region, $status, $connection, $lang, $isManned);
  3474.         } else {
  3475.             $regions = new Region\Listing();
  3476.             foreach ($regions as $region) {
  3477.                 $response[] = $this->ewsAnalyticsCount($region, $status, $connection, $lang, $isManned);
  3478.             }
  3479.         }
  3481.         return $response;
  3482.     }
  3484.     public function ewsAnalyticsCount($region, $status, $connection, $lang, $isManned)
  3485.     {
  3486.         $regionNameEn = $region->getName("en");
  3487.         $regionNameAr = $region->getName("ar");
  3489.         $statuses = ["active", "archived", "expired"];
  3490.         $count = ['regionEn' => $regionNameEn, "regionAr" => $regionNameAr];
  3492.         if (in_array($status, $statuses)) {
  3493.             $count[$status] = $this->getStatusData($region, $status, $connection, $isManned);
  3494.         } else {
  3495.             foreach ($statuses as $s) {
  3496.                 $count[$s] = $this->getStatusData($region, $s, $connection, $isManned);
  3497.             }
  3498.         }
  3500.         return $count;
  3501.     }
  3503.     public function getStatusData($region, $status, $connection, $isManned)
  3504.     {
  3505.         $totalNotifications = $this->statusCount($region, $status, $isManned);
  3506.         $alertTypeCount = $this->alertCount($region, $status, $connection, $isManned);
  3508.         return [
  3509.             'total_notifications' => $totalNotifications,
  3510.             'alert_type_count' => $alertTypeCount,
  3511.         ];
  3512.     }
  3514.     public function alertCount($region, $status, $connection, $isManned)
  3515.     {
  3516.         $currentTimestamp = time(); // Current UNIX timestamp
  3517.         $twentyFourHoursAgoTimestamp = strtotime('-24 hours'); // 24 hours ago timestamp
  3519.         $claim_report_sql = $connection->createQueryBuilder();
  3521.         $claim_report_sql
  3522.             ->select('oa.Color AS color', 'COUNT(oq.oo_id) AS count')
  3523.             ->from('object_ews_notification', 'oq')
  3524.             ->join('oq', 'object_query_alert_type', 'oa', 'oq.alertType__id = oa.oo_id')
  3525.             ->andWhere('oq.region__id = :regionId')
  3526.             ->andWhere('oq.status = :status');
  3527.         if ($isManned !== null && $isManned == true) {
  3528.             $claim_report_sql->andWhere('oq.isManned = 1');
  3529.         } elseif ($isManned !== null && $isManned == false) {
  3530.             $claim_report_sql->andWhere('oq.isManned = 0');
  3531.         }
  3533.         $claim_report_sql->andWhere('oq.o_published = 1'); // added new line
  3536.         // Initialize parameters array
  3537.         $params = [
  3538.             'regionId' => $region->getId(),
  3539.             'status' => $status,
  3540.         ];
  3542.         // Add conditions based on status
  3543.         if ($status == "active") {
  3544.             $claim_report_sql->andWhere('oq.endDate > :currentTimestamp');
  3545.             $params['currentTimestamp'] = $currentTimestamp;
  3546.         } else if ($status == "expired") {
  3547.             $claim_report_sql->andWhere('oq.endDate < :currentTimestamp AND oq.endDate > :twentyFourHoursAgoTimestamp');
  3548.             $params['currentTimestamp'] = $currentTimestamp;
  3549.             $params['twentyFourHoursAgoTimestamp'] = $twentyFourHoursAgoTimestamp;
  3550.         } else if ($status == "archived") {
  3551.             $claim_report_sql->andWhere('oq.endDate < :twentyFourHoursAgoTimestamp');
  3552.             $params['twentyFourHoursAgoTimestamp'] = $twentyFourHoursAgoTimestamp;
  3553.         }
  3555.         // Set all parameters at once
  3556.         $claim_report_sql->setParameters($params);
  3558.         $claim_report_sql->groupBy('color');
  3560.         $claimReportstmt = $claim_report_sql->execute();
  3561.         $results = $claimReportstmt->fetchAllAssociative();
  3563.         // Fetch all possible colors
  3564.         $alertTypes = new AlertType\Listing();
  3565.         $allColors = [];
  3566.         foreach ($alertTypes as $alertType) {
  3567.             if ($alertType) {
  3568.                 $allColors[] = $alertType->getColor();
  3569.             }
  3570.         }
  3572.         if (empty($allColors)) {
  3573.             $allColors = ["yellow", "orange", "red"];
  3574.         }
  3576.         // Create an associative array to store counts by color
  3577.         $countsByColor = [];
  3578.         foreach ($results as $result) {
  3579.             $countsByColor[$result['color']] = $result['count'];
  3580.         }
  3582.         // Merge counts for existing colors with counts for all colors, including those with count 0
  3583.         $finalResult = [];
  3584.         foreach ($allColors as $color) {
  3585.             $finalResult[] = [
  3586.                 "color" => $color,
  3587.                 "count" => isset($countsByColor[$color]) ? $countsByColor[$color] : 0
  3588.             ];
  3589.         }
  3591.         return $finalResult;
  3592.     }
  3596.     public function statusCount($region, $status, $isManned)
  3597.     {
  3598.         $notifications = new EwsNotification\Listing();
  3599.         $currentTimestamp = time(); // Get the current UNIX timestamp
  3600.         $twentyFourHoursAgoTimestamp = strtotime('-24 hours'); // 24 hours ago timestamp
  3602.         $conditions = "region__id = ? AND status = ?";
  3603.         $params = [$region->getId(), $status];
  3605.         if ($status == "active") {
  3606.             $conditions .= " AND endDate > ?";
  3607.             $params[] = $currentTimestamp;
  3608.         } else if ($status == "expired") {
  3609.             $conditions .= " AND endDate < ? AND endDate > ?";
  3610.             $params[] = $currentTimestamp;
  3611.             $params[] = $twentyFourHoursAgoTimestamp;
  3612.         } else if ($status == "archived") {
  3613.             $conditions .= " AND endDate < ?";
  3614.             $params[] = $twentyFourHoursAgoTimestamp;
  3615.         }
  3617.         $notifications->addConditionParam($conditions, $params);
  3619.         // Add condition for manned notifications
  3620.         if ($isManned !== null) {
  3621.             $notifications->addConditionParam("isManned = ?", [$isManned]);
  3622.         }
  3624.         return $notifications->count();
  3625.     }
  3627.     public function searchEwsNotification($params, $lang, $paginator, $translator): array
  3628.     {
  3629.         $response = [];
  3630.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  3631.         $page = isset($params['page']) ? $params['page'] : 1;
  3633.         $notificationList = new DataObject\EwsNotification\Listing();
  3634.         $notificationList->setUnpublished(true);
  3635.         $notificationList->filterByPublished(true);
  3637.         if (isset($params['isManned']) && $params['isManned'] == true) {
  3638.             $notificationList->addConditionParam("isManned = 1");
  3639.         } elseif (isset($params['isManned']) && $params['isManned'] == false) {
  3640.             $notificationList->addConditionParam("isManned = 0");
  3641.         }
  3644.         if (isset($params['id']) && !empty($params['id'])) {
  3645.             $idz = $params['id'];
  3646.             $notificationList->addConditionParam("oo_id IN (?)", [$idz]);
  3647.         }
  3648.         if (isset($params['alertAction']) && !empty($params['alertAction'])) {
  3649.             $alertActionIds = [];
  3650.             $alertActionList = new DataObject\AlertAction\Listing();
  3651.             $alertActionList->addConditionParam("alertActionId IN (?)", [$params['alertAction']]);
  3652.             foreach ($alertActionList as $alertAction) {
  3653.                 $alertActionIds[] = $alertAction->getId();
  3654.             }
  3655.             $alertActionids = implode(",", $alertActionIds);
  3656.             $notificationList->addConditionParam("alertAction REGEXP CONCAT('(^|,)(', REPLACE('$alertActionids',',', '|'), ')(,|$)')");
  3657.         }
  3658.         if (isset($params['alertType']) && !empty($params['alertType'])) {
  3659.             $alertTypeIds = [];
  3660.             $alertTypeList = new DataObject\AlertType\Listing();
  3661.             $alertTypeList->addConditionParam("alertTypeId IN (?)", [$params['alertType']]);
  3662.             foreach ($alertTypeList as $alertType) {
  3663.                 $alertTypeIds[] = $alertType->getId();
  3664.             }
  3665.             $notificationList->addConditionParam("alertType__id IN (?)", [$alertTypeIds]);
  3666.         }
  3667.         // if (isset($params['phenomena']) && !empty($params['phenomena'])) {
  3668.         //     $phenomenaIds = [];
  3669.         //     $phenomenaList = new DataObject\PhenomenaList\Listing();
  3670.         //     $phenomenaList->addConditionParam("phenomenalistid IN (?)", [$params['phenomena']]);
  3671.         //     foreach ($phenomenaList as $phenomena) {
  3672.         //         $phenomenaIds[] = $phenomena->getId();
  3673.         //     }
  3674.         //     $notificationList->addConditionParam("weatherPhenomenon__id IN (?)", [$phenomenaIds]);
  3675.         // }
  3677.         if (!empty($params['phenomena'])) {
  3678.             $alertStatusSql = null;
  3679.             foreach ($params['phenomena'] as $alertStatus) {
  3680.                 $alertStatus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($alertStatus, true);
  3681.                 if ($alertStatus) {
  3682.                     $alertStatusSql .= "alertStatus__id = " . $alertStatus->getId() . " OR ";
  3683.                 }
  3684.             }
  3685.             $notificationList->addConditionParam("(" . substr($alertStatusSql, 0, -3) . ")");
  3686.         }
  3688.         if (isset($params['region']) && !empty($params['region'])) {
  3689.             $regionIds = [];
  3690.             $regionList = new DataObject\Region\Listing();
  3691.             $regionList->addConditionParam("regionId IN (?)", [$params['region']]);
  3692.             foreach ($regionList as $region) {
  3693.                 $regionIds[] = $region->getId();
  3694.             }
  3695.             $notificationList->addConditionParam("region__id IN (?)", [$regionIds]);
  3696.         }
  3697.         if (isset($params['governate']) && !empty($params['governate'])) {
  3698.             $governatesIds = [];
  3699.             $governateList = new DataObject\Governorate\Listing();
  3700.             $governateList->addConditionParam("governoteId IN (?)", [$params['governate']]);
  3701.             foreach ($governateList as $governate) {
  3702.                 $governatesIds[] = $governate->getId();
  3703.             }
  3704.             $governatesIds = implode(",", $governatesIds);
  3705.             $notificationList->addConditionParam("governorate REGEXP CONCAT('(^|,)(', REPLACE('$governatesIds',',', '|'), ')(,|$)')");
  3706.         }
  3709.         if (isset($params['status'][0]) && !empty($params['status'][0])) {
  3710.             $currentTimestamp = time();
  3711.             $twentyFourHoursAgo = strtotime('-24 hours');
  3713.             if ($params['status'][0] == "active" && (!isset($params['status'][1]) || empty($params['status'][1]))) {
  3714.                 // Filter notifications with an end date in the future or equal to current time
  3715.                 $notificationList->filterByEndDate($currentTimestamp, ">=");
  3716.             } else if ($params['status'][0] == "expired" && (!isset($params['status'][1]) || empty($params['status'][1]))) {
  3717.                 // Filter notifications with an end date in the past, but not older than 24 hours
  3718.                 $notificationList->filterByEndDate($currentTimestamp, "<");
  3719.                 $notificationList->filterByEndDate($twentyFourHoursAgo, ">=");
  3720.             } else if ($params['status'][0] == "archived" && (!isset($params['status'][1]) || empty($params['status'][1]))) {
  3721.                 // Filter notifications with an end date older than 24 hours
  3722.                 $notificationList->filterByEndDate($twentyFourHoursAgo, "<");
  3723.             } else if (isset($params['status'][1]) && !empty($params['status'][1])) {
  3724.                 if (($params['status'][0] == "active" && $params['status'][1] == "expired") || ($params['status'][0] == "expired" && $params['status'][1] == "active")) {
  3725.                     // Filter notifications that are either active or expired
  3726.                     $notificationList->filterByEndDate($currentTimestamp, ">=");
  3727.                     $notificationList->filterByEndDate($twentyFourHoursAgo, ">=");
  3728.                 }
  3729.             }
  3730.         } else {
  3731.             // If no status is provided, return 0 records
  3732.             $notificationList->addConditionParam("1 = 0");
  3733.         }
  3735.         $notificationList->setLocale($lang);
  3736.         if (isset($params['searchId']) && !empty($params['searchId'])) {
  3737.             $notificationList->addConditionParam(
  3738.                 "(ewsSearchId LIKE ?)",
  3739.                 [
  3740.                     '%' . $params['searchId'] . '%'
  3741.                 ]
  3742.             );
  3743.         }
  3745.         if (isset($params['alertHazard']) && !empty($params['alertHazard'])) {
  3747.             $alertHazardIds = [];
  3748.             $alertHazardList = new DataObject\AlertHazard\Listing();
  3749.             $alertHazardList->addConditionParam("alertHazardId IN (?)", [$params['alertHazard']]);
  3750.             foreach ($alertHazardList as $alertHazard) {
  3751.                 $alertHazardIds[] = $alertHazard->getId();
  3752.             }
  3753.             $alertHazardIds = implode(",", $alertHazardIds);
  3754.             $notificationList->addConditionParam("alertHazard REGEXP CONCAT('(^|,)(', REPLACE('$alertHazardIds',',', '|'), ')(,|$)')");
  3755.         }
  3756.         if (isset($params['municipality']) && !empty($params['municipality'])) {
  3757.             $municipalityIds = [];
  3758.             $municipalityList = new DataObject\Municipality\Listing();
  3759.             $municipalityList->addConditionParam("municipalityid IN (?)", [$params['municipality']]);
  3760.             foreach ($municipalityList as $municipality) {
  3761.                 $municipalityIds[] = $municipality->getId();
  3762.             }
  3763.             $municipalityIds = implode(",", $municipalityIds);
  3764.             $notificationList->addConditionParam("municipality REGEXP CONCAT('(^|,)(', REPLACE('$municipalityIds',',', '|'), ')(,|$)')");
  3765.         }
  3766.         if (isset($params['startDate']) && !empty($params['startDate'])) {
  3767.             $notificationList->filterByStartDate(strtotime($params['startDate']), ">=");
  3768.         }
  3769.         if (isset($params['endDate']) && !empty($params['endDate'])) {
  3770.             $notificationList->filterByEndDate(strtotime($params['endDate']), "<=");
  3771.         }
  3773.         if (isset($params['fromDate']) && isset($params['toDate']) && !empty($params['fromDate']) && !empty($params['toDate'])) {
  3774.             $fromDate = new \DateTime($params['fromDate']);
  3775.             $toDate = new \DateTime($params['toDate']);
  3777.             // Ensure the dates are in the correct format
  3778.             $fromDateStr = strtotime($fromDate->format('Y-m-d H:i:s'));
  3779.             $toDateStr = strtotime($toDate->format('Y-m-d') . ' 23:59:59');
  3781.             $notificationList->addConditionParam(
  3782.                 "(o_creationDate >= ? AND o_creationDate <= ?)",
  3783.                 [$fromDateStr, $toDateStr]
  3784.             );
  3785.         }
  3788.         $notifications = $notificationList->load();
  3789.         $sortedData = [];
  3791.         foreach ($notifications as $notification) {
  3792.             $regionEn = $notification->getRegion()->getName("en"); // Assuming getRegion() is available
  3793.             $startDate = $notification->getStartDate()->format('Y-m-d H:i:s'); // Assuming getStartDate() returns a \DateTime
  3794.             $endDate = $notification->getEndDate()->format('Y-m-d H:i:s');
  3795.             $alertStatusEn = $notification->getWeatherPhenomenon()?->getTitle("en");
  3796.             $creationDate = $notification->getCreationDate(); // Assuming getCreationDate() returns a \DateTime
  3797.             $searchIdEn = $notification->getEwsSearchId("en");
  3798.             $searchIdAr = $notification->getEwsSearchId("ar");
  3799.             $title = $notification->getStartDate() ? $notification->getStartDate()->format("dmY") . '-' . $notification->getId() : '';
  3800.             $alertTypeEn = $notification->getAlertType()?->getName("en");
  3801.             $fromDate = $notification->getStartDate()->format('Y-m-d H:i:s');
  3802.             $toDate = $notification->getEndDate()->format('Y-m-d H:i:s');
  3803.             $region = $regionEn;
  3804.             $created_at = $notification->getCreationDate();
  3805.             $alertStatus = $alertStatusEn;
  3806.             $sortedData[] = [
  3807.                 'notification' => $notification,
  3808.                 'regionName' => $regionEn,
  3809.                 'alertStatus' => $alertStatusEn,
  3810.                 'startDate' => $startDate,
  3811.                 'endDate' => $endDate,
  3812.                 'creationDate' => $creationDate, // Add creation date to sorting criteria
  3813.                 'searchIdEn' => $searchIdEn,
  3814.                 'searchIdAr' => $searchIdAr,
  3815.                 'title' => $title,
  3816.                 'alertType' => $alertTypeEn,
  3817.                 'fromDate' => $fromDate,
  3818.                 'toDate' => $toDate,
  3819.                 'region' => $region,
  3820.                 'created_at' => $created_at,
  3821.                 'alertStatus' => $alertStatus
  3822.             ];
  3823.         }
  3825.         // Define default sort orders and detect if any sort parameter is provided
  3826.         $sortOrderRegion = $params['sortByRegion'] ?? null;
  3827.         $sortOrderStartDate = $params['sortByStartDate'] ?? null;
  3828.         $sortOrderEndDate = $params['sortByEndDate'] ?? null;
  3829.         $sortOrderAlertStatus = $params['sortByAlertStatus'] ?? null;
  3830.         $sortOrderSearchIdEn = $params['sortBySearchIdEn'] ?? null;
  3831.         $sortOrderSearchIdAr = $params['sortBySearchIdAr'] ?? null;
  3832.         $sortOrderCreatedAt = $params['sortByCreated'] ?? null;
  3833.         $sortOrderTitle = $params['sortByTitle'] ?? null;
  3834.         $sortOrderAlertType = $params['sortByAlertType'] ?? null;
  3835.         $sortOrderFromDate = $params['sortByFromDate'] ?? null;
  3836.         $sortOrderToDate = $params['sortByToDate'] ?? null;
  3837.         $sortOrderRegionNew = $params['sortByRegionNew'] ?? null;
  3838.         $sortOrderCreatedAtNew = $params['sortByCreatedAt'] ?? null;
  3839.         $sortOrderAlertStatusNew = $params['sortByAlertStatusNew'] ?? null;
  3840.         
  3841.         // Support for orderKey and order parameters (NEW - clean approach)
  3842.         $orderKey = $params['orderKey'] ?? null;
  3843.         $order = $params['order'] ?? 'asc';
  3844.         
  3845.         // Simple mapping for new fields
  3846.         $newFieldMapping = [
  3847.             'title' => 'sortOrderTitle',
  3848.             'alertType' => 'sortOrderAlertType',
  3849.             'fromDate' => 'sortOrderFromDate', 
  3850.             'toDate' => 'sortOrderToDate',
  3851.             'region' => 'sortOrderRegionNew',
  3852.             'created_at' => 'sortOrderCreatedAtNew',
  3853.             'alertStatus' => 'sortOrderAlertStatusNew'
  3854.         ];
  3855.         
  3856.         // Set the appropriate sort order variable
  3857.         if ($orderKey && isset($newFieldMapping[$orderKey])) {
  3858.             $variableName = $newFieldMapping[$orderKey];
  3859.             $$variableName = $order;
  3860.         }
  3861.         
  3862.         // Check if any sort parameter is provided (OLD + NEW)
  3863.         $anySortParamProvided = $sortOrderRegion || $sortOrderStartDate || $sortOrderEndDate || $sortOrderAlertStatus || $sortOrderSearchIdEn || $sortOrderSearchIdAr || $sortOrderTitle || $sortOrderAlertType || $sortOrderFromDate || $sortOrderToDate || $sortOrderRegionNew || $sortOrderCreatedAtNew || $sortOrderAlertStatusNew;
  3864.         usort($sortedData, function ($a, $b) use ($sortOrderRegion, $sortOrderStartDate, $sortOrderEndDate, $sortOrderAlertStatus, $sortOrderSearchIdEn, $sortOrderSearchIdAr, $sortOrderCreatedAt, $sortOrderTitle, $sortOrderAlertType, $sortOrderFromDate, $sortOrderToDate, $sortOrderRegionNew, $sortOrderCreatedAtNew, $sortOrderAlertStatusNew, $anySortParamProvided) {
  3865.             if (!$anySortParamProvided || $sortOrderCreatedAt) {
  3866.                 if ($sortOrderCreatedAt == null) {
  3867.                     $sortOrderCreatedAt = "desc";
  3868.                 }
  3869.                 // Default to sorting by creation date if no sort parameter is provided
  3870.                 $compareCreatedAt = strcmp($a['creationDate'], $b['creationDate']) * ($sortOrderCreatedAt === 'desc' ? -1 : 1);
  3871.                 if ($compareCreatedAt !== 0) return $compareCreatedAt; // Assuming 'asc' as default sort order for creation date
  3872.             }
  3873.             // Else, sort based on the provided parameters
  3874.             if ($sortOrderRegion) {
  3875.                 $compareRegion = strcmp($a['regionName'], $b['regionName']) * ($sortOrderRegion === 'desc' ? -1 : 1);
  3876.                 if ($compareRegion !== 0) return $compareRegion;
  3877.             }
  3878.             if ($sortOrderSearchIdEn) {
  3879.                 $compareSearchIdEn = strcmp($a['searchIdEn'], $b['searchIdEn']) * ($sortOrderSearchIdEn === 'desc' ? -1 : 1);
  3880.                 if ($compareSearchIdEn !== 0) return $compareSearchIdEn;
  3881.             }
  3882.             if ($sortOrderSearchIdAr) {
  3883.                 $compareSearchIdAr = strcmp($a['searchIdAr'], $b['searchIdAr']) * ($sortOrderSearchIdAr === 'desc' ? -1 : 1);
  3884.                 if ($compareSearchIdAr !== 0) return $compareSearchIdAr;
  3885.             }
  3886.             if ($sortOrderAlertStatus) {
  3887.                 $compareAlertStatus = strcmp($a['alertStatus'], $b['alertStatus']) * ($sortOrderAlertStatus === 'desc' ? -1 : 1);
  3888.                 if ($compareAlertStatus !== 0) return $compareAlertStatus;
  3889.             }
  3890.             if ($sortOrderStartDate) {
  3891.                 $compareStartDate = strcmp($a['startDate'], $b['startDate']) * ($sortOrderStartDate === 'desc' ? -1 : 1);
  3892.                 if ($compareStartDate !== 0) return $compareStartDate;
  3893.             }
  3894.             if ($sortOrderEndDate) {
  3895.                 return strcmp($a['endDate'], $b['endDate']) * ($sortOrderEndDate === 'desc' ? -1 : 1);
  3896.             }
  3897.             
  3898.             // New sorting fields (ADDED - keeps old functionality)
  3899.             if ($sortOrderTitle) {
  3900.                 $compareTitle = strcmp($a['title'], $b['title']) * ($sortOrderTitle === 'desc' ? -1 : 1);
  3901.                 if ($compareTitle !== 0) return $compareTitle;
  3902.             }
  3903.             if ($sortOrderAlertType) {
  3904.                 $compareAlertType = strcmp($a['alertType'], $b['alertType']) * ($sortOrderAlertType === 'desc' ? -1 : 1);
  3905.                 if ($compareAlertType !== 0) return $compareAlertType;
  3906.             }
  3907.             if ($sortOrderFromDate) {
  3908.                 $compareFromDate = strcmp($a['fromDate'], $b['fromDate']) * ($sortOrderFromDate === 'desc' ? -1 : 1);
  3909.                 if ($compareFromDate !== 0) return $compareFromDate;
  3910.             }
  3911.             if ($sortOrderToDate) {
  3912.                 $compareToDate = strcmp($a['toDate'], $b['toDate']) * ($sortOrderToDate === 'desc' ? -1 : 1);
  3913.                 if ($compareToDate !== 0) return $compareToDate;
  3914.             }
  3915.             if ($sortOrderRegionNew) {
  3916.                 $compareRegionNew = strcmp($a['region'], $b['region']) * ($sortOrderRegionNew === 'desc' ? -1 : 1);
  3917.                 if ($compareRegionNew !== 0) return $compareRegionNew;
  3918.             }
  3919.             if ($sortOrderCreatedAtNew) {
  3920.                 $compareCreatedAtNew = strcmp($a['created_at'], $b['created_at']) * ($sortOrderCreatedAtNew === 'desc' ? -1 : 1);
  3921.                 if ($compareCreatedAtNew !== 0) return $compareCreatedAtNew;
  3922.             }
  3923.             if ($sortOrderAlertStatusNew) {
  3924.                 $compareAlertStatusNew = strcmp($a['alertStatus'], $b['alertStatus']) * ($sortOrderAlertStatusNew === 'desc' ? -1 : 1);
  3925.                 if ($compareAlertStatusNew !== 0) return $compareAlertStatusNew;
  3926.             }
  3927.             
  3928.             // If all provided parameters are equal, or no specific sort orders are provided, default to creation date
  3929.             return ($b['creationDate'] ?? 0) - ($a['creationDate'] ?? 0);
  3930.         });
  3932.         $sortedNotifications = array_map(function ($item) {
  3933.             return $item['notification'];
  3934.         }, $sortedData);
  3937.         if (isset($params['dashboard']) && !empty($params['dashboard'] && $params['dashboard'] == 'dashboard')) {
  3938.             return ["data" => $notificationList];
  3939.         }
  3942.         // Extract the sorted notifications
  3944.        
  3945.         if ($paginator == null) {
  3947.             // if ($sortedNotifications->count()) {
  3948.             foreach ($sortedNotifications as $notification) {
  3949.                 // if($notification->getPublished())
  3950.                 $response[] = $this->createNotificationFormat($notification, $translator);
  3951.             }
  3952.             // }
  3954.             return ["success" => TRUE, "data" => $response];
  3955.         }
  3958.         $paginator = $paginator->paginate(
  3959.             $sortedNotifications,
  3960.             $page,
  3961.             $pageSize
  3962.         );
  3963.         // if ($sortedNotifications->count()) {
  3964.         foreach ($paginator as $notification) {
  3965.             // if($notification->getPublished())
  3966.             $response[] = $this->createNotificationFormat($notification, $translator);
  3967.         }
  3968.         // }
  3970.         return ["data" => $response, "paginationVariables" => $paginator->getPaginationData()];
  3971.     }
  3973.     public function archiveNotification($params, $translator): array
  3974.     {
  3976.         $id = $params['id'] ?? null;
  3977.         if (!$id) {
  3978.             throw new \Exception("EWS id is required");
  3979.         }
  3981.         $ewsNotification = \Pimcore\Model\DataObject::getById($id);
  3982.         if (!$ewsNotification instanceof \Pimcore\Model\DataObject\EwsNotification) {
  3983.             // throw new \Exception("Ews notification not found");
  3984.             return ['success' => false, 'message' => $translator->trans('ews_notification_not_found')];
  3985.         }
  3987.         if (isset($params['status']) && $params['status']) {
  3988.             $ewsNotification->setStatus("archived");
  3989.         }
  3990.         $ewsNotification->save(["versionNote" => "Update"]);
  3992.         return ['success' => true, 'message' => $translator->trans('archive_ews_notification'), "notification_id" => $ewsNotification->getId()];
  3993.     }
  3995.     public function getId(): ?UuidV4
  3996.     {
  3998.         $uuid = UuidV4::v4();
  3999.         return $uuid;
  4000.     }
  4002.     public function getPhenomenaList()
  4003.     {
  4004.         $phenomenas = new \Pimcore\Model\DataObject\PhenomenaList\Listing();
  4005.         $phenomenas->setOrderKey("o_creationDate");
  4006.         $phenomenas->setOrder("desc");
  4007.         $phenomenas->load();
  4008.         $response = [];
  4010.         if (count($phenomenas) > 0) {
  4011.             foreach ($phenomenas as $phenomena) {
  4012.                 $response[] = [
  4013.                     "id" => $phenomena->getPhenomenaListId(),
  4014.                     "nameEN" => $phenomena->getTitle('en'),
  4015.                     "nameAr" => $phenomena->getTitle('ar'),
  4016.                 ];
  4017.             }
  4019.             return ["success" => true, "data" => $response];
  4020.         }
  4022.         return ["success" => false, "data" => $response];
  4023.     }
  4025.     public function getHazardListByAlertStatusId($statusId, $lang = "en")
  4026.     {
  4027.         $response = [];
  4028.         $alertSttaus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($statusId, true);
  4029.         if ($alertSttaus instanceof \Pimcore\Model\DataObject\AlertStatus) {
  4030.             if ($alertSttaus && $alertSttaus->getAlertHazards()) {
  4031.                 foreach ($alertSttaus->getAlertHazards() as  $value) {
  4032.                     $alertHazardObj = $value->getLocalizedfields()->getItems();
  4033.                     $response[] = ["id" => (int)$value->getAlertHazardId(), "nameEn" => $alertHazardObj['en']['name'], "nameAr" => $alertHazardObj['ar']['name']];
  4034.                 }
  4035.             } else {
  4036.                 return ["success" => false, "message" => "No Hazard is set"];
  4037.             }
  4038.         } else {
  4039.             return ["success" => false, "message" => "Invalid alert status id"];
  4040.         }
  4041.         return ["success" => true, "data" => $response];
  4042.     }
  4044.     // public function getHazardListByAlertStatusId($statusId, $lang = "en")
  4045.     // {
  4046.     //     $response = [];
  4047.     //     $alertPhenomena = \Pimcore\Model\DataObject\PhenomenaList::getByPhenomenaListId($statusId, true);
  4048.     //     if ($alertPhenomena instanceof \Pimcore\Model\DataObject\PhenomenaList) {
  4049.     //         if ($alertPhenomena && $alertPhenomena->getAlertHazards()) {
  4050.     //             foreach ($alertPhenomena->getAlertHazards() as  $value) {
  4051.     //                 $alertHazardObj = $value->getLocalizedfields()->getItems();
  4052.     //                 $response[] = ["id" => (int)$value->getAlertHazardId(), "nameEn" => $alertHazardObj['en']['name'], "nameAr" => $alertHazardObj['ar']['name']];
  4053.     //             }
  4054.     //         } else {
  4055.     //             return ["success" => false, "message" => "No Hazard is set"];
  4056.     //         }
  4057.     //     } else {
  4058.     //         return ["success" => false, "message" => "Invalid alert status id"];
  4059.     //     }
  4060.     //     return ["success" => true, "data" => $response];
  4061.     // }
  4063.     public function getOtherGovernoratesByRegion($regionId)
  4064.     {
  4065.         $response = [];
  4066.         $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  4067.         if (!$region) {
  4068.             throw new \Exception("Region not available");
  4069.         }
  4070.         $otherGovernorates = new DataObject\EwsOtherLocation\Listing();
  4071.         //$otherGovernorates->filterByRegionId($region);
  4072.         $otherGovernorates = $otherGovernorates->load();
  4073.         if ($otherGovernorates) {
  4074.             foreach ($otherGovernorates as $governorate) {
  4075.                 $region = $governorate->getregionId();
  4076.                 $regionData = [];
  4077.                 if (!empty($region)) {
  4078.                     $regionData = [
  4079.                         "id" => $region->getRegionId(),
  4080.                         "nameEn" => $region->getName('en'),
  4081.                         "nameAr" => $region->getName('ar'),
  4082.                         "longitude" => $region->getLongitude(),
  4083.                         "latitude" => $region->getLongitude()
  4085.                     ];
  4086.                 }
  4087.                 $response[] = [
  4088.                     "id" => $governorate->getgovernoteId(),
  4089.                     "nameEn" => $governorate->getName('en'),
  4090.                     "nameAr" => $governorate->getName('ar'),
  4091.                     "regionId" => $regionData,
  4092.                     "longitude" => $governorate->getLongitude(),
  4093.                     "latitude" => $governorate->getLatitude(),
  4094.                     "isHidden" => $governorate->getisHidden(),
  4095.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  4096.                     "MunicipalityID" => $governorate->getMunicipalityID()
  4097.                 ];
  4098.             }
  4099.         }
  4101.         return ["success" => true, "data" => $response];
  4102.     }
  4104.     public function createEwsReportUserGroup($params, $translator)
  4105.     {
  4106.         $response = [];
  4107.         $checkGroup = EwsAndReportUserGroup::getByName($params['name'], true);
  4108.         if ($checkGroup instanceof EwsAndReportUserGroup) {
  4109.             return ["success" => false, "message" => $translator->trans("group_name_already_exists"), "name" => $params['name']];
  4110.         }
  4111.         $ewsReportUserGroup = new DataObject\EwsAndReportUserGroup();
  4112.         $ewsReportUserGroup->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Notification/userGroups/" . $params['type'] . "/"));
  4113.         $ewsReportUserGroup->setKey(\Pimcore\Model\Element\Service::getValidKey($params['name'] . "-" . strtotime("now") . "-" . rand(1, 10000), 'object', 'object'));
  4114.         $ewsReportUserGroup->setName(strip_tags($params['name']));
  4115.         $ewsReportUserGroup->setJsonData(json_encode($params['data']));
  4116.         $ewsReportUserGroup->setGroupType($params['type']);
  4118.         $ewsReportUserGroup->setPublished(true);
  4119.         $ewsReportUserGroup->save();
  4120.         return ["success" => true, "message" => $translator->trans("ews_report_user_group_created")];
  4121.     }
  4123.     public function updateEwsReportUserGroup($params, $translator)
  4124.     {
  4125.         $response = [];
  4126.         $updateGroup = EwsAndReportUserGroup::getById($params['id']);
  4127.         if (!$updateGroup instanceof EwsAndReportUserGroup) {
  4128.             return ["success" => false, "message" => $translator->trans('ews_report_user_group_not_found'), "id" => $params['id']];
  4129.         }
  4130.         if (isset($params['name']) && !empty($params['name']) && $updateGroup->getName() != $params['name']) {
  4132.             $checkGroup = EwsAndReportUserGroup::getByName($params['name'], true);
  4133.             if ($checkGroup instanceof EwsAndReportUserGroup) {
  4134.                 return ["success" => false, "message" => $translator->trans("group_name_already_exists"), "name" => $params['name']];
  4135.             }
  4136.             $updateGroup->setName(strip_tags($params['name']));
  4137.             $updateGroup->setKey(\Pimcore\Model\Element\Service::getValidKey($params['name'] . "-" . strtotime("now") . "-" . rand(1, 10000), 'object', 'object'));
  4138.         }
  4140.         if (isset($params['data']) && !empty($params['data'])) {
  4141.             $updateGroup->setJsonData(json_encode($params['data']));
  4142.         }
  4144.         if (isset($params['type']) && !empty($params['type'])) {
  4145.             $updateGroup->setGroupType($params['type']);
  4146.             $updateGroup->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Notification/userGroups/" . $params['type'] . "/"));
  4147.         }
  4149.         $updateGroup->setJsonData(json_encode($params['data']));
  4150.         $updateGroup->setGroupType($params['type']);
  4152.         $updateGroup->setPublished(true);
  4153.         $updateGroup->save();
  4154.         return ["success" => true, "message" => $translator->trans("ews_report_user_group_updated")];
  4155.     }
  4157.     public function deleteEwsReportUserGroup($params, $translator)
  4158.     {
  4159.         $response = [];
  4160.         $deleteGroup = EwsAndReportUserGroup::getById($params['id']);
  4161.         if (!$deleteGroup instanceof EwsAndReportUserGroup) {
  4162.             return ["success" => false, "message" => $translator->trans('ews_report_user_group_not_found'), "id" => $params['id']];
  4163.         }
  4165.         $deleteGroup->delete();
  4166.         return ["success" => true, "message" => $translator->trans("ews_report_user_group_deleted")];
  4167.     }
  4169.     public function listEwsReportUserGroup($params, $paginator, $translator)
  4170.     {
  4171.         $data = [];
  4172.         $listing = new EwsAndReportUserGroup\Listing();
  4173.     
  4174.         // Allowed sorting keys
  4175.         $allowedOrderKeys = ['name', 'type', 'email_count', 'oo_id'];
  4176.         $allowedOrderDirections = ['asc', 'desc'];
  4177.     
  4178.         $orderKey = $params['orderKey'] ?? 'oo_id';
  4179.         $orderDirection = strtolower($params['order'] ?? 'desc');
  4180.     
  4181.         if (in_array($orderKey, $allowedOrderKeys) && in_array($orderDirection, $allowedOrderDirections)) {
  4182.             $fieldMapping = [
  4183.                 'name' => 'name',
  4184.                 'type' => 'groupType',
  4185.                 'oo_id' => 'oo_id'
  4186.             ];
  4187.     
  4188.             // Normal sorting keys (done in SQL)
  4189.             if (isset($fieldMapping[$orderKey])) {
  4190.                 $listing->setOrderKey($fieldMapping[$orderKey]);
  4191.                 $listing->setOrder(strtoupper($orderDirection));
  4192.             }
  4193.         } else {
  4194.             // Default sorting
  4195.             $orderKey = 'oo_id';
  4196.             $orderDirection = 'desc';
  4197.             $listing->setOrderKey('oo_id');
  4198.             $listing->setOrder('DESC');
  4199.         }
  4200.     
  4202.         if (isset($params['type']) && !empty($params['type'])) {
  4203.             $listing->addConditionParam("groupType = ?", [$params['type']]);
  4204.         }
  4206.         if (isset($params['search']) && !empty($params['search'])) {
  4207.             $listing->addConditionParam("name LIKE ? ", ['%' . $params['search'] . '%']);
  4208.         }
  4209.         
  4210.     
  4211.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  4212.         $page = isset($params['page']) ? $params['page'] : 1;
  4213.     
  4214.         $paginator = $paginator->paginate(
  4215.             $listing,
  4216.             $page,
  4217.             $pageSize
  4218.         );
  4219.     
  4220.         // Convert paginator to array
  4221.         $groups = iterator_to_array($paginator);
  4222.     
  4223.         // Handle email_count sorting manually in PHP
  4224.         if ($orderKey === 'email_count') {
  4225.             usort($groups, function ($a, $b) use ($orderDirection) {
  4226.                 $lenA = count(json_decode($a->getJsonData(), true) ?? []);
  4227.                 $lenB = count(json_decode($b->getJsonData(), true) ?? []);
  4228.                 return $orderDirection === 'asc' ? $lenA <=> $lenB : $lenB <=> $lenA;
  4229.             });
  4230.         }
  4231.     
  4232.         // Prepare output data
  4233.         foreach ($groups as $group) {
  4234.             $jsonData = json_decode($group->getJsonData(), true) ?? [];
  4235.             $data[] = [
  4236.                 "id" => $group->getId(),
  4237.                 "name" => $group->getName(),
  4238.                 "type" => $group->getGroupType(),
  4239.                 "email_count" => count($jsonData),
  4240.                 "data" => $jsonData
  4241.             ];
  4242.         }
  4244.         if (count($data) > 0) {
  4246.             return ["success" => true, "data" => $data, "paginationVariables" => $paginator->getPaginationData()];
  4247.         } else {
  4248.             return ["success" => false, "message" => $translator->trans('no_ews_report_user_group_found')];
  4249.         }
  4250.     }
  4252.     public function getSortCriteria()
  4253.     {
  4254.         // This is a placeholder; you'll need to adapt this based on how you can access the region's name or other criteria
  4255.         return $this->getRegion()->getName();
  4256.     }
  4257.     public function getCenters($governorateId = null, $lang = 'en')
  4258.     {
  4259.         $response = [];
  4260.         $districts = new DataObject\District\Listing();
  4261.         if (is_array($governorateId)) {
  4262.             $govIdsArr = [];
  4263.             foreach ($governorateId as $govId) {
  4264.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  4265.                 if ($governorate) {
  4266.                     array_push($govIdsArr, $governorate->getId());
  4267.                 }
  4268.             }
  4269.             $districts->setCondition("governorate__id IN (" . implode(", ", $govIdsArr) . ")");
  4270.         } else {
  4271.             if ($governorateId) {
  4272.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($governorateId, true);
  4273.                 $districts->setCondition("governorate__id = ?", [$governorate->getId()]);
  4274.             }
  4275.         }
  4276.         $districts = $districts->load();
  4277.         if ($districts) {
  4278.             foreach ($districts as $district) {
  4279.                 $response[] = [
  4280.                     "id" => $district->getObjectId(),
  4281.                     "nameEn" => $district->getName('en'),
  4282.                     "nameAr" => $district->getName('ar'),
  4283.                     "longitude" => $district->getLongitude(),
  4284.                     "latitude" => $district->getLatitude(),
  4285.                     "governate" => $district->getGovernorate()->getGovernoteId()
  4286.                 ];
  4287.             }
  4288.         }
  4290.         // Determine sorting field based on language
  4291.         $sortField = 'nameEn'; // Default sorting by English
  4292.         if (isset($lang) && strtolower($lang) === 'ar') {
  4293.             $sortField = 'nameAr'; // Sorting by Arabic
  4294.         }
  4296.         // Sort manually using usort()
  4297.         usort($response, function ($a, $b) use ($sortField) {
  4298.             return strcmp($a[$sortField], $b[$sortField]);
  4299.         });
  4301.         return ["success" => true, "data" => $response];
  4302.     }
  4303. }