Subversion Repositories eFlore/Projets.eflore-projets

Rev

Rev 392 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
167 jpm 1
<?php
392 jpm 2
/**
3
 * Exemple lancement:
4
 * /opt/lampp/bin/php -d memory_limit=3500M cli.php osm/mise_a_jour -a MAJ -f fichier_osm_a_analyser
5
 */
167 jpm 6
class MiseAjour extends Script {
7
	private $communes = array();
8
	private $relations_communes = array();
9
	private $relation_a_chemins = array();
10
	private $chemin_a_noeuds = array();
11
	private $noeuds = array();
12
	private $pas = 10000;
13
	private $pas_commune = 1000;
392 jpm 14
 
167 jpm 15
	protected $parametres_autorises = array(
16
	'-f' => array(true, null, 'Chemin du fichier osm à analyser'));
17
 
18
	public function executer() {
19
		$this->bdd = new Bdd();
20
 
21
		// Lancement de l'action demandée
22
		$cmd = $this->getParametre('a');
23
	    switch ($cmd) {
24
			case 'MAJ' :
25
				$this->MettreAjour();
26
				break;
27
				default :
28
				$this->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));
29
		}
30
    }
392 jpm 31
 
32
 
167 jpm 33
	/**
34
	 * Fonction permettant de traiter et d'analyser le fichier de différence et de mettre  à jour la base de données
35
	 * en tenant compte des trois cas:Suppression, Création ,modification
36
	*/
37
	private function MettreAjour() {
38
		$lecteur = new XMLReader();
39
		if ($lecteur->open($this->getParametre('f'))) {
40
			$dom = new DomDocument();
41
			while ($lecteur->read()) {
42
				if ($lecteur->nodeType == XMLREADER::ELEMENT) {
43
					if ($lecteur->localName == 'create') {
44
						$creations = $lecteur->expand();
45
						$this->	analyserCreations($creations);
392 jpm 46
					}
167 jpm 47
					if ($lecteur->localName == 'modify') {
48
						$modifications = $lecteur->expand();
49
						$this->	analyserModifications($modifications);
392 jpm 50
					}
167 jpm 51
					if ($lecteur->localName == 'delete') {
52
						$suppressions = $lecteur->expand();
53
						$this->	analyserSuppressions($suppressions);
392 jpm 54
					}
167 jpm 55
				}
56
			}
57
		} else {
58
			$e = "Impossible d'ouvrir le fichier osm : %s";
59
			$this->traiterErreur($e, array($this->getParametre('f')));
60
		}
61
	}
392 jpm 62
 
167 jpm 63
	/**
64
	 * Fonction permettant le traitement du cas création concernant les relations, ways et les noeuds.
65
	 */
66
	private function analyserCreations($creations) {
67
		$relations = $creations->getElementsByTagName('relation');
68
		foreach ($relations as $relation) {
69
			$this-> analyserRelation($relation);
70
			if (count($this->relation_a_chemins) > $this->pas) {
71
				$this->insererRelationAChemins();
72
			}
73
			if (count($this->relations_communes) > $this->pas_commune) {
74
				$this->insererRelationsCommunes();
75
			}
76
		}
77
		$ways = $creations->getElementsByTagName('way');
78
		foreach ($ways as $way) {
79
			$this->analyserWay($way);
80
			if (count($this->chemin_a_noeuds) > $this->pas) {
81
				$this->insererCheminANoeuds();
82
			}
83
		}
84
		$noeuds = $creations->getElementsByTagName('node');
85
		foreach ($noeuds as $noeud) {
86
			$this->analyserNode($noeud);
87
			if (count($this->noeuds) > $this->pas) {
88
				$this->insererNoeuds();
89
			}
90
		}
91
		$this->insererRelationsCommunes();
92
		$this->insererRelationAChemins();
93
		$this->insererCheminANoeuds();
94
		$this->insererNoeuds();
95
	}
392 jpm 96
 
167 jpm 97
	/**
98
	 * Fonction permettant le traitement du cas modification concernant les relations, ways et les noeuds.
99
	 */
100
	private function analyserModifications($modifications) {
101
		$relations = $modifications->getElementsByTagName('relation');
102
		foreach ($relations as $relation) {
103
			$this-> analyserRelation($relation);
104
			if (count($this->relation_a_chemins) > $this->pas) {
105
				$this->modifierRelationAChemins();
106
			}
107
			if (count($this->relations_communes) > $this->pas_commune) {
108
				$this->modifierRelationsCommunes();
109
			}
110
		}
111
		$ways = $modifications->getElementsByTagName('way');
112
		foreach ($ways as $way) {
113
			$this->analyserWay($way);
114
			if (count($this->chemin_a_noeuds) > $this->pas) {
115
				$this->modifierCheminANoeuds();
116
			}
117
		}
118
		$noeuds = $modifications->getElementsByTagName('node');
119
		foreach ($noeuds as $noeud) {
120
			$this->analyserNode($noeud);
121
			if (count($this->noeuds) > $this->pas) {
122
				$this->modifierNoeuds();
123
			}
124
		}
125
		$this->modifierRelationsCommunes();
126
		$this->modifierRelationAChemins();
127
		$this->modifierCheminANoeuds();
128
		$this->modifierNoeuds();
129
	}
392 jpm 130
 
167 jpm 131
	/**
132
	 * Fonction permettant le traitement du cas suppression concernant les relations, ways et les noeuds.
133
	 */
134
	private function analyserSuppressions($suppressions) {
135
		$relations = $suppressions->getElementsByTagName('relation');
136
		foreach ($relations as $relation) {
137
			$this-> analyserRelation($relation);
138
			if (count($this->relation_a_chemins) > $this->pas) {
139
				$this->supprimerRelationAChemins();
140
			}
141
			if (count($this->relations_communes) > $this->pas_commune) {
142
				$this->supprimerRelationsCommunes();
143
			}
144
		}
145
		$ways = $suppressions->getElementsByTagName('way');
146
		foreach ($ways as $way) {
147
			$this->analyserWay($way);
148
			if (count($this->chemin_a_noeuds) > $this->pas) {
149
				$this->supprimerCheminANoeuds();
150
			}
151
		}
152
		$noeuds = $suppressions->getElementsByTagName('node');
153
		foreach ($noeuds as $noeud) {
154
			$this->analyserNode($noeud);
155
			if (count($this->noeuds) > $this->pas) {
156
				$this->supprimerNoeuds();
157
			}
158
		}
159
		$this->supprimerRelationsCommunes();
160
		$this->supprimerRelationAChemins();
161
		$this->supprimerCheminANoeuds();
162
		$this->supprimerNoeuds();
163
	}
392 jpm 164
 
165
 
167 jpm 166
	/**
167
	 * Récupère l'id commune, nom commune et le code INSEE et remplie la table `osm_relations`
392 jpm 168
	 */
167 jpm 169
	private function analyserRelation($relation) {
170
		$relation_id = $this->proteger($relation->getAttribute('id'));
171
		$chemins = $relation->getElementsByTagName('member');
172
		foreach ($chemins as $chemin) {
173
			if ($chemin->getAttribute('type') == 'way') { //écarter le noeud centrale
174
				$chemin_id = $this->proteger($chemin->getAttribute('ref'));
175
				$role = $this->proteger($chemin->getAttribute('role'));//role: null, inner, outer, exclave et enclave.
392 jpm 176
				$this->relation_a_chemins[] = array($relation_id, $chemin_id, $role);
167 jpm 177
			}
178
		}
179
		$commune_nom = null;
180
		$commune_insee = null;
181
		$tags = $relation->getElementsByTagName('tag');
182
		foreach ($tags as $tag) {
183
			$tag_cle = $tag->getAttribute('k');
184
			$tag_val = $tag->getAttribute('v');
185
			switch ($tag_cle) {
186
				case 'name' :
187
					$commune_nom = $this->proteger($tag_val);
392 jpm 188
					break;
167 jpm 189
				case 'ref:INSEE' :
190
					$commune_insee = $this->proteger($tag_val);
191
					break;
192
			}
193
			if (!is_null($commune_nom) && !is_null($commune_insee)) {
194
				$this->relations_communes[] = array($relation_id, $commune_nom, $commune_insee);
195
				if (!isset($this->communes[$commune_insee])) {
196
					$this->communes[$commune_insee] = $relation_id;
197
				} else {
198
					$e = "La relation #%s contient déjà le tag ref:INSEE avec la valeur %s.".
199
						"Veuillez corriger la carte OSM.";
200
					$this->traiterErreur($e, array($this->communes[$commune_insee], $commune_insee, $relation_id));
201
				}
202
				break;
203
			}
392 jpm 204
		}
167 jpm 205
	}
392 jpm 206
 
167 jpm 207
	/**
208
	 * Récupère l'id_way et tous les id_node de chaque way et remplie la table `osm_chemin_a_noeuds`
392 jpm 209
	 */
167 jpm 210
	private function analyserWay($way) {
211
		$chemin_id = $this->proteger($way->getAttribute('id'));
212
		$ordre = 0;
213
		$noeuds = $way->getElementsByTagName('nd');
214
		$chemin_a_noeuds = array();
215
		foreach ($noeuds as $noeud) {
216
			$noeud_id = $this->proteger($noeud->getAttribute('ref'));
217
			$ordre++;
218
	    	$this->chemin_a_noeuds[] = array($chemin_id, $noeud_id, $ordre);
219
		}
220
	}
392 jpm 221
 
222
	/**
167 jpm 223
	 * Fonction qui récupère tous les l'id_node et les valeurs(Lat/Lon) correspondantes et remplie la table `osm_noeuds`
392 jpm 224
	 */
167 jpm 225
	private function analyserNode($node) {
226
		$noeud_id = $this->proteger($node->getAttribute('id'));
227
		$lat = $this->proteger($node->getAttribute('lat'));
228
		$lon = $this->proteger($node->getAttribute('lon'));
229
		$this->noeuds[] = array($noeud_id, $lat, $lon);
230
	}
392 jpm 231
 
232
	//Insertion des relations
167 jpm 233
	private function insererRelationsCommunes() {
234
		$requete =	'INSERT INTO osm_relations (id_relation, nom, code_insee) '.
235
					'VALUES '.$this->creerValuesMultiple($this->relations_communes);
236
		$this->inserer($requete);
237
		$this->relations_communes = array();
238
	}
239
 
392 jpm 240
	//Insertion des relations à chemins
167 jpm 241
	private function insererRelationAChemins() {
242
		$requete =	'INSERT INTO osm_relation_a_chemins (id_relation, id_chemin, role) '.
243
					'VALUES '.$this->creerValuesMultiple($this->relation_a_chemins);
244
		$this->inserer($requete);
245
		$this->relation_a_chemins = array();
392 jpm 246
	}
167 jpm 247
 
392 jpm 248
	//Insertion des chemins à noeuds
167 jpm 249
	private function insererCheminANoeuds() {
250
		$requete = 	'INSERT INTO osm_chemin_a_noeuds (id_chemin, id_noeud, ordre) '.
251
					'VALUES '.$this->creerValuesMultiple($this->chemin_a_noeuds);
252
		$this->inserer($requete);
253
		$this->chemin_a_noeuds = array();
254
	}
392 jpm 255
 
256
	//Insertion des noeuds
167 jpm 257
	private function insererNoeuds() {
258
		$requete = 'INSERT INTO osm_noeuds (id_noeud, lat, `long`) '.
259
	    		   'VALUES '.$this->creerValuesMultiple($this->noeuds);
260
		$this->inserer($requete);
261
		$this->noeuds = array();
262
	}
392 jpm 263
 
264
	//Update des relations
167 jpm 265
	private function modifierRelationsCommunes() {
266
		$donnees = $this->relations_communes;
267
		foreach ($donnees as $donnee) {
392 jpm 268
		$requete = 'UPDATE osm_relations '.
269
					"SET id_relation = $donnee[0], nom = $donnee[1], code_insee = $donnee[2] ".
167 jpm 270
					"WHERE id_relation = $donnee[0]";
271
			$this->inserer($requete);
272
		}
273
		$this->relations_communes = array();
274
	}
392 jpm 275
 
167 jpm 276
	/*
392 jpm 277
	*Update des relations à chemins en supprimant l'ancienne relation et tous ses chemins
278
	*de la table osm_relation_a_chemins et insérer la nouvelle
167 jpm 279
	*/
280
	private function modifierRelationAChemins() {
281
		$relations_a_chemins_a_supp = array();
282
		$donnees = $this->relation_a_chemins;
283
		foreach ($donnees as $donnee) {
284
			$relations_a_chemins_a_supp[] = $donnee[0];
285
		}
286
		$values_chaine = '('.implode(',',array_unique($relations_a_chemins_a_supp)).')';
287
		$requete = 'DELETE FROM osm_relation_a_chemins '.
288
					"WHERE id_relation IN $values_chaine";
392 jpm 289
		$this->inserer($requete);
167 jpm 290
		foreach ($donnees as $donnee) {
291
			$requete = 'INSERT INTO osm_relation_a_chemins (id_relation, id_chemin, role) '.
292
						"VALUES ($donnee[0], $donnee[1], $donnee[2]);";
293
			$this->inserer($requete);
294
		}
295
		$this->relation_a_chemins = array();
392 jpm 296
	}
297
 
167 jpm 298
	/*
392 jpm 299
	*Update des chemins à noeuds en supprimant l'ancien chemin et tous ses noeuds
300
	*de la table osm_chemins_a_noeuds et insérer le nouveau
167 jpm 301
	*/
302
	private function modifierCheminANoeuds() {
303
		$chemin_a_noeuds_a_supp = array();
304
		$donnees = $this->chemin_a_noeuds;
305
		foreach ($donnees as $donnee) {
306
			$chemin_a_noeuds_a_supp[] = $donnee[0];
307
		}
308
		$values_chaine = '('.implode(',',array_unique($chemin_a_noeuds_a_supp)).')';
309
		$requete = 'DELETE FROM osm_chemin_a_noeuds '.
310
					"WHERE id_chemin IN $values_chaine";
392 jpm 311
		$this->inserer($requete);
167 jpm 312
		foreach ($donnees as $donnee) {
313
			$requete = 'INSERT INTO osm_chemin_a_noeuds (id_chemin, id_noeud, ordre) '.
314
						"VALUES ($donnee[0], $donnee[1], $donnee[2]);";
315
			$this->inserer($requete);
316
		}
317
		$this->chemin_a_noeuds = array();
318
	}
392 jpm 319
 
320
 
321
	//Update des noeuds
167 jpm 322
	private function modifierNoeuds() {
323
		$donnees = $this->noeuds;
324
		foreach ($donnees as $donnee) {
392 jpm 325
			$requete = 'UPDATE osm_noeuds '.
326
						"SET id_noeud = $donnee[0], lat = $donnee[1], `long` = $donnee[2] ".
167 jpm 327
						"WHERE id_noeud = $donnee[0]";
328
			$this->inserer($requete);
329
		}
330
		$this->noeuds = array();
331
	}
392 jpm 332
 
333
 
334
	//Suppressions des relations
167 jpm 335
	private function supprimerRelationsCommunes() {
336
		$donnees = $this->relations_communes;
337
		foreach ($donnees as $donnee) {
392 jpm 338
			$requete = 'DELETE FROM osm_relations '.
167 jpm 339
						"WHERE id_relation = $donnee[0]";
340
			$this->inserer($requete);
341
		}
342
		$this->relations_communes = array();
343
	}
392 jpm 344
 
345
	//Suppressions des relations à chemins
167 jpm 346
	private function supprimerRelationAChemins() {
347
		$donnees = $this->relations_communes;
348
		foreach ($donnees as $donnee) {
349
			$donnees = $this->relation_a_chemins;
392 jpm 350
			$requete = 'DELETE FROM osm_relation_a_chemins '.
167 jpm 351
						"WHERE id_relation = $donnee[0]";
352
			$this->inserer($requete);
353
		}
354
		$this->relation_a_chemins = array();
392 jpm 355
	}
356
 
357
	//Suppressions des chemins à noeuds
167 jpm 358
	private function supprimerCheminANoeuds() {
359
		$donnees = $this->chemin_a_noeuds;
360
		foreach ($donnees as $donnee) {
361
			$donnees = $this->relation_a_chemins;
392 jpm 362
			$requete = 'DELETE FROM osm_chemin_a_noeuds '.
167 jpm 363
						"WHERE id_chemin = $donnee[0]";
364
			$this->inserer($requete);
365
		}
366
		$this->chemin_a_noeuds = array();
367
	}
392 jpm 368
 
369
	//Suppressions des chemins à noeuds
167 jpm 370
	private function supprimerNoeuds() {
371
		$donnees = $this->noeuds;
372
		foreach ($donnees as $donnee) {
392 jpm 373
			$requete = 'DELETE FROM osm_noeuds '.
167 jpm 374
						"WHERE id_noeud = $donnee[0]";
375
			$this->inserer($requete);
376
		}
377
		$this->noeuds = array();
378
	}
392 jpm 379
 
167 jpm 380
	private function inserer($requete) {
381
		$this->bdd->requeter($requete);
382
	}
392 jpm 383
 
167 jpm 384
	private function proteger($chaine) {
385
		return $this->bdd->proteger($chaine);
386
	}
392 jpm 387
 
167 jpm 388
	private function creerValuesMultiple($donnees) {
389
		$values = array();
390
		foreach ($donnees as $donnee) {
391
			$values[] = implode(',', $donnee);
392
		}
393
		$values_chaine = '('.implode('),(', $values).')';
394
		return $values_chaine;
395
	}
392 jpm 396
}
167 jpm 397
?>