scores/webservice
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity
webservice/batch/getPieces.php
Michael RICOIS 74f49efe33 Ajout du script getPieces
2010-12-06 17:13:56 +00:00

277 lines
12 KiB
PHP
Raw Blame History

#!/usr/bin/php
<?php
ini_set('memory_limit', '1024M');
//Durée maximale du script
$dureeMaxi=300; // secondes (soit 5 minutes)
//Interval entre chaque tentative de récupération des Kbis sur le FTP
$dureeInterval=5; // secondes
set_time_limit(($dureeMaxi+10));
error_reporting(E_ALL & ~E_NOTICE);
// 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(),
)));
require_once realpath(dirname(__FILE__)).'/../config/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 'Metier/insee/classMInsee.php';
require_once 'Metier/partenaires/classMGreffes.php';
require_once 'Metier/partenaires/classMBilans.php';
$strInfoScript='Usage : '.basename($argv[0]). " SIREN [PIECE='kbis'] [TYPE=''] [VISU=1] [COURRIER=0] [REF='']
Récupération d'une pièce (kbis par défaut) pour un SIREN.
[PIECE]
kbis Seul pièce possible pour l'instant
";
$siren=0;
$piece='kbis';
$type='';
$visu=1;
$courrier=0;
$ref='';
$heureDemande = date('Hi');
$iInsee = new MInsee();
for ($i=1; isset($argv[$i]); $i++) {
if (substr($argv[$i],0,1)=='-') {
switch (strtolower(substr($argv[$i],1,1))) {
case '-':
case '?':
die($strInfoScript);
break;
default:
die('Option '. $argv[$i] . ' inconnue !'.EOL);
break;
}
}
elseif ($i==1) $siren=$argv[$i]*1;
elseif ($i==2) $piece=$argv[$i];
elseif ($i==3) $type=$argv[$i];
elseif ($i==4) $visu=$argv[$i];
elseif ($i==5) $courrier=$argv[$i];
elseif ($i==6) $ref=$argv[$i];
}
function kbisLog($siren,$piece,$message,$typeLog='DEBUG') {
global $heureDemande;
if ($typeLog=='DEBUG') {
$fp = fopen("./kbis.log", 'a');
fwrite($fp, date('Y-m-d H:i:s')." - $siren ($heureDemande) $piece $message".EOL);
fclose($fp);
} else {
$fp = fopen("./kbis-error.log", 'a');
fwrite($fp, date('Y-m-d H:i:s')." - $siren ($heureDemande) $piece $message".EOL);
fclose($fp);
}
}
if ($siren<100 || !$iInsee->valideSiren($siren)) {
kbisLog($siren, $piece, "IN : Siren $siren Invalide !");
} else {
switch (strlen($siren)) {
case 1: $siren='00000000'.$siren; break;
case 2: $siren='0000000'.$siren; break;
case 3: $siren='000000'.$siren; break;
case 4: $siren='00000'.$siren; break;
case 5: $siren='0000'.$siren; break;
case 6: $siren='000'.$siren; break;
case 7: $siren='00'.$siren; break;
case 8: $siren='0'.$siren; break;
}
}
if ($piece<>'kbis') {
kbisLog($siren, $piece, "IN : Piece $piece inexistante !");
}
// Ouverture de quelques fichiers pour lecture
$fp = fopen("/tmp/$piece-$siren", 'w+');
fwrite($fp, "$siren;$piece;$type;$visu;$courrier;$ref");
rewind($fp);
// Mise en place d'une connexion basique
$conn_id = ftp_connect('192.168.3.4');
// Identification avec un nom d'utilisateur et un mot de passe
$login_result = ftp_login($conn_id, 'kbis', 'kbis');
$tabListInit=ftp_nlist($conn_id, 'pdf/');
$nbList=count($tabListInit);
$nbEssais=0; // Nombre de tentatives de récupération
// Tente de charger le fichier $file
if (!ftp_fput($conn_id, "in/$piece-$siren.txt", $fp, FTP_ASCII))
$erreur=true;
fclose($fp);
kbisLog($siren, $piece, "IN : Fichier déposé en commande sur le FTP");
while (true) {
$nbEssais++;
sleep($dureeInterval);
$tabList=ftp_nlist($conn_id, 'pdf/');
if (count($tabList)>$nbList) {
kbisLog($siren, $piece, "WAIT : Essai $nbEssais, des nouveaux fichiers sont disponibles sur le FTP !");
// On vérifie que le K-Bis récupéré est bien celui commandé !!!
sleep($dureeInterval); // Laisse le temps au serveur de K-Bis de finir le fichier PDF !!!
$tabNom=array_diff($tabList,$tabListInit);
ftp_chdir($conn_id, 'pdf');
$ficDist=str_replace('pdf/', '', reset($tabNom));
if (!ftp_get($conn_id,"/tmp/$piece-$siren.pdf", $ficDist, FTP_BINARY)) {
// Problème FTP --> STOP
kbisLog($siren, $piece, "OUT : Problème FTP");
$erreur=true;
die();
}
shell_exec("/var/www/cgi-bin/pdftotext /tmp/$piece-$siren.pdf /tmp/$piece-$siren.txt");
$str=file_get_contents("/tmp/$piece-$siren.txt");
//if (preg_match("/((?:[0-9]{9,9})|(?:[0-9]{3,3} [0-9]{3,3} [0-9]{3,3})|(?:[0-9]{3,3}\.[0-9]{3,3}\.[0-9]{3,3})|(?:[0-9]{3,3}-[0-9]{3,3}-[0-9]{3,3}))/", $str, $matches)) {
if (preg_match("/((?:\s[0-9]{9,9})|(?:\s[0-9]{3,3}\s[0-9]{3,3}\s[0-9]{3,3})|(?:\s[0-9]{3,3}\.[0-9]{3,3}\.[0-9]{3,3})|(?:\s[0-9]{3,3}-[0-9]{3,3}-[0-9]{3,3}))/U", $str, $matches)) {
$sirenLu=trim(str_replace(' ','', $matches[1]));
if ($sirenLu==$siren) {
kbisLog($siren, $piece, "OUT : Le nouveau fichier est celui attendu ($sirenLu=$siren)");
copy("/tmp/$piece-$siren.pdf", DOC_WEB_LOCAL."pdf/$piece-$siren.pdf");
ftp_chdir($conn_id, '/html');
$tabListHtml=ftp_nlist($conn_id, $siren.'*');
foreach ($tabListHtml as $fichierHtml) {
$ficDist2=str_replace('html/', '', $fichierHtml);
$buff = ftp_mdtm($conn_id, $ficDist2);
if ($buff!=-1 && date("Ymd", $buff)==date("Ymd")) {
ftp_get($conn_id,"/tmp/$piece-$siren.html", $ficDist2, FTP_ASCII);
$strKbis=file_get_contents("/tmp/$piece-$siren.html");
// Log provisoire
$fp = fopen("/tmp/$piece-commande.log", 'a+');
fwrite($fp, date('Y/m/d H:i:s')." - $siren - Nb fichier HTML : ".count($tabListHtml).print_r($tabListHtml));
fclose($fp);
/*
if (preg_match('/<TD align=left colSpan=2><B>IDENTIFICATION <\/B>(.*)<TD colSpan=2><B>RENSEIGNEMENTS RELATIFS A LA PERSONNE MORALE<\/B>/Uis', $strKbis, $matches))
{
$htmlId=$matches[1];
if (preg_match('/<TD (?:.*) vAlign=top align=left>Dénomination sociale \:<\/TD>(.*)<\/TD><\/TR>/Uis', $htmlId, $matches))
$rs=trim(strip_tags($matches[1]));
if (preg_match('/<TD (?:.*) italic" vAlign=top align=left>Numéro RCS \:<\/TD>(.*)<\/TD><\/TR>/Uis', $htmlId, $matches))
$rcs=trim(strip_tags($matches[1]));
//if (preg_match('/<TD style="FONT-STYLE\: italic" vAlign=top align=left>Date immatriculation \:<\/TD>(.*)<\/TD><\/TR>/Uis', $htmlId, $matches))
// $dateImmat=trim(strip_tags($matches[1]));
}
if (preg_match('/<TD align=left colSpan=2><B>ADMINISTRATION<\/B>(.*)<TD align=left colSpan=2><B>RENSEIGNEMENTS RELATIFS A L\'ACTIVITE COMMERCIALE<\/B>/Uis', $strKbis, $matches))
{
// Les dirigeants provenants de toute autre source sont marqués inactifs
$ret=$iDb->query("UPDATE rncs_dirigeants SET actif=0 WHERE source<>'gre' AND siren=$siren");
$tabDirs=array();
$htmlAd=$matches[1];
$tabTmp=explode('<HR SIZE=1>', $htmlAd);
foreach ($tabTmp as $i=>$htmlDir) {
if ($i==0) continue;
$tabDir=array();
if (preg_match('/<TD (?:.*) vAlign=top>(.*)<\/TD>/Uis', $htmlDir, $matches))
$tabDir['fonction']=trim(strip_tags($matches[1]));
if (preg_match('/<TBODY>(?:.*)<TR>(?:.*)<TD>(.*)<\/TD><\/TR>/Uis', $htmlDir, $matches))
$tabDir['nom']=trim(strip_tags($matches[1]));
if (preg_match('/<TD>\((.*)\)<\/TD><\/TR>/Uis', $htmlDir, $matches))
$tabDir['siren']=trim(strip_tags($matches[1]));
if (preg_match('/<TD>(.*)<\/TD><\/TR>(?:.*)<TR>(?:.*)<TD>représentée par <\/TD><\/TR>(?:.*)<TD>(.*)<\/TD><\/TR>/Uis', $htmlDir, $matches)) {
//$tabDir['rs']=trim(strip_tags($matches[1]));
$tabDir['rep']=trim(strip_tags($matches[2]));
}
if (preg_match('/<TD>né\(e\)(.*)<TR>/Uis', $htmlDir, $matches))
$tabDir['naiss']=trim(strip_tags($matches[1]));
if (preg_match('/<TD>de nationalité (.*)<\/TD><\/TR></Uis', $htmlDir, $matches))
$tabDir['natio']=trim(strip_tags($matches[1]));
if (preg_match('/<TD>demeurant (.*)<\/TD><\/TR></Uis', $htmlDir, $matches))
$tabDir['adresse']=trim(strip_tags($matches[1]));
//$tabDir['html']=$htmlDir;
$tabDirs[]=$tabDir;
$iDb=new WDB();
$nom=$tabDir['nom'];
$rs2=$prenom=$civ='';
if ($tabDir['rep']<>'') {
$nom=$tabDir['rep'];
$rs2=$tabDir['nom'];
}
if (preg_match('/( MONSIEUR&nbsp;| MADAME&nbsp;| MADEMOISELLE&nbsp;)/i', ' '.$nom,$matches2)) {
switch (trim($matches2[1])) {
case 'MONSIEUR&nbsp;': $civ='M'; break;
case 'MADAME&nbsp;': $civ='MME'; break;
case 'MADEMOISELLE&nbsp;': $civ='MLLE'; break;
}
$nom=preg_replace('/( MONSIEUR&nbsp;| MADAME&nbsp;| MADEMOISELLE&nbsp;)/i','',' '.$nom);
}
$tabTmp=explode('&nbsp;', $nom);
$nom=trim(strtr($tabTmp[0],array('&amp;'=>'&')));
$prenom=trim($tabTmp[1]);
if (preg_match('/(\d\d) (janvier|f.vrier|mars|avril|mai|juin|juillet|ao.t|septembre|octobre|novembre|d.cembre) (\d\d\d\d) (.*)/i', $tabDir['naiss'],$matches2))
{
$j=trim($matches2[1]);
$m=trim($matches2[2]);
$a=trim($matches2[3]);
$dateNaiss=Wdate::dateT('dMY', 'Y-m-d', $j.$m.$a);
$lieuNaiss=preg_replace('/^à /','', trim(strtr($matches2[4],array('&nbsp;'=>' ', '&amp;'=>'&'))));
}
$iDb->insert('rncs_dirigeants',
array( 'siren' => $siren,
'raisonSociale' => $rs,
'civilite' => $civ,
'dirSiren' => substr(trim(str_replace(' ','', $tabDir['siren'])),0,9),
'dirRS' => $rs2,
'nom' => $nom,
'prenom' => $prenom,
'naissance_nom' => '',
'naissance_date'=> $dateNaiss,
'naissance_lieu'=> $lieuNaiss,
'fonction_code' => 0000,
'fonction_lib' => $tabDir['fonction'],
'nat' => preg_replace('/^de nationalité /','', trim(strtr($tabDir['natio'],array('&nbsp;'=>' ', '&amp;'=>'&')))),
'adresse' => preg_replace('/^demeurant /','', trim(strtr($tabDir['adresse'],array('&nbsp;'=>' ', '&amp;'=>'&')))),
'actif' => 1,
'dateInsert' => date('YmdHis'),
'source' => 'gre',
), true);
}
}
//debugLog('I',"Liste des dirigeants du kbis :".print_r($tabDirs),__LINE__,__FILE__, __FUNCTION__, __CLASS__);*/
}
}
break;
} else
kbisLog($siren, $piece, "OUT : Le nouveau fichier n'est pas celui attendu ($sirenLu<>$siren)");
}
} else {
kbisLog($siren, $piece, "WAIT : Essai $nbEssais, aucun nouveau fichier disponible sur le FTP !");
if (($nbEssais*$dureeInterval)>$dureeMaxi) {
kbisLog($siren, $piece, "OUT : Essai $nbEssais, ERREUR aucun kbis trouvé en $dureeMaxi secondes sur le FTP !");
kbisLog($siren, $piece, "OUT : Essai $nbEssais, ERREUR aucun kbis trouvé en $dureeMaxi secondes sur le FTP !", 'ERROR');
$message="ERREUR lors de la récupération du '$piece' pour le siren $siren (aucun PDF sur le serveur FTP au bout de $nbEssais essais en $dureeMaxi secondes)".EOL;
$message.=EOL."Si vous obtenez régulièrement ce message avec des siren différents, il faut probablement relancer la passerelle de commandes de pièces officielles.".EOL;
sendMail('production@scores-decisions.com', 'ylenaour@scores-decisions.com,mricois@scores-decisions.com', 'ERREUR KBIS entre la passerelle et le WebService', $message);
die();
}
}
}
// Fermeture de la connexion et du pointeur de fichier
ftp_close($conn_id);
kbisLog($siren, $piece, "OUT : Fin normale de la récupération du kbis".EOL);
die();
Reference in New Issue View Git Blame Copy Permalink