Merge branch 'master' into g-omregningsjekk-filtrer-vekk-de-med-total…

…-samordning-og-spesialtilfeller

src/main/kotlin/no/nav/familie/ef/sak/fagsak/FagsakPersonService.kt

@@ -31,7 +31,7 @@ class FagsakPersonService(private val fagsakPersonRepository: FagsakPersonReposi
         feilHvisIkke(personIdenter.contains(gjeldendePersonIdent)) {
             "Liste med personidenter inneholder ikke gjeldende personident"
         }
-        return (
+        return ( // TODO : Lag task som sender over til minside kafka-kø (ved insert)
             fagsakPersonRepository.findByIdent(personIdenter)
                 ?: fagsakPersonRepository.insert(FagsakPerson(identer = setOf(PersonIdent(gjeldendePersonIdent))))
             )
@@ -41,6 +41,7 @@ class FagsakPersonService(private val fagsakPersonRepository: FagsakPersonReposi
     fun oppdaterIdent(fagsakPerson: FagsakPerson, gjeldendePersonIdent: String): FagsakPerson {
         return if (fagsakPerson.hentAktivIdent() != gjeldendePersonIdent) {
             fagsakPersonRepository.update(fagsakPerson.medOppdatertGjeldendeIdent(gjeldendePersonIdent))
+            // TODO : Lag task som sender over til minside kafka-kø
         } else {
             fagsakPerson
         }

src/main/kotlin/no/nav/familie/ef/sak/forvaltning/MinsideForvaltningsController.kt

@@ -1,11 +1,14 @@
 package no.nav.familie.ef.sak.forvaltning
 
+import no.nav.familie.ef.sak.fagsak.FagsakPersonRepository
 import no.nav.familie.ef.sak.felles.dto.PersonIdentDto
 import no.nav.familie.ef.sak.infrastruktur.exception.feilHvisIkke
 import no.nav.familie.ef.sak.infrastruktur.featuretoggle.FeatureToggleService
 import no.nav.familie.ef.sak.infrastruktur.featuretoggle.Toggle
 import no.nav.familie.ef.sak.infrastruktur.sikkerhet.SikkerhetContext
+import no.nav.familie.ef.sak.minside.MikrofrontendEnableBrukereTask
 import no.nav.familie.ef.sak.minside.MinSideKafkaProducerService
+import no.nav.familie.prosessering.internal.TaskService
 import no.nav.security.token.support.core.api.ProtectedWithClaims
 import org.springframework.web.bind.annotation.PostMapping
 import org.springframework.web.bind.annotation.RequestBody
@@ -18,6 +21,8 @@ import org.springframework.web.bind.annotation.RestController
 class MinsideForvaltningsController(
     private val featureToggleService: FeatureToggleService,
     private val minSideKafkaProducerService: MinSideKafkaProducerService,
+    private val fagsakPersonRepository: FagsakPersonRepository,
+    private val taskService: TaskService,
 ) {
     @PostMapping("aktiver")
     fun aktiverPersonForMinSide(@RequestBody personIdentDto: PersonIdentDto) {
@@ -33,6 +38,16 @@ class MinsideForvaltningsController(
         minSideKafkaProducerService.deaktiver(personIdent = personIdentDto.personIdent)
     }
 
+    @PostMapping("aktiver-alle")
+    fun aktiverAllePersonerForMinSide() {
+        feilHvisIkke(erUtviklerMedVeilderrolle()) { "Kan kun kjøres av utvikler med veilederrolle" }
+        fagsakPersonRepository.findAll().chunked(500)
+            .forEach { fagsakPersoner ->
+                val task = MikrofrontendEnableBrukereTask.opprettTask(fagsakPersoner)
+                taskService.save(task)
+            }
+    }
+
     private fun validerPersonIdent(personIdentDto: PersonIdentDto) {
         if (personIdentDto.personIdent.length != 11) {
             error("PersonIdent må ha 11 siffer")

src/main/kotlin/no/nav/familie/ef/sak/minside/MikrofrontendEnableBrukereTask.kt

@@ -0,0 +1,39 @@
+package no.nav.familie.ef.sak.minside
+
+import com.fasterxml.jackson.module.kotlin.readValue
+import no.nav.familie.ef.sak.fagsak.domain.FagsakPerson
+import no.nav.familie.kontrakter.felles.objectMapper
+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
+
+@Service
+@TaskStepBeskrivelse(
+    taskStepType = MikrofrontendEnableBrukereTask.TYPE,
+    beskrivelse = "Sender over liste av personer til minside kafka-kø",
+)
+class MikrofrontendEnableBrukereTask(val minSideKafkaProducerService: MinSideKafkaProducerService) : AsyncTaskStep {
+
+    private val logger = LoggerFactory.getLogger(this::class.java)
+
+    override fun doTask(task: Task) {
+        logger.info("Starter task for aktivering av brukere for mikrofrontend")
+        val fagsakPersonIdenter = objectMapper.readValue<List<FagsakPerson>>(task.payload)
+        fagsakPersonIdenter.forEach { fagsakPerson ->
+            minSideKafkaProducerService.aktiver(fagsakPerson.hentAktivIdent())
+        }
+    }
+
+    companion object {
+
+        fun opprettTask(fagsakPerson: List<FagsakPerson>): Task {
+            return Task(
+                type = TYPE,
+                payload = objectMapper.writeValueAsString(fagsakPerson),
+            )
+        }
+        const val TYPE = "mikrofrontendEnableBrukereTask"
+    }
+}