src/EventSubscriber/TwitterEventListner.php line 29

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.         ) {
  41.             $governates = $ewsNotification->getGovernorate();
  43.             $startDate = $ewsNotification->getStartDate()->format('Y-m-d');
  44.             $currentDate = Carbon::now();
  45.             $targetDate = Carbon::parse($startDate);
  47.             $content = '';
  48.             $parameters = [];
  49.             if (!empty($ewsNotification->getRegion())) {
  50.                 // $content .= 'Region : '. $ewsNotification->getRegion()->getName('en')  ." \n";
  51.                 $parameters['region'] = $ewsNotification->getRegion()->getName('ar');
  52.             }
  54.             if (!empty($ewsNotification->getAlertAction())) {
  55.                 $alertActions = [];
  56.                 //$content .= 'Alert Action: ';
  57.                 foreach ($ewsNotification->getAlertAction() as $alertAction) {
  58.                     // $content .= $alertAction->getName() .' , ';
  59.                     $alertActions[] = $alertAction->getName('ar');
  60.                 }
  62.                 // $content .= " \n";
  63.                 $parameters['alertAction'] = $alertActions;
  64.             }
  66.             if (!empty($ewsNotification->getAlertType())) {
  67.                 $parameters['alertType'] = $ewsNotification->getAlertType()->getName('en');
  68.                 
  69.                 // $content .= 'Alert Type: ' . $ewsNotification->getAlertType()->getName() ." \n";
  70.             }
  73.             if (!empty($ewsNotification->getWeatherPhenomenon())) {
  74.                 $parameters['weatherPhenomenon'] = $ewsNotification->getWeatherPhenomenon()->getTitle('en');
  75.                 // $parameters['alertStatusAr'] = $ewsNotification->getWeatherPhenomenon()->getTitle('ar');
  76.                 $parameters['alertStatusAr'] = '';
  77.                 //$content .= 'Weather Phenomenon: ' . $ewsNotification->getWeatherPhenomenon()->getTitle() ." \n";
  78.             }
  80.             
  81.             if (!empty($ewsNotification->getAlertHazard())) {
  82.                 $alertHazards = [];
  83.                 //$content .= 'Alert Hazards: ';
  84.                 foreach ($ewsNotification->getAlertHazard() as $hazard) {
  85.                     //$content .= $hazard->getName() .' , ';
  86.                     $alertHazards[] = $hazard->getName('ar');
  87.                 }
  88.                 $parameters['alertHazards'] = $alertHazards;
  90.                 //$content .= " \n";
  91.             }
  93.             if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  94.                 $governorates = [];
  95.                 //$content .= 'Governorate(s) Affected: ';
  96.                 foreach ($ewsNotification->getGovernorate() as $governorate) {
  97.                     $governorates[] = $governorate->getName('ar');
  98.                     //$content .= $governorate->getName() .' , ';
  99.                 }
  100.                 $parameters['governorateAffected'] = $governorates;
  101.                 //$content .= " \n";
  102.             }
  104.             //$content .= 'Alert Start Date: ' . (!empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  105.             //$content .= 'Alert End Date: ' . (!empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  106.             $parameters['alertStartDate'] = !empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown';
  107.             $parameters['alertEndDate'] = !empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown';
  109.             // $content .= 'Posted Today Date: ' . date('Y-m-d h:i:sa') ." \n";
  111.             // if (!empty($ewsNotification->getAttachment())) {
  112.             //     $attachmentFile = API_BASE_URL.'/'.$ewsNotification->getAttachment()->getFullPath();
  113.             //     $content .= 'Attachment : '. $attachmentFile ." \n";
  114.             // }
  115.             $HashTagcontent = "";
  116.             if (!empty($ewsNotification->getRegion())) {
  117.                 $regionName = $ewsNotification->getRegion()->getName('ar');
  118.                 $regionName = str_replace(' ', '_', $regionName);
  119.                 // $HashTagcontent .= "اسم المنطقة: #$regionName\n";
  120.             }
  121.             if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  122.                 // $HashTagcontent .= "المحافظات المتأثرة: ";
  123.                 foreach ($ewsNotification->getGovernorate() as $governorate) {
  124.                     $govName = $governorate->getName('ar');
  125.                     // $HashTagcontent .= "#$govName, ";
  126.                 }
  127.                 // $HashTagcontent = rtrim($HashTagcontent, ', ');
  128.                 // $HashTagcontent .= "\n";
  129.             }
  130.             // $HashTagcontent .= "#الإنذار_المبكر #طقس_السعودية #المركز_الوطني_للأرصاد";
  131.             // $HashTagcontent .= "";
  132.             
  133.             $HashTagcontent = $ewsNotification->getXPost();
  134.             
  135.             $parameters['furtherInformation'] = "https://ncm.gov.sa/Ar/alert/Pages/default.aspx";
  136.             // $content .= "For further information visit: https://ncm.gov.sa/Ar/alert/Pages/default.aspx \n";
  137.             
  138.             // $html = $this->twig->render('image_templates/x-post-template.html.twig', $parameters);
  139.             // $this->snappyImage->setOption('enable-local-file-access', true);
  140.             // $this->snappyImage->setOption('width', '787');
  141.             // $this->snappyImage->setOption('height', '797');
  142.             // $this->snappyImage->setOption('format', 'png');
  143.             // $image = $this->snappyImage->getOutputFromHtml($html);
  144.             // $asset = \App\Lib\Utility::createAsset($image, rand(0, 10000) . '_' . time() . '_custom_weather_report.jpeg', 'EWS Twitter Images');
  145.             // $asset_path = PIMCORE_PROJECT_ROOT . '/public/var/assets' . $asset->getPath() . $asset->getFileName();
  146.             // $tweet = $this->twitterService->uploadMedia($asset_path,$HashTagcontent);
  148.             $xPost = PIMCORE_PROJECT_ROOT . '/public/var/assets' .$ewsNotification->getXAttachment()->getPath() . $ewsNotification->getXAttachment()->getFileName();
  149.             $xPostAssets = $ewsNotification->getXAttachment();
  150.             $tweet = $this->twitterService->uploadMedia($xPost,$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([$xPostAssets],$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.             $ewsNotification->getEnableTwitterNotification() == true
  208.         ) {
  209.             $governates = $ewsNotification->getGovernorate();
  211.             $startDate = $ewsNotification->getStartDate()->format('Y-m-d');
  212.             $currentDate = Carbon::now();
  213.             $targetDate = Carbon::parse($startDate);
  215.             $content = '';
  216.             $parameters = [];
  217.             if (!empty($ewsNotification->getRegion())) {
  218.                // $content .= 'Region : '. $ewsNotification->getRegion()->getName('en')  ." \n";
  219.                 $parameters['region'] = $ewsNotification->getRegion()->getName('ar');
  220.             }
  222.             if (!empty($ewsNotification->getAlertAction())) {
  223.                // $content .= 'Alert Action: ';
  224.                 $alertActions = [];
  225.                 foreach ($ewsNotification->getAlertAction() as $alertAction) {
  226.                     $alertActions[] = $alertAction->getName('ar');
  227.                     //$content .= $alertAction->getName() .' , ';
  228.                 }
  229.                 $parameters['alertAction'] = $alertActions;
  230.                 //$content .= " \n";
  231.             }
  233.             if (!empty($ewsNotification->getAlertType())) {
  234.                 $parameters['alertType'] = $ewsNotification->getAlertType()->getName('en');
  235.                 //$content .= 'Alert Type: ' . $ewsNotification->getAlertType()->getColor() ." \n";
  236.             }
  239.             if (!empty($ewsNotification->getWeatherPhenomenon())) {
  240.                 $parameters['weatherPhenomenon'] = $ewsNotification->getWeatherPhenomenon()->getTitle('en');
  241.                 $parameters['alertStatusAr'] = $ewsNotification->getWeatherPhenomenon()->getTitle('ar');
  242.                 //$content .= 'Weather Phenomenon: ' . $ewsNotification->getWeatherPhenomenon()->getTitle() ." \n";
  243.             }
  245.             
  246.             if (!empty($ewsNotification->getAlertHazard())) {
  247.                 $alertHazards = [];
  248.                 //$content .= 'Alert Hazards: ';
  249.                 foreach ($ewsNotification->getAlertHazard() as $hazard) {
  250.                     $alertHazards[] = $hazard->getName('ar');
  251.                     //$content .= $hazard->getName() .' , ';
  252.                 }
  253.                 $parameters['alertHazards'] = $alertHazards;
  254.                 //$content .= " \n";
  255.             }
  257.             if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  258.                 //$content .= 'Governorate(s) Affected: ';
  259.                 $governorates = [];
  260.                 foreach ($ewsNotification->getGovernorate() as $governorate) {
  261.                     $governorates[] = $governorate->getName('ar');
  262.                     //$content .= $governorate->getName() .' , ';
  263.                 }
  264.                 $parameters['governorateAffected'] = $governorates;
  265.                 //$content .= " \n";
  266.             }
  268.             //$content .= 'Alert Start  Date: ' . (!empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  269.             //$content .= 'Alert End Date: ' . (!empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  270.             $parameters['alertStartDate'] = !empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown';
  271.             $parameters['alertEndDate'] = !empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown';
  272.             // $content .= 'Posted Today Date: ' . date('Y-m-d h:i:sa') ." \n";
  274.             // if (!empty($ewsNotification->getAttachment())) {
  275.             //     $attachmentFile = API_BASE_URL.'/'.$ewsNotification->getAttachment()->getFullPath();
  276.             //     $content .= 'Attachment : '. $attachmentFile ." \n";
  277.             // }
  278.             //$content .= "For further information visit: https://ncm.gov.sa/Ar/alert/Pages/default.aspx \n";
  279.             $HashTagcontent = "";
  280.             if (!empty($ewsNotification->getRegion())) {
  281.                 $regionName = $ewsNotification->getRegion()->getName('ar');
  282.                 $regionName = str_replace(' ', '_', $regionName);
  283.                 // $HashTagcontent .= "اسم المنطقة: #$regionName\n";
  284.             }
  285.             if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  286.                 // $HashTagcontent .= "المحافظات المتأثرة: ";
  287.                 foreach ($ewsNotification->getGovernorate() as $governorate) {
  288.                     $govName = $governorate->getName('ar');
  289.                     // $HashTagcontent .= "#$govName, ";
  290.                 }
  291.                 // $HashTagcontent = rtrim($HashTagcontent, ', ');
  292.                 // $HashTagcontent .= "\n";
  293.             }
  294.             // $HashTagcontent .= "#الإنذار_المبكر #طقس_السعودية #المركز_الوطني_للأرصاد";
  295.             // $HashTagcontent .= "";
  297.             $HashTagcontent = $ewsNotification->getXPost();
  299.             $parameters['furtherInformation'] = "https://ncm.gov.sa/Ar/alert/Pages/default.aspx";
  301.             // $html = $this->twig->render('image_templates/x-post-template.html.twig', $parameters);
  302.             
  303.             // $this->snappyImage->setOption('enable-local-file-access', true);
  304.             // $this->snappyImage->setOption('width', '787');
  305.             // $this->snappyImage->setOption('height', '797');
  306.             // $this->snappyImage->setOption('format', 'png');
  307.             // $image = $this->snappyImage->getOutputFromHtml($html);
  308.             // $asset = \App\Lib\Utility::createAsset($image, rand(0, 10000) . '_' . time() . '_custom_weather_report.jpeg', 'EWS Twitter Images');
  309.             // $asset_path = PIMCORE_PROJECT_ROOT . '/public/var/assets' . $asset->getPath() . $asset->getFileName();
  310.             // $tweet = $this->twitterService->uploadMedia($asset_path, $HashTagcontent);
  312.             $xPost = PIMCORE_PROJECT_ROOT . '/public/var/assets' .$ewsNotification->getXAttachment()->getPath() . $ewsNotification->getXAttachment()->getFileName();
  313.             $xPostAssets = $ewsNotification->getXAttachment();
  314.             $tweet = $this->twitterService->uploadMedia($xPost, $HashTagcontent);
  315.             if ($tweet) {
  316.                 if(isset($tweet['result']->data)){
  318.                     $tweet_text = $tweet['result']?->data?->text;
  319.                     preg_match('/https?:\/\/\S+/', $tweet_text, $matches);
  320.                     $url = $matches[0] ?? null;
  321.                   
  322.                     // $tweet = $this->twitterService->postTweet('', $media_id);
  323.                     // $twitterResponse = $this->c2Service->sendTwitterTweetResponse($_ENV['TWITTER_POST_TEMPLATE'], $ewsNotification->getId(), $html, $url);
  324.                     // $twitterResponse = $this->c2Service->addAsset([$asset],$url);
  325.                     // $asset->delete();
  326.               
  327.                     $twitterResponse = $this->c2Service->addAsset([$xPostAssets],$url);
  328.                 }
  330.                 if (!empty($tweet['tweetId'])) {
  331.                     $ewsNotification->setTwitterId($tweet['tweetId']);
  332.                 }
  333.     
  334.                 $ewsNotification->setTwitterLog($tweet['data']);
  335.                 $ewsNotification->save();
  336.     
  337.                 
  338.                 if ($tweet['httpCode'] === 200 || $tweet['httpCode'] === 201 || $tweet['httpCode'] === 204) {
  339.                     
  340.                 }
  341.                 elseif ($tweet['httpCode'] === 403) {
  342.                     // Forbidden - Duplicate content error
  343.                     $responseData = json_decode($tweet['data'], true);
  344.                     $errorMessage = $responseData['detail'];
  345.                     // echo $errorMessage;
  346.                 } else {
  347.                     // echo 'Unexpected HTTP status code: ' . $tweet['httpCode'];
  348.                 }
  349.             }
  351.             //$tweet = $this->twitterService->postTweet($content);
  353.             
  355.             // echo 'POST_ID : '.$tweet['tweetId']. ' EWS_ID : '.$ewsNotification->getId(). ' , ';
  356.         }
  357.     }
  358. }