Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Støtt ny skjemaklasse #619

Merged
merged 3 commits into from
Jul 25, 2024
Merged

Støtt ny skjemaklasse #619

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
5ab1b41
Støtt ny skjemaklasse
bjerga Jul 18, 2024
38b71e3
Merge branch 'main' into dev/overgang-nytt-skjema
bjerga Jul 24, 2024
e826722
Sett innsendingsårsak basert på tidligere lagrede inntektsmeldinger
bjerga Jul 24, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 13 additions & 1 deletion ...rc/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/api/innsending/InnsendingRoute.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,10 @@ import io.prometheus.client.Summary
import kotlinx.serialization.SerializationException
import kotlinx.serialization.builtins.serializer
import no.nav.helse.rapids_rivers.RapidsConnection
import no.nav.helsearbeidsgiver.domene.inntektsmelding.Utils.convert
import no.nav.helsearbeidsgiver.domene.inntektsmelding.deprecated.Innsending
import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.AarsakInnsending
import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.skjema.SkjemaInntektsmelding
import no.nav.helsearbeidsgiver.felles.ResultJson
import no.nav.helsearbeidsgiver.felles.Tekst
import no.nav.helsearbeidsgiver.felles.rapidsrivers.redis.RedisConnection
Expand Down Expand Up @@ -71,7 +74,16 @@ fun Route.innsendingRoute(
logger.info(it)
sikkerLogger.info("$it og request:\n$json")
}
}.fromJson(Innsending.serializer())
}.let { json ->
runCatching {
json.fromJson(SkjemaInntektsmelding.serializer()).convert(
sykmeldingsperioder = emptyList(),
aarsakInnsending = AarsakInnsending.Ny,
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Prøver å forstå dette. Når er det egentlig AarsakInnsending blir til Endring her?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Aldri! Jeg hadde glemt at det var noe som manglet, men når du sier det så må det et steg til for å sjekke om vi har noe i databasen for å bestemme om det er endring eller ei. Godt du er på!

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Greit å verifisere i backend sikkert. Men er det mulig å se i payloaden fra frontend at det er endring?
Må man ikke gi en begrunnelse for endring etc.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Det feltet blir bestemt av om man sender fra en kvitteringsside eller ei, så brukeren bestemmer ikke noe over feltet. Begrunnelse for endring er for inntekt.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nå har jeg fikset det. I starten setter man AarsakInnsendig.Ny uansett, men så endres det i https://github.com/navikt/helsearbeidsgiver-inntektsmelding/pull/619/files#diff-a305504fd5988ecbc6a069c88045df4d7077a7966c13974403ae8aea298d2a89R191.

)
}.getOrElse {
json.fromJson(Innsending.serializer())
}
}

tilgangskontroll.validerTilgangTilForespoersel(call.request, forespoerselId)

Expand Down
1 change: 1 addition & 0 deletions ...o/nav/helsearbeidsgiver/inntektsmelding/api/lagreselvbestemtim/LagreSelvbestemtImRoute.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -170,6 +170,7 @@ private suspend fun PipelineContext<Unit, ApplicationCall>.sendResponse(resultat
}
}

// TODO slett når frontend bruker korrekte navn
private fun JsonElement.fromJsonBackup(error: Throwable): SkjemaInntektsmeldingSelvbestemt {
val skjemaJson = jsonObject
val inntektJson = skjemaJson[SkjemaInntektsmeldingSelvbestemt::inntekt.name]!!.jsonObject
Expand Down
48 changes: 44 additions & 4 deletions .../src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/innsending/InnsendingService.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,11 @@ package no.nav.helsearbeidsgiver.inntektsmelding.innsending
import kotlinx.serialization.builtins.serializer
import kotlinx.serialization.json.JsonElement
import no.nav.helse.rapids_rivers.RapidsConnection
import no.nav.helsearbeidsgiver.domene.inntektsmelding.Utils.convert
import no.nav.helsearbeidsgiver.domene.inntektsmelding.deprecated.Innsending
import no.nav.helsearbeidsgiver.domene.inntektsmelding.deprecated.Inntektsmelding
import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.AarsakInnsending
import no.nav.helsearbeidsgiver.domene.inntektsmelding.v1.skjema.SkjemaInntektsmelding
import no.nav.helsearbeidsgiver.felles.BehovType
import no.nav.helsearbeidsgiver.felles.EventName
import no.nav.helsearbeidsgiver.felles.Forespoersel
Expand All @@ -21,6 +24,7 @@ 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.utils.Log
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.json.toPretty
Expand All @@ -37,12 +41,13 @@ data class Steg0(
val orgnr: Orgnr,
val sykmeldtFnr: Fnr,
val avsenderFnr: Fnr,
val skjema: Innsending,
val skjema: JsonElement,
)

sealed class Steg1 {
data class Komplett(
val forespoersel: Forespoersel,
val aarsakInnsending: AarsakInnsending,
val orgNavn: String,
val sykmeldt: PersonDato,
val avsender: PersonDato,
Expand Down Expand Up @@ -80,6 +85,8 @@ class InnsendingService(
Key.INNTEKTSMELDING_DOKUMENT,
Key.ER_DUPLIKAT_IM,
Key.FORESPOERSEL_SVAR,
Key.LAGRET_INNTEKTSMELDING,
Key.EKSTERN_INNTEKTSMELDING,
)

override fun lesSteg0(melding: Map<Key, JsonElement>): Steg0 =
Expand All @@ -89,20 +96,30 @@ class InnsendingService(
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(Innsending.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) }
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, orgNavn, sykmeldt, avsender)
val results = listOf(forespoersel, tidligereInntektsmelding, tidligereEksternInntektsmelding, orgNavn, sykmeldt, avsender)

return if (results.all { it.isSuccess }) {
val aarsakInnsending =
if (tidligereInntektsmelding.getOrThrow().success == null && tidligereEksternInntektsmelding.getOrThrow().success == null) {
AarsakInnsending.Ny
} else {
AarsakInnsending.Endring
}

Steg1.Komplett(
forespoersel = forespoersel.getOrThrow(),
aarsakInnsending = aarsakInnsending,
orgNavn = orgNavn.getOrThrow(),
sykmeldt = sykmeldt.getOrThrow(),
avsender = avsender.getOrThrow(),
Expand All @@ -129,6 +146,17 @@ class InnsendingService(
Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(),
).also { loggBehovPublisert(BehovType.HENT_TRENGER_IM, it) }

rapid
.publish(
Key.EVENT_NAME to eventName.toJson(),
Key.BEHOV to BehovType.HENT_LAGRET_IM.toJson(),
Key.UUID to steg0.transaksjonId.toJson(),
Key.DATA to
mapOf(
Key.FORESPOERSEL_ID to steg0.forespoerselId.toJson(),
).toJson(),
).also { loggBehovPublisert(BehovType.HENT_LAGRET_IM, it) }

rapid
.publish(
Key.EVENT_NAME to eventName.toJson(),
Expand All @@ -154,10 +182,22 @@ class InnsendingService(
steg1: Steg1,
) {
if (steg1 is Steg1.Komplett) {
val skjema =
runCatching {
steg0.skjema
.fromJson(SkjemaInntektsmelding.serializer())
.convert(
sykmeldingsperioder = steg1.forespoersel.sykmeldingsperioder,
aarsakInnsending = steg1.aarsakInnsending,
)
}.getOrElse {
steg0.skjema.fromJson(Innsending.serializer())
}

val inntektsmelding =
mapInntektsmelding(
forespoersel = steg1.forespoersel,
skjema = steg0.skjema,
skjema = skjema,
fulltnavnArbeidstaker = steg1.sykmeldt.navn,
virksomhetNavn = steg1.orgNavn,
innsenderNavn = steg1.avsender.navn,
Expand Down
27 changes: 26 additions & 1 deletion ...t/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/integrasjonstest/InnsendingServiceIT.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,10 @@ import no.nav.helsearbeidsgiver.felles.PersonDato
import no.nav.helsearbeidsgiver.felles.ResultJson
import no.nav.helsearbeidsgiver.felles.json.lesOrNull
import no.nav.helsearbeidsgiver.felles.json.toJson
import no.nav.helsearbeidsgiver.felles.json.toMap
import no.nav.helsearbeidsgiver.felles.test.mock.gyldigInnsendingRequest
import no.nav.helsearbeidsgiver.felles.test.mock.mockForespurtData
import no.nav.helsearbeidsgiver.felles.test.mock.mockInntektsmelding
import no.nav.helsearbeidsgiver.inntektsmelding.helsebro.domene.ForespoerselSvar
import no.nav.helsearbeidsgiver.inntektsmelding.helsebro.toForespoersel
import no.nav.helsearbeidsgiver.inntektsmelding.integrasjonstest.utils.EndToEndTest
Expand All @@ -37,9 +39,12 @@ import java.util.UUID
class InnsendingServiceIT : EndToEndTest() {
@Test
fun `Test at innsending er mottatt`() {
val tidligereInntektsmelding = mockInntektsmelding()

forespoerselRepository.lagreForespoersel(Mock.forespoerselId.toString(), Mock.orgnr.verdi)
forespoerselRepository.oppdaterSakId(Mock.forespoerselId.toString(), Mock.SAK_ID)
forespoerselRepository.oppdaterOppgaveId(Mock.forespoerselId.toString(), Mock.OPPGAVE_ID)
imRepository.lagreInntektsmelding(Mock.forespoerselId.toString(), tidligereInntektsmelding)

val transaksjonId: UUID = UUID.randomUUID()

Expand Down Expand Up @@ -83,6 +88,24 @@ class InnsendingServiceIT : EndToEndTest() {
it[Key.FORESPOERSEL_SVAR]?.fromJson(Forespoersel.serializer()) shouldBe Mock.forespoersel
}

// Tidligere inntektsmelding hentet
messages
.filter(EventName.INSENDING_STARTED)
.filter(Key.LAGRET_INNTEKTSMELDING, nestedData = true)
.filter(Key.EKSTERN_INNTEKTSMELDING, nestedData = true)
.firstAsMap()
.verifiserTransaksjonId(transaksjonId)
.verifiserForespoerselId()
.also {
it shouldContainKey Key.DATA

val data = it[Key.DATA]?.toMap().orEmpty()
val tidligereInntektsmeldingResult = ResultJson(success = tidligereInntektsmelding.toJson(Inntektsmelding.serializer()))

data[Key.LAGRET_INNTEKTSMELDING]?.fromJson(ResultJson.serializer()) shouldBe tidligereInntektsmeldingResult
data[Key.EKSTERN_INNTEKTSMELDING]?.fromJson(ResultJson.serializer()) shouldBe ResultJson(success = null)
}

// Virksomhetsnavn hentet
messages
.filter(EventName.INSENDING_STARTED)
Expand Down Expand Up @@ -183,7 +206,9 @@ class InnsendingServiceIT : EndToEndTest() {

private fun Map<Key, JsonElement>.verifiserForespoerselId(): Map<Key, JsonElement> =
also {
Key.FORESPOERSEL_ID.lesOrNull(UuidSerializer, it) shouldBe Mock.forespoerselId
val data = it[Key.DATA]?.toMap().orEmpty()
val forespoerselId = Key.FORESPOERSEL_ID.lesOrNull(UuidSerializer, it) ?: Key.FORESPOERSEL_ID.lesOrNull(UuidSerializer, data)
forespoerselId shouldBe Mock.forespoerselId
}

private object Mock {
Expand Down