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.         $response = [];
  616.         try {
  618.             $notificationList = new DataObject\EwsNotification\Listing();
  619.             $notificationList->setLimit(100);
  621.             // Get the current date as a DateTime object
  622.             $timezone = new \DateTimeZone(TIMEZONE);
  623.             $currentDate = new \DateTime();
  624.             // Set the condition to filter for notifications where endDate is greater than the current date
  625.             $notificationList->setCondition("endDate > ?", [$currentDate->format('Y-m-d H:i:s')]);
  627.             $notificationList->setOrderKey("o_creationDate");
  628.             $notificationList->setOrder("desc");
  630.             // Loop through the notifications to find the last updated date
  632.             // Initialize $lastUpdatedDate with a default value or a date in the past
  633.             $lastUpdatedDate = new DateTime('1900-01-01 00:00:00'); // Replace with your desired default value
  636.             foreach ($notificationList as $notification) {
  637.                 $notificationUpdatedDate = $notification->getEndDate()->setTimezone($timezone);
  639.                 if ($notificationUpdatedDate > $lastUpdatedDate) {
  640.                     $lastUpdatedDate = $notificationUpdatedDate;
  641.                 }
  642.             }
  644.             // Create an empty RSS XML structure
  645.             $rss = new SimpleXMLElement('<rss version="2.0"/>');
  646.             // Create the <channel> element
  647.             $channel = $rss->addChild('channel');
  650.             // Add elements inside <channel>
  651.             $channel->addChild('title', $translator->trans("Early warning system from the National Center of Meteorology, Kingdom of Saudi Arabia"));
  652.             //$channel->addChild('link', 'https://ncm.gov.sa/Ar/alert/Pages/feedalerts.aspx');
  653.             $channel->addChild('link', $_ENV['BASE_URL_DEMO_AJWAA_API'] . '/' . $lang . '/cap-alerts');
  654.             $channel->addChild('description', $translator->trans("Early warning system from the National Center of Meteorology, Kingdom of Saudi Arabia"));
  655.             $channel->addChild('language', $lang);
  656.             $channel->addChild('copyright', $translator->trans("All rights reserved to the National Center of Meteorology, Kingdom of Saudi Arabia"));
  657.             $channel->addChild('pubDate', $lastUpdatedDate->format('D, d M Y H:i:s \G\M\T'));
  660.             // Create the <image> element
  661.             $image = $channel->addChild('image');
  662.             $image->addChild('title', $translator->trans("Early warning system from the National Center of Meteorology, Kingdom of Saudi Arabia"));
  663.             $image->addChild('url', $_ENV['BASE_URL_DEMO_AJWAA_API'] . '/assets/images/logo2.3.png');
  664.             //$image->addChild('link', 'https://ncm.gov.sa/Ar/alert/Pages/feedalerts.aspx');
  665.             $image->addChild('link', $_ENV['BASE_URL_DEMO_AJWAA_API'] . '/' . $lang . '/cap-alerts');
  667.             // Create multiple <alert> elements and add them to the <alerts> element
  668.             // Create child elements and add them to the alert
  671.             foreach ($notificationList as $notification) { // Create two <alert> elements as an example
  673.                 $hazardNames = "";
  674.                 if (!empty($notification->getAlertHazard())) {
  675.                     $hazardNamesArr = [];
  676.                     foreach ($notification->getAlertHazard() as $hazard) {
  677.                         $hazardNamesArr[] = $hazard->getName();
  678.                     }
  679.                     $hazardNames .= implode(", ", $hazardNamesArr);
  680.                 }
  682.                 $governorateNames = "";
  683.                 $governorateCoordinates = "";
  684.                 if ($notification->getGovernorate() && !empty($notification->getGovernorate())) {
  685.                     $governorateNames .= " The governorates of ";
  686.                     $governorateNamesArr = [];
  687.                     $governorateCoordinatesArr = [];
  688.                     foreach ($notification->getGovernorate() as $governorate) {
  689.                         $governorateNamesArr[] = $governorate->getName();
  690.                         $governorateCoordinatesArr[] = $governorate->getLatitude() . "," . $governorate->getLongitude();
  691.                     }
  692.                     $governorateNames .= implode(", ", $governorateNamesArr) . " are expected to be affected.";
  693.                     $governorateCoordinates .= implode(" ", $governorateCoordinatesArr);
  694.                 }
  697.                 // Create one or more <item> elements
  698.                 $item = $channel->addChild('item');
  699.                 //$item->addChild('guid', $notification->getGuid());
  700.                 $item->addChild('guid', "{" . $notification->getGuid() . "}");
  702.                 $item->addChild('title', ($notification->getAlertStatus() ? $notification->getAlertStatus()->getName($lang) : "") . " ,  " . ($notification->getRegion() ? $notification->getRegion()->getName() : ""));
  703.                 $item->addChild('link', $_ENV['BASE_URL_DEMO_AJWAA_API'] . '/cap/' . $lang . '/alerts/' . $notification->getGuid() . '.xml');
  704.                 //$item->addChild('link', $request->getSchemeAndHttpHost() . '/cap/' . $lang . '/alerts/' . $notification->getId() . '-' . $notification->getGuid() . '.xml');
  705.                 $item->addChild('description', "A severe weather event is expected in the " . ($notification->getRegion() ? $notification->getRegion()->getName() : "UNKNOWN") . " region with a potential for " . (!empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName($lang) : "UNKNOWN") . ", which could result in " . $hazardNames . ", " . $governorateNames . " Alert Start Date: " . (!empty($notification->getStartDate()) ? $notification->getStartDate()->format('d/m/Y H:i:s A') : "UNKNOWN") . " Alert End Date: " . (!empty($notification->getEndDate()) ? $notification->getEndDate()->format("d/m/Y H:i:s A") : "UNKNOWN"));
  706.                 $item->addChild('author', AUTHOR);
  707.                 $item->addChild('pubDate', $notification->getStartDate()->setTimeZone($timezone)->format('D, d M Y H:i:s \G\M\T'));
  708.             }
  710.             // Create additional <item> elements as needed
  712.             // Format the XML for output
  713.             $dom = dom_import_simplexml($rss)->ownerDocument;
  714.             $dom->formatOutput = true;
  716.             // Save the XML to a file
  717.             $xmlString = $dom->saveXML();
  719.             // Set the Content-Type header to specify that the response is XML
  720.             header("Content-Type: application/xml");
  722.             // Save the XML to a file or output it
  723.             $xmlString = $rss->saveXML();
  724.             print $xmlString;
  725.             exit;
  726.             return $xmlString;
  727.         } catch (\Exception $ex) {
  728.             $result = ["success" => false, "message" => $ex->getMessage()];
  729.         }
  731.         return $result;
  732.     }
  734.     public function capAlertNotificationDetailxml($guid, $lang, $translator)
  735.     {
  736.         $response = [];
  737.         $timezone = new \DateTimeZone(TIMEZONE);
  739.         try {
  742.             $notification = \Pimcore\Model\DataObject\EwsNotification::getByGuid($guid, true);
  745.             if (empty($notification)) {
  746.                 throw new \Exception('Notification not found.');
  747.             }
  748.             $doc = new DomDocument('1.0', 'UTF-8');
  749.             // Create the root element
  750.             $alert = $doc->createElement('alert');
  751.             $alert->setAttribute('xmlns', 'urn:oasis:names:tc:emergency:cap:1.2');
  752.             $doc->appendChild($alert);
  753.             // Create child elements and add them to the alert
  754.             $identifier = $doc->createElement('identifier',  $notification->getGuid()); //uuid
  755.             $sender = $doc->createElement('sender', SENDER_EMAIL);
  756.             $sent = $doc->createElement('sent', $notification->getStartDate()->setTimezone($timezone)->format('Y-m-d\TH:i:sP'));
  757.             $status = $doc->createElement('status', 'Actual');
  758.             $msgType = $doc->createElement('msgType', 'Alert');
  759.             $scope = $doc->createElement('scope', 'Public');
  760.             $alert->appendChild($identifier);
  761.             $alert->appendChild($sender);
  762.             $alert->appendChild($sent);
  763.             $alert->appendChild($status);
  764.             $alert->appendChild($msgType);
  765.             $alert->appendChild($scope);
  766.             // Create the <info> element and add it to the alert
  767.             $info = $doc->createElement('info');
  768.             $alert->appendChild($info);
  769.             // Create child elements for the <info> element
  770.             $category = $doc->createElement('category', 'Met');
  771.             $event = $doc->createElement('event', $notification->getAlertStatus() ? $notification->getAlertStatus()->getName($lang) : 'UNKNOWN'); //high rain
  772.             $urgency = $doc->createElement('urgency', 'Immediate');
  773.             //$severity = $doc->createElement('severity',  $notification->getAlertAction()[0] ? $notification->getAlertAction()[0]->getCapStatus() : "UNKNOWN");
  774.             $severity = $doc->createElement('severity',  "Severe" . ($notification->getAlertAction()[0] ? $notification->getAlertAction()[0]->getCapStatus() : "UNKNOWN"));
  775.             $certainty = $doc->createElement('certainty', 'Observed');
  776.             $onset = $doc->createElement('onset', $notification->getEndDate()->setTimezone($timezone)->format('Y-m-d\TH:i:sP'));
  777.             $expires = $doc->createElement('expires', $notification->getEndDate()->setTimezone($timezone)->format('Y-m-d\TH:i:sP'));
  778.             $senderName = $doc->createElement('senderName', $translator->trans("Focus-National-Meteorology"));
  779.             $headline = $doc->createElement('headline', 'SEVERE ' . $notification->getAlertStatus()->getName($lang) . ' WARNING');
  782.             $hazardNames = "";
  783.             if (!empty($notification->getAlertHazard())) {
  784.                 $hazardNamesArr = [];
  785.                 foreach ($notification->getAlertHazard() as $hazard) {
  786.                     $hazardNamesArr[] = $hazard->getName($lang);
  787.                 }
  788.                 $hazardNames .= implode(", ", $hazardNamesArr);
  789.             }
  791.             $governorateNames = "";
  792.             $governorateCoordinates = "";
  793.             if ($notification->getGovernorate() && !empty($notification->getGovernorate())) {
  794.                 $governorateNames .= " The governorates of ";
  795.                 $governorateNamesArr = [];
  796.                 $governorateCoordinatesArr = [];
  797.                 foreach ($notification->getGovernorate() as $governorate) {
  798.                     $governorateNamesArr[] = $governorate->getName($lang);
  799.                     $governorateCoordinatesArr[] = $governorate->getLatitude() . "," . $governorate->getLongitude();
  800.                 }
  801.                 $governorateNames .= implode(", ", $governorateNamesArr) . " are expected to be affected.";
  802.                 $governorateCoordinates .= implode(" ", $governorateCoordinatesArr);
  803.             }
  805.             $description = $doc->createElement('description', "A severe weather event is expected in the " . ($notification->getRegion() ? $notification->getRegion()->getName($lang) : "UNKNOWN") . " region with a potential for " . (!empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName($lang) : "UNKNOWN") . ", which could result in " . $hazardNames . ", " . $governorateNames . " Alert Start Date: " . (!empty($notification->getStartDate()) ? $notification->getStartDate()->format('d/m/Y H:i:s A') : "UNKNOWN") . " Alert End Date: " . (!empty($notification->getEndDate()) ? $notification->getEndDate()->format("d/m/Y H:i:s A") : "UNKNOWN"));
  806.             $instruction = $doc->createElement('instruction', '');
  807.             $contact = $doc->createElement('contact', CONTACT);
  808.             $web = $doc->createElement('web', 'https://ncm.gov.sa//Ar/alert/Pages/MapDetail.aspx?AlertId=43431&amp;amp;VId=3.0');
  809.             $info->appendChild($category);
  810.             $info->appendChild($event);
  811.             $info->appendChild($urgency);
  812.             $info->appendChild($severity);
  813.             $info->appendChild($certainty);
  814.             $info->appendChild($onset);
  815.             $info->appendChild($expires);
  816.             $info->appendChild($senderName);
  817.             $info->appendChild($headline);
  818.             $info->appendChild($description);
  819.             $info->appendChild($instruction);
  820.             $info->appendChild($contact);
  822.             // Create the <area> element and add it to the <info> element
  823.             $area = $doc->createElement('area');
  824.             $info->appendChild($area);
  825.             //$info->appendChild($web);
  826.             // Create child elements for the <area> element
  827.             //$areaDesc = $doc->createElement('areaDesc', $notification->getMessage());
  828.             $areaDesc = $doc->createElement('areaDesc', "Makkah region including Al Taif, Madrakah" . $notification->getMessage());
  830.             $polygon = '';
  832.             // Remove square brackets at the beginning and end
  833.             $coordinatesString = trim($notification->getCoordinates(), '[]');
  835.             // Split the coordinates into an array
  836.             $coordinates = explode("],[", $coordinatesString);
  838.             foreach ($coordinates as $coordinate) {
  839.                 $parts = explode(",", $coordinate);
  840.                 if (count($parts) == 2 && is_numeric($parts[0]) && is_numeric($parts[1])) {
  841.                     $polygon .= $parts[0] . "," . $parts[1] . ' ';
  842.                 }
  843.             }
  845.             // Remove the trailing comma
  846.             $polygon = rtrim($polygon, ',');
  848.             if (!empty(trim($polygon))) {
  849.                 $polygon = $doc->createElement('polygon', $polygon);
  850.             } else {
  851.                 $polygonDesc = $notification->getRegion() ? $notification->getRegion()->getLatitude() . "," . $notification->getRegion()->getLongitude() : '';
  852.                 $polygon = $doc->createElement('polygon', $polygonDesc . ' ' . $polygonDesc . ' ' . $polygonDesc . ' ' . $polygonDesc);
  853.             }
  855.             $area->appendChild($areaDesc);
  856.             $area->appendChild($polygon);
  859.             // Save the XML to a file or output it
  860.             $xmlString = $doc->saveXML();
  862.             print $xmlString;
  863.             exit;
  864.             return $xmlString;
  865.         } catch (\Exception $ex) {
  866.             $result = ["success" => false, "message" => $ex->getMessage()];
  867.         }
  869.         return $result;
  870.     }
  872.     public function viewNotification($params, $translator): array
  873.     {
  874.         $result = [];
  875.         // try {
  877.         $viewNotification = DataObject\EwsNotification::getById($params['id'], false);
  878.         if (!$viewNotification) {
  879.             $viewNotification = DataObject\EwsNotification::getById($params['id'], true);
  880.         }
  881.         if ($viewNotification) {
  882.             $notificationData = $this->createNotificationFormat($viewNotification, $translator);
  883.             $history =  $this->getVersions($viewNotification, $translator);
  884.             return ["success" => true, "data" => $notificationData, "history" => $history];
  885.         }
  887.         return ["success" => false, "message" => $translator->trans("ews_notification_does_not_exists")];
  888.         // } catch (\Exception $ex) {
  889.         //     $result = ["success" => false, "message" => $ex->getMessage()];
  890.         // }
  892.         return $result;
  893.     }
  895.     public function addAddressComponentsFieldCollection($addressComponents, DataObject\EwsNotification $object)
  896.     {
  897.         $items = new \Pimcore\Model\DataObject\Fieldcollection();
  899.         foreach ($addressComponents as $Data) {
  901.             #creating field collections
  902.             $item = new DataObject\Fieldcollection\Data\AddressComponents();
  903.             $item->setAddressValue(strip_tags($Data['long_name']));
  904.             $item->setAddressKey(strip_tags($Data['types'][0]));
  906.             $items->add($item);
  907.         }
  909.         return $object->setAddressComponents($items);
  910.     }
  912.     public function getAlertAction($id)
  913.     {
  914.         $alertActionObj = DataObject\AlertAction::getById($id);
  915.         $data = [];
  916.         if (!empty($alertActionObj)) {
  917.             $data['id'] = $alertActionObj->getAlertActionId();
  918.             $data['severity'] = $alertActionObj->getSeverity();
  919.             $data['nameEn'] = $alertActionObj->getName('en');
  920.             $data['nameAr'] = $alertActionObj->getName('ar');
  921.         }
  922.         return $data;
  923.     }
  924.     public function getAlertType($id)
  925.     {
  926.         $alertTypeObj = DataObject\AlertType::getById($id);
  927.         $data = [];
  928.         if (!empty($alertTypeObj)) {
  929.             $data['id'] = $alertTypeObj->getAlertTypeId();
  930.             $data['nameEn'] = $alertTypeObj->getName('en');
  931.             $data['nameAr'] = $alertTypeObj->getName('ar');
  932.         }
  933.         return $data;
  934.     }
  936.     public function getAlertStatus($id)
  937.     {
  938.         $alertStatus = DataObject\AlertStatus::getById($id);
  939.         $data = [];
  940.         if (!empty($alertStatus)) {
  941.             $alertType = $alertStatus->getAlertType();
  942.             $alertData = [];
  943.             if (!empty($alertType)) {
  944.                 $alertData = [
  945.                     "id" => $alertType->getAlertTypeId(),
  946.                     "nameEn" => $alertType->getName('en'),
  947.                     "nameAr" => $alertType->getName('ar')
  949.                 ];
  950.             }
  951.             $data['id'] = $alertStatus->getAlertStatusId();
  952.             $data['nameEn'] = $alertStatus->getName('en');
  953.             $data['nameAr'] = $alertStatus->getName('ar');
  954.             $data['alertType'] = $alertData;
  955.         }
  956.         return $data;
  957.     }
  959.     public function getAlertHazard($id)
  960.     {
  961.         $alertHazardObj = DataObject\AlertHazard::getById($id);
  962.         $data = [];
  963.         if (!empty($alertHazardObj)) {
  964.             $data['id'] = $alertHazardObj->getAlertHazardId();
  965.             $data['nameEn'] = $alertHazardObj->getName('en');
  966.             $data['nameAr'] = $alertHazardObj->getName('ar');
  967.         }
  968.         return $data;
  969.     }
  971.     public function getRegion($id)
  972.     {
  973.         $regionObj = DataObject\Region::getById($id);
  974.         $data = [];
  975.         if (!empty($regionObj)) {
  976.             $data['id'] = $regionObj->getRegionId();
  977.             $data['nameEn'] = $regionObj->getName('en');
  978.             $data['nameAr'] = $regionObj->getName('ar');
  979.             $data['longitude'] = $regionObj->getLongitude();
  980.             $data['latitude'] = $regionObj->getLatitude();
  981.         }
  982.         return $data;
  983.     }
  985.     public function getEvent($id)
  986.     {
  987.         $eventObj = DataObject\Event::getById($id);
  988.         $data = [];
  989.         if (!empty($eventObj)) {
  990.             $data['id'] = $eventObj->getEventId();
  991.             $data['nameEn'] = $eventObj->getName('en');
  992.             $data['nameAr'] = $eventObj->getName('ar');
  993.         }
  994.         return $data;
  995.     }
  997.     public function getWeatherPhenomenon($id)
  998.     {
  999.         $weatherPhenObj = DataObject\PhenomenaList::getById($id);
  1000.         $data = [];
  1001.         if (!empty($weatherPhenObj)) {
  1002.             $data['id'] = $weatherPhenObj->getPhenomenaListId();
  1003.             $data['nameEn'] = $weatherPhenObj->getTitle('en');
  1004.             $data['nameAr'] = $weatherPhenObj->getTitle('ar');
  1005.         }
  1006.         return $data;
  1007.     }
  1009.     public function getWeatherPhenAffect($id)
  1010.     {
  1011.         $weatherPhenObj = DataObject\WeatherPhenomenonAffect::getById($id);
  1012.         $data = [];
  1013.         if (!empty($weatherPhenObj)) {
  1014.             $data['id'] = $weatherPhenObj->getWeatherPhenomenonAffectId();
  1015.             $data['nameEn'] = $weatherPhenObj->getName('en');
  1016.             $data['nameAr'] = $weatherPhenObj->getName('ar');
  1017.         }
  1018.         return $data;
  1019.     }
  1020.     // public function getGovernorateDetail($governorateList)
  1021.     // {
  1022.     //     $result = [];
  1023.     //     if (!empty($governorateList)) {
  1024.     //         for ($i = 0; $i < count($governorateList); $i++) {
  1025.     //             $parentGovernates = null;
  1026.     //             if ($governorateList[$i]->getIsMunicipality()) {
  1028.     //                 $municipatlity = \Pimcore\Model\DataObject\Municipality::getByMunicipalityId($governorateList[$i]->getMunicipalityID(), true);
  1030.     //                 if ($municipatlity &&  $municipatlity->getGovernorate()) {
  1031.     //                     $parentGovernates = $municipatlity->getGovernorate();
  1032.     //                 }
  1033.     //             }
  1034.     //             $result[$i]['id'] = $governorateList[$i]->getGovernoteId();
  1035.     //             $result[$i]['nameEn'] = $governorateList[$i]->getName('en');
  1036.     //             $result[$i]['nameAr'] = $governorateList[$i]->getName('ar');
  1037.     //             $result[$i]['longitude'] = $governorateList[$i]->getLongitude();
  1038.     //             $result[$i]['latitude'] = $governorateList[$i]->getLatitude();
  1039.     //             $result[$i]['parentId'] = $parentGovernates ? $parentGovernates->getGovernoteId() : null;
  1041.     //             $result[$i]['parenNameEn'] = $parentGovernates ? $parentGovernates->getName('en') : null;
  1042.     //             $result[$i]['parenNameAr'] = $parentGovernates ? $parentGovernates->getName('ar') : null;
  1044.     //             $result[$i]['parentLongitude'] = $parentGovernates ? $parentGovernates->getLongitude() : null;
  1045.     //             $result[$i]['parentLatitude'] = $parentGovernates ? $parentGovernates->getLatitude() : null;
  1046.     //             $result[$i]['isMunicipality'] = $governorateList[$i]->getIsMunicipality();
  1047.     //             $result[$i]['municipalities'] = [];
  1048.     //         }
  1049.     //     }
  1050.     //     return $result;
  1051.     // }
  1053.     public function getGovernorateDetail($governorateList)
  1054.     {
  1055.         $result = [];
  1056.         if (!empty($governorateList)) {
  1057.             $uniqueGovernorateArray = [];
  1058.             foreach ($governorateList as $governorate) {
  1059.                 $parentGovernates = null;
  1061.                 // Check if it is a municipality and fetch parent governorate
  1062.                 if ($governorate->getIsMunicipality()) {
  1063.                     $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityId($governorate->getMunicipalityID(), true);
  1064.                     if ($municipality && $municipality->getGovernorate()) {
  1065.                         $parentGovernates = $municipality->getGovernorate();
  1066.                     }
  1067.                 }
  1069.                 // Initialize a unique governorate array if needed
  1070.                 $parentId = $parentGovernates ? $parentGovernates->getGovernoteId() : $governorate->getGovernoteId();
  1072.                 if (!isset($uniqueGovernorateArray[$parentId])) {
  1073.                     $uniqueGovernorateArray[$parentId] = [
  1074.                         'id' => $parentId,
  1075.                         'nameEn' => $parentGovernates ? $parentGovernates->getName('en') : $governorate->getName('en'),
  1076.                         'nameAr' => $parentGovernates ? $parentGovernates->getName('ar') : $governorate->getName('ar'),
  1077.                         'longitude' => $parentGovernates ? $parentGovernates->getLongitude() : $governorate->getLongitude(),
  1078.                         'latitude' => $parentGovernates ? $parentGovernates->getLatitude() : $governorate->getLatitude(),
  1079.                         'municipalities' => []
  1080.                     ];
  1081.                 }
  1083.                 // Add municipality details if it is a municipality
  1084.                 if ($governorate->getIsMunicipality()) {
  1085.                     $uniqueGovernorateArray[$parentId]['municipalities'][] = [
  1086.                         'id' => $governorate->getGovernoteId(),
  1087.                         'nameEn' => $governorate->getName('en'),
  1088.                         'nameAr' => $governorate->getName('ar'),
  1089.                         'longitude' => $governorate->getLongitude(),
  1090.                         'latitude' => $governorate->getLatitude()
  1091.                     ];
  1092.                 }
  1093.             }
  1095.             // Flatten the associative array to a numerical array for output
  1096.             $result = array_values($uniqueGovernorateArray);
  1097.         }
  1099.         return $result;
  1100.     }
  1103.     public function getMessageDetail($notificationObj)
  1104.     {
  1105.         $data = [];
  1106.         if (!empty($notificationObj)) {
  1107.             $data['messageEn'] = $notificationObj->getMessage('en');
  1108.             $data['messageAr'] = $notificationObj->getMessage('ar');
  1109.         }
  1110.         return $data;
  1111.     }
  1113.     public function createAsset($fileData, $filename)
  1114.     {
  1116.         // Validate the file data
  1117.         if (preg_match('/^data:(image\/(png|jpe?g)|application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel));base64,/', $fileData) !== 1) {
  1118.             return false; // Invalid file data or MIME type
  1119.         }
  1121.         // Extract the file extension from the MIME type
  1122.         $extension = '';
  1123.         if (preg_match('/^data:image\/(png|jpe?g);base64,/', $fileData)) {
  1124.             $extension = 'jpg'; // Assume JPG for base64-encoded image data (PNG or JPEG)
  1125.         } elseif (preg_match('/^data:application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel);base64,/', $fileData)) {
  1126.             $extension = 'pdf'; // PDF, DOCX, or Excel
  1127.         }
  1129.         // Remove the "data:image/png;base64," or "data:application/pdf;base64," prefix to get the actual base64-encoded content
  1130.         $base64Content = preg_replace('/^data:(image\/png|application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel));base64,/', '', $fileData);
  1132.         // Decode the base64-encoded content
  1133.         $fileContent = base64_decode($base64Content);
  1135.         // Validate the decoded content
  1136.         if ($fileContent === false) {
  1137.             return false; // Invalid base64-encoded content
  1138.         }
  1140.         // Create the Pimcore asset
  1141.         $asset = new \Pimcore\Model\Asset();
  1142.         $parent = Asset\Service::createFolderByPath('/EWSNotification');
  1143.         $asset->setFilename($filename); // Replace with the desired filename and extension
  1144.         $asset->setParent($parent);
  1145.         $asset->setData($fileContent);
  1147.         // Set the MIME type based on the file extension
  1148.         $mimeType = '';
  1149.         if ($extension === 'pdf') {
  1150.             $mimeType = 'application/pdf';
  1151.         } elseif ($extension === 'jpg') {
  1152.             $mimeType = 'image/jpeg';
  1153.         } elseif ($extension === 'png') {
  1154.             $mimeType = 'image/png';
  1155.         } elseif ($extension === 'docx') {
  1156.             $mimeType = 'application/vnd.openxmlformats-officedocument.wordprocessingml.document';
  1157.         } elseif ($extension === 'xlsx') {
  1158.             $mimeType = 'application/vnd.ms-excel';
  1159.         }
  1161.         // Validate the MIME type
  1162.         if (!in_array($mimeType, ['image/jpeg', 'image/png', 'application/pdf', 'application/vnd.openxmlformats-officedocument.wordprocessingml.document', 'application/vnd.ms-excel'])) {
  1163.             return false; // Invalid MIME type
  1164.         }
  1166.         $asset->setType($mimeType);
  1168.         // Save the asset
  1169.         $asset->save();
  1171.         return $asset;
  1172.     }
  1174.     public function getPhenomenaListByAlertId($alertID, $lang = "en")
  1175.     {
  1176.         $response = [];
  1177.         $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alertID, true);
  1178.         if ($alertType instanceof \Pimcore\Model\DataObject\AlertType) {
  1179.             $phenomenaList = $alertType->getPhenomenaList();
  1180.             if ($phenomenaList) {
  1181.                 foreach ($phenomenaList as $phenomena) {
  1182.                     $phenomenaId = $phenomena->getPhenomena();
  1183.                     if ($phenomenaId) {
  1184.                         $phenomenaObj = \Pimcore\Model\DataObject::getById($phenomenaId);
  1185.                         $response[] = ["id" => $phenomenaObj->getphenomenaListId(), "nameEn" => $phenomenaObj->getTitle("en"), "nameAr" => $phenomenaObj->getTitle("ar"), "criteria" => $phenomena->getCriteria()];
  1186.                     }
  1187.                 }
  1188.             } else {
  1189.                 return ["success" => false, "message" => "No criteria is set"];
  1190.             }
  1191.         } else {
  1192.             return ["success" => false, "message" => "Invalid alert type id"];
  1193.         }
  1194.         return ["success" => true, "data" => $response];
  1195.     }
  1197.     public function getPhenomenaListByAlertIds($alertIDs, $lang = "en")
  1198.     {
  1199.         $response = [];
  1200.         if (count($alertIDs) > 0) {
  1201.             foreach ($alertIDs as $alertID) {
  1202.                 $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alertID, true);
  1204.                 if ($alertType instanceof \Pimcore\Model\DataObject\AlertType) {
  1205.                     $phenomenaList = $alertType->getPhenomenaList();
  1207.                     if ($phenomenaList) {
  1208.                         foreach ($phenomenaList as $phenomena) {
  1209.                             $phenomenaId = $phenomena->getPhenomena();
  1211.                             if ($phenomenaId) {
  1212.                                 $phenomenaObj = \Pimcore\Model\DataObject::getById($phenomenaId);
  1213.                                 if ($phenomenaObj instanceof \Pimcore\Model\DataObject) {
  1214.                                     $currentId = $phenomenaObj->getphenomenaListId();
  1215.                                     $existingIds = array_column($response, 'id');
  1217.                                     if (!in_array($currentId, $existingIds)) {
  1218.                                         $response[] = [
  1219.                                             "id" => $currentId,
  1220.                                             "nameEn" => $phenomenaObj->getTitle("en"),
  1221.                                             "nameAr" => $phenomenaObj->getTitle("ar"),
  1222.                                             "criteria" => $phenomena->getCriteria()
  1223.                                         ];
  1224.                                     } else {
  1225.                                         $index = array_search($currentId, $existingIds);
  1226.                                         $response[$index]['criteria'] .= ', ' . $phenomena->getCriteria();
  1227.                                     }
  1228.                                 }
  1229.                             }
  1230.                         }
  1231.                     } else {
  1232.                         return ["success" => false, "message" => "No criteria is set"];
  1233.                     }
  1234.                 }
  1235.             }
  1237.             return ["success" => true, "data" => $response];
  1238.         }
  1240.         return ["success" => false, "message" => "Invalid alert type id"];
  1241.     }
  1243.     public function getAlertActions()
  1244.     {
  1245.         $response = [];
  1246.         $alertActions = new DataObject\AlertAction\Listing();
  1247.         $alertActions = $alertActions->load();
  1248.         if ($alertActions) {
  1249.             foreach ($alertActions as $alertAction) {
  1250.                 $response[] = [
  1251.                     "id" => $alertAction->getAlertActionId(),
  1252.                     "nameEn" => $alertAction->getName('en'),
  1253.                     "nameAr" => $alertAction->getName('ar'),
  1254.                     "severity" => $alertAction->getSeverity()
  1255.                 ];
  1256.             }
  1257.         }
  1258.         return ["success" => true, "data" => $response];
  1259.     }
  1261.     public function getAlertHazards()
  1262.     {
  1263.         $response = [];
  1264.         $alertHazards = new DataObject\AlertHazard\Listing();
  1265.         $alertHazards = $alertHazards->load();
  1266.         if ($alertHazards) {
  1267.             foreach ($alertHazards as $alertHazard) {
  1268.                 $response[] = [
  1269.                     "id" => $alertHazard->getalertHazardId(),
  1270.                     "nameEn" => $alertHazard->getName('en'),
  1271.                     "nameAr" => $alertHazard->getName('ar'),
  1272.                     "OrderId" => $alertHazard->getOrderId()
  1273.                 ];
  1274.             }
  1275.         }
  1277.         return ["success" => true, "data" => $response];
  1278.     }
  1280.     public function getAlertTypes()
  1281.     {
  1282.         $response = [];
  1283.         $alertTypes = new DataObject\AlertType\Listing();
  1284.         $alertTypes = $alertTypes->load();
  1285.         if ($alertTypes) {
  1286.             foreach ($alertTypes as $alertType) {
  1287.                 $response[] = [
  1288.                     "id" => $alertType->getAlertTypeId(),
  1289.                     "color" => $alertType->getColor(),
  1290.                     "nameEn" => $alertType->getName('en'),
  1291.                     "nameAr" => $alertType->getName('ar')
  1292.                 ];
  1293.             }
  1294.         }
  1296.         return ["success" => true, "data" => $response];
  1297.     }
  1299.     public function getEvents()
  1300.     {
  1301.         $response = [];
  1302.         $events = new DataObject\Event\Listing();
  1303.         $events = $events->load();
  1304.         if ($events) {
  1305.             foreach ($events as $event) {
  1306.                 $response[] = [
  1307.                     "id" => $event->getEventId(),
  1308.                     "nameEn" => $event->getName('en'),
  1309.                     "nameAr" => $event->getName('ar')
  1311.                 ];
  1312.             }
  1313.         }
  1315.         return ["success" => true, "data" => $response];
  1316.     }
  1317.     public function getWeatherPhenomenones()
  1318.     {
  1319.         $response = [];
  1320.         $weatherPhenomenons = new DataObject\PhenomenaList\Listing();
  1321.         $weatherPhenomenons = $weatherPhenomenons->load();
  1322.         if ($weatherPhenomenons) {
  1323.             foreach ($weatherPhenomenons as $weatherPhenomenon) {
  1324.                 $response[] = [
  1325.                     "id" => $weatherPhenomenon->getPhenomenaListId(),
  1326.                     "nameEn" => $weatherPhenomenon->getTitle('en'),
  1327.                     "nameAr" => $weatherPhenomenon->getTitle('ar')
  1329.                 ];
  1330.             }
  1331.         }
  1333.         return ["success" => true, "data" => $response];
  1334.     }
  1336.     public function getWeatherPhenomenonAffect()
  1337.     {
  1338.         $response = [];
  1339.         $getWeatherPhenomAffects = new DataObject\WeatherPhenomenonAffect\Listing();
  1340.         $getWeatherPhenomAffects = $getWeatherPhenomAffects->load();
  1341.         if ($getWeatherPhenomAffects) {
  1342.             foreach ($getWeatherPhenomAffects as $getWeatherPhenomAffect) {
  1343.                 $response[] = [
  1344.                     "id" => $getWeatherPhenomAffect->getWeatherPhenomenonAffectId(),
  1345.                     "nameEn" => $getWeatherPhenomAffect->getName('en'),
  1346.                     "nameAr" => $getWeatherPhenomAffect->getName('ar')
  1348.                 ];
  1349.             }
  1350.         }
  1352.         return ["success" => true, "data" => $response];
  1353.     }
  1355.     public function getAlertStatuses($params)
  1356.     {
  1357.         $response = [];
  1358.         $alertStatuss = new DataObject\AlertStatus\Listing();
  1360.         // Handle search by name
  1361.         if (isset($params['search']) && !empty($params['search'])) {
  1362.             $alertStatuss->addConditionParam("name LIKE ?", "%" . $params['search'] . "%");
  1363.         }
  1365.         // Handle alert type filter
  1366.         if (isset($params['alert_id']) && !empty($params['alert_id'])) {
  1367.             $alertTypeIds = [];
  1368.             $alertTypeList = new DataObject\AlertType\Listing();
  1369.             $alertTypeList->addConditionParam("alertTypeId IN (?)", [$params['alert_id']]);
  1370.             foreach ($alertTypeList as $alertType) {
  1371.                 $alertTypeIds[] = $alertType->getId();
  1372.             }
  1373.             $alertStatuss->addConditionParam("alertType__id IN (?)", [$alertTypeIds]);
  1374.         }
  1376.         // Check for regionId array and isLandLocked logic
  1377.         $excludeWavesRising = false;
  1378.         if (isset($params['regionId']) && is_array($params['regionId']) && count($params['regionId']) > 0) {
  1379.             foreach ($params['regionId'] as $regionId) {
  1380.                 $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  1381.                 if ($region && $region->getIsLandLocked()) {
  1382.                     $excludeWavesRising = true;
  1383.                     break;
  1384.                 }
  1385.             }
  1386.         }
  1388.         $alertStatuss = $alertStatuss->load();
  1390.         if ($alertStatuss) {
  1391.             foreach ($alertStatuss as $alertStatus) {
  1392.                 // Exclude "Waves rising" if needed
  1393.                 if ($excludeWavesRising && ((strtolower(trim($alertStatus->getName('en'))) === 'waves rising'))) {
  1394.                     continue;
  1395.                 }
  1397.                 $alertType = $alertStatus->getAlertType();
  1398.                 $alertData = [];
  1399.                 if (!empty($alertType)) {
  1400.                     $alertData = [
  1401.                         "id" => $alertType->getAlertTypeId(),
  1402.                         "nameEn" => $alertType->getName('en'),
  1403.                         "nameAr" => $alertType->getName('ar')
  1404.                     ];
  1405.                 }
  1406.                 $response[] = [
  1407.                     "id" => $alertStatus->getalertStatusId(),
  1408.                     "nameEn" => $alertStatus->getName('en'),
  1409.                     "nameAr" => $alertStatus->getName('ar'),
  1410.                     "imageTemplate" => $alertStatus->getimageTemplate(),
  1411.                     "alertType" => $alertData
  1412.                 ];
  1413.             }
  1414.         }
  1416.         return ["success" => true, "data" => $response];
  1417.     }
  1419.     public function getGovernorates()
  1420.     {
  1421.         $response = [];
  1422.         $governorates = new DataObject\Governorate\Listing();
  1423.         $Governorates = $governorates->load();
  1424.         if ($governorates) {
  1425.             foreach ($governorates as $governorate) {
  1426.                 $region = $governorate->getregionId();
  1427.                 $regionData = [];
  1428.                 if (!empty($region)) {
  1429.                     $regionData = [
  1430.                         "id" => $region->getRegionId(),
  1431.                         "nameEn" => $region->getName('en'),
  1432.                         "nameAr" => $region->getName('ar'),
  1433.                         "longitude" => $region->getLongitude(),
  1434.                         "latitude" => $region->getLongitude()
  1436.                     ];
  1437.                 }
  1438.                 $response[] = [
  1439.                     "id" => $governorate->getgovernoteId(),
  1440.                     "nameEn" => $governorate->getName('en'),
  1441.                     "nameAr" => $governorate->getName('ar'),
  1442.                     "regionId" => $regionData,
  1443.                     "longitude" => $governorate->getLongitude(),
  1444.                     "latitude" => $governorate->getLatitude(),
  1445.                     "isHidden" => $governorate->getisHidden(),
  1446.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  1447.                     "MunicipalityID" => $governorate->getMunicipalityID()
  1448.                 ];
  1449.             }
  1450.         }
  1452.         return ["success" => true, "data" => $response];
  1453.     }
  1455.     public function getMunicipality($governorateId = null, $lang = 'en')
  1456.     {
  1457.         $response = [];
  1458.         $municipalities = new DataObject\Municipality\Listing();
  1459.         if (is_array($governorateId)) {
  1460.             $govIdsArr = [];
  1461.             foreach ($governorateId as $govId) {
  1462.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  1463.                 if ($governorate) {
  1464.                     array_push($govIdsArr, $governorate->getId());
  1465.                 }
  1466.             }
  1467.             $municipalities->setCondition("governorate__id IN (" . implode(", ", $govIdsArr) . ")");
  1468.         } else {
  1469.             if ($governorateId) {
  1470.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($governorateId, true);
  1471.                 $municipalities->setCondition("governorate__id = ?", [$governorate->getId()]);
  1472.             }
  1473.         }
  1474.         $municipalities = $municipalities->load();
  1475.         if ($municipalities) {
  1476.             foreach ($municipalities as $municipality) {
  1477.                 $response[] = [
  1478.                     "id" => $municipality->getMunicipalityid(),
  1479.                     "nameEn" => $municipality->getName('en'),
  1480.                     "nameAr" => $municipality->getName('ar'),
  1481.                     "longitude" => $municipality->getLongitude(),
  1482.                     "latitude" => $municipality->getLatitude(),
  1483.                     "governate" => $municipality->getGovernorate()->getGovernoteId()
  1484.                 ];
  1485.             }
  1486.         }
  1488.         // Determine sorting field based on language
  1489.         $sortField = 'nameEn'; // Default sorting by English
  1490.         if (isset($lang) && strtolower($lang) === 'ar') {
  1491.             $sortField = 'nameAr'; // Sorting by Arabic
  1492.         }
  1494.         // Sort manually using usort()
  1495.         usort($response, function ($a, $b) use ($sortField) {
  1496.             return strcmp($a[$sortField], $b[$sortField]);
  1497.         });
  1499.         return ["success" => true, "data" => $response];
  1500.     }
  1501.     public function getMunicipalityByParams($governorateId = null,$search = null, $lang = 'en')
  1502.     {
  1503.         $response = [];
  1504.         $municipalities = new DataObject\Municipality\Listing();
  1505.         if (is_array($governorateId)) {
  1506.             $govIdsArr = [];
  1507.             foreach ($governorateId as $govId) {
  1508.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  1509.                 if ($governorate) {
  1510.                     array_push($govIdsArr, $governorate->getId());
  1511.                 }
  1512.             }
  1513.             $municipalities->setCondition("governorate__id IN (" . implode(", ", $govIdsArr) . ")");
  1514.         } else {
  1515.             if ($governorateId) {
  1516.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($governorateId, true);
  1517.                 $municipalities->setCondition("governorate__id = ?", [$governorate->getId()]);
  1518.             }
  1519.         }
  1520.         if (isset($search)) {
  1521.             $municipalities->addConditionParam("name LIKE ?", "%{$search}%");
  1522.         }
  1523.         $municipalities = $municipalities->load();
  1524.         if ($municipalities) {
  1525.             foreach ($municipalities as $municipality) {
  1526.                 $response[] = [
  1527.                     "id" => $municipality->getMunicipalityid(),
  1528.                     "nameEn" => $municipality->getName('en'),
  1529.                     "nameAr" => $municipality->getName('ar'),
  1530.                     "longitude" => $municipality->getLongitude(),
  1531.                     "latitude" => $municipality->getLatitude(),
  1532.                     "governate" => $municipality->getGovernorate()->getGovernoteId()
  1533.                 ];
  1534.             }
  1535.         }
  1537.         // Determine sorting field based on language
  1538.         $sortField = 'nameEn'; // Default sorting by English
  1539.         if (isset($lang) && strtolower($lang) === 'ar') {
  1540.             $sortField = 'nameAr'; // Sorting by Arabic
  1541.         }
  1543.         // Sort manually using usort()
  1544.         usort($response, function ($a, $b) use ($sortField) {
  1545.             return strcmp($a[$sortField], $b[$sortField]);
  1546.         });
  1548.         return ["success" => true, "data" => $response];
  1549.     }
  1550.     public function getGovernoratesByRegion($params)
  1551.     {
  1552.         $response = [];
  1554.         $governorates = new DataObject\Governorate\Listing();
  1556.         if (isset($params['region_id'])) {
  1557.             $region = \Pimcore\Model\DataObject\Region::getByRegionId($params['region_id'], true);
  1558.             if (!$region) {
  1559.                 throw new \Exception("Region not available");
  1560.             }
  1561.             $governorates->filterByRegionId($region);
  1562.         }
  1564.         if (isset($params['region_ids']) && !empty($params['region_ids'])) {
  1565.             $regionIds = [];
  1566.             $regionList = new DataObject\Region\Listing();
  1567.             $regionList->addConditionParam("regionId IN (?)", [$params['region_ids']]);
  1568.             foreach ($regionList as $region) {
  1569.                 $regionIds[] = $region->getId();
  1570.             }
  1571.             $governorates->addConditionParam("regionId__id IN (?)", [$regionIds]);
  1572.         }
  1574.         // Load governorates without sorting in Pimcore
  1575.         $governorates = $governorates->load();
  1577.         // Convert to array for manual sorting
  1578.         $count = 0;
  1579.         if ($governorates) {
  1580.             foreach ($governorates as $governorate) {
  1581.                 $region = $governorate->getregionId();
  1582.                 $regionData = [];
  1583.                 if (!empty($region)) {
  1584.                     $regionData = [
  1585.                         "id" => $region->getRegionId(),
  1586.                         "nameEn" => $region->getName('en'),
  1587.                         "nameAr" => $region->getName('ar'),
  1588.                         "longitude" => $region->getLongitude(),
  1589.                         "latitude" => $region->getLatitude()
  1591.                     ];
  1592.                 }
  1593.                 $response[$count] = [
  1594.                     "id" => $governorate->getgovernoteId(),
  1595.                     "nameEn" => $governorate->getName('en'),
  1596.                     "nameAr" => $governorate->getName('ar'),
  1597.                     "regionId" => $regionData,
  1598.                     "longitude" => $governorate->getLongitude(),
  1599.                     "latitude" => $governorate->getLatitude(),
  1600.                     "isHidden" => $governorate->getisHidden(),
  1601.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  1602.                     "MunicipalityID" => $governorate->getMunicipalityID(),
  1603.                     "bbox" => $governorate->getBbox()
  1604.                 ];
  1606.                 if ($governorate->getMunicipalityID() && $governorate->getIsMunicipality()) {
  1607.                     $municipality = \Pimcore\Model\DataObject\Municipality::getBymunicipalityid($governorate->getMunicipalityID(), true);
  1608.                     if ($municipality) {
  1609.                         $muniGovernate = $municipality->getgovernorate();
  1610.                         if ($muniGovernate) {
  1611.                             $response[$count]["parent_id"] = $muniGovernate->getgovernoteId();
  1612.                             $response[$count]["parent_longitude"] = $muniGovernate->getLongitude();
  1613.                             $response[$count]["parent_latitude"] = $muniGovernate->getLatitude();
  1614.                             $response[$count]["parent_name_en"] = $muniGovernate->getName("en");
  1615.                             $response[$count]["parent_name_ar"] = $muniGovernate->getName("ar");
  1616.                         }
  1617.                     }
  1618.                 }
  1619.                 $count++;
  1620.             }
  1621.         }
  1623.         // Determine sorting field based on language
  1624.         $sortField = 'nameEn'; // Default sorting by English
  1625.         if (isset($params['lang']) && strtolower($params['lang']) === 'ar') {
  1626.             $sortField = 'nameAr'; // Sorting by Arabic
  1627.         }
  1629.         // Sort manually using usort()
  1630.         usort($response, function ($a, $b) use ($sortField) {
  1631.             return strcmp($a[$sortField], $b[$sortField]);
  1632.         });
  1634.         return ["success" => true, "data" => $response];
  1635.     }
  1637.     public function getGovernoratesByParams($params)
  1638.     {
  1639.         $response = [];
  1641.         $governorates = new DataObject\Governorate\Listing();
  1643.         if (isset($params['region_id'])) {
  1644.             $region = \Pimcore\Model\DataObject\Region::getByRegionId($params['region_id'], true);
  1645.             if (!$region) {
  1646.                 throw new \Exception("Region not available");
  1647.             }
  1648.             $governorates->filterByRegionId($region);
  1649.         }
  1651.         if (isset($params['region_ids']) && !empty($params['region_ids'])) {
  1652.             $regionIds = [];
  1653.             $regionList = new DataObject\Region\Listing();
  1654.             $regionList->addConditionParam("regionId IN (?)", [$params['region_ids']]);
  1655.             foreach ($regionList as $region) {
  1656.                 $regionIds[] = $region->getId();
  1657.             }
  1658.             $governorates->addConditionParam("regionId__id IN (?)", [$regionIds]);
  1659.         }
  1660.         if (isset($params['search'])) {
  1661.             $governorates->addConditionParam("name LIKE ?", "%{$params['search']}%");
  1662.         }
  1663.         // Load governorates without sorting in Pimcore
  1664.         $governorates = $governorates->load();
  1666.         // Convert to array for manual sorting
  1667.         $count = 0;
  1668.         if ($governorates) {
  1669.             foreach ($governorates as $governorate) {
  1670.                 $region = $governorate->getregionId();
  1671.                 $regionData = [];
  1672.                 if (!empty($region)) {
  1673.                     $regionData = [
  1674.                         "id" => $region->getRegionId(),
  1675.                         "nameEn" => $region->getName('en'),
  1676.                         "nameAr" => $region->getName('ar'),
  1677.                         "longitude" => $region->getLongitude(),
  1678.                         "latitude" => $region->getLatitude()
  1680.                     ];
  1681.                 }
  1682.                 $response[$count] = [
  1683.                     "id" => $governorate->getgovernoteId(),
  1684.                     "nameEn" => $governorate->getName('en'),
  1685.                     "nameAr" => $governorate->getName('ar'),
  1686.                     "regionId" => $regionData,
  1687.                     "longitude" => $governorate->getLongitude(),
  1688.                     "latitude" => $governorate->getLatitude(),
  1689.                     "isHidden" => $governorate->getisHidden(),
  1690.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  1691.                     "MunicipalityID" => $governorate->getMunicipalityID(),
  1692.                     "bbox" => $governorate->getBbox()
  1693.                 ];
  1695.                 if ($governorate->getMunicipalityID() && $governorate->getIsMunicipality()) {
  1696.                     $municipality = \Pimcore\Model\DataObject\Municipality::getBymunicipalityid($governorate->getMunicipalityID(), true);
  1697.                     if ($municipality) {
  1698.                         $muniGovernate = $municipality->getgovernorate();
  1699.                         if ($muniGovernate) {
  1700.                             $response[$count]["parent_id"] = $muniGovernate->getgovernoteId();
  1701.                             $response[$count]["parent_longitude"] = $muniGovernate->getLongitude();
  1702.                             $response[$count]["parent_latitude"] = $muniGovernate->getLatitude();
  1703.                             $response[$count]["parent_name_en"] = $muniGovernate->getName("en");
  1704.                             $response[$count]["parent_name_ar"] = $muniGovernate->getName("ar");
  1705.                         }
  1706.                     }
  1707.                 }
  1708.                 $count++;
  1709.             }
  1710.         }
  1712.         // Determine sorting field based on language
  1713.         $sortField = 'nameEn'; // Default sorting by English
  1714.         if (isset($params['lang']) && strtolower($params['lang']) === 'ar') {
  1715.             $sortField = 'nameAr'; // Sorting by Arabic
  1716.         }
  1718.         // Sort manually using usort()
  1719.         usort($response, function ($a, $b) use ($sortField) {
  1720.             return strcmp($a[$sortField], $b[$sortField]);
  1721.         });
  1723.         return ["success" => true, "data" => $response];
  1724.     }
  1725.     public function getVersions($notificationObject, $translator)
  1726.     {
  1727.         $result = [];
  1728.         $versions = $notificationObject->getVersions();
  1729.         if ($versions) {
  1730.             foreach ($versions as $version) {
  1731.                 $note = $version->getNote();
  1732.                 if ($note == "Update") {
  1733.                     $viewNotification = $version->loadData();
  1734.                     if ($viewNotification instanceof EwsNotification) {
  1735.                         $result[] = $this->createNotificationFormat($viewNotification, $translator);
  1736.                     }
  1737.                 }
  1738.             }
  1739.         }
  1741.         return $result;
  1742.     }
  1744.     private function createNotificationFormat($notification, $translator)
  1745.     {
  1746.         $response = [];
  1747.         $critetia = '';
  1748.         $critetiaAr = '';
  1749.         $status = 'active';
  1750.         $alertType = $notification->getAlertType();
  1751.         $phenomena = $notification->getWeatherPhenomenon();
  1752.         // Set the timezone to Asia/Riyadh
  1753.         $timezone = new \DateTimeZone(TIMEZONE);
  1754.         // Convert start and end dates to Asia/Riyadh timezone
  1755.         $startDate = $notification->getStartDate() ? $notification->getStartDate()->setTimezone($timezone) : null;
  1756.         $endDate = $notification->getEndDate() ? $notification->getEndDate()->setTimezone($timezone) : null;
  1757.         if ($alertType && $phenomena) {
  1758.             $phenomenaList = $alertType->getPhenomenaList();
  1759.             if ($phenomenaList) {
  1760.                 $items = $phenomenaList->getItems();
  1761.                 if ($items) {
  1762.                     foreach ($items as $item) {
  1763.                         if ($item->getPhenomena() == $phenomena->getId()) {
  1764.                             $critetia = $item->getCriteria();
  1765.                             $critetiaAr = $item->getCriteriaAr();
  1766.                             break;
  1767.                         }
  1768.                     }
  1769.                 }
  1770.             }
  1771.         }
  1772.         if ($endDate && $endDate < new \DateTime('now', $timezone)) {
  1773.             $status = "expired";
  1774.         }
  1775.         $twentyFourHoursAgo = (new \DateTime('now', $timezone))->modify('-24 hours');
  1776.         if ($endDate && $endDate < $twentyFourHoursAgo) {
  1777.             $status = "archived";
  1778.         }
  1779.         $response = [
  1780.             "id" => $notification->getId(),
  1781.             "searchEwsIdEn" => $notification->getEwsSearchId("en"),
  1782.             "searchEwsIdAr" => $notification->getEwsSearchId("ar"),
  1783.             "title" => $startDate ? $startDate->format("dmY") . '-' . $notification->getId() : '',
  1784.             "alertType" => !empty($notification->getAlertType()) ? $notification->getAlertType()->getAlertTypeId() : "",
  1785.             "alertTypeAr" => !empty($notification->getAlertType()) ? $notification->getAlertType()->getName("ar") : "",
  1786.             "alertTypeEn" => !empty($notification->getAlertType()) ? ucwords($notification->getAlertType()->getColor()) : "",
  1787.             "fromDate" => $startDate ? $startDate->format("Y-m-d H:i:s") : "",
  1788.             "toDate" => $endDate ? $endDate->format("Y-m-d H:i:s") : "",
  1789.             "alertStatusID" => !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getAlertStatusId() : "",
  1790.             "alertStatusAr" => !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName("ar") : "",
  1791.             "alertStatusEn" => !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName("en") : "",
  1792.             "alertStatusCategory" => "",
  1793.             "alertHazard" => !empty($notification->getAlertHazard()) ? $this->getAlertHazardArr($notification->getAlertHazard()) : [],
  1794.             "regionID" => !empty($notification->getRegion()) ? $notification->getRegion()->getRegionId() : "",
  1795.             "regionAR" => !empty($notification->getRegion()) ? $notification->getRegion()->getName("ar") : "",
  1796.             "regionEn" => !empty($notification->getRegion()) ? $notification->getRegion()->getName("en") : "",
  1797.             "governorates" => ($notification->getRegion()) ? $this->getGovernorateDetail($notification->getGovernorate()) : [],
  1798.             "ewsOtherLocations" => ($notification->getRegion()) ? $this->getGovernorateDetail($notification->getEwsOtherLocations()) : [],
  1799.             "otherLocationsAr" => $this->getOtherLocationsNames($notification->getEwsOtherLocations(), 'ar'),
  1800.             "otherLocationsEn" => $this->getOtherLocationsNames($notification->getEwsOtherLocations(), 'en'),
  1801.             "tweetID" => "",
  1802.             "enableTwitterNotification" => $notification->getEnableTwitterNotification(),
  1803.             "enableSMSNotification" => $notification->getEnableSMSNotification(),
  1804.             "enableEmailNotification" => $notification->getEnableEmailNotification(),
  1805.             "alertActions" => $this->getAlertActionsByArr($notification->getAlertAction()),
  1806.             "municipalities" => $this->getMunicipalityArr($notification->getMunicipality()),
  1807.             "lastModified" => ($notification->getModificationDate()) ? date("Y-m-d H:i:s", $notification->getModificationDate()) : "",
  1808.             "last_modified_date" => ($notification->getModificationDate()) ? date("Y-m-d", $notification->getModificationDate()) : "",
  1809.             'coordinates' => $notification->getCoordinates(),
  1810.             'message' => $notification->getMessage("en"),
  1811.             "file" => (!empty($notification->getAttachment())) ? API_BASE_URL . $notification->getAttachment()->getFullPath() : [],
  1812.             'criteria' => $critetia,
  1813.             'criteriaAr' => $critetiaAr,
  1814.             'created_at' => ($notification->getCreationDate()) ? date("Y-m-d H:i:s", $notification->getCreationDate()) : "",
  1815.             'created_by' => ($notification->getUser()) ? $notification->getUser()->getName() : "",
  1816.             'edited_by' => ($notification->getEditor()) ? $notification->getEditor()->getName() : (($notification->getUser()) ? $notification->getUser()->getName() : ""),
  1817.             'status_en' => ucfirst($status),
  1818.             'status_ar' => $translator->trans(ucfirst($status), [], null, 'ar'),
  1819.             'previewText' => $notification->getPreviewText() ?? false,
  1820.         ];
  1821.         return $response;
  1822.     }
  1824.     private function getAlertHazardArr($alertHazardArr)
  1825.     {
  1826.         $result = [];
  1827.         if ($alertHazardArr) {
  1828.             foreach ($alertHazardArr as $affect) {
  1829.                 $result[] = [
  1830.                     "pim_id" => $affect->getId(),
  1831.                     "id" => $affect->getAlertHazardId(),
  1832.                     "nameEn" => $affect->getName("en"),
  1833.                     "nameAr" => $affect->getName("ar"),
  1834.                 ];
  1835.             }
  1836.         }
  1838.         return $result;
  1839.     }
  1841.     private function getAlertActionsByArr($alertActions)
  1842.     {
  1843.         $result = [];
  1844.         if ($alertActions) {
  1845.             foreach ($alertActions as $alert) {
  1846.                 $result[] = [
  1847.                     "pim_id" => $alert->getId(),
  1848.                     "id" => $alert->getAlertActionId(),
  1849.                     "descriptionEn" => $alert->getName("en"),
  1850.                     "descriptionAr" => $alert->getName("ar"),
  1851.                 ];
  1852.             }
  1853.         }
  1855.         return $result;
  1856.     }
  1858.     private function getMunicipalityArr($municipalities)
  1859.     {
  1860.         $result = [];
  1861.         if ($municipalities) {
  1862.             foreach ($municipalities as $municipality) {
  1863.                 // p_R($municipality->getName());                
  1864.                 $result[] = [
  1865.                     "id" => $municipality->getMunicipalityId(),
  1866.                     "nameEn" => $municipality->getName("en"),
  1867.                     "nameAr" => $municipality->getName("ar"),
  1868.                     "governate" => $municipality->getGovernorate()->getGovernoteId()
  1869.                 ];
  1870.             }
  1871.         }
  1873.         return $result;
  1874.     }
  1876.     private function getOtherLocationsNames($otherLocations, $lang = 'ar')
  1877.     {
  1878.         $names = []; // Step 1: Initialize an array to hold the names
  1880.         if ($otherLocations) {
  1882.             foreach ($otherLocations as $otherLocation) {
  1883.                 $names[] = $otherLocation->getName($lang); // Step 2 & 3: Extract and collect names
  1884.             }
  1885.         }
  1886.         if (empty($names)) { // Check if the names array is empty
  1887.             return ''; // Return an empty string if there are no names
  1888.         }
  1890.         $namesString = implode(', ', $names); // Step 4: Convert the array to a comma-separated string
  1892.         return $namesString; // Return or use the comma-separated string as needed
  1893.     }
  1895.     public function publishedEwsNotification($notificationId, $published, $userGroupIds, $translator, $emailService, $templating, $logger)
  1896.     {
  1897.         $result = [];
  1900.         $viewNotification = DataObject\EwsNotification::getById($notificationId, false);
  1902.         if (!$viewNotification) {
  1903.             $viewNotification = DataObject\EwsNotification::getById($notificationId, true);
  1904.         }
  1905.         if ($published) {
  1906.             $viewNotification->setStatus("active");
  1907.         } else {
  1908.             $viewNotification->setStatus("");
  1909.         }
  1910.         $viewNotification->setPublished($published);
  1912.         //set ews search Id
  1913.         $currentDate = new \DateTime();
  1914.         $formattedDate = $currentDate->format('dmY') . '-' . $viewNotification->getId();
  1915.         $searchIdEn = 'Early Warning System | ' . $formattedDate . ' | ' . ucfirst($viewNotification->getAlertType()?->getColor()) . ' Alert | ' . $viewNotification->getWeatherPhenomenon()?->getTitle("en");
  1916.         $searchIdAr = $translator->trans('Early Warning System', [], null, "ar") . ' | ' . $formattedDate . ' | ' . $translator->trans(ucfirst($viewNotification->getAlertType()?->getColor()) . ' Alert', [], null, "ar") . ' | ' . $viewNotification->getWeatherPhenomenon()?->getTitle("ar");
  1917.         $viewNotification->setEwsSearchId($searchIdEn, "en");
  1918.         $viewNotification->setEwsSearchId($searchIdAr, "ar");
  1919.         $viewNotification->save(["versionNote" => "Update"]);
  1921.         $viewNotification->save();
  1923.         // $alert = $this->createNotificationFormat($viewNotification, $translator);
  1925.         if ($published) {
  1926.             // Ensure you use 'php' to execute the command.
  1927.             $jsonUserGroupIds = json_encode($userGroupIds);
  1928.             $process = new Process(['php', 'bin/console', 'app:send-early-warning-alert-email', '--alertId=' . $viewNotification->getId(), '--userGroupIds=' . $jsonUserGroupIds]);
  1929.             $process->setWorkingDirectory(PIMCORE_PROJECT_ROOT);
  1931.             try {
  1932.                 $process->mustRun();
  1933.                 $result['success'] = true;
  1934.                 $logger->info("published EwsNotification command executed successfully: " . $process->getOutput());
  1935.                 $result['message'] = $process->getOutput();
  1936.             } catch (ProcessFailedException $exception) {
  1937.                 $logger->error("published EwsNotification command failed: " . $exception->getMessage());
  1938.                 return ['success' => false, 'message' => $exception->getMessage()];
  1939.             }
  1940.         }
  1942.         return ["success" => true, "message" => $translator->trans("ews_notification_published")];
  1943.     }
  1945.     public function reportEwsNotification($param, $translator)
  1946.     {
  1947.         $result = [];
  1948.         $region = null;
  1949.         try {
  1950.             $listing = new EwsNotification\Listing();
  1951.             $reportType = isset($param['report_type']) ? $param['report_type'] : null;
  1952.             $regionId = isset($param['region_id']) ? $param['region_id'] : null;
  1953.             if ($regionId) {
  1954.                 $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  1955.                 if (!$region) {
  1956.                     throw new \Exception("Region not exists");
  1957.                 }
  1958.             }
  1960.             switch ($reportType) {
  1961.                 case 'published_in_week':
  1962.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 week"));
  1963.                     break;
  1964.                 case 'published_in_day':
  1965.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 day"));
  1966.                     break;
  1967.                 case 'published_in_month':
  1968.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 month"));
  1969.                     break;
  1970.                 case 'published_in_year':
  1971.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 year"));
  1972.                     break;
  1973.                 case 'published_in_region':
  1974.                     $listing->setCondition("o_published = true AND region__id = ?", [$region->getId()]);
  1975.                     break;
  1976.                 case 'published_in_draft':
  1977.                     $listing->setCondition("o_published = false");
  1978.                     break;
  1979.                 default:
  1980.                     throw new \Exception("Invalid request");
  1981.                     break;
  1982.             }
  1984.             $result['count'] = $listing->getCount();
  1985.             $notifications = $listing->load();
  1986.             if ($notifications) {
  1987.                 foreach ($notifications as $notification) {
  1988.                     $result['data'][] = $this->createNotificationFormat($notification, $translator);
  1989.                 }
  1990.             }
  1991.             return $result;
  1992.         } catch (\Exception $ex) {
  1993.             return new \Exception($ex->getMessage());
  1994.         }
  1996.         return $result;
  1997.     }
  1999.     private function sendEmailNotification($users, $alert, $emailService, $templating)
  2000.     {
  2001.         $mailSent = null;
  2002.         if ($alert) {
  2003.             $governatesArr = $alert['governorates'];
  2004.             $governates = [];
  2005.             if ($governatesArr) {
  2006.                 foreach ($governatesArr as $gov) {
  2007.                     $governates[] = $gov['nameEn'];
  2008.                 }
  2009.             }
  2011.             $data = $alert;
  2012.             $data['sender'] = 'National Center for Meteorology';
  2013.             //$subject = $alert['searchEwsIdAr'] ??'Severe Weather Alert - ' . $gov['nameEn'];
  2014.             // $subject = $alert['alertStatusAr'] . ' - ' . $alert['regionAR'];
  2015.             // $subject = 'النظام Ø§Ù„الي Ù„لإنذار Ø§Ù„مبكر :' . ' - ' . $alert['searchEwsIdAr'];
  2016.             $parts = explode('|', $alert['searchEwsIdAr']);
  2017.             $excluded = implode('|', array_slice($parts, 1));
  2018.             $subject = 'النظام Ø§Ù„الي Ù„لإنذار Ø§Ù„مبكر :'  . $excluded;
  2023.             // $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $data);
  2025.             //sending an email document (pimcore document)
  2026.             // $emailAlertTemplate = '/email/alert_notification';
  2028.             if ($users) {
  2029.                 foreach ($users as $currentUser) {
  2031.                     if (isset($alert['enableEmailNotification']) && $alert['enableEmailNotification']) {
  2033.                         if ($currentUser->getSendEwsEmail() || is_null($currentUser->getSendEwsEmail())) {
  2034.                             # code...
  2037.                             // $email = $currentUser->getEmail();
  2038.                             // $param = ['user' => $currentUser, 'message' => $html, 'url' => null];
  2039.                             // $mailSent = $emailService->sendMail($param, $email, $emailAlertTemplate, $subject);
  2040.                             // $data['name'] = $user->getName();
  2042.                             // extra param js
  2043.                             $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  2044.                             $alertName = $alertObj->getColor() ? $alertObj->getColor() : '';
  2046.                             $alert['user_name'] = $currentUser->getName();
  2047.                             $alert['host'] = API_BASE_URL;
  2048.                             $alert['alertColor'] = $alertName;
  2050.                             $backgroundColor = '#fcb82526';
  2051.                             $borderColor = '#000000';
  2052.                             $textColor = '#000000';
  2054.                             // unsubscribe ews notificaiton token
  2055.                             $tokenURL = '';
  2056.                             $token = $this->userModel->unSubscribeEwsGenerateToken($currentUser->getEmail());
  2057.                             if (!empty($token)) {
  2058.                                 $tokenURL = BASE_URL . '/unsubscribe/notification?ews=true&token=' . $token;
  2059.                             }
  2062.                             if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  2063.                                 $alertColorLower = strtolower(trim($alert['alertColor']));
  2065.                                 if ($alertColorLower === 'red') {
  2066.                                     $backgroundColor = '#f6000017';
  2067.                                     $borderColor = '#F60000';
  2068.                                     $textColor = '#F60000';
  2069.                                 } elseif ($alertColorLower === 'orange') {
  2070.                                     $backgroundColor = '#ff66001f';
  2071.                                     $borderColor = '#FF6600';
  2072.                                     $textColor = '#FF6600';
  2073.                                 } elseif ($alertColorLower === 'yellow') {
  2074.                                     $backgroundColor = '#fcb82526';
  2075.                                     $borderColor = '#FCB825';
  2076.                                     $textColor = '#FCB825';
  2077.                                 }
  2078.                             }
  2079.                             $purpose = EWS_MESSAGE;
  2080.                             $alert['backgroundColor'] = $backgroundColor;
  2081.                             $alert['borderColor'] = $borderColor;
  2082.                             $alert['textColor'] = $textColor;
  2083.                             $alert['tokenURL'] = $tokenURL;
  2084.                             $alert['mannedAlertDatailUrl'] = null;
  2085.                             $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  2086.                             $mailSent = $this->c2Service->sendNotificationEmail($_ENV['EWS_MAIL_TEMPLATE'], $alert['id'], $currentUser->getId(), $html, $subject, $purpose);
  2088.                             // $this->c2Service->sendMannedAlertEmails($html,$currentUser->getId(),$alert['id']);
  2089.                             // $mailSent=$this->c2Service->sendMannedAlertEmails($html,$currentUser->getId(),$alert['id'],$subject);
  2090.                             if ($mailSent) {
  2091.                                 $status = "sent";
  2092.                                 $this->saveEmailStatus($currentUser->getEmail(), $currentUser->getName(), $alert, $status);
  2093.                             } else {
  2094.                                 $status = "not sent";
  2095.                                 $this->saveEmailStatus($currentUser->getEmail(), $currentUser->getName(), $alert, $status);
  2096.                             }
  2097.                         }
  2098.                     }
  2099.                 }
  2100.             }
  2101.         }
  2103.         return $mailSent;
  2104.     }
  2106.     private function sendExcelEmailNotification($userGroupIds, $alert, $emailService, $templating)
  2107.     {
  2108.         $mailSent = null;
  2109.         if ($alert) {
  2110.             $governatesArr = $alert['governorates'];
  2111.             $governates = [];
  2112.             if ($governatesArr) {
  2113.                 foreach ($governatesArr as $gov) {
  2114.                     $governates[] = $gov['nameEn'];
  2115.                 }
  2116.             }
  2118.             $data = $alert;
  2119.             $data['sender'] = 'National Center for Meteorology';
  2120.             // $subject = $alert['searchEwsIdAr'] ??'Severe Weather Alert - ' . $gov['nameEn'];
  2121.             //$subject = $alert['alertStatusAr'] . ' - ' . $alert['regionAR'];
  2122.             // $subject = 'النظام Ø§Ù„الي Ù„لإنذار Ø§Ù„مبكر :' . ' - ' . $alert['searchEwsIdAr'];
  2124.             $parts = explode('|', $alert['searchEwsIdAr']);
  2125.             $excluded = implode('|', array_slice($parts, 1));
  2126.             $subject = 'النظام Ø§Ù„الي Ù„لإنذار Ø§Ù„مبكر :'  . $excluded;
  2129.             if ($userGroupIds) {
  2131.                 foreach ($userGroupIds as $userGroupId) {
  2132.                     if ($userGroupId) {
  2134.                         $userGroup = \Pimcore\Model\DataObject\EwsAndReportUserGroup::getById($userGroupId, true);
  2135.                         if ($userGroup instanceof \Pimcore\Model\DataObject\EwsAndReportUserGroup) {
  2137.                             foreach (json_decode($userGroup->getJsonData()) as $currentUser) {
  2139.                                 if (isset($currentUser->firstName) && isset($currentUser->lastName) && isset($currentUser->email)) {
  2141.                                     // extra param js
  2142.                                     $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  2143.                                     $alertName = $alertObj->getColor() ? $alertObj->getColor() : '';
  2145.                                     $alert['user_name'] = $currentUser->firstName . ' ' . $currentUser->lastName;
  2146.                                     $alert['host'] = API_BASE_URL;
  2147.                                     $alert['alertColor'] = $alertName;
  2149.                                     $backgroundColor = '#fcb82526';
  2150.                                     $borderColor = '#000000';
  2151.                                     $textColor = '#000000';
  2153.                                     if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  2154.                                         $alertColorLower = strtolower(trim($alert['alertColor']));
  2156.                                         if ($alertColorLower === 'red') {
  2157.                                             $backgroundColor = '#f6000017';
  2158.                                             $borderColor = '#F60000';
  2159.                                             $textColor = '#F60000';
  2160.                                         } elseif ($alertColorLower === 'orange') {
  2161.                                             $backgroundColor = '#ff66001f';
  2162.                                             $borderColor = '#FF6600';
  2163.                                             $textColor = '#FF6600';
  2164.                                         } elseif ($alertColorLower === 'yellow') {
  2165.                                             $backgroundColor = '#fcb82526';
  2166.                                             $borderColor = '#FCB825';
  2167.                                             $textColor = '#FCB825';
  2168.                                         }
  2169.                                     }
  2171.                                     $alert['backgroundColor'] = $backgroundColor;
  2172.                                     $alert['borderColor'] = $borderColor;
  2173.                                     $alert['textColor'] = $textColor;
  2174.                                     $alert['tokenURL'] = null;
  2175.                                     $alert['mannedAlertDatailUrl'] = null;
  2176.                                     $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  2178.                                     // $email = $currentUser->email;
  2179.                                     // $param = ['user' => $currentUser, 'message' => $html, 'url' => null];
  2180.                                     // $mailSent = $emailService->sendMail($param, "abdul.muqeet@centric.ae", '/email/alert_notification', $subject);
  2181.                                     $purpose = EWS_MESSAGE;
  2182.                                     $mailSent = $this->c2Service->sendDefaultEmail($_ENV['EWS_MAIL_TEMPLATE'], $alert['id'], $currentUser->email, $html, $subject, $purpose);
  2184.                                     if ($mailSent) {
  2185.                                         $status = "sent";
  2186.                                         $this->saveEmailStatus($currentUser->email, $currentUser->firstName . ' ' . $currentUser->lastName, $alert, $status);
  2187.                                     } else {
  2188.                                         $status = "not sent";
  2189.                                         $this->saveEmailStatus($currentUser->email, $currentUser->firstName . ' ' . $currentUser->lastName, $alert, $status);
  2190.                                     }
  2191.                                 }
  2192.                             }
  2193.                         }
  2194.                     }
  2195.                 }
  2196.             }
  2197.         }
  2199.         return $mailSent;
  2200.     }
  2202.     private function saveEmailStatus($userEmail, $userName, $alert, $emailStatus)
  2203.     {
  2205.         // Get all governorates names in string seprated by ,
  2206.         $nameEnArray = array_column($alert["governorates"], "nameEn");
  2207.         $nameEnString = implode(", ", $nameEnArray);
  2209.         $nameArArray = array_column($alert["governorates"], "nameAr");
  2210.         $nameArString = implode(", ", $nameArArray);
  2212.         $ewsEmailStatus = new FetchSentEwsEmail();
  2213.         $ewsEmailStatus->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Other/FetchSentEwsEmail/"));
  2214.         $ewsEmailStatus->setKey(\Pimcore\Model\Element\Service::getValidKey($userEmail . "-" . strtotime("now") . "-" . rand(1, 10000), 'object'));
  2215.         $ewsEmailStatus->setEwsId($alert['id']);
  2216.         $ewsEmailStatus->setUserName($userName);
  2217.         $ewsEmailStatus->setEmail($userEmail);
  2218.         //$ewsEmailStatus->setLocationName($locationName);
  2219.         $ewsEmailStatus->setAlertType($alert['alertTypeEn'], 'en');
  2220.         $ewsEmailStatus->setAlertType($alert['alertTypeAr'], 'ar');
  2221.         $ewsEmailStatus->setAlertStatus($alert['alertStatusEn'], 'en');
  2222.         $ewsEmailStatus->setAlertStatus($alert['alertStatusAr'], 'ar');
  2223.         $ewsEmailStatus->setRegionName($alert['regionEn'], 'en');
  2224.         $ewsEmailStatus->setRegionName($alert['regionAR'], 'ar');
  2225.         $ewsEmailStatus->setGovernorateNames($nameEnString, 'en');
  2226.         $ewsEmailStatus->setGovernorateNames($nameArString, 'ar');
  2227.         $ewsEmailStatus->setStatus($emailStatus);
  2228.         $ewsEmailStatus->setPublished(true);
  2229.         $ewsEmailStatus->save();
  2231.         return $ewsEmailStatus;
  2232.     }
  2234.     public function getEwsNotificationEmailStatus($params, $paginator, $translator)
  2235.     {
  2236.         $result = [];
  2237.         try {
  2238.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  2239.             $page = isset($params['page']) ? $params['page'] : 1;
  2241.             $notificationId = $params["id"] ? $params["id"] : null;
  2242.             $listing = new FetchSentEwsEmail\Listing();
  2243.             $listing->setCondition("ewsId = ? ", [$notificationId]);
  2245.             $paginator = $paginator->paginate(
  2246.                 $listing,
  2247.                 $page,
  2248.                 $pageSize
  2249.             );
  2251.             if ($paginator->count() > 0) {
  2252.                 foreach ($paginator as $EwsNotificationEmail) {
  2253.                     $result[] = [
  2254.                         "ewsId" => $EwsNotificationEmail->getEwsId(),
  2255.                         "userName" => $EwsNotificationEmail->getUserName(),
  2256.                         "Email" => $EwsNotificationEmail->getEmail(),
  2257.                         "locationName" => $EwsNotificationEmail->getLocationName(),
  2258.                         "alertType" => $EwsNotificationEmail->getAlertType('en'),
  2259.                         "alertTypeAr" => $EwsNotificationEmail->getAlertType('ar'),
  2260.                         "alertStatus" => $EwsNotificationEmail->getAlertStatus('en'),
  2261.                         "alertStatusAr" => $EwsNotificationEmail->getAlertStatus('ar'),
  2262.                         "regionName" => $EwsNotificationEmail->getRegionName('en'),
  2263.                         "regionNameAr" => $EwsNotificationEmail->getRegionName('ar'),
  2264.                         "governorateNames" => explode(",", $EwsNotificationEmail->getGovernorateNames('en')),
  2265.                         "governorateNamesAr" => explode(",", $EwsNotificationEmail->getGovernorateNames('ar')),
  2266.                         "emailStatus" => $EwsNotificationEmail->getStatus(),
  2267.                         "emailStatusAr" => $translator->trans($EwsNotificationEmail->getStatus(), [], null, "ar"),
  2268.                     ];
  2269.                 }
  2270.             }
  2272.             return ["success" => TRUE, "data" => $result, "paginationVariables" => $paginator->getPaginationData()];
  2273.         } catch (\Exception $ex) {
  2274.             return new \Exception($ex->getMessage());
  2275.         }
  2277.         return $result;
  2278.     }
  2280.     public function getOtherLocations()
  2281.     {
  2282.         $response = [];
  2283.         $otherLocations = new DataObject\OtherLocation\Listing();
  2284.         $otherLocations = $otherLocations->load();
  2285.         if ($otherLocations) {
  2286.             foreach ($otherLocations as $otherLocation) {
  2287.                 $response[] = [
  2288.                     "id" => $otherLocation->getOtherLocationId(),
  2289.                     "nameEn" => $otherLocation->getName('en'),
  2290.                     "nameAr" => $otherLocation->getName('ar')
  2291.                 ];
  2292.             }
  2293.         }
  2294.         return ["success" => true, "data" => $response];
  2295.     }
  2297.     public function getEwsNotificationByByRegionName($regionName)
  2298.     {
  2299.         $db = Db::get();
  2300.         $selectedLocalities = $db->fetchAll("SELECT * FROM `object_collection_AddressComponents_location` WHERE (`addressKey` = 'locality' || `addressKey` = 'administrative_area_level_1') and (TRIM(REPLACE(`addressValue`,'Province','')) = '" . $regionName . "')");
  2301.         return $selectedLocalities;
  2302.     }
  2304.     public function ewsAnalytics($params, $connection, $lang): array
  2305.     {
  2306.         $response = [];
  2308.         $status = isset($params['status']) ? $params['status'] : "";
  2310.         $isManned = null;
  2311.         if (isset($params['isManned']) && $params['isManned'] == true) {
  2312.             $isManned = true;
  2313.         } elseif (isset($params['isManned']) && $params['isManned'] == false) {
  2314.             $isManned = false;
  2315.         }
  2318.         if (isset($params['region']) && !empty($params['region'])) {
  2319.             $region = Region::getByRegionId($params['region'], true);
  2320.             $response[] = $this->ewsAnalyticsCount($region, $status, $connection, $lang, $isManned);
  2321.         } else {
  2322.             $regions = new Region\Listing();
  2323.             foreach ($regions as $region) {
  2324.                 $response[] = $this->ewsAnalyticsCount($region, $status, $connection, $lang, $isManned);
  2325.             }
  2326.         }
  2328.         return $response;
  2329.     }
  2331.     public function ewsAnalyticsCount($region, $status, $connection, $lang, $isManned)
  2332.     {
  2333.         $regionNameEn = $region->getName("en");
  2334.         $regionNameAr = $region->getName("ar");
  2336.         $statuses = ["active", "archived", "expired"];
  2337.         $count = ['regionEn' => $regionNameEn, "regionAr" => $regionNameAr];
  2339.         if (in_array($status, $statuses)) {
  2340.             $count[$status] = $this->getStatusData($region, $status, $connection, $isManned);
  2341.         } else {
  2342.             foreach ($statuses as $s) {
  2343.                 $count[$s] = $this->getStatusData($region, $s, $connection, $isManned);
  2344.             }
  2345.         }
  2347.         return $count;
  2348.     }
  2350.     public function getStatusData($region, $status, $connection, $isManned)
  2351.     {
  2352.         $totalNotifications = $this->statusCount($region, $status, $isManned);
  2353.         $alertTypeCount = $this->alertCount($region, $status, $connection, $isManned);
  2355.         return [
  2356.             'total_notifications' => $totalNotifications,
  2357.             'alert_type_count' => $alertTypeCount,
  2358.         ];
  2359.     }
  2361.     public function alertCount($region, $status, $connection, $isManned)
  2362.     {
  2363.         $currentTimestamp = time(); // Current UNIX timestamp
  2364.         $twentyFourHoursAgoTimestamp = strtotime('-24 hours'); // 24 hours ago timestamp
  2366.         $claim_report_sql = $connection->createQueryBuilder();
  2368.         $claim_report_sql
  2369.             ->select('oa.Color AS color', 'COUNT(oq.oo_id) AS count')
  2370.             ->from('object_ews_notification', 'oq')
  2371.             ->join('oq', 'object_query_alert_type', 'oa', 'oq.alertType__id = oa.oo_id')
  2372.             ->andWhere('oq.region__id = :regionId')
  2373.             ->andWhere('oq.status = :status');
  2374.         if ($isManned !== null && $isManned == true) {
  2375.             $claim_report_sql->andWhere('oq.isManned = 1');
  2376.         } elseif ($isManned !== null && $isManned == false) {
  2377.             $claim_report_sql->andWhere('oq.isManned = 0');
  2378.         }
  2380.         $claim_report_sql->andWhere('oq.o_published = 1'); // added new line
  2383.         // Initialize parameters array
  2384.         $params = [
  2385.             'regionId' => $region->getId(),
  2386.             'status' => $status,
  2387.         ];
  2389.         // Add conditions based on status
  2390.         if ($status == "active") {
  2391.             $claim_report_sql->andWhere('oq.endDate > :currentTimestamp');
  2392.             $params['currentTimestamp'] = $currentTimestamp;
  2393.         } else if ($status == "expired") {
  2394.             $claim_report_sql->andWhere('oq.endDate < :currentTimestamp AND oq.endDate > :twentyFourHoursAgoTimestamp');
  2395.             $params['currentTimestamp'] = $currentTimestamp;
  2396.             $params['twentyFourHoursAgoTimestamp'] = $twentyFourHoursAgoTimestamp;
  2397.         } else if ($status == "archived") {
  2398.             $claim_report_sql->andWhere('oq.endDate < :twentyFourHoursAgoTimestamp');
  2399.             $params['twentyFourHoursAgoTimestamp'] = $twentyFourHoursAgoTimestamp;
  2400.         }
  2402.         // Set all parameters at once
  2403.         $claim_report_sql->setParameters($params);
  2405.         $claim_report_sql->groupBy('color');
  2407.         $claimReportstmt = $claim_report_sql->execute();
  2408.         $results = $claimReportstmt->fetchAllAssociative();
  2410.         // Fetch all possible colors
  2411.         $alertTypes = new AlertType\Listing();
  2412.         $allColors = [];
  2413.         foreach ($alertTypes as $alertType) {
  2414.             if ($alertType) {
  2415.                 $allColors[] = $alertType->getColor();
  2416.             }
  2417.         }
  2419.         if (empty($allColors)) {
  2420.             $allColors = ["yellow", "orange", "red"];
  2421.         }
  2423.         // Create an associative array to store counts by color
  2424.         $countsByColor = [];
  2425.         foreach ($results as $result) {
  2426.             $countsByColor[$result['color']] = $result['count'];
  2427.         }
  2429.         // Merge counts for existing colors with counts for all colors, including those with count 0
  2430.         $finalResult = [];
  2431.         foreach ($allColors as $color) {
  2432.             $finalResult[] = [
  2433.                 "color" => $color,
  2434.                 "count" => isset($countsByColor[$color]) ? $countsByColor[$color] : 0
  2435.             ];
  2436.         }
  2438.         return $finalResult;
  2439.     }
  2443.     public function statusCount($region, $status, $isManned)
  2444.     {
  2445.         $notifications = new EwsNotification\Listing();
  2446.         $currentTimestamp = time(); // Get the current UNIX timestamp
  2447.         $twentyFourHoursAgoTimestamp = strtotime('-24 hours'); // 24 hours ago timestamp
  2449.         $conditions = "region__id = ? AND status = ?";
  2450.         $params = [$region->getId(), $status];
  2452.         if ($status == "active") {
  2453.             $conditions .= " AND endDate > ?";
  2454.             $params[] = $currentTimestamp;
  2455.         } else if ($status == "expired") {
  2456.             $conditions .= " AND endDate < ? AND endDate > ?";
  2457.             $params[] = $currentTimestamp;
  2458.             $params[] = $twentyFourHoursAgoTimestamp;
  2459.         } else if ($status == "archived") {
  2460.             $conditions .= " AND endDate < ?";
  2461.             $params[] = $twentyFourHoursAgoTimestamp;
  2462.         }
  2464.         $notifications->addConditionParam($conditions, $params);
  2466.         // Add condition for manned notifications
  2467.         if ($isManned !== null) {
  2468.             $notifications->addConditionParam("isManned = ?", [$isManned]);
  2469.         }
  2471.         return $notifications->count();
  2472.     }
  2474.     public function searchEwsNotification($params, $lang, $paginator, $translator): array
  2475.     {
  2476.         $response = [];
  2477.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  2478.         $page = isset($params['page']) ? $params['page'] : 1;
  2480.         $notificationList = new DataObject\EwsNotification\Listing();
  2481.         $notificationList->setUnpublished(true);
  2482.         $notificationList->filterByPublished(true);
  2484.         if (isset($params['isManned']) && $params['isManned'] == true) {
  2485.             $notificationList->addConditionParam("isManned = 1");
  2486.         } elseif (isset($params['isManned']) && $params['isManned'] == false) {
  2487.             $notificationList->addConditionParam("isManned = 0");
  2488.         }
  2491.         if (isset($params['id']) && !empty($params['id'])) {
  2492.             $idz = $params['id'];
  2493.             $notificationList->addConditionParam("oo_id IN (?)", [$idz]);
  2494.         }
  2495.         if (isset($params['alertAction']) && !empty($params['alertAction'])) {
  2496.             $alertActionIds = [];
  2497.             $alertActionList = new DataObject\AlertAction\Listing();
  2498.             $alertActionList->addConditionParam("alertActionId IN (?)", [$params['alertAction']]);
  2499.             foreach ($alertActionList as $alertAction) {
  2500.                 $alertActionIds[] = $alertAction->getId();
  2501.             }
  2502.             $alertActionids = implode(",", $alertActionIds);
  2503.             $notificationList->addConditionParam("alertAction REGEXP CONCAT('(^|,)(', REPLACE('$alertActionids',',', '|'), ')(,|$)')");
  2504.         }
  2505.         if (isset($params['alertType']) && !empty($params['alertType'])) {
  2506.             $alertTypeIds = [];
  2507.             $alertTypeList = new DataObject\AlertType\Listing();
  2508.             $alertTypeList->addConditionParam("alertTypeId IN (?)", [$params['alertType']]);
  2509.             foreach ($alertTypeList as $alertType) {
  2510.                 $alertTypeIds[] = $alertType->getId();
  2511.             }
  2512.             $notificationList->addConditionParam("alertType__id IN (?)", [$alertTypeIds]);
  2513.         }
  2514.         // if (isset($params['phenomena']) && !empty($params['phenomena'])) {
  2515.         //     $phenomenaIds = [];
  2516.         //     $phenomenaList = new DataObject\PhenomenaList\Listing();
  2517.         //     $phenomenaList->addConditionParam("phenomenalistid IN (?)", [$params['phenomena']]);
  2518.         //     foreach ($phenomenaList as $phenomena) {
  2519.         //         $phenomenaIds[] = $phenomena->getId();
  2520.         //     }
  2521.         //     $notificationList->addConditionParam("weatherPhenomenon__id IN (?)", [$phenomenaIds]);
  2522.         // }
  2524.         if (!empty($params['phenomena'])) {
  2525.             $alertStatusSql = null;
  2526.             foreach ($params['phenomena'] as $alertStatus) {
  2527.                 $alertStatus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($alertStatus, true);
  2528.                 if ($alertStatus) {
  2529.                     $alertStatusSql .= "alertStatus__id = " . $alertStatus->getId() . " OR ";
  2530.                 }
  2531.             }
  2532.             $notificationList->addConditionParam("(" . substr($alertStatusSql, 0, -3) . ")");
  2533.         }
  2535.         if (isset($params['region']) && !empty($params['region'])) {
  2536.             $regionIds = [];
  2537.             $regionList = new DataObject\Region\Listing();
  2538.             $regionList->addConditionParam("regionId IN (?)", [$params['region']]);
  2539.             foreach ($regionList as $region) {
  2540.                 $regionIds[] = $region->getId();
  2541.             }
  2542.             $notificationList->addConditionParam("region__id IN (?)", [$regionIds]);
  2543.         }
  2544.         if (isset($params['governate']) && !empty($params['governate'])) {
  2545.             $governatesIds = [];
  2546.             $governateList = new DataObject\Governorate\Listing();
  2547.             $governateList->addConditionParam("governoteId IN (?)", [$params['governate']]);
  2548.             foreach ($governateList as $governate) {
  2549.                 $governatesIds[] = $governate->getId();
  2550.             }
  2551.             $governatesIds = implode(",", $governatesIds);
  2552.             $notificationList->addConditionParam("governorate REGEXP CONCAT('(^|,)(', REPLACE('$governatesIds',',', '|'), ')(,|$)')");
  2553.         }
  2556.         if (isset($params['status'][0]) && !empty($params['status'][0])) {
  2557.             $currentTimestamp = time();
  2558.             $twentyFourHoursAgo = strtotime('-24 hours');
  2560.             if ($params['status'][0] == "active" && (!isset($params['status'][1]) || empty($params['status'][1]))) {
  2561.                 // Filter notifications with an end date in the future or equal to current time
  2562.                 $notificationList->filterByEndDate($currentTimestamp, ">=");
  2563.             } else if ($params['status'][0] == "expired" && (!isset($params['status'][1]) || empty($params['status'][1]))) {
  2564.                 // Filter notifications with an end date in the past, but not older than 24 hours
  2565.                 $notificationList->filterByEndDate($currentTimestamp, "<");
  2566.                 $notificationList->filterByEndDate($twentyFourHoursAgo, ">=");
  2567.             } else if ($params['status'][0] == "archived" && (!isset($params['status'][1]) || empty($params['status'][1]))) {
  2568.                 // Filter notifications with an end date older than 24 hours
  2569.                 $notificationList->filterByEndDate($twentyFourHoursAgo, "<");
  2570.             } else if (isset($params['status'][1]) && !empty($params['status'][1])) {
  2571.                 if (($params['status'][0] == "active" && $params['status'][1] == "expired") || ($params['status'][0] == "expired" && $params['status'][1] == "active")) {
  2572.                     // Filter notifications that are either active or expired
  2573.                     $notificationList->filterByEndDate($currentTimestamp, ">=");
  2574.                     $notificationList->filterByEndDate($twentyFourHoursAgo, ">=");
  2575.                 }
  2576.             }
  2577.         } else {
  2578.             // If no status is provided, return 0 records
  2579.             $notificationList->addConditionParam("1 = 0");
  2580.         }
  2582.         $notificationList->setLocale($lang);
  2583.         if (isset($params['searchId']) && !empty($params['searchId'])) {
  2584.             $notificationList->addConditionParam(
  2585.                 "(ewsSearchId LIKE ?)",
  2586.                 [
  2587.                     '%' . $params['searchId'] . '%'
  2588.                 ]
  2589.             );
  2590.         }
  2592.         if (isset($params['alertHazard']) && !empty($params['alertHazard'])) {
  2594.             $alertHazardIds = [];
  2595.             $alertHazardList = new DataObject\AlertHazard\Listing();
  2596.             $alertHazardList->addConditionParam("alertHazardId IN (?)", [$params['alertHazard']]);
  2597.             foreach ($alertHazardList as $alertHazard) {
  2598.                 $alertHazardIds[] = $alertHazard->getId();
  2599.             }
  2600.             $alertHazardIds = implode(",", $alertHazardIds);
  2601.             $notificationList->addConditionParam("alertHazard REGEXP CONCAT('(^|,)(', REPLACE('$alertHazardIds',',', '|'), ')(,|$)')");
  2602.         }
  2603.         if (isset($params['municipality']) && !empty($params['municipality'])) {
  2604.             $municipalityIds = [];
  2605.             $municipalityList = new DataObject\Municipality\Listing();
  2606.             $municipalityList->addConditionParam("municipalityid IN (?)", [$params['municipality']]);
  2607.             foreach ($municipalityList as $municipality) {
  2608.                 $municipalityIds[] = $municipality->getId();
  2609.             }
  2610.             $municipalityIds = implode(",", $municipalityIds);
  2611.             $notificationList->addConditionParam("municipality REGEXP CONCAT('(^|,)(', REPLACE('$municipalityIds',',', '|'), ')(,|$)')");
  2612.         }
  2613.         if (isset($params['startDate']) && !empty($params['startDate'])) {
  2614.             $notificationList->filterByStartDate(strtotime($params['startDate']), ">=");
  2615.         }
  2616.         if (isset($params['endDate']) && !empty($params['endDate'])) {
  2617.             $notificationList->filterByEndDate(strtotime($params['endDate']), "<=");
  2618.         }
  2620.         if (isset($params['fromDate']) && isset($params['toDate']) && !empty($params['fromDate']) && !empty($params['toDate'])) {
  2621.             $fromDate = new \DateTime($params['fromDate']);
  2622.             $toDate = new \DateTime($params['toDate']);
  2624.             // Ensure the dates are in the correct format
  2625.             $fromDateStr = strtotime($fromDate->format('Y-m-d H:i:s'));
  2626.             $toDateStr = strtotime($toDate->format('Y-m-d') . ' 23:59:59');
  2628.             $notificationList->addConditionParam(
  2629.                 "(o_creationDate >= ? AND o_creationDate <= ?)",
  2630.                 [$fromDateStr, $toDateStr]
  2631.             );
  2632.         }
  2635.         $notifications = $notificationList->load();
  2636.         $sortedData = [];
  2638.         foreach ($notifications as $notification) {
  2639.             $regionEn = $notification->getRegion()->getName("en"); // Assuming getRegion() is available
  2640.             $startDate = $notification->getStartDate()->format('Y-m-d H:i:s'); // Assuming getStartDate() returns a \DateTime
  2641.             $endDate = $notification->getEndDate()->format('Y-m-d H:i:s');
  2642.             $alertStatusEn = $notification->getWeatherPhenomenon()?->getTitle("en");
  2643.             $creationDate = $notification->getCreationDate(); // Assuming getCreationDate() returns a \DateTime
  2644.             $searchIdEn = $notification->getEwsSearchId("en");
  2645.             $searchIdAr = $notification->getEwsSearchId("ar");
  2646.             $title = $notification->getStartDate() ? $notification->getStartDate()->format("dmY") . '-' . $notification->getId() : '';
  2647.             $alertTypeEn = $notification->getAlertType()?->getName("en");
  2648.             $fromDate = $notification->getStartDate()->format('Y-m-d H:i:s');
  2649.             $toDate = $notification->getEndDate()->format('Y-m-d H:i:s');
  2650.             $region = $regionEn;
  2651.             $created_at = $notification->getCreationDate();
  2652.             $alertStatus = $alertStatusEn;
  2653.             $sortedData[] = [
  2654.                 'notification' => $notification,
  2655.                 'regionName' => $regionEn,
  2656.                 'alertStatus' => $alertStatusEn,
  2657.                 'startDate' => $startDate,
  2658.                 'endDate' => $endDate,
  2659.                 'creationDate' => $creationDate, // Add creation date to sorting criteria
  2660.                 'searchIdEn' => $searchIdEn,
  2661.                 'searchIdAr' => $searchIdAr,
  2662.                 'title' => $title,
  2663.                 'alertType' => $alertTypeEn,
  2664.                 'fromDate' => $fromDate,
  2665.                 'toDate' => $toDate,
  2666.                 'region' => $region,
  2667.                 'created_at' => $created_at,
  2668.                 'alertStatus' => $alertStatus
  2669.             ];
  2670.         }
  2672.         // Define default sort orders and detect if any sort parameter is provided
  2673.         $sortOrderRegion = $params['sortByRegion'] ?? null;
  2674.         $sortOrderStartDate = $params['sortByStartDate'] ?? null;
  2675.         $sortOrderEndDate = $params['sortByEndDate'] ?? null;
  2676.         $sortOrderAlertStatus = $params['sortByAlertStatus'] ?? null;
  2677.         $sortOrderSearchIdEn = $params['sortBySearchIdEn'] ?? null;
  2678.         $sortOrderSearchIdAr = $params['sortBySearchIdAr'] ?? null;
  2679.         $sortOrderCreatedAt = $params['sortByCreated'] ?? null;
  2680.         $sortOrderTitle = $params['sortByTitle'] ?? null;
  2681.         $sortOrderAlertType = $params['sortByAlertType'] ?? null;
  2682.         $sortOrderFromDate = $params['sortByFromDate'] ?? null;
  2683.         $sortOrderToDate = $params['sortByToDate'] ?? null;
  2684.         $sortOrderRegionNew = $params['sortByRegionNew'] ?? null;
  2685.         $sortOrderCreatedAtNew = $params['sortByCreatedAt'] ?? null;
  2686.         $sortOrderAlertStatusNew = $params['sortByAlertStatusNew'] ?? null;
  2687.         
  2688.         // Support for orderKey and order parameters (NEW - clean approach)
  2689.         $orderKey = $params['orderKey'] ?? null;
  2690.         $order = $params['order'] ?? 'asc';
  2691.         
  2692.         // Simple mapping for new fields
  2693.         $newFieldMapping = [
  2694.             'title' => 'sortOrderTitle',
  2695.             'alertType' => 'sortOrderAlertType',
  2696.             'fromDate' => 'sortOrderFromDate', 
  2697.             'toDate' => 'sortOrderToDate',
  2698.             'region' => 'sortOrderRegionNew',
  2699.             'created_at' => 'sortOrderCreatedAtNew',
  2700.             'alertStatus' => 'sortOrderAlertStatusNew'
  2701.         ];
  2702.         
  2703.         // Set the appropriate sort order variable
  2704.         if ($orderKey && isset($newFieldMapping[$orderKey])) {
  2705.             $variableName = $newFieldMapping[$orderKey];
  2706.             $$variableName = $order;
  2707.         }
  2708.         
  2709.         // Check if any sort parameter is provided (OLD + NEW)
  2710.         $anySortParamProvided = $sortOrderRegion || $sortOrderStartDate || $sortOrderEndDate || $sortOrderAlertStatus || $sortOrderSearchIdEn || $sortOrderSearchIdAr || $sortOrderTitle || $sortOrderAlertType || $sortOrderFromDate || $sortOrderToDate || $sortOrderRegionNew || $sortOrderCreatedAtNew || $sortOrderAlertStatusNew;
  2711.         usort($sortedData, function ($a, $b) use ($sortOrderRegion, $sortOrderStartDate, $sortOrderEndDate, $sortOrderAlertStatus, $sortOrderSearchIdEn, $sortOrderSearchIdAr, $sortOrderCreatedAt, $sortOrderTitle, $sortOrderAlertType, $sortOrderFromDate, $sortOrderToDate, $sortOrderRegionNew, $sortOrderCreatedAtNew, $sortOrderAlertStatusNew, $anySortParamProvided) {
  2712.             if (!$anySortParamProvided || $sortOrderCreatedAt) {
  2713.                 if ($sortOrderCreatedAt == null) {
  2714.                     $sortOrderCreatedAt = "desc";
  2715.                 }
  2716.                 // Default to sorting by creation date if no sort parameter is provided
  2717.                 $compareCreatedAt = strcmp($a['creationDate'], $b['creationDate']) * ($sortOrderCreatedAt === 'desc' ? -1 : 1);
  2718.                 if ($compareCreatedAt !== 0) return $compareCreatedAt; // Assuming 'asc' as default sort order for creation date
  2719.             }
  2720.             // Else, sort based on the provided parameters
  2721.             if ($sortOrderRegion) {
  2722.                 $compareRegion = strcmp($a['regionName'], $b['regionName']) * ($sortOrderRegion === 'desc' ? -1 : 1);
  2723.                 if ($compareRegion !== 0) return $compareRegion;
  2724.             }
  2725.             if ($sortOrderSearchIdEn) {
  2726.                 $compareSearchIdEn = strcmp($a['searchIdEn'], $b['searchIdEn']) * ($sortOrderSearchIdEn === 'desc' ? -1 : 1);
  2727.                 if ($compareSearchIdEn !== 0) return $compareSearchIdEn;
  2728.             }
  2729.             if ($sortOrderSearchIdAr) {
  2730.                 $compareSearchIdAr = strcmp($a['searchIdAr'], $b['searchIdAr']) * ($sortOrderSearchIdAr === 'desc' ? -1 : 1);
  2731.                 if ($compareSearchIdAr !== 0) return $compareSearchIdAr;
  2732.             }
  2733.             if ($sortOrderAlertStatus) {
  2734.                 $compareAlertStatus = strcmp($a['alertStatus'], $b['alertStatus']) * ($sortOrderAlertStatus === 'desc' ? -1 : 1);
  2735.                 if ($compareAlertStatus !== 0) return $compareAlertStatus;
  2736.             }
  2737.             if ($sortOrderStartDate) {
  2738.                 $compareStartDate = strcmp($a['startDate'], $b['startDate']) * ($sortOrderStartDate === 'desc' ? -1 : 1);
  2739.                 if ($compareStartDate !== 0) return $compareStartDate;
  2740.             }
  2741.             if ($sortOrderEndDate) {
  2742.                 return strcmp($a['endDate'], $b['endDate']) * ($sortOrderEndDate === 'desc' ? -1 : 1);
  2743.             }
  2744.             
  2745.             // New sorting fields (ADDED - keeps old functionality)
  2746.             if ($sortOrderTitle) {
  2747.                 $compareTitle = strcmp($a['title'], $b['title']) * ($sortOrderTitle === 'desc' ? -1 : 1);
  2748.                 if ($compareTitle !== 0) return $compareTitle;
  2749.             }
  2750.             if ($sortOrderAlertType) {
  2751.                 $compareAlertType = strcmp($a['alertType'], $b['alertType']) * ($sortOrderAlertType === 'desc' ? -1 : 1);
  2752.                 if ($compareAlertType !== 0) return $compareAlertType;
  2753.             }
  2754.             if ($sortOrderFromDate) {
  2755.                 $compareFromDate = strcmp($a['fromDate'], $b['fromDate']) * ($sortOrderFromDate === 'desc' ? -1 : 1);
  2756.                 if ($compareFromDate !== 0) return $compareFromDate;
  2757.             }
  2758.             if ($sortOrderToDate) {
  2759.                 $compareToDate = strcmp($a['toDate'], $b['toDate']) * ($sortOrderToDate === 'desc' ? -1 : 1);
  2760.                 if ($compareToDate !== 0) return $compareToDate;
  2761.             }
  2762.             if ($sortOrderRegionNew) {
  2763.                 $compareRegionNew = strcmp($a['region'], $b['region']) * ($sortOrderRegionNew === 'desc' ? -1 : 1);
  2764.                 if ($compareRegionNew !== 0) return $compareRegionNew;
  2765.             }
  2766.             if ($sortOrderCreatedAtNew) {
  2767.                 $compareCreatedAtNew = strcmp($a['created_at'], $b['created_at']) * ($sortOrderCreatedAtNew === 'desc' ? -1 : 1);
  2768.                 if ($compareCreatedAtNew !== 0) return $compareCreatedAtNew;
  2769.             }
  2770.             if ($sortOrderAlertStatusNew) {
  2771.                 $compareAlertStatusNew = strcmp($a['alertStatus'], $b['alertStatus']) * ($sortOrderAlertStatusNew === 'desc' ? -1 : 1);
  2772.                 if ($compareAlertStatusNew !== 0) return $compareAlertStatusNew;
  2773.             }
  2774.             
  2775.             // If all provided parameters are equal, or no specific sort orders are provided, default to creation date
  2776.             return ($b['creationDate'] ?? 0) - ($a['creationDate'] ?? 0);
  2777.         });
  2779.         $sortedNotifications = array_map(function ($item) {
  2780.             return $item['notification'];
  2781.         }, $sortedData);
  2784.         if (isset($params['dashboard']) && !empty($params['dashboard'] && $params['dashboard'] == 'dashboard')) {
  2785.             return ["data" => $notificationList];
  2786.         }
  2789.         // Extract the sorted notifications
  2791.        
  2792.         if ($paginator == null) {
  2794.             // if ($sortedNotifications->count()) {
  2795.             foreach ($sortedNotifications as $notification) {
  2796.                 // if($notification->getPublished())
  2797.                 $response[] = $this->createNotificationFormat($notification, $translator);
  2798.             }
  2799.             // }
  2801.             return ["success" => TRUE, "data" => $response];
  2802.         }
  2805.         $paginator = $paginator->paginate(
  2806.             $sortedNotifications,
  2807.             $page,
  2808.             $pageSize
  2809.         );
  2810.         // if ($sortedNotifications->count()) {
  2811.         foreach ($paginator as $notification) {
  2812.             // if($notification->getPublished())
  2813.             $response[] = $this->createNotificationFormat($notification, $translator);
  2814.         }
  2815.         // }
  2817.         return ["data" => $response, "paginationVariables" => $paginator->getPaginationData()];
  2818.     }
  2820.     public function archiveNotification($params, $translator): array
  2821.     {
  2823.         $id = $params['id'] ?? null;
  2824.         if (!$id) {
  2825.             throw new \Exception("EWS id is required");
  2826.         }
  2828.         $ewsNotification = \Pimcore\Model\DataObject::getById($id);
  2829.         if (!$ewsNotification instanceof \Pimcore\Model\DataObject\EwsNotification) {
  2830.             // throw new \Exception("Ews notification not found");
  2831.             return ['success' => false, 'message' => $translator->trans('ews_notification_not_found')];
  2832.         }
  2834.         if (isset($params['status']) && $params['status']) {
  2835.             $ewsNotification->setStatus("archived");
  2836.         }
  2837.         $ewsNotification->save(["versionNote" => "Update"]);
  2839.         return ['success' => true, 'message' => $translator->trans('archive_ews_notification'), "notification_id" => $ewsNotification->getId()];
  2840.     }
  2842.     public function getId(): ?UuidV4
  2843.     {
  2845.         $uuid = UuidV4::v4();
  2846.         return $uuid;
  2847.     }
  2849.     public function getPhenomenaList()
  2850.     {
  2851.         $phenomenas = new \Pimcore\Model\DataObject\PhenomenaList\Listing();
  2852.         $phenomenas->setOrderKey("o_creationDate");
  2853.         $phenomenas->setOrder("desc");
  2854.         $phenomenas->load();
  2855.         $response = [];
  2857.         if (count($phenomenas) > 0) {
  2858.             foreach ($phenomenas as $phenomena) {
  2859.                 $response[] = [
  2860.                     "id" => $phenomena->getPhenomenaListId(),
  2861.                     "nameEN" => $phenomena->getTitle('en'),
  2862.                     "nameAr" => $phenomena->getTitle('ar'),
  2863.                 ];
  2864.             }
  2866.             return ["success" => true, "data" => $response];
  2867.         }
  2869.         return ["success" => false, "data" => $response];
  2870.     }
  2872.     public function getHazardListByAlertStatusId($statusId, $lang = "en")
  2873.     {
  2874.         $response = [];
  2875.         $alertSttaus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($statusId, true);
  2876.         if ($alertSttaus instanceof \Pimcore\Model\DataObject\AlertStatus) {
  2877.             if ($alertSttaus && $alertSttaus->getAlertHazards()) {
  2878.                 foreach ($alertSttaus->getAlertHazards() as  $value) {
  2879.                     $alertHazardObj = $value->getLocalizedfields()->getItems();
  2880.                     $response[] = ["id" => (int)$value->getAlertHazardId(), "nameEn" => $alertHazardObj['en']['name'], "nameAr" => $alertHazardObj['ar']['name']];
  2881.                 }
  2882.             } else {
  2883.                 return ["success" => false, "message" => "No Hazard is set"];
  2884.             }
  2885.         } else {
  2886.             return ["success" => false, "message" => "Invalid alert status id"];
  2887.         }
  2888.         return ["success" => true, "data" => $response];
  2889.     }
  2891.     // public function getHazardListByAlertStatusId($statusId, $lang = "en")
  2892.     // {
  2893.     //     $response = [];
  2894.     //     $alertPhenomena = \Pimcore\Model\DataObject\PhenomenaList::getByPhenomenaListId($statusId, true);
  2895.     //     if ($alertPhenomena instanceof \Pimcore\Model\DataObject\PhenomenaList) {
  2896.     //         if ($alertPhenomena && $alertPhenomena->getAlertHazards()) {
  2897.     //             foreach ($alertPhenomena->getAlertHazards() as  $value) {
  2898.     //                 $alertHazardObj = $value->getLocalizedfields()->getItems();
  2899.     //                 $response[] = ["id" => (int)$value->getAlertHazardId(), "nameEn" => $alertHazardObj['en']['name'], "nameAr" => $alertHazardObj['ar']['name']];
  2900.     //             }
  2901.     //         } else {
  2902.     //             return ["success" => false, "message" => "No Hazard is set"];
  2903.     //         }
  2904.     //     } else {
  2905.     //         return ["success" => false, "message" => "Invalid alert status id"];
  2906.     //     }
  2907.     //     return ["success" => true, "data" => $response];
  2908.     // }
  2910.     public function getOtherGovernoratesByRegion($regionId)
  2911.     {
  2912.         $response = [];
  2913.         $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  2914.         if (!$region) {
  2915.             throw new \Exception("Region not available");
  2916.         }
  2917.         $otherGovernorates = new DataObject\EwsOtherLocation\Listing();
  2918.         //$otherGovernorates->filterByRegionId($region);
  2919.         $otherGovernorates = $otherGovernorates->load();
  2920.         if ($otherGovernorates) {
  2921.             foreach ($otherGovernorates as $governorate) {
  2922.                 $region = $governorate->getregionId();
  2923.                 $regionData = [];
  2924.                 if (!empty($region)) {
  2925.                     $regionData = [
  2926.                         "id" => $region->getRegionId(),
  2927.                         "nameEn" => $region->getName('en'),
  2928.                         "nameAr" => $region->getName('ar'),
  2929.                         "longitude" => $region->getLongitude(),
  2930.                         "latitude" => $region->getLongitude()
  2932.                     ];
  2933.                 }
  2934.                 $response[] = [
  2935.                     "id" => $governorate->getgovernoteId(),
  2936.                     "nameEn" => $governorate->getName('en'),
  2937.                     "nameAr" => $governorate->getName('ar'),
  2938.                     "regionId" => $regionData,
  2939.                     "longitude" => $governorate->getLongitude(),
  2940.                     "latitude" => $governorate->getLatitude(),
  2941.                     "isHidden" => $governorate->getisHidden(),
  2942.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  2943.                     "MunicipalityID" => $governorate->getMunicipalityID()
  2944.                 ];
  2945.             }
  2946.         }
  2948.         return ["success" => true, "data" => $response];
  2949.     }
  2951.     public function createEwsReportUserGroup($params, $translator)
  2952.     {
  2953.         $response = [];
  2954.         $checkGroup = EwsAndReportUserGroup::getByName($params['name'], true);
  2955.         if ($checkGroup instanceof EwsAndReportUserGroup) {
  2956.             return ["success" => false, "message" => $translator->trans("group_name_already_exists"), "name" => $params['name']];
  2957.         }
  2958.         $ewsReportUserGroup = new DataObject\EwsAndReportUserGroup();
  2959.         $ewsReportUserGroup->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Notification/userGroups/" . $params['type'] . "/"));
  2960.         $ewsReportUserGroup->setKey(\Pimcore\Model\Element\Service::getValidKey($params['name'] . "-" . strtotime("now") . "-" . rand(1, 10000), 'object', 'object'));
  2961.         $ewsReportUserGroup->setName(strip_tags($params['name']));
  2962.         $ewsReportUserGroup->setJsonData(json_encode($params['data']));
  2963.         $ewsReportUserGroup->setGroupType($params['type']);
  2965.         $ewsReportUserGroup->setPublished(true);
  2966.         $ewsReportUserGroup->save();
  2967.         return ["success" => true, "message" => $translator->trans("ews_report_user_group_created")];
  2968.     }
  2970.     public function updateEwsReportUserGroup($params, $translator)
  2971.     {
  2972.         $response = [];
  2973.         $updateGroup = EwsAndReportUserGroup::getById($params['id']);
  2974.         if (!$updateGroup instanceof EwsAndReportUserGroup) {
  2975.             return ["success" => false, "message" => $translator->trans('ews_report_user_group_not_found'), "id" => $params['id']];
  2976.         }
  2977.         if (isset($params['name']) && !empty($params['name']) && $updateGroup->getName() != $params['name']) {
  2979.             $checkGroup = EwsAndReportUserGroup::getByName($params['name'], true);
  2980.             if ($checkGroup instanceof EwsAndReportUserGroup) {
  2981.                 return ["success" => false, "message" => $translator->trans("group_name_already_exists"), "name" => $params['name']];
  2982.             }
  2983.             $updateGroup->setName(strip_tags($params['name']));
  2984.             $updateGroup->setKey(\Pimcore\Model\Element\Service::getValidKey($params['name'] . "-" . strtotime("now") . "-" . rand(1, 10000), 'object', 'object'));
  2985.         }
  2987.         if (isset($params['data']) && !empty($params['data'])) {
  2988.             $updateGroup->setJsonData(json_encode($params['data']));
  2989.         }
  2991.         if (isset($params['type']) && !empty($params['type'])) {
  2992.             $updateGroup->setGroupType($params['type']);
  2993.             $updateGroup->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Notification/userGroups/" . $params['type'] . "/"));
  2994.         }
  2996.         $updateGroup->setJsonData(json_encode($params['data']));
  2997.         $updateGroup->setGroupType($params['type']);
  2999.         $updateGroup->setPublished(true);
  3000.         $updateGroup->save();
  3001.         return ["success" => true, "message" => $translator->trans("ews_report_user_group_updated")];
  3002.     }
  3004.     public function deleteEwsReportUserGroup($params, $translator)
  3005.     {
  3006.         $response = [];
  3007.         $deleteGroup = EwsAndReportUserGroup::getById($params['id']);
  3008.         if (!$deleteGroup instanceof EwsAndReportUserGroup) {
  3009.             return ["success" => false, "message" => $translator->trans('ews_report_user_group_not_found'), "id" => $params['id']];
  3010.         }
  3012.         $deleteGroup->delete();
  3013.         return ["success" => true, "message" => $translator->trans("ews_report_user_group_deleted")];
  3014.     }
  3016.     public function listEwsReportUserGroup($params, $paginator, $translator)
  3017.     {
  3018.         $data = [];
  3019.         $listing = new EwsAndReportUserGroup\Listing();
  3020.     
  3021.         // Allowed sorting keys
  3022.         $allowedOrderKeys = ['name', 'type', 'email_count', 'oo_id'];
  3023.         $allowedOrderDirections = ['asc', 'desc'];
  3024.     
  3025.         $orderKey = $params['orderKey'] ?? 'oo_id';
  3026.         $orderDirection = strtolower($params['order'] ?? 'desc');
  3027.     
  3028.         if (in_array($orderKey, $allowedOrderKeys) && in_array($orderDirection, $allowedOrderDirections)) {
  3029.             $fieldMapping = [
  3030.                 'name' => 'name',
  3031.                 'type' => 'groupType',
  3032.                 'oo_id' => 'oo_id'
  3033.             ];
  3034.     
  3035.             // Normal sorting keys (done in SQL)
  3036.             if (isset($fieldMapping[$orderKey])) {
  3037.                 $listing->setOrderKey($fieldMapping[$orderKey]);
  3038.                 $listing->setOrder(strtoupper($orderDirection));
  3039.             }
  3040.         } else {
  3041.             // Default sorting
  3042.             $orderKey = 'oo_id';
  3043.             $orderDirection = 'desc';
  3044.             $listing->setOrderKey('oo_id');
  3045.             $listing->setOrder('DESC');
  3046.         }
  3047.     
  3049.         if (isset($params['type']) && !empty($params['type'])) {
  3050.             $listing->addConditionParam("groupType = ?", [$params['type']]);
  3051.         }
  3053.         if (isset($params['search']) && !empty($params['search'])) {
  3054.             $listing->addConditionParam("name LIKE ? ", ['%' . $params['search'] . '%']);
  3055.         }
  3056.         
  3057.     
  3058.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  3059.         $page = isset($params['page']) ? $params['page'] : 1;
  3060.     
  3061.         $paginator = $paginator->paginate(
  3062.             $listing,
  3063.             $page,
  3064.             $pageSize
  3065.         );
  3066.     
  3067.         // Convert paginator to array
  3068.         $groups = iterator_to_array($paginator);
  3069.     
  3070.         // Handle email_count sorting manually in PHP
  3071.         if ($orderKey === 'email_count') {
  3072.             usort($groups, function ($a, $b) use ($orderDirection) {
  3073.                 $lenA = count(json_decode($a->getJsonData(), true) ?? []);
  3074.                 $lenB = count(json_decode($b->getJsonData(), true) ?? []);
  3075.                 return $orderDirection === 'asc' ? $lenA <=> $lenB : $lenB <=> $lenA;
  3076.             });
  3077.         }
  3078.     
  3079.         // Prepare output data
  3080.         foreach ($groups as $group) {
  3081.             $jsonData = json_decode($group->getJsonData(), true) ?? [];
  3082.             $data[] = [
  3083.                 "id" => $group->getId(),
  3084.                 "name" => $group->getName(),
  3085.                 "type" => $group->getGroupType(),
  3086.                 "email_count" => count($jsonData),
  3087.                 "data" => $jsonData
  3088.             ];
  3089.         }
  3091.         if (count($data) > 0) {
  3093.             return ["success" => true, "data" => $data, "paginationVariables" => $paginator->getPaginationData()];
  3094.         } else {
  3095.             return ["success" => false, "message" => $translator->trans('no_ews_report_user_group_found')];
  3096.         }
  3097.     }
  3099.     public function getSortCriteria()
  3100.     {
  3101.         // This is a placeholder; you'll need to adapt this based on how you can access the region's name or other criteria
  3102.         return $this->getRegion()->getName();
  3103.     }
  3104.     public function getCenters($governorateId = null, $lang = 'en')
  3105.     {
  3106.         $response = [];
  3107.         $districts = new DataObject\District\Listing();
  3108.         if (is_array($governorateId)) {
  3109.             $govIdsArr = [];
  3110.             foreach ($governorateId as $govId) {
  3111.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  3112.                 if ($governorate) {
  3113.                     array_push($govIdsArr, $governorate->getId());
  3114.                 }
  3115.             }
  3116.             $districts->setCondition("governorate__id IN (" . implode(", ", $govIdsArr) . ")");
  3117.         } else {
  3118.             if ($governorateId) {
  3119.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($governorateId, true);
  3120.                 $districts->setCondition("governorate__id = ?", [$governorate->getId()]);
  3121.             }
  3122.         }
  3123.         $districts = $districts->load();
  3124.         if ($districts) {
  3125.             foreach ($districts as $district) {
  3126.                 $response[] = [
  3127.                     "id" => $district->getObjectId(),
  3128.                     "nameEn" => $district->getName('en'),
  3129.                     "nameAr" => $district->getName('ar'),
  3130.                     "longitude" => $district->getLongitude(),
  3131.                     "latitude" => $district->getLatitude(),
  3132.                     "governate" => $district->getGovernorate()->getGovernoteId()
  3133.                 ];
  3134.             }
  3135.         }
  3137.         // Determine sorting field based on language
  3138.         $sortField = 'nameEn'; // Default sorting by English
  3139.         if (isset($lang) && strtolower($lang) === 'ar') {
  3140.             $sortField = 'nameAr'; // Sorting by Arabic
  3141.         }
  3143.         // Sort manually using usort()
  3144.         usort($response, function ($a, $b) use ($sortField) {
  3145.             return strcmp($a[$sortField], $b[$sortField]);
  3146.         });
  3148.         return ["success" => true, "data" => $response];
  3149.     }
  3150. }