[BRMO-227] BRK2 directory scanner proces en bestanden laden via voorp…

…agina
B3Partners · Nov 24, 2022 · f9f1e75 · f9f1e75
1 parent a20f1d4
commit f9f1e75
Show file tree

Hide file tree

Showing 11 changed files with 374 additions and 18 deletions.
diff --git a/brmo-persistence/src/main/java/nl/b3p/brmo/persistence/staging/BRK2ScannerProces.java b/brmo-persistence/src/main/java/nl/b3p/brmo/persistence/staging/BRK2ScannerProces.java
@@ -0,0 +1,19 @@
+/*
+ * Copyright (C) 2022 B3Partners B.V.
+ *
+ * SPDX-License-Identifier: MIT
+ *
+ */
+package nl.b3p.brmo.persistence.staging;
+
+import javax.persistence.Entity;
+
+/**
+ * Proces configuratie voor de BRK 2 directory scanner.
+ *
+ * @author mprins
+ */
+@Entity
+public class BRK2ScannerProces extends DirectoryScannerProces {
+
+}
diff --git a/brmo-persistence/src/main/resources/META-INF/persistence.xml b/brmo-persistence/src/main/resources/META-INF/persistence.xml
@@ -10,6 +10,7 @@
         <class>nl.b3p.brmo.persistence.staging.Bericht</class>
         <class>nl.b3p.brmo.persistence.staging.LaadProces</class>
         <class>nl.b3p.brmo.persistence.staging.BRKScannerProces</class>
+        <class>nl.b3p.brmo.persistence.staging.BRK2ScannerProces</class>
         <class>nl.b3p.brmo.persistence.staging.AutomatischProces</class>
         <class>nl.b3p.brmo.persistence.staging.NHRInschrijving</class>
         <properties>
@@ -31,6 +32,7 @@
         <class>nl.b3p.brmo.persistence.staging.Bericht</class>
         <class>nl.b3p.brmo.persistence.staging.LaadProces</class>
         <class>nl.b3p.brmo.persistence.staging.BRKScannerProces</class>
+        <class>nl.b3p.brmo.persistence.staging.BRK2ScannerProces</class>
         <class>nl.b3p.brmo.persistence.staging.AutomatischProces</class>
         <class>nl.b3p.brmo.persistence.staging.NHRInschrijving</class>
         <properties>

diff --git a/...istence/staging/BRKScannerProcesTest.java → ...stence/staging/BRK2ScannerProcesTest.java b/...istence/staging/BRKScannerProcesTest.java → ...stence/staging/BRK2ScannerProcesTest.java
@@ -14,21 +14,21 @@
  *
  * @author mprins
  */
-public class BRKScannerProcesTest extends TestUtil {
+public class BRK2ScannerProcesTest extends TestUtil {
 
     /**
      * round trip test van maken, opslaan en uitlezen van een BRKScannerProces.
      */
     @Test
     public void roundtrip() {
-        BRKScannerProces p = new BRKScannerProces();
+        BRK2ScannerProces p = new BRK2ScannerProces();
         p.setScanDirectory(DIR);
         p.getConfig().put("isActive", new ClobElement("true"));
         entityManager.persist(p);
 
         final long id = p.getId();
 
-        BRKScannerProces c = entityManager.find(BRKScannerProces.class, id);
+        BRK2ScannerProces c = entityManager.find(BRK2ScannerProces.class, id);
         assertEquals(DIR, c.getScanDirectory(), "De directory is zoals geconfigureerd.");
         assertEquals("true", c.getConfig().get("isActive").getValue(), "Verwacht dat de parameter is zoals geconfigureerd.");
 
@@ -41,12 +41,12 @@ public void roundtrip() {
      */
     @Test
     public void testUpdateSamenvattingEnLogfile() {
-        BRKScannerProces p = new BRKScannerProces();
+        BRK2ScannerProces p = new BRK2ScannerProces();
         p.updateSamenvattingEnLogfile(NAAM_BESCHIJVING);
         entityManager.persist(p);
         final long id = p.getId();
 
-        BRKScannerProces c = entityManager.find(BRKScannerProces.class, id);
+        BRK2ScannerProces c = entityManager.find(BRK2ScannerProces.class, id);
         assertEquals(c.getLogfile(), c.getSamenvatting(), "Verwacht dat de logfile en de samenvatting hetzelfde zijn.");
 
         c.updateSamenvattingEnLogfile(NAAM);

diff --git a/brmo-persistence/src/test/java/nl/b3p/brmo/persistence/staging/MailRapportageProcesTest.java b/brmo-persistence/src/test/java/nl/b3p/brmo/persistence/staging/MailRapportageProcesTest.java
@@ -70,15 +70,15 @@ public void testRapportageLijst() {
         entityManager.persist(p);
         final long pId = p.getId();
 
-        BRKScannerProces p2 = new BRKScannerProces();
+        BRK2ScannerProces p2 = new BRK2ScannerProces();
         p2.setScanDirectory(DIR);
         p2.getConfig().put("isActive", new ClobElement("true"));
         p2.setStatus(AutomatischProces.ProcessingStatus.ERROR);
         p2.setSamenvatting(NAAM_BESCHIJVING);
         entityManager.persist(p2);
         final long pId2 = p2.getId();
 
-        BRKScannerProces p3 = new BRKScannerProces();
+        BRK2ScannerProces p3 = new BRK2ScannerProces();
         p3.setScanDirectory(DIR);
         p3.getConfig().put("isActive", new ClobElement("true"));
         p3.setStatus(AutomatischProces.ProcessingStatus.WAITING);

diff --git a/brmo-persistence/src/test/resources/META-INF/persistence.xml b/brmo-persistence/src/test/resources/META-INF/persistence.xml
@@ -10,6 +10,7 @@
         <class>nl.b3p.brmo.persistence.staging.Bericht</class>
         <class>nl.b3p.brmo.persistence.staging.LaadProces</class>
         <class>nl.b3p.brmo.persistence.staging.BRKScannerProces</class>
+        <class>nl.b3p.brmo.persistence.staging.BRK2ScannerProces</class>
         <class>nl.b3p.brmo.persistence.staging.AutomatischProces</class>
         <class>nl.b3p.brmo.persistence.staging.MailRapportageProces</class>
         <class>nl.b3p.brmo.persistence.staging.BAGScannerProces</class>
@@ -39,6 +40,7 @@
         <class>nl.b3p.brmo.persistence.staging.Bericht</class>
         <class>nl.b3p.brmo.persistence.staging.LaadProces</class>
         <class>nl.b3p.brmo.persistence.staging.BRKScannerProces</class>
+        <class>nl.b3p.brmo.persistence.staging.BRK2ScannerProces</class>
         <class>nl.b3p.brmo.persistence.staging.AutomatischProces</class>
         <class>nl.b3p.brmo.persistence.staging.MailRapportageProces</class>
         <class>nl.b3p.brmo.persistence.staging.BAGScannerProces</class>
@@ -77,6 +79,7 @@
         <class>nl.b3p.brmo.persistence.staging.Bericht</class>
         <class>nl.b3p.brmo.persistence.staging.LaadProces</class>
         <class>nl.b3p.brmo.persistence.staging.BRKScannerProces</class>
+        <class>nl.b3p.brmo.persistence.staging.BRK2ScannerProces</class>
         <class>nl.b3p.brmo.persistence.staging.AutomatischProces</class>
         <class>nl.b3p.brmo.persistence.staging.MailRapportageProces</class>
         <class>nl.b3p.brmo.persistence.staging.BAGScannerProces</class>

diff --git a/brmo-service/src/main/java/nl/b3p/brmo/service/scanner/AbstractExecutableProces.java b/brmo-service/src/main/java/nl/b3p/brmo/service/scanner/AbstractExecutableProces.java
@@ -47,6 +47,8 @@ public static ProcesExecutable getProces(AutomatischProces config) {
                 return new BAG2MutatieProcesRunner((BAG2MutatieProces) config);
             case BAGScannerProces:
                 return new BAGDirectoryScanner((BAGScannerProces) config);
+            case BRK2ScannerProces:
+                return new BRK2DirectoryScanner((BRK2ScannerProces) config);
             case BRKScannerProces:
                 return new BRKDirectoryScanner((BRKScannerProces) config);
             case MailRapportageProces:
@@ -118,7 +120,7 @@ public void run() {
      * <pre>
      * loadFromFile(bericht)
      * 	→ stagingProxy.loadBr(InputStream stream, String type, String fileName,...)
-     * 	→ snapshot reader van de input stream parsed het bericht in een BrkSnapshotXMLReader of BagMutatieXMLReader die bericht voor bericht uitgelezen kunnen worden
+     * 	→ snapshot reader van de input stream parsed het bericht in een BrkSnapshotXMLReader, Brk2SnapshotXMLReader of BagMutatieXMLReader die bericht voor bericht uitgelezen kunnen worden
      * 	→ bepaal of laadproces bestaat stagingProxy.laadProcesExists(filenaam/datum)
      * 	→ laadproces in database maken stagingProxy.writeLaadProces(bestand_naam/bestand_datum/soort/gebied/opmerking/status/status_datum/contact_email)
      * 	→ uitlezen xml bericht als
@@ -127,11 +129,9 @@ public void run() {
      * </pre>
      *
      * @param input een input bestand
-     * @param soort het type registratie, bijvoorbeeld
-     * {@value nl.b3p.brmo.loader.BrmoFramework#BR_BRK}
+     * @param soort het type registratie, bijvoorbeeld {@value nl.b3p.brmo.loader.BrmoFramework#BR_BRK2}
      *
-     * @return {@code true} als het bestand een duplicaat betreft, anders
-     * {@code false}
+     * @return {@code true} als het bestand een duplicaat betreft, anders {@code false}
      *
      */
     protected boolean isDuplicaatLaadProces(File input, String soort) {