Merge branch 'master' into IS-2271-Possibility-to-see-arbeidsuforhet-varsel-before-expired-in-syfooversikt

Author: vetlesolgaard

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

@@ -70,7 +70,8 @@ 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 
+        OR friskmelding_til_arbeidsformidling_fom IS NOT NULL
+        OR arbeidsuforhet_aktiv_vurdering = 't'
         )
     AND (tildelt_enhet_updated_at IS NULL OR tildelt_enhet_updated_at <= NOW() - INTERVAL '24 HOURS')
     ORDER BY tildelt_enhet_updated_at ASC

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

@@ -44,6 +44,7 @@ const val queryPersonOppfolgingstilfelleVirksomhetNoVirksomhetsnavnList =
         OR behandler_bistand_ubehandlet = 't'
         OR arbeidsuforhet_vurder_avslag_ubehandlet = 't'
         OR friskmelding_til_arbeidsformidling_fom IS NOT NULL
+        OR arbeidsuforhet_aktiv_vurdering = 't'
         )
     ORDER BY PERSON_OPPFOLGINGSTILFELLE_VIRKSOMHET.created_at ASC
     LIMIT 1000

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

@@ -54,6 +54,7 @@ const val queryHentUbehandledePersonerTilknyttetEnhet = """
                             OR trenger_oppfolging = 't'
                             OR behandler_bistand_ubehandlet = 't'
                             OR arbeidsuforhet_vurder_avslag_ubehandlet = 't'
+                            OR arbeidsuforhet_aktiv_vurdering = 't'
                             OR friskmelding_til_arbeidsformidling_fom IS NOT NULL
                             )
                         );

src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/ArbeidsuforhetVurderingConsumer.kt

@@ -26,7 +26,7 @@ class ArbeidsuforhetVurderingConsumer(
     override fun pollAndProcessRecords(kafkaConsumer: KafkaConsumer<String, ArbeidsuforhetVurderingRecord>) {
         val records = kafkaConsumer.poll(Duration.ofMillis(pollDurationInMillis))
         if (records.count() > 0) {
-            LOGGER.info("ArbeidsuforhetVurderingConsumer trace: Received ${records.count()} records")
+            log.info("ArbeidsuforhetVurderingConsumer trace: Received ${records.count()} records")
             processRecords(records = records)
             kafkaConsumer.commitSync()
         }
@@ -59,7 +59,7 @@ class ArbeidsuforhetVurderingConsumer(
 
     companion object {
         private const val ARBEIDSUFORHET_VURDERING_TOPIC = "teamsykefravr.arbeidsuforhet-vurdering"
-        private val LOGGER: Logger = LoggerFactory.getLogger(this::class.java)
+        private val log: Logger = LoggerFactory.getLogger(this::class.java)
     }
 }