1009 lines
35 KiB
PHP
1009 lines
35 KiB
PHP
<?php
|
|
/*
|
|
* Crontab
|
|
* 01 19 * * 1-6 scores php /home/scores/batch/scripts/clients/SfrIndicateur.php --cron --load >> /home/scores/batch/shared/log/SfrIndicateur.log
|
|
* 01 00 * * 1-6 scores php /home/scores/batch/scripts/clients/SfrIndicateur.php --cron --evaluate >> /home/scores/batch/shared/log/SfrIndicateur.log
|
|
*/
|
|
error_reporting(E_ALL & ~E_STRICT & ~E_NOTICE & ~E_WARNING & ~E_DEPRECATED);
|
|
|
|
// --- Define path to application directory
|
|
defined('APPLICATION_PATH')
|
|
|| define('APPLICATION_PATH', realpath(__DIR__ . '/../application'));
|
|
|
|
// --- Define application environment
|
|
defined('APPLICATION_ENV')
|
|
|| define('APPLICATION_ENV', (getenv('APPLICATION_ENV') ? getenv('APPLICATION_ENV') : 'production'));
|
|
|
|
// --- Composer autoload
|
|
require_once realpath(__DIR__ . '/../vendor/autoload.php');
|
|
|
|
// Create application, bootstrap, and run
|
|
$application = new Zend_Application(APPLICATION_ENV, APPLICATION_PATH . '/configs/application.ini');
|
|
|
|
// --- Options
|
|
$displayUsage = false;
|
|
try {
|
|
$opts = new Zend_Console_Getopt(array(
|
|
'help|?' => "Displays usage information.",
|
|
'load-s' => "Preload file in database and check SIREN",
|
|
'evaluate-s' => "Lauch evaluation (specify the Seq Number to regen)",
|
|
'manual-s' => "Provide manualy the file path to get result and debug values",
|
|
'debug' => "Debug",
|
|
'cron' => "Mandatory option for launch the cli in cron",
|
|
));
|
|
$opts->parse();
|
|
} catch (Zend_Console_Getopt_Exception $e) {
|
|
$displayUsage = true;
|
|
}
|
|
|
|
// --- Aide / Options
|
|
if (count($opts->getOptions())==0 || isset($opts->help)) {
|
|
$displayUsage = true;
|
|
}
|
|
|
|
// --- Usage
|
|
if ($displayUsage) {
|
|
echo "Execute prestation SFR.\n";
|
|
echo $opts->getUsageMessage();
|
|
exit;
|
|
}
|
|
|
|
require_once APPLICATION_PATH.'/configs/config.php';
|
|
|
|
$c = new Zend_Config($application->getOptions());
|
|
$db = Zend_Db::factory($c->profil->db->metier);
|
|
Zend_Db_Table_Abstract::setDefaultAdapter($db);
|
|
|
|
// Database
|
|
$config = new \Doctrine\DBAL\Configuration();
|
|
$connectionParams = array(
|
|
'dbname' => $c->profil->db->metier->params->dbname,
|
|
'user' => $c->profil->db->metier->params->username,
|
|
'password' => $c->profil->db->metier->params->password,
|
|
'host' => $c->profil->db->metier->params->host,
|
|
'charset' => 'utf8',
|
|
'driver' => 'pdo_mysql',
|
|
);
|
|
|
|
try {
|
|
$conn = \Doctrine\DBAL\DriverManager::getConnection($connectionParams, $config);
|
|
Zend_Registry::set('doctrine', $conn);
|
|
} catch (\Doctrine\DBAL\DBALException $e) {
|
|
echo "Connection Database impossible.\n";
|
|
exit;
|
|
}
|
|
|
|
$client = 'sfrbtr';
|
|
$typeDepot = 'SFTP';
|
|
$prestation = 'FICH_RCE';
|
|
|
|
//Input path
|
|
$pathIn = $c->profil->path->shared .
|
|
DIRECTORY_SEPARATOR . 'clients' .
|
|
DIRECTORY_SEPARATOR . $client .
|
|
DIRECTORY_SEPARATOR . 'send';
|
|
|
|
//Output path
|
|
$pathOut = $c->profil->path->shared .
|
|
DIRECTORY_SEPARATOR . 'clients' .
|
|
DIRECTORY_SEPARATOR . $client .
|
|
DIRECTORY_SEPARATOR . 'recv';
|
|
|
|
/*
|
|
* File Configuration
|
|
* Possible encoding :
|
|
* Windows-1252//TRANSLIT
|
|
* ISO-8859-15//TRANSLIT
|
|
*
|
|
*/
|
|
$fileOptionsIn = array(
|
|
'dir' => $pathIn,
|
|
'type' => 'csv',
|
|
'delimiter' => ';',
|
|
'enclosure' => '"',
|
|
'header' => array('idDemande', 'SSAEmetteur'),
|
|
'columns' => array('siren', 'nbLignes', 'dateContrat', 'nbContrats', 'ir'),
|
|
'encoding' => 'ISO-8859-15',
|
|
);
|
|
|
|
$fileOkOptionsOut = array(
|
|
'dir' => $pathOut,
|
|
'type' => 'csv',
|
|
'delimiter' => ';',
|
|
'enclosure' => '"',
|
|
'header' => array('idDemande', 'SSAEmetteur'),
|
|
'columns' => array('siren', 'idVOR', 'PO', 'commentaire'),
|
|
'name' => 'FICH_RCE_RETOUR_',
|
|
'encoding' => 'ISO-8859-15',
|
|
);
|
|
|
|
$fileErrorOptionsOut = array(
|
|
'dir' => $pathOut,
|
|
'type' => 'csv',
|
|
'delimiter' => ';',
|
|
'enclosure' => '"',
|
|
'header' => array('idDemande', 'SSAEmetteur'),
|
|
'columns' => array('siren', 'code'),
|
|
'name' => 'FICH_RCE_ERREUR_',
|
|
'encoding' => 'ISO-8859-15',
|
|
);
|
|
|
|
$filePortefeuilleOptionsOut = array(
|
|
'dir' => $pathOut,
|
|
'type' => 'csv',
|
|
'delimiter' => ',',
|
|
'enclosure' => '"',
|
|
'header' => array(),
|
|
'columns' => array(
|
|
'loginUti',
|
|
'source',
|
|
'email',
|
|
'siren',
|
|
'nic',
|
|
'ref',
|
|
'dateAjout',
|
|
'rs',
|
|
'cp',
|
|
'ville',
|
|
'dateDerEnvoi',
|
|
'encoursClient',
|
|
'actif',
|
|
'procol',
|
|
'indiScore20',
|
|
'encours',
|
|
'indiScoreDate',
|
|
'dateBilan',
|
|
'indiScore20Pre',
|
|
'encoursPre',
|
|
'indiScoreDatePre',
|
|
'sourceModif',
|
|
'scoreSolv',
|
|
'scoreSolvPre',
|
|
'scoreDir',
|
|
'scoreDirPre',
|
|
'scoreConf',
|
|
'scoreConfPre',
|
|
'cj',
|
|
'capital',
|
|
'capitalDev',
|
|
'ape_entrep',
|
|
'tca',
|
|
'teff_entrep',
|
|
'dateUpdate',
|
|
),
|
|
'name' => 'CLIENTSINDISCORE_',
|
|
'encoding' => 'ISO-8859-15',
|
|
);
|
|
|
|
// => Debug Mode - Create file with debug values
|
|
if ($opts->manual) {
|
|
if (!empty($opts->manual) && $opts->manual!==true) {
|
|
$filepath = $opts->manual;
|
|
$pathOut = dirname(realpath($filepath));
|
|
} else {
|
|
$pathOut = dirname(__FILE__);
|
|
}
|
|
|
|
$fileOptionsIn['dir'] = $pathOut;
|
|
$fileErrorOptionsOut['dir'] = $pathOut;
|
|
$fileOkOptionsOut['dir'] = $pathOut;
|
|
|
|
$dateBegin = date('YmdHis');
|
|
$filesOutOptions = array(
|
|
'ok' => $fileOkOptionsOut,
|
|
'error' => $fileErrorOptionsOut
|
|
);
|
|
}
|
|
|
|
// => Automatic mode
|
|
if ($opts->cron) {
|
|
|
|
/*
|
|
* Detecter si la date n'est pas trop ancienne
|
|
*/
|
|
$dateNow = new DateTime();
|
|
$dateIn1 = $dateNow->format('Y-m-d H:i:s');
|
|
$dateNow->sub(new DateInterval('PT20H'));
|
|
$dateIn2 = $dateNow->format('Y-m-d H:i:s');
|
|
|
|
//client, name, depotType, depotDate, depotFile, nbLines, dateInsert, dateExecute
|
|
$fluxinSql = "SELECT * FROM sdv1.flux_filein
|
|
WHERE client=:client AND name=:prestation AND depotType=:typeDepot
|
|
AND dateExecute='0000-00-00 00:00:00' AND dateInsert BETWEEN :dateIn2 AND :dateIn1
|
|
ORDER BY dateInsert DESC";
|
|
try {
|
|
$stmt = $conn->prepare($fluxinSql);
|
|
$stmt->bindValue('client', $client);
|
|
$stmt->bindValue('prestation', $prestation);
|
|
$stmt->bindValue('typeDepot', $typeDepot);
|
|
$stmt->bindValue('dateIn2', $dateIn2);
|
|
$stmt->bindValue('dateIn1', $dateIn1);
|
|
$stmt->execute();
|
|
} catch (\Doctrine\DBAL\DBALException $e) {
|
|
echo $e->getMessage();
|
|
exit(1);
|
|
}
|
|
|
|
if ($stmt->rowCount() == 0) {
|
|
echo date('Y-m-d H:i:s')." : Aucun traitement à réaliser.".PHP_EOL;
|
|
exit;
|
|
}
|
|
|
|
$p = $stmt->fetch(\PDO::FETCH_OBJ);
|
|
$filepath = $pathIn . DIRECTORY_SEPARATOR . $p->depotFile;
|
|
|
|
if (!file_exists($filepath)) {
|
|
echo date('Y-m-d H:i:s')." : Fichier inexistant ! ".PHP_EOL;
|
|
exit;
|
|
}
|
|
|
|
$opts->load = $filepath;
|
|
}
|
|
|
|
/**
|
|
* Chargement du fichier avec premières vérifications
|
|
*/
|
|
if ($opts->load && !$opts->evaluate) {
|
|
|
|
// Lire et vérifier le fichier
|
|
if (checkFile($opts->load, $fileOptionsIn)) {
|
|
// Charger dans la table client AVEC vérification SIREN valide et existe
|
|
echo date('Y-m-d H:i:s')." - Début chargement...\n";
|
|
$seq = execDbIn($opts->load, $fileOptionsIn);
|
|
|
|
// Marquer les SIREN qui n'existe pas dans la bdd
|
|
echo date('Y-m-d H:i:s')." - Marquage des SIREN inexistant\n";
|
|
$sql = "UPDATE jo.sfr_data SET error=1020 WHERE NumSeq='".$seq."' AND error=0 AND siren NOT IN (SELECT DISTINCT siren FROM jo.etablissements_old)";
|
|
try {
|
|
$conn->executeQuery($sql);
|
|
} catch (\Doctrine\DBAL\DBALException $e) {
|
|
$sql = "UPDATE jo.sfr_data SET error=1020 WHERE NumSeq='".$seq."' AND error=0 AND siren NOT IN (SELECT DISTINCT siren FROM jo.etablissements)";
|
|
$conn->executeQuery($sql);
|
|
}
|
|
|
|
//@todo : Mise à jour du portefeuille CFT (Nom de la prestation)
|
|
|
|
//Ajouter les SIREN valide qui ne sont pas en surveillance
|
|
echo date('Y-m-d H:i:s')." - Mise sous surveillance\n";
|
|
$sql = "INSERT IGNORE INTO jo.scores_surveillance (siren) (SELECT siren FROM jo.sfr_data WHERE error=0 AND NumSeq='".$seq."')";
|
|
$conn->executeQuery($sql);
|
|
|
|
//Marquer les SIREN qui ne seront pas calculé
|
|
/*echo date('Y-m-d H:i:s')." - Marquage des SIREN imposssible à calculer\n";
|
|
$sql = "UPDATE jo.sfr_data SET error=2020 WHERE NumSeq='".$seq."' AND error=0 AND siren IN (SELECT siren FROM jo.scores_surveillance WHERE naf='' OR CJ IS NULL OR dateCrea IS NULL OR indiScoreDate='0000-00-00')";
|
|
$result = $db->query($sql);*/
|
|
}
|
|
|
|
// --- Nettoyage
|
|
$date = new DateTime();
|
|
if ($date->format('w') == 6) {
|
|
$date->sub(new DateInterval('P1D'))->setTime(23, 59, 59);
|
|
echo date('Y-m-d H:i:s')." - Suppression ancienne référence.\n";
|
|
$sql = "DELETE FROM jo.sfr_data WHERE dateInsert < '".$date->format('Y-m-d H:i:s')."'";
|
|
try {
|
|
$conn->executeQuery($sql);
|
|
} catch (\Doctrine\DBAL\DBALException $e) {
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Lancement de l'évaluation et création des 3 fichiers de sorties
|
|
*/
|
|
if ($opts->evaluate) {
|
|
|
|
// Traitement automatique
|
|
if (!empty($opts->manual) && $opts->manual!==true) {
|
|
echo "Traitement Manuel..." . "\n";
|
|
execFileIn($filepath, $fileOptionsIn, array('ok'=>$fileOkOptionsOut, 'error'=>$fileErrorOptionsOut), $opts->debug);
|
|
}
|
|
// Traitement manuel
|
|
else {
|
|
$execRef = new Scores_Exec_Ref('SFRINDICATEUR');
|
|
$execId = $execRef->start();
|
|
|
|
$nbLines = 0;
|
|
|
|
// Use Seq Number from command line
|
|
if ($opts->evaluate !== true) {
|
|
$seq = $opts->evaluate;
|
|
}
|
|
// Guess the last Seq Number
|
|
else {
|
|
try {
|
|
$stmt = $conn->executeQuery('SELECT NumSeq, dateInsert FROM jo.sfr_data ORDER BY id DESC LIMIT 0,1');
|
|
$result = $stmt->fetch(\PDO::FETCH_OBJ);
|
|
} catch (\Doctrine\DBAL\DBALException $e) {
|
|
echo $e->getMessage();
|
|
}
|
|
$seq = $result->NumSeq;
|
|
|
|
// Insertion de moins de 20 Heures
|
|
$dateLimit = new DateTime();
|
|
$dateLimit->sub(new DateInterval('PT20H'));
|
|
$dateInsert = DateTime::createFromFormat('Y-m-d H:i:s', $result->dateInsert);
|
|
if ($dateLimit > $dateInsert) {
|
|
echo date('Y-m-d H:i:s')." : Aucun traitement à réaliser (Dernière date : ".$dateInsert->format('Y-m-d H:i:s').").\n";
|
|
exit;
|
|
}
|
|
}
|
|
|
|
$dateBegin = date('YmdHis');
|
|
|
|
// Génération des fichiers
|
|
if ($opts->cron) {
|
|
// Marquer les SIREN qui ne seront pas calculé
|
|
echo date('Y-m-d H:i:s')." - Marquage des SIREN imposssible à calculer\n";
|
|
$sql = "UPDATE jo.sfr_data SET error=2020 WHERE NumSeq='".$seq."' AND error=0 AND siren IN (SELECT siren FROM jo.scores_surveillance WHERE naf='' OR CJ IS NULL OR dateCrea IS NULL OR indiScoreDate='0000-00-00')";
|
|
$conn->executeQuery($sql);
|
|
}
|
|
|
|
// Recherche des siren valides ainsi que leur scores
|
|
$sql = 'SELECT sfr.siren, sfr.DateContrat, sfr.IR,' .
|
|
' surv.actif, surv.procol, surv.naf, surv.CJ, surv.dateImmat, surv.dateCrea, surv.effectif, surv.indiScore20, surv.indiScoreDate, surv.dateUpdate' .
|
|
' FROM jo.sfr_data AS sfr' .
|
|
' LEFT JOIN jo.scores_surveillance AS surv ON sfr.siren=surv.siren' .
|
|
' WHERE sfr.error=0 AND sfr.NumSeq=\''.$seq.'\'';
|
|
|
|
echo date('Y-m-d H:i:s')." - Recherche des SIREN valides avec leur score.\n";
|
|
$stmt = $conn->executeQuery($sql);
|
|
|
|
$nb = $stmt->rowCount();
|
|
if ($nb > 0) {
|
|
echo date('Y-m-d H:i:s')." - NbLignes=".$nb."\n";
|
|
|
|
if ($execId !== null) {
|
|
$execRef->total($execId, $nb);
|
|
}
|
|
|
|
$file = $fileOkOptionsOut['dir'] . DIRECTORY_SEPARATOR . $fileOkOptionsOut['name'] . $dateBegin . '.' . $fileOkOptionsOut['type'];
|
|
|
|
// Ouverture fichier RETOUR
|
|
$fp = fopen($file, 'w');
|
|
|
|
$sfrM = new Metier_Sfr_Scoring();
|
|
$sfrM->notCalculateInError = true;
|
|
|
|
// Header
|
|
if ($opts->debug) {
|
|
$keys = array_keys($sfrM->getValDebug());
|
|
$fileOkOptionsOut['columns'] = array_merge($fileOkOptionsOut['columns'], $keys);
|
|
$line = array();
|
|
foreach ($fileOkOptionsOut['columns'] as $i => $column) {
|
|
$line[] = array($seq, 'RCE');
|
|
}
|
|
} else {
|
|
$line = array($seq, 'RCE');
|
|
}
|
|
|
|
fputcsv($fp, $line, $fileOkOptionsOut['delimiter'], $fileOkOptionsOut['enclosure']);
|
|
|
|
$row = 0;
|
|
// Content
|
|
while ($item = $stmt->fetch(\PDO::FETCH_OBJ)) {
|
|
$row++;
|
|
echo date('Y-m-d H:i:s')." - Ligne $row : Siren=".$item->siren;
|
|
|
|
if ($execId !== null) {
|
|
$execRef->increment($execId, $row);
|
|
}
|
|
|
|
//Score non calculé
|
|
if ($item->indiScore20 === null) {
|
|
echo ", Non calculé";
|
|
$conn->update('jo.sfr_data', array('error' => 2020),
|
|
array("siren" => $item->siren, 'NumSeq' => $seq));
|
|
}
|
|
//Evaluation
|
|
else {
|
|
$sfrM = new Metier_Sfr_Scoring();
|
|
$sfrM->notCalculateInError = true;
|
|
|
|
//Set Values
|
|
$sfrM->setVal('ContratDate', $item->DateContrat);
|
|
$sfrM->setVal('IR', $item->IR);
|
|
$sfrM->setVal('NAF', $item->naf);
|
|
$sfrM->setVal('FJ', $item->CJ);
|
|
$sfrM->setVal('InseeActif', $item->actif);
|
|
$sfrM->setVal('Effectif', $item->effectif);
|
|
$sfrM->setVal('Indiscore', $item->indiScore20);
|
|
|
|
$sfrM->setVal('DateCalculIndiscore', $item->indiScoreDate);
|
|
$sfrM->setVal('DateUpdate', $item->dateUpdate);
|
|
$sfrM->setVal('DateCrea', $item->dateCrea);
|
|
$sfrM->setVal('DateImmat', $item->dateImmat);
|
|
$sfrM->setVal('SituationJuridique', $item->procol);
|
|
|
|
//Evaluate
|
|
if ($sfrM->evaluate($item->siren)) {
|
|
$values = array();
|
|
$values['siren'] = str_pad($item->siren, 9, '0', STR_PAD_LEFT);
|
|
$values['idVOR'] = $sfrM->getIndicateur();
|
|
$values['commentaire'] = $sfrM->getComment();
|
|
$values['PO'] = $sfrM->getPo();
|
|
|
|
if ($opts->debug) {
|
|
$valuesDebug = $sfrM->getValDebug();
|
|
$values = array_merge($values, $valuesDebug);
|
|
}
|
|
|
|
echo ", ID=".$values['idVOR'].", commentaire=".$values['commentaire'];
|
|
|
|
//Ecrire fichier RETOUR
|
|
$line = array();
|
|
foreach ($fileOkOptionsOut['columns'] as $i => $column) {
|
|
$line[] = $values[$column];
|
|
}
|
|
fputcsv($fp, $line, $fileOkOptionsOut['delimiter'], $fileOkOptionsOut['enclosure']);
|
|
} else {
|
|
echo ", Pas de calcul";
|
|
$conn->update('jo.sfr_data', array('error' => 2020),
|
|
array("siren" => $item->siren, 'NumSeq' => $seq));
|
|
}
|
|
}
|
|
echo "\n";
|
|
}
|
|
|
|
fclose($fp);
|
|
}
|
|
if ($fileOkOptionsOut['encoding']) {
|
|
echo "Encodage du fichier\n";
|
|
passthru("iconv -f UTF-8 -t ISO-8859-15 ".$file." -o ".$file.".enc");
|
|
passthru("cp -fv ".$file.".enc ".$file);
|
|
}
|
|
|
|
$nbLines = $row;
|
|
|
|
if ($opts->cron) {
|
|
$dateEnd = date('YmdHis');
|
|
$conn->insert('sdv1.flux_fileout', array(
|
|
'client' => $client,
|
|
'name' => $prestation,
|
|
'nbLines' => $nbLines,
|
|
'dateBegin' => $dateBegin,
|
|
'dateEnd' => $dateEnd,
|
|
'fileOut' => basename($file),
|
|
'depotType' => $typeDepot,
|
|
'depotDate' => '0000-00-00 00:00:00',
|
|
));
|
|
// Ecrire la date d'execution dans flux_filein
|
|
$conn->update('sdv1.flux_filein', array('dateExecute' => $dateEnd),
|
|
array('id' => $p->id));
|
|
}
|
|
|
|
if ($execId !== null) {
|
|
$execRef->end($execId);
|
|
}
|
|
|
|
// Recherche des siren en erreur
|
|
$sql = 'SELECT sfr.siren, sfr.error' .
|
|
' FROM jo.sfr_data AS sfr' .
|
|
' WHERE sfr.error!=0 AND sfr.NumSeq=\''.$seq.'\'';
|
|
|
|
echo date('Y-m-d H:i:s')." - Recherche des SIREN en erreur.\n";
|
|
$stmt = $conn->executeQuery($sql);
|
|
|
|
$nb = $stmt->rowCount();
|
|
if ($nb > 0) {
|
|
echo date('Y-m-d H:i:s')." - NbLignes=".$nb."\n";
|
|
|
|
$file = $fileErrorOptionsOut['dir'] . DIRECTORY_SEPARATOR . $fileErrorOptionsOut['name'] . $dateBegin . '.' . $fileErrorOptionsOut['type'];
|
|
|
|
// Ouverture fichier ERREUR
|
|
$fp = fopen($file, 'w');
|
|
|
|
// Header
|
|
$line = array($seq, 'RCE');
|
|
fputcsv($fp, $line, $fileErrorOptionsOut['delimiter'], $fileErrorOptionsOut['enclosure']);
|
|
|
|
$row = 0;
|
|
// Content
|
|
while ($item = $stmt->fetch(\PDO::FETCH_OBJ)) {
|
|
$row++;
|
|
echo date('Y-m-d H:i:s')." - Ligne $row : Siren=".$item->siren;
|
|
|
|
$values = array(
|
|
'siren' => str_pad($item->siren, 9, '0', STR_PAD_LEFT),
|
|
'code' => $item->error,
|
|
);
|
|
|
|
//Ecrire fichier ERREUR
|
|
$line = array();
|
|
foreach ($fileErrorOptionsOut['columns'] as $i => $column) {
|
|
$line[] = $values[$column];
|
|
}
|
|
fputcsv($fp, $line, $fileErrorOptionsOut['delimiter'], $fileErrorOptionsOut['enclosure']);
|
|
|
|
echo "\n";
|
|
}
|
|
fclose($fp);
|
|
if ($fileErrorOptionsOut['encoding']) {
|
|
passthru("iconv -f UTF-8 -t ISO-8859-15 ".$file." -o ".$file.".enc");
|
|
passthru("cp -fv ".$file.".enc ".$file);
|
|
}
|
|
|
|
$nbLines = $row;
|
|
echo date('Y-m-d H:i:s')." - Nb Lignes Traitées : ".$nbLines."\n";
|
|
|
|
if ($opts->cron) {
|
|
$dateEnd = date('YmdHis');
|
|
$conn->insert('sdv1.flux_fileout', array(
|
|
'client' => $client,
|
|
'name' => $prestation,
|
|
'nbLines' => $nbLines,
|
|
'dateBegin' => $dateBegin,
|
|
'dateEnd' => $dateEnd,
|
|
'fileOut' => basename($file),
|
|
'depotType' => $typeDepot,
|
|
'depotDate' => '0000-00-00 00:00:00',
|
|
));
|
|
// Ecrire la date d'execution dans flux_filein
|
|
$conn->update('sdv1.flux_filein', array('dateExecute' => $dateEnd),
|
|
array('id' => $p->id));
|
|
}
|
|
}
|
|
|
|
//Extraction du fichier PORTEFEUILLE - @todo
|
|
$sql = 'SELECT sfr.siren,' .
|
|
' surv.actif, surv.procol, surv.indiScore20, surv.encours, surv.indiScoreDate,' .
|
|
' surv.dateBilan, surv.indiScore20Pre, surv.encoursPre, surv.indiScoreDatePre, surv.sourceModif,' .
|
|
' surv.scoreSolv, surv.scoreSolvPre, surv.scoreDir, surv.scoreDirPre, surv.scoreConf, surv.scoreConfPre,' .
|
|
' surv.CJ, surv.naf, surv.effectif, surv.dateUpdate' .
|
|
' FROM jo.sfr_data AS sfr, jo.scores_surveillance AS surv' .
|
|
' WHERE sfr.siren=surv.siren AND sfr.error=0 AND sfr.NumSeq=\''.$seq.'\' AND indiScore20 IS NOT NULL';
|
|
|
|
echo date('Y-m-d H:i:s')." - Extraction du portefeuille.\n";
|
|
$stmt = $conn->executeQuery($sql);
|
|
|
|
$nb = $stmt->rowCount();
|
|
if ($nb > 0) {
|
|
echo date('Y-m-d H:i:s')." - NbLignes=".$nb."\n";
|
|
|
|
$file = $filePortefeuilleOptionsOut['dir'] . DIRECTORY_SEPARATOR . $filePortefeuilleOptionsOut['name'] . $dateBegin . '.' . $filePortefeuilleOptionsOut['type'];
|
|
|
|
// Ouverture fichier PORTEFEUILLE
|
|
$fp = fopen($file, 'w');
|
|
|
|
// Header
|
|
fputcsv($fp, $filePortefeuilleOptionsOut['columns'], $filePortefeuilleOptionsOut['delimiter'], $filePortefeuilleOptionsOut['enclosure']);
|
|
|
|
$row = 0;
|
|
// Content
|
|
while ($item = $stmt->fetch(\PDO::FETCH_OBJ)) {
|
|
$row++;
|
|
|
|
$values = array(
|
|
'loginUti' => 'AUTO',
|
|
'source' => 'score',
|
|
'email' => 'AUTO',
|
|
'siren' => str_pad($item->siren, 9, '0', STR_PAD_LEFT),
|
|
'nic' => '00000',
|
|
'ref' => 'AUTO',
|
|
'dateAjout' => '',
|
|
'rs' => '',
|
|
'cp' => '',
|
|
'ville' => '',
|
|
'dateDerEnvoi' => '',
|
|
'encoursClient' => '',
|
|
'actif' => $item->actif,
|
|
'procol' => $item->procol,
|
|
'indiScore20' => $item->indiScore20,
|
|
'encours' => $item->encours,
|
|
'indiScoreDate' => $item->indiScoreDate,
|
|
'dateBilan' => ($item->dateBilan == '0000-00-00 00:00:00') ? '' : $item->dateBilan,
|
|
'indiScore20Pre' => $item->indiScore20Pre,
|
|
'encoursPre' => $item->encoursPre,
|
|
'indiScoreDatePre' => ($item->indiScoreDatePre == '0000-00-00 00:00:00') ? '' : $item->indiScoreDatePre,
|
|
'sourceModif' => $item->sourceModif,
|
|
'scoreSolv' => $item->scoreSolv,
|
|
'scoreSolvPre' => $item->scoreSolvPre,
|
|
'scoreDir' => $item->scoreDir,
|
|
'scoreDirPre' => $item->scoreDirPre,
|
|
'scoreConf' => $item->scoreConf,
|
|
'scoreConfPre' => $item->scoreConfPre,
|
|
'cj' => $item->CJ,
|
|
'capital' => '',
|
|
'capitalDev' => '',
|
|
'ape_entrep' => $item->naf,
|
|
'tca' => '',
|
|
'teff_entrep' => $item->effectif,
|
|
'dateUpdate' => $item->dateUpdate,
|
|
);
|
|
|
|
//Ecrire fichier POTEFEUILLE
|
|
$line = array();
|
|
foreach ($filePortefeuilleOptionsOut['columns'] as $i => $column) {
|
|
$line[] = $values[$column];
|
|
}
|
|
fputcsv($fp, $line, $filePortefeuilleOptionsOut['delimiter'], $filePortefeuilleOptionsOut['enclosure']);
|
|
}
|
|
|
|
fclose($fp);
|
|
if ($filePortefeuilleOptionsOut['encoding']) {
|
|
passthru("iconv -f UTF-8 -t ISO-8859-15 ".$file." -o ".$file.".enc");
|
|
passthru("cp -fv ".$file.".enc ".$file);
|
|
}
|
|
|
|
$nbLines = $row;
|
|
echo date('Y-m-d H:i:s')." - Nb Lignes Traitées : ".$nbLines."\n";
|
|
|
|
if ($opts->cron) {
|
|
$dateEnd = date('YmdHis');
|
|
$conn->insert('sdv1.flux_fileout', array(
|
|
'client' => $client,
|
|
'name' => $prestation,
|
|
'nbLines' => $nbLines,
|
|
'dateBegin' => $dateBegin,
|
|
'dateEnd' => $dateEnd,
|
|
'fileOut' => basename($file),
|
|
'depotType' => $typeDepot,
|
|
'depotDate' => '0000-00-00 00:00:00',
|
|
));
|
|
// Ecrire la date d'execution dans flux_filein
|
|
$conn->update('sdv1.flux_filein', array('dateExecute' => $dateEnd),
|
|
array('id' => $p->id));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
*
|
|
* @param array $values
|
|
* @param string $seq
|
|
* @param string $debug
|
|
* @return array
|
|
*/
|
|
function execInternal($values, $seq, $debug = false)
|
|
{
|
|
$error = 0;
|
|
|
|
$siren = $values['siren'];
|
|
|
|
echo "$siren";
|
|
|
|
$classInsee = new Metier_Insee_MInsee();
|
|
|
|
$values['code'] = '';
|
|
//Siren valide - 1010
|
|
if (!$classInsee->valideSiren($siren)) {
|
|
$error = 1;
|
|
$code = 'error';
|
|
$values['code'] = '1010';
|
|
echo " - Erreur 1010.";
|
|
}
|
|
//Siren existant - 1020
|
|
elseif (!$classInsee->sirenExiste($siren)) {
|
|
$error = 1;
|
|
$code = 'error';
|
|
$values['code'] = '1020';
|
|
echo " - Erreur 1020.";
|
|
}
|
|
|
|
//Date incorrecte - 2010
|
|
try {
|
|
$dateContrat = DateTime::createFromFormat('Ymd', $values['dateContrat']);
|
|
} catch (Exception $e) {
|
|
if ($values['dateContrat']!='') {
|
|
$error = 1;
|
|
$code = 'error';
|
|
$values['code'] = '2010';
|
|
echo " - Erreur 2010 ";
|
|
}
|
|
}
|
|
|
|
if ($error == 0) {
|
|
//Calculate data
|
|
$sfrM = new Metier_Sfr_Scoring();
|
|
$sfrM->notCalculateInError = false;
|
|
|
|
//Set Values
|
|
$sfrM->setVal('ContratDate', $values['dateContrat']);
|
|
$sfrM->setVal('IR', $values['ir']);
|
|
|
|
//Evaluate
|
|
if ($sfrM->evaluate($siren)) {
|
|
$values['idVOR'] = $sfrM->getIndicateur();
|
|
$values['commentaire'] = $sfrM->getComment();
|
|
$values['PO'] = $sfrM->getPo();
|
|
|
|
$valuesDebug = $sfrM->getValDebug();
|
|
if ($debug) {
|
|
$values = array_merge($values, $valuesDebug);
|
|
}
|
|
|
|
$code = 'ok';
|
|
|
|
echo " - VOR=".$values['idVOR']." , commentaire=".$values['commentaire']." , PO=".$values['PO'];
|
|
} else {
|
|
$error = 1;
|
|
$code = 'error';
|
|
$values['code'] = '2020';
|
|
echo " - Not calculated ";
|
|
}
|
|
}
|
|
|
|
echo PHP_EOL;
|
|
|
|
return array(
|
|
'values' => $values,
|
|
'code' => $code,
|
|
);
|
|
}
|
|
|
|
|
|
/**
|
|
*
|
|
* @param string $file
|
|
* @param array $fileOptionsIn
|
|
* @param array $filesOptionsOut
|
|
* @param boolean $debug
|
|
* @param boolean $resume
|
|
* @return array
|
|
*/
|
|
function execFileIn($file, $fileOptionsIn, $filesOptionsOut = array(), $debug = false, $resume = false)
|
|
{
|
|
global $dateBegin;
|
|
|
|
//Set the input file path
|
|
$filepathIn = $file;
|
|
|
|
//Open output file path
|
|
foreach ($filesOptionsOut as $code => $file) {
|
|
${'fp'.$code} = fopen($file['dir'] . DIRECTORY_SEPARATOR . $file['name'] . $dateBegin . '.' . $file['type'], 'w');
|
|
}
|
|
|
|
//Read file
|
|
if (file_exists($filepathIn)) {
|
|
if (($handle = fopen($filepathIn, '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) {
|
|
$filesOptionsOut['error']['header'] = array();
|
|
$filesOptionsOut['ok']['header'] = array();
|
|
} else {
|
|
$filesOptionsOut['error']['header'] = $header;
|
|
$filesOptionsOut['ok']['header'] = $header;
|
|
}
|
|
|
|
if ($resume) {
|
|
fputcsv(${'fp'.$codeRetour}, $filesOptionsOut['ok']['line'][0], $filesOptionsOut['ok']['delimiter'], $filesOptionsOut['ok']['enclosure']);
|
|
}
|
|
}
|
|
|
|
//Content
|
|
else {
|
|
|
|
//Set values from file
|
|
$values = array();
|
|
foreach ($fileOptionsIn['columns'] as $i => $column) {
|
|
$values[$column] = $data[$i];
|
|
}
|
|
|
|
$isResume = false;
|
|
|
|
if ($resume) {
|
|
foreach ($filesOptionsOut['ok']['line'] as $line) {
|
|
if ($line[0] == $data[0]) {
|
|
fputcsv(${'fp'.$codeRetour}, $line, $filesOptionsOut['ok']['delimiter'], $filesOptionsOut['ok']['enclosure']);
|
|
$isResume = true;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!$isResume) {
|
|
|
|
//Exec the process
|
|
$valuesClient = execInternal($values, $header['idDemande'], true);
|
|
|
|
//Format output
|
|
$codeRetour = $valuesClient['code'];
|
|
//$filesOptionsOut[$codeRetour]['line'][] = $valuesClient['values'];
|
|
if ($debug) {
|
|
$filesOptionsOut[$codeRetour]['columns'] = array_keys($valuesClient['values']);
|
|
}
|
|
|
|
if ($row == 2) {
|
|
foreach ($filesOptionsOut as $code => $file) {
|
|
$line = array();
|
|
//Dynamic Header
|
|
if (count($file['header'])>0) {
|
|
foreach ($file['header'] as $i => $column) {
|
|
$line[] = $column;
|
|
}
|
|
}
|
|
//Static Header
|
|
else {
|
|
foreach ($file['columns'] as $i => $column) {
|
|
$line[] = $column;
|
|
}
|
|
}
|
|
fputcsv(${'fp'.$code}, $line, $filesOptionsOut[$code]['delimiter'], $filesOptionsOut[$code]['enclosure']);
|
|
}
|
|
}
|
|
|
|
//Write the line following the return code
|
|
$line = array();
|
|
foreach ($filesOptionsOut[$codeRetour]['columns'] as $i => $column) {
|
|
$line[] = $valuesClient['values'][$column];
|
|
}
|
|
fputcsv(${'fp'.$codeRetour}, $line, $filesOptionsOut[$codeRetour]['delimiter'], $filesOptionsOut[$codeRetour]['enclosure']);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
fclose($handle);
|
|
|
|
foreach ($filesOptionsOut as $code => $file) {
|
|
fclose(${'fp'.$code});
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
*
|
|
* @param string $filepathIn
|
|
* @param array $fileOptionsIn
|
|
* @return boolean
|
|
*/
|
|
function checkFile($filepathIn, $fileOptionsIn)
|
|
{
|
|
if (file_exists($filepathIn)) {
|
|
if (($handle = fopen($filepathIn, 'r')) !== false) {
|
|
$row = 0;
|
|
while (($data = fgetcsv($handle, 0, $fileOptionsIn['delimiter'], $fileOptionsIn['enclosure'])) !== false) {
|
|
$row++;
|
|
|
|
//Header
|
|
if (count($fileOptionsIn['header']) > 0 && $row == 1) {
|
|
if (count($fileOptionsIn['header']) != count($data)) {
|
|
return false;
|
|
}
|
|
}
|
|
//Content
|
|
else {
|
|
if (count($fileOptionsIn['columns']) != count($data)) {
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
fclose($handle);
|
|
|
|
return true;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Load in database
|
|
* @param string $file
|
|
* @param array $fileOptionsIn
|
|
* @param array $filesOptionsOut
|
|
* @param boolean $debug
|
|
* @param boolean $resume
|
|
* @return array
|
|
*/
|
|
function execDbIn($file, $fileOptionsIn, $debug = false)
|
|
{
|
|
//Set the input file path
|
|
//$filepathIn = $fileOptionsIn['dir'] . DIRECTORY_SEPARATOR . $file;
|
|
$filepathIn = $file;
|
|
|
|
//Read file
|
|
if (file_exists($filepathIn)) {
|
|
if (($handle = fopen($filepathIn, 'r')) !== false) {
|
|
$row = 0;
|
|
while (($data = fgetcsv($handle, 0, $fileOptionsIn['delimiter'], $fileOptionsIn['enclosure'])) !== false) {
|
|
$row++;
|
|
|
|
echo date('Y-m-d H:i:s')." - 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) {
|
|
$filesOptionsOut['error']['header'] = array();
|
|
$filesOptionsOut['ok']['header'] = array();
|
|
} else {
|
|
$filesOptionsOut['error']['header'] = $header;
|
|
$filesOptionsOut['ok']['header'] = $header;
|
|
}
|
|
}
|
|
|
|
//Content
|
|
else {
|
|
|
|
//Set values from file
|
|
$values = array();
|
|
foreach ($fileOptionsIn['columns'] as $i => $column) {
|
|
$values[$column] = $data[$i];
|
|
}
|
|
|
|
//Exec the process
|
|
$values = execDbInternal($values);
|
|
$conn = Zend_Registry::get('doctrine');
|
|
$conn->insert('jo.sfr_data', array(
|
|
'NumSeq' => $header['idDemande'],
|
|
'siren' => $values['siren'],
|
|
'NbLignes' => $values['nbLignes'],
|
|
'NbContrats' => $values['nbContrats'],
|
|
'DateContrat' => $values['dateContrat'],
|
|
'IR' => $values['ir'],
|
|
'IdVOR' => '',
|
|
'comment' => '',
|
|
'PO' => 0,
|
|
'debug' => '',
|
|
'error' => $values['code'],
|
|
));
|
|
}
|
|
}
|
|
}
|
|
fclose($handle);
|
|
|
|
return $header['idDemande'];
|
|
}
|
|
}
|
|
|
|
|
|
function execDbInternal($values, $debug = false)
|
|
{
|
|
$error = 0;
|
|
|
|
$siren = $values['siren'];
|
|
|
|
echo "$siren";
|
|
|
|
$classInsee = new Metier_Insee_MInsee();
|
|
|
|
$values['code'] = '';
|
|
|
|
//Siren valide - 1010
|
|
if (!$classInsee->valideSiren($siren)) {
|
|
$error = 1;
|
|
$code = 'error';
|
|
$values['code'] = '1010';
|
|
echo " Erreur 1010.";
|
|
}
|
|
|
|
//Siren existant - 1020
|
|
/*else if ( !$classInsee->sirenExiste($siren) ) {
|
|
$error = 1;
|
|
$code = 'error';
|
|
$values['code'] = '1020';
|
|
echo " - Erreur 1020.";
|
|
}*/
|
|
|
|
//Date incorrecte - 2010
|
|
try {
|
|
$dateContrat = DateTime::createFromFormat('Ymd', $values['dateContrat']);
|
|
} catch (Exception $e) {
|
|
if ($values['dateContrat']!='') {
|
|
$error = 1;
|
|
$code = 'error';
|
|
$values['code'] = '2010';
|
|
echo " - Erreur 2010 ";
|
|
}
|
|
}
|
|
|
|
echo PHP_EOL;
|
|
|
|
return $values;
|
|
}
|