Subversion Repositories eFlore/Projets.eflore-projets

Rev

Details | Last modification | View Log | RSS feed

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