Merge remote-tracking branch 'origin/dev' into dev
This commit is contained in:
commit
1fa2fc9315
2 changed files with 2 additions and 2 deletions
|
|
@ -57,7 +57,7 @@ public class TaskListener extends QueueConsumer implements InitializingBean {
|
||||||
private final SpotOvernightOrderService spotOvernightOrderService;
|
private final SpotOvernightOrderService spotOvernightOrderService;
|
||||||
private final OrderCurrencyTriExportService orderCurrencyTriExportService;
|
private final OrderCurrencyTriExportService orderCurrencyTriExportService;
|
||||||
private final KafkaSender kafkaSender;
|
private final KafkaSender kafkaSender;
|
||||||
private final DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyymmddHHmmssSSS");
|
private final DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS");
|
||||||
private final Path storagePath;
|
private final Path storagePath;
|
||||||
private final SendOrdersTypes sendOrdersTypes;
|
private final SendOrdersTypes sendOrdersTypes;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -72,7 +72,7 @@ public class OrderCurrencyMapStore extends TemplateMapStore<OrderCurrency> {
|
||||||
log.debug("loadAllKeys from " + getTableName());
|
log.debug("loadAllKeys from " + getTableName());
|
||||||
List<Long> keys;
|
List<Long> keys;
|
||||||
try {
|
try {
|
||||||
keys = jdbcTemplate.query("select id from " + getTableName() + " where created_at = ?",
|
keys = jdbcTemplate.query("select id from " + getTableName() + " where cast(created_at as date) = ?",
|
||||||
new Object[]{LocalDate.now()},
|
new Object[]{LocalDate.now()},
|
||||||
(resultSet, i) -> resultSet.getLong("id"));
|
(resultSet, i) -> resultSet.getLong("id"));
|
||||||
} catch (Throwable e) {
|
} catch (Throwable e) {
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue