LcShopBundle/ShopBundle/Controller/Backend/NewsController.php

<?php

namespace Lc\ShopBundle\Controller\Backend;

use App\Repository\UserRepository;
use Doctrine\ORM\EntityManagerInterface;
use FOS\UserBundle\Model\UserManagerInterface;
use Lc\ShopBundle\Context\NewsInterface;
use Lc\ShopBundle\Context\UserInterface;
use Lc\ShopBundle\Services\MailUtils;
use Lc\ShopBundle\Services\UtilsManager;
use Mailjet\MailjetSwiftMailer\SwiftMailer\MailjetTransport;
use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
use Symfony\Component\HttpFoundation\Session\SessionInterface;
use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
use Symfony\Component\Security\Core\Security;
use Symfony\Contracts\Translation\TranslatorInterface;
use \Mailjet\Resources ;

class NewsController extends AdminController
{
        protected $parameterBag ;

        public function __construct(Security $security, UserManagerInterface $userManager, EntityManagerInterface $em, MailjetTransport $mailjetTransport, UtilsManager $utilsManager, TranslatorInterface $translator, SessionInterface $session, ParameterBagInterface $parameterBag)
        {
                parent::__construct($security, $userManager, $em, $mailjetTransport, $utilsManager, $translator, $session);
                $this->parameterBag = $parameterBag ;
        }

        public function sendTestAction()
        {
                $newsletter = $this->getNewsletter() ;

                if($newsletter) {
                    $news = $this->getNews() ;

                    $merchantCurrent = $this->merchantUtils->getMerchantCurrent() ;
                    $merchantConfigEmailContact = $merchantCurrent->getMerchantConfig('email-contact');

                    if($merchantConfigEmailContact && strlen($merchantConfigEmailContact)) {
                        $this->mailUtils->send([
                            MailUtils::SUBJECT => $news->getTitle(),
                            MailUtils::TO_EMAIL => $merchantConfigEmailContact,
                            MailUtils::TO_NAME => $this->parameterBag->get('app.site_name'),
                            MailUtils::CONTENT_TEMPLATE => 'mail/news',
                            MailUtils::CONTENT_DATA => [
                                'news' => $news,
                                'newsletter' => $newsletter,
                                'user' => $this->security->getUser()
                            ],
                        ]);

                        $this->addFlash('success', 'Actualité de test envoyée à '.$merchantConfigEmailContact);
                    }
                    else {
                        throw new \ErrorException("L'email de contact n'est pas défini pour ce Merchant.") ;
                    }
                }

                return $this->redirectToRoute('easyadmin', ['entity' => 'News', 'action' => 'list']) ;
        }

        public function sendAction()
        {
                ini_set('memory_limit', '-1');
                set_time_limit(0);

                $currentMerchant = $this->merchantUtils->getMerchantCurrent() ;
                $newsletter = $this->getNewsletter() ;

                if($newsletter) {
                    $news = $this->getNews() ;
                    $users = $this->em->getRepository($this->em->getClassMetadata(UserInterface::class)->getName())->findAllByNewsletter($newsletter) ;

                    $countUsers = count($users) ;

                    $packageMessagesArray = [];
                    $packageMessageLimit = 50 ;

                    $paramsTemplate = [
                        'news' => $news,
                        'newsletter' => $newsletter,
                        'user' => $this->security->getUser()
                    ] ;

                    $i = 0 ;

                    foreach ($users as $user) {
                        $paramsTemplate['user'] =$user;

                        if(!isset($packageMessagesArray[$i])) {
                            $packageMessagesArray[$i] = [] ;
                        }

                        if($user->getEmail() && strlen($user->getEmail())) {
                            $packageMessagesArray[$i][] = [
                                'To' => [
                                    [
                                        'Email' => $user->getEmail(),
                                        'Name' => $user->getFirstname().' '.$user->getLastname(),
                                    ]
                                ],
                                'From' => [
                                    'Email' => $this->getParameter('app.noreply_email'),
                                    'Name' => $this->getParameter('app.site_name')
                                ],
                                'Subject' => $currentMerchant->getMerchantConfig('email-from-name').' - '.$news->getTitle(),
                                'TextPart' => $this->renderView('mail/news-text.html.twig', $paramsTemplate),
                                'HTMLPart' => $this->renderView('mail/news-html.html.twig', $paramsTemplate),
                                'CustomCampaign' => $news->getTitle(),
                                'DeduplicateCampaign' => true
                            ] ;

                            if(count($packageMessagesArray[$i]) >= $packageMessageLimit) {
                                $i ++ ;
                            }
                        }
                    }

                    if($countUsers > 0) {
                        $mj = new \Mailjet\Client($this->mailjetTransport->getApiKey(), $this->mailjetTransport->getApiSecret(),true,['version' => 'v3.1']);

                        foreach($packageMessagesArray as $messagesArray) {
                            $body = [
                                'Messages' => $messagesArray
                            ];
                            $response = $mj->post(Resources::$Email, ['body' => $body]);
                        }

                        if(isset($response) && $response->success()) {
                            $this->addFlash('success', 'Actualité envoyée à '.$countUsers.' utilisateurs.');

                            $news->setIsSent(true) ;
                            $this->em->persist($news);
                            $this->em->flush() ;
                        }
                        else {
                            $this->addFlash('error', "Une erreur est survenue lors de l'envoi de l'actualité.");
                        }
                    }
                    else {
                        $this->addFlash('error', 'Aucun utilisateur inscrit à la newsletter.');
                    }
                }

                return $this->redirectToRoute('easyadmin', ['entity' => 'News', 'action' => 'list']) ;
        }

        public function getNewsletter()
        {
                $news = $this->getNews() ;

                if($news) {
                    $newsletter = $news->getNewsletter() ;
                }

                if(isset($newsletter) && $newsletter) {
                    return $newsletter ;
                }
                else {
                    $this->utils->addFlash('error', 'Aucune newsletter n\'est liée à l\'actualité.');
                }
        }

        public function getNews()
        {
                $idNews = $this->request->get('id') ;
                $news = $this->em->getRepository($this->em->getClassMetadata(NewsInterface::class)->getName())->find($idNews) ;

                if($news) {
                        return $news ;
                }
                else {
                        throw new NotFoundHttpException('Actualité introuvable') ;
                }
        }

}