Cde 302 acceder aux logs de lalgo best ppn sur la prod

src/main/java/fr/abes/bestppn/BestPpnApplication.java

@@ -2,9 +2,11 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.EnableAspectJAutoProxy;
 import org.springframework.kafka.annotation.EnableKafka;
 
 @EnableKafka
+@EnableAspectJAutoProxy
 @SpringBootApplication
 public class BestPpnApplication {
 	public static void main(String[] args) {

src/main/java/fr/abes/bestppn/configuration/BaconDbConfig.java

@@ -41,7 +41,7 @@ public class BaconDbConfig extends AbstractConfig {
     public LocalContainerEntityManagerFactoryBean baconEntityManager() {
         LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
         em.setDataSource(baconDataSource());
-        em.setPackagesToScan(new String[]{"fr.abes.bestppn.entity.bacon"});
+        em.setPackagesToScan(new String[]{"fr.abes.bestppn.model.entity.bacon"});
         configHibernate(em, platform, showsql, dialect, ddlAuto, generateDdl, initMode);
         return em;
     }

src/main/java/fr/abes/bestppn/configuration/BaseXMLOracleConfig.java

@@ -46,7 +46,7 @@ public LocalContainerEntityManagerFactoryBean baseXmlEntityManager() {
 				= new LocalContainerEntityManagerFactoryBean();
 		em.setDataSource(baseXmlDataSource());
 		em.setPackagesToScan(
-				"fr.abes.bestppn.entity.basexml");
+				"fr.abes.bestppn.model.entity.basexml");
 		configHibernate(em, platform, showsql, dialect, ddlAuto, generateDdl, initMode);
 		return em;
 	}

src/main/java/fr/abes/bestppn/controller/BestPpnController.java

@@ -1,6 +1,8 @@
 package fr.abes.bestppn.controller;
 
-import fr.abes.bestppn.dto.kafka.LigneKbartDto;
+import fr.abes.bestppn.model.dto.BestPpnDto;
+import fr.abes.bestppn.model.dto.kafka.LigneKbartDto;
+import fr.abes.bestppn.model.BestPpn;
 import fr.abes.bestppn.exception.BestPpnException;
 import fr.abes.bestppn.exception.IllegalDoiException;
 import fr.abes.bestppn.service.BestPpnService;
@@ -15,6 +17,8 @@
 
 import java.io.IOException;
 import java.net.URISyntaxException;
+import java.util.ArrayList;
+import java.util.List;
 
 @Tag(name = "Calcul du meilleur PPN", description = "API de calcul du meilleur PPN pour une ligne tsv")
 @CrossOrigin(origins = "*")
@@ -37,11 +41,12 @@ public BestPpnController(BestPpnService service) {
             }
     )
     @GetMapping(value = "/bestPpn")
-    public String bestPpn(@RequestParam(name = "provider") String provider, @RequestParam(name = "publication_title", required = false) String publicationTitle,
-                          @RequestParam(name = "publication_type") String publicationType, @RequestParam(name = "online_identifier", required = false) String onlineIdentifier,
-                          @RequestParam(name = "print_identifier", required = false) String printIdentifier, @RequestParam(name = "titleUrl", required = false) String titleUrl,
-                          @RequestParam(name = "date_monograph_published_online", required = false) String dateMonographPublishedOnline, @RequestParam(name = "date_monograph_published_print", required = false) String dateMonographPublishedPrint,
-                          @RequestParam(name = "first_author", required = false) String firstAuthor, @RequestParam(name = "force", required = false) Boolean force) throws IOException {
+    public BestPpnDto bestPpn(@RequestParam(name = "provider") String provider, @RequestParam(name = "publication_title", required = false) String publicationTitle,
+                              @RequestParam(name = "publication_type") String publicationType, @RequestParam(name = "online_identifier", required = false) String onlineIdentifier,
+                              @RequestParam(name = "print_identifier", required = false) String printIdentifier, @RequestParam(name = "titleUrl", required = false) String titleUrl,
+                              @RequestParam(name = "date_monograph_published_online", required = false) String dateMonographPublishedOnline, @RequestParam(name = "date_monograph_published_print", required = false) String dateMonographPublishedPrint,
+                              @RequestParam(name = "first_author", required = false) String firstAuthor, @RequestParam(name = "force", required = false) Boolean force,
+                              @RequestParam(name = "log", required = false) Boolean log) throws IOException {
         try {
             LigneKbartDto ligneKbartDto = new LigneKbartDto();
             ligneKbartDto.setPublicationType(publicationType);
@@ -53,11 +58,16 @@ public String bestPpn(@RequestParam(name = "provider") String provider, @Request
             ligneKbartDto.setDateMonographPublishedOnline((dateMonographPublishedOnline != null) ? dateMonographPublishedOnline : "");
             ligneKbartDto.setFirstAuthor((firstAuthor != null) ? firstAuthor : "");
             boolean injectKafka = (force != null) ? force : false;
-            return service.getBestPpn(ligneKbartDto, provider, injectKafka).getPpn();
+            boolean isSendLog = (log != null) ? log : false;
+            BestPpn bestPpn = service.getBestPpn(ligneKbartDto, provider, injectKafka, isSendLog);
+            if(!isSendLog) bestPpn.setLogs(null); // désactive l'envoi des logs si non demandés.
+            return new BestPpnDto(bestPpn);
         } catch (URISyntaxException e) {
             throw new IllegalArgumentException("Une url dans le champ title_url du kbart n'est pas correcte");
         } catch (BestPpnException | RestClientException | IllegalArgumentException | IllegalDoiException e) {
-            return e.getMessage();
+            List<String> logs = new ArrayList<>();
+            logs.add(e.getMessage());
+            return new BestPpnDto(logs);
         }
     }
 }

src/main/java/fr/abes/bestppn/kafka/TopicConsumer.java

@@ -2,8 +2,8 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import fr.abes.bestppn.dto.kafka.LigneKbartDto;
-import fr.abes.bestppn.entity.bacon.Provider;
+import fr.abes.bestppn.model.dto.kafka.LigneKbartDto;
+import fr.abes.bestppn.model.entity.bacon.Provider;
 import fr.abes.bestppn.exception.*;
 import fr.abes.bestppn.repository.bacon.ProviderRepository;
 import fr.abes.bestppn.service.EmailService;

src/main/java/fr/abes/bestppn/kafka/TopicProducer.java

@@ -3,8 +3,8 @@
 import com.fasterxml.jackson.core.JsonProcessingException;
 import fr.abes.LigneKbartConnect;
 import fr.abes.LigneKbartImprime;
-import fr.abes.bestppn.dto.kafka.LigneKbartDto;
-import fr.abes.bestppn.entity.bacon.ProviderPackage;
+import fr.abes.bestppn.model.dto.kafka.LigneKbartDto;
+import fr.abes.bestppn.model.entity.bacon.ProviderPackage;
 import fr.abes.bestppn.exception.BestPpnException;
 import fr.abes.bestppn.utils.UtilsMapper;
 import jakarta.annotation.PostConstruct;

src/main/java/fr/abes/bestppn/model/BestPpn.java

@@ -0,0 +1,52 @@
+package fr.abes.bestppn.model;
+
+import fr.abes.bestppn.utils.DESTINATION_TOPIC;
+import fr.abes.bestppn.utils.TYPE_SUPPORT;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import org.springframework.lang.Nullable;
+
+import java.util.List;
+
+@Getter
+@Setter
+@NoArgsConstructor
+public class BestPpn {
+
+    @Nullable
+    private String ppn;
+
+    @Nullable
+    private TYPE_SUPPORT typeSupport;
+
+    @Nullable
+    private DESTINATION_TOPIC destination;
+
+    @Nullable
+    private List<String> logs;
+
+    public BestPpn(String ppn, DESTINATION_TOPIC destination) {
+        this.ppn = ppn;
+        this.destination = destination;
+    }
+
+    public BestPpn(String ppn, DESTINATION_TOPIC destination, TYPE_SUPPORT typeSupport) {
+        this.ppn = ppn;
+        this.destination = destination;
+        this.typeSupport = typeSupport;
+    }
+
+    public BestPpn(String ppn, DESTINATION_TOPIC destination, List<String> logs) {
+        this.ppn = ppn;
+        this.destination = destination;
+        this.logs = logs;
+    }
+
+    public BestPpn(String ppn, DESTINATION_TOPIC destination, TYPE_SUPPORT typeSupport, List<String> logs) {
+        this.ppn = ppn;
+        this.destination = destination;
+        this.typeSupport = typeSupport;
+        this.logs = logs;
+    }
+}

src/main/java/fr/abes/bestppn/model/dto/BestPpnDto.java

@@ -0,0 +1,44 @@
+package fr.abes.bestppn.model.dto;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import fr.abes.bestppn.model.BestPpn;
+import fr.abes.bestppn.utils.TYPE_SUPPORT;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import org.springframework.lang.Nullable;
+
+import java.util.List;
+
+@Getter
+@Setter
+@NoArgsConstructor
+public class BestPpnDto {
+    @Nullable
+    @JsonInclude(JsonInclude.Include.NON_NULL)
+    private String ppn;
+
+    @Nullable
+    @JsonInclude(JsonInclude.Include.NON_NULL)
+    private TYPE_SUPPORT typeSupport;
+
+    @Nullable
+    @JsonInclude(JsonInclude.Include.NON_NULL)
+    private List<String> logs;
+
+    public BestPpnDto(String ppn, TYPE_SUPPORT typeSupport, List<String> logs) {
+        this.ppn = ppn;
+        this.typeSupport = typeSupport;
+        this.logs = logs;
+    }
+
+    public BestPpnDto(List<String> logs) {
+        this.logs = logs;
+    }
+
+    public BestPpnDto(BestPpn bestPpn) {
+        this.ppn = bestPpn.getPpn();
+        this.typeSupport = bestPpn.getTypeSupport();
+        this.logs = bestPpn.getLogs();
+    }
+}

src/main/java/fr/abes/bestppn/dto/PackageKbartDto.java → src/main/java/fr/abes/bestppn/model/dto/PackageKbartDto.java

@@ -1,6 +1,6 @@
-package fr.abes.bestppn.dto;
+package fr.abes.bestppn.model.dto;
 
-import fr.abes.bestppn.dto.kafka.LigneKbartDto;
+import fr.abes.bestppn.model.dto.kafka.LigneKbartDto;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 import lombok.Setter;

src/main/java/fr/abes/bestppn/dto/kafka/KbartProviderDto.java → src/main/java/fr/abes/bestppn/model/dto/kafka/KbartProviderDto.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.dto.kafka;
+package fr.abes.bestppn.model.dto.kafka;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import lombok.Getter;

src/main/java/fr/abes/bestppn/dto/kafka/LigneKbartDto.java → src/main/java/fr/abes/bestppn/model/dto/kafka/LigneKbartDto.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.dto.kafka;
+package fr.abes.bestppn.model.dto.kafka;
 
 import com.fasterxml.jackson.annotation.JsonIgnore;
 import com.fasterxml.jackson.annotation.JsonProperty;

src/main/java/fr/abes/bestppn/dto/kafka/PpnKbartProviderDto.java → src/main/java/fr/abes/bestppn/model/dto/kafka/PpnKbartProviderDto.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.dto.kafka;
+package fr.abes.bestppn.model.dto.kafka;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

src/main/java/fr/abes/bestppn/dto/mail/MailDto.java → src/main/java/fr/abes/bestppn/model/dto/mail/MailDto.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.dto.mail;
+package fr.abes.bestppn.model.dto.mail;
 
 import lombok.Getter;
 import lombok.Setter;

src/main/java/fr/abes/bestppn/dto/wscall/PpnWithTypeDto.java → src/main/java/fr/abes/bestppn/model/dto/wscall/PpnWithTypeDto.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.dto.wscall;
+package fr.abes.bestppn.model.dto.wscall;
 
 import fr.abes.bestppn.utils.TYPE_DOCUMENT;
 import fr.abes.bestppn.utils.TYPE_SUPPORT;

src/main/java/fr/abes/bestppn/dto/wscall/ResultDat2PpnWebDto.java → src/main/java/fr/abes/bestppn/model/dto/wscall/ResultDat2PpnWebDto.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.dto.wscall;
+package fr.abes.bestppn.model.dto.wscall;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import lombok.Getter;

src/main/java/fr/abes/bestppn/dto/wscall/ResultWsSudocDto.java → src/main/java/fr/abes/bestppn/model/dto/wscall/ResultWsSudocDto.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.dto.wscall;
+package fr.abes.bestppn.model.dto.wscall;
 
 import fr.abes.bestppn.utils.TYPE_SUPPORT;
 import lombok.Getter;

src/main/java/fr/abes/bestppn/dto/wscall/SearchDatWebDto.java → src/main/java/fr/abes/bestppn/model/dto/wscall/SearchDatWebDto.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.dto.wscall;
+package fr.abes.bestppn.model.dto.wscall;
 
 import lombok.Getter;
 import lombok.Setter;

src/main/java/fr/abes/bestppn/entity/ExecutionReport.java → src/main/java/fr/abes/bestppn/model/entity/ExecutionReport.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.entity;
+package fr.abes.bestppn.model.entity;
 
 import lombok.Data;
 

src/main/java/fr/abes/bestppn/entity/PpnResultList.java → src/main/java/fr/abes/bestppn/model/entity/PpnResultList.java

@@ -1,6 +1,6 @@
-package fr.abes.bestppn.entity;
+package fr.abes.bestppn.model.entity;
 
-import fr.abes.bestppn.dto.wscall.PpnWithTypeDto;
+import fr.abes.bestppn.model.dto.wscall.PpnWithTypeDto;
 import fr.abes.bestppn.utils.TYPE_SUPPORT;
 import lombok.Getter;
 import lombok.NoArgsConstructor;

src/main/java/fr/abes/bestppn/entity/bacon/LigneKbart.java → src/main/java/fr/abes/bestppn/model/entity/bacon/LigneKbart.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.entity.bacon;
+package fr.abes.bestppn.model.entity.bacon;
 
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;

src/main/java/fr/abes/bestppn/entity/bacon/Provider.java → src/main/java/fr/abes/bestppn/model/entity/bacon/Provider.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.entity.bacon;
+package fr.abes.bestppn.model.entity.bacon;
 
 import jakarta.persistence.*;
 import lombok.Getter;

src/main/java/fr/abes/bestppn/entity/bacon/ProviderPackage.java → src/main/java/fr/abes/bestppn/model/entity/bacon/ProviderPackage.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.entity.bacon;
+package fr.abes.bestppn.model.entity.bacon;
 
 import jakarta.persistence.*;
 import lombok.AllArgsConstructor;

src/main/java/fr/abes/bestppn/entity/basexml/NoticesBibio.java → src/main/java/fr/abes/bestppn/model/entity/basexml/NoticesBibio.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.entity.basexml;
+package fr.abes.bestppn.model.entity.basexml;
 
 import jakarta.persistence.*;
 import lombok.Getter;

src/main/java/fr/abes/bestppn/entity/basexml/notice/Controlfield.java → src/main/java/fr/abes/bestppn/model/entity/basexml/notice/Controlfield.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.entity.basexml.notice;
+package fr.abes.bestppn.model.entity.basexml.notice;
 
 import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty;
 import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlText;

src/main/java/fr/abes/bestppn/entity/basexml/notice/Datafield.java → src/main/java/fr/abes/bestppn/model/entity/basexml/notice/Datafield.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.entity.basexml.notice;
+package fr.abes.bestppn.model.entity.basexml.notice;
 
 import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty;
 import lombok.Getter;

src/main/java/fr/abes/bestppn/entity/basexml/notice/NoticeXml.java → src/main/java/fr/abes/bestppn/model/entity/basexml/notice/NoticeXml.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.entity.basexml.notice;
+package fr.abes.bestppn.model.entity.basexml.notice;
 
 import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty;
 import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlRootElement;

src/main/java/fr/abes/bestppn/entity/basexml/notice/SubField.java → src/main/java/fr/abes/bestppn/model/entity/basexml/notice/SubField.java

@@ -1,4 +1,4 @@
-package fr.abes.bestppn.entity.basexml.notice;
+package fr.abes.bestppn.model.entity.basexml.notice;
 
 import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty;
 import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlText;

src/main/java/fr/abes/bestppn/repository/bacon/LigneKbartRepository.java

@@ -1,7 +1,7 @@
 package fr.abes.bestppn.repository.bacon;
 
 import fr.abes.bestppn.configuration.BaconDbConfiguration;
-import fr.abes.bestppn.entity.bacon.LigneKbart;
+import fr.abes.bestppn.model.entity.bacon.LigneKbart;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 import org.springframework.transaction.annotation.Transactional;

src/main/java/fr/abes/bestppn/repository/bacon/ProviderPackageRepository.java

@@ -1,7 +1,7 @@
 package fr.abes.bestppn.repository.bacon;
 
 import fr.abes.bestppn.configuration.BaconDbConfiguration;
-import fr.abes.bestppn.entity.bacon.ProviderPackage;
+import fr.abes.bestppn.model.entity.bacon.ProviderPackage;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 

src/main/java/fr/abes/bestppn/repository/bacon/ProviderRepository.java

@@ -1,7 +1,7 @@
 package fr.abes.bestppn.repository.bacon;
 
 import fr.abes.bestppn.configuration.BaconDbConfiguration;
-import fr.abes.bestppn.entity.bacon.Provider;
+import fr.abes.bestppn.model.entity.bacon.Provider;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 

src/main/java/fr/abes/bestppn/repository/basexml/NoticesBibioRepository.java

@@ -1,6 +1,6 @@
 package fr.abes.bestppn.repository.basexml;
 
-import fr.abes.bestppn.entity.basexml.NoticesBibio;
+import fr.abes.bestppn.model.entity.basexml.NoticesBibio;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;