_cron.php

Vai alla documentazione di questo file.

<?php

    // inclusione del framework
        require '../../_src/_config.php';

    // costanti che descrivono lo stato di funzionamento del framework
        define( 'CRON_RUNNING'                  , 'CRONRUN' );

    // apro il report
        $cHnd = fopen( DIRECTORY_BASE . DIRECTORY_LOG . 'latest/cron.latest.log', WRITE_FILE_OVERWRITE );

    // log
        logWrite( 'chiamata cron API', 'cron', LOG_INFO );

    // lock delle tabelle
        mysqlQuery( $cf['mysql']['connection'], 'LOCK TABLES cron WRITE, cron_log WRITE, job WRITE' );

    // tempo
        $time = time();

    // output
        $cf['cron']['results'] = array();

    // seleziono i task con profili di schedulazione compatibili con l'orario corrente
        $tasks = mysqlQuery(
            $cf['mysql']['connection'],
            'SELECT * FROM cron WHERE '.
            '( minuto = ?                                               OR minuto IS NULL ) AND '.
            '( ora = ?                                                  OR ora IS NULL ) AND '.
            '( giorno_del_mese = ?                                      OR giorno_del_mese IS NULL ) AND '.
            '( mese = ?                                                 OR mese IS NULL ) AND '.
            '( giorno_della_settimana = ?                               OR giorno_della_settimana IS NULL ) AND '.
            '( settimana = ?                                            OR settimana IS NULL ) AND '.
            '( from_unixtime( timestamp_esecuzione, "%Y%m%d%H%i") < ?   OR timestamp_esecuzione IS NULL ) ',
            array(
                array( 's' => intval( date( 'i', $time ) ) ),           // 
                array( 's' => date( 'G', $time ) ),                     // 
                array( 's' => date( 'j', $time ) ),                     // 
                array( 's' => date( 'n', $time ) ),                     // 
                array( 's' => date( 'w', $time ) ),                     // 0 - 6, 0 -> domenica
                array( 's' => date( 'W', $time ) ),                     // 1 - 52/53
                array( 's' => date( 'YmdHi', $time ) )
            )
        );

    // log
        logWrite( 'criteri di ricerca -> ' . date( 'i', $time ) . ' ' . date( 'G', $time ) . ' ' . date( 'j', $time ) . ' ' . date( 'n', $time ) . ' ' . date( 'w', $time ) . ' ' . date( 'W', $time ), 'cron', LOG_INFO );

    // timestamp di esecuzione iniziale
        foreach( $tasks as $task ) {
            mysqlQuery( $cf['mysql']['connection'], 'UPDATE cron SET timestamp_esecuzione = ? WHERE id = ?', array( array( 's' => $time ), array( 's' => $task['id'] ) ) );
        }

    // seleziono i job attivi
        $jobs = mysqlQuery(
            $cf['mysql']['connection'],
            'SELECT * FROM job WHERE '.
            'timestamp_apertura <= ? AND timestamp_apertura IS NOT NULL AND timestamp_completamento IS NULL '.
            'AND ( from_unixtime( timestamp_esecuzione, "%Y%m%d%H%i") < ? OR timestamp_esecuzione IS NULL )',
            array(
                array( 's' => $time ),
                array( 's' => date( 'YmdHi', $time ) )
            )
        );

    // log
        logWrite( 'trovati ' . count( $jobs ) . ' job', 'cron', LOG_DEBUG );

    // timestamp di esecuzione iniziale
        foreach( $jobs as $job ) {
            if( file_exists( DIRECTORY_BASE . $job['job'] ) ) {
                mysqlQuery( $cf['mysql']['connection'], 'UPDATE job SET timestamp_esecuzione = ? WHERE id = ?', array( array( 's' => $time ), array( 's' => $job['id'] ) ) );
            }
        }

    // unlock delle tabelle
        mysqlQuery( $cf['mysql']['connection'], 'UNLOCK TABLES' );

    // ciclo sui task
        foreach( $tasks as $task ) {
            if( file_exists( DIRECTORY_BASE . $task['task'] ) ) {

#           // verifico che il task non sia già stato eseguito nel minuto corrente
#               if( date( 'YmdHi', $task['timestamp_esecuzione'] ) != date( 'YmdHi', $time ) ) {

                    // resetto lo status
                        $status = array();

                    // latest
                        fwrite( $cHnd, 'eseguo ' . $task['task']  . ' x' . $task['iterazioni'] . PHP_EOL );

                    // log
                        logWrite( 'eseguo il task ' . $task['id'] . ' -> ' . $task['task'], 'cron', LOG_DEBUG );

#                   // array dei risultati
#                       $cf['cron']['results'] = array();

                    // eseguo il task
                        for( $iter = 0; $iter < $task['iterazioni']; $iter++ ) {
                            logWrite( 'iterazione #' . $iter . ' per il task ' . $task['id'] . ' -> ' . $task['task'], 'cron', LOG_DEBUG );
                            fwrite( $cHnd, 'iterazione #' . $iter . PHP_EOL );
                            require DIRECTORY_BASE . $task['task'];
                            $cf['cron']['results']['task'][ $task['task'] ][ $task['id'] ] = array_replace_recursive( $status, array( 'esecuzione' => time() ) );
                            if( ! isset( $task['delay'] ) || empty( $task['delay'] ) ) { $task['delay'] = 3; }
                            sleep( $task['delay'] );
                        }

                    // aggiorno il log
                        mysqlQuery( $cf['mysql']['connection'], 'INSERT INTO cron_log ( id_cron, testo, timestamp_esecuzione ) VALUES ( ?, ?, ? )', array( array( 's' => $task['id'] ), array( 's' => json_encode( $cf['cron']['results'] ) ), array( 's' => $time ) ) );

                    // aggiorno la tabella di pianificazione
                        mysqlQuery( $cf['mysql']['connection'], 'UPDATE cron SET timestamp_esecuzione = ? WHERE id = ?', array( array( 's' => $time ), array( 's' => $task['id'] ) ) );

                    // latest
                        fwrite( $cHnd, print_r( $status, true ) . PHP_EOL );

#               } else {

#                   // log
#                       logWrite( 'task ' . $task['id'] . ' già eseguito alle ' . date( 'Y-m-d H:i', $time ), 'cron', LOG_NOTICE );

#               }

            }
        }

    // ciclo sui job
        foreach( $jobs as $job ) {
            if( file_exists( DIRECTORY_BASE . $job['job'] ) ) {

#           // verifico che il job non sia già stato eseguito nel minuto corrente
#               if( date( 'YmdHi', $job['timestamp_esecuzione'] ) != date( 'YmdHi', $time ) ) {

                    // log
                        logWrite( 'eseguo il job ' . $job['id'] . ' -> ' . $job['job'], 'cron', LOG_DEBUG );

#                   // array dei risultati
#                       $cf['cron']['results'] = array();

                    // eseguo il job
                        require DIRECTORY_BASE . $job['job'];

                    // integro la timestamp di esecuzione
                        $cf['cron']['results']['job'][ $job['job'] ][ $job['id'] ] = array_replace_recursive( $status, array( 'esecuzione' => time() ) );

                    // aggiorno la tabella di avanzamento lavori
                        mysqlQuery( $cf['mysql']['connection'], 'UPDATE job SET timestamp_esecuzione = ?, workspace = ? WHERE id = ?', array( array( 's' => $time ), array( 's' => serialize( $wksp ) ), array( 's' => $job['id'] ) ) );

#               } else {

#                   // log
#                       logWrite( 'job ' . $job['id'] . ' già eseguito alle ' . date( 'Y-m-d H:i', $time ), 'cron', LOG_NOTICE );

#               }

            }
        }

    // log
        appendToFile( '-- ' . date( 'Y-m-d H:i:s' ) . PHP_EOL . print_r( $cf['cron']['results'], true ), 'var/log/cron/' . date( 'Ymd' ) . '.log' );

    // output
        buildJson( $cf['cron']['results'] );

    // chiusura latest
        fclose( $cHnd );

?>