observations ayant tous les mots-clés (intersection) * machin OU bildule OU chose => observations ayant au moins un des mots-clés (union) * ATTENTION * machin ET bidule OU chose donne un résultat indéterminé pour l'instant * * @internal Mininum PHP version : 5.2 * @category CEL * @package Services * @subpackage Widget * @version 0.1 * @author Mathias CHOUET * @author Jean-Pascal MILCENT * @author Aurelien PERONNET * @license GPL v3 * @license CECILL v2 * @copyright 1999-2014 Tela Botanica */ // TODO : supprimer le TRIM quand les obs seront reliées correctements aux localisations (sur le code INSEE par exemple) class CelWidgetMapPoint extends Cel { const MARQUEUR_GROUPE = 'GROUPE'; const MARQUEUR_COMMUNE = 'COMMUNE'; const MARQUEUR_STATION = 'STATION'; private $standard = "1"; private $table_export = "cel_export"; /** * Méthode appelée avec une requête de type GET. */ public function getElement($ressources) { $retour = null; if($this->parametres == null) { $this->parametres = array(); } extract($this->parametres); //Chronometre::chrono("Avant groupage"); if (isset($this->parametres['standard']) && $this->parametres['standard'] == 0) { $this->standard = "0"; $this->table_export = "cel_export_total"; } $action = array_shift($ressources); if (isset($action)) { $methode = $this->traiterNomMethodeGet($action); if (method_exists($this, $methode)) { $retour = $this->$methode($ressources); } else { $this->messages[] = "Ce type de ressource '$methode' n'est pas disponible."; } } else { $this->messages[] = "Vous devez indiquer le type de ressource."; } //Chronometre::chrono("Apres traitement"); //echo Chronometre::afficherChrono(); if (is_null($retour)) { $info = 'Un problème est survenu : '.print_r($this->messages, true); $this->envoyer($info); } else if (isset($retour['type']) && $retour['type'] == 'jsonVar') { $this->envoyerJsonVar($retour['variable_js'], $retour['donnees']); } else if (isset($retour['type']) && $retour['type'] == 'jsonP') { $this->envoyerJsonp($retour['donnees']); } else if (isset($retour['type']) && $retour['type'] == 'png') { header("Content-type: image/png"); imagepng($retour['img']); imagedestroy($retour['img']); } else { $this->envoyerJson($retour); } } /** * Les icones des groupes de stations */ public function getIconeGroupe($params) { extract($this->parametres); $chemin_marqueur = sprintf($this->config['settings']['cheminCelMarkerObsTpl'], $type); $img = imagecreatefrompng($chemin_marqueur); $noir = imagecolorallocate($img, 0, 0, 0); $texte = (String) $nbre; $x = (imagesx($img) - 6.0 * strlen($texte)) / 2; $y = (imagesy($img) - 16) / 2; imagestring($img, 3, $x, $y, $texte, $noir); imagealphablending($img, false); imagesavealpha($img, true); return array('type' => 'png', 'img' => $img); } public function getTout($params) { $emplacements = null; $concatenation_id = "CONCAT(IFNULL(latitude,''),IFNULL(longitude,'')) "; $transmission = ( $this->standard == 0) ? "transmission = '1' AND " : ""; $requete = 'SELECT distinct ce_zone_geo, zone_geo, NULL as station, '. "NULL as mots_cles_texte, ". "latitude, ". "NULL as wgs84_latitude, ". "longitude, ". "NULL as wgs84_longitude, ". $concatenation_id." as id_coord ". 'FROM '.$this->table_export.' AS co '. "WHERE ".$transmission. " (". $this->construireWhereRectangleStationOR()." ". $this->construireWhereRectangleCommuneOR().") ". $this->construireWhereDept(). $this->construireWhereCommune(). $this->construireWherePays(). $this->construireWhereUtilisateur(). $this->construireWhereNumTaxonAvecSousTaxons(). $this->construireWhereNomTaxon(). $this->construireWhereReferentiel(). $this->construireWhereDate(). $this->construireWhereCommentaire(). $this->construireWherePhotosSeulement(). $this->construireWhereProjet(). $this->construireWhereTag(). $this->construireWhereNombreDeJours(). $this->construireWhereAnnee(). $this->construireWhereGroupeZoneGeo(); $resultats_emplacements = Cel::db()->requeter($requete); $emplacements = $this->traiterEmplacements($resultats_emplacements, $this->compterObservations($params)); return $emplacements; } private function afficherRequeteFormatee($requete) { $requete = str_replace(')',')
',$requete); $requete = str_replace('(','
(',$requete); echo '
'.$requete.'
'; exit; } private $nb_obs = 0; private function compterObservations($params) { $transmission = ( $this->standard == 0) ? "transmission = '1' AND " : ""; $requete = 'SELECT COUNT(*) as nb '. 'FROM '.$this->table_export.' AS co '. "WHERE ".$transmission. " (". $this->construireWhereRectangleStationOR()." OR ". $this->construireWhereRectangleCommuneOR().") ". $this->construireWhereDept(). $this->construireWhereCommune(). $this->construireWherePays(). $this->construireWhereUtilisateur(). $this->construireWhereNumTaxonAvecSousTaxons(). $this->construireWhereNomTaxon(). $this->construireWhereReferentiel(). $this->construireWhereDate(). $this->construireWhereCommentaire(). $this->construireWherePhotosSeulement(). $this->construireWhereProjet(). $this->construireWhereTag(). $this->construireWhereNombreDeJours(). $this->construireWhereAnnee(). $this->construireWhereGroupeZoneGeo(); $resultats_nb_obs = Cel::db()->requeter($requete); return $resultats_nb_obs[0]['nb']; } private function traiterEmplacements(&$emplacements, $nb_total_observation) { $zoom = (int) array_key_exists('zoom', $this->parametres) ? $this->parametres['zoom'] : 11; $distance = (int) array_key_exists('distance', $this->parametres) ? $this->parametres['distance'] : 20; $marqueurs = array( 'stats' => array('stations' => 0, 'communes' => 0, 'observations' => 0), 'points' => null ); if (isset($this->parametres['ne']) && $this->parametres['sw'] && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) { $ne = $this->decomposerLatLng($this->parametres['ne']); $sw = $this->decomposerLatLng($this->parametres['sw']); $marqueurs['points'] = CartoGroupage::creerGroupesQuadtree($emplacements, $ne['lat'], $ne['lng'], $sw['lat'], $sw['lng'], $zoom); // laisser la classe cartoGroupage compter les élements simplifie le comptage // et permet de ne pas reparser le tableau pour compter les différents éléments $nb_elements = CartoGroupage::getNbElements(); // les bornes servent à centrer la carte dans le cas ou l'on demande des paramètres précis $marqueurs['stats']['coordmax'] = CartoGroupage::getBornes(); $marqueurs['stats']['stations'] = $nb_elements['stations']; $marqueurs['stats']['communes'] = $nb_elements['communes']; $marqueurs['stats']['observations'] = (int)$nb_total_observation; } else { $marqueurs['points'] = $emplacements; } return $marqueurs; } private function traiterStations($communes, $stations) { $zoom = (int) array_key_exists('zoom', $this->parametres) ? $this->parametres['zoom'] : 11; $distance = (int) array_key_exists('distance', $this->parametres) ? $this->parametres['distance'] : 20; $marqueurs = array( 'stats' => array('stations' => 0, 'communes' => 0, 'observations' => 0), 'points' => null ); $marqueurs['stats']['observations'] = $this->traiterNbreObs($communes) + $this->traiterNbreObs($stations); $points = array(); if ($communes !== false) { foreach ($communes as $commune) { if (is_numeric($commune['lat']) && is_numeric($commune['lng'])) { extract($commune); $id = self::MARQUEUR_COMMUNE.':'.$lat.'|'.$lng; $lata = round($lat, 5); $lnga = round($lng, 5); if (!isset($points[$id])) { $points[$id]['id'] = $id; $points[$id]['nom'] = $nom; $points[$id]['lat'] = $lata; $points[$id]['lng'] = $lnga; $points[$id]['nbre'] = 1; $marqueurs['stats']['communes']++; } else { $points[$id]['nbre']++; } } } } if ($stations !== false) { foreach ($stations as $station) { if (is_numeric($station['lat']) && is_numeric($station['lng'])) { extract($station); $id = self::MARQUEUR_STATION.':'.$lat.'|'.$lng; $lata = round($lat, 5); $lnga = round($lng, 5); $nom = $this->etreNull($nom) ? $lata.','.$lnga : $nom; if (!isset($points[$id])) { $points[$id]['id'] = $id; $points[$id]['nom'] = $nom; $points[$id]['lat'] = $lata; $points[$id]['lng'] = $lnga; $points[$id]['nbre'] = 1; $marqueurs['stats']['stations']++; } else { $points[$id]['nbre']++; } } } } if (isset($this->parametres['ne']) && $this->parametres['sw'] && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) { $ne = $this->decomposerLatLng($this->parametres['ne']); $sw = $this->decomposerLatLng($this->parametres['sw']); $marqueurs['points'] = CartoGroupage::creerGroupesQuadtree($points, $ne['lat'], $ne['lng'], $sw['lat'], $sw['lng'], $zoom); } else { $marqueurs['points'] = $points; } //$marqueurs['stats']['latDiff'] = abs($marqueurs['stats']['latMin'] - $marqueurs['stats']['latMax']); //$marqueurs['stats']['lngDiff'] = abs($marqueurs['stats']['lngMin'] - $marqueurs['stats']['lngMax']); return $marqueurs; } private function definirLatLngMaxMin(&$marqueurs, $lat, $lng) { if ($lat != null && $lng != null) { $marqueurs['stats']['latMin'] = $marqueurs['stats']['latMin'] > $lat ? $lat : $marqueurs['stats']['latMin']; $marqueurs['stats']['lngMin'] = $marqueurs['stats']['lngMin'] > $lng ? $lng : $marqueurs['stats']['lngMin']; $marqueurs['stats']['latMax'] = $marqueurs['stats']['latMax'] < $lat ? $lat : $marqueurs['stats']['latMax']; $marqueurs['stats']['lngMax'] = $marqueurs['stats']['lngMax'] < $lng ? $lng : $marqueurs['stats']['lngMax']; } } private function traiterNbreObs($resultats) { $obs_nbre = 0; if ($resultats !== false) { $obs_nbre = count($resultats); } return $obs_nbre; } private function verifierLatLng($lat, $lng) { $ok_lat = $this->etreLatitude($lat) ? true : false; $ok_lng = $this->etreLongitude($lng) ? true : false; $ok = $ok_lat && $ok_lng; return $ok; } private function etreLatitude($lat) { $ok = false; //$format = preg_match('/^[-]?[0-9]+(?:[.][0-9]+|)$/', $lat) ? true : false; $ok = ($lat >= -90 && $lat <= 90) ? true : false; return $ok; } private function etreLongitude($lng) { $ok = false; //$format = preg_match('/^[-]?[0-9]+(?:[.][0-9]+|)$/', $lng) ? true : false; $ok = ($lng >= -180 && $lng <= 180) ? true : false; return $ok; } /* à changer pour localisation_floutage */ private function etreObsSensible($tags) { $sensible = true; if (stristr($tags, 'sensible') === FALSE) { $sensible = false; } return $sensible; } private function communeEstDemandee() { $station_infos = $this->decomposerParametreStation(); $commune_demandee = true; if($station_infos['type'] == self::MARQUEUR_STATION) { $commune_demandee = false; } return $commune_demandee; } /** * Données pour l'affichage des obs d'une station */ public function getObservations($params) { $resultats = array(); $total = 0; $transmission = ( $this->standard == 0) ? "transmission = '1' " : " 1 "; if (isset($this->parametres['station']) && !$this->etreNull($this->parametres['station'])) { $requete = 'SELECT SQL_CALC_FOUND_ROWS id_observation, ce_utilisateur, courriel_utilisateur, pseudo_utilisateur as nom_utilisateur, "" as prenom_utilisateur, '. ' nom_sel, nom_ret, nom_sel_nn, nom_ret_nn, "" as nt, famille, '. ' lieudit, zone_geo, date_observation, milieu, commentaire, '. ' null as utm_secteur, null as utm_x, null as utm_y, ce_zone_geo as code, date_transmission, nom_referentiel '. 'FROM '.$this->table_export.' AS co '. "WHERE ".$transmission. (($this->communeEstDemandee()) ? $this->construireWhereCommuneSansCoordonneesAvecSensibles() : $this->construireWhereCoordonneesSansSensibles()). $this->construireWhereDept(). $this->construireWherePays(). $this->construireWhereUtilisateur(). $this->construireWhereNumTaxonAvecSousTaxons(). $this->construireWhereNomTaxon(). $this->construireWhereReferentiel(). $this->construireWhereDate(). $this->construireWhereCommentaire(). $this->construireWherePhotosSeulement(). $this->construireWhereProjet(). $this->construireWhereTag(). $this->construireWhereNombreDeJours(). $this->construireWhereAnnee(). $this->construireWhereGroupeZoneGeo(). 'ORDER BY nom_sel ASC '. "LIMIT {$this->start},{$this->limit} "; //echo $requete;exit; $resultats = Cel::db()->requeter($requete, self::SQL_RETOUR_COMPLET, self::SQL_MODE_OBJET); $requete = 'SELECT FOUND_ROWS()'; $total = (int) Cel::db()->requeter($requete, self::SQL_RETOUR_COLONNE); } // Post-traitement $observations = $this->traiterObservations($resultats, $total); $observations = $this->ajouterImagesAuxObs($observations); $observations = $this->ajouterAuteursAuxObs($observations); $observations = $this->supprimerIdDesObs($observations); return $observations; } private function traiterObservations($donnees, $total) { $observations = array('commune' => '', 'observations' => array(), 'observateurs' => array()); $observations['total'] = (isset($total)) ? $total : 0; if (is_array($donnees) && count($donnees) > 0) { foreach ($donnees as $donnee) { //echo '
'.print_r($donnee,true).'
';exit; $observation = array(); $observation['idObs'] = $donnee->id_observation; $observation['nn'] = $this->etreNull($donnee->nom_sel_nn) ? null : $donnee->nom_sel_nn; $observation['nomSci'] = $this->nettoyerTexte($donnee->nom_sel); $observation['date'] = ($donnee->date_observation != '0000-00-00 00:00:00') ? $this->formaterDate($donnee->date_observation, '%d/%m/%Y') : ''; $observation['datePubli'] = $this->formaterDate($donnee->date_transmission); $observation['lieu'] = $this->traiterLieu($donnee); $observation['observateur'] = $donnee->courriel_utilisateur; $observation['observateurId'] = $donnee->ce_utilisateur; $observation['urlEflore'] = $this->getUrlEflore($donnee->nom_referentiel, $donnee->nom_sel_nn); if (isset($donnee->zone_geo)) { $observations['commune'] = $this->nettoyerTexte($donnee->zone_geo); } $observations['observations'][$donnee->id_observation] = $observation; if (! array_key_exists($donnee->ce_utilisateur, $observations['observateurs'])) { $observations['observateurs'][$donnee->courriel_utilisateur] = $donnee->courriel_utilisateur; } } } return $observations; } private function traiterLieu($donnee) { $lieu = array(); if (!$this->etreNull($donnee->lieudit)) { $lieu[] = $donnee->lieudit; } if (!$this->etreNull($donnee->milieu)) { $lieu[] = $donnee->milieu; } return implode(', ', $lieu); } private function chargerImages(Array $obs_ids) { // Récupération des données au format Json $service = 'CelImage/liste-ids?obsId='.implode(',', $obs_ids); $url = sprintf($this->config['settings']['baseURLServicesCelTpl'], $service); $json = $this->getRestClient()->consulter($url); $donnees = json_decode($json); // Post-traitement des données $images = $this->traiterImages($donnees); return $images; } private function traiterImages($donnees) { $images = array(); if (count($donnees) > 0) { foreach ($donnees as $id_obs => $id_images) { foreach ($id_images as $id_img) { $urls['idImg'] = $id_img; $urls['guid'] = sprintf($this->config['settings']['guidImgTpl'], $id_img); $urls['miniature'] = $this->getUrlImage($id_img, 'CXS'); $urls['normale'] = $this->getUrlImage($id_img, 'XL'); $images[$id_obs][] = $urls; } } } return $images; } private function ajouterImagesAuxObs($observations) { $images = $this->chargerImages(array_keys($observations['observations'])); foreach ($observations['observations'] as $id => $infos) { if(isset($images[$id])) { $infos['images'] = $images[$id]; $observations['observations'][$id] = $infos; } } return $observations; } private function ajouterAuteursAuxObs($observations) { $observateurs = $this->recupererUtilisateursIdentite(array_keys($observations['observateurs'])); unset($observations['observateurs']); foreach ($observations['observations'] as $id => $infos) { $courriel = strtolower($infos['observateur']); if(isset($observateurs[$courriel])) { $infos['observateur'] = $observateurs[$courriel]['intitule']; $infos['observateurId'] = $observateurs[$courriel]['id']; } $observations['observations'][$id] = $infos; } return $observations; } private function supprimerIdDesObs($observations) { // Le tableau de sortie ne doit pas avoir les id des obs en clé car sinon Jquery Template ne fonctionne pas $observationSansId = $observations; unset($observationSansId['observations']); foreach ($observations['observations'] as $id => $infos) { $observationSansId['observations'][] = $infos; } return $observationSansId; } /** * Liste des taxons présents sur la carte */ public function getTaxons($params) { $json = null; $transmission = ( $this->standard == 0) ? "transmission = '1' AND " : ""; $requete = 'SELECT SQL_CALC_FOUND_ROWS DISTINCT nom_ret, nom_ret_nn, nt, famille '. 'FROM '.$this->table_export.' AS co '. "WHERE ".$transmission. " nom_ret != '' ". $this->construireWhereDept(). $this->construireWhereCommune(). $this->construireWherePays(). $this->construireWhereUtilisateur(). $this->construireWhereNumTaxon(). $this->construireWhereNomTaxon(). $this->construireWhereReferentiel(). $this->construireWhereDate(). $this->construireWhereCommentaire(). $this->construireWherePhotosSeulement(). $this->construireWhereProjet(). $this->construireWhereTag(). $this->construireWhereNombreDeJours(). $this->construireWhereAnnee(). $this->construireWhereGroupeZoneGeo(). 'ORDER BY nom_ret ASC '. "LIMIT {$this->start},{$this->limit} "; //$this->debug[] = $requete; $resultats = Cel::db()->requeter($requete, self::SQL_RETOUR_COMPLET, self::SQL_MODE_OBJET); //echo $requete;exit; $requete = 'SELECT FOUND_ROWS()'; $taxons['total'] = (int) Cel::db()->requeter($requete, self::SQL_RETOUR_COLONNE); // Post-traitement $taxons['taxons'] = $this->traiterTaxons($resultats); return $taxons; } private function traiterTaxons($donnees) { $taxons = array(); if (is_array($donnees) && count($donnees) > 0) { foreach ($donnees as $donnee) { if (!isset($taxons[$donnee->nt]) && ! $this->etreNull($donnee->nom_ret)) { $taxon = array(); $taxon['nn'] = $donnee->nom_ret_nn; $taxon['nt'] = $donnee->nt; $taxon['nom'] = $this->nettoyerTexte($donnee->nom_ret); $taxon['famille'] = $this->nettoyerTexte($donnee->famille); $taxons[$donnee->nt] = $taxon; } } } $taxons = array_values($taxons); return $taxons; } private function construireWhereCoordonnees() { $sql = ''; // Récupération des coordonnées depuis l'id station extract($this->decomposerParametreStation()); if (isset($type)) { if ($type == self::MARQUEUR_COMMUNE) { $lat = Cel::db()->proteger($lat.'%'); $lng = Cel::db()->proteger($lng.'%'); //$sql = " AND wgs84_latitude LIKE $lat AND wgs84_longitude LIKE $lng "; } else if ($type == self::MARQUEUR_STATION) { $lat = Cel::db()->proteger($lat.'%'); $lng = Cel::db()->proteger($lng.'%'); $sql = " AND (latitude LIKE $lat AND longitude LIKE $lng) "; } } return $sql; } private function construireWhereCoordonneesSansSensibles() { $sql = '('; // Récupération des coordonnées depuis l'id station extract($this->decomposerParametreStation()); if (isset($type)) { if ($type == self::MARQUEUR_COMMUNE) { $lat = Cel::db()->proteger($lat); $lng = Cel::db()->proteger($lng); //$sql = " AND wgs84_latitude LIKE $lat AND wgs84_longitude LIKE $lng "; } else if ($type == self::MARQUEUR_STATION) { $lat = Cel::db()->proteger($lat.'%'); $lng = Cel::db()->proteger($lng.'%'); $sql = " AND (latitude LIKE $lat AND longitude LIKE $lng) "; } } //$sql .= ' AND (localisation_floutage IS NULL OR localisation_floutage = "précise" ) '; return $sql; } private function construireWhereCommentaire() { $sql = ''; list($type, $commentaire) = $this->decomposerParametreCommentaire(); if (!$this->etreNull($commentaire)) { $commentaire = Cel::db()->proteger('%'.$commentaire.'%'); switch ($type) { case '*' : $sql = $this->obtenirConditionPourCommentaires($commentaire); $sql = " AND (commentaire LIKE $commentaire OR ($sql)) "; break; case 'observation' : $sql = " AND commentaire LIKE $commentaire "; break; case 'photo' : $sql = ' AND '.$this->obtenirConditionPourCommentaires($commentaire).' '; break; case 'photo.meta' : $sql = ' AND '.$this->obtenirConditionPourCommentaireMeta($commentaire).' '; break; case 'photo.utilisateur' : $sql = ' AND '.$this->obtenirConditionPourCommentaireUtilisateur($commentaire).' '; break; default: $sql = " AND commentaire LIKE $commentaire "; } } return $sql; } private function construireWhereNomTaxon() { $sql = ''; list($type, $nom) = $this->decomposerParametreTaxon(); if (!$this->etreNull($nom)) { $nom = Cel::db()->proteger($nom.'%'); switch ($type) { case '*' : $sql = " AND (nom_ret LIKE $nom OR nom_sel LIKE $nom OR famille LIKE $nom) "; break; case 'retenu' : $sql = " AND nom_ret LIKE $nom "; break; case 'selectionne' : $sql = " AND nom_sel LIKE $nom "; break; case 'famille' : $sql = " AND famille LIKE $nom "; break; default: $sql = " AND nom_ret LIKE $nom "; } } return $sql; } private function construireWhereReferentiel() { $sql = ''; extract($this->parametres); if (isset($referentiel) && !$this->etreNull($referentiel)) { $referentiel = Cel::db()->proteger($referentiel); $sql = ' AND co.nom_referentiel = '.$referentiel.' '; } return $sql; } private function construireWhereDate() { $sql = ''; // Récupération des coordonnées depuis l'id station list($type, $date) = $this->decomposerParametreDate(); if (!$this->etreNull($date)) { $date = Cel::db()->proteger($date.'%'); switch ($type) { case '*' : $sql = " AND ( date_observation LIKE $date OR date_creation LIKE $date OR date_modification LIKE $date OR date_transmission LIKE $date) "; break; case 'observation' : $sql = " AND date_observation LIKE $date "; break; case 'creation' : $sql = " AND date_creation LIKE $date "; break; case 'modification' : $sql = " AND date_modification LIKE $date "; break; case 'transmission' : $sql = " AND date_transmission LIKE $date "; break; case 'photo' : $sql = $this->obtenirConditionPourDatePhoto($date); break; case 'ajout' : $sql = $this->obtenirConditionPourDateAjout($date); break; case 'liaison' : $sql = $this->obtenirConditionPourDateLiaison($date); break; default: $sql = " AND date_observation LIKE $date "; } } return $sql; } private function obtenirConditionPourDatePhoto($date) { $observations = $this->obtenirObsLieesImg('date.photo', $date); if (is_null($observations)) { $this->debug[] = "Aucune observation n'est liée à une photo prise à la date : $date"; } $sql = $this->assemblerObsEnConditionSql($observations); return $sql; } private function obtenirConditionPourDateLiaison($date) { $observations = $this->obtenirObsLieesImg('date.liaison', $date); if (is_null($observations)) { $this->debug[] = "Aucune observation n'a été liée à une image à à la date : $date"; } $sql = $this->assemblerObsEnConditionSql($observations); return $sql; } private function obtenirConditionPourDateAjout($date) { $observations = $this->obtenirObsLieesImg('date.ajout', $date); if (is_null($observations)) { $this->debug[] = "Aucune observation n'est liée à une image ajoutée à la date : $date"; } $sql = $this->assemblerObsEnConditionSql($observations); return $sql; } private function obtenirConditionPourCommentaireMeta($commentaire) { $observations = $this->obtenirObsLieesImg('commentaire.meta', $commentaire); if (is_null($observations)) { $this->debug[] = "Aucune observation n'est liée à une image dont le commentaire des méta-données correspond à : $commmentaire"; } $operateur = ''; $sql = $this->assemblerObsEnConditionSql($observations, $operateur); return $sql; } private function obtenirConditionPourCommentaireUtilisateur($commentaire) { $observations = $this->obtenirObsLieesImg('commentaire.utilisateur', $commentaire); if (is_null($observations)) { $this->debug[] = "Aucune observation n'est liée à une image dont le commentaire des utilisateur correspond à : $commmentaire"; } $operateur = ''; $sql = $this->assemblerObsEnConditionSql($observations, $operateur); return $sql; } private function obtenirConditionPourCommentaires($commentaire) { $observations = $this->obtenirObsLieesImg('commentaire.*', $commentaire); if (is_null($observations)) { $this->debug[] = "Aucune observation n'est liée à une image dont un des commentaires correspond à : $commmentaire"; } $operateur = ''; $sql = $this->assemblerObsEnConditionSql($observations, $operateur); return $sql; } /** * Récupération des identifiant d'utilisateur et des ordres des observations correspondant à une date. * Retour sous forme de tableau : array[identifiant] = array(ordre, ordre...); */ private function obtenirObsLieesImg($type, $param) { $transmission = ( $this->standard == 0) ? "transmission = '1' AND " : ""; // Construction de la requête $requete = 'SELECT DISTINCT co.id_obs, co.ce_utilisateur AS utilisateur '. 'FROM '.$this->table_export.' AS co '. ' LEFT JOIN cel_zones_geo AS zg '. ' ON (zg.nom = co.zone_geo AND zg.code = co.ce_zone_geo) '. "WHERE ".$transmission." co.images != null". ($type == 'date.creation' ? " AND co.date_creation LIKE $param " : ''). ($type == 'commentaire.obs' ? " AND co.commentaire LIKE $param " : ''). ($type == 'commentaire.*' ? " AND co.commentaire LIKE $param " : ''). $this->construireWhereCoordonnees(). $this->construireWhereDept(). $this->construireWhereCommune(). $this->construireWherePays(). $this->construireWhereUtilisateur(). $this->construireWhereNumTaxon(). $this->construireWhereNomTaxon(). $this->construireWhereReferentiel(). $this->construireWhereProjet(). $this->construireWhereTag(). $this->construireWhereGroupeZoneGeo(). 'ORDER BY utilisateur ASC'; //$this->debug[] = $requete; //die($requete); $resultats = Cel::db()->requeter($requete); $observations = null; if ($resultats != false) { $observations = array(); foreach ($resultats as $occurence) { $utilisateur = $occurence['utilisateur']; $ordre = $occurence['id_obs']; if (!array_key_exists($utilisateur, $observations)) { $observations[$utilisateur] = array(); } if (!array_key_exists($ordre, $observations[$utilisateur])) { $observations[$utilisateur][$ordre] = $ordre; } } } return $observations; } private function assemblerObsEnConditionSql($observations, $operateur = 'AND') { $sql = ''; if ($observations != null) { // Pré-construction du where de la requête $tpl_where = "(identifiant = '%s' AND ordre IN (%s))"; foreach ($observations as $utilisateur => $ordres) { $morceaux_requete[] = sprintf($tpl_where, $utilisateur, implode(',', $ordres)); } if (count($morceaux_requete) > 0) { $sql = implode(" \nOR ", $morceaux_requete); } } else { // Nous voulons que la requête ne retourne rien $sql = "identifiant = '' AND ordre = ''"; } $sql = " $operateur ($sql) "; return $sql; } private function construireWhereRectangleStation() { $sql = ''; if (isset($this->parametres['ne']) && isset($this->parametres['sw']) && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) { $ne = $this->decomposerLatLng($this->parametres['ne']); $sw = $this->decomposerLatLng($this->parametres['sw']); $latMin = $sw['lat']; $lngMin = $sw['lng']; $latMax = $ne['lat']; $lngMax = $ne['lng']; // ATTENTION : latitude correspond bien à la LATITUDE! $sql = " AND (latitude != 0 AND longitude != 0) ". " AND latitude > $latMin ". " AND latitude < $latMax ". " AND longitude > $lngMin ". " AND longitude < $lngMax "; } return $sql; } private function construireWhereRectangleStationOR() { $sql = ''; if (isset($this->parametres['ne']) && isset($this->parametres['sw']) && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) { $ne = $this->decomposerLatLng($this->parametres['ne']); $sw = $this->decomposerLatLng($this->parametres['sw']); $latMin = $sw['lat']; $lngMin = $sw['lng']; $latMax = $ne['lat']; $lngMax = $ne['lng']; $sql = "( (latitude != 0 AND longitude != 0) ". " AND latitude BETWEEN $latMin AND $latMax ". " AND longitude BETWEEN $lngMin AND $lngMax )"; /*$sql = " MBRWithin(mon_point, GeomFromText('POLYGON((".$latMin.' '.$lngMin.','. $latMax.' '.$lngMin.','. $latMax.' '.$lngMax.','. $latMax.' '.$lngMin.','. $latMin.' '.$lngMin."))')) "; */ } return $sql; } private function construireWhereRectangleCommune() { $sql = ''; if (isset($this->parametres['ne']) && isset($this->parametres['sw']) && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) { $ne = $this->decomposerLatLng($this->parametres['ne']); $sw = $this->decomposerLatLng($this->parametres['sw']); $latMin = $sw['lat']; $lngMin = $sw['lng']; $latMax = $ne['lat']; $lngMax = $ne['lng']; /*$sql = "AND wgs84_longitude != 0 AND wgs84_latitude != 0 ". " AND wgs84_latitude BETWEEN $latMin AND $latMax ". " AND wgs84_longitude BETWEEN $lngMin AND $lngMax ";*/ } return $sql; } private function construireWhereRectangleCommuneOR() { $sql = ''; if (isset($this->parametres['ne']) && isset($this->parametres['sw']) && ! $this->etreNull($this->parametres['ne']) && ! $this->etreNull($this->parametres['sw'])) { $ne = $this->decomposerLatLng($this->parametres['ne']); $sw = $this->decomposerLatLng($this->parametres['sw']); $latMin = $sw['lat']; $lngMin = $sw['lng']; $latMax = $ne['lat']; $lngMax = $ne['lng']; /*$sql = "( wgs84_longitude != 0 AND wgs84_latitude != 0 ". " AND wgs84_latitude BETWEEN $latMin AND $latMax ". " AND wgs84_longitude BETWEEN $lngMin AND $lngMax )";*/ /*$sql = " MBRWithin(point_commune, GeomFromText('POLYGON((".$latMin.' '.$lngMin.','. $latMax.' '.$lngMin.','. $latMax.' '.$lngMax.','. $latMax.' '.$lngMin.','. $latMin.' '.$lngMin."))')) ";*/ } return $sql; } private function construireWhereDept() { $sql = ''; // Récupération des coordonnées depuis l'id station extract($this->parametres); if (isset($dept) && !$this->etreNull($dept)) { $valeurs_a_proteger = explode(',',trim($dept)); foreach ($valeurs_a_proteger as $valeur) { $valeurs_protegees[] = '(dept = '.Cel::db()->quote($valeur).') '; } $valeurs = implode(' OR ', $valeurs_protegees); $sql = " AND ($valeurs) "; } return $sql; } private function construireWhereCommune() { $sql = ''; // Récupération des coordonnées depuis l'id station extract($this->parametres); if (isset($this->parametres['commune']) && !$this->etreNull($commune)) { $commune = Cel::db()->proteger($commune); $sql = " AND zone_geo LIKE $commune"; } if (isset($this->parametres['zonegeo']) && !$this->etreNull($zonegeo)) { $zonegeo = Cel::db()->proteger($zonegeo); $sql = " AND ce_zone_geo = $zonegeo"; } return $sql; } private function construireWherePays() { $sql = ''; extract($this->parametres); if (isset($this->parametres['pays']) && !$this->etreNull($pays)) { $pays = Cel::db()->proteger($pays); $sql = " AND pays = $pays"; } return $sql; } private function construireWhereCommuneSansCoordonneesAvecSensibles() { $sql = ''; // Récupération des coordonnées depuis l'id station extract($this->parametres); if (isset($this->parametres['commune']) && !$this->etreNull($commune)) { $commune = Cel::db()->proteger($commune); $sql = " AND zone_geo LIKE $commune"; } if (isset($this->parametres['zonegeo']) && !$this->etreNull($zonegeo)) { $zonegeo = Cel::db()->proteger($zonegeo); $sql = " AND ce_zone_geo = $zonegeo"; } $sql .= " AND ". "(". "(". "(latitude = '000null' OR latitude = '' OR latitude = 0 OR latitude IS NULL) AND ". "(longitude = '000null' OR longitude = '' OR longitude = 0 OR longitude IS NULL) ". ')'. ' OR localisation_floutage IN ("localité", "10x10km")'. ') '; return $sql; } private function construireWherePhotosSeulement() { $sql = ''; if (isset($this->parametres['photos']) && $this->parametres['photos'] == 1) { $sql = ' AND co.images is not null '; } return $sql; } private function construireWhereUtilisateur() { $sql = ''; // TODO tester si l'on recoit un id, un mail ou bien un nom ou prenom // pour en faire une fonction polyvalente extract($this->parametres); if (isset($this->parametres['utilisateur']) && !$this->etreNull($utilisateur)) { $utilisateur = Cel::db()->proteger($utilisateur); if (is_numeric($this->parametres['utilisateur'])) { $sql = " AND co.ce_utilisateur = $utilisateur "; } else { $sql = " AND co.courriel_utilisateur = $utilisateur "; } } return $sql; } private function construireWhereNumTaxon() { $sql = ''; // Récupération des coordonnées depuis l'id station extract($this->parametres); if (isset($this->parametres['num_nom_ret']) && !$this->etreNull($num_nom_ret)) { $num_nom_ret = Cel::db()->proteger($num_nom_ret); $sql = " AND nom_ret_nn = $num_nom_ret "; } return $sql; } private function construireWhereNumTaxonAvecSousTaxons() { $sql = ''; // Récupération des coordonnées depuis l'id station extract($this->parametres); if (isset($this->parametres['num_nom_ret']) && !$this->etreNull($num_nom_ret)) { $sous_taxons = $this->obtenirSousTaxons($this->parametres['num_nom_ret']); $num_nom_retenu = Cel::db()->proteger($num_nom_ret); if(!empty($sous_taxons)) { $sql_in_sous_tax = implode(',', $sous_taxons); $sql = " AND (nom_sel_nn IN (".$num_nom_retenu.', '.$sql_in_sous_tax.") OR ". "nom_ret_nn IN (".$num_nom_retenu.', '.$sql_in_sous_tax.") ". ") "; } else { $sql = " AND nom_ret_nn = $num_nom_ret "; } } return $sql; } private function obtenirSousTaxons($nt) { $referentiel = 'bdtfx'; if(isset($this->parametres['referentiel']) && $this->parametres['referentiel'] != "" && $this->parametres['referentiel'] != '*') { $referentiel = $this->parametres['referentiel']; } $nn_sous_taxons = array(); $sous_taxons = $this->obtenirSousTaxonsPourNn($referentiel, $nt); foreach($sous_taxons as $sous_tax) { $nn_sous_taxons[] = $sous_tax['num_nom']; } return $nn_sous_taxons; } private function construireWhereProjet() { $sql = ''; extract($this->parametres); $projet_sql = isset($projet) ? $this->getSqlWhereProjet($projet) : null; if (!$this->etreNull($projet_sql)) { $sql = " AND ($projet_sql) "; } return $sql; } /** * Traitement de $projet pour construction du filtre dans la requête * * projet1 ET projet2 ET projet3 => intersection * projet1 OU projet2 OU projet3 => union * projet1 ET projet2 OU projet3 => ATTENTION indéfini */ private function getSqlWhereProjet($projet) { $sql = null; if (isset($projet) && !$this->etreNull($projet)) { if (strpos($projet, ' ET ')) { // intersection $projets = explode(' ET ', $projet); $clauses = array(); foreach ($projets as $proj) { if ($proj != '') { $clauses[] = 'co.mots_cles_texte LIKE '.Cel::db()->proteger('%'.$proj.'%'); } } $sql = implode($clauses, ' AND '); } else if (strpos($projet, ' OU ')) { // union $projets = explode(' OU ', $projet); $clauses = array(); foreach ($projets as $proj) { if ($proj != '') { $clauses[] = 'co.mots_cles_texte LIKE '.Cel::db()->proteger('%'.$proj.'%'); } } $sql = implode($clauses, ' OR '); } else { // simple $sql = 'co.programme = '.Cel::db()->proteger($projet).' OR co.mots_cles_texte LIKE '.Cel::db()->proteger('%'.$projet.'%'); } } return $sql; } private function construireWhereTag() { $sql = ''; extract($this->parametres); $tag_sql = isset($tag) ? $this->getSqlWhereObsAvecImagesTaguees($tag) : null; if (!$this->etreNull($tag_sql)) { $sql = " AND ($tag_sql) "; } return $sql; } private function construireWhereNombreDeJours() { $sql = null; extract($this->parametres); if (isset($nbjours) && !$this->etreNull($nbjours)) { $sql = ' AND DATEDIFF(CURDATE(),co.date_creation) <= '.Cel::db()->proteger($nbjours).' '; } return $sql; } private function construireWhereAnnee() { $sql = null; extract($this->parametres); if (isset($annee) && !$this->etreNull($annee)) { $sql = ' AND YEAR(co.date_creation) = ' . Cel::db()->proteger($annee) . ' '; } return $sql; } private function construireWhereGroupeZoneGeo() { $sql = null; extract($this->parametres); if (isset($groupe_zones_geo) && !$this->etreNull($groupe_zones_geo)) { $req = "SELECT valeur FROM cel_groupes_zones WHERE id_groupe = ".Cel::db()->proteger($groupe_zones_geo); $res = Cel::db()->requeter($req); $zones = array(); foreach($res as &$r) { $zones[] = Cel::db()->proteger($r['valeur']); } $sql = 'AND ce_zone_geo IN ('.implode(',', $zones).') '; } return $sql; } /** * Traitement de $tag pour construction du filtre dans la requête */ private function getSqlWhereObsAvecImagesTaguees($tag) { $sql = null; $transmission = ( $this->standard == 0) ? "co.transmission = '1' " : " 1 "; if (isset($tag) && !$this->etreNull($tag)) { $tag_sql = $this->getSqlWhereMotsCles($tag); // Construction de la requête $requete = 'SELECT DISTINCT co.id_observation AS id_obs, co.ce_utilisateur AS utilisateur '. 'FROM cel_images_export ci'. ' INNER JOIN '.$this->table_export.' AS co '. ' ON (ci.ce_observation = co.id_observation) '. ' LEFT JOIN cel_zones_geo AS zg '. " ON (zg.nom = co.zone_geo AND zg.code = co.ce_zone_geo) ". "WHERE ".$transmission. $this->construireWhereCoordonnees(). $this->construireWhereUtilisateur(). $this->construireWhereNumTaxon(). $this->construireWhereNomTaxon(). $this->construireWhereReferentiel(). $this->construireWhereProjet(). (!$this->etreNull($tag_sql) ? "AND ($tag_sql) " : ''). 'ORDER BY utilisateur ASC'; //$this->debug[] = $requete; //die($requete); $elements_tag = Cel::db()->requeter($requete); $requete_tag = array(); if ($elements_tag != false && count($elements_tag) > 0) { $filtres = array(); foreach ($elements_tag as $occurence) { $utilisateur = $occurence['utilisateur']; $id_obs = $occurence['id_obs']; if (!array_key_exists($utilisateur, $filtres)) { $filtres[$utilisateur] = array(); } if (!array_key_exists($id_obs, $filtres[$utilisateur])) { $filtres[$utilisateur][$id_obs] = $id_obs; } } // Pré-construction du where de la requête $tpl_where = "(id_observation IN (%s))"; foreach ($filtres as $utilisateur => $id_obs) { $requete_tag[] = sprintf($tpl_where, implode(',', $id_obs)); } } else { $this->messages[] = "Aucune observation ne possède d'images avec ce mot-clé."; } if (count($requete_tag) > 0) { $sql = implode(" \nOR ", $requete_tag); } } return $sql; } /** * Traitement de $tag pour construction du filtre dans la requête */ private function getSqlWhereMotsCles($tag) { $sql = null; $mots_cles = $this->decomposerParametreTag($tag); $requete_projet = $this->getSqlWhereMotsClesImages($mots_cles); $sql = $requete_projet; //$this->debug[] = $sql; return $sql; } /** * Traitement de $tag pour construction du filtre dans la requête */ private function getSqlWhereMotsClesImages($mots_cles_encodes) { $where_mots_cles_images = array(); foreach ($mots_cles_encodes['motsClesEncodesProteges'] as $mot_cle_encode) { $where_mots_cles_images[] = "ci.mots_cles_texte LIKE $mot_cle_encode"; } $where_mots_cles_images = implode(' '.$mots_cles_encodes['type'].' ', $where_mots_cles_images); return $where_mots_cles_images; } private function decomposerParametreTag($tags) { $mots_cles = array('type' => null, 'motsCles' => null, 'motsClesEncodesProteges' => null); if (preg_match('/.+OU.+/', $tags)) { $mots_cles['type'] = 'OR'; $mots_cles['motsCles'] = explode('OU', $tags); } else if (preg_match('/.+ET.+/', $tags)) { $mots_cles['type'] = 'AND'; $mots_cles['motsCles'] = explode('ET', $tags); } else { $mots_cles['motsCles'][] = $tags; } foreach ($mots_cles['motsCles'] as $mot) { $mots_cles['motsClesEncodesProteges'][] = Cel::db()->quote('%'.$mot.'%'); } $this->debug[] = $mots_cles; return $mots_cles; } private function decomposerLatLng($coord) { $lat_lng = array(); if (isset($coord)) { list($lat, $lng) = explode('|', $coord); $lat_lng = array('lat' => $lat, 'lng' => $lng); } return $lat_lng; } private function decomposerParametreStation() { $station_infos = array(); if (isset($this->parametres['station'])) { $station = $this->parametres['station']; $this->debug[] = $station; @list($type, $coord) = explode(':', $station); @list($lat, $lng) = explode('|', $coord); $station_infos = array('type' => $type, 'lat' => $lat, 'lng' => $lng); } return $station_infos; } private function decomposerParametreDate() { $date_infos = array(null,null); if (isset($this->parametres['date'])) { $date = $this->parametres['date']; if (strpos($date, ':')) { list($type, $date) = explode(':', $date); } else { $type = 'observation'; } $date = str_replace('/', '-', $date); if (preg_match('/(^[0-9]{2})-([0-9]{2})-([0-9]{4}$)/', $date, $matches)) { $date = $matches[3].'-'.$matches[2].'-'.$matches[1]; } $date_infos = array($type, $date); } return $date_infos; } private function decomposerParametreTaxon() { $nom_infos = array(null,null); if (isset($this->parametres['taxon'])) { $taxon = $this->parametres['taxon']; if (strpos($taxon, ':')) { $nom_infos = explode(':', $taxon); } else { $nom_infos = array('retenu', $taxon); } } return $nom_infos; } private function decomposerParametreCommentaire() { $commentaire_infos = array(null,null); if (isset($this->parametres['commentaire'])) { $commentaire = $this->parametres['commentaire']; if (strpos($commentaire, ':')) { $commentaire_infos = explode(':', $commentaire); } else { $commentaire_infos = array('observation', $commentaire); } } return $commentaire_infos; } } ?>