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

Subversion Repositories Applications.referentiel

(root)/branches/v2.0-betulales/services/modules/Traitement.php @ 388 – Rev 33 → 38