src/EventSubscriber/TwitterEventListner.php line 200

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use Carbon\Carbon;
  6. use Pimcore\Mail;
  7. use Pimcore\Model\DataObject;
  8. use Pimcore\Event\Model\DataObjectEvent;
  9. use Pimcore\Model\DataObject\EwsNotification;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use App\Service\TwitterService;
  12. use App\C2IntegrationBundle\Service\C2Service;
  13. use Symfony\Component\Templating\EngineInterface;
  14. use Knp\Snappy\Pdf;
  15. use Knp\Snappy\Image;
  17. class TwitterEventListner
  18. {
  20.     private $twitterService;
  21.     private $c2Service;
  23.     public function __construct(private Pdf $snappy, private Image $snappyImage, private EngineInterface $twig)
  24.     {
  25.         $this->twitterService = new TwitterService();
  26.         $this->c2Service = new C2Service();
  27.     }
  29.     public function onObjectCreate(DataObjectEvent $ewsNotificationObject)
  30.     {
  31.         $ewsNotification = $ewsNotificationObject->getObject();
  32.         
  33.         if (
  34.             ($ewsNotification instanceof EwsNotification) &&
  35.             ($ewsNotification->isPublished(true)) &&
  36.             empty($ewsNotification->getTwitterId())  &&
  37.             empty($ewsNotification->getTwitterLog()) &&
  38.             $ewsNotification->getEnableTwitterNotification() == true &&
  39.             $ewsNotification->getStatus() != "ended"
  40.         ) {
  42.             $governates = $ewsNotification->getGovernorate();
  44.             $startDate = $ewsNotification->getStartDate()->format('Y-m-d');
  45.             $currentDate = Carbon::now();
  46.             $targetDate = Carbon::parse($startDate);
  48.             $content = '';
  49.             $parameters = [];
  50.             if (!empty($ewsNotification->getRegion())) {
  51.                 // $content .= 'Region : '. $ewsNotification->getRegion()->getName('en')  ." \n";
  52.                 $parameters['region'] = $ewsNotification->getRegion()->getName('ar');
  53.             }
  55.             if (!empty($ewsNotification->getAlertAction())) {
  56.                 $alertActions = [];
  57.                 //$content .= 'Alert Action: ';
  58.                 foreach ($ewsNotification->getAlertAction() as $alertAction) {
  59.                     // $content .= $alertAction->getName() .' , ';
  60.                     $alertActions[] = $alertAction->getName('ar');
  61.                 }
  63.                 // $content .= " \n";
  64.                 $parameters['alertAction'] = $alertActions;
  65.             }
  67.             if (!empty($ewsNotification->getAlertType())) {
  68.                 $parameters['alertType'] = $ewsNotification->getAlertType()->getName('en');
  69.                 
  70.                 // $content .= 'Alert Type: ' . $ewsNotification->getAlertType()->getName() ." \n";
  71.             }
  74.             if (!empty($ewsNotification->getWeatherPhenomenon())) {
  75.                 $parameters['weatherPhenomenon'] = $ewsNotification->getWeatherPhenomenon()->getTitle('en');
  76.                 // $parameters['alertStatusAr'] = $ewsNotification->getWeatherPhenomenon()->getTitle('ar');
  77.                 $parameters['alertStatusAr'] = '';
  78.                 //$content .= 'Weather Phenomenon: ' . $ewsNotification->getWeatherPhenomenon()->getTitle() ." \n";
  79.             }
  81.             
  82.             if (!empty($ewsNotification->getAlertHazard())) {
  83.                 $alertHazards = [];
  84.                 //$content .= 'Alert Hazards: ';
  85.                 foreach ($ewsNotification->getAlertHazard() as $hazard) {
  86.                     //$content .= $hazard->getName() .' , ';
  87.                     $alertHazards[] = $hazard->getName('ar');
  88.                 }
  89.                 $parameters['alertHazards'] = $alertHazards;
  91.                 //$content .= " \n";
  92.             }
  94.             if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  95.                 $governorates = [];
  96.                 //$content .= 'Governorate(s) Affected: ';
  97.                 foreach ($ewsNotification->getGovernorate() as $governorate) {
  98.                     $governorates[] = $governorate->getName('ar');
  99.                     //$content .= $governorate->getName() .' , ';
  100.                 }
  101.                 $parameters['governorateAffected'] = $governorates;
  102.                 //$content .= " \n";
  103.             }
  105.             //$content .= 'Alert Start Date: ' . (!empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  106.             //$content .= 'Alert End Date: ' . (!empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  107.             $parameters['alertStartDate'] = !empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown';
  108.             $parameters['alertEndDate'] = !empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown';
  110.             // $content .= 'Posted Today Date: ' . date('Y-m-d h:i:sa') ." \n";
  112.             // if (!empty($ewsNotification->getAttachment())) {
  113.             //     $attachmentFile = API_BASE_URL.'/'.$ewsNotification->getAttachment()->getFullPath();
  114.             //     $content .= 'Attachment : '. $attachmentFile ." \n";
  115.             // }
  116.             $HashTagcontent = "";
  117.             if (!empty($ewsNotification->getRegion())) {
  118.                 $regionName = $ewsNotification->getRegion()->getName('ar');
  119.                 $regionName = str_replace(' ', '_', $regionName);
  120.                 // $HashTagcontent .= "اسم المنطقة: #$regionName\n";
  121.             }
  122.             if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  123.                 // $HashTagcontent .= "المحافظات المتأثرة: ";
  124.                 foreach ($ewsNotification->getGovernorate() as $governorate) {
  125.                     $govName = $governorate->getName('ar');
  126.                     // $HashTagcontent .= "#$govName, ";
  127.                 }
  128.                 // $HashTagcontent = rtrim($HashTagcontent, ', ');
  129.                 // $HashTagcontent .= "\n";
  130.             }
  131.             // $HashTagcontent .= "#الإنذار_المبكر #طقس_السعودية #المركز_الوطني_للأرصاد";
  132.             // $HashTagcontent .= "";
  133.             
  134.             $HashTagcontent = $this->buildXPostCaption($ewsNotification);
  135.             
  136.             $parameters['furtherInformation'] = 'https://beta.ncm.gov.sa/en/early-warning/' . $ewsNotification->getId();
  137.             // $content .= "For further information visit: https://beta.ncm.gov.sa/en/early-warning/" . $ewsNotification->getId() . " \n";
  138.             
  139.             // $html = $this->twig->render('image_templates/x-post-template.html.twig', $parameters);
  140.             // $this->snappyImage->setOption('enable-local-file-access', true);
  141.             // $this->snappyImage->setOption('width', '787');
  142.             // $this->snappyImage->setOption('height', '797');
  143.             // $this->snappyImage->setOption('format', 'png');
  144.             // $image = $this->snappyImage->getOutputFromHtml($html);
  145.             // $asset = \App\Lib\Utility::createAsset($image, rand(0, 10000) . '_' . time() . '_custom_weather_report.jpeg', 'EWS Twitter Images');
  146.             // $asset_path = PIMCORE_PROJECT_ROOT . '/public/var/assets' . $asset->getPath() . $asset->getFileName();
  147.             // $tweet = $this->twitterService->uploadMedia($asset_path,$HashTagcontent);
  149.             $xPostMedia = $this->getXPostMedia($ewsNotification);
  150.             $tweet = $this->twitterService->uploadMedia($xPostMedia['paths'], $HashTagcontent);
  152.             if ($tweet) {
  153.                 // $tweet = $this->twitterService->postTweet('', $media_id);
  154.                 // $twitterResponse = $this->c2Service->sendTwitterTweetResponse($_ENV['TWITTER_POST_TEMPLATE'], $ewsNotification->getId(), $html);
  155.                 if(isset($tweet['result']->data)){
  157.                     $tweet_text = $tweet['result']?->data?->text;
  158.                     preg_match('/https?:\/\/\S+/', $tweet_text, $matches);
  159.                     $url = $matches[0] ?? null;
  160.                     $twitterResponse = $this->c2Service->addAsset($xPostMedia['assets'], $url);
  161.                 }
  162.               
  163.                 // $tweet = $this->twitterService->postTweet('', $media_id);
  164.                 // $twitterResponse = $this->c2Service->sendTwitterTweetResponse($_ENV['TWITTER_POST_TEMPLATE'], $ewsNotification->getId(), $html, $url);
  167.                 // $asset->delete();
  170.                 if (!empty($tweet['tweetId'])) {
  171.                     $ewsNotification->setTwitterId($tweet['tweetId']);
  172.                 }
  173.     
  174.                 $ewsNotification->setTwitterLog($tweet['data']);
  175.                 $ewsNotification->save();
  176.     
  177.                 
  178.                 if ($tweet['httpCode'] === 200 || $tweet['httpCode'] === 201 || $tweet['httpCode'] === 204) {
  179.                     
  180.                 }
  181.                 elseif ($tweet['httpCode'] === 403) {
  182.                     // Forbidden - Duplicate content error
  183.                     $responseData = json_decode($tweet['data'], true);
  184.                     $errorMessage = $responseData['detail'];
  185.                     // echo $errorMessage;
  186.                 } else {
  187.                     // echo 'Unexpected HTTP status code: ' . $tweet['httpCode'];
  188.                 }
  190.             }
  191.             // $tweet = $this->twitterService->postTweet($content);
  192.             
  193.             
  195.             // echo 'POST_ID : '.$tweet['tweetId']. ' EWS_ID : '.$ewsNotification->getId(). ' , ';        
  196.         }
  197.     }
  200.     public function onObjectUpdate(DataObjectEvent $ewsNotificationObject)
  201.     {
  202.         $ewsNotification = $ewsNotificationObject->getObject();
  204.         if (
  205.             ($ewsNotification instanceof EwsNotification) &&
  206.         ($ewsNotification->isPublished(true)) &&
  207.         empty($ewsNotification->getTwitterId())  &&
  208.             empty($ewsNotification->getTwitterLog()) &&
  209.             $ewsNotification->getEnableTwitterNotification() == true &&
  210.             $ewsNotification->getStatus() != "ended"
  211.         ) {
  212.             $governates = $ewsNotification->getGovernorate();
  214.             $startDate = $ewsNotification->getStartDate()->format('Y-m-d');
  215.             $currentDate = Carbon::now();
  216.             $targetDate = Carbon::parse($startDate);
  218.             $content = '';
  219.             $parameters = [];
  220.             if (!empty($ewsNotification->getRegion())) {
  221.                // $content .= 'Region : '. $ewsNotification->getRegion()->getName('en')  ." \n";
  222.                 $parameters['region'] = $ewsNotification->getRegion()->getName('ar');
  223.             }
  225.             if (!empty($ewsNotification->getAlertAction())) {
  226.                // $content .= 'Alert Action: ';
  227.                 $alertActions = [];
  228.                 foreach ($ewsNotification->getAlertAction() as $alertAction) {
  229.                     $alertActions[] = $alertAction->getName('ar');
  230.                     //$content .= $alertAction->getName() .' , ';
  231.                 }
  232.                 $parameters['alertAction'] = $alertActions;
  233.                 //$content .= " \n";
  234.             }
  236.             if (!empty($ewsNotification->getAlertType())) {
  237.                 $parameters['alertType'] = $ewsNotification->getAlertType()->getName('en');
  238.                 //$content .= 'Alert Type: ' . $ewsNotification->getAlertType()->getColor() ." \n";
  239.             }
  242.             if (!empty($ewsNotification->getWeatherPhenomenon())) {
  243.                 $parameters['weatherPhenomenon'] = $ewsNotification->getWeatherPhenomenon()->getTitle('en');
  244.                 $parameters['alertStatusAr'] = $ewsNotification->getWeatherPhenomenon()->getTitle('ar');
  245.                 //$content .= 'Weather Phenomenon: ' . $ewsNotification->getWeatherPhenomenon()->getTitle() ." \n";
  246.             }
  248.             
  249.             if (!empty($ewsNotification->getAlertHazard())) {
  250.                 $alertHazards = [];
  251.                 //$content .= 'Alert Hazards: ';
  252.                 foreach ($ewsNotification->getAlertHazard() as $hazard) {
  253.                     $alertHazards[] = $hazard->getName('ar');
  254.                     //$content .= $hazard->getName() .' , ';
  255.                 }
  256.                 $parameters['alertHazards'] = $alertHazards;
  257.                 //$content .= " \n";
  258.             }
  260.             if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  261.                 //$content .= 'Governorate(s) Affected: ';
  262.                 $governorates = [];
  263.                 foreach ($ewsNotification->getGovernorate() as $governorate) {
  264.                     $governorates[] = $governorate->getName('ar');
  265.                     //$content .= $governorate->getName() .' , ';
  266.                 }
  267.                 $parameters['governorateAffected'] = $governorates;
  268.                 //$content .= " \n";
  269.             }
  271.             //$content .= 'Alert Start  Date: ' . (!empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  272.             //$content .= 'Alert End Date: ' . (!empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  273.             $parameters['alertStartDate'] = !empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown';
  274.             $parameters['alertEndDate'] = !empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown';
  275.             // $content .= 'Posted Today Date: ' . date('Y-m-d h:i:sa') ." \n";
  277.             // if (!empty($ewsNotification->getAttachment())) {
  278.             //     $attachmentFile = API_BASE_URL.'/'.$ewsNotification->getAttachment()->getFullPath();
  279.             //     $content .= 'Attachment : '. $attachmentFile ." \n";
  280.             // }
  281.             //$content .= "For further information visit: https://beta.ncm.gov.sa/en/early-warning/" . $ewsNotification->getId() . " \n";
  282.             $HashTagcontent = "";
  283.             if (!empty($ewsNotification->getRegion())) {
  284.                 $regionName = $ewsNotification->getRegion()->getName('ar');
  285.                 $regionName = str_replace(' ', '_', $regionName);
  286.                 // $HashTagcontent .= "اسم المنطقة: #$regionName\n";
  287.             }
  288.             if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  289.                 // $HashTagcontent .= "المحافظات المتأثرة: ";
  290.                 foreach ($ewsNotification->getGovernorate() as $governorate) {
  291.                     $govName = $governorate->getName('ar');
  292.                     // $HashTagcontent .= "#$govName, ";
  293.                 }
  294.                 // $HashTagcontent = rtrim($HashTagcontent, ', ');
  295.                 // $HashTagcontent .= "\n";
  296.             }
  297.             // $HashTagcontent .= "#الإنذار_المبكر #طقس_السعودية #المركز_الوطني_للأرصاد";
  298.             // $HashTagcontent .= "";
  300.             $HashTagcontent = $this->buildXPostCaption($ewsNotification);
  302.             $parameters['furtherInformation'] = 'https://beta.ncm.gov.sa/en/early-warning/' . $ewsNotification->getId();
  304.             // $html = $this->twig->render('image_templates/x-post-template.html.twig', $parameters);
  305.             
  306.             // $this->snappyImage->setOption('enable-local-file-access', true);
  307.             // $this->snappyImage->setOption('width', '787');
  308.             // $this->snappyImage->setOption('height', '797');
  309.             // $this->snappyImage->setOption('format', 'png');
  310.             // $image = $this->snappyImage->getOutputFromHtml($html);
  311.             // $asset = \App\Lib\Utility::createAsset($image, rand(0, 10000) . '_' . time() . '_custom_weather_report.jpeg', 'EWS Twitter Images');
  312.             // $asset_path = PIMCORE_PROJECT_ROOT . '/public/var/assets' . $asset->getPath() . $asset->getFileName();
  313.             // $tweet = $this->twitterService->uploadMedia($asset_path, $HashTagcontent);
  315.             $xPostMedia = $this->getXPostMedia($ewsNotification);
  316.             $tweet = $this->twitterService->uploadMedia($xPostMedia['paths'], $HashTagcontent);
  317.             if ($tweet) {
  318.                 if(isset($tweet['result']->data)){
  320.                     $tweet_text = $tweet['result']?->data?->text;
  321.                     preg_match('/https?:\/\/\S+/', $tweet_text, $matches);
  322.                     $url = $matches[0] ?? null;
  324.                     // $tweet = $this->twitterService->postTweet('', $media_id);
  325.                     // $twitterResponse = $this->c2Service->sendTwitterTweetResponse($_ENV['TWITTER_POST_TEMPLATE'], $ewsNotification->getId(), $html, $url);
  326.                     // $twitterResponse = $this->c2Service->addAsset([$asset],$url);
  327.                     // $asset->delete();
  329.                     $twitterResponse = $this->c2Service->addAsset($xPostMedia['assets'], $url);
  330.                 }
  332.                 if (!empty($tweet['tweetId'])) {
  333.                     $ewsNotification->setTwitterId($tweet['tweetId']);
  334.                 }
  336.                 $ewsNotification->setTwitterLog($tweet['data']);
  337.                 $ewsNotification->save();
  340.                 if ($tweet['httpCode'] === 200 || $tweet['httpCode'] === 201 || $tweet['httpCode'] === 204) {
  342.                 }
  343.                 elseif ($tweet['httpCode'] === 403) {
  344.                     // Forbidden - Duplicate content error
  345.                     $responseData = json_decode($tweet['data'], true);
  346.                     $errorMessage = $responseData['detail'];
  347.                     // echo $errorMessage;
  348.                 } else {
  349.                     // echo 'Unexpected HTTP status code: ' . $tweet['httpCode'];
  350.                 }
  351.             }
  353.             //$tweet = $this->twitterService->postTweet($content);
  355.             
  357.             // echo 'POST_ID : '.$tweet['tweetId']. ' EWS_ID : '.$ewsNotification->getId(). ' , ';
  358.         }
  359.     }
  361.     private function getXPostMedia(EwsNotification $ewsNotification): array
  362.     {
  363.         $paths = [];
  364.         $assets = [];
  365.         $assetRoot = PIMCORE_PROJECT_ROOT . '/public/var/assets';
  367.         foreach ([
  368.             $ewsNotification->getXAttachment(),
  369.             $ewsNotification->getPolygonXAtachment(),
  370.             //$ewsNotification->getXHistoryAtachment(),
  371.         ] as $asset) {
  372.             if ($asset) {
  373.                 $paths[] = $assetRoot . $asset->getPath() . $asset->getFileName();
  374.                 $assets[] = $asset;
  375.             }
  376.         }
  378.         return ['paths' => $paths, 'assets' => $assets];
  379.     }
  381.     /**
  382.      * Replace old NCM alert page URLs in the X caption with the public portal early-warning link.
  383.      */
  384.     private function buildXPostCaption(EwsNotification $ewsNotification): string
  385.     {
  386.         $caption = (string) $ewsNotification->getXPost();
  387.         $earlyWarningUrl = 'https://beta.ncm.gov.sa/en/early-warning/' . $ewsNotification->getId();
  389.         $replaced = preg_replace(
  390.             '#https?://(?:www\.)?ncm\.gov\.sa/[Aa]r/alert/[Pp]ages\S*#u',
  391.             $earlyWarningUrl,
  392.             $caption
  393.         );
  395.         return is_string($replaced) ? $replaced : $caption;
  396.     }
  397. }