Subversion Repositories eFlore/Applications.cel

Compare Revisions

Ignore whitespace Rev 1995 → Rev 1996

/trunk/scripts/modules/migrationsauvages/Migrationsauvages.php
New file
0,0 → 1,134
<?php
// Encodage : UTF-8
// +-------------------------------------------------------------------------------------------------------------------+
/**
* Traitement des observations sauvages pour les migrer vers des champs étendus
*
* Description : classe permettant d'affecter des champs étendus aux observations sauvages
* Utilisation : php script.php migrationsauvages -a migrerObservationsSauvages
*
* @category PHP 5.3
* @package scripts
//Auteur original :
* @author Aurélien PERONNET <aurelien@tela-botanica.org>
* @copyright Copyright (c) 2009, Tela Botanica (accueil@tela-botanica.org)
* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL-v3
* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL-v2
* @version $Id$
*/
// +-------------------------------------------------------------------------------------------------------------------+
class Migrationsauvages extends Script {
// +-------------------------------------------------------------------------------------------------------------------+
public function executer() {
include_once dirname(__FILE__).'/bibliotheque/Dao.php';
$this->dao = new Dao();
// Récupération de paramétres
// Lancement de l'action demandée
$cmd = $this->getParametre('a');
$this->mode_verbeux = $this->getParametre('v');
$this->migrerObservationsSauvages();
}
private function migrerObservationsSauvages() {
$liste_observations = $this->dao->obtenirObservationsSauvages();
$this->traiterObservationsSauvages($liste_observations);
}
private function traiterObservationsSauvages($liste_observations) {
$debut = microtime(true);
$nb_obs_modifiees = 0;
$nb_obs_ignorees = 0;
$total = count($liste_observations);
if($this->mode_verbeux) {
echo "-------------------------------------------------------------------\n";
echo " Début de la migration des observations sauvages vers les champs étendus \n";
echo " ".$total." observations concernées \n";
echo "-------------------------------------------------------------------\n";
}
$champs_etendus_a_inserer = array();
$nb_champs_total = 0;
$nb_champs = 0;
echo " Insertion des champs étendus (5 par observation) par paquet de 100 \n";
foreach($liste_observations as $observation) {
// test si obs candidate est ok, i.e. si elle contient bien un champ station formate comme ceci
// coordonnees_debut_de_rue;coordonnees_fin_de_rue;cote_de_la_rue
if ($this->doitMigrerObservation($observation)) {
$champs_etendus_a_inserer[] = $this->convertirChampsObsSauvagesEnChampsEtendus($observation);
$nb_obs_modifiees++;
$nb_champs += 5;
$nb_champs_total += 5;
} else {
$nb_obs_ignorees++;
}
// insertion par paquets de 100 champs ou bien à la fin du parcours de la liste s'il y a moins de
// 20 observations à traiter (20 obs * 5 champs = 100 champs)
if($nb_champs >= 100 || ($nb_obs_modifiees + $nb_obs_ignorees >= count($liste_observations))) {
$this->dao->ajouterChampsEtendusParLots($champs_etendus_a_inserer);
$champs_etendus_a_inserer = array();
$nb_champs = 0;
if($this->mode_verbeux) {
$this->afficherAvancement(' champs étendus insérés ', $nb_champs_total);
}
}
}
 
$fin = microtime(true);
if($this->mode_verbeux) {
echo "\n";
echo "-------------------------------------------------------------------\n";
echo " Fin de la migration des observations sauvages, \n";
echo " ".($fin - $debut)." secondes écoulées \n";
echo " ".$nb_champs_total." champs étendus créées \n";
echo " ".$nb_obs_modifiees." observations modifiées \n";
echo " ".$nb_obs_ignorees." observations ignorées \n";
echo "-------------------------------------------------------------------\n";
echo "\n";
}
}
private function doitMigrerObservation($observation) {
return (!empty($observation['station']) && substr_count($observation['station'],";") == 2);
}
private function convertirChampsObsSauvagesEnChampsEtendus($observation) {
list($coords_debut_rue,$coords_fin_rue,$cote_rue) = explode(';', $observation['station']);
$coords_debut_rue = explode(',', $coords_debut_rue);
$coords_fin_rue = explode(',', $coords_fin_rue);
$lieu_dit = (trim($observation['lieudit']) == 'non renseigné(e)') ? '' : $observation['lieudit'];
$id = $observation['id_observation'];
$champs_etendus = array(
array('id_observation' => $id,
'cle' => 'latitudeDebutRue',
'label' => 'Latitude du début de la rue',
'valeur' => $coords_debut_rue[0]),
array('id_observation' => $id,
'cle' => 'longitudeDebutRue',
'label' => 'Longitude du début de la rue',
'valeur' => $coords_debut_rue[1]),
array('id_observation' => $id,
'cle' => 'latitudeFinRue',
'label' => 'Latitude de fin de la rue',
'valeur' => $coords_debut_rue[0]),
array('id_observation' => $id,
'cle' => 'longitudeFinRue',
'label' => 'Longitude de fin de la rue',
'valeur' => $coords_debut_rue[1]),
array('id_observation' => $id,
'cle' => 'adresse',
'label' => 'Adresse',
'valeur' => $lieu_dit)
);
return $champs_etendus;
}
}
?>
/trunk/scripts/modules/migrationsauvages/bibliotheque/Dao.php
New file
0,0 → 1,35
<?php
class Dao extends Bdd {
public function obtenirObservationsSauvages() {
$requete = 'SELECT * FROM cel_obs '.
'WHERE mots_cles_texte LIKE "%sauvages%" '.
'AND mots_cles_texte LIKE "%Projets coopératifs%" ';
 
$resultat = $this->recupererTous($requete);
return $resultat;
}
public function ajouterChampsEtendusParLots($obs_a_champs_etendus) {
$lignes = array();
foreach ($obs_a_champs_etendus as $champs_etendus_obs) {
foreach ($champs_etendus_obs as $champ_etendu) {
$id = $this->proteger($champ_etendu['id_observation']);
$cle = $this->proteger($champ_etendu['cle']);
$label = $this->proteger($champ_etendu['label']);
$valeur = $this->proteger($champ_etendu['valeur']);
$lignes[] = "($id, $cle, $label, $valeur)";
}
}
$requete = "INSERT INTO cel_obs_etendues (id_observation, cle, label, valeur) ".
"VALUES ".implode(',', $lignes)." ON DUPLICATE KEY UPDATE valeur = VALUES(valeur) -- ".__FILE__.' '.__LINE__;
// la partie on duplicate key est spécifique mysql mais il sera facile de s'en passer le jour
// où l'on change de sgbd
$ajout = $this->requeter($requete);
return ($ajout !== false);
}
}
?>