FIX: Oppretter behandling også dersom opphørshendelse flyttes lenger fram i tid (#218)

* FIX: Oppretter behandling også dersom opphørshendelse flyttes lenger fram i tid

* FIX: Validerer også årsak

Author: espenjv

domenetjenester/hendelsemottak/src/main/java/no/nav/ung/sak/hendelsemottak/tjenester/UngdomsprogramOpphørFagsakTilVurderingUtleder.java

@@ -6,6 +6,8 @@
 import java.util.Map;
 import java.util.Optional;
 
+import no.nav.fpsak.tidsserie.LocalDateTimeline;
+import no.nav.ung.sak.ungdomsprogram.UngdomsprogramPeriodeTjeneste;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -25,7 +27,7 @@ public class UngdomsprogramOpphørFagsakTilVurderingUtleder implements FagsakerT
 
     private static final Logger logger = LoggerFactory.getLogger(UngdomsprogramOpphørFagsakTilVurderingUtleder.class);
     private BehandlingRepository behandlingRepository;
-    private UngdomsprogramPeriodeRepository ungdomsprogramPeriodeRepository;
+    private UngdomsprogramPeriodeTjeneste ungdomsprogramPeriodeTjeneste;
     private FinnFagsakerForAktørTjeneste finnFagsakerForAktørTjeneste;
 
     public UngdomsprogramOpphørFagsakTilVurderingUtleder() {
@@ -34,10 +36,10 @@ public class UngdomsprogramOpphørFagsakTilVurderingUtleder implements FagsakerT
 
     @Inject
     public UngdomsprogramOpphørFagsakTilVurderingUtleder(BehandlingRepository behandlingRepository,
-                                                         UngdomsprogramPeriodeRepository ungdomsprogramPeriodeRepository,
+                                                         UngdomsprogramPeriodeTjeneste ungdomsprogramPeriodeTjeneste,
                                                          FinnFagsakerForAktørTjeneste finnFagsakerForAktørTjeneste) {
         this.behandlingRepository = behandlingRepository;
-        this.ungdomsprogramPeriodeRepository = ungdomsprogramPeriodeRepository;
+        this.ungdomsprogramPeriodeTjeneste = ungdomsprogramPeriodeTjeneste;
         this.finnFagsakerForAktørTjeneste = finnFagsakerForAktørTjeneste;
     }
 
@@ -76,10 +78,10 @@ private boolean erNyInformasjonIHendelsen(Fagsak fagsak, LocalDate opphørsdato,
         }
 
         Behandling behandling = behandlingOpt.get();
-        var periodeGrunnlag = ungdomsprogramPeriodeRepository.hentGrunnlag(behandling.getId());
-        if (periodeGrunnlag.isPresent()) {
-            var harIngenPerioderEtterOpphør = periodeGrunnlag.get().getUngdomsprogramPerioder().getPerioder().stream().noneMatch(p -> p.getPeriode().getTomDato().isAfter(opphørsdato));
-            if (harIngenPerioderEtterOpphør) {
+        final var ungdomsprogramTidslinje = ungdomsprogramPeriodeTjeneste.finnPeriodeTidslinje(behandling.getId());
+        if (!ungdomsprogramTidslinje.isEmpty()) {
+            var erSisteDatoAlleredeSattTilOpphørsdato = ungdomsprogramTidslinje.getMaxLocalDate().equals(opphørsdato);
+            if (erSisteDatoAlleredeSattTilOpphørsdato) {
                 logger.info("Datagrunnlag på behandling {} for {} hadde ingen perioder med ungdomsprogram etter opphørsdato. Trigget av hendelse {}.", behandling.getUuid(), fagsak.getSaksnummer(), hendelseId);
                 return false;
             }

domenetjenester/hendelsemottak/src/test/java/no/nav/ung/sak/hendelsemottak/tjenester/UngdomsprogramOpphørFagsakTilVurderingUtlederTest.java

@@ -1,12 +1,18 @@
 package no.nav.ung.sak.hendelsemottak.tjenester;
 
+import static no.nav.ung.kodeverk.behandling.BehandlingÅrsakType.RE_HENDELSE_OPPHØR_UNGDOMSPROGRAM;
 import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
 import static org.mockito.Mockito.mock;
 
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Map;
 
+import no.nav.ung.kodeverk.behandling.BehandlingÅrsakType;
+import no.nav.ung.sak.behandlingslager.fagsak.Fagsak;
+import no.nav.ung.sak.ungdomsprogram.UngdomsprogramPeriodeTjeneste;
+import org.assertj.core.api.AbstractIntegerAssert;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
@@ -49,7 +55,7 @@ public class UngdomsprogramOpphørFagsakTilVurderingUtlederTest {
     void setUp() {
         var fagsakRepository = new FagsakRepository(entityManager);
         this.utleder = new UngdomsprogramOpphørFagsakTilVurderingUtleder(
-            new BehandlingRepository(entityManager), ungdomsprogramPeriodeRepository, new FinnFagsakerForAktørTjeneste(entityManager, fagsakRepository));
+            new BehandlingRepository(entityManager), new UngdomsprogramPeriodeTjeneste(ungdomsprogramPeriodeRepository), new FinnFagsakerForAktørTjeneste(entityManager, fagsakRepository));
         scenarioBuilder = TestScenarioBuilder.builderMedSøknad(FagsakYtelseType.UNGDOMSYTELSE)
             .medBruker(BRUKER_AKTØR_ID);
     }
@@ -74,7 +80,7 @@ void setUp() {
     }
 
     @Test
-    void skal_ikke_returnere_årsak_dersom_ingen_ungdomsprogramperioder_etter_opphørsdato() {
+    void skal_ikke_returnere_årsak_dersom_ungdomsprogramperiode_sluttdato_er_lik_opphørsdato() {
         var behandling = scenarioBuilder.lagre(entityManager);
         scenarioBuilder.lagreFagsak(behandlingRepositoryProvider);
         ungdomsprogramPeriodeRepository.lagre(behandling.getId(), List.of(new UngdomsprogramPeriode(DatoIntervallEntitet.fraOgMedTilOgMed(STP, OPPHØRSDATO))));
@@ -92,6 +98,43 @@ void setUp() {
         assertThat(fagsakBehandlingÅrsakTypeMap.isEmpty()).isTrue();
     }
 
+    @Test
+    void skal_returnere_årsak_dersom_ungdomsprogramperiode_sluttdato_er_etter_opphørsdato() {
+        var behandling = scenarioBuilder.lagre(entityManager);
+        scenarioBuilder.lagreFagsak(behandlingRepositoryProvider);
+        ungdomsprogramPeriodeRepository.lagre(behandling.getId(), List.of(new UngdomsprogramPeriode(DatoIntervallEntitet.fraOgMedTilOgMed(STP, OPPHØRSDATO.plusDays(1)))));
+
+        behandling.avsluttBehandling();
+        entityManager.flush();
+
+        var builder = new HendelseInfo.Builder();
+        builder.leggTilAktør(BRUKER_AKTØR_ID);
+        builder.medHendelseId("1");
+        builder.medOpprettet(LocalDateTime.now());
+        var fagsakBehandlingÅrsakTypeMap = utleder.finnFagsakerTilVurdering(new UngdomsprogramOpphørHendelse(builder.build(), OPPHØRSDATO));
+
+
+        validerHarÅrsak(fagsakBehandlingÅrsakTypeMap);
+    }
+
+    @Test
+    void skal_returnere_årsak_dersom_ungdomsprogramperiode_sluttdato_er_før_opphørsdato() {
+        var behandling = scenarioBuilder.lagre(entityManager);
+        scenarioBuilder.lagreFagsak(behandlingRepositoryProvider);
+        ungdomsprogramPeriodeRepository.lagre(behandling.getId(), List.of(new UngdomsprogramPeriode(DatoIntervallEntitet.fraOgMedTilOgMed(STP, OPPHØRSDATO.minusDays(1)))));
+
+        behandling.avsluttBehandling();
+        entityManager.flush();
+
+        var builder = new HendelseInfo.Builder();
+        builder.leggTilAktør(BRUKER_AKTØR_ID);
+        builder.medHendelseId("1");
+        builder.medOpprettet(LocalDateTime.now());
+        var fagsakBehandlingÅrsakTypeMap = utleder.finnFagsakerTilVurdering(new UngdomsprogramOpphørHendelse(builder.build(), OPPHØRSDATO));
+
+
+        validerHarÅrsak(fagsakBehandlingÅrsakTypeMap);
+    }
 
     @Test
     void skal_returnere_årsak_dersom_en_ungdomsprogramperiode_som_går_over_opphørsdato() {
@@ -109,7 +152,12 @@ void setUp() {
         var fagsakBehandlingÅrsakTypeMap = utleder.finnFagsakerTilVurdering(new UngdomsprogramOpphørHendelse(builder.build(), OPPHØRSDATO));
 
 
+        validerHarÅrsak(fagsakBehandlingÅrsakTypeMap);
+    }
+
+    private static void validerHarÅrsak(Map<Fagsak, BehandlingÅrsakType> fagsakBehandlingÅrsakTypeMap) {
         assertThat(fagsakBehandlingÅrsakTypeMap.keySet().size()).isEqualTo(1);
+        assertThat(fagsakBehandlingÅrsakTypeMap.values().iterator().next()).isEqualTo(RE_HENDELSE_OPPHØR_UNGDOMSPROGRAM);
     }
 
 }