Skip to content

Commit 95d97f3

Browse files
espenjvgithub-actions[bot]ramrock93
authored
Ung fordel (#112)
* rebase * Fjerner støtte for journalføring på generell sak * Fjerner request for knyt t til annen sak * Fjerner orgnr * Erstatter prosesstaskrepo med tjeneste * Fjerner ubrukte metoder * Rename Behandlingtype * Fjerner frisinn ting * Fjerner inntektsmelding * Oppretter tabeller og sekvenser * Legger inn hendelseshåndtering * Legger til konfig * Legger til repo for avro schema i settings.xml * Legger til server * Fiks dependency * Legger til confluent repo * Fjerner repo fra settings.xml * Fjerner kanalreferanse * ung-sak.openapi.json updated by build pipeline skip-checks:true * Flytter kodeverk, slår sammen tjenester * Prøver å få den til å starte opp * Legger til healtchecks for kafka * Tvinger swagger-annotations til å bruke samme versjon som resten * ung-sak.openapi.json updated by build pipeline skip-checks:true * Legger til kafka.brokers i app-vtp.properties * Sette temurin som default * Flytter fordel inn i ung-sak * Fjerner mulighet for å opprette fagsak via rest * Fjerner duplikat metode * ung-sak.openapi.json updated by build pipeline skip-checks:true * Fjerner håndtering av legacy wrapper * Mapper direkte til saksdokumenter Legger til manglende props Fikser db kolonnenavn * Fjerner pleietrengende info fra fagsak søk * ung-sak.openapi.json updated by build pipeline skip-checks:true * Legger til test * Legger til test og fjerner ubrukt request * rename områdeTema tilbake til tema * Endringer etter QA * Fjerner FordelBehandlingtyper som ikkje er relevante * Gjer ytelsetype påkrevd * Fjerner ubrukte props entiteter * Retter kommentar på tabell * Retter kommentar på tabell * Retter kommentar på tabell * Endrer format på default timestamp now * Prefikser tabeller med FORDEL * Fjerner ubrukt tjeneste * Legger til hendelseforsinkelse * Fleire tester * Legger til prestophook * Går tilbake til CURRENT_TIMESTAMP * Egen mapper for mapping til og fra json for hendelse * Legger til dokarkiv i outbound policy --------- Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> Co-authored-by: Ramin Esfandiari <[email protected]>
1 parent 828daaa commit 95d97f3

File tree

134 files changed

+8484
-811
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

134 files changed

+8484
-811
lines changed

‎.run/Ung-sak JettyDevServer.run.xml

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
<component name="ProjectRunConfigurationManager">
22
<configuration default="false" name="Ung-sak JettyDevServer" type="Application" factoryName="Application">
3-
<option name="ALTERNATIVE_JRE_PATH" value="21" />
3+
<option name="ALTERNATIVE_JRE_PATH" value="temurin-21" />
44
<option name="ALTERNATIVE_JRE_PATH_ENABLED" value="true" />
55
<option name="MAIN_CLASS_NAME" value="no.nav.ung.sak.web.server.jetty.JettyDevServer" />
66
<module name="web-webapp" />

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

-17
Original file line numberDiff line numberDiff line change
@@ -75,9 +75,6 @@ public class MottattDokument extends BaseEntitet {
7575
@Column(name = "kildesystem")
7676
private String kildesystem;
7777

78-
@Column(name = "kanalreferanse", updatable = false)
79-
private String kanalreferanse;
80-
8178
/** Arbeidsgiver referanse - orgnummer eller privat arbeidsgiver fnr. */
8279
@Column(name = "arbeidsgiver")
8380
private String arbeidsgiver;
@@ -143,10 +140,6 @@ public String getKildesystem() {
143140
return kildesystem;
144141
}
145142

146-
public String getKanalreferanse() {
147-
return kanalreferanse;
148-
}
149-
150143
public String getFeilmelding() {
151144
return feilmelding;
152145
}
@@ -224,10 +217,6 @@ public void setKildesystem(String systemnavn) {
224217
this.kildesystem = systemnavn;
225218
}
226219

227-
public void setKanalreferanse(String kanalreferanse) {
228-
this.kanalreferanse = kanalreferanse;
229-
}
230-
231220
public void setFeilmeldingOgOppdaterStatus(String feilmelding) {
232221
this.feilmelding = feilmelding;
233222
setStatus(feilmelding == null ? DokumentStatus.GYLDIG : DokumentStatus.UGYLDIG);
@@ -276,11 +265,6 @@ public Builder medMottattTidspunkt(LocalDateTime mottattTidspunkt) {
276265
return this;
277266
}
278267

279-
public Builder medKanalreferanse(String kanalreferanse) {
280-
mottatteDokumentMal.kanalreferanse = kanalreferanse;
281-
return this;
282-
}
283-
284268
public Builder medStatus(DokumentStatus status) {
285269
mottatteDokumentMal.setStatus(status);
286270
return this;
@@ -348,7 +332,6 @@ public int hashCode() {
348332
@Override
349333
public String toString() {
350334
return getClass().getSimpleName() + "<journalpostId=" + journalpostId
351-
+ ", kanalReferanse=" + kanalreferanse
352335
+ ", arbeidsgiver=" + arbeidsgiver
353336
+ ", type=" + type
354337
+ ", journalpostId=" + journalpostId

‎deploy/dev-gcp.yml

+14
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,9 @@ spec:
2222
timeout: 5
2323
periodSeconds: 10
2424
failureThreshold: 27
25+
preStopHook:
26+
http:
27+
path: /ung/sak/internal/health/preStop
2528
replicas:
2629
min: 2
2730
max: 2
@@ -89,6 +92,7 @@ spec:
8992
- host: "pdl-api.dev-fss-pub.nais.io"
9093
- host: "saf-q2.dev-fss-pub.nais.io"
9194
- host: "norg2.dev-fss-pub.nais.io"
95+
- host: "dokarkiv-q2.dev-fss-pub.nais.io"
9296
inbound:
9397
rules:
9498
- application: ung-sak
@@ -151,6 +155,12 @@ spec:
151155
value: omsorgspenger.k9-rapid-v2
152156
- name: KAFKA_INFOTRYGDFEED_AIVEN_TOPIC
153157
value: k9saksbehandling.k9-infotrygd-feed-hendelse
158+
- name: HENDELSE_PERSON_LEESAH_TOPIC
159+
value: pdl.leesah-v1
160+
- name: KAFKA_JOURNAL_TOPIC
161+
value: teamdokumenthandtering.aapen-dok-journalfoering
162+
163+
154164

155165
# Baseurl
156166
- name: SCHEMA_REGISTRY_URL
@@ -241,6 +251,8 @@ spec:
241251
value: api://dev-fss.teamdokumenthandtering.saf/.default
242252
- name: DOKARKIV_URL
243253
value: https://dokarkiv-q2.dev-fss-pub.nais.io/rest/journalpostapi/v1
254+
- name: DOKARKIV_BASE_URL
255+
value: https://dokarkiv-q2.dev-fss-pub.nais.io
244256
- name: DOKARKIV_SCOPE
245257
value: api://dev-fss.teamdokumenthandtering.dokarkiv/.default
246258

@@ -262,6 +274,8 @@ spec:
262274
# Konfigurasjoner
263275
- name: FLYWAY_REPAIR_ON_FAIL
264276
value: "false"
277+
- name: INNSENDING_HENDELSER_FORSINKELSE
278+
value: "PT1M"
265279

266280
# Audit logging
267281
- name: AUDITLOGGER_ENABLED

‎deploy/prod-gcp.yml

+8
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,9 @@ spec:
2222
timeout: 5
2323
periodSeconds: 10
2424
failureThreshold: 27
25+
preStopHook:
26+
http:
27+
path: /ung/sak/internal/health/preStop
2528
replicas:
2629
min: 2
2730
max: 2
@@ -89,6 +92,7 @@ spec:
8992
- host: "pdl-api.prod-fss-pub.nais.io"
9093
- host: "saf.prod-fss-pub.nais.io"
9194
- host: "norg2.prod-fss-pub.nais.io"
95+
- host: "dokarkiv.prod-fss-pub.nais.io"
9296
inbound:
9397
rules:
9498
- application: ung-sak
@@ -233,6 +237,8 @@ spec:
233237
value: api://prod-fss.teamdokumenthandtering.saf/.default
234238
- name: DOKARKIV_URL
235239
value: https://dokarkiv.prod-fss-pub.nais.io/rest/journalpostapi/v1
240+
- name: DOKARKIV_BASE_URL
241+
value: https://dokarkiv.prod-fss-pub.nais.io
236242
- name: DOKARKIV_SCOPE
237243
value: api://prod-fss.teamdokumenthandtering.dokarkiv/.default
238244

@@ -255,6 +261,8 @@ spec:
255261
# Konfigurasjoner
256262
- name: FLYWAY_REPAIR_ON_FAIL
257263
value: "false"
264+
- name: INNSENDING_HENDELSER_FORSINKELSE
265+
value: "PT1H"
258266

259267
# Audit logging
260268
- name: AUDITLOGGER_ENABLED

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

+1-3
Original file line numberDiff line numberDiff line change
@@ -5,14 +5,12 @@
55
import no.nav.ung.sak.behandlingslager.behandling.motattdokument.MottattDokument;
66

77
class MottattDokumentSorterer {
8-
private static Comparator<String> nullSafeStringComparator = Comparator.nullsFirst(String::compareToIgnoreCase);
98

109
private MottattDokumentSorterer() {
1110
// skjul public constructor
1211
}
1312

1413
static Comparator<MottattDokument> sorterMottattDokument() {
15-
return Comparator.comparing(MottattDokument::getMottattDato)
16-
.thenComparing(MottattDokument::getKanalreferanse, nullSafeStringComparator);
14+
return Comparator.comparing(MottattDokument::getMottattTidspunkt);
1715
}
1816
}

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

-10
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ public class InngåendeSaksdokument {
1717
private Boolean elektroniskSøknad;
1818
private String payload;
1919
private UUID forsendelseId;
20-
private String kanalreferanse;
2120
private String journalEnhet;
2221
private Brevkode type;
2322
private FagsakYtelseType fagsakYtelseType;
@@ -58,10 +57,6 @@ public UUID getForsendelseId() {
5857
return forsendelseId;
5958
}
6059

61-
public String getKanalreferanse() {
62-
return kanalreferanse;
63-
}
64-
6560
public String getJournalEnhet() {
6661
return journalEnhet;
6762
}
@@ -114,11 +109,6 @@ public static class Builder {
114109
return this;
115110
}
116111

117-
public InngåendeSaksdokument.Builder medKanalreferanse(String kanalreferanse) {
118-
this.kladd.kanalreferanse = kanalreferanse;
119-
return this;
120-
}
121-
122112
public InngåendeSaksdokument.Builder medJournalførendeEnhet(String journalEnhet) {
123113
this.kladd.journalEnhet = journalEnhet;
124114
return this;

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

-1
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,6 @@ public void dokumenterAnkommet(Collection<InngåendeSaksdokument> saksdokumenter
6868
.medFagsakId(saksdokument.getFagsakId());
6969

7070
builder.medMottattTidspunkt(mottattTidspunkt);
71-
builder.medKanalreferanse(saksdokument.getKanalreferanse());
7271

7372
if (saksdokument.getJournalpostId() != null) {
7473
builder.medJournalPostId(new JournalpostId(saksdokument.getJournalpostId().getVerdi()));

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

+3-55
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package no.nav.ung.sak.mottak;
22

33

4-
import java.time.LocalDate;
4+
import java.time.LocalDateTime;
55
import java.util.List;
66
import java.util.stream.Collectors;
77

@@ -12,45 +12,19 @@
1212

1313
public class MottattDokumentSortererTest {
1414

15-
@Test
16-
public void skal_sortere_etter_mottatt_dag_og_kanalref_når_dag_er_lik() {
17-
// Arrange
18-
MottattDokument.Builder builder = new MottattDokument.Builder();
19-
builder
20-
.medMottattDato(LocalDate.now())
21-
.medFagsakId(41337L)
22-
.medKanalreferanse("AR307765531");
23-
24-
MottattDokument første = builder.build();
25-
26-
27-
MottattDokument.Builder builder2 = new MottattDokument.Builder();
28-
builder2.medMottattDato(LocalDate.now())
29-
.medFagsakId(41337L)
30-
.medKanalreferanse("AR317765531");
31-
MottattDokument andre = builder2.build();
32-
33-
List<MottattDokument> dokumenter = List.of(andre, første);
34-
35-
// Act
36-
List<MottattDokument> sortert = dokumenter.stream().sorted(MottattDokumentSorterer.sorterMottattDokument()).collect(Collectors.toList());
37-
38-
// Assert
39-
Assertions.assertThat(sortert).containsExactly(første, andre);
40-
}
4115

4216
@Test
4317
public void skal_sortere_etter_mottatt_dag_når_den_er_ulik() {
4418
// Arrange
4519
MottattDokument.Builder builder = new MottattDokument.Builder();
4620
builder
47-
.medMottattDato(LocalDate.now())
21+
.medMottattTidspunkt(LocalDateTime.now())
4822
.medFagsakId(41337L);
4923

5024
MottattDokument første = builder.build();
5125

5226
MottattDokument.Builder builder2 = new MottattDokument.Builder();
53-
builder2.medMottattDato(LocalDate.now().plusDays(1))
27+
builder2.medMottattTidspunkt(LocalDateTime.now().plusDays(1))
5428
.medFagsakId(41337L);
5529
MottattDokument andre = builder2.build();
5630

@@ -63,30 +37,4 @@ public class MottattDokumentSortererTest {
6337
Assertions.assertThat(sortert).containsExactly(første, andre);
6438
}
6539

66-
@Test
67-
public void skal_ikke_feile_når_kanalref_er_null() {
68-
// Arrange
69-
MottattDokument.Builder builder = new MottattDokument.Builder();
70-
builder
71-
.medMottattDato(LocalDate.now())
72-
.medFagsakId(41337L)
73-
.medKanalreferanse(null);
74-
75-
MottattDokument første = builder.build();
76-
77-
78-
MottattDokument.Builder builder2 = new MottattDokument.Builder();
79-
builder2.medMottattDato(LocalDate.now())
80-
.medFagsakId(41337L)
81-
.medKanalreferanse("AR317765531");
82-
MottattDokument andre = builder2.build();
83-
84-
List<MottattDokument> dokumenter = List.of(andre, første);
85-
86-
// Act
87-
List<MottattDokument> sortert = dokumenter.stream().sorted(MottattDokumentSorterer.sorterMottattDokument()).collect(Collectors.toList());
88-
89-
// Assert
90-
Assertions.assertThat(sortert).containsExactly(første, andre);
91-
}
9240
}

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

+16-19
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,11 @@
1616
import no.nav.k9.felles.integrasjon.arbeidsfordeling.rest.ArbeidsfordelingRequest;
1717
import no.nav.k9.felles.integrasjon.arbeidsfordeling.rest.ArbeidsfordelingResponse;
1818
import no.nav.k9.felles.integrasjon.arbeidsfordeling.rest.ArbeidsfordelingRestKlient;
19+
import no.nav.ung.kodeverk.behandling.BehandlingTema;
1920
import no.nav.ung.kodeverk.behandling.BehandlingType;
2021
import no.nav.ung.kodeverk.behandling.FagsakYtelseType;
2122
import no.nav.ung.kodeverk.person.Diskresjonskode;
23+
import no.nav.ung.kodeverk.produksjonsstyring.OmrådeTema;
2224
import no.nav.ung.kodeverk.produksjonsstyring.OrganisasjonsEnhet;
2325
import no.nav.ung.sak.behandlingslager.aktør.GeografiskTilknytning;
2426
import no.nav.ung.sak.domene.person.tps.TpsTjeneste;
@@ -33,10 +35,6 @@ static class EnhetsTjenesteData {
3335
OrganisasjonsEnhet enhetKlage;
3436
List<OrganisasjonsEnhet> alleBehandlendeEnheter;
3537
LocalDate sisteInnhenting = LocalDate.MIN;
36-
37-
Optional<OrganisasjonsEnhet> finnOrganisasjonsEnhet(String enhetId) {
38-
return alleBehandlendeEnheter.stream().filter(e -> enhetId.equals(e.getEnhetId())).findFirst();
39-
}
4038
}
4139

4240
private static final String NK_ENHET_ID = "4292";
@@ -79,21 +77,20 @@ Optional<OrganisasjonsEnhet> oppdaterEnhetSjekkOppgittePersoner(FagsakYtelseType
7977
return Optional.empty();
8078
}
8179

82-
Optional<OrganisasjonsEnhet> oppdaterEnhetSjekkRegistrerteRelasjoner(FagsakYtelseType ytelseType,
83-
String enhetId,
84-
AktørId hovedAktør,
85-
Collection<AktørId> alleAktører) {
86-
var cacheEntry = oppdaterEnhetCache(ytelseType);
87-
if (cacheEntry.enhetKode6.getEnhetId().equals(enhetId) || NK_ENHET_ID.equals(enhetId)) {
88-
return Optional.empty();
89-
}
90-
if (harNoenDiskresjonskode6(alleAktører)) {
91-
return Optional.of(cacheEntry.enhetKode6);
92-
}
93-
if (cacheEntry.finnOrganisasjonsEnhet(enhetId).isEmpty()) {
94-
return Optional.of(hentEnhetSjekkKunAktør(hovedAktør, ytelseType));
95-
}
96-
return Optional.empty();
80+
public List<OrganisasjonsEnhet> hentFordelingEnhetId(OmrådeTema tema, BehandlingTema behandlingsTema, GeografiskTilknytning geo) {
81+
var request = ArbeidsfordelingRequest.ny()
82+
.medTema(tema.getOffisiellKode())
83+
.medBehandlingstema(behandlingsTema == null ? null : behandlingsTema.getOffisiellKode())
84+
.medDiskresjonskode(geo.getDiskresjonskode().getKode())
85+
.medGeografiskOmraade(geo.getTilknytning())
86+
.build();
87+
88+
return arbeidsfordelingTjeneste
89+
.finnEnhet(request)
90+
.stream()
91+
.filter(response -> "AKTIV".equalsIgnoreCase(response.getStatus()))
92+
.map(r -> new OrganisasjonsEnhet(r.getEnhetNr(), r.getEnhetNavn()))
93+
.collect(Collectors.toList());
9794
}
9895

9996
OrganisasjonsEnhet hentEnhetSjekkKunAktør(AktørId aktørId, FagsakYtelseType ytelseType) {

0 commit comments

Comments
 (0)