diff --git a/src/main/kotlin/no/nav/k9/los/fagsystem/k9punsj/K9PunsjStream.kt b/src/main/kotlin/no/nav/k9/los/fagsystem/k9punsj/K9PunsjStream.kt deleted file mode 100644 index a5dd74aca..000000000 --- a/src/main/kotlin/no/nav/k9/los/fagsystem/k9punsj/K9PunsjStream.kt +++ /dev/null @@ -1,87 +0,0 @@ -package no.nav.k9.los.fagsystem.k9punsj - -import com.fasterxml.jackson.module.kotlin.readValue -import kotlinx.coroutines.runBlocking -import no.nav.k9.los.Configuration -import no.nav.k9.los.aksjonspunktbehandling.SerDes -import no.nav.k9.los.aksjonspunktbehandling.Topic -import no.nav.k9.los.fagsystem.k9punsj.kontrakt.ProduksjonsstyringHendelse -import no.nav.k9.los.fagsystem.k9sak.K9SakStream -import no.nav.k9.los.integrasjon.kafka.ManagedKafkaStreams -import no.nav.k9.los.integrasjon.kafka.ManagedStreamHealthy -import no.nav.k9.los.integrasjon.kafka.ManagedStreamReady -import no.nav.k9.los.integrasjon.kafka.IKafkaConfig -import no.nav.k9.los.utils.LosObjectMapper -import no.nav.k9.los.utils.TransientFeilHåndterer -import org.apache.kafka.clients.consumer.OffsetResetStrategy -import org.apache.kafka.streams.StreamsBuilder -import org.apache.kafka.streams.Topology -import org.apache.kafka.streams.kstream.Consumed -import org.slf4j.LoggerFactory - -internal class K9PunsjStream constructor( - kafkaConfig: IKafkaConfig, - configuration: Configuration, - k9punsjEventHandlerv2: K9PunsjEventHandlerV2 -) { - - private val stream = ManagedKafkaStreams( - name = NAME, - properties = kafkaConfig.stream(NAME, OffsetResetStrategy.NONE), - topology = topology( - configuration = configuration, - k9PunsjEventHandler = k9punsjEventHandlerv2 - ), - unreadyAfterStreamStoppedIn = kafkaConfig.unreadyAfterStreamStoppedIn - ) - - internal val ready = ManagedStreamReady(stream) - internal val healthy = ManagedStreamHealthy(stream) - - private companion object { - private const val NAME = "K9PunsjHendelseV1" - - private val log = LoggerFactory.getLogger(K9SakStream::class.java) - - private fun topology( - configuration: Configuration, - k9PunsjEventHandler: K9PunsjEventHandlerV2 - ): Topology { - val builder = StreamsBuilder() - val fromTopic = Topic( - name = configuration.getK9PunsjTopic(), - serDes = K9PunsjEventSerDes() - ) - builder - .stream( - fromTopic.name, - Consumed.with(fromTopic.keySerde, fromTopic.valueSerde) - ).peek { _, e -> log.info("--> K9PunsjHendelse: ${e.safeToString() }") } - .foreach { _, entry -> - if (entry != null) { - TransientFeilHåndterer().utfør(NAME) { - runBlocking { - k9PunsjEventHandler.prosesser(entry) } - } - } - } - return builder.build() - } - - class K9PunsjEventSerDes : SerDes() { - override fun deserialize(topic: String?, data: ByteArray?): ProduksjonsstyringHendelse? { - return data?.let { - return try { - LosObjectMapper.instance.readValue(it) - } catch (e: Exception) { - log.warn("", e) - log.warn(String(it)) - throw e - } - } - } - } - } - - internal fun stop() = stream.stop(becauseOfError = false) -} diff --git a/src/main/kotlin/no/nav/k9/los/integrasjon/azuregraph/DisplayName.kt b/src/main/kotlin/no/nav/k9/los/integrasjon/azuregraph/DisplayName.kt deleted file mode 100644 index 953b29f7b..000000000 --- a/src/main/kotlin/no/nav/k9/los/integrasjon/azuregraph/DisplayName.kt +++ /dev/null @@ -1,11 +0,0 @@ -package no.nav.k9.los.integrasjon.azuregraph - - -import com.fasterxml.jackson.annotation.JsonProperty - -data class DisplayName( - @JsonProperty("@odata.context") - val odataContext: String, - val displayName: String, - val PremisesSamAccountName: String -) diff --git a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/AvsluttGosysOppgaveRequest.kt b/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/AvsluttGosysOppgaveRequest.kt deleted file mode 100644 index 80c8e756e..000000000 --- a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/AvsluttGosysOppgaveRequest.kt +++ /dev/null @@ -1,18 +0,0 @@ -package no.nav.k9.los.integrasjon.gosys - -import org.json.JSONObject - -class AvsluttGosysOppgaveRequest( - private val versjon: Int, - private val id: Int -) { - - - fun body(): String { - return JSONObject() - .put("versjon", versjon) - .put("id", id) - .put("status", GosysKonstanter.OppgaveStatus.FERDIGSTILT) - .toString() - } -} diff --git a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/ForventetStatusCodeResponseHandler.kt b/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/ForventetStatusCodeResponseHandler.kt deleted file mode 100644 index 039e1d549..000000000 --- a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/ForventetStatusCodeResponseHandler.kt +++ /dev/null @@ -1,34 +0,0 @@ -package no.nav.k9.los.integrasjon.gosys - -import org.apache.http.HttpResponse -import org.apache.http.client.HttpResponseException -import org.apache.http.impl.client.BasicResponseHandler -import org.apache.http.util.EntityUtils -import java.io.IOException - -internal class ForventetStatusCodeResponseHandler( - private val forventetStatusCode: Int) : - BasicResponseHandler() { - @Throws(HttpResponseException::class, IOException::class) - override fun handleResponse( - response: HttpResponse - ): String { - val statusLine = response.statusLine - val entity = response.entity - if (statusLine.statusCode != forventetStatusCode) { - EntityUtils.consume(entity) - throw HttpResponseException( - statusLine.statusCode, - statusLine.reasonPhrase - ) - } - return entity?.let { handleEntity(it) }!! - } - - companion object { - fun of(forventetStatusCode: Int): ForventetStatusCodeResponseHandler { - return ForventetStatusCodeResponseHandler(forventetStatusCode) - } - } - -} \ No newline at end of file diff --git a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/GosysKonstanter.kt b/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/GosysKonstanter.kt deleted file mode 100644 index 2771c7890..000000000 --- a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/GosysKonstanter.kt +++ /dev/null @@ -1,46 +0,0 @@ -package no.nav.k9.los.integrasjon.gosys - - -class GosysKonstanter private constructor() { - enum class TemaGruppe(val dto: String) { - FAMILIE("FMLI"); - } - - enum class OppgaveType(val dto: String) { - JOURNALFØRING("JFR"), - BEHANDLE("BEH_SAK"); - } - - enum class Prioritet(val dto: String) { - NORMAL("NORM"); - } - - enum class Fagsaksystem(val dto: String) { - INFOTRYGD("IT00"), - K9SAK("IT01"); - } - - enum class OppgaveStatus(val dto: String) { - OPPRETTET("OPPRETTET"), - AAPNET("AAPNET"), - UNDER_BEHANDLING("UNDER_BEHANDLING"), - FERDIGSTILT("FERDIGSTILT"), - FEILREGISTRERT("FEILREGISTRERT"); - } - - enum class JournalpostSystem(val dto: String) { - JOARK("AS36"); - } - - enum class BehandlingsTema(val dto: String) { - PLEIEPENGER_SYKT_BARN_NY_ORDNING("ab0320"), OMSORGSPENGER("ab0149"); - } - - enum class BehandlingsType(val dto: String) { - DIGITAL_SØKNAD("ae0227"); - } - - enum class Tema(val dto: String) { - KAPITTEL_9_YTELSER("OMS"); - } -} diff --git a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/GosysOppgave.kt b/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/GosysOppgave.kt deleted file mode 100644 index b64651053..000000000 --- a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/GosysOppgave.kt +++ /dev/null @@ -1,3 +0,0 @@ -package no.nav.k9.los.integrasjon.gosys - -data class GosysOppgave(val oppgaveId: Int, val versjon : Int) diff --git a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/HentGosysOppgaverRequest.kt b/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/HentGosysOppgaverRequest.kt deleted file mode 100644 index 784e5f357..000000000 --- a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/HentGosysOppgaverRequest.kt +++ /dev/null @@ -1,11 +0,0 @@ -package no.nav.k9.los.integrasjon.gosys - -data class HentGosysOppgaverRequest( - val tema: GosysKonstanter.Tema, - val oppgaveType: GosysKonstanter.OppgaveType, - val aktørId: String -){ - fun queryString(): String { - return "?tema=${tema.dto}&oppgavetype=${oppgaveType.dto}&aktoerId=$aktørId" - } -} diff --git a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/OpprettGosysOppgaveRequest.kt b/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/OpprettGosysOppgaveRequest.kt deleted file mode 100644 index d13900e30..000000000 --- a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/OpprettGosysOppgaveRequest.kt +++ /dev/null @@ -1,33 +0,0 @@ -package no.nav.k9.los.integrasjon.gosys - -import org.json.JSONObject -import java.time.LocalDate - -class OpprettGosysOppgaveRequest( - private val oppgaveType: GosysKonstanter.OppgaveType, - private val prioritet: GosysKonstanter.Prioritet, - private val temaGruppe: GosysKonstanter.TemaGruppe, - private val fagsaksystem: GosysKonstanter.Fagsaksystem, - private val fristIDager: Int, - private val aktiv: LocalDate, - private val aktørId: String, - private val enhetsNummer: String, - private val fagsakId: String -) { - fun body(): String { - return JSONObject() - .put("oppgavetype", oppgaveType.dto) - .put("prioritet", prioritet.dto) - .put("behandlingstema", "kategori.behandlingstema.dto") - .put("temagruppe", temaGruppe.dto) - .put("fristFerdigstillelse", Virkedager.nVirkedagerFra(fristIDager, aktiv)) - .put("aktivDato", aktiv.toString()) - .put("aktoerId", aktørId) - .put("tildeltEnhetsnr", enhetsNummer) - .put("saksreferanse", fagsakId) - .put("behandlingstype", "kategori.behandlingstype.dto") - .put("tema", "kategori.tema.dto") - .put("behandlesAvApplikasjon", fagsaksystem.dto) - .toString() - } -} diff --git a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/Virkedager.kt b/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/Virkedager.kt deleted file mode 100644 index 8956eee2f..000000000 --- a/src/main/kotlin/no/nav/k9/los/integrasjon/gosys/Virkedager.kt +++ /dev/null @@ -1,19 +0,0 @@ -package no.nav.k9.los.integrasjon.gosys - -import java.time.DayOfWeek -import java.time.LocalDate - -internal object Virkedager { - fun nVirkedagerFra(n: Int, dato: LocalDate): LocalDate { - return if (n == 0) dato else nVirkedagerFra(n - 1, nesteUkedag(dato)) - } - - private fun nesteUkedag(dato: LocalDate): LocalDate { - val nesteDag = dato.plusDays(1) - return if (erHelg(nesteDag)) nesteUkedag(nesteDag) else nesteDag - } - - private fun erHelg(dato: LocalDate): Boolean { - return dato.dayOfWeek == DayOfWeek.SATURDAY || dato.dayOfWeek == DayOfWeek.SUNDAY - } -} \ No newline at end of file diff --git a/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/statistikk/Behandling.kt b/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/statistikk/Behandling.kt index b66913c79..331d35bb3 100644 --- a/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/statistikk/Behandling.kt +++ b/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/statistikk/Behandling.kt @@ -143,28 +143,12 @@ class BehandlingBuilder(behandlingId: String, saksnummer: String) { ) fun build(): Behandling = behandling - fun buildJson(): String = build().toJson() - - fun sakId(sakId: String?): BehandlingBuilder { - behandling = behandling.copy(sakId = sakId) - return this - } fun behandlingId(behandlingId: String): BehandlingBuilder { behandling = behandling.copy(behandlingId = behandlingId) return this } - fun funksjonellTid(funksjonellTid: OffsetDateTime?): BehandlingBuilder { - behandling = behandling.copy(funksjonellTid = funksjonellTid) - return this - } - - fun tekniskTid(tekniskTid: OffsetDateTime?): BehandlingBuilder { - behandling = behandling.copy(tekniskTid = tekniskTid) - return this - } - fun mottattDato(mottattDato: LocalDate?): BehandlingBuilder { behandling = behandling.copy(mottattDato = mottattDato) return this @@ -175,21 +159,6 @@ class BehandlingBuilder(behandlingId: String, saksnummer: String) { return this } - fun vedtaksDato(vedtaksDato: LocalDate?): BehandlingBuilder { - behandling = behandling.copy(vedtaksDato = vedtaksDato) - return this - } - - fun relatertBehandlingId(relatertBehandlingId: String?): BehandlingBuilder { - behandling = behandling.copy(relatertBehandlingId = relatertBehandlingId) - return this - } - - fun vedtakId(vedtakId: String?): BehandlingBuilder { - behandling = behandling.copy(vedtakId = vedtakId) - return this - } - fun saksnummer(saksnummer: String): BehandlingBuilder { behandling = behandling.copy(saksnummer = saksnummer) return this diff --git a/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/statistikk/Sak.kt b/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/statistikk/Sak.kt index 919e512ac..4c695d45d 100644 --- a/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/statistikk/Sak.kt +++ b/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/statistikk/Sak.kt @@ -67,33 +67,12 @@ class SakBuilder(saksnummer: String) { private var sak = Sak(saksnummer = saksnummer) fun build(): Sak = sak - fun buildJson(): String = build().toJson() - - fun funksjonellTid(funksjonellTid: OffsetDateTime?): SakBuilder { - sak = sak.copy(funksjonellTid = funksjonellTid) - return this - } - - fun tekniskTid(tekniskTid: OffsetDateTime?): SakBuilder { - sak = sak.copy(tekniskTid = tekniskTid) - return this - } - - fun opprettetDato(opprettetDato: LocalDate?): SakBuilder { - sak = sak.copy(opprettetDato = opprettetDato) - return this - } fun aktorId(aktorId: Long?): SakBuilder { sak = sak.copy(aktorId = aktorId) return this } - fun aktorer(aktoerer: List): SakBuilder { - sak = sak.copy(aktorer = aktoerer) - return this - } - fun saksnummer(saksnummer: String): SakBuilder { sak = sak.copy(saksnummer = saksnummer) return this @@ -104,29 +83,10 @@ class SakBuilder(saksnummer: String) { return this } - fun undertype(kode: String?, beskrivelse: String?): SakBuilder { - sak = sak.copy(underType = kode, underTypeBeskrivelse = beskrivelse) - return this - } - - fun sakStatus(kode: String?, beskrivelse: String?): SakBuilder { - sak = sak.copy(sakStatus = kode, sakStatusBeskrivelse = beskrivelse) - return this - } - - fun avsender(avsender: String?): SakBuilder { - sak = sak.copy(avsender = avsender) - return this - } - fun versjon(versjon: Long?): SakBuilder { sak = sak.copy(versjon = versjon) return this } - fun sakId(sakId: String?): SakBuilder { - sak = sak.copy(sakId = sakId) - return this - } } \ No newline at end of file diff --git "a/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/mottak/omraade/Omr\303\245deRepository.kt" "b/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/mottak/omraade/Omr\303\245deRepository.kt" index 34c6d46bc..bb8fc4f5f 100644 --- "a/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/mottak/omraade/Omr\303\245deRepository.kt" +++ "b/src/main/kotlin/no/nav/k9/los/nyoppgavestyring/mottak/omraade/Omr\303\245deRepository.kt" @@ -10,7 +10,6 @@ import javax.sql.DataSource class OmrådeRepository(private val dataSource: DataSource) { - private val log = LoggerFactory.getLogger(OmrådeRepository::class.java) private val områdeCache = Cache(cacheSizeLimit = null) diff --git a/src/main/kotlin/no/nav/k9/los/tjenester/saksbehandler/nokkeltall/NyeOgFerdigstilteOppgaver.kt b/src/main/kotlin/no/nav/k9/los/tjenester/saksbehandler/nokkeltall/NyeOgFerdigstilteOppgaver.kt deleted file mode 100644 index f33d8ace4..000000000 --- a/src/main/kotlin/no/nav/k9/los/tjenester/saksbehandler/nokkeltall/NyeOgFerdigstilteOppgaver.kt +++ /dev/null @@ -1,18 +0,0 @@ -package no.nav.k9.los.tjenester.saksbehandler.nokkeltall - -import no.nav.k9.los.domene.modell.BehandlingType -import java.time.LocalDate - -data class NyeOgFerdigstilteOppgaver( - val behandlingType: BehandlingType, - val dato: LocalDate, - val nye: MutableSet = mutableSetOf(), - val ferdigstilte: MutableSet = mutableSetOf() -) { - fun leggTilNy(uuid: String) { - nye.add(uuid) - } - fun leggTilFerdigstilt(uuid: String) { - ferdigstilte.add(uuid) - } -} diff --git a/src/main/kotlin/no/nav/k9/los/utils/DateUtil.kt b/src/main/kotlin/no/nav/k9/los/utils/DateUtil.kt index 7bdc8fa2f..2487b0db6 100644 --- a/src/main/kotlin/no/nav/k9/los/utils/DateUtil.kt +++ b/src/main/kotlin/no/nav/k9/los/utils/DateUtil.kt @@ -34,11 +34,3 @@ fun LocalDateTime.leggTilDagerHoppOverHelg(dager: Int): LocalDateTime { return nyDato.atTime(23, 59) } -fun LocalDateTime.forskyvReservasjonsDatoBakover(): LocalDateTime { - var localDate = this.toLocalDate() - while (localDate.dayOfWeek == DayOfWeek.SATURDAY || localDate.dayOfWeek == DayOfWeek.SUNDAY) { - localDate = localDate.minusDays(1) - } - - return localDate.atStartOfDay() -} diff --git a/src/main/kotlin/no/nav/k9/los/utils/HashUtil.kt b/src/main/kotlin/no/nav/k9/los/utils/HashUtil.kt deleted file mode 100644 index 92b8c5f5b..000000000 --- a/src/main/kotlin/no/nav/k9/los/utils/HashUtil.kt +++ /dev/null @@ -1,13 +0,0 @@ -package no.nav.k9.los.utils - -import java.security.MessageDigest - -fun String.sha512(): String { - return this.hashWithAlgorithm("SHA-512") -} - -private fun String.hashWithAlgorithm(algorithm: String): String { - val digest = MessageDigest.getInstance(algorithm) - val bytes = digest.digest(this.toByteArray(Charsets.UTF_8)) - return bytes.fold("") { str, it -> str + "%02x".format(it) } -} diff --git a/src/test/kotlin/no/nav/k9/los/aksjonspunktbehandling/BehandlingProsessEventTilbakeDtoBuilder.kt b/src/test/kotlin/no/nav/k9/los/aksjonspunktbehandling/BehandlingProsessEventTilbakeDtoBuilder.kt index 89fb3f5f8..8d4b20a4f 100644 --- a/src/test/kotlin/no/nav/k9/los/aksjonspunktbehandling/BehandlingProsessEventTilbakeDtoBuilder.kt +++ b/src/test/kotlin/no/nav/k9/los/aksjonspunktbehandling/BehandlingProsessEventTilbakeDtoBuilder.kt @@ -107,21 +107,6 @@ class BehandlingProsessEventTilbakeDtoBuilder( return this } - fun medEksternId(eksternId: UUID): BehandlingProsessEventTilbakeDtoBuilder { - this.eksternId = eksternId - return this - } - - fun medBehandlingSteg(behandlingSteg: String): BehandlingProsessEventTilbakeDtoBuilder { - this.behandlingSteg = behandlingSteg - return this - } - - fun medBehandlingStatus(behandlingStatus: BehandlingStatus): BehandlingProsessEventTilbakeDtoBuilder { - this.behandlingStatus = behandlingStatus - return this - } - fun build(): BehandlingProsessEventTilbakeDto { return BehandlingProsessEventTilbakeDto( eksternId = eksternId, diff --git a/src/test/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/k9saktillos/k9saktillosadapter/K9SakTilLosIT.kt b/src/test/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/k9saktillos/k9saktillosadapter/K9SakTilLosIT.kt index 89c2f06f2..cef0382bd 100644 --- a/src/test/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/k9saktillos/k9saktillosadapter/K9SakTilLosIT.kt +++ b/src/test/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/k9saktillos/k9saktillosadapter/K9SakTilLosIT.kt @@ -375,15 +375,6 @@ class K9SakTilLosIT : AbstractK9LosIntegrationTest() { ) } - private fun hentEnesteReservasjon(saksbehandler: Saksbehandler): ReservasjonV3Dto { - val oppgaveApisTjeneste = get() - return runBlocking { - oppgaveApisTjeneste.hentReserverteOppgaverForSaksbehandler(saksbehandler).also { - assertThat(it).hasSize(1) - }.first() - } - } - private fun assertIngenReservasjon(saksbehandler: Saksbehandler) { val oppgaveApisTjeneste = get() runBlocking { assertThat( @@ -408,77 +399,6 @@ class K9SakTilLosIT : AbstractK9LosIntegrationTest() { } } - private fun leggTilbakeAlleReservasjoner(saksbehandler: Saksbehandler) { - val oppgaveApisTjeneste = get() - runBlocking { - oppgaveApisTjeneste.hentReserverteOppgaverForSaksbehandler(saksbehandler).forEach { reservasjon -> - - val params = - listOf(AnnullerReservasjon(reservasjon.reservertOppgaveV1Dto?.oppgaveNøkkel - ?: reservasjon.reserverteV3Oppgaver.first().oppgaveNøkkel)) - - oppgaveApisTjeneste.annullerReservasjoner(params, saksbehandler) - } - } - } - - private fun forleng(saksbehandler: Saksbehandler, reservasjon: ReservasjonV3Dto, tilDato: LocalDateTime) { - val oppgaveApisTjeneste = get() - val nøkler = listOfNotNull(reservasjon.reservertOppgaveV1Dto?.oppgaveNøkkel).takeIf { it.isNotEmpty() } - ?: reservasjon.reserverteV3Oppgaver.map { it.oppgaveNøkkel } - - runBlocking { - nøkler.forEach { - oppgaveApisTjeneste.forlengReservasjon( - ForlengReservasjonDto( - it, - "begrunnelse", - tilDato - ), saksbehandler - ) - } - } - } - - - private fun endre(saksbehandler: Saksbehandler, nøkler: List, tilDato: LocalDate) { - val oppgaveApisTjeneste = get() - - runBlocking { - oppgaveApisTjeneste.endreReservasjoner( - nøkler.map { ReservasjonEndringDto( - it, - saksbehandler.brukerIdent, - tilDato, - "begrunnelse", - )}, saksbehandler - ) - } - } - - private fun ReservasjonV3Dto.oppgaveNøkkelDtos() = - (listOfNotNull(reservertOppgaveV1Dto?.oppgaveNøkkel).takeIf { it.isNotEmpty() } - ?: reserverteV3Oppgaver.map { it.oppgaveNøkkel }) - - - private fun overfør(saksbehandler: Saksbehandler, nøkler: List) { - val oppgaveApisTjeneste = get() - - runBlocking { - nøkler.forEach { - oppgaveApisTjeneste.overførReservasjon( - FlyttReservasjonId( - it, - saksbehandler.brukerIdent!!, - "begrunnelse", - ), saksbehandler - ) - } - } - } - - - private fun opprettKøFor(saksbehandler: Saksbehandler, oppgaveQuery: OppgaveQuery): OppgaveKo { val oppgaveKoRepository = get() val nyKø = oppgaveKoRepository.leggTil("Test", skjermet = false).copy( @@ -507,23 +427,6 @@ class K9SakTilLosIT : AbstractK9LosIntegrationTest() { } return OppgaveQuery(filtre) } - - fun hentOppgaver(eksternId: UUID): Map, Boolean> { - return get().transaction { tx -> - tx.run( - queryOf( - "select * from oppgave_v3 where ekstern_id = :eksternId", mapOf("eksternId" to eksternId.toString()) - ).map { row -> - Triple( - Oppgavestatus.valueOf(row.string("status")), - row.string("reservasjonsnokkel"), - row.localDateTime("endret_tidspunkt"), - ) to row.boolean("aktiv") - }.asList - ).toMap() - } - } - } object TestOppgaveNøkkel { diff --git a/src/test/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/k9tilbaketillos/k9tilbaketillosadapter/K9TilbakeTilLosIT.kt b/src/test/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/k9tilbaketillos/k9tilbaketillosadapter/K9TilbakeTilLosIT.kt index ebfc172fe..1933dc4b7 100644 --- a/src/test/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/k9tilbaketillos/k9tilbaketillosadapter/K9TilbakeTilLosIT.kt +++ b/src/test/kotlin/no/nav/k9/los/nyoppgavestyring/domeneadaptere/k9/k9tilbaketillos/k9tilbaketillosadapter/K9TilbakeTilLosIT.kt @@ -268,129 +268,4 @@ class K9TilbakeTilLosIT : AbstractK9LosIntegrationTest() { } } - private fun leggTilbakeAlleReservasjoner(saksbehandler: Saksbehandler) { - val oppgaveApisTjeneste = get() - runBlocking { - oppgaveApisTjeneste.hentReserverteOppgaverForSaksbehandler(saksbehandler).forEach { reservasjon -> - - val params = - listOf(AnnullerReservasjon(reservasjon.reservertOppgaveV1Dto?.oppgaveNøkkel - ?: reservasjon.reserverteV3Oppgaver.first().oppgaveNøkkel)) - - oppgaveApisTjeneste.annullerReservasjoner(params, saksbehandler) - } - } - } - - private fun forleng(saksbehandler: Saksbehandler, reservasjon: ReservasjonV3Dto, tilDato: LocalDateTime) { - val oppgaveApisTjeneste = get() - val nøkler = listOfNotNull(reservasjon.reservertOppgaveV1Dto?.oppgaveNøkkel).takeIf { it.isNotEmpty() } - ?: reservasjon.reserverteV3Oppgaver.map { it.oppgaveNøkkel } - - runBlocking { - nøkler.forEach { - oppgaveApisTjeneste.forlengReservasjon( - ForlengReservasjonDto( - it, - "begrunnelse", - tilDato - ), saksbehandler - ) - } - } - } - - - private fun endre(saksbehandler: Saksbehandler, nøkler: List, tilDato: LocalDate) { - val oppgaveApisTjeneste = get() - - runBlocking { - oppgaveApisTjeneste.endreReservasjoner( - nøkler.map { ReservasjonEndringDto( - it, - saksbehandler.brukerIdent, - tilDato, - "begrunnelse", - )}, saksbehandler - ) - } - } - - private fun ReservasjonV3Dto.oppgaveNøkkelDtos() = - (listOfNotNull(reservertOppgaveV1Dto?.oppgaveNøkkel).takeIf { it.isNotEmpty() } - ?: reserverteV3Oppgaver.map { it.oppgaveNøkkel }) - - - private fun overfør(saksbehandler: Saksbehandler, nøkler: List) { - val oppgaveApisTjeneste = get() - - runBlocking { - nøkler.forEach { - oppgaveApisTjeneste.overførReservasjon( - FlyttReservasjonId( - it, - saksbehandler.brukerIdent!!, - "begrunnelse", - ), saksbehandler - ) - } - } - } - - - - private fun opprettKøFor(saksbehandler: Saksbehandler, oppgaveQuery: OppgaveQuery): OppgaveKo { - val oppgaveKoRepository = get() - val nyKø = oppgaveKoRepository.leggTil("Test", skjermet = false).copy( - saksbehandlere = listOf(saksbehandler.epost), - oppgaveQuery = oppgaveQuery - ) - return oppgaveKoRepository.endre(nyKø) - } - - private fun querySomKunInneholder(eksternId: UUID, vararg status: Oppgavestatus = emptyArray()): OppgaveQuery { - val filtre = mutableListOf( - byggFilterK9(FeltType.BEHANDLINGUUID, FeltverdiOperator.EQUALS, eksternId.toString()) - ) - if (status.isNotEmpty()) { - filtre.add(byggGenereltFilter(FeltType.OPPGAVE_STATUS, FeltverdiOperator.EQUALS, *status.map { it.kode }.toTypedArray())) - } - return OppgaveQuery(filtre) - } - - private fun querySomKunInneholder(eksternId: List, vararg status: Oppgavestatus = emptyArray()): OppgaveQuery { - val filtre = mutableListOf( - byggFilterK9(FeltType.BEHANDLINGUUID, FeltverdiOperator.IN, *eksternId.map { it.toString() }.toTypedArray()) - ) - if (status.isNotEmpty()) { - filtre.add(byggGenereltFilter(FeltType.OPPGAVE_STATUS, FeltverdiOperator.EQUALS, *status.map { it.kode }.toTypedArray())) - } - return OppgaveQuery(filtre) - } -} - -object TestOppgaveNøkkel { - fun forK9sak(eksternId: UUID) = OppgaveNøkkelDto( - oppgaveEksternId = eksternId.toString(), - oppgaveTypeEksternId = "k9sak", - områdeEksternId = "K9", - ) -} - -private fun byggFilterK9(feltType: FeltType, feltverdiOperator: FeltverdiOperator, vararg verdier: String?): FeltverdiOppgavefilter { - return FeltverdiOppgavefilter( - "K9", - feltType.eksternId, - feltverdiOperator.name, - verdier.toList() - ) -} - -private fun byggGenereltFilter(feltType: FeltType, feltverdiOperator: FeltverdiOperator, vararg verdier: String?): FeltverdiOppgavefilter { - return FeltverdiOppgavefilter( - null, - feltType.eksternId, - feltverdiOperator.name, - verdier.toList() - ) } diff --git a/src/test/kotlin/no/nav/k9/los/tjenester/avdelingsleder/nokkeltall/NokkeltallTjenesteTest.kt b/src/test/kotlin/no/nav/k9/los/tjenester/avdelingsleder/nokkeltall/NokkeltallTjenesteTest.kt index 98ede6430..f6a28ebd3 100644 --- a/src/test/kotlin/no/nav/k9/los/tjenester/avdelingsleder/nokkeltall/NokkeltallTjenesteTest.kt +++ b/src/test/kotlin/no/nav/k9/los/tjenester/avdelingsleder/nokkeltall/NokkeltallTjenesteTest.kt @@ -26,10 +26,6 @@ import java.util.* class NokkeltallTjenesteTest : AbstractK9LosIntegrationTest() { - val DAG1 = LocalDate.now().minusDays(2) - val DAG2 = LocalDate.now().minusDays(1) - val DAG3 = LocalDate.now() - @Test fun `Hent oppgaver på vent - 1 oppgave uten aksjonspunkt skal gi 0 oppgaver på vent`() { val nøkkeltallTjeneste = get()