Subversion Repositories eFlore/Applications.cel

<?php
// declare(encoding='UTF-8');
/**
 * Traitement des codes INSEE et des codes pays de la base de données CEL
 * Permet d'affecter des codes INSEE et des codes pays aux obs possédant des coordonnées mais pas de commune ou de pays.
 *
 * Utilisation :
 * - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a tout</code>
 * - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a colonne</code>
 * - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a payssanscorrespondance</code>
 * - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a codeinseesanscorrespondance</code>
 *
 * @category   CEL
 * @package    Scripts
 * @subpackage Zones Geo
 * @author     Mathias CHOUET <mathias@tela-botanica.org>
 * @author     Aurelien PERONNET <aurelien@tela-botanica.org>
 * @license    GPL v3 <http://www.gnu.org/licenses/gpl.txt>
 * @license    CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
 * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
 */
include_once dirname(__FILE__).'/bibliotheque/Dao.php';

class CodeZoneGeo extends Script {

        protected $tableauTaxon;
        protected $dao;
        protected $observations;
        
        protected $url_service_geo_tpl;
        protected $url_service_pays_tpl;

        protected $mode_verbeux = false;

        // Paramêtres autorisées lors de l'appel au script en ligne de commande
        protected $parametres_autorises = array(
                '-n' => array(true, true, 'Nom du fichier ou du dossier à traiter'));

        public function executer() {
                
                $this->url_service_geo_tpl = Config::get('urlZoneGeoTpl');
                $this->url_service_pays_tpl = Config::get('urlPaysTpl');

                $this->dao = new Dao();
                // Récupération de paramétres
                // Lancement de l'action demandée
                $cmd = $this->getParametre('a');
                $this->mode_verbeux = $this->getParametre('v');

                switch ($cmd) {
                        case 'tout' :
                                // à effectuer manuellement au premier lancement du script
                                $this->creerColonne();
                                $this->calculerToutSansCorrespondanceDepuisLeDebut();
                                break;
                        case 'colonne' :
                                $this->creerColonne();
                                break;
                        case 'codeinseesanscorrespondance' :
                                $this->calculerCodesInseeSansCorrespondance();
                                break;
                        case 'codeinseesanscorrespondancedepuisledebut' :
                                $this->calculerCodesInseeSansCorrespondanceDepuisLeDebut();
                                break;
                        case 'payssanscorrespondance' :
                                $this->calculerPaysSansCorrespondance();
                                break;  
                        case 'payssanscorrespondancedepuisledebut' :
                                $this->calculerPaysSansCorrespondanceDepuisLeDebut();
                                break;
                        case 'toutsanscorrespondance' :
                                // devrait être être l'option utilisée dans le cron quotidien (avec l'option -v 0)
                                $this->calculerToutSansCorrespondance();
                                break;
                        case 'toutsanscorrespondancedepuisledebut' :
                                $this->calculerToutSansCorrespondanceDepuisLeDebut();
                                break;
                        default :
                                $this->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));
                }
        }

        protected function creerColonne() {
                $this->dao->creerColonneCodeInseeCalcule();
        }

        protected function calculerCodesInseeSansCorrespondance() {
                $liste_coordonnees = $this->dao->rechercherCoordonneesFrancaisesSansCorrespondances();
                $this->traiterCoordonnees($liste_coordonnees);
        }
        
        protected function calculerCodesInseeSansCorrespondanceDepuisLeDebut() {
                $liste_coordonnees = $this->dao->rechercherCoordonneesFrancaisesSansCorrespondanceDepuisLeDebut();
                $this->traiterCoordonnees($liste_coordonnees);
        }
        
        protected function calculerPaysSansCorrespondance() {
                $liste_coordonnees = $this->dao->rechercherPaysSansCorrespondance();
                $this->traiterCoordonnees($liste_coordonnees);
        }
        
        protected function calculerPaysSansCorrespondanceDepuisLeDebut() {
                $liste_coordonnees = $this->dao->rechercherPaysSansCorrespondanceDepuisLeDebut();
                $this->traiterCoordonnees($liste_coordonnees);
        }
        
        protected function calculerToutSansCorrespondance() {
                $this->affecterPaysFranceAuxCommunes();
                $liste_coordonnees = $this->dao->rechercherToutSansCorrespondance();
                $this->traiterCoordonnees($liste_coordonnees);
        }

        protected function calculerToutSansCorrespondanceDepuisLeDebut() {
                $this->affecterPaysFranceAuxCommunes();
                $liste_coordonnees = $this->dao->rechercherSansCorrespondanceDepuisLeDebut();
                $this->traiterCoordonnees($liste_coordonnees);
        }
        
        protected function affecterPaysFranceAuxCommunes() {
                if ($this->mode_verbeux) {
                        echo "-------------------------------------------------------------------\n";
                        echo "  Affectation du pays France aux communes ayant un code INSEE mais pas de pays ... ";
                }
                
                $maj = $this->dao->affecterPaysFranceAuxCommunesRenseignees();
                
                if ($this->mode_verbeux) {
                        echo "OK \n";
                        echo "  ".$maj." commune".($maj > 1 ? 's' : '')." affectée".($maj > 1 ? 's' : '')."\n";
                        echo "-------------------------------------------------------------------\n";
                }
        }

        private function traiterCoordonnees($liste_coordonnees) {
                $debut = microtime(true);
                $nb_coordonnees_modifiees = 0;
                $nb_coordonnees_ignorees = 0;
                $total = count($liste_coordonnees);

                if ($this->mode_verbeux) {
                        echo "-------------------------------------------------------------------\n";
                        echo "  Calcul des codes INSEE, du code pays et modification (".count($liste_coordonnees)." coordonnées en tout) ... \n";
                        echo "  Enrichissement des champs zone geo et ce_zone_geo vides ... \n";
                        echo "-------------------------------------------------------------------\n";
                }

                foreach ($liste_coordonnees as $coordonnees) {
                        $infos_coord = $this->obtenirInfosPourCoordonnees($coordonnees);
                        if ($infos_coord != null) {
                                // Le type renvoyé permet de connaitre ce qu'on peut modifier
                                if($infos_coord['type'] == 'france') {
                                        // Cas d'une commune française
                                        $coordonnee_a_traiter = array(
                                                'latitude' => $coordonnees['latitude'],
                                                'longitude' => $coordonnees['longitude'],
                                                'code_insee' => $infos_coord['code_insee'],
                                                'nom' => $infos_coord['nom']
                                        );
                                        $this->dao->modifierCodeInseeEtZoneGeo($coordonnee_a_traiter);
                                } else if($infos_coord['type'] == 'pays') {
                                        // Cas d'un lieu à l'étranger
                                        $coordonnee_a_traiter = array(
                                                        'latitude' => $coordonnees['latitude'],
                                                        'longitude' => $coordonnees['longitude'],
                                                        'code_pays' => $infos_coord['code_pays'],
                                                        'nom' => $infos_coord['nom']
                                        );
                                        $this->dao->modifierPays($coordonnee_a_traiter);
                                }
                                $nb_coordonnees_modifiees++;
                        } else {
                                $nb_coordonnees_ignorees++;
                        }
                        if ($this->mode_verbeux) {
                                $this->afficherAvancement('  Coordonnées traitées ', $nb_coordonnees_modifiees);
                        }
                }

                $fin = microtime(true);
                if ($this->mode_verbeux) {
                        echo "\n";
                        echo "-------------------------------------------------------------------\n";
                        echo "  Fin de la mise à jour des codes INSEE calculés, du pays et de l'enrichissement, \n";
                        echo "  ".($fin - $debut)." secondes écoulées \n";
                        echo "  ".$nb_coordonnees_modifiees." code insee calculés et modifiés \n";
                        echo "  ".$nb_coordonnees_ignorees." coordonnées ignorées \n";
                        echo "-------------------------------------------------------------------\n";
                        echo "\n";
                }
        }

        private function obtenirInfosPourCoordonnees($coordonnees) {
                $infos_coord = null;
                // Test facile qui permet d'abord de tenter une localisation bien plus rapide si les coordonnées 
                // sont dans la bounding box approximative de la France
                if($this->testerCoordonneesWgsFrance($coordonnees['latitude'], $coordonnees['longitude'])) {
                        $infos_coord = $this->chercherInfosCommune('osm', $coordonnees['latitude'], $coordonnees['longitude']);
                        if ($infos_coord == null) {
                                // Sinon recherche par pays
                                $infos_coord = $this->chercherInfosPays($coordonnees['latitude'], $coordonnees['longitude']);
                        }
                } else {
                        // Recherche par pays immédiate si en dehors de la bouding box française
                        $infos_coord = $this->chercherInfosPays($coordonnees['latitude'], $coordonnees['longitude']);
                }
                return $infos_coord;
        }

        private function chercherInfosCommune($projet, $latitude, $longitude) {
                
                $noms_params = array('{projet}', '{latitude}', '{longitude}');
                $valeurs_params = array($projet, $latitude, $longitude);
                
                $url_service = str_replace($noms_params, $valeurs_params, $this->url_service_geo_tpl);
                $url_service = str_replace(',', '.', $url_service);

                $ch = curl_init($url_service);
                curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
                $reponse = curl_exec($ch);

                $infos_coord = $this->traiterReponseServiceCommune($reponse);
                curl_close($ch);

                return $infos_coord;
        }
        
        private function chercherInfosPays($latitude, $longitude) {
                $noms_params = array('{latitude}', '{longitude}');
                $valeurs_params = array($latitude, $longitude);
                $url_service = str_replace($noms_params, $valeurs_params, $this->url_service_pays_tpl);
                $url_service = str_replace(',', '.', $url_service);

                $ch = curl_init($url_service);
                curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
                $reponse = curl_exec($ch);
                
                $res = json_decode($reponse, true);
                $retour = null;
                
                if(!empty($res)) {
                        // Cas où l'on a recherché des coordonnées en France
                        // On en profite pour remplir plus de données
                        // que le simple pays si elles sont présentes
                        if(isset($res[8]) && isset($res[8]['codeInsee'])) {
                                $retour = array(
                                        'code_insee' => $res[8]['codeInsee'],
                                        'nom' => $res[8]['intitule'],
                                        'type' => 'france'
                                );
                        } else {
                                // Cas de la recherche en dehors de France
                                // La zone de plus haut niveau est toujours un pays 
                                // (car le niveau de zone est limité à 2)
                                $infos_pays = $res[min(array_keys($res))];
                                // La zone de niveau le plus bas est la "localité"
                                // la plus précise qu'on a pu trouver
                                $infos_localite = $res[max(array_keys($res))];
        
                                // Cas où l'on a trouvé un code pays
                                if(!empty($infos_pays['codeIso31661'])) {
                                        $retour = array(
                                                'code_pays' => $infos_pays['codeIso31661'], 
                                                'nom' => ''
                                        );
                                } elseif(!empty($infos_pays['codeIso31662'])) {
                                        // Quelquefois la zone de plus haut niveau est une région ou une province
                                        // heureusement son code est de forme XX-YY ou XX est le code iso du pays !
                                        $retour = array(
                                                'code_pays' => substr($infos_pays['codeIso31662'], 0, 2), 
                                                'nom' => ''
                                        );
                                }
                                
                                // Pas de sens de prendre un nom de localité si on a pas de pays
                                if(!empty($retour['code_pays'])) {
                                        // Type sert à savoir quelle fonction de mise à jour on appellera
                                        $retour['type'] = 'pays';
                                        $retour['nom'] = $infos_localite['intitule'];
                                }
                        }
                }
                return $retour;
        }

        private function traiterReponseServiceCommune($reponse) {
                $retour = null;
                $reponse = json_decode($reponse);
                // cas du service lion 1906 qui peut renvoyer plusieurs communes (on prend la première)
                if (is_array($reponse)) {
                        $reponse = $reponse[0];
                }
                if (isset($reponse->codeINSEE)) {
                        // Type sert à savoir quelle fonction de mise à jour on appellera
                        $retour = array('code_insee' => $reponse->codeINSEE,
                                                        'nom' => $reponse->nom,
                                                        'type' => 'france');
                }
                return $retour;
        }
        
        private function testerCoordonneesWgsFrance($latitude, $longitude) {
                $coord_france = false;
                if ($latitude != '' && $longitude != '') {
                        if ($latitude < 51.071667 && $latitude > 41.316667) {
                                if ($longitude < 9.513333 && $longitude > -5.140278) {
                                        $coord_france = true;
                                }
                        }
                }
                return $coord_france;
        }
}