src/EventSubscriber/Boutique/CommandeSubscriber.php line 57

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber\Boutique;
  5. use App\Entity\Boutique\AvoirHistorique;
  6. use App\Entity\Boutique\Facture;
  7. use App\Entity\Boutique\ProduitStockBalance;
  8. use App\Entity\User\CagnotteHistorique;
  9. use App\Entity\User\PromotionHistorique;
  10. use App\Manager\Boutique\ProduitStockBalanceManager;
  11. use App\Manager\Boutique\WebserviceManager;
  12. use App\Utils\Toolbox;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use App\Utils\Emails\CommandeEmail;
  15. use App\Entity\Boutique\Produit;
  16. use App\Entity\Boutique\ProduitDeclinaison;
  17. use App\Entity\Boutique\Commande;
  18. use App\Entity\Boutique\CommandeHistorique;
  19. use App\Event\CommandeEvent;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. use Symfony\Component\Routing\RouterInterface;
  23. class CommandeSubscriber implements EventSubscriberInterface
  24. {
  25.     private $em;
  26.     private $commandeEmail;
  27.     private $router;
  28.     private $webserviceManager;
  29.     /**
  30.      * @var ProduitStockBalanceManager
  31.      */
  32.     private $produitStockBalanceManager;
  34.     public function __construct(
  35.         EntityManagerInterface $entityManager,
  36.         CommandeEmail $commandeEmail,
  37.         RouterInterface $router,
  38.         WebserviceManager $webserviceManager,
  39.         ProduitStockBalanceManager $produitStockBalanceManager
  40.     ) {
  41.         $this->em                   = $entityManager;
  42.         $this->commandeEmail        = $commandeEmail;
  43.         $this->router               = $router;
  44.         $this->webserviceManager    = $webserviceManager;
  45.         $this->produitStockBalanceManager = $produitStockBalanceManager;
  46.     }
  48.     public static function getSubscribedEvents()
  49.     {
  50.         return array(
  51.             CommandeEvent::COMMANDE_ENREGISTRER_SUCCESS          => array('onCommandeEnregistrerSuccess', -10),
  52.             CommandeEvent::COMMANDE_ENREGISTRER_STATUT           => array('onCommandeEnregistrerStatut', -10),
  53.             CommandeEvent::COMMANDE_ENREGISTRER_MODEPAIEMENT     => array('onCommandeEnregistrerModepaiement', -10),
  54.         );
  55.     }
  57.     public function onCommandeEnregistrerSuccess(CommandeEvent $event)
  58.     {
  60.     }
  62.     public function onCommandeEnregistrerStatut(CommandeEvent $event)
  63.     {
  64.         $commande   = $event->getCommande();
  65.         $eventUser  = $event->getUser();
  67.         // Création Facture
  68.         if (
  69.             false === $commande->checkStatutHistorique($commande->getStatut()) &&
  70.             $commande->getStatut() == Commande::STATUT_PAIEMENT_ACCEPTE &&
  71.             is_null($commande->getFacture())
  72.         ) {
  73.             $numero = strtoupper(Toolbox::generateRandomString(10));
  75.             $facture = new Facture();
  76.             $facture->setNumero($numero);
  77.             $this->em->persist($facture);
  78.             $this->em->flush();
  80.             $commande->setFacture($facture);
  81.             $this->em->persist($commande);
  82.             $this->em->flush();
  83.         }
  85.         // Création Facture avoir
  86.         if (
  87.             false === $commande->checkStatutHistorique($commande->getStatut()) &&
  88.             ($commande->getStatut() == Commande::STATUT_ANNULEE || $commande->getStatut() == Commande::STATUT_REMBOURSE) &&
  89.             !is_null($commande->getFacture()) &&
  90.             is_null($commande->getFactureAvoir())
  91.         ) {
  92.             $numero = strtoupper(Toolbox::generateRandomString(10));
  94.             $facture = new Facture();
  95.             $facture->setNumero($numero);
  96.             $facture->setIsAvoir(true);
  97.             $this->em->persist($facture);
  98.             $this->em->flush();
  100.             $commande->setFactureAvoir($facture);
  101.             $this->em->persist($commande);
  102.             $this->em->flush();
  103.         }
  105.         // MAJ des ebillets gere par le site
  106.         if (
  107.             false === $commande->checkStatutHistorique($commande->getStatut()) &&
  108.             $commande->getStatut() == Commande::STATUT_PAIEMENT_ACCEPTE &&
  109.             false === $commande->getCommandeAyantDroits()->isEmpty()
  110.         ) {
  111.             $ebilletsEnRupture = [];
  112.             foreach ($commande->getCommandeAyantDroits() as $commandeAyantDroit) {
  113.                 $commandeLigne = $commandeAyantDroit->getCommandeLigne();
  115.                 $entite = $commandeLigne->getProduit();
  116.                 if (!is_null($commandeLigne->getProduitDeclinaison())) {
  117.                     $entite = $commandeLigne->getProduitDeclinaison();
  118.                 }
  120.                 $eanDisponibles = $entite->getProduitEansDisponibles();
  122.                 // Si on a des ebillets dispo en stock
  123.                 if (count($eanDisponibles)) {
  124.                     $produitEan = $eanDisponibles[0];
  125.                     $produitEan->setCommandeAyantDroit($commandeAyantDroit);
  126.                     $produitEan->setUtilise(true);
  127.                     $produitEan->setNom($commandeAyantDroit->getNom());
  128.                     $produitEan->setPrenom($commandeAyantDroit->getPrenom());
  130.                     $this->em->persist($produitEan);
  131.                     $this->em->flush();
  132.                 }
  133.                 else {
  134.                     $commandeAyantDroit->setEbilletManquant(true);
  136.                     $this->em->persist($commandeAyantDroit);
  137.                     $this->em->flush();
  138.                 }
  140.                 // Envoi mails notification pour ebillet (produit)
  141.                 if (
  142.                     is_null($commandeLigne->getProduitDeclinaison()) &&
  143.                     !is_null($commandeLigne->getProduit()->getSeuilAlerteBillet()) &&
  144.                     count($commandeLigne->getProduit()->getProduitEansDisponibles()) <= $commandeLigne->getProduit()->getSeuilAlerteBillet()
  145.                 ) {
  146.                     $ebilletsEnRupture[$commandeLigne->getProduit()->getId().'_0'] = [
  147.                         'produit'       => $commandeLigne->getProduit(),
  148.                         'declinaison'   => null
  149.                     ];
  150.                 }
  152.                 // Envoi mails notification pour ebillet (declinaison)
  153.                 if (
  154.                     !is_null($commandeLigne->getProduitDeclinaison()) &&
  155.                     !is_null($commandeLigne->getProduitDeclinaison()->getSeuilAlerteBillet()) &&
  156.                     count($commandeLigne->getProduitDeclinaison()->getProduitEansDisponibles()) <= $commandeLigne->getProduitDeclinaison()->getSeuilAlerteBillet()
  157.                 ) {
  158.                     $ebilletsEnRupture[$commandeLigne->getProduit()->getId().'_'.$commandeLigne->getProduitDeclinaison()->getId()] = [
  159.                         'produit'       => $commandeLigne->getProduit(),
  160.                         'declinaison'   => $commandeLigne->getProduitDeclinaison(),
  161.                     ];
  162.                 }
  163.             }
  165.             foreach ($ebilletsEnRupture as $ebilletEnRupture) {
  166.                 $this->commandeEmail->alerteStockEbillet($ebilletEnRupture['produit'], $ebilletEnRupture['declinaison']);
  167.             }
  168.         }
  170.         // MAJ de la passation ReducCE
  171.         if (
  172.             false === $commande->checkStatutHistorique($commande->getStatut()) &&
  173.             $commande->getStatut() == Commande::STATUT_PAIEMENT_ACCEPTE &&
  174.             !empty($commande->getNumeroReducCe()) &&
  175.             false === $commande->getPassation()
  176.         ) {
  177.             $response = $this->webserviceManager->passationCommande([
  178.                 'CE_ID'             => getenv('APP_PARTENAIRE_ID'),
  179.                 'commandes_numero'  => $commande->getNumeroReducCe()
  180.             ]);
  182.             $xml = simplexml_load_string($response->PASSATION_COMMANDEResult->any);
  183.             if (isset($xml->NewDataSet->Commande->statut)) {
  184.                 $statut             = (string) $xml->NewDataSet->Commande->statut;
  185.                 $error              = (string) $xml->NewDataSet->Commande->message_erreur;
  186.                 $commandes_numero   = (string) $xml->NewDataSet->Commande->commandes_numero;
  188.                 if ("true" == $statut) {
  189.                     $commande->setPassation(true);
  190.                     $this->em->persist($commande);
  191.                     $this->em->flush();
  192.                 }
  193.                 else {
  194.                     $this->webserviceManager->addLog(
  195.                         'PASSATION_COMMANDEResult',
  196.                         $commande->getId(),
  197.                         $error
  198.                     );
  199.                 }
  200.             }
  201.         }
  203.         // Envoi mail de notification si la commande n'a pas deja ete dans ce statut et que le statut declenche un mail
  204.         if (
  205.             false === $commande->checkStatutHistorique($commande->getStatut()) &&
  206.             in_array($commande->getStatut(), $commande->getStatutEmail())
  207.         ) {
  208.             if ($commande->getStatut() == Commande::STATUT_ATTENTE_CHEQUE)
  209.                 $this->commandeEmail->alerteCommandeAttentePaiementCheque($commande);
  211.             if ($commande->getStatut() == Commande::STATUT_ATTENTE_VIREMENT)
  212.                 $this->commandeEmail->alerteCommandeAttentePaiementVirement($commande);
  214.             if ($commande->getStatut() == Commande::STATUT_ATTENTE_REAPPRO)
  215.                 $this->commandeEmail->alerteCommandeAttenteReapprovisionnement($commande);
  217.             if ($commande->getStatut() == Commande::STATUT_PAIEMENT_ACCEPTE)
  218.                 $this->commandeEmail->alerteCommandePaiementAccepte($commande);
  220.             if ($commande->getStatut() == Commande::STATUT_PAIEMENT_ERREUR)
  221.                 $this->commandeEmail->alerteCommandePaiementErreur($commande);
  223.             if ($commande->getStatut() == Commande::STATUT_ENCOURS_PREPA)
  224.                 $this->commandeEmail->alerteCommandeEnCoursPreparation($commande);
  226.             if (
  227.                 $commande->getStatut() == Commande::STATUT_ENCOURS_LIVRAISON ||
  228.                 $commande->getStatut() == Commande::STATUT_EXPEDIE_ENTREPRISE ||
  229.                 $commande->getStatut() == Commande::STATUT_EXPEDIE_DOMICILE ||
  230.                 $commande->getStatut() == Commande::STATUT_EXPEDIE_PARTIELLE_ENTREPRISE ||
  231.                 $commande->getStatut() == Commande::STATUT_EXPEDIE_PARTIELLE_DOMICILE
  232.             ) {
  233.                 $this->commandeEmail->alerteCommandeEnCoursLivraison($commande);
  234.             }
  236.             if (
  237.                 $commande->getStatut() == Commande::STATUT_LIVRAISON_ENTREPRISE ||
  238.                 $commande->getStatut() == Commande::STATUT_LIVRAISON_PARTIELLE_ENTREPRISE
  239.             ) {
  240.                 $this->commandeEmail->alerteCommandeLivre($commande);
  241.             }
  243.             if (
  244.                 $commande->getStatut() == Commande::STATUT_RETRAIT_AGENCE ||
  245.                 $commande->getStatut() == Commande::STATUT_RETRAIT_AGENCE_PARTIEL
  246.             ) {
  247.                 $this->commandeEmail->alerteCommandeRetraitAgence($commande);
  248.             }
  250.             if ($commande->getStatut() == Commande::STATUT_ANNULEE)
  251.                 $this->commandeEmail->alerteCommandeAnnulee($commande);
  253.             if ($commande->getStatut() == Commande::STATUT_REMBOURSE)
  254.                 $this->commandeEmail->alerteCommandeRemboursement($commande);
  256.             if ($commande->getStatut() == Commande::STATUT_REMBOURSE_PARTIEL)
  257.                 $this->commandeEmail->alerteCommandeRemboursementPartiel($commande);
  259.             if ($commande->getStatut() == Commande::STATUT_CREDIT_PARTIEL)
  260.                 $this->commandeEmail->alerteCommandeRemboursementPartiel($commande);
  262.             if ($commande->getStatut() == Commande::STATUT_LIVRE)
  263.                 $this->commandeEmail->alerteCommandeLivre($commande);
  265.             if ($commande->getStatut() == Commande::STATUT_COMMERCIAL_BIENVENUE)
  266.                 $this->commandeEmail->alerteCommercialBienvenue($commande);
  268.             if ($commande->getStatut() == Commande::STATUT_COMMERCIAL_PARRAINAGE)
  269.                 $this->commandeEmail->alerteCommercialParrainage($commande);
  271.             if ($commande->getStatut() == Commande::STATUT_COMMERCIAL_EVALUATION)
  272.                 $this->commandeEmail->alerteCommercialEvaluation($commande);
  274.             if ($commande->getStatut() == Commande::STATUT_COMMERCIAL_PROMOTION)
  275.                 $this->commandeEmail->alerteCommercialPromotion($commande);
  277.             if ($commande->getStatut() == Commande::STATUT_PAIEMENT_PARTIEL_ACCEPTE)
  278.                 $this->commandeEmail->alerteCommandePaiementPartielAccepte($commande);
  280.             if ($commande->getStatut() == Commande::STATUT_COMMANDE_ADMIN) {
  281.                 $adminToken = $commande->generateAdminToken();
  282.                 $commande->setAdminToken($adminToken);
  284.                 $this->em->persist($commande);
  285.                 $this->em->flush();
  287.                 $this->commandeEmail->alerteCommandeAdmin($commande);
  288.             }
  289.         }
  291.         // MAJ des avoirs
  292.         if (
  293.             false === $commande->checkStatutHistorique($commande->getStatut()) &&
  294.             in_array($commande->getStatut(), $commande->getDebitAvoir()) &&
  295.             false === $commande->checkStatutPaiementAttente() &&
  296.             true === $commande->getUtiliserAvoir() &&
  297.             !is_null($commande->getMontantAvoir())
  298.         ) {
  299.             if ($commande->getStatut() == Commande::STATUT_ANNULEE || $commande->getStatut() == Commande::STATUT_REMBOURSE) {
  300.                 $avoirHistoriques = $commande->getAvoirHistoriques();
  302.                 foreach ($avoirHistoriques as $avoirHistorique) {
  303.                     $avoir = $avoirHistorique->getAvoir();
  305.                     $nouveauSolde = ($avoir->getReste() + $avoirHistorique->getMontant());
  306.                     $avoir->setReste($nouveauSolde);
  307.                     $this->em->persist($avoir);
  309.                     $newAvoirHistorique = clone ($avoirHistorique);
  310.                     $newAvoirHistorique->setOperation(AvoirHistorique::OPERATION_CREDIT);
  311.                     $this->em->persist($newAvoirHistorique);
  312.                 }
  314.                 $this->em->flush();
  315.             }
  316.             else {
  317.                 $avoirADebiter = $commande->getMontantAvoir();
  319.                 foreach ($commande->getAvoirUtilises() as $avoir) {
  320.                     if ($avoir->getReste() > 0) {
  321.                         $avoirHistorique = new AvoirHistorique();
  322.                         $avoirHistorique->setOperateur($commande->getUser());
  323.                         $avoirHistorique->setAvoir($avoir);
  324.                         $avoirHistorique->setCommande($commande);
  325.                         $avoirHistorique->setOperation(AvoirHistorique::OPERATION_DEBIT);
  327.                         $nouveauSolde = ($avoir->getReste() - $avoirADebiter);
  329.                         if ($nouveauSolde >= 0) {
  330.                             $avoirHistorique->setMontant($avoirADebiter);
  331.                             $avoirADebiter = 0;
  332.                             $avoir->setReste($nouveauSolde);
  333.                         }
  334.                         else {
  335.                             $avoirHistorique->setMontant($avoir->getReste());
  336.                             $avoirADebiter -= $avoir->getReste();
  337.                             $avoir->setReste(0);
  338.                         }
  340.                         $avoir->addAvoirHistorique($avoirHistorique);
  342.                         $this->em->persist($avoir);
  343.                         $this->em->flush();
  345.                         if (0 == $avoirADebiter) {
  346.                             break;
  347.                         }
  348.                     }
  349.                 }
  350.             }
  351.         }
  353.         // MAJ de la cagnotte CSE
  354.         if (
  355.             false === $commande->checkStatutHistorique($commande->getStatut()) &&
  356.             in_array($commande->getStatut(), $commande->getDebitCagnotte()) &&
  357.             false === $commande->checkStatutPaiementAttente() &&
  358.             true === $commande->getUtiliserCagnotte() &&
  359.             !is_null($commande->getMontantCagnotte())
  360.         ) {
  361.             $user = $commande->getUser();
  363.             if ($commande->getStatut() == Commande::STATUT_ANNULEE || $commande->getStatut() == Commande::STATUT_REMBOURSE) {
  364.                 $nouveauMontantCagnotte = ($user->getCagnotte() + $commande->getMontantCagnotte());
  365.                 $user->setCagnotte($nouveauMontantCagnotte);
  366.                 $operation = CagnotteHistorique::OPERATION_CREDIT;
  367.             } else {
  368.                 $nouveauMontantCagnotte = ($user->getCagnotte() - $commande->getMontantCagnotte());
  369.                 $user->setCagnotte($nouveauMontantCagnotte);
  370.                 $operation = CagnotteHistorique::OPERATION_DEBIT;
  371.             }
  373.             $cagnotteHistorique = new CagnotteHistorique();
  374.             $cagnotteHistorique->setOperation($operation);
  375.             $cagnotteHistorique->setUser($user);
  376.             $cagnotteHistorique->setMontant($commande->getMontantCagnotte());
  377.             $cagnotteHistorique->setOperateur($user);
  378.             $cagnotteHistorique->setCommande($commande);
  380.             if (false === $user->getGroups()->isEmpty()) {
  381.                 $cagnotteHistorique->setGroup($user->getGroups()->first());
  382.             }
  384.             if (!is_null($commande->getPromotion())) {
  385.                 $cagnotteHistorique->setPromotion($commande->getPromotion());
  386.             }
  388.             $user->addCagnotteHistorique($cagnotteHistorique);
  390.             $this->em->persist($user);
  391.             $this->em->flush();
  392.         }
  394.         // MAJ subventions
  395.         if (
  396.             false === $commande->checkStatutHistorique($commande->getStatut()) &&
  397.             in_array($commande->getStatut(), $commande->getDebitSubvention()) &&
  398.             false === $commande->checkStatutPaiementAttente()
  399.         ) {
  400.             if (
  401.                 $commande->getStatut() == Commande::STATUT_ANNULEE ||
  402.                 $commande->getStatut() == Commande::STATUT_REMBOURSE ||
  403.                 $commande->getStatut() == Commande::STATUT_REMBOURSE_PARTIEL ||
  404.                 $commande->getStatut() == Commande::STATUT_CREDIT_PARTIEL
  405.             ) {
  406.                 $operation = PromotionHistorique::OPERATION_CREDIT;
  407.             }
  408.             else {
  409.                 $operation = PromotionHistorique::OPERATION_DEBIT;
  410.             }
  412.             $user = $commande->getUser();
  414.             foreach ($commande->getLignes() as $ligne) {
  415.                 if (!is_null($ligne->getPromotion())) {
  416.                     $dateUtilisationAt = $ligne->getCreatedAt();
  417.                     if ($operation == PromotionHistorique::OPERATION_CREDIT) {
  418.                         $dateUtilisationAt = new \DateTime();
  419.                     }
  421.                     $promotionHistorique = new PromotionHistorique();
  422.                     $promotionHistorique->setUser($user);
  423.                     $promotionHistorique->setOperateur($user);
  424.                     $promotionHistorique->setCommande($commande);
  425.                     $promotionHistorique->setCommandeLigne($ligne);
  426.                     $promotionHistorique->setDateUtilisationAt($dateUtilisationAt);
  427.                     $promotionHistorique->setPromotion($ligne->getPromotion());
  428.                     $promotionHistorique->setOperation($operation);
  430.                     if (false === $user->getGroups()->isEmpty()) {
  431.                         $promotionHistorique->setGroup($user->getGroups()->first());
  432.                     }
  434.                     if (
  435.                         ($commande->getStatut() == Commande::STATUT_REMBOURSE_PARTIEL || $commande->getStatut() == Commande::STATUT_CREDIT_PARTIEL) &&
  436.                         (!is_null($ligne->getQuantiteRetourne()) || !is_null($ligne->getMontantRembourse()))
  437.                     ) {
  438.                         if (!is_null($ligne->getMontantRembourse())) {
  439.                             $promotionHistorique->setMontant($ligne->getMontantRembourse());
  440.                         }
  442.                         if (!is_null($ligne->getQuantiteRetourne())) {
  443.                             $promotionHistorique->setQuantite($ligne->getQuantiteRetourne());
  444.                         }
  446.                         $commande->addPromotionHistorique($promotionHistorique);
  447.                     }
  449.                     if (
  450.                         $commande->getStatut() != Commande::STATUT_REMBOURSE_PARTIEL &&
  451.                         $commande->getStatut() != Commande::STATUT_CREDIT_PARTIEL
  452.                     ) {
  453.                         $promotionHistorique->setMontant($ligne->getMontantRemise() * $ligne->getQuantite());
  454.                         $promotionHistorique->setQuantite($ligne->getQuantite());
  456.                         $commande->addPromotionHistorique($promotionHistorique);
  457.                     }
  458.                 }
  459.             }
  461.             $this->em->persist($commande);
  462.             $this->em->flush();
  463.         }
  465.         // MAJ du stock si la commande n'a pas deja ete dans ce statut et que le statut declenche une MAJ du stock
  466.         if (
  467.             false === $commande->checkStatutHistorique($commande->getStatut()) &&
  468. //            false === $commande->checkStatutPaiementAttente() &&
  469.             in_array($commande->getStatut(), $commande->getStatutMajStock())
  470.         ) {
  471.             $this->produitStockBalanceManager->updateStockByCommande($commande);
  472.         }
  474.         // Ajout dans table historique
  475.         $commandeHistorique = new CommandeHistorique();
  476.         $commandeHistorique->setCommande($commande);
  477.         $commandeHistorique->setUser($eventUser);
  478.         $commandeHistorique->setStatut($commande->getStatut());
  479.         $commande->addCommandeHistorique($commandeHistorique);
  481.         $this->em->persist($commande);
  482.         $this->em->flush();
  483.     }
  485.     public function onCommandeEnregistrerModepaiement(CommandeEvent $event)
  486.     {
  488.     }
  489. }