From a76339cd629dbfc47378976ffc0a1f9152d8db1c Mon Sep 17 00:00:00 2001 From: Anders Palfi Date: Wed, 27 Sep 2023 12:10:11 +0200 Subject: [PATCH] Fjerner im hendelser fra fp-topics (#468) --- fp-topics/README.md | 9 +- fp-topics/hendelser-inntektsmelding/pom.xml | 57 ------ .../inntektsmelding/Akt\303\270r.java" | 31 --- .../inntektsmelding/DokumentHendelse.java | 27 --- .../inntektsmelding/v1/InntektsmeldingV1.java | 181 ------------------ .../v1/InntektsmeldingV1Test.java | 82 -------- .../inntektsmelding/v1/TestJsonMapper.java | 38 ---- fp-topics/pom.xml | 1 - 8 files changed, 3 insertions(+), 423 deletions(-) delete mode 100644 fp-topics/hendelser-inntektsmelding/pom.xml delete mode 100644 "fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/Akt\303\270r.java" delete mode 100644 fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/DokumentHendelse.java delete mode 100644 fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/v1/InntektsmeldingV1.java delete mode 100644 fp-topics/hendelser-inntektsmelding/src/test/java/no/nav/vedtak/hendelser/inntektsmelding/v1/InntektsmeldingV1Test.java delete mode 100644 fp-topics/hendelser-inntektsmelding/src/test/java/no/nav/vedtak/hendelser/inntektsmelding/v1/TestJsonMapper.java diff --git a/fp-topics/README.md b/fp-topics/README.md index 7ac601a2..33b0cd92 100644 --- a/fp-topics/README.md +++ b/fp-topics/README.md @@ -1,10 +1,7 @@ Felles melding kontrakter for kafka -- hendelser-behandling (bør kanskje flyttes til fp-los) - - fp-sak -> fp-los - - fp-tilbake -> fp-los - -- hendelser-inntektsmelding (bør flyttes til fp-sak) - - fp-sak -> fpinfo-historikk +- hendelser-behandling + - fp-sak -> fp-los/fpoversikt + - fp-tilbake -> fp-los/fpoversikt - fp-topics-behandlingsprosess @deprecated (bør flyttes til fp-tilbake eller k9 sin repo) - k9-tilbake -> k9-los diff --git a/fp-topics/hendelser-inntektsmelding/pom.xml b/fp-topics/hendelser-inntektsmelding/pom.xml deleted file mode 100644 index 6bdcdf11..00000000 --- a/fp-topics/hendelser-inntektsmelding/pom.xml +++ /dev/null @@ -1,57 +0,0 @@ - - - - no.nav.foreldrepenger.kontrakter.topics - fp-topics - ${revision} - - 4.0.0 - - FP-TOPICS :: Inntektsmelding Mottatt - Kontrakt for å sende informasjon om lagrete inntektsmeldinger - hendelser-inntektsmelding - jar - - - - jakarta.validation - jakarta.validation-api - provided - - - - com.fasterxml.jackson.core - jackson-annotations - provided - - - - - com.fasterxml.jackson.core - jackson-databind - - - com.fasterxml.jackson.datatype - jackson-datatype-jdk8 - - - com.fasterxml.jackson.datatype - jackson-datatype-jsr310 - - - - - org.hibernate.validator - hibernate-validator - test - - - org.glassfish - jakarta.el - test - - - - \ No newline at end of file diff --git "a/fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/Akt\303\270r.java" "b/fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/Akt\303\270r.java" deleted file mode 100644 index f6bda396..00000000 --- "a/fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/Akt\303\270r.java" +++ /dev/null @@ -1,31 +0,0 @@ -package no.nav.vedtak.hendelser.inntektsmelding; - -import jakarta.validation.constraints.NotNull; -import jakarta.validation.constraints.Pattern; - -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonValue; - -public class Aktør { - - @NotNull - @JsonValue - @Pattern(regexp = "\\d{9}|\\d{11}|\\d{13}") // Orgnr / Fnr / aktørid - private String id; - - public Aktør() { - } - - public Aktør(String id) { - this.id = id; - } - - - public String getId() { - return id; - } - - public void setId(@JsonProperty("id") String id) { - this.id = id; - } -} diff --git a/fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/DokumentHendelse.java b/fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/DokumentHendelse.java deleted file mode 100644 index 575a0efd..00000000 --- a/fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/DokumentHendelse.java +++ /dev/null @@ -1,27 +0,0 @@ -package no.nav.vedtak.hendelser.inntektsmelding; - -import java.time.LocalDateTime; - -import com.fasterxml.jackson.annotation.JsonSubTypes; -import com.fasterxml.jackson.annotation.JsonTypeInfo; - -import no.nav.vedtak.hendelser.inntektsmelding.v1.InntektsmeldingV1; - -@JsonTypeInfo( - use = JsonTypeInfo.Id.NAME, - property = "version") -@JsonSubTypes({ - @JsonSubTypes.Type(value = InntektsmeldingV1.class, name = "1.0"), -}) -public abstract class DokumentHendelse { - - public abstract Aktør getAktørId(); - - public abstract String getHendelse(); - - public abstract String getJournalpostId(); - - public abstract String getSaksnummer(); - - public abstract LocalDateTime getInnsendingsTidspunkt(); -} diff --git a/fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/v1/InntektsmeldingV1.java b/fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/v1/InntektsmeldingV1.java deleted file mode 100644 index 829af861..00000000 --- a/fp-topics/hendelser-inntektsmelding/src/main/java/no/nav/vedtak/hendelser/inntektsmelding/v1/InntektsmeldingV1.java +++ /dev/null @@ -1,181 +0,0 @@ -package no.nav.vedtak.hendelser.inntektsmelding.v1; - -import java.time.LocalDate; -import java.time.LocalDateTime; - -import jakarta.validation.Valid; -import jakarta.validation.constraints.NotNull; -import jakarta.validation.constraints.Pattern; -import jakarta.validation.constraints.Size; - -import com.fasterxml.jackson.annotation.JsonAutoDetect; -import com.fasterxml.jackson.annotation.JsonIgnoreProperties; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; - -import no.nav.vedtak.hendelser.inntektsmelding.Aktør; -import no.nav.vedtak.hendelser.inntektsmelding.DokumentHendelse; - -@JsonIgnoreProperties(ignoreUnknown = true) -@JsonInclude(value = JsonInclude.Include.NON_ABSENT, content = JsonInclude.Include.NON_EMPTY) -@JsonAutoDetect(fieldVisibility = JsonAutoDetect.Visibility.NONE, getterVisibility = JsonAutoDetect.Visibility.NONE, setterVisibility = JsonAutoDetect.Visibility.NONE, isGetterVisibility = JsonAutoDetect.Visibility.NONE, creatorVisibility = JsonAutoDetect.Visibility.NONE) -public class InntektsmeldingV1 extends DokumentHendelse { - - public static final String HENDELSE_INNTEKTSMELDING = "INNTEKTSMELDING_"; - private static final String INNTEKTSMELDING_NY = "NY"; - private static final String INNTEKTSMELDING_ENDRING = "ENDRING"; - - /** - * Hendelsetype til bruk for mottatte inntektsmdeldinger. Venter "..._NY" eller "_ENDRING" - */ - @NotNull - @Size(max = 50) - @Pattern(regexp = "INNTEKTSMELDING_NY|INNTEKTSMELDING_ENDRING") - @JsonProperty(value = "hendelse", required = true, defaultValue = HENDELSE_INNTEKTSMELDING + INNTEKTSMELDING_NY) - private String hendelse; - - /** - * Saksnummer som inntektsmeldingen er journalført på - */ - @NotNull - @Size(max = 30) - @Pattern(regexp = "^[a-zA-Z0-9_\\-]*$") - @JsonProperty(value = "saksnummer", required = true) - private String saksnummer; - - /** - * Journalpost for arkivert inntektsmelding - */ - @NotNull - @Size(max = 30) - @Pattern(regexp = "^[a-zA-Z0-9_\\-]*$") - @JsonProperty(value = "journalpostId", required = true) - private String journalpostId; - - /** - * Unik referanse for inntektsmelding - bruker AR-referanse - */ - @NotNull - @Size(max = 30) - @Pattern(regexp = "^[a-zA-Z0-9_\\-]*$") - @JsonProperty(value = "referanseId", required = true) - private String referanseId; - - /** - * Bruker som inntektsmelding gjelder for - */ - @NotNull - @Valid - @JsonProperty(value = "aktørId", required = true) - private Aktør aktørId; - - /** - * ID for innsender - kan være org.nr eller aktørId (privat arbeidsgiver) - */ - @NotNull - @Valid - @JsonProperty(value = "arbeidsgiverId", required = true) - private Aktør arbeidsgiverId; - - /** - * Innsendinstidspunkt fra inntektsmelding - */ - @NotNull - @Valid - @JsonProperty(value = "innsendingsTidspunkt", required = true) - private LocalDateTime innsendingsTidspunkt; - - /** - * Startdato - kun satt for Foreldrepenger, ikke svangerskapspenger - */ - @Valid - @JsonProperty(value = "startDato", required = true) - private LocalDate startDato; - - @Override - public String getJournalpostId () { - return journalpostId; - } - - @Override - public String getSaksnummer() { - return saksnummer; - } - - @Override - public String getHendelse() { - return hendelse; - } - - @Override - public Aktør getAktørId() { - return aktørId; - } - - @Override - public LocalDateTime getInnsendingsTidspunkt() { - return innsendingsTidspunkt; - } - - public Aktør getArbeidsgiverId() { - return arbeidsgiverId; - } - - public String getReferanseId() { return referanseId; } - - public LocalDate getStartDato() { - return startDato; - } - - public static class Builder { - private InntektsmeldingV1 inntektsmelding; - - public Builder() { - inntektsmelding = new InntektsmeldingV1(); - } - - public Builder medSaksnummer(String saksnummer) { - inntektsmelding.saksnummer = saksnummer; - return this; - } - - public Builder medJournalpostId(String journalpostId) { - inntektsmelding.journalpostId = journalpostId; - return this; - } - - public Builder medReferanseId(String referanseId) { - inntektsmelding.referanseId = referanseId; - return this; - } - - public Builder medAktørId(String aktørId) { - inntektsmelding.aktørId = new Aktør(aktørId); - return this; - } - - public Builder medArbeidsgiverId(String aktørId) { - inntektsmelding.arbeidsgiverId = new Aktør(aktørId); - return this; - } - - public Builder medStartDato(LocalDate startDato) { - inntektsmelding.startDato = startDato; - return this; - } - - public Builder medInnsendingsTidspunkt(LocalDateTime innsendingsTidspunkt) { - inntektsmelding.innsendingsTidspunkt = innsendingsTidspunkt; - return this; - } - - public Builder medInnsendingsÅrsak(String innsendingsÅrsak) { - inntektsmelding.hendelse = HENDELSE_INNTEKTSMELDING + innsendingsÅrsak; - return this; - } - - public InntektsmeldingV1 build() { - return inntektsmelding; - } - } -} diff --git a/fp-topics/hendelser-inntektsmelding/src/test/java/no/nav/vedtak/hendelser/inntektsmelding/v1/InntektsmeldingV1Test.java b/fp-topics/hendelser-inntektsmelding/src/test/java/no/nav/vedtak/hendelser/inntektsmelding/v1/InntektsmeldingV1Test.java deleted file mode 100644 index c1df3b21..00000000 --- a/fp-topics/hendelser-inntektsmelding/src/test/java/no/nav/vedtak/hendelser/inntektsmelding/v1/InntektsmeldingV1Test.java +++ /dev/null @@ -1,82 +0,0 @@ -package no.nav.vedtak.hendelser.inntektsmelding.v1; - -import static org.assertj.core.api.Assertions.assertThat; - -import java.time.LocalDate; -import java.time.LocalDateTime; - -import jakarta.validation.Validation; - -import org.junit.jupiter.api.Test; - -import com.fasterxml.jackson.databind.ObjectReader; -import com.fasterxml.jackson.databind.ObjectWriter; - -public class InntektsmeldingV1Test { - - private static final ObjectWriter WRITER = TestJsonMapper.getMapper().writerWithDefaultPrettyPrinter(); - private static final ObjectReader READER = TestJsonMapper.getMapper().reader(); - - @Test - public void test_innteksmelding_fp() throws Exception { - String arRef = "AR123456"; - LocalDate startDato = LocalDate.now().plusWeeks(3); - LocalDateTime innsending = LocalDateTime.now().minusMinutes(3); - var inntektsmelding = new InntektsmeldingV1.Builder() - .medAktørId("1234567891234") - .medReferanseId(arRef) - .medInnsendingsTidspunkt(innsending) - .medStartDato(startDato) - .medArbeidsgiverId("987654321") - .medSaksnummer("99977755") - .medJournalpostId("11224466") - .medInnsendingsÅrsak("ENDRING") - .build(); - - String json = WRITER.writeValueAsString(inntektsmelding); - System.out.println(json); - - InntektsmeldingV1 roundTripped = READER.forType(InntektsmeldingV1.class).readValue(json); - - assertThat(roundTripped).isNotNull(); - assertThat(roundTripped.getReferanseId()).isEqualTo(arRef); - assertThat(roundTripped.getHendelse()).isEqualTo(InntektsmeldingV1.HENDELSE_INNTEKTSMELDING + "ENDRING"); - assertThat(roundTripped.getInnsendingsTidspunkt()).isEqualToIgnoringNanos(innsending); - assertThat(roundTripped.getStartDato()).isEqualTo(startDato); - validateResult(roundTripped); - } - - @Test - public void test_innteksmelding_svp() throws Exception { - String arRef = "AR123456"; - var inntektsmelding = new InntektsmeldingV1.Builder() - .medAktørId("1234567891234") - .medReferanseId(arRef) - .medInnsendingsTidspunkt(LocalDateTime.now()) - .medArbeidsgiverId("9876543210432") - .medSaksnummer("99977755") - .medJournalpostId("11224466") - .medInnsendingsÅrsak("NY") - .build(); - - String json = WRITER.writeValueAsString(inntektsmelding); - System.out.println(json); - - InntektsmeldingV1 roundTripped = READER.forType(InntektsmeldingV1.class).readValue(json); - - assertThat(roundTripped).isNotNull(); - assertThat(roundTripped.getReferanseId()).isNotNull(); - assertThat(roundTripped.getHendelse()).isEqualTo(InntektsmeldingV1.HENDELSE_INNTEKTSMELDING + "NY"); - assertThat(roundTripped.getStartDato()).isNull(); - validateResult(roundTripped); - } - - private void validateResult(Object roundTripped) { - assertThat(roundTripped).isNotNull(); - try (var factory = Validation.buildDefaultValidatorFactory()) { - var validator = factory.getValidator(); - var violations = validator.validate(roundTripped); - assertThat(violations).isEmpty(); - } - } -} \ No newline at end of file diff --git a/fp-topics/hendelser-inntektsmelding/src/test/java/no/nav/vedtak/hendelser/inntektsmelding/v1/TestJsonMapper.java b/fp-topics/hendelser-inntektsmelding/src/test/java/no/nav/vedtak/hendelser/inntektsmelding/v1/TestJsonMapper.java deleted file mode 100644 index da0b28bb..00000000 --- a/fp-topics/hendelser-inntektsmelding/src/test/java/no/nav/vedtak/hendelser/inntektsmelding/v1/TestJsonMapper.java +++ /dev/null @@ -1,38 +0,0 @@ -package no.nav.vedtak.hendelser.inntektsmelding.v1; - -import com.fasterxml.jackson.annotation.JsonAutoDetect; -import com.fasterxml.jackson.annotation.PropertyAccessor; -import com.fasterxml.jackson.databind.DeserializationFeature; -import com.fasterxml.jackson.databind.InjectableValues; -import com.fasterxml.jackson.databind.InjectableValues.Std; -import com.fasterxml.jackson.databind.ObjectMapper; -import com.fasterxml.jackson.databind.SerializationFeature; -import com.fasterxml.jackson.datatype.jdk8.Jdk8Module; -import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule; - -public class TestJsonMapper { - - private static final ObjectMapper OM; - - static { - ObjectMapper objectMapper = new ObjectMapper(); - objectMapper.registerModule(new Jdk8Module()); - objectMapper.registerModule(new JavaTimeModule()); - objectMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS); - objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); - objectMapper.setVisibility(PropertyAccessor.GETTER, JsonAutoDetect.Visibility.NONE); - objectMapper.setVisibility(PropertyAccessor.SETTER, JsonAutoDetect.Visibility.NONE); - objectMapper.setVisibility(PropertyAccessor.IS_GETTER, JsonAutoDetect.Visibility.NONE); - objectMapper.setVisibility(PropertyAccessor.FIELD, JsonAutoDetect.Visibility.ANY); - objectMapper.setVisibility(PropertyAccessor.CREATOR, JsonAutoDetect.Visibility.ANY); - - Std std = new InjectableValues.Std(); - objectMapper.setInjectableValues(std); - OM = objectMapper; - } - - public static ObjectMapper getMapper() { - return OM; - } - -} diff --git a/fp-topics/pom.xml b/fp-topics/pom.xml index 78f36f25..34e51d6b 100644 --- a/fp-topics/pom.xml +++ b/fp-topics/pom.xml @@ -18,7 +18,6 @@ hendelser-behandlingsprosess - hendelser-inntektsmelding hendelser-behandling