bundle/w3des/NewsletterBundle/src/Util.php line 82

Open in your IDE?
  1. <?php
  2. namespace w3des\NewsletterBundle;
  4. use Doctrine\ORM\EntityManager;
  5. use Ramsey\Uuid\Uuid;
  6. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  7. use Symfony\Component\Validator\Validation;
  8. use w3des\NewsletterBundle\Entity\NewsletterEmail;
  9. use Symfony\Component\Validator\Constraints\NotBlank;
  10. use Symfony\Component\Validator\Constraints\Email;
  11. use Symfony\Component\HttpFoundation\RequestStack;
  12. use Symfony\Bundle\FrameworkBundle\Routing\Router;
  13. use w3des\AdminBundle\Service\Settings;
  14. use Symfony\Component\Console\Output\OutputInterface;
  15. use w3des\NewsletterBundle\Entity\NewsletterContent;
  16. use Egulias\EmailValidator\EmailValidator;
  17. use Egulias\EmailValidator\Validation\RFCValidation;
  18. use Symfony\Component\Mailer\MailerInterface;
  20. class Util
  21. {
  23. protected $em;
  25. protected $stack;
  27. protected $router;
  29. protected $settings;
  31. protected $mailer;
  33. protected $defaultScheme;
  35. protected $defaultHost;
  37. public function __construct(EntityManager $em, RequestStack $stack, Router $router, Settings $settings, MailerInterface $mailer, $defaultScheme, $defaultHost)
  38. {
  39. $this->settings = $settings;
  40. $this->em = $em;
  41. $this->stack = $stack;
  42. $this->router = $router;
  43. $this->mailer = $mailer;
  44. $this->defaultHost = $defaultHost;
  45. $this->defaultScheme = $defaultScheme;
  46. }
  48. public function import($_service, $pageLocale, $fileName)
  49. {
  50. $repo = $this->em->getRepository(NewsletterEmail::class);
  51. $fp = fopen($fileName, 'r');
  52. $count = 0;
  53. $lines = 0;
  54. $v = Validation::createValidator();
  55. $rules = [
  56. new NotBlank(),
  57. new Email()
  58. ];
  59. while ($line = \fgetcsv($fp, null, ';')) {
  60. $lines ++;
  61. $email = trim($line[0]);
  62. if (count($v->validate($email, $rules)) == 0 && ! $repo->findOneBy([
  63. 'locale' => $pageLocale,
  64. 'email' => $email
  65. ])) {
  66. $mail = new NewsletterEmail();
  67. $mail->setEmail($email);
  69. $mail->setService($_service);
  70. $mail->setCreatedAt(new \DateTime());
  71. $mail->setLocale($pageLocale);
  72. $mail->setId(Uuid::uuid4()->toString());
  73. $this->em->persist($mail);
  74. $this->em->flush();
  75. $count ++;
  76. }
  77. }
  78. \fclose($fp);
  79. return ' Zaimportowano ' . $count . '/ ' . $lines . ' nowych e-maili';
  80. }
  82. public function send(NewsletterContent $model, $testMail = null, OutputInterface $output = null)
  83. {
  84. $content = $this->fixContent($model->getContent());
  85. if ($testMail) {
  86. $mails = [
  87. $testMail
  88. ];
  89. } else {
  90. $mails = [];
  91. foreach ($this->em->getRepository(NewsletterEmail::class)->findBy([
  92. 'locale' => $model->getLocale()
  93. ], [
  94. 'createdAt' => 'desc'
  95. ]) as $tmp) {
  96. $mails[] = $tmp->getEmail();
  97. }
  98. }
  99. $i = 0;
  100. $mailFrom = $this->settings->get('mail_from', null, $model->getLocale());
  101. $mailFromName = $this->settings->get('mail_from_name', null, $model->getLocale()) ?: $mailFrom;
  102. foreach ($mails as $mail) {
  103. try {
  104. $validator = new EmailValidator();
  106. if (! $validator->isValid($mail, new RFCValidation())) {
  107. continue;
  108. }
  109. $link = $this->router->generate('newsletter.subscribe', [
  110. 'email' => \base64_encode($mail),
  111. 'remove' => 1,
  112. 'direct' => 1
  113. ], UrlGeneratorInterface::ABSOLUTE_URL);
  114. $cnt = $content . '<br /><br />--<br /><p style="font-size: 11px;">Aby wypisać się z naszej listy dystrybucyjnej <a href="' . $link . '" target="_blank"><span style="color:blue">kliknij tutaj</span></a></p>';
  116. $msg = \Swift_Message::newInstance($model->getTitle(), $cnt, 'text/html', 'utf-8');
  117. $msg->setFrom($mailFrom, $mailFromName);
  118. $msg->setReplyTo($mailFrom);
  119. $msg->setReturnPath($mailFrom);
  120. // $this->getHeaders()->addMailboxHeader('Rcp-To', [$this->get('settings')->get('mail_from') => $this->get('settings')->get('mail_from')]);
  121. $msg->setTo(trim($mail));
  123. if ($output) {
  124. $output->writeln('<comment>' . $mail . ';</comment>');
  125. }
  126. $this->mailer->send($msg);
  127. $i ++;
  128. if ($i % 100 == 0) {
  129. if ($output) {
  130. $output->writeln('<info>Sleep</info>');
  131. }
  132. // sleep(60);
  133. }
  134. } catch (\Exception $e1) {} catch (\Throwable $e2) {}
  135. }
  136. }
  138. protected function fixContent($cnt)
  139. {
  140. $request = $this->stack->getCurrentRequest();
  141. $prefix = '';
  142. if ($request) {
  143. $prefix = $request->getScheme() . '://' . $request->getHost() . '/';
  144. } else {
  145. $prefix = $this->defaultScheme . '://' . $this->defaultHost . '/';
  146. }
  148. $cnt = preg_replace('#src="/#i', 'src="' . $prefix, $cnt);
  149. $cnt = preg_replace('#href="/#i', 'href="' . $prefix, $cnt);
  151. return $cnt;
  152. }
  153. }