Abonner på inntekts hendelser

behandlingslager/domene/src/main/java/no/nav/ung/sak/behandlingslager/tilkjentytelse/InntektAbonnement.java

@@ -0,0 +1,100 @@
+package no.nav.ung.sak.behandlingslager.tilkjentytelse;
+
+import jakarta.persistence.AttributeOverride;
+import jakarta.persistence.AttributeOverrides;
+import jakarta.persistence.Column;
+import jakarta.persistence.Embedded;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import jakarta.persistence.Version;
+import no.nav.k9.felles.konfigurasjon.konfig.Tid;
+import no.nav.ung.sak.behandlingslager.BaseEntitet;
+import no.nav.ung.sak.behandlingslager.PostgreSQLRangeType;
+import no.nav.ung.sak.behandlingslager.Range;
+import no.nav.ung.sak.domene.typer.tid.DatoIntervallEntitet;
+import no.nav.ung.sak.typer.AktørId;
+import org.hibernate.annotations.Type;
+
+import java.time.LocalDate;
+
+@Entity(name = "InntektAbonnement")
+@Table(name = "INNTEKT_ABONNEMENT")
+public class InntektAbonnement extends BaseEntitet {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "SEQ_INNTEKT_ABONNEMENT")
+    private Long id;
+
+    @Column(name = "abonnement_id", nullable = false)
+    private String abonnementId;
+
+    @Embedded
+    @AttributeOverrides(@AttributeOverride(name = "aktørId", column = @Column(name = "aktoer_id", nullable = false)))
+    private AktørId aktørId;
+
+    @Type(PostgreSQLRangeType.class)
+    @Column(name = "periode", columnDefinition = "daterange")
+    private Range<LocalDate> periode;
+
+    @Column(name = "siste_bruksdag", nullable = false)
+    private LocalDate sisteBruksdag;
+
+    @Version
+    @Column(name = "versjon", nullable = false)
+    private long versjon;
+
+    @Column(name = "aktiv", nullable = false)
+    private boolean aktiv = true;
+
+    public InntektAbonnement() {
+    }
+
+    public InntektAbonnement(String abonnementId, AktørId aktørId) {
+        this.abonnementId = abonnementId;
+        this.aktørId = aktørId;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public String getAbonnementId() {
+        return abonnementId;
+    }
+
+    public AktørId getAktørId() {
+        return aktørId;
+    }
+
+    public DatoIntervallEntitet getPeriode() {
+        return DatoIntervallEntitet.fra(periode);
+    }
+
+    void setPeriode(LocalDate fom, LocalDate tom) {
+        if ((fom == null || fom.equals(Tid.TIDENES_BEGYNNELSE))) {
+            throw new IllegalArgumentException(String.format("Alle saker må angi en startdato: [%s, %s]", fom, tom));
+        }
+        if (tom == null || tom.equals(Tid.TIDENES_ENDE)) {
+            throw new IllegalArgumentException();
+        }
+        this.periode = DatoIntervallEntitet.fra(fom, tom).toRange();
+    }
+
+    public LocalDate getSisteBruksdag() {
+        return sisteBruksdag;
+    }
+
+    public void setSisteBruksdag(LocalDate sisteBruksdag) {
+        this.sisteBruksdag = sisteBruksdag;
+    }
+
+    public boolean erAktiv() {
+        return aktiv;
+    }
+    public void setAktiv(boolean aktiv) {
+        this.aktiv = aktiv;
+    }
+}

behandlingslager/domene/src/main/java/no/nav/ung/sak/behandlingslager/tilkjentytelse/InntektAbonnementRepository.java

@@ -0,0 +1,37 @@
+package no.nav.ung.sak.behandlingslager.tilkjentytelse;
+
+import jakarta.enterprise.context.Dependent;
+import jakarta.inject.Inject;
+import jakarta.persistence.EntityManager;
+import no.nav.ung.sak.typer.AktørId;
+import java.util.Optional;
+
+@Dependent
+public class InntektAbonnementRepository {
+
+    private EntityManager entityManager;
+
+    @Inject
+    public InntektAbonnementRepository(EntityManager entityManager) {
+        this.entityManager = entityManager;
+    }
+
+    public void lagre(InntektAbonnement abonnement) {
+        entityManager.persist(abonnement);
+    }
+
+    public Optional<InntektAbonnement> hentAbonnementForAktør(AktørId aktørId) {
+        var query = entityManager.createQuery(
+            "SELECT i FROM InntektAbonnement i WHERE i.aktørId = :aktørId AND i.aktiv = true",
+            InntektAbonnement.class
+        );
+        query.setParameter("aktørId", aktørId);
+        return query.getResultStream().findFirst();
+    }
+
+    public void slettAbonnement(InntektAbonnement abonnement) {
+        abonnement.setAktiv(false);
+        entityManager.persist(abonnement);
+    }
+}
+

behandlingsprosess/src/main/java/no/nav/ung/sak/domene/behandling/steg/kompletthet/VurderKompletthetStegImpl.java

@@ -3,20 +3,19 @@
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 import no.nav.k9.felles.konfigurasjon.konfig.KonfigVerdi;
-import no.nav.ung.kodeverk.behandling.BehandlingÅrsakType;
 import no.nav.ung.kodeverk.behandling.aksjonspunkt.AksjonspunktDefinisjon;
 import no.nav.ung.kodeverk.behandling.aksjonspunkt.Venteårsak;
 import no.nav.ung.kodeverk.varsel.EtterlysningType;
 import no.nav.ung.sak.behandling.BehandlingReferanse;
 import no.nav.ung.sak.behandlingskontroll.*;
-import no.nav.ung.sak.behandlingslager.behandling.BehandlingÅrsak;
 import no.nav.ung.sak.behandlingslager.behandling.repository.BehandlingRepository;
 import no.nav.ung.sak.behandlingslager.etterlysning.Etterlysning;
 import no.nav.ung.sak.behandlingslager.etterlysning.EtterlysningRepository;
 import no.nav.ung.sak.behandlingslager.fagsak.Fagsak;
 import no.nav.ung.sak.domene.behandling.steg.kompletthet.registerinntektkontroll.KontrollerInntektEtterlysningOppretter;
 import no.nav.ung.sak.domene.behandling.steg.kompletthet.registerinntektkontroll.RapporteringsfristAutopunktUtleder;
 import no.nav.ung.sak.domene.behandling.steg.ungdomsprogramkontroll.ProgramperiodeendringEtterlysningTjeneste;
+import no.nav.ung.sak.domene.registerinnhenting.InntektAbonnentTjeneste;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -57,8 +56,10 @@ public class VurderKompletthetStegImpl implements VurderKompletthetSteg {
     private BehandlingRepository behandlingRepository;
     private KontrollerInntektEtterlysningOppretter kontrollerInntektEtterlysningOppretter;
     private ProgramperiodeendringEtterlysningTjeneste programperiodeendringEtterlysningTjeneste;
+    private InntektAbonnentTjeneste inntektAbonnentTjeneste;
     private RapporteringsfristAutopunktUtleder rapporteringsfristAutopunktUtleder;
     private Duration ventePeriode;
+    private boolean hentInntektHendelserEnabled;
 
 
     VurderKompletthetStegImpl() {
@@ -69,14 +70,18 @@ public VurderKompletthetStegImpl(EtterlysningRepository etterlysningRepository,
                                      BehandlingRepository behandlingRepository,
                                      KontrollerInntektEtterlysningOppretter kontrollerInntektEtterlysningOppretter,
                                      ProgramperiodeendringEtterlysningTjeneste programperiodeendringEtterlysningTjeneste,
+                                     InntektAbonnentTjeneste inntektAbonnentTjeneste,
                                      RapporteringsfristAutopunktUtleder rapporteringsfristAutopunktUtleder,
-                                     @KonfigVerdi(value = "VENTEFRIST_UTTALELSE", defaultVerdi = "P14D") String ventePeriode) {
+                                     @KonfigVerdi(value = "VENTEFRIST_UTTALELSE", defaultVerdi = "P14D") String ventePeriode,
+                                     @KonfigVerdi(value = "HENT_INNTEKT_HENDELSER_ENABLED", required = false, defaultVerdi = "false") boolean hentInntektHendelserEnabled) {
         this.etterlysningRepository = etterlysningRepository;
         this.behandlingRepository = behandlingRepository;
         this.kontrollerInntektEtterlysningOppretter = kontrollerInntektEtterlysningOppretter;
         this.programperiodeendringEtterlysningTjeneste = programperiodeendringEtterlysningTjeneste;
+        this.inntektAbonnentTjeneste = inntektAbonnentTjeneste;
         this.rapporteringsfristAutopunktUtleder = rapporteringsfristAutopunktUtleder;
         this.ventePeriode = Duration.parse(ventePeriode);
+        this.hentInntektHendelserEnabled = hentInntektHendelserEnabled;
     }
 
     @Override
@@ -95,6 +100,10 @@ public VurderKompletthetStegImpl(EtterlysningRepository etterlysningRepository,
             log.info("Behandling {} har ikke digital bruker, hopper over opprettelse av etterlysninger for endret programperiode og kontroll av inntekt.", kontekst.getBehandlingId());
         }
 
+        if (hentInntektHendelserEnabled) {
+            inntektAbonnentTjeneste.opprettAbonnement(behandlingReferanse.getAktørId(), behandling.getFagsak().getPeriode().tilPeriode());
+        }
+
         // Steg 2: Utled aksjonspunkter
         List<AksjonspunktResultat> aksjonspunktResultater = new ArrayList<>();
 
@@ -105,6 +114,11 @@ public VurderKompletthetStegImpl(EtterlysningRepository etterlysningRepository,
         // Sjekker etterlysninger opprettet i steg 1
         final var etterlysningerSomVenterPåSvar = etterlysningRepository.hentEtterlysningerSomVenterPåSvar(kontekst.getBehandlingId());
         aksjonspunktResultater.addAll(utledFraEtterlysninger(etterlysningerSomVenterPåSvar));
+
+        if(etterlysningerSomVenterPåSvar.isEmpty()) {
+            inntektAbonnentTjeneste.avsluttAbonnentHvisFinnes(behandlingReferanse.getAktørId());
+        }
+
         return BehandleStegResultat.utførtMedAksjonspunktResultater(aksjonspunktResultater);
     }
 

behandlingsprosess/src/test/java/no/nav/ung/sak/domene/behandling/steg/kompletthet/VurderKompletthetStegImplTest.java

@@ -17,6 +17,7 @@
 import no.nav.ung.sak.domene.behandling.steg.kompletthet.registerinntektkontroll.KontrollerInntektEtterlysningOppretter;
 import no.nav.ung.sak.domene.behandling.steg.kompletthet.registerinntektkontroll.RapporteringsfristAutopunktUtleder;
 import no.nav.ung.sak.domene.behandling.steg.ungdomsprogramkontroll.ProgramperiodeendringEtterlysningTjeneste;
+import no.nav.ung.sak.domene.registerinnhenting.InntektAbonnentTjeneste;
 import no.nav.ung.sak.domene.typer.tid.DatoIntervallEntitet;
 import no.nav.ung.sak.typer.AktørId;
 import no.nav.ung.sak.typer.Saksnummer;
@@ -71,9 +72,11 @@ void setUp() {
         vurderKompletthetSteg = new VurderKompletthetStegImpl(etterlysningRepository, behandlingRepository,
             mock(KontrollerInntektEtterlysningOppretter.class),
             mock(ProgramperiodeendringEtterlysningTjeneste.class),
+            mock(InntektAbonnentTjeneste.class),
             rapporteringsfristAutopunktUtleder,
-            "P14D");
-
+            "P14D",
+            false
+        );
     }
 
     @Test

deploy/dev-gcp.yml

@@ -200,6 +200,11 @@ spec:
     - name: KABAL_SCOPE
       value: api://dev-gcp.klage.kabal-api/.default
 
+    - name: INNTEKTSKOMPONENTEN_URL
+      value: http://ikomp.team-inntekt/rest/v2/abonnement
+    - name: INNTEKTSKOMPONENTEN_SCOPE
+      value: api://dev-gcp.team-inntekt.ikomp/.default
+
     # Saf
     - name: SAF_BASE_URL
       value: https://saf-q2.dev-fss-pub.nais.io
@@ -239,6 +244,8 @@ spec:
       value: "true"
     - name: OPPFRISK_KONTROLLBEHANDLING_ENABLED
       value: "true"
+    - name: OPPFRISK_VED_INNKOMMENDE_INNTEKTSHENDELSE_ENABLED
+      value: "false"
     - name: KLAGE_ENABLED
       value: "true"
     - name: INTEGRASJON_KABAL
@@ -263,6 +270,8 @@ spec:
       value: "P1D"
     - name: OVERSTYR_REGISTERDATA_DURATION
       value: "PT30M"
+    - name: HENT_INNTEKT_HENDElSER_INTERVALL
+      value: "PT1M"
 
     # Audit logging
     - name: AUDITLOGGER_ENABLED

deploy/prod-gcp.yml

@@ -267,6 +267,8 @@ spec:
       value: "15"
     - name: VENTEFRIST_UTTALELSE
       value: "P14D"
+    - name: HENT_INNTEKT_HENDElSER_INTERVALL
+      value: "PT1M"
 
     # Audit logging
     - name: AUDITLOGGER_ENABLED