Améliorer le cron de récuperation des matchs

[CNadjim]

• Utiliser une technologie plus stable pour augmenter la lisibilité du code, spring batch

• Utiliser la librairie ModelMapper afin de mapper une DTO vers l'objet en base.

• https://stackoverflow.com/questions/14949985/how-to-get-jobparameter-and-jobexecutioncontext-in-the-itemwriter

[CNadjim]

@Configuration
@EnableScheduling
@EnableBatchProcessing
@EnableMBeanExport
@Slf4j
public class BatchConfig {

    private RestTemplate restTemplate;
    private ModelMapper modelMapper;
    private final TeamRepository teamRepository;

    public BatchConfig(TeamRepository teamRepository){
        this.teamRepository = teamRepository;
        this.modelMapper = new ModelMapper();
        this.restTemplate = new RestTemplate();
        this.restTemplate.getInterceptors().add(new RestTemplateInterceptor());
    }

    //Reader
    @Bean
    public TeamReader teamReader() {
        return new TeamReader("https://api.football-data.org/v2/competitions/2000/teams",this.restTemplate);
    }

    //Processor
    @Bean
    public TeamProcessor teamProcessor() {
        return new TeamProcessor(this.modelMapper);
    }

    //Writer
    @Bean
    public TeamWriter teamWriter() {
        return new TeamWriter(this.teamRepository);
    }


    @Bean(name = "teamStep")
    public Step buildTeamStep(StepBuilderFactory stepBuilderFactory,
                              TeamReader teamReader,
                              TeamProcessor teamProcessor,
                              TeamWriter teamWriter) {

        TaskletStep step = stepBuilderFactory.get("build-team-step")
                .allowStartIfComplete(true)
                .<TeamDto, Team>chunk(1)
                .faultTolerant()
                .reader(teamReader)
                .processor(teamProcessor)
                .writer(teamWriter)
                .build();

        DefaultTransactionAttribute transactionAttribute = new DefaultTransactionAttribute();
        transactionAttribute.setTimeout(60);

        step.setTransactionAttribute(transactionAttribute);

        return step;
    }

    @Bean(name = "teamJob")
    public Job payoffJob(@Qualifier("teamStep") Step teamStep, JobBuilderFactory jobBuilderFactory) throws Exception {
        return jobBuilderFactory.get("build-team-job")
                .incrementer(new RunIdIncrementer())
                .flow(teamStep)
                .end()
                .build();
    }
}

[CNadjim]

public class TeamReader implements ItemReader<TeamDto> {

    private String apiUrl;
    private RestTemplate restTemplate;

    private int nextTeamIndex;
    private List<TeamDto> teamData;

    public TeamReader(String apiUrl, RestTemplate restTemplate) {
        this.apiUrl = apiUrl;
        this.restTemplate = restTemplate;
        this.nextTeamIndex = 0;
    }

    @Override
    public TeamDto read() throws Exception {
        if (teamDataIsNotInitialized()) {
            teamData = fetchTeamDataFromAPI();
        }

        TeamDto nextTeam = null;

        if (nextTeamIndex < teamData.size()) {
            nextTeam = teamData.get(nextTeamIndex);
            nextTeamIndex++;
        }

        return nextTeam;
    }

    private boolean teamDataIsNotInitialized() {
        return this.teamData == null;
    }

    private List<TeamDto> fetchTeamDataFromAPI() {
        return restTemplate.getForObject(apiUrl, TeamsDto.class).getTeams();
    }
}

[CNadjim]

public class TeamProcessor implements ItemProcessor<TeamDto,Team> {
    private ModelMapper modelMapper;

    public TeamProcessor(ModelMapper modelMapper){
        this.modelMapper = modelMapper;
    }
    @Override
    public Team process(TeamDto teamDto) throws Exception {
        Team team = modelMapper.map(teamDto,Team.class);
        team.setId(null);
        return team;
    }
}

[CNadjim]

public class TeamWriter implements ItemWriter<Team> {
    private TeamRepository teamRepository;

    public TeamWriter(TeamRepository teamRepository) {
        this.teamRepository = teamRepository;
    }

    @Override
    public void write(List<? extends Team> teams) throws Exception {
        teamRepository.save(teams);
    }
}