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. empty($ewsNotification->getTwitterId()) &&
  209. empty($ewsNotification->getTwitterLog()) &&
  210. $ewsNotification->getEnableTwitterNotification() == true &&
  211. $ewsNotification->getStatus() != "ended"
  212. ) {
  213. $governates = $ewsNotification->getGovernorate();
  215. $startDate = $ewsNotification->getStartDate()->format('Y-m-d');
  216. $currentDate = Carbon::now();
  217. $targetDate = Carbon::parse($startDate);
  219. $content = '';
  220. $parameters = [];
  221. if (!empty($ewsNotification->getRegion())) {
  222. // $content .= 'Region : '. $ewsNotification->getRegion()->getName('en') ." \n";
  223. $parameters['region'] = $ewsNotification->getRegion()->getName('ar');
  224. }
  226. if (!empty($ewsNotification->getAlertAction())) {
  227. // $content .= 'Alert Action: ';
  228. $alertActions = [];
  229. foreach ($ewsNotification->getAlertAction() as $alertAction) {
  230. $alertActions[] = $alertAction->getName('ar');
  231. //$content .= $alertAction->getName() .' , ';
  232. }
  233. $parameters['alertAction'] = $alertActions;
  234. //$content .= " \n";
  235. }
  237. if (!empty($ewsNotification->getAlertType())) {
  238. $parameters['alertType'] = $ewsNotification->getAlertType()->getName('en');
  239. //$content .= 'Alert Type: ' . $ewsNotification->getAlertType()->getColor() ." \n";
  240. }
  243. if (!empty($ewsNotification->getWeatherPhenomenon())) {
  244. $parameters['weatherPhenomenon'] = $ewsNotification->getWeatherPhenomenon()->getTitle('en');
  245. $parameters['alertStatusAr'] = $ewsNotification->getWeatherPhenomenon()->getTitle('ar');
  246. //$content .= 'Weather Phenomenon: ' . $ewsNotification->getWeatherPhenomenon()->getTitle() ." \n";
  247. }
  250. if (!empty($ewsNotification->getAlertHazard())) {
  251. $alertHazards = [];
  252. //$content .= 'Alert Hazards: ';
  253. foreach ($ewsNotification->getAlertHazard() as $hazard) {
  254. $alertHazards[] = $hazard->getName('ar');
  255. //$content .= $hazard->getName() .' , ';
  256. }
  257. $parameters['alertHazards'] = $alertHazards;
  258. //$content .= " \n";
  259. }
  261. if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  262. //$content .= 'Governorate(s) Affected: ';
  263. $governorates = [];
  264. foreach ($ewsNotification->getGovernorate() as $governorate) {
  265. $governorates[] = $governorate->getName('ar');
  266. //$content .= $governorate->getName() .' , ';
  267. }
  268. $parameters['governorateAffected'] = $governorates;
  269. //$content .= " \n";
  270. }
  272. //$content .= 'Alert Start Date: ' . (!empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  273. //$content .= 'Alert End Date: ' . (!empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown') ." \n";
  274. $parameters['alertStartDate'] = !empty($ewsNotification->getStartDate()) ? $ewsNotification->getStartDate()->format('Y-m-d h:i:sa') : 'Unknown';
  275. $parameters['alertEndDate'] = !empty($ewsNotification->getEndDate()) ? $ewsNotification->getEndDate()->format('Y-m-d h:i:sa') : 'Unknown';
  276. // $content .= 'Posted Today Date: ' . date('Y-m-d h:i:sa') ." \n";
  278. // if (!empty($ewsNotification->getAttachment())) {
  279. // $attachmentFile = API_BASE_URL.'/'.$ewsNotification->getAttachment()->getFullPath();
  280. // $content .= 'Attachment : '. $attachmentFile ." \n";
  281. // }
  282. //$content .= "For further information visit: https://ncm.gov.sa/Ar/alert/Pages/default.aspx \n";
  283. $HashTagcontent = "";
  284. if (!empty($ewsNotification->getRegion())) {
  285. $regionName = $ewsNotification->getRegion()->getName('ar');
  286. $regionName = str_replace(' ', '_', $regionName);
  287. // $HashTagcontent .= "اسم المنطقة: #$regionName\n";
  288. }
  289. if ($ewsNotification->getGovernorate() && !empty($ewsNotification->getGovernorate())) {
  290. // $HashTagcontent .= "المحافظات المتأثرة: ";
  291. foreach ($ewsNotification->getGovernorate() as $governorate) {
  292. $govName = $governorate->getName('ar');
  293. // $HashTagcontent .= "#$govName, ";
  294. }
  295. // $HashTagcontent = rtrim($HashTagcontent, ', ');
  296. // $HashTagcontent .= "\n";
  297. }
  298. // $HashTagcontent .= "#الإنذار_المبكر #طقس_السعودية #المركز_الوطني_للأرصاد";
  299. // $HashTagcontent .= "";
  301. $HashTagcontent = $ewsNotification->getXPost();
  303. $parameters['furtherInformation'] = "https://ncm.gov.sa/Ar/alert/Pages/default.aspx";
  305. // $html = $this->twig->render('image_templates/x-post-template.html.twig', $parameters);
  307. // $this->snappyImage->setOption('enable-local-file-access', true);
  308. // $this->snappyImage->setOption('width', '787');
  309. // $this->snappyImage->setOption('height', '797');
  310. // $this->snappyImage->setOption('format', 'png');
  311. // $image = $this->snappyImage->getOutputFromHtml($html);
  312. // $asset = \App\Lib\Utility::createAsset($image, rand(0, 10000) . '_' . time() . '_custom_weather_report.jpeg', 'EWS Twitter Images');
  313. // $asset_path = PIMCORE_PROJECT_ROOT . '/public/var/assets' . $asset->getPath() . $asset->getFileName();
  314. // $tweet = $this->twitterService->uploadMedia($asset_path, $HashTagcontent);
  316. $xPost = PIMCORE_PROJECT_ROOT . '/public/var/assets' .$ewsNotification->getXAttachment()->getPath() . $ewsNotification->getXAttachment()->getFileName();
  317. $xPostAssets = $ewsNotification->getXAttachment();
  318. $tweet = $this->twitterService->uploadMedia($xPost, $HashTagcontent);
  319. if ($tweet) {
  320. if(isset($tweet['result']->data)){
  322. $tweet_text = $tweet['result']?->data?->text;
  323. preg_match('/https?:\/\/\S+/', $tweet_text, $matches);
  324. $url = $matches[0] ?? null;
  326. // $tweet = $this->twitterService->postTweet('', $media_id);
  327. // $twitterResponse = $this->c2Service->sendTwitterTweetResponse($_ENV['TWITTER_POST_TEMPLATE'], $ewsNotification->getId(), $html, $url);
  328. // $twitterResponse = $this->c2Service->addAsset([$asset],$url);
  329. // $asset->delete();
  331. $twitterResponse = $this->c2Service->addAsset([$xPostAssets],$url);
  332. }
  334. if (!empty($tweet['tweetId'])) {
  335. $ewsNotification->setTwitterId($tweet['tweetId']);
  336. }
  338. $ewsNotification->setTwitterLog($tweet['data']);
  339. $ewsNotification->save();
  342. if ($tweet['httpCode'] === 200 || $tweet['httpCode'] === 201 || $tweet['httpCode'] === 204) {
  344. }
  345. elseif ($tweet['httpCode'] === 403) {
  346. // Forbidden - Duplicate content error
  347. $responseData = json_decode($tweet['data'], true);
  348. $errorMessage = $responseData['detail'];
  349. // echo $errorMessage;
  350. } else {
  351. // echo 'Unexpected HTTP status code: ' . $tweet['httpCode'];
  352. }
  353. }
  355. //$tweet = $this->twitterService->postTweet($content);
  359. // echo 'POST_ID : '.$tweet['tweetId']. ' EWS_ID : '.$ewsNotification->getId(). ' , ';
  360. }
  361. }
  362. }