Subversion Repositories eFlore/Applications.cel

Compare Revisions

Ignore whitespace Rev 829 → Rev 830

/trunk/jrest/services/CelWidgetSaisie.php
16,71 → 16,96
*/
class CelWidgetSaisie extends CelMotCle {
public function createElement($requeteDonnees){
if (array_key_exists('utilisateur', $requeteDonnees)) {
$this->debug[] = 'Utilisateur : ok';
$utilisateur = $requeteDonnees['utilisateur'];
if (array_key_exists('courriel', $utilisateur)) {
$this->debug[] = 'Courriel : ok';
extract($utilisateur);
$ordre = $this->getMaxOrdre($courriel);
if (!is_null($ordre)) {
$this->debug[] = 'Ordre : ok';
// Triage et manipulation des données
$observations = array();
foreach ($requeteDonnees as $cle => $obs) {
if (preg_match('/^obsId[0-9]+$/', $cle)) {
$obsAAjouter = array();
$obsAAjouter['identifiant'] = $courriel;
$obsAAjouter['prenom_utilisateur'] = $prenom;
$obsAAjouter['nom_utilisateur'] = $nom;
$obsAAjouter['ordre'] = $ordre++;
$obsAAjouter['nom_sel'] = $obs['nom_sel'];
$obsAAjouter['num_nom_sel'] = $obs['num_nom_sel'];
$obsAAjouter['nom_ret'] = $obs['nom_ret'];
$obsAAjouter['num_nom_ret'] = $obs['num_nom_ret'];
$obsAAjouter['num_taxon'] = $obs['num_taxon'];
$obsAAjouter['famille'] = $obs['famille'];
$obsAAjouter['date_observation'] = $this->transormerDateFrVersMysql($obs['date']);
$obsAAjouter['milieu'] = $obs['milieu'];
$obsAAjouter['commentaire'] = $obs['notes'];
$obsAAjouter['transmission'] = '1';
$obsAAjouter['date_creation'] = date('Y-m-d H:i:s');
$obsAAjouter['date_transmission'] = date('Y-m-d H:i:s');
$obsAAjouter['mots_cles_texte'] = $obs['tag'];
$obsAAjouter['coord_x'] = $obs['latitude'];
$obsAAjouter['coord_y'] = $obs['longitude'];
$obsAAjouter['location'] = $obs['commune_nom'];
$obsAAjouter['id_location'] = substr($obs['commune_code_insee'], 0, 2);
$obsAAjouter['ref_geo'] = 'WGS84';
$observations[] = $this->protegerTableau($obsAAjouter);
private $projet = null;
private $utilisateur_id = null;
public function getElement($params) {
$resultat[] = $this->ajouterMotCleObs('jpm@tela-botanica.org', 'Projets coopératifs', self::OBS_RACINE_ID.'.projets-cooperatifs', self::OBS_RACINE_ID);
$resultat[] = $this->ajouterMotCleObs('jpm@tela-botanica.org', 'Biodiversite34', self::OBS_RACINE_ID.'.projets-cooperatifs.biodiversite34', self::OBS_RACINE_ID.'.projets-cooperatifs');
$this->envoyerJson($resultat);
}
public function createElement($requeteDonnees) {
if (array_key_exists('projet', $requeteDonnees)) {
$this->debug[] = 'Projet : ok';
$this->projet = $requeteDonnees['projet'];
if (array_key_exists('utilisateur', $requeteDonnees)) {
$this->debug[] = 'Utilisateur : ok';
$utilisateur = $requeteDonnees['utilisateur'];
if (array_key_exists('courriel', $utilisateur)) {
$this->debug[] = 'Courriel : ok';
extract($utilisateur);
$this->utilisateur_id = $courriel;
$ordre = $this->getMaxOrdre($courriel);
if (!is_null($ordre)) {
$this->debug[] = 'Ordre : ok';
// Triage et manipulation des données
$observations = array();
foreach ($requeteDonnees as $cle => $obs) {
if (preg_match('/^obsId[0-9]+$/', $cle)) {
$obsAAjouter = array();
$obsAAjouter['identifiant'] = $courriel;
$obsAAjouter['prenom_utilisateur'] = $prenom;
$obsAAjouter['nom_utilisateur'] = $nom;
$obsAAjouter['ordre'] = $ordre++;
$obsAAjouter['nom_sel'] = $obs['nom_sel'];
$obsAAjouter['num_nom_sel'] = $obs['num_nom_sel'];
$obsAAjouter['nom_ret'] = $obs['nom_ret'];
$obsAAjouter['num_nom_ret'] = $obs['num_nom_ret'];
$obsAAjouter['num_taxon'] = $obs['num_taxon'];
$obsAAjouter['famille'] = $obs['famille'];
$obsAAjouter['date_observation'] = $this->transormerDateFrVersMysql($obs['date']);
$obsAAjouter['milieu'] = $obs['milieu'];
$obsAAjouter['commentaire'] = $obs['notes'];
$obsAAjouter['transmission'] = '1';
$obsAAjouter['date_creation'] = date('Y-m-d H:i:s');
$obsAAjouter['date_transmission'] = date('Y-m-d H:i:s');
$obsAAjouter['coord_x'] = $obs['latitude'];
$obsAAjouter['coord_y'] = $obs['longitude'];
$obsAAjouter['location'] = $obs['commune_nom'];
$obsAAjouter['id_location'] = substr($obs['commune_code_insee'], 0, 2);
$obsAAjouter['ref_geo'] = 'WGS84';
$observations[] = $this->protegerTableau($obsAAjouter);
}
}
}
$this->debug[] = 'Nbre obs ajoutée : '.count($observations);
// Insertion dans la base
$ok = true;
foreach ($observations as $obs) {
$insert = "INSERT INTO cel_inventory ";
$champs = '('.implode(', ', array_keys($obs)).') ';
$values = 'VALUES ('.implode(', ', $obs).') ';
$requete = $insert.$champs.$values;
if ($this->executerRequeteSimple($requete) == false) {
$ok = false;
$this->debug[] = 'Nbre obs ajoutée : '.count($observations);
// Insertion dans la base
$ok = true;
$obs_a_lier = array();
foreach ($observations as $obs) {
$insert = "INSERT INTO cel_inventory ";
$champs = '('.implode(', ', array_keys($obs)).') ';
$values = 'VALUES ('.implode(', ', $obs).') ';
$requete = $insert.$champs.$values;
if ($this->executerRequeteSimple($requete) === false) {
$ok = false;
} else {
$obs_ok[] = trim($obs['ordre'], "'");
}
}
if ($ok === true) {
$this->debug[] = print_r($obs_ok, true);
$liaison_ok = $this->lierObsAMotsCles($obs_ok);
if ($liaison_ok === false) {
$e = "Toutes les observations n'ont pas pu être liées au mot-clé du projet.";
$this->messages[] = $e;
}
} else {
$this->messages[] = "Un problème est survenu lors de l'insertion dans la base de données.";
}
} else {
$this->messages[] = "Un nouveau numéro d'ordre d'observation n'a pu être généré.";
}
if ($ok === false) {
$this->messages[] = "Un problème est survenu lors de l'insertion dans la base de données.";
}
} else {
$this->messages[] = "Un nouveau numéro d'ordre d'observation n'a pu être généré.";
$this->messages[] = "L'identifiant de l'utilisateur (courriel) n'a pas été transmis.";
}
} else {
$this->messages[] = "L'identifiant de l'utilisateur (courriel) n'a pas été transmis.";
$this->messages[] = "Les informations concernant l'utilisateur (prénom, nom, courriel) n'ont pas été transmises.";
}
} else {
$this->messages[] = "Les informations concernant l'utilisateur (prénom, nom, courriel) n'ont pas été transmises.";
$this->messages[] = "Les informations concernant le projet coopératif n'ont pas été transmises.";
}
$msg = (count($this->messages) > 0) ? 'erreur' : 'ok';
101,13 → 126,6
return $ordre;
}
private function protegerTableau(Array $tableau) {
foreach ($tableau as $id => $val) {
$tableau[$id] = $this->bdd->quote($val);
}
return $tableau;
}
/**
* Transforme une date au format français (jj/mm/aaaa) dans un format Mysql (aaaa-mm-jj).
* @param string $dateFr date au format français (jj/mm/aaaa)
121,5 → 139,20
}
return $dateMysql;
}
private function lierObsAMotsCles($observations) {
$categorie = self::OBS_RACINE_ID.'.projets-cooperatifs';
$projet = $categorie.'.'.strtolower($this->projet);
$ajout_mot_cle_1 = $this->ajouterMotCleObs($this->utilisateur_id, 'Projets coopératifs', $categorie, self::OBS_RACINE_ID);
$ajout_mot_cle_2 = $this->ajouterMotCleObs($this->utilisateur_id, $this->projet, $projet, $categorie);
$liaison_ok = false;
if ($ajout_mot_cle_1 && $ajout_mot_cle_2) {
$liaison_ok = $this->lierMotCleObs($this->utilisateur_id, array($projet), $observations);
} else {
$e = "La catégorie du projet et le mot-clé du projet n'ont pas pu être ajouté.";
$this->messages[] = $e;
}
return $liaison_ok;
}
}
?>