Skip to content

Commit

Permalink
Revert "Send udelte samtalereferat til oversikten (#897)"
Browse files Browse the repository at this point in the history
This reverts commit 8746e73.
  • Loading branch information
madsleegiil committed Dec 20, 2024
1 parent 8746e73 commit 7030ea8
Show file tree
Hide file tree
Showing 19 changed files with 21 additions and 743 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@
import no.nav.veilarbaktivitet.aktivitet.feil.EndringAvHistoriskAktivitetException;
import no.nav.veilarbaktivitet.eventsLogger.BigQueryClient;
import no.nav.veilarbaktivitet.eventsLogger.EventType;
import no.nav.veilarbaktivitet.oversikten.OversiktenService;
import no.nav.veilarbaktivitet.person.Person;
import no.nav.veilarbaktivitet.person.PersonService;
import org.slf4j.Logger;
Expand All @@ -32,7 +31,6 @@ public class AktivitetAppService {
private final MetricService metricService;
private final PersonService personService;
private final BigQueryClient bigQueryClient;
private final OversiktenService oversiktenService;

private static final Set<AktivitetTypeData> TYPER_SOM_KAN_ENDRES_EKSTERNT = new HashSet<>(Arrays.asList(
AktivitetTypeData.EGENAKTIVITET,
Expand Down Expand Up @@ -104,16 +102,6 @@ private static boolean erReferatetEndretForDetErPublisert(AktivitetData aktivite
return !aktivitetData.getMoteData().isReferatPublisert() && referatEndret;
}

private boolean referatErDeltMedBruker(AktivitetData nyAktivitet) {
if(nyAktivitet.getMoteData() == null) return false;
return nyAktivitet.getMoteData().isReferatPublisert();
}

private boolean nyopprettetAktivitetKanHaReferat(AktivitetData nyAktivitet) {
var aktivitetstyperSomKanHaReferatNårAktivitetOpprettes = List.of(AktivitetTypeData.SAMTALEREFERAT);
return aktivitetstyperSomKanHaReferatNårAktivitetOpprettes.contains(nyAktivitet.getAktivitetType());
}

@Transactional
public AktivitetData opprettNyAktivitet(AktivitetData aktivitetData) {

Expand All @@ -125,14 +113,8 @@ public AktivitetData opprettNyAktivitet(AktivitetData aktivitetData) {
}

AktivitetData nyAktivitet = aktivitetService.opprettAktivitet(aktivitetData);

if (nyopprettetAktivitetKanHaReferat(nyAktivitet)) {
if (referatErDeltMedBruker(nyAktivitet)) {
bigQueryClient.logEvent(nyAktivitet, EventType.SAMTALEREFERAT_OPPRETTET_OG_DELT_MED_BRUKER);
} else {
bigQueryClient.logEvent(nyAktivitet, EventType.SAMTALEREFERAT_OPPRETTET);
oversiktenService.lagreStartMeldingOmUdeltSamtalereferatIUtboks(nyAktivitet.getAktorId(), nyAktivitet.getId());
}
if (nyAktivitet.getAktivitetType() == AktivitetTypeData.SAMTALEREFERAT || nyAktivitet.getAktivitetType() == AktivitetTypeData.MOTE) {
bigQueryClient.logEvent(nyAktivitet, EventType.SAMTALEREFERAT_OPPRETTET);
}

// dette er gjort på grunn av KVP
Expand Down Expand Up @@ -247,39 +229,21 @@ public AktivitetData oppdaterReferat(AktivitetData aktivitet) {
final var originalAktivitet = hentAktivitet(aktivitet.getId());
kanEndreAktivitetGuard(originalAktivitet, aktivitet.getVersjon(), aktivitet.getAktorId());

var oppdatertAktivitet = aktivitetService.oppdaterReferat(originalAktivitet, aktivitet);

var maybeEventType = hentEventTypePåSamtalereferat(originalAktivitet, aktivitet);
maybeEventType.ifPresent(eventType -> {
bigQueryClient.logEvent(oppdatertAktivitet, eventType);
sendMeldingTilOversikten(oppdatertAktivitet, eventType);
});
return oppdatertAktivitet;
}
var oppdatertAktivtiet = aktivitetService.oppdaterReferat(
originalAktivitet,
aktivitet
);

private void sendMeldingTilOversikten(AktivitetData aktivitet, EventType eventType) {
if (eventType == EventType.SAMTALEREFERAT_OPPRETTET) { // Kan kun skje for aktivitetstype "Møte"
oversiktenService.lagreStartMeldingOmUdeltSamtalereferatIUtboks(aktivitet.getAktorId(), aktivitet.getId());
} else if (eventType == EventType.SAMTALEREFERAT_DELT_MED_BRUKER) {
oversiktenService.lagreStoppMeldingOmUdeltSamtalereferatIUtboks(aktivitet.getAktorId(), aktivitet.getId());
if(!originalAktivitet.getMoteData().isReferatPublisert() && oppdatertAktivtiet.getMoteData().isReferatPublisert()) {
bigQueryClient.logEvent(oppdatertAktivtiet, EventType.SAMTALEREFERAT_DELT_MED_BRUKER);
}
}

private Optional<EventType> hentEventTypePåSamtalereferat(AktivitetData originalAktivitet, AktivitetData oppdatertAktivitet) {
var forrigeReferat = Optional.ofNullable(originalAktivitet.getMoteData()).map(it -> it.getReferat()).orElse("");
var nesteReferat = Optional.ofNullable(oppdatertAktivitet.getMoteData()).map(it -> it.getReferat()).orElse("");

var referatHarNåFåttInnhold = forrigeReferat.isEmpty() && !nesteReferat.isEmpty();
var referatHarNåBlittDeltMedBruker = !originalAktivitet.getMoteData().isReferatPublisert() && oppdatertAktivitet.getMoteData().isReferatPublisert();

if (referatHarNåFåttInnhold && !referatHarNåBlittDeltMedBruker) {
return Optional.of(EventType.SAMTALEREFERAT_OPPRETTET);
} else if (referatHarNåFåttInnhold && referatHarNåBlittDeltMedBruker) {
return Optional.of(EventType.SAMTALEREFERAT_OPPRETTET_OG_DELT_MED_BRUKER);
} else if (!referatHarNåFåttInnhold && referatHarNåBlittDeltMedBruker) {
return Optional.of(EventType.SAMTALEREFERAT_DELT_MED_BRUKER);
} else {
return Optional.empty();
var nesteReferat = Optional.ofNullable(oppdatertAktivtiet.getMoteData()).map(it -> it.getReferat()).orElse("");
if (forrigeReferat.isEmpty() && !nesteReferat.isEmpty() && oppdatertAktivtiet.getAktivitetType() == AktivitetTypeData.MOTE ) {
bigQueryClient.logEvent(oppdatertAktivtiet, EventType.SAMTALEREFERAT_FIKK_INNHOLD);
}

return oppdatertAktivtiet;
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -15,4 +15,4 @@ public class MoteData {

String referat;
boolean referatPublisert;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -80,6 +80,10 @@ class AktivitetsplanController(
@RequestBody aktivitet: AktivitetDTO,
@RequestParam(required = false, defaultValue = "false") automatisk: Boolean
): AktivitetDTO {
return internOpprettAktivitet(aktivitet, automatisk)
}

fun internOpprettAktivitet(aktivitet: AktivitetDTO, automatisk: Boolean): AktivitetDTO {
return aktivitetDataMapperService.mapTilAktivitetData(aktivitet)
.withAutomatiskOpprettet(automatisk)
.let { aktivitetData -> appService.opprettNyAktivitet(aktivitetData) }
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ package no.nav.veilarbaktivitet.config

import com.fasterxml.jackson.annotation.JsonInclude
import no.nav.veilarbaktivitet.aktivitet.feil.*
import org.slf4j.LoggerFactory
import org.springframework.http.HttpStatus
import org.springframework.http.ResponseEntity
import org.springframework.web.bind.annotation.ControllerAdvice
Expand All @@ -14,7 +13,6 @@ import org.springframework.web.servlet.mvc.method.annotation.ResponseEntityExcep

@ControllerAdvice
class HttpExceptionHandler : ResponseEntityExceptionHandler() {
val log = LoggerFactory.getLogger(HttpExceptionHandler::class.java)

@ExceptionHandler(value = [EndringAvAktivitetException::class])
fun handleException(e: EndringAvAktivitetException, request: WebRequest): ResponseEntity<Response> {
Expand All @@ -34,15 +32,6 @@ class HttpExceptionHandler : ResponseEntityExceptionHandler() {
.body(Response(statusCode = e.statusCode.value(), message = e.reason))
}

@ExceptionHandler(value = [RuntimeException::class])
fun handleRuntimeException(e: RuntimeException, request: WebRequest): ResponseEntity<Response> {
val statusKode = HttpStatus.INTERNAL_SERVER_ERROR.value()
log.error("Feil i håndtering av kall", e)
return ResponseEntity
.status(statusKode)
.body(Response(statusCode = statusKode, message = "Noe gikk galt"))
}

@JsonInclude(JsonInclude.Include.NON_NULL)
data class Response(
val message: String?,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@ enum class EventType {
SAMTALEREFERAT_OPPRETTET,
SAMTALEREFERAT_FIKK_INNHOLD,
SAMTALEREFERAT_DELT_MED_BRUKER,
SAMTALEREFERAT_OPPRETTET_OG_DELT_MED_BRUKER,
}

data class SamtalereferatPublisertFordeling(
Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

Loading

0 comments on commit 7030ea8

Please sign in to comment.