Skip to content

Commit

Permalink
FIX : Ajout condition sur création notice Exnihilo
Browse files Browse the repository at this point in the history
  • Loading branch information
pierre-maraval committed Nov 7, 2024
1 parent 27e0704 commit f9b8b23
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion src/main/java/fr/abes/kafkatosudoc/kafka/KbartListener.java
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
import fr.abes.kafkatosudoc.service.EmailService;
import fr.abes.kafkatosudoc.service.SudocService;
import fr.abes.kafkatosudoc.utils.CheckFiles;
import fr.abes.kafkatosudoc.utils.Utils;
import fr.abes.kafkatosudoc.utils.UtilsMapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.avro.generic.GenericRecord;
Expand Down Expand Up @@ -382,7 +383,10 @@ public void listenKbartFromKafkaExNihilo(ConsumerRecord<String, LigneKbartConnec
service.authenticateBaseSignal(serveurSudoc, portSudoc, loginSudoc, passwordSudoc, signalDb);
if (this.workInProgressMapExNihilo.get(filename).getListeNotices() != null && !this.workInProgressMapExNihilo.get(filename).getListeNotices().isEmpty()) {
for (LigneKbartConnect ligneKbartConnect : this.workInProgressMapExNihilo.get(filename).getListeNotices()) {
creerNoticeExNihilo(ligneKbartConnect, provider, service, packageName);
//on ne crée la notice que s'il existe un onlineId ou un doi
if (ligneKbartConnect.getONLINEIDENTIFIER() != null || !Utils.extractDoiFromConnect(ligneKbartConnect).isEmpty()) {
creerNoticeExNihilo(ligneKbartConnect, provider, service, packageName);
}
}
}

Expand Down

0 comments on commit f9b8b23

Please sign in to comment.