From d0276cb126166f351589a3a3dcc65f80cc666a86 Mon Sep 17 00:00:00 2001 From: enbraining Date: Mon, 22 Apr 2024 08:25:35 +0900 Subject: [PATCH] =?UTF-8?q?:fire:=20=EB=8F=99=EC=9D=BC=ED=95=9C=20?= =?UTF-8?q?=EA=B8=B0=EB=8A=A5=EC=9D=B4=20=EC=8B=A4=ED=96=89=EB=90=98?= =?UTF-8?q?=EB=8A=94=20=EC=8A=A4=EC=BC=80=EC=A4=84=EC=9D=B4=20=EC=A4=91?= =?UTF-8?q?=EB=B3=B5=EB=90=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/team/gsmgogo/job/DailyJob.java | 40 -------------- .../gsmgogo/scheduler/DailyScheduler.java | 54 ------------------- 2 files changed, 94 deletions(-) delete mode 100644 gsmgogo-batch/src/main/java/team/gsmgogo/job/DailyJob.java delete mode 100644 gsmgogo-batch/src/main/java/team/gsmgogo/scheduler/DailyScheduler.java 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 - ); - } -}