src/Manager/CustomerManager.php line 27

Open in your IDE?
  1. <?php
  3. namespace App\Manager;
  5. use App\Entity\Customer;
  6. use App\Entity\Address;
  7. use App\Entity\CustomerLoginToken;
  8. use App\Entity\PriceGroup;
  10. class CustomerManager {
  11.     
  12.     private $session;
  13.     private $mailer;
  14.     private $em;
  15.     private $key = "SDflkfoRE5459Z_çà#è79=/";
  17.     public function __construct(\Symfony\Component\HttpFoundation\Session\SessionInterface $session, \Doctrine\ORM\EntityManagerInterface $em, \App\Service\Mailer $mailer)
  18.     {
  19.         $this->session = $session;
  20.         $this->em = $em;
  21.         $this->mailer = $mailer;
  22.         $this->cart = null;
  23.     }
  24.     
  25.     public function getCustomer()
  26.     {
  27.         $id = $this->session->get('customer_id');
  28.         if(!empty($id)){
  29.             $customer = $this->em->getRepository('App:Customer')->find($id);
  30.             if(!empty($customer)){
  31.                 if($this->checkToken($customer)){
  32.                     return $customer;
  33.                 }
  34.             }
  35.         }
  36.         return false;
  37.     }
  38.     
  39.     public function getCustomerCountry()
  40.     {
  41.         $customer = $this->getCustomer();
  42.         if($customer){
  43.             $defaultAddress = $customer->getDefaultAddress();
  44.             if($defaultAddress){
  45.                 return $defaultAddress->getCountry();
  46.             }
  47.         }
  48.         return false;
  49.     }
  50.     
  51.     public function getPriceContext(): PriceGroup
  52.     {
  53.         $code = $this->session->get('customer_price_context', PriceGroup::CODE_VIVOG);
  54.         return $this->em->getRepository(PriceGroup::class)->findOneByCode($code);
  55.     }
  56.     
  57.     public function setPriceContext(PriceGroup $priceGroup)
  58.     {
  59.         $customer = $this->getCustomer();
  60.         if(empty($customer) || !$this->hasPriceContext($priceGroup)){
  61.             throw new \App\Exception\PriceGroupException();
  62.         }
  63.         $this->session->set('customer_price_context',$priceGroup->getCode());
  64.     }
  65.     
  66.     public function isExpert()
  67.     {
  68.         $currentPriceGroup = $this->session->get('customer_price_context', false);
  69.         return $currentPriceGroup === PriceGroup::CODE_EXPERT;
  70.     }
  71.     
  72.     public function hasExpertContext()
  73.     {
  74.         $customer = $this->getCustomer();
  75.         foreach($customer->getPriceGroups() as $priceGroup) {
  76.             if($priceGroup->getGroup()->getCode() == PriceGroup::CODE_EXPERT)
  77.                 return true;
  78.         }
  79.         return false;
  80.     }
  81.     
  82.     public function hasPriceContext(PriceGroup $priceGroup)
  83.     {
  84.         $customer = $this->getCustomer();
  85.         foreach($customer->getPriceGroups() as $cPriceGroup) {
  86.             if($cPriceGroup->getGroup() == $priceGroup)
  87.                 return true;
  88.         }
  89.         return false;
  90.     }
  91.     
  92.     public function initCustomerSession(&$customer)
  93.     {
  94.         $this->updateLastLogin($customer);
  95.         $this->session->set('customer_id',$customer->getId());
  96.         $this->session->set('customer_email',$customer->getEmail());
  97.         $this->session->set('customer_token',$this->getToken($customer));
  98.     }
  99.     
  100.     protected function updateLastLogin(Customer $customer)
  101.     {
  102.         $customer->setLastLogin(new \DateTime);
  103.         $nbLogin = $customer->getNbLogin()+1;
  104.         $customer->setNbLogin($nbLogin);
  105.         $this->em->persist($customer);
  106.         $this->em->flush();
  107.     }
  108.     
  109.     public function login($user,$pwd)
  110.     {
  111.         $customer = $this->em->getRepository('App:Customer')->findOneBy(array(
  112.             'email'=>$user
  113.         ));
  114.         if(!empty($customer)){
  115.             if($this->checkPassword($pwd, $customer->getPassword())){
  116.                 $priceGroups = $customer->getPriceGroups();
  117.                 if(count($priceGroups) == 0) {
  118.                     throw new \App\Exception\PriceGroupException();
  119.                 }
  120.                 $this->initCustomerSession($customer);
  121.                 return $customer;
  122.             }
  123.         }
  124.         return false;
  125.     }
  126.     
  127.     
  128.     
  129.     public function checkLogin($user,$pwd)
  130.     {
  131.         $customer = $this->em->getRepository('App:Customer')->findOneBy(array(
  132.             'email'=>$user
  133.         ));
  134.         if(!empty($customer)){
  135.             return $this->checkPassword($pwd, $customer->getPassword());
  136.         }
  137.         return false;
  138.     }
  139.     
  140.     public function generateLoginToken(Customer $customer)
  141.     {
  142.         $code = \App\Helpers\Encoder::getRandomDigit(4);
  143.         $token = new CustomerLoginToken();
  144.         $token->setCustomer($customer);
  145.         $token->setToken($this->getLoginToken($code));
  146.     }
  147.     
  148.     protected function getLoginToken($code)
  149.     {
  150.         return md5($code.CustomerLoginToken::$KEY);
  151.     }
  152.     
  153.     public function checkCustomerLoginToken(Customer $customer, $code)
  154.     {
  155.         $code = \App\Helpers\Encoder::getRandomDigit(4);
  156.         $token = new CustomerLoginToken();
  157.         $token->setCustomer($customer);
  158.         $token->setToken($this->getLoginToken($code));
  159.     }
  160.     
  161.     public function register($data, $locale = "fr")
  162.     {
  163.         $customer = $this->em->getRepository('App:Customer')->findOneBy(array('email'=>$data['email']));
  164.         if(!empty($customer)){
  165.             $this->session->getFlashBag()->add('error', 'Un compte utilisateur utilise déjà cette adresse email : '.$data['email']);
  166.             return false;
  167.         }
  168.         $defaultGroup = $this->em->getRepository('App:CustomerGroup')->find(1);
  169.         $customer = new \App\Entity\Customer();
  170.         $customer->setGroup($defaultGroup);
  171.         $customer->setEmailAddress($data['email']);
  172.         $customer->setGender($data['address']->getGender());
  173.         $customer->setFirstname($data['address']->getFirstName());
  174.         $customer->setLastname($data['address']->getLastName());
  175.         $customer->setTelephone($data['address']->getPhone());
  176.         $customer->setPassword($this->encryptPassword($data['plainPassword']));
  177. //        $customer->setNewsletter($data['newsletter']);
  178.         //$customer->setPassword(hex2bin($this->encryptPassword($data['plainPassword'])));
  179.         
  180.         $customer->setCompany($data['company']);
  181.         $customer->setSiret($data['siret']);
  182.         $customer->setTva($data['tva']);
  183.         $customer->setElevage($data['elevage']);
  184.         $customer->setMetier($data['metier']);
  185.         
  186.         $language = $this->em->getRepository('App:Language')->findOneByCode($locale);
  187.         $customer->setLanguage($language);
  188.         $customer->setCreation(new \DateTime);
  189.         $customer->setStatus(Customer::STATUS_WAITING);
  190.         $this->em->persist($customer);
  191.         $this->em->flush();
  192.         
  193.         if(isset($data['address'])){
  194.             $address = new Address();
  195.             $address->setGender($data['address']->getGender());
  196.             $address->setFirstname($data['address']->getFirstName());
  197.             $address->setLastname($data['address']->getLastName());
  198.             $address->setCompany($data['address']->getCompany());
  199.             $address->setAddress1($data['address']->getAddress1());
  200.             $address->setAddress2($data['address']->getAddress2());
  201.             $address->setPostcode($data['address']->getPostcode());
  202.             $address->setCity($data['address']->getCity());
  203.             $address->setCountry($data['address']->getCountry());
  204.             $address->setPhone($data['address']->getPhone());
  205.             $address->setCustomer($customer);
  206.             $this->em->persist($address);
  207.             $customer->setDefaultAddress($address);
  208.             $this->em->persist($customer);
  209.             $this->em->flush();
  210.         }
  211. //        $this->mailer->sendAccountConfirmation($customer, $locale);
  212.         
  213.         $customerPrice = new \App\Entity\CustomerPriceGroup();
  214.         $customerPrice->setCustomer($customer);
  215.         if($data['expert']) {
  216.             $priceGroup = $this->em->getRepository(PriceGroup::class)->findOneByCode(PriceGroup::CODE_EXPERT);
  217.             $customerPrice->setSapId($data['expertId']);
  218.         }else{
  219.             $priceGroup = $this->em->getRepository(PriceGroup::class)->findOneByCode(PriceGroup::CODE_VIVOG);
  220.         }
  221.         $customerPrice->setGroup($priceGroup);
  222.         $this->em->persist($customerPrice);
  223.         $this->em->flush();
  224.         $this->em->refresh($customer);
  225. //        $this->setPriceContext($priceGroup);
  226.         
  227.         $this->mailer->notifyRegistration($customer);
  228.         $this->initCustomerSession($customer);
  229.         return $customer;
  230.     }
  231.     
  232.     public function delete(Customer $customer)
  233.     {
  234.         try{
  235.             $this->em->remove($customer);
  236.             $this->em->flush();
  237.         } catch (\Exception $ex) {
  238.             return false;
  239.         }
  240.         return true;
  241.     }
  242.     
  243.     public function checkPassword(string $plain, string $encrypted)
  244.     {
  245.         if (!empty($plain) && !empty($encrypted)) {
  246.             $stack = explode(':', $encrypted);
  247.             if (sizeof($stack) != 2) return false;
  248.             return md5($stack[1] . $plain) == $stack[0];
  249.         }
  250.         return false;
  251.     }
  252.     
  253.     public function encryptPassword($plain)
  254.     {
  255.         $salt = substr(md5($plain), 0, 2);
  256.         return md5($salt.$plain).':'.$salt;
  257.     }
  258.     
  259.     public function renewPassword($email, $locale)
  260.     {
  261.         $customer = $this->em->getRepository('App:Customer')->findOneByEmail($email);
  262.         if(empty($customer)){
  263.             return "Aucun compte client ne correspond à l'email saisi.";
  264.         }else{
  265.             $pwd = $this->generatePassword();
  266.             $customer->setPassword($this->encryptPassword($pwd));
  267.             try{
  268.                 $this->mailer->sendPassword($customer,$pwd,$locale);
  269.                 $this->em->persist($customer);
  270.                 $this->em->flush();
  271.                 return true;
  272.             } catch (Exception $ex) {
  273.                 return "Erreur lors de la génération du mot de passe";
  274.                 return $ex->getMessage();
  275.             }
  276.         }
  277.         return  false;
  278.     }
  279.     
  280.     private function generatePassword($length=8)
  281.     {
  282.         //$chars = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789';
  283.         $chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789';
  284.         $count = mb_strlen($chars);
  285.         for ($i = 0, $result = ''; $i < $length; $i++) {
  286.             $index = rand(0, $count - 1);
  287.             $result .= mb_substr($chars, $index, 1);
  288.         }
  289.         return $result;
  290.     }
  291.     
  292.     public function changePassword(Customer $customer, $currentPwd, $newPwd)
  293.     {
  294.         if($this->checkPassword($currentPwd, $customer->getPassword())){
  295.             $customer->setPassword($this->encryptPassword($newPwd));
  296.             $this->em->persist($customer);
  297.             $this->em->flush();
  298.             return true;
  299.         }
  300.         return "Mot de passe incorrect";
  301.     }
  302.     
  303.     public function logout()
  304.     {
  305. //        $this->log('déconnexion');
  306.         $this->session->remove('customer_id');
  307.         $this->session->remove('customer_fullname');
  308.         $this->session->remove('customer_email');
  309.         $this->session->remove('customer_token');
  310.     }
  311.     
  312.     public function isLogged() {
  313.         $customer = $this->getCustomer();
  314.         return $customer != false;
  315.     }
  316.     
  317.     public function isElite() {
  318.         $customer = $this->getCustomer();
  319.         return $customer && $customer->hasEliteDiscount();
  320.     }
  321.     
  322.     public function log($action='')
  323.     {
  324.         $customer = $this->getCustomer();
  325.         if($customer===false)
  326.             return;
  327.         $log = new \App\Entity\CustomerLog();
  328.         $log->setCustomer($customer);
  329.         $log->setDate(new \DateTime());
  330.         $log->setAction($action);
  331.         $this->em->persist($log);
  332.         $this->em->flush();
  333.     }
  334.     
  335.     private function getToken(\App\Entity\Customer $customer)
  336.     {
  337.         return md5($customer->getId()."-".$customer->getEmail()."-".$this->key);
  338.     }
  339.     
  340.     private function checkToken(\App\Entity\Customer $customer)
  341.     {
  342.         return $this->session->get('customer_token') === $this->getToken($customer);
  343.     }
  344.     
  345.     /**
  346.      * Colonne 1 = Code client Synoptic
  347.      * Colonne 2 = Nom réduit
  348.      * Colonne 3 = Raison sociale
  349.      * Colonne 4 = Code tarif du client
  350.      * Colonne 5 = Code remise du client
  351.      */
  352.     public function importDiscountFromCsv($csvFile) {
  353.         if(!file_exists($csvFile))
  354.             throw new \Exception('File not found');
  355.         if (($handle = fopen($csvFile, "r")) !== FALSE) {
  356.             $row = 0;
  357.             while (($data = fgetcsv($handle, null, ";")) !== FALSE) {
  358.                 $customers = $this->em->getRepository('App:Customer')->findBySynopticId($data[0]);
  359.                 foreach($customers as $customer){
  360.                     $customer->setPriceCode($data[3]);
  361.                     $customer->setDiscountCode($data[4]);
  362.                     $this->em->persist($customer);
  363.                     $this->em->flush();
  364.                 }
  365.             }
  366.             fclose($handle);
  367.         }
  368.     }
  369.     
  370.     public function canSeePrices() {
  371.         if(!$this->isLogged())
  372.             return false;
  373.         $customer = $this->getCustomer();
  374.         $status = $customer->getStatus();
  375.         return empty($status) || $status == Customer::STATUS_VALIDATED;
  376.     }
  377.     
  378.     public function validate(Customer $customer, bool $test) {
  379.         $value = $test ? Customer::STATUS_VALIDATED : Customer::STATUS_BLOCKED;
  380.         $customer->setStatus($value);
  381.         $this->em->persist($customer);
  382.         $this->em->flush();
  383.         $this->em->refresh($customer);
  384.         $this->mailer->sendCustomerValidation($customer);
  385.     }
  386.     
  387.     public function anonymize(Customer $customer) {
  388.         $customer->setFirstname('anonyme');
  389.         $customer->setLastname('anonyme');
  390.         $customer->setEmailAddress(uniqid().'@vivog.fr');
  391.         $customer->setCompany('anonyme');
  392.         $this->em->persist($customer);
  393.         $this->em->flush();
  394.     }
  395.     
  396.     
  397. }