Subversion Repositories eFlore/Applications.cel

Rev

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