Behandle automatisk inntekt task

src/main/kotlin/no/nav/familie/ef/sak/behandling/revurdering/AutomatiskRevurderingController.kt

@@ -35,5 +35,5 @@ class AutomatiskRevurderingController(
 
 data class AutomatiskRevurdering(
     val personIdent: String,
-    val automatiskRevurdert: Boolean,
+    val kanAutomatiskRevurderes: Boolean,
 )

src/main/kotlin/no/nav/familie/ef/sak/behandling/revurdering/BehandleAutomatiskInntektsendringTask.kt

@@ -0,0 +1,86 @@
+package no.nav.familie.ef.sak.behandling.revurdering
+
+import no.nav.familie.ef.sak.behandling.BehandlingService
+import no.nav.familie.ef.sak.behandling.domain.BehandlingType
+import no.nav.familie.ef.sak.fagsak.FagsakService
+import no.nav.familie.ef.sak.fagsak.domain.Fagsak
+import no.nav.familie.ef.sak.infrastruktur.config.ObjectMapperProvider.objectMapper
+import no.nav.familie.ef.sak.infrastruktur.featuretoggle.FeatureToggleService
+import no.nav.familie.ef.sak.infrastruktur.featuretoggle.Toggle
+import no.nav.familie.kontrakter.ef.felles.BehandlingÅrsak
+import no.nav.familie.kontrakter.felles.ef.StønadType
+import no.nav.familie.prosessering.AsyncTaskStep
+import no.nav.familie.prosessering.TaskStepBeskrivelse
+import no.nav.familie.prosessering.domene.Task
+import org.slf4j.LoggerFactory
+import org.springframework.stereotype.Service
+import java.util.Properties
+
+data class PayloadBehandleAutomatiskInntektsendringTask(
+    val personIdent: String,
+    val ukeÅr: String,
+)
+
+@Service
+@TaskStepBeskrivelse(
+    taskStepType = BehandleAutomatiskInntektsendringTask.TYPE,
+    beskrivelse = "Skal automatisk opprette en ny behandling ved automatisk inntektsendring",
+)
+class BehandleAutomatiskInntektsendringTask(
+    private val behandlingService: BehandlingService,
+    private val fagsakService: FagsakService,
+    private val featureToggleService: FeatureToggleService,
+) : AsyncTaskStep {
+    private val secureLogger = LoggerFactory.getLogger("secureLogger")
+
+    override fun doTask(task: Task) {
+        val toggle = featureToggleService.isEnabled(Toggle.BEHANDLE_AUTOMATISK_INNTEKTSENDRING)
+
+        val personIdent = task.payload
+        val fagsak =
+            fagsakService.finnFagsak(
+                personIdenter = setOf(personIdent),
+                stønadstype = StønadType.OVERGANGSSTØNAD,
+            )
+
+        loggInfoOpprett(personIdent, fagsak)
+
+        if (toggle) {
+            if (fagsak != null) {
+                loggInfoOpprett(personIdent, fagsak)
+
+                behandlingService.opprettBehandling(
+                    behandlingType = BehandlingType.REVURDERING,
+                    fagsakId = fagsak.id,
+                    behandlingsårsak = BehandlingÅrsak.AUTOMATISK_INNTEKTSENDRING,
+                )
+            } else {
+                secureLogger.error("Finner ikke fagsak for personIdent=$personIdent på stønadstype=${StønadType.OVERGANGSSTØNAD} under automatisk inntektsendring")
+            }
+        }
+    }
+
+    companion object {
+        const val TYPE = "behandleAutomatiskInntektsendringTask"
+
+        fun opprettTask(payload: String): Task {
+            val payloadObject = objectMapper.readValue(payload, PayloadBehandleAutomatiskInntektsendringTask::class.java)
+
+            return Task(
+                type = TYPE,
+                payload = payload,
+                properties =
+                    Properties().apply {
+                        this["personIdent"] = payloadObject.personIdent
+                    },
+            )
+        }
+    }
+
+    fun loggInfoOpprett(
+        personIdent: String,
+        fagsak: Fagsak?,
+    ) {
+        secureLogger.info("Kan opprette behandling med $personIdent stønadstype=${StønadType.OVERGANGSSTØNAD} faksakId ${fagsak?.id}")
+    }
+}

src/main/kotlin/no/nav/familie/ef/sak/behandling/revurdering/RevurderingController.kt

@@ -81,4 +81,11 @@ class RevurderingController(
         tilgangService.validerTilgangTilBehandling(behandlingId, AuditLoggerEvent.ACCESS)
         return Ressurs.success(revurderingService.hentRevurderingsinformasjon(behandlingId))
     }
+
+    @PostMapping("opprett-automatisk")
+    fun opprettAutomatiskInntektsendringsTask(
+        @RequestBody personIdenter: List<String>,
+    ) {
+        revurderingService.opprettAutomatiskInntektsendringTask(personIdenter)
+    }
 }

src/main/kotlin/no/nav/familie/ef/sak/behandling/revurdering/RevurderingService.kt

@@ -28,9 +28,13 @@ import no.nav.familie.ef.sak.vedtak.VedtakService
 import no.nav.familie.ef.sak.vilkår.VurderingService
 import no.nav.familie.kontrakter.ef.felles.BehandlingÅrsak
 import no.nav.familie.kontrakter.felles.ef.StønadType
+import no.nav.familie.kontrakter.felles.objectMapper
+import no.nav.familie.leader.LeaderClient
 import no.nav.familie.prosessering.internal.TaskService
 import org.springframework.stereotype.Service
 import org.springframework.transaction.annotation.Transactional
+import java.time.LocalDate
+import java.time.temporal.IsoFields
 import java.util.UUID
 
 @Service
@@ -142,6 +146,26 @@ class RevurderingService(
         return revurdering
     }
 
+    @Transactional
+    fun opprettAutomatiskInntektsendringTask(personIdenter: List<String>) {
+        if (LeaderClient.isLeader() != true) {
+            return
+        }
+
+        val ukeÅr = LocalDate.now().let { "${it.get(IsoFields.WEEK_OF_WEEK_BASED_YEAR)}-${it.year}" }
+
+        personIdenter.forEach { personIdent ->
+
+            val payload = objectMapper.writeValueAsString(PayloadBehandleAutomatiskInntektsendringTask(personIdent = personIdent, ukeÅr = ukeÅr))
+            val finnesTask = taskService.finnTaskMedPayloadOgType(payload, BehandleAutomatiskInntektsendringTask.TYPE)
+
+            if (finnesTask == null) {
+                val task = BehandleAutomatiskInntektsendringTask.opprettTask(payload)
+                taskService.save(task)
+            }
+        }
+    }
+
     private fun vilkårsbehandleNyeBarn(
         revurdering: Behandling,
         vilkårsbehandleNyeBarn: VilkårsbehandleNyeBarn,

src/main/kotlin/no/nav/familie/ef/sak/infrastruktur/featuretoggle/FeatureToggleController.kt

@@ -25,6 +25,7 @@ class FeatureToggleController(
             Toggle.VELG_ÅRSAK_VED_KLAGE_OPPRETTELSE,
             Toggle.FRONTEND_VIS_MARKERE_GODKJENNE_OPPGAVE_MODAL,
             Toggle.VIS_AUTOMATISK_INNTEKTSENDRING,
+            Toggle.BEHANDLE_AUTOMATISK_INNTEKTSENDRING,
         )
 
     @GetMapping

src/main/kotlin/no/nav/familie/ef/sak/infrastruktur/featuretoggle/FeatureToggleService.kt

@@ -19,6 +19,7 @@ enum class Toggle(
         "Release",
     ),
     KONTROLLER_NÆRINGSINNTEKT("familie.ef.sak.kontroller-naeringsinntekt"),
+    BEHANDLE_AUTOMATISK_INNTEKTSENDRING("familie.ef.sak-behandle-automatisk-inntektsendring-task", "Release"),
 
     // Operational
     G_BEREGNING("familie.ef.sak.g-beregning", "Operational"),

src/main/kotlin/no/nav/familie/ef/sak/vedtak/VedtakController.kt

@@ -238,6 +238,7 @@ class VedtakController(
         for (personIdent in personIdentToBehandlingIds.keys) {
             val behandlingId = personIdentToBehandlingIds[personIdent]
             val forventetInntektForBehandling = behandlingIdToForventetInntektMap[behandlingId]
+            secureLogger.info("PersonIdent: $personIdent ForventetInntektForBehandling: $forventetInntektForBehandling")
             if (forventetInntektForBehandling == null) {
                 secureLogger.warn("Fant ikke behandling $behandlingId knyttet til ident $personIdent - får ikke vurdert inntekt")
             } else {