xit-java
/
mens-traffic-parent
23
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: lombok 제거

Browse Source
main
Jonguk. Lim 1 year ago
parent 414050130f
commit e811464ba1
2 changed files with 30 additions and 36 deletions
Show Stats Download Patch File Download Diff File

49
mens-batch/src/main/java/kr/xit/batch/ens/job/KtGbsAccessTokenUpdateJobConfig.java
Unescape Escape View File

@ -1,25 +1,17 @@
package kr.xit.batch.ens.job; package kr.xit.batch.ens.job;
import org.springframework.batch.core.Job; import org.springframework.batch.core.*;
import org.springframework.batch.core.Step; import org.springframework.batch.core.configuration.annotation.*;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; import org.springframework.beans.factory.annotation.*;
import org.springframework.batch.core.configuration.annotation.JobScope; import org.springframework.context.annotation.*;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import kr.xit.batch.ens.task.KtGbsAccessTokenUpdateTasklet; import kr.xit.batch.ens.task.*;
import kr.xit.biz.ens.service.IEnsBatchKtGbsAccessTokenUpdateService; import kr.xit.biz.ens.service.*;
import kr.xit.core.biz.batch.CustomRunIdIncrementer; import kr.xit.core.biz.batch.*;
import kr.xit.core.biz.batch.listener.CustomJobListener; import kr.xit.core.biz.batch.listener.*;
import kr.xit.core.biz.batch.listener.CustomStepListener; import kr.xit.core.biz.batch.service.*;
import kr.xit.core.biz.batch.listener.NoWorkFoundStepListener; import kr.xit.core.biz.batch.task.*;
import kr.xit.core.biz.batch.service.IBatchCmmService; import lombok.extern.slf4j.*;
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 lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
/** /**
* <pre> * <pre>
@ -37,17 +29,20 @@ import lombok.extern.slf4j.Slf4j;
* </pre> * </pre>
*/ */
@Slf4j @Slf4j
@RequiredArgsConstructor
@Configuration @Configuration
public class KtGbsAccessTokenUpdateJobConfig { public class KtGbsAccessTokenUpdateJobConfig {
private static final String JOB_NAME = "ktGbsAccessTokenUpdateJob"; private static final String JOB_NAME = "ktGbsAccessTokenUpdateJob";
@SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection")
private final JobBuilderFactory jobBuilderFactory; @Autowired
private final StepBuilderFactory stepBuilderFactory; private JobBuilderFactory jobBuilderFactory;
@Autowired
private StepBuilderFactory stepBuilderFactory;
private final IBatchCmmService lockService; @Autowired
private final IEnsBatchKtGbsAccessTokenUpdateService service; private IBatchCmmService batchCmmService;
@Autowired
private IEnsBatchKtGbsAccessTokenUpdateService service;
@Bean(name = JOB_NAME) @Bean(name = JOB_NAME)
public Job ktGbsAccessTokenUpdateJob() { public Job ktGbsAccessTokenUpdateJob() {
@ -92,7 +87,7 @@ public class KtGbsAccessTokenUpdateJobConfig {
@Bean(name = JOB_NAME + "_start_step") @Bean(name = JOB_NAME + "_start_step")
protected Step start() { protected Step start() {
return stepBuilderFactory.get("Job_Locking") return stepBuilderFactory.get("Job_Locking")
.tasklet(new BatchStartTasklet(lockService)) .tasklet(new BatchStartTasklet(batchCmmService))
.build(); .build();
} }
@ -100,7 +95,7 @@ public class KtGbsAccessTokenUpdateJobConfig {
@Bean(name = JOB_NAME + "_end_step") @Bean(name = JOB_NAME + "_end_step")
protected Step end() { protected Step end() {
return stepBuilderFactory.get("Lock_Release") return stepBuilderFactory.get("Lock_Release")
.tasklet(new BatchEndTasklet(lockService)) .tasklet(new BatchEndTasklet(batchCmmService))
.build(); .build();
} }
@ -108,7 +103,7 @@ public class KtGbsAccessTokenUpdateJobConfig {
@Bean(name = JOB_NAME + "_fail_step") @Bean(name = JOB_NAME + "_fail_step")
protected Step fail() { protected Step fail() {
return stepBuilderFactory.get("Lock_Release") return stepBuilderFactory.get("Lock_Release")
.tasklet(new BatchFailEndTasklet(lockService)) .tasklet(new BatchFailEndTasklet(batchCmmService))
.build(); .build();
} }
} }

17
mens-batch/src/main/java/kr/xit/core/biz/batch/service/BatchCmmService.java
Unescape Escape View File

@ -12,41 +12,40 @@ import kr.xit.core.biz.batch.mapper.*;
import kr.xit.core.biz.batch.model.BatchCmmDTO.*; import kr.xit.core.biz.batch.model.BatchCmmDTO.*;
import kr.xit.core.exception.*; import kr.xit.core.exception.*;
@Service @Service
public class BatchCmmService extends EgovAbstractServiceImpl implements IBatchCmmService { public class BatchCmmService extends EgovAbstractServiceImpl implements IBatchCmmService {
@Resource @Resource
private IBatchCmmMapper mapper; private IBatchCmmMapper batchCmmMapper;
@Override @Override
@Transactional(readOnly = true) @Transactional(readOnly = true)
public Optional<BatchLock> findById(final String instanceId) { public Optional<BatchLock> findById(final String instanceId) {
return mapper.selectBatchLockByInstanceId(instanceId); return batchCmmMapper.selectBatchLockByInstanceId(instanceId);
} }
@Override @Override
@Transactional(propagation = Propagation.REQUIRES_NEW) @Transactional(propagation = Propagation.REQUIRES_NEW)
public void addBatchLock(final BatchLock dto) { public void addBatchLock(final BatchLock dto) {
mapper.insertBatchLock(dto); batchCmmMapper.insertBatchLock(dto);
} }
@Override @Override
@Transactional(propagation = Propagation.REQUIRES_NEW) @Transactional(propagation = Propagation.REQUIRES_NEW)
public void modifyBatchLock(final BatchLock dto) { public void modifyBatchLock(final BatchLock dto) {
mapper.updateBatchLock(dto); batchCmmMapper.updateBatchLock(dto);
} }
@Override @Override
@Transactional(propagation = Propagation.REQUIRES_NEW) @Transactional(propagation = Propagation.REQUIRES_NEW)
public void addBatchLog(final BatchLock dto) { public void addBatchLog(final BatchLock dto) {
mapper.insertBatchLog(dto); batchCmmMapper.insertBatchLog(dto);
} }
@Override @Override
@Transactional(propagation = Propagation.REQUIRES_NEW) @Transactional(propagation = Propagation.REQUIRES_NEW)
public void modifyBatchLog(final BatchLock dto) { public void modifyBatchLog(final BatchLock dto) {
mapper.updateBatchLog(dto); batchCmmMapper.updateBatchLog(dto);
} }
//-------------------------------------------------------------- //--------------------------------------------------------------
@ -55,13 +54,13 @@ public class BatchCmmService extends EgovAbstractServiceImpl implements IBatchCm
@Override @Override
@Transactional(readOnly = true) @Transactional(readOnly = true)
public List<BatchLock> findBatchLocks(){ public List<BatchLock> findBatchLocks(){
return mapper.selectBatchLocks(); return batchCmmMapper.selectBatchLocks();
} }
@Override @Override
@Transactional(readOnly = true) @Transactional(readOnly = true)
public String execBatch(final BatchCmmRequest reqDTO){ public String execBatch(final BatchCmmRequest reqDTO){
BatchLock rtnDTO = mapper.selectBatchLock(reqDTO.getInstanceId()).orElseThrow(() -> BizRuntimeException.create("배치 인스턴스를 찾을 수 없습니다.")); BatchLock rtnDTO = batchCmmMapper.selectBatchLock(reqDTO.getInstanceId()).orElseThrow(() -> BizRuntimeException.create("배치 인스턴스를 찾을 수 없습니다."));
reqDTO.setProfile(reqDTO.getProfile()); reqDTO.setProfile(reqDTO.getProfile());
String uri = rtnDTO.getInstanceUrl(); String uri = rtnDTO.getInstanceUrl();

Write Preview
Loading…
Cancel
Save