Subversion Repositories eFlore/Applications.cel

Rev

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