svg

src/ninegate-1.0/src/Cadoles/CronBundle/Command/CronexecCommand.php

@@ -0,0 +1,92 @@
+<?php
+
+namespace Cadoles\CronBundle\Command;
+
+use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\ArrayInput;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Filesystem\Filesystem;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\Process\Exception\ProcessFailedException;
+use Symfony\Component\Process\Process;
+
+use Cadoles\CronBundle\Entity\Cron;
+
+class CronexecCommand extends ContainerAwareCommand
+{
+    private $container;
+    private $em;
+    private $output;
+    private $filesystem;
+    private $rootlog;
+
+    protected function configure()
+    {
+        $this
+            ->setName('Cron:Exec')
+            ->setDescription("Executer les commandes présente dans le bus des commandes à exécuter à la volet")
+        ;
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+               
+        $this->container    = $this->getApplication()->getKernel()->getContainer();
+        $this->em           = $this->container->get('doctrine')->getEntityManager();
+        $this->output       = $output;
+        $this->filesystem   = new Filesystem();
+        $this->rootlog      = $this->container->get('kernel')->getRootDir()."/../var/logs/";
+        echo $this->rootlog;
+        // On supprime le fichier de log spécifique à ce script
+        //$this->filesystem->remove($this->rootlog."exec.log");
+        $this->filesystem->dumpFile($this->rootlog.'exec.log', "");
+        $this->filesystem->chown($this->rootlog.'exec.log', "www-data");
+
+        $cronexecs=$this->em->getRepository("CadolesCronBundle:Cronexec")->findAll();
+        if($cronexecs) {
+            $this->writelnred('');
+            $this->writelnred('== Cron:Exec');        
+            $this->writelnred('==========================================================================================================');
+        
+            foreach($cronexecs as $cron) {
+                // Récupération de la commande
+                $command = $this->getApplication()->find($cron->getCommand());
+                
+                // Réccuépration des parametres
+                $jsonparameter=json_decode($cron->getJsonargument(),true);
+
+                // Parametre id du cron actuel
+                $jsonparameter["cronid"]=$cron->getId();
+                $jsonparameter["byexec"]=true;
+
+                // Formater la chaine de parametre
+                $parameter = new ArrayInput($jsonparameter);
+
+                // Executer la commande
+                $returnCode=false;
+                try{
+                    $returnCode = $command->run($parameter, $output);
+                }
+                catch(\Exception $e) { 
+                    $this->writelnred("JOB EN ERREUR"); 
+                } 
+            }
+        }
+        
+        return 1;
+    }
+
+    private function writelnred($string) { 
+        $this->output->writeln('<fg=red>'.$string.'</>');
+        $this->filesystem->appendToFile($this->rootlog.'cron.log', $string."\n");
+        $this->filesystem->appendToFile($this->rootlog.'exec.log', $string."\n");
+    }
+    private function writeln($string) { 
+        $this->output->writeln($string);
+        $this->filesystem->appendToFile($this->rootlog.'cron.log', $string."\n");
+        $this->filesystem->appendToFile($this->rootlog.'exec.log', $string."\n");
+    }  
+}

src/ninegate-1.0/src/Cadoles/CronBundle/Entity/Cronexec.php

@@ -0,0 +1,98 @@
+<?php
+
+namespace Cadoles\CronBundle\Entity;
+
+use Doctrine\ORM\Mapping as ORM;
+use Symfony\Component\Validator\Constraints as Assert;
+
+/**
+ * Cron
+ *
+ * @ORM\Table(name="cronexec")
+ * @ORM\Entity(repositoryClass="Cadoles\CronBundle\Repository\CronexecRepository")
+ */
+class Cronexec
+{
+    /**
+     * @var integer
+     *
+     * @ORM\Column(name="id", type="integer")
+     * @ORM\Id
+     * @ORM\GeneratedValue(strategy="AUTO")
+     */
+    private $id;
+
+    /**
+     * @var string
+     *
+     * @ORM\Column(name="command", type="string", nullable=false)
+     * @Assert\NotBlank()
+     *
+     */
+    private $command;
+
+    /**
+     * @ORM\Column(type="text", nullable=true)
+     */
+    private $jsonargument; 
+
+
+
+    /**
+     * Get id
+     *
+     * @return integer
+     */
+    public function getId()
+    {
+        return $this->id;
+    }
+
+    /**
+     * Set command
+     *
+     * @param string $command
+     *
+     * @return Cronexec
+     */
+    public function setCommand($command)
+    {
+        $this->command = $command;
+
+        return $this;
+    }
+
+    /**
+     * Get command
+     *
+     * @return string
+     */
+    public function getCommand()
+    {
+        return $this->command;
+    }
+
+    /**
+     * Set jsonargument
+     *
+     * @param string $jsonargument
+     *
+     * @return Cronexec
+     */
+    public function setJsonargument($jsonargument)
+    {
+        $this->jsonargument = $jsonargument;
+
+        return $this;
+    }
+
+    /**
+     * Get jsonargument
+     *
+     * @return string
+     */
+    public function getJsonargument()
+    {
+        return $this->jsonargument;
+    }
+}

src/ninegate-1.0/src/Cadoles/CronBundle/Repository/CronexecRepository.php

@@ -0,0 +1,9 @@
+<?php
+
+namespace Cadoles\CronBundle\Repository;
+
+use Doctrine\ORM\EntityRepository;
+
+class CronexecRepository extends EntityRepository
+{
+}

src/ninegate-1.0/src/Cadoles/CronBundle/Resources/views/Cron/exec.html.twig

@@ -0,0 +1,32 @@
+{% extends '@CadolesCore/base.html.twig' %}
+
+{% block pagewrapper %}
+    <h1 class="page-header">JOB EXEC</h1>
+    <br><br>
+    <div class="panel panel-primary">
+        <div class="panel-heading">
+            <i class="fa fa-pencil fa-fw"></i> Logs
+        </div>
+
+        <div class="panel-body">
+        </div>
+    </div>
+{% endblock %}
+
+{% block localjavascript %}
+    function refreshContent() {
+        console.log("refresh");
+        
+        $.ajax({
+            method: "POST",
+            url: "{{ path('cadoles_cron_config_cronexecread') }}",
+            success: function(data, dataType)
+            {
+                $(".panel-body").html(data.replace(/\"/g,"").replace(/\\n/g,"<br>"));
+            }
+        });         
+    };
+
+    var timer=setInterval(refreshContent, 1000);        
+
+{% endblock %}