Skip to content

Commit

Permalink
- Construction de l'étape 2 de lecture de la ligne du fichier
Browse files Browse the repository at this point in the history
  • Loading branch information
jvk88511334 committed Aug 14, 2024
1 parent 5f3fcbd commit 1841b55
Show file tree
Hide file tree
Showing 6 changed files with 119 additions and 8 deletions.
6 changes: 4 additions & 2 deletions batch/src/main/java/fr/abes/item/batch/JobConfiguration.java
Original file line number Diff line number Diff line change
Expand Up @@ -329,11 +329,13 @@ public Job jobTraiterLigneFichierExemp(JobRepository jobRepository, @Qualifier("

//job de lancement d'un traitement de suppression
@Bean
public Job jobTraiterLignerFichierSuppr(JobRepository jobRepository, @Qualifier("stepRecupererNextDemandeSuppr") Step step1) {
public Job jobTraiterLignerFichierSuppr(JobRepository jobRepository, @Qualifier("stepRecupererNextDemandeSuppr") Step step1, @Qualifier("stepLireLigneFichier") Step step2) {
return new JobBuilder("traiterLigneFichierSuppr", jobRepository).incrementer(incrementer())
.start(step1).on(Constant.FAILED).end()
.from(step1).on(Constant.AUCUNE_DEMANDE).end()
.from(step1).on(Constant.COMPLETED).end()
.from(step1).on(Constant.COMPLETED).to(step2)
.from(step2).on(Constant.FAILED).end()
.from(step2).on(Constant.COMPLETED).end()
.build().build();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,7 @@

import fr.abes.item.batch.LogTime;
import fr.abes.item.batch.mail.IMailer;
import fr.abes.item.batch.traitement.model.LigneFichierDto;
import fr.abes.item.batch.traitement.model.LigneFichierDtoExemp;
import fr.abes.item.batch.traitement.model.LigneFichierDtoModif;
import fr.abes.item.batch.traitement.model.LigneFichierDtoRecouv;
import fr.abes.item.batch.traitement.model.*;
import fr.abes.item.core.configuration.factory.StrategyFactory;
import fr.abes.item.core.constant.Constant;
import fr.abes.item.core.constant.TYPE_DEMANDE;
Expand Down Expand Up @@ -85,7 +82,7 @@ public RepeatStatus execute(@NonNull StepContribution stepContribution, @NonNull
this.lignesFichier.add(new LigneFichierDtoRecouv((LigneFichierRecouv) localLigne));
break;
case SUPP:
//TODO this.lignesFichier.add(new LigneFichierDtoSuppr((LigneFichierSupp) localLigne));
this.lignesFichier.add(new LigneFichierDtoSuppr((LigneFichierSupp) localLigne));
default:
}
}
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,45 @@
package fr.abes.item.batch.traitement.model;

import fr.abes.item.core.constant.TYPE_DEMANDE;
import fr.abes.item.core.entities.item.Demande;
import fr.abes.item.core.entities.item.LigneFichierSupp;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;

@NoArgsConstructor
public class LigneFichierDtoSuppr extends LigneFichierDto implements ILigneFichierDtoService {
@Getter @Setter
private String requete;
@Getter @Setter
private String ppn;
@Getter @Setter
private String rcr;
@Getter @Setter
private String epn;

public LigneFichierDtoSuppr(LigneFichierSupp ligneFichierSupp){
super(ligneFichierSupp.getNumLigneFichier(), ligneFichierSupp.getTraitee(), ligneFichierSupp.getPosition(), ligneFichierSupp.getId(), ligneFichierSupp.getRetourSudoc(), ligneFichierSupp.getValeurZone());
this.epn = ligneFichierSupp.getEpn();
this.ppn = ligneFichierSupp.getPpn();
this.rcr = ligneFichierSupp.getRcr();
}

public LigneFichierDtoSuppr(Integer numLigneFichier, Integer traitee, Integer position, Integer refDemande, String retourSudoc, String valeurZone, String requete, String ppn, String rcr, String epn) {
super(numLigneFichier, traitee, position, refDemande, retourSudoc, valeurZone);
this.requete = requete;
this.ppn = ppn;
this.rcr = rcr;
this.epn = epn;
}

@Override
public String getValeurToWriteInFichierResultat(Demande demande, Integer nbPpnInFileResult) {
return null;
}

@Override
public TYPE_DEMANDE getTypeDemande() {
return null;
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
package fr.abes.item.batch.traitement.model;

import fr.abes.item.core.configuration.factory.Strategy;
import fr.abes.item.core.constant.TYPE_DEMANDE;
import fr.abes.item.core.entities.item.DemandeSupp;
import fr.abes.item.core.entities.item.LigneFichier;
import fr.abes.item.core.entities.item.LigneFichierSupp;

@Strategy(type = ILigneFichierDtoMapper.class, typeDemande = TYPE_DEMANDE.EXEMP)
public class LigneFichierDtoSupprMapper implements ILigneFichierDtoMapper {
@Override
public LigneFichierSupp getLigneFichierEntity(LigneFichierDto lfd)
//TODO ajuster le mapper en fonction de ce que renvoie le sudoc
{
LigneFichierDtoSuppr lfdSuppr = (LigneFichierDtoSuppr) lfd;
LigneFichierSupp lf = new LigneFichierSupp();
lf.setPpn(lfdSuppr.getPpn());
lf.setRcr(lfdSuppr.getRcr());
lf.setEpn(lfdSuppr.getEpn());
lf.setDemandeSupp(new DemandeSupp(lfdSuppr.getRefDemande()));
lf.setTraitee(lfdSuppr.getTraitee());
return lf;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,9 @@ public class DemandeSupp extends Demande {
public TYPE_DEMANDE getTypeDemande() {
return TYPE_DEMANDE.SUPP;
}

public DemandeSupp(Integer numDemande) {
super(numDemande);
}
public DemandeSupp(String rcr, Date dateCreation, Date dateModification, TYPE_SUPPRESSION typeSuppression,
String comment, EtatDemande etatDemande, Utilisateur utilisateur) {
super(rcr, dateCreation, dateModification, etatDemande, comment, utilisateur);
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,41 @@
package fr.abes.item.core.entities.item;

import jakarta.persistence.*;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;

import javax.validation.constraints.NotNull;
import java.io.Serializable;

@Entity
@Getter @Setter
@NoArgsConstructor
@Table(name="LIGNE_FICHIER_SUPP")
public class LigneFichierSupp extends LigneFichier implements Serializable, ILigneFichier {
@Column(name = "PPN")
private String ppn;

@Column(name = "RCR")
private String rcr;

@Column(name = "EPN")
private String epn;

@Column(name = "NB_REPONSE")
private Integer nbReponse;

@ManyToOne
@JoinColumn(name = "REF_DEMANDE") @NotNull
private DemandeSupp demandeSupp;


@Override
public void setEntityAfterBatch(LigneFichier ligneFichier) {
//TODO revoir
LigneFichierSupp ligneFichierSupp = (LigneFichierSupp)ligneFichier;
this.setRetourSudoc(ligneFichierSupp.getRetourSudoc());
this.setNbReponse(ligneFichierSupp.getNbReponse());
this.setTraitee(1);
}
}

0 comments on commit 1841b55

Please sign in to comment.