Skip to content

Commit

Permalink
Merge pull request #336 from navikt/feature/logging
Browse files Browse the repository at this point in the history
Endret mye av loggingen til å logge på json-format. Endret på log-lev…
  • Loading branch information
LarsOttoHaugen authored Apr 26, 2024
2 parents 6899ddf + cc8830d commit 7cab7bc
Show file tree
Hide file tree
Showing 29 changed files with 170 additions and 143 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ open class GrunnlagsConsumer {

fun <T> logResponse(logger: Logger, restResponse: RestResponse<T>) {
when (restResponse) {
is RestResponse.Success -> logger.info("Response: ${HttpStatus.OK}")
is RestResponse.Success -> logger.debug("Response: {}", HttpStatus.OK)
is RestResponse.Failure -> logger.warn("Response: ${restResponse.statusCode}/${restResponse.message}")
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ import no.nav.bidrag.grunnlag.consumer.arbeidsforhold.api.Arbeidsforhold
import no.nav.bidrag.grunnlag.consumer.arbeidsforhold.api.HentArbeidsforholdRequest
import no.nav.bidrag.grunnlag.exception.RestResponse
import no.nav.bidrag.grunnlag.exception.tryExchange
import no.nav.bidrag.grunnlag.util.GrunnlagUtil.Companion.tilJson
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import org.springframework.core.ParameterizedTypeReference
Expand All @@ -26,7 +27,7 @@ open class ArbeidsforholdConsumer(private val restTemplate: HttpHeaderRestTempla

@Retryable(value = [Exception::class], backoff = Backoff(delay = 500))
open fun hentArbeidsforhold(request: HentArbeidsforholdRequest): RestResponse<List<Arbeidsforhold>> {
SECURE_LOGGER.info("Henter arbeidsforhold fra Aareg med request: $request")
SECURE_LOGGER.info("Henter arbeidsforhold fra Aareg med request: ${tilJson(request)}")

val responseType = object : ParameterizedTypeReference<List<Arbeidsforhold>>() {}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ import no.nav.bidrag.grunnlag.consumer.arbeidsforhold.api.HentEnhetsregisterRequ
import no.nav.bidrag.grunnlag.consumer.arbeidsforhold.api.HentEnhetsregisterResponse
import no.nav.bidrag.grunnlag.exception.RestResponse
import no.nav.bidrag.grunnlag.exception.tryExchange
import no.nav.bidrag.grunnlag.util.GrunnlagUtil.Companion.tilJson
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import org.springframework.http.HttpMethod
Expand All @@ -24,7 +25,7 @@ open class EnhetsregisterConsumer(private val restTemplate: HttpHeaderRestTempla
@Retryable(value = [Exception::class], backoff = Backoff(delay = 500))
open fun hentEnhetsinfo(request: HentEnhetsregisterRequest): RestResponse<HentEnhetsregisterResponse> {
LOGGER.info("Henter info om en organisasjon fra Ereg")
SECURE_LOGGER.info("Henter info om en organisasjon fra Ereg med request: $request")
SECURE_LOGGER.info("Henter info om en organisasjon fra Ereg med request: ${tilJson(request)}")

val restResponse = restTemplate.tryExchange(
byggEregUrl(request),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ open class BidragPersonConsumer(private val restTemplate: HttpHeaderRestTemplate

@Retryable(value = [Exception::class], backoff = Backoff(delay = 500))
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")
logger.debug("Kaller bidrag-person som igjen henter info om fødselsdato og eventuelt død fra PDL")

val restResponse = restTemplate.tryExchange(
BIDRAGPERSON_CONTEXT_FOEDSEL_DOED,
Expand Down Expand Up @@ -108,7 +108,7 @@ open class BidragPersonConsumer(private val restTemplate: HttpHeaderRestTemplate

@Retryable(value = [Exception::class], backoff = Backoff(delay = 500))
open fun hentPersonidenter(personident: Personident, inkludereHistoriske: Boolean): RestResponse<List<PersonidentDto>> {
logger.info("Kaller bidrag-person som igjen kaller PDL for å finne en persons historiske identer")
logger.debug("Kaller bidrag-person som igjen kaller PDL for å finne en persons historiske identer")

val responseType = object : ParameterizedTypeReference<List<PersonidentDto>>() {}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ open class FamilieBaSakConsumer(private val restTemplate: HttpHeaderRestTemplate

@Retryable(value = [Exception::class], backoff = Backoff(delay = 500))
open fun hentFamilieBaSak(request: FamilieBaSakRequest): RestResponse<FamilieBaSakResponse> {
logger.info("Henter utvidet barnetrygd og småbarnstillegg fra familie-ba-sak")
logger.debug("Henter utvidet barnetrygd og småbarnstillegg fra familie-ba-sak")

val restResponse = restTemplate.tryExchange(
FAMILIEBASAK_CONTEXT,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ open class FamilieEfSakConsumer(

@Retryable(value = [Exception::class], backoff = Backoff(delay = 500))
open fun hentBarnetilsyn(request: BarnetilsynRequest): RestResponse<BarnetilsynResponse> {
logger.info("Henter barnetilsyn")
logger.debug("Henter barnetilsyn")

val restResponse = restTemplate.tryExchange(
BARNETILSYN_CONTEXT,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,9 +28,9 @@ open class InntektskomponentenConsumer(private val restTemplate: HttpHeaderRestT
@Retryable(value = [Exception::class], backoff = Backoff(delay = 500))
open fun hentInntekter(request: HentInntektListeRequest, abonnerteInntekterRequest: Boolean): RestResponse<HentInntektListeResponse> {
if (abonnerteInntekterRequest) {
LOGGER.info("Henter abonnerte inntekter fra Inntektskomponenten.")
LOGGER.debug("Henter abonnerte inntekter fra Inntektskomponenten.")
} else {
LOGGER.info("Henter inntekter fra Inntektskomponenten.")
LOGGER.debug("Henter inntekter fra Inntektskomponenten.")
}
SECURE_LOGGER.info("HentInntektListeRequest: $request")
val url = if (abonnerteInntekterRequest) DETALJERTE_ABONNERTE_INNTEKTER_CONTEXT else INNTEKT_LISTE_CONTEXT
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ import no.nav.bidrag.grunnlag.ISSUER
import no.nav.bidrag.grunnlag.SECURE_LOGGER
import no.nav.bidrag.grunnlag.service.GrunnlagspakkeService
import no.nav.bidrag.grunnlag.service.HentGrunnlagService
import no.nav.bidrag.grunnlag.util.GrunnlagUtil.Companion.tilJson
import no.nav.bidrag.transport.behandling.grunnlag.request.HentGrunnlagRequestDto
import no.nav.bidrag.transport.behandling.grunnlag.request.OppdaterGrunnlagspakkeRequestDto
import no.nav.bidrag.transport.behandling.grunnlag.request.OpprettGrunnlagspakkeRequestDto
Expand Down Expand Up @@ -47,7 +48,7 @@ class GrunnlagController(
request: OpprettGrunnlagspakkeRequestDto,
): Int? {
val grunnlagspakkeOpprettet = grunnlagspakkeService.opprettGrunnlagspakke(request)
LOGGER.info("Følgende grunnlagspakke er opprettet: $grunnlagspakkeOpprettet")
LOGGER.info("Grunnlagspakke er opprettet med id: $grunnlagspakkeOpprettet")
return grunnlagspakkeOpprettet
}

Expand All @@ -69,9 +70,9 @@ class GrunnlagController(
@Valid @RequestBody
request: OppdaterGrunnlagspakkeRequestDto,
): OppdaterGrunnlagspakkeDto? {
SECURE_LOGGER.info("Oppdaterer grunnlagspakkeId: $grunnlagspakkeId med request: ${tilJson(request)}")
val grunnlagspakkeOppdatert = grunnlagspakkeService.oppdaterGrunnlagspakke(grunnlagspakkeId, request)
LOGGER.info("Følgende grunnlagspakke ble oppdatert: $grunnlagspakkeId")
SECURE_LOGGER.info("Oppdater grunnlagspakkeId: $grunnlagspakkeId med request: $request")
return grunnlagspakkeOppdatert
}

Expand All @@ -93,7 +94,7 @@ class GrunnlagController(
): HentGrunnlagspakkeDto? {
val grunnlagspakkeFunnet = grunnlagspakkeService.hentGrunnlagspakke(grunnlagspakkeId)
LOGGER.info("Følgende grunnlagspakke ble hentet: ${grunnlagspakkeFunnet.grunnlagspakkeId}")
SECURE_LOGGER.info("Hent grunnlagspakke med id: $grunnlagspakkeId ga følgende response: $grunnlagspakkeFunnet")
SECURE_LOGGER.info("Hent av grunnlagspakke med id: $grunnlagspakkeId ga følgende response: ${tilJson(grunnlagspakkeFunnet)}")

return grunnlagspakkeFunnet
}
Expand Down Expand Up @@ -138,9 +139,9 @@ class GrunnlagController(
@Valid @RequestBody
request: HentGrunnlagRequestDto,
): HentGrunnlagDto? {
SECURE_LOGGER.info("Henter grunnlag med request: ${tilJson(request)}")
val hentGrunnlagDto = hentGrunnlagService.hentGrunnlag(request)
SECURE_LOGGER.info("Følgende hentGrunnlagRequest ble behandlet: $request")
SECURE_LOGGER.info("Følgende HentGrunnlagDto ble sendt som respons: $hentGrunnlagDto")
SECURE_LOGGER.info("Hent av grunnlag ga følgende respons: ${tilJson(hentGrunnlagDto)}")
return hentGrunnlagDto
}

Expand Down
26 changes: 17 additions & 9 deletions src/main/kotlin/no/nav/bidrag/grunnlag/model/OppdaterAinntekt.kt
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ import no.nav.bidrag.grunnlag.service.PersonIdOgPeriodeRequest
import no.nav.bidrag.grunnlag.util.GrunnlagUtil.Companion.JANUAR2015
import no.nav.bidrag.grunnlag.util.GrunnlagUtil.Companion.finnFilter
import no.nav.bidrag.grunnlag.util.GrunnlagUtil.Companion.finnFormaal
import no.nav.bidrag.grunnlag.util.GrunnlagUtil.Companion.tilJson
import no.nav.bidrag.transport.behandling.grunnlag.response.OppdaterGrunnlagDto
import no.nav.tjenester.aordningen.inntektsinformasjon.AktoerType
import org.apache.commons.lang3.StringUtils
Expand Down Expand Up @@ -47,18 +48,25 @@ class OppdaterAinntekt(
// 2015.01 hvis periodeFra er tidligere enn det. Hvis periodeTil er før januar 2015 så gjøres det ikke et kall.
//
if (personIdOgPeriode.periodeTil.isBefore(LocalDate.of(2015, 1, 1))) {
LOGGER.info("Ugyldig periode angitt i HentInntektRequest (Inntektskomponenten). PeriodeTil må være januar 2015 eller senere")
SECURE_LOGGER.info(
"Ugyldig periode angitt i HentInntektRequest (Inntektskomponenten). PeriodeTil må være januar 2015 eller senere: " +
"$personIdOgPeriode",
LOGGER.warn("Ugyldig periode angitt i HentInntektRequest (Inntektskomponenten). PeriodeTil må være januar 2015 eller senere")
SECURE_LOGGER.warn(
"Ugyldig periode angitt i HentInntektRequest (Inntektskomponenten). PeriodeTil må være januar 2015 eller senere: ${
tilJson(
personIdOgPeriode,
)
}",
)
} else {
val periodeFra: String
if (personIdOgPeriode.periodeFra.isBefore(LocalDate.parse("2015-01-01"))) {
periodeFra = JANUAR2015
LOGGER.info("For gammel periodeFra angitt i HentInntektRequest (Inntektskomponenten), overstyres til januar 2015")
SECURE_LOGGER.info(
"For gammel periodeFra angitt i HentInntektRequest (Inntektskomponenten), overstyres til januar 2015: $personIdOgPeriode",
LOGGER.warn("For gammel periodeFra angitt i HentInntektRequest (Inntektskomponenten), overstyres til januar 2015")
SECURE_LOGGER.warn(
"For gammel periodeFra angitt i HentInntektRequest (Inntektskomponenten), overstyres til januar 2015: ${
tilJson(
personIdOgPeriode,
)
}",
)
} else {
periodeFra = personIdOgPeriode.periodeFra.toString().substring(0, 7)
Expand All @@ -78,10 +86,10 @@ class OppdaterAinntekt(
hentInntektListeRequestListe.forEach { hentInntektListeRequest ->
// Henter inntekter for ett og ett år (litt uvisst hvorfor det er løst slik)

SECURE_LOGGER.info("Kaller InntektskomponentenService med request: $hentInntektListeRequest")
SECURE_LOGGER.info("Kaller InntektskomponentenService med request: ${tilJson(hentInntektListeRequest)}")

val hentInntektListeResponseIntern = inntektskomponentenService.hentInntekt(hentInntektListeRequest)
SECURE_LOGGER.info("Inntektskomponenten ga følgende respons: $hentInntektListeResponseIntern")
SECURE_LOGGER.info("Inntektskomponenten ga følgende respons: ${tilJson(hentInntektListeResponseIntern)}")

if (hentInntektListeResponseIntern.exceptionKastet) {
this.add(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,9 +11,8 @@ import no.nav.bidrag.grunnlag.consumer.pensjon.api.HentBarnetilleggPensjonReques
import no.nav.bidrag.grunnlag.exception.RestResponse
import no.nav.bidrag.grunnlag.service.PersistenceService
import no.nav.bidrag.grunnlag.service.PersonIdOgPeriodeRequest
import no.nav.bidrag.grunnlag.util.GrunnlagUtil.Companion.tilJson
import no.nav.bidrag.transport.behandling.grunnlag.response.OppdaterGrunnlagDto
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import org.springframework.http.HttpStatus
import java.time.LocalDateTime

Expand All @@ -24,11 +23,6 @@ class OppdaterBarnetillegg(
private val pensjonConsumer: PensjonConsumer,
) : MutableList<OppdaterGrunnlagDto> by mutableListOf() {

companion object {
@JvmStatic
private val LOGGER: Logger = LoggerFactory.getLogger(OppdaterBarnetillegg::class.java)
}

fun oppdaterBarnetillegg(
barnetilleggRequestListe: List<PersonIdOgPeriodeRequest>,
historiskeIdenterMap: Map<String, List<String>>,
Expand All @@ -41,8 +35,7 @@ class OppdaterBarnetillegg(
tom = personIdOgPeriode.periodeTil.minusDays(1),
)

LOGGER.info("Kaller barnetillegg pensjon")
SECURE_LOGGER.info("Kaller barnetillegg pensjon med request: $hentBarnetilleggPensjonRequest")
SECURE_LOGGER.info("Kaller barnetillegg pensjon med request: ${tilJson(hentBarnetilleggPensjonRequest)}")

try {
when (
Expand All @@ -52,7 +45,7 @@ class OppdaterBarnetillegg(
is RestResponse.Success -> {
val barnetilleggPensjonResponse = restResponseBarnetilleggPensjon.body

SECURE_LOGGER.info("Barnetillegg pensjon ga følgende respons: $barnetilleggPensjonResponse")
SECURE_LOGGER.info("Barnetillegg pensjon ga følgende respons: ${tilJson(barnetilleggPensjonResponse)}")

persistenceService.oppdaterEksisterendeBarnetilleggPensjonTilInaktiv(
grunnlagspakkeId = grunnlagspakkeId,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,9 +10,8 @@ import no.nav.bidrag.grunnlag.consumer.familieefsak.api.BarnetilsynRequest
import no.nav.bidrag.grunnlag.exception.RestResponse
import no.nav.bidrag.grunnlag.service.PersistenceService
import no.nav.bidrag.grunnlag.service.PersonIdOgPeriodeRequest
import no.nav.bidrag.grunnlag.util.GrunnlagUtil.Companion.tilJson
import no.nav.bidrag.transport.behandling.grunnlag.response.OppdaterGrunnlagDto
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import java.time.LocalDate
import java.time.LocalDateTime
import java.time.Month
Expand All @@ -25,11 +24,6 @@ class OppdaterBarnetilsyn(
private val familieEfSakConsumer: FamilieEfSakConsumer,
) : MutableList<OppdaterGrunnlagDto> by mutableListOf() {

companion object {
@JvmStatic
private val LOGGER: Logger = LoggerFactory.getLogger(OppdaterBarnetilsyn::class.java)
}

fun oppdaterBarnetilsyn(
barnetilsynRequestListe: List<PersonIdOgPeriodeRequest>,
historiskeIdenterMap: Map<String, List<String>>,
Expand All @@ -42,8 +36,7 @@ class OppdaterBarnetilsyn(
personIdOgPeriode.periodeFra,
)

LOGGER.info("Henter barnetilsyn for enslig forsørger")
SECURE_LOGGER.info("Kaller barnetilsyn enslig forsørger med request: $barnetilsynRequest")
SECURE_LOGGER.info("Kaller barnetilsyn enslig forsørger med request: ${tilJson(barnetilsynRequest)}")

try {
when (
Expand All @@ -52,7 +45,7 @@ class OppdaterBarnetilsyn(
) {
is RestResponse.Success -> {
val barnetilsynResponse = restResponseBarnetilsyn.body
SECURE_LOGGER.info("Barnetilsyn ga følgende respons: $barnetilsynResponse")
SECURE_LOGGER.info("Barnetilsyn ga følgende respons: ${tilJson(barnetilsynResponse)}")

persistenceService.oppdaterEksisterendeBarnetilsynTilInaktiv(
grunnlagspakkeId = grunnlagspakkeId,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,8 @@ import no.nav.bidrag.grunnlag.consumer.familiekssak.api.BisysDto
import no.nav.bidrag.grunnlag.exception.RestResponse
import no.nav.bidrag.grunnlag.service.PersistenceService
import no.nav.bidrag.grunnlag.service.PersonIdOgPeriodeRequest
import no.nav.bidrag.grunnlag.util.GrunnlagUtil.Companion.tilJson
import no.nav.bidrag.transport.behandling.grunnlag.response.OppdaterGrunnlagDto
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import org.springframework.http.HttpStatus
import java.time.LocalDate
import java.time.LocalDateTime
Expand All @@ -24,11 +23,6 @@ class OppdaterKontantstotte(
private val familieKsSakConsumer: FamilieKsSakConsumer,
) : MutableList<OppdaterGrunnlagDto> by mutableListOf() {

companion object {
@JvmStatic
private val LOGGER: Logger = LoggerFactory.getLogger(OppdaterBarnetillegg::class.java)
}

fun oppdaterKontantstotte(
kontantstotteRequestListe: List<PersonIdOgPeriodeRequest>,
historiskeIdenterMap: Map<String, List<String>>,
Expand All @@ -44,8 +38,7 @@ class OppdaterKontantstotte(
identer = personIdListe,
)

LOGGER.info("Kaller kontantstøtte")
SECURE_LOGGER.info("Kaller kontantstøtte med request: $innsynRequest")
SECURE_LOGGER.info("Kaller kontantstøtte med request: ${tilJson(innsynRequest)}")

try {
when (
Expand All @@ -54,7 +47,7 @@ class OppdaterKontantstotte(
) {
is RestResponse.Success -> {
val kontantstotteResponse = restResponseKontantstotte.body
SECURE_LOGGER.info("kontantstøtte ga følgende respons: $kontantstotteResponse")
SECURE_LOGGER.info("kontantstøtte ga følgende respons: ${tilJson(kontantstotteResponse)}")

persistenceService.oppdaterEksisterendeKontantstotteTilInaktiv(
grunnlagspakkeId = grunnlagspakkeId,
Expand Down Expand Up @@ -133,7 +126,7 @@ class OppdaterKontantstotte(
"${personIdOgPeriode.periodeTil}.",
),
)
SECURE_LOGGER.info("kontantstøtte familie-ks-sak svarer med feil, respons: $restResponseKontantstotte")
SECURE_LOGGER.warn("kontantstøtte familie-ks-sak svarte med feil, respons: ${tilJson(restResponseKontantstotte)}")
}
}
} catch (e: Exception) {
Expand Down
Loading

0 comments on commit 7cab7bc

Please sign in to comment.