Legge historiskstatistikk for Land

Co-authored-by: Per-Christian Nielsen <per-christian.nielsen@nav.no>
navikt · Sep 29, 2023 · ef135a3 · ef135a3
1 parent d5d6bc5
commit ef135a3
Show file tree

Hide file tree

Showing 5 changed files with 38 additions and 1 deletion.
diff --git a/src/main/kotlin/no/nav/lydia/sykefraversstatistikk/SykefraværsstatistikkService.kt b/src/main/kotlin/no/nav/lydia/sykefraversstatistikk/SykefraværsstatistikkService.kt
@@ -21,6 +21,8 @@ import org.slf4j.LoggerFactory
 import java.time.LocalDate.now
 import kotlin.system.measureTimeMillis
 
+const val LANDKODE_NO = "NO"
+
 class SykefraværsstatistikkService(
     val sykefraversstatistikkRepository: SykefraversstatistikkRepository,
     val virksomhetsinformasjonRepository: VirksomhetsinformasjonRepository,
@@ -185,6 +187,11 @@ class SykefraværsstatistikkService(
                             kategori = SEKTOR,
                             kode = sektor?.kode ?: "",
                             statistikk = sektor?.let { virksomhetsinformasjonRepository.hentSektorstatistikkPerKvartal(sektor = it) } ?: emptyList()
+                    ),
+                    landsstatistikk = KategoriStatistikk(
+                            kategori = LAND,
+                            kode = LANDKODE_NO,
+                            statistikk = virksomhetsinformasjonRepository.hentLandsstatistikkPerKvartal()
                     )
             )
         }

diff --git a/src/main/kotlin/no/nav/lydia/sykefraversstatistikk/VirksomhetsinformasjonRepository.kt b/src/main/kotlin/no/nav/lydia/sykefraversstatistikk/VirksomhetsinformasjonRepository.kt
@@ -196,6 +196,9 @@ class VirksomhetsinformasjonRepository(val dataSource: DataSource) {
     fun hentSektorstatistikkPerKvartal(sektor: Sektor) =
         hentKategoristatistikkPerKvartal(Kategori.SEKTOR, sektor.kode)
 
+    fun hentLandsstatistikkPerKvartal() =
+        hentKategoristatistikkPerKvartal(Kategori.LAND, LANDKODE_NO)
+
     private fun hentKategoristatistikkPerKvartal(kategori: Kategori, kode: String) =
         using(sessionOf(dataSource)) { session ->
             val query = queryOf(

diff --git a/src/main/kotlin/no/nav/lydia/sykefraversstatistikk/domene/HistoriskStatistikk.kt b/src/main/kotlin/no/nav/lydia/sykefraversstatistikk/domene/HistoriskStatistikk.kt
@@ -9,6 +9,7 @@ data class HistoriskStatistikk(
     val næringsstatistikk: KategoriStatistikk,
     val bransjestatistikk: KategoriStatistikk,
     val sektorstatistikk: KategoriStatistikk,
+    val landsstatistikk: KategoriStatistikk,
 )
 
 @Serializable

diff --git a/src/test/kotlin/no/nav/lydia/container/sykefraversstatistikk/SykefraversstatistikkApiTest.kt b/src/test/kotlin/no/nav/lydia/container/sykefraversstatistikk/SykefraversstatistikkApiTest.kt
@@ -78,6 +78,7 @@ import no.nav.lydia.ia.sak.domene.ANTALL_DAGER_FØR_SAK_LÅSES
 import no.nav.lydia.ia.sak.domene.IAProsessStatus
 import no.nav.lydia.ia.sak.domene.IASakshendelseType.FULLFØR_BISTAND
 import no.nav.lydia.ia.sak.domene.IASakshendelseType.TA_EIERSKAP_I_SAK
+import no.nav.lydia.sykefraversstatistikk.LANDKODE_NO
 import no.nav.lydia.sykefraversstatistikk.api.EierDTO
 import no.nav.lydia.sykefraversstatistikk.api.FILTERVERDIER_PATH
 import no.nav.lydia.sykefraversstatistikk.api.Periode
@@ -685,13 +686,18 @@ class SykefraversstatistikkApiTest {
                 prosentSiste4Kvartal = 5.0,
                 prosentSistePubliserteKvartal = 79.9,
         )
+        settSykefraværsprosentLand(
+                prosentSiste4Kvartal = 5.0,
+                prosentSistePubliserteKvartal = 99.9,
+        )
 
         val resultat = hentStatikkHistorikk(orgnr = nyVirksomhet.orgnr)
 
         resultat.virksomhetsstatistikk.statistikk shouldHaveSize perioder.size
         resultat.næringsstatistikk.statistikk shouldHaveAtLeastSize 1
         resultat.bransjestatistikk.statistikk shouldHaveAtLeastSize 1
         resultat.sektorstatistikk.statistikk shouldHaveAtLeastSize 1
+        resultat.landsstatistikk.statistikk shouldHaveAtLeastSize 1
 
         resultat.virksomhetsstatistikk.statistikk.map {
             Periode(kvartal = it.kvartal, årstall = it.årstall)
@@ -701,6 +707,7 @@ class SykefraversstatistikkApiTest {
         resultat.næringsstatistikk.statistikk.forAtLeastOne { it.sykefraværsprosent shouldBe 75.0 }
         resultat.bransjestatistikk.statistikk.forAtLeastOne { it.sykefraværsprosent shouldBe 77.7 }
         resultat.sektorstatistikk.statistikk.forAtLeastOne { it.sykefraværsprosent shouldBe 79.9 }
+        resultat.landsstatistikk.statistikk.forAtLeastOne { it.sykefraværsprosent shouldBe 99.9 }
     }
 
     @Test
@@ -1220,6 +1227,26 @@ class SykefraversstatistikkApiTest {
                     Kafka.statistikkSektorGroupId
             )
         }
+
+        fun settSykefraværsprosentLand(
+                prosentSiste4Kvartal: Double,
+                prosentSistePubliserteKvartal: Double = 2.0
+        ) {
+            val kafkaMelding = SykefraversstatistikkImportTestUtils.JsonMelding(
+                    kategori = Kategori.LAND,
+                    kode = LANDKODE_NO,
+                    kvartal = gjeldendePeriode.tilKvartal(),
+                    sistePubliserteKvartal = sistePubliserteKvartal.copy(prosent = prosentSistePubliserteKvartal),
+                    siste4Kvartal = siste4Kvartal.copy(prosent = prosentSiste4Kvartal)
+            )
+
+            TestContainerHelper.kafkaContainerHelper.sendOgVentTilKonsumert(
+                    kafkaMelding.toJsonKey(),
+                    kafkaMelding.toJsonValue(),
+                    KafkaContainerHelper.statistikkLandTopic,
+                    Kafka.statistikkLandGroupId
+            )
+        }
     }
 }
 

diff --git a/src/test/kotlin/no/nav/lydia/helper/TestData.kt b/src/test/kotlin/no/nav/lydia/helper/TestData.kt
@@ -13,7 +13,6 @@ class TestData(
     antallTilfeldigeVirksomheter: Int = 0,
 ) {
     companion object {
-        const val LANDKODE_NO = "NO"
         const val BRANSJE_BARNEHAGE = "Barnehager"
         const val BRANSJE_NÆRINGSMIDDELINDUSTRI = "Næringsmiddelindustri"
         const val NÆRING_JORDBRUK = "01"