Subversion Repositories eFlore/Applications.coel

Rev

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

Rev Author Line No. Line
1497 jpm 1
<?php
2
/**
3
 * Service fournissant la liste des collections et leurs informations.
4
 * Encodage en entrée : utf8
5
 * Encodage en sortie : utf8
6
 *
7
 * @author Jean-Pascal MILCENT <jpm@tela-botanica.org>
8
 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
9
 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
10
 * @version $Id$
11
 * @copyright 2009
12
 */
13
class CoelCollection extends Coel {
14
 
15
	protected $tables = array(	101 => array(
16
									'nom' => 'coel_collection',
17
									'prefixe' => 'cc',
18
									'id' => array('cc_id_collection')),
19
		   						106 => array(
20
		   							'nom' => 'coel_collection_botanique',
21
		   							'prefixe' => 'ccb',
22
		   							'id' => array('ccb_id_collection')));
23
 
24
	/**
25
	 * Méthode principale appelée avec une requête de type GET.
26
	 */
27
	public function getElement($param = array()) {
28
		// Initialisation des variables
29
		$info = array();
30
 
31
		// Nour recherchons le type de requête demandé
32
		$type = $param[0];
33
 
34
		if ($type == '*' || is_numeric($type)) {
35
			$info = $this->getElementParDefaut($param);
36
		} else {
37
			$methode = 'getElement'.$type;
38
			if (method_exists($this, $methode)) {
39
				array_shift($param);
40
				$info = $this->$methode($param);
41
			} else {
42
				$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
43
			}
44
		}
45
 
46
		// Envoie sur la sortie standard
47
		$this->envoyer($info);
48
	}
49
 
50
	/**
51
	 * Méthode par défaut pour garder la compatibilité avec Coel.
52
	 * Appelée avec les paramêtres d'url suivant :
53
	 * /CoelCollection/_/_/_
1765 aurelien 54
	 * ou les _ représentent dans l'ordre : id_collection ou nom
1497 jpm 55
	 * Si un des paramêtres est abscent, il prendre la valeur *
56
	 */
57
	public function getElementParDefaut($param) {
58
		// Initialisation des variables
59
		$info = array();
60
 
61
		// Pré traitement des paramêtres
1765 aurelien 62
		$p = $this->traiterParametresUrl(array('id_collection', 'recherche'), $param);
1497 jpm 63
 
64
		// Construction de la requête
65
		$requete = 	(($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' c.*, cb.*, '.
66
					'	cmhl_date_modification, cmhl_notes, cmhl_source, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip, '.
67
					'	ccm.cc_nom AS _collection_mere_nom_, '.
68
					'	cs_nom AS _structure_nom_, cs_ville AS _structure_ville_ '.
69
					'FROM coel_collection AS c'.
70
					'	LEFT JOIN coel_meta_historique_ligne AS cmhl ON (c.cc_ce_meta = cmhl_id_historique_ligne) '.
71
					'	LEFT JOIN coel_structure ON (c.cc_ce_structure = cs_id_structure) '.
72
					'	LEFT JOIN coel_collection AS ccm ON (c.cc_ce_mere = ccm.cc_id_collection) '.
73
					'	LEFT JOIN coel_collection_botanique AS cb ON (c.cc_id_collection = ccb_id_collection) '.
74
					((count($p) != 0) ? 'WHERE ' : '').
75
					((isset($p['id_collection'])) ? "AND c.cc_id_collection = {$p['id_collection']} " : '').
1636 aurelien 76
					(isset($p['recherche']) ? $this->construireWhereRecherche($p['recherche']) : '').
1497 jpm 77
					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'c.cc_nom ASC').' ';
78
 
79
		$requete = str_replace('WHERE AND', 'WHERE', $requete);
80
		$requeteCount = $requete;
81
		$requete .= "LIMIT $this->start, $this->limit ";
82
 
83
		// Récupération des résultats
84
		try {
85
			// SPÉCIAL :
86
			// Lorsqu'on cherche une seule structure avec un id passé en paramêtre, nous devons renvoyer un objet
1544 jpm 87
			$donnees = (isset($p['id_collection'])) ? $this->bdd->query($requete)->fetch(PDO::FETCH_OBJ) : $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
1497 jpm 88
			if ($donnees === false) {
89
				$this->messages[] = "La requête a retourné aucun résultat.";
90
			}
91
 
92
			$nbElements = $this->bdd->query($requeteCount)->rowCount();
93
 
94
			$info['nbElements'] = $nbElements;
95
			$info['collections'] = $donnees;
96
 
97
		} catch (PDOException $e) {
98
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
99
		}
100
 
101
		return $info;
102
	}
103
 
1636 aurelien 104
	private function construireWhereRecherche($recherche) {
105
		$recherche = "AND ".
106
						"(".
107
							"c.cc_nom LIKE {$recherche}  OR ".
108
							"cs_ville LIKE {$recherche} ".
109
						")";
110
		return $recherche;
111
	}
112
 
1497 jpm 113
 	/* Méthode pour récupérer une liste de collection en fonction d'un id structure.
114
	 * Appelée avec les paramêtres d'url suivant :
115
	 * /CoelCollection/ParIdStructure/_
116
	 * ou les _ représentent dans l'ordre : id_structure
117
	 * Si un des paramêtres est abscent, il prendre la valeur *
118
	 */
119
	public function getElementParIdStructure($param) {
120
		// Initialisation des variables
121
		$info = array();
122
 
123
		// Pré traitement des paramêtres
124
		$p = $this->traiterParametresUrl(array('id_structure'), $param);
125
		if (!isset($p['id_structure'])) {
126
			$this->messages[] = "Il est obligatoire d'indiquer un id de structure pour utiliser ce service.";
127
		} else {
128
			// Construction de la requête
129
			$requete = 	(($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' cc_nom, cc_id_collection '.
130
						'FROM coel_collection AS c '.
131
						'WHERE '.
132
						"	c.cc_ce_structure = {$p['id_structure']} ".
133
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'c.cc_nom ASC').' '.
134
						"LIMIT $this->start, $this->limit ";
135
 
136
			// Récupération des résultats
137
			try {
138
				// SPÉCIAL :
139
				// Lorsqu'on cherche une seule structure avec un id passé en paramêtre, nous devons renvoyer un objet
1544 jpm 140
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
1497 jpm 141
				if ($donnees === false) {
142
					$this->messages[] = "La requête a retourné aucun résultat.";
143
				} else {
144
					$info = $donnees;
145
				}
146
			} catch (PDOException $e) {
147
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
148
			}
149
		}
150
		return $info;
151
	}
152
 
1546 jpm 153
	/* Méthode pour récupérer le nombre de collection en fonction d'un id structure.
154
	 * Appelée avec les paramêtres d'url suivant :
155
	 * /CoelCollection/NbreParIdStructure/_
156
	 * ou les _ représentent dans l'ordre : id_structure
157
	 * Si un des paramêtres est abscent, il prendre la valeur *
158
	 */
159
	public function getElementNbreParIdStructure($param) {
160
		// Initialisation des variables
161
		$info = array();
162
 
163
		// Pré traitement des paramêtres
164
		$p = $this->traiterParametresUrl(array('id_structure'), $param);
165
		if (!isset($p['id_structure'])) {
166
			$this->messages[] = "Il est obligatoire d'indiquer un id de structure pour utiliser ce service.";
167
		} else {
168
			// Construction de la requête
169
			$requete = 	(($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' COUNT(cc_id_collection) AS nbre '.
170
						'FROM coel_collection AS c '.
171
						'WHERE '.
172
						"	c.cc_ce_structure = {$p['id_structure']} ".
173
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'c.cc_nom ASC');
174
 
175
			// Récupération des résultats
176
			try {
177
				// SPÉCIAL :
178
				// Lorsqu'on cherche une seule structure avec un id passé en paramêtre, nous devons renvoyer un objet
179
				$donnees = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
180
				if ($donnees === false) {
181
					$this->messages[] = "La requête a retourné aucun résultat.";
182
				} else {
183
					$info = $donnees['nbre'];
184
				}
185
			} catch (PDOException $e) {
186
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
187
			}
188
		}
189
		return $info;
190
	}
191
 
1497 jpm 192
	/**
193
	 * Méthode appelée pour ajouter un élément.
194
	 */
195
	public function createElement($params) {
196
		// Identification de l'utilisateur
197
		list($id_utilisateur, $id_session) = $this->getIdentification($params);
198
 
199
		// Contrôle du non détournement de l'utilisateur
200
		if ($this->etreAutorise($id_utilisateur)) {
201
			try {
202
	   			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
203
	   			$tables_a_modifier = $this->recupererTablesAModifier($params);
204
	   			reset($tables_a_modifier);
205
 
206
	   			$id_collection = null;
207
				while (list($table_id, $table) = each($tables_a_modifier)) {
208
		   			if (!is_null($table['champs'])) {
209
				   		if (!$this->avoirCleComplete($table)) {
210
		   					// Ajout des données à la table des données
211
		   					$id_collection = $this->ajouter($table);
212
		   					if ($id_collection !== false) {
213
								$table['champs_valeurs_id']['cc_id_collection'] = $id_collection;
214
								$table['champs_valeurs_brut']['cc_id_collection'] = $id_collection;
215
								$tables_a_modifier[106]['champs_valeurs_id']['ccb_id_collection'] = $id_collection;
216
								$tables_a_modifier[106]['champs_valeurs_brut']['ccb_id_collection'] = $id_collection;
217
								$tables_a_modifier[106]['champs_valeurs_protege']['ccb_id_collection'] = $this->bdd->quote($id_collection);
218
 
219
								// Historisation (Ajout des méta-données)
220
								$etat = 1; // Ajout
221
								$cle = $this->recupererCle($table);
222
								$info = $this->creerXmlHisto($table['champs_valeurs_brut']);
223
								$id_meta = $this->historiser($table_id, $cle, $info, $id_utilisateur, $etat, $id_session);
224
 
225
						   		// Liaison de la table des données à ses méta-données
226
						   		$champ_meta = "{$table['prefixe']}_ce_meta";
227
						   		$table['champs_valeurs_protege'] = array($champ_meta => $id_meta);
228
						   		$this->modifier($table);
229
		   					}
230
			   			} else {
231
			   				$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
232
			   			}
233
		   			}
234
				}
1622 aurelien 235
				if(!isset($params['cpr_abreviation'])) {
236
					$params['cpr_abreviation'] = '';
237
				}
1497 jpm 238
				$this->ajouterGuid($params['cpr_abreviation'], $id_collection);
239
			} catch (PDOException $e) {
240
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
241
			}
242
	   	}
243
 
244
	   	$this->envoyer($id_collection);
245
	}
246
 
247
	/**
248
	 * Méthode appelée pour mettre à jour un élément
249
	 */
250
	public function updateElement($uid, $params) {
251
		// Vérification de la présence des id passés par l'url
252
		if (!isset($uid[0])) {
253
			$this->messages[] = "Identifiant de collection manquant. Vous ne devriez pas avoir accès à ce service.";
254
		} else {
255
			// Identification de l'utilisateur
256
			list($id_utilisateur, $id_session) = $this->getIdentification($params);
257
 
258
			// Contrôle du non détournement de l'utilisateur
259
			if ($this->etreAutorise($id_utilisateur)) {
260
		   		try {
261
		   			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
262
		   			$tables_a_modifier = $this->recupererTablesAModifier($params);
263
 
264
		   			// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
265
			   		foreach ($tables_a_modifier as $table_id => $table) {
266
						$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
267
					}
268
				} catch (PDOException $e) {
269
					$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
270
				}
271
		   	}
272
		}
273
 
274
		// Envoie sur la sortie standard
275
		$this->envoyer();
276
	}
277
 
278
	/**
279
	 * Méthode appelée pour supprimer un élément
280
	 */
281
	public function deleteElement($uid) {
282
		// Vérification de la présence des id passés par l'url
283
		if (!isset($uid[0]) || !isset($uid[1])) {
284
			$this->messages[] = "Identifiant de collection ou d'utilisateur manquant. Vous ne devriez pas avoir accès à ce service.";
285
		} else {
286
			// Identification de l'utilisateur
287
			list($id_utilisateur, $id_session) = $this->getIdentification($uid[0]);
288
 
289
			// Contrôle du non détournement de l'utilisateur
290
			if ($this->etreAutorise($id_utilisateur)) {
291
				// Récupération des id passés par l'url
292
				$identifiants = explode(',', rtrim($uid[1], ','));
293
 
294
		   		try {
295
		   			if (count($identifiants) == 0) {
296
		   				$this->messages[] = "Aucun enregistrement n'a été supprimé.";
297
		   			} else {
298
			   			foreach ($identifiants as $id_collection) {
299
				   			// Vérification que la structure ne possède pas de collections liées
300
							$params = array('cc_id_collection' => $id_collection, 'ccb_id_collection' => $id_collection);
301
							$tables_a_modifier = $this->recupererTablesAModifier($params);
302
 
303
							foreach ($tables_a_modifier as $table_id => $table) {
304
					   			if ($this->avoirEnregistrement($table)) {
305
					   				$resultat = $this->supprimer($table);
306
									if ($resultat === true) {
307
										// Historisation (Ajout des méta-données)
308
										$cle = $this->recupererCle($table);
309
										$this->historiser($table_id, $cle, 'NULL', $id_utilisateur, 3, $id_session);
310
									}
311
					   			}
312
				   			}
313
			   			}
314
		   			}
315
			   	} catch (PDOException $e) {
316
					$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
317
				}
318
		   	}
319
		}
320
 
321
		// Envoie sur la sortie standard
322
		$this->envoyer();
323
	}
324
 
1765 aurelien 325
	private function ajouterGuid($id_collection) {
1497 jpm 326
		if ($id_collection !== false) {
327
			$table_guid = $this->tables[101];
328
			$table_guid['champs_valeurs_id']['cc_id_collection'] = $id_collection;
1765 aurelien 329
			$table_guid['champs_valeurs_protege']['cc_guid'] = $this->bdd->quote(sprintf($this->config['coel']['guid'], 'coll'.$id_collection));
1497 jpm 330
			$this->modifier($table_guid);
331
		}
332
	}
333
}
334
?>