Lagrer nå person_ident på oppgave fra behandlingsflyt.

navikt · Oct 24, 2024 · de1480b · de1480b
1 parent 2f3b87b
commit de1480b
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 4 deletions.
diff --git a/api-kontrakt/src/main/kotlin/no/nav/aap/oppgave/OppgaveDto.kt b/api-kontrakt/src/main/kotlin/no/nav/aap/oppgave/OppgaveDto.kt
@@ -7,6 +7,7 @@ import java.util.UUID
 
 data class OppgaveDto(
     val id: Long? = null,
+    val personIdent: String? = null,
     val saksnummer: String? = null,
     val behandlingRef: UUID? = null,
     val journalpostId: Long? = null,

diff --git a/app/src/main/kotlin/no/nav/aap/oppgave/OppgaveRepository.kt b/app/src/main/kotlin/no/nav/aap/oppgave/OppgaveRepository.kt
@@ -26,9 +26,10 @@ class OppgaveRepository(private val connection: DBConnection) {
                 STATUS,
                 BEHANDLINGSTYPE,
                 OPPRETTET_AV,
-                OPPRETTET_TIDSPUNKT
+                OPPRETTET_TIDSPUNKT,
+                PERSON_IDENT
             ) VALUES (
-                ?, ?, ?, ?, ?, ?, ?, ?, ?
+                ?, ?, ?, ?, ?, ?, ?, ?, ?, ?
             )
             
         """.trimIndent()
@@ -43,6 +44,7 @@ class OppgaveRepository(private val connection: DBConnection) {
                 setString(7, oppgaveDto.behandlingstype.name)
                 setString(8, oppgaveDto.opprettetAv)
                 setLocalDateTime(9, oppgaveDto.opprettetTidspunkt)
+                setString(10, oppgaveDto.personIdent)
             }
         }
         return OppgaveId(id, 0L)
@@ -335,6 +337,7 @@ class OppgaveRepository(private val connection: DBConnection) {
     private fun oppgaveMapper(row: Row): OppgaveDto {
         return OppgaveDto(
             id = row.getLong("ID"),
+            personIdent = row.getStringOrNull("PERSON_IDENT"),
             saksnummer = row.getStringOrNull("SAKSNUMMER"),
             behandlingRef = row.getUUIDOrNull("BEHANDLING_REF"),
             journalpostId = row.getLongOrNull("JOURNALPOST_ID"),
@@ -355,6 +358,7 @@ class OppgaveRepository(private val connection: DBConnection) {
     private companion object {
         val alleOppgaveFelt = """
             ID,
+            PERSON_IDENT,
             SAKSNUMMER,
             BEHANDLING_REF,
             JOURNALPOST_ID,

diff --git a/app/src/main/kotlin/no/nav/aap/oppgave/oppdater/OppdaterOppgaveService.kt b/app/src/main/kotlin/no/nav/aap/oppgave/oppdater/OppdaterOppgaveService.kt
@@ -110,7 +110,7 @@ class OppdaterOppgaveService(private val connection: DBConnection) {
 
     private fun opprettOppgaver(oppgaveOppdatering: OppgaveOppdatering, avklarsbehovSomDetSkalOpprettesOppgaverFor: List<AvklaringsbehovKode>, oppgaveRepo: OppgaveRepository) {
         avklarsbehovSomDetSkalOpprettesOppgaverFor.forEach { avklaringsbehovKode ->
-            val nyOppgave = oppgaveOppdatering.opprettNyOppgave(avklaringsbehovKode, oppgaveOppdatering.behandlingstype, "Kelvin")
+            val nyOppgave = oppgaveOppdatering.opprettNyOppgave(oppgaveOppdatering.personIdent, avklaringsbehovKode, oppgaveOppdatering.behandlingstype, "Kelvin")
             val oppgaveId = oppgaveRepo.opprettOppgave(nyOppgave)
             log.info("Ny oppgave(id=${oppgaveId.id}) ble opprettet")
             val hvemLøsteForrigeAvklaringsbehov = oppgaveOppdatering.hvemLøsteForrigeAvklaringsbehov()
@@ -176,8 +176,9 @@ class OppdaterOppgaveService(private val connection: DBConnection) {
             .last()
     }
 
-    private fun OppgaveOppdatering.opprettNyOppgave(avklaringsbehovKode: AvklaringsbehovKode, behandlingstype: Behandlingstype, ident: String): OppgaveDto {
+    private fun OppgaveOppdatering.opprettNyOppgave(personIdent: String?, avklaringsbehovKode: AvklaringsbehovKode, behandlingstype: Behandlingstype, ident: String): OppgaveDto {
         return OppgaveDto(
+            personIdent = personIdent,
             saksnummer = this.saksnummer,
             behandlingRef = this.referanse,
             journalpostId = this.journalpostId,

diff --git a/app/src/main/kotlin/no/nav/aap/oppgave/oppdater/OppgaveOppdatering.kt b/app/src/main/kotlin/no/nav/aap/oppgave/oppdater/OppgaveOppdatering.kt
@@ -26,6 +26,7 @@ enum class AvklaringsbehovStatus {
 }
 
 data class OppgaveOppdatering(
+    val personIdent: String? = null,
     val saksnummer: String? = null,
     val referanse: UUID? = null,
     val journalpostId: Long? = null,
@@ -49,6 +50,7 @@ data class Endring(
 
 fun BehandlingFlytStoppetHendelse.tilOppgaveOppdatering(): OppgaveOppdatering {
     return OppgaveOppdatering(
+        personIdent = this.personIdent,
         saksnummer = this.saksnummer.toString(),
         referanse = this.referanse.referanse,
         behandlingStatus = this.status.tilBehandlingsstatus(),

diff --git a/dbflyway/src/main/resources/flyway/V1.9__Nytt_felt_person_ident_på_oppgave.sql b/dbflyway/src/main/resources/flyway/V1.9__Nytt_felt_person_ident_på_oppgave.sql
@@ -0,0 +1 @@
+ALTER TABLE OPPGAVE ADD COLUMN PERSON_IDENT VARCHAR(11);