src/Command/SendMannedAlertsCommand.php line 210

Open in your IDE?
  1. <?php
  3. namespace App\Command;
  5. use App\Model\UserModel;
  6. use Datetime;
  7. use Pimcore\Db;
  8. use GuzzleHttp\Client;
  9. use Pimcore\Log\Simple;
  10. use App\Service\RedisCache;
  11. use App\Model\LocationModel;
  12. use GuzzleHttp\Psr7\Request;
  13. use App\Service\EmailService;
  14. use Pimcore\Model\DataObject;
  15. use App\Model\EwsNotificationModel;
  16. use App\Service\NCMWeatherAPIService;
  17. use App\Service\MeteomaticsWeatherService;
  18. use Symfony\Component\Console\Command\Command;
  19. use Symfony\Component\Templating\EngineInterface;
  20. use Symfony\Component\Console\Input\InputArgument;
  21. use Symfony\Component\Console\Input\InputInterface;
  22. use Symfony\Component\Console\Output\OutputInterface;
  23. use App\C2IntegrationBundle\Service\C2Service;
  24. use App\Service\RichService;
  25. use Symfony\Contracts\HttpClient\HttpClientInterface;
  26. class SendMannedAlertsCommand extends Command
  27. {
  28. protected static $defaultName = 'app:get-manned-alerts';
  29. const HOURS = 24;
  30. var $emailService = null;
  31. private $templating;
  32. private $nCMWeatherAPIService;
  33. private $redisCache;
  34. private $locationModel;
  35. private $userModel;
  36. private $ewsNotificationModel;
  37. private $c2Service;
  38. private $richService;
  39. private $httpClient;
  41. public function __construct(EngineInterface $templating, RedisCache $redisCache, RichService $richService, HttpClientInterface $httpClient)
  42. {
  43. parent::__construct();
  45. $this->templating = $templating;
  46. $this->nCMWeatherAPIService = new NCMWeatherAPIService($redisCache,$httpClient);
  47. $this->redisCache = $redisCache;
  48. $this->locationModel = new LocationModel();
  49. $this->userModel = new UserModel();
  50. $this->ewsNotificationModel = new EwsNotificationModel();
  51. $this->c2Service = new C2Service();
  52. $this->richService = $richService;
  53. }
  55. protected function configure()
  56. {
  57. $this->setDescription('Retrieve manned alerts by location');
  58. }
  60. protected function execute(InputInterface $input, OutputInterface $output)
  61. { date_default_timezone_set(TIMEZONE);
  62. $this->emailService = new EmailService();
  63. $mateoMaticsService = new MeteomaticsWeatherService($this->redisCache);
  65. $db = DB::get();
  66. $localities = [];
  67. $loopCount = 5;
  69. $distincLocalities = $db->fetchAll("SELECT GROUP_CONCAT(DISTINCT addressValue) as localities FROM `object_collection_AddressComponents_location` WHERE `addressKey` = 'locality'");
  71. if ($distincLocalities) {
  72. $localities = explode(",", $distincLocalities[0]['localities']);
  73. }
  75. // Fetching alerts
  76. $alerts = $this->nCMWeatherAPIService->getAlerts();
  77. if ($alerts) {
  79. foreach ($alerts as $alert) {
  80. try {
  81. // Create update alert
  82. $mannedAlert = $this->createUpdateAlertNotification($alert, $output);
  84. if (!$mannedAlert) {
  85. $output->writeln('Nothing updated on notification = ' . $alert['id']);
  86. continue;
  87. }
  88. if ($_ENV['SEND_EMAIL_NOTIFICATION'] == "false") {
  89. $output->writeln('Email is not allowed on this environment');
  90. continue;
  91. }
  93. if (!$mannedAlert->getIsSent()) {
  95. $mannedAlertSubscription = new DataObject\MannedAlertSubscription\Listing();
  96. $mannedAlertSubscription->setOrderKey("o_creationDate");
  97. $mannedAlertSubscription->setOrder("desc");
  98. foreach ($mannedAlertSubscription as $subscription) {
  100. if ($subscription->getIsPublic() == false) {
  101. # code...
  102. // $subscriptionRegion = $subscription->getIsPublic() ?? false;
  103. $subscriptionRegion = false;
  104. if ($subscription->getRegion()) {
  105. if ($subscription->getRegion()->getRegionId() == $alert['regionID']) {
  106. $subscriptionRegion = true;
  107. }
  108. }
  110. // $alertType = $subscription->getIsPublic() ?? false;
  111. $alertType = false;
  112. if ($subscription->getAlertType()) {
  113. foreach ($subscription->getAlertType() as $alertType) {
  114. if ($alertType->getAlertTypeId() == $alert['alertType']) {
  115. $alertType = true;
  116. break;
  117. }
  118. }
  119. }
  121. // $alertGovernorate = $subscription->getIsPublic() ?? false;
  122. $alertGovernorate = false;
  123. $alertGovernoratesIds = array_column($alert['governorates'], 'id');
  124. if ($subscription->getGovernorate()) {
  125. foreach ($subscription->getGovernorate() as $governorate) {
  126. if (in_array($governorate->getGovernoteId(), $alertGovernoratesIds)) {
  127. $alertGovernorate = true;
  128. break;
  129. }
  130. }
  131. }
  133. // $phenomena = $subscription->getIsPublic() ?? false;
  134. $phenomena = false;
  135. $phenomenaIds = array_column($alert['alertHazards'], 'id');
  136. if ($subscription->getPhenomena()) {
  137. foreach ($subscription->getPhenomena() as $phenomenas) {
  138. if (in_array($phenomenas->getPhenomenaListId(), $phenomenaIds)) {
  139. $phenomena = true;
  140. break;
  141. }
  142. }
  143. }
  146. if ($subscriptionRegion && $alertType && $alertGovernorate && $phenomena) {
  147. // if (!empty($subscription->getEmail())) {
  148. // $user_name = explode('@', $subscription->getEmail());
  149. // $email = $this->sendEmailNotification($user_name[0], $alert, $subscription->getEmail(), $actualUser = false);
  151. // // continue;
  152. // }
  153. if (!empty($subscription->getCreator())) {
  154. $user = $subscription->getCreator();
  156. $entityUserSubscription = $this->userModel->getEntitySubscription($user);
  157. $packageExpired = $entityUserSubscription ? (new \DateTime() > $entityUserSubscription->getEndDate() ? true : false) : false;
  158. $subActive = $entityUserSubscription ? $entityUserSubscription->getIsActive() : false;
  159. $nonSubUser = $subActive && !$packageExpired;
  161. if ($user->getSevereWeatherAlert() && $nonSubUser) {
  162. $email = $this->sendEmailNotification($user, $alert, null , true);
  163. }
  164. }
  165. }
  166. }
  168. }
  170. // if (in_array($alert['regionEn'], $localities)) {
  172. // // SELECT olqre.name as region,olqge.name as governate,olqwfc.name as municipality FROM object_region ore LEFT JOIN object_governorate ogo ON ore.oo_id = ogo.regionId__id LEFT JOIN object_weather_forecasting_city owfc ON owfc.MappedGovernorateId__id = ogo.oo_id LEFT JOIN object_localized_query_region_en olqre ON ore.oo_id = olqre.ooo_id LEFT JOIN object_localized_query_governorate_en olqge ON ogo.oo_id = olqge.ooo_id LEFT JOIN object_localized_query_weather_forecasting_city_en olqwfc ON owfc.oo_id = olqwfc.ooo_id
  173. // // Fetching user fall in found localities
  174. // $selectedLocalities = $this->ewsNotificationModel->getEwsNotificationByByRegionName($alert['regionEn']);
  175. // if ($selectedLocalities) {
  177. // $totalIterations = count($selectedLocalities);
  178. // $iterations = 0;
  179. // foreach ($selectedLocalities as $locality) {
  180. // $locality = \Pimcore\Model\DataObject::getById($locality['o_id']);
  181. // $users = $locality->getUser();
  183. // // $email = $this->sendEmailNotification($users, $alert);
  185. // // Increment the iteration count
  186. // $iterations++;
  188. // // Check if 5 iterations have passed
  189. // if ($iterations % $loopCount === 0 && $iterations !== $totalIterations) {
  190. // // If 5 iterations have passed and it's not the last iteration, sleep for 65 seconds
  191. // sleep(65);
  192. // }
  193. // }
  194. // }
  195. // }
  197. }
  199. $mannedAlert->setIsSent(true);
  200. $mannedAlert->save();
  201. } catch (\Exception $ex) {
  202. p_r($ex->getMessage());
  203. }
  204. }
  205. }
  207. return 0;
  208. }
  210. private function sendEmailNotification($users, $alert, $email = null, $actualUser)
  211. {
  212. $mailSent = null;
  213. if ($alert) {
  214. $governatesArr = $alert['governorates'];
  215. $governates = [];
  216. if ($governatesArr) {
  217. foreach ($governatesArr as $gov) {
  218. $governates[] = $gov['nameEn'];
  219. }
  220. }
  222. $alertHazardsArr = $alert['alertHazards'];
  223. $alertHazards = [];
  224. $alertHazards_ar = [];
  225. if ($alertHazardsArr) {
  226. foreach ($alertHazardsArr as $alertHazard) {
  227. $alertHazards[] = $alertHazard['descriptionEn'];
  228. $alertHazards_ar[] = ['nameAr' =>$alertHazard['descriptionAr']];
  229. }
  230. }
  232. $alertActionsArr = $alert['alertActions'];
  233. $alertActions = [];
  234. if ($alertActionsArr) {
  235. foreach ($alertActionsArr as $alertAction) {
  236. $alertActions[] = $alertAction['descriptionEn'];
  237. }
  238. }
  241. $data = $alert;
  242. $data['sender'] = 'National Center for Meteorology';
  243. // $subject =$alert['searchEwsIdAr'] ??'Severe Weather Alert - ' . $alert['regionEn'];
  244. $subject = $alert['alertStatusAr'] . ' - ' . $alert['regionAR'];
  247. //sending an email document (pimcore document)
  248. $emailAlertTemplate = '/email/alert_notification';
  250. if ($users) {
  251. $data['name'] = $email ? $users : $users->getName();
  253. // extra param js
  254. $alertObj = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($alert['alertType'], true);
  255. $alertName = $alertObj->getColor() ? $alertObj->getColor() : '';
  257. $alert['user_name'] = $email ? $users : $users->getName();
  258. $alert['host'] = API_BASE_URL;
  259. $alert['alertColor'] = $alertName;
  261. $backgroundColor = '#fcb82526';
  262. $borderColor = '#000000';
  263. $textColor = '#000000';
  265. if (isset($alert['alertColor']) && !empty(trim($alert['alertColor']))) {
  266. $alertColorLower = strtolower(trim($alert['alertColor']));
  268. if ($alertColorLower === 'red') {
  269. $backgroundColor = '#f6000017';
  270. $borderColor = '#F60000';
  271. $textColor = '#F60000';
  272. } elseif ($alertColorLower === 'orange') {
  273. $backgroundColor = '#ff66001f';
  274. $borderColor = '#FF6600';
  275. $textColor = '#FF6600';
  276. } elseif ($alertColorLower === 'yellow') {
  277. $backgroundColor = '#fcb82526';
  278. $borderColor = '#FCB825';
  279. $textColor = '#FCB825';
  280. }
  281. }
  283. $alert['backgroundColor'] = $backgroundColor;
  284. $alert['borderColor'] = $borderColor;
  285. $alert['textColor'] = $textColor;
  287. $currentDate = new \DateTime($alert['fromDate']);
  288. $searchIdAr= 'النظام الالي للإنذار المبكر | '.$currentDate->format('dmY').'-'.$alert['id'].' | '.$alert['alertTypeAr'].' | '.$alert['alertStatusAr'];
  289. $alert['searchEwsIdAr'] = $searchIdAr;
  290. $alert['alertHazard'] = $alertHazards_ar;
  291. $alert['last_modified_date'] = $alert['lastModified'];
  294. $alert['tokenURL'] = null; // for now this is null but we have to develop unsubscribe functionality for this as well
  295. if ($actualUser) {
  296. // general un subscribe function
  297. $token = \App\Lib\Utility::getUnSubscribeToken($users->getId());
  298. $alert['tokenURL'] = BASE_URL . '/unsubscribe/email?token=' . $token;
  299. }
  305. $alert['mannedAlertDatailUrl'] = "https://ncm.gov.sa/Ar/alert/Pages/MapDetail.aspx?AlertId=".$alert['id'];
  306. $html = $this->templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  308. $mannedAlert = \Pimcore\Model\DataObject\MannedAlertNotification::getByAlertId($alert['id'], true);
  309. $purpose = MANNED_ALERT_MESSAGE;
  310. if ($email) {
  311. $mailSent = $this->c2Service->sendDefaultEmail($_ENV['EWS_MAIL_TEMPLATE'], $mannedAlert->getId(), $email, $html, $subject, $purpose);
  312. } else {
  313. $mailSent = $this->c2Service->sendNotificationEmail($_ENV['EWS_MAIL_TEMPLATE'], $mannedAlert->getId(), $users->getId(), $html, $subject, $purpose);
  314. }
  316. if ($users->getPhoneNo() && strlen($users->getPhoneNo()) == 9) {
  317. $messageSMS = sprintf(SMS_MESSAGE["MANNED_ALERT"], strtoupper($alertName) . " alert raised in " . $alert['regionAR'] . ' for ' . $alert['alertStatusAr'] . " event");
  318. $this->richService->sendSms(SAUDI_CALL_CODE.$users->getPhoneNo(), $messageSMS);
  319. }
  322. // $html = $this->templating->render('web2print/_manned_alert_notification_ar.html.twig', $alert);
  323. // $response['message_en'] = $html;
  325. // $email = $users->getEmail();
  326. // $param = ['user' => $users, 'message' => $html, 'url' => null];
  327. // $mailSent = $this->emailService->sendMail($param, $email, $emailAlertTemplate, $subject);
  328. }
  330. // if ($users) {
  331. // foreach ($users as $user) {
  332. // $data['name'] = $user->getName();
  333. // $html = $this->templating->render('web2print/_manned_alert_notification_ar.html.twig', $data);
  334. // $currentUser = $user->getObject();
  335. // $data = $user->getData();
  336. // if (isset($data['get_severe_alert']) && $data['get_severe_alert']) {
  337. // $email = $currentUser->getEmail();
  338. // $param = ['user' => $currentUser, 'message' => $html, 'url' => null];
  339. // $mailSent = $this->emailService->sendMail($param, $email, $emailAlertTemplate, $subject);
  340. // }
  341. // }
  342. // }
  343. }
  345. return $mailSent;
  346. }
  348. private function createUpdateAlertNotification($alert, $output)
  349. {
  350. // Generate the hash for the current alert data
  351. $alertHash = md5(json_encode($alert));
  353. // Retrieve the existing MannedAlertNotification object by alert ID
  354. $mannedAlert = \Pimcore\Model\DataObject\MannedAlertNotification::getByAlertId($alert['id'], true);
  356. // Check if the alert already exists
  357. if ($mannedAlert) {
  358. // Compare the old hash with the new hash
  359. if ($mannedAlert->getHash() === $alertHash) {
  360. // If the hashes match, the alert has not changed; ignore it
  361. return null;
  362. }
  363. } else {
  364. // If the alert does not exist, create a new MannedAlertNotification object
  365. $mannedAlert = new DataObject\MannedAlertNotification();
  366. $mannedAlert->setKey($alert['id']);
  367. $date = date('Y-m-d', strtotime($alert['fromDate']));
  368. $mannedAlert->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/Notification/' . $date));
  369. $mannedAlert->setPublished(TRUE);
  370. }
  372. // Update the MannedAlertNotification object with the new alert data
  373. $mannedAlert->setAlertId($alert['id']);
  374. $mannedAlert->setTitle($alert['title']);
  375. $mannedAlert->setAlertType($this->getAlertType($alert['alertType'], $alert['alertTypeAr'], $alert['alertTypeEn']));
  377. $fromDate = \Carbon\Carbon::createFromFormat('m/d/Y h:i:s A', $alert['fromDate']);
  378. $toDate = \Carbon\Carbon::createFromFormat('m/d/Y h:i:s A', $alert['toDate']);
  379. $lastModified = \Carbon\Carbon::createFromFormat('m/d/Y h:i:s A', $alert['lastModified']);
  381. $mannedAlert->setFromDate($fromDate);
  382. $mannedAlert->setToDate($toDate);
  383. $mannedAlert->setLastModifiedDate($lastModified);
  384. $mannedAlert->setAlertStatusCategory($this->getAlertStatusCategory($alert['alertStatusCategory']));
  385. $mannedAlert->setAlertStatus($this->getAlertStatus($alert['alertStatusID'], $alert['alertStatusAr'], $alert['alertStatusEn']));
  387. $alertHazardArr = [];
  388. if ($alert['alertHazards']) {
  389. foreach ($alert['alertHazards'] as $alertHazard) {
  390. $alertHazardArr[] = $this->getAlertHazard($alertHazard['id'], $alertHazard['descriptionAr'], $alertHazard['descriptionEn']);
  391. }
  392. $mannedAlert->setAlertHazards(array_filter($alertHazardArr));
  393. }
  395. $mannedAlert->setRegion($this->getRegion($alert['regionID'], $alert['regionAR'], $alert['regionEn']));
  397. $alertGovernorateArr = [];
  398. if ($alert['governorates']) {
  399. foreach ($alert['governorates'] as $alertGovernorate) {
  400. $alertGovernorateArr[] = $this->getGovernorates($alertGovernorate['id'], $alertGovernorate['nameAr'], $alertGovernorate['nameEn'], $alertGovernorate['longitude'], $alertGovernorate['latitude']);
  401. }
  402. $mannedAlert->setGovernorates(array_filter($alertGovernorateArr));
  403. }
  405. $mannedAlert->setOtherLocation($alert['otherLocationsEn'], 'en');
  406. $mannedAlert->setOtherLocation($alert['otherLocationsAr'], 'ar');
  407. $mannedAlert->settweetID($alert['tweetID']);
  409. $alertAlertActionArr = [];
  410. if ($alert['alertActions']) {
  411. foreach ($alert['alertActions'] as $alertAlertAction) {
  412. $alertAlertActionArr[] = $this->getAlertAction($alertAlertAction['id'], $alertAlertAction['descriptionAr'], $alertAlertAction['descriptionEn']);
  413. }
  414. $mannedAlert->setAlertAction(array_filter($alertAlertActionArr));
  415. }
  417. // Set the hash for the alert
  418. $mannedAlert->setHash($alertHash);
  419. $mannedAlert->setRawText(json_encode($alert));
  420. $mannedAlert->setIsSent(false);
  422. // Save the updated MannedAlertNotification object
  423. $mannedAlert->save();
  425. return $mannedAlert;
  426. }
  428. private function getAlertType($id, $nameAr, $nameEn)
  429. {
  430. $alertType = \Pimcore\Model\DataObject\AlertType::getByAlertTypeId($id, true);
  431. if (!$alertType) {
  432. $alertType = new \Pimcore\Model\DataObject\AlertType();
  433. $alertType->setKey($id);
  434. $alertType->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/AlertType'));
  435. $alertType->setAlertTypeId($id);
  436. $alertType->setName($nameAr, "en");
  437. $alertType->setName($nameEn, "ar");
  438. $alertType->setPublished(true);
  439. $alertType->save();
  440. }
  441. return $alertType;
  442. }
  444. private function getAlertStatusCategory($name)
  445. {
  446. $alertStatusCategory = \Pimcore\Model\DataObject\AlertStatusCategory::getByName($name, true);
  447. if (!$alertStatusCategory) {
  448. $alertStatusCategory = new \Pimcore\Model\DataObject\AlertStatusCategory();
  449. $alertStatusCategory->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/AlertStatusCategory'));
  450. $alertStatusCategory->setKey($name);
  451. $alertStatusCategory->setName($name);
  452. $alertStatusCategory->setPublished(true);
  453. $alertStatusCategory->save();
  454. }
  455. return $alertStatusCategory;
  456. }
  458. private function getAlertStatus($id, $nameAr, $nameEn)
  459. {
  460. $alertStatus = \Pimcore\Model\DataObject\AlertStatus::getByAlertStatusId($id, true);
  461. if (!$alertStatus) {
  462. $alertStatus = new \Pimcore\Model\DataObject\AlertStatus();
  463. $alertStatus->setKey($id);
  464. $alertStatus->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/AlertStatus'));
  465. $alertStatus->setAlertStatusId($id);
  466. $alertStatus->setName($nameAr, 'ar');
  467. $alertStatus->setName($nameEn, 'en');
  468. $alertStatus->setPublished(true);
  469. $alertStatus->save();
  470. }
  471. return $alertStatus;
  472. }
  474. private function getAlertHazard($id, $descriptionAr, $descriptionEn)
  475. {
  476. $alertHazard = \Pimcore\Model\DataObject\AlertHazard::getByAlertHazardId($id, true);
  477. if (!$alertHazard) {
  478. $alertHazard = new \Pimcore\Model\DataObject\AlertHazard();
  479. $alertHazard->setKey($id);
  480. $alertHazard->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/AlertHazard'));
  481. $alertHazard->setAlertHazardId($id);
  482. $alertHazard->setName($descriptionAr, "ar");
  483. $alertHazard->setName($descriptionEn, "en");
  484. $alertHazard->setPublished(true);
  485. $alertHazard->save();
  486. } else {
  487. $alertHazard->setName($descriptionAr, "ar");
  488. $alertHazard->setName($descriptionEn, "en");
  489. $alertHazard->save();
  490. }
  493. return $alertHazard;
  494. }
  496. private function getRegion($id, $nameAr, $nameEn)
  497. {
  498. $region = \Pimcore\Model\DataObject\Region::getByRegionId($id, true);
  499. if (!$region) {
  500. $region = new \Pimcore\Model\DataObject\Region();
  501. $region->setKey($id);
  502. $region->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/Region'));
  503. $region->setRegionId($id);
  504. $region->setName($nameAr, 'ar');
  505. $region->setName($nameEn, 'en');
  506. $region->setPublished(true);
  507. $region->save();
  508. }
  509. return $region;
  510. }
  512. private function getGovernorates($id, $nameAr, $nameEn, $longitude, $latitude)
  513. {
  514. $governorate = \Pimcore\Model\DataObject\Governorate::getByGovernoteId($id, true);
  515. if (!$governorate) {
  516. $governorate = new \Pimcore\Model\DataObject\Governorate();
  517. $governorate->setKey($id);
  518. $governorate->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/Governorate'));
  519. $governorate->setGovernoteId($id);
  520. $governorate->setName($nameAr, "ar");
  521. $governorate->setName($nameEn, "en");
  522. $governorate->setLongitude($longitude);
  523. $governorate->setLatitude($latitude);
  524. $governorate->setPublished(true);
  525. $governorate->save();
  526. }
  527. return $governorate;
  528. }
  530. private function getAlertAction($id, $descriptionAr, $descriptionEn)
  531. {
  532. $alertAction = \Pimcore\Model\DataObject\AlertAction::getByAlertActionId($id, true);
  533. if (!$alertAction) {
  534. $alertAction = new \Pimcore\Model\DataObject\AlertAction();
  535. $alertAction->setKey($id);
  536. $alertAction->setParent(\Pimcore\Model\DataObject\Service::createFolderByPath('/MannedAlert/Master/AlertAction'));
  537. $alertAction->setAlertActionId($id);
  538. $alertAction->setName($descriptionAr, "ar");
  539. $alertAction->setName($descriptionEn, "en");
  540. $alertAction->setPublished(true);
  541. $alertAction->save();
  542. }
  543. return $alertAction;
  544. }
  545. }