UserUtils : setNewsletter

ShopBundle/Services/UserUtils.php

 namespace Lc\ShopBundle\Services ;
 
 use Doctrine\ORM\EntityManagerInterface;
+use Lc\ShopBundle\Context\MerchantUtilsInterface;
 use Symfony\Component\HttpFoundation\Cookie ;
 use Lc\ShopBundle\Context\VisitorInterface;
 use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
         protected $utils ;
         protected $requestStack ;
         protected $visitorRepository ;
+        protected $merchantUtils ;
 
-        public function __construct(ParameterBagInterface $parameterBag, EntityManagerInterface $em, Utils $utils, RequestStack $requestStack)
+        public function __construct(ParameterBagInterface $parameterBag, EntityManagerInterface $em, Utils $utils,
+                                    RequestStack $requestStack, MerchantUtilsInterface $merchantUtils)
         {
                 $this->em = $em ;
                 $this->parameterBag = $parameterBag ;
                 $this->utils = $utils ;
                 $this->requestStack = $requestStack ;
                 $this->visitorRepository = $this->em->getRepository($this->em->getClassMetadata(VisitorInterface::class)->getName()) ;
+                $this->merchantUtils = $merchantUtils ;
         }
 
         public function getCookieNameVisitor()
                 $this->em->flush() ;
         }
 
+        public function setNewsletter($user, $subscribeNewsletter)
+        {
+                $currentMerchant = $this->merchantUtils->getMerchantCurrent() ;
+                $newsletters = $currentMerchant->getNewsletters() ;
+
+                if(isset($newsletters[0]) && $newsletters[0]) {
+                        if($subscribeNewsletter) {
+                                $user->addNewsletter($newsletters[0]) ;
+                        }
+                        else {
+                                $user->removeNewsletter($newsletters[0]) ;
+                        }
+                }
+
+                $this->em->persist($user) ;
+                $this->em->flush() ;
+        }
+
 }