IS-2274: Frisk til arbeid

Author: geir-waagboe

src/main/kotlin/no/nav/syfo/cronjob/preloadcache/PreloadCacheCronjob.kt

@@ -35,10 +35,11 @@ class PreloadCacheCronjob(
         database.getEnheter()
             .forEach { enhetNr ->
                 try {
+                    val now = LocalDate.now()
                     val personer = database.hentUbehandledePersonerTilknyttetEnhet(enhetNr).map { pPersonOversiktStatus ->
                         pPersonOversiktStatus.toPersonOversiktStatus(emptyList())
                     }.filter { personOversiktStatus ->
-                        personOversiktStatus.hasActiveOppgave(arenaCutoff)
+                        personOversiktStatus.hasActiveOppgave(arenaCutoff, now)
                     }
 
                     log.info("Caching ${personer.size} for enhet $enhetNr")

src/main/kotlin/no/nav/syfo/personstatus/PersonoversiktStatusService.kt

@@ -23,6 +23,7 @@ class PersonoversiktStatusService(
         val personListe = database.hentUbehandledePersonerTilknyttetEnhet(
             enhet = enhet,
         )
+        val today = LocalDate.now()
         return personListe.map { pPersonOversikStatus ->
             val personOppfolgingstilfelleVirksomhetList = getPersonOppfolgingstilfelleVirksomhetList(
                 pPersonOversikStatusId = pPersonOversikStatus.id,
@@ -31,7 +32,7 @@ class PersonoversiktStatusService(
                 personOppfolgingstilfelleVirksomhetList = personOppfolgingstilfelleVirksomhetList,
             )
         }.filter { personOversiktStatus ->
-            personOversiktStatus.hasActiveOppgave(arenaCutoff = arenaCutoff)
+            personOversiktStatus.hasActiveOppgave(arenaCutoff = arenaCutoff, today = today)
         }
     }
 

src/main/kotlin/no/nav/syfo/personstatus/api/v2/PersonOversiktStatusDTO.kt

@@ -25,7 +25,7 @@ data class PersonOversiktStatusDTO(
     val trengerOppfolgingFrist: LocalDate?,
     val behandlerBerOmBistandUbehandlet: Boolean,
     val arbeidsuforhetVurderAvslagUbehandlet: Boolean,
-    val friskmeldingtilarbeidsformidlingFom: LocalDate?
+    val friskmeldingtilarbeidsformidlingFom: LocalDate?,
 )
 
 data class PersonOppfolgingstilfelleDTO(

src/main/kotlin/no/nav/syfo/personstatus/domain/PersonOversiktStatus.kt

@@ -66,13 +66,14 @@ fun PersonOversiktStatus.isActiveAktivitetskrav(arenaCutoff: LocalDate) =
     (aktivitetskrav == AktivitetskravStatus.NY || aktivitetskrav == AktivitetskravStatus.AVVENT) &&
         aktivitetskravStoppunkt?.isAfter(arenaCutoff) ?: false
 
-fun PersonOversiktStatus.hasActiveOppgave(arenaCutoff: LocalDate): Boolean {
+fun PersonOversiktStatus.hasActiveOppgave(arenaCutoff: LocalDate, today: LocalDate): Boolean {
     return this.oppfolgingsplanLPSBistandUbehandlet == true ||
         this.dialogmotesvarUbehandlet ||
         this.isDialogmotekandidat() ||
         (this.motebehovUbehandlet == true && this.latestOppfolgingstilfelle != null) ||
         this.isActiveAktivitetskrav(arenaCutoff = arenaCutoff) ||
-        hasActiveBehandlerdialogOppgave() ||
+        this.hasActiveBehandlerdialogOppgave() ||
+        this.hasFriskmeldingTilArbeidsformidling(today) ||
         this.aktivitetskravVurderStansUbehandlet ||
         this.trengerOppfolging || this.behandlerBerOmBistandUbehandlet || this.arbeidsuforhetVurderAvslagUbehandlet
 }
@@ -127,6 +128,9 @@ fun PersonOversiktStatus.hasActiveBehandlerdialogOppgave(): Boolean {
         this.behandlerdialogAvvistUbehandlet
 }
 
+private fun PersonOversiktStatus.hasFriskmeldingTilArbeidsformidling(today: LocalDate): Boolean =
+    this.friskmeldingtilarbeidsformidlingFom != null && today.isBeforeOrEqual(this.friskmeldingtilarbeidsformidlingFom)
+
 fun PersonOversiktStatus.applyHendelse(
     oversikthendelseType: OversikthendelseType,
 ): PersonOversiktStatus =

src/main/resources/db/migration/V16_1__add_column_friskmeldingtilarbeidsformidling_fradato.sql

@@ -2,5 +2,5 @@ ALTER TABLE person_oversikt_status
     ADD COLUMN friskmelding_til_arbeidsformidling_fom DATE;
 
 CREATE INDEX IX_PERSON_OVERSIKT_FTA_FOM
-    ON PERSON_OVERSIKT_STATUS (tildelt_enhet, friskmelding_til_arbeidsformidling_fom)
+    ON PERSON_OVERSIKT_STATUS (friskmelding_til_arbeidsformidling_fom)
     WHERE (friskmelding_til_arbeidsformidling_fom IS NOT NULL);

src/test/kotlin/no/nav/syfo/personstatus/api/v2/PersonoversiktStatusApiV2Spek.kt

@@ -587,6 +587,65 @@ object PersonoversiktStatusApiV2Spek : Spek({
                         personOversiktStatus.dialogmotesvarUbehandlet shouldBeEqualTo true
                     }
                 }
+                it("return person with friskmelding til arbeidsformidling starting tomorrow") {
+                    val personident = PersonIdent(ARBEIDSTAKER_FNR)
+                    with(database) {
+                        createPersonOversiktStatus(PersonOversiktStatus(personident.value))
+                        setTildeltEnhet(personident, NAV_ENHET)
+                        setFriskmeldingtilarbeidsformidlingFom(personident, LocalDate.now().plusDays(1))
+                    }
+
+                    with(
+                        handleRequest(HttpMethod.Get, url) {
+                            addHeader(HttpHeaders.Authorization, bearerHeader(validToken))
+                        }
+                    ) {
+                        response.status() shouldBeEqualTo HttpStatusCode.OK
+
+                        val personOversiktStatus =
+                            objectMapper.readValue<List<PersonOversiktStatusDTO>>(response.content!!).first()
+                        personOversiktStatus.fnr shouldBeEqualTo personident.value
+                        personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
+                        personOversiktStatus.friskmeldingtilarbeidsformidlingFom!! shouldBeAfter LocalDate.now()
+                    }
+                }
+                it("return person with friskmelding til arbeidsformidling starting today") {
+                    val personident = PersonIdent(ARBEIDSTAKER_FNR)
+                    with(database) {
+                        createPersonOversiktStatus(PersonOversiktStatus(personident.value))
+                        setTildeltEnhet(personident, NAV_ENHET)
+                        setFriskmeldingtilarbeidsformidlingFom(personident, LocalDate.now())
+                    }
+
+                    with(
+                        handleRequest(HttpMethod.Get, url) {
+                            addHeader(HttpHeaders.Authorization, bearerHeader(validToken))
+                        }
+                    ) {
+                        response.status() shouldBeEqualTo HttpStatusCode.OK
+
+                        val personOversiktStatus =
+                            objectMapper.readValue<List<PersonOversiktStatusDTO>>(response.content!!).first()
+                        personOversiktStatus.fnr shouldBeEqualTo personident.value
+                        personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
+                        personOversiktStatus.friskmeldingtilarbeidsformidlingFom!! shouldBeEqualTo LocalDate.now()
+                    }
+                }
+                it("does not return person with friskmelding til arbeidsformidling starting yesterday") {
+                    val personident = PersonIdent(ARBEIDSTAKER_FNR)
+                    with(database) {
+                        createPersonOversiktStatus(PersonOversiktStatus(personident.value))
+                        setTildeltEnhet(personident, NAV_ENHET)
+                        setFriskmeldingtilarbeidsformidlingFom(personident, LocalDate.now().minusDays(1))
+                    }
+                    with(
+                        handleRequest(HttpMethod.Get, url) {
+                            addHeader(HttpHeaders.Authorization, bearerHeader(validToken))
+                        }
+                    ) {
+                        response.status() shouldBeEqualTo HttpStatusCode.NoContent
+                    }
+                }
 
                 it("Should update name in database") {
                     val personIdent = PersonIdent(ARBEIDSTAKER_FNR)

src/test/kotlin/no/nav/syfo/testutil/TestDatabase.kt

@@ -8,6 +8,7 @@ import no.nav.syfo.personstatus.domain.PersonOversiktStatus
 import org.flywaydb.core.Flyway
 import java.sql.Connection
 import java.sql.Timestamp
+import java.time.LocalDate
 import java.time.OffsetDateTime
 
 class TestDatabase : DatabaseInterface {
@@ -105,7 +106,28 @@ fun DatabaseInterface.setTildeltEnhet(
         connection.prepareStatement(querySetTildeltEnhet).use {
             it.setString(1, enhet)
             it.setString(2, ident.value)
-            it.execute()
+            if (it.executeUpdate() != 1) throw RuntimeException("No row updated")
+        }
+        connection.commit()
+    }
+}
+
+const val queryFriskmeldingtilarbeidsformidlingFom =
+    """
+    UPDATE PERSON_OVERSIKT_STATUS
+    SET friskmelding_til_arbeidsformidling_fom = ?
+    WHERE fnr = ?
+    """
+
+fun DatabaseInterface.setFriskmeldingtilarbeidsformidlingFom(
+    ident: PersonIdent,
+    fom: LocalDate,
+) {
+    this.connection.use { connection ->
+        connection.prepareStatement(queryFriskmeldingtilarbeidsformidlingFom).use {
+            it.setObject(1, fom)
+            it.setString(2, ident.value)
+            if (it.executeUpdate() != 1) throw RuntimeException("No row updated")
         }
         connection.commit()
     }