fikset type på innlesingsId/correlationId

navikt · Oct 30, 2024 · 547a0a0 · 547a0a0
1 parent 74f6475
commit 547a0a0
Show file tree

Hide file tree

Showing 6 changed files with 17 additions and 14 deletions.
diff --git a/.../opptjening/omsorgsopptjening/start/innlesning/barnetrygd/domain/Barnetrygdinformasjon.kt b/.../opptjening/omsorgsopptjening/start/innlesning/barnetrygd/domain/Barnetrygdinformasjon.kt
@@ -1,5 +1,7 @@
 package no.nav.pensjon.opptjening.omsorgsopptjening.start.innlesning.barnetrygd.domain
 
+import no.nav.pensjon.opptjening.omsorgsopptjening.felles.CorrelationId
+import no.nav.pensjon.opptjening.omsorgsopptjening.felles.InnlesingId
 import no.nav.pensjon.opptjening.omsorgsopptjening.felles.domene.kafka.Rådata
 import no.nav.pensjon.opptjening.omsorgsopptjening.felles.domene.kafka.messages.domene.PersongrunnlagMelding
 import java.time.Instant
@@ -12,8 +14,8 @@ data class Barnetrygdinformasjon(
     val ident: String,
     val persongrunnlag: List<PersongrunnlagMelding.Persongrunnlag>,
     val rådata: Rådata,
-    val correlationId: UUID,
-    val innlesingId: UUID,
+    val correlationId: CorrelationId,
+    val innlesingId: InnlesingId,
     val status: Status,
 ) {
     enum class Status {

diff --git a/...tjening/omsorgsopptjening/start/innlesning/barnetrygd/domain/BarnetrygdmottakerService.kt b/...tjening/omsorgsopptjening/start/innlesning/barnetrygd/domain/BarnetrygdmottakerService.kt
@@ -128,8 +128,8 @@ class BarnetrygdmottakerService(
             ident = komplettert.barnetrygdmottaker.personId!!.fnr,
             persongrunnlag = komplettert.persongrunnlag,
             rådata = komplettert.rådata,
-            correlationId = komplettert.barnetrygdmottaker.correlationId.toUUID(),
-            innlesingId = komplettert.barnetrygdmottaker.innlesingId.toUUID(),
+            correlationId = komplettert.barnetrygdmottaker.correlationId,
+            innlesingId = komplettert.barnetrygdmottaker.innlesingId,
             status = Barnetrygdinformasjon.Status.KLAR,
         )
     }

diff --git a/...n/opptjening/omsorgsopptjening/start/innlesning/barnetrygd/domain/SendTilBestemService.kt b/...n/opptjening/omsorgsopptjening/start/innlesning/barnetrygd/domain/SendTilBestemService.kt
@@ -35,8 +35,8 @@ class SendTilBestemService(
         try {
             val barnetrygdinformasjonsListe: List<Barnetrygdinformasjon?>? =
                 låsteTilSending?.data?.map { barnetrygdinformasjon ->
-                    Mdc.scopedMdc(CorrelationId(barnetrygdinformasjon.correlationId)) {
-                        Mdc.scopedMdc(InnlesingId(barnetrygdinformasjon.innlesingId)) {
+                    Mdc.scopedMdc(barnetrygdinformasjon.correlationId) {
+                        Mdc.scopedMdc(barnetrygdinformasjon.innlesingId) {
                             send(barnetrygdinformasjon)
                         }
                     }
@@ -95,8 +95,8 @@ class SendTilBestemService(
                     omsorgsyter = barnetrygdinformasjon.ident,
                     persongrunnlag = barnetrygdinformasjon.persongrunnlag,
                     rådata = barnetrygdinformasjon.rådata,
-                    innlesingId = InnlesingId(barnetrygdinformasjon.innlesingId),
-                    correlationId = CorrelationId(barnetrygdinformasjon.correlationId),
+                    innlesingId = barnetrygdinformasjon.innlesingId,
+                    correlationId = barnetrygdinformasjon.correlationId,
                 )
             )
         )

diff --git a/...sorgsopptjening/start/innlesning/barnetrygd/repository/BarnetrygdinformasjonRepository.kt b/...sorgsopptjening/start/innlesning/barnetrygd/repository/BarnetrygdinformasjonRepository.kt
@@ -56,8 +56,8 @@ class BarnetrygdinformasjonRepository(
                 "ident" to barnetrygdinformasjon.ident,
                 "persongrunnlag" to serialize(barnetrygdinformasjon.persongrunnlag),
                 "rådata" to serialize(barnetrygdinformasjon.rådata),
-                "correlationId" to barnetrygdinformasjon.correlationId,
-                "innlesingId" to barnetrygdinformasjon.innlesingId,
+                "correlationId" to barnetrygdinformasjon.correlationId.toUUID(),
+                "innlesingId" to barnetrygdinformasjon.innlesingId.toUUID(),
                 "status" to when (barnetrygdinformasjon.status) {
                     Barnetrygdinformasjon.Status.KLAR -> "Klar"
                     Barnetrygdinformasjon.Status.SENDT -> "Sendt"
@@ -189,8 +189,8 @@ class BarnetrygdinformasjonRepository(
                 ident = rs.getString("ident"),
                 persongrunnlag = deserialize<List<PersongrunnlagMelding.Persongrunnlag>>(rs.getString("persongrunnlag")),
                 rådata = deserialize<Rådata>(rs.getString("rådata")),
-                correlationId = UUID.fromString(rs.getString("correlationId")),
-                innlesingId = UUID.fromString(rs.getString("innlesingId")),
+                correlationId = CorrelationId.fromString(rs.getString("correlationId")),
+                innlesingId = InnlesingId.fromString(rs.getString("innlesingId")),
                 status = when (val value = rs.getString("status")) {
                     "Klar" -> Barnetrygdinformasjon.Status.KLAR
                     "Sendt" -> Barnetrygdinformasjon.Status.SENDT

diff --git a/...n/no/nav/pensjon/opptjening/omsorgsopptjening/start/innlesning/tasks/SendTilBestemTask.kt b/...n/no/nav/pensjon/opptjening/omsorgsopptjening/start/innlesning/tasks/SendTilBestemTask.kt
@@ -20,6 +20,7 @@ class SendTilBestemTask(
 
     @Scheduled(fixedDelay = 5000)
     override fun run() {
+        log.info("sendTilBestemTask().run()") // TODO: fjern ekstra logging
         try {
             if (isEnabled()) {
                 sendAltSomErKlartTilBestem()

diff --git a/...sopptjening/start/innlesning/barnetrygd/repository/BarnetrygdinformasjonRepositoryTest.kt b/...sopptjening/start/innlesning/barnetrygd/repository/BarnetrygdinformasjonRepositoryTest.kt
@@ -107,8 +107,8 @@ class BarnetrygdinformasjonRepositoryTest(
                 )
             ),
             rådata = Rådata(listOf(RådataFraKilde(mapOf("eple" to "eple", "banan" to "banan")))),
-            correlationId = barnetrygdmottaker.correlationId.toUUID(),
-            innlesingId = innlesing.id.toUUID(),
+            correlationId = barnetrygdmottaker.correlationId,
+            innlesingId = innlesing.id,
             status = Barnetrygdinformasjon.Status.KLAR,
         )
     }