Skip to content

Commit

Permalink
Merge pull request #72 from abes-esr/develop
Browse files Browse the repository at this point in the history 
suppression des log.info
  • Loading branch information
@julg
julg authored Dec 11, 2023
2 parents f4e6905 + 6b4245c commit abd0b84
Show file tree
Hide file tree
Showing 20 changed files with 93 additions and 92 deletions.
12 changes: 4 additions & 8 deletions src/main/java/fr/abes/theses_batch_indexation/configuration/BatchConfiguration.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -32,13 +32,9 @@
public class BatchConfiguration {

protected final JobBuilderFactory jobs;

protected final StepBuilderFactory stepBuilderFactory;

protected final DataSource dataSourceLecture;

private final JobConfig config;

private final ItemWriteListener<TheseModel> theseWriteListener;
private final ItemProcessListener<TheseModel, TheseModel> theseProcessListener;

Expand All @@ -59,7 +55,7 @@ public Job jobIndexationThesesDansES(Step stepIndexThesesDansES,
Tasklet initialiserIndexESTasklet,
Tasklet chargerOaiSetsTasklet,
JobTheseCompletionNotificationListener listener) {
log.info("debut du job indexation des theses dans ES...");
log.debug("debut du job indexation des theses dans ES...");

return jobs.get("indexationThesesDansES").repository(jobRepository).incrementer(new RunIdIncrementer())
.listener(listener)
Expand Down Expand Up @@ -119,7 +115,7 @@ public Job jobIndexationThematiquesDansES(Step stepIndexThematiquesDansES,
JobRepository jobRepository,
Tasklet initialiserIndexESTasklet,
JobTheseCompletionNotificationListener listener) {
log.info("debut du job indexation des thematiques dans ES...");
log.debug("debut du job indexation des thematiques dans ES...");

return jobs.get("indexationThematiquesDansES").repository(jobRepository).incrementer(new RunIdIncrementer())
.listener(listener)
Expand All @@ -134,7 +130,7 @@ public Job jobIndexationThematiquesDansES(Step stepIndexThematiquesDansES,
public Job jobSuppressionThesesDansES(Step stepSupprimeThesesOuThematiquesDansES,
JobRepository jobRepository,
JobTheseCompletionNotificationListener listener) {
log.info("debut du job de suppression des theses dans ES...");
log.debug("debut du job de suppression des theses dans ES...");

return jobs.get("suppressionThesesDansES").repository(jobRepository).incrementer(new RunIdIncrementer())
.listener(listener)
Expand All @@ -146,7 +142,7 @@ public Job jobSuppressionThesesDansES(Step stepSupprimeThesesOuThematiquesDansES
public Job jobSuppressionThematiquesDansES(Step stepSupprimeThesesOuThematiquesDansES,
JobRepository jobRepository,
JobTheseCompletionNotificationListener listener) {
log.info("debut du job de suppression des thématiques dans ES...");
log.debug("debut du job de suppression des thématiques dans ES...");

return jobs.get("suppressionThematiquesDansES").repository(jobRepository).incrementer(new RunIdIncrementer())
.listener(listener)
Expand Down
2 changes: 0 additions & 2 deletions src/main/java/fr/abes/theses_batch_indexation/configuration/ElasticClient.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,8 @@
public class ElasticClient {

private static ElasticsearchClient client;

private ElasticClient() {
}

public static ElasticsearchClient getElasticsearchClient() {
return client;
}
Expand Down
3 changes: 3 additions & 0 deletions src/main/java/fr/abes/theses_batch_indexation/database/DbService.java
View file
Original file line number Diff line number Diff line change
@@ -1,17 +1,20 @@
package fr.abes.theses_batch_indexation.database;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class DbService {

@Autowired
private JdbcTemplate jdbcTemplate;

public void supprimerTheseATraiter(String id, TableIndexationES tableIndexationES) {
jdbcTemplate.update("DELETE FROM "+ tableIndexationES.name() +" WHERE NNT = ? OR NUMSUJET = ?", id, id);
log.info(id + " est indexé.");
}
public void mettreToutesLesThesesAIndexer(TableIndexationES tableIndexationES) {
jdbcTemplate.update("insert into " + tableIndexationES.name() + " (iddoc, nnt, numsujet) select iddoc, nnt, numsujet from document");
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/fr/abes/theses_batch_indexation/database/TheseDeleteRowMapper.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ public TheseModel mapRow(ResultSet rs, int rowNum) throws SQLException {
OracleResultSet rsOra = (OracleResultSet) rs;

these.setIdDoc(rsOra.getInt("iddoc"));
log.info("dans TheseDeleteRowMapper, l'iddoc est : " + these.getIdDoc());
log.debug("dans TheseDeleteRowMapper, l'iddoc est : " + these.getIdDoc());
these.setNnt(rsOra.getString("nnt"));
these.setIdSujet(rsOra.getString("numsujet"));

Expand Down
2 changes: 1 addition & 1 deletion src/main/java/fr/abes/theses_batch_indexation/database/TheseRowMapper.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ public TheseModel mapRow(ResultSet rs, int rowNum) throws SQLException {
OracleResultSet rsOra = (OracleResultSet) rs;

these.setIdDoc(rsOra.getInt("iddoc"));
log.info("dans TheseRowMapper, l'iddoc est : " + these.getIdDoc());
log.debug("dans TheseRowMapper, l'iddoc est : " + these.getIdDoc());
these.setNnt(rsOra.getString("nnt"));
these.setIdSujet(rsOra.getString("numsujet"));
these.setDoc(XMLType.createXML(rsOra.getOPAQUE("doc")).getStringVal());
Expand Down
36 changes: 18 additions & 18 deletions src/main/java/fr/abes/theses_batch_indexation/dto/personne/PersonneMapee.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing du status
* ***********************************/
log.info("traitement de status");
log.debug("traitement de status");
theseModelES.setStatus(Status.SOUTENUE);
try {
Optional<DmdSec> dmdSecPourStepGestion = mets.getDmdSec().stream().filter(d -> d.getMdWrap().getXmlData().getStepGestion() != null).findFirst();
Expand Down Expand Up @@ -99,7 +99,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des sujets
* ***********************************/
log.info("traitement de sujets");
log.debug("traitement de sujets");
try {
List<Subject> subjects = dmdSec.getMdWrap().getXmlData().getThesisRecord().getSubject();
Iterator<Subject> subjectIterator = subjects.iterator();
Expand All @@ -125,7 +125,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des sujets Rameau
* ***********************************/
log.info("traitement de sujetsRameau");
log.debug("traitement de sujetsRameau");

try {
List<VedetteRameauNomCommun> sujetsRameauNomCommunDepuisTef = dmdSec.getMdWrap().getXmlData()
Expand Down Expand Up @@ -204,7 +204,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing du résumé
* ***********************************/
log.info("traitement de resumes");
log.debug("traitement de resumes");
try {
List<Abstract> abstracts = dmdSec.getMdWrap().getXmlData().getThesisRecord().getAbstract();
Iterator<Abstract> abstractIterator = abstracts.iterator();
Expand All @@ -225,7 +225,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing de la discipline
* ***********************************/
log.info("traitement de discipline");
log.debug("traitement de discipline");
try {
ThesisDegreeDiscipline tddisc = techMD.getMdWrap().getXmlData().getThesisAdmin()
.getThesisDegree().getThesisDegreeDiscipline();
Expand All @@ -239,7 +239,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing de la date de soutenance
* ***********************************/
log.info("traitement de dateSoutenance");
log.debug("traitement de dateSoutenance");
try {
theseModelES.setDate_soutenance(techMD.getMdWrap().getXmlData().getThesisAdmin().getDateAccepted().getValue().toString());
} catch (NullPointerException e) {
Expand All @@ -254,7 +254,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing de la date d'inscription
* ***********************************/
log.info("traitement de datePremiereInscriptionDoctorat");
log.debug("traitement de datePremiereInscriptionDoctorat");
try {
theseModelES.setDate_inscription(techMD.getMdWrap().getXmlData().getThesisAdmin().getThesisDegree().getDatePremiereInscriptionDoctorat().toString());
} catch (NullPointerException e) {
Expand All @@ -267,7 +267,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des etablissements
* ***********************************/
log.info("traitement de etablissements");
log.debug("traitement de etablissements");

try {
List<ThesisDegreeGrantor> grantors = techMD.getMdWrap().getXmlData().getThesisAdmin()
Expand Down Expand Up @@ -297,7 +297,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing de la source
* ***********************************/
log.info("traitement de source");
log.debug("traitement de source");
theseModelES.setSource(Source.SUDOC);
if (theseModelES.getStatus().equals(Status.EN_PREPARATION)) {
theseModelES.setSource(Source.STEP);
Expand All @@ -317,7 +317,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des titres
* ***********************************/
log.info("traitement de titres");
log.debug("traitement de titres");
try {

// Titre principal
Expand Down Expand Up @@ -353,7 +353,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des Domaines
* ***********************************/
log.info("traitement de oaiSets");
log.debug("traitement de oaiSets");
try {
Iterator<String> oaiSetSpecIterator = techMD.getMdWrap().getXmlData().getThesisAdmin()
.getOaiSetSpec().iterator();
Expand All @@ -372,7 +372,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des auteurs de la thèse
* ***********************************/
log.info("traitement des auteurs");
log.debug("traitement des auteurs");
try {
Iterator<Auteur> iter = techMD.getMdWrap().getXmlData().getThesisAdmin()
.getAuteur().iterator();
Expand All @@ -391,7 +391,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des directeurs de la thèse
* ***********************************/
log.info("traitement de directeurs");
log.debug("traitement de directeurs");
try {
Iterator<DirecteurThese> iter = techMD.getMdWrap().getXmlData().getThesisAdmin()
.getDirecteurThese().iterator();
Expand All @@ -415,7 +415,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des auteurs de la thèse
* ***********************************/
log.info("traitement des auteurs");
log.debug("traitement des auteurs");
try {
traiterAuteurs(techMD.getMdWrap().getXmlData().getThesisAdmin()
.getAuteur());
Expand All @@ -429,7 +429,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des directeurs de la thèse
* ***********************************/
log.info("traitement de directeurs");
log.debug("traitement de directeurs");
try {
traiterDirecteurs(techMD.getMdWrap().getXmlData().getThesisAdmin()
.getDirecteurThese());
Expand All @@ -442,7 +442,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des rapporteurs de la thèse
* ***********************************/
log.info("traitement des rapporteurs");
log.debug("traitement des rapporteurs");
try {
traiterRapporteurs(techMD.getMdWrap().getXmlData().getThesisAdmin()
.getRapporteur());
Expand All @@ -457,7 +457,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing du président du jury de la thèse
* ***********************************/
log.info("traitement du président du jury de la thèse");
log.debug("traitement du président du jury de la thèse");
try {
traiterPresident(techMD.getMdWrap().getXmlData().getThesisAdmin()
.getPresidentJury());
Expand All @@ -472,7 +472,7 @@ public PersonneMapee(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des membres du jury de la thèse
* ***********************************/
log.info("traitement des membres du jury de la thèse");
log.debug("traitement des membres du jury de la thèse");
try {
traiterMembreJury(techMD.getMdWrap().getXmlData().getThesisAdmin()
.getMembreJury());
Expand Down
26 changes: 13 additions & 13 deletions src/main/java/fr/abes/theses_batch_indexation/dto/personne/RecherchePersonneMappe.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des sujets
* ***********************************/
log.info("traitement de sujets");
log.debug("traitement de sujets");
try {
List<Subject> subjects = dmdSec.getMdWrap().getXmlData().getThesisRecord().getSubject();
Iterator<Subject> subjectIterator = subjects.iterator();
Expand All @@ -72,7 +72,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des sujets Rameau
* ***********************************/
log.info("traitement de sujetsRameau");
log.debug("traitement de sujetsRameau");

try {
List<VedetteRameauNomCommun> sujetsRameauNomCommunDepuisTef = dmdSec.getMdWrap().getXmlData()
Expand Down Expand Up @@ -151,7 +151,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing du résumé
* ***********************************/
log.info("traitement de resumes");
log.debug("traitement de resumes");
try {
List<Abstract> abstracts = dmdSec.getMdWrap().getXmlData().getThesisRecord().getAbstract();
Iterator<Abstract> abstractIterator = abstracts.iterator();
Expand All @@ -172,7 +172,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing de la discipline
* ***********************************/
log.info("traitement de discipline");
log.debug("traitement de discipline");
try {
ThesisDegreeDiscipline tddisc = techMD.getMdWrap().getXmlData().getThesisAdmin()
.getThesisDegree().getThesisDegreeDiscipline();
Expand All @@ -186,7 +186,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing de la date de soutenance
* ***********************************/
log.info("traitement de dateSoutenance");
log.debug("traitement de dateSoutenance");
try {
theseModelES.setDate_soutenance(techMD.getMdWrap().getXmlData().getThesisAdmin().getDateAccepted().getValue().toString());
} catch (NullPointerException e) {
Expand All @@ -201,7 +201,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing de la date d'inscription
* ***********************************/
log.info("traitement de datePremiereInscriptionDoctorat");
log.debug("traitement de datePremiereInscriptionDoctorat");
try {
theseModelES.setDate_inscription(techMD.getMdWrap().getXmlData().getThesisAdmin().getThesisDegree().getDatePremiereInscriptionDoctorat().toString());
} catch (NullPointerException e) {
Expand All @@ -214,7 +214,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des etablissements
* ***********************************/
log.info("traitement de etablissements");
log.debug("traitement de etablissements");

try {
List<ThesisDegreeGrantor> grantors = techMD.getMdWrap().getXmlData().getThesisAdmin()
Expand Down Expand Up @@ -244,7 +244,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des Domaines
* ***********************************/
log.info("traitement de oaiSets");
log.debug("traitement de oaiSets");
try {
Iterator<String> oaiSetSpecIterator = techMD.getMdWrap().getXmlData().getThesisAdmin()
.getOaiSetSpec().iterator();
Expand All @@ -267,7 +267,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des auteurs de la thèse
* ***********************************/
log.info("traitement des auteurs");
log.debug("traitement des auteurs");
try {
traiterAuteurs(techMD.getMdWrap().getXmlData().getThesisAdmin()
.getAuteur());
Expand All @@ -281,7 +281,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des directeurs de la thèse
* ***********************************/
log.info("traitement de directeurs");
log.debug("traitement de directeurs");
try {
traiterDirecteurs(techMD.getMdWrap().getXmlData().getThesisAdmin()
.getDirecteurThese());
Expand All @@ -294,7 +294,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des rapporteurs de la thèse
* ***********************************/
log.info("traitement des rapporteurs");
log.debug("traitement des rapporteurs");
try {
traiterRapporteurs(techMD.getMdWrap().getXmlData().getThesisAdmin()
.getRapporteur());
Expand All @@ -309,7 +309,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing du président du jury de la thèse
* ***********************************/
log.info("traitement du président du jury de la thèse");
log.debug("traitement du président du jury de la thèse");
try {
traiterPresident(techMD.getMdWrap().getXmlData().getThesisAdmin()
.getPresidentJury());
Expand All @@ -324,7 +324,7 @@ public RecherchePersonneMappe(Mets mets, String id, List<Set> oaiSets) {
/************************************
* Parsing des membres du jury de la thèse
* ***********************************/
log.info("traitement des membres du jury de la thèse");
log.debug("traitement des membres du jury de la thèse");
try {
traiterMembreJury(techMD.getMdWrap().getXmlData().getThesisAdmin()
.getMembreJury());
Expand Down
Loading

0 comments on commit abd0b84

Please sign in to comment.