- * description : 전자 고지 CCTV accept - * - * packageName : kr.xit.ens.support.batch.job - * fileName : EnsCctvAcceptJobConfg - * author : seojh - * date : 2023-07-17 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-17 seojh 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Configuration -public class EnsCctvAcceptJobConfg { - private static final String JOB_NAME = "EnsCctvAcceptJob"; - - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobBuilderFactory jobBuilderFactory; - private final StepBuilderFactory stepBuilderFactory; - - private final IBatchCmmService lockService; - private final IEnsCctvFileService service; - - @Bean(name = JOB_NAME) - public Job ensCctvAcceptJob() { - return jobBuilderFactory.get(JOB_NAME) - .incrementer(new CustomRunIdIncrementer()) - .listener(new CustomJobListener()) - .listener(new CustomStepListener()) - .listener(new NoWorkFoundStepListener()) - - // JOB 시작 - // start() 결과가 FAILED 인경우 종료 - .start(start()) - .on("FAILED") - .end() - - // start()의 결과로 부터 FAILED를 제외한 모든 경우 to() 실행 - //.from(start()) - .on("*") - .to(execution()) - .on("FAILED") - .to(fail()) - - .from(execution()) - // to() 실행 결과와 상관 없이 end() 실행 - .on("*") - .to(end()) - - // JOB 종료 - .end() - - .build(); - } - - @Bean(name = JOB_NAME + "_step") - public Step execution() { - return stepBuilderFactory.get(JOB_NAME + "_step") - .tasklet(new EnsCctvAcceptTasklet(service)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_start_step") - protected Step start() { - return stepBuilderFactory.get("Job_Locking") - .tasklet(new BatchStartTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_end_step") - protected Step end() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchEndTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_fail_step") - protected Step fail() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchFailEndTasklet(lockService)) - .build(); - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/job/EnsCctvFileJobConfg.java b/mens-api/src/main/java/kr/xit/ens/support/batch/job/EnsCctvFileJobConfg.java deleted file mode 100644 index eb0e0f3..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/job/EnsCctvFileJobConfg.java +++ /dev/null @@ -1,113 +0,0 @@ -package kr.xit.ens.support.batch.job; - -import kr.xit.biz.ens.service.IEnsCctvFileService; -import kr.xit.core.biz.batch.CustomRunIdIncrementer; -import kr.xit.core.biz.batch.listener.CustomJobListener; -import kr.xit.core.biz.batch.listener.CustomStepListener; -import kr.xit.core.biz.batch.listener.NoWorkFoundStepListener; -import kr.xit.core.biz.batch.service.IBatchCmmService; -import kr.xit.core.biz.batch.task.BatchEndTasklet; -import kr.xit.core.biz.batch.task.BatchFailEndTasklet; -import kr.xit.core.biz.batch.task.BatchStartTasklet; -import kr.xit.ens.support.batch.task.EnsCctvFileTasklet; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.batch.core.Job; -import org.springframework.batch.core.Step; -import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -/** - *
- * description : 전자 고지 CCTV 파일 처리(서광) - * - * packageName : kr.xit.ens.support.batch.job - * fileName : EnsCctvFileJobConfg - * author : seojh - * date : 2023-07-17 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-17 seojh 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Configuration -public class EnsCctvFileJobConfg { - private static final String JOB_NAME = "EnsCctvFileJob"; - - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobBuilderFactory jobBuilderFactory; - private final StepBuilderFactory stepBuilderFactory; - - private final IBatchCmmService lockService; - private final IEnsCctvFileService service; - - @Bean(name = JOB_NAME) - public Job ensCctvFileJob() { - return jobBuilderFactory.get(JOB_NAME) - .incrementer(new CustomRunIdIncrementer()) - .listener(new CustomJobListener()) - .listener(new CustomStepListener()) - .listener(new NoWorkFoundStepListener()) - - // JOB 시작 - // start() 결과가 FAILED 인경우 종료 - .start(start()) - .on("FAILED") - .end() - - // start()의 결과로 부터 FAILED를 제외한 모든 경우 to() 실행 - //.from(start()) - .on("*") - .to(execution()) - .on("FAILED") - .to(fail()) - - .from(execution()) - // to() 실행 결과와 상관 없이 end() 실행 - .on("*") - .to(end()) - - // JOB 종료 - .end() - - .build(); - } - - @Bean(name = JOB_NAME + "_step") - public Step execution() { - return stepBuilderFactory.get(JOB_NAME + "_step") - .tasklet(new EnsCctvFileTasklet(service)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_start_step") - protected Step start() { - return stepBuilderFactory.get("Job_Locking") - .tasklet(new BatchStartTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_end_step") - protected Step end() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchEndTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_fail_step") - protected Step fail() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchFailEndTasklet(lockService)) - .build(); - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/job/PniCctvAcceptJobConfg.java b/mens-api/src/main/java/kr/xit/ens/support/batch/job/PniCctvAcceptJobConfg.java deleted file mode 100644 index b02fdf6..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/job/PniCctvAcceptJobConfg.java +++ /dev/null @@ -1,114 +0,0 @@ -package kr.xit.ens.support.batch.job; - -import kr.xit.biz.pni.service.IPniCctvFileService; -import kr.xit.core.biz.batch.CustomRunIdIncrementer; -import kr.xit.core.biz.batch.listener.CustomJobListener; -import kr.xit.core.biz.batch.listener.CustomStepListener; -import kr.xit.core.biz.batch.listener.NoWorkFoundStepListener; -import kr.xit.core.biz.batch.service.IBatchCmmService; -import kr.xit.core.biz.batch.task.BatchEndTasklet; -import kr.xit.core.biz.batch.task.BatchFailEndTasklet; -import kr.xit.core.biz.batch.task.BatchStartTasklet; -import kr.xit.ens.support.batch.task.PniCctvAcceptTasklet; -import kr.xit.ens.support.batch.task.PniCctvFileTasklet; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.batch.core.Job; -import org.springframework.batch.core.Step; -import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -/** - *
- * description : 사전고지 CCTV accept - * - * packageName : kr.xit.ens.support.batch.job - * fileName : PniCctvAcceptJobConfg - * author : limju - * date : 2023-07-11 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-11 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Configuration -public class PniCctvAcceptJobConfg { - private static final String JOB_NAME = "PniCctvAcceptJob"; - - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobBuilderFactory jobBuilderFactory; - private final StepBuilderFactory stepBuilderFactory; - - private final IBatchCmmService lockService; - private final IPniCctvFileService service; - - @Bean(name = JOB_NAME) - public Job pniCctvAcceptJob() { - return jobBuilderFactory.get(JOB_NAME) - .incrementer(new CustomRunIdIncrementer()) - .listener(new CustomJobListener()) - .listener(new CustomStepListener()) - .listener(new NoWorkFoundStepListener()) - - // JOB 시작 - // start() 결과가 FAILED 인경우 종료 - .start(start()) - .on("FAILED") - .end() - - // start()의 결과로 부터 FAILED를 제외한 모든 경우 to() 실행 - //.from(start()) - .on("*") - .to(execution()) - .on("FAILED") - .to(fail()) - - .from(execution()) - // to() 실행 결과와 상관 없이 end() 실행 - .on("*") - .to(end()) - - // JOB 종료 - .end() - - .build(); - } - - @Bean(name = JOB_NAME + "_step") - public Step execution() { - return stepBuilderFactory.get(JOB_NAME + "_step") - .tasklet(new PniCctvAcceptTasklet(service)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_start_step") - protected Step start() { - return stepBuilderFactory.get("Job_Locking") - .tasklet(new BatchStartTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_end_step") - protected Step end() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchEndTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_fail_step") - protected Step fail() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchFailEndTasklet(lockService)) - .build(); - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/job/PniCctvFileJobConfg.java b/mens-api/src/main/java/kr/xit/ens/support/batch/job/PniCctvFileJobConfg.java deleted file mode 100644 index 4193ea4..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/job/PniCctvFileJobConfg.java +++ /dev/null @@ -1,113 +0,0 @@ -package kr.xit.ens.support.batch.job; - -import kr.xit.biz.pni.service.IPniCctvFileService; -import kr.xit.core.biz.batch.CustomRunIdIncrementer; -import kr.xit.core.biz.batch.listener.CustomJobListener; -import kr.xit.core.biz.batch.listener.CustomStepListener; -import kr.xit.core.biz.batch.listener.NoWorkFoundStepListener; -import kr.xit.core.biz.batch.service.IBatchCmmService; -import kr.xit.core.biz.batch.task.BatchEndTasklet; -import kr.xit.core.biz.batch.task.BatchFailEndTasklet; -import kr.xit.core.biz.batch.task.BatchStartTasklet; -import kr.xit.ens.support.batch.task.PniCctvFileTasklet; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.batch.core.Job; -import org.springframework.batch.core.Step; -import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -/** - *
- * description : 사전고지 CCTV 파일 처리(서광) - * - * packageName : kr.xit.ens.support.batch.job - * fileName : PniCctvFileJobConfg - * author : limju - * date : 2023-07-10 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-10 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Configuration -public class PniCctvFileJobConfg { - private static final String JOB_NAME = "PniCctvFileJob"; - - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobBuilderFactory jobBuilderFactory; - private final StepBuilderFactory stepBuilderFactory; - - private final IBatchCmmService lockService; - private final IPniCctvFileService service; - - @Bean(name = JOB_NAME) - public Job pniCctvFileJob() { - return jobBuilderFactory.get(JOB_NAME) - .incrementer(new CustomRunIdIncrementer()) - .listener(new CustomJobListener()) - .listener(new CustomStepListener()) - .listener(new NoWorkFoundStepListener()) - - // JOB 시작 - // start() 결과가 FAILED 인경우 종료 - .start(start()) - .on("FAILED") - .end() - - // start()의 결과로 부터 FAILED를 제외한 모든 경우 to() 실행 - //.from(start()) - .on("*") - .to(execution()) - .on("FAILED") - .to(fail()) - - .from(execution()) - // to() 실행 결과와 상관 없이 end() 실행 - .on("*") - .to(end()) - - // JOB 종료 - .end() - - .build(); - } - - @Bean(name = JOB_NAME + "_step") - public Step execution() { - return stepBuilderFactory.get(JOB_NAME + "_step") - .tasklet(new PniCctvFileTasklet(service)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_start_step") - protected Step start() { - return stepBuilderFactory.get("Job_Locking") - .tasklet(new BatchStartTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_end_step") - protected Step end() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchEndTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_fail_step") - protected Step fail() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchFailEndTasklet(lockService)) - .build(); - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngAcceptJobConfig.java b/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngAcceptJobConfig.java deleted file mode 100644 index acc4749..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngAcceptJobConfig.java +++ /dev/null @@ -1,113 +0,0 @@ -package kr.xit.ens.support.batch.job; - -import org.springframework.batch.core.Job; -import org.springframework.batch.core.Step; -import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -import kr.xit.biz.ens.service.ISendMessageLinkService; -import kr.xit.core.biz.batch.CustomRunIdIncrementer; -import kr.xit.core.biz.batch.listener.CustomJobListener; -import kr.xit.core.biz.batch.listener.CustomStepListener; -import kr.xit.core.biz.batch.service.IBatchCmmService; -import kr.xit.core.biz.batch.task.BatchEndTasklet; -import kr.xit.core.biz.batch.task.BatchFailEndTasklet; -import kr.xit.core.biz.batch.task.BatchStartTasklet; -import kr.xit.ens.support.batch.task.SndngAcceptTasklet; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; - -/** - *
- * description : 문자 발송 시스템 연계 - 접수 - * - * packageName : kr.xit.ens.support.batch.job - * fileName : SndngAcceptJobConfig - * author : limju - * date : 2023-06-12 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-12 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Configuration -public class SndngAcceptJobConfig { - private static final String JOB_NAME = "SndngAcceptJob"; - - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobBuilderFactory jobBuilderFactory; - private final StepBuilderFactory stepBuilderFactory; - - private final IBatchCmmService lockService; - private final ISendMessageLinkService linkService; - - @Bean(name = JOB_NAME) - public Job sndngAcceptJob() { - return jobBuilderFactory.get(JOB_NAME) - .incrementer(new CustomRunIdIncrementer()) - .listener(new CustomJobListener()) - .listener(new CustomStepListener()) - //.listener(new NoWorkFoundStepListener()) - - // JOB 시작 - // start() 결과가 FAILED 인경우 종료 - .start(start()) - .on("FAILED") - .end() - - // start()의 결과로 부터 FAILED를 제외한 모든 경우 to() 실행 - //.from(start()) - .on("*") - .to(execution()) - .on("FAILED") - .to(fail()) - - .from(execution()) - // to() 실행 결과와 상관 없이 end() 실행 - .on("*") - .to(end()) - - // JOB 종료 - .end() - - .build(); - } - - @Bean(name = JOB_NAME + "_step") - public Step execution() { - return stepBuilderFactory.get(JOB_NAME + "_step") - .tasklet(new SndngAcceptTasklet(linkService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_start_step") - protected Step start() { - return stepBuilderFactory.get("Job_Locking") - .tasklet(new BatchStartTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_end_step") - protected Step end() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchEndTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_fail_step") - protected Step fail() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchFailEndTasklet(lockService)) - .build(); - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngCloseJobConfig.java b/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngCloseJobConfig.java deleted file mode 100644 index 26f4ca9..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngCloseJobConfig.java +++ /dev/null @@ -1,114 +0,0 @@ -package kr.xit.ens.support.batch.job; - -import kr.xit.biz.ens.service.ISendMessageLinkService; -import kr.xit.core.biz.batch.CustomRunIdIncrementer; -import kr.xit.core.biz.batch.listener.CustomJobListener; -import kr.xit.core.biz.batch.listener.CustomStepListener; -import kr.xit.core.biz.batch.listener.NoWorkFoundStepListener; -import kr.xit.core.biz.batch.service.IBatchCmmService; -import kr.xit.core.biz.batch.task.BatchEndTasklet; -import kr.xit.core.biz.batch.task.BatchFailEndTasklet; -import kr.xit.core.biz.batch.task.BatchStartTasklet; -import kr.xit.ens.support.batch.task.SndngCloseTasklet; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.batch.core.Job; -import org.springframework.batch.core.Step; -import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; -import org.springframework.context.annotation.Lazy; - -/** - *
- * description : - * - * packageName : kr.xit.ens.support.batch.job - * fileName : SndngCloseJobConfig - * author : seojh - * date : 2023-06-14 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-14 seojh 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Configuration -public class SndngCloseJobConfig { - private static final String JOB_NAME = "SndngCloseJob"; - - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobBuilderFactory jobBuilderFactory; - private final StepBuilderFactory stepBuilderFactory; - - private final IBatchCmmService lockService; - private final ISendMessageLinkService linkService; - - @Bean(name = JOB_NAME) - public Job sndngCloseJob() { - return jobBuilderFactory.get(JOB_NAME) - .incrementer(new CustomRunIdIncrementer()) - .listener(new CustomJobListener()) - .listener(new CustomStepListener()) - .listener(new NoWorkFoundStepListener()) - - // JOB 시작 - // start() 결과가 FAILED 인경우 종료 - .start(start()) - .on("FAILED") - .end() - - // start()의 결과로 부터 FAILED를 제외한 모든 경우 to() 실행 - //.from(start()) - .on("*") - .to(execution()) - .on("FAILED") - .to(fail()) - - .from(execution()) - // to() 실행 결과와 상관 없이 end() 실행 - .on("*") - .to(end()) - - // JOB 종료 - .end() - - .build(); - } - - @Bean(name = JOB_NAME + "_step") - public Step execution() { - return stepBuilderFactory.get(JOB_NAME + "_step") - .tasklet(new SndngCloseTasklet(linkService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_start_step") - protected Step start() { - return stepBuilderFactory.get("Job_Locking") - .tasklet(new BatchStartTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_end_step") - protected Step end() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchEndTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_fail_step") - protected Step fail() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchFailEndTasklet(lockService)) - .build(); - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngMakeJobConfig.java b/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngMakeJobConfig.java deleted file mode 100644 index ce6ea33..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngMakeJobConfig.java +++ /dev/null @@ -1,114 +0,0 @@ -package kr.xit.ens.support.batch.job; - -import org.springframework.batch.core.Job; -import org.springframework.batch.core.Step; -import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -import kr.xit.biz.ens.service.ISendMessageLinkService; -import kr.xit.core.biz.batch.CustomRunIdIncrementer; -import kr.xit.core.biz.batch.listener.CustomJobListener; -import kr.xit.core.biz.batch.listener.CustomStepListener; -import kr.xit.core.biz.batch.listener.NoWorkFoundStepListener; -import kr.xit.core.biz.batch.service.IBatchCmmService; -import kr.xit.core.biz.batch.task.BatchEndTasklet; -import kr.xit.core.biz.batch.task.BatchFailEndTasklet; -import kr.xit.core.biz.batch.task.BatchStartTasklet; -import kr.xit.ens.support.batch.task.SndngMakeTasklet; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; - -/** - *
- * description : 문자 발송 시스템 연계 - 전송 대상 생성 - * - * packageName : kr.xit.ens.support.batch.job - * fileName : SndngMakeJobConfig - * author : limju - * date : 2023-06-12 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-12 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Configuration -public class SndngMakeJobConfig { - private static final String JOB_NAME = "SndngMakeJob"; - - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobBuilderFactory jobBuilderFactory; - private final StepBuilderFactory stepBuilderFactory; - - private final IBatchCmmService lockService; - private final ISendMessageLinkService linkService; - - @Bean(name = JOB_NAME) - public Job sndngMakeJob() { - return jobBuilderFactory.get(JOB_NAME) - .incrementer(new CustomRunIdIncrementer()) - .listener(new CustomJobListener()) - .listener(new CustomStepListener()) - .listener(new NoWorkFoundStepListener()) - - // JOB 시작 - // start() 결과가 FAILED 인경우 종료 - .start(start()) - .on("FAILED") - .end() - - // start()의 결과로 부터 FAILED를 제외한 모든 경우 to() 실행 - .from(start()) - .on("*") - .to(execution()) - .on("FAILED") - .to(fail()) - - .from(execution()) - // to() 실행 결과와 상관 없이 end() 실행 - .on("*") - .to(end()) - - // JOB 종료 - .end() - - .build(); - } - - @Bean(name = JOB_NAME + "_step") - public Step execution() { - return stepBuilderFactory.get(JOB_NAME + "_step") - .tasklet(new SndngMakeTasklet(linkService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_start_step") - protected Step start() { - return stepBuilderFactory.get("Job_Locking") - .tasklet(new BatchStartTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_end_step") - protected Step end() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchEndTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_fail_step") - protected Step fail() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchFailEndTasklet(lockService)) - .build(); - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngSnedBulksJobConfig.java b/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngSnedBulksJobConfig.java deleted file mode 100644 index 82cb9ea..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngSnedBulksJobConfig.java +++ /dev/null @@ -1,114 +0,0 @@ -package kr.xit.ens.support.batch.job; - -import org.springframework.batch.core.Job; -import org.springframework.batch.core.Step; -import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -import kr.xit.biz.ens.service.ISendMessageLinkService; -import kr.xit.core.biz.batch.CustomRunIdIncrementer; -import kr.xit.core.biz.batch.listener.CustomJobListener; -import kr.xit.core.biz.batch.listener.CustomStepListener; -import kr.xit.core.biz.batch.listener.NoWorkFoundStepListener; -import kr.xit.core.biz.batch.service.IBatchCmmService; -import kr.xit.core.biz.batch.task.BatchEndTasklet; -import kr.xit.core.biz.batch.task.BatchFailEndTasklet; -import kr.xit.core.biz.batch.task.BatchStartTasklet; -import kr.xit.ens.support.batch.task.SndngSendBulksTasklet; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; - -/** - *
- * description : 문자 발송 시스템 연계 - 전송 - * - * packageName : kr.xit.ens.support.batch.job - * fileName : SndngSnedBulksJobConfig - * author : limju - * date : 2023-06-12 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-12 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Configuration -public class SndngSnedBulksJobConfig { - private static final String JOB_NAME = "SndngSendBulksJob"; - - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobBuilderFactory jobBuilderFactory; - private final StepBuilderFactory stepBuilderFactory; - - private final IBatchCmmService lockService; - private final ISendMessageLinkService linkService; - - @Bean(name = JOB_NAME) - public Job sndngSendBulksJob() { - return jobBuilderFactory.get(JOB_NAME) - .incrementer(new CustomRunIdIncrementer()) - .listener(new CustomJobListener()) - .listener(new CustomStepListener()) - .listener(new NoWorkFoundStepListener()) - - // JOB 시작 - // start() 결과가 FAILED 인경우 종료 - .start(start()) - .on("FAILED") - .end() - - // start()의 결과로 부터 FAILED를 제외한 모든 경우 to() 실행 - //.from(start()) - .on("*") - .to(execution()) - .on("FAILED") - .to(fail()) - - .from(execution()) - // to() 실행 결과와 상관 없이 end() 실행 - .on("*") - .to(end()) - - // JOB 종료 - .end() - - .build(); - } - - @Bean(name = JOB_NAME + "_step") - public Step execution() { - return stepBuilderFactory.get(JOB_NAME + "_step") - .tasklet(new SndngSendBulksTasklet(linkService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_start_step") - protected Step start() { - return stepBuilderFactory.get("Job_Locking") - .tasklet(new BatchStartTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_end_step") - protected Step end() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchEndTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_fail_step") - protected Step fail() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchFailEndTasklet(lockService)) - .build(); - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngStatusBulksJobConfig.java b/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngStatusBulksJobConfig.java deleted file mode 100644 index 7dbff1c..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/job/SndngStatusBulksJobConfig.java +++ /dev/null @@ -1,114 +0,0 @@ -package kr.xit.ens.support.batch.job; - -import org.springframework.batch.core.Job; -import org.springframework.batch.core.Step; -import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -import kr.xit.biz.ens.service.ISendMessageLinkService; -import kr.xit.core.biz.batch.CustomRunIdIncrementer; -import kr.xit.core.biz.batch.listener.CustomJobListener; -import kr.xit.core.biz.batch.listener.CustomStepListener; -import kr.xit.core.biz.batch.listener.NoWorkFoundStepListener; -import kr.xit.core.biz.batch.service.IBatchCmmService; -import kr.xit.core.biz.batch.task.BatchEndTasklet; -import kr.xit.core.biz.batch.task.BatchFailEndTasklet; -import kr.xit.core.biz.batch.task.BatchStartTasklet; -import kr.xit.ens.support.batch.task.SndngStatusBulksTasklet; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; - -/** - *
- * description : 문자 발송 시스템 연계 - 상태조회 - * - * packageName : kr.xit.ens.support.batch.job - * fileName : SndngStatusBulksJobConfig - * author : limju - * date : 2023-06-13 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-13 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Configuration -public class SndngStatusBulksJobConfig { - private static final String JOB_NAME = "SndngStatusBulksJob"; - - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobBuilderFactory jobBuilderFactory; - private final StepBuilderFactory stepBuilderFactory; - - private final IBatchCmmService lockService; - private final ISendMessageLinkService linkService; - - @Bean(name = JOB_NAME) - public Job sndngStatusBulksJob() { - return jobBuilderFactory.get(JOB_NAME) - .incrementer(new CustomRunIdIncrementer()) - .listener(new CustomJobListener()) - .listener(new CustomStepListener()) - .listener(new NoWorkFoundStepListener()) - - // JOB 시작 - // start() 결과가 FAILED 인경우 종료 - .start(start()) - .on("FAILED") - .end() - - // start()의 결과로 부터 FAILED를 제외한 모든 경우 to() 실행 - .from(start()) - .on("*") - .to(execution()) - .on("FAILED") - .to(fail()) - - .from(execution()) - // to() 실행 결과와 상관 없이 end() 실행 - .on("*") - .to(end()) - - // JOB 종료 - .end() - - .build(); - } - - @Bean(name = JOB_NAME + "_step") - public Step execution() { - return stepBuilderFactory.get(JOB_NAME + "_step") - .tasklet(new SndngStatusBulksTasklet(linkService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_start_step") - protected Step start() { - return stepBuilderFactory.get("Job_Locking") - .tasklet(new BatchStartTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_end_step") - protected Step end() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchEndTasklet(lockService)) - .build(); - } - - @JobScope - @Bean(name = JOB_NAME + "_fail_step") - protected Step fail() { - return stepBuilderFactory.get("Lock_Release") - .tasklet(new BatchFailEndTasklet(lockService)) - .build(); - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/rowmapper/LoggingRowMapper.java b/mens-api/src/main/java/kr/xit/ens/support/batch/rowmapper/LoggingRowMapper.java deleted file mode 100644 index dc65f9a..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/rowmapper/LoggingRowMapper.java +++ /dev/null @@ -1,33 +0,0 @@ -package kr.xit.ens.support.batch.rowmapper; - - -import java.sql.ResultSet; -import java.sql.SQLException; - -import org.springframework.jdbc.core.RowMapper; - -import kr.xit.core.biz.model.LoggingDTO; - -/** - *
- * description : - * - * packageName : kr.xit.ens.support.batch.rowmapper - * fileName : LoggingRowMapper - * author : limju - * date : 2023-05-16 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-05-16 limju 최초 생성 - * - *- */ -public class LoggingRowMapper implements RowMapper
- * description : 전자 고지 CCTV accept - * - * packageName : kr.xit.ens.support.batch.scheduler - * fileName : EnsCctvAcceptJobScheduler - * author : seojh - * date : 2023-07-17 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-17 seojh 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Component -public class EnsCctvAcceptJobScheduler { - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobLauncher jobLauncher; - private final EnsCctvAcceptJobConfg jobConfiguration; - @Value("${app.slack-webhook.enabled:false}") - private String isSlackEnabled; - - //FIXME : 전자 고지 CCTV 파일 처리(서광) 실행 간격 정의 - private final static int RUN_EXEC_MIS = 10000; - - //@Scheduled(initialDelay = RUN_EXEC_MIS, fixedDelay = RUN_EXEC_MIS) - public void runJob() { - - Map
- * description : 전자 고지 CCTV 파일 처리(서광) - * - * packageName : kr.xit.ens.support.batch.scheduler - * fileName : EnsCctvFileJobScheduler - * author : seojh - * date : 2023-07-17 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-17 seojh 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Component -public class EnsCctvFileJobScheduler { - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobLauncher jobLauncher; - private final EnsCctvFileJobConfg jobConfiguration; - @Value("${app.slack-webhook.enabled:false}") - private String isSlackEnabled; - - //FIXME : 전자 고지 CCTV 파일 처리(서광) 실행 간격 정의 - private final static int RUN_EXEC_MIS = 10000; - - //@Scheduled(initialDelay = RUN_EXEC_MIS, fixedDelay = RUN_EXEC_MIS) - public void runJob() { - - Map
- * description : 사전고지 CCTV accept - * - * packageName : kr.xit.ens.support.batch.scheduler - * fileName : PniCctvAcceptJobScheduler - * author : limju - * date : 2023-07-11 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-11 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Component -public class PniCctvAcceptJobScheduler { - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobLauncher jobLauncher; - private final PniCctvAcceptJobConfg jobConfiguration; - @Value("${app.slack-webhook.enabled:false}") - private String isSlackEnabled; - - //FIXME : 사전고지 CCTV 파일 처리(서광) 실행 간격 정의 - private final static int RUN_EXEC_MIS = 10000; - - //@Scheduled(initialDelay = RUN_EXEC_MIS, fixedDelay = RUN_EXEC_MIS) - public void runJob() { - - Map
- * description : 사전고지 CCTV 파일 처리(서광) - * - * packageName : kr.xit.ens.support.batch.scheduler - * fileName : PniCctvFileJobScheduler - * author : limju - * date : 2023-07-10 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-10 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Component -public class PniCctvFileJobScheduler { - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobLauncher jobLauncher; - private final PniCctvFileJobConfg jobConfiguration; - @Value("${app.slack-webhook.enabled:false}") - private String isSlackEnabled; - - //FIXME : 사전고지 CCTV 파일 처리(서광) 실행 간격 정의 - private final static int RUN_EXEC_MIS = 10000; - - //@Scheduled(initialDelay = RUN_EXEC_MIS, fixedDelay = RUN_EXEC_MIS) - public void runJob() { - - Map
- * description : 연계 발송 - 접수 데이타 생성 - * 대상 : 연계발송마스터(tb_cntc_sndng_mastr) : sndng_process_sttus = 'accept' - * 연계발송상세(tb_cntc_sndng_detail) - * -> 통합발송 마스터(tb_ens_unity_sndng_mastr) - * 통합발송상세(tb_ens_unity_sndng_detail) - * : 연계발송마스터 and tb_ens_unity_sndng_mastr - sndng_process_sttus = 'accept-ok' - * packageName : kr.xit.ens.support.batch.scheduler - * fileName : SndngAcceptJobScheduler - * author : limju - * date : 2023-06-12 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-12 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Component -public class SndngAcceptJobScheduler { - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobLauncher jobLauncher; - private final SndngAcceptJobConfig jobConfiguration; - @Value("${app.slack-webhook.enabled:false}") - private String isSlackEnabled; - - //@Scheduled(cron = "${app.batch.cron.ens.accept}") - public void runJob() { - - Map
- * description :상태 close - send-ok - * 대상 : 연계 발송 마스터(tb_cntc_sndng_mastr) - * -> 연계 발송 마스터(tb_cntc_sndng_mastr) - * 통합 발송 마스터(tb_ens_unity_sndng_mastr) - * 발송 마스터(tb_ens_sndng_mastr) - * packageName : kr.xit.ens.support.batch.scheduler - * fileName : SndngCloseJobScheduler - * author : seojh - * date : 2023-06-14 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-14 seojh 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Component -public class SndngCloseJobScheduler { - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobLauncher jobLauncher; - private final SndngCloseJobConfig jobConfiguration; - @Value("${app.slack-webhook.enabled:false}") - private String isSlackEnabled; - - //@Scheduled(cron = "${app.batch.cron.ens.close}") - public void runJob() { - - Map
- * description : 연계 발송 - 전송 대상 데이타 생성 - * 대상 : 통합발송 마스터(tb_ens_unity_sndng_mastr) - * * 통합발송상세(tb_ens_unity_sndng_detail) - * -> 발송 마스터(tb_ens_sndng_mastr) - * 발송상세(tb_ens_kakao_my_doc) - * packageName : kr.xit.ens.support.batch.scheduler - * fileName : SndngMakeJobScheduler - * author : limju - * date : 2023-06-12 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-12 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Component -public class SndngMakeJobScheduler { - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobLauncher jobLauncher; - private final SndngMakeJobConfig jobConfiguration; - @Value("${app.slack-webhook.enabled:false}") - private String isSlackEnabled; - - //@Scheduled(cron = "${app.batch.cron.ens.make}") - public void runJob() { - - Map
- * description : 연계 발송 - 전송 - * 대상 : 발송 마스터(tb_ens_sndng_mastr) - * 발송상세(tb_ens_kakao_my_doc) - * 연계발송결과(tb_cntc_sndng_result) - * packageName : kr.xit.ens.support.batch.scheduler - * fileName : SndngSendBulksJobScheduler - * author : limju - * date : 2023-06-12 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-12 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Component -public class SndngSendBulksJobScheduler { - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobLauncher jobLauncher; - private final SndngSnedBulksJobConfig jobConfiguration; - @Value("${app.slack-webhook.enabled:false}") - private String isSlackEnabled; - - //@Scheduled(cron = "${app.batch.cron.ens.send}") - public void runJob() { - - Map
- * description : 연계 발송 - 상태조회 - * 대상 : 연계발송결과(tb_cntc_sndng_result) - * 발송상세(tb_ens_kakao_my_doc) - * packageName : kr.xit.ens.support.batch.scheduler - * fileName : SndngStatusBulksJobScheduler - * author : limju - * date : 2023-06-13 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-13 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -@Component -public class SndngStatusBulksJobScheduler { - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobLauncher jobLauncher; - private final SndngStatusBulksJobConfig jobConfiguration; - - @Value("${app.slack-webhook.enabled:false}") - private String isSlackEnabled; - - //@Scheduled(cron = "${app.batch.cron.ens.kko-status}") - public void runJob() { - - Map
- * description : 전자 고지 CCTV accept - * - * packageName : kr.xit.ens.support.batch.task - * fileName : EnsCctvAcceptTasklet - * author : seojh - * date : 2023-07-17 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-17 seojh 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -public class EnsCctvAcceptTasklet implements Tasklet { - private final IEnsCctvFileService service; - @Override - @JobScope - public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) { - final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled"); - - try { - service.acceptEnsNtnccntcSndng(); - }catch(Exception e){ - log.error("EnsCctvAcceptTasklet error :: {}", e.getMessage()); - - TaskCmmUtils.taskBatchErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - - TaskCmmUtils.taskEnsMessageLinkServiceUpdateErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - - contribution.setExitStatus(ExitStatus.FAILED); - return RepeatStatus.FINISHED; - } - contribution.setExitStatus(ExitStatus.COMPLETED); - return RepeatStatus.FINISHED; - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/task/EnsCctvFileTasklet.java b/mens-api/src/main/java/kr/xit/ens/support/batch/task/EnsCctvFileTasklet.java deleted file mode 100644 index e12090d..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/task/EnsCctvFileTasklet.java +++ /dev/null @@ -1,55 +0,0 @@ -package kr.xit.ens.support.batch.task; - -import kr.xit.biz.ens.service.IEnsCctvFileService; -import kr.xit.ens.support.batch.task.cmm.TaskCmmUtils; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.batch.core.ExitStatus; -import org.springframework.batch.core.StepContribution; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.scope.context.ChunkContext; -import org.springframework.batch.core.step.tasklet.Tasklet; -import org.springframework.batch.repeat.RepeatStatus; - -/** - *
- * description : 전자 고지 CCTV 파일 처리(서광) - * - * packageName : kr.xit.ens.support.batch.task - * fileName : EnsCctvFileTasklet - * author : seojh - * date : 2023-07-17 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-17 seojh 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -public class EnsCctvFileTasklet implements Tasklet { - private final IEnsCctvFileService service; - @Override - @JobScope - public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) { - final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled"); - - try { - service.createCctvFileOfSg(); - }catch(Exception e){ - log.error("EnsCctvFileTasklet error :: {}", e.getMessage()); - - TaskCmmUtils.taskBatchErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - - contribution.setExitStatus(ExitStatus.FAILED); - return RepeatStatus.FINISHED; - } - contribution.setExitStatus(ExitStatus.COMPLETED); - return RepeatStatus.FINISHED; - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/task/PniCctvAcceptTasklet.java b/mens-api/src/main/java/kr/xit/ens/support/batch/task/PniCctvAcceptTasklet.java deleted file mode 100644 index a48dfb6..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/task/PniCctvAcceptTasklet.java +++ /dev/null @@ -1,61 +0,0 @@ -package kr.xit.ens.support.batch.task; - -import kr.xit.biz.pni.service.IPniCctvFileService; -import kr.xit.ens.support.batch.task.cmm.TaskCmmUtils; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.batch.core.ExitStatus; -import org.springframework.batch.core.StepContribution; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.scope.context.ChunkContext; -import org.springframework.batch.core.step.tasklet.Tasklet; -import org.springframework.batch.repeat.RepeatStatus; - -/** - *
- * description : 사전고지 CCTV accept - * - * packageName : kr.xit.ens.support.batch.task - * fileName : PniCctvAcceptTasklet - * author : limju - * date : 2023-07-11 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-11 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -public class PniCctvAcceptTasklet implements Tasklet { - private final IPniCctvFileService service; - @Override - @JobScope - public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) { - final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled"); - - try { - service.acceptPniNtnccntcSndng(); - }catch(Exception e){ - log.error("PniCctvAcceptTasklet error :: {}", e.getMessage()); - - TaskCmmUtils.taskBatchErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - - TaskCmmUtils.taskEnsMessageLinkServiceUpdateErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - - contribution.setExitStatus(ExitStatus.FAILED); - return RepeatStatus.FINISHED; - } - contribution.setExitStatus(ExitStatus.COMPLETED); - return RepeatStatus.FINISHED; - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/task/PniCctvFileTasklet.java b/mens-api/src/main/java/kr/xit/ens/support/batch/task/PniCctvFileTasklet.java deleted file mode 100644 index b852300..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/task/PniCctvFileTasklet.java +++ /dev/null @@ -1,55 +0,0 @@ -package kr.xit.ens.support.batch.task; - -import kr.xit.biz.pni.service.IPniCctvFileService; -import kr.xit.ens.support.batch.task.cmm.TaskCmmUtils; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.batch.core.ExitStatus; -import org.springframework.batch.core.StepContribution; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.scope.context.ChunkContext; -import org.springframework.batch.core.step.tasklet.Tasklet; -import org.springframework.batch.repeat.RepeatStatus; - -/** - *
- * description : 사전고지 CCTV 파일 처리(서광) - * - * packageName : kr.xit.ens.support.batch.task - * fileName : PniCctvFileTasklet - * author : limju - * date : 2023-07-10 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-07-10 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -public class PniCctvFileTasklet implements Tasklet { - private final IPniCctvFileService service; - @Override - @JobScope - public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) { - final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled"); - - try { - service.createCctvFileOfSg(); - }catch(Exception e){ - log.error("PniCctvFileTasklet error :: {}", e.getMessage()); - - TaskCmmUtils.taskBatchErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - - contribution.setExitStatus(ExitStatus.FAILED); - return RepeatStatus.FINISHED; - } - contribution.setExitStatus(ExitStatus.COMPLETED); - return RepeatStatus.FINISHED; - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngAcceptTasklet.java b/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngAcceptTasklet.java deleted file mode 100644 index 9050a04..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngAcceptTasklet.java +++ /dev/null @@ -1,62 +0,0 @@ -package kr.xit.ens.support.batch.task; - -import kr.xit.ens.support.batch.task.cmm.TaskCmmUtils; -import org.springframework.batch.core.ExitStatus; -import org.springframework.batch.core.StepContribution; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.scope.context.ChunkContext; -import org.springframework.batch.core.step.tasklet.Tasklet; -import org.springframework.batch.repeat.RepeatStatus; - -import kr.xit.biz.ens.service.ISendMessageLinkService; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; - -/** - *
- * description : - * - * packageName : kr.xit.ens.support.batch.task - * fileName : SndngAcceptTasklet - * author : limju - * date : 2023-06-12 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-12 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -public class SndngAcceptTasklet implements Tasklet { - private final ISendMessageLinkService service; - @Override - @JobScope - public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) { - String sndngProcessSttus = contribution.getStepExecution().getJobParameters().getString("sndngProcessSttus"); - final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled"); - - try { - service.accept(sndngProcessSttus); - }catch(Exception e){ - log.error("SndngAcceptTasklet error :: {}", e.getMessage()); - - TaskCmmUtils.taskBatchErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - - TaskCmmUtils.taskEnsMessageLinkServiceUpdateErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - contribution.setExitStatus(ExitStatus.FAILED); - return RepeatStatus.FINISHED; - } - contribution.setExitStatus(ExitStatus.COMPLETED); - return RepeatStatus.FINISHED; - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngCloseTasklet.java b/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngCloseTasklet.java deleted file mode 100644 index bd83cc4..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngCloseTasklet.java +++ /dev/null @@ -1,59 +0,0 @@ -package kr.xit.ens.support.batch.task; - -import kr.xit.biz.ens.service.ISendMessageLinkService; -import kr.xit.ens.support.batch.task.cmm.TaskCmmUtils; -import lombok.extern.slf4j.Slf4j; - -import org.springframework.batch.core.ExitStatus; -import org.springframework.batch.core.StepContribution; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.scope.context.ChunkContext; -import org.springframework.batch.core.step.tasklet.Tasklet; -import org.springframework.batch.repeat.RepeatStatus; - -/** - *
- * description : - * - * packageName : kr.xit.ens.support.batch.task - * fileName : SndngCloseTasklet - * author : seojh - * date : 2023-06-14 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-14 seojh 최초 생성 - * - *- */ -@Slf4j -public class SndngCloseTasklet implements Tasklet { - private final ISendMessageLinkService service; - - public SndngCloseTasklet(ISendMessageLinkService service) { - this.service = service; - } - - @Override - @JobScope - public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) { - String sndngProcessSttus = contribution.getStepExecution().getJobParameters().getString("sndngProcessSttus"); - final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled"); - - try { - service.close(sndngProcessSttus); - }catch(Exception e){ - log.error("SndngCloseTasklet error :: {}", e.getMessage()); - - TaskCmmUtils.taskBatchErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - contribution.setExitStatus(ExitStatus.FAILED); - return RepeatStatus.FINISHED; - } - contribution.setExitStatus(ExitStatus.COMPLETED); - return RepeatStatus.FINISHED; - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngMakeTasklet.java b/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngMakeTasklet.java deleted file mode 100644 index ae05ebf..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngMakeTasklet.java +++ /dev/null @@ -1,62 +0,0 @@ -package kr.xit.ens.support.batch.task; - -import kr.xit.ens.support.batch.task.cmm.TaskCmmUtils; -import org.springframework.batch.core.ExitStatus; -import org.springframework.batch.core.StepContribution; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.scope.context.ChunkContext; -import org.springframework.batch.core.step.tasklet.Tasklet; -import org.springframework.batch.repeat.RepeatStatus; - -import kr.xit.biz.ens.service.ISendMessageLinkService; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; - -/** - *
- * description : - * - * packageName : kr.xit.ens.support.batch.task - * fileName : SndngMakeTasklet - * author : limju - * date : 2023-06-12 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-12 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -public class SndngMakeTasklet implements Tasklet { - private final ISendMessageLinkService service; - @Override - @JobScope - public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) { - String sndngProcessSttus = contribution.getStepExecution().getJobParameters().getString("sndngProcessSttus"); - final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled"); - - try { - service.make(sndngProcessSttus); - }catch(Exception e){ - log.error("SndngMakeTasklet error :: {}", e.getMessage()); - - TaskCmmUtils.taskBatchErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - - TaskCmmUtils.taskEnsMessageLinkServiceUpdateErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - contribution.setExitStatus(ExitStatus.FAILED); - return RepeatStatus.FINISHED; - } - contribution.setExitStatus(ExitStatus.COMPLETED); - return RepeatStatus.FINISHED; - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngSendBulksTasklet.java b/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngSendBulksTasklet.java deleted file mode 100644 index 720766e..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngSendBulksTasklet.java +++ /dev/null @@ -1,69 +0,0 @@ -package kr.xit.ens.support.batch.task; - -import java.util.UUID; - -import kr.xit.ens.support.batch.task.cmm.TaskCmmUtils; -import org.slf4j.MDC; -import org.springframework.batch.core.ExitStatus; -import org.springframework.batch.core.StepContribution; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.scope.context.ChunkContext; -import org.springframework.batch.core.step.tasklet.Tasklet; -import org.springframework.batch.repeat.RepeatStatus; - -import kr.xit.biz.ens.service.ISendMessageLinkService; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; - -/** - *
- * description : - * - * packageName : kr.xit.ens.support.batch.task - * fileName : SndngSendBulksTasklet - * author : limju - * date : 2023-06-12 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-12 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -public class SndngSendBulksTasklet implements Tasklet { - private final ISendMessageLinkService service; - @Override - @JobScope - public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) { - String sndngProcessSttus = contribution.getStepExecution().getJobParameters().getString("sndngProcessSttus"); - final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled"); - - try { - MDC.put("request_trace_batch_id", UUID.randomUUID().toString().replace("-", "")); - MDC.put("uri", "/v1/documents/bulk"); - MDC.put("method", "POST"); - - service.sendBulks(sndngProcessSttus); - }catch(Exception e){ - log.error("SndngSendBulksTasklet error :: {}", e.getMessage()); - - TaskCmmUtils.taskBatchErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - - TaskCmmUtils.taskEnsMessageLinkServiceUpdateErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - contribution.setExitStatus(ExitStatus.FAILED); - return RepeatStatus.FINISHED; - } - contribution.setExitStatus(ExitStatus.COMPLETED); - return RepeatStatus.FINISHED; - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngStatusBulksTasklet.java b/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngStatusBulksTasklet.java deleted file mode 100644 index 870bf3b..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/task/SndngStatusBulksTasklet.java +++ /dev/null @@ -1,63 +0,0 @@ -package kr.xit.ens.support.batch.task; - -import kr.xit.ens.support.batch.task.cmm.TaskCmmUtils; -import org.slf4j.MDC; -import org.springframework.batch.core.ExitStatus; -import org.springframework.batch.core.StepContribution; -import org.springframework.batch.core.configuration.annotation.JobScope; -import org.springframework.batch.core.scope.context.ChunkContext; -import org.springframework.batch.core.step.tasklet.Tasklet; -import org.springframework.batch.repeat.RepeatStatus; - -import kr.xit.biz.ens.service.ISendMessageLinkService; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; - -import java.util.UUID; - -/** - *
- * description : - * - * packageName : kr.xit.ens.support.batch.task - * fileName : SndngStatusBulksTasklet - * author : limju - * date : 2023-06-13 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-13 limju 최초 생성 - * - *- */ -@Slf4j -@RequiredArgsConstructor -public class SndngStatusBulksTasklet implements Tasklet { - private final ISendMessageLinkService service; - @Override - @JobScope - public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) { - final String sndngProcessSttus = contribution.getStepExecution().getJobParameters().getString("sndngProcessSttus"); - final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled"); - - try { - MDC.put("request_trace_batch_id", UUID.randomUUID().toString().replace("-", "")); - MDC.put("uri", "/v1/documents/bulk/status"); - MDC.put("method", "POST"); - - service.findKkoMyDocStatusBulks(sndngProcessSttus); - }catch(Exception e){ - log.error("SndngStatusBulksTasklet error :: {}", e.getMessage()); - - TaskCmmUtils.taskBatchErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - e.getMessage(), - isSlackEnabled - ); - contribution.setExitStatus(ExitStatus.FAILED); - return RepeatStatus.FINISHED; - } - contribution.setExitStatus(ExitStatus.COMPLETED); - return RepeatStatus.FINISHED; - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/task/cmm/TaskCmmUtils.java b/mens-api/src/main/java/kr/xit/ens/support/batch/task/cmm/TaskCmmUtils.java deleted file mode 100644 index 006dbb8..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/task/cmm/TaskCmmUtils.java +++ /dev/null @@ -1,83 +0,0 @@ -package kr.xit.ens.support.batch.task.cmm; - -import kr.xit.biz.ens.model.EnsDTO; -import kr.xit.core.biz.batch.model.BatchCmmDTO; -import kr.xit.core.spring.util.ApiSpringUtils; -import kr.xit.ens.support.common.ApiConstants; -import lombok.AccessLevel; -import lombok.NoArgsConstructor; -import org.slf4j.MDC; - -import static egovframework.com.cmm.util.EgovStringUtil.cutString; - -/** - *
- * description : - * - * packageName : kr.xit.ens.support.batch.task.cmm - * fileName : TaskCmmUtils - * author : limju - * date : 2023-06-19 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-06-19 limju 최초 생성 - * - *- */ -@NoArgsConstructor(access = AccessLevel.PRIVATE) -public class TaskCmmUtils { - public static void taskBatchErrorLog(final String instanceId, final String errorMsg, final String isSlackEnabled){ - ApiSpringUtils.getBatchCmmService().modifyBatchLog( - BatchCmmDTO - .builder() - .batchLogId(MDC.get("batch_log_id")) - .instanceId(instanceId) - .traceId(MDC.get("request_trace_id")) - .message(errorMsg) - .build() - ); - if(Boolean.parseBoolean(isSlackEnabled)) { - ApiSpringUtils.getSlackWebhookPush().sendSlackAlertLog( - errorMsg, - MDC.get("uri"), - "batch call"); - } - } - - /** - * 배치 실행시 발생한 에러 처리 - *
업무단에서 발생한 에러 처리를 위한 메소드 - * @param instanceId String 배치인스턴스 - * @param errorMsg String 에러 메세지 - * @param isSlackEnabled boolean 슬랙 push 여부 - */ - public static void taskEnsMessageLinkServiceUpdateErrorLog(final String instanceId, final String errorMsg, final String isSlackEnabled){ - final String UNITY_SNDNG_MASTR_ID = "unitySndngMastrId"; - - String unitySndngMastrId = null; - String sndngProcessSttus = null; - String sndngMastrId = null; - - if("SndngAcceptJob".equals(instanceId) || "PniCctvAcceptJob".equals(instanceId)){ - unitySndngMastrId = MDC.get(UNITY_SNDNG_MASTR_ID); - sndngProcessSttus = ApiConstants.SndngProcessStatus.ACCETP_FAIL.getCode(); - } else if ("SndngMakeJob".equals(instanceId)) { - unitySndngMastrId = MDC.get(UNITY_SNDNG_MASTR_ID); - sndngProcessSttus = MDC.get("sndngProcessSttus"); - } else if ("SndngSendBulksJob".equals(instanceId)) { - unitySndngMastrId = MDC.get(UNITY_SNDNG_MASTR_ID); - sndngMastrId = MDC.get("sndngMastrId"); - sndngProcessSttus = MDC.get("sndngProcessSttus"); - } - ApiSpringUtils.getSendMessageLinkService().updateErrorLog( - EnsDTO.SndngMssageParam.builder() - .unitySndngMastrId(unitySndngMastrId) - .sndngMastrId(sndngMastrId) - .newSndngProcessSttus(sndngProcessSttus) - .errorCode(instanceId) - .errorMssage(cutString(errorMsg, 300)) - .build() - ); - } -} diff --git a/mens-api/src/main/java/kr/xit/ens/support/batch/web/KkopayEltrcDocBatchController.java b/mens-api/src/main/java/kr/xit/ens/support/batch/web/KkopayEltrcDocBatchController.java deleted file mode 100644 index 1938e0e..0000000 --- a/mens-api/src/main/java/kr/xit/ens/support/batch/web/KkopayEltrcDocBatchController.java +++ /dev/null @@ -1,224 +0,0 @@ -package kr.xit.ens.support.batch.web; - -import java.util.Date; -import java.util.HashMap; -import java.util.Map; - -import kr.xit.core.support.utils.Checks; -import kr.xit.ens.support.batch.job.*; -import org.springframework.batch.core.JobExecution; -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.beans.factory.annotation.Value; -import org.springframework.http.HttpStatus; -import org.springframework.http.MediaType; -import org.springframework.http.ResponseEntity; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; - -import io.swagger.v3.oas.annotations.Operation; -import io.swagger.v3.oas.annotations.tags.Tag; -import kr.xit.core.model.ApiResponseDTO; -import kr.xit.ens.support.batch.scheduler.SndngSendBulksJobScheduler; -import kr.xit.ens.support.common.ApiConstants; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; - -/** - *
- * description : 카카오페이 전자문서 발송요청 배치 컨트롤러 - * - * packageName : kr.xit.ens.support.batch.web - * fileName : KkopayEltrcDocBatchController - * author : limju - * date : 2023-05-16 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023-05-16 limju 최초 생성 - * - *- */ -@Tag(name = "KkopayEltrcDocBatchController", description = "전자고지 통합발송 연계 배치 WEB") -@Slf4j -@RequiredArgsConstructor -@RestController -@RequestMapping(value = "/api/batch/v1") -public class KkopayEltrcDocBatchController { - @Value("${app.slack-webhook.enabled:false}") - private String isSlackEnabled; - - @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") - private final JobLauncher jobLauncher; - private final SndngAcceptJobConfig acceptJobConfig; - private final SndngMakeJobConfig makeJobConfig; - private final SndngSnedBulksJobConfig sendBulksJobConfig; - private final SndngStatusBulksJobConfig statusJobConfig; - private final SndngCloseJobConfig closeJobConfig; - private final PniCctvFileJobConfg pniCctvFileJobConfg; - private final PniCctvAcceptJobConfg pniCctvAcceptJobConfg; - - @Operation(summary = "accept", description = "accept") - @GetMapping(value = "/accept", produces = MediaType.APPLICATION_JSON_VALUE) - public ApiResponseDTO accept() { - try { - JobExecution jobExecution = jobLauncher.run(acceptJobConfig.sndngAcceptJob(), getJobParameters(ApiConstants.SndngProcessStatus.ACCEPT.getCode())); - - while(jobExecution.isRunning()){ - log.info("..."); - } - printLog(jobExecution); - - } catch (JobExecutionAlreadyRunningException | JobInstanceAlreadyCompleteException - | JobParametersInvalidException | org.springframework.batch.core.repository.JobRestartException e) { - - log.error(e.getMessage()); - } - return ApiResponseDTO.success(HttpStatus.OK); - } - - @Operation(summary = "make", description = "make") - @GetMapping(value = "/make", produces = MediaType.APPLICATION_JSON_VALUE) - public ApiResponseDTO make() { - - try { - JobExecution jobExecution = jobLauncher.run(makeJobConfig.sndngMakeJob(), getJobParameters(ApiConstants.SndngProcessStatus.ACCETP_OK.getCode())); - - while(jobExecution.isRunning()){ - log.info("..."); - } - printLog(jobExecution); - - } catch (JobExecutionAlreadyRunningException | JobInstanceAlreadyCompleteException - | JobParametersInvalidException | org.springframework.batch.core.repository.JobRestartException e) { - - log.error(e.getMessage()); - } - return ApiResponseDTO.success(HttpStatus.OK); - } - - @Operation(summary = "close", description = "close") - @GetMapping(value = "/close", produces = MediaType.APPLICATION_JSON_VALUE) - public ApiResponseDTO close() { - - try { - JobExecution jobExecution = jobLauncher.run(closeJobConfig.sndngCloseJob(), getJobParameters(ApiConstants.SndngProcessStatus.SEND_OK.getCode())); - - while(jobExecution.isRunning()){ - log.info("..."); - } - printLog(jobExecution); - - } catch (JobExecutionAlreadyRunningException | JobInstanceAlreadyCompleteException - | JobParametersInvalidException | org.springframework.batch.core.repository.JobRestartException e) { - - log.error(e.getMessage()); - } - return ApiResponseDTO.success(HttpStatus.OK); - } - - @Operation(summary = "sendBulks", description = "sendBulks") - @GetMapping(value = "/sendBulks", produces = MediaType.APPLICATION_JSON_VALUE) - public ApiResponseDTO sendBulks() { - - try { - JobExecution jobExecution = jobLauncher.run(sendBulksJobConfig.sndngSendBulksJob(), getJobParameters(ApiConstants.SndngProcessStatus.MAKE_OK.getCode())); - - while(jobExecution.isRunning()){ - log.info("..."); - } - printLog(jobExecution); - - } catch (JobExecutionAlreadyRunningException | JobInstanceAlreadyCompleteException - | JobParametersInvalidException | org.springframework.batch.core.repository.JobRestartException e) { - - log.error(e.getMessage()); - } - return ApiResponseDTO.success(HttpStatus.OK); - } - - @Operation(summary = "statusBulks", description = "statusBulks") - @GetMapping(value = "/statusBulks", produces = MediaType.APPLICATION_JSON_VALUE) - public ApiResponseDTO statusBulks() { - - try { - JobExecution jobExecution = jobLauncher.run(statusJobConfig.sndngStatusBulksJob(), getJobParameters(ApiConstants.SndngProcessStatus.SEND_OK.getCode())); - - while(jobExecution.isRunning()){ - log.info("..."); - } - printLog(jobExecution); - - } catch (JobExecutionAlreadyRunningException | JobInstanceAlreadyCompleteException - | JobParametersInvalidException | org.springframework.batch.core.repository.JobRestartException e) { - - log.error(e.getMessage()); - } - return ApiResponseDTO.success(HttpStatus.OK); - } - - @Operation(summary = "pniCctvFileService", description = "CCTV 사전알림(서광)") - @GetMapping(value = "/pniCctvFileService", produces = MediaType.APPLICATION_JSON_VALUE) - public ApiResponseDTO pniCctvFileService() { - - try { - JobExecution jobExecution = jobLauncher.run(pniCctvFileJobConfg.pniCctvFileJob(), getJobParameters(null)); - - while(jobExecution.isRunning()){ - log.info("..."); - } - printLog(jobExecution); - - } catch (JobExecutionAlreadyRunningException | JobInstanceAlreadyCompleteException - | JobParametersInvalidException | org.springframework.batch.core.repository.JobRestartException e) { - - log.error(e.getMessage()); - } - return ApiResponseDTO.success(HttpStatus.OK); - } - - @Operation(summary = "pniCctvAccept", description = "CCTV 단속 사전알림 accept") - @GetMapping(value = "/pniCctvAccept", produces = MediaType.APPLICATION_JSON_VALUE) - public ApiResponseDTO pniCctvAccept() { - - try { - JobExecution jobExecution = jobLauncher.run(pniCctvAcceptJobConfg.pniCctvAcceptJob(), getJobParameters(null)); - - while(jobExecution.isRunning()){ - log.info("..."); - } - printLog(jobExecution); - - } catch (JobExecutionAlreadyRunningException | JobInstanceAlreadyCompleteException - | JobParametersInvalidException | org.springframework.batch.core.repository.JobRestartException e) { - - log.error(e.getMessage()); - } - return ApiResponseDTO.success(HttpStatus.OK); - } - - private JobParameters getJobParameters(final String processStatus){ - Map
- * description : - * packageName : kr.xit.ens.support.common.code - * fileName : KkoReponseCode - * author : minuk - * date : 2023/05/07 - * ====================================================================== - * 변경일 변경자 변경 내용 - * ---------------------------------------------------------------------- - * 2023/05/07 minuk 최초 생성 - * - *- */ -//TODO:: KakaoConstants 로 통합 -public class KkoReponseCode { - - public enum ErrorCode { - -// INVALID_VALUE("INVALID_VALUE", "INVALID_VALUE", "유효하지 않은 값입니다."), -// UNIDENTIFIED_USER("UNIDENTIFIED_USER", "INVALID_VALUE", "유효하지 않은 값입니다."), -// UNAUTHORIZED("UNAUTHORIZED", "UNAUTHORIZED", "접근 권한이 없습니다."), -// FORBIDDEN("FORBIDDEN", "FORBIDDEN", "허용되지 않는 요청입니다. 수신거부된 사용자 입니다."), -// NOT_FOUND("NOT_FOUND", "NOT_FOUND", "요청 정보를 찾을 수 없습니다."), -// INTERNAL_ERROR("INTERNAL_ERROR", "INTERNAL_SERVER_ERROR", "서버 에러입니다. 다시 시도해 주세요."), -// ; - - INVALID_VALUE(400, "INVALID_VALUE", "유효하지 않은 값입니다."), - UNIDENTIFIED_USER(400, "INVALID_VALUE", "유효하지 않은 값입니다."), - UNAUTHORIZED(401, "UNAUTHORIZED", "접근 권한이 없습니다."), - FORBIDDEN(403, "FORBIDDEN", "허용되지 않는 요청입니다. 수신거부된 사용자 입니다."), - NOT_FOUND(404, "NOT_FOUND", "요청 정보를 찾을 수 없습니다."), - INTERNAL_ERROR(500, "INTERNAL_SERVER_ERROR", "서버 에러입니다. 다시 시도해 주세요."), - ; - - @Getter - private int errorCode; - - @Getter - private String errorString; - - @Getter - private String message; - - ErrorCode(int errorCode, String errorString, String message){ - this.errorCode = errorCode; - this.errorString = errorString; - this.message = message; - } - } -}