Subversion Repositories eFlore/Projets.eflore-projets

<?php
class Dao extends Bdd {

// +-------------------------------------------------------------------------------------------------------------------+
// Requête d'intégration sur table sophy_publication   
        public function integrerBiblio($biblio){
        $biblio = array_map(array($this, 'proteger'), $biblio);
                $requete = 'INSERT INTO sophy_publication VALUES ('.implode(', ', $biblio).');';
        $resultat = $this->requeter($requete);
                if ($resultat === false) {
                        $info = $biblio['id_publi']." n'est pas intégrée.\n";
                } else {
                        $info = $biblio['id_publi']." est intégrée.\n";
                }
                return $info;
    }
    
// +-------------------------------------------------------------------------------------------------------------------+
// Requête d'intégration sur table sophy_tableau 
        public function integrerTableau($titre) {
                $titre = array_map(array($this, 'proteger'), $titre);
                $requete_integre_tableau = 'INSERT INTO sophy_tableau VALUES ('.implode(', ', $titre).');';
                $reponse_requete_int_tab = $this->requeter($requete_integre_tableau);
                if ($reponse_requete_int_tab === false) {
                        $info = "tableau ".$titre['numPubli']."-".$titre['numTableau']." non intégrée.";
                } else {
                        $info = '';
                }
                return $info;
        }
// +-------------------------------------------------------------------------------------------------------------------+
// Requêtes sur table sophy_station    
        // Requête d'intégration qui retourne l'id de la dernière station insérée (rechercheIdStation)
        public function integrerStation($station) {
                $station = array_map(array($this, 'proteger'), $station);
                $reponse['id_station'] = null;
                $requete_integre_station = 'INSERT INTO sophy_station (`ss_num_source`, `ss_poste_meteo`, `ss_localisation`,
                `ss_latitude`, `ss_pays`, `ss_longitude`,`ss_code_departement`, `ss_altitude`, `ss_code_insee_commune`,
                `ss_ce_precision_geographique`, `ss_systeme_projection`, `ss_latitude_dms`, `ss_longitude_dms`, `ss_latitude_wgs`, 
                `ss_longitude_wgs`, `ss_utmNorthing`, `ss_utmEasting`, `ss_utmZone`) VALUES 
                ('.implode(', ', $station).');';
                
                $reponse_requete_int_stat = $this->requeter($requete_integre_station);
                if ($reponse_requete_int_stat === false) {
                        $reponse['info'] = "station ".$station['numSource']." non intégrée. $requete_integre_station";
                } else {
                        $reponse['id_station'] = $this->rechercheIdStation();
                        $reponse['info'] = '';
                }
                return $reponse;
        }
        
        // Retourne le dernier identifiant de la table station
        public function rechercheIdStation() {
                $requete_select_id = "SELECT MAX(ss_id_station) as idMax FROM sophy_station;";
                $resultat_requete_id = $this->recuperer($requete_select_id);
                return $resultat_requete_id['idMax'];
        }
        
        public function rechercherCoordonneesWgs() {
                $requete = "SELECT `ss_longitude_wgs` as longitude, `ss_latitude_wgs` as latitude
                                        FROM `sophy_station`
                                        GROUP BY `longitude` , `latitude`";
                /* Les stations restantes avec coordonnées sans code insee
                SELECT COUNT( * ) AS `Lignes` , `ss_longitude_wgs` , `ss_latitude_wgs`
                        FROM `sophy_station`
                        WHERE `ss_latitude_wgs` != ''
                        AND `ss_code_insee_calculee` =0
                        GROUP BY `ss_longitude_wgs` , `ss_latitude_wgs`
                        ORDER BY `Lignes` DESC
                                        */
                $resultat = $this->recupererTous($requete);
                return $resultat;
        }
        
        public function creerColonneCodeInseeCalculee() {
                $create = "ALTER TABLE `sophy_station` ADD `ss_code_insee_calculee` VARCHAR( 5 ) NOT NULL ,
                                                ADD INDEX ( `ss_code_insee_calculee` )";
                $this->requeter($create);
        }
        
        public function ajouterCodeInseeCalculee($latitude, $longitude, $code_insee) {
                $insert = "UPDATE `sophy_station` SET `ss_code_insee_calculee` = '$code_insee' ".
                                        "WHERE ss_latitude_wgs = '$latitude' AND ss_longitude_wgs = '$longitude'";
                $this->requeter($insert);
        }
        
// +-------------------------------------------------------------------------------------------------------------------+
// Requête d'intégration sur table sophy_releve     
        public function integrerReleve($titre, $numReleve, $idStation) {
                $requete_integre_releve = "INSERT INTO sophy_releve VALUES (".$titre['numPubli'].", ".
                        $titre['numTableau'].", ".$numReleve.", ".$idStation.");";
                $reponse_requete_int_tab = $this->requeter($requete_integre_releve);
                if ($reponse_requete_int_tab === false) {
                        $info = "releve ".$titre['numPubli']."-".$titre['numTableau']."-".$numReleve." non intégrée.";
                        echo $requete_integre_releve."\n";
                } else {
                        $info = '';
                }
                return $info;
        }
        
// +-------------------------------------------------------------------------------------------------------------------+
// Requête d'intégration sur table sophy_observation     
        public function integrerObservation($observations) {
                $requete = "INSERT INTO `sophy_observation` (`so_id_publi`, `so_id_tableau`, `so_id_releve`, `so_num_ligne`,".
                 " `so_id_taxon`, `so_id_strate`, `so_ce_abondance`) VALUES ";
                foreach ($observations as $plante) {
                        if (isset($plante)) {
                                foreach ($plante as $observation) {
                                        $observation = array_map(array($this, 'proteger'), $observation);
                                        $requete .= " (".implode(', ', $observation)." ),";
                                }
                        }
                }
                $requete = substr($requete,0,-1).";";
                $resultat = $this->requeter($requete);
                if ($resultat === false) {
                        echo $requete."\n";
                        $info = " n'est pas intégrée.\n";
                } else {
                        $info = '';
                }
                return $info;
        }
        
        
// +-------------------------------------------------------------------------------------------------------------------+        
//      Requête pour calculer les statistiques sur toutes les tables
        public function getNombreLigne($tables) {
                $requete = null;
                foreach ($tables as $nomTable => $colonnes) {
                        $requete = "SELECT COUNT(*) as nombreTotal";
                        foreach ($colonnes as $recherche => $nom) {
                                $requete .= ", count(distinct {$recherche}) as {$nom}";
                        }
                        $requete .= " FROM {$nomTable}; ";
                        $resultat[$nomTable] = $this->recupererTous($requete);
                }
                return $resultat;
        }
        
// +-------------------------------------------------------------------------------------------------------------------+
// Requête de création et d'insertion sur table sophy_tapir     
        public function creerTapir() {
                $info = 'Créé';
                $requete = "DROP TABLE IF EXISTS `sophy_tapir`;
                        CREATE table `sophy_tapir` AS 
                                SELECT CONCAT(_utf8'urn:lsid:tela-botanica.org:sophy:',o.so_id_publi,'.',
                                                o.so_id_tableau,'.',o.so_id_releve,'.',o.so_num_ligne,'.',
                                                o.so_id_taxon,'.',o.so_id_strate) AS `guid`, 
                                        CONCAT(o.so_id_publi,'.',o.so_id_tableau,'.',o.so_id_releve,'.',
                                                o.so_num_ligne,'.',o.so_id_taxon,'.',o.so_id_strate) AS `observation_id`,       
                                        p.sp_date AS observation_date,
                                        t.st_nom AS nom_scientifique_complet, 
                                        CONCAT(s.ss_code_departement,s.ss_code_insee_commune) AS lieu_commune_code_insee, 
                                        s.ss_localisation AS `lieu_station_nom`,
                                        s.ss_latitude_wgs AS `lieu_station_latitude`,
                                        s.ss_longitude_wgs AS `lieu_station_longitude`,
                                        s.ss_utmEasting AS `lieu_station_utm_est`, 
                                        s.ss_utmNorthing AS `lieu_station_utm_nord`,
                                        s.ss_utmZone AS `lieu_station_utm_zone`,
                                        p.sp_auteur AS observateur_nom_complet
                                FROM sophy_observation o LEFT JOIN sophy_taxon t ON (o.so_id_taxon = t.st_id_taxon)
                                        LEFT JOIN sophy_releve r ON (r.sr_id_publi = o.so_id_publi AND r.sr_id_tableau = o.so_id_tableau AND r.sr_id_releve = o.so_id_releve ) 
                                        LEFT JOIN sophy_station s ON (r.sr_id_station = s.ss_id_station)  
                                        LEFT JOIN sophy_publication p ON (r.sr_id_publi = p.sp_id_publi);";
                $reponse = $this->requeter($requete);
                if ($reponse === false) {
                        $info = "Erreur";
                }       
                return $info;
        }
}
?>