Skip to content

Commit

Permalink
Forberede omlegging kodeverdier (#1858)
Browse files Browse the repository at this point in the history
* Forberede omlegging

* Klienter serialiserer som String ved kall til abakus

* Rydde mer + deps

* Eksplisitt liste klienter

* Mer deps i migrerigner

* Mer deps for tester

* Siste dep som manglet
  • Loading branch information
jolarsen authored Aug 8, 2022
1 parent 2b065c3 commit 2a6df71
Show file tree
Hide file tree
Showing 51 changed files with 417 additions and 395 deletions.
10 changes: 10 additions & 0 deletions domenetjenester/iay/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -118,5 +118,15 @@
<artifactId>felles-testutilities</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.zaxxer</groupId>
<artifactId>HikariCP</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-plus</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
</project>
Original file line number Diff line number Diff line change
Expand Up @@ -323,7 +323,7 @@ public Response hentSnapshotIayGrunnlag(@NotNull @Valid InntektArbeidYtelseGrunn

var grunnlagEtterspurt = iayTjeneste.hentGrunnlagEtterspurtFor(aktørId,
new Saksnummer(saksnummer),
YtelseType.fraKode(ytelseType.getKode()),
ytelseType,
spesifikasjon.getGrunnlagVersjon());

grunnlagEtterspurt.forEach(g -> {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -115,8 +115,8 @@ public Response hentRefusjonskravDatoForSak(@NotNull @Valid InntektsmeldingerReq
LoggUtil.setupLogMdc(spesifikasjon.getYtelseType(), spesifikasjon.getSaksnummer());
var aktørId = new AktørId(spesifikasjon.getPerson().getIdent());
var saksnummer = new Saksnummer(spesifikasjon.getSaksnummer());
var ytelseType = YtelseType.fraKode(spesifikasjon.getYtelseType().getKode());
var inntektsmeldinger = iayTjeneste.hentAlleInntektsmeldingerFor(aktørId, saksnummer, YtelseType.fraKode(ytelseType.getKode()));
var ytelseType = spesifikasjon.getYtelseType();
var inntektsmeldinger = iayTjeneste.hentAlleInntektsmeldingerFor(aktørId, saksnummer, ytelseType);
var kobling = koblingTjeneste.hentSisteFor(aktørId, saksnummer, ytelseType);
if (kobling.isEmpty()) {
response = Response.ok(new InntektsmeldingerDto().medInntektsmeldinger(Collections.emptyList())).build();
Expand Down Expand Up @@ -192,9 +192,9 @@ private void valider(YtelseType ytelseType, List<Inntektsmelding> inntektsmeldin

var aktørId = new AktørId(spesifikasjon.getPerson().getIdent());
var saksnummer = new Saksnummer(spesifikasjon.getSaksnummer());
var ytelseType = YtelseType.fraKode(spesifikasjon.getYtelseType().getKode());
Map<Inntektsmelding, ArbeidsforholdInformasjon> førsteMap = iayTjeneste.hentAlleInntektsmeldingerForEksternRef(aktørId, saksnummer, new KoblingReferanse(spesifikasjon.getEksternRefEn()), YtelseType.fraKode(ytelseType.getKode()));
Map<Inntektsmelding, ArbeidsforholdInformasjon> andreMap = iayTjeneste.hentAlleInntektsmeldingerForEksternRef(aktørId, saksnummer, new KoblingReferanse(spesifikasjon.getEksternRefTo()), YtelseType.fraKode(ytelseType.getKode()));
var ytelseType = spesifikasjon.getYtelseType();
Map<Inntektsmelding, ArbeidsforholdInformasjon> førsteMap = iayTjeneste.hentAlleInntektsmeldingerForEksternRef(aktørId, saksnummer, new KoblingReferanse(spesifikasjon.getEksternRefEn()), ytelseType);
Map<Inntektsmelding, ArbeidsforholdInformasjon> andreMap = iayTjeneste.hentAlleInntektsmeldingerForEksternRef(aktørId, saksnummer, new KoblingReferanse(spesifikasjon.getEksternRefTo()), ytelseType);

var diffMap = iayTjeneste.utledInntektsmeldingDiff(førsteMap, andreMap);
InntektsmeldingerDto imDiffListe = MapInntektsmeldinger.mapUnikeInntektsmeldingerFraGrunnlag(diffMap);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,7 @@ private OppgittArbeidsforholdDto mapArbeidsforhold(OppgittArbeidsforhold arbeids
var periode = new Periode(periode1.getFomDato(), periode1.getTomDato());

var org = egenNæring.getOrgnummer() == null ? null : new Organisasjon(egenNæring.getOrgnummer().getId());
var virksomhetType = egenNæring.getVirksomhetType().getKode();
var virksomhetType = egenNæring.getVirksomhetType();

var dto = new OppgittEgenNæringDto(periode)
.medBegrunnelse(egenNæring.getBegrunnelse())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@

import no.nav.abakus.iaygrunnlag.kodeverk.InntektspostType;
import no.nav.foreldrepenger.abakus.felles.jpa.IntervallEntitet;

import no.nav.foreldrepenger.abakus.registerdata.inntekt.sigrun.klient.BeregnetSkatt;
import no.nav.foreldrepenger.abakus.registerdata.inntekt.sigrun.klient.summertskattegrunnlag.SSGGrunnlag;
import no.nav.foreldrepenger.abakus.registerdata.inntekt.sigrun.klient.summertskattegrunnlag.SSGResponse;
Expand All @@ -40,11 +39,11 @@ private static void mapSummertskattegrunnlag(Map<Year, Optional<SSGResponse>> su
SSGResponse ssgResponse = entry.getValue().get();
Optional<SSGGrunnlag> ssggrunnlag = ssgResponse.getSvalbardGrunnlag()
.stream()
.filter(f -> TekniskNavn.fraKode(f.getTekniskNavn()) != null)
.filter(f -> TekniskNavnMapper.fraSigrunNavn(f.getTekniskNavn()) != null)
.findFirst();
ssggrunnlag.ifPresent(grunnlag -> {
IntervallEntitet datoIntervallEntitet = lagDatoIntervall(entry.getKey());
InntektspostType inntektspostType = TekniskNavn.fraKode(grunnlag.getTekniskNavn()).getInntektspostType();
InntektspostType inntektspostType = TekniskNavnMapper.fraSigrunNavn(grunnlag.getTekniskNavn());
Map<InntektspostType, BigDecimal> inntektspost = årTilInntektMap.get(datoIntervallEntitet);
if (inntektspost == null) {
Map<InntektspostType, BigDecimal> typeTilVerdiMap = new HashMap<>();
Expand All @@ -70,7 +69,7 @@ private static void mapBeregnetSkatt(Map<Year, List<BeregnetSkatt>> beregnetSkat
IntervallEntitet intervallEntitet = lagDatoIntervall(entry.getKey());
Map<InntektspostType, BigDecimal> typeTilVerdiMap = new HashMap<>();
for (BeregnetSkatt beregnetSkatteobjekt : entry.getValue()) {
InntektspostType type = TekniskNavn.fraKode(beregnetSkatteobjekt.getTekniskNavn()).getInntektspostType();
InntektspostType type = TekniskNavnMapper.fraSigrunNavn(beregnetSkatteobjekt.getTekniskNavn());
if (type != null) {
BigDecimal beløp = typeTilVerdiMap.get(type);
if (beløp == null) {
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1,38 @@
package no.nav.foreldrepenger.abakus.registerdata.inntekt.sigrun;

import java.util.List;
import java.util.Map;

import no.nav.abakus.iaygrunnlag.kodeverk.InntektspostType;

public final class TekniskNavnMapper {

static final String PERSONINNTEKT_LØNN = "personinntektLoenn";
static final String PERSONINNTEKT_BARE_PENSJONSDEL = "personinntektBarePensjonsdel";
static final String PERSONINNTEKT_NÆRING = "personinntektNaering";
static final String PERSONINNTEKT_FISKE_FANGST_FAMILIEBARNEHAGE = "personinntektFiskeFangstFamiliebarnehage";
static final String SVALBARD_LØNN_LØNNSTREKKORDNINGEN = "svalbardLoennLoennstrekkordningen";
static final String SVALBARD_PERSONINNTEKT_NÆRING = "svalbardPersoninntektNaering";
static final String LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN = "loennsinntektMedTrygdeavgiftspliktOmfattetAvLoennstrekkordningen";
static final String SKATTEOPPGJØRSDATO = "skatteoppgjoersdato";

private static final Map<String, InntektspostType> SIGRUN_TIL_INNTEKTSPOST = Map.of(
PERSONINNTEKT_LØNN, InntektspostType.LØNN,
PERSONINNTEKT_BARE_PENSJONSDEL, InntektspostType.LØNN,
PERSONINNTEKT_NÆRING, InntektspostType.SELVSTENDIG_NÆRINGSDRIVENDE,
PERSONINNTEKT_FISKE_FANGST_FAMILIEBARNEHAGE, InntektspostType.NÆRING_FISKE_FANGST_FAMBARNEHAGE,
SVALBARD_LØNN_LØNNSTREKKORDNINGEN, InntektspostType.LØNN,
SVALBARD_PERSONINNTEKT_NÆRING, InntektspostType.SELVSTENDIG_NÆRINGSDRIVENDE,
LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN, InntektspostType.LØNN
);

private static final List<String> SIGRUN_TIL_NULL = List.of(SKATTEOPPGJØRSDATO);

public static InntektspostType fraSigrunNavn(String tekniskNavn) {
if (tekniskNavn == null || SIGRUN_TIL_NULL.contains(tekniskNavn)) {
return null;
}
return SIGRUN_TIL_INNTEKTSPOST.get(tekniskNavn);
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ private Kobling oppdaterKobling(InnhentRegisterdataRequest dto) {
} else {
kobling = koblingOpt.get();
if (YtelseType.UDEFINERT.equals(kobling.getYtelseType())) {
var ytelseType = mapTilYtelseType(dto);
var ytelseType = dto.getYtelseType();
if (ytelseType != null) {
kobling.setYtelseType(ytelseType);
}
Expand All @@ -110,10 +110,6 @@ private Kobling oppdaterKobling(InnhentRegisterdataRequest dto) {
return kobling;
}

private YtelseType mapTilYtelseType(InnhentRegisterdataRequest dto) {
return YtelseType.fraKode(dto.getYtelseType().getKode());
}

public String triggAsyncInnhent(InnhentRegisterdataRequest dto) {
Kobling kobling = oppdaterKobling(dto);

Expand Down
Original file line number Diff line number Diff line change
@@ -1,10 +1,6 @@
package no.nav.foreldrepenger.abakus.registerdata.ytelse.infotrygd.kodemaps;

import com.fasterxml.jackson.annotation.JsonProperty;

import no.nav.abakus.iaygrunnlag.kodeverk.Kodeverdi;

public enum RelatertYtelseStatus implements Kodeverdi {
public enum RelatertYtelseStatus {

// Statuser fra Arena
AVSLU("AVSLU"),
Expand All @@ -31,33 +27,14 @@ public enum RelatertYtelseStatus implements Kodeverdi {
AVSLUTTET_IT("A"),
;

@JsonProperty(value = "kode")
private String kode;

@JsonProperty(value = "kodeverk")
private String kodeverk = "RELATERT_YTELSE_STATUS";

RelatertYtelseStatus(String kode) {
this.kode = kode;
}

@Override
public String getKode() {
return kode;
}

@Override
public String getKodeverk() {
return kodeverk;
}

@Override
public String getOffisiellKode() {
return kode;
}

@Override
public String getNavn() {
return kode;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -15,27 +15,27 @@ public class DiffSjekkTest {
public void skal_diffe_entitet_med_landkode() throws Exception {
var traverser = TraverseEntityGraphFactory.build();

var objCAN = EgenNæringBuilder.ny().medLandkode(Landkode.CAN).build();
var objDNK = EgenNæringBuilder.ny().medLandkode(Landkode.DNK).build();
var objNOR = EgenNæringBuilder.ny().medLandkode(Landkode.NOR).build();

var differ = new DiffEntity(traverser);

assertThat(differ.areDifferent(objCAN, objNOR)).isTrue();
assertThat(differ.areDifferent(objCAN, objCAN)).isFalse();
assertThat(differ.areDifferent(objDNK, objNOR)).isTrue();
assertThat(differ.areDifferent(objDNK, objDNK)).isFalse();

}

@Test
public void skal_diffe_landkode() throws Exception {
var traverser = TraverseEntityGraphFactory.build();

var objCAN = Landkode.CAN;
var objDNK = Landkode.DNK;
var objNOR = Landkode.NOR;

var differ = new DiffEntity(traverser);

assertThat(differ.areDifferent(objCAN, objNOR)).isTrue();
assertThat(differ.areDifferent(objCAN, objCAN)).isFalse();
assertThat(differ.areDifferent(objDNK, objNOR)).isTrue();
assertThat(differ.areDifferent(objDNK, objDNK)).isFalse();

}
}
Original file line number Diff line number Diff line change
Expand Up @@ -27,8 +27,8 @@ public class SigrunTilInternMapperTest {
Map<Year, Optional<SSGResponse>> summertskattegrunnlag = new HashMap<>();

Year iÅr = Year.of(iDag.getYear());
beregnet.put(iÅr, List.of(new BeregnetSkatt(TekniskNavn.PERSONINNTEKT_LØNN.getKode(), "5000")));
summertskattegrunnlag.put(iÅr, Optional.of(new SSGResponse(List.of(), List.of(new SSGGrunnlag(TekniskNavn.LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN.getKode(), "5000")), null)));
beregnet.put(iÅr, List.of(new BeregnetSkatt(TekniskNavnMapper.PERSONINNTEKT_LØNN, "5000")));
summertskattegrunnlag.put(iÅr, Optional.of(new SSGResponse(List.of(), List.of(new SSGGrunnlag(TekniskNavnMapper.LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN, "5000")), null)));

Map<IntervallEntitet, Map<InntektspostType, BigDecimal>> map = SigrunTilInternMapper.mapFraSigrunTilIntern(beregnet, summertskattegrunnlag);
LocalDate førsteDagIÅr = LocalDate.of(iÅr.getValue(), 1, 1);
Expand All @@ -44,7 +44,7 @@ public class SigrunTilInternMapperTest {
Map<Year, Optional<SSGResponse>> summertskattegrunnlag = new HashMap<>();

Year iÅr = Year.of(iDag.getYear());
summertskattegrunnlag.put(iÅr, Optional.of(new SSGResponse(List.of(), List.of(new SSGGrunnlag(TekniskNavn.LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN.getKode(), "5000")), null)));
summertskattegrunnlag.put(iÅr, Optional.of(new SSGResponse(List.of(), List.of(new SSGGrunnlag(TekniskNavnMapper.LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN, "5000")), null)));

Map<IntervallEntitet, Map<InntektspostType, BigDecimal>> map = SigrunTilInternMapper.mapFraSigrunTilIntern(beregnet, summertskattegrunnlag);
LocalDate førsteDagIÅr = LocalDate.of(iÅr.getValue(), 1, 1);
Expand All @@ -60,8 +60,8 @@ public class SigrunTilInternMapperTest {
Map<Year, Optional<SSGResponse>> summertskattegrunnlag = new HashMap<>();

Year iÅr = Year.of(iDag.getYear());
beregnet.put(iÅr, List.of(new BeregnetSkatt(TekniskNavn.PERSONINNTEKT_LØNN.getKode(), "5000"), new BeregnetSkatt(TekniskNavn.SKATTEOPPGJØRSDATO.getKode(), "2018-10-04")));
summertskattegrunnlag.put(iÅr, Optional.of(new SSGResponse(List.of(), List.of(new SSGGrunnlag(TekniskNavn.LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN.getKode(), "5000")), null)));
beregnet.put(iÅr, List.of(new BeregnetSkatt(TekniskNavnMapper.PERSONINNTEKT_LØNN, "5000"), new BeregnetSkatt(TekniskNavnMapper.SKATTEOPPGJØRSDATO, "2018-10-04")));
summertskattegrunnlag.put(iÅr, Optional.of(new SSGResponse(List.of(), List.of(new SSGGrunnlag(TekniskNavnMapper.LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN, "5000")), null)));

Map<IntervallEntitet, Map<InntektspostType, BigDecimal>> map = SigrunTilInternMapper.mapFraSigrunTilIntern(beregnet, summertskattegrunnlag);
LocalDate førsteDagIÅr = LocalDate.of(iÅr.getValue(), 1, 1);
Expand All @@ -77,8 +77,8 @@ public class SigrunTilInternMapperTest {
Map<Year, Optional<SSGResponse>> summertskattegrunnlag = new HashMap<>();

Year iÅr = Year.of(iDag.getYear());
beregnet.put(iÅr, List.of(new BeregnetSkatt(TekniskNavn.PERSONINNTEKT_FISKE_FANGST_FAMILIEBARNEHAGE.getKode(), "5000")));
summertskattegrunnlag.put(iÅr, Optional.of(new SSGResponse(List.of(), List.of(new SSGGrunnlag(TekniskNavn.LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN.getKode(), "5000")), null)));
beregnet.put(iÅr, List.of(new BeregnetSkatt(TekniskNavnMapper.PERSONINNTEKT_FISKE_FANGST_FAMILIEBARNEHAGE, "5000")));
summertskattegrunnlag.put(iÅr, Optional.of(new SSGResponse(List.of(), List.of(new SSGGrunnlag(TekniskNavnMapper.LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN, "5000")), null)));

Map<IntervallEntitet, Map<InntektspostType, BigDecimal>> map = SigrunTilInternMapper.mapFraSigrunTilIntern(beregnet, summertskattegrunnlag);
LocalDate førsteDagIÅr = LocalDate.of(iÅr.getValue(), 1, 1);
Expand All @@ -95,8 +95,8 @@ public class SigrunTilInternMapperTest {
Map<Year, Optional<SSGResponse>> summertskattegrunnlag = new HashMap<>();

Year iÅr = Year.of(iDag.getYear());
beregnet.put(iÅr, List.of(new BeregnetSkatt(TekniskNavn.PERSONINNTEKT_LØNN.getKode(), "5000"), new BeregnetSkatt(TekniskNavn.PERSONINNTEKT_BARE_PENSJONSDEL.getKode(), "5000"), new BeregnetSkatt(TekniskNavn.SKATTEOPPGJØRSDATO.getKode(), "2018-10-04")));
summertskattegrunnlag.put(iÅr, Optional.of(new SSGResponse(List.of(), List.of(new SSGGrunnlag(TekniskNavn.LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN.getKode(), "5000")), null)));
beregnet.put(iÅr, List.of(new BeregnetSkatt(TekniskNavnMapper.PERSONINNTEKT_LØNN, "5000"), new BeregnetSkatt(TekniskNavnMapper.PERSONINNTEKT_BARE_PENSJONSDEL, "5000"), new BeregnetSkatt(TekniskNavnMapper.SKATTEOPPGJØRSDATO, "2018-10-04")));
summertskattegrunnlag.put(iÅr, Optional.of(new SSGResponse(List.of(), List.of(new SSGGrunnlag(TekniskNavnMapper.LØNNSINNTEKT_MED_TRYGDEAVGIFTSPLIKT_OMFATTET_AV_LØNNSTREKKORDNINGEN, "5000")), null)));

Map<IntervallEntitet, Map<InntektspostType, BigDecimal>> map = SigrunTilInternMapper.mapFraSigrunTilIntern(beregnet, summertskattegrunnlag);
LocalDate førsteDagIÅr = LocalDate.of(iÅr.getValue(), 1, 1);
Expand Down
10 changes: 10 additions & 0 deletions domenetjenester/kobling/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -53,5 +53,15 @@
<artifactId>felles-testutilities</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.zaxxer</groupId>
<artifactId>HikariCP</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-plus</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
</project>
Loading

0 comments on commit 2a6df71

Please sign in to comment.