Subversion Repositories eFlore/Applications.cel

Rev

Rev 3714 | Rev 3731 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 3714 Rev 3720
Line 17... Line 17...
17
 * @license    GPL v3 <http://www.gnu.org/licenses/gpl.txt>
17
 * @license    GPL v3 <http://www.gnu.org/licenses/gpl.txt>
18
 * @license    CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
18
 * @license    CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
19
 * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
19
 * @copyright  1999-2014 Tela Botanica <accueil@tela-botanica.org>
20
 */
20
 */
21
class CelWidgetSaisie extends Cel {
21
class CelWidgetSaisie extends Cel {
22
    
22
 
23
    private $projet = null;
23
    private $projet = null;
24
    private $projetId = null;
24
    private $projetId = null;
25
    private $projetTags = array();
25
    private $projetTags = array();
26
    private $tagsObs = null;
26
    private $tagsObs = null;
27
    private $tagsImg = null;
27
    private $tagsImg = null;
Line 30... Line 30...
30
    private $userIntitule = null;
30
    private $userIntitule = null;
31
    private $isFromPlantNet = false;
31
    private $isFromPlantNet = false;
32
    private $isSauvages = false;
32
    private $isSauvages = false;
33
    const DUREE_DE_VIE_IMG = 86400;// 3600 * 24 = 86 400 (1 journée)
33
    const DUREE_DE_VIE_IMG = 86400;// 3600 * 24 = 86 400 (1 journée)
34
    const ARRET_SERVICE = false;// Permet de bloquer le service en cas de problème sur le serveur
34
    const ARRET_SERVICE = false;// Permet de bloquer le service en cas de problème sur le serveur
35
    
35
 
36
    private $correspondanceIdImgTags = array();
36
    private $correspondanceIdImgTags = array();
37
    private $gestionMotsClesObs = null;
37
    private $gestionMotsClesObs = null;
38
    private $gestionMotsClesImages = null;
38
    private $gestionMotsClesImages = null;
39
    
39
 
40
    public function createElement($requeteDonnees) {
40
    public function createElement($requeteDonnees) {
41
        if (self::ARRET_SERVICE) {
41
        if (self::ARRET_SERVICE) {
42
            $this->messages[] = "Désactivation temporaire du service d'envoi des données au CEL.";
42
            $this->messages[] = "Désactivation temporaire du service d'envoi des données au CEL.";
43
        } else if (array_key_exists('projet', $requeteDonnees)) {
43
        } else if (array_key_exists('projet', $requeteDonnees)) {
44
            $this->debug[] = 'Projet : '.$requeteDonnees['projet'];
44
            $this->debug[] = 'Projet : '.$requeteDonnees['projet'];
45
            if ($requeteDonnees['projet'] != "base") {
45
            if ($requeteDonnees['projet'] != "base") {
46
                $this->projet = $requeteDonnees['projet'];
46
                $this->projet = $requeteDonnees['projet'];
47
                $this->projetId = $requeteDonnees['id_projet'] ?? null;
47
                $this->projetId = $requeteDonnees['id_projet'] ?? null;
48
            }
48
            }
49
            
49
 
50
            // Si c'est une obs Pl@ntNet
50
            // Si c'est une obs Pl@ntNet
51
            if (! empty($requeteDonnees['tag-obs']) && strpos(strtolower($requeteDonnees['tag-obs']), 'plantnet') !== false) {
51
            if (! empty($requeteDonnees['tag-obs']) && strpos(strtolower($requeteDonnees['tag-obs']), 'plantnet') !== false) {
52
                $this->isFromPlantNet = true;
52
                $this->isFromPlantNet = true;
53
            }
53
            }
54
            // Si c'est une obs Pl@ntNet
54
            // Si c'est une obs Pl@ntNet
55
            if (! empty($requeteDonnees['tag-obs']) && strpos(strtolower($requeteDonnees['tag-obs']), 'mobileSauvages') !== false) {
55
            if (! empty($requeteDonnees['tag-obs']) && strpos(strtolower($requeteDonnees['tag-obs']), 'mobileSauvages') !== false) {
56
                $this->isSauvages = true;
56
                $this->isSauvages = true;
57
            }
57
            }
58
            
58
 
59
            // Traitements des tags multiples de projet
59
            // Traitements des tags multiples de projet
60
            $this->traiterProjetTags();
60
            $this->traiterProjetTags();
61
            
61
 
62
            // Traitement des tags spécifiques aux obs
62
            // Traitement des tags spécifiques aux obs
63
            $this->traiterTagObs($requeteDonnees);
63
            $this->traiterTagObs($requeteDonnees);
64
            
64
 
65
            // Traitement des tags spécifiques aux images
65
            // Traitement des tags spécifiques aux images
66
            $this->traiterTagImg($requeteDonnees);
66
            $this->traiterTagImg($requeteDonnees);
67
            
67
 
68
            // Traitement des observations et des images
68
            // Traitement des observations et des images
69
            if (isset($requeteDonnees['utilisateur']['courriel']) && filter_var($requeteDonnees['utilisateur']['courriel'], FILTER_VALIDATE_EMAIL)) {
69
            if (isset($requeteDonnees['utilisateur']['courriel']) && filter_var($requeteDonnees['utilisateur']['courriel'], FILTER_VALIDATE_EMAIL)) {
70
                $this->debug[] = 'Utilisateur : '.print_r($requeteDonnees['utilisateur'], true);
70
                $this->debug[] = 'Utilisateur : '.print_r($requeteDonnees['utilisateur'], true);
71
                $utilisateur = $requeteDonnees['utilisateur'];
71
                $utilisateur = $requeteDonnees['utilisateur'];
72
                // début transaction car si insertions par le même utilisateur en parallèle,
72
                // début transaction car si insertions par le même utilisateur en parallèle,
73
                // De plus, ça permet de ne pas conserver les données d'obs si l'image provoque une erreur
73
                // De plus, ça permet de ne pas conserver les données d'obs si l'image provoque une erreur
74
                //Cel::db()->setAttribute(PDO::ATTR_AUTOCOMMIT, false);
74
                //Cel::db()->setAttribute(PDO::ATTR_AUTOCOMMIT, false);
75
                Cel::db()->beginTransaction();
75
                Cel::db()->beginTransaction();
76
                $erreursDurantTraitement = false;
76
                $erreursDurantTraitement = false;
77
                $nomsOriginauxImagesTemp = array();
77
                $nomsOriginauxImagesTemp = array();
78
                
78
 
79
                // hop on récupère les infos de l'utilisateur
79
                // hop on récupère les infos de l'utilisateur
80
                $infosUtilisateur = $this->infosInscritTela($utilisateur['courriel']);
80
                $infosUtilisateur = $this->infosInscritTela($utilisateur['courriel']);
81
                if ($infosUtilisateur) {
81
                if ($infosUtilisateur) {
82
                    $this->userId = $infosUtilisateur['id'];
82
                    $this->userId = $infosUtilisateur['id'];
83
                    $this->userIntitule = $infosUtilisateur['intitule'];
83
                    $this->userIntitule = $infosUtilisateur['intitule'];
84
                } else {
84
                } else {
85
                    $this->userId = 0;
85
                    $this->userId = 0;
86
                    $this->userIntitule = $utilisateur['prenom'] . ' ' . $utilisateur['nom'];
86
                    $this->userIntitule = $utilisateur['prenom'] . ' ' . $utilisateur['nom'];
87
                }
87
                }
88
                $this->userEmail = $utilisateur['courriel'];
88
                $this->userEmail = $utilisateur['courriel'];
89
                
89
 
90
                $this->debug[] = 'Courriel : ' . $this->userEmail;
90
                $this->debug[] = 'Courriel : ' . $this->userEmail;
91
                $requeteDonnees = $this->supprimerSlashesProfond($requeteDonnees);
91
                $requeteDonnees = $this->supprimerSlashesProfond($requeteDonnees);
92
                // Triage et manipulation des données
92
                // Triage et manipulation des données
93
                $observations = array();
93
                $observations = array();
94
                foreach ($requeteDonnees as $cle => $obs) {
94
                foreach ($requeteDonnees as $cle => $obs) {
95
                    if (preg_match('/^obsId[0-9]+$/', $cle)) {
95
                    if (preg_match('/^obsId[0-9]+$/', $cle)) {
96
                        $this->debug[] = 'commune_nom : '.$obs['commune_nom'];
96
                        $this->debug[] = 'commune_nom : '.$obs['commune_nom'];
97
                        $this->debug[] = 'commune_code_insee : '. (isset($obs['commune_code_insee']) ? $obs['commune_code_insee'] : 'n/a');
97
                        $this->debug[] = 'commune_code_insee : '. (isset($obs['commune_code_insee']) ? $obs['commune_code_insee'] : 'n/a');
98
                        
98
 
99
                        $obsAAjouter = array();
99
                        $obsAAjouter = array();
100
                        $obsAAjouter['user_id'] = $this->userId;
100
                        $obsAAjouter['user_id'] = $this->userId;
101
                        $obsAAjouter['user_email'] = $this->userEmail;
101
                        $obsAAjouter['user_email'] = $this->userEmail;
102
                        $obsAAjouter['user_pseudo'] = $this->userIntitule;
102
                        $obsAAjouter['user_pseudo'] = $this->userIntitule;
103
                        
103
 
104
                        $obsAAjouter['user_sci_name'] = isset($obs['nom_sel']) ? $obs['nom_sel'] : null;
104
                        $obsAAjouter['user_sci_name'] = isset($obs['nom_sel']) ? $obs['nom_sel'] : null;
105
                        $obsAAjouter['user_sci_name_id'] = isset($obs['num_nom_sel']) ? $obs['num_nom_sel'] : null;
105
                        $obsAAjouter['user_sci_name_id'] = isset($obs['num_nom_sel']) && '' !== $obs['num_nom_sel'] ? $obs['num_nom_sel'] : null;
106
                        $obsAAjouter['accepted_sci_name'] = isset($obs['nom_ret']) ? $obs['nom_ret'] : null;
106
                        $obsAAjouter['accepted_sci_name'] = isset($obs['nom_ret']) ? $obs['nom_ret'] : null;
107
                        $obsAAjouter['accepted_sci_name_id'] = isset($obs['num_nom_ret']) ? $obs['num_nom_ret'] : null;
107
                        $obsAAjouter['accepted_sci_name_id'] = isset($obs['num_nom_ret']) && '' !== $obs['num_nom_ret'] ? $obs['num_nom_ret'] : null;
108
                        $obsAAjouter['family'] = isset($obs['famille']) ? $obs['famille'] : null;
108
                        $obsAAjouter['family'] = isset($obs['famille']) ? $obs['famille'] : null;
109
                        $obsAAjouter['taxo_repo'] = isset($obs['referentiel']) ? ($obs['referentiel'] == 'bdtfxr') ? 'bdtfx' : $obs['referentiel'] : null;
109
                        $obsAAjouter['taxo_repo'] = isset($obs['referentiel']) ? ($obs['referentiel'] == 'bdtfxr') ? 'bdtfx' : $obs['referentiel'] : null;
110
                        
110
 
111
                        $obsAAjouter['date_observed'] = $this->transormerDateFrVersMysql($obs['date']);
111
                        $obsAAjouter['date_observed'] = $this->transormerDateFrVersMysql($obs['date']);
112
                        $obsAAjouter['annotation'] = isset($obs['notes']) && trim($obs['notes']) !== "" ? $obs['notes'] : null;
112
                        $obsAAjouter['annotation'] = isset($obs['notes']) && trim($obs['notes']) !== "" ? $obs['notes'] : null;
113
                        
113
 
114
                        // Pays est pour le moment sur un varchar(2) dans la base
114
                        // Pays est pour le moment sur un varchar(2) dans la base
115
                        // alors qu'il est envoyé complet par le script WidgetSaisie
115
                        // alors qu'il est envoyé complet par le script WidgetSaisie
116
                        $obsAAjouter['osm_country'] = (isset($obs['pays'])) ? $obs['pays'] : null;
116
                        $obsAAjouter['osm_country'] = (isset($obs['pays'])) ? $obs['pays'] : null;
117
                        $obsAAjouter['locality'] = $obs['commune_nom'];
117
                        $obsAAjouter['locality'] = $obs['commune_nom'];
118
                        $obsAAjouter['locality_insee_code'] = isset($obs['commune_code_insee']) ? $obs['commune_code_insee'] : '';
118
                        $obsAAjouter['locality_insee_code'] = isset($obs['commune_code_insee']) ? $obs['commune_code_insee'] : '';
119
                        $obsAAjouter['sublocality'] = isset($obs['lieudit']) && trim($obs['lieudit']) !== "" ? $obs['lieudit'] : null;
119
                        $obsAAjouter['sublocality'] = isset($obs['lieudit']) && trim($obs['lieudit']) !== "" ? $obs['lieudit'] : null;
120
                        $obsAAjouter['station'] = isset($obs['station']) && trim($obs['station']) !== "" ? $obs['station'] : null;
120
                        $obsAAjouter['station'] = isset($obs['station']) && trim($obs['station']) !== "" ? $obs['station'] : null;
121
                        $obsAAjouter['environment'] = isset($obs['milieu']) && trim($obs['milieu']) !== "" ? $obs['milieu'] : null;
121
                        $obsAAjouter['environment'] = isset($obs['milieu']) && trim($obs['milieu']) !== "" ? $obs['milieu'] : null;
122
                        $obsAAjouter['elevation'] = (! empty($obs['altitude'])) ? $obs['altitude'] : null;
122
                        $obsAAjouter['elevation'] = (! empty($obs['altitude'])) ? $obs['altitude'] : null;
123
                        $obsAAjouter['geometry'] = $obs['geometry'] ?? json_encode([
123
                        $obsAAjouter['geometry'] = $obs['geometry'] ?? json_encode([
124
                            'type' => 'Point',
124
                                'type' => 'Point',
125
                            'coordinates' => [ (float)$obs['longitude'], (float)$obs['latitude'] ]
125
                                'coordinates' => [ (float)$obs['longitude'], (float)$obs['latitude'] ]
126
                        ]); // CONCAT('{\"type\":\"Point\",\"coordinates\":[', longitude, ',', latitude,']}'),
126
                            ]); // CONCAT('{\"type\":\"Point\",\"coordinates\":[', longitude, ',', latitude,']}'),
127
                        $obsAAjouter['geodatum'] = 'WGS84';
127
                        $obsAAjouter['geodatum'] = 'WGS84';
128
                        
128
 
129
                        $obsAAjouter['phenology'] = isset($obs['phenologie']) ? $obs['phenologie'] : null;
129
                        $obsAAjouter['phenology'] = isset($obs['phenologie']) ? $obs['phenologie'] : null;
130
                        $obsAAjouter['coef'] = isset($obs['abondance']) ? $obs['abondance'] : null;
130
                        $obsAAjouter['coef'] = isset($obs['abondance']) ? $obs['abondance'] : null;
131
                        
131
 
132
                        $obsAAjouter['is_public'] = '1';
132
                        $obsAAjouter['is_public'] = '1';
133
                        $obsAAjouter['date_created'] = date('Y-m-d H:i:s');
133
                        $obsAAjouter['date_created'] = date('Y-m-d H:i:s');
134
                        $obsAAjouter['date_updated'] = $obsAAjouter['date_created'];
134
                        $obsAAjouter['date_updated'] = $obsAAjouter['date_created'];
135
                        $obsAAjouter['date_published'] = $obsAAjouter['date_created'];
135
                        $obsAAjouter['date_published'] = $obsAAjouter['date_created'];
136
                        
136
 
137
                        $obsAAjouter['image_nom'] = $obs['image_nom'] ?? null;
137
                        $obsAAjouter['image_nom'] = $obs['image_nom'] ?? null;
138
                        $obsAAjouter['image_b64'] = $obs['image_b64'] ?? null;
138
                        $obsAAjouter['image_b64'] = $obs['image_b64'] ?? null;
139
                        
139
 
140
                        $obsAAjouter['certainty'] = '';
140
                        $obsAAjouter['certainty'] = '';
141
                        if (isset($obs['certitude'])) {
141
                        if (isset($obs['certitude'])) {
142
                            switch ($obs['certitude']) {
142
                            switch ($obs['certitude']) {
143
                                case 'certaine':
143
                                case 'certaine':
144
                                    $obsAAjouter['certainty'] = 'certain';
144
                                    $obsAAjouter['certainty'] = 'certain';
Line 160... Line 160...
160
                        }
160
                        }
161
                        if ($this->isSauvages) {
161
                        if ($this->isSauvages) {
162
                            $obsAAjouter['input_source'] = 'autre';
162
                            $obsAAjouter['input_source'] = 'autre';
163
                            $obsAAjouter['project'] = 'sauvages';
163
                            $obsAAjouter['project'] = 'sauvages';
164
                        }
164
                        }
165
                        
165
 
166
                        $obsAAjouter['obs_etendue'] = isset($obs['obs_etendue']) ? $obs['obs_etendue'] : array();
166
                        $obsAAjouter['obs_etendue'] = isset($obs['obs_etendue']) ? $obs['obs_etendue'] : array();
167
                        
167
 
168
                        // Tentative d'enrichissement des données taxonomiques
168
                        // Tentative d'enrichissement des données taxonomiques
169
                        // @TODO attention aux perfs, aux timeouts de WS etc.
169
                        // @TODO attention aux perfs, aux timeouts de WS etc.
170
                        $this->enrichirDonneesTaxonomiques($obsAAjouter);
170
                        $this->enrichirDonneesTaxonomiques($obsAAjouter);
171
                        
171
 
172
                        $observations[] = $obsAAjouter;
172
                        $observations[] = $obsAAjouter;
173
                    }
173
                    }
174
                }
174
                }
175
                $this->debug[] = 'Nbre obs ajoutée : '.count($observations);
175
                $this->debug[] = 'Nbre obs ajoutée : '.count($observations);
176
                $this->debug[] = 'projet : '.$this->projet;
176
                $this->debug[] = 'projet : '.$this->projet;
177
                $this->debug[] = 'tagsObs : '.print_r($this->tagsObs, true);
177
                $this->debug[] = 'tagsObs : '.print_r($this->tagsObs, true);
178
                $this->debug[] = 'tagsImg : '.print_r($this->tagsImg, true);
178
                $this->debug[] = 'tagsImg : '.print_r($this->tagsImg, true);
179
                
179
 
180
                // Insertion dans la base
180
                // Insertion dans la base
181
                $obs_a_taguer_ids = array();
181
                $obs_a_taguer_ids = array();
182
                $img_a_taguer_ids_noms = array();
182
                $img_a_taguer_ids_noms = array();
183
                $champsEtendusObs = array();
183
                $champsEtendusObs = array();
184
                foreach ($observations as $obs) {
184
                foreach ($observations as $obs) {
185
                    $fullObs = $obs;
185
                    $fullObs = $obs;
186
                    unset($obs['obs_etendue']);
186
                    unset($obs['obs_etendue']);
187
                    unset($obs['image_nom']);
187
                    unset($obs['image_nom']);
188
                    unset($obs['image_b64']);
188
                    unset($obs['image_b64']);
189
                    
189
 
190
                    $obs = $this->protegerTableau($obs);
190
                    $obs = $this->protegerTableau($obs);
191
                    
191
 
192
                    $champs = implode(', ', array_keys($obs));
192
                    $champs = implode(', ', array_keys($obs));
193
                    $valeurs = implode(', ', $obs);
193
                    $valeurs = implode(', ', $obs);
194
                    $requete = "INSERT INTO occurrence ($champs) VALUES ($valeurs) ";
194
                    $requete = "INSERT INTO occurrence ($champs) VALUES ($valeurs) ";
195
                    
195
 
196
                    if (Cel::db()->executer($requete) === false) {
196
                    if (Cel::db()->executer($requete) === false) {
197
                        $erreursDurantTraitement = true;
197
                        $erreursDurantTraitement = true;
198
                        $this->messages[] = "Un problème est survenu lors de l'insertion de l'obs dans la base de données.";
198
                        $this->messages[] = "Un problème est survenu lors de l'insertion de l'obs dans la base de données.";
199
                    }
199
                    }
200
                    
200
 
201
                    // récupérer l'id de l'obs nouvellement insérée
201
                    // récupérer l'id de l'obs nouvellement insérée
202
                    $idNouvelleObs = Cel::db()->obtenirDernierId();
202
                    $idNouvelleObs = Cel::db()->obtenirDernierId();
203
                    $obs_a_taguer_ids[] = $idNouvelleObs;
203
                    $obs_a_taguer_ids[] = $idNouvelleObs;
204
                    $champsEtendusObs[$idNouvelleObs] = $fullObs['obs_etendue'];
204
                    $champsEtendusObs[$idNouvelleObs] = $fullObs['obs_etendue'];
205
                    
205
 
206
                    $imgAAjouter = null;
206
                    $imgAAjouter = null;
207
                    if (isset($fullObs['image_nom'])) {
207
                    if (isset($fullObs['image_nom'])) {
208
                        $imgAAjouter = $this->traiterImagesALierAObs($idNouvelleObs, $fullObs);
208
                        $imgAAjouter = $this->traiterImagesALierAObs($idNouvelleObs, $fullObs);
209
                        foreach ($imgAAjouter as $uneImgAAjouter) {
209
                        foreach ($imgAAjouter as $uneImgAAjouter) {
210
                            $nomsOriginauxImagesTemp[] = $uneImgAAjouter['nom'];
210
                            $nomsOriginauxImagesTemp[] = $uneImgAAjouter['nom'];
211
                        }
211
                        }
212
                    }
212
                    }
213
                    
213
 
214
                    // si le formulaire contient une image on la traite
214
                    // si le formulaire contient une image on la traite
215
                    if (!empty($imgAAjouter)) {
215
                    if (!empty($imgAAjouter)) {
216
                        $this->nettoyerImagesUploades();
216
                        $this->nettoyerImagesUploades();
217
                        $img_a_taguer_ids_noms = $this->stockerImagesEtLierAObs($idNouvelleObs, $imgAAjouter);
217
                        $img_a_taguer_ids_noms = $this->stockerImagesEtLierAObs($idNouvelleObs, $imgAAjouter);
218
                        if (empty($img_a_taguer_ids_noms)) {
218
                        if (empty($img_a_taguer_ids_noms)) {
Line 222... Line 222...
222
                            $cmd = sprintf($this->config['cel']['commande_script_images'],implode(',', array_keys($img_a_taguer_ids_noms)));
222
                            $cmd = sprintf($this->config['cel']['commande_script_images'],implode(',', array_keys($img_a_taguer_ids_noms)));
223
                            pclose(popen($cmd,"r"));
223
                            pclose(popen($cmd,"r"));
224
                        }
224
                        }
225
                    }
225
                    }
226
                }
226
                }
227
                
227
 
228
                $this->gestionMotsClesObs = new GestionMotsClesChemin($this->config,'obs');
228
                $this->gestionMotsClesObs = new GestionMotsClesChemin($this->config,'obs');
229
                $this->gestionMotsClesImages = new GestionMotsClesChemin($this->config,'images');
229
                $this->gestionMotsClesImages = new GestionMotsClesChemin($this->config,'images');
230
                
230
 
231
                $this->taguerObs($obs_a_taguer_ids);
231
                $this->taguerObs($obs_a_taguer_ids);
232
                if (!empty($img_a_taguer_ids_noms)) {
232
                if (!empty($img_a_taguer_ids_noms)) {
233
                    $this->taguerImg(array_keys($img_a_taguer_ids_noms));
233
                    $this->taguerImg(array_keys($img_a_taguer_ids_noms));
234
                }
234
                }
235
                
235
 
236
                // Les champs taggés sont des champs supplémentaires stockés sous forme de clé => valeur
236
                // Les champs taggés sont des champs supplémentaires stockés sous forme de clé => valeur
237
                $this->ajouterChampsEtendusObs($obs_a_taguer_ids, $champsEtendusObs);
237
                $this->ajouterChampsEtendusObs($obs_a_taguer_ids, $champsEtendusObs);
238
                // Fin de la transaction - on considère que commit() et rollback() ne ratent jamais
238
                // Fin de la transaction - on considère que commit() et rollback() ne ratent jamais
239
                if ($erreursDurantTraitement === false) {
239
                if ($erreursDurantTraitement === false) {
240
                    // Suppression des fichiers images temporaires
240
                    // Suppression des fichiers images temporaires
Line 281... Line 281...
281
            'images' => $infosImages
281
            'images' => $infosImages
282
        );
282
        );
283
        $this->envoyerJson($retour);
283
        $this->envoyerJson($retour);
284
        exit;
284
        exit;
285
    }
285
    }
286
    
286
 
287
    /**
287
    /**
288
     * Retourne les infos du compte correspondant à $courriel
288
     * Retourne les infos du compte correspondant à $courriel
289
     * si présent dans l'annuaire Tela,
289
     * si présent dans l'annuaire Tela,
290
     * false sinon
290
     * false sinon
291
     */
291
     */
Line 308... Line 308...
308
            return false;
308
            return false;
309
        }
309
        }
310
        // le service annuaire a retourné qqch de valide
310
        // le service annuaire a retourné qqch de valide
311
        return array_shift($retour);
311
        return array_shift($retour);
312
    }
312
    }
313
    
313
 
314
    /**
314
    /**
315
     * Retourne true si les champs suivants sont présents dans le tableau :
315
     * Retourne true si les champs suivants sont présents dans le tableau :
316
     *  - obsId1[user_sci_name]
316
     *  - obsId1[user_sci_name]
317
     *  - obsId1[latitude]' : obs.geoloc.lat || '',
317
     *  - obsId1[latitude]' : obs.geoloc.lat || '',
318
     'obsId1[longitude]' : obs.geoloc.lon || '',
318
    'obsId1[longitude]' : obs.geoloc.lon || '',
319
     *  mot-clé "pn:referentiel"
319
     *  mot-clé "pn:referentiel"
320
     */
320
     */
321
    protected function estUneDonneeQualifiee($donnees) {
321
    protected function estUneDonneeQualifiee($donnees) {
322
        // vérifier date et géoloc
322
        // vérifier date et géoloc
323
        // lancer enrichirDonneesTaxonomiques et vérifier si ça a retrouvé un nn
323
        // lancer enrichirDonneesTaxonomiques et vérifier si ça a retrouvé un nn
324
    }
324
    }
325
    
325
 
326
    /**
326
    /**
327
     * Si les données taxonomiques sont incomplètes dans $obs
327
     * Si les données taxonomiques sont incomplètes dans $obs
328
     * (clefs 'nom_sel_nn', 'user_sci_name', 'taxo_repo', 'accepted_sci_name_id',
328
     * (clefs 'nom_sel_nn', 'user_sci_name', 'taxo_repo', 'accepted_sci_name_id',
329
     * 'accepted_sci_name', 'family'), tente d'en récupérer un maximum à l'aide des
329
     * 'accepted_sci_name', 'family'), tente d'en récupérer un maximum à l'aide des
330
     * services eFlore, à condition que soient mentionnés au moins :
330
     * services eFlore, à condition que soient mentionnés au moins :
Line 339... Line 339...
339
            $ref = $obs['taxo_repo'];
339
            $ref = $obs['taxo_repo'];
340
            $ns = $obs['user_sci_name'];
340
            $ns = $obs['user_sci_name'];
341
            $nr = $obs['accepted_sci_name'];
341
            $nr = $obs['accepted_sci_name'];
342
            $nnr = $obs['accepted_sci_name_id'];
342
            $nnr = $obs['accepted_sci_name_id'];
343
            $fam = $obs['family'];
343
            $fam = $obs['family'];
344
            
344
 
345
            // si j'ai un nn, tentative de retrouver le nnr, le user_sci_name,
345
            // si j'ai un nn, tentative de retrouver le nnr, le user_sci_name,
346
            // le accepted_sci_name et la famille, s'ils ne sont pas déjà présents (on
346
            // le accepted_sci_name et la famille, s'ils ne sont pas déjà présents (on
347
            // pourrait les écraser systématiquement mais l'appel au service
347
            // pourrait les écraser systématiquement mais l'appel au service
348
            // dégrade les perfs)
348
            // dégrade les perfs)
349
            if ((! empty($nn) && is_numeric($nn))
349
            if ((! empty($nn) && is_numeric($nn))
350
                // omission du test sur 'accepted_sci_name' car le service eFlore noms ne le retourne que sans auteur (pas bon)
350
                // omission du test sur 'accepted_sci_name' car le service eFlore noms ne le retourne que sans auteur (pas bon)
351
                && (empty($ns) || empty($nnr) || empty($fam) /*|| empty($nr)*/)) {
351
                && (empty($ns) || empty($nnr) || empty($fam) /*|| empty($nr)*/)) {
-
 
352
                // go
-
 
353
                $this->enrichirDonneesTaxonomiquesParNN($ref, $nn, $obs);
-
 
354
            } else {
-
 
355
                // si j'ai un nom complet, avec un peu de bol il sera dans le référentiel
-
 
356
                if ((! empty($ns))
-
 
357
                    && (empty($nn) || empty($nnr) || empty($fam) /*|| empty($nr)*/)) {
352
                    // go
358
                    // go
353
                    $this->enrichirDonneesTaxonomiquesParNN($ref, $nn, $obs);
359
                    $this->enrichirDonneesTaxonomiquesParNS($ref, $ns, $obs);
354
                } else {
360
                }
355
                    // si j'ai un nom complet, avec un peu de bol il sera dans le référentiel
-
 
356
                    if ((! empty($ns))
-
 
357
                        && (empty($nn) || empty($nnr) || empty($fam) /*|| empty($nr)*/)) {
-
 
358
                            // go
-
 
359
                            $this->enrichirDonneesTaxonomiquesParNS($ref, $ns, $obs);
-
 
360
                        }
-
 
361
                } // sinon fuque
361
            } // sinon fuque
362
                
362
 
363
        }
363
        }
364
    }
364
    }
365
    
365
 
366
    /**
366
    /**
367
     * Enrichit le tableau $obs destiné à être inséré dans le BDD, en
367
     * Enrichit le tableau $obs destiné à être inséré dans le BDD, en
368
     * interrogeant le service eFlore/noms par référentiel + nom scientifique
368
     * interrogeant le service eFlore/noms par référentiel + nom scientifique
369
     * avec auteur
369
     * avec auteur
370
     */
370
     */
Line 403... Line 403...
403
            } catch(Exception $e) {
403
            } catch(Exception $e) {
404
                // échec silencieux
404
                // échec silencieux
405
            }
405
            }
406
        }
406
        }
407
    }
407
    }
408
    
408
 
409
    /**
409
    /**
410
     * Enrichit le tableau $obs destiné à être inséré dans le BDD, en
410
     * Enrichit le tableau $obs destiné à être inséré dans le BDD, en
411
     * interrogeant le service eFlore/noms par référentiel + nn
411
     * interrogeant le service eFlore/noms par référentiel + nn
412
     */
412
     */
413
    protected function enrichirDonneesTaxonomiquesParNN($ref, $nn, &$obs) {
413
    protected function enrichirDonneesTaxonomiquesParNN($ref, $nn, &$obs) {
Line 437... Line 437...
437
            } catch(Exception $e) {
437
            } catch(Exception $e) {
438
                // échec silencieux
438
                // échec silencieux
439
            }
439
            }
440
        }
440
        }
441
    }
441
    }
442
    
442
 
443
    private function traiterProjetTags() {
443
    private function traiterProjetTags() {
444
        if (strpos($this->projet, ',') === false) {
444
        if (strpos($this->projet, ',') === false) {
445
            $this->projetTags = array('Projets coopératifs>'.$this->projet);
445
            $this->projetTags = array('Projets coopératifs>'.$this->projet);
446
        } else {
446
        } else {
447
            $projetTagsTxt = explode(',', $this->projet);
447
            $projetTagsTxt = explode(',', $this->projet);
448
            foreach ($projetTagsTxt as $tag) {
448
            foreach ($projetTagsTxt as $tag) {
449
                $this->projetTags[] = 'Projets coopératifs>'.$tag;
449
                $this->projetTags[] = 'Projets coopératifs>'.$tag;
450
            }
450
            }
451
        }
451
        }
452
    }
452
    }
453
    
453
 
454
    private function traiterTagObs($requeteDonnees) {
454
    private function traiterTagObs($requeteDonnees) {
455
        if (array_key_exists('tag-obs', $requeteDonnees) && $requeteDonnees['tag-obs'] != '') {
455
        if (array_key_exists('tag-obs', $requeteDonnees) && $requeteDonnees['tag-obs'] != '') {
456
            $this->tagsObs = explode(',', $requeteDonnees['tag-obs']);
456
            $this->tagsObs = explode(',', $requeteDonnees['tag-obs']);
457
        }
457
        }
458
        foreach ($this->projetTags as $tag) {
458
        foreach ($this->projetTags as $tag) {
459
            $this->tagsObs[] = $tag;
459
            $this->tagsObs[] = $tag;
460
        }
460
        }
461
    }
461
    }
462
    
462
 
463
    private function traiterTagImg($requeteDonnees) {
463
    private function traiterTagImg($requeteDonnees) {
464
        if (array_key_exists('tag-img', $requeteDonnees) && $requeteDonnees['tag-img'] != '') {
464
        if (array_key_exists('tag-img', $requeteDonnees) && $requeteDonnees['tag-img'] != '') {
465
            $this->tagsImg = explode(',', $requeteDonnees['tag-img']);
465
            $this->tagsImg = explode(',', $requeteDonnees['tag-img']);
466
        }
466
        }
467
        foreach ($this->projetTags as $tag) {
467
        foreach ($this->projetTags as $tag) {
468
            $this->tagsImg[] = $tag;
468
            $this->tagsImg[] = $tag;
469
        }
469
        }
470
    }
470
    }
471
    
471
 
472
    private function ajouterChampsEtendusObs($obs_ids, $obs_a_champs_etendus) {
472
    private function ajouterChampsEtendusObs($obs_ids, $obs_a_champs_etendus) {
473
        $champs_etendus_obs = array();
473
        $champs_etendus_obs = array();
474
        $gestionChampsEtendus = new GestionChampsEtendus($this->config, 'obs');
474
        $gestionChampsEtendus = new GestionChampsEtendus($this->config, 'obs');
475
        
475
 
476
        foreach ($obs_ids as $id_obs) {
476
        foreach ($obs_ids as $id_obs) {
477
            $champs = array_shift($obs_a_champs_etendus);
477
            $champs = array_shift($obs_a_champs_etendus);
478
            if ($champs != null && is_array($champs)) {
478
            if ($champs != null && is_array($champs)) {
479
                foreach ($champs as $infosChamp) {
479
                foreach ($champs as $infosChamp) {
480
                    $cle = isset($infosChamp['cle']) ? $infosChamp['cle'] : '';
480
                    $cle = isset($infosChamp['cle']) ? $infosChamp['cle'] : '';
481
                    $valeur = isset($infosChamp['valeur']) ? $infosChamp['valeur'] : '';
481
                    $valeur = isset($infosChamp['valeur']) ? $infosChamp['valeur'] : '';
482
                    
482
 
483
                    if (!empty($cle) && $valeur !== '') {
483
                    if (!empty($cle) && $valeur !== '') {
484
                        $champEtendu = new ObsEtendue();
484
                        $champEtendu = new ObsEtendue();
485
                        $champEtendu->id = $id_obs;
485
                        $champEtendu->id = $id_obs;
486
                        $champEtendu->cle = $cle;
486
                        $champEtendu->cle = $cle;
487
                        $champEtendu->valeur = $valeur;
487
                        $champEtendu->valeur = $valeur;
488
                        
488
 
489
                        $champs_etendus_obs[] = $champEtendu;
489
                        $champs_etendus_obs[] = $champEtendu;
490
                    }
490
                    }
491
                }
491
                }
492
            }
492
            }
493
        }
493
        }
494
        
494
 
495
        if(! $champs_etendus_obs) return TRUE;
495
        if(! $champs_etendus_obs) return TRUE;
496
        
496
 
497
        return $gestionChampsEtendus->ajouterParLots($champs_etendus_obs, $this->projet);
497
        return $gestionChampsEtendus->ajouterParLots($champs_etendus_obs, $this->projet);
498
    }
498
    }
499
    
499
 
500
    private function traiterImagesALierAObs($idObs, $obs) {
500
    private function traiterImagesALierAObs($idObs, $obs) {
501
        $imgAAjouter = array();
501
        $imgAAjouter = array();
502
        if (is_array($obs['image_nom'])) {
502
        if (is_array($obs['image_nom'])) {
503
            foreach ($obs['image_nom'] as $index => $nom_image) {
503
            foreach ($obs['image_nom'] as $index => $nom_image) {
504
                $image = array();
504
                $image = array();
Line 518... Line 518...
518
            $image['nom'] = $obs['image_nom'];
518
            $image['nom'] = $obs['image_nom'];
519
            $image['b64'] = $obs['image_b64'] ?? null;
519
            $image['b64'] = $obs['image_b64'] ?? null;
520
            $this->debug[] = 'Contient B64 : '.(isset($obs['image_b64']) ? 'oui' : 'non');
520
            $this->debug[] = 'Contient B64 : '.(isset($obs['image_b64']) ? 'oui' : 'non');
521
            $imgAAjouter[] = $image;
521
            $imgAAjouter[] = $image;
522
        }
522
        }
523
        
523
 
524
        return $imgAAjouter;
524
        return $imgAAjouter;
525
    }
525
    }
526
    
526
 
527
    protected function stockerImagesEtLierAObs($id_obs, $img) {
527
    protected function stockerImagesEtLierAObs($id_obs, $img) {
528
        $img_a_taguer_ids_noms = array();
528
        $img_a_taguer_ids_noms = array();
529
        foreach ($img as $image) {
529
        foreach ($img as $image) {
530
            $image['nom'] = trim(rtrim($image['nom'], "'"), "'");
530
            $image['nom'] = trim(rtrim($image['nom'], "'"), "'");
531
            $nomFichierImg = $this->traiterNomFichierImage($image['nom']);
531
            $nomFichierImg = $this->traiterNomFichierImage($image['nom']);
532
            $cheminImage = $this->config['cel']['chemin_stockage_temp']."/$nomFichierImg";
532
            $cheminImage = $this->config['cel']['chemin_stockage_temp']."/$nomFichierImg";
533
            // Si l'image est transmise en base 64
533
            // Si l'image est transmise en base 64
534
            if (isset($image['b64'])) {
534
            if (isset($image['b64'])) {
535
                $this->transformerBase64enFichier($cheminImage, $image['b64']);
535
                $this->transformerBase64enFichier($cheminImage, $image['b64']);
536
            }
536
            }
537
            
537
 
538
            $this->debug[] = 'Nom fichier img debut :'.$nomFichierImg;
538
            $this->debug[] = 'Nom fichier img debut :'.$nomFichierImg;
539
            $idImg = $this->ajouterImageSurDdEtBdd($id_obs, $cheminImage, $nomFichierImg);
539
            $idImg = $this->ajouterImageSurDdEtBdd($id_obs, $cheminImage, $nomFichierImg);
540
            if ($idImg !== false) {
540
            if ($idImg !== false) {
541
                $img_a_taguer_ids_noms[$idImg] = $nomFichierImg;
541
                $img_a_taguer_ids_noms[$idImg] = $nomFichierImg;
542
                if (isset($image['tags'])) {
542
                if (isset($image['tags'])) {
Line 553... Line 553...
553
                break;
553
                break;
554
            }
554
            }
555
        }
555
        }
556
        return $img_a_taguer_ids_noms;
556
        return $img_a_taguer_ids_noms;
557
    }
557
    }
558
    
558
 
559
    private function supprimerSlashesProfond($valeur) {
559
    private function supprimerSlashesProfond($valeur) {
560
        $valeur = is_array($valeur) ? array_map(array($this, 'supprimerSlashesProfond'), $valeur) : stripslashes($valeur);
560
        $valeur = is_array($valeur) ? array_map(array($this, 'supprimerSlashesProfond'), $valeur) : stripslashes($valeur);
561
        return $valeur;
561
        return $valeur;
562
    }
562
    }
563
    
563
 
564
    /**
564
    /**
565
     * Transforme une date au format français (jj/mm/aaaa) dans un format Mysql (aaaa-mm-jj).
565
     * Transforme une date au format français (jj/mm/aaaa) dans un format Mysql (aaaa-mm-jj).
566
     * @param string $dateFr date au format français (jj/mm/aaaa)
566
     * @param string $dateFr date au format français (jj/mm/aaaa)
567
     * @return string date au format Mysql (aaaa-mm-jj)
567
     * @return string date au format Mysql (aaaa-mm-jj)
568
     */
568
     */
Line 572... Line 572...
572
        if (count($morceauxDate) == 3) {
572
        if (count($morceauxDate) == 3) {
573
            $dateMysql = implode('-', array_reverse($morceauxDate));
573
            $dateMysql = implode('-', array_reverse($morceauxDate));
574
        }
574
        }
575
        return $dateMysql;
575
        return $dateMysql;
576
    }
576
    }
577
    
577
 
578
    private function taguerObs($obs_a_taguer_ids) {
578
    private function taguerObs($obs_a_taguer_ids) {
579
        if (count($obs_a_taguer_ids) > 0) {
579
        if (count($obs_a_taguer_ids) > 0) {
580
            foreach ($this->tagsObs as $hierarchieTag) {
580
            foreach ($this->tagsObs as $hierarchieTag) {
581
                $tagsALier = explode('>', $hierarchieTag);
581
                $tagsALier = explode('>', $hierarchieTag);
582
                $liaisonOk = $this->lierObsAMotsCles($obs_a_taguer_ids, $tagsALier);
582
                $liaisonOk = $this->lierObsAMotsCles($obs_a_taguer_ids, $tagsALier);
Line 585... Line 585...
585
                    $this->messages[] = $e;
585
                    $this->messages[] = $e;
586
                }
586
                }
587
            }
587
            }
588
        }
588
        }
589
    }
589
    }
590
    
590
 
591
    private function lierObsAMotsCles($observations_ids, $tags) {
591
    private function lierObsAMotsCles($observations_ids, $tags) {
592
        // pas de mots clés pour les non-inscrits
592
        // pas de mots clés pour les non-inscrits
593
        if ($this->userId == null) {
593
        if ($this->userId == null) {
594
            $this->userId = 0;
594
            $this->userId = 0;
595
        }
595
        }
596
        
596
 
597
        $chemin_parent = '/';
597
        $chemin_parent = '/';
598
        $listeIdsTags = array();
598
        $listeIdsTags = array();
599
        foreach ($tags as $tag) {
599
        foreach ($tags as $tag) {
600
            $tag = $this->nettoyerTag($tag);
600
            $tag = $this->nettoyerTag($tag);
601
            if ($tag != '') {
601
            if ($tag != '') {
Line 604... Line 604...
604
                    $listeIdsTags[] = $id_mot_cle;
604
                    $listeIdsTags[] = $id_mot_cle;
605
                    $chemin_parent .= $tag."/";
605
                    $chemin_parent .= $tag."/";
606
                }
606
                }
607
            }
607
            }
608
        }
608
        }
609
        
609
 
610
        $liaison_ok = $this->gestionMotsClesObs->lierParTableaux($listeIdsTags, $observations_ids);
610
        $liaison_ok = $this->gestionMotsClesObs->lierParTableaux($listeIdsTags, $observations_ids);
611
        return $liaison_ok;
611
        return $liaison_ok;
612
    }
612
    }
613
    
613
 
614
    private function taguerImg($img_a_taguer_ids) {
614
    private function taguerImg($img_a_taguer_ids) {
615
        if (count($img_a_taguer_ids) > 0) {
615
        if (count($img_a_taguer_ids) > 0) {
616
            $this->debug[] = "Tags img : ".print_r($this->tagsImg, true);
616
            $this->debug[] = "Tags img : ".print_r($this->tagsImg, true);
617
            foreach ($this->tagsImg as $hierarchieTag) {
617
            foreach ($this->tagsImg as $hierarchieTag) {
618
                $tagsALier = explode('>', $hierarchieTag);
618
                $tagsALier = explode('>', $hierarchieTag);
Line 630... Line 630...
630
                    $this->lierImgAMotsCles(array($id_img), $tags);
630
                    $this->lierImgAMotsCles(array($id_img), $tags);
631
                }
631
                }
632
            }
632
            }
633
        }
633
        }
634
    }
634
    }
635
    
635
 
636
    private function lierImgAMotsCles($images_ids, $tags) {
636
    private function lierImgAMotsCles($images_ids, $tags) {
637
        // pas de mots clés pour les non-inscrits
637
        // pas de mots clés pour les non-inscrits
638
        if ($this->userId == null) {
638
        if ($this->userId == null) {
639
            $this->userId = 0;
639
            $this->userId = 0;
640
        }
640
        }
641
        
641
 
642
        $chemin_parent = "/";
642
        $chemin_parent = "/";
643
        $listeIdsTags = array();
643
        $listeIdsTags = array();
644
        foreach ($tags as $tag) {
644
        foreach ($tags as $tag) {
645
            $tag = $this->nettoyerTag($tag);
645
            $tag = $this->nettoyerTag($tag);
646
            if ($tag != '') {
646
            if ($tag != '') {
Line 652... Line 652...
652
            }
652
            }
653
        }
653
        }
654
        $liaison_ok = $this->gestionMotsClesImages->lierParTableaux($listeIdsTags, $images_ids);
654
        $liaison_ok = $this->gestionMotsClesImages->lierParTableaux($listeIdsTags, $images_ids);
655
        return $liaison_ok;
655
        return $liaison_ok;
656
    }
656
    }
657
    
657
 
658
    private function nettoyerTag($tag) {
658
    private function nettoyerTag($tag) {
659
        $tag = trim($tag);
659
        $tag = trim($tag);
660
        $tag = preg_replace('/(?:\s+|[,]+)/', ' ', $tag);
660
        $tag = preg_replace('/(?:\s+|[,]+)/', ' ', $tag);
661
        return $tag;
661
        return $tag;
662
    }
662
    }
663
    
663
 
664
    private function traiterNomFichierImage($fichierNom) {
664
    private function traiterNomFichierImage($fichierNom) {
665
        $fichierNom = preg_replace('/[.](jpeg|jpg)$/i', '.jpg', strtolower(trim($fichierNom)));
665
        $fichierNom = preg_replace('/[.](jpeg|jpg)$/i', '.jpg', strtolower(trim($fichierNom)));
666
        return $fichierNom;
666
        return $fichierNom;
667
    }
667
    }
668
    
668
 
669
    /**
669
    /**
670
     * Décode l'image en base64,enregistre celle-ci sous forme de fichier du type de l'image
670
     * Décode l'image en base64,enregistre celle-ci sous forme de fichier du type de l'image
671
     *  dans un dossier temporaire.
671
     *  dans un dossier temporaire.
672
     */
672
     */
673
    private function transformerBase64enFichier($cheminImage, $imageInfosB64) {
673
    private function transformerBase64enFichier($cheminImage, $imageInfosB64) {
674
        // Enleve la partie data:image qui permet la previsalisation pour firefox de l'image en base64
674
        // Enleve la partie data:image qui permet la previsalisation pour firefox de l'image en base64
675
        $imageBase64 = explode(';', $imageInfosB64);
675
        $imageBase64 = explode(';', $imageInfosB64);
676
        $dataBase64 = explode(',',$imageBase64[1]);
676
        $dataBase64 = explode(',',$imageBase64[1]);
677
        $dataImg = base64_decode($dataBase64[1]);
677
        $dataImg = base64_decode($dataBase64[1]);
678
        
678
 
679
        $imageRessource = fopen($cheminImage, 'wb');
679
        $imageRessource = fopen($cheminImage, 'wb');
680
        fwrite($imageRessource, $dataImg);
680
        fwrite($imageRessource, $dataImg);
681
        fclose($imageRessource);
681
        fclose($imageRessource);
682
        
682
 
683
        if (file_exists($cheminImage) == false) {
683
        if (file_exists($cheminImage) == false) {
684
            $this->messages[] = "Erreur lors de la création du fichier";
684
            $this->messages[] = "Erreur lors de la création du fichier";
685
        }
685
        }
686
    }
686
    }
687
    
687
 
688
    /**
688
    /**
689
     * Supprime toutes les images temporaires dont :
689
     * Supprime toutes les images temporaires dont :
690
     * - l'ancienneté est supérieure à DUREE_DE_VIE_IMG (si $nomsDeFichiers est vide, par défaut)
690
     * - l'ancienneté est supérieure à DUREE_DE_VIE_IMG (si $nomsDeFichiers est vide, par défaut)
691
     * - le nom correspond à un des éléments du tableau $nomsDeFichiers (s'il est spécifié et non vide)
691
     * - le nom correspond à un des éléments du tableau $nomsDeFichiers (s'il est spécifié et non vide)
692
     */
692
     */
Line 714... Line 714...
714
                    }
714
                    }
715
                }
715
                }
716
            }
716
            }
717
        }
717
        }
718
    }
718
    }
719
    
719
 
720
    /**
720
    /**
721
     * Ajoute une image dans la base de données et stocke le fichier en fabriquant les miniatures,
721
     * Ajoute une image dans la base de données et stocke le fichier en fabriquant les miniatures,
722
     * renvoie le nouvel id d'image en cas de succès
722
     * renvoie le nouvel id d'image en cas de succès
723
     *
723
     *
724
     * @param string $id_obs l'id de l'obs
724
     * @param string $id_obs l'id de l'obs
Line 750... Line 750...
750
                $resultat = Cel::db()->executer($requete);
750
                $resultat = Cel::db()->executer($requete);
751
                if ($resultat !== false) {
751
                if ($resultat !== false) {
752
                    $idImage = $this->traiterEtRecupererIdImage($nomFichierImage);
752
                    $idImage = $this->traiterEtRecupererIdImage($nomFichierImage);
753
                    if ($idImage !== false) {
753
                    if ($idImage !== false) {
754
                        $infosImage['url'] = 'https://api.tela-botanica.org/img:'.str_pad($idImage, 9, '0', STR_PAD_LEFT).'O';
754
                        $infosImage['url'] = 'https://api.tela-botanica.org/img:'.str_pad($idImage, 9, '0', STR_PAD_LEFT).'O';
755
                        
755
 
756
                        $manipulateurImage = new ImageRecreation($this->config);
756
                        $manipulateurImage = new ImageRecreation($this->config);
757
                        // Stocke le fichier en conservant les fichiers temporaires, ce qui permet de réessayer
757
                        // Stocke le fichier en conservant les fichiers temporaires, ce qui permet de réessayer
758
                        // de les traiter en cas d'échec de la totalité du processus de traitement de l'obs
758
                        // de les traiter en cas d'échec de la totalité du processus de traitement de l'obs
759
                        $stockageOk = $manipulateurImage->stockerFichierOriginal($cheminImage, $idImage, true);
759
                        $stockageOk = $manipulateurImage->stockerFichierOriginal($cheminImage, $idImage, true);
760
                        if ($stockageOk) {
760
                        if ($stockageOk) {
Line 762... Line 762...
762
                            if (file_exists($miniatureChemin)) {
762
                            if (file_exists($miniatureChemin)) {
763
                                if (@unlink($miniatureChemin) === false) {
763
                                if (@unlink($miniatureChemin) === false) {
764
                                    $this->messages[] = "La miniature de l'image n'a pu être supprimée.";
764
                                    $this->messages[] = "La miniature de l'image n'a pu être supprimée.";
765
                                }
765
                                }
766
                            }
766
                            }
767
                            
767
 
768
                        } else {
768
                        } else {
769
                            $this->messages[] = "Une erreur s'est produite lors du stockage du fichier.";
769
                            $this->messages[] = "Une erreur s'est produite lors du stockage du fichier.";
770
                            // Remise à zéro d'idImage pour que l'erreur ne soit pas ignorée par l'appelant
770
                            // Remise à zéro d'idImage pour que l'erreur ne soit pas ignorée par l'appelant
771
                            $idImage = false;
771
                            $idImage = false;
772
                        }
772
                        }
Line 782... Line 782...
782
        } else {
782
        } else {
783
            $this->messages[] = "L'image originale est introuvable sur le serveur.";
783
            $this->messages[] = "L'image originale est introuvable sur le serveur.";
784
        }
784
        }
785
        return $idImage;
785
        return $idImage;
786
    }
786
    }
787
    
787
 
788
    /**
788
    /**
789
     * Supprime une image du disque dur. Ne touche pas à la base de données, on considère
789
     * Supprime une image du disque dur. Ne touche pas à la base de données, on considère
790
     * que c'est le rôle de la transaction d'annuler les écritures en cas de problème
790
     * que c'est le rôle de la transaction d'annuler les écritures en cas de problème
791
     *
791
     *
792
     * @param Integer $idImageASupprimer
792
     * @param Integer $idImageASupprimer
793
     * @return boolean $ok true si la suppression s'est bien passée, false s'il reste au moins un fichier
793
     * @return boolean $ok true si la suppression s'est bien passée, false s'il reste au moins un fichier
794
     */
794
     */
795
    protected function effacerImageDuDd($idImageASupprimer) {
795
    protected function effacerImageDuDd($idImageASupprimer) {
796
        $manipulateurImage = new ImageRecreation($this->config);
796
        $manipulateurImage = new ImageRecreation($this->config);
797
        $ok = $manipulateurImage->detruireImageSurDisque($idImageASupprimer);
797
        $ok = $manipulateurImage->detruireImageSurDisque($idImageASupprimer);
798
        
798
 
799
        return $ok;
799
        return $ok;
800
    }
800
    }
801
    
801
 
802
    private function traiterEtRecupererIdImage($original_name) {
802
    private function traiterEtRecupererIdImage($original_name) {
803
        $id_utilisateur = Cel::db()->proteger($this->userId);
803
        $id_utilisateur = Cel::db()->proteger($this->userId);
804
        $email_utilisateur = Cel::db()->proteger($this->userEmail);
804
        $email_utilisateur = Cel::db()->proteger($this->userEmail);
805
        $original_name = Cel::db()->proteger($original_name);
805
        $original_name = Cel::db()->proteger($original_name);
806
        
806
 
807
        $requete = 'SELECT id '.
807
        $requete = 'SELECT id '.
808
            'FROM photo '.
808
            'FROM photo '.
809
            "WHERE (user_id = $id_utilisateur OR user_email = $email_utilisateur)".
809
            "WHERE (user_id = $id_utilisateur OR user_email = $email_utilisateur)".
810
            "	AND original_name = $original_name ";
810
            "	AND original_name = $original_name ";
811
        $resultat = Cel::db()->requeter($requete);
811
        $resultat = Cel::db()->requeter($requete);
812
        $id_image = $resultat[0]['id'] ?? false;
812
        $id_image = $resultat[0]['id'] ?? false;
813
        
813
 
814
        if ($id_image) {
814
        if ($id_image) {
815
            $full_id_image = str_pad($id_image, 9, '0', STR_PAD_LEFT) . 'O';
815
            $full_id_image = str_pad($id_image, 9, '0', STR_PAD_LEFT) . 'O';
816
            $image_url = sprintf($this->config['settings']['celImgUrlTpl'], $full_id_image);
816
            $image_url = sprintf($this->config['settings']['celImgUrlTpl'], $full_id_image);
817
            $requete = 'UPDATE photo'
817
            $requete = 'UPDATE photo'
818
                . ' SET url = ' . Cel::db()->proteger($image_url)
818
                . ' SET url = ' . Cel::db()->proteger($image_url)
819
                . ' WHERE id = ' . Cel::db()->proteger($id_image);
819
                . ' WHERE id = ' . Cel::db()->proteger($id_image);
820
                $resultat = Cel::db()->requeter($requete);
820
            $resultat = Cel::db()->requeter($requete);
821
        }
821
        }
822
        
822
 
823
        return $id_image;
823
        return $id_image;
824
        
824
 
825
    }
825
    }
826
    
826
 
827
    private function construireRequeteInsertionImage($informations) {
827
    private function construireRequeteInsertionImage($informations) {
828
        $champs = array();
828
        $champs = array();
829
        $valeurs = array();
829
        $valeurs = array();
830
        foreach ($informations as $champ => $valeur) {
830
        foreach ($informations as $champ => $valeur) {
831
            $champs[] = $champ;
831
            $champs[] = $champ;
Line 837... Line 837...
837
                $valeurs[$champ] = Cel::db()->proteger($valeur);
837
                $valeurs[$champ] = Cel::db()->proteger($valeur);
838
            }
838
            }
839
        }
839
        }
840
        $champsConcat = implode(', ', $champs);
840
        $champsConcat = implode(', ', $champs);
841
        $valeursConcat = implode(', ', $valeurs);
841
        $valeursConcat = implode(', ', $valeurs);
842
        
842
 
843
        $requete = "INSERT INTO photo ($champsConcat) VALUES ($valeursConcat) ".
843
        $requete = "INSERT INTO photo ($champsConcat) VALUES ($valeursConcat) ".
844
            ' -- '.__FILE__.':'.__LINE__;
844
            ' -- '.__FILE__.':'.__LINE__;
845
        return $requete;
845
        return $requete;
846
    }
846
    }
847
}
847
}