Merge pull request #106 from abes-esr/refactor_035

Refactor : changement appel pour récupérer le provider des zones 035.

Dockerfile

@@ -31,12 +31,11 @@ RUN mvn --batch-mode \
 #FROM tomcat:9-jdk17 as api-image
 #COPY --from=build-image /build/web/target/*.war /usr/local/tomcat/webapps/ROOT.war
 #CMD [ "catalina.sh", "run" ]
-FROM eclipse-temurin:17-jdk as sudoc-image
+FROM eclipse-temurin:17-jre as sudoc-image
 WORKDIR /app/
 COPY --from=build-image /build/target/sudoc.jar /app/sudoc.jar
 ENV TZ=Europe/Paris
 RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo $TZ > /etc/timezone
 COPY ./docker/docker-entrypoint.sh /docker-entrypoint.sh
-COPY ./docker/jstatd.all.policy /app/jstatd.all.policy
 RUN chmod +x /docker-entrypoint.sh
 ENTRYPOINT ["/docker-entrypoint.sh"]

docker/docker-entrypoint.sh

@@ -1,15 +1,4 @@
 #!/bin/bash
 
-export HOSTNAME=${HOSTNAME}
-
-echo "Démarrage de jstatd..."
-jstatd -J-Djava.security.policy=jstatd.all.policy -J-Djava.security.manager=allow -J-Djava.rmi.server.hostname=${HOSTNAME} &
-JSTATD_PID=$!
-
 echo "Démarrage de l'application Java..."
-java -XX:MaxRAMPercentage=75 -XX:+UseG1GC -XX:ConcGCThreads=5 -XX:+ExitOnOutOfMemoryError -XX:MaxGCPauseMillis=100 -Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.port=9090 -Dcom.sun.management.jmxremote.rmi.port=9090 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.local.only=false -Djava.rmi.server.hostname=${HOSTNAME} -jar /app/sudoc.jar
-JAVA_APP_PID=$!
-
-# Attendre que les processus se terminent
-wait $JAVA_APP_PID
-kill $JSTATD_PID
+java -XX:MaxRAMPercentage=75 -XX:+UseG1GC -XX:ConcGCThreads=5 -XX:+ExitOnOutOfMemoryError -XX:MaxGCPauseMillis=100 -jar /app/sudoc.jar

src/main/java/fr/abes/sudoc/component/BaseXmlFunctionsCaller.java

@@ -34,14 +34,6 @@ public List<String> isbnToPpn(String isbn) throws UncategorizedSQLException {
     }
 
 
-    public String baconProvider035(Integer provider) throws SQLRecoverableException, UncategorizedSQLException {
-        StringBuilder request = new StringBuilder("SELECT AUTORITES.BACON_PROVIDER_035_JSON(");
-        request.append(provider);
-        request.append(") as data_xml from DUAL");
-        return baseXmlJdbcTemplate.queryForObject(request.toString(), String.class);
-    }
-
-
     public List<String> doiToPpn(String doi) throws UncategorizedSQLException {
         StringBuilder request = new StringBuilder("SELECT distinct ppn from AUTORITES.biblio_table_fouretout where cle1='DOI' and cle2='");
         request.append(doi.toLowerCase());

src/main/java/fr/abes/sudoc/controller/SudocController.java

@@ -9,27 +9,21 @@
 import fr.abes.sudoc.exception.IllegalPpnException;
 import fr.abes.sudoc.exception.ZoneNotFoundException;
 import fr.abes.sudoc.service.*;
-import fr.abes.sudoc.utils.ExecutionTime;
 import fr.abes.sudoc.utils.TYPE_ID;
-import fr.abes.sudoc.utils.TYPE_SUPPORT;
 import fr.abes.sudoc.utils.Utilitaire;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.*;
 
 import javax.validation.Valid;
 import java.io.IOException;
-import java.util.ArrayList;
 import java.util.List;
 import java.util.Optional;
 
 @Slf4j
 @RestController
 @RequestMapping("/api/v1")
 public class SudocController {
-
-
     private final IdentifiantFactory factory;
 
     private final SudocService service;
@@ -55,10 +49,10 @@ public ResultWsDto onlineIdentifier2Ppn(@PathVariable String type, @PathVariable
             TYPE_ID enumType = Utilitaire.getEnumFromString(type);
             IIdentifiantService service = factory.getService(enumType);
             if (service.checkFormat(onlineIdentifier)) {
-                log.debug("Recherche des ppn pour l'identifiant onlineIdentifier n° " + onlineIdentifier + " avec le service " + enumType);
+                log.debug("Recherche des ppn pour l'identifiant onlineIdentifier n° {} avec le service {}", onlineIdentifier, enumType);
                 List<String> listPpn = service.getPpnFromIdentifiant(onlineIdentifier);
                 for (String ppn : listPpn) {
-                    log.debug("onlineIdentifier n° " + onlineIdentifier + " <-> ppn n° " + ppn);
+                    log.debug("onlineIdentifier n° {} <-> ppn n° {}", onlineIdentifier, ppn);
                     feedResultatWithNotice(resultat, providerDto, ppn);
                 }
             }
@@ -68,7 +62,7 @@ public ResultWsDto onlineIdentifier2Ppn(@PathVariable String type, @PathVariable
         } catch (IllegalStateException ex) {
             throw new IllegalArgumentException("Le type " + type + " est incorrect. Les types acceptés sont : monograph, serial");
         } catch (IOException ex) {
-            log.error("erreur dans la récupération de la notice correspondant à l'identifiant " + onlineIdentifier);
+            log.error("erreur dans la récupération de la notice correspondant à l'online identifier {}", onlineIdentifier);
             throw new IOException(ex);
         }
         return resultat;
@@ -84,9 +78,9 @@ public ResultWsDto printIdentifier2Ppn(@PathVariable String type, @PathVariable
             TYPE_ID enumType = Utilitaire.getEnumFromString(type);
             IIdentifiantService service = factory.getService(enumType);
             if (service.checkFormat(printIdentifier)) {
-                log.debug("Recherche des ppn pour l'identifiant printIdentifier n° " + printIdentifier + " avec le service " + enumType);
+                log.debug("Recherche des ppn pour l'identifiant printIdentifier n° {} avec le service {}", printIdentifier, enumType);
                 for (String ppn : service.getPpnFromIdentifiant(printIdentifier)) {
-                    log.debug("printIdentifier n° " + printIdentifier + " <-> ppn n° " + ppn);
+                    log.debug("printIdentifier n° {} <-> ppn n° {}", printIdentifier, ppn);
                     NoticeXml notice = noticeService.getNoticeByPpn(ppn);
                     if (!notice.isDeleted()) {
                         if (notice.isNoticeImprimee()) {
@@ -127,7 +121,7 @@ public ResultWsDto printIdentifier2Ppn(@PathVariable String type, @PathVariable
         } catch (IllegalStateException ex) {
             throw new IllegalArgumentException("Le type " + type + " est incorrect. Les types acceptés sont : monograph, serial");
         } catch (IOException ex) {
-            log.error("erreur dans la récupération de la notice correspondant à l'identifiant " + printIdentifier);
+            log.error("erreur dans la récupération de la notice correspondant à au print identifier {}", printIdentifier);
             throw new IOException(ex);
         }
     }
@@ -141,21 +135,21 @@ public ResultWsDto doiIdentifier2Ppn(@RequestParam(name = "doi") String doi_iden
         try {
             IIdentifiantService service = factory.getService(TYPE_ID.DOI);
             if (service.checkFormat(doi_identifier)) {
-                log.debug("Recherche des ppn pour l'identifiant doi_identifier n° " + doi_identifier + " avec le service DOI");
+                log.debug("Recherche des ppn pour l'identifiant doi_identifier n° {} avec le service DOI", doi_identifier);
                 for(String ppn : service.getPpnFromIdentifiant(doi_identifier) ) {
-                    log.debug("doi_identifier n° " + doi_identifier + " <-> ppn n° " + ppn);
+                    log.debug("doi_identifier n° {} <-> ppn n° {}", doi_identifier, ppn);
                     feedResultatWithNotice(resultat, providerDto, ppn);
                 }
             } else {
                 throw new IllegalArgumentException("Le DOI n'est pas au bon format");
             }
         } catch (IOException ex) {
-            log.error("Erreur dans la récupération de la notice correspondant à l'identifiant");
+            log.error("Erreur dans la récupération de la notice correspondant au doi {}", doi_identifier);
             throw new IOException(ex);
         } catch (ZoneNotFoundException e) {
             throw new IOException(e.getMessage());
         } catch (IllegalPpnException e) {
-            log.info("Aucune notice ne correspond à l'identifiant " + doi_identifier);
+            log.info("Aucune notice ne correspond au doi {}", doi_identifier);
             //res.addErreur("Aucune notice ne correspond à l'identifiant " + doi_identifier);
         }
         return resultat;
@@ -189,7 +183,7 @@ public ResultWsDto datToPpn(@Valid @RequestBody SearchDatWebDto request) throws
         }
         try {
             for (String ppn : service.getPpnFromDat(request.getDate(), request.getAuteur(), request.getTitre())) {
-                log.debug("dat2ppn : date : " + request.getDate() + " / auteur : " + request.getAuteur() + " / titre : " + request.getTitre() + " <-> ppn n° " + ppn);
+                log.debug("dat2ppn : date : {} / auteur : {} / titre : {} <-> ppn n° {}", request.getDate(), request.getAuteur(), request.getTitre(), ppn);
                 feedResultatWithNotice(resultat, providerDto, ppn);
             }
         } catch (CBSException | ZoneNotFoundException ex) {

src/main/java/fr/abes/sudoc/entity/Provider035.java

@@ -0,0 +1,20 @@
+package fr.abes.sudoc.entity;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Entity
+@Data
+@Table(name = "PROVIDER_035", schema = "BACON")
+public class Provider035 implements Serializable {
+    @Id
+    @Column(name = "IDT_PROVIDER")
+    private Integer id;
+    @Column(name = "VALEUR_035")
+    private String valeur;
+}

src/main/java/fr/abes/sudoc/repository/Provider035Repository.java

@@ -0,0 +1,9 @@
+package fr.abes.sudoc.repository;
+
+import fr.abes.sudoc.entity.Provider035;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface Provider035Repository extends JpaRepository<Provider035, Integer> {
+}

src/main/java/fr/abes/sudoc/service/DoiService.java

@@ -39,7 +39,9 @@ public List<String> getPpnFromIdentifiant(String doi) throws IOException, Illega
                 if (result.size() != 1) {
                     throw new IllegalPpnException("Plusieurs résultats à la recherche sur doi " + doi);
                 } else {
-                    return Collections.singletonList(result.get(0));
+                    List<String> retour = new ArrayList<>();
+                    retour.add(result.get(0));
+                    return retour;
                 }
         } catch (UncategorizedSQLException ex) {
             throw new IOException("Incident technique lors de l'accès à la base de données");

src/main/java/fr/abes/sudoc/service/ProviderService.java

@@ -1,36 +1,25 @@
 package fr.abes.sudoc.service;
 
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import fr.abes.sudoc.component.BaseXmlFunctionsCaller;
 import fr.abes.sudoc.dto.provider.ElementDto;
-import fr.abes.sudoc.dto.provider035.ResultProvider035Dto;
 import fr.abes.sudoc.entity.Provider;
+import fr.abes.sudoc.entity.Provider035;
 import fr.abes.sudoc.entity.notice.NoticeXml;
+import fr.abes.sudoc.repository.Provider035Repository;
 import fr.abes.sudoc.repository.ProviderRepository;
-import fr.abes.sudoc.utils.ExecutionTime;
-import fr.abes.sudoc.utils.Utilitaire;
 import lombok.RequiredArgsConstructor;
 import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 
 import java.io.IOException;
-import java.sql.SQLRecoverableException;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
 import java.util.Optional;
 
 @Service
 @RequiredArgsConstructor
 public class ProviderService {
-
-    private final BaseXmlFunctionsCaller caller;
-
-    private final ObjectMapper objectMapper;
-
     private final ProviderRepository providerRepository;
 
+    private final Provider035Repository provider035Repository;
+
 
     @Cacheable("providerCache")
     public Optional<ElementDto> getProviderDisplayName(Optional<String> shortname) {
@@ -49,46 +38,25 @@ public Optional<ElementDto> getProviderDisplayName(Optional<String> shortname) {
         return providerDisplayName;
     }
 
-
-    public List<String> getProviderFor035(Integer provider) throws IOException {
-        List<String> listValeurs = new ArrayList<>();
-        try {
-            ResultProvider035Dto result = objectMapper.readValue(caller.baconProvider035(provider), ResultProvider035Dto.class);
-            if (result.getBacon().getQuery().getResult() != null) {
-                String valeur035 = result.getBacon().getQuery().getResult().getElements().getValeur035();
-                if (valeur035 != null) {
-                    listValeurs.addAll(Arrays.stream(valeur035.split("\\|")).toList());
-                }
-            }
-        } catch (JsonProcessingException ex) {
-            throw new IOException("Impossible de récupérer les ppns correspondant à cet identifiant");
-        } catch (SQLRecoverableException ex) {
-            throw new IOException("Incident technique lors de l'accès à la base de données");
-        }
-        return listValeurs;
+    public String getProviderFor035(Integer provider) {
+        Optional<Provider035> valeur035Opt = provider035Repository.findById(provider);
+        return valeur035Opt.map(Provider035::getValeur).orElse(null);
     }
 
     public boolean checkProviderDansNoticeGeneral(Optional<ElementDto> providerDisplayName, NoticeXml notice) throws IOException {
-        if (providerDisplayName.isPresent()) {
-            return this.checkProviderDansNotice(providerDisplayName.get().getDisplayName(), notice)
-                    || this.checkProviderDansNotice(providerDisplayName.get().getProvider(), notice)
-                    || this.checkProviderIn035(providerDisplayName.get().getIdProvider(), notice);
-        }
-        return true;
+        return providerDisplayName.map(elementDto -> this.checkProviderDansNotice(elementDto.getDisplayName(), notice)
+                || this.checkProviderDansNotice(elementDto.getProvider(), notice)
+                || this.checkProviderIn035(elementDto.getIdProvider(), notice)).orElse(true);
     }
 
     private boolean checkProviderDansNotice(String provider, NoticeXml notice) {
         return notice.checkProviderInZone(provider, "210", "c")
                 || notice.checkProviderInZone(provider, "214", "c");
     }
 
-    private boolean checkProviderIn035(Integer providerIdt, NoticeXml notice) throws IOException {
-        List<String> providers035 = this.getProviderFor035(providerIdt);
-        for (String provider035 : providers035) {
-            if (notice.checkProviderIn035a(provider035)) {
-                return true;
-            }
-        }
-        return false;
+    private boolean checkProviderIn035(Integer providerIdt, NoticeXml notice) {
+        String provider035 = this.getProviderFor035(providerIdt);
+        return provider035 != null && notice.checkProviderIn035a(provider035);
+
     }
 }