WebSVN – eFlore/Applications.cel – Diff – //branches/v2.6-greffoir/jrest/services/CelWidgetSaisie.php

 	private $projetTags = array();
 	private $tagsObs = null;
 	private $tagsImg = null;
 	private $champsEtendusObs = null;
 	private $utilisateur_id = null;
-	const DUREE_DE_VIE_IMG = 86400;// 3600 * 24 * 2 = 172 800
+	const DUREE_DE_VIE_IMG = 86400;// 3600 * 24 = 86 400 (1 journée)
 	const ARRET_SERVICE = false;// Permet de bloquer le service en cas de problème sur le serveur
 	private $correspondanceIdImgTags = array();
 	private $gestionMotsClesObs = null;
 			$this->projet = $requeteDonnees['projet'];
 			// Traitements des tags multiples de projet
 			$this->traiterProjetTags();
-			// Traitement des tags spécifique aux obs
+			// Traitement des tags spécifiques aux obs
 			$this->traiterTagObs($requeteDonnees);
-			// Traitement des tags spécifique aux images
+			// Traitement des tags spécifiques aux images
 			$this->traiterTagImg($requeteDonnees);
 			// Traitement des observations et des images
 			if (filter_var($requeteDonnees['utilisateur']['courriel'], FILTER_VALIDATE_EMAIL)) {
 				$this->debug[] = 'Utilisateur : '.print_r($requeteDonnees['utilisateur'], true);
+				$utilisateur = $requeteDonnees['utilisateur'];
-				$utilisateur = $requeteDonnees['utilisateur'];
+				if (array_key_exists('courriel', $utilisateur)) {
-				if (array_key_exists('courriel', $utilisateur)) {
+					// début transaction car si insertions par le même utilisateur en parallèle,
+					// le getMaxOrdre et le INSERT sont en concurrence et risquent de foirer.
+					// De plus, ça permet de ne pas conserver les données d'obs si l'image provoque une erreur
-					// début transaction car si insertions par le même utilisateur en parallèle,
+					//Cel::db()->setAttribute(PDO::ATTR_AUTOCOMMIT, false);
-					// le getMaxOrdre et le INSERT sont en concurrence et risquent de foirer
+					Cel::db()->beginTransaction();
-					//Cel::db()->setAttribute(PDO::ATTR_AUTOCOMMIT, false);
+					$erreursDurantTraitement = false;
-					Cel::db()->beginTransaction();
+					$nomsOriginauxImagesTemp = array();
 								$this->champsEtendusObs[$ordreObs] = isset($obs['obs_etendue']) ? $obs['obs_etendue'] : array();
 								$imgAAjouter = null;
 								if (!empty($obs['image_nom'])) {
+									$imgAAjouter = $this->traiterImagesALierAObs($id_utilisateur, $ordreObs, $obs);
+									if ($imgAAjouter != null) {
+										foreach ($imgAAjouter as $uneImgAAjouter) {
+											$nomsOriginauxImagesTemp[] = $uneImgAAjouter['nom'];
+										}
 									$imgAAjouter = $this->traiterImagesALierAObs($id_utilisateur, $ordreObs, $obs);
+								}
 								if(!trim($courriel) && !trim($id_utilisateur)) {
 							$champs = implode(', ', array_keys($obs));
 							$valeurs = implode(', ', $obs);
 							$requete = "INSERT INTO cel_obs ($champs) VALUES ($valeurs) ";
+							if (Cel::db()->executer($requete) === false) {
-							if (Cel::db()->executer($requete) === false) {
+								$erreursDurantTraitement = true;
 								$this->messages[] = "Un problème est survenu lors de l'insertion de l'obs dans la base de données.";
 							} else {
 								$obs_a_taguer_ordres[] = trim($obs['ordre'], "'");
 							// si le formulaire contient une image on la traite
 							if ($img != null) {
 								$this->nettoyerImagesUploades();
+								$img_a_taguer_ids = $this->stockerImagesEtLierAObs($img, $id_utilisateur, $utilisateur);
+								if ($img_a_taguer_ids === false) {
+									$erreursDurantTraitement = true;
+									$this->messages[] = "Au moins une des images n'a pas pu être enregistrée.";
-								$img_a_taguer_ids = $this->stockerImagesEtLierAObs($img, $id_utilisateur, $utilisateur);
+								} else {
-								$cmd = sprintf($this->config['cel']['commande_script_images'],implode(',', $img_a_taguer_ids));
+									$cmd = sprintf($this->config['cel']['commande_script_images'],implode(',', $img_a_taguer_ids));
+									pclose(popen($cmd,"r"));
 								pclose(popen($cmd,"r"));
+							}
+						}
 						$this->gestionMotsClesObs = new GestionMotsClesChemin($this->config,'obs');
 						$this->gestionMotsClesImages = new GestionMotsClesChemin($this->config,'images');
+						$obs_a_taguer_ids = $this->obtenirIdsObsPourTableauOrdres($this->utilisateur_id, $obs_a_taguer_ordres);
+						$this->taguerObs($obs_a_taguer_ids);
-						$obs_a_taguer_ids = $this->obtenirIdsObsPourTableauOrdres($this->utilisateur_id, $obs_a_taguer_ordres);
+						if ($img_a_taguer_ids !== false) {
-						$this->taguerObs($obs_a_taguer_ids);
+							$this->taguerImg($img_a_taguer_ids);
 						$this->taguerImg($img_a_taguer_ids);
 						// Les champs taggés sont des champs supplémentaires stockés sous forme de clé => valeur
-						// Les champs taggés sont des champs supplémentaires stockés sous forme de clé => valeur
+						$this->ajouterChampsEtendusObs($obs_a_taguer_ids, $this->champsEtendusObs);
+					} else {
+						$erreursDurantTraitement = true;
+						$this->messages[] = "Un nouveau numéro d'ordre d'observation n'a pu être généré.";
+					}
-						$this->ajouterChampsEtendusObs($obs_a_taguer_ids, $this->champsEtendusObs);
+					// Fin de la transaction - on considère que commit() et rollback() ne ratent jamais
+					if ($erreursDurantTraitement === false) {
+						// Suppression des fichiers images temporaires
+						$this->nettoyerImagesUploades($nomsOriginauxImagesTemp);
+						Cel::db()->commit();
+					} else {
+						// On annule l'écriture des images enregistrées sur le disque dur - la transaction
+						// se charge de les retirer de la base de données
+						if ($img_a_taguer_ids !== false) {
+							foreach ($img_a_taguer_ids as $idImageASupprimer) {
+								$this->effacerImageDuDd($idImageASupprimer);
 					} else {
 						$this->messages[] = "Un nouveau numéro d'ordre d'observation n'a pu être généré.";
 						Cel::db()->rollBack();
 					Cel::db()->commit();
 				} else {
 			$this->messages[] = "Les informations concernant le projet coopératif n'ont pas été transmises.";
+		}
 		if (count($this->messages) > 0) {
 			$this->debug[] = print_r($this->messages, true);
+		}
-		$msg = (count($this->messages) > 0) ? 'erreur' : 'ok';
+		if (count($this->messages) > 0) {
+			$msg = 'erreur';
+			$idNouvelleObs = null;
+		} else {
+			$msg = 'ok';
+		}
 		$retour = (object) array('msg' => $msg, 'id' => $idNouvelleObs);
 		$this->envoyerJson($retour);
 		exit;
+	}
+		}
 		return $imgAAjouter;
 	}
-	private function stockerImagesEtLierAObs($img, $id_utilisateur, $utilisateur) {
+	protected function stockerImagesEtLierAObs($img, $id_utilisateur, $utilisateur) {
 		$img_a_taguer_ids = array();
 		if (!isset($img['nom']) && is_array($img)) {
 			foreach ($img as $index => $image) {
 						$img_a_taguer_ids[] = $idImg;
 						if (isset($image['tags'])) {
 							$this->correspondanceIdImgTags[$idImg] = $image['tags'];
+						}
+					}
+				} else {
+					// L'image n'a pas pu être écrite.
+					// On annule l'écriture des précédentes et on s'arrête là - la transaction
+					// se chargera de les retirer de la base de données
+					foreach ($img_a_taguer_ids as $idImageASupprimer) {
+						$this->effacerImageDuDd($idImageASupprimer);
+					}
+					$img_a_taguer_ids = false;
+					break;
+				}
+			}
 		} else {
 			$nomFichierImg = $this->traiterNomFichierImage($img['nom']);
 			$cheminImage = $this->config['cel']['chemin_stockage_temp']."/$nomFichierImg";
 					$img_a_taguer_ids[] = $idImg;
 					if (isset($img['tags'])) {
 						$this->correspondanceIdImgTags[$idImg] = $img['tags'];
+					}
+				}
+			} else {
+				// L'image n'a pas pu être écrite
+				$img_a_taguer_ids = false;
+			}
+		}
 		return $img_a_taguer_ids;
 			$ids[] = $id['id_observation'];
+		}
 		return $ids;
+	}
+	/**
+	 * Supprime toutes les images temporaires dont :
+	 * - l'ancienneté est supérieure à DUREE_DE_VIE_IMG (si $nomsDeFichiers vaut false, par défaut)
+	 * - le nom correspond à un des éléments du tableau $nomsDeFichiers (s'il est spécifié et non vide)
+	 */
+	protected function nettoyerImagesUploades($nomsDeFichiers=false) {
+		// mode de suppression
+		$suppressionParNom = (is_array($nomsDeFichiers) && count($nomsDeFichiers > 0));
 	public function nettoyerImagesUploades() {
 		$dossierStockage = $this->config['cel']['chemin_stockage_temp'].'/';
 		if (is_dir($dossierStockage)) {
 			$objets = scandir($dossierStockage);
-			if ($objets !== false) {
+			if (is_array($objets)) {
 				foreach ($objets as $objet) {
-					$chemin = $dossierStockage.$objet;
+					$chemin = $dossierStockage . $objet;
+					if (is_file($chemin)) {
+						// critère de suppression
+						if ($suppressionParNom) {
+							$suppression = in_array($objet, $nomsDeFichiers);
-					if (is_file($chemin)) {
+						} else {
-						$filemtime = @filemtime($chemin);
+							$filemtime = @filemtime($chemin);
-						if ($filemtime !== false) {
+							if ($filemtime !== false) {
-							$suppression = (time() - $filemtime >= self::DUREE_DE_VIE_IMG) ? true : false;
-							if ($suppression === true) {
-								unlink($chemin);
+								$suppression = (time() - $filemtime >= self::DUREE_DE_VIE_IMG) ? true : false;
+							}
+						}
+						// suppression
+						if ($suppression === true) {
+							unlink($chemin);
+						}
+					}
+				}
+			}
+		}
 					$resultat = Cel::db()->executer($requete);
 					if ($resultat !== false) {
 						$idImage = $this->obtenirIdImagePourIdentifiantEtOrdre($idUtilisateur, $nouvelOrdre);
 						if ($idImage !== false) {
 							$manipulateurImage = new ImageRecreation($this->config);
+							// Stocke le fichier en conservant les fichiers temporaires, ce qui permet de réessayer
+							// de les traiter en cas d'échec de la totalité du processus de traitement de l'obs
-							$stockageOk = $manipulateurImage->stockerFichierOriginal($cheminImage, $idImage);
+							$stockageOk = $manipulateurImage->stockerFichierOriginal($cheminImage, $idImage, true);
 							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.";
 			$this->messages[] = "Erreur lors du calcul du nouvel ordre de l'image.";
+		}
 		return $idImage;
+	}
+	/**
+	 * Supprime une image du disque dur. Ne touche pas à la base de données, on considère
+	 * que c'est le rôle de la transaction d'annuler les écritures en cas de problème
+	 *
+	 * @param Integer $idImageASupprimer
+	 * @return boolean $ok true si la suppression s'est bien passée, false s'il reste au moins un fichier
+	 */
+	protected function effacerImageDuDd($idImageASupprimer) {
+		$manipulateurImage = new ImageRecreation($this->config);
+		$ok = $manipulateurImage->detruireImageSurDisque($idImageASupprimer);
+		return $ok;
+	}
 	private function obtenirNouvelOrdrePourUtilisateur($id_utilisateur) {
 		$id_utilisateur = Cel::db()->proteger($id_utilisateur);

Subversion Repositories eFlore/Applications.cel

(root)//branches/v2.6-greffoir/jrest/services/CelWidgetSaisie.php – Rev 2355 → 2386