flux/read.php

<?php
/**
 * Indicateur de récupération par le client
 * Attention le script doit s'executer avec l'utilisateur root
 */
// --- 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.",
		'file|f=s' => "Give the full file path to integrate",
		'debug' => "Send a mail for debug",
    ));
	$opts->parse();
	$optsNb = $opts->getOptions();
} catch (Zend_Console_Getopt_Exception $e) {
    $displayUsage = true;
}

// --- Aide / Options
if ($optsNb == 0 || isset($opts->help)) {
    $displayUsage = true;
}

// --- Usage
if ($displayUsage) {
	echo "Execute basic action when a customer read a file.\n";
	echo $opts->getUsageMessage();
	exit;
}

// --- Get the file
if ( isset($opts->file) )
{
    $optionsNoLog = false;
    $repositoryDir = 'recv';

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

	// --- Get the main directory name in FTP and SFTP
	$pathParts = pathinfo($opts->file);
	$filenameIn = $pathParts['basename'];
	$extension = '';
	if (array_key_exists('extension', $pathParts))
	{
		$extension = $pathParts['extension'];
	}
	$client = basename(dirname($pathParts['dirname']));

	// --- Base path, type and repository
	$startpos = strlen( $c->profil->path->data . DIRECTORY_SEPARATOR );
	if ('sftp' == substr($opts->file, $startpos, 4))
	{
		$type = 'SFTP';
		$fluxBasePath = $c->profil->path->sftp . '/' . $client;
	}
	elseif ('ftp' == substr($opts->file, $startpos, 3))
	{
		$type = 'FTP';
		$fluxBasePath = $c->profil->path->ftp . '/' . $client;
	}
	$fluxRepository = str_replace(array($fluxBasePath.'/', '/'.$filenameIn), array('', ''), $opts->file);

	// --- Match prestation
	$prestations = include __DIR__ . '/config.php';
	$prestation = null;
    if (array_key_exists($client, $prestations))
    {
        $clientPrestations = $prestations[$client]['prestations'];
        foreach ($clientPrestations as $i => $p)
        {
            // --- Not default repository dir
            if (array_key_exists('directory', $p) && !empty($p['directory']))
            {
                $repositoryDir = $p['directory'];
            }

            if ($type == $p['type'] && $fluxRepository == $repositoryDir)
            {
                $prestation = $p['name'];

                // --- Set option
                if (array_key_exists('in', $p) && count($p['in']) > 0)
                {
                    foreach ($p['in'] as $option => $value)
                    {
                        ${'options'.$option} = $value;
                    }
                }

                break;
            }
        }
    }

    if ($prestation === null) {
        echo date('Y-m-d H:i:s')." - Prestation not found !\n";
    }

	$fluxBasePath .= '/'.$repositoryDir;

	// --- Prepare mail or Debug mode
	if ($opts->mail || $opts->debug)
	{
		$subject = "[Flux] - Lecture fichier $client";
		$txt = "Lecture d'un fichier\n";
		$txt.= "Client : $client\n";
		$txt.= "Mode de transmission : $type\n";
		$txt.= "Fichier : ".$filenameIn."\n";
		$txt.= "Nombre de Lignes : $nbLines\n";
		$txt.= "Taille du fichier : $size\n";

		$mail = new Zend_Mail('UTF-8');
        // --- Configuration du transport SMTP
		if ( $c->profil->mail->method == 'smtp' ) {
		    $config = array();
		    if ( isset($this->config->auth) ) {
		        $config['auth'] = $this->config->auth;
		        if ( isset($this->config->username) ) {
		            $config['username'] = $c->profil->mail->username;
		        }
		        if ( isset($this->config->password) ) {
		            $config['password'] = $c->profil->mail->password;
		        }
		    }
		    if ( isset($this->config->port) ) {
		        $config['port'] = $c->profil->mail->port;
		    }
		    $tr = new Zend_Mail_Transport_Smtp($c->profil->mail->host, $config);
		}
		// --- Configuration transport Sendmail
		if ( $this->config->mail->method == 'sendmail' ) {
		    $tr = new Zend_Mail_Transport_Sendmail();
		}
		$mail->setDefaultTransport($tr);
		$mail->setBodyText($txt);
		$mail->setFrom('supportdev@scores-decisions.com', 'Machine Flux');
		$mail->addTo('suivi@scores-decisions.com', 'Suivi');
		$mail->setSubject($subject);
		$mail->send();

		// --- Stop
		if ($opts->mail) {
			exit;
		}
	}

    // --- Execute
    if ($optionsNoLog === false)
    {
	    $db = Zend_Db::factory($c->profil->db->metier);
	    Zend_Db_Table::setDefaultAdapter($db);
	    $fluxM = new Application_Model_Sdv1FluxFileOut();

        // --- Vérifier si l'indicateur de lecture n'a pas déjà été ecrit
        $readSql = $fluxM->select()->where("fileOut='".$filenameIn."'");
        $readResult = $fluxM->fetchRow($readSql);
        if ($readResult !== null) {
            if ($readResult->depotDateRead == 0) {
                // --- Ecrire l'indicateur de lecture
                try {
                    $fluxM->update(array('depotDateRead' => date('YmdHis')), "fileOut='".$filenameIn."'");
                    echo date('Y-m-d H:i:s')." - Enregistrement client:$client fichier:$filenameIn\n";
                }
                catch (Zend_Db_Exception $e){
                    echo date('Y-m-d H:i:s')." - ERREUR Enregistrement client:$client fichier:$filenameIn\n";
                }
            }
        }
    }
}