WebSVN – Applications.referentiel – Diff – /trunk/services/modules/Traitement.php


<?php
/**
 * Service permettant d'enregistrer une demande de traitement ou de consulter les infos sur les traitements.
 * Encodage en entrée : utf8
 * Encodage en sortie : utf8
 *
 * @category	Php 5.2
 * @package		Referentiel
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
 * @license		GPL v3 <http://www.gnu.org/licenses/gpl.txt>
 * @license		CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
 * @copyright	2010 Tela-Botanica
 * @version		$Id$
 */
class Traitement extends Ref {
	
	/**
	 * Méthode principale appelée avec une requête de type GET.
	 */
	public function getElement($params_url = array()) {
		// Initialisation des variables
		$info = null;
				
		// Nour recherchons le type de requête demandé
		$p = $this->traiterParametresUrl(array('type'), $params_url, false);
		extract($p);
		
		if (!is_null($type)) {
			$methode = 'getElement'.$type;
			if (method_exists($this, $methode)) {
				array_shift($params_url);
				$info = $this->$methode($params_url);
			} else {
				$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
			}
		} else {
			$this->messages[] = "Veuillez préciser le type de requête.";
		}
		
		// Envoie sur la sortie standard
		$this->envoyer($info);
	}
	
	/** Méthode pour récupérer les infos d'un traitement.
	* Appelée avec les paramêtres d'url suivant :
	* /Traitement/Info/id_traitement
	* 
	* @return mixed les infos du traitement ou false en cas d'échec. 
	*/
	public function getElementInfo($params_url) {
		$p = $this->traiterParametresUrl(array('id'), $params_url);
		extract($p);
		
		$infos = false;
		if (!is_null($id)) {
			$requete =	'SELECT * '.
						"FROM ref_traitement ".
						"WHERE id_traitement = $id ";
			// Récupération des résultats
			try {
				$infos = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
				if ($infos === false) {
					$this->messages[] = "La requête a retourné aucun résultat.";
				}
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
			}
		} else {
			$this->messages[] = "Veuillez préciser l'identifinat du traitement comme premier paramêtre (ex. : 38).";
		}
		
		return $infos;
	}
	
	/**
	 * Retourne les infos sur la dernière demande de traitement pour un projet donné.
	 */
	public function getElementDerniereDemande($params_url) {
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
		extract($p);
		
		$donnees = false;
		if (!is_null($projet)) {
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
						'FROM ref_traitement '.
						"WHERE referentiel_code = $projet ".
						'	AND date_fin IS NULL '.
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' '.
						'LIMIT 0,1 ';
			
			$this->debug[] = $requete;
			
			// Récupération des résultats
			try {
				$donnees = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
				if ($donnees === false) {
					$this->messages[] = "La requête a retourné aucun résultat.";
				} else if (0 == count($donnees)) {
					$donnees = null;
				}
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
			}
		} else {
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
		}
		
		return $donnees;
	}
	
	/**
	 * Retourne les infos sur les traitements en attente.
	 */
	public function getElementEnAttente($params_url) {
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
		extract($p);
		
		$donnees = null;
		if (isset($projet) && isset($script)) {
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
						'FROM ref_traitement '.
						"WHERE referentiel_code = $projet ".
						"	AND script = $script ".
						'	AND date_debut IS NULL '.
						'	AND date_fin IS NULL '.
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
			
			// Récupération des résultats
			try {
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
				if ($donnees === false) {
					$this->messages[] = "La requête a retourné aucun résultat.";
				} else if (0 == count($donnees)) {
					$donnees = null;
				}
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
			}
		} else {
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
		}
		
		return $donnees;
	}
	
	/**
	 * Retourne les infos sur les traitements en cours.
	 */
	public function getElementEnCours($params_url) {
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
		extract($p);
		
		$donnees = null;
		if (isset($projet) && isset($script)) {
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
						'FROM ref_traitement '.
						"WHERE referentiel_code = $projet ".
						"	AND script = $script ".
						'	AND date_debut IS NOT NULL '.
						'	AND date_fin IS NULL '.
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
			
			// Récupération des résultats
			try {
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
				if ($donnees === false) {
					$this->messages[] = "La requête a retourné aucun résultat.";
				} else if (0 == count($donnees)) {
					$donnees = null;
				}
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
			}
		} else {
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
		}
		
		return $donnees;
	}
	
	/**
	 * Retourne les id des demandes de traitements obsolètes.
	 */
	public function getElementObsolete($params_url) {
		$p = $this->traiterParametresUrl(array('projet'), $params_url);
		extract($p);
		
		$sortie = false;
		if (!is_null($projet)) {
			try {
				$requete =	'SELECT MAX(date_debut) '.
							'FROM ref_traitement '.
							"WHERE referentiel_code = $projet ".
							'	AND date_debut IS NOT NULL '.
							'GROUP BY referentiel_code ';
				
				$date_max = $this->bdd->query($requete)->fetchColumn();
				if ($date_max === false) {
					$this->messages[] = "La requête de récupération de la date de début max a échouée.";
				} else {
					$date_max = $this->bdd->quote($date_max);
					$requete = 	'SELECT id_traitement '.
								'FROM ref_traitement '.
								"WHERE referentiel_code = $projet ".
								'	AND date_debut IS NULL '.
								'	AND date_fin IS NULL '.
								"	AND meta_date_creation < $date_max ";
					$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
					if ($donnees === false) {
						$this->messages[] = "La requête a retourné aucun résultat.";
					}
				}
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
			}
			// Pos-traitement
			$sortie = array();
			if ($donnees != false) {
				foreach ($donnees as $donnee) {
					$sortie[] = $donnee['id_traitement'];
				}
			}
		} else {
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
		}
		
		return $sortie;
	}
	
	/**
	 * Retourne les infos sur les traitements terminés.
	 */
	public function getElementTermines($params_url) {
		$p = $this->traiterParametresUrl(array('projet', 'script'), $params_url);
		extract($p);
		
		$donnees = null;
		if (isset($projet) && isset($script)) {
			$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
						'FROM ref_traitement '.
						"WHERE referentiel_code = $projet ".
						"	AND script = $script ".
						'	AND date_debut IS NOT NULL '.
						'	AND date_fin IS NOT NULL '.
						'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' ';
			
			// Récupération des résultats
			try {
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
				if ($donnees === false) {
					$this->messages[] = "La requête a retourné aucun résultat.";
				} else if (0 == count($donnees)) {
					$donnees = null;
				}
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
			}
		} else {
			$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff) ".
				"et le code du script à lancer comme second paramêtre (ex. : tests ou versionnage).";
		}
		
		return $donnees;
	}
	
	/**
	 * Méthode appelée pour ajouter un traitement.
	 * Retour l'id du nouvel enregistrement ou false!
	 */
	public function createElement($params_post) {
		$params_proteges = $this->traiterParametresPost(array('referentiel_code', 'script'), $params_post);
		$meta_date_creation = date ("Y-m-d H:i:s");
		$nom = $this->bdd->quote("Traitement {$params_post['referentiel_code']} - $meta_date_creation");
		$meta_date_creation = $this->bdd->quote($meta_date_creation);
		
		try {
			$requete = 	"INSERT INTO ref_traitement ".
   						' (referentiel_code, script, nom, meta_date_creation) '.
						" VALUES ({$params_proteges['referentiel_code']}, {$params_proteges['script']}, $nom, $meta_date_creation) ";
			$resultat = $this->bdd->exec($requete);
			if ($resultat === false) {
				$id = false;
				$this->debug[] = "Traitement NON ajouté.";
			} else {
				$id = $this->bdd->lastInsertId();
			}
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
		}
	   	
	   	$this->envoyer($id);
	}
	
	/**
	 * Méthode principale appelée avec une requête de type POST.
	 */
	public function updateElement($params_url, $params_post) {
		// Initialisation des variables
		$info = array();
				
		// Nour recherchons le type de requête demandé
		extract($this->traiterParametresUrl(array('id'), $params_url, true));
		extract($this->traiterParametresPost(array('action'), $params_post, false));
 
		if (!is_null($id)) {
			if (!is_null($action)) {
				$methode = 'updateElement'.$action;
				if (method_exists($this, $methode)) {
					//array_shift($param);
					$info = $this->$methode($id, $params_post);
				} else {
					$this->messages[] = "Le type de mise à jour demandé '$action' n'est pas disponible.";
				}
			} else {
				$this->messages[] = "Veuillez préciser le type de mise à jour à faire.";
				// TODO : coder une mise à jour générique dans une méthode updateElementDefaut($id, $params_post);
			}
		} else {
			$this->messages[] = "Veuillez préciser l'id du traitement comme premier paramêtre dans l'url.";
		}
		
		// Envoie sur la sortie standard
		$this->envoyer($info);
	}
	
	/**
	 * Méthode pour indiquer le démarage d'un traitement.
	 */
	public function updateElementDebuter($id, $params_post) {
		$ok = true;
		try {
			$requete = 	'UPDATE ref_traitement '.
						'SET date_debut = NOW() '.
						"WHERE id_traitement = $id ";
			$this->debug[] = "$requete";
			$resultat = $this->bdd->exec($requete);
			if ($resultat === false) {
				$ok = false;
				$this->messages[] = "Traitement NON modifié.";
			}
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
		}
	   	
	   	return $ok;
	}
	
	/**
	 * Méthode pour indiquer la fin d'un traitement.
	 */
	public function updateElementTerminer($id, $params_post) {
		$ok = true;
		try {
			$requete = 	'UPDATE ref_traitement '.
						'SET date_fin = NOW(), duree = TIMEDIFF(NOW(), date_debut) '.
						"WHERE id_traitement = $id ";
			$this->debug[] = "$requete";
			$resultat = $this->bdd->exec($requete);
			if ($resultat === false) {
				$ok = false;
				$this->messages[] = "Traitement NON modifié.";
			}
		} catch (PDOException $e) {
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
		}
	   	
	   	return $ok;
	}
	
	/**
	 * Méthode principale appelée avec une requête de type DELETE.
	 */
	public function deleteElement($params_url) {
		// Initialisation des variables
		$ok = true;
				
		// Extraction des paramètres de l'url
		extract($this->traiterParametresUrl(array('ids'), $params_url, true));
 
		if (!is_null($ids)) {
			try {
				$in_ids = $this->traiterBddClauseIn($ids);
				$requete = 	'DELETE FROM ref_traitement '.
							"WHERE id_traitement IN ($in_ids) ";
				$this->debug[] = "$requete";
				$resultat = $this->bdd->exec($requete);
				if ($resultat === false) {
					$ok = false;
					$this->messages[] = "Traitement(s) NON supprimé(s).";
				}
			} catch (PDOException $e) {
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
			}
		} else {
			$this->messages[] = "Veuillez préciser un ou plusieurs id de traitement séparés par des virgules comme premier paramètre dans l'url.";
		}
		
		// Envoie sur la sortie standard
		$this->envoyer($ok);
	}
}
?>

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

Subversion Repositories Applications.referentiel

(root)/trunk/services/modules/Traitement.php – Rev 38 → 39