RefPromoteurSequencesUpdateStepConfig.java
- package com.sintia.ffl.admin.audio.services.batch.refpromoteur.load;
- import com.sintia.ffl.admin.staging.FileUtils;
- import com.sintia.ffl.admin.staging.sequences.IntegerSequence;
- import com.sintia.ffl.admin.staging.step.imports.sequences.SequencePromoteurImportStepConfig;
- import com.sintia.ffl.adminui.commons.enums.TypeStaging;
- import com.sintia.ffl.core.commons.enums.CodePromoteur;
- import lombok.extern.slf4j.Slf4j;
- import org.apache.commons.lang3.StringUtils;
- import org.springframework.batch.core.Step;
- import org.springframework.batch.core.configuration.annotation.JobScope;
- import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
- import org.springframework.batch.core.configuration.annotation.StepScope;
- import org.springframework.batch.item.support.AbstractItemStreamItemReader;
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.context.annotation.Bean;
- import org.springframework.context.annotation.Configuration;
- import org.springframework.core.task.AsyncTaskExecutor;
- import javax.sql.DataSource;
- import java.io.IOException;
- import java.util.HashSet;
- import java.util.List;
- import java.util.Set;
- @Slf4j
- @Configuration
- public class RefPromoteurSequencesUpdateStepConfig extends SequencePromoteurImportStepConfig {
- public RefPromoteurSequencesUpdateStepConfig(){
- super(
- TypeStaging.REF_PROMOTEUR
- );
- }
- @Bean
- @JobScope
- public Step refPromoteurSequencesUpdateStep(
- StepBuilderFactory stepBuilderFactory,
- FileUtils fileUtils,
- DataSource dataSource,
- AsyncTaskExecutor asyncExecutor,
- @Value("#{jobParameters['codePromoteur']}") String codePromoteur
- ) throws IOException {
- Set<String> sequencesNames = new HashSet<>(List.of(
- "forfait_audio_identifiant_forfait_audio_seq",
- "marque_audio_promoteur_identifiant_marque_audio_promoteur_seq"
- ));
- // Tables spécifiques SCS
- if(StringUtils.equals(CodePromoteur.SCS.name(), codePromoteur)){
- sequencesNames.addAll(List.of(
- "accessoire_audio_identifianaccessoire_audio_seq",
- "gamme_audio_identifiant_gamme_audio_seq"
- ));
- }
- return super.buildStep(
- stepBuilderFactory,
- fileUtils,
- asyncExecutor,
- dataSource,
- sequencesNames
- );
- }
- @Bean("refPromoteurSequencesUpdateReader")
- @StepScope
- @Override
- public AbstractItemStreamItemReader<IntegerSequence> reader(
- FileUtils fileUtils,
- @Value("#{jobParameters['envSource'] ?: 'pprod'}") String envSource,
- @Value("#{jobParameters['envCible'] ?: 'pprod'}") String envCible,
- @Value("#{jobParameters['codePromoteur']}") String codePromoteur
- ) throws IOException {
- return super.buildReader(fileUtils, envSource, envCible, codePromoteur);
- }
- }