<?php

require_once 'Framework/Modele.php';

class Messagerie extends Modele {

	public function getmessagesnonlus()
    {
		$sql = 'call sp_r_messages_non_lus()';
			
        $resultat = $this->executerRequete($sql);
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }

	public function countmessagesnonlus()
    {
		$sql = 'call sp_r_count_messages_non_lus()';
			
        $resultat = $this->executerRequete($sql);
		
		$donnees = $resultat->fetch(PDO::FETCH_ASSOC);
		
		$_SESSION['nbMessagesNonLus_C'] = $donnees['nbMessagesNonLus'];
		
		return $_SESSION['nbMessagesNonLus_C'];
    }

	public function creermessage($codePrestataire, $textMessage, $idParent)
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_creer_messagerie(?, ?, ?, ?);';
			
		$this->executerRequete($sql, array($codePrestataire, $textMessage, $user, $idParent));
    }
	
	public function marquercommelu($idMessagerie)
    {
		$user = $_SESSION['login'];
		
		$sql = 'call sp_r_marquer_messagerie_lu(?, ?);';
			
		$this->executerRequete($sql, array($idMessagerie, $user));
    }

	public function getmessages($date1, $date2, $messageLu, $textMessage, $codePrestataire)
    {
		$sql = 'call sp_r_messages(?, ?, ?, ?, ?)';
			
		$resultat = $this->executerRequete($sql, array($date1, $date2, $messageLu, $textMessage, $codePrestataire));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }
	
	public function repondremessage($idMessagerie, $idParent, $textMessage)
    {
		$user 				= $_SESSION['login'];

		$sql = 'call sp_r_repondre_messagerie(?, ?, ?, ?);';
			
		$this->executerRequete($sql, array($idMessagerie, $idParent, $textMessage, $user));
    }
	
	public function getmessageriesimple($idMessagerie, $idParent)
    {
		$sql = 'call sp_p_get_messagerie_simple(?, ?);';

		$resultat = $this->executerRequete($sql, array($idMessagerie, $idParent));
		
		return $resultat->fetch(PDO::FETCH_ASSOC);
    }
	
	public function getmessageriehistorique($idParent)
    {
		$sql = 'call sp_r_messages_historique(?)';
			
		$resultat = $this->executerRequete($sql, array($idParent));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }
	
	public function creermessagecommun($objet, $textMessage)
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_creer_messagerie_commun(?, ?, ?);';
			
		$this->executerRequete($sql, array($objet,$textMessage, $user));
    }
	
	public function getmessagescommun($date1, $date2)
    {
		$sql = 'call sp_r_messages_commun(?, ?)';
			
		$resultat = $this->executerRequete($sql, array($date1, $date2));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }
	
	// initmessagecommun()
	public function initmessagecommun()
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_init_messagerie_commun(?);';
			
		$this->executerRequete($sql, array($user));
    }
	
	public function getprestatairesmessagerienonselectionnes($codeTypePrestataire)
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_prestataires_messagerie_non_selectionnes(?, ?)';
			
		$resultat = $this->executerRequete($sql, array($user, $codeTypePrestataire));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }

	public function getprestatairesmessagerieselectionnes($codeTypePrestataire)
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_prestataires_messagerie_selectionnes(?, ?)';
			
		$resultat = $this->executerRequete($sql, array($user, $codeTypePrestataire));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }
	
	public function ajouterprestaire($idPrestataire)
    {
		$sql = 'call sp_r_ajouter_prestataire_messagerie(?);';
		
		$this->executerRequete($sql, array($idPrestataire));
    }
	
	public function retirerprestaire($idPrestataire)
    {
		$sql = 'call sp_r_retirer_prestataire_messagerie(?);';
		
		$this->executerRequete($sql, array($idPrestataire));
    }
	
	public function ajouterprestairetous($codeTypePrestataire)
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_ajouter_prestataire_messagerie_tous(?, ?);';
		
		$this->executerRequete($sql, array($user, $codeTypePrestataire));
    }
	
	public function retirerprestairetous($codeTypePrestataire)
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_retirer_prestataire_messagerie_tous(?, ?);';
		
		$this->executerRequete($sql, array($user, $codeTypePrestataire));
    }
	
	public function listemailprestatairemessagecommun()
	{
		$user = $_SESSION['login'];
		
		$sql = "call sp_r_liste_prestataires_messagerie_selectionnes(?);";
		
		$resultat = $this->executerRequete($sql, array($user));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }
	
	public function getmessagescommunall($date1, $date2, $textMessage)
    {
		$sql = 'call sp_r_messages_commun_all(?, ?, ?)';
			
		$resultat = $this->executerRequete($sql, array($date1, $date2, $textMessage));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }

	public function initenvoisms($codeTypeDestinataire)
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_init_envoi_sms(?, ?);';
			
		$this->executerRequete($sql, array($user, $codeTypeDestinataire));
    }
	
	public function videdestainairesms()
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_vider_envoi_sms(?);';
			
		$this->executerRequete($sql, array($user));
    }
	
	public function getdestinatairesnonselectionnes()
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_destinataires_sms_non_selectionnes(?)';
			
		$resultat = $this->executerRequete($sql, array($user));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }

	public function getdestinatairesselectionnes()
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_destinataires_sms_selectionnes(?)';
			
		$resultat = $this->executerRequete($sql, array($user));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }

	public function ajouterdestinatairesmstous()
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_ajouter_destinataires_sms_tous(?);';
		
		$this->executerRequete($sql, array($user));
    }
	
	public function retirerdestinatairesmstous()
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_retirer_destinataires_sms_tous(?);';
		
		$this->executerRequete($sql, array($user));
    }

	public function ajouterundestinatairesms($idDestinataire)
    {
		$sql = 'call sp_r_ajouter_un_destinataire_sms(?);';
		
		$this->executerRequete($sql, array($idDestinataire));
    }
	
	public function retirerundestinatairesms($idDestinataire)
    {
		$sql = 'call sp_r_retirer_un_destinataire_sms(?);';
		
		$this->executerRequete($sql, array($idDestinataire));
    }
	
	public function mettresmscommeunattente($textMessage)
    {
		$codeSociete 	= $_SESSION['codeSociete'];
		$user 			= $_SESSION['login'];

		$sql = 'call sp_r_ajouter_envoisms_groupe(?, ?, ?);';
			
		$this->executerRequete($sql, array($codeSociete, $user, $textMessage));
    }
	
	public function mettresmscommeunattentelibre($noDestination, $textMessage)
    {
		$codeSociete 	= $_SESSION['codeSociete'];
		$user 			= $_SESSION['login'];

		$sql = 'call sp_r_ajouter_envoisms_libre(?, ?, ?, ?);';
			
		$this->executerRequete($sql, array($codeSociete, $user, $noDestination, $textMessage));
    }
	
	public function getenvoisms($date1, $date2)
    {
		$sql = 'call sp_get_envois_sms(?, ?)';
			
		$resultat = $this->executerRequete($sql, array($date1, $date2));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }
	
	public function getenvoismsencours($date1, $date2)
    {
		$sql = 'call sp_get_envois_sms_enc_cours(?, ?)';
			
		$resultat = $this->executerRequete($sql, array($date1, $date2));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }

	public function smsrechercheclient($nomClientAdherent)
    {
		$nomClientAdherent = contruireParamLike($nomClientAdherent);
		
		$sql = 'call sp_sms_rechercher_client(?)';
			
		$resultat = $this->executerRequete($sql, array($nomClientAdherent));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }
	
	public function initenvoismsadherentclient($numeroClientAdherent)
    {
		$user = $_SESSION['login'];

		$sql = 'call sp_r_init_envoi_sms_adherent_client(?, ?);';
			
		$this->executerRequete($sql, array($user, $numeroClientAdherent));
    }

	public function initenvoismsadherentlocalite($codePays, $codeVille ,$codeLocalite)
    {
		$codePays 		= contruireParamLike($codePays);
		$codeVille 		= contruireParamLike($codeVille);
		$codeLocalite	= contruireParamLike($codeLocalite);

		$user = $_SESSION['login'];

		$sql = 'call sp_r_init_envoi_sms_adherent_localite(?, ?, ?, ?);';
			
		$this->executerRequete($sql, array($user, $codePays, $codeVille ,$codeLocalite));
    }
	
	public function initenvoismsadherentclientlocalite($numeroClientAdherent, $codePays, $codeVille ,$codeLocalite)
    {
		$codePays 		= contruireParamLike($codePays);
		$codeVille 		= contruireParamLike($codeVille);
		$codeLocalite	= contruireParamLike($codeLocalite);

		$user = $_SESSION['login'];

		$sql = 'call sp_r_init_envoi_sms_adherent_client_localite(?, ?, ?, ?, ?);';
			
		$this->executerRequete($sql, array($user, $numeroClientAdherent, $codePays, $codeVille ,$codeLocalite));
    }

	public function enregistrerparamimportdestinatairesms($nomOrigine, $nouveau_fichier, $taille)
	{
		$idPolice 		= $_SESSION['idPolice_C'];
		$codeSociete 	= $_SESSION['codeSociete'];
		$user 			= $_SESSION['login'];
		//$cheminFichier 	= $_SESSION['dossierGed'].$nouveau_fichier;
		$cheminFichier 	= $nouveau_fichier;

		$sql = 'call sp_r_enregistrer_param_import_destinataire_sms(?, ?, ?, ?, ?);';
		
		$this->executerRequete($sql, array($codeSociete, $nomOrigine, $cheminFichier, $taille, $user));
    }	
	
    public function getFichierImportSms()
	{
		$user 		= $_SESSION['login'];

		$sql = 'CALL sp_afficher_fichier_import_sms(?);';
				
        $resultat = $this->executerRequete($sql, array($user));
		
		return $resultat->fetch(PDO::FETCH_ASSOC);
    }

    public function getModeleDestinataireSms()
	{
		$sql = 'CALL sp_export_modele_destinataire_sms();';
				
        $beneficiaires = $this->executerRequete($sql);
		
		return $beneficiaires->fetchAll(PDO::FETCH_ASSOC);
    }

    public function initIinsererLigneDestinataireSms()
	{
		$user = $_SESSION['login'];

		$sql = 'CALL sp_init_inserer_ligne_destinataire_sms(?);';
				
        $this->executerRequete($sql, array($user));
    }

    public function insererLigneDestinataireSms($idDestintaire, $libelleDestinataire, $destination)
	{
		$user 		= $_SESSION['login'];
		
		$sql = 'call sp_inserer_ligne_destinataire_sms(?, ?, ?, ?);';
				
        $resultat = $this->executerRequete($sql, array($user, $idDestintaire, $libelleDestinataire, $destination));
    }

    public function majetape()
	{
		$user = $_SESSION['login'];

		$sql = 'CALL sp_r_maj_etape_3_import_destinataire_sms(?);';
				
        $this->executerRequete($sql, array($user));
    }
	
	public function getderniermessagenonlu()
    {
		$sql = 'call sp_r_dernier_message_non_lu()';
			
		$resultat = $this->executerRequete($sql);
		
		return $resultat->fetch(PDO::FETCH_ASSOC);
    }

	public function getenvoiwhatsapp($date1, $date2)
    {
		$sql = 'call sp_get_envois_sms_whatsapp(?, ?)';
			
		$resultat = $this->executerRequete($sql, array($date1, $date2));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }
	
	public function getenvoiwhatsappencours($date1, $date2)
    {
		$sql = 'call sp_get_envois_sms_whatsapp_enc_cours(?, ?)';
			
		$resultat = $this->executerRequete($sql, array($date1, $date2));
		
		return $resultat->fetchAll(PDO::FETCH_ASSOC);
    }
}