treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

imdg поправил Map_TradingClearingRegistryHistory (баг в 2527755afc), CLS-473 alt+ctrl+L SimpleObjectMapStore

Browse source
This commit is contained in:
AKurakin 2023-08-21 11:29:50 +03:00
parent 63eab63c48
commit 2ea1c4332e
2 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/base/SimpleObjectMapStore.java
View file

@ -124,7 +124,8 @@ public abstract class SimpleObjectMapStore<T extends SpcexObjectBase> implements
/** /**
* Выгружает ID по таблице по условию dateField >= today * Выгружает ID по таблице по условию dateField >= today
* @param dateField оле даты *
* @param dateField поле даты
* @return ID's * @return ID's
*/ */
public Iterable<Long> defaultLoadAllKeysOnTodayByField(String dateField) { public Iterable<Long> defaultLoadAllKeysOnTodayByField(String dateField) {
@ -132,7 +133,7 @@ public abstract class SimpleObjectMapStore<T extends SpcexObjectBase> implements
log.debug("loadAllKeys from {} on {} >= today {}", getTableName(), dateField, today); log.debug("loadAllKeys from {} on {} >= today {}", getTableName(), dateField, today);
List<Long> keys; List<Long> keys;
try { try {
keys = jdbcTemplate.query("select id from " + getTableName() + " where "+ dateField +" >= ?", keys = jdbcTemplate.query("select id from " + getTableName() + " where " + dateField + " >= ?",
(resultSet, i) -> resultSet.getLong("id"), (resultSet, i) -> resultSet.getLong("id"),
new Object[]{today}); new Object[]{today});
} catch (Throwable e) { } catch (Throwable e) {

2
clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/services/UpdateMapService.java
View file

@ -213,7 +213,7 @@ public class UpdateMapService extends AbstractUpdateMapService {
TradingClearingRegistryHistory tradingClearingRegistryHistory = new TradingClearingRegistryHistory(); TradingClearingRegistryHistory tradingClearingRegistryHistory = new TradingClearingRegistryHistory();
createBusinessEvent(tradingClearingRegistryHistory, eventType); createBusinessEvent(tradingClearingRegistryHistory, eventType);
tradingClearingRegistryHistory.setObject((TradingClearingRegistry) value); tradingClearingRegistryHistory.setObject((TradingClearingRegistry) value);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_TradingClearingRegistry).put(tradingClearingRegistryHistory.getId(), tradingClearingRegistryHistory); hazelcastServerInstance.getMap(IMDGDistributedNames.Map_TradingClearingRegistryHistory).put(tradingClearingRegistryHistory.getId(), tradingClearingRegistryHistory);
} else if (value instanceof Security) { // Существуют наследники этой таблицы, по этому в последнюю очередь делать эту проверку. } else if (value instanceof Security) { // Существуют наследники этой таблицы, по этому в последнюю очередь делать эту проверку.