Subversion Repositories Applications.referentiel

Rev

Rev 45 | Rev 51 | 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
39 jpm 22 
		$info = null;
23 jpm 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) {
45 jpm 79 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
33 jpm 80 
		extract($p);
26 jpm 81 
 
33 jpm 82 
		$donnees = false;
45 jpm 83 
		if (isset($projet) && isset($script)) {
33 jpm 84 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
85 
						'FROM ref_traitement '.
86 
						"WHERE referentiel_code = $projet ".
45 jpm 87 
						"	AND script = $script ".
33 jpm 88 
						'	AND date_fin IS NULL '.
89 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' '.
90 
						'LIMIT 0,1 ';
91 
 
92 
			// Récupération des résultats
93 
			try {
94 
				$donnees = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
95 
				if ($donnees === false) {
96 
					$this->messages[] = "La requête a retourné aucun résultat.";
39 jpm 97 
				} else if (0 == count($donnees)) {
98 
					$donnees = null;
33 jpm 99 
				}
100 
			} catch (PDOException $e) {
101 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
26 jpm 102 
			}
33 jpm 103 
		} else {
45 jpm 104 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
105 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
26 jpm 106 
		}
33 jpm 107 
 
26 jpm 108 
		return $donnees;
109 
	}
110 
 
111 
	/**
38 jpm 112 
	 * Retourne les infos sur les traitements en attente.
113 
	 */
114 
	public function getElementEnAttente($params_url) {
39 jpm 115 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
38 jpm 116 
		extract($p);
117 
 
39 jpm 118 
		$donnees = null;
119 
		if (isset($projet) && isset($script)) {
38 jpm 120 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
121 
						'FROM ref_traitement '.
122 
						"WHERE referentiel_code = $projet ".
39 jpm 123 
						"	AND script = $script ".
38 jpm 124 
						'	AND date_debut IS NULL '.
125 
						'	AND date_fin IS NULL '.
126 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
127 
 
128 
			// Récupération des résultats
129 
			try {
130 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
131 
				if ($donnees === false) {
132 
					$this->messages[] = "La requête a retourné aucun résultat.";
39 jpm 133 
				} else if (0 == count($donnees)) {
134 
					$donnees = null;
38 jpm 135 
				}
136 
			} catch (PDOException $e) {
137 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
138 
			}
139 
		} else {
39 jpm 140 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
141 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
38 jpm 142 
		}
143 
 
144 
		return $donnees;
145 
	}
146 
 
147 
	/**
33 jpm 148 
	 * Retourne les infos sur les traitements en cours.
24 jpm 149 
	 */
33 jpm 150 
	public function getElementEnCours($params_url) {
39 jpm 151 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
33 jpm 152 
		extract($p);
24 jpm 153 
 
39 jpm 154 
		$donnees = null;
155 
		if (isset($projet) && isset($script)) {
33 jpm 156 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
157 
						'FROM ref_traitement '.
158 
						"WHERE referentiel_code = $projet ".
39 jpm 159 
						"	AND script = $script ".
33 jpm 160 
						'	AND date_debut IS NOT NULL '.
161 
						'	AND date_fin IS NULL '.
162 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
163 
 
164 
			// Récupération des résultats
165 
			try {
166 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
167 
				if ($donnees === false) {
168 
					$this->messages[] = "La requête a retourné aucun résultat.";
39 jpm 169 
				} else if (0 == count($donnees)) {
170 
					$donnees = null;
33 jpm 171 
				}
172 
			} catch (PDOException $e) {
173 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
24 jpm 174 
			}
33 jpm 175 
		} else {
39 jpm 176 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
177 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
24 jpm 178 
		}
33 jpm 179 
 
24 jpm 180 
		return $donnees;
181 
	}
182 
 
183 
	/**
26 jpm 184 
	 * Retourne les id des demandes de traitements obsolètes.
185 
	 */
33 jpm 186 
	public function getElementObsolete($params_url) {
45 jpm 187 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
33 jpm 188 
		extract($p);
189 
 
45 jpm 190 
		$sortie = null;
191 
		if (isset($projet) && isset($script)) {
33 jpm 192 
			try {
193 
				$requete =	'SELECT MAX(date_debut) '.
194 
							'FROM ref_traitement '.
195 
							"WHERE referentiel_code = $projet ".
45 jpm 196 
							"	AND script = $script ".
33 jpm 197 
							'	AND date_debut IS NOT NULL '.
198 
							'GROUP BY referentiel_code ';
199 
 
200 
				$date_max = $this->bdd->query($requete)->fetchColumn();
201 
				if ($date_max === false) {
202 
					$this->messages[] = "La requête de récupération de la date de début max a échouée.";
203 
				} else {
204 
					$date_max = $this->bdd->quote($date_max);
205 
					$requete = 	'SELECT id_traitement '.
206 
								'FROM ref_traitement '.
207 
								"WHERE referentiel_code = $projet ".
45 jpm 208 
								"	AND script = $script ".
33 jpm 209 
								'	AND date_debut IS NULL '.
210 
								'	AND date_fin IS NULL '.
211 
								"	AND meta_date_creation < $date_max ";
212 
					$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
213 
					if ($donnees === false) {
214 
						$this->messages[] = "La requête a retourné aucun résultat.";
215 
					}
216 
				}
217 
			} catch (PDOException $e) {
218 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
219 
			}
220 
			// Pos-traitement
45 jpm 221 
 
33 jpm 222 
			if ($donnees != false) {
223 
				foreach ($donnees as $donnee) {
224 
					$sortie[] = $donnee['id_traitement'];
225 
				}
226 
			}
227 
		} else {
45 jpm 228 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
229 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
33 jpm 230 
		}
231 
 
232 
		return $sortie;
233 
	}
234 
 
235 
	/**
236 
	 * Retourne les infos sur les traitements terminés.
237 
	 */
238 
	public function getElementTermines($params_url) {
39 jpm 239 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
33 jpm 240 
		extract($p);
241 
 
39 jpm 242 
		$donnees = null;
243 
		if (isset($projet) && isset($script)) {
33 jpm 244 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
26 jpm 245 
						'FROM ref_traitement '.
246 
						"WHERE referentiel_code = $projet ".
39 jpm 247 
						"	AND script = $script ".
26 jpm 248 
						'	AND date_debut IS NOT NULL '.
33 jpm 249 
						'	AND date_fin IS NOT NULL '.
250 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
26 jpm 251 
 
33 jpm 252 
			// Récupération des résultats
253 
			try {
26 jpm 254 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
255 
				if ($donnees === false) {
256 
					$this->messages[] = "La requête a retourné aucun résultat.";
39 jpm 257 
				} else if (0 == count($donnees)) {
258 
					$donnees = null;
26 jpm 259 
				}
33 jpm 260 
			} catch (PDOException $e) {
261 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
26 jpm 262 
			}
33 jpm 263 
		} else {
39 jpm 264 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
265 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
26 jpm 266 
		}
33 jpm 267 
 
268 
		return $donnees;
26 jpm 269 
	}
270 
 
271 
	/**
23 jpm 272 
	 * Méthode appelée pour ajouter un traitement.
273 
	 * Retour l'id du nouvel enregistrement ou false!
274 
	 */
26 jpm 275 
	public function createElement($params_post) {
49 jpm 276 
		$params_proteges = $this->traiterParametresPost(array('referentiel_code', 'script', 'script_parametres'), $params_post);
277 
		$meta_date_creation = date ('Y-m-d H:i:s');
26 jpm 278 
		$nom = $this->bdd->quote("Traitement {$params_post['referentiel_code']} - $meta_date_creation");
23 jpm 279 
		$meta_date_creation = $this->bdd->quote($meta_date_creation);
280 
 
281 
		try {
282 
			$requete = 	"INSERT INTO ref_traitement ".
49 jpm 283 
   						' (referentiel_code, script, script_parametres, nom, meta_date_creation) '.
284 
						" VALUES ({$params_proteges['referentiel_code']}, {$params_proteges['script_parametres']}, {$params_proteges['script']}, $nom, $meta_date_creation) ";
23 jpm 285 
			$resultat = $this->bdd->exec($requete);
286 
			if ($resultat === false) {
287 
				$id = false;
288 
				$this->debug[] = "Traitement NON ajouté.";
289 
			} else {
290 
				$id = $this->bdd->lastInsertId();
291 
			}
292 
		} catch (PDOException $e) {
293 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
294 
		}
295 
 
296 
	   	$this->envoyer($id);
297 
	}
26 jpm 298 
 
299 
	/**
300 
	 * Méthode principale appelée avec une requête de type POST.
301 
	 */
302 
	public function updateElement($params_url, $params_post) {
303 
		// Initialisation des variables
304 
		$info = array();
305 
 
306 
		// Nour recherchons le type de requête demandé
307 
		extract($this->traiterParametresUrl(array('id'), $params_url, true));
308 
		extract($this->traiterParametresPost(array('action'), $params_post, false));
309 
 
310 
		if (!is_null($id)) {
311 
			if (!is_null($action)) {
312 
				$methode = 'updateElement'.$action;
313 
				if (method_exists($this, $methode)) {
314 
					//array_shift($param);
315 
					$info = $this->$methode($id, $params_post);
316 
				} else {
317 
					$this->messages[] = "Le type de mise à jour demandé '$action' n'est pas disponible.";
318 
				}
319 
			} else {
320 
				$this->messages[] = "Veuillez préciser le type de mise à jour à faire.";
321 
				// TODO : coder une mise à jour générique dans une méthode updateElementDefaut($id, $params_post);
322 
			}
323 
		} else {
324 
			$this->messages[] = "Veuillez préciser l'id du traitement comme premier paramêtre dans l'url.";
325 
		}
326 
 
327 
		// Envoie sur la sortie standard
328 
		$this->envoyer($info);
329 
	}
330 
 
331 
	/**
332 
	 * Méthode pour indiquer le démarage d'un traitement.
333 
	 */
334 
	public function updateElementDebuter($id, $params_post) {
335 
		$ok = true;
336 
		try {
337 
			$requete = 	'UPDATE ref_traitement '.
338 
						'SET date_debut = NOW() '.
339 
						"WHERE id_traitement = $id ";
340 
			$this->debug[] = "$requete";
341 
			$resultat = $this->bdd->exec($requete);
342 
			if ($resultat === false) {
343 
				$ok = false;
344 
				$this->messages[] = "Traitement NON modifié.";
345 
			}
346 
		} catch (PDOException $e) {
347 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
348 
		}
349 
 
350 
	   	return $ok;
351 
	}
352 
 
353 
	/**
30 jpm 354 
	 * Méthode pour indiquer la fin d'un traitement.
355 
	 */
356 
	public function updateElementTerminer($id, $params_post) {
357 
		$ok = true;
358 
		try {
359 
			$requete = 	'UPDATE ref_traitement '.
33 jpm 360 
						'SET date_fin = NOW(), duree = TIMEDIFF(NOW(), date_debut) '.
30 jpm 361 
						"WHERE id_traitement = $id ";
362 
			$this->debug[] = "$requete";
363 
			$resultat = $this->bdd->exec($requete);
364 
			if ($resultat === false) {
365 
				$ok = false;
366 
				$this->messages[] = "Traitement NON modifié.";
367 
			}
368 
		} catch (PDOException $e) {
369 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
370 
		}
371 
 
372 
	   	return $ok;
373 
	}
374 
 
375 
	/**
26 jpm 376 
	 * Méthode principale appelée avec une requête de type DELETE.
377 
	 */
378 
	public function deleteElement($params_url) {
379 
		// Initialisation des variables
380 
		$ok = true;
381 
 
382 
		// Extraction des paramètres de l'url
383 
		extract($this->traiterParametresUrl(array('ids'), $params_url, true));
384 
 
385 
		if (!is_null($ids)) {
386 
			try {
387 
				$in_ids = $this->traiterBddClauseIn($ids);
388 
				$requete = 	'DELETE FROM ref_traitement '.
389 
							"WHERE id_traitement IN ($in_ids) ";
390 
				$this->debug[] = "$requete";
391 
				$resultat = $this->bdd->exec($requete);
392 
				if ($resultat === false) {
393 
					$ok = false;
394 
					$this->messages[] = "Traitement(s) NON supprimé(s).";
395 
				}
396 
			} catch (PDOException $e) {
397 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
398 
			}
399 
		} else {
400 
			$this->messages[] = "Veuillez préciser un ou plusieurs id de traitement séparés par des virgules comme premier paramètre dans l'url.";
401 
		}
402 
 
403 
		// Envoie sur la sortie standard
404 
		$this->envoyer($ok);
405 
	}
23 jpm 406 
}
407 
?>