Evolution #464: Commande refresh elements

src/Muzich/CoreBundle/Command/RefreshEmbedsCommand.php → src/Muzich/CoreBundle/Command/ElementRefreshCommand.php

@@ -10,17 +10,18 @@ use Symfony\Component\Console\Output\OutputInterface;
 
 use Muzich\CoreBundle\Managers\ElementManager;
 
-class RefreshEmbedsCommand extends ContainerAwareCommand
+class ElementRefreshCommand extends ContainerAwareCommand
 {
   protected function configure()
   {
     $this
-      ->setName('elementengine:refresh-embeds')
-      ->setDescription('Actualise les embeds')
+      ->setName('elementengine:refresh')
+      ->setDescription('Actualise les éléments avec les API externes')
       // Dans l'avenir on pourra préciser:
       // - le type
       // - l'élément
       ->addOption('sites', null, InputOption::VALUE_REQUIRED, 'Liste exhaustive des site a traiter')
+//      ->addOption('section', null, InputOption::VALUE_REQUIRED, 'Sections a mettre a jours (all, embed, data, )', 'all')
 //      ->addArgument('sites', InputArgument::OPTIONAL, 'Liste exhaustive des site a traiter')
 //      ->addOption('yell', null, InputOption::VALUE_NONE, 'If set, the task will yell in uppercase letters')
     ;
@@ -32,15 +33,19 @@ class RefreshEmbedsCommand extends ContainerAwareCommand
     $em = $doctrine->getEntityManager();
 
     $output->writeln('#');
-    $output->writeln('## Script de mise a jour des code embeds ##');
+    $output->writeln('## Script de mise a jour des éléments ##');
     $output->writeln('#');
 
     $filter_sites = array();
+    $sql_like = "";
+    $sql_like_parameters = array();
     if (($sites = $input->getOption('sites')))
     {
       foreach (explode(',', $sites) as $site)
       {
         $filter_sites[] = trim($site);
+        $sql_like .= " OR e.url LIKE :site".trim(str_replace('.', '', $site));
+        $sql_like_parameters['site'.trim(str_replace('.', '', $site))] = '%'.$site.'%';
       }
     }
     
@@ -50,8 +55,8 @@ class RefreshEmbedsCommand extends ContainerAwareCommand
     {
       $elements = $em->createQuery(
         "SELECT e FROM MuzichCoreBundle:Element e "
-        . " WHERE e.type IN (:types)"
-      )->setParameter('types', $filter_sites)
+        . " WHERE e.type IN (:types) $sql_like"
+      )->setParameters(array_merge(array('types' => $filter_sites), $sql_like_parameters))
        ->getResult()      
       ;
       $output->writeln('<comment>Utilisation de filtre par site ('.$input->getOption('sites').')</comment>');
@@ -68,6 +73,7 @@ class RefreshEmbedsCommand extends ContainerAwareCommand
     {
       $output->writeln('<info>Prise en charge de "'.$element->getUrl().'" ...</info>');
       $factory = new ElementManager($element, $em, $this->getContainer());
+      $factory->determineType();
       $factory->proceedExtraFields();
       $em->persist($element);
     }

src/Muzich/CoreBundle/Managers/ElementManager.php

@@ -96,7 +96,7 @@ class ElementManager
   /**
    * Determine le type d'objet auquel on a affaire.
    */
-  protected function determineType()
+  public function determineType()
   {
     // On ne prend pas de risque avec le www, on l'enlève
     $url = str_replace('www.', '', $this->element->getUrl());