Tar i mot innsending for innrapportering av inntekt og oppretter task for lagring i abakus (#149)

* Tar i mot innsending for innrapportering av inntekt og oppretter task for lagring i abakus

* Fikser tester

* ung-sak.openapi.json updated by build pipeline 


skip-checks:true

* Bruker riktig behandlingsårsak

---------

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>

Author: espenjv

behandlingsprosess/src/main/java/no/nav/ung/sak/domene/behandling/steg/iverksettevedtak/HenleggBehandlingTjeneste.java

@@ -132,10 +132,6 @@ private void henleggDokumenter(Behandling behandling) {
 
         Set<Brevkode> kravdokumentTyper = new HashSet<>(Brevkode.SØKNAD_TYPER);
 
-        if (Objects.equals(behandling.getFagsakYtelseType(), FagsakYtelseType.OMP)) {
-            kravdokumentTyper.addAll(List.of(Brevkode.INNTEKTSMELDING, Brevkode.FRAVÆRSKORRIGERING_IM_OMS));
-        }
-
         List<MottattDokument> gyldigeDokumenterFagsak = mottatteDokumentRepository.hentGyldigeDokumenterMedFagsakId(behandling.getFagsakId());
         List<MottattDokument> gyldigeKravdokumenterBehandling = gyldigeDokumenterFagsak.stream()
             .filter(dok -> behandling.getId().equals(dok.getBehandlingId()))

domenetjenester/dokumentarkiv/src/test/java/no/nav/ung/sak/dokument/arkiv/DokumentArkivTjenesteImplTest.java

@@ -132,9 +132,9 @@ public void skalRetunereDokumenterAvFiltypePDF() {
     }
 
     @Test
-    public void skalRetunereDokumenttypeInntektsmelding() {
+    public void skalRetunereDokumenttypeInntektsrapportering() {
         Journalpost journalpost = byggJournalpostMedFlereDokumenter(List.of(
-            byggDokumentInfo(ArkivFilType.PDF, Variantformat.ARKIV, Brevkode.INNTEKTSMELDING),
+            byggDokumentInfo(ArkivFilType.PDF, Variantformat.ARKIV, Brevkode.UNGDOMSYTELSE_INNTEKTRAPPORTERING),
             byggDokumentInfo(ArkivFilType.PDF, Variantformat.ARKIV, Brevkode.UDEFINERT)
         ));
         Dokumentoversikt dokumentoversikt = new Dokumentoversikt(List.of(journalpost), null);

domenetjenester/mottak/pom.xml

@@ -40,10 +40,6 @@
             <groupId>no.nav.ung.sak</groupId>
             <artifactId>behandlingskontroll</artifactId>
         </dependency>
-        <dependency>
-            <groupId>no.nav.k9</groupId>
-            <artifactId>inntektsmelding-v1</artifactId>
-        </dependency>
         <dependency>
             <groupId>no.nav.k9</groupId>
             <artifactId>ettersendelse</artifactId>
@@ -52,15 +48,7 @@
             <groupId>no.nav.ung.sak</groupId>
             <artifactId>innsyn</artifactId>
         </dependency>
-        <!-- JAXB for å parse Inntektsmelding -->
-        <dependency>
-            <groupId>jakarta.xml.bind</groupId>
-            <artifactId>jakarta.xml.bind-api</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>org.glassfish.jaxb</groupId>
-            <artifactId>jaxb-runtime</artifactId>
-        </dependency>
+
 
         <!-- Test avhengigheter -->
         <dependency>

domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/DokumentMottakerSøknadUng.java

@@ -48,7 +48,7 @@ public void lagreDokumentinnhold(Collection<MottattDokument> mottattDokument, Be
             }
             Ungdomsytelse ytelse = søknad.getYtelse();
             ungdomsytelseSøknadPersisterer.lagreSøknadEntitet(søknad, dokument.getJournalpostId(), behandlingId, Optional.of(ytelse.getSøknadsperiode()), dokument.getMottattDato());
-            ungdomsytelseSøknadPersisterer.lagreSøknadsperioder(ytelse.getSøknadsperiodeList(), dokument.getJournalpostId(), behandlingId);
+            ungdomsytelseSøknadPersisterer.lagreSøknadsperioder(ytelse.getStartdatoer(), dokument.getJournalpostId(), behandlingId);
             ungdomsytelseSøknadPersisterer.oppdaterFagsakperiode(ytelse.getSøknadsperiode().getFraOgMed(), behandling);
 
         }

domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/DokumentmottakerFelles.java

@@ -1,21 +1,8 @@
 package no.nav.ung.sak.mottak.dokumentmottak;
 
-import java.util.ArrayList;
-import java.util.List;
-
 import jakarta.enterprise.context.Dependent;
 import jakarta.inject.Inject;
-import no.nav.k9.felles.integrasjon.saf.AvsenderMottakerResponseProjection;
-import no.nav.k9.felles.integrasjon.saf.BrukerResponseProjection;
-import no.nav.k9.felles.integrasjon.saf.DokumentInfo;
-import no.nav.k9.felles.integrasjon.saf.DokumentInfoResponseProjection;
-import no.nav.k9.felles.integrasjon.saf.DokumentvariantResponseProjection;
-import no.nav.k9.felles.integrasjon.saf.Journalpost;
-import no.nav.k9.felles.integrasjon.saf.JournalpostQueryRequest;
-import no.nav.k9.felles.integrasjon.saf.JournalpostResponseProjection;
-import no.nav.k9.felles.integrasjon.saf.RelevantDatoResponseProjection;
-import no.nav.k9.felles.integrasjon.saf.SafTjeneste;
-import no.nav.k9.felles.integrasjon.saf.SakResponseProjection;
+import no.nav.k9.felles.integrasjon.saf.*;
 import no.nav.ung.kodeverk.behandling.BehandlingÅrsakType;
 import no.nav.ung.kodeverk.dokument.Brevkode;
 import no.nav.ung.kodeverk.historikk.HistorikkAktør;
@@ -27,13 +14,16 @@
 import no.nav.ung.sak.historikk.HistorikkInnslagTekstBuilder;
 import no.nav.ung.sak.typer.JournalpostId;
 
+import java.util.ArrayList;
+import java.util.List;
+
 @Dependent
 public class HistorikkinnslagTjeneste {
 
     private static final String VEDLEGG = "Vedlegg";
     private static final String SØKNAD = "Søknad";
     private static final String INNSENDING = "Innsending";
-    private static final String INNTEKTSMELDING = "Inntektsmelding";
+    private static final String INNTEKTSRAPPORTERING = "Inntektsrapportering";
     private HistorikkRepository historikkRepository;
     private SafTjeneste safTjeneste;
 
@@ -114,8 +104,8 @@ private String finnLinkTekstHoveddokument(DokumentInfo hoveddokumentJournalMetad
         if (brevkode == null) {
             return INNSENDING;
         }
-        if (brevkode.equals(Brevkode.INNTEKTSMELDING)) {
-            return INNTEKTSMELDING;
+        if (brevkode.equals(Brevkode.UNGDOMSYTELSE_INNTEKTRAPPORTERING)) {
+            return INNTEKTSRAPPORTERING;
         }
         if (Brevkode.SØKNAD_TYPER.contains(brevkode)) {
             return SØKNAD;
@@ -132,13 +122,9 @@ private HistorikkinnslagDokumentLink lagHistorikkInnslagDokumentLink(DokumentInf
         return historikkinnslagDokumentLink;
     }
 
-    public void opprettHistorikkinnslagForVedlegg(Long fagsakId, JournalpostId journalpostId, Brevkode dokumentTypeId) {
+    public void opprettHistorikkinnslagForVedlegg(Long fagsakId, JournalpostId journalpostId) {
         Historikkinnslag historikkinnslag = new Historikkinnslag();
-        if (dokumentTypeId != null && dokumentTypeId.equals(Brevkode.INNTEKTSMELDING)) {
-            historikkinnslag.setAktør(HistorikkAktør.ARBEIDSGIVER);
-        } else {
-            historikkinnslag.setAktør(HistorikkAktør.SØKER);
-        }
+        historikkinnslag.setAktør(HistorikkAktør.SØKER);
         historikkinnslag.setType(HistorikkinnslagType.VEDLEGG_MOTTATT);
         historikkinnslag.setFagsakId(fagsakId);
 
@@ -168,36 +154,36 @@ public void opprettHistorikkinnslagForBehandlingOppdatertMedNyeOpplysninger(Beha
 
     private JournalpostResponseProjection byggDokumentoversiktResponseProjection() {
         return new JournalpostResponseProjection()
-                .journalpostId()
+            .journalpostId()
+            .tittel()
+            .journalposttype()
+            .journalstatus()
+            .kanal()
+            .tema()
+            .behandlingstema()
+            .sak(new SakResponseProjection()
+                .fagsaksystem()
+                .fagsakId())
+            .bruker(new BrukerResponseProjection()
+                .id()
+                .type())
+            .avsenderMottaker(new AvsenderMottakerResponseProjection()
+                .id()
+                .type()
+                .navn())
+            .dokumenter(new DokumentInfoResponseProjection()
+                .dokumentInfoId()
                 .tittel()
-                .journalposttype()
-                .journalstatus()
-                .kanal()
-                .tema()
-                .behandlingstema()
-                .sak(new SakResponseProjection()
-                    .fagsaksystem()
-                    .fagsakId())
-                .bruker(new BrukerResponseProjection()
-                    .id()
-                    .type())
-                .avsenderMottaker(new AvsenderMottakerResponseProjection()
-                    .id()
-                    .type()
-                    .navn())
-                .dokumenter(new DokumentInfoResponseProjection()
-                    .dokumentInfoId()
-                    .tittel()
-                    .brevkode()
-                    .dokumentvarianter(new DokumentvariantResponseProjection()
-                        .variantformat()
-                        .filnavn()
-                        .filtype()
-                        .saksbehandlerHarTilgang()
-                    ))
-                .relevanteDatoer(new RelevantDatoResponseProjection()
-                    .dato()
-                    .datotype()
-                );
+                .brevkode()
+                .dokumentvarianter(new DokumentvariantResponseProjection()
+                    .variantformat()
+                    .filnavn()
+                    .filtype()
+                    .saksbehandlerHarTilgang()
+                ))
+            .relevanteDatoer(new RelevantDatoResponseProjection()
+                .dato()
+                .datotype()
+            );
     }
 }

domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/EttersendelseDokumentValidator.java

@@ -9,6 +9,8 @@
 import java.util.Set;
 import java.util.stream.Collectors;
 
+import no.nav.k9.søknad.ytelse.ung.v1.UngSøknadstype;
+import no.nav.ung.sak.behandling.prosessering.task.StartBehandlingTask;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -48,7 +50,6 @@ public class InnhentDokumentTjeneste {
 
     private final Instance<Dokumentmottaker> mottakere;
     private final Behandlingsoppretter behandlingsoppretter;
-    private final DokumentmottakerFelles dokumentMottakerFelles;
     private final BehandlingRevurderingRepository revurderingRepository;
     private final BehandlingRepository behandlingRepository;
     private final BehandlingLåsRepository behandlingLåsRepository;
@@ -59,14 +60,12 @@ public class InnhentDokumentTjeneste {
 
     @Inject
     public InnhentDokumentTjeneste(@Any Instance<Dokumentmottaker> mottakere,
-                                   DokumentmottakerFelles dokumentMottakerFelles,
                                    Behandlingsoppretter behandlingsoppretter,
                                    BehandlingRepositoryProvider repositoryProvider,
                                    BehandlingProsesseringTjeneste behandlingProsesseringTjeneste,
                                    ProsessTaskTjeneste prosessTaskTjeneste,
                                    FagsakProsessTaskRepository fagsakProsessTaskRepository) {
         this.mottakere = mottakere;
-        this.dokumentMottakerFelles = dokumentMottakerFelles;
         this.behandlingsoppretter = behandlingsoppretter;
         this.behandlingRepository = repositoryProvider.getBehandlingRepository();
         this.revurderingRepository = repositoryProvider.getBehandlingRevurderingRepository();
@@ -164,7 +163,15 @@ public void lagreDokumenter(Map<Brevkode, List<MottattDokument>> mottattDokument
     }
 
     private ProsessTaskData asynkStartBehandling(Behandling behandling) {
-        return dokumentMottakerFelles.opprettTaskForÅStarteBehandling(behandling);
+        return opprettTaskForÅStarteBehandling(behandling);
+    }
+
+
+    private ProsessTaskData opprettTaskForÅStarteBehandling(Behandling behandling) {
+        ProsessTaskData prosessTaskData =  ProsessTaskData.forProsessTask(StartBehandlingTask.class);
+        prosessTaskData.setBehandling(behandling.getFagsakId(), behandling.getId(), behandling.getAktørId().getId());
+        prosessTaskData.setCallIdFraEksisterende();
+        return prosessTaskData;
     }
 
     private Boolean erBehandlingAvsluttet(Optional<Behandling> sisteYtelsesbehandling) {

domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/HistorikkinnslagTjeneste.java

@@ -1,14 +1,11 @@
 package no.nav.ung.sak.mottak.dokumentmottak;
 
-import java.util.Collection;
-import java.util.Objects;
-import java.util.stream.Collectors;
-
 import jakarta.enterprise.context.Dependent;
-
-import no.nav.ung.sak.behandlingslager.behandling.motattdokument.MottattDokument;
 import no.nav.k9.søknad.JsonUtils;
 import no.nav.k9.søknad.Søknad;
+import no.nav.ung.sak.behandlingslager.behandling.motattdokument.MottattDokument;
+
+import java.util.Objects;
 
 @Dependent
 public class SøknadParser {
@@ -22,10 +19,4 @@ public class SøknadParser {
             throw new DokumentValideringException("Parsefeil i søknad", e);
         }
     }
-
-    public Collection<Søknad> parseSøknader(Collection<MottattDokument> mottatteDokumenter) {
-        return mottatteDokumenter.stream()
-            .map(this::parseSøknad)
-            .collect(Collectors.toList());
-    }
 }

domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/InnhentDokumentTjeneste.java

@@ -1,13 +1,13 @@
 package no.nav.ung.sak.mottak.dokumentmottak;
 
-import java.util.Collection;
-import java.util.Objects;
-
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
+import no.nav.k9.søknad.ytelse.ung.v1.UngdomsytelseSøknadValidator;
 import no.nav.ung.kodeverk.dokument.Brevkode;
 import no.nav.ung.sak.behandlingslager.behandling.motattdokument.MottattDokument;
-import no.nav.k9.søknad.ytelse.ung.v1.UngdomsytelseSøknadValidator;
+
+import java.util.Collection;
+import java.util.Objects;
 
 @ApplicationScoped
 @DokumentGruppeRef(Brevkode.UNGDOMSYTELSE_SOKNAD_KODE)

domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/SøknadParser.java

@@ -56,10 +56,10 @@ public class UngdomsytelseSøknadPersisterer {
         søknadRepository.lagreOgFlush(behandlingId, søknadEntitet);
     }
 
-    public void lagreSøknadsperioder(List<Periode> søknadsperioder, JournalpostId journalpostId, Long behandlingId) {
+    public void lagreSøknadsperioder(List<LocalDate> startDatoer, JournalpostId journalpostId, Long behandlingId) {
         final List<UngdomsytelseSøktStartdato> søknadsperiodeliste = new ArrayList<>();
-        søknadsperioder.stream()
-            .map(s -> new UngdomsytelseSøktStartdato(s.getFraOgMed(), journalpostId))
+        startDatoer.stream()
+            .map(it -> new UngdomsytelseSøktStartdato(it, journalpostId))
             .forEach(søknadsperiodeliste::add);
 
         ungdomsytelseStartdatoRepository.lagre(behandlingId, søknadsperiodeliste);