SystExploitAppAudioAssoLoadStepConfig.java

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

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

  18. import java.io.IOException;

  19. @Slf4j
  20. @Configuration
  21. public class SystExploitAppAudioAssoLoadStepConfig extends AbstractCommunImportStepConfig<SystExploitAppAudioAsso, SystExplAppAudioId, SystExploitAppAudioAssoRepository> {

  22.     public SystExploitAppAudioAssoLoadStepConfig(){
  23.         super(
  24.                 SystExploitAppAudioAsso.class,
  25.                 TypeStaging.REF_CATALOGUE
  26.         );
  27.     }

  28.     @Bean
  29.     @JobScope
  30.     public Step systExploitAppAudioAssoLoadStep(StepBuilderFactory stepBuilderFactory,
  31.                                                 SystExploitAppAudioAssoRepository systExploitAppAudioAssoRepository, FileUtils fileUtils,
  32.                                                 StagingStepListener<SystExploitAppAudioAsso, SystExplAppAudioId> stepListener) throws IOException {
  33.         return super.buildStep(stepBuilderFactory, systExploitAppAudioAssoRepository, fileUtils, stepListener);
  34.     }

  35.     @Bean("systExploitAppAudioAssoItemReader")
  36.     @StepScope
  37.     @Override
  38.     public GenerericItemReadFromFile<SystExploitAppAudioAsso> reader(
  39.             FileUtils fileUtils,
  40.             @Value("#{jobParameters['envSource'] ?: 'pprod'}") String envSource,
  41.             @Value("#{jobParameters['envCible'] ?: 'pprod'}") String envCible
  42.     ) throws IOException {
  43.         return super.buildReader(fileUtils, envSource, envCible);
  44.     }

  45. }