src/EventSubscriber/TwitterEventListner.php line 201

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();
  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');
  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. }
  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 .= "";
  134. $HashTagcontent = $ewsNotification->getXPost();
  136. $parameters['furtherInformation'] = "https://ncm.gov.sa/Ar/alert/Pages/default.aspx";
  137. // $content .= "For further information visit: https://ncm.gov.sa/Ar/alert/Pages/default.aspx \n";
  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. $xPost = PIMCORE_PROJECT_ROOT . '/public/var/assets' .$ewsNotification->getXAttachment()->getPath() . $ewsNotification->getXAttachment()->getFileName();
  150. $xPostAssets = $ewsNotification->getXAttachment();
  151. $tweet = $this->twitterService->uploadMedia($xPost,$HashTagcontent);
  153. if ($tweet) {
  154. // $tweet = $this->twitterService->postTweet('', $media_id);
  155. // $twitterResponse = $this->c2Service->sendTwitterTweetResponse($_ENV['TWITTER_POST_TEMPLATE'], $ewsNotification->getId(), $html);
  156. if(isset($tweet['result']->data)){
  158. $tweet_text = $tweet['result']?->data?->text;
  159. preg_match('/https?:\/\/\S+/', $tweet_text, $matches);
  160. $url = $matches[0] ?? null;
  161. $twitterResponse = $this->c2Service->addAsset([$xPostAssets],$url);
  162. }
  164. // $tweet = $this->twitterService->postTweet('', $media_id);
  165. // $twitterResponse = $this->c2Service->sendTwitterTweetResponse($_ENV['TWITTER_POST_TEMPLATE'], $ewsNotification->getId(), $html, $url);
  168. // $asset->delete();
  171. if (!empty($tweet['tweetId'])) {
  172. $ewsNotification->setTwitterId($tweet['tweetId']);
  173. }
  175. $ewsNotification->setTwitterLog($tweet['data']);
  176. $ewsNotification->save();
  179. if ($tweet['httpCode'] === 200 || $tweet['httpCode'] === 201 || $tweet['httpCode'] === 204) {
  181. }
  182. elseif ($tweet['httpCode'] === 403) {
  183. // Forbidden - Duplicate content error
  184. $responseData = json_decode($tweet['data'], true);
  185. $errorMessage = $responseData['detail'];
  186. // echo $errorMessage;
  187. } else {
  188. // echo 'Unexpected HTTP status code: ' . $tweet['httpCode'];
  189. }
  191. }
  192. // $tweet = $this->twitterService->postTweet($content);
  196. // echo 'POST_ID : '.$tweet['tweetId']. ' EWS_ID : '.$ewsNotification->getId(). ' , ';
  197. }
  198. }
  201. public function onObjectUpdate(DataObjectEvent $ewsNotificationObject)
  202. {
  203. $ewsNotification = $ewsNotificationObject->getObject();
  205. if (
  206. ($ewsNotification instanceof EwsNotification) &&
  207. ($ewsNotification->isPublished(true)) &&
  208. $ewsNotification->getEnableTwitterNotification() == true &&
  209. $ewsNotification->getStatus() != "ended"
  210. ) {
  211. $governates = $ewsNotification->getGovernorate();
  213. $startDate = $ewsNotification->getStartDate()->format('Y-m-d');
  214. $currentDate = Carbon::now();
  215. $targetDate = Carbon::parse($startDate);
  217. $content = '';
  218. $parameters = [];
  219. if (!empty($ewsNotification->getRegion())) {
  220. // $content .= 'Region : '. $ewsNotification->getRegion()->getName('en') ." \n";
  221. $parameters['region'] = $ewsNotification->getRegion()->getName('ar');
  222. }
  224. if (!empty($ewsNotification->getAlertAction())) {
  225. // $content .= 'Alert Action: ';
  226. $alertActions = [];
  227. foreach ($ewsNotification->getAlertAction() as $alertAction) {
  228. $alertActions[] = $alertAction->getName('ar');
  229. //$content .= $alertAction->getName() .' , ';
  230. }
  231. $parameters['alertAction'] = $alertActions;
  232. //$content .= " \n";
  233. }
  235. if (!empty($ewsNotification->getAlertType())) {
  236. $parameters['alertType'] = $ewsNotification->getAlertType()->getName('en');
  237. //$content .= 'Alert Type: ' . $ewsNotification->getAlertType()->getColor() ." \n";
  238. }
  241. if (!empty($ewsNotification->getWeatherPhenomenon())) {
  242. $parameters['weatherPhenomenon'] = $ewsNotification->getWeatherPhenomenon()->getTitle('en');
  243. $parameters['alertStatusAr'] = $ewsNotification->getWeatherPhenomenon()->getTitle('ar');
  244. //$content .= 'Weather Phenomenon: ' . $ewsNotification->getWeatherPhenomenon()->getTitle() ." \n";
  245. }
  248. if (!empty($ewsNotification->getAlertHazard())) {
  249. $alertHazards = [];
  250. //$content .= 'Alert Hazards: ';
  251. foreach ($ewsNotification->getAlertHazard() as $hazard) {
  252. $alertHazards[] = $hazard->getName('ar');
  253. //$content .= $hazard->getName() .' , ';
  254. }
  255. $parameters['alertHazards'] = $alertHazards;
  256. //$content .= " \n";
  257. }
  259. if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  260. //$content .= 'Governorate(s) Affected: ';
  261. $governorates = [];
  262. foreach ($ewsNotification->getGovernorate() as $governorate) {
  263. $governorates[] = $governorate->getName('ar');
  264. //$content .= $governorate->getName() .' , ';
  265. }
  266. $parameters['governorateAffected'] = $governorates;
  267. //$content .= " \n";
  268. }
  270. //$content .= 'Alert Start Date: ' . (!empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  271. //$content .= 'Alert End Date: ' . (!empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  272. $parameters['alertStartDate'] = !empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown';
  273. $parameters['alertEndDate'] = !empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown';
  274. // $content .= 'Posted Today Date: ' . date('Y-m-d h:i:sa') ." \n";
  276. // if (!empty($ewsNotification->getAttachment())) {
  277. // $attachmentFile = API_BASE_URL.'/'.$ewsNotification->getAttachment()->getFullPath();
  278. // $content .= 'Attachment : '. $attachmentFile ." \n";
  279. // }
  280. //$content .= "For further information visit: https://ncm.gov.sa/Ar/alert/Pages/default.aspx \n";
  281. $HashTagcontent = "";
  282. if (!empty($ewsNotification->getRegion())) {
  283. $regionName = $ewsNotification->getRegion()->getName('ar');
  284. $regionName = str_replace(' ', '_', $regionName);
  285. // $HashTagcontent .= "اسم المنطقة: #$regionName\n";
  286. }
  287. if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  288. // $HashTagcontent .= "المحافظات المتأثرة: ";
  289. foreach ($ewsNotification->getGovernorate() as $governorate) {
  290. $govName = $governorate->getName('ar');
  291. // $HashTagcontent .= "#$govName, ";
  292. }
  293. // $HashTagcontent = rtrim($HashTagcontent, ', ');
  294. // $HashTagcontent .= "\n";
  295. }
  296. // $HashTagcontent .= "#الإنذار_المبكر #طقس_السعودية #المركز_الوطني_للأرصاد";
  297. // $HashTagcontent .= "";
  299. $HashTagcontent = $ewsNotification->getXPost();
  301. $parameters['furtherInformation'] = "https://ncm.gov.sa/Ar/alert/Pages/default.aspx";
  303. // $html = $this->twig->render('image_templates/x-post-template.html.twig', $parameters);
  305. // $this->snappyImage->setOption('enable-local-file-access', true);
  306. // $this->snappyImage->setOption('width', '787');
  307. // $this->snappyImage->setOption('height', '797');
  308. // $this->snappyImage->setOption('format', 'png');
  309. // $image = $this->snappyImage->getOutputFromHtml($html);
  310. // $asset = \App\Lib\Utility::createAsset($image, rand(0, 10000) . '_' . time() . '_custom_weather_report.jpeg', 'EWS Twitter Images');
  311. // $asset_path = PIMCORE_PROJECT_ROOT . '/public/var/assets' . $asset->getPath() . $asset->getFileName();
  312. // $tweet = $this->twitterService->uploadMedia($asset_path, $HashTagcontent);
  314. $xPost = PIMCORE_PROJECT_ROOT . '/public/var/assets' .$ewsNotification->getXAttachment()->getPath() . $ewsNotification->getXAttachment()->getFileName();
  315. $xPostAssets = $ewsNotification->getXAttachment();
  316. $tweet = $this->twitterService->uploadMedia($xPost, $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([$xPostAssets],$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);
  357. // echo 'POST_ID : '.$tweet['tweetId']. ' EWS_ID : '.$ewsNotification->getId(). ' , ';
  358. }
  359. }
  360. }