Skip to content

main병합 #243

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Yyang-YE merged 2 commits into from
Nov 28, 2025
Merged

main병합 #243

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
6e572e6
스케줄러 예외 처리
dlwls423 Nov 27, 2025
800e491
Merge pull request #242 from DevKor-github/fix/scheduler
dlwls423 Nov 28, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
63 changes: 40 additions & 23 deletions src/main/java/devkor/com/teamcback/domain/operatingtime/scheduler/OperatingScheduler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,45 +30,62 @@ public class OperatingScheduler {
private static Boolean isEvenWeek = null;

@Scheduled(cron = "0 0 0 * * *") // 매일 자정마다
// @EventListener(ApplicationReadyEvent.class)
@EventListener(ApplicationReadyEvent.class)
public void updateOperatingTime() {
setState();
log.info("운영 시간 업데이트");

redisLockUtil.executeWithLock("lock", 1, 300, () -> {
operatingService.updateOperatingTime(dayOfWeek, isHoliday, isVacation, isEvenWeek);
return null;
});
try{
setState();
log.info("운영 시간 업데이트");

redisLockUtil.executeWithLock("lock", 1, 300, () -> {
operatingService.updateOperatingTime(dayOfWeek, isHoliday, isVacation, isEvenWeek);
return null;
});
} catch (Exception e) {
log.info("updateOperatingTime() 작업 실패: {}", e.getMessage(), e);
}
}


// @Scheduled(cron = "30 35 * * * *") // 테스트용
// @EventListener(ApplicationReadyEvent.class) // 테스트용
@Scheduled(cron = "0 */10 9-18 * * *") // 10분마다
public void updateOperatingDuringPeakHour() {
log.info("운영 여부 업데이트");
redisLockUtil.executeWithLock("lock", 1, 300, () -> {
operatingService.updateIsOperating(LocalTime.now(), dayOfWeek, isHoliday, isVacation, isEvenWeek);
return null;
});
try{
log.info("운영 여부 업데이트");
redisLockUtil.executeWithLock("lock", 1, 300, () -> {
operatingService.updateIsOperating(LocalTime.now(), dayOfWeek, isHoliday, isVacation, isEvenWeek);
return null;
});
} catch (Exception e) {
log.info("updateOperatingDuringPeakHour() 작업 실패: {}", e.getMessage(), e);
}
}

@Scheduled(cron = "0 0,30 0-8,19-23 * * *") // 30분마다
public void updateOperating() {
log.info("운영 여부 업데이트");
redisLockUtil.executeWithLock("lock", 1, 300, () -> {
operatingService.updateIsOperating(LocalTime.now(), dayOfWeek, isHoliday, isVacation, isEvenWeek);
return null;
});
try{
log.info("운영 여부 업데이트");
redisLockUtil.executeWithLock("lock", 1, 300, () -> {
operatingService.updateIsOperating(LocalTime.now(), dayOfWeek, isHoliday, isVacation, isEvenWeek);
return null;
});
} catch (Exception e) {
log.info("updateOperating() 작업 실패: {}", e.getMessage(), e);
}
}

// 장소 운영 시간 저장 - 건물의 운영 시간에 변동이 있을 경우 1회 작동
@EventListener(ApplicationReadyEvent.class)
public void updatePlaceOperatingTime() {
log.info("장소 운영 시간 업데이트");
redisLockUtil.executeWithLock("lock", 1, 300, () -> {
operatingService.updatePlaceOperatingTime();
return null;
});
try{
log.info("장소 운영 시간 업데이트");
redisLockUtil.executeWithLock("lock", 1, 300, () -> {
operatingService.updatePlaceOperatingTime();
return null;
});
} catch (Exception e) {
log.info("updatePlaceOperatingTime() 작업 실패: {}", e.getMessage(), e);
}
}

private void setState() {
Expand Down
Loading