From d4d544a086732996bb3bc7360e78fe9a8fe07c7c Mon Sep 17 00:00:00 2001 From: AKurakin Date: Fri, 31 Mar 2023 13:54:40 +0300 Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-252=20DDL?= =?UTF-8?q?=20=D1=8D=D1=82=D0=B0=D0=BF=201,=20=D0=BA=D0=BE=D1=80=D1=80?= =?UTF-8?q?=D0=B5=D0=BA=D1=82=D0=B8=D1=80=D0=BE=D0=B2=D0=BA=D0=B0=20MoneyM?= =?UTF-8?q?arketSecurityHistory=20-=20=D0=BF=D0=BE=D0=BA=D0=B0=20=D0=BD?= =?UTF-8?q?=D0=B5=20=D0=BD=D1=83=D0=B6=D0=B5=D0=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/resources/meta/meta.xml | 2 +- .../data/misc/MoneyMarketSecurityHistory.java | 26 ---- .../MoneyMarketSecurityHistoryMapStore.java | 113 ------------------ .../imdg/services/UpdateMapService.java | 6 - .../structure/RunnableMapNamesForTesting.java | 1 - .../clearing/imdg/IMDGDistributedNames.java | 1 - 6 files changed, 1 insertion(+), 148 deletions(-) delete mode 100644 clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/MoneyMarketSecurityHistory.java delete mode 100644 clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessevent/MoneyMarketSecurityHistoryMapStore.java diff --git a/clearing-parent/backend-api/src/main/resources/meta/meta.xml b/clearing-parent/backend-api/src/main/resources/meta/meta.xml index b77babc59..6d2512af4 100644 --- a/clearing-parent/backend-api/src/main/resources/meta/meta.xml +++ b/clearing-parent/backend-api/src/main/resources/meta/meta.xml @@ -462,7 +462,7 @@ - + diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/MoneyMarketSecurityHistory.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/MoneyMarketSecurityHistory.java deleted file mode 100644 index f24b02f70..000000000 --- a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/MoneyMarketSecurityHistory.java +++ /dev/null @@ -1,26 +0,0 @@ -package ru.clearing.classes.statics.data.misc; - -import ru.clearing.classes.ConstSerializable; -import ru.clearing.classes.objects.BusinessEvent; - -import java.io.Serial; - -/** - * DB table: MONEY_MARKET_SECURITY_HISTORY - **/ -public class MoneyMarketSecurityHistory extends BusinessEvent { - @Serial - private static final long serialVersionUID = ConstSerializable.serialVersionUID; - - private MoneyMarketSecurity object; - - @Override - public MoneyMarketSecurity getObject() { - return object; - } - - @Override - public void setObject(MoneyMarketSecurity object) { - this.object = object; - } -} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessevent/MoneyMarketSecurityHistoryMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessevent/MoneyMarketSecurityHistoryMapStore.java deleted file mode 100644 index 788d0db14..000000000 --- a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessevent/MoneyMarketSecurityHistoryMapStore.java +++ /dev/null @@ -1,113 +0,0 @@ -package ru.spcex.clearing.imdg.businessevent; - -import org.springframework.jdbc.core.JdbcTemplate; -import org.springframework.stereotype.Component; -import ru.spcex.clearing.imdg.IMDGDistributedNames; -import ru.clearing.classes.statics.data.misc.MoneyMarketSecurity; -import ru.clearing.classes.statics.data.misc.MoneyMarketSecurityHistory; -import ru.spcex.clearing.imdg.base.TemplateEventMapStore; -import ru.spcex.platform.utils.time.TimeUtil; - -import java.util.ArrayList; -import java.util.List; -import java.util.Map; - -@Component -public class MoneyMarketSecurityHistoryMapStore extends TemplateEventMapStore { - - public MoneyMarketSecurityHistoryMapStore(JdbcTemplate jdbcTemplate) { - super(jdbcTemplate); - } - - @Override - public String getMapName() { - return IMDGDistributedNames.Map_MoneyMarketSecurityHistory; - } - - @Override - public String getTableName() { - return "MONEY_MARKET_SECURITY_HISTORY"; - } - - - @Override - public String[] getFields() { - return new String[]{ - "ID", "EVENT_TIME", "EVENT_USER_ID", "EVENT_TYPE", - "MONEY_MARKET_SECURITY_ID", "SECURITY_ID", "DESCRIPTION", "START_DATE", "END_DATE", "NOMINAL_VALUE", "NOMINAL_CURRENCY", "TERM_TYPE", "LOT_SIZE"}; - } - - public String[] getFieldsSecurity() { - return new String[]{ - "ID", "EVENT_TIME", "EVENT_USER_ID", "EVENT_TYPE", - "SECURITY_ID", "CREATED_AT", "UPDATED_AT", "INSTRUMENT_TYPE", "ISSUER_ID", "SHORT_NAME", "FULL_NAME", "SHORT_NAME_ENG", "FULL_NAME_ENG", "SECURITY_SYMBOL", "ISIN", "WORKFLOW_STATUS"}; - } - - private final String insertToSecurityStatement = makeInsertSql("SECURITY", - getFieldsSecurity(), "id"); - - - @Override - protected Object[] objectToField(MoneyMarketSecurityHistory historyLog) { - MoneyMarketSecurity moneyMarketSecurity = historyLog.getObject(); - Object[] args = new Object[]{ - historyLog.getId(), - historyLog.getEventTime(), - historyLog.getUserId(), - historyLog.getEventType(), - - moneyMarketSecurity.getId(), - moneyMarketSecurity.getSecurityId(), - moneyMarketSecurity.getDescription(), - TimeUtil.toDateFromLocalDate(moneyMarketSecurity.getStartDate()), - TimeUtil.toDateFromLocalDate(moneyMarketSecurity.getEndDate()), - moneyMarketSecurity.getNominalValue(), - moneyMarketSecurity.getNominalCurrency(), - moneyMarketSecurity.getTermType(), - moneyMarketSecurity.getLotSize() - }; - return args; - } - - protected Object[] securityField(MoneyMarketSecurityHistory historyLog) { - MoneyMarketSecurity object = historyLog.getObject(); - Object[] args = new Object[]{ - historyLog.getId(), - historyLog.getEventTime(), - historyLog.getUserId(), - historyLog.getEventType(), - - object.getSecurityId(), - TimeUtil.toDateFromInstant(object.getCreated()), - TimeUtil.toDateFromInstant(object.getUpdated()), - object.getInstrumentType(), - object.getIssuerId(), - object.getShortName(), - object.getFullName(), - object.getShortNameEng(), - object.getFullNameEng(), - object.getSecuritySymbol(), - object.getIsin(), - object.getWorkflowStatus() - }; - return args; - } - - @Override - public void store(Map map) { - List moneyMarketArgs = new ArrayList<>(); - List securityArgs = new ArrayList<>(); - - for (Map.Entry entry : map.entrySet()) { - MoneyMarketSecurityHistory obj = entry.getValue(); - Object[] args = objectToField(obj); - if (args.length != validateSize) { - throw new IllegalArgumentException("objectToField return " + args.length + " arguments, but expected " + validateSize); - } - moneyMarketArgs.add(args); - securityArgs.add(securityField(obj)); - } - batchInsertUpdate(insertStatement, moneyMarketArgs); - batchInsertUpdate(insertToSecurityStatement, securityArgs); - } -} 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 0b19a6a84..2f4058cde 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 @@ -43,7 +43,6 @@ public class UpdateMapService extends AbstractUpdateMapService { hazelcastServerInstance.getMap(IMDGDistributedNames.Map_UserConnect).addLocalEntryListener(this, Predicates.alwaysTrue(), true); hazelcastServerInstance.getMap(IMDGDistributedNames.Map_User).addLocalEntryListener(this, Predicates.alwaysTrue(), true); hazelcastServerInstance.getMap(IMDGDistributedNames.Map_Currency).addLocalEntryListener(this, Predicates.alwaysTrue(), true); - hazelcastServerInstance.getMap(IMDGDistributedNames.Map_MoneyMarketSecurity).addLocalEntryListener(this, Predicates.alwaysTrue(), true); hazelcastServerInstance.getMap(IMDGDistributedNames.Map_Listing).addLocalEntryListener(this, Predicates.alwaysTrue(), true); hazelcastServerInstance.getMap(IMDGDistributedNames.Map_MarketHistory).addLocalEntryListener(this, Predicates.alwaysTrue(), true); } @@ -102,11 +101,6 @@ public class UpdateMapService extends AbstractUpdateMapService { createBusinessEvent(currencyHistory, eventType); currencyHistory.setObject((Currency) value); hazelcastServerInstance.getMap(IMDGDistributedNames.Map_CurrencyHistory).put(currencyHistory.getId(), currencyHistory); - } else if (value instanceof MoneyMarketSecurity) { - MoneyMarketSecurityHistory moneyMarketSecurityHistory = new MoneyMarketSecurityHistory(); - createBusinessEvent(moneyMarketSecurityHistory, eventType); - moneyMarketSecurityHistory.setObject((MoneyMarketSecurity) value); - hazelcastServerInstance.getMap(IMDGDistributedNames.Map_MoneyMarketSecurityHistory).put(moneyMarketSecurityHistory.getId(), moneyMarketSecurityHistory); } else if (value instanceof Listing) { ListingHistory listingHistory = new ListingHistory(); createBusinessEvent(listingHistory, eventType); diff --git a/clearing-parent/imdg/src/test/java/ru/spcex/clearing/imdg/structure/RunnableMapNamesForTesting.java b/clearing-parent/imdg/src/test/java/ru/spcex/clearing/imdg/structure/RunnableMapNamesForTesting.java index 130716b0d..4f91b9c9d 100644 --- a/clearing-parent/imdg/src/test/java/ru/spcex/clearing/imdg/structure/RunnableMapNamesForTesting.java +++ b/clearing-parent/imdg/src/test/java/ru/spcex/clearing/imdg/structure/RunnableMapNamesForTesting.java @@ -69,7 +69,6 @@ public class RunnableMapNamesForTesting { businessObjectAndBusinessEventForCheckMapStores.add(new BusinessObjectAndBusinessEventForCheckMapStore<>(IMDGDistributedNames.Map_UserConnectHistory, UserConnectHistory.class)); businessObjectAndBusinessEventForCheckMapStores.add(new BusinessObjectAndBusinessEventForCheckMapStore<>(IMDGDistributedNames.Map_UserHistory, UserHistory.class)); businessObjectAndBusinessEventForCheckMapStores.add(new BusinessObjectAndBusinessEventForCheckMapStore<>(IMDGDistributedNames.Map_CurrencyHistory, CurrencyHistory.class)); - businessObjectAndBusinessEventForCheckMapStores.add(new BusinessObjectAndBusinessEventForCheckMapStore<>(IMDGDistributedNames.Map_MoneyMarketSecurityHistory, MoneyMarketSecurityHistory.class)); businessObjectAndBusinessEventForCheckMapStores.add(new BusinessObjectAndBusinessEventForCheckMapStore<>(IMDGDistributedNames.Map_ListingHistory, ListingHistory.class)); businessObjectAndBusinessEventForCheckMapStores.add(new BusinessObjectAndBusinessEventForCheckMapStore<>(IMDGDistributedNames.Map_MarketHistory, MarketHistory.class)); diff --git a/platform-parent/platform-imdg-api/src/main/java/ru/spcex/clearing/imdg/IMDGDistributedNames.java b/platform-parent/platform-imdg-api/src/main/java/ru/spcex/clearing/imdg/IMDGDistributedNames.java index 6d3753ba8..6ddba6e78 100644 --- a/platform-parent/platform-imdg-api/src/main/java/ru/spcex/clearing/imdg/IMDGDistributedNames.java +++ b/platform-parent/platform-imdg-api/src/main/java/ru/spcex/clearing/imdg/IMDGDistributedNames.java @@ -126,7 +126,6 @@ public final class IMDGDistributedNames { public static final String Map_ShareTypeDictionary = "Map_ShareTypeDictionary"; public static final String Map_BondTypeDictionary = "Map_BondTypeDictionary"; public static final String Map_CurrencyHistory = "Map_CurrencyHistory"; - public static final String Map_MoneyMarketSecurityHistory = "Map_MoneyMarketSecurityHistory"; public static final String Map_EquitySecurity = "Map_EquitySecurity"; public static final String Map_FixedIncomeSecurity = "Map_FixedIncomeSecurity"; public static final String Map_FixedIncomeCashFlow = "Map_FixedIncomeCashFlow";