src/Library/Subscribers/EmailSubscriber.php line 119

Open in your IDE?
  1. <?php
  3. namespace App\Library\Subscribers;
  5. use App\Library\Database;
  6. use App\Library\Event\demoSendEvent;
  7. use App\Library\Event\GrapperProcessEvent;
  8. use App\Library\Event\GrapperQueueEvent;
  9. use App\Library\Event\testEvent;
  10. use App\Library\Helper;
  11. use App\Library\Mailer as MailHandler;
  12. use App\Library\TemplateLibrary;
  13. use App\models\acount;
  14. use App\models\blacklistEmail;
  15. use App\models\eadr;
  16. use App\models\emain;
  17. use App\models\grapperEmailTemplate;
  18. use App\models\grapperMailLog;
  19. use DateInterval;
  20. use DateTime;
  21. use Doctrine\DBAL\Exception as BaseException;
  22. use Error;
  23. use ErrorException;
  24. use Exception;
  25. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. use Symfony\Component\HttpFoundation\JsonResponse;
  27. use Symfony\Component\Mailer\Exception\TransportExceptionInterface;
  28. use Symfony\Component\Mime\Email;
  29. use Symfony\Component\Mime\Exception\RfcComplianceException;
  30. use Twig\Environment;
  31. use Twig\Error\LoaderError;
  32. use Twig\Error\RuntimeError;
  33. use Twig\Error\SyntaxError;
  34. use Twig\Loader\ArrayLoader;
  36. class EmailSubscriber implements EventSubscriberInterface
  37. {
  38.     /**
  39.      * SQL Statement to select email template
  40.      */
  42.     
  43.     protected const TEMPLATE_NEW_EVENTS_ONLY = 1;
  44.     protected const TEMPLATE_NEW_AND_OLD_EVENTS = 2;
  45.     protected const TEMPLATE_OLD_EVENTS_ONLY = 3;
  46.     protected const TEMPLATE_NO_EVENTS = 4;
  47.     
  48.     public const FS_TEMPLATES = [
  49.         141 => [
  50.             'html'=>'customer/141/html.twig',
  51.             'text'=>false,
  52.         ],
  53.     ];
  55.     public function __construct(
  56.         private readonly Database    $database,
  57.         private readonly MailHandler $mailer,
  58.         private readonly TemplateLibrary $template
  59.     ){
  61.     }
  62.     /**
  63.      * Defining required events
  64.      * @return \array[][]
  65.      */
  66.     public static function getSubscribedEvents():array
  67.     {
  68.         return [
  69.             GrapperProcessEvent::EVENT_RENDER => [
  70.                 [
  71.                     'renderTemplate', 1000
  72.                 ]  
  73.             ],
  74.             GrapperProcessEvent::EVENT_SEND => [
  75.                 [
  76.                     'sendEmail', 1000
  77.                 ]
  78.             ],
  79.             GrapperQueueEvent::EVENT_POST=>[
  80.                 [
  81.                     'sendEmailsToCustomer', 1000,
  82.                 ]
  83.             ],
  84.             demoSendEvent::EVENT=>[
  85.                 'demoSend', 1000
  86.             ],
  87.             testEvent::EVENT=>[
  88.                 'testSend', 1000
  89.             ]
  90.         ];
  91.     }
  93.     public function testSend(testEvent $event):void{
  94.         try{
  95.             $mailObj = new Email();
  96.             $mailObj->to(base64_decode($event->getEmail()));
  97.             $mailObj->subject('Event Scout SMTP Test');
  98.             $mailObj->text('Test Email');
  99.             $mailObj->from('noreply@rce-event-service.de');
  100.             $mailObj->addReplyTo('support@rce.de');
  101.             $this->mailer->init($event->getCustomerId());
  102.             $this->mailer->getMailer()->send($mailObj);
  103.             $event->setResponse(new JsonResponse(['sent'=>true]));
  104.             return;
  105.         }catch(ErrorException|BaseException|Error  $ex){
  106.             $event->setResponse(new JsonResponse(['sent'=>false,'reason'=>'Bitte prüfen Sie ihre SMTP-Zugangsdaten!', 'debug' => $ex->getMessage()]));
  107.             return;
  108.         }
  109.     }
  112.     /**
  113.      * @throws TransportExceptionInterface
  114.      * @throws RuntimeError
  115.      * @throws BaseException
  116.      * @throws LoaderError
  117.      * @throws SyntaxError
  118.      */
  119.     public function demoSend(demoSendEvent $event):void{
  121.         $stmt = $this->database->getConnection()->prepare(acount::GET_SPECIFIC_GRAPPER_CUSTOMER);
  122.         $stmt->bindValue(1,$event->getCustomerId());
  123.         $resultSet = $stmt->executeQuery();
  124.         $customer = $resultSet->fetchAssociative();
  125.         if(empty($event->getAdrId())){
  126.             $sql = grapperEmailTemplate::GET_TEMPLATE_ACCOUNT;
  127.             $stmt = $this->database->getConnection()->prepare($sql);
  128.             $stmt->bindValue(1, $event->getCustomerId());
  130.         }else{
  131.             $sql = grapperEmailTemplate::GET_TEMPLATE;
  132.             $stmt = $this->database->getConnection()->prepare($sql);
  133.             $stmt->bindValue(1, $event->getCustomerId());
  134.             $stmt->bindValue(2, $event->getAdrId());
  135.         }
  136.         $resultSet = $stmt->executeQuery();
  137.         $template = $resultSet->fetchAssociative();
  138.         if(empty($event->getAdrId())){
  139.             $row = [
  140.                 'adrid'=>42,
  141.                 'adrname'=>'test eintrag',
  142.                 'adrstreet'=>'test straße 1',
  143.                 'adrcity'=>'test stadt',
  144.                 'extra1'=>'test',
  145.                 'extra2'=>'test',
  146.                 'extra3'=>'test',
  147.                 'extra4'=>'test',
  148.             ];
  149.         }else{
  150.             $sql = eadr::SELECT_ADDRESSE;
  151.             $stmt = $this->database->getConnection()->prepare($sql);
  152.             $stmt->bindValue(1, $event->getAdrId());
  153.             $resultSet = $stmt->executeQuery();
  154.             $row = $resultSet->fetchAllAssociative()[0];
  155.         }
  156.         if(empty($template)){
  157.             $event->setResponse(new JsonResponse(['sent'=>false,'reason'=>'Template existiert nicht']));
  158.             return;
  159.         }
  160.         $link = 'https://events.rceevent.de/region/?eintragen';
  161.         if(!empty($customer['grapper_meldemodul_link'])){
  162.             $link = $customer['grapper_meldemodul_link'];
  163.         }
  164.         $visibleLink = $link;
  165.         $subStmt = $this->database->getConnection()->prepare(emain::GET_REACENT_EVENTS);
  166.         $subStmt->bindValue(1, $event->getCustomerId());
  167.         $subStmt->bindValue(2, $event->getAdrId());
  168.         $subStmt->bindValue(3, $event->getAdrId());
  169.         $subStmt->bindValue(4, $event->getAdrId());
  170.         $subResultSet = $subStmt->executeQuery();
  171.         $events = $subResultSet->fetchAllAssociative();
  172.         $resultEvents = [];
  173.         if(count($events)>0){
  174.             foreach($events as $item){
  175.                 $resultEvents[] = [
  176.                     'name'         => $item['ename'],
  177.                     'desc'         => $item['edesc'],
  178.                     'date'         => $item['edate'],
  179.                     'dateTo'     => $item['edateto'],
  180.                     'start'     => $item['etimestart'],
  181.                     'end'         => $item['etimeend'],
  182.                     'hash'         => $item['hashid'],
  183.                     'seolink'    => sprintf(Helper::generateSeoUrl($item['ename'], $row['adrcity'], $item['hashid']), $customer['grapper_domain']),
  184.                     'link'         => 'http link zur veranstaltung',
  185.                 ];
  186.             }
  187.         }
  189.         $replaceSet = [
  190.             'adressid'            => $row['adrid'],
  191.             'name'                => $row['adrname'],
  192.             'street'            => $row['adrstreet'],
  193.             'city'                => $row['adrcity'],
  194.             'extra1'            => $row['extra1'],
  195.             'extra2'            => $row['extra2'],
  196.             'extra3'            => $row['extra3'],
  197.             'extra4'            => $row['extra4'],
  198.             'teamname'            => $customer['Name'],
  199.             'teamvorname'        => $customer['Vorname'],
  200.             'teamfirma'            => $customer['Firma'],
  201.             'teamstrasse'         => $customer['Strasse'],
  202.             'teamplz'             => $customer['Plz'],
  203.             'teamort'             => $customer['Ort'],
  204.             'teamland'             => $customer['Land'],
  205.             'sender'            => $customer['grapper_smtp_self_receive'],
  206.             'link'                 => $link,
  207.             'visibleLink'        => $visibleLink,
  208.             'linkUnsubscribe'     => 'https://rce-event.de/modules/meldung/optout.php?id='.$row['adrid'],
  209.             'events'             => $resultEvents,
  210.             'eventCount'        => count($resultEvents),
  211.         ];
  213.         $subject = $customer['grapper_betreff'];
  214.         if(!empty($template['grapper_betreff'])){
  215.             $subject = $template['grapper_betreff'];
  216.         }
  217.         $loader = new ArrayLoader(
  218.             [
  219.                 'html.twig'=>str_replace(
  220.                     [
  221.                         '#sender#', '#teamland#', '#teamort#', '#teamplz#', '#teamstrasse#', '#teamfirma#', '#teamvorname#', '#teamname#', '#name#','#street#','#city#', '#extra1', 'extra2', 'extra2', 'extra4',
  222.                     ],
  223.                     [
  224.                         '{{ sender}}', '{{ teamland}}', '{{ teamort}}', '{{ teamplz}}', '{{ teamstrasse}}', '{{ teamfirma}}', '{{ teamvorname}}', '{{ teamname}}', '{{name}}','{{street}}','{{city}}','{{extra1}}','{{extra2}}','{{extra3}}','{{extra4}}',
  225.                     ],
  226.                     (empty($template['html'])?'':$template['html'])
  227.                 ),
  228.                 'text.twig'=>str_replace(
  229.                     [
  230.                         '#name#','#street#','#city#', '#extra1', 'extra2', 'extra2', 'extra4',
  231.                     ],
  232.                     [
  233.                         '{{name}}','{{street}}','{{city}}','{{extra1}}','{{extra2}}','{{extra3}}','{{extra4}}',
  234.                     ],
  235.                     (empty($template['text'])?'':$template['text'])
  236.                 ),
  237.             ]
  238.         );
  239.         $twig = new Environment($loader, [
  240.             'cache'=>__DIR__.'/../../var/twig',
  241.         ]);
  242.         $text = str_replace('&amp;', '&', $twig->render('text.twig', $replaceSet));
  243.         $html = str_replace('&amp;', '&', $twig->render('html.twig', $replaceSet));
  244.         $mailObj = new Email();
  245.         $mailObj->to(base64_decode($event->getEmail()));
  246.         $mailObj->subject($subject);
  247.         if(!empty($text)){
  248.             $mailObj->text($text);
  249.         }else{
  250.             $mailObj->text('leer');
  251.         }
  252.         if(!empty($html)){
  253.             $mailObj->html($html);
  254.         }
  255.         $mailObj->from('noreply@rce-event-service.de');
  256.         $mailObj->addReplyTo('support@rce.de');
  257.         try{
  258.             $this->mailer->init($event->getCustomerId());
  259.             $this->mailer->getMailer()->send($mailObj);
  260.             $event->setResponse(new JsonResponse(['sent'=>true]));
  261.             return;
  262.         }catch(Exception $ex){
  263.             $event->setResponse(new JsonResponse(['sent'=>false,'reason'=>'Bitte prüfen Sie ihre SMTP-Zugangsdaten!', 'debug' => $ex->getMessage()]));
  264.             return;
  265.         }
  266.         $event->setResponse(JsonResponse(['sent'=>false,'reason'=>'Unbekannter Fehler. Bitte kontaktieren Sie den Support', 'debug' => $ex->getMessage()]));
  267.     }
  269.     /**
  270.      * render text and html template
  271.      * @param \App\Library\Event\GrapperEvent $event
  272.      * @return void
  273.      * @throws BaseException
  274.      * @throws LoaderError
  275.      * @throws RuntimeError
  276.      * @throws SyntaxError
  277.      */
  278.     public function renderTemplate(GrapperProcessEvent $event):void
  279.     {
  280.         $event->addVerboseOutput('Parsing Templates');
  281.         $template = null;
  282.         $event->addVerboseOutput('Customer: '.$event->getAcount()->getId().' Address ID: '.$event->getAddress()->getId());
  283.         $this->template->reset();
  284.         $this->template->prepareTemplate($event);
  285.         $this->template->prepareTwig();
  287.         $link = 'https://events.rceevent.de/region/?eintragen';
  288.         if(!empty($event->getAcount()->getMeldeModulLink())){
  289.             $link = $event->getAcount()->getMeldeModulLink();
  290.         }
  291.         $visibleLink = $link;
  292.         if(!strpos($link, '?')!==false){
  293.             $link .= '?';
  294.         }else{
  295.             $link .= '&';
  296.         }
  297.         $link .= 'gid='.(int)$event->getAddress()->getId();
  299.         //var_dump($rowResult);
  300.         $subStmt = $this->database->getConnection()->prepare(emain::GET_REACENT_EVENTS);
  301.         $subStmt->bindValue(1, $event->getAcount()->getId());
  302.         $subStmt->bindValue(2, $event->getAddress()->getId());
  303.         $subStmt->bindValue(3, $event->getAddress()->getId());
  304.         $subStmt->bindValue(4, $event->getAddress()->getEmail());
  305.         $subResultSet = $subStmt->executeQuery();
  306.         $events = $subResultSet->fetchAllAssociative();
  307.         $resultEvents = [];
  308.         $eventMode = 0;
  309.         $n = 0;
  310.         if(count($events)>0){
  311.             foreach($events as $item){
  312.                 $resultEvents[] = [
  313.                     'active'    => ($item['eonline']==='enable,free'?1:0),
  314.                     'name'         => (strlen($item['ename']) > 35?substr($item['ename'], 0,35).'...':$item['ename']),
  315.                     'fullname'     => $item['ename'],
  316.                     'desc'         => $item['edesc'],
  317.                     'date'         => $item['edate'],
  318.                     'dateTo'     => $item['edateto'],
  319.                     'start'     => $item['etimestart'],
  320.                     'end'         => $item['etimeend'],
  321.                     'hash'         => $item['hashid'],
  322.                     'city'        => (!empty($item['adrcity']) && $item['adrcity']!='-' && $item['adrcity']!=' '?$item['adrcity']:$item['ecity']),
  323.                     'location'    => (!empty($item['adrname'])?$item['adrname']:$item['elocation']),
  324.                     'street'    => (!empty($item['adrstreet'])?$item['adrstreet']:$item['estreet']),
  325.                     'adrzip'    => (!empty($item['adrzip'])?$item['adrzip']:$item['ezip']),
  326.                     'country'    => (!empty($item['adrland'])?$item['adrland']:$item['eland']),
  327.                     'old'        => 0,
  328.                     'seolink'    => sprintf(Helper::generateSeoUrl($item['ename'], $item['adrcity'], $item['hashid']), $event->getAcount()->getDomain()),
  329.                     'link'         => 'http link zur veranstaltung',
  330.                 ];
  331.                 $n++;
  332.             }
  333.         }
  334.         $i=0;
  335.         $o=0;
  336.         unset($events, $item);
  337.         if(count($resultEvents) < 4){
  338.             $subStmt = $this->database->getConnection()->prepare(emain::GET_ALL_EVENTS);
  339.             $subStmt->bindValue(1, $event->getAcount()->getId());
  340.             $subStmt->bindValue(2, $event->getAddress()->getId());
  341.             $subStmt->bindValue(3, $event->getAddress()->getId());
  342.             $subStmt->bindValue(4, $event->getAddress()->getEmail());
  343.             $datemin = new DateTime();
  344.             $dateDiff = new DateInterval('P4Y');
  345.             $datemin->sub($dateDiff);
  346.             $subStmt->bindValue(5, $datemin->format('Y.m.d H:i:s'));
  347.             $subResultSet = $subStmt->executeQuery();
  348.             $events = $subResultSet->fetchAllAssociative();
  349.             $i = count($resultEvents);
  350.             $o = 0;
  351.             if(count($events)>0){
  352.                 foreach($events as $item){
  353.                     if($i>5){
  354.                         continue;
  355.                     }
  356.                     $resultEvents[] = [
  357.                         'active'    => 0,
  358.                         'name'         => (strlen($item['ename']) > 35?substr($item['ename'], 0,35).'...':$item['ename']),
  359.                         'fullname'     => $item['ename'],
  360.                         'desc'         => $item['edesc'],
  361.                         'date'         => $item['edate'],
  362.                         'dateTo'     => $item['edateto'],
  363.                         'start'     => $item['etimestart'],
  364.                         'end'         => $item['etimeend'],
  365.                         'hash'         => $item['hashid'],
  366.                         'city'        => (!empty($item['adrcity']) && $item['adrcity']!='-' && $item['adrcity']!=' '?$item['adrcity']:$item['ecity']),
  367.                         'location'    => (!empty($item['adrname'])?$item['adrname']:$item['elocation']),
  368.                         'street'    => (!empty($item['adrstreet'])?$item['adrstreet']:$item['estreet']),
  369.                         'adrzip'    => (!empty($item['adrzip'])?$item['adrzip']:$item['ezip']),
  370.                         'country'    => (!empty($item['adrland'])?$item['adrland']:$item['eland']),
  371.                         'old'        => 1,
  372.                         'seolink'    => 'false',
  373.                         'link'         => 'http link zur veranstaltung',
  374.                     ];
  375.                     $i++;
  376.                     $o++;
  377.                 }
  378.             }
  379.         }
  380.         if($n > 0 && $o < 1){
  381.             $eventMode = self::TEMPLATE_NEW_EVENTS_ONLY;
  382.         }
  383.         if($n > 0 && $o > 0){
  384.             $eventMode = self::TEMPLATE_NEW_AND_OLD_EVENTS;
  385.         }
  386.         if($n < 1 && $o > 0){
  387.             $eventMode = self::TEMPLATE_OLD_EVENTS_ONLY;
  388.         }
  389.         if($n < 1 && $o < 1){
  390.             $eventMode = self::TEMPLATE_NO_EVENTS;
  391.         }
  392.         unset($events, $item);
  393.         if(count($resultEvents) < 1){
  394.             $eventMode = self::TEMPLATE_NO_EVENTS;
  395.         }
  396.         $replaceSet = [
  397.             'adressid'            => $event->getAddress()->getId(),
  398.             'name'                => $event->getAddress()->getName(),
  399.             'street'            => $event->getAddress()->getStreet(),
  400.             'city'                => $event->getAddress()->getCity(),
  401.             'extra1'            => $event->getAddress()->getExtra1(),
  402.             'extra2'            => $event->getAddress()->getExtra2(),
  403.             'extra3'            => $event->getAddress()->getExtra3(),
  404.             'extra4'            => $event->getAddress()->getExtra4(),
  405.             'email'                => $event->getAddress()->getEmail(),
  406.             'eventMode'            => $eventMode,
  407.             'teamname'            => $event->getAcount()->getName(),
  408.             'teamvorname'        => $event->getAcount()->getFirstName(),
  409.             'teamfirma'            => $event->getAcount()->getCompany(),
  410.             'teamstrasse'         => $event->getAcount()->getStreet(),
  411.             'teamplz'             => $event->getAcount()->getZipCode(),
  412.             'teamort'             => $event->getAcount()->getCity(),
  413.             'teamland'             => $event->getAcount()->getCountry(),
  414.             'sender'            => $event->getAcount()->getSmtpSelfReceive(),
  415.             'link'                 => $link,
  416.             'visibleLink'        => $visibleLink,
  417.             'linkUnsubscribe'     => 'https://rce-event.de/modules/meldung/optout.php?id='.$event->getAddress()->getId(),
  418.             'events'             => $resultEvents,
  419.             'eventCount'        => count($resultEvents),
  420.         ];
  421.         $event->addVerboseOutput('Mail Mode:'.$eventMode);
  422.         $subject = $this->template->getTemplate()->getSubject();
  423.         if(!empty($subject)){
  424.             $subject = $event->getAcount()->getBetreff();
  425.         }
  426.         $this->template->render($replaceSet, $event, $subject);
  427.     }
  429.     /**
  430.      * @param GrapperProcessEvent $event
  431.      * @return void
  432.      * @throws BaseException
  433.      */
  434.     public function sendEmail(GrapperProcessEvent $event):void
  435.     {
  436.         $event->addVerboseOutput('sending Email');
  437.         $this->mailer->initMailer($this->mailer->getDsn($event));
  438.         if(
  439.             !$event->getTemplate()->containsKey('subject')
  440.             ||
  441.             empty($event->getTemplate()->get('subject'))
  442.         ){
  443.             $event->stopPropagation();
  444.             $event->addVerboseOutput('html templateis empty for '.$event->getAddressId());
  445.             return;
  446.         }
  448.        $template = $event->getTemplate();
  449.        $adrid = $event->getAddress()->getId();
  450.       $event->addVerboseOutput('Customer: '.$event->getAcount()->getId().' Address ID: '.$adrid);
  451.        if(!filter_var($event->getAddress()->getEmail(), FILTER_VALIDATE_EMAIL)){
  452.            //disable Address as it fails
  453.            $stmt = $this->database->getConnection()->prepare(eadr::DISABLE_EMAIL_SENDING_DUE_TO_ERROR);
  454.            $stmt->bindValue(1,$event->getCustomerId());
  455.            $stmt->bindValue(2,$event->getAddressId());
  456.            $stmt->executeQuery();
  457.            $event->addVerboseOutput('Due to an error within the email Adress the Addressid '.$event->getAddressId(). ' was disabled');
  458.            $event->stopPropagation();
  459.            return;
  460.        }
  461.        $blacklist = $this->database->getData(blacklistEmail::class, blacklistEmail::CHECK_EMAIL_BLACKLIST, [$event->getAddress()->getEmail()]);
  463.        if(!empty($blacklist)){
  464.            $stmt = $this->database->getConnection()->prepare(eadr::DISABLE_EMAIL_SENDING_DUE_TO_ERROR);
  465.            $stmt->bindValue(1,$event->getCustomerId());
  466.            $stmt->bindValue(2,$event->getAddressId());
  467.            $stmt->executeQuery();
  468.            $event->addVerboseOutput('The Address is Blacklisted '.$event->getAddressId(). ' so it was disabled');
  469.            $event->stopPropagation();
  470.            $event->addVerboseOutput('email address is blacklisted'.$event->getAddress()->getEmail());
  471.            return;
  472.        }
  473.         try{
  474.             //blacklist scann end
  475.             $email = new Email();
  476.             $receiver = [];
  477.             if(MailHandler::DEBUG_MODE > 0){
  478.                 $i=0;
  479.                 foreach(MailHandler::DEBUG_EMAILS as $row){
  480.                     if($i===0){
  481.                         $receiver[] = $row;
  482.                         $email->to($row);
  483.                         $i++;
  484.                     }else{
  485.                         $receiver[] = $row;
  486.                         $email->addTo($row);
  487.                     }
  488.                 }
  489.             }else{
  490.                 $receiver[] = $event->getAddress()->getEmail();
  491.                 $email->to($event->getAddress()->getEmail());
  492.             }
  493.             $email->subject($event->getTemplate()->get('subject'));
  495.             if(!empty($event->getTemplate()->get('html'))){
  496.                 $email->html($event->getTemplate()->get('html'));
  497.             }
  498.            if(!empty($event->getTemplate()->get('text'))){
  499.                $email->text($event->getTemplate()->get('text'));
  500.            }
  501.            if(!empty($event->getAcount()->getSmtpSelfReceive())){
  502.                $email->addBcc($event->getAcount()->getSmtpSelfReceive());
  503.            }
  504.             if(MailHandler::FREE_MAILER_ENABLED && $event->getAcount()->getLizenz()->isFreeMailer()){
  505.                 $email->from(MailHandler::FREE_MAILER_USER);
  506.             }else{
  507.                 $email->from($event->getAcount()->getSender());
  508.             }
  509.             if(!empty($event->getAcount()->getReplyTo())){
  510.                 $email->addReplyTo($event->getAcount()->getReplyTo());
  511.             }else{
  512.                 $email->addReplyTo($event->getAcount()->getSender());
  513.             }
  514.             if(!empty($event->getAcount()->getSmtpSelfReceive())){
  515.                 $email->bcc($event->getAcount()->getSmtpSelfReceive());
  516.             }
  517.         }catch(RfcComplianceException $ex){
  518.             $event->addVerboseOutput($ex->getMessage());
  519.         }
  520.           $event->addVerboseOutput('email is sent');
  521.         if(MailHandler::DEBUG_SEND > 0){
  522.             $event->addVerboseOutput($event->getAddress()->getEmail());
  523.         }else{
  524.             $event->addVerboseOutput('email sent');
  525.                 $this->mailer->getMailer()->send($email);
  526.         }
  527.         
  528.         $sql = sprintf(grapperMailLog::LOG_MAIL_SENT, $event->getAddress()->getEmail(), (int)$event->getAcount()->getId());
  529.         $stmt = $this->database->getConnection()->prepare($sql);
  530.         $stmt->executeQuery();
  531.            $event->setSent(true);
  532.        if($event->getAcount()->getSendDelay() > 0){
  533.            //sleep($event->getAcount()->getSendDelay());
  534.        }
  535.          unset($transport, $mailer, $email, $dsn, $stmt);
  536.     }
  538.     /**
  539.      * @throws SyntaxError
  540.      * @throws RuntimeError
  541.      * @throws LoaderError
  542.      * @throws BaseException
  543.      */
  544.     public function sendEmailsToCustomer(GrapperQueueEvent $event):void{
  545.         $this->mailer->initMailer($this->mailer->initStatisticSender($event));
  546.         $email = new Email();
  547.         if(MailHandler::DEBUG_MODE > 0){
  548.             $i=0;
  549.             foreach(MailHandler::DEBUG_EMAILS as $row){
  550.                 $email->addTo($row);
  551.             }
  552.         }else{
  553.             $email->addTo($event->getAcount()->getEmail());
  554.         }
  555.         if(!empty(MailHandler::DEFAULT_STATISTIC_RECEIVER))
  556.         {
  557.             $email->addTo(MailHandler::DEFAULT_STATISTIC_RECEIVER);
  558.         }
  559.         $email->from(MailHandler::STATISTICS_MAILER_USER);
  560.         $email->addReplyTo(MailHandler::DEFAULT_STATISTIC_SENDER);
  561.         $email->subject(MailHandler::STATISTICS_SUBJECT);
  562.         $loader = new ArrayLoader(
  563.             [
  564.                 'html.twig'=>file_get_contents(__DIR__.'/../../../templates/email.statistics.html.twig'),
  565.             ]
  566.         );
  567.         
  568.         $twig = new Environment($loader, [
  569.             'cache'=>__DIR__.'/../../../var/twig',
  570.         ]);
  571.         $stmt = $this->database->getConnection()->prepare(grapperMailLog::LOG_MAIL_SENT_SUCCESSFULL);
  572.         $stmt->bindValue(1, $event->getStartTime()->format('y.m.d H:i:s'));
  573.         $interval = new DateInterval('PT30S');
  574.         $currentTime = (new DateTime())->add($interval);
  575.         $stmt->bindValue(2, $currentTime->format('y.m.d H:i:s'));
  576.         $result = $stmt->executeQuery();
  577.         $resultArray = $result->fetchAssociative();
  578.         $parameters = [
  579.             'sent' => $event->getAddresses()->toArray(),
  580.             'total' => $event->getAddresses()->count(),
  581.             'customer' => $event->getAcount(),
  582.             'sentCounter'=>$resultArray['cnt'],
  583.         ];
  584.         $html = $twig->render('html.twig', $parameters);
  585.         $email->html($html);
  586.         try{
  587.             if(MailHandler::DEBUG_MODE === 0)
  588.             {
  589.                 $this->mailer->send($email);
  590.             }else{
  591.                 dump($parameters);
  592.             }
  593.         }catch (TransportExceptionInterface $ex){
  594.             $event->addVerboseOutput($ex->getMessage());
  595.         }catch(Exception $ex){
  596.             $event->addVerboseOutput($ex->getMessage());
  597.         }
  598.     }
  599. }