> call() {
-
- return webClient.put()
- .uri(uriBuilder -> uriBuilder.path(AMELDING_URL)
- .build())
- .httpRequest(httpRequest -> {
- HttpClientRequest reactorRequest = httpRequest.getNativeRequest();
- reactorRequest.responseTimeout(Duration.ofSeconds(REQUEST_DURATION));
- })
- .header(HttpHeaders.AUTHORIZATION, "Bearer " + token)
- .header(UserConstant.USER_HEADER_JWT, TokenXUtil.getUserJwt())
- .header(MILJOE, miljo)
- .bodyValue(amelding)
- .retrieve()
- .toBodilessEntity()
- .map(respons -> ResponseEntity.status(respons.getStatusCode()).body("OK"))
- .doOnError(WebClientFilter::logErrorMessage)
- .onErrorResume(error -> Mono.just(ResponseEntity.status(WebClientFilter.getStatus(error))
- .body(WebClientFilter.getMessage(error))))
- .retryWhen(Retry.backoff(3, Duration.ofSeconds(5))
- .filter(WebClientFilter::is5xxException));
- }
-}
diff --git a/apps/dolly-backend/src/main/resources/application-local.yml b/apps/dolly-backend/src/main/resources/application-local.yml
index 60c4ce2e4df..8124e2597cf 100644
--- a/apps/dolly-backend/src/main/resources/application-local.yml
+++ b/apps/dolly-backend/src/main/resources/application-local.yml
@@ -43,8 +43,6 @@ consumers:
url: https://testnav-tps-messaging-service.intern.dev.nav.no
testnav-person-service:
url: https://testnav-person-service.intern.dev.nav.no
- testnav-arbeidsforhold-service:
- url: https://testnav-arbeidsforhold-service.intern.dev.nav.no
testnav-organisasjon-service:
url: https://testnav-organisasjon-service.intern.dev.nav.no
testnav-sykemelding-api:
diff --git a/apps/dolly-backend/src/main/resources/application.yml b/apps/dolly-backend/src/main/resources/application.yml
index 1b62d6f9def..a40980668f6 100644
--- a/apps/dolly-backend/src/main/resources/application.yml
+++ b/apps/dolly-backend/src/main/resources/application.yml
@@ -200,11 +200,6 @@ consumers:
namespace: dolly
url: http://testnav-pdl-forvalter.dolly.svc.cluster.local
cluster: dev-gcp
- testnav-arbeidsforhold-service:
- name: testnav-arbeidsforhold-service
- namespace: dolly
- url: http://testnav-arbeidsforhold-service.dolly.svc.cluster.local
- cluster: dev-gcp
testnav-sykemelding-api:
name: testnav-sykemelding-api
namespace: dolly
diff --git a/apps/dolly-frontend/config.idporten.yml b/apps/dolly-frontend/config.idporten.yml
index 44a14a2c9d8..c6a89e2a411 100644
--- a/apps/dolly-frontend/config.idporten.yml
+++ b/apps/dolly-frontend/config.idporten.yml
@@ -33,12 +33,10 @@ spec:
- application: testnav-arbeidsplassencv-proxy
- application: testnav-bruker-service
- application: testnav-bruker-service-dev
- - application: testnav-generer-synt-amelding-service
- application: testnav-helsepersonell-service
- application: testnav-joark-dokument-service
- application: testnav-kodeverk-service
- application: testnav-miljoer-service
- - application: testnav-oppsummeringsdokument-service
- application: testnav-organisasjon-faste-data-service
- application: testnav-organisasjon-forvalter
- application: testnav-organisasjon-service
diff --git a/apps/dolly-frontend/config.test.yml b/apps/dolly-frontend/config.test.yml
index c8c86b70443..687aeffb88f 100644
--- a/apps/dolly-frontend/config.test.yml
+++ b/apps/dolly-frontend/config.test.yml
@@ -37,12 +37,10 @@ spec:
- application: testnav-amelding-service
- application: testnav-arbeidsplassencv-proxy
- application: testnav-bruker-service-dev
- - application: testnav-generer-synt-amelding-service
- application: testnav-helsepersonell-service
- application: testnav-joark-dokument-service
- application: testnav-kodeverk-service
- application: testnav-miljoer-service
- - application: testnav-oppsummeringsdokument-service
- application: testnav-organisasjon-faste-data-service
- application: testnav-organisasjon-forvalter
- application: testnav-organisasjon-service
diff --git a/apps/dolly-frontend/config.unstable.yml b/apps/dolly-frontend/config.unstable.yml
index 06ec62693d6..93dcb6a143d 100644
--- a/apps/dolly-frontend/config.unstable.yml
+++ b/apps/dolly-frontend/config.unstable.yml
@@ -40,7 +40,6 @@ spec:
- application: testnav-joark-dokument-service
- application: testnav-kodeverk-service
- application: testnav-miljoer-service
- - application: testnav-oppsummeringsdokument-service
- application: testnav-organisasjon-faste-data-service
- application: testnav-organisasjon-forvalter
- application: testnav-organisasjon-service
diff --git a/apps/dolly-frontend/config.yml b/apps/dolly-frontend/config.yml
index 51b1cb879cc..6571486f961 100644
--- a/apps/dolly-frontend/config.yml
+++ b/apps/dolly-frontend/config.yml
@@ -39,15 +39,12 @@ spec:
- application: dolly-redis-session
- application: generer-navn-service
- application: testnav-adresse-service
- - application: testnav-amelding-service
- application: testnav-arbeidsplassencv-proxy
- application: testnav-bruker-service
- - application: testnav-generer-synt-amelding-service
- application: testnav-helsepersonell-service
- application: testnav-joark-dokument-service
- application: testnav-kodeverk-service
- application: testnav-miljoer-service
- - application: testnav-oppsummeringsdokument-service
- application: testnav-organisasjon-faste-data-service
- application: testnav-organisasjon-forvalter
- application: testnav-organisasjon-service
diff --git a/apps/dolly-search-service/src/main/java/no/nav/testnav/dollysearchservice/mapper/MappingStrategy.java b/apps/dolly-search-service/src/main/java/no/nav/testnav/dollysearchservice/mapper/MappingStrategy.java
deleted file mode 100644
index e28705ec577..00000000000
--- a/apps/dolly-search-service/src/main/java/no/nav/testnav/dollysearchservice/mapper/MappingStrategy.java
+++ /dev/null
@@ -1,19 +0,0 @@
-package no.nav.testnav.dollysearchservice.mapper;
-
-import ma.glasnost.orika.MapperFactory;
-
-@FunctionalInterface
-public interface MappingStrategy {
-
- /**
- * A callback for registering criteria on the provided {@link MapperFactory}.
- *
- * {@code
- *
- * @Override public void register(MapperFactory factory) {
- * factory.registerMapper(arbeidsfordelingToRestArbeidsfordeling());
- * }
- * }
- */
- void register(MapperFactory factory);
-}
diff --git a/apps/dolly-search-service/src/main/java/no/nav/testnav/dollysearchservice/mapper/OpenSearchV2ResponseMappingStrategy.java b/apps/dolly-search-service/src/main/java/no/nav/testnav/dollysearchservice/mapper/OpenSearchV2ResponseMappingStrategy.java
deleted file mode 100644
index 437c6abd7e8..00000000000
--- a/apps/dolly-search-service/src/main/java/no/nav/testnav/dollysearchservice/mapper/OpenSearchV2ResponseMappingStrategy.java
+++ /dev/null
@@ -1,31 +0,0 @@
-package no.nav.testnav.dollysearchservice.mapper;
-
-import ma.glasnost.orika.CustomMapper;
-import ma.glasnost.orika.MapperFactory;
-import ma.glasnost.orika.MappingContext;
-import no.nav.testnav.dollysearchservice.dto.SearchInternalResponse;
-import no.nav.testnav.libs.data.dollysearchservice.v1.SearchResponse;
-import org.springframework.stereotype.Component;
-
-@Component
-public class OpenSearchV2ResponseMappingStrategy implements MappingStrategy {
-
- @Override
- public void register(MapperFactory factory) {
- factory.classMap(SearchInternalResponse.class, SearchResponse.class)
- .customize(new CustomMapper<>() {
- @Override
- public void mapAtoB(SearchInternalResponse searchInternalResponse, SearchResponse searchResponse, MappingContext context) {
-
- searchResponse.setTotalHits(searchInternalResponse.getTotalHits());
- searchResponse.setTook(searchInternalResponse.getTook());
- searchResponse.setSide(searchInternalResponse.getSide());
- searchResponse.setAntall(searchInternalResponse.getAntall());
- searchResponse.setSeed(searchInternalResponse.getSeed());
- searchResponse.setPersoner(searchInternalResponse.getPersoner());
- searchResponse.setError(searchInternalResponse.getError());
- }
- })
- .register();
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/Dockerfile b/apps/generer-arbeidsforhold-populasjon-service/Dockerfile
deleted file mode 100644
index 99258cd954d..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/Dockerfile
+++ /dev/null
@@ -1,8 +0,0 @@
-FROM ghcr.io/navikt/baseimages/temurin:21
-LABEL maintainer="Team Dolly"
-
-ENV JAVA_OPTS="-Dspring.profiles.active=prod"
-
-ADD build/libs/app.jar /app/app.jar
-
-EXPOSE 8080
diff --git a/apps/generer-arbeidsforhold-populasjon-service/README.md b/apps/generer-arbeidsforhold-populasjon-service/README.md
deleted file mode 100644
index 97bea213464..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/README.md
+++ /dev/null
@@ -1,6 +0,0 @@
-# Generer-arbeidsforhold-populasjon-service
-Service som genererer arbeidsforhold i et valgt miljø for en spesifisert tidsperiode.
-
-## Lokal kjøring
-* [Generelt.](../../docs/local_general.md)
-* [Secret Manager.](../../docs/local_secretmanager.md)
\ No newline at end of file
diff --git a/apps/generer-arbeidsforhold-populasjon-service/build.gradle b/apps/generer-arbeidsforhold-populasjon-service/build.gradle
deleted file mode 100644
index cfa772f62d0..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/build.gradle
+++ /dev/null
@@ -1,27 +0,0 @@
-plugins {
- id "dolly-apps"
-}
-
-sonarqube {
- properties {
- property "sonar.projectKey", "testnav-generer-arbeidsforhold-populasjon-service"
- property "sonar.projectName", "testnav-generer-arbeidsforhold-populasjon-service"
- }
-}
-
-dependencies {
- implementation "no.nav.testnav.libs:commands"
- implementation "no.nav.testnav.libs:data-transfer-objects"
- implementation "no.nav.testnav.libs:security-core"
- implementation "no.nav.testnav.libs:servlet-core"
- implementation "no.nav.testnav.libs:servlet-insecure-security"
-
- implementation "org.springframework.boot:spring-boot-starter-web"
- implementation "org.springframework.boot:spring-boot-starter-oauth2-resource-server"
- implementation "org.springframework.boot:spring-boot-starter-web"
-
- implementation "org.springdoc:springdoc-openapi-starter-webmvc-ui:$versions.springdoc"
- implementation "io.swagger.core.v3:swagger-annotations-jakarta:$versions.swagger"
-
- testImplementation "org.springframework.cloud:spring-cloud-contract-wiremock"
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/config.yml b/apps/generer-arbeidsforhold-populasjon-service/config.yml
deleted file mode 100644
index 2a4610aa157..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/config.yml
+++ /dev/null
@@ -1,63 +0,0 @@
-apiVersion: "nais.io/v1alpha1"
-kind: "Application"
-metadata:
- name: testnav-generer-arbeidsforhold-populasjon-service
- namespace: dolly
- annotations:
- nginx.ingress.kubernetes.io/proxy-read-timeout: "1200"
- labels:
- team: dolly
-spec:
- image: "{{image}}"
- port: 8080
- tokenx:
- enabled: true
- azure:
- application:
- allowAllUsers: true
- enabled: true
- tenant: nav.no
- accessPolicy:
- inbound:
- rules:
- - application: team-dolly-lokal-app
- cluster: dev-gcp
- - application: testnav-oversikt-frontend
- cluster: dev-gcp
- outbound:
- rules:
- - application: testnav-oppsummeringsdokument-service
- - application: testnav-generer-organisasjon-populasjon-service
- - application: testnav-organisasjon-service
- - application: synthdata-amelding
- liveness:
- path: /internal/isAlive
- initialDelay: 4
- periodSeconds: 5
- failureThreshold: 500
- observability:
- logging:
- destinations:
- - id: elastic
- autoInstrumentation:
- enabled: true
- runtime: java
- readiness:
- path: /internal/isReady
- initialDelay: 4
- periodSeconds: 5
- failureThreshold: 500
- prometheus:
- enabled: true
- path: /internal/metrics
- replicas:
- min: 1
- max: 1
- resources:
- requests:
- cpu: 500m
- memory: 1024Mi
- limits:
- memory: 2048Mi
- ingresses:
- - "https://testnav-generer-arbeidsforhold-populasjon-service.intern.dev.nav.no"
\ No newline at end of file
diff --git a/apps/generer-arbeidsforhold-populasjon-service/gradle/wrapper/gradle-wrapper.jar b/apps/generer-arbeidsforhold-populasjon-service/gradle/wrapper/gradle-wrapper.jar
deleted file mode 100644
index 7454180f2ae..00000000000
Binary files a/apps/generer-arbeidsforhold-populasjon-service/gradle/wrapper/gradle-wrapper.jar and /dev/null differ
diff --git a/apps/generer-arbeidsforhold-populasjon-service/gradle/wrapper/gradle-wrapper.properties b/apps/generer-arbeidsforhold-populasjon-service/gradle/wrapper/gradle-wrapper.properties
deleted file mode 100644
index 48c0a02ca41..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/gradle/wrapper/gradle-wrapper.properties
+++ /dev/null
@@ -1,5 +0,0 @@
-distributionBase=GRADLE_USER_HOME
-distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.7-bin.zip
-zipStoreBase=GRADLE_USER_HOME
-zipStorePath=wrapper/dists
diff --git a/apps/generer-arbeidsforhold-populasjon-service/gradlew b/apps/generer-arbeidsforhold-populasjon-service/gradlew
deleted file mode 100755
index 3da45c161b0..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/gradlew
+++ /dev/null
@@ -1,234 +0,0 @@
-#!/bin/sh
-
-#
-# Copyright ? 2015-2021 the original authors.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# https://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-
-##############################################################################
-#
-# Gradle start up script for POSIX generated by Gradle.
-#
-# Important for running:
-#
-# (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
-# noncompliant, but you have some other compliant shell such as ksh or
-# bash, then to run this script, type that shell name before the whole
-# command line, like:
-#
-# ksh Gradle
-#
-# Busybox and similar reduced shells will NOT work, because this script
-# requires all of these POSIX shell features:
-# * functions;
-# * expansions ?$var?, ?${var}?, ?${var:-default}?, ?${var+SET}?,
-# ?${var#prefix}?, ?${var%suffix}?, and ?$( cmd )?;
-# * compound commands having a testable exit status, especially ?case?;
-# * various built-in commands including ?command?, ?set?, and ?ulimit?.
-#
-# Important for patching:
-#
-# (2) This script targets any POSIX shell, so it avoids extensions provided
-# by Bash, Ksh, etc; in particular arrays are avoided.
-#
-# The "traditional" practice of packing multiple parameters into a
-# space-separated string is a well documented source of bugs and security
-# problems, so this is (mostly) avoided, by progressively accumulating
-# options in "$@", and eventually passing that to Java.
-#
-# Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
-# and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
-# see the in-line comments for details.
-#
-# There are tweaks for specific operating systems such as AIX, CygWin,
-# Darwin, MinGW, and NonStop.
-#
-# (3) This script is generated from the Groovy template
-# https://github.com/gradle/gradle/blob/master/subprojects/plugins/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
-# within the Gradle project.
-#
-# You can find Gradle at https://github.com/gradle/gradle/.
-#
-##############################################################################
-
-# Attempt to set APP_HOME
-
-# Resolve links: $0 may be a link
-app_path=$0
-
-# Need this for daisy-chained symlinks.
-while
- APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path
- [ -h "$app_path" ]
-do
- ls=$( ls -ld "$app_path" )
- link=${ls#*' -> '}
- case $link in #(
- /*) app_path=$link ;; #(
- *) app_path=$APP_HOME$link ;;
- esac
-done
-
-APP_HOME=$( cd "${APP_HOME:-./}" && pwd -P ) || exit
-
-APP_NAME="Gradle"
-APP_BASE_NAME=${0##*/}
-
-# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
-DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
-
-# Use the maximum available, or set MAX_FD != -1 to use that value.
-MAX_FD=maximum
-
-warn () {
- echo "$*"
-} >&2
-
-die () {
- echo
- echo "$*"
- echo
- exit 1
-} >&2
-
-# OS specific support (must be 'true' or 'false').
-cygwin=false
-msys=false
-darwin=false
-nonstop=false
-case "$( uname )" in #(
- CYGWIN* ) cygwin=true ;; #(
- Darwin* ) darwin=true ;; #(
- MSYS* | MINGW* ) msys=true ;; #(
- NONSTOP* ) nonstop=true ;;
-esac
-
-CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
-
-
-# Determine the Java command to use to start the JVM.
-if [ -n "$JAVA_HOME" ] ; then
- if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
- # IBM's JDK on AIX uses strange locations for the executables
- JAVACMD=$JAVA_HOME/jre/sh/java
- else
- JAVACMD=$JAVA_HOME/bin/java
- fi
- if [ ! -x "$JAVACMD" ] ; then
- die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
-
-Please set the JAVA_HOME variable in your environment to match the
-location of your Java installation."
- fi
-else
- JAVACMD=java
- which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
-
-Please set the JAVA_HOME variable in your environment to match the
-location of your Java installation."
-fi
-
-# Increase the maximum file descriptors if we can.
-if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
- case $MAX_FD in #(
- max*)
- MAX_FD=$( ulimit -H -n ) ||
- warn "Could not query maximum file descriptor limit"
- esac
- case $MAX_FD in #(
- '' | soft) :;; #(
- *)
- ulimit -n "$MAX_FD" ||
- warn "Could not set maximum file descriptor limit to $MAX_FD"
- esac
-fi
-
-# Collect all arguments for the java command, stacking in reverse order:
-# * args from the command line
-# * the main class name
-# * -classpath
-# * -D...appname settings
-# * --module-path (only if needed)
-# * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
-
-# For Cygwin or MSYS, switch paths to Windows format before running java
-if "$cygwin" || "$msys" ; then
- APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
- CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
-
- JAVACMD=$( cygpath --unix "$JAVACMD" )
-
- # Now convert the arguments - kludge to limit ourselves to /bin/sh
- for arg do
- if
- case $arg in #(
- -*) false ;; # don't mess with options #(
- /?*) t=${arg#/} t=/${t%%/*} # looks like a POSIX filepath
- [ -e "$t" ] ;; #(
- *) false ;;
- esac
- then
- arg=$( cygpath --path --ignore --mixed "$arg" )
- fi
- # Roll the args list around exactly as many times as the number of
- # args, so each arg winds up back in the position where it started, but
- # possibly modified.
- #
- # NB: a `for` loop captures its iteration list before it begins, so
- # changing the positional parameters here affects neither the number of
- # iterations, nor the values presented in `arg`.
- shift # remove old arg
- set -- "$@" "$arg" # push replacement arg
- done
-fi
-
-# Collect all arguments for the java command;
-# * $DEFAULT_JVM_OPTS, $JAVA_OPTS, and $GRADLE_OPTS can contain fragments of
-# shell script including quotes and variable substitutions, so put them in
-# double quotes to make sure that they get re-expanded; and
-# * put everything else in single quotes, so that it's not re-expanded.
-
-set -- \
- "-Dorg.gradle.appname=$APP_BASE_NAME" \
- -classpath "$CLASSPATH" \
- org.gradle.wrapper.GradleWrapperMain \
- "$@"
-
-# Use "xargs" to parse quoted args.
-#
-# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
-#
-# In Bash we could simply go:
-#
-# readarray ARGS < <( xargs -n1 <<<"$var" ) &&
-# set -- "${ARGS[@]}" "$@"
-#
-# but POSIX shell has neither arrays nor command substitution, so instead we
-# post-process each arg (as a line of input to sed) to backslash-escape any
-# character that might be a shell metacharacter, then use eval to reverse
-# that process (while maintaining the separation between arguments), and wrap
-# the whole thing up as a single "set" statement.
-#
-# This will of course break if any of these variables contains a newline or
-# an unmatched quote.
-#
-
-eval "set -- $(
- printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
- xargs -n1 |
- sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
- tr '\n' ' '
- )" '"$@"'
-
-exec "$JAVACMD" "$@"
diff --git a/apps/generer-arbeidsforhold-populasjon-service/gradlew.bat b/apps/generer-arbeidsforhold-populasjon-service/gradlew.bat
deleted file mode 100644
index ac1b06f9382..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/gradlew.bat
+++ /dev/null
@@ -1,89 +0,0 @@
-@rem
-@rem Copyright 2015 the original author or authors.
-@rem
-@rem Licensed under the Apache License, Version 2.0 (the "License");
-@rem you may not use this file except in compliance with the License.
-@rem You may obtain a copy of the License at
-@rem
-@rem https://www.apache.org/licenses/LICENSE-2.0
-@rem
-@rem Unless required by applicable law or agreed to in writing, software
-@rem distributed under the License is distributed on an "AS IS" BASIS,
-@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-@rem See the License for the specific language governing permissions and
-@rem limitations under the License.
-@rem
-
-@if "%DEBUG%" == "" @echo off
-@rem ##########################################################################
-@rem
-@rem Gradle startup script for Windows
-@rem
-@rem ##########################################################################
-
-@rem Set local scope for the variables with windows NT shell
-if "%OS%"=="Windows_NT" setlocal
-
-set DIRNAME=%~dp0
-if "%DIRNAME%" == "" set DIRNAME=.
-set APP_BASE_NAME=%~n0
-set APP_HOME=%DIRNAME%
-
-@rem Resolve any "." and ".." in APP_HOME to make it shorter.
-for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
-
-@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
-set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
-
-@rem Find java.exe
-if defined JAVA_HOME goto findJavaFromJavaHome
-
-set JAVA_EXE=java.exe
-%JAVA_EXE% -version >NUL 2>&1
-if "%ERRORLEVEL%" == "0" goto execute
-
-echo.
-echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
-echo.
-echo Please set the JAVA_HOME variable in your environment to match the
-echo location of your Java installation.
-
-goto fail
-
-:findJavaFromJavaHome
-set JAVA_HOME=%JAVA_HOME:"=%
-set JAVA_EXE=%JAVA_HOME%/bin/java.exe
-
-if exist "%JAVA_EXE%" goto execute
-
-echo.
-echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
-echo.
-echo Please set the JAVA_HOME variable in your environment to match the
-echo location of your Java installation.
-
-goto fail
-
-:execute
-@rem Setup the command line
-
-set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
-
-
-@rem Execute Gradle
-"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
-
-:end
-@rem End local scope for the variables with windows NT shell
-if "%ERRORLEVEL%"=="0" goto mainEnd
-
-:fail
-rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
-rem the _cmd.exe /c_ return code!
-if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
-exit /b 1
-
-:mainEnd
-if "%OS%"=="Windows_NT" endlocal
-
-:omega
diff --git a/apps/generer-arbeidsforhold-populasjon-service/gradlewUpdate.sh b/apps/generer-arbeidsforhold-populasjon-service/gradlewUpdate.sh
deleted file mode 100755
index e5ee6361152..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/gradlewUpdate.sh
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/bash
-
-gradle wrapper
\ No newline at end of file
diff --git a/apps/generer-arbeidsforhold-populasjon-service/settings.gradle b/apps/generer-arbeidsforhold-populasjon-service/settings.gradle
deleted file mode 100644
index 2b9f546b563..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/settings.gradle
+++ /dev/null
@@ -1,21 +0,0 @@
-plugins {
- id "com.gradle.develocity" version "3.19"
-}
-
-rootProject.name = "generer-arbeidsforhold-populasjon-service"
-
-includeBuild "../../plugins/java"
-
-includeBuild "../../libs/commands"
-includeBuild "../../libs/data-transfer-objects"
-includeBuild "../../libs/security-core"
-includeBuild "../../libs/servlet-core"
-includeBuild "../../libs/servlet-insecure-security"
-includeBuild "../../libs/testing"
-
-develocity {
- buildScan {
- termsOfUseUrl = "https://gradle.com/terms-of-service"
- termsOfUseAgree = "yes"
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/GenererArbeidsforholdPopulasjonServiceApplicationStarter.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/GenererArbeidsforholdPopulasjonServiceApplicationStarter.java
deleted file mode 100644
index 1c2cfe7921a..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/GenererArbeidsforholdPopulasjonServiceApplicationStarter.java
+++ /dev/null
@@ -1,15 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice;
-
-import no.nav.dolly.libs.nais.NaisEnvironmentApplicationContextInitializer;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.builder.SpringApplicationBuilder;
-
-@SpringBootApplication
-public class GenererArbeidsforholdPopulasjonServiceApplicationStarter {
-
- public static void main(String[] args) {
- new SpringApplicationBuilder(GenererArbeidsforholdPopulasjonServiceApplicationStarter.class)
- .initializers(new NaisEnvironmentApplicationContextInitializer())
- .run(args);
- }
-}
\ No newline at end of file
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/adapter/IdentAdapter.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/adapter/IdentAdapter.java
deleted file mode 100644
index dd92c4f66b5..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/adapter/IdentAdapter.java
+++ /dev/null
@@ -1,7 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.adapter;
-
-import reactor.core.publisher.Flux;
-
-public interface IdentAdapter {
- Flux getIdenter(String miljo, int antall);
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/ApplicationConfig.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/ApplicationConfig.java
deleted file mode 100644
index 8eb066edf91..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/ApplicationConfig.java
+++ /dev/null
@@ -1,25 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.config;
-
-import no.nav.testnav.libs.servletcore.config.ApplicationCoreConfig;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.context.annotation.Import;
-import org.springframework.core.task.TaskExecutor;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
-import org.springframework.security.task.DelegatingSecurityContextAsyncTaskExecutor;
-
-@Configuration
-@Import({ApplicationCoreConfig.class})
-public class ApplicationConfig {
-
- @Bean
- public TaskExecutor executor() {
- final ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
- executor.setMaxPoolSize(100);
- executor.setCorePoolSize(50);
- executor.setThreadNamePrefix("thread-pool-with-security-context-");
- executor.initialize();
- return new DelegatingSecurityContextAsyncTaskExecutor(executor);
- }
-
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/Consumers.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/Consumers.java
deleted file mode 100644
index 76985531a44..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/Consumers.java
+++ /dev/null
@@ -1,31 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.config;
-
-import lombok.Getter;
-import lombok.NoArgsConstructor;
-import lombok.Setter;
-import no.nav.testnav.libs.securitycore.domain.ServerProperties;
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.context.annotation.Configuration;
-
-import static lombok.AccessLevel.PACKAGE;
-
-/**
- * Samler alle placeholders for ulike {@code consumers.*}-konfigurasjon her, dvs. subklasser av {@code ServerProperties}.
- *
- * Husk at Spring Boot bruker relaxed binding
- * mellom configuration properties og field names.
- *
- * @see ServerProperties
- */
-@Configuration
-@ConfigurationProperties(prefix = "consumers")
-@NoArgsConstructor(access = PACKAGE)
-@Getter
-@Setter(PACKAGE)
-public class Consumers {
-
- private ServerProperties testnavGenererOrganisasjonPopulasjonService;
- private ServerProperties oppsummeringsdokumentService;
- private ServerProperties testnavOrganisasjonService;
- private ServerProperties syntAmelding;
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/OpenApiConfig.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/OpenApiConfig.java
deleted file mode 100644
index 44c6bc94c6c..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/OpenApiConfig.java
+++ /dev/null
@@ -1,55 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.config;
-
-import io.swagger.v3.oas.models.Components;
-import io.swagger.v3.oas.models.OpenAPI;
-import io.swagger.v3.oas.models.info.Contact;
-import io.swagger.v3.oas.models.info.Info;
-import io.swagger.v3.oas.models.info.License;
-import io.swagger.v3.oas.models.security.SecurityRequirement;
-import io.swagger.v3.oas.models.security.SecurityScheme;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.web.servlet.config.annotation.ViewControllerRegistry;
-import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
-
-import java.util.Arrays;
-
-import no.nav.testnav.libs.servletcore.config.ApplicationProperties;
-
-@Configuration
-public class OpenApiConfig implements WebMvcConfigurer {
-
- @Bean
- public OpenAPI openApi(ApplicationProperties applicationProperties) {
- return new OpenAPI()
- .components(new Components().addSecuritySchemes("bearer-jwt", new SecurityScheme()
- .type(SecurityScheme.Type.HTTP)
- .scheme("bearer")
- .bearerFormat("JWT")
- .in(SecurityScheme.In.HEADER)
- .name("Authorization")
- ))
- .addSecurityItem(
- new SecurityRequirement().addList("bearer-jwt", Arrays.asList("read", "write")))
- .info(new Info()
- .title(applicationProperties.getName())
- .version(applicationProperties.getVersion())
- .description(applicationProperties.getDescription())
- .termsOfService("https://nav.no")
- .contact(new Contact()
- .url("https://nav-it.slack.com/archives/CA3P9NGA2")
- .email("dolly@nav.no")
- .name("Team Dolly")
- )
- .license(new License()
- .name("MIT License")
- .url("https://opensource.org/licenses/MIT")
- )
- );
- }
-
- @Override
- public void addViewControllers(ViewControllerRegistry registry) {
- registry.addViewController("/swagger").setViewName("redirect:/swagger-ui.html");
- }
-}
\ No newline at end of file
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/SecurityConfig.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/SecurityConfig.java
deleted file mode 100644
index 60193328810..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/config/SecurityConfig.java
+++ /dev/null
@@ -1,39 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.config;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.core.annotation.Order;
-import org.springframework.security.config.Customizer;
-import org.springframework.security.config.annotation.web.builders.HttpSecurity;
-import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
-import org.springframework.security.config.annotation.web.configurers.AbstractHttpConfigurer;
-import org.springframework.security.config.http.SessionCreationPolicy;
-import org.springframework.security.web.SecurityFilterChain;
-
-
-@Order(1)
-@EnableWebSecurity
-@Configuration
-public class SecurityConfig {
-
- @Bean
- public SecurityFilterChain filterChain(HttpSecurity httpSecurity) throws Exception {
-
- httpSecurity.sessionManagement(sessionConfig -> sessionConfig.sessionCreationPolicy(SessionCreationPolicy.STATELESS))
- .csrf(AbstractHttpConfigurer::disable)
- .authorizeHttpRequests(authorizeConfig -> authorizeConfig.requestMatchers(
- "/internal/**",
- "/webjars/**",
- "/swagger-resources/**",
- "/v3/api-docs/**",
- "/swagger-ui/**",
- "/swagger",
- "/error",
- "/swagger-ui.html"
- ).permitAll().requestMatchers("/api/**").fullyAuthenticated())
- .oauth2ResourceServer(oauth2RSConfig -> oauth2RSConfig.jwt(Customizer.withDefaults()));
-
- return httpSecurity.build();
- }
-}
-
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/GenererOrganisasjonPopulasjonConsumer.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/GenererOrganisasjonPopulasjonConsumer.java
deleted file mode 100644
index 5dfcf5e8710..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/GenererOrganisasjonPopulasjonConsumer.java
+++ /dev/null
@@ -1,39 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer;
-
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.config.Consumers;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command.GetOpplysningspliktigOrgnummerCommand;
-import no.nav.testnav.libs.securitycore.domain.ServerProperties;
-import no.nav.testnav.libs.standalone.servletsecurity.exchange.TokenExchange;
-import org.springframework.stereotype.Component;
-import org.springframework.web.reactive.function.client.WebClient;
-
-import java.util.Set;
-
-@Component
-public class GenererOrganisasjonPopulasjonConsumer {
- private final WebClient webClient;
- private final ServerProperties serverProperties;
- private final TokenExchange tokenExchange;
-
- public GenererOrganisasjonPopulasjonConsumer(
- Consumers consumers,
- TokenExchange tokenExchange,
- WebClient.Builder webClientBuilder) {
-
- serverProperties = consumers.getTestnavGenererOrganisasjonPopulasjonService();
- this.tokenExchange = tokenExchange;
- this.webClient = webClientBuilder
- .baseUrl(serverProperties.getUrl())
- .build();
- }
-
- public Set getOpplysningspliktig(String miljo) {
- return tokenExchange.exchange(serverProperties)
- .flatMap(accessToken -> new GetOpplysningspliktigOrgnummerCommand(
- webClient,
- accessToken.getTokenValue(),
- miljo
- ).call()
- ).block();
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/OppsummeringsdokumentConsumer.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/OppsummeringsdokumentConsumer.java
deleted file mode 100644
index 6295bcb421b..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/OppsummeringsdokumentConsumer.java
+++ /dev/null
@@ -1,125 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.config.Consumers;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command.GetOppsummeringsdokumentCommand;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command.SaveOppsummeringsdokumenterCommand;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding.Oppsummeringsdokument;
-import no.nav.testnav.libs.commands.GetOppsummeringsdokumenterByIdentCommand;
-import no.nav.testnav.libs.commands.GetOppsummeringsdokumenterCommand;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.OppsummeringsdokumentDTO;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.Populasjon;
-import no.nav.testnav.libs.securitycore.domain.ServerProperties;
-import no.nav.testnav.libs.servletcore.config.ApplicationProperties;
-import no.nav.testnav.libs.standalone.servletsecurity.exchange.TokenExchange;
-import org.springframework.http.MediaType;
-import org.springframework.http.codec.json.Jackson2JsonDecoder;
-import org.springframework.http.codec.json.Jackson2JsonEncoder;
-import org.springframework.stereotype.Component;
-import org.springframework.web.reactive.function.client.WebClient;
-import reactor.core.publisher.Mono;
-
-import java.time.LocalDate;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.Executor;
-import java.util.concurrent.Executors;
-
-@Slf4j
-@Component
-public class OppsummeringsdokumentConsumer {
- private static final int BYTE_COUNT = 16 * 1024 * 1024;
- private final WebClient webClient;
- private final TokenExchange tokenExchange;
- private final ServerProperties serverProperties;
- private final ApplicationProperties applicationProperties;
- private final Executor executor;
-
- public OppsummeringsdokumentConsumer(
- TokenExchange tokenExchange,
- Consumers consumers,
- ObjectMapper objectMapper,
- ApplicationProperties applicationProperties,
- WebClient.Builder webClientBuilder) {
-
- this.applicationProperties = applicationProperties;
- this.tokenExchange = tokenExchange;
- serverProperties = consumers.getOppsummeringsdokumentService();
- this.executor = Executors.newFixedThreadPool(20);
-
- this.webClient = webClientBuilder
- .baseUrl(serverProperties.getUrl())
- .codecs(clientDefaultCodecsConfigurer -> {
- clientDefaultCodecsConfigurer.defaultCodecs().maxInMemorySize(BYTE_COUNT);
- clientDefaultCodecsConfigurer
- .defaultCodecs()
- .jackson2JsonEncoder(new Jackson2JsonEncoder(objectMapper, MediaType.APPLICATION_JSON));
- clientDefaultCodecsConfigurer
- .defaultCodecs()
- .jackson2JsonDecoder(new Jackson2JsonDecoder(objectMapper, MediaType.APPLICATION_JSON));
- })
- .build();
- }
-
- /**
- * Bruker future til å sette en limit på antall samtidige requests.
- */
- @SneakyThrows
- public Mono save(OppsummeringsdokumentDTO dto, String miljo) {
- return Mono.fromFuture(saveFuture(dto, miljo));
- }
-
- private CompletableFuture saveFuture(OppsummeringsdokumentDTO dto, String miljo) {
- return CompletableFuture.supplyAsync(
- () -> tokenExchange
- .exchange(serverProperties)
- .flatMap(accessToken -> new SaveOppsummeringsdokumenterCommand(
- webClient,
- accessToken.getTokenValue(),
- dto,
- miljo,
- applicationProperties.getName(),
- Populasjon.MINI_NORGE
- ).call())
- .block(),
- executor
- );
- }
-
- public List getAll(String miljo) {
- log.info("Henter alle oppsummeringsdokument fra {}...", miljo);
- var accessToken = tokenExchange.exchange(serverProperties).block();
- var list = new GetOppsummeringsdokumenterCommand(webClient, accessToken.getTokenValue(), miljo).call();
- log.info("Fant {} opplysningspliktig fra {}.", list.size(), miljo);
- return list;
- }
-
- public Mono> getAllForIdent(String ident, String miljo) {
- return tokenExchange.exchange(serverProperties)
- .flatMap(accessToken -> new GetOppsummeringsdokumenterByIdentCommand(webClient, accessToken.getTokenValue(), ident, miljo).call());
- }
-
- public Mono getOppsummeringsdokument(String opplysningspliktigOrgnummer, LocalDate kalendermaaned, String miljo) {
- return tokenExchange
- .exchange(serverProperties)
- .flatMap(accessToken -> new GetOppsummeringsdokumentCommand(
- webClient,
- accessToken.getTokenValue(),
- opplysningspliktigOrgnummer,
- kalendermaaned,
- miljo
- ).call())
- .defaultIfEmpty(
- OppsummeringsdokumentDTO
- .builder()
- .version(1L)
- .kalendermaaned(kalendermaaned)
- .opplysningspliktigOrganisajonsnummer(opplysningspliktigOrgnummer)
- .virksomheter(new ArrayList<>())
- .build()
- ).map(Oppsummeringsdokument::new);
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/OrganisasjonConsumer.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/OrganisasjonConsumer.java
deleted file mode 100644
index 2888017d4b3..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/OrganisasjonConsumer.java
+++ /dev/null
@@ -1,47 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer;
-
-import lombok.extern.slf4j.Slf4j;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.config.Consumers;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command.GetOrganisasjonCommand;
-import no.nav.testnav.libs.dto.organisasjon.v1.OrganisasjonDTO;
-import no.nav.testnav.libs.securitycore.domain.ServerProperties;
-import no.nav.testnav.libs.standalone.servletsecurity.exchange.TokenExchange;
-import org.springframework.cache.annotation.CacheConfig;
-import org.springframework.cache.annotation.Cacheable;
-import org.springframework.stereotype.Component;
-import org.springframework.web.reactive.function.client.WebClient;
-import reactor.core.publisher.Flux;
-
-import java.util.Set;
-import java.util.stream.Collectors;
-
-@Slf4j
-@Component
-@CacheConfig
-public class OrganisasjonConsumer {
- private final ServerProperties serverProperties;
- private final TokenExchange tokenExchange;
- private final WebClient webClient;
-
- public OrganisasjonConsumer(
- Consumers consumers,
- TokenExchange tokenExchange,
- WebClient.Builder webClientBuilder) {
-
- serverProperties = consumers.getTestnavOrganisasjonService();
- this.tokenExchange = tokenExchange;
- this.webClient = webClientBuilder
- .baseUrl(serverProperties.getUrl())
- .build();
- }
-
- @Cacheable("Mini-Norge-EREG")
- public Flux getOrganisasjoner(Set orgnummerListe, String miljo) {
- return tokenExchange.exchange(serverProperties)
- .flatMapMany(accessToken -> Flux.concat(
- orgnummerListe.stream()
- .map(orgnummer -> new GetOrganisasjonCommand(webClient, accessToken.getTokenValue(), orgnummer, miljo).call())
- .collect(Collectors.toList())
- ));
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/SyntArbeidsforholdConsumer.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/SyntArbeidsforholdConsumer.java
deleted file mode 100644
index c5c9f646508..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/SyntArbeidsforholdConsumer.java
+++ /dev/null
@@ -1,61 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.config.Consumers;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command.GenererArbeidsforholdHistorikkCommand;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command.GenererStartArbeidsforholdCommand;
-import no.nav.testnav.libs.dto.syntrest.v1.ArbeidsforholdRequest;
-import no.nav.testnav.libs.dto.syntrest.v1.ArbeidsforholdResponse;
-import no.nav.testnav.libs.securitycore.domain.ServerProperties;
-import no.nav.testnav.libs.standalone.servletsecurity.exchange.TokenExchange;
-import org.springframework.http.MediaType;
-import org.springframework.http.codec.json.Jackson2JsonDecoder;
-import org.springframework.http.codec.json.Jackson2JsonEncoder;
-import org.springframework.stereotype.Component;
-import org.springframework.web.reactive.function.client.WebClient;
-import reactor.core.publisher.Mono;
-
-import java.time.LocalDate;
-import java.util.List;
-
-@Component
-public class SyntArbeidsforholdConsumer {
- private final TokenExchange tokenExchange;
- private final ServerProperties serverProperties;
- private final WebClient webClient;
- private final ObjectMapper objectMapper;
-
- public SyntArbeidsforholdConsumer(
- TokenExchange tokenExchange,
- Consumers consumers,
- ObjectMapper objectMapper,
- WebClient.Builder webClientBuilder) {
-
- this.tokenExchange = tokenExchange;
- serverProperties = consumers.getSyntAmelding();
- this.objectMapper = objectMapper;
- this.webClient = webClientBuilder
- .baseUrl(serverProperties.getUrl())
- .codecs(clientDefaultCodecsConfigurer -> {
- clientDefaultCodecsConfigurer
- .defaultCodecs()
- .jackson2JsonEncoder(new Jackson2JsonEncoder(objectMapper, MediaType.APPLICATION_JSON));
- clientDefaultCodecsConfigurer
- .defaultCodecs()
- .jackson2JsonDecoder(new Jackson2JsonDecoder(objectMapper, MediaType.APPLICATION_JSON));
- })
- .build();
- }
-
- public Mono> genererStartArbeidsforhold(LocalDate startdato) {
- return tokenExchange
- .exchange(serverProperties)
- .flatMap(accessToken -> new GenererStartArbeidsforholdCommand(webClient, startdato, accessToken.getTokenValue()).call());
- }
-
- public Mono>> genererArbeidsforholdHistorikk(List requests) {
- return tokenExchange
- .exchange(serverProperties)
- .flatMap(accessToken -> new GenererArbeidsforholdHistorikkCommand(webClient, requests, accessToken.getTokenValue(), objectMapper).call());
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GenererArbeidsforholdHistorikkCommand.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GenererArbeidsforholdHistorikkCommand.java
deleted file mode 100644
index 80d3fcd4461..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GenererArbeidsforholdHistorikkCommand.java
+++ /dev/null
@@ -1,55 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command;
-
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import lombok.RequiredArgsConstructor;
-import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.testnav.libs.commands.utils.WebClientFilter;
-import no.nav.testnav.libs.dto.syntrest.v1.ArbeidsforholdRequest;
-import no.nav.testnav.libs.dto.syntrest.v1.ArbeidsforholdResponse;
-import org.springframework.core.ParameterizedTypeReference;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.MediaType;
-import org.springframework.web.reactive.function.BodyInserters;
-import org.springframework.web.reactive.function.client.WebClient;
-import reactor.core.publisher.Mono;
-import reactor.util.retry.Retry;
-
-import java.time.Duration;
-import java.util.List;
-import java.util.concurrent.Callable;
-
-@Slf4j
-@RequiredArgsConstructor
-public class GenererArbeidsforholdHistorikkCommand implements Callable>>> {
- private final WebClient webClient;
- private final List requests;
- private final String token;
- private final ObjectMapper objectMapper;
-
- @SneakyThrows
- @Override
- public Mono>> call() {
- log.info("Genererer arbeidsforhold historikk.");
- var body = requests.toArray(new ArbeidsforholdRequest[requests.size()]);
- return webClient
- .post()
- .uri("/api/v1/arbeidsforhold/historikk")
- .body(BodyInserters.fromPublisher(Mono.just(body), ArbeidsforholdRequest[].class))
- .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
- .header(HttpHeaders.AUTHORIZATION, "Bearer " + token)
- .retrieve()
- .bodyToMono(new ParameterizedTypeReference>>() {
- })
- .retryWhen(Retry.backoff(3, Duration.ofSeconds(5))
- .filter(WebClientFilter::is5xxException))
- .doOnError(error -> {
- try {
- log.error("Feil ved opprettelse av historikk med body: {}.", objectMapper.writeValueAsString(body), error);
- } catch (JsonProcessingException e) {
- log.error("Feil ved convertering av body til string.", e);
- }
- });
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GenererStartArbeidsforholdCommand.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GenererStartArbeidsforholdCommand.java
deleted file mode 100644
index a7ad0cd5605..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GenererStartArbeidsforholdCommand.java
+++ /dev/null
@@ -1,52 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command;
-
-import lombok.RequiredArgsConstructor;
-import lombok.Value;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.testnav.libs.commands.utils.WebClientFilter;
-import no.nav.testnav.libs.dto.syntrest.v1.ArbeidsforholdResponse;
-import org.springframework.core.ParameterizedTypeReference;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.MediaType;
-import org.springframework.web.reactive.function.BodyInserters;
-import org.springframework.web.reactive.function.client.WebClient;
-import reactor.core.publisher.Mono;
-import reactor.util.retry.Retry;
-
-import java.time.Duration;
-import java.time.LocalDate;
-import java.util.List;
-import java.util.concurrent.Callable;
-
-@Slf4j
-@RequiredArgsConstructor
-public class GenererStartArbeidsforholdCommand implements Callable>> {
- private final WebClient webClient;
- private final LocalDate startdate;
- private final String token;
-
- @Override
- public Mono> call() {
- log.info("Generer nytt arbeidsforhold den {}.", startdate);
- return webClient
- .post()
- .uri("/api/v1/arbeidsforhold/new")
- .body(BodyInserters.fromPublisher(Mono.just(new Request(startdate)), Request.class))
- .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
- .header(HttpHeaders.AUTHORIZATION, "Bearer " + token)
- .retrieve()
- .bodyToMono(new ParameterizedTypeReference>() {
- })
- .retryWhen(Retry.backoff(3, Duration.ofSeconds(5))
- .filter(WebClientFilter::is5xxException))
- .map(value -> {
- log.info("Nytt arbeidsforhold generert. (Antall: {})", value.size());
- return value;
- });
- }
-
- @Value
- private class Request {
- LocalDate startdato;
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GetOpplysningspliktigOrgnummerCommand.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GetOpplysningspliktigOrgnummerCommand.java
deleted file mode 100644
index fde28ac57fa..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GetOpplysningspliktigOrgnummerCommand.java
+++ /dev/null
@@ -1,37 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command;
-
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.testnav.libs.commands.utils.WebClientFilter;
-import org.springframework.core.ParameterizedTypeReference;
-import org.springframework.http.HttpHeaders;
-import org.springframework.web.reactive.function.client.WebClient;
-import reactor.core.publisher.Mono;
-import reactor.util.retry.Retry;
-
-import java.time.Duration;
-import java.util.Set;
-import java.util.concurrent.Callable;
-
-@Slf4j
-@RequiredArgsConstructor
-public class GetOpplysningspliktigOrgnummerCommand implements Callable>> {
- private final WebClient webClient;
- private final String accessToken;
- private final String miljo;
-
- @Override
- public Mono> call() {
- log.info("Henter alle opplysningspliktige orgnummer i {}...", miljo);
- return webClient
- .get()
- .uri("/api/v1/opplysningspliktig")
- .header(HttpHeaders.AUTHORIZATION, "Bearer " + accessToken)
- .header("miljo", miljo)
- .retrieve()
- .bodyToMono(new ParameterizedTypeReference>() {
- })
- .retryWhen(Retry.backoff(3, Duration.ofSeconds(5))
- .filter(WebClientFilter::is5xxException));
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GetOppsummeringsdokumentCommand.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GetOppsummeringsdokumentCommand.java
deleted file mode 100644
index 82e973ea1ea..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GetOppsummeringsdokumentCommand.java
+++ /dev/null
@@ -1,45 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command;
-
-import lombok.RequiredArgsConstructor;
-import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.testnav.libs.commands.utils.WebClientFilter;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.OppsummeringsdokumentDTO;
-import org.springframework.http.HttpHeaders;
-import org.springframework.web.reactive.function.client.WebClient;
-import org.springframework.web.reactive.function.client.WebClientResponseException;
-import reactor.core.publisher.Mono;
-import reactor.util.retry.Retry;
-
-import java.time.Duration;
-import java.time.LocalDate;
-import java.util.concurrent.Callable;
-
-@Slf4j
-@RequiredArgsConstructor
-public class GetOppsummeringsdokumentCommand implements Callable> {
- private final WebClient webClient;
- private final String accessToken;
- private final String orgnummer;
- private final LocalDate kalendermaaned;
- private final String miljo;
-
- @SneakyThrows
- @Override
- public Mono call() {
- log.info("Henter oppsummeringsdokumentet med orgnummer {} den {} i {}.", orgnummer, kalendermaaned, miljo);
- return webClient
- .get()
- .uri(builder -> builder
- .path("/api/v1/oppsummeringsdokumenter/{orgnummer}/{kalendermaaned}")
- .build(orgnummer, kalendermaaned)
- )
- .header("miljo", miljo)
- .header(HttpHeaders.AUTHORIZATION, "Bearer " + accessToken)
- .retrieve()
- .bodyToMono(OppsummeringsdokumentDTO.class)
- .retryWhen(Retry.backoff(3, Duration.ofSeconds(5))
- .filter(WebClientFilter::is5xxException))
- .onErrorResume(throwable -> throwable instanceof WebClientResponseException.NotFound, throwable -> Mono.empty());
- }
-}
\ No newline at end of file
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GetOrganisasjonCommand.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GetOrganisasjonCommand.java
deleted file mode 100644
index 6f8a2ae118c..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/GetOrganisasjonCommand.java
+++ /dev/null
@@ -1,42 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command;
-
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.testnav.libs.commands.utils.WebClientFilter;
-import no.nav.testnav.libs.dto.organisasjon.v1.OrganisasjonDTO;
-import org.springframework.http.HttpHeaders;
-import org.springframework.web.reactive.function.client.WebClient;
-import org.springframework.web.reactive.function.client.WebClientResponseException;
-import reactor.core.publisher.Mono;
-import reactor.util.retry.Retry;
-
-import java.time.Duration;
-import java.util.concurrent.Callable;
-
-@Slf4j
-@RequiredArgsConstructor
-public class GetOrganisasjonCommand implements Callable> {
- private final WebClient webClient;
- private final String token;
- private final String orgnummer;
- private final String miljo;
-
- @Override
- public Mono call() {
- log.trace("Henter organisasjon med orgnummer {} fra {}...", orgnummer, miljo);
- return webClient
- .get()
- .uri(builder -> builder
- .path("/api/v1/organisasjoner/{orgnummer}")
- .build(orgnummer)
- )
- .header(HttpHeaders.AUTHORIZATION, "Bearer " + token)
- .header("miljo", this.miljo)
- .retrieve()
- .bodyToMono(OrganisasjonDTO.class)
- .retryWhen(Retry.backoff(3, Duration.ofSeconds(5))
- .filter(WebClientFilter::is5xxException))
- .onErrorResume(throwable -> throwable instanceof WebClientResponseException.NotFound, throwable -> Mono.empty());
-
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/SaveOppsummeringsdokumenterCommand.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/SaveOppsummeringsdokumenterCommand.java
deleted file mode 100644
index 40c649ceddf..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/consumer/command/SaveOppsummeringsdokumenterCommand.java
+++ /dev/null
@@ -1,68 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.command;
-
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.testnav.libs.commands.utils.WebClientFilter;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.OppsummeringsdokumentDTO;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.Populasjon;
-import org.springframework.http.HttpHeaders;
-import org.springframework.web.reactive.function.BodyInserters;
-import org.springframework.web.reactive.function.client.WebClient;
-import reactor.core.publisher.Mono;
-import reactor.util.retry.Retry;
-
-import java.time.Duration;
-import java.util.concurrent.Callable;
-
-@Slf4j
-@RequiredArgsConstructor
-public class SaveOppsummeringsdokumenterCommand implements Callable> {
- private final WebClient webClient;
- private final String accessToken;
- private final OppsummeringsdokumentDTO dto;
- private final String miljo;
- private final String origin;
- private final Populasjon populasjon;
-
- @Override
- public Mono call() {
- log.info(
- "Sender inn opplysningspliktig {} den {}.",
- dto.getOpplysningspliktigOrganisajonsnummer(),
- dto.getKalendermaaned()
- );
- return webClient
- .put()
- .uri(builder -> builder.path("/api/v1/oppsummeringsdokumenter").build())
- .header(HttpHeaders.AUTHORIZATION, "Bearer " + accessToken)
- .header("miljo", miljo)
- .header("origin", origin)
- .header("populasjon", populasjon.toString())
- .body(BodyInserters.fromPublisher(Mono.just(dto), OppsummeringsdokumentDTO.class))
- .exchange()
- .flatMap(response -> response.toEntity(String.class))
- .retryWhen(Retry.backoff(3, Duration.ofSeconds(5))
- .filter(WebClientFilter::is5xxException))
- .map(response -> {
-
-
- if (!response.getStatusCode().is2xxSuccessful()) {
- throw new RuntimeException(String.format(
- "Feil med opprettelse av opplysningspliktig %s. Error: %s Status code: %s.",
- dto.getOpplysningspliktigOrganisajonsnummer(),
- response.getBody(),
- response.getStatusCodeValue()
- ));
- }
-
- var id = response.getHeaders().get("ID").stream().findFirst().orElseThrow();
- log.info(
- "Opplysningspliktig {} sendt inn den {} med id {}",
- dto.getOpplysningspliktigOrganisajonsnummer(),
- dto.getKalendermaaned(),
- id
- );
- return id;
- });
- }
-}
\ No newline at end of file
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/controller/GenererArbeidsforholdController.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/controller/GenererArbeidsforholdController.java
deleted file mode 100644
index b5484bfc465..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/controller/GenererArbeidsforholdController.java
+++ /dev/null
@@ -1,27 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.controller;
-
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.service.OrkestratorService;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestHeader;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
-
-@Slf4j
-@RestController
-@RequiredArgsConstructor
-@RequestMapping("/api/v1/arbeidsforhold")
-public class GenererArbeidsforholdController {
-
- private final OrkestratorService orkestratorService;
-
- @PostMapping(value = "/develop")
- public void populate(
- @RequestHeader String miljo,
- @RequestParam Integer months
- ) {
- orkestratorService.orkestrerMedArbeidsforhold(miljo, months);
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Id.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Id.java
deleted file mode 100644
index cac2ce2db32..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Id.java
+++ /dev/null
@@ -1,5 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain;
-
-public interface Id {
- String getId();
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/OppsummeringsdokumentTimeline.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/OppsummeringsdokumentTimeline.java
deleted file mode 100644
index ef8848a5871..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/OppsummeringsdokumentTimeline.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain;
-
-import java.util.List;
-
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding.Oppsummeringsdokument;
-
-public class OppsummeringsdokumentTimeline extends Timeline {
-
- public OppsummeringsdokumentTimeline(List list) {
- list.forEach(this::put);
- }
-
- private void put(Oppsummeringsdokument oppsummeringsdokument) {
- super.put(oppsummeringsdokument.getKalendermaaned(), oppsummeringsdokument);
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Organisajon.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Organisajon.java
deleted file mode 100644
index 4d9abe3db9a..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Organisajon.java
+++ /dev/null
@@ -1,38 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain;
-
-import no.nav.testnav.libs.dto.organisasjon.v1.OrganisasjonDTO;
-
-import java.util.List;
-import java.util.Random;
-
-public class Organisajon {
- private static final Random RANDOM = new Random();
- private OrganisasjonDTO dto;
-
- public Organisajon(OrganisasjonDTO dto) {
- this.dto = dto;
- }
-
- public String getOrgnummer() {
- return dto.getOrgnummer();
- }
-
- public boolean isDriverVirksomheter() {
- return !dto.getDriverVirksomheter().isEmpty();
- }
-
- public String getRandomVirksomhetsnummer() {
- return dto.getDriverVirksomheter().get(RANDOM.nextInt(dto.getDriverVirksomheter().size()));
- }
-
- public List getDriverVirksomheter() {
- return dto.getDriverVirksomheter();
- }
-
- public boolean isOpplysningspliktig() {
- return switch (dto.getEnhetType()) {
- case "AS", "NUF", "BRL", "KBO", "SA", "ENK" -> true;
- default -> false;
- };
- }
-}
\ No newline at end of file
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/PermisjonCount.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/PermisjonCount.java
deleted file mode 100644
index 2e524123005..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/PermisjonCount.java
+++ /dev/null
@@ -1,51 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain;
-
-import lombok.Getter;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.List;
-
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding.Permisjon;
-
-@Slf4j
-@Getter
-public class PermisjonCount {
- float velferdspermisjon = 0;
- float utdanningspermisjon = 0;
- float permisjonMedForeldrepenger = 0;
- float permisjonVedMilitaertjeneste = 0;
- float permisjon = 0;
- float permittering = 0;
-
- public PermisjonCount(List permisjoner) {
- if (permisjoner == null) {
- return;
- }
- for (var permisjon : permisjoner) {
- switch (permisjon.getBeskrivelse()) {
- case "velferdspermisjon":
- velferdspermisjon++;
- break;
- case "utdanningspermisjon":
- utdanningspermisjon++;
- break;
- case "permisjonMedForeldrepenger":
- permisjonMedForeldrepenger++;
- break;
- case "permisjonVedMilitaertjeneste":
- permisjonVedMilitaertjeneste++;
- break;
- case "permisjon":
- this.permisjon++;
- break;
- case "permittering":
- permittering++;
- break;
- default:
- log.warn("Ukjent permisjons beskrivelse {}", permisjon.getBeskrivelse());
- break;
- }
- }
- }
-
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Person.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Person.java
deleted file mode 100644
index 9be1ddef4cf..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Person.java
+++ /dev/null
@@ -1,44 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain;
-
-import com.fasterxml.jackson.annotation.JsonIgnore;
-
-import java.time.LocalDate;
-import java.util.Set;
-import java.util.stream.Collectors;
-
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding.Arbeidsforhold;
-
-public class Person {
- private final String ident;
- @JsonIgnore
- private final Timeline timeline;
-
- public Person(String ident, Timeline timeline) {
- this.ident = ident;
- this.timeline = timeline;
- }
-
- public String getIdent() {
- return ident;
- }
-
- public Set getArbeidsforholdOn(LocalDate date) {
- return timeline.get(date);
- }
-
- public Set getArbeidsforholdToRemoveOn(LocalDate date) {
- var history = timeline.getHistory(date);
- var current = timeline.get(date);
- return history.stream().filter(value -> !current.contains(value)).collect(Collectors.toSet());
- }
-
- public void updateTimeline(Timeline timeline) {
- this.timeline.update(timeline);
- }
-
- public Timeline getTimeline(){
- return timeline;
- }
-
-
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Timeline.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Timeline.java
deleted file mode 100644
index 4465aaafeeb..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/Timeline.java
+++ /dev/null
@@ -1,99 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain;
-
-import lombok.Getter;
-
-import java.time.LocalDate;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.TreeMap;
-import java.util.function.BiConsumer;
-import java.util.function.Function;
-import java.util.stream.Collectors;
-
-public class Timeline {
- private final Map> timeline;
- private final Map> history;
- @Getter
- private final Set updatedDates = new HashSet<>();
-
- public Timeline(Map> map) {
- timeline = new TreeMap<>();
- history = new TreeMap<>();
- map.forEach((key, values) -> values.forEach(value -> put(key, value, false)));
- }
-
- public Timeline() {
- timeline = new TreeMap<>();
- history = new TreeMap<>();
- }
-
- public LocalDate getLastDate() {
- return timeline.keySet().stream().reduce(null, (sub, date) -> {
- if (sub == null) {
- return date;
- }
- return date.compareTo(sub) > 0 ? date : sub;
- }
- );
- }
-
- public void put(LocalDate date, T value, boolean updated) {
- if (updated) {
- updatedDates.add(date);
- }
-
- if (!timeline.containsKey(date)) {
- timeline.put(date, new TimelineEntries<>());
- }
-
- var timelineEntries = timeline.get(date);
- timelineEntries.put(value);
- }
-
- public void put(LocalDate date, T value) {
- put(date, value, true);
- }
-
- public void replace(LocalDate date, Collection values) {
- updatedDates.add(date);
-
- if (timeline.containsKey(date)) {
- history.put(date, timeline.get(date));
- }
-
- timeline.put(date, new TimelineEntries<>());
- var timelineEntries = timeline.get(date);
- values.forEach(timelineEntries::put);
- }
-
- public void update(Timeline timeline) {
- timeline.forEach(this::replace);
- }
-
- public void forEach(BiConsumer> action) {
- timeline.forEach((date, entries) -> action.accept(date, entries.getAll()));
- }
-
- public List applyForAll(Function function) {
- return timeline.values().stream().flatMap(value -> value.getAll().stream().map(function))
- .collect(Collectors.toList());
- }
-
- public Set getHistory(LocalDate date) {
- if (!history.containsKey(date)) {
- return Collections.emptySet();
- }
- return history.get(date).getAll();
- }
-
- public Set get(LocalDate date) {
- if (!timeline.containsKey(date)) {
- return Collections.emptySet();
- }
- return timeline.get(date).getAll();
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/TimelineEntries.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/TimelineEntries.java
deleted file mode 100644
index ba310fa6d3d..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/TimelineEntries.java
+++ /dev/null
@@ -1,22 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain;
-
-import java.util.Map;
-import java.util.Set;
-import java.util.TreeMap;
-import java.util.stream.Collectors;
-
-public class TimelineEntries {
- private final Map entires;
-
- public TimelineEntries() {
- entires = new TreeMap<>();
- }
-
- public void put(T value) {
- entires.put(value.getId(), value);
- }
-
- public Set getAll() {
- return entires.entrySet().stream().map(Map.Entry::getValue).collect(Collectors.toSet());
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Arbeidsforhold.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Arbeidsforhold.java
deleted file mode 100644
index 9684748b02c..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Arbeidsforhold.java
+++ /dev/null
@@ -1,142 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding;
-
-import lombok.EqualsAndHashCode;
-import lombok.Value;
-import lombok.extern.slf4j.Slf4j;
-
-import java.time.LocalDate;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.stream.Collectors;
-
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.Id;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.PermisjonCount;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.ArbeidsforholdDTO;
-import no.nav.testnav.libs.dto.syntrest.v1.ArbeidsforholdRequest;
-import no.nav.testnav.libs.dto.syntrest.v1.ArbeidsforholdResponse;
-
-@Value
-@Slf4j
-@EqualsAndHashCode(callSuper = false)
-public class Arbeidsforhold extends Generated implements Id {
- String id;
- String type;
- LocalDate startdato;
- LocalDate sluttdato;
- Float antallTimerPerUke;
- String yrke;
- String arbeidstidsordning;
- Float stillingsprosent;
- LocalDate sisteLoennsendringsdato;
- List permisjoner;
- String historikk;
- List avvik;
- Fartoey fartoey;
- List inntekter;
- String virksomhetsnummer;
- String opplysningspliktig;
- String ident;
-
- public Arbeidsforhold(ArbeidsforholdDTO dto, String virksomhetsnummer, String opplysningspliktig, String ident) {
- this.virksomhetsnummer = virksomhetsnummer;
- this.opplysningspliktig = opplysningspliktig;
- this.ident = ident;
- id = dto.getArbeidsforholdId();
- type = dto.getTypeArbeidsforhold();
- startdato = dto.getStartdato();
- sluttdato = dto.getSluttdato();
- antallTimerPerUke = dto.getAntallTimerPerUke();
- yrke = dto.getYrke();
- arbeidstidsordning = dto.getArbeidstidsordning();
- stillingsprosent = dto.getStillingsprosent();
- sisteLoennsendringsdato = dto.getSisteLoennsendringsdato();
- permisjoner = dto.getPermisjoner().stream().map(Permisjon::new).collect(Collectors.toList());
- historikk = dto.getHistorikk();
- avvik = dto.getAvvik().stream().map(Avvik::new).collect(Collectors.toList());
- fartoey = dto.getFartoey() == null ? null : new Fartoey(dto.getFartoey());
- inntekter = dto.getInntekter().stream().map(Inntekt::new).collect(Collectors.toList());
- }
-
- public Arbeidsforhold(ArbeidsforholdResponse response, String id, String virksomhetsnummer, String opplysningspliktig, String ident) {
- this.id = id;
- this.virksomhetsnummer = virksomhetsnummer;
- this.opplysningspliktig = opplysningspliktig;
- this.ident = ident;
- type = emptyToNull(response.getArbeidsforholdType());
- startdato = response.getStartdato();
- sluttdato = format(response.getSluttdato());
- antallTimerPerUke = emptyToNull(response.getAntallTimerPerUkeSomEnFullStillingTilsvarer());
- yrke = emptyToNull(response.getYrke());
- arbeidstidsordning = emptyToNull(response.getArbeidstidsordning());
- stillingsprosent = response.getStillingsprosent();
- sisteLoennsendringsdato = response.getSisteLoennsendringsdato();
- permisjoner = response.getPermisjoner() == null
- ? new ArrayList<>()
- : response.getPermisjoner().stream().map(Permisjon::new).collect(Collectors.toList());
- historikk = response.getHistorikk();
- avvik = response.getAvvik() == null
- ? new ArrayList<>()
- : Collections.singletonList(new Avvik(response.getAvvik()));
- fartoey = response.getFartoey() == null ? null : new Fartoey(response.getFartoey());
- inntekter = response.getInntekter() == null
- ? new ArrayList<>()
- : response.getInntekter().stream().map(Inntekt::new).collect(Collectors.toList());
- }
-
-
- public ArbeidsforholdRequest toSynt(Integer endringer, LocalDate kaldermnd) {
- var permisjonCount = new PermisjonCount(permisjoner);
- return ArbeidsforholdRequest
- .builder()
- .antallTimerPerUkeSomEnFullStillingTilsvarer(nullToEmpty(antallTimerPerUke))
- .arbeidsforholdType(nullToEmpty(type))
- .arbeidstidsordning(nullToEmpty(arbeidstidsordning))
- .permisjon(permisjonCount.getPermisjon())
- .permisjonMedForeldrepenger(permisjonCount.getPermisjonMedForeldrepenger())
- .permisjonVedMilitaertjeneste(permisjonCount.getPermisjonVedMilitaertjeneste())
- .permittering(permisjonCount.getPermittering())
- .velferdspermisjon(permisjonCount.getVelferdspermisjon())
- .utdanningspermisjon(permisjonCount.getUtdanningspermisjon())
- .rapporteringsmaaned(formatKaldenermaand(kaldermnd))
- .sisteDatoForStillingsprosentendring(kaldermnd)
- .sisteLoennsendringsdato(sisteLoennsendringsdato)
- .sluttdato(format(sluttdato))
- .startdato(startdato)
- .stillingsprosent(nullToEmpty(stillingsprosent))
- .yrke(nullToEmpty(yrke))
- .historikk(historikk)
- .numEndringer(endringer)
- .fartoey(fartoey != null ? fartoey.toSynt() : null)
- .permisjoner(permisjoner == null ? null : permisjoner.stream().map(Permisjon::toSynt).collect(Collectors.toList()))
- .inntekter(inntekter == null ? null : inntekter.stream().map(Inntekt::toSynt).collect(Collectors.toList()))
- .antallInntekter(inntekter == null ? 0 : inntekter.size())
- .avvik(toSyntAvvik(avvik))
- .build();
- }
-
- public ArbeidsforholdDTO toDTO() {
- return ArbeidsforholdDTO
- .builder()
- .typeArbeidsforhold(type)
- .antallTimerPerUke(antallTimerPerUke)
- .arbeidstidsordning(arbeidstidsordning)
- .sisteLoennsendringsdato(sisteLoennsendringsdato)
- .stillingsprosent(stillingsprosent)
- .yrke(yrke)
- .startdato(startdato)
- .sluttdato(sluttdato)
- .arbeidsforholdId(id)
- .permisjoner(permisjoner == null ? null : permisjoner.stream().map(Permisjon::toDTO).collect(Collectors.toList()))
- .historikk(historikk)
- .fartoey(fartoey == null ? null : fartoey.toDTO())
- .inntekter(inntekter == null ? null : inntekter.stream().map(Inntekt::toDTO).collect(Collectors.toList()))
- .avvik(avvik == null ? null : avvik.stream().map(Avvik::toDTO).collect(Collectors.toList()))
- .build();
- }
-
- public boolean isForenklet() {
- return type.equals("forenkletOppgjoersordning");
- }
-
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Avvik.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Avvik.java
deleted file mode 100644
index 0bf1bc111eb..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Avvik.java
+++ /dev/null
@@ -1,43 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding;
-
-import lombok.Value;
-
-import no.nav.testnav.libs.dto.syntrest.v1.AvvikDTO;
-
-@Value
-public class Avvik {
- String id;
- String navn;
- String alvorlighetsgrad;
-
- public Avvik(no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.AvvikDTO dto){
- id = dto.getId();
- navn = dto.getNavn();
- alvorlighetsgrad = dto.getAlvorlighetsgrad();
- }
-
- public Avvik(AvvikDTO dto) {
- id = dto.getId();
- navn = dto.getNavn();
- alvorlighetsgrad = dto.getAlvorlighetsgrad();
- }
-
- public no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.AvvikDTO toDTO(){
- return no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.AvvikDTO
- .builder()
- .navn(navn)
- .id(id)
- .alvorlighetsgrad(alvorlighetsgrad)
- .build();
- }
-
- public AvvikDTO toSynt(){
- return AvvikDTO
- .builder()
- .id(id)
- .navn(navn)
- .alvorlighetsgrad(alvorlighetsgrad)
- .build();
- }
-
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Fartoey.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Fartoey.java
deleted file mode 100644
index d7cb50cca37..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Fartoey.java
+++ /dev/null
@@ -1,41 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding;
-
-import lombok.Value;
-
-import no.nav.testnav.libs.dto.syntrest.v1.FartoeyDTO;
-
-@Value
-public class Fartoey {
- String skipsregister;
- String skipstype;
- String fartsomraade;
-
- public Fartoey(no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.FartoeyDTO dto) {
- skipsregister = dto.getSkipsregister();
- skipstype = dto.getSkipstype();
- fartsomraade = dto.getFartsomraade();
- }
-
- public Fartoey(FartoeyDTO dto) {
- skipsregister = dto.getSkipsregister();
- skipstype = dto.getSkipstype();
- fartsomraade = dto.getFartsomraade();
- }
-
- public no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.FartoeyDTO toDTO() {
- return no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.FartoeyDTO.builder()
- .fartsomraade(fartsomraade)
- .skipsregister(skipsregister)
- .skipstype(skipstype)
- .build();
- }
-
- public FartoeyDTO toSynt() {
- return FartoeyDTO
- .builder()
- .skipsregister(skipsregister)
- .skipstype(skipstype)
- .fartsomraade(fartsomraade)
- .build();
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Generated.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Generated.java
deleted file mode 100644
index 1663969f811..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Generated.java
+++ /dev/null
@@ -1,49 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding;
-
-import org.apache.logging.log4j.util.Strings;
-
-import java.time.LocalDate;
-import java.time.format.DateTimeFormatter;
-import java.util.List;
-
-import no.nav.testnav.libs.dto.syntrest.v1.AvvikDTO;
-
-abstract class Generated {
-
- Float nullToEmpty(Float value) {
- return value == null ? 0f : value;
- }
-
- String nullToEmpty(String value) {
- return value == null ? "" : value;
- }
-
- String emptyToNull(String value) {
- return value == null ? null : value.equals("") ? null : value;
- }
-
- Float emptyToNull(Float value) {
- return value == 0f ? null : value;
- }
-
- String formatKaldenermaand(LocalDate value) {
- return value.format(DateTimeFormatter.ofPattern("yyyy-MM"));
- }
-
- String format(LocalDate value) {
- if (value == null) {
- return "";
- }
- return value.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
- }
-
- LocalDate format(String value) {
- return Strings.isBlank(value) ? null : LocalDate.parse(value);
- }
-
-
- AvvikDTO toSyntAvvik(List list) {
- return list == null ? null : list.stream().findFirst().map(Avvik::toSynt).orElse(null);
- }
-
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Inntekt.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Inntekt.java
deleted file mode 100644
index 99b9966aced..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Inntekt.java
+++ /dev/null
@@ -1,61 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding;
-
-import lombok.EqualsAndHashCode;
-import lombok.Value;
-
-import java.time.LocalDate;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.stream.Collectors;
-
-import no.nav.testnav.libs.dto.syntrest.v1.InntektDTO;
-
-@Value
-@EqualsAndHashCode(callSuper = false)
-public class Inntekt extends Generated {
- LocalDate startdatoOpptjeningsperiode;
- LocalDate sluttdatoOpptjeningsperiode;
- Integer antall;
- String opptjeningsland;
- List avvik;
-
- public Inntekt(no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.InntektDTO dto){
- sluttdatoOpptjeningsperiode = dto.getSluttdatoOpptjeningsperiode();
- startdatoOpptjeningsperiode = dto.getStartdatoOpptjeningsperiode();
- antall = dto.getAntall();
- opptjeningsland = dto.getOpptjeningsland();
- avvik = dto.getAvvik().stream().map(Avvik::new).collect(Collectors.toList());
- }
-
- public Inntekt(InntektDTO dto) {
- sluttdatoOpptjeningsperiode = dto.getSluttdatoOpptjeningsperiode();
- startdatoOpptjeningsperiode = dto.getStartdatoOpptjeningsperiode();
- antall = dto.getAntall();
- opptjeningsland = dto.getOpptjeningsland();
- avvik = dto.getAvvik() == null ? new ArrayList<>() : Collections.singletonList(new Avvik(dto.getAvvik()));
- }
-
- public InntektDTO toSynt() {
- return InntektDTO
- .builder()
- .startdatoOpptjeningsperiode(startdatoOpptjeningsperiode)
- .sluttdatoOpptjeningsperiode(sluttdatoOpptjeningsperiode)
- .antall(antall)
- .opptjeningsland(opptjeningsland)
- .avvik(toSyntAvvik(avvik))
- .build();
- }
-
- public no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.InntektDTO toDTO(){
- return no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.InntektDTO
- .builder()
- .startdatoOpptjeningsperiode(startdatoOpptjeningsperiode)
- .sluttdatoOpptjeningsperiode(sluttdatoOpptjeningsperiode)
- .opptjeningsland(opptjeningsland)
- .antall(antall)
- .avvik(avvik == null ? null : avvik.stream().map(Avvik::toDTO).collect(Collectors.toList()))
- .build();
- }
-
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Opplysningspliktig.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Opplysningspliktig.java
deleted file mode 100644
index 9578ddbb038..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Opplysningspliktig.java
+++ /dev/null
@@ -1,12 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding;
-
-import java.time.LocalDate;
-import java.util.List;
-
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.VirksomhetDTO;
-
-public class Opplysningspliktig {
- private LocalDate kalendermaaned;
- private String opplysningspliktigOrganisajonsnummer;
- private List virksomheter;
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Oppsummeringsdokument.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Oppsummeringsdokument.java
deleted file mode 100644
index f851f8bbf95..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Oppsummeringsdokument.java
+++ /dev/null
@@ -1,101 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding;
-
-import lombok.extern.slf4j.Slf4j;
-
-import java.time.LocalDate;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Optional;
-
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.Id;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.ArbeidsforholdDTO;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.OppsummeringsdokumentDTO;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.PersonDTO;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.VirksomhetDTO;
-
-@Slf4j
-public class Oppsummeringsdokument implements Id {
- private final OppsummeringsdokumentDTO dto;
-
- public Oppsummeringsdokument(OppsummeringsdokumentDTO dto) {
- this.dto = dto;
- this.dto.setVersion(this.dto.getVersion() == null ? 1L : this.dto.getVersion() + 1);
- }
-
- public String getOpplysningspliktigOrganisajonsnummer() {
- return dto.getOpplysningspliktigOrganisajonsnummer();
- }
-
- public LocalDate getKalendermaaned() {
- return dto.getKalendermaaned();
- }
-
- public void remove(Arbeidsforhold arbeidsforhold) {
- log.info("Fjerner arbeidsforhold med id {}.", arbeidsforhold.getId());
- var person = dto.getVirksomheter()
- .stream()
- .filter(value -> value.getOrganisajonsnummer().equals(arbeidsforhold.getVirksomhetsnummer()))
- .findFirst()
- .orElseThrow()
- .getPersoner()
- .stream()
- .filter(value -> value.getIdent().equals(arbeidsforhold.getIdent()))
- .findFirst()
- .orElseThrow();
- person.getArbeidsforhold().remove(arbeidsforhold.toDTO());
- }
-
- public void addAll(List arbeidsforhold) {
- arbeidsforhold.forEach(this::add);
- }
-
- private void add(Arbeidsforhold arbeidsforhold) {
-
- VirksomhetDTO virksomhet = dto.getVirksomheter()
- .stream()
- .filter(value -> value.getOrganisajonsnummer().equals(arbeidsforhold.getVirksomhetsnummer()))
- .findFirst()
- .orElseGet(() -> {
- VirksomhetDTO virksomhetDTO = new VirksomhetDTO(arbeidsforhold.getVirksomhetsnummer(), new ArrayList<>());
- dto.getVirksomheter().add(virksomhetDTO);
- return virksomhetDTO;
- });
-
- Optional optional = virksomhet.getPersoner()
- .stream()
- .filter(value -> value.getIdent().equals(arbeidsforhold.getIdent()))
- .findFirst();
-
- if (optional.isEmpty()) {
- virksomhet.getPersoner().add(new PersonDTO(arbeidsforhold.getIdent(), Collections.singletonList(
- arbeidsforhold.toDTO()
- )));
- } else {
- PersonDTO personDTO = optional.get();
- Optional tidligereArbeidsforhold = personDTO.getArbeidsforhold()
- .stream()
- .filter(arbeidsforholdDTO -> arbeidsforholdDTO.getArbeidsforholdId().equals(arbeidsforhold.getId()))
- .findFirst();
-
- List list = new ArrayList<>(personDTO.getArbeidsforhold());
- if (tidligereArbeidsforhold.isPresent()) {
- ArbeidsforholdDTO dto = tidligereArbeidsforhold.get();
- log.info("Fjerner tidligere arbeidsforhold {}", dto.getArbeidsforholdId());
- list.remove(dto);
- }
-
- list.add(arbeidsforhold.toDTO());
- personDTO.setArbeidsforhold(list);
- }
- }
-
- public OppsummeringsdokumentDTO toDTO() {
- return dto;
- }
-
- @Override
- public String getId() {
- return getOpplysningspliktigOrganisajonsnummer();
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Permisjon.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Permisjon.java
deleted file mode 100644
index 8ccb48e75c6..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/domain/amelding/Permisjon.java
+++ /dev/null
@@ -1,65 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding;
-
-import lombok.EqualsAndHashCode;
-import lombok.Value;
-
-import java.time.LocalDate;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.UUID;
-import java.util.stream.Collectors;
-
-import no.nav.testnav.libs.dto.syntrest.v1.PermisjonDTO;
-
-@Value
-@EqualsAndHashCode(callSuper = false)
-public class Permisjon extends Generated {
- String id;
- String beskrivelse;
- LocalDate startdato;
- LocalDate sluttdato;
- Float permisjonsprosent;
- List avvik;
-
- public Permisjon(no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.PermisjonDTO dto) {
- id = UUID.randomUUID().toString();
- beskrivelse = dto.getBeskrivelse();
- startdato = dto.getStartdato();
- sluttdato = dto.getSluttdato();
- permisjonsprosent = dto.getPermisjonsprosent();
- avvik = dto.getAvvik().stream().map(Avvik::new).collect(Collectors.toList());
- }
-
- public Permisjon(PermisjonDTO dto) {
- id = UUID.randomUUID().toString();
- beskrivelse = dto.getBeskrivelse();
- startdato = dto.getStartdato();
- sluttdato = dto.getSluttdato();
- permisjonsprosent = dto.getPermisjonsprosent() == null ? null : Float.parseFloat(dto.getPermisjonsprosent());
- avvik = dto.getAvvik() == null ? new ArrayList<>() : Collections.singletonList(new Avvik(dto.getAvvik()));
- }
-
- public no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.PermisjonDTO toDTO() {
- return no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.PermisjonDTO
- .builder()
- .permisjonId(UUID.randomUUID().toString())
- .beskrivelse(beskrivelse)
- .permisjonsprosent(permisjonsprosent)
- .sluttdato(sluttdato)
- .startdato(startdato)
- .avvik(avvik == null ? null : avvik.stream().map(Avvik::toDTO).collect(Collectors.toList()))
- .build();
- }
-
- public PermisjonDTO toSynt() {
- return PermisjonDTO
- .builder()
- .beskrivelse(beskrivelse)
- .startdato(startdato)
- .sluttdato(sluttdato)
- .permisjonsprosent(permisjonsprosent == null ? null : permisjonsprosent.toString())
- .avvik(toSyntAvvik(avvik))
- .build();
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/ArbeidsforholdHistorikkService.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/ArbeidsforholdHistorikkService.java
deleted file mode 100644
index bc2292ec3e6..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/ArbeidsforholdHistorikkService.java
+++ /dev/null
@@ -1,63 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.service;
-
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Service;
-import reactor.core.publisher.Mono;
-
-import java.time.LocalDate;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.UUID;
-import java.util.stream.Collectors;
-
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.SyntArbeidsforholdConsumer;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding.Arbeidsforhold;
-import no.nav.testnav.libs.dto.syntrest.v1.ArbeidsforholdResponse;
-
-@Service
-@RequiredArgsConstructor
-public class ArbeidsforholdHistorikkService {
- private final SyntArbeidsforholdConsumer syntArbeidsforholdConsumer;
-
- public Mono> genererStart(LocalDate startdato, String virksomhetsnummer, String opplysningspliktig, String ident) {
- var response = syntArbeidsforholdConsumer.genererStartArbeidsforhold(startdato);
- return response.map(items -> items.stream().map(item -> new Arbeidsforhold(
- item,
- UUID.randomUUID().toString(),
- virksomhetsnummer,
- opplysningspliktig,
- ident
- )).collect(Collectors.toList()));
- }
-
- public Mono>> genererHistorikk(List previous, LocalDate kaldermnd, int antall) {
- var responseList = syntArbeidsforholdConsumer.genererArbeidsforholdHistorikk(
- previous.stream()
- .map(arb -> arb.toSynt(antall, kaldermnd))
- .collect(Collectors.toList())
- );
- return responseList.map(list -> convert(previous, list));
- }
-
-
- private List> convert(List previous, List> responses){
- var arbeidsforholds = new ArrayList>();
-
- for(int index = 0; index < responses.size(); index++) {
-
- var previousArbeidsforhold = previous.get(index);
-
- var newArbeidsforholds = responses.get(index).stream().map(value -> new Arbeidsforhold(
- value,
- previousArbeidsforhold.getId(),
- previousArbeidsforhold.getVirksomhetsnummer(),
- previousArbeidsforhold.getOpplysningspliktig(),
- previousArbeidsforhold.getIdent()
- )).collect(Collectors.toList());
-
- arbeidsforholds.add(newArbeidsforholds);
- }
- return arbeidsforholds;
- }
-
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/ArbeidsforholdSerivce.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/ArbeidsforholdSerivce.java
deleted file mode 100644
index c2a7a32983f..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/ArbeidsforholdSerivce.java
+++ /dev/null
@@ -1,48 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.service;
-
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Service;
-import reactor.core.publisher.Mono;
-
-import java.time.LocalDate;
-import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
-
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.OppsummeringsdokumentConsumer;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.Timeline;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding.Arbeidsforhold;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.OppsummeringsdokumentDTO;
-
-@Service
-@RequiredArgsConstructor
-public class ArbeidsforholdSerivce {
- private final OppsummeringsdokumentConsumer oppsummeringsdokumentConsumer;
-
- public Mono> findTimelineFor(String ident, String miljo) {
- var dokumenter = oppsummeringsdokumentConsumer.getAllForIdent(ident, miljo);
- return dokumenter.map(items -> new Timeline<>(map(ident, items)));
- }
-
- private Map> map(String ident, java.util.List items) {
- return items.stream()
- .flatMap(oppsummeringsdokument -> oppsummeringsdokument.getVirksomheter()
- .stream()
- .flatMap(virksomhet -> virksomhet.getPersoner()
- .stream()
- .filter(value -> value.getIdent().equals(ident))
- .map(person -> Map.entry(
- oppsummeringsdokument.getKalendermaaned(),
- person.getArbeidsforhold()
- .stream()
- .map(arbeidsforhold -> new Arbeidsforhold(
- arbeidsforhold,
- virksomhet.getOrganisajonsnummer(),
- oppsummeringsdokument.getOpplysningspliktigOrganisajonsnummer(),
- person.getIdent()
- )).collect(Collectors.toList())
- ))
- ))
- .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/IdentService.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/IdentService.java
deleted file mode 100644
index e2031c933f2..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/IdentService.java
+++ /dev/null
@@ -1,34 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.service;
-
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.OppsummeringsdokumentConsumer;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.OppsummeringsdokumentDTO;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.PersonDTO;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.VirksomhetDTO;
-import org.springframework.stereotype.Service;
-
-import java.util.Collection;
-import java.util.Set;
-import java.util.stream.Collectors;
-
-@Slf4j
-@Service
-@RequiredArgsConstructor
-public class IdentService {
- private final OppsummeringsdokumentConsumer arbeidsforholdConsumer;
-
- public Set getIdenterMedArbeidsforhold(String miljo) {
- var identer = arbeidsforholdConsumer
- .getAll(miljo)
- .stream()
- .map(OppsummeringsdokumentDTO::getVirksomheter)
- .flatMap(Collection::stream)
- .map(VirksomhetDTO::getPersoner)
- .flatMap(Collection::stream)
- .map(PersonDTO::getIdent)
- .collect(Collectors.toSet());
- log.info("Fant {} identer i {}.", identer.size(), miljo);
- return identer;
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/OppsummeringsdokumentService.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/OppsummeringsdokumentService.java
deleted file mode 100644
index 53b74f33547..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/OppsummeringsdokumentService.java
+++ /dev/null
@@ -1,71 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.service;
-
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.OppsummeringsdokumentConsumer;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.OppsummeringsdokumentTimeline;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.Person;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding.Arbeidsforhold;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding.Oppsummeringsdokument;
-import org.springframework.stereotype.Service;
-import reactor.core.publisher.Flux;
-
-import java.time.LocalDate;
-import java.util.HashSet;
-import java.util.List;
-import java.util.stream.Collectors;
-
-@Slf4j
-@Service
-@RequiredArgsConstructor
-public class OppsummeringsdokumentService {
-
- private final OppsummeringsdokumentConsumer oppsummeringsdokumentConsumer;
-
- public void save(Flux personer, String miljo) {
- var list = personer.collectList().block();
- save(list, miljo);
- }
-
- public void save(List personer, String miljo) {
- log.info(
- "Legger til arbeidsforhold for {}.",
- personer.stream().map(Person::getIdent).collect(Collectors.joining(", "))
- );
-
- var dates = personer
- .stream()
- .map(value -> value.getTimeline().getUpdatedDates())
- .reduce(new HashSet<>(), (sub, item) -> {
- sub.addAll(item);
- return sub;
- });
-
- dates.parallelStream()
- .flatMap(kalendermnd -> getOppdatertOppsumeringsdokument(personer, kalendermnd, miljo).stream())
- .collect(Collectors.groupingBy(Oppsummeringsdokument::getId))
- .values()
- .parallelStream()
- .map(OppsummeringsdokumentTimeline::new)
- .forEach(timeline -> timeline.applyForAll(value -> oppsummeringsdokumentConsumer.save(value.toDTO(), miljo).block()));
- }
-
- private List getOppdatertOppsumeringsdokument(List personer, LocalDate kalendermnd, String miljo) {
- log.info("Oppdaterer arbeidsforhold på opplysningspliktig...");
- var oppsummeringsdokumenter = Flux.concat(
- personer.stream()
- .flatMap(person -> person.getArbeidsforholdOn(kalendermnd).stream())
- .collect(Collectors.groupingBy(Arbeidsforhold::getOpplysningspliktig))
- .entrySet()
- .stream()
- .map(entry -> oppsummeringsdokumentConsumer.getOppsummeringsdokument(entry.getKey(), kalendermnd, miljo)
- .map(oppsummeringsdokument -> {
- oppsummeringsdokument.addAll(entry.getValue());
- return oppsummeringsdokument;
- }))
- .toList()
- ).collectList().block();
- log.info("Oppdatert {} opplysningsplikitg med nye arbeidsforhold.", oppsummeringsdokumenter.size());
- return oppsummeringsdokumenter;
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/OrganisasjonService.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/OrganisasjonService.java
deleted file mode 100644
index 120cfcc899f..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/OrganisasjonService.java
+++ /dev/null
@@ -1,47 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.service;
-
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.stream.Collectors;
-
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.GenererOrganisasjonPopulasjonConsumer;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.OppsummeringsdokumentConsumer;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.consumer.OrganisasjonConsumer;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.Organisajon;
-import no.nav.testnav.libs.dto.oppsummeringsdokumentservice.v2.OppsummeringsdokumentDTO;
-
-@Slf4j
-@Service
-@RequiredArgsConstructor
-public class OrganisasjonService {
- private final GenererOrganisasjonPopulasjonConsumer genererOrganisasjonPopulasjonConsumer;
- private final OppsummeringsdokumentConsumer oppsummeringsdokumentConsumer;
- private final OrganisasjonConsumer organisasjonConsumer;
-
- public List getOpplysningspliktigeOrganisasjoner(String miljo, boolean unused) {
- var oppsummeringsdokuments = unused ? oppsummeringsdokumentConsumer.getAll(miljo) : new ArrayList();
-
- var opplysningspliktigOrgnummer = genererOrganisasjonPopulasjonConsumer.getOpplysningspliktig(miljo);
- var list = organisasjonConsumer
- .getOrganisasjoner(opplysningspliktigOrgnummer, miljo)
- .collectList()
- .block();
- log.info("Funnet {} opplysningspliktige organiasjon(er).", list.size());
- return list
- .stream()
- .filter(value -> !oppsummeringsdokuments
- .stream()
- .map(OppsummeringsdokumentDTO::getOpplysningspliktigOrganisajonsnummer)
- .collect(Collectors.toSet())
- .contains(value)
- )
- .filter(value -> !value.getDriverVirksomheter().isEmpty())
- .map(Organisajon::new)
- .collect(Collectors.toList());
- }
-
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/OrkestratorService.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/OrkestratorService.java
deleted file mode 100644
index c442603285d..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/OrkestratorService.java
+++ /dev/null
@@ -1,19 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.service;
-
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Service;
-import reactor.core.publisher.Flux;
-
-@Service
-@RequiredArgsConstructor
-public class OrkestratorService {
- private final IdentService identService;
- private final PersonArbeidsforholdHistorkkService personArbeidsforholdHistorkkService;
- private final OppsummeringsdokumentService oppsummeringsdokumentService;
-
- public void orkestrerMedArbeidsforhold(String miljo, int months) {
- var identerMedArbeidsforhold = identService.getIdenterMedArbeidsforhold(miljo);
- var personer = personArbeidsforholdHistorkkService.generer(Flux.fromStream(identerMedArbeidsforhold.stream()), miljo, months);
- oppsummeringsdokumentService.save(personer, miljo);
- }
-}
diff --git a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/PersonArbeidsforholdHistorkkService.java b/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/PersonArbeidsforholdHistorkkService.java
deleted file mode 100644
index 890b9c49c0c..00000000000
--- a/apps/generer-arbeidsforhold-populasjon-service/src/main/java/no/nav/registre/testnav/genererarbeidsforholdpopulasjonservice/service/PersonArbeidsforholdHistorkkService.java
+++ /dev/null
@@ -1,204 +0,0 @@
-package no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.service;
-
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.Organisajon;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.Person;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.Timeline;
-import no.nav.registre.testnav.genererarbeidsforholdpopulasjonservice.domain.amelding.Arbeidsforhold;
-import org.springframework.stereotype.Service;
-import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
-
-import java.time.LocalDate;
-import java.time.Period;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-import java.util.Random;
-import java.util.Set;
-import java.util.TreeSet;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.Executor;
-import java.util.concurrent.atomic.AtomicInteger;
-
-@Slf4j
-@Service
-@RequiredArgsConstructor
-public class PersonArbeidsforholdHistorkkService {
- private final ArbeidsforholdSerivce arbeidsforholdSerivce;
- private final ArbeidsforholdHistorikkService arbeidsforholdHistorikkService;
- private final OrganisasjonService organisasjonService;
- private final Executor executor;
- private final Random random = new Random();
-
- public Flux generer(Flux identer, String miljo, int months) {
- var organisasjoner = organisasjonService.getOpplysningspliktigeOrganisasjoner(miljo, true);
- return identer.flatMap(ident -> generer(ident, miljo, months, organisasjoner));
- }
-
- public Flux generer(Flux identer, String miljo, LocalDate fom, LocalDate tom) {
- var organisasjoner = organisasjonService.getOpplysningspliktigeOrganisasjoner(miljo, false);
- return identer.flatMap(ident -> generer(ident, miljo, fom, tom, organisasjoner));
- }
-
- private Mono generer(String ident, String miljo, int months, List organisajoner) {
- var count = new AtomicInteger();
- return arbeidsforholdSerivce
- .findTimelineFor(ident, miljo)
- .flatMap(timeline -> {
- var lastDate = timeline.getLastDate();
- var person = new Person(ident, timeline);
- var previous = person.getArbeidsforholdOn(lastDate);
- var map = getArbeidsforholdMap(
- new ArrayList<>(previous),
- organisajoner,
- ident,
- findAllDatesBetween(lastDate.plusMonths(1), lastDate.plusMonths(months)).iterator()
- );
- return updatePerson(count, person, map);
- }).filter(Objects::nonNull);
- }
-
- private Mono generer(String ident, String miljo, LocalDate fom, LocalDate tom, List organisajoner) {
- var count = new AtomicInteger();
- return arbeidsforholdSerivce
- .findTimelineFor(ident, miljo)
- .flatMap(timeline -> {
- var person = new Person(ident, timeline);
- var previous = person.getArbeidsforholdOn(fom.minusMonths(1));
- var map = getArbeidsforholdMap(new ArrayList<>(previous), organisajoner, ident, findAllDatesBetween(fom, tom).iterator());
-
- return updatePerson(count, person, map);
- }).filter(Objects::nonNull);
- }
-
- private Mono updatePerson(AtomicInteger count, Person person, Mono