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);
  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");
  319. try {
  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. }