From 9b2d5dbf3a15cff4d10714ba0ed25f0a056762ac Mon Sep 17 00:00:00 2001 From: ialbert Date: Tue, 4 Jul 2023 13:37:17 +0300 Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-383=20imdg?= =?UTF-8?q?=20=D0=B2=D1=8B=D0=B3=D1=80=D1=83=D0=B7=D0=BA=D0=B0=20=D0=B4?= =?UTF-8?q?=D0=B0=D0=BD=D0=BD=D1=8B=D1=85=20=D0=B7=D0=B0=20=D1=81=D0=B5?= =?UTF-8?q?=D0=B3=D0=BE=D0=B4=D0=BD=D1=8F:=20execution=5Fdeposit/execution?= =?UTF-8?q?=5Ffond=20=D0=BF=D0=BE=20trading=5Fdate=20s=5Ftrades=20=D0=BF?= =?UTF-8?q?=D0=BE=20trade=5Fdate=20statement=20=D0=BF=D0=BE=20clearing=5Fd?= =?UTF-8?q?ate=20notification=20=D0=BF=D0=BE=20clearing=5Fdate=20s=5Fdf=20?= =?UTF-8?q?=D0=BF=D0=BE=20generation=5Ftime?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../businessobject/ExecutionFondMapStore.java | 18 +++++++++++++++ .../businessobject/StatementMapStore.java | 18 +++++++++++++++ .../imdg/object/ExecutionDepositMapStore.java | 18 +++++++++++++++ .../imdg/object/NotificationMapStore.java | 18 +++++++++++++++ .../clearing/imdg/object/SDf01MapStore.java | 18 +++++++++++++++ .../clearing/imdg/object/SDf02MapStore.java | 18 +++++++++++++++ .../clearing/imdg/object/SDf03MapStore.java | 18 +++++++++++++++ .../clearing/imdg/object/SDf04MapStore.java | 18 +++++++++++++++ .../clearing/imdg/object/SDf05MapStore.java | 18 +++++++++++++++ .../clearing/imdg/object/SDf06MapStore.java | 21 ++++++++++++++++-- .../clearing/imdg/object/SDf07MapStore.java | 20 ++++++++++++++++- .../clearing/imdg/object/SDf08MapStore.java | 18 +++++++++++++++ .../clearing/imdg/object/SDf09MapStore.java | 19 +++++++++++++++- .../clearing/imdg/object/SDf10MapStore.java | 19 +++++++++++++++- .../clearing/imdg/object/SDf11MapStore.java | 19 +++++++++++++++- .../clearing/imdg/object/SDf12MapStore.java | 22 ++++++++++++++++--- .../clearing/imdg/object/SDf13MapStore.java | 19 +++++++++++++++- .../clearing/imdg/object/SDf14MapStore.java | 21 ++++++++++++++++-- .../clearing/imdg/object/SDf20MapStore.java | 20 ++++++++++++++++- .../clearing/imdg/object/SDf21MapStore.java | 21 ++++++++++++++++-- .../clearing/imdg/object/SDf51MapStore.java | 20 ++++++++++++++++- .../clearing/imdg/object/SDf52MapStore.java | 20 ++++++++++++++++- .../clearing/imdg/object/SDf53MapStore.java | 22 ++++++++++++++++--- .../clearing/imdg/object/SDf54MapStore.java | 21 ++++++++++++++++-- .../clearing/imdg/object/SDf55MapStore.java | 18 +++++++++++++++ .../clearing/imdg/object/SDf56MapStore.java | 18 +++++++++++++++ .../clearing/imdg/object/SDf57MapStore.java | 18 +++++++++++++++ .../clearing/imdg/object/STradesMapStore.java | 18 +++++++++++++++ 28 files changed, 514 insertions(+), 22 deletions(-) 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 0eb253637..7425fd1f9 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 @@ -5,11 +5,14 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.execution.ExecutionFond; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class ExecutionFondMapStore extends TemplateMapStore { @@ -39,6 +42,21 @@ public class ExecutionFondMapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where trading_date = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public ExecutionFond objectReader(ResultSet resultSet) throws SQLException { ExecutionFond object = new ExecutionFond(); 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 babef23ac..3aa257d14 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 @@ -5,11 +5,14 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.statement.Statement; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class StatementMapStore extends TemplateMapStore { @@ -35,6 +38,21 @@ 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; + } + @Override public Statement objectReader(ResultSet resultSet) throws SQLException { Statement object = new Statement(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ExecutionDepositMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ExecutionDepositMapStore.java index d59b6e4b2..909d4283f 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ExecutionDepositMapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ExecutionDepositMapStore.java @@ -5,11 +5,14 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.execution.ExecutionDeposit; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class ExecutionDepositMapStore extends TemplateMapStore { @@ -43,6 +46,21 @@ public class ExecutionDepositMapStore extends TemplateMapStore }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where trading_date = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override protected ExecutionDeposit objectReader(ResultSet resultSet) throws SQLException { ExecutionDeposit object = new ExecutionDeposit(); 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 2826683e7..251ca31c1 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 @@ -5,10 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.misc.Notification; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class NotificationMapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ 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; + } + @Override public Notification objectReader(ResultSet resultSet) throws SQLException { Notification object = new Notification(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf01MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf01MapStore.java index 027b96675..a5797bdc3 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf01MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf01MapStore.java @@ -5,10 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf01; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf01MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf01MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf01 objectReader(ResultSet resultSet) throws SQLException { SDf01 object = new SDf01(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf02MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf02MapStore.java index 1d922e122..2b911dd37 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf02MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf02MapStore.java @@ -5,10 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf02; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf02MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf02MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf02 objectReader(ResultSet resultSet) throws SQLException { SDf02 object = new SDf02(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf03MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf03MapStore.java index 2a22e089e..94ba1aded 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf03MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf03MapStore.java @@ -5,10 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf03; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf03MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf03MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf03 objectReader(ResultSet resultSet) throws SQLException { SDf03 object = new SDf03(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf04MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf04MapStore.java index 1b1ac63b5..fae30c5e5 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf04MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf04MapStore.java @@ -5,10 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf04; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf04MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf04MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf04 objectReader(ResultSet resultSet) throws SQLException { SDf04 object = new SDf04(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf05MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf05MapStore.java index 47bdfa02b..0f144567d 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf05MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf05MapStore.java @@ -5,11 +5,14 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf05; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf05MapStore extends TemplateMapStore { @@ -35,6 +38,21 @@ public class SDf05MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf05 objectReader(ResultSet resultSet) throws SQLException { SDf05 object = new SDf05(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf06MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf06MapStore.java index 94edabb33..3d59f0fb1 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf06MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf06MapStore.java @@ -2,15 +2,17 @@ package ru.spcex.clearing.imdg.object; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.clearing.classes.statics.data.sdf.SDf06; +import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; -import java.util.*; +import java.time.LocalDate; +import java.util.List; @Component public class SDf06MapStore extends TemplateMapStore { @@ -36,6 +38,21 @@ public class SDf06MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf06 objectReader(ResultSet resultSet) throws SQLException { SDf06 object = new SDf06(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf07MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf07MapStore.java index e0d5118ff..351b00f91 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf07MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf07MapStore.java @@ -2,14 +2,17 @@ package ru.spcex.clearing.imdg.object; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.clearing.classes.statics.data.sdf.SDf07; +import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf07MapStore extends TemplateMapStore { @@ -35,6 +38,21 @@ public class SDf07MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf07 objectReader(ResultSet resultSet) throws SQLException { SDf07 object = new SDf07(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf08MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf08MapStore.java index a061f133e..cda68c98d 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf08MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf08MapStore.java @@ -5,10 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf08; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf08MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf08MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf08 objectReader(ResultSet resultSet) throws SQLException { SDf08 object = new SDf08(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf09MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf09MapStore.java index f29d05c01..93b355cfa 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf09MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf09MapStore.java @@ -5,11 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf09; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; -import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf09MapStore extends TemplateMapStore { @@ -35,6 +37,21 @@ public class SDf09MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf09 objectReader(ResultSet resultSet) throws SQLException { SDf09 object = new SDf09(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf10MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf10MapStore.java index 6f5a547aa..e5f178974 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf10MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf10MapStore.java @@ -5,11 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf10; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; -import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf10MapStore extends TemplateMapStore { @@ -36,6 +38,21 @@ public class SDf10MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf10 objectReader(ResultSet resultSet) throws SQLException { SDf10 object = new SDf10(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf11MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf11MapStore.java index eed66accc..583943ad6 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf11MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf11MapStore.java @@ -5,11 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf11; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; -import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf11MapStore extends TemplateMapStore { @@ -35,6 +37,21 @@ public class SDf11MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf11 objectReader(ResultSet resultSet) throws SQLException { SDf11 object = new SDf11(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf12MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf12MapStore.java index 469d211c6..e30e85a57 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf12MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf12MapStore.java @@ -3,15 +3,16 @@ package ru.spcex.clearing.imdg.object; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.clearing.classes.statics.data.sdf.SDf12; +import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; -import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; -import java.util.*; +import java.time.LocalDate; +import java.util.List; @Component public class SDf12MapStore extends TemplateMapStore { @@ -37,6 +38,21 @@ public class SDf12MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf12 objectReader(ResultSet resultSet) throws SQLException { SDf12 object = new SDf12(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf13MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf13MapStore.java index 25c1abc6c..27920b831 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf13MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf13MapStore.java @@ -5,11 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf13; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; -import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf13MapStore extends TemplateMapStore { @@ -35,6 +37,21 @@ public class SDf13MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf13 objectReader(ResultSet resultSet) throws SQLException { SDf13 object = new SDf13(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf14MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf14MapStore.java index bb88f2dc4..bb637e692 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf14MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf14MapStore.java @@ -2,14 +2,16 @@ package ru.spcex.clearing.imdg.object; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.clearing.classes.statics.data.sdf.SDf14; +import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; -import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf14MapStore extends TemplateMapStore { @@ -35,6 +37,21 @@ public class SDf14MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf14 objectReader(ResultSet resultSet) throws SQLException { SDf14 object = new SDf14(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf20MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf20MapStore.java index 7ddf99571..374dbc9b1 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf20MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf20MapStore.java @@ -2,13 +2,16 @@ package ru.spcex.clearing.imdg.object; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.clearing.classes.statics.data.sdf.SDf20; +import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf20MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf20MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf20 objectReader(ResultSet resultSet) throws SQLException { SDf20 object = new SDf20(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf21MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf21MapStore.java index aed684cf6..827001a7d 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf21MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf21MapStore.java @@ -2,14 +2,16 @@ package ru.spcex.clearing.imdg.object; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.clearing.classes.statics.data.sdf.SDf21; +import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; -import java.util.*; +import java.time.LocalDate; +import java.util.List; @Component public class SDf21MapStore extends TemplateMapStore { @@ -35,6 +37,21 @@ public class SDf21MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf21 objectReader(ResultSet resultSet) throws SQLException { SDf21 object = new SDf21(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf51MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf51MapStore.java index b454a835d..aae6bdc90 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf51MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf51MapStore.java @@ -2,13 +2,16 @@ package ru.spcex.clearing.imdg.object; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.clearing.classes.statics.data.sdf.SDf51; +import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf51MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf51MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf51 objectReader(ResultSet resultSet) throws SQLException { SDf51 object = new SDf51(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf52MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf52MapStore.java index 10b260390..aff7a012d 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf52MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf52MapStore.java @@ -2,13 +2,16 @@ package ru.spcex.clearing.imdg.object; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.clearing.classes.statics.data.sdf.SDf52; +import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf52MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf52MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf52 objectReader(ResultSet resultSet) throws SQLException { SDf52 object = new SDf52(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf53MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf53MapStore.java index 973539f4f..7dc2b9943 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf53MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf53MapStore.java @@ -2,15 +2,16 @@ package ru.spcex.clearing.imdg.object; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.clearing.classes.statics.data.sdf.SDf53; +import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; -import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; -import java.util.*; +import java.time.LocalDate; +import java.util.List; @Component public class SDf53MapStore extends TemplateMapStore { @@ -36,6 +37,21 @@ public class SDf53MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf53 objectReader(ResultSet resultSet) throws SQLException { SDf53 object = new SDf53(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf54MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf54MapStore.java index d8ff3af72..e83604594 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf54MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf54MapStore.java @@ -2,14 +2,16 @@ package ru.spcex.clearing.imdg.object; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.clearing.classes.statics.data.sdf.SDf54; +import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; -import java.util.*; +import java.time.LocalDate; +import java.util.List; @Component public class SDf54MapStore extends TemplateMapStore { @@ -35,6 +37,21 @@ public class SDf54MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf54 objectReader(ResultSet resultSet) throws SQLException { SDf54 object = new SDf54(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf55MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf55MapStore.java index 40efb1f1f..81f1dd2c2 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf55MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf55MapStore.java @@ -5,10 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf55; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf55MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf55MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf55 objectReader(ResultSet resultSet) throws SQLException { SDf55 object = new SDf55(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf56MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf56MapStore.java index 0de660d05..efed4f0b3 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf56MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf56MapStore.java @@ -5,10 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf56; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf56MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf56MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf56 objectReader(ResultSet resultSet) throws SQLException { SDf56 object = new SDf56(); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf57MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf57MapStore.java index 8abdf9498..8ca395465 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf57MapStore.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf57MapStore.java @@ -5,10 +5,13 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.sdf.SDf57; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class SDf57MapStore extends TemplateMapStore { @@ -34,6 +37,21 @@ public class SDf57MapStore extends TemplateMapStore { }; } + @Override + public Iterable loadAllKeys() { + log.debug("loadAllKeys from " + getTableName()); + List keys; + try { + keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(generation_time as date) = ?", + new Object[]{LocalDate.now()}, + (resultSet, i) -> resultSet.getLong("id")); + } catch (Throwable e) { + log.error("{}", ExceptionUtils.getStackTrace(e)); + throw e; + } + return keys; + } + @Override public SDf57 objectReader(ResultSet resultSet) throws SQLException { SDf57 object = new SDf57(); 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 a0abb29f2..c5f3612e1 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 @@ -5,11 +5,14 @@ import org.springframework.stereotype.Component; import ru.clearing.classes.statics.data.misc.STrades; import ru.spcex.clearing.imdg.IMDGDistributedNames; import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.log.ExceptionUtils; import ru.spcex.platform.utils.time.TimeUtil; import java.math.BigDecimal; import java.sql.ResultSet; import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; @Component public class STradesMapStore extends TemplateMapStore { @@ -41,6 +44,21 @@ 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; + } + @Override public STrades objectReader(ResultSet resultSet) throws SQLException { STrades object = new STrades();