Korrigering av k9 saksnummer håndtering (#1007)

* Oppretter ikke nytt saksnr når man starter ny søknad,
saksnummer fra k9 hentes fra SAF når vi sender in søknad.
Finner vi ikke saksnummer så kaller vi /fordel/fagsak/opprett med data fra punsj søknaden

* Fiks uhåndtert feil SAFGateway, fix k9sakimpl

src/main/kotlin/no/nav/k9punsj/domenetjenester/MappeService.kt

@@ -442,6 +442,7 @@ internal class MappeService(
         return Mappe(mappeId, søker, bunkerMedSøknader)
     }
 
+    @Deprecated("Bruk soknadService")
     suspend fun hentSøknad(søknad: String): SøknadEntitet? {
         return soknadService.hentSøknad(søknad)
     }

src/main/kotlin/no/nav/k9punsj/domenetjenester/SoknadService.kt

@@ -6,7 +6,9 @@ import no.nav.k9.kodeverk.Fagsystem
 import no.nav.k9.kodeverk.dokument.Brevkode
 import no.nav.k9.sak.typer.Saksnummer
 import no.nav.k9.søknad.Søknad
+import no.nav.k9punsj.domenetjenester.repository.BunkeRepository
 import no.nav.k9punsj.domenetjenester.repository.SøknadRepository
+import no.nav.k9punsj.felles.FagsakYtelseType
 import no.nav.k9punsj.felles.Identitetsnummer.Companion.somIdentitetsnummer
 import no.nav.k9punsj.felles.JournalpostId.Companion.somJournalpostId
 import no.nav.k9punsj.felles.Søknadstype
@@ -39,15 +41,16 @@ import java.util.UUID
 import kotlin.coroutines.coroutineContext
 
 @Service
-internal class SoknadService(
+class SoknadService(
     private val journalpostService: JournalpostService,
     private val søknadRepository: SøknadRepository,
     private val søknadMetrikkService: SøknadMetrikkService,
     private val safGateway: SafGateway,
     private val k9SakService: K9SakService,
     private val sakClient: SakClient,
     private val pdlService: PdlService,
-    private val dokarkivGateway: DokarkivGateway
+    private val dokarkivGateway: DokarkivGateway,
+    private val bunkeRepository: BunkeRepository
 ) {
 
     internal suspend fun sendSøknad(
@@ -59,7 +62,7 @@ internal class SoknadService(
 
         val journalpostIdListe = journalpostIder.toList()
         val journalposterKanSendesInn = journalpostService.kanSendeInn(journalpostIdListe)
-        val punsjetAvSaksbehandler = søknadRepository.hentSøknad(søknad.søknadId.id)?.endret_av!!.replace("\"", "")
+        val punsjetAvSaksbehandler = hentSistEndretAvSaksbehandler(søknad.søknadId.id)
 
         val søkerFnr = søknad.søker.personIdent.verdi
         val k9YtelseType = Søknadstype.fraBrevkode(brevkode).k9YtelseType
@@ -106,15 +109,7 @@ internal class SoknadService(
             }
             fagsakIder.first().second
         } else {
-            // Hent k9saksnummer
-            val k9SaksnummerGrunnlag = HentK9SaksnummerGrunnlag(
-                søknadstype = fagsakYtelseType,
-                søker = søkerFnr,
-                pleietrengende = søknad.berørtePersoner?.firstOrNull()?.personIdent?.verdi,
-                annenPart = søknad.berørtePersoner?.firstOrNull()?.personIdent?.verdi,
-                journalpostId = journalpostIder.first() // TODO: Brukes for å utlede dato, hentes fra behandlingsAar.
-            )
-            val k9Respons = k9SakService.hentEllerOpprettSaksnummer(k9SaksnummerGrunnlag)
+            val k9Respons = k9SakService.hentEllerOpprettSaksnummer(søknad.søknadId.toString())
             require(k9Respons.second.isNullOrBlank()) { "Feil ved henting av saksnummer: ${k9Respons.second}" }
             logger.info("Fick saksnummer (${k9Respons.second} av K9Sak for Journalpost ${journalpostIder.first()}")
             k9Respons.first
@@ -240,6 +235,12 @@ internal class SoknadService(
         return søknadRepository.hentSøknad(søknadId)?.endret_av!!.replace("\"", "")
     }
 
+    suspend fun henteYtelsetypeForSøknad(søknadId: String): FagsakYtelseType? {
+        return hentSøknad(søknadId)?.bunkeId?.let { bunkeId ->
+            bunkeRepository.hentYtelseTypeForBunke(bunkeId)
+        }
+    }
+
     private suspend fun leggerVedPayload(
         søknad: Søknad,
         journalpostIder: MutableSet<String>

src/main/kotlin/no/nav/k9punsj/domenetjenester/repository/BunkeRepository.kt

@@ -72,4 +72,23 @@ class BunkeRepository(private val dataSource: DataSource) {
             }
         }
     }
+
+    suspend fun hentYtelseTypeForBunke(bunkeId: String): FagsakYtelseType? {
+        return using(sessionOf(dataSource)) {
+            return@using it.transaction { tx ->
+                return@transaction tx.run(
+                    queryOf(
+                        """
+                                select ytelse_type from $BUNKE_TABLE where bunke_id = :bunkeId
+                             """,
+                        mapOf(
+                            "bunkeId" to UUID.fromString(bunkeId)
+                        )
+                    ).map { row ->
+                        FagsakYtelseType.fromKode(row.string("ytelse_type"))
+                    }.asSingle
+                )
+            }
+        }
+    }
 }

src/main/kotlin/no/nav/k9punsj/integrasjoner/dokarkiv/SafGateway.kt

@@ -94,17 +94,21 @@ class SafGateway(
             UUID.randomUUID().toString()
         }
 
-        val response = client
-            .post()
-            .uri { it.pathSegment("graphql").build() }
-            .header(ConsumerIdHeaderKey, ConsumerIdHeaderValue)
-            .header(CorrelationIdHeader, correlationId)
-            .header(HttpHeaders.AUTHORIZATION, accessToken.asAuthoriationHeader())
-            .accept(MediaType.APPLICATION_JSON)
-            .bodyValue(SafDtos.JournalpostQuery(journalpostId))
-            .retrieve()
-            .toEntity(SafDtos.JournalpostResponseWrapper::class.java)
-            .awaitFirst()
+        val response = try {
+            client
+                .post()
+                .uri { it.pathSegment("graphql").build() }
+                .header(ConsumerIdHeaderKey, ConsumerIdHeaderValue)
+                .header(CorrelationIdHeader, correlationId)
+                .header(HttpHeaders.AUTHORIZATION, accessToken.asAuthoriationHeader())
+                .accept(MediaType.APPLICATION_JSON)
+                .bodyValue(SafDtos.JournalpostQuery(journalpostId))
+                .retrieve()
+                .toEntity(SafDtos.JournalpostResponseWrapper::class.java)
+                .awaitFirst()
+        } catch (e: Exception) {
+            throw IllegalStateException("Feil ved oppslag mot SAF graphql. ${e.message}", e)
+        }
 
         val safResponse = response.body
         val errors = safResponse?.errors

src/main/kotlin/no/nav/k9punsj/integrasjoner/k9sak/HentK9SaksnummerGrunnlagDto.kt

@@ -1,11 +1,12 @@
 package no.nav.k9punsj.integrasjoner.k9sak
 
 import no.nav.k9punsj.felles.FagsakYtelseType
+import no.nav.k9punsj.felles.dto.PeriodeDto
 
 data class HentK9SaksnummerGrunnlag(
     val søknadstype: FagsakYtelseType,
     val søker: String,
     val pleietrengende: String?,
     val annenPart: String?,
-    val journalpostId: String
+    val periode: PeriodeDto?,
 )

src/main/kotlin/no/nav/k9punsj/integrasjoner/k9sak/K9SakService.kt

@@ -32,9 +32,9 @@ interface K9SakService {
 
     /**
      * Henter saksnummer fra K9Sak, hvis det ikke finnes oppretter vi en ny fagsak.
-     * Bruker behandlingsAar fra PunsjJournalpost for å sikkre riktig periode for saksnummeret.
+     * Periode hentes fra soknaden å defaulter til 1/1 og 31/12 hvis fom eller tom ikke er satt.
      */
-    suspend fun hentEllerOpprettSaksnummer(k9SaksnummerGrunnlag: HentK9SaksnummerGrunnlag): Pair<String?, String?>
+    suspend fun hentEllerOpprettSaksnummer(søknadId: String): Pair<String?, String?>
 
     suspend fun hentSisteSaksnummerForPeriode(
         fagsakYtelseType: FagsakYtelseType,

src/main/kotlin/no/nav/k9punsj/integrasjoner/k9sak/K9SakServiceImpl.kt

@@ -9,15 +9,16 @@ import no.nav.k9.kodeverk.behandling.FagsakYtelseType
 import no.nav.k9.kodeverk.dokument.Brevkode
 import no.nav.k9.sak.kontrakt.arbeidsforhold.InntektArbeidYtelseArbeidsforholdV2Dto
 import no.nav.k9.sak.kontrakt.mottak.FinnEllerOpprettSak
-import no.nav.k9.sak.typer.JournalpostId
 import no.nav.k9.sak.typer.Periode
 import no.nav.k9.søknad.Søknad
 import no.nav.k9punsj.StandardProfil
 import no.nav.k9punsj.domenetjenester.PersonService
+import no.nav.k9punsj.domenetjenester.SoknadService
 import no.nav.k9punsj.felles.ZoneUtils.Oslo
 import no.nav.k9punsj.felles.dto.ArbeidsgiverMedArbeidsforholdId
 import no.nav.k9punsj.felles.dto.PeriodeDto
 import no.nav.k9punsj.felles.dto.SaksnummerDto
+import no.nav.k9punsj.felles.dto.SøknadEntitet
 import no.nav.k9punsj.hentCallId
 import no.nav.k9punsj.integrasjoner.k9sak.K9SakServiceImpl.Urls.finnFagsak
 import no.nav.k9punsj.integrasjoner.k9sak.K9SakServiceImpl.Urls.hentIntektsmeldingerUrl
@@ -26,6 +27,13 @@ import no.nav.k9punsj.integrasjoner.k9sak.K9SakServiceImpl.Urls.sendInnSøknadUr
 import no.nav.k9punsj.integrasjoner.k9sak.K9SakServiceImpl.Urls.sokFagsaker
 import no.nav.k9punsj.integrasjoner.k9sak.K9SakServiceImpl.Urls.sokFagsakerUrl
 import no.nav.k9punsj.journalpost.JournalpostService
+import no.nav.k9punsj.omsorgspengeraleneomsorg.tilOmsAOvisning
+import no.nav.k9punsj.omsorgspengerkronisksyktbarn.tilOmsKSBvisning
+import no.nav.k9punsj.omsorgspengermidlertidigalene.tilOmsMAvisning
+import no.nav.k9punsj.omsorgspengerutbetaling.tilOmsUtvisning
+import no.nav.k9punsj.opplaeringspenger.tilOlpvisning
+import no.nav.k9punsj.pleiepengerlivetssluttfase.tilPlsvisning
+import no.nav.k9punsj.pleiepengersyktbarn.tilPsbvisning
 import no.nav.k9punsj.utils.objectMapper
 import org.intellij.lang.annotations.Language
 import org.json.JSONArray
@@ -47,7 +55,8 @@ class K9SakServiceImpl(
     @Value("\${no.nav.k9sak.scope}") private val k9sakScope: Set<String>,
     @Qualifier("sts") private val accessTokenClient: AccessTokenClient,
     private val personService: PersonService,
-    private val journalpostService: JournalpostService
+    private val journalpostService: JournalpostService,
+    private val soknadService: SoknadService,
 ) : K9SakService {
 
     private val cachedAccessTokenClient = CachedAccessTokenClient(accessTokenClient)
@@ -185,26 +194,28 @@ class K9SakServiceImpl(
         }
     }
 
-    /*
-    * 1. Utleder periode fra PunsjJournalpost.behandlingsAar eller bruker nåvarande år som periode.
-    * 2. Slår opp saksnummer basert på ytelsetype, periode & inkluderte aktørIder.
-     */
     override suspend fun hentEllerOpprettSaksnummer(
-        k9SaksnummerGrunnlag: HentK9SaksnummerGrunnlag,
+        søknadId: String
     ): Pair<String?, String?> {
-        val aar = journalpostService.hentBehandlingsAar(k9SaksnummerGrunnlag.journalpostId)
-        val periode = Periode(
-            LocalDate.of(aar, 1, 12),
-            LocalDate.of(aar, 12, 31)
-        )
+        val søknad = soknadService.hentSøknad(søknadId)
+            ?: return Pair(null, "Fant ikke søknad")
+        val fagsakYtelseType = soknadService.henteYtelsetypeForSøknad(søknad!!.søknadId)
+            ?: return Pair(null, "Fant ikke fagsakytelsetype")
+        val k9SaksnummerGrunnlag = søknad.tilK9saksnummerGrunnlag(fagsakYtelseType)
 
         val søkerAktørId = personService.finnEllerOpprettPersonVedNorskIdent(k9SaksnummerGrunnlag.søker).aktørId
-        val pleietrengendeAktørId = if(!k9SaksnummerGrunnlag.pleietrengende.isNullOrEmpty() && k9SaksnummerGrunnlag.pleietrengende != "null") {
-            personService.finnEllerOpprettPersonVedNorskIdent(k9SaksnummerGrunnlag.pleietrengende).aktørId
-        } else null
-        val annenpartAktørId = if(!k9SaksnummerGrunnlag.annenPart.isNullOrEmpty() && k9SaksnummerGrunnlag.annenPart != "null") {
-            personService.finnEllerOpprettPersonVedNorskIdent(k9SaksnummerGrunnlag.annenPart).aktørId
-        } else null
+        val pleietrengendeAktørId =
+            if (!k9SaksnummerGrunnlag.pleietrengende.isNullOrEmpty() && k9SaksnummerGrunnlag.pleietrengende != "null") {
+                personService.finnEllerOpprettPersonVedNorskIdent(k9SaksnummerGrunnlag.pleietrengende).aktørId
+            } else null
+        val annenpartAktørId =
+            if (!k9SaksnummerGrunnlag.annenPart.isNullOrEmpty() && k9SaksnummerGrunnlag.annenPart != "null") {
+                personService.finnEllerOpprettPersonVedNorskIdent(k9SaksnummerGrunnlag.annenPart).aktørId
+            } else null
+        val periode = Periode(
+            k9SaksnummerGrunnlag.periode?.fom ?: LocalDate.now().withMonth(1).withDayOfMonth(1),
+            k9SaksnummerGrunnlag.periode?.tom ?: LocalDate.now().withMonth(12).withDayOfMonth(31)
+        )
 
         val payloadMedAktørId = FinnEllerOpprettSak(
             FagsakYtelseType.fraKode(k9SaksnummerGrunnlag.søknadstype.kode).kode,
@@ -313,6 +324,112 @@ class K9SakServiceImpl(
         )
     }
 
+    private fun SøknadEntitet.tilK9saksnummerGrunnlag(
+        fagsakYtelseType: no.nav.k9punsj.felles.FagsakYtelseType
+    ): HentK9SaksnummerGrunnlag {
+        // Kontrakt  fra k9-sak FagsakYtelseType
+        // https://github.com/navikt/k9-sak/blob/83b654701d242629a20eabbab642c399c6c27182/kodeverk/src/main/java/no/nav/k9/kodeverk/behandling/FagsakYtelseType.java#L57
+        return when (fagsakYtelseType) {
+            no.nav.k9punsj.felles.FagsakYtelseType.PLEIEPENGER_SYKT_BARN -> {
+                val psbVisning = this.tilPsbvisning()
+                HentK9SaksnummerGrunnlag(
+                    søknadstype = fagsakYtelseType,
+                    søker = psbVisning.soekerId!!,
+                    pleietrengende = psbVisning.barn?.norskIdent,
+                    annenPart = null,
+                    periode = psbVisning.soeknadsperiode?.firstOrNull()
+                )
+            }
+
+            no.nav.k9punsj.felles.FagsakYtelseType.OMSORGSPENGER -> {
+                val omsVisning = this.tilOmsUtvisning()
+                HentK9SaksnummerGrunnlag(
+                    søknadstype = fagsakYtelseType,
+                    søker = omsVisning.soekerId!!,
+                    pleietrengende = null,
+                    annenPart = null,
+                    periode = omsVisning.periodeForHeleAretMedFravaer()
+                )
+            }
+
+            no.nav.k9punsj.felles.FagsakYtelseType.OMSORGSPENGER_UTBETALING -> {
+                val omsUtvisning = this.tilOmsUtvisning()
+                HentK9SaksnummerGrunnlag(
+                    søknadstype = fagsakYtelseType,
+                    søker = omsUtvisning.soekerId!!,
+                    pleietrengende = null,
+                    annenPart = null,
+                    periode = omsUtvisning.periodeForHeleAretMedFravaer()
+                )
+            }
+
+            no.nav.k9punsj.felles.FagsakYtelseType.OMSORGSPENGER_ALENE_OMSORGEN -> {
+                val omsAoVisning = this.tilOmsAOvisning()
+                HentK9SaksnummerGrunnlag(
+                    søknadstype = fagsakYtelseType,
+                    søker = omsAoVisning.soekerId!!,
+                    pleietrengende = omsAoVisning.barn!!.norskIdent,
+                    annenPart = null,
+                    periode = omsAoVisning.periode
+                )
+            }
+
+            no.nav.k9punsj.felles.FagsakYtelseType.OMSORGSPENGER_MIDLERTIDIG_ALENE -> {
+                val omsMaVisning = this.tilOmsMAvisning()
+                HentK9SaksnummerGrunnlag(
+                    søknadstype = fagsakYtelseType,
+                    søker = omsMaVisning.soekerId!!,
+                    pleietrengende = null,
+                    annenPart = omsMaVisning.annenForelder!!.norskIdent,
+                    periode = omsMaVisning.annenForelder.periode
+                )
+            }
+
+            no.nav.k9punsj.felles.FagsakYtelseType.OMSORGSPENGER_KRONISK_SYKT_BARN -> {
+                val omsKsVisning = this.tilOmsKSBvisning()
+                HentK9SaksnummerGrunnlag(
+                    søknadstype = fagsakYtelseType,
+                    søker = omsKsVisning.soekerId!!,
+                    pleietrengende = omsKsVisning.barn!!.norskIdent,
+                    annenPart = null,
+                    periode = omsKsVisning.mottattDato?.periodeDtoForHeleAret()
+                )
+            }
+
+            no.nav.k9punsj.felles.FagsakYtelseType.PLEIEPENGER_LIVETS_SLUTTFASE -> {
+                val tilPlsvisning = this.tilPlsvisning()
+                HentK9SaksnummerGrunnlag(
+                    søknadstype = fagsakYtelseType,
+                    søker = tilPlsvisning.soekerId!!,
+                    pleietrengende = tilPlsvisning.pleietrengende!!.norskIdent,
+                    annenPart = null,
+                    periode = tilPlsvisning.soeknadsperiode?.firstOrNull()
+                )
+            }
+
+            no.nav.k9punsj.felles.FagsakYtelseType.OPPLÆRINGSPENGER -> {
+                val tilOlpvisning = this.tilOlpvisning()
+                HentK9SaksnummerGrunnlag(
+                    søknadstype = fagsakYtelseType,
+                    søker = tilOlpvisning.soekerId!!,
+                    pleietrengende = tilOlpvisning.barn!!.norskIdent,
+                    annenPart = null,
+                    periode = tilOlpvisning.soeknadsperiode?.firstOrNull()
+                )
+            }
+
+            no.nav.k9punsj.felles.FagsakYtelseType.UKJENT -> throw IllegalStateException("Ustøttet fagsakytelsetype")
+            no.nav.k9punsj.felles.FagsakYtelseType.UDEFINERT -> throw IllegalStateException("Ustøttet fagsakytelsetype")
+        }
+    }
+
+    private fun LocalDate.periodeDtoForHeleAret(): PeriodeDto {
+        return PeriodeDto(
+            fom = this.withMonth(1).withDayOfMonth(1),
+            tom = this.withMonth(12).withDayOfMonth(31)
+        )
+    }
+
     internal companion object {
         private suspend fun hentCallId() = try {
             coroutineContext.hentCallId()

src/main/kotlin/no/nav/k9punsj/integrasjoner/sak/SakClient.kt

@@ -17,7 +17,7 @@ import org.springframework.web.reactive.function.client.WebClient
 import java.net.URI
 
 @Service
-internal class SakClient(
+class SakClient(
     @Value("\${no.nav.sak.base_url}") private val baseUrl: URI,
     @Qualifier("sts") private val accessTokenClient: AccessTokenClient,
 ) {

src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostService.kt

@@ -50,12 +50,14 @@ class JournalpostService(
     internal suspend fun hentSafJournalPost(journalpostId: String): SafDtos.Journalpost? =
         safGateway.hentJournalpostInfo(journalpostId)
 
+    @Deprecated("Periode skal hentes fra søknaden i soknadservice. FIXME")
     internal suspend fun hentBehandlingsAar(journalpostId: String): Int {
         val behandlingsAar = journalpostRepository.hent(journalpostId).behandlingsAar
         logger.info("Hentet behandlingsår ($behandlingsAar) for journalpost: $journalpostId")
         return behandlingsAar ?: LocalDate.now().year
     }
 
+    @Deprecated("Periode skal hentes fra søknaden i soknadservice. FIXME")
     internal suspend fun lagreBehandlingsAar(journalpostId: String, behandlingsAar: Int) {
         val journalpost = journalpostRepository.hentHvis(journalpostId)
         if (journalpost != null) {
@@ -105,6 +107,7 @@ class JournalpostService(
         }
     }
 
+    @Deprecated("Kan sende in betyr att den har blitt sendt in fra før? FIXME")
     internal fun kanSendesInn(søknadEntitet: SøknadEntitet): MutableSet<String> {
         val journalPoster = søknadEntitet.journalposter!!
         val journalposterDto: JournalposterDto = objectMapper.convertValue(journalPoster)
@@ -200,6 +203,7 @@ class JournalpostService(
         return journalpostRepository.hentHvis(journalpostId)
     }
 
+    @Deprecated("Kan sende in betyr att den har blitt sendt in fra før? FIXME")
     internal suspend fun kanSendeInn(journalpostId: List<String>): Boolean {
         return journalpostRepository.kanSendeInn(journalpostId)
     }