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 CEL
*/
 
class PullPlantnet extends Script {
 
	protected $bdd;
 
	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 $startDate = '';
	protected $currentPage = '';
	protected $currentProject = '';
	protected $hasMore = false;
	protected $count = 0;
 
	// Traduction des organes de PN
	protected $tagsImageTraduits = [
		'flower' => 'fleur',
		'fruit' => 'fruit',
		'leaf' => 'feuille',
		'bark' => 'écorce',
		'branch' => 'branche',
		'habit' => 'port',
	];
 
	/**
	 * 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, '1', 'Date de début (parsée par strtotime). Ex: "YYYY:MM:DD HH:II:SS"'),
		'-pnObsId' => array(false, true, "ID de l'obs chez PlantNet"),
		'-tbObsId' => array(false, true, "ID de l'obs chez Tela"),
	);
 
	public function __construct($script_nom, $parametres_cli) {
		parent::__construct($script_nom, $parametres_cli);
		$this->bdd = new Bdd();
 
		$this->correspondingIdsFilename = Config::get('correspondingIdsFilename');
	}
 
	public function executer() {
		$cmd = $this->getParametre('a');
 
		switch ($cmd) {
			case 'updateLatest':
				$this->updateLatest($this->getParametre('startDate'));
				break;
			case 'updateOnePN':
				$this->updateOne($this->getParametre('pnObsId'));
				break;
			case 'updateOneTB':
				$this->updateOneTB($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"' . "\n"
						. 'php cli.php PullPlantnet -a updateOnePN -pnObsId "xxxxxx"' . "\n"
						. 'php cli.php PullPlantnet -a updateOneTB -tbObsId "xxxxxx"' . "\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') {
		$this->startDate = strtotime($startDate) * 1000; // we need a microtimestamp
 
		$pnProjects = $this->getProjects(); // refresh projects list
		foreach ($pnProjects as $project) {
			do {
				$observations_PN = $this->getProjectLatest($project);
				$this->updateObs($observations_PN);
			} while ($this->hasMore);
		}
	}
 
	private function getProjectLatest(array $project): 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}'],
				[$project['id'], Config::get('tokenPlantnet'), $this->startDate],
				Config::get('urlPlantnetBase').Config::get('urlPlantnetLatestChanges')
			);
			// die(var_dump($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->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->count += count($observations_PN);
			$this->currentPage = Config::get('urlPlantnetBase').$responseJson['next'].$this->count;
		} else {
			$this->currentPage = '';
			$this->count = 0;
		}
 
		return $observations_PN;
	}
 
	private function getProjects(): array {
		// get PN projects list
		$url = str_replace('{token}', Config::get('tokenPlantnet'), Config::get('urlPlantnetBase').Config::get('urlPlantnetProjects'));
 
		$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_service : $reponse\n");
		}
		$pnProjects = json_decode($reponse, true);
 
		echo 'Liste de projets récupérée : ' . count($pnProjects) . " projets dans la liste\n";
 
		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)) {
				continue;
			} else {
				$this->processedObsId[] = $obs['id'];
			}
 
			// 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'])) {
				continue; // pas de nom de taxon, obs inutile
			}
			if (!isset($obs['geo'])) {
				continue; // pas de position, obs inutile
			}
			if (!isset($obs['dateObs'])) {
				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
				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) {
					continue; // c'est pas un telabotaniste
				}
				echo "Synchro d'une obs d'un telabotaniste : $email\n";
				// echo 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 (TB {$res[0]['id_observation']})\n";
						$this->updateFromPN($obs, $res[0]['id_observation']);
					} else {
						echo "Obs déjà en base : ID PN {$obs['id']}, ID TB {$res[0]['id_observation']}\n";
					}
					continue;
				}
 
				if (isset($obs['deleted']) && (true === $obs['deleted'])) {
					continue; // obs supprimée chez PN sans être passée par nos serveurs
				}
 
				$images = [];
				$tags_images = [];
				foreach ($obs['images'] ?? [] as $i => $image) {
					if ($image['deleted']) {
						continue;
					}
 
					// téléchargement de l'image PN
					$tempfile = tempnam("/tmp", "PullPN_") . ".jpg";
					$handle = fopen($tempfile, "w");
					fwrite($handle, file_get_contents($image['o']));
					fclose($handle);
 
					echo "cool on a fait un fichier de " . filesize($tempfile) . " octets là : $tempfile\n";
 
					$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);
					// var_dump($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'};
						$tags_images[] = $this->tagsImageTraduits[$image['organ']] ?? ''; // @TODO translate
					}
				}
				// var_dump($images, $tags_images);
				// die();
 
				// on insère l'obs via le service CelWidgetSaisie
				$infos_obs = [
					// 'obsId1[commune_code_insee]' => '',
					'obsId1[commune_nom]' => $obs['geo']['place'] ?? '',
					'obsId1[date]' => date('d/m/Y', intdiv($obs['dateObs'], 1000)),
					// 'obsId1[famille]' => '',
					'obsId1[latitude]' => (string)$obs['geo']['lat'] ?? '',
					// 'obsId1[lieudit]' => '',
					'obsId1[longitude]' => (string)$obs['geo']['lon'] ?? '',
					// 'obsId1[milieu]' => '',
					// 'obsId1[nom_ret]' => '',
					'obsId1[nom_sel]' => $obs['currentName'],
					'obsId1[certitude]' => 'douteux',
					// 'obsId1[notes]' => '',
					// 'obsId1[num_nom_ret]' => '',
					// 'obsId1[num_nom_sel]' => '',
					// 'obsId1[num_taxon]' => '',
					'obsId1[referentiel]' => $this->findProbableTaxoRepos($this->currentProject['id']),
					// '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;
				}
				// die(var_dump($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);
				$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");
				}
 
				// var_dump($reponse);
				$id_obs_tb = $this->bdd->proteger(json_decode($reponse, true)['id']);
				$id_obs_pn = $this->bdd->proteger($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, $id_obs_tb, $id_obs_pn);
				$this->bdd->requeter($sql);
			}
		}
	}
 
	/**
	 * 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 updateFromPN(array $pnObs, string $tbObsId) {
		if (!is_array($pnObs) || !is_string($tbObsId)) {
			// die(var_dump($pnObs, $tbObsId));
			throw new Exception("\nBad params types\n");
		}
		// die(var_dump($pnObs));
 
		// 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);
			die(var_dump($res));
			if (isset($res[0]) && ('PlantNet' === $res[0]['input_source'])) {
				// oui ? alors supprimer obs !
				echo("obs à supprimer\n");
				$sql = "DELETE FROM occurrence WHERE id = '$tbObsId'"
						. ' -- ' . __FILE__ . ':' . __LINE__;
				$this->bdd->requeter($sql);
				$sql = "UPDATE photos SET occurrence_id = NULL WHERE occurrence_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($id) {
		// vérification que l'obs est bien dans la BdD de Tela
		$sql = "SELECT date_maj, id_observation FROM cel_plantnet WHERE id_plantnet = '$id'"
					. ' -- ' . __FILE__ . ':' . __LINE__;
		$res = $this->bdd->recupererTous($sql);
		// die(var_dump($res));
		if (!$res) {
			throw new Exception("\nPlantnet occurrence id ($id) doesn't exist in tela db. \n");
		}
 
		// l'obs existe déjà à Tela, on vérifie si il faut màj
		$urlInfosObs = str_replace(
			['{token}', '{ids}'],
			[Config::get('tokenPlantnet'), $id],
			Config::get('urlPlantnetBase').Config::get('urlPlantnetObsById')
		);
		$ch = curl_init($urlInfosObs);
		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("\nPlantnet api ($urlInfosObs) replied with code $code : $reponse\n");
		}
 
		echo "La suite n'a pas été implémentée.\n";
		die(var_dump($reponse));
	}
 
	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 = '';
 
		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);
 
	}
 
	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!";
	}
}
Subversion Repositories eFlore/Applications.cel

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

Rev 3756		Rev 3758
1	`<?php`	1	`<?php`
2		2
3	`/*`	3	`/*`
4	`PHP 7`	4	`PHP 7`
5		5
6	`Script used to synchronize PN occ with CEL`	6	`Script used to synchronize PN occ with CEL`
7	`*/`	7	`*/`
8		8
9	`class PullPlantnet extends Script {`	9	`class PullPlantnet extends Script {`
10		10
11	`protected $bdd;`	11	`protected $bdd;`
12		12
13	`protected $allowedPartners = ['tb', 'pn'];`	13	`protected $allowedPartners = ['tb', 'pn'];`
14		14
15	`// Nom du fichier contenant les correspondances d'ID TB/PN`	15	`// Nom du fichier contenant les correspondances d'ID TB/PN`
16	`protected $correspondingIdsFilename = '';`	16	`protected $correspondingIdsFilename = '';`
17		17
18	`// Cache d'informations utilisateurs provenant de l'annuaire TB`	18	`// Cache d'informations utilisateurs provenant de l'annuaire TB`
19	`protected $userInfos = [];`	19	`protected $userInfos = [];`
-		20
-		21	`// Cache des obs id PN traitées pendant cette run`
-		22	`protected $processedObsId = [];`
20		23
21	`// Paramètre de suivi et de pagination de l'API des obs PN`	24	`// Paramètre de suivi et de pagination de l'API des obs PN`
22	`protected $startDate = '';`	25	`protected $startDate = '';`
23	`protected $currentPage = '';`	26	`protected $currentPage = '';`
24	`protected $currentProject = '';`	27	`protected $currentProject = '';`
25	`protected $hasMore = false;`	28	`protected $hasMore = false;`
26	`protected $count = 0;`	29	`protected $count = 0;`
27		30
28	`// Traduction des organes de PN`	31	`// Traduction des organes de PN`
29	`protected $tagsImageTraduits = [`	32	`protected $tagsImageTraduits = [`
30	`'flower' => 'fleur',`	33	`'flower' => 'fleur',`
31	`'fruit' => 'fruit',`	34	`'fruit' => 'fruit',`
32	`'leaf' => 'feuille',`	35	`'leaf' => 'feuille',`
33	`'bark' => 'écorce',`	36	`'bark' => 'écorce',`
34	`'branch' => 'branche',`	37	`'branch' => 'branche',`
35	`'habit' => 'port',`	38	`'habit' => 'port',`
36	`];`	39	`];`
37		40