Subversion Repositories eFlore/Applications.coel

Rev

Rev 1519 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
1497 jpm 1
<?php
2
/**
3
 * Service fournissant la liste des relations "structure à personne".
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 CoelCollectionACommentaire extends Coel {
14
 
15
	const MODE_SUPPRESSION_PAR_COLLECTION = 'SuppressionParCollection';
16
	const MODE_SUPPRESSION_PAR_COMMENTAIRE = 'SuppressionParCommentaire';
17
 
18
	/** Contient les infos sur les tables gérées par ce service.
19
	 * Bien respecter l'ordre avec en premier les tables liées et en dernier la table établissant la relation. */
20
	protected $tables = array(	102 => array(	'nom' => 'coel_collection_a_commentaire',
21
												'prefixe' => 'ccac',
22
												'id' => array('ccac_id_collection', 'ccac_id_commentaire')));
23
 
24
	/**
25
	 * Méthode 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
		// Pré traitement des paramêtres
32
		$p = $this->traiterParametresUrl(array('id_collection', 'mark_public'), $param);
33
 
34
		// Construction de la requête
35
		$requete = 	(($this->distinct) ? 'SELECT DISTINCT ' : 'SELECT ').
36
					'	ccac.*, ccm.* '.
37
					'FROM coel_collection_a_commentaire AS ccac '.
38
					'	LEFT JOIN coel_meta_historique_ligne ON (ccac_ce_meta = cmhl_id_historique_ligne) '.
39
					'	LEFT JOIN coel_commentaire AS ccm ON (ccac_id_commentaire = ccm_id_commentaire) '.
40
					((count($p) != 0) ? 'WHERE ' : '').
41
					(isset($p['id_collection']) ? "AND ccac_id_collection = {$p['id_collection']} " : '').
42
					(isset($p['mark_public']) 	? "AND ccm_mark_public = {$p['mark_public']} " : '').
43
					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'ccac_ce_meta DESC').' ';
44
		$requete = str_replace('WHERE AND', 'WHERE', $requete);
45
		$requeteCount = $requete;
46
		$requete .= "LIMIT $this->start, $this->limit ";
47
 
48
		// Récupération des résultats
49
		try {
1519 jpm 50
			$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
1497 jpm 51
			if ($donnees === false) {
52
				$this->messages[] = "La requête a retourné aucun résultat.";
53
			}
54
 
55
			$nbElements = $this->bdd->query($requeteCount)->rowCount();
56
 
57
			$info['nbElements'] = $nbElements;
58
			$info['collectionsACommentaire'] = $donnees;
59
 
60
		} catch (PDOException $e) {
61
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
62
		}
63
 
64
		// Envoie sur la sortie standard
65
		$this->envoyer($info);
66
	}
67
 
68
	/**
69
	 * Méthode appelée pour ajouter un élément.
70
	 */
71
	public function createElement($params) {
72
		// Identification de l'utilisateur
73
		list($id_utilisateur, $id_session) = $this->getIdentification($params);
74
 
75
		// Contrôle du non détournement de l'utilisateur
76
		if ($this->etreAutorise($id_utilisateur)) {
77
			// Vérification des tables à vraiment mettre à jour en fonction des données passées.
78
   			$tables_a_modifier = $this->recupererTablesAModifier($params);
79
 
80
	   		try {
81
	   			// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
82
	   			// Nous ne pouvons pas utiliser foreach car il travaille sur une copie du tableau or nous le modifions dynamiquement dans la boucle
83
	   			reset($tables_a_modifier);
84
				while (list($table_id, $table) = each($tables_a_modifier)) {
85
		   			if (!is_null($table['champs'])) {
86
		   				if (!$this->avoirCleComplete($table)) {
87
		   					$this->messages[] = 'Il est nécessaire de fournir toutes les clés à ce service.';
88
			   			} else {
89
			   				$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
90
			   			}
91
		   			}
92
		   		}
93
			} catch (PDOException $e) {
94
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
95
			}
96
	   	} else {
97
	   		$this->messages[] = "Il faut être identifié pour accéder à ce service";
98
	   	}
99
 
100
		// Envoie sur la sortie standard
101
		$this->envoyer();
102
	}
103
 
104
	/**
105
	 * Méthode appelée pour mettre à jour un élément
106
	 */
107
	public function updateElement($uid, $params) {
108
		// Vérification de la présence des id passés par l'url
109
		if (!isset($uid[0]) && !isset($uid[1])) {
110
			$this->messages[] = 'Aucun identifiant de collection a été passé. Vous ne devriez pas avoir accès à ce service.';
111
		} else {
112
			// Identification de l'utilisateur
113
			list($id_utilisateur, $id_session) = $this->getIdentification($params);
114
 
115
			// Contrôle du non détournement de l'utilisateur
116
			if ($this->etreAutorise($id_utilisateur)) {
117
				// Vérification des tables à vraiment mettre à jour en fonction des données passées.
118
   				$tables_a_modifier = $this->recupererTablesAModifier($params);
119
   				try {
120
		   			// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
121
			   		foreach ($tables_a_modifier as $table_id => $table) {
122
			   			$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
123
			   		}
124
				} catch (PDOException $e) {
125
					$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
126
				}
127
			}
128
	   	}
129
 
130
		// Envoie sur la sortie standard
131
		$this->envoyer();
132
	}
133
 
134
	/**
135
	 * Méthode appelée pour supprimer un ou plusieurs éléments
136
	 */
137
	public function deleteElement($uid) {
138
	   	// NOTES : la suppression ne supprime pas les personnes mais seulements les relations
139
 
140
	    // Vérification de la présence des id passés par l'url
141
		if (!isset($uid[0]) || !isset($uid[1])) {
142
				$this->messages[] = "Identifiant de relations ou d'utilisateur manquant. Vous ne devriez pas avoir accès à ce service.";
143
		} else {
144
			// Identification de l'utilisateur
145
			list($id_utilisateur, $id_session) = $this->getIdentification($uid[0]);
146
 
147
			// Mode de suppression
148
			$mode_de_suppression = '';
149
			if (isset($uid[2])) {
150
				$mode_de_suppression = $uid[2];
151
			}
152
 
153
			// Contrôle du non détournement de l'utilisateur
154
			if ($this->etreAutorise($id_utilisateur)) {
155
				// Récupération des identifiant à supprimer
156
				$identifiants = array();
157
				$identifiants_agreges = explode(',', rtrim($uid[1], ','));
158
				foreach ($identifiants_agreges as $identifiant) {
159
					$identifiants[] = explode('-', $identifiant);
160
				}
161
 
162
		   		if (count($identifiants) == 0) {
163
		   			$this->messages[] = "Aucun enregistrement n'a été supprimé.";
164
		   		} else {
165
			   		try {
166
				   		foreach ($identifiants as $id) {
167
				   			if (count($id) == 1) { // Seulement des id de collection
168
					   			if ($mode_de_suppression == MODE_SUPPRESSION_PAR_COLLECTION) {
169
					   				$params = array('ccac_id_collection' => $id[0]);
170
					   			} else if ($mode_de_suppression == MODE_SUPPRESSION_PAR_COMMENTAIRE) {
171
					   				$params = array('ccac_id_commentaire' => $id[0]);
172
					   			} else {
173
					   				$params = array('ccac_id_collection' => $id[0]);
174
					   			}
175
					   		}	else if (count($id) == 2) { // Tous les id...
176
				   				$params = array('ccac_id_collection' => $id[0], 'ccac_id_commentaire' => $id[1]);
177
					   		}
178
							$tables_a_modifier = $this->recupererTablesAModifier($params);
179
							$table = $tables_a_modifier[102];
180
 
181
							if ($this->avoirEnregistrement($table)) {
182
								$resultat = $this->supprimer($table);
183
								if ($resultat === true) {
184
									// Historisation (Ajout des méta-données)
185
									$cle = $this->recupererCle($table);
186
									$this->historiser(102, $cle, 'NULL', $id_utilisateur, Coel::ETAT_SUPPRIMER, $id_session);
187
								}
188
							}
189
			   			}
190
				   	} catch (PDOException $e) {
191
						$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
192
					}
193
		   		}
194
			}
195
		}
196
 
197
		// Envoie sur la sortie standard
198
		$this->envoyer();
199
	}
200
}
201
?>