diff --git a/gsmgogo-batch/src/main/java/team/gsmgogo/job/DailyJob.java b/gsmgogo-batch/src/main/java/team/gsmgogo/job/DailyJob.java deleted file mode 100644 index a227e856..00000000 --- a/gsmgogo-batch/src/main/java/team/gsmgogo/job/DailyJob.java +++ /dev/null @@ -1,40 +0,0 @@ -package team.gsmgogo.job; - -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.batch.core.*; -import org.springframework.batch.core.job.builder.JobBuilder; -import org.springframework.batch.core.repository.JobRepository; -import org.springframework.batch.core.step.builder.StepBuilder; -import org.springframework.batch.repeat.RepeatStatus; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; -import org.springframework.transaction.PlatformTransactionManager; -import team.gsmgogo.domain.user.repository.UserQueryDslRepository; - -@Slf4j -@Configuration -@RequiredArgsConstructor -public class DailyJob { - private final JobRepository jobRepository; - private final PlatformTransactionManager platformTransactionManager; - private final UserQueryDslRepository userQueryDslRepository; - - @Bean(name = "resetDailyCountJob") - public Job resetCountJob(){ - return new JobBuilder("reset-daily-count-Job", jobRepository) - .start(resetCountStep(jobRepository, platformTransactionManager)) - .build(); - } - - @Bean - public Step resetCountStep(JobRepository jobRepository, PlatformTransactionManager platformTransactionManager){ - return new StepBuilder("reset-count-step", jobRepository) - .tasklet((contribution, chunkContext) -> { - userQueryDslRepository.bulkResetVerifyCount(); - return RepeatStatus.FINISHED; - }, - platformTransactionManager) - .build(); - } -} diff --git a/gsmgogo-batch/src/main/java/team/gsmgogo/scheduler/DailyScheduler.java b/gsmgogo-batch/src/main/java/team/gsmgogo/scheduler/DailyScheduler.java deleted file mode 100644 index a8009da3..00000000 --- a/gsmgogo-batch/src/main/java/team/gsmgogo/scheduler/DailyScheduler.java +++ /dev/null @@ -1,54 +0,0 @@ -package team.gsmgogo.scheduler; - -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.batch.core.JobParameter; -import org.springframework.batch.core.JobParameters; -import org.springframework.batch.core.JobParametersInvalidException; -import org.springframework.batch.core.launch.JobLauncher; -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.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Component; -import org.springframework.transaction.PlatformTransactionManager; -import team.gsmgogo.domain.user.repository.UserQueryDslRepository; -import team.gsmgogo.job.DailyJob; - -import java.util.HashMap; -import java.util.Map; - -@Slf4j -@Component -@RequiredArgsConstructor -public class DailyScheduler { - private final JobLauncher jobLauncher; - private final JobRepository jobRepository; - private final PlatformTransactionManager platformTransactionManager; - private final UserQueryDslRepository userQueryDslRepository; - -// @Scheduled(cron = "0 5 1 * * *") -// public void resetLoginCount() throws JobInstanceAlreadyCompleteException, JobExecutionAlreadyRunningException, JobParametersInvalidException, JobRestartException { -// Map> confMap = new HashMap<>(); -// confMap.put("time", new JobParameter(System.currentTimeMillis(), String.class)); -// JobParameters jobParameters = new JobParameters(confMap); -// -// jobLauncher.run( -// new DailyJob(jobRepository, platformTransactionManager, userQueryDslRepository).resetCountJob(), -// jobParameters -// ); -// } - - @Scheduled(cron = "0 0 0 * * *") - public void registerAlert() throws JobInstanceAlreadyCompleteException, JobExecutionAlreadyRunningException, JobParametersInvalidException, JobRestartException { - Map> confMap = new HashMap<>(); - confMap.put("time", new JobParameter(System.currentTimeMillis(), String.class)); - JobParameters jobParameters = new JobParameters(confMap); - - jobLauncher.run( - new DailyJob(jobRepository, platformTransactionManager, userQueryDslRepository).resetCountJob(), - jobParameters - ); - } -}