<?php
use mikehaertl\wkhtmlto\Pdf;

require_once __DIR__ . '/Types.php';

class Pieces extends Scores_Ws_Server
{
	/**
	 * Récupération d'un kbis
	 * @param string $siren
	 *  SIREN ou SIRET siege
	 * @param string $diffusion
	 * 	Mode de diffusion (T=Téléchargement|M=Email|C=Courrier)
	 * @param string $reference
	 * 	Reference du client
	 * @return string
	 */
	public function getKbis($siren, $diffusion = 'T', $reference = '')
	{
		$this->authenticate();
		$this->permission('KBIS');

		$siren = substr($siren, 0, 9);

		// Vérification du siren
		if (intval($siren) == 0) {
			$this->sendError('1010');
		} elseif (strlen($siren) != 9) {
			$this->sendError('1020');
		}
		if (empty($diffusion)) {
		    $diffusion = 'T';
		}

		$iInsee = new Metier_Insee_MInsee();
		$identite = $iInsee->getIdentiteLight($siren);

		$refCommande = uniqid();

		$commandeM = new Application_Model_Sdv1GreffeCommandesKb();
		try {
    		$id = $commandeM->insert(array(
    		    'refCommande' => $refCommande,
    		    'login' => $this->User->login,
    		    'email' => $this->User->email,
    		    'refClient' => $reference,
    		    'mode' => $diffusion,
    		    'siren' => $siren,
    		    'raisonSociale' => $identite['Nom'],
    		    'dateInsert' => date('YmdHis'),
    		    'dateCommande' => date('YmdHis'),
    		));
		} catch (Zend_Db_Exception $e) {

		}

		switch ($diffusion) {

			//Demande de KBIS par email
		    case 'M':
		    //Demande de KBIS original par courrier
			case 'C':

				return $refCommande;

				break;

		    //Téléchargement du KBIS (payant)
			case 'T':
			default:

				$hostname = 'http://'.$_SERVER['SERVER_NAME'];
				if ($_SERVER['SERVER_PORT']!='80'){
					$hostname.= ':'.$_SERVER['SERVER_PORT'];
				}

				$c = Zend_Registry::get('config');
				$path = realpath($c->profil->path->shared).'/datafile/kbis/';

				//Le fichier existe avec une date de validité inférieure à 1 jour
				$filepdf = $path.$siren.'.pdf';
				if ( file_exists($filepdf) && date('Ymd', filemtime($filepdf))==date('Ymd') ) {

					$this->wsLog('kbis', $siren, basename($filepdf));
					$commandeM->update(array('dateEnvoi'=> date('YmdHis')), 'id='.$id);

					return $hostname.'/fichier/kbis/'.basename($filepdf);

				} else {

					$file = null;

					//On vérifie quand même si il n'existe pas une commande en html
					$dir = $path.date('Ymd');
					if ( file_exists($dir) ) {
						foreach ( glob($dir.'/'.$siren.'-*.html') as $file ) {
							break;
						}
					}

					if ( empty($file) ) {

					    $identifiant = $identite['Siret'];

						//Téléchargement du KBIS
						$result = array();
					    exec('php '.APPLICATION_PATH.'/../scripts/jobs//getKbis.php --siren '.$siren, $result);
					    $result = end($result);
						if (substr($result,-5)=='.html')
						{
							$file = $dir.'/'.$result;
							$this->wsLog('kbis', $siren, $result);
						}
						elseif ( $result!='ERREUR')
						{
							throw new SoapFault('MSG',$result);
						}
						else
						{
							$text = 'La récupération du KBIS a échoué sur le siren : '.$siren;
							throw new SoapFault('0000',"Erreur récupération du kbis");
						}
					} else {
						$this->wsLog('kbis', $siren, basename($file));
					}

					// Génération du PDF
					$pdf = new Pdf();
					$options = array(
					    'binary'           => $c->profil->wkhtmltopdf->path,
					    'ignoreWarnings'   => true,
					    'disable-internal-links',
					);
                    $pdf->setOptions($options);
					$pdf->addPage($file, array(), 'html');
                    $pdf->saveAs($filepdf);

					if ( !file_exists($filepdf) ) {
						throw new SoapFault('0000', "Fichier PDF introuvable");
					}

					$commandeM->update(array('dateEnvoi'=> date('YmdHis')), 'id='.$id);

					return $hostname.'/fichier/kbis/'.basename($filepdf);
				}

			break;
		}
	}

	/**
	 * Liste des bilans disponible au format image
	 * @param string $identifiant
	 * 	SIREN ou autre identifiant
	 * @param int $position
	 *	Numéro de page
	 * @param int $nbRep
	 * 	Nombre de réponse par page (max=200)
	 * @return Bilans
	 * @throws SoapFault
	 */
	public function getBilans($identifiant, $position = 0, $nbRep = 200)
	{
		// @todo : Code Saisie + Date saisie

		$this->authenticate();

		if ( empty($position) ) {
		    $position = 0;
		}
	    if ($nbRep > 200) {
	        $nbRep = 200;
	    }

	    if ( strlen($identifiant)!=9 ) {
	        $this->sendError('1010');
	    }

		/**
		 * Entreprise avec des bilans
		 * Base RNCS
		 * Si association alors lire dans la base de données pour établir la liste
		 * //@todo : Enregistrer dans la base jo.greffes_bilans
		 */
	    $iInsee = new Metier_Insee_MInsee();
	    $identite = $iInsee->getIdentiteLight($identifiant);
	    if (empty($identite['id'])){
	        $this->sendError('1020');
	    }
	    $fj = $identite['FJ'];

	    $assoFormeJuridique = array(
	        //Associations
	        '9210','9220','9221','9222','9223','9224','9230','9240','9260',
	        //Syndicats
	        '7345','7353','7354','7355','8410','8420','9110',
	        //Fondation
	        '9300',
	    );

	    $list = array();

	    /**
	     * Liste des bilans association
	     */
	    if ( in_array($fj, $assoFormeJuridique) ) {

    	    $bilansM = new Application_Model_JoAssoBilans();
    	    //Comptage
    	    $sql = $bilansM->select()
    	        ->from($bilansM, 'COUNT(*) as nb')
    	        ->where('siren=?', $identifiant);

    	    $nbBilans = $bilansM->fetchRow($sql)->nb;

    	    if ($nbBilans>0)
    	    {
        	    //Liste
        	    $sql = $bilansM->select()
        	        ->from($bilansM, array('dateCloture', 'Assoc_Date_Declaration', 'pdfLink',
        	            'typeCompte', 'pdfSize', 'pdfPage'))
        	        ->where('siren = ?', $identifiant)
        	        ->order('dateCloture DESC')
        	        ->limit($nbRep, $position);
        	    $bilans = $bilansM->fetchAll($sql);

        	    if( $bilans->count() > 0) {
        	        foreach ($bilans as $item) {

        	            $filename = basename($item->pdfLink);

        	            $c = Zend_Registry::get('config');
        	            $file = $c->profil->path->shared.'/datafile/association/bilans/' . $filename;

        	            $bilansList = new Bilan();
            	        $bilansList->DateCloture = substr($item->dateCloture,0,4).substr($item->dateCloture,5,2).substr($item->dateCloture,8,2);
            	        $bilansList->DateDepot = substr($item->Assoc_Date_Declaration,0,4).substr($item->Assoc_Date_Declaration,5,2).substr($item->Assoc_Date_Declaration,8,2);
            	        $bilansList->DureeExercice = '';
            	        $bilansList->Type = $item->typeCompte;

            	        //Chech file exist
            	        if ( file_exists($file) )
            	        {
            	            $bilansList->File = 'ASS_'.$filename;
            	            $bilansList->FileSize = $item->pdfSize;
            	            $bilansList->NumberOfPages = $item->pdfPage;
            	            $bilansList->ModeDiffusion = 'T';
            	        }
            	        $list[] = $bilansList;
            	    }
        	    }
    	    }

	    }
	    //Liste des bilans Infogreffe
	    else
	    {
	        $infogreffe = new Metier_Infogreffe_DocBI($identifiant);
	        try {
	           $list = $infogreffe->getList();
	        } catch (Exception $e) {
	            if ($this->User->idClient == 1) {
	                throw new SoapFault('ERR', $e->getMessage());
	            } else {
	                throw new SoapFault('ERR', "Application error");
	            }
	        }
	        $nbBilans = count($list);

            // Ajout d'informations supplémentaires
	        if ( count($list)>0 ) {
	        	foreach ( $list as $i => $item ) {

                    // Surcharge des codes de saisie
                    $date = DateTime::createFromFormat('Y-m-d', $item->DateCloture);
                    try {
                        $liasseM = new Application_Model_JoBilans();
                        $sql = $liasseM->select()
                                ->where('siren=?', $identifiant)
                                ->where('dateExercice=?', $date->format('Ymd'));
                        if ( $item->Type == 'consolides' ) {
                            $sql->where('typeBilan = "C"');
                        } elseif ( $item->Type == 'sociaux' ) {
                            $sql->where('typeBilan="N" OR typeBilan="S"');
                        }

                        $row = $liasseM->fetchRow($sql);
                    } catch (Zend_Db_Exception $e) {
                    	//file_put_contents('debug.log', $e->getMessage()."\n", FILE_APPEND);
                    }

                    //Override SaisieDate
                    if ( $row === null ) {

                        //Reset greffe_bilans : duree_exercice, saisie_date, saisie_code, ctrl_code, pages
                        if ( $item->SaisieDate !== null ) {
                            try {
                                $bilansM = new Application_Model_JoGreffesBilans();
                                $bilansM->update(array(
                                    'duree_exercice' => null,
                                    'saisie_date' => null,
                                    'saisie_code' => null,
                                    'ctrl_code' => null,
                                    'pages' => null,
                                ), array('siren='.$identifiant, 'num_depot='.$item->NumDepot) );
                            } catch (Zend_Db_Exception $e) {
                                file_put_contents('debug.log', $e->getMessage()."\n", FILE_APPEND);
                            }
                        }
                        $item->DureeExercice = null;
                        $item->SaisieDate = null;
                        $item->SaisieCode = null;

                    } else {
                        $item->DureeExercice = $row->dureeExercice;
                        $item->SaisieDate = substr($row->dateProvPartenaire,0,4).'-'.
                                            substr($row->dateProvPartenaire,4,2).'-'.
                                            substr($row->dateProvPartenaire,6,2);
                        $item->SaisieCode = '00';
                        //@todo : Améliorer le label de retour - partenaire de saisie
                        //$item->SaisieLabel = '';
                    }

                    if ( $item->ModeDiffusion == 'C' ) {
                        $cmdM = new Application_Model_Sdv1GreffeCommandesBi();
                        $sql = $cmdM->select()
                            ->where('siren=?', $identifiant)
                            ->where('bilanCloture=?', $item->DateCloture);
                        $row = $cmdM->fetchRow($sql);
                        if ( $row !== null ) {
                            $item->ModeDiffusion = 'O';
                        }
                    }

	        	}
	        }

	    }

	    $this->wsLog('greffe_bilans', $identifiant, 'Liste');

		$output = new Bilans();
		$output->nbReponses = $nbBilans;
		$output->result = $list;

		return $output;
	}

	/**
	 * Commande du fichier (URL ou Référence de commande)
	 * @param string $identifiant
	 * 	SIREN ou autre identifiant
	 * @param string $dateCloture
	 * 	Date de cloture du bilan (SSAA-MM-JJ)
	 * @param string $type
	 * 	Type de compte (null|sociaux|consolides)
	 * @param string $diffusion
	 * 	Mode de diffusion (T|C)
	 * @param string $reference
	 * 	Nom du fichier ou référence de commande
	 * @throws SoapFault
	 * @return string
	 * 	URL ou identifiant de commande
	 */
	public function getBilan($identifiant, $dateCloture, $type, $diffusion, $reference = '')
	{
		$this->authenticate();
		$this->permission('actes');

		if (strlen($identifiant) != 9) {
		    $this->sendError('1010');
		}

		if (empty($reference)) {
			$reference = '';
		}

		$output = '';

		/**
		 * Association
		 */
		if ( substr($reference, 0,4) == 'ASS_' ) {
		    switch ( $diffusion ) {
		        case 'T':
		            if ( preg_match('/^ASS_([0-9]{9})_([0-9]{8})/', $reference, $parseRef) ) {
		                $controlSiren = $parseRef[1];
		                $controlDate = substr($parseRef[2],4,4).substr($parseRef[2],2,2).substr($parseRef[2],0,2);
		                if ( $controlSiren == $identifiant && $controlDate == $dateCloture) {

		                	$filename = substr($reference,4);
		                    $c = Zend_Registry::get('config');
		                    $file = $c->profil->path->shared . '/datafile/association/bilans/' . $filename;
		                    $dest = $c->profil->path->shared . '/files/' . $reference;

		                    if ( file_exists($file) && copy($file, $dest)) {
		                        $hostname = 'http://'.$_SERVER['SERVER_NAME'];
		                        if ($_SERVER['SERVER_PORT']!='80') {
		                            $hostname.= ':'.$_SERVER['SERVER_PORT'];
		                        }
		                        $output = $hostname . '/fichier/associations/' . basename($dest);
		                        $dateClotureD = substr($dateCloture,4,2).'/'.substr($dateCloture,6,2).'/'.substr($dateCloture,0,4);
		                        $this->wsLog('greffe_bilans', $identifiant, 'Bilan association au '.$dateClotureD);
		                    }

		                }
		            }
		            break;
		    }

		    return $output;
		}

		/**
		 * Entreprise
		 */
		else {

		    // Génération identifiant de commande unique
		    $refCommande = uniqid();

		    $iInsee = new Metier_Insee_MInsee();
		    $identite = $iInsee->getIdentiteLight($identifiant);

		    // Sauvegarde dans la base
		    $data = array(
		        'refCommande'     => $refCommande,
		        'login'           => $this->User->login,
		        'email'           => $this->User->email,
		        'refClient'       => $reference,
		        'mode'            => $diffusion,
		        'siren'           => $identifiant,
		        'raisonSociale'   => $identite['Nom'],
		        'bilanCloture'    => $dateCloture,
		        'bilanType'       => $type,
		        'dateInsert'      => date('YmdHis'),
		    );
		    try {
		        $this->conn->insert('sdv1.greffe_commandes_bi', $data);
		        $id = $this->conn->lastInsertId();
		    }
		    catch(\Doctrine\DBAL\DBALException $e) {
		        if ($this->User->idClient == 1) {
		            throw new SoapFault('ERR', $e->getMessage());
		        }
		        else {
		            throw new SoapFault('ERR', "Application error");
		        }
		    }

		    switch ($diffusion) {

		    	case 'T':

		    	    // Passer la commande chez infogreffe
	                $infogreffe = new Metier_Infogreffe_DocBI($identifiant);
	                //$infogreffe->debug = true;
	                try {
                        $pdf = $infogreffe->getCommandeT($dateCloture, $type, $id);
                        try {
                            $this->conn->update('sdv1.greffe_commandes_bi',
                                array('dateEnvoi'=> date('YmdHis')), array('id' => $id));
                        }
                        catch(\Doctrine\DBAL\DBALException $e) {}
	                }
	                catch (Exception $e) {
	                    try {
	                        $this->conn->update('sdv1.greffe_commandes_bi',
	                            array('cmdError'=> $e->getMessage()), array('id' => $id));
	                    }
	                    catch(\Doctrine\DBAL\DBALException $e) {}
                        if ( $e->getCode() == $infogreffe::INT ) {
                            throw new SoapFault('ERR', "Erreur lors de la commande auprès de notre prestataire.");
                        }
	                }

	                // Distribuer le fichier
		            if ( !empty($pdf) ) {

		            	$c = Zend_Registry::get('config');
		            	$file = null;
                        if ( file_exists($c->profil->infogreffe->storage->path . '/OCR/' . $pdf) ) {
                            $file = $c->profil->infogreffe->storage->path . '/OCR/' . $pdf;
                        } elseif ( file_exists($c->profil->infogreffe->storage->path . '/' . $pdf) ) {
                            $file = $c->profil->infogreffe->storage->path . '/' . $pdf;
                        }
                        $dest = $c->profil->path->shared . '/files/' . basename($file);

    	                if ( $file !== null && copy($file, $dest) ) {
    	                    $hostname = 'http://'.$_SERVER['SERVER_NAME'];
    	                    if ( $_SERVER['SERVER_PORT'] != '80' ) {
    	                        $hostname.= ':'.$_SERVER['SERVER_PORT'];
    	                    }
    	                    $output = $hostname . '/fichier/greffes/' . basename($dest); // @todo : Chemin du fichier
    	                    $this->wsLog('greffe_bilans', $identifiant, basename($dest));
    	                }
    	                else {
    	                    throw new SoapFault('ERR', 'Fichier introuvable');
    	                }

		            }
	                break;

		        case 'C':
		        case 'F':

		        	// Commande chez Infogreffe
		        	if ( $diffusion == 'C' ) {
    		        	$infogreffe = new Metier_Infogreffe_DocBI($identifiant);
    		        	try {
    		        	    $infogreffe->getCommandeC($dateCloture, $type, 'G-BI-'.$id);
    		        	    try {
    		        	        $this->conn->update('sdv1.greffe_commandes_bi',
    		        	            array('dateCommande'=> date('YmdHis')), array('id' => $id));
    		        	    }
    		        	    catch(\Doctrine\DBAL\DBALException $e) {}
    		        	    $this->wsLog('greffe_bilans', $identifiant, $refCommande);
    		        	}
    		        	catch(Exception $e) {
    		        	    try {
    		        	        $this->conn->update('sdv1.greffe_commandes_bi',
    		        	            array('cmdError'=> $e->getMessage()), array('id' => $id));
    		        	    }
    		        	    catch(\Doctrine\DBAL\DBALException $e) {}
    		        	}
		        	}

					$output = $refCommande;
		            break;
		    }

		    return $output;
		}
	}

	/**
	 * Liste des actes au format image
	 * @param string $identifiant
	 * 	SIREN ou autre identifiant
	 * @param int $position
	 *	Numéro de page
	 * @param int $nbRep
	 * 	Nombre de réponse par page (max=200)
	 * @throws SoapFault
	 * @return Actes
	 */
	public function getActes($identifiant, $position = 0, $nbRep = 200)
	{
	    $this->authenticate();

	    if ( empty($position) ) {
	        $position = 0;
	    }
	    if ($nbRep > 200) {
	        $nbRep = 200;
	    }

	    if ( strlen($identifiant)!=9 ) {
	        $this->sendError('1010');
	    }

	    $iInsee = new Metier_Insee_MInsee();
	    $identite = $iInsee->getIdentiteLight($identifiant);
	    if (empty($identite['id'])){
	        $this->sendError('1020');
	    }

	    $infogreffe = new Metier_Infogreffe_DocAC($identifiant);
	    $list = $infogreffe->getList();
	    $nbActes = count($list);

	    if ($nbActes>0) {
    	    //Information INPI
    	    $rncs = new Metier_Partenaires_MRncs();
    	    foreach ($list as $i => $item) {
    	        $result = $rncs->getListeDepots($identifiant, $item->DepotDate);
    	        if (count($result)>0) {
    	            foreach ($result as $infos) {
    	                $list[$i]->infos[] = $infos['libDepot'];
    	            }
    	        }
    	    }
	    }

	    $this->wsLog('greffe_actes', $identifiant, 'Liste');

	    $output = new Actes();
	    $output->result = $list;
	    $output->nbReponses = $nbActes;

	    return $output;
	}

	/**
	 * Acte : Commande d'un fichier
	 * @param string $identifiant
	 * 		SIREN
	 * @param string $diffusion
	 * 		Mode de diffusion (C|T)
	 * @param string $depotNum
	 *
	 * @param string $depotDate
	 *
	 * @param string $acteType
	 * 		Type de l'acte
	 * @param string $acteNum
	 * 		Numéro de l'acte
	 * @param string $acteDate
	 * 		Date de l'acte
	 * @param string $reference
	 * 		A DETERMINER
	 * @throws SoapFault
	 * @return string
	 * 		URL ou identifiant de commande
	 */
	public function getActe($identifiant, $diffusion, $depotNum, $depotDate, $acteType, $acteNum, $acteDate, $reference = '')
	{
		$this->authenticate();
		$this->permission('actes');

		if (strlen($identifiant) != 9) {
			$this->sendError('1010');
		}

		$output = '';

		// Génération identifiant de commande unique
		$refCommande = uniqid();

		$iInsee = new Metier_Insee_MInsee();
		$identite = $iInsee->getIdentiteLight($identifiant);

		// Sauvegarde dans la base
		$data = array(
		    'refCommande'     => $refCommande,
		    'login'           => $this->User->login,
		    'email'           => $this->User->email,
		    'refClient'       => $reference,
		    'siren'           => $identifiant,
		    'mode'            => $diffusion,
		    'raisonSociale'   => $identite['Nom'],
		    'depotNum'        => $depotNum,
		    'depotDate'       => $depotDate,
		    'acteType'        => $acteType,
		    'acteDate'        => $acteDate,
		    'acteNum'         => $acteNum,
		    'dateInsert'      => date('YmdHis'),
		);
        try {
            $this->conn->insert('sdv1.greffe_commandes_ac', $data);
            $id = $this->conn->lastInsertId();
        }
        catch(\Doctrine\DBAL\DBALException $e) {
            if ($this->User->idClient == 1) {
                throw new SoapFault('ERR', $e->getMessage());
            }
            else {
                throw new SoapFault('ERR', "Application error");
            }
        }

		switch ($diffusion) {

			case 'T':

                // Passer la commande chez Infogreffe
				$infogreffe = new Metier_Infogreffe_DocAC($identifiant);
				try {
				    $pdf = $infogreffe->getCommandeT($depotDate, $depotNum, $acteType, $acteDate, $acteNum, $id);
				    try {
				        $this->conn->update('sdv1.greffe_commandes_ac',
				            array('dateEnvoi'=> date('YmdHis')), array('id' => $id));
				    }
				    catch(\Doctrine\DBAL\DBALException $e) {}
				}
				catch (Exception $e) {
				    try {
				        $this->conn->update('sdv1.greffe_commandes_ac',
				            array('cmdError'=> $e->getMessage()), array('id' => $id));
				    }
				    catch(\Doctrine\DBAL\DBALException $e) {}

				    if ( $e->getCode() == $infogreffe::INT ) {
                        throw new SoapFault('ERR', "Erreur lors de la commande auprès de notre prestataire.");
                    }
				}

				// Distribuer le fichier
				if ( !empty($pdf) ) {

					$c = Zend_Registry::get('config');
					$file = null;
					if ( file_exists($c->profil->infogreffe->storage->path . '/OCR/' . $pdf) ) {
					    $file = $c->profil->infogreffe->storage->path . '/OCR/' . $pdf;
					} elseif ( file_exists($c->profil->infogreffe->storage->path . '/' . $pdf) ) {
					    $file = $c->profil->infogreffe->storage->path . '/' . $pdf;
					}
					$dest = $c->profil->path->shared . '/files/' . basename($file);

					if ( $file !== null && copy($file, $dest)) {

						$hostname = 'http://'.$_SERVER['SERVER_NAME'];
						if ( $_SERVER['SERVER_PORT'] != '80' ) {
							$hostname.= ':'.$_SERVER['SERVER_PORT'];
						}
						$output = $hostname . '/fichier/greffes/' . basename($dest);
						$this->wsLog('greffe_actes', $identifiant, basename($dest));
						return $output;

					} else {
						throw new SoapFault('ERR', 'Fichier introuvable.');
					}

				}

				return false;

				break;

			case 'C':
			case 'F':

				if ( $diffusion == 'C' ) {
    				// Commande chez Infogreffe
    				$infogreffe = new Metier_Infogreffe_DocAC($identifiant);
    				try {
    				    $infogreffe->getCommandeC($depotDate, $depotNum, $acteType, $acteDate, $acteNum, 'G-AC-'.$id);
    				    try {
    				        $this->conn->update('sdv1.greffe_commandes_ac',
    				            array('dateCommande'=> date('YmdHis')), array('id' => $id));
    				    }
    				    catch(\Doctrine\DBAL\DBALException $e) {}
    				    $this->wsLog('greffe_actes', $identifiant, $refCommande);
    				}
    				catch(Exception $e) {
    				    try {
    				        $this->conn->update('sdv1.greffe_commandes_ac',
    				            array('cmdError'=> $e->getMessage()), array('id' => $id));
    				    }
    				    catch(\Doctrine\DBAL\DBALException $e) {}
    				}
				}

				return $refCommande;

				break;
		}

		return $output;
	}

	/**
	 * Set an email associated to the command
	 * @param string $id
	 * @param string $email
	 * @throws SoapFault
	 * @return boolean
	 */
	public function setActeCmdEmail($id, $email)
	{
	    $this->authenticate();
	    $this->permission('actes');

        $validator = new Zend_Validate_EmailAddress();
        if ( !$validator->isValid($email) ){
        	throw new SoapFault('ERR', "Adresse email invalide.");
        }

	    // --- Vérification que la commande existe
	    try {
	        $sql = "SELECT * FROM sdv1.greffe_commandes_ac WHERE login = :login AND refCommande = :id";
	        $stmt = $this->conn->prepare($sql);
	        $stmt->bindValue('login', $this->User->login);
	        $stmt->bindValue('id', $id);
	        $stmt->execute();
	    }
	    catch (\Doctrine\DBAL\DBALException $e) {
	        if ($this->User->idClient == 1) {
	            throw new SoapFault('ERR', $e->getMessage());
	        }
	        else {
	            throw new SoapFault('ERR', "Application error");
	        }
	    }

	    if ($stmt->rowCount() > 0) {
	        if ( is_int($email) ) {
	            //Id of secondary email
	        }
	        else {
	            $dataUpdate = array('email' => $email);
	            try {
	                $result = $this->conn->update('sdv1.greffe_commandes_ac', $dataUpdate,
	                    array('refCommande' => $id));
	                if ($result) {
	                    return true;
	                }
	            }
	            catch (\Doctrine\DBAL\DBALException $e) {
	                if ($this->User->idClient == 1) {
	                    throw new SoapFault('ERR', $e->getMessage());
	                }
	                else {
	                    throw new SoapFault('ERR', "Application error");
	                }
	            }
	        }
	    }

	    return false;
	}

	/**
	 * Set an email associated to the command
	 * @param string $id
	 * @param string $email
	 * @throws SoapFault
	 * @return boolean
	 */
	public function setBilanCmdEmail($id, $email)
	{
	    $this->authenticate();
	    $this->permission('actes');

	    $validator = new Zend_Validate_EmailAddress();
	    if ( !$validator->isValid($email) ){
	        throw new SoapFault('ERR', "Adresse email invalide.");
	    }

	    // --- Vérification que la commande existe
	    try {
	        $sql = "SELECT * FROM sdv1.greffe_commandes_bi WHERE login = :login AND refCommande = :id";
	        $stmt = $this->conn->prepare($sql);
	        $stmt->bindValue('login', $this->User->login);
	        $stmt->bindValue('id', $id);
	        $stmt->execute();
	    }
	    catch (\Doctrine\DBAL\DBALException $e) {
	        if ($this->User->idClient == 1) {
	            throw new SoapFault('ERR', $e->getMessage());
	        }
	        else {
	            throw new SoapFault('ERR', "Application error");
	        }
	    }

	    if ($stmt->rowCount() > 0) {
	        if ( is_int($email) ) {
	            //Id of secondary email
	        }
	        else {
	            $dataUpdate = array('email' => $email);
	            try {
	                $result = $this->conn->update('sdv1.greffe_commandes_bi', $dataUpdate,
	                    array('refCommande' => $id));
	                if ($result) {
	                    return true;
	                }
	            }
	            catch (\Doctrine\DBAL\DBALException $e) {
	                if ($this->User->idClient == 1) {
	                    throw new SoapFault('ERR', $e->getMessage());
	                }
	                else {
	                    throw new SoapFault('ERR', "Application error");
	                }
	            }
	        }
	    }

	    return false;
	}

	/**
	 * Set an email associated to the command
	 * @param string $id
	 * @param string $email
	 * @throws SoapFault
	 * @return boolean
	 */
	public function setKbisCmdEmail($id, $email)
	{
	    $this->authenticate();
	    $this->permission('KBIS');

	    $validator = new Zend_Validate_EmailAddress();
	    if ( !$validator->isValid($email) ){
	        throw new SoapFault('ERR', "Adresse email invalide.");
	    }

	    // --- Vérification que la commande existe
	    try {
	        $sql = "SELECT * FROM sdv1.greffe_commandes_kb WHERE login = :login AND refCommande = :id";
	        $stmt = $this->conn->prepare($sql);
	        $stmt->bindValue('login', $this->User->login);
	        $stmt->bindValue('id', $id);
	        $stmt->execute();
	    }
	    catch (\Doctrine\DBAL\DBALException $e) {
	        if ($this->User->idClient == 1) {
	            throw new SoapFault('ERR', $e->getMessage());
	        }
	        else {
	            throw new SoapFault('ERR', "Application error");
	        }
	    }

	    if ($stmt->rowCount() > 0) {
	        if ( is_int($email) ) {
	            //Id of secondary email
	        }
	        else {
	            $dataUpdate = array('email' => $email);
	            try {
	                $result = $this->conn->update('sdv1.greffe_commandes_kb', $dataUpdate,
	                    array('refCommande' => $id));
	                if ($result) {
	                    return true;
	                }
	            }
	            catch (\Doctrine\DBAL\DBALException $e) {
	                if ($this->User->idClient == 1) {
	                    throw new SoapFault('ERR', $e->getMessage());
	                }
	                else {
	                    throw new SoapFault('ERR', "Application error");
	                }
	            }
	        }
	    }

	    return false;
	}

	/**
	 * Ajouter des informations pour la commande, principalement lors de commande courrier
	 * @param string $id
	 *     Identifiant de la commande
	 * @param string $infos
	 *     Information au format json
	 * @throws SoapFault
	 * @return boolean
	 */
	public function setKbisCmdLetter($id, $infos)
	{
	    $this->authenticate();
	    $this->permission('KBIS');

	    // --- Vérification que la commande existe
	    try {
	        $sql = "SELECT * FROM sdv1.greffe_commandes_kb WHERE login = :login AND refCommande = :id";
	        $stmt = $this->conn->prepare($sql);
	        $stmt->bindValue('login', $this->User->login);
	        $stmt->bindValue('id', $id);
	        $stmt->execute();
	    }
	    catch (\Doctrine\DBAL\DBALException $e) {
	        if ($this->User->idClient == 1) {
	            throw new SoapFault('ERR', $e->getMessage());
	        }
	        else {
	            throw new SoapFault('ERR', "Application error");
	        }
	    }

	    if ($stmt->rowCount() == 0) {
	        return false;
	    }

	    // --- Update
        $dataUpdate = array('infos' => $infos);
        try {
            $result = $this->conn->update('sdv1.greffe_commandes', $dataUpdate,
                array('refCommande' => $id));
            if ($result) {
                return true;
            }
        } catch (\Doctrine\DBAL\DBALException $e) {
            if ($this->User->idClient == 1) {
                throw new SoapFault('ERR', $e->getMessage());
            } else {
                throw new SoapFault('ERR', "Application error");
            }

        }

	    return false;
	}

	/**
	 * Statut association - Liste
	 * @param string $companyId
	 * @param string $type
	 * @return AssoActe[]
	 */
	public function getAssoActes($companyId, $type = null)
	{
	    $this->authenticate();

	    // --- Lecture de la table des actes associations
        try {
            $sql = "SELECT * FROM jo.asso_statut WHERE companyId = :companyId";
            $stmt = $this->conn->prepare($sql);
            $stmt->bindValue('companyId', $companyId);
            $stmt->execute();
        }
        catch (\Doctrine\DBAL\DBALException $e) {
            if ($this->User->idClient == 1) {
                throw new SoapFault('ERR', $e->getMessage());
            }
            else {
                throw new SoapFault('ERR', "Application error");
            }
        }

        $output = array();
        if ($stmt->rowCount() > 0) {
            $statutResult = $stmt->fetchAll(\PDO::FETCH_OBJ);
            foreach ($statutResult as $item) {
                $statut = new AssoActe();
                $statut->Date = $item->statutDate;
                $statut->File = $item->statutFile;
                $statut->DateInsert = $item->dateInsert;
                $output[] = $statut;
            }
        }

        return $output;
	}

	/**
	 * Statut association - Fichier
	 * @param string $companyId
	 *     Identifiant, siren de l'entreprise
	 * @param string $type
	 * @param string $date
	 *     Date au format AAAA-MM-JJ
	 * @throws SoapFault
	 * @return string
	 *     URL ou identifiant de commande
	 */
	public function getAssoActe($companyId, $type = null, $date)
	{
	    $this->authenticate();
	    $this->permission('actes');

        // --- Lecture table des actes associations
        try {
            $sql = "SELECT * FROM jo.asso_statut WHERE companyId = :companyId AND statutDate = :date";
            $stmt = $this->conn->prepare($sql);
            $stmt->bindValue('companyId', $companyId);
            $stmt->bindValue('date', $date);
            $stmt->execute();
        }
        catch (\Doctrine\DBAL\DBALException $e) {
            if ($this->User->idClient == 1) {
                throw new SoapFault('ERR', $e->getMessage());
            }
            else {
                throw new SoapFault('ERR', "Application error");
            }
        }

        if ($stmt->rowCount() == 0) {
            return false;
        }

        $statutResult = $stmt->fetch(\PDO::FETCH_BOTH);

	    // --- Distribuer le fichier
	    if ( !empty($statutResult->statutFile) ) {
	        $c = Zend_Registry::get('config');
	        $file = $c->profil->path->shared . '/datafile/association/actes/' . $statutResult->statutFile;
	        $dest = $c->profil->path->shared . '/files/' . basename($file);
	        if ( file_exists($file) && copy($file, $dest)) {
	            $hostname = 'http://'.$_SERVER['SERVER_NAME'];
	            if ( $_SERVER['SERVER_PORT'] != '80' ) {
	                $hostname.= ':'.$_SERVER['SERVER_PORT'];
	            }
	            $output = $hostname . '/fichier/greffes/' . basename($dest);
	            $this->wsLog('assoacte', $companyId, basename($dest));
	            return $output;
	        } else {
	            throw new SoapFault('ERR', 'Fichier introuvable.');
	        }
	    }

	    return false;
	}

	/**
	 * Commande de statut association
	 * @param string $companyId
	 * @param string $type (siren|waldec)
	 * @throws SoapFault
	 * @return mixed
	 */
	public function setAssoStatut($companyId, $type = null)
	{
	    $this->authenticate();
	    $this->permission('actes');

	    $inseeM = new Metier_Insee_MInsee();
	    if ($type == 'siren') {
	        $result = $inseeM->getIdentiteLight($companyId);
	        $companyName = $result['Nom'];
	    } elseif ($type == 'waldec') {
	        $result = $inseeM->getEtablissementsParId('AUTRE', $companyId);
	        $companyName = $result['Nom'];
	    }

	    $refCommande = uniqid();

        try {
            $data = array(
                'refCommande'   => $refCommande,
                'companyId'     => $companyId,
                'typeId'        => $type,
                'companyName'   => $companyName,
                'userId'        => $this->User->id,
                'userLogin'     => $this->User->login,
                'userEmail'     => $this->User->email,
                'dateInsert'    => date('YmdHis'),
            );
            $result = $this->conn->insert('sdv1.order_asso_statut', $data);
            if ($result) {
                return $refCommande;
            }
	    }
	    catch (\Doctrine\DBAL\DBALException $e) {
	        if ($this->User->idClient == 1) {
	            throw new SoapFault('ERR', $e->getMessage());
	        } else {
	            throw new SoapFault('ERR', "Application error");
	        }
	    }

	    return false;
	}

	/**
	 * Modifier une commande de statut association
	 * @param string $id
	 *     Référence de commande
	 * @param string $data
	 *     Objet json (email, reference)
	 * @throws SoapFault
	 * @return boolean
	 */
	public function setAssoStatutDetail($id, $data)
	{
	    $this->authenticate();
	    $this->permission('actes');

	    // --- Vérification que la commande existe
	    try {
	        $sql = "SELECT * FROM sdv1.order_asso_statut WHERE userLogin = :login AND refCommande = :id";
	        $stmt = $this->conn->prepare($sql);
	        $stmt->bindValue('login', $this->User->login);
	        $stmt->bindValue('id', $id);
	        $stmt->execute();
	    }
	    catch (\Doctrine\DBAL\DBALException $e) {
	        if ($this->User->idClient == 1) {
	            throw new SoapFault('ERR', $e->getMessage());
	        }
	        else {
	            throw new SoapFault('ERR', "Application error");
	        }
	    }

	    if ($stmt->rowCount() == 0) {
	        return false;
	    }

	    // --- Paramètres envoyés
	    $params = json_decode($data, true);
	    $dataUpdate = array();
	    if (count($params) > 0) {
	        foreach ($params as $k => $v) {
	            switch ($k) {
	                case 'email':
        	            // --- Vérification email
        	            $validator = new Zend_Validate_EmailAddress();
        	            if ( !$validator->isValid($v) ){
        	                throw new SoapFault('ERR', "Adresse email invalide.");
        	            }
        	            $dataUpdate['email'] = $v;
    	            break;
	                case 'reference':
	                    $dataUpdate['reference'] = $v;
	                    break;
	            }
	        }
	    }

	    // --- Mise à jour de la commande
        if (count($dataUpdate) > 0) {
            try {
                $result = $this->conn->update('sdv1.order_asso_statut', $dataUpdate,
                    array('refCommande' => $id));
                if ($result) {
                    return true;
                }
            }
            catch (\Doctrine\DBAL\DBALException $e) {
                if ($this->User->idClient == 1) {
                    throw new SoapFault('ERR', $e->getMessage());
                } else {
                    throw new SoapFault('ERR', "Application error");
                }
            }
        }

	    return false;
	}

	/**
	 * Commande de privileges
	 * @param string $companyId
	 *     Siren
	 * @param string $doc
	 *     Type de privilege (privsecu, privtres, nantfond, declcrea)
	 * @throws SoapFault
	 * @return mixed
	 */
	public function setPrivileges($companyId, $doc = null)
	{
	    $this->authenticate();
	    $this->permission('privileges');

	    $inseeM = new Metier_Insee_MInsee();
        $result = $inseeM->getIdentiteLight($companyId);
        $companyName = $result['Nom'];

	    $refCommande = uniqid();

	    try {
	        $data = array(
	            'refCommande'  => $refCommande,
	            'docType'      => $doc,
	            'companyId'    => $companyId,
	            'companyName'  => $companyName,
	            'userId'       => $this->User->id,
	            'userLogin'    => $this->User->login,
	            'userEmail'    => $this->User->email,
	            'dateInsert'   => date('YmdHis'),
	        );
	        $result = $this->conn->insert('sdv1.order_privileges', $data);
            if ($result) {
                return $refCommande;
            }
	    }
	    catch (\Doctrine\DBAL\DBALException $e) {
	        if ($this->User->idClient == 1) {
	            throw new SoapFault('ERR', $e->getMessage());
	        } else {
	            throw new SoapFault('ERR', "Application error");
	        }
	    }

	    return false;
	}

	/**
	 * Défini un email pour la commande de privilege
	 * @param string $id
	 * @param string $email
	 * @throws SoapFault
	 * @return boolean
	 */
	public function setPrivilegesEmail($id, $email)
	{
	    $this->authenticate();

	    $validator = new Zend_Validate_EmailAddress();
	    if ( !$validator->isValid($email) ){
	        throw new SoapFault('ERR', "Adresse email invalide.");
	    }

	    try {
    	    $sql = "SELECT * FROM sdv1.order_privileges WHERE login = :login AND refCommande = :id";
            $stmt = $this->conn->prepare($sql);
            $stmt->bindValue('login', $this->User->login);
            $stmt->bindValue('id', $id);
            $stmt->execute();
	    }
	    catch (\Doctrine\DBAL\DBALException $e) {
	        if ($this->User->idClient == 1) {
	            throw new SoapFault('ERR', $e->getMessage());
	        }
	        else {
	            throw new SoapFault('ERR', "Application error");
	        }
	    }

	    if ($stmt->rowCount() > 0) {
	        if ( is_int($email) ) {
	            //Id of secondary email
	        }
	        else {
	            $dataUpdate = array('email' => $email);
	            try {
	                $result = $this->conn->update('sdv1.order_privileges', $dataUpdate,
	                    array('refCommande' => $id));
	                if ($result) {
	                    return true;
	                }
	            }
	            catch (\Doctrine\DBAL\DBALException $e) {
	                if ($this->User->idClient == 1) {
	                    throw new SoapFault('ERR', $e->getMessage());
	                }
	                else {
	                    throw new SoapFault('ERR', "Application error");
	                }
	            }
	        }
	    }

	    return false;
	}

}