Ung fordel

.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="21" />
+    <option name="ALTERNATIVE_JRE_PATH" value="temurin-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

@@ -75,9 +75,6 @@ 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;
@@ -143,10 +140,6 @@ public String getKildesystem() {
         return kildesystem;
     }
 
-    public String getKanalreferanse() {
-        return kanalreferanse;
-    }
-
     public String getFeilmelding() {
         return feilmelding;
     }
@@ -224,10 +217,6 @@ 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);
@@ -276,11 +265,6 @@ 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;
@@ -348,7 +332,6 @@ public int hashCode() {
     @Override
     public String toString() {
         return getClass().getSimpleName() + "<journalpostId=" + journalpostId
-            + ", kanalReferanse=" + kanalreferanse
             + ", arbeidsgiver=" + arbeidsgiver
             + ", type=" + type
             + ", journalpostId=" + journalpostId

deploy/dev-gcp.yml

@@ -151,6 +151,12 @@ 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
@@ -241,6 +247,8 @@ 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
 
@@ -262,6 +270,8 @@ spec:
     # Konfigurasjoner
     - name: FLYWAY_REPAIR_ON_FAIL
       value: "false"
+    - name: INNSENDING_HENDELSER_FORSINKELSE
+      value: "PT1M"
 
       # Audit logging
     - name: AUDITLOGGER_ENABLED

deploy/prod-gcp.yml

@@ -233,6 +233,8 @@ 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
 
@@ -255,6 +257,8 @@ 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,14 +5,12 @@
 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::getMottattDato)
-            .thenComparing(MottattDokument::getKanalreferanse, nullSafeStringComparator);
+        return Comparator.comparing(MottattDokument::getMottattTidspunkt);
     }
 }

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

@@ -17,7 +17,6 @@ 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;
@@ -58,10 +57,6 @@ public UUID getForsendelseId() {
         return forsendelseId;
     }
 
-    public String getKanalreferanse() {
-        return kanalreferanse;
-    }
-
     public String getJournalEnhet() {
         return journalEnhet;
     }
@@ -114,11 +109,6 @@ 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,7 +68,6 @@ 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.LocalDate;
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -12,45 +12,19 @@
 
 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
-            .medMottattDato(LocalDate.now())
+            .medMottattTidspunkt(LocalDateTime.now())
             .medFagsakId(41337L);
 
         MottattDokument første = builder.build();
 
         MottattDokument.Builder builder2 = new MottattDokument.Builder();
-        builder2.medMottattDato(LocalDate.now().plusDays(1))
+        builder2.medMottattTidspunkt(LocalDateTime.now().plusDays(1))
             .medFagsakId(41337L);
         MottattDokument andre = builder2.build();
 
@@ -63,30 +37,4 @@ 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,9 +16,11 @@
 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;
@@ -33,10 +35,6 @@ 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";
@@ -79,21 +77,20 @@ Optional<OrganisasjonsEnhet> oppdaterEnhetSjekkOppgittePersoner(FagsakYtelseType
         return Optional.empty();
     }
 
-    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();
+    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());
     }
 
     OrganisasjonsEnhet hentEnhetSjekkKunAktør(AktørId aktørId, FagsakYtelseType ytelseType) {

fordel/pom.xml

@@ -0,0 +1,64 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>no.nav.ung.sak</groupId>
+        <artifactId>ung-sak</artifactId>
+        <version>${revision}${sha1}${changelist}</version>
+    </parent>
+
+    <artifactId>fordel</artifactId>
+    <packaging>jar</packaging>
+    <name>ung-sak :: Fordel</name>
+
+    <dependencies>
+        <dependency>
+            <groupId>no.nav.teamdokumenthandtering</groupId>
+            <artifactId>teamdokumenthandtering-avro-schemas</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>io.confluent</groupId>
+            <artifactId>kafka-avro-serializer</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.confluent</groupId>
+            <artifactId>kafka-streams-avro-serde</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>no.nav.ung.sak</groupId>
+            <artifactId>mottak</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>no.nav.ung.sak</groupId>
+            <artifactId>hendelsemottak</artifactId>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.avro</groupId>
+                <artifactId>avro-maven-plugin</artifactId>
+                <version>1.12.0</version>
+
+                <executions>
+                    <execution>
+                        <phase>generate-sources</phase>
+                        <goals>
+                            <goal>idl-protocol</goal>
+                        </goals>
+                        <configuration>
+                            <sourceDirectory>src/main/resources/avro/leesah</sourceDirectory>
+                            <outputDirectory>${project.build.directory}/generated-sources</outputDirectory>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>