| New file |
|---|
| 0,0 → 1,123 |
|---|
| <?php |
| // declare(encoding='UTF-8'); |
| /** |
| * Service permettant d'insérer les informations fournie par le widget Saisie dans le CEL. |
| * Encodage en entrée : utf8 |
| * Encodage en sortie : utf8 |
| * |
| * Cas d'utilisation : |
| * PUT /CelWidgetSaisie : ajout de données en les passant via $_POST |
| * |
| * @author Jean-Pascal MILCENT <jpm@clapas.org> |
| * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt> |
| * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt> |
| * @version $Id$ |
| * @copyright © 2011, Jean-Pascal MILCENT |
| */ |
| class CelWidgetSaisie extends Cel { |
| |
| public function getElement($ressources) { |
| $this->envoyerJson($ressources); |
| } |
| |
| public function createElement($requeteDonnees){ |
| if (array_key_exists('utilisateur', $requeteDonnees)) { |
| $this->debug[] = 'Utilisateur : ok'; |
| $utilisateur = $requeteDonnees['utilisateur']; |
| if (array_key_exists('courriel', $utilisateur)) { |
| $this->debug[] = 'Courriel : ok'; |
| extract($utilisateur); |
| $ordre = $this->getMaxOrdre($courriel); |
| if (!is_null($ordre)) { |
| $this->debug[] = 'Ordre : ok'; |
| // Triage et manipulation des données |
| $observations = array(); |
| foreach ($requeteDonnees as $cle => $obs) { |
| if (preg_match('/^obsId[0-9]+$/', $cle)) { |
| $obsAAjouter = array(); |
| $obsAAjouter['identifiant'] = $courriel; |
| $obsAAjouter['prenom_utilisateur'] = $prenom; |
| $obsAAjouter['nom_utilisateur'] = $nom; |
| $obsAAjouter['ordre'] = $ordre++; |
| $obsAAjouter['nom_sel'] = $obs['nom_sel']; |
| $obsAAjouter['num_nom_sel'] = $obs['num_nom_sel']; |
| $obsAAjouter['nom_ret'] = $obs['nom_ret']; |
| $obsAAjouter['num_nom_ret'] = $obs['num_nom_ret']; |
| $obsAAjouter['num_taxon'] = $obs['num_taxon']; |
| $obsAAjouter['famille'] = $obs['famille']; |
| $obsAAjouter['date_observation'] = $this->transormerDateFrVersMysql($obs['date']); |
| $obsAAjouter['milieu'] = $obs['milieu']; |
| $obsAAjouter['commentaire'] = $obs['notes']; |
| $obsAAjouter['transmission'] = '1'; |
| $obsAAjouter['date_creation'] = date('Y-m-d H:i:s'); |
| $obsAAjouter['date_transmission'] = date('Y-m-d H:i:s'); |
| $obsAAjouter['mots_cles_texte'] = $obs['tag']; |
| $obsAAjouter['coord_x'] = $obs['latitude']; |
| $obsAAjouter['coord_y'] = $obs['longitude']; |
| $obsAAjouter['ref_geo'] = 'WGS84'; |
| |
| $observations[] = $this->protegerTableau($obsAAjouter); |
| } |
| } |
| $this->debug[] = 'Nbre obs ajoutée : '.count($observations); |
| // Insertion dans la base |
| $ok = true; |
| foreach ($observations as $obs) { |
| $insert = "INSERT INTO cel_inventory "; |
| $champs = '('.implode(', ', array_keys($obs)).') '; |
| $values = 'VALUES ('.implode(', ', $obs).') '; |
| $requete = $insert.$champs.$values; |
| if ($this->executerRequeteSimple($requete) == false) { |
| $ok = false; |
| } |
| } |
| if ($ok === false) { |
| $this->messages[] = "Un problème est survenu lors de l'insertion dans la base de données."; |
| } |
| } else { |
| $this->messages[] = "Un nouveau numéro d'ordre d'observation n'a pu être généré."; |
| } |
| } else { |
| $this->messages[] = "L'identifiant de l'utilisateur (courriel) n'a pas été transmis."; |
| } |
| } else { |
| $this->messages[] = "Les informations concernant l'utilisateur (prénom, nom, courriel) n'ont pas été transmises."; |
| } |
| $this->envoyer('ici'); |
| } |
| |
| private function getMaxOrdre($identifiant) { |
| $ordre = null; |
| $identifiant = $this->bdd->quote($identifiant); |
| $requete = "SELECT MAX(ordre) AS ordre ". |
| "FROM cel_inventory ". |
| "WHERE identifiant = $identifiant "; |
| $ordre_max = $this->executerRequete($requete, 'Column'); |
| if ($ordre_max !== false) { |
| $ordre = $ordre_max + 1; |
| } |
| return $ordre; |
| } |
| |
| private function protegerTableau(Array $tableau) { |
| foreach ($tableau as $id => $val) { |
| $tableau[$id] = $this->bdd->quote($val); |
| } |
| return $tableau; |
| } |
| |
| /** |
| * Transforme une date au format français (jj/mm/aaaa) dans un format Mysql (aaaa-mm-jj). |
| * @param string $dateFr date au format français (jj/mm/aaaa) |
| * @return string date au format Mysql (aaaa-mm-jj) |
| */ |
| private function transormerDateFrVersMysql($dateFr) { |
| $dateMysql = '0000-00-00'; |
| $morceauxDate = explode('/', $dateFr); |
| if (count($morceauxDate) == 3) { |
| $dateMysql = implode('-', array_reverse($morceauxDate)); |
| } |
| return $dateMysql; |
| } |
| } |
| ?> |