Sanere Leesah FoedselV1

navikt · Jun 15, 2024 · 71ad0f9 · 71ad0f9
1 parent ef8c5f0
commit 71ad0f9
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 57 deletions.
diff --git a/...ne/src/main/java/no/nav/foreldrepenger/abonnent/pdl/kafka/PdlLeesahHendelseHåndterer.java b/...ne/src/main/java/no/nav/foreldrepenger/abonnent/pdl/kafka/PdlLeesahHendelseHåndterer.java
@@ -3,14 +3,12 @@
 import static io.confluent.kafka.serializers.KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG;
 import static no.nav.foreldrepenger.abonnent.pdl.kafka.PdlLeesahOversetter.DØD;
 import static no.nav.foreldrepenger.abonnent.pdl.kafka.PdlLeesahOversetter.DØDFØDSEL;
-import static no.nav.foreldrepenger.abonnent.pdl.kafka.PdlLeesahOversetter.FØDSEL;
 import static no.nav.foreldrepenger.abonnent.pdl.kafka.PdlLeesahOversetter.FØDSELSDATO;
 import static no.nav.foreldrepenger.abonnent.pdl.kafka.PdlLeesahOversetter.UTFLYTTING;
 
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.Map;
-import java.util.Optional;
 import java.util.function.Supplier;
 
 import org.apache.kafka.common.serialization.Deserializer;
@@ -24,7 +22,6 @@
 import jakarta.inject.Inject;
 import jakarta.transaction.Transactional;
 import no.nav.foreldrepenger.abonnent.felles.domene.HendelseKilde;
-import no.nav.foreldrepenger.abonnent.felles.domene.HendelseType;
 import no.nav.foreldrepenger.abonnent.felles.domene.HåndtertStatusType;
 import no.nav.foreldrepenger.abonnent.felles.domene.InngåendeHendelse;
 import no.nav.foreldrepenger.abonnent.felles.task.HendelserDataWrapper;
@@ -94,9 +91,7 @@ void handleMessage(String key, Personhendelse payload) { // key er spesialtegn +
             return;
         }
 
-        if (FØDSEL.contentEquals(payload.getOpplysningstype())) {
-            håndterFødsel(payload);
-        } else if (FØDSELSDATO.contentEquals(payload.getOpplysningstype())) {
+        if (FØDSELSDATO.contentEquals(payload.getOpplysningstype())) {
             håndterFødselsdato(payload);
         } else if (DØD.contentEquals(payload.getOpplysningstype())) {
             håndterDødsfall(payload);
@@ -107,20 +102,6 @@ void handleMessage(String key, Personhendelse payload) { // key er spesialtegn +
         }
     }
 
-    private void håndterFødsel(Personhendelse payload) {
-        var foedsel = payload.getFoedsel();
-        if (foedsel != null) {
-            loggMottakMedDato(payload, "fødsel", "fødselsdato", foedsel.getFoedselsdato());
-        } else {
-            loggMottakUtenDato(payload, "fødsel");
-        }
-        var pdlFødsel = oversetter.oversettFødsel(payload);
-        // Må håndtere korrigerte og annullerte hendelser et par dager framover
-        if (!HendelseType.PDL_FØDSEL_OPPRETTET.equals(pdlFødsel.getHendelseType())) {
-            prosesserHendelseVidereHvisRelevant(pdlFødsel);
-        }
-    }
-
     private void håndterFødselsdato(Personhendelse payload) {
         var foedselsdato = payload.getFoedselsdato();
         if (foedselsdato != null) {
@@ -129,11 +110,7 @@ void handleMessage(String key, Personhendelse payload) { // key er spesialtegn +
             loggMottakUtenDato(payload, "fødsel dato");
         }
         var pdlFødsel = oversetter.oversettFødselsdato(payload);
-        var tidligere = Optional.ofNullable(pdlFødsel.getTidligereHendelseId())
-            .flatMap(th -> hendelseRepository.finnHendelseFraIdHvisFinnes(th, HendelseKilde.PDL));
-        if (HendelseType.PDL_FØDSEL_OPPRETTET.equals(pdlFødsel.getHendelseType()) || tidligere.isPresent()) {
-            prosesserHendelseVidereHvisRelevant(pdlFødsel);
-        }
+        prosesserHendelseVidereHvisRelevant(pdlFødsel);
     }
 
     private void håndterDødsfall(Personhendelse payload) {

diff --git a/domene/src/main/java/no/nav/foreldrepenger/abonnent/pdl/kafka/PdlLeesahOversetter.java b/domene/src/main/java/no/nav/foreldrepenger/abonnent/pdl/kafka/PdlLeesahOversetter.java
@@ -21,7 +21,6 @@ public class PdlLeesahOversetter {
 
     private static final Logger LOG = LoggerFactory.getLogger(PdlLeesahOversetter.class);
 
-    public static final String FØDSEL = "FOEDSEL_V1";
     public static final String FØDSELSDATO = "FOEDSELSDATO_V1";
     public static final String DØD = "DOEDSFALL_V1";
     public static final String DØDFØDSEL = "DOEDFOEDT_BARN_V1";
@@ -31,17 +30,6 @@ public PdlLeesahOversetter() {
         // CDI
     }
 
-    public PdlFødsel oversettFødsel(Personhendelse personhendelse) {
-        var builder = PdlFødsel.builder();
-        oversettPersonhendelse(personhendelse, builder);
-
-        if (personhendelse.getFoedsel() != null) {
-            builder.medFødselsdato(personhendelse.getFoedsel().getFoedselsdato());
-        }
-
-        return builder.build();
-    }
-
     public PdlFødsel oversettFødselsdato(Personhendelse personhendelse) {
         var builder = PdlFødsel.builder();
         oversettPersonhendelse(personhendelse, builder);
@@ -109,7 +97,7 @@ private HendelseType oversettHendelseType(Personhendelse personhendelse) {
             var endringstype = personhendelse.getEndringstype();
 
             switch (opplysningstype) {
-                case FØDSEL, FØDSELSDATO -> {
+                case FØDSELSDATO -> {
                     return switch (endringstype) {
                         case OPPRETTET -> HendelseType.PDL_FØDSEL_OPPRETTET;
                         case ANNULLERT -> HendelseType.PDL_FØDSEL_ANNULLERT;

diff --git a/domene/src/main/resources/avro/leesah/Personhendelse.avdl b/domene/src/main/resources/avro/leesah/Personhendelse.avdl
@@ -2,7 +2,6 @@
 protocol PersonhendelseProto {
   import idl "doedfoedtbarn/DoedfoedtBarn.avdl";
   import idl "doedsfall/Doedsfall.avdl";
-  import idl "foedsel/Foedsel.avdl";
   import idl "foedselsdato/Foedselsdato.avdl";
   import idl "utflytting/Utflytting.avdl";
 
@@ -26,7 +25,6 @@ protocol PersonhendelseProto {
 
     union { null, no.nav.person.pdl.leesah.doedfoedtbarn.DoedfoedtBarn } doedfoedtBarn = null;
     union { null, no.nav.person.pdl.leesah.doedsfall.Doedsfall } doedsfall = null;
-    union { null, no.nav.person.pdl.leesah.foedsel.Foedsel } foedsel = null;
     union { null, no.nav.person.pdl.leesah.foedselsdato.Foedselsdato } foedselsdato = null;
     union { null, no.nav.person.pdl.leesah.utflytting.UtflyttingFraNorge } utflyttingFraNorge = null;
   }

diff --git a/domene/src/main/resources/avro/leesah/foedsel/Foedsel.avdl b/domene/src/main/resources/avro/leesah/foedsel/Foedsel.avdl
diff --git a/...rc/test/java/no/nav/foreldrepenger/abonnent/pdl/kafka/PdlLeesahHendelseHåndtererTest.java b/...rc/test/java/no/nav/foreldrepenger/abonnent/pdl/kafka/PdlLeesahHendelseHåndtererTest.java
@@ -31,7 +31,7 @@
 import no.nav.person.pdl.leesah.Endringstype;
 import no.nav.person.pdl.leesah.Personhendelse;
 import no.nav.person.pdl.leesah.doedsfall.Doedsfall;
-import no.nav.person.pdl.leesah.foedsel.Foedsel;
+import no.nav.person.pdl.leesah.foedselsdato.Foedselsdato;
 import no.nav.person.pdl.leesah.utflytting.UtflyttingFraNorge;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTaskData;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTaskGruppe;
@@ -144,7 +144,7 @@ void skal_lagre_oversatt_utflyttingshendelse_og_opprette_vurder_sortering_task()
         payload.setPersonidenter(List.of("1111111111111", "22222222222"));
         payload.setMaster("Freg");
         payload.setOpprettet(OPPRETTET_TID.atZone(ZoneId.systemDefault()).toInstant());
-        payload.setOpplysningstype("FOEDSEL_V1");
+        payload.setOpplysningstype("FOEDSELSDATO_V1");
         payload.setEndringstype(Endringstype.ANNULLERT);
         var hendelseCaptor = ArgumentCaptor.forClass(InngåendeHendelse.class);
         doNothing().when(hendelseRepository).lagreInngåendeHendelse(hendelseCaptor.capture());
@@ -157,7 +157,7 @@ void skal_lagre_oversatt_utflyttingshendelse_og_opprette_vurder_sortering_task()
         // Assert
         var inngåendeHendelse = hendelseCaptor.getValue();
         assertThat(inngåendeHendelse.getPayload()).contains("\"hendelseId\":\"ABC\"", "\"personidenter\":[\"1111111111111\",\"22222222222\"]",
-            "\"master\":\"Freg\"", "\"opplysningstype\":\"FOEDSEL_V1\"", "\"endringstype\":\"ANNULLERT\"",
+            "\"master\":\"Freg\"", "\"opplysningstype\":\"FOEDSELSDATO_V1\"", "\"endringstype\":\"ANNULLERT\"",
             "\"hendelseType\":\"PDL_FOEDSEL_ANNULLERT\"");
         assertThat(inngåendeHendelse.getHendelseId()).isEqualTo("ABC");
         assertThat(inngåendeHendelse.getHåndtertStatus()).isEqualTo(HåndtertStatusType.MOTTATT);
@@ -180,11 +180,11 @@ void skal_lagre_oversatt_utflyttingshendelse_og_opprette_vurder_sortering_task()
         payload.setPersonidenter(List.of("1111111111111", "22222222222"));
         payload.setMaster("Freg");
         payload.setOpprettet(OPPRETTET_TID.atZone(ZoneId.systemDefault()).toInstant());
-        payload.setOpplysningstype("FOEDSEL_V1");
+        payload.setOpplysningstype("FOEDSELSDATO_V1");
         payload.setEndringstype(Endringstype.ANNULLERT);
-        var fødselsdato = new Foedsel();
+        var fødselsdato = new Foedselsdato();
         fødselsdato.setFoedselsdato(LocalDate.now().minusYears(20));
-        payload.setFoedsel(fødselsdato);
+        payload.setFoedselsdato(fødselsdato);
 
         // Act
         hendelseHåndterer.handleMessage("", payload);