[v1.2.0] 미션 및 레벨 프로덕션 적용

deploy/prod/grafana/provisioning/alerting/contact-points.yml

@@ -10,15 +10,59 @@ contactPoints:
         settings:
           url: $DISCORD_MONITOR_WEBHOOK_URL
           use_discord_username: false
-          title: '{{ if eq .Status "firing" }}{{ else }}[복구] {{ end }} {{ .CommonLabels.alertname }}'
+          title: '{{ if eq .CommonLabels.alertname "[CRITICAL] 5xx 에러율 1% 초과" }}{{ if eq .Status "firing" }}{{ .CommonLabels.alertname }}{{ else }}[RESOLVED] 5xx 에러율 정상화{{ end }}{{ else }}{{ if eq .Status "firing" }}{{ else }}[복구] {{ end }}{{ .CommonLabels.alertname }}{{ end }}'
           message: |
+            {{ if eq .CommonLabels.alertname "[CRITICAL] 5xx 에러율 1% 초과" }}
+            {{ $notificationStatus := .Status }}
             {{ range .Alerts }}
+            {{ if eq $notificationStatus "firing" }}
+            Time        : {{ .StartsAt | tz "Asia/Seoul" | date "2006-01-02 15:04:05" }} (KST)
+            5xx Rate    : {{ .Annotations.error_rate }}
+
+            ────────────────────────
+
             {{ .Annotations.summary }}
-            
+
             확인 필요
             {{ .Annotations.description }}
-
+
+            ────────────────────────
+
+            Explore Logs
+            {{ .Annotations.explore_url }}
+
+            Alert
+            {{ .GeneratorURL }}
+
+            Dashboard
+            {{ .DashboardURL }}
+            {{ else }}
+            Detected    : {{ .StartsAt | tz "Asia/Seoul" | date "2006-01-02 15:04:05" }} (KST)
+            Resolved    : {{ .EndsAt | tz "Asia/Seoul" | date "2006-01-02 15:04:05" }} (KST)
+            Duration    : {{ .EndsAt.Sub .StartsAt }}
+
+            최근 5분 기준 5xx 에러율이 1% 이하로 내려갔습니다.
+
+            ────────────────────────
+
+            Explore Logs
+            {{ .Annotations.explore_url }}
+
+            Alert
+            {{ .GeneratorURL }}
+
+            Dashboard
+            {{ .DashboardURL }}
+            {{ end }}
+            {{ end }}
+            {{ else }}
+            {{ range .Alerts }}
+            {{ .Annotations.summary }}
+
+            확인 필요
+            {{ .Annotations.description }}
+
             관련 모니터링 링크
             - Grafana Alert: {{ .GeneratorURL }}
             {{ end }}
-
+            {{ end }}

deploy/prod/grafana/provisioning/alerting/rules.yml

@@ -1,5 +1,9 @@
 apiVersion: 1
 
+deleteRules:
+  - orgId: 1
+    uid: didit-http-5xx-detected
+
 groups:
   - orgId: 1
     name: didit-prod-critical
@@ -69,74 +73,6 @@ groups:
             - 최근 트래픽 증가 여부
             - 메모리 누수 및 OOM 로그
 
-      - uid: didit-http-5xx-detected
-        title: '[CRITICAL] 5xx 에러 발생'
-        condition: C
-        data:
-          - refId: A
-            datasourceUid: prometheus
-            relativeTimeRange:
-              from: 120
-              to: 0
-            model:
-              refId: A
-              expr: |
-                sum(
-                  increase(
-                    http_server_requests_seconds_count{
-                      environment="prod",
-                      status=~"5.."
-                    }[1m]
-                  )
-                )
-              instant: true
-              intervalMs: 1000
-              maxDataPoints: 43200
-
-          - refId: B
-            datasourceUid: __expr__
-            model:
-              refId: B
-              type: reduce
-              expression: A
-              reducer: last
-              datasource:
-                type: __expr__
-                uid: __expr__
-
-          - refId: C
-            datasourceUid: __expr__
-            model:
-              refId: C
-              type: threshold
-              expression: B
-              conditions:
-                - evaluator:
-                    type: gt
-                    params: [ 0 ]
-                  operator:
-                    type: and
-                  query:
-                    params: [ C ]
-                  reducer:
-                    type: last
-                  type: query
-              datasource:
-                type: __expr__
-                uid: __expr__
-
-        noDataState: OK
-        execErrState: Alerting
-        for: 0s
-        labels:
-          severity: critical
-        annotations:
-          summary: 5xx 에러가 발생했습니다.
-          description: |
-            - API 서버 ERROR 로그
-            - 발생 API 및 예외 내용
-            - DB 및 외부 연동 서비스 상태
-
       - uid: didit-http-5xx-rate-critical
         title: '[CRITICAL] 5xx 에러율 1% 초과'
         condition: C
@@ -204,14 +140,19 @@ groups:
         noDataState: OK
         execErrState: Alerting
         for: 2m
+        dashboardUid: dfp8jkcluca2oe
+
         labels:
           severity: critical
+
         annotations:
           summary: 5xx 에러율이 1%를 초과했습니다.
+          error_rate: '{{ humanizePercentage $values.B.Value }}'
           description: |
             - API 서버 로그
             - 최근 배포 여부
             - 특정 API 및 외부 서비스 장애 여부
+          explore_url: https://monitoring.didit.ai.kr/explore?schemaVersion=1&panes=%7B%22ttc%22:%7B%22datasource%22:%22loki%22,%22queries%22:%5B%7B%22refId%22:%22A%22,%22expr%22:%22%7Bcontainer%3D~%5C%22didit-api-%28blue%7Cgreen%29%5C%22%7D%20%7C%3D%20%5C%22ERROR%5C%22%22,%22queryType%22:%22range%22,%22datasource%22:%7B%22type%22:%22loki%22,%22uid%22:%22loki%22%7D,%22editorMode%22:%22code%22%7D%5D,%22range%22:%7B%22from%22:%22now-15m%22,%22to%22:%22now%22%7D,%22panelsState%22:%7B%22logs%22:%7B%22columns%22:%7B%220%22:%22Time%22,%221%22:%22Line%22%7D,%22visualisationType%22:%22table%22,%22labelFieldName%22:%22labels%22%7D%7D%7D%7D&orgId=1
 
       - uid: didit-hikaricp-usage-critical
         title: '[CRITICAL] HikariCP 커넥션 풀 사용률 90% 초과'

src/docs/asciidoc/app/index.adoc

@@ -19,6 +19,7 @@ include::auth.adoc[]
 include::user.adoc[]
 include::retrospect.adoc[]
 include::badge.adoc[]
+include::mission.adoc[]
 include::notice.adoc[]
 include::inquiry.adoc[]
 include::project.adoc[]

src/docs/asciidoc/app/mission.adoc

@@ -0,0 +1,32 @@
+= 미션 API
+
+== 현재 미션 조회
+
+=== Request
+
+include::{snippets}/mission/current/http-request.adoc[]
+
+=== Response
+
+include::{snippets}/mission/current/http-response.adoc[]
+include::{snippets}/mission/current/response-fields.adoc[]
+
+== 레벨업 팝업 확인
+
+=== Request
+
+include::{snippets}/mission/level-up-confirm/http-request.adoc[]
+
+=== Response
+
+include::{snippets}/mission/level-up-confirm/http-response.adoc[]
+
+== 실패 팝업 확인 및 재도전
+
+=== Request
+
+include::{snippets}/mission/retry/http-request.adoc[]
+
+=== Response
+
+include::{snippets}/mission/retry/http-response.adoc[]

src/main/kotlin/com/didit/adapter/integration/scheduler/MissionScheduler.kt

@@ -0,0 +1,63 @@
+package com.didit.adapter.integration.scheduler
+
+import com.didit.application.achievement.required.MissionRepository
+import com.didit.application.achievement.required.UserMissionRepository
+import com.didit.application.retrospect.required.RetrospectiveRepository
+import com.didit.domain.shared.ServiceTime
+import jakarta.transaction.Transactional
+import org.slf4j.LoggerFactory
+import org.springframework.scheduling.annotation.Scheduled
+import org.springframework.stereotype.Component
+import java.time.temporal.TemporalAdjusters
+
+@Component
+class MissionScheduler(
+    private val userMissionRepository: UserMissionRepository,
+    private val missionRepository: MissionRepository,
+    private val retrospectiveRepository: RetrospectiveRepository,
+) {
+    companion object {
+        private val logger = LoggerFactory.getLogger(MissionScheduler::class.java)
+    }
+
+    @Scheduled(cron = "0 0 * * * *")
+    @Transactional
+    fun checkExpiredLv2Missions() {
+        val expiredMissions = userMissionRepository.findExpiredLv2Missions()
+
+        expiredMissions.forEach { userMission ->
+            userMission.setFailureWaitingConfirm()
+            userMissionRepository.save(userMission)
+        }
+
+        logger.info("Lv2 만료 미션 검사 완료 - count: ${expiredMissions.size}")
+    }
+
+    @Scheduled(cron = "0 0 0 ? * MON")
+    @Transactional
+    fun checkConsecutiveWeekFailure() {
+        val consecutiveWeekMissions = userMissionRepository.findConsecutiveWeekMissionsInProgress()
+
+        consecutiveWeekMissions.forEach { userMission ->
+            val lastWeekStart =
+                ServiceTime.today().with(TemporalAdjusters.previousOrSame(java.time.DayOfWeek.MONDAY)).minusWeeks(1)
+
+            val lastWeekRetroCount =
+                retrospectiveRepository.countCompletedByUserIdAndPeriod(
+                    userId = userMission.userId,
+                    from = ServiceTime.startOfDayUtc(lastWeekStart),
+                    to = ServiceTime.startOfDayUtc(lastWeekStart.plusWeeks(1)),
+                )
+
+            if (lastWeekRetroCount == 0) {
+                userMission.setFailureWaitingConfirm()
+                userMissionRepository.save(userMission)
+                logger.info(
+                    "연속주차 실패 - userId: ${userMission.userId}, missionId: ${userMission.missionId}",
+                )
+            }
+        }
+
+        logger.info("연속주차 실패 검사 완료 - total: ${consecutiveWeekMissions.size}")
+    }
+}

src/main/kotlin/com/didit/adapter/persistence/achievement/OrganizationAchievementReaderImpl.kt

@@ -0,0 +1,30 @@
+package com.didit.adapter.persistence.achievement
+
+import com.didit.application.achievement.required.OrganizationAchievementReader
+import com.didit.application.organization.required.ProjectRepository
+import com.didit.application.retrospect.required.RetrospectiveRepository
+import org.springframework.stereotype.Component
+import java.util.UUID
+
+@Component
+class OrganizationAchievementReaderImpl(
+    private val projectRepository: ProjectRepository,
+    private val retrospectiveRepository: RetrospectiveRepository,
+) : OrganizationAchievementReader {
+    override fun countProjects(userId: UUID): Int = projectRepository.findAllByUserIdAndDeletedAtIsNull(userId).size
+
+    override fun countProjectAssignedRetros(userId: UUID): Int =
+        retrospectiveRepository
+            .findAllCompletedByUserId(userId)
+            .count { it.projectId != null }
+
+    override fun maxRetroCountInOneProject(userId: UUID): Int =
+        retrospectiveRepository
+            .findAllCompletedByUserId(userId)
+            .mapNotNull { it.projectId }
+            .groupingBy { it }
+            .eachCount()
+            .values
+            .maxOrNull()
+            ?: 0
+}

src/main/kotlin/com/didit/adapter/persistence/achievement/RetrospectAchievementReaderImpl.kt

@@ -4,27 +4,53 @@ import com.didit.application.achievement.required.RetrospectAchievementReader
 import com.didit.application.retrospect.required.RetrospectiveRepository
 import com.didit.domain.retrospect.RetroStatus
 import com.didit.domain.shared.ServiceTime
+import org.springframework.beans.factory.annotation.Value
 import org.springframework.stereotype.Component
 import java.time.DayOfWeek
+import java.time.LocalDate
+import java.time.LocalDateTime
 import java.util.UUID
 
 @Component
 class RetrospectAchievementReaderImpl(
     private val retrospectiveRepository: RetrospectiveRepository,
+    @Value("\${achievement.feature-launched-at:2026-06-30T00:00:00}") private val featureLaunchedAt: LocalDateTime,
 ) : RetrospectAchievementReader {
-    override fun countCompletedRetros(userId: UUID): Int =
-        retrospectiveRepository.countByUserIdAndStatusAndDeletedAtIsNull(userId, RetroStatus.COMPLETED)
+    companion object {
+        private const val MAX_CONSECUTIVE_WEEKS_SCAN = 60
+    }
 
-    override fun countDeepQuestionAnswers(userId: UUID): Int =
-        retrospectiveRepository
-            .findAllCompletedByUserId(userId)
-            .sumOf { it.countDeepQuestionAnswers() }
+    override fun countCompletedRetros(userId: UUID): Int = completedAtsSinceLaunch(userId).size
+
+    override fun countRetrosInWeek(
+        userId: UUID,
+        weekStartKst: LocalDate,
+    ): Int = weekCountsByMondayKst(userId)[weekStartKst] ?: 0
+
+    override fun countConsecutiveWeeksWithMinRetros(
+        userId: UUID,
+        weeklyMinCount: Int,
+    ): Int {
+        val weekCounts = weekCountsByMondayKst(userId)
+        var weekStart = ServiceTime.today().with(DayOfWeek.MONDAY)
+        var consecutive = 0
+        repeat(MAX_CONSECUTIVE_WEEKS_SCAN) {
+            val count = weekCounts[weekStart] ?: 0
+            if (count < weeklyMinCount) return consecutive
+            consecutive += 1
+            weekStart = weekStart.minusWeeks(1)
+        }
+        return consecutive
+    }
 
-    override fun countWeeklyGoalAchievedWeeks(userId: UUID): Int =
+    private fun weekCountsByMondayKst(userId: UUID): Map<LocalDate, Int> =
+        completedAtsSinceLaunch(userId)
+            .map { ServiceTime.toServiceDate(it) }
+            .groupingBy { it.with(DayOfWeek.MONDAY) }
+            .eachCount()
+
+    private fun completedAtsSinceLaunch(userId: UUID): List<LocalDateTime> =
         retrospectiveRepository
             .findCompletedAtByUserIdAndStatusAndDeletedAtIsNull(userId, RetroStatus.COMPLETED)
-            .map { ServiceTime.toServiceDate(it) }
-            .distinct()
-            .groupBy { it.with(DayOfWeek.MONDAY) }
-            .count { (_, dates) -> dates.size >= 3 }
+            .filter { !it.isBefore(featureLaunchedAt) }
 }

src/main/kotlin/com/didit/adapter/webapi/achievement/BadgeApi.kt

@@ -21,6 +21,12 @@ class BadgeApi(
         @CurrentUserId userId: UUID,
     ): SuccessResponse<List<BadgeResponse>> = SuccessResponse.of(badgeFinder.findAll(userId))
 
+    @RequireAuth
+    @GetMapping("/recent")
+    fun findRecent(
+        @CurrentUserId userId: UUID,
+    ): SuccessResponse<List<BadgeResponse>> = SuccessResponse.of(badgeFinder.findRecent(userId))
+
     @RequireAuth
     @GetMapping("/popup")
     fun findUnnotified(