diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/base/SimpleObjectMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/base/SimpleObjectMapStore.java index d6ac4af8b..6a2bd0105 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/base/SimpleObjectMapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/base/SimpleObjectMapStore.java @@ -126,14 +126,15 @@ public abstract class SimpleObjectMapStore implements * Выгружает ID по таблице по условию dateField >= today * * @param dateField поле даты + * @param canBeGreat true - используется условие >= today, иначе строгое = * @return ID's */ - public Iterable defaultLoadAllKeysOnTodayByField(String dateField) { + public Iterable defaultLoadAllKeysOnTodayByField(String dateField, boolean canBeGreat) { LocalDate today = LocalDate.now(); - log.debug("loadAllKeys from {} on {} >= today {}", getTableName(), dateField, today); + log.debug("loadAllKeys from {} on {} {} today", getTableName(), dateField, canBeGreat ? ">=" : "="); List keys; try { - keys = jdbcTemplate.query("select id from " + getTableName() + " where " + dateField + " >= ?", + keys = jdbcTemplate.query("select id from " + getTableName() + " where " + dateField + (canBeGreat ? " >= ?" : " = ?"), (resultSet, i) -> resultSet.getLong("id"), new Object[]{today}); } catch (Throwable e) { @@ -144,7 +145,7 @@ public abstract class SimpleObjectMapStore implements } public Iterable defaultLoadAllKeysOnTodayByTradingDate() { - return defaultLoadAllKeysOnTodayByField("trading_date"); + return defaultLoadAllKeysOnTodayByField("trading_date", false); } protected void batchInsertUpdate(@NonNull String insertStatement, @NonNull List args) { diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/ExecutionFondMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/ExecutionFondMapStore.java index 1cee4c879..e240ce865 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/ExecutionFondMapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/ExecutionFondMapStore.java @@ -37,7 +37,7 @@ public class ExecutionFondMapStore extends TemplateMapStore { @Override public Iterable loadAllKeys() { - return defaultLoadAllKeysOnTodayByField("SETTLEMENT_DATE"); + return defaultLoadAllKeysOnTodayByField("SETTLEMENT_DATE", true); } @Override diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/StatementMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/StatementMapStore.java index 3aa257d14..b0a10bc88 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/StatementMapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/StatementMapStore.java @@ -40,17 +40,7 @@ public class StatementMapStore extends TemplateMapStore { @Override public Iterable loadAllKeys() { - log.debug("loadAllKeys from " + getTableName()); - List keys; - try { - keys = jdbcTemplate.query("select id from " + getTableName() + " where clearing_date = ?", - new Object[]{LocalDate.now()}, - (resultSet, i) -> resultSet.getLong("id")); - } catch (Throwable e) { - log.error("{}", ExceptionUtils.getStackTrace(e)); - throw e; - } - return keys; + return defaultLoadAllKeysOnTodayByField("clearing_date", false); } @Override diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/NotificationMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/NotificationMapStore.java index 251ca31c1..dd137918d 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/NotificationMapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/NotificationMapStore.java @@ -39,17 +39,7 @@ public class NotificationMapStore extends TemplateMapStore { @Override public Iterable loadAllKeys() { - log.debug("loadAllKeys from " + getTableName()); - List keys; - try { - keys = jdbcTemplate.query("select id from " + getTableName() + " where clearing_date = ?", - new Object[]{LocalDate.now()}, - (resultSet, i) -> resultSet.getLong("id")); - } catch (Throwable e) { - log.error("{}", ExceptionUtils.getStackTrace(e)); - throw e; - } - return keys; + return defaultLoadAllKeysOnTodayByField("clearing_date", false); } @Override diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/STradesMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/STradesMapStore.java index c5f3612e1..6a8c95582 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/STradesMapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/STradesMapStore.java @@ -46,17 +46,7 @@ public class STradesMapStore extends TemplateMapStore { @Override public Iterable loadAllKeys() { - log.debug("loadAllKeys from " + getTableName()); - List keys; - try { - keys = jdbcTemplate.query("select id from " + getTableName() + " where trade_date = ?", - new Object[]{LocalDate.now()}, - (resultSet, i) -> resultSet.getLong("id")); - } catch (Throwable e) { - log.error("{}", ExceptionUtils.getStackTrace(e)); - throw e; - } - return keys; + return defaultLoadAllKeysOnTodayByField("trade_date", false); } @Override