propparer callId og henter informasjonselementer som bestilt (#597)

Author: ekun

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/domene/iay/InntektArbeidYtelseRepository.java

@@ -35,8 +35,8 @@
 import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittArbeidsforhold;
 import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittEgenNæring;
 import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittFrilansoppdrag;
-import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjeningBuilder;
 import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjening;
+import no.nav.foreldrepenger.abakus.domene.iay.søknad.OppgittOpptjeningBuilder;
 import no.nav.foreldrepenger.abakus.felles.diff.DiffEntity;
 import no.nav.foreldrepenger.abakus.felles.diff.DiffResult;
 import no.nav.foreldrepenger.abakus.felles.diff.TraverseGraph;

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/RegisterdataInnhentingTask.java

@@ -7,23 +7,32 @@
 import javax.enterprise.inject.Instance;
 import javax.inject.Inject;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+
 import no.nav.abakus.iaygrunnlag.kodeverk.YtelseType;
+import no.nav.abakus.iaygrunnlag.request.InnhentRegisterdataRequest;
 import no.nav.foreldrepenger.abakus.domene.iay.InntektArbeidYtelseGrunnlagBuilder;
 import no.nav.foreldrepenger.abakus.iay.InntektArbeidYtelseTjeneste;
 import no.nav.foreldrepenger.abakus.kobling.Kobling;
 import no.nav.foreldrepenger.abakus.kobling.KoblingTask;
 import no.nav.foreldrepenger.abakus.kobling.KoblingTjeneste;
 import no.nav.foreldrepenger.abakus.kobling.kontroll.YtelseTypeRef;
 import no.nav.foreldrepenger.abakus.kobling.repository.LåsRepository;
+import no.nav.foreldrepenger.abakus.registerdata.tjeneste.InnhentRegisterdataTjeneste;
 import no.nav.foreldrepenger.abakus.registerdata.tjeneste.RegisterdataElement;
+import no.nav.foreldrepenger.abakus.vedtak.json.JacksonJsonConfig;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTask;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTaskData;
 
 @ApplicationScoped
 @ProsessTask(RegisterdataInnhentingTask.TASKTYPE)
 public class RegisterdataInnhentingTask extends KoblingTask {
-    public static final String TASKTYPE = "registerdata.innhent";
 
+    public static final String TASKTYPE = "registerdata.innhent";
+    private static final Logger log = LoggerFactory.getLogger(RegisterdataInnhentingTask.class);
     private KoblingTjeneste koblingTjeneste;
     private InntektArbeidYtelseTjeneste iayTjeneste;
     private Instance<IAYRegisterInnhentingTjeneste> innhentTjenester;
@@ -49,13 +58,15 @@ private IAYRegisterInnhentingTjeneste finnInnhenter(YtelseType ytelseType) {
     @Override
     protected void prosesser(ProsessTaskData prosessTaskData) {
         Kobling kobling = koblingTjeneste.hent(Long.valueOf(prosessTaskData.getBehandlingId()));
-        prosessTaskData.getPayloadAsString();
 
-        var informasjonsElementer = Set.of(RegisterdataElement.ARBEIDSFORHOLD,
-            RegisterdataElement.YTELSE,
-            RegisterdataElement.INNTEKT_PENSJONSGIVENDE,
-            RegisterdataElement.INNTEKT_BEREGNINGSGRUNNLAG,
-            RegisterdataElement.INNTEKT_SAMMENLIGNINGSGRUNNLAG);
+        Set<RegisterdataElement> informasjonsElementer;
+        log.info("Starter registerinnhenting for sak=[{}, {}] med behandling='{}'", kobling.getSaksnummer(), kobling.getYtelseType(), kobling.getKoblingReferanse());
+        try {
+            var request = JacksonJsonConfig.getMapper().readValue(prosessTaskData.getPayloadAsString(), InnhentRegisterdataRequest.class);
+            informasjonsElementer = InnhentRegisterdataTjeneste.hentUtInformasjonsElementer(request);
+        } catch (JsonProcessingException e) {
+            throw new RuntimeException("Feilet i deserialisering av innhent request", e);
+        }
 
         InntektArbeidYtelseGrunnlagBuilder builder = finnInnhenter(kobling.getYtelseType()).innhentRegisterdata(kobling, informasjonsElementer);
         iayTjeneste.lagre(kobling.getKoblingReferanse(), builder);

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/tjeneste/InnhentRegisterdataTjeneste.java

@@ -12,6 +12,8 @@
 import javax.enterprise.inject.Instance;
 import javax.inject.Inject;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+
 import no.nav.abakus.iaygrunnlag.Aktør;
 import no.nav.abakus.iaygrunnlag.Periode;
 import no.nav.abakus.iaygrunnlag.kodeverk.YtelseType;
@@ -33,6 +35,7 @@
 import no.nav.foreldrepenger.abakus.registerdata.callback.CallbackTask;
 import no.nav.foreldrepenger.abakus.typer.AktørId;
 import no.nav.foreldrepenger.abakus.typer.Saksnummer;
+import no.nav.foreldrepenger.abakus.vedtak.json.JacksonJsonConfig;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTaskData;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTaskGruppe;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTaskStatus;
@@ -145,6 +148,11 @@ public String triggAsyncInnhent(InnhentRegisterdataRequest dto) {
         ProsessTaskData callbackTask = new ProsessTaskData(CallbackTask.TASKTYPE);
         innhentingTask.setAktørId(kobling.getAktørId().getId());
         innhentingTask.setProperty(TaskConstants.KOBLING_ID, kobling.getId().toString());
+        try {
+            innhentingTask.setPayload(JacksonJsonConfig.getMapper().writeValueAsString(dto));
+        } catch (JsonProcessingException e) {
+            throw new RuntimeException("Feil i serialisering av innhentingrequest", e);
+        }
         callbackTask.setAktørId(kobling.getAktørId().getId());
         callbackTask.setProperty(TaskConstants.KOBLING_ID, kobling.getId().toString());
 
@@ -157,6 +165,7 @@ public String triggAsyncInnhent(InnhentRegisterdataRequest dto) {
         }
         taskGruppe.addNesteSekvensiell(innhentingTask);
         taskGruppe.addNesteSekvensiell(callbackTask);
+        taskGruppe.setCallIdFraEksisterende();
 
         return prosessTaskRepository.lagre(taskGruppe);
     }

domenetjenester/kobling/src/main/java/no/nav/foreldrepenger/abakus/kobling/Kobling.java

@@ -138,6 +138,10 @@ public void setOpptjeningsperiode(IntervallEntitet opptjeningsperiode) {
         this.opptjeningsperiode = opptjeningsperiode;
     }
 
+    public Saksnummer getSaksnummer() {
+        return saksnummer;
+    }
+
     public YtelseType getYtelseType() {
         return ytelseType;
     }