Skip to content

Commit 4c40278

Browse files
vetlesolgaardvetlesolgaard
committed
Merge branch 'master' into IS-2271-Possibility-to-see-arbeidsuforhet-varsel-before-expired-in-syfooversikt
2 parents 3882858 + e590c9c commit 4c40278

File tree

10 files changed

+51
-20
lines changed

10 files changed

+51
-20
lines changed

‎.nais/naiserator-dev.yaml

+4
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,10 @@ spec:
7070
diskAutoresize: true
7171
kafka:
7272
pool: nav-dev
73+
observability:
74+
autoInstrumentation:
75+
enabled: true
76+
runtime: java
7377
envFrom:
7478
- secret: syfooversiktsrv-redis-password
7579
env:

‎.nais/naiserator-prod.yaml

+4
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,10 @@ spec:
7272
diskAutoresize: true
7373
kafka:
7474
pool: nav-prod
75+
observability:
76+
autoInstrumentation:
77+
enabled: true
78+
runtime: java
7579
envFrom:
7680
- secret: syfooversiktsrv-redis-password
7781
env:

‎src/main/kotlin/no/nav/syfo/cronjob/behandlendeenhet/PersonBehandlendeEnhetQuery.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ const val queryGetPersonerWithOppgaveAndOldEnhet =
7070
OR trenger_oppfolging = 't'
7171
OR behandler_bistand_ubehandlet = 't'
7272
OR arbeidsuforhet_vurder_avslag_ubehandlet = 't'
73-
OR (friskmelding_til_arbeidsformidling_fom IS NOT NULL AND friskmelding_til_arbeidsformidling_fom >= CURRENT_DATE)
73+
OR friskmelding_til_arbeidsformidling_fom IS NOT NULL
7474
)
7575
AND (tildelt_enhet_updated_at IS NULL OR tildelt_enhet_updated_at <= NOW() - INTERVAL '24 HOURS')
7676
ORDER BY tildelt_enhet_updated_at ASC

‎src/main/kotlin/no/nav/syfo/cronjob/virksomhetsnavn/PersonOppfolgingstilfelleVirksomhetsnavnQuery.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ const val queryPersonOppfolgingstilfelleVirksomhetNoVirksomhetsnavnList =
4343
OR trenger_oppfolging = 't'
4444
OR behandler_bistand_ubehandlet = 't'
4545
OR arbeidsuforhet_vurder_avslag_ubehandlet = 't'
46-
OR (friskmelding_til_arbeidsformidling_fom IS NOT NULL AND friskmelding_til_arbeidsformidling_fom >= CURRENT_DATE)
46+
OR friskmelding_til_arbeidsformidling_fom IS NOT NULL
4747
)
4848
ORDER BY PERSON_OPPFOLGINGSTILFELLE_VIRKSOMHET.created_at ASC
4949
LIMIT 1000

‎src/main/kotlin/no/nav/syfo/frisktilarbeid/kafka/KafkaFriskTilArbeidMetric.kt

+4-4
Original file line numberDiff line numberDiff line change
@@ -12,17 +12,17 @@ const val KAFKA_CONSUMER_FRISKTILARBEID_UPDATE = "${KAFKA_CONSUMER_FRISKTILARBEI
1212

1313
val COUNT_KAFKA_CONSUMER_FRISKTILARBEID_READ: Counter =
1414
Counter.builder(KAFKA_CONSUMER_FRISKTILARBEID_READ)
15-
.description("Counts the number of reads from topic - isfrisktilarbeid-vedtak-fattet")
15+
.description("Counts the number of reads from topic - isfrisktilarbeid-vedtak-status")
1616
.register(METRICS_REGISTRY)
1717
val COUNT_KAFKA_CONSUMER_FRISKTILARBEID_TOMBSTONE: Counter =
1818
Counter.builder(KAFKA_CONSUMER_FRISKTILARBEID_TOMBSTONE)
19-
.description("Counts the number of tombstones received from topic - isfrisktilarbeid-vedtak-fattet")
19+
.description("Counts the number of tombstones received from topic - isfrisktilarbeid-vedtak-status")
2020
.register(METRICS_REGISTRY)
2121
val COUNT_KAFKA_CONSUMER_FRISKTILARBEID_CREATED_PERSONOVERSIKT_STATUS: Counter =
2222
Counter.builder(KAFKA_CONSUMER_FRISKTILARBEID_CREATE)
23-
.description("Counts the number of personoversikt-status created from reading topic - isfrisktilarbeid-vedtak-fattet")
23+
.description("Counts the number of personoversikt-status created from reading topic - isfrisktilarbeid-vedtak-status")
2424
.register(METRICS_REGISTRY)
2525
val COUNT_KAFKA_CONSUMER_FRISKTILARBEID_UPDATED_PERSONOVERSIKT_STATUS: Counter =
2626
Counter.builder(KAFKA_CONSUMER_FRISKTILARBEID_UPDATE)
27-
.description("Counts the number of personoversikt-status updated from reading topic - isfrisktilarbeid-vedtak-fattet")
27+
.description("Counts the number of personoversikt-status updated from reading topic - isfrisktilarbeid-vedtak-status")
2828
.register(METRICS_REGISTRY)

‎src/main/kotlin/no/nav/syfo/frisktilarbeid/kafka/KafkaFriskTilArbeidTask.kt

+2-2
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ fun launchKafkaTaskFriskTilArbeidVedtak(
2222
val consumerProperties = Properties().apply {
2323
putAll(kafkaAivenConsumerConfig(kafkaEnvironment = kafkaEnvironment))
2424
this[ConsumerConfig.MAX_POLL_RECORDS_CONFIG] = "10"
25-
this[ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG] = VedtakFattetRecordDeserializer::class.java
25+
this[ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG] = VedtakStatusRecordDeserializer::class.java
2626
}
2727

2828
launchKafkaTask(
@@ -33,7 +33,7 @@ fun launchKafkaTaskFriskTilArbeidVedtak(
3333
)
3434
}
3535

36-
class VedtakFattetRecordDeserializer : Deserializer<VedtakStatusRecord> {
36+
class VedtakStatusRecordDeserializer : Deserializer<VedtakStatusRecord> {
3737
private val mapper = configuredJacksonMapper()
3838
override fun deserialize(topic: String, data: ByteArray): VedtakStatusRecord =
3939
mapper.readValue(data, VedtakStatusRecord::class.java)

‎src/main/kotlin/no/nav/syfo/personstatus/db/getFromPersonOversiktStatus.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ const val queryHentUbehandledePersonerTilknyttetEnhet = """
5454
OR trenger_oppfolging = 't'
5555
OR behandler_bistand_ubehandlet = 't'
5656
OR arbeidsuforhet_vurder_avslag_ubehandlet = 't'
57-
OR (friskmelding_til_arbeidsformidling_fom IS NOT NULL AND friskmelding_til_arbeidsformidling_fom >= CURRENT_DATE)
57+
OR friskmelding_til_arbeidsformidling_fom IS NOT NULL
5858
)
5959
);
6060
"""

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

+1-4
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ fun PersonOversiktStatus.hasActiveOppgave(arenaCutoff: LocalDate): Boolean {
7373
(this.motebehovUbehandlet == true && this.latestOppfolgingstilfelle != null) ||
7474
this.isActiveAktivitetskrav(arenaCutoff = arenaCutoff) ||
7575
this.hasActiveBehandlerdialogOppgave() ||
76-
this.hasFriskmeldingTilArbeidsformidling() ||
76+
this.friskmeldingTilArbeidsformidlingFom != null ||
7777
this.aktivitetskravVurderStansUbehandlet ||
7878
this.trengerOppfolging || this.behandlerBerOmBistandUbehandlet || this.arbeidsuforhetVurderAvslagUbehandlet
7979
}
@@ -128,9 +128,6 @@ fun PersonOversiktStatus.hasActiveBehandlerdialogOppgave(): Boolean {
128128
this.behandlerdialogAvvistUbehandlet
129129
}
130130

131-
private fun PersonOversiktStatus.hasFriskmeldingTilArbeidsformidling(): Boolean =
132-
this.friskmeldingTilArbeidsformidlingFom != null && LocalDate.now().isBeforeOrEqual(this.friskmeldingTilArbeidsformidlingFom)
133-
134131
fun PersonOversiktStatus.applyHendelse(
135132
oversikthendelseType: OversikthendelseType,
136133
): PersonOversiktStatus =

‎src/main/resources/db/migration/V16_4__adjust_frisktilarbeid_index.sql

+19
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
DROP INDEX IX_PERSON_OVERSIKT_STATUS_ENHETENS_OVERSIKT;
2+
DROP INDEX IX_PERSON_OVERSIKT_FTA_FOM;
3+
4+
CREATE INDEX IX_PERSON_OVERSIKT_STATUS_ENHETENS_OVERSIKT
5+
ON PERSON_OVERSIKT_STATUS (tildelt_enhet, dialogmotekandidat_generated_at)
6+
WHERE (motebehov_ubehandlet
7+
OR oppfolgingsplan_lps_bistand_ubehandlet
8+
OR dialogmotesvar_ubehandlet
9+
OR dialogmotekandidat
10+
OR ((aktivitetskrav = 'NY' OR aktivitetskrav = 'AVVENT') AND aktivitetskrav_stoppunkt > '2023-03-10')
11+
OR behandlerdialog_svar_ubehandlet
12+
OR behandlerdialog_ubesvart_ubehandlet
13+
OR behandlerdialog_avvist_ubehandlet
14+
OR aktivitetskrav_vurder_stans_ubehandlet
15+
OR trenger_oppfolging
16+
OR behandler_bistand_ubehandlet
17+
OR arbeidsuforhet_vurder_avslag_ubehandlet
18+
OR friskmelding_til_arbeidsformidling_fom IS NOT NULL
19+
);

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

+14-7
Original file line numberDiff line numberDiff line change
@@ -589,10 +589,11 @@ object PersonoversiktStatusApiV2Spek : Spek({
589589
}
590590
it("return person with friskmelding til arbeidsformidling starting tomorrow") {
591591
val personident = PersonIdent(ARBEIDSTAKER_FNR)
592+
val tomorrow = LocalDate.now().plusDays(1)
592593
with(database) {
593594
createPersonOversiktStatus(PersonOversiktStatus(personident.value))
594595
setTildeltEnhet(personident, NAV_ENHET)
595-
setFriskmeldingTilArbeidsformidlingFom(personident, LocalDate.now().plusDays(1))
596+
setFriskmeldingTilArbeidsformidlingFom(personident, tomorrow)
596597
}
597598

598599
with(
@@ -606,15 +607,16 @@ object PersonoversiktStatusApiV2Spek : Spek({
606607
objectMapper.readValue<List<PersonOversiktStatusDTO>>(response.content!!).first()
607608
personOversiktStatus.fnr shouldBeEqualTo personident.value
608609
personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
609-
personOversiktStatus.friskmeldingTilArbeidsformidlingFom!! shouldBeAfter LocalDate.now()
610+
personOversiktStatus.friskmeldingTilArbeidsformidlingFom!! shouldBeEqualTo tomorrow
610611
}
611612
}
612613
it("return person with friskmelding til arbeidsformidling starting today") {
613614
val personident = PersonIdent(ARBEIDSTAKER_FNR)
615+
val today = LocalDate.now()
614616
with(database) {
615617
createPersonOversiktStatus(PersonOversiktStatus(personident.value))
616618
setTildeltEnhet(personident, NAV_ENHET)
617-
setFriskmeldingTilArbeidsformidlingFom(personident, LocalDate.now())
619+
setFriskmeldingTilArbeidsformidlingFom(personident, today)
618620
}
619621

620622
with(
@@ -628,22 +630,27 @@ object PersonoversiktStatusApiV2Spek : Spek({
628630
objectMapper.readValue<List<PersonOversiktStatusDTO>>(response.content!!).first()
629631
personOversiktStatus.fnr shouldBeEqualTo personident.value
630632
personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
631-
personOversiktStatus.friskmeldingTilArbeidsformidlingFom!! shouldBeEqualTo LocalDate.now()
633+
personOversiktStatus.friskmeldingTilArbeidsformidlingFom!! shouldBeEqualTo today
632634
}
633635
}
634-
it("does not return person with friskmelding til arbeidsformidling starting yesterday") {
636+
it("return person with friskmelding til arbeidsformidling starting yesterday") {
635637
val personident = PersonIdent(ARBEIDSTAKER_FNR)
638+
val yesterday = LocalDate.now().minusDays(1)
636639
with(database) {
637640
createPersonOversiktStatus(PersonOversiktStatus(personident.value))
638641
setTildeltEnhet(personident, NAV_ENHET)
639-
setFriskmeldingTilArbeidsformidlingFom(personident, LocalDate.now().minusDays(1))
642+
setFriskmeldingTilArbeidsformidlingFom(personident, yesterday)
640643
}
641644
with(
642645
handleRequest(HttpMethod.Get, url) {
643646
addHeader(HttpHeaders.Authorization, bearerHeader(validToken))
644647
}
645648
) {
646-
response.status() shouldBeEqualTo HttpStatusCode.NoContent
649+
val personOversiktStatus =
650+
objectMapper.readValue<List<PersonOversiktStatusDTO>>(response.content!!).first()
651+
personOversiktStatus.fnr shouldBeEqualTo personident.value
652+
personOversiktStatus.enhet shouldBeEqualTo behandlendeEnhetDTO().enhetId
653+
personOversiktStatus.friskmeldingTilArbeidsformidlingFom!! shouldBeEqualTo yesterday
647654
}
648655
}
649656

0 commit comments

Comments
 (0)