Rev 1781 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | RSS feed
<?php
/**
* Service fournissant la liste des personnes et leurs informations
* Encodage en entrée : utf8
* Encodage en sortie : utf8
*
* @author Grégoire duché <gregoire@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>
* @version $Id$
* @copyright 2009
*/
class CoelPersonne extends Coel {
protected $tables = array( 113 => array('nom' => 'coel_personne',
'prefixe' => 'cp',
'id' => array('cp_id_personne')));
/**
* Méthode appelée avec une requête de type GET.
*
* Liste des paramètres :
* /Personne_Id/Nom_Complet/
* Attention : pour avoir toutes les personnes, il faut éxécuter : CoelPersonneListe
* Pour avoir toutes les personnes dont le nom complet comment par NomComplet il faut éxécuter : CoelPersonneListe/* /NomComplet
*/
function getElement($param = array()) {
// Initialisation de variables
$info = array();
// Pré traitement des paramêtres
$p = $this->traiterParametresUrl(array('id_personne', 'recherche'), $param);
// Construction de la requête
$requete = (($this->distinct) ? 'SELECT DISTINCT' : 'SELECT').' cp.*, '.
' cmhl_date_modification, cmhl_notes, cmhl_source, cmhl_ce_modifier_par, cmhl_ce_etat, cmhl_ip '.
'FROM coel_personne AS cp '.
' LEFT JOIN coel_meta_historique_ligne ON (cp_ce_meta = cmhl_id_historique_ligne) '.
((count($p) != 0) ? 'WHERE ' : '').
(isset($p['id_personne']) ? "AND cp_id_personne = {$p['id_personne']} " : '').
(isset($p['recherche']) ? $this->construireWhereRecherche($p['recherche']) : '').
'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby : 'TRIM(cp_nom) ASC').' ';
$requete = str_replace('WHERE AND', 'WHERE', $requete);
$requeteCount = $requete;
$requete .= "LIMIT $this->start, $this->limit ";
// Exécution de la requêtre SQL et test d'éventuelles erreurs
try {
$donnees = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
if ($donnees === false) {
$this->messages[] = "La requête a retourné aucun résultat.";
}
$nbElements = $this->bdd->query($requeteCount)->rowCount();
$info['nbElements'] = $nbElements;
$info['personnes'] = $donnees;
} catch (PDOException $e) {
$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());
}
// Envoie sur la sortie standard
$this->envoyer($info);
}
private function construireWhereRecherche($recherche) {
$recherche = "AND ".
"(".
"cp_fmt_nom_complet LIKE {$recherche} OR ".
"cp_code_postal LIKE {$recherche} OR ".
"cp_ville LIKE {$recherche} OR ".
"cp_truk_courriel LIKE {$recherche} ".
")";
return $recherche;
}
/**
* Méthode appelée pour ajouter un élément.
*/
public function createElement($params) {
// Identification de l'utilisateur
list($id_utilisateur, $id_session) = $this->getIdentification($params);
$id_personne = null;
// Contrôle du non détournement de l'utilisateur
if ($this->etreAutorise($id_utilisateur)) {
try {
// Vérification des tables à vraiment mettre à jour en fonction des données passées.
$tables_a_modifier = $this->recupererTablesAModifier($params);
reset($tables_a_modifier);
while (list($table_id, $table) = each($tables_a_modifier)) {
if (!is_null($table['champs'])) {
if (!$this->avoirCleComplete($table)) {
// Ajout des données à la table des données
$id_personne = $this->ajouter($table);
if ($id_personne !== false) {
$table['champs_valeurs_id']['cp_id_personne'] = $id_personne;
$table['champs_valeurs_brut']['cp_id_personne'] = $id_personne;
// Historisation (Ajout des méta-données)
$etat = 1; // Ajout
$cle = $this->recupererCle($table);
$info = $this->creerXmlHisto($table['champs_valeurs_brut']);
$id_meta = $this->historiser($table_id, $cle, $info, $id_utilisateur, $etat, $id_session);
// Liaison de la table des données à ses méta-données
$champ_meta = "{$table['prefixe']}_ce_meta";
$table['champs_valeurs_protege'] = array($champ_meta => $id_meta);
$this->modifier($table);
}
} else {
$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
}
}
}
} catch (PDOException $e) {
$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
}
}
$this->envoyer((string) $id_personne);
}
/**
* Méthode appelée pour mettre à jour un élément
*/
public function updateElement($uid, $params) {
//Mise à jour de la personne
// Identification de l'utilisateur
list($id_utilisateur, $id_session) = $this->getIdentification($params);
// Contrôle du non détournement de l'utilisateur
if ($this->etreAutorise($id_utilisateur)) {
try {
$id_personne = $uid[0];
if (($id_personne == null)||(trim($id_personne) == "")) {
$this->messages[] = 'Aucun identifiant de personne n\'a été fourni';
} else {
// Vérification des tables à vraiment mettre à jour en fonction des données passées.
$tables_a_modifier = $this->recupererTablesAModifier($params);
// Pour chaque table du module nous lançons si nécessaire l'historisation puis la mise à jour
foreach ($tables_a_modifier as $table_id => $table) {
$this->mettreAJourAvecCle($id_utilisateur, $id_session, $table_id, $table);
}
$infos_utilisateur = $this->getUtilisateur();
// si la mise à jour concerne l'utilisateur actuellement identifié
// @TODO refaire autrement - de toute façon, ne marchait pas (rechargeait à chaque fois !)
/*if($id_utilisateur == $infos_utilisateur['id']) {
$this->rechargerCookieUtilisateur();
}*/
}
} catch (PDOException $e) {
$messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
}
}
$this->envoyer();
}
/**
* Méthode appelée pour supprimer un élément
*/
public function deleteElement($uid) {
// Vérification de la présence des id passés par l'url
if (!isset($uid[0]) || !isset($uid[1])) {
$this->messages[] = "Identifiant d'utilisateur ou de personne manquant. Vous ne devriez pas avoir accès à ce service.";
} else {
list($id_utilisateur, $id_session) = $this->getIdentification($uid[0]);
// Contrôle du non détournement de l'utilisateur
if ($this->etreAutorise($id_utilisateur)) {
// Récupération des id passés par l'url
$identifiants = explode(',', rtrim($uid[1], ','));
if (count($identifiants) == 0) {
$this->messages[] = "Aucun enregistrement n'a été supprimé.";
} else {
foreach ($identifiants as $id_personne) {
try {
// Vérification de la liaison avec d'autres données et génération des messages d'erreur
if ($this->verifierPresencePersonne($id_personne) === false) {
$params = array('cp_id_personne' => $id_personne);
$tables_a_modifier = $this->recupererTablesAModifier($params);
foreach ($tables_a_modifier as $table_id => $table) {
if ($this->avoirEnregistrement($table)) {
$resultat = $this->supprimer($table);
if ($resultat === true) {
// Historisation (Ajout des méta-données)
$cle = $this->recupererCle($table);
$this->historiser($table_id, $cle, 'NULL', $id_utilisateur, 3, $id_session);
}
} else {
$this->messages[] = "Aucun enregistrement correspondant dans la base de données.";
}
}
}
} catch (PDOException $e) {
$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
}
}
}
}
}
// Envoie sur la sortie standard
$this->envoyer();
}
private function verifierPresencePersonne($id_personne) {
$presence = false;
if ($presence = $this->verifierPresenceDansStructure($id_personne)) {
$this->messages[] = 'Cette personne ne peut être supprimée car elle est liée à une structure';
} else if ($presence = $this->verifierPresenceDansCollection($id_personne)) {
$this->messages[] = 'Cette personne ne peut être supprimée car elle est liée à une collection';
} else if ($presence = $this->verifierPresenceDansPublication($id_personne)) {
$this->messages[] = 'Cette personne ne peut être supprimée car elle est liée à une publication';
} else if ($presence = $this->verifierPresenceDansRelation01($id_personne)) {
$this->messages[] = "Cette personne ne peut être supprimée car elle est le sujet d'une relation";
} else if ($presence = $this->verifierPresenceDansRelation02($id_personne)) {
$this->messages[] = "Cette personne ne peut être supprimée car elle est l'objet d'une relation";
}
return $presence;
}
private function verifierPresenceDansStructure($id_personne) {
$requete = 'SELECT COUNT(csap_id_personne) AS nbre '.
'FROM coel_structure_a_personne '.
"WHERE csap_id_personne = '$id_personne' ".
'GROUP BY csap_id_personne ';
return $this->contenirDonnees($requete);
}
private function verifierPresenceDansCollection($id_personne) {
$requete = 'SELECT COUNT(ccap_id_personne) AS nbre '.
'FROM coel_collection_a_personne '.
"WHERE ccap_id_personne = '$id_personne' ".
'GROUP BY ccap_id_personne ';
return $this->contenirDonnees($requete);
}
private function verifierPresenceDansPublication($id_personne) {
$requete = 'SELECT COUNT(cpuap_id_personne) AS nbre '.
'FROM coel_publication_a_personne '.
"WHERE cpuap_id_personne = '$id_personne' ".
'GROUP BY cpuap_id_personne ';
return $this->contenirDonnees($requete);
}
private function verifierPresenceDansRelation01($id_personne) {
$requete = 'SELECT COUNT(cpar_id_personne_01) AS nbre '.
'FROM coel_personne_a_relation '.
"WHERE cpar_id_personne_01 = '$id_personne' ".
'GROUP BY cpar_id_personne_01 ';
return $this->contenirDonnees($requete);
}
private function verifierPresenceDansRelation02($id_personne) {
$requete = 'SELECT COUNT(cpar_id_personne_02) AS nbre '.
'FROM coel_personne_a_relation '.
"WHERE cpar_id_personne_02 = '$id_personne' ".
'GROUP BY cpar_id_personne_02 ';
return $this->contenirDonnees($requete);
}
}
?>