src/EventSubscriber/ReportEventListener.php line 27

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  4. use Pimcore\Db;
  5. use Pimcore\Mail;
  6. use Knp\Snappy\Pdf;
  7. use Knp\Snappy\Image;
  8. use Pimcore\Model\Asset;
  9. use App\Service\EmailService;
  10. use App\Service\TwitterService;
  11. use App\Service\NotificationService;
  12. use Pimcore\Model\DataObject\Report;
  13. use Pimcore\Model\DataObject\Customer;
  14. use Pimcore\Event\Model\DataObjectEvent;
  15. use Symfony\Component\Templating\EngineInterface;
  16. use App\C2IntegrationBundle\Service\C2Service;
  17. use Symfony\Contracts\Translation\TranslatorInterface;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class ReportEventListener
  20. {
  21.     private $c2Service;
  23.     public function __construct(protected NotificationService $notificationService, private EmailService $emailService, private Pdf $snappy, private TwitterService $twitterService, private Image $snappyImage, private EngineInterface $twig)
  24.     {
  25.         $this->c2Service = new C2Service();
  26.     }
  27.     public function onObjectPublish(DataObjectEvent $event)
  28.     {
  29.         $object = $event->getObject();
  30.         $tokens = [];
  32.         if (($object instanceof Report) && ($object->isPublished(true)) && ($object->getIsMannedReport() !== true)) {
  33.             $reportType = $object->getReportType()?->getName() ?? 'Historical Report';
  34.             $organizations = $object->getOrganization();
  35.             if ($organizations) {
  36.                 foreach ($organizations as $organization) {
  37.                     $users = Customer::getByOrganization($organization);
  38.                     foreach ($users as $user) {
  39.                         if ($user?->getDeviceToken()) {
  40.                             $tokens[] = $user->getDeviceToken();
  41.                         }
  42.                     }
  43.                 }
  44.             } else {
  45.                 $db = Db::get();
  46.                 $select = $db->createQueryBuilder();
  47.                 $select->select('customer.deviceToken');
  48.                 $select->from('object_query_customer', 'customer');
  49.                 $select->innerJoin('customer', 'object_query_user_role', 'userRole', 'userRole.oo_id = customer.role__id');
  50.                 $select->andWhere("userRole.name = " . $db->quote(USER_ROLES['CLIENT_ADMIN']) . " OR userRole.name = " . $db->quote(USER_ROLES['CLIENT_USER']));
  51.                 $select->andWhere("customer.deviceToken != " . $db->quote(null));
  52.                 $result = $db->fetchAllAssociative($select);
  53.                 $deviceTokens = array_column($result, 'deviceToken');
  54.                 foreach ($deviceTokens as $user) {
  55.                     $tokens[] = $user;
  56.                 }
  57.             }
  58.             if (!empty($tokens)) {
  59.                 $this->notificationService->sendNotification('Report', 'NCM Has published ' . $reportType, $tokens);
  60.             }
  61.             if ($reportType != 'Historical Report') {
  64.                 // $fileName = '_custom_weather_report.pdf';
  65.                 // $reportPath = '/report/ReportPdf';
  67.                 // if ($object->getReportType()?->getKey() == 'MannForecastReport') {
  68.                 //     $template =  'pdf/report_pdf_template.html.twig';
  69.                 // }elseif ($object->getReportType()?->getKey() == 'advance-custom-weather-report') {
  71.                 //     $template = 'pdf/advance_custom_report_pdf_template.html.twig';
  72.                 //     $fileName = '_advance_custom_weather_report.pdf';
  73.                 //     $reportPath = '/report/advanceCustomReportPdf';
  74.                 // }else {
  75.                 //     $template = 'pdf/automatic_report_pdf_template.html.twig';
  76.                 // }
  79.                 // new code added for new templates start
  80.                 // Determine the template and path based on the report type
  81.                 $templates = [
  82.                     'arabian-gulf-report' => 'pdfReportTemplates/arabian-gulf-report.html.twig',
  83.                     'red-sea-report' => 'pdfReportTemplates/red-sea-report.html.twig',
  84.                     'custom-weather-report' => 'pdfReportTemplates/custom-weather-report.html.twig',
  85.                     '10-day-forecast-report' => 'pdfReportTemplates/ten-day-forecast-report.html.twig',
  86.                     'mashaer-weather-report' => 'pdfReportTemplates/mashaer-weather-report.html.twig',
  87.                     'advance-custom-weather-report' => 'pdfReportTemplates/advance-custom-weather-report.html.twig',
  88.                 ];
  90.                 $defaultTemplate = 'pdfReportTemplates/automatic_report_pdf_template.html.twig';
  91.                 $reportKey = $object->getReportType()?->getReportkey();
  92.                 $template = $templates[$reportKey] ?? $defaultTemplate;
  94.                 // Determine report path
  95.                 $reportPaths = [
  96.                     'red-sea-report' => '/report/advanceCustomReportPdf',
  97.                     'custom-weather-report' => '/report/advanceCustomReportPdf',
  98.                     '10-day-forecast-report' => '/report/advanceCustomReportPdf',
  99.                     'mashaer-weather-report' => '/report/advanceCustomReportPdf',
  100.                     'advance-custom-weather-report' => '/report/advanceCustomReportPdf',
  101.                 ];
  102.                 $reportPath = $reportPaths[$reportKey] ?? '/report/ReportPdf';
  104.                 // new code added for new templates end
  106.                 $parameter = [
  107.                     'data' => $object,
  108.                     'reportTitleEn' => $object->getReportTitle('en'),
  109.                     'reportTitleAr' => $object->getReportTitle('ar'),
  110.                     'reportDescriptionEn' => $object->getDescription('en'),
  111.                     'reportDescriptionAr' => $object->getDescription('ar'),
  112.                     'reportDisclaimerEn' => $object->getReportDisclaimer('en'), // new 
  113.                     'reportDisclaimerAr' => $object->getReportDisclaimer('ar'), // new 
  114.                     'additionalNoteEn' => $object->getAdditionalNote('en'), // new 
  115.                     'additionalNoteAr' => $object->getAdditionalNote('ar'), // new 
  116.                     'stateOfTheSeaEn' => $object->getStateOfTheSea('en'), // new 
  117.                     'stateOfTheSeaAr' => $object->getStateOfTheSea('ar'), // new 
  118.                     'waveHeightEn' => $object->getWaveHeight('en'), // new 
  119.                     'waveHeightAr' => $object->getWaveHeight('ar'), // new 
  120.                     'surfaceWindEn' => $object->getSurfaceWind('en'), // new 
  121.                     'surfaceWindAr' => $object->getSurfaceWind('ar'), // new 
  122.                     'publishOnPdf' => $object->getPublishOnPdf() == true ? true : false, // new 
  123.                     'reportType' => $object->getReportType()?->getReportkey(),
  125.                     'template' => $template,
  126.                 ];
  127.                 $language = ['en', 'ar'];
  128.                 $pdfasset = [];
  129.                 foreach ($language as $lang) {
  130.                     $parameter['lang'] = $lang;
  131.                     $pdf = \App\Lib\Utility::generatePdf($parameter, $this->snappy);
  132.                     // new code added for new templates start
  133.                     // Set file name and report path
  134.                     $pdfReportName = ($object->getReportType()?->getName($lang) ?? 'Report') . '_' . date('d-m-Y') . '_' . rand(0, 10000) . '_' . time() .  '.pdf';
  135.                     $reportPath .= '/emails/' . $object->getId();
  136.                     // new code added for new templates end
  138.                     $asset = \App\Lib\Utility::createAsset($pdf, $pdfReportName, $reportPath);
  139.                     if ($asset instanceof Asset) {
  140.                         $pdfasset[$lang] = $asset;
  141.                     } else {
  142.                         $pdfasset[$lang] = '';
  143.                     }
  144.                 }
  145.                 // $object->setAssetAr($pdfasset['ar']);
  146.                 // $object->setAsset($pdfasset['en']);
  147.                 $object->save();
  148.             }
  149.             $emails = [];
  150.             if ($object->getEmails()) {
  151.                 $email = explode(",", $object->getEmails());
  152.                 $emails = array_merge($email, $emails);
  153.             }
  154.             if ($object->getSendEmail()) {
  155.                 if ($organizations) {
  156.                     foreach ($organizations as $organization) {
  157.                         $users = Customer::getByOrganization($organization);
  158.                         foreach ($users as $user) {
  159.                             if ($user?->getEmail()) {
  160.                                 $emails[] = $user->getEmail();
  161.                             }
  162.                         }
  163.                     }
  164.                 }
  165.             }
  166.             if ($emails) {
  167.                 foreach ($emails as $email) {
  168.                     $emailAlertTemplate = '/email/report_email';
  169.                     $param = [
  170.                         'body' => 'NCM Has published ' . $reportType
  171.                     ];
  172.                     $purpose = REPORT_MESSAGE;
  173.                     $html = $this->twig->render('email/report_email_template.html.twig', $param);
  174.                     $mailSent = $this->c2Service->sendCustomReportEmail($_ENV['CUSTOM_REPORT_TEMPLATE'], $object->getId(), $email, $html, $subject = "اشعار مخصص لتوقع حالة طقس معرفة مسبقاً", [$pdfasset['en'], $pdfasset['ar']], $purpose);
  175.                     // $mailSent = $this->emailService->sendMail($param, $email, $emailAlertTemplate, $subject = "اشعار مخصص لتوقع حالة طقس معرفة مسبقاً", [$pdfasset['en']->getData(), $pdfasset['ar']->getData()],[$pdfasset['en']->getFilename(),$pdfasset['ar']->getFilename()],[$pdfasset['en']->getMimeType(), $pdfasset['ar']->getMimeType()]);
  176.                 }
  178.                 $pdfasset['en']->delete();
  179.                 $pdfasset['ar']->delete();
  180.             }
  181.             if ($object->getForTwitterChannel()) {
  182.                 $parameter = [
  183.                     'data' => $object,
  184.                     'reportTitleEn' => $object->getReportTitle('en'),
  185.                     'reportTitleAr' => $object->getReportTitle('ar'),
  186.                     'reportDescriptionEn' => $object->getDescription('en'),
  187.                     'reportDescriptionAr' => $object->getDescription('ar'),
  188.                     'reportDisclaimerEn' => $object->getReportDisclaimer('en'), // new 
  189.                     'reportDisclaimerAr' => $object->getReportDisclaimer('ar'), // new 
  190.                     'additionalNoteEn' => $object->getAdditionalNote('en'), // new 
  191.                     'additionalNoteAr' => $object->getAdditionalNote('ar'), // new 
  192.                     'stateOfTheSeaEn' => $object->getStateOfTheSea('en'), // new 
  193.                     'stateOfTheSeaAr' => $object->getStateOfTheSea('ar'), // new 
  194.                     'waveHeightEn' => $object->getWaveHeight('en'), // new 
  195.                     'waveHeightAr' => $object->getWaveHeight('ar'), // new 
  196.                     'surfaceWindEn' => $object->getSurfaceWind('en'), // new 
  197.                     'surfaceWindAr' => $object->getSurfaceWind('ar'), // new 
  198.                     'publishOnPdf' => $object->getPublishOnPdf() == true ? true : false, // new 
  199.                     'lang' => 'ar'
  200.                 ];
  202.                 // if ($object->getReportType()?->getKey() == 'advance-custom-weather-report') {
  203.                 //     $templateImage = 'pdf/advance_custom_report_pdf_template.html.twig';
  204.                 //     $fileName = '_advance_custom_weather_report.pdf';
  205.                 //     $reportPath = '/report/advanceCustomReportPdf';
  206.                 // }else {
  207.                 //     $templateImage = 'pdf/automatic_report_pdf_template.html.twig';
  208.                 // }
  210.                 // new code added for new templates start
  212.                 // Determine the template and path based on the report type
  213.                 $templateImage = [
  214.                     'arabian-gulf-report' => 'pdfReportTemplates/arabian-gulf-report.html.twig',
  215.                     'red-sea-report' => 'pdfReportTemplates/red-sea-report.html.twig',
  216.                     'custom-weather-report' => 'pdfReportTemplates/custom-weather-report.html.twig',
  217.                     '10-day-forecast-report' => 'pdfReportTemplates/ten-day-forecast-report.html.twig',
  218.                     'mashaer-weather-report' => 'pdfReportTemplates/mashaer-weather-report.html.twig',
  219.                     'advance-custom-weather-report' => 'pdfReportTemplates/advance-custom-weather-report.html.twig',
  220.                 ];
  222.                 // new code added for new templates end
  224.                 $defaultTemplate = 'pdfReportTemplates/automatic_report_pdf_template.html.twig';
  225.                 $reportKey = $object->getReportType()?->getReportkey();
  226.                 $templateImage = $templateImage[$reportKey] ?? $defaultTemplate;
  228.                 $html = $this->twig->render($templateImage, $parameter);
  229.                 $this->snappyImage->setOption('enable-local-file-access', true);
  230.                 $this->snappyImage->setOption('width', '2500');
  231.                 $this->snappyImage->setOption('height', '2500');
  232.                 $this->snappyImage->setOption('format', 'jpeg');
  233.                 // $this->snappyImage->setOption('transparent', true);
  234.                 $image = $this->snappyImage->getOutputFromHtml($html);
  235.                 $asset = \App\Lib\Utility::createAsset($image, rand(0, 10000) . '_' . time() . '_custom_weather_report.jpeg', 'ReportImages');
  236.                 $asset_path = PIMCORE_PROJECT_ROOT . '/public/var/assets' . $asset->getPath() . $asset->getFileName();
  237.                 $media_id = $this->twitterService->uploadMedia($asset_path, 'Custom Weather Report has Published');
  238.                 if ($media_id) {
  239.                     // $this->twitterService->postTweet('Custom Weather Report has Published.', $media_id["result"]);
  240.                     $asset->delete();
  241.                 }
  242.             }
  243.         }
  244.     }
  245. }