Merge pull request #4464 from navikt/feature/deltaker-prosent

lagre full deltakelsesprosent hvis det mangler for AFT/VTA

mulighetsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/api/plugins/DependencyInjection.kt

@@ -142,7 +142,7 @@ private fun kafka(appConfig: AppConfig) = module {
                 arenaMigreringTiltaksgjennomforingProducer = get(),
                 tiltaksgjennomforingRepository = get(),
             ),
-            AmtDeltakerV1KafkaConsumer(config = config.consumers.amtDeltakerV1, deltakere = get()),
+            AmtDeltakerV1KafkaConsumer(config = config.consumers.amtDeltakerV1, tiltakstyper = get(), deltakere = get()),
             AmtVirksomheterV1KafkaConsumer(
                 config = config.consumers.amtVirksomheterV1,
                 arrangorRepository = get(),

mulighetsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/api/repositories/TiltakstypeRepository.kt

@@ -118,6 +118,20 @@ class TiltakstypeRepository(private val db: Database) {
         }
     }
 
+    fun getByGjennomforingId(gjennomforingId: UUID): TiltakstypeDto {
+        @Language("PostgreSQL")
+        val query = """
+            select t.*
+            from tiltakstype_admin_dto_view t
+            join tiltaksgjennomforing g on g.tiltakstype_id = t.id
+            where g.id = ?::uuid
+        """.trimIndent()
+        val queryResult = queryOf(query, gjennomforingId).map { it.toTiltakstypeDto() }.asSingle
+        return requireNotNull(db.run(queryResult)) {
+            "Det finnes ingen tiltakstype for gjennomforing med id=$gjennomforingId"
+        }
+    }
+
     fun getAll(
         pagination: Pagination = Pagination.all(),
     ): PaginatedResult<TiltakstypeDto> {

mulighetsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/api/services/TiltakstypeService.kt

@@ -23,6 +23,12 @@ class TiltakstypeService(
         .recordStats()
         .build()
 
+    private val cacheByGjennomforingId: Cache<UUID, TiltakstypeDto> = Caffeine.newBuilder()
+        .expireAfterWrite(12, TimeUnit.HOURS)
+        .maximumSize(10_000)
+        .recordStats()
+        .build()
+
     fun isEnabled(tiltakskode: Tiltakskode?) = enabledTiltakskoder.contains(tiltakskode)
 
     fun getAll(
@@ -46,4 +52,10 @@ class TiltakstypeService(
             tiltakstypeRepository.getBySanityId(sanityId)
         }
     }
+
+    fun getByGjennomforingId(gjennomforingId: UUID): TiltakstypeDto {
+        return CacheUtils.tryCacheFirstNotNull(cacheByGjennomforingId, gjennomforingId) {
+            tiltakstypeRepository.getByGjennomforingId(gjennomforingId)
+        }
+    }
 }

mulighetsrommet-api/src/main/kotlin/no/nav/mulighetsrommet/kafka/consumers/amt/AmtDeltakerV1KafkaConsumer.kt

@@ -5,6 +5,8 @@ import kotlinx.serialization.json.decodeFromJsonElement
 import no.nav.common.kafka.consumer.util.deserializer.Deserializers.uuidDeserializer
 import no.nav.mulighetsrommet.api.domain.dbo.DeltakerDbo
 import no.nav.mulighetsrommet.api.repositories.DeltakerRepository
+import no.nav.mulighetsrommet.api.services.TiltakstypeService
+import no.nav.mulighetsrommet.domain.Tiltakskode
 import no.nav.mulighetsrommet.domain.dto.DeltakerStatus
 import no.nav.mulighetsrommet.domain.dto.amt.AmtDeltakerV1Dto
 import no.nav.mulighetsrommet.kafka.KafkaTopicConsumer
@@ -15,6 +17,7 @@ import java.util.*
 
 class AmtDeltakerV1KafkaConsumer(
     config: Config,
+    private val tiltakstyper: TiltakstypeService,
     private val deltakere: DeltakerRepository,
 ) : KafkaTopicConsumer<UUID, JsonElement>(
     config,
@@ -47,14 +50,28 @@ class AmtDeltakerV1KafkaConsumer(
         }
     }
 
-    private fun AmtDeltakerV1Dto.toDeltakerDbo(): DeltakerDbo = DeltakerDbo(
-        id = id,
-        gjennomforingId = gjennomforingId,
-        startDato = startDato,
-        sluttDato = sluttDato,
-        registrertTidspunkt = registrertDato,
-        endretTidspunkt = endretDato,
-        stillingsprosent = prosentStilling?.toDouble(),
-        status = status,
-    )
+    private fun AmtDeltakerV1Dto.toDeltakerDbo(): DeltakerDbo {
+        val tiltakstype = tiltakstyper.getByGjennomforingId(gjennomforingId)
+
+        val stillingsprosent = when (tiltakstype.tiltakskode) {
+            // Hvis stillingsprosent mangler for AFT/VTA så kan det antas å være 100
+            Tiltakskode.ARBEIDSFORBEREDENDE_TRENING, Tiltakskode.VARIG_TILRETTELAGT_ARBEID_SKJERMET -> {
+                prosentStilling?.toDouble() ?: 100.0
+            }
+
+            // TODO: ikke lese inn stillingsprosent for andre tiltakstyper?
+            //  Skal visstnok ikke være relevant for disse, selv om det finnes en del data der per i dag
+            else -> prosentStilling?.toDouble()
+        }
+        return DeltakerDbo(
+            id = id,
+            gjennomforingId = gjennomforingId,
+            startDato = startDato,
+            sluttDato = sluttDato,
+            registrertTidspunkt = registrertDato,
+            endretTidspunkt = endretDato,
+            stillingsprosent = stillingsprosent,
+            status = status,
+        )
+    }
 }

mulighetsrommet-api/src/test/kotlin/no/nav/mulighetsrommet/kafka/amt/AmtDeltakerV1KafkaConsumerTest.kt

@@ -11,7 +11,8 @@ import no.nav.mulighetsrommet.api.domain.dbo.DeltakerDbo
 import no.nav.mulighetsrommet.api.fixtures.MulighetsrommetTestDomain
 import no.nav.mulighetsrommet.api.fixtures.TiltaksgjennomforingFixtures
 import no.nav.mulighetsrommet.api.repositories.DeltakerRepository
-import no.nav.mulighetsrommet.api.repositories.TiltaksgjennomforingRepository
+import no.nav.mulighetsrommet.api.repositories.TiltakstypeRepository
+import no.nav.mulighetsrommet.api.services.TiltakstypeService
 import no.nav.mulighetsrommet.database.kotest.extensions.FlywayDatabaseTestListener
 import no.nav.mulighetsrommet.database.kotest.extensions.truncateAll
 import no.nav.mulighetsrommet.domain.dto.DeltakerStatus
@@ -26,10 +27,13 @@ class AmtDeltakerV1KafkaConsumerTest : FunSpec({
 
     context("consume deltakere") {
         beforeTest {
-            MulighetsrommetTestDomain().initialize(database.db)
-
-            val tiltaksgjennomforinger = TiltaksgjennomforingRepository(database.db)
-            tiltaksgjennomforinger.upsert(TiltaksgjennomforingFixtures.Oppfolging1)
+            MulighetsrommetTestDomain(
+                gjennomforinger = listOf(
+                    TiltaksgjennomforingFixtures.Oppfolging1,
+                    TiltaksgjennomforingFixtures.AFT1,
+                    TiltaksgjennomforingFixtures.VTA1,
+                ),
+            ).initialize(database.db)
         }
 
         afterEach {
@@ -39,7 +43,8 @@ class AmtDeltakerV1KafkaConsumerTest : FunSpec({
         val deltakere = DeltakerRepository(database.db)
         val deltakerConsumer = AmtDeltakerV1KafkaConsumer(
             config = KafkaTopicConsumer.Config(id = "deltaker", topic = "deltaker"),
-            deltakere,
+            tiltakstyper = TiltakstypeService(TiltakstypeRepository(database.db), listOf()),
+            deltakere = deltakere,
         )
 
         val deltakelsesdato = LocalDateTime.of(2023, 3, 1, 0, 0, 0)
@@ -108,5 +113,21 @@ class AmtDeltakerV1KafkaConsumerTest : FunSpec({
 
             deltakere.getAll().shouldBeEmpty()
         }
+
+        test("tolker stillingsprosent som 100 hvis den mangler for forhåndsgodkjente tiltak") {
+            deltakerConsumer.consume(
+                amtDeltaker1.id,
+                Json.encodeToJsonElement(amtDeltaker1.copy(gjennomforingId = TiltaksgjennomforingFixtures.AFT1.id)),
+            )
+            deltakerConsumer.consume(
+                amtDeltaker2.id,
+                Json.encodeToJsonElement(amtDeltaker2.copy(gjennomforingId = TiltaksgjennomforingFixtures.VTA1.id)),
+            )
+
+            deltakere.getAll().shouldContainExactly(
+                deltaker1Dbo.copy(gjennomforingId = TiltaksgjennomforingFixtures.AFT1.id, stillingsprosent = 100.0),
+                deltaker2Dbo.copy(gjennomforingId = TiltaksgjennomforingFixtures.VTA1.id, stillingsprosent = 100.0),
+            )
+        }
     }
 })