getAllSettings() {
public Setting getById(Long settingId) {
return settingRepository.findById(settingId).get();
}
+
+ @Transactional(readOnly = true)
+ public SettingDTO getSettingById(Long id) {
+ Setting setting = settingRepository.findById(id)
+ .orElseThrow(() -> new SettingException(ErrorCode.SETTING_NOT_FOUND));
+
+ return convertToDTO(setting);
+ }
+
}
\ No newline at end of file
diff --git a/SpringBoot/src/main/java/Baemin/News_Deliver/Global/Scheduler/TaskSchedulerService.java b/SpringBoot/src/main/java/Baemin/News_Deliver/Global/Scheduler/TaskSchedulerService.java
index 3eedf69..1a14426 100644
--- a/SpringBoot/src/main/java/Baemin/News_Deliver/Global/Scheduler/TaskSchedulerService.java
+++ b/SpringBoot/src/main/java/Baemin/News_Deliver/Global/Scheduler/TaskSchedulerService.java
@@ -30,15 +30,18 @@
* 동적으로 카카오 뉴스 메시지를 전송할 스케줄을 등록/취소하는 서비스입니다.
*
*
- * Spring의 {@link TaskScheduler}를 사용하여 사용자별로 개별 {@link ScheduledFuture} 작업을 관리합니다.
+ * Spring의 {@link TaskScheduler}를 사용하여 사용자별로 개별 {@link ScheduledFuture} 작업을
+ * 관리합니다.
* 각 작업은 userId-settingId 조합으로 유니크하게 식별됩니다.
*
*
- * 기능 요약:
+ *
+ * 기능 요약:
+ *
*
- * - 사용자 설정에 따른 cron 스케줄 등록
- * - 기존 스케줄 취소 및 갱신
- * - 스케줄 실행 시 카카오 메시지 발송 트리거
+ * - 사용자 설정에 따른 cron 스케줄 등록
+ * - 기존 스케줄 취소 및 갱신
+ * - 스케줄 실행 시 카카오 메시지 발송 트리거
*
*/
@@ -47,7 +50,7 @@
@Slf4j
public class TaskSchedulerService {
- @Qualifier("customTaskScheduler") //커스텀한 테스크 스케쥴러로 등록함.
+ @Qualifier("customTaskScheduler") // 커스텀한 테스크 스케쥴러로 등록함.
private final TaskScheduler taskScheduler;
private final KakaoMessageService kakaoMessageService;
@@ -75,6 +78,9 @@ public class TaskSchedulerService {
public void scheduleUser(Setting setting) {
Long settingId = setting.getId();
+ // findByIdWithAllAssociations 사용
+ // setting = settingRepository.findByIdWithAllAssociations(settingId)
+ // .orElseThrow(() -> new KakaoException(ErrorCode.SETTING_NOT_FOUND));
// Fetch Join으로 days 미리 가져와서 LazyInitializationException 방지
setting = settingRepository.findByIdWithDays(settingId)
.orElseThrow(() -> new KakaoException(ErrorCode.SETTING_NOT_FOUND));
@@ -82,7 +88,7 @@ public void scheduleUser(Setting setting) {
Long userId = setting.getUser().getId();
String taskKey = generateTaskKey(userId, settingId);
- // 이미 등록된 경우 기존 스케줄 취소
+ /* 이미 등록된 경우 기존 스케줄 취소 */
if (scheduledTasks.containsKey(taskKey)) {
cancelUser(userId, settingId);
}
@@ -102,7 +108,17 @@ public void scheduleUser(Setting setting) {
log.info("[Scheduler] 유저 {} / setting {} 메시지 발송 트리거 - {}", userId, settingId, LocalDateTime.now());
try {
- Optional optionalSetting = settingRepository.findById(settingId);
+
+ /**
+ *
+ * Hot Fix : Setting Keyword Feth Join 문제 해결 시도
+ *
+ *
+ */
+ Optional optionalSetting = settingRepository.findByIdWithDays(settingId);
+ // Optional optionalSetting =
+ // settingRepository.findByIdWithAllAssociations(settingId); //안됨됨
+ // Optional optionalSetting = settingRepository.findById(settingId);
if (optionalSetting.isEmpty()) {
log.warn("[Scheduler] 유저 {} / setting {} 설정 정보가 없음", userId, settingId);
@@ -111,8 +127,12 @@ public void scheduleUser(Setting setting) {
Setting settings = optionalSetting.get();
- log.info("[Scheduler] 유저 {} / setting {} 키워드: {}, 제외 키워드: {}",
- userId, settingId, settings.getKeywords(), settings.getBlockKeywords());
+ // blockKeywords, keywords가 꼭 필요하다면 강제 초기화
+ // Hibernate.initialize(settings.getBlockKeywords());
+ // Hibernate.initialize(settings.getKeywords());
+
+ // log.info("[Scheduler] 유저 {} / setting {} 키워드: {}, 제외 키워드: {}",
+ // userId, settingId, settings.getKeywords(), settings.getBlockKeywords());
kakaoMessageService.sendKakaoMessage(refreshAccessToken, userId);
@@ -152,7 +172,7 @@ public void cancelUser(Long userId, Long settingId) {
* @param settingId 설정 ID
* @return userId-settingId 형식의 문자열 키
*/
- //중복 스케쥴러 삭제 메서드용
+ // 중복 스케쥴러 삭제 메서드용
private String generateTaskKey(Long userId, Long settingId) {
return userId + "-" + settingId;
}