diff --git a/nais/nais-prod.yaml b/nais/nais-prod.yaml index b54064ab8..7b2fa3ced 100644 --- a/nais/nais-prod.yaml +++ b/nais/nais-prod.yaml @@ -159,4 +159,4 @@ spec: - name: BASE_URL_DOKUMENTARKIV_OPPFOLGING_DOCUMENTS_PAGE value: https://www.nav.no/dokumentarkiv/tema/OPP - name: URL_AKTIVITETSKRAV_INFO_PAGE - value: https://www.nav.no/syk/aktivitetskrav \ No newline at end of file + value: https://www.nav.no/syk/aktivitetskrav diff --git a/src/main/kotlin/no/nav/syfo/service/AktivitetspliktForhandsvarselService.kt b/src/main/kotlin/no/nav/syfo/service/AktivitetspliktForhandsvarselService.kt index e88ea97c9..062c04a8f 100644 --- a/src/main/kotlin/no/nav/syfo/service/AktivitetspliktForhandsvarselService.kt +++ b/src/main/kotlin/no/nav/syfo/service/AktivitetspliktForhandsvarselService.kt @@ -14,7 +14,6 @@ class AktivitetspliktForhandsvarselVarselService( val urlAktivitetskravInfoPage: String, private val isSendingEnabled: Boolean, ) { - // TODO fun sendVarselTilArbeidstaker(varselHendelse: ArbeidstakerHendelse) { if (isSendingEnabled) { log.info("[FORHAANDSVARSEL] sending enabled") diff --git a/src/main/kotlin/no/nav/syfo/service/SenderFacade.kt b/src/main/kotlin/no/nav/syfo/service/SenderFacade.kt index 427cdb71a..4c45b23bb 100644 --- a/src/main/kotlin/no/nav/syfo/service/SenderFacade.kt +++ b/src/main/kotlin/no/nav/syfo/service/SenderFacade.kt @@ -184,7 +184,6 @@ class SenderFacade( } private fun ferdigstillVarsel(utsendtVarsel: PUtsendtVarsel) { - log.info("[FORHAANDSVARSEL] Fetched utsendt varsel from DB. About to ferdigstill. fnr:${utsendtVarsel.fnr}, uuid: ${utsendtVarsel.uuid}, eksternReferanse: ${utsendtVarsel.eksternReferanse}") if (utsendtVarsel.eksternReferanse != null && utsendtVarsel.ferdigstiltTidspunkt == null) { when (utsendtVarsel.kanal) { BRUKERNOTIFIKASJON.name -> { diff --git a/src/main/kotlin/no/nav/syfo/service/VarselBusService.kt b/src/main/kotlin/no/nav/syfo/service/VarselBusService.kt index 2d9f6ea5c..c082f57a6 100644 --- a/src/main/kotlin/no/nav/syfo/service/VarselBusService.kt +++ b/src/main/kotlin/no/nav/syfo/service/VarselBusService.kt @@ -73,9 +73,6 @@ class VarselBusService( fun ferdigstillVarsel(varselHendelse: EsyfovarselHendelse) { if (varselHendelse.isArbeidstakerHendelse()) { - if (varselHendelse.type == SM_AKTIVITETSPLIKT) { - log.info("[FORHAANDSVARSEL] skal ferdigstille varsel av type ${varselHendelse.type}") - } senderFacade.ferdigstillArbeidstakerVarsler(varselHendelse.toArbeidstakerHendelse()) } else { senderFacade.ferdigstillNarmesteLederVarsler(varselHendelse.toNarmestelederHendelse()) diff --git a/src/main/kotlin/no/nav/syfo/service/microfrontend/MikrofrontendAktivitetskravService.kt b/src/main/kotlin/no/nav/syfo/service/microfrontend/MikrofrontendAktivitetskravService.kt index fd5caf922..7b247e034 100644 --- a/src/main/kotlin/no/nav/syfo/service/microfrontend/MikrofrontendAktivitetskravService.kt +++ b/src/main/kotlin/no/nav/syfo/service/microfrontend/MikrofrontendAktivitetskravService.kt @@ -5,25 +5,23 @@ import no.nav.syfo.db.domain.PMikrofrontendSynlighet import no.nav.syfo.db.fetchFnrsWithExpiredMicrofrontendEntries import no.nav.syfo.db.fetchMikrofrontendSynlighetEntriesByFnr import no.nav.syfo.db.updateMikrofrontendEntrySynligTomByFnrAndTjeneste -import no.nav.syfo.kafka.consumers.varselbus.domain.* +import no.nav.syfo.kafka.consumers.varselbus.domain.ArbeidstakerHendelse +import no.nav.syfo.kafka.consumers.varselbus.domain.getSynligTom import no.nav.syfo.kafka.producers.mineside_microfrontend.MinSideRecord import no.nav.syfo.kafka.producers.mineside_microfrontend.Tjeneste import no.nav.syfo.service.microfrontend.MikrofrontendService.Companion.actionEnabled import no.nav.syfo.utils.dataToVarselData -import org.slf4j.Logger -import org.slf4j.LoggerFactory class MikrofrontendAktivitetskravService(val database: DatabaseInterface) { val mikrofrontendId = "syfo-aktivitetskrav" - private val log: Logger = LoggerFactory.getLogger(MikrofrontendAktivitetskravService::class.qualifiedName) + fun createOrUpdateAktivitetskravMicrofrontendByHendelse(hendelse: ArbeidstakerHendelse): MinSideRecord? { return createOrUpdateMinSideRecord(hendelse) } private fun createOrUpdateMinSideRecord(hendelse: ArbeidstakerHendelse): MinSideRecord? { val isMikrofrontendActiveForUser = - existingMikrofrontendEntries(hendelse.arbeidstakerFnr, Tjeneste.AKTIVITETSKRAV).isNotEmpty() - log.warn("[FORHAANDSVARSEL] hendelse data: ${hendelse.data} || ${hendelse.data}") + existingMikrofrontendEntries(hendelse.arbeidstakerFnr).isNotEmpty() val actions = dataToVarselData(hendelse.data).aktivitetskrav requireNotNull(actions) @@ -55,8 +53,8 @@ class MikrofrontendAktivitetskravService(val database: DatabaseInterface) { .map { Triple(it, mikrofrontendId, Tjeneste.AKTIVITETSKRAV) } } - private fun existingMikrofrontendEntries(fnr: String, tjeneste: Tjeneste): List { + private fun existingMikrofrontendEntries(fnr: String): List { return database.fetchMikrofrontendSynlighetEntriesByFnr(fnr) - .filter { it.tjeneste == tjeneste.name } + .filter { it.tjeneste == Tjeneste.AKTIVITETSKRAV.name } } }