Subversion Repositories eFlore/Applications.cel

<?php

class Dao extends Bdd {

	private $temps_derniere_requete = 0;

	public function rechercherCoordonnees($conditions = array()) {

		if(!empty($conditions)) {

			$where = 'WHERE '.implode(' AND ', $conditions);

		}

		$requete = "SELECT longitude, latitude ".

			"FROM cel_obs ".

			$where.

			"GROUP BY longitude , latitude ";

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

		$this->reinitialiserTempsDerniereRequete();

		return $resultat;

	}

	public function rechercherCoordonneesFrancaisesSansCorrespondances() {

		$conditions = array(

						$this->getConditionCoordonneesValides(),

						$this->getConditionInfosGeoIncompletes(),

						$this->getConditionlimiteeALaFrance(),

						$this->getConditionModifObsRecente()

					);

		return $this->rechercherCoordonnees($conditions);

	}

	public function rechercherCoordonneesFrancaisesSansCorrespondanceDepuisLeDebut() {

		$conditions = array(

						$this->getConditionCoordonneesValides(),

						$this->getConditionInfosGeoIncompletes(),

						$this->getConditionlimiteeALaFrance()

					);

		return $this->rechercherCoordonnees($conditions);

	}

	public function rechercherPaysSansCorrespondance() {

		$conditions = array(

				$this->getConditionCoordonneesValides(),

				$this->getConditionSansPays(),

				$this->getConditionModifObsRecente()

		);

		return $this->rechercherCoordonnees($conditions);

	}

	public function rechercherPaysSansCorrespondanceDepuisLeDebut() {

		$conditions = array(

				$this->getConditionCoordonneesValides(),

				$this->getConditionSansPays()

		);

		return $this->rechercherCoordonnees($conditions);

	}

	public function rechercherToutSansCorrespondance() {

		$conditions = array(

				$this->getConditionCoordonneesValides(),

				'('.

					$this->getConditionInfosGeoIncompletes().' OR '.

					$this->getConditionSansPays().

				') ',

				$this->getConditionModifObsRecente()

		);

		return $this->rechercherCoordonnees($conditions);

	}

	public function rechercherSansCorrespondanceDepuisLeDebut() {

		$conditions = array(

				$this->getConditionCoordonneesValides(),

				'('.

				$this->getConditionInfosGeoIncompletes().' OR '.

				$this->getConditionSansPays().

				') '

		);

		return $this->rechercherCoordonnees($conditions);

	}

	private function getConditionModifObsRecente() {

		$condition = 'DATE_ADD(date_modification, INTERVAL 25 HOUR) >= CURDATE() ';

		return $condition;

	}

	private function getConditionInfosGeoIncompletes() {

		$condition = '('.

						'ce_zone_geo IS NULL OR ce_zone_geo = "" OR '.

						'zone_geo IS NULL OR zone_geo = "" '.

					 ') ';

		return $condition;

	}

	private function getConditionlimiteeALaFrance() {

		$condition = '('.

						'(latitude <= 51.071667 AND latitude >= 41.316667) AND '.

					 	'(longitude <= 9.513333 AND longitude >= -5.140278) '.

					 ') ';

		return $condition;

	}

	private function getConditionSansPays() {

		$condition = '(pays IS NULL OR pays = "XX" OR pays = "")';

		return $condition;

	}

	private function getConditionCoordonneesValides() {

		$condition = '(latitude IS NOT NULL AND longitude IS NOT NULL '.

					 ' AND latitude != 0 AND latitude != "" '.

					 ' AND longitude != 0 AND longitude != "" ) ';

		return $condition;

	}

	public function creerColonneCodeInseeCalcule() {

		$create = 'ALTER TABLE cel_obs '.

			'ADD code_insee_calcule VARCHAR(5) NOT NULL ';

		$this->requeter($create);

		$this->reinitialiserTempsDerniereRequete();

	}

	public function ajouterCodeInseeCalcule($latitude, $longitude, $code_insee) {

		$insert = 'UPDATE cel_obs '.

			"SET ".

			"code_insee_calcule = ".$this->proteger($code_insee)." ".

			"WHERE latitude = ".$this->proteger($latitude)." ".

			"	AND longitude = ".$this->proteger($longitude)." ";

		$this->requeter($insert);

		$this->reinitialiserTempsDerniereRequete();

	}

	public function modifierCodeInseeEtZoneGeo($coordonnees) {

		$codeP = $this->proteger($coordonnees['code_insee']);

		$codeInseeP = $this->proteger('INSEE-C:'.$coordonnees['code_insee']);

		$nomP = $this->proteger($coordonnees['nom']);

		$update = "UPDATE cel_obs ".

			"SET ".

				"pays = 'FR', ".

				"code_insee_calcule = ".$codeP.", ".

				"ce_zone_geo = ".$codeInseeP.", ".

		    	"zone_geo = IF(zone_geo = '' OR zone_geo = NULL, ".$nomP.", zone_geo) ".

			"WHERE ".

			" latitude = ".$this->proteger($coordonnees['latitude'])." ".

			" AND longitude = ".$this->proteger($coordonnees['longitude'])." ";

		$this->requeter($update);

		$this->reinitialiserTempsDerniereRequete();

	}

	public function modifierPays($coordonnees) {

		$codePaysP = $this->proteger($coordonnees['code_pays']);

		$nomP = $this->proteger($coordonnees['nom']);

		$update = "UPDATE cel_obs ".

				"SET ".

				"pays = ".$codePaysP.", ".

				"zone_geo = IF(zone_geo = '' OR zone_geo = NULL, ".$nomP.", zone_geo) ".

				"WHERE ".

				" latitude = ".$this->proteger($coordonnees['latitude'])." ".

				" AND longitude = ".$this->proteger($coordonnees['longitude'])." ";

		$this->requeter($update);

		$this->reinitialiserTempsDerniereRequete();

	}

	// Il peut se passer assez de temps sans qu'aucune requete ne soit effectuée

	// (cas d'un grand nombre d'enregistrements à la suite pour lesquels on ne trouve

	// aucun département). Pour éviter cela on teste régulièrement la connection

	public function testerActiviteConnection() {

		$temps_courant = microtime(true);

		$temps_depuis_derniere_requete = $temps_courant - $this->temps_derniere_requete;

		if($temps_depuis_derniere_requete >= 18) {

			$this->ping();

			$this->reinitialiserTempsDerniereRequete();

		}

	}

	private function reinitialiserTempsDerniereRequete() {

		$this->temps_derniere_requete = microtime(true);

	}

}