SFR : Fichier CLI pour la gestion du fichier
This commit is contained in:
Michael RICOIS
parent
8c9be80f5a
commit
13c820611f
373
1.2/scripts/clients/SfrIndicateur.php
Normal file
373
1.2/scripts/clients/SfrIndicateur.php
Normal file
@ -0,0 +1,373 @@
|
||||
<?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 ...
|
||||
Loading…
x
Reference in New Issue
Block a user