src/EventSubscriber/NewsfeedVoteAnswerSubscriber.php line 30

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\NewsfeedVoteAnswer;
  6. use Doctrine\ORM\EntityManagerInterface;
  7. use App\Event\NewsfeedVoteAnswerPreRemoveEvent;
  8. use App\Event\NewsfeedVoteAnswerPostPersistEvent;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class NewsfeedVoteAnswerSubscriber implements EventSubscriberInterface
  12. {
  13.     public function __construct(
  14.         private EntityManagerInterface $_em
  15.     ) {}
  17.     public static function getSubscribedEvents(): array
  18.     {
  19.         return [
  20.             NewsfeedVoteAnswerPostPersistEvent::NAME => 'onPostPersist',
  21.             NewsfeedVoteAnswerPreRemoveEvent::NAME => 'onPreRemove',
  22.         ];
  23.     }
  25.     public function onPostPersist(NewsfeedVoteAnswerPostPersistEvent $event)
  26.     {
  27.         $this->calculateTotalVote($event->getObject());
  28.     }
  30.     public function onPreRemove(NewsfeedVoteAnswerPreRemoveEvent $event)
  31.     {
  32.         $this->calculateTotalVote($event->getObject(), true);
  33.     }
  35.     private function calculateTotalVote(NewsfeedVoteAnswer $newsfeedVoteAnswer, $isRemove = false)
  36.     {
  37.         $newsfeed = $newsfeedVoteAnswer->getNewsfeed();
  38.         $totalVotes = $this->_em->getRepository(NewsfeedVoteAnswer::class)
  39.             ->getTotalVotes($newsfeed);
  41.         $votesByOption = [];
  42.         if ($totalVotes) {
  43.             foreach ($totalVotes as $tv) {
  44.                 $votesByOption[$tv['opt']] = $isRemove ? ($tv['total']-1) : $tv['total'];
  45.             }
  46.         }
  48.         $newsfeed->setVoteResult($votesByOption);
  50.         $this->_em->persist($newsfeed);
  51.         $this->_em->flush();
  52.     }
  53. }