Subversion Repositories eFlore/Applications.cel

Rev

Go to most recent revision | Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
1500 delphine 1
<?php
2
class Dao extends Bdd {
2436 jpm 3
 
1520 aurelien 4
	private $temps_derniere_requete = 0;
2436 jpm 5
 
2527 aurelien 6
	public function rechercherCoordonnees($conditions = array()) {
7
		if(!empty($conditions)) {
8
			$where = 'WHERE '.implode(' AND ', $conditions);
9
		}
10
 
1523 aurelien 11
		$requete = "SELECT longitude, latitude ".
12
			"FROM cel_obs ".
2527 aurelien 13
			$where.
1523 aurelien 14
			"GROUP BY longitude , latitude ";
2527 aurelien 15
 
1500 delphine 16
		$resultat = $this->recupererTous($requete);
1520 aurelien 17
		$this->reinitialiserTempsDerniereRequete();
1500 delphine 18
		return $resultat;
19
	}
2436 jpm 20
 
2527 aurelien 21
	public function rechercherCoordonneesSansCorrespondances() {
22
		$conditions = array(
23
						$this->getConditionCoordonneesValides(),
24
						$this->getConditionInfosGeoIncompletes(),
25
						$this->getConditionlimiteeALaFrance(),
26
						$this->getConditionModifObsRecente()
27
					);
28
 
29
		return $this->rechercherCoordonnees($conditions);
1517 aurelien 30
	}
2525 aurelien 31
 
32
	public function rechercherCoordonneesSansCorrespondanceDepuisLeDebut() {
2527 aurelien 33
		$conditions = array(
34
						$this->getConditionCoordonneesValides(),
35
						$this->getConditionInfosGeoIncompletes(),
36
						$this->getConditionlimiteeALaFrance()
37
					);
38
 
39
		return $this->rechercherCoordonnees($conditions);
2525 aurelien 40
	}
2527 aurelien 41
 
42
 
43
	private function getConditionModifObsRecente() {
44
		$condition = 'DATE_ADD(date_modification, INTERVAL 25 HOUR) >= CURDATE() ';
45
		return $condition;
46
	}
47
 
48
	private function getConditionInfosGeoIncompletes() {
49
		$condition = '('.
2528 aurelien 50
						'ce_zone_geo IS NULL OR ce_zone_geo = "" OR '.
51
						'zone_geo IS NULL OR zone_geo = "" '.
2527 aurelien 52
					 ') ';
53
		return $condition;
54
	}
55
 
56
	private function getConditionlimiteeALaFrance() {
57
		$condition = '('.
58
						'(latitude <= 51.071667 AND latitude >= 41.316667) AND '.
59
					 	'(longitude <= 9.513333 AND longitude >= -5.140278) '.
60
					 ') ';
61
		return $condition;
62
	}
63
 
64
	private function getConditionCoordonneesValides() {
65
		$condition = '(latitude IS NOT NULL AND longitude IS NOT NULL '.
66
					 ' AND latitude != 0 AND latitude != "" '.
67
					 ' AND longitude != 0 AND longitude != "" ) ';
68
		return $condition;
69
	}
2436 jpm 70
 
1523 aurelien 71
	public function creerColonneCodeInseeCalcule() {
72
		$create = 'ALTER TABLE cel_obs '.
73
			'ADD code_insee_calcule VARCHAR(5) NOT NULL ';
1500 delphine 74
		$this->requeter($create);
1520 aurelien 75
		$this->reinitialiserTempsDerniereRequete();
1500 delphine 76
	}
2436 jpm 77
 
1523 aurelien 78
	public function ajouterCodeInseeCalcule($latitude, $longitude, $code_insee) {
79
		$insert = 'UPDATE cel_obs '.
2527 aurelien 80
			"SET ".
81
			"code_insee_calcule = ".$this->proteger($code_insee)." ".
1523 aurelien 82
			"WHERE latitude = ".$this->proteger($latitude)." ".
83
			"	AND longitude = ".$this->proteger($longitude)." ";
1500 delphine 84
		$this->requeter($insert);
1520 aurelien 85
		$this->reinitialiserTempsDerniereRequete();
1500 delphine 86
	}
2436 jpm 87
 
1523 aurelien 88
	public function modifierCodeInseeEtZoneGeo($coordonnees) {
2528 aurelien 89
 
90
		$codeP = $this->proteger($coordonnees['code_insee']);
91
		$codeInseeP = $this->proteger('INSEE-C:'.$coordonnees['code_insee']);
92
		$nomP = $this->proteger($coordonnees['nom']);
93
 
1523 aurelien 94
		$update = "UPDATE cel_obs ".
2527 aurelien 95
			"SET ".
2528 aurelien 96
				"code_insee_calcule = ".$codeP.", ".
97
				"ce_zone_geo = ".$codeInseeP.", ".
98
		    	"zone_geo = IF(zone_geo = '' OR zone_geo = NULL, ".$nomP.", zone_geo) ".
2527 aurelien 99
			"WHERE ".
100
			" latitude = ".$this->proteger($coordonnees['latitude'])." ".
101
			" AND longitude = ".$this->proteger($coordonnees['longitude'])." ";
1500 delphine 102
		$this->requeter($update);
1520 aurelien 103
		$this->reinitialiserTempsDerniereRequete();
1500 delphine 104
	}
2436 jpm 105
 
1520 aurelien 106
	// Il peut se passer assez de temps sans qu'aucune requete ne soit effectuée
107
	// (cas d'un grand nombre d'enregistrements à la suite pour lesquels on ne trouve
108
	// aucun département). Pour éviter cela on teste régulièrement la connection
109
	public function testerActiviteConnection() {
110
		$temps_courant = microtime(true);
111
		$temps_depuis_derniere_requete = $temps_courant - $this->temps_derniere_requete;
112
		if($temps_depuis_derniere_requete >= 18) {
113
			$this->ping();
114
			$this->reinitialiserTempsDerniereRequete();
115
		}
116
	}
2436 jpm 117
 
1520 aurelien 118
	private function reinitialiserTempsDerniereRequete() {
119
		$this->temps_derniere_requete = microtime(true);
120
	}
2436 jpm 121
}