_indirizzi.geocode.php

Vai alla documentazione di questo file.

<?php

    // inclusione del framework
        if( ! defined( 'CRON_RUNNING' ) ) {
            require '../../../_src/_config.php';
        }

    // inizializzo l'array del risultato
        $status = array();

    // status
        $status['info'][] = 'inizio operazioni di geocode';

    // lock delle tabelle della coda
        $lock = mysqlQuery( $cf['mysql']['connection'], 'LOCK TABLES indirizzi WRITE, comuni WRITE, stati WRITE, provincie WRITE, regioni WRITE, zone_cap WRITE' );

    // se il lock è andato a buon fine
        if( $lock === true ) {

            // prelevo un indirizzo dalla coda
                $geocode = mysqlSelectRow(
                    $cf['mysql']['connection'],
                    'SELECT indirizzi.*, '.
                    'comuni.id_provincia, '.
                    'provincie.sigla, '.
                    'comuni.nome AS comune, '.
                    'stati.iso31661alpha2 AS sigla_stato, '.
                    'stati.nome AS stato '.
                    'FROM indirizzi '.
                    'LEFT JOIN comuni ON comuni.id = indirizzi.id_comune '.
                    'LEFT JOIN provincie ON provincie.id = comuni.id_provincia '.
                    'LEFT JOIN regioni ON regioni.id = provincie.id_regione '.
                    'LEFT JOIN stati ON stati.id = regioni.id_stato '.
                    'WHERE ( latitudine IS NULL OR longitudine IS NULL OR cap IS NULL ) '.
                    'AND ( timestamp_geocode IS NULL OR timestamp_geocode < ? OR timestamp_aggiornamento > timestamp_geocode ) '.
                    'ORDER BY timestamp_geocode ASC '.
                    'LIMIT 1 ',
                    array( array( 's' => strtotime( '-1 day' ) ) )
                );

            // debug
                // echo 'indirizzo: ' . print_r( $geocode, true );

            // se c'è almeno una geocode da inviare
                if( ! empty( $geocode ) ) {

                    // status
                        $status['indirizzo'] = $geocode;

                    // inizio la transazione
                        if( mysqlQuery( $cf['mysql']['connection'], 'START TRANSACTION' ) ) {

                            // geolocalizzazione
                                $gc = mapquestGetCachedCoords(
                                    $cf['memcache']['connection'],
                                    $cf['mapquest']['server']['key'],
                                    $geocode['civico'],
                                    $geocode['indirizzo'],
                                    $geocode['comune'],
                                    $geocode['stato']
                                );

                            // debug
                                // print_r( $gc );

                            // controllo l'esito dell'invio
                            // TODO gestire il caso in cui l'API non restituisca risultati utili
                            // NOTA il meccanismo deve essere in grado di ritardare i tentativi successivi in modo da non bloccare la coda
                                if( ! empty( $gc ) ) {

                                    // aggiornamento database
                                        mysqlQuery(
                                            $cf['mysql']['connection'],
                                            'UPDATE indirizzi SET latitudine = ?, longitudine = ?, cap = ?, timestamp_geocode = unix_timestamp() WHERE id = ?',
                                            array(
                                                array( 'd' => $gc['lat'] ),
                                                array( 'd' => $gc['lng'] ),
                                                array( 's' => $gc['cap'] ),
                                                array( 's' => $geocode['id'] )
                                            )
                                        );

                                    // se l'indirizzo non ha zona
                                        if( empty( $geocode['id_zona'] ) ) {

                                            $idZona = mysqlSelectValue( $cf['mysql']['connection'], 'SELECT id_zona FROM zone_cap WHERE cap = ?', array( array( 's' => $gc['cap'] ) ) );

                                            if( ! empty( $idZona ) ) {
                                                mysqlQuery( $cf['mysql']['connection'], 'UPDATE indirizzi SET id_zona = ? WHERE id = ?', array( array( 's' => $idZona ), array( 's' => $geocode['id'] ) ) );
                                            }

                                        }

                                    // commit
                                        mysqlQuery( $cf['mysql']['connection'], 'COMMIT' );

                                    // log
                                        logWrite( 'salvataggio della geolocalizzazione completato', 'geocode', LOG_DEBUG );

                                } else {

                                    // aggiornamento database
                                        mysqlQuery(
                                            $cf['mysql']['connection'],
                                            'UPDATE indirizzi SET timestamp_geocode = unix_timestamp() WHERE id = ?',
                                            array(
                                                array( 's' => $geocode['id'] )
                                            )
                                        );

#                                   // rollback
#                                       mysqlQuery( $cf['mysql']['connection'], 'ROLLBACK' );

                                    // commit
                                        mysqlQuery( $cf['mysql']['connection'], 'COMMIT' );

                                    // status
                                        $status['info'][] = 'geolocalizzazione fallita';

                                    // log
                                        logWrite( 'impossibile ottenere la geolocalizzazione', 'geocode', LOG_ERR );

                                }

                        } else {

                            // status
                                $status['info'][] = 'transazione fallita';

                            // log
                                logWrite( 'impossibile avviare la transazione per geolocalizzare un indirizzo', 'geocode', LOG_ERR );

                        }

                } else {

                    // status
                        $status['info'][] = 'nessun indirizzo in coda';

                    // log
                        logWrite( 'nessun indirizzo in coda da geolocalizzare', 'geocode', LOG_INFO );

                }

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

            // TODO
                // qui fare l'invio con geocode_send()
                // NOTA la variabile $geocode è ancora valorizzata

        } else {

            // log
                logWrite( 'impossibile acquisire il lock sulle tabelle di coda', 'geocode', LOG_ERR );

        }


    // output
        buildJson( array( 'status' => 'OK' ) );

?>