Merge pull request #467 from B3Partners/issue#464-1.5.2.x

Betere afhandeling van duplicaat BAG laadprocessen die door Kadaster via GDS2 (toch) geleverd worden
B3Partners · Jun 28, 2018 · e7e520d · e7e520d
2 parents 6c59373 + 88e2940
commit e7e520d
Show file tree

Hide file tree

Showing 2 changed files with 43 additions and 4 deletions.
diff --git a/brmo-loader/src/main/java/nl/b3p/brmo/loader/BrmoFramework.java b/brmo-loader/src/main/java/nl/b3p/brmo/loader/BrmoFramework.java
@@ -318,7 +318,9 @@ public void loadFromFile(String type, String fileName) throws BrmoException {
     }
 
     /**
-     * NB na gebruik zelf de database verbinding sluiten / opruimen met {@link #closeBrmoFramework()}
+     * laden van BR data uit een bestand. <br>
+     * NB na gebruik zelf de database verbinding sluiten / opruimen met
+     * {@link #closeBrmoFramework()}.
      *
      * @param type basis registratie type
      * @param fileName bestand
@@ -383,15 +385,35 @@ protected void afterRead(int n) {
         }
     }
 
-    public void loadFromStream(String type, InputStream stream, String fileName) throws BrmoException {
+    /**
+     * laden van BR data uit een stream.
+     *
+     * @param type type registratie, bijv. {@value BrmoFramework#BR_BRK}
+     * @param stream datastream
+     * @param fileName te gebruiken bestandsnaam om laadproces te identificeren
+     * @throws BrmoException als er een algemene fout optreed
+     * @throws BrmoDuplicaatLaadprocesException als het "bestand"
+     * {@code fileName} al geladen is
+     * @throws BrmoLeegBestandException als het "bestand" {@code fileName} leeg
+     * is
+     */
+    public void loadFromStream(String type, InputStream stream, String fileName)
+            throws BrmoException, BrmoDuplicaatLaadprocesException, BrmoLeegBestandException {
         try {
             stagingProxy.loadBr(stream, type, fileName, null);
-        } catch(Exception e) {
+        } catch (Exception e) {
+            if (e instanceof BrmoDuplicaatLaadprocesException) {
+                throw (BrmoDuplicaatLaadprocesException) e;
+            }
+            if (e instanceof BrmoLeegBestandException) {
+                throw (BrmoLeegBestandException) e;
+            }
             throw new BrmoException("Fout bij loaden basisregistratie gegevens", e);
         }
     }
 
     /**
+     * laden van BR data uit een stream.
      *
      * @param type type registratie, bijv. {@value BrmoFramework#BR_BRK}
      * @param stream datastream

diff --git a/brmo-service/src/main/java/nl/b3p/brmo/service/scanner/GDS2OphalenProces.java b/brmo-service/src/main/java/nl/b3p/brmo/service/scanner/GDS2OphalenProces.java
@@ -53,6 +53,8 @@
 import javax.xml.ws.handler.Handler;
 import nl.b3p.brmo.loader.BrmoFramework;
 import nl.b3p.brmo.loader.entity.BrkBericht;
+import nl.b3p.brmo.loader.util.BrmoDuplicaatLaadprocesException;
+import nl.b3p.brmo.loader.util.BrmoLeegBestandException;
 import nl.b3p.brmo.loader.xml.BrkSnapshotXMLReader;
 import nl.b3p.brmo.persistence.staging.AutomatischProces;
 import static nl.b3p.brmo.persistence.staging.AutomatischProces.LOG_NEWLINE;
@@ -506,7 +508,22 @@ private void laadBagAfgifte(AfgifteGBType a, String url) throws Exception {
                         l.updateStatus(msg);
                         l.addLog(msg);
                         log.debug(msg);
-                        brmo.loadFromStream("bag", new CloseShieldInputStream(innerzip), getLaadprocesBestandsnaam(a) + "/" + entry.getName() + "/" + innerentry.getName());
+                        try {
+                            brmo.loadFromStream(BrmoFramework.BR_BAG,
+                                    new CloseShieldInputStream(innerzip),
+                                    getLaadprocesBestandsnaam(a) + "/" + entry.getName() + "/" + innerentry.getName()
+                            );
+                        } catch (BrmoDuplicaatLaadprocesException d) {
+                            msg = "Duplicaat laadproces. " + d.getLocalizedMessage();
+                            l.updateStatus(msg);
+                            l.addLog(msg);
+                            log.warn(msg);
+                        } catch (BrmoLeegBestandException e) {
+                            msg = "Leeg bestand voor laadproces. " + e.getLocalizedMessage();
+                            l.updateStatus(msg);
+                            l.addLog(msg);
+                            log.info(msg);
+                        }
                         innerentry = innerzip.getNextEntry();
                     }
                 } else {