Skip to content

fix(streak): format reminder title templates #337

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
SolfE merged 1 commit into from
Jun 23, 2026
Merged

fix(streak): format reminder title templates #337

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
129 changes: 70 additions & 59 deletions src/main/java/com/linglevel/api/streak/scheduler/StreakProtectionScheduler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,32 +7,24 @@
import com.linglevel.api.fcm.service.FcmMessagingService;
import com.linglevel.api.i18n.CountryCode;
import com.linglevel.api.i18n.LanguageCode;
import com.linglevel.api.streak.entity.DailyCompletion;
import com.linglevel.api.streak.entity.FreezeTransaction;
import com.linglevel.api.streak.entity.StreakReminderMessage;
import com.linglevel.api.streak.entity.UserStudyReport;
import com.linglevel.api.streak.repository.DailyCompletionRepository;
import com.linglevel.api.streak.repository.FreezeTransactionRepository;
import com.linglevel.api.streak.repository.UserStudyReportRepository;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.Duration;
import java.time.Instant;
import java.time.LocalDate;
import java.time.ZoneId;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
* 스트릭 보호 알림 스케줄러
* 매일 밤 9시에 실행하여 스트릭이 깨지지 않도록 알림을 전송합니다.
* - 조건: currentStreak > 0 && 오늘 학습 미완료
*/
/** 스트릭 보호 알림 스케줄러 매일 밤 9시에 실행하여 스트릭이 깨지지 않도록 알림을 전송합니다. - 조건: currentStreak > 0 && 오늘 학습 미완료 */
@Component
@RequiredArgsConstructor
@Slf4j
Expand All @@ -50,15 +42,14 @@ public class StreakProtectionScheduler {
private static final String CAMPAIGN_ID = "streak_protection";
private static final int BATCH_SIZE = 500;

/**
* 매일 밤 9시에 실행: 스트릭 보호 알림 전송
*/
/** 매일 밤 9시에 실행: 스트릭 보호 알림 전송 */
@Scheduled(cron = "0 0 21 * * *", zone = "Asia/Seoul")
public void sendStreakProtectionNotifications() {
Instant startTime = Instant.now();
LocalDate today = LocalDate.now(KST);

log.info("[Streak Protection] Starting notification batch at 21:00 KST for date: {}", today);
log.info(
"[Streak Protection] Starting notification batch at 21:00 KST for date: {}", today);

int candidateUsers = 0;
int usersWithoutCompletion = 0;
Expand All @@ -68,7 +59,8 @@ public void sendStreakProtectionNotifications() {

try {
// 1. 현재 스트릭이 있는 모든 활성 사용자 조회 (currentStreak > 0)
List<UserStudyReport> activeUsers = userStudyReportRepository.findByCurrentStreakGreaterThan(0);
List<UserStudyReport> activeUsers =
userStudyReportRepository.findByCurrentStreakGreaterThan(0);
candidateUsers = activeUsers.size();

log.info("[Streak Protection] Found {} active users with streak > 0", candidateUsers);
Expand All @@ -78,8 +70,8 @@ public void sendStreakProtectionNotifications() {
String userId = report.getUserId();

// 2-1. 오늘 학습 완료 여부 확인
boolean hasCompletedToday = dailyCompletionRepository
.existsByUserIdAndCompletionDate(userId, today);
boolean hasCompletedToday =
dailyCompletionRepository.existsByUserIdAndCompletionDate(userId, today);
if (hasCompletedToday) {
continue; // 이미 학습 완료한 사용자는 스킵
}
Expand All @@ -93,9 +85,8 @@ public void sendStreakProtectionNotifications() {
}
usersWithTokens++;

List<String> fcmTokens = tokens.stream()
.map(FcmToken::getFcmToken)
.collect(Collectors.toList());
List<String> fcmTokens =
tokens.stream().map(FcmToken::getFcmToken).collect(Collectors.toList());

// 2-3. 언어 결정
LanguageCode languageCode = determineLanguageFromTokens(tokens);
Expand All @@ -104,83 +95,105 @@ public void sendStreakProtectionNotifications() {
boolean usedFreezeYesterday = checkIfFreezeUsedYesterday(userId, today);

// 2-5. 메시지 타입 결정 (프리즈 사용 여부에 따라)
StreakReminderMessage messageType = usedFreezeYesterday
? StreakReminderMessage.STREAK_SAVED_BY_FREEZE
: StreakReminderMessage.STREAK_PROTECTION;
StreakReminderMessage messageType =
usedFreezeYesterday
? StreakReminderMessage.STREAK_SAVED_BY_FREEZE
: StreakReminderMessage.STREAK_PROTECTION;

StreakReminderMessage.Message message = messageType.getRandomMessage(languageCode);
String title = String.format(message.getTitle(), report.getCurrentStreak());
String body = String.format(message.getBodyFormat(), report.getCurrentStreak());

FcmMessageRequest messageRequest = FcmMessageRequest.builder()
.title(message.getTitle())
.body(body)
.type(NOTIFICATION_TYPE)
.campaignId(CAMPAIGN_ID)
.action("open_app")
.build();
FcmMessageRequest messageRequest =
FcmMessageRequest.builder()
.title(title)
.body(body)
.type(NOTIFICATION_TYPE)
.campaignId(CAMPAIGN_ID)
.action("open_app")
.build();

// 2-5. 알림 전송
try {
if (fcmTokens.size() == 1) {
fcmMessagingService.sendMessage(fcmTokens.get(0), messageRequest);
notificationsSent++;
log.debug("[Streak Protection] Sent to user: {} (streak: {}, lang: {}, type: {})",
userId, report.getCurrentStreak(), languageCode, messageType);
log.debug(
"[Streak Protection] Sent to user: {} (streak: {}, lang: {}, type: {})",
userId,
report.getCurrentStreak(),
languageCode,
messageType);
} else {
BatchResponse response = fcmMessagingService.sendMulticastMessage(fcmTokens, messageRequest);
BatchResponse response =
fcmMessagingService.sendMulticastMessage(fcmTokens, messageRequest);

for (int i = 0; i < response.getResponses().size(); i++) {
if (response.getResponses().get(i).isSuccessful()) {
notificationsSent++;
} else {
notificationsFailed++;
String failedToken = fcmTokens.get(i);
log.warn("[Streak Protection] Failed to send to user: {}, token error: {}",
userId, response.getResponses().get(i).getException().getMessage());
log.warn(
"[Streak Protection] Failed to send to user: {}, token error: {}",
userId,
response.getResponses().get(i).getException().getMessage());
fcmTokenService.deactivateToken(failedToken);
}
}

log.debug("[Streak Protection] Multicast to user: {} - Success: {}, Failed: {}",
userId, response.getSuccessCount(), response.getFailureCount());
log.debug(
"[Streak Protection] Multicast to user: {} - Success: {}, Failed: {}",
userId,
response.getSuccessCount(),
response.getFailureCount());
}
} catch (Exception e) {
notificationsFailed++;
log.warn("[Streak Protection] Failed to send notification to user: {}", userId, e);
log.warn(
"[Streak Protection] Failed to send notification to user: {}",
userId,
e);
}
}

long durationMillis = Duration.between(startTime, Instant.now()).toMillis();

log.info("[Streak Protection] Completed. Candidates: {}, Without completion: {}, With tokens: {}, " +
"Sent: {}, Failed: {}, Duration: {}ms",
candidateUsers, usersWithoutCompletion, usersWithTokens,
notificationsSent, notificationsFailed, durationMillis);
log.info(
"[Streak Protection] Completed. Candidates: {}, Without completion: {}, With tokens: {}, "
+ "Sent: {}, Failed: {}, Duration: {}ms",
candidateUsers,
usersWithoutCompletion,
usersWithTokens,
notificationsSent,
notificationsFailed,
durationMillis);

} catch (Exception e) {
log.error("[Streak Protection] Critical error. Candidates: {}, Without completion: {}, Sent: {}, Failed: {}",
candidateUsers, usersWithoutCompletion, notificationsSent, notificationsFailed, e);
log.error(
"[Streak Protection] Critical error. Candidates: {}, Without completion: {}, Sent: {}, Failed: {}",
candidateUsers,
usersWithoutCompletion,
notificationsSent,
notificationsFailed,
e);
}
}

/**
* 어제 프리즈가 사용되었는지 확인합니다.
* 어제 날짜(00:00 ~ 23:59)에 amount가 -1인 트랜잭션이 있으면 프리즈 사용됨
*/
/** 어제 프리즈가 사용되었는지 확인합니다. 어제 날짜(00:00 ~ 23:59)에 amount가 -1인 트랜잭션이 있으면 프리즈 사용됨 */
private boolean checkIfFreezeUsedYesterday(String userId, LocalDate today) {
LocalDate yesterday = today.minusDays(1);
Instant yesterdayStart = yesterday.atStartOfDay(KST).toInstant();
Instant yesterdayEnd = today.atStartOfDay(KST).toInstant();

List<FreezeTransaction> transactions = freezeTransactionRepository
.findByUserIdAndAmountAndCreatedAtBetween(userId, -1, yesterdayStart, yesterdayEnd);
List<FreezeTransaction> transactions =
freezeTransactionRepository.findByUserIdAndAmountAndCreatedAtBetween(
userId, -1, yesterdayStart, yesterdayEnd);

return !transactions.isEmpty();
}

/**
* FcmToken 리스트에서 사용자의 선호 언어를 결정합니다.
*/
/** FcmToken 리스트에서 사용자의 선호 언어를 결정합니다. */
private LanguageCode determineLanguageFromTokens(List<FcmToken> tokens) {
if (tokens.isEmpty()) {
return LanguageCode.EN;
Expand All @@ -190,9 +203,7 @@ private LanguageCode determineLanguageFromTokens(List<FcmToken> tokens) {
return convertCountryCodeToLanguageCode(countryCode);
}

/**
* CountryCode를 LanguageCode로 변환합니다.
*/
/** CountryCode를 LanguageCode로 변환합니다. */
private LanguageCode convertCountryCodeToLanguageCode(CountryCode countryCode) {
if (countryCode == null) {
return LanguageCode.EN;
Expand Down
Loading
Loading