Rev 1111 | Rev 1219 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | RSS feed
<?php// declare(encoding='UTF-8');/*** Service permettant d'insérer les informations fournie par le widget Saisie dans le CEL.* Encodage en entrée : utf8* Encodage en sortie : utf8** Cas d'utilisation :* PUT /CelWidgetSaisie : ajout de données en les passant via $_POST** @author Jean-Pascal MILCENT <jpm@clapas.org>* @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>* @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>* @version $Id$* @copyright © 2011, Jean-Pascal MILCENT*/class CelWidgetSaisie extends CelMotCle {private $projet = null;private $utilisateur_id = null;const DUREE_DE_VIE_IMG = 86400;// 3600 * 24 * 2 = 172 800public function createElement($requeteDonnees) {if (array_key_exists('projet', $requeteDonnees)) {$this->debug[] = 'Projet : ok';$this->projet = $requeteDonnees['projet'];if (array_key_exists('utilisateur', $requeteDonnees)) {$this->debug[] = 'Utilisateur : ok';$utilisateur = $requeteDonnees['utilisateur'];if (array_key_exists('courriel', $utilisateur)) {$this->debug[] = 'Courriel : ok';extract($utilisateur);$this->utilisateur_id = $courriel;$ordre = $this->getMaxOrdre($courriel);if (!is_null($ordre)) {$requeteDonnees = $this->supprimerSlashesProfond($requeteDonnees);// Triage et manipulation des données$observations = array();foreach ($requeteDonnees as $cle => $obs) {if (preg_match('/^obsId[0-9]+$/', $cle)) {$idObs = $ordre++;$this->debug[] = 'commune_nom : '.$obs['commune_nom'];$this->debug[] = 'commune_code_insee : '.$obs['commune_code_insee'];$obsAAjouter = array();$obsAAjouter['identifiant'] = $courriel;$obsAAjouter['prenom_utilisateur'] = $prenom;$obsAAjouter['nom_utilisateur'] = $nom;$obsAAjouter['ordre'] = $idObs;$obsAAjouter['nom_sel'] = $obs['nom_sel'];$obsAAjouter['num_nom_sel'] = $obs['num_nom_sel'];$obsAAjouter['nom_ret'] = $obs['nom_ret'];$obsAAjouter['num_nom_ret'] = $obs['num_nom_ret'];$obsAAjouter['num_taxon'] = $obs['num_taxon'];$obsAAjouter['famille'] = $obs['famille'];$obsAAjouter['date_observation'] = $this->transormerDateFrVersMysql($obs['date']);$obsAAjouter['milieu'] = $obs['milieu'];$obsAAjouter['commentaire'] = $obs['notes'];$obsAAjouter['transmission'] = '1';$obsAAjouter['date_creation'] = date('Y-m-d H:i:s');$obsAAjouter['date_transmission'] = date('Y-m-d H:i:s');$obsAAjouter['location'] = $obs['commune_nom'];$obsAAjouter['id_location'] = substr($obs['commune_code_insee'], 0, 2);$obsAAjouter['lieudit'] = isset($obs['lieu_dit']) ? $obs['lieu_dit'] : null;$obsAAjouter['station'] = isset($obs['station']) ? $obs['station'] : null;$obsAAjouter['coord_x'] = $obs['latitude'];$obsAAjouter['coord_y'] = $obs['longitude'];$obsAAjouter['ref_geo'] = 'WGS84';$imgAAjouter = null;if (!empty($obs['image_nom'])) {$imgAAjouter = array();$imgAAjouter['id_utilisateur'] = $courriel;$imgAAjouter['id_obs'] = $idObs;$imgAAjouter['nom'] = $obs['image_nom'];$imgAAjouter['b64'] = $obs['image_b64'];$this->debug[] = 'Contient B64 : '.(empty($obs['image_b64']) ? 'non' : 'oui');}$observations[$idObs] = array('obs' => $this->protegerTableau($obsAAjouter),'img' => $imgAAjouter);}}$this->debug[] = 'Nbre obs ajoutée : '.count($observations);// Insertion dans la base$ok = true;$obs_a_lier = array();foreach ($observations as $infos) {$obs = $infos['obs'];$img = $infos['img'];// si le formulaire contient une image on la traiteif ($img != null) {$this->nettoyerImagesUploades();$nomFichierImg = $this->traiterNomFichierImage($img['nom']);$cheminImage = $this->config['cel_db']['chemin_stockage_temp']."/$nomFichierImg";// Si l'image est transmise en base 64if (empty($img['b64']) === false) {$this->transformerBase64enFichier($cheminImage, $img['b64']);}$this->debug[] = 'Nom fichier img debut :'.$nomFichierImg;$idImg = $this->ajouterImageSurDdEtBdd($img['id_utilisateur'], $cheminImage, $nomFichierImg);if ($idImg !== false) {$this->lierObsEtImg($idImg, $img['id_utilisateur'], $img['id_obs']);}}$requete = 'INSERT INTO cel_inventory '.'('.implode(', ', array_keys($obs)).') '.'VALUES ('.implode(', ', $obs).') ';$this->debug[] = $requete;if ($this->executerRequeteSimple($requete) === false) {$ok = false;} else {$obs_a_lier[] = trim($obs['ordre'], "'");}}if ($ok === true) {$this->debug[] = 'AJOUT dans la BDD OK : '.print_r($obs_a_lier, true);$liaisonOk = $this->lierObsAMotsCles($obs_a_lier);if ($liaisonOk === false) {$e = "Toutes les observations n'ont pas pu être liées au mot-clé du projet.";$this->messages[] = $e;}} else {$this->messages[] = "Un problème est survenu lors de l'insertion dans la base de données.";}} else {$this->messages[] = "Un nouveau numéro d'ordre d'observation n'a pu être généré.";}} else {$this->messages[] = "L'identifiant de l'utilisateur (courriel) n'a pas été transmis.";}} else {$this->messages[] = "Les informations concernant l'utilisateur (prénom, nom, courriel) n'ont pas été transmises.";}} else {$this->messages[] = "Les informations concernant le projet coopératif n'ont pas été transmises.";}$msg = (count($this->messages) > 0) ? 'erreur' : 'ok';$retour = (object) array('msg' => $msg);$this->envoyerJson($retour);}private function supprimerSlashesProfond($valeur) {$valeur = is_array($valeur) ? array_map(array($this, 'supprimerSlashesProfond'), $valeur) : stripslashes($valeur);return $valeur;}private function getMaxOrdre($identifiant) {$ordre = null;$identifiant = $this->bdd->quote($identifiant);$requete = "SELECT MAX(ordre) AS ordre "."FROM cel_inventory "."WHERE identifiant = $identifiant ";$ordre_max = $this->executerRequete($requete, 'Column');if ($ordre_max !== false) {$ordre = $ordre_max + 1;}return $ordre;}/*** Transforme une date au format français (jj/mm/aaaa) dans un format Mysql (aaaa-mm-jj).* @param string $dateFr date au format français (jj/mm/aaaa)* @return string date au format Mysql (aaaa-mm-jj)*/private function transormerDateFrVersMysql($dateFr) {$dateMysql = '0000-00-00';$morceauxDate = explode('/', $dateFr);if (count($morceauxDate) == 3) {$dateMysql = implode('-', array_reverse($morceauxDate));}return $dateMysql;}private function lierObsAMotsCles($observations) {$categorie = self::OBS_RACINE_ID.'.projets-cooperatifs';$projet = $categorie.'.'.strtolower($this->projet);$ajout_mot_cle_1 = $this->ajouterMotCleObs($this->utilisateur_id, 'Projets coopératifs', $categorie, self::OBS_RACINE_ID);$ajout_mot_cle_2 = $this->ajouterMotCleObs($this->utilisateur_id, $this->projet, $projet, $categorie);$liaison_ok = false;if ($ajout_mot_cle_1 && $ajout_mot_cle_2) {$liaison_ok = $this->lierMotCleObs($this->utilisateur_id, array($projet), $observations);} else {$this->messages[] = "La catégorie du projet et le mot-clé du projet n'ont pas pu être ajouté.";}return $liaison_ok;}private function traiterNomFichierImage($fichierNom) {$fichierNom = preg_replace('/[.](jpeg|jpg)$/i', '.jpg', strtolower(trim($fichierNom)));return $fichierNom;}/*** Décode l'image en base64,enregistre celle-ci sous forme de fichier du type de l'image* dans un dossier temporaire.*/private function transformerBase64enFichier($cheminImage, $imageInfosB64) {// Enleve la partie data:image qui permet la previsalisation pour firefox de l'image en base64$imageBase64 = explode(';', $imageInfosB64);$dataBase64 = explode(',',$imageBase64[1]);$dataImg = base64_decode($dataBase64[1]);$imageRessource = fopen($cheminImage, 'wb');fwrite($imageRessource, $dataImg);fclose($imageRessource);if (file_exists($cheminImage) == false) {$this->messages[] = "Erreur lors de la création du fichier";}}public function lierObsEtImg($id_image, $id_utilisateur, $id_obs) {$id_image = $this->proteger($id_image);$id_utilisateur = $this->proteger($id_utilisateur);$id_obs = $this->proteger($id_obs);$requete = 'INSERT INTO cel_obs_images '.' (coi_ce_image, coi_ce_utilisateur, coi_ce_observation, coi_date_liaison) '."VALUES ($id_image, $id_utilisateur, $id_obs, NOW()) ".' ON DUPLICATE KEY UPDATE coi_ce_image = coi_ce_image';if ($this->executerRequeteSimple($requete) === false) {$this->messages[] = "La requête de liaison de l'obs $id_obs à l'image $id_image pour l'utilisateur $id_utilisateur a échouée.";}}public function nettoyerImagesUploades() {$dossierStockage = $this->config['cel_db']['chemin_stockage_temp'].'/';if (is_dir($dossierStockage)) {$objets = scandir($dossierStockage);if ($objets !== false) {foreach ($objets as $objet) {$chemin = $dossierStockage.$objet;if (is_file($chemin)) {$filemtime = @filemtime($chemin);if ($filemtime !== false) {$suppression = (time() - $filemtime >= self::DUREE_DE_VIE_IMG) ? true : false;if ($suppression === true) {unlink($chemin);}}}}}}}/*** Ajoute une image dans la base de données et stocke le fichier en fabriquant les miniatures,* renvoie le nouvel id d'image en cas de succès** @param string $idUtilisateur l'identifiant de l'utilisateur* @param string $cheminImage le chemin vers le fichier original de l'image* @param string $nomFichierImage le nom du fichier original de l'image*/public function ajouterImageSurDdEtBdd($idUtilisateur, $cheminImage, $nomFichierImage) {$idImage = false;$nouvelOrdre = $this->obtenirNouvelOrdrePourUtilisateur($idUtilisateur);if ($nouvelOrdre !== false) {if (file_exists($cheminImage)) {$extracteurMetadonnees = new ExtracteurMetadonnees();$metadonnees = $extracteurMetadonnees->extraireMetadonnees($cheminImage) ;if ($metadonnees !== false) {$infosImage = $metadonnees;$infosImage['ci_ordre'] = $nouvelOrdre;$infosImage['ci_publiable_eflore'] = 'false';$infosImage['ci_nom_original'] = $nomFichierImage;$infosImage['ci_ce_utilisateur'] = $idUtilisateur;$infosImage['ci_md5'] = md5_file($cheminImage);$this->debug[] = 'Nom fichier img meta :'.$nomFichierImage;$requete = $this->construireRequeteInsertionImage($infosImage);$resultat = $this->executerRequeteSimple($requete);if ($resultat !== false) {$idImage = $this->obtenirIdImagePourIdentifiantEtOrdre($idUtilisateur, $nouvelOrdre);if ($idImage !== false) {$manipulateurImage = new ImageRecreation($this->config);$stockageOk = $manipulateurImage->stockerFichierEtCreerMiniatures($cheminImage, $idImage);if ($stockageOk) {$miniatureChemin = str_replace('.jpg', '_min.jpg', $cheminImage);if (file_exists($miniatureChemin)) {if (@unlink($miniatureChemin) === false) {$this->messages[] = "La miniature de l'image n'a pu être supprimée.";}}} else {$this->messages[] = "Une erreur s'est produite lors du stockage du fichier.";}} else {$this->messages[] = "Impossible d'obtenir le nouvel identifiant de l'image";}} else {$this->messages[] = "Echec de l'insertion dans la base de donnees des informations de l'image.";}} else {$this->messages[] = "Erreur lors de l'extraction des metadonnées.";}} else {$this->messages[] = "L'image originale est introuvable sur le serveur.";}} else {$this->messages[] = "Erreur lors du calcul du nouvel ordre de l'image.";}return $idImage;}private function obtenirNouvelOrdrePourUtilisateur($id_utilisateur) {$id_utilisateur = $this->proteger($id_utilisateur);$requete = 'SELECT MAX(ci_ordre) as max_ordre '.'FROM cel_images '."WHERE ci_ce_utilisateur = $id_utilisateur ";$resultat = $this->executerRequete($requete);$ordre = ($resultat) ? ++$resultat[0]['max_ordre'] : 0;return $ordre;}private function obtenirIdImagePourIdentifiantEtOrdre($id_utilisateur, $ordre) {$id_utilisateur = $this->proteger($id_utilisateur);$ordre = $this->proteger($ordre);$requete = 'SELECT ci_id_image '.'FROM cel_images '."WHERE ci_ce_utilisateur = $id_utilisateur "." AND ci_ordre = $ordre ";$resultat = $this->executerRequete($requete);$id_image = (count($resultat) > 0) ? $resultat[0]['ci_id_image'] : false;return $id_image;}private function construireRequeteInsertionImage($informations) {$champs = array('ci_meta_date_ajout');$valeurs = array('CURRENT_TIMESTAMP()');foreach ($informations as $champ => $valeur) {$champs[] = $champ;$valeurs[] = is_null($valeur) ? 'NULL' : $this->proteger($valeur);if ($champ == 'ci_meta_date_time' && $valeur != 'NULL') {$champs[] = 'ci_meta_date';$valeurs[] = $this->proteger($valeur);}}$champs = implode(', ', $champs);$valeurs = implode(', ', $valeurs);$requete = "INSERT INTO cel_images ($champs) VALUES ($valeurs) ";return $requete;}}?>