PurgeVerresService.java

package com.sintia.ffl.admin.optique.catalogue.batch.batchservice;

import com.sintia.ffl.admin.optique.catalogue.models.LaunchStateDTO;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.core.BatchStatus;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.JobParametersInvalidException;
import org.springframework.batch.core.launch.support.SimpleJobLauncher;
import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;
import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.repository.JobRestartException;
import org.springframework.core.task.SyncTaskExecutor;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;

import java.util.Date;

@Service
@RequiredArgsConstructor
@Slf4j
public class PurgeVerresService {

	private final JobRepository jobRepository;
	
	private final Job purgeVerresJob;

	private final TaskExecutor asyncExecutor;
	
	private final LaunchStateDTO launchState = new LaunchStateDTO();
	
	private static final Logger LOGGER = LoggerFactory.getLogger(PurgeVerresService.class);
	
	public BatchStatus handlePurgeGlasses() {
		LOGGER.info("Launching glasses purge job manually");
		SimpleJobLauncher simpleJobLauncher = new SimpleJobLauncher();
		simpleJobLauncher.setTaskExecutor(asyncExecutor);
		simpleJobLauncher.setJobRepository(jobRepository);
		
		Date scriptRunningDate = new Date();
		JobParameters jobParameters = new JobParametersBuilder().addLong("time", System.currentTimeMillis()).addDate("scriptDate", scriptRunningDate).toJobParameters();
		
		try {
			JobExecution status = simpleJobLauncher.run(purgeVerresJob, jobParameters); return status.getStatus();
		} catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException |
				JobParametersInvalidException e) {
			LOGGER.error("Error executing job 'purgeVerresJob'", e); return BatchStatus.FAILED;
		} finally {
			launchState.unlock();
			LOGGER.info("Batch started");
		}
	}
}