TFP-6044 journalpost sikkerhetsnett

domene/src/main/java/no/nav/foreldrepenger/mottak/behandlendeenhet/EnhetsTjeneste.java

@@ -33,7 +33,7 @@ public String hentFordelingEnhetId(Optional<String> enhetInput, String aktørId)
     }
 
     public static String enhetEllerNasjonalEnhet(String enhet) {
-        return SPESIALENHETER.contains(enhet) ? enhet : NASJONAL_ENHET_ID;
+        return enhet != null && SPESIALENHETER.contains(enhet) ? enhet : NASJONAL_ENHET_ID;
     }
 
     private String hentEnhetId(String aktørId) {

domene/src/main/java/no/nav/foreldrepenger/mottak/task/SikkerhetsnettTask.java

@@ -0,0 +1,68 @@
+package no.nav.foreldrepenger.mottak.task;
+
+import java.util.stream.Collectors;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import jakarta.enterprise.context.Dependent;
+import jakarta.inject.Inject;
+import no.nav.foreldrepenger.journalføring.domene.JournalpostId;
+import no.nav.foreldrepenger.journalføring.oppgave.Journalføringsoppgave;
+import no.nav.foreldrepenger.journalføring.oppgave.domene.NyOppgave;
+import no.nav.foreldrepenger.journalføring.oppgave.lager.AktørId;
+import no.nav.foreldrepenger.mottak.behandlendeenhet.EnhetsTjeneste;
+import no.nav.foreldrepenger.mottak.journal.ArkivTjeneste;
+import no.nav.foreldrepenger.mottak.task.sikkerhetsnett.SikkerhetsnettKlient;
+import no.nav.foreldrepenger.mottak.task.sikkerhetsnett.SikkerhetsnettResponse;
+import no.nav.vedtak.felles.prosesstask.api.ProsessTask;
+import no.nav.vedtak.felles.prosesstask.api.ProsessTaskData;
+import no.nav.vedtak.felles.prosesstask.api.ProsessTaskHandler;
+
+@Dependent
+@ProsessTask(value = "vedlikehold.tasks.sikkerhetsnett", cronExpression = "0 29 6 * * *", maxFailedRuns = 1) // Endre siste asterisk til WED
+public class SikkerhetsnettTask implements ProsessTaskHandler {
+
+    private static final Logger LOG = LoggerFactory.getLogger(SikkerhetsnettTask.class);
+
+    private final ArkivTjeneste arkivTjeneste;
+    private final EnhetsTjeneste enhetsTjeneste;
+    private final Journalføringsoppgave journalføringsoppgave;
+    private final SikkerhetsnettKlient sikkerhetsnettKlient;
+
+    @Inject
+    public SikkerhetsnettTask(ArkivTjeneste arkivTjeneste,
+                              EnhetsTjeneste enhetsTjeneste,
+                              Journalføringsoppgave journalføringsoppgave,
+                              SikkerhetsnettKlient sikkerhetsnettKlient) {
+        this.arkivTjeneste = arkivTjeneste;
+        this.enhetsTjeneste = enhetsTjeneste;
+        this.journalføringsoppgave = journalføringsoppgave;
+        this.sikkerhetsnettKlient = sikkerhetsnettKlient;
+    }
+
+    @Override
+    public void doTask(ProsessTaskData prosessTaskData) {
+        var åpneJournalposterUtenOppgave = sikkerhetsnettKlient.hentÅpneJournalposterEldreEnn(7).stream()
+            .filter(jp -> jp.mottaksKanal() == null || !"EESSI".equals(jp.mottaksKanal()))
+            .filter(jp -> !journalføringsoppgave.finnesÅpeneJournalføringsoppgaverFor(JournalpostId.fra(jp.journalpostId())))
+            .toList();
+        LOG.info("FPFORDEL SIKKERHETSNETT fant {} journalposter uten oppgave. {}", åpneJournalposterUtenOppgave.size(),
+            åpneJournalposterUtenOppgave.stream().map(SikkerhetsnettResponse::journalpostId).collect(Collectors.joining(",")));
+        åpneJournalposterUtenOppgave.forEach(this::opprettOppgave);
+    }
+
+    private void opprettOppgave(SikkerhetsnettResponse jp) {
+        var journalpostId = JournalpostId.fra(jp.journalpostId());
+        var journalpost = arkivTjeneste.hentArkivJournalpost(journalpostId.getVerdi());
+        var aktørId = journalpost.getBrukerAktørId().map(AktørId::new).orElse(null);
+        var aktørIdString = journalpost.getBrukerAktørId().orElse(null);
+        var enhet = enhetsTjeneste.hentFordelingEnhetId(journalpost.getJournalfoerendeEnhet(), aktørIdString);
+        var nyoppgave = new NyOppgave(journalpostId, enhet, aktørId, null, journalpost.getBehandlingstema(), "Journalføring");
+        if (EnhetsTjeneste.NK_ENHET_ID.equals(enhet)) {
+            journalføringsoppgave.opprettGosysJournalføringsoppgaveFor(nyoppgave);
+        } else {
+            journalføringsoppgave.opprettJournalføringsoppgaveFor(nyoppgave);
+        }
+    }
+}

domene/src/main/java/no/nav/foreldrepenger/mottak/task/sikkerhetsnett/SikkerhetsnettKlient.java

@@ -0,0 +1,44 @@
+package no.nav.foreldrepenger.mottak.task.sikkerhetsnett;
+
+import java.util.List;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import jakarta.enterprise.context.Dependent;
+import jakarta.ws.rs.core.UriBuilder;
+import no.nav.foreldrepenger.fordel.kodeverdi.Tema;
+import no.nav.vedtak.felles.integrasjon.rest.RestClient;
+import no.nav.vedtak.felles.integrasjon.rest.RestClientConfig;
+import no.nav.vedtak.felles.integrasjon.rest.RestConfig;
+import no.nav.vedtak.felles.integrasjon.rest.RestRequest;
+import no.nav.vedtak.felles.integrasjon.rest.TokenFlow;
+
+@Dependent
+@RestClientConfig(tokenConfig = TokenFlow.ADAPTIVE, endpointProperty = "sikkerhetsnett.url",
+    endpointDefault = "http://dokarkiv.teamdokumenthandtering/rest/journalpostapi/v1/finnMottatteJournalposter",
+    scopesProperty = "dokarkiv.scopes", scopesDefault = "api://prod-fss.teamdokumenthandtering.dokarkiv/.default")
+public class SikkerhetsnettKlient {
+
+    private final RestClient restKlient;
+    private final RestConfig restConfig;
+
+    protected SikkerhetsnettKlient() {
+        this(RestClient.client());
+    }
+
+    protected SikkerhetsnettKlient(RestClient client) {
+        this.restKlient = client;
+        this.restConfig = RestConfig.forClient(this.getClass());
+    }
+
+
+    public List<SikkerhetsnettResponse> hentÅpneJournalposterEldreEnn(int antallDagerGamle) {
+        var opprett = UriBuilder.fromUri(restConfig.endpoint())
+            .queryParam("tema", Tema.FORELDRE_OG_SVANGERSKAPSPENGER.getOffisiellKode())
+            .queryParam("antallDagerGamle", String.valueOf(antallDagerGamle))
+            .build();
+        var restRequest = RestRequest.newGET(opprett, restConfig);
+        return restKlient.sendReturnList(restRequest, SikkerhetsnettResponse.class);
+    }
+}

domene/src/main/java/no/nav/foreldrepenger/mottak/task/sikkerhetsnett/SikkerhetsnettResponse.java

@@ -0,0 +1,8 @@
+package no.nav.foreldrepenger.mottak.task.sikkerhetsnett;
+
+public record SikkerhetsnettResponse(String journalpostId,
+                                     String mottaksKanal,
+                                     String behandlingstema,
+                                     String journalforendeEnhet) {
+
+}

web/src/main/resources/application.properties

@@ -23,3 +23,4 @@ oppgave.rs.uri=http://oppgave.oppgavehandtering/api/v1/oppgaver
 saf.base.url=http://saf.teamdokumenthandtering
 # Klienter (lokal)
 dokarkiv.base.url=http://dokarkiv.teamdokumenthandtering/rest/journalpostapi/v1/journalpost
+sikkerhetsnett.url=http://dokarkiv.teamdokumenthandteringrest/journalpostapi/v1/finnMottatteJournalposter

web/src/test/resources/application-vtp.properties

@@ -4,6 +4,7 @@ server.port=8090
 oppgave.rs.uri=https://localhost:8063/rest/oppgave/api/v1/oppgaver
 oppgave.scopes=testscope
 dokarkiv.base.url=https://localhost:8063/rest/dokarkiv/rest/journalpostapi/v1/journalpost
+sikkerhetsnett.url=https://localhost:8063/rest/dokarkiv/rest/journalpostapi/v1/finnMottatteJournalposter
 dokarkiv.scopes=testscope
 saf.base.url=https://localhost:8063/rest/api/saf
 saf.scopes=testscope