Subversion Repositories eFlore/Applications.cel

Rev

Rev 2414 | Rev 2536 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
1500 delphine 1 
<?php
2414 jpm 2 
// declare(encoding='UTF-8');
1500 delphine 3 
/**
2533 aurelien 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.
1500 delphine 6 
 *
2414 jpm 7 
 * Utilisation :
2533 aurelien 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>
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>
1500 delphine 12 
 *
2414 jpm 13 
 * @category   CEL
14 
 * @package    Scripts
2533 aurelien 15 
 * @subpackage Zones Geo
2414 jpm 16 
 * @author     Mathias CHOUET <mathias@tela-botanica.org>
17 
 * @author     Aurelien PERONNET <aurelien@tela-botanica.org>
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>
20 
 * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
1500 delphine 21 
 */
2414 jpm 22 
include_once dirname(__FILE__).'/bibliotheque/Dao.php';
23 
 
2533 aurelien 24 
class CodeZoneGeo extends Script {
2414 jpm 25 
 
1500 delphine 26 
	protected $tableauTaxon;
27 
	protected $dao;
28 
	protected $observations;
2533 aurelien 29 
 
30 
	protected $url_service_geo_tpl;
31 
	protected $url_service_pays_tpl;
2414 jpm 32 
 
1523 aurelien 33 
	protected $mode_verbeux = false;
2414 jpm 34 
 
1500 delphine 35 
	// Paramêtres autorisées lors de l'appel au script en ligne de commande
36 
	protected $parametres_autorises = array(
37 
		'-n' => array(true, true, 'Nom du fichier ou du dossier à traiter'));
38 
 
39 
	public function executer() {
2533 aurelien 40 
 
41 
		$this->url_service_geo_tpl = Config::get('urlZoneGeoTpl');
42 
		$this->url_service_pays_tpl = Config::get('urlPaysTpl');
2414 jpm 43 
 
1500 delphine 44 
		$this->dao = new Dao();
45 
		// Récupération de paramétres
46 
		// Lancement de l'action demandée
47 
		$cmd = $this->getParametre('a');
1523 aurelien 48 
		$this->mode_verbeux = $this->getParametre('v');
2414 jpm 49 
 
1500 delphine 50 
		switch ($cmd) {
51 
			case 'tout' :
1517 aurelien 52 
				// à effectuer manuellement au premier lancement du script
1500 delphine 53 
				$this->creerColonne();
2533 aurelien 54 
				$this->calculerToutSansCorrespondanceDepuisLeDebut();
1500 delphine 55 
				break;
56 
			case 'colonne' :
57 
				$this->creerColonne();
58 
				break;
2533 aurelien 59 
			case 'codeinseesanscorrespondance' :
1523 aurelien 60 
				$this->calculerCodesInseeSansCorrespondance();
61 
				break;
2533 aurelien 62 
			case 'codeinseesanscorrespondancedepuisledebut' :
63 
				$this->calculerCodesInseeSansCorrespondanceDepuisLeDebut();
1500 delphine 64 
				break;
2533 aurelien 65 
			case 'payssanscorrespondance' :
66 
				$this->calculerPaysSansCorrespondance();
67 
				break;
68 
			case 'payssanscorrespondancedepuisledebut' :
69 
				$this->calculerPaysSansCorrespondanceDepuisLeDebut();
70 
				break;
71 
			case 'toutsanscorrespondance' :
72 
				// devrait être être l'option utilisée dans le cron quotidien (avec l'option -v 0)
73 
				$this->calculerToutSansCorrespondance();
74 
				break;
75 
			case 'toutsanscorrespondancedepuisLeDebut' :
76 
				$this->calculerToutSansCorrespondanceDepuisLeDebut();
77 
				break;
1500 delphine 78 
			default :
79 
				$this->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));
80 
		}
81 
	}
82 
 
2533 aurelien 83 
	protected function creerColonne() {
1523 aurelien 84 
		$this->dao->creerColonneCodeInseeCalcule();
1500 delphine 85 
	}
2414 jpm 86 
 
2533 aurelien 87 
	protected function calculerCodesInseeSansCorrespondance() {
88 
		$liste_coordonnees = $this->dao->rechercherCoordonneesFrancaisesSansCorrespondances();
1517 aurelien 89 
		$this->traiterCoordonnees($liste_coordonnees);
90 
	}
2533 aurelien 91 
 
92 
	protected function calculerCodesInseeSansCorrespondanceDepuisLeDebut() {
93 
		$liste_coordonnees = $this->dao->rechercherCoordonneesFrancaisesSansCorrespondanceDepuisLeDebut();
94 
		$this->traiterCoordonnees($liste_coordonnees);
95 
	}
96 
 
97 
	protected function calculerPaysSansCorrespondance() {
98 
		$liste_coordonnees = $this->dao->rechercherPaysSansCorrespondance();
99 
		$this->traiterCoordonnees($liste_coordonnees);
100 
	}
101 
 
102 
	protected function calculerPaysSansCorrespondanceDepuisLeDebut() {
103 
		$liste_coordonnees = $this->dao->rechercherPaysSansCorrespondanceDepuisLeDebut();
104 
		$this->traiterCoordonnees($liste_coordonnees);
105 
	}
106 
 
107 
	protected function calculerToutSansCorrespondance() {
108 
		$liste_coordonnees = $this->dao->rechercherToutSansCorrespondance();
109 
		$this->traiterCoordonnees($liste_coordonnees);
110 
	}
2414 jpm 111 
 
2533 aurelien 112 
	protected function calculerToutSansCorrespondanceDepuisLeDebut() {
113 
		$liste_coordonnees = $this->dao->rechercherSansCorrespondanceDepuisLeDebut();
1517 aurelien 114 
		$this->traiterCoordonnees($liste_coordonnees);
115 
	}
2414 jpm 116 
 
1517 aurelien 117 
	private function traiterCoordonnees($liste_coordonnees) {
118 
		$debut = microtime(true);
1523 aurelien 119 
		$nb_coordonnees_modifiees = 0;
120 
		$nb_coordonnees_ignorees = 0;
1517 aurelien 121 
		$total = count($liste_coordonnees);
2414 jpm 122 
 
123 
		if ($this->mode_verbeux) {
1523 aurelien 124 
			echo "-------------------------------------------------------------------\n";
2533 aurelien 125 
			echo "  Calcul des codes INSEE, du code pays et modification (".count($liste_coordonnees)." coordonnées en tout) ... \n";
1523 aurelien 126 
			echo "  Enrichissement des champs zone geo et ce_zone_geo vides ... \n";
127 
			echo "-------------------------------------------------------------------\n";
128 
		}
2414 jpm 129 
 
1500 delphine 130 
		foreach ($liste_coordonnees as $coordonnees) {
1523 aurelien 131 
			$infos_coord = $this->obtenirInfosPourCoordonnees($coordonnees);
132 
			if ($infos_coord != null) {
2533 aurelien 133 
				// Le type renvoyé permet de connaitre ce qu'on peut modifier
134 
				if($infos_coord['type'] == 'france') {
135 
					// Cas d'une commune française
136 
					$coordonnee_a_traiter = array(
137 
						'latitude' => $coordonnees['latitude'],
138 
						'longitude' => $coordonnees['longitude'],
139 
						'code_insee' => $infos_coord['code_insee'],
140 
						'nom' => $infos_coord['nom']
141 
					);
142 
					$this->dao->modifierCodeInseeEtZoneGeo($coordonnee_a_traiter);
143 
				} else if($infos_coord['type'] == 'pays') {
144 
					// Cas d'un lieu à l'étranger
145 
					$coordonnee_a_traiter = array(
146 
							'latitude' => $coordonnees['latitude'],
147 
							'longitude' => $coordonnees['longitude'],
148 
							'code_pays' => $infos_coord['code_pays'],
149 
							'nom' => $infos_coord['nom']
150 
					);
151 
					$this->dao->modifierPays($coordonnee_a_traiter);
152 
				}
1523 aurelien 153 
				$nb_coordonnees_modifiees++;
154 
			} else {
155 
				$nb_coordonnees_ignorees++;
1500 delphine 156 
			}
2414 jpm 157 
			if ($this->mode_verbeux) {
1523 aurelien 158 
				$this->afficherAvancement('  Coordonnées traitées ', $nb_coordonnees_modifiees);
159 
			}
1500 delphine 160 
		}
2414 jpm 161 
 
1517 aurelien 162 
		$fin = microtime(true);
2414 jpm 163 
		if ($this->mode_verbeux) {
1523 aurelien 164 
			echo "\n";
165 
			echo "-------------------------------------------------------------------\n";
2533 aurelien 166 
			echo "  Fin de la mise à jour des codes INSEE calculés, du pays et de l'enrichissement, \n";
1523 aurelien 167 
			echo "  ".($fin - $debut)." secondes écoulées \n";
168 
			echo "  ".$nb_coordonnees_modifiees." code insee calculés et modifiés \n";
169 
			echo "  ".$nb_coordonnees_ignorees." coordonnées ignorées \n";
170 
			echo "-------------------------------------------------------------------\n";
171 
			echo "\n";
172 
		}
1500 delphine 173 
	}
2414 jpm 174 
 
1523 aurelien 175 
	private function obtenirInfosPourCoordonnees($coordonnees) {
176 
		$infos_coord = null;
2533 aurelien 177 
		// Test facile qui permet d'abord de tenter une localisation bien plus rapide si les coordonnées
178 
		// sont dans la bounding box approximative de la France
179 
		if($this->testerCoordonneesWgsFrance($coordonnees['latitude'], $coordonnees['longitude'])) {
1523 aurelien 180 
			$infos_coord = $this->chercherInfosCommune('osm', $coordonnees['latitude'], $coordonnees['longitude']);
181 
			if ($infos_coord == null) {
2533 aurelien 182 
				// Sinon recherche par pays
183 
				$infos_coord = $this->chercherInfosPays($coordonnees['latitude'], $coordonnees['longitude']);
1523 aurelien 184 
			}
2533 aurelien 185 
		} else {
186 
			// Recherche par pays immédiate si en dehors de la bouding box française
187 
			$infos_coord = $this->chercherInfosPays($coordonnees['latitude'], $coordonnees['longitude']);
1523 aurelien 188 
		}
189 
		return $infos_coord;
190 
	}
2414 jpm 191 
 
1523 aurelien 192 
	private function chercherInfosCommune($projet, $latitude, $longitude) {
2533 aurelien 193 
 
194 
		$noms_params = array('{projet}', '{latitude}', '{longitude}');
195 
		$valeurs_params = array($projet, $latitude, $longitude);
196 
 
197 
		$url_service = str_replace($noms_params, $valeurs_params, $this->url_service_geo_tpl);
198 
		$url_service = str_replace(',', '.', $url_service);
2414 jpm 199 
 
1500 delphine 200 
		$ch = curl_init($url_service);
201 
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
202 
		$reponse = curl_exec($ch);
2414 jpm 203 
 
1523 aurelien 204 
		$infos_coord = $this->traiterReponseServiceCommune($reponse);
1518 aurelien 205 
		curl_close($ch);
2414 jpm 206 
 
1523 aurelien 207 
		return $infos_coord;
1518 aurelien 208 
	}
2533 aurelien 209 
 
210 
	private function chercherInfosPays($latitude, $longitude) {
211 
		$noms_params = array('{latitude}', '{longitude}');
212 
		$valeurs_params = array($latitude, $longitude);
213 
		$url_service = str_replace($noms_params, $valeurs_params, $this->url_service_pays_tpl);
214 
		$url_service = str_replace(',', '.', $url_service);
1518 aurelien 215 
 
2533 aurelien 216 
		$ch = curl_init($url_service);
217 
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
218 
		$reponse = curl_exec($ch);
219 
 
220 
		$res = json_decode($reponse, true);
221 
		$retour = null;
222 
 
223 
		if(!empty($res)) {
224 
			// Cas où l'on a recherché des coordonnées en France
225 
			// On en profite pour remplir plus de données
226 
			// que le simple pays si elles sont présentes
227 
			if(isset($res[8]) && isset($res[8]['codeInsee'])) {
228 
				$retour = array(
229 
					'code_insee' => $res[8]['codeInsee'],
230 
					'nom' => $res[8]['intitule'],
231 
					'type' => 'france'
232 
				);
233 
			} else {
234 
				// Cas de la recherche en dehors de France
235 
				// La zone de plus haut niveau est toujours un pays
236 
				// (car le niveau de zone est limité à 2)
237 
				$infos_pays = $res[min(array_keys($res))];
238 
				// La zone de niveau le plus bas est la "localité"
239 
				// la plus précise qu'on a pu trouver
240 
				$infos_localite = $res[max(array_keys($res))];
241 
 
242 
				// Cas où l'on a trouvé un code pays
243 
				if(!empty($infos_pays['codeIso31661'])) {
244 
					$retour = array(
245 
						'code_pays' => $infos_pays['codeIso31661'],
246 
						'nom' => ''
247 
					);
248 
				} elseif(!empty($infos_pays['codeIso31662'])) {
249 
					// Quelquefois la zone de plus haut niveau est une région ou une province
250 
					// heureusement son code est de forme XX-YY ou XX est le code iso du pays !
251 
					$retour = array(
252 
						'code_pays' => substr($infos_pays['codeIso31662'], 0, 2),
253 
						'nom' => ''
254 
					);
255 
				}
256 
 
257 
				// Pas de sens de prendre un nom de localité si on a pas de pays
258 
				if(!empty($retour['code_pays'])) {
259 
					// Type sert à savoir quelle fonction de mise à jour on appellera
260 
					$retour['type'] = 'pays';
261 
					$retour['nom'] = $infos_localite['intitule'];
262 
				}
263 
			}
264 
		}
265 
		return $retour;
266 
	}
267 
 
1523 aurelien 268 
	private function traiterReponseServiceCommune($reponse) {
269 
		$retour = null;
1500 delphine 270 
		$reponse = json_decode($reponse);
1518 aurelien 271 
		// cas du service lion 1906 qui peut renvoyer plusieurs communes (on prend la première)
2414 jpm 272 
		if (is_array($reponse)) {
1518 aurelien 273 
			$reponse = $reponse[0];
274 
		}
1500 delphine 275 
		if (isset($reponse->codeINSEE)) {
2533 aurelien 276 
			// Type sert à savoir quelle fonction de mise à jour on appellera
1523 aurelien 277 
			$retour = array('code_insee' => $reponse->codeINSEE,
2533 aurelien 278 
							'nom' => $reponse->nom,
279 
							'type' => 'france');
2414 jpm 280 
		}
1523 aurelien 281 
		return $retour;
1500 delphine 282 
	}
2533 aurelien 283 
 
284 
	private function testerCoordonneesWgsFrance($latitude, $longitude) {
285 
		$coord_france = false;
286 
		if ($latitude != '' && $longitude != '') {
287 
			if ($latitude < 51.071667 && $latitude > 41.316667) {
288 
				if ($longitude < 9.513333 && $longitude > -5.140278) {
289 
					$coord_france = true;
290 
				}
291 
			}
292 
		}
293 
		return $coord_france;
1500 delphine 294 
	}
2414 jpm 295 
}