Bug causing empty sak list if hjelpestønad does not exist

navikt · Sep 28, 2023 · 66658df · 66658df
1 parent d3b5ac6
commit 66658df
Show file tree

Hide file tree

Showing 2 changed files with 35 additions and 3 deletions.
diff --git a/...tjening/omsorgsopptjening/start/innlesning/barnetrygd/domain/BarnetrygdmottakerService.kt b/...tjening/omsorgsopptjening/start/innlesning/barnetrygd/domain/BarnetrygdmottakerService.kt
@@ -55,14 +55,15 @@ class BarnetrygdmottakerService(
                                         ident = barnetrygdmottaker.ident,
                                         ar = barnetrygdmottaker.år,
                                     )
-                                    val barnetrygdOgHjelpestønad = barnetrygd.barnetrygdsaker.flatMap { sak ->
+                                    val barnetrygdOgHjelpestønad = barnetrygd.barnetrygdsaker.map { sak ->
                                         val minMaxDatePerOmsorgsmottaker =
                                             sak.hentOmsorgsmottakere().associateWith { mottaker ->
                                                 sak.vedtaksperioder.filter { it.omsorgsmottaker == mottaker }
                                                     .let { vedtaksperioder -> vedtaksperioder.minOf { it.fom } to vedtaksperioder.maxOf { it.tom } }
                                             }
-                                        hjelpestønadService.hentForOmsorgsmottakere(minMaxDatePerOmsorgsmottaker)
-                                            .map { sak.leggTilVedtaksperiode(it) }
+                                        val hjelpestønad =
+                                            hjelpestønadService.hentForOmsorgsmottakere(minMaxDatePerOmsorgsmottaker)
+                                        sak.copy(vedtaksperioder = sak.vedtaksperioder + hjelpestønad)
                                     }
                                     kafkaProducer.send(
                                         createKafkaMessage(

diff --git a/...ing/omsorgsopptjening/start/innlesning/barnetrygd/domain/BarnetrygdmottakerServiceTest.kt b/...ing/omsorgsopptjening/start/innlesning/barnetrygd/domain/BarnetrygdmottakerServiceTest.kt
@@ -277,6 +277,37 @@ class BarnetrygdmottakerServiceTest : SpringContextTest.NoKafka() {
         }
     }
 
+    @Test
+    fun `omsorgsgrunnlag sender bare barnetrygd dersom hjelpestønad ikke eksisterer`() {
+        val captor = argumentCaptor<ProducerRecord<String, String>> { }
+        given(kafkaTemplate.send(captor.capture())).willAnswer {
+            CompletableFuture.completedFuture(it.arguments[0])
+        }
+        given(clock.instant()).willReturn(Instant.now())
+
+        val innlesing = lagreFullførtInnlesing()
+
+        barnetrygdmottakerRepository.insert(
+            Barnetrygdmottaker.Transient(
+                ident = "12345678910",
+                correlationId = CorrelationId.generate(),
+                innlesingId = innlesing.id
+            )
+        )
+
+        wiremock.`hent-barnetrygd ok`()
+        wiremock.`hent hjelpestønad ok - ingen hjelpestønad`()
+
+        barnetrygdService.process()
+
+        deserialize<OmsorgsgrunnlagMelding>(captor.allValues.single().value()).also { omsorgsgrunnlagMelding ->
+            omsorgsgrunnlagMelding.saker.single().also { sak ->
+                assertEquals(1, sak.vedtaksperioder.count())
+                assertEquals(1, sak.vedtaksperioder.count { it.omsorgstype == Omsorgstype.FULL_BARNETRYGD })
+            }
+        }
+    }
+
     private fun lagreFullførtInnlesing(): BarnetrygdInnlesing {
         val bestilt = innlesingRepository.bestilt(
             BarnetrygdInnlesing.Bestilt(