src/Command/StoreMannedToEwsAlertCommnad.php line 237

Open in your IDE?
  1. <?php
  3. namespace App\Command;
  5. use Datetime;
  6. use Pimcore\Db;
  7. use GuzzleHttp\Client;
  8. use Pimcore\Log\Simple;
  9. use App\Service\RedisCache;
  10. use App\Model\LocationModel;
  11. use GuzzleHttp\Psr7\Request;
  12. use App\Service\EmailService;
  13. use Pimcore\Model\DataObject;
  14. use App\Model\EwsNotificationModel;
  15. use App\Service\NCMWeatherAPIService;
  16. use App\Service\MeteomaticsWeatherService;
  17. use Symfony\Component\Console\Command\Command;
  18. use Symfony\Component\Templating\EngineInterface;
  19. use Symfony\Component\Console\Input\InputArgument;
  20. use Symfony\Component\Console\Input\InputInterface;
  21. use Symfony\Component\Console\Output\OutputInterface;
  22. use App\C2IntegrationBundle\Service\C2Service;
  23. use App\Service\RichService;
  24. use Symfony\Contracts\HttpClient\HttpClientInterface;
  25. use Pimcore\Model\DataObject\FetchSentEwsEmail;
  26. use Symfony\Contracts\Translation\TranslatorInterface;
  27. use Pimcore\Log\ApplicationLogger;
  29. class StoreMannedToEwsAlertCommnad extends Command
  30. {
  31.     protected static $defaultName = 'app:get-manned-in-ews-alerts';
  32.     const HOURS = 24;
  33.     var $emailService = null;
  34.     private $templating;
  35.     private $nCMWeatherAPIService;
  36.     private $redisCache;
  37.     private $locationModel;
  38.     private $ewsNotificationModel;
  39.     private $c2Service;
  40.     private $richService;
  41.     private $httpClient;
  42.     private $logger;
  45.     public function __construct(EngineInterface $templating, RedisCache $redisCache, RichService $richService, HttpClientInterface $httpClient, protected TranslatorInterface $translator, ApplicationLogger $logger)
  46.     {
  47.         parent::__construct();
  49.         $this->templating = $templating;
  50.         $this->nCMWeatherAPIService = new NCMWeatherAPIService($redisCache, $httpClient);
  51.         $this->redisCache = $redisCache;
  52.         $this->locationModel = new LocationModel();
  53.         $this->ewsNotificationModel = new EwsNotificationModel();
  54.         $this->c2Service = new C2Service();
  55.         $this->richService = $richService;
  56.         $this->logger = $logger;
  57.     }
  59.     protected function configure()
  60.     {
  61.         $this->setDescription('Retrieve manned alerts by location and strore in EwsNotification object');
  62.     }
  64.     protected function execute(InputInterface $input, OutputInterface $output)
  65.     {
  66.         $this->emailService = new EmailService();
  67.         $mateoMaticsService = new MeteomaticsWeatherService($this->redisCache);
  71.         // Fetching alerts 
  72.         $alerts = $this->nCMWeatherAPIService->getAlerts();
  74.         if ($alerts) {
  76.             foreach ($alerts as $alert) {
  77.                 try {
  78.                     // Create update alert
  79.                     $ewsAlert = $this->createUpdateAlertNotification($alert, $output);
  81.                     if (!$ewsAlert) {
  82.                         $output->writeln('Nothing updated on notification = ' . $alert['id']);
  83.                         continue;
  84.                     }
  85.                     if ($_ENV['SEND_EMAIL_NOTIFICATION'] == "false") {
  86.                         $output->writeln('Email is not allowed on this environment');
  87.                         continue;
  88.                     }
  90.                     if (!$ewsAlert->getIsSent()) {
  93.                         $mannedAlertSubscription = new DataObject\MannedAlertSubscription\Listing();
  94.                         $mannedAlertSubscription->setOrderKey("o_creationDate");
  95.                         $mannedAlertSubscription->setOrder("desc");
  96.                         foreach ($mannedAlertSubscription as $subscription) {
  97.                             if ($subscription->getIsPublic() == false) {
  98.                                 // $subscriptionRegion = $subscription->getIsPublic() ?? false;
  99.                                 $subscriptionRegion =  false;
  100.                                 if ($subscription->getRegion()) {
  101.                                     if ($subscription->getRegion()->getRegionId() == $alert['regionID']) {
  102.                                         $subscriptionRegion = true;
  103.                                     }
  104.                                 }
  106.                                 // $alertType = $subscription->getIsPublic() ?? false;
  107.                                 $alertType =  false;
  108.                                 if ($subscription->getAlertType()) {
  109.                                     foreach ($subscription->getAlertType() as $alertType) {
  110.                                         if ($alertType->getAlertTypeId() == $alert['alertType']) {
  111.                                             $alertType = true;
  112.                                             break;
  113.                                         }
  114.                                     }
  115.                                 }
  117.                                 // $alertGovernorate = $subscription->getIsPublic() ?? false;
  118.                                 $alertGovernorate =  false;
  119.                                 $alertGovernoratesIds = array_column($alert['governorates'], 'id');
  120.                                 if ($subscription->getGovernorate()) {
  121.                                     foreach ($subscription->getGovernorate() as $governorate) {
  122.                                         if (in_array($governorate->getGovernoteId(), $alertGovernoratesIds)) {
  123.                                             $alertGovernorate = true;
  124.                                             break;
  125.                                         }
  126.                                     }
  127.                                 }
  129.                                 // $phenomena = $subscription->getIsPublic() ?? false;
  132.                                 $phenomena = false;
  133.                                 if ($subscription->getAlertStatus()) {
  134.                                     foreach ($subscription->getAlertStatus() as $subscriptionAlertStatus) {
  135.                                         if ($subscriptionAlertStatus->getAlertStatusId() == $alert['alertStatusID']) {
  136.                                             $phenomena = true;
  137.                                             break;
  138.                                         }
  139.                                     }
  140.                                 }
  142.                                 // // logic for send email to those subscribers whose alert is updated
  143.                                 // $ewsObjectArray = ($subscription) ? $subscription->getMatchedEwsAlerts() : [];
  144.                                 // if ($ewsObjectArray) {
  145.                                 //     // Loop through the alerts
  146.                                 //     foreach ($ewsObjectArray as $ewsAlert) {
  147.                                 //         // Check if the alert ID matches and is updated
  148.                                 //         $currentEwsAlert = $ewsAlert->getObject();
  149.                                 //         $data = $ewsAlert->getData();
  151.                                 //         if ($currentEwsAlert->getId() === $ewsAlert->getId() && $data['isUpdated'] == true) {
  152.                                 //             if (!empty($subscription->getCreator())) {
  153.                                 //                 $users = [];
  154.                                 //                 $owner = $subscription->getCreator();
  155.                                 //                 $subscribers = $subscription->getSubscribers();
  156.                                 //                 // Ensure $owner is an array
  157.                                 //                 $owner = [$owner];
  158.                                 //                 // Merge $owner and $subscribers into $users
  159.                                 //                 $users = array_merge($owner, $subscribers);
  160.                                 //                 // if ($user->getSendEwsEmail() == true || is_null($user->getSendEwsEmail())) {
  161.                                 //                 $email = $this->sendEmailNotification($users, $alert, $this->templating);
  163.                                 //                 // if ($email) {
  164.                                 //                 //     $ewsNotification->setIsEmailSent(true);
  165.                                 //                 //     $ewsNotification->save();
  166.                                 //                 // }
  167.                                 //                 // }
  168.                                 //             }
  169.                                 //             break; // Stop the loop once a match is found
  170.                                 //         }
  171.                                 //     }
  172.                                 // }
  174.                                 // check if all conditions are true then send email
  175.                                 if ($subscriptionRegion && $alertType && $alertGovernorate && $phenomena) {
  176.                                     if (!empty($subscription->getCreator())) {
  177.                                         $users = [];
  178.                                         $owner = $subscription->getCreator();
  179.                                         $subscribers = $subscription->getSubscribers();
  180.                                         // Ensure $owner is an array
  181.                                         $owner = [$owner];
  182.                                         // Merge $owner and $subscribers into $users
  183.                                         $users = array_merge($owner, $subscribers);
  184.                                         foreach ($users as $user) {
  185.                                             if ($user instanceof \Pimcore\Model\DataObject\Customer) {
  186.                                                 if ($user->getSevereWeatherAlert()) {
  187.                                                     $email = $this->sendEmailNotification($user, $alert, null, true, $ewsAlert);
  188.                                                 }
  189.                                             }
  190.                                         }
  191.                                         // // Retrieve existing alerts from the subscription
  192.                                         // $existingAlerts = $subscription->getMatchedEwsAlerts();
  194.                                         // // Assuming $viewNotification has a method getId() to get its unique ID
  195.                                         // $newAlertId = $ewsAlert->getId();
  197.                                         // // Filter out the existing alert with the same ID, if any
  198.                                         // $filteredAlerts = array_filter($existingAlerts, function ($alert) use ($newAlertId) {
  199.                                         //     // Assuming $alert is an ObjectMetadata instance with a method to get the underlying alert ID
  200.                                         //     return $alert->getObject()->getId() !== $newAlertId;
  201.                                         // });
  203.                                         // // Create a new ObjectMetadata instance for the new alert
  204.                                         // $objectMetadata = new DataObject\Data\ObjectMetadata('matchedEwsAlerts', ['isUpdated'], $ewsAlert);
  205.                                         // $objectMetadata->setIsUpdated(false);
  207.                                         // // Add the new ObjectMetadata instance to the filtered alerts array
  208.                                         // $filteredAlerts[] = $objectMetadata;
  210.                                         // // Set the updated array back to the subscription
  211.                                         // $subscription->setMatchedEwsAlerts($filteredAlerts);
  212.                                         // $subscription->save();
  213.                                     }
  214.                                 }
  215.                             }
  216.                         }
  220.                         // if ($userGroupIds) {
  222.                         //     $email = $this->sendExcelEmailNotification($userGroupIds, $alert, $this->templating);
  223.                         // }
  224.                     }
  226.                     $ewsAlert->setIsSent(true);
  227.                     $ewsAlert->save();
  228.                 } catch (\Exception $ex) {
  229.                     p_r($ex->getMessage());
  230.                 }
  231.             }
  232.         }
  234.         return 0;
  235.     }
  237.     private function sendEmailNotification($user, $alert, $email = null, $actualUser, $alertObject)
  238.     {
  239.         $mailSent = null;
  240.         if ($alert) {
  241.             $governatesArr = $alert['governorates'];
  242.             $governates = [];
  243.             if ($governatesArr) {
  244.                 foreach ($governatesArr as $gov) {
  245.                     $governates[] = $gov['nameEn'];
  246.                 }
  247.             }
  249.             $alertHazardsArr = $alert['alertHazards'];
  250.             $alertHazards = [];
  251.             $alertHazards_ar = [];
  252.             if ($alertHazardsArr) {
  253.                 foreach ($alertHazardsArr as $alertHazard) {
  254.                     $alertHazards[] = $alertHazard['descriptionEn'];
  255.                     $alertHazards_ar[] = ['nameAr' => $alertHazard['descriptionAr']];
  256.                 }
  257.             }
  259.             $alertActionsArr = $alert['alertActions'];
  260.             $alertActions = [];
  261.             if ($alertActionsArr) {
  262.                 foreach ($alertActionsArr as $alertAction) {
  263.                     $alertActions[] = $alertAction['descriptionEn'];
  264.                 }
  265.             }
  268.             $data = $alert;
  269.             $data['sender'] = 'National Center for Meteorology';
  270.             // $subject =$alert['searchEwsIdAr'] ??'Severe Weather Alert - ' . $alert['regionEn'];
  271.             $subject = $alert['alertStatusAr'] . ' - ' . $alert['regionAR'];
  273.             if ($user) {
  274.                 $data['name'] = $email ? $user : $user->getName();
  276.                 // extra param js
  277.                 $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  278.                 $alertName = $alertObj->getColor() ? $alertObj->getColor() : '';
  280.                 $alert['user_name'] = $email ? $user : $user->getName();
  281.                 $alert['host'] = API_BASE_URL;
  282.                 $alert['alertColor'] = $alertName;
  285.                 $currentDate = new \DateTime($alert['fromDate']);
  286.                 $searchIdAr = 'النظام Ø§Ù„الي Ù„لإنذار Ø§Ù„مبكر | ' . $currentDate->format('dmY') . '-' . $alert['id'] . ' | ' . $alert['alertTypeAr'] . ' | ' . $alert['alertStatusAr'];
  287.                 $alert['searchEwsIdAr'] = $searchIdAr;
  288.                 $alert['alertHazard'] = $alertHazards_ar;
  289.                 $alert['last_modified_date'] =  $alert['lastModified'];
  291.                 $alert['tokenURL'] = null; // for now this is null but we have to develop unsubscribe functionality for this as well 
  292.                 if ($actualUser) {
  293.                     // general un subscribe function
  294.                     $token = \App\Lib\Utility::getUnSubscribeToken($user->getId());
  295.                     $alert['tokenURL'] = BASE_URL . '/unsubscribe/email?token=' . $token;
  296.                 }
  297.                 $alert['mannedAlertDatailUrl'] = "https://ncm.gov.sa/Ar/alert/Pages/MapDetail.aspx?AlertId=" . $alert['id'];
  298.                 $html = $this->templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  300.                 $mannedAlert = \Pimcore\Model\DataObject\EwsNotification::getByAlertId($alert['id'], true);
  301.                 $purpose = MANNED_ALERT_MESSAGE;
  302.                 if ($email) {
  303.                     $mailSent = $this->c2Service->sendDefaultEmail($_ENV['EWS_MAIL_TEMPLATE'], $mannedAlert->getId(), $email, $html, $subject, $purpose);
  304.                 } else {
  305.                     $mailSent = $this->c2Service->sendNotificationEmail($_ENV['EWS_MAIL_TEMPLATE'], $mannedAlert->getId(), $user->getId(), $html, $subject, $purpose);
  306.                 }
  308.                 if ($user->getPhoneNo() && strlen($user->getPhoneNo()) == 9) {
  309.                     $messageSMS = sprintf(SMS_MESSAGE["MANNED_ALERT"], strtoupper($alertName) . " alert raised in " . $alert['regionAR'] . ' for ' . $alert['alertStatusAr'] . " event");
  310.                     $this->richService->sendSms(SAUDI_CALL_CODE . $user->getPhoneNo(), $messageSMS);
  311.                 }
  313.                 if ($alertObject->getEnableSmsNotification() && $user->getPhoneNo() && strlen($user->getPhoneNo()) == 9) {
  314.                     $smsTemplate = \Pimcore\Model\WebsiteSetting::getByName('MANNED_ALERT', null);
  315.     
  316.                     if ($smsTemplate != null && $smsTemplate->getData() != null) {
  317.                         $messageSMS = sprintf(SMS_MESSAGE["MANNED_ALERT"], strtoupper($alertName) . " alert raised in " . $alert['regionAR'] . ' for ' . $alert['alertStatusAr'] . " event");
  318.     
  319.                         try {
  320.                            
  321.                             $responseSMS = $this->richService->sendMannedAlertNotificationSMS($alertObject, $user, $purpose, $messageSMS);
  322.                             if (!$responseSMS) {
  323.                                 $this->logger->error('Failed to send SMS to ' . SAUDI_CALL_CODE . $user->getPhoneNo());
  324.                             }
  325.                         } catch (\Exception $e) {
  326.                             $this->logger->error('Exception occurred while sending SMS: ' . $e->getMessage());
  327.                         }
  328.                     }
  329.                 }
  330.             }
  331.         }
  333.         return $mailSent;
  334.     }
  336.     private function sendExcelEmailNotification($userGroupIds, $alert, $templating)
  337.     {
  338.         $mailSent = null;
  339.         if ($alert) {
  340.             $governatesArr = $alert['governorates'];
  341.             $governates = [];
  342.             if ($governatesArr) {
  343.                 foreach ($governatesArr as $gov) {
  344.                     $governates[] = $gov['nameEn'];
  345.                 }
  346.             }
  348.             $data = $alert;
  349.             $data['sender'] = 'National Center for Meteorology';
  350.             // $subject = $alert['searchEwsIdAr'] ??'Severe Weather Alert - ' . $gov['nameEn'];
  351.             //$subject = $alert['alertStatusAr'] . ' - ' . $alert['regionAR'];
  352.             // $subject = 'النظام Ø§Ù„الي Ù„لإنذار Ø§Ù„مبكر :' . ' - ' . $alert['searchEwsIdAr'];
  354.             $parts = explode('|', $alert['searchEwsIdAr']);
  355.             $excluded = implode('|', array_slice($parts, 1));
  356.             $subject = 'النظام Ø§Ù„الي Ù„لإنذار Ø§Ù„مبكر :'  . $excluded;
  359.             if ($userGroupIds) {
  361.                 foreach ($userGroupIds as $userGroupId) {
  362.                     if ($userGroupId) {
  364.                         $userGroup = \Pimcore\Model\DataObject\EwsAndReportUserGroup::getById($userGroupId, true);
  365.                         if ($userGroup instanceof \Pimcore\Model\DataObject\EwsAndReportUserGroup) {
  367.                             foreach (json_decode($userGroup->getJsonData()) as $currentUser) {
  369.                                 if (isset($currentUser->firstName) && isset($currentUser->lastName) && isset($currentUser->email)) {
  371.                                     // extra param js
  372.                                     $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  373.                                     $alertName = $alertObj->getColor() ? $alertObj->getColor() : '';
  375.                                     $alert['user_name'] = $currentUser->firstName . ' ' . $currentUser->lastName;
  376.                                     $alert['host'] = API_BASE_URL;
  377.                                     $alert['alertColor'] = $alertName;
  379.                                     $backgroundColor = '#fcb82526';
  380.                                     $borderColor = '#000000';
  381.                                     $textColor = '#000000';
  383.                                     if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  384.                                         $alertColorLower = strtolower(trim($alert['alertColor']));
  386.                                         if ($alertColorLower === 'red') {
  387.                                             $backgroundColor = '#f6000017';
  388.                                             $borderColor = '#F60000';
  389.                                             $textColor = '#F60000';
  390.                                         } elseif ($alertColorLower === 'orange') {
  391.                                             $backgroundColor = '#ff66001f';
  392.                                             $borderColor = '#FF6600';
  393.                                             $textColor = '#FF6600';
  394.                                         } elseif ($alertColorLower === 'yellow') {
  395.                                             $backgroundColor = '#fcb82526';
  396.                                             $borderColor = '#FCB825';
  397.                                             $textColor = '#FCB825';
  398.                                         }
  399.                                     }
  401.                                     $alert['backgroundColor'] = $backgroundColor;
  402.                                     $alert['borderColor'] = $borderColor;
  403.                                     $alert['textColor'] = $textColor;
  404.                                     $alert['tokenURL'] = null;
  405.                                     $alert['mannedAlertDatailUrl'] = null;
  406.                                     $html = $templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  408.                                     // $email = $currentUser->email;
  409.                                     // $param = ['user' => $currentUser, 'message' => $html, 'url' => null];
  410.                                     // $mailSent = $emailService->sendMail($param, "abdul.muqeet@centric.ae", '/email/alert_notification', $subject);
  411.                                     $purpose = EWS_MESSAGE;
  412.                                     $mailSent = $this->c2Service->sendDefaultEmail($_ENV['EWS_MAIL_TEMPLATE'], $alert['id'], $currentUser->email, $html, $subject, $purpose);
  414.                                     if ($mailSent) {
  415.                                         $status = "sent";
  416.                                         $this->saveEmailStatus($currentUser->email, $currentUser->firstName . ' ' . $currentUser->lastName, $alert, $status);
  417.                                     } else {
  418.                                         $status = "not sent";
  419.                                         $this->saveEmailStatus($currentUser->email, $currentUser->firstName . ' ' . $currentUser->lastName, $alert, $status);
  420.                                     }
  421.                                 }
  422.                             }
  423.                         }
  424.                     }
  425.                 }
  426.             }
  427.         }
  429.         return $mailSent;
  430.     }
  432.     private function saveEmailStatus($userEmail, $userName, $alert, $emailStatus)
  433.     {
  435.         // Get all governorates names in string seprated by ,
  436.         $nameEnArray = array_column($alert["governorates"], "nameEn");
  437.         $nameEnString = implode(", ", $nameEnArray);
  439.         $nameArArray = array_column($alert["governorates"], "nameAr");
  440.         $nameArString = implode(", ", $nameArArray);
  442.         $ewsEmailStatus = new FetchSentEwsEmail();
  443.         $ewsEmailStatus->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath("/Other/FetchSentEwsEmail/"));
  444.         $ewsEmailStatus->setKey(\Pimcore\Model\Element\Service::getValidKey($userEmail . "-" . strtotime("now") . "-" . rand(1, 10000), 'object'));
  445.         $ewsEmailStatus->setEwsId($alert['id']);
  446.         $ewsEmailStatus->setUserName($userName);
  447.         $ewsEmailStatus->setEmail($userEmail);
  448.         //$ewsEmailStatus->setLocationName($locationName);
  449.         $ewsEmailStatus->setAlertType($alert['alertTypeEn'], 'en');
  450.         $ewsEmailStatus->setAlertType($alert['alertTypeAr'], 'ar');
  451.         $ewsEmailStatus->setAlertStatus($alert['alertStatusEn'], 'en');
  452.         $ewsEmailStatus->setAlertStatus($alert['alertStatusAr'], 'ar');
  453.         $ewsEmailStatus->setRegionName($alert['regionEn'], 'en');
  454.         $ewsEmailStatus->setRegionName($alert['regionAR'], 'ar');
  455.         $ewsEmailStatus->setGovernorateNames($nameEnString, 'en');
  456.         $ewsEmailStatus->setGovernorateNames($nameArString, 'ar');
  457.         $ewsEmailStatus->setStatus($emailStatus);
  458.         $ewsEmailStatus->setPublished(true);
  459.         $ewsEmailStatus->save();
  461.         return $ewsEmailStatus;
  462.     }
  464.     private function createUpdateAlertNotification($alert, $output)
  465.     {
  466.         // Generate the hash for the current alert data
  467.         $alertHash = md5(json_encode($alert));
  469.         // Retrieve the existing EwsNotification object by alert ID
  470.         $ewsNotification = \Pimcore\Model\DataObject\EwsNotification::getByAlertId($alert['id'], true);
  472.         // Check if the ews alert already exists
  473.         if ($ewsNotification) {
  474.             // Compare the old hash with the new hash
  475.             if ($ewsNotification->getHash() === $alertHash) {
  476.                 // If the hashes match, the alert has not changed; ignore it
  477.                 return null;
  478.             }
  479.         } else {
  480.             // If the alert does not exist, create a new MannedAlertNotification object
  481.             $ewsNotification = new DataObject\EwsNotification();
  482.             $ewsNotification->setKey($alert['id']);
  483.             $date = date('Y-m-d', strtotime($alert['fromDate']));
  484.             $ewsNotification->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/EWSNotification/' . $date));
  485.             $ewsNotification->setGuid(\App\Lib\Utility::getUUID()->toRfc4122());
  486.         }
  488.         $ewsNotification->setIsManned(true);
  489.         // Update the MannedAlertNotification object with the new alert data
  490.         $ewsNotification->setAlertId($alert['id']);
  491.         $ewsNotification->setTitle($alert['title']);
  492.         $ewsNotification->setAlertType($this->getAlertType($alert['alertType'], $alert['alertTypeAr'], $alert['alertTypeEn']));
  494.         $fromDate = \Carbon\Carbon::createFromFormat('m/d/Y h:i:s A', $alert['fromDate']);
  495.         $toDate = \Carbon\Carbon::createFromFormat('m/d/Y h:i:s A', $alert['toDate']);
  496.         $lastModified = \Carbon\Carbon::createFromFormat('m/d/Y h:i:s A', $alert['lastModified']);
  498.         $ewsNotification->setStartDate($fromDate);
  499.         $ewsNotification->setEndDate($toDate);
  500.         $ewsNotification->setLastModifiedDate($lastModified);
  501.         $ewsNotification->setAlertStatusCategory($this->getAlertStatusCategory($alert['alertStatusCategory'])); // need  to fix
  502.         $ewsNotification->setStatus("active");
  503.         $alertStatus = $this->getAlertStatus($alert['alertStatusID'], $alert['alertStatusAr'], $alert['alertStatusEn']);
  504.         if ($alertStatus) {
  505.             $ewsNotification->setAlertStatus($alertStatus);
  506.         }
  508.         $alertHazardArr = [];
  509.         if ($alert['alertHazards']) {
  510.             foreach ($alert['alertHazards'] as $alertHazard) {
  511.                 $alertHazardArr[] = $this->getAlertHazard($alertHazard['id'], $alertHazard['descriptionAr'], $alertHazard['descriptionEn']);
  512.             }
  513.             $ewsNotification->setAlertHazard(array_filter($alertHazardArr));
  514.         }
  516.         $ewsNotification->setRegion($this->getRegion($alert['regionID'], $alert['regionAR'], $alert['regionEn']));
  518.         $alertGovernorateArr = [];
  519.         if ($alert['governorates']) {
  520.             foreach ($alert['governorates'] as $alertGovernorate) {
  521.                 $alertGovernorateArr[] = $this->getGovernorates($alertGovernorate['id'], $alertGovernorate['nameAr'], $alertGovernorate['nameEn'], $alertGovernorate['longitude'], $alertGovernorate['latitude']);
  522.             }
  523.             $ewsNotification->setGovernorate(array_filter($alertGovernorateArr));
  524.         }
  526.         $ewsNotification->setOtherLocation($alert['otherLocationsEn'], 'en');
  527.         $ewsNotification->setOtherLocation($alert['otherLocationsAr'], 'ar');
  529.         if ($alert['otherLocationsAr']) {
  531.             $otherLocation = \Pimcore\Model\DataObject\EwsOtherLocation::getByName($alert['otherLocationsAr'], 'en', true);
  532.             $ewsNotification->setEwsOtherLocations($otherLocation);
  533.         }
  536.         $ewsNotification->settweetID($alert['tweetID']);
  538.         $alertAlertActionArr = [];
  539.         if ($alert['alertActions']) {
  540.             foreach ($alert['alertActions'] as $alertAlertAction) {
  541.                 $alertAlertActionArr[] = $this->getAlertAction($alertAlertAction['id'], $alertAlertAction['descriptionAr'], $alertAlertAction['descriptionEn']);
  542.             }
  543.             $ewsNotification->setAlertAction(array_filter($alertAlertActionArr));
  544.         }
  546.         // Set the hash for the alert
  547.         $ewsNotification->setHash($alertHash);
  548.         $ewsNotification->setRawText(json_encode($alert));
  549.         $ewsNotification->setIsSent(false);
  550.         $ewsNotification->setOmitMandatoryCheck(true);
  551.         // saving here just to get the id
  552.         $ewsNotification->save();
  554.         $currentDate = new \DateTime();
  555.         $formattedDate = $currentDate->format('dmY') . '-' . $ewsNotification->getId();
  556.         $searchIdEn = 'Early Warning System | ' . $formattedDate . ' | ' . ucfirst($ewsNotification->getAlertType()?->getColor()) . ' Alert | ' . $ewsNotification->getAlertStatus()?->getName("en");
  557.         $searchIdAr = $this->translator->trans('Early Warning System', [], null, "ar") . ' | ' . $formattedDate . ' | ' . $this->translator->trans(ucfirst($ewsNotification->getAlertType()?->getColor()) . ' Alert', [], null, "ar") . ' | ' . $ewsNotification->getAlertStatus()?->getName("ar");
  558.         $ewsNotification->setEwsSearchId($searchIdEn, "en");
  559.         $ewsNotification->setEwsSearchId($searchIdAr, "ar");
  561.         // Save the updated MannedAlertNotification object
  563.         $ewsNotification->setPublished(TRUE);
  564.         $ewsNotification->save();
  566.         return $ewsNotification;
  567.     }
  569.     private function getAlertType($id, $nameAr, $nameEn)
  570.     {
  571.         $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($id, true);
  572.         if (!$alertType) {
  573.             $alertType = new \Pimcore\Model\DataObject\AlertType();
  574.             $alertType->setKey($id);
  575.             $alertType->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/AlertType'));
  576.             $alertType->setAlertTypeId($id);
  577.             $alertType->setName($nameAr, "en");
  578.             $alertType->setName($nameEn, "ar");
  579.             $alertType->setPublished(true);
  580.             $alertType->save();
  581.         }
  582.         return $alertType;
  583.     }
  585.     private function getAlertStatusCategory($name)
  586.     {
  587.         $alertStatusCategory = \Pimcore\Model\DataObject\AlertStatusCategory::getByName($name, true);
  588.         if (!$alertStatusCategory) {
  589.             $alertStatusCategory = new \Pimcore\Model\DataObject\AlertStatusCategory();
  590.             $alertStatusCategory->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/AlertStatusCategory'));
  591.             $alertStatusCategory->setKey($name);
  592.             $alertStatusCategory->setName($name);
  593.             $alertStatusCategory->setPublished(true);
  594.             $alertStatusCategory->save();
  595.         }
  596.         return $alertStatusCategory;
  597.     }
  599.     private function getAlertStatus($id, $nameAr, $nameEn)
  600.     {
  601.         $alertStatus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($id, true);
  602.         if (!$alertStatus) {
  603.             $alertStatus = new \Pimcore\Model\DataObject\AlertStatus();
  604.             $alertStatus->setKey($id);
  605.             $alertStatus->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/AlertStatus'));
  606.             $alertStatus->setAlertStatusId($id);
  607.             $alertStatus->setName($nameAr, 'ar');
  608.             $alertStatus->setName($nameEn, 'en');
  609.             $alertStatus->setPublished(true);
  610.             $alertStatus->save();
  611.         }
  612.         return $alertStatus;
  613.     }
  615.     private function getAlertHazard($id, $descriptionAr, $descriptionEn)
  616.     {
  617.         $alertHazard = \Pimcore\Model\DataObject\AlertHazard::getByAlertHazardId($id, true);
  618.         if (!$alertHazard) {
  619.             $alertHazard = new \Pimcore\Model\DataObject\AlertHazard();
  620.             $alertHazard->setKey($id);
  621.             $alertHazard->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/AlertHazard'));
  622.             $alertHazard->setAlertHazardId($id);
  623.             $alertHazard->setName($descriptionAr, "ar");
  624.             $alertHazard->setName($descriptionEn, "en");
  625.             $alertHazard->setPublished(true);
  626.             $alertHazard->save();
  627.         } else {
  628.             $alertHazard->setName($descriptionAr, "ar");
  629.             $alertHazard->setName($descriptionEn, "en");
  630.             $alertHazard->save();
  631.         }
  634.         return $alertHazard;
  635.     }
  637.     private function getRegion($id, $nameAr, $nameEn)
  638.     {
  639.         $region = \Pimcore\Model\DataObject\Region::getByRegionId($id, true);
  640.         if (!$region) {
  641.             $region = new \Pimcore\Model\DataObject\Region();
  642.             $region->setKey($id);
  643.             $region->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/Region'));
  644.             $region->setRegionId($id);
  645.             $region->setName($nameAr, 'ar');
  646.             $region->setName($nameEn, 'en');
  647.             $region->setPublished(true);
  648.             $region->save();
  649.         }
  650.         return $region;
  651.     }
  653.     private function getGovernorates($id, $nameAr, $nameEn, $longitude, $latitude)
  654.     {
  655.         $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($id, true);
  656.         if (!$governorate) {
  657.             $governorate = new \Pimcore\Model\DataObject\Governorate();
  658.             $governorate->setKey($id);
  659.             $governorate->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/Governorate'));
  660.             $governorate->setGovernoteId($id);
  661.             $governorate->setName($nameAr, "ar");
  662.             $governorate->setName($nameEn, "en");
  663.             $governorate->setLongitude($longitude);
  664.             $governorate->setLatitude($latitude);
  665.             $governorate->setPublished(true);
  666.             $governorate->save();
  667.         }
  668.         return $governorate;
  669.     }
  671.     private function getAlertAction($id, $descriptionAr, $descriptionEn)
  672.     {
  673.         $alertAction = \Pimcore\Model\DataObject\AlertAction::getByAlertActionId($id, true);
  674.         if (!$alertAction) {
  675.             $alertAction = new \Pimcore\Model\DataObject\AlertAction();
  676.             $alertAction->setKey($id);
  677.             $alertAction->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/AlertAction'));
  678.             $alertAction->setAlertActionId($id);
  679.             $alertAction->setName($descriptionAr, "ar");
  680.             $alertAction->setName($descriptionEn, "en");
  681.             $alertAction->setPublished(true);
  682.             $alertAction->save();
  683.         }
  684.         return $alertAction;
  685.     }
  686. }