progress.php

Vai alla documentazione di questo file.

<?php

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

    // decodifico l'input
        $input = json_decode( file_get_contents('php://input'), true );

    // decodifico l'input
        if( is_array( $input ) ) {
            $_REQUEST = array_replace_recursive(
                $_REQUEST, $input
            );
        }

    // verifico che ci sia un job id
        if( isset( $_REQUEST['job'] ) ) {

            // recupero i dati del job
                $job = mysqlSelectRow(
                    $cf['mysql']['connection'],
                    'SELECT * FROM job WHERE id = ?',
                    array( array( 's' => $_REQUEST['job'] ) )
                );

            // se il job va iniziato...
                if( empty( $job ) ) {

                    // costruzione dell'output
                        $dati = array(
                            'job' => $_REQUEST['job'],
                            'done' => false,
                            'totale' => 100,
                            'corrente' => 0,
                            'progresso' => 0,
                            'passo' => 1,
                            'message' => 'lavoro iniziato',
                            'error' => false
                        );

                    // inserisco i dati del job
                        $job = mysqlQuery(
                            $cf['mysql']['connection'],
                            'INSERT INTO job ( id, totale, corrente, passo ) VALUES ( ?, ?, ?, ? )',
                            array(
                                array( 's' => $dati['job'] ),
                                array( 's' => $dati['totale'] ),
                                array( 's' => $dati['corrente'] ),
                                array( 's' => $dati['passo'] )
                            )
                        );

                } elseif( $job['totale'] == $job['corrente'] ) {

                    // costruzione dell'output
                        $dati = array(
                            'job' => $job['id'],
                            'done' => true,
                            'totale' => $job['totale'],
                            'corrente' => $job['corrente'],
                            'progresso' => 100,
                            'passo' => $job['passo'],
                            'message' => 'lavoro completato',
                            'error' => false
                        );

                    // reset del job
                        mysqlQuery(
                            $cf['mysql']['connection'],
                            'DELETE FROM job WHERE id = ?',
                            array( array( 's' => $_REQUEST['job'] ) )
                        );

                } else {

                    // costruzione dell'output
                        $dati = array(
                            'job' => $job['id'],
                            'done' => false,
                            'totale' => $job['totale'],
                            'corrente' => $job['corrente'] + 1,
                            'progresso' => floor( ( $job['corrente'] * 100 ) / $job['totale'] ),
                            'passo' => $job['passo'],
                            'message' => 'lavoro al ' . floor( ( $job['corrente'] * 100 ) / $job['totale'] ) . '%',
                            'error' => false
                        );

                    // aggiorno i dati del job
                        $job = mysqlQuery(
                            $cf['mysql']['connection'],
                            'REPLACE INTO job ( id, totale, corrente, passo ) VALUES ( ?, ?, ?, ? )',
                            array(
                                array( 's' => $dati['job'] ),
                                array( 's' => $dati['totale'] ),
                                array( 's' => $dati['corrente'] ),
                                array( 's' => $dati['passo'] )
                            )
                        );

                }

        } else {

            // costruzione dell'output
                $dati = array(
                    'done' => true,
                    'message' => 'nessun job specificato',
                    'error' => true
                );

        }

    // output
        buildJson( $dati );

?>