Subversion Repositories eFlore/Applications.cel

<?php
class Dao extends Bdd {

        private $temps_derniere_requete = 0;

        public function rechercherCoordonnees() {
                $requete = "SELECT longitude, latitude ".
                        "FROM cel_obs ".
                        "GROUP BY longitude , latitude ";
                $resultat = $this->recupererTous($requete);
                $this->reinitialiserTempsDerniereRequete();
                return $resultat;
        }

        public function rechercherCoordonneesSansCorrespondances() {
                $requete = 'SELECT longitude, latitude '.
                        'FROM cel_obs '.
                        "WHERE code_insee_calcule = '' ".
                        '       AND DATE_ADD(date_modification, INTERVAL 25 HOUR) >= CURDATE() '.
                        'GROUP BY longitude , latitude ';
                $resultat = $this->recupererTous($requete);
                $this->reinitialiserTempsDerniereRequete();
                return $resultat;
        }

        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) {
                $update = "UPDATE cel_obs ".
                        "SET ce_zone_geo = CONCAT('INSEE-C:' , code_insee_calcule), ".
                        "zone_geo = ".$this->proteger($coordonnees['nom'])." ".
                        "WHERE ce_zone_geo = '' AND zone_geo = '' ".
                        "       AND 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);
        }
}