batch/bin/sourceJalPdf.php

<?php
/**
 * Livraison des fichiers pour orone
 *
 * Toutes les 10 minutes
 * Lire les fichiers dans le repertoire clients/jalpdfsed/send
 * Intégrer les informations dans la table octde.jalpdfsed
 * Copier le fichier dans clients/orone/recv
 * Integrer les informations dans flux_fileout pour livraison
 * Mettre à jour la date de livraison
 * Déplacer le fichier dans clients/jalpdfsed/send/done
 */

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.",
        'parsefile' => "Parcours les fichiers",
        'deliver'   => "Relivrer les fichiers depuis (from)",
        'from=s'    => "db, date au format AAAAMMJJ",
        'verbose'   => "mode verbeux",
        '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 "Gestion des PDFs JAL (Emission et Transmission).\n";
    echo $opts->getUsageMessage();
    exit;
}

$c = new Zend_Config($application->getOptions());

// 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);
} catch (\Doctrine\DBAL\DBALException $e) {
    echo "Connection Database impossible.\n";
    exit;
}


if ($opts->cron) {

    echo date('Y-m-d H:i:s')." - Récupération des fichiers jalpdfsed.\n";

    // --- Lire les fichiers dans sdv1.flux_filein (jalpdfsed/PDF) avec dateExecute = 0
    try {
        $fileSql = "SELECT * FROM sdv1.flux_filein WHERE client='jalpdfsed' AND name='PDF'
            AND dateExecute='0000-00-00 00:00:00'";
        $fileStmt = $conn->executeQuery($fileSql);
    }
    catch (\Doctrine\DBAL\DBALException $e) {
        echo date('Y-m-d H:i:s')." - ".$e->getMessage()."\n"; exit;
    }

    if ($fileStmt->rowCount() > 0) {
        echo date('Y-m-d H:i:s')." - Aucun fichier à traiter\n";
    }
    else {
        while($item = $fileStmt->fetch(\PDO::FETCH_OBJ)) {
            $fileName = $item->depotFile;
            $filePath = $c->profil->path->shared . '/clients/jalpdfsed/send/' . $fileName;

            echo date('Y-m-d H:i:s')." - Fichier $fileName\n";

            if ( false !== ( $file = file_get_contents($filePath) ) ) {
                if (preg_match('/^([0-9]{1,})_([0-9]{8})(_[0-9]{1,})?\.pdf$/i', $fileName, $t)) {
                    $idJalEd = $t[1];
                    $dateJalEd = $t[2];

                    //Version
                    preg_match( "/^\%PDF\-(.*)\s/U", $file, $matches );
                    $fileVersion = '';
                    if (count($matches) > 0) {
                        $fileVersion = $matches[1];
                    }
                    //Number of page
                    $filePage = preg_match_all( "/\/Page\W/", $file, $matches );
                    //Pdf size
                    $fileSize = filesize($filePath);
                    //Date de création
                    $fileDate = date('Ymd', filectime($filePath));

                    $isInsert = false;
                    $jalSql = "SELECT pdfName FROM octde.jalpdfsed WHERE pdfName=:file";
                    $jalStmt = $conn->prepare($jalSql);
                    $jalStmt->bindValue('file', $fileName);
                    $jalStmt->execute();
                    if ($jalStmt->rowCount()) {
                        $data = array(
                            'pdfName' => $fileName,
                            'idJalEd' => $idJalEd,
                            'dateJalEd' => $dateJalEd,
                            'pdfSize' => $fileSize,
                            'pdfPage' => $filePage,
                            'pdfVer' => $fileVersion,
                            'pdfDate' => $fileDate,
                            'pdfText' => 0,
                            'dateInsert' => date('YmdHis'),
                        );
                        // --- Renseigner octde.jalpdfsed
                        try {
                            $isInsert = $conn->insert('octde.jalpdfsed', $data);
                        }
                        catch (\Doctrine\DBAL\DBALException $e) {
                            echo date('Y-m-d H:i:s')." - ".$e->getMessage()."\n";
                            continue;
                        }
                    }
                    else {
                        $exist = $jalStmt->fetch(\PDO::FETCH_OBJ);
                        // --- Vérification de la taille des fichiers
                        if ($fileSize != $exist->pdfSize) {
                            // --- Renseigner octde.jalpdfsed
                            try {
                                $isInsert = $conn->update('octde.jalpdfsed', array(
                                    'pdfSize' => $fileSize,
                                    'pdfPage' => $filePage,
                                    'pdfVer' => $fileVersion,
                                    'pdfDate' => $fileDate,
                                    'dateDeliver' => '0000-00-00 00:00:00',
                                ), array('id' => $exist->id));
                            }
                            catch (\Doctrine\DBAL\DBALException $e) {
                                echo date('Y-m-d H:i:s')." - ".$e->getMessage()."\n";
                                continue;
                            }
                        }
                    }

                    if ($isInsert) {
                        // --- Copier le fichier dans le dossier de stockage orone/recv
                        if (copy($filePath, $c->profil->path->shared . '/clients/orone/recv/' . $fileName)) {
                            // --- Definir sdv1.flux_filein dateExecute
                            try {
                                $conn->update('sdv1.flux_filein', array(
                                    'dateExecute' => date('YmdHis')),
                                    array('id' => $item->id));
                            }
                            catch (\Doctrine\DBAL\DBALException $e) {
                                echo date('Y-m-d H:i:s')." - ".$e->getMessage()."\n";
                            }
                        }
                    }
                }
            }
        }
    }
    echo date('Y-m-d H:i:s')." - Fin Récupération des fichiers jalpdfsed.\n";
}

if ($opts->deliver || $opts->cron) {

    echo date('Y-m-d H:i:s')." - Livraison des fichiers.\n";

    $fileList = array();

    $from = 'db';
    if (isset($opts->from) && $opts->from != 'db') {
        $from = $opts->from;
    }

    // --- Lire tous les fichiers avec dateDeliver = 0
    if ($from == 'db') {
        try {
            $jalSql = "SELECT * FROM octde.jalpdfsed WHERE dateDeliver = '0000-00-00 00:00:00'";
            $jalStmt = $conn->executeQuery($jalSql);
        }
        catch(\Doctrine\DBAL\DBALException $e) {
            echo date('Y-m-d H:i:s')." - ".$e->getMessage()."\n";
        }
    }
    // --- Renvoyer tous les fichiers en date du AAAAMMJJ
    else {
        exit;
    }

    if ($jalStmt->rowCount() == 0) {
        echo date('Y-m-d H:i:s')." - Aucun nouveau fichier pour orone\n";
    } else {
        // --- Envoyer les fichiers pour orone, simplement marquer dans teletransmission
        while($item = $jalStmt->fetch(\PDO::FETCH_OBJ)) {
            echo date('Y-m-d H:i:s')." - Fichier $item->pdfName\n";
            $filePath = $c->profil->path->shared . '/clients/orone/recv/' . $item->pdfName;
            if (file_exists($filePath)) {
                $isInsert = false;
                $size = filesize($filePath);
                try {
                    $isInsert = $conn->insert('sdv1.flux_fileout', array(
                        'client' => 'orone',
                        'name' => 'PDF',
                        'nbLines' => 0,
                        'dateBegin' => date('YmdHis'),
                        'dateEnd' => date('YmdHis'),
                        'fileOut' => $item->pdfName,
                        'depotFileSize' => $size,
                        'depotType' => 'FTP',
                        'depotDate' => '0000-00-00 00:00:00',
                    ));
                }
                catch (\Doctrine\DBAL\DBALException $e) {
                    echo date('Y-m-d H:i:s')." - ".$e->getMessage()."\n";
                    continue;
                }

                // --- Definir octde.jalpdfsed dateDeliver
                if ($isInsert) {
                    try {
                        $conn->update('octde.jalpdfsed',
                            array('dateDeliver' => date('YmdHis')),
                            array('id' => $item->id));
                    }
                    catch(\Doctrine\DBAL\DBALException $e) {
                        echo date('Y-m-d H:i:s')." - ".$e->getMessage()."\n";
                    }
                }
            }
        }
    }

    echo date('Y-m-d H:i:s')." - Fin Livraison des fichiers.\n";
}

if ($opts->parsefile) {
    // --- Lire les fichiers dans clients/jalpdfsed/send
    // --- Vérifier la présence en base
}