Subversion Repositories Sites.obs-saisons.fr

<?php

class Maintenance extends JRestService {

	/**

     * Méthode appelée avec une requête de type GET.

     *

     */

    function executer($param = array()) {

    	$debut = microtime(true);

    	echo "Recherche des stations ayant des coordonnées mais aucune commune associee ...";

		$requete = "SELECT * FROM `ods_stations` WHERE os_ce_commune NOT REGEXP '^-?[0-9]+$' AND os_ce_commune NOT IN (SELECT oc_code_insee FROM ods_communes)";

		$liste_stations = $this->executerRequete($requete);

		echo " ".count($liste_stations)." stations trouvées \n";

		echo "Début de la recherche des communes associées \n";

		$recherche_infos = new OdsCommune($this->config);

		$communes_inconnues = array();

		$infos_stations_completees = array();

		foreach($liste_stations as $station) {

			$infos_code_insee = $this->effectuerRechercheCommune($station['os_latitude'], $station['os_longitude']);

			$infos_code_insee['ancien_nom'] = $station['os_ce_commune'];

			$infos_code_insee['lat'] = $station['os_latitude'];

			$infos_code_insee['lon'] = $station['os_longitude'];

			if($infos_code_insee['certitude'] == "ok") {

				$infos_stations_completees[$station['os_id_station']] = $infos_code_insee;

			} else {

				$communes_inconnues[$station['os_id_station']] = $infos_code_insee;

			}

		}

		echo "Fin de la recherche :  \n";

		echo "  - ".count($infos_stations_completees)." stations se verront affecter un code insee \n";

		echo "  - ".count($communes_inconnues)." stations ne correspondent à aucune commune connue  \n";

		file_put_contents($this->config["appli"]["chemin_fichiers_temp"]."/communes_inconnues.txt", print_r($communes_inconnues, true));

		file_put_contents($this->config["appli"]["chemin_fichiers_temp"]."/communes_localisees.txt", print_r($infos_stations_completees, true));

		$fin = microtime(true) - $debut;

		echo "La recherche à pris ".$fin." secondes \n";

		echo "Modification des stations dont la certitude est ok \n";

		$suite = microtime(true);

		foreach($infos_stations_completees as $id_station => $infos_station) {

			$requete = "UPDATE ods_stations SET os_ce_commune = ".$this->proteger($infos_station['codeINSEE'])." WHERE os_id_station = ".$this->proteger($id_station);

			$this->executerRequeteSimple($requete);

		}

		$suite_et_fin = microtime(true) - $suite;

		echo "Fin de modification des stations concernées \n";

		echo "La mise à jour de la base a pris ".$suite_et_fin." secondes \n";

		echo "Les stations non modifiées sont disponibles dans le fichier situé dans ".$this->config["appli"]["chemin_fichiers_temp"]."/communes_inconnues.txt \n";

    }

    function effectuerRechercheCommune($lat, $lon) {

    	$url_commune = "http://api.tela-botanica.org/service:eflore:0.1/osm/nom-commune?lon=".urlencode($lon)."&lat=".urlencode($lat);

    	$infos_commune_json = @file_get_contents($url_commune);

    	$infos = null;

    	if($infos_commune_json != null) {

    		$infos_d = json_decode($infos_commune_json, true);

    		if(isset($infos_d['codeINSEE']) && trim($infos_d['codeINSEE']) != "") {

    			$infos_d['source'] = 'osm';

    			$infos = $infos_d;

    			$infos['certitude'] = 'ok';

    		} else {

    			$infos = $this->rechercherParGoogleMaps($lat, $lon);

    		}

    	} else {

    		$infos = $this->rechercherParGoogleMaps($lat, $lon);

    	}

    	return $infos;

    }

    private function rechercherParGoogleMaps($lat, $lon) {

    	$url_commune_fallback = "https://maps.googleapis.com/maps/api/geocode/json?latlng=".urlencode($lat).",".urlencode($lon)."&sensor=false";

    	$infos = $this->decoderRetourGoogleMaps(@file_get_contents($url_commune_fallback));

    	return $infos;

    }

    private function decoderRetourGoogleMaps($retour) {

    	$nom = null;

    	$code_postal = null;

    	$retour_infos_tpl = array("certitude" => "bof", "source" => "google", "nom" => "", "codeINSEE" => "");

    	if($retour != null) {

    		$retour = json_decode($retour, true);

    		if(isset($retour['results']) && count($retour['results']) != 0) {

    			$infos_commune = $retour['results'][0];

    			foreach($infos_commune['address_components'] as $tranche) {

    				if(isset($tranche['types'])) {

    					if(in_array('locality',$tranche['types'])) {

    						$nom = $tranche['long_name'];

    					}

    					if(in_array('postal_code',$tranche['types'])) {

    						$code_postal = $tranche['long_name'];

    					}

    					if($nom != null && $code_postal != null) {

    						break;

    					}

    				}

    			}

    		}

    	}

    	if($nom != null && $code_postal != null) {

	    	$dpt = substr($code_postal, 0, 2);

	    	$dpt = $dpt."___";

	    	// le retour de google maps est un code postal et pas un code insee

	    	$requete = "SELECT oc_code_insee FROM ods_communes WHERE oc_nom LIKE ".$this->proteger($nom."%")." AND oc_code_insee LIKE ".$this->proteger($dpt);

	    	$resultat = $this->executerRequete($requete);

	    	if(!empty($resultat)) {

	    		$retour_infos[1] = $resultat[0]['oc_code_insee'];

	    		$retour_infos_tpl = array(

	    							"certitude" => "ok",

	    							"source" => "google",

	    							"nom" => $nom,

	    							"codeINSEE" => $resultat[0]['oc_code_insee']);

	    	} else {

	    		$retour_infos_tpl = array(

	    							"certitude" => "douteux",

	    							"source" => "google",

	    							"nom" => $nom,

	    							"codeINSEE" => $code_postal);

	    	}

    	}

    	return $retour_infos_tpl;

    }

}

?>