Sjekke ved migrering (#2467)

navikt · Feb 20, 2024 · bcfa6d2 · bcfa6d2
1 parent 9a38f00
commit bcfa6d2
Show file tree

Hide file tree

Showing 2 changed files with 43 additions and 5 deletions.
diff --git a/pom.xml b/pom.xml
@@ -6,7 +6,7 @@
     <parent>
         <groupId>no.nav.foreldrepenger.felles</groupId>
         <artifactId>fp-bom</artifactId>
-        <version>3.1.0</version>
+        <version>3.1.1</version>
     </parent>
 
     <groupId>no.nav.foreldrepenger.fordel</groupId>
@@ -36,15 +36,15 @@
 
         <felles.version>7.0.4</felles.version>
         <prosesstask.version>5.0.4</prosesstask.version>
-        <fp-kontrakter.version>9.0.3</fp-kontrakter.version>
+        <fp-kontrakter.version>9.1.3</fp-kontrakter.version>
     </properties>
 
     <dependencyManagement>
         <dependencies>
             <dependency>
                 <groupId>no.nav.foreldrepenger.felles</groupId>
                 <artifactId>fp-bom</artifactId>
-                <version>3.1.0</version>
+                <version>3.1.1</version>
                 <scope>import</scope>
                 <type>pom</type>
             </dependency>
@@ -141,7 +141,7 @@
             <dependency>
                 <groupId>io.confluent</groupId>
                 <artifactId>kafka-streams-avro-serde</artifactId>
-                <version>7.5.3</version>
+                <version>7.6.0</version>
             </dependency>
         </dependencies>
     </dependencyManagement>

diff --git a/...ava/no/nav/foreldrepenger/fordel/web/app/forvaltning/migrering/MigreringRestTjeneste.java b/...ava/no/nav/foreldrepenger/fordel/web/app/forvaltning/migrering/MigreringRestTjeneste.java
@@ -2,7 +2,9 @@
 
 import static jakarta.ws.rs.core.MediaType.APPLICATION_JSON;
 
+import java.util.HashSet;
 import java.util.function.Function;
+import java.util.stream.Collectors;
 
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
@@ -72,6 +74,24 @@ public Response lesOppgaver() {
         return Response.ok(respons).build();
     }
 
+    @POST
+    @Operation(description = "Sammenligner oppgaver som skal migreres", tags = "Forvaltning",
+        summary = ("Sammenligner oppgaver som skal migreres"),
+        responses = {@ApiResponse(responseCode = "200", description = "Oppgaver")})
+    @Path("/sammenlignOppgaver")
+    @BeskyttetRessurs(actionType = ActionType.READ, resourceType = ResourceType.DRIFT)
+    public Response sammenlignOppgaver(@TilpassetAbacAttributt(supplierClass = MigreringAbacSupplier.class)
+                                  @NotNull @Parameter(name = "oppgaver") @Valid MigreringOppgaveDto oppgaver) {
+        var rmap = oppgaver.oppgaver().stream()
+            .map(MigreringMapper::fraOppgaveDto)
+            .collect(Collectors.toList());
+        var lokale = oppgaveRepository.hentAlleÅpneOppgaver().stream()
+            .map(MigreringMapper::tilOppgaveDto)
+            .collect(Collectors.toSet());
+        var remote = new HashSet<>(oppgaver.oppgaver());
+        return lokale.size() == remote.size() && lokale.containsAll(remote) ? Response.ok().build() : Response.status(Response.Status.NOT_FOUND).build();
+    }
+
     @POST
     @Operation(description = "Lagrer oppgaver som skal migreres", tags = "Forvaltning",
         summary = ("Lagre oppgaver som skal migreres"),
@@ -90,7 +110,7 @@ public Response lagreOppgaver(@TilpassetAbacAttributt(supplierClass = MigreringA
     @Operation(description = "Lagre lokale journalposter som skal migreres", tags = "Forvaltning",
         summary = ("Lagre lokale journalposter som skal migreres"),
         responses = {@ApiResponse(responseCode = "200", description = "Journalposter")})
-    @Path("/lagreTasks")
+    @Path("/lagreJournal")
     @BeskyttetRessurs(actionType = ActionType.READ, resourceType = ResourceType.DRIFT)
     public Response lagreJournal(@TilpassetAbacAttributt(supplierClass = MigreringAbacSupplier.class)
                                    @NotNull @Parameter(name = "journalposter") @Valid MigreringJournalpostDto journalposter) {
@@ -100,6 +120,24 @@ public Response lagreJournal(@TilpassetAbacAttributt(supplierClass = MigreringAb
         return Response.ok().build();
     }
 
+    @POST
+    @Operation(description = "Sammenligne lokale journalposter som skal migreres", tags = "Forvaltning",
+        summary = ("Sammenligne lokale journalposter som skal migreres"),
+        responses = {@ApiResponse(responseCode = "200", description = "Journalposter")})
+    @Path("/sammenlignJournal")
+    @BeskyttetRessurs(actionType = ActionType.READ, resourceType = ResourceType.DRIFT)
+    public Response sammenlignJournal(@TilpassetAbacAttributt(supplierClass = MigreringAbacSupplier.class)
+                                 @NotNull @Parameter(name = "journalposter") @Valid MigreringJournalpostDto journalposter) {
+        var rmap = journalposter.journalposter().stream()
+            .map(MigreringMapper::fraJournalpostDto)
+            .collect(Collectors.toList());
+        var lokale = dokumentRepository.hentAlleJournalposter().stream()
+            .map(MigreringMapper::tilJournalpostDto)
+            .collect(Collectors.toSet());
+        var remote = new HashSet<>(journalposter.journalposter());
+        return lokale.size() == remote.size() && lokale.containsAll(remote) ? Response.ok().build() : Response.status(Response.Status.NOT_FOUND).build();
+    }
+
     @GET
     @Operation(description = "Leser ut lokale journalposter som skal migreres", tags = "Forvaltning",
         summary = ("Leser ut lokale journalposter som skal migreres"),