EtatDemandeTiersPayantLoadStepConfig.java

  1. package com.sintia.ffl.admin.audio.services.batch.refcommun.load;

  2. import com.sintia.ffl.admin.audio.dal.entities.EtatDemandeTiersPayant;
  3. import com.sintia.ffl.admin.audio.dal.repositories.EtatDemandeTiersPayantRepository;
  4. import com.sintia.ffl.admin.staging.FileUtils;
  5. import com.sintia.ffl.admin.staging.GenerericItemReadFromFile;
  6. import com.sintia.ffl.admin.staging.StagingStepListener;
  7. import com.sintia.ffl.admin.staging.step.imports.AbstractCommunImportStepConfig;
  8. import com.sintia.ffl.adminui.commons.enums.TypeStaging;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.springframework.batch.core.Step;
  11. import org.springframework.batch.core.configuration.annotation.JobScope;
  12. import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
  13. import org.springframework.batch.core.configuration.annotation.StepScope;
  14. import org.springframework.beans.factory.annotation.Value;
  15. import org.springframework.context.annotation.Bean;
  16. import org.springframework.context.annotation.Configuration;

  17. import java.io.IOException;

  18. @Slf4j
  19. @Configuration
  20. public class EtatDemandeTiersPayantLoadStepConfig extends AbstractCommunImportStepConfig<EtatDemandeTiersPayant, Integer, EtatDemandeTiersPayantRepository> {

  21.     public EtatDemandeTiersPayantLoadStepConfig(){
  22.         super(EtatDemandeTiersPayant.class, TypeStaging.REF_COMMUN);
  23.     }

  24.     @Bean
  25.     @JobScope
  26.     public Step etatDemandeTiersPayantLoadStep(StepBuilderFactory stepBuilderFactory,
  27.                                                EtatDemandeTiersPayantRepository etatDemandeTiersPayantRepository, FileUtils fileUtils,
  28.                                                StagingStepListener<EtatDemandeTiersPayant, Integer> stepListener) throws IOException {
  29.         return super.buildStep(stepBuilderFactory, etatDemandeTiersPayantRepository, fileUtils, stepListener);
  30.     }

  31.     @Bean("etatDemandeTiersPayantItemReader")
  32.     @StepScope
  33.     @Override
  34.     public GenerericItemReadFromFile<EtatDemandeTiersPayant> reader(
  35.             FileUtils fileUtils,
  36.             @Value("#{jobParameters['envSource'] ?: 'pprod'}") String envSource,
  37.             @Value("#{jobParameters['envCible'] ?: 'pprod'}") String envCible
  38.     ) throws IOException {
  39.         return super.buildReader(fileUtils, envSource, envCible);
  40.     }

  41. }