Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Ktlint format #424

Merged
merged 1 commit into from
Oct 16, 2023
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 0 additions & 6 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
<bidrag-commons.version>20231013111728_2a4d649</bidrag-commons.version>
<bidrag-commons-test.version>1.20230503150725_3c2c77b</bidrag-commons-test.version>
<bidrag-transport.version>20231010134706_52d8d27</bidrag-transport.version>
<bidrag-dokument-dto.version>1.6.41</bidrag-dokument-dto.version>
<commons-codec.version>1.15</commons-codec.version>
<graphq-dgs-client.version>6.0.5</graphq-dgs-client.version>
<joark-hendelse.version>67a9be4476b63b7247cfacfaf821ab656bd2a952</joark-hendelse.version>
Expand Down Expand Up @@ -134,11 +133,6 @@
<groupId>io.micrometer</groupId>
<artifactId>micrometer-registry-prometheus</artifactId>
</dependency>
<dependency>
<groupId>no.nav.bidrag.dokument</groupId>
<artifactId>bidrag-dokument-dto</artifactId>
<version>${bidrag-dokument-dto.version}</version>
</dependency>

<dependency>
<groupId>no.nav.bidrag</groupId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import io.swagger.v3.oas.annotations.enums.SecuritySchemeType
import io.swagger.v3.oas.annotations.info.Info
import io.swagger.v3.oas.annotations.security.SecurityRequirement
import io.swagger.v3.oas.annotations.security.SecurityScheme
import no.nav.bidrag.commons.ExceptionLogger
import no.nav.bidrag.commons.security.api.EnableSecurityConfiguration
import no.nav.bidrag.commons.security.service.SecurityTokenService
import no.nav.bidrag.commons.security.service.StsTokenService
Expand All @@ -15,7 +14,6 @@ import no.nav.bidrag.commons.web.DefaultCorsFilter
import no.nav.bidrag.commons.web.HttpHeaderRestTemplate
import no.nav.bidrag.commons.web.MdcFilter
import no.nav.bidrag.commons.web.UserMdcFilter
import no.nav.bidrag.dokument.arkiv.aop.HttpStatusRestControllerAdvice
import no.nav.bidrag.dokument.arkiv.consumer.BidragOrganisasjonConsumer
import no.nav.bidrag.dokument.arkiv.consumer.DokarkivConsumer
import no.nav.bidrag.dokument.arkiv.consumer.DokarkivKnyttTilSakConsumer
Expand Down Expand Up @@ -331,30 +329,32 @@ class BidragDokumentArkivConfig {
val bidragOrganisasjonUrl: String
) {
override fun toString(): String {
return ("dokarkivUrl='"
+ dokarkivUrl
+ '\''
+ ", safUrl='"
+ safUrl
+ '\''
+ ", bidragPersonUrl='"
+ bidragPersonUrl
+ '\''
+ ", dokarkivKnyttTilSakUrl='"
+ dokarkivKnyttTilSakUrl
+ '\''
+ ", securityTokenUrl='"
+ securityTokenUrl
+ '\''
+ ", bidragOrganisasjonUrl='"
+ bidragOrganisasjonUrl
+ '\''
+ ", naisAppName='"
+ naisAppName
+ '\''
+ ", secretForServiceUser '"
+ notActualValue()
+ "'.")
return (
"dokarkivUrl='" +
dokarkivUrl +
'\'' +
", safUrl='" +
safUrl +
'\'' +
", bidragPersonUrl='" +
bidragPersonUrl +
'\'' +
", dokarkivKnyttTilSakUrl='" +
dokarkivKnyttTilSakUrl +
'\'' +
", securityTokenUrl='" +
securityTokenUrl +
'\'' +
", bidragOrganisasjonUrl='" +
bidragOrganisasjonUrl +
'\'' +
", naisAppName='" +
naisAppName +
'\'' +
", secretForServiceUser '" +
notActualValue() +
"'."
)
}

private fun notActualValue(): String {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,5 @@
package no.nav.bidrag.dokument.arkiv.aop

import com.fasterxml.jackson.databind.exc.MismatchedInputException
import com.fasterxml.jackson.module.kotlin.MissingKotlinParameterException
import no.nav.bidrag.commons.util.hentForespørselValideringsfeil
import no.nav.bidrag.dokument.arkiv.model.HttpStatusException
import no.nav.bidrag.dokument.arkiv.model.JournalIkkeFunnetException
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,24 +37,28 @@ class AvvikController(private val avvikService: AvvikService) : BaseController()
@GetMapping(ROOT_JOURNAL + "/{journalpostId}/avvik")
@Operation(
security = [SecurityRequirement(name = "bearer-key")],
summary = "Henter mulige avvik for en journalpost, id på formatet '"
+ KildesystemIdenfikator.PREFIX_JOARK
+ "<journalpostId>'"
summary = "Henter mulige avvik for en journalpost, id på formatet '" +
KildesystemIdenfikator.PREFIX_JOARK +
"<journalpostId>'"
)
@ApiResponses(
value = [ApiResponse(
responseCode = "200",
description = "Tilgjengelig avvik for journalpost er hentet"
), ApiResponse(
responseCode = "404",
description = "Fant ikke journalpost som det skal hentes avvik på",
)]
value = [
ApiResponse(
responseCode = "200",
description = "Tilgjengelig avvik for journalpost er hentet"
), ApiResponse(
responseCode = "404",
description = "Fant ikke journalpost som det skal hentes avvik på"
)
]
)
fun hentAvvik(
@PathVariable journalpostId: String?,
@Parameter(name = "saksnummer", description = "journalposten tilhører sak") @RequestParam(
@Parameter(name = "saksnummer", description = "journalposten tilhører sak")
@RequestParam(
required = false
) saksnummer: String?
)
saksnummer: String?
): ResponseEntity<List<AvvikType>> {
val muligSak = Optional.ofNullable(saksnummer)
if (muligSak.isPresent) {
Expand All @@ -71,13 +75,15 @@ class AvvikController(private val avvikService: AvvikService) : BaseController()
),
HttpStatus.BAD_REQUEST
)
} else ResponseEntity.ok(
avvikService.hentAvvik(
java.lang.Long.valueOf(
kildesystemIdenfikator.hentJournalpostId()!!.toLong()
} else {
ResponseEntity.ok(
avvikService.hentAvvik(
java.lang.Long.valueOf(
kildesystemIdenfikator.hentJournalpostId()!!.toLong()
)
)
)
)
}
}

@PostMapping(
Expand All @@ -86,17 +92,19 @@ class AvvikController(private val avvikService: AvvikService) : BaseController()
)
@Operation(
security = [SecurityRequirement(name = "bearer-key")],
summary = "Behandler et avvik for en journalpost, id på formatet '"
+ KildesystemIdenfikator.PREFIX_JOARK_COMPLETE
+ "<journalpostId>'"
summary = "Behandler et avvik for en journalpost, id på formatet '" +
KildesystemIdenfikator.PREFIX_JOARK_COMPLETE +
"<journalpostId>'"
)
@Transactional
@ApiResponses(
value = [ApiResponse(
responseCode = "200",
description = "Avvik på journalpost er behandlet"
), ApiResponse(
responseCode = "400", description = """En av følgende:
value = [
ApiResponse(
responseCode = "200",
description = "Avvik på journalpost er behandlet"
), ApiResponse(
responseCode = "400",
description = """En av følgende:
- prefiks på journalpostId er ugyldig
- avvikstypen mangler i avvikshendelsen
- enhetsnummer i header (X_ENHET) mangler
Expand All @@ -105,18 +113,21 @@ class AvvikController(private val avvikService: AvvikService) : BaseController()
- BESTILL_SPLITTING: beskrivelse må være i avvikshendelsen
- OVERFOR_TIL_ANNEN_ENHET: nyttEnhetsnummer og gammeltEnhetsnummer må være i detaljer map
"""
), ApiResponse(
responseCode = "503",
description = "Oppretting av oppgave for avviket feilet"
)]
), ApiResponse(
responseCode = "503",
description = "Oppretting av oppgave for avviket feilet"
)
]
)
fun behandleAvvik(
@PathVariable journalpostId: String?,
@RequestBody avvikshendelse: Avvikshendelse,
@RequestHeader(EnhetFilter.X_ENHET_HEADER) enhet: String?
): ResponseEntity<BehandleAvvikshendelseResponse> {
LOGGER.info(
"Behandle avvik {} for journalpost {}", avvikshendelse.avvikType, journalpostId
"Behandle avvik {} for journalpost {}",
avvikshendelse.avvikType,
journalpostId
)
BidragDokumentArkiv.SECURE_LOGGER.info(
"Behandle avvik {} for journalpost {}: {}",
Expand All @@ -135,17 +146,21 @@ class AvvikController(private val avvikService: AvvikService) : BaseController()
if (muligAvvikstype == null || enhet.isNullOrBlank()) {
val message = String.format(
"BAD REQUEST: avvikshendelse: %s, mulig avvik: %s, enhet: %s",
avvikshendelse, muligAvvikstype, enhet
avvikshendelse,
muligAvvikstype,
enhet
)
LOGGER.warn(message)
return ResponseEntity(
initHttpHeadersWith(HttpHeaders.WARNING, message), HttpStatus.BAD_REQUEST
initHttpHeadersWith(HttpHeaders.WARNING, message),
HttpStatus.BAD_REQUEST
)
}
val behandleAvvikResponse = avvikService.behandleAvvik(
AvvikshendelseIntern(
avvikshendelse,
enhet, kildesystemIdenfikator.hentJournalpostId()!!.toLong()
enhet,
kildesystemIdenfikator.hentJournalpostId()!!.toLong()
)
)
return ResponseEntity.ok(behandleAvvikResponse)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,8 @@ class JournalpostController(
return journalpostService.hentJournalpostMedFnrOgTilknyttedeSaker(
java.lang.Long.valueOf(
journalpostId.toLong()
), saksnummer
),
saksnummer
)
.map { journalpost: Journalpost -> ResponseEntity.ok(journalpost.tilJournalpostResponse()) }
.orElse(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,10 +26,12 @@ class OpprettJournalpostController(private val opprettJournalpostService: Oppret
description = "Opprett journalpost i Joark"
)
@ApiResponses(
value = [ApiResponse(
responseCode = "400",
description = "Opprett journalpost kalt med ugyldig data"
)]
value = [
ApiResponse(
responseCode = "400",
description = "Opprett journalpost kalt med ugyldig data"
)
]
)
fun opprettJournalpost(@RequestBody opprettJournalpostRequest: OpprettJournalpostRequest): ResponseEntity<OpprettJournalpostResponse> {
SECURE_LOGGER.info("Oppretter journalpost {}", opprettJournalpostRequest)
Expand Down
22 changes: 14 additions & 8 deletions src/main/java/no/nav/bidrag/dokument/arkiv/service/AvvikService.kt
Original file line number Diff line number Diff line change
Expand Up @@ -47,10 +47,8 @@ import org.slf4j.LoggerFactory
import org.springframework.stereotype.Service
import java.time.LocalDate
import java.util.Base64
import java.util.Optional
import java.util.function.Consumer
import java.util.stream.Stream
import kotlin.jvm.optionals.getOrNull

@Service
class AvvikService(
Expand Down Expand Up @@ -259,17 +257,25 @@ class AvvikService(
med tittel "$nyJournalpostTittel (Kopiert fra dokument: ${journalpost.hentTittel()})"
avvikshendelseIntern.dokumenter!!.forEach(
Consumer { (dokumentreferanse, _, _, tittel, dokument, brevkode): DokumentDto ->
val dokumentByte = if (Strings.isNotEmpty(dokument)) Base64.getDecoder()
.decode(dokument) else null
val dokumentByte = if (Strings.isNotEmpty(dokument)) {
Base64.getDecoder()
.decode(dokument)
} else {
null
}
+JoarkOpprettJournalpostRequest.Dokument(
dokumentInfoId = dokumentreferanse,
brevkode = brevkode,
tittel = tittel,
dokumentvarianter = if (dokumentByte != null) listOf(
opprettDokumentVariant(
dokumentByte = dokumentByte
dokumentvarianter = if (dokumentByte != null) {
listOf(
opprettDokumentVariant(
dokumentByte = dokumentByte
)
)
) else emptyList()
} else {
emptyList()
}
)
}
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ import no.nav.bidrag.dokument.arkiv.dto.validerAdresse
import no.nav.bidrag.dokument.arkiv.dto.validerKanDistribueres
import no.nav.bidrag.dokument.arkiv.dto.validerKanDistribueresUtenAdresse
import no.nav.bidrag.dokument.arkiv.dto.validerUtgaaendeJournalpostKanDupliseres
import no.nav.bidrag.dokument.arkiv.kafka.BehandleJournalforingHendelseService
import no.nav.bidrag.dokument.arkiv.mapper.tilVarselTypeDto
import no.nav.bidrag.dokument.arkiv.model.Discriminator
import no.nav.bidrag.dokument.arkiv.model.JournalpostIkkeFunnetException
Expand Down Expand Up @@ -83,7 +82,7 @@ class DistribuerJournalpostService(
request.forsendelseStoerrelse
)
SECURE_LOGGER.info("Hentet kanal ${kanal.distribusjonskanal} for forespørsel $request")
return kanal;
return kanal
}

fun hentDistribusjonKanal(journalpost: Journalpost): BestemKanalResponse {
Expand Down Expand Up @@ -208,11 +207,14 @@ class DistribuerJournalpostService(
val distribusjonKanal = hentDistribusjonKanal(journalpost)

val adresse =
if (distribusjonKanal.distribusjonskanal == DistribusjonsKanal.PRINT) hentOgValiderAdresse(
distribuerJournalpostRequest,
journalpost
) else null

if (distribusjonKanal.distribusjonskanal == DistribusjonsKanal.PRINT) {
hentOgValiderAdresse(
distribuerJournalpostRequest,
journalpost
)
} else {
null
}

// TODO: Lagre bestillingsid når bd-arkiv er koblet mot database
val distribuerResponse =
Expand Down Expand Up @@ -326,7 +328,6 @@ class DistribuerJournalpostService(
distribuerJournalpostRequestInternal: DistribuerJournalpostRequestInternal,
journalpost: Journalpost
): DistribuerTilAdresse? {

if (distribuerJournalpostRequestInternal.hasAdresse()) {
return distribuerJournalpostRequestInternal.getAdresse()
}
Expand Down Expand Up @@ -410,7 +411,7 @@ class DistribuerJournalpostService(
if (Strings.isNullOrEmpty(batchId)) "NONE" else batchId,
"enhet", journalpost.journalforendeEnhet,
"tema", journalpost.tema,
"kanal", kanal,
"kanal", kanal
).increment()

distributionAntallDokumenter.record(journalpost.dokumenter.size.toDouble())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -118,12 +118,14 @@ class EndreJournalpostService(
endreJournalpostCommand.hentTilknyttetSaker().stream()
.filter { sak: String? -> !journalpost.hentTilknyttetSaker().contains(sak) }
.collect(Collectors.toSet())
.forEach(Consumer { saksnummer: String? ->
tilknyttTilSak(
saksnummer,
journalpost
)
})
.forEach(
Consumer { saksnummer: String? ->
tilknyttTilSak(
saksnummer,
journalpost
)
}
)
}
}

Expand Down Expand Up @@ -178,7 +180,6 @@ class EndreJournalpostService(
LOGGER.info("Henter jouranlpost $journalpostId")
return journalpostService.hentJournalpost(journalpostId)
?: throw JournalpostIkkeFunnetException("Kunne ikke finne journalpost med id: $journalpostId")

}

fun oppdaterDistribusjonsInfo(
Expand Down
Loading