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

imdg добавление некоторых History

Browse source
This commit is contained in:
AKurakin 2023-05-31 12:28:53 +03:00
parent 7e8566cb14
commit 2527755afc
1 changed files with 56 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -11,10 +11,18 @@ import ru.clearing.classes.statics.data.account.*;
import ru.clearing.classes.statics.data.company.*; import ru.clearing.classes.statics.data.company.*;
import ru.clearing.classes.statics.data.company.relation.Relation; import ru.clearing.classes.statics.data.company.relation.Relation;
import ru.clearing.classes.statics.data.company.relation.RelationHistory; import ru.clearing.classes.statics.data.company.relation.RelationHistory;
import ru.clearing.classes.statics.data.execution.ExecutionDeposit;
import ru.clearing.classes.statics.data.execution.ExecutionDepositHistory;
import ru.clearing.classes.statics.data.execution.ExecutionFond;
import ru.clearing.classes.statics.data.execution.ExecutionFondHistory;
import ru.clearing.classes.statics.data.instrument.issue.*; import ru.clearing.classes.statics.data.instrument.issue.*;
import ru.clearing.classes.statics.data.misc.*; import ru.clearing.classes.statics.data.misc.*;
import ru.clearing.classes.statics.data.profile.ProfileDocument; import ru.clearing.classes.statics.data.profile.ProfileDocument;
import ru.clearing.classes.statics.data.profile.ProfileDocumentHistory; import ru.clearing.classes.statics.data.profile.ProfileDocumentHistory;
import ru.clearing.classes.statics.data.registry.Registry;
import ru.clearing.classes.statics.data.registry.RegistryHistory;
import ru.clearing.classes.statics.data.registry.TradingClearingRegistry;
import ru.clearing.classes.statics.data.registry.TradingClearingRegistryHistory;
import ru.clearing.classes.statics.data.security.MoneyMarketSecurity; import ru.clearing.classes.statics.data.security.MoneyMarketSecurity;
import ru.clearing.classes.statics.data.security.MoneyMarketSecurityHistory; import ru.clearing.classes.statics.data.security.MoneyMarketSecurityHistory;
import ru.clearing.classes.statics.data.security.Security; import ru.clearing.classes.statics.data.security.Security;
@ -57,6 +65,14 @@ public class UpdateMapService extends AbstractUpdateMapService {
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_Listing).addLocalEntryListener(this, Predicates.alwaysTrue(), true); hazelcastServerInstance.getMap(IMDGDistributedNames.Map_Listing).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_Market).addLocalEntryListener(this, Predicates.alwaysTrue(), true); hazelcastServerInstance.getMap(IMDGDistributedNames.Map_Market).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_Notification).addLocalEntryListener(this, Predicates.alwaysTrue(), true); hazelcastServerInstance.getMap(IMDGDistributedNames.Map_Notification).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_ClearingAccount).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_ClientCode).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_DepoAccount).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_ExecutionDeposit).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_ExecutionFond).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_Registry).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_Session).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_TradingClearingRegistry).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
} }
@Override @Override
@ -158,6 +174,46 @@ public class UpdateMapService extends AbstractUpdateMapService {
createBusinessEvent(notificationHistory, eventType); createBusinessEvent(notificationHistory, eventType);
notificationHistory.setObject((Notification) value); notificationHistory.setObject((Notification) value);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_NotificationHistory).put(notificationHistory.getId(), notificationHistory); hazelcastServerInstance.getMap(IMDGDistributedNames.Map_NotificationHistory).put(notificationHistory.getId(), notificationHistory);
} else if (value instanceof ClearingAccount) {
ClearingAccountHistory clearingAccountHistory = new ClearingAccountHistory();
createBusinessEvent(clearingAccountHistory, eventType);
clearingAccountHistory.setObject((ClearingAccount) value);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_ClearingAccountHistory).put(clearingAccountHistory.getId(), clearingAccountHistory);
} else if (value instanceof ClientCode) {
ClientCodeHistory clientCodeHistory = new ClientCodeHistory();
createBusinessEvent(clientCodeHistory, eventType);
clientCodeHistory.setObject((ClientCode) value);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_ClientCodeHistory).put(clientCodeHistory.getId(), clientCodeHistory);
} else if (value instanceof DepoAccount) {
DepoAccountHistory depoAccountHistory = new DepoAccountHistory();
createBusinessEvent(depoAccountHistory, eventType);
depoAccountHistory.setObject((DepoAccount) value);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_DepoAccountHistory).put(depoAccountHistory.getId(), depoAccountHistory);
} else if (value instanceof ExecutionDeposit) {
ExecutionDepositHistory executionDepositHistory = new ExecutionDepositHistory();
createBusinessEvent(executionDepositHistory, eventType);
executionDepositHistory.setObject((ExecutionDeposit) value);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_ExecutionDepositHistory).put(executionDepositHistory.getId(), executionDepositHistory);
} else if (value instanceof ExecutionFond) {
ExecutionFondHistory executionFondHistory = new ExecutionFondHistory();
createBusinessEvent(executionFondHistory, eventType);
executionFondHistory.setObject((ExecutionFond) value);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_ExecutionFondHistory).put(executionFondHistory.getId(), executionFondHistory);
} else if (value instanceof Registry) {
RegistryHistory registryHistory = new RegistryHistory();
createBusinessEvent(registryHistory, eventType);
registryHistory.setObject((Registry) value);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_RegistryHistory).put(registryHistory.getId(), registryHistory);
} else if (value instanceof Session) {
SessionHistory sessionHistory = new SessionHistory();
createBusinessEvent(sessionHistory, eventType);
sessionHistory.setObject((Session) value);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_SessionHistory).put(sessionHistory.getId(), sessionHistory);
} else if (value instanceof TradingClearingRegistry) {
TradingClearingRegistryHistory tradingClearingRegistryHistory = new TradingClearingRegistryHistory();
createBusinessEvent(tradingClearingRegistryHistory, eventType);
tradingClearingRegistryHistory.setObject((TradingClearingRegistry) value);
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_TradingClearingRegistry).put(tradingClearingRegistryHistory.getId(), tradingClearingRegistryHistory);
} else if (value instanceof Security) { // Существуют наследники этой таблицы, по этому в последнюю очередь делать эту проверку. } else if (value instanceof Security) { // Существуют наследники этой таблицы, по этому в последнюю очередь делать эту проверку.