/branches/v5.12-baouque/scripts/modules/osm/ZonesAdmin.php |
---|
New file |
0,0 → 1,119 |
<?php |
/** |
* Création de la table osm_communes. |
* /opt/lampp/bin/php cli.php osm -a communes -m manuel |
* |
*/ |
class ZonesAdmin { |
private $conteneur; |
private $bdd; |
private $messages; |
private $mode; |
private $bddOsmNom; |
public function __construct($conteneur) { |
$this->conteneur = $conteneur; |
$this->bdd = $this->conteneur->getBdd(); |
$this->bddOsmNom = $this->conteneur->getParametre('bdd_osm_nom'); |
$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 'za' : |
$this->supprimerTableOsmZonesAdmin(); |
$this->conteneur->getEfloreCommun()->chargerStructureSql(); |
$this->creerTableOsmZonesAdmin(); |
$this->corrigerTableOsmZonesAdmin(); |
$this->mettreAJourIdZoneGeo(); |
break; |
case 'zaCreer' : |
$this->creerTableOsmZonesAdmin(); |
break; |
case 'zaCorriger' : |
$this->corrigerTableOsmZonesAdmin(); |
break; |
case 'zaMajIdZG' : |
$this->mettreAJourIdZoneGeo(); |
break; |
case 'zaSupprimer' : |
$this->supprimerTableOsmZonesAdmin(); |
break; |
default : |
$this->messages->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd)); |
} |
} |
private function supprimerTableOsmZonesAdmin() { |
$requete = 'DROP TABLE IF EXISTS osm_zones_admin '. |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
private function creerTableOsmZonesAdmin() { |
$requete = 'INSERT INTO osm_zones_admin '. |
"SELECT if(ref_insee != '' AND admin_level = 8, CONCAT('INSEE-C:',ref_insee), ". |
"if(ref_insee != '' AND admin_level = 6, CONCAT('INSEE-D:',ref_insee), ". |
"if(ref_insee != '' AND admin_level = 4, CONCAT('INSEE-R:',ref_insee), ". |
"if(iso3166_2 != '', CONCAT('ISO-3166-2:',iso3166_2), ". |
"if(iso3166_1 != '', CONCAT('ISO-3166-1:',iso3166_1), ". |
"CONCAT('OSM-ID:',osm_id)))))), ". |
'osm_id, osm_version, osm_timestamp, '. |
"if(name_fr != '', name_fr, name), ". |
'shape, shape_centroid, Y(shape_centroid), X(shape_centroid), zone, '. |
'admin_level, iso3166_1, iso3166_2, ref_insee, ref_nuts, '. |
'name, name_fr, name_en, name_es, wikipedia '. |
"FROM {$this->bddOsmNom}.multipolygons_ref ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
private function corrigerTableOsmZonesAdmin() { |
$requete = 'SELECT osm_id, other_tags '. |
"FROM {$this->bddOsmNom}.multipolygons_ref ". |
"WHERE iso3166_2 IS NULL AND other_tags LIKE '%\"iso3166-2\"%' ". |
' -- '.__FILE__.' : '.__LINE__; |
$resultat = $this->bdd->recupererTous($requete); |
if ($resultat) { |
foreach ($resultat as $infos) { |
$tags = $this->getTags($infos['other_tags']); |
$iso_3166_2 = $this->bdd->proteger($tags['iso3166-2']); |
$osm_id = $this->bdd->proteger($infos['osm_id']); |
$requete = 'UPDATE osm_zones_admin '. |
"SET code_iso_3166_2 = $iso_3166_2 ". |
"WHERE osm_id = $osm_id ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
} |
} |
private function getTags($tagsInfos) { |
$tags = array(); |
$clesValeurs = explode(',', $tagsInfos); |
foreach ($clesValeurs as $cleValeur) { |
list($cle, $val) = explode('=>', $cleValeur); |
$tags[trim($cle, '"')] = trim($val, '"'); |
} |
return $tags; |
} |
private function mettreAJourIdZoneGeo() { |
$requete = 'UPDATE osm_zones_admin '. |
"SET id_zone_geo = if(code_insee != '' AND niveau = 8, CONCAT('INSEE-C:',code_insee), ". |
"if(code_insee != '' AND niveau = 6, CONCAT('INSEE-D:',code_insee), ". |
"if(code_insee != '' AND niveau = 4, CONCAT('INSEE-R:',code_insee), ". |
"if(code_iso_3166_2 != '', CONCAT('ISO-3166-2:',code_iso_3166_2), ". |
"if(code_iso_3166_1 != '', CONCAT('ISO-3166-1:',code_iso_3166_1), ". |
"CONCAT('OSM-ID:',osm_id)))))) ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
} |
/branches/v5.12-baouque/scripts/modules/osm/config.ini |
---|
New file |
0,0 → 1,12 |
; Base de données contenant les infos provenant d'OSM |
bdd_osm_nom = "tb_osm" |
; Ajouter les nouvelles version à la suite dans versions et versionsDonnees. |
version = "2.0" |
dossierSql = "{ref:dossierDonneesEflore}osm/" |
[fichiers] |
structureSql = "osm_v{ref:version}.sql" |
[chemins] |
structureSql = "{ref:dossierSql}{ref:version}/{ref:fichiers.structureSql}" |
/branches/v5.12-baouque/scripts/modules/osm/Osm.php |
---|
New file |
0,0 → 1,65 |
<?php |
//declare(encoding='UTF-8'); |
/** |
* Exemple de lancement du script : : |
* 1. Création de la base de données : |
* /opt/lampp/bin/php cli.php osm -a communes -m manuel -v 3 |
* |
* @category php 5.4 |
* @package DEL |
* @subpackage Scripts |
* @author Aurélien PERONNET <aurelien@tela-botanica.org> |
* @copyright Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org) |
* @license CeCILL v2 http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt |
* @license GNU-GPL http://www.gnu.org/licenses/gpl.html |
*/ |
class Osm extends EfloreScript { |
const PROJET_NOM = 'osm'; |
protected $parametres_autorises = array( |
'-m' => array(false, 'auto', 'Mode «auto» ou «manuel». En manuel, les compteurs dans les boucles sont affichés.')); |
public function executer() { |
try { |
$this->initialiserProjet(self::PROJET_NOM); |
// Lancement de l'action demandée |
$cmd = $this->getParametre('a'); |
switch ($cmd) { |
case 'chargerStructureSql' : |
$this->chargerStructureSql(); |
break; |
case 'cm' : |
case 'cmCreer' : |
case 'cmSupprimer' : |
$script = $this->chargerClasse('FranceCommunes'); |
$script->executer(); |
break; |
case 'za' : |
case 'zaCreer' : |
case 'zaCorriger' : |
case 'zaMajIdZG' : |
case 'zaSupprimer' : |
$script = $this->chargerClasse('ZonesAdmin'); |
$script->executer(); |
break; |
default : |
throw new Exception("Erreur : la commande '$cmd' n'existe pas!"); |
} |
} catch (Exception $e) { |
$this->traiterErreur($e->getMessage()); |
} |
print "\n";// Pour ramener à la ligne en fin de script |
} |
protected function initialiserProjet($projetNom) { |
$this->projetNom = $projetNom; |
} |
private function chargerClasse($classe) { |
require_once $classe.'.php'; |
$conteneur = new Conteneur($this->parametres); |
return new $classe($conteneur); |
} |
} |
/branches/v5.12-baouque/scripts/modules/osm/archives/ParseurOsm.php |
---|
New file |
0,0 → 1,245 |
<?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; |
} |
} |
/branches/v5.12-baouque/scripts/modules/osm/archives/shell/carto-osm-maj.sh |
---|
New file |
0,0 → 1,91 |
#!/bin/bash |
# |
# Script de lancement de l'integration des donnees OSM pour le geocodage inverse |
# Mohcen BENMOUNAH & Jean-Pascal MILCENT [19 juillet 2011] |
# |
ageEnSeconde(){ expr `date +%s` - `stat -c %Y $1`; }; |
if [ -f config.cfg ] ; then |
source config.cfg |
echo $DATE; |
else |
echo "Veuillez paramétrer le script en renommant le fichier 'config.defaut.cfg' en 'config.cfg'." |
exit; |
fi |
echo "Export de l'emplacement du binaire Java dans la variable d'environnement JAVACMD"; |
export JAVACMD="$CHEMIN_JAVA" |
echo "Export de l'emplacement du dossier tmp pour Osmosis" |
export JAVACMD_OPTIONS="-Djava.io.tmpdir=$OSMOSIS_DOSSIER_TMP -Xmx4G" |
if [ ! -f "$DOSSIER_OSM/$FICHIER_OSM" ] || [ `ageEnSeconde "$DOSSIER_OSM/$FICHIER_OSM"` -gt 86000 ] ; then |
echo "Téléchargement du nouveau fichier PBF ..."; |
wget $URL_FICHIER_OSM -O "$DOSSIER_OSM/$FICHIER_OSM" |
else |
echo "Fichier $FICHIER_OSM existant à moins d'un jour."; |
fi |
if [ ! -f "$DOSSIER_OSM/$FICHIER_ZG_NEW" ] || [ `ageEnSeconde "$DOSSIER_OSM/$FICHIER_ZG_NEW"` -gt 86000 ] ; then |
echo "Filtrage du fichier en cours ..."; |
$CHEMIN_OSMOSIS \ |
-v \ |
--read-pbf-fast "$DOSSIER_OSM/$FICHIER_OSM" workers=6 \ |
--tf accept-relations admin_level=8 \ |
--tf accept-relations type=boundary \ |
--tf accept-relations ref:INSEE=* \ |
--used-way \ |
--used-node \ |
--wx "$DOSSIER_OSM/$FICHIER_ZG_NEW" |
fi |
HEURE_DEBUT=`date +"%F %X"`; |
echo "Début éxecution scripts php : $HEURE_DEBUT"; |
if [ ! -f "$DOSSIER_OSM/$FICHIER_ZG_OLD" ] ; then |
echo "Création des tables osm en cours ..."; |
$CHEMIN_PHP -d memory_limit=$MEMORY_LIMIT_PHP $CHEMIN_SCRIPT/cli.php osm -a chargerStructureSql -v $VERBOSITE > $FICHIER_LOG |
echo "Analyse du fichier osm en cours ..."; |
$CHEMIN_PHP -d memory_limit=$MEMORY_LIMIT_PHP $CHEMIN_SCRIPT/cli.php osm -a analyser -v $VERBOSITE -f "$DOSSIER_OSM/$FICHIER_ZG_NEW" >> $FICHIER_LOG |
else |
echo "Suppression du fichier DIFF existant en cours ..."; |
rm -f "$DOSSIER_OSM/$FICHIER_ZG_DIFF" |
echo "Déduction de la différence en cours ..."; |
$CHEMIN_OSMOSIS\ |
--read-xml file="$DOSSIER_OSM/$FICHIER_ZG_NEW" \ |
--read-xml file="$DOSSIER_OSM/$FICHIER_ZG_OLD" \ |
--derive-change \ |
--write-xml-change file="$DOSSIER_OSM/$FICHIER_ZG_DIFF" |
echo "Début de la mise à jour de base ..."; |
$CHEMIN_PHP -d memory_limit=$MEMORY_LIMIT_PHP $CHEMIN_SCRIPT/cli.php mise_a_jour -a MAJ -f "$DOSSIER_OSM/$FICHIER_ZG_DIFF" > $FICHIER_LOG |
fi |
echo "Renommage du fichier NEW en OLD en cours ..."; |
mv "$DOSSIER_OSM/$FICHIER_ZG_NEW" "$DOSSIER_OSM/$FICHIER_ZG_OLD" >> $FICHIER_LOG |
echo "Traitement de l'ordre en cours ..."; |
$CHEMIN_PHP -d memory_limit=$MEMORY_LIMIT_PHP $CHEMIN_SCRIPT/cli.php osm -a ordre -v $VERBOSITE >> $FICHIER_LOG |
echo "Remplissage des polygones en cours ..."; |
$CHEMIN_PHP -d memory_limit=$MEMORY_LIMIT_PHP $CHEMIN_SCRIPT/cli.php osm -a polygone -v $VERBOSITE >> $FICHIER_LOG |
echo "Remise de l'ordre à zéro en cours ..."; |
$CHEMIN_PHP -d memory_limit=$MEMORY_LIMIT_PHP $CHEMIN_SCRIPT/cli.php osm -a zero -v $VERBOSITE >> $FICHIER_LOG |
echo "Traitement de l'ordre des polygones incomplets en cours ..."; |
$CHEMIN_PHP -d memory_limit=$MEMORY_LIMIT_PHP $CHEMIN_SCRIPT/cli.php osm -a ordonnerPolygoneInc -v $VERBOSITE >> $FICHIER_LOG |
echo "Remplissage des polygones incomplets en cours ..."; |
$CHEMIN_PHP -d memory_limit=$MEMORY_LIMIT_PHP $CHEMIN_SCRIPT/cli.php osm -a remplirPolygoneInc -v $VERBOSITE >> $FICHIER_LOG |
echo "Renommage des polygones incomplets en cours ..."; |
$CHEMIN_PHP -d memory_limit=$MEMORY_LIMIT_PHP $CHEMIN_SCRIPT/cli.php osm -a renommer -v $VERBOSITE >> $FICHIER_LOG |
echo "Definition des centroïdes en cours ..."; |
$CHEMIN_PHP -d memory_limit=$MEMORY_LIMIT_PHP $CHEMIN_SCRIPT/cli.php osm -a centre -v $VERBOSITE >> $FICHIER_LOG |
HEURE_FIN=`date +"%F %X"`; |
echo "Fin éxecution scripts php : $HEURE_FIN"; |
Property changes: |
Added: svn:executable |
+* |
\ No newline at end of property |
/branches/v5.12-baouque/scripts/modules/osm/archives/shell/config.defaut.cfg |
---|
New file |
0,0 → 1,26 |
# Binaires |
CHEMIN_JAVA="/usr/local/jre/bin/java" |
CHEMIN_PHP="/usr/local/php/5.5/bin/php" |
CHEMIN_SCRIPT="/home/apitela/www/scripts/eflore" |
# Dossiers, fichiers & urls |
# Pour tester : http://download.geofabrik.de/europe/france/languedoc-roussillon-latest.osm.pbf |
URL_FICHIER_OSM="http://download.geofabrik.de/europe/france-latest.osm.pbf" |
DOSSIER_OSM="/home/jpm/web/eflore/eflore-projets/donnees/osm" |
FICHIER_OSM="fr.osm.pbf" |
FICHIER_ZG_NEW="fr_communes_new.osm" |
FICHIER_ZG_OLD="fr_communes_old.osm" |
FICHIER_ZG_DIFF="fr_communes_diff.osm" |
# Osmosis |
CHEMIN_OSMOSIS="/usr/local/sbin/osmosis-0.43.1/bin" |
OSMOSIS_DOSSIER_TMP="$DOSSIER_OSM/tmp" |
# Logs |
VERBOSITE=3 |
DATE=`date +"%F"` |
CHEMIN_LOG="$DOSSIER_OSM/logs" |
FICHIER_LOG="$CHEMIN_LOG/analyse_${DATE}.log" |
# Paramètres PHP |
MEMORY_LIMIT_PHP="8000M" |
/branches/v5.12-baouque/scripts/modules/osm/archives/shell/carto-osm-service.sh |
---|
New file |
0,0 → 1,41 |
#!/bin/sh |
#/etc/rc.d/init.d/ |
# |
# Jean-Pascal MILCENT & Mohcen BENMOUNAH [19 juillet 2011] |
# Service de lancement des scripts d'integration des donnees OSM pour le service de Geocadage Inverse |
# |
case "$1" in |
start) |
echo "Demarrage de carto-osm-cron :" |
nohup /usr/local/sbin/carto-osm-cron 1>/dev/null 2>/dev/null & |
;; |
stop) |
echo "Arret de carto-osm-cron" |
PID=`ps -eaf | grep carto-osm-cron | grep -v grep | tr -s ' ' | cut -d' ' -f2 | head -n1` |
kill -9 ${PID} |
;; |
status) |
echo -n "Voici les PID du processus carto-osm-cron :" |
PID=`ps -eaf | grep carto-osm-cron | grep -v grep | tr -s ' ' | cut -d' ' -f2 | head -n1` |
echo ${PID} |
;; |
*) |
echo "Usage: {start|stop|status}" |
exit 1 |
;; |
esac |
Property changes: |
Added: svn:executable |
+* |
\ No newline at end of property |
/branches/v5.12-baouque/scripts/modules/osm/archives/shell/carto-osm-cron.sh |
---|
New file |
0,0 → 1,30 |
#!/bin/bash |
# |
# Mohcen BENMOUNAH & Jean-Pascal MILCENT [19 juillet 2011] |
# /etc/init.d/carto-osm : demarage/arrete/etat du cron de l'integration des donnees OSM pour le Geocodage Inverse (carto-osm) |
# Lancement toutes les semaines le samedi matin après 3h00 |
while true |
do |
JOUR=$(date "+%u") |
# Si nous sommes samedi (=6) |
if [ $JOUR -eq 6 ] ; then |
HEURE=$(date "+%H") |
# Si nous sommes à 3 heures du matin |
if [ $HEURE -eq 3 ] ; then |
logger "carto-osm-maj : lancement script" |
sudo -u telabotap /usr/local/sbin/carto-osm-maj |
logger "carto-osm-maj : arret script" |
# Nous retenterons de vérifier jour et heure dans 6 jours |
sleep 6d |
else |
# Tentative toutes les heures |
logger "carto-osm-maj : tentative heure $HEURE" |
sleep 1h |
fi |
else |
# Tentative tous les jours |
logger "carto-osm-maj : tentative jour $JOUR" |
sleep 1d |
fi |
done |
Property changes: |
Added: svn:executable |
+* |
\ No newline at end of property |
/branches/v5.12-baouque/scripts/modules/osm/archives/shell |
---|
New file |
Property changes: |
Added: svn:ignore |
+config.cfg |
/branches/v5.12-baouque/scripts/modules/osm/archives/PolygoneCreateur.php |
---|
New file |
0,0 → 1,143 |
<?php |
/** |
* Traitement de l'ordre : |
* |
* Fonction qui rajoute l'ordre et le sens de chaque way d'une relation dans la table `osm_relation_a_chemins` |
* |
* Exemple de lancement du script : |
* /opt/lampp/bin/php -d memory_limit=8000M cli.php osm -a ordre -m manuel |
* |
*/ |
class PolygoneCreateur { |
private $conteneur; |
private $bdd; |
private $messages; |
private $mode; |
public function __construct($conteneur) { |
$this->conteneur = $conteneur; |
$this->bdd = $this->conteneur->getBdd(); |
$this->messages = $this->conteneur->getMessages(); |
$this->mode = $this->conteneur->getParametre('m'); |
} |
/** |
* Fonction qui parcourt tous les ways les noeuds de chaque relation en prenant en considération l'ordre et |
* le sens de chaque ways concaténés ensemble (séparés par des virgules). Update du champ polygone de chaque |
* relation dans la table `osm_relations` |
*/ |
public function executer() { |
// Lancement de l'action demandée |
$cmd = $this->conteneur->getParametre('a'); |
switch ($cmd) { |
case 'polygone' : |
$this->genererPolygones(); |
break; |
case 'centre' : |
$this->mettreAJourCentroide(); |
break; |
case 'zero' : |
$this->remettreOrdreAZero(); |
break; |
default : |
$msgTpl = "Erreur : la commande '%s' n'est pas prise en compte par la classe %s !"; |
$msg = sprintf($msgTpl, $cmd, get_class($this)); |
throw new Exception($msg); |
} |
print "\n";// Pour ramener à la ligne en fin de script |
} |
private function genererPolygones() { |
$relations = $this->getRelations(); |
foreach ($relations as $relation) { |
$chemins = $this->getChemins($relation['id_relation']); |
$noeuds = array(); |
foreach ($chemins as $chemin) { |
$noeuds = array_merge($noeuds, $this->getNoeuds($chemin['id_chemin'], $chemin['sens'])); |
} |
$this->creerPolygone($relation, $noeuds); |
if ($this->mode == 'manuel') { |
$this->messages->afficherAvancement("Création du polygone pour la relation : ", 1); |
} |
} |
} |
private function getRelations() { |
$requete = 'SELECT id_relation, nom, code_insee '. |
'FROM osm_relations '. |
' -- '.__FILE__.' : '.__LINE__; |
$relations = $this->bdd->recupererTous($requete); |
return $relations; |
} |
private function getChemins($idRelation) { |
$requete = 'SELECT id_chemin, sens '. |
'FROM osm_relation_a_chemins '. |
"WHERE id_relation = $idRelation ". |
'ORDER BY ordre '. |
' -- '.__FILE__.' : '.__LINE__; |
$chemins = $this->bdd->recupererTous($requete); |
return $chemins; |
} |
private function getNoeuds($idChemin, $sens) { |
$tri = ($sens == 'directe') ? 'ASC' : 'DESC'; |
$requete = 'SELECT NLL.id_noeud, NLL.lat, NLL.`long` '. |
'FROM osm_chemin_a_noeuds AS WN '. |
' INNER JOIN osm_noeuds AS NLL ON (WN.id_noeud = NLL.id_noeud) '. |
"WHERE WN.id_chemin = $idChemin ". |
"ORDER BY WN.ordre $tri ". |
' -- '.__FILE__.' : '.__LINE__; |
$noeuds = $this->bdd->recupererTous($requete); |
$latLng = array(); |
foreach ($noeuds as $noeud) { |
$latLng[] = $noeud['lat'].' '.$noeud['long']; |
} |
return $latLng; |
} |
private function creerPolygone($relation, $noeuds) { |
$polygone = implode(', ', $noeuds); |
$idRelation = $relation['id_relation']; |
$nomCommuneP = $this->bdd->proteger($relation['nom']); |
$InseeP = $this->bdd->proteger($relation['code_insee']); |
$note = ($noeuds[0] == $noeuds[count($noeuds) - 1]) ? 'Polygone complet' : 'Polygone incomplet'; |
$requete = 'REPLACE INTO osm_communes (id_relation, nom, code_insee, polygone, notes ) '. |
"VALUES ($idRelation, $nomCommuneP, $InseeP, ". |
"POLYFROMTEXT('MULTIPOLYGON ((($polygone)))'), '$note') ". |
' -- '.__FILE__.' : '.__LINE__; |
unset($polygone); |
$this->bdd->requeter($requete); |
} |
/** |
* Pour chaque commune, renseigne le champe "centre" avec un point centroïde du polygone (si non null). |
*/ |
private function mettreAJourCentroide() { |
$requete = 'UPDATE osm_communes '. |
'SET centre = CENTROID(polygone) '. |
"WHERE polygone IS NOT NULL ". |
' -- '.__FILE__.' : '.__LINE__; |
$retour = $this->bdd->requeter($requete); |
$this->messages->traiterInfo("Nombre de centroïde mis à jour : ".$retour->rowCount()); |
} |
/** |
* Pour chaque commune, remet à zéro l'ordre des chemins si le polygone est incomplet. |
*/ |
private function remettreOrdreAZero() { |
$sousRequeteRelations = 'SELECT DISTINCT id_relation '. |
'FROM osm_communes '. |
"WHERE notes = 'Polygone incomplet' "; |
$requete = 'UPDATE osm_relation_a_chemins '. |
'SET ordre = NULL '. |
"WHERE id_relation IN ($sousRequeteRelations) ". |
' -- '.__FILE__.' : '.__LINE__; |
$retour = $this->bdd->requeter($requete); |
$this->messages->traiterInfo("Nombre de chemins remis à zéro : ".$retour->rowCount()); |
} |
} |
/branches/v5.12-baouque/scripts/modules/osm/archives/PolygoneReparateur.php |
---|
New file |
0,0 → 1,300 |
<?php |
/** |
* Réparation des polygones incomplets : |
* |
* Exemple de lancement du script : |
* /opt/lampp/bin/php -d memory_limit=8000M cli.php osm -a ordonnerPolygoneInc -m manuel -v 3 |
* |
* /opt/lampp/bin/php -d memory_limit=8000M cli.php osm -a remplirPolygoneInc -m manuel -v 3 |
* |
* /opt/lampp/bin/php -d memory_limit=8000M cli.php osm -a renommer -m manuel -v 3 |
* |
*/ |
class PolygoneReparateur { |
private $conteneur; |
private $bdd; |
private $messages; |
private $mode; |
public function __construct($conteneur) { |
$this->conteneur = $conteneur; |
$this->bdd = $this->conteneur->getBdd(); |
$this->messages = $this->conteneur->getMessages(); |
$this->mode = $this->conteneur->getParametre('m'); |
} |
/** |
* Fonction qui parcourt tous les ways les noeuds de chaque relation en prenant en considération l'ordre et |
* le sens de chaque ways concaténés ensemble (séparés par des virgules). Update du champ polygone de chaque |
* relation dans la table `osm_relations` |
*/ |
public function executer() { |
// Lancement de l'action demandée |
$cmd = $this->conteneur->getParametre('a'); |
switch ($cmd) { |
case 'ordonnerPolygoneInc' : |
$this->ordonnerRelationsAuPolygoneIncomplet(); |
break; |
case 'remplirPolygoneInc' : |
$this->remplirRelationsAuPolygoneIncomplet(); |
break; |
case 'renommer' : |
$this->renommerEnPolygoneIncomplet(); |
break; |
default : |
$msgTpl = "Erreur : la commande '%s' n'est pas prise en compte par la classe %s !"; |
$msg = sprintf($msgTpl, $cmd, get_class($this)); |
throw new Exception($msg); |
} |
print "\n";// Pour ramener à la ligne en fin de script |
} |
/** |
* Fonction qui récupère les relations des polygones incomplets et appelle pour chaque relation la fonction |
* ordonnerPolygoneIncomplet($ordre,$tour,$idRelation,$nombrePolygone) |
*/ |
private function ordonnerRelationsAuPolygoneIncomplet() { |
$relations = $this->getRelationsAuPolygoneIncomplet(); |
foreach ($relations as $relation) { |
$idRelation = $relation['id_relation']; |
$this->ordonnerCheminsMultiPolygone($idRelation); |
if ($this->mode == 'manuel') { |
$this->messages->afficherAvancement("Réparation du polygone incomplet : ", 1); |
} |
} |
} |
/** |
* Fonction récursive qui exécute la même tâche que la fonction ordonnerWays() pour chaque polygone d'un |
* multipolygone et remplie le champ NbPoly dans la table `osm_relation_a_chemins` qui correspond au nombre de polygone fermé |
* dans le multipolygone |
*/ |
private function ordonnerCheminsMultiPolygone($idRelation, $numPolygone = 1, $ordre = 1, $tour = 1) { |
$chemins = $this->getChemins($idRelation); |
$nbreCheminsTotal = count($chemins); |
// premier élément du tableau |
$idPremierChemin = $chemins[0]['id_chemin']; |
$idChemin = $idPremierChemin; |
$this->mettreAJourChemin($idRelation, $idPremierChemin, $ordre, 'directe', $numPolygone); |
//selection dernier noeud |
$nodes = $this->getNoeuds($idPremierChemin); |
$nombreNodes = count($nodes); |
$premierNoeud = $nodes[0]['id_noeud']; |
$dernierNoeud = $nodes[$nombreNodes - 1]['id_noeud']; |
$noeudActuel = $dernierNoeud; |
//Condition pour laquelle la boucle while continue à tourner; tant que le premier noeud du polygone n'est |
//égale au dernier et tant qu'il reste des ways à gérer |
while (($premierNoeud != $noeudActuel) && (($ordre % 1000) < $nbreCheminsTotal)) { |
//select le way qui possède le dernier noeud du précédent way et écarter l'actuel |
$ordre++; |
$chemins = $this->getCheminsAOrdonner($idRelation, $idChemin, $noeudActuel); |
if (isset($chemins[0])) { |
$idChemin = $chemins[0]['id_chemin']; |
$nodes = $this->getNoeuds($idChemin); |
$nombreNodes = count($nodes); |
if (strcmp($nodes[0]['id_noeud'], $noeudActuel ) == 0) { |
$sens = 'directe'; |
$noeudActuel = $nodes[$nombreNodes-1]['id_noeud']; |
} else { |
$sens = 'indirecte'; |
$noeudActuel = $nodes[0]['id_noeud']; |
} |
$this->mettreAJourChemin($idRelation, $idChemin, $ordre, $sens, $numPolygone); |
} |
} |
$ordre = 1000 * $tour; //différencier chaque polygone: pour chaque polygone on a un multiple de mille |
if ($this->getNombreChemins($idRelation) != 0) { |
//appelle de la méthode récursivement |
$this->ordonnerCheminsMultiPolygone($idRelation, ++$numPolygone, $ordre, ++$tour); |
} |
} |
private function getRelationsAuPolygoneIncomplet() { |
$requete = 'SELECT id_relation '. |
'FROM osm_communes '. |
"WHERE notes = 'Polygone incomplet' ". |
' -- '.__FILE__.' : '.__LINE__; |
$relations = $this->bdd->recupererTous($requete); |
return $relations; |
} |
private function getChemins($idRelation) { |
$requete = 'SELECT id_chemin '. |
'FROM osm_relation_a_chemins '. |
"WHERE id_relation = $idRelation ". |
"AND ordre IS NULL ". |
' -- '.__FILE__.' : '.__LINE__; |
$chemins = $this->bdd->recupererTous($requete); |
return $chemins; |
} |
/** |
* Select des ways qui n'ont pas été ordonnés: on obtient à chaque itération les ways qui restent à ordonner |
*/ |
private function getCheminsAOrdonner($idRelation, $idChemin, $idNoeud) { |
$requete = 'SELECT cn.id_chemin '. |
'FROM osm_relation_a_chemins AS rc '. |
' INNER JOIN osm_chemin_a_noeuds AS cn ON (rc.id_chemin = cn.id_chemin) '. |
"WHERE cn.id_noeud = $idNoeud ". |
"AND cn.id_chemin != $idChemin ". |
"AND rc.id_relation = $idRelation ". |
"AND rc.ordre IS NULL ". |
' -- '.__FILE__.' : '.__LINE__; |
$chemins = $this->bdd->recupererTous($requete); |
return $chemins; |
} |
private function getNoeuds($idChemin) { |
$requete = 'SELECT id_noeud '. |
'FROM osm_chemin_a_noeuds '. |
"WHERE id_chemin = $idChemin ". |
'ORDER BY ordre '. |
' -- '.__FILE__.' : '.__LINE__; |
$noeuds = $this->bdd->recupererTous($requete); |
return $noeuds; |
} |
private function getNombreChemins($idRelation) { |
$requete = 'SELECT COUNT(id_chemin) AS nbre '. |
'FROM osm_relation_a_chemins '. |
"WHERE id_relation = $idRelation ". |
'AND ordre = 0 '. |
' -- '.__FILE__.' : '.__LINE__; |
$infos = $this->bdd->recuperer($requete); |
return $infos['nbre']; |
} |
private function mettreAJourChemin($idRelation, $idChemin, $ordre, $sens, $nbrePoly) { |
$requete = 'UPDATE osm_relation_a_chemins '. |
"SET ordre = '$ordre', sens = '$sens', num_poly = $nbrePoly ". |
"WHERE id_relation = $idRelation ". |
"AND id_chemin = $idChemin ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
/** |
* Fonction qui récupère les relations des polygones incomplets et appelle pour chaque relation la fonction |
* remplirPolygoneIncomplet($idRelation); |
*/ |
private function remplirRelationsAuPolygoneIncomplet() { |
$relations = $this->getRelationsAuPolygoneIncomplet(); |
foreach ($relations as $relation) { |
$this->remplirPolygoneIncomplet($relation['id_relation']); |
if ($this->mode == 'manuel') { |
$this->messages->afficherAvancement("Création du polygone incomplet : ", 1); |
} |
} |
} |
/** |
* Fonction qui exécute la même tâche que la fonction remplirPolygone() pour chaque polygone d'un multipolygone |
* et renvoie un tableau MultiPolygone[] où chaque case contient un polygone fermé. Puis met à jour le polygone |
* de la commune. |
*/ |
private function remplirPolygoneIncomplet($idRelation) { |
// Tableau multipolygone qui contient tous les polygones d'un multipolygone |
$multiPolygone = array(); |
// Tableau roles qui contient les différents roles des chemins de la relation |
$roles = array(); |
// Sélectionner le nombre de polygones qui existe dans un multipolygone |
$nbPoly = $this->getNombrePoly($idRelation); |
//boucle for qui parcourt chaque polygone du multipolygone |
for ($numPoly = 1; $numPoly <= $nbPoly; $numPoly++) { |
$polygone = array(); |
$chemins = $this->getCheminsParPolygone($idRelation, $numPoly); |
foreach ($chemins as $chemin) { |
$role = $chemin['role']; |
$roles[$role] = (isset($roles[$role])) ? $roles[$role]++ : 1; |
$noeuds = $this->getNoeudsPourCheminEtSens($chemin['id_chemin'], $chemin['sens']); |
$polygone = array_merge($polygone, $noeuds); |
} |
$multiPolygone[] = implode(', ', $polygone); |
} |
$this->mettreAJourMultiPolygone($multiPolygone, $roles, $idRelation, $nbPoly); |
} |
private function getNombrePoly($idRelation) { |
$requete = 'SELECT MAX(num_poly) AS num_poly '. |
'FROM osm_relation_a_chemins '. |
"WHERE id_relation = $idRelation ". |
' -- '.__FILE__.' : '.__LINE__; |
$resultat = $this->bdd->recuperer($requete); |
return $resultat['num_poly']; |
} |
private function getCheminsParPolygone($idRelation, $numPoly) { |
$requete = 'SELECT id_chemin, sens, role '. |
'FROM osm_relation_a_chemins '. |
"WHERE id_relation = $idRelation ". |
"AND num_poly = $numPoly ". |
'ORDER BY ordre '. |
' -- '.__FILE__.' : '.__LINE__; |
$chemins = $this->bdd->recupererTous($requete); |
return $chemins; |
} |
private function getNoeudsPourCheminEtSens($idChemin, $sens) { |
$tri = ($sens == 'directe') ? 'ASC' : 'DESC'; |
$requete = 'SELECT NLL.id_noeud, NLL.lat, NLL.`long` '. |
'FROM osm_chemin_a_noeuds AS WN '. |
' INNER JOIN osm_noeuds AS NLL ON (WN.id_noeud = NLL.id_noeud) '. |
"WHERE WN.id_chemin = $idChemin ". |
"ORDER BY WN.ordre $tri ". |
' -- '.__FILE__.' : '.__LINE__; |
$noeuds = $this->bdd->recupererTous($requete); |
$latLng = array(); |
foreach ($noeuds as $noeud) { |
$latLng[] = $noeud['lat'].' '.$noeud['long']; |
} |
return $latLng; |
} |
/** |
* Remplie le champ polygone à partir du tableau MultiPolygone |
*/ |
private function mettreAJourMultiPolygone($multiPolygone, $roles, $idRelation, $nbPoly) { |
// Présence d'une enclave contenue dans cette entité administrative mais qui appartient à une autre entité administrative |
if ((isset($roles['inner']) || isset($roles['enclave']))) { |
if ($nbPoly == 2) { |
$multiPoly = implode('),(', $multiPolygone); |
} else { |
$multiPoly = null; |
$msgTpl = "La relation '%s' possède plus de 2 polygones de type enclaves."; |
$this->messages->traiterErreur($msgTpl, array($idRelation)); |
} |
} else { |
// Tous les autres cas |
$multiPoly = implode(')),((', $multiPolygone); |
} |
if (isset($multiPoly)) { |
$this->mettreAJourCommune($idRelation, $multiPoly); |
} |
} |
private function mettreAJourCommune($idRelation, $multiPoly) { |
$requete = 'UPDATE osm_communes '. |
"SET polygone = MPOLYFROMTEXT('MULTIPOLYGON((($multiPoly)))'), ". |
"notes = 'Polygone complet' ". |
"WHERE id_relation = $idRelation ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
/** |
* Renomme la note des polygones vides d'un polygone complet en polygone incomplet |
*/ |
private function renommerEnPolygoneIncomplet() { |
$requete = 'UPDATE osm_communes '. |
"SET notes = 'Polygone incomplet' ". |
"WHERE ASTEXT(polygone) IS NULL ". |
' -- '.__FILE__.' : '.__LINE__; |
$retour = $this->bdd->requeter($requete); |
$this->messages->traiterInfo("Nombre de polygones définis à incomplet : ".$retour->rowCount()); |
} |
} |
/branches/v5.12-baouque/scripts/modules/osm/archives/OrdonneurDeChemins.php |
---|
New file |
0,0 → 1,226 |
<?php |
/** |
* Traitement de l'ordre : |
* |
* Fonction qui rajoute l'ordre et le sens de chaque way d'une relation dans la table `osm_relation_a_chemins` |
* |
* Exemple de lancement du script : |
* /opt/lampp/bin/php -d memory_limit=8000M cli.php osm -a ordre -m manuel |
* |
*/ |
class OrdonneurDeChemins { |
private $conteneur; |
private $bdd; |
private $messages; |
private $mode; |
private $premierNoeudPolygon = null; |
private $infosRel = array(); |
private $infosNoeuds = array(); |
private $idRelation = null; |
private $idChemin = null; |
private $idNoeud = null; |
private $ordre = 0; |
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() { |
$relations = $this->getToutesRelationsAChemins(); |
if ($this->mode == 'manuel') { |
$this->messages->traiterInfo("Nombre de relations : %s", array(count($relations))); |
} |
foreach ($relations as $relation) { |
// Traitement de la relation courante |
$this->idRelation = $relation['id_relation']; |
$this->chargerDonneesRelationActuelle(); |
$numPolygon = 1; |
while(count($this->chemins) > 0) { |
reset($this->chemins); |
$idChemin = key($this->chemins); |
echo "--------------POLY : $numPolygon : $idChemin\n"; |
$this->ordonnerCheminsRelation($numPolygon, $idChemin); |
$this->mettreAJourRelationAChemin(); |
$numPolygon++; |
} |
// Affichage de l'avancement |
if ($this->mode == 'manuel') { |
$this->messages->afficherAvancement("Ordone les chemins de la relation : ", 1); |
} |
} |
} |
private function getToutesRelationsAChemins() { |
$requete = 'SELECT DISTINCT id_relation '. |
'FROM osm_relation_a_chemins '. |
'WHERE id_relation = 403823 '. |
' -- '.__FILE__.' : '.__LINE__; |
$relations = $this->bdd->recupererTous($requete); |
return $relations; |
} |
private function chargerDonneesRelationActuelle() { |
$requete = 'SELECT cn.id_chemin, cn.id_noeud, cn.ordre '. |
'FROM osm_relation_a_chemins AS rc '. |
' INNER JOIN osm_chemin_a_noeuds AS cn ON (rc.id_chemin = cn.id_chemin) '. |
"WHERE rc.id_relation = {$this->idRelation} ". |
"ORDER BY rc.ordre ASC, cn.ordre ASC ". |
' -- '.__FILE__.' : '.__LINE__; |
$infos = $this->bdd->recupererTous($requete); |
$noeuds = array(); |
foreach ($infos as $info) { |
$noeuds[$info['id_noeud']][$info['id_chemin']] = $info['ordre']; |
if (! isset($this->chemins[$info['id_chemin']]) ) { |
$this->chemins[$info['id_chemin']]['max'] == info['ordre']; |
if ($info['ordre'] == 1) { |
$this->chemins[$info['id_chemin']][0] == $info['id_noeud']; |
} |
} else { |
} |
if (count($noeuds[$info['id_noeud']]) == 2) { |
list($premierChemin, $dernierChemin) = array_keys($noeuds[$info['id_noeud']]); |
$this->chemins[$premierChemin][] = $info['id_noeud']; |
$this->chemins[$dernierChemin][] = $info['id_noeud']; |
$this->noeuds[$info['id_noeud']][$premierChemin] = $dernierChemin; |
$this->noeuds[$info['id_noeud']][$dernierChemin] = $premierChemin; |
} |
} |
//print_r($this->chemins);exit(); |
} |
private function ordonnerCheminsRelation($numPolygon, $idChemin, $idCheminPrecedent = null, $ordre = 1) { |
$this->infosRel[$idChemin] = array($ordre, $numPolygon); |
list($premierNoeud, $dernierNoeud) = $this->chemins[$idChemin]; |
if ($idCheminPrecedent == null) {// Premier chemin à tester |
$this->premierNoeudPolygon = $premierNoeud; |
$noeudSuivant = ($dernierNoeud == $premierNoeud) ? $premierNoeud : $dernierNoeud; |
echo "Chemin $idChemin :: premierNoeud: $premierNoeud, dernierNoeud: $dernierNoeud \n"; |
} else { |
list($premierNoeudPrec, $dernierNoeudPrec) = $this->chemins[$idCheminPrecedent]; |
unset($this->chemins[$idCheminPrecedent]); |
$noeudSuivant = ($dernierNoeudPrec == $dernierNoeud || $premierNoeudPrec == $dernierNoeud) ? $premierNoeud : $dernierNoeud; |
echo "Chemin $idChemin :: premierNoeudPrec: $premierNoeudPrec, dernierNoeudPrec: $dernierNoeudPrec, premierNoeud: $premierNoeud, dernierNoeud: $dernierNoeud \n"; |
} |
if ($this->premierNoeudPolygon != $noeudSuivant) { |
if (isset($this->noeuds[$noeudSuivant][$idChemin])) { |
$idCheminSuivant = $this->noeuds[$noeudSuivant][$idChemin]; |
if (! isset($this->infosRel[$idCheminSuivant])) { |
$this->ordonnerCheminsRelation($numPolygon, $idCheminSuivant, $idChemin, ++$ordre); |
} else { |
$this->messages->traiterAvertissement("Chemins %s déjà pris en comtpe", array($idCheminSuivant)); |
} |
} else { |
$this->messages->traiterAvertissement("Relation %s a un polygone incomplet", array($this->idRelation)); |
} |
} else { |
unset($this->chemins[$idChemin]); |
} |
return null; |
} |
private function mettreAJourRelationAChemin() { |
if (count($this->infosRel) > 0) { |
foreach ($this->infosRel as $idC => $donnees) { |
list($ordre, $numPolygon) = $this->bdd->proteger($donnees); |
$requete = 'UPDATE osm_relation_a_chemins '. |
"SET sens = $ordre, num_poly = $numPolygon ". |
"WHERE id_relation = {$this->idRelation} ". |
"AND id_chemin = $idC ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
$this->infosRel = array(); |
} |
} |
private function creerSet($donnees) { |
$values = array(); |
foreach ($donnees as $infos) { |
$infosP = $this->bdd->proteger($infos); |
$values[] = implode(',', $infosP); |
} |
$valuesClause = '('.implode('),(', $values).')'; |
return $valuesClause; |
} |
private function getIdPremierChemin() { |
$idChemin = null; |
if (count($this->infosRel) > 0) { |
reset($this->infosRel); |
$idChemin = key($this->infosRel); |
} |
return $idChemin; |
} |
private function mettreAJourChemin($sens, $ligne, $fichier = __FILE__) { |
$ordre = $this->ordre++; |
$requete = 'UPDATE osm_relation_a_chemins '. |
"SET ordre = '$ordre', sens = '$sens' ". |
"WHERE id_relation = {$this->idRelation} ". |
"AND id_chemin = {$this->idChemin} ". |
" -- $fichier : $ligne"; |
$retour = $this->bdd->requeter($requete); |
return $retour; |
} |
private function getIdDernierNoeud() { |
$idNoeud = false; |
if (count($this->infosRel[$this->idChemin]) > 0) { |
end($this->infosRel[$this->idChemin]); |
$idNoeud = current($this->infosRel[$this->idChemin]); |
} |
return $idNoeud; |
} |
private function ordonnerChemins() { |
foreach ($this->infosRel as $chemin) { |
// Selection du chemin qui possède le dernier noeud du précédent chemin et écarter l'actuel |
$idCheminSuivant = $this->getIdCheminSuivant(); |
if ($idCheminSuivant) { |
$this->idChemin = $idCheminSuivant; |
$idPremierNoeud = $this->getIdPremierNoeud(); |
$idDernierNoeud = $this->getIdDernierNoeud(); |
$sens = $this->getSens($idPremierNoeud); |
$this->mettreAJourChemin($sens, __LINE__); |
$this->idNoeud = ($sens == 'directe') ? $idDernierNoeud : $idPremierNoeud; |
} |
} |
} |
private function getIdCheminSuivant() { |
$idCheminSuivant = false; |
if (isset($this->infosNoeuds[$this->idNoeud])) { |
$idCheminSuivant = next($this->infosNoeuds[$this->idNoeud]); |
//echo $this->idChemin.'-'.$idCheminSuivant."\n".print_r($this->infosNoeuds[$this->idNoeud]); exit(); |
} else { |
$msg = "Impossible de trouver le chemin suivant pour la relation : %s, le chemin %s et le noeud %s"; |
$this->messages->traiterAvertissement($msg, array($this->idRelation, $this->idChemin, $this->idNoeud)); |
} |
return $idCheminSuivant; |
} |
private function getSens($idPremierNoeud) { |
$sens = ( strcmp($idPremierNoeud, $this->idNoeud ) == 0 ) ? 'directe' : 'indirecte'; |
return $sens; |
} |
private function getIdPremierNoeud() { |
$idNoeud = false; |
if (count($this->infosRel[$this->idChemin]) > 0) { |
reset($this->infosRel[$this->idChemin]); |
$idNoeud = current($this->infosRel[$this->idChemin]); |
} |
return $idNoeud; |
} |
} |
/branches/v5.12-baouque/scripts/modules/osm/archives/config.ini |
---|
New file |
0,0 → 1,9 |
; Ajouter les nouvelles version à la suite dans versions et versionsDonnees. |
version = "1.0" |
dossierSql = "{ref:dossierDonneesEflore}osm/" |
[fichiers] |
structureSql = "osm_v{ref:version}.sql" |
[chemins] |
structureSql = "{ref:dossierSql}{ref:version}/{ref:fichiers.structureSql}" |
/branches/v5.12-baouque/scripts/modules/osm/archives/MiseAJour.php |
---|
New file |
0,0 → 1,417 |
<?php |
/** |
* Permet de mettre à jour les contours à partir d'un fichier de diff. |
* |
* Exemple de lancement du script : |
* /opt/lampp/bin/php -d memory_limit=3500M cli.php osm -a maj -f fichier_osm_change -e fichier_osm_nouveau |
*/ |
class MiseAJour { |
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; |
private $elementType = ''; |
public function __construct($conteneur) { |
$this->conteneur = $conteneur; |
$this->bdd = $this->conteneur->getBdd(); |
$this->messages = $this->conteneur->getMessages(); |
$this->mode = $this->conteneur->getParametre('m'); |
} |
/** |
* Fonction qui parcourt tous les ways les noeuds de chaque relation en prenant en considération l'ordre et |
* le sens de chaque ways concaténés ensemble (séparés par des virgules). Update du champ polygone de chaque |
* relation dans la table `osm_relations` |
*/ |
public function executer() { |
// Lancement de l'action demandée |
$cmd = $this->conteneur->getParametre('a'); |
switch ($cmd) { |
case 'maj' : |
$this->mettreAjour(); |
break; |
default : |
$msgTpl = "Erreur : la commande '%s' n'est pas prise en compte par la classe %s !"; |
$msg = sprintf($msgTpl, $cmd, get_class($this)); |
throw new Exception($msg); |
} |
print "\n";// Pour ramener à la ligne en fin de script |
} |
/** |
* Fonction permettant de traiter et d'analyser le fichier de différence et de mettre à jour la base de données |
* en tenant compte des trois cas:Suppression, Création ,modification |
*/ |
private function mettreAjour() { |
$lecteur = $this->getLecteurXml(); |
while ($lecteur->read()) { |
if ($lecteur->nodeType == XMLREADER::ELEMENT) { |
$this->elementType = $lecteur->localName; |
$this->analyserElementXml($lecteur->localName, $lecteur->expand()); |
} |
if ($this->mode == 'manuel') { |
$this->messages->afficherAvancement("Analyse de la ligne du fichier de diff OSM : ", 1); |
} |
} |
} |
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; |
} |
private function analyserElementXml($noeudDom) { |
$relations = $noeudDom->getElementsByTagName('relation'); |
if ($relations->length > 0) { |
foreach ($relations as $relation) { |
$this->analyserRelation($relation); |
$this->traiterRelations(); |
} |
} |
$ways = $creations->getElementsByTagName('way'); |
if ($ways->length > 0) { |
foreach ($ways as $way) { |
$this->analyserWay($way); |
$this->traiterCheminANoeuds(); |
} |
} |
$noeuds = $creations->getElementsByTagName('node'); |
if ($noeuds->length > 0) { |
foreach ($noeuds as $noeud) { |
$this->analyserNode($noeud); |
$this->traiterNoeuds(); |
} |
} |
$this->traiterElementsOrphelins(); |
} |
private function traiterRelations() { |
if (count($this->relation_a_chemins) > $this->pas) { |
switch ($this->elementType) { |
case 'create' : |
$this->insererRelationAChemins(); |
break; |
case 'modify' : |
$this->modifierRelationAChemins(); |
break; |
case 'delete' : |
$this->supprimerRelationAChemins(); |
break; |
} |
} |
if (count($this->relations_communes) > $this->pas_commune) { |
switch ($this->elementType) { |
case 'create' : |
$this->insererRelationsCommunes(); |
break; |
case 'modify' : |
$this->modifierRelationsCommunes(); |
break; |
case 'delete' : |
$this->supprimerRelationsCommunes(); |
break; |
} |
} |
} |
private function traiterChemins() { |
if (count($this->chemin_a_noeuds) > $this->pas) { |
switch ($this->elementType) { |
case 'create' : |
$this->insererCheminANoeuds(); |
break; |
case 'modify' : |
$this->modifierCheminANoeuds(); |
break; |
case 'delete' : |
$this->supprimerCheminANoeuds(); |
break; |
} |
} |
} |
private function traiterNoeuds() { |
if (count($this->noeuds) > $this->pas) { |
switch ($this->elementType) { |
case 'create' : |
$this->insererNoeuds(); |
break; |
case 'modify' : |
$this->modifierNoeuds(); |
break; |
case 'delete' : |
$this->supprimerNoeuds(); |
break; |
} |
} |
} |
private function traiterElementsOrphelins() { |
switch ($this->elementType) { |
case 'create' : |
$this->insererRelationsCommunes(); |
$this->insererRelationAChemins(); |
$this->insererCheminANoeuds(); |
$this->insererNoeuds(); |
break; |
case 'modify' : |
$this->modifierRelationsCommunes(); |
$this->modifierRelationAChemins(); |
$this->modifierCheminANoeuds(); |
$this->modifierNoeuds(); |
break; |
case 'delete' : |
$this->supprimerRelationsCommunes(); |
$this->supprimerRelationAChemins(); |
$this->supprimerCheminANoeuds(); |
$this->supprimerNoeuds(); |
break; |
} |
} |
/** |
* Récupère l'id commune, nom commune et le code INSEE et remplie la table `osm_relations` |
*/ |
private function analyserRelation($relation) { |
$relation_id = $relation->getAttribute('id'); |
$chemins = $relation->getElementsByTagName('member'); |
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); |
} |
} |
$tags = $relation->getElementsByTagName('tag'); |
if ($tags->length > 0) { |
$this->analyserTags($relation_id, $tags); |
} |
} |
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)) { |
$this->relations_communes[] = array($relation_id, $commune_nom, $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->traiterErreur($e, array($this->communes[$commune_insee], $commune_insee, $relation_id)); |
} |
break; |
} |
} |
} |
/** |
* 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'); |
$noeuds = $way->getElementsByTagName('nd'); |
$ordre = 0; |
foreach ($noeuds as $noeud) { |
$noeud_id = $noeud->getAttribute('ref'); |
$this->chemin_a_noeuds[] = array($chemin_id, $noeud_id, ++$ordre); |
} |
} |
/** |
* 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) { |
$this->noeuds[] = array( |
$node->getAttribute('id'), |
$node->getAttribute('lat'), |
$node->getAttribute('lon') |
); |
} |
//Insertion des relations |
private function insererRelationsCommunes() { |
$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(); |
} |
//Insertion des relations à chemins |
private function insererRelationAChemins() { |
$requete = 'INSERT INTO osm_relation_a_chemins (id_relation, id_chemin, role) '. |
'VALUES '.$this->creerValuesMultiple($this->relation_a_chemins). |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
$this->relation_a_chemins = array(); |
} |
//Insertion des chemins à noeuds |
private function insererCheminANoeuds() { |
$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(); |
} |
//Insertion des noeuds |
private function insererNoeuds() { |
$requete = 'INSERT INTO osm_noeuds (id_noeud, lat, `long`) '. |
'VALUES '.$this->creerValuesMultiple($this->noeuds). |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
$this->noeuds = array(); |
} |
//Update des relations |
private function modifierRelationsCommunes() { |
foreach ($this->relations_communes as $donnee) { |
$infosP = $this->bdd->proteger($donnee); |
$requete = 'UPDATE osm_relations '. |
"SET id_relation = $infosP[0], nom = $infosP[1], code_insee = $infosP[2] ". |
"WHERE id_relation = $infosP[0] ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
$this->relations_communes = array(); |
} |
/* |
*Update des relations à chemins en supprimant l'ancienne relation et tous ses chemins |
*de la table osm_relation_a_chemins et insérer la nouvelle |
*/ |
private function modifierRelationAChemins() { |
$this->supprimerRelationAChemins(); |
foreach ($this->relation_a_chemins as $donnee) { |
$infosP = $this->bdd->proteger($donnee); |
$requete = 'INSERT INTO osm_relation_a_chemins (id_relation, id_chemin, role) '. |
"VALUES ($infosP[0], $infosP[1], $infosP[2]) ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
$this->relation_a_chemins = array(); |
} |
/* |
*Update des chemins à noeuds en supprimant l'ancien chemin et tous ses noeuds |
*de la table osm_chemins_a_noeuds et insérer le nouveau |
*/ |
private function modifierCheminANoeuds() { |
$this->supprimerCheminANoeuds(); |
foreach ($this->chemin_a_noeuds as $donnee) { |
$infosP = $this->bdd->proteger($donnee); |
$requete = 'INSERT INTO osm_chemin_a_noeuds (id_chemin, id_noeud, ordre) '. |
"VALUES ($infosP[0], $infosP[1], $infosP[2]) ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
$this->chemin_a_noeuds = array(); |
} |
//Update des noeuds |
private function modifierNoeuds() { |
foreach ($this->noeuds as $donnee) { |
$infosP = $this->bdd->proteger($donnee); |
$requete = 'UPDATE osm_noeuds '. |
"SET id_noeud = $infosP[0], lat = $infosP[1], `long` = $infosP[2] ". |
"WHERE id_noeud = $infosP[0] ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
$this->noeuds = array(); |
} |
//Suppressions des relations |
private function supprimerRelationsCommunes() { |
$idsIn = $this->getIds($this->relations_communes); |
$this->relations_communes = array(); |
$requete = 'DELETE FROM osm_relations '. |
"WHERE id_relation IN ($idsIn) ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
//Suppressions des relations à chemins |
private function supprimerRelationAChemins() { |
$idsIn = $this->getIds($this->relation_a_chemins); |
$this->relation_a_chemins = array(); |
$requete = 'DELETE FROM osm_relation_a_chemins '. |
"WHERE id_relation IN ($idsIn) ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
//Suppressions des chemins à noeuds |
private function supprimerCheminANoeuds() { |
$idsIn = $this->getIds($this->chemin_a_noeuds); |
$this->chemin_a_noeuds = array(); |
$requete = 'DELETE FROM osm_chemin_a_noeuds '. |
"WHERE id_chemin IN ($idsIn) ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
//Suppressions des chemins à noeuds |
private function supprimerNoeuds() { |
$idsIn = $this->getIds($this->noeuds); |
$this->noeuds = array(); |
$requete = 'DELETE FROM osm_noeuds '. |
"WHERE id_noeud IN ($idsIn) ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
private function getIds(&$tableau) { |
$ids = array(); |
foreach ($tableau as $info) { |
$ids[] = $this->bdd->proteger($info[0]); |
} |
$idsSansDoublon = array_unique($ids); |
$idsIn = implode(',', $idsSansDoublon); |
return $idsIn; |
} |
private function creerValuesMultiple($donnees) { |
$values = array(); |
foreach ($donnees as $infos) { |
$infosP = $this->bdd->proteger($infos); |
$values[] = implode(',', $infosP); |
} |
$valuesClause = '('.implode('),(', $values).')'; |
return $valuesClause; |
} |
} |
/branches/v5.12-baouque/scripts/modules/osm/archives/Osm.php |
---|
New file |
0,0 → 1,104 |
<?php |
//declare(encoding='UTF-8'); |
/** |
* Exemple de lancement du script : : |
* 1. Création de la base de données : |
* /opt/lampp/bin/php cli.php osm -a chargerStructureSql -m manuel -v 3 |
* |
* 2. Analyse du fichir OSM : |
* /opt/lampp/bin/php cli.php osm -a analyser -f "../donnees/osm/fr_communes_new.osm" -m manuel -v 3 |
* |
* 3. Traitement de l'ordre : |
* /opt/lampp/bin/php cli.php osm -a ordre -m manuel -v 3 |
* |
* 4. Remplissage des polygones : |
* /opt/lampp/bin/php cli.php osm -a polygone -m manuel -v 3 |
* |
* Définition des centroïdes pour les polygones déjà complets: |
* /opt/lampp/bin/php cli.php osm -a centre -m manuel -v 3 |
* |
* 5. Remise de l'ordre à zéro : |
* /opt/lampp/bin/php cli.php osm -a zero -m manuel -v 3 |
* |
* 6. Traitement de l'ordre des polygones incomplets : |
* /opt/lampp/bin/php cli.php osm -a ordonnerPolygoneInc -m manuel -v 3 |
* |
* 7. Remplissage des polygones incomplets : |
* /opt/lampp/bin/php cli.php osm -a remplirPolygoneInc -m manuel -v 3 |
* |
* 8. Renommage des polygones incomplets : |
* /opt/lampp/bin/php cli.php osm -a renommer -m manuel -v 3 |
* |
* 9. Définition des centroïdes : |
* /opt/lampp/bin/php cli.php osm -a centre -m manuel -v 3 |
* |
* @category php 5.4 |
* @package DEL |
* @subpackage Scripts |
* @author Aurélien PERONNET <aurelien@tela-botanica.org> |
* @copyright Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org) |
* @license CeCILL v2 http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt |
* @license GNU-GPL http://www.gnu.org/licenses/gpl.html |
*/ |
// TODO : Améliorer la gestion de l'ordre des chemins pour éviter de prendre en compte des chemins inexistants |
class Osm extends EfloreScript { |
const PROJET_NOM = 'osm'; |
protected $parametres_autorises = array( |
'-f' => array(true, null, 'Chemin du fichier osm à analyser'), |
'-m' => array(false, 'auto', 'Mode «auto» ou «manuel». En manuel, les compteurs dans les boucles sont affichés.')); |
public function executer() { |
try { |
$this->initialiserProjet(self::PROJET_NOM); |
// Lancement de l'action demandée |
$cmd = $this->getParametre('a'); |
switch ($cmd) { |
case 'chargerStructureSql' : |
$this->chargerStructureSql(); |
break; |
case 'analyser' : |
$script = $this->chargerClasse('ParseurOsm'); |
$script->executer(); |
break; |
case 'ordre' : |
$script = $this->chargerClasse('OrdonneurDeChemins'); |
$script->executer(); |
break; |
case 'polygone' : |
case 'centre' : |
case 'zero' : |
$script = $this->chargerClasse('PolygoneCreateur'); |
$script->executer(); |
break; |
case 'ordonnerPolygoneInc' : |
case 'remplirPolygoneInc' : |
case 'renommer' : |
$script = $this->chargerClasse('PolygoneReparateur'); |
$script->executer(); |
break; |
case 'maj' : |
$script = $this->chargerClasse('MiseAJour'); |
$script->executer(); |
break; |
default : |
throw new Exception("Erreur : la commande '$cmd' n'existe pas!"); |
} |
} catch (Exception $e) { |
$this->traiterErreur($e->getMessage()); |
} |
print "\n";// Pour ramener à la ligne en fin de script |
} |
protected function initialiserProjet($projetNom) { |
$this->projetNom = $projetNom; |
} |
private function chargerClasse($classe) { |
require_once $classe.'.php'; |
$conteneur = new Conteneur($this->parametres); |
return new $classe($conteneur); |
} |
} |
/branches/v5.12-baouque/scripts/modules/osm/FranceCommunes.php |
---|
New file |
0,0 → 1,61 |
<?php |
/** |
* Création de la table osm_communes. |
* /opt/lampp/bin/php cli.php osm -a communes -m manuel |
* |
*/ |
class FranceCommunes { |
private $conteneur; |
private $bdd; |
private $messages; |
private $mode; |
private $bddOsmNom; |
public function __construct($conteneur) { |
$this->conteneur = $conteneur; |
$this->bdd = $this->conteneur->getBdd(); |
$this->bddOsmNom = $this->conteneur->getParametre('bdd_osm_nom'); |
$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 'cm' : |
$this->supprimerTableOsmCommunes(); |
$this->conteneur->getEfloreCommun()->chargerStructureSql(); |
$this->creerTableOsmCommunes(); |
break; |
case 'cmCreer' : |
$this->creerTableOsmCommunes(); |
break; |
case 'cmSupprimer' : |
$this->supprimerTableOsmCommunes(); |
break; |
default : |
$this->messages->traiterErreur('Erreur : la commande "%s" n\'existe pas!', array($cmd)); |
} |
} |
private function supprimerTableOsmCommunes() { |
$requete = 'DROP TABLE IF EXISTS osm_communes '. |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
private function creerTableOsmCommunes() { |
$requete = 'INSERT INTO osm_communes '. |
"SELECT osm_id, osm_version, osm_timestamp, name, ref_insee, shape, shape_centroid, wikipedia ". |
"FROM {$this->bddOsmNom}.multipolygons_ref ". |
"WHERE admin_level = 8 ". |
"AND (ref_insee IS NOT NULL OR ref_insee != '') ". |
"AND CHAR_LENGTH(ref_insee) = 5 ". |
' -- '.__FILE__.' : '.__LINE__; |
$this->bdd->requeter($requete); |
} |
} |
/branches/v5.12-baouque/scripts/modules/osm/. |
---|
New file |
Property changes: |
Added: svn:mergeinfo |
Merged /branches/v5.2-alpage/scripts/modules/osm:r976,978 |
Merged /branches/v5.7-arrayanal/scripts/modules/osm:r1050,1052 |
Merged /branches/v5.1-acheb/scripts/modules/osm:r927 |
Merged /branches/v5.7-arrayanal:r1066-1070 |
Added: svn:ignore |
+.config.ini.swp |