feat(TFP-5818): avslutt kobling og fjern inaktive grunnlag task. (#2636)

* TFP-5818: Legger inn en task som skal avslutte en kobling og så rydde opp i innaktive grunnlag.

* fix: fikser manglende ytelse type på kobling. Returner 204 hvis kobling mangler.

* review: erstattet task med direkt tjeneste kall.

* Test

* sonar + ny namespace for azure-token-generator

Author: mrsladek

.deploy/dev-fss-teamforeldrepenger.json

@@ -59,7 +59,7 @@
     },
     {
       "app": "azure-token-generator",
-      "namespace": "aura",
+      "namespace": "nais",
       "cluster": "dev-gcp",
       "roles": [
         "ekstern"

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/domene/iay/InntektArbeidYtelseRepository.java

@@ -15,6 +15,8 @@
 import java.util.stream.Collectors;
 
 import org.hibernate.jpa.HibernateHints;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
@@ -43,6 +45,8 @@
 @ApplicationScoped
 public class InntektArbeidYtelseRepository {
 
+    private static final Logger LOG = LoggerFactory.getLogger(InntektArbeidYtelseRepository.class);
+
     private EntityManager entityManager;
     private KoblingRepository koblingRepository;
 
@@ -421,6 +425,18 @@ private void lagreOgFlush(KoblingReferanse koblingReferanse, InntektArbeidYtelse
         entityManager.flush();
     }
 
+    private void validerKoblingErAktiv(KoblingReferanse koblingReferanse) {
+        koblingRepository.hentForKoblingReferanse(koblingReferanse).ifPresent(InntektArbeidYtelseRepository::validerIkkeAvsluttet);
+    }
+
+    private static void validerIkkeAvsluttet(Kobling kobling) {
+        if (!kobling.erAktiv()) {
+            throw new TekniskException("FT-49000", String.format(
+                "Ikke tillatt å gjøre endringer på en avsluttet kobling. Gjelder kobling med referanse %s",
+                kobling.getKoblingReferanse()));
+        }
+    }
+
     /**
      * Kaster exception hvis grunnlaget er i en ugyldig tilstand
      *
@@ -436,7 +452,6 @@ private void sjekkKonsistens(InntektArbeidYtelseGrunnlag grunnlag) {
             .ifPresent(
                 aggregat -> aggregat.getAktørArbeid().stream().map(AktørArbeid::hentAlleYrkesaktiviteter).flatMap(Collection::stream).forEach(it -> {
                     if (it.getArbeidsforholdRef().gjelderForSpesifiktArbeidsforhold()) {
-                        var arRef = aggregat.getEksternReferanse();
                         arbeidsforholdInformasjon.finnEkstern(grRef, it.getArbeidsgiver(),
                             it.getArbeidsforholdRef()); // Validerer om det finnes ekstern for intern ref
                         // (kaster exception hvis ikke)
@@ -455,7 +470,6 @@ private void sjekkKonsistens(InntektArbeidYtelseGrunnlag grunnlag) {
             .ifPresent(
                 aggregat -> aggregat.getAktørArbeid().stream().map(AktørArbeid::hentAlleYrkesaktiviteter).flatMap(Collection::stream).forEach(it -> {
                     if (it.getArbeidsforholdRef().gjelderForSpesifiktArbeidsforhold()) {
-                        var arRef = aggregat.getEksternReferanse();
                         arbeidsforholdInformasjon.finnEkstern(grRef, it.getArbeidsgiver(),
                             it.getArbeidsforholdRef()); // Validerer om det finnes ekstern for intern ref
                         // (kaster exception hvis ikke)
@@ -638,18 +652,15 @@ private Optional<InntektArbeidYtelseGrunnlag> getAktivtInntektArbeidGrunnlag(Kob
         throw new IllegalStateException("Finner flere aktive grunnlag på koblingReferanse=" + koblingReferanse);
     }
 
-    private Optional<Kobling> validerKoblingErAktiv(KoblingReferanse koblingReferanse) {
-        var kobling = koblingRepository.hentForKoblingReferanse(koblingReferanse);
-        kobling.ifPresent(InntektArbeidYtelseRepository::validerIkkeAvsluttet);
-        return kobling;
-    }
-
-    private static void validerIkkeAvsluttet(Kobling kobling) {
-        if (!kobling.erAktiv()) {
-            throw new TekniskException("FT-49000", String.format(
-                "Ikke tillatt å gjøre endringer på en avsluttet kobling. Gjelder kobling med referanse %s",
-                kobling.getKoblingReferanse()));
-        }
+    public void slettAlleInaktiveGrunnlagFor(KoblingReferanse koblingReferanse) {
+        final var query = entityManager.createQuery("""
+            DELETE FROM InntektArbeidGrunnlag gr
+            WHERE gr.aktiv = false
+            AND gr.koblingId = (SELECT k.id FROM Kobling k where k.koblingReferanse = :ref)
+            """);
+        query.setParameter("ref", koblingReferanse);
+        var countDelete = query.executeUpdate();
+        LOG.info("Slettet {} inaktive grunnlag for kobling {}", countDelete, koblingReferanse);
     }
 
     private Optional<ArbeidsforholdInformasjon> hentArbeidsforholdInformasjon(Optional<InntektArbeidYtelseGrunnlag> grunnlag) {

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/iay/InntektArbeidYtelseTjeneste.java

@@ -71,6 +71,16 @@ public Optional<InntektArbeidYtelseGrunnlag> hentGrunnlagFor(KoblingReferanse ko
         return repository.hentInntektArbeidYtelseGrunnlagForBehandling(koblingReferanse);
     }
 
+    /**
+     * Fjerner alle inaktive grunnlag for en kobling og bør brukes når koblingen deaktiveres.
+     * Operasjonen sletter kun de underliggende `gr_arbeid_inntekt`-entitetene og ikke de tilhørende aggregatene,
+     * siden disse kan gjenbrukes av andre koblinger ettersom grunnlaget kopieres til nye behandlinger av saken.
+     *
+     * @param koblingReferanse
+     */
+    public void slettInaktiveGrunnlagFor(KoblingReferanse koblingReferanse) {
+        repository.slettAlleInaktiveGrunnlagFor(koblingReferanse);
+    }
 
     public Set<Inntektsmelding> hentAlleInntektsmeldingerFor(AktørId aktørId, Saksnummer saksnummer, YtelseType ytelseType) {
         return repository.hentAlleInntektsmeldingerFor(aktørId, saksnummer, ytelseType);

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/RegisterdataInnhentingTask.java

@@ -49,8 +49,7 @@ public RegisterdataInnhentingTask(LåsRepository låsRepository,
 
     @Override
     protected void prosesser(ProsessTaskData prosessTaskData) {
-        String nyKoblingId = prosessTaskData.getPropertyValue(TaskConstants.KOBLING_ID);
-        Long koblingId = nyKoblingId != null ? Long.valueOf(nyKoblingId) : prosessTaskData.getBehandlingIdAsLong();
+        Long koblingId = Long.valueOf(prosessTaskData.getPropertyValue(TaskConstants.KOBLING_ID));
         Kobling kobling = koblingTjeneste.hent(koblingId);
         LOG.info("Starter registerinnhenting for sak=[{}, {}] med behandling='{}'", kobling.getSaksnummer(), kobling.getYtelseType(),
             kobling.getKoblingReferanse());

domenetjenester/iay/src/test/java/no/nav/foreldrepenger/abakus/domene/iay/InntektArbeidYtelseRepositoryTest.java

@@ -11,7 +11,6 @@
 import java.util.Optional;
 import java.util.Set;
 import java.util.UUID;
-import java.util.stream.Collectors;
 
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
@@ -52,7 +51,7 @@ class InntektArbeidYtelseRepositoryTest {
     private KoblingRepository koblingRepository;
 
     @BeforeEach
-    public void setup() {
+    void setup() {
         repository = new InntektArbeidYtelseRepository(jpaExtension.getEntityManager());
         koblingRepository = new KoblingRepository(jpaExtension.getEntityManager());
     }
@@ -395,7 +394,7 @@ void skal_kunne_lagre_overstyring_av_oppgitt_opptjening_flere_ganger() {
             .map(Optional::get)
             .map(InntektsmeldingAggregat::getInntektsmeldinger)
             .flatMap(Collection::stream)
-            .collect(Collectors.toList());
+            .toList();
         assertThat(inntektsmeldings).hasSize(4);
 
         var aktivtGrunnlag = repository.hentInntektArbeidYtelseForBehandling(koblingReferanse);
@@ -475,7 +474,7 @@ void skal_kun_hente_aktivt_grunnlag() {
             .map(Optional::get)
             .map(InntektsmeldingAggregat::getInntektsmeldinger)
             .flatMap(Collection::stream)
-            .collect(Collectors.toList());
+            .toList();
         assertThat(inntektsmeldings).hasSize(1);
 
         var aktivtGrunnlag = repository.hentInntektArbeidYtelseForBehandling(koblingReferanse);
@@ -552,7 +551,7 @@ void skal_kun_hente_aktivt_grunnlag() {
             .map(Optional::get)
             .map(InntektsmeldingAggregat::getInntektsmeldinger)
             .flatMap(Collection::stream)
-            .collect(Collectors.toList());
+            .toList();
         assertThat(inntektsmeldings).hasSize(4);
 
         var aktivtGrunnlag = repository.hentInntektArbeidYtelseForBehandling(koblingReferanse);
@@ -608,8 +607,6 @@ void skal_kun_hente_aktivt_grunnlag() {
             .medRefusjon(BigDecimal.ONE)
             .build();
 
-        var b = "AR122".compareTo("AR124") > 0;
-
         repository.lagre(ko.getKoblingReferanse(), ArbeidsforholdInformasjonBuilder.oppdatere(new ArbeidsforholdInformasjon()),
             List.of(inntektsmelding1, inntektsmelding2, inntektsmelding3));
 
@@ -623,7 +620,7 @@ void skal_kun_hente_aktivt_grunnlag() {
             .map(Optional::get)
             .map(InntektsmeldingAggregat::getInntektsmeldinger)
             .flatMap(Collection::stream)
-            .collect(Collectors.toList());
+            .toList();
         assertThat(inntektsmeldings).hasSize(2);
 
         var aktivtGrunnlag = repository.hentInntektArbeidYtelseForBehandling(koblingReferanse);

domenetjenester/kobling/pom.xml

@@ -43,6 +43,5 @@
 			<groupId>no.nav.foreldrepenger.abakus</groupId>
 			<artifactId>felles</artifactId>
 		</dependency>
-
 	</dependencies>
 </project>

domenetjenester/kobling/src/main/java/no/nav/foreldrepenger/abakus/kobling/KoblingRestTjeneste.java

@@ -21,8 +21,7 @@ protected KoblingTask(LåsRepository låsRepository) {
 
     @Override
     public void doTask(ProsessTaskData prosessTaskData) {
-        var nyKoblingId = prosessTaskData.getPropertyValue(TaskConstants.KOBLING_ID);
-        var koblingId = nyKoblingId != null ? Long.valueOf(nyKoblingId) : prosessTaskData.getBehandlingIdAsLong();
+        var koblingId = Long.valueOf(prosessTaskData.getPropertyValue(TaskConstants.KOBLING_ID));
         LOG_CONTEXT.add("koblingId", koblingId);
 
         var koblingLås = låsRepository.taLås(koblingId);

domenetjenester/kobling/src/main/java/no/nav/foreldrepenger/abakus/kobling/KoblingTask.java

@@ -75,7 +75,7 @@ public void lagre(Kobling nyKobling) {
         var diff = getDiff(eksisterendeKobling.orElse(null), nyKobling);
         // Diffen blir aldri forskjellig om nyKobling er allerede persistert i databasen. Men endringen blir skrevet til databasen likevel da hele transaksjonen commites.
         if (!diff.isEmpty()) {
-            if (nyKobling.getId() != null) {
+            if (nyKobling.getId() == null) {
                 LOG.info("KOBLING: Lagrer en helt ny kobling med id={}, endringer={}", nyKobling.getId(), diff.getLeafDifferences());
             } else {
                 LOG.info("KOBLING: Lagrer endringer på kobling med id={}, endringer={}", nyKobling.getId(), diff.getLeafDifferences());

domenetjenester/kobling/src/main/java/no/nav/foreldrepenger/abakus/kobling/repository/KoblingRepository.java

@@ -88,8 +88,7 @@ public static Map<String, YtelseType> kodeMap() {
     }
 
     public static List<YtelseType> abakusYtelser() {
-        return List.of(YtelseType.FORELDREPENGER, YtelseType.SVANGERSKAPSPENGER, YtelseType.OMSORGSPENGER, YtelseType.PLEIEPENGER_SYKT_BARN,
-            YtelseType.PLEIEPENGER_NÆRSTÅENDE, YtelseType.OPPLÆRINGSPENGER, YtelseType.FRISINN);
+        return List.of(YtelseType.FORELDREPENGER, YtelseType.SVANGERSKAPSPENGER);
     }
 
     @Override

kodeverk/src/main/java/no/nav/abakus/iaygrunnlag/kodeverk/YtelseType.java

@@ -15,7 +15,7 @@
 @JsonIgnoreProperties(ignoreUnknown = true)
 @JsonInclude(value = Include.NON_ABSENT, content = Include.NON_EMPTY)
 @JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, creatorVisibility = Visibility.NONE)
-public class AvsluttGrunnlagRequest {
+public class AvsluttKoblingRequest {
 
     /**
      * Saksnummer alle grunnlag og koblinger er linket til.
@@ -41,10 +41,10 @@ public class AvsluttGrunnlagRequest {
     private PersonIdent aktør;
 
     @JsonCreator
-    public AvsluttGrunnlagRequest(@JsonProperty(value = "saksnummer", required = true) @Valid @NotNull String saksnummer,
-                                  @JsonProperty(value = "referanse", required = true) @Valid @NotNull UUID referanse,
-                                  @JsonProperty(value = "ytelseType", required = true) @NotNull YtelseType ytelseType,
-                                  @JsonProperty(value = "aktør", required = true) @NotNull @Valid PersonIdent aktør) {
+    public AvsluttKoblingRequest(@JsonProperty(value = "saksnummer", required = true) @Valid @NotNull String saksnummer,
+                                 @JsonProperty(value = "referanse", required = true) @Valid @NotNull UUID referanse,
+                                 @JsonProperty(value = "ytelseType", required = true) @NotNull YtelseType ytelseType,
+                                 @JsonProperty(value = "aktør", required = true) @NotNull @Valid PersonIdent aktør) {
         this.saksnummer = saksnummer;
         this.referanse = referanse;
         this.ytelseType = ytelseType;