feat: 스케줄러 수정 (#496)

Nexters · Oct 3, 2024 · 5fcd36a · 5fcd36a
1 parent c622bf8
commit 5fcd36a
Showing 1 changed file with 18 additions and 18 deletions.
diff --git a/app/src/main/kotlin/com/nexters/bottles/app/notification/component/StatisticsScheduler.kt b/app/src/main/kotlin/com/nexters/bottles/app/notification/component/StatisticsScheduler.kt
@@ -64,10 +64,10 @@ class StatisticsScheduler(
                         "type" to "mrkdwn",
                         "text" to """
                     지표 물어다주는 새 :bird: 
-                    전체 유저: ${currentUser} 명 
-                    어제 가입 유저: ${yesterdayRegisterUser} 명 
-                    어제 탈퇴 유저: ${yesterdayLeaveUser} 명 
-                    어제 핑퐁 시작 유저: ${yesterdayStartPingpong} 명 
+                    전체 유저: ${currentUser.count()} 명 
+                    어제 가입 유저: ${yesterdayRegisterUser.count()} 명 
+                    어제 탈퇴 유저: ${yesterdayLeaveUser.count()} 명 
+                    어제 핑퐁 시작 유저: ${yesterdayStartPingpong.count()} 명 
                 """.trimIndent()
                     )
                 )
@@ -76,14 +76,14 @@ class StatisticsScheduler(
 
         log.info { "Sending request to Slack: ${ObjectMapper().writeValueAsString(request)}" }
 
-//        val response = webClient.post()
-//            .contentType(MediaType.APPLICATION_JSON)
-//            .body(BodyInserters.fromValue(request))
-//            .retrieve()
-//            .bodyToMono(String::class.java)
-//            .block()
-//
-//        log.info { "response: $response" }
+        val response = webClient.post()
+            .contentType(MediaType.APPLICATION_JSON)
+            .body(BodyInserters.fromValue(request))
+            .retrieve()
+            .bodyToMono(String::class.java)
+            .block()
+
+        log.info { "response: $response" }
     }
 
     @Scheduled(cron = "* * 10 * * 1")
@@ -121,11 +121,11 @@ class StatisticsScheduler(
             )
         )
 
-//        val response = webClient.post()
-//            .contentType(MediaType.APPLICATION_JSON)
-//            .body(BodyInserters.fromValue(request))
-//            .retrieve()
-//            .bodyToMono(String::class.java)
-//            .block()
+        val response = webClient.post()
+            .contentType(MediaType.APPLICATION_JSON)
+            .body(BodyInserters.fromValue(request))
+            .retrieve()
+            .bodyToMono(String::class.java)
+            .block()
     }
 }