Skip to content

Commit

Permalink
Tatt i bruk siste versjon av bidrag-transport (og bidrag-domene i ste… (
Browse files Browse the repository at this point in the history 
#275)

* Tatt i bruk siste versjon av bidrag-transport (og bidrag-domene i stedet for bidrag-domain)

* Ny versjon av bidrag-transport (rename av klasse)
  • Loading branch information
@LarsOttoHaugen
LarsOttoHaugen authored Nov 30, 2023
1 parent c37a188 commit 471f583
Show file tree
Hide file tree
Showing 50 changed files with 961 additions and 691 deletions.
8 changes: 8 additions & 0 deletions .editorconfig
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
[*.{kt,kts}]
ktlint_code_style = intellij_idea
max_line_length = 150
tab_width = 4
ktlint_standard_discouraged-comment-location = disabled

[**/test/**/*.{kt,kts}]
ktlint_standard_max-line-length = disabled
41 changes: 9 additions & 32 deletions pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,21 +19,20 @@

<properties>
<!-- build/language -->
<kotlin.version>1.9.10</kotlin.version>
<kotlin.version>1.9.20</kotlin.version>
<build-helper-maven.version>3.2.0</build-helper-maven.version>
<token-support.version>3.1.7</token-support.version>
<token-support.version>3.1.8</token-support.version>
<!-- dependencies -->
<bidrag-commons.version>20231002151454_eab4a7b</bidrag-commons.version>
<bidrag-commons-test.version>1.20230511093912_dc35d81</bidrag-commons-test.version>
<bidrag-transport.version>20230929134005_dfcb25d</bidrag-transport.version>
<bidrag-transport.version>20231130133957_b66e902</bidrag-transport.version>
<bidrag-tilgangskontroll.version>1.10.4</bidrag-tilgangskontroll.version>
<mockito-kotlin.version>5.1.0</mockito-kotlin.version>
<springdoc-openapi-ui.version>2.2.0</springdoc-openapi-ui.version>
<nimbus-jose-jwt.version>9.31</nimbus-jose-jwt.version>
<nimbus-jose-jwt.version>9.37.1</nimbus-jose-jwt.version>
<springframework-cloud.version>4.0.4</springframework-cloud.version>
<com.squareup.okhttp3.version>4.12.0</com.squareup.okhttp3.version>
<aordningen-inntektsinformasjon-v1.version>1.7</aordningen-inntektsinformasjon-v1.version>
<bidrag-behandling-felles.version>0.0.85</bidrag-behandling-felles.version>
</properties>

<dependencyManagement>
Expand All @@ -46,7 +45,7 @@
<dependency>
<groupId>io.swagger.core.v3</groupId>
<artifactId>swagger-annotations</artifactId>
<version>2.2.15</version>
<version>2.2.19</version>
</dependency>
</dependencies>
</dependencyManagement>
Expand Down Expand Up @@ -86,20 +85,10 @@
<dependency>
<groupId>com.fasterxml.jackson.datatype</groupId>
<artifactId>jackson-datatype-jsr310</artifactId>
<version>2.15.3</version>
<version>2.16.0</version>
</dependency>

<!-- nav -->
<!-- <dependency>-->
<!-- <groupId>no.nav.bidrag</groupId>-->
<!-- <artifactId>bidrag-behandling-felles</artifactId>-->
<!-- <version>${bidrag-behandling-felles.version}</version>-->
<!-- </dependency>-->
<!-- <dependency>-->
<!-- <groupId>no.nav.bidrag</groupId>-->
<!-- <artifactId>bidrag-behandling-felles-dto</artifactId>-->
<!-- <version>${bidrag-behandling-felles-dto.version}</version>-->
<!-- </dependency>-->
<dependency>
<groupId>com.nimbusds</groupId>
<artifactId>nimbus-jose-jwt</artifactId>
Expand Down Expand Up @@ -227,18 +216,6 @@
<version>${com.squareup.okhttp3.version}</version>
<scope>test</scope>
</dependency>
<!-- <dependency>-->
<!-- <groupId>org.springframework.cloud</groupId>-->
<!-- <artifactId>spring-cloud-starter-contract-stub-runner</artifactId>-->
<!-- <version>${springframework-cloud.version}</version>-->
<!-- <scope>test</scope>-->
<!-- <exclusions>-->
<!-- <exclusion>-->
<!-- <groupId>com.google.guava</groupId>-->
<!-- <artifactId>guava</artifactId>-->
<!-- </exclusion>-->
<!-- </exclusions>-->
<!-- </dependency>-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-contract-wiremock</artifactId>
Expand Down Expand Up @@ -322,9 +299,9 @@
</executions>
<dependencies>
<dependency>
<groupId>com.pinterest</groupId>
<artifactId>ktlint</artifactId>
<version>0.50.0</version>
<groupId>com.pinterest.ktlint</groupId>
<artifactId>ktlint-cli</artifactId>
<version>1.0.1</version>
</dependency>
<!-- additional 3rd party ruleset(s) can be specified here -->
</dependencies>
Expand Down
6 changes: 3 additions & 3 deletions src/main/kotlin/no/nav/bidrag/grunnlag/bo/BarnetilsynBo.kt
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package no.nav.bidrag.grunnlag.bo

import io.swagger.v3.oas.annotations.media.Schema
import no.nav.bidrag.domain.enums.barnetilsyn.Skolealder
import no.nav.bidrag.domain.enums.barnetilsyn.Tilsyntype
import no.nav.bidrag.domene.enums.barnetilsyn.Skolealder
import no.nav.bidrag.domene.enums.barnetilsyn.Tilsynstype
import no.nav.bidrag.grunnlag.persistence.entity.Barnetilsyn
import java.time.LocalDate
import java.time.LocalDateTime
Expand Down Expand Up @@ -38,7 +38,7 @@ data class BarnetilsynBo(
val belop: Int? = null,

@Schema(description = "Angir om barnetilsynet er heltid eller deltid")
val tilsynstype: Tilsyntype?,
val tilsynstype: Tilsynstype?,

@Schema(description = "Angir om barnet er over eller under skolealder")
val skolealder: Skolealder?,
Expand Down
5 changes: 4 additions & 1 deletion src/main/kotlin/no/nav/bidrag/grunnlag/bo/RelatertPersonBo.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,10 @@ data class RelatertPersonBo(
@Schema(description = "Angir om den relaterte personen er barn av BM eller BM")
var erBarnAvBmBp: Boolean,

@Schema(description = "Den relaterte personen bor i husstanden fra- og med måned. Hvis periodeFra og periodeTil == null så er personen barn som ikke bor sammen med BM/BP")
@Schema(
description = "Den relaterte personen bor i husstanden fra- og med måned. Hvis periodeFra og periodeTil == null så er personen barn som " +
"ikke bor sammen med BM/BP",
)
val husstandsmedlemPeriodeFra: LocalDate?,

@Schema(description = "Den relaterte personen bor i husstanden til- og med måned")
Expand Down
28 changes: 14 additions & 14 deletions src/main/kotlin/no/nav/bidrag/grunnlag/comparator/AbstractPeriodComparator.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,23 +15,23 @@ abstract class AbstractPeriodComparator<T : PeriodComparable<*, *>> {
}

private fun isInsidePeriod(requestedPeriod: IPeriod, existingPeriod: IPeriod): Boolean {
return existingPeriod.periodeFra.isAfterOrEqual(requestedPeriod.periodeFra) && existingPeriod.periodeTil.isBeforeOrEqual(requestedPeriod.periodeTil)
return existingPeriod.periodeFra.isAfterOrEqual(requestedPeriod.periodeFra) && existingPeriod.periodeTil
.isBeforeOrEqual(requestedPeriod.periodeTil)
}

fun comparePeriodEntities(
requestedPeriod: IPeriod,
newEntities: List<T>,
existingEntities: List<T>,
): ComparatorResult<T> {
fun comparePeriodEntities(requestedPeriod: IPeriod, newEntities: List<T>, existingEntities: List<T>): ComparatorResult<T> {
val expiredEntities = mutableListOf<T>()
val updatedEntities = mutableListOf<T>()
val equalEntities = mutableListOf<T>()

val existingEntitiesWithinRequestedPeriod = filterEntitiesByPeriod(existingEntities, newEntities, requestedPeriod, expiredEntities)
SECURE_LOGGER.debug("${existingEntitiesWithinRequestedPeriod.size} eksisterende entiteter innenfor forespurt periode (${requestedPeriod.periodeFra} - ${requestedPeriod.periodeTil}).")
SECURE_LOGGER.debug(
"${existingEntitiesWithinRequestedPeriod.size} eksisterende entiteter innenfor forespurt periode (${requestedPeriod.periodeFra} - " +
"${requestedPeriod.periodeTil}).",
)
SECURE_LOGGER.debug("${expiredEntities.size} utløpte entiteter før sammenligning.")

newEntities.forEach() { newEntity ->
newEntities.forEach { newEntity ->
val existingEntityWithEqualPeriod = findEntityWithEqualPeriod(newEntity, existingEntitiesWithinRequestedPeriod)
if (existingEntityWithEqualPeriod != null) {
if (isEntitiesEqual(newEntity, existingEntityWithEqualPeriod)) {
Expand All @@ -46,7 +46,10 @@ abstract class AbstractPeriodComparator<T : PeriodComparable<*, *>> {
updatedEntities.add(newEntity)
}
} else {
SECURE_LOGGER.debug("Kunne ikke finne eksisterede entitet for perioden (${newEntity.periodEntity.periodeFra} - ${newEntity.periodEntity.periodeTil}).")
SECURE_LOGGER.debug(
"Kunne ikke finne eksisterede entitet for perioden (${newEntity.periodEntity.periodeFra} - " +
"${newEntity.periodEntity.periodeTil}).",
)
updatedEntities.add(newEntity)
}
}
Expand All @@ -65,10 +68,7 @@ abstract class AbstractPeriodComparator<T : PeriodComparable<*, *>> {
return differences
}

private fun findEntityWithEqualPeriod(
periodEntity: T,
periodEntities: List<T>,
): T? {
private fun findEntityWithEqualPeriod(periodEntity: T, periodEntities: List<T>): T? {
return periodEntities.find { t ->
t.periodEntity.periodeFra.isEqual(periodEntity.periodEntity.periodeFra) && t.periodEntity.periodeTil.isEqual(
periodEntity.periodEntity.periodeTil,
Expand All @@ -83,7 +83,7 @@ abstract class AbstractPeriodComparator<T : PeriodComparable<*, *>> {
expiredEntities: MutableList<T>,
): List<T> {
val filteredEntities = mutableListOf<T>()
existingEntities.forEach() { existingEntity ->
existingEntities.forEach { existingEntity ->
if (isInsidePeriod(requestedPeriod, existingEntity.periodEntity) && periodEntityStillExists(existingEntity, newEntities)) {
filteredEntities.add(existingEntity)
} else {
Expand Down
45 changes: 37 additions & 8 deletions src/main/kotlin/no/nav/bidrag/grunnlag/comparator/AinntektPeriodComparator.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,13 +21,33 @@ class AinntektPeriodComparator : AbstractPeriodComparator<PeriodComparable<Ainnt
differences.putAll(compareFields(newAinntektsposter[i].beskrivelse, existingAinntektsposter[i].beskrivelse, "beskrivelse"))
differences.putAll(compareFields(newAinntektsposter[i].belop, existingAinntektsposter[i].belop, "belop"))
differences.putAll(compareFields(newAinntektsposter[i].fordelType, existingAinntektsposter[i].fordelType, "fordelType"))
differences.putAll(compareFields(newAinntektsposter[i].opplysningspliktigId, existingAinntektsposter[i].opplysningspliktigId, "opplysningspliktigId"))
differences.putAll(compareFields(newAinntektsposter[i].opptjeningsperiodeFra, existingAinntektsposter[i].opptjeningsperiodeFra, "opptjeningsperiodeFra"))
differences.putAll(compareFields(newAinntektsposter[i].opptjeningsperiodeTil, existingAinntektsposter[i].opptjeningsperiodeTil, "opptjeningsperiodeTil"))
differences.putAll(compareFields(newAinntektsposter[i].utbetalingsperiode, existingAinntektsposter[i].utbetalingsperiode, "utbetalingsperiode"))
differences.putAll(
compareFields(newAinntektsposter[i].opplysningspliktigId, existingAinntektsposter[i].opplysningspliktigId, "opplysningspliktigId"),
)
differences.putAll(
compareFields(newAinntektsposter[i].opptjeningsperiodeFra, existingAinntektsposter[i].opptjeningsperiodeFra, "opptjeningsperiodeFra"),
)
differences.putAll(
compareFields(newAinntektsposter[i].opptjeningsperiodeTil, existingAinntektsposter[i].opptjeningsperiodeTil, "opptjeningsperiodeTil"),
)
differences.putAll(
compareFields(newAinntektsposter[i].utbetalingsperiode, existingAinntektsposter[i].utbetalingsperiode, "utbetalingsperiode"),
)
differences.putAll(compareFields(newAinntektsposter[i].virksomhetId, existingAinntektsposter[i].virksomhetId, "virksomhetId"))
differences.putAll(compareFields(newAinntektsposter[i].etterbetalingsperiodeFra, existingAinntektsposter[i].etterbetalingsperiodeFra, "etterbetalingsperiodeFom"))
differences.putAll(compareFields(newAinntektsposter[i].etterbetalingsperiodeTil, existingAinntektsposter[i].etterbetalingsperiodeTil, "etterbetalingsperiodeTom"))
differences.putAll(
compareFields(
newAinntektsposter[i].etterbetalingsperiodeFra,
existingAinntektsposter[i].etterbetalingsperiodeFra,
"etterbetalingsperiodeFom",
),
)
differences.putAll(
compareFields(
newAinntektsposter[i].etterbetalingsperiodeTil,
existingAinntektsposter[i].etterbetalingsperiodeTil,
"etterbetalingsperiodeTom",
),
)
}
if (differences.isNotEmpty()) {
SECURE_LOGGER.debug(toJsonString(differences))
Expand All @@ -38,8 +58,17 @@ class AinntektPeriodComparator : AbstractPeriodComparator<PeriodComparable<Ainnt
private fun sortAinntektsposter(ainntektsposter: List<AinntektspostBo>): List<AinntektspostBo> {
return ainntektsposter.sortedWith(
compareBy(
{ it.utbetalingsperiode }, { it.opptjeningsperiodeFra }, { it.opptjeningsperiodeTil }, { it.opplysningspliktigId }, { it.virksomhetId },
{ it.inntektType }, { it.fordelType }, { it.beskrivelse }, { it.belop }, { it.etterbetalingsperiodeFra }, { it.etterbetalingsperiodeTil },
{ it.utbetalingsperiode },
{ it.opptjeningsperiodeFra },
{ it.opptjeningsperiodeTil },
{ it.opplysningspliktigId },
{ it.virksomhetId },
{ it.inntektType },
{ it.fordelType },
{ it.beskrivelse },
{ it.belop },
{ it.etterbetalingsperiodeFra },
{ it.etterbetalingsperiodeTil },
),
)
}
Expand Down
4 changes: 3 additions & 1 deletion src/main/kotlin/no/nav/bidrag/grunnlag/comparator/SkattegrunnlagPeriodComparator.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,9 @@ class SkattegrunnlagPeriodComparator : AbstractPeriodComparator<PeriodComparable
val existingSkattegrunnlagspost = existingSkattegrunnlagsposter[i]

differences.putAll(compareFields(newSkattegrunnlagspost.inntektType, existingSkattegrunnlagspost.inntektType, "inntektType"))
differences.putAll(compareFields(newSkattegrunnlagspost.skattegrunnlagType, existingSkattegrunnlagspost.skattegrunnlagType, "skattegrunnlagType"))
differences.putAll(
compareFields(newSkattegrunnlagspost.skattegrunnlagType, existingSkattegrunnlagspost.skattegrunnlagType, "skattegrunnlagType"),
)
differences.putAll(compareFields(newSkattegrunnlagspost.belop, existingSkattegrunnlagspost.belop, "belop"))
}
if (differences.isNotEmpty()) {
Expand Down
22 changes: 10 additions & 12 deletions src/main/kotlin/no/nav/bidrag/grunnlag/consumer/bidragperson/BidragPersonConsumer.kt
View file
Original file line number Diff line number Diff line change
@@ -1,9 +1,7 @@
package no.nav.bidrag.grunnlag.consumer.bidragperson

import no.nav.bidrag.commons.web.HttpHeaderRestTemplate
import no.nav.bidrag.domain.ident.PersonIdent
import no.nav.bidrag.domain.number.Fødselsår
import no.nav.bidrag.domain.string.FulltNavn
import no.nav.bidrag.domene.ident.Personident
import no.nav.bidrag.grunnlag.SECURE_LOGGER
import no.nav.bidrag.grunnlag.consumer.GrunnlagsConsumer
import no.nav.bidrag.grunnlag.exception.RestResponse
Expand All @@ -30,29 +28,29 @@ open class BidragPersonConsumer(private val restTemplate: HttpHeaderRestTemplate
val logger: Logger = LoggerFactory.getLogger(BidragPersonConsumer::class.java)
}

open fun hentNavnFoedselOgDoed(personIdent: PersonIdent): RestResponse<NavnFødselDødDto> {
open fun hentNavnFoedselOgDoed(personident: Personident): RestResponse<NavnFødselDødDto> {
logger.info("Kaller bidrag-person som igjen henter info om fødselsdato og eventuelt død fra PDL")

val restResponse = restTemplate.tryExchange(
BIDRAGPERSON_CONTEXT_FOEDSEL_DOED,
HttpMethod.POST,
initHttpEntity(PersonRequest(personIdent)),
initHttpEntity(PersonRequest(personident)),
NavnFødselDødDto::class.java,
NavnFødselDødDto(FulltNavn(""), null, Fødselsår(0), null),
NavnFødselDødDto(navn = "", fødselsdato = null, fødselsår = 0, dødsdato = null),
)

logResponse(SECURE_LOGGER, restResponse)

return restResponse
}

open fun hentForelderBarnRelasjon(personIdent: PersonIdent): RestResponse<ForelderBarnRelasjonDto> {
open fun hentForelderBarnRelasjon(personident: Personident): RestResponse<ForelderBarnRelasjonDto> {
logger.info("Kaller bidrag-person som igjen henter forelderbarnrelasjoner for angitt person fra PDL")

val restResponse = restTemplate.tryExchange(
BIDRAGPERSON_CONTEXT_FORELDER_BARN_RELASJON,
HttpMethod.POST,
initHttpEntity(PersonRequest(personIdent)),
initHttpEntity(PersonRequest(personident)),
ForelderBarnRelasjonDto::class.java,
ForelderBarnRelasjonDto(emptyList()),
)
Expand All @@ -62,7 +60,7 @@ open class BidragPersonConsumer(private val restTemplate: HttpHeaderRestTemplate
return restResponse
}

open fun hentHusstandsmedlemmer(personIdent: PersonIdent): RestResponse<HusstandsmedlemmerDto> {
open fun hentHusstandsmedlemmer(personident: Personident): RestResponse<HusstandsmedlemmerDto> {
logger.info(
"Kaller bidrag-person som igjen henter info om en persons bostedsadresser " +
"og personer som har bodd på samme adresse på samme tid fra PDL",
Expand All @@ -71,7 +69,7 @@ open class BidragPersonConsumer(private val restTemplate: HttpHeaderRestTemplate
val restResponse = restTemplate.tryExchange(
BIDRAGPERSON_CONTEXT_HUSSTANDSMEDLEMMER,
HttpMethod.POST,
initHttpEntity(PersonRequest(personIdent)),
initHttpEntity(PersonRequest(personident)),
HusstandsmedlemmerDto::class.java,
HusstandsmedlemmerDto(emptyList()),
)
Expand All @@ -81,13 +79,13 @@ open class BidragPersonConsumer(private val restTemplate: HttpHeaderRestTemplate
return restResponse
}

open fun hentSivilstand(personIdent: PersonIdent): RestResponse<SivilstandshistorikkDto> {
open fun hentSivilstand(personident: Personident): RestResponse<SivilstandshistorikkDto> {
logger.info("Kaller bidrag-person som igjen kaller PDL for å finne en persons sivilstand")

val restResponse = restTemplate.tryExchange(
BIDRAGPERSON_CONTEXT_SIVILSTAND,
HttpMethod.POST,
initHttpEntity(PersonRequest(personIdent)),
initHttpEntity(PersonRequest(personident)),
SivilstandshistorikkDto::class.java,
SivilstandshistorikkDto(emptyList()),
)
Expand Down
Loading

0 comments on commit 471f583

Please sign in to comment.