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

http://jira.mfd.msk:8088/browse/CLS-522

Browse source
This commit is contained in:
etreschenkov 2023-10-18 12:04:27 +03:00
parent 63d0a12f55
commit 41ce70416c
16 changed files with 500 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/index/SearchProxyDepoPaymentInstructionRegister.java Normal file
View file

@ -0,0 +1,19 @@
package ru.spcex.clearing.historyimdg.index;
import ru.spcex.clearing.historyimdg.index.field.SearchWithCreated;
import java.time.Instant;
public class SearchProxyDepoPaymentInstructionRegister extends SearchProxy implements SearchWithCreated {
private Instant created;
@Override
public Instant getCreated() {
return created;
}
@Override
public void setCreated(Instant created) {
this.created = created;
}
}

19
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/index/SearchProxyExcludeLiabilitiesRegister.java Normal file
View file

@ -0,0 +1,19 @@
package ru.spcex.clearing.historyimdg.index;
import ru.spcex.clearing.historyimdg.index.field.SearchWithCreated;
import java.time.Instant;
public class SearchProxyExcludeLiabilitiesRegister extends SearchProxy implements SearchWithCreated {
private Instant created;
@Override
public Instant getCreated() {
return created;
}
@Override
public void setCreated(Instant created) {
this.created = created;
}
}

19
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/index/SearchProxyExecutionRegister.java Normal file
View file

@ -0,0 +1,19 @@
package ru.spcex.clearing.historyimdg.index;
import ru.spcex.clearing.historyimdg.index.field.SearchWithTradingDate;
import java.time.LocalDate;
public class SearchProxyExecutionRegister extends SearchProxy implements SearchWithTradingDate {
private LocalDate tradingDate;
@Override
public LocalDate getTradingDate() {
return tradingDate;
}
@Override
public void setTradingDate(LocalDate tradingDate) {
this.tradingDate = tradingDate;
}
}

19
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/index/SearchProxyLiabilitiesRegister.java Normal file
View file

@ -0,0 +1,19 @@
package ru.spcex.clearing.historyimdg.index;
import ru.spcex.clearing.historyimdg.index.field.SearchWithCreated;
import java.time.Instant;
public class SearchProxyLiabilitiesRegister extends SearchProxy implements SearchWithCreated {
private Instant created;
@Override
public Instant getCreated() {
return created;
}
@Override
public void setCreated(Instant created) {
this.created = created;
}
}

31
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/AdmittedLiabilitiesRegisterHistoryMapStore.java Normal file
View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.register.AdmittedLiabilitiesRegister;
import ru.spcex.clearing.imdg.businessobject.AdmittedLiabilitiesRegisterMapStore;
import java.util.ArrayList;
@Component
public class AdmittedLiabilitiesRegisterHistoryMapStore extends AdmittedLiabilitiesRegisterMapStore {
public AdmittedLiabilitiesRegisterHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected boolean isLoadable(Long id) {
return true;
}
@Override
protected boolean isLoadable(AdmittedLiabilitiesRegister obj) {
return true;
}
@Override
public Iterable<Long> loadAllKeys() {
log.debug("AdmittedLiabilitiesRegister loadAllKeys is called");
return new ArrayList<>();
}
}

31
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/CoveredLiabilitiesRegisterHistoryMapStore.java Normal file
View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.register.CoveredLiabilitiesRegister;
import ru.spcex.clearing.imdg.businessobject.CoveredLiabilitiesRegisterMapStore;
import java.util.ArrayList;
@Component
public class CoveredLiabilitiesRegisterHistoryMapStore extends CoveredLiabilitiesRegisterMapStore {
public CoveredLiabilitiesRegisterHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected boolean isLoadable(Long id) {
return true;
}
@Override
protected boolean isLoadable(CoveredLiabilitiesRegister obj) {
return true;
}
@Override
public Iterable<Long> loadAllKeys() {
log.debug("CoveredLiabilitiesRegister loadAllKeys is called");
return new ArrayList<>();
}
}

31
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/DepoBalanceRegisterHistoryMapStore.java Normal file
View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.register.DepoBalanceRegister;
import ru.spcex.clearing.imdg.businessobject.DepoBalanceRegisterMapStore;
import java.util.ArrayList;
@Component
public class DepoBalanceRegisterHistoryMapStore extends DepoBalanceRegisterMapStore {
public DepoBalanceRegisterHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected boolean isLoadable(Long id) {
return true;
}
@Override
protected boolean isLoadable(DepoBalanceRegister obj) {
return true;
}
@Override
public Iterable<Long> loadAllKeys() {
log.debug("DepoBalanceRegister loadAllKeys is called");
return new ArrayList<>();
}
}

31
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/DepoPaymentInstructionRegisterHistoryMapStore.java Normal file
View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.register.DepoPaymentInstructionRegister;
import ru.spcex.clearing.imdg.businessobject.DepoPaymentInstructionRegisterMapStore;
import java.util.ArrayList;
@Component
public class DepoPaymentInstructionRegisterHistoryMapStore extends DepoPaymentInstructionRegisterMapStore {
public DepoPaymentInstructionRegisterHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected boolean isLoadable(Long id) {
return true;
}
@Override
protected boolean isLoadable(DepoPaymentInstructionRegister obj) {
return true;
}
@Override
public Iterable<Long> loadAllKeys() {
log.debug("DepoPaymentInstructionRegister loadAllKeys is called");
return new ArrayList<>();
}
}

31
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/ExcludeLiabilitiesRegisterHistoryMapStore.java Normal file
View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.register.ExcludeLiabilitiesRegister;
import ru.spcex.clearing.imdg.businessobject.ExcludeLiabilitiesRegisterMapStore;
import java.util.ArrayList;
@Component
public class ExcludeLiabilitiesRegisterHistoryMapStore extends ExcludeLiabilitiesRegisterMapStore {
public ExcludeLiabilitiesRegisterHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected boolean isLoadable(Long id) {
return true;
}
@Override
protected boolean isLoadable(ExcludeLiabilitiesRegister obj) {
return true;
}
@Override
public Iterable<Long> loadAllKeys() {
log.debug("ExcludeLiabilitiesRegister loadAllKeys is called");
return new ArrayList<>();
}
}

31
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/ExecutionFondHistoryMapStore.java Normal file
View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.execution.ExecutionFond;
import ru.spcex.clearing.imdg.businessobject.ExecutionFondMapStore;
import java.util.ArrayList;
@Component
public class ExecutionFondHistoryMapStore extends ExecutionFondMapStore {
public ExecutionFondHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected boolean isLoadable(Long id) {
return true;
}
@Override
protected boolean isLoadable(ExecutionFond obj) {
return true;
}
@Override
public Iterable<Long> loadAllKeys() {
log.debug("ExecutionFond loadAllKeys is called");
return new ArrayList<>();
}
}

31
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/ExecutionRegisterHistoryMapStore.java Normal file
View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.register.ExecutionRegister;
import ru.spcex.clearing.imdg.businessobject.ExecutionRegisterMapStore;
import java.util.ArrayList;
@Component
public class ExecutionRegisterHistoryMapStore extends ExecutionRegisterMapStore {
public ExecutionRegisterHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected boolean isLoadable(Long id) {
return true;
}
@Override
protected boolean isLoadable(ExecutionRegister obj) {
return true;
}
@Override
public Iterable<Long> loadAllKeys() {
log.debug("ExecutionRegister loadAllKeys is called");
return new ArrayList<>();
}
}

31
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/LiabilitiesRegisterHistoryMapStore.java Normal file
View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.register.LiabilitiesRegister;
import ru.spcex.clearing.imdg.businessobject.LiabilitiesRegisterMapStore;
import java.util.ArrayList;
@Component
public class LiabilitiesRegisterHistoryMapStore extends LiabilitiesRegisterMapStore {
public LiabilitiesRegisterHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected boolean isLoadable(Long id) {
return true;
}
@Override
protected boolean isLoadable(LiabilitiesRegister obj) {
return true;
}
@Override
public Iterable<Long> loadAllKeys() {
log.debug("LiabilitiesRegister loadAllKeys is called");
return new ArrayList<>();
}
}

44
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/SearchDepoPaymentInstructionRegisterMapStore.java Normal file
View file

@ -0,0 +1,44 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.spcex.clearing.historyimdg.index.SearchProxyDepoPaymentInstructionRegister;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import java.util.Collection;
import java.util.Collections;
import java.util.Map;
@Component
public class SearchDepoPaymentInstructionRegisterMapStore extends AbstractSliceMapLoader<SearchProxyDepoPaymentInstructionRegister> {
public SearchDepoPaymentInstructionRegisterMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected String getTableName() {
return "depo_payment_instruction_register";
}
@Override
public Collection<SearchProxyDepoPaymentInstructionRegister> load(Collection<Long> keys) {
Map<String, Collection<Long>> paramMap = Collections.singletonMap("ids", keys);
return namedParameterJdbcTemplate.query("select * from " + getTableName() + " where id in (:ids)", paramMap,
(rs, rowNum) -> {
SearchProxyDepoPaymentInstructionRegister proxyRegistry = new SearchProxyDepoPaymentInstructionRegister();
proxyRegistry.setId(rs.getObject("id", Long.class));
proxyRegistry.setCreated(getInstantFromTimestamp(rs, "CREATED_AT"));
return proxyRegistry;
});
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_SearchMoneyPaymentInstructionRegister;
}
@Override
public String[] getIndexingField() {
return new String[]{};
}
}

44
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/SearchExcludeLiabilitiesRegisterMapStore.java Normal file
View file

@ -0,0 +1,44 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.spcex.clearing.historyimdg.index.SearchProxyExcludeLiabilitiesRegister;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import java.util.Collection;
import java.util.Collections;
import java.util.Map;
@Component
public class SearchExcludeLiabilitiesRegisterMapStore extends AbstractSliceMapLoader<SearchProxyExcludeLiabilitiesRegister> {
public SearchExcludeLiabilitiesRegisterMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected String getTableName() {
return "exclude_liabilities_register";
}
@Override
public Collection<SearchProxyExcludeLiabilitiesRegister> load(Collection<Long> keys) {
Map<String, Collection<Long>> paramMap = Collections.singletonMap("ids", keys);
return namedParameterJdbcTemplate.query("select * from " + getTableName() + " where id in (:ids)", paramMap,
(rs, rowNum) -> {
SearchProxyExcludeLiabilitiesRegister proxyRegistry = new SearchProxyExcludeLiabilitiesRegister();
proxyRegistry.setId(rs.getObject("id", Long.class));
proxyRegistry.setCreated(getInstantFromTimestamp(rs, "CREATED_AT"));
return proxyRegistry;
});
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_SearchMoneyPaymentInstructionRegister;
}
@Override
public String[] getIndexingField() {
return new String[]{};
}
}

44
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/SearchExecutionRegisterMapStore.java Normal file
View file

@ -0,0 +1,44 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.spcex.clearing.historyimdg.index.SearchProxyExecutionRegister;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import java.util.Collection;
import java.util.Collections;
import java.util.Map;
@Component
public class SearchExecutionRegisterMapStore extends AbstractSliceMapLoader<SearchProxyExecutionRegister> {
public SearchExecutionRegisterMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected String getTableName() {
return "execution_fond";
}
@Override
public Collection<SearchProxyExecutionRegister> load(Collection<Long> keys) {
Map<String, Collection<Long>> paramMap = Collections.singletonMap("ids", keys);
return namedParameterJdbcTemplate.query("select * from " + getTableName() + " where id in (:ids)", paramMap,
(rs, rowNum) -> {
SearchProxyExecutionRegister proxyRegister = new SearchProxyExecutionRegister();
proxyRegister.setId(rs.getObject("id", Long.class));
proxyRegister.setTradingDate(getLocalDateFromSqlDate(rs,"trading_date"));
return proxyRegister;
});
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_SearchExecutionFond;
}
@Override
public String[] getIndexingField() {
return new String[]{};
}
}

44
clearing-parent/imdg-hist/src/main/java/ru/spcex/clearing/historyimdg/mapstores/SearchLiabilitiesRegisterMapStore.java Normal file
View file

@ -0,0 +1,44 @@
package ru.spcex.clearing.historyimdg.mapstores;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.spcex.clearing.historyimdg.index.SearchProxyLiabilitiesRegister;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import java.util.Collection;
import java.util.Collections;
import java.util.Map;
@Component
public class SearchLiabilitiesRegisterMapStore extends AbstractSliceMapLoader<SearchProxyLiabilitiesRegister> {
public SearchLiabilitiesRegisterMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
protected String getTableName() {
return "liabilities_register";
}
@Override
public Collection<SearchProxyLiabilitiesRegister> load(Collection<Long> keys) {
Map<String, Collection<Long>> paramMap = Collections.singletonMap("ids", keys);
return namedParameterJdbcTemplate.query("select * from " + getTableName() + " where id in (:ids)", paramMap,
(rs, rowNum) -> {
SearchProxyLiabilitiesRegister proxyRegistry = new SearchProxyLiabilitiesRegister();
proxyRegistry.setId(rs.getObject("id", Long.class));
proxyRegistry.setCreated(getInstantFromTimestamp(rs, "CREATED_AT"));
return proxyRegistry;
});
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_SearchMoneyPaymentInstructionRegister;
}
@Override
public String[] getIndexingField() {
return new String[]{};
}
}