This commit is contained in:
parent
d9e93271b0
commit
bbd133093f
2 changed files with 7 additions and 2 deletions
|
|
@ -31,6 +31,11 @@ public class ExecutionCurrencyMapStore extends TemplateMapStore<ExecutionCurrenc
|
|||
return "EXECUTION_CURRENCY";
|
||||
}
|
||||
|
||||
@Override
|
||||
public Iterable<Long> loadAllKeys() {
|
||||
return defaultLoadAllKeysOnTodayByField("TRADING_DATE", false);
|
||||
}
|
||||
|
||||
@Override
|
||||
public String[] getFields() {
|
||||
return new String[]{
|
||||
|
|
|
|||
|
|
@ -52,8 +52,8 @@ public class RegistryMapStore extends TemplateMapStore<Registry> {
|
|||
LocalDate today = LocalDate.now();
|
||||
log.debug("loadAllKeys from {} with condition and today {}", getTableName(), today);
|
||||
List<Long> keys;
|
||||
String sql = "select id from " + getTableName() + " WHERE registry_status<>'OK' or registry_status='OK' " +
|
||||
"and (clearing_date = ? OR updated_at::date = ?)";
|
||||
String sql = "select id from " + getTableName() + " WHERE (registry_status<>'OK' and registry_status<>'CLRD') " +
|
||||
" or ((registry_status='ОК' or registry_status='CLRD') and (clearing_date = ? OR updated_at::date = ?))";
|
||||
try {
|
||||
keys = jdbcTemplate.query(sql,
|
||||
(resultSet, i) -> resultSet.getLong("id"),
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue