From ceaed29fa5ca6e4f4edc10b2d41898a159dab77a Mon Sep 17 00:00:00 2001
From: Mark Prins <1165786+mprins@users.noreply.github.com>
Date: Tue, 26 Nov 2024 14:19:00 +0100
Subject: [PATCH] BRMO-374: opruimen ongebruikte functie om BRK
verwijderberichten te herhalen
---
.../stripes/AdvancedFunctionsActionBean.java | 138 +-----------------
1 file changed, 2 insertions(+), 136 deletions(-)
diff --git a/brmo-service/src/main/java/nl/b3p/brmo/service/stripes/AdvancedFunctionsActionBean.java b/brmo-service/src/main/java/nl/b3p/brmo/service/stripes/AdvancedFunctionsActionBean.java
index 2516be819a..d1ebfbf1e5 100644
--- a/brmo-service/src/main/java/nl/b3p/brmo/service/stripes/AdvancedFunctionsActionBean.java
+++ b/brmo-service/src/main/java/nl/b3p/brmo/service/stripes/AdvancedFunctionsActionBean.java
@@ -458,7 +458,6 @@ public void cleanupBerichten(String config, String soort) throws Exception {
}
public void deleteBerichten(String config, String soort) throws Exception {
- final MutableInt processed = new MutableInt(0);
final DataSource dataSourceStaging = ConfigUtil.getDataSourceStaging();
final Connection conn = dataSourceStaging.getConnection();
final GeometryJdbcConverter geomToJdbc =
@@ -637,143 +636,10 @@ public void replayNHRVerwerking(String soort, String status)
rsgb.close();
}
- /**
- * Deze actie loopt door de lijst brk verwijderberichten (={@code } br_xml) met status
- * RSGB_OK om ze nogmaals naar de rsgb te transformeren.
- *
- * @param status bericht status
- * @param soort soort bericht
- * @throws SQLException if any
- * @throws BrmoException if any
- * @throws Exception if any
- */
- public void replayBRKVerwijderBerichten(String soort, String status)
- throws SQLException, BrmoException, Exception {
- int offset = 0;
- int batch = 1000;
- final MutableInt processed = new MutableInt(0);
- final DataSource dataSourceStaging = ConfigUtil.getDataSourceStaging();
- final DataSource dataSourceRsgb = ConfigUtil.getDataSourceRsgb();
- final Connection conn = dataSourceStaging.getConnection();
- final GeometryJdbcConverter geomToJdbc =
- GeometryJdbcConverterFactory.getGeometryJdbcConverter(conn);
- final RowProcessor processor = new StagingRowHandler();
-
- LOG.debug("staging datasource: " + dataSourceStaging);
- LOG.debug("rsgb datasource: " + dataSourceRsgb);
-
- String countsql =
- "select count(id) from "
- + BrmoFramework.BERICHT_TABLE
- + " where soort='"
- + soort
- + "'"
- + " and status='"
- + status
- + "'"
- // gebruik like (en niet =) omdat anders ORA-00932 want br_xml is clob
- + " and br_xml like ''";
- LOG.debug("SQL voor tellen van berichten batch: " + countsql);
- Number o =
- new QueryRunner(geomToJdbc.isPmdKnownBroken()).query(conn, countsql, new ScalarHandler<>());
- LOG.debug("Totaal te verwerken verwijder berichten: " + o);
-
- if (o instanceof BigDecimal) {
- total(o.longValue());
- } else if (o instanceof Integer) {
- total(o.longValue());
- } else {
- total((Long) o);
- }
-
- StagingProxy staging = new StagingProxy(dataSourceStaging);
- RsgbProxy rsgb = new RsgbProxy(dataSourceRsgb, null, staging, Bericht.STATUS.RSGB_OK, this);
- rsgb.setOrderBerichten(true);
- rsgb.init();
-
- do {
- LOG.debug(String.format("Ophalen berichten batch met offset %d, limit %d", offset, batch));
- String sql =
- "select * from "
- + BrmoFramework.BERICHT_TABLE
- + " where soort='"
- + soort
- + "'"
- + " and status='"
- + status
- + "'"
- + " and br_xml like ''"
- + " order by id";
- sql = geomToJdbc.buildPaginationSql(sql, offset, batch);
- LOG.debug("SQL voor ophalen berichten batch: " + sql);
-
- processed.setValue(0);
- Exception e =
- new QueryRunner(geomToJdbc.isPmdKnownBroken())
- .query(
- conn,
- sql,
- rs -> {
- while (rs.next()) {
- try {
- Bericht bericht = processor.toBean(rs, Bericht.class);
- LOG.debug("Opnieuw verwerken van bericht: " + bericht);
- // bewaar oude log
- String oudeOpmerkingen = bericht.getOpmerking();
- // forceer verwerking door bericht op STAGING_OK te
- // zetten en dan opnieuw te verwerken
- bericht.setStatus(Bericht.STATUS.STAGING_OK);
- new QueryRunner(geomToJdbc.isPmdKnownBroken())
- .update(
- conn,
- "update "
- + BrmoFramework.BERICHT_TABLE
- + " set status_datum = ?, status = ? where id = ?",
- new Timestamp(bericht.getStatusDatum().getTime()),
- bericht.getStatus().toString(),
- bericht.getId());
-
- rsgb.handle(bericht, rsgb.transformToTableData(bericht), true);
-
- bericht.setOpmerking(
- "Opnieuw verwerkt met geavanceerde functies optie.\nNieuwe verwerkingslog (oude log daaronder)\n"
- + bericht.getOpmerking()
- + "\n\nOude verwerkingslog\n\n"
- + oudeOpmerkingen);
- bericht.setStatusDatum(new Date());
- new QueryRunner(geomToJdbc.isPmdKnownBroken())
- .update(
- conn,
- "update "
- + BrmoFramework.BERICHT_TABLE
- + " set opmerking = ? where id = ?",
- bericht.getOpmerking(),
- bericht.getId());
- } catch (Exception e1) {
- return e1;
- }
- processed.increment();
- }
- return null;
- });
- offset += processed.intValue();
-
- progress(offset);
-
- // If handler threw exception processing row, rethrow it
- if (e != null) {
- closeQuietly(conn);
- throw e;
- }
- } while (processed.intValue() > 0);
- closeQuietly(conn);
- rsgb.close();
- }
-
/**
* Verwijderen van enkele aanhalingstekens van typering en clazz van sommige nHR persoon records
- * dmv SQL update. fix voor issue #527, {@code 'INGESCHREVEN NIET-NATUURLIJK PERSOON'} moet worden
- * {@code INGESCHREVEN NIET-NATUURLIJK PERSOON} (evt. afgekort op 35 char voor de
+ * door middel van SQL update. Fix voor issue #527, {@code 'INGESCHREVEN NIET-NATUURLIJK PERSOON'}
+ * moet worden {@code INGESCHREVEN NIET-NATUURLIJK PERSOON} (evt. afgekort op 35 char voor de
* 'ingeschr_niet_nat_prs' tabel/'typering' kolom)
*
* @param soort soort bericht