IS-2274: Frisk til arbeid

geir-waagboe · geir-waagboe · commit 9ead1eff5abf · 2024-04-22T13:50:03.000+02:00
diff --git a/src/main/kotlin/no/nav/syfo/cronjob/behandlendeenhet/PersonBehandlendeEnhetQuery.kt b/src/main/kotlin/no/nav/syfo/cronjob/behandlendeenhet/PersonBehandlendeEnhetQuery.kt
@@ -70,6 +70,7 @@ const val queryGetPersonerWithOppgaveAndOldEnhet =
         OR trenger_oppfolging = 't'
         OR behandler_bistand_ubehandlet = 't'
         OR arbeidsuforhet_vurder_avslag_ubehandlet = 't'
+        OR (friskmelding_til_arbeidsformidling_fom IS NOT NULL AND friskmelding_til_arbeidsformidling_fom >= CURRENT_DATE) 
         )
     AND (tildelt_enhet_updated_at IS NULL OR tildelt_enhet_updated_at <= NOW() - INTERVAL '24 HOURS')
     ORDER BY tildelt_enhet_updated_at ASC
diff --git a/src/main/kotlin/no/nav/syfo/cronjob/preloadcache/PreloadCacheCronjob.kt b/src/main/kotlin/no/nav/syfo/cronjob/preloadcache/PreloadCacheCronjob.kt
@@ -35,11 +35,10 @@ 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, now)
+                        personOversiktStatus.hasActiveOppgave(arenaCutoff)
                     }
 
                     log.info("Caching ${personer.size} for enhet $enhetNr")
diff --git a/src/main/kotlin/no/nav/syfo/cronjob/virksomhetsnavn/PersonOppfolgingstilfelleVirksomhetsnavnQuery.kt b/src/main/kotlin/no/nav/syfo/cronjob/virksomhetsnavn/PersonOppfolgingstilfelleVirksomhetsnavnQuery.kt
@@ -43,6 +43,7 @@ const val queryPersonOppfolgingstilfelleVirksomhetNoVirksomhetsnavnList =
         OR trenger_oppfolging = 't'
         OR behandler_bistand_ubehandlet = 't'
         OR arbeidsuforhet_vurder_avslag_ubehandlet = 't'
+        OR (friskmelding_til_arbeidsformidling_fom IS NOT NULL AND friskmelding_til_arbeidsformidling_fom >= CURRENT_DATE)
         )
     ORDER BY PERSON_OPPFOLGINGSTILFELLE_VIRKSOMHET.created_at ASC
     LIMIT 1000
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/PersonoversiktStatusService.kt b/src/main/kotlin/no/nav/syfo/personstatus/PersonoversiktStatusService.kt
@@ -23,7 +23,6 @@ class PersonoversiktStatusService(
         val personListe = database.hentUbehandledePersonerTilknyttetEnhet(
             enhet = enhet,
         )
-        val today = LocalDate.now()
         return personListe.map { pPersonOversikStatus ->
             val personOppfolgingstilfelleVirksomhetList = getPersonOppfolgingstilfelleVirksomhetList(
                 pPersonOversikStatusId = pPersonOversikStatus.id,
@@ -32,7 +31,7 @@ class PersonoversiktStatusService(
                 personOppfolgingstilfelleVirksomhetList = personOppfolgingstilfelleVirksomhetList,
             )
         }.filter { personOversiktStatus ->
-            personOversiktStatus.hasActiveOppgave(arenaCutoff = arenaCutoff, today = today)
+            personOversiktStatus.hasActiveOppgave(arenaCutoff = arenaCutoff)
         }
     }
 
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/api/v2/PersonOversiktStatusDTO.kt b/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(
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/db/getFromPersonOversiktStatus.kt b/src/main/kotlin/no/nav/syfo/personstatus/db/getFromPersonOversiktStatus.kt
@@ -124,7 +124,7 @@ fun ResultSet.toPPersonOversiktStatus(): PPersonOversiktStatus =
         behandlerBerOmBistandUbehandlet = getBoolean("behandler_bistand_ubehandlet"),
         antallSykedager = getObject("antall_sykedager") as Int?,
         arbeidsuforhetVurderAvslagUbehandlet = getBoolean("arbeidsuforhet_vurder_avslag_ubehandlet"),
-        friskmeldingtilarbeidsformidlingFom = getDate("friskmelding_til_arbeidsformidling_fom")?.toLocalDate(),
+        friskmeldingTilArbeidsformidlingFom = getDate("friskmelding_til_arbeidsformidling_fom")?.toLocalDate(),
     )
 
 fun ResultSet.toVeilederBrukerKnytning(): VeilederBrukerKnytning =
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/domain/PPersonOversiktStatus.kt b/src/main/kotlin/no/nav/syfo/personstatus/domain/PPersonOversiktStatus.kt
@@ -41,7 +41,7 @@ data class PPersonOversiktStatus(
     val behandlerBerOmBistandUbehandlet: Boolean,
     val antallSykedager: Int?,
     val arbeidsuforhetVurderAvslagUbehandlet: Boolean,
-    val friskmeldingtilarbeidsformidlingFom: LocalDate?,
+    val friskmeldingTilArbeidsformidlingFom: LocalDate?,
 )
 
 fun PPersonOversiktStatus.toPersonOversiktStatus(
@@ -73,7 +73,7 @@ fun PPersonOversiktStatus.toPersonOversiktStatus(
     trengerOppfolgingFrist = trengerOppfolgingFrist,
     behandlerBerOmBistandUbehandlet = behandlerBerOmBistandUbehandlet,
     arbeidsuforhetVurderAvslagUbehandlet = arbeidsuforhetVurderAvslagUbehandlet,
-    friskmeldingtilarbeidsformidlingFom = friskmeldingtilarbeidsformidlingFom,
+    friskmeldingTilArbeidsformidlingFom = friskmeldingTilArbeidsformidlingFom,
 )
 
 fun PPersonOversiktStatus.toPersonOppfolgingstilfelle(
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/domain/PersonOversiktStatus.kt b/src/main/kotlin/no/nav/syfo/personstatus/domain/PersonOversiktStatus.kt
@@ -36,7 +36,7 @@ data class PersonOversiktStatus(
     val trengerOppfolgingFrist: LocalDate? = null,
     val behandlerBerOmBistandUbehandlet: Boolean = false,
     val arbeidsuforhetVurderAvslagUbehandlet: Boolean = false,
-    val friskmeldingtilarbeidsformidlingFom: LocalDate? = null,
+    val friskmeldingTilArbeidsformidlingFom: LocalDate? = null,
 ) {
     constructor(fnr: String) : this(
         null, fnr = fnr, null, null, null,
@@ -66,14 +66,14 @@ fun PersonOversiktStatus.isActiveAktivitetskrav(arenaCutoff: LocalDate) =
     (aktivitetskrav == AktivitetskravStatus.NY || aktivitetskrav == AktivitetskravStatus.AVVENT) &&
         aktivitetskravStoppunkt?.isAfter(arenaCutoff) ?: false
 
-fun PersonOversiktStatus.hasActiveOppgave(arenaCutoff: LocalDate, today: LocalDate): Boolean {
+fun PersonOversiktStatus.hasActiveOppgave(arenaCutoff: LocalDate): Boolean {
     return this.oppfolgingsplanLPSBistandUbehandlet == true ||
         this.dialogmotesvarUbehandlet ||
         this.isDialogmotekandidat() ||
         (this.motebehovUbehandlet == true && this.latestOppfolgingstilfelle != null) ||
         this.isActiveAktivitetskrav(arenaCutoff = arenaCutoff) ||
         this.hasActiveBehandlerdialogOppgave() ||
-        this.hasFriskmeldingTilArbeidsformidling(today) ||
+        this.hasFriskmeldingTilArbeidsformidling() ||
         this.aktivitetskravVurderStansUbehandlet ||
         this.trengerOppfolging || this.behandlerBerOmBistandUbehandlet || this.arbeidsuforhetVurderAvslagUbehandlet
 }
@@ -119,7 +119,7 @@ fun PersonOversiktStatus.toPersonOversiktStatusDTO(arenaCutoff: LocalDate) =
         trengerOppfolgingFrist = trengerOppfolgingFrist,
         behandlerBerOmBistandUbehandlet = behandlerBerOmBistandUbehandlet,
         arbeidsuforhetVurderAvslagUbehandlet = arbeidsuforhetVurderAvslagUbehandlet,
-        friskmeldingtilarbeidsformidlingFom = friskmeldingtilarbeidsformidlingFom,
+        friskmeldingTilArbeidsformidlingFom = friskmeldingTilArbeidsformidlingFom,
     )
 
 fun PersonOversiktStatus.hasActiveBehandlerdialogOppgave(): Boolean {
@@ -128,8 +128,8 @@ fun PersonOversiktStatus.hasActiveBehandlerdialogOppgave(): Boolean {
         this.behandlerdialogAvvistUbehandlet
 }
 
-private fun PersonOversiktStatus.hasFriskmeldingTilArbeidsformidling(today: LocalDate): Boolean =
-    this.friskmeldingtilarbeidsformidlingFom != null && today.isBeforeOrEqual(this.friskmeldingtilarbeidsformidlingFom)
+private fun PersonOversiktStatus.hasFriskmeldingTilArbeidsformidling(): Boolean =
+    this.friskmeldingTilArbeidsformidlingFom != null && LocalDate.now().isBeforeOrEqual(this.friskmeldingTilArbeidsformidlingFom)
 
 fun PersonOversiktStatus.applyHendelse(
     oversikthendelseType: OversikthendelseType,
diff --git a/src/test/kotlin/no/nav/syfo/personstatus/api/v2/PersonoversiktStatusApiV2Spek.kt b/src/test/kotlin/no/nav/syfo/personstatus/api/v2/PersonoversiktStatusApiV2Spek.kt
@@ -592,7 +592,7 @@ object PersonoversiktStatusApiV2Spek : Spek({
                     with(database) {
                         createPersonOversiktStatus(PersonOversiktStatus(personident.value))
                         setTildeltEnhet(personident, NAV_ENHET)
-                        setFriskmeldingtilarbeidsformidlingFom(personident, LocalDate.now().plusDays(1))
+                        setFriskmeldingTilArbeidsformidlingFom(personident, LocalDate.now().plusDays(1))
                     }
 
                     with(
@@ -606,15 +606,15 @@ object PersonoversiktStatusApiV2Spek : Spek({
                             objectMapper.readValue<List<PersonOversiktStatusDTO>>(response.content!!).first()
                         personOversiktStatus.fnr shouldBeEqualTo personident.value
                         personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
-                        personOversiktStatus.friskmeldingtilarbeidsformidlingFom!! shouldBeAfter LocalDate.now()
+                        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())
+                        setFriskmeldingTilArbeidsformidlingFom(personident, LocalDate.now())
                     }
 
                     with(
@@ -628,15 +628,15 @@ object PersonoversiktStatusApiV2Spek : Spek({
                             objectMapper.readValue<List<PersonOversiktStatusDTO>>(response.content!!).first()
                         personOversiktStatus.fnr shouldBeEqualTo personident.value
                         personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
-                        personOversiktStatus.friskmeldingtilarbeidsformidlingFom!! shouldBeEqualTo LocalDate.now()
+                        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))
+                        setFriskmeldingTilArbeidsformidlingFom(personident, LocalDate.now().minusDays(1))
                     }
                     with(
                         handleRequest(HttpMethod.Get, url) {
diff --git a/src/test/kotlin/no/nav/syfo/testutil/TestDatabase.kt b/src/test/kotlin/no/nav/syfo/testutil/TestDatabase.kt
@@ -119,7 +119,7 @@ const val queryFriskmeldingtilarbeidsformidlingFom =
     WHERE fnr = ?
     """
 
-fun DatabaseInterface.setFriskmeldingtilarbeidsformidlingFom(
+fun DatabaseInterface.setFriskmeldingTilArbeidsformidlingFom(
     ident: PersonIdent,
     fom: LocalDate,
 ) {
diff --git a/src/test/kotlin/no/nav/syfo/testutil/generator/PPersonOversiktStatusGenerator.kt b/src/test/kotlin/no/nav/syfo/testutil/generator/PPersonOversiktStatusGenerator.kt
@@ -38,5 +38,5 @@ fun generatePPersonOversiktStatus(fnr: String = UserConstants.ARBEIDSTAKER_FNR)
     behandlerBerOmBistandUbehandlet = false,
     antallSykedager = null,
     arbeidsuforhetVurderAvslagUbehandlet = false,
-    friskmeldingtilarbeidsformidlingFom = null,
+    friskmeldingTilArbeidsformidlingFom = null,
 )

Original file line number	Diff line number	Diff line change
`@@ -70,6 +70,7 @@ const val queryGetPersonerWithOppgaveAndOldEnhet =`
`70`	`70`	`OR trenger_oppfolging = 't'`
`71`	`71`	`OR behandler_bistand_ubehandlet = 't'`
`72`	`72`	`OR arbeidsuforhet_vurder_avslag_ubehandlet = 't'`
	`73`	`+ OR (friskmelding_til_arbeidsformidling_fom IS NOT NULL AND friskmelding_til_arbeidsformidling_fom >= CURRENT_DATE)`
`73`	`74`	`)`
`74`	`75`	`AND (tildelt_enhet_updated_at IS NULL OR tildelt_enhet_updated_at <= NOW() - INTERVAL '24 HOURS')`
`75`	`76`	`ORDER BY tildelt_enhet_updated_at ASC`
Original file line number	Diff line number	Diff line change
`@@ -43,6 +43,7 @@ const val queryPersonOppfolgingstilfelleVirksomhetNoVirksomhetsnavnList =`
`43`	`43`	`OR trenger_oppfolging = 't'`
`44`	`44`	`OR behandler_bistand_ubehandlet = 't'`
`45`	`45`	`OR arbeidsuforhet_vurder_avslag_ubehandlet = 't'`
	`46`	`+ OR (friskmelding_til_arbeidsformidling_fom IS NOT NULL AND friskmelding_til_arbeidsformidling_fom >= CURRENT_DATE)`
`46`	`47`	`)`
`47`	`48`	`ORDER BY PERSON_OPPFOLGINGSTILFELLE_VIRKSOMHET.created_at ASC`
`48`	`49`	`LIMIT 1000`
Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,6 @@ class PersonoversiktStatusService(`
`23`	`23`	`val personListe = database.hentUbehandledePersonerTilknyttetEnhet(`
`24`	`24`	`enhet = enhet,`
`25`	`25`	`)`
`26`		`- val today = LocalDate.now()`
`27`	`26`	`return personListe.map { pPersonOversikStatus ->`
`28`	`27`	`val personOppfolgingstilfelleVirksomhetList = getPersonOppfolgingstilfelleVirksomhetList(`
`29`	`28`	`pPersonOversikStatusId = pPersonOversikStatus.id,`
`@@ -32,7 +31,7 @@ class PersonoversiktStatusService(`
`32`	`31`	`personOppfolgingstilfelleVirksomhetList = personOppfolgingstilfelleVirksomhetList,`
`33`	`32`	`)`
`34`	`33`	`}.filter { personOversiktStatus ->`
`35`		`- personOversiktStatus.hasActiveOppgave(arenaCutoff = arenaCutoff, today = today)`
	`34`	`+ personOversiktStatus.hasActiveOppgave(arenaCutoff = arenaCutoff)`
`36`	`35`	`}`
`37`	`36`	`}`
`38`	`37`
Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@ data class PersonOversiktStatusDTO(`
`25`	`25`	`val trengerOppfolgingFrist: LocalDate?,`
`26`	`26`	`val behandlerBerOmBistandUbehandlet: Boolean,`
`27`	`27`	`val arbeidsuforhetVurderAvslagUbehandlet: Boolean,`
`28`		`- val friskmeldingtilarbeidsformidlingFom: LocalDate?,`
	`28`	`+ val friskmeldingTilArbeidsformidlingFom: LocalDate?,`
`29`	`29`	`)`
`30`	`30`
`31`	`31`	`data class PersonOppfolgingstilfelleDTO(`
Original file line number	Diff line number	Diff line change
`@@ -124,7 +124,7 @@ fun ResultSet.toPPersonOversiktStatus(): PPersonOversiktStatus =`
`124`	`124`	`behandlerBerOmBistandUbehandlet = getBoolean("behandler_bistand_ubehandlet"),`
`125`	`125`	`antallSykedager = getObject("antall_sykedager") as Int?,`
`126`	`126`	`arbeidsuforhetVurderAvslagUbehandlet = getBoolean("arbeidsuforhet_vurder_avslag_ubehandlet"),`
`127`		`- friskmeldingtilarbeidsformidlingFom = getDate("friskmelding_til_arbeidsformidling_fom")?.toLocalDate(),`
	`127`	`+ friskmeldingTilArbeidsformidlingFom = getDate("friskmelding_til_arbeidsformidling_fom")?.toLocalDate(),`
`128`	`128`	`)`
`129`	`129`
`130`	`130`	`fun ResultSet.toVeilederBrukerKnytning(): VeilederBrukerKnytning =`
Original file line number	Diff line number	Diff line change
`@@ -38,5 +38,5 @@ fun generatePPersonOversiktStatus(fnr: String = UserConstants.ARBEIDSTAKER_FNR)`
`38`	`38`	`behandlerBerOmBistandUbehandlet = false,`
`39`	`39`	`antallSykedager = null,`
`40`	`40`	`arbeidsuforhetVurderAvslagUbehandlet = false,`
`41`		`- friskmeldingtilarbeidsformidlingFom = null,`
	`41`	`+ friskmeldingTilArbeidsformidlingFom = null,`
`42`	`42`	`)`