Subversion Repositories eFlore/Applications.cel

Rev

Rev 1765 | Rev 1821 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
719 jpm 1
<?php
2
// declare(encoding='UTF-8');
3
/**
4
 * Service permettant d'insérer les informations fournie par le widget Saisie dans le CEL.
5
 * Encodage en entrée : utf8
6
 * Encodage en sortie : utf8
7
 *
8
 * Cas d'utilisation :
9
 * PUT /CelWidgetSaisie : ajout de données en les passant via $_POST
10
 *
11
 * @author Jean-Pascal MILCENT <jpm@clapas.org>
12
 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
13
 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
14
 * @version $Id$
15
 * @copyright © 2011, Jean-Pascal MILCENT
16
 */
824 jpm 17
class CelWidgetSaisie extends CelMotCle {
1068 jpm 18
 
830 jpm 19
	private $projet = null;
1350 aurelien 20
	private $tagsObs = null;
21
	private $tagsImg = null;
1512 aurelien 22
	private $champsEtendusObs = null;
830 jpm 23
	private $utilisateur_id = null;
1350 aurelien 24
	const DUREE_DE_VIE_IMG = 86400;// 3600 * 24 * 2 = 172 800
25
	const ARRET_SERVICE = false;// Permet de bloquer le service en cas de problème sur le serveur
1565 jpm 26
 
1498 aurelien 27
	private $correspondanceIdImgTags = array();
1068 jpm 28
 
830 jpm 29
	public function createElement($requeteDonnees) {
1350 aurelien 30
		if (self::ARRET_SERVICE) {
31
			$this->messages[] = "Désactivation temporaire du service d'envoi des données au CEL.";
32
		} else if (array_key_exists('projet', $requeteDonnees)) {
830 jpm 33
			$this->debug[] = 'Projet : ok';
34
			$this->projet = $requeteDonnees['projet'];
1350 aurelien 35
			if (array_key_exists('tag-obs', $requeteDonnees) && $requeteDonnees['tag-obs'] != '') {
36
				$this->tagsObs = explode(',', $requeteDonnees['tag-obs']);
37
			}
38
			$this->tagsObs[] = 'Projets coopératifs>'.$this->projet;
39
			if (array_key_exists('tag-img', $requeteDonnees) && $requeteDonnees['tag-img'] != '') {
40
				$this->tagsImg = explode(',', $requeteDonnees['tag-img']);
41
			}
42
			$this->tagsImg[] = 'Projets coopératifs>'.$this->projet;
1593 raphael 43
			if (filter_var($requeteDonnees['utilisateur']['courriel'], FILTER_VALIDATE_EMAIL)) {
830 jpm 44
				$this->debug[] = 'Utilisateur : ok';
45
				$utilisateur = $requeteDonnees['utilisateur'];
46
				if (array_key_exists('courriel', $utilisateur)) {
47
					$this->debug[] = 'Courriel : ok';
1350 aurelien 48
					$utilisateur = $this->affecterChampsManquantsUtilisateur($utilisateur);
830 jpm 49
					extract($utilisateur);
1350 aurelien 50
					$this->utilisateur_id = $id_utilisateur;
1565 jpm 51
					$ordre = $this->getMaxOrdre($id_utilisateur);
830 jpm 52
					if (!is_null($ordre)) {
1350 aurelien 53
						$requeteDonnees = $this->supprimerSlashesProfond($requeteDonnees);
830 jpm 54
						// Triage et manipulation des données
55
						$observations = array();
56
						foreach ($requeteDonnees as $cle => $obs) {
57
							if (preg_match('/^obsId[0-9]+$/', $cle)) {
1350 aurelien 58
								$ordreObs = $ordre++;
1068 jpm 59
 
1350 aurelien 60
								$this->debug[] = 'commune_nom : '.$obs['commune_nom'];
61
								$this->debug[] = 'commune_code_insee : '.$obs['commune_code_insee'];
62
 
830 jpm 63
								$obsAAjouter = array();
1350 aurelien 64
								$obsAAjouter['ce_utilisateur'] = $id_utilisateur;
65
								$obsAAjouter['courriel_utilisateur'] = $courriel;
830 jpm 66
								$obsAAjouter['prenom_utilisateur'] = $prenom;
67
								$obsAAjouter['nom_utilisateur'] = $nom;
1350 aurelien 68
								$obsAAjouter['ordre'] = $ordreObs;
69
 
830 jpm 70
								$obsAAjouter['nom_sel'] = $obs['nom_sel'];
1350 aurelien 71
								$obsAAjouter['nom_sel_nn'] = isset($obs['num_nom_sel']) ? $obs['num_nom_sel'] : null;
72
								$obsAAjouter['nom_ret'] = isset($obs['nom_ret']) ? $obs['nom_ret'] : null;
73
								$obsAAjouter['nom_ret_nn'] = isset($obs['num_nom_ret']) ? $obs['num_nom_ret'] : null;
74
								$obsAAjouter['nt'] = isset($obs['num_taxon']) ? $obs['num_taxon'] : null;
75
								$obsAAjouter['famille'] = isset($obs['famille']) ? $obs['famille'] : null;
76
								$obsAAjouter['nom_referentiel'] = isset($obs['referentiel']) ? $obs['referentiel'] : null;
77
 
830 jpm 78
								$obsAAjouter['date_observation'] = $this->transormerDateFrVersMysql($obs['date']);
1350 aurelien 79
								$obsAAjouter['commentaire'] = $obs['notes'];
80
 
81
								$obsAAjouter['zone_geo'] = $obs['commune_nom'];
82
								$obsAAjouter['ce_zone_geo'] = 'INSEE-C:'.$obs['commune_code_insee'];
83
								$obsAAjouter['lieudit'] = isset($obs['lieudit']) ? $obs['lieudit'] : null;
84
								$obsAAjouter['station'] = isset($obs['station']) ? $obs['station'] : null;
1571 aurelien 85
								$obsAAjouter['milieu'] = isset($obs['milieu']) ? $obs['milieu'] : null;
1350 aurelien 86
								$obsAAjouter['latitude'] = $obs['latitude'];
87
								$obsAAjouter['longitude'] = $obs['longitude'];
88
								$obsAAjouter['geodatum'] = 'WGS84';
89
 
830 jpm 90
								$obsAAjouter['transmission'] = '1';
91
								$obsAAjouter['date_creation'] = date('Y-m-d H:i:s');
1350 aurelien 92
								$obsAAjouter['date_modification'] = $obsAAjouter['date_creation'];
93
								$obsAAjouter['date_transmission'] = $obsAAjouter['date_creation'];
1565 jpm 94
 
1512 aurelien 95
								$this->champsEtendusObs[$ordreObs] = isset($obs['obs_etendue']) ? $obs['obs_etendue'] : array();
1068 jpm 96
 
97
								$imgAAjouter = null;
98
								if (!empty($obs['image_nom'])) {
1498 aurelien 99
									$imgAAjouter = $this->traiterImagesALierAObs($id_utilisateur, $ordreObs, $obs);
1068 jpm 100
								}
101
 
1806 raphael 102
								if(!trim($courriel) && !trim($id_utilisateur)) {
103
									// XXX: debug
104
									file_put_contents("/tmp/debug-cel-" . time(),
105
													  $_POST . "\n=\n" . $requeteDonnees . "\n=\n" . var_export($obsAAjouter, true) .
106
													  "\n=\n", $_SERVER);
107
								}
108
 
1350 aurelien 109
								$observations[$ordreObs] = array(
1068 jpm 110
									'obs' => $this->protegerTableau($obsAAjouter),
111
									'img' => $imgAAjouter);
830 jpm 112
							}
719 jpm 113
						}
1068 jpm 114
						$this->debug[] = 'Nbre obs ajoutée : '.count($observations);
115
 
830 jpm 116
						// Insertion dans la base
1350 aurelien 117
						$obs_a_taguer_ordres = array();
118
						$img_a_taguer_ids = array();
1068 jpm 119
						foreach ($observations as $infos) {
120
							$obs = $infos['obs'];
121
							$img = $infos['img'];
122
 
1350 aurelien 123
							$champs = implode(', ', array_keys($obs));
124
							$valeurs = implode(', ', $obs);
125
							$requete = "INSERT INTO cel_obs ($champs) VALUES ($valeurs) ";
126
 
1765 raphael 127
							if (Cel::db()->executerRequeteSimple($requete) === false) {
1350 aurelien 128
								$this->messages[] = "Un problème est survenu lors de l'insertion de l'obs dans la base de données.";
129
							} else {
130
								$obs_a_taguer_ordres[] = trim($obs['ordre'], "'");
131
							}
1565 jpm 132
 
1068 jpm 133
							// si le formulaire contient une image on la traite
134
							if ($img != null) {
1350 aurelien 135
								$this->nettoyerImagesUploades();
1538 aurelien 136
								$img_a_taguer_ids = $this->stockerImagesEtLierAObs($img, $id_utilisateur, $utilisateur);
1068 jpm 137
							}
719 jpm 138
						}
1565 jpm 139
 
1354 aurelien 140
						$obs_a_taguer_ids = $this->obtenirIdsObsPourTableauOrdres($this->utilisateur_id, $obs_a_taguer_ordres);
141
						$this->taguerObs($obs_a_taguer_ids);
1353 aurelien 142
						$this->taguerImg($img_a_taguer_ids);
1565 jpm 143
 
1512 aurelien 144
						// Les champs taggés sont des champs supplémentaires stockés sous forme de clé => valeur
145
						$this->ajouterChampsEtendusObs($obs_a_taguer_ids, $this->champsEtendusObs);
830 jpm 146
					} else {
147
						$this->messages[] = "Un nouveau numéro d'ordre d'observation n'a pu être généré.";
719 jpm 148
					}
149
				} else {
830 jpm 150
					$this->messages[] = "L'identifiant de l'utilisateur (courriel) n'a pas été transmis.";
719 jpm 151
				}
152
			} else {
830 jpm 153
				$this->messages[] = "Les informations concernant l'utilisateur (prénom, nom, courriel) n'ont pas été transmises.";
719 jpm 154
			}
155
		} else {
830 jpm 156
			$this->messages[] = "Les informations concernant le projet coopératif n'ont pas été transmises.";
824 jpm 157
		}
158
		$msg = (count($this->messages) > 0) ? 'erreur' : 'ok';
159
		$retour = (object) array('msg' => $msg);
1068 jpm 160
		$this->envoyerJson($retour);
1719 aurelien 161
		exit;
719 jpm 162
	}
1565 jpm 163
 
1512 aurelien 164
	private function ajouterChampsEtendusObs($obs_ids, $obs_a_champs_etendus) {
165
		$champs_etendus_obs = array();
1565 jpm 166
		$gestionChampsEtendus = new GestionChampsEtendus($this->config, 'obs');
167
 
168
		foreach ($obs_ids as $id_obs) {
1512 aurelien 169
			$champs = array_shift($obs_a_champs_etendus);
1565 jpm 170
			if ($champs != null && is_array($champs)) {
171
				foreach ($champs as $infosChamp) {
172
					$cle = isset($infosChamp['cle']) ? $infosChamp['cle'] : '';
173
					$label = isset($infosChamp['label']) ? $infosChamp['label'] : '';
174
					$valeur = isset($infosChamp['valeur']) ? $infosChamp['valeur'] : '';
175
 
176
					if (empty($cle) && !empty($label)) {
177
						$cle = $gestionChampsEtendus->transformerLabelEnCle($label);
178
					}
179
 
180
					if (!empty($cle) && !empty($valeur)) {
181
						$champEtendu = new ChampEtendu();
182
						$champEtendu->id = $id_obs;
183
						$champEtendu->cle = $cle;
184
						$champEtendu->label = empty($label) ? $cle : $label;
185
						$champEtendu->valeur = $valeur;
186
 
187
						$champs_etendus_obs[] = $champEtendu;
188
					}
1512 aurelien 189
				}
190
			}
191
		}
1565 jpm 192
		$ajout_champ_etendus = $gestionChampsEtendus->ajouterParLots($champs_etendus_obs);
1512 aurelien 193
		return $ajout_champ_etendus;
194
	}
1565 jpm 195
 
1498 aurelien 196
	private function traiterImagesALierAObs($id_utilisateur, $ordreObs, $obs) {
197
		$imgAAjouter = null;
1565 jpm 198
		if (is_array($obs['image_nom'])) {
1498 aurelien 199
			$imgAAjouter = array();
200
			foreach ($obs['image_nom'] as $index => $nom_image) {
201
				$image = array();
202
				$image['id_utilisateur'] = $id_utilisateur;
203
				$image['id_obs'] = $ordreObs;
204
				$image['nom'] = $nom_image;
205
				$image['tags'] = isset($obs['image_tag'][$index]) ? explode(',',$obs['image_tag'][$index]) : '';
1565 jpm 206
				// on suppose que les b64 des images sont envoyés dans le même ordre que leurs noms
1498 aurelien 207
				// TODO: indexer le tableau avec le nom des images
208
				$image['b64'] = isset($obs['image_b64'][$index]) ? $obs['image_b64'][$index] : '';
1565 jpm 209
				$this->debug[] = 'Contient B64 : '.(empty($obs['image_b64']) ? 'non' : 'oui');
1498 aurelien 210
				$imgAAjouter[] = $image;
211
			}
212
		} else {
213
			if (!empty($obs['image_nom'])) {
214
				$imgAAjouter = array();
215
				$imgAAjouter['id_utilisateur'] = $id_utilisateur;
216
				$imgAAjouter['id_obs'] = $ordreObs;
217
				$imgAAjouter['nom'] = $obs['image_nom'];
1538 aurelien 218
				//$imgAAjouter['tags'] = isset($obs['image_tag']) ? explode(',',$obs['image_tag']) : '';
1527 aurelien 219
				$imgAAjouter['b64'] = isset($obs['image_b64']) ? $obs['image_b64'] : array();
1498 aurelien 220
				$this->debug[] = 'Contient B64 : '.(empty($obs['image_b64']) ? 'non' : 'oui');
221
			}
222
		}
1565 jpm 223
 
1498 aurelien 224
		return $imgAAjouter;
225
	}
1565 jpm 226
 
1498 aurelien 227
	private function stockerImagesEtLierAObs($img, $id_utilisateur, $utilisateur) {
1565 jpm 228
		$img_a_taguer_ids = array();
229
		if (!isset($img['nom']) && is_array($img)) {
230
			foreach ($img as $index => $image) {
1498 aurelien 231
				$nomFichierImg = $this->traiterNomFichierImage($image['nom']);
232
				$cheminImage = $this->config['cel']['chemin_stockage_temp']."/$nomFichierImg";
233
				// Si l'image est transmise en base 64
234
				if (empty($image['b64']) === false) {
235
					$this->transformerBase64enFichier($cheminImage, $image['b64']);
236
				}
1565 jpm 237
 
1498 aurelien 238
				$this->debug[] = 'Nom fichier img debut :'.$nomFichierImg;
239
				$idImg = $this->ajouterImageSurDdEtBdd($utilisateur, $cheminImage, $nomFichierImg);
240
				if ($idImg !== false) {
241
					$liaisonOk = $this->lierObsEtImg($idImg, $id_utilisateur, $image['id_obs']);
242
					if ($liaisonOk === true) {
243
						$img_a_taguer_ids[] = $idImg;
1565 jpm 244
						if (isset($image['tags'])) {
1498 aurelien 245
							$this->correspondanceIdImgTags[$idImg] = $image['tags'];
246
						}
247
					}
248
				}
249
			}
250
		} else {
251
			$nomFichierImg = $this->traiterNomFichierImage($img['nom']);
252
			$cheminImage = $this->config['cel']['chemin_stockage_temp']."/$nomFichierImg";
253
			// Si l'image est transmise en base 64
254
			if (empty($img['b64']) === false) {
255
				$this->transformerBase64enFichier($cheminImage, $img['b64']);
256
			}
1565 jpm 257
 
1498 aurelien 258
			$this->debug[] = 'Nom fichier img debut :'.$nomFichierImg;
259
			$idImg = $this->ajouterImageSurDdEtBdd($utilisateur, $cheminImage, $nomFichierImg);
260
			if ($idImg !== false) {
261
				$liaisonOk = $this->lierObsEtImg($idImg, $id_utilisateur, $img['id_obs']);
262
				if ($liaisonOk === true) {
263
					$img_a_taguer_ids[] = $idImg;
1565 jpm 264
					if (isset($img['tags'])) {
1498 aurelien 265
						$this->correspondanceIdImgTags[$idImg] = $img['tags'];
266
					}
267
				}
268
			}
269
		}
1565 jpm 270
 
1538 aurelien 271
		return $img_a_taguer_ids;
1498 aurelien 272
	}
1565 jpm 273
 
1350 aurelien 274
	private function affecterChampsManquantsUtilisateur($utilisateur) {
1467 aurelien 275
		$gestion_utilisateur = new User($this->config);
276
		$infos_complementaires = $gestion_utilisateur->obtenirUtilisateurSiExiste($utilisateur['courriel']);
1350 aurelien 277
		if(!isset($utilisateur['id_utilisateur']) || trim($utilisateur['id_utilisateur']) == '') {
1467 aurelien 278
			$utilisateur['id_utilisateur'] = ($infos_complementaires['connecte']) ? $infos_complementaires['id_utilisateur'] : $utilisateur['courriel'];
1350 aurelien 279
			$utilisateur['prenom'] = trim($infos_complementaires['prenom']) != '' ? $infos_complementaires['prenom'] : $utilisateur['prenom'];
280
			$utilisateur['nom'] = trim($infos_complementaires['nom']) != '' ? $infos_complementaires['nom'] : $utilisateur['nom'];
281
		}
1068 jpm 282
 
1350 aurelien 283
		return $utilisateur;
284
	}
285
 
286
	private function supprimerSlashesProfond($valeur) {
287
		$valeur = is_array($valeur) ? array_map(array($this, 'supprimerSlashesProfond'), $valeur) : stripslashes($valeur);
288
		return $valeur;
289
	}
290
 
291
	private function getMaxOrdre($id_utilisateur) {
719 jpm 292
		$ordre = null;
1765 raphael 293
		$identifiant = Cel::db()->quote($id_utilisateur);
719 jpm 294
		$requete = 	"SELECT MAX(ordre) AS ordre ".
1350 aurelien 295
					"FROM cel_obs ".
1765 raphael 296
					"WHERE ce_utilisateur = ".Cel::db()->proteger($id_utilisateur)." ";
1350 aurelien 297
 
1765 raphael 298
		$ordre_max = Cel::db()->executerRequete($requete, 'Column');
719 jpm 299
		if ($ordre_max !== false) {
300
			$ordre = $ordre_max + 1;
301
		}
302
		return $ordre;
303
	}
1068 jpm 304
 
719 jpm 305
	/**
306
	 * Transforme une date au format français (jj/mm/aaaa) dans un format Mysql (aaaa-mm-jj).
307
	 * @param string $dateFr date au format français (jj/mm/aaaa)
308
	 * @return string date au format Mysql (aaaa-mm-jj)
309
	 */
310
	private function transormerDateFrVersMysql($dateFr) {
311
		$dateMysql = '0000-00-00';
312
		$morceauxDate = explode('/', $dateFr);
313
		if (count($morceauxDate) == 3) {
1068 jpm 314
			$dateMysql = implode('-', array_reverse($morceauxDate));
719 jpm 315
		}
316
		return $dateMysql;
317
	}
1068 jpm 318
 
1354 aurelien 319
	private function taguerObs($obs_a_taguer_ids) {
320
		if (count($obs_a_taguer_ids) > 0) {
1350 aurelien 321
			foreach ($this->tagsObs as $hierarchieTag) {
322
				$tagsALier = explode('>', $hierarchieTag);
1354 aurelien 323
				$liaisonOk = $this->lierObsAMotsCles($obs_a_taguer_ids, $tagsALier);
1350 aurelien 324
				if ($liaisonOk === false) {
325
					$e = "Toutes les observations n'ont pas pu être liées aux mots-clés : $hierarchieTag";
326
					$this->messages[] = $e;
327
				}
328
			}
830 jpm 329
		}
1350 aurelien 330
	}
331
 
1354 aurelien 332
	private function lierObsAMotsCles($observations_ids, $tags) {
1350 aurelien 333
		$idTagParent = self::OBS_RACINE_ID;
334
		$listeIdsTags = array();
335
		foreach ($tags as $tag) {
336
			$tag = $this->nettoyerTag($tag);
1354 aurelien 337
			if ($tag != '') {
1350 aurelien 338
				$id_mot_cle = $this->ajouterMotCleObs($this->utilisateur_id, $tag, $idTagParent);
1354 aurelien 339
				if ($id_mot_cle !== false) {
1350 aurelien 340
					$listeIdsTags[] = $id_mot_cle;
341
					$idTagParent = $id_mot_cle;
1354 aurelien 342
				}
343
			}
1350 aurelien 344
		}
1400 aurelien 345
 
1354 aurelien 346
		$liaison_ok = $this->lierMotCleObs($this->utilisateur_id, $listeIdsTags, $observations_ids);
830 jpm 347
		return $liaison_ok;
348
	}
1068 jpm 349
 
1350 aurelien 350
	private function taguerImg($img_a_taguer_ids) {
351
		if (count($img_a_taguer_ids) > 0) {
352
			$this->debug[] = "Tags img : ".print_r($this->tagsImg, true);
353
			foreach ($this->tagsImg as $hierarchieTag) {
354
				$tagsALier = explode('>', $hierarchieTag);
355
				$liaisonOk = $this->lierImgAMotsCles($img_a_taguer_ids, $tagsALier);
356
				if ($liaisonOk === false) {
357
					$e = "Toutes les images n'ont pas pu être liées aux mots-clés : $hierarchieTag";
358
					$this->messages[] = $e;
359
				}
360
			}
361
		}
1498 aurelien 362
		// Liaison des tags spécifiques à chaque image s'il y en a
363
		if(count($this->correspondanceIdImgTags) > 0) {
364
			foreach ($this->correspondanceIdImgTags as $id_img => $tags) {
365
				if($tags != null && !empty($tags)) {
366
					$this->lierImgAMotsCles(array($id_img), $tags);
367
				}
368
			}
369
		}
1350 aurelien 370
	}
371
 
372
	private function lierImgAMotsCles($images_ids, $tags) {
373
		$idTagParent = self::IMG_RACINE_ID;
374
		$listeIdsTags = array();
375
		foreach ($tags as $tag) {
376
			$tag = $this->nettoyerTag($tag);
1354 aurelien 377
			if ($tag != '') {
1350 aurelien 378
				$id_mot_cle = $this->ajouterMotCleImg($this->utilisateur_id, $tag, $idTagParent);
1354 aurelien 379
				if ($id_mot_cle !== false) {
1350 aurelien 380
					$listeIdsTags[] = $id_mot_cle;
381
					$idTagParent = $id_mot_cle;
1354 aurelien 382
				}
383
			}
1350 aurelien 384
		}
1354 aurelien 385
		$liaison_ok = $this->lierMotCleImg($this->utilisateur_id, $listeIdsTags, $images_ids);
1350 aurelien 386
		return $liaison_ok;
387
	}
388
 
389
	private function nettoyerTag($tag) {
390
		$tag = trim($tag);
391
		$tag = preg_replace('/(?:\s+|[,]+)/', ' ', $tag);
392
		return $tag;
393
	}
394
 
1068 jpm 395
	private function traiterNomFichierImage($fichierNom) {
396
		$fichierNom = preg_replace('/[.](jpeg|jpg)$/i', '.jpg', strtolower(trim($fichierNom)));
397
		return $fichierNom;
398
	}
399
 
400
	/**
401
	* Décode l'image en base64,enregistre celle-ci sous forme de fichier du type de l'image
402
	*  dans un dossier temporaire.
403
	*/
1350 aurelien 404
	private function transformerBase64enFichier($cheminImage, $imageInfosB64) {
1068 jpm 405
		// Enleve la partie data:image qui permet la previsalisation pour firefox de l'image en base64
406
		$imageBase64 = explode(';', $imageInfosB64);
407
		$dataBase64 = explode(',',$imageBase64[1]);
408
		$dataImg = base64_decode($dataBase64[1]);
409
 
410
		$imageRessource = fopen($cheminImage, 'wb');
411
		fwrite($imageRessource, $dataImg);
412
		fclose($imageRessource);
413
 
414
		if (file_exists($cheminImage) == false) {
415
			 $this->messages[] = "Erreur lors de la création du fichier";
416
		}
417
	}
418
 
1350 aurelien 419
	public function lierObsEtImg($id_image, $utilisateur, $ordre_obs) {
1765 raphael 420
		$id_image = Cel::db()->proteger($id_image);
421
		$id_obs = Cel::db()->proteger($this->obtenirIdObsPourIdentifiantEtOrdre($utilisateur, $ordre_obs));
1068 jpm 422
 
423
		$requete = 'INSERT INTO cel_obs_images '.
1350 aurelien 424
			'	(id_image, id_observation, date_liaison) '.
425
			"VALUES ($id_image, $id_obs, NOW()) ".
426
			'	ON DUPLICATE KEY UPDATE id_image = id_image';
1068 jpm 427
 
1350 aurelien 428
		$liaison = true;
1765 raphael 429
		if (Cel::db()->executerRequeteSimple($requete) === false) {
1068 jpm 430
			$this->messages[] = "La requête de liaison de l'obs $id_obs à l'image $id_image pour l'utilisateur $id_utilisateur a échouée.";
1350 aurelien 431
			$liaison = false;
1068 jpm 432
		}
1350 aurelien 433
		return $liaison;
1068 jpm 434
	}
1565 jpm 435
 
1350 aurelien 436
	private function obtenirIdObsPourIdentifiantEtOrdre($id_utilisateur, $ordre) {
1565 jpm 437
 
1765 raphael 438
		$id_utilisateur = Cel::db()->proteger($id_utilisateur);
439
		$ordre = Cel::db()->proteger($ordre);
1565 jpm 440
 
1350 aurelien 441
		$requete = 'SELECT id_observation '.
442
					'FROM cel_obs '.
443
					"WHERE ce_utilisateur = $id_utilisateur ".
444
					"	AND ordre = $ordre ";
1068 jpm 445
 
1765 raphael 446
		$resultat = Cel::db()->executerRequete($requete);
1565 jpm 447
 
1350 aurelien 448
		$id_obs = (count($resultat) > 0) ? $resultat[0]['id_observation'] : false;
449
		return $id_obs;
450
	}
1565 jpm 451
 
1354 aurelien 452
	private function obtenirIdsObsPourTableauOrdres($id_utilisateur, $ordres) {
1765 raphael 453
		$id_utilisateur = Cel::db()->proteger($id_utilisateur);
454
		$ordres = array_map(array(Cel::db(),'proteger'), $ordres);
1565 jpm 455
 
1354 aurelien 456
		$requete = 'SELECT id_observation '.
457
							'FROM cel_obs '.
458
							"WHERE ce_utilisateur = $id_utilisateur ".
459
							" AND ordre IN (".implode(',',$ordres).") ";
1565 jpm 460
 
1765 raphael 461
		$resultat = Cel::db()->executerRequete($requete);
1354 aurelien 462
		$ids = array();
463
		foreach($resultat as $id) {
464
			$ids[] = $id['id_observation'];
465
		}
466
		return $ids;
467
	}
1350 aurelien 468
 
469
	public function nettoyerImagesUploades() {
470
		$dossierStockage = $this->config['cel']['chemin_stockage_temp'].'/';
471
		if (is_dir($dossierStockage)) {
472
			$objets = scandir($dossierStockage);
473
			if ($objets !== false) {
474
				foreach ($objets as $objet) {
475
					$chemin = $dossierStockage.$objet;
476
					if (is_file($chemin)) {
477
						$filemtime = @filemtime($chemin);
478
						if ($filemtime !== false) {
479
							$suppression = (time() - $filemtime >= self::DUREE_DE_VIE_IMG) ? true : false;
480
							if ($suppression === true) {
481
								unlink($chemin);
482
							}
483
						}
484
					}
485
				}
486
			}
487
		}
488
	}
489
 
1068 jpm 490
	/**
491
	* Ajoute une image dans la base de données et stocke le fichier en fabriquant les miniatures,
492
	* renvoie le nouvel id d'image en cas de succès
493
	*
1412 aurelien 494
	* @param string $utilisateur l'utilisateur
1350 aurelien 495
	* @param string $cheminImage le chemin vers le fichier original de l'image
496
	* @param string $nomFichierImage le nom du fichier original de l'image
1068 jpm 497
	*/
1412 aurelien 498
	public function ajouterImageSurDdEtBdd($utilisateur, $cheminImage, $nomFichierImage) {
1068 jpm 499
		$idImage = false;
1412 aurelien 500
		$idUtilisateur = $utilisateur['id_utilisateur'];
1068 jpm 501
		$nouvelOrdre = $this->obtenirNouvelOrdrePourUtilisateur($idUtilisateur);
502
		if ($nouvelOrdre !== false) {
503
			if (file_exists($cheminImage)) {
504
				$extracteurMetadonnees = new ExtracteurMetadonnees();
505
				$metadonnees = $extracteurMetadonnees->extraireMetadonnees($cheminImage) ;
506
				if ($metadonnees !== false) {
507
					$infosImage = $metadonnees;
1350 aurelien 508
					$infosImage['ordre'] = $nouvelOrdre;
509
					$infosImage['publiable_eflore'] = 'false';
510
					$infosImage['nom_original'] = $nomFichierImage;
511
					$infosImage['ce_utilisateur'] = $idUtilisateur;
1412 aurelien 512
					$infosImage['courriel_utilisateur'] = $utilisateur['courriel'];
513
					$infosImage['nom_utilisateur'] = $utilisateur['nom'];
514
					$infosImage['prenom_utilisateur'] = $utilisateur['prenom'];
1350 aurelien 515
					$infosImage['md5'] = md5_file($cheminImage);
516
					$this->debug[] = 'Nom fichier img meta :'.$nomFichierImage;
1068 jpm 517
					$requete = $this->construireRequeteInsertionImage($infosImage);
1765 raphael 518
					$resultat = Cel::db()->executerRequeteSimple($requete);
1068 jpm 519
					if ($resultat !== false) {
520
						$idImage = $this->obtenirIdImagePourIdentifiantEtOrdre($idUtilisateur, $nouvelOrdre);
521
						if ($idImage !== false) {
522
							$manipulateurImage = new ImageRecreation($this->config);
523
							$stockageOk = $manipulateurImage->stockerFichierEtCreerMiniatures($cheminImage, $idImage);
1350 aurelien 524
							if ($stockageOk) {
525
								$miniatureChemin = str_replace('.jpg', '_min.jpg', $cheminImage);
526
								if (file_exists($miniatureChemin)) {
527
									if (@unlink($miniatureChemin) === false) {
528
										$this->messages[] = "La miniature de l'image n'a pu être supprimée.";
529
									}
530
								}
531
 
532
							} else {
1068 jpm 533
								$this->messages[] = "Une erreur s'est produite lors du stockage du fichier.";
534
							}
535
						} else {
536
							$this->messages[] =  "Impossible d'obtenir le nouvel identifiant de l'image";
537
						}
538
					} else {
539
						$this->messages[] = "Echec de l'insertion dans la base de donnees des informations de l'image.";
540
					}
541
				} else {
542
					$this->messages[] = "Erreur lors de l'extraction des metadonnées.";
543
				}
544
			} else {
545
				$this->messages[] = "L'image originale est introuvable sur le serveur.";
546
			}
547
		} else {
548
			$this->messages[] = "Erreur lors du calcul du nouvel ordre de l'image.";
549
		}
550
		return $idImage;
551
	}
552
 
553
	private function obtenirNouvelOrdrePourUtilisateur($id_utilisateur) {
1765 raphael 554
		$id_utilisateur = Cel::db()->proteger($id_utilisateur);
1068 jpm 555
 
1350 aurelien 556
		$requete = 'SELECT MAX(ordre) as max_ordre '.
1068 jpm 557
			'FROM cel_images '.
1350 aurelien 558
			"WHERE ce_utilisateur = $id_utilisateur ";
1765 raphael 559
		$resultat = Cel::db()->executerRequete($requete);
1068 jpm 560
 
1350 aurelien 561
		$ordre = ($resultat) ? ++$resultat[0]['max_ordre'] : 0;
1068 jpm 562
		return $ordre;
563
	}
564
 
565
	private function obtenirIdImagePourIdentifiantEtOrdre($id_utilisateur, $ordre) {
1765 raphael 566
		$id_utilisateur = Cel::db()->proteger($id_utilisateur);
567
		$ordre = Cel::db()->proteger($ordre);
1068 jpm 568
 
1350 aurelien 569
		$requete = 'SELECT id_image '.
1068 jpm 570
			'FROM cel_images '.
1350 aurelien 571
			"WHERE ce_utilisateur = $id_utilisateur ".
572
			"	AND ordre = $ordre ";
1765 raphael 573
		$resultat = Cel::db()->executerRequete($requete);
1068 jpm 574
 
1350 aurelien 575
		$id_image = (count($resultat) > 0) ? $resultat[0]['id_image'] : false;
1068 jpm 576
		return $id_image;
577
 
578
	}
579
 
580
	private function construireRequeteInsertionImage($informations) {
1350 aurelien 581
		$champs = array('date_creation');
1068 jpm 582
		$valeurs = array('CURRENT_TIMESTAMP()');
583
 
584
		foreach ($informations as $champ => $valeur) {
585
			$champs[] = $champ;
1765 raphael 586
			$valeurs[] = is_null($valeur) ? 'NULL' : Cel::db()->proteger($valeur);
1400 aurelien 587
			if ($champ == 'date_creation' && $valeur != 'NULL') {
588
				$champs[] = 'date_creation';
1765 raphael 589
				$valeurs[] = Cel::db()->proteger($valeur);
1068 jpm 590
			}
591
		}
592
		$champs = implode(', ', $champs);
593
		$valeurs = implode(', ', $valeurs);
594
 
595
		$requete = "INSERT INTO cel_images ($champs) VALUES ($valeurs) ";
596
 
597
		return $requete;
598
	}
719 jpm 599
}
600
?>