ninegate/src/ninegate-1.0/src/Cadoles/CoreBundle/Command/OnlyCommand.php

<?php
namespace Cadoles\CoreBundle\Command;

use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Finder\Finder;
use Symfony\Component\Filesystem\Filesystem;
use Symfony\Component\HttpKernel\KernelInterface;
use Symfony\Component\HttpFoundation\Response;
use Doctrine\DBAL\Connection as DBALConnection;
use Doctrine\ORM\EntityManager;

use Cadoles\CoreBundle\Entity\Niveau01;
use Cadoles\CoreBundle\Entity\Niveau02;
use Cadoles\CoreBundle\Entity\User;
use Cadoles\CoreBundle\Entity\Group;
use Cadoles\CoreBundle\Entity\UserGroup;
use Cadoles\PortalBundle\Entity\Calendar;
use Cadoles\PortalBundle\Entity\Blog;

use Unirest\Request;

global $bdd01;
global $config;


class OnlyCommand extends Command
{
    private $container;
    private $em;
    private $output;
    private $filesystem;
    private $rootlog;
    private $only_activate;
    private $only_sync;
    private $only_url;
    private $only_host;
    private $only_user;
    private $only_password;

    protected function configure()
    {
        $this
            ->setName('Core:Only')
            ->setDescription('Synchronisation Only Office')
            ->setHelp('This command Synchro Only Office for Core')
            ->addArgument('simulate', InputArgument::OPTIONAL, 'true to simulate / false to run')            
            ->addArgument('cronid', InputArgument::OPTIONAL, 'ID Cron Job') 
            ->addArgument('lastchance', InputArgument::OPTIONAL, 'Lastchance to run the cron')              
        ;
    }

    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/";

        $this->writelnred('');
        $this->writelnred('== Core:Only');        
        $this->writelnred('==========================================================================================================');

        setlocale( LC_CTYPE, 'fr_FR' );

        $simulate = $input->getArgument('simulate');
        if($simulate=="") $simulate="true";
        
        if($simulate!="true"&&$simulate!="false") {
            $this->writeln('Paramétre incorrect');
            return;
        }
        $simulate=($simulate=="true");
        
        $this->writeln('');
        if($simulate) $this->writeln('** SIMULATION');
        else $this->writeln('** REEL');

        $this->writeln('');
        $this->writeln('=====================================================');
        $this->writeln('== SYNCHONISATION ONLY OFFICE =======================');
        $this->writeln('=====================================================');
        
        $this->only_activate = $this->container->getParameter("activate_widonlyoffice");
        if(!$this->only_activate) {
            $this->writeln('Synchronisation Only désactivé');
            return 1;
        }

        $this->only_sync = $this->container->getParameter("widonlyoffice_sync");
        if(!$this->only_sync) {
            $this->writeln('Synchronisation Only désactivé');
            return 1;
        }

        $this->only_sync        = true;
        $this->only_url         = $this->container->getParameter("widonlyoffice_url")."/api/2.0/";
        $this->only_host        = str_replace("https://","",str_replace("http://","",$this->container->getParameter("widonlyoffice_url")));

        //$this->only_url         = "https://transnum.oo.ac-dijon.fr"."/api/2.0/";
        //$this->only_host        = "transnum.oo.ac-dijon.fr";

        $this->only_user        = $this->container->getParameter("widonlyoffice_user");
        $this->only_password    = $this->container->getParameter("widonlyoffice_password");

        $this->writeln($this->only_url);
        $this->writeln($this->only_host);
        $this->writeln($this->only_user);
        $this->writeln($this->only_password);

        if($this->only_sync) {
            // Only Office est-il dans le domaine 
            if(stripos($this->only_url,"/")===0)
                $this->only_url="https://".$this->container->getParameter("weburl").$this->only_url;
            $indomaine = (stripos($this->only_url,$this->container->getParameter("weburl"))!==false);

            // Si hors domaine on utilise le proxy si proxy il y a 
            if(!$indomaine) {
                $PROXYactivate = $this->em->getRepository("CadolesCoreBundle:Config")->find("PROXYactivate")->getValue();
                if($PROXYactivate) {
                    $PROXYserver    = $this->em->getRepository("CadolesCoreBundle:Config")->find("PROXYserver")->getValue();
                    $PROXYport      = $this->em->getRepository("CadolesCoreBundle:Config")->find("PROXYport")->getValue();                    
                    \Unirest\Request::proxy($PROXYserver, $PROXYport, CURLPROXY_HTTP, true);
                }
            }
            

            // Authentification à onlyoffice
            $this->writeln('');
            $this->writeln('== AUTHENTIFICATION =================================');
            \Unirest\Request::verifyPeer(false);
            \Unirest\Request::verifyHost(false);
            $headers    = ['Host' => $this->only_host, 'Accept' => 'application/json','Content-Type'=>'application/json'];
            $query      = array('userName' => $this->only_user, 'password' => $this->only_password);
            $body       = \Unirest\Request\Body::json($query);
            
            $response   = \Unirest\Request::post($this->only_url.'/authentication',$headers,$body);
            if($this->koresponse($response)) return 0;
            $token=$response->body->response->token;
            $headers["Authorization"]=$token;
            
            // Synchronisation des utilisateur Only sur l'annuaire
            $this->writeln('');
            $this->writeln('== SYNCHRONISATION ONLY==============================');
            //$response   = \Unirest\Request::get($this->only_url.'/settings/ldap/sync',$headers);
            //if($this->koresponse($response)) return 0;

            // Controler les utilisateur only
            $this->writeln('');
            $this->writeln('== CONTROLE USER ONLY================================');
            $response   = \Unirest\Request::get($this->only_url.'/people',$headers);
            if($this->koresponse($response)) return 0;

            foreach($response->body->response as $onlyuser) {
                $user=$this->em->getRepository("CadolesCoreBundle:User")->findBy(["username"=>$onlyuser->userName]);
                if(!$user) {
                    $this->writelnred("ERREUR ".$onlyuser->userName." existe dans OnlyOffice mais pas dans Ninegate");
                }
            }

            // Controler les utilisateurs ninegate
            $this->writeln('');
            $this->writeln('== CONTROLE USER NINEGATE============================');            
            $users=$this->em->getRepository("CadolesCoreBundle:User")->findAll();
            foreach($users as $user) {
                $response   = \Unirest\Request::get($this->only_url.'/people/'.$user->getUsername(),$headers);
                if($this->koresponse($response)) {
                    $this->writelnred("ERREUR ".$user->getUsername()." existe dans Ninegate mais pas dans OnlyOffice");
                }
            }
        }

        $this->writeln('');
        return 1;
    }

    function koresponse($response) {
        if($response->code>=Response::HTTP_BAD_REQUEST) {
            $this->writelnred("ERREUR ".$response->code);
            if(property_exists($response,"body") && property_exists($response->body,"error")) $this->writelnred("ERREUR ".$response->body->error->message);;
            return true;
        }

        return false;
    }    
    private function writelnred($string) { 
        $this->output->writeln('<fg=red>'.$string.'</>');
        $this->filesystem->appendToFile($this->rootlog.'cron.log', $string."\n");
    }
    private function writeln($string) { 
        $this->output->writeln($string);
        $this->filesystem->appendToFile($this->rootlog.'cron.log', $string."\n");
    }   


}