ialbert 2022-12-28 19:11:37 +03:00
parent ad410be755
commit 6312389943
24 changed files with 2974 additions and 30 deletions

View file

@ -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;
}
}

View file

@ -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;
}
}

View file

@ -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;
}
}

View file

@ -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;
/**
* Реестр сделок допущенных к клирингу
* <p>
* 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;
}

View file

@ -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;
}
}

View file

@ -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;
}
}

View file

@ -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;
/**
* Реестр сделок допущенных к клирингу
* <p>
* 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;
}
}

View file

@ -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;
}
}

View file

@ -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;
}
}

View file

@ -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;
}
}

View file

@ -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;
}
}

View file

@ -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;
}
}

View file

@ -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;
}
}

View file

@ -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<AdmittedDealRegister> {
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;
}
}

View file

@ -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<BalanceRegister> {
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;
}
}

View file

@ -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<ClearMemberRegister> {
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;
}
}

View file

@ -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<ContractRegister> {
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;
}
}

View file

@ -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<CoveredDealRegister> {
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;
}
}

View file

@ -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<DealRegister> {
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;
}
}

View file

@ -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<ExecutionDeposit> {
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;
}
}

View file

@ -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<OrderRegister> {
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;
}
}

View file

@ -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<ReportRegister> {
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;
}
}

View file

@ -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<UncoveredDealRegister> {
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;
}
}

View file

@ -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 отдельно и завернуть в метод, чтобы не напрямую обращаться.