Subversion Repositories eFlore/Applications.cel

Rev

Go to most recent revision | Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
719 jpm 1
<?php
2
// declare(encoding='UTF-8');
3
/**
4
 * Service permettant d'insérer les informations fournie par le widget Saisie dans le CEL.
5
 * Encodage en entrée : utf8
6
 * Encodage en sortie : utf8
7
 *
8
 * Cas d'utilisation :
9
 * PUT /CelWidgetSaisie : ajout de données en les passant via $_POST
10
 *
11
 * @author Jean-Pascal MILCENT <jpm@clapas.org>
12
 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
13
 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
14
 * @version $Id$
15
 * @copyright © 2011, Jean-Pascal MILCENT
16
 */
824 jpm 17
class CelWidgetSaisie extends CelMotCle {
719 jpm 18
 
830 jpm 19
	private $projet = null;
20
	private $utilisateur_id = null;
21
 
22
	public function getElement($params) {
831 jpm 23
		//$resultat[] = $this->ajouterMotCleObs('jpm@clapas.org', 'Projets coopératifs', self::OBS_RACINE_ID.'.projets-cooperatifs', self::OBS_RACINE_ID);
24
		//$resultat[] = $this->ajouterMotCleObs('jpm@clapas.org', 'Biodiversite34', self::OBS_RACINE_ID.'.projets-cooperatifs.biodiversite34', self::OBS_RACINE_ID.'.projets-cooperatifs');
25
		//$this->envoyerJson($resultat);
830 jpm 26
	}
27
 
28
	public function createElement($requeteDonnees) {
29
		if (array_key_exists('projet', $requeteDonnees)) {
30
			$this->debug[] = 'Projet : ok';
31
			$this->projet = $requeteDonnees['projet'];
32
			if (array_key_exists('utilisateur', $requeteDonnees)) {
33
				$this->debug[] = 'Utilisateur : ok';
34
				$utilisateur = $requeteDonnees['utilisateur'];
35
				if (array_key_exists('courriel', $utilisateur)) {
36
					$this->debug[] = 'Courriel : ok';
37
					extract($utilisateur);
38
					$this->utilisateur_id = $courriel;
39
					$ordre = $this->getMaxOrdre($courriel);
40
					if (!is_null($ordre)) {
41
						$this->debug[] = 'Ordre : ok';
42
						// Triage et manipulation des données
43
						$observations = array();
44
						foreach ($requeteDonnees as $cle => $obs) {
45
							if (preg_match('/^obsId[0-9]+$/', $cle)) {
46
								$obsAAjouter = array();
47
								$obsAAjouter['identifiant'] = $courriel;
48
								$obsAAjouter['prenom_utilisateur'] = $prenom;
49
								$obsAAjouter['nom_utilisateur'] = $nom;
50
								$obsAAjouter['ordre'] = $ordre++;
51
								$obsAAjouter['nom_sel'] = $obs['nom_sel'];
52
								$obsAAjouter['num_nom_sel'] = $obs['num_nom_sel'];
53
								$obsAAjouter['nom_ret'] = $obs['nom_ret'];
54
								$obsAAjouter['num_nom_ret'] = $obs['num_nom_ret'];
55
								$obsAAjouter['num_taxon'] = $obs['num_taxon'];
56
								$obsAAjouter['famille'] = $obs['famille'];
57
								$obsAAjouter['date_observation'] = $this->transormerDateFrVersMysql($obs['date']);
58
								$obsAAjouter['milieu'] = $obs['milieu'];
59
								$obsAAjouter['commentaire'] = $obs['notes'];
60
								$obsAAjouter['transmission'] = '1';
61
								$obsAAjouter['date_creation'] = date('Y-m-d H:i:s');
62
								$obsAAjouter['date_transmission'] = date('Y-m-d H:i:s');
63
								$obsAAjouter['coord_x'] = $obs['latitude'];
64
								$obsAAjouter['coord_y'] = $obs['longitude'];
65
								$obsAAjouter['location'] = $obs['commune_nom'];
66
								$obsAAjouter['id_location'] = substr($obs['commune_code_insee'], 0, 2);
67
								$obsAAjouter['ref_geo'] = 'WGS84';
68
 
69
								$observations[] = $this->protegerTableau($obsAAjouter);
70
							}
719 jpm 71
						}
830 jpm 72
						$this->debug[] = 'Nbre obs ajoutée : '.count($observations);
73
						// Insertion dans la base
74
						$ok = true;
75
						$obs_a_lier = array();
76
						foreach ($observations as $obs) {
77
							$insert = "INSERT INTO cel_inventory ";
78
							$champs = '('.implode(', ', array_keys($obs)).') ';
79
							$values = 'VALUES ('.implode(', ', $obs).') ';
80
							$requete = $insert.$champs.$values;
81
							if ($this->executerRequeteSimple($requete) === false) {
82
								$ok = false;
83
							} else {
84
								$obs_ok[] = trim($obs['ordre'], "'");
85
							}
719 jpm 86
						}
830 jpm 87
 
88
						if ($ok === true) {
89
							$this->debug[] = print_r($obs_ok, true);
90
							$liaison_ok = $this->lierObsAMotsCles($obs_ok);
91
							if ($liaison_ok === false) {
92
								$e = "Toutes les observations n'ont pas pu être liées au mot-clé du projet.";
93
								$this->messages[] = $e;
94
							}
95
						} else {
96
							$this->messages[] = "Un problème est survenu lors de l'insertion dans la base de données.";
97
						}
98
					} else {
99
						$this->messages[] = "Un nouveau numéro d'ordre d'observation n'a pu être généré.";
719 jpm 100
					}
101
				} else {
830 jpm 102
					$this->messages[] = "L'identifiant de l'utilisateur (courriel) n'a pas été transmis.";
719 jpm 103
				}
104
			} else {
830 jpm 105
				$this->messages[] = "Les informations concernant l'utilisateur (prénom, nom, courriel) n'ont pas été transmises.";
719 jpm 106
			}
107
		} else {
830 jpm 108
			$this->messages[] = "Les informations concernant le projet coopératif n'ont pas été transmises.";
824 jpm 109
		}
110
 
111
		$msg = (count($this->messages) > 0) ? 'erreur' : 'ok';
112
		$retour = (object) array('msg' => $msg);
113
		$this->envoyerJson($obj);
719 jpm 114
	}
115
 
116
	private function getMaxOrdre($identifiant) {
117
		$ordre = null;
118
		$identifiant = $this->bdd->quote($identifiant);
119
		$requete = 	"SELECT MAX(ordre) AS ordre ".
120
					"FROM cel_inventory ".
121
					"WHERE identifiant = $identifiant ";
122
		$ordre_max = $this->executerRequete($requete, 'Column');
123
		if ($ordre_max !== false) {
124
			$ordre = $ordre_max + 1;
125
		}
126
		return $ordre;
127
	}
128
 
129
	/**
130
	 * Transforme une date au format français (jj/mm/aaaa) dans un format Mysql (aaaa-mm-jj).
131
	 * @param string $dateFr date au format français (jj/mm/aaaa)
132
	 * @return string date au format Mysql (aaaa-mm-jj)
133
	 */
134
	private function transormerDateFrVersMysql($dateFr) {
135
		$dateMysql = '0000-00-00';
136
		$morceauxDate = explode('/', $dateFr);
137
		if (count($morceauxDate) == 3) {
138
			$dateMysql = implode('-', array_reverse($morceauxDate));
139
		}
140
		return $dateMysql;
141
	}
830 jpm 142
 
143
	private function lierObsAMotsCles($observations) {
144
		$categorie =  self::OBS_RACINE_ID.'.projets-cooperatifs';
145
		$projet =  $categorie.'.'.strtolower($this->projet);
146
		$ajout_mot_cle_1 = $this->ajouterMotCleObs($this->utilisateur_id, 'Projets coopératifs', $categorie, self::OBS_RACINE_ID);
147
		$ajout_mot_cle_2 = $this->ajouterMotCleObs($this->utilisateur_id, $this->projet, $projet, $categorie);
148
		$liaison_ok = false;
149
		if ($ajout_mot_cle_1 && $ajout_mot_cle_2) {
150
			$liaison_ok = $this->lierMotCleObs($this->utilisateur_id, array($projet), $observations);
151
		} else {
152
			$e = "La catégorie du projet et le mot-clé du projet n'ont pas pu être ajouté.";
153
			$this->messages[] = $e;
154
		}
155
		return $liaison_ok;
156
	}
719 jpm 157
}
158
?>