Revert "Ung fordel (#112)"

This reverts commit 95d97f3

Author: qtips

.run/Ung-sak JettyDevServer.run.xml

@@ -1,6 +1,6 @@
 <component name="ProjectRunConfigurationManager">
   <configuration default="false" name="Ung-sak JettyDevServer" type="Application" factoryName="Application">
-    <option name="ALTERNATIVE_JRE_PATH" value="temurin-21" />
+    <option name="ALTERNATIVE_JRE_PATH" value="21" />
     <option name="ALTERNATIVE_JRE_PATH_ENABLED" value="true" />
     <option name="MAIN_CLASS_NAME" value="no.nav.ung.sak.web.server.jetty.JettyDevServer" />
     <module name="web-webapp" />

behandlingslager/domene/src/main/java/no/nav/ung/sak/behandlingslager/behandling/motattdokument/MottattDokument.java

@@ -8,6 +8,10 @@
 import java.time.LocalDateTime;
 import java.util.Objects;
 
+import org.hibernate.annotations.DynamicInsert;
+import org.hibernate.annotations.DynamicUpdate;
+import org.hibernate.engine.jdbc.ClobProxy;
+
 import jakarta.persistence.AttributeOverride;
 import jakarta.persistence.AttributeOverrides;
 import jakarta.persistence.Column;
@@ -22,11 +26,6 @@
 import jakarta.persistence.Table;
 import jakarta.persistence.Transient;
 import jakarta.persistence.Version;
-
-import org.hibernate.annotations.DynamicInsert;
-import org.hibernate.annotations.DynamicUpdate;
-import org.hibernate.engine.jdbc.ClobProxy;
-
 import no.nav.ung.kodeverk.dokument.Brevkode;
 import no.nav.ung.kodeverk.dokument.DokumentStatus;
 import no.nav.ung.sak.behandlingslager.BaseEntitet;
@@ -75,6 +74,9 @@ public class MottattDokument extends BaseEntitet {
     @Column(name = "kildesystem")
     private String kildesystem;
 
+    @Column(name = "kanalreferanse", updatable = false)
+    private String kanalreferanse;
+
     /** Arbeidsgiver referanse - orgnummer eller privat arbeidsgiver fnr. */
     @Column(name = "arbeidsgiver")
     private String arbeidsgiver;
@@ -140,6 +142,10 @@ public String getKildesystem() {
         return kildesystem;
     }
 
+    public String getKanalreferanse() {
+        return kanalreferanse;
+    }
+
     public String getFeilmelding() {
         return feilmelding;
     }
@@ -217,6 +223,10 @@ public void setKildesystem(String systemnavn) {
         this.kildesystem = systemnavn;
     }
 
+    public void setKanalreferanse(String kanalreferanse) {
+        this.kanalreferanse = kanalreferanse;
+    }
+
     public void setFeilmeldingOgOppdaterStatus(String feilmelding) {
         this.feilmelding = feilmelding;
         setStatus(feilmelding == null ? DokumentStatus.GYLDIG : DokumentStatus.UGYLDIG);
@@ -265,6 +275,11 @@ public Builder medMottattTidspunkt(LocalDateTime mottattTidspunkt) {
             return this;
         }
 
+        public Builder medKanalreferanse(String kanalreferanse) {
+            mottatteDokumentMal.kanalreferanse = kanalreferanse;
+            return this;
+        }
+
         public Builder medStatus(DokumentStatus status) {
             mottatteDokumentMal.setStatus(status);
             return this;
@@ -332,6 +347,7 @@ public int hashCode() {
     @Override
     public String toString() {
         return getClass().getSimpleName() + "<journalpostId=" + journalpostId
+            + ", kanalReferanse=" + kanalreferanse
             + ", arbeidsgiver=" + arbeidsgiver
             + ", type=" + type
             + ", journalpostId=" + journalpostId

deploy/dev-gcp.yml

@@ -22,9 +22,6 @@ spec:
     timeout: 5
     periodSeconds: 10
     failureThreshold: 27
-  preStopHook:
-    http:
-      path: /ung/sak/internal/health/preStop
   replicas:
     min: 2
     max: 2
@@ -92,7 +89,6 @@ spec:
         - host: "pdl-api.dev-fss-pub.nais.io"
         - host: "saf-q2.dev-fss-pub.nais.io"
         - host: "norg2.dev-fss-pub.nais.io"
-        - host: "dokarkiv-q2.dev-fss-pub.nais.io"
     inbound:
       rules:
         - application: ung-sak
@@ -155,12 +151,6 @@ spec:
       value: omsorgspenger.k9-rapid-v2
     - name: KAFKA_INFOTRYGDFEED_AIVEN_TOPIC
       value: k9saksbehandling.k9-infotrygd-feed-hendelse
-    - name: HENDELSE_PERSON_LEESAH_TOPIC
-      value: pdl.leesah-v1
-    - name: KAFKA_JOURNAL_TOPIC
-      value: teamdokumenthandtering.aapen-dok-journalfoering
-
-
 
     # Baseurl
     - name: SCHEMA_REGISTRY_URL
@@ -251,8 +241,6 @@ spec:
       value: api://dev-fss.teamdokumenthandtering.saf/.default
     - name: DOKARKIV_URL
       value: https://dokarkiv-q2.dev-fss-pub.nais.io/rest/journalpostapi/v1
-    - name: DOKARKIV_BASE_URL
-      value: https://dokarkiv-q2.dev-fss-pub.nais.io
     - name: DOKARKIV_SCOPE
       value: api://dev-fss.teamdokumenthandtering.dokarkiv/.default
 
@@ -274,8 +262,6 @@ spec:
     # Konfigurasjoner
     - name: FLYWAY_REPAIR_ON_FAIL
       value: "false"
-    - name: INNSENDING_HENDELSER_FORSINKELSE
-      value: "PT1M"
 
       # Audit logging
     - name: AUDITLOGGER_ENABLED

deploy/prod-gcp.yml

@@ -22,9 +22,6 @@ spec:
     timeout: 5
     periodSeconds: 10
     failureThreshold: 27
-  preStopHook:
-    http:
-      path: /ung/sak/internal/health/preStop
   replicas:
     min: 2
     max: 2
@@ -92,7 +89,6 @@ spec:
         - host: "pdl-api.prod-fss-pub.nais.io"
         - host: "saf.prod-fss-pub.nais.io"
         - host: "norg2.prod-fss-pub.nais.io"
-        - host: "dokarkiv.prod-fss-pub.nais.io"
     inbound:
       rules:
         - application: ung-sak
@@ -237,8 +233,6 @@ spec:
       value: api://prod-fss.teamdokumenthandtering.saf/.default
     - name: DOKARKIV_URL
       value: https://dokarkiv.prod-fss-pub.nais.io/rest/journalpostapi/v1
-    - name: DOKARKIV_BASE_URL
-      value: https://dokarkiv.prod-fss-pub.nais.io
     - name: DOKARKIV_SCOPE
       value: api://prod-fss.teamdokumenthandtering.dokarkiv/.default
 
@@ -261,8 +255,6 @@ spec:
     # Konfigurasjoner
     - name: FLYWAY_REPAIR_ON_FAIL
       value: "false"
-    - name: INNSENDING_HENDELSER_FORSINKELSE
-      value: "PT1H"
 
     # Audit logging
     - name: AUDITLOGGER_ENABLED

domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/MottattDokumentSorterer.java

@@ -5,12 +5,14 @@
 import no.nav.ung.sak.behandlingslager.behandling.motattdokument.MottattDokument;
 
 class MottattDokumentSorterer {
+    private static Comparator<String> nullSafeStringComparator = Comparator.nullsFirst(String::compareToIgnoreCase);
 
     private MottattDokumentSorterer() {
         // skjul public constructor
     }
 
     static Comparator<MottattDokument> sorterMottattDokument() {
-        return Comparator.comparing(MottattDokument::getMottattTidspunkt);
+        return Comparator.comparing(MottattDokument::getMottattDato)
+            .thenComparing(MottattDokument::getKanalreferanse, nullSafeStringComparator);
     }
 }

domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/InngåendeSaksdokument.java

@@ -17,6 +17,7 @@ public class InngåendeSaksdokument {
     private Boolean elektroniskSøknad;
     private String payload;
     private UUID forsendelseId;
+    private String kanalreferanse;
     private String journalEnhet;
     private Brevkode type;
     private FagsakYtelseType fagsakYtelseType;
@@ -57,6 +58,10 @@ public UUID getForsendelseId() {
         return forsendelseId;
     }
 
+    public String getKanalreferanse() {
+        return kanalreferanse;
+    }
+
     public String getJournalEnhet() {
         return journalEnhet;
     }
@@ -109,6 +114,11 @@ public static class Builder {
             return this;
         }
 
+        public InngåendeSaksdokument.Builder medKanalreferanse(String kanalreferanse) {
+            this.kladd.kanalreferanse = kanalreferanse;
+            return this;
+        }
+
         public InngåendeSaksdokument.Builder medJournalførendeEnhet(String journalEnhet) {
             this.kladd.journalEnhet = journalEnhet;
             return this;

domenetjenester/mottak/src/main/java/no/nav/ung/sak/mottak/dokumentmottak/SaksbehandlingDokumentmottakTjeneste.java

@@ -68,6 +68,7 @@ public void dokumenterAnkommet(Collection<InngåendeSaksdokument> saksdokumenter
                 .medFagsakId(saksdokument.getFagsakId());
 
             builder.medMottattTidspunkt(mottattTidspunkt);
+            builder.medKanalreferanse(saksdokument.getKanalreferanse());
 
             if (saksdokument.getJournalpostId() != null) {
                 builder.medJournalPostId(new JournalpostId(saksdokument.getJournalpostId().getVerdi()));

domenetjenester/mottak/src/test/java/no/nav/ung/sak/mottak/MottattDokumentSortererTest.java

@@ -1,7 +1,7 @@
 package no.nav.ung.sak.mottak;
 
 
-import java.time.LocalDateTime;
+import java.time.LocalDate;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -12,19 +12,45 @@
 
 public class MottattDokumentSortererTest {
 
+    @Test
+    public void skal_sortere_etter_mottatt_dag_og_kanalref_når_dag_er_lik() {
+        // Arrange
+        MottattDokument.Builder builder = new MottattDokument.Builder();
+        builder
+            .medMottattDato(LocalDate.now())
+            .medFagsakId(41337L)
+            .medKanalreferanse("AR307765531");
+
+        MottattDokument første = builder.build();
+
+
+        MottattDokument.Builder builder2 = new MottattDokument.Builder();
+        builder2.medMottattDato(LocalDate.now())
+            .medFagsakId(41337L)
+            .medKanalreferanse("AR317765531");
+        MottattDokument andre = builder2.build();
+
+        List<MottattDokument> dokumenter = List.of(andre, første);
+
+        // Act
+        List<MottattDokument> sortert = dokumenter.stream().sorted(MottattDokumentSorterer.sorterMottattDokument()).collect(Collectors.toList());
+
+        // Assert
+        Assertions.assertThat(sortert).containsExactly(første, andre);
+    }
 
     @Test
     public void skal_sortere_etter_mottatt_dag_når_den_er_ulik() {
         // Arrange
         MottattDokument.Builder builder = new MottattDokument.Builder();
         builder
-            .medMottattTidspunkt(LocalDateTime.now())
+            .medMottattDato(LocalDate.now())
             .medFagsakId(41337L);
 
         MottattDokument første = builder.build();
 
         MottattDokument.Builder builder2 = new MottattDokument.Builder();
-        builder2.medMottattTidspunkt(LocalDateTime.now().plusDays(1))
+        builder2.medMottattDato(LocalDate.now().plusDays(1))
             .medFagsakId(41337L);
         MottattDokument andre = builder2.build();
 
@@ -37,4 +63,30 @@ public class MottattDokumentSortererTest {
         Assertions.assertThat(sortert).containsExactly(første, andre);
     }
 
+    @Test
+    public void skal_ikke_feile_når_kanalref_er_null() {
+        // Arrange
+        MottattDokument.Builder builder = new MottattDokument.Builder();
+        builder
+            .medMottattDato(LocalDate.now())
+            .medFagsakId(41337L)
+            .medKanalreferanse(null);
+
+        MottattDokument første = builder.build();
+
+
+        MottattDokument.Builder builder2 = new MottattDokument.Builder();
+        builder2.medMottattDato(LocalDate.now())
+            .medFagsakId(41337L)
+            .medKanalreferanse("AR317765531");
+        MottattDokument andre = builder2.build();
+
+        List<MottattDokument> dokumenter = List.of(andre, første);
+
+        // Act
+        List<MottattDokument> sortert = dokumenter.stream().sorted(MottattDokumentSorterer.sorterMottattDokument()).collect(Collectors.toList());
+
+        // Assert
+        Assertions.assertThat(sortert).containsExactly(første, andre);
+    }
 }

domenetjenester/produksjonsstyring/src/main/java/no/nav/ung/sak/produksjonsstyring/behandlingenhet/EnhetsTjeneste.java

@@ -16,11 +16,9 @@
 import no.nav.k9.felles.integrasjon.arbeidsfordeling.rest.ArbeidsfordelingRequest;
 import no.nav.k9.felles.integrasjon.arbeidsfordeling.rest.ArbeidsfordelingResponse;
 import no.nav.k9.felles.integrasjon.arbeidsfordeling.rest.ArbeidsfordelingRestKlient;
-import no.nav.ung.kodeverk.behandling.BehandlingTema;
 import no.nav.ung.kodeverk.behandling.BehandlingType;
 import no.nav.ung.kodeverk.behandling.FagsakYtelseType;
 import no.nav.ung.kodeverk.person.Diskresjonskode;
-import no.nav.ung.kodeverk.produksjonsstyring.OmrådeTema;
 import no.nav.ung.kodeverk.produksjonsstyring.OrganisasjonsEnhet;
 import no.nav.ung.sak.behandlingslager.aktør.GeografiskTilknytning;
 import no.nav.ung.sak.domene.person.tps.TpsTjeneste;
@@ -35,6 +33,10 @@ static class EnhetsTjenesteData {
         OrganisasjonsEnhet enhetKlage;
         List<OrganisasjonsEnhet> alleBehandlendeEnheter;
         LocalDate sisteInnhenting = LocalDate.MIN;
+
+        Optional<OrganisasjonsEnhet> finnOrganisasjonsEnhet(String enhetId) {
+            return alleBehandlendeEnheter.stream().filter(e -> enhetId.equals(e.getEnhetId())).findFirst();
+        }
     }
 
     private static final String NK_ENHET_ID = "4292";
@@ -77,20 +79,21 @@ Optional<OrganisasjonsEnhet> oppdaterEnhetSjekkOppgittePersoner(FagsakYtelseType
         return Optional.empty();
     }
 
-    public List<OrganisasjonsEnhet> hentFordelingEnhetId(OmrådeTema tema, BehandlingTema behandlingsTema, GeografiskTilknytning geo) {
-        var request = ArbeidsfordelingRequest.ny()
-            .medTema(tema.getOffisiellKode())
-            .medBehandlingstema(behandlingsTema == null ? null : behandlingsTema.getOffisiellKode())
-            .medDiskresjonskode(geo.getDiskresjonskode().getKode())
-            .medGeografiskOmraade(geo.getTilknytning())
-            .build();
-
-        return arbeidsfordelingTjeneste
-            .finnEnhet(request)
-            .stream()
-            .filter(response -> "AKTIV".equalsIgnoreCase(response.getStatus()))
-            .map(r -> new OrganisasjonsEnhet(r.getEnhetNr(), r.getEnhetNavn()))
-            .collect(Collectors.toList());
+    Optional<OrganisasjonsEnhet> oppdaterEnhetSjekkRegistrerteRelasjoner(FagsakYtelseType ytelseType,
+                                                                         String enhetId,
+                                                                         AktørId hovedAktør,
+                                                                         Collection<AktørId> alleAktører) {
+        var cacheEntry = oppdaterEnhetCache(ytelseType);
+        if (cacheEntry.enhetKode6.getEnhetId().equals(enhetId) || NK_ENHET_ID.equals(enhetId)) {
+            return Optional.empty();
+        }
+        if (harNoenDiskresjonskode6(alleAktører)) {
+            return Optional.of(cacheEntry.enhetKode6);
+        }
+        if (cacheEntry.finnOrganisasjonsEnhet(enhetId).isEmpty()) {
+            return Optional.of(hentEnhetSjekkKunAktør(hovedAktør, ytelseType));
+        }
+        return Optional.empty();
     }
 
     OrganisasjonsEnhet hentEnhetSjekkKunAktør(AktørId aktørId, FagsakYtelseType ytelseType) {