<?php
error_reporting(E_ALL ^ E_STRICT ^ E_NOTICE ^ E_WARNING);

// Define path to application directory
defined('APPLICATION_PATH')
	|| define('APPLICATION_PATH', realpath(dirname(__FILE__) . '/../../application'));

// Define application environment
defined('APPLICATION_ENV')
	|| define('APPLICATION_ENV', (getenv('APPLICATION_ENV') ? getenv('APPLICATION_ENV') : 'production'));

// Ensure library/ is on include_path
set_include_path(implode(PATH_SEPARATOR, array(
	realpath(APPLICATION_PATH . '/../library'),
	get_include_path(),
)));

/** Zend_Application */
require_once 'Zend/Application.php';

// Create application, bootstrap, and run
$application = new Zend_Application(
		APPLICATION_ENV,
		APPLICATION_PATH . '/configs/application.ini'
);

try {
	$opts = new Zend_Console_Getopt(
		//Options
		array(
			'help|?' 	=> "Displays usage information.",
			'manual=s'	=> "Provide manualy the file without save in database",
			'debug' 	=> "Send a mail for debug",
		)
	);
	$opts->parse();
} catch (Zend_Console_Getopt_Exception $e) {
	echo $e->getUsageMessage();
	exit;
}

//Usage
if( isset($opts->help) || count($opts->getOptions())==0 )
{
	echo "Place files in right directory for sending to the customer.\n";
	echo $opts->getUsageMessage();
	exit;
}

require_once APPLICATION_PATH.'/configs/config.php';

require_once 'framework/fwk.php';
require_once 'framework/common/chiffres.php';
require_once 'framework/common/dates.php';
require_once 'framework/mail/sendMail.php';
require_once 'framework/common/mysql.php';

require_once 'Metier/insee/classMInsee.php';
require_once 'Metier/scores/classMSolvabilite.php';
require_once 'Metier/partenaires/classMLiens.php';

$c = new Zend_Config($application->getOptions());
$db = Zend_Db::factory($c->profil->db->metier);
Zend_Db_Table_Abstract::setDefaultAdapter($db);

//Configuration
$fileOptionsIn = array(
		'type' => 'csv',
		'delimiter' => ';',
		'enclosure' => '"',
		'header' => array('idDemande', 'SSAEmetteur'),
		'columns' => array('siren', 'nbLignes', 'dateContrat', 'nbContrats', 'ir'),
);

$fileOkOptionsOut = array(
		'type' => 'csv',
		'delimiter' => ';',
		'enclosure' => '"',
		'header' => array('idDemande', 'SSAEmetteur'),
		'columns' => array('siren', 'idVOR', 'PO', 'commentaire'),
		'name' => 'FICH_RCE_RETOUR_',
);

$fileErrorOptionsOut = array(
		'type' => 'csv',
		'delimiter' => ';',
		'enclosure' => '"',
		'header' => array('idDemande', 'SSAEmetteur'),
		'columns' => array('siren', 'code'),
		'name' => 'FICH_RCE_ERREUR_',
);

$client = 'SFR';
$typeDepot = 'SFTP';


// => Manual Mode
if ( $opts->manual ) {

	$filepath = $opts->manual;
	$pathOut = dirname($filepath);
	$dateBegin = date('YmdHis');

	//Read file
	$result = execFileIn($filepath, $fileOptionsIn, array('ok'=>$fileOkOptionsOut, 'error'=>$fileErrorOptionsOut), true);

	foreach($result as $code => $file) {
		$filename = $file['name'] . $dateBegin . '.csv';
		execFileOut($pathOut . DIRECTORY_SEPARATOR . $filename, $file);
	}

}

// => Automatic mode
else {

	//Lire les fichiers à traiter dans la table
	$c = new Zend_Config($application->getOptions());
	$db = Zend_Db::factory($c->profil->metier);
	Zend_Db_Table::setDefaultAdapter($db);

	//client, typeDepot, dateDepot, fileDepot, nblignes, dateInsert, dateExecute
	$fluxinM = new Application_Model_JoFluxFileIn();
	$sql = $fluxinM->select()
		->where('client=?',$client)
		->where('typeDepot=?',$typeDepot)
		->where('dateExecute=','0000-00-00 00:00:00');

	$result = $fluxinM->fetchAll($sql);

	if ( $result->count()==0 ) {
		//Send a mail
	} else {

		//Create output file from result
		$pathOut = $c->profil->path->storage .
			DIRECTORY_SEPARATOR . 'clients' .
			DIRECTORY_SEPARATOR . 'recv';

		$fluxoutM = new Application_Model_JoFluxFileOut();

		//Read file
		$result = execFileIn($filepath, $fileOptionsIn, array('ok'=>$fileOkOptionsOut, 'error'=>$fileErrorOptionsOut));

		foreach($result as $code => $file) {
			$dateBegin = date('YmdHis');

			$filename = $file['name'] . $dateBegin . '.csv';
			execFileOut($pathOut . DIRECTORY_SEPARATOR . $filename, $file);

			$dateEnd = date('YmdHis');

			$fluxoutM->insert(array(
					'client' => $client,
					'name' => $name,
					'nbLines' => $rows,
					'dateBegin' => $dateBegin,
					'dateEnd' => $dateEnd,
					'fileOut' => $filename,
					'typeDepot' => $typeDepot,
					'dateDepot' => '0000-00-00 00:00:00',
			));
		}

		//Ecrire la date d'execution dans flux_filein
		$fluxinM->update(array(
				'dateExecute' => $dateEnd,
		), 'id='.$item->id);

	}
}

/**
 *
 * @param unknown $values
 * @param unknown $row
 * @param string $debug
 * @return multitype:number multitype: Ambigous <string, multitype:, number, mixed, NULL>
 */
function execInternal($values, $row, $debug = false)
{
	$header = array();
	$error = 0;

	$siren = $values['siren'];

	echo "$siren";

	$classInsee = new MInsee();

	//Siren valide - 1010
	if ( !$classInsee->valideSiren($siren) ) {
		$error = 1;
		$values['code'] = '1010';
		echo " - Erreur 1010.".PHP_EOL;
	}

	//Siren existant - 1020
	if ( !$classInsee->sirenExiste($siren) ) {
		$error = 1;
		$values['code'] = '1020';
		echo " - Erreur 1020.".PHP_EOL;
	}

	if ($error == 0 ){
		//Calculate data
		require_once 'Metier/Sfr/Sfr.php';
		$sfrM = new Metier_Sfr();
		$sfrM->evaluate($siren);
		$values['idVOR'] = $sfrM->getIndicateur();
		$values['commentaire'] = $sfrM->getComment();
		$values['PO'] = $sfrM->getPo();


		if ($debug) {
			$valuesDebug = $sfrM->getValDebug();
			$values = array_merge($values, $valuesDebug);
			$header = array_keys($values);
		}

		echo " - VOR=".$values['idVOR']." , commentaire=".$values['commentaire']." , PO=".$values['PO'].PHP_EOL;
	}

	return array(
		'values' => $values,
		'error' => $error,
		'header' => $header,
	);
}

/**
 *
 * @param unknown $filepath
 * @param unknown $fileOptionsIn
 * @param unknown $filesOptionsOut
 * @param string $debug
 * @return Ambigous <multitype:, unknown, number, unknown, string, mixed, NULL>
 */
function execFileIn($filepath, $fileOptionsIn, $filesOptionsOut = array(), $debug = false)
{
	//Read file
	if ( file_exists($filepath) ) {

		$output = $filesOptionsOut;

		if (($handle = fopen($filepath, 'r')) !== false) {
			$row = 0;
			while (($data = fgetcsv($handle, 0, $fileOptionsIn['delimiter'], $fileOptionsIn['enclosure'])) !== false)
			{
				$row++;

				echo "Ligne $row : ";

				//Header
				if (count($fileOptionsIn['header']) > 0 && $row == 1) {
					foreach ( $fileOptionsIn['header'] as $i => $column ) {
						$header[$column] = $data[$i];
					}
					echo "Detection HEADER.".PHP_EOL;

					if ($debug) {
						$output['error']['header'] =  array();
						$output['ok']['header'] =  array();
					} else {
						$output['error']['header'] =  $header;
						$output['ok']['header'] =  $header;
					}
				}

				//Content
				else {

					//Set values
					$values = array();
					foreach ( $fileOptionsIn['columns'] as $i => $column ) {
						$values[$column] = $data[$i];
					}

					$valuesClient = execInternal($values, $row, true);

					if ( $valuesClient['error'] == 1 ) {
						$output['error']['line'][] = $valuesClient['values'];
						if ($debug) {
							$output['error']['columns'] =  $valuesClient['header'];
						}
					} else {
						$output['ok']['line'][] = $valuesClient['values'];
						if ($debug) {
							$output['ok']['columns'] =  $valuesClient['header'];
						}
					}

				}
			}


		}
		fclose($handle);

		return $output;
	}
}

/**
 *
 * @param unknown $file
 * @param unknown $options
 */
function execFileOut($file, $options)
{
	$fp = fopen($file, 'w');

	//=> Header
	$line = array();
	//Dynamic Header
	if ( count($options['header'])>0 ) {
		foreach ( $options['header'] as $i => $column ) {
			$line[] = $column;
		}
	}
	//Static Header
	else {
		foreach ( $options['columns'] as $i => $column ) {
			$line[] = $column;
		}
	}
	fputcsv($fp, $line, $options['delimiter'], $options['enclosure']);

	//=> Content
	if ( count($options['line'])>0 ) {
		foreach ($options['line'] as $c ) {
			$line = array();
			foreach ( $options['columns'] as $i => $column ) {
				$line[] = $c[$column];
			}
			fputcsv($fp, $line, $options['delimiter'], $options['enclosure']);
		}
	}
	fclose($fp);
}


//Lire ligne à ligne pour intégration
//Eviter les lignes vide
//=> Siren Ok alors calcul puis dans bdd et dans fichier ok
//=> Siren Non Ok dans fichier erreur avec son code

//Siren invalide, siren inexistant, calcul impossible


//Ligne d'entête (colonne 1 RCE<NumSeq>)

//SIREN => VARCHAR(9)
//Nombre de lignes actives => INT
//Date d'entrée en relation => VARCHAR()
//Nombre de contrats actifs => INT
//Indicateur de recouvrement => FLOAT

//Elements de sortie
//SIREN
//Indicateur VOR
//PO
//Commentaire


//Paramètres supplémentaires
//NumSeq
//Elements de calcul
//date

//Historisation
// INSERT [LOW_PRIORITY] [IGNORE] [INTO] nom_de_la_table [(liste des colonnes)] SELECT ...