src/Command/ImportChorusCommand.php line 20

Open in your IDE?
  1. <?php 
  2. namespace App\Command;
  4. use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
  6. use Symfony\Component\Console\Command\Command;
  7. use Symfony\Component\Console\Input\InputInterface;
  8. use Symfony\Component\Console\Output\OutputInterface;
  9. use Symfony\Component\Console\Input\InputArgument;
  10. use Symfony\Component\DependencyInjection\ContainerInterface;
  11. use Doctrine\ORM\Query\ResultSetMappingBuilder;
  12. use Doctrine\ORM\Query\ResultSetMapping;
  13. use Symfony\Component\Console\Style\SymfonyStyle;
  15. use Symfony\Component\Process\Process;
  16. use Symfony\Component\Process\Exception\ProcessFailedException;
  17. use Symfony\Component\Filesystem\Filesystem;
  20. class ImportChorusCommand extends ContainerAwareCommand
  21. {
  22.     private $container;
  23.     private $nb_thread;
  24.     private $my_argument_name;
  25.     
  26.     protected function configure()
  27.     {
  28.         $this
  29.         // the name of the command (the part after "bin/console")
  30.         ->setName('delef:import:chorus')
  31.         
  32.         // the short description shown while running "php bin/console list"
  33.         ->setDescription('Import Chorus database')
  34.         
  35.         // the full command description shown when running the command with
  36.         // the "--help" option
  37.         ->setHelp('');
  38.         
  39.         //add an argument to the task
  40.         //$this->addArgument('extension', InputArgument::REQUIRED, 'my_argument_name');
  41.         
  42.     }
  43.     
  44.     public function __construct(ContainerInterface $container)
  45.     {
  46.         // best practices recommend to call the parent constructor first and
  47.         // then set your own properties. That wouldn't work in this case
  48.         // because configure() needs the properties set in this constructor
  49.         //$this->requirePassword = $requirePassword;
  50.     
  51.         parent::__construct();
  52.         $this->container = $container;
  53.         
  54.     }
  57.     protected function execute(InputInterface $input, OutputInterface $output)
  58.     {
  59.         $io = new SymfonyStyle($input, $output);
  60.         
  61.         
  62.         //$this->my_argument_name = $input->getArgument('my_argument_name');
  63.         $io->title('Import des données chorus');
  64.         
  65.         //$file_url="https://chorus-pro.gouv.fr/cpp/static/far0037/courant/FAR0037.zip";
  66.         $file_url="https://cpro.chorus-pro.gouv.fr/cpp/static/far0037/courant/FAR0037.zip";
  67.         $io->note('url : '.$file_url);
  68.         $filesystem = new Filesystem();
  69.         $filesystem->mkdir('./var/chorus', 0700);
  70.         
  71.         $filesystem->remove(['./var/chorus/FAR0037.zip']);
  72.         $filesystem->remove(['./var/chorus/extract/']);
  74.         $ch = curl_init();
  75.         curl_setopt($ch, CURLOPT_URL, $file_url);
  76.         curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
  77.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  78.         $data = curl_exec ($ch);
  79.         $error = curl_error($ch);
  80.         curl_close ($ch);
  82.         if(!empty($error)){
  83.             $io->error($error);
  84.             exit;
  85.         }else{
  86.             $io->text('Fichier correctement téléchargé.');
  87.             $file = fopen('./var/chorus/FAR0037.zip', "w+");
  88.             fputs($file, $data);
  89.             fclose($file);
  90.         }
  91.         
  92.         $zip = new \ZipArchive;
  93.         if ($zip->open('./var/chorus/FAR0037.zip') === TRUE) {
  94.             $filesystem->mkdir('./var/chorus/extract/', 0700);
  95.             $zip->extractTo('./var/chorus/extract/');
  96.             $zip->close();
  97.             $files = scandir('./var/chorus/extract/');
  98.             
  99.         } else {
  100.            $io->error("Le fichier './var/chorus/FAR0037.zip' ne peux pas être ouvert.");
  101.            exit;
  102.         }
  103.         
  104.         if(count($files)!=3){
  105.             $io->error("Impossible de détecter le fichier xml");
  106.             exit;
  107.         }else{
  108.             $xml_file=$files[2];
  109.             $io->text('Fichier trouvé : '.$xml_file);
  110.         }
  111.      
  112.         $string=file_get_contents('./var/chorus/extract/'.$xml_file);
  113.         $xml = simplexml_load_string($string);
  114.         
  115.         //print_r($xml->CPPStructurePartenaireUnitaire);
  116.         
  117.         $number_items=count($xml);
  118.         $io->text('Nombre d\'enregistrements : '.$number_items);
  119.         $io->section('Insertion en base');
  120.         $io->progressStart($number_items);
  121.         
  122.         $cn = $this->container->get('doctrine')->getManager()->getConnection();
  123.         
  124.         $stmt = $cn->prepare("TRUNCATE `chorus`");
  125.         $stmt->execute();
  126.         $stmt = $cn->prepare("SET autocommit=0");
  127.         $stmt->execute();
  128.         $stmt = $cn->prepare("SET unique_checks=0;");
  129.         $stmt->execute();
  130.         $stmt = $cn->prepare("SET foreign_key_checks=0;");
  131.         $stmt->execute();
  132.         foreach($xml as $t=>$i){
  133.             $type_identifiant    = @$i->TypeIdentifiant;
  134.             $identifiant        = @$i->Identifiant;
  135.             $raison_sociale      = @$i->RaisonSociale;
  136.             $adresse            = @$i->AdressePostale->Adresse;
  137.             $code_postal         = @$i->AdressePostale->CodePostal;
  138.             $ville              = @$i->AdressePostale->Ville;
  139.             $pays_code          = @$i->AdressePostale->Pays->Code;
  140.             $pays_libelle       = @$i->AdressePostale->Pays->Libelle;
  141.             $emetteur_edi        = @$i->EmetteurEdi=="true"?1:0;;
  142.             $recepteur_edi       = @$i->RecepteurEdi=="true"?1:0;
  143.             $gestion_statut_mise_en_paiement = @$i->GestionStatutMiseEnPaiement=="true"?1:0;
  144.             $gestion_engagement  = @$i->GestionEngagement=="true"?1:0;
  145.             $gestion_service     = @$i->GestionService=="true"?1:0;
  146.             $gestion_service_engagement=@$i->GestionServiceEngagement=="true"?1:0;
  147.             $est_MOA             = @$i->EstMOA=="true"?1:0;
  148.             $est_MOA_uniquement   = @$i->EstMOAUniquement=="true"?1:0;
  149.             $structure_active    = @$i->StructureActive=="true"?1:0;
  150.             //19974578700010
  151.             if(!empty($i->Services->Service)){
  152.                 foreach($i->Services->Service as $s){
  153.                    /* if($s->Code!="FACTURES_PUBLIQUES")
  154.                     {*/
  155.                         $service_code           = $s->Code;
  156.                         $service_nom            = $s->Nom;
  157.                         $service_gestion_EGMT   = $s->GestionEGMT=="true"?1:0;
  158.                         $service_service_actif  = $s->ServiceActif=="true"?1:0;
  159.                         
  160.                         
  161.                         $sql="INSERT INTO `chorus` (`id`, `type_identifiant`, `identifiant`, `raison_sociale`, `adresse`, `code_postal`, `ville`, `pays_code`, `pays_libelle`, `service_code`, `service_nom`, `service_gestion_egmt`, `service_service_actif`, `emetteur_edi`, `recepteur_edi`, `gestion_statut_mise_en_paiement`, `gestion_engagement`, `gestion_service`, `gestion_service_engagement`, `est_moa`, `est_moa_uniquement`, `structure_active`) VALUES (
  162.                             NULL,
  163.                             :type_identifiant,
  164.                             :identifiant,
  165.                             :raison_sociale,
  166.                             :adresse,
  167.                             :code_postal,
  168.                             :ville,
  169.                             :pays_code,
  170.                             :pays_libelle,
  171.                             :service_code,
  172.                             :service_nom,
  173.                             :service_gestion_EGMT,
  174.                             :service_service_actif,
  175.                             :emetteur_edi,
  176.                             :recepteur_edi,
  177.                             :gestion_statut_mise_en_paiement,
  178.                             :gestion_engagement,
  179.                             :gestion_service,
  180.                             :gestion_service_engagement,
  181.                             :est_MOA,
  182.                             :est_MOA_uniquement,
  183.                             :structure_active
  184.                             );";
  185.                         $stmt = $cn->prepare($sql);
  186.                         $stmt->execute(array(
  187.                             'type_identifiant' => $type_identifiant,
  188.                             'identifiant' => $identifiant,
  189.                             'raison_sociale' => $raison_sociale,
  190.                             'adresse' => $adresse,
  191.                             'code_postal' => $code_postal,
  192.                             'ville' => $ville,
  193.                             'pays_code' => $pays_code,
  194.                             'pays_libelle' => $pays_libelle,
  195.                             'service_code' => $service_code,
  196.                             'pays_libelle' => $pays_libelle,
  197.                             'service_code' => $service_code,
  198.                             'service_nom' => $service_nom,
  199.                             'service_gestion_EGMT' => $service_gestion_EGMT,
  200.                             'service_service_actif' => $service_service_actif,
  201.                             'emetteur_edi' => $emetteur_edi,
  202.                             'recepteur_edi' => $recepteur_edi,
  203.                             'gestion_statut_mise_en_paiement' => $gestion_statut_mise_en_paiement,
  204.                             'gestion_engagement' => $gestion_engagement,
  205.                             'gestion_service' => $gestion_service,
  206.                             'gestion_service_engagement' => $gestion_service_engagement,
  207.                             'est_MOA' => $est_MOA,
  208.                             'est_MOA_uniquement' => $est_MOA_uniquement,
  209.                             'structure_active' => $structure_active,
  210.                     
  211.                         ));
  212.                    /* }   */
  213.                 }
  214.             }
  215.             $io->progressAdvance();
  216.         }
  217.         $stmt = $cn->prepare("COMMIT;");
  218.         $stmt->execute();
  219.         $stmt = $cn->prepare("SET unique_checks=1;");
  220.         $stmt->execute();
  221.         $stmt = $cn->prepare("SET foreign_key_checks=1;");
  222.         $stmt->execute();
  223.         $io->progressFinish();
  224.        
  225.     }
  226. }
  227. ?>