Skip to content

Commit

Permalink
Nytt skjema: Bruk orgnr og fnr fra forespørsel (#634)
Browse files Browse the repository at this point in the history
  • Loading branch information
@bjerga
bjerga authored Jul 26, 2024
1 parent ad3b9c7 commit 61df36c
Show file tree
Hide file tree
Showing 4 changed files with 61 additions and 50 deletions.
26 changes: 20 additions & 6 deletions ...rc/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/innsending/InnsendingRoute.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,7 @@ import no.nav.helsearbeidsgiver.inntektsmelding.api.auth.lesFnrFraAuthToken
import no.nav.helsearbeidsgiver.inntektsmelding.api.logger
import no.nav.helsearbeidsgiver.inntektsmelding.api.response.JsonErrorResponse
import no.nav.helsearbeidsgiver.inntektsmelding.api.response.RedisTimeoutResponse
import no.nav.helsearbeidsgiver.inntektsmelding.api.response.ValideringErrorResponse
import no.nav.helsearbeidsgiver.inntektsmelding.api.sikkerLogger
import no.nav.helsearbeidsgiver.inntektsmelding.api.utils.respond
import no.nav.helsearbeidsgiver.inntektsmelding.api.utils.respondBadRequest
Expand Down Expand Up @@ -76,18 +77,31 @@ fun Route.innsendingRoute(
}
}.let { json ->
runCatching {
json.fromJson(SkjemaInntektsmelding.serializer()).convert(
sykmeldingsperioder = emptyList(),
aarsakInnsending = AarsakInnsending.Ny,
)
json
.fromJson(SkjemaInntektsmelding.serializer())
.also {
val valideringsfeil = it.valider()
if (valideringsfeil.isNotEmpty()) {
val response = ValideringErrorResponse(valideringsfeil)

respondBadRequest(response, ValideringErrorResponse.serializer())
return@measureTimeMillis
}
}.convert(
sykmeldingsperioder = emptyList(),
aarsakInnsending = AarsakInnsending.Ny,
)
}.getOrElse {
json.fromJson(Innsending.serializer())
json
.fromJson(Innsending.serializer())
.also {
it.validate()
}
}
}

tilgangskontroll.validerTilgangTilForespoersel(call.request, forespoerselId)

request.validate()
val innloggerFnr = call.request.lesFnrFraAuthToken()
producer.publish(transaksjonId, forespoerselId, request, innloggerFnr)

Expand Down
74 changes: 40 additions & 34 deletions .../src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/InnsendingService.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ import no.nav.helsearbeidsgiver.felles.rapidsrivers.model.Fail
import no.nav.helsearbeidsgiver.felles.rapidsrivers.publish
import no.nav.helsearbeidsgiver.felles.rapidsrivers.redis.RedisKey
import no.nav.helsearbeidsgiver.felles.rapidsrivers.redis.RedisStore
import no.nav.helsearbeidsgiver.felles.rapidsrivers.service.ServiceMed2Steg
import no.nav.helsearbeidsgiver.felles.rapidsrivers.service.ServiceMed3Steg
import no.nav.helsearbeidsgiver.felles.utils.Log
import no.nav.helsearbeidsgiver.utils.json.fromJson
import no.nav.helsearbeidsgiver.utils.json.serializer.UuidSerializer
Expand All @@ -32,48 +32,46 @@ 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

data class Steg0(
val transaksjonId: UUID,
val forespoerselId: UUID,
val orgnr: Orgnr,
val sykmeldtFnr: Fnr,
val avsenderFnr: Fnr,
val skjema: JsonElement,
)

sealed class Steg1 {
data class Steg1(
val forespoersel: Forespoersel,
)

sealed class Steg2 {
data class Komplett(
val forespoersel: Forespoersel,
val aarsakInnsending: AarsakInnsending,
val orgNavn: String,
val sykmeldt: PersonDato,
val avsender: PersonDato,
) : Steg1()
) : Steg2()

data object Delvis : Steg1()
data object Delvis : Steg2()
}

data class Steg2(
data class Steg3(
val inntektsmelding: Inntektsmelding,
val erDuplikat: Boolean,
)

class InnsendingService(
private val rapid: RapidsConnection,
override val redisStore: RedisStore,
) : ServiceMed2Steg<Steg0, Steg1, Steg2>() {
) : ServiceMed3Steg<Steg0, Steg1, Steg2, Steg3>() {
override val logger = logger()
override val sikkerLogger = sikkerLogger()

override val eventName = EventName.INSENDING_STARTED
override val startKeys =
setOf(
Key.FORESPOERSEL_ID,
Key.ORGNRUNDERENHET,
Key.IDENTITETSNUMMER,
Key.ARBEIDSGIVER_ID,
Key.SKJEMA_INNTEKTSMELDING,
)
Expand All @@ -93,21 +91,23 @@ class InnsendingService(
Steg0(
transaksjonId = Key.UUID.les(UuidSerializer, melding),
forespoerselId = Key.FORESPOERSEL_ID.les(UuidSerializer, melding),
orgnr = Key.ORGNRUNDERENHET.les(Orgnr.serializer(), melding),
sykmeldtFnr = Key.IDENTITETSNUMMER.les(Fnr.serializer(), melding),
avsenderFnr = Key.ARBEIDSGIVER_ID.les(Fnr.serializer(), melding),
skjema = Key.SKJEMA_INNTEKTSMELDING.les(JsonElement.serializer(), melding),
)

override fun lesSteg1(melding: Map<Key, JsonElement>): Steg1 {
val forespoersel = runCatching { Key.FORESPOERSEL_SVAR.les(Forespoersel.serializer(), melding) }
override fun lesSteg1(melding: Map<Key, JsonElement>): Steg1 =
Steg1(
forespoersel = Key.FORESPOERSEL_SVAR.les(Forespoersel.serializer(), melding),
)

override fun lesSteg2(melding: Map<Key, JsonElement>): Steg2 {
val tidligereInntektsmelding = runCatching { Key.LAGRET_INNTEKTSMELDING.les(ResultJson.serializer(), melding) }
val tidligereEksternInntektsmelding = runCatching { Key.EKSTERN_INNTEKTSMELDING.les(ResultJson.serializer(), melding) }
val orgNavn = runCatching { Key.VIRKSOMHET.les(String.serializer(), melding) }
val sykmeldt = runCatching { Key.ARBEIDSTAKER_INFORMASJON.les(PersonDato.serializer(), melding) }
val avsender = runCatching { Key.ARBEIDSGIVER_INFORMASJON.les(PersonDato.serializer(), melding) }

val results = listOf(forespoersel, tidligereInntektsmelding, tidligereEksternInntektsmelding, orgNavn, sykmeldt, avsender)
val results = listOf(tidligereInntektsmelding, tidligereEksternInntektsmelding, orgNavn, sykmeldt, avsender)

return if (results.all { it.isSuccess }) {
val aarsakInnsending =
Expand All @@ -117,22 +117,21 @@ class InnsendingService(
AarsakInnsending.Endring
}

Steg1.Komplett(
forespoersel = forespoersel.getOrThrow(),
Steg2.Komplett(
aarsakInnsending = aarsakInnsending,
orgNavn = orgNavn.getOrThrow(),
sykmeldt = sykmeldt.getOrThrow(),
avsender = avsender.getOrThrow(),
)
} else if (results.any { it.isSuccess }) {
Steg1.Delvis
Steg2.Delvis
} else {
throw results.firstNotNullOf { it.exceptionOrNull() }
}
}

override fun lesSteg2(melding: Map<Key, JsonElement>): Steg2 =
Steg2(
override fun lesSteg3(melding: Map<Key, JsonElement>): Steg3 =
Steg3(
inntektsmelding = Key.INNTEKTSMELDING_DOKUMENT.les(Inntektsmelding.serializer(), melding),
erDuplikat = Key.ER_DUPLIKAT_IM.les(Boolean.serializer(), melding),
)
Expand All @@ -145,7 +144,12 @@ class InnsendingService(
Key.UUID to steg0.transaksjonId.toJson(),
Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(),
).also { loggBehovPublisert(BehovType.HENT_TRENGER_IM, it) }
}

override fun utfoerSteg1(
steg0: Steg0,
steg1: Steg1,
) {
rapid
.publish(
Key.EVENT_NAME to eventName.toJson(),
Expand All @@ -163,7 +167,7 @@ class InnsendingService(
Key.BEHOV to BehovType.VIRKSOMHET.toJson(),
Key.UUID to steg0.transaksjonId.toJson(),
Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(),
Key.ORGNRUNDERENHET to steg0.orgnr.toJson(),
Key.ORGNRUNDERENHET to steg1.forespoersel.orgnr.toJson(),
).also { loggBehovPublisert(BehovType.VIRKSOMHET, it) }

rapid
Expand All @@ -172,23 +176,24 @@ class InnsendingService(
Key.BEHOV to BehovType.FULLT_NAVN.toJson(),
Key.UUID to steg0.transaksjonId.toJson(),
Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(),
Key.IDENTITETSNUMMER to steg0.sykmeldtFnr.toJson(),
Key.IDENTITETSNUMMER to steg1.forespoersel.fnr.toJson(),
Key.ARBEIDSGIVER_ID to steg0.avsenderFnr.toJson(),
).also { loggBehovPublisert(BehovType.FULLT_NAVN, it) }
}

override fun utfoerSteg1(
override fun utfoerSteg2(
steg0: Steg0,
steg1: Steg1,
steg2: Steg2,
) {
if (steg1 is Steg1.Komplett) {
if (steg2 is Steg2.Komplett) {
val skjema =
runCatching {
steg0.skjema
.fromJson(SkjemaInntektsmelding.serializer())
.convert(
sykmeldingsperioder = steg1.forespoersel.sykmeldingsperioder,
aarsakInnsending = steg1.aarsakInnsending,
aarsakInnsending = steg2.aarsakInnsending,
)
}.getOrElse {
steg0.skjema.fromJson(Innsending.serializer())
Expand All @@ -198,9 +203,9 @@ class InnsendingService(
mapInntektsmelding(
forespoersel = steg1.forespoersel,
skjema = skjema,
fulltnavnArbeidstaker = steg1.sykmeldt.navn,
virksomhetNavn = steg1.orgNavn,
innsenderNavn = steg1.avsender.navn,
fulltnavnArbeidstaker = steg2.sykmeldt.navn,
virksomhetNavn = steg2.orgNavn,
innsenderNavn = steg2.avsender.navn,
)

if (inntektsmelding.bestemmendeFraværsdag.isBefore(inntektsmelding.inntektsdato)) {
Expand All @@ -221,25 +226,26 @@ class InnsendingService(
}
}

override fun utfoerSteg2(
override fun utfoerSteg3(
steg0: Steg0,
steg1: Steg1,
steg2: Steg2,
steg3: Steg3,
) {
val resultJson =
ResultJson(
success = steg2.inntektsmelding.toJson(Inntektsmelding.serializer()),
success = steg3.inntektsmelding.toJson(Inntektsmelding.serializer()),
).toJson(ResultJson.serializer())

redisStore.set(RedisKey.of(steg0.transaksjonId), resultJson)

if (!steg2.erDuplikat) {
if (!steg3.erDuplikat) {
val publisert =
rapid.publish(
Key.EVENT_NAME to EventName.INNTEKTSMELDING_MOTTATT.toJson(),
Key.UUID to steg0.transaksjonId.toJson(),
Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(),
Key.INNTEKTSMELDING_DOKUMENT to steg2.inntektsmelding.toJson(Inntektsmelding.serializer()),
Key.INNTEKTSMELDING_DOKUMENT to steg3.inntektsmelding.toJson(Inntektsmelding.serializer()),
)

MdcUtils.withLogFields(
Expand Down
8 changes: 1 addition & 7 deletions ...src/test/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InnsendingIT.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,6 @@ import no.nav.helsearbeidsgiver.inntektsmelding.integrasjonstest.utils.maxMekker
import no.nav.helsearbeidsgiver.utils.json.fromJson
import no.nav.helsearbeidsgiver.utils.json.serializer.UuidSerializer
import no.nav.helsearbeidsgiver.utils.json.toJson
import no.nav.helsearbeidsgiver.utils.test.wrapper.genererGyldig
import no.nav.helsearbeidsgiver.utils.wrapper.Fnr
import org.junit.jupiter.api.BeforeEach
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.TestInstance
Expand Down Expand Up @@ -72,8 +70,6 @@ class InnsendingIT : EndToEndTest() {
Key.UUID to transaksjonId.toJson(),
Key.DATA to "".toJson(),
Key.FORESPOERSEL_ID to Mock.forespoerselId.toJson(),
Key.ORGNRUNDERENHET to Mock.skjema.orgnrUnderenhet.toJson(),
Key.IDENTITETSNUMMER to Mock.skjema.identitetsnummer.toJson(),
Key.ARBEIDSGIVER_ID to Mock.skjema.identitetsnummer.toJson(),
Key.SKJEMA_INNTEKTSMELDING to Mock.skjema.toJson(Innsending.serializer()),
)
Expand Down Expand Up @@ -169,8 +165,6 @@ class InnsendingIT : EndToEndTest() {
Key.UUID to transaksjonId.toJson(),
Key.DATA to "".toJson(),
Key.FORESPOERSEL_ID to Mock.forespoerselId.toJson(),
Key.ORGNRUNDERENHET to Mock.skjema.orgnrUnderenhet.toJson(),
Key.IDENTITETSNUMMER to bjarneBetjent.ident!!.toJson(),
Key.ARBEIDSGIVER_ID to maxMekker.ident!!.toJson(),
Key.SKJEMA_INNTEKTSMELDING to Mock.skjema.toJson(Innsending.serializer()),
)
Expand Down Expand Up @@ -249,7 +243,7 @@ class InnsendingIT : EndToEndTest() {
const val OPPGAVE_ID = "neglisjert-sommer"

val forespoerselId: UUID = UUID.randomUUID()
val skjema = mockInnsending().copy(identitetsnummer = Fnr.genererGyldig().verdi)
val skjema = mockInnsending().copy(identitetsnummer = bjarneBetjent.ident!!)

private val forespoersel = skjema.tilForespoersel(UUID.randomUUID())

Expand Down
3 changes: 0 additions & 3 deletions ...t/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InnsendingServiceIT.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -70,8 +70,6 @@ class InnsendingServiceIT : EndToEndTest() {
Key.UUID to transaksjonId.toJson(),
Key.DATA to "".toJson(),
Key.FORESPOERSEL_ID to Mock.forespoerselId.toJson(),
Key.ORGNRUNDERENHET to Mock.orgnr.toJson(),
Key.IDENTITETSNUMMER to Mock.fnr.toJson(),
Key.ARBEIDSGIVER_ID to Mock.fnrAg.toJson(),
Key.SKJEMA_INNTEKTSMELDING to gyldigInnsendingRequest.toJson(Innsending.serializer()),
)
Expand Down Expand Up @@ -216,7 +214,6 @@ class InnsendingServiceIT : EndToEndTest() {
const val OPPGAVE_ID = "kunstig-demon"

val orgnr = Orgnr.genererGyldig()
val fnr = Fnr.genererGyldig()
val fnrAg = Fnr.genererGyldig()
val forespoerselId: UUID = UUID.randomUUID()
val vedtaksperiodeId: UUID = UUID.randomUUID()
Expand Down

0 comments on commit 61df36c

Please sign in to comment.