WebSVN – eFlore/Applications.cel – Diff – /trunk/scripts/modules/code_zone_geo/CodeZoneGeo.php


<?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;
	}
}

Subversion Repositories eFlore/Applications.cel

(root)/trunk/scripts/modules/code_zone_geo/CodeZoneGeo.php – Rev 2536 → 2559

Rev 2536		Rev 2559
1	`<?php`	1	`<?php`
2	`// declare(encoding='UTF-8');`	2	`// declare(encoding='UTF-8');`
3	`/**`	3	`/**`
4	`* Traitement des codes INSEE et des codes pays de la base de données CEL`	4	`* Traitement des codes INSEE et des codes pays de la base de données CEL`
5	`* Permet d'affecter des codes INSEE et des codes pays aux obs possédant des coordonnées mais pas de commune ou de pays.`	5	`* Permet d'affecter des codes INSEE et des codes pays aux obs possédant des coordonnées mais pas de commune ou de pays.`
6	`*`	6	`*`
7	`* Utilisation :`	7	`* Utilisation :`
8	`* - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a tout</code>`	8	`* - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a tout</code>`
9	`* - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a colonne</code>`	9	`* - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a colonne</code>`
10	`* - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a payssanscorrespondance</code>`	10	`* - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a payssanscorrespondance</code>`
11	`* - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a codeinseesanscorrespondance</code>`	11	`* - Pour ? : <code>/opt/lamp/bin/php cli.php code_zone_geo -a codeinseesanscorrespondance</code>`
12	`*`	12	`*`
13	`* @category CEL`	13	`* @category CEL`
14	`* @package Scripts`	14	`* @package Scripts`
15	`* @subpackage Zones Geo`	15	`* @subpackage Zones Geo`
16	`* @author Mathias CHOUET <mathias@tela-botanica.org>`	16	`* @author Mathias CHOUET <mathias@tela-botanica.org>`
17	`* @author Aurelien PERONNET <aurelien@tela-botanica.org>`	17	`* @author Aurelien PERONNET <aurelien@tela-botanica.org>`
18	`* @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>`	18	`* @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>`
19	`* @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>`	19	`* @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>`
20	`* @copyright 1999-2014 Tela Botanica <accueil@tela-botanica.org>`	20	`* @copyright 1999-2014 Tela Botanica <accueil@tela-botanica.org>`
21	`*/`	21	`*/`
22	`include_once dirname(__FILE__).'/bibliotheque/Dao.php';`	22	`include_once dirname(__FILE__).'/bibliotheque/Dao.php';`
23		23
24	`class CodeZoneGeo extends Script {`	24	`class CodeZoneGeo extends Script {`
25		25
26	`protected $tableauTaxon;`	26	`protected $tableauTaxon;`
27	`protected $dao;`	27	`protected $dao;`
28	`protected $observations;`	28	`protected $observations;`
29		29
30	`protected $url_service_geo_tpl;`	30	`protected $url_service_geo_tpl;`
31	`protected $url_service_pays_tpl;`	31	`protected $url_service_pays_tpl;`
32		32
33	`protected $mode_verbeux = false;`	33	`protected $mode_verbeux = false;`
34		34
35	`// Paramêtres autorisées lors de l'appel au script en ligne de commande`	35	`// Paramêtres autorisées lors de l'appel au script en ligne de commande`
36	`protected $parametres_autorises = array(`	36	`protected $parametres_autorises = array(`
37	`'-n' => array(true, true, 'Nom du fichier ou du dossier à traiter'));`	37	`'-n' => array(true, true, 'Nom du fichier ou du dossier à traiter'));`
38		38
39	`public function executer() {`	39	`public function executer() {`
40		40