<?php
/**
* Service fournissant la liste des relations "publication à personne".
* Encodage en entrée : utf8
* Encodage en sortie : utf8
*
* @category PHP 5.2
* @package jrest
* @author Aurélien PERONNET <aurelien@tela-botanica.org>
* @author Jean-Pascal MILCENT <jpm@tela-botanica.org>
* @copyright © 2009, Tela Botanica
* @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$
* @link /doc/jrest/
*/
class CoelPublicationAPersonne extends Coel {
	
	const ROLE_AUTEUR = 2360;
	
	/** Contient les infos sur les tables gérées par ce service.
	 * Bien respecter l'ordre avec en premier les tables liées et en dernier la table établissant la relation. */
	protected $tables = array(	119 => array(	'nom' => 'coel_publication_a_personne',
												'prefixe' => 'cpuap',
												'id' => array('cpuap_id_personne', 'cpuap_id_publication', 'cpuap_id_role')));

	/**
	 * Méthode appelée avec une requête de type GET.
	 */
	public function getElement($param = array()) {
		// Initialisation des variables
		$info = array();
		
		// Pré traitement des paramêtres
		$p = $this->traiterParametresUrl(array('id_publication', 'id_personne', 'id_role'), $param, false);
		
		// Construction de la requête
		$requete = 	(($this->distinct) ? 'SELECT DISTINCT ' : 'SELECT ').
					'	cpu.*, cpuap.*, cp_id_personne, cp_ce_projet, cp_prenom, cp_nom, cp_fmt_nom_complet, cp_code_postal, cp_truk_courriel, cp_ville '.
					'FROM coel_publication_a_personne AS cpuap '.
					'	LEFT JOIN coel_meta_historique_ligne ON (cpuap_ce_meta = cmhl_id_historique_ligne) '.
					'	LEFT JOIN coel_personne AS cp ON (cpuap_id_personne = cp_id_personne) '.  
					'	LEFT JOIN coel_publication AS cpu ON (cpuap_id_publication = cpu_id_publication) '.
					((count($p) != 0) ? 'WHERE ' : '').
					(isset($p['id_personne']) 		? "AND cpuap_id_personne IN ({$p['id_personne']}) " : '').
					(isset($p['id_publication']) 	? "AND cpuap_id_publication = '{$p['id_publication']}' " : '').
					(isset($p['id_role'])			? "AND cpuap_id_role IN ({$p['id_role']}) " : '').
					'ORDER BY '.((!is_null($this->orderby)) ? $this->orderby  : 'cpuap_ce_meta DESC').' ';
		$requete = str_replace('WHERE AND', 'WHERE', $requete);
		$requeteCount = $requete;
		$requete .= "LIMIT $this->start, $this->limit ";
		
		// Récupération des résultats
		try {
			$donnees = (count($p) == 3) ? $this->bdd->query($requete)->fetch(PDO::FETCH_OBJ) : $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
			if ($donnees === false) {
				$this->messages[] = "La requête n'a retourné aucun résultat.";
			}
			$nbElements = $this->bdd->query($requeteCount)->rowCount();
			
			$info['nbElements'] = $nbElements;
			$info['publicationsAPersonne'] = $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);
	}

	/**
	 * 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);

		// Contrôle du non détournement de l'utilisateur
		if ($this->etreAutorise($id_utilisateur)) {
			$auteurs = $role = $ordre_des_auteurs = $publications = array();
			// Traitement spécial pour ajouter plusieurs personnes liées à une publication à la fois...
			if (isset($params['cpuap_id_auteur'])) {
				$auteurs = explode(',', $params['cpuap_id_auteur']);
				unset($params['cpuap_id_auteur']);
			}
			
			if (isset($params['cpuap_id_role'])) {
				$role = explode(',', $params['cpuap_id_role']);
			}
			
			if (isset($params['cpuap_ordre'])) {
				$ordre_des_auteurs = explode(',', $params['cpuap_ordre']);
				unset($params['cpuap_ordre']);
			}
			
			// Traitement spécial pour ajouter plusieurs publications liées à une personne à la fois...
			if (isset($params['cpuap_id_publication'])) {
				$publications = explode(',', $params['cpuap_id_publication']);
				if (count($publications) > 1)	{
					unset($params['cpuap_id_publication']);
				}
			}
			
			if (count($auteurs) != 0 || count($publications) != 0) {
				// Formulaire Publication : nous lions des auteurs à une publication
				// Cas où il y a une seule publication et un ou plusieurs auteurs ; c'est donc une liaison d'une publi a plusieurs personne avec le role "auteur"			
				if (count($auteurs) >= 1 && count($publications) == 1 && (count($role) == 1 && $role[0] == self::ROLE_AUTEUR))	{
					$compteur = 0;
					foreach ($auteurs as $params['cpuap_id_personne']) {
						$params['cpuap_ordre'] = $ordre_des_auteurs[$compteur++];
						
						// 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
			   			// Nous ne pouvons pas utiliser foreach car il travaille sur une copie du tableau or nous le modifions dynamiquement dans la boucle
			   			reset($tables_a_modifier);
						while (list($table_id, $table) = each($tables_a_modifier)) {
				   			if (!is_null($table['champs'])) {
				   				try {
				   					$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());
								}
				   			}
				   		}
					}
				}
				// Formulaire Personne : nous lions des publications à une personne
				// Cas où il y a plusieurs publications ; c'est donc une liaison de plusieurs publis a une personne avec n roles
				else if (count($auteurs) == 1 && count($publications) >= 1 && (count($role) > 1 || (count($role) == 1 && $role[0] != self::ROLE_AUTEUR)) )	{
					$params['cpuap_id_personne'] = $auteurs[0];
					for ($i = 0; $i < count($publications); $i++ )	{
						$params['cpuap_id_publication'] = $publications[$i];
						$params['cpuap_id_role'] = $role[$i];
						
						// 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
			   			// Nous ne pouvons pas utiliser foreach car il travaille sur une copie du tableau or nous le modifions dynamiquement dans la boucle
			   			reset($tables_a_modifier);
						while (list($table_id, $table) = each($tables_a_modifier)) {
				   			if (!is_null($table['champs'])) {
				   				try {
				   					$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());
								}
				   			}
				   		}
					}
				}
			} else {
				$this->messages[] = "Aucun identifiant d'auteur ou de publication fournis";
			}
	   	} else {
	   		$this->messages[] = "Il faut être identifié pour accéder à ce service";
	   	}

		// Envoie sur la sortie standard
		$this->envoyer();
	}

	/**
	 * Méthode appelée pour mettre à jour un élément
	 */
	public function updateElement($uid, $params) {
		// Vérification de la présence des id passés par l'url
		if (!isset($uid[0]) && !isset($uid[1]) && !isset($uid[2])) {
			$this->messages[] = 'Aucun identifiant de publication, personne et role a été passé. Vous ne devriez pas avoir accès à ce service.';
		} else {
			// 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)) {
				// Vérification des tables à vraiment mettre à jour en fonction des données passées.
   				$tables_a_modifier = $this->recupererTablesAModifier($params);
   				
   				$id_publication = $params['cpuap_id_publication'];
   				$auteurs = explode(',', $params['cpuap_id_auteur']);
   				$id_role = $params['cpuap_id_role'];
   				$ordre = explode(',', $params['cpuap_ordre']);
   				
   				if (count($auteurs) != 0 && $params['cpuap_id_publication'] != '') {
   					$compteur = 0;
					foreach ($auteurs as $auteur) {
		   				$params = array('cpuap_id_publication' => $id_publication, 
		   					'cpuap_id_personne' => $auteur, 
		   					'cpuap_id_role' => $id_role, 
		   					'cpuap_ordre' => $ordre[$compteur++]);
		   				
						$tables_a_modifier = $this->recupererTablesAModifier($params);
						$table = $tables_a_modifier[119];

						if ($this->avoirEnregistrement($table)) {
							$resultat = $this->supprimer($table);
							if ($resultat === true) {
								// Historisation (Ajout des méta-données)
								$cle = $this->recupererCle($table);
								$this->historiser(119, $cle, 'NULL', $id_utilisateur, 3, $id_session);
							}
						}
	   				
				   		reset($tables_a_modifier);
						while (list($table_id, $table) = each($tables_a_modifier)) {
				   			if (!is_null($table['champs'])) {
				   				try {
					   				$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);
								}
				   			}
				   		}
					}
				} else {
					$this->messages[] = "Aucun identifiant d'auteur et de publication fournis";
				}
			} else {
	   			$this->messages[] = "Il faut être identifié pour accéder à ce service";
	   		}
	   	}

		// Envoie sur la sortie standard
		$this->envoyer();
	}

	/**
	 * Méthode appelée pour supprimer un élément
	 */
	public function deleteElement($uid) {
	   	// NOTES : la suppression ne supprime pas les personnes mais seulements les relations

	    // Vérification de la présence des id passés par l'url
		if (!isset($uid[0]) || !isset($uid[1])) {
				$this->messages[] = "Identifiant de relations ou d'utilisateur manquant. Vous ne devriez pas avoir accès à ce service.";
		} else {
			// Identification de l'utilisateur
			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 identifiant à supprimer
				$identifiants = array();
				$identifiants_agreges = explode(',', rtrim($uid[1], ','));
				foreach ($identifiants_agreges as $identifiant) {
					$identifiants[] = explode('-', $identifiant);
				}
				
		   		if (count($identifiants) == 0) {
		   			$this->messages[] = "Aucun enregistrement n'a été supprimé.";
		   		} else {
			   		try {
				   		foreach ($identifiants as $id) {
				   			if (count($id) == 1) { // Seulement des id de publication
					   			// Suppression en une seule fois toutes les relations d'une publication
				   				$params = array('cpuap_id_publication' => $id[0]);
					   		} else if (count($id) == 3) { // Tous les id...
				   				// Suppression d'une seule relation particulière
					   			$params = array('cpuap_id_publication' => $id[0], 'cpuap_id_personne' => $id[1], 'cpuap_id_role' => $id[2]);
					   		}
					   		
							$tables_a_modifier = $this->recupererTablesAModifier($params);
							$table = $tables_a_modifier[119];

							if ($this->avoirEnregistrement($table)) {
								$resultat = $this->supprimer($table);
								if ($resultat === true) {
									// Historisation (Ajout des méta-données)
									$cle = $this->recupererCle($table);
									$this->historiser(119, $cle, 'NULL', $id_utilisateur, 3, $id_session);
								}
							}
			   			}
				   	} catch (PDOException $e) {
						$this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
					}
		   		}
			}
		}

		// Envoie sur la sortie standard
		$this->envoyer();
	}
}
?>