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

 	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 = [];
+	protected $userInfos = [];
-	// Paramètre de suivi et de pagination de l'API des obs PN
-	protected $currentPage = '';
+	// Paramètre de suivi et de pagination de l'API des obs PN
-	protected $currentProject = '';
+	protected $currentPage = '';
 	protected $lastTimestamp = '';
 	protected $hasMore = false;
+		}
+	}
 	/**
-	 * Considering all modified pn obs since startDate
-	 * One pn project after an other
+	 * Considering all modified pn obs since startDate
 	 * 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
+		$startDate = strtotime($startDate) * 1000; // we need a microtimestamp
-		foreach ($pnProjects as $project) {
-			do {
+		do {
-				$observations_PN = $this->getProjectLatest($project, $startDate, $lifecycle);
+			$observations_PN = $this->getLatest($startDate, $lifecycle);
-				$this->updateObs($observations_PN);
-			} while ($this->hasMore);
+			$this->updateObs($observations_PN);
-		}
+		} while ($this->hasMore);
-	}
+	}
 	private function getProjectLatest(array $project, int $startDate, string $lifecycle): array {
-		$this->currentProject = $project;
-		$this->refreshBddConnexion();
 	private function getLatest(int $startDate, string $lifecycle): array {
-		if (!$this->currentPage) {
+		$this->refreshBddConnexion();
-			echo 'Projet ' . $project['name'] . "\n";
+		if (!$this->currentPage) {
 			// hop, on appelle le service de PN
 			$url_service = str_replace(
-				['{project}', '{token}', '{startDate}', '{lifecycle}'],
+				['{token}', '{startDate}', '{lifecycle}'],
 		$this->lastTimestamp = end($observations_PN)['dateUpdated'];
 		if ($this->hasMore) {
 			// $url_service = Config::get('urlPlantnetBase').$responseJson['next'];
 			// Build next page url with last read timestamp, to avoid pagination latency
 			$url_service = str_replace(
-				['{project}', '{token}', '{startDate}', '{lifecycle}'],
+				['{token}', '{startDate}', '{lifecycle}'],
-				[$project['id'], Config::get('tokenPlantnet'), $this->lastTimestamp, $lifecycle],
+				[Config::get('tokenPlantnet'), $this->lastTimestamp, $lifecycle],
 				Config::get('urlPlantnetBase').Config::get('urlPlantnetLatestChanges')
 			);
 			$this->currentPage = $url_service;
 			$this->debug("URL service derniers changements, page suivante : {$this->currentPage}");
 		} else {
 		return $observations_PN;
+	}
 	private function getProjects(): array {
-		// get PN projects list
+		// get PN projects list (useless since we have a single source)
 		$url = str_replace('{token}', Config::get('tokenPlantnet'), Config::get('urlPlantnetBase').Config::get('urlPlantnetProjects'));
 	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 (array_key_exists($obs['id'], $this->processedObsId)) {
-				$this->log("Obs {$obs['id']} déjà traitée pendant cette run");
-				continue;
-			} else {
-				$this->processedObsId[$obs['id']] = true;
-				$this->log("Obs {$obs['id']} ajoutée à la liste des obs traitées pendant cette run");
 		foreach ($observations_PN as $obs) {
 			// 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");
 					'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[referentiel]' => $this->findProbableTaxoRepos($obs['project']), // @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'],
+					'tag-obs' => 'plantnet, plantnet-mobile, pn:referentiel-' . $obs['project'],
 					'utilisateur[courriel]' => $email,
 					'utilisateur[id_utilisateur]' => $infos_utilisateur['id'],
 					'utilisateur[nom]' => $infos_utilisateur['nom'],
 					'utilisateur[prenom]' => $infos_utilisateur['prenom'],
 					'origin' => 'pullPlantnet',
 		// // 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));
+		if (!is_int($pnObsId) || !is_string($pnProjectId)) {
 			throw new Exception("\nBad params types, give me an integer and a string plz\n");
+		}
 		// get PN project list
 		$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(

Subversion Repositories eFlore/Applications.cel

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