New file |
0,0 → 1,158 |
<?php |
// declare(encoding='UTF-8'); |
/** |
* Service permettant d'insérer les informations fournie par le widget Saisie dans le CEL. |
* Encodage en entrée : utf8 |
* Encodage en sortie : utf8 |
* |
* Cas d'utilisation : |
* PUT /CelWidgetSaisie : ajout de données en les passant via $_POST |
* |
* @author Jean-Pascal MILCENT <jpm@clapas.org> |
* @license GPL v3 <http://www.gnu.org/licenses/gpl.txt> |
* @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt> |
* @version $Id$ |
* @copyright © 2011, Jean-Pascal MILCENT |
*/ |
class CelWidgetSaisie extends CelMotCle { |
|
private $projet = null; |
private $utilisateur_id = null; |
|
public function getElement($params) { |
//$resultat[] = $this->ajouterMotCleObs('jpm@clapas.org', 'Projets coopératifs', self::OBS_RACINE_ID.'.projets-cooperatifs', self::OBS_RACINE_ID); |
//$resultat[] = $this->ajouterMotCleObs('jpm@clapas.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; |
$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é."; |
} |
} else { |
$this->messages[] = "L'identifiant de l'utilisateur (courriel) n'a pas été transmis."; |
} |
} else { |
$this->messages[] = "Les informations concernant l'utilisateur (prénom, nom, courriel) n'ont pas été transmises."; |
} |
} else { |
$this->messages[] = "Les informations concernant le projet coopératif n'ont pas été transmises."; |
} |
|
$msg = (count($this->messages) > 0) ? 'erreur' : 'ok'; |
$retour = (object) array('msg' => $msg); |
$this->envoyerJson($obj); |
} |
|
private function getMaxOrdre($identifiant) { |
$ordre = null; |
$identifiant = $this->bdd->quote($identifiant); |
$requete = "SELECT MAX(ordre) AS ordre ". |
"FROM cel_inventory ". |
"WHERE identifiant = $identifiant "; |
$ordre_max = $this->executerRequete($requete, 'Column'); |
if ($ordre_max !== false) { |
$ordre = $ordre_max + 1; |
} |
return $ordre; |
} |
|
/** |
* 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) |
* @return string date au format Mysql (aaaa-mm-jj) |
*/ |
private function transormerDateFrVersMysql($dateFr) { |
$dateMysql = '0000-00-00'; |
$morceauxDate = explode('/', $dateFr); |
if (count($morceauxDate) == 3) { |
$dateMysql = implode('-', array_reverse($morceauxDate)); |
} |
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; |
} |
} |
?> |