Støtte for uttalelse og svar journalpost

qtips · qtips · commit 5b732096a57f · 2025-03-20T23:39:56.000+01:00
diff --git a/behandlingslager/domene/src/main/java/no/nav/ung/sak/behandlingslager/etterlysning/EtterlysningEntitet.java b/behandlingslager/domene/src/main/java/no/nav/ung/sak/behandlingslager/etterlysning/EtterlysningEntitet.java
@@ -5,17 +5,22 @@
 
 import org.hibernate.annotations.Immutable;
 
+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.JoinColumn;
+import jakarta.persistence.OneToOne;
 import jakarta.persistence.Table;
 import no.nav.ung.kodeverk.etterlysning.EtterlysningStatus;
 import no.nav.ung.kodeverk.etterlysning.EtterlysningType;
 import no.nav.ung.sak.behandlingslager.BaseEntitet;
 import no.nav.ung.sak.domene.typer.tid.DatoIntervallEntitet;
+import no.nav.ung.sak.typer.JournalpostId;
 
 @Entity(name = "Etterlysning")
 @Table(name = "ETTERLYSNING")
@@ -50,6 +55,14 @@ public class EtterlysningEntitet extends BaseEntitet {
     @Column(name = "frist")
     private LocalDateTime frist;
 
+    @Embedded
+    @AttributeOverrides(@AttributeOverride(name = "journalpostId", column = @Column(name = "svar_journalpost_id")))
+    private JournalpostId svarJournalpostId;
+
+    @OneToOne
+    @JoinColumn(name = "id", referencedColumnName = "etterlysning_id")
+    private UttalelseEntitet uttalelse;
+
     private EtterlysningEntitet() {
         // Hibernate
     }
@@ -131,10 +144,24 @@ public void skalAvbrytes() {
         this.status = EtterlysningStatus.SKAL_AVBRYTES;
     }
 
-    public void mottattSvar() {
+    public void mottattSvar(JournalpostId svarJournalpostId) {
         if (status != EtterlysningStatus.VENTER) {
             throw new IllegalStateException("Kan ikke motta svar på etterlysning som ikke er satt til VENTER. Status er " + status);
         }
+        this.svarJournalpostId = svarJournalpostId;
         this.status = EtterlysningStatus.MOTTATT_SVAR;
     }
+
+    public void mottattUttalelse(String uttalelse, JournalpostId svarJournalpostId) {
+        mottattSvar(svarJournalpostId);
+        this.uttalelse = new UttalelseEntitet(uttalelse, this.id);
+    }
+
+    public JournalpostId getSvarJournalpostId() {
+        return svarJournalpostId;
+    }
+
+    public UttalelseEntitet getUttalelse() {
+        return uttalelse;
+    }
 }
diff --git a/behandlingslager/domene/src/main/java/no/nav/ung/sak/behandlingslager/etterlysning/EtterlysningRepository.java b/behandlingslager/domene/src/main/java/no/nav/ung/sak/behandlingslager/etterlysning/EtterlysningRepository.java
@@ -25,12 +25,15 @@ public EtterlysningRepository(EntityManager entityManager) {
     }
 
     public EtterlysningEntitet lagre(EtterlysningEntitet etterlysning) {
+        if (etterlysning.getUttalelse() != null) {
+            entityManager.persist(etterlysning.getUttalelse());
+        }
         entityManager.persist(etterlysning);
         return etterlysning;
     }
 
     public List<EtterlysningEntitet> lagre(List<EtterlysningEntitet> etterlysninger) {
-        etterlysninger.forEach(entityManager::persist);
+        etterlysninger.forEach(this::lagre);
         return etterlysninger;
     }
 
diff --git a/behandlingslager/domene/src/main/java/no/nav/ung/sak/behandlingslager/etterlysning/UttalelseEntitet.java b/behandlingslager/domene/src/main/java/no/nav/ung/sak/behandlingslager/etterlysning/UttalelseEntitet.java
@@ -0,0 +1,43 @@
+package no.nav.ung.sak.behandlingslager.etterlysning;
+
+import org.hibernate.annotations.Immutable;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import no.nav.ung.sak.behandlingslager.BaseEntitet;
+
+@Entity(name = "Uttalelse")
+@Table(name = "UTTALELSE")
+@Immutable
+public class UttalelseEntitet extends BaseEntitet {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "seq_uttalelse")
+    private Long id;
+
+    @Column(name = "uttalelse", updatable = false, nullable = false)
+    private String uttalelseTekst;
+
+    @Column(name = "etterlysning_id", updatable = false, nullable = false)
+    private long etterlysningId;
+
+
+    private UttalelseEntitet() {
+        // Hibernate
+    }
+
+    public UttalelseEntitet(String uttalelseTekst, long etterlysningId) {
+        this.uttalelseTekst = uttalelseTekst;
+        this.etterlysningId = etterlysningId;
+    }
+
+
+    public String getUttalelseTekst() {
+        return uttalelseTekst;
+    }
+
+}
diff --git a/behandlingslager/domene/src/main/resources/META-INF/pu-default.etterlysning.orm.xml b/behandlingslager/domene/src/main/resources/META-INF/pu-default.etterlysning.orm.xml
@@ -7,5 +7,6 @@
     <sequence-generator name="SEQ_ETTERLYSNING" allocation-size="50" sequence-name="SEQ_ETTERLYSNING"/>
 
     <entity class="no.nav.ung.sak.behandlingslager.etterlysning.EtterlysningEntitet"/>
+    <entity class="no.nav.ung.sak.behandlingslager.etterlysning.UttalelseEntitet"/>
 
 </entity-mappings>
diff --git a/domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/oppgavebekreftelse/InntektBekreftelseHåndterer.java b/domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/oppgavebekreftelse/InntektBekreftelseHåndterer.java
@@ -49,9 +49,6 @@ public class InntektBekreftelseHåndterer implements BekreftelseHåndterer {
         // lagre grunnlag
         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();
@@ -67,7 +64,12 @@ public class InntektBekreftelseHåndterer implements BekreftelseHåndterer {
         // hent tilhørende etterlysning og marker den som løst
         UUID oppgaveId = inntektBekreftelse.getOppgaveId();
         EtterlysningEntitet etterlysning = etterlysningRepository.hentEtterlysningForEksternReferanse(oppgaveId);
-        etterlysning.mottattSvar();
+
+        if (inntektBekreftelse.getUttalelseFraBruker() != null) {
+            etterlysning.mottattUttalelse(inntektBekreftelse.getUttalelseFraBruker(), oppgaveBekreftelseInnhold.journalpostId());
+        } else {
+            etterlysning.mottattSvar(oppgaveBekreftelseInnhold.journalpostId());
+        }
         etterlysningRepository.lagre(etterlysning);
 
     }
diff --git a/domenetjenester/mottak/src/test/java/no/nav/ung/sak/mottak/dokumentmottak/oppgavebekreftelse/InntektBekreftelseHåndtererTest.java b/domenetjenester/mottak/src/test/java/no/nav/ung/sak/mottak/dokumentmottak/oppgavebekreftelse/InntektBekreftelseHåndtererTest.java
@@ -35,7 +35,6 @@
 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;
@@ -51,8 +50,6 @@ class InntektBekreftelseHåndtererTest {
 
     @Inject
     private EntityManager em;
-    @Inject
-    private BehandlingskontrollTjeneste behandlingskontrollTjeneste;
     private EtterlysningRepository etterlysningRepository;
     private ProsessTaskTjeneste prosessTaskTjeneste;
 
@@ -66,7 +63,7 @@ void setup() {
     }
 
     @Test
-    void skalOppdatereEtterlysningOppdatereIayGrunnlagLagreUttalelseOgSetteBehandlingAvVent() {
+    void skalOppdatereEtterlysningOppdatereIayGrunnlagOgSetteBehandlingAvVent() {
         // Arrange
         TestScenarioBuilder scenarioBuilder = TestScenarioBuilder.builderMedSøknad()
             .medBehandlingType(BehandlingType.REVURDERING);
@@ -103,7 +100,7 @@ void skalOppdatereEtterlysningOppdatereIayGrunnlagLagreUttalelseOgSetteBehandlin
                         BigDecimal.valueOf(oppgittInntekt),
                         BigDecimal.ZERO)),
                     true,
-                    "uttalelse")
+                    "en uttalelse")
             ),
             LocalDateTime.now(),
             Brevkode.UNGDOMSYTELSE_OPPGAVE_BEKREFTELSE
@@ -112,6 +109,7 @@ void skalOppdatereEtterlysningOppdatereIayGrunnlagLagreUttalelseOgSetteBehandlin
         // Act
         var inntektBekreftelseHåndterer = new InntektBekreftelseHåndterer(etterlysningRepository, prosessTaskTjeneste);
         inntektBekreftelseHåndterer.håndter(bekreftelse);
+        em.flush();
 
         // Assert
         //abakus er oppdatert
@@ -130,5 +128,12 @@ void skalOppdatereEtterlysningOppdatereIayGrunnlagLagreUttalelseOgSetteBehandlin
         //etterlysning er oppdatert
         var oppdatertEtterlysning = etterlysningRepository.hentEtterlysning(etterlysning.getId());
         assertThat(oppdatertEtterlysning.getStatus()).isEqualTo(EtterlysningStatus.MOTTATT_SVAR);
+        assertThat(oppdatertEtterlysning.getSvarJournalpostId().getJournalpostId().getVerdi()).isEqualTo(String.valueOf(journalpostId));
+        assertThat(oppdatertEtterlysning.getUttalelse().getUttalelseTekst()).isEqualTo("en uttalelse");
+    }
+
+    @Test
+    void skalIkkeOppdatereGrunnlagVedUttalelse(){
+
     }
 }
diff --git a/migreringer/src/main/resources/db/postgres/defaultDS/1.0/V1.0_022__uttalelse.sql b/migreringer/src/main/resources/db/postgres/defaultDS/1.0/V1.0_022__uttalelse.sql
@@ -0,0 +1,21 @@
+create table uttalelse
+(
+    id              bigint      not null primary key,
+    uttalelse      text        not null,
+    etterlysning_id bigint      not null references etterlysning (id),
+    opprettet_tid   timestamp            default CURRENT_TIMESTAMP not null,
+    opprettet_av    varchar(20) not null default 'VL',
+    endret_av       varchar(20),
+    endret_tid      timestamp
+);
+
+create sequence if not exists seq_uttalelse increment by 50 minvalue 1000000;
+
+comment on table uttalelse is 'Inneholder uttalelser typisk ved uenigheter på etterlysninger';
+comment on column uttalelse.uttalelse is 'Uttalelsetekst';
+
+alter table etterlysning add svar_journalpost_id varchar(20);
+comment on column etterlysning.svar_journalpost_id is 'journalpost_id for svar på etterlysning';
+
+create unique index idx_etterlysning_ekstern_ref on etterlysning (ekstern_ref);
+

Original file line number	Diff line number	Diff line change
`@@ -25,12 +25,15 @@ public EtterlysningRepository(EntityManager entityManager) {`
`25`	`25`	`}`
`26`	`26`
`27`	`27`	`public EtterlysningEntitet lagre(EtterlysningEntitet etterlysning) {`
	`28`	`+ if (etterlysning.getUttalelse() != null) {`
	`29`	`+ entityManager.persist(etterlysning.getUttalelse());`
	`30`	`+ }`
`28`	`31`	`entityManager.persist(etterlysning);`
`29`	`32`	`return etterlysning;`
`30`	`33`	`}`
`31`	`34`
`32`	`35`	`public List<EtterlysningEntitet> lagre(List<EtterlysningEntitet> etterlysninger) {`
`33`		`- etterlysninger.forEach(entityManager::persist);`
	`36`	`+ etterlysninger.forEach(this::lagre);`
`34`	`37`	`return etterlysninger;`
`35`	`38`	`}`
`36`	`39`