Subversion Repositories eFlore/Projets.eflore-projets

<?php

/**

 * Exemple de lancement du script :

 *

 * Analyse du fichir OSM :

 * /opt/lampp/bin/php cli.php osm -a analyser -f "../donnees/osm/france_communes_new.osm" -m manuel

 *

 */

class ParseurOsm {

	private $conteneur;

	private $bdd;

	private $messages;

	private $mode;

	private $communes = array();

	private $relations_communes = array();

	private $relation_a_chemins = array();

	private $chemin_a_noeuds = array();

	private $noeuds = array();

	private $pas = 10000;

	private $pas_commune = 1000;

	public function __construct($conteneur) {

		$this->conteneur = $conteneur;

		$this->bdd = $this->conteneur->getBdd();

		$this->messages = $this->conteneur->getMessages();

		$this->mode = $this->conteneur->getParametre('m');

	}

	public function executer() {

		// Lancement de l'action demandée

		$cmd = $this->conteneur->getParametre('a');

		switch ($cmd) {

			case 'analyser' :

				$this->lireFichierOsm();

				break;

			case 'polygone' :

				$this->remplirPolygone();

				break;

			case 'zero' :

				$this->remettreOrdreAZero();

				break;

			default :

				$this->messages->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd));

		}

	}

	/**

	 * Lit le fichier OSM et lance l'analyse des noeuds xml en fonction de leur type.

	 */

	private function lireFichierOsm() {

		$lecteur = $this->getLecteurXml();

		while ($lecteur->read()) {

			if ($lecteur->nodeType == XMLREADER::ELEMENT) {

				$this->analyserElementXml($lecteur->localName, $lecteur->expand());

			}

			if ($this->mode == 'manuel') {

				$this->messages->afficherAvancement("Analyse de la ligne du fichier OSM : ", 1);

			}

		}

		$this->insererElementsOrphelins();

	}

	private function analyserElementXml($elementNom, $noeudDom) {

		switch ($elementNom) {

			case 'relation' :

				$this->analyserRelation($noeudDom);

				break;

			case 'way' :

				$this->analyserWay($noeudDom);

				break;

			case 'node' :

				$this->analyserNode($noeudDom);

				break;

		}

	}

	private function insererElementsOrphelins() {

		$this->insererRelationsCommunes();

		$this->insererRelationAChemins();

		$this->insererCheminANoeuds();

		$this->insererNoeuds();

	}

	private function getLecteurXml() {

		$fichierOsm = $this->conteneur->getParametre('f');

		$lecteur = new XMLReader();

		$ouvertureXmlOk = $lecteur->open($fichierOsm);

		if ($ouvertureXmlOk === false) {

			$msgTpl = "Impossible d'ouvrir le fichier osm : %s";

			$msg = sprintf($msgTpl, $this->conteneur->getParametre('f'));

			new Exception($msg);

		}

		return $lecteur;

	}

	/**

	 * Récupère l'id commune, nom commune et le code INSEE et remplie la table `CommuneOSM`

	 */

	private function analyserRelation($relation) {

		$idRelation = $relation->getAttribute('id');

		$chemins = $relation->getElementsByTagName('member');

		$this->analyserChemins($idRelation, $chemins);

		if (count($this->relation_a_chemins) > $this->pas) {

			$this->insererRelationAChemins();

		}

		$tags = $relation->getElementsByTagName('tag');

		$this->analyserTags($idRelation, $tags);

		if (count($this->relations_communes) > $this->pas_commune) {

			$this->insererRelationsCommunes();

		}

	}

	private function analyserChemins($relation_id, $chemins) {

		$ordreChemin = 1;

		foreach ($chemins as $chemin) {

			if ($chemin->getAttribute('type') == 'way') { //écarter le noeud centrale

				$chemin_id = $chemin->getAttribute('ref');

				$role = $chemin->getAttribute('role');//role: null, inner, outer, exclave et enclave.

				$this->relation_a_chemins[] = array($relation_id, $chemin_id, $role, $ordreChemin++);

			}

		}

	}

	private function analyserTags($relation_id, $tags) {

		$commune_nom = null;

		$commune_insee = null;

		foreach ($tags as $tag) {

			$tag_cle = $tag->getAttribute('k');

			$tag_val = $tag->getAttribute('v');

			switch ($tag_cle) {

				case 'name' :

					$commune_nom = $tag_val;

					break;

				case 'ref:INSEE' :

					$commune_insee = $tag_val;

					break;

			}

			if (!is_null($commune_nom) && !is_null($commune_insee)) {

				if (!isset($this->relations_communes[$relation_id])) {

					$this->relations_communes[$relation_id] = array($relation_id, $commune_nom, $commune_insee);

				} else {

					$e = "La relation #%s possédant le tag ref:INSEE «%s» est déjà prise en compte.";

					$this->messages->traiterErreur($e, array($relation_id, $commune_insee));

				}

				if (!isset($this->communes[$commune_insee])) {

					$this->communes[$commune_insee] = $relation_id;

				} else {

					$e = "La relation #%s contient déjà le tag ref:INSEE avec la valeur %s.".

						"Veuillez corriger la carte OSM.";

					$this->messages->traiterErreur($e, array($this->communes[$commune_insee], $commune_insee, $relation_id));

				}

				break;// Stoppe le foreach car nous avons les infos nécessaires

			}

		}

	}

	/**

	 * Récupère l'id_way et tous les id_node de chaque way et remplie la table `osm_chemin_a_noeuds`

	 */

	private function analyserWay($way) {

		$chemin_id = $way->getAttribute('id');

		$ordre = 1;

		$noeuds = $way->getElementsByTagName('nd');

		foreach ($noeuds as $noeud) {

			$noeud_id = $noeud->getAttribute('ref');

			$this->chemin_a_noeuds[] = array($chemin_id, $noeud_id, $ordre++);

		}

		if (count($this->chemin_a_noeuds) > $this->pas) {

			$this->insererCheminANoeuds();

		}

	}

	/**

	 * Fonction qui récupère tous les l'id_node et les valeurs(Lat/Lon) correspondantes et remplie la table `osm_noeuds`

	 */

	private function analyserNode($node) {

		$noeud_id = $node->getAttribute('id');

		$lat = $node->getAttribute('lat');

		$lon = $node->getAttribute('lon');

		$this->noeuds[] = array($noeud_id, $lat, $lon);

		if (count($this->noeuds) > $this->pas) {

			$this->insererNoeuds();

		}

	}

	private function insererRelationsCommunes() {

		if (count($this->relations_communes) > 0) {

			$requete = 'INSERT INTO osm_relations (id_relation, nom, code_insee) '.

				'VALUES '.$this->creerValuesMultiple($this->relations_communes).

				' -- '.__FILE__.' : '.__LINE__;

			$this->bdd->requeter($requete);

		}

		$this->relations_communes = array();

	}

	private function insererRelationAChemins() {

		if (count($this->relation_a_chemins) > 0) {

			$requete = 'INSERT INTO osm_relation_a_chemins (id_relation, id_chemin, role, ordre) '.

				'VALUES '.$this->creerValuesMultiple($this->relation_a_chemins).

				' -- '.__FILE__.' : '.__LINE__;

			$this->bdd->requeter($requete);

		}

		$this->relation_a_chemins = array();

	}

	private function insererCheminANoeuds() {

		if (count($this->chemin_a_noeuds) > 0) {

			$requete = 'INSERT INTO osm_chemin_a_noeuds (id_chemin, id_noeud, ordre) '.

				'VALUES '.$this->creerValuesMultiple($this->chemin_a_noeuds).

				' -- '.__FILE__.' : '.__LINE__;

			$this->bdd->requeter($requete);

		}

		$this->chemin_a_noeuds = array();

	}

	private function insererNoeuds() {

		if (count($this->noeuds) > 0) {

			$requete = 'INSERT INTO osm_noeuds (id_noeud, lat, `long`) '.

				'VALUES '.$this->creerValuesMultiple($this->noeuds).

				' -- '.__FILE__.' : '.__LINE__;

			$this->bdd->requeter($requete);

		}

		$this->noeuds = array();

	}

	private function creerValuesMultiple($donnees) {

		$values = array();

		foreach ($donnees as $infos) {

			$infosP = $this->bdd->proteger($infos);

			$values[] = implode(',', $infosP);

		}

		$valuesClause = '('.implode('),(', $values).')';

		return $valuesClause;

	}

}