Symfony Profiler

<?php
namespace App\EventSubscriber;
use App\Event\CreditEvent;
use App\Event\OrderEvent;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\Mailer\MailerInterface;
use Symfony\Bridge\Twig\Mime\TemplatedEmail;
use App\Entity\ShopOrder;
use App\Entity\UserEleveCredit;
use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Lock\LockFactory;
class OrderEventSubscriber implements EventSubscriberInterface
{
private $logger;
private $dispatcher;
private array $cachers = array();
public function __construct(
private LockFactory $locker,
\Psr\Log\LoggerInterface $lifecycleLogger,
private EntityManagerInterface $entityManager,
private MailerInterface $mailer,
\App\Cacher\PreSetCacher $cacher,
UserEventSubscriber $UserEventSubscriber
)
{
$this->dispatcher = new \Symfony\Component\EventDispatcher\EventDispatcher();
$this->dispatcher->addSubscriber($UserEventSubscriber);
$this->logger = $lifecycleLogger;
$cacher->setItemName('commande');
$this->cachers['order'] = clone $cacher;
$cacher->setItemName('eleve');
$this->cachers['eleve'] = clone $cacher;
$cacher->setItemName('lifecycle');
$this->cachers['lifecycle'] = clone $cacher;
}
public static function getSubscribedEvents() : array
{
return [
OrderEvent::CONFIRMED => 'onOrderConfirmed',
];
}
public function onOrderConfirmed(OrderEvent $event)
{
#à bug aléatoire, solution aléatoire
sleep(rand(0,3));
$shopOrder = $event->getShopOrder();
// Log the event
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'shopOrder'=>['id'=>$shopOrder->getId(), 'reference'=>$shopOrder->getReference(), 'total'=>$shopOrder->getTotal()],
]);
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'lock'=>'acquiring',
]);
$lock = $this->locker->createLock('order:'.$shopOrder->getReference());
$locked = $lock->acquire(true);
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'lock'=>'acquired',
'locked'=>$locked,
]);
// $e = new \Exception;
$trace = '';
// $trace = print_r($e->getTraceAsString(),true);
$trace .= '#locked '.print_r($locked,true);
$trace .= '#_GET '.print_r($_GET,true);
$trace .= '#_POST '.print_r($_POST,true);
$trace .= '#_SERVER '.print_r($_SERVER,true);
// $trace .= '#Request '.print_r(Request::createFromGlobals()->getContent(),true);
// $trace .= '#lock '.print_r($lock,true);
$this->mailer->send((new TemplatedEmail())
->to('gabriel@pyreweb.com')
->subject('Locker')
->textTemplate('maildebug.txt.twig')
->context([
'texte'=>$shopOrder->getReference().' has a locker?'.PHP_EOL.$trace,
])
);
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'status shopOrder'=>$shopOrder->getStatus()->getCode(),
]);
if ($shopOrder->getStatus()->getCode() == 'success') {
// $this->mailAdminAboutError($shopOrder, 'La commande n°'.$shopOrder->getReference().' a déjà été payée.');
throw new \Error('La commande n°'.$shopOrder->getReference().' a déjà été payée.');
}
$user = $event->getUser();
$entityManager = $this->entityManager;
$ShopOrderStatus = $entityManager->getRepository(\App\Entity\ShopOrderStatus::class)->findOneBy(['code'=>'success']);
$shopOrder->setStatus($ShopOrderStatus);
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'status'=>$ShopOrderStatus->getCode(),
]);
//liste des crédits utilisateurs non flushés
$UserEleveCredits = new \Doctrine\Common\Collections\ArrayCollection();
// Traitement des éléments de la commande
/** @var \App\Entity\ShopOrderProduct */
foreach($shopOrder->getshopOrderProducts() as $shopOrderProduct) {
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'shopOrderProduct'=>[
'id'=>$shopOrderProduct->getId(),
'intitule'=>$shopOrderProduct->getIntitule(),
'categorie'=>$shopOrderProduct->getCategorie()->getIntitule(),
'points'=>$shopOrderProduct->getPoints(),
'quantite'=>$shopOrderProduct->getQuantite(),
]
]);
//Mise à jour des crédits utilisateur
// La catégorie des crédits utilisateur concernée existe-elle ?
$cat = $entityManager->getRepository(UserEleveCredit::class);
$UserEleveCredit = $cat->findOneWithShopOrderProduct($shopOrderProduct);
if($UserEleveCredit == null) {
// On vérifie s'il y a une catégorie pas encore flushée pour le user
$UserEleveCredit = $UserEleveCredits->filter(function($UserEleveCredit) use ($shopOrderProduct) {
return $UserEleveCredit->getCategorie() == $shopOrderProduct->getCategorie();
})->first();
if(!$UserEleveCredit) {
$UserEleveCredit = null;
}
}
// Elle n'existe pas pour ce User, on la crée
if($UserEleveCredit == null) {
$UserEleveCredit = new UserEleveCredit();
$UserEleveCredit->setUser($user);
$UserEleveCredit->setCategorie($shopOrderProduct->getCategorie());
}
// On ajoute les points
$UserEleveCredit->addPoints($shopOrderProduct->getTotalPoints());
$entityManager->persist($UserEleveCredit);
$UserEleveCredits->add($UserEleveCredit);
$event = new CreditEvent($UserEleveCredit);
$event->setMovedPoints($shopOrderProduct->getTotalPoints());
$this->dispatcher->dispatch($event, CreditEvent::ADDED);
}
$entityManager->persist($shopOrder);
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'flushed'=>'pending',
]);
$entityManager->flush();
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'flushed'=>'done',
]);
$lock->release();
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'lock'=>'released',
]);
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'cache emptying'=>'lifecycle',
]);
// Delete the cache entries
$this->cachers['lifecycle']->empty();
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'cache emptied'=>'lifecycle',
]);
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'cache emptying'=>'eleve',
'index'=>['id'=>$user->getId(), 'email'=>$user->getEmail()],
]);
$this->cachers['eleve']->delete($user);
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'cache emptied'=>'eleve',
'index'=>['id'=>$user->getId(), 'email'=>$user->getEmail()],
]);
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'cache emptying'=>'order',
'index'=>['id'=>$shopOrder->getId(), 'reference'=>$shopOrder->getReference()],
]);
$this->cachers['order']->delete($shopOrder);
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'cache emptied'=>'order',
'index'=>['id'=>$shopOrder->getId(), 'reference'=>$shopOrder->getReference()],
]);
$this->cachers['order']->delete('count');
$this->logger->info(OrderEvent::CONFIRMED.' '.$shopOrder->getReference(), [
'cache emptied'=>'order',
'index'=>'count',
]);
$this->mailAdminAboutConfirmation($shopOrder);
$this->mailUserAboutConfirmation($shopOrder);
}
protected function mailAdminAboutError(ShopOrder $shopOrder, string $erreur){
$this->mailer->send((new TemplatedEmail())
->subject('Erreur sur une Commande')
->htmlTemplate('admin/mail/order_error.html.twig')
->context([
'commande'=>$shopOrder,
'erreur'=>$erreur
])
);
}
protected function mailAdminAboutConfirmation(ShopOrder $shopOrder){
$this->mailer->send((new TemplatedEmail())
->subject('Commande confirmée')
->htmlTemplate('admin/mail/order_confirmed.html.twig')
->context([
'commande'=>$shopOrder,
])
);
}
protected function mailUserAboutConfirmation(ShopOrder $shopOrder){
$this->mailer->send((new TemplatedEmail())
->to($shopOrder->getUser()->getEmail())
->subject('Commande confirmée')
->htmlTemplate('eleve/mail/order_confirmed.html.twig')
->context([
'commande'=>$shopOrder,
])
);
}
}

src/EventSubscriber/OrderEventSubscriber.php line 49