Subversion Repositories eFlore/Applications.cel

<?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@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;

						$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;

	}

}

?>