Subversion Repositories Applications.referentiel

Rev

Rev 24 | Rev 30 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 24 Rev 26
Line 15... Line 15...
15 
class Traitement extends Ref {
 15 
class Traitement extends Ref {
Line 16... Line 16...
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($param = array()) {
 20 
	public function getElement($params_url = array()) {
21 
		// Initialisation des variables
 21 
		// Initialisation des variables
Line 22... Line 22...
22 
		$info = array();
 22 
		$info = array();
23
23
Line 24... Line 24...
24 
		// Nour recherchons le type de requête demandé
 24 
		// Nour recherchons le type de requête demandé
25 
		$p = $this->traiterParametresUrl(array('type', 'projet'), $param, false);
 25 
		$p = $this->traiterParametresUrl(array('type', 'projet'), $params_url, false);
Line 26... Line 26...
26
26
Line 47... Line 47...
47 
		// Envoie sur la sortie standard
 47 
		// Envoie sur la sortie standard
48 
		$this->envoyer($info);
 48 
		$this->envoyer($info);
49 
	}
 49 
	}
Line 50... Line 50...
50
50
- 
 
 51 
	/**
- 
 
 52 
	 * Retourne les infos sur la dernière demande de traitement pour un projet donné.
- 
 
 53 
	 */
- 
 
 54 
	public function getElementDerniereDemande($projet) {
- 
 
 55 
		$projet = $this->bdd->quote($projet);
- 
 
 56 
		$requete =	($this->distinct ? 'SELECT DISTINCT' : 'SELECT').' * '.
- 
 
 57 
					'FROM ref_traitement '.
- 
 
 58 
					"WHERE referentiel_code = $projet ".
- 
 
 59 
					'	AND date_fin IS NULL '.
- 
 
 60 
					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'meta_date_creation  DESC').' '.
- 
 
 61 
					'LIMIT 0,1 ';
- 
 
 62
- 
 
 63 
		$this->debug[] = $requete;
- 
 
 64
- 
 
 65 
		// Récupération des résultats
- 
 
 66 
		try {
- 
 
 67 
			$donnees = $this->bdd->query($requete)->fetch(PDO::FETCH_ASSOC);
- 
 
 68 
			if ($donnees === false) {
- 
 
 69 
				$this->messages[] = "La requête a retourné aucun résultat.";
- 
 
 70 
			}
- 
 
 71 
		} catch (PDOException $e) {
- 
 
 72 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
- 
 
 73 
		}
- 
 
 74 
		return $donnees;
- 
 
 75 
	}
- 
 
 76
51 
	/**
 77 
	/**
52 
	 * Retourne les infos sur les traitements en cours ou en attentes.
 78 
	 * Retourne les infos sur les traitements en cours ou en attentes.
53 
	 */
 79 
	 */
54 
	public function getElementEnCours($projet) {
 80 
	public function getElementEnCours($projet) {
55 
		$projet = $this->bdd->quote($projet);
 81 
		$projet = $this->bdd->quote($projet);
Line 71... Line 97...
71 
		}
 97 
		}
72 
		return $donnees;
 98 
		return $donnees;
73 
	}
 99 
	}
Line 74... Line 100...
74
100
- 
 
 101 
	/**
- 
 
 102 
	 * Retourne les id des demandes de traitements obsolètes.
- 
 
 103 
	 */
- 
 
 104 
	public function getElementObsolete($projet) {
- 
 
 105 
		$projet = $this->bdd->quote($projet);
- 
 
 106 
		try {
- 
 
 107 
			$requete =	'SELECT MAX(date_debut) '.
- 
 
 108 
						'FROM ref_traitement '.
- 
 
 109 
						"WHERE referentiel_code = $projet ".
- 
 
 110 
						'	AND date_debut IS NOT NULL '.
- 
 
 111 
						'GROUP BY referentiel_code ';
- 
 
 112
- 
 
 113 
			$date_max = $this->bdd->query($requete)->fetchColumn();
- 
 
 114 
			if ($date_max === false) {
- 
 
 115 
				$this->messages[] = "La requête de récupération de la date de début max a échouée.";
- 
 
 116 
			} else {
- 
 
 117 
				$date_max = $this->bdd->quote($date_max);
- 
 
 118 
				$requete = 	'SELECT id_traitement '.
- 
 
 119 
							'FROM ref_traitement '.
- 
 
 120 
							"WHERE referentiel_code = $projet ".
- 
 
 121 
							'	AND date_debut IS NULL '.
- 
 
 122 
							'	AND date_fin IS NULL '.
- 
 
 123 
							"	AND meta_date_creation < $date_max ";
- 
 
 124 
				$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
- 
 
 125 
				if ($donnees === false) {
- 
 
 126 
					$this->messages[] = "La requête a retourné aucun résultat.";
- 
 
 127 
				}
- 
 
 128 
			}
- 
 
 129 
		} catch (PDOException $e) {
- 
 
 130 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
- 
 
 131 
		}
- 
 
 132 
		// Pos-traitement
- 
 
 133 
		$sortie = array();
- 
 
 134 
		if ($donnees != false) {
- 
 
 135 
			foreach ($donnees as $donnee) {
- 
 
 136 
				$sortie[] = $donnee['id_traitement'];
- 
 
 137 
			}
- 
 
 138 
		}
- 
 
 139 
		return $sortie;
- 
 
 140 
	}
- 
 
 141
75 
	/**
 142 
	/**
76 
	 * Méthode appelée pour ajouter un traitement.
 143 
	 * Méthode appelée pour ajouter un traitement.
77 
	 * Retour l'id du nouvel enregistrement ou false!
 144 
	 * Retour l'id du nouvel enregistrement ou false!
78 
	 */
 145 
	 */
79 
	public function createElement($params) {
 146 
	public function createElement($params_post) {
80 
		$params_proteges = $this->traiterParametresPost(array('referentiel_code'), $params);
 147 
		$params_proteges = $this->traiterParametresPost(array('referentiel_code'), $params_post);
81 
		$meta_date_creation = date ("Y-m-d H:i:s");
 148 
		$meta_date_creation = date ("Y-m-d H:i:s");
82 
		$nom = $this->bdd->quote("Traitement {$params['referentiel_code']} - $meta_date_creation");
 149 
		$nom = $this->bdd->quote("Traitement {$params_post['referentiel_code']} - $meta_date_creation");
Line 83... Line 150...
83 
		$meta_date_creation = $this->bdd->quote($meta_date_creation);
 150 
		$meta_date_creation = $this->bdd->quote($meta_date_creation);
84
151
85 
		try {
 152 
		try {
Line 97... Line 164...
97 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
 164 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
98 
		}
 165 
		}
Line 99... Line 166...
99
166
100 
	   	$this->envoyer($id);
 167 
	   	$this->envoyer($id);
- 
 
 168 
	}
- 
 
 169
- 
 
 170 
	/**
- 
 
 171 
	 * Méthode principale appelée avec une requête de type POST.
- 
 
 172 
	 */
- 
 
 173 
	public function updateElement($params_url, $params_post) {
- 
 
 174 
		// Initialisation des variables
- 
 
 175 
		$info = array();
- 
 
 176
- 
 
 177 
		// Nour recherchons le type de requête demandé
- 
 
 178 
		extract($this->traiterParametresUrl(array('id'), $params_url, true));
- 
 
 179 
		extract($this->traiterParametresPost(array('action'), $params_post, false));
- 
 
 180 
 
- 
 
 181 
		if (!is_null($id)) {
- 
 
 182 
			if (!is_null($action)) {
- 
 
 183 
				$methode = 'updateElement'.$action;
- 
 
 184 
				if (method_exists($this, $methode)) {
- 
 
 185 
					//array_shift($param);
- 
 
 186 
					$info = $this->$methode($id, $params_post);
- 
 
 187 
				} else {
- 
 
 188 
					$this->messages[] = "Le type de mise à jour demandé '$action' n'est pas disponible.";
- 
 
 189 
				}
- 
 
 190 
			} else {
- 
 
 191 
				$this->messages[] = "Veuillez préciser le type de mise à jour à faire.";
- 
 
 192 
				// TODO : coder une mise à jour générique dans une méthode updateElementDefaut($id, $params_post);
- 
 
 193 
			}
- 
 
 194 
		} else {
- 
 
 195 
			$this->messages[] = "Veuillez préciser l'id du traitement comme premier paramêtre dans l'url.";
- 
 
 196 
		}
- 
 
 197
- 
 
 198 
		// Envoie sur la sortie standard
- 
 
 199 
		$this->envoyer($info);
- 
 
 200 
	}
- 
 
 201
- 
 
 202 
	/**
- 
 
 203 
	 * Méthode pour indiquer le démarage d'un traitement.
- 
 
 204 
	 */
- 
 
 205 
	public function updateElementDebuter($id, $params_post) {
- 
 
 206 
		$ok = true;
- 
 
 207 
		try {
- 
 
 208 
			$requete = 	'UPDATE ref_traitement '.
- 
 
 209 
						'SET date_debut = NOW() '.
- 
 
 210 
						"WHERE id_traitement = $id ";
- 
 
 211 
			$this->debug[] = "$requete";
- 
 
 212 
			$resultat = $this->bdd->exec($requete);
- 
 
 213 
			if ($resultat === false) {
- 
 
 214 
				$ok = false;
- 
 
 215 
				$this->messages[] = "Traitement NON modifié.";
- 
 
 216 
			}
- 
 
 217 
		} catch (PDOException $e) {
- 
 
 218 
			$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
- 
 
 219 
		}
- 
 
 220
- 
 
 221 
	   	return $ok;
- 
 
 222 
	}
- 
 
 223
- 
 
 224 
	/**
- 
 
 225 
	 * Méthode principale appelée avec une requête de type DELETE.
- 
 
 226 
	 */
- 
 
 227 
	public function deleteElement($params_url) {
- 
 
 228 
		// Initialisation des variables
- 
 
 229 
		$ok = true;
- 
 
 230
- 
 
 231 
		// Extraction des paramètres de l'url
- 
 
 232 
		extract($this->traiterParametresUrl(array('ids'), $params_url, true));
- 
 
 233 
 
- 
 
 234 
		if (!is_null($ids)) {
- 
 
 235 
			try {
- 
 
 236 
				$in_ids = $this->traiterBddClauseIn($ids);
- 
 
 237 
				$requete = 	'DELETE FROM ref_traitement '.
- 
 
 238 
							"WHERE id_traitement IN ($in_ids) ";
- 
 
 239 
				$this->debug[] = "$requete";
- 
 
 240 
				$resultat = $this->bdd->exec($requete);
- 
 
 241 
				if ($resultat === false) {
- 
 
 242 
					$ok = false;
- 
 
 243 
					$this->messages[] = "Traitement(s) NON supprimé(s).";
- 
 
 244 
				}
- 
 
 245 
			} catch (PDOException $e) {
- 
 
 246 
				$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
- 
 
 247 
			}
- 
 
 248 
		} else {
- 
 
 249 
			$this->messages[] = "Veuillez préciser un ou plusieurs id de traitement séparés par des virgules comme premier paramètre dans l'url.";
- 
 
 250 
		}
- 
 
 251
- 
 
 252 
		// Envoie sur la sortie standard
- 
 
 253 
		$this->envoyer($ok);
101 
	}
 254 
	}
102 
}
 255 
}
103 
?>
 256 
?>