src/Model/EwsNotificationModel.php line 4612

Open in your IDE?
  1. <?php
  3. namespace App\Model;
  5. use DateTime;
  6. use Pimcore\Db;
  7. use DOMDocument;
  8. use Pimcore\Model\DataObject\AlertAction;
  9. use Pimcore\Model\DataObject\AlertHazard;
  10. use Pimcore\Model\DataObject\AlertStatus;
  11. use Pimcore\Model\DataObject\Governorate;
  12. use Pimcore\Model\DataObject\EwsPolygon;
  13. use SimpleXMLElement;
  14. use Pimcore\Model\Asset;
  15. use Doctrine\DBAL\Connection;
  16. use Pimcore\Model\DataObject;
  17. use Symfony\Component\Uid\UuidV4;
  18. use Pimcore\Model\DataObject\Region;
  19. use Pimcore\Model\DataObject\AlertType;
  20. use Pimcore\Model\DataObject\EwsNotification;
  21. use Symfony\Component\HttpFoundation\Request;
  22. use Pimcore\Model\DataObject\FetchSentEwsEmail;
  23. use App\C2IntegrationBundle\Service\C2Service;
  24. use Pimcore\Model\Asset\MetaData\ClassDefinition\Data\DataObject as DataDataObject;
  25. use Pimcore\Model\DataObject\EwsAndReportUserGroup;
  26. use App\Model\UserModel;
  27. use App\Service\Translation\Bilingual;
  28. use Symfony\Component\Process\Process;
  29. use Symfony\Component\Process\Exception\ProcessFailedException;
  30. use App\Lib\ConsoleBackgroundProcess;
  31. use App\Lib\PublicPortalEwsWebhookProcessLauncher;
  32. use Psr\Log\LoggerInterface;
  33. use Knp\Snappy\Image as SnappyImage;
  35. class EwsNotificationModel
  36. {
  37.     /** Pimcore class definition maxItems for center / district many-to-many fields */
  38.     private const MAX_EWS_CENTER_DISTRICT_RELATIONS = 1000;
  40.     public $c2Service;
  41.     private $userModel;
  43.     function __construct()
  44.     {
  45.         $this->c2Service = new C2Service();
  46.         $this->userModel = new UserModel();
  47.     }
  49.     /**
  50.      * Deduplicate by object id, preserve request order, enforce Pimcore maxItems on relation fields.
  51.      *
  52.      * @param array<int, DataObject\AbstractObject|null|false> $objects
  53.      * @return DataObject\AbstractObject[]
  54.      */
  55.     private function capUniqueDataObjectRelations(array $objects, int $max = self::MAX_EWS_CENTER_DISTRICT_RELATIONS): array
  56.     {
  57.         $out = [];
  58.         $seen = [];
  59.         foreach ($objects as $obj) {
  60.             if (!$obj instanceof DataObject\AbstractObject) {
  61.                 continue;
  62.             }
  63.             $oid = $obj->getId();
  64.             if (!$oid || isset($seen[$oid])) {
  65.                 continue;
  66.             }
  67.             $seen[$oid] = true;
  68.             $out[] = $obj;
  69.             if (count($out) >= $max) {
  70.                 break;
  71.             }
  72.         }
  74.         return $out;
  75.     }
  77.     /**
  78.      * Coerce a request ID (scalar or single-element array) to a value Pimcore getBy* can quote.
  79.      */
  80.     private function scalarId($value)
  81.     {
  82.         if (is_array($value)) {
  83.             $value = reset($value);
  84.         }
  86.         if ($value === false || $value === null || $value === '') {
  87.             return null;
  88.         }
  90.         return $value;
  91.     }
  93.     /**
  94.      * Split a comma-separated ID string or array, skipping empty values, preserving request order.
  95.      *
  96.      * @return string[]
  97.      */
  98.     private function parseCommaSeparatedIds($value): array
  99.     {
  100.         if ($value === null || $value === '' || $value === false) {
  101.             return [];
  102.         }
  104.         if (is_array($value)) {
  105.             $ids = [];
  106.             foreach ($value as $id) {
  107.                 if (is_array($id)) {
  108.                     $id = reset($id);
  109.                 }
  110.                 if ($id !== null && $id !== false && $id !== '') {
  111.                     $ids[] = $id;
  112.                 }
  113.             }
  115.             return $ids;
  116.         }
  118.         $ids = [];
  119.         foreach (explode(',', (string) $value) as $id) {
  120.             if ($id !== '') {
  121.                 $ids[] = $id;
  122.             }
  123.         }
  125.         return $ids;
  126.     }
  128.     public function createNotification($request, $params, $userInterface, $translator): array
  129.     {
  130.         $result = [];
  131.         // try {
  132.         $regionId = $params['regionId'] ?? null;
  133.         $polygonId = $params['polygonId'] ?? null;
  134.         $governorateIds = $params['governateIds'] ?? null;
  135.         $mapGovernorateIds = $params['mapGovernorateIds'] ?? null;
  136.         $municipalities = $params['municipalityIds'] ?? null;
  137.         $centerIds = $params['centerIds'] ?? null;
  138.         $districtIds = $params['districtIds'] ?? null;
  139.         $ewsOtherLocationIds = $params['ewsOtherLocationIds'] ?? null;
  140.         $alertActionId = $params['alertActionId'] ?? null;
  141.         $alertTypeId = $params['alertTypeId'] ?? null;
  142.         $weatherPhenomenonId = $params['weatherPhenomenonId'] ?? null;
  143.         $coordinates = json_encode($params['coordinates'] ?? []);
  144.         $message = $params['message'] ?? [];
  145.         $alertHazardId = $params['alertHazardId'] ?? null;
  146.         $otherLocationId = $params['otherLocationId'] ?? null;
  147.         $enableTwitterNotification = $params['enableTwitterNotification'] ?? false;
  148.         $enableSMSNotification = $params['enableSMSNotification'] ?? false;
  149.         $enableEmailNotification = $params['enableEmailNotification'] ?? false;
  150.         $x_post = $params['x_post'] ?? "";
  151.         $previewText = isset($params['previewText']) ? $params['previewText'] : false;
  152.         $notificationType =  $params['notificationType'] ?? null;
  153.         $alertPage = $params['alertPage'] ?? null;
  155.         $ewsNotification = new DataObject\EwsNotification();
  156.         $ewsNotification->setParent(DataObject\Service::createFolderByPath('/Notification/EWSNotification'));
  157.         $ewsNotification->setKey(md5($coordinates . $regionId . $governorateIds) . '-' . time());
  158.         $ewsNotification->setGuid(\App\Lib\Utility::getUUID()->toRfc4122());
  160.         if (isset($params['startDate'])) {
  161.             $startTime = $params['startTime'] ?? '00:00:00';
  162.             $fromDate = $params['startDate'] . ' ' . $startTime;
  163.             $ewsNotification->setStartDate(\Carbon\Carbon::createFromFormat('Y-m-d H:i:s', $fromDate));
  164.         }
  166.         if (isset($params['endDate'])) {
  167.             $endTime = $params['endTime'] ?? '00:00:00';
  168.             $endDate = $params['endDate'] . ' ' . $endTime;
  169.             $ewsNotification->setEndDate(\Carbon\Carbon::createFromFormat('Y-m-d H:i:s', $endDate));
  170.         }
  172.         if (isset($message['en'])) {
  173.             $ewsNotification->setMessage($message['en'], 'en');
  174.         }
  176.         if (isset($message['ar'])) {
  177.             $ewsNotification->setMessage($message['ar'], 'ar');
  178.         }
  181.         if (!empty($regionId)) {
  182.             $regionObj = DataObject\Region::getByRegionId($regionId, 1);
  183.             if (!empty($regionObj)) {
  184.                 $ewsNotification->setRegion($regionObj);
  185.                 if ($governorateIds) {
  186.                     $governorateIdArr = explode(",", $governorateIds);
  187.                     if ($governorateIdArr) {
  188.                         $applyGovernates = [];
  189.                         foreach ($governorateIdArr as $id) {
  190.                             if (!empty($id)) {
  191.                                 $applyGovernates[] = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($id, true);
  192.                                 if (!empty(array_unique($applyGovernates))) {
  193.                                     $ewsNotification->setGovernorate(array_unique($applyGovernates));
  194.                                 }
  195.                             }
  196.                         }
  197.                     }
  198.                     if ($municipalities) {
  199.                         $municipalitiesIdArr = explode(",", $municipalities);
  200.                         if ($municipalitiesIdArr) {
  201.                             $applyMunicipalities = [];
  202.                             foreach ($municipalitiesIdArr as $id) {
  203.                                 $applyMunicipalities[] = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($id, true);
  204.                                 if (!empty(array_unique($applyMunicipalities))) {
  205.                                     $ewsNotification->setMunicipality(array_unique($applyMunicipalities));
  206.                                 }
  207.                             }
  208.                         }
  209.                     }
  210.                 } else {
  211.                     $ewsNotification->setGovernorate($this->governorateByRegion($regionObj->getId()));
  212.                 }
  213.             }
  214.         }
  215.         if(!empty($mapGovernorateIds)) {
  216.             $mapGovernorateIdArr = explode(",", $mapGovernorateIds);
  217.             if ($mapGovernorateIdArr) {
  218.                 $applyMapGovernates = [];
  219.                 foreach ($mapGovernorateIdArr as $id) {
  220.                     if (!empty($id)) {
  221.                         $applyMapGovernates[] = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($id, true);
  222.                         if (!empty(array_unique($applyMapGovernates))) {
  223.                             $ewsNotification->setMapGovernorate(array_unique($applyMapGovernates));
  224.                         }
  225.                     }
  226.                 }
  227.             }
  228.         }
  229.         if ($ewsOtherLocationIds) {
  230.             $ewsOtherLocationIdArr = explode(",", $ewsOtherLocationIds);
  231.             if ($ewsOtherLocationIdArr) {
  232.                 $applyOtherGovernates = [];
  233.                 foreach ($ewsOtherLocationIdArr as $id) {
  234.                     $applyOtherGovernates[] = \Pimcore\Model\DataObject\EwsOtherLocation::getByGovernoteId($id, true);
  236.                     if (!empty(array_unique($applyOtherGovernates))) {
  237.                         $ewsNotification->setEwsOtherLocations(array_unique($applyOtherGovernates));
  238.                     }
  239.                 }
  240.             }
  241.         }
  243.         if (!empty($alertHazardId)) {
  244.             $alertHazardArr = explode(",", $alertHazardId);
  245.             if ($alertHazardArr) {
  246.                 $alertHazardArrRequest = [];
  247.                 foreach ($alertHazardArr as $alertHazardId) {
  248.                     $weatherPhenomenonAffect = DataObject\AlertHazard::getByAlertHazardId($alertHazardId, 1);
  249.                     if ($weatherPhenomenonAffect) {
  250.                         $alertHazardArrRequest[] = $weatherPhenomenonAffect;
  251.                     }
  252.                 }
  253.                 $ewsNotification->setAlertHazard($alertHazardArrRequest);
  254.             }
  255.         }
  256.         if (!empty($centerIds)) {
  257.             $applyCenters = [];
  258.             foreach (array_filter(array_map('trim', explode(',', (string) $centerIds))) as $id) {
  259.                 $center = DataObject\Centers::getById((int) $id);
  260.                 if ($center instanceof DataObject\Centers) {
  261.                     $applyCenters[] = $center;
  262.                 }
  263.             }
  264.             $applyCenters = $this->capUniqueDataObjectRelations($applyCenters);
  265.             if ($applyCenters !== []) {
  266.                 $ewsNotification->setCenter($applyCenters);
  267.             }
  268.         }
  269.         if (!empty($districtIds)) {
  270.             $applyDistrict = [];
  271.             foreach (array_filter(array_map('trim', explode(',', (string) $districtIds))) as $id) {
  272.                 $district = DataObject\District::getById((int) $id);
  273.                 if ($district instanceof DataObject\District) {
  274.                     $applyDistrict[] = $district;
  275.                 }
  276.             }
  277.             $applyDistrict = $this->capUniqueDataObjectRelations($applyDistrict);
  278.             if ($applyDistrict !== []) {
  279.                 $ewsNotification->setDistrict($applyDistrict);
  280.             }
  281.         }
  282.         if (!empty($alertTypeId)) {
  283.             $alertType = DataObject\AlertType::getByAlertTypeId($alertTypeId, 1);
  284.             $ewsNotification->setAlertType($alertType);
  285.         }
  288.         if (!empty($alertActionId)) {
  289.             $alertActionArr = explode(",", $alertActionId);
  290.             if ($alertActionArr) {
  291.                 $alertActionArrRequest = [];
  292.                 foreach ($alertActionArr as $alertActionId) {
  293.                     $alertAction = DataObject\AlertAction::getByAlertActionId($alertActionId, 1);
  294.                     if ($alertAction) {
  295.                         $alertActionArrRequest[] = $alertAction;
  296.                     }
  297.                 }
  298.                 $ewsNotification->setAlertAction($alertActionArrRequest);
  299.             }
  300.         }
  302.         if (!empty($otherLocationId)) {
  303.             $otherLocationArr = explode(",", $otherLocationId);
  304.             if ($otherLocationArr) {
  305.                 $otherLocationArrRequest = [];
  306.                 foreach ($otherLocationArr as $otherLocationId) {
  307.                     $otherLocation = DataObject\OtherLocation::getByOtherLocationId($otherLocationId, 1);
  308.                     if ($otherLocation) {
  309.                         $otherLocationArrRequest[] = $otherLocation;
  310.                     }
  311.                 }
  312.                 $ewsNotification->setOtherLocations($otherLocationArrRequest);
  313.             }
  314.         }
  317.         if (!empty($weatherPhenomenonId)) {
  318.             $alertStatus = DataObject\AlertStatus::getByAlertStatusId($weatherPhenomenonId, true);
  319.             $ewsNotification->setAlertStatus($alertStatus);
  320.         }
  321.         if (!empty($polygonId)) {
  322.             $ewsPolygon = EwsPolygon::getById($polygonId ?? null);
  323.             $ewsNotification->setPolygon($ewsPolygon);
  324.             $ewsNotification->setIsPolygon(true);
  325.         }
  327.         $ewsNotification->setCoordinates($coordinates);
  329.         $addressComponents = $params['address_components'] ?? [];
  330.         $this->addAddressComponentsFieldCollection($addressComponents, $ewsNotification);
  333.         if (!empty($params['file'])) {
  334.             $asset = $this->createAsset($params['file'], time() . $params['filename']);
  335.             if ($asset) {
  336.                 $ewsNotification->setAttachment($asset);
  337.             }
  338.         }
  340.         if (!empty($params['x_img'])) {
  341.             $asset = $this->createAsset($params['x_img'], uniqid() . "EWSTwitterImages.png");
  342.             if ($asset) {
  343.                 $ewsNotification->setXAttachment($asset);
  344.             }
  345.         }
  347.         if (!empty($params['polygon_x_img'])) {
  348.             $asset = $this->createAsset($params['polygon_x_img'], uniqid() . "EWSPolygonTwitterImages.png");
  349.             if ($asset) {
  350.                 $ewsNotification->setPolygonXAtachment($asset);
  351.             }
  352.         }
  354.         $ewsNotification->setXPost($x_post);
  355.         $ewsNotification->setEnableTwitterNotification($enableTwitterNotification);
  356.         $ewsNotification->setEnableSMSNotification($enableSMSNotification);
  357.         $ewsNotification->setEnableEmailNotification($enableEmailNotification);
  358.         $ewsNotification->setUser($userInterface);
  359.         $ewsNotification->setEditor($userInterface);
  360.         $ewsNotification->setPublished(false);
  361.         $ewsNotification->setPreviewText($previewText);
  362.         $ewsNotification->setNotificationType($notificationType);
  363.         if (isset($params['alertPage'])) {
  364.             $ewsNotification->setAlertPage($alertPage);
  365.         }
  367.         //$ewsNotification->save(["versionNote" => "Update"]);
  369.         //set ews search Id
  370.         $currentDate = new \DateTime();
  371.         $formattedDate = $currentDate->format('dmY') . '-' . $ewsNotification->getId();
  372.         $searchIdEn = 'Early Warning System | ' . $formattedDate . ' | ' . ucfirst($ewsNotification->getAlertType()?->getColor()) . ' Alert | ' . $ewsNotification->getWeatherPhenomenon()?->getTitle("en");
  373.         $searchIdAr = $translator->trans('Early Warning System', [], null, "ar") . ' | ' . $formattedDate . ' | ' . $translator->trans(ucfirst($ewsNotification->getAlertType()?->getColor()) . ' Alert', [], null, "ar") . ' | ' . $ewsNotification->getWeatherPhenomenon()?->getTitle("ar");
  374.         $ewsNotification->setEwsSearchId($searchIdEn, "en");
  375.         $ewsNotification->setEwsSearchId($searchIdAr, "ar");
  376.         //$ewsNotification->save(["versionNote" => "Update"]);
  377.         $ewsNotification->save();
  379.         $this->saveUserMessageSuggestions(
  380.             (int) $userInterface->getId(),
  381.             $message
  382.         );
  384.         return ['success' => true, 'message' => $translator->trans('ews_notification_added_successifully'), "notification_id" => $ewsNotification->getId()];
  385.         // } catch (\Exception $ex) {
  386.         //     $result = ['success' => false, 'message' => $ex->getMessage()];
  387.         // }
  389.         return $result;
  390.     }
  392.     public function updateNotification($request, $params, $userInterface, $translator, $userGroupIds, $isPublished, $emailService, $templating, $logger): array
  393.     {
  394.         $result = [];
  396.         // try {
  397.         $id = $params['id'] ?? null;
  398.         if (!$id) {
  399.             throw new \Exception("EWS id is required");
  400.         }
  402.         $regionId = $params['regionId'] ?? null;
  403.         $governorateIds = $params['governateIds'] ?? null;
  404.         $mapGovernorateIds = $params['mapGovernorateIds'] ?? null;
  405.         $municipalities = $params['municipalityIds'] ?? null;
  406.         $centerIds = $params['centerIds'] ?? null;
  407.         $districtIds = $params['districtIds'] ?? null;
  408.         $ewsOtherLocationIds = $params['ewsOtherLocationIds'] ?? null;
  409.         $alertActionId = $params['alertActionId'] ?? null;
  410.         $alertTypeId = $params['alertTypeId'] ?? null;
  411.         $weatherPhenomenonId = $params['weatherPhenomenonId'] ?? null;
  412.         $coordinates = json_encode($params['coordinates'] ?? []);
  413.         $message = $params['message'] ?? [];
  414.         $alertHazardId = $params['alertHazardId'] ?? null;
  415.         $enableTwitterNotification = $params['enableTwitterNotification'] ?? false;
  416.         $enableSMSNotification = $params['enableSMSNotification'] ?? false;
  417.         $enableEmailNotification = $params['enableEmailNotification'] ?? false;
  418.         $previewText = isset($params['previewText']) ? $params['previewText'] : false;
  419.         $alertPage = $params['alertPage'] ?? null;
  421.         $ewsNotification = \Pimcore\Model\DataObject::getById($id);
  422.         if (!$ewsNotification instanceof \Pimcore\Model\DataObject\EwsNotification) {
  423.             // throw new \Exception("Ews notification not found");
  424.             return ['success' => false, 'message' => $translator->trans('ews_notification_not_found')];
  425.         }
  427.         if (isset($params['startDate'])) {
  428.             $startTime = $params['startTime'] ?? '00:00:00';
  429.             $fromDate = $params['startDate'] . ' ' . $startTime;
  430.             $ewsNotification->setStartDate(\Carbon\Carbon::createFromFormat('Y-m-d H:i:s', $fromDate));
  431.         }
  433.         if (isset($params['endDate'])) {
  434.             $endTime = $params['endTime'] ?? '00:00:00';
  435.             $endDate = $params['endDate'] . ' ' . $endTime;
  436.             $ewsNotification->setEndDate(\Carbon\Carbon::createFromFormat('Y-m-d H:i:s', $endDate));
  437.         }
  439.         if (isset($message['en'])) {
  440.             $ewsNotification->setMessage($message['en'], 'en');
  441.         }
  443.         if (isset($message['ar'])) {
  444.             $ewsNotification->setMessage($message['ar'], 'ar');
  445.         }
  448.         if (!empty($regionId)) {
  449.             $regionObj = DataObject\Region::getByRegionId($regionId, 1);
  450.             if (!empty($regionObj)) {
  451.                 $ewsNotification->setRegion($regionObj);
  452.                 if ($governorateIds) {
  453.                     $governorateIdArr = explode(",", $governorateIds);
  454.                     if ($governorateIdArr) {
  455.                         $applyGovernates = [];
  456.                         foreach ($governorateIdArr as $id) {
  457.                             if (!empty($id)) {
  458.                                 $applyGovernates[] = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($id, true);
  459.                                 if (!empty(array_unique($applyGovernates))) {
  460.                                     $ewsNotification->setGovernorate(array_unique($applyGovernates));
  461.                                 }
  462.                             }
  463.                         }
  464.                     }
  465.                     if ($municipalities) {
  466.                         $municipalitiesIdArr = explode(",", $municipalities);
  467.                         if ($municipalitiesIdArr) {
  468.                             $applyMunicipalities = [];
  469.                             foreach ($municipalitiesIdArr as $id) {
  470.                                 $applyMunicipalities[] = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($id, true);
  471.                                 if (!empty(array_unique($applyMunicipalities))) {
  472.                                     $ewsNotification->setMunicipality(array_unique($applyMunicipalities));
  473.                                 }
  474.                             }
  475.                         }
  476.                     }
  477.                 } else {
  478.                     $ewsNotification->setGovernorate($this->governorateByRegion($regionObj->getId()));
  479.                 }
  480.             }
  481.         }
  482.         if(!empty($mapGovernorateIds)) {
  483.             $mapGovernorateIdArr = explode(",", $mapGovernorateIds);
  484.             if ($mapGovernorateIdArr) {
  485.                 $applyMapGovernates = [];
  486.                 foreach ($mapGovernorateIdArr as $id) {
  487.                     if (!empty($id)) {
  488.                         $applyMapGovernates[] = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($id, true);
  489.                         if (!empty(array_unique($applyMapGovernates))) {
  490.                             $ewsNotification->setMapGovernorate(array_unique($applyMapGovernates));
  491.                         }
  492.                     }
  493.                 }
  494.             }
  495.         }
  496.         if ($ewsOtherLocationIds) {
  497.             $ewsOtherLocationIdArr = explode(",", $ewsOtherLocationIds);
  498.             if ($ewsOtherLocationIdArr) {
  499.                 $applyOtherGovernates = [];
  500.                 foreach ($ewsOtherLocationIdArr as $id) {
  501.                     $applyOtherGovernates[] = \Pimcore\Model\DataObject\EwsOtherLocation::getByGovernoteId($id, true);
  503.                     if (!empty(array_unique($applyOtherGovernates))) {
  504.                         $ewsNotification->setEwsOtherLocations(array_unique($applyOtherGovernates));
  505.                     }
  506.                 }
  507.             }
  508.         }
  509.         if (!empty($alertTypeId)) {
  510.             $alertType = DataObject\AlertType::getByAlertTypeId($alertTypeId, 1);
  511.             $ewsNotification->setAlertType($alertType);
  512.         }
  515.         if (!empty($alertActionId)) {
  516.             $alertActionArr = explode(",", $alertActionId);
  517.             if ($alertActionArr) {
  518.                 $alertActionArrRequest = [];
  519.                 foreach ($alertActionArr as $alertActionId) {
  520.                     $alertAction = DataObject\AlertAction::getByAlertActionId($alertActionId, 1);
  521.                     if ($alertAction) {
  522.                         $alertActionArrRequest[] = $alertAction;
  523.                     }
  524.                 }
  525.                 $ewsNotification->setAlertAction($alertActionArrRequest);
  526.             }
  527.         }
  530.         if (!empty($weatherPhenomenonId)) {
  531.             $alertStatus = DataObject\AlertStatus::getByAlertStatusId($weatherPhenomenonId, true);
  532.             $ewsNotification->setAlertStatus($alertStatus);
  533.         }
  535.         if (!empty($centerIds)) {
  536.             $applyCenters = [];
  537.             foreach (array_filter(array_map('trim', explode(',', (string) $centerIds))) as $id) {
  538.                 $center = DataObject\Centers::getById((int) $id);
  539.                 if ($center instanceof DataObject\Centers) {
  540.                     $applyCenters[] = $center;
  541.                 }
  542.             }
  543.             $applyCenters = $this->capUniqueDataObjectRelations($applyCenters);
  544.             if ($applyCenters !== []) {
  545.                 $ewsNotification->setCenter($applyCenters);
  546.             }
  547.         }
  548.         if (!empty($districtIds)) {
  549.             $applyDistrict = [];
  550.             foreach (array_filter(array_map('trim', explode(',', (string) $districtIds))) as $id) {
  551.                 $district = DataObject\District::getById((int) $id);
  552.                 if ($district instanceof DataObject\District) {
  553.                     $applyDistrict[] = $district;
  554.                 }
  555.             }
  556.             $applyDistrict = $this->capUniqueDataObjectRelations($applyDistrict);
  557.             if ($applyDistrict !== []) {
  558.                 $ewsNotification->setDistrict($applyDistrict);
  559.             }
  560.         }
  562.         if (!empty($alertHazardId)) {
  563.             $alertHazardArr = explode(",", $alertHazardId);
  564.             if ($alertHazardArr) {
  565.                 $alertHazardArrRequest = [];
  566.                 foreach ($alertHazardArr as $alertHazardId) {
  567.                     $weatherPhenomenonAffect = DataObject\AlertHazard::getByAlertHazardId($alertHazardId, 1);
  568.                     if ($weatherPhenomenonAffect) {
  569.                         $alertHazardArrRequest[] = $weatherPhenomenonAffect;
  570.                     }
  571.                 }
  572.                 $ewsNotification->setAlertHazard($alertHazardArrRequest);
  573.             }
  574.         }
  577.         $ewsNotification->setCoordinates($coordinates);
  579.         $addressComponents = $params['address_components'] ?? [];
  580.         $this->addAddressComponentsFieldCollection($addressComponents, $ewsNotification);
  583.         if (!empty($params['file'])) {
  584.             $asset = $this->createAsset($params['file'], uniqid() . $params['filename']);
  585.             if ($asset) {
  586.                 $ewsNotification->setAttachment($asset);
  587.             }
  588.         }else{
  589.             $ewsNotification->setAttachment(null);
  590.         }
  592.         if (!empty($params['x_img'])) {
  593.             $asset = $this->createAsset($params['x_img'], uniqid() . "EWSTwitterImages.png");
  594.             if ($asset) {
  595.                 $ewsNotification->setXAttachment($asset);
  596.             }
  597.         }else{
  598.             $ewsNotification->setXAttachment(null);
  599.         }
  601.         if (!empty($params['polygon_x_img'])) {
  602.             $asset = $this->createAsset($params['polygon_x_img'], uniqid() . "EWSPolygonTwitterImages.png");
  603.             if ($asset) {
  604.                 $ewsNotification->setPolygonXAtachment($asset);
  605.             }
  606.         }else{
  607.             $ewsNotification->setPolygonXAtachment(null);
  608.         }
  610.         if (!empty($params['x_post'])) {
  611.             $ewsNotification->setXPost($params['x_post']);
  612.         }
  614.         $ewsNotification->setEnableTwitterNotification($enableTwitterNotification);
  615.         $ewsNotification->setEnableSMSNotification($enableSMSNotification);
  616.         $ewsNotification->setEnableEmailNotification($enableEmailNotification);
  617.         $ewsNotification->setPreviewText($previewText);
  618.         if (isset($params['alertPage'])) {
  619.             $ewsNotification->setAlertPage($alertPage);
  620.         }
  621.         //$ewsNotification->setPublished(true);
  622.         $ewsNotification->setUser($userInterface);
  623.         $ewsNotification->setEditor($userInterface);
  624.         //set ews search Id
  625.         $currentDate = new \DateTime();
  626.         $formattedDate = $currentDate->format('dmY') . '-' . $ewsNotification->getId();
  627.         $searchIdEn = 'Early Warning System | ' . $formattedDate . ' | ' . ucfirst($ewsNotification->getAlertType()?->getColor()) . ' Alert | ' . $ewsNotification->getWeatherPhenomenon()?->getTitle("en");
  628.         $searchIdAr = $translator->trans('Early Warning System', [], null, "ar") . ' | ' . $formattedDate . ' | ' . $translator->trans(ucfirst($ewsNotification->getAlertType()?->getColor()) . ' Alert', [], null, "ar") . ' | ' . $ewsNotification->getWeatherPhenomenon()?->getTitle("ar");
  629.         $ewsNotification->setEwsSearchId($searchIdEn, "en");
  630.         $ewsNotification->setEwsSearchId($searchIdAr, "ar");
  632.         // // When publishing an updated alert to Twitter, generate Alert History image via wkhtmltoimage.
  633.         // if ($enableTwitterNotification && $templating) {
  634.         //     try {
  635.         //         $historyLang = method_exists($translator, 'getLocale') ? (string) $translator->getLocale() : 'en';
  636.         //         $historyAsset = $this->generateAlertHistoryTwitterImage(
  637.         //             $ewsNotification,
  638.         //             $templating,
  639.         //             $logger,
  640.         //             !empty($alertActionId),
  641.         //             $translator,
  642.         //             $historyLang
  643.         //         );
  644.         //         if ($historyAsset) {
  645.         //             $ewsNotification->setXHistoryAtachment($historyAsset);
  646.         //         }
  647.         //     } catch (\Throwable $e) {
  648.         //         $logger->error('Failed to generate EWS alert history Twitter image: ' . $e->getMessage());
  649.         //     }
  650.         // }
  652.         // Allow TwitterEventListner to post again when republishing an updated alert.
  653.         if ($isPublished && $enableTwitterNotification && $ewsNotification->isPublished(true)) {
  654.             $ewsNotification->setTwitterId('');
  655.             $ewsNotification->setTwitterLog('');
  656.         }
  658.         // Persist the selected user groups so the End alert can email the same groups later.
  659.         if (!empty($userGroupIds)) {
  660.             $groups = [];
  661.             foreach ($userGroupIds as $gid) {
  662.                 $group = EwsAndReportUserGroup::getById($gid, true);
  663.                 if ($group instanceof EwsAndReportUserGroup) {
  664.                     $groups[] = $group;
  665.                 }
  666.             }
  667.             $ewsNotification->setUserGroup($groups);
  668.         }
  670.         $ewsNotification->save(["versionNote" => "Update"]);
  672.         $this->saveUserMessageSuggestions(
  673.             (int) $userInterface->getId(),
  674.             $message
  675.         );
  677.         if ($this->shouldDispatchPublicPortalEwsWebhook($ewsNotification)) {
  678.             $this->dispatchPublicPortalEwsWebhookIfConfigured((int) $ewsNotification->getId(), $logger);
  679.         }
  681.         if ($isPublished) {
  682.             // send email
  683.             // Ensure you use 'php' to execute the command.
  685.             $jsonUserGroupIds = json_encode($userGroupIds);
  686.             $process = new Process(['php', 'bin/console', 'app:send-early-warning-alert-email', '--alertId=' . $ewsNotification->getId(), '--userGroupIds=' . $jsonUserGroupIds]);
  687.             $process->setWorkingDirectory(PIMCORE_PROJECT_ROOT);
  689.             try {
  690.                 $process->mustRun();
  691.                 $result['success'] = true;
  692.                 $logger->info("update EwsNotification command executed successfully: " . $process->getOutput());
  693.                 $result['message'] = $process->getOutput();
  694.             } catch (ProcessFailedException $exception) {
  695.                 $logger->error("update EwsNotification command failed: " . $exception->getMessage());
  696.                 return ['success' => false, 'message' => $exception->getMessage()];
  697.             }
  698.         }
  700.         return ['success' => true, 'message' => $translator->trans('ews_notification_updated_successifully'), "notification_id" => $ewsNotification->getId()];
  701.         // } catch (\Exception $ex) {
  702.         //     $result = ['success' => false, 'message' => $ex->getMessage()];
  703.         // }
  705.         return $result;
  706.     }
  708.     public function governorateByRegion($regionId)
  709.     {
  710.         $governorateArr = [];
  711.         $governorateList = new DataObject\Governorate\Listing();
  712.         $governorateList->setCondition('regionId__id = ?', $regionId);
  713.         $governorateList->load();
  714.         if (!empty($governorateList)) {
  716.             foreach ($governorateList as $governorate) {
  717.                 array_push($governorateArr, $governorate);
  718.             }
  719.         }
  720.         return $governorateArr;
  721.     }
  723.     public function notificationListing($params, $paginator, $translator): array
  724.     {
  725.         $response = [];
  727.         // try {
  729.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  730.         $page = isset($params['page']) ? $params['page'] : 1;
  732.         $notificationList = new DataObject\EwsNotification\Listing();
  733.         // $notificationList->setOffset(!empty($params['offset']) ? $params['offset'] : 0);
  734.         // $notificationList->setLimit(!empty($params['limit']) ? $params['limit'] : LIMIT_PER_PAGE);
  735.         $notificationList->setOrderKey("o_creationDate");
  736.         $notificationList->setOrder("desc");
  737.         $notificationList->setUnpublished(true);
  738.         if ($params['unpublished'] == false) {
  739.             $notificationList->filterByPublished(true);
  740.         } else {
  741.             $notificationList->filterByPublished(false);
  742.         }
  744.         $notificationList->setOrder("desc");
  746.         if (isset($params['region']) && !empty($params['region'])) {
  747.             $regionSql = null;
  748.             $alertRegion = \Pimcore\Model\DataObject\Region::getByRegionId($params['region'], true);
  749.             if ($alertRegion) {
  750.                 $regionSql .= "region__id = " . $alertRegion->getId() . " OR ";
  751.             }
  752.             $notificationList->addConditionParam("(" . substr($regionSql, 0, -3) . ")");
  753.         }
  754.         if (isset($params['status']) && !empty($params['status'])) {
  755.             $notificationList->addConditionParam("status IN (?)", [$params['status']]);
  756.         }
  757.         if (isset($params['addressCmp']) && !empty($params['addressCmp'])) {
  759.             //TODO
  761.         }
  762.         if (isset($params['start_date']) && !empty($params['start_date'])  && isset($params['end_date']) && !empty($params['end_date'])) {
  763.             $notificationList->filterByStartDate(strtotime($params['start_date']), ">=");
  764.             $notificationList->filterByEndDate(strtotime($params['end_date']), "<=");
  765.         }
  767.         if (isset($params['fromDate']) && isset($params['toDate']) && !empty($params['fromDate']) && !empty($params['toDate'])) {
  768.             $fromDate = new \DateTime($params['fromDate']);
  769.             $toDate = new \DateTime($params['toDate']);
  771.             // Ensure the dates are in the correct format
  772.             $fromDateStr = strtotime($fromDate->format('Y-m-d H:i:s'));
  773.             $toDateStr = strtotime($toDate->format('Y-m-d') . ' 23:59:59');
  775.             $notificationList->addConditionParam(
  776.                 "(o_creationDate >= ? AND o_creationDate <= ?)",
  777.                 [$fromDateStr, $toDateStr]
  778.             );
  779.         }
  781.         $notificationList->load();
  784.         if ($notificationList) {
  785.             foreach ($notificationList as $notification) {
  786.                 $response[] = $this->createNotificationFormat($notification, $translator);
  787.             }
  788.         }
  789.         if ($paginator == null) {
  790.             return ["success" => TRUE, "data" => $response];
  791.         }
  792.         $paginator = $paginator->paginate(
  793.             $response,
  794.             $page,
  795.             $pageSize
  796.         );
  798.         return ["success" => TRUE, "data" => $paginator, "paginationVariables" => $paginator->getPaginationData()];
  799.         // return $response;
  800.         // } catch (\Exception $ex) {
  801.         //     $result = ["success" => false, "message" => $ex->getMessage()];
  802.         // }
  804.         // return $result;
  805.     }
  807.     public function capAlertNotificationListingxml($request, $params, $lang, $translator)
  808.     {
  810.         try {
  812.             $notificationList = new DataObject\EwsNotification\Listing();
  815.             // Get the timezone for date operations
  816.             $timezone = new \DateTimeZone(TIMEZONE);
  818.             // Filter by pubDate if provided (format: d-m-Y, e.g., 25-12-2025)
  819.             if (isset($params['pubDate']) && !empty($params['pubDate'])) {
  820.                 $pubDateStr = $params['pubDate'];
  821.                 // Parse the date from d-m-Y format
  822.                 $pubDate = \DateTime::createFromFormat('d-m-Y', $pubDateStr, $timezone);
  823.                 if ($pubDate === false) {
  824.                     // Try alternative format Y-m-d
  825.                     $pubDate = \DateTime::createFromFormat('Y-m-d', $pubDateStr, $timezone);
  826.                 }
  828.                 if ($pubDate !== false) {
  829.                     // Set time to start of day (00:00:00)
  830.                     $pubDate->setTime(0, 0, 0);
  831.                     $startTimestamp = $pubDate->getTimestamp();
  833.                     // Set time to end of day (23:59:59)
  834.                     $pubDateEnd = clone $pubDate;
  835.                     $pubDateEnd->setTime(23, 59, 59);
  836.                     $endTimestamp = $pubDateEnd->getTimestamp();
  838.                     // Filter notifications where startDate falls within the specified date
  839.                     // Use filterByStartDate for >= start of day
  840.                     $notificationList->filterByStartDate($startTimestamp, ">=");
  841.                     // Add condition for <= end of day using addConditionParam
  842.                     $notificationList->addConditionParam("startDate <= ?", [$endTimestamp]);
  843.                 }
  844.             } else {
  845.                 $notificationList->setCondition("endDate > ?", [time()]);
  846.             }
  848.             $notificationList->setOrderKey("oo_id");
  849.             $notificationList->setOrder("desc");
  852.             // Get the current date as a DateTime object
  853.             $currentDate = new \DateTime('now', $timezone);
  854.             // Set the condition to filter for notifications where endDate is greater than the current date
  857.             // Loop through the notifications to find the last updated date
  859.             // Initialize $lastUpdatedDate with current date as default
  860.             $lastUpdatedDate = $currentDate;
  862.             foreach ($notificationList as $notification) {
  863.                 $notificationUpdatedDate = $notification->getEndDate()->setTimezone($timezone);
  865.                 if ($notificationUpdatedDate > $lastUpdatedDate) {
  866.                     $lastUpdatedDate = $notificationUpdatedDate;
  867.                 }
  868.             }
  870.             // Create an empty RSS XML structure
  871.             // $rss = new SimpleXMLElement('<rss version="2.0"/>');
  872.             $rss = new SimpleXMLElement('<?xml version="1.0" encoding="UTF-8"?><rss version="2.0"/>');
  874.             // Create the <channel> element
  875.             $channel = $rss->addChild('channel');
  878.             // Add elements inside <channel>
  879.             $channel->addChild('title', $translator->trans("Early Warning System from National Center of Meteorology, Saudi Arabia"));
  880.             $channel->addChild('link', $_ENV['BASE_URL'] . '/' . $lang . '/cap-alerts');
  881.             $channel->addChild('description', $translator->trans("Early Warning System from National Center of Meteorology, Saudi Arabia"));
  882.             $channel->addChild('language', $lang);
  883.             $channel->addChild('copyright', $translator->trans("Copyright (c) " . date('Y') . ", NCM. Licensed under Creative Commons BY 4.0"));
  884.             $channel->addChild('pubDate', $lastUpdatedDate->format('D, d M Y H:i:s \G\M\T'));
  887.             // Create the <image> element
  888.             $image = $channel->addChild('image');
  889.             $image->addChild('title', $translator->trans("Early Warning System from National Center of Meteorology, Saudi Arabia"));
  890.             $image->addChild('url', $_ENV['BASE_URL'] . '/assets/images/logo2.3.png');
  891.             $image->addChild('link', $_ENV['BASE_URL'] . '/' . $lang . '/cap-alerts');
  893.             // Create multiple <alert> elements and add them to the <alerts> element
  894.             // Create child elements and add them to the alert
  896.             foreach ($notificationList as $notification) { // Create two <alert> elements as an example
  898.                 $hazardNames = "";
  899.                 if (!empty($notification->getAlertHazard())) {
  900.                     $hazardNamesArr = [];
  901.                     foreach ($notification->getAlertHazard() as $hazard) {
  902.                         $hazardNamesArr[] = $hazard->getName($lang);
  903.                     }
  904.                     $hazardNames .= implode(", ", $hazardNamesArr);
  905.                 }
  907.                 $governorateNames = "";
  908.                 $governorateCoordinates = "";
  909.                 $governorateNamesArr = [];
  910.                 if ($notification->getGovernorate() && !empty($notification->getGovernorate())) {
  911.                     $governorateCoordinatesArr = [];
  912.                     foreach ($notification->getGovernorate() as $governorate) {
  913.                         $governorateNamesArr[] = $governorate->getName($lang);
  914.                         $governorateCoordinatesArr[] = $governorate->getLatitude() . "," . $governorate->getLongitude();
  915.                     }
  916.                     $governorateCoordinates .= implode(" ", $governorateCoordinatesArr);
  918.                     // Format governorates with "and" before the last one
  919.                     if (count($governorateNamesArr) > 1) {
  920.                         $lastGovernorate = array_pop($governorateNamesArr);
  921.                         $governorateNames = implode(" - ", $governorateNamesArr) . " - " . $lastGovernorate;
  922.                     } else {
  923.                         $governorateNames = $governorateNamesArr[0];
  924.                     }
  925.                 }
  927.                 // Get region and alert status names
  928.                 $regionName = $notification->getRegion() ? $notification->getRegion()->getName($lang) : $translator->trans("UNKNOWN");
  929.                 $alertStatusName = !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName($lang) : $translator->trans("UNKNOWN");
  930.                 // Format title
  931.                 $title =  $alertStatusName . ", " . $regionName;
  932.                 // Format dates in GMT format for description
  933.                 $startDateGMT = !empty($notification->getStartDate()) ? $notification->getStartDate()->setTimezone(new \DateTimeZone('GMT'))->format('D, d M Y H:i:s \G\M\T') : $translator->trans("UNKNOWN");
  934.                 $endDateGMT = !empty($notification->getEndDate()) ? $notification->getEndDate()->setTimezone(new \DateTimeZone('GMT'))->format('D, d M Y H:i:s \G\M\T') : $translator->trans("UNKNOWN");
  936.                 // Format description: "{Hazard names} From: {startDate GMT} To: {endDate GMT}, {Location}"
  937.                 $descriptionParts = [];
  938.                 // if (!empty($hazardNames)) {
  939.                 //     $descriptionParts[] = $hazardNames;
  940.                 // }
  941.                 $descriptionParts[] = $alertStatusName . " " . $translator->trans("From") . ": " . $startDateGMT . " " . $translator->trans("To") . ": " . $endDateGMT;
  942.                 if (!empty($governorateNames)) {
  943.                     $descriptionParts[] = ", " . $governorateNames;
  944.                 }
  945.                 $description = implode(" ", $descriptionParts);
  947.                 // Create one or more <item> elements
  948.                 $item = $channel->addChild('item');
  950.                 $item->addChild('guid', "{" . $notification->getGuid() . "}");
  952.                 $item->addChild('title', $title);
  953.                 $item->addChild('link', $_ENV['BASE_URL'] . '/cap/' . $lang . '/alerts/' . $notification->getGuid() . '.xml');
  955.                 $item->addChild('description', $description);
  956.                 $item->addChild('author', AUTHOR);
  957.                 $item->addChild('pubDate', $notification->getStartDate()->setTimeZone(new \DateTimeZone('GMT'))->format('D, d M Y H:i:s \G\M\T'));
  958.             }
  960.             // Create additional <item> elements as needed
  962.             // Format the XML for output
  963.             $dom = dom_import_simplexml($rss)->ownerDocument;
  964.             $dom->formatOutput = true;
  966.             // Save the XML to a file
  967.             $xmlString = $dom->saveXML();
  969.             // Set the Content-Type header to specify that the response is XML
  970.             header("Content-Type: application/xml");
  972.             // Save the XML to a file or output it
  973.             $xmlString = $rss->saveXML();
  974.             print $xmlString;
  975.             exit;
  976.             return $xmlString;
  977.         } catch (\Exception $ex) {
  978.             $result = ["success" => false, "message" => $ex->getMessage()];
  979.         }
  981.         return $result;
  982.     }
  984.     public function capAlertNotificationDetailxml($guid, $lang, $translator)
  985.     {
  986.         $response = [];
  987.         $timezone = new \DateTimeZone(TIMEZONE);
  989.         try {
  992.             $notification = \Pimcore\Model\DataObject\EwsNotification::getByGuid($guid, true);
  995.             if (empty($notification)) {
  996.                 throw new \Exception('Notification not found.');
  997.             }
  998.             $doc = new DomDocument('1.0', 'UTF-8');
  999.             // Create the root element
  1000.             $alert = $doc->createElement('alert');
  1001.             $alert->setAttribute('xmlns', 'urn:oasis:names:tc:emergency:cap:1.2');
  1002.             $alert->setAttribute('xmlns:xsl', 'http://www.w3.org/1999/XSL/Transform');
  1003.             $alert->setAttribute('xmlns:ds', 'http://www.w3.org/2000/09/xmldsig#');
  1004.             $doc->appendChild($alert);
  1005.             // Create child elements and add them to the alert
  1006.             $identifier = $doc->createElement('identifier',  $notification->getGuid()); //uuid
  1007.             $sender = $doc->createElement('sender', $translator->trans('NCM'));
  1008.             $sent = $doc->createElement('sent', $notification->getStartDate()->setTimezone($timezone)->format('Y-m-d\TH:i:sP'));
  1009.             $status = $doc->createElement('status', 'Actual');
  1010.             $msgType = $doc->createElement('msgType', 'Alert');
  1011.             $scope = $doc->createElement('scope', 'Public');
  1012.             $alert->appendChild($identifier);
  1013.             $alert->appendChild($sender);
  1014.             $alert->appendChild($sent);
  1015.             $alert->appendChild($status);
  1016.             $alert->appendChild($msgType);
  1017.             $alert->appendChild($scope);
  1018.             // Create the <info> element and add it to the alert
  1019.             $info = $doc->createElement('info');
  1020.             $alert->appendChild($info);
  1021.             // Create child elements for the <info> element
  1022.             $category = $doc->createElement('category', 'Met');
  1023.             $event = $doc->createElement('event', $notification->getAlertStatus() ? $notification->getAlertStatus()->getName($lang) : $translator->trans('UNKNOWN')); //high rain
  1024.             $responseType = $doc->createElement('responseType', 'None');
  1025.             $effective = $doc->createElement('effective', $notification->getStartDate()->setTimezone($timezone)->format('Y-m-d\TH:i:sP'));
  1027.             // Determine CAP urgency, severity, and certainty based on alert type and event
  1028.             $eventName = $notification->getAlertStatus() ? strtolower($notification->getAlertStatus()->getName('en')) : '';
  1029.             $alertTypeColor = $notification->getAlertType() ? strtoupper($notification->getAlertType()->getColor() ?? '') : '';
  1031.             // Determine urgency based on alert type and event severity
  1032.             // Immediate: Life-threatening, requires immediate action (RED alerts, tornadoes, etc.)
  1033.             // Expected: Forecasted events that will occur (most weather alerts)
  1034.             // Past: Events that have already occurred
  1035.             // Future: Long-term forecasts
  1036.             $urgency = 'Expected'; // Default for most weather alerts
  1037.             if ($alertTypeColor === 'RED' || stripos($eventName, 'tornado') !== false || stripos($eventName, 'extreme') !== false) {
  1038.                 $urgency = 'Immediate';
  1039.             }
  1041.             // Determine severity based on alert type color and event
  1042.             // Extreme: Widespread destruction
  1043.             // Severe: Significant threat to life/property
  1044.             // Moderate: Some threat
  1045.             // Minor: Minimal threat
  1046.             // Unknown: Severity unknown
  1047.             $severity = 'Moderate'; // Default
  1048.             if ($alertTypeColor === 'RED') {
  1049.                 $severity = 'Extreme';
  1050.             } elseif ($alertTypeColor === 'ORANGE') {
  1051.                 $severity = 'Severe';
  1052.             } elseif ($alertTypeColor === 'YELLOW') {
  1053.                 $severity = 'Moderate';
  1054.             } elseif ($alertTypeColor === 'GREEN' || stripos($eventName, 'light') !== false || stripos($eventName, 'minor') !== false) {
  1055.                 $severity = 'Minor';
  1056.             }
  1058.             // Certainty: Observed (happening now), Likely (will occur), Possible (may occur), Unlikely, Unknown
  1059.             $certainty = 'Possible'; // Default - assume observed for active alerts
  1061.             $urgencyElement = $doc->createElement('urgency', $urgency);
  1062.             $severityElement = $doc->createElement('severity', $severity);
  1063.             $certaintyElement = $doc->createElement('certainty', $certainty);
  1065.             // Remove eventCode element - SAME codes are US-specific and not applicable
  1066.             // If eventCode is needed in future, use WMO codes instead:
  1067.             // $eventCode = $doc->createElement('eventCode');
  1068.             // $eventCodeValueName = $doc->createElement('valueName', 'WMO');
  1069.             // $eventCodeValueText = $doc->createElement('value', 'FOG'); // Example WMO code
  1070.             // $eventCode->appendChild($eventCodeValueName);
  1071.             // $eventCode->appendChild($eventCodeValueText);
  1073.             // Fix: onset should use startDate (when the event begins), not endDate
  1074.             $onsetDate = $notification->getStartDate() ? $notification->getStartDate()->setTimezone($timezone) : null;
  1075.             if (!$onsetDate) {
  1076.                 // Fallback to current time if startDate is not available
  1077.                 $onsetDate = new \DateTime('now', $timezone);
  1078.             }
  1079.             $onset = $doc->createElement('onset', $onsetDate->format('Y-m-d\TH:i:sP'));
  1081.             // Fix: expires must be after onset (use endDate, ensure it's after startDate)
  1082.             $expiresDate = $notification->getEndDate() ? $notification->getEndDate()->setTimezone($timezone) : null;
  1083.             if (!$expiresDate) {
  1084.                 // Fallback: if no endDate, set expires to 24 hours after onset
  1085.                 $expiresDate = clone $onsetDate;
  1086.                 $expiresDate->modify('+24 hours');
  1087.             } else {
  1088.                 // Ensure expires is after onset (CAP requirement)
  1089.                 if ($expiresDate <= $onsetDate) {
  1090.                     // If expires equals or is before onset, add at least 1 hour
  1091.                     $expiresDate = clone $onsetDate;
  1092.                     $expiresDate->modify('+1 hour');
  1093.                 }
  1094.             }
  1095.             $expires = $doc->createElement('expires', $expiresDate->format('Y-m-d\TH:i:sP'));
  1096.             $senderName = $doc->createElement('senderName', $translator->trans('NCM'));
  1097.             $headline = $doc->createElement('headline', $notification->getAlertType()->getName($lang) . ', ' .  $notification->getAlertStatus()->getName($lang));
  1098.             // $headline = $doc->createElement(
  1099.             //     'headline',
  1100.             //     $translator->trans('Early Warning Alert in') . ' ' .
  1101.             //     (
  1102.             //         $notification->getRegion()
  1103.             //             ? $notification->getRegion()->getName($lang)
  1104.             //             : $translator->trans('UNKNOWN')
  1105.             //     ) . ': ' .
  1106.             //     (
  1107.             //         $notification->getAlertStatus()
  1108.             //             ? $notification->getAlertStatus()->getName($lang)
  1109.             //             : $translator->trans('UNKNOWN')
  1110.             //     )
  1111.             // );
  1113.             $hazardNames = "";
  1114.             if (!empty($notification->getAlertHazard())) {
  1115.                 $hazardNamesArr = [];
  1116.                 foreach ($notification->getAlertHazard() as $hazard) {
  1117.                     $hazardNamesArr[] = $hazard->getName($lang);
  1118.                 }
  1119.                 $hazardNames .= implode(", ", $hazardNamesArr);
  1120.             }
  1122.             $governorateNames = "";
  1123.             $governorateCoordinates = "";
  1124.             $governorateNamesArr = [];
  1125.             if ($notification->getGovernorate() && !empty($notification->getGovernorate())) {
  1126.                 $governorateCoordinatesArr = [];
  1127.                 foreach ($notification->getGovernorate() as $governorate) {
  1128.                     $governorateNamesArr[] = $governorate->getName($lang);
  1129.                     $governorateCoordinatesArr[] = $governorate->getLatitude() . "," . $governorate->getLongitude();
  1130.                 }
  1131.                 // Format governorates with "و" for Arabic or "and" for English before the last one
  1132.                 if (count($governorateNamesArr) > 1) {
  1133.                     $lastGovernorate = array_pop($governorateNamesArr);
  1134.                     $andText = ($lang == 'ar') ? ' و ' : ', and ';
  1135.                     $governorateNames = implode(", ", $governorateNamesArr) . $andText . $lastGovernorate;
  1136.                 } else {
  1137.                     $governorateNames = $governorateNamesArr[0];
  1138.                 }
  1139.                 $governorateCoordinates .= implode(" ", $governorateCoordinatesArr);
  1140.             }
  1142.             // Get region and alert status names
  1143.             $regionName = $notification->getRegion() ? $notification->getRegion()->getName($lang) : $translator->trans("UNKNOWN");
  1144.             $alertStatusName = $notification->getAlertStatus() ? $notification->getAlertStatus()->getName($lang) : $translator->trans("UNKNOWN");
  1146.             // Format dates
  1147.             $startDateFormatted = !empty($notification->getStartDate()) ? $notification->getStartDate()->setTimezone($timezone)->format('d/m/Y H:i:s A') : $translator->trans("UNKNOWN");
  1148.             $endDateFormatted = !empty($notification->getEndDate()) ? $notification->getEndDate()->setTimezone($timezone)->format("d/m/Y H:i:s A") : $translator->trans("UNKNOWN");
  1150.             // Format description: Comma-separated list of hazard names (e.g., "Raised dust, Active winds,Near lack of horizontal visibility (1-3) km")
  1151.             $descriptionText = !empty($hazardNames) ? $hazardNames : "";
  1153.             $description = $doc->createElement('description', $notification->getAlertStatus()->getName($lang) . ' ' . $descriptionText);
  1155.             // Create actionable instruction based on alert type and hazards (CAP compliance)
  1156.             // Handle multiple hazards by checking all types and combining instructions
  1157.             $instructionText = '';
  1158.             if (!empty($hazardNames)) {
  1159.                 $instructions = [];
  1160.                 $hazardNamesLower = strtolower($hazardNames);
  1162.                 // Check for all hazard types and collect relevant instructions
  1163.                 // Priority hazards first
  1164.                 if (stripos($hazardNames, 'tornado') !== false || stripos($hazardNames, 'إعصار') !== false) {
  1165.                     $instructions[] = ($lang == 'ar')
  1166.                         ? 'انتقل فوراً إلى أقرب ملجأ أو الطابق السفلي. تجنب النوافذ والمناطق المكشوفة.'
  1167.                         : 'Move immediately to the nearest shelter or basement. Avoid windows and exposed areas.';
  1168.                 }
  1170.                 if (
  1171.                     stripos($hazardNames, 'rain') !== false || stripos($hazardNames, 'مطر') !== false ||
  1172.                     stripos($hazardNames, 'flood') !== false || stripos($hazardNames, 'فيضان') !== false ||
  1173.                     stripos($hazardNames, 'pooling') !== false || stripos($hazardNames, 'تجمع') !== false
  1174.                 ) {
  1175.                     $instructions[] = ($lang == 'ar')
  1176.                         ? 'انتقل إلى أرض مرتفعة لتجنب الفيضانات. تجنب القيادة في المناطق المغمورة.'
  1177.                         : 'Move to higher ground to avoid flooding. Avoid driving through flooded areas.';
  1178.                 }
  1180.                 if (stripos($hazardNames, 'wave') !== false || stripos($hazardNames, 'موجة') !== false) {
  1181.                     $instructions[] = ($lang == 'ar')
  1182.                         ? 'تجنب المناطق الساحلية والأنشطة البحرية. ابق بعيداً عن الشواطئ.'
  1183.                         : 'Avoid coastal areas and marine activities. Stay away from beaches.';
  1184.                 }
  1186.                 if (stripos($hazardNames, 'wind') !== false || stripos($hazardNames, 'رياح') !== false) {
  1187.                     $instructions[] = ($lang == 'ar')
  1188.                         ? 'تجنب الخروج من المنزل وتأكد من إغلاق النوافذ والأبواب بإحكام. تجنب القيادة إذا أمكن.'
  1189.                         : 'Avoid going outside and ensure windows and doors are securely closed. Avoid driving if possible.';
  1190.                 }
  1192.                 if (stripos($hazardNames, 'thunder') !== false || stripos($hazardNames, 'رعد') !== false) {
  1193.                     $instructions[] = ($lang == 'ar')
  1194.                         ? 'تجنب المناطق المكشوفة والبقاء في الداخل. تجنب استخدام الأجهزة الإلكترونية والمياه.'
  1195.                         : 'Avoid exposed areas and stay indoors. Avoid using electronic devices and water.';
  1196.                 }
  1198.                 if (stripos($hazardNames, 'hail') !== false || stripos($hazardNames, 'برد') !== false) {
  1199.                     $instructions[] = ($lang == 'ar')
  1200.                         ? 'ابق في الداخل وتجنب النوافذ. إذا كنت في الخارج، ابحث عن مأوى فوري.'
  1201.                         : 'Stay indoors and avoid windows. If outside, seek immediate shelter.';
  1202.                 }
  1204.                 if (
  1205.                     stripos($hazardNames, 'visibility') !== false || stripos($hazardNames, 'رؤية') !== false ||
  1206.                     stripos($hazardNames, 'fog') !== false || stripos($hazardNames, 'ضباب') !== false ||
  1207.                     stripos($hazardNames, 'low visibility') !== false || stripos($hazardNames, 'lack of horizontal visibility') !== false
  1208.                 ) {
  1209.                     $instructions[] = ($lang == 'ar')
  1210.                         ? 'تجنب القيادة إلا للضرورة القصوى. إذا كنت تقود، استخدم الأضواء المنخفضة واتبع المسافة الآمنة.'
  1211.                         : 'Avoid driving except in emergencies. If driving, use low beams and maintain safe distance.';
  1212.                 }
  1214.                 if (stripos($hazardNames, 'snow') !== false || stripos($hazardNames, 'ثلج') !== false) {
  1215.                     $instructions[] = ($lang == 'ar')
  1216.                         ? 'تجنب السفر غير الضروري. إذا كنت في الخارج، ارتدِ ملابس دافئة وتجنب الطرق الزلقة.'
  1217.                         : 'Avoid unnecessary travel. If outside, wear warm clothing and avoid slippery roads.';
  1218.                 }
  1220.                 if (
  1221.                     stripos($hazardNames, 'frost') !== false || stripos($hazardNames, 'صقيع') !== false ||
  1222.                     (stripos($hazardNames, 'temperature') !== false && stripos($hazardNames, 'drop') !== false) ||
  1223.                     (stripos($hazardNames, 'درجة') !== false && stripos($hazardNames, 'انخفاض') !== false) ||
  1224.                     stripos($hazardNames, 'below zero') !== false
  1225.                 ) {
  1226.                     $instructions[] = ($lang == 'ar')
  1227.                         ? 'احمِ نفسك من البرد الشديد. ارتدِ ملابس دافئة وتجنب التعرض الطويل للطقس البارد.'
  1228.                         : 'Protect yourself from extreme cold. Wear warm clothing and avoid prolonged exposure to cold weather.';
  1229.                 }
  1231.                 if ((stripos($hazardNames, 'rise') !== false && stripos($hazardNames, 'temperature') !== false) ||
  1232.                     (stripos($hazardNames, 'ارتفاع') !== false && stripos($hazardNames, 'درجة') !== false) ||
  1233.                     stripos($hazardNames, 'degrees Celsius') !== false || stripos($hazardNames, 'درجة مئوية') !== false
  1234.                 ) {
  1235.                     $instructions[] = ($lang == 'ar')
  1236.                         ? 'احمِ نفسك من الحرارة الشديدة. ابق في أماكن مكيفة، اشرب الكثير من الماء، وتجنب الأنشطة الخارجية.'
  1237.                         : 'Protect yourself from extreme heat. Stay in air-conditioned areas, drink plenty of water, and avoid outdoor activities.';
  1238.                 }
  1240.                 // Combine all instructions or use default
  1241.                 if (!empty($instructions)) {
  1242.                     // Remove duplicates and combine with appropriate separator
  1243.                     $uniqueInstructions = array_unique($instructions);
  1244.                     $separator = ($lang == 'ar') ? ' ' : ' ';
  1245.                     $instructionText = implode($separator, $uniqueInstructions);
  1246.                 } else {
  1247.                     $instructionText = ($lang == 'ar')
  1248.                         ? 'اتخذ الاحتياطات اللازمة واتبع التعليمات الرسمية. ابق في مكان آمن.'
  1249.                         : 'Take necessary precautions and follow official instructions. Stay in a safe place.';
  1250.                 }
  1251.             } else {
  1252.                 // Default instruction if no specific hazards
  1253.                 $instructionText = ($lang == 'ar')
  1254.                     ? 'اتخذ الاحتياطات اللازمة واتبع التعليمات الرسمية من المركز الوطني للأرصاد.'
  1255.                     : 'Take necessary precautions and follow official instructions from the National Center of Meteorology.';
  1256.             }
  1257.             $instruction = $doc->createElement('instruction', $instructionText);
  1259.             $contact = $doc->createElement('contact', CONTACT);
  1261.             // Create dynamic web URL using notification ID (CAP compliance - absolute HTTPS URL)
  1262.             $web = $doc->createElement('web', htmlspecialchars($_ENV['PUBLIC_PORTAL_URL'] . $lang . '/test-early-warning/' . $notification->getId(), ENT_XML1, 'UTF-8'));
  1264.             $info->appendChild($category);
  1265.             $info->appendChild($event);
  1266.             $info->appendChild($responseType);
  1267.             $info->appendChild($urgencyElement);
  1268.             $info->appendChild($severityElement);
  1269.             $info->appendChild($certaintyElement);
  1270.             // eventCode removed - SAME codes are US-specific
  1271.             $info->appendChild($effective);
  1272.             $info->appendChild($onset);
  1273.             $info->appendChild($expires);
  1274.             $info->appendChild($senderName);
  1275.             $info->appendChild($headline);
  1276.             $info->appendChild($description);
  1277.             $info->appendChild($instruction);
  1278.             $info->appendChild($web);
  1279.             $info->appendChild($contact);
  1282.             // Get polygon coordinates from JSON lookup sheet - returns array of polygons per governorate
  1283.             $governoratePolygons = [];
  1285.             // Try to get polygons from the JSON lookup sheet first
  1286.             if ($notification->getGovernorate() && !empty($notification->getGovernorate())) {
  1287.                 // Convert collection to array if needed
  1288.                 $governorates = $notification->getGovernorate();
  1289.                 if (is_object($governorates) && method_exists($governorates, 'getItems')) {
  1290.                     $governorates = $governorates->getItems();
  1291.                 } elseif (!is_array($governorates)) {
  1292.                     $governorates = iterator_to_array($governorates);
  1293.                 }
  1294.                 if (!empty($governorates)) {
  1295.                     $governoratePolygons = $this->getPolygonFromJsonSheet($governorates);
  1296.                 }
  1297.             }
  1299.             // Fallback to notification coordinates if JSON lookup didn't provide polygons
  1300.             if (empty($governoratePolygons)) {
  1301.                 $coordinatesString = $notification->getCoordinates();
  1303.                 if (!empty($coordinatesString)) {
  1304.                     // Try to parse as JSON (GeoJSON format)
  1305.                     $coordinatesData = json_decode($coordinatesString, true);
  1307.                     if (json_last_error() === JSON_ERROR_NONE && is_array($coordinatesData)) {
  1308.                         // Handle GeoJSON format: coordinates can be in various structures
  1309.                         // [[[lng, lat], [lng, lat], ...]] for Polygon
  1310.                         // [[lng, lat], [lng, lat], ...] for LineString
  1311.                         // [lng, lat] for Point
  1312.                         $coordArray = [];
  1314.                         if (isset($coordinatesData['type']) && $coordinatesData['type'] === 'Polygon' && isset($coordinatesData['coordinates'])) {
  1315.                             // GeoJSON Polygon format
  1316.                             $coordArray = $coordinatesData['coordinates'][0] ?? [];
  1317.                         } elseif (isset($coordinatesData['type']) && $coordinatesData['type'] === 'LineString' && isset($coordinatesData['coordinates'])) {
  1318.                             // GeoJSON LineString format
  1319.                             $coordArray = $coordinatesData['coordinates'];
  1320.                         } elseif (is_array($coordinatesData) && isset($coordinatesData[0])) {
  1321.                             // Nested array format: [[[lng, lat], ...]] or [[lng, lat], ...]
  1322.                             if (is_array($coordinatesData[0]) && is_array($coordinatesData[0][0])) {
  1323.                                 // [[[lng, lat], ...]] - take first ring
  1324.                                 $coordArray = $coordinatesData[0];
  1325.                             } elseif (is_array($coordinatesData[0]) && count($coordinatesData[0]) >= 2 && is_numeric($coordinatesData[0][0])) {
  1326.                                 // [[lng, lat], ...]
  1327.                                 $coordArray = $coordinatesData;
  1328.                             }
  1329.                         }
  1331.                         // Process coordinate array
  1332.                         if (!empty($coordArray)) {
  1333.                             $polygon = '';
  1334.                             $firstCoordinate = null;
  1335.                             foreach ($coordArray as $coord) {
  1336.                                 if (is_array($coord) && count($coord) >= 2) {
  1337.                                     $lng = (float)$coord[0];
  1338.                                     $lat = (float)$coord[1];
  1340.                                     // CAP polygon format: "lat,lng lat,lng ..." (note: lat first, then lng)
  1341.                                     // Format with 6 decimal places as per client requirement
  1342.                                     $coordString = number_format($lat, 6, '.', '') . "," . number_format($lng, 6, '.', '');
  1344.                                     if ($firstCoordinate === null) {
  1345.                                         $firstCoordinate = $coordString;
  1346.                                     }
  1347.                                     $polygon .= $coordString . ' ';
  1348.                                 }
  1349.                             }
  1351.                             // Remove the trailing space
  1352.                             $polygon = rtrim($polygon);
  1354.                             // Validate and ensure polygon is closed
  1355.                             if (!empty(trim($polygon)) && $firstCoordinate !== null) {
  1356.                                 $polygonTrimmed = trim($polygon);
  1357.                                 $coords = explode(' ', $polygonTrimmed);
  1358.                                 $uniqueCoords = array_unique($coords);
  1360.                                 // Check if we have at least 4 distinct points
  1361.                                 if (count($uniqueCoords) >= 4) {
  1362.                                     // Ensure polygon is closed (first coordinate = last coordinate) - CAP compliance requirement
  1363.                                     $lastCoordinate = end($coords);
  1364.                                     if ($lastCoordinate !== $firstCoordinate) {
  1365.                                         $polygon .= ' ' . $firstCoordinate;
  1366.                                     }
  1367.                                     // Create a single polygon entry for fallback
  1368.                                     $governoratePolygons[] = [
  1369.                                         'governorate' => null,
  1370.                                         'nameEn' => null,
  1371.                                         'nameAr' => null,
  1372.                                         'polygon' => $polygon
  1373.                                     ];
  1374.                                 }
  1375.                             }
  1376.                         }
  1377.                     } else {
  1378.                         // Fallback: try to parse as string format "[[lat,lng],[lat,lng],...]"
  1379.                         $coordinatesString = trim($coordinatesString, '[]');
  1380.                         $coordinates = explode("],[", $coordinatesString);
  1382.                         $polygon = '';
  1383.                         $firstCoordinate = null;
  1384.                         foreach ($coordinates as $coordinate) {
  1385.                             $parts = explode(",", trim($coordinate, '[]'));
  1386.                             if (count($parts) >= 2 && is_numeric($parts[0]) && is_numeric($parts[1])) {
  1387.                                 $lat = (float)$parts[0];
  1388.                                 $lng = (float)$parts[1];
  1389.                                 // Format with 6 decimal places as per client requirement
  1390.                                 $coordString = number_format($lat, 6, '.', '') . "," . number_format($lng, 6, '.', '');
  1392.                                 if ($firstCoordinate === null) {
  1393.                                     $firstCoordinate = $coordString;
  1394.                                 }
  1395.                                 $polygon .= $coordString . ' ';
  1396.                             }
  1397.                         }
  1399.                         // Remove the trailing space and validate
  1400.                         $polygon = rtrim($polygon);
  1401.                         if (!empty(trim($polygon)) && $firstCoordinate !== null) {
  1402.                             $polygonTrimmed = trim($polygon);
  1403.                             $coords = explode(' ', $polygonTrimmed);
  1404.                             $uniqueCoords = array_unique($coords);
  1406.                             if (count($uniqueCoords) >= 4) {
  1407.                                 $lastCoordinate = end($coords);
  1408.                                 if ($lastCoordinate !== $firstCoordinate) {
  1409.                                     $polygon .= ' ' . $firstCoordinate;
  1410.                                 }
  1411.                                 $governoratePolygons[] = [
  1412.                                     'governorate' => null,
  1413.                                     'nameEn' => null,
  1414.                                     'nameAr' => null,
  1415.                                     'polygon' => $polygon
  1416.                                 ];
  1417.                             }
  1418.                         }
  1419.                     }
  1420.                 }
  1421.             }
  1423.             // Create area elements - one for each governorate polygon (separate polygons, not merged)
  1424.             // Each governorate gets its own <area> element with its own <polygon>, even if from the same region
  1425.             if (!empty($governoratePolygons)) {
  1426.                 foreach ($governoratePolygons as $govPolygon) {
  1427.                     $area = $doc->createElement('area');
  1428.                     $info->appendChild($area);
  1430.                     // Create areaDesc for this governorate (format: "Region region - GovernorateName")
  1431.                     $areaDescText = '';
  1432.                     if ($lang == 'ar') {
  1433.                         $areaDescText = "منطقة " . $regionName;
  1434.                         if (!empty($govPolygon['nameAr'])) {
  1435.                             $areaDescText .= " - " . $govPolygon['nameAr'];
  1436.                         }
  1437.                     } else {
  1438.                         $areaDescText = $regionName . " " . $translator->trans("region");
  1439.                         if (!empty($govPolygon['nameEn'])) {
  1440.                             $areaDescText .= " - " . $govPolygon['nameEn'];
  1441.                         }
  1442.                     }
  1443.                     // Note: Removed $notification->getMessage() to match the required format
  1444.                     $areaDesc = $doc->createElement('areaDesc', $areaDescText . ' : ' . $translator->trans('The entire governorate'));
  1446.                     // Validate and create polygon element for this specific governorate
  1447.                     $polygon = $govPolygon['polygon'];
  1448.                     if (!empty(trim($polygon))) {
  1449.                         $polygonTrimmed = trim($polygon);
  1450.                         $coords = explode(' ', $polygonTrimmed);
  1451.                         $uniqueCoords = array_unique($coords);
  1453.                         // Check if we have at least 4 distinct points
  1454.                         if (count($uniqueCoords) >= 4) {
  1455.                             // Ensure polygon is closed (first coordinate = last coordinate) - CAP compliance requirement
  1456.                             $firstCoord = $coords[0];
  1457.                             $lastCoord = end($coords);
  1458.                             if ($lastCoord !== $firstCoord) {
  1459.                                 $polygon .= ' ' . $firstCoord;
  1460.                             }
  1461.                             $polygonElement = $doc->createElement('polygon', $polygon);
  1462.                         } else {
  1463.                             // Not enough distinct points - create a bounding box for this specific governorate
  1464.                             // Use governorate-specific coordinates if available
  1465.                             $govSpecificCoords = '';
  1466.                             if (is_object($govPolygon['governorate']) && method_exists($govPolygon['governorate'], 'getLatitude')) {
  1467.                                 $govLat = $govPolygon['governorate']->getLatitude();
  1468.                                 $govLng = $govPolygon['governorate']->getLongitude();
  1469.                                 if (is_numeric($govLat) && is_numeric($govLng)) {
  1470.                                     $govSpecificCoords = number_format($govLat, 6, '.', '') . ',' . number_format($govLng, 6, '.', '');
  1471.                                 }
  1472.                             }
  1473.                             $polygonElement = $this->createFallbackPolygon($doc, $notification, $govSpecificCoords, $timezone);
  1474.                         }
  1475.                     } else {
  1476.                         // No valid coordinates - create fallback polygon for this specific governorate
  1477.                         $govSpecificCoords = '';
  1478.                         if (is_object($govPolygon['governorate']) && method_exists($govPolygon['governorate'], 'getLatitude')) {
  1479.                             $govLat = $govPolygon['governorate']->getLatitude();
  1480.                             $govLng = $govPolygon['governorate']->getLongitude();
  1481.                             if (is_numeric($govLat) && is_numeric($govLng)) {
  1482.                                 $govSpecificCoords = number_format($govLat, 6, '.', '') . ',' . number_format($govLng, 6, '.', '');
  1483.                             }
  1484.                         }
  1485.                         $polygonElement = $this->createFallbackPolygon($doc, $notification, $govSpecificCoords, $timezone);
  1486.                     }
  1488.                     $area->appendChild($areaDesc);
  1489.                     $area->appendChild($polygonElement);
  1490.                 }
  1491.             } else {
  1492.                 // No polygons found - create a single fallback area
  1493.                 $area = $doc->createElement('area');
  1494.                 $info->appendChild($area);
  1496.                 // Create child elements for the <area> element
  1497.                 if ($lang == 'ar') {
  1498.                     $areaDescText = "منطقة " . $regionName;
  1499.                 } else {
  1500.                     $areaDescText = $regionName . " " . $translator->trans("region");
  1501.                 }
  1502.                 if (!empty($governorateNames)) {
  1503.                     $areaDescText .= " " . $translator->trans("including") . " " . $governorateNames;
  1504.                 }
  1505.                 $areaDescText .= $notification->getMessage();
  1506.                 $areaDesc = $doc->createElement('areaDesc', $areaDescText);
  1508.                 $polygonElement = $this->createFallbackPolygon($doc, $notification, $governorateCoordinates, $timezone);
  1510.                 $area->appendChild($areaDesc);
  1511.                 $area->appendChild($polygonElement);
  1512.             }
  1514.             // Add XML stylesheet reference (CAP compliance)
  1515.             $stylesheet = $doc->createProcessingInstruction('xml-stylesheet', 'type="text/xsl" href="https://ncm.gov.sa/assets/styles/cap.xsl"');
  1516.             $doc->insertBefore($stylesheet, $alert);
  1518.             // Add digital signature structure (placeholder - CAP compliance recommendation)
  1519.             // Note: This is a placeholder. For production, implement real XML digital signatures
  1520.             $dsSignature = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:Signature');
  1522.             // Create SignedInfo element
  1523.             $dsSignedInfo = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:SignedInfo');
  1525.             // CanonicalizationMethod
  1526.             $dsCanonicalizationMethod = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:CanonicalizationMethod');
  1527.             $dsCanonicalizationMethod->setAttribute('Algorithm', 'http://www.w3.org/2001/10/xml-exc-c14n#');
  1528.             $dsSignedInfo->appendChild($dsCanonicalizationMethod);
  1530.             // SignatureMethod
  1531.             $dsSignatureMethod = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:SignatureMethod');
  1532.             $dsSignatureMethod->setAttribute('Algorithm', 'http://www.w3.org/2001/04/xmldsig-more#rsa-sha256');
  1533.             $dsSignedInfo->appendChild($dsSignatureMethod);
  1535.             // Reference - Empty URI for enveloped signature (signs the parent document)
  1536.             $dsReference = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:Reference');
  1537.             $dsReference->setAttribute('URI', '');
  1539.             // Transforms
  1540.             $dsTransforms = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:Transforms');
  1541.             $dsTransform = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:Transform');
  1542.             $dsTransform->setAttribute('Algorithm', 'http://www.w3.org/2000/09/xmldsig#enveloped-signature');
  1543.             $dsTransforms->appendChild($dsTransform);
  1544.             $dsReference->appendChild($dsTransforms);
  1546.             // DigestMethod
  1547.             $dsDigestMethod = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:DigestMethod');
  1548.             $dsDigestMethod->setAttribute('Algorithm', 'http://www.w3.org/2001/04/xmlenc#sha256');
  1549.             $dsReference->appendChild($dsDigestMethod);
  1551.             // DigestValue - Generate hash from notification data (placeholder)
  1552.             $digestData = $notification->getGuid() . '_' . $notification->getId() . '_' . time();
  1553.             $digestHash = hash('sha256', $digestData, true);
  1554.             $digestValue = base64_encode($digestHash);
  1555.             $dsDigestValue = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:DigestValue', $digestValue);
  1556.             $dsReference->appendChild($dsDigestValue);
  1558.             $dsSignedInfo->appendChild($dsReference);
  1559.             $dsSignature->appendChild($dsSignedInfo);
  1561.             // SignatureValue - Generate base64-encoded signature-like value
  1562.             $signatureData = $notification->getGuid() . '_' . $notification->getId() . '_' . time();
  1563.             $hash = hash('sha256', $signatureData, true);
  1564.             // Generate additional random bytes to create a signature-like length (RSA-2048 signature is ~256 bytes)
  1565.             $randomBytes = random_bytes(192); // 192 + 32 (sha256) = 224 bytes, base64 = ~300 chars
  1566.             $combinedBytes = $hash . $randomBytes;
  1567.             $uniqueSignatureValue = base64_encode($combinedBytes);
  1568.             $dsSignatureValue = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:SignatureValue', $uniqueSignatureValue);
  1569.             $dsSignature->appendChild($dsSignatureValue);
  1571.             // KeyInfo
  1572.             $dsKeyInfo = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:KeyInfo');
  1573.             $dsKeyName = $doc->createElementNS('http://www.w3.org/2000/09/xmldsig#', 'ds:KeyName', 'NCM-Public-Key');
  1574.             $dsKeyInfo->appendChild($dsKeyName);
  1575.             $dsSignature->appendChild($dsKeyInfo);
  1577.             $alert->appendChild($dsSignature);
  1579.             // Save the XML to a file or output it
  1580.             $xmlString = $doc->saveXML();
  1582.             print $xmlString;
  1583.             exit;
  1584.             return $xmlString;
  1585.         } catch (\Exception $ex) {
  1586.             $result = ["success" => false, "message" => $ex->getMessage()];
  1587.         }
  1589.         return $result;
  1590.     }
  1592.     /**
  1593.      * Get polygon coordinates from JSON lookup sheet for given governorates
  1594.      * 
  1595.      * This method validates and formats latitude/longitude coordinates to exactly 6 decimal places
  1596.      * as required by CAP specification. The JSON file contains the official polygon boundaries
  1597.      * for Saudi Arabia governorates, and coordinates are validated and standardized here.
  1598.      * 
  1599.      * Returns separate polygons for each governorate (not merged)
  1600.      * 
  1601.      * @param array $governorates Array of Governorate objects
  1602.      * @return array Array of arrays with 'governorate', 'nameEn', 'nameAr', and 'polygon' keys
  1603.      */
  1604.     private function getPolygonFromJsonSheet($governorates)
  1605.     {
  1606.         $governoratePolygons = [];
  1607.         // JSON file path containing validated polygon boundaries with coordinates
  1608.         // Use only ksa_governorate_boundaries.geojson file
  1609.         $jsonFilePath = PIMCORE_PROJECT_ROOT . '/public/import/ksa_governorate_boundaries.geojson';
  1611.         // Check if file exists
  1612.         if (!file_exists($jsonFilePath)) {
  1613.             error_log("getPolygonFromJsonSheet: JSON file not found at: " . $jsonFilePath);
  1614.             return [];
  1615.         }
  1617.         // Load JSON file content
  1618.         $jsonContent = file_get_contents($jsonFilePath);
  1619.         if ($jsonContent === false) {
  1620.             error_log("getPolygonFromJsonSheet: Failed to read JSON file");
  1621.             return [];
  1622.         }
  1624.         // Try to decode JSON with increased depth limit for large nested structures
  1625.         $jsonData = json_decode($jsonContent, true, 512, JSON_BIGINT_AS_STRING);
  1627.         // If JSON decode fails, try alternative approach: extract coordinates directly from file
  1628.         if (json_last_error() !== JSON_ERROR_NONE) {
  1629.             $errorMsg = "getPolygonFromJsonSheet: JSON decode error: " . json_last_error_msg() . " (Error code: " . json_last_error() . ")";
  1630.             error_log($errorMsg);
  1631.             error_log("getPolygonFromJsonSheet: File size: " . strlen($jsonContent) . " bytes");
  1632.             // Fallback: Extract coordinates directly from file content using regex/string matching
  1633.             return $this->extractCoordinatesFromFileContent($jsonContent, $governorates);
  1634.         }
  1636.         if (!isset($jsonData['features']) || !is_array($jsonData['features'])) {
  1637.             $availableKeys = isset($jsonData) ? implode(', ', array_keys($jsonData)) : 'null';
  1638.             error_log("getPolygonFromJsonSheet: JSON missing 'features' array. Available keys: " . $availableKeys);
  1639.             error_log("getPolygonFromJsonSheet: JSON type: " . gettype($jsonData));
  1640.             return [];
  1641.         }
  1643.         $debugMatches = [];
  1644.         $debugInfo = null; // Initialize debug info variable
  1646.         // Log total features in JSON for debugging
  1647.         error_log("getPolygonFromJsonSheet: Total features in JSON: " . count($jsonData['features']));
  1649.         // Process each governorate separately to create individual polygons
  1650.         foreach ($governorates as $governorate) {
  1651.             // Handle both object and array cases
  1652.             if (is_object($governorate)) {
  1653.                 $governorateId = method_exists($governorate, 'getGovernoteId') ? $governorate->getGovernoteId() : null;
  1654.                 $governorateNameEn = method_exists($governorate, 'getName') ? $governorate->getName('en') : null;
  1655.                 $governorateNameAr = method_exists($governorate, 'getName') ? $governorate->getName('ar') : null;
  1656.                 $governorateObj = $governorate;
  1658.                 // Check if this governorate is a municipality and fetch parent governorate
  1659.                 if (method_exists($governorate, 'getIsMunicipality') && $governorate->getIsMunicipality()) {
  1660.                     $municipalityId = method_exists($governorate, 'getMunicipalityID') ? $governorate->getMunicipalityID() : null;
  1661.                     if ($municipalityId !== null) {
  1662.                         try {
  1663.                             $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($municipalityId, true);
  1664.                             if ($municipality && $municipality->getGovernorate()) {
  1665.                                 $parentGovernorate = $municipality->getGovernorate();
  1666.                                 // Use parent governorate's names for matching (English first, then Arabic)
  1667.                                 $governorateNameEn = $parentGovernorate->getName('en');
  1668.                                 $governorateNameAr = $parentGovernorate->getName('ar');
  1669.                                 // Also update the ID to parent governorate's ID for matching
  1670.                                 $governorateId = $parentGovernorate->getGovernoteId();
  1671.                                 error_log("getPolygonFromJsonSheet: Municipality detected (ID: " . $municipalityId . "), using parent governorate - ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1672.                             }
  1673.                         } catch (\Exception $ex) {
  1674.                             error_log("getPolygonFromJsonSheet: Error fetching municipality (ID: " . $municipalityId . "): " . $ex->getMessage());
  1675.                         }
  1676.                     }
  1677.                 }
  1678.             } elseif (is_array($governorate)) {
  1679.                 $governorateId = $governorate['id'] ?? $governorate['governoteId'] ?? null;
  1680.                 $governorateNameEn = $governorate['name_en'] ?? $governorate['name']['en'] ?? null;
  1681.                 $governorateNameAr = $governorate['name_ar'] ?? $governorate['name']['ar'] ?? null;
  1682.                 $governorateObj = $governorate;
  1684.                 // Check if this governorate is a municipality (array format)
  1685.                 if (isset($governorate['IsMunicipality']) && $governorate['IsMunicipality']) {
  1686.                     $municipalityId = $governorate['MunicipalityID'] ?? null;
  1687.                     if ($municipalityId !== null) {
  1688.                         try {
  1689.                             $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($municipalityId, true);
  1690.                             if ($municipality && $municipality->getGovernorate()) {
  1691.                                 $parentGovernorate = $municipality->getGovernorate();
  1692.                                 // Use parent governorate's names for matching (English first, then Arabic)
  1693.                                 $governorateNameEn = $parentGovernorate->getName('en');
  1694.                                 $governorateNameAr = $parentGovernorate->getName('ar');
  1695.                                 // Also update the ID to parent governorate's ID for matching
  1696.                                 $governorateId = $parentGovernorate->getGovernoteId();
  1697.                                 error_log("getPolygonFromJsonSheet: Municipality detected (ID: " . $municipalityId . "), using parent governorate - ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1698.                             }
  1699.                         } catch (\Exception $ex) {
  1700.                             error_log("getPolygonFromJsonSheet: Error fetching municipality (ID: " . $municipalityId . "): " . $ex->getMessage());
  1701.                         }
  1702.                     }
  1703.                 }
  1704.             } else {
  1705.                 error_log("getPolygonFromJsonSheet: Unexpected governorate type: " . gettype($governorate));
  1706.                 continue;
  1707.             }
  1709.             // Log what we're looking for
  1710.             error_log("getPolygonFromJsonSheet: Searching for governorate - ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1712.             // Log sample features from JSON (only once) - showing REGION_N_1 field that we match against
  1713.             static $loggedSamples = false;
  1714.             if (!$loggedSamples) {
  1715.                 $sampleFeatures = [];
  1716.                 foreach (array_slice($jsonData['features'], 0, 10) as $sampleIdx => $sampleFeature) {
  1717.                     $sampleProps = $sampleFeature['properties'] ?? [];
  1718.                     $sampleFeatures[] = [
  1719.                         'REGION_N_1' => $sampleProps['REGION_N_1'] ?? 'N/A',
  1720.                     ];
  1721.                 }
  1722.                 error_log("getPolygonFromJsonSheet: Sample REGION_N_1 values from JSON (first 10): " . json_encode($sampleFeatures, JSON_UNESCAPED_UNICODE));
  1723.                 $loggedSamples = true;
  1724.             }
  1726.             $matched = false;
  1727.             $matchReason = '';
  1728.             $matchAttempts = [];
  1729.             $foundAnyMatch = false; // Track if we found at least one match for this governorate
  1731.             // Find matching feature in JSON by matching governorate nameEn with REGION_N_1 field only
  1732.             foreach ($jsonData['features'] as $featureIndex => $feature) {
  1733.                 $matched = false; // Reset for each feature
  1734.                 if (!isset($feature['properties']) || !isset($feature['geometry'])) {
  1735.                     continue;
  1736.                 }
  1738.                 $properties = $feature['properties'];
  1739.                 $geometry = $feature['geometry'];
  1741.                 // Match by English name only (exact case-insensitive match - using REGION_N_1 field only)
  1742.                 if ($governorateNameEn !== null) {
  1743.                     $govNameEn = trim((string)$governorateNameEn);
  1744.                     if (!empty($govNameEn) && isset($properties['REGION_N_1'])) {
  1745.                         // Normalize the governorate name (lowercase, normalize whitespace)
  1746.                         $govNameNormalized = strtolower(preg_replace('/\s+/', ' ', $govNameEn));
  1748.                         $jsonNameEn = trim((string)$properties['REGION_N_1']);
  1749.                         if (!empty($jsonNameEn)) {
  1750.                             $jsonNameNormalized = strtolower(preg_replace('/\s+/', ' ', $jsonNameEn));
  1752.                             // Only exact case-insensitive match (normalized)
  1753.                             if ($jsonNameNormalized === $govNameNormalized) {
  1754.                                 $matched = true;
  1755.                                 $matchReason = 'Name_EN (exact via REGION_N_1): ' . $governorateNameEn . ' matches ' . $jsonNameEn;
  1756.                             }
  1757.                         }
  1758.                     }
  1759.                 }
  1761.                 if ($matched && isset($geometry['type']) && isset($geometry['coordinates'])) {
  1762.                     error_log("getPolygonFromJsonSheet: Match found! Reason: " . $matchReason . ", Geometry type: " . $geometry['type'] . ", ADMIN: " . ($properties['ADMIN'] ?? 'N/A'));
  1764.                     // Extract coordinates based on geometry type
  1765.                     $coords = $this->extractCoordinatesFromGeometry($geometry);
  1766.                     error_log("getPolygonFromJsonSheet: Extracted " . count($coords) . " coordinates");
  1768.                     if (!empty($coords)) {
  1769.                         // Format coordinates for this governorate separately
  1770.                         $polygonCoords = $this->formatCoordinates($coords);
  1772.                         // Check if we already have a polygon for THIS SPECIFIC governorate
  1773.                         // IMPORTANT: We do NOT merge polygons from different features to avoid creating straight connecting lines.
  1774.                         // If a governorate appears in multiple features, we use only the first match to prevent invalid polygon connections.
  1775.                         $existingIndex = null;
  1776.                         foreach ($governoratePolygons as $idx => $existingPoly) {
  1777.                             if (($existingPoly['governorate'] === $governorateObj) ||
  1778.                                 (is_object($governorateObj) && is_object($existingPoly['governorate']) &&
  1779.                                     method_exists($governorateObj, 'getGovernoteId') &&
  1780.                                     method_exists($existingPoly['governorate'], 'getGovernoteId') &&
  1781.                                     $governorateObj->getGovernoteId() === $existingPoly['governorate']->getGovernoteId())
  1782.                             ) {
  1783.                                 $existingIndex = $idx;
  1784.                                 break;
  1785.                             }
  1786.                         }
  1788.                         if ($existingIndex !== null) {
  1789.                             // Governorate already has a polygon - skip this match to avoid creating straight connecting lines
  1790.                             // Using only the first match ensures clean polygon boundaries without invalid connections
  1791.                             error_log("getPolygonFromJsonSheet: Skipping duplicate match for governorate ID: " . $governorateId . " (already has polygon)");
  1792.                         } else {
  1793.                             // Store polygon with governorate info (separate polygon per governorate)
  1794.                             // Each governorate gets its own entry, even if multiple governorates are from the same region
  1795.                             $governoratePolygons[] = [
  1796.                                 'governorate' => $governorateObj,
  1797.                                 'nameEn' => $governorateNameEn,
  1798.                                 'nameAr' => $governorateNameAr,
  1799.                                 'polygon' => $polygonCoords
  1800.                             ];
  1801.                             error_log("getPolygonFromJsonSheet: Successfully added polygon for governorate ID: " . $governorateId);
  1802.                         }
  1804.                         $matchDebug = [
  1805.                             'match_reason' => $matchReason,
  1806.                             'coords_count' => count($coords),
  1807.                             'geometry_type' => $geometry['type'],
  1808.                             'matched' => true
  1809.                         ];
  1810.                         $debugMatches[] = $matchDebug;
  1811.                         if ($debugInfo !== null) $debugInfo['matches'][] = $matchDebug;
  1813.                         $foundAnyMatch = true; // Mark that we found at least one match
  1815.                         // Continue searching for more matching features (same governorate can have multiple regions)
  1816.                         // We'll merge all matching polygons for this governorate
  1817.                         continue;
  1818.                     } else {
  1819.                         $errorMsg = "Matched but extracted 0 coordinates. Geometry type: " . $geometry['type'] . ", Coordinates structure: " . json_encode($geometry['coordinates']);
  1820.                         error_log("getPolygonFromJsonSheet: " . $errorMsg);
  1821.                         if ($debugInfo !== null) {
  1822.                             $debugInfo['errors'][] = $errorMsg;
  1823.                             $debugInfo['matches'][] = ['match_reason' => $matchReason, 'matched' => true, 'coords_extracted' => 0];
  1824.                         }
  1825.                     }
  1826.                 }
  1827.             }
  1829.             if (!$foundAnyMatch) {
  1830.                 error_log("getPolygonFromJsonSheet: No match found for governorate ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1831.                 $noMatchDebug = [
  1832.                     'governorate_id' => $governorateId,
  1833.                     'governorate_id_type' => gettype($governorateId),
  1834.                     'name_en' => $governorateNameEn,
  1835.                     'name_ar' => $governorateNameAr,
  1836.                     'matched' => false,
  1837.                     'match_attempts' => array_slice($matchAttempts, 0, 10) // Limit to first 10 attempts
  1838.                 ];
  1839.                 $debugMatches[] = $noMatchDebug;
  1840.                 if ($debugInfo !== null) $debugInfo['matches'][] = $noMatchDebug;
  1841.             }
  1842.         }
  1844.         // Log summary
  1845.         error_log("getPolygonFromJsonSheet: Processed " . count($governorates) . " governorates, found " . count($governoratePolygons) . " polygons");
  1847.         if (empty($governoratePolygons)) {
  1848.             // Log available REGION_N_1 values from JSON for debugging
  1849.             $availableRegionNames = [];
  1850.             foreach ($jsonData['features'] as $feature) {
  1851.                 $props = $feature['properties'] ?? [];
  1852.                 $regionName = $props['REGION_N_1'] ?? null;
  1853.                 if ($regionName !== null) {
  1854.                     $availableRegionNames[] = $regionName;
  1855.                 }
  1856.             }
  1857.             error_log("getPolygonFromJsonSheet: No coordinates found. Debug matches: " . json_encode($debugMatches));
  1858.             error_log("getPolygonFromJsonSheet: Available REGION_N_1 values in JSON (first 20): " . implode(', ', array_slice($availableRegionNames, 0, 20)));
  1859.         } else {
  1860.             error_log("getPolygonFromJsonSheet: Successfully extracted polygons for " . count($governoratePolygons) . " governorates");
  1861.         }
  1863.         return $governoratePolygons;
  1864.     }
  1866.     /**
  1867.      * Extract coordinates from GeoJSON geometry (supports Polygon and MultiPolygon)
  1868.      * 
  1869.      * @param array $geometry GeoJSON geometry object
  1870.      * @return array Array of coordinate pairs [lng, lat]
  1871.      */
  1872.     private function extractCoordinatesFromGeometry($geometry)
  1873.     {
  1874.         $coordinates = [];
  1876.         if (!isset($geometry['type']) || !isset($geometry['coordinates'])) {
  1877.             return $coordinates;
  1878.         }
  1880.         $type = $geometry['type'];
  1881.         $coords = $geometry['coordinates'];
  1883.         if ($type === 'Polygon' && is_array($coords)) {
  1884.             // Polygon: coordinates[0] is the outer ring
  1885.             if (isset($coords[0]) && is_array($coords[0])) {
  1886.                 foreach ($coords[0] as $coord) {
  1887.                     if (is_array($coord) && count($coord) >= 2) {
  1888.                         $coordinates[] = $coord;
  1889.                     }
  1890.                 }
  1891.             }
  1892.         } elseif ($type === 'MultiPolygon' && is_array($coords)) {
  1893.             // MultiPolygon: array of polygons, each polygon has coordinates[0] as outer ring
  1894.             // IMPORTANT: Use only the FIRST polygon to avoid creating straight connecting lines between disconnected parts
  1895.             // CAP XML polygons should represent a single continuous boundary
  1896.             if (!empty($coords) && is_array($coords[0]) && isset($coords[0][0]) && is_array($coords[0][0])) {
  1897.                 foreach ($coords[0][0] as $coord) {
  1898.                     if (is_array($coord) && count($coord) >= 2) {
  1899.                         $coordinates[] = $coord;
  1900.                     }
  1901.                 }
  1902.             }
  1903.         }
  1905.         return $coordinates;
  1906.     }
  1908.     /**
  1909.      * Extract coordinates directly from file content when JSON parsing fails
  1910.      * This is a fallback method that uses string/regex matching
  1911.      */
  1912.     private function extractCoordinatesFromFileContent($fileContent, $governorates)
  1913.     {
  1914.         $governoratePolygons = [];
  1916.         foreach ($governorates as $governorate) {
  1917.             $governorateCoords = [];
  1918.             // Get governorate ID and names
  1919.             if (is_object($governorate)) {
  1920.                 $governorateId = method_exists($governorate, 'getGovernoteId') ? $governorate->getGovernoteId() : null;
  1921.                 $governorateNameEn = method_exists($governorate, 'getName') ? $governorate->getName('en') : null;
  1922.                 $governorateNameAr = method_exists($governorate, 'getName') ? $governorate->getName('ar') : null;
  1923.                 $governorateObj = $governorate;
  1925.                 // Check if this governorate is a municipality and fetch parent governorate
  1926.                 if (method_exists($governorate, 'getIsMunicipality') && $governorate->getIsMunicipality()) {
  1927.                     $municipalityId = method_exists($governorate, 'getMunicipalityID') ? $governorate->getMunicipalityID() : null;
  1928.                     if ($municipalityId !== null) {
  1929.                         try {
  1930.                             $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($municipalityId, true);
  1931.                             if ($municipality && $municipality->getGovernorate()) {
  1932.                                 $parentGovernorate = $municipality->getGovernorate();
  1933.                                 // Use parent governorate's names for matching (English first, then Arabic)
  1934.                                 $governorateNameEn = $parentGovernorate->getName('en');
  1935.                                 $governorateNameAr = $parentGovernorate->getName('ar');
  1936.                                 // Also update the ID to parent governorate's ID for matching
  1937.                                 $governorateId = $parentGovernorate->getGovernoteId();
  1938.                                 error_log("extractCoordinatesFromFileContent: Municipality detected (ID: " . $municipalityId . "), using parent governorate - ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1939.                             }
  1940.                         } catch (\Exception $ex) {
  1941.                             error_log("extractCoordinatesFromFileContent: Error fetching municipality (ID: " . $municipalityId . "): " . $ex->getMessage());
  1942.                         }
  1943.                     }
  1944.                 }
  1945.             } elseif (is_array($governorate)) {
  1946.                 $governorateId = $governorate['id'] ?? $governorate['governoteId'] ?? null;
  1947.                 $governorateNameEn = $governorate['name_en'] ?? $governorate['name']['en'] ?? null;
  1948.                 $governorateNameAr = $governorate['name_ar'] ?? $governorate['name']['ar'] ?? null;
  1949.                 $governorateObj = $governorate;
  1951.                 // Check if this governorate is a municipality (array format)
  1952.                 if (isset($governorate['IsMunicipality']) && $governorate['IsMunicipality']) {
  1953.                     $municipalityId = $governorate['MunicipalityID'] ?? null;
  1954.                     if ($municipalityId !== null) {
  1955.                         try {
  1956.                             $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityid($municipalityId, true);
  1957.                             if ($municipality && $municipality->getGovernorate()) {
  1958.                                 $parentGovernorate = $municipality->getGovernorate();
  1959.                                 // Use parent governorate's names for matching (English first, then Arabic)
  1960.                                 $governorateNameEn = $parentGovernorate->getName('en');
  1961.                                 $governorateNameAr = $parentGovernorate->getName('ar');
  1962.                                 // Also update the ID to parent governorate's ID for matching
  1963.                                 $governorateId = $parentGovernorate->getGovernoteId();
  1964.                                 error_log("extractCoordinatesFromFileContent: Municipality detected (ID: " . $municipalityId . "), using parent governorate - ID: " . var_export($governorateId, true) . ", EN: " . var_export($governorateNameEn, true) . ", AR: " . var_export($governorateNameAr, true));
  1965.                             }
  1966.                         } catch (\Exception $ex) {
  1967.                             error_log("extractCoordinatesFromFileContent: Error fetching municipality (ID: " . $municipalityId . "): " . $ex->getMessage());
  1968.                         }
  1969.                     }
  1970.                 }
  1971.             } else {
  1972.                 continue;
  1973.             }
  1975.             if ($governorateId === null) {
  1976.                 continue;
  1977.             }
  1979.             // Search for the governorate section in the file
  1980.             // Try multiple patterns for both old (GovID) and new (ADMIN) formats
  1981.             // Patterns: "GovID": "76", "GovID": 76, "ADMIN": 12, "ADMIN": "12"
  1982.             $idStr = (string)$governorateId;
  1983.             $patterns = [
  1984.                 '"ADMIN"\s*:\s*"' . preg_quote($idStr, '/') . '"',
  1985.                 '"ADMIN"\s*:\s*' . preg_quote($idStr, '/'),
  1986.                 '"GovID"\s*:\s*"' . preg_quote($idStr, '/') . '"',
  1987.                 '"GovID"\s*:\s*' . preg_quote($idStr, '/'),
  1988.             ];
  1990.             $found = false;
  1991.             foreach ($patterns as $pattern) {
  1992.                 if (preg_match('/' . $pattern . '/', $fileContent, $matches, PREG_OFFSET_CAPTURE)) {
  1993.                     $matchPos = $matches[0][1];
  1994.                     $found = true;
  1996.                     // Find the coordinates array that follows this ADMIN/GovID (within next 100000 chars)
  1997.                     $searchArea = substr($fileContent, $matchPos, 100000);
  1999.                     // Look for coordinates array: "coordinates": [[[lng, lat], ...]]
  2000.                     if (preg_match('/"coordinates"\s*:\s*\[/', $searchArea, $coordMatch, PREG_OFFSET_CAPTURE)) {
  2001.                         $coordStartInArea = $coordMatch[0][1];
  2002.                         $coordStart = $matchPos + $coordStartInArea;
  2004.                         // Extract the coordinates array by finding matching brackets
  2005.                         $depth = 0;
  2006.                         $startBracket = false;
  2007.                         $coordString = '';
  2008.                         $bracketCount = 0;
  2010.                         // Find the opening bracket
  2011.                         for ($i = $coordStart; $i < strlen($fileContent) && $i < $coordStart + 200000; $i++) {
  2012.                             $char = $fileContent[$i];
  2013.                             if ($char === '[') {
  2014.                                 if (!$startBracket) {
  2015.                                     $startBracket = true;
  2016.                                 }
  2017.                                 $depth++;
  2018.                                 $bracketCount++;
  2019.                                 $coordString .= $char;
  2020.                             } elseif ($char === ']') {
  2021.                                 $depth--;
  2022.                                 $bracketCount++;
  2023.                                 $coordString .= $char;
  2024.                                 if ($depth === 0 && $startBracket) {
  2025.                                     break; // Found complete coordinates array
  2026.                                 }
  2027.                             } elseif ($startBracket) {
  2028.                                 $coordString .= $char;
  2029.                             } elseif (preg_match('/\S/', $char)) {
  2030.                                 // Non-whitespace before bracket - might be start
  2031.                                 if ($char === '[') {
  2032.                                     $startBracket = true;
  2033.                                     $depth = 1;
  2034.                                     $coordString = '[';
  2035.                                 }
  2036.                             }
  2037.                         }
  2039.                         // Extract coordinates using regex (more reliable than JSON parsing for malformed JSON)
  2040.                         // Pattern: [ lng, lat ] or [lng,lat] - matches coordinate pairs
  2041.                         $coordPattern = '/\[\s*([+-]?\d+\.?\d*)\s*,\s*([+-]?\d+\.?\d*)\s*\]/';
  2042.                         preg_match_all($coordPattern, $coordString, $coordMatches, PREG_SET_ORDER);
  2044.                         if (!empty($coordMatches)) {
  2045.                             foreach ($coordMatches as $match) {
  2046.                                 $lng = (float)$match[1];
  2047.                                 $lat = (float)$match[2];
  2049.                                 // Validate ranges
  2050.                                 if ($lat >= -90 && $lat <= 90 && $lng >= -180 && $lng <= 180) {
  2051.                                     $governorateCoords[] = [$lng, $lat];
  2052.                                 }
  2053.                             }
  2054.                         } else {
  2055.                             // Fallback: Try JSON decode if regex fails
  2056.                             $coordsArray = json_decode($coordString, true);
  2057.                             if ($coordsArray !== null && is_array($coordsArray)) {
  2058.                                 $coords = $this->extractCoordsFromArray($coordsArray);
  2059.                                 if (!empty($coords)) {
  2060.                                     $governorateCoords = $coords;
  2061.                                 }
  2062.                             }
  2063.                         }
  2065.                         // Format coordinates for this governorate separately
  2066.                         if (!empty($governorateCoords)) {
  2067.                             $polygonCoords = $this->formatCoordinates($governorateCoords);
  2068.                             $governoratePolygons[] = [
  2069.                                 'governorate' => $governorateObj,
  2070.                                 'nameEn' => $governorateNameEn,
  2071.                                 'nameAr' => $governorateNameAr,
  2072.                                 'polygon' => $polygonCoords
  2073.                             ];
  2074.                         }
  2075.                     }
  2076.                     break; // Found match, no need to try other patterns
  2077.                 }
  2078.             }
  2079.         }
  2081.         return $governoratePolygons;
  2082.     }
  2084.     /**
  2085.      * Extract coordinate pairs from nested array structure (Polygon/MultiPolygon)
  2086.      */
  2087.     private function extractCoordsFromArray($coordsArray)
  2088.     {
  2089.         $coordinates = [];
  2091.         if (!is_array($coordsArray)) {
  2092.             return $coordinates;
  2093.         }
  2095.         // Check if it's a coordinate pair [lng, lat]
  2096.         if (count($coordsArray) === 2 && is_numeric($coordsArray[0]) && is_numeric($coordsArray[1])) {
  2097.             $coordinates[] = $coordsArray;
  2098.             return $coordinates;
  2099.         }
  2101.         // Recursively process nested arrays
  2102.         foreach ($coordsArray as $item) {
  2103.             if (is_array($item)) {
  2104.                 $subCoords = $this->extractCoordsFromArray($item);
  2105.                 $coordinates = array_merge($coordinates, $subCoords);
  2106.             }
  2107.         }
  2109.         return $coordinates;
  2110.     }
  2112.     /**
  2113.      * Format coordinates for CAP format
  2114.      */
  2115.     private function formatCoordinates($allCoordinates)
  2116.     {
  2117.         $formattedCoords = [];
  2119.         foreach ($allCoordinates as $coord) {
  2120.             if (is_array($coord) && count($coord) >= 2) {
  2121.                 if (!is_numeric($coord[0]) || !is_numeric($coord[1])) {
  2122.                     continue;
  2123.                 }
  2125.                 $lng = (float)$coord[0];
  2126.                 $lat = (float)$coord[1];
  2128.                 // Validate ranges
  2129.                 if ($lat < -90 || $lat > 90 || $lng < -180 || $lng > 180) {
  2130.                     continue;
  2131.                 }
  2133.                 $formattedLat = number_format($lat, 6, '.', '');
  2134.                 $formattedLng = number_format($lng, 6, '.', '');
  2135.                 $formattedCoords[] = $formattedLat . ',' . $formattedLng;
  2136.             }
  2137.         }
  2139.         if (!empty($formattedCoords)) {
  2140.             $polygonCoords = implode(' ', $formattedCoords);
  2142.             // Ensure polygon is closed
  2143.             $coordsArray = explode(' ', $polygonCoords);
  2144.             $firstCoord = $coordsArray[0];
  2145.             $lastCoord = end($coordsArray);
  2146.             if ($firstCoord !== $lastCoord) {
  2147.                 $polygonCoords .= ' ' . $firstCoord;
  2148.             }
  2150.             return $polygonCoords;
  2151.         }
  2153.         return '';
  2154.     }
  2156.     /**
  2157.      * Create a fallback polygon when coordinates are invalid or missing
  2158.      * Creates a bounding box from region/governorate coordinates
  2159.      */
  2160.     private function createFallbackPolygon($doc, $notification, $governorateCoordinates, $timezone)
  2161.     {
  2162.         $polygonCoords = '';
  2164.         // Try to use governorate coordinates first
  2165.         if (!empty($governorateCoordinates)) {
  2166.             $coords = explode(' ', trim($governorateCoordinates));
  2167.             $validCoords = [];
  2169.             foreach ($coords as $coord) {
  2170.                 if (strpos($coord, ',') !== false) {
  2171.                     $parts = explode(',', $coord);
  2172.                     if (count($parts) == 2 && is_numeric($parts[0]) && is_numeric($parts[1])) {
  2173.                         $validCoords[] = $coord;
  2174.                     }
  2175.                 }
  2176.             }
  2178.             if (count($validCoords) >= 4) {
  2179.                 // Use governorate coordinates
  2180.                 $polygonCoords = implode(' ', $validCoords);
  2181.                 // Close the polygon
  2182.                 if (!empty($validCoords)) {
  2183.                     $firstCoord = $validCoords[0];
  2184.                     $lastCoord = end($validCoords);
  2185.                     if ($firstCoord !== $lastCoord) {
  2186.                         $polygonCoords .= ' ' . $firstCoord;
  2187.                     }
  2188.                 }
  2189.             }
  2190.         }
  2192.         // Fallback to region coordinates if governorate coordinates are insufficient
  2193.         if (empty($polygonCoords) && $notification->getRegion()) {
  2194.             $lat = $notification->getRegion()->getLatitude();
  2195.             $lng = $notification->getRegion()->getLongitude();
  2197.             if (is_numeric($lat) && is_numeric($lng)) {
  2198.                 // Create a small bounding box around the region center (0.1 degree radius)
  2199.                 $offset = 0.1;
  2200.                 $coords = [
  2201.                     ($lat - $offset) . ',' . ($lng - $offset), // SW
  2202.                     ($lat - $offset) . ',' . ($lng + $offset), // SE
  2203.                     ($lat + $offset) . ',' . ($lng + $offset), // NE
  2204.                     ($lat + $offset) . ',' . ($lng - $offset), // NW
  2205.                     ($lat - $offset) . ',' . ($lng - $offset)  // Close polygon
  2206.                 ];
  2207.                 $polygonCoords = implode(' ', $coords);
  2208.             }
  2209.         }
  2211.         // Final fallback: use default coordinates if nothing else works
  2212.         if (empty($polygonCoords)) {
  2213.             // Default coordinates for Saudi Arabia center (Riyadh area)
  2214.             $defaultCoords = [
  2215.                 '24.5,46.5',  // SW
  2216.                 '24.5,46.7',  // SE
  2217.                 '24.7,46.7',  // NE
  2218.                 '24.7,46.5',  // NW
  2219.                 '24.5,46.5'   // Close polygon
  2220.             ];
  2221.             $polygonCoords = implode(' ', $defaultCoords);
  2222.         }
  2224.         return $doc->createElement('polygon', $polygonCoords);
  2225.     }
  2227.     public function viewNotification($params, $translator): array
  2228.     {
  2229.         $decodedJwtToken = $params['decodedJwtToken'] ?? null;
  2230.         $userPermission = $params['userPermission'] ?? null;
  2232.         if (is_array($params['id'])) {
  2233.             $ids = array_values(array_unique(array_filter($params['id'], static function ($v) {
  2234.                 return $v !== null && $v !== '' && $v !== false;
  2235.             })));
  2236.             if ($ids === []) {
  2237.                 return ['success' => false, 'message' => $translator->trans('ews_notification_does_not_exists')];
  2238.             }
  2239.             $items = [];
  2240.             foreach ($ids as $id) {
  2241.                 $viewNotification = DataObject\EwsNotification::getById($id, false);
  2242.                 if (!$viewNotification) {
  2243.                     $viewNotification = DataObject\EwsNotification::getById($id, true);
  2244.                 }
  2245.                 if ($viewNotification) {
  2246.                     $items[] = [
  2247.                         'id' => $id,
  2248.                         'success' => true,
  2249.                         'data' => $this->formatNotificationWithUpdateChanges($viewNotification, $translator, $decodedJwtToken, $userPermission),
  2250.                         'history' => $this->getVersions($viewNotification, $translator, $decodedJwtToken, $userPermission),
  2251.                     ];
  2252.                 } else {
  2253.                     $items[] = [
  2254.                         'id' => $id,
  2255.                         'success' => false,
  2256.                         'message' => $translator->trans('ews_notification_does_not_exists'),
  2257.                     ];
  2258.                 }
  2259.             }
  2260.             $anyOk = false;
  2261.             foreach ($items as $row) {
  2262.                 if (!empty($row['success'])) {
  2263.                     $anyOk = true;
  2264.                     break;
  2265.                 }
  2266.             }
  2268.             return $anyOk
  2269.                 ? ['success' => true, 'items' => $items]
  2270.                 : ['success' => false, 'message' => $translator->trans('ews_notification_does_not_exists'), 'items' => $items];
  2271.         }
  2273.         $viewNotification = DataObject\EwsNotification::getById($params['id'], false);
  2274.         if (!$viewNotification) {
  2275.             $viewNotification = DataObject\EwsNotification::getById($params['id'], true);
  2276.         }
  2277.         if ($viewNotification) {
  2278.             $notificationData = $this->formatNotificationWithUpdateChanges($viewNotification, $translator, $decodedJwtToken, $userPermission);
  2279.             $history = $this->getVersions($viewNotification, $translator, $decodedJwtToken, $userPermission);
  2281.             return ['success' => true, 'data' => $notificationData, 'history' => $history];
  2282.         }
  2284.         return ['success' => false, 'message' => $translator->trans('ews_notification_does_not_exists')];
  2285.     }
  2287.     public function searchEwsNotificationByRegion($regionId, $translator)
  2288.     {
  2289.         $items = [];
  2291.         // The "region" field on EwsNotification is a manyToOneRelation, so the
  2292.         // magic getByRegion() expects an ElementInterface (or ['id','type'] array),
  2293.         // NOT the raw regionId integer that comes from the API request. We must
  2294.         // resolve the Region object first via its custom regionId field.
  2295.         $regionObj = DataObject\Region::getByRegionId($regionId, 1);
  2296.         if (!$regionObj) {
  2297.             return ['success' => false, 'message' => $translator->trans('Region not found.')];
  2298.         }
  2300.         $currentTimestamp = time();
  2302.         $ewsNotificationList = DataObject\EwsNotification::getByRegion($regionObj);
  2303.         if (!empty($ewsNotificationList)) {
  2304.             $ewsNotificationList->addConditionParam("status != ?", ["ended"]);
  2305.             $ewsNotificationList->filterByEndDate($currentTimestamp, ">=");
  2307.             foreach ($ewsNotificationList as $ewsNotification) {
  2308.                 $items[] = $ewsNotification->getId();
  2309.             }
  2310.         }
  2311.         return ['success' => true, 'items' => $items];
  2312.     }
  2313.     
  2314.     public function addAddressComponentsFieldCollection($addressComponents, DataObject\EwsNotification $object)
  2315.     {
  2316.         $items = new \Pimcore\Model\DataObject\Fieldcollection();
  2318.         foreach ($addressComponents as $Data) {
  2320.             #creating field collections
  2321.             $item = new DataObject\Fieldcollection\Data\AddressComponents();
  2322.             $item->setAddressValue(strip_tags($Data['long_name']));
  2323.             $item->setAddressKey(strip_tags($Data['types'][0]));
  2325.             $items->add($item);
  2326.         }
  2328.         return $object->setAddressComponents($items);
  2329.     }
  2331.     public function getAlertAction($id)
  2332.     {
  2333.         $alertActionObj = DataObject\AlertAction::getById($id);
  2334.         $data = [];
  2335.         if (!empty($alertActionObj)) {
  2336.             $data['id'] = $alertActionObj->getAlertActionId();
  2337.             $data['severity'] = $alertActionObj->getSeverity();
  2338.             $data['nameEn'] = $alertActionObj->getName('en');
  2339.             $data['nameAr'] = $alertActionObj->getName('ar');
  2340.         }
  2341.         return $data;
  2342.     }
  2343.     public function getAlertType($id)
  2344.     {
  2345.         $alertTypeObj = DataObject\AlertType::getById($id);
  2346.         $data = [];
  2347.         if (!empty($alertTypeObj)) {
  2348.             $data['id'] = $alertTypeObj->getAlertTypeId();
  2349.             $data['nameEn'] = $alertTypeObj->getName('en');
  2350.             $data['nameAr'] = $alertTypeObj->getName('ar');
  2351.         }
  2352.         return $data;
  2353.     }
  2355.     public function getAlertStatus($id)
  2356.     {
  2357.         $alertStatus = DataObject\AlertStatus::getById($id);
  2358.         $data = [];
  2359.         if (!empty($alertStatus)) {
  2360.             $alertType = $alertStatus->getAlertType();
  2361.             $alertData = [];
  2362.             if (!empty($alertType)) {
  2363.                 $alertData = [
  2364.                     "id" => $alertType->getAlertTypeId(),
  2365.                     "nameEn" => $alertType->getName('en'),
  2366.                     "nameAr" => $alertType->getName('ar')
  2368.                 ];
  2369.             }
  2370.             $data['id'] = $alertStatus->getAlertStatusId();
  2371.             $data['nameEn'] = $alertStatus->getName('en');
  2372.             $data['nameAr'] = $alertStatus->getName('ar');
  2373.             $data['alertType'] = $alertData;
  2374.         }
  2375.         return $data;
  2376.     }
  2378.     public function getAlertHazard($id)
  2379.     {
  2380.         $alertHazardObj = DataObject\AlertHazard::getById($id);
  2381.         $data = [];
  2382.         if (!empty($alertHazardObj)) {
  2383.             $data['id'] = $alertHazardObj->getAlertHazardId();
  2384.             $data['nameEn'] = $alertHazardObj->getName('en');
  2385.             $data['nameAr'] = $alertHazardObj->getName('ar');
  2386.         }
  2387.         return $data;
  2388.     }
  2390.     public function getRegion($id)
  2391.     {
  2392.         $regionObj = DataObject\Region::getById($id);
  2393.         $data = [];
  2394.         if (!empty($regionObj)) {
  2395.             $data['id'] = $regionObj->getRegionId();
  2396.             $data['nameEn'] = $regionObj->getName('en');
  2397.             $data['nameAr'] = $regionObj->getName('ar');
  2398.             $data['longitude'] = $regionObj->getLongitude();
  2399.             $data['latitude'] = $regionObj->getLatitude();
  2400.         }
  2401.         return $data;
  2402.     }
  2404.     public function getEvent($id)
  2405.     {
  2406.         $eventObj = DataObject\Event::getById($id);
  2407.         $data = [];
  2408.         if (!empty($eventObj)) {
  2409.             $data['id'] = $eventObj->getEventId();
  2410.             $data['nameEn'] = $eventObj->getName('en');
  2411.             $data['nameAr'] = $eventObj->getName('ar');
  2412.         }
  2413.         return $data;
  2414.     }
  2416.     public function getWeatherPhenomenon($id)
  2417.     {
  2418.         $weatherPhenObj = DataObject\PhenomenaList::getById($id);
  2419.         $data = [];
  2420.         if (!empty($weatherPhenObj)) {
  2421.             $data['id'] = $weatherPhenObj->getPhenomenaListId();
  2422.             $data['nameEn'] = $weatherPhenObj->getTitle('en');
  2423.             $data['nameAr'] = $weatherPhenObj->getTitle('ar');
  2424.         }
  2425.         return $data;
  2426.     }
  2428.     public function getWeatherPhenAffect($id)
  2429.     {
  2430.         $weatherPhenObj = DataObject\WeatherPhenomenonAffect::getById($id);
  2431.         $data = [];
  2432.         if (!empty($weatherPhenObj)) {
  2433.             $data['id'] = $weatherPhenObj->getWeatherPhenomenonAffectId();
  2434.             $data['nameEn'] = $weatherPhenObj->getName('en');
  2435.             $data['nameAr'] = $weatherPhenObj->getName('ar');
  2436.         }
  2437.         return $data;
  2438.     }
  2439.     // public function getGovernorateDetail($governorateList)
  2440.     // {
  2441.     //     $result = [];
  2442.     //     if (!empty($governorateList)) {
  2443.     //         for ($i = 0; $i < count($governorateList); $i++) {
  2444.     //             $parentGovernates = null;
  2445.     //             if ($governorateList[$i]->getIsMunicipality()) {
  2447.     //                 $municipatlity = \Pimcore\Model\DataObject\Municipality::getByMunicipalityId($governorateList[$i]->getMunicipalityID(), true);
  2449.     //                 if ($municipatlity &&  $municipatlity->getGovernorate()) {
  2450.     //                     $parentGovernates = $municipatlity->getGovernorate();
  2451.     //                 }
  2452.     //             }
  2453.     //             $result[$i]['id'] = $governorateList[$i]->getGovernoteId();
  2454.     //             $result[$i]['nameEn'] = $governorateList[$i]->getName('en');
  2455.     //             $result[$i]['nameAr'] = $governorateList[$i]->getName('ar');
  2456.     //             $result[$i]['longitude'] = $governorateList[$i]->getLongitude();
  2457.     //             $result[$i]['latitude'] = $governorateList[$i]->getLatitude();
  2458.     //             $result[$i]['parentId'] = $parentGovernates ? $parentGovernates->getGovernoteId() : null;
  2460.     //             $result[$i]['parenNameEn'] = $parentGovernates ? $parentGovernates->getName('en') : null;
  2461.     //             $result[$i]['parenNameAr'] = $parentGovernates ? $parentGovernates->getName('ar') : null;
  2463.     //             $result[$i]['parentLongitude'] = $parentGovernates ? $parentGovernates->getLongitude() : null;
  2464.     //             $result[$i]['parentLatitude'] = $parentGovernates ? $parentGovernates->getLatitude() : null;
  2465.     //             $result[$i]['isMunicipality'] = $governorateList[$i]->getIsMunicipality();
  2466.     //             $result[$i]['municipalities'] = [];
  2467.     //         }
  2468.     //     }
  2469.     //     return $result;
  2470.     // }
  2472.     public function getGovernorateDetail($governorateList)
  2473.     {
  2474.         $result = [];
  2475.         if (!empty($governorateList)) {
  2476.             $uniqueGovernorateArray = [];
  2477.             $isCapital = [];
  2478.             $hasCapital = false;
  2479.             foreach ($governorateList as $governorate) {
  2480.                 $parentGovernates = null;
  2482.                 // Check if it is a municipality and fetch parent governorate
  2483.                 if ($governorate->getIsMunicipality()) {
  2484.                     $municipality = \Pimcore\Model\DataObject\Municipality::getByMunicipalityId($governorate->getMunicipalityID(), true);
  2485.                     if ($municipality && $municipality->getGovernorate()) {
  2486.                         $parentGovernates = $municipality->getGovernorate();
  2487.                     }
  2488.                 }
  2490.                 // Initialize a unique governorate array if needed
  2491.                 $parentId = $parentGovernates ? $parentGovernates->getGovernoteId() : $governorate->getGovernoteId();
  2493.                 if (!isset($uniqueGovernorateArray[$parentId])) {
  2494.                     $uniqueGovernorateArray[$parentId] = [
  2495.                         'id' => $parentId,
  2496.                         'nameEn' => $parentGovernates ? $parentGovernates->getName('en') : $governorate->getName('en'),
  2497.                         'nameAr' => $parentGovernates ? $parentGovernates->getName('ar') : $governorate->getName('ar'),
  2498.                         'longitude' => $parentGovernates ? $parentGovernates->getLongitude() : $governorate->getLongitude(),
  2499.                         'latitude' => $parentGovernates ? $parentGovernates->getLatitude() : $governorate->getLatitude(),
  2500.                         'municipalities' => []
  2501.                     ];
  2502.                     $gov = $parentGovernates ?: \Pimcore\Model\DataObject\Governorate::getByGovernoteId($parentId, true) ?: $governorate;
  2503.                     $isCapital[$parentId] = method_exists($gov, 'getIsCapital') ? (bool) $gov->getIsCapital() : false;
  2504.                 }
  2506.                 // Add municipality details if it is a municipality
  2507.                 if ($governorate->getIsMunicipality()) {
  2508.                     $uniqueGovernorateArray[$parentId]['municipalities'][] = [
  2509.                         'id' => $governorate->getGovernoteId(),
  2510.                         'nameEn' => $governorate->getName('en'),
  2511.                         'nameAr' => $governorate->getName('ar'),
  2512.                         'longitude' => $governorate->getLongitude(),
  2513.                         'latitude' => $governorate->getLatitude()
  2514.                     ];
  2515.                 }
  2516.             }
  2518.             // Flatten the associative array to a numerical array for output
  2519.             $result = array_values($uniqueGovernorateArray);
  2520.             if (in_array(true, $isCapital, true)) {
  2521.                 foreach ($result as $i => &$row) {
  2522.                     $row['_'] = $i;
  2523.                 }
  2524.                 unset($row);
  2525.                 usort($result, static function ($a, $b) use ($isCapital) {
  2526.                     $c = (int) !empty($isCapital[$b['id']]) - (int) !empty($isCapital[$a['id']]);
  2528.                     return $c ?: ($a['_'] <=> $b['_']);
  2529.                 });
  2530.                 foreach ($result as &$row) {
  2531.                     unset($row['_']);
  2532.                 }
  2533.                 unset($row);
  2534.             }
  2535.         }
  2537.         return $result;
  2538.     }
  2541.     public function getMessageDetail($notificationObj)
  2542.     {
  2543.         $data = [];
  2544.         if (!empty($notificationObj)) {
  2545.             $data['messageEn'] = $notificationObj->getMessage('en');
  2546.             $data['messageAr'] = $notificationObj->getMessage('ar');
  2547.         }
  2548.         return $data;
  2549.     }
  2551.     public function createAsset($fileData, $filename)
  2552.     {
  2554.         // Validate the file data
  2555.         if (preg_match('/^data:(image\/(png|jpe?g)|application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel));base64,/', $fileData) !== 1) {
  2556.             return false; // Invalid file data or MIME type
  2557.         }
  2559.         // Extract the file extension from the MIME type
  2560.         $extension = '';
  2561.         if (preg_match('/^data:image\/(png|jpe?g);base64,/', $fileData)) {
  2562.             $extension = 'jpg'; // Assume JPG for base64-encoded image data (PNG or JPEG)
  2563.         } elseif (preg_match('/^data:application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel);base64,/', $fileData)) {
  2564.             $extension = 'pdf'; // PDF, DOCX, or Excel
  2565.         }
  2567.         // Remove the "data:image/png;base64," or "data:application/pdf;base64," prefix to get the actual base64-encoded content
  2568.         $base64Content = preg_replace('/^data:(image\/png|application\/(pdf|vnd.openxmlformats-officedocument.wordprocessingml.document|vnd.ms-excel));base64,/', '', $fileData);
  2570.         // Decode the base64-encoded content
  2571.         $fileContent = base64_decode($base64Content);
  2573.         // Validate the decoded content
  2574.         if ($fileContent === false) {
  2575.             return false; // Invalid base64-encoded content
  2576.         }
  2578.         // Create the Pimcore asset
  2579.         $asset = new \Pimcore\Model\Asset();
  2580.         $parent = Asset\Service::createFolderByPath('/EWSNotification');
  2581.         $asset->setFilename($filename); // Replace with the desired filename and extension
  2582.         $asset->setParent($parent);
  2583.         $asset->setData($fileContent);
  2585.         // Set the MIME type based on the file extension
  2586.         $mimeType = '';
  2587.         if ($extension === 'pdf') {
  2588.             $mimeType = 'application/pdf';
  2589.         } elseif ($extension === 'jpg') {
  2590.             $mimeType = 'image/jpeg';
  2591.         } elseif ($extension === 'png') {
  2592.             $mimeType = 'image/png';
  2593.         } elseif ($extension === 'docx') {
  2594.             $mimeType = 'application/vnd.openxmlformats-officedocument.wordprocessingml.document';
  2595.         } elseif ($extension === 'xlsx') {
  2596.             $mimeType = 'application/vnd.ms-excel';
  2597.         }
  2599.         // Validate the MIME type
  2600.         if (!in_array($mimeType, ['image/jpeg', 'image/png', 'application/pdf', 'application/vnd.openxmlformats-officedocument.wordprocessingml.document', 'application/vnd.ms-excel'])) {
  2601.             return false; // Invalid MIME type
  2602.         }
  2604.         $asset->setType($mimeType);
  2606.         // Save the asset
  2607.         $asset->save();
  2609.         return $asset;
  2610.     }
  2612.     public function getPhenomenaListByAlertId($alertID, $lang = "en")
  2613.     {
  2614.         $response = [];
  2615.         $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alertID, true);
  2616.         if ($alertType instanceof \Pimcore\Model\DataObject\AlertType) {
  2617.             $phenomenaList = $alertType->getPhenomenaList();
  2618.             if ($phenomenaList) {
  2619.                 foreach ($phenomenaList as $phenomena) {
  2620.                     $phenomenaId = $phenomena->getPhenomena();
  2621.                     if ($phenomenaId) {
  2622.                         $phenomenaObj = \Pimcore\Model\DataObject::getById($phenomenaId);
  2623.                         $response[] = ["id" => $phenomenaObj->getphenomenaListId(), "nameEn" => $phenomenaObj->getTitle("en"), "nameAr" => $phenomenaObj->getTitle("ar"), "criteria" => $phenomena->getCriteria()];
  2624.                     }
  2625.                 }
  2626.             } else {
  2627.                 return ["success" => false, "message" => "No criteria is set"];
  2628.             }
  2629.         } else {
  2630.             return ["success" => false, "message" => "Invalid alert type id"];
  2631.         }
  2632.         return ["success" => true, "data" => $response];
  2633.     }
  2635.     public function getPhenomenaListByAlertIds($alertIDs, $lang = "en")
  2636.     {
  2637.         $response = [];
  2638.         if (count($alertIDs) > 0) {
  2639.             foreach ($alertIDs as $alertID) {
  2640.                 $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alertID, true);
  2642.                 if ($alertType instanceof \Pimcore\Model\DataObject\AlertType) {
  2643.                     $phenomenaList = $alertType->getPhenomenaList();
  2645.                     if ($phenomenaList) {
  2646.                         foreach ($phenomenaList as $phenomena) {
  2647.                             $phenomenaId = $phenomena->getPhenomena();
  2649.                             if ($phenomenaId) {
  2650.                                 $phenomenaObj = \Pimcore\Model\DataObject::getById($phenomenaId);
  2651.                                 if ($phenomenaObj instanceof \Pimcore\Model\DataObject) {
  2652.                                     $currentId = $phenomenaObj->getphenomenaListId();
  2653.                                     $existingIds = array_column($response, 'id');
  2655.                                     if (!in_array($currentId, $existingIds)) {
  2656.                                         $response[] = [
  2657.                                             "id" => $currentId,
  2658.                                             "nameEn" => $phenomenaObj->getTitle("en"),
  2659.                                             "nameAr" => $phenomenaObj->getTitle("ar"),
  2660.                                             "criteria" => $phenomena->getCriteria()
  2661.                                         ];
  2662.                                     } else {
  2663.                                         $index = array_search($currentId, $existingIds);
  2664.                                         $response[$index]['criteria'] .= ', ' . $phenomena->getCriteria();
  2665.                                     }
  2666.                                 }
  2667.                             }
  2668.                         }
  2669.                     } else {
  2670.                         return ["success" => false, "message" => "No criteria is set"];
  2671.                     }
  2672.                 }
  2673.             }
  2675.             return ["success" => true, "data" => $response];
  2676.         }
  2678.         return ["success" => false, "message" => "Invalid alert type id"];
  2679.     }
  2681.     public function getAlertActions()
  2682.     {
  2683.         $response = [];
  2684.         $alertActions = new DataObject\AlertAction\Listing();
  2685.         $alertActions = $alertActions->load();
  2686.         if ($alertActions) {
  2687.             foreach ($alertActions as $alertAction) {
  2688.                 $response[] = [
  2689.                     "id" => $alertAction->getAlertActionId(),
  2690.                     "nameEn" => $alertAction->getName('en'),
  2691.                     "nameAr" => $alertAction->getName('ar'),
  2692.                     "severity" => $alertAction->getSeverity()
  2693.                 ];
  2694.             }
  2695.         }
  2696.         return ["success" => true, "data" => $response];
  2697.     }
  2699.     public function getAlertHazards()
  2700.     {
  2701.         $response = [];
  2702.         $alertHazards = new DataObject\AlertHazard\Listing();
  2703.         $alertHazards = $alertHazards->load();
  2704.         if ($alertHazards) {
  2705.             foreach ($alertHazards as $alertHazard) {
  2706.                 $response[] = [
  2707.                     "id" => $alertHazard->getalertHazardId(),
  2708.                     "nameEn" => $alertHazard->getName('en'),
  2709.                     "nameAr" => $alertHazard->getName('ar'),
  2710.                     "OrderId" => $alertHazard->getOrderId()
  2711.                 ];
  2712.             }
  2713.         }
  2715.         return ["success" => true, "data" => $response];
  2716.     }
  2718.     public function getAlertTypes()
  2719.     {
  2720.         $response = [];
  2721.         $alertTypes = new DataObject\AlertType\Listing();
  2722.         $alertTypes = $alertTypes->load();
  2723.         if ($alertTypes) {
  2724.             foreach ($alertTypes as $alertType) {
  2725.                 $response[] = [
  2726.                     "id" => $alertType->getAlertTypeId(),
  2727.                     "color" => $alertType->getColor(),
  2728.                     "nameEn" => $alertType->getName('en'),
  2729.                     "nameAr" => $alertType->getName('ar')
  2730.                 ];
  2731.             }
  2732.         }
  2734.         return ["success" => true, "data" => $response];
  2735.     }
  2737.     public function getEvents()
  2738.     {
  2739.         $response = [];
  2740.         $events = new DataObject\Event\Listing();
  2741.         $events = $events->load();
  2742.         if ($events) {
  2743.             foreach ($events as $event) {
  2744.                 $response[] = [
  2745.                     "id" => $event->getEventId(),
  2746.                     "nameEn" => $event->getName('en'),
  2747.                     "nameAr" => $event->getName('ar')
  2749.                 ];
  2750.             }
  2751.         }
  2753.         return ["success" => true, "data" => $response];
  2754.     }
  2755.     public function getWeatherPhenomenones()
  2756.     {
  2757.         $response = [];
  2758.         $weatherPhenomenons = new DataObject\PhenomenaList\Listing();
  2759.         $weatherPhenomenons = $weatherPhenomenons->load();
  2760.         if ($weatherPhenomenons) {
  2761.             foreach ($weatherPhenomenons as $weatherPhenomenon) {
  2762.                 $response[] = [
  2763.                     "id" => $weatherPhenomenon->getPhenomenaListId(),
  2764.                     "nameEn" => $weatherPhenomenon->getTitle('en'),
  2765.                     "nameAr" => $weatherPhenomenon->getTitle('ar')
  2767.                 ];
  2768.             }
  2769.         }
  2771.         return ["success" => true, "data" => $response];
  2772.     }
  2774.     public function getWeatherPhenomenonAffect()
  2775.     {
  2776.         $response = [];
  2777.         $getWeatherPhenomAffects = new DataObject\WeatherPhenomenonAffect\Listing();
  2778.         $getWeatherPhenomAffects = $getWeatherPhenomAffects->load();
  2779.         if ($getWeatherPhenomAffects) {
  2780.             foreach ($getWeatherPhenomAffects as $getWeatherPhenomAffect) {
  2781.                 $response[] = [
  2782.                     "id" => $getWeatherPhenomAffect->getWeatherPhenomenonAffectId(),
  2783.                     "nameEn" => $getWeatherPhenomAffect->getName('en'),
  2784.                     "nameAr" => $getWeatherPhenomAffect->getName('ar')
  2786.                 ];
  2787.             }
  2788.         }
  2790.         return ["success" => true, "data" => $response];
  2791.     }
  2793.     public function getAlertStatuses($params)
  2794.     {
  2795.         $response = [];
  2796.         $alertStatuss = new DataObject\AlertStatus\Listing();
  2797.         // Handle search by name
  2798.         if (isset($params['search']) && !empty($params['search'])) {
  2799.             $alertStatuss->addConditionParam("name LIKE ?", "%" . $params['search'] . "%");
  2800.         }
  2801.         // Handle alert type filter
  2802.         if (isset($params['alert_id']) && !empty($params['alert_id'])) {
  2803.             $alertTypeIds = [];
  2804.             $alertTypeList = new DataObject\AlertType\Listing();
  2805.             $alertTypeList->addConditionParam("alertTypeId IN (?)", [$params['alert_id']]);
  2806.             foreach ($alertTypeList as $alertType) {
  2807.                 $alertTypeIds[] = $alertType->getId();
  2808.             }
  2809.             $alertStatuss->addConditionParam("alertType__id IN (?)", [$alertTypeIds]);
  2810.         }
  2811.         // Check for regionId array and isLandLocked logic
  2812.         $excludeWavesRising = false;
  2813.         if (isset($params['regionId']) && is_array($params['regionId']) && count($params['regionId']) > 0) {
  2814.             foreach ($params['regionId'] as $regionId) {
  2815.                 $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  2816.                 if ($region && $region->getIsLandLocked()) {
  2817.                     $excludeWavesRising = true;
  2818.                     break;
  2819.                 }
  2820.             }
  2821.         }
  2822.         $alertStatuss = $alertStatuss->load();
  2823.         if ($alertStatuss) {
  2824.             foreach ($alertStatuss as $alertStatus) {
  2825.                 // Exclude "Waves rising" if needed
  2826.                 if ($excludeWavesRising && ((strtolower(trim($alertStatus->getName('en'))) === 'waves rising'))) {
  2827.                     continue;
  2828.                 }
  2829.                 $alertType = $alertStatus->getAlertType();
  2830.                 $alertData = [];
  2831.                 if (!empty($alertType)) {
  2832.                     $alertData = [
  2833.                         "id" => $alertType->getAlertTypeId(),
  2834.                         "nameEn" => $alertType->getName('en'),
  2835.                         "nameAr" => $alertType->getName('ar')
  2836.                     ];
  2837.                 }
  2838.                 $response[] = [
  2839.                     "id" => $alertStatus->getalertStatusId(),
  2840.                     "nameEn" => $alertStatus->getName('en'),
  2841.                     "nameAr" => $alertStatus->getName('ar'),
  2842.                     "imageTemplate" => $alertStatus->getimageTemplate(),
  2843.                     "alertType" => $alertData
  2844.                 ];
  2845.             }
  2846.         }
  2847.         return ["success" => true, "data" => $response];
  2848.     }
  2850.     public function getGovernorates()
  2851.     {
  2852.         $response = [];
  2853.         $governorates = new DataObject\Governorate\Listing();
  2854.         $Governorates = $governorates->load();
  2855.         if ($governorates) {
  2856.             foreach ($governorates as $governorate) {
  2857.                 $region = $governorate->getregionId();
  2858.                 $regionData = [];
  2859.                 if (!empty($region)) {
  2860.                     $regionData = [
  2861.                         "id" => $region->getRegionId(),
  2862.                         "nameEn" => $region->getName('en'),
  2863.                         "nameAr" => $region->getName('ar'),
  2864.                         "longitude" => $region->getLongitude(),
  2865.                         "latitude" => $region->getLongitude()
  2867.                     ];
  2868.                 }
  2869.                 $response[] = [
  2870.                     "id" => $governorate->getgovernoteId(),
  2871.                     "nameEn" => $governorate->getName('en'),
  2872.                     "nameAr" => $governorate->getName('ar'),
  2873.                     "regionId" => $regionData,
  2874.                     "longitude" => $governorate->getLongitude(),
  2875.                     "latitude" => $governorate->getLatitude(),
  2876.                     "isHidden" => $governorate->getisHidden(),
  2877.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  2878.                     "MunicipalityID" => $governorate->getMunicipalityID()
  2879.                 ];
  2880.             }
  2881.         }
  2883.         return ["success" => true, "data" => $response];
  2884.     }
  2886.     public function getMunicipality($governorateId = null, $lang = 'en')
  2887.     {
  2888.         $response = [];
  2889.         $municipalities = new DataObject\Municipality\Listing();
  2890.         if (is_array($governorateId)) {
  2891.             $govIdsArr = [];
  2892.             foreach ($governorateId as $govId) {
  2893.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  2894.                 if ($governorate) {
  2895.                     array_push($govIdsArr, $governorate->getId());
  2896.                 }
  2897.             }
  2898.             $municipalities->setCondition("governorate__id IN (" . implode(", ", $govIdsArr) . ")");
  2899.         } else {
  2900.             if ($governorateId) {
  2901.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($governorateId, true);
  2902.                 $municipalities->setCondition("governorate__id = ?", [$governorate->getId()]);
  2903.             }
  2904.         }
  2905.         $municipalities = $municipalities->load();
  2906.         if ($municipalities) {
  2907.             foreach ($municipalities as $municipality) {
  2908.                 $response[] = [
  2909.                     "id" => $municipality->getMunicipalityid(),
  2910.                     "nameEn" => $municipality->getName('en'),
  2911.                     "nameAr" => $municipality->getName('ar'),
  2912.                     "longitude" => $municipality->getLongitude(),
  2913.                     "latitude" => $municipality->getLatitude(),
  2914.                     "governate" => $municipality->getGovernorate()->getGovernoteId()
  2915.                 ];
  2916.             }
  2917.         }
  2919.         // Determine sorting field based on language
  2920.         $sortField = 'nameEn'; // Default sorting by English
  2921.         if (isset($lang) && strtolower($lang) === 'ar') {
  2922.             $sortField = 'nameAr'; // Sorting by Arabic
  2923.         }
  2925.         // Sort manually using usort()
  2926.         usort($response, function ($a, $b) use ($sortField) {
  2927.             return strcmp($a[$sortField], $b[$sortField]);
  2928.         });
  2930.         return ["success" => true, "data" => $response];
  2931.     }
  2933.     public function getGovernoratesByRegion($params)
  2934.     {
  2935.         $response = [];
  2937.         $governorates = new DataObject\Governorate\Listing();
  2939.         if (isset($params['region_id'])) {
  2940.             $region = \Pimcore\Model\DataObject\Region::getByRegionId($params['region_id'], true);
  2941.             if (!$region) {
  2942.                 throw new \Exception("Region not available");
  2943.             }
  2944.             $governorates->filterByRegionId($region);
  2945.         }
  2947.         if (isset($params['region_ids']) && !empty($params['region_ids'])) {
  2948.             $regionIds = [];
  2949.             $regionList = new DataObject\Region\Listing();
  2950.             $regionList->addConditionParam("regionId IN (?)", [$params['region_ids']]);
  2951.             foreach ($regionList as $region) {
  2952.                 $regionIds[] = $region->getId();
  2953.             }
  2954.             $governorates->addConditionParam("regionId__id IN (?)", [$regionIds]);
  2955.         }
  2957.         // Load governorates without sorting in Pimcore
  2958.         $governorates = $governorates->load();
  2960.         // Convert to array for manual sorting
  2961.         $count = 0;
  2962.         if ($governorates) {
  2963.             foreach ($governorates as $governorate) {
  2964.                 $region = $governorate->getregionId();
  2965.                 $regionData = [];
  2966.                 if (!empty($region)) {
  2967.                     $regionData = [
  2968.                         "id" => $region->getRegionId(),
  2969.                         "nameEn" => $region->getName('en'),
  2970.                         "nameAr" => $region->getName('ar'),
  2971.                         "longitude" => $region->getLongitude(),
  2972.                         "latitude" => $region->getLatitude()
  2974.                     ];
  2975.                 }
  2976.                 $response[$count] = [
  2977.                     "id" => $governorate->getgovernoteId(),
  2978.                     "nameEn" => $governorate->getName('en'),
  2979.                     "nameAr" => $governorate->getName('ar'),
  2980.                     "regionId" => $regionData,
  2981.                     "longitude" => $governorate->getLongitude(),
  2982.                     "latitude" => $governorate->getLatitude(),
  2983.                     "isHidden" => $governorate->getisHidden(),
  2984.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  2985.                     "MunicipalityID" => $governorate->getMunicipalityID(),
  2986.                     "bbox" => $governorate->getBbox()
  2987.                 ];
  2989.                 if ($governorate->getMunicipalityID() && $governorate->getIsMunicipality()) {
  2990.                     $municipality = \Pimcore\Model\DataObject\Municipality::getBymunicipalityid($governorate->getMunicipalityID(), true);
  2991.                     if ($municipality) {
  2992.                         $muniGovernate = $municipality->getgovernorate();
  2993.                         if ($muniGovernate) {
  2994.                             $response[$count]["parent_id"] = $muniGovernate->getgovernoteId();
  2995.                             $response[$count]["parent_longitude"] = $muniGovernate->getLongitude();
  2996.                             $response[$count]["parent_latitude"] = $muniGovernate->getLatitude();
  2997.                             $response[$count]["parent_name_en"] = $muniGovernate->getName("en");
  2998.                             $response[$count]["parent_name_ar"] = $muniGovernate->getName("ar");
  2999.                         }
  3000.                     }
  3001.                 }
  3002.                 $count++;
  3003.             }
  3004.         }
  3006.         // Determine sorting field based on language
  3007.         $sortField = 'nameEn'; // Default sorting by English
  3008.         if (isset($params['lang']) && strtolower($params['lang']) === 'ar') {
  3009.             $sortField = 'nameAr'; // Sorting by Arabic
  3010.         }
  3012.         // Sort manually using usort()
  3013.         usort($response, function ($a, $b) use ($sortField) {
  3014.             return strcmp($a[$sortField], $b[$sortField]);
  3015.         });
  3017.         return ["success" => true, "data" => $response];
  3018.     }
  3021.     public function getVersions($notificationObject, $translator, $decodedJwtToken = null, $userPermission = null)
  3022.     {
  3023.         $snapshots = $this->collectUpdateVersionSnapshots($notificationObject);
  3024.         $resultAscending = [];
  3026.         foreach ($snapshots as $index => $snap) {
  3027.             /** @var EwsNotification $viewNotification */
  3028.             $viewNotification = $snap['obj'];
  3029.             $previous = $index > 0 ? $snapshots[$index - 1]['obj'] : null;
  3030.             $formatted = $this->createNotificationFormat($viewNotification, $translator, $decodedJwtToken, $userPermission);
  3031.             $formatted['updateChanges'] = $this->buildNotificationUpdateChanges(
  3032.                 $viewNotification,
  3033.                 $previous instanceof EwsNotification ? $previous : null,
  3034.                 $translator
  3035.             );
  3036.             $resultAscending[] = $formatted;
  3037.         }
  3039.         // Newest first (matches Pimcore getVersions() iteration order).
  3040.         return array_reverse($resultAscending);
  3041.     }
  3043.     /**
  3044.      * Format live notification payload and attach updateChanges vs previous Update version.
  3045.      */
  3046.     private function formatNotificationWithUpdateChanges(
  3047.         EwsNotification $notification,
  3048.         $translator,
  3049.         $decodedJwtToken = null,
  3050.         $userPermission = null
  3051.     ): array {
  3052.         $formatted = $this->createNotificationFormat($notification, $translator, $decodedJwtToken, $userPermission);
  3053.         $formatted['updateChanges'] = $this->buildNotificationUpdateChanges(
  3054.             $notification,
  3055.             $this->resolvePreviousUpdateForCurrent($notification),
  3056.             $translator
  3057.         );
  3059.         return $formatted;
  3060.     }
  3062.     /**
  3063.      * Collect Update-note version snapshots oldest → newest.
  3064.      *
  3065.      * @return array<int, array{ts: int, obj: EwsNotification}>
  3066.      */
  3067.     private function collectUpdateVersionSnapshots(EwsNotification $notification): array
  3068.     {
  3069.         $snapshots = [];
  3070.         $versions = $notification->getVersions() ?: [];
  3071.         foreach ($versions as $version) {
  3072.             if ($version->getNote() !== 'Update') {
  3073.                 continue;
  3074.             }
  3075.             $view = $version->loadData();
  3076.             if (!$view instanceof EwsNotification) {
  3077.                 continue;
  3078.             }
  3079.             $snapshots[] = [
  3080.                 'ts' => (int) ($version->getDate() ?: $view->getModificationDate() ?: $view->getCreationDate()),
  3081.                 'obj' => $view,
  3082.             ];
  3083.         }
  3085.         usort($snapshots, static fn($a, $b) => ($a['ts'] ?? 0) <=> ($b['ts'] ?? 0));
  3087.         return array_values($snapshots);
  3088.     }
  3090.     private function resolvePreviousUpdateForCurrent(EwsNotification $current): ?EwsNotification
  3091.     {
  3092.         $snapshots = $this->collectUpdateVersionSnapshots($current);
  3093.         if ($snapshots === []) {
  3094.             return null;
  3095.         }
  3097.         $lastIndex = count($snapshots) - 1;
  3098.         $last = $snapshots[$lastIndex];
  3099.         $lastMod = (int) ($last['obj']->getModificationDate() ?: 0);
  3100.         $currentMod = (int) ($current->getModificationDate() ?: 0);
  3102.         // Latest Update version is usually the same state as the live object.
  3103.         if ($lastMod === $currentMod || (int) ($last['ts'] ?? 0) >= $currentMod) {
  3104.             return $lastIndex >= 1 ? $snapshots[$lastIndex - 1]['obj'] : null;
  3105.         }
  3107.         return $last['obj'];
  3108.     }
  3110.     /**
  3111.      * Text describing what changed, plus map images from polygonXAtachment.
  3112.      * - Location or alertType change → previous + after images
  3113.      * - Any other update → single current image
  3114.      * Text fields are always returned in both en and ar.
  3115.      *
  3116.      * @return array{
  3117.      *   textEn: string,
  3118.      *   textAr: string,
  3119.      *   items: array<int, array{key: string, titleEn: string, titleAr: string, detailEn: string, detailAr: string}>,
  3120.      *   images: array{previous: string, current: string}
  3121.      * }
  3122.      */
  3123.     private function buildNotificationUpdateChanges(
  3124.         EwsNotification $current,
  3125.         ?EwsNotification $previous,
  3126.         $translator
  3127.     ): array {
  3128.         $timezone = new \DateTimeZone(defined('TIMEZONE') ? TIMEZONE : 'Asia/Riyadh');
  3130.         // Canonical action keys (language-independent), titles resolved per locale below.
  3131.         $actionKeys = [];
  3132.         $seenKeys = [];
  3133.         foreach ($this->extractRelevantHistoryActions($current, $translator, 'en') as $actionMeta) {
  3134.             $key = (string) ($actionMeta['key'] ?? '');
  3135.             if ($key === '' || isset($seenKeys[$key])) {
  3136.                 continue;
  3137.             }
  3138.             $seenKeys[$key] = true;
  3139.             $actionKeys[] = $key;
  3140.         }
  3142.         $hasLocationUpdate = in_array('Update Alert Location', $actionKeys, true);
  3143.         $hasAlertTypeUpdate = in_array('Raise Alert', $actionKeys, true) || in_array('Lower Alert', $actionKeys, true);
  3145.         // Fallback when alertAction labels are missing but fields clearly changed.
  3146.         if ($previous) {
  3147.             if (!$hasAlertTypeUpdate && $this->hasSeverityChanged($current, $previous)) {
  3148.                 $hasAlertTypeUpdate = true;
  3149.                 $actionKeys[] = $this->resolveRaiseOrLowerKey($previous, $current);
  3150.             }
  3151.             if (!$hasLocationUpdate && $this->hasLocationChanged($current, $previous)) {
  3152.                 $hasLocationUpdate = true;
  3153.                 $actionKeys[] = 'Update Alert Location';
  3154.             }
  3155.         }
  3157.         $items = [];
  3158.         $textPartsEn = [];
  3159.         $textPartsAr = [];
  3161.         foreach ($actionKeys as $key) {
  3162.             $titleEn = $this->resolveUpdateChangeTitle($key, $current, $translator, 'en');
  3163.             $titleAr = $this->resolveUpdateChangeTitle($key, $current, $translator, 'ar');
  3164.             $detailEn = $this->buildAlertHistoryActionDetail(
  3165.                 $key,
  3166.                 $current,
  3167.                 $previous,
  3168.                 $timezone,
  3169.                 $translator,
  3170.                 'en'
  3171.             );
  3172.             $detailAr = $this->buildAlertHistoryActionDetail(
  3173.                 $key,
  3174.                 $current,
  3175.                 $previous,
  3176.                 $timezone,
  3177.                 $translator,
  3178.                 'ar'
  3179.             );
  3181.             $items[] = [
  3182.                 'key' => $key,
  3183.                 'titleEn' => $titleEn,
  3184.                 'titleAr' => $titleAr,
  3185.                 'detailEn' => $detailEn,
  3186.                 'detailAr' => $detailAr,
  3187.             ];
  3188.             $textPartsEn[] = $detailEn !== '' ? ($titleEn . ': ' . $detailEn) : $titleEn;
  3189.             $textPartsAr[] = $detailAr !== '' ? ($titleAr . ': ' . $detailAr) : $titleAr;
  3190.         }
  3192.         $currentImage = $this->getPolygonXAttachmentUrl($current) ?? '';
  3193.         if ($hasLocationUpdate || $hasAlertTypeUpdate) {
  3194.             // Location / alertType change → before & after map images
  3195.             $images = [
  3196.                 'previous' => $previous ? ($this->getPolygonXAttachmentUrl($previous) ?? '') : '',
  3197.                 'current' => $currentImage,
  3198.             ];
  3199.         } else {
  3200.             // All other updates → same shape, previous empty
  3201.             $images = [
  3202.                 'previous' => '',
  3203.                 'current' => $currentImage,
  3204.             ];
  3205.         }
  3207.         return [
  3208.             'textEn' => implode("\n", array_filter($textPartsEn, static fn($t) => $t !== '')),
  3209.             'textAr' => implode("\n", array_filter($textPartsAr, static fn($t) => $t !== '')),
  3210.             'items' => $items,
  3211.             'images' => $images,
  3212.         ];
  3213.     }
  3215.     private function resolveUpdateChangeTitle(
  3216.         string $key,
  3217.         EwsNotification $notification,
  3218.         $translator,
  3219.         string $lang
  3220.     ): string {
  3221.         $actions = $notification->getAlertAction() ?: [];
  3222.         foreach ($actions as $action) {
  3223.             if (!$action) {
  3224.                 continue;
  3225.             }
  3226.             $mapped = $this->mapAlertActionToHistoryTitle((string) $action->getName('en'));
  3227.             if ($mapped === $key) {
  3228.                 $localized = (string) ($action->getName($lang) ?: '');
  3229.                 if ($localized !== '') {
  3230.                     return $localized;
  3231.                 }
  3232.                 break;
  3233.             }
  3234.         }
  3236.         return $this->transAlertHistory($key, $translator, $lang);
  3237.     }
  3239.     private function getPolygonXAttachmentUrl(?EwsNotification $notification): ?string
  3240.     {
  3241.         if (!$notification) {
  3242.             return null;
  3243.         }
  3244.         $asset = $notification->getPolygonXAtachment();
  3245.         if (!$asset || !method_exists($asset, 'getFullPath')) {
  3246.             return null;
  3247.         }
  3248.         $path = (string) $asset->getFullPath();
  3249.         if ($path === '') {
  3250.             return null;
  3251.         }
  3253.         return BASE_URL . $path;
  3254.     }
  3256.     private function hasSeverityChanged(EwsNotification $current, EwsNotification $previous): bool
  3257.     {
  3258.         $from = strtolower((string) ($previous->getAlertType()?->getColor() ?? ''));
  3259.         $to = strtolower((string) ($current->getAlertType()?->getColor() ?? ''));
  3261.         return $from !== '' && $to !== '' && $from !== $to;
  3262.     }
  3264.     private function hasLocationChanged(EwsNotification $current, EwsNotification $previous): bool
  3265.     {
  3266.         $currentGov = $this->extractGovernorateNamesForHistory($current, 'en');
  3267.         $previousGov = $this->extractGovernorateNamesForHistory($previous, 'en');
  3268.         sort($currentGov);
  3269.         sort($previousGov);
  3270.         if ($currentGov !== $previousGov) {
  3271.             return true;
  3272.         }
  3274.         $currentCoords = (string) ($current->getCoordinates() ?? '');
  3275.         $previousCoords = (string) ($previous->getCoordinates() ?? '');
  3276.         if ($currentCoords !== $previousCoords) {
  3277.             return true;
  3278.         }
  3280.         $currentPolygonId = $current->getPolygon()?->getId();
  3281.         $previousPolygonId = $previous->getPolygon()?->getId();
  3283.         return $currentPolygonId !== $previousPolygonId;
  3284.     }
  3286.     private function resolveAlertSeverityLabel(EwsNotification $notification, string $lang = 'en', $translator = null): string
  3287.     {
  3288.         $color = (string) ($notification->getAlertType()?->getColor() ?? '');
  3289.         if ($color === '') {
  3290.             return '';
  3291.         }
  3292.         $label = ucwords(strtolower($color));
  3294.         return $this->transAlertHistory($label, $translator, $lang);
  3295.     }
  3297.     private function resolveRaiseOrLowerKey(EwsNotification $previous, EwsNotification $current): string
  3298.     {
  3299.         $rank = ['green' => 1, 'yellow' => 2, 'orange' => 3, 'red' => 4];
  3300.         $from = strtolower((string) ($previous->getAlertType()?->getColor() ?? ''));
  3301.         $to = strtolower((string) ($current->getAlertType()?->getColor() ?? ''));
  3302.         $fromRank = $rank[$from] ?? 0;
  3303.         $toRank = $rank[$to] ?? 0;
  3305.         return $toRank < $fromRank ? 'Lower Alert' : 'Raise Alert';
  3306.     }
  3308.     private function resolveRaiseOrLowerTitle(
  3309.         EwsNotification $previous,
  3310.         EwsNotification $current,
  3311.         $translator,
  3312.         string $lang
  3313.     ): string {
  3314.         return $this->transAlertHistory(
  3315.             $this->resolveRaiseOrLowerKey($previous, $current),
  3316.             $translator,
  3317.             $lang
  3318.         );
  3319.     }
  3321.     public function ewsNotificationHasVersionUpdateHistory(EwsNotification $notification): bool
  3322.     {
  3323.         $updateCount = 0;
  3324.         foreach ($notification->getVersions() ?: [] as $version) {
  3325.             if ($version->getNote() === 'Update') {
  3326.                 $updateCount++;
  3327.                 if ($updateCount > 1) {
  3328.                     return true;
  3329.                 }
  3330.             }
  3331.         }
  3333.         return false;
  3334.     }
  3336.     private function createNotificationFormat($notification, $translator, $decodedJwtToken = null, $userPermission = null)
  3337.     {
  3338.         $response = [];
  3339.         $critetia = '';
  3340.         $critetiaAr = '';
  3341.         $status = 'active';
  3342.         $alertType = $notification->getAlertType();
  3343.         $phenomena = $notification->getWeatherPhenomenon();
  3344.         // Set the timezone to Asia/Riyadh
  3345.         $timezone = new \DateTimeZone(TIMEZONE);
  3346.         // Convert start and end dates to Asia/Riyadh timezone
  3347.         $startDate = $notification->getStartDate() ? $notification->getStartDate()->setTimezone($timezone) : null;
  3348.         $endDate = $notification->getEndDate() ? $notification->getEndDate()->setTimezone($timezone) : null;
  3349.         $alertEndDate = $notification->getAlertEndDate() ? $notification->getAlertEndDate()->setTimezone($timezone) : null;
  3350.         if ($alertType && $phenomena) {
  3351.             $phenomenaList = $alertType->getPhenomenaList();
  3352.             if ($phenomenaList) {
  3353.                 $items = $phenomenaList->getItems();
  3354.                 if ($items) {
  3355.                     foreach ($items as $item) {
  3356.                         if ($item->getPhenomena() == $phenomena->getId()) {
  3357.                             $critetia = $item->getCriteria();
  3358.                             $critetiaAr = $item->getCriteriaAr();
  3359.                             break;
  3360.                         }
  3361.                     }
  3362.                 }
  3363.             }
  3364.         }
  3365.         if ($notification->getStatus() != "ended") {
  3366.             if ($endDate && $endDate < new \DateTime('now', $timezone)) {
  3367.                 $status = "expired";
  3368.             }
  3369.             $twentyFourHoursAgo = (new \DateTime('now', $timezone))->modify('-24 hours');
  3370.             if ($endDate && $endDate < $twentyFourHoursAgo) {
  3371.                 $status = "archived";
  3372.             }
  3373.         } else {
  3374.             $twentyFourHoursAgo = (new \DateTime('now', $timezone))->modify('-24 hours');
  3375.             if ($alertEndDate && $alertEndDate < $twentyFourHoursAgo) {
  3376.                 $status = "archived";
  3377.             } else {
  3378.                 $status = "ended";
  3379.             }
  3380.         }
  3382.         $hideUnpublishedBackup = DataObject::doHideUnpublished();
  3383.         DataObject::setHideUnpublished(false);
  3384.         $polygonId = $notification->getPolygon()?->getId();
  3385.         $linkedAlertIds = array_map(
  3386.             fn($obj) => $obj->getId(),
  3387.             $notification->getPolygon()?->getEwsAlerts(true) ?? []
  3388.         );
  3389.         $polCoords = $notification->getPolygon() ? json_decode($notification->getPolygon()->getcoordinates()) : [];
  3390.         $polExpired = $notification->getPolygon() && $notification->getPolygon()->getExpire() ? $notification->getPolygon()->getExpire() : null;
  3391.         $polPublished = $notification->getPolygon() ? $notification->getPolygon()->getPublished() : false;
  3392.         DataObject::setHideUnpublished($hideUnpublishedBackup);
  3395.         // Initialize edit and delete flags
  3396.         $editFlag = false;
  3399.         // Get the current report's type key
  3400.         $notificationType = $notification->getNotificationType();
  3402.         // Map report type keys to permission names
  3403.         $permissionMapping = [
  3404.             'Default' => 'edit_ews_notification',
  3405.             'Polygon' => 'update_ews_notification_polygon',
  3406.             'Map' => 'update_ews_notification_map'
  3407.         ];
  3409.         // Check permissions only for the current report type
  3410.         // if ($notificationType && isset($permissionMapping[$notificationType]) && !empty($userPermission)) {
  3411.         //     $permissionName = $permissionMapping[$notificationType];
  3412.         //     $permissionStatus = $userPermission->getUserPermissions($decodedJwtToken, $translator);
  3414.         //     // Check edit permission
  3415.         //     if (isset($permissionStatus['grants']["$permissionName"]) && $permissionStatus['grants']["$permissionName"] === true) {
  3416.         //         $editFlag = true;
  3417.         //     }
  3420.         // }
  3422.         $response = [
  3423.             "id" => $notification->getId(),
  3424.             "searchEwsIdEn" => $notification->getEwsSearchId("en"),
  3425.             "searchEwsIdAr" => $notification->getEwsSearchId("ar"),
  3426.             "title" => $startDate ? $startDate->format("dmY") . '-' . $notification->getId() : '',
  3427.             "alertType" => !empty($notification->getAlertType()) ? $notification->getAlertType()->getAlertTypeId() : "",
  3428.             "alertTypeAr" => !empty($notification->getAlertType()) ? $notification->getAlertType()->getName("ar") : "",
  3429.             "alertTypeEn" => !empty($notification->getAlertType()) ? ucwords($notification->getAlertType()->getColor()) : "",
  3430.             "fromDate" => $startDate ? $startDate->format("Y-m-d H:i:s") : "",
  3431.             "toDate" => $endDate ? $endDate->format("Y-m-d H:i:s") : "",
  3432.             "alertEndDate" => $alertEndDate && $status == "ended"  ? $alertEndDate->format("Y-m-d H:i:s") : null,
  3433.             "alertStatusID" => !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getAlertStatusId() : "",
  3434.             "alertStatusAr" => !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName("ar") : "",
  3435.             "alertStatusEn" => !empty($notification->getAlertStatus()) ? $notification->getAlertStatus()->getName("en") : "",
  3436.             "alertStatusCategory" => "",
  3437.             "alertHazard" => !empty($notification->getAlertHazard()) ? $this->getAlertHazardArr($notification->getAlertHazard()) : [],
  3438.             "regionID" => !empty($notification->getRegion()) ? $notification->getRegion()->getRegionId() : "",
  3439.             "regionAR" => !empty($notification->getRegion()) ? $notification->getRegion()->getName("ar") : "",
  3440.             "regionEn" => !empty($notification->getRegion()) ? $notification->getRegion()->getName("en") : "",
  3441.             "governorates" => ($notification->getRegion()) ? $this->getGovernorateDetail($notification->getGovernorate()) : [],
  3442.             "mapGovernorates" => $notification->getMapGovernorate() ? $this->getGovernorateDetail($notification->getMapGovernorate()) : [],
  3443.             "ewsOtherLocations" => ($notification->getRegion()) ? $this->getGovernorateDetail($notification->getEwsOtherLocations()) : [],
  3444.             "otherLocationsAr" => $this->getOtherLocationsNames($notification->getEwsOtherLocations(), 'ar'),
  3445.             "otherLocationsEn" => $this->getOtherLocationsNames($notification->getEwsOtherLocations(), 'en'),
  3446.             "tweetID" => "",
  3447.             "enableTwitterNotification" => $notification->getEnableTwitterNotification(),
  3448.             "enableSMSNotification" => $notification->getEnableSMSNotification(),
  3449.             "enableEmailNotification" => $notification->getEnableEmailNotification(),
  3450.             "alertActions" => $this->getAlertActionsByArr($notification->getAlertAction()),
  3451.             "municipalities" => $this->getMunicipalityArr($notification->getMunicipality()),
  3452.             "centers" => $this->getCenterArr($notification->getCenter()),
  3453.             "districts" => $this->getDistrictArr($notification->getDistrict()),
  3454.             "lastModified" => ($notification->getModificationDate()) ? date("Y-m-d H:i:s", $notification->getModificationDate()) : "",
  3455.             "last_modified_date" => ($notification->getModificationDate()) ? date("Y-m-d", $notification->getModificationDate()) : "",
  3456.             'coordinates' => $notification->getCoordinates(),
  3457.             'message' => $notification->getMessage("en"),
  3458.             "message_en" => Bilingual::to($notification->getMessage("en"), 'en'),
  3459.             "message_ar" => Bilingual::to($notification->getMessage("en"), 'ar'),
  3460.             "file" => (!empty($notification->getAttachment())) ? API_BASE_URL . $notification->getAttachment()->getFullPath() : [],
  3461.             'criteria' => $critetia,
  3462.             'criteriaAr' => $critetiaAr,
  3463.             'created_at' => ($notification->getCreationDate()) ? date("Y-m-d H:i:s", $notification->getCreationDate()) : "",
  3464.             'created_by' => ($notification->getUser()) ? $notification->getUser()->getName() : "",
  3465.             'edited_by' => ($notification->getEditor()) ? $notification->getEditor()->getName() : (($notification->getUser()) ? $notification->getUser()->getName() : ""),
  3466.             'status_en' => ucfirst($status),
  3467.             'status_ar' => $translator->trans(ucfirst($status), [], null, 'ar'),
  3468.             'previewText' => $notification->getPreviewText() ?? false,
  3469.             'isPolygon' => $notification->getIsPolygon(),
  3470.             'linkedAlerts' => $linkedAlertIds,
  3471.             'polygonId' => $polygonId,
  3472.             'polygonCoordinates' => $polCoords,
  3473.             'polygonExpired' => $polExpired,
  3474.             'polygonPublished' => $polPublished,
  3475.             'canEdit' => $editFlag,
  3476.             'notificationType' => $notification->getNotificationType(),
  3477.             'alertPage' => $notification->getAlertPage(),
  3478.             'x_post' => $notification->getXPost(),
  3479.             'user_group_ids' => array_map(
  3480.                 fn($group) => $group->getId(),
  3481.                 $notification->getUserGroup()
  3482.             ),
  3483.         ];
  3484.         return $response;
  3485.     }
  3487.     /**
  3488.      * Same payload shape as one element in device API search-ews-notification "data" (plus optional caller fields).
  3489.      */
  3490.     public function buildSearchEwsNotificationAlertPayload(
  3491.         EwsNotification $notification,
  3492.         $translator,
  3493.         $decodedJwtToken = null,
  3494.         $userPermission = null
  3495.     ): array {
  3496.         return $this->createNotificationFormat($notification, $translator, $decodedJwtToken, $userPermission);
  3497.     }
  3499.     private function getAlertHazardArr($alertHazardArr)
  3500.     {
  3501.         $result = [];
  3502.         if ($alertHazardArr) {
  3503.             foreach ($alertHazardArr as $affect) {
  3504.                 $result[] = [
  3505.                     "pim_id" => $affect->getId(),
  3506.                     "id" => $affect->getAlertHazardId(),
  3507.                     "nameEn" => $affect->getName("en"),
  3508.                     "nameAr" => $affect->getName("ar"),
  3509.                 ];
  3510.             }
  3511.         }
  3513.         return $result;
  3514.     }
  3516.     private function getAlertActionsByArr($alertActions)
  3517.     {
  3518.         $result = [];
  3519.         if ($alertActions) {
  3520.             foreach ($alertActions as $alert) {
  3521.                 $result[] = [
  3522.                     "pim_id" => $alert->getId(),
  3523.                     "id" => $alert->getAlertActionId(),
  3524.                     "descriptionEn" => $alert->getName("en"),
  3525.                     "descriptionAr" => $alert->getName("ar"),
  3526.                 ];
  3527.             }
  3528.         }
  3530.         return $result;
  3531.     }
  3533.     private function getMunicipalityArr($municipalities)
  3534.     {
  3535.         $result = [];
  3536.         if ($municipalities) {
  3537.             foreach ($municipalities as $municipality) {
  3538.                 // p_R($municipality->getName());                
  3539.                 $result[] = [
  3540.                     "id" => $municipality->getMunicipalityId(),
  3541.                     "nameEn" => $municipality->getName("en"),
  3542.                     "nameAr" => $municipality->getName("ar"),
  3543.                     "governate" => $municipality->getGovernorate()->getGovernoteId()
  3544.                 ];
  3545.             }
  3546.         }
  3548.         return $result;
  3549.     }
  3550.     private function getDistrictArr($districts)
  3551.     {
  3552.         $result = [];
  3553.         if ($districts) {
  3554.             foreach ($districts as $district) {
  3555.                 $result[] = [
  3556.                     "id" => $district->getId(),
  3557.                     "nameEn" => $district->getName("en"),
  3558.                     "nameAr" => $district->getName("ar"),
  3559.                     "longitude" => $district->getLongitude(),
  3560.                     "latitude" => $district->getLatitude(),
  3561.                     "governate" => $district->getGovernorate()->getGovernoteId()
  3562.                 ];
  3563.             }
  3564.         }
  3566.         return $result;
  3567.     }
  3568.     private function getCenterArr($centers)
  3569.     {
  3570.         $result = [];
  3571.         if ($centers) {
  3572.             foreach ($centers as $center) {
  3573.                 $result[] = [
  3574.                     "id" => $center->getId(),
  3575.                     "nameEn" => $center->getName("en"),
  3576.                     "nameAr" => $center->getName("ar"),
  3577.                     "longitude" => $center->getLongitude(),
  3578.                     "latitude" => $center->getLatitude(),
  3579.                     "governate" => $center->getGovernorate()->getGovernoteId()
  3580.                 ];
  3581.             }
  3582.         }
  3584.         return $result;
  3585.     }
  3586.     private function getOtherLocationsNames($otherLocations, $lang = 'ar')
  3587.     {
  3588.         $names = []; // Step 1: Initialize an array to hold the names
  3590.         if ($otherLocations) {
  3592.             foreach ($otherLocations as $otherLocation) {
  3593.                 $names[] = $otherLocation->getName($lang); // Step 2 & 3: Extract and collect names
  3594.             }
  3595.         }
  3596.         if (empty($names)) { // Check if the names array is empty
  3597.             return ''; // Return an empty string if there are no names
  3598.         }
  3600.         $namesString = implode(', ', $names); // Step 4: Convert the array to a comma-separated string
  3602.         return $namesString; // Return or use the comma-separated string as needed
  3603.     }
  3605.     private function shouldDispatchPublicPortalEwsWebhook(EwsNotification $notification): bool
  3606.     {
  3607.         if ($notification->getPublished()) {
  3608.             return true;
  3609.         }
  3610.         $status = (string) $notification->getStatus();
  3612.         return $status === 'ended' || $status === 'archived';
  3613.     }
  3615.     private function dispatchPublicPortalEwsWebhookIfConfigured(int $notificationId, ?LoggerInterface $logger = null): void
  3616.     {
  3617.         try {
  3618.             PublicPortalEwsWebhookProcessLauncher::dispatch($notificationId, $logger);
  3619.         } catch (\Throwable $e) {
  3620.             if ($logger !== null) {
  3621.                 $logger->warning('Public portal EWS webhook dispatch failed: ' . $e->getMessage());
  3622.             }
  3623.         }
  3624.     }
  3626.     public function publishEwsNotification($notificationId, $published, $userGroupIds, $translator, $emailService, $templating, $logger)
  3627.     {
  3628.         $result = [];
  3631.         $viewNotification = DataObject\EwsNotification::getById($notificationId, false);
  3633.         if (!$viewNotification) {
  3634.             $viewNotification = DataObject\EwsNotification::getById($notificationId, true);
  3635.         }
  3636.         if ($published) {
  3637.             $viewNotification->setStatus("active");
  3638.         } else {
  3639.             $viewNotification->setStatus("");
  3640.         }
  3641.         $viewNotification->setPublished($published);
  3643.         //set ews search Id
  3644.         $currentDate = new \DateTime();
  3645.         $formattedDate = $currentDate->format('dmY') . '-' . $viewNotification->getId();
  3646.         $searchIdEn = 'Early Warning System | ' . $formattedDate . ' | ' . ucfirst($viewNotification->getAlertType()?->getColor()) . ' Alert | ' . $viewNotification->getWeatherPhenomenon()?->getTitle("en");
  3647.         $searchIdAr = $translator->trans('Early Warning System', [], null, "ar") . ' | ' . $formattedDate . ' | ' . $translator->trans(ucfirst($viewNotification->getAlertType()?->getColor()) . ' Alert', [], null, "ar") . ' | ' . $viewNotification->getWeatherPhenomenon()?->getTitle("ar");
  3648.         $viewNotification->setEwsSearchId($searchIdEn, "en");
  3649.         $viewNotification->setEwsSearchId($searchIdAr, "ar");
  3651.         // // When publishing an updated alert to Twitter, also generate history on republish path.
  3652.         // if ($published && $viewNotification->getEnableTwitterNotification() && $templating) {
  3653.         //     try {
  3654.         //         if ($this->ewsNotificationHasVersionUpdateHistory($viewNotification)) {
  3655.         //             $historyLang = method_exists($translator, 'getLocale') ? (string) $translator->getLocale() : 'en';
  3656.         //             $historyAsset = $this->generateAlertHistoryTwitterImage(
  3657.         //                 $viewNotification,
  3658.         //                 $templating,
  3659.         //                 $logger,
  3660.         //                 false,
  3661.         //                 $translator,
  3662.         //                 $historyLang
  3663.         //             );
  3664.         //             if ($historyAsset) {
  3665.         //                 $viewNotification->setXHistoryAtachment($historyAsset);
  3666.         //             }
  3667.         //         }
  3668.         //     } catch (\Throwable $e) {
  3669.         //         $logger->error('Failed to generate EWS alert history Twitter image on publish: ' . $e->getMessage());
  3670.         //     }
  3671.         // }
  3673.         // Allow TwitterEventListner to post again on republish after an alert update.
  3674.         if ($published && $viewNotification->getEnableTwitterNotification()) {
  3675.             $viewNotification->setTwitterId('');
  3676.             $viewNotification->setTwitterLog('');
  3677.         }
  3679.         // Persist the selected user groups so the End alert can email the same groups later.
  3680.         if (!empty($userGroupIds)) {
  3681.             $groups = [];
  3682.             foreach ($userGroupIds as $gid) {
  3683.                 $group = EwsAndReportUserGroup::getById($gid, true);
  3684.                 if ($group instanceof EwsAndReportUserGroup) {
  3685.                     $groups[] = $group;
  3686.                 }
  3687.             }
  3688.             $viewNotification->setUserGroup($groups);
  3689.         }
  3691.         $viewNotification->save(["versionNote" => "Update"]);
  3693.         // $alert = $this->createNotificationFormat($viewNotification, $translator);
  3695.         // Commenting out the public portal EWS webhook dispatch as not working correctly 2026-08-17.
  3696.         // $this->dispatchPublicPortalEwsWebhookIfConfigured((int) $viewNotification->getId(), $logger);
  3698.         if ($published) {
  3699.             // Emails stay on the same console command; run it in the background so this API is not blocked.
  3700.             $jsonUserGroupIds = json_encode($userGroupIds);
  3701.             try {
  3702.                 ConsoleBackgroundProcess::start([
  3703.                     'php',
  3704.                     'bin/console',
  3705.                     'app:send-early-warning-alert-email',
  3706.                     '--alertId=' . $viewNotification->getId(),
  3707.                     '--userGroupIds=' . $jsonUserGroupIds,
  3708.                 ]);
  3709.                 $logger->info('Started send-early-warning-alert-email in background for EwsNotification ' . $viewNotification->getId());
  3710.             } catch (\Throwable $exception) {
  3711.                 $logger->error("published EwsNotification command failed to start: " . $exception->getMessage());
  3712.                 return ['success' => false, 'message' => $exception->getMessage()];
  3713.             }
  3714.         }
  3716.         return ["success" => true, "message" => $translator->trans("ews_notification_published")];
  3717.     }
  3719.     public function previewEwsNotification($params, $user, $translator, $templating)
  3720.     {
  3721.         $regionId = $params['regionId'] ?? null;
  3722.         $governorateIds = $params['governateIds'] ?? null;
  3723.         $startDate = $params['startDate'] ?? null;
  3724.         $endDate = $params['endDate'] ?? null;
  3725.         $startTime = $params['startTime'] ?? null;
  3726.         $endTime = $params['endTime'] ?? null;
  3727.         $alertActionId = $params['alertActionId'] ?? null;
  3728.         $alertTypeId = $params['alertTypeId'] ?? null;
  3729.         $alertStatusId = $params['alertStatusId'] ?? null;
  3730.         $alertHazardId = $params['alertHazardId'] ?? null;
  3732.         $alertItem = AlertType::getByAlertTypeId($this->scalarId($alertTypeId), 1);
  3733.         $regionItem = Region::getByRegionId($this->scalarId($regionId), 1);
  3734.         $alertStatusItem = AlertStatus::getByAlertStatusId($this->scalarId($alertStatusId), 1);
  3736.         $govIds = $this->parseCommaSeparatedIds($governorateIds);
  3737.         $govById = [];
  3738.         if (!empty($govIds)) {
  3739.             $governorateArr = new Governorate\Listing();
  3740.             $governorateArr->setCondition('governoteId IN (?)', [$govIds]);
  3741.             foreach ($governorateArr as $item) {
  3742.                 $govById[(string) $item->getgovernoteId()] = $item;
  3743.             }
  3744.         }
  3745.         $govItems = [];
  3746.         foreach ($govIds as $govId) {
  3747.             if (!isset($govById[(string) $govId])) {
  3748.                 continue;
  3749.             }
  3750.             $item = $govById[(string) $govId];
  3751.             $govItems[] = [
  3752.                 "id" => $item->getgovernoteId(),
  3753.                 "nameEn" => $item->getName('en'),
  3754.                 "nameAr" => $item->getName('ar'),
  3755.                 "longitude" => (float)$item->getLongitude(),
  3756.                 "latitude" => (float)$item->getLatitude(),
  3757.             ];
  3758.         }
  3760.         $hazardIds = $this->parseCommaSeparatedIds($alertHazardId);
  3761.         $hazardById = [];
  3762.         if (!empty($hazardIds)) {
  3763.             $hazardArr = new AlertHazard\Listing();
  3764.             $hazardArr->setCondition('alertHazardId IN (?)', [$hazardIds]);
  3765.             foreach ($hazardArr as $item) {
  3766.                 $hazardById[(string) $item->getAlertHazardId()] = $item;
  3767.             }
  3768.         }
  3769.         $hazardItems = [];
  3770.         foreach ($hazardIds as $hazardId) {
  3771.             if (!isset($hazardById[(string) $hazardId])) {
  3772.                 continue;
  3773.             }
  3774.             $item = $hazardById[(string) $hazardId];
  3775.             $hazardItems[] = [
  3776.                 "pim_id" => $item->getId(),
  3777.                 "id" => $item->getAlertHazardId(),
  3778.                 "nameEn" => $item->getName('en'),
  3779.                 "nameAr" => $item->getName('ar'),
  3780.             ];
  3781.         }
  3783.         $actionIds = $this->parseCommaSeparatedIds($alertActionId);
  3784.         $actionById = [];
  3785.         if (!empty($actionIds)) {
  3786.             $actionArr = new AlertAction\Listing();
  3787.             $actionArr->setCondition('alertActionId IN (?)', [$actionIds]);
  3788.             foreach ($actionArr as $item) {
  3789.                 $actionById[(string) $item->getAlertActionId()] = $item;
  3790.             }
  3791.         }
  3792.         $actionItems = [];
  3793.         foreach ($actionIds as $actionId) {
  3794.             if (!isset($actionById[(string) $actionId])) {
  3795.                 continue;
  3796.             }
  3797.             $item = $actionById[(string) $actionId];
  3798.             $actionItems[] = [
  3799.                 "pim_id" => $item->getId(),
  3800.                 "id" => $item->getAlertActionId(),
  3801.                 "descriptionEn" => $item->getName('en'),
  3802.                 "descriptionAr" => $item->getName('ar'),
  3803.             ];
  3804.         }
  3806.         // Preview only: reuse an existing token or mint a display token. Do not persist
  3807.         // a new unsubscribe token on the user (that was a write on every preview).
  3808.         $tokenURL = '';
  3809.         $token = '';
  3810.         if (is_object($user) && method_exists($user, 'getEwsNotificationToken')) {
  3811.             $token = (string) $user->getEwsNotificationToken();
  3812.         }
  3813.         if ($token === '') {
  3814.             $token = base64_encode($user->getEmail() . time() . uniqid());
  3815.         }
  3816.         if ($token !== '') {
  3817.             $tokenURL = BASE_URL . '/unsubscribe/notification?ews=true&token=' . $token;
  3818.         }
  3820.         $currentDate = new \DateTime();
  3821.         $dummyId = "ID";
  3822.         $dummyIdAr = "الهوية";
  3823.         $formattedDate = $currentDate->format('dmY') . '-' . $dummyId;
  3824.         $formattedDateAr = $currentDate->format('dmY') . '-' . $dummyIdAr;
  3825.         $searchIdEn = 'Early Warning System | ' . $formattedDate . ' | ' . ucfirst($alertItem->getColor()) . ' Alert | ' ;
  3826.         $searchIdAr = $translator->trans('Early Warning System', [], null, "ar") . ' | ' . $formattedDateAr . ' | ' . $translator->trans(ucfirst($alertItem->getColor()) . ' Alert', [], null, "ar") . ' | ' ;
  3828.         $fromDate = "{$startDate} " . ($startTime ? $startTime : '00:00:00');
  3829.         $toDate = "{$endDate} " . ($endTime ? $endTime : '00:00:00');
  3831.         $message = [
  3832.             "en" => "There is {$alertStatusItem->getName('en')} alert in {$regionItem->get('name', 'en')} Start Time : {$fromDate} End Time : {$toDate}",
  3833.             "ar" => "يوجد تنبيه {$alertStatusItem->getName('ar')} في {$regionItem->get('name', 'ar')} وقت البداية: {$fromDate} وقت الانتهاء: {$toDate}"
  3834.         ];
  3836.         $alert = [
  3837.             "user_name" => $user->getName(),
  3838.             "host" => API_BASE_URL,
  3839.             "tokenURL" => $tokenURL,
  3840.             "title" => $formattedDate,
  3841.             "alertColor" => $alertItem->getColor(),
  3842.             "alertType" => $alertItem->getAlertTypeId(),
  3843.             "alertTypeAr" => $alertItem->getName('ar'),
  3844.             "alertTypeEn" => $alertItem->getColor(),
  3845.             "fromDate" => "{$startDate} {$startTime}",
  3846.             "toDate" => "{$endDate} {$endTime}",
  3847.             "mannedAlertDatailUrl" => null,
  3848.             "searchEwsIdEn" => $searchIdEn,
  3849.             "searchEwsIdAr" => $searchIdAr,
  3850.             "alertHazard" => $hazardItems,
  3851.             "alertActions" => $actionItems,
  3852.             "alertStatusID" => $alertStatusItem->getalertStatusId(),
  3853.             "alertStatusEn" => $alertStatusItem->getName('en'),
  3854.             "alertStatusAr" => $alertStatusItem->getName('ar'),
  3855.             "regionID" => $regionId,
  3856.             "regionEn" => $regionItem->get('name', 'en'),
  3857.             "regionAR" => $regionItem->get('name', 'ar'),
  3858.             "governorates" => $govItems,
  3859.             "last_modified_date" => date("Y-m-d"),
  3860.         ];
  3862.         $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  3864.         return ["success" => true, "emailHtml" => $html, "smsMsg" => $message['ar']];
  3865.     }
  3867.     public function reportEwsNotification($param, $translator)
  3868.     {
  3869.         $result = [];
  3870.         $region = null;
  3871.         try {
  3872.             $listing = new EwsNotification\Listing();
  3873.             $reportType = isset($param['report_type']) ? $param['report_type'] : null;
  3874.             $regionId = isset($param['region_id']) ? $param['region_id'] : null;
  3875.             if ($regionId) {
  3876.                 $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  3877.                 if (!$region) {
  3878.                     throw new \Exception("Region not exists");
  3879.                 }
  3880.             }
  3882.             switch ($reportType) {
  3883.                 case 'published_in_week':
  3884.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 week"));
  3885.                     break;
  3886.                 case 'published_in_day':
  3887.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 day"));
  3888.                     break;
  3889.                 case 'published_in_month':
  3890.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 month"));
  3891.                     break;
  3892.                 case 'published_in_year':
  3893.                     $listing->setCondition("o_published = true AND o_creationDate >= " . strtotime("-1 year"));
  3894.                     break;
  3895.                 case 'published_in_region':
  3896.                     $listing->setCondition("o_published = true AND region__id = ?", [$region->getId()]);
  3897.                     break;
  3898.                 case 'published_in_draft':
  3899.                     $listing->setCondition("o_published = false");
  3900.                     break;
  3901.                 default:
  3902.                     throw new \Exception("Invalid request");
  3903.                     break;
  3904.             }
  3906.             $result['count'] = $listing->getCount();
  3907.             $notifications = $listing->load();
  3908.             if ($notifications) {
  3909.                 foreach ($notifications as $notification) {
  3910.                     $result['data'][] = $this->createNotificationFormat($notification, $translator);
  3911.                 }
  3912.             }
  3913.             return $result;
  3914.         } catch (\Exception $ex) {
  3915.             return new \Exception($ex->getMessage());
  3916.         }
  3918.         return $result;
  3919.     }
  3921.     private function sendEmailNotification($users, $alert, $emailService, $templating)
  3922.     {
  3923.         $mailSent = null;
  3924.         if ($alert) {
  3925.             $governatesArr = $alert['governorates'];
  3926.             $governates = [];
  3927.             if ($governatesArr) {
  3928.                 foreach ($governatesArr as $gov) {
  3929.                     $governates[] = $gov['nameEn'];
  3930.                 }
  3931.             }
  3933.             $data = $alert;
  3934.             $data['sender'] = 'National Center for Meteorology';
  3935.             //$subject = $alert['searchEwsIdAr'] ??'Severe Weather Alert - ' . $gov['nameEn'];
  3936.             // $subject = $alert['alertStatusAr'] . ' - ' . $alert['regionAR'];
  3937.             // $subject = 'النظام الالي للإنذار المبكر :' . ' - ' . $alert['searchEwsIdAr'];
  3938.             $parts = explode('|', $alert['searchEwsIdAr']);
  3939.             $excluded = implode('|', array_slice($parts, 1));
  3940.             $subject = 'النظام الالي للإنذار المبكر :'  . $excluded;
  3945.             // $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $data);
  3947.             //sending an email document (pimcore document)
  3948.             // $emailAlertTemplate = '/email/alert_notification';
  3950.             if ($users) {
  3951.                 foreach ($users as $currentUser) {
  3953.                     if (isset($alert['enableEmailNotification']) && $alert['enableEmailNotification']) {
  3955.                         if ($currentUser->getSendEwsEmail() || is_null($currentUser->getSendEwsEmail())) {
  3956.                             # code...
  3959.                             // $email = $currentUser->getEmail();
  3960.                             // $param = ['user' => $currentUser, 'message' => $html, 'url' => null];
  3961.                             // $mailSent = $emailService->sendMail($param, $email, $emailAlertTemplate, $subject);
  3962.                             // $data['name'] = $user->getName();
  3964.                             // extra param js
  3965.                             $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  3966.                             $alertName = $alertObj->getColor() ? $alertObj->getColor() : '';
  3968.                             $alert['user_name'] = $currentUser->getName();
  3969.                             $alert['host'] = API_BASE_URL;
  3970.                             $alert['alertColor'] = $alertName;
  3972.                             $backgroundColor = '#fcb82526';
  3973.                             $borderColor = '#000000';
  3974.                             $textColor = '#000000';
  3976.                             // unsubscribe ews notificaiton token
  3977.                             $tokenURL = '';
  3978.                             $token = $this->userModel->unSubscribeEwsGenerateToken($currentUser->getEmail());
  3979.                             if (!empty($token)) {
  3980.                                 $tokenURL = BASE_URL . '/unsubscribe/notification?ews=true&token=' . $token;
  3981.                             }
  3984.                             if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  3985.                                 $alertColorLower = strtolower(trim($alert['alertColor']));
  3987.                                 if ($alertColorLower === 'red') {
  3988.                                     $backgroundColor = '#f6000017';
  3989.                                     $borderColor = '#F60000';
  3990.                                     $textColor = '#F60000';
  3991.                                 } elseif ($alertColorLower === 'orange') {
  3992.                                     $backgroundColor = '#ff66001f';
  3993.                                     $borderColor = '#FF6600';
  3994.                                     $textColor = '#FF6600';
  3995.                                 } elseif ($alertColorLower === 'yellow') {
  3996.                                     $backgroundColor = '#fcb82526';
  3997.                                     $borderColor = '#FCB825';
  3998.                                     $textColor = '#FCB825';
  3999.                                 }
  4000.                             }
  4001.                             $purpose = EWS_MESSAGE;
  4002.                             $alert['backgroundColor'] = $backgroundColor;
  4003.                             $alert['borderColor'] = $borderColor;
  4004.                             $alert['textColor'] = $textColor;
  4005.                             $alert['tokenURL'] = $tokenURL;
  4006.                             $alert['mannedAlertDatailUrl'] = null;
  4007.                             $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  4008.                             $mailSent = $this->c2Service->sendNotificationEmail($_ENV['EWS_MAIL_TEMPLATE'], $alert['id'], $currentUser->getId(), $html, $subject, $purpose);
  4010.                             // $this->c2Service->sendMannedAlertEmails($html,$currentUser->getId(),$alert['id']);
  4011.                             // $mailSent=$this->c2Service->sendMannedAlertEmails($html,$currentUser->getId(),$alert['id'],$subject);
  4012.                             if ($mailSent) {
  4013.                                 $status = "sent";
  4014.                                 $this->saveEmailStatus($currentUser->getEmail(), $currentUser->getName(), $alert, $status);
  4015.                             } else {
  4016.                                 $status = "not sent";
  4017.                                 $this->saveEmailStatus($currentUser->getEmail(), $currentUser->getName(), $alert, $status);
  4018.                             }
  4019.                         }
  4020.                     }
  4021.                 }
  4022.             }
  4023.         }
  4025.         return $mailSent;
  4026.     }
  4028.     private function sendExcelEmailNotification($userGroupIds, $alert, $emailService, $templating)
  4029.     {
  4030.         $mailSent = null;
  4031.         if ($alert) {
  4032.             $governatesArr = $alert['governorates'];
  4033.             $governates = [];
  4034.             if ($governatesArr) {
  4035.                 foreach ($governatesArr as $gov) {
  4036.                     $governates[] = $gov['nameEn'];
  4037.                 }
  4038.             }
  4040.             $data = $alert;
  4041.             $data['sender'] = 'National Center for Meteorology';
  4042.             // $subject = $alert['searchEwsIdAr'] ??'Severe Weather Alert - ' . $gov['nameEn'];
  4043.             //$subject = $alert['alertStatusAr'] . ' - ' . $alert['regionAR'];
  4044.             // $subject = 'النظام الالي للإنذار المبكر :' . ' - ' . $alert['searchEwsIdAr'];
  4046.             $parts = explode('|', $alert['searchEwsIdAr']);
  4047.             $excluded = implode('|', array_slice($parts, 1));
  4048.             $subject = 'النظام الالي للإنذار المبكر :'  . $excluded;
  4051.             if ($userGroupIds) {
  4053.                 foreach ($userGroupIds as $userGroupId) {
  4054.                     if ($userGroupId) {
  4056.                         $userGroup = \Pimcore\Model\DataObject\EwsAndReportUserGroup::getById($userGroupId, true);
  4057.                         if ($userGroup instanceof \Pimcore\Model\DataObject\EwsAndReportUserGroup) {
  4059.                             foreach (json_decode($userGroup->getJsonData()) as $currentUser) {
  4061.                                 $entityUserSubscription = $this->userModel->getEntitySubscription($currentUser);
  4062.                                 $packageExpired = $entityUserSubscription ? (new \DateTime() > $entityUserSubscription->getEndDate() ? true : false) : false;
  4063.                                 $subActive = $entityUserSubscription ? $entityUserSubscription->getIsActive() : false;
  4064.                                 $nonSubUser = $subActive && !$packageExpired;
  4066.                                 if (isset($currentUser->firstName) && isset($currentUser->lastName) && isset($currentUser->email) && $nonSubUser) {
  4068.                                     // extra param js
  4069.                                     $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  4070.                                     $alertName = $alertObj->getColor() ? $alertObj->getColor() : '';
  4072.                                     $alert['user_name'] = $currentUser->firstName . ' ' . $currentUser->lastName;
  4073.                                     $alert['host'] = API_BASE_URL;
  4074.                                     $alert['alertColor'] = $alertName;
  4076.                                     $backgroundColor = '#fcb82526';
  4077.                                     $borderColor = '#000000';
  4078.                                     $textColor = '#000000';
  4080.                                     if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  4081.                                         $alertColorLower = strtolower(trim($alert['alertColor']));
  4083.                                         if ($alertColorLower === 'red') {
  4084.                                             $backgroundColor = '#f6000017';
  4085.                                             $borderColor = '#F60000';
  4086.                                             $textColor = '#F60000';
  4087.                                         } elseif ($alertColorLower === 'orange') {
  4088.                                             $backgroundColor = '#ff66001f';
  4089.                                             $borderColor = '#FF6600';
  4090.                                             $textColor = '#FF6600';
  4091.                                         } elseif ($alertColorLower === 'yellow') {
  4092.                                             $backgroundColor = '#fcb82526';
  4093.                                             $borderColor = '#FCB825';
  4094.                                             $textColor = '#FCB825';
  4095.                                         }
  4096.                                     }
  4098.                                     $alert['backgroundColor'] = $backgroundColor;
  4099.                                     $alert['borderColor'] = $borderColor;
  4100.                                     $alert['textColor'] = $textColor;
  4101.                                     $alert['tokenURL'] = null;
  4102.                                     $alert['mannedAlertDatailUrl'] = null;
  4103.                                     $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  4104.                                     // $email = $currentUser->email;
  4105.                                     // $param = ['user' => $currentUser, 'message' => $html, 'url' => null];
  4106.                                     // $mailSent = $emailService->sendMail($param, "abdul.muqeet@centric.ae", '/email/alert_notification', $subject);
  4107.                                     $purpose = EWS_MESSAGE;
  4108.                                     $mailSent = $this->c2Service->sendDefaultEmail($_ENV['EWS_MAIL_TEMPLATE'], $alert['id'], $currentUser->email, $html, $subject, $purpose);
  4110.                                     if ($mailSent) {
  4111.                                         $status = "sent";
  4112.                                         $this->saveEmailStatus($currentUser->email, $currentUser->firstName . ' ' . $currentUser->lastName, $alert, $status);
  4113.                                     } else {
  4114.                                         $status = "not sent";
  4115.                                         $this->saveEmailStatus($currentUser->email, $currentUser->firstName . ' ' . $currentUser->lastName, $alert, $status);
  4116.                                     }
  4117.                                 }
  4118.                             }
  4119.                         }
  4120.                     }
  4121.                 }
  4122.             }
  4123.         }
  4125.         return $mailSent;
  4126.     }
  4128.     private function saveEmailStatus($userEmail, $userName, $alert, $emailStatus)
  4129.     {
  4131.         // Get all governorates names in string seprated by ,
  4132.         $nameEnArray = array_column($alert["governorates"], "nameEn");
  4133.         $nameEnString = implode(", ", $nameEnArray);
  4135.         $nameArArray = array_column($alert["governorates"], "nameAr");
  4136.         $nameArString = implode(", ", $nameArArray);
  4138.         $ewsEmailStatus = new FetchSentEwsEmail();
  4139.         $ewsEmailStatus->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Other/FetchSentEwsEmail/"));
  4140.         $ewsEmailStatus->setKey(\Pimcore\Model\Element\Service::getValidKey($userEmail . "-" . strtotime("now") . "-" . rand(1, 10000), 'object'));
  4141.         $ewsEmailStatus->setEwsId($alert['id']);
  4142.         $ewsEmailStatus->setUserName($userName);
  4143.         $ewsEmailStatus->setEmail($userEmail);
  4144.         //$ewsEmailStatus->setLocationName($locationName);
  4145.         $ewsEmailStatus->setAlertType($alert['alertTypeEn'], 'en');
  4146.         $ewsEmailStatus->setAlertType($alert['alertTypeAr'], 'ar');
  4147.         $ewsEmailStatus->setAlertStatus($alert['alertStatusEn'], 'en');
  4148.         $ewsEmailStatus->setAlertStatus($alert['alertStatusAr'], 'ar');
  4149.         $ewsEmailStatus->setRegionName($alert['regionEn'], 'en');
  4150.         $ewsEmailStatus->setRegionName($alert['regionAR'], 'ar');
  4151.         $ewsEmailStatus->setGovernorateNames($nameEnString, 'en');
  4152.         $ewsEmailStatus->setGovernorateNames($nameArString, 'ar');
  4153.         $ewsEmailStatus->setStatus($emailStatus);
  4154.         $ewsEmailStatus->setPublished(true);
  4155.         $ewsEmailStatus->save();
  4157.         return $ewsEmailStatus;
  4158.     }
  4160.     public function getEwsNotificationEmailStatus($params, $paginator, $translator)
  4161.     {
  4162.         $result = [];
  4163.         try {
  4164.             $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  4165.             $page = isset($params['page']) ? $params['page'] : 1;
  4167.             $notificationId = $params["id"] ? $params["id"] : null;
  4168.             $listing = new FetchSentEwsEmail\Listing();
  4169.             $listing->setCondition("ewsId = ? ", [$notificationId]);
  4171.             $paginator = $paginator->paginate(
  4172.                 $listing,
  4173.                 $page,
  4174.                 $pageSize
  4175.             );
  4177.             if ($paginator->count() > 0) {
  4178.                 foreach ($paginator as $EwsNotificationEmail) {
  4179.                     $result[] = [
  4180.                         "ewsId" => $EwsNotificationEmail->getEwsId(),
  4181.                         "userName" => $EwsNotificationEmail->getUserName(),
  4182.                         "Email" => $EwsNotificationEmail->getEmail(),
  4183.                         "locationName" => $EwsNotificationEmail->getLocationName(),
  4184.                         "alertType" => $EwsNotificationEmail->getAlertType('en'),
  4185.                         "alertTypeAr" => $EwsNotificationEmail->getAlertType('ar'),
  4186.                         "alertStatus" => $EwsNotificationEmail->getAlertStatus('en'),
  4187.                         "alertStatusAr" => $EwsNotificationEmail->getAlertStatus('ar'),
  4188.                         "regionName" => $EwsNotificationEmail->getRegionName('en'),
  4189.                         "regionNameAr" => $EwsNotificationEmail->getRegionName('ar'),
  4190.                         "governorateNames" => explode(",", $EwsNotificationEmail->getGovernorateNames('en')),
  4191.                         "governorateNamesAr" => explode(",", $EwsNotificationEmail->getGovernorateNames('ar')),
  4192.                         "emailStatus" => $EwsNotificationEmail->getStatus(),
  4193.                         "emailStatusAr" => $translator->trans($EwsNotificationEmail->getStatus(), [], null, "ar"),
  4194.                     ];
  4195.                 }
  4196.             }
  4198.             return ["success" => TRUE, "data" => $result, "paginationVariables" => $paginator->getPaginationData()];
  4199.         } catch (\Exception $ex) {
  4200.             return new \Exception($ex->getMessage());
  4201.         }
  4203.         return $result;
  4204.     }
  4206.     public function getOtherLocations()
  4207.     {
  4208.         $response = [];
  4209.         $otherLocations = new DataObject\OtherLocation\Listing();
  4210.         $otherLocations = $otherLocations->load();
  4211.         if ($otherLocations) {
  4212.             foreach ($otherLocations as $otherLocation) {
  4213.                 $response[] = [
  4214.                     "id" => $otherLocation->getOtherLocationId(),
  4215.                     "nameEn" => $otherLocation->getName('en'),
  4216.                     "nameAr" => $otherLocation->getName('ar')
  4217.                 ];
  4218.             }
  4219.         }
  4220.         return ["success" => true, "data" => $response];
  4221.     }
  4223.     public function getEwsNotificationByByRegionName($regionName)
  4224.     {
  4225.         $db = Db::get();
  4226.         $selectedLocalities = $db->fetchAll("SELECT * FROM `object_collection_AddressComponents_location` WHERE (`addressKey` = 'locality' || `addressKey` = 'administrative_area_level_1') and (TRIM(REPLACE(`addressValue`,'Province','')) = '" . $regionName . "')");
  4227.         return $selectedLocalities;
  4228.     }
  4230.     public function ewsAnalytics($params, $connection, $lang): array
  4231.     {
  4232.         $response = [];
  4234.         $status = isset($params['status']) ? $params['status'] : "";
  4236.         $isManned = null;
  4237.         if (isset($params['isManned']) && $params['isManned'] == true) {
  4238.             $isManned = true;
  4239.         } elseif (isset($params['isManned']) && $params['isManned'] == false) {
  4240.             $isManned = false;
  4241.         }
  4244.         if (isset($params['region']) && !empty($params['region'])) {
  4245.             $region = Region::getByRegionId($params['region'], true);
  4246.             $response[] = $this->ewsAnalyticsCount($region, $status, $connection, $lang, $isManned);
  4247.         } else {
  4248.             $regions = new Region\Listing();
  4249.             foreach ($regions as $region) {
  4250.                 $response[] = $this->ewsAnalyticsCount($region, $status, $connection, $lang, $isManned);
  4251.             }
  4252.         }
  4254.         return $response;
  4255.     }
  4257.     public function ewsAnalyticsCount($region, $status, $connection, $lang, $isManned)
  4258.     {
  4259.         $regionNameEn = $region->getName("en");
  4260.         $regionNameAr = $region->getName("ar");
  4262.         $statuses = ["active", "archived", "expired"];
  4263.         $count = ['regionEn' => $regionNameEn, "regionAr" => $regionNameAr];
  4265.         if (in_array($status, $statuses)) {
  4266.             $count[$status] = $this->getStatusData($region, $status, $connection, $isManned);
  4267.         } else {
  4268.             foreach ($statuses as $s) {
  4269.                 $count[$s] = $this->getStatusData($region, $s, $connection, $isManned);
  4270.             }
  4271.         }
  4273.         return $count;
  4274.     }
  4276.     public function getStatusData($region, $status, $connection, $isManned)
  4277.     {
  4278.         $totalNotifications = $this->statusCount($region, $status, $isManned);
  4279.         $alertTypeCount = $this->alertCount($region, $status, $connection, $isManned);
  4281.         return [
  4282.             'total_notifications' => $totalNotifications,
  4283.             'alert_type_count' => $alertTypeCount,
  4284.         ];
  4285.     }
  4287.     public function alertCount($region, $status, $connection, $isManned)
  4288.     {
  4289.         $currentTimestamp = time(); // Current UNIX timestamp
  4290.         $twentyFourHoursAgoTimestamp = strtotime('-24 hours'); // 24 hours ago timestamp
  4292.         $claim_report_sql = $connection->createQueryBuilder();
  4294.         $claim_report_sql
  4295.             ->select('oa.Color AS color', 'COUNT(oq.oo_id) AS count')
  4296.             ->from('object_ews_notification', 'oq')
  4297.             ->join('oq', 'object_query_alert_type', 'oa', 'oq.alertType__id = oa.oo_id')
  4298.             ->andWhere('oq.region__id = :regionId')
  4299.             ->andWhere('oq.status = :status');
  4300.         if ($isManned !== null && $isManned == true) {
  4301.             $claim_report_sql->andWhere('oq.isManned = 1');
  4302.         } elseif ($isManned !== null && $isManned == false) {
  4303.             $claim_report_sql->andWhere('oq.isManned = 0');
  4304.         }
  4306.         $claim_report_sql->andWhere('oq.o_published = 1'); // added new line
  4309.         // Initialize parameters array
  4310.         $params = [
  4311.             'regionId' => $region->getId(),
  4312.             'status' => $status,
  4313.         ];
  4315.         // Add conditions based on status
  4316.         if ($status == "active") {
  4317.             $claim_report_sql->andWhere('oq.endDate > :currentTimestamp');
  4318.             $params['currentTimestamp'] = $currentTimestamp;
  4319.         } else if ($status == "expired") {
  4320.             $claim_report_sql->andWhere('oq.endDate < :currentTimestamp AND oq.endDate > :twentyFourHoursAgoTimestamp');
  4321.             $params['currentTimestamp'] = $currentTimestamp;
  4322.             $params['twentyFourHoursAgoTimestamp'] = $twentyFourHoursAgoTimestamp;
  4323.         } else if ($status == "archived") {
  4324.             $claim_report_sql->andWhere('oq.endDate < :twentyFourHoursAgoTimestamp');
  4325.             $params['twentyFourHoursAgoTimestamp'] = $twentyFourHoursAgoTimestamp;
  4326.         }
  4328.         // Set all parameters at once
  4329.         $claim_report_sql->setParameters($params);
  4331.         $claim_report_sql->groupBy('color');
  4333.         $claimReportstmt = $claim_report_sql->execute();
  4334.         $results = $claimReportstmt->fetchAllAssociative();
  4336.         // Fetch all possible colors
  4337.         $alertTypes = new AlertType\Listing();
  4338.         $allColors = [];
  4339.         foreach ($alertTypes as $alertType) {
  4340.             if ($alertType) {
  4341.                 $allColors[] = $alertType->getColor();
  4342.             }
  4343.         }
  4345.         if (empty($allColors)) {
  4346.             $allColors = ["yellow", "orange", "red"];
  4347.         }
  4349.         // Create an associative array to store counts by color
  4350.         $countsByColor = [];
  4351.         foreach ($results as $result) {
  4352.             $countsByColor[$result['color']] = $result['count'];
  4353.         }
  4355.         // Merge counts for existing colors with counts for all colors, including those with count 0
  4356.         $finalResult = [];
  4357.         foreach ($allColors as $color) {
  4358.             $finalResult[] = [
  4359.                 "color" => $color,
  4360.                 "count" => isset($countsByColor[$color]) ? $countsByColor[$color] : 0
  4361.             ];
  4362.         }
  4364.         return $finalResult;
  4365.     }
  4369.     public function statusCount($region, $status, $isManned)
  4370.     {
  4371.         $notifications = new EwsNotification\Listing();
  4372.         $currentTimestamp = time(); // Get the current UNIX timestamp
  4373.         $twentyFourHoursAgoTimestamp = strtotime('-24 hours'); // 24 hours ago timestamp
  4375.         $conditions = "region__id = ? AND status = ?";
  4376.         $params = [$region->getId(), $status];
  4378.         if ($status == "active") {
  4379.             $conditions .= " AND endDate > ?";
  4380.             $params[] = $currentTimestamp;
  4381.         } else if ($status == "expired") {
  4382.             $conditions .= " AND endDate < ? AND endDate > ?";
  4383.             $params[] = $currentTimestamp;
  4384.             $params[] = $twentyFourHoursAgoTimestamp;
  4385.         } else if ($status == "archived") {
  4386.             $conditions .= " AND endDate < ?";
  4387.             $params[] = $twentyFourHoursAgoTimestamp;
  4388.         }
  4390.         $notifications->addConditionParam($conditions, $params);
  4392.         // Add condition for manned notifications
  4393.         if ($isManned !== null) {
  4394.             $notifications->addConditionParam("isManned = ?", [$isManned]);
  4395.         }
  4397.         return $notifications->count();
  4398.     }
  4400.     public function searchEwsNotification($params, $lang, $paginator, $translator): array
  4401.     {
  4402.         $response = [];
  4403.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  4404.         $page = isset($params['page']) ? $params['page'] : 1;
  4406.         $notificationList = new DataObject\EwsNotification\Listing();
  4408.         // If unpublished parameter exists and is true, show unpublished items
  4409.         // Handle boolean true, string "true", or integer 1
  4410.         $isUnpublished = isset($params['unpublished']) && (
  4411.             $params['unpublished'] === true ||
  4412.             $params['unpublished'] === 'true' ||
  4413.             $params['unpublished'] === 1 ||
  4414.             $params['unpublished'] === '1'
  4415.         );
  4417.         if ($isUnpublished) {
  4418.             $notificationList->setUnpublished(true);
  4419.             $notificationList->filterByPublished(false);
  4420.         }
  4421.         // No else needed - default behavior already shows published only
  4423.         if (isset($params['allowedNotificationTypes'])) {
  4424.             $notificationList->addConditionParam("notificationType IN (?)", [$params["allowedNotificationTypes"]]);
  4425.         }
  4428.         if (isset($params['isManned']) && $params['isManned'] == true) {
  4429.             $notificationList->addConditionParam("isManned = 1");
  4430.         } elseif (isset($params['isManned']) && $params['isManned'] == false) {
  4431.             $notificationList->addConditionParam("isManned = 0");
  4432.         }
  4435.         if (isset($params['id']) && !empty($params['id'])) {
  4436.             $idz = $params['id'];
  4437.             $notificationList->addConditionParam("oo_id IN (?)", [$idz]);
  4438.         }
  4439.         if (isset($params['alertAction']) && !empty($params['alertAction'])) {
  4440.             $alertActionIds = [];
  4441.             $alertActionList = new DataObject\AlertAction\Listing();
  4442.             $alertActionList->addConditionParam("alertActionId IN (?)", [$params['alertAction']]);
  4443.             foreach ($alertActionList as $alertAction) {
  4444.                 $alertActionIds[] = $alertAction->getId();
  4445.             }
  4446.             $alertActionids = implode(",", $alertActionIds);
  4447.             $notificationList->addConditionParam("alertAction REGEXP CONCAT('(^|,)(', REPLACE('$alertActionids',',', '|'), ')(,|$)')");
  4448.         }
  4449.         if (isset($params['alertType']) && !empty($params['alertType'])) {
  4450.             $alertTypeIds = [];
  4451.             $alertTypeList = new DataObject\AlertType\Listing();
  4452.             $alertTypeList->addConditionParam("alertTypeId IN (?)", [$params['alertType']]);
  4453.             foreach ($alertTypeList as $alertType) {
  4454.                 $alertTypeIds[] = $alertType->getId();
  4455.             }
  4456.             $notificationList->addConditionParam("alertType__id IN (?)", [$alertTypeIds]);
  4457.         }
  4458.         // if (isset($params['phenomena']) && !empty($params['phenomena'])) {
  4459.         //     $phenomenaIds = [];
  4460.         //     $phenomenaList = new DataObject\PhenomenaList\Listing();
  4461.         //     $phenomenaList->addConditionParam("phenomenalistid IN (?)", [$params['phenomena']]);
  4462.         //     foreach ($phenomenaList as $phenomena) {
  4463.         //         $phenomenaIds[] = $phenomena->getId();
  4464.         //     }
  4465.         //     $notificationList->addConditionParam("weatherPhenomenon__id IN (?)", [$phenomenaIds]);
  4466.         // }
  4468.         if (!empty($params['phenomena'])) {
  4469.             $alertStatusSql = null;
  4470.             foreach ($params['phenomena'] as $alertStatus) {
  4471.                 $alertStatus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($alertStatus, true);
  4472.                 if ($alertStatus) {
  4473.                     $alertStatusSql .= "alertStatus__id = " . $alertStatus->getId() . " OR ";
  4474.                 }
  4475.             }
  4476.             $notificationList->addConditionParam("(" . substr($alertStatusSql, 0, -3) . ")");
  4477.         }
  4479.         if (isset($params['region']) && !empty($params['region'])) {
  4480.             $regionIds = [];
  4481.             $regionList = new DataObject\Region\Listing();
  4482.             $regionList->addConditionParam("regionId IN (?)", [$params['region']]);
  4483.             foreach ($regionList as $region) {
  4484.                 $regionIds[] = $region->getId();
  4485.             }
  4486.             $notificationList->addConditionParam("region__id IN (?)", [$regionIds]);
  4487.         }
  4488.         if (isset($params['governate']) && !empty($params['governate'])) {
  4489.             $governatesIds = [];
  4490.             $governateList = new DataObject\Governorate\Listing();
  4491.             $governateList->addConditionParam("governoteId IN (?)", [$params['governate']]);
  4492.             foreach ($governateList as $governate) {
  4493.                 $governatesIds[] = $governate->getId();
  4494.             }
  4495.             $governatesIds = implode(",", $governatesIds);
  4496.             $notificationList->addConditionParam("governorate REGEXP CONCAT('(^|,)(', REPLACE('$governatesIds',',', '|'), ')(,|$)')");
  4497.         }
  4499.         if (isset($params['status'][0]) && !empty($params['status'][0])) {
  4501.             $currentTimestamp = time();
  4502.             $twentyFourHoursAgo = strtotime('-24 hours');
  4504.             if ($params['status'][0] == "active" && (!isset($params['status'][1]) || empty($params['status'][1]))) {
  4505.                 // Filter notifications with an end date in the future or equal to current time
  4506.                 $notificationList->addConditionParam("status != ?", ["ended"]);
  4507.                 $notificationList->filterByEndDate($currentTimestamp, ">=");
  4508.             } else if ($params['status'][0] == "expired" && (!isset($params['status'][1]) || empty($params['status'][1]))) {
  4509.                 // Filter notifications with an end date in the past, but not older than 24 hours
  4510.                 $notificationList->addConditionParam("status != ?", ["ended"]);
  4511.                 $notificationList->filterByEndDate($currentTimestamp, "<");
  4512.                 $notificationList->filterByEndDate($twentyFourHoursAgo, ">=");
  4513.             } else if ($params['status'][0] == "archived" && (!isset($params['status'][1]) || empty($params['status'][1]))) {
  4514.                 // Filter notifications with an end date older than 24 hours
  4515.                 $notificationList->addConditionParam("endDate < ? OR alertEndDate < ? ", [$twentyFourHoursAgo, $twentyFourHoursAgo]);
  4516.                 // $notificationList->filterByEndDate($twentyFourHoursAgo, "<");
  4517.             } else if ($params['status'][0] == "ended" && (!isset($params['status'][1]) || empty($params['status'][1]))) {
  4518.                 $notificationList->filterByAlertEndDate($twentyFourHoursAgo, ">");
  4519.                 $notificationList->filterByStatus("ended");
  4520.                 // $notificationList->addConditionParam("status = ?",["ended"]);
  4521.             } else if (isset($params['status'][1]) && !empty($params['status'][1])) {
  4522.                 $conditions = [];
  4524.                 if (in_array('ended', $params['status'])) {
  4525.                     $conditions[] = "(status = 'ended' AND AlertEndDate > {$twentyFourHoursAgo})";
  4526.                 }
  4528.                 if (in_array('active', $params['status'])) {
  4529.                     $conditions[] = "(status != 'ended' AND endDate >= {$currentTimestamp})";
  4530.                 }
  4532.                 if (in_array('expired', $params['status'])) {
  4533.                     $conditions[] = "(status != 'ended' AND endDate < {$currentTimestamp} AND endDate >= {$twentyFourHoursAgo})";
  4534.                 }
  4536.                 if (in_array('archived', $params['status'])) {
  4537.                     $conditions[] = "(status != 'ended' AND (endDate < {$twentyFourHoursAgo} OR alertEndDate < {$twentyFourHoursAgo}))";
  4538.                 }
  4540.                 if (!empty($conditions)) {
  4541.                     $notificationList->addConditionParam('(' . implode(' OR ', $conditions) . ')');
  4542.                 }
  4543.             }
  4544.         } else {
  4545.             // If no status is provided, return 0 records (only for published records)
  4546.             // For unpublished records, don't require status filter
  4547.             if (!$isUnpublished) {
  4548.                 $notificationList->addConditionParam("1 = 0");
  4549.             }
  4550.         }
  4552.         $notificationList->setLocale($lang);
  4553.         if (isset($params['searchId']) && !empty($params['searchId'])) {
  4554.             $notificationList->addConditionParam(
  4555.                 "(ewsSearchId LIKE ?)",
  4556.                 [
  4557.                     '%' . $params['searchId'] . '%'
  4558.                 ]
  4559.             );
  4560.         }
  4562.         if (isset($params['alertHazard']) && !empty($params['alertHazard'])) {
  4564.             $alertHazardIds = [];
  4565.             $alertHazardList = new DataObject\AlertHazard\Listing();
  4566.             $alertHazardList->addConditionParam("alertHazardId IN (?)", [$params['alertHazard']]);
  4567.             foreach ($alertHazardList as $alertHazard) {
  4568.                 $alertHazardIds[] = $alertHazard->getId();
  4569.             }
  4570.             $alertHazardIds = implode(",", $alertHazardIds);
  4571.             $notificationList->addConditionParam("alertHazard REGEXP CONCAT('(^|,)(', REPLACE('$alertHazardIds',',', '|'), ')(,|$)')");
  4572.         }
  4573.         if (isset($params['municipality']) && !empty($params['municipality'])) {
  4574.             $municipalityIds = [];
  4575.             $municipalityList = new DataObject\Municipality\Listing();
  4576.             $municipalityList->addConditionParam("municipalityid IN (?)", [$params['municipality']]);
  4577.             foreach ($municipalityList as $municipality) {
  4578.                 $municipalityIds[] = $municipality->getId();
  4579.             }
  4580.             $municipalityIds = implode(",", $municipalityIds);
  4581.             $notificationList->addConditionParam("municipality REGEXP CONCAT('(^|,)(', REPLACE('$municipalityIds',',', '|'), ')(,|$)')");
  4582.         }
  4584.         if (isset($params['startDate']) && !empty($params['startDate'])) {
  4585.             $notificationList->filterByStartDate(strtotime($params['startDate']), ">=");
  4586.         }
  4587.         if (isset($params['endDate']) && !empty($params['endDate'])) {
  4588.             $notificationList->filterByEndDate(strtotime($params['endDate']), "<=");
  4589.         }
  4591.         if (isset($params['fromDate']) && isset($params['toDate']) && !empty($params['fromDate']) && !empty($params['toDate'])) {
  4592.             $fromDate = new \DateTime($params['fromDate']);
  4593.             $toDate = new \DateTime($params['toDate']);
  4595.             // Ensure the dates are in the correct format
  4596.             $fromDateStr = strtotime($fromDate->format('Y-m-d H:i:s'));
  4597.             $toDateStr = strtotime($toDate->format('Y-m-d') . ' 23:59:59');
  4599.             $notificationList->addConditionParam(
  4600.                 "(o_creationDate >= ? AND o_creationDate <= ?)",
  4601.                 [$fromDateStr, $toDateStr]
  4602.             );
  4603.         }
  4606.         $notifications = $notificationList->load();
  4609.         $sortedData = [];
  4611.         foreach ($notifications as $notification) {
  4612.             $regionEn = $notification->getRegion() ? $notification->getRegion()->getName("en") : "";
  4613.             $startDate = $notification->getStartDate() ? $notification->getStartDate()->format('Y-m-d H:i:s') : "";
  4614.             $endDate = $notification->getEndDate() ? $notification->getEndDate()->format('Y-m-d H:i:s') : "";
  4615.             $alertStatusEn = $notification->getWeatherPhenomenon()?->getTitle("en");
  4616.             $creationDate = $notification->getCreationDate();
  4617.             $searchIdEn = $notification->getEwsSearchId("en");
  4618.             $searchIdAr = $notification->getEwsSearchId("ar");
  4619.             $sortedData[] = [
  4620.                 'notification' => $notification,
  4621.                 'regionName' => $regionEn,
  4622.                 'alertStatus' => $alertStatusEn,
  4623.                 'startDate' => $startDate,
  4624.                 'endDate' => $endDate,
  4625.                 'creationDate' => $creationDate, // Add creation date to sorting criteria
  4626.                 'searchIdEn' => $searchIdEn,
  4627.                 'searchIdAr' => $searchIdAr
  4628.             ];
  4629.         }
  4631.         // Define default sort orders and detect if any sort parameter is provided
  4632.         $sortOrderRegion = $params['sortByRegion'] ?? null;
  4633.         $sortOrderStartDate = $params['sortByStartDate'] ?? null;
  4634.         $sortOrderEndDate = $params['sortByEndDate'] ?? null;
  4635.         $sortOrderAlertStatus = $params['sortByAlertStatus'] ?? null;
  4636.         $sortOrderSearchIdEn = $params['sortBySearchIdEn'] ?? null;
  4637.         $sortOrderSearchIdAr = $params['sortBySearchIdAr'] ?? null;
  4638.         $sortOrderCreatedAt = $params['sortByCreated'] ?? null;
  4639.         // Check if any sort parameter is provided
  4640.         $anySortParamProvided = $sortOrderRegion || $sortOrderStartDate || $sortOrderEndDate || $sortOrderAlertStatus || $sortOrderSearchIdEn || $sortOrderSearchIdAr;
  4641.         usort($sortedData, function ($a, $b) use ($sortOrderRegion, $sortOrderStartDate, $sortOrderEndDate, $sortOrderAlertStatus, $sortOrderSearchIdEn, $sortOrderSearchIdAr, $sortOrderCreatedAt, $anySortParamProvided) {
  4642.             if (!$anySortParamProvided || $sortOrderCreatedAt) {
  4643.                 if ($sortOrderCreatedAt == null) {
  4644.                     $sortOrderCreatedAt = "desc";
  4645.                 }
  4646.                 // Default to sorting by creation date if no sort parameter is provided
  4647.                 $compareCreatedAt = strcmp($a['creationDate'], $b['creationDate']) * ($sortOrderCreatedAt === 'desc' ? -1 : 1);
  4648.                 if ($compareCreatedAt !== 0) return $compareCreatedAt; // Assuming 'asc' as default sort order for creation date
  4649.             }
  4650.             // Else, sort based on the provided parameters
  4651.             if ($sortOrderRegion) {
  4652.                 $compareRegion = strcmp($a['regionName'], $b['regionName']) * ($sortOrderRegion === 'desc' ? -1 : 1);
  4653.                 if ($compareRegion !== 0) return $compareRegion;
  4654.             }
  4655.             if ($sortOrderSearchIdEn) {
  4656.                 $compareSearchIdEn = strcmp($a['searchIdEn'], $b['searchIdEn']) * ($sortOrderSearchIdEn === 'desc' ? -1 : 1);
  4657.                 if ($compareSearchIdEn !== 0) return $compareSearchIdEn;
  4658.             }
  4659.             if ($sortOrderSearchIdAr) {
  4660.                 $compareSearchIdAr = strcmp($a['searchIdAr'], $b['searchIdAr']) * ($sortOrderSearchIdAr === 'desc' ? -1 : 1);
  4661.                 if ($compareSearchIdAr !== 0) return $compareSearchIdAr;
  4662.             }
  4663.             if ($sortOrderAlertStatus) {
  4664.                 $compareAlertStatus = strcmp($a['alertStatus'], $b['alertStatus']) * ($sortOrderAlertStatus === 'desc' ? -1 : 1);
  4665.                 if ($compareAlertStatus !== 0) return $compareAlertStatus;
  4666.             }
  4667.             if ($sortOrderStartDate) {
  4668.                 $compareStartDate = strcmp($a['startDate'], $b['startDate']) * ($sortOrderStartDate === 'desc' ? -1 : 1);
  4669.                 if ($compareStartDate !== 0) return $compareStartDate;
  4670.             }
  4671.             if ($sortOrderEndDate) {
  4672.                 return strcmp($a['endDate'], $b['endDate']) * ($sortOrderEndDate === 'desc' ? -1 : 1);
  4673.             }
  4674.             // If all provided parameters are equal, or no specific sort orders are provided, default to creation date
  4675.             return ($b['creationDate'] ?? 0) - ($a['creationDate'] ?? 0);
  4676.         });
  4678.         $sortedNotifications = array_map(function ($item) {
  4679.             return $item['notification'];
  4680.         }, $sortedData);
  4683.         if (isset($params['dashboard']) && $params['dashboard'] === 'dashboard') {
  4684.             return [
  4685.                 'success' => true,
  4686.                 'data' => array_values(array_map(
  4687.                     static fn ($notification) => (int) $notification->getId(),
  4688.                     $sortedNotifications
  4689.                 )),
  4690.             ];
  4691.         }
  4694.         // Extract the sorted notifications
  4697.         if ($paginator == null) {
  4699.             // if ($sortedNotifications->count()) {
  4700.             foreach ($sortedNotifications as $notification) {
  4701.                 // if($notification->getPublished())
  4702.                 $item = $this->createNotificationFormat($notification, $translator);
  4703.                 $item['history'] = false;
  4704.                 if ($this->ewsNotificationHasVersionUpdateHistory($notification)) {
  4705.                     $item['history'] = true;
  4706.                 }
  4707.                 
  4708.                 $response[] = $item;
  4709.             }
  4710.             // }
  4712.             return ["success" => TRUE, "data" => $response];
  4713.         }
  4716.         $paginator = $paginator->paginate(
  4717.             $sortedNotifications,
  4718.             $page,
  4719.             $pageSize
  4720.         );
  4722.         $decodedJwtToken  = isset($params['decodedJwtToken']) ?? null;
  4723.         $userPermission = isset($params['userPermission']) ?? null;
  4724.         // if ($sortedNotifications->count()) {
  4725.         foreach ($paginator as $notification) {
  4726.             // if($notification->getPublished())
  4727.             $item = $this->createNotificationFormat($notification, $translator, $decodedJwtToken, $userPermission);
  4728.             $item['history'] = false;
  4729.             if ($this->ewsNotificationHasVersionUpdateHistory($notification)) {
  4730.                 $item['history'] = true;
  4731.             }
  4732.             $response[] = $item;
  4733.         }
  4734.         // }
  4736.         return ["data" => $response, "paginationVariables" => $paginator->getPaginationData()];
  4737.     }
  4739.     public function archiveNotification($params, $translator): array
  4740.     {
  4742.         $id = $params['id'] ?? null;
  4743.         if (!$id) {
  4744.             throw new \Exception("EWS id is required");
  4745.         }
  4747.         $ewsNotification = \Pimcore\Model\DataObject::getById($id);
  4748.         if (!$ewsNotification instanceof \Pimcore\Model\DataObject\EwsNotification) {
  4749.             // throw new \Exception("Ews notification not found");
  4750.             return ['success' => false, 'message' => $translator->trans('ews_notification_not_found')];
  4751.         }
  4753.         if (isset($params['status']) && $params['status']) {
  4754.             $ewsNotification->setStatus("archived");
  4755.         }
  4756.         $ewsNotification->save(["versionNote" => "Update"]);
  4758.         if ($this->shouldDispatchPublicPortalEwsWebhook($ewsNotification)) {
  4759.             $this->dispatchPublicPortalEwsWebhookIfConfigured((int) $ewsNotification->getId());
  4760.         }
  4762.         return ['success' => true, 'message' => $translator->trans('archive_ews_notification'), "notification_id" => $ewsNotification->getId()];
  4763.     }
  4765.     public function getId(): ?UuidV4
  4766.     {
  4768.         $uuid = UuidV4::v4();
  4769.         return $uuid;
  4770.     }
  4772.     public function getPhenomenaList()
  4773.     {
  4774.         $phenomenas = new \Pimcore\Model\DataObject\PhenomenaList\Listing();
  4775.         $phenomenas->setOrderKey("o_creationDate");
  4776.         $phenomenas->setOrder("desc");
  4777.         $phenomenas->load();
  4778.         $response = [];
  4780.         if (count($phenomenas) > 0) {
  4781.             foreach ($phenomenas as $phenomena) {
  4782.                 $response[] = [
  4783.                     "id" => $phenomena->getPhenomenaListId(),
  4784.                     "nameEN" => $phenomena->getTitle('en'),
  4785.                     "nameAr" => $phenomena->getTitle('ar'),
  4786.                 ];
  4787.             }
  4789.             return ["success" => true, "data" => $response];
  4790.         }
  4792.         return ["success" => false, "data" => $response];
  4793.     }
  4795.     public function getHazardListByAlertStatusId($statusId,  $regionIds = [], $lang = "en")
  4796.     {
  4797.         $response = [];
  4798.         $excludeWavesRising = false;
  4799.         // Check if any region is landlocked
  4800.         if (!empty($regionIds) && is_array($regionIds)) {
  4801.             foreach ($regionIds as $regionId) {
  4802.                 $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  4803.                 if ($region && $region->getIsLandLocked()) {
  4804.                     $excludeWavesRising = true;
  4805.                     break;
  4806.                 }
  4807.             }
  4808.         }
  4809.         $alertStatus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($statusId, true);
  4810.         if ($alertStatus instanceof \Pimcore\Model\DataObject\AlertStatus) {
  4811.             if ($alertStatus && $alertStatus->getAlertHazards()) {
  4812.                 foreach ($alertStatus->getAlertHazards() as $value) {
  4813.                     $alertHazardObj = $value->getLocalizedfields()->getItems();
  4814.                     // Exclude "Waves rising" if needed
  4815.                     if (
  4816.                         $excludeWavesRising &&
  4817.                         isset($alertHazardObj['en']['name']) &&
  4818.                         strtolower(trim($alertHazardObj['en']['name'])) === 'waves rising'
  4819.                     ) {
  4820.                         continue;
  4821.                     }
  4822.                     $response[] = [
  4823.                         "id" => (int)$value->getAlertHazardId(),
  4824.                         "nameEn" => $alertHazardObj['en']['name'],
  4825.                         "nameAr" => $alertHazardObj['ar']['name']
  4826.                     ];
  4827.                 }
  4828.             } else {
  4829.                 return ["success" => false, "message" => "No Hazard is set"];
  4830.             }
  4831.         } else {
  4832.             return ["success" => false, "message" => "Invalid alert status id"];
  4833.         }
  4834.         return ["success" => true, "data" => $response];
  4835.     }
  4837.     // public function getHazardListByAlertStatusId($statusId, $lang = "en")
  4838.     // {
  4839.     //     $response = [];
  4840.     //     $alertPhenomena = \Pimcore\Model\DataObject\PhenomenaList::getByPhenomenaListId($statusId, true);
  4841.     //     if ($alertPhenomena instanceof \Pimcore\Model\DataObject\PhenomenaList) {
  4842.     //         if ($alertPhenomena && $alertPhenomena->getAlertHazards()) {
  4843.     //             foreach ($alertPhenomena->getAlertHazards() as  $value) {
  4844.     //                 $alertHazardObj = $value->getLocalizedfields()->getItems();
  4845.     //                 $response[] = ["id" => (int)$value->getAlertHazardId(), "nameEn" => $alertHazardObj['en']['name'], "nameAr" => $alertHazardObj['ar']['name']];
  4846.     //             }
  4847.     //         } else {
  4848.     //             return ["success" => false, "message" => "No Hazard is set"];
  4849.     //         }
  4850.     //     } else {
  4851.     //         return ["success" => false, "message" => "Invalid alert status id"];
  4852.     //     }
  4853.     //     return ["success" => true, "data" => $response];
  4854.     // }
  4856.     public function getOtherGovernoratesByRegion($regionId)
  4857.     {
  4858.         $response = [];
  4859.         $region = \Pimcore\Model\DataObject\Region::getByRegionId($regionId, true);
  4860.         if (!$region) {
  4861.             throw new \Exception("Region not available");
  4862.         }
  4863.         $otherGovernorates = new DataObject\EwsOtherLocation\Listing();
  4864.         //$otherGovernorates->filterByRegionId($region);
  4865.         $otherGovernorates = $otherGovernorates->load();
  4866.         if ($otherGovernorates) {
  4867.             foreach ($otherGovernorates as $governorate) {
  4868.                 $region = $governorate->getregionId();
  4869.                 $regionData = [];
  4870.                 if (!empty($region)) {
  4871.                     $regionData = [
  4872.                         "id" => $region->getRegionId(),
  4873.                         "nameEn" => $region->getName('en'),
  4874.                         "nameAr" => $region->getName('ar'),
  4875.                         "longitude" => $region->getLongitude(),
  4876.                         "latitude" => $region->getLongitude()
  4878.                     ];
  4879.                 }
  4880.                 $response[] = [
  4881.                     "id" => $governorate->getgovernoteId(),
  4882.                     "nameEn" => $governorate->getName('en'),
  4883.                     "nameAr" => $governorate->getName('ar'),
  4884.                     "regionId" => $regionData,
  4885.                     "longitude" => $governorate->getLongitude(),
  4886.                     "latitude" => $governorate->getLatitude(),
  4887.                     "isHidden" => $governorate->getisHidden(),
  4888.                     "IsMunicipality" => $governorate->getIsMunicipality(),
  4889.                     "MunicipalityID" => $governorate->getMunicipalityID()
  4890.                 ];
  4891.             }
  4892.         }
  4894.         return ["success" => true, "data" => $response];
  4895.     }
  4897.     public function createEwsReportUserGroup($params, $translator)
  4898.     {
  4899.         $response = [];
  4900.         $checkGroup = EwsAndReportUserGroup::getByName($params['name'], true);
  4901.         if ($checkGroup instanceof EwsAndReportUserGroup) {
  4902.             return ["success" => false, "message" => $translator->trans("group_name_already_exists"), "name" => $params['name']];
  4903.         }
  4904.         $ewsReportUserGroup = new DataObject\EwsAndReportUserGroup();
  4905.         $ewsReportUserGroup->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Notification/userGroups/" . $params['type'] . "/"));
  4906.         $ewsReportUserGroup->setKey(\Pimcore\Model\Element\Service::getValidKey($params['name'] . "-" . strtotime("now") . "-" . rand(1, 10000), 'object', 'object'));
  4907.         $ewsReportUserGroup->setName(strip_tags($params['name']));
  4908.         $ewsReportUserGroup->setJsonData(json_encode($params['data']));
  4909.         $ewsReportUserGroup->setGroupType($params['type']);
  4911.         $ewsReportUserGroup->setPublished(true);
  4912.         $ewsReportUserGroup->save();
  4913.         return ["success" => true, "message" => $translator->trans("ews_report_user_group_created")];
  4914.     }
  4916.     public function updateEwsReportUserGroup($params, $translator)
  4917.     {
  4918.         $response = [];
  4919.         $updateGroup = EwsAndReportUserGroup::getById($params['id']);
  4920.         if (!$updateGroup instanceof EwsAndReportUserGroup) {
  4921.             return ["success" => false, "message" => $translator->trans('ews_report_user_group_not_found'), "id" => $params['id']];
  4922.         }
  4923.         if (isset($params['name']) && !empty($params['name']) && $updateGroup->getName() != $params['name']) {
  4925.             $checkGroup = EwsAndReportUserGroup::getByName($params['name'], true);
  4926.             if ($checkGroup instanceof EwsAndReportUserGroup) {
  4927.                 return ["success" => false, "message" => $translator->trans("group_name_already_exists"), "name" => $params['name']];
  4928.             }
  4929.             $updateGroup->setName(strip_tags($params['name']));
  4930.             $updateGroup->setKey(\Pimcore\Model\Element\Service::getValidKey($params['name'] . "-" . strtotime("now") . "-" . rand(1, 10000), 'object', 'object'));
  4931.         }
  4933.         if (isset($params['data']) && !empty($params['data'])) {
  4934.             $updateGroup->setJsonData(json_encode($params['data']));
  4935.         }
  4937.         if (isset($params['type']) && !empty($params['type'])) {
  4938.             $updateGroup->setGroupType($params['type']);
  4939.             $updateGroup->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Notification/userGroups/" . $params['type'] . "/"));
  4940.         }
  4942.         $updateGroup->setJsonData(json_encode($params['data']));
  4943.         $updateGroup->setGroupType($params['type']);
  4945.         $updateGroup->setPublished(true);
  4946.         $updateGroup->save();
  4947.         return ["success" => true, "message" => $translator->trans("ews_report_user_group_updated")];
  4948.     }
  4950.     public function deleteEwsReportUserGroup($params, $translator)
  4951.     {
  4952.         $response = [];
  4953.         $deleteGroup = EwsAndReportUserGroup::getById($params['id']);
  4954.         if (!$deleteGroup instanceof EwsAndReportUserGroup) {
  4955.             return ["success" => false, "message" => $translator->trans('ews_report_user_group_not_found'), "id" => $params['id']];
  4956.         }
  4958.         $deleteGroup->delete();
  4959.         return ["success" => true, "message" => $translator->trans("ews_report_user_group_deleted")];
  4960.     }
  4962.     public function listEwsReportUserGroup($params, $paginator, $translator)
  4963.     {
  4964.         $data = [];
  4965.         $listing = new EwsAndReportUserGroup\Listing();
  4966.         $listing->setOrderKey("oo_id");
  4967.         $listing->setOrder("DESC");
  4969.         if (isset($params['type']) && !empty($params['type'])) {
  4970.             $listing->addConditionParam("groupType = ?", [$params['type']]);
  4971.         }
  4973.         if (isset($params['search']) && !empty($params['search'])) {
  4974.             $listing->addConditionParam("name LIKE ? ", ['%' . $params['search'] . '%']);
  4975.         }
  4978.         $pageSize = isset($params['page_size']) ? $params['page_size'] : LIMIT_PER_PAGE;
  4979.         $page = isset($params['page']) ? $params['page'] : 1;
  4981.         $paginator = $paginator->paginate(
  4982.             $listing,
  4983.             $page,
  4984.             $pageSize
  4985.         );
  4987.         foreach ($paginator as $group) {
  4988.             $data[] = [
  4989.                 "id" => $group->getId(),
  4990.                 "name" => $group->getName(),
  4991.                 "type" => $group->getGroupType(),
  4992.                 "data" => json_decode($group->getJsonData(), true)
  4993.             ];
  4994.         }
  4996.         if (count($data) > 0) {
  4998.             return ["success" => true, "data" => $data, "paginationVariables" => $paginator->getPaginationData()];
  4999.         } else {
  5000.             return ["success" => false, "message" => $translator->trans('no_ews_report_user_group_found')];
  5001.         }
  5002.     }
  5004.     public function getSortCriteria()
  5005.     {
  5006.         // This is a placeholder; you'll need to adapt this based on how you can access the region's name or other criteria
  5007.         return $this->getRegion()->getName();
  5008.     }
  5009.     public function getCenters($governorateId = null, $lang = 'en')
  5010.     {
  5011.         $response = [];
  5012.         $centers = new DataObject\Centers\Listing();
  5013.         if (is_array($governorateId)) {
  5014.             $govIdsArr = [];
  5015.             foreach ($governorateId as $govId) {
  5016.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  5017.                 if ($governorate) {
  5018.                     array_push($govIdsArr, $governorate->getId());
  5019.                 }
  5020.             }
  5021.             $centers->setCondition("governorate__id IN (" . implode(", ", $govIdsArr) . ")");
  5022.         } else {
  5023.             if ($governorateId) {
  5024.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($governorateId, true);
  5025.                 $centers->setCondition("governorate__id = ?", [$governorate->getId()]);
  5026.             }
  5027.         }
  5028.         $centers = $centers->load();
  5029.         if ($centers) {
  5030.             foreach ($centers as $center) {
  5031.                 $response[] = [
  5032.                     'id' => $center->getId(),
  5033.                     "object_id" => $center->getObjectId(),
  5034.                     "nameEn" => $center->getName('en'),
  5035.                     "nameAr" => $center->getName('ar'),
  5036.                     "longitude" => $center->getLongitude(),
  5037.                     "latitude" => $center->getLatitude(),
  5038.                     "governate" => $center->getGovernorate()->getGovernoteId()
  5039.                 ];
  5040.             }
  5041.         }
  5043.         // Determine sorting field based on language
  5044.         $sortField = 'nameEn'; // Default sorting by English
  5045.         if (isset($lang) && strtolower($lang) === 'ar') {
  5046.             $sortField = 'nameAr'; // Sorting by Arabic
  5047.         }
  5049.         // Sort manually using usort()
  5050.         usort($response, function ($a, $b) use ($sortField) {
  5051.             return strcmp($a[$sortField], $b[$sortField]);
  5052.         });
  5054.         return ["success" => true, "data" => $response];
  5055.     }
  5056.     public function getDistricts($governorateId = null, $lang = 'en')
  5057.     {
  5058.         $response = [];
  5059.         $districts = new DataObject\District\Listing();
  5060.         if (is_array($governorateId)) {
  5061.             $govIdsArr = [];
  5062.             foreach ($governorateId as $govId) {
  5063.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($govId, true);
  5064.                 if ($governorate) {
  5065.                     array_push($govIdsArr, $governorate->getId());
  5066.                 }
  5067.             }
  5068.             $districts->setCondition("governorate__id IN (" . implode(", ", $govIdsArr) . ")");
  5069.         } else {
  5070.             if ($governorateId) {
  5071.                 $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($governorateId, true);
  5072.                 $districts->setCondition("governorate__id = ?", [$governorate->getId()]);
  5073.             }
  5074.         }
  5075.         $districts = $districts->load();
  5076.         if ($districts) {
  5077.             foreach ($districts as $district) {
  5078.                 $response[] = [
  5079.                     "id" => $district->getId(),
  5080.                     "object_id" => $district->getObjectId(),
  5081.                     "nameEn" => $district->getName('en'),
  5082.                     "nameAr" => $district->getName('ar'),
  5083.                     "longitude" => $district->getLongitude(),
  5084.                     "latitude" => $district->getLatitude(),
  5085.                     "governate" => $district->getGovernorate()->getGovernoteId()
  5086.                 ];
  5087.             }
  5088.         }
  5090.         // Determine sorting field based on language
  5091.         $sortField = 'nameEn'; // Default sorting by English
  5092.         if (isset($lang) && strtolower($lang) === 'ar') {
  5093.             $sortField = 'nameAr'; // Sorting by Arabic
  5094.         }
  5096.         // Sort manually using usort()
  5097.         usort($response, function ($a, $b) use ($sortField) {
  5098.             return strcmp($a[$sortField], $b[$sortField]);
  5099.         });
  5101.         return ["success" => true, "data" => $response];
  5102.     }
  5103.     public function createEwsPolygon($params, $translator)
  5104.     {
  5105.         $coordinates = $params['coordinates'] ?? null;
  5106.         $alertTypeId = $params['alertTypeId'] ?? null;
  5107.         $expiryDate = $params['expiryDate'] ?? null;
  5108.         $type = $params['type'] ?? null;
  5109.         // if (!is_array($coordinates) || empty($coordinates)) {
  5110.         //     return ['success' => false, 'message' => $translator->trans('invalid_coordinates')];
  5111.         // }
  5113.         $ewsPolygon = new DataObject\EwsPolygon();
  5114.         $ewsPolygon->setParent(DataObject\Service::createFolderByPath('/Notification/EWSPolygon'));
  5115.         $ewsPolygon->setKey(uniqid("polygon-"));
  5116.         $ewsPolygon->setCoordinates(json_encode($coordinates));
  5117.         if (!empty($type)) {
  5118.             $ewsPolygon->setEwsAlertType($type);
  5119.         }
  5121.         if ($alertTypeId && !empty($alertTypeId)) {
  5122.             $alertType = DataObject\AlertType::getByAlertTypeId($alertTypeId, 1);
  5123.             if (!$alertType) {
  5124.                 return ['success' => false, 'message' => $translator->trans('invalid_alert_type')];
  5125.             }
  5126.             $ewsPolygon->setAlertType($alertType);
  5127.         }
  5128.         if ($expiryDate && !empty($expiryDate)) {
  5129.             $ewsPolygon->setExpire(\Carbon\Carbon::createFromFormat('Y-m-d H:i:s', $expiryDate));
  5130.         }
  5131.         // $ewsPolygon->setPublished(true);
  5133.         try {
  5134.             $ewsPolygon->save();
  5135.         } catch (\Exception $e) {
  5136.             return ['success' => false, 'message' => $translator->trans('error_saving_polygon'), 'error' => $e->getMessage()];
  5137.         }
  5139.         return [
  5140.             'success' => true,
  5141.             'message' => $translator->trans('ews_polygon_added_successfully'),
  5142.             'polygonId' => $ewsPolygon->getId(),
  5143.             'type' => $ewsPolygon->getEwsAlertType()
  5144.         ];
  5145.     }
  5146.     public function updateEwsPolygon($params, $translator)
  5147.     {
  5148.         $ewsPolygon = EwsPolygon::getById($params['id'] ?? null);
  5149.         if (!$ewsPolygon instanceof EwsPolygon) {
  5150.             return [
  5151.                 "success" => false,
  5152.                 "message" => $translator->trans('ews_polygon_not_found'),
  5153.                 "id" => $params['id'] ?? null
  5154.             ];
  5155.         }
  5157.         // Update coordinates if provided and valid
  5158.         if (isset($params['coordinates'])) {
  5159.             $coordinates = $params['coordinates'];
  5160.             // if (!is_array($coordinates) || empty($coordinates)) {
  5161.             //     return ['success' => false, 'message' => $translator->trans('invalid_coordinates')];
  5162.             // }
  5163.             $ewsPolygon->setCoordinates(json_encode($coordinates));
  5164.         }
  5166.         if (!empty($params['type'])) {
  5167.             $ewsPolygon->setEwsAlertType($params['type']);
  5168.         }
  5170.         // Update alert type if provided
  5171.         if (!empty($params['alertTypeId'])) {
  5172.             $alertTypeId = $params['alertTypeId'];
  5173.             $alertType = DataObject\AlertType::getByAlertTypeId($alertTypeId, 1);
  5174.             if (!$alertType) {
  5175.                 return ['success' => false, 'message' => $translator->trans('invalid_alert_type')];
  5176.             }
  5177.             $ewsPolygon->setAlertType($alertType);
  5178.         }
  5180.         // Update EWS alerts if provided
  5181.         if (!empty($params['alertIds']) && is_array($params['alertIds'])) {
  5182.             $alertIds = $params['alertIds'];
  5183.             $ewsNotifications = [];
  5184.             foreach ($alertIds as $alertId) {
  5185.                 $ewsNotification = \Pimcore\Model\DataObject\EwsNotification::getById($alertId, true);
  5186.                 if (!$ewsNotification instanceof \Pimcore\Model\DataObject\EwsNotification) {
  5187.                     return [
  5188.                         'success' => false,
  5189.                         'message' => $translator->trans('ews_notification_not_found'),
  5190.                         'invalid_alert_id' => $alertId
  5191.                     ];
  5192.                 }
  5193.                 $ewsNotification->setPolygon($ewsPolygon);
  5194.                 $ewsNotification->save();
  5195.                 $ewsNotifications[] = $ewsNotification;
  5196.             }
  5197.             $ewsPolygon->setEwsAlerts(array_unique($ewsNotifications));
  5198.         }
  5199.         if (!empty($params['expiryDate'])) {
  5200.             $ewsPolygon->setExpire(\Carbon\Carbon::createFromFormat('Y-m-d H:i:s', $params['expiryDate']));
  5201.         }
  5202.         if (!empty($params['isPublished']) && $params['isPublished'] == true) {
  5203.             $ewsPolygon->setPublished(true);
  5204.         }
  5205.         // Try saving
  5206.         try {
  5207.             $ewsPolygon->save();
  5208.         } catch (\Exception $e) {
  5209.             return [
  5210.                 'success' => false,
  5211.                 'message' => $translator->trans('error_saving_polygon'),
  5212.                 'error' => $e->getMessage()
  5213.             ];
  5214.         }
  5216.         return [
  5217.             'success' => true,
  5218.             'message' => $translator->trans('ews_polygon_updated_successfully'),
  5219.             'polygonId' => $ewsPolygon->getId()
  5220.         ];
  5221.     }
  5222.     public function listEwsPolygon($params, $paginator, $translator)
  5223.     {
  5224.         $ewsId = $params['id'] ?? null;
  5225.         $isPublished = array_key_exists('isPublished', $params) ? (bool) $params['isPublished'] : true;
  5226.         \Pimcore\Model\DataObject::setHideUnpublished(false);
  5228.         $listing = new EwsPolygon\Listing();
  5229.         // $listing->addConditionParam('expire >= ?', [time()]);
  5231.         if ($ewsId) {
  5232.             $listing->addConditionParam('o_id = ?', [(int)$ewsId]);
  5233.         }
  5235.         $listing->setOrderKey("oo_id");
  5236.         $listing->setOrder("DESC");
  5238.         $data = [];
  5240.         foreach ($listing as $polygon) {
  5241.             if ($polygon->getPublished() !== $isPublished) {
  5242.                 continue; // skip if it doesn't match the required published status
  5243.             }
  5245.             $alertIds = [];
  5246.             $isEnded = false;
  5247.             $alerts = $polygon->getEwsAlerts();
  5248.             if (is_array($alerts)) {
  5249.                 foreach ($alerts as $alert) {
  5250.                     if ($alert instanceof \Pimcore\Model\DataObject\EwsNotification) {
  5251.                         $alertIds[] = $alert->getId();
  5252.                         $isEnded = $alert->getStatus() == "ended" ? true : false;
  5253.                     }
  5254.                 }
  5255.             }
  5257.             $alertTypeObj = $polygon->getAlertType();
  5258.             $alertTypeId = ($alertTypeObj instanceof \Pimcore\Model\DataObject\AlertType)
  5259.                 ? $alertTypeObj->getAlertTypeId()
  5260.                 : null;
  5262.             $data[] = [
  5263.                 "id" => $polygon->getId(),
  5264.                 "coordinates" => json_decode($polygon->getCoordinates(), true),
  5265.                 "alertType" => $alertTypeId,
  5266.                 "type" => $polygon->getEwsAlertType(),
  5267.                 "alerts" => $alertIds,
  5268.                 "expiryDate" => $polygon->getExpire(),
  5269.                 "isExpired" => $polygon->getExpire() ? $polygon->getExpire()->getTimestamp() < time() : null,
  5270.                 "isEnded" => $isEnded
  5271.             ];
  5272.         }
  5274.         if (!empty($data)) {
  5275.             return [
  5276.                 "success" => true,
  5277.                 "data" => $data,
  5278.             ];
  5279.         }
  5281.         return [
  5282.             "success" => false,
  5283.             "message" => $translator->trans('polygons_not_found'),
  5284.         ];
  5285.     }
  5287.     public function endEwsNotification($params, $translator, $logger)
  5288.     {
  5289.         $result = [];
  5292.         $viewNotification = DataObject\EwsNotification::getById($params['id'], true);
  5294.         if (!$viewNotification instanceof EwsNotification) {
  5295.             return [
  5296.                 "success" => false,
  5297.                 "message" => $translator->trans('ews_notification_not_found'),
  5298.                 "id" => $params['id'] ?? null
  5299.             ];
  5300.         }
  5303.         //set ews search Id
  5304.         $viewNotification->setStatus("ended");
  5305.         $viewNotification->setAlertEndDate(\Carbon\Carbon::now());
  5307.         // Persist the browser-rendered image (x_img) as an asset on the alert so the Twitter end
  5308.         // listener posts that instead of generating one with wkhtmltoimage. The save() below
  5309.         // fires the listener, which reads endXAttachment.
  5310.         if (!empty($params['x_img'])) {
  5311.             $dataUri = $params['x_img'];
  5312.             if (($commaPos = strpos($dataUri, ',')) !== false && stripos($dataUri, 'base64') !== false) {
  5313.                 $dataUri = substr($dataUri, $commaPos + 1);
  5314.             }
  5315.             $binary = base64_decode(strtr($dataUri, ' ', '+'), true);
  5316.             if ($binary !== false && $binary !== '') {
  5317.                 $endAsset = \App\Lib\Utility::createAsset(
  5318.                     $binary,
  5319.                     $viewNotification->getId() . '_' . time() . '_end_ews_alert.png',
  5320.                     'END EWS Twitter Images'
  5321.                 );
  5322.                 if ($endAsset) {
  5323.                     $viewNotification->setEndXAttachment($endAsset);
  5324.                 }
  5325.             }
  5326.         }
  5328.         // DIAGNOSTIC (temporary): confirm the end method runs and log the values the
  5329.         // TwitterEwsEndEventListner gates on. Written to Pimcore ApplicationLogger so it
  5330.         // lands in the application_logs table. Remove once the End-tweet issue is resolved.
  5331.         \Pimcore\Log\ApplicationLogger::getInstance('END-DIAG', true)->info(sprintf(
  5332.             '[END-DIAG] endEwsNotification saving EWS ID %s | published=%s | enableTwitter=%s | status=%s',
  5333.             $viewNotification->getId(),
  5334.             var_export($viewNotification->isPublished(true), true),
  5335.             var_export($viewNotification->getEnableTwitterNotification(), true),
  5336.             var_export($viewNotification->getStatus(), true)
  5337.         ));
  5339.         $viewNotification->save(["versionNote" => "End alert"]);
  5340.         $viewNotification->save();
  5342.         if ($this->shouldDispatchPublicPortalEwsWebhook($viewNotification)) {
  5343.             $this->dispatchPublicPortalEwsWebhookIfConfigured((int) $viewNotification->getId(), $logger);
  5344.         }
  5346.         $alert = $this->createNotificationFormat($viewNotification, $translator, $params['decodedJwtToken'], $params['userPermission']);
  5348.         if ($viewNotification) {
  5349.             // Email the same user groups that were selected when the alert was published/edited.
  5350.             $userGroupIds = array_map(
  5351.                 fn($group) => $group->getId(),
  5352.                 $viewNotification->getUserGroup()
  5353.             );
  5355.             // Ensure you use 'php' to execute the command.
  5356.             $command = ['php', 'bin/console', 'app:send-early-warning-alert-email', '--alertId=' . $viewNotification->getId(), '--endAlert=1'];
  5357.             if (!empty($userGroupIds)) {
  5358.                 $command[] = '--userGroupIds=' . json_encode($userGroupIds);
  5359.             }
  5360.             $process = new Process($command);
  5361.             $process->setWorkingDirectory(PIMCORE_PROJECT_ROOT);
  5362.             // Set timeout to 5 minutes (300 seconds) or null for no timeout
  5363.             $process->setTimeout(300); // or use null for unlimited time
  5365.             try {
  5366.                 $process->mustRun();
  5367.                 $result['success'] = true;
  5368.                 $logger->info("End EwsNotification command executed successfully: " . $process->getOutput());
  5369.                 $result['message'] = $process->getOutput();
  5370.             } catch (ProcessFailedException $exception) {
  5371.                 $logger->error("End EwsNotification command failed: " . $exception->getMessage());
  5372.                 return ['success' => false, 'message' => $exception->getMessage()];
  5373.             }
  5374.         }
  5376.         return ["success" => true, "message" => $translator->trans("ews_notification_end")];
  5377.     }
  5379.     /**
  5380.      * Persist distinct message texts for a user so create/update history is preserved.
  5381.      * Re-using the same message bumps last_used_at; new text inserts a new row.
  5382.      *
  5383.      * @param array<string, string> $messages keyed by locale (e.g. en/ar)
  5384.      */
  5385.     public function saveUserMessageSuggestions(int $userId, array $messages): void
  5386.     {
  5387.         if ($userId <= 0 || empty($messages)) {
  5388.             return;
  5389.         }
  5391.         $db = Db::get();
  5392.         $now = (new \DateTime())->format('Y-m-d H:i:s');
  5394.         foreach ($messages as $language => $text) {
  5395.             $text = trim((string) $text);
  5396.             if ($text === '') {
  5397.                 continue;
  5398.             }
  5400.             $hash = hash('sha256', $text);
  5401.             $existingId = $db->fetchOne(
  5402.                 'SELECT id FROM ews_user_message_suggestions WHERE user_id = ? AND message_hash = ?',
  5403.                 [$userId, $hash]
  5404.             );
  5406.             if ($existingId) {
  5407.                 $db->executeStatement(
  5408.                     'UPDATE ews_user_message_suggestions SET last_used_at = ?, language = COALESCE(?, language) WHERE id = ?',
  5409.                     [$now, is_string($language) ? $language : null, $existingId]
  5410.                 );
  5411.             } else {
  5412.                 $db->insert('ews_user_message_suggestions', [
  5413.                     'user_id' => $userId,
  5414.                     'message' => $text,
  5415.                     'message_hash' => $hash,
  5416.                     'language' => is_string($language) ? $language : null,
  5417.                     'last_used_at' => $now,
  5418.                     'created_at' => $now,
  5419.                 ]);
  5420.             }
  5421.         }
  5422.     }
  5424.     /**
  5425.      * Search previously used EWS notification messages for an authenticated user.
  5426.      * Only searches when $q has at least 2 characters.
  5427.      * Reads from ews_user_message_suggestions so updates keep prior message history.
  5428.      *
  5429.      * @return array{success: bool, data: list<array{message: string, last_used_at: string|null, created_at: string|null}>}
  5430.      */
  5431.     public function getUserMessageSuggestions(int $userId, string $q, int $limit = 10): array
  5432.     {
  5433.         $q = trim($q);
  5434.         $limit = max(1, min(10, $limit));
  5436.         if (mb_strlen($q) < 2) {
  5437.             return ['success' => true, 'data' => []];
  5438.         }
  5440.         $db = Db::get();
  5441.         $qb = $db->createQueryBuilder();
  5442.         $qb->select([
  5443.                 'message',
  5444.                 'last_used_at',
  5445.                 'created_at',
  5446.             ])
  5447.             ->from('ews_user_message_suggestions')
  5448.             ->where('user_id = :userId')
  5449.             ->andWhere('message LIKE :search')
  5450.             ->orderBy('last_used_at', 'DESC')
  5451.             ->addOrderBy('created_at', 'DESC')
  5452.             ->setMaxResults($limit)
  5453.             ->setParameter('userId', $userId)
  5454.             ->setParameter('search', '%' . $q . '%');
  5456.         $rows = $qb->execute()->fetchAllAssociative();
  5458.         $data = [];
  5459.         foreach ($rows as $row) {
  5460.             $data[] = [
  5461.                 'message' => (string) $row['message'],
  5462.                 'last_used_at' => $row['last_used_at'] ?? null,
  5463.                 'created_at' => $row['created_at'] ?? null,
  5464.             ];
  5465.         }
  5467.         return ['success' => true, 'data' => $data];
  5468.     }
  5470.     /**
  5471.      * Build Alert History rows for Twitter image from Update versions.
  5472.      * Multiple alert actions on the same version are clubbed into one row.
  5473.      *
  5474.      * Mapping:
  5475.      * Change Location → Update Alert Location
  5476.      * Change Type → Lower Alert / Raise Alert
  5477.      * Change Date or Time → Update Alert Period
  5478.      * Change Status → Update Alert Status
  5479.      */
  5480.     public function buildAlertHistoryImageEntries(
  5481.         EwsNotification $notification,
  5482.         bool $includeCurrentState = true,
  5483.         $translator = null,
  5484.         string $lang = 'en'
  5485.     ): array {
  5486.         $lang = strtolower($lang) === 'ar' ? 'ar' : 'en';
  5487.         $timezone = new \DateTimeZone(defined('TIMEZONE') ? TIMEZONE : 'Asia/Riyadh');
  5488.         $snapshots = [];
  5490.         $versions = $notification->getVersions() ?: [];
  5491.         foreach ($versions as $version) {
  5492.             if ($version->getNote() !== 'Update') {
  5493.                 continue;
  5494.             }
  5495.             $view = $version->loadData();
  5496.             if (!$view instanceof EwsNotification) {
  5497.                 continue;
  5498.             }
  5499.             $actions = $this->extractRelevantHistoryActions($view, $translator, $lang);
  5500.             if ($actions === []) {
  5501.                 continue;
  5502.             }
  5503.             $snapshots[] = [
  5504.                 'ts' => (int) ($version->getDate() ?: $view->getModificationDate() ?: $view->getCreationDate()),
  5505.                 'obj' => $view,
  5506.                 'actions' => $actions,
  5507.             ];
  5508.         }
  5510.         // Include the in-memory updated state (not yet saved as a version).
  5511.         if ($includeCurrentState) {
  5512.             $currentActions = $this->extractRelevantHistoryActions($notification, $translator, $lang);
  5513.             if ($currentActions !== []) {
  5514.                 $snapshots[] = [
  5515.                     'ts' => time(),
  5516.                     'obj' => $notification,
  5517.                     'actions' => $currentActions,
  5518.                 ];
  5519.             }
  5520.         }
  5522.         usort($snapshots, static fn($a, $b) => ($a['ts'] ?? 0) <=> ($b['ts'] ?? 0));
  5524.         $entries = [];
  5525.         $hasNewAlert = false;
  5526.         $titleSeparator = $lang === 'ar' ? ' | ' : ' | ';
  5528.         foreach ($snapshots as $index => $snap) {
  5529.             /** @var EwsNotification $obj */
  5530.             $obj = $snap['obj'];
  5531.             $previous = $index > 0 ? $snapshots[$index - 1]['obj'] : null;
  5532.             $timestamp = $this->formatAlertHistoryTimestamp((int) $snap['ts'], $timezone);
  5533.             $color = $this->resolveAlertHistoryDotColor($obj);
  5535.             $clubbedActions = [];
  5536.             $titleParts = [];
  5537.             $detailParts = [];
  5538.             $primaryKey = '';
  5540.             foreach ($snap['actions'] as $actionMeta) {
  5541.                 $key = $actionMeta['key'];
  5542.                 $title = $actionMeta['title'];
  5543.                 if ($key === 'New Alert') {
  5544.                     $hasNewAlert = true;
  5545.                 }
  5546.                 if ($primaryKey === '') {
  5547.                     $primaryKey = $key;
  5548.                 }
  5549.                 $detail = $this->buildAlertHistoryActionDetail(
  5550.                     $key,
  5551.                     $obj,
  5552.                     $previous instanceof EwsNotification ? $previous : null,
  5553.                     $timezone,
  5554.                     $translator,
  5555.                     $lang
  5556.                 );
  5557.                 $titleParts[] = $title;
  5558.                 if ($detail !== '') {
  5559.                     $detailParts[] = $detail;
  5560.                 }
  5561.                 $clubbedActions[] = [
  5562.                     'title' => $title,
  5563.                     'detail' => $detail,
  5564.                     'key' => $key,
  5565.                 ];
  5566.             }
  5568.             $entries[] = [
  5569.                 'timestamp' => $timestamp,
  5570.                 'title' => implode($titleSeparator, $titleParts),
  5571.                 'titleKey' => $primaryKey,
  5572.                 'detail' => implode("\n", $detailParts),
  5573.                 'actions' => $clubbedActions,
  5574.                 'color' => $color,
  5575.                 'ts' => (int) $snap['ts'],
  5576.             ];
  5577.         }
  5579.         if (!$hasNewAlert) {
  5580.             $createdTs = (int) ($notification->getCreationDate() ?: time());
  5581.             $newAlertTitle = $this->transAlertHistory('New Alert', $translator, $lang);
  5582.             array_unshift($entries, [
  5583.                 'timestamp' => $this->formatAlertHistoryTimestamp($createdTs, $timezone),
  5584.                 'title' => $newAlertTitle,
  5585.                 'titleKey' => 'New Alert',
  5586.                 'detail' => '',
  5587.                 'actions' => [
  5588.                     [
  5589.                         'title' => $newAlertTitle,
  5590.                         'detail' => '',
  5591.                         'key' => 'New Alert',
  5592.                     ],
  5593.                 ],
  5594.                 'color' => $this->resolveAlertHistoryDotColor($notification),
  5595.                 'ts' => $createdTs,
  5596.             ]);
  5597.         }
  5599.         usort($entries, static fn($a, $b) => ($b['ts'] ?? 0) <=> ($a['ts'] ?? 0));
  5601.         return array_values($entries);
  5602.     }
  5604.     /**
  5605.      * Render Alert History HTML and convert to a PNG asset with wkhtmltoimage.
  5606.      */
  5607.     public function generateAlertHistoryTwitterImage(
  5608.         EwsNotification $notification,
  5609.         $templating,
  5610.         $logger = null,
  5611.         bool $includeCurrentState = true,
  5612.         $translator = null,
  5613.         string $lang = 'en'
  5614.     ): ?\Pimcore\Model\Asset {
  5615.         $lang = strtolower($lang) === 'ar' ? 'ar' : 'en';
  5616.         $entries = $this->buildAlertHistoryImageEntries($notification, $includeCurrentState, $translator, $lang);
  5617.         if ($entries === []) {
  5618.             return null;
  5619.         }
  5621.         $timezone = new \DateTimeZone(defined('TIMEZONE') ? TIMEZONE : 'Asia/Riyadh');
  5622.         $startedTs = (int) ($notification->getCreationDate() ?: time());
  5623.         foreach ($entries as $entry) {
  5624.             $isNewAlert = ($entry['titleKey'] ?? '') === 'New Alert';
  5625.             if (!$isNewAlert && !empty($entry['actions']) && is_array($entry['actions'])) {
  5626.                 foreach ($entry['actions'] as $action) {
  5627.                     if (($action['key'] ?? '') === 'New Alert') {
  5628.                         $isNewAlert = true;
  5629.                         break;
  5630.                     }
  5631.                 }
  5632.             }
  5633.             if ($isNewAlert && !empty($entry['ts'])) {
  5634.                 $startedTs = min($startedTs, (int) $entry['ts']);
  5635.             }
  5636.         }
  5638.         $html = $templating->render('image_templates/alert-history.html.twig', [
  5639.             'lang' => $lang,
  5640.             'isRtl' => $lang === 'ar',
  5641.             'labels' => [
  5642.                 'alertHistory' => $this->transAlertHistory('Alert History', $translator, $lang),
  5643.             ],
  5644.             'startedOn' => $this->formatAlertHistoryStartedOn($startedTs, $timezone, $translator, $lang),
  5645.             'entries' => $entries,
  5646.         ]);
  5648.         $container = \Pimcore::getContainer();
  5649.         /** @var SnappyImage $snappyImage */
  5650.         $snappyImage = $container->has('knp_snappy.image')
  5651.             ? $container->get('knp_snappy.image')
  5652.             : $container->get(SnappyImage::class);
  5654.         $snappyImage->setOption('enable-local-file-access', true);
  5655.         $snappyImage->setOption('width', '776');
  5656.         $snappyImage->setOption('format', 'png');
  5657.         $snappyImage->setOption('quality', 100);
  5659.         $imageBinary = $snappyImage->getOutputFromHtml($html);
  5660.         if (!$imageBinary) {
  5661.             if ($logger) {
  5662.                 $logger->error('wkhtmltoimage returned empty output for EWS alert history image');
  5663.             }
  5664.             return null;
  5665.         }
  5667.         return \App\Lib\Utility::createAsset(
  5668.             $imageBinary,
  5669.             uniqid('', true) . '_ews_alert_history_' . $lang . '.png',
  5670.             'EWS Twitter Images'
  5671.         );
  5672.     }
  5674.     /**
  5675.      * @return array<int, array{key: string, title: string}>
  5676.      */
  5677.     private function extractRelevantHistoryActions(EwsNotification $notification, $translator = null, string $lang = 'en'): array
  5678.     {
  5679.         $titles = [];
  5680.         $seenKeys = [];
  5681.         $actions = $notification->getAlertAction() ?: [];
  5682.         foreach ($actions as $action) {
  5683.             if (!$action) {
  5684.                 continue;
  5685.             }
  5686.             $key = $this->mapAlertActionToHistoryTitle((string) $action->getName('en'));
  5687.             if ($key === null || isset($seenKeys[$key])) {
  5688.                 continue;
  5689.             }
  5690.             $seenKeys[$key] = true;
  5691.             $localized = (string) ($action->getName($lang) ?: '');
  5692.             $titles[] = [
  5693.                 'key' => $key,
  5694.                 'title' => $localized !== '' ? $localized : $this->transAlertHistory($key, $translator, $lang),
  5695.             ];
  5696.         }
  5698.         return $titles;
  5699.     }
  5701.     /**
  5702.      * Map stored alert-action / change labels to canonical history keys.
  5703.      */
  5704.     private function mapAlertActionToHistoryTitle(string $nameEn): ?string
  5705.     {
  5706.         $haystack = strtolower(trim($nameEn));
  5707.         if ($haystack === '') {
  5708.             return null;
  5709.         }
  5711.         if (str_contains($haystack, 'new alert')) {
  5712.             return 'New Alert';
  5713.         }
  5714.         if (str_contains($haystack, 'raise')) {
  5715.             return 'Raise Alert';
  5716.         }
  5717.         if (str_contains($haystack, 'lower')) {
  5718.             return 'Lower Alert';
  5719.         }
  5720.         if (str_contains($haystack, 'location') || $haystack === 'change location') {
  5721.             return 'Update Alert Location';
  5722.         }
  5723.         if (
  5724.             str_contains($haystack, 'period')
  5725.             || str_contains($haystack, 'change date')
  5726.             || str_contains($haystack, 'change time')
  5727.             || str_contains($haystack, 'date or time')
  5728.             || (str_contains($haystack, 'time') && str_contains($haystack, 'update'))
  5729.         ) {
  5730.             return 'Update Alert Period';
  5731.         }
  5732.         if (str_contains($haystack, 'status') || $haystack === 'change status') {
  5733.             return 'Update Alert Status';
  5734.         }
  5736.         return null;
  5737.     }
  5739.     private function buildAlertHistoryActionDetail(
  5740.         string $titleKey,
  5741.         EwsNotification $current,
  5742.         ?EwsNotification $previous,
  5743.         \DateTimeZone $timezone,
  5744.         $translator = null,
  5745.         string $lang = 'en'
  5746.     ): string {
  5747.         if (!$previous) {
  5748.             return '';
  5749.         }
  5751.         if ($titleKey === 'Raise Alert' || $titleKey === 'Lower Alert') {
  5752.             $from = $this->resolveAlertSeverityLabel($previous, $lang, $translator);
  5753.             $to = $this->resolveAlertSeverityLabel($current, $lang, $translator);
  5754.             if ($from !== '' && $to !== '' && $from !== $to) {
  5755.                 return $this->transAlertHistory(
  5756.                     'Severity changed from %from% to %to%',
  5757.                     $translator,
  5758.                     $lang,
  5759.                     ['%from%' => $from, '%to%' => $to]
  5760.                 );
  5761.             }
  5762.         }
  5764.         if ($titleKey === 'Update Alert Location') {
  5765.             $currentNames = $this->extractGovernorateNamesForHistory($current, $lang);
  5766.             $previousNames = $this->extractGovernorateNamesForHistory($previous, $lang);
  5767.             $added = array_values(array_diff($currentNames, $previousNames));
  5768.             $removed = array_values(array_diff($previousNames, $currentNames));
  5769.             $nameSeparator = $lang === 'ar' ? '، ' : ', ';
  5770.             $parts = [];
  5771.             if ($added) {
  5772.                 $parts[] = $this->transAlertHistory(
  5773.                     'Added governorates: %names%',
  5774.                     $translator,
  5775.                     $lang,
  5776.                     ['%names%' => implode($nameSeparator, $added)]
  5777.                 );
  5778.             }
  5779.             if ($removed) {
  5780.                 $parts[] = $this->transAlertHistory(
  5781.                     'Removed governorates: %names%',
  5782.                     $translator,
  5783.                     $lang,
  5784.                     ['%names%' => implode($nameSeparator, $removed)]
  5785.                 );
  5786.             }
  5787.             return implode('. ', $parts);
  5788.         }
  5790.         if ($titleKey === 'Update Alert Period') {
  5791.             $from = $this->formatAlertHistoryPeriodRange($previous, $timezone);
  5792.             $to = $this->formatAlertHistoryPeriodRange($current, $timezone);
  5793.             if ($from !== $to) {
  5794.                 return $this->transAlertHistory(
  5795.                     'Time changed from %from% to %to%',
  5796.                     $translator,
  5797.                     $lang,
  5798.                     ['%from%' => $from, '%to%' => $to]
  5799.                 );
  5800.             }
  5801.         }
  5803.         if ($titleKey === 'Update Alert Status') {
  5804.             $from = (string) ($previous->getAlertStatus()?->getName($lang) ?? $previous->getAlertStatus()?->getName('en') ?? '');
  5805.             $to = (string) ($current->getAlertStatus()?->getName($lang) ?? $current->getAlertStatus()?->getName('en') ?? '');
  5806.             if ($from !== '' && $to !== '' && $from !== $to) {
  5807.                 return $this->transAlertHistory(
  5808.                     'Status changed from %from% to %to%',
  5809.                     $translator,
  5810.                     $lang,
  5811.                     ['%from%' => $from, '%to%' => $to]
  5812.                 );
  5813.             }
  5814.         }
  5816.         return '';
  5817.     }
  5819.     /**
  5820.      * @return string[]
  5821.      */
  5822.     private function extractGovernorateNamesForHistory(EwsNotification $notification, string $lang = 'en'): array
  5823.     {
  5824.         $names = [];
  5825.         $fallback = $lang === 'ar' ? 'en' : 'ar';
  5826.         foreach ($notification->getGovernorate() ?: [] as $gov) {
  5827.             if ($gov) {
  5828.                 $name = (string) ($gov->getName($lang) ?: $gov->getName($fallback));
  5829.                 if ($name !== '') {
  5830.                     $names[] = $name;
  5831.                 }
  5832.             }
  5833.         }
  5834.         foreach ($notification->getMapGovernorate() ?: [] as $gov) {
  5835.             if ($gov) {
  5836.                 $name = (string) ($gov->getName($lang) ?: $gov->getName($fallback));
  5837.                 if ($name !== '' && !in_array($name, $names, true)) {
  5838.                     $names[] = $name;
  5839.                 }
  5840.             }
  5841.         }
  5843.         return $names;
  5844.     }
  5846.     private function formatAlertHistoryPeriodRange(EwsNotification $notification, \DateTimeZone $timezone): string
  5847.     {
  5848.         $startDate = $notification->getStartDate();
  5849.         $endDate = $notification->getEndDate();
  5850.         $start = $startDate
  5851.             ? ($startDate instanceof \Carbon\Carbon ? $startDate->copy()->setTimezone($timezone) : (clone $startDate)->setTimezone($timezone))
  5852.             : null;
  5853.         $end = $endDate
  5854.             ? ($endDate instanceof \Carbon\Carbon ? $endDate->copy()->setTimezone($timezone) : (clone $endDate)->setTimezone($timezone))
  5855.             : null;
  5856.         $startStr = $start ? $start->format('d/m/Y H:i') : '';
  5857.         $endStr = $end ? $end->format('d/m/Y H:i') : '';
  5858.         if ($startStr === '' && $endStr === '') {
  5859.             return '';
  5860.         }
  5862.         return $startStr . '–' . $endStr;
  5863.     }
  5865.     private function formatAlertHistoryTimestamp(int $timestamp, \DateTimeZone $timezone): string
  5866.     {
  5867.         if ($timestamp <= 0) {
  5868.             return '';
  5869.         }
  5870.         $dt = (new \DateTime('@' . $timestamp))->setTimezone($timezone);
  5872.         return $dt->format('d/m/Y') . ' | ' . $dt->format('H:i');
  5873.     }
  5875.     private function formatAlertHistoryStartedOn(int $timestamp, \DateTimeZone $timezone, $translator = null, string $lang = 'en'): string
  5876.     {
  5877.         if ($timestamp <= 0) {
  5878.             return '';
  5879.         }
  5880.         $dt = (new \DateTime('@' . $timestamp))->setTimezone($timezone);
  5882.         return $this->transAlertHistory(
  5883.             'Started on %date% at %time%',
  5884.             $translator,
  5885.             $lang,
  5886.             [
  5887.                 '%date%' => $dt->format('d/m/Y'),
  5888.                 '%time%' => $dt->format('H:i'),
  5889.             ]
  5890.         );
  5891.     }
  5893.     private function transAlertHistory(string $key, $translator = null, string $lang = 'en', array $params = []): string
  5894.     {
  5895.         $fallback = [
  5896.             'en' => [
  5897.                 'Alert History' => 'Alert History',
  5898.                 'New Alert' => 'New Alert',
  5899.                 'Raise Alert' => 'Raise Alert',
  5900.                 'Lower Alert' => 'Lower Alert',
  5901.                 'Update Alert Location' => 'Update Alert Location',
  5902.                 'Update Alert Period' => 'Update Alert Period',
  5903.                 'Update Alert Status' => 'Update Alert Status',
  5904.                 'Started on %date% at %time%' => 'Started on %date% at %time%',
  5905.                 'Added governorates: %names%' => 'Added governorates: %names%',
  5906.                 'Removed governorates: %names%' => 'Removed governorates: %names%',
  5907.                 'Time changed from %from% to %to%' => 'Time changed from %from% to %to%',
  5908.                 'Status changed from %from% to %to%' => 'Status changed from %from% to %to%',
  5909.                 'Severity changed from %from% to %to%' => 'Severity changed from %from% to %to%',
  5910.                 'Red' => 'Red',
  5911.                 'Orange' => 'Orange',
  5912.                 'Yellow' => 'Yellow',
  5913.                 'Green' => 'Green',
  5914.             ],
  5915.             'ar' => [
  5916.                 'Alert History' => 'سجل التنبيه',
  5917.                 'New Alert' => 'تنبيه جديد',
  5918.                 'Raise Alert' => 'رفع مستوى التنبيه',
  5919.                 'Lower Alert' => 'خفض مستوى التنبيه',
  5920.                 'Update Alert Location' => 'تحديث موقع التنبيه',
  5921.                 'Update Alert Period' => 'تحديث فترة التنبيه',
  5922.                 'Update Alert Status' => 'تحديث حالة التنبيه',
  5923.                 'Started on %date% at %time%' => 'بدأ في %date% الساعة %time%',
  5924.                 'Added governorates: %names%' => 'المحافظات المضافة: %names%',
  5925.                 'Removed governorates: %names%' => 'المحافظات المحذوفة: %names%',
  5926.                 'Time changed from %from% to %to%' => 'تم تغيير الوقت من %from% إلى %to%',
  5927.                 'Status changed from %from% to %to%' => 'تم تغيير الحالة من %from% إلى %to%',
  5928.                 'Severity changed from %from% to %to%' => 'تم تغيير الشدة من %from% إلى %to%',
  5929.                 'Red' => 'أحمر',
  5930.                 'Orange' => 'برتقالي',
  5931.                 'Yellow' => 'أصفر',
  5932.                 'Green' => 'أخضر',
  5933.             ],
  5934.         ];
  5936.         $applyParams = static function (string $text) use ($params): string {
  5937.             foreach ($params as $search => $replace) {
  5938.                 $text = str_replace((string) $search, (string) $replace, $text);
  5939.             }
  5941.             return $text;
  5942.         };
  5944.         if ($translator && method_exists($translator, 'trans')) {
  5945.             $translated = $translator->trans($key, $params, null, $lang);
  5946.             if (is_string($translated) && $translated !== '') {
  5947.                 // Symfony returns the message id when missing; prefer our bilingual fallback.
  5948.                 $untranslated = $applyParams($key);
  5949.                 if (!($lang !== 'en' && $translated === $untranslated && isset($fallback[$lang][$key]))) {
  5950.                     return $translated;
  5951.                 }
  5952.             }
  5953.         }
  5955.         $text = $fallback[$lang][$key] ?? ($fallback['en'][$key] ?? $key);
  5957.         return $applyParams($text);
  5958.     }
  5960.     private function resolveAlertHistoryDotColor(EwsNotification $notification): string
  5961.     {
  5962.         $color = strtolower((string) ($notification->getAlertType()?->getColor() ?? 'red'));
  5963.         if (in_array($color, ['red', 'orange', 'yellow', 'green'], true)) {
  5964.             return $color;
  5965.         }
  5967.         return 'red';
  5968.     }
  5969. }