지대한
1 week ago
1 changed files with 28 additions and 27 deletions
@ -1,47 +1,48 @@
|
||||
package com.palnet.biz.scheduler.ctr; |
||||
|
||||
import com.palnet.biz.scheduler.ctr.service.CtrSchedulerService; |
||||
import lombok.RequiredArgsConstructor; |
||||
import org.slf4j.Logger; |
||||
import org.slf4j.LoggerFactory; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.context.annotation.Profile; |
||||
import org.springframework.scheduling.annotation.Scheduled; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
import com.palnet.biz.scheduler.ctr.service.CtrSchedulerService; |
||||
|
||||
/** |
||||
* 데이터 정제 작업을 위한 스케줄러 |
||||
* @author kang |
||||
* |
||||
* @author kang |
||||
*/ |
||||
@Profile({"dev", "prod"}) |
||||
@RequiredArgsConstructor |
||||
@Component |
||||
public class CtrScheduler { |
||||
|
||||
@Autowired |
||||
private CtrSchedulerService service; |
||||
private final CtrSchedulerService service; |
||||
|
||||
private Logger logger = LoggerFactory.getLogger(getClass()); |
||||
private Logger logger = LoggerFactory.getLogger(getClass()); |
||||
|
||||
|
||||
/** |
||||
* TODO 비행 종료 처리 - 최신 수신 일로 부터 5분동안 데이터 수신 되지 않는 경우 종료 처리 |
||||
* |
||||
* 실행 주기 : 10초 |
||||
*/ |
||||
@Scheduled(fixedDelay = 1000 * 10) |
||||
public void controlEndScheduler() { |
||||
/** |
||||
* TODO 비행 종료 처리 - 최신 수신 일로 부터 5분동안 데이터 수신 되지 않는 경우 종료 처리 |
||||
* <p> |
||||
* 실행 주기 : 10초 |
||||
*/ |
||||
@Scheduled(fixedDelay = 1000 * 10) |
||||
public void controlEndScheduler() { |
||||
// logger.debug("=================== {Control End Scheduler} ===================== ");
|
||||
service.controlEndProcess(); |
||||
} |
||||
|
||||
/** |
||||
* TODO 비행 시작 지점 주소 변환 처리 |
||||
* |
||||
* 실행 주기 : 10초 |
||||
*/ |
||||
@Scheduled(fixedDelay = 1000 * 10) |
||||
public void transferLocationScheduler() { |
||||
service.controlEndProcess(); |
||||
} |
||||
|
||||
/** |
||||
* TODO 비행 시작 지점 주소 변환 처리 |
||||
* <p> |
||||
* 실행 주기 : 10초 |
||||
*/ |
||||
@Scheduled(fixedDelay = 1000 * 10) |
||||
public void transferLocationScheduler() { |
||||
// logger.debug("=================== {transferLocation} ===================== ");
|
||||
service.transferLocationProcess(); |
||||
} |
||||
service.transferLocationProcess(); |
||||
} |
||||
|
||||
} |
||||
|
Loading…
Reference in new issue