fortsett behandling

Author: qtips

domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/oppgavebekreftelse/InntektBekreftelseHåndterer.java

@@ -13,8 +13,11 @@
 import no.nav.k9.oppgave.bekreftelse.Bekreftelse;
 import no.nav.k9.oppgave.bekreftelse.ung.inntekt.InntektBekreftelse;
 import no.nav.k9.prosesstask.api.ProsessTaskData;
+import no.nav.k9.prosesstask.api.ProsessTaskGruppe;
 import no.nav.k9.prosesstask.api.ProsessTaskTjeneste;
 import no.nav.ung.kodeverk.arbeidsforhold.ArbeidType;
+import no.nav.ung.kodeverk.behandling.BehandlingStegType;
+import no.nav.ung.sak.behandling.prosessering.task.FortsettBehandlingTask;
 import no.nav.ung.sak.behandlingslager.behandling.Behandling;
 import no.nav.ung.sak.behandlingslager.etterlysning.EtterlysningEntitet;
 import no.nav.ung.sak.behandlingslager.etterlysning.EtterlysningRepository;
@@ -38,31 +41,45 @@ public class InntektBekreftelseHåndterer implements BekreftelseHåndterer {
         this.prosessTaskTjeneste = prosessTaskTjeneste;
     }
 
+    //TODO hva hvis behandling er ikke på KONTROLLER_REGISTER_INNTEKT steg?
     @Override
-    public void håndter(OppgaveBekreftelseInnhold bekreftelse) {
-        InntektBekreftelse b = bekreftelse.oppgaveBekreftelse().getBekreftelse();
+    public void håndter(OppgaveBekreftelseInnhold oppgaveBekreftelseInnhold) {
+        InntektBekreftelse inntektBekreftelse = oppgaveBekreftelseInnhold.oppgaveBekreftelse().getBekreftelse();
 
         // lagre grunnlag
-        var oppgittOpptjeningMottattRequest = mapOppgittOpptjeningRequest(bekreftelse);
-        lagreOppgittOpptjeningFraSøknad(bekreftelse, oppgittOpptjeningMottattRequest);
+        var abakusTask = lagOppdaterAbakusTask(oppgaveBekreftelseInnhold);
+
+        // opprett uttalelse hvis finnes
+
+
+        // ta behandling av vent (lukker autopunkt også)
+        var fortsettTask = ProsessTaskData.forProsessTask(FortsettBehandlingTask.class);
+        Behandling behandling = oppgaveBekreftelseInnhold.behandling();
+        fortsettTask.setBehandling(behandling.getFagsakId(), behandling.getId());
+        fortsettTask.setSaksnummer(behandling.getFagsak().getSaksnummer().getVerdi());
+        fortsettTask.setProperty(FortsettBehandlingTask.GJENOPPTA_STEG, BehandlingStegType.KONTROLLER_REGISTER_INNTEKT.getKode());
+
+        ProsessTaskGruppe gruppe = new ProsessTaskGruppe();
+        gruppe.addNesteSekvensiell(abakusTask);
+        gruppe.addNesteSekvensiell(fortsettTask);
+        prosessTaskTjeneste.lagre(gruppe);
 
         // hent tilhørende etterlysning og marker den som løst
-        UUID oppgaveId = b.getOppgaveId();
+        UUID oppgaveId = inntektBekreftelse.getOppgaveId();
         EtterlysningEntitet etterlysning = etterlysningRepository.hentEtterlysningForEksternReferanse(oppgaveId);
         etterlysning.mottattSvar();
         etterlysningRepository.lagre(etterlysning);
 
-        // opprett uttalelse hvis finnes
-
-
-        // ta behandling av vent
-
     }
 
     /**
      * Lagrer oppgitt opptjening til abakus fra mottatt dokument.
+     *
+     * @return
      */
-    private void lagreOppgittOpptjeningFraSøknad(OppgaveBekreftelseInnhold bekreftelseInnhold, OppgittOpptjeningMottattRequest request) {
+    private ProsessTaskData lagOppdaterAbakusTask(OppgaveBekreftelseInnhold bekreftelseInnhold) {
+        var request = mapOppgittOpptjeningRequest(bekreftelseInnhold);
+
         try {
             var behandling = bekreftelseInnhold.behandling();
             var enkeltTask = ProsessTaskData.forProsessTask(AsyncAbakusLagreOpptjeningTask.class);
@@ -75,8 +92,9 @@ public class InntektBekreftelseHåndterer implements BekreftelseHåndterer {
             enkeltTask.setBehandling(behandling.getFagsakId(), behandling.getId(), behandling.getAktørId().getAktørId());
             enkeltTask.setSaksnummer(behandling.getFagsak().getSaksnummer().getVerdi());
             enkeltTask.setCallIdFraEksisterende();
+            return enkeltTask;
+
 
-            prosessTaskTjeneste.lagre(enkeltTask);
         } catch (IOException e) {
             throw AbakusInntektArbeidYtelseTjenesteFeil.FEIL.feilVedKallTilAbakus("Opprettelse av task for lagring av oppgitt opptjening i abakus feiler.", e).toException();
         }

domenetjenester/mottak/src/test/java/no/nav/ung/sak/mottak/dokumentmottak/oppgavebekreftelse/InntektBekreftelseHåndtererTest.java

@@ -32,9 +32,10 @@
 import no.nav.k9.søknad.felles.type.SøknadId;
 import no.nav.ung.kodeverk.behandling.BehandlingStegType;
 import no.nav.ung.kodeverk.behandling.BehandlingType;
-import no.nav.ung.kodeverk.behandling.aksjonspunkt.AksjonspunktDefinisjon;
 import no.nav.ung.kodeverk.dokument.Brevkode;
 import no.nav.ung.kodeverk.etterlysning.EtterlysningStatus;
+import no.nav.ung.sak.behandling.prosessering.task.FortsettBehandlingTask;
+import no.nav.ung.sak.behandlingskontroll.BehandlingskontrollTjeneste;
 import no.nav.ung.sak.behandlingslager.behandling.Behandling;
 import no.nav.ung.sak.behandlingslager.etterlysning.EtterlysningEntitet;
 import no.nav.ung.sak.behandlingslager.etterlysning.EtterlysningRepository;
@@ -50,6 +51,8 @@ class InntektBekreftelseHåndtererTest {
 
     @Inject
     private EntityManager em;
+    @Inject
+    private BehandlingskontrollTjeneste behandlingskontrollTjeneste;
     private EtterlysningRepository etterlysningRepository;
     private ProsessTaskTjeneste prosessTaskTjeneste;
 
@@ -64,13 +67,9 @@ void setup() {
 
     @Test
     void skalOppdatereEtterlysningOppdatereIayGrunnlagLagreUttalelseOgSetteBehandlingAvVent() {
-
-
         // Arrange
         TestScenarioBuilder scenarioBuilder = TestScenarioBuilder.builderMedSøknad()
             .medBehandlingType(BehandlingType.REVURDERING);
-
-        scenarioBuilder.leggTilAksjonspunkt(AksjonspunktDefinisjon.AUTO_SATT_PÅ_VENT_ETTERLYST_INNTEKTUTTALELSE, BehandlingStegType.KONTROLLER_REGISTER_INNTEKT);
         Behandling behandling = scenarioBuilder.lagre(em);
 
         var periode = DatoIntervallEntitet.fra(LocalDate.now(), LocalDate.now());
@@ -123,9 +122,10 @@ void skalOppdatereEtterlysningOppdatereIayGrunnlagLagreUttalelseOgSetteBehandlin
         assertThat(abakusTask.getPropertyValue(AsyncAbakusLagreOpptjeningTask.BREVKODER)).isEqualTo(Brevkode.UNGDOMSYTELSE_OPPGAVE_BEKREFTELSE.getKode());
         assertThat(abakusTask.getPayloadAsString()).contains(String.valueOf(oppgittInntekt));
 
-
-        //behandling er ikke lenger på vent
-        assertThat(behandling.getAksjonspunkter()).isEmpty();
+        //behandling taes av vent
+        var fortsettSteg = prosessTaskTjeneste.finnAlle(FortsettBehandlingTask.TASKTYPE, ProsessTaskStatus.KLAR);
+        assertThat(fortsettSteg).hasSize(1);
+        assertThat(fortsettSteg.getFirst().getPropertyValue(FortsettBehandlingTask.GJENOPPTA_STEG)).isEqualTo(BehandlingStegType.KONTROLLER_REGISTER_INNTEKT.getKode());
 
         //etterlysning er oppdatert
         var oppdatertEtterlysning = etterlysningRepository.hentEtterlysning(etterlysning.getId());