Line 1... |
Line 1... |
1 |
<?php
|
1 |
<?php
|
2 |
// Encodage : UTF-8
|
2 |
// Encodage : UTF-8
|
3 |
// +-------------------------------------------------------------------------------------------------------------------+
|
3 |
// +-------------------------------------------------------------------------------------------------------------------+
|
4 |
/**
|
4 |
/**
|
5 |
* Traitement des fichiers de la banque de données SOPHY pour insertion
|
5 |
* Traitement des codes INSEE de la banque de données cel
|
6 |
*
|
6 |
*
|
7 |
* Description : classe permettant d'insérer les tableaux phytosociologiques de la banque de données SOPHY
|
7 |
* Description : classe permettant d'affecter des codes INSEE aux obs possédant des coordonnées mais pas de commune
|
8 |
* Utilisation : php script.php code -a codeInseeCommune
|
8 |
* Utilisation : php script.php code -a codeInseeCommune
|
9 |
*
|
9 |
*
|
10 |
* @category PHP 5.3
|
10 |
* @category PHP 5.3
|
11 |
* @package phytosocio
|
11 |
* @package phytosocio
|
12 |
//Auteur original :
|
12 |
//Auteur original :
|
13 |
* @author Delphine CAUQUIL <delphine@tela-botanica.org>
|
13 |
* @author Delphine CAUQUIL <delphine@tela-botanica.org>
|
- |
|
14 |
* @author Aurélien PERONNET <aurelien@tela-botanica.org>
|
14 |
* @copyright Copyright (c) 2009, Tela Botanica (accueil@tela-botanica.org)
|
15 |
* @copyright Copyright (c) 2009, Tela Botanica (accueil@tela-botanica.org)
|
15 |
* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL-v3
|
16 |
* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL-v3
|
16 |
* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL-v2
|
17 |
* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL-v2
|
17 |
* @version $Id$
|
18 |
* @version $Id$
|
18 |
*/
|
19 |
*/
|
Line 20... |
Line 21... |
20 |
class Codeinseecommune extends Script {
|
21 |
class Codeinseecommune extends Script {
|
Line 21... |
Line 22... |
21 |
|
22 |
|
22 |
protected $tableauTaxon;
|
23 |
protected $tableauTaxon;
|
23 |
protected $dao;
|
24 |
protected $dao;
|
- |
|
25 |
protected $observations;
|
- |
|
26 |
|
- |
|
27 |
protected $mode_verbeux = false;
|
24 |
protected $observations;
|
28 |
|
25 |
// Paramêtres autorisées lors de l'appel au script en ligne de commande
|
29 |
// Paramêtres autorisées lors de l'appel au script en ligne de commande
|
26 |
protected $parametres_autorises = array(
|
30 |
protected $parametres_autorises = array(
|
Line 27... |
Line 31... |
27 |
'-n' => array(true, true, 'Nom du fichier ou du dossier à traiter'));
|
31 |
'-n' => array(true, true, 'Nom du fichier ou du dossier à traiter'));
|
Line 32... |
Line 36... |
32 |
|
36 |
|
33 |
$this->dao = new Dao();
|
37 |
$this->dao = new Dao();
|
34 |
// Récupération de paramétres
|
38 |
// Récupération de paramétres
|
35 |
// Lancement de l'action demandée
|
39 |
// Lancement de l'action demandée
|
- |
|
40 |
$cmd = $this->getParametre('a');
|
- |
|
41 |
$this->mode_verbeux = $this->getParametre('v');
|
36 |
$cmd = $this->getParametre('a');
|
42 |
|
37 |
switch ($cmd) {
|
43 |
switch ($cmd) {
|
38 |
case 'tout' :
|
44 |
case 'tout' :
|
39 |
// à effectuer manuellement au premier lancement du script
|
45 |
// à effectuer manuellement au premier lancement du script
|
40 |
$this->creerColonne();
|
46 |
$this->creerColonne();
|
41 |
$this->calculerCodeInsee();
|
- |
|
42 |
$this->modifierCodeInsee();
|
47 |
$this->calculerCodesInsee();
|
43 |
break;
|
- |
|
44 |
case 'sanscorrespondance' :
|
- |
|
45 |
// devrait être être l'option utilisée dans le cron quotidien
|
- |
|
46 |
$this->calculerCodeInseeSansCorrespondance();
|
- |
|
47 |
$this->modifierCodeInsee();
|
- |
|
48 |
break;
|
48 |
break;
|
49 |
case 'colonne' :
|
49 |
case 'colonne' :
|
50 |
$this->creerColonne();
|
50 |
$this->creerColonne();
|
51 |
break;
|
51 |
break;
|
- |
|
52 |
case 'sanscorrespondance' :
|
52 |
case 'calculer' :
|
53 |
// devrait être être l'option utilisée dans le cron quotidien (avec l'option -v 0)
|
53 |
$this->calculerCodeInsee();
|
54 |
$this->calculerCodesInseeSansCorrespondance();
|
54 |
break;
|
55 |
break;
|
55 |
case 'modifier' :
|
56 |
case 'calculer' :
|
56 |
$this->modifierCodeInsee();
|
57 |
$this->calculerCodesInsee();
|
57 |
break;
|
58 |
break;
|
58 |
default :
|
59 |
default :
|
59 |
$this->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));
|
60 |
$this->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));
|
60 |
}
|
61 |
}
|
Line 61... |
Line 62... |
61 |
}
|
62 |
}
|
Line 62... |
Line 63... |
62 |
|
63 |
|
63 |
// +-------------------------------------------------------------------------------------------------------------------+
|
64 |
// +-------------------------------------------------------------------------------------------------------------------+
|
64 |
|
65 |
|
Line 65... |
Line 66... |
65 |
private function creerColonne() {
|
66 |
private function creerColonne() {
|
66 |
$this->dao->creerColonneCodeInseeCalculee();
|
67 |
$this->dao->creerColonneCodeInseeCalcule();
|
67 |
}
|
68 |
}
|
68 |
|
69 |
|
Line 69... |
Line 70... |
69 |
private function calculerCodeInseeSansCorrespondance() {
|
70 |
private function calculerCodesInseeSansCorrespondance() {
|
70 |
$liste_coordonnees = $this->dao->rechercherCoordonneesSansCorrespondances();
|
71 |
$liste_coordonnees = $this->dao->rechercherCoordonneesSansCorrespondances();
|
71 |
$this->traiterCoordonnees($liste_coordonnees);
|
72 |
$this->traiterCoordonnees($liste_coordonnees);
|
72 |
}
|
73 |
}
|
Line 73... |
Line 74... |
73 |
|
74 |
|
74 |
private function calculerCodeInsee() {
|
- |
|
75 |
$liste_coordonnees = $this->dao->rechercherCoordonnees();
|
- |
|
76 |
$this->traiterCoordonnees($liste_coordonnees);
|
- |
|
- |
|
75 |
private function calculerCodesInsee() {
|
77 |
}
|
76 |
$liste_coordonnees = $this->dao->rechercherCoordonnees();
|
- |
|
77 |
$this->traiterCoordonnees($liste_coordonnees);
|
78 |
|
78 |
}
|
79 |
private function traiterCoordonnees($liste_coordonnees) {
|
79 |
|
- |
|
80 |
private function traiterCoordonnees($liste_coordonnees) {
|
- |
|
81 |
|
- |
|
82 |
$debut = microtime(true);
|
- |
|
83 |
$nb_coordonnees_modifiees = 0;
|
- |
|
84 |
$nb_coordonnees_ignorees = 0;
|
- |
|
85 |
$total = count($liste_coordonnees);
|
- |
|
86 |
|
- |
|
87 |
if($this->mode_verbeux) {
|
80 |
echo "-------------------------------------------------------------------\n";
|
88 |
echo "-------------------------------------------------------------------\n";
|
81 |
echo " Traitement et calcul des codes INSEE (".count($liste_coordonnees)." coordonnées en tout) ... \n";
|
89 |
echo " Calcul des codes INSEE et modification (".count($liste_coordonnees)." coordonnées en tout) ... \n";
|
82 |
echo "-------------------------------------------------------------------\n";
|
90 |
echo " Enrichissement des champs zone geo et ce_zone_geo vides ... \n";
|
83 |
$debut = microtime(true);
|
91 |
echo "-------------------------------------------------------------------\n";
|
84 |
$i = 0;
|
92 |
}
|
85 |
$total = count($liste_coordonnees);
|
93 |
|
86 |
foreach ($liste_coordonnees as $coordonnees) {
|
94 |
foreach ($liste_coordonnees as $coordonnees) {
|
87 |
if ($this->testerCoordonneesWgsFrance($coordonnees['latitude'], $coordonnees['longitude'])) {
|
95 |
$infos_coord = $this->obtenirInfosPourCoordonnees($coordonnees);
|
- |
|
96 |
if ($infos_coord != null) {
|
88 |
$code_insee = $this->chercherCodeCommune('osm', $coordonnees['latitude'], $coordonnees['longitude']);
|
97 |
$coordonnee_a_traiter = array(
|
- |
|
98 |
'latitude' => $coordonnees['latitude'],
|
89 |
if ($code_insee != "") {
|
99 |
'longitude' => $coordonnees['longitude'],
|
- |
|
100 |
'code_insee' => $infos_coord['code_insee'],
|
90 |
$this->dao->ajouterCodeInseeCalculee($coordonnees['latitude'], $coordonnees['longitude'], $code_insee);
|
101 |
'nom' => $infos_coord['nom']
|
- |
|
102 |
);
|
- |
|
103 |
$this->modifierInformationsGeo($coordonnee_a_traiter);
|
91 |
} else {
|
104 |
$nb_coordonnees_modifiees++;
|
92 |
$code_insee = $this->chercherCodeCommune('lion1906', $coordonnees['latitude'], $coordonnees['longitude']);
|
- |
|
93 |
if ($code_insee != "") {
|
- |
|
94 |
$this->dao->ajouterCodeInseeCalculee($coordonnees['latitude'], $coordonnees['longitude'], $code_insee);
|
- |
|
95 |
}
|
105 |
} else {
|
96 |
}
|
106 |
$nb_coordonnees_ignorees++;
|
97 |
}
|
107 |
}
|
- |
|
108 |
if($this->mode_verbeux) {
|
- |
|
109 |
$this->afficherAvancement(' Coordonnées traitées ', $nb_coordonnees_modifiees);
|
98 |
$i++;
|
110 |
}
|
- |
|
111 |
}
|
99 |
$this->afficherAvancement(' Lignes traitées ', $i);
|
112 |
|
- |
|
113 |
$fin = microtime(true);
|
- |
|
114 |
if($this->mode_verbeux) {
|
100 |
$this->dao->testerActiviteConnection();
|
115 |
echo "\n";
|
101 |
}
|
116 |
echo "-------------------------------------------------------------------\n";
|
- |
|
117 |
echo " Fin de la mise à jour des codes INSEE calculés et de l'enrichissement, \n";
|
- |
|
118 |
echo " ".($fin - $debut)." secondes écoulées \n";
|
- |
|
119 |
echo " ".$nb_coordonnees_modifiees." code insee calculés et modifiés \n";
|
- |
|
120 |
echo " ".$nb_coordonnees_ignorees." coordonnées ignorées \n";
|
- |
|
121 |
echo "-------------------------------------------------------------------\n";
|
- |
|
122 |
echo "\n";
|
- |
|
123 |
}
|
- |
|
124 |
}
|
- |
|
125 |
|
- |
|
126 |
private function obtenirInfosPourCoordonnees($coordonnees) {
|
- |
|
127 |
$infos_coord = null;
|
- |
|
128 |
if ($this->testerCoordonneesWgsFrance($coordonnees['latitude'], $coordonnees['longitude'])) {
|
- |
|
129 |
$infos_coord = $this->chercherInfosCommune('osm', $coordonnees['latitude'], $coordonnees['longitude']);
|
- |
|
130 |
if ($infos_coord == null) {
|
- |
|
131 |
$infos_coord = $this->chercherInfosCommune('lion1906', $coordonnees['latitude'], $coordonnees['longitude']);
|
- |
|
132 |
}
|
- |
|
133 |
}
|
- |
|
134 |
return $infos_coord;
|
- |
|
135 |
}
|
- |
|
136 |
|
- |
|
137 |
private function modifierInformationsGeo($coordonnee_a_traiter) {
|
- |
|
138 |
$this->modifierCodeInseeCalculePourCoordonnees($coordonnee_a_traiter);
|
102 |
echo "\n";
|
139 |
$this->modifierCodeInseeEtZoneGeo($coordonnee_a_traiter);
|
Line 103... |
Line 140... |
103 |
$fin = microtime(true);
|
140 |
}
|
104 |
echo "-------------------------------------------------------------------\n";
|
141 |
|
- |
|
142 |
private function modifierCodeInseeCalculePourCoordonnees($coordonnee_a_traiter) {
|
105 |
echo " Fin du traitement, ".($fin - $debut)." secondes écoulées \n";
|
143 |
$this->dao->testerActiviteConnection();
|
Line 106... |
Line 144... |
106 |
echo "-------------------------------------------------------------------\n";
|
144 |
$this->dao->ajouterCodeInseeCalcule($coordonnee_a_traiter['latitude'], $coordonnee_a_traiter['longitude'], $coordonnee_a_traiter['code_insee']);
|
107 |
echo "\n";
|
145 |
}
|
108 |
}
|
146 |
|
Line 109... |
Line 147... |
109 |
|
147 |
private function modifierCodeInseeEtZoneGeo($coordonnee_a_traiter) {
|
110 |
private function modifierCodeInsee() {
|
148 |
$this->dao->testerActiviteConnection();
|
111 |
$this->dao->modifierCodeInsee();
|
149 |
$this->dao->modifierCodeInseeEtZoneGeo($coordonnee_a_traiter);
|
112 |
}
|
150 |
}
|
- |
|
151 |
|
113 |
|
152 |
private function chercherInfosCommune($projet, $latitude, $longitude) {
|
114 |
private function chercherCodeCommune($projet, $latitude, $longitude) {
|
153 |
$url_service = "www.tela-botanica.org/service:eflore:0.1/{$projet}/nom-commune".
|
Line 115... |
Line 154... |
115 |
$url_service = "www.tela-botanica.org/service:eflore:0.1/{$projet}/nom-commune".
|
154 |
"?lat={$latitude}&lon={$longitude}";
|
116 |
"?lat={$latitude}&lon={$longitude}";
|
155 |
|
Line 117... |
Line 156... |
117 |
|
156 |
$url_service = str_replace(',', '.', $url_service);
|
118 |
$url_service = str_replace(',', '.', $url_service);
|
157 |
$ch = curl_init($url_service);
|
119 |
$ch = curl_init($url_service);
|
158 |
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
120 |
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
159 |
$reponse = curl_exec($ch);
|
121 |
$reponse = curl_exec($ch);
|
160 |
|
122 |
$reponse = $this->traiterReponseServiceCommune($response);
|
161 |
$infos_coord = $this->traiterReponseServiceCommune($reponse);
|
123 |
curl_close($ch);
|
162 |
curl_close($ch);
|
124 |
|
163 |
|
125 |
return $code_insee;
|
164 |
return $infos_coord;
|
- |
|
165 |
}
|
126 |
}
|
166 |
|
127 |
|
167 |
private function traiterReponseServiceCommune($reponse) {
|
128 |
private function traiterReponseServiceCommune($response) {
|
168 |
$retour = null;
|
Line 129... |
Line 169... |
129 |
$code_insee = '';
|
169 |
$reponse = json_decode($reponse);
|
130 |
$reponse = json_decode($reponse);
|
170 |
// cas du service lion 1906 qui peut renvoyer plusieurs communes (on prend la première)
|
131 |
// cas du service lion 1906 qui peut renvoyer plusieurs communes (on prend la première)
|
171 |
if(is_array($reponse)) {
|
Line 147... |
Line 187... |
147 |
}
|
187 |
}
|
148 |
}
|
188 |
}
|
149 |
}
|
189 |
}
|
150 |
return $coord_france;
|
190 |
return $coord_france;
|
151 |
}
|
191 |
}
|
152 |
private function analyserCodeDeptComm($ligneDecoupe) {
|
- |
|
153 |
if (preg_match('/^\d{2}$/', $ligneDecoupe['codeDept'])) {
|
- |
|
154 |
} elseif (preg_match('/^\s{0,1}\d{1,2}\s{0,1}$/',$ligneDecoupe['codeDept'])) {
|
- |
|
155 |
$ligneDecoupe['codeDept'] = str_replace(' ', '0', $ligneDecoupe['codeDept']);
|
- |
|
156 |
} else {
|
- |
|
157 |
$ligneDecoupe['codeDept'] = null;
|
- |
|
158 |
}
|
- |
|
159 |
if (preg_match('/^\d{3}$/', $ligneDecoupe['codeCommune'])) {
|
- |
|
160 |
} elseif (preg_match('/^\s{0,2}\d{1,2,3}\s{0,2}$/', $ligneDecoupe['codeCommune'])) {
|
- |
|
161 |
$ligneDecoupe['codeCommune'] = str_replace(' ', '0', $ligneDecoupe['codeCommune']);
|
- |
|
162 |
} elseif ($ligneDecoupe['codeDept'] == null) {
|
- |
|
163 |
$ligneDecoupe['codeCommune'] = null;
|
- |
|
164 |
} else {
|
- |
|
165 |
$ligneDecoupe['codeCommune'] = '000';
|
- |
|
166 |
}
|
- |
|
167 |
return $ligneDecoupe;
|
- |
|
168 |
}
|
- |
|
169 |
private function analyserCoordGrdParis($ligneDecoupe, $ligne) {
|
- |
|
170 |
if (preg_match('/[\s0]0\.000/', $ligneDecoupe['latitude'], $match)) {
|
- |
|
171 |
$ligneDecoupe['latitude'] = null;
|
- |
|
172 |
$ligneDecoupe['longitude'] = null;
|
- |
|
173 |
} elseif (preg_match('/\d{1,2}\.\d{2,3}/', $ligneDecoupe['latitude'], $match)) {// format souhaité
|
- |
|
174 |
$ligneDecoupe['latitude_wgs'] = round($ligneDecoupe['latitude']*0.9, 7);
|
- |
|
175 |
$ligneDecoupe['longitude_wgs'] = round($ligneDecoupe['longitude']*0.9+2.3372291, 7);
|
- |
|
176 |
} elseif (preg_match('/(\d{2})[\d\s,](\d{3})/', $ligneDecoupe['latitude'], $match)) {//erreur de saisie
|
- |
|
177 |
$ligneDecoupe['latitude'] = $match[1].'.'.$match[2];
|
- |
|
178 |
$ligneDecoupe['latitude_wgs'] = round($ligneDecoupe['latitude']*0.9, 7);
|
- |
|
179 |
$ligneDecoupe['longitude_wgs'] = round($ligneDecoupe['longitude']*0.9 + 2.3372291, 7);
|
- |
|
180 |
} elseif (preg_match('/^[a-zA-Z\s]*[a-zA-Z][a-zA-Z\s]*$/', $ligneDecoupe['latitude'])) {// lat absente + nom long
|
- |
|
181 |
$ligneDecoupe['nomStation'] = rtrim(substr($ligne, 10, 48));
|
- |
|
182 |
$ligneDecoupe['latitude'] = null;
|
- |
|
183 |
$ligneDecoupe['longitude'] = null;
|
- |
|
184 |
} elseif (preg_match('/.[AO].123/', $ligneDecoupe['latitude'], $match)) {
|
- |
|
185 |
$ligneDecoupe['latitude'] = null;
|
- |
|
186 |
$ligneDecoupe['longitude'] = null;
|
- |
|
187 |
} elseif ($ligneDecoupe['latitude'] != null) {
|
- |
|
188 |
$ligneDecoupe['latitude'] = null;
|
- |
|
189 |
$ligneDecoupe['longitude'] = null;
|
- |
|
190 |
}
|
- |
|
191 |
return $ligneDecoupe;
|
- |
|
192 |
}
|
- |
|
193 |
}
|
192 |
}
|
194 |
?>
|
193 |
?>
|
195 |
|
194 |
|