Merge branch 'master' into bugfix/folkeregistermetadata-opphoerstidsp…

…unkt

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/sykemelding/SykemeldingConsumer.java

@@ -1,6 +1,7 @@
 package no.nav.dolly.bestilling.sykemelding;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
+import io.swagger.v3.core.util.Json;
 import lombok.extern.slf4j.Slf4j;
 import no.nav.dolly.bestilling.ConsumerStatus;
 import no.nav.dolly.bestilling.sykemelding.command.SykemeldingPostCommand;
@@ -41,7 +42,7 @@ public SykemeldingConsumer(
     @Timed(name = "providers", tags = { "operation", "detaljertsykemelding_opprett" })
     public Mono<SykemeldingResponse> postDetaljertSykemelding(DetaljertSykemeldingRequest detaljertSykemeldingRequest) {
 
-        log.info("Detaljert Sykemelding sendt {}", detaljertSykemeldingRequest);
+        log.info("Detaljert Sykemelding sendt {}", Json.pretty(detaljertSykemeldingRequest));
 
         return tokenService.exchange(serverProperties)
                 .flatMap(token -> new SykemeldingPostCommand(webClient, detaljertSykemeldingRequest,

apps/sykemelding-api/Dockerfile

@@ -1,6 +1,7 @@
 FROM ghcr.io/navikt/baseimages/temurin:21
 LABEL maintainer="Team Dolly"
 
+ENV JAVA_OPTS="--add-opens java.base/java.lang=ALL-UNNAMED"
 ADD /build/libs/app.jar /app/app.jar
 
 EXPOSE 8080

apps/sykemelding-api/build.gradle

@@ -21,14 +21,15 @@ dependencies {
     implementation "org.springframework.boot:spring-boot-starter-security"
 
     implementation "org.springdoc:springdoc-openapi-starter-webmvc-ui:$versions.springdoc"
-    implementation "io.swagger.core.v3:swagger-annotations-jakarta:$versions.swagger"
 
     implementation "com.ibm.mq:mq-jms-spring-boot-starter:$versions.mq"
     implementation "jakarta.xml.bind:jakarta.xml.bind-api:$versions.jakartaXmlBindApi"
     implementation "jakarta.activation:jakarta.activation-api:$versions.jakartaActivation"
     implementation "org.glassfish.jaxb:jaxb-runtime:$versions.jaxb"
     implementation "com.fasterxml.jackson.dataformat:jackson-dataformat-xml"
 
+    implementation "ma.glasnost.orika:orika-core:$versions.orika"
+
     testImplementation "no.nav.testnav.libs:testing"
     testImplementation "org.springframework.security:spring-security-test"
     testImplementation "org.springframework.cloud:spring-cloud-contract-wiremock"

apps/sykemelding-api/config.test.yml

@@ -66,6 +66,8 @@ spec:
         - application: testnav-oversikt-frontend
         - application: testnav-synt-sykemelding-api-dev
     outbound:
+      rules:
+        - application: testnav-sykemelding-proxy
       external:
         - host: mqls04.preprod.local
           ports:

apps/sykemelding-api/config.yml

@@ -66,6 +66,8 @@ spec:
         - application: testnav-oversikt-frontend
         - application: testnav-synt-sykemelding-api
     outbound:
+      rules:
+        - application: testnav-sykemelding-proxy
       external:
         - host: mqls04.preprod.local
           ports:

apps/sykemelding-api/src/main/java/no/nav/registre/testnorge/sykemelding/config/Consumers.java

@@ -0,0 +1,21 @@
+package no.nav.registre.testnorge.sykemelding.config;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+import no.nav.testnav.libs.securitycore.domain.ServerProperties;
+
+import static lombok.AccessLevel.PACKAGE;
+
+@Configuration
+@ConfigurationProperties(prefix = "consumers")
+@NoArgsConstructor(access = PACKAGE)
+@Getter
+@Setter(PACKAGE)
+public class Consumers {
+
+    private ServerProperties sykemeldingProxy;
+}

apps/sykemelding-api/src/main/java/no/nav/registre/testnorge/sykemelding/config/MapperFacadeConfig.java

@@ -0,0 +1,37 @@
+package no.nav.registre.testnorge.sykemelding.config;
+
+import lombok.RequiredArgsConstructor;
+import ma.glasnost.orika.CustomConverter;
+import ma.glasnost.orika.MapperFacade;
+import ma.glasnost.orika.impl.DefaultMapperFactory;
+import no.nav.registre.testnorge.sykemelding.mapper.MappingStrategy;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.List;
+
+import static java.util.Objects.nonNull;
+
+@Configuration
+@RequiredArgsConstructor
+public class MapperFacadeConfig {
+
+    @Bean
+    MapperFacade mapperFacade(List<MappingStrategy> mappingStrategies, List<CustomConverter> customConverters) {
+        DefaultMapperFactory mapperFactory = new DefaultMapperFactory.Builder().build();
+
+        if (nonNull(mappingStrategies)) {
+            for (MappingStrategy mapper : mappingStrategies) {
+                mapper.register(mapperFactory);
+            }
+        }
+
+        if (nonNull(customConverters)) {
+            for (CustomConverter converter : customConverters) {
+                mapperFactory.getConverterFactory().registerConverter(converter);
+            }
+        }
+
+        return mapperFactory.getMapperFacade();
+    }
+}

apps/sykemelding-api/src/main/java/no/nav/registre/testnorge/sykemelding/consumer/SyfoConsumer.java

@@ -6,11 +6,12 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.HttpStatus;
 import org.springframework.jms.core.JmsTemplate;
-import org.springframework.stereotype.Component;
+import org.springframework.stereotype.Service;
 
 @Slf4j
-@Component
+@Service
 public class SyfoConsumer {
+
     private final JmsTemplate jmsTemplate;
     private final String queueName;
 

apps/sykemelding-api/src/main/java/no/nav/registre/testnorge/sykemelding/consumer/SyfosmreglerConsumer.java

@@ -0,0 +1,34 @@
+package no.nav.registre.testnorge.sykemelding.consumer;
+
+import no.nav.registre.testnorge.sykemelding.config.Consumers;
+import no.nav.registre.testnorge.sykemelding.consumer.command.SyfosmreglerPostValidateCommand;
+import no.nav.registre.testnorge.sykemelding.dto.ReceivedSykemeldingDTO;
+import no.nav.testnav.libs.dto.sykemelding.v1.ValidationResultDTO;
+import no.nav.testnav.libs.securitycore.domain.ServerProperties;
+import no.nav.testnav.libs.servletsecurity.exchange.TokenExchange;
+import org.springframework.stereotype.Service;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Mono;
+
+@Service
+public class SyfosmreglerConsumer {
+
+    private final ServerProperties properties;
+    private final TokenExchange tokenExchange;
+    private final WebClient webClient;
+
+    public SyfosmreglerConsumer(Consumers consumers, WebClient.Builder webClientBuilder, TokenExchange tokenExchange) {
+
+        this.properties = consumers.getSykemeldingProxy();
+        this.tokenExchange = tokenExchange;
+        this.webClient = webClientBuilder
+                .baseUrl(properties.getUrl())
+                .build();
+    }
+
+    public Mono<ValidationResultDTO> validate(ReceivedSykemeldingDTO sykemelding) {
+
+        return tokenExchange.exchange(properties)
+                .flatMap(token -> new SyfosmreglerPostValidateCommand(webClient, sykemelding, token.getTokenValue()).call());
+    }
+}

apps/sykemelding-api/src/main/java/no/nav/registre/testnorge/sykemelding/consumer/command/SyfosmreglerPostValidateCommand.java

@@ -0,0 +1,42 @@
+package no.nav.registre.testnorge.sykemelding.consumer.command;
+
+import io.swagger.v3.core.util.Json;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import no.nav.registre.testnorge.sykemelding.dto.ReceivedSykemeldingDTO;
+import no.nav.testnav.libs.dto.sykemelding.v1.ValidationResultDTO;
+import no.nav.testnav.libs.reactivecore.utils.WebClientFilter;
+import org.springframework.http.HttpHeaders;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Mono;
+
+import java.util.concurrent.Callable;
+
+@Slf4j
+@RequiredArgsConstructor
+public class SyfosmreglerPostValidateCommand implements Callable<Mono<ValidationResultDTO>> {
+
+    private static final String SYFOSMREGLER_VALIDATE_URL = "/v1/rules/validate";
+
+    private final WebClient webClient;
+    private final ReceivedSykemeldingDTO receivedSykemelding;
+    private final String accessToken;
+
+    @Override
+    public Mono<ValidationResultDTO> call() {
+
+        log.info("Sender til syfosmregler {}", Json.pretty(receivedSykemelding));
+
+        return webClient.post()
+                .uri(uriBuilder -> uriBuilder.path(SYFOSMREGLER_VALIDATE_URL).build())
+                .header(HttpHeaders.AUTHORIZATION, "Bearer " + accessToken)
+                .bodyValue(receivedSykemelding)
+                .retrieve()
+                .bodyToMono(ValidationResultDTO.class)
+                .doOnError(WebClientFilter::logErrorMessage)
+                .onErrorResume(error -> Mono.just(ValidationResultDTO.builder()
+                        .httpStatus(WebClientFilter.getStatus(error))
+                        .message(WebClientFilter.getMessage(error))
+                        .build()));
+    }
+}

apps/sykemelding-api/src/main/java/no/nav/registre/testnorge/sykemelding/domain/Aktivitet.java

@@ -2,21 +2,26 @@
 
 import no.nav.registre.testnorge.sykemelding.external.xmlstds.helseopplysningerarbeidsuforhet._2013_10_01.XMLHelseOpplysningerArbeidsuforhet;
 import no.nav.testnav.libs.dto.sykemelding.v1.PeriodeDTO;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.server.ResponseStatusException;
 
 import java.time.LocalDate;
 import java.util.List;
-import java.util.stream.Collectors;
 
 class Aktivitet {
     private final XMLHelseOpplysningerArbeidsuforhet.Aktivitet xmlAktivitet;
 
     Aktivitet(List<PeriodeDTO> dtos, boolean manglendeTilretteleggingPaaArbeidsplassen) {
+
+        if (dtos.isEmpty()) {
+            throw new ResponseStatusException(HttpStatus.BAD_REQUEST, "Perioder må angis");
+        }
         this.xmlAktivitet = new XMLHelseOpplysningerArbeidsuforhet.Aktivitet()
                 .withPeriode(
                         dtos.stream()
                                 .map(value -> new Periode(value, manglendeTilretteleggingPaaArbeidsplassen))
                                 .map(Periode::getXmlObject)
-                                .collect(Collectors.toList())
+                                .toList()
                 );
     }
 

apps/sykemelding-api/src/main/java/no/nav/registre/testnorge/sykemelding/domain/Arbeidsgiver.java

@@ -7,13 +7,13 @@
 import static java.util.Objects.nonNull;
 
 public class Arbeidsgiver {
-    private XMLHelseOpplysningerArbeidsuforhet.Arbeidsgiver xmlArbeidsgiver;
+    private final XMLHelseOpplysningerArbeidsuforhet.Arbeidsgiver xmlArbeidsgiver;
 
     Arbeidsgiver(ArbeidsgiverDTO dto) {
         xmlArbeidsgiver = new XMLHelseOpplysningerArbeidsuforhet.Arbeidsgiver()
                 .withHarArbeidsgiver(new XMLCS()
-                        .withDN("En arbeidsgiver")
-                        .withV("1"))
+                        .withDN(nonNull(dto) ? "En arbeidsgiver" : "Ingen arbeidsgiver")
+                        .withV(nonNull(dto) ? "1" : "3"))
                 .withNavnArbeidsgiver(nonNull(dto) ? dto.getNavn() : null)
                 .withYrkesbetegnelse(nonNull(dto) ? dto.getYrkesbetegnelse() : null)
                 .withStillingsprosent(nonNull(dto) ? getStillingsprosent(dto) : null);

apps/sykemelding-api/src/main/java/no/nav/registre/testnorge/sykemelding/domain/Dokument.java

@@ -28,10 +28,12 @@ class Dokument {
                 .withMedisinskVurdering(medisinskVurdering.getXmlObject())
                 .withAktivitet(aktivitet.getXmlObject())
                 .withPrognose(prognose.getXmlObject())
+                .withUtdypendeOpplysninger(new UtdypendeOpplysninger(dto.getUtdypendeOpplysninger()).getXmlObject())
                 .withTiltak(
                         new XMLHelseOpplysningerArbeidsuforhet.Tiltak()
                                 .withTiltakArbeidsplassen(dto.getDetaljer().getTiltakArbeidsplass())
                                 .withTiltakNAV(dto.getDetaljer().getTiltakNav())
+                                .withAndreTiltak(dto.getDetaljer().getAndreTiltak())
                 )
                 .withKontaktMedPasient(
                         new XMLHelseOpplysningerArbeidsuforhet.KontaktMedPasient()

apps/sykemelding-api/src/main/java/no/nav/registre/testnorge/sykemelding/domain/MedisinskVurdering.java

@@ -7,15 +7,14 @@
 
 import java.time.LocalDate;
 import java.util.List;
-import java.util.stream.Collectors;
 
 class MedisinskVurdering {
 
-    private final XMLHelseOpplysningerArbeidsuforhet.MedisinskVurdering medisinskVurdering;
+    private final XMLHelseOpplysningerArbeidsuforhet.MedisinskVurdering xmlMedisinskVurdering;
 
     MedisinskVurdering(LocalDate fom, DiagnoseDTO hovedDiagnose, List<DiagnoseDTO> biDiagnoser) {
 
-        medisinskVurdering = new XMLHelseOpplysningerArbeidsuforhet.MedisinskVurdering()
+        xmlMedisinskVurdering = new XMLHelseOpplysningerArbeidsuforhet.MedisinskVurdering()
                 .withHovedDiagnose(new XMLHelseOpplysningerArbeidsuforhet.MedisinskVurdering.HovedDiagnose()
                         .withDiagnosekode(new XMLCV()
                                 .withDN(hovedDiagnose.getDiagnose())
@@ -29,19 +28,19 @@ class MedisinskVurdering {
                                         .withS(value.getSystem())
                                         .withV(value.getDiagnosekode())
                                 )
-                                .collect(Collectors.toList())
+                                .toList()
                         )
                 )
                 .withYrkesskade(false)
                 .withYrkesskadeDato(fom)
                 .withSvangerskap(false)
                 .withAnnenFraversArsak(
-                        new XMLArsakType().withBeskriv("Medising årsak i kategorien annet")
+                        new XMLArsakType().withBeskriv("Medisinsk årsak i kategorien annet")
                 )
                 .withSkjermesForPasient(false);
     }
 
     XMLHelseOpplysningerArbeidsuforhet.MedisinskVurdering getXmlObject() {
-        return medisinskVurdering;
+        return xmlMedisinskVurdering;
     }
 }

apps/sykemelding-api/src/main/java/no/nav/registre/testnorge/sykemelding/domain/Pasient.java

@@ -10,31 +10,38 @@
 import no.nav.testnav.libs.dto.sykemelding.v1.HelsepersonellDTO;
 import no.nav.testnav.libs.dto.sykemelding.v1.PasientDTO;
 
+import static java.util.Objects.nonNull;
+
 public class Pasient {
 
     private final XMLHelseOpplysningerArbeidsuforhet.Pasient xmlPasient;
 
 
     Pasient(PasientDTO pasientDTO, HelsepersonellDTO helsepersonellDTO) {
+        var pasient = nonNull(pasientDTO) ? pasientDTO : PasientDTO.builder()
+                .ident("12508407724")
+                .fornavn("Test")
+                .etternavn("Testesen")
+                .build();
         xmlPasient = new XMLHelseOpplysningerArbeidsuforhet.Pasient()
                 .withNavn(new XMLNavnType()
-                        .withEtternavn(pasientDTO.getEtternavn())
-                        .withMellomnavn(pasientDTO.getMellomnavn())
-                        .withFornavn(pasientDTO.getFornavn())
+                        .withEtternavn(pasient.getEtternavn())
+                        .withMellomnavn(pasient.getMellomnavn())
+                        .withFornavn(pasient.getFornavn())
                 )
                 .withFodselsnummer(new XMLIdent()
-                        .withId(pasientDTO.getIdent())
+                        .withId(pasient.getIdent())
                         .withTypeId(new XMLCV()
                                 .withV("FNR")
                                 .withDN("Fødselsnummer")
                                 .withS("2.16.578.1.12.4.1.1.8116"))
                 )
                 .withKontaktInfo(new XMLTeleCom()
                         .withTypeTelecom(new XMLCS().withV("HP").withDN("Hovedtelefon"))
-                        .withTeleAddress(new XMLURL().withV("tel:" + pasientDTO.getTelefon()))
+                        .withTeleAddress(new XMLURL().withV("tel:" + pasient.getTelefon()))
                 )
                 .withNavnFastlege(helsepersonellDTO.getFornavn() + " " + helsepersonellDTO.getEtternavn())
-                .withNAVKontor(pasientDTO.getNavKontor());
+                .withNAVKontor(pasient.getNavKontor());
     }
 
     XMLHelseOpplysningerArbeidsuforhet.Pasient getXmlObject() {