From 7cc5b3c443568ca78e8060a7b4a8db6226741653 Mon Sep 17 00:00:00 2001 From: Mikael Bjerga <6940327+bjerga@users.noreply.github.com> Date: Tue, 17 Dec 2024 10:49:42 +0100 Subject: [PATCH] Bruk wrappers i forespoersel (#808) --- .../aktiveorgnrservice/AktiveOrgnrService.kt | 9 +-- .../hentforespoersel/HentForespoerselRoute.kt | 4 +- .../HentForespoerselIdListeRoute.kt | 2 +- .../HentForespoerselRouteKtTest.kt | 11 ++- .../HentForespoerselIdListeRouteKtTest.kt | 12 ++-- .../BerikInntektsmeldingService.kt | 8 +-- .../MapInntektsmelding.kt | 6 +- .../BerikInntektsmeldingServiceTest.kt | 4 +- .../MapInntektsmeldingKtTest.kt | 6 +- .../felles/domene/Forespoersel.kt | 8 ++- .../felles/domene/ForespoerselFraBro.kt | 6 +- .../felles/ForespoerselTest.kt | 68 ++++++++++--------- .../felles/test/mock/MockForespoersel.kt | 8 +-- .../BerikInntektsmeldingServiceIT.kt | 16 ++--- .../integrasjonstest/InnsendingIT.kt | 12 ++-- .../HentDataTilPaaminnelseService.kt | 4 +- .../HentDataTilSakOgOppgaveService.kt | 8 +-- .../river/EndrePaaminnelseRiver.kt | 2 +- .../OpprettForespoerselSakOgOppgaveRiver.kt | 5 +- .../HentDataTilPaaminnelseServiceTest.kt | 3 +- .../HentDataTilSakOgOppgaveServiceTest.kt | 6 +- .../river/EndrePaaminnelseRiverTest.kt | 3 +- ...pprettForespoerselSakOgOppgaveRiverTest.kt | 30 +++----- .../trengerservice/HentForespoerselService.kt | 13 ++-- .../HentForespoerselServiceTest.kt | 5 +- 25 files changed, 127 insertions(+), 132 deletions(-) diff --git a/aktiveorgnrservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/aktiveorgnrservice/AktiveOrgnrService.kt b/aktiveorgnrservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/aktiveorgnrservice/AktiveOrgnrService.kt index 9d6e8a7be..a76130353 100644 --- a/aktiveorgnrservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/aktiveorgnrservice/AktiveOrgnrService.kt +++ b/aktiveorgnrservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/aktiveorgnrservice/AktiveOrgnrService.kt @@ -1,7 +1,6 @@ package no.nav.helsearbeidsgiver.inntektsmelding.aktiveorgnrservice import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection -import kotlinx.serialization.builtins.MapSerializer import kotlinx.serialization.builtins.serializer import kotlinx.serialization.json.JsonElement import no.nav.helsearbeidsgiver.felles.BehovType @@ -12,6 +11,7 @@ import no.nav.helsearbeidsgiver.felles.domene.Arbeidsforhold import no.nav.helsearbeidsgiver.felles.domene.Person import no.nav.helsearbeidsgiver.felles.domene.ResultJson import no.nav.helsearbeidsgiver.felles.json.les +import no.nav.helsearbeidsgiver.felles.json.orgMapSerializer import no.nav.helsearbeidsgiver.felles.json.personMapSerializer import no.nav.helsearbeidsgiver.felles.json.toJson import no.nav.helsearbeidsgiver.felles.rapidsrivers.KafkaKey @@ -28,6 +28,7 @@ import no.nav.helsearbeidsgiver.utils.json.toJson import no.nav.helsearbeidsgiver.utils.log.logger import no.nav.helsearbeidsgiver.utils.log.sikkerLogger import no.nav.helsearbeidsgiver.utils.wrapper.Fnr +import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.util.UUID data class Steg0( @@ -47,7 +48,7 @@ sealed class Steg1 { } data class Steg2( - val virksomheter: Map, + val virksomheter: Map, ) class AktiveOrgnrService( @@ -89,7 +90,7 @@ class AktiveOrgnrService( override fun lesSteg2(melding: Map): Steg2 = Steg2( - virksomheter = Key.VIRKSOMHETER.les(MapSerializer(String.serializer(), String.serializer()), melding), + virksomheter = Key.VIRKSOMHETER.les(orgMapSerializer, melding), ) override fun utfoerSteg0( @@ -179,7 +180,7 @@ class AktiveOrgnrService( val gyldigeUnderenheter = steg2.virksomheter.map { AktiveArbeidsgivere.Arbeidsgiver( - orgnrUnderenhet = it.key, + orgnrUnderenhet = it.key.verdi, virksomhetsnavn = it.value, ) } diff --git a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoersel/HentForespoerselRoute.kt b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoersel/HentForespoerselRoute.kt index 7308c9c4a..021c3ef84 100644 --- a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoersel/HentForespoerselRoute.kt +++ b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoersel/HentForespoerselRoute.kt @@ -100,8 +100,8 @@ private fun HentForespoerselResultat.toResponse(): HentForespoerselResponse { navn = sykmeldtNavn, innsenderNavn = avsenderNavn, orgNavn = orgNavn, - identitetsnummer = forespoersel.fnr, - orgnrUnderenhet = forespoersel.orgnr, + identitetsnummer = forespoersel.fnr.verdi, + orgnrUnderenhet = forespoersel.orgnr.verdi, fravaersperioder = forespoersel.sykmeldingsperioder, egenmeldingsperioder = forespoersel.egenmeldingsperioder, bestemmendeFravaersdag = forespoersel.forslagBestemmendeFravaersdag(), diff --git a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoerselIdListe/HentForespoerselIdListeRoute.kt b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoerselIdListe/HentForespoerselIdListeRoute.kt index 9a270675a..167754f85 100644 --- a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoerselIdListe/HentForespoerselIdListeRoute.kt +++ b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoerselIdListe/HentForespoerselIdListeRoute.kt @@ -113,7 +113,7 @@ suspend fun PipelineContext.hentForespoersler( } else -> { - orgnrSet.firstOrNull()?.also { orgnr -> tilgangskontroll.validerTilgangTilOrg(call.request, orgnr) } + orgnrSet.firstOrNull()?.also { orgnr -> tilgangskontroll.validerTilgangTilOrg(call.request, orgnr.verdi) } val respons = resultat.map { (id, forespoersel) -> diff --git a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoersel/HentForespoerselRouteKtTest.kt b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoersel/HentForespoerselRouteKtTest.kt index f23b43f8f..1d84f9a59 100644 --- a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoersel/HentForespoerselRouteKtTest.kt +++ b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoersel/HentForespoerselRouteKtTest.kt @@ -36,6 +36,9 @@ import no.nav.helsearbeidsgiver.utils.test.date.februar import no.nav.helsearbeidsgiver.utils.test.date.januar import no.nav.helsearbeidsgiver.utils.test.date.mars import no.nav.helsearbeidsgiver.utils.test.json.removeJsonWhitespace +import no.nav.helsearbeidsgiver.utils.test.wrapper.genererGyldig +import no.nav.helsearbeidsgiver.utils.wrapper.Fnr +import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Assertions.assertNotNull import org.junit.jupiter.api.Assertions.assertNull @@ -148,12 +151,14 @@ class HentForespoerselRouteKtTest : ApiTest() { } private object Mock { + private val orgnr = Orgnr.genererGyldig() + val request = HentForespoerselRequest(UUID.randomUUID()) private val forespoersel = Forespoersel( - orgnr = "123", - fnr = "abc", + orgnr = orgnr, + fnr = Fnr.genererGyldig(), sykmeldingsperioder = listOf( 1.april til 20.april, @@ -164,7 +169,7 @@ private object Mock { 29.mars til 29.mars, 31.mars til 31.mars, ), - bestemmendeFravaersdager = mapOf("123" to 25.april), + bestemmendeFravaersdager = mapOf(orgnr to 25.april), forespurtData = mockForespurtData(), erBesvart = false, vedtaksperiodeId = UUID.randomUUID(), diff --git a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoerselIdListe/HentForespoerselIdListeRouteKtTest.kt b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoerselIdListe/HentForespoerselIdListeRouteKtTest.kt index a84acc12c..ba9386652 100644 --- a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoerselIdListe/HentForespoerselIdListeRouteKtTest.kt +++ b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/hentforespoerselIdListe/HentForespoerselIdListeRouteKtTest.kt @@ -294,16 +294,16 @@ class HentForespoerselIdListeRouteKtTest : ApiTest() { private object Mock { val orgnr = Orgnr.genererGyldig() - val vedtaksPeriodeId1 = UUID.randomUUID() - val forespoerselId1 = UUID.randomUUID() + val vedtaksPeriodeId1: UUID = UUID.randomUUID() + val forespoerselId1: UUID = UUID.randomUUID() - val vedtaksPeriodeId2 = UUID.randomUUID() - val forespoerselId2 = UUID.randomUUID() + val vedtaksPeriodeId2: UUID = UUID.randomUUID() + val forespoerselId2: UUID = UUID.randomUUID() fun mockResultat(): Map = mapOf( - forespoerselId1 to mockForespoersel().copy(vedtaksperiodeId = vedtaksPeriodeId1, orgnr = orgnr.toString()), - forespoerselId2 to mockForespoersel().copy(vedtaksperiodeId = vedtaksPeriodeId2, orgnr = orgnr.toString()), + forespoerselId1 to mockForespoersel().copy(vedtaksperiodeId = vedtaksPeriodeId1, orgnr = orgnr), + forespoerselId2 to mockForespoersel().copy(vedtaksperiodeId = vedtaksPeriodeId2, orgnr = orgnr), ) fun mockResultatMedUlikeOrgnr(): Map = diff --git a/berik-inntektsmelding-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingService.kt b/berik-inntektsmelding-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingService.kt index 095d16086..51a177564 100644 --- a/berik-inntektsmelding-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingService.kt +++ b/berik-inntektsmelding-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingService.kt @@ -127,7 +127,7 @@ class BerikInntektsmeldingService( Key.KONTEKST_ID to steg0.transaksjonId.toJson(), Key.DATA to data - .plus(Key.ORGNR_UNDERENHETER to setOf(steg1.forespoersel.orgnr).toJson(String.serializer())) + .plus(Key.ORGNR_UNDERENHETER to setOf(steg1.forespoersel.orgnr).toJson(Orgnr.serializer())) .toJson(), ).also { loggBehovPublisert(BehovType.HENT_VIRKSOMHET_NAVN, it) } } @@ -149,7 +149,7 @@ class BerikInntektsmeldingService( .plus( Key.FNR_LISTE to listOf( - steg1.forespoersel.fnr.let(::Fnr), + steg1.forespoersel.fnr, steg0.avsenderFnr, ).toJson(Fnr.serializer()), ).toJson(), @@ -163,8 +163,8 @@ class BerikInntektsmeldingService( steg2: Steg2, steg3: Steg3, ) { - val orgNavn = steg2.orgnrMedNavn[steg1.forespoersel.orgnr.let(::Orgnr)] ?: UKJENT_VIRKSOMHET - val sykmeldtNavn = steg3.personer[steg1.forespoersel.fnr.let(::Fnr)]?.navn ?: UKJENT_NAVN + val orgNavn = steg2.orgnrMedNavn[steg1.forespoersel.orgnr] ?: UKJENT_VIRKSOMHET + val sykmeldtNavn = steg3.personer[steg1.forespoersel.fnr]?.navn ?: UKJENT_NAVN val avsenderNavn = steg3.personer[steg0.avsenderFnr]?.navn ?: UKJENT_NAVN val aarsakInnsending = if (steg1.forespoersel.erBesvart) AarsakInnsending.Endring else AarsakInnsending.Ny diff --git a/berik-inntektsmelding-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/MapInntektsmelding.kt b/berik-inntektsmelding-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/MapInntektsmelding.kt index 67261b279..27ec88894 100644 --- a/berik-inntektsmelding-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/MapInntektsmelding.kt +++ b/berik-inntektsmelding-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/MapInntektsmelding.kt @@ -8,8 +8,6 @@ import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.Sykmeldt import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.skjema.SkjemaInntektsmelding import no.nav.helsearbeidsgiver.felles.domene.Forespoersel import no.nav.helsearbeidsgiver.felles.domene.ForslagInntekt -import no.nav.helsearbeidsgiver.utils.wrapper.Fnr -import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.time.ZonedDateTime import java.util.UUID @@ -61,12 +59,12 @@ fun mapInntektsmelding( ), sykmeldt = Sykmeldt( - fnr = forespoersel.fnr.let(::Fnr), + fnr = forespoersel.fnr, navn = sykmeldtNavn, ), avsender = Avsender( - orgnr = forespoersel.orgnr.let(::Orgnr), + orgnr = forespoersel.orgnr, orgNavn = virksomhetNavn, navn = avsenderNavn, tlf = skjema.avsenderTlf, diff --git a/berik-inntektsmelding-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingServiceTest.kt b/berik-inntektsmelding-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingServiceTest.kt index cf3a1c79d..4f0a7ab2e 100644 --- a/berik-inntektsmelding-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingServiceTest.kt +++ b/berik-inntektsmelding-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/BerikInntektsmeldingServiceTest.kt @@ -157,11 +157,11 @@ private object Mock { private val sykmeldt = Person( - fnr = Fnr(forespoersel.fnr), + fnr = forespoersel.fnr, navn = "Dolly Duck", ) - private val orgnrMedNavn = mapOf(Orgnr(forespoersel.orgnr) to "Lasses kasserollesjappe") + private val orgnrMedNavn = mapOf(forespoersel.orgnr to "Lasses kasserollesjappe") private val personer = mapOf( diff --git a/berik-inntektsmelding-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/MapInntektsmeldingKtTest.kt b/berik-inntektsmelding-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/MapInntektsmeldingKtTest.kt index b0892d9da..c3d5cdd63 100644 --- a/berik-inntektsmelding-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/MapInntektsmeldingKtTest.kt +++ b/berik-inntektsmelding-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/berikinntektsmeldingservice/MapInntektsmeldingKtTest.kt @@ -21,8 +21,6 @@ import no.nav.helsearbeidsgiver.felles.test.mock.utenPaakrevdRefusjon import no.nav.helsearbeidsgiver.utils.test.date.august import no.nav.helsearbeidsgiver.utils.test.date.desember import no.nav.helsearbeidsgiver.utils.test.date.juli -import no.nav.helsearbeidsgiver.utils.wrapper.Fnr -import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.time.ZonedDateTime import kotlin.time.Duration.Companion.seconds import kotlin.time.toJavaDuration @@ -57,13 +55,13 @@ class MapInntektsmeldingKtTest : sykmeldt shouldBe Sykmeldt( - fnr = forespoersel.fnr.let(::Fnr), + fnr = forespoersel.fnr, navn = sykmeldtNavn, ) avsender shouldBe Avsender( - orgnr = forespoersel.orgnr.let(::Orgnr), + orgnr = forespoersel.orgnr, orgNavn = virksomhetNavn, navn = avsenderNavn, tlf = skjema.avsenderTlf, diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/domene/Forespoersel.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/domene/Forespoersel.kt index f17717d71..7d51f9e38 100644 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/domene/Forespoersel.kt +++ b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/domene/Forespoersel.kt @@ -8,17 +8,19 @@ import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.Periode import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.bestemmendeFravaersdag import no.nav.helsearbeidsgiver.utils.json.serializer.LocalDateSerializer import no.nav.helsearbeidsgiver.utils.json.serializer.UuidSerializer +import no.nav.helsearbeidsgiver.utils.wrapper.Fnr +import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.time.LocalDate import java.util.UUID @Serializable data class Forespoersel( - val orgnr: String, - val fnr: String, + val orgnr: Orgnr, + val fnr: Fnr, val vedtaksperiodeId: UUID, val sykmeldingsperioder: List, val egenmeldingsperioder: List, - val bestemmendeFravaersdager: Map, + val bestemmendeFravaersdager: Map, val forespurtData: ForespurtData, val erBesvart: Boolean, val opprettetUpresisIkkeBruk: LocalDate, diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/domene/ForespoerselFraBro.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/domene/ForespoerselFraBro.kt index 0dc6ea5fd..8f279badf 100644 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/domene/ForespoerselFraBro.kt +++ b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/domene/ForespoerselFraBro.kt @@ -28,12 +28,12 @@ data class ForespoerselFraBro( ) { fun toForespoersel(): Forespoersel = Forespoersel( - orgnr = orgnr.verdi, - fnr = fnr.verdi, + orgnr = orgnr, + fnr = fnr, vedtaksperiodeId = vedtaksperiodeId, sykmeldingsperioder = sykmeldingsperioder, egenmeldingsperioder = egenmeldingsperioder, - bestemmendeFravaersdager = bestemmendeFravaersdager.mapKeys { it.key.verdi }, + bestemmendeFravaersdager = bestemmendeFravaersdager, forespurtData = forespurtData, erBesvart = erBesvart, opprettetUpresisIkkeBruk = opprettetUpresisIkkeBruk, diff --git a/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/ForespoerselTest.kt b/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/ForespoerselTest.kt index 398a3b5d6..683431c50 100644 --- a/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/ForespoerselTest.kt +++ b/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/ForespoerselTest.kt @@ -18,13 +18,15 @@ import no.nav.helsearbeidsgiver.utils.test.date.mai import no.nav.helsearbeidsgiver.utils.test.date.mars import no.nav.helsearbeidsgiver.utils.test.date.november import no.nav.helsearbeidsgiver.utils.test.date.september +import no.nav.helsearbeidsgiver.utils.test.wrapper.genererGyldig +import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr class ForespoerselTest : FunSpec({ context(Forespoersel::forslagBestemmendeFravaersdag.name) { test("bestemmende fraværsdag-forslaget fra Spleis overstyres av eldre sykmelding + egenmelding") { - val orgnr = "555898023" + val orgnr = Orgnr.genererGyldig() val forespoersel = mockForespoersel().copy( @@ -34,7 +36,7 @@ class ForespoerselTest : bestemmendeFravaersdager = mapOf( orgnr to 1.juli, - "444707112" to 13.mai, + Orgnr.genererGyldig() to 13.mai, ), ) @@ -42,7 +44,7 @@ class ForespoerselTest : } test("bestemmende fraværsdag-forslaget fra Spleis brukes dersom den er tidligere enn sykmelding + egenmelding") { - val orgnr = "555898023" + val orgnr = Orgnr.genererGyldig() val forespoersel = mockForespoersel().copy( @@ -55,7 +57,7 @@ class ForespoerselTest : bestemmendeFravaersdager = mapOf( orgnr to 1.juli, - "444707112" to 13.mai, + Orgnr.genererGyldig() to 13.mai, ), ) @@ -63,7 +65,7 @@ class ForespoerselTest : } test("bestemmende fraværsdag-forslaget fra Spleis brukes dersom det ikke finnes egenmeldinger") { - val orgnr = "555898023" + val orgnr = Orgnr.genererGyldig() val forespoersel = mockForespoersel().copy( @@ -76,7 +78,7 @@ class ForespoerselTest : bestemmendeFravaersdager = mapOf( orgnr to 1.juli, - "444707112" to 13.mai, + Orgnr.genererGyldig() to 13.mai, ), ) @@ -86,7 +88,7 @@ class ForespoerselTest : test("beregner bestemmende fraværsdag dersom det mangler for eget orgnr") { val forespoersel = mockForespoersel().copy( - orgnr = "555898023", + orgnr = Orgnr.genererGyldig(), sykmeldingsperioder = listOf( 5.januar til 30.januar, @@ -94,7 +96,7 @@ class ForespoerselTest : egenmeldingsperioder = listOf(1.januar til 1.januar), bestemmendeFravaersdager = mapOf( - "444707112" to 13.mai, + Orgnr.genererGyldig() to 13.mai, ), ) @@ -105,10 +107,10 @@ class ForespoerselTest : val forespoersel = mockForespoersel() .copy( - orgnr = "555898023", + orgnr = Orgnr.genererGyldig(), sykmeldingsperioder = listOf(7.mars til 31.mars), egenmeldingsperioder = listOf(5.mars til 6.mars), - bestemmendeFravaersdager = mapOf("444707112" to 14.april), + bestemmendeFravaersdager = mapOf(Orgnr.genererGyldig() to 14.april), ).utenPaakrevdAGP() forespoersel.forslagBestemmendeFravaersdag() shouldBe 7.mars @@ -117,7 +119,7 @@ class ForespoerselTest : context(Forespoersel::forslagInntektsdato.name) { test("gir minste bestemmende fraværsdag (når det stammer fra eget orgnr og den er tidligere enn sykmelding + egenmelding)") { - val orgnr = "333848343" + val orgnr = Orgnr.genererGyldig() val forespoersel = mockForespoersel().copy( @@ -130,8 +132,8 @@ class ForespoerselTest : bestemmendeFravaersdager = mapOf( orgnr to 28.februar, - "851993994" to 1.mars, - "900505434" to 3.mars, + Orgnr.genererGyldig() to 1.mars, + Orgnr.genererGyldig() to 3.mars, ), ) @@ -139,7 +141,7 @@ class ForespoerselTest : } test("gir minste bestemmende fraværsdag (når det stammer fra annet orgnr og den er tidligere enn sykmelding + egenmelding)") { - val orgnr = "333848343" + val orgnr = Orgnr.genererGyldig() val forespoersel = mockForespoersel().copy( @@ -152,8 +154,8 @@ class ForespoerselTest : bestemmendeFravaersdager = mapOf( orgnr to 9.november, - "851993994" to 4.november, - "900505434" to 2.desember, + Orgnr.genererGyldig() to 4.november, + Orgnr.genererGyldig() to 2.desember, ), ) @@ -163,7 +165,7 @@ class ForespoerselTest : test("gir minste bestemmende fraværsdag selv uten eget orgnr når den er tidligere enn sykmelding + egenmelding") { val forespoersel = mockForespoersel().copy( - orgnr = "333848343", + orgnr = Orgnr.genererGyldig(), sykmeldingsperioder = listOf( 1.desember til 31.desember, @@ -171,8 +173,8 @@ class ForespoerselTest : egenmeldingsperioder = listOf(28.november til 29.november), bestemmendeFravaersdager = mapOf( - "851993994" to 7.juni, - "900505434" to 5.juni, + Orgnr.genererGyldig() to 7.juni, + Orgnr.genererGyldig() to 5.juni, ), ) @@ -180,7 +182,7 @@ class ForespoerselTest : } test("gir minste bestemmende fraværsdag dersom det ikke finnes egenmeldinger") { - val orgnr = "333848343" + val orgnr = Orgnr.genererGyldig() val forespoersel = mockForespoersel().copy( @@ -193,8 +195,8 @@ class ForespoerselTest : bestemmendeFravaersdager = mapOf( orgnr to 11.desember, - "851993994" to 8.desember, - "900505434" to 7.desember, + Orgnr.genererGyldig() to 8.desember, + Orgnr.genererGyldig() to 7.desember, ), ) @@ -204,7 +206,7 @@ class ForespoerselTest : test("beregner bestemmende fraværsdag fra sykmelding + egenmelding dersom de kommer tidligere enn bestemmende fraværsdager fra Spleis") { val forespoersel = mockForespoersel().copy( - orgnr = "333848343", + orgnr = Orgnr.genererGyldig(), sykmeldingsperioder = listOf( 2.januar til 31.januar, @@ -212,8 +214,8 @@ class ForespoerselTest : egenmeldingsperioder = listOf(1.januar til 1.januar), bestemmendeFravaersdager = mapOf( - "851993994" to 7.juni, - "900505434" to 5.juni, + Orgnr.genererGyldig() to 7.juni, + Orgnr.genererGyldig() to 5.juni, ), ) @@ -237,7 +239,7 @@ class ForespoerselTest : val forespoersel = mockForespoersel() .copy( - orgnr = "333848343", + orgnr = Orgnr.genererGyldig(), sykmeldingsperioder = listOf(8.august til 28.august), egenmeldingsperioder = listOf(2.august til 7.august), bestemmendeFravaersdager = emptyMap(), @@ -249,7 +251,7 @@ class ForespoerselTest : context(Forespoersel::eksternBestemmendeFravaersdag.name) { test("gir minste bestemmende fraværsdag blant andre orgnr (når eget orgnr tilstede)") { - val orgnr = "666747222" + val orgnr = Orgnr.genererGyldig() val forespoersel = mockForespoersel().copy( @@ -257,8 +259,8 @@ class ForespoerselTest : bestemmendeFravaersdager = mapOf( orgnr to 12.august, - "567923412" to 19.september, - "393540723" to 27.september, + Orgnr.genererGyldig() to 19.september, + Orgnr.genererGyldig() to 27.september, ), ) @@ -268,11 +270,11 @@ class ForespoerselTest : test("gir minste bestemmende fraværsdag blant andre orgnr (når eget orgnr mangler)") { val forespoersel = mockForespoersel().copy( - orgnr = "666747222", + orgnr = Orgnr.genererGyldig(), bestemmendeFravaersdager = mapOf( - "567923412" to 13.juli, - "393540723" to 12.juli, + Orgnr.genererGyldig() to 13.juli, + Orgnr.genererGyldig() to 12.juli, ), ) @@ -280,7 +282,7 @@ class ForespoerselTest : } test("gir 'null' dersom bestemmende fraværsdag kun er tilstede for eget orgnr") { - val orgnr = "666747222" + val orgnr = Orgnr.genererGyldig() val forespoersel = mockForespoersel().copy( diff --git a/felles/src/testFixtures/kotlin/no/nav/helsearbeidsgiver/felles/test/mock/MockForespoersel.kt b/felles/src/testFixtures/kotlin/no/nav/helsearbeidsgiver/felles/test/mock/MockForespoersel.kt index dff9e1ed4..4c296f601 100644 --- a/felles/src/testFixtures/kotlin/no/nav/helsearbeidsgiver/felles/test/mock/MockForespoersel.kt +++ b/felles/src/testFixtures/kotlin/no/nav/helsearbeidsgiver/felles/test/mock/MockForespoersel.kt @@ -16,15 +16,15 @@ import java.util.UUID fun mockForespoersel(): Forespoersel { val orgnr = Orgnr.genererGyldig() return Forespoersel( - orgnr = orgnr.verdi, - fnr = Fnr.genererGyldig().verdi, + orgnr = orgnr, + fnr = Fnr.genererGyldig(), vedtaksperiodeId = UUID.randomUUID(), sykmeldingsperioder = listOf(2.januar til 31.januar), egenmeldingsperioder = listOf(1.januar til 1.januar), bestemmendeFravaersdager = mapOf( - orgnr.verdi to 1.januar, - Orgnr.genererGyldig().verdi to 5.januar, + orgnr to 1.januar, + Orgnr.genererGyldig() to 5.januar, ), forespurtData = mockForespurtData(), erBesvart = false, diff --git a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/BerikInntektsmeldingServiceIT.kt b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/BerikInntektsmeldingServiceIT.kt index bb247e94e..435855f7d 100644 --- a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/BerikInntektsmeldingServiceIT.kt +++ b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/BerikInntektsmeldingServiceIT.kt @@ -104,7 +104,7 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() { .verifiserForespoerselIdFraSkjema() .also { val data = it[Key.DATA].shouldNotBeNull().toMap() - data[Key.VIRKSOMHETER]?.fromJson(orgMapSerializer) shouldBe mapOf(Mock.forespoersel.orgnr.let(::Orgnr) to "Bedrift A/S") + data[Key.VIRKSOMHETER]?.fromJson(orgMapSerializer) shouldBe mapOf(Mock.forespoersel.orgnr to "Bedrift A/S") } // Inntektsmelding lagret @@ -228,7 +228,7 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() { .verifiserForespoerselIdFraSkjema() .also { val data = it[Key.DATA].shouldNotBeNull().toMap() - data[Key.VIRKSOMHETER]?.fromJson(orgMapSerializer) shouldBe mapOf(Mock.forespoersel.orgnr.let(::Orgnr) to "Bedrift A/S") + data[Key.VIRKSOMHETER]?.fromJson(orgMapSerializer) shouldBe mapOf(Mock.forespoersel.orgnr to "Bedrift A/S") } // Personnavn ikke hentet @@ -331,8 +331,8 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() { val forespoersel = Forespoersel( - orgnr = orgnr.verdi, - fnr = bjarneBetjent.ident!!, + orgnr = orgnr, + fnr = bjarneBetjent.ident!!.let(::Fnr), vedtaksperiodeId = UUID.randomUUID(), sykmeldingsperioder = listOf( @@ -344,7 +344,7 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() { 26.juni til 27.juni, 29.juni til 29.juni, ), - bestemmendeFravaersdager = mapOf(orgnr.verdi to 15.juli), + bestemmendeFravaersdager = mapOf(orgnr to 15.juli), forespurtData = mockForespurtData(), erBesvart = false, opprettetUpresisIkkeBruk = 2.august, @@ -352,13 +352,13 @@ class BerikInntektsmeldingServiceIT : EndToEndTest() { val forespoerselSvar = ForespoerselFraBro( - orgnr = Orgnr(forespoersel.orgnr), - fnr = Fnr(forespoersel.fnr), + orgnr = forespoersel.orgnr, + fnr = forespoersel.fnr, forespoerselId = forespoerselId, vedtaksperiodeId = forespoersel.vedtaksperiodeId, egenmeldingsperioder = forespoersel.egenmeldingsperioder, sykmeldingsperioder = forespoersel.sykmeldingsperioder, - bestemmendeFravaersdager = forespoersel.bestemmendeFravaersdager.mapKeys { Orgnr(it.key) }, + bestemmendeFravaersdager = forespoersel.bestemmendeFravaersdager, forespurtData = mockForespurtData(), erBesvart = false, opprettetUpresisIkkeBruk = forespoersel.opprettetUpresisIkkeBruk, diff --git a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InnsendingIT.kt b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InnsendingIT.kt index c13df278c..00d8e757d 100644 --- a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InnsendingIT.kt +++ b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InnsendingIT.kt @@ -186,8 +186,8 @@ class InnsendingIT : EndToEndTest() { val forespoersel = Forespoersel( - orgnr = orgnr.verdi, - fnr = bjarneBetjent.ident!!, + orgnr = orgnr, + fnr = bjarneBetjent.ident!!.let(::Fnr), vedtaksperiodeId = UUID.randomUUID(), sykmeldingsperioder = listOf( @@ -199,7 +199,7 @@ class InnsendingIT : EndToEndTest() { 26.juni til 27.juni, 29.juni til 29.juni, ), - bestemmendeFravaersdager = mapOf(orgnr.verdi to 15.juli), + bestemmendeFravaersdager = mapOf(orgnr to 15.juli), forespurtData = mockForespurtData(), erBesvart = false, opprettetUpresisIkkeBruk = 17.juli, @@ -207,13 +207,13 @@ class InnsendingIT : EndToEndTest() { val forespoerselSvar = ForespoerselFraBro( - orgnr = Orgnr(forespoersel.orgnr), - fnr = Fnr(forespoersel.fnr), + orgnr = forespoersel.orgnr, + fnr = forespoersel.fnr, forespoerselId = forespoerselId, vedtaksperiodeId = forespoersel.vedtaksperiodeId, egenmeldingsperioder = forespoersel.egenmeldingsperioder, sykmeldingsperioder = forespoersel.sykmeldingsperioder, - bestemmendeFravaersdager = forespoersel.bestemmendeFravaersdager.mapKeys { Orgnr(it.key) }, + bestemmendeFravaersdager = forespoersel.bestemmendeFravaersdager, forespurtData = mockForespurtData(), erBesvart = false, opprettetUpresisIkkeBruk = forespoersel.opprettetUpresisIkkeBruk, diff --git a/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilPaaminnelseService.kt b/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilPaaminnelseService.kt index 9cea79a49..b68098831 100644 --- a/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilPaaminnelseService.kt +++ b/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilPaaminnelseService.kt @@ -80,7 +80,7 @@ class HentDataTilPaaminnelseService( Key.DATA to data .plus( - Key.ORGNR_UNDERENHETER to setOf(steg1.forespoersel.orgnr).toJson(String.serializer()), + Key.ORGNR_UNDERENHETER to setOf(steg1.forespoersel.orgnr).toJson(Orgnr.serializer()), ).toJson(), ) } @@ -96,7 +96,7 @@ class HentDataTilPaaminnelseService( sikkerLogger.info(it) } - val orgNavn = steg2.orgnrMedNavn[steg1.forespoersel.orgnr.let(::Orgnr)] ?: ORG_NAVN_DEFAULT + val orgNavn = steg2.orgnrMedNavn[steg1.forespoersel.orgnr] ?: ORG_NAVN_DEFAULT rapid.publish( key = steg0.forespoerselId, diff --git a/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilSakOgOppgaveService.kt b/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilSakOgOppgaveService.kt index 0c5644452..6df7480ec 100644 --- a/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilSakOgOppgaveService.kt +++ b/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilSakOgOppgaveService.kt @@ -82,7 +82,7 @@ class HentDataTilSakOgOppgaveService( Key.DATA to data .plus( - Key.ORGNR_UNDERENHETER to setOf(steg0.forespoersel.orgnr).toJson(String.serializer()), + Key.ORGNR_UNDERENHETER to setOf(steg0.forespoersel.orgnr).toJson(Orgnr.serializer()), ).toJson(), ) } @@ -100,7 +100,7 @@ class HentDataTilSakOgOppgaveService( Key.DATA to data .plus( - Key.FNR_LISTE to setOf(steg0.forespoersel.fnr).toJson(String.serializer()), + Key.FNR_LISTE to setOf(steg0.forespoersel.fnr).toJson(Fnr.serializer()), ).toJson(), ) } @@ -116,8 +116,8 @@ class HentDataTilSakOgOppgaveService( sikkerLogger.info(it) } - val orgNavn = steg1.orgnrMedNavn[steg0.forespoersel.orgnr.let(::Orgnr)] ?: ORG_NAVN_DEFAULT - val sykmeldt = steg2.personer[steg0.forespoersel.fnr.let(::Fnr)] ?: personDefault(steg0.forespoersel.fnr.let(::Fnr)) + val orgNavn = steg1.orgnrMedNavn[steg0.forespoersel.orgnr] ?: ORG_NAVN_DEFAULT + val sykmeldt = steg2.personer[steg0.forespoersel.fnr] ?: personDefault(steg0.forespoersel.fnr) rapid.publish( key = steg0.forespoerselId, diff --git a/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/EndrePaaminnelseRiver.kt b/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/EndrePaaminnelseRiver.kt index 85fdc56ac..e3990a247 100644 --- a/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/EndrePaaminnelseRiver.kt +++ b/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/EndrePaaminnelseRiver.kt @@ -57,7 +57,7 @@ class EndrePaaminnelseRiver( override fun EndrePaaminnelseMelding.haandter(json: Map): Map? { endreOppgavePaaminnelser( forespoerselId = forespoerselId, - orgnr = forespoersel.orgnr.let(::Orgnr), + orgnr = forespoersel.orgnr, orgNavn = orgNavn, sykmeldingsperioder = forespoersel.sykmeldingsperioder, ) diff --git a/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiver.kt b/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiver.kt index 04870c02a..ae5b64933 100644 --- a/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiver.kt +++ b/notifikasjon/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiver.kt @@ -22,7 +22,6 @@ import no.nav.helsearbeidsgiver.utils.json.serializer.UuidSerializer import no.nav.helsearbeidsgiver.utils.json.toJson import no.nav.helsearbeidsgiver.utils.log.logger import no.nav.helsearbeidsgiver.utils.log.sikkerLogger -import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.util.UUID data class OpprettForespoerselSakOgOppgaveMelding( @@ -67,7 +66,7 @@ class OpprettForespoerselSakOgOppgaveRiver( agNotifikasjonKlient.opprettSak( lenke = lenke, inntektsmeldingTypeId = forespoerselId, - orgnr = forespoersel.orgnr.let(::Orgnr), + orgnr = forespoersel.orgnr, sykmeldt = sykmeldt, sykmeldingsperioder = forespoersel.sykmeldingsperioder, ) @@ -76,7 +75,7 @@ class OpprettForespoerselSakOgOppgaveRiver( agNotifikasjonKlient.opprettOppgave( lenke = lenke, forespoerselId = forespoerselId, - orgnr = forespoersel.orgnr.let(::Orgnr), + orgnr = forespoersel.orgnr, orgNavn = orgNavn, skalHaPaaminnelse = skalHaPaaminnelse, paaminnelseAktivert = paaminnelseToggle.oppgavePaaminnelseAktivert, diff --git a/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilPaaminnelseServiceTest.kt b/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilPaaminnelseServiceTest.kt index 07ebef115..3282c1526 100644 --- a/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilPaaminnelseServiceTest.kt +++ b/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilPaaminnelseServiceTest.kt @@ -22,7 +22,6 @@ import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.firstMessage import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.message import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.sendJson import no.nav.helsearbeidsgiver.utils.json.toJson -import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.util.UUID class HentDataTilPaaminnelseServiceTest : @@ -91,7 +90,7 @@ private object HentDataTilPaaminnelseServiceMock { val forespoersel = mockForespoersel() val transaksjonId: UUID = forespoersel.vedtaksperiodeId val forespoerselId: UUID = UUID.randomUUID() - val orgnrMedNavn = mapOf(forespoersel.orgnr.let(::Orgnr) to "Kåre Conradis Kål og Kålrabi") + val orgnrMedNavn = mapOf(forespoersel.orgnr to "Kåre Conradis Kål og Kålrabi") fun steg0(): Map = mapOf( diff --git a/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilSakOgOppgaveServiceTest.kt b/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilSakOgOppgaveServiceTest.kt index 44b539819..3f1aa2de8 100644 --- a/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilSakOgOppgaveServiceTest.kt +++ b/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/HentDataTilSakOgOppgaveServiceTest.kt @@ -25,8 +25,6 @@ import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.firstMessage import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.message import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.sendJson import no.nav.helsearbeidsgiver.utils.json.toJson -import no.nav.helsearbeidsgiver.utils.wrapper.Fnr -import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.util.UUID class HentDataTilSakOgOppgaveServiceTest : @@ -101,8 +99,8 @@ private object Mock { val forespoersel = mockForespoersel() val transaksjonId: UUID = forespoersel.vedtaksperiodeId val forespoerselId: UUID = UUID.randomUUID() - val orgnrMedNavn = mapOf(forespoersel.orgnr.let(::Orgnr) to "Kåre Conradis Kål og Kålrabi") - val personer = listOf(forespoersel.fnr.let(::Fnr)).associateWith { Person(it, "Kåre Conradi") } + val orgnrMedNavn = mapOf(forespoersel.orgnr to "Kåre Conradis Kål og Kålrabi") + val personer = listOf(forespoersel.fnr).associateWith { Person(it, "Kåre Conradi") } fun steg0(): Map = mapOf( diff --git a/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/EndrePaaminnelseRiverTest.kt b/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/EndrePaaminnelseRiverTest.kt index 4e313e025..cb3008f69 100644 --- a/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/EndrePaaminnelseRiverTest.kt +++ b/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/EndrePaaminnelseRiverTest.kt @@ -26,7 +26,6 @@ import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.firstMessage import no.nav.helsearbeidsgiver.felles.test.rapidsrivers.sendJson import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.NotifikasjonTekst import no.nav.helsearbeidsgiver.utils.json.toJson -import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.util.UUID class EndrePaaminnelseRiverTest : @@ -137,7 +136,7 @@ object EndrePaaminnelseMock { Paaminnelse( NotifikasjonTekst.PAAMINNELSE_TITTEL, NotifikasjonTekst.paaminnelseInnhold( - orgnr = Orgnr(forespoersel.orgnr), + orgnr = forespoersel.orgnr, orgNavn = orgNavn, sykmeldingsperioder = forespoersel.sykmeldingsperioder, ), diff --git a/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiverTest.kt b/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiverTest.kt index 9e6f6b549..79eb01667 100644 --- a/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiverTest.kt +++ b/notifikasjon/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/notifikasjon/river/OpprettForespoerselSakOgOppgaveRiverTest.kt @@ -31,8 +31,6 @@ import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.NotifikasjonTekst import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.PaaminnelseToggle import no.nav.helsearbeidsgiver.inntektsmelding.notifikasjon.sakLevetid import no.nav.helsearbeidsgiver.utils.json.toJson -import no.nav.helsearbeidsgiver.utils.wrapper.Fnr -import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.util.UUID class OpprettForespoerselSakOgOppgaveRiverTest : @@ -74,7 +72,7 @@ class OpprettForespoerselSakOgOppgaveRiverTest : coVerifySequence { mockAgNotifikasjonKlient.opprettNySak( - virksomhetsnummer = innkommendeMelding.forespoersel.orgnr, + virksomhetsnummer = innkommendeMelding.forespoersel.orgnr.verdi, grupperingsid = innkommendeMelding.forespoerselId.toString(), merkelapp = NotifikasjonTekst.MERKELAPP, lenke = "en-slags-url/im-dialog/${innkommendeMelding.forespoerselId}", @@ -85,7 +83,7 @@ class OpprettForespoerselSakOgOppgaveRiverTest : hardDeleteOm = sakLevetid, ) mockAgNotifikasjonKlient.opprettNyOppgave( - virksomhetsnummer = innkommendeMelding.forespoersel.orgnr, + virksomhetsnummer = innkommendeMelding.forespoersel.orgnr.verdi, eksternId = innkommendeMelding.forespoerselId.toString(), grupperingsid = innkommendeMelding.forespoerselId.toString(), merkelapp = NotifikasjonTekst.MERKELAPP, @@ -94,7 +92,7 @@ class OpprettForespoerselSakOgOppgaveRiverTest : varslingTittel = NotifikasjonTekst.STATUS_TEKST_UNDER_BEHANDLING, varslingInnhold = NotifikasjonTekst.oppgaveInnhold( - innkommendeMelding.forespoersel.orgnr.let(::Orgnr), + innkommendeMelding.forespoersel.orgnr, innkommendeMelding.orgNavn, innkommendeMelding.forespoersel.sykmeldingsperioder, ), @@ -104,7 +102,7 @@ class OpprettForespoerselSakOgOppgaveRiverTest : tittel = NotifikasjonTekst.PAAMINNELSE_TITTEL, innhold = NotifikasjonTekst.paaminnelseInnhold( - innkommendeMelding.forespoersel.orgnr.let(::Orgnr), + innkommendeMelding.forespoersel.orgnr, innkommendeMelding.orgNavn, innkommendeMelding.forespoersel.sykmeldingsperioder, ), @@ -253,24 +251,18 @@ class OpprettForespoerselSakOgOppgaveRiverTest : } }) -private object OpprettSakOgOppgaveMock { - val forespoerselId = UUID.randomUUID() +fun innkommendeOpprettForespoerselSakOgOppgaveMelding(): OpprettForespoerselSakOgOppgaveMelding { val forespoersel = mockForespoersel() - val orgnr = Orgnr(forespoersel.orgnr) - val orgNavn = "Peer Gynts Løgn og Bedrageri LTD" - val person = Person(Fnr(forespoersel.fnr), "Peer Gynt") -} - -fun innkommendeOpprettForespoerselSakOgOppgaveMelding(): OpprettForespoerselSakOgOppgaveMelding = - OpprettForespoerselSakOgOppgaveMelding( + return OpprettForespoerselSakOgOppgaveMelding( eventName = EventName.SAK_OG_OPPGAVE_OPPRETT_REQUESTED, transaksjonId = UUID.randomUUID(), - forespoerselId = OpprettSakOgOppgaveMock.forespoerselId, - sykmeldt = OpprettSakOgOppgaveMock.person, - orgNavn = OpprettSakOgOppgaveMock.orgNavn, + forespoerselId = UUID.randomUUID(), + sykmeldt = Person(forespoersel.fnr, "Peer Gynt"), + orgNavn = "Peer Gynts Løgn og Bedrageri LTD", skalHaPaaminnelse = true, - forespoersel = OpprettSakOgOppgaveMock.forespoersel, + forespoersel = forespoersel, ) +} private fun OpprettForespoerselSakOgOppgaveMelding.toMap() = mapOf( diff --git a/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselService.kt b/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselService.kt index d5fed7c3d..49fd2ebe5 100644 --- a/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselService.kt +++ b/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselService.kt @@ -1,7 +1,6 @@ package no.nav.helsearbeidsgiver.inntektsmelding.trengerservice import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection -import kotlinx.serialization.builtins.MapSerializer import kotlinx.serialization.builtins.serializer import kotlinx.serialization.json.JsonElement import no.nav.helsearbeidsgiver.felles.BehovType @@ -15,6 +14,7 @@ import no.nav.helsearbeidsgiver.felles.domene.Person import no.nav.helsearbeidsgiver.felles.domene.ResultJson import no.nav.helsearbeidsgiver.felles.json.les import no.nav.helsearbeidsgiver.felles.json.lesOrNull +import no.nav.helsearbeidsgiver.felles.json.orgMapSerializer import no.nav.helsearbeidsgiver.felles.json.personMapSerializer import no.nav.helsearbeidsgiver.felles.json.toJson import no.nav.helsearbeidsgiver.felles.rapidsrivers.KafkaKey @@ -32,6 +32,7 @@ import no.nav.helsearbeidsgiver.utils.log.MdcUtils import no.nav.helsearbeidsgiver.utils.log.logger import no.nav.helsearbeidsgiver.utils.log.sikkerLogger import no.nav.helsearbeidsgiver.utils.wrapper.Fnr +import no.nav.helsearbeidsgiver.utils.wrapper.Orgnr import java.util.UUID private const val UNDEFINED_FELT = "{}" @@ -50,7 +51,7 @@ data class Steg1( sealed class Steg2 { data class Komplett( - val orgnrMedNavn: Map, + val orgnrMedNavn: Map, val personer: Map, val inntekt: Inntekt?, ) : Steg2() @@ -81,7 +82,7 @@ class HentForespoerselService( ) override fun lesSteg2(melding: Map): Steg2 { - val orgnrMedNavn = runCatching { Key.VIRKSOMHETER.les(MapSerializer(String.serializer(), String.serializer()), melding) } + val orgnrMedNavn = runCatching { Key.VIRKSOMHETER.les(orgMapSerializer, melding) } val personer = runCatching { Key.PERSONER.les(personMapSerializer, melding) } val inntekt = runCatching { @@ -138,7 +139,7 @@ class HentForespoerselService( mapOf( Key.SVAR_KAFKA_KEY to svarKafkaKey.toJson(), Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(), - Key.ORGNR_UNDERENHETER to setOf(steg1.forespoersel.orgnr).toJson(String.serializer()), + Key.ORGNR_UNDERENHETER to setOf(steg1.forespoersel.orgnr).toJson(Orgnr.serializer()), ).toJson(), ).also { loggBehovPublisert(BehovType.HENT_VIRKSOMHET_NAVN, it) } @@ -154,7 +155,7 @@ class HentForespoerselService( Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(), Key.FNR_LISTE to setOf( - steg1.forespoersel.fnr.let(::Fnr), + steg1.forespoersel.fnr, steg0.avsenderFnr, ).toJson(Fnr.serializer()), ).toJson(), @@ -184,7 +185,7 @@ class HentForespoerselService( steg2: Steg2, ) { if (steg2 is Steg2.Komplett) { - val sykmeldtNavn = steg2.personer[steg1.forespoersel.fnr.let(::Fnr)]?.navn ?: UKJENT_NAVN + val sykmeldtNavn = steg2.personer[steg1.forespoersel.fnr]?.navn ?: UKJENT_NAVN val avsenderNavn = steg2.personer[steg0.avsenderFnr]?.navn ?: UKJENT_NAVN val orgNavn = steg2.orgnrMedNavn[steg1.forespoersel.orgnr] ?: UKJENT_VIRKSOMHET diff --git a/trengerservice/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselServiceTest.kt b/trengerservice/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselServiceTest.kt index 58ce9e3d6..b9612faf9 100644 --- a/trengerservice/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselServiceTest.kt +++ b/trengerservice/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerselServiceTest.kt @@ -18,6 +18,7 @@ import no.nav.helsearbeidsgiver.felles.domene.InntektPerMaaned import no.nav.helsearbeidsgiver.felles.domene.Person import no.nav.helsearbeidsgiver.felles.domene.ResultJson import no.nav.helsearbeidsgiver.felles.json.lesOrNull +import no.nav.helsearbeidsgiver.felles.json.orgMapSerializer import no.nav.helsearbeidsgiver.felles.json.personMapSerializer import no.nav.helsearbeidsgiver.felles.json.toJson import no.nav.helsearbeidsgiver.felles.rapidsrivers.KafkaKey @@ -121,7 +122,7 @@ private object Mock { ), forespoersel = mockForespoersel().copy( - fnr = sykmeldt.fnr.verdi, + fnr = sykmeldt.fnr, ), feil = emptyMap(), ) @@ -153,7 +154,7 @@ private object Mock { Key.KONTEKST_ID to transaksjonId.toJson(), Key.DATA to mapOf( - Key.VIRKSOMHETER to mapOf(resultat.forespoersel.orgnr to resultat.orgNavn).toJson(), + Key.VIRKSOMHETER to mapOf(resultat.forespoersel.orgnr to resultat.orgNavn).toJson(orgMapSerializer), Key.PERSONER to mapOf( sykmeldt.fnr to sykmeldt,