Brevbestilling task (#92)

Brevbestilling task som journalfører og distribuerer. Bruker egen tabell tilsvarende det i k9-formidling for å holde oversikt over brevbestillinger. Distribusjon må gjøres i egen task fordi journalføring og distribusjon ikke er idempotent.  

* Opprett brevbestillings task etter iverksetting.

* støtte for å svare med html basert på accept header

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

* støtte for versjon og aktiv flagg for å manuelt stoppe brev

Gjenstår: 
- utlede og hente data til templates fra behandlingtilstand
- få andre brev (type varsel) til å funke med samme oppsett. 
- tester med TODOs

skip-checks:true



---------

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

Author: qtips

deploy/dev-gcp.yml

@@ -222,11 +222,19 @@ spec:
     - name: UNGDOMSPROGRAMREGISTER_SCOPE
       value: api://dev-gcp.k9saksbehandling.ung-deltakelse-opplyser/.default
 
-    # Graphql services
+    # Saf
     - name: SAF_BASE_URL
       value: https://saf-q2.dev-fss-pub.nais.io
     - name: SAF_SCOPE
       value: api://dev-fss.teamdokumenthandtering.saf/.default
+    - name: DOKDISTFORDELING_URL
+      value: https://dokdistfordeling.dev-fss-pub.nais.io/rest/v1
+    - name: DOKDISTFORDELING_SCOPE
+      value: api://dev-fss.teamdokumenthandtering.saf/.default
+    - name: DOKARKIV_URL
+      value: https://dokarkiv-q2.dev-fss-pub.nais.io/rest/journalpostapi/v1
+    - name: DOKARKIV_SCOPE
+      value: api://dev-fss.teamdokumenthandtering.dokarkiv/.default
 
     # Sikkerhet:
     - name: CLIENT_SCOPE

deploy/prod-gcp.yml

@@ -193,11 +193,19 @@ spec:
     - name: UNGDOMSPROGRAMREGISTER_SCOPE
       value: api://prod-gcp.k9saksbehandling.ung-deltakelse-opplyser/.default
 
-    # Graphql services
+    # Saf
     - name: SAF_BASE_URL
       value: https://saf.prod-fss-pub.nais.io
     - name: SAF_SCOPE
       value: api://prod-fss.teamdokumenthandtering.saf/.default
+    - name: DOKDISTFORDELING_URL
+      value: https://dokdistfordeling.prod-fss-pub.nais.io/rest/v1
+    - name: DOKDISTFORDELING_SCOPE
+      value: api://prod-fss.teamdokumenthandtering.saf/.default
+    - name: DOKARKIV_URL
+      value: https://dokarkiv.prod-fss-pub.nais.io/rest/journalpostapi/v1
+    - name: DOKARKIV_SCOPE
+      value: api://prod-fss.teamdokumenthandtering.dokarkiv/.default
 
     # Sikkerhet:
     - name: CLIENT_SCOPE

domenetjenester/vedtak/pom.xml

@@ -37,6 +37,10 @@
             <groupId>no.nav.ung.sak</groupId>
             <artifactId>skjaeringstidspunkt</artifactId>
         </dependency>
+        <dependency>
+            <groupId>no.nav.ung.sak</groupId>
+            <artifactId>formidling</artifactId>
+        </dependency>
 
 		<!-- Prosjektinterne avhengigheter -->
 		<dependency>

domenetjenester/vedtak/src/main/java/no/nav/ung/sak/domene/vedtak/observer/VedtakFattetEventObserver.java

@@ -8,6 +8,7 @@
 import no.nav.k9.prosesstask.api.ProsessTaskTjeneste;
 import no.nav.ung.kodeverk.vedtak.IverksettingStatus;
 import no.nav.ung.sak.behandlingslager.behandling.vedtak.BehandlingVedtakEvent;
+import no.nav.ung.sak.formidling.BrevbestillingTask;
 
 @ApplicationScoped
 public class VedtakFattetEventObserver {
@@ -24,7 +25,7 @@ public VedtakFattetEventObserver(ProsessTaskTjeneste taskTjeneste) {
 
     public void observerBehandlingVedtak(@Observes BehandlingVedtakEvent event) {
         if (IverksettingStatus.IVERKSATT.equals(event.getVedtak().getIverksettingStatus())) {
-            var gruppe = new ProsessTaskGruppe();
+            var gruppe = new ProsessTaskGruppe(opprettTaskForBrevbestilling(event));
 
             if (erBehandlingAvRettTypeForAbakus(event)) {
                 gruppe.addNesteSekvensiell(opprettTaskForPubliseringAvVedtakMedYtelse(event));
@@ -33,10 +34,19 @@ public void observerBehandlingVedtak(@Observes BehandlingVedtakEvent event) {
         }
     }
 
+    private static ProsessTaskData opprettTaskForBrevbestilling(BehandlingVedtakEvent event) {
+        ProsessTaskData prosessTaskData = ProsessTaskData.forProsessTask(BrevbestillingTask.class);
+        prosessTaskData.setBehandling(event.getFagsakId(), event.getBehandlingId());
+        return prosessTaskData;
+    }
+
+
     private boolean erBehandlingAvRettTypeForAbakus(BehandlingVedtakEvent event) {
         return event.getBehandling().erYtelseBehandling();
     }
 
+
+
     @Deprecated
     private ProsessTaskData opprettTaskForPubliseringAvVedtakMedYtelse(BehandlingVedtakEvent event) {
         final ProsessTaskData taskData = ProsessTaskData.forProsessTask(PubliserVedtattYtelseHendelseTask.class);

domenetjenester/vedtak/src/test/java/no/nav/ung/sak/domene/vedtak/observer/VedtakFattetEventObserverTest.java

@@ -1,5 +1,6 @@
 package no.nav.ung.sak.domene.vedtak.observer;
 
+import static org.assertj.core.api.Assertions.assertThat;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.never;
@@ -8,6 +9,7 @@
 import static org.mockito.Mockito.when;
 
 import java.time.LocalDateTime;
+import java.util.Collection;
 import java.util.Optional;
 
 import org.junit.jupiter.api.BeforeEach;
@@ -31,6 +33,7 @@
 import no.nav.ung.sak.behandlingslager.behandling.vedtak.BehandlingVedtakEvent;
 import no.nav.ung.sak.behandlingslager.behandling.vedtak.BehandlingVedtakRepository;
 import no.nav.ung.sak.db.util.JpaExtension;
+import no.nav.ung.sak.formidling.BrevbestillingTask;
 import no.nav.ung.sak.typer.AktørId;
 
 @ExtendWith(CdiAwareExtension.class)
@@ -59,16 +62,15 @@ public void setup() {
     }
 
     @Test
-    //TODO endre til å sjekke brevtask
     public void publisererVedtakForIverksatteVedtak() {
         var behandlingVedtakEvent = lagVedtakEvent(IverksettingStatus.IVERKSATT, VedtakResultatType.INNVILGET);
         vedtakFattetEventObserver.observerBehandlingVedtak(behandlingVedtakEvent);
 
         verify(prosessTaskRepository, times(1)).lagre(prosessTaskGruppeCaptorCaptor.capture());
-//        assertThat(prosessTaskGruppeCaptorCaptor.getAllValues().stream().map(ProsessTaskGruppe::getTasks)
-//            .flatMap(Collection::stream)
-//            .map(it -> it.getTask().getTaskType()))
-//            .containsExactlyInAnyOrder(PubliserVedtattYtelseHendelseTask.TASKTYPE, PubliserVedtakHendelseTask.TASKTYPE);
+        assertThat(prosessTaskGruppeCaptorCaptor.getAllValues().stream().map(ProsessTaskGruppe::getTasks)
+            .flatMap(Collection::stream)
+            .map(it -> it.getTask().getTaskType()))
+            .containsExactlyInAnyOrder(PubliserVedtattYtelseHendelseTask.TASKTYPE, BrevbestillingTask.TASKTYPE);
     }
 
     @Test
@@ -80,16 +82,15 @@ public void publisererVedtakForIverksatteVedtak() {
     }
 
     @Test
-    //TODO endre til å sjekke brevtask
     public void publisererKunGenereltVedtakseventVedAvslag() {
         var behandlingVedtakEvent = lagVedtakEvent(IverksettingStatus.IVERKSATT, VedtakResultatType.AVSLAG);
         vedtakFattetEventObserver.observerBehandlingVedtak(behandlingVedtakEvent);
 
-//        verify(prosessTaskRepository, times(1)).lagre(prosessTaskGruppeCaptorCaptor.capture());
-//        assertThat(prosessTaskGruppeCaptorCaptor.getAllValues().stream().map(ProsessTaskGruppe::getTasks)
-//            .flatMap(Collection::stream)
-//            .map(it -> it.getTask().getTaskType()))
-//            .containsExactly(PubliserVedtakHendelseTask.TASKTYPE, PubliserVedtattYtelseHendelseTask.TASKTYPE);
+        verify(prosessTaskRepository, times(1)).lagre(prosessTaskGruppeCaptorCaptor.capture());
+        assertThat(prosessTaskGruppeCaptorCaptor.getAllValues().stream().map(ProsessTaskGruppe::getTasks)
+            .flatMap(Collection::stream)
+            .map(it -> it.getTask().getTaskType()))
+            .containsExactly(BrevbestillingTask.TASKTYPE, PubliserVedtattYtelseHendelseTask.TASKTYPE);
     }
 
     private Behandling lagBehandling() {

formidling/src/main/java/no/nav/ung/sak/formidling/BrevGenerererTjeneste.java

@@ -5,16 +5,14 @@
 
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
-import no.nav.ung.kodeverk.formidling.IdType;
-import no.nav.ung.kodeverk.formidling.RolleType;
 import no.nav.ung.sak.behandlingslager.aktør.PersoninfoBasis;
 import no.nav.ung.sak.behandlingslager.behandling.Behandling;
 import no.nav.ung.sak.behandlingslager.behandling.repository.BehandlingRepository;
 import no.nav.ung.sak.domene.person.pdl.AktørTjeneste;
 import no.nav.ung.sak.domene.person.pdl.PersonBasisTjeneste;
 import no.nav.ung.sak.formidling.domene.GenerertBrev;
+import no.nav.ung.sak.formidling.domene.PdlPerson;
 import no.nav.ung.sak.formidling.dto.Brevbestilling;
-import no.nav.ung.sak.formidling.dto.PartResponseDto;
 import no.nav.ung.sak.formidling.pdfgen.PdfGenDokument;
 import no.nav.ung.sak.formidling.pdfgen.PdfGenKlient;
 import no.nav.ung.sak.formidling.template.TemplateInput;
@@ -63,30 +61,26 @@ public GenerertBrev generer(Brevbestilling brevbestilling) {
         // konverter til pdf fra templateData
         PdfGenDokument dokument = pdfGen.lagDokument(input);
 
-        var mottaker = mapPartResponseDto(pdlMottaker);
         return new GenerertBrev(
             dokument,
-            mottaker,
-            mottaker,
+            pdlMottaker,
+            pdlMottaker,
             brevbestilling.malType(),
             input.templateType()
         );
     }
 
-    private PartResponseDto mapPartResponseDto(PDLMottaker pdlMottaker) {
-        return new PartResponseDto(pdlMottaker.aktørId.getAktørId(), pdlMottaker.navn, IdType.AKTØRID, RolleType.BRUKER);
-    }
-
-    private PDLMottaker hentMottaker(Behandling behandling) {
+    private PdlPerson hentMottaker(Behandling behandling) {
         AktørId aktørId = behandling.getFagsak().getAktørId();
         var personIdent = aktørTjeneste.hentPersonIdentForAktørId(aktørId)
             .orElseThrow(() -> new IllegalArgumentException("Fant ikke person med aktørid"));
         PersoninfoBasis personinfoBasis = personBasisTjeneste.hentBasisPersoninfo(aktørId, personIdent);
 
         String fnr = personIdent.getIdent();
         Objects.requireNonNull(fnr);
-        return new PDLMottaker(fnr, aktørId, personinfoBasis.getNavn());
+        return new PdlPerson(fnr, aktørId, personinfoBasis.getNavn());
     }
 
-    record PDLMottaker(String fnr, AktørId aktørId, String navn) {}
+
 }
+

formidling/src/main/java/no/nav/ung/sak/formidling/BrevbestillingRepository.java

@@ -0,0 +1,53 @@
+package no.nav.ung.sak.formidling;
+
+import java.util.List;
+
+import jakarta.enterprise.context.Dependent;
+import jakarta.inject.Inject;
+import jakarta.persistence.EntityManager;
+import jakarta.persistence.TypedQuery;
+import no.nav.ung.sak.formidling.domene.BehandlingBrevbestillingEntitet;
+import no.nav.ung.sak.formidling.domene.BrevbestillingEntitet;
+
+@Dependent
+public class BrevbestillingRepository {
+    private final EntityManager entityManager;
+
+    @Inject
+    public BrevbestillingRepository(EntityManager entityManager) {
+        this.entityManager = entityManager;
+    }
+
+
+    public List<BehandlingBrevbestillingEntitet> hentForBehandling(Long behandlingId) {
+        TypedQuery<BehandlingBrevbestillingEntitet> query = entityManager.createQuery(
+            "from BehandlingBrevbestillingEntitet b where b.behandlingId = :behandlingId and aktiv = true",
+            BehandlingBrevbestillingEntitet.class
+        );
+        query.setParameter("behandlingId", behandlingId);
+
+        return query.getResultList();
+    }
+
+    public void lagreForBehandling(BehandlingBrevbestillingEntitet bestilling) {
+        entityManager.persist(bestilling);
+        entityManager.flush();
+    }
+
+    public void lagre(BrevbestillingEntitet bestilling) {
+        entityManager.persist(bestilling);
+        entityManager.flush();
+    }
+
+    public BrevbestillingEntitet hent(Long id) {
+        TypedQuery<BrevbestillingEntitet> query = entityManager.createQuery(
+            "from BrevbestillingEntitet b where b.id = :id and aktiv = true",
+            BrevbestillingEntitet.class
+        );
+        query.setParameter("id", id);
+
+        return query.getSingleResult();
+
+    }
+
+}