scores/batch
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix conn ftp et doctrine

Browse Source
This commit is contained in:
Michael RICOIS 2017-02-20 09:33:52 +01:00
parent bffb95211d
commit 44ed36dace
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
bin/sourceDila.php
View File

@ -137,14 +137,14 @@ if ($opts->cron || $oneShot) {
} }
// --- Connexion au FTP // --- Connexion au FTP
$conn = ftp_connect($FTPSERVER); $connFtp = ftp_connect($FTPSERVER);
if (false === $conn) { if (false === $connFtp) {
echo date('Y-m-d H:i:s') . " - Impossible de se connecter à $FTPSERVER\n"; echo date('Y-m-d H:i:s') . " - Impossible de se connecter à $FTPSERVER\n";
exit; exit;
} }
// --- Login // --- Login
$login = ftp_login($conn, $FTPUSER, $FTPPASS); $login = ftp_login($connFtp, $FTPUSER, $FTPPASS);
if (false === $login) { if (false === $login) {
echo date('Y-m-d H:i:s') . " - Erreur authentication à $FTPSERVER\n"; echo date('Y-m-d H:i:s') . " - Erreur authentication à $FTPSERVER\n";
exit; exit;
@ -171,7 +171,7 @@ if ($opts->cron || $oneShot) {
} }
// --- Liste des fichiers dans le répertoire // --- Liste des fichiers dans le répertoire
$contents = ftp_nlist($conn, $ftpDir); $contents = ftp_nlist($connFtp, $ftpDir);
if ($contents === false) { if ($contents === false) {
echo date('Y-m-d H:i:s') . " - Impossible de lister le répertoire $ftpDir\n"; echo date('Y-m-d H:i:s') . " - Impossible de lister le répertoire $ftpDir\n";
@ -203,19 +203,19 @@ if ($opts->cron || $oneShot) {
echo date('Y-m-d H:i:s') . " - Lecture $file\n"; echo date('Y-m-d H:i:s') . " - Lecture $file\n";
$fileSql = "SELECT * FROM sdv1.flux_dila WHERE file=:file ORDER BY dateInsert DESC LIMIT 0,1"; $fileSql = "SELECT * FROM sdv1.flux_dila WHERE file=:file ORDER BY dateInsert DESC LIMIT 0,1";
$fileStmt = $connDoctrine->prepare($fileSql); $fileStmt = $conn->prepare($fileSql);
$fileStmt->bindValue('file', $file); $fileStmt->bindValue('file', $file);
$fileStmt->execute(); $fileStmt->execute();
// --- Récupération des infos FTP // --- Récupération des infos FTP
$ftpDate = 0; $ftpDate = 0;
$fileTime = ftp_mdtm($conn, $ftpDir.'/'.$file); $fileTime = ftp_mdtm($connFtp, $ftpDir.'/'.$file);
if ($fileTime != -1) { if ($fileTime != -1) {
date_default_timezone_set('UTC'); date_default_timezone_set('UTC');
$ftpDate = date('YmdHis', $fileTime); $ftpDate = date('YmdHis', $fileTime);
date_default_timezone_set('Europe/Paris'); date_default_timezone_set('Europe/Paris');
} }
$ftpSize = ftp_size($conn, $ftpDir.'/'.$file); $ftpSize = ftp_size($connFtp, $ftpDir.'/'.$file);
// -- Fichier non présent en base // -- Fichier non présent en base
if ($fileStmt->rowCount() == 0) { if ($fileStmt->rowCount() == 0) {
@ -234,7 +234,7 @@ if ($opts->cron || $oneShot) {
'dateInsert'=> date('YmdHis'), 'dateInsert'=> date('YmdHis'),
); );
try { try {
$connDoctrine->insert('sdv1.flux_dila', $data); $conn->insert('sdv1.flux_dila', $data);
} catch (\Doctrine\DBAL\DBALException $e) { } catch (\Doctrine\DBAL\DBALException $e) {
echo date('Y-m-d H:i:s') . " - Erreur insertion bdd $file = ".$e->getMessage()."\n"; echo date('Y-m-d H:i:s') . " - Erreur insertion bdd $file = ".$e->getMessage()."\n";
} }
@ -254,7 +254,7 @@ if ($opts->cron || $oneShot) {
// --- Téléchargement du fichier // --- Téléchargement du fichier
if ($downloadFile === true) { if ($downloadFile === true) {
echo date('Y-m-d H:i:s') . " - Telechargement $file\n"; echo date('Y-m-d H:i:s') . " - Telechargement $file\n";
if (ftp_get($conn, $storageDir.'/'.$file, $ftpDir.'/'.$file, FTP_BINARY)) { if (ftp_get($connFtp, $storageDir.'/'.$file, $ftpDir.'/'.$file, FTP_BINARY)) {
echo date('Y-m-d H:i:s') . " - Ecriture du fichier $storageDir/$file\n"; echo date('Y-m-d H:i:s') . " - Ecriture du fichier $storageDir/$file\n";
// --- Vérification cohérance // --- Vérification cohérance
@ -268,7 +268,7 @@ if ($opts->cron || $oneShot) {
'dateInsert'=> date('YmdHis'), 'dateInsert'=> date('YmdHis'),
); );
try { try {
$connDoctrine->insert('sdv1.flux_dila', $data); $conn->insert('sdv1.flux_dila', $data);
} catch (\Doctrine\DBAL\DBALException $e) { } catch (\Doctrine\DBAL\DBALException $e) {
echo date('Y-m-d H:i:s') . " - Erreur insertion bdd $file = ".$e->getMessage()."\n"; echo date('Y-m-d H:i:s') . " - Erreur insertion bdd $file = ".$e->getMessage()."\n";
} }
@ -286,7 +286,7 @@ if ($opts->cron || $oneShot) {
} }
// --- Fermeture du FTP // --- Fermeture du FTP
ftp_close($conn); ftp_close($connFtp);
if ($execId !== null) { if ($execId !== null) {
$execRef->total($execId, $unitInc); $execRef->total($execId, $unitInc);