WebSVN – eFlore/Applications.cel – Diff – /branches/v3.00-serfouette/scripts/modules/pull_plantnet/PullPlantnet.php


<?php
 
/*
	PHP 7
 
	Script used to synchronize PN occ with Flora Data
 
	Écrit en franglish pour une meilleure compréhension (lol)
*/
 
class PullPlantnet extends Script {
 
	protected $bdd;
 
	protected $debug = false;
 
	protected $allowedPartners = ['tb', 'pn'];
 
	// Nom du fichier contenant les correspondances d'ID TB/PN
	protected $correspondingIdsFilename = '';
 
	// Cache d'informations utilisateurs provenant de l'annuaire TB
	protected $userInfos = [];
 
	// Cache des obs id PN traitées pendant cette run
	protected $processedObsId = [];
 
	// Paramètre de suivi et de pagination de l'API des obs PN
	protected $currentPage = '';
	protected $currentProject = '';
	protected $hasMore = false;
 
 
	// Traduction des organes de PN
	protected $tagsImageTraduits = [
		'flower' => 'fleur',
		'fruit' => 'fruit',
		'leaf' => 'feuille',
		'bark' => 'écorce',
		'branch' => 'branche',
		'habit' => 'port',
	];
 
	// Différents types de lifecle possible pour filtrer les obs
	// Modified renvoi les obs en fonction de leur date de modif
	// Created, en fonction de la date de création
	// Deleted, well, you already got it
	protected $lifecycles = [
		'created',
		'modified',
		'deleted', // deleted peut être très lent (pas d'index coté PN pour le moment)
	];
 
	/**
	 * Paramêtres par défaut disponibles pour la ligne de commande
	 * le tableau se construit de la forme suivante :
	 * - clé =  nom du paramêtre '-foo'
	 * - value = contient un nouveau tableau composé de cette façon :
	 *  - booléen: true si le paramêtre est obligatoire
	 *  - booléen ou var : true si le paramêtre nécessite un valeur à sa suite ou la valeur par défaut
	 *  - string: description du contenu du paramêtre
	 * Les paramêtres optionels devraient être déclaré à la fin du tableau.
	 * Le dernier parametre du tableau peut avoir la valeur '...',
	 * il contiendra alors l'ensemble des paramêtres suivant trouvés sur la ligne de commande.
	 * @var array
	 */
	protected $parametres_autorises = array(
		'-startDate' => array(false, true, 'Date de début (parsée par strtotime). Ex: "YYYY:MM:DD HH:II:SS"'),
		'-lifecycle' => array(false, true, 'Par défaut : modified ; Au choix parmi : created/modified/deleted (deleted est lent)'),
		'-pnObsId' => array(false, true, "ID de l'obs chez PlantNet"),
		'-project' => array(false, true, "projectId de l'obs chez PlantNet"),
		'-tbObsId' => array(false, true, "ID de l'obs chez Tela"),
		'-debug' => array(false, false, "Mode débug (ajoute du log) Au choix parmi : debug/log (log est plus verbeux)"),
	);
 
	public function __construct($script_nom, $parametres_cli) {
		parent::__construct($script_nom, $parametres_cli);
		$this->bdd = new Bdd();
 
		$this->correspondingIdsFilename = Config::get('correspondingIdsFilename');
 
		$this->debug = $this->getParametre('debug');
	}
 
	public function executer() {
		$cmd = $this->getParametre('a');
 
		switch ($cmd) {
			case 'updateLatest':
				$this->updateLatest($this->getParametre('startDate'), $this->getParametre('lifecycle'));
				break;
			case 'updateOnePN':
				$this->updateOnePN((int)$this->getParametre('pnObsId'), $this->getParametre('project'));
				break;
			case 'updateOneTB':
				$this->updateOneTB((int)$this->getParametre('tbObsId'));
				break;
			case 'updateCorrespondingIdsTable':
				$this->updateCorrespondingIdsTable();
				break;
			default:
				$msg = "Erreur : la commande '$cmd' n'existe pas!\n"
						. ', utilisez plutôt :' . "\n"
						. 'php cli.php PullPlantnet -a updateLatest -startDate "YYYY:MM:DD HH:II:SS" [[-lifecycle [modified]/created/deleted]]' . "\n"
						. 'php cli.php PullPlantnet -a updateOnePN -pnObsId "1234567890" -project "xxxxxx"' . "\n"
						. 'php cli.php PullPlantnet -a updateOneTB -tbObsId "1234567890"' . "\n"
						. 'php cli.php PullPlantnet -a updateCorrespondingIdsTable' . "\n"
						;
				throw new Exception($msg);
		}
	}
 
	/**
	 * Considering all modified pn obs since startDate
	 * One pn project after an other
	 * Inserting obs in tb db (if new and matching user email)
	 */
	private function updateLatest(string $startDate = '1917:03:15 00:00:00', string $lifecycle = 'modified') {
		$startDate = strtotime($startDate) * 1000; // we need a microtimestamp
 
		$pnProjects = $this->getProjects(); // refresh projects list
		foreach ($pnProjects as $project) {
			do {
				$observations_PN = $this->getProjectLatest($project, $startDate, $lifecycle);
				$this->updateObs($observations_PN);
			} while ($this->hasMore);
		}
	}
 
	private function getProjectLatest(array $project, int $startDate, string $lifecycle): array {
		$this->currentProject = $project;
 
		if (!$this->currentPage) {
			echo 'Projet ' . $project['name'] . "\n";
 
			// hop, on appelle le service de PN
			$url_service = str_replace(
				['{project}', '{token}', '{startDate}', '{lifecycle}'],
				[$project['id'], Config::get('tokenPlantnet'), $startDate, $lifecycle],
				Config::get('urlPlantnetBase').Config::get('urlPlantnetLatestChanges')
			);
 
			$this->debug("URL service derniers changements : $url_service");
 
			$this->currentPage = $url_service;
		}
 
		$ch = curl_init($this->currentPage);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
		$reponse = curl_exec($ch);
		$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
		curl_close($ch);
 
		// cool, maintenant on va trier ce qu'on a reçu
		if (!$reponse) {
			throw new Exception("\nPN ne répond rien à l'adresse {$this->currentPage}\n");
		} elseif (200 != $code) {
			// l'api répond avec une 404 quand y'a une date dans le futur ou simplement pas de nouvelle obs...
			if (404 == $code && strpos($reponse, 'No more results')) {
				$this->log("Pas d'autres résultats");
				$this->hasMore = false;
				$this->currentPage = '';
				return [];
			}
			throw new Exception("\nPN répond avec une $code à l'adresse {$this->currentPage} : $reponse\n");
		}
		$responseJson = json_decode($reponse, true);
		$observations_PN = $responseJson['data'] ?? [];
 
		$this->hasMore = $responseJson['hasMore'];
		if ($this->hasMore) {
 
			$this->currentPage = Config::get('urlPlantnetBase').$responseJson['next'];
			$this->debug("URL service derniers changements, page suivante : {$this->currentPage}");
		} else {
			$this->currentPage = '';
 
		}
 
		return $observations_PN;
	}
 
	private function getProjects(): array {
		// get PN projects list
		$url = str_replace('{token}', Config::get('tokenPlantnet'), Config::get('urlPlantnetBase').Config::get('urlPlantnetProjects'));
 
		$this->debug("URL service liste projets : $url");
 
		$ch = curl_init($url);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
		$reponse = curl_exec($ch);
		$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
		curl_close($ch);
 
		if (!$reponse || 200 != $code) {
			throw new Exception("\nPN répond avec une $code à l'adresse $url : $reponse\n");
		}
		$pnProjects = json_decode($reponse, true);
 
		echo 'Liste de projets récupérée : ' . count($pnProjects) . " projets dans la liste\n";
 
		$this->debug("Liste projets : " . json_encode($pnProjects));
 
		return $pnProjects;
	}
 
	/**
	 * For a given bunch of plantnet obs, post new one threw saisie widget service
	 */
	private function updateObs(array $observations_PN) {
 
		$url_cel_widget_saisie = Config::get('urlCelWidgetSaisie');
 
		foreach ($observations_PN as $obs) {
			// est-ce qu'on a déjà traité cette obs ? (oui une même obs peut être dans plusieurs projects)
			if (in_array($obs['id'], $this->processedObsId)) {
				$this->log("Obs {$obs['id']} déjà traitée pendant cette run");
				continue;
			} else {
				$this->processedObsId[] = $obs['id'];
				$this->log("Obs {$obs['id']} ajoutée à la liste de cette run");
			}
 
			// on ne teste pas la suppression de l'obs ici, faut le faire après avoir vérifié si on l'a déjà synchro
			if (!isset($obs['currentName'])) {
				$this->log("Obs {$obs['id']} sans nom de taxon, on zap");
				continue; // pas de nom de taxon, obs inutile
			}
			if (!isset($obs['geo'])) {
				$this->log("Obs {$obs['id']} sans geom, on zap");
				continue; // pas de position, obs inutile
			}
			if (!isset($obs['dateObs'])) {
				$this->log("Obs {$obs['id']} sans date, on zap");
				continue; // pas de date, obs inutile
			}
 
			if (isset($obs['partner']['id']) && 'tela' === $obs['partner']['id']) {
				// c'est une obs tela
				// si c'est mis à jour récemment coté PN et qu'on l'a pas supprimée chez nous entre temps
					// on update les votes PN
					// on update l'identification proposée par PN
 
				// @TODO
				$this->log("Obs {$obs['id']} venant de Tela, mise à jour pas implémentée, on zap");
				continue;
			} elseif (!isset($obs['partner']['id'])) {
				// ce n'est pas une obs d'un partenaire, c'est donc une obs PN
				// on récupère l'id utilisateur tela via son mail
				$email = $obs['author']['email'];
				$infos_utilisateur = $this->findUserInfo($email);
				if (!$infos_utilisateur) {
					$this->log("Obs {$obs['id']} email $email ne provient pas d'un telabotaniste");
					continue; // c'est pas un telabotaniste
				}
				$this->log("Obs {$obs['id']} email $email provient d'un telabotaniste");
				$this->log(json_encode($obs));
				// die(var_dump($obs));
 
				// vérification que l'obs n'a pas déjà été ajoutée à la BdD de Tela
				$sql = "SELECT date_maj, id_observation FROM cel_plantnet WHERE id_plantnet = '{$obs['id']}'"
						. ' -- ' . __FILE__ . ':' . __LINE__;
				$res = $this->bdd->recupererTous($sql);
				// die(var_dump($res));
				if ($res) {
					// l'obs existe déjà, on vérifie si il faut màj puis on passe à la suite
					// la date de l'obs est un microtime, donc on coupe les millièmes
					// die(var_dump((int)($obs['dateUpdated']/1000), strtotime($res[0]['date_maj'])));
					if ((int)($obs['dateUpdated']/1000) > strtotime($res[0]['date_maj'])) {
						echo "Obs déjà en base, mise à jour : ID PN {$obs['id']} ; ID TB {$res[0]['id_observation']} ; utilisateur_tb $email\n";
						$this->updateFromPN($obs, $res[0]['id_observation']);
					} else {
						echo "Obs déjà en base, déjà à jour : ID PN {$obs['id']} ; ID TB {$res[0]['id_observation']} ; utilisateur_tb $email\n";
					}
					continue;
				}
 
				if (isset($obs['deleted']) && (true === $obs['deleted'])) {
					$this->log("Obs {$obs['id']} supprimée coté PlantNet");
					continue; // obs supprimée chez PN sans être passée par nos serveurs
				}
 
				$images = [];
				$tags_images = [];
				$images_size = 0;
				foreach ($obs['images'] ?? [] as $i => $image) {
					if ($image['deleted']) {
						$this->log("Obs {$obs['id']} image {$image['id']} supprimée coté PlantNet");
						continue;
					}
 
					// téléchargement de l'image PN
					$img = false;
					$retry = 3;
					do {
						$img = file_get_contents($image['o']);
						$retry--;
						$this->log("Obs {$obs['id']} lecture image {$image['id']} tentatives restantes : $retry");
					} while (!$img && $retry);
 
					if (!$img) {
						echo "Abandon, image impossible à télécharger : {$image['o']}\n";
						continue;
					}
 
					// Écriture dans un fichier temporaire
					$tempfile = tempnam("/tmp", "PullPN_") . ".jpg";
					$handle = fopen($tempfile, "w");
					fwrite($handle, $img);
					fclose($handle);
					$images_size += filesize($tempfile);
 
					$this->log("Obs {$obs['id']} image {$image['id']} créée " . number_format(filesize($tempfile), 0, ',', ' ') . " octets : $tempfile");
 
					$params = [
						'name' => 'image' . $i,
						'fichier' => new CURLFile($tempfile, 'image/jpg')
					];
 
					// envoi de l'image PN à l'api de création
					$ch = curl_init(Config::get('urlCelUploadImageTemp'));
					curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
					curl_setopt($ch, CURLOPT_POST, true);
					curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
					$reponse = curl_exec($ch);
					$this->log("Obs {$obs['id']} image {$image['id']} envoyée à l'api de création. Réponse : $reponse");
					$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
					curl_close($ch);
 
					unlink($tempfile);
 
					$reponse = simplexml_load_string($reponse);
					/* Response format if success:
					<?xml version="1.0" encoding="UTF-8"?>
					<root>
						<miniature-url>https://api-test.tela-botanica.org/tmp/cel/imgtmp/chaflipe_min.jpg</miniature-url>
						<image-nom>chaflipe.jpg</image-nom>
						<message></message>
						<debogage></debogage>
					</root>
					*/
					// var_dump($reponse);
					if ($reponse && '' == $reponse->message /* && '' != $reponse->{'image-nom'} */) {
						$images[] = (string)$reponse->{'image-nom'};
 
						$tag = $this->tagsImageTraduits[$image['organ']] ?? $image['organ'];
						if (trim($tag)) {
							$tags_images[] = $tag;
						}
					}
				}
				// var_dump($images, $tags_images);
				// die();
 
				$geo = $this->getGeoInfo($obs['geo']);
				$this->log("Obs {$obs['id']} décodage du geom : " . json_encode($obs['geo']));
				$this->log("Obs {$obs['id']} geom décodé : " . json_encode($geo));
 
				// on insère l'obs via le service CelWidgetSaisie
				$infos_obs = [
					'obsId1[date]' => date('d/m/Y', intdiv($obs['dateObs'], 1000)),
					'obsId1[latitude]' => $geo['lat'] ?? null,
					'obsId1[longitude]' => $geo['lon'] ?? null,
					'obsId1[pays]' => $geo['countryCode'] ?? null,
					'obsId1[code_postal]' => $geo['postcode'] ?? null,
					'obsId1[commune_nom]' => $geo['city'] ?? null,
					// 'obsId1[commune_code_insee]' => '',
					// 'obsId1[lieudit]' => '',
					// 'obsId1[milieu]' => '',
					'obsId1[nom_sel]' => $obs['currentName'],
					// 'obsId1[nom_ret]' => '',
					// 'obsId1[famille]' => '',
					'obsId1[certitude]' => 'douteux',
					// 'obsId1[notes]' => '',
					// 'obsId1[num_nom_ret]' => '',
					// 'obsId1[num_nom_sel]' => '',
					// 'obsId1[num_taxon]' => '',
					'obsId1[referentiel]' => $this->findProbableTaxoRepos($this->currentProject['id']), // @TODO faire une fois et mettre en cache
					// 'obsId1[station]' => '',
					'obsId1[obs_id]' => $obs['id'],
					'projet' => 'PlantNet',
					'tag-img' => implode(', ', $tags_images ?? []),
					'tag-obs' => 'plantnet, plantnet-mobile, pn:referentiel-' . $this->currentProject['id'],
					'utilisateur[courriel]' => $email,
					'utilisateur[id_utilisateur]' => $infos_utilisateur['id'],
					'utilisateur[nom]' => $infos_utilisateur['nom'],
					'utilisateur[prenom]' => $infos_utilisateur['prenom'],
					'origin' => 'pullPlantnet',
				];
 
				foreach ($images as $i => $image) {
					$infos_obs["obsId1[image_nom][$i]"] = $image;
				}
 
				$this->log("Obs {$obs['id']} prête à être insérée : " . json_encode($infos_obs));
 
				// curl post $infos_obs
				$ch = curl_init($url_cel_widget_saisie);
				curl_setopt($ch, CURLOPT_POST, true);
				curl_setopt($ch, CURLOPT_POSTFIELDS, $infos_obs);
				curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
				$reponse = curl_exec($ch);
				$this->log("Obs {$obs['id']} réponse de la requête d'insertion : " . json_encode($reponse));
				$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
				curl_close($ch);
 
				if (!$reponse || 200 != $code) {
					throw new Exception("Ça a pété à l'envoi de l'obs :\n $reponse\n avec l'obs : " . json_encode($infos_obs) . "\n");
				}
 
 
				$id_obs_tb = json_decode($reponse, true)['id'];
				$id_obs_pn = $obs['id'];
				// on insère les ids de correspondance obsPN obsTB dans la table cel_plantnet
				$sql = 'INSERT INTO cel_plantnet (id_observation, id_plantnet, date_maj)'
						.' VALUES (%s, %s, NOW())'
						. ' -- ' . __FILE__ . ':' . __LINE__;
				$sql = sprintf($sql, $this->bdd->proteger($id_obs_tb), $this->bdd->proteger($id_obs_pn));
				$this->bdd->requeter($sql);
 
				$date = date('d/m/Y H:i:s', intdiv($obs['dateObs'], 1000));
				$count_img = count($images);
				$images_size = number_format($images_size, 0, ',', ' ');
				echo "Obs insérée en base : ID PN $id_obs_pn ; ID TB $id_obs_tb ; utilisateur_tb $email ; date_obs $date ; images $count_img ; taille_octets $images_size \n";
			}
		}
	}
 
	/**
	 * Return TB taxo repos names for given PN project
	 *
	 * @return string
	 */
	private function findProbableTaxoRepos($pnProjectId) {
		$selectedRepos = [];
		// Référentiels tela botanica indexés par référentiels PN (version octobre 2019)
		// @TODO à revoir en fonction des nouvelles mises en prod de nouveaux référentiels
		$tbTaxoRepos = [
			'afn' => [/*'apd', */'isfan'],
			'aft' => ['apd'],
			'antilles' => ['bdtxa', 'taxref'],
			'canada' => ['vascan'],
			'comores' => ['apd'],
			'endemia' => ['florical', 'taxref'],
			'taxref	' => ['bdtfx'],
			'guyane' => ['aublet', 'taxref'],
			'hawai' => [],
			'lapaz' => ['aublet', 'taxref'],
			'martinique' => ['bdtxa', 'taxref'],
			'maurice' => ['apd'],
			'medor' => ['lbf'],
			'namerica' => [],
			'polynesiefr' => ['taxref'],
			'prosea' => ['asia'],
			'prota' => ['isfan', 'apd'],
			'provence' => ['bdtfx', 'taxref'],
			'reunion' => ['bdtre', 'taxref'],
			'salad' => ['bdtfx', 'taxref'],
			'useful' => [],
			'weurope' => ['bdtfx'],
			'the-plant-list' => [],
			'iscantree' => ['apd'],
			'central-america' => [],
			'invasion' => ['bdtfx'],
			'weeds' => ['bdtfx'],
			'malaysia' => [],
		];
 
		if (array_key_exists($pnProjectId, $tbTaxoRepos)) {
			array_map(function($repo) use ($selectedRepos) {
				$selectedRepos[] = $repo;
			}, $tbTaxoRepos[$pnProjectId]);
		}
 
		// @TODO chercher le nom dans plusieurs référentiels avant d'envoyer l'obs
		// prendre "enrichirDonneesTaxonomiques" du service de saisie et le coller ici
		// en attendant on envoi juste le premier référentiel trouvé
		return $selectedRepos[0] ?? '';
	}
 
	/*
	 * Retrouve les infos d'un utilisateur tela à partir de son email
	 * @param string $email User email
	 * @return mixed 		Tableau des infos de l'utilisateur
	 *						False si l'email n'est pas trouvé dans l'annuaire
	 */
	private function findUserInfo($email) {
		// cherche dans le cache
		if (array_key_exists($email, $this->userInfos)) {
			$infosUtilisateur = $this->userInfos[$email];
			// echo("Email in cache : $email\n");
		} else {
			$infosUtilisateur = false;
			$urlInfosUtilisateur = str_replace('{email}', $email, Config::get('urlAnnuaireIdParEmail'));
 
			$ch = curl_init($urlInfosUtilisateur);
			curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
			$reponse = curl_exec($ch);
			$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
			curl_close($ch);
 
			// on peut pas tester le code de réponse de cette api, si l'utilisateur n'est pas trouvé ça fait une 500 >_<
			// une bonne réponse ressemble à ça :
			// {"killian@tela-botanica.org":{"id":"30489","prenom":"Killian","nom":"Stefanini","pseudo":"Killian Stefanini","pseudoUtilise":true,"intitule":"Killian Stefanini","avatar":"\/\/www.gravatar.com\/avatar\/a9b9b8484076540924c03af816c77fc8?s=50&r=g&d=mm","groupes":{"19226":"adm","18943":"","23152":"","21684":"","21598":"adm","23184":"","23516":""},"permissions":["editor"],"nomWiki":"KillianStefanini"}}
			$reponse = json_decode($reponse, true);
			if (!isset($reponse)) {
				throw new Exception("\nL'annuaire n'a pas répondu avec du json : code $code à l'adresse $urlInfosUtilisateur : $reponse\n");
			}
 
			if (!isset($reponse['error'])) {
				$infosUtilisateur = array_shift($reponse);
			}
 
			// met en cache
			$this->userInfos[$email] = $infosUtilisateur;
			// echo("Email cached : $email\n");
		}
 
		return $infosUtilisateur;
	}
 
	private function getGeoInfo($obs) {
		$geo = [];
		if (!isset($obs['lat']) && !isset($obs['lon'])) {
			return $geo;
		}
 
		// $data = [
		// 	'hitsPerPage' => 1,
		// 	'aroundLatLng' => "{$obs['lat']},{$obs['lon']}"
		// ];
		$headers = [
			'X-Algolia-Application-Id' => Config::get('algoliaApplicationId'),
			'X-Algolia-API-Key' => Config::get('algoliaAPIKey'),
		];
 
		$lat = number_format($obs['lat'], 6, '.', '');
		$lon = number_format($obs['lon'], 6, '.', '');
 
		$ch = curl_init(Config::get('urlReverseGeocodingLatLng')."$lat,$lon");
		curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
		$reponse = curl_exec($ch);
		$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
		curl_close($ch);
 
		if ($reponse) {
			$reponse = json_decode($reponse, true);
			// die(var_dump($reponse));
			$infos = $reponse['hits'][0];
 
			$geo = [
				'lat' => (string) $obs['lat'],
				'lon' => (string) $obs['lon'],
				'country' => $infos['country']['fr'] ?? $infos['country']['default'],
				'city' => $infos['city']['default'][0] ?? null,
				'postcode' => $infos['postcode'][0] ?? null,
				'countryCode' => strtoupper($infos['country_code']),
			];
		}
 
		return $geo;
	}
 
	private function updateFromPN(array $pnObs, string $tbObsId) {
		if (!is_array($pnObs) || !is_string($tbObsId)) {
			// die(var_dump($pnObs, $tbObsId));
			throw new Exception("\nBad params types, give me an array and an integer plz\n");
		}
		// die(var_dump($pnObs));
 
		// log update date to cel_plantnet
		$sql = "UPDATE cel_plantnet SET date_maj = NOW() WHERE id_observation = $tbObsId"
				. ' -- ' . __FILE__ . ':' . __LINE__;
		$this->bdd->requeter($sql);
 
		// check for deleted
		if (isset($pnObs['deleted']) && (true === $pnObs['deleted'])) {
			// est-ce une obs issue de PN ?
			//// faut regarder le champ input_source == PlantNet
			$sql = "SELECT input_source FROM occurrence WHERE id = '$tbObsId'"
					. ' -- ' . __FILE__ . ':' . __LINE__;
			$res = $this->bdd->recupererTous($sql);
 
			if (isset($res[0]) && ('PlantNet' === $res[0]['input_source'])) {
				// oui ? alors supprimer obs !
				echo "Obs supprimée coté PN, suppression : ID PN {$obs['id']} ; ID TB {$res[0]['id_observation']}\n";
 
				$sql = "UPDATE photos SET occurrence_id = NULL WHERE occurrence_id = '$tbObsId'"
						. ' -- ' . __FILE__ . ':' . __LINE__;
				$this->bdd->requeter($sql);
 
				$sql = "DELETE FROM occurrence WHERE id = '$tbObsId'"
						. ' -- ' . __FILE__ . ':' . __LINE__;
				$this->bdd->requeter($sql);
			}
		}
 
		// check for deleted images
		foreach ($pnObs['images'] as $image) {
			if ($image['deleted']) {
				// no idea
				// y'a pas encore de lien tangible entre les images PN et les notres
			}
		}
 
		// @TODO : finir la comparaison des proposition entre celles de Tela et celles PN
		// // check for votes (notes et taxon)
		// $names = [];
		// foreach ($pnObs['computed']['votes'] as $vote) {
		// 	echo($vote['name']);
		// 	echo($vote['score']['pn']);
		// 	echo($vote['score']['total']);
 
		// 	$names[$vote['score']['pn']] = $vote['name'];
		// }
		// ksort($names, SORT_NUMERIC); // votes sorted by score asc
		// $pn_sorted_votes = array_reverse($names, true); // desc
 
		// // get existing votes
		// $sql = "SELECT id_commentaire, nom_sel, nom_sel_nn, nom_referentiel, nom_referentiel, utilisateur_courriel, proposition_initiale, proposition_retenue"
		// 		. "WHERE ce_observation = '$tbObsId' AND ce_commentaire_parent = 0"
		// 		. ' -- ' . __FILE__ . ':' . __LINE__;
		// $existing_votes = $this->bdd->recupererTous($sql);
 
		// // @TODO : compare votes
		// // insert_new_votes($pn_sorted_votes, $existing_votes);
	}
 
	private function updateOnePN($pnObsId, $pnProjectId) {
		if (!is_int($pnObsId) || !is_string($pnProjectId)) {
			die(var_dump($pnObsId, $pnProjectId));
			throw new Exception("\nBad params types, give me an integer and a string plz\n");
		}
		// get PN project list
		$list = [];
		$pnProjects = $this->getProjects(); // refresh projects list
		foreach ($pnProjects as $project) {
			$list[$project['id']] = $project['name'];
		}
 
		// if project not in list display list
		if (!array_key_exists($pnProjectId, $list)) {
			echo "Available projects:\n";
			foreach ($list as $projectId => $projectName) {
				echo " - $projectId ($projectName)\n";
			}
			throw new Exception("Project $pnProjectId does not exist\n");
		} else {
			$this->currentProject = [
				'id' => $pnProjectId,
				'name' => $list[$pnProjectId],
			];
		}
 
		// get PN obs
		$urlInfosObs = str_replace(
			['{token}', '{project}', '{id}'],
			[Config::get('tokenPlantnet'), $pnProjectId, $pnObsId],
			Config::get('urlPlantnetBase').Config::get('urlPlantnetObsById')
		);
		$ch = curl_init($urlInfosObs);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
		$response = curl_exec($ch);
		$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
		curl_close($ch);
 
		if (!$response || 200 != $code) {
			throw new Exception("\nPlantnet api ($urlInfosObs) replied with code $code : $response\n");
		}
 
		// change last modification date to force update
		$obs = json_decode($response, true);
		$date = new DateTime();
		$date->setTimestamp(intdiv($obs['dateUpdated'], 1000) - 1);
		$date = $this->bdd->proteger($date->format('Y-m-d H:i:s'));
		$sql = "UPDATE cel_plantnet SET date_maj = $date WHERE id_plantnet = '$pnObsId'"
				. ' -- ' . __FILE__ . ':' . __LINE__;
		$this->bdd->requeter($sql);
 
		$this->updateObs([$obs]);
	}
 
	private function updateOneTB($id) {
		$corres = $this->findMatchingPartnerId($id, 'tb');
		echo "L'obs tela avec l'id $id a été trouvée chez plantnet avec l'id : " .$corres['pn'] . "\n";
		echo "La suite n'a pas été implémentée.\n";
	}
 
	/*
	 * Trouve les ids d'une obs chez les partenaires
	 * Il faut lancer updateMatchingPartnersIds pour obtenir une liste fraiche
	 *
	 * @param 	string $id			L'id de l'obs
	 * @param 	string $partner		Le partenaire correspondant à l'id de l'obs
	 *
	 * @return  mixed 				Le tableau de correspondances d'ids
	 *								False si l'id n'est pas trouvé
	 */
	private function findMatchingPartnerId($id, $partner) {
		if (!in_array($partner, $this->allowedPartners)) {
			throw new Exception("\nUnknown partner : $partner. Available Partners : " . implode(', ', $this->allowedPartners) . "\n");
		}
 
		// le json ressemble à ça :
		// {"tb":"2369732","pn":"1001020199"}, {"tb":"2369733","pn":"1001020176"}, ...
		$ids = json_decode(file_get_contents($this->correspondingIdsFilename), true);
		// extrait la colonne du partenaire recherché du tableau multidimensionnel fraichement décodé
		$partnerColumn = array_column($ids, $partner);
		// cherche l'index de l'id recherché
		$index = array_search($id, $partnerColumn);
 
		return $index ? $ids[$index] : false;
	}
 
	private function updateCorrespondingIdsTable() {
		// first update cache file if necessary
		if (!file_exists($this->correspondingIdsFilename) || time() > (filemtime($this->correspondingIdsFilename) + (24 * 3600))) {
			$this->updateMatchingPartnersIds();
		}
 
		$data = file_get_contents($this->correspondingIdsFilename);
		$data = json_decode($data, true);
 
		$now = new DateTime;
		$now = $this->bdd->proteger($now->format('Y-m-d H:i:s'));
 
		$sqlInsert = 'INSERT INTO cel_plantnet (id_observation, id_plantnet, date_maj)'
					. ' VALUES %s'
					. ' ON DUPLICATE KEY UPDATE id_observation=VALUES(id_observation), id_plantnet=VALUES(id_plantnet)'
					. ' -- ' . __FILE__ . ':' . __LINE__;
		$values = '';
 
		echo "Updating matching partners ids table\n";
		foreach ($data as $id => $corres) {
			$id_obs_tb = $this->bdd->proteger($corres['tb']);
			$id_obs_pn = $this->bdd->proteger($corres['pn']);
			// on insère les ids de correspondance obsPN obsTB dans la table cel_plantnet
			$values .= " ($id_obs_tb, $id_obs_pn, $now),";
 
			if (0 === $id % 100) {
				$values = substr($values, 0, -1); // retire la dernière virgule
				$sql = sprintf($sqlInsert, $values);
				// var_dump($sql);
				$this->bdd->requeter($sql);
				$values = '';
			}
		}
		// Faut envoyer les dernières données qui sont pas passées dans le modulo
		$values = substr($values, 0, -1); // retire la dernière virgule
		$sql = sprintf($sqlInsert, $values);
		// var_dump($sql);
		$this->bdd->requeter($sql);
 
		$count = count($data);
		echo "Success: #$count updated\n";
	}
 
	private function updateMatchingPartnersIds() {
		// curl -X GET --header 'Accept: application/json' 'https://bourbonnais.cirad.fr:8081/v1/edi/observations/partnerids?token=f0ca433febe320675c24ee2ddfab8b82f65d556b' > partnerids.txt
		$matchingPartnersIdsServiceUrl = str_replace(
			'{token}',
			Config::get('tokenPlantnet'),
			Config::get('urlPlantnetBase').Config::get('urlPlantnetMatchingPartner')
		);
		$ch = curl_init($matchingPartnersIdsServiceUrl);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
 
		echo "Updating matching partners ids...\n";
		$reponse = curl_exec($ch);
		$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
		curl_close($ch);
 
 
		if (!$reponse || 200 != $code) {
			throw new Exception("\nError updating partners ids, http error code \"$code\" whith url \"$matchingPartnersIdsServiceUrl\"...\n");
		}
		echo "Response data from PN api gathered, know computing...\n";
 
		if (!file_put_contents($this->correspondingIdsFilename, $reponse)) {
			throw new Exception("\nError writing correspondingIdsFilename with path : " . $this->correspondingIdsFilename . "\n");
		}
		echo "Matching partners ids saved!";
	}
 
	private function debug($text) {
		if ($this->debug) {
			echo 'DEBUG - ' . $text . "\n";
		}
	}
 
	private function log($text) {
		if ('log' == $this->debug) {
			echo 'LOG - ' . $text . "\n";
		}
	}
}


Rev 3771	Rev 3773
1	`<?php`	1	`<?php`
2		2
3	`/*`	3	`/*`
4	`PHP 7`	4	`PHP 7`
5		5
-		6	`Script used to synchronize PN occ with Flora Data`
-		7
6	`Script used to synchronize PN occ with CEL`	8	`Écrit en franglish pour une meilleure compréhension (lol)`
7	`*/`	9	`*/`
8		10
9	`class PullPlantnet extends Script {`	11	`class PullPlantnet extends Script {`
10		12
11	`protected $bdd;`	13	`protected $bdd;`
-		14
-		15	`protected $debug = false;`
12		16
13	`protected $allowedPartners = ['tb', 'pn'];`	17	`protected $allowedPartners = ['tb', 'pn'];`
14		18
15	`// Nom du fichier contenant les correspondances d'ID TB/PN`	19	`// Nom du fichier contenant les correspondances d'ID TB/PN`
16	`protected $correspondingIdsFilename = '';`	20	`protected $correspondingIdsFilename = '';`
17		21
18	`// Cache d'informations utilisateurs provenant de l'annuaire TB`	22	`// Cache d'informations utilisateurs provenant de l'annuaire TB`
19	`protected $userInfos = [];`	23	`protected $userInfos = [];`
20		24
21	`// Cache des obs id PN traitées pendant cette run`	25	`// Cache des obs id PN traitées pendant cette run`
22	`protected $processedObsId = [];`	26	`protected $processedObsId = [];`
23		27
24	`// Paramètre de suivi et de pagination de l'API des obs PN`	28	`// Paramètre de suivi et de pagination de l'API des obs PN`
25	`protected $currentPage = '';`	29	`protected $currentPage = '';`
26	`protected $currentProject = '';`	30	`protected $currentProject = '';`
27	`protected $hasMore = false;`	31	`protected $hasMore = false;`
28	`protected $count = 0;`	-
29		32
30	`// Traduction des organes de PN`	33	`// Traduction des organes de PN`
31	`protected $tagsImageTraduits = [`	34	`protected $tagsImageTraduits = [`
32	`'flower' => 'fleur',`	35	`'flower' => 'fleur',`
33	`'fruit' => 'fruit',`	36	`'fruit' => 'fruit',`
34	`'leaf' => 'feuille',`	37	`'leaf' => 'feuille',`
35	`'bark' => 'écorce',`	38	`'bark' => 'écorce',`
36	`'branch' => 'branche',`	39	`'branch' => 'branche',`
37	`'habit' => 'port',`	40	`'habit' => 'port',`
38	`];`	41	`];`
39		42
40	`// Différents types de lifecle possible pour filtrer les obs`	43	`// Différents types de lifecle possible pour filtrer les obs`
41	`// Modified renvoi les obs en fonction de leur date de modif`	44	`// Modified renvoi les obs en fonction de leur date de modif`
42	`// Created, en fonction de la date de création`	45	`// Created, en fonction de la date de création`
43	`// Deleted, well, you already got it`	46	`// Deleted, well, you already got it`
44	`protected $lifecycles = [`	47	`protected $lifecycles = [`
45	`'created',`	48	`'created',`
46	`'modified',`	49	`'modified',`
47	`'deleted', // deleted peut être très lent`	50	`'deleted', // deleted peut être très lent (pas d'index coté PN pour le moment)`
48	`];`	51	`];`
49		52
50	`/**`	53	`/**`
51	`* Paramêtres par défaut disponibles pour la ligne de commande`	54	`* Paramêtres par défaut disponibles pour la ligne de commande`
52	`* le tableau se construit de la forme suivante :`	55	`* le tableau se construit de la forme suivante :`
53	`* - clé = nom du paramêtre '-foo'`	56	`* - clé = nom du paramêtre '-foo'`
54	`* - value = contient un nouveau tableau composé de cette façon :`	57	`* - value = contient un nouveau tableau composé de cette façon :`
55	`* - booléen: true si le paramêtre est obligatoire`	58	`* - booléen: true si le paramêtre est obligatoire`
56	`* - booléen ou var : true si le paramêtre nécessite un valeur à sa suite ou la valeur par défaut`	59	`* - booléen ou var : true si le paramêtre nécessite un valeur à sa suite ou la valeur par défaut`
57	`* - string: description du contenu du paramêtre`	60	`* - string: description du contenu du paramêtre`
58	`* Les paramêtres optionels devraient être déclaré à la fin du tableau.`	61	`* Les paramêtres optionels devraient être déclaré à la fin du tableau.`
59	`* Le dernier parametre du tableau peut avoir la valeur '...',`	62	`* Le dernier parametre du tableau peut avoir la valeur '...',`
60	`* il contiendra alors l'ensemble des paramêtres suivant trouvés sur la ligne de commande.`	63	`* il contiendra alors l'ensemble des paramêtres suivant trouvés sur la ligne de commande.`
61	`* @var array`	64	`* @var array`
62	`*/`	65	`*/`
63	`protected $parametres_autorises = array(`	66	`protected $parametres_autorises = array(`
64	`'-startDate' => array(false, true, 'Date de début (parsée par strtotime). Ex: "YYYY:MM:DD HH:II:SS"'),`	67	`'-startDate' => array(false, true, 'Date de début (parsée par strtotime). Ex: "YYYY:MM:DD HH:II:SS"'),`
65	`'-lifecycle' => array(false, true, 'Par défaut : modified ; Au choix parmi : created/modified/deleted (deleted est lent)'),`	68	`'-lifecycle' => array(false, true, 'Par défaut : modified ; Au choix parmi : created/modified/deleted (deleted est lent)'),`
66	`'-pnObsId' => array(false, true, "ID de l'obs chez PlantNet"),`	69	`'-pnObsId' => array(false, true, "ID de l'obs chez PlantNet"),`
67	`'-project' => array(false, true, "projectId de l'obs chez PlantNet"),`	70	`'-project' => array(false, true, "projectId de l'obs chez PlantNet"),`
68	`'-tbObsId' => array(false, true, "ID de l'obs chez Tela"),`	71	`'-tbObsId' => array(false, true, "ID de l'obs chez Tela"),`
-		72	`'-debug' => array(false, false, "Mode débug (ajoute du log) Au choix parmi : debug/log (log est plus verbeux)"),`
69	`);`	73	`);`
70		74
71	`public function __construct($script_nom, $parametres_cli) {`	75	`public function __construct($script_nom, $parametres_cli) {`
72	`parent::__construct($script_nom, $parametres_cli);`	76	`parent::__construct($script_nom, $parametres_cli);`
73	`$this->bdd = new Bdd();`	77	`$this->bdd = new Bdd();`
74		78
75	`$this->correspondingIdsFilename = Config::get('correspondingIdsFilename');`	79	`$this->correspondingIdsFilename = Config::get('correspondingIdsFilename');`
-		80
-		81	`$this->debug = $this->getParametre('debug');`
76	`}`	82	`}`
77		83
78	`public function executer() {`	84	`public function executer() {`
79	`$cmd = $this->getParametre('a');`	85	`$cmd = $this->getParametre('a');`
80		86
81	`switch ($cmd) {`	87	`switch ($cmd) {`
82	`case 'updateLatest':`	88	`case 'updateLatest':`
83	`$this->updateLatest($this->getParametre('startDate'));`	89	`$this->updateLatest($this->getParametre('startDate'), $this->getParametre('lifecycle'));`
84	`break;`	90	`break;`
85	`case 'updateOnePN':`	91	`case 'updateOnePN':`
86	`$this->updateOnePN((int)$this->getParametre('pnObsId'), $this->getParametre('project'));`	92	`$this->updateOnePN((int)$this->getParametre('pnObsId'), $this->getParametre('project'));`
87	`break;`	93	`break;`
88	`case 'updateOneTB':`	94	`case 'updateOneTB':`
89	`$this->updateOneTB($this->getParametre('tbObsId'));`	95	`$this->updateOneTB((int)$this->getParametre('tbObsId'));`
90	`break;`	96	`break;`
91	`case 'updateCorrespondingIdsTable':`	97	`case 'updateCorrespondingIdsTable':`
92	`$this->updateCorrespondingIdsTable();`	98	`$this->updateCorrespondingIdsTable();`
93	`break;`	99	`break;`
94	`default:`	100	`default:`
95	`$msg = "Erreur : la commande '$cmd' n'existe pas!\n"`	101	`$msg = "Erreur : la commande '$cmd' n'existe pas!\n"`
96	`. ', utilisez plutôt :' . "\n"`	102	`. ', utilisez plutôt :' . "\n"`
97	`. 'php cli.php PullPlantnet -a updateLatest -startDate "YYYY:MM:DD HH:II:SS" [[-lifecycle [modified]/created/deleted]]' . "\n"`	103	`. 'php cli.php PullPlantnet -a updateLatest -startDate "YYYY:MM:DD HH:II:SS" [[-lifecycle [modified]/created/deleted]]' . "\n"`
98	`. 'php cli.php PullPlantnet -a updateOnePN -pnObsId "xxxxxx" -project "xxxxxx"' . "\n"`	104	`. 'php cli.php PullPlantnet -a updateOnePN -pnObsId "1234567890" -project "xxxxxx"' . "\n"`
99	`. 'php cli.php PullPlantnet -a updateOneTB -tbObsId "xxxxxx"' . "\n"`	105	`. 'php cli.php PullPlantnet -a updateOneTB -tbObsId "1234567890"' . "\n"`
100	`. 'php cli.php PullPlantnet -a updateCorrespondingIdsTable' . "\n"`	106	`. 'php cli.php PullPlantnet -a updateCorrespondingIdsTable' . "\n"`
101	`;`	107	`;`
102	`throw new Exception($msg);`	108	`throw new Exception($msg);`
103	`}`	109	`}`
104	`}`	110	`}`
105		111
106	`/**`	112	`/**`
107	`* Considering all modified pn obs since startDate`	113	`* Considering all modified pn obs since startDate`
108	`* One pn project after an other`	114	`* One pn project after an other`
109	`* Inserting obs in tb db (if new and matching user email)`	115	`* Inserting obs in tb db (if new and matching user email)`
110	`*/`	116	`*/`
111	`private function updateLatest(string $startDate = '1917:03:15 00:00:00', string $lifecycle = 'modified') {`	117	`private function updateLatest(string $startDate = '1917:03:15 00:00:00', string $lifecycle = 'modified') {`
112	`$startDate = strtotime($startDate) * 1000; // we need a microtimestamp`	118	`$startDate = strtotime($startDate) * 1000; // we need a microtimestamp`
113		119
114	`$pnProjects = $this->getProjects(); // refresh projects list`	120	`$pnProjects = $this->getProjects(); // refresh projects list`
115	`foreach ($pnProjects as $project) {`	121	`foreach ($pnProjects as $project) {`
116	`do {`	122	`do {`
117	`$observations_PN = $this->getProjectLatest($project, $startDate, $lifecycle);`	123	`$observations_PN = $this->getProjectLatest($project, $startDate, $lifecycle);`
118	`$this->updateObs($observations_PN);`	124	`$this->updateObs($observations_PN);`
119	`} while ($this->hasMore);`	125	`} while ($this->hasMore);`
120	`}`	126	`}`
121	`}`	127	`}`
122		128
123	`private function getProjectLatest(array $project, int $startDate, string $lifecycle): array {`	129	`private function getProjectLatest(array $project, int $startDate, string $lifecycle): array {`
124	`$this->currentProject = $project;`	130	`$this->currentProject = $project;`
125		131
126	`if (!$this->currentPage) {`	132	`if (!$this->currentPage) {`
127	`echo 'Projet ' . $project['name'] . "\n";`	133	`echo 'Projet ' . $project['name'] . "\n";`
128		134
129	`// hop, on appelle le service de PN`	135	`// hop, on appelle le service de PN`
130	`$url_service = str_replace(`	136	`$url_service = str_replace(`
131	`['{project}', '{token}', '{startDate}', '{lifecycle}'],`	137	`['{project}', '{token}', '{startDate}', '{lifecycle}'],`
132	`[$project['id'], Config::get('tokenPlantnet'), $startDate, $lifecycle],`	138	`[$project['id'], Config::get('tokenPlantnet'), $startDate, $lifecycle],`
133	`Config::get('urlPlantnetBase').Config::get('urlPlantnetLatestChanges')`	139	`Config::get('urlPlantnetBase').Config::get('urlPlantnetLatestChanges')`
134	`);`	140	`);`
-		141
135	`// die(var_dump($url_service));`	142	`$this->debug("URL service derniers changements : $url_service");`
-		143
136	`$this->currentPage = $url_service;`	144	`$this->currentPage = $url_service;`
137	`}`	145	`}`
138		146
139	`$ch = curl_init($this->currentPage);`	147	`$ch = curl_init($this->currentPage);`
140	`curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);`	148	`curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);`
141	`$reponse = curl_exec($ch);`	149	`$reponse = curl_exec($ch);`
142	`$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);`	150	`$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);`
143	`curl_close($ch);`	151	`curl_close($ch);`
144		152
145	`// cool, maintenant on va trier ce qu'on a reçu`	153	`// cool, maintenant on va trier ce qu'on a reçu`
146	`if (!$reponse) {`	154	`if (!$reponse) {`
147	`throw new Exception("\nPN ne répond rien à l'adresse {$this->currentPage}\n");`	155	`throw new Exception("\nPN ne répond rien à l'adresse {$this->currentPage}\n");`
148	`} elseif (200 != $code) {`	156	`} elseif (200 != $code) {`
149	`// l'api répond avec une 404 quand y'a une date dans le futur ou simplement pas de nouvelle obs...`	157	`// l'api répond avec une 404 quand y'a une date dans le futur ou simplement pas de nouvelle obs...`
150	`if (404 == $code && strpos($reponse, 'No more results')) {`	158	`if (404 == $code && strpos($reponse, 'No more results')) {`
-		159	`$this->log("Pas d'autres résultats");`
151	`$this->hasMore = false;`	160	`$this->hasMore = false;`
152	`$this->currentPage = '';`	161	`$this->currentPage = '';`
153	`return [];`	162	`return [];`
154	`}`	163	`}`
155	`throw new Exception("\nPN répond avec une $code à l'adresse {$this->currentPage} : $reponse\n");`	164	`throw new Exception("\nPN répond avec une $code à l'adresse {$this->currentPage} : $reponse\n");`
156	`}`	165	`}`
157	`$responseJson = json_decode($reponse, true);`	166	`$responseJson = json_decode($reponse, true);`
158	`$observations_PN = $responseJson['data'] ?? [];`	167	`$observations_PN = $responseJson['data'] ?? [];`
159		168
160	`$this->hasMore = $responseJson['hasMore'];`	169	`$this->hasMore = $responseJson['hasMore'];`
161	`if ($this->hasMore) {`	170	`if ($this->hasMore) {`
162	`$this->count += count($observations_PN);`	-
163	`$this->currentPage = Config::get('urlPlantnetBase').$responseJson['next'];`	171	`$this->currentPage = Config::get('urlPlantnetBase').$responseJson['next'];`
-		172	`$this->debug("URL service derniers changements, page suivante : {$this->currentPage}");`
164	`} else {`	173	`} else {`
165	`$this->currentPage = '';`	174	`$this->currentPage = '';`
166	`$this->count = 0;`	-
167	`}`	175	`}`
168		176
169	`return $observations_PN;`	177	`return $observations_PN;`
170	`}`	178	`}`
171		179
172	`private function getProjects(): array {`	180	`private function getProjects(): array {`
173	`// get PN projects list`	181	`// get PN projects list`
174	`$url = str_replace('{token}', Config::get('tokenPlantnet'), Config::get('urlPlantnetBase').Config::get('urlPlantnetProjects'));`	182	`$url = str_replace('{token}', Config::get('tokenPlantnet'), Config::get('urlPlantnetBase').Config::get('urlPlantnetProjects'));`
-		183
-		184	`$this->debug("URL service liste projets : $url");`
175		185
176	`$ch = curl_init($url);`	186	`$ch = curl_init($url);`
177	`curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);`	187	`curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);`
178	`$reponse = curl_exec($ch);`	188	`$reponse = curl_exec($ch);`
179	`$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);`	189	`$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);`
180	`curl_close($ch);`	190	`curl_close($ch);`
181		191
182	`if (!$reponse \|\| 200 != $code) {`	192	`if (!$reponse \|\| 200 != $code) {`
183	`throw new Exception("\nPN répond avec une $code à l'adresse $url : $reponse\n");`	193	`throw new Exception("\nPN répond avec une $code à l'adresse $url : $reponse\n");`
184	`}`	194	`}`
185	`$pnProjects = json_decode($reponse, true);`	195	`$pnProjects = json_decode($reponse, true);`
186		196
187	`echo 'Liste de projets récupérée : ' . count($pnProjects) . " projets dans la liste\n";`	197	`echo 'Liste de projets récupérée : ' . count($pnProjects) . " projets dans la liste\n";`
-		198
-		199	`$this->debug("Liste projets : " . json_encode($pnProjects));`
188		200
189	`return $pnProjects;`	201	`return $pnProjects;`
190	`}`	202	`}`
191		203
192	`/**`	204	`/**`
193	`* For a given bunch of plantnet obs, post new one threw saisie widget service`	205	`* For a given bunch of plantnet obs, post new one threw saisie widget service`
194	`*/`	206	`*/`
195	`private function updateObs(array $observations_PN) {`	207	`private function updateObs(array $observations_PN) {`
196		208
197	`$url_cel_widget_saisie = Config::get('urlCelWidgetSaisie');`	209	`$url_cel_widget_saisie = Config::get('urlCelWidgetSaisie');`
198		210
199	`foreach ($observations_PN as $obs) {`	211	`foreach ($observations_PN as $obs) {`
200	`// est-ce qu'on a déjà traité cette obs ? (oui une même obs peut être dans plusieurs projects)`	212	`// est-ce qu'on a déjà traité cette obs ? (oui une même obs peut être dans plusieurs projects)`
201	`if (in_array($obs['id'], $this->processedObsId)) {`	213	`if (in_array($obs['id'], $this->processedObsId)) {`
-		214	`$this->log("Obs {$obs['id']} déjà traitée pendant cette run");`
202	`continue;`	215	`continue;`
203	`} else {`	216	`} else {`
204	`$this->processedObsId[] = $obs['id'];`	217	`$this->processedObsId[] = $obs['id'];`
-		218	`$this->log("Obs {$obs['id']} ajoutée à la liste de cette run");`
205	`}`	219	`}`
206		220
207	`// on ne teste pas la suppression de l'obs ici, faut le faire après avoir vérifié si on l'a déjà synchro`	221	`// on ne teste pas la suppression de l'obs ici, faut le faire après avoir vérifié si on l'a déjà synchro`
208	`if (!isset($obs['currentName'])) {`	222	`if (!isset($obs['currentName'])) {`
-		223	`$this->log("Obs {$obs['id']} sans nom de taxon, on zap");`
209	`continue; // pas de nom de taxon, obs inutile`	224	`continue; // pas de nom de taxon, obs inutile`
210	`}`	225	`}`
211	`if (!isset($obs['geo'])) {`	226	`if (!isset($obs['geo'])) {`
-		227	`$this->log("Obs {$obs['id']} sans geom, on zap");`
212	`continue; // pas de position, obs inutile`	228	`continue; // pas de position, obs inutile`
213	`}`	229	`}`
214	`if (!isset($obs['dateObs'])) {`	230	`if (!isset($obs['dateObs'])) {`
-		231	`$this->log("Obs {$obs['id']} sans date, on zap");`
215	`continue; // pas de date, obs inutile`	232	`continue; // pas de date, obs inutile`
216	`}`	233	`}`
217		234
218	`if (isset($obs['partner']['id']) && 'tela' === $obs['partner']['id']) {`	235	`if (isset($obs['partner']['id']) && 'tela' === $obs['partner']['id']) {`
219	`// c'est une obs tela`	236	`// c'est une obs tela`
220	`// si c'est mis à jour récemment coté PN et qu'on l'a pas supprimée chez nous entre temps`	237	`// si c'est mis à jour récemment coté PN et qu'on l'a pas supprimée chez nous entre temps`
221	`// on update les votes PN`	238	`// on update les votes PN`
222	`// on update l'identification proposée par PN`	239	`// on update l'identification proposée par PN`
223		240
224	`// @TODO`	241	`// @TODO`
-		242	`$this->log("Obs {$obs['id']} venant de Tela, mise à jour pas implémentée, on zap");`
225	`continue;`	243	`continue;`
226	`} elseif (!isset($obs['partner']['id'])) {`	244	`} elseif (!isset($obs['partner']['id'])) {`
227	`// ce n'est pas une obs d'un partenaire, c'est donc une obs PN`	245	`// ce n'est pas une obs d'un partenaire, c'est donc une obs PN`
228	`// on récupère l'id utilisateur tela via son mail`	246	`// on récupère l'id utilisateur tela via son mail`
229	`$email = $obs['author']['email'];`	247	`$email = $obs['author']['email'];`
230	`$infos_utilisateur = $this->findUserInfo($email);`	248	`$infos_utilisateur = $this->findUserInfo($email);`
231	`if (!$infos_utilisateur) {`	249	`if (!$infos_utilisateur) {`
-		250	`$this->log("Obs {$obs['id']} email $email ne provient pas d'un telabotaniste");`
232	`continue; // c'est pas un telabotaniste`	251	`continue; // c'est pas un telabotaniste`
233	`}`	252	`}`
234	`//echo "Synchro d'une obs d'un telabotaniste : $email";`	253	`$this->log("Obs {$obs['id']} email $email provient d'un telabotaniste");`
235	`// echo json_encode($obs);`	254	`$this->log(json_encode($obs));`
236	`// die(var_dump($obs));`	255	`// die(var_dump($obs));`
237		256
238	`// vérification que l'obs n'a pas déjà été ajoutée à la BdD de Tela`	257	`// vérification que l'obs n'a pas déjà été ajoutée à la BdD de Tela`
239	`$sql = "SELECT date_maj, id_observation FROM cel_plantnet WHERE id_plantnet = '{$obs['id']}'"`	258	`$sql = "SELECT date_maj, id_observation FROM cel_plantnet WHERE id_plantnet = '{$obs['id']}'"`
240	`. ' -- ' . __FILE__ . ':' . __LINE__;`	259	`. ' -- ' . __FILE__ . ':' . __LINE__;`
241	`$res = $this->bdd->recupererTous($sql);`	260	`$res = $this->bdd->recupererTous($sql);`
242	`// die(var_dump($res));`	261	`// die(var_dump($res));`
243	`if ($res) {`	262	`if ($res) {`
244	`// l'obs existe déjà, on vérifie si il faut màj puis on passe à la suite`	263	`// l'obs existe déjà, on vérifie si il faut màj puis on passe à la suite`
245	`// la date de l'obs est un microtime, donc on coupe les millièmes`	264	`// la date de l'obs est un microtime, donc on coupe les millièmes`
246	`// die(var_dump((int)($obs['dateUpdated']/1000), strtotime($res[0]['date_maj'])));`	265	`// die(var_dump((int)($obs['dateUpdated']/1000), strtotime($res[0]['date_maj'])));`
247	`if ((int)($obs['dateUpdated']/1000) > strtotime($res[0]['date_maj'])) {`	266	`if ((int)($obs['dateUpdated']/1000) > strtotime($res[0]['date_maj'])) {`
248	`echo "Obs déjà en base, mise à jour : ID PN {$obs['id']} ; ID TB {$res[0]['id_observation']} ; utilisateur_tb $email\n";`	267	`echo "Obs déjà en base, mise à jour : ID PN {$obs['id']} ; ID TB {$res[0]['id_observation']} ; utilisateur_tb $email\n";`
249	`$this->updateFromPN($obs, $res[0]['id_observation']);`	268	`$this->updateFromPN($obs, $res[0]['id_observation']);`
250	`} else {`	269	`} else {`
251	`echo "Obs déjà en base, déjà à jour : ID PN {$obs['id']} ; ID TB {$res[0]['id_observation']} ; utilisateur_tb $email\n";`	270	`echo "Obs déjà en base, déjà à jour : ID PN {$obs['id']} ; ID TB {$res[0]['id_observation']} ; utilisateur_tb $email\n";`
252	`}`	271	`}`
253	`continue;`	272	`continue;`
254	`}`	273	`}`
255		274
256	`if (isset($obs['deleted']) && (true === $obs['deleted'])) {`	275	`if (isset($obs['deleted']) && (true === $obs['deleted'])) {`
-		276	`$this->log("Obs {$obs['id']} supprimée coté PlantNet");`
257	`continue; // obs supprimée chez PN sans être passée par nos serveurs`	277	`continue; // obs supprimée chez PN sans être passée par nos serveurs`
258	`}`	278	`}`
259		279
260	`$images = [];`	280	`$images = [];`
261	`$tags_images = [];`	281	`$tags_images = [];`
262	`$images_size = 0;`	282	`$images_size = 0;`
263	`foreach ($obs['images'] ?? [] as $i => $image) {`	283	`foreach ($obs['images'] ?? [] as $i => $image) {`
264	`if ($image['deleted']) {`	284	`if ($image['deleted']) {`
-		285	`$this->log("Obs {$obs['id']} image {$image['id']} supprimée coté PlantNet");`
265	`continue;`	286	`continue;`
266	`}`	287	`}`
267		288
268	`// téléchargement de l'image PN`	289	`// téléchargement de l'image PN`
269	`$img = false;`	290	`$img = false;`
270	`$retry = 3;`	291	`$retry = 3;`
271	`do {`	292	`do {`
272	`$img = file_get_contents($image['o']);`	293	`$img = file_get_contents($image['o']);`
273	`$retry--;`	294	`$retry--;`
-		295	`$this->log("Obs {$obs['id']} lecture image {$image['id']} tentatives restantes : $retry");`
274	`} while (!$img && $retry);`	296	`} while (!$img && $retry);`
275		297
276	`if (!$img) {`	298	`if (!$img) {`
277	`echo "Abandon, image impossible à télécharger : {$image['o']}\n";`	299	`echo "Abandon, image impossible à télécharger : {$image['o']}\n";`
278	`continue;`	300	`continue;`
279	`}`	301	`}`
280		302
281	`// Écriture dans un fichier temporaire`	303	`// Écriture dans un fichier temporaire`
282	`$tempfile = tempnam("/tmp", "PullPN_") . ".jpg";`	304	`$tempfile = tempnam("/tmp", "PullPN_") . ".jpg";`
283	`$handle = fopen($tempfile, "w");`	305	`$handle = fopen($tempfile, "w");`
284	`fwrite($handle, $img);`	306	`fwrite($handle, $img);`
285	`fclose($handle);`	307	`fclose($handle);`
286	`$images_size += filesize($tempfile);`	308	`$images_size += filesize($tempfile);`
287		309
288	`// echo "Image de " . number_format(filesize($tempfile), 0, ',', ' ') . " octets créé : $tempfile\n";`	310	`$this->log("Obs {$obs['id']} image {$image['id']} créée " . number_format(filesize($tempfile), 0, ',', ' ') . " octets : $tempfile");`
289		311
290	`$params = [`	312	`$params = [`
291	`'name' => 'image' . $i,`	313	`'name' => 'image' . $i,`
292	`'fichier' => new CURLFile($tempfile, 'image/jpg')`	314	`'fichier' => new CURLFile($tempfile, 'image/jpg')`
293	`];`	315	`];`
294		316
295	`// envoi de l'image PN à l'api de création`	317	`// envoi de l'image PN à l'api de création`
296	`$ch = curl_init(Config::get('urlCelUploadImageTemp'));`	318	`$ch = curl_init(Config::get('urlCelUploadImageTemp'));`
297	`curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);`	319	`curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);`
298	`curl_setopt($ch, CURLOPT_POST, true);`	320	`curl_setopt($ch, CURLOPT_POST, true);`
299	`curl_setopt($ch, CURLOPT_POSTFIELDS, $params);`	321	`curl_setopt($ch, CURLOPT_POSTFIELDS, $params);`
300	`$reponse = curl_exec($ch);`	322	`$reponse = curl_exec($ch);`
301	`// var_dump($reponse);`	323	`$this->log("Obs {$obs['id']} image {$image['id']} envoyée à l'api de création. Réponse : $reponse");`
302	`$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);`	324	`$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);`
303	`curl_close($ch);`	325	`curl_close($ch);`
304		326
305	`unlink($tempfile);`	327	`unlink($tempfile);`
306		328
307	`$reponse = simplexml_load_string($reponse);`	329	`$reponse = simplexml_load_string($reponse);`
308	`/* Response format if success:`	330	`/* Response format if success:`
309	`<?xml version="1.0" encoding="UTF-8"?>`	331	`<?xml version="1.0" encoding="UTF-8"?>`
310	`<root>`	332	`<root>`
311	`<miniature-url>https://api-test.tela-botanica.org/tmp/cel/imgtmp/chaflipe_min.jpg</miniature-url>`	333	`<miniature-url>https://api-test.tela-botanica.org/tmp/cel/imgtmp/chaflipe_min.jpg</miniature-url>`
312	`<image-nom>chaflipe.jpg</image-nom>`	334	`<image-nom>chaflipe.jpg</image-nom>`
313	`<message></message>`	335	`<message></message>`
314	`<debogage></debogage>`	336	`<debogage></debogage>`
315	`</root>`	337	`</root>`
316	`*/`	338	`*/`
317	`// var_dump($reponse);`	339	`// var_dump($reponse);`
318	`if ($reponse && '' == $reponse->message /* && '' != $reponse->{'image-nom'} */) {`	340	`if ($reponse && '' == $reponse->message /* && '' != $reponse->{'image-nom'} */) {`
319	`$images[] = (string)$reponse->{'image-nom'};`	341	`$images[] = (string)$reponse->{'image-nom'};`
320		342
321	`$tag = $this->tagsImageTraduits[$image['organ']] ?? $image['organ'];`	343	`$tag = $this->tagsImageTraduits[$image['organ']] ?? $image['organ'];`
322	`if (trim($tag)) {`	344	`if (trim($tag)) {`
323	`$tags_images[] = $tag;`	345	`$tags_images[] = $tag;`
324	`}`	346	`}`
325	`}`	347	`}`
326	`}`	348	`}`
327	`// var_dump($images, $tags_images);`	349	`// var_dump($images, $tags_images);`
328	`// die();`	350	`// die();`
329		351
330	`$geo = $this->getGeoInfo($obs['geo']);`	352	`$geo = $this->getGeoInfo($obs['geo']);`
-		353	`$this->log("Obs {$obs['id']} décodage du geom : " . json_encode($obs['geo']));`
-		354	`$this->log("Obs {$obs['id']} geom décodé : " . json_encode($geo));`
331		355
332	`// on insère l'obs via le service CelWidgetSaisie`	356	`// on insère l'obs via le service CelWidgetSaisie`
333	`$infos_obs = [`	357	`$infos_obs = [`
334	`'obsId1[date]' => date('d/m/Y', intdiv($obs['dateObs'], 1000)),`	358	`'obsId1[date]' => date('d/m/Y', intdiv($obs['dateObs'], 1000)),`
335	`'obsId1[latitude]' => $geo['lat'] ?? null,`	359	`'obsId1[latitude]' => $geo['lat'] ?? null,`
336	`'obsId1[longitude]' => $geo['lon'] ?? null,`	360	`'obsId1[longitude]' => $geo['lon'] ?? null,`
337	`'obsId1[pays]' => $geo['countryCode'] ?? null,`	361	`'obsId1[pays]' => $geo['countryCode'] ?? null,`
338	`'obsId1[code_postal]' => $geo['postcode'] ?? null,`	362	`'obsId1[code_postal]' => $geo['postcode'] ?? null,`
339	`'obsId1[commune_nom]' => $geo['city'] ?? null,`	363	`'obsId1[commune_nom]' => $geo['city'] ?? null,`
340	`// 'obsId1[commune_code_insee]' => '',`	364	`// 'obsId1[commune_code_insee]' => '',`
341	`// 'obsId1[lieudit]' => '',`	365	`// 'obsId1[lieudit]' => '',`
342	`// 'obsId1[milieu]' => '',`	366	`// 'obsId1[milieu]' => '',`
343	`'obsId1[nom_sel]' => $obs['currentName'],`	367	`'obsId1[nom_sel]' => $obs['currentName'],`
344	`// 'obsId1[nom_ret]' => '',`	368	`// 'obsId1[nom_ret]' => '',`
345	`// 'obsId1[famille]' => '',`	369	`// 'obsId1[famille]' => '',`
346	`'obsId1[certitude]' => 'douteux',`	370	`'obsId1[certitude]' => 'douteux',`
347	`// 'obsId1[notes]' => '',`	371	`// 'obsId1[notes]' => '',`
348	`// 'obsId1[num_nom_ret]' => '',`	372	`// 'obsId1[num_nom_ret]' => '',`
349	`// 'obsId1[num_nom_sel]' => '',`	373	`// 'obsId1[num_nom_sel]' => '',`
350	`// 'obsId1[num_taxon]' => '',`	374	`// 'obsId1[num_taxon]' => '',`
351	`'obsId1[referentiel]' => $this->findProbableTaxoRepos($this->currentProject['id']),`	375	`'obsId1[referentiel]' => $this->findProbableTaxoRepos($this->currentProject['id']), // @TODO faire une fois et mettre en cache`
352	`// 'obsId1[station]' => '',`	376	`// 'obsId1[station]' => '',`
353	`'obsId1[obs_id]' => $obs['id'],`	377	`'obsId1[obs_id]' => $obs['id'],`
354	`'projet' => 'PlantNet',`	378	`'projet' => 'PlantNet',`
355	`'tag-img' => implode(', ', $tags_images ?? []),`	379	`'tag-img' => implode(', ', $tags_images ?? []),`
356	`'tag-obs' => 'plantnet, plantnet-mobile, pn:referentiel-' . $this->currentProject['id'],`	380	`'tag-obs' => 'plantnet, plantnet-mobile, pn:referentiel-' . $this->currentProject['id'],`
357	`'utilisateur[courriel]' => $email,`	381	`'utilisateur[courriel]' => $email,`
358	`'utilisateur[id_utilisateur]' => $infos_utilisateur['id'],`	382	`'utilisateur[id_utilisateur]' => $infos_utilisateur['id'],`
359	`'utilisateur[nom]' => $infos_utilisateur['nom'],`	383	`'utilisateur[nom]' => $infos_utilisateur['nom'],`
360	`'utilisateur[prenom]' => $infos_utilisateur['prenom'],`	384	`'utilisateur[prenom]' => $infos_utilisateur['prenom'],`
361	`'origin' => 'pullPlantnet',`	385	`'origin' => 'pullPlantnet',`
362	`];`	386	`];`
363		387
364	`foreach ($images as $i => $image) {`	388	`foreach ($images as $i => $image) {`
365	`$infos_obs["obsId1[image_nom][$i]"] = $image;`	389	`$infos_obs["obsId1[image_nom][$i]"] = $image;`
366	`}`	390	`}`
-		391
367	`// var_dump($infos_obs);`	392	`$this->log("Obs {$obs['id']} prête à être insérée : " . json_encode($infos_obs));`
368		393
369	`// curl post $infos_obs`	394	`// curl post $infos_obs`
370	`$ch = curl_init($url_cel_widget_saisie);`	395	`$ch = curl_init($url_cel_widget_saisie);`
371	`curl_setopt($ch, CURLOPT_POST, true);`	396	`curl_setopt($ch, CURLOPT_POST, true);`
372	`curl_setopt($ch, CURLOPT_POSTFIELDS, $infos_obs);`	397	`curl_setopt($ch, CURLOPT_POSTFIELDS, $infos_obs);`
373	`curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);`	398	`curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);`
374	`$reponse = curl_exec($ch);`	399	`$reponse = curl_exec($ch);`
-		400	`$this->log("Obs {$obs['id']} réponse de la requête d'insertion : " . json_encode($reponse));`
375	`$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);`	401	`$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);`
376	`curl_close($ch);`	402	`curl_close($ch);`
377		403
378	`if (!$reponse \|\| 200 != $code) {`	404	`if (!$reponse \|\| 200 != $code) {`
379	`throw new Exception("Ça a pété à l'envoi de l'obs :\n $reponse\n avec l'obs : " . json_encode($infos_obs) . "\n");`	405	`throw new Exception("Ça a pété à l'envoi de l'obs :\n $reponse\n avec l'obs : " . json_encode($infos_obs) . "\n");`
380	`}`	406	`}`
381		-
382	`// var_dump($reponse);`	407
383	`$id_obs_tb = json_decode($reponse, true)['id'];`	408	`$id_obs_tb = json_decode($reponse, true)['id'];`
384	`$id_obs_pn = $obs['id'];`	409	`$id_obs_pn = $obs['id'];`
385	`// on insère les ids de correspondance obsPN obsTB dans la table cel_plantnet`	410	`// on insère les ids de correspondance obsPN obsTB dans la table cel_plantnet`
386	`$sql = 'INSERT INTO cel_plantnet (id_observation, id_plantnet, date_maj)'`	411	`$sql = 'INSERT INTO cel_plantnet (id_observation, id_plantnet, date_maj)'`
387	`.' VALUES (%s, %s, NOW())'`	412	`.' VALUES (%s, %s, NOW())'`
388	`. ' -- ' . __FILE__ . ':' . __LINE__;`	413	`. ' -- ' . __FILE__ . ':' . __LINE__;`
389	`$sql = sprintf($sql, $this->bdd->proteger($id_obs_tb), $this->bdd->proteger($id_obs_pn));`	414	`$sql = sprintf($sql, $this->bdd->proteger($id_obs_tb), $this->bdd->proteger($id_obs_pn));`
390	`$this->bdd->requeter($sql);`	415	`$this->bdd->requeter($sql);`
391		416
392	`$date = date('d/m/Y H:i:s', intdiv($obs['dateObs'], 1000));`	417	`$date = date('d/m/Y H:i:s', intdiv($obs['dateObs'], 1000));`
393	`$count_img = count($images);`	418	`$count_img = count($images);`
394	`$images_size = number_format($images_size, 0, ',', ' ');`	419	`$images_size = number_format($images_size, 0, ',', ' ');`
395	`echo "Obs insérée en base : ID PN $id_obs_pn ; ID TB $id_obs_tb ; utilisateur_tb $email ; date $date ; images $count_img ; taille_octets $images_size \n";`	420	`echo "Obs insérée en base : ID PN $id_obs_pn ; ID TB $id_obs_tb ; utilisateur_tb $email ; date_obs $date ; images $count_img ; taille_octets $images_size \n";`
396	`}`	421	`}`
397	`}`	422	`}`
398	`}`	423	`}`
399		424
400	`/**`	425	`/**`
401	`* Return TB taxo repos names for given PN project`	426	`* Return TB taxo repos names for given PN project`
402	`*`	427	`*`
403	`* @return string`	428	`* @return string`
404	`*/`	429	`*/`
405	`private function findProbableTaxoRepos($pnProjectId) {`	430	`private function findProbableTaxoRepos($pnProjectId) {`
406	`$selectedRepos = [];`	431	`$selectedRepos = [];`
407	`// Référentiels tela botanica indexés par référentiels PN (version octobre 2019)`	432	`// Référentiels tela botanica indexés par référentiels PN (version octobre 2019)`
408	`// @TODO à revoir en fonction des nouvelles mises en prod de nouveaux référentiels`	433	`// @TODO à revoir en fonction des nouvelles mises en prod de nouveaux référentiels`
409	`$tbTaxoRepos = [`	434	`$tbTaxoRepos = [`
410	`'afn' => [/'apd', /'isfan'],`	435	`'afn' => [/'apd', /'isfan'],`
411	`'aft' => ['apd'],`	436	`'aft' => ['apd'],`
412	`'antilles' => ['bdtxa', 'taxref'],`	437	`'antilles' => ['bdtxa', 'taxref'],`
413	`'canada' => ['vascan'],`	438	`'canada' => ['vascan'],`
414	`'comores' => ['apd'],`	439	`'comores' => ['apd'],`
415	`'endemia' => ['florical', 'taxref'],`	440	`'endemia' => ['florical', 'taxref'],`
416	`'taxref ' => ['bdtfx'],`	441	`'taxref ' => ['bdtfx'],`
417	`'guyane' => ['aublet', 'taxref'],`	442	`'guyane' => ['aublet', 'taxref'],`
418	`'hawai' => [],`	443	`'hawai' => [],`
419	`'lapaz' => ['aublet', 'taxref'],`	444	`'lapaz' => ['aublet', 'taxref'],`
420	`'martinique' => ['bdtxa', 'taxref'],`	445	`'martinique' => ['bdtxa', 'taxref'],`
421	`'maurice' => ['apd'],`	446	`'maurice' => ['apd'],`
422	`'medor' => ['lbf'],`	447	`'medor' => ['lbf'],`
423	`'namerica' => [],`	448	`'namerica' => [],`
424	`'polynesiefr' => ['taxref'],`	449	`'polynesiefr' => ['taxref'],`
425	`'prosea' => ['asia'],`	450	`'prosea' => ['asia'],`
426	`'prota' => ['isfan', 'apd'],`	451	`'prota' => ['isfan', 'apd'],`
427	`'provence' => ['bdtfx', 'taxref'],`	452	`'provence' => ['bdtfx', 'taxref'],`
428	`'reunion' => ['bdtre', 'taxref'],`	453	`'reunion' => ['bdtre', 'taxref'],`
429	`'salad' => ['bdtfx', 'taxref'],`	454	`'salad' => ['bdtfx', 'taxref'],`
430	`'useful' => [],`	455	`'useful' => [],`
431	`'weurope' => ['bdtfx'],`	456	`'weurope' => ['bdtfx'],`
432	`'the-plant-list' => [],`	457	`'the-plant-list' => [],`
433	`'iscantree' => ['apd'],`	458	`'iscantree' => ['apd'],`
434	`'central-america' => [],`	459	`'central-america' => [],`
435	`'invasion' => ['bdtfx'],`	460	`'invasion' => ['bdtfx'],`
436	`'weeds' => ['bdtfx'],`	461	`'weeds' => ['bdtfx'],`
437	`'malaysia' => [],`	462	`'malaysia' => [],`
438	`];`	463	`];`
439		464
440	`if (array_key_exists($pnProjectId, $tbTaxoRepos)) {`	465	`if (array_key_exists($pnProjectId, $tbTaxoRepos)) {`
441	`array_map(function($repo) use ($selectedRepos) {`	466	`array_map(function($repo) use ($selectedRepos) {`
442	`$selectedRepos[] = $repo;`	467	`$selectedRepos[] = $repo;`
443	`}, $tbTaxoRepos[$pnProjectId]);`	468	`}, $tbTaxoRepos[$pnProjectId]);`
444	`}`	469	`}`
445		470
446	`// @TODO chercher le nom dans plusieurs référentiels avant d'envoyer l'obs`	471	`// @TODO chercher le nom dans plusieurs référentiels avant d'envoyer l'obs`
447	`// prendre "enrichirDonneesTaxonomiques" du service de saisie et le coller ici`	472	`// prendre "enrichirDonneesTaxonomiques" du service de saisie et le coller ici`
448	`// en attendant on envoi juste le premier référentiel trouvé`	473	`// en attendant on envoi juste le premier référentiel trouvé`
449	`return $selectedRepos[0] ?? '';`	474	`return $selectedRepos[0] ?? '';`
450	`}`	475	`}`
451		476
452	`/*`	477	`/*`
453	`* Retrouve les infos d'un utilisateur tela à partir de son email`	478	`* Retrouve les infos d'un utilisateur tela à partir de son email`
454	`* @param string $email User email`	479	`* @param string $email User email`
455	`* @return mixed Tableau des infos de l'utilisateur`	480	`* @return mixed Tableau des infos de l'utilisateur`
456	`* False si l'email n'est pas trouvé dans l'annuaire`	481	`* False si l'email n'est pas trouvé dans l'annuaire`
457	`*/`	482	`*/`
458	`private function findUserInfo($email) {`	483	`private function findUserInfo($email) {`
459	`// cherche dans le cache`	484	`// cherche dans le cache`
460	`if (array_key_exists($email, $this->userInfos)) {`	485	`if (array_key_exists($email, $this->userInfos)) {`
461	`$infosUtilisateur = $this->userInfos[$email];`	486	`$infosUtilisateur = $this->userInfos[$email];`
462	`// echo("Email in cache : $email\n");`	487	`// echo("Email in cache : $email\n");`
463	`} else {`	488	`} else {`
464	`$infosUtilisateur = false;`	489	`$infosUtilisateur = false;`
465	`$urlInfosUtilisateur = str_replace('{email}', $email, Config::get('urlAnnuaireIdParEmail'));`	490	`$urlInfosUtilisateur = str_replace('{email}', $email, Config::get('urlAnnuaireIdParEmail'));`
466		491
467	`$ch = curl_init($urlInfosUtilisateur);`	492	`$ch = curl_init($urlInfosUtilisateur);`
468	`curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);`	493	`curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);`
469	`$reponse = curl_exec($ch);`	494	`$reponse = curl_exec($ch);`
470	`$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);`	495	`$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);`
471	`curl_close($ch);`	496	`curl_close($ch);`

Subversion Repositories eFlore/Applications.cel

(root)/branches/v3.00-serfouette/scripts/modules/pull_plantnet/PullPlantnet.php – Rev 3771 → 3773