unngå unnødvendige db queries

Statistikk på statusoversikt på behovsmeldinger er ikke så viktig at det må kjøres 3000 ganger om dagen. Endrer derfor til å kun kjøre 1 gang hver natt, for å redusere CPU-load.
navikt · Feb 9, 2024 · f6cd437 · f6cd437
1 parent 578675a
commit f6cd437
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 2 deletions.
diff --git a/src/main/kotlin/no/nav/hjelpemidler/soknad/db/metrics/Metrics.kt b/src/main/kotlin/no/nav/hjelpemidler/soknad/db/metrics/Metrics.kt
@@ -6,7 +6,14 @@ import kotlinx.coroutines.runBlocking
 import mu.KotlinLogging
 import no.nav.hjelpemidler.soknad.db.db.SøknadStore
 import no.nav.hjelpemidler.soknad.db.domain.Status
+import java.time.LocalDate
+import java.time.LocalDateTime
+import java.time.ZoneId
+import java.util.Date
+import java.util.Timer
 import java.util.UUID
+import java.util.concurrent.TimeUnit
+import kotlin.concurrent.timerTask
 
 private val logg = KotlinLogging.logger {}
 
@@ -15,6 +22,20 @@ internal class Metrics(
     private val aivenMetrics: AivenMetrics = AivenMetrics(),
 ) {
 
+    init {
+        Timer("metrics", true).schedule(
+            timerTask {
+                runBlocking {
+                    launch {
+                        countApplicationsByStatus()
+                    }
+                }
+            },
+            midnatt(),
+            TimeUnit.DAYS.toMillis(1),
+        )
+    }
+
     fun measureElapsedTimeBetweenStatusChanges(soknadsId: UUID, status: Status) {
         runBlocking {
             launch(Job()) {
@@ -125,3 +146,9 @@ internal class Metrics(
         const val COUNT_OF_SOKNAD_BY_STATUS = "hm-soknadsbehandling.event.count_of_soknad_by_status"
     }
 }
+
+private fun midnatt() = LocalDate.now().plusDays(1).atStartOfDay().toDate()
+
+private fun LocalDateTime.toDate(): Date {
+    return Date.from(this.atZone(ZoneId.systemDefault()).toInstant())
+}
diff --git a/src/main/kotlin/no/nav/hjelpemidler/soknad/db/routes/SoknadService.kt b/src/main/kotlin/no/nav/hjelpemidler/soknad/db/routes/SoknadService.kt
@@ -348,7 +348,6 @@ internal fun Route.azureAdRoutes(
             call.respond(rowsUpdated)
 
             metrics.measureElapsedTimeBetweenStatusChanges(soknadsId, newStatus)
-            metrics.countApplicationsByStatus()
         } catch (e: Exception) {
             logger.error(e) { "Feilet ved oppdatering av søknad" }
             call.respond(HttpStatusCode.BadRequest, "Feilet ved oppdatering av søknad")
@@ -362,7 +361,6 @@ internal fun Route.azureAdRoutes(
             call.respond(rowsUpdated)
 
             metrics.measureElapsedTimeBetweenStatusChanges(statusMedÅrsak.søknadId, statusMedÅrsak.status)
-            metrics.countApplicationsByStatus()
         } catch (e: Exception) {
             logger.error(e) { "Feilet ved oppdatering av søknad" }
             call.respond(HttpStatusCode.BadRequest, "Feilet ved oppdatering av søknad")