1302: Lagre referanse til tilknyttet oppgave

Author: Henreich

app/src/main/kotlin/no/nav/tiltakspenger/vedtak/repository/meldekort/BrukersMeldekortPostgresRepo.kt

@@ -53,7 +53,29 @@ class BrukersMeldekortPostgresRepo(
                     "mottatt" to brukersMeldekort.mottatt,
                     "dager" to brukersMeldekort.toDagerJson(),
                     "journalpost_id" to brukersMeldekort.journalpostId.toString(),
-                    "oppgave_id" to brukersMeldekort.oppgaveId,
+                    "oppgave_id" to brukersMeldekort.oppgaveId?.toString(),
+                ).asUpdate,
+            )
+        }
+    }
+
+    /**
+     * Oppdaterer et meldekort som allerede er lagret i databasen.
+     */
+    override fun oppdater(
+        brukersMeldekort: BrukersMeldekort,
+        sessionContext: SessionContext?,
+    ) {
+        sessionFactory.withSession(sessionContext) { session ->
+            session.run(
+                sqlQuery(
+                    """
+                update meldekort_bruker 
+                set oppgave_id = :oppgave_id
+                where id = :id
+                """,
+                    "id" to brukersMeldekort.id.toString(),
+                    "oppgave_id" to brukersMeldekort.oppgaveId?.toString(),
                 ).asUpdate,
             )
         }

app/src/test/kotlin/no/nav/tiltakspenger/meldekort/service/OppgaveMeldekortServiceTest.kt

@@ -2,6 +2,7 @@ package no.nav.tiltakspenger.meldekort.service
 
 import io.mockk.clearAllMocks
 import io.mockk.coEvery
+import io.mockk.coJustRun
 import io.mockk.coVerify
 import io.mockk.every
 import io.mockk.mockk
@@ -35,9 +36,21 @@ class OppgaveMeldekortServiceTest {
             val meldekort = mockk<BrukersMeldekort>()
             every { meldekort.journalpostId } returns journalpostId
             every { meldekort.sakId } returns SakId.random()
+            every {
+                meldekort.copy(
+                    id = any(),
+                    meldeperiode = any(),
+                    sakId = any(),
+                    mottatt = any(),
+                    dager = any(),
+                    journalpostId = any(),
+                    oppgaveId = any(),
+                )
+            } returns meldekort
 
             coEvery { brukersMeldekortRepo.hentMeldekortSomIkkeSkalGodkjennesAutomatisk() } returns listOf(meldekort)
             coEvery { sakRepo.hentForSakId(any()) } returns mockk(relaxed = true)
+            coJustRun { brukersMeldekortRepo.oppdater(any()) }
 
             service.opprettOppgaveForMeldekortSomIkkeGodkjennesAutomatisk()
 
@@ -57,6 +70,7 @@ class OppgaveMeldekortServiceTest {
             val meldekort = mockk<BrukersMeldekort>()
             every { meldekort.journalpostId } returns null
             coEvery { brukersMeldekortRepo.hentMeldekortSomIkkeSkalGodkjennesAutomatisk() } returns listOf(meldekort)
+            coJustRun { brukersMeldekortRepo.oppdater(any()) }
 
             service.opprettOppgaveForMeldekortSomIkkeGodkjennesAutomatisk()
 
@@ -85,6 +99,7 @@ class OppgaveMeldekortServiceTest {
             val meldekort = (1..20).map { mockk<BrukersMeldekort>(relaxed = true) }
             coEvery { brukersMeldekortRepo.hentMeldekortSomIkkeSkalGodkjennesAutomatisk() } returns meldekort
             coEvery { sakRepo.hentForSakId(any()) } returns mockk(relaxed = true)
+            coJustRun { brukersMeldekortRepo.oppdater(any()) }
 
             service.opprettOppgaveForMeldekortSomIkkeGodkjennesAutomatisk()
 

domene/src/main/kotlin/no/nav/tiltakspenger/meldekort/domene/BrukersMeldekortRepo.kt

@@ -11,6 +11,11 @@ interface BrukersMeldekortRepo {
         sessionContext: SessionContext? = null,
     )
 
+    fun oppdater(
+        brukersMeldekort: BrukersMeldekort,
+        sessionContext: SessionContext? = null,
+    )
+
     fun hentForSakId(
         sakId: SakId,
         sessionContext: SessionContext? = null,

domene/src/main/kotlin/no/nav/tiltakspenger/meldekort/service/OppgaveMeldekortService.kt

@@ -26,7 +26,10 @@ class OppgaveMeldekortService(
                 ?: log.warn { "Fant ikke sak for sakId ${meldekort.sakId}" }.let { return@forEach }
 
             log.info { "Oppretter oppgave for meldekortId ${meldekort.id}" }
-            oppgaveGateway.opprettOppgave(sak.fnr, journalpostId, Oppgavebehov.NYTT_MELDEKORT)
+            val oppgaveId = oppgaveGateway.opprettOppgave(sak.fnr, journalpostId, Oppgavebehov.NYTT_MELDEKORT)
+
+            log.info { "Opprettet oppgave med id $oppgaveId for meldekort med id ${meldekort.id}" }
+            brukersMeldekortRepo.oppdater(meldekort.copy(oppgaveId = oppgaveId))
         }
     }
 }

test-common/src/main/kotlin/no/nav/tiltakspenger/fakes/repos/BrukersMeldekortFakeRepo.kt

@@ -28,6 +28,10 @@ class BrukersMeldekortFakeRepo(val meldeperiodeFakeRepo: MeldeperiodeFakeRepo) :
         )
     }
 
+    override fun oppdater(brukersMeldekort: BrukersMeldekort, sessionContext: SessionContext?) {
+        data.get()[brukersMeldekort.id] = brukersMeldekort
+    }
+
     override fun hentForSakId(sakId: SakId, sessionContext: SessionContext?): List<BrukersMeldekort> {
         return data.get().values.filter {
             it.sakId == sakId