Subversion Repositories eFlore/Projets.eflore-projets

Rev

Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
167 jpm 1
<?php
2
/**
392 jpm 3
 * Exemple de lancement du script :
4
 *
1046 jpm 5
 * Analyse du fichir OSM :
6
 * /opt/lampp/bin/php cli.php osm -a analyser -f "../donnees/osm/france_communes_new.osm" -m manuel
7
 *
167 jpm 8
 */
1046 jpm 9
class ParseurOsm {
392 jpm 10
 
1046 jpm 11
	private $conteneur;
12
	private $bdd;
13
	private $messages;
14
	private $mode;
15
 
167 jpm 16
	private $communes = array();
17
	private $relations_communes = array();
18
	private $relation_a_chemins = array();
19
	private $chemin_a_noeuds = array();
20
	private $noeuds = array();
21
	private $pas = 10000;
22
	private $pas_commune = 1000;
392 jpm 23
 
1046 jpm 24
	public function __construct($conteneur) {
25
		$this->conteneur = $conteneur;
26
		$this->bdd = $this->conteneur->getBdd();
27
		$this->messages = $this->conteneur->getMessages();
28
		$this->mode = $this->conteneur->getParametre('m');
29
	}
167 jpm 30
 
31
	public function executer() {
32
		// Lancement de l'action demandée
1046 jpm 33
		$cmd = $this->conteneur->getParametre('a');
34
		switch ($cmd) {
35
			case 'analyser' :
167 jpm 36
				$this->lireFichierOsm();
37
				break;
38
			case 'polygone' :
39
				$this->remplirPolygone();
40
				break;
41
			case 'zero' :
42
				$this->remettreOrdreAZero();
43
				break;
44
			default :
1046 jpm 45
				$this->messages->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));
167 jpm 46
		}
1046 jpm 47
	}
167 jpm 48
 
1046 jpm 49
	/**
167 jpm 50
	 * Lit le fichier OSM et lance l'analyse des noeuds xml en fonction de leur type.
392 jpm 51
	 */
167 jpm 52
	private function lireFichierOsm() {
1046 jpm 53
		$lecteur = $this->getLecteurXml();
54
		while ($lecteur->read()) {
55
			if ($lecteur->nodeType == XMLREADER::ELEMENT) {
56
				$this->analyserElementXml($lecteur->localName, $lecteur->expand());
57
			}
58
			if ($this->mode == 'manuel') {
59
				$this->messages->afficherAvancement("Analyse de la ligne du fichier OSM : ", 1);
60
			}
61
		}
62
		$this->insererElementsOrphelins();
63
	}
392 jpm 64
 
1046 jpm 65
	private function analyserElementXml($elementNom, $noeudDom) {
66
		switch ($elementNom) {
67
			case 'relation' :
68
				$this->analyserRelation($noeudDom);
69
				break;
70
			case 'way' :
71
				$this->analyserWay($noeudDom);
72
				break;
73
			case 'node' :
74
				$this->analyserNode($noeudDom);
75
				break;
76
		}
77
	}
392 jpm 78
 
1046 jpm 79
	private function insererElementsOrphelins() {
80
		$this->insererRelationsCommunes();
81
		$this->insererRelationAChemins();
82
		$this->insererCheminANoeuds();
83
		$this->insererNoeuds();
84
	}
85
 
86
	private function getLecteurXml() {
87
		$fichierOsm = $this->conteneur->getParametre('f');
88
		$lecteur = new XMLReader();
89
		$ouvertureXmlOk = $lecteur->open($fichierOsm);
90
		if ($ouvertureXmlOk === false) {
91
			$msgTpl = "Impossible d'ouvrir le fichier osm : %s";
92
			$msg = sprintf($msgTpl, $this->conteneur->getParametre('f'));
93
			new Exception($msg);
167 jpm 94
		}
1046 jpm 95
		return $lecteur;
167 jpm 96
	}
392 jpm 97
 
167 jpm 98
	/**
99
	 * Récupère l'id commune, nom commune et le code INSEE et remplie la table `CommuneOSM`
392 jpm 100
	 */
167 jpm 101
	private function analyserRelation($relation) {
1046 jpm 102
		$idRelation = $relation->getAttribute('id');
103
 
167 jpm 104
		$chemins = $relation->getElementsByTagName('member');
1046 jpm 105
		$this->analyserChemins($idRelation, $chemins);
106
		if (count($this->relation_a_chemins) > $this->pas) {
107
			$this->insererRelationAChemins();
108
		}
109
 
110
		$tags = $relation->getElementsByTagName('tag');
111
		$this->analyserTags($idRelation, $tags);
112
		if (count($this->relations_communes) > $this->pas_commune) {
113
			$this->insererRelationsCommunes();
114
		}
115
	}
116
 
117
	private function analyserChemins($relation_id, $chemins) {
167 jpm 118
		foreach ($chemins as $chemin) {
119
			if ($chemin->getAttribute('type') == 'way') { //écarter le noeud centrale
1046 jpm 120
				$chemin_id = $chemin->getAttribute('ref');
121
				$role = $chemin->getAttribute('role');//role: null, inner, outer, exclave et enclave.
392 jpm 122
				$this->relation_a_chemins[] = array($relation_id, $chemin_id, $role);
167 jpm 123
			}
124
		}
1046 jpm 125
	}
126
 
127
	private function analyserTags($relation_id, $tags) {
167 jpm 128
		$commune_nom = null;
129
		$commune_insee = null;
130
		foreach ($tags as $tag) {
131
			$tag_cle = $tag->getAttribute('k');
132
			$tag_val = $tag->getAttribute('v');
1046 jpm 133
 
167 jpm 134
			switch ($tag_cle) {
135
				case 'name' :
1046 jpm 136
					$commune_nom = $tag_val;
392 jpm 137
					break;
167 jpm 138
				case 'ref:INSEE' :
1046 jpm 139
					$commune_insee = $tag_val;
167 jpm 140
					break;
141
			}
1046 jpm 142
 
167 jpm 143
			if (!is_null($commune_nom) && !is_null($commune_insee)) {
1046 jpm 144
 
145
				if (!isset($this->relations_communes[$relation_id])) {
146
					$this->relations_communes[$relation_id] = array($relation_id, $commune_nom, $commune_insee);
147
				} else {
148
					$e = "La relation #%s possédant le tag ref:INSEE «%s» est déjà prise en compte.";
149
					$this->messages->traiterErreur($e, array($relation_id, $commune_insee));
150
				}
151
 
167 jpm 152
				if (!isset($this->communes[$commune_insee])) {
153
					$this->communes[$commune_insee] = $relation_id;
154
				} else {
155
					$e = "La relation #%s contient déjà le tag ref:INSEE avec la valeur %s.".
156
						"Veuillez corriger la carte OSM.";
1046 jpm 157
					$this->messages->traiterErreur($e, array($this->communes[$commune_insee], $commune_insee, $relation_id));
167 jpm 158
				}
1046 jpm 159
				break;// Stoppe le foreach car nous avons les infos nécessaires
167 jpm 160
			}
392 jpm 161
		}
167 jpm 162
	}
392 jpm 163
 
167 jpm 164
	/**
165
	 * Récupère l'id_way et tous les id_node de chaque way et remplie la table `osm_chemin_a_noeuds`
392 jpm 166
	 */
167 jpm 167
	private function analyserWay($way) {
1046 jpm 168
		$chemin_id = $way->getAttribute('id');
169
		$ordre = 1;
167 jpm 170
		$noeuds = $way->getElementsByTagName('nd');
171
		foreach ($noeuds as $noeud) {
1046 jpm 172
			$noeud_id = $noeud->getAttribute('ref');
173
			$this->chemin_a_noeuds[] = array($chemin_id, $noeud_id, $ordre++);
167 jpm 174
		}
1046 jpm 175
 
176
		if (count($this->chemin_a_noeuds) > $this->pas) {
177
			$this->insererCheminANoeuds();
178
		}
167 jpm 179
	}
392 jpm 180
 
181
	/**
167 jpm 182
	 * Fonction qui récupère tous les l'id_node et les valeurs(Lat/Lon) correspondantes et remplie la table `osm_noeuds`
392 jpm 183
	 */
167 jpm 184
	private function analyserNode($node) {
1046 jpm 185
		$noeud_id = $node->getAttribute('id');
186
		$lat = $node->getAttribute('lat');
187
		$lon = $node->getAttribute('lon');
167 jpm 188
		$this->noeuds[] = array($noeud_id, $lat, $lon);
1046 jpm 189
 
190
		if (count($this->noeuds) > $this->pas) {
191
			$this->insererNoeuds();
192
		}
167 jpm 193
	}
392 jpm 194
 
167 jpm 195
	private function insererRelationsCommunes() {
1046 jpm 196
		if (count($this->relations_communes) > 0) {
197
			$requete = 'INSERT INTO osm_relations (id_relation, nom, code_insee) '.
198
				'VALUES '.$this->creerValuesMultiple($this->relations_communes).
199
				' -- '.__FILE__.' : '.__LINE__;
200
			$this->bdd->requeter($requete);
201
		}
167 jpm 202
		$this->relations_communes = array();
203
	}
392 jpm 204
 
167 jpm 205
	private function insererRelationAChemins() {
1046 jpm 206
		if (count($this->relation_a_chemins) > 0) {
207
			$requete = 'INSERT INTO osm_relation_a_chemins (id_relation, id_chemin, role) '.
208
				'VALUES '.$this->creerValuesMultiple($this->relation_a_chemins).
209
				' -- '.__FILE__.' : '.__LINE__;
210
			$this->bdd->requeter($requete);
211
		}
167 jpm 212
		$this->relation_a_chemins = array();
392 jpm 213
	}
214
 
167 jpm 215
	private function insererCheminANoeuds() {
1046 jpm 216
		if (count($this->chemin_a_noeuds) > 0) {
217
			$requete = 'INSERT INTO osm_chemin_a_noeuds (id_chemin, id_noeud, ordre) '.
218
				'VALUES '.$this->creerValuesMultiple($this->chemin_a_noeuds).
219
				' -- '.__FILE__.' : '.__LINE__;
220
			$this->bdd->requeter($requete);
221
		}
167 jpm 222
		$this->chemin_a_noeuds = array();
223
	}
392 jpm 224
 
167 jpm 225
	private function insererNoeuds() {
1046 jpm 226
		if (count($this->noeuds) > 0) {
227
			$requete = 'INSERT INTO osm_noeuds (id_noeud, lat, `long`) '.
228
				'VALUES '.$this->creerValuesMultiple($this->noeuds).
229
				' -- '.__FILE__.' : '.__LINE__;
230
			$this->bdd->requeter($requete);
231
		}
167 jpm 232
		$this->noeuds = array();
233
	}
392 jpm 234
 
167 jpm 235
	private function creerValuesMultiple($donnees) {
236
		$values = array();
1046 jpm 237
		foreach ($donnees as $infos) {
238
			$infosP = $this->bdd->proteger($infos);
239
			$values[] = implode(',', $infosP);
167 jpm 240
		}
1046 jpm 241
		$valuesClause = '('.implode('),(', $values).')';
242
		return $valuesClause;
167 jpm 243
	}
1046 jpm 244
}