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) {
1055 jpm 118
		$ordreChemin = 1;
167 jpm 119
		foreach ($chemins as $chemin) {
120
			if ($chemin->getAttribute('type') == 'way') { //écarter le noeud centrale
1046 jpm 121
				$chemin_id = $chemin->getAttribute('ref');
122
				$role = $chemin->getAttribute('role');//role: null, inner, outer, exclave et enclave.
1055 jpm 123
				$this->relation_a_chemins[] = array($relation_id, $chemin_id, $role, $ordreChemin++);
167 jpm 124
			}
125
		}
1046 jpm 126
	}
127
 
128
	private function analyserTags($relation_id, $tags) {
167 jpm 129
		$commune_nom = null;
130
		$commune_insee = null;
131
		foreach ($tags as $tag) {
132
			$tag_cle = $tag->getAttribute('k');
133
			$tag_val = $tag->getAttribute('v');
1046 jpm 134
 
167 jpm 135
			switch ($tag_cle) {
136
				case 'name' :
1046 jpm 137
					$commune_nom = $tag_val;
392 jpm 138
					break;
167 jpm 139
				case 'ref:INSEE' :
1046 jpm 140
					$commune_insee = $tag_val;
167 jpm 141
					break;
142
			}
1046 jpm 143
 
167 jpm 144
			if (!is_null($commune_nom) && !is_null($commune_insee)) {
1046 jpm 145
 
146
				if (!isset($this->relations_communes[$relation_id])) {
147
					$this->relations_communes[$relation_id] = array($relation_id, $commune_nom, $commune_insee);
148
				} else {
149
					$e = "La relation #%s possédant le tag ref:INSEE «%s» est déjà prise en compte.";
150
					$this->messages->traiterErreur($e, array($relation_id, $commune_insee));
151
				}
152
 
167 jpm 153
				if (!isset($this->communes[$commune_insee])) {
154
					$this->communes[$commune_insee] = $relation_id;
155
				} else {
156
					$e = "La relation #%s contient déjà le tag ref:INSEE avec la valeur %s.".
157
						"Veuillez corriger la carte OSM.";
1046 jpm 158
					$this->messages->traiterErreur($e, array($this->communes[$commune_insee], $commune_insee, $relation_id));
167 jpm 159
				}
1046 jpm 160
				break;// Stoppe le foreach car nous avons les infos nécessaires
167 jpm 161
			}
392 jpm 162
		}
167 jpm 163
	}
392 jpm 164
 
167 jpm 165
	/**
166
	 * Récupère l'id_way et tous les id_node de chaque way et remplie la table `osm_chemin_a_noeuds`
392 jpm 167
	 */
167 jpm 168
	private function analyserWay($way) {
1046 jpm 169
		$chemin_id = $way->getAttribute('id');
170
		$ordre = 1;
167 jpm 171
		$noeuds = $way->getElementsByTagName('nd');
172
		foreach ($noeuds as $noeud) {
1046 jpm 173
			$noeud_id = $noeud->getAttribute('ref');
174
			$this->chemin_a_noeuds[] = array($chemin_id, $noeud_id, $ordre++);
167 jpm 175
		}
1046 jpm 176
 
177
		if (count($this->chemin_a_noeuds) > $this->pas) {
178
			$this->insererCheminANoeuds();
179
		}
167 jpm 180
	}
392 jpm 181
 
182
	/**
167 jpm 183
	 * Fonction qui récupère tous les l'id_node et les valeurs(Lat/Lon) correspondantes et remplie la table `osm_noeuds`
392 jpm 184
	 */
167 jpm 185
	private function analyserNode($node) {
1046 jpm 186
		$noeud_id = $node->getAttribute('id');
187
		$lat = $node->getAttribute('lat');
188
		$lon = $node->getAttribute('lon');
167 jpm 189
		$this->noeuds[] = array($noeud_id, $lat, $lon);
1046 jpm 190
 
191
		if (count($this->noeuds) > $this->pas) {
192
			$this->insererNoeuds();
193
		}
167 jpm 194
	}
392 jpm 195
 
167 jpm 196
	private function insererRelationsCommunes() {
1046 jpm 197
		if (count($this->relations_communes) > 0) {
198
			$requete = 'INSERT INTO osm_relations (id_relation, nom, code_insee) '.
199
				'VALUES '.$this->creerValuesMultiple($this->relations_communes).
200
				' -- '.__FILE__.' : '.__LINE__;
201
			$this->bdd->requeter($requete);
202
		}
167 jpm 203
		$this->relations_communes = array();
204
	}
392 jpm 205
 
167 jpm 206
	private function insererRelationAChemins() {
1046 jpm 207
		if (count($this->relation_a_chemins) > 0) {
1055 jpm 208
			$requete = 'INSERT INTO osm_relation_a_chemins (id_relation, id_chemin, role, ordre) '.
1046 jpm 209
				'VALUES '.$this->creerValuesMultiple($this->relation_a_chemins).
210
				' -- '.__FILE__.' : '.__LINE__;
211
			$this->bdd->requeter($requete);
212
		}
167 jpm 213
		$this->relation_a_chemins = array();
392 jpm 214
	}
215
 
167 jpm 216
	private function insererCheminANoeuds() {
1046 jpm 217
		if (count($this->chemin_a_noeuds) > 0) {
218
			$requete = 'INSERT INTO osm_chemin_a_noeuds (id_chemin, id_noeud, ordre) '.
219
				'VALUES '.$this->creerValuesMultiple($this->chemin_a_noeuds).
220
				' -- '.__FILE__.' : '.__LINE__;
221
			$this->bdd->requeter($requete);
222
		}
167 jpm 223
		$this->chemin_a_noeuds = array();
224
	}
392 jpm 225
 
167 jpm 226
	private function insererNoeuds() {
1046 jpm 227
		if (count($this->noeuds) > 0) {
228
			$requete = 'INSERT INTO osm_noeuds (id_noeud, lat, `long`) '.
229
				'VALUES '.$this->creerValuesMultiple($this->noeuds).
230
				' -- '.__FILE__.' : '.__LINE__;
231
			$this->bdd->requeter($requete);
232
		}
167 jpm 233
		$this->noeuds = array();
234
	}
392 jpm 235
 
167 jpm 236
	private function creerValuesMultiple($donnees) {
237
		$values = array();
1046 jpm 238
		foreach ($donnees as $infos) {
239
			$infosP = $this->bdd->proteger($infos);
240
			$values[] = implode(',', $infosP);
167 jpm 241
		}
1046 jpm 242
		$valuesClause = '('.implode('),(', $values).')';
243
		return $valuesClause;
167 jpm 244
	}
1046 jpm 245
}