diff --git a/.github/workflows/delete_images.yml b/.github/workflows/delete_images.yml deleted file mode 100644 index 7d092d4b..00000000 --- a/.github/workflows/delete_images.yml +++ /dev/null @@ -1,23 +0,0 @@ -name: 'Remove Old Images' -on: - workflow_dispatch: - schedule: - - cron: '0 4 * * *' - -jobs: - remove-images: - name: 'Remove old images job' - runs-on: ubuntu-latest - permissions: - packages: write - steps: - - uses: actions/delete-package-versions@v5 - with: - package-name: 'familie-oppdrag/familie-oppdrag' - package-type: 'container' - min-versions-to-keep: 1 - - uses: actions/delete-package-versions@v5 - with: - package-name: 'familie-oppdrag' - package-type: 'container' - min-versions-to-keep: 1 \ No newline at end of file diff --git a/pom.xml b/pom.xml index 8a36b7a3..209dd264 100644 --- a/pom.xml +++ b/pom.xml @@ -505,7 +505,7 @@ com.pinterest.ktlint ktlint-cli - 1.2.1 + 1.3.1 diff --git a/src/main/kotlin/no/nav/familie/oppdrag/avstemming/AvstemmingMapper.kt b/src/main/kotlin/no/nav/familie/oppdrag/avstemming/AvstemmingMapper.kt index eb1827c9..774ad9cd 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/avstemming/AvstemmingMapper.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/avstemming/AvstemmingMapper.kt @@ -12,8 +12,8 @@ object AvstemmingMapper { return Base64.getUrlEncoder().encodeToString(bb.array()).substring(0, 22) } - fun fagområdeTilAvleverendeKomponentKode(fagområde: String): String { - return when (fagområde) { + fun fagområdeTilAvleverendeKomponentKode(fagområde: String): String = + when (fagområde) { "EFOG" -> "EF" "EFBT" -> "EF" "EFSP" -> "EF" @@ -21,9 +21,10 @@ object AvstemmingMapper { "KS" -> "KS" else -> throw Error("$fagområde støttes ikke ennå") } - } } -enum class SystemKode(val kode: String) { +enum class SystemKode( + val kode: String, +) { OPPDRAGSSYSTEMET("OS"), } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/common/SOAPFaultExceptionUtil.kt b/src/main/kotlin/no/nav/familie/oppdrag/common/SOAPFaultExceptionUtil.kt index a023403b..bb4b0c35 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/common/SOAPFaultExceptionUtil.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/common/SOAPFaultExceptionUtil.kt @@ -9,7 +9,10 @@ fun logSoapFaultException(e: Exception) { if (e is SOAPFaultException) { val details = e.fault.detail?.let { detail -> - detail.detailEntries.asSequence().mapNotNull { it.textContent }.joinToString(",") + detail.detailEntries + .asSequence() + .mapNotNull { it.textContent } + .joinToString(",") } secureLogger.error( "SOAPFaultException -" + diff --git a/src/main/kotlin/no/nav/familie/oppdrag/config/ApiExceptionHandler.kt b/src/main/kotlin/no/nav/familie/oppdrag/config/ApiExceptionHandler.kt index 65d52a4a..42d7baeb 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/config/ApiExceptionHandler.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/config/ApiExceptionHandler.kt @@ -24,9 +24,7 @@ class ApiExceptionHandler { @ExceptionHandler(JwtTokenUnauthorizedException::class) fun handleJwtTokenUnauthorizedException( jwtTokenUnauthorizedException: JwtTokenUnauthorizedException, - ): ResponseEntity> { - return unauthorized("Unauthorized") - } + ): ResponseEntity> = unauthorized("Unauthorized") @ExceptionHandler(Throwable::class) fun handleThrowable(throwable: Throwable): ResponseEntity> { @@ -38,7 +36,8 @@ class ApiExceptionHandler { fun handleThrowable(feil: IntegrasjonException): ResponseEntity> { secureLogger.error("Feil mot ${feil.system} har oppstått", feil) logger.error("Feil mot ${feil.system} har oppstått exception=${getMostSpecificCause(feil)::class}") - return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR) + return ResponseEntity + .status(HttpStatus.INTERNAL_SERVER_ERROR) .body(Ressurs.failure(errorMessage = feil.message)) } @@ -48,7 +47,8 @@ class ApiExceptionHandler { return when (tssException) { is TssConnectionException -> serviceUnavailable(tssException.message!!, tssException) is TssNoDataFoundException -> { - ResponseEntity.status(HttpStatus.NOT_FOUND) + ResponseEntity + .status(HttpStatus.NOT_FOUND) .body(Ressurs.failure(errorMessage = tssException.message)) } else -> illegalState(tssException.message!!, tssException) @@ -58,7 +58,8 @@ class ApiExceptionHandler { @ExceptionHandler(FinnesIkkeITps::class) fun handleThrowable(feil: FinnesIkkeITps): ResponseEntity> { logger.warn("Personen finnes ikke i TPS system=${feil.system} ") - return ResponseEntity.status(HttpStatus.BAD_REQUEST) + return ResponseEntity + .status(HttpStatus.BAD_REQUEST) .body(Ressurs.failure(errorMessage = "Personen finnes ikke i TPS")) } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/config/DatabaseConfiguration.kt b/src/main/kotlin/no/nav/familie/oppdrag/config/DatabaseConfiguration.kt index f689ef0f..8306a159 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/config/DatabaseConfiguration.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/config/DatabaseConfiguration.kt @@ -20,18 +20,14 @@ import javax.sql.DataSource @Configuration class DatabaseConfiguration : AbstractJdbcConfiguration() { @Bean - fun operations(dataSource: DataSource): NamedParameterJdbcTemplate { - return NamedParameterJdbcTemplate(dataSource) - } + fun operations(dataSource: DataSource): NamedParameterJdbcTemplate = NamedParameterJdbcTemplate(dataSource) @Bean - fun transactionManager(dataSource: DataSource): PlatformTransactionManager { - return DataSourceTransactionManager(dataSource) - } + fun transactionManager(dataSource: DataSource): PlatformTransactionManager = DataSourceTransactionManager(dataSource) @Bean - override fun jdbcCustomConversions(): JdbcCustomConversions { - return JdbcCustomConversions( + override fun jdbcCustomConversions(): JdbcCustomConversions = + JdbcCustomConversions( listOf( PGobjectTilUtbetalingsoppdragConverter(), UtbetalingsoppdragTilPGobjectConverter(), @@ -39,13 +35,10 @@ class DatabaseConfiguration : AbstractJdbcConfiguration() { MmelTilPGobjectConverter(), ), ) - } @ReadingConverter class PGobjectTilUtbetalingsoppdragConverter : Converter { - override fun convert(pGobject: PGobject): Utbetalingsoppdrag? { - return pGobject.value?.let { objectMapper.readValue(it) } - } + override fun convert(pGobject: PGobject): Utbetalingsoppdrag? = pGobject.value?.let { objectMapper.readValue(it) } } @WritingConverter @@ -59,9 +52,7 @@ class DatabaseConfiguration : AbstractJdbcConfiguration() { @ReadingConverter class PGobjectTilMmelConverter : Converter { - override fun convert(pGobject: PGobject): Mmel? { - return pGobject.value?.let { objectMapper.readValue(it) } - } + override fun convert(pGobject: PGobject): Mmel? = pGobject.value?.let { objectMapper.readValue(it) } } @WritingConverter diff --git a/src/main/kotlin/no/nav/familie/oppdrag/config/IntegrasjonException.kt b/src/main/kotlin/no/nav/familie/oppdrag/config/IntegrasjonException.kt index 1a92f9e3..f1383455 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/config/IntegrasjonException.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/config/IntegrasjonException.kt @@ -11,4 +11,6 @@ open class IntegrasjonException( throwable: Throwable? = null, ) : RuntimeException(msg, throwable) -open class FinnesIkkeITps(val system: Integrasjonssystem) : RuntimeException() +open class FinnesIkkeITps( + val system: Integrasjonssystem, +) : RuntimeException() diff --git a/src/main/kotlin/no/nav/familie/oppdrag/config/OppdragMQConfig.kt b/src/main/kotlin/no/nav/familie/oppdrag/config/OppdragMQConfig.kt index b055166e..80302474 100755 --- a/src/main/kotlin/no/nav/familie/oppdrag/config/OppdragMQConfig.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/config/OppdragMQConfig.kt @@ -70,12 +70,11 @@ class OppdragMQConfig( } @Bean - fun jmsTemplateUtgående(mqQueueConnectionFactory: ConnectionFactory): JmsTemplate { - return JmsTemplate(mqQueueConnectionFactory).apply { + fun jmsTemplateUtgående(mqQueueConnectionFactory: ConnectionFactory): JmsTemplate = + JmsTemplate(mqQueueConnectionFactory).apply { defaultDestinationName = sendQueue isSessionTransacted = true } - } @Bean fun tssConnectionFactory(): ConnectionFactory { @@ -131,7 +130,6 @@ class OppdragMQConfig( } @Bean - fun jmsTemplateAvstemming(mqQueueConnectionFactory: ConnectionFactory): JmsTemplate { - return JmsTemplate(mqQueueConnectionFactory).apply { defaultDestinationName = avstemmingQueue } - } + fun jmsTemplateAvstemming(mqQueueConnectionFactory: ConnectionFactory): JmsTemplate = + JmsTemplate(mqQueueConnectionFactory).apply { defaultDestinationName = avstemmingQueue } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/config/ServiceConfig.kt b/src/main/kotlin/no/nav/familie/oppdrag/config/ServiceConfig.kt index d2ac5198..ba079374 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/config/ServiceConfig.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/config/ServiceConfig.kt @@ -16,13 +16,13 @@ class ServiceConfig( @Value("\${OPPDRAG_SERVICE_URL}") private val simulerFpServiceUrl: String, ) { @Bean - fun stsConfig(): StsConfig { - return StsConfig.builder() + fun stsConfig(): StsConfig = + StsConfig + .builder() .url(stsUrl) .username(systemuserUsername) .password(systemuserPwd) .build() - } @Bean fun simulerFpServicePort(): SimulerFpService = diff --git a/src/main/kotlin/no/nav/familie/oppdrag/config/SwaggerConfig.kt b/src/main/kotlin/no/nav/familie/oppdrag/config/SwaggerConfig.kt index 24a3a1bd..bff3a8cc 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/config/SwaggerConfig.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/config/SwaggerConfig.kt @@ -13,18 +13,17 @@ class SwaggerConfig { private val bearer = "JWT" @Bean - fun openApi(): OpenAPI { - return OpenAPI().info(Info().title("Familie oppdrag api")) + fun openApi(): OpenAPI = + OpenAPI() + .info(Info().title("Familie oppdrag api")) .components(Components().addSecuritySchemes(bearer, bearerTokenSecurityScheme())) .addSecurityItem(SecurityRequirement().addList(bearer, listOf("read", "write"))) - } - private fun bearerTokenSecurityScheme(): SecurityScheme { - return SecurityScheme() + private fun bearerTokenSecurityScheme(): SecurityScheme = + SecurityScheme() .type(SecurityScheme.Type.APIKEY) .scheme(bearer) .bearerFormat("JWT") .`in`(SecurityScheme.In.HEADER) .name("Authorization") - } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/domene/OppdragIdMapping.kt b/src/main/kotlin/no/nav/familie/oppdrag/domene/OppdragIdMapping.kt index c871869c..91d905ca 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/domene/OppdragIdMapping.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/domene/OppdragIdMapping.kt @@ -8,5 +8,7 @@ val Oppdrag.id: OppdragId OppdragId( this.oppdrag110.kodeFagomraade, this.oppdrag110.oppdragGjelderId, - this.oppdrag110.oppdragsLinje150?.get(0)?.henvisning!!, + this.oppdrag110.oppdragsLinje150 + ?.get(0) + ?.henvisning!!, ) diff --git a/src/main/kotlin/no/nav/familie/oppdrag/grensesnittavstemming/GrensesnittavstemmingMapper.kt b/src/main/kotlin/no/nav/familie/oppdrag/grensesnittavstemming/GrensesnittavstemmingMapper.kt index a9200213..7bda4c2d 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/grensesnittavstemming/GrensesnittavstemmingMapper.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/grensesnittavstemming/GrensesnittavstemmingMapper.kt @@ -57,8 +57,8 @@ class GrensesnittavstemmingMapper( aksjon = opprettAksjonsdata(aksjonType) } - private fun opprettAksjonsdata(aksjonType: AksjonType): Aksjonsdata { - return Aksjonsdata().apply { + private fun opprettAksjonsdata(aksjonType: AksjonType): Aksjonsdata = + Aksjonsdata().apply { this.aksjonType = aksjonType this.kildeType = KildeType.AVLEV this.avstemmingType = AvstemmingType.GRSN @@ -70,18 +70,16 @@ class GrensesnittavstemmingMapper( this.avleverendeAvstemmingId = avstemmingId this.brukerId = fagområde } - } - private fun opprettAvstemmingsdataLister(oppdragsliste: List): List { - return opprettDetaljdata(oppdragsliste).chunked(ANTALL_DETALJER_PER_MELDING).map { + private fun opprettAvstemmingsdataLister(oppdragsliste: List): List = + opprettDetaljdata(oppdragsliste).chunked(ANTALL_DETALJER_PER_MELDING).map { lagMelding(AksjonType.DATA).apply { this.detalj.addAll(it) } } - } - private fun opprettDetaljdata(oppdragsliste: List): List { - return oppdragsliste.mapNotNull { oppdrag -> + private fun opprettDetaljdata(oppdragsliste: List): List = + oppdragsliste.mapNotNull { oppdrag -> leggTilGrunnlagsinformasjon(oppdrag) leggTilTotalData(oppdrag) @@ -106,7 +104,6 @@ class GrensesnittavstemmingMapper( null } } - } private fun håndterAvstemmingstidspunkt(oppdrag: OppdragTilAvstemming) { val fom = avstemmingstidspunkt.fom @@ -159,13 +156,12 @@ class GrensesnittavstemmingMapper( OppdragStatus.KVITTERT_UKJENT -> null } - private fun opprettTotalData(): Totaldata { - return Totaldata().apply { + private fun opprettTotalData(): Totaldata = + Totaldata().apply { this.totalAntall = total.antall this.totalBelop = BigDecimal.valueOf(total.beløp) this.fortegn = getFortegn(total.beløp) } - } private fun opprettPeriodeData(): Periodedata { val fom = @@ -180,8 +176,8 @@ class GrensesnittavstemmingMapper( } } - private fun opprettGrunnlagsData(): Grunnlagsdata { - return Grunnlagsdata().apply { + private fun opprettGrunnlagsData(): Grunnlagsdata = + Grunnlagsdata().apply { godkjentAntall = grunnlagsdata.godkjentAntall godkjentBelop = BigDecimal.valueOf(grunnlagsdata.godkjentBelop) godkjentFortegn = getFortegn(grunnlagsdata.godkjentBelop) @@ -198,17 +194,18 @@ class GrensesnittavstemmingMapper( avvistBelop = BigDecimal.valueOf(grunnlagsdata.avvistBelop) avvistFortegn = getFortegn(grunnlagsdata.avvistBelop) } - } private fun getSatsBeløp(oppdrag: OppdragTilAvstemming): Long = - oppdrag.utbetalingsoppdrag.utbetalingsperiode.map { it.sats }.reduce(BigDecimal::add).toLong() + oppdrag.utbetalingsoppdrag.utbetalingsperiode + .map { it.sats } + .reduce(BigDecimal::add) + .toLong() - private fun getFortegn(satsbeløp: Long): Fortegn { - return if (satsbeløp >= 0) Fortegn.T else Fortegn.F - } + private fun getFortegn(satsbeløp: Long): Fortegn = if (satsbeløp >= 0) Fortegn.T else Fortegn.F private fun formaterTilPeriodedataFormat(stringTimestamp: String): String = - LocalDateTime.parse(stringTimestamp, tidspunktFormatter) + LocalDateTime + .parse(stringTimestamp, tidspunktFormatter) .format(DateTimeFormatter.ofPattern("yyyyMMddHH")) } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/grensesnittavstemming/JaxbGrensesnittAvstemmingsdata.kt b/src/main/kotlin/no/nav/familie/oppdrag/grensesnittavstemming/JaxbGrensesnittAvstemmingsdata.kt index c2e6b08c..fd454c19 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/grensesnittavstemming/JaxbGrensesnittAvstemmingsdata.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/grensesnittavstemming/JaxbGrensesnittAvstemmingsdata.kt @@ -11,9 +11,11 @@ object JaxbGrensesnittAvstemmingsdata { fun tilXml(avstemmingsmelding: Avstemmingsdata): String { val stringWriter = StringWriter() - jaxbContext.createMarshaller().apply { - setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true) - }.marshal(ObjectFactory().createAvstemmingsdata(avstemmingsmelding), stringWriter) + jaxbContext + .createMarshaller() + .apply { + setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true) + }.marshal(ObjectFactory().createAvstemmingsdata(avstemmingsmelding), stringWriter) return stringWriter.toString() } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/KvitteringConstants.kt b/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/KvitteringConstants.kt index 2cb5a214..662c7245 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/KvitteringConstants.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/KvitteringConstants.kt @@ -3,7 +3,9 @@ package no.nav.familie.oppdrag.iverksetting import no.trygdeetaten.skjema.oppdrag.Oppdrag import java.lang.IllegalArgumentException -enum class Status(val kode: String) { +enum class Status( + val kode: String, +) { OK("00"), AKSEPTERT_MEN_NOE_ER_FEIL("04"), AVVIST_FUNKSJONELLE_FEIL("08"), diff --git a/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMapper.kt b/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMapper.kt index 3a0a728c..64debe45 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMapper.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMapper.kt @@ -103,9 +103,8 @@ class OppdragMapper { } } - fun tilOppdrag(oppdrag110: Oppdrag110): Oppdrag { - return objectFactory.createOppdrag().apply { + fun tilOppdrag(oppdrag110: Oppdrag110): Oppdrag = + objectFactory.createOppdrag().apply { this.oppdrag110 = oppdrag110 } - } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMottaker.kt b/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMottaker.kt index c483bf6c..9048f21a 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMottaker.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMottaker.kt @@ -51,7 +51,8 @@ class OppdragMottaker( log.debug("Henter oppdrag $oppdragId fra databasen") val førsteOppdragUtenKvittering = - oppdragLagerRepository.hentKvitteringsinformasjon(oppdragId) + oppdragLagerRepository + .hentKvitteringsinformasjon(oppdragId) .find { oppdrag -> oppdrag.status == OppdragStatus.LAGT_PÅ_KØ } if (førsteOppdragUtenKvittering == null) { log.warn("Oppdraget tilknyttet mottatt kvittering har uventet status i databasen. Oppdraget er: $oppdragId") @@ -100,7 +101,5 @@ class OppdragMottaker( OppdragStatus.KVITTERT_OK } - fun lesKvittering(svarFraOppdrag: String): Oppdrag { - return Jaxb.tilOppdrag(svarFraOppdrag) - } + fun lesKvittering(svarFraOppdrag: String): Oppdrag = Jaxb.tilOppdrag(svarFraOppdrag) } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragSenderMQ.kt b/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragSenderMQ.kt index d96fd2d4..637a0173 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragSenderMQ.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragSenderMQ.kt @@ -22,7 +22,11 @@ class OppdragSenderMQ( throw UnsupportedOperationException("Kan ikke sende melding til oppdrag. Integrasjonen er skrudd av.") } - val oppdragId = oppdrag.oppdrag110?.oppdragsLinje150?.lastOrNull()?.henvisning + val oppdragId = + oppdrag.oppdrag110 + ?.oppdragsLinje150 + ?.lastOrNull() + ?.henvisning val oppdragXml = Jaxb.tilXml(oppdrag) LOG.info( "Sender oppdrag for fagsystem=${oppdrag.oppdrag110.kodeFagomraade} og " + diff --git a/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragSkjemaConstants.kt b/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragSkjemaConstants.kt index 48f6489d..99d0654e 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragSkjemaConstants.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragSkjemaConstants.kt @@ -23,7 +23,9 @@ class OppdragSkjemaConstants { } } -enum class EndringsKode(val kode: String) { +enum class EndringsKode( + val kode: String, +) { NY("NY"), UENDRET("UEND"), ENDRING("ENDR"), @@ -39,7 +41,9 @@ enum class EndringsKode(val kode: String) { } } -enum class UtbetalingsfrekvensKode(val kode: String) { +enum class UtbetalingsfrekvensKode( + val kode: String, +) { DAGLIG("DAG"), UKENTLIG("UKE"), MÅNEDLIG("MND"), @@ -47,7 +51,9 @@ enum class UtbetalingsfrekvensKode(val kode: String) { ENGANGSUTBETALING("ENG"), } -enum class SatsTypeKode(val kode: String) { +enum class SatsTypeKode( + val kode: String, +) { DAGLIG("DAG"), UKENTLIG("UKE"), MÅNEDLIG("MND"), @@ -68,14 +74,16 @@ enum class SatsTypeKode(val kode: String) { } } -enum class GradTypeKode(val kode: String) { +enum class GradTypeKode( + val kode: String, +) { UFØREGRAD("UFOR"), UTBETALINGSGRAD("UBGR"), UTTAKSGRAD_ALDERSPENSJON("UTAP"), UTTAKSGRAD_AFP("AFPG"), } -fun LocalDate.toXMLDate(): XMLGregorianCalendar { - return DatatypeFactory.newInstance() +fun LocalDate.toXMLDate(): XMLGregorianCalendar = + DatatypeFactory + .newInstance() .newXMLGregorianCalendar(GregorianCalendar.from(atStartOfDay(ZoneId.systemDefault()))) -} diff --git a/src/main/kotlin/no/nav/familie/oppdrag/konsistensavstemming/KonsistensavstemmingMapper.kt b/src/main/kotlin/no/nav/familie/oppdrag/konsistensavstemming/KonsistensavstemmingMapper.kt index e220caaa..3a689b11 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/konsistensavstemming/KonsistensavstemmingMapper.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/konsistensavstemming/KonsistensavstemmingMapper.kt @@ -77,8 +77,8 @@ class KonsistensavstemmingMapper( return dataListe } - private fun lagOppdragsdata(utbetalingsoppdrag: Utbetalingsoppdrag): Oppdragsdata { - return Oppdragsdata().apply { + private fun lagOppdragsdata(utbetalingsoppdrag: Utbetalingsoppdrag): Oppdragsdata = + Oppdragsdata().apply { fagomradeKode = utbetalingsoppdrag.fagSystem fagsystemId = utbetalingsoppdrag.saksnummer utbetalingsfrekvens = UtbetalingsfrekvensKode.MÅNEDLIG.kode @@ -97,7 +97,6 @@ class KonsistensavstemmingMapper( ) } } - } private fun lagOppdragsLinjeListe( utbetalingsperiode: Utbetalingsperiode, @@ -150,19 +149,17 @@ class KonsistensavstemmingMapper( return aktiv } - private fun lagAttestant(utbetalingsoppdrag: Utbetalingsoppdrag): Attestant { - return Attestant().apply { + private fun lagAttestant(utbetalingsoppdrag: Utbetalingsoppdrag): Attestant = + Attestant().apply { attestantId = utbetalingsoppdrag.saksbehandlerId } - } - private fun lagEnhet(): Enhet { - return Enhet().apply { + private fun lagEnhet(): Enhet = + Enhet().apply { enhetType = OppdragSkjemaConstants.ENHET_TYPE enhet = OppdragSkjemaConstants.ENHET enhetFom = OppdragSkjemaConstants.ENHET_DATO_FOM.format(datoFormatter) } - } private fun lagTotaldata(): Konsistensavstemmingsdata { val konsistensavstemmingsdata = lagAksjonsmelding(KonsistensavstemmingConstants.DATA) @@ -177,21 +174,20 @@ class KonsistensavstemmingMapper( return konsistensavstemmingsdata } - private fun getFortegn(satsbeløp: Long): String { - return if (BigDecimal.valueOf(satsbeløp) >= BigDecimal.ZERO) { + private fun getFortegn(satsbeløp: Long): String = + if (BigDecimal.valueOf(satsbeløp) >= BigDecimal.ZERO) { KonsistensavstemmingConstants.FORTEGN_T } else { KonsistensavstemmingConstants.FORTEGN_F } - } private fun lagAksjonsmelding(aksjontype: String): Konsistensavstemmingsdata = Konsistensavstemmingsdata().apply { aksjonsdata = opprettAksjonsdata(aksjontype) } - private fun opprettAksjonsdata(aksjonstype: String): Aksjonsdata { - return Aksjonsdata().apply { + private fun opprettAksjonsdata(aksjonstype: String): Aksjonsdata = + Aksjonsdata().apply { this.aksjonsType = aksjonstype this.kildeType = KonsistensavstemmingConstants.KILDETYPE this.avstemmingType = KonsistensavstemmingConstants.KONSISTENSAVSTEMMING @@ -202,7 +198,6 @@ class KonsistensavstemmingMapper( this.avleverendeAvstemmingId = avstemmingId this.brukerId = fagsystem } - } companion object { val LOG: Logger = LoggerFactory.getLogger(KonsistensavstemmingMapper::class.java) diff --git a/src/main/kotlin/no/nav/familie/oppdrag/repository/InsertUpdateRepositoryImpl.kt b/src/main/kotlin/no/nav/familie/oppdrag/repository/InsertUpdateRepositoryImpl.kt index 6a526c7e..a30332b2 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/repository/InsertUpdateRepositoryImpl.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/repository/InsertUpdateRepositoryImpl.kt @@ -5,22 +5,16 @@ import org.springframework.stereotype.Component import org.springframework.transaction.annotation.Transactional @Component -class InsertUpdateRepositoryImpl(val entityOperations: JdbcAggregateOperations) : InsertUpdateRepository { - override fun insert(t: T): T { - return entityOperations.insert(t) - } +class InsertUpdateRepositoryImpl( + val entityOperations: JdbcAggregateOperations, +) : InsertUpdateRepository { + override fun insert(t: T): T = entityOperations.insert(t) @Transactional - override fun insertAll(list: List): List { - return list.map(this::insert) - } + override fun insertAll(list: List): List = list.map(this::insert) - override fun update(t: T): T { - return entityOperations.update(t) - } + override fun update(t: T): T = entityOperations.update(t) @Transactional - override fun updateAll(list: List): List { - return list.map(this::update) - } + override fun updateAll(list: List): List = list.map(this::update) } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/repository/Kvitteringsinformasjon.kt b/src/main/kotlin/no/nav/familie/oppdrag/repository/Kvitteringsinformasjon.kt index 193348d2..1d2d3e91 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/repository/Kvitteringsinformasjon.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/repository/Kvitteringsinformasjon.kt @@ -30,8 +30,8 @@ object KvitteringsinformasjonRowMapper : RowMapper { override fun mapRow( resultSet: ResultSet, rowNumbers: Int, - ): Kvitteringsinformasjon { - return Kvitteringsinformasjon( + ): Kvitteringsinformasjon = + Kvitteringsinformasjon( fagsystem = resultSet.getString("fagsystem"), personIdent = resultSet.getString("person_ident"), fagsakId = resultSet.getString("fagsak_id"), @@ -42,5 +42,4 @@ object KvitteringsinformasjonRowMapper : RowMapper { kvitteringsmelding = resultSet.getString("kvitteringsmelding")?.let { objectMapper.readValue(it) }, versjon = resultSet.getInt("versjon"), ) - } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragLager.kt b/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragLager.kt index 6282d5e8..3a257388 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragLager.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragLager.kt @@ -33,8 +33,8 @@ data class OppdragLager( utbetalingsoppdrag: Utbetalingsoppdrag, oppdrag: Oppdrag, versjon: Int = 0, - ): OppdragLager { - return OppdragLager( + ): OppdragLager = + OppdragLager( personIdent = utbetalingsoppdrag.aktoer, fagsystem = utbetalingsoppdrag.fagSystem, fagsakId = utbetalingsoppdrag.saksnummer, @@ -45,7 +45,6 @@ data class OppdragLager( kvitteringsmelding = null, versjon = versjon, ) - } } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragLagerRepositoryJdbc.kt b/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragLagerRepositoryJdbc.kt index 70cdf3f4..a1673ff9 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragLagerRepositoryJdbc.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragLagerRepositoryJdbc.kt @@ -16,7 +16,9 @@ import java.time.LocalDateTime import java.util.UUID @Repository -class OppdragLagerRepositoryJdbc(val jdbcTemplate: NamedParameterJdbcTemplate) : OppdragLagerRepository { +class OppdragLagerRepositoryJdbc( + val jdbcTemplate: NamedParameterJdbcTemplate, +) : OppdragLagerRepository { internal val log = LoggerFactory.getLogger(OppdragLagerRepositoryJdbc::class.java) override fun hentOppdrag( @@ -202,21 +204,23 @@ class OppdragLagerRepositoryJdbc(val jdbcTemplate: NamedParameterJdbcTemplate) : val status = setOf(OppdragStatus.KVITTERT_OK, OppdragStatus.KVITTERT_MED_MANGLER).map { it.name } - return behandlingIder.chunked(3000).map { behandlingIderChunked -> - val values = - MapSqlParameterSource() - .addValue("fagsystem", fagsystem) - .addValue("behandlingIder", behandlingIderChunked) - .addValue("status", status) - - jdbcTemplate.query(query, values) { resultSet, _ -> - UtbetalingsoppdragForKonsistensavstemming( - resultSet.getString("fagsak_id"), - resultSet.getString("behandling_id"), - objectMapper.readValue(resultSet.getString("utbetalingsoppdrag")), - ) - } - }.flatten() + return behandlingIder + .chunked(3000) + .map { behandlingIderChunked -> + val values = + MapSqlParameterSource() + .addValue("fagsystem", fagsystem) + .addValue("behandlingIder", behandlingIderChunked) + .addValue("status", status) + + jdbcTemplate.query(query, values) { resultSet, _ -> + UtbetalingsoppdragForKonsistensavstemming( + resultSet.getString("fagsak_id"), + resultSet.getString("behandling_id"), + objectMapper.readValue(resultSet.getString("utbetalingsoppdrag")), + ) + } + }.flatten() } override fun hentSisteUtbetalingsoppdragForFagsaker( @@ -256,8 +260,8 @@ class OppdragLagerRowMapper : RowMapper { override fun mapRow( resultSet: ResultSet, rowNumbers: Int, - ): OppdragLager { - return OppdragLager( + ): OppdragLager = + OppdragLager( uuid = UUID.fromString(resultSet.getString("id") ?: UUID.randomUUID().toString()), fagsystem = resultSet.getString("fagsystem"), personIdent = resultSet.getString("person_ident"), @@ -271,5 +275,4 @@ class OppdragLagerRowMapper : RowMapper { kvitteringsmelding = resultSet.getString("kvitteringsmelding")?.let { objectMapper.readValue(it) }, versjon = resultSet.getInt("versjon"), ) - } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragTilAvstemming.kt b/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragTilAvstemming.kt index 5098b924..86cbcb5c 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragTilAvstemming.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/repository/OppdragTilAvstemming.kt @@ -25,8 +25,8 @@ object OppdragTilAvstemmingRowMapper : RowMapper { override fun mapRow( resultSet: ResultSet, rowNumbers: Int, - ): OppdragTilAvstemming { - return OppdragTilAvstemming( + ): OppdragTilAvstemming = + OppdragTilAvstemming( fagsystem = resultSet.getString("fagsystem"), personIdent = resultSet.getString("person_ident"), fagsakId = resultSet.getString("fagsak_id"), @@ -37,5 +37,4 @@ object OppdragTilAvstemmingRowMapper : RowMapper { opprettetTidspunkt = resultSet.getTimestamp("opprettet_tidspunkt").toLocalDateTime(), kvitteringsmelding = resultSet.getString("kvitteringsmelding")?.let { objectMapper.readValue(it) }, ) - } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLager.kt b/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLager.kt index 16ce86e4..65c99a03 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLager.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLager.kt @@ -26,14 +26,13 @@ data class SimuleringLager( fun lagFraOppdrag( utbetalingsoppdrag: Utbetalingsoppdrag, request: SimulerBeregningRequest, - ): SimuleringLager { - return SimuleringLager( + ): SimuleringLager = + SimuleringLager( fagsystem = utbetalingsoppdrag.fagSystem, fagsakId = utbetalingsoppdrag.saksnummer, behandlingId = utbetalingsoppdrag.behandlingsIdForFørsteUtbetalingsperiode(), utbetalingsoppdrag = objectMapper.writeValueAsString(utbetalingsoppdrag), requestXml = Jaxb.tilXml(request = request), ) - } } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLagerRepository.kt b/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLagerRepository.kt index c991026e..b0d39594 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLagerRepository.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLagerRepository.kt @@ -5,7 +5,9 @@ import org.springframework.stereotype.Repository import java.util.UUID @Repository -interface SimuleringLagerRepository : RepositoryInterface, InsertUpdateRepository { +interface SimuleringLagerRepository : + RepositoryInterface, + InsertUpdateRepository { // language=PostgreSQL @Query( """ diff --git a/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLagerTjenesteImpl.kt b/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLagerTjenesteImpl.kt index bf1cc918..ac84a6ee 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLagerTjenesteImpl.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/repository/SimuleringLagerTjenesteImpl.kt @@ -18,15 +18,11 @@ class SimuleringLagerTjenesteImpl : SimuleringLagerTjeneste { simuleringLagerRepository.update(simuleringLager) } - override fun finnAlleSimuleringsLager(): List { - return simuleringLagerRepository.findAll().toList() - } + override fun finnAlleSimuleringsLager(): List = simuleringLagerRepository.findAll().toList() override fun hentSisteSimuleringsresultat( fagsystem: String, fagsakId: String, behandlingId: String, - ): SimuleringLager { - return simuleringLagerRepository.finnSisteSimuleringsresultat(fagsystem, fagsakId, behandlingId) - } + ): SimuleringLager = simuleringLagerRepository.finnSisteSimuleringsresultat(fagsystem, fagsakId, behandlingId) } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/rest/AvstemmingController.kt b/src/main/kotlin/no/nav/familie/oppdrag/rest/AvstemmingController.kt index 57babc98..eba53110 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/rest/AvstemmingController.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/rest/AvstemmingController.kt @@ -39,7 +39,8 @@ class AvstemmingController( ): ResponseEntity> { LOG.info("Grensesnittavstemming: Kjører for ${request.fagsystem}-oppdrag fra ${request.fra} til ${request.til}") - return Result.runCatching { grensesnittavstemmingService.utførGrensesnittavstemming(request) } + return Result + .runCatching { grensesnittavstemmingService.utførGrensesnittavstemming(request) } .fold( onFailure = { illegalState("Grensesnittavstemming feilet", it) }, onSuccess = { ok("Grensesnittavstemming sendt ok") }, @@ -68,12 +69,13 @@ class AvstemmingController( "med ${request.perioderForBehandlinger.sumOf { it.perioder.size }} antall periodeIder", ) - return Result.runCatching { - konsistensavstemmingService.utførKonsistensavstemming(request, sendStartmelding, sendAvsluttmelding, transaksjonsId) - }.fold( - onFailure = { illegalState("Konsistensavstemming feilet", it) }, - onSuccess = { ok("Konsistensavstemming sendt ok") }, - ) + return Result + .runCatching { + konsistensavstemmingService.utførKonsistensavstemming(request, sendStartmelding, sendAvsluttmelding, transaksjonsId) + }.fold( + onFailure = { illegalState("Konsistensavstemming feilet", it) }, + onSuccess = { ok("Konsistensavstemming sendt ok") }, + ) } @PostMapping(path = ["/konsistensavstemming"], consumes = [MediaType.APPLICATION_JSON_VALUE]) @@ -88,17 +90,18 @@ class AvstemmingController( "med ${request.utbetalingsoppdrag.size} antall oppdrag", ) - return Result.runCatching { - konsistensavstemmingService.utførKonsistensavstemming( - request, - sendStartmelding = sendStartmelding, - sendAvsluttmelding = sendAvsluttmelding, - transaksjonsId = transaksjonId, + return Result + .runCatching { + konsistensavstemmingService.utførKonsistensavstemming( + request, + sendStartmelding = sendStartmelding, + sendAvsluttmelding = sendAvsluttmelding, + transaksjonsId = transaksjonId, + ) + }.fold( + onFailure = { illegalState("Konsistensavstemming feilet", it) }, + onSuccess = { ok("Konsistensavstemming sendt ok") }, ) - }.fold( - onFailure = { illegalState("Konsistensavstemming feilet", it) }, - onSuccess = { ok("Konsistensavstemming sendt ok") }, - ) } @PostMapping("/{fagsystem}/fagsaker/siste-utbetalingsoppdrag") diff --git a/src/main/kotlin/no/nav/familie/oppdrag/rest/OppdragController.kt b/src/main/kotlin/no/nav/familie/oppdrag/rest/OppdragController.kt index 36cc575b..a10c3dc6 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/rest/OppdragController.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/rest/OppdragController.kt @@ -34,46 +34,46 @@ class OppdragController( fun sendOppdrag( @Valid @RequestBody utbetalingsoppdrag: Utbetalingsoppdrag, - ): ResponseEntity> { - return Result.runCatching { - val oppdrag110 = oppdragMapper.tilOppdrag110(utbetalingsoppdrag) - val oppdrag = oppdragMapper.tilOppdrag(oppdrag110) + ): ResponseEntity> = + Result + .runCatching { + val oppdrag110 = oppdragMapper.tilOppdrag110(utbetalingsoppdrag) + val oppdrag = oppdragMapper.tilOppdrag(oppdrag110) - oppdragService.opprettOppdrag(utbetalingsoppdrag, oppdrag, 0) - }.fold( - onFailure = { - if (it is OppdragAlleredeSendtException) { - conflict("Oppdrag er allerede sendt for saksnr ${utbetalingsoppdrag.saksnummer}.") - } else { - illegalState("Klarte ikke sende oppdrag for saksnr ${utbetalingsoppdrag.saksnummer}", it) - } - }, - onSuccess = { - ok("Oppdrag sendt OK") - }, - ) - } + oppdragService.opprettOppdrag(utbetalingsoppdrag, oppdrag, 0) + }.fold( + onFailure = { + if (it is OppdragAlleredeSendtException) { + conflict("Oppdrag er allerede sendt for saksnr ${utbetalingsoppdrag.saksnummer}.") + } else { + illegalState("Klarte ikke sende oppdrag for saksnr ${utbetalingsoppdrag.saksnummer}", it) + } + }, + onSuccess = { + ok("Oppdrag sendt OK") + }, + ) @PostMapping(consumes = [MediaType.APPLICATION_JSON_VALUE], path = ["/oppdragPaaNytt/{versjon}"]) fun sendOppdragPåNytt( @Valid @RequestBody utbetalingsoppdrag: Utbetalingsoppdrag, @PathVariable versjon: Int, - ): ResponseEntity> { - return Result.runCatching { - val oppdrag110 = oppdragMapper.tilOppdrag110(utbetalingsoppdrag) - val oppdrag = oppdragMapper.tilOppdrag(oppdrag110) + ): ResponseEntity> = + Result + .runCatching { + val oppdrag110 = oppdragMapper.tilOppdrag110(utbetalingsoppdrag) + val oppdrag = oppdragMapper.tilOppdrag(oppdrag110) - oppdragService.opprettOppdrag(utbetalingsoppdrag, oppdrag, versjon) - }.fold( - onFailure = { - illegalState("Klarte ikke sende oppdrag for saksnr ${utbetalingsoppdrag.saksnummer}", it) - }, - onSuccess = { - ok("Oppdrag sendt OK") - }, - ) - } + oppdragService.opprettOppdrag(utbetalingsoppdrag, oppdrag, versjon) + }.fold( + onFailure = { + illegalState("Klarte ikke sende oppdrag for saksnr ${utbetalingsoppdrag.saksnummer}", it) + }, + onSuccess = { + ok("Oppdrag sendt OK") + }, + ) @PostMapping("resend") fun resendOppdrag( @@ -87,8 +87,9 @@ class OppdragController( fun hentStatus( @Valid @RequestBody oppdragId: OppdragId, - ): ResponseEntity> { - return Result.runCatching { oppdragService.hentStatusForOppdrag(oppdragId) } + ): ResponseEntity> = + Result + .runCatching { oppdragService.hentStatusForOppdrag(oppdragId) } .fold( onFailure = { notFound("Fant ikke oppdrag med id $oppdragId") @@ -97,14 +98,14 @@ class OppdragController( ok(it.status, it.kvitteringsmelding?.beskrMelding ?: "") }, ) - } @PostMapping(consumes = [MediaType.APPLICATION_JSON_VALUE], path = ["/oppdrag/manuell-kvittering"]) fun opprettManuellKvitteringPåOppdrag( @Valid @RequestBody oppdragId: OppdragId, - ): ResponseEntity> { - return Result.runCatching { oppdragService.opprettManuellKvitteringPåOppdrag(oppdragId) } + ): ResponseEntity> = + Result + .runCatching { oppdragService.opprettManuellKvitteringPåOppdrag(oppdragId) } .fold( onFailure = { if (it is OppdragHarAlleredeKvitteringException) { @@ -117,5 +118,4 @@ class OppdragController( ok(it.status, it.kvitteringsmelding?.beskrMelding ?: "") }, ) - } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/rest/SimuleringController.kt b/src/main/kotlin/no/nav/familie/oppdrag/rest/SimuleringController.kt index 89f185a2..41ce1f8a 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/rest/SimuleringController.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/rest/SimuleringController.kt @@ -35,9 +35,8 @@ class SimuleringController( fun utførSimuleringOgHentResultat( @Valid @RequestBody utbetalingsoppdrag: Utbetalingsoppdrag, - ): ResponseEntity> { - return ok(simuleringTjeneste.utførSimuleringOghentDetaljertSimuleringResultat(utbetalingsoppdrag)) - } + ): ResponseEntity> = + ok(simuleringTjeneste.utførSimuleringOghentDetaljertSimuleringResultat(utbetalingsoppdrag)) @PostMapping(path = ["/feilutbetalinger"]) fun hentFeilutbetalinger( diff --git a/src/main/kotlin/no/nav/familie/oppdrag/rest/TilbakekrevingController.kt b/src/main/kotlin/no/nav/familie/oppdrag/rest/TilbakekrevingController.kt index fb38a770..80e0337a 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/rest/TilbakekrevingController.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/rest/TilbakekrevingController.kt @@ -22,31 +22,27 @@ import java.util.UUID @RestController @RequestMapping("/api/tilbakekreving") @ProtectedWithClaims(issuer = "azuread") -class TilbakekrevingController(private val økonomiClient: ØkonomiClient) { +class TilbakekrevingController( + private val økonomiClient: ØkonomiClient, +) { @PostMapping(consumes = [MediaType.APPLICATION_JSON_VALUE], path = ["/iverksett/{behandlingId}"]) fun iverksettVedtak( @PathVariable("behandlingId") behandlingId: UUID, @Valid @RequestBody tilbakekrevingsvedtakRequest: TilbakekrevingsvedtakRequest, - ): Ressurs { - return Ressurs.success(økonomiClient.iverksettVedtak(behandlingId, tilbakekrevingsvedtakRequest)) - } + ): Ressurs = Ressurs.success(økonomiClient.iverksettVedtak(behandlingId, tilbakekrevingsvedtakRequest)) @PostMapping(consumes = [MediaType.APPLICATION_JSON_VALUE], path = ["/kravgrunnlag/{kravgrunnlagId}"]) fun hentKravgrunnlag( @PathVariable("kravgrunnlagId") kravgrunnlagId: BigInteger, @Valid @RequestBody hentKravgrunnlagRequest: KravgrunnlagHentDetaljRequest, - ): Ressurs { - return Ressurs.success(økonomiClient.hentKravgrunnlag(kravgrunnlagId, hentKravgrunnlagRequest)) - } + ): Ressurs = Ressurs.success(økonomiClient.hentKravgrunnlag(kravgrunnlagId, hentKravgrunnlagRequest)) @PostMapping(consumes = [MediaType.APPLICATION_JSON_VALUE], path = ["/annuler/kravgrunnlag/{kravgrunnlagId}"]) fun annulerKravgrunnlag( @PathVariable("kravgrunnlagId") kravgrunnlagId: BigInteger, @Valid @RequestBody kravgrunnlagAnnulerRequest: KravgrunnlagAnnulerRequest, - ): Ressurs { - return Ressurs.success(økonomiClient.annulerKravgrunnlag(kravgrunnlagId, kravgrunnlagAnnulerRequest)) - } + ): Ressurs = Ressurs.success(økonomiClient.annulerKravgrunnlag(kravgrunnlagId, kravgrunnlagAnnulerRequest)) } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/service/GrensesnittavstemmingService.kt b/src/main/kotlin/no/nav/familie/oppdrag/service/GrensesnittavstemmingService.kt index ac7a3cd3..28bfde15 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/service/GrensesnittavstemmingService.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/service/GrensesnittavstemmingService.kt @@ -151,7 +151,10 @@ class GrensesnittavstemmingService( } } -enum class Status(val status: String, val beskrivelse: String) { +enum class Status( + val status: String, + val beskrivelse: String, +) { GODKJENT("godkjent", "Antall oppdrag som har fått OK kvittering (alvorlighetsgrad 00)."), AVVIST( "avvist", diff --git a/src/main/kotlin/no/nav/familie/oppdrag/service/KonsistensavstemmingService.kt b/src/main/kotlin/no/nav/familie/oppdrag/service/KonsistensavstemmingService.kt index 13f75d77..ec8e51fe 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/service/KonsistensavstemmingService.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/service/KonsistensavstemmingService.kt @@ -74,9 +74,8 @@ class KonsistensavstemmingService( fun hentSisteUtbetalingsoppdragForFagsaker( fagsystem: String, fagsakIder: Set, - ): List { - return oppdragLagerRepository.hentSisteUtbetalingsoppdragForFagsaker(fagsystem, fagsakIder) - } + ): List = + oppdragLagerRepository.hentSisteUtbetalingsoppdragForFagsaker(fagsystem, fagsakIder) @Transactional fun utførKonsistensavstemming( @@ -158,14 +157,19 @@ class KonsistensavstemmingService( return utbetalingsoppdragPåFagsak.map { (saksnummer, utbetalingsoppdragListe) -> val senesteUtbetalingsoppdrag = - utbetalingsoppdragListe.maxByOrNull { oppdrag -> - oppdrag.utbetalingsoppdrag.utbetalingsperiode.maxOf { it.periodeId } - }?.utbetalingsoppdrag ?: error("Finner ikke seneste behandling for fagsak=$saksnummer") + utbetalingsoppdragListe + .maxByOrNull { oppdrag -> + oppdrag.utbetalingsoppdrag.utbetalingsperiode.maxOf { it.periodeId } + }?.utbetalingsoppdrag ?: error("Finner ikke seneste behandling for fagsak=$saksnummer") val behandlingsIderForFagsak = utbetalingsoppdragListe.map { it.behandlingId }.toSet() val aktuellePeriodeIderForFagsak = - perioderPåBehandling.filter { behandlingsIderForFagsak.contains(it.key) }.values.flatten().toSet() + perioderPåBehandling + .filter { behandlingsIderForFagsak.contains(it.key) } + .values + .flatten() + .toSet() var aktivtFødselsnummer: String? = null val perioderTilKonsistensavstemming = @@ -197,7 +201,11 @@ class KonsistensavstemmingService( ) { if (periodeIderPåBehandling.size != request.perioderForBehandlinger.size) { val duplikateBehandlinger = - request.perioderForBehandlinger.map { it.behandlingId }.groupingBy { it }.eachCount().filter { it.value > 1 } + request.perioderForBehandlinger + .map { it.behandlingId } + .groupingBy { it } + .eachCount() + .filter { it.value > 1 } error("Behandling finnes flere ganger i requesten: ${duplikateBehandlinger.keys}") } } @@ -205,10 +213,9 @@ class KonsistensavstemmingService( private fun hentFødselsnummerForBehandling( fødselsnummerPåBehandling: Map, behandlingId: String, - ): String { - return fødselsnummerPåBehandling[behandlingId] + ): String = + fødselsnummerPåBehandling[behandlingId] ?: error("Finnes ikke et aktivt fødselsnummer for behandlingId $behandlingId") - } companion object { val LOG: Logger = LoggerFactory.getLogger(KonsistensavstemmingService::class.java) diff --git a/src/main/kotlin/no/nav/familie/oppdrag/service/MellomlagringKonsistensavstemmingService.kt b/src/main/kotlin/no/nav/familie/oppdrag/service/MellomlagringKonsistensavstemmingService.kt index 3f82ff5e..c25a9bed 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/service/MellomlagringKonsistensavstemmingService.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/service/MellomlagringKonsistensavstemmingService.kt @@ -20,13 +20,12 @@ class MellomlagringKonsistensavstemmingService( 0L } - fun hentAggregertAntallOppdrag(metaInfo: KonsistensavstemmingMetaInfo): Int { - return if (metaInfo.erSisteBatchIEnSplittetBatch()) { + fun hentAggregertAntallOppdrag(metaInfo: KonsistensavstemmingMetaInfo): Int = + if (metaInfo.erSisteBatchIEnSplittetBatch()) { mellomlagringKonsistensavstemmingRepository.hentAggregertAntallOppdrag(metaInfo.transaksjonsId!!) } else { 0 } - } fun opprettInnslagIMellomlagring( metaInfo: KonsistensavstemmingMetaInfo, diff --git a/src/main/kotlin/no/nav/familie/oppdrag/service/OppdragServiceE2E.kt b/src/main/kotlin/no/nav/familie/oppdrag/service/OppdragServiceE2E.kt index 557d2c0d..aeb08f9b 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/service/OppdragServiceE2E.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/service/OppdragServiceE2E.kt @@ -31,17 +31,11 @@ class OppdragServiceE2E( oppdragLagerRepository.oppdaterStatus(oppdrag.id, OppdragStatus.KVITTERT_OK) } - override fun hentStatusForOppdrag(oppdragId: OppdragId): OppdragLager { - return oppdragLagerRepository.hentOppdrag(oppdragId) - } + override fun hentStatusForOppdrag(oppdragId: OppdragId): OppdragLager = oppdragLagerRepository.hentOppdrag(oppdragId) - override fun resendOppdrag(oppdragId: OppdragId) { - throw NotImplementedError("Ikke implementert") - } + override fun resendOppdrag(oppdragId: OppdragId): Unit = throw NotImplementedError("Ikke implementert") - override fun opprettManuellKvitteringPåOppdrag(oppdragId: OppdragId): OppdragLager { - throw NotImplementedError("Ikke implementert") - } + override fun opprettManuellKvitteringPåOppdrag(oppdragId: OppdragId): OppdragLager = throw NotImplementedError("Ikke implementert") companion object { val LOG = LoggerFactory.getLogger(OppdragServiceE2E::class.java) diff --git a/src/main/kotlin/no/nav/familie/oppdrag/service/OppdragServiceImpl.kt b/src/main/kotlin/no/nav/familie/oppdrag/service/OppdragServiceImpl.kt index 983a980a..cfb50bf9 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/service/OppdragServiceImpl.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/service/OppdragServiceImpl.kt @@ -40,9 +40,7 @@ class OppdragServiceImpl( oppdragSender.sendOppdrag(oppdrag) } - override fun hentStatusForOppdrag(oppdragId: OppdragId): OppdragLager { - return oppdragLagerRepository.hentOppdrag(oppdragId) - } + override fun hentStatusForOppdrag(oppdragId: OppdragId): OppdragLager = oppdragLagerRepository.hentOppdrag(oppdragId) @Transactional(rollbackFor = [Throwable::class]) override fun resendOppdrag(oppdragId: OppdragId) { @@ -81,6 +79,8 @@ class OppdragServiceImpl( } } -class OppdragAlleredeSendtException() : RuntimeException() +class OppdragAlleredeSendtException : RuntimeException() -class OppdragHarAlleredeKvitteringException(melding: String) : RuntimeException(melding) +class OppdragHarAlleredeKvitteringException( + melding: String, +) : RuntimeException(melding) diff --git a/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimulerBeregningRequestMapper.kt b/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimulerBeregningRequestMapper.kt index e85af37b..d2812e17 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimulerBeregningRequestMapper.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimulerBeregningRequestMapper.kt @@ -18,14 +18,20 @@ import java.time.format.DateTimeFormatter @Component class SimulerBeregningRequestMapper { private val fpServiceGrensesnittFactory = - no.nav.system.os.tjenester.simulerfpservice.simulerfpservicegrensesnitt.ObjectFactory() - private val fpServiceTypesFactory = no.nav.system.os.tjenester.simulerfpservice.simulerfpserviceservicetypes.ObjectFactory() - private val oppdragSkjemaFactory = no.nav.system.os.entiteter.oppdragskjema.ObjectFactory() + no.nav.system.os.tjenester.simulerfpservice.simulerfpservicegrensesnitt + .ObjectFactory() + private val fpServiceTypesFactory = + no.nav.system.os.tjenester.simulerfpservice.simulerfpserviceservicetypes + .ObjectFactory() + private val oppdragSkjemaFactory = + no.nav.system.os.entiteter.oppdragskjema + .ObjectFactory() private val tidspunktFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd-HH.mm.ss.SSSSSS") fun tilSimulerBeregningRequest(utbetalingsoppdrag: Utbetalingsoppdrag): SimulerBeregningRequest = - fpServiceGrensesnittFactory.createSimulerBeregningRequest() + fpServiceGrensesnittFactory + .createSimulerBeregningRequest() .apply { request = tilSimulerBeregningTypesRequest(utbetalingsoppdrag) } private fun tilSimulerBeregningTypesRequest(utbetalingsoppdrag: Utbetalingsoppdrag) = diff --git a/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringResultatTransformer.kt b/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringResultatTransformer.kt index 6a338fb7..c0119d95 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringResultatTransformer.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringResultatTransformer.kt @@ -50,8 +50,8 @@ class SimuleringResultatTransformer { utenInntrekk: Boolean, stoppnivaa: BeregningStoppnivaa, detaljer: BeregningStoppnivaaDetaljer, - ): SimulertPostering { - return SimulertPostering( + ): SimulertPostering = + SimulertPostering( betalingType = utledBetalingType(detaljer.belop), erFeilkonto = stoppnivaa.isFeilkonto, beløp = detaljer.belop, @@ -66,15 +66,13 @@ class SimuleringResultatTransformer { posteringType = PosteringType.fraKode(detaljer.typeKlasse), utenInntrekk = utenInntrekk, ) - } - private fun hentOrgNrEllerFnr(orgNrEllerFnr: String): String { - return if (erOrgNr(orgNrEllerFnr)) { + private fun hentOrgNrEllerFnr(orgNrEllerFnr: String): String = + if (erOrgNr(orgNrEllerFnr)) { orgNrEllerFnr.substring(2) } else { orgNrEllerFnr } - } private fun utledMottakerType( utbetalesTilId: String, @@ -98,13 +96,12 @@ class SimuleringResultatTransformer { return "00" == verdi.substring(0, 2) } - private fun utledBetalingType(belop: BigDecimal): BetalingType { - return if (belop > BigDecimal.ZERO) { + private fun utledBetalingType(belop: BigDecimal): BetalingType = + if (belop > BigDecimal.ZERO) { BetalingType.DEBIT } else { BetalingType.KREDIT } - } private fun parseDato(dato: String): LocalDate { val dtf = DateTimeFormatter.ofPattern(DATO_PATTERN) diff --git a/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringSenderImpl.kt b/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringSenderImpl.kt index 6db20dff..1ee2fc53 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringSenderImpl.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringSenderImpl.kt @@ -11,10 +11,11 @@ import org.springframework.stereotype.Service @Profile("!dev & !dev_psql_mq") @Service -class SimuleringSenderImpl(private val port: SimulerFpService) : SimuleringSender { +class SimuleringSenderImpl( + private val port: SimulerFpService, +) : SimuleringSender { @Override @Retryable(value = [SimulerBeregningFeilUnderBehandling::class], maxAttempts = 3, backoff = Backoff(delay = 4000)) - override fun hentSimulerBeregningResponse(simulerBeregningRequest: SimulerBeregningRequest?): SimulerBeregningResponse { - return port.simulerBeregning(simulerBeregningRequest) - } + override fun hentSimulerBeregningResponse(simulerBeregningRequest: SimulerBeregningRequest?): SimulerBeregningResponse = + port.simulerBeregning(simulerBeregningRequest) } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringTjenesteImpl.kt b/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringTjenesteImpl.kt index e62de6b7..ae7fc064 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringTjenesteImpl.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/simulering/SimuleringTjenesteImpl.kt @@ -123,43 +123,46 @@ class SimuleringTjenesteImpl( return FeilutbetalingerFraSimulering(feilutbetaltePerioder = feilutbetaltPerioder) } - private fun finnFeilPosteringer(simulering: Beregning): Map> { - return simulering.beregningsPeriode.map { beregningsperiode -> - beregningsperiode to - beregningsperiode.beregningStoppnivaa.map { stoppNivå -> + private fun finnFeilPosteringer(simulering: Beregning): Map> = + simulering.beregningsPeriode + .map { beregningsperiode -> + beregningsperiode to + beregningsperiode.beregningStoppnivaa + .map { stoppNivå -> + stoppNivå.beregningStoppnivaaDetaljer.filter { detalj -> + detalj.typeKlasse == PosteringType.FEILUTBETALING.kode && + detalj.belop > BigDecimal.ZERO + } + }.flatten() + }.filter { it.second.isNotEmpty() } + .toMap() + + private fun finnYtelPosteringer(simulering: Beregning): Map> = + simulering.beregningsPeriode.associateWith { beregningsperiode -> + beregningsperiode.beregningStoppnivaa + .map { stoppNivå -> stoppNivå.beregningStoppnivaaDetaljer.filter { detalj -> - detalj.typeKlasse == PosteringType.FEILUTBETALING.kode && - detalj.belop > BigDecimal.ZERO + detalj.typeKlasse == PosteringType.YTELSE.kode } }.flatten() - }.filter { it.second.isNotEmpty() }.toMap() - } - - private fun finnYtelPosteringer(simulering: Beregning): Map> { - return simulering.beregningsPeriode.associateWith { beregningsperiode -> - beregningsperiode.beregningStoppnivaa.map { stoppNivå -> - stoppNivå.beregningStoppnivaaDetaljer.filter { detalj -> - detalj.typeKlasse == PosteringType.YTELSE.kode - } - }.flatten() } - } private fun hentYtelPerioder( feilutbetaltePeriode: BeregningsPeriode, ytelPerioder: Map>, - ): List { - return ytelPerioder.keys.filter { ytelPeriode -> + ): List = + ytelPerioder.keys.filter { ytelPeriode -> ytelPeriode.periodeFom == feilutbetaltePeriode.periodeFom && ytelPeriode.periodeTom == feilutbetaltePeriode.periodeTom } - } private fun summerNegativeYtelPosteringer( perioder: List, ytelPerioder: Map>, ) = perioder.sumOf { beregningsperiode -> - ytelPerioder.getValue(beregningsperiode).filter { it.belop < BigDecimal.ZERO } + ytelPerioder + .getValue(beregningsperiode) + .filter { it.belop < BigDecimal.ZERO } .sumOf { detalj -> detalj.belop } } @@ -167,7 +170,9 @@ class SimuleringTjenesteImpl( perioder: List, ytelPerioder: Map>, ) = perioder.sumOf { beregningsperiode -> - ytelPerioder.getValue(beregningsperiode).filter { it.belop > BigDecimal.ZERO } + ytelPerioder + .getValue(beregningsperiode) + .filter { it.belop > BigDecimal.ZERO } .sumOf { detalj -> detalj.belop } } diff --git "a/src/main/kotlin/no/nav/familie/oppdrag/tilbakekreving/\303\230konomiClient.kt" "b/src/main/kotlin/no/nav/familie/oppdrag/tilbakekreving/\303\230konomiClient.kt" index e4fb8819..0cb8fd8b 100644 --- "a/src/main/kotlin/no/nav/familie/oppdrag/tilbakekreving/\303\230konomiClient.kt" +++ "b/src/main/kotlin/no/nav/familie/oppdrag/tilbakekreving/\303\230konomiClient.kt" @@ -17,7 +17,9 @@ import java.math.BigInteger import java.util.UUID @Service -class ØkonomiClient(private val økonomiService: TilbakekrevingPortType) { +class ØkonomiClient( + private val økonomiService: TilbakekrevingPortType, +) { private val logger: Logger = LoggerFactory.getLogger(this::class.java) fun iverksettVedtak( diff --git a/src/main/kotlin/no/nav/familie/oppdrag/tss/TssController.kt b/src/main/kotlin/no/nav/familie/oppdrag/tss/TssController.kt index 84f98024..2cbb3929 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/tss/TssController.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/tss/TssController.kt @@ -18,14 +18,14 @@ import org.springframework.web.bind.annotation.RestController @RestController @RequestMapping("/api/tss") @ProtectedWithClaims(issuer = "azuread") -class TssController(private val tssOppslagService: TssOppslagService) { +class TssController( + private val tssOppslagService: TssOppslagService, +) { @Operation(summary = "Henter informasjon om samhandler ved bruk av ORGNR og TSS-tjensten B910") @PostMapping(path = ["/proxy/b910"]) fun hentSamhandlerDataForOrganisasjonProxy( @RequestBody tssSamhandlerIdent: TssSamhandlerIdent, - ): Ressurs { - return Ressurs.success(tssOppslagService.hentSamhandlerDataForOrganisasjonB910(tssSamhandlerIdent)) - } + ): Ressurs = Ressurs.success(tssOppslagService.hentSamhandlerDataForOrganisasjonB910(tssSamhandlerIdent)) @Operation( summary = @@ -35,39 +35,35 @@ class TssController(private val tssOppslagService: TssOppslagService) { @PostMapping(path = ["/proxy/b940"]) fun søkSamhnadlerinfoFraNavnProxy( @RequestBody request: SøkSamhandlerInfoRequest, - ): Ressurs { - return Ressurs.success( + ): Ressurs = + Ressurs.success( tssOppslagService.hentInformasjonOmSamhandlerInstB940(request.navn, request.postNr, request.område, request.side).tssOutputData, ) - } @Operation(summary = "Henter informasjon om samhandler ved bruk av ORGNR og TSS-tjensten B910") @GetMapping(path = ["/orgnr/{orgnr}"]) fun hentSamhandlerDataForOrganisasjon( @PathVariable("orgnr") orgnr: String, - ): Ressurs { - return Ressurs.success( + ): Ressurs = + Ressurs.success( tssOppslagService.hentSamhandlerInformasjon(TssSamhandlerIdent(ident = orgnr, type = TssSamhandlerIdentType.ORGNR)), ) - } @Operation(summary = "Henter informasjon om samhandler ved bruk av ekstern id fra TSS og TSS-tjensten B910") @GetMapping(path = ["/tssnr/{tssnr}"]) fun hentSamhandlerDataForTssEksternId( @PathVariable("tssnr") tssnr: String, - ): Ressurs { - return Ressurs.success( + ): Ressurs = + Ressurs.success( tssOppslagService.hentSamhandlerInformasjon(TssSamhandlerIdent(ident = tssnr, type = TssSamhandlerIdentType.TSS)), ) - } @Operation(summary = "Søk samhandlere ved bruk av navn og TSS-tjensten B940. Første side er 0") @PostMapping(path = ["/navn"]) fun søkSamhnadlerinfoFraNavn( @RequestBody request: SøkSamhandlerInfoRequest, - ): Ressurs { - return Ressurs.success( + ): Ressurs = + Ressurs.success( tssOppslagService.hentInformasjonOmSamhandlerInst(request.navn, request.postNr, request.område, request.side), ) - } } diff --git a/src/main/kotlin/no/nav/familie/oppdrag/tss/TssException.kt b/src/main/kotlin/no/nav/familie/oppdrag/tss/TssException.kt index b3fe26ce..08d911c1 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/tss/TssException.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/tss/TssException.kt @@ -5,18 +5,26 @@ open class TssException( var alvorligGrad: String? = null, var kodeMelding: String? = null, throwable: Throwable? = null, -) : - RuntimeException( - listOfNotNull(feilmelding, alvorligGrad, kodeMelding).joinToString("-"), - throwable, - ) +) : RuntimeException( + listOfNotNull(feilmelding, alvorligGrad, kodeMelding).joinToString("-"), + throwable, + ) -class TssResponseException(feilmelding: String, alvorligGrad: String?, kodeMelding: String?) : TssException( - feilmelding, - alvorligGrad, - kodeMelding, -) +class TssResponseException( + feilmelding: String, + alvorligGrad: String?, + kodeMelding: String?, +) : TssException( + feilmelding, + alvorligGrad, + kodeMelding, + ) -class TssConnectionException(feilmelding: String, throwable: Throwable? = null) : TssException(feilmelding, throwable = throwable) +class TssConnectionException( + feilmelding: String, + throwable: Throwable? = null, +) : TssException(feilmelding, throwable = throwable) -class TssNoDataFoundException(feilmelding: String) : TssException(feilmelding) +class TssNoDataFoundException( + feilmelding: String, +) : TssException(feilmelding) diff --git a/src/main/kotlin/no/nav/familie/oppdrag/tss/TssOppslagService.kt b/src/main/kotlin/no/nav/familie/oppdrag/tss/TssOppslagService.kt index 17867567..719ba650 100644 --- a/src/main/kotlin/no/nav/familie/oppdrag/tss/TssOppslagService.kt +++ b/src/main/kotlin/no/nav/familie/oppdrag/tss/TssOppslagService.kt @@ -15,7 +15,9 @@ import org.slf4j.LoggerFactory import org.springframework.stereotype.Service @Service -class TssOppslagService(private val tssMQClient: TssMQClient) { +class TssOppslagService( + private val tssMQClient: TssMQClient, +) { private val logger = LoggerFactory.getLogger(TssOppslagService::class.java) fun hentSamhandlerDataForOrganisasjonB910(tssSamhandlerIdent: TssSamhandlerIdent): TypeOD910 { @@ -40,9 +42,7 @@ class TssOppslagService(private val tssMQClient: TssMQClient) { postNummer: String?, område: String?, side: Int, - ): TssSamhandlerData { - return tssMQClient.søkOrgInfo(navn, postNummer, område, side) - } + ): TssSamhandlerData = tssMQClient.søkOrgInfo(navn, postNummer, område, side) fun hentInformasjonOmSamhandlerInst( navn: String?, @@ -113,10 +113,15 @@ class TssOppslagService(private val tssMQClient: TssMQClient) { enkeltSamhandler: Samhandler, orgnr: String?, ): SamhandlerInfo { - val navn = enkeltSamhandler.samhandler110.samhandler.first().navnSamh + val navn = + enkeltSamhandler.samhandler110.samhandler + .first() + .navnSamh val orgnr = - orgnr ?: enkeltSamhandler.alternativId111.samhId.filter { it.kodeAltIdentType == "ORG" && it.datoIdentTom.isBlank() } - .firstOrNull()?.idAlternativ + orgnr ?: enkeltSamhandler.alternativId111.samhId + .filter { it.kodeAltIdentType == "ORG" && it.datoIdentTom.isBlank() } + .firstOrNull() + ?.idAlternativ val (tssId, avdNr) = mapTssEksternIdOgAvdNr(enkeltSamhandler.samhandlerAvd125) val avdelingsAdresser = madAdresse(enkeltSamhandler.adresse130, avdNr) @@ -124,7 +129,10 @@ class TssOppslagService(private val tssMQClient: TssMQClient) { } private fun mapSamhandler(enkeltSamhandler: TypeKomp940): SamhandlerInfo { - val navn = enkeltSamhandler.samhandler110.samhandler.first().navnSamh + val navn = + enkeltSamhandler.samhandler110.samhandler + .first() + .navnSamh val (tssId, avdNr) = mapTssEksternIdOgAvdNr(enkeltSamhandler.samhandlerAvd125) val avdelingsAdresser = madAdresse(enkeltSamhandler.adresse130, avdNr) @@ -146,10 +154,10 @@ class TssOppslagService(private val tssMQClient: TssMQClient) { private fun madAdresse( adresse130: TypeSamhAdr, avdNr: String?, - ) = adresse130.adresseSamh.filter { - it.avdNr == avdNr && it.gyldigAdresse == "J" - } - .mapNotNull { + ) = adresse130.adresseSamh + .filter { + it.avdNr == avdNr && it.gyldigAdresse == "J" + }.mapNotNull { val adresseLinje = if (it.antAdrLinje.isNullOrBlank()) emptyList() else it.adrLinjeInfo.adresseLinje SamhandlerAdresse(adresseLinje, it.postNr, it.poststed, it.beskrAdresseType) } diff --git a/src/test/kotlin/no/nav/familie/oppdrag/DevPsqlMqLauncher.kt b/src/test/kotlin/no/nav/familie/oppdrag/DevPsqlMqLauncher.kt index 01bd4b48..1feee93b 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/DevPsqlMqLauncher.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/DevPsqlMqLauncher.kt @@ -39,6 +39,10 @@ object DevPsqlMqLauncher { } } -class KPostgreSQLContainer(imageName: String) : PostgreSQLContainer(imageName) +class KPostgreSQLContainer( + imageName: String, +) : PostgreSQLContainer(imageName) -class KGenericContainer(imageName: String) : GenericContainer(imageName) +class KGenericContainer( + imageName: String, +) : GenericContainer(imageName) diff --git a/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/JaxbTest.kt b/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/JaxbTest.kt index 8b673b38..c2d16c1a 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/JaxbTest.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/JaxbTest.kt @@ -26,7 +26,8 @@ internal class JaxbTest { internal fun `oppdrag tilXml`() { val dato = LocalDate.of(2022, 1, 1) val xmlGregorianCalendar = - DatatypeFactory.newInstance() + DatatypeFactory + .newInstance() .newXMLGregorianCalendar(GregorianCalendar.from(dato.atStartOfDay(ZoneId.of("Europe/Oslo")))) val oppdrag = Oppdrag().apply { @@ -129,5 +130,8 @@ internal class JaxbTest { ) } - private fun loadResource(file: String) = JaxbTest::class.java.classLoader.getResource(file)!!.readText() + private fun loadResource(file: String) = + JaxbTest::class.java.classLoader + .getResource(file)!! + .readText() } diff --git a/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/KontraktTilOppdragTest.kt b/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/KontraktTilOppdragTest.kt index f32097f4..a56de828 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/KontraktTilOppdragTest.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/KontraktTilOppdragTest.kt @@ -154,7 +154,13 @@ class KontraktTilOppdragTest { Assertions.assertEquals(utbetalingsoppdrag.aktoer, oppdragsLinje150.utbetalesTilId) Assertions.assertEquals(utbetalingsperiode.behandlingId.toString(), oppdragsLinje150.henvisning) Assertions.assertEquals(utbetalingsoppdrag.saksbehandlerId, oppdragsLinje150.attestant180[0].attestantId) - Assertions.assertEquals(utbetalingsperiode.utbetalingsgrad, oppdragsLinje150.grad170.firstOrNull()?.grad?.toInt()) + Assertions.assertEquals( + utbetalingsperiode.utbetalingsgrad, + oppdragsLinje150.grad170 + .firstOrNull() + ?.grad + ?.toInt(), + ) if (utbetalingsperiode.forrigePeriodeId !== null && !utbetalingsperiode.erEndringPåEksisterendePeriode) { Assertions.assertEquals( diff --git a/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMQMottakTest.kt b/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMQMottakTest.kt index 4a221aca..f005f4a3 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMQMottakTest.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/iverksetting/OppdragMQMottakTest.kt @@ -179,9 +179,10 @@ class OppdragMQMottakTest { verify(exactly = 1) { oppdragMottaker.log.warn(any()) } } - private fun lesKvittering(filnavn: String): String { - return this::class.java.getResourceAsStream("/$filnavn").bufferedReader().use { it.readText() } - } + private fun lesKvittering(filnavn: String): String = + this::class.java.getResourceAsStream("/$filnavn").bufferedReader().use { + it.readText() + } val String.fraRessursSomTextMessage: TextMessage get() { diff --git a/src/test/kotlin/no/nav/familie/oppdrag/konsistensavstemming/KonsistensavstemmingServiceTest.kt b/src/test/kotlin/no/nav/familie/oppdrag/konsistensavstemming/KonsistensavstemmingServiceTest.kt index 89f854fc..e54edeb0 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/konsistensavstemming/KonsistensavstemmingServiceTest.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/konsistensavstemming/KonsistensavstemmingServiceTest.kt @@ -112,12 +112,19 @@ class KonsistensavstemmingServiceTest { assertThat(oppdrag.captured.oppdragsdataListe[0].oppdragslinjeListe).hasSize(2) assertThat(oppdrag.captured.oppdragsdataListe[0].oppdragGjelderId).isEqualTo(aktiveFødselsnummere[0]) assertTrue { - oppdrag.captured.oppdragsdataListe[0].oppdragslinjeListe + oppdrag.captured.oppdragsdataListe[0] + .oppdragslinjeListe .all { it.utbetalesTilId == aktiveFødselsnummere[0] } } - assertThat(totalData.captured.totaldata.totalBelop.toInt()).isEqualTo(322) - assertThat(totalData.captured.totaldata.totalAntall.toInt()).isEqualTo(1) + assertThat( + totalData.captured.totaldata.totalBelop + .toInt(), + ).isEqualTo(322) + assertThat( + totalData.captured.totaldata.totalAntall + .toInt(), + ).isEqualTo(1) } @Test @@ -146,11 +153,25 @@ class KonsistensavstemmingServiceTest { assertThat(oppdrag.captured.oppdragsdataListe).hasSize(1) assertThat(oppdrag.captured.oppdragsdataListe[0].oppdragslinjeListe).hasSize(2) assertThat(oppdrag.captured.oppdragsdataListe[0].oppdragGjelderId).isEqualTo(aktiveFødselsnummere[0]) - assertThat(oppdrag.captured.oppdragsdataListe[0].oppdragslinjeListe[0].utbetalesTilId == "tss-id") - assertThat(oppdrag.captured.oppdragsdataListe[0].oppdragslinjeListe[1].utbetalesTilId == aktiveFødselsnummere[0]) + assertThat( + oppdrag.captured.oppdragsdataListe[0] + .oppdragslinjeListe[0] + .utbetalesTilId == "tss-id", + ) + assertThat( + oppdrag.captured.oppdragsdataListe[0] + .oppdragslinjeListe[1] + .utbetalesTilId == aktiveFødselsnummere[0], + ) - assertThat(totalData.captured.totaldata.totalBelop.toInt()).isEqualTo(322) - assertThat(totalData.captured.totaldata.totalAntall.toInt()).isEqualTo(1) + assertThat( + totalData.captured.totaldata.totalBelop + .toInt(), + ).isEqualTo(322) + assertThat( + totalData.captured.totaldata.totalAntall + .toInt(), + ).isEqualTo(1) } @Test @@ -183,7 +204,8 @@ class KonsistensavstemmingServiceTest { assertThat(oppdrag.captured.oppdragsdataListe[0].oppdragslinjeListe).hasSize(1) assertThat(oppdrag.captured.oppdragsdataListe[0].oppdragGjelderId).isEqualTo(aktiveFødselsnummere[0]) assertTrue { - oppdrag.captured.oppdragsdataListe[0].oppdragslinjeListe + oppdrag.captured.oppdragsdataListe[0] + .oppdragslinjeListe .any { it.utbetalesTilId == aktiveFødselsnummere[0] } } @@ -191,12 +213,19 @@ class KonsistensavstemmingServiceTest { assertThat(oppdrag2.captured.oppdragsdataListe[0].oppdragslinjeListe).hasSize(2) assertThat(oppdrag2.captured.oppdragsdataListe[0].oppdragGjelderId).isEqualTo(aktiveFødselsnummere[1]) assertTrue { - oppdrag2.captured.oppdragsdataListe[0].oppdragslinjeListe + oppdrag2.captured.oppdragsdataListe[0] + .oppdragslinjeListe .any { it.utbetalesTilId == aktiveFødselsnummere[1] } } - assertThat(totalData.captured.totaldata.totalBelop.toInt()).isEqualTo(161) - assertThat(totalData.captured.totaldata.totalAntall.toInt()).isEqualTo(2) + assertThat( + totalData.captured.totaldata.totalBelop + .toInt(), + ).isEqualTo(161) + assertThat( + totalData.captured.totaldata.totalAntall + .toInt(), + ).isEqualTo(2) } @Test diff --git a/src/test/kotlin/no/nav/familie/oppdrag/repository/OppdragLagerRepositoryJdbcTest.kt b/src/test/kotlin/no/nav/familie/oppdrag/repository/OppdragLagerRepositoryJdbcTest.kt index 5d4ebd42..f4067a58 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/repository/OppdragLagerRepositoryJdbcTest.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/repository/OppdragLagerRepositoryJdbcTest.kt @@ -71,7 +71,8 @@ internal class OppdragLagerRepositoryJdbcTest { @Test fun skal_lagre_status() { val oppdragLager = - utbetalingsoppdragMedTilfeldigAktoer().somOppdragLager + utbetalingsoppdragMedTilfeldigAktoer() + .somOppdragLager .copy(status = OppdragStatus.LAGT_PÅ_KØ) oppdragLagerRepository.opprettOppdrag(oppdragLager) @@ -88,7 +89,8 @@ internal class OppdragLagerRepositoryJdbcTest { @Test fun skal_lagre_kvitteringsmelding() { val oppdragLager = - utbetalingsoppdragMedTilfeldigAktoer().somOppdragLager + utbetalingsoppdragMedTilfeldigAktoer() + .somOppdragLager .copy(status = OppdragStatus.LAGT_PÅ_KØ) oppdragLagerRepository.opprettOppdrag(oppdragLager) @@ -107,7 +109,8 @@ internal class OppdragLagerRepositoryJdbcTest { @Test fun `skal kun sette kvitteringsmeldingen til null`() { val oppdragLager = - utbetalingsoppdragMedTilfeldigAktoer().somOppdragLager + utbetalingsoppdragMedTilfeldigAktoer() + .somOppdragLager .copy(status = OppdragStatus.LAGT_PÅ_KØ, kvitteringsmelding = kvitteringsmelding()) oppdragLagerRepository.opprettOppdrag(oppdragLager) @@ -123,8 +126,10 @@ internal class OppdragLagerRepositoryJdbcTest { private fun kvitteringsmelding(): Mmel { val kvitteringsmelding = Jaxb.tilOppdrag( - this::class.java.getResourceAsStream("/kvittering-avvist.xml") - .bufferedReader().use { it.readText() }, + this::class.java + .getResourceAsStream("/kvittering-avvist.xml") + .bufferedReader() + .use { it.readText() }, ) return kvitteringsmelding.mmel } @@ -162,13 +167,14 @@ internal class OppdragLagerRepositoryJdbcTest { val dag = LocalDate.now() fun hentOppdragForGrensesnittsavstemming(page: Int) = - oppdragLagerRepository.hentIverksettingerForGrensesnittavstemming( - dag.atStartOfDay(), - dag.atTime(23, 59), - "BA", - 2, - page, - ).map { it.behandlingId.toInt() } + oppdragLagerRepository + .hentIverksettingerForGrensesnittavstemming( + dag.atStartOfDay(), + dag.atTime(23, 59), + "BA", + 2, + page, + ).map { it.behandlingId.toInt() } val oppdrag1 = lagTestUtbetalingsoppdrag( @@ -244,16 +250,14 @@ internal class OppdragLagerRepositoryJdbcTest { baOppdragLager.fagsystem, setOf("finnes ikke"), ), - ) - .isEmpty() + ).isEmpty() assertThat( oppdragLagerRepository.hentUtbetalingsoppdragForKonsistensavstemming( baOppdragLager.fagsystem, setOf(baOppdragLager.behandlingId), ), - ) - .hasSize(1) + ).hasSize(1) assertThat( oppdragLagerRepository.hentUtbetalingsoppdragForKonsistensavstemming( @@ -263,8 +267,7 @@ internal class OppdragLagerRepositoryJdbcTest { behandlingB.behandlingId, ), ), - ) - .hasSize(2) + ).hasSize(2) } @Test diff --git a/src/test/kotlin/no/nav/familie/oppdrag/rest/OppdragControllerIntegrationTest.kt b/src/test/kotlin/no/nav/familie/oppdrag/rest/OppdragControllerIntegrationTest.kt index bc2b9686..b2c79feb 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/rest/OppdragControllerIntegrationTest.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/rest/OppdragControllerIntegrationTest.kt @@ -105,7 +105,8 @@ internal class OppdragControllerIntegrationTest { ) { await() .pollInterval(Duration.ofMillis(200)) - .atMost(Duration.ofSeconds(10)).untilAsserted { + .atMost(Duration.ofSeconds(10)) + .untilAsserted { assertThat(oppdragLagerRepository.hentOppdrag(oppdragId).status).isEqualTo(oppdragStatus) } } diff --git a/src/test/kotlin/no/nav/familie/oppdrag/service/GrensesnittavstemmingServiceTest.kt b/src/test/kotlin/no/nav/familie/oppdrag/service/GrensesnittavstemmingServiceTest.kt index e70d6234..d48c839e 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/service/GrensesnittavstemmingServiceTest.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/service/GrensesnittavstemmingServiceTest.kt @@ -64,14 +64,16 @@ class GrensesnittavstemmingServiceTest { ) } returns listOf( - TestOppdragMedAvstemmingsdato.lagTestUtbetalingsoppdrag( - LocalDateTime.now(), - fagområde, - ).somAvstemming, - TestOppdragMedAvstemmingsdato.lagTestUtbetalingsoppdrag( - LocalDateTime.now(), - fagområde, - ).somAvstemming, + TestOppdragMedAvstemmingsdato + .lagTestUtbetalingsoppdrag( + LocalDateTime.now(), + fagområde, + ).somAvstemming, + TestOppdragMedAvstemmingsdato + .lagTestUtbetalingsoppdrag( + LocalDateTime.now(), + fagområde, + ).somAvstemming, ) every { oppdragLagerRepository.hentIverksettingerForGrensesnittavstemming( @@ -83,10 +85,11 @@ class GrensesnittavstemmingServiceTest { ) } returns listOf( - TestOppdragMedAvstemmingsdato.lagTestUtbetalingsoppdrag( - LocalDateTime.now(), - fagområde, - ).somAvstemming, + TestOppdragMedAvstemmingsdato + .lagTestUtbetalingsoppdrag( + LocalDateTime.now(), + fagområde, + ).somAvstemming, ) grensesnittavstemmingService.utførGrensesnittavstemming( diff --git a/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/Periode.kt b/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/Periode.kt index 59419b50..c75a1e65 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/Periode.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/Periode.kt @@ -54,9 +54,7 @@ data class Periode constructor( }, ) - override fun compareTo(other: Periode): Int { - return fom.compareTo(other.fom) - } + override fun compareTo(other: Periode): Int = fom.compareTo(other.fom) val antallVirkedager: Int get() { diff --git a/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/PeriodeGenerator.kt b/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/PeriodeGenerator.kt index ac3f2324..9f9c55b0 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/PeriodeGenerator.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/PeriodeGenerator.kt @@ -190,16 +190,17 @@ class PeriodeGenerator { PeriodeType.YTEL, ), ) - opphør.sats?.let { - Periode( - ytelse.tom, - ytelse.tom, - it, - ytelse.sats, - ytelse.typeSats, - ytelse.kodeKlassifik, - ) - }?.let { periodeList.add(it) } + opphør.sats + ?.let { + Periode( + ytelse.tom, + ytelse.tom, + it, + ytelse.sats, + ytelse.typeSats, + ytelse.kodeKlassifik, + ) + }?.let { periodeList.add(it) } removeYtelsesPerioder.add(ytelse) continue@ytelseloop // Scenario 3,4 og 5 @@ -216,38 +217,40 @@ class PeriodeGenerator { ) // Scenario 3 & 4 if (!ytelse.tom.isAfter(opphør.tom)) { - opphør.sats?.let { - Periode( - opphør.fom, - ytelse.tom, - it, - ytelse.sats, - ytelse.typeSats, - ytelse.kodeKlassifik, - ) - }?.let { - periodeList.add( - it, - ) - } + opphør.sats + ?.let { + Periode( + opphør.fom, + ytelse.tom, + it, + ytelse.sats, + ytelse.typeSats, + ytelse.kodeKlassifik, + ) + }?.let { + periodeList.add( + it, + ) + } removeYtelsesPerioder.add(ytelse) continue@ytelseloop // Scenario 5 } else { // if (ytelse.getTom().isAfter(opphør.getTom()) - opphør.sats?.let { - Periode( - opphør.fom, - opphør.tom, - it, - ytelse.sats, - ytelse.typeSats, - ytelse.kodeKlassifik, - ) - }?.let { - periodeList.add( - it, - ) - } + opphør.sats + ?.let { + Periode( + opphør.fom, + opphør.tom, + it, + ytelse.sats, + ytelse.typeSats, + ytelse.kodeKlassifik, + ) + }?.let { + periodeList.add( + it, + ) + } addYtelsesPerioder.add( Periode( opphør.tom.plusDays(1), @@ -262,30 +265,32 @@ class PeriodeGenerator { } // Scenario 6 & 7 } else if (ytelse.fom.isEqual(opphør.fom) && !ytelse.tom.isAfter(opphør.tom)) { - opphør.sats?.let { - Periode( - ytelse.fom, - ytelse.tom, - it, - ytelse.sats, - ytelse.typeSats, - ytelse.kodeKlassifik, - ) - }?.let { periodeList.add(it) } + opphør.sats + ?.let { + Periode( + ytelse.fom, + ytelse.tom, + it, + ytelse.sats, + ytelse.typeSats, + ytelse.kodeKlassifik, + ) + }?.let { periodeList.add(it) } removeYtelsesPerioder.add(ytelse) continue@ytelseloop // Scenario 8 } else if (ytelse.fom.isEqual(opphør.fom) && ytelse.tom.isAfter(opphør.tom)) { - opphør.sats?.let { - Periode( - ytelse.fom, - opphør.tom, - it, - ytelse.sats, - ytelse.typeSats, - ytelse.kodeKlassifik, - ) - }?.let { periodeList.add(it) } + opphør.sats + ?.let { + Periode( + ytelse.fom, + opphør.tom, + it, + ytelse.sats, + ytelse.typeSats, + ytelse.kodeKlassifik, + ) + }?.let { periodeList.add(it) } addYtelsesPerioder.add( Periode( opphør.tom.plusDays(1), @@ -305,16 +310,17 @@ class PeriodeGenerator { opphør.tom, ) ) { // ytelse.getFom() er implisit før opphør.getTom() da ytelse.getFom() ikke kan være etter ytelse.getTom() - opphør.sats?.let { - Periode( - ytelse.fom, - ytelse.tom, - it, - ytelse.sats, - ytelse.typeSats, - ytelse.kodeKlassifik, - ) - }?.let { periodeList.add(it) } + opphør.sats + ?.let { + Periode( + ytelse.fom, + ytelse.tom, + it, + ytelse.sats, + ytelse.typeSats, + ytelse.kodeKlassifik, + ) + }?.let { periodeList.add(it) } removeYtelsesPerioder.add(ytelse) continue@ytelseloop // Scenario 10 & 11 @@ -325,16 +331,17 @@ class PeriodeGenerator { opphør.tom, ) ) { // ytelse.getTom() er implisit after opphør.getTom() ellers ville den truffet forrige if-statement - opphør.sats?.let { - Periode( - ytelse.fom, - opphør.tom, - it, - ytelse.sats, - ytelse.typeSats, - ytelse.kodeKlassifik, - ) - }?.let { periodeList.add(it) } + opphør.sats + ?.let { + Periode( + ytelse.fom, + opphør.tom, + it, + ytelse.sats, + ytelse.typeSats, + ytelse.kodeKlassifik, + ) + }?.let { periodeList.add(it) } addYtelsesPerioder.add( Periode( opphør.tom.plusDays(1), diff --git a/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringGenerator.kt b/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringGenerator.kt index 9596a6aa..4019576a 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringGenerator.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringGenerator.kt @@ -30,7 +30,8 @@ class SimuleringGenerator { response.response = null } else { val innerResponse = - no.nav.system.os.tjenester.simulerfpservice.simulerfpserviceservicetypes.SimulerBeregningResponse() + no.nav.system.os.tjenester.simulerfpservice.simulerfpserviceservicetypes + .SimulerBeregningResponse() response.response = innerResponse innerResponse.simulering = beregning } @@ -168,7 +169,8 @@ class SimuleringGenerator { ) } } else if (oppdragsperiode.periodeType == PeriodeType.REDUKSJON && - YearMonth.from(periode.fom) + YearMonth + .from(periode.fom) .isBefore(nesteMåned) ) { stoppnivaa.beregningStoppnivaaDetaljer.add( @@ -187,7 +189,8 @@ class SimuleringGenerator { ) } } else if (oppdragsperiode.periodeType == PeriodeType.ØKNING && - YearMonth.from(periode.fom) + YearMonth + .from(periode.fom) .isBefore(nesteMåned) ) { stoppnivaa.beregningStoppnivaaDetaljer.add( diff --git a/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringGeneratorTest.kt b/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringGeneratorTest.kt index 71925a27..20bc9991 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringGeneratorTest.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringGeneratorTest.kt @@ -24,21 +24,31 @@ internal class SimuleringGeneratorTest { val response = simuleringGenerator.opprettSimuleringsResultat(request) assertThat(response.response.simulering.gjelderId) .isEqualTo(oppdragGjelderId) - .isEqualTo(response.response.simulering.beregningsPeriode[0].beregningStoppnivaa[0].utbetalesTilId) - .withFailMessage("Forventet 'gjelderId' var feil og/eller mottaker av ytelsen stemte ikke overens med personen ytelsen gjelder") + .isEqualTo( + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa[0] + .utbetalesTilId, + ).withFailMessage( + "Forventet 'gjelderId' var feil og/eller mottaker av ytelsen stemte ikke overens med personen ytelsen gjelder", + ) assertThat(response.response.simulering.beregningsPeriode.size) .isEqualTo(1) .withFailMessage( "Resultatperioden ble delt opp feil, ettersom alle periodene er sammenhengende skal de komme som en lang resultatperiode", ) - assertThat(response.response.simulering.beregningsPeriode[0].beregningStoppnivaa.size) - .isEqualTo(6) + assertThat( + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa.size, + ).isEqualTo(6) .withFailMessage( "Perioden fom 01.06.2020 - tom 30.11.2020 skal være på totat 5 måneder. Antall måneder i resultatet var: " + - response.response.simulering.beregningsPeriode[0].beregningStoppnivaa.size, + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa.size, ) val detaljer: List = - response.response.simulering.beregningsPeriode[0].beregningStoppnivaa[0].beregningStoppnivaaDetaljer + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa[0] + .beregningStoppnivaaDetaljer detaljer.sortedBy { beregningStoppnivaaDetaljer -> beregningStoppnivaaDetaljer.behandlingskode } assertThat(detaljer.size) .isEqualTo(1) @@ -63,17 +73,27 @@ internal class SimuleringGeneratorTest { val response = simuleringGenerator.opprettSimuleringsResultat(request) assertThat(response.response.simulering.gjelderId) .isEqualTo(oppdragGjelderId) - .isEqualTo(response.response.simulering.beregningsPeriode[0].beregningStoppnivaa[0].utbetalesTilId) - .withFailMessage("Forventet 'gjelderId' var feil og/eller mottaker av ytelsen stemte ikke overens med personen ytelsen gjelder") - assertThat(response.response.simulering.beregningsPeriode[0].beregningStoppnivaa.size) - .isEqualTo(5) + .isEqualTo( + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa[0] + .utbetalesTilId, + ).withFailMessage( + "Forventet 'gjelderId' var feil og/eller mottaker av ytelsen stemte ikke overens med personen ytelsen gjelder", + ) + assertThat( + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa.size, + ).isEqualTo(5) .withFailMessage( "Perioden fom 01.07.2020 - tom 30.11.2020 skal være på totat 5 måneder. Antall måneder i resultatet var: " + - response.response.simulering.beregningsPeriode[0].beregningStoppnivaa.size, + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa.size, ) val detaljer: List = - response.response.simulering.beregningsPeriode[0].beregningStoppnivaa[0].beregningStoppnivaaDetaljer + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa[0] + .beregningStoppnivaaDetaljer assertThat(detaljer.size) .isEqualTo(3) .withFailMessage("En respons med senket ytelse skal ha 3 beregningsStoppnivåDetaljer, Ytelse, Feilutbetaling og Negativ ytelse") @@ -110,17 +130,27 @@ internal class SimuleringGeneratorTest { val response = simuleringGenerator.opprettSimuleringsResultat(request) assertThat(response.response.simulering.gjelderId) .isEqualTo(oppdragGjelderId) - .isEqualTo(response.response.simulering.beregningsPeriode[0].beregningStoppnivaa[0].utbetalesTilId) - .withFailMessage("Forventet 'gjelderId' var feil og/eller mottaker av ytelsen stemte ikke overens med personen ytelsen gjelder") - assertThat(response.response.simulering.beregningsPeriode[0].beregningStoppnivaa.size) - .isEqualTo(4) + .isEqualTo( + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa[0] + .utbetalesTilId, + ).withFailMessage( + "Forventet 'gjelderId' var feil og/eller mottaker av ytelsen stemte ikke overens med personen ytelsen gjelder", + ) + assertThat( + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa.size, + ).isEqualTo(4) .withFailMessage( "Perioden fom 01.07.2020 - tom 31.10.2020 skal være på totat 4 måneder. Antall måneder i resultatet var: " + - response.response.simulering.beregningsPeriode[0].beregningStoppnivaa.size, + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa.size, ) val detaljer: List = - response.response.simulering.beregningsPeriode[0].beregningStoppnivaa[0].beregningStoppnivaaDetaljer + response.response.simulering.beregningsPeriode[0] + .beregningStoppnivaa[0] + .beregningStoppnivaaDetaljer assertThat(detaljer.size) .isEqualTo(3) .withFailMessage("En respons med senket ytelse skal ha 3 beregningsStoppnivåDetaljer, Ytelse, Feilutbetaling og Negativ ytelse") @@ -151,7 +181,8 @@ internal class SimuleringGeneratorTest { ): SimulerBeregningRequest { val request = SimulerBeregningRequest() request.request = - no.nav.system.os.tjenester.simulerfpservice.simulerfpserviceservicetypes.SimulerBeregningRequest() + no.nav.system.os.tjenester.simulerfpservice.simulerfpserviceservicetypes + .SimulerBeregningRequest() request.request.oppdrag = Oppdrag() request.request.oppdrag.kodeEndring = kodeEndring request.request.oppdrag.kodeFagomraade = "BA" diff --git a/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringSenderMock.kt b/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringSenderMock.kt index dce14739..16bf72f0 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringSenderMock.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/simulering/mock/SimuleringSenderMock.kt @@ -9,7 +9,6 @@ import org.springframework.stereotype.Service @Profile("dev", "dev_psql_mq") @Service class SimuleringSenderMock : SimuleringSender { - override fun hentSimulerBeregningResponse(simulerBeregningRequest: SimulerBeregningRequest?): SimulerBeregningResponse { - return SimuleringGenerator().opprettSimuleringsResultat(simulerBeregningRequest!!) - } + override fun hentSimulerBeregningResponse(simulerBeregningRequest: SimulerBeregningRequest?): SimulerBeregningResponse = + SimuleringGenerator().opprettSimuleringsResultat(simulerBeregningRequest!!) } diff --git a/src/test/kotlin/no/nav/familie/oppdrag/simulering/util/SimuleringTestUtils.kt b/src/test/kotlin/no/nav/familie/oppdrag/simulering/util/SimuleringTestUtils.kt index 2d3a57ce..d49f4077 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/simulering/util/SimuleringTestUtils.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/simulering/util/SimuleringTestUtils.kt @@ -68,7 +68,8 @@ fun lagSimulerBeregningResponse(beregningsPerioder: List): Si beregning.beregningsPeriode.addAll(beregningsPerioder) val simulerBeregningResponse = - no.nav.system.os.tjenester.simulerfpservice.simulerfpserviceservicetypes.SimulerBeregningResponse() + no.nav.system.os.tjenester.simulerfpservice.simulerfpserviceservicetypes + .SimulerBeregningResponse() simulerBeregningResponse.simulering = beregning val response = SimulerBeregningResponse() diff --git a/src/test/kotlin/no/nav/familie/oppdrag/tss/TssOppslagServiceTest.kt b/src/test/kotlin/no/nav/familie/oppdrag/tss/TssOppslagServiceTest.kt index ecfca81f..d13f625e 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/tss/TssOppslagServiceTest.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/tss/TssOppslagServiceTest.kt @@ -32,10 +32,20 @@ internal class TssOppslagServiceTest { every { mockedMessage.getBody(String::class.java) } returns lesFil("tss-910-response.xml") val response = service.hentSamhandlerDataForOrganisasjonB910(TssSamhandlerIdent("ORGNR", ORGNR)) assertEquals(1, response.enkeltSamhandler.size) - assertEquals("2", response.enkeltSamhandler.first().samhandlerAvd125.antSamhAvd) + assertEquals( + "2", + response.enkeltSamhandler + .first() + .samhandlerAvd125.antSamhAvd, + ) assertEquals( "80000112244", - response.enkeltSamhandler.first().samhandlerAvd125.samhAvd.filter { it.kilde == "IT00" }.first().idOffTSS, + response.enkeltSamhandler + .first() + .samhandlerAvd125.samhAvd + .filter { it.kilde == "IT00" } + .first() + .idOffTSS, ) } @@ -49,7 +59,13 @@ internal class TssOppslagServiceTest { assertEquals("0550", response.adresser.first().postNr) assertEquals("Oslo", response.adresser.first().postSted) assertEquals("Arbeidsadresse", response.adresser.first().adresseType) - assertEquals("Vei 3", response.adresser.first().adresselinjer.first()) + assertEquals( + "Vei 3", + response.adresser + .first() + .adresselinjer + .first(), + ) } @Test @@ -104,23 +120,46 @@ internal class TssOppslagServiceTest { fun `Skal hente samhandlerinfo ved søk på navn ved bruk av proxytjenesten b940`() { every { mockedMessage.getBody(String::class.java) } returns lesFil("tss-940-response.xml") val response = - service.hentInformasjonOmSamhandlerInstB940( - navn = "Inst", - postNummer = null, - område = null, - side = 0, - ).tssOutputData.samhandlerODataB940 + service + .hentInformasjonOmSamhandlerInstB940( + navn = "Inst", + postNummer = null, + område = null, + side = 0, + ).tssOutputData.samhandlerODataB940 assertEquals(3, response.enkeltSamhandler.size) - assertEquals("2", response.enkeltSamhandler.first().samhandlerAvd125.antSamhAvd) + assertEquals( + "2", + response.enkeltSamhandler + .first() + .samhandlerAvd125.antSamhAvd, + ) assertEquals( "80000442211", - response.enkeltSamhandler.first().samhandlerAvd125.samhAvd.filter { it.kilde == "IT00" }.first().idOffTSS, + response.enkeltSamhandler + .first() + .samhandlerAvd125.samhAvd + .filter { it.kilde == "IT00" } + .first() + .idOffTSS, ) assertEquals( "80000112244", - response.enkeltSamhandler.get(1).samhandlerAvd125.samhAvd.filter { it.kilde == "IT00" }.first().idOffTSS, + response.enkeltSamhandler + .get(1) + .samhandlerAvd125.samhAvd + .filter { it.kilde == "IT00" } + .first() + .idOffTSS, + ) + assertEquals( + 0, + response.enkeltSamhandler + .get(2) + .samhandlerAvd125.samhAvd + .filter { it.kilde == "IT00" } + .size, ) - assertEquals(0, response.enkeltSamhandler.get(2).samhandlerAvd125.samhAvd.filter { it.kilde == "IT00" }.size) } @Test @@ -131,11 +170,45 @@ internal class TssOppslagServiceTest { assertEquals(2, response.samhandlere.size) assertEquals("Inst 1", response.samhandlere.first().navn) assertEquals("80000442211", response.samhandlere.first().tssEksternId) - assertEquals(1, response.samhandlere.first().adresser.size) - assertEquals("0550", response.samhandlere.first().adresser.first().postNr) - assertEquals("Oslo", response.samhandlere.first().adresser.first().postSted) - assertEquals("Arbeidsadresse", response.samhandlere.first().adresser.first().adresseType) - assertEquals("[Vei 3]", response.samhandlere.first().adresser.first().adresselinjer.toString()) + assertEquals( + 1, + response.samhandlere + .first() + .adresser.size, + ) + assertEquals( + "0550", + response.samhandlere + .first() + .adresser + .first() + .postNr, + ) + assertEquals( + "Oslo", + response.samhandlere + .first() + .adresser + .first() + .postSted, + ) + assertEquals( + "Arbeidsadresse", + response.samhandlere + .first() + .adresser + .first() + .adresseType, + ) + assertEquals( + "[Vei 3]", + response.samhandlere + .first() + .adresser + .first() + .adresselinjer + .toString(), + ) assertEquals("Inst 2", response.samhandlere.last().navn) assertEquals("80000112244", response.samhandlere.last().tssEksternId) } @@ -148,11 +221,45 @@ internal class TssOppslagServiceTest { assertEquals(2, response.samhandlere.size) assertEquals("Inst 1", response.samhandlere.first().navn) assertEquals("80000442211", response.samhandlere.first().tssEksternId) - assertEquals(1, response.samhandlere.first().adresser.size) - assertEquals("0550", response.samhandlere.first().adresser.first().postNr) - assertEquals("Oslo", response.samhandlere.first().adresser.first().postSted) - assertEquals("Arbeidsadresse", response.samhandlere.first().adresser.first().adresseType) - assertEquals("[Vei 3]", response.samhandlere.first().adresser.first().adresselinjer.toString()) + assertEquals( + 1, + response.samhandlere + .first() + .adresser.size, + ) + assertEquals( + "0550", + response.samhandlere + .first() + .adresser + .first() + .postNr, + ) + assertEquals( + "Oslo", + response.samhandlere + .first() + .adresser + .first() + .postSted, + ) + assertEquals( + "Arbeidsadresse", + response.samhandlere + .first() + .adresser + .first() + .adresseType, + ) + assertEquals( + "[Vei 3]", + response.samhandlere + .first() + .adresser + .first() + .adresselinjer + .toString(), + ) assertEquals("Inst 2", response.samhandlere.last().navn) assertEquals("80000112244", response.samhandlere.last().tssEksternId) } @@ -165,16 +272,48 @@ internal class TssOppslagServiceTest { assertEquals(2, response.samhandlere.size) assertEquals("Inst 1", response.samhandlere.first().navn) assertEquals("80000442211", response.samhandlere.first().tssEksternId) - assertEquals(1, response.samhandlere.first().adresser.size) - assertEquals("0550", response.samhandlere.first().adresser.first().postNr) - assertEquals("Oslo", response.samhandlere.first().adresser.first().postSted) - assertEquals("Arbeidsadresse", response.samhandlere.first().adresser.first().adresseType) - assertEquals("[Vei 3]", response.samhandlere.first().adresser.first().adresselinjer.toString()) + assertEquals( + 1, + response.samhandlere + .first() + .adresser.size, + ) + assertEquals( + "0550", + response.samhandlere + .first() + .adresser + .first() + .postNr, + ) + assertEquals( + "Oslo", + response.samhandlere + .first() + .adresser + .first() + .postSted, + ) + assertEquals( + "Arbeidsadresse", + response.samhandlere + .first() + .adresser + .first() + .adresseType, + ) + assertEquals( + "[Vei 3]", + response.samhandlere + .first() + .adresser + .first() + .adresselinjer + .toString(), + ) assertEquals("Inst 2", response.samhandlere.last().navn) assertEquals("80000112244", response.samhandlere.last().tssEksternId) } - private fun lesFil(fileName: String): String { - return TssOppslagServiceTest::class.java.getResource("/tss/$fileName").readText() - } + private fun lesFil(fileName: String): String = TssOppslagServiceTest::class.java.getResource("/tss/$fileName").readText() } diff --git a/src/test/kotlin/no/nav/familie/oppdrag/util/ContainerTest.kt b/src/test/kotlin/no/nav/familie/oppdrag/util/ContainerTest.kt index 3994161b..05808ce8 100644 --- a/src/test/kotlin/no/nav/familie/oppdrag/util/ContainerTest.kt +++ b/src/test/kotlin/no/nav/familie/oppdrag/util/ContainerTest.kt @@ -19,21 +19,24 @@ object Containers { .withEnv("persistance.enabled", "true") .withExposedPorts(1414) - class MyGeneralContainer(imageName: String) : GenericContainer(imageName) + class MyGeneralContainer( + imageName: String, + ) : GenericContainer(imageName) class MQInitializer : ApplicationContextInitializer { override fun initialize(configurableApplicationContext: ConfigurableApplicationContext) { - TestPropertyValues.of( - "oppdrag.mq.port=" + ibmMQContainer.getMappedPort(1414), - "oppdrag.mq.queuemanager=QM1", - "oppdrag.mq.send=DEV.QUEUE.1", - "oppdrag.mq.mottak=DEV.QUEUE.1", - "oppdrag.mq.channel=DEV.ADMIN.SVRCONN", - "oppdrag.mq.hostname=localhost", - "oppdrag.mq.user=admin", - "oppdrag.mq.password: passw0rd", - "oppdrag.mq.enabled: true", - ).applyTo(configurableApplicationContext.environment) + TestPropertyValues + .of( + "oppdrag.mq.port=" + ibmMQContainer.getMappedPort(1414), + "oppdrag.mq.queuemanager=QM1", + "oppdrag.mq.send=DEV.QUEUE.1", + "oppdrag.mq.mottak=DEV.QUEUE.1", + "oppdrag.mq.channel=DEV.ADMIN.SVRCONN", + "oppdrag.mq.hostname=localhost", + "oppdrag.mq.user=admin", + "oppdrag.mq.password: passw0rd", + "oppdrag.mq.enabled: true", + ).applyTo(configurableApplicationContext.environment) } } }