diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/execution/ExecutionDeposit.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/execution/ExecutionDeposit.java new file mode 100644 index 000000000..73a011f1c --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/execution/ExecutionDeposit.java @@ -0,0 +1,244 @@ +package ru.clearing.classes.statics.data.execution; + +import ru.clearing.classes.objects.BusinessObject; + +import java.math.BigDecimal; +import java.time.Instant; +import java.time.LocalDate; + +public class ExecutionDeposit extends BusinessObject { + private Long exchangeExecutionId; + private Instant exchangeExecutionTime; + private LocalDate tradingDate; + private Long accountId; + private String market; + private BigDecimal price; + private BigDecimal lots; + private BigDecimal quantity; + private BigDecimal firstLegAmount; + private BigDecimal secondLegAmount; + private BigDecimal interestAmount; + private String side; + private String settlementCurrency; + private Long companyId; + private Long duration; + private LocalDate firstLegSettlementDate; + private LocalDate secondLegSettlementDate; + private LocalDate firstLegSettlementCode; + private LocalDate secondLegSettlementCode; + private String securityFullName; + private String securitySymbol; + private Long securityId; + private Long counterPartyId; + private String coverageStatus; + private Long sessionId; + private LocalDate clearingDate; + + public Long getExchangeExecutionId() { + return exchangeExecutionId; + } + + public void setExchangeExecutionId(Long exchangeExecutionId) { + this.exchangeExecutionId = exchangeExecutionId; + } + + public Instant getExchangeExecutionTime() { + return exchangeExecutionTime; + } + + public void setExchangeExecutionTime(Instant exchangeExecutionTime) { + this.exchangeExecutionTime = exchangeExecutionTime; + } + + public LocalDate getTradingDate() { + return tradingDate; + } + + public void setTradingDate(LocalDate tradingDate) { + this.tradingDate = tradingDate; + } + + public Long getAccountId() { + return accountId; + } + + public void setAccountId(Long accountId) { + this.accountId = accountId; + } + + public String getMarket() { + return market; + } + + public void setMarket(String market) { + this.market = market; + } + + public BigDecimal getPrice() { + return price; + } + + public void setPrice(BigDecimal price) { + this.price = price; + } + + public BigDecimal getLots() { + return lots; + } + + public void setLots(BigDecimal lots) { + this.lots = lots; + } + + public BigDecimal getQuantity() { + return quantity; + } + + public void setQuantity(BigDecimal quantity) { + this.quantity = quantity; + } + + public BigDecimal getFirstLegAmount() { + return firstLegAmount; + } + + public void setFirstLegAmount(BigDecimal firstLegAmount) { + this.firstLegAmount = firstLegAmount; + } + + public BigDecimal getSecondLegAmount() { + return secondLegAmount; + } + + public void setSecondLegAmount(BigDecimal secondLegAmount) { + this.secondLegAmount = secondLegAmount; + } + + public BigDecimal getInterestAmount() { + return interestAmount; + } + + public void setInterestAmount(BigDecimal interestAmount) { + this.interestAmount = interestAmount; + } + + public String getSide() { + return side; + } + + public void setSide(String side) { + this.side = side; + } + + public String getSettlementCurrency() { + return settlementCurrency; + } + + public void setSettlementCurrency(String settlementCurrency) { + this.settlementCurrency = settlementCurrency; + } + + public Long getCompanyId() { + return companyId; + } + + public void setCompanyId(Long companyId) { + this.companyId = companyId; + } + + public Long getDuration() { + return duration; + } + + public void setDuration(Long duration) { + this.duration = duration; + } + + public LocalDate getFirstLegSettlementDate() { + return firstLegSettlementDate; + } + + public void setFirstLegSettlementDate(LocalDate firstLegSettlementDate) { + this.firstLegSettlementDate = firstLegSettlementDate; + } + + public LocalDate getSecondLegSettlementDate() { + return secondLegSettlementDate; + } + + public void setSecondLegSettlementDate(LocalDate secondLegSettlementDate) { + this.secondLegSettlementDate = secondLegSettlementDate; + } + + public LocalDate getFirstLegSettlementCode() { + return firstLegSettlementCode; + } + + public void setFirstLegSettlementCode(LocalDate firstLegSettlementCode) { + this.firstLegSettlementCode = firstLegSettlementCode; + } + + public LocalDate getSecondLegSettlementCode() { + return secondLegSettlementCode; + } + + public void setSecondLegSettlementCode(LocalDate secondLegSettlementCode) { + this.secondLegSettlementCode = secondLegSettlementCode; + } + + public String getSecurityFullName() { + return securityFullName; + } + + public void setSecurityFullName(String securityFullName) { + this.securityFullName = securityFullName; + } + + public String getSecuritySymbol() { + return securitySymbol; + } + + public void setSecuritySymbol(String securitySymbol) { + this.securitySymbol = securitySymbol; + } + + public Long getSecurityId() { + return securityId; + } + + public void setSecurityId(Long securityId) { + this.securityId = securityId; + } + + public Long getCounterPartyId() { + return counterPartyId; + } + + public void setCounterPartyId(Long counterPartyId) { + this.counterPartyId = counterPartyId; + } + + public String getCoverageStatus() { + return coverageStatus; + } + + public void setCoverageStatus(String coverageStatus) { + this.coverageStatus = coverageStatus; + } + + public Long getSessionId() { + return sessionId; + } + + public void setSessionId(Long sessionId) { + this.sessionId = sessionId; + } + + public LocalDate getClearingDate() { + return clearingDate; + } + + public void setClearingDate(LocalDate clearingDate) { + this.clearingDate = clearingDate; + } +} diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/liabilities/LiabilitiesClaimsAssets.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/liabilities/LiabilitiesClaimsAssets.java new file mode 100644 index 000000000..65198c87e --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/liabilities/LiabilitiesClaimsAssets.java @@ -0,0 +1,227 @@ +package ru.clearing.classes.statics.data.liabilities; + +import ru.clearing.classes.ConstSerializable; +import ru.clearing.classes.objects.BusinessObject; + +import java.math.BigDecimal; +import java.time.LocalDate; + +public class LiabilitiesClaimsAssets extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + private Long companyId; + private Long accountId; + private String accountType; + private String account; + private BigDecimal liabilitiesQuantity; + private BigDecimal claimsQuantity; + private String currency; + private LocalDate settlementDate; + private LocalDate tradingDate; + private LocalDate refundDate; + private BigDecimal price; + private Long securityId; + private String tradingCode; + private String clearingCode; + private String shortName; + private String contract; + private String comment; + private String fullName; + private Long parentId; + private Long liabilitiesClaimsMoneyId; + private Long clearingStatus; + private Long paymentId; + private Long refundPaymentId; + private LocalDate clearingDate; + + public Long getCompanyId() { + return companyId; + } + + public void setCompanyId(Long companyId) { + this.companyId = companyId; + } + + public Long getAccountId() { + return accountId; + } + + public void setAccountId(Long accountId) { + this.accountId = accountId; + } + + public String getAccountType() { + return accountType; + } + + public void setAccountType(String accountType) { + this.accountType = accountType; + } + + public String getAccount() { + return account; + } + + public void setAccount(String account) { + this.account = account; + } + + public BigDecimal getLiabilitiesQuantity() { + return liabilitiesQuantity; + } + + public void setLiabilitiesQuantity(BigDecimal liabilitiesQuantity) { + this.liabilitiesQuantity = liabilitiesQuantity; + } + + public BigDecimal getClaimsQuantity() { + return claimsQuantity; + } + + public void setClaimsQuantity(BigDecimal claimsQuantity) { + this.claimsQuantity = claimsQuantity; + } + + public String getCurrency() { + return currency; + } + + public void setCurrency(String currency) { + this.currency = currency; + } + + public LocalDate getSettlementDate() { + return settlementDate; + } + + public void setSettlementDate(LocalDate settlementDate) { + this.settlementDate = settlementDate; + } + + public LocalDate getTradingDate() { + return tradingDate; + } + + public void setTradingDate(LocalDate tradingDate) { + this.tradingDate = tradingDate; + } + + public LocalDate getRefundDate() { + return refundDate; + } + + public void setRefundDate(LocalDate refundDate) { + this.refundDate = refundDate; + } + + public BigDecimal getPrice() { + return price; + } + + public void setPrice(BigDecimal price) { + this.price = price; + } + + public Long getSecurityId() { + return securityId; + } + + public void setSecurityId(Long securityId) { + this.securityId = securityId; + } + + public String getTradingCode() { + return tradingCode; + } + + public void setTradingCode(String tradingCode) { + this.tradingCode = tradingCode; + } + + public String getClearingCode() { + return clearingCode; + } + + public void setClearingCode(String clearingCode) { + this.clearingCode = clearingCode; + } + + public String getShortName() { + return shortName; + } + + public void setShortName(String shortName) { + this.shortName = shortName; + } + + public String getContract() { + return contract; + } + + public void setContract(String contract) { + this.contract = contract; + } + + public String getComment() { + return comment; + } + + public void setComment(String comment) { + this.comment = comment; + } + + public String getFullName() { + return fullName; + } + + public void setFullName(String fullName) { + this.fullName = fullName; + } + + public Long getParentId() { + return parentId; + } + + public void setParentId(Long parentId) { + this.parentId = parentId; + } + + public Long getLiabilitiesClaimsMoneyId() { + return liabilitiesClaimsMoneyId; + } + + public void setLiabilitiesClaimsMoneyId(Long liabilitiesClaimsMoneyId) { + this.liabilitiesClaimsMoneyId = liabilitiesClaimsMoneyId; + } + + public Long getClearingStatus() { + return clearingStatus; + } + + public void setClearingStatus(Long clearingStatus) { + this.clearingStatus = clearingStatus; + } + + public Long getPaymentId() { + return paymentId; + } + + public void setPaymentId(Long paymentId) { + this.paymentId = paymentId; + } + + public Long getRefundPaymentId() { + return refundPaymentId; + } + + public void setRefundPaymentId(Long refundPaymentId) { + this.refundPaymentId = refundPaymentId; + } + + public LocalDate getClearingDate() { + return clearingDate; + } + + public void setClearingDate(LocalDate clearingDate) { + this.clearingDate = clearingDate; + } +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/liabilities/LiabilitiesClaimsMoney.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/liabilities/LiabilitiesClaimsMoney.java new file mode 100644 index 000000000..0b45b316e --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/liabilities/LiabilitiesClaimsMoney.java @@ -0,0 +1,128 @@ +package ru.clearing.classes.statics.data.liabilities; + +import ru.clearing.classes.ConstSerializable; +import ru.clearing.classes.objects.BusinessObject; + +import java.math.BigDecimal; +import java.time.LocalDate; + +public class LiabilitiesClaimsMoney extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + private Long companyId; + private Long accountId; + private String accountType; + private String account; + private BigDecimal liabilitiesAmount; + private BigDecimal claimsAmount; + private LocalDate settlementDate; + private LocalDate tradingDate; + private String currency; + private String tradingCode; + private String shortName; + private String fullName; + private LocalDate clearingDate; + + public Long getCompanyId() { + return companyId; + } + + public void setCompanyId(Long companyId) { + this.companyId = companyId; + } + + public Long getAccountId() { + return accountId; + } + + public void setAccountId(Long accountId) { + this.accountId = accountId; + } + + public String getAccountType() { + return accountType; + } + + public void setAccountType(String accountType) { + this.accountType = accountType; + } + + public String getAccount() { + return account; + } + + public void setAccount(String account) { + this.account = account; + } + + public BigDecimal getLiabilitiesAmount() { + return liabilitiesAmount; + } + + public void setLiabilitiesAmount(BigDecimal liabilitiesAmount) { + this.liabilitiesAmount = liabilitiesAmount; + } + + public BigDecimal getClaimsAmount() { + return claimsAmount; + } + + public void setClaimsAmount(BigDecimal claimsAmount) { + this.claimsAmount = claimsAmount; + } + + public LocalDate getSettlementDate() { + return settlementDate; + } + + public void setSettlementDate(LocalDate settlementDate) { + this.settlementDate = settlementDate; + } + + public LocalDate getTradingDate() { + return tradingDate; + } + + public void setTradingDate(LocalDate tradingDate) { + this.tradingDate = tradingDate; + } + + public String getCurrency() { + return currency; + } + + public void setCurrency(String currency) { + this.currency = currency; + } + + public String getTradingCode() { + return tradingCode; + } + + public void setTradingCode(String tradingCode) { + this.tradingCode = tradingCode; + } + + public String getShortName() { + return shortName; + } + + public void setShortName(String shortName) { + this.shortName = shortName; + } + + public String getFullName() { + return fullName; + } + + public void setFullName(String fullName) { + this.fullName = fullName; + } + + public LocalDate getClearingDate() { + return clearingDate; + } + + public void setClearingDate(LocalDate clearingDate) { + this.clearingDate = clearingDate; + } +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/AdmittedDealRegister.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/AdmittedDealRegister.java deleted file mode 100644 index 859eef78f..000000000 --- a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/AdmittedDealRegister.java +++ /dev/null @@ -1,30 +0,0 @@ -package ru.clearing.classes.statics.data.misc; - -import ru.clearing.classes.ConstSerializable; -import ru.clearing.classes.objects.BusinessObject; - -import java.math.BigDecimal; -import java.time.Instant; -import java.time.LocalTime; - -/** - * Реестр сделок допущенных к клирингу - *

- * DB table: ADMITTED_DEAL_REGISTER - **/ -public class AdmittedDealRegister extends BusinessObject { - private static final long serialVersionUID = ConstSerializable.serialVersionUID; - - private String companyFullName; - private Instant executionDepositRegisterTradingDate; - private String exchangeExecutionId; - private LocalTime exchangeExecutionTime; - private Long securityShortName; - private String sellerFullName; - private String sellerClearingCode; - private String sellerAccount; - private String buyerFullName; - private String buyerClearingCode; - private String buyerAccount; - private BigDecimal executionDepositRegisterAmount; -} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/BalanceRegister.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/BalanceRegister.java new file mode 100644 index 000000000..12ab161a0 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/BalanceRegister.java @@ -0,0 +1,138 @@ +package ru.clearing.classes.statics.data.misc; + +import ru.clearing.classes.ConstSerializable; +import ru.clearing.classes.objects.BusinessObject; + +import java.math.BigDecimal; +import java.time.Instant; + +public class BalanceRegister extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private Instant sDf01Date; + private String currencyCode; + private String setHouseName; + private String account; + private String infoAccount; + private BigDecimal remainderSum; + private BigDecimal blockedSum; + private BigDecimal unblockedSum; + private String inn; + private Long market; + private String fullName; + private String typeRemains; + private String docNumber; + private Long companyId; + + public Instant getsDf01Date() { + return sDf01Date; + } + + public void setsDf01Date(Instant sDf01Date) { + this.sDf01Date = sDf01Date; + } + + public String getCurrencyCode() { + return currencyCode; + } + + public void setCurrencyCode(String currencyCode) { + this.currencyCode = currencyCode; + } + + public String getSetHouseName() { + return setHouseName; + } + + public void setSetHouseName(String setHouseName) { + this.setHouseName = setHouseName; + } + + public String getAccount() { + return account; + } + + public void setAccount(String account) { + this.account = account; + } + + public String getInfoAccount() { + return infoAccount; + } + + public void setInfoAccount(String infoAccount) { + this.infoAccount = infoAccount; + } + + public BigDecimal getRemainderSum() { + return remainderSum; + } + + public void setRemainderSum(BigDecimal remainderSum) { + this.remainderSum = remainderSum; + } + + public BigDecimal getBlockedSum() { + return blockedSum; + } + + public void setBlockedSum(BigDecimal blockedSum) { + this.blockedSum = blockedSum; + } + + public BigDecimal getUnblockedSum() { + return unblockedSum; + } + + public void setUnblockedSum(BigDecimal unblockedSum) { + this.unblockedSum = unblockedSum; + } + + public String getInn() { + return inn; + } + + public void setInn(String inn) { + this.inn = inn; + } + + public Long getMarket() { + return market; + } + + public void setMarket(Long market) { + this.market = market; + } + + public String getFullName() { + return fullName; + } + + public void setFullName(String fullName) { + this.fullName = fullName; + } + + public String getTypeRemains() { + return typeRemains; + } + + public void setTypeRemains(String typeRemains) { + this.typeRemains = typeRemains; + } + + public String getDocNumber() { + return docNumber; + } + + public void setDocNumber(String docNumber) { + this.docNumber = docNumber; + } + + public Long getCompanyId() { + return companyId; + } + + public void setCompanyId(Long companyId) { + this.companyId = companyId; + } +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/ClearMemberRegister.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/ClearMemberRegister.java new file mode 100644 index 000000000..d10488275 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/misc/ClearMemberRegister.java @@ -0,0 +1,236 @@ +package ru.clearing.classes.statics.data.misc; + +import ru.clearing.classes.ConstSerializable; +import ru.clearing.classes.objects.BusinessObject; + +import java.time.Instant; +import java.time.LocalDate; + +public class ClearMemberRegister extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + private String tradingCode; + private String clearingCode; + private String fullName; + private String shortName; + private String categoryList; + private String corporationSole; + private String account; + private Long bank; + private String bankName; + private String inn; + private String bic; + private String ogrn; + private String cpp; + private String ocpo; + private String contractNumber; + private LocalDate contractDate; + private LocalDate registrationDate; + private LocalDate systemDate; + private Instant accessDate; + private Instant suspentionDate; + private Instant reopeningDate; + private Instant closeDate; + private Instant exclusionDate; + private String address; + private String email; + + public String getTradingCode() { + return tradingCode; + } + + public void setTradingCode(String tradingCode) { + this.tradingCode = tradingCode; + } + + public String getClearingCode() { + return clearingCode; + } + + public void setClearingCode(String clearingCode) { + this.clearingCode = clearingCode; + } + + public String getFullName() { + return fullName; + } + + public void setFullName(String fullName) { + this.fullName = fullName; + } + + public String getShortName() { + return shortName; + } + + public void setShortName(String shortName) { + this.shortName = shortName; + } + + public String getCategoryList() { + return categoryList; + } + + public void setCategoryList(String categoryList) { + this.categoryList = categoryList; + } + + public String getCorporationSole() { + return corporationSole; + } + + public void setCorporationSole(String corporationSole) { + this.corporationSole = corporationSole; + } + + public String getAccount() { + return account; + } + + public void setAccount(String account) { + this.account = account; + } + + public Long getBank() { + return bank; + } + + public void setBank(Long bank) { + this.bank = bank; + } + + public String getBankName() { + return bankName; + } + + public void setBankName(String bankName) { + this.bankName = bankName; + } + + public String getInn() { + return inn; + } + + public void setInn(String inn) { + this.inn = inn; + } + + public String getBic() { + return bic; + } + + public void setBic(String bic) { + this.bic = bic; + } + + public String getOgrn() { + return ogrn; + } + + public void setOgrn(String ogrn) { + this.ogrn = ogrn; + } + + public String getCpp() { + return cpp; + } + + public void setCpp(String cpp) { + this.cpp = cpp; + } + + public String getOcpo() { + return ocpo; + } + + public void setOcpo(String ocpo) { + this.ocpo = ocpo; + } + + public String getContractNumber() { + return contractNumber; + } + + public void setContractNumber(String contractNumber) { + this.contractNumber = contractNumber; + } + + public LocalDate getContractDate() { + return contractDate; + } + + public void setContractDate(LocalDate contractDate) { + this.contractDate = contractDate; + } + + public LocalDate getRegistrationDate() { + return registrationDate; + } + + public void setRegistrationDate(LocalDate registrationDate) { + this.registrationDate = registrationDate; + } + + public LocalDate getSystemDate() { + return systemDate; + } + + public void setSystemDate(LocalDate systemDate) { + this.systemDate = systemDate; + } + + public Instant getAccessDate() { + return accessDate; + } + + public void setAccessDate(Instant accessDate) { + this.accessDate = accessDate; + } + + public Instant getSuspentionDate() { + return suspentionDate; + } + + public void setSuspentionDate(Instant suspentionDate) { + this.suspentionDate = suspentionDate; + } + + public Instant getReopeningDate() { + return reopeningDate; + } + + public void setReopeningDate(Instant reopeningDate) { + this.reopeningDate = reopeningDate; + } + + public Instant getCloseDate() { + return closeDate; + } + + public void setCloseDate(Instant closeDate) { + this.closeDate = closeDate; + } + + public Instant getExclusionDate() { + return exclusionDate; + } + + public void setExclusionDate(Instant exclusionDate) { + this.exclusionDate = exclusionDate; + } + + public String getAddress() { + return address; + } + + public void setAddress(String address) { + this.address = address; + } + + public String getEmail() { + return email; + } + + public void setEmail(String email) { + this.email = email; + } +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/AdmittedDealRegister.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/AdmittedDealRegister.java new file mode 100644 index 000000000..099f66bd7 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/AdmittedDealRegister.java @@ -0,0 +1,153 @@ +package ru.clearing.classes.statics.data.register; + +import ru.clearing.classes.ConstSerializable; +import ru.clearing.classes.objects.BusinessObject; + +import java.math.BigDecimal; +import java.time.Instant; +import java.time.LocalDate; + +/** + * Реестр сделок допущенных к клирингу + *

+ * DB table: ADMITTED_DEAL_REGISTER + **/ +public class AdmittedDealRegister extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private Long executionId; + private String companyFullName; + private LocalDate tradingDate; + private Long exchangeExecutionId; + private Instant exchangeExecutionTime; + private String securitySymbol; + private String securityFullName; + private String sellerFullName; + private String sellerClearingCode; + private String sellerAccount; + private String buyerFullName; + private String buyerClearingCode; + private String buyerAccount; + private BigDecimal amount; + private LocalDate clearingDate; + + public Long getExecutionId() { + return executionId; + } + + public void setExecutionId(Long executionId) { + this.executionId = executionId; + } + + public String getCompanyFullName() { + return companyFullName; + } + + public void setCompanyFullName(String companyFullName) { + this.companyFullName = companyFullName; + } + + public LocalDate getTradingDate() { + return tradingDate; + } + + public void setTradingDate(LocalDate tradingDate) { + this.tradingDate = tradingDate; + } + + public Long getExchangeExecutionId() { + return exchangeExecutionId; + } + + public void setExchangeExecutionId(Long exchangeExecutionId) { + this.exchangeExecutionId = exchangeExecutionId; + } + + public Instant getExchangeExecutionTime() { + return exchangeExecutionTime; + } + + public void setExchangeExecutionTime(Instant exchangeExecutionTime) { + this.exchangeExecutionTime = exchangeExecutionTime; + } + + public String getSecuritySymbol() { + return securitySymbol; + } + + public void setSecuritySymbol(String securitySymbol) { + this.securitySymbol = securitySymbol; + } + + public String getSecurityFullName() { + return securityFullName; + } + + public void setSecurityFullName(String securityFullName) { + this.securityFullName = securityFullName; + } + + public String getSellerFullName() { + return sellerFullName; + } + + public void setSellerFullName(String sellerFullName) { + this.sellerFullName = sellerFullName; + } + + public String getSellerClearingCode() { + return sellerClearingCode; + } + + public void setSellerClearingCode(String sellerClearingCode) { + this.sellerClearingCode = sellerClearingCode; + } + + public String getSellerAccount() { + return sellerAccount; + } + + public void setSellerAccount(String sellerAccount) { + this.sellerAccount = sellerAccount; + } + + public String getBuyerFullName() { + return buyerFullName; + } + + public void setBuyerFullName(String buyerFullName) { + this.buyerFullName = buyerFullName; + } + + public String getBuyerClearingCode() { + return buyerClearingCode; + } + + public void setBuyerClearingCode(String buyerClearingCode) { + this.buyerClearingCode = buyerClearingCode; + } + + public String getBuyerAccount() { + return buyerAccount; + } + + public void setBuyerAccount(String buyerAccount) { + this.buyerAccount = buyerAccount; + } + + public BigDecimal getAmount() { + return amount; + } + + public void setAmount(BigDecimal amount) { + this.amount = amount; + } + + public LocalDate getClearingDate() { + return clearingDate; + } + + public void setClearingDate(LocalDate clearingDate) { + this.clearingDate = clearingDate; + } +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/ContractRegister.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/ContractRegister.java new file mode 100644 index 000000000..186f2d69f --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/ContractRegister.java @@ -0,0 +1,137 @@ +package ru.clearing.classes.statics.data.register; + +import ru.clearing.classes.ConstSerializable; +import ru.clearing.classes.objects.BusinessObject; + +import java.time.LocalDate; + +public class ContractRegister extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private String name; + private String number; + private LocalDate issueDate; + private Long companyFullName; + private Long companyId; + private String documentType; + private String issuePlace; + private String issuer; + private String issuerCode; + private String place; + private LocalDate validFromDate; + private LocalDate validToDate; + private LocalDate closeDate; + private String comment; + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getNumber() { + return number; + } + + public void setNumber(String number) { + this.number = number; + } + + public LocalDate getIssueDate() { + return issueDate; + } + + public void setIssueDate(LocalDate issueDate) { + this.issueDate = issueDate; + } + + public Long getCompanyFullName() { + return companyFullName; + } + + public void setCompanyFullName(Long companyFullName) { + this.companyFullName = companyFullName; + } + + public Long getCompanyId() { + return companyId; + } + + public void setCompanyId(Long companyId) { + this.companyId = companyId; + } + + public String getDocumentType() { + return documentType; + } + + public void setDocumentType(String documentType) { + this.documentType = documentType; + } + + public String getIssuePlace() { + return issuePlace; + } + + public void setIssuePlace(String issuePlace) { + this.issuePlace = issuePlace; + } + + public String getIssuer() { + return issuer; + } + + public void setIssuer(String issuer) { + this.issuer = issuer; + } + + public String getIssuerCode() { + return issuerCode; + } + + public void setIssuerCode(String issuerCode) { + this.issuerCode = issuerCode; + } + + public String getPlace() { + return place; + } + + public void setPlace(String place) { + this.place = place; + } + + public LocalDate getValidFromDate() { + return validFromDate; + } + + public void setValidFromDate(LocalDate validFromDate) { + this.validFromDate = validFromDate; + } + + public LocalDate getValidToDate() { + return validToDate; + } + + public void setValidToDate(LocalDate validToDate) { + this.validToDate = validToDate; + } + + public LocalDate getCloseDate() { + return closeDate; + } + + public void setCloseDate(LocalDate closeDate) { + this.closeDate = closeDate; + } + + public String getComment() { + return comment; + } + + public void setComment(String comment) { + this.comment = comment; + } +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/CoveredDealRegister.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/CoveredDealRegister.java new file mode 100644 index 000000000..925eeab6a --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/CoveredDealRegister.java @@ -0,0 +1,148 @@ +package ru.clearing.classes.statics.data.register; + +import ru.clearing.classes.ConstSerializable; +import ru.clearing.classes.objects.BusinessObject; + +import java.math.BigDecimal; +import java.time.Instant; +import java.time.LocalDate; + +public class CoveredDealRegister extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private Long executionId; + private String companyFullName; + private LocalDate tradingDate; + private Long exchangeExecutionId; + private Instant exchangeExecutionTime; + private String securitySymbol; + private String securityFullName; + private String sellerFullName; + private String sellerClearingCode; + private String sellerAccount; + private String buyerFullName; + private String buyerClearingCode; + private String buyerAccount; + private BigDecimal amount; + private LocalDate clearingDate; + + public Long getExecutionId() { + return executionId; + } + + public void setExecutionId(Long executionId) { + this.executionId = executionId; + } + + public String getCompanyFullName() { + return companyFullName; + } + + public void setCompanyFullName(String companyFullName) { + this.companyFullName = companyFullName; + } + + public LocalDate getTradingDate() { + return tradingDate; + } + + public void setTradingDate(LocalDate tradingDate) { + this.tradingDate = tradingDate; + } + + public Long getExchangeExecutionId() { + return exchangeExecutionId; + } + + public void setExchangeExecutionId(Long exchangeExecutionId) { + this.exchangeExecutionId = exchangeExecutionId; + } + + public Instant getExchangeExecutionTime() { + return exchangeExecutionTime; + } + + public void setExchangeExecutionTime(Instant exchangeExecutionTime) { + this.exchangeExecutionTime = exchangeExecutionTime; + } + + public String getSecuritySymbol() { + return securitySymbol; + } + + public void setSecuritySymbol(String securitySymbol) { + this.securitySymbol = securitySymbol; + } + + public String getSecurityFullName() { + return securityFullName; + } + + public void setSecurityFullName(String securityFullName) { + this.securityFullName = securityFullName; + } + + public String getSellerFullName() { + return sellerFullName; + } + + public void setSellerFullName(String sellerFullName) { + this.sellerFullName = sellerFullName; + } + + public String getSellerClearingCode() { + return sellerClearingCode; + } + + public void setSellerClearingCode(String sellerClearingCode) { + this.sellerClearingCode = sellerClearingCode; + } + + public String getSellerAccount() { + return sellerAccount; + } + + public void setSellerAccount(String sellerAccount) { + this.sellerAccount = sellerAccount; + } + + public String getBuyerFullName() { + return buyerFullName; + } + + public void setBuyerFullName(String buyerFullName) { + this.buyerFullName = buyerFullName; + } + + public String getBuyerClearingCode() { + return buyerClearingCode; + } + + public void setBuyerClearingCode(String buyerClearingCode) { + this.buyerClearingCode = buyerClearingCode; + } + + public String getBuyerAccount() { + return buyerAccount; + } + + public void setBuyerAccount(String buyerAccount) { + this.buyerAccount = buyerAccount; + } + + public BigDecimal getAmount() { + return amount; + } + + public void setAmount(BigDecimal amount) { + this.amount = amount; + } + + public LocalDate getClearingDate() { + return clearingDate; + } + + public void setClearingDate(LocalDate clearingDate) { + this.clearingDate = clearingDate; + } +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/DealRegister.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/DealRegister.java new file mode 100644 index 000000000..d267160bf --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/DealRegister.java @@ -0,0 +1,190 @@ +package ru.clearing.classes.statics.data.register; + +import ru.clearing.classes.objects.BusinessObject; + +import java.math.BigDecimal; +import java.time.Instant; +import java.time.LocalDate; + +public class DealRegister extends BusinessObject { + private Long executionId; + private Long exchangeExecutionId; + private Instant exchangeExecutionTime; + private LocalDate tradingDate; + private String account; + private String market; + private BigDecimal price; + private BigDecimal amount; + private String side; + private String settlementCurrency; + private Long companyId; + private LocalDate firstLegSettlementDate; + private LocalDate secondLegSettlementDate; + private String securityFullName; + private String securitySymbol; + private Long securityId; + private Long counterPartyId; + private String coverageStatus; + private Long sessionId; + private LocalDate clearingDate; + + public Long getExecutionId() { + return executionId; + } + + public void setExecutionId(Long executionId) { + this.executionId = executionId; + } + + public Long getExchangeExecutionId() { + return exchangeExecutionId; + } + + public void setExchangeExecutionId(Long exchangeExecutionId) { + this.exchangeExecutionId = exchangeExecutionId; + } + + public Instant getExchangeExecutionTime() { + return exchangeExecutionTime; + } + + public void setExchangeExecutionTime(Instant exchangeExecutionTime) { + this.exchangeExecutionTime = exchangeExecutionTime; + } + + public LocalDate getTradingDate() { + return tradingDate; + } + + public void setTradingDate(LocalDate tradingDate) { + this.tradingDate = tradingDate; + } + + public String getAccount() { + return account; + } + + public void setAccount(String account) { + this.account = account; + } + + public String getMarket() { + return market; + } + + public void setMarket(String market) { + this.market = market; + } + + public BigDecimal getPrice() { + return price; + } + + public void setPrice(BigDecimal price) { + this.price = price; + } + + public BigDecimal getAmount() { + return amount; + } + + public void setAmount(BigDecimal amount) { + this.amount = amount; + } + + public String getSide() { + return side; + } + + public void setSide(String side) { + this.side = side; + } + + public String getSettlementCurrency() { + return settlementCurrency; + } + + public void setSettlementCurrency(String settlementCurrency) { + this.settlementCurrency = settlementCurrency; + } + + public Long getCompanyId() { + return companyId; + } + + public void setCompanyId(Long companyId) { + this.companyId = companyId; + } + + public LocalDate getFirstLegSettlementDate() { + return firstLegSettlementDate; + } + + public void setFirstLegSettlementDate(LocalDate firstLegSettlementDate) { + this.firstLegSettlementDate = firstLegSettlementDate; + } + + public LocalDate getSecondLegSettlementDate() { + return secondLegSettlementDate; + } + + public void setSecondLegSettlementDate(LocalDate secondLegSettlementDate) { + this.secondLegSettlementDate = secondLegSettlementDate; + } + + public String getSecurityFullName() { + return securityFullName; + } + + public void setSecurityFullName(String securityFullName) { + this.securityFullName = securityFullName; + } + + public String getSecuritySymbol() { + return securitySymbol; + } + + public void setSecuritySymbol(String securitySymbol) { + this.securitySymbol = securitySymbol; + } + + public Long getSecurityId() { + return securityId; + } + + public void setSecurityId(Long securityId) { + this.securityId = securityId; + } + + public Long getCounterPartyId() { + return counterPartyId; + } + + public void setCounterPartyId(Long counterPartyId) { + this.counterPartyId = counterPartyId; + } + + public String getCoverageStatus() { + return coverageStatus; + } + + public void setCoverageStatus(String coverageStatus) { + this.coverageStatus = coverageStatus; + } + + public Long getSessionId() { + return sessionId; + } + + public void setSessionId(Long sessionId) { + this.sessionId = sessionId; + } + + public LocalDate getClearingDate() { + return clearingDate; + } + + public void setClearingDate(LocalDate clearingDate) { + this.clearingDate = clearingDate; + } +} diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/OrderRegister.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/OrderRegister.java new file mode 100644 index 000000000..cf0986da9 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/OrderRegister.java @@ -0,0 +1,93 @@ +package ru.clearing.classes.statics.data.register; + +import ru.clearing.classes.ConstSerializable; +import ru.clearing.classes.objects.BusinessObject; + +import java.math.BigDecimal; +import java.time.LocalDate; + +public class OrderRegister extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private String creditLegAccount; + private BigDecimal creditLegAmount; + private String creditLegCurrencyCode; + private Long creditLegDirection; + private String debitLegAccount; + private String sender; + private String addressee; + private String documentNumber; + private LocalDate clearingDate; + + public String getCreditLegAccount() { + return creditLegAccount; + } + + public void setCreditLegAccount(String creditLegAccount) { + this.creditLegAccount = creditLegAccount; + } + + public BigDecimal getCreditLegAmount() { + return creditLegAmount; + } + + public void setCreditLegAmount(BigDecimal creditLegAmount) { + this.creditLegAmount = creditLegAmount; + } + + public String getCreditLegCurrencyCode() { + return creditLegCurrencyCode; + } + + public void setCreditLegCurrencyCode(String creditLegCurrencyCode) { + this.creditLegCurrencyCode = creditLegCurrencyCode; + } + + public Long getCreditLegDirection() { + return creditLegDirection; + } + + public void setCreditLegDirection(Long creditLegDirection) { + this.creditLegDirection = creditLegDirection; + } + + public String getDebitLegAccount() { + return debitLegAccount; + } + + public void setDebitLegAccount(String debitLegAccount) { + this.debitLegAccount = debitLegAccount; + } + + public String getSender() { + return sender; + } + + public void setSender(String sender) { + this.sender = sender; + } + + public String getAddressee() { + return addressee; + } + + public void setAddressee(String addressee) { + this.addressee = addressee; + } + + public String getDocumentNumber() { + return documentNumber; + } + + public void setDocumentNumber(String documentNumber) { + this.documentNumber = documentNumber; + } + + public LocalDate getClearingDate() { + return clearingDate; + } + + public void setClearingDate(LocalDate clearingDate) { + this.clearingDate = clearingDate; + } +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/ReportRegister.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/ReportRegister.java new file mode 100644 index 000000000..6cda6e948 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/ReportRegister.java @@ -0,0 +1,74 @@ +package ru.clearing.classes.statics.data.register; + +import ru.clearing.classes.ConstSerializable; +import ru.clearing.classes.objects.BusinessObject; + +import java.time.LocalDate; + +public class ReportRegister extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private String companyFullName; + private String clearingCode; + private Long sessionId; + private String comment; + private String name; + private Long quantity; + private LocalDate clearingDate; + + public String getCompanyFullName() { + return companyFullName; + } + + public void setCompanyFullName(String companyFullName) { + this.companyFullName = companyFullName; + } + + public String getClearingCode() { + return clearingCode; + } + + public void setClearingCode(String clearingCode) { + this.clearingCode = clearingCode; + } + + public Long getSessionId() { + return sessionId; + } + + public void setSessionId(Long sessionId) { + this.sessionId = sessionId; + } + + public String getComment() { + return comment; + } + + public void setComment(String comment) { + this.comment = comment; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public Long getQuantity() { + return quantity; + } + + public void setQuantity(Long quantity) { + this.quantity = quantity; + } + + public LocalDate getClearingDate() { + return clearingDate; + } + + public void setClearingDate(LocalDate clearingDate) { + this.clearingDate = clearingDate; + } +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/UncoveredDealRegister.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/UncoveredDealRegister.java new file mode 100644 index 000000000..6319b1c4b --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/register/UncoveredDealRegister.java @@ -0,0 +1,157 @@ +package ru.clearing.classes.statics.data.register; + +import ru.clearing.classes.ConstSerializable; +import ru.clearing.classes.objects.BusinessObject; + +import java.math.BigDecimal; +import java.time.Instant; +import java.time.LocalDate; + +public class UncoveredDealRegister extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private Long executionId; + private String companyFullName; + private LocalDate tradingDate; + private Long exchangeExecutionId; + private Instant exchangeExecutionTime; + private String securitySymbol; + private String securityFullName; + private String sellerFullName; + private String sellerClearingCode; + private String sellerAccount; + private String buyerFullName; + private String buyerClearingCode; + private String buyerAccount; + private BigDecimal amount; + private String resultStatus; + private LocalDate clearingDate; + + public Long getExecutionId() { + return executionId; + } + + public void setExecutionId(Long executionId) { + this.executionId = executionId; + } + + public String getCompanyFullName() { + return companyFullName; + } + + public void setCompanyFullName(String companyFullName) { + this.companyFullName = companyFullName; + } + + public LocalDate getTradingDate() { + return tradingDate; + } + + public void setTradingDate(LocalDate tradingDate) { + this.tradingDate = tradingDate; + } + + public Long getExchangeExecutionId() { + return exchangeExecutionId; + } + + public void setExchangeExecutionId(Long exchangeExecutionId) { + this.exchangeExecutionId = exchangeExecutionId; + } + + public Instant getExchangeExecutionTime() { + return exchangeExecutionTime; + } + + public void setExchangeExecutionTime(Instant exchangeExecutionTime) { + this.exchangeExecutionTime = exchangeExecutionTime; + } + + public String getSecuritySymbol() { + return securitySymbol; + } + + public void setSecuritySymbol(String securitySymbol) { + this.securitySymbol = securitySymbol; + } + + public String getSecurityFullName() { + return securityFullName; + } + + public void setSecurityFullName(String securityFullName) { + this.securityFullName = securityFullName; + } + + public String getSellerFullName() { + return sellerFullName; + } + + public void setSellerFullName(String sellerFullName) { + this.sellerFullName = sellerFullName; + } + + public String getSellerClearingCode() { + return sellerClearingCode; + } + + public void setSellerClearingCode(String sellerClearingCode) { + this.sellerClearingCode = sellerClearingCode; + } + + public String getSellerAccount() { + return sellerAccount; + } + + public void setSellerAccount(String sellerAccount) { + this.sellerAccount = sellerAccount; + } + + public String getBuyerFullName() { + return buyerFullName; + } + + public void setBuyerFullName(String buyerFullName) { + this.buyerFullName = buyerFullName; + } + + public String getBuyerClearingCode() { + return buyerClearingCode; + } + + public void setBuyerClearingCode(String buyerClearingCode) { + this.buyerClearingCode = buyerClearingCode; + } + + public String getBuyerAccount() { + return buyerAccount; + } + + public void setBuyerAccount(String buyerAccount) { + this.buyerAccount = buyerAccount; + } + + public BigDecimal getAmount() { + return amount; + } + + public void setAmount(BigDecimal amount) { + this.amount = amount; + } + + public String getResultStatus() { + return resultStatus; + } + + public void setResultStatus(String resultStatus) { + this.resultStatus = resultStatus; + } + + public LocalDate getClearingDate() { + return clearingDate; + } + + public void setClearingDate(LocalDate clearingDate) { + this.clearingDate = clearingDate; + } +} \ No newline at end of file diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/AdmittedDealRegisterMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/AdmittedDealRegisterMapStore.java new file mode 100644 index 000000000..6b3e65d55 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/AdmittedDealRegisterMapStore.java @@ -0,0 +1,101 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.clearing.classes.statics.data.register.AdmittedDealRegister; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.time.TimeUtil; + +import java.math.BigDecimal; +import java.sql.ResultSet; +import java.sql.SQLException; + +@Component +public class AdmittedDealRegisterMapStore extends TemplateMapStore { + + public AdmittedDealRegisterMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getTableName() { + return "ADMITTED_DEAL_REGISTER"; + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_AdmittedDealRegister; + } + + @Override + public String[] getFields() { + return new String[]{"ID", "CREATED_AT", "UPDATED_AT", + "EXECUTION_ID", + "COMPANY_FULL_NAME", + "TRADING_DATE", + "EXCHANGE_EXECUTION_ID", + "EXCHANGE_EXECUTION_TIME", + "SECURITY_SYMBOL", + "SECURITY_FULL_NAME", + "SELLER_FULL_NAME", + "SELLER_CLEARING_CODE", + "SELLER_ACCOUNT", + "BUYER_FULL_NAME", + "BUYER_CLEARING_CODE", + "BUYER_ACCOUNT", + "AMOUNT", + "CLEARING_DATE", + }; + } + + @Override + protected AdmittedDealRegister objectReader(ResultSet resultSet) throws SQLException { + AdmittedDealRegister object = new AdmittedDealRegister(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setExecutionId(resultSet.getObject("EXECUTION_ID", Long.class)); + object.setCompanyFullName(resultSet.getObject("COMPANY_FULL_NAME", String.class)); + object.setTradingDate(getLocalDateFromSqlDate(resultSet, "TRADING_DATE")); + object.setExchangeExecutionId(resultSet.getObject("EXCHANGE_EXECUTION_ID", Long.class)); + object.setExchangeExecutionTime(getInstantFromTimestamp(resultSet, "EXCHANGE_EXECUTION_TIME")); + object.setSecuritySymbol(resultSet.getObject("SECURITY_SYMBOL", String.class)); + object.setSecurityFullName(resultSet.getObject("SECURITY_FULL_NAME", String.class)); + object.setSellerFullName(resultSet.getObject("SELLER_FULL_NAME", String.class)); + object.setSellerClearingCode(resultSet.getObject("SELLER_CLEARING_CODE", String.class)); + object.setSellerAccount(resultSet.getObject("SELLER_ACCOUNT", String.class)); + object.setBuyerFullName(resultSet.getObject("BUYER_FULL_NAME", String.class)); + object.setBuyerClearingCode(resultSet.getObject("BUYER_CLEARING_CODE", String.class)); + object.setBuyerAccount(resultSet.getObject("BUYER_ACCOUNT", String.class)); + object.setAmount(resultSet.getObject("AMOUNT", BigDecimal.class)); + object.setClearingDate(getLocalDateFromSqlDate(resultSet, "CLEARING_DATE")); + return object; + } + + @Override + protected Object[] objectToField(AdmittedDealRegister object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.toDateFromInstant(object.getCreated()), + TimeUtil.toDateFromInstant(object.getUpdated()), + object.getExecutionId(), + object.getCompanyFullName(), + TimeUtil.toDateFromLocalDate(object.getTradingDate()), + object.getExchangeExecutionId(), + TimeUtil.toDateFromInstant(object.getExchangeExecutionTime()), + object.getSecuritySymbol(), + object.getSecurityFullName(), + object.getSellerFullName(), + object.getSellerClearingCode(), + object.getSellerAccount(), + object.getBuyerFullName(), + object.getBuyerClearingCode(), + object.getBuyerAccount(), + object.getAmount(), + TimeUtil.toDateFromLocalDate(object.getClearingDate()), + }; + return args; + } + +} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/BalanceRegisterMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/BalanceRegisterMapStore.java new file mode 100644 index 000000000..b40e95341 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/BalanceRegisterMapStore.java @@ -0,0 +1,98 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.clearing.classes.statics.data.misc.BalanceRegister; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.time.TimeUtil; + +import java.math.BigDecimal; +import java.sql.ResultSet; +import java.sql.SQLException; + +@Component +public class BalanceRegisterMapStore extends TemplateMapStore { + + public BalanceRegisterMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getTableName() { + return "BALANCE_REGISTER"; + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_BalanceRegister; + } + + @Override + public String[] getFields() { + return new String[]{"ID", "CREATED_AT", "UPDATED_AT", + "S_DF01_DATE", + "CURRENCY_CODE", + "SET_HOUSE_NAME", + "ACCOUNT", + "INFO_ACCOUNT", + "REMAINDER_SUM", + "BLOCKED_SUM", + "UNBLOCKED_SUM", + "INN", + "MARKET", + "FULL_NAME", + "TYPE_REMAINS", + "DOC_NUMBER", + "COMPANY_ID" + }; + } + + @Override + protected BalanceRegister objectReader(ResultSet resultSet) throws SQLException { + BalanceRegister object = new BalanceRegister(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setsDf01Date(getInstantFromTimestamp(resultSet, "S_DF01_DATE")); + object.setCurrencyCode(resultSet.getObject("CURRENCY_CODE", String.class)); + object.setSetHouseName(resultSet.getObject("SET_HOUSE_NAME", String.class)); + object.setAccount(resultSet.getObject("ACCOUNT", String.class)); + object.setInfoAccount(resultSet.getObject("INFO_ACCOUNT", String.class)); + object.setRemainderSum(resultSet.getObject("REMAINDER_SUM", BigDecimal.class)); + object.setBlockedSum(resultSet.getObject("BLOCKED_SUM", BigDecimal.class)); + object.setUnblockedSum(resultSet.getObject("UNBLOCKED_SUM", BigDecimal.class)); + object.setInn(resultSet.getObject("INN", String.class)); + object.setMarket(resultSet.getObject("MARKET", Long.class)); + object.setFullName(resultSet.getObject("FULL_NAME", String.class)); + object.setTypeRemains(resultSet.getObject("TYPE_REMAINS", String.class)); + object.setDocNumber(resultSet.getObject("DOC_NUMBER", String.class)); + object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class)); + return object; + } + + @Override + protected Object[] objectToField(BalanceRegister object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.toDateFromInstant(object.getCreated()), + TimeUtil.toDateFromInstant(object.getUpdated()), + TimeUtil.toDateFromInstant(object.getsDf01Date()), + object.getCurrencyCode(), + object.getSetHouseName(), + object.getAccount(), + object.getInfoAccount(), + object.getRemainderSum(), + object.getBlockedSum(), + object.getUnblockedSum(), + object.getInn(), + object.getMarket(), + object.getFullName(), + object.getTypeRemains(), + object.getDocNumber(), + object.getCompanyId() + }; + return args; + } + +} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ClearMemberRegisterMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ClearMemberRegisterMapStore.java new file mode 100644 index 000000000..df29c7f8a --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ClearMemberRegisterMapStore.java @@ -0,0 +1,130 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.clearing.classes.statics.data.misc.ClearMemberRegister; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.time.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; + +@Component +public class ClearMemberRegisterMapStore extends TemplateMapStore { + + public ClearMemberRegisterMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getTableName() { + return "CLEARMEMBER_REGISTER"; + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_ClearMemberRegister; + } + + @Override + public String[] getFields() { + return new String[]{"ID", "CREATED_AT", "UPDATED_AT", + "TRADING_CODE", + "CLEARING_CODE", + "FULL_NAME", + "SHORT_NAME", + "CATEGORY_LIST", + "CORPORATION_SOLE", + "ACCOUNT", + "BANK", + "BANK_NAME", + "INN", + "BIC", + "OGRN", + "CPP", + "OCPO", + "CONTRACT_NUMBER", + "CONTRACT_DATE", + "REGISTRATION_DATE", + "SYSTEM_DATE", + "ACCESS_DATE", + "SUSPENTION_DATE", + "REOPENING_DATE", + "CLOSE_DATE", + "EXCLUSION_DATE", + "ADDRESS", + "EMAIL", + }; + } + + @Override + protected ClearMemberRegister objectReader(ResultSet resultSet) throws SQLException { + ClearMemberRegister object = new ClearMemberRegister(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setTradingCode(resultSet.getObject("TRADING_CODE", String.class)); + object.setClearingCode(resultSet.getObject("CLEARING_CODE", String.class)); + object.setFullName(resultSet.getObject("FULL_NAME", String.class)); + object.setShortName(resultSet.getObject("SHORT_NAME", String.class)); + object.setCategoryList(resultSet.getObject("CATEGORY_LIST", String.class)); + object.setCorporationSole(resultSet.getObject("CORPORATION_SOLE", String.class)); + object.setAccount(resultSet.getObject("ACCOUNT", String.class)); + object.setBank(resultSet.getObject("BANK", Long.class)); + object.setBankName(resultSet.getObject("BANK_NAME", String.class)); + object.setInn(resultSet.getObject("INN", String.class)); + object.setBic(resultSet.getObject("BIC", String.class)); + object.setOgrn(resultSet.getObject("OGRN", String.class)); + object.setCpp(resultSet.getObject("CPP", String.class)); + object.setOcpo(resultSet.getObject("OCPO", String.class)); + object.setContractNumber(resultSet.getObject("CONTRACT_NUMBER", String.class)); + object.setContractDate(getLocalDateFromSqlDate(resultSet, "CONTRACT_DATE")); + object.setRegistrationDate(getLocalDateFromSqlDate(resultSet, "REGISTRATION_DATE")); + object.setSystemDate(getLocalDateFromSqlDate(resultSet, "SYSTEM_DATE")); + object.setAccessDate(getInstantFromTimestamp(resultSet, "ACCESS_DATE")); + object.setSuspentionDate(getInstantFromTimestamp(resultSet, "SUSPENTION_DATE")); + object.setReopeningDate(getInstantFromTimestamp(resultSet, "REOPENING_DATE")); + object.setCloseDate(getInstantFromTimestamp(resultSet, "CLOSE_DATE")); + object.setExclusionDate(getInstantFromTimestamp(resultSet, "EXCLUSION_DATE")); + object.setAddress(resultSet.getObject("ADDRESS", String.class)); + object.setEmail(resultSet.getObject("EMAIL", String.class)); + return object; + } + + @Override + protected Object[] objectToField(ClearMemberRegister clearMemberRegister) { + Object[] args = new Object[]{ + clearMemberRegister.getId(), + TimeUtil.toDateFromInstant(clearMemberRegister.getCreated()), + TimeUtil.toDateFromInstant(clearMemberRegister.getUpdated()), + clearMemberRegister.getTradingCode(), + clearMemberRegister.getClearingCode(), + clearMemberRegister.getFullName(), + clearMemberRegister.getShortName(), + clearMemberRegister.getCategoryList(), + clearMemberRegister.getCorporationSole(), + clearMemberRegister.getAccount(), + clearMemberRegister.getBank(), + clearMemberRegister.getBankName(), + clearMemberRegister.getInn(), + clearMemberRegister.getBic(), + clearMemberRegister.getOgrn(), + clearMemberRegister.getCpp(), + clearMemberRegister.getOcpo(), + clearMemberRegister.getContractNumber(), + TimeUtil.toDateFromLocalDate(clearMemberRegister.getContractDate()), + TimeUtil.toDateFromLocalDate(clearMemberRegister.getRegistrationDate()), + TimeUtil.toDateFromLocalDate(clearMemberRegister.getSystemDate()), + TimeUtil.toDateFromInstant(clearMemberRegister.getAccessDate()), + TimeUtil.toDateFromInstant(clearMemberRegister.getSuspentionDate()), + TimeUtil.toDateFromInstant(clearMemberRegister.getReopeningDate()), + TimeUtil.toDateFromInstant(clearMemberRegister.getCloseDate()), + TimeUtil.toDateFromInstant(clearMemberRegister.getExclusionDate()), + clearMemberRegister.getAddress(), + clearMemberRegister.getEmail() + }; + return args; + } + +} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ContractRegisterMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ContractRegisterMapStore.java new file mode 100644 index 000000000..a97030e36 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ContractRegisterMapStore.java @@ -0,0 +1,97 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.clearing.classes.statics.data.register.ContractRegister; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.time.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; + +@Component +public class ContractRegisterMapStore extends TemplateMapStore { + + public ContractRegisterMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getTableName() { + return "CONTRACT_REGISTER"; + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_ContractRegister; + } + + @Override + public String[] getFields() { + return new String[]{"ID", "CREATED_AT", "UPDATED_AT", + "NAME", + "NUMBER", + "ISSUE_DATE", + "COMPANY_FULL_NAME", + "COMPANY_ID", + "DOCUMENT_TYPE", + "ISSUE_PLACE", + "ISSUER", + "ISSUER_CODE", + "PLACE", + "VALID_FROM_DATE", + "VALID_TO_DATE", + "CLOSE_DATE", + "COMMENT", + }; + } + + @Override + protected ContractRegister objectReader(ResultSet resultSet) throws SQLException { + ContractRegister object = new ContractRegister(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setName(resultSet.getObject("NAME", String.class)); + object.setNumber(resultSet.getObject("NUMBER", String.class)); + object.setIssueDate(getLocalDateFromSqlDate(resultSet, "ISSUE_DATE")); + object.setCompanyFullName(resultSet.getObject("COMPANY_FULL_NAME", Long.class)); + object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class)); + object.setDocumentType(resultSet.getObject("DOCUMENT_TYPE", String.class)); + object.setIssuePlace(resultSet.getObject("ISSUE_PLACE", String.class)); + object.setIssuer(resultSet.getObject("ISSUER", String.class)); + object.setIssuerCode(resultSet.getObject("ISSUER_CODE", String.class)); + object.setPlace(resultSet.getObject("PLACE", String.class)); + object.setValidFromDate(getLocalDateFromSqlDate(resultSet, "VALID_FROM_DATE")); + object.setValidToDate(getLocalDateFromSqlDate(resultSet, "VALID_TO_DATE")); + object.setCloseDate(getLocalDateFromSqlDate(resultSet, "CLOSE_DATE")); + object.setComment(resultSet.getObject("COMMENT", String.class)); + return object; + } + + @Override + protected Object[] objectToField(ContractRegister object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.toDateFromInstant(object.getCreated()), + TimeUtil.toDateFromInstant(object.getUpdated()), + object.getName(), + object.getNumber(), + TimeUtil.toDateFromLocalDate(object.getIssueDate()), + object.getCompanyFullName(), + object.getCompanyId(), + object.getDocumentType(), + object.getIssuePlace(), + object.getIssuer(), + object.getIssuerCode(), + object.getPlace(), + TimeUtil.toDateFromLocalDate(object.getValidFromDate()), + TimeUtil.toDateFromLocalDate(object.getValidToDate()), + TimeUtil.toDateFromLocalDate(object.getCloseDate()), + object.getComment(), + }; + return args; + } + +} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/CoveredDealRegisterMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/CoveredDealRegisterMapStore.java new file mode 100644 index 000000000..7ffb2875d --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/CoveredDealRegisterMapStore.java @@ -0,0 +1,101 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.clearing.classes.statics.data.register.CoveredDealRegister; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.time.TimeUtil; + +import java.math.BigDecimal; +import java.sql.ResultSet; +import java.sql.SQLException; + +@Component +public class CoveredDealRegisterMapStore extends TemplateMapStore { + + public CoveredDealRegisterMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getTableName() { + return "COVERED_DEAL_REGISTER"; + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_CoveredDealRegister; + } + + @Override + public String[] getFields() { + return new String[]{"ID", "CREATED_AT", "UPDATED_AT", + "EXECUTION_ID", + "COMPANY_FULL_NAME", + "TRADING_DATE", + "EXCHANGE_EXECUTION_ID", + "EXCHANGE_EXECUTION_TIME", + "SECURITY_SYMBOL", + "SECURITY_FULL_NAME", + "SELLER_FULL_NAME", + "SELLER_CLEARING_CODE", + "SELLER_ACCOUNT", + "BUYER_FULL_NAME", + "BUYER_CLEARING_CODE", + "BUYER_ACCOUNT", + "AMOUNT", + "CLEARING_DATE", + }; + } + + @Override + protected CoveredDealRegister objectReader(ResultSet resultSet) throws SQLException { + CoveredDealRegister object = new CoveredDealRegister(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setExecutionId(resultSet.getObject("EXECUTION_ID", Long.class)); + object.setCompanyFullName(resultSet.getObject("COMPANY_FULL_NAME", String.class)); + object.setTradingDate(getLocalDateFromSqlDate(resultSet, "TRADING_DATE")); + object.setExchangeExecutionId(resultSet.getObject("EXCHANGE_EXECUTION_ID", Long.class)); + object.setExchangeExecutionTime(getInstantFromTimestamp(resultSet, "EXCHANGE_EXECUTION_TIME")); + object.setSecuritySymbol(resultSet.getObject("SECURITY_SYMBOL", String.class)); + object.setSecurityFullName(resultSet.getObject("SECURITY_FULL_NAME", String.class)); + object.setSellerFullName(resultSet.getObject("SELLER_FULL_NAME", String.class)); + object.setSellerClearingCode(resultSet.getObject("SELLER_CLEARING_CODE", String.class)); + object.setSellerAccount(resultSet.getObject("SELLER_ACCOUNT", String.class)); + object.setBuyerFullName(resultSet.getObject("BUYER_FULL_NAME", String.class)); + object.setBuyerClearingCode(resultSet.getObject("BUYER_CLEARING_CODE", String.class)); + object.setBuyerAccount(resultSet.getObject("BUYER_ACCOUNT", String.class)); + object.setAmount(resultSet.getObject("AMOUNT", BigDecimal.class)); + object.setClearingDate(getLocalDateFromSqlDate(resultSet, "CLEARING_DATE")); + return object; + } + + @Override + protected Object[] objectToField(CoveredDealRegister object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.toDateFromInstant(object.getCreated()), + TimeUtil.toDateFromInstant(object.getUpdated()), + object.getExecutionId(), + object.getCompanyFullName(), + TimeUtil.toDateFromLocalDate(object.getTradingDate()), + object.getExchangeExecutionId(), + TimeUtil.toDateFromInstant(object.getExchangeExecutionTime()), + object.getSecuritySymbol(), + object.getSecurityFullName(), + object.getSellerFullName(), + object.getSellerClearingCode(), + object.getSellerAccount(), + object.getBuyerFullName(), + object.getBuyerClearingCode(), + object.getBuyerAccount(), + object.getAmount(), + TimeUtil.toDateFromLocalDate(object.getClearingDate()), + }; + return args; + } + +} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/DealRegisterMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/DealRegisterMapStore.java new file mode 100644 index 000000000..04c001815 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/DealRegisterMapStore.java @@ -0,0 +1,116 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.clearing.classes.statics.data.register.DealRegister; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.time.TimeUtil; + +import java.math.BigDecimal; +import java.sql.ResultSet; +import java.sql.SQLException; + +@Component +public class DealRegisterMapStore extends TemplateMapStore { + + public DealRegisterMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getTableName() { + return "DEAL_REGISTER"; + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_DealRegister; + } + + @Override + public String[] getFields() { + return new String[]{"ID", "CREATED_AT", "UPDATED_AT", + "EXECUTION_ID", + "EXCHANGE_EXECUTION_ID", + "EXCHANGE_EXECUTION_TIME", + "TRADING_DATE", + "ACCOUNT", + "MARKET", + "PRICE", + "AMOUNT", + "SIDE", + "SETTLEMENT_CURRENCY", + "COMPANY_ID", + "FIRST_LEG_SETTLEMENT_DATE", + "SECOND_LEG_SETTLEMENT_DATE", + "SECURITY_FULL_NAME", + "SECURITY_SYMBOL", + "SECURITY_ID", + "COUNTER_PARTY_ID", + "COVERAGE_STATUS", + "SESSION_ID", + "CLEARING_DATE", + }; + } + + @Override + protected DealRegister objectReader(ResultSet resultSet) throws SQLException { + DealRegister object = new DealRegister(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setExecutionId(resultSet.getObject("EXECUTION_ID", Long.class)); + object.setExchangeExecutionId(resultSet.getObject("EXCHANGE_EXECUTION_ID", Long.class)); + object.setExchangeExecutionTime(getInstantFromTimestamp(resultSet, "EXCHANGE_EXECUTION_TIME")); + object.setTradingDate(getLocalDateFromSqlDate(resultSet, "TRADING_DATE")); + object.setAccount(resultSet.getObject("ACCOUNT", String.class)); + object.setMarket(resultSet.getObject("MARKET", String.class)); + object.setPrice(resultSet.getObject("PRICE", BigDecimal.class)); + object.setAmount(resultSet.getObject("AMOUNT", BigDecimal.class)); + object.setSide(resultSet.getObject("SIDE", String.class)); + object.setSettlementCurrency(resultSet.getObject("SETTLEMENT_CURRENCY", String.class)); + object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class)); + object.setFirstLegSettlementDate(getLocalDateFromSqlDate(resultSet, "FIRST_LEG_SETTLEMENT_DATE")); + object.setSecondLegSettlementDate(getLocalDateFromSqlDate(resultSet, "SECOND_LEG_SETTLEMENT_DATE")); + object.setSecurityFullName(resultSet.getObject("SECURITY_FULL_NAME", String.class)); + object.setSecuritySymbol(resultSet.getObject("SECURITY_SYMBOL", String.class)); + object.setSecurityId(resultSet.getObject("SECURITY_ID", Long.class)); + object.setCounterPartyId(resultSet.getObject("COUNTER_PARTY_ID", Long.class)); + object.setCoverageStatus(resultSet.getObject("COVERAGE_STATUS", String.class)); + object.setSessionId(resultSet.getObject("SESSION_ID", Long.class)); + object.setClearingDate(getLocalDateFromSqlDate(resultSet, "CLEARING_DATE")); + return object; + } + + @Override + protected Object[] objectToField(DealRegister object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.toDateFromInstant(object.getCreated()), + TimeUtil.toDateFromInstant(object.getUpdated()), + object.getExecutionId(), + object.getExchangeExecutionId(), + TimeUtil.toDateFromInstant(object.getExchangeExecutionTime()), + TimeUtil.toDateFromLocalDate(object.getTradingDate()), + object.getAccount(), + object.getMarket(), + object.getPrice(), + object.getAmount(), + object.getSide(), + object.getSettlementCurrency(), + object.getCompanyId(), + TimeUtil.toDateFromLocalDate(object.getFirstLegSettlementDate()), + TimeUtil.toDateFromLocalDate(object.getSecondLegSettlementDate()), + object.getSecurityFullName(), + object.getSecuritySymbol(), + object.getSecurityId(), + object.getCounterPartyId(), + object.getCoverageStatus(), + object.getSessionId(), + TimeUtil.toDateFromLocalDate(object.getClearingDate()), + }; + return args; + } + +} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ExecutionDepositMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ExecutionDepositMapStore.java new file mode 100644 index 000000000..c8a5185dd --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ExecutionDepositMapStore.java @@ -0,0 +1,133 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.clearing.classes.statics.data.execution.ExecutionDeposit; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.time.TimeUtil; + +import java.math.BigDecimal; +import java.sql.ResultSet; +import java.sql.SQLException; + +@Component +public class ExecutionDepositMapStore extends TemplateMapStore { + public ExecutionDepositMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getTableName() { + return "EXECUTION_DEPOSIT"; + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_ExecutionDeposit; + } + + @Override + public String[] getFields() { + return new String[]{"ID", "CREATED_AT", "UPDATED_AT", + "EXCHANGE_EXECUTION_ID", + "EXCHANGE_EXECUTION_TIME", + "TRADING_DATE", + "ACCOUNT_ID", + "MARKET", + "PRICE", + "LOTS", + "QUANTITY", + "FIRST_LEG_AMOUNT", + "SECOND_LEG_AMOUNT", + "INTEREST_AMOUNT", + "SIDE", + "SETTLEMENT_CURRENCY", + "COMPANY_ID", + "DURATION", + "FIRST_LEG_SETTLEMENT_DATE", + "SECOND_LEG_SETTLEMENT_DATE", + "FIRST_LEG_SETTLEMENT_CODE", + "SECOND_LEG_SETTLEMENT_CODE", + "SECURITY_FULL_NAME", + "SECURITY_SYMBOL", + "SECURITY_ID", + "COUNTER_PARTY_ID", + "COVERAGE_STATUS", + "SESSION_ID", + "CLEARING_DATE", + }; + } + + @Override + protected ExecutionDeposit objectReader(ResultSet resultSet) throws SQLException { + ExecutionDeposit object = new ExecutionDeposit(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setExchangeExecutionId(resultSet.getObject("EXCHANGE_EXECUTION_ID", Long.class)); + object.setExchangeExecutionTime(getInstantFromTimestamp(resultSet, "EXCHANGE_EXECUTION_TIME")); + object.setTradingDate(getLocalDateFromSqlDate(resultSet, "TRADING_DATE")); + object.setAccountId(resultSet.getObject("ACCOUNT_ID", Long.class)); + object.setMarket(resultSet.getObject("MARKET", String.class)); + object.setPrice(resultSet.getObject("PRICE", BigDecimal.class)); + object.setLots(resultSet.getObject("LOTS", BigDecimal.class)); + object.setQuantity(resultSet.getObject("QUANTITY", BigDecimal.class)); + object.setFirstLegAmount(resultSet.getObject("FIRST_LEG_AMOUNT", BigDecimal.class)); + object.setSecondLegAmount(resultSet.getObject("SECOND_LEG_AMOUNT", BigDecimal.class)); + object.setInterestAmount(resultSet.getObject("INTEREST_AMOUNT", BigDecimal.class)); + object.setSide(resultSet.getObject("SIDE", String.class)); + object.setSettlementCurrency(resultSet.getObject("SETTLEMENT_CURRENCY", String.class)); + object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class)); + object.setDuration(resultSet.getObject("DURATION", Long.class)); + object.setFirstLegSettlementDate(getLocalDateFromSqlDate(resultSet, "FIRST_LEG_SETTLEMENT_DATE")); + object.setSecondLegSettlementDate(getLocalDateFromSqlDate(resultSet, "SECOND_LEG_SETTLEMENT_DATE")); + object.setFirstLegSettlementCode(getLocalDateFromSqlDate(resultSet, "FIRST_LEG_SETTLEMENT_CODE")); + object.setSecondLegSettlementCode(getLocalDateFromSqlDate(resultSet, "SECOND_LEG_SETTLEMENT_CODE")); + object.setSecurityFullName(resultSet.getObject("SECURITY_FULL_NAME", String.class)); + object.setSecuritySymbol(resultSet.getObject("SECURITY_SYMBOL", String.class)); + object.setSecurityId(resultSet.getObject("SECURITY_ID", Long.class)); + object.setCounterPartyId(resultSet.getObject("COUNTER_PARTY_ID", Long.class)); + object.setCoverageStatus(resultSet.getObject("COVERAGE_STATUS", String.class)); + object.setSessionId(resultSet.getObject("SESSION_ID", Long.class)); + object.setClearingDate(getLocalDateFromSqlDate(resultSet, "CLEARING_DATE")); + return object; + } + + @Override + protected Object[] objectToField(ExecutionDeposit object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.toDateFromInstant(object.getCreated()), + TimeUtil.toDateFromInstant(object.getUpdated()), + object.getExchangeExecutionId(), + TimeUtil.toDateFromInstant(object.getExchangeExecutionTime()), + TimeUtil.toDateFromLocalDate(object.getTradingDate()), + object.getAccountId(), + object.getMarket(), + object.getPrice(), + object.getLots(), + object.getQuantity(), + object.getFirstLegAmount(), + object.getSecondLegAmount(), + object.getInterestAmount(), + object.getSide(), + object.getSettlementCurrency(), + object.getCompanyId(), + object.getDuration(), + TimeUtil.toDateFromLocalDate(object.getFirstLegSettlementDate()), + TimeUtil.toDateFromLocalDate(object.getSecondLegSettlementDate()), + TimeUtil.toDateFromLocalDate(object.getFirstLegSettlementCode()), + TimeUtil.toDateFromLocalDate(object.getSecondLegSettlementCode()), + object.getSecurityFullName(), + object.getSecuritySymbol(), + object.getSecurityId(), + object.getCounterPartyId(), + object.getCoverageStatus(), + object.getSessionId(), + TimeUtil.toDateFromLocalDate(object.getClearingDate()), + }; + return args; + } + +} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/OrderRegisterMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/OrderRegisterMapStore.java new file mode 100644 index 000000000..d8f63be13 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/OrderRegisterMapStore.java @@ -0,0 +1,83 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.clearing.classes.statics.data.register.OrderRegister; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.time.TimeUtil; + +import java.math.BigDecimal; +import java.sql.ResultSet; +import java.sql.SQLException; + +@Component +public class OrderRegisterMapStore extends TemplateMapStore { + + public OrderRegisterMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getTableName() { + return "ORDER_REGISTER"; + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_OrderRegister; + } + + @Override + public String[] getFields() { + return new String[]{"ID", "CREATED_AT", "UPDATED_AT", + "CREDIT_LEG_ACCOUNT", + "CREDIT_LEG_AMOUNT", + "CREDIT_LEG_CURRENCY_CODE", + "CREDIT_LEG_DIRECTION", + "DEBIT_LEG_ACCOUNT", + "SENDER", + "ADDRESSEE", + "DOCUMENT_NUMBER", + "CLEARING_DATE", + }; + } + + @Override + protected OrderRegister objectReader(ResultSet resultSet) throws SQLException { + OrderRegister object = new OrderRegister(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setCreditLegAccount(resultSet.getObject("CREDIT_LEG_ACCOUNT", String.class)); + object.setCreditLegAmount(resultSet.getObject("CREDIT_LEG_AMOUNT", BigDecimal.class)); + object.setCreditLegCurrencyCode(resultSet.getObject("CREDIT_LEG_CURRENCY_CODE", String.class)); + object.setCreditLegDirection(resultSet.getObject("CREDIT_LEG_DIRECTION", Long.class)); + object.setDebitLegAccount(resultSet.getObject("DEBIT_LEG_ACCOUNT", String.class)); + object.setSender(resultSet.getObject("SENDER", String.class)); + object.setAddressee(resultSet.getObject("ADDRESSEE", String.class)); + object.setDocumentNumber(resultSet.getObject("DOCUMENT_NUMBER", String.class)); + object.setClearingDate(getLocalDateFromSqlDate(resultSet, "CLEARING_DATE")); + return object; + } + + @Override + protected Object[] objectToField(OrderRegister object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.toDateFromInstant(object.getCreated()), + TimeUtil.toDateFromInstant(object.getUpdated()), + object.getCreditLegAccount(), + object.getCreditLegAmount(), + object.getCreditLegCurrencyCode(), + object.getCreditLegDirection(), + object.getDebitLegAccount(), + object.getSender(), + object.getAddressee(), + object.getDocumentNumber(), + TimeUtil.toDateFromLocalDate(object.getClearingDate()), + }; + return args; + } + +} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ReportRegisterMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ReportRegisterMapStore.java new file mode 100644 index 000000000..2a0f11026 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/ReportRegisterMapStore.java @@ -0,0 +1,76 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.clearing.classes.statics.data.register.ReportRegister; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.time.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; + +@Component +public class ReportRegisterMapStore extends TemplateMapStore { + + public ReportRegisterMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getTableName() { + return "REPORT_REGISTER"; + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_ReportRegister; + } + + @Override + public String[] getFields() { + return new String[]{"ID", "CREATED_AT", "UPDATED_AT", + "COMPANY_FULL_NAME", + "CLEARING_CODE", + "SESSION_ID", + "COMMENT", + "NAME", + "QUANTITY", + "CLEARING_DATE", + }; + } + + @Override + protected ReportRegister objectReader(ResultSet resultSet) throws SQLException { + ReportRegister object = new ReportRegister(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setCompanyFullName(resultSet.getObject("COMPANY_FULL_NAME", String.class)); + object.setClearingCode(resultSet.getObject("CLEARING_CODE", String.class)); + object.setSessionId(resultSet.getObject("SESSION_ID", Long.class)); + object.setComment(resultSet.getObject("COMMENT", String.class)); + object.setName(resultSet.getObject("NAME", String.class)); + object.setQuantity(resultSet.getObject("QUANTITY", Long.class)); + object.setClearingDate(getLocalDateFromSqlDate(resultSet, "CLEARING_DATE")); + return object; + } + + @Override + protected Object[] objectToField(ReportRegister object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.toDateFromInstant(object.getCreated()), + TimeUtil.toDateFromInstant(object.getUpdated()), + object.getCompanyFullName(), + object.getClearingCode(), + object.getSessionId(), + object.getComment(), + object.getName(), + object.getQuantity(), + TimeUtil.toDateFromLocalDate(object.getClearingDate()), + }; + return args; + } + +} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/UncoveredDealRegisterMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/UncoveredDealRegisterMapStore.java new file mode 100644 index 000000000..c4df8b816 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/UncoveredDealRegisterMapStore.java @@ -0,0 +1,104 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.clearing.classes.statics.data.register.UncoveredDealRegister; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.platform.utils.time.TimeUtil; + +import java.math.BigDecimal; +import java.sql.ResultSet; +import java.sql.SQLException; + +@Component +public class UncoveredDealRegisterMapStore extends TemplateMapStore { + + public UncoveredDealRegisterMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getTableName() { + return "UNCOVERED_DEAL_REGISTER"; + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_UncoveredDealRegister; + } + + @Override + public String[] getFields() { + return new String[]{"ID", "CREATED_AT", "UPDATED_AT", + "EXECUTION_ID", + "COMPANY_FULL_NAME", + "TRADING_DATE", + "EXCHANGE_EXECUTION_ID", + "EXCHANGE_EXECUTION_TIME", + "SECURITY_SYMBOL", + "SECURITY_FULL_NAME", + "SELLER_FULL_NAME", + "SELLER_CLEARING_CODE", + "SELLER_ACCOUNT", + "BUYER_FULL_NAME", + "BUYER_CLEARING_CODE", + "BUYER_ACCOUNT", + "AMOUNT", + "RESULT_STATUS", + "CLEARING_DATE", + }; + } + + @Override + protected UncoveredDealRegister objectReader(ResultSet resultSet) throws SQLException { + UncoveredDealRegister object = new UncoveredDealRegister(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setExecutionId(resultSet.getObject("EXECUTION_ID", Long.class)); + object.setCompanyFullName(resultSet.getObject("COMPANY_FULL_NAME", String.class)); + object.setTradingDate(getLocalDateFromSqlDate(resultSet, "TRADING_DATE")); + object.setExchangeExecutionId(resultSet.getObject("EXCHANGE_EXECUTION_ID", Long.class)); + object.setExchangeExecutionTime(getInstantFromTimestamp(resultSet, "EXCHANGE_EXECUTION_TIME")); + object.setSecuritySymbol(resultSet.getObject("SECURITY_SYMBOL", String.class)); + object.setSecurityFullName(resultSet.getObject("SECURITY_FULL_NAME", String.class)); + object.setSellerFullName(resultSet.getObject("SELLER_FULL_NAME", String.class)); + object.setSellerClearingCode(resultSet.getObject("SELLER_CLEARING_CODE", String.class)); + object.setSellerAccount(resultSet.getObject("SELLER_ACCOUNT", String.class)); + object.setBuyerFullName(resultSet.getObject("BUYER_FULL_NAME", String.class)); + object.setBuyerClearingCode(resultSet.getObject("BUYER_CLEARING_CODE", String.class)); + object.setBuyerAccount(resultSet.getObject("BUYER_ACCOUNT", String.class)); + object.setAmount(resultSet.getObject("AMOUNT", BigDecimal.class)); + object.setResultStatus(resultSet.getObject("RESULT_STATUS", String.class)); + object.setClearingDate(getLocalDateFromSqlDate(resultSet, "CLEARING_DATE")); + return object; + } + + @Override + protected Object[] objectToField(UncoveredDealRegister object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.toDateFromInstant(object.getCreated()), + TimeUtil.toDateFromInstant(object.getUpdated()), + object.getExecutionId(), + object.getCompanyFullName(), + TimeUtil.toDateFromLocalDate(object.getTradingDate()), + object.getExchangeExecutionId(), + TimeUtil.toDateFromInstant(object.getExchangeExecutionTime()), + object.getSecuritySymbol(), + object.getSecurityFullName(), + object.getSellerFullName(), + object.getSellerClearingCode(), + object.getSellerAccount(), + object.getBuyerFullName(), + object.getBuyerClearingCode(), + object.getBuyerAccount(), + object.getAmount(), + object.getResultStatus(), + TimeUtil.toDateFromLocalDate(object.getClearingDate()), + }; + return args; + } + +} 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 0b9a7a970..dd7db6001 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 @@ -108,6 +108,16 @@ public final class IMDGDistributedNames { public static final String Map_Session = "Map_Session"; public static final String Map_Notification = "Map_Notification"; public static final String Map_LiabilitiesClaimsAssets = "Map_LiabilitiesClaimsAssets"; + public static final String Map_ClearMemberRegister = "Map_ClearMemberRegister"; + public static final String Map_BalanceRegister = "Map_BalanceRegister"; + public static final String Map_ExecutionDeposit = "Map_ExecutionDeposit"; + public static final String Map_DealRegister = "Map_DealRegister"; + public static final String Map_AdmittedDealRegister = "Map_AdmittedDealRegister"; + public static final String Map_CoveredDealRegister = "Map_CoveredDealRegister"; + public static final String Map_UncoveredDealRegister = "Map_UncoveredDealRegister"; + public static final String Map_ReportRegister = "Map_ReportRegister"; + public static final String Map_ContractRegister = "Map_ContractRegister"; + public static final String Map_OrderRegister = "Map_OrderRegister"; public static final String MAP_SEQUENCE_NAME = "MAP_SEQUENCE_NAME"; // todo вынести idGenerator отдельно и завернуть в метод, чтобы не напрямую обращаться.