Subversion Repositories Applications.referentiel

Compare Revisions

Ignore whitespace Rev 32 → Rev 33

/trunk/services/modules/Traitement.php
22,23 → 22,16
$info = array();
// Nour recherchons le type de requête demandé
$p = $this->traiterParametresUrl(array('type', 'projet'), $params_url, false);
$p = $this->traiterParametresUrl(array('type'), $params_url, false);
extract($p);
$type = $p['type'];
$projet = $p['projet'];
if (!is_null($type)) {
if (!is_null($projet)) {
$methode = 'getElement'.$type;
if (method_exists($this, $methode)) {
//array_shift($param);
$info = $this->$methode($projet);
} else {
$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
}
$methode = 'getElement'.$type;
if (method_exists($this, $methode)) {
array_shift($params_url);
$info = $this->$methode($params_url);
} else {
$this->messages[] = "Veuillez préciser le nom de code du projet comme premier paramêtre (ex. : bdnff).";
$this->messages[] = "Le type d'information demandé '$type' n'est pas disponible.";
}
} else {
$this->messages[] = "Veuillez préciser le type de requête.";
48,54 → 41,100
$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($projet) {
$projet = $this->bdd->quote($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 ';
public function getElementDerniereDemande($params_url) {
$p = $this->traiterParametresUrl(array('projet'), $params_url);
extract($p);
$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.";
$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());
}
} 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 ou en attentes.
* Retourne les infos sur les traitements en cours.
*/
public function getElementEnCours($projet) {
$projet = $this->bdd->quote($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').' ';
$this->debug[] = $requete;
public function getElementEnCours($params_url) {
$p = $this->traiterParametresUrl(array('projet'), $params_url);
extract($p);
// 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.";
$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());
}
} 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;
}
102,42 → 141,82
/**
* Retourne les id des demandes de traitements obsolètes.
*/
public function getElementObsolete($projet) {
$projet = $this->bdd->quote($projet);
try {
$requete = 'SELECT MAX(date_debut) '.
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 '.
'GROUP BY referentiel_code ';
' AND date_fin IS NOT NULL '.
'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby : 'meta_date_creation DESC').' ';
$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 ";
// 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());
}
} 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).";
}
// Pos-traitement
$sortie = array();
if ($donnees != false) {
foreach ($donnees as $donnee) {
$sortie[] = $donnee['id_traitement'];
}
}
return $sortie;
return $donnees;
}
/**
229,7 → 308,7
$ok = true;
try {
$requete = 'UPDATE ref_traitement '.
'SET date_fin = NOW() '.
'SET date_fin = NOW(), duree = TIMEDIFF(NOW(), date_debut) '.
"WHERE id_traitement = $id ";
$this->debug[] = "$requete";
$resultat = $this->bdd->exec($requete);