From dbb040e4562f459e2cc7d578a5140ba6f53f17d9 Mon Sep 17 00:00:00 2001 From: Jesper Hustad Date: Mon, 25 Nov 2024 14:40:08 +0100 Subject: [PATCH 1/4] Lagt til midlertidlig SPINN_INNTEKTSMELDING_ID_V2 key --- .gitignore | 1 + felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt | 1 + .../forespoerselbesvart/ForespoerselBesvartRiver.kt | 1 + .../forespoerselbesvart/ForespoerselBesvartRiverTest.kt | 1 + 4 files changed, 4 insertions(+) diff --git a/.gitignore b/.gitignore index 876d186bd..c6844d4d8 100644 --- a/.gitignore +++ b/.gitignore @@ -3,3 +3,4 @@ **/build out .DS_Store +.kotlin \ No newline at end of file diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt index 8cc2d13b0..a4225237e 100644 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt +++ b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt @@ -54,6 +54,7 @@ enum class Key( // ulik formattering SPINN_INNTEKTSMELDING_ID("spinnInntektsmeldingId"), + SPINN_INNTEKTSMELDING_ID_V2("spinn_inntektsmelding_id"), ; diff --git a/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt b/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt index 4898598be..519825bab 100644 --- a/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt +++ b/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt @@ -52,6 +52,7 @@ class ForespoerselBesvartRiver : PriObjectRiver() { mapOf( Key.FORESPOERSEL_ID to forespoerselId.toJson(), Key.SPINN_INNTEKTSMELDING_ID to spinnInntektsmeldingId?.toJson(), + Key.SPINN_INNTEKTSMELDING_ID_V2 to spinnInntektsmeldingId?.toJson(), ).mapValuesNotNull { it } .toJson(), ) diff --git a/forespoersel-besvart/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiverTest.kt b/forespoersel-besvart/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiverTest.kt index 3230342b3..817638503 100644 --- a/forespoersel-besvart/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiverTest.kt +++ b/forespoersel-besvart/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiverTest.kt @@ -64,6 +64,7 @@ class ForespoerselBesvartRiverTest : mapOf( Key.FORESPOERSEL_ID to forespoerselId.toJson(), Key.SPINN_INNTEKTSMELDING_ID to spinnInntektsmeldingId.toJson(), + Key.SPINN_INNTEKTSMELDING_ID_V2 to spinnInntektsmeldingId.toJson(), ).toJson(), ) From c5103694f6ddcc7ee727397cdb4d498cc4ad8b23 Mon Sep 17 00:00:00 2001 From: Jesper Hustad Date: Mon, 25 Nov 2024 14:45:52 +0100 Subject: [PATCH 2/4] lagt til logging av pri-topic melding --- .../ForespoerselBesvartRiver.kt | 26 +++++++++++-------- 1 file changed, 15 insertions(+), 11 deletions(-) diff --git a/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt b/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt index 519825bab..6599331f8 100644 --- a/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt +++ b/forespoersel-besvart/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/forespoerselbesvart/ForespoerselBesvartRiver.kt @@ -45,17 +45,21 @@ class ForespoerselBesvartRiver : PriObjectRiver() { Metrics.forespoerslerBesvartFraSpleis.inc() - return mapOf( - Key.EVENT_NAME to EventName.FORESPOERSEL_BESVART.toJson(), - Key.KONTEKST_ID to transaksjonId.toJson(), - Key.DATA to - mapOf( - Key.FORESPOERSEL_ID to forespoerselId.toJson(), - Key.SPINN_INNTEKTSMELDING_ID to spinnInntektsmeldingId?.toJson(), - Key.SPINN_INNTEKTSMELDING_ID_V2 to spinnInntektsmeldingId?.toJson(), - ).mapValuesNotNull { it } - .toJson(), - ) + val resultat = + mapOf( + Key.EVENT_NAME to EventName.FORESPOERSEL_BESVART.toJson(), + Key.KONTEKST_ID to transaksjonId.toJson(), + Key.DATA to + mapOf( + Key.FORESPOERSEL_ID to forespoerselId.toJson(), + Key.SPINN_INNTEKTSMELDING_ID to spinnInntektsmeldingId?.toJson(), + Key.SPINN_INNTEKTSMELDING_ID_V2 to spinnInntektsmeldingId?.toJson(), + ).mapValuesNotNull { it } + .toJson(), + ) + logger.info("Sendt en melding fra pri-topic.") + sikkerLogger.info("Sendt en melding fra pri-topic:\n${resultat.toJson()}") + return resultat } override fun BesvartMelding.haandterFeil( From 61608778a8d9d7fb5e4bcbd00863a3ec57bb467c Mon Sep 17 00:00:00 2001 From: Jesper Hustad Date: Mon, 25 Nov 2024 16:33:23 +0100 Subject: [PATCH 3/4] =?UTF-8?q?endret=20navn=20p=C3=A5=20variabel=20key=20?= =?UTF-8?q?til=20ORGNR=5FUNDERENHET?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../inntektsmelding/altinn/TilgangRiver.kt | 2 +- .../inntektsmelding/altinn/TilgangRiverTest.kt | 2 +- .../inntektsmelding/api/auth/TilgangProducer.kt | 2 +- .../inntektselvbestemt/InntektSelvbestemtProducer.kt | 2 +- .../InntektSelvbestemtProducerTest.kt | 2 +- .../main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt | 2 +- .../felles/rapidsrivers/redis/RedisStoreTest.kt | 10 +++++----- .../InntektSelvbestemtService.kt | 4 ++-- .../InntektSelvbestemtServiceTest.kt | 2 +- .../inntektsmelding/inntekt/HentInntektRiver.kt | 2 +- .../inntektsmelding/inntekt/HentInntektRiverTest.kt | 2 +- .../inntektsmelding/inntektservice/InntektService.kt | 2 +- .../integrasjonstest/InntektSelvbestemtIT.kt | 6 +++--- .../tilgangservice/TilgangForespoerselService.kt | 2 +- .../tilgangservice/TilgangOrgService.kt | 4 ++-- .../trengerservice/HentForespoerselService.kt | 2 +- 16 files changed, 24 insertions(+), 24 deletions(-) diff --git a/altinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiver.kt b/altinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiver.kt index ab5c31efe..461f2de7e 100644 --- a/altinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiver.kt +++ b/altinn/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiver.kt @@ -48,7 +48,7 @@ class TilgangRiver( behovType = Key.BEHOV.krev(BehovType.TILGANGSKONTROLL, BehovType.serializer(), json), transaksjonId = Key.KONTEKST_ID.les(UuidSerializer, json), data = data, - orgnr = Key.ORGNRUNDERENHET.les(Orgnr.serializer(), data), + orgnr = Key.ORGNR_UNDERENHET.les(Orgnr.serializer(), data), fnr = Key.FNR.les(Fnr.serializer(), data), ) } diff --git a/altinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiverTest.kt b/altinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiverTest.kt index e2e27a770..c4a2a7b6c 100644 --- a/altinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiverTest.kt +++ b/altinn/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/altinn/TilgangRiverTest.kt @@ -133,7 +133,7 @@ private object MockTilgang { transaksjonId = UUID.randomUUID(), data = mapOf( - Key.ORGNRUNDERENHET to orgnr.toJson(Orgnr.serializer()), + Key.ORGNR_UNDERENHET to orgnr.toJson(Orgnr.serializer()), Key.FNR to fnr.toJson(Fnr.serializer()), ), orgnr = orgnr, diff --git a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/auth/TilgangProducer.kt b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/auth/TilgangProducer.kt index 84bd07405..50aae0369 100644 --- a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/auth/TilgangProducer.kt +++ b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/auth/TilgangProducer.kt @@ -42,7 +42,7 @@ class TilgangProducer( EventName.TILGANG_ORG_REQUESTED, transaksjonId, fnr, - Key.ORGNRUNDERENHET to orgnr.toJson(), + Key.ORGNR_UNDERENHET to orgnr.toJson(), ) private fun publish( diff --git a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt index 2120f9361..63061cc86 100644 --- a/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt +++ b/api/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducer.kt @@ -37,7 +37,7 @@ class InntektSelvbestemtProducer( Key.DATA to mapOf( Key.FNR to request.sykmeldtFnr.toJson(), - Key.ORGNRUNDERENHET to request.orgnr.toJson(), + Key.ORGNR_UNDERENHET to request.orgnr.toJson(), Key.INNTEKTSDATO to request.inntektsdato.toJson(), ).toJson(), ).also { json -> diff --git a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt index 8ae641e94..73b78e7f8 100644 --- a/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt +++ b/api/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/inntektselvbestemt/InntektSelvbestemtProducerTest.kt @@ -37,7 +37,7 @@ class InntektSelvbestemtProducerTest : Key.DATA to mapOf( Key.FNR to sykmeldtFnr.toJson(), - Key.ORGNRUNDERENHET to orgnr.toJson(), + Key.ORGNR_UNDERENHET to orgnr.toJson(), Key.INNTEKTSDATO to inntektsdato.toJson(), ).toJson(), ) diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt index a4225237e..2540f7911 100644 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt +++ b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/Key.kt @@ -50,7 +50,7 @@ enum class Key( VEDTAKSPERIODE_ID_LISTE("vedtaksperiode_id_liste"), VIRKSOMHET("virksomhet"), VIRKSOMHETER("virksomheter"), - ORGNRUNDERENHET("orgnr_underenhet"), + ORGNR_UNDERENHET("orgnr_underenhet"), // ulik formattering SPINN_INNTEKTSMELDING_ID("spinnInntektsmeldingId"), diff --git a/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/redis/RedisStoreTest.kt b/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/redis/RedisStoreTest.kt index a957026b1..519d116ee 100644 --- a/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/redis/RedisStoreTest.kt +++ b/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/redis/RedisStoreTest.kt @@ -30,7 +30,7 @@ class RedisStoreTest : "$keyPrefix#$transaksjonId" to "\"mango\"", "$keyPrefix#$transaksjonId#${Key.SAK_ID}#feil" to "\"papaya\"", "$keyPrefix#$transaksjonId#${Key.FNR}" to "\"ananas\"", - "$keyPrefix#$transaksjonId#${Key.ORGNRUNDERENHET}" to "\"kokosnøtt\"", + "$keyPrefix#$transaksjonId#${Key.ORGNR_UNDERENHET}" to "\"kokosnøtt\"", "$keyPrefix#$transaksjonId#${Key.TILGANG}" to null, ), ), @@ -42,7 +42,7 @@ class RedisStoreTest : redisStore.lesAlleMellomlagrede(transaksjonId) shouldContainExactly mapOf( Key.FNR to "ananas".toJson(), - Key.ORGNRUNDERENHET to "kokosnøtt".toJson(), + Key.ORGNR_UNDERENHET to "kokosnøtt".toJson(), ) } @@ -60,7 +60,7 @@ class RedisStoreTest : "${Key.FNR}" to "\"bringebær\"", "$transaksjonId#${Key.FNR}" to "\"blåbær\"", "$keyPrefix#$transaksjonId#ikkeEnKey" to "\"tyttebær\"", - "$keyPrefix#$transaksjonId#${Key.ORGNRUNDERENHET}" to "\"kokosnøtt\"", + "$keyPrefix#$transaksjonId#${Key.ORGNR_UNDERENHET}" to "\"kokosnøtt\"", ), ), keyPrefix = keyPrefix, @@ -70,7 +70,7 @@ class RedisStoreTest : redisStore.lesAlleMellomlagrede(transaksjonId) shouldContainExactly mapOf( - Key.ORGNRUNDERENHET to "kokosnøtt".toJson(), + Key.ORGNR_UNDERENHET to "kokosnøtt".toJson(), ) } @@ -85,7 +85,7 @@ class RedisStoreTest : mockStorageInit = mapOf( "$keyPrefix#$transaksjonId#${Key.FNR}" to "\"ananas\"", - "$keyPrefix#$transaksjonId#${Key.ORGNRUNDERENHET}" to "streng uten ekstra fnutter", + "$keyPrefix#$transaksjonId#${Key.ORGNR_UNDERENHET}" to "streng uten ekstra fnutter", "$keyPrefix#$transaksjonId#${Key.PERSONER}" to "{true}", "$keyPrefix#$transaksjonId#${Key.VIRKSOMHETER}" to "]]42[[", ), diff --git a/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt b/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt index 0f73b5ffb..9fe16a8fa 100644 --- a/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt +++ b/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt @@ -51,7 +51,7 @@ class InntektSelvbestemtService( Steg0( transaksjonId = Key.KONTEKST_ID.les(UuidSerializer, melding), fnr = Key.FNR.les(Fnr.serializer(), melding), - orgnr = Key.ORGNRUNDERENHET.les(Orgnr.serializer(), melding), + orgnr = Key.ORGNR_UNDERENHET.les(Orgnr.serializer(), melding), inntektsdato = Key.INNTEKTSDATO.les(LocalDateSerializer, melding), ) @@ -73,7 +73,7 @@ class InntektSelvbestemtService( data .plus( mapOf( - Key.ORGNRUNDERENHET to steg0.orgnr.toJson(), + Key.ORGNR_UNDERENHET to steg0.orgnr.toJson(), Key.FNR to steg0.fnr.toJson(), Key.INNTEKTSDATO to steg0.inntektsdato.toJson(), ), diff --git a/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt b/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt index 5a9f0d3c1..9edbebe8e 100644 --- a/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt +++ b/inntekt-selvbestemt-service/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtServiceTest.kt @@ -120,7 +120,7 @@ private object Mock { val steg0Data = mapOf( - Key.ORGNRUNDERENHET to Orgnr.genererGyldig().toJson(), + Key.ORGNR_UNDERENHET to Orgnr.genererGyldig().toJson(), Key.FNR to Fnr.genererGyldig().toJson(), Key.INNTEKTSDATO to 14.april.toJson(), ) diff --git a/inntekt/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiver.kt b/inntekt/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiver.kt index c84034e4c..6f8f8a72d 100644 --- a/inntekt/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiver.kt +++ b/inntekt/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiver.kt @@ -54,7 +54,7 @@ class HentInntektRiver( behovType = Key.BEHOV.krev(BehovType.HENT_INNTEKT, BehovType.serializer(), json), transaksjonId = Key.KONTEKST_ID.les(UuidSerializer, json), data = data, - orgnr = Key.ORGNRUNDERENHET.les(Orgnr.serializer(), data), + orgnr = Key.ORGNR_UNDERENHET.les(Orgnr.serializer(), data), fnr = Key.FNR.les(Fnr.serializer(), data), inntektsdato = Key.INNTEKTSDATO.les(LocalDateSerializer, data), ) diff --git a/inntekt/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiverTest.kt b/inntekt/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiverTest.kt index 14b81518c..1151a9bf6 100644 --- a/inntekt/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiverTest.kt +++ b/inntekt/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntekt/HentInntektRiverTest.kt @@ -175,7 +175,7 @@ private object Mock { transaksjonId = UUID.randomUUID(), data = mapOf( - Key.ORGNRUNDERENHET to orgnr.toJson(), + Key.ORGNR_UNDERENHET to orgnr.toJson(), Key.FNR to fnr.toJson(), Key.INNTEKTSDATO to inntektsdato.toJson(), ), diff --git a/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt b/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt index 753377cef..18d9358f3 100644 --- a/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt +++ b/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt @@ -103,7 +103,7 @@ class InntektService( data .plus( mapOf( - Key.ORGNRUNDERENHET to steg1.forespoersel.orgnr.toJson(), + Key.ORGNR_UNDERENHET to steg1.forespoersel.orgnr.toJson(), Key.FNR to steg1.forespoersel.fnr.toJson(), Key.INNTEKTSDATO to steg0.skjaeringstidspunkt.toJson(), ), diff --git a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt index 2741dfc53..3cddde89c 100644 --- a/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt +++ b/integrasjonstest/src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InntektSelvbestemtIT.kt @@ -34,7 +34,7 @@ class InntektSelvbestemtIT : EndToEndTest() { Key.DATA to mapOf( Key.FNR to Mock.fnr.toJson(), - Key.ORGNRUNDERENHET to Mock.orgnr.toJson(), + Key.ORGNR_UNDERENHET to Mock.orgnr.toJson(), Key.INNTEKTSDATO to Mock.inntektsdato.toJson(), ).toJson(), ) @@ -49,7 +49,7 @@ class InntektSelvbestemtIT : EndToEndTest() { Key.KONTEKST_ID to Mock.transaksjonId.toJson(), Key.DATA to mapOf( - Key.ORGNRUNDERENHET to Mock.orgnr.toJson(), + Key.ORGNR_UNDERENHET to Mock.orgnr.toJson(), Key.FNR to Mock.fnr.toJson(), Key.INNTEKTSDATO to Mock.inntektsdato.toJson(), ).toJson(), @@ -65,7 +65,7 @@ class InntektSelvbestemtIT : EndToEndTest() { Key.KONTEKST_ID to Mock.transaksjonId.toJson(), Key.DATA to mapOf( - Key.ORGNRUNDERENHET to Mock.orgnr.toJson(), + Key.ORGNR_UNDERENHET to Mock.orgnr.toJson(), Key.FNR to Mock.fnr.toJson(), Key.INNTEKTSDATO to Mock.inntektsdato.toJson(), Key.INNTEKT to Mock.inntektPerMaaned.toJson(Inntekt.serializer()), diff --git a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt index 7339864cc..6d3b99c01 100644 --- a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt +++ b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt @@ -106,7 +106,7 @@ class TilgangForespoerselService( data .plus( mapOf( - Key.ORGNRUNDERENHET to steg1.forespoersel.orgnr.toJson(), + Key.ORGNR_UNDERENHET to steg1.forespoersel.orgnr.toJson(), Key.FNR to steg0.avsenderFnr.toJson(), ), ).toJson(), diff --git a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt index 8e566a098..64d192156 100644 --- a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt +++ b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt @@ -47,7 +47,7 @@ class TilgangOrgService( override fun lesSteg0(melding: Map): Steg0 = Steg0( transaksjonId = Key.KONTEKST_ID.les(UuidSerializer, melding), - orgnr = Key.ORGNRUNDERENHET.les(Orgnr.serializer(), melding), + orgnr = Key.ORGNR_UNDERENHET.les(Orgnr.serializer(), melding), fnr = Key.FNR.les(Fnr.serializer(), melding), ) @@ -69,7 +69,7 @@ class TilgangOrgService( data .plus( mapOf( - Key.ORGNRUNDERENHET to steg0.orgnr.toJson(), + Key.ORGNR_UNDERENHET to steg0.orgnr.toJson(), Key.FNR to steg0.fnr.toJson(), ), ).toJson(), 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 9483adca8..e14a20ab4 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 @@ -162,7 +162,7 @@ class HentForespoerselService( Key.DATA to mapOf( Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(), - Key.ORGNRUNDERENHET to steg1.forespoersel.orgnr.toJson(), + Key.ORGNR_UNDERENHET to steg1.forespoersel.orgnr.toJson(), Key.FNR to steg1.forespoersel.fnr.toJson(), Key.INNTEKTSDATO to inntektsdato.toJson(), ).toJson(), From 3b6edcccbe3930260cb09cbe3103e4e5890080b8 Mon Sep 17 00:00:00 2001 From: Jesper Hustad Date: Tue, 26 Nov 2024 11:08:42 +0100 Subject: [PATCH 4/4] merget endringer fra main --- .../aktiveorgnrservice/AktiveOrgnrService.kt | 4 ++++ .../BerikInntektsmeldingService.kt | 5 ++++ .../felles/rapidsrivers/RiverUtils.kt | 2 -- .../felles/rapidsrivers/RiverUtilsKtTest.kt | 19 --------------- gradle.properties | 2 +- .../innsending/InnsendingService.kt | 19 ++++++++------- .../innsending/KvitteringService.kt | 1 + .../InntektSelvbestemtService.kt | 7 +++--- .../inntektservice/InntektService.kt | 2 ++ .../HentDataTilPaaminnelseService.kt | 24 ++++++++++--------- .../HentDataTilSakOgOppgaveService.kt | 24 ++++++++++--------- .../river/EndrePaaminnelseRiver.kt | 2 +- .../river/EndrePaaminnelseRiverTest.kt | 2 +- .../HentSelvbestemtImService.kt | 1 + .../LagreSelvbestemtImService.kt | 6 +++++ .../TilgangForespoerselService.kt | 2 ++ .../tilgangservice/TilgangOrgService.kt | 1 + .../trengerservice/HentForespoerselService.kt | 4 ++++ ...poerslerForVedtaksperiodeIdListeService.kt | 1 + 19 files changed, 70 insertions(+), 58 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 dd030dfde..c52239491 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 @@ -96,6 +96,7 @@ class AktiveOrgnrService( steg0: Steg0, ) { rapid.publish( + key = steg0.sykmeldtFnr, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.ARBEIDSGIVERE.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -106,6 +107,7 @@ class AktiveOrgnrService( ) rapid.publish( + key = steg0.sykmeldtFnr, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_ARBEIDSFORHOLD.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -116,6 +118,7 @@ class AktiveOrgnrService( ) rapid.publish( + key = steg0.sykmeldtFnr, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_PERSONER.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -144,6 +147,7 @@ class AktiveOrgnrService( utfoerSteg2(data, steg0, steg1, Steg2(emptyMap())) } else { rapid.publish( + key = steg0.sykmeldtFnr, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_VIRKSOMHET_NAVN.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), 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 9e633ef1f..095d16086 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 @@ -103,6 +103,7 @@ class BerikInntektsmeldingService( ) { rapid .publish( + key = steg0.skjema.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_TRENGER_IM.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -120,6 +121,7 @@ class BerikInntektsmeldingService( ) { rapid .publish( + key = steg0.skjema.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_VIRKSOMHET_NAVN.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -138,6 +140,7 @@ class BerikInntektsmeldingService( ) { rapid .publish( + key = steg0.skjema.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_PERSONER.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -187,6 +190,7 @@ class BerikInntektsmeldingService( rapid .publish( + key = steg0.skjema.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.LAGRE_IM.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -214,6 +218,7 @@ class BerikInntektsmeldingService( if (!steg4.erDuplikat) { val publisert = rapid.publish( + key = steg0.skjema.forespoerselId, Key.EVENT_NAME to EventName.INNTEKTSMELDING_MOTTATT.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), Key.DATA to diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt index f63acddc4..d7b702a49 100644 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt +++ b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtils.kt @@ -13,8 +13,6 @@ import no.nav.helsearbeidsgiver.utils.json.toJson import no.nav.helsearbeidsgiver.utils.wrapper.Fnr import java.util.UUID -fun MessageContext.publish(vararg messageFields: Pair): JsonElement = publish(null, messageFields.toMap()) - fun MessageContext.publish( key: Fnr, vararg messageFields: Pair, diff --git a/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtilsKtTest.kt b/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtilsKtTest.kt index b6f9d873d..2ccd2d1c2 100644 --- a/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtilsKtTest.kt +++ b/felles/src/test/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/RiverUtilsKtTest.kt @@ -30,25 +30,6 @@ class RiverUtilsKtTest : context("publish") { - test("vararg pairs (uten key)") { - val melding = - arrayOf( - Key.FORESPOERSEL_ID to UUID.randomUUID().toJson(), - Key.INNTEKTSMELDING to mockInntektsmeldingV1().toJson(Inntektsmelding.serializer()), - Key.FNR_LISTE to setOf("111", "333", "555").toJson(String.serializer()), - ) - - testRapid.publish(*melding) - - verifySequence { - testRapid.publish( - withArg { - it.parseJson().toMap() shouldContainExactly melding.toMap() - }, - ) - } - } - test("vararg pairs (fnr-key)") { val key = Fnr.genererGyldig() val melding = diff --git a/gradle.properties b/gradle.properties index 3a6c94277..d140f3b7b 100644 --- a/gradle.properties +++ b/gradle.properties @@ -19,7 +19,7 @@ utilsVersion=0.9.0 aaregClientVersion=0.7.0 altinnClientVersion=0.4.0 maskinportenClientVersion=0.1.9 -arbeidsgiverNotifikasjonKlientVersion=3.3.1 +arbeidsgiverNotifikasjonKlientVersion=3.3.2 brregKlientVersion=0.5.0 dokarkivKlientVersion=0.3.1 inntektKlientVersion=0.4.0 diff --git a/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/InnsendingService.kt b/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/InnsendingService.kt index 556d7c2da..273cd4dfa 100644 --- a/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/InnsendingService.kt +++ b/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/InnsendingService.kt @@ -63,6 +63,7 @@ class InnsendingService( ) { rapid .publish( + key = steg0.skjema.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.LAGRE_IM_SKJEMA.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -84,15 +85,15 @@ class InnsendingService( if (!steg1.erDuplikat) { val publisert = - rapid - .publish( - Key.EVENT_NAME to EventName.INNTEKTSMELDING_SKJEMA_LAGRET.toJson(), - Key.KONTEKST_ID to steg0.transaksjonId.toJson(), - Key.DATA to - data - .plus(Key.INNSENDING_ID to steg1.innsendingId.toJson(Long.serializer())) - .toJson(), - ) + rapid.publish( + key = steg0.skjema.forespoerselId, + Key.EVENT_NAME to EventName.INNTEKTSMELDING_SKJEMA_LAGRET.toJson(), + Key.KONTEKST_ID to steg0.transaksjonId.toJson(), + Key.DATA to + data + .plus(Key.INNSENDING_ID to steg1.innsendingId.toJson(Long.serializer())) + .toJson(), + ) MdcUtils.withLogFields( Log.event(EventName.INNTEKTSMELDING_SKJEMA_LAGRET), diff --git a/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/KvitteringService.kt b/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/KvitteringService.kt index 424b0ba6d..d50cbe8c4 100644 --- a/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/KvitteringService.kt +++ b/innsending/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/KvitteringService.kt @@ -70,6 +70,7 @@ class KvitteringService( ) { val publisert = rapid.publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_LAGRET_IM.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), diff --git a/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt b/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt index 9fe16a8fa..e84e3eb50 100644 --- a/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt +++ b/inntekt-selvbestemt-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektselvbestemtservice/InntektSelvbestemtService.kt @@ -30,7 +30,7 @@ import java.util.UUID data class Steg0( val transaksjonId: UUID, val orgnr: Orgnr, - val fnr: Fnr, + val sykmeldtFnr: Fnr, val inntektsdato: LocalDate, ) @@ -50,7 +50,7 @@ class InntektSelvbestemtService( override fun lesSteg0(melding: Map): Steg0 = Steg0( transaksjonId = Key.KONTEKST_ID.les(UuidSerializer, melding), - fnr = Key.FNR.les(Fnr.serializer(), melding), + sykmeldtFnr = Key.FNR.les(Fnr.serializer(), melding), orgnr = Key.ORGNR_UNDERENHET.les(Orgnr.serializer(), melding), inntektsdato = Key.INNTEKTSDATO.les(LocalDateSerializer, melding), ) @@ -66,6 +66,7 @@ class InntektSelvbestemtService( ) { val publisert = rapid.publish( + key = steg0.sykmeldtFnr, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_INNTEKT.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -74,7 +75,7 @@ class InntektSelvbestemtService( .plus( mapOf( Key.ORGNR_UNDERENHET to steg0.orgnr.toJson(), - Key.FNR to steg0.fnr.toJson(), + Key.FNR to steg0.sykmeldtFnr.toJson(), Key.INNTEKTSDATO to steg0.inntektsdato.toJson(), ), ).toJson(), diff --git a/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt b/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt index 18d9358f3..8cdadf183 100644 --- a/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt +++ b/inntektservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/inntektservice/InntektService.kt @@ -72,6 +72,7 @@ class InntektService( ) { rapid .publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_TRENGER_IM.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -96,6 +97,7 @@ class InntektService( ) { rapid .publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_INNTEKT.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), 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 44de17eec..9cea79a49 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 @@ -55,6 +55,7 @@ class HentDataTilPaaminnelseService( } rapid.publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_TRENGER_IM.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -71,17 +72,17 @@ class HentDataTilPaaminnelseService( steg0: Steg0, steg1: Steg1, ) { - rapid - .publish( - Key.EVENT_NAME to eventName.toJson(), - Key.BEHOV to BehovType.HENT_VIRKSOMHET_NAVN.toJson(), - Key.KONTEKST_ID to steg0.transaksjonId.toJson(), - Key.DATA to - data - .plus( - Key.ORGNR_UNDERENHETER to setOf(steg1.forespoersel.orgnr).toJson(String.serializer()), - ).toJson(), - ) + rapid.publish( + key = steg0.forespoerselId, + Key.EVENT_NAME to eventName.toJson(), + Key.BEHOV to BehovType.HENT_VIRKSOMHET_NAVN.toJson(), + Key.KONTEKST_ID to steg0.transaksjonId.toJson(), + Key.DATA to + data + .plus( + Key.ORGNR_UNDERENHETER to setOf(steg1.forespoersel.orgnr).toJson(String.serializer()), + ).toJson(), + ) } override fun utfoerSteg2( @@ -98,6 +99,7 @@ class HentDataTilPaaminnelseService( val orgNavn = steg2.orgnrMedNavn[steg1.forespoersel.orgnr.let(::Orgnr)] ?: ORG_NAVN_DEFAULT rapid.publish( + key = steg0.forespoerselId, Key.EVENT_NAME to EventName.OPPGAVE_ENDRE_PAAMINNELSE_REQUESTED.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), Key.DATA to 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 556893e67..0c5644452 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 @@ -75,6 +75,7 @@ class HentDataTilSakOgOppgaveService( } rapid.publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_VIRKSOMHET_NAVN.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -91,17 +92,17 @@ class HentDataTilSakOgOppgaveService( steg0: Steg0, steg1: Steg1, ) { - rapid - .publish( - Key.EVENT_NAME to eventName.toJson(), - Key.BEHOV to BehovType.HENT_PERSONER.toJson(), - Key.KONTEKST_ID to steg0.transaksjonId.toJson(), - Key.DATA to - data - .plus( - Key.FNR_LISTE to setOf(steg0.forespoersel.fnr).toJson(String.serializer()), - ).toJson(), - ) + rapid.publish( + key = steg0.forespoerselId, + Key.EVENT_NAME to eventName.toJson(), + Key.BEHOV to BehovType.HENT_PERSONER.toJson(), + Key.KONTEKST_ID to steg0.transaksjonId.toJson(), + Key.DATA to + data + .plus( + Key.FNR_LISTE to setOf(steg0.forespoersel.fnr).toJson(String.serializer()), + ).toJson(), + ) } override fun utfoerSteg2( @@ -119,6 +120,7 @@ class HentDataTilSakOgOppgaveService( val sykmeldt = steg2.personer[steg0.forespoersel.fnr.let(::Fnr)] ?: personDefault(steg0.forespoersel.fnr.let(::Fnr)) rapid.publish( + key = steg0.forespoerselId, Key.EVENT_NAME to EventName.SAK_OG_OPPGAVE_OPPRETT_REQUESTED.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), Key.DATA to 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 9c4c5fdf8..40ee0ee77 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 @@ -113,7 +113,7 @@ class EndrePaaminnelseRiver( orgNavn = orgNavn, sykmeldingsperioder = sykmeldingsperioder, ), - tidMellomOppgaveopprettelseOgPaaminnelse = "P21D", + tidMellomOppgaveopprettelseOgPaaminnelse = "P28D", ), ) } 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 c4031d4b4..11c872370 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 @@ -141,7 +141,7 @@ object EndrePaaminnelseMock { orgNavn = orgNavn, sykmeldingsperioder = forespoersel.sykmeldingsperioder, ), - tidMellomOppgaveopprettelseOgPaaminnelse = "P21D", + tidMellomOppgaveopprettelseOgPaaminnelse = "P28D", ) } diff --git a/selvbestemt-hent-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemthentimservice/HentSelvbestemtImService.kt b/selvbestemt-hent-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemthentimservice/HentSelvbestemtImService.kt index aa7c79fcd..21dfc7d2f 100644 --- a/selvbestemt-hent-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemthentimservice/HentSelvbestemtImService.kt +++ b/selvbestemt-hent-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemthentimservice/HentSelvbestemtImService.kt @@ -57,6 +57,7 @@ class HentSelvbestemtImService( ) { val publisert = rapid.publish( + key = steg0.selvbestemtId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_SELVBESTEMT_IM.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), diff --git a/selvbestemt-lagre-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemtlagreimservice/LagreSelvbestemtImService.kt b/selvbestemt-lagre-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemtlagreimservice/LagreSelvbestemtImService.kt index d3a37a59a..eac19cd19 100644 --- a/selvbestemt-lagre-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemtlagreimservice/LagreSelvbestemtImService.kt +++ b/selvbestemt-lagre-im-service/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/selvbestemtlagreimservice/LagreSelvbestemtImService.kt @@ -128,6 +128,7 @@ class LagreSelvbestemtImService( kontrollerSkjema(steg0.skjema) rapid.publish( + key = steg0.skjema.sykmeldtFnr, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_VIRKSOMHET_NAVN.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -140,6 +141,7 @@ class LagreSelvbestemtImService( ) rapid.publish( + key = steg0.skjema.sykmeldtFnr, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_PERSONER.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -156,6 +158,7 @@ class LagreSelvbestemtImService( ) rapid.publish( + key = steg0.skjema.sykmeldtFnr, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_ARBEIDSFORHOLD.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -198,6 +201,7 @@ class LagreSelvbestemtImService( if (erAktivtArbeidsforhold) { rapid .publish( + key = inntektsmelding.type.id, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.LAGRE_SELVBESTEMT_IM.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -234,6 +238,7 @@ class LagreSelvbestemtImService( AarsakInnsending.Ny -> { rapid .publish( + key = steg2.inntektsmelding.type.id, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.OPPRETT_SELVBESTEMT_SAK.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -270,6 +275,7 @@ class LagreSelvbestemtImService( if (!steg2.erDuplikat) { val publisert = rapid.publish( + key = steg2.inntektsmelding.type.id, Key.EVENT_NAME to EventName.SELVBESTEMT_IM_LAGRET.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), Key.DATA to diff --git a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt index 6d3b99c01..b1bc541b8 100644 --- a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt +++ b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangForespoerselService.kt @@ -75,6 +75,7 @@ class TilgangForespoerselService( ) { rapid .publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_TRENGER_IM.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -99,6 +100,7 @@ class TilgangForespoerselService( ) { rapid .publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.TILGANGSKONTROLL.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), diff --git a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt index 64d192156..44fa12f8f 100644 --- a/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt +++ b/tilgangservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/tilgangservice/TilgangOrgService.kt @@ -62,6 +62,7 @@ class TilgangOrgService( ) { rapid .publish( + key = steg0.fnr, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.TILGANGSKONTROLL.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), 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 e14a20ab4..484aa5796 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 @@ -109,6 +109,7 @@ class HentForespoerselService( ) { rapid .publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_TRENGER_IM.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -128,6 +129,7 @@ class HentForespoerselService( rapid .publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_VIRKSOMHET_NAVN.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -140,6 +142,7 @@ class HentForespoerselService( rapid .publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_PERSONER.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), @@ -156,6 +159,7 @@ class HentForespoerselService( rapid .publish( + key = steg0.forespoerselId, Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_INNTEKT.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(), diff --git a/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerslerForVedtaksperiodeIdListeService.kt b/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerslerForVedtaksperiodeIdListeService.kt index 1a293e66a..cbe1af914 100644 --- a/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerslerForVedtaksperiodeIdListeService.kt +++ b/trengerservice/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/trengerservice/HentForespoerslerForVedtaksperiodeIdListeService.kt @@ -60,6 +60,7 @@ class HentForespoerslerForVedtaksperiodeIdListeService( ) { rapid .publish( + key = UUID.randomUUID(), Key.EVENT_NAME to eventName.toJson(), Key.BEHOV to BehovType.HENT_FORESPOERSLER_FOR_VEDTAKSPERIODE_ID_LISTE.toJson(), Key.KONTEKST_ID to steg0.transaksjonId.toJson(),