@Scheduled 운영

@Configuration
@EnableScheduling
public class SchedulingConfig {

    @Bean
    public ThreadPoolTaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler s = new ThreadPoolTaskScheduler();
        s.setPoolSize(4);                              // 배치 수 + 여유 1
        s.setThreadNamePrefix("batch-");
        s.setErrorHandler(t ->
                log.error("스케줄 작업 실패", t));       // 예외 삼키지 않고 로그
        s.setWaitForTasksToCompleteOnShutdown(true);    // shutdown 시 진행 중 대기
        s.setAwaitTerminationSeconds(30);
        return s;
    }
}

@Component
public class SyncJob {

    @Scheduled(fixedDelayString = "${sync.delay:60000}")
    public void syncFromLegacy() { /* ... */ }

    @Scheduled(cron = "0 0 2 * * *", zone = "Asia/Seoul")
    public void dailyReport() { /* ... */ }
}

<!-- pom.xml -->
<dependency>
    <groupId>net.javacrumbs.shedlock</groupId>
    <artifactId>shedlock-spring</artifactId>
</dependency>
<dependency>
    <groupId>net.javacrumbs.shedlock</groupId>
    <artifactId>shedlock-provider-jdbc-template</artifactId>
</dependency>

@Configuration
@EnableSchedulerLock(defaultLockAtMostFor = "10m")
public class ShedLockConfig {
    @Bean
    public LockProvider lockProvider(DataSource ds) {
        return new JdbcTemplateLockProvider(ds);
    }
}

@Scheduled(cron = "0 0 2 * * *", zone = "Asia/Seoul")
@SchedulerLock(name = "dailyReport",
        lockAtMostFor = "30m", lockAtLeastFor = "1m")
public void dailyReport() { /* ... */ }

-- Oracle 용 shedlock 테이블
CREATE TABLE shedlock (
    name       VARCHAR2(64)  NOT NULL PRIMARY KEY,
    lock_until TIMESTAMP(3)  NOT NULL,
    locked_at  TIMESTAMP(3)  NOT NULL,
    locked_by  VARCHAR2(255) NOT NULL
);

@RestController
@RequestMapping("/admin/jobs")
public class JobAdminController {
    private final SafeTaskHolder dailyReport;   // 스케줄과 같은 인스턴스 공유

    @PostMapping("/{name}/run")
    public ResponseEntity<String> runNow(@PathVariable String name) {
        SafeTask task = dailyReport.find(name);
        if (task.isRunning())                    // 진행 중이면 겹치지 않게 거절
            return ResponseEntity.status(409).body("이미 실행 중입니다");
        new Thread(task).start();
        return ResponseEntity.accepted().body("실행을 시작했습니다");
    }
}

CREATE TABLE job_run (
    job_name    VARCHAR2(64)  NOT NULL,
    started_at  TIMESTAMP     NOT NULL,
    finished_at TIMESTAMP,
    status      VARCHAR2(16)  NOT NULL,   -- RUNNING, OK, FAIL
    message     VARCHAR2(2000)
);

-- 마지막 성공 이후 N분: 알림 조건
SELECT job_name,
       ROUND((SYSDATE - MAX(finished_at)) * 24 * 60) AS minutes_since_ok
FROM   job_run
WHERE  status = 'OK'
GROUP  BY job_name
HAVING (SYSDATE - MAX(finished_at)) * 24 * 60 > 60;  -- 60분 이상 성공 없음