muzich/src/Muzich/CoreBundle/Propagator/EventElement.php

<?php

namespace Muzich\CoreBundle\Propagator;

use Muzich\CoreBundle\Propagator\EventPropagator;
use Muzich\CoreBundle\Entity\Element;
use Muzich\CoreBundle\Actions\User\Event as UserEventAction;
use Muzich\CoreBundle\Actions\User\Reputation as UserReputation;
use Muzich\CoreBundle\Entity\Event;
use Muzich\CoreBundle\Entity\User;
use Muzich\CoreBundle\Managers\CommentsManager;
use Muzich\CoreBundle\Entity\ElementTagsProposition;
use Muzich\CoreBundle\Managers\EventArchiveManager;
use Muzich\CoreBundle\Entity\EventArchive;
use Muzich\CoreBundle\Security\Context as SecurityContext;
use Muzich\CoreBundle\Entity\Playlist;

/**
 * Propagateur d'événement concernant les éléments
 *
 * @author bux
 */
class EventElement extends EventPropagator
{  
  
  /**
   * Cette procédure doit être appelé après l'ajout d'un commentaire sur un 
   * événement. Actuellement il:
   * * Met a jour ou créer un objet événement (nouveau commentaire) pour le
   *   propriétaire de l'élément.
   * * Met a jour ou créer un objet événement (nouveau commentaire) pour les
   *   utilisateurs qui follow cet élément.
   * 
   * @param Element $element 
   */
  public function commentAdded(Element $element, User $user)
  {
    // On avertis le propriétaire si ce n'est pas lui même qui vient de commenter
    if ($user->getId() != $element->getOwner()->getId())
    {
      $uea = new UserEventAction($element->getOwner(), $this->container);
      $event = $uea->proceed(Event::TYPE_COMMENT_ADDED_ELEMENT, $element->getId());
      $this->container->get('doctrine')->getEntityManager()->persist($event);
    }
    
    // Pour chaque utilisateur qui a demandé a être avertis d'un nouveau commentaire
    $cm = new CommentsManager($element->getComments());
    $uids = $cm->getFollowersIds();
    
    if (count($uids))
    {
      $users = $this->container->get('doctrine')->getEntityManager()
        ->getRepository('MuzichCoreBundle:User')
        ->getUsersWithIds($uids)
      ;
      if (count($users))
      {
        foreach ($users as $user_c)
        {
          // On n'avertis pas l'utilisateur de son propre commentaire
          if ($user->getId() != $user_c->getId())
          {
            $uea = new UserEventAction($user_c, $this->container);
            $event = $uea->proceed(Event::TYPE_COMMENT_ADDED_ELEMENT, $element->getId());
            $this->container->get('doctrine')->getEntityManager()->persist($event);
          }
        }
      }
    }
  }
  
  /**
   * Un point a été ajouté par quelqu'un a cet élément
   * Conséquences:
   *  * L'auteur du partage gagne x point de reputation
   *
   * @param Element $element 
   */
  public function onePointAdded(Element $element)
  {
    $ur = new UserReputation($element->getOwner());
    $ur->addPoints(
      $this->container->getParameter('reputation_element_point_value')
    );
  }
  
  /**
   * Un point a été retiré par quelqu'un a cet élément
   * Conséquences:
   *  * L'auteur du partage perd x point de reputation
   *
   * @param Element $element 
   */
  public function onePointRemoved(Element $element)
  {
    $ur = new UserReputation($element->getOwner());
    $ur->removePoints(
      $this->container->getParameter('reputation_element_point_value')
    );
  }
  
  /**
   * L'élément a été ajouté aux favoris d'un utilisateur
   * 
   * @param Element $element 
   */
  public function addedToFavorites(Element $element, User $added_by_user)
  {
    $ur = new UserReputation($element->getOwner());
    $security_context = new SecurityContext($added_by_user);
    if (!$security_context->actionIsAffectedBy(SecurityContext::AFFECT_NO_SCORING, SecurityContext::ACTION_ELEMENT_ADD_TO_FAVORITES))
    {
      $score_action = $this->container->getParameter('reputation_element_favorite_value');
      $ur->addPoints($score_action);
      $element->addPoints($score_action);
      $element->increaseCountFavorited();
    }
    
    $uea = new UserEventAction($element->getOwner(), $this->container);
    $event = $uea->proceed(Event::TYPE_FAV_ADDED_ELEMENT, $element->getId());
    $this->container->get('doctrine')->getEntityManager()->persist($event);
  }
  
  /**
   * L'élément a été retiré des favoris d'un utilisateur
   * 
   * @param Element $element 
   */
  public function removedFromFavorites(Element $element, User $removed_by_user)
  {
    $ur = new UserReputation($element->getOwner());
    $security_context = new SecurityContext($removed_by_user);
    if (!$security_context->actionIsAffectedBy(SecurityContext::AFFECT_NO_SCORING, SecurityContext::ACTION_ELEMENT_ADD_TO_FAVORITES))
    {
      $score_action = $this->container->getParameter('reputation_element_favorite_value');
      $ur->removePoints($score_action);
      $element->removePoints($score_action);
      $element->uncreaseCountFavorited();
    }
  }
  
  public function addedToPlaylist(Element $element, User $added_by_user, Playlist $playlist)
  {
    // On persiste les modifs pour compter correctement
    $this->getEntityManager()->persist($playlist);
    $this->getEntityManager()->flush();
    
    $ur = new UserReputation($element->getOwner());
    $security_context = new SecurityContext($added_by_user);
    if (
        !$security_context->actionIsAffectedBy(SecurityContext::AFFECT_NO_SCORING, SecurityContext::ACTION_PLAYLIST_ADD_ELEMENT) 
        // Qu'une seule fois dans la playlist
        && $playlist->getCountElement($element) == 1
        // Element dans une seule playlist (par la suite ca ne rapporte plus de points)
        && $this->countUserPlaylistWithElement($added_by_user, $element) == 1
        && $element->getOwner()->getId() != $added_by_user->getId()
    )
    {
      $score_action = $this->container->getParameter('reputation_element_added_to_playlist');
      $ur->addPoints($score_action);
      $element->addPoints($score_action);
      $element->increaseCountPlaylisted();
    }
  }
  
  protected function countUserPlaylistWithElement(User $user, Element $element)
  {
    return $this->getEntityManager()->createQueryBuilder()
      ->select('COUNT(p)')
      ->from('MuzichCoreBundle:Playlist', 'p')
      ->where('p.elements LIKE :element_id AND p.owner = :owner_id')
      ->setParameter('owner_id', $user->getId())
      ->setParameter('element_id', '%"id":"'.$element->getId().'"%')
      ->getQuery()
      ->getSingleScalarResult()
    ;
  }
  
  public function removedFromPlaylist(Element $element, User $removed_by_user, Playlist $playlist)
  {
    // On persiste les modifs pour compter correctement
    $this->getEntityManager()->persist($playlist);
    $this->getEntityManager()->flush();
    
    $ur = new UserReputation($element->getOwner());
    $security_context = new SecurityContext($removed_by_user);
    if (
        !$security_context->actionIsAffectedBy(SecurityContext::AFFECT_NO_SCORING, SecurityContext::ACTION_PLAYLIST_REMOVE_ELEMENT) 
        // L'element n'est plus dans la playlist
        && $playlist->getCountElement($element) == 0
        // On ne trouve plus l'element dans ses playlists
        && $this->countUserPlaylistWithElement($removed_by_user, $element) == 0
        && $element->getOwner()->getId() != $removed_by_user->getId()
    )
    {
      $score_action = $this->container->getParameter('reputation_element_added_to_playlist');
      $ur->removePoints($score_action);
      $element->removePoints($score_action);
      $element->uncreaseCountPlaylisted();
    }
  }
  
  /**
   * Des tags viennent d'être proposé a un élément
   *
   * @param Element $element 
   */
  public function tagsProposed(Element $element)
  {
    $uea = new UserEventAction($element->getOwner(), $this->container);
    $event = $uea->proceed(Event::TYPE_TAGS_PROPOSED, $element->getId());
    $this->container->get('doctrine')->getEntityManager()->persist($event);
  }
  
  public function tagsAccepteds(ElementTagsProposition $proposition)
  {
    // On archive le fait que la proposition est été accepté
    $eam = new EventArchiveManager($this->container->get('doctrine')->getEntityManager());
    $eam->add($proposition->getUser(), EventArchive::PROP_TAGS_ELEMENT_ACCEPTED);
    
    // Et on donne des points a l'utilisateur
    $ur = new UserReputation($proposition->getUser());
    $ur->addPoints(
      $this->container->getParameter('reputation_element_tags_element_prop_value')
    );
    $this->container->get('doctrine')->getEntityManager()->persist($proposition->getUser());
  }
  
  /**
   * Intervien lorsque l'évènement est supprimé.
   * Il doit retirer au propriétaire:
   * * Les points de l'élément
   * * Les points du aux mises en favoris
   * 
   * @param Element $element 
   */
  public function elementRemoved(Element $element)
  {
    // L'utilisateur n'a plus droits aux points de l'élément.
    $ur = new UserReputation($element->getOwner());
    $ur->removePoints(
      $element->getPoints() * $this->container->getParameter('reputation_element_point_value')
    );
    
    // Ni aux points liés aux mises en favoris
    $fav = $this->container->get('doctrine')->getEntityManager()->createQuery(
      "SELECT COUNT(f) FROM MuzichCoreBundle:UsersElementsFavorites f"
      . " JOIN f.element e"
      . " WHERE e.owner = :uid AND f.user != :uid AND e.id = :eid"
    )->setParameters(array(
      'uid' => $element->getOwner()->getId(),
      'eid' => $element->getId()
    ))
     ->getScalarResult()      
    ;

    if (count($fav))
    {
      if (count($fav[0]))
      {
        $count_favs = $fav[0][1];
        $ur = new UserReputation($element->getOwner());
        $ur->removePoints(
          $count_favs * $this->container->getParameter('reputation_element_favorite_value')
        );
      }
    }
  }
  
}