Subversion Repositories Applications.referentiel

Rev

Rev 38 | Rev 45 | 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) {
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.";
39 jpm 98 
				} else if (0 == count($donnees)) {
99 
					$donnees = null;
33 jpm 100 
				}
101 
			} catch (PDOException $e) {
102 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
26 jpm 103 
			}
33 jpm 104 
		} else {
105 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
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) {
187 
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
188 
		extract($p);
189 
 
190 
		$sortie = false;
191 
		if (!is_null($projet)) {
192 
			try {
193 
				$requete =	'SELECT MAX(date_debut) '.
194 
							'FROM ref_traitement '.
195 
							"WHERE referentiel_code = $projet ".
196 
							'	AND date_debut IS NOT NULL '.
197 
							'GROUP BY referentiel_code ';
198 
 
199 
				$date_max = $this->bdd->query($requete)->fetchColumn();
200 
				if ($date_max === false) {
201 
					$this->messages[] = "La requête de récupération de la date de début max a échouée.";
202 
				} else {
203 
					$date_max = $this->bdd->quote($date_max);
204 
					$requete = 	'SELECT id_traitement '.
205 
								'FROM ref_traitement '.
206 
								"WHERE referentiel_code = $projet ".
207 
								'	AND date_debut IS NULL '.
208 
								'	AND date_fin IS NULL '.
209 
								"	AND meta_date_creation < $date_max ";
210 
					$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
211 
					if ($donnees === false) {
212 
						$this->messages[] = "La requête a retourné aucun résultat.";
213 
					}
214 
				}
215 
			} catch (PDOException $e) {
216 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
217 
			}
218 
			// Pos-traitement
219 
			$sortie = array();
220 
			if ($donnees != false) {
221 
				foreach ($donnees as $donnee) {
222 
					$sortie[] = $donnee['id_traitement'];
223 
				}
224 
			}
225 
		} else {
226 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
227 
		}
228 
 
229 
		return $sortie;
230 
	}
231 
 
232 
	/**
233 
	 * Retourne les infos sur les traitements terminés.
234 
	 */
235 
	public function getElementTermines($params_url) {
39 jpm 236 
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
33 jpm 237 
		extract($p);
238 
 
39 jpm 239 
		$donnees = null;
240 
		if (isset($projet) && isset($script)) {
33 jpm 241 
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
26 jpm 242 
						'FROM ref_traitement '.
243 
						"WHERE referentiel_code = $projet ".
39 jpm 244 
						"	AND script = $script ".
26 jpm 245 
						'	AND date_debut IS NOT NULL '.
33 jpm 246 
						'	AND date_fin IS NOT NULL '.
247 
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
26 jpm 248 
 
33 jpm 249 
			// Récupération des résultats
250 
			try {
26 jpm 251 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
252 
				if ($donnees === false) {
253 
					$this->messages[] = "La requête a retourné aucun résultat.";
39 jpm 254 
				} else if (0 == count($donnees)) {
255 
					$donnees = null;
26 jpm 256 
				}
33 jpm 257 
			} catch (PDOException $e) {
258 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
26 jpm 259 
			}
33 jpm 260 
		} else {
39 jpm 261 
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
262 
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
26 jpm 263 
		}
33 jpm 264 
 
265 
		return $donnees;
26 jpm 266 
	}
267 
 
268 
	/**
23 jpm 269 
	 * Méthode appelée pour ajouter un traitement.
270 
	 * Retour l'id du nouvel enregistrement ou false!
271 
	 */
26 jpm 272 
	public function createElement($params_post) {
39 jpm 273 
		$params_proteges = $this->traiterParametresPost(array('referentiel_code', 'script'), $params_post);
23 jpm 274 
		$meta_date_creation = date ("Y-m-d H:i:s");
26 jpm 275 
		$nom = $this->bdd->quote("Traitement {$params_post['referentiel_code']} - $meta_date_creation");
23 jpm 276 
		$meta_date_creation = $this->bdd->quote($meta_date_creation);
277 
 
278 
		try {
279 
			$requete = 	"INSERT INTO ref_traitement ".
39 jpm 280 
   						' (referentiel_code, script, nom, meta_date_creation) '.
281 
						" VALUES ({$params_proteges['referentiel_code']}, {$params_proteges['script']}, $nom, $meta_date_creation) ";
23 jpm 282 
			$resultat = $this->bdd->exec($requete);
283 
			if ($resultat === false) {
284 
				$id = false;
285 
				$this->debug[] = "Traitement NON ajouté.";
286 
			} else {
287 
				$id = $this->bdd->lastInsertId();
288 
			}
289 
		} catch (PDOException $e) {
290 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
291 
		}
292 
 
293 
	   	$this->envoyer($id);
294 
	}
26 jpm 295 
 
296 
	/**
297 
	 * Méthode principale appelée avec une requête de type POST.
298 
	 */
299 
	public function updateElement($params_url, $params_post) {
300 
		// Initialisation des variables
301 
		$info = array();
302 
 
303 
		// Nour recherchons le type de requête demandé
304 
		extract($this->traiterParametresUrl(array('id'), $params_url, true));
305 
		extract($this->traiterParametresPost(array('action'), $params_post, false));
306 
 
307 
		if (!is_null($id)) {
308 
			if (!is_null($action)) {
309 
				$methode = 'updateElement'.$action;
310 
				if (method_exists($this, $methode)) {
311 
					//array_shift($param);
312 
					$info = $this->$methode($id, $params_post);
313 
				} else {
314 
					$this->messages[] = "Le type de mise à jour demandé '$action' n'est pas disponible.";
315 
				}
316 
			} else {
317 
				$this->messages[] = "Veuillez préciser le type de mise à jour à faire.";
318 
				// TODO : coder une mise à jour générique dans une méthode updateElementDefaut($id, $params_post);
319 
			}
320 
		} else {
321 
			$this->messages[] = "Veuillez préciser l'id du traitement comme premier paramêtre dans l'url.";
322 
		}
323 
 
324 
		// Envoie sur la sortie standard
325 
		$this->envoyer($info);
326 
	}
327 
 
328 
	/**
329 
	 * Méthode pour indiquer le démarage d'un traitement.
330 
	 */
331 
	public function updateElementDebuter($id, $params_post) {
332 
		$ok = true;
333 
		try {
334 
			$requete = 	'UPDATE ref_traitement '.
335 
						'SET date_debut = NOW() '.
336 
						"WHERE id_traitement = $id ";
337 
			$this->debug[] = "$requete";
338 
			$resultat = $this->bdd->exec($requete);
339 
			if ($resultat === false) {
340 
				$ok = false;
341 
				$this->messages[] = "Traitement NON modifié.";
342 
			}
343 
		} catch (PDOException $e) {
344 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
345 
		}
346 
 
347 
	   	return $ok;
348 
	}
349 
 
350 
	/**
30 jpm 351 
	 * Méthode pour indiquer la fin d'un traitement.
352 
	 */
353 
	public function updateElementTerminer($id, $params_post) {
354 
		$ok = true;
355 
		try {
356 
			$requete = 	'UPDATE ref_traitement '.
33 jpm 357 
						'SET date_fin = NOW(), duree = TIMEDIFF(NOW(), date_debut) '.
30 jpm 358 
						"WHERE id_traitement = $id ";
359 
			$this->debug[] = "$requete";
360 
			$resultat = $this->bdd->exec($requete);
361 
			if ($resultat === false) {
362 
				$ok = false;
363 
				$this->messages[] = "Traitement NON modifié.";
364 
			}
365 
		} catch (PDOException $e) {
366 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
367 
		}
368 
 
369 
	   	return $ok;
370 
	}
371 
 
372 
	/**
26 jpm 373 
	 * Méthode principale appelée avec une requête de type DELETE.
374 
	 */
375 
	public function deleteElement($params_url) {
376 
		// Initialisation des variables
377 
		$ok = true;
378 
 
379 
		// Extraction des paramètres de l'url
380 
		extract($this->traiterParametresUrl(array('ids'), $params_url, true));
381 
 
382 
		if (!is_null($ids)) {
383 
			try {
384 
				$in_ids = $this->traiterBddClauseIn($ids);
385 
				$requete = 	'DELETE FROM ref_traitement '.
386 
							"WHERE id_traitement IN ($in_ids) ";
387 
				$this->debug[] = "$requete";
388 
				$resultat = $this->bdd->exec($requete);
389 
				if ($resultat === false) {
390 
					$ok = false;
391 
					$this->messages[] = "Traitement(s) NON supprimé(s).";
392 
				}
393 
			} catch (PDOException $e) {
394 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
395 
			}
396 
		} else {
397 
			$this->messages[] = "Veuillez préciser un ou plusieurs id de traitement séparés par des virgules comme premier paramètre dans l'url.";
398 
		}
399 
 
400 
		// Envoie sur la sortie standard
401 
		$this->envoyer($ok);
402 
	}
23 jpm 403 
}
404 
?>