src/Subscriber/Content/ContentRankingSubscriber.php line 43

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\Content;
  5. use App\Entity\ContentRanking;
  6. use App\Event\Content\CommentCreatedEvent;
  7. use App\Event\Content\CommentUpdatedEvent;
  8. use App\Service\Content\CommentService;
  9. use App\Service\Content\RankingService;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class ContentRankingSubscriber implements EventSubscriberInterface
  13. {
  14.     protected RankingService $service;
  16.     protected CommentService $commentService;
  18.     /**
  19.      * CommentSubscriber constructor.
  20.      */
  21.     public function __construct(RankingService $service, CommentService $commentService)
  22.     {
  23.         $this->service = $service;
  24.         $this->commentService = $commentService;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             CommentCreatedEvent::class => [
  31.                 ['onCommentCreatedUpdateContentRankingVotes', 0],
  32.             ],
  33.             CommentUpdatedEvent::class => [
  34.                 ['onCommentUpdatedUpdateContentRankingVotes', 0],
  35.             ],
  36.         ];
  37.     }
  39.     /**
  40.      * @throws \Doctrine\ORM\ORMException
  41.      * @throws \Doctrine\ORM\OptimisticLockException
  42.      */
  43.     public function onCommentCreatedUpdateContentRankingVotes(CommentCreatedEvent $event)
  44.     {
  45.         $this->calculateAndStoreRanking($event);
  46.     }
  48.     /**
  49.      * @param CommentCreatedEvent $event
  50.      *
  51.      * @throws \Doctrine\ORM\ORMException
  52.      * @throws \Doctrine\ORM\OptimisticLockException
  53.      */
  54.     public function onCommentUpdatedUpdateContentRankingVotes(CommentUpdatedEvent $event)
  55.     {
  56.         $this->calculateAndStoreRanking($event);
  57.     }
  59.     /**
  60.      * @throws \Doctrine\ORM\ORMException
  61.      * @throws \Doctrine\ORM\OptimisticLockException
  62.      */
  63.     protected function calculateAndStoreRanking(CommentCreatedEvent|CommentUpdatedEvent $event)
  64.     {
  65.         $content = $event->getComment()->getContent();
  66.         if (!$ranking = $content->getRanking()) {
  67.             $ranking = $this->service->createRankingByContent($content);
  68.         }
  70.         $sums = $this->commentService->getSumsForContent($content);
  72.         $ranking->setCommentCount($sums['comment_count']);
  73.         $ranking->setVotes((int) $sums['vote_count']);
  74.         if ($ranking->getVotes() > 0) {
  75.             $ranking->setVoteAverage($sums['vote_sum'] / $ranking->getVotes());
  76.         }
  78.         $ranking->setRank($this->calculateRankInteger($ranking));
  80.         $this->service->storeRanking($ranking);
  81.     }
  83.     protected function calculateRankInteger(ContentRanking $entity): int
  84.     {
  85.         $rank = 0;
  86.         if ($entity->getVoteAverage()) {
  87.             $rank += $entity->getVoteAverage() * 100;
  88.         }
  89.         if ($entity->getVotes()) {
  90.             $rank += $entity->getVotes() * 20;
  91.         }
  92.         if ($entity->getCommentCount()) {
  93.             $rank += $entity->getCommentCount() * 20;
  94.         }
  95.         if ($entity->getSellCount()) {
  96.             $rank += $entity->getSellCount() * 10;
  97.         }
  98.         // do not consider for now (business logic)
  99.         if (false && $entity->getLikeCount()) {
  100.             $rank += $entity->getLikeCount() * 10;
  101.         }
  102.         if ($entity->getRankModifier()) {
  103.             $rank = $entity * $entity->getRankModifier();
  104.         }
  106.         return $rank;
  107.     }
  108. }