webservice/batch/getPieces.php

#!/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);
	}
}

function checkSiren($siren, $str)
{
	$pattern = "/((?:\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";
	if (preg_match($pattern, $str, $matches))
	{
		$sirenLu = trim(str_replace(' ','', $matches[1]));
		if ($sirenLu == $siren)
		{
			return $sirenLu;
		}
	}
	return false;
}

if ($siren<100 || !$iInsee->valideSiren($siren)) {
	kbisLog($siren, $piece, "IN : Siren $siren Invalide !");
	exit;
} 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 !");
	exit;
}

define('FORMAT', 'PDF'); //HTML ou PDF
define('PKBIS_HOST', '192.168.3.4');
define('PKBIS_USER', 'kbis');
define('PKBIS_PASS', 'kbis');
define('PDFTOTEXT', '/usr/bin/pdftotext'); // Vérifier que l'executable existe
define('WKHTMLTOPDF', '/usr/bin/wkhtmltopdf'); // Vérifier que l'executable existe....
/*
Principe de fonctionnement

- Vérifier en local que le fichier n'existe pas déjà et qu'il a moins d'un jour

- Envoi dun fichier portant le nom de $pieces-$siren.txt sur le ftp pour le
	début de la récupération du kbis

- Vérifier sur le FTP que le fichier est disponible
	Comparaison avec un ftp_nlist sur dossier /pdf ou /html

- Vérifier la date du fichier HTML (qui est le fichier source) afin d'écrire dans les logs

- Vérifier que le fichier PDF ou HTML correspond bien au SIREN demandé
	Pour le fichier PDF, transformation avec pdftotext, et on parcours le fichier
	texte à la recherche du SIREN
	Pour le fichier HTML, on parcours le fichier à la recherche du siren et
	on le tranforme en PDF grâce à wkhtmltopdf
*/

$kbisLocalPDF  = DOC_WEB_LOCAL."kbis/$piece-$siren.pdf";
$kbisLocalHTML = DOC_WEB_LOCAL."kbis/$piece-$siren.html";
$kbisLocalTXT  = DOC_WEB_LOCAL."kbis/$piece-$siren.txt";

if (file_exists($kbisLocalPDF)
	&& date('Ymd',filectime($kbisLocalPDF))==date('Ymd')){
	exit;
} else {
	if (file_exists($kbisLocalHTML)) 	unlink($kbisLocalHTML);
	if (file_exists($kbisLocalPDF)) 	unlink($kbisLocalPDF);
	if (file_exists($kbisLocalTXT)) 	unlink($kbisLocalTXT);
}

// Ouverture de la connexion FTP
$conn_id = ftp_connect(PKBIS_HOST);
$login_result = ftp_login($conn_id, PKBIS_USER, PKBIS_PASS);

$tabListInit = ftp_nlist($conn_id, strtolower(FORMAT).'/');
$nbList = count($tabListInit);
$nbEssais = 0;	// Nombre de tentatives de récupération

// Fichier à déposer sur le FTP pour débuter la commande
$fp = fopen(DOC_WEB_LOCAL."kbis/$piece-$siren", 'w+');
fwrite($fp, "$siren;$piece;$type;$visu;$courrier;$ref");
rewind($fp);
if (!ftp_fput($conn_id, "in/$piece-$siren.txt", $fp, FTP_ASCII)){
	//Envoi mail pour erreur
	exit;
}
fclose($fp);

kbisLog($siren, $piece, "IN : Fichier déposé en commande sur le FTP");

// Surveillance du FTP pour récupération du fichier
while (true)
{
	$nbEssais++;
	sleep($dureeInterval);
	$tabList = ftp_nlist($conn_id, strtolower(FORMAT).'/');
	if (count($tabList)>$nbList)
	{
		kbisLog($siren, $piece, "WAIT : Essai $nbEssais, des nouveaux fichiers sont disponibles sur le FTP !");
		sleep($dureeInterval); // Laisse le temps au serveur de K-Bis de finir le fichier PDF !!!
		$tabNom = array_diff($tabList,$tabListInit);
		
		//Récupération du fichier
		ftp_chdir($conn_id, strtolower(FORMAT));
		$ficDist = str_replace(strtolower(FORMAT).'/', '', reset($tabNom));
		if (!ftp_get($conn_id,DOC_WEB_LOCAL."kbis/$piece-$siren.".strtolower(FORMAT), $ficDist, FTP_BINARY))
		{
			// Problème FTP --> STOP
			kbisLog($siren, $piece, "OUT : Problème FTP");
			exit;
		}
		
		//Traitement en fonction du format
		if (FORMAT == 'PDF')
		{
			shell_exec(PDFTOTEXT.' '.$kbisLocalPDF.' '.$kbisLocalTXT);
			$str = file_get_contents($kbisLocalTXT);
			$sirenLu = checkSiren($siren, $str);
			if ($sirenLu){
				kbisLog($siren, $piece, "OUT : Le nouveau fichier est celui attendu ($sirenLu=$siren)");
			} else {
				kbisLog($siren, $piece, "OUT : Le nouveau fichier n'est pas celui attendu ($sirenLu<>$siren)");
				unlink($kbisLocalPDF);
			}
			break;
		}
		elseif (FORMAT == 'HTML')
		{
			$str = file_get_contents($kbisLocalHTML);
			$str = preg_replace('@<DIV class=no-print>.*?</DIV>@si', '', $str);
			file_put_contents($kbisLocalHTML, $str);
			$sirenLu = checkSiren($siren, $str);
			if ($sirenLu){
				kbisLog($siren, $piece, "OUT : Le nouveau fichier est celui attendu ($sirenLu=$siren)");
				shell_exec(WKHTMLTOPDF.' '.$kbisLocalHTML.' '.$kbisLocalPDF);
			} else {
				kbisLog($siren, $piece, "OUT : Le nouveau fichier n'est pas celui attendu ($sirenLu<>$siren)");
				unlink($kbisLocalHTML);
			}
			break;
		}
		
		//Log ?
		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")) {
				$fp = fopen(LOG_PATH."/$piece-commande.log", 'a+');
				fwrite($fp, date('Y/m/d H:i:s')." - $siren - Nb fichier HTML : ".count($tabListHtml).print_r($tabListHtml));
				fclose($fp);
			}
		}
		
	}
	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);
			exit;
		}
	}
}
// 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);
exit;