Subversion Repositories Applications.referentiel

Rev

Rev 30 | Rev 38 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
23 jpm 1 
<?php
2 
/**
3 
 * Service permettant d'enregistrer une demande de traitement ou de consulter les infos sur les traitements.
4 
 * Encodage en entrée : utf8
5 
 * Encodage en sortie : utf8
6 
 *
7 
 * @category	Php 5.2
8 
 * @package		Referentiel
9 
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
10 
 * @license		GPL v3 <http://www.gnu.org/licenses/gpl.txt>
11 
 * @license		CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
12 
 * @copyright	2010 Tela-Botanica
13 
 * @version		$Id$
14 
 */
15 
class Traitement extends Ref {
24 jpm 16 
 
23 jpm 17 
	/**
18 
	 * Méthode principale appelée avec une requête de type GET.
19 
	 */
26 jpm 20 
	public function getElement($params_url = array()) {
23 jpm 21 
		// Initialisation des variables
22 
		$info = array();
23 
 
24 
		// Nour recherchons le type de requête demandé
33 jpm 25 
		$p = $this->traiterParametresUrl(array('type'), $params_url, false);
26 
		extract($p);
23 jpm 27 
 
28 
		if (!is_null($type)) {
33 jpm 29 
			$methode = 'getElement'.$type;
30 
			if (method_exists($this, $methode)) {
31 
				array_shift($params_url);
32 
				$info = $this->$methode($params_url);
23 jpm 33 
			} else {
33 jpm 34 
				$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
23 jpm 35 
			}
36 
		} else {
37 
			$this->messages[] = "Veuillez préciser le type de requête.";
38 
		}
39 
 
40 
		// Envoie sur la sortie standard
41 
		$this->envoyer($info);
42 
	}
43 
 
33 jpm 44 
	/** Méthode pour récupérer les infos d'un traitement.
45 
	* Appelée avec les paramêtres d'url suivant :
46 
	* /Traitement/Info/id_traitement
47 
	*
48 
	* @return mixed les infos du traitement ou false en cas d'échec.
49 
	*/
50 
	public function getElementInfo($params_url) {
51 
		$p = $this->traiterParametresUrl(array('id'), $params_url);
52 
		extract($p);
53 
 
54 
		$infos = false;
55 
		if (!is_null($id)) {
56 
			$requete =	'SELECT * '.
57 
						"FROM ref_traitement ".
58 
						"WHERE id_traitement = $id ";
59 
			// Récupération des résultats
60 
			try {
61 
				$infos = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
62 
				if ($infos === false) {
63 
					$this->messages[] = "La requête a retourné aucun résultat.";
64 
				}
65 
			} catch (PDOException $e) {
66 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
67 
			}
68 
		} else {
69 
			$this->messages[] = "Veuillez préciser l'identifinat du traitement comme premier paramêtre (ex. : 38).";
70 
		}
71 
 
72 
		return $infos;
73 
	}
74 
 
23 jpm 75 
	/**
26 jpm 76 
	 * Retourne les infos sur la dernière demande de traitement pour un projet donné.
77 
	 */
33 jpm 78 
	public function getElementDerniereDemande($params_url) {
79 
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
80 
		extract($p);
26 jpm 81 
 
33 jpm 82 
		$donnees = false;
83 
		if (!is_null($projet)) {
84 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
85 
						'FROM ref_traitement '.
86 
						"WHERE referentiel_code = $projet ".
87 
						'	AND date_fin IS NULL '.
88 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' '.
89 
						'LIMIT 0,1 ';
90 
 
91 
			$this->debug[] = $requete;
92 
 
93 
			// Récupération des résultats
94 
			try {
95 
				$donnees = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
96 
				if ($donnees === false) {
97 
					$this->messages[] = "La requête a retourné aucun résultat.";
98 
				}
99 
			} catch (PDOException $e) {
100 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
26 jpm 101 
			}
33 jpm 102 
		} else {
103 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
26 jpm 104 
		}
33 jpm 105 
 
26 jpm 106 
		return $donnees;
107 
	}
108 
 
109 
	/**
33 jpm 110 
	 * Retourne les infos sur les traitements en cours.
24 jpm 111 
	 */
33 jpm 112 
	public function getElementEnCours($params_url) {
113 
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
114 
		extract($p);
24 jpm 115 
 
33 jpm 116 
		$donnees = false;
117 
		if (!is_null($projet)) {
118 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
119 
						'FROM ref_traitement '.
120 
						"WHERE referentiel_code = $projet ".
121 
						'	AND date_debut IS NOT NULL '.
122 
						'	AND date_fin IS NULL '.
123 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
124 
 
125 
			// Récupération des résultats
126 
			try {
127 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
128 
				if ($donnees === false) {
129 
					$this->messages[] = "La requête a retourné aucun résultat.";
130 
				}
131 
			} catch (PDOException $e) {
132 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
24 jpm 133 
			}
33 jpm 134 
		} else {
135 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
24 jpm 136 
		}
33 jpm 137 
 
24 jpm 138 
		return $donnees;
139 
	}
140 
 
141 
	/**
26 jpm 142 
	 * Retourne les id des demandes de traitements obsolètes.
143 
	 */
33 jpm 144 
	public function getElementObsolete($params_url) {
145 
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
146 
		extract($p);
147 
 
148 
		$sortie = false;
149 
		if (!is_null($projet)) {
150 
			try {
151 
				$requete =	'SELECT MAX(date_debut) '.
152 
							'FROM ref_traitement '.
153 
							"WHERE referentiel_code = $projet ".
154 
							'	AND date_debut IS NOT NULL '.
155 
							'GROUP BY referentiel_code ';
156 
 
157 
				$date_max = $this->bdd->query($requete)->fetchColumn();
158 
				if ($date_max === false) {
159 
					$this->messages[] = "La requête de récupération de la date de début max a échouée.";
160 
				} else {
161 
					$date_max = $this->bdd->quote($date_max);
162 
					$requete = 	'SELECT id_traitement '.
163 
								'FROM ref_traitement '.
164 
								"WHERE referentiel_code = $projet ".
165 
								'	AND date_debut IS NULL '.
166 
								'	AND date_fin IS NULL '.
167 
								"	AND meta_date_creation < $date_max ";
168 
					$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
169 
					if ($donnees === false) {
170 
						$this->messages[] = "La requête a retourné aucun résultat.";
171 
					}
172 
				}
173 
			} catch (PDOException $e) {
174 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
175 
			}
176 
			// Pos-traitement
177 
			$sortie = array();
178 
			if ($donnees != false) {
179 
				foreach ($donnees as $donnee) {
180 
					$sortie[] = $donnee['id_traitement'];
181 
				}
182 
			}
183 
		} else {
184 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
185 
		}
186 
 
187 
		return $sortie;
188 
	}
189 
 
190 
	/**
191 
	 * Retourne les infos sur les traitements terminés.
192 
	 */
193 
	public function getElementTermines($params_url) {
194 
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
195 
		extract($p);
196 
 
197 
		$donnees = false;
198 
		if (!is_null($projet)) {
199 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
26 jpm 200 
						'FROM ref_traitement '.
201 
						"WHERE referentiel_code = $projet ".
202 
						'	AND date_debut IS NOT NULL '.
33 jpm 203 
						'	AND date_fin IS NOT NULL '.
204 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
26 jpm 205 
 
33 jpm 206 
			// Récupération des résultats
207 
			try {
26 jpm 208 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
209 
				if ($donnees === false) {
210 
					$this->messages[] = "La requête a retourné aucun résultat.";
211 
				}
33 jpm 212 
			} catch (PDOException $e) {
213 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
26 jpm 214 
			}
33 jpm 215 
		} else {
216 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
26 jpm 217 
		}
33 jpm 218 
 
219 
		return $donnees;
26 jpm 220 
	}
221 
 
222 
	/**
23 jpm 223 
	 * Méthode appelée pour ajouter un traitement.
224 
	 * Retour l'id du nouvel enregistrement ou false!
225 
	 */
26 jpm 226 
	public function createElement($params_post) {
227 
		$params_proteges = $this->traiterParametresPost(array('referentiel_code'), $params_post);
23 jpm 228 
		$meta_date_creation = date ("Y-m-d H:i:s");
26 jpm 229 
		$nom = $this->bdd->quote("Traitement {$params_post['referentiel_code']} - $meta_date_creation");
23 jpm 230 
		$meta_date_creation = $this->bdd->quote($meta_date_creation);
231 
 
232 
		try {
233 
			$requete = 	"INSERT INTO ref_traitement ".
234 
   						' (referentiel_code, nom, meta_date_creation) '.
235 
						" VALUES ({$params_proteges['referentiel_code']}, $nom, $meta_date_creation) ";
236 
			$resultat = $this->bdd->exec($requete);
237 
			if ($resultat === false) {
238 
				$id = false;
239 
				$this->debug[] = "Traitement NON ajouté.";
240 
			} else {
241 
				$id = $this->bdd->lastInsertId();
242 
			}
243 
		} catch (PDOException $e) {
244 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
245 
		}
246 
 
247 
	   	$this->envoyer($id);
248 
	}
26 jpm 249 
 
250 
	/**
251 
	 * Méthode principale appelée avec une requête de type POST.
252 
	 */
253 
	public function updateElement($params_url, $params_post) {
254 
		// Initialisation des variables
255 
		$info = array();
256 
 
257 
		// Nour recherchons le type de requête demandé
258 
		extract($this->traiterParametresUrl(array('id'), $params_url, true));
259 
		extract($this->traiterParametresPost(array('action'), $params_post, false));
260 
 
261 
		if (!is_null($id)) {
262 
			if (!is_null($action)) {
263 
				$methode = 'updateElement'.$action;
264 
				if (method_exists($this, $methode)) {
265 
					//array_shift($param);
266 
					$info = $this->$methode($id, $params_post);
267 
				} else {
268 
					$this->messages[] = "Le type de mise à jour demandé '$action' n'est pas disponible.";
269 
				}
270 
			} else {
271 
				$this->messages[] = "Veuillez préciser le type de mise à jour à faire.";
272 
				// TODO : coder une mise à jour générique dans une méthode updateElementDefaut($id, $params_post);
273 
			}
274 
		} else {
275 
			$this->messages[] = "Veuillez préciser l'id du traitement comme premier paramêtre dans l'url.";
276 
		}
277 
 
278 
		// Envoie sur la sortie standard
279 
		$this->envoyer($info);
280 
	}
281 
 
282 
	/**
283 
	 * Méthode pour indiquer le démarage d'un traitement.
284 
	 */
285 
	public function updateElementDebuter($id, $params_post) {
286 
		$ok = true;
287 
		try {
288 
			$requete = 	'UPDATE ref_traitement '.
289 
						'SET date_debut = NOW() '.
290 
						"WHERE id_traitement = $id ";
291 
			$this->debug[] = "$requete";
292 
			$resultat = $this->bdd->exec($requete);
293 
			if ($resultat === false) {
294 
				$ok = false;
295 
				$this->messages[] = "Traitement NON modifié.";
296 
			}
297 
		} catch (PDOException $e) {
298 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
299 
		}
300 
 
301 
	   	return $ok;
302 
	}
303 
 
304 
	/**
30 jpm 305 
	 * Méthode pour indiquer la fin d'un traitement.
306 
	 */
307 
	public function updateElementTerminer($id, $params_post) {
308 
		$ok = true;
309 
		try {
310 
			$requete = 	'UPDATE ref_traitement '.
33 jpm 311 
						'SET date_fin = NOW(), duree = TIMEDIFF(NOW(), date_debut) '.
30 jpm 312 
						"WHERE id_traitement = $id ";
313 
			$this->debug[] = "$requete";
314 
			$resultat = $this->bdd->exec($requete);
315 
			if ($resultat === false) {
316 
				$ok = false;
317 
				$this->messages[] = "Traitement NON modifié.";
318 
			}
319 
		} catch (PDOException $e) {
320 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
321 
		}
322 
 
323 
	   	return $ok;
324 
	}
325 
 
326 
	/**
26 jpm 327 
	 * Méthode principale appelée avec une requête de type DELETE.
328 
	 */
329 
	public function deleteElement($params_url) {
330 
		// Initialisation des variables
331 
		$ok = true;
332 
 
333 
		// Extraction des paramètres de l'url
334 
		extract($this->traiterParametresUrl(array('ids'), $params_url, true));
335 
 
336 
		if (!is_null($ids)) {
337 
			try {
338 
				$in_ids = $this->traiterBddClauseIn($ids);
339 
				$requete = 	'DELETE FROM ref_traitement '.
340 
							"WHERE id_traitement IN ($in_ids) ";
341 
				$this->debug[] = "$requete";
342 
				$resultat = $this->bdd->exec($requete);
343 
				if ($resultat === false) {
344 
					$ok = false;
345 
					$this->messages[] = "Traitement(s) NON supprimé(s).";
346 
				}
347 
			} catch (PDOException $e) {
348 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
349 
			}
350 
		} else {
351 
			$this->messages[] = "Veuillez préciser un ou plusieurs id de traitement séparés par des virgules comme premier paramètre dans l'url.";
352 
		}
353 
 
354 
		// Envoie sur la sortie standard
355 
		$this->envoyer($ok);
356 
	}
23 jpm 357 
}
358 
?>