From 1ceea67a39dbaa58d72380caacaf7914658aaac2 Mon Sep 17 00:00:00 2001 From: pbarroca <pbarroca@afi-sa.fr> Date: Mon, 24 Mar 2014 16:37:03 +0100 Subject: [PATCH] Code cleaning --- cosmogramme/php/integre_traite_main.php | 139 ++++++++++++------------ 1 file changed, 70 insertions(+), 69 deletions(-) diff --git a/cosmogramme/php/integre_traite_main.php b/cosmogramme/php/integre_traite_main.php index d6d044ecdb5..ca77f6d96ef 100644 --- a/cosmogramme/php/integre_traite_main.php +++ b/cosmogramme/php/integre_traite_main.php @@ -26,29 +26,30 @@ error_reporting(E_ERROR | E_PARSE); // Arguments de la commande en mode cron -if ($argc == 3 or $argc==4) -{ +if ($argc == 3 or $argc==4) { $user = $argv[1]; $passe = $argv[2]; $cron_a_traiter=$argv[3]; - if(!$cron_a_traiter) $cron_a_traiter="all"; + if (!$cron_a_traiter) + $cron_a_traiter = 'all'; $mode_cron = true; } -include("_init_frame.php"); +include '_init_frame.php'; // Includes -if ($mode_cron == true) setVariable("clef_traitements", "0"); // en mode cron : on debloque la base -require_once("classe_chronometre.php"); -require_once("classe_parseur.php"); -require_once("classe_log.php"); -require_once("classe_notice_integration.php"); -require_once("classe_maj_auto.php"); -require_once("classe_bib.php"); +if ($mode_cron == true) + setVariable('clef_traitements', '0'); // en mode cron : on debloque la base +require_once 'classe_chronometre.php'; +require_once 'classe_parseur.php'; +require_once 'classe_log.php'; +require_once 'classe_notice_integration.php'; +require_once 'classe_maj_auto.php'; +require_once 'classe_bib.php'; // Instanciations -$log = new Class_log("integration"); -$log_erreur = new Class_log("erreur", false); -$log_warning = new Class_log("warning", false); +$log = new Class_log('integration'); +$log_erreur = new Class_log('erreur', false); +$log_warning = new Class_log('warning', false); $chrono = new chronometre(); $chrono_fichier = new chronometre(); $chrono100notices = new chronometre(); @@ -57,47 +58,50 @@ $notice = new notice_integration(); $bib = new bibliotheque(); // Initialisations -$integration_path = getVariable("integration_path"); -$debug_level = getVariable("debug_level"); -$nb_afi_retry = getVariable("Z3950_retry_level"); -$compteur = array(); +$integration_path = getVariable('integration_path'); +$debug_level = getVariable('debug_level'); +$nb_afi_retry = getVariable('Z3950_retry_level'); +$compteur = []; $date = dateDuJour(0); $nb_notices = 0; $timeout = intval(ini_get("max_execution_time") * 0.75); -if (!$timeout) $timeout = 25; // Pour le debugger +if (!$timeout) + $timeout = 25; // Pour le debugger $timeStart = time(); $chrono->start(); -$phase = "0"; -$phase_data = array(); +$phase = '0'; +$phase_data = []; // ---------------------------------------------------------------- // Début du traitement // ---------------------------------------------------------------- -if ($_REQUEST["reprise"] == "oui") -{ +if ($_REQUEST['reprise'] == 'oui') { $log->open(true); $log_erreur->open(true); $log_warning->open(true); restaureContext(); $reprise = true; -} -else -{ + +} else { // init variables - setVariable("traitement_erreurs", 0); - setVariable("traitement_warnings", 0); - setVariable("traitement_phase", "Déplacement des fichiers"); + setVariable('traitement_erreurs', 0); + setVariable('traitement_warnings', 0); + setVariable('traitement_phase', 'Déplacement des fichiers'); $log->open(false); $log_erreur->open(false); $log_warning->open(false); $log->ecrire('<h4>Début du traitement</h4>'); - $log->ecrire("Date : " . date("d-m-Y") . BR); - $log->ecrire("Heure : " . date("G:i:s") . BR); - if ($mode_cron == true) $log->ecrire("Mode : automatique (cron)" . BR); else $log->ecrire("Mode : manuel" . BR); - if($cron_a_traiter > '') - { - $txt=array("all"=>"tous types d'imports","tot"=>"imports totaux uniquement","inc"=>"imports incrementiels uniquement"); - $log->ecrire("Type d'import : ".$txt[$cron_a_traiter] . BR); + $log->ecrire('Date : ' . date('d-m-Y') . BR); + $log->ecrire('Heure : ' . date('G:i:s') . BR); + $log->ecrire('Mode : ' + . (($mode_cron == true) ? 'automatique (cron)' : 'manuel') + . BR); + + if ($cron_a_traiter > '') { + $txt = ['all' => 'tous types d\'imports', + 'tot' => 'imports totaux uniquement', + 'inc' => 'imports incrementiels uniquement']; + $log->ecrire('Type d\'import : ' . $txt[$cron_a_traiter] . BR); } // controle du trigger de maj des notices @@ -112,40 +116,38 @@ else "); * */ - // ---------------------------------------------------------------- - // Déplacement des fichiers dans Upload - // ---------------------------------------------------------------- - $log->ecrire("<h4>Déplacement des fichiers à intégrer</h4>"); + $log->ecrire('<h4>Déplacement des fichiers à intégrer</h4>'); $transfert = new maj_auto(); $erreur = $transfert->transfertfichiersFtp(); - if ($erreur) - { - $log->ecrire(BR . BR . '<span class="rouge">' . $erreur . ' : Abandon du traitement !</span><br>'); + if ($erreur) { + $log->ecrire(BR . BR + . '<span class="rouge">' . $erreur . ' : Abandon du traitement !</span><br>'); exit; } - setVariable("integration_date", $date); + setVariable('integration_date', $date); $transfert->supprimerEntetesPergame(); // ---------------------------------------------------------------- // controle si on doit sortir en cas d'import total // ---------------------------------------------------------------- - if($cron_a_traiter > '' and $cron_a_traiter!="all") - { - $controle=fetchOne("select count(*) from integrations,profil_donnees + if ($cron_a_traiter > '' and $cron_a_traiter != 'all') { + $controle = fetchOne("select count(*) from integrations,profil_donnees Where integrations.profil=profil_donnees.id_profil and traite='non' and type_operation=2 and type_fichier=0"); - if($cron_a_traiter=="inc" and $controle>0) - { - $erreur="Il y a un import total à traiter et le cron demande de ne traiter que les imports incrementiels"; - $log->ecrire(BR . BR . '<span class="rouge">' . $erreur . ' : Abandon du traitement !</span><br>'); + + if ($cron_a_traiter == 'inc' and $controle > 0) { + $erreur = 'Il y a un import total à traiter et le cron demande de ne traiter que les imports incrementiels'; + $log->ecrire(BR . BR + . '<span class="rouge">' . $erreur . ' : Abandon du traitement !</span><br>'); exit; } - if($cron_a_traiter=="tot" and $controle==0) - { - $erreur="Il n'y aucun import total à traiter et le cron demande de ne traiter que les imports totaux"; - $log->ecrire(BR . BR . '<span class="rouge">' . $erreur . ' : Abandon du traitement !</span><br>'); + + if ($cron_a_traiter == 'tot' and $controle == 0) { + $erreur = 'Il n\'y aucun import total à traiter et le cron demande de ne traiter que les imports totaux'; + $log->ecrire(BR . BR + . '<span class="rouge">' . $erreur . ' : Abandon du traitement !</span><br>'); exit; } } @@ -153,34 +155,34 @@ else // ---------------------------------------------------------------- // Test blocage de la base // ---------------------------------------------------------------- - $log->ecrire("<h4>Traitement des notices</h4>"); - if (getVariable("clef_traitements") == "1") - { + $log->ecrire('<h4>Traitement des notices</h4>'); + if (getVariable('clef_traitements') == '1') { $log->ecrire('<span class="rouge">La base est bloquée (clef_traitements) : Abandon du traitement !</span><br>'); $log->close(); exit; } - $log->ecrire("Blocage de la base<br>"); - setVariable("clef_traitements", "1"); + $log->ecrire('Blocage de la base<br>'); + setVariable('clef_traitements', '1'); } // ---------------------------------------------------------------- // Integration des notices (PHASE 0) // ---------------------------------------------------------------- -setVariable("traitement_phase", "Intégration des notices"); - +setVariable('traitement_phase', 'Intégration des notices'); $resultat = $sql->prepareListe("select * from integrations Where traite='non' Order by id"); -while ($ligne = $sql->fetchNext($resultat)) -{ + +while ($ligne = $sql->fetchNext($resultat)) { extract($ligne); - $format = $sql->fetchOne("select format from profil_donnees where id_profil=$profil"); - $type_fichier = $sql->fetchOne("select type_fichier from profil_donnees where id_profil=$profil"); + $format = $sql->fetchOne('select format from profil_donnees where id_profil=' . $profil); + $type_fichier = $sql->fetchOne('select type_fichier from profil_donnees where id_profil=' . $profil); // Si autre que notices on passe // if (!$type_fichier || $type_fichier=='') $log->ecrire('<span class="bib">Problème de configuration, pas de type de fichier pour le profil de données: '.$profil.' concernant le fichier: '.$fichier.'</span><br>'); // if ($type_fichier =='' || ($type_fichier > 0 and $type_fichier < 10)) continue; - if ($type_fichier > 0 and $type_fichier < 10) continue; + if ($type_fichier > 0 and $type_fichier < 10) + continue; + $nom_bib = $bib->getNomCourt($id_bib); $libelle_type_operation = getLibCodifVariable("import_type_operation", $type_operation); $trace = '<br><b><span class="vert">' . $nom_bib . " (" . $libelle_type_operation . ")</b></span><br>"; @@ -191,8 +193,7 @@ while ($ligne = $sql->fetchNext($resultat)) if (!$pointeur_reprise) $log->ecrire($trace); else print($trace); // Suppression des exemplaires si export total - if ($type_operation == 2 and !$reprise and !$pointeur_reprise) - { + if ($type_operation == 2 and !$reprise and !$pointeur_reprise) { $log->ecrire(BR . '<span class="violet">Supression des exemplaires</span><br>'); if(filesize($integration_path . $fichier)>0) { -- GitLab