diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/services/UpdateMapService.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/services/UpdateMapService.java index 19d300c15..b7c49e858 100644 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/services/UpdateMapService.java +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/services/UpdateMapService.java @@ -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.relation.Relation; 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.misc.*; import ru.clearing.classes.statics.data.profile.ProfileDocument; 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.MoneyMarketSecurityHistory; 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_Market).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 @@ -158,6 +174,46 @@ public class UpdateMapService extends AbstractUpdateMapService { createBusinessEvent(notificationHistory, eventType); notificationHistory.setObject((Notification) value); 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) { // Существуют наследники этой таблицы, по этому в последнюю очередь делать эту проверку.