http://jira.mfd.msk:8088/browse/CLS-613 DDL classes версии 3.1, классы

This commit is contained in:
AKurakin 2024-03-15 14:57:30 +03:00
parent 3ab04ca9e8
commit a804a64078
59 changed files with 1913 additions and 70 deletions

View file

@ -31,6 +31,9 @@ public class ClientCodeNewAction implements IAction<ClientCodeNewRequest> {
@ApiModelProperty(value = "Номер депозитарного счета", example = "1234") @ApiModelProperty(value = "Номер депозитарного счета", example = "1234")
@JsonProperty @JsonProperty
private Long depoAccountId; private Long depoAccountId;
@ApiModelProperty(value = "Список валютных счетов", example = "[1234,5678]")
@JsonProperty
private List<Long> currencyAccountList;
@ApiModelProperty(value = "Наименование статуса", example = "ACTV") @ApiModelProperty(value = "Наименование статуса", example = "ACTV")
@JsonProperty @JsonProperty
private String status; private String status;
@ -43,6 +46,7 @@ public class ClientCodeNewAction implements IAction<ClientCodeNewRequest> {
req.setTradingClearingRegistryId(this.tradingClearingRegistryId); req.setTradingClearingRegistryId(this.tradingClearingRegistryId);
req.setMoneyAccountId(this.moneyAccountId); req.setMoneyAccountId(this.moneyAccountId);
req.setDepoAccountId(this.depoAccountId); req.setDepoAccountId(this.depoAccountId);
req.setCurrencyAccountList(this.currencyAccountList);
req.setStatus(this.status); req.setStatus(this.status);
return req; return req;
} }
@ -93,6 +97,14 @@ public class ClientCodeNewAction implements IAction<ClientCodeNewRequest> {
this.depoAccountId = depoAccountId; this.depoAccountId = depoAccountId;
} }
public List<Long> getCurrencyAccountList() {
return currencyAccountList;
}
public void setCurrencyAccountList(List<Long> currencyAccountList) {
this.currencyAccountList = currencyAccountList;
}
public String getStatus() { public String getStatus() {
return status; return status;
} }

View file

@ -32,6 +32,9 @@ public class ClientCodeUpdateAction implements IAction<ClientCodeUpdateRequest>
@ApiModelProperty(value = "Номер депозитарного счета", example = "1234") @ApiModelProperty(value = "Номер депозитарного счета", example = "1234")
@JsonProperty @JsonProperty
private Long depoAccountId; private Long depoAccountId;
@ApiModelProperty(value = "Список валютных счетов", example = "[1234,5678]")
@JsonProperty
private List<Long> currencyAccountList;
@ApiModelProperty(value = "Наименование статуса", example = "ACTV") @ApiModelProperty(value = "Наименование статуса", example = "ACTV")
@JsonProperty @JsonProperty
private String status; private String status;
@ -46,6 +49,7 @@ public class ClientCodeUpdateAction implements IAction<ClientCodeUpdateRequest>
req.setTradingClearingRegistryId(this.tradingClearingRegistryId); req.setTradingClearingRegistryId(this.tradingClearingRegistryId);
req.setMoneyAccountId(this.moneyAccountId); req.setMoneyAccountId(this.moneyAccountId);
req.setDepoAccountId(this.depoAccountId); req.setDepoAccountId(this.depoAccountId);
req.setCurrencyAccountList(this.currencyAccountList);
req.setStatus(this.status); req.setStatus(this.status);
return req; return req;
} }
@ -104,6 +108,14 @@ public class ClientCodeUpdateAction implements IAction<ClientCodeUpdateRequest>
this.depoAccountId = depoAccountId; this.depoAccountId = depoAccountId;
} }
public List<Long> getCurrencyAccountList() {
return currencyAccountList;
}
public void setCurrencyAccountList(List<Long> currencyAccountList) {
this.currencyAccountList = currencyAccountList;
}
public String getStatus() { public String getStatus() {
return status; return status;
} }

View file

@ -14,6 +14,7 @@ public class Account extends BusinessObject {
private String account; private String account;
private String accountType; private String accountType;
private Long relationId; private Long relationId;
private String currency;
private String status; private String status;
private String processingSign; private String processingSign;
private Long companyId; private Long companyId;
@ -42,6 +43,14 @@ public class Account extends BusinessObject {
this.relationId = value; this.relationId = value;
} }
public String getCurrency() {
return currency;
}
public void setCurrency(String currency) {
this.currency = currency;
}
public String getStatus() { public String getStatus() {
return status; return status;
} }

View file

@ -18,6 +18,7 @@ public class ClientCode extends BusinessObject {
private Long tradingClearingRegistryId; private Long tradingClearingRegistryId;
private Long moneyAccountId; private Long moneyAccountId;
private Long depoAccountId; private Long depoAccountId;
private Long currencyAccountId;
private String status; private String status;
public Long getCompanyId() { public Long getCompanyId() {
@ -60,6 +61,14 @@ public class ClientCode extends BusinessObject {
this.depoAccountId = value; this.depoAccountId = value;
} }
public Long getCurrencyAccountId() {
return currencyAccountId;
}
public void setCurrencyAccountId(Long value) {
this.currencyAccountId = value;
}
public String getStatus() { public String getStatus() {
return status; return status;
} }

View file

@ -0,0 +1,33 @@
package ru.clearing.classes.statics.data.company;
import ru.clearing.classes.ConstSerializable;
import ru.spcex.platform.classes.base.SpcexObjectBase;
/**
* Параметры расчетной организации
*
* DB table: SETTLEMENT_HOUSE_PROPERTIES
**/
public class SettlementHouseProperties extends SpcexObjectBase {
private static final long serialVersionUID = ConstSerializable.serialVersionUID;
private Long companyId;
private String currencyCode;
public Long getCompanyId() {
return companyId;
}
public void setCompanyId(Long value) {
this.companyId = value;
}
public String getCurrencyCode() {
return currencyCode;
}
public void setCurrencyCode(String value) {
this.currencyCode = value;
}
}

View file

@ -0,0 +1,28 @@
package ru.clearing.classes.statics.data.company;
import ru.clearing.classes.ConstSerializable;
import ru.clearing.classes.objects.BusinessEvent;
import java.io.Serial;
/**
* Изменение состояния объекта Параметры расчетной организации
*
* DB table: SETTLEMENT_HOUSE_PROPERTIES_HISTORY
**/
public class SettlementHousePropertiesHistory extends BusinessEvent<SettlementHouseProperties> {
@Serial
private static final long serialVersionUID = ConstSerializable.serialVersionUID;
private SettlementHouseProperties object;
@Override
public SettlementHouseProperties getObject() {
return object;
}
@Override
public void setObject(SettlementHouseProperties object) {
this.object = object;
}
}

View file

@ -0,0 +1,180 @@
package ru.clearing.classes.statics.data.execution;
import ru.clearing.classes.ConstSerializable;
import ru.spcex.platform.classes.base.interfaces.ExecutionType;
import java.math.BigDecimal;
import java.time.Instant;
import java.time.LocalDate;
/**
* Сделки с валютными инструментами
* <p>
* DB table: EXECUTION_CURRENCY
**/
public class ExecutionCurrency extends ExecutionCommon {
private static final long serialVersionUID = ConstSerializable.serialVersionUID;
// private Long exchangeExecutionId;
// private Instant exchangeExecutionTime;
private Instant exchangeExecutionMicroseconds;
// private LocalDate tradingDate;
private LocalDate settlementDate;
private String settlementCode;
// private Long securityId;
// private String securitySymbol;
private String securityName;
// private Long companyId;
private Long partyTradingClearingRegistryId;
// private String partyTradingClearingRegistry;
// private Long counterPartyId;
// private Long counterPartyTradingClearingRegistryId;
// private String counterPartyTradingClearingRegistry;
// private String market;
// private BigDecimal price;
// extend: private BigDecimal lotSize;
// private BigDecimal lots;
private BigDecimal settlementAmount;
// private BigDecimal quantity;
// private String side;
private String currencyCode;
private String settlementOrganization;
// private String coverageStatus;
// private Long sessionId;
private String depoCode;
// private LocalDate clearingDate;
// --- API ExecutionCommon ---
public ExecutionType type() {
return ExecutionType.ExecutionCurrency;
}
@Deprecated
@Override
public Long getTradingClearingRegistryId() {
return getPartyTradingClearingRegistryId();
}
@Deprecated
@Override
public void setTradingClearingRegistryId(Long partyTradingClearingRegistryId) {
setPartyTradingClearingRegistryId(partyTradingClearingRegistryId);
}
@Deprecated
@Override
public BigDecimal getInterestAmount() {
throw new IllegalStateException("Not implemented for ExecutionCurrency");
}
@Deprecated
@Override
public void setInterestAmount(BigDecimal interestAmount) {
throw new IllegalStateException("Not implemented for ExecutionCurrency");
}
@Deprecated
@Override
public String getSettlementCurrency() {
throw new IllegalStateException("Not implemented for ExecutionCurrency");
}
@Deprecated
@Override
public void setSettlementCurrency(String settlementCurrency) {
throw new IllegalStateException("Not implemented for ExecutionCurrency");
}
@Deprecated
@Override
public Long getDuration() {
throw new IllegalStateException("Not implemented for ExecutionCurrency");
}
@Deprecated
@Override
public void setDuration(Long duration) {
throw new IllegalStateException("Not implemented for ExecutionCurrency");
}
@Deprecated
@Override
public String getSecurityFullName() {
return getSecurityName();
}
@Deprecated
@Override
public void setSecurityFullName(String securityFullName) {
setSecurityName(securityFullName);
}
// --- end of API ---
public Instant getExchangeExecutionMicroseconds() {
return exchangeExecutionMicroseconds;
}
public void setExchangeExecutionMicroseconds(Instant value) {
this.exchangeExecutionMicroseconds = value;
}
public LocalDate getSettlementDate() {
return settlementDate;
}
public void setSettlementDate(LocalDate value) {
this.settlementDate = value;
}
public String getSettlementCode() {
return settlementCode;
}
public void setSettlementCode(String value) {
this.settlementCode = value;
}
public String getSecurityName() {
return securityName;
}
public void setSecurityName(String value) {
this.securityName = value;
}
public Long getPartyTradingClearingRegistryId() {
return partyTradingClearingRegistryId;
}
public void setPartyTradingClearingRegistryId(Long value) {
this.partyTradingClearingRegistryId = value;
}
public BigDecimal getSettlementAmount() {
return settlementAmount;
}
public void setSettlementAmount(BigDecimal value) {
this.settlementAmount = value;
}
public String getCurrencyCode() {
return currencyCode;
}
public void setCurrencyCode(String currencyCode) {
this.currencyCode = currencyCode;
}
public String getSettlementOrganization() {
return settlementOrganization;
}
public void setSettlementOrganization(String value) {
this.settlementOrganization = value;
}
public String getDepoCode() {
return depoCode;
}
public void setDepoCode(String value) {
this.depoCode = value;
}
}

View file

@ -0,0 +1,28 @@
package ru.clearing.classes.statics.data.execution;
import ru.clearing.classes.ConstSerializable;
import ru.clearing.classes.objects.BusinessEvent;
import java.io.Serial;
/**
* Изменение состояния объекта Сделки с валютными инструментами
* <p>
* DB table: EXECUTION_CURRENCY_HISTORY
**/
public class ExecutionCurrencyHistory extends BusinessEvent<ExecutionCurrency> {
@Serial
private static final long serialVersionUID = ConstSerializable.serialVersionUID;
private ExecutionCurrency object;
@Override
public ExecutionCurrency getObject() {
return object;
}
@Override
public void setObject(ExecutionCurrency object) {
this.object = object;
}
}

View file

@ -13,6 +13,8 @@ public class Listing extends BusinessObject {
private String symbolName; private String symbolName;
private String tradingCurrency; private String tradingCurrency;
private String workflowStatus; private String workflowStatus;
private BigDecimal minStep;
private BigDecimal precision;
public Long getSecurityId() { public Long getSecurityId() {
return securityId; return securityId;
@ -69,4 +71,20 @@ public class Listing extends BusinessObject {
public void setWorkflowStatus(String workflowStatus) { public void setWorkflowStatus(String workflowStatus) {
this.workflowStatus = workflowStatus; this.workflowStatus = workflowStatus;
} }
public BigDecimal getMinStep() {
return minStep;
}
public void setMinStep(BigDecimal minStep) {
this.minStep = minStep;
}
public BigDecimal getPrecision() {
return precision;
}
public void setPrecision(BigDecimal precision) {
this.precision = precision;
}
} }

View file

@ -17,6 +17,8 @@ public class DepoBalanceRegister extends BusinessObject {
private Long companyId; private Long companyId;
private Long sessionId; private Long sessionId;
private String setHouseName;
private String number;
private String depoCode; private String depoCode;
private BigDecimal quantity; private BigDecimal quantity;
private String securitySymbol; private String securitySymbol;
@ -36,6 +38,20 @@ public class DepoBalanceRegister extends BusinessObject {
this.sessionId=value; this.sessionId=value;
} }
public String getSetHouseName() {
return setHouseName;
}
public void setSetHouseName(String value) {
this.setHouseName=value;
}
public String getNumber() {
return number;
}
public void setNumber(String value) {
this.number=value;
}
public String getDepoCode() { public String getDepoCode() {
return depoCode; return depoCode;
} }

View file

@ -0,0 +1,61 @@
package ru.clearing.classes.statics.data.register;
import ru.clearing.classes.ConstSerializable;
import ru.clearing.classes.objects.BusinessObject;
/**
* Результат запроса к gateway
* <p>
* DB table: GATEWAY_RESULT
**/
public class GatewayResult extends BusinessObject {
private static final long serialVersionUID = ConstSerializable.serialVersionUID;
private String requestId;
private String nameRequest;
private String request;
private String result;
private String gatewayResultStatus;
public String getRequestId() {
return requestId;
}
public void setRequestId(String value) {
this.requestId = value;
}
public String getNameRequest() {
return nameRequest;
}
public void setNameRequest(String value) {
this.nameRequest = value;
}
public String getRequest() {
return request;
}
public void setRequest(String value) {
this.request = value;
}
public String getResult() {
return result;
}
public void setResult(String value) {
this.result = value;
}
public String getGatewayResultStatus() {
return gatewayResultStatus;
}
public void setGatewayResultStatus(String value) {
this.gatewayResultStatus = value;
}
}

View file

@ -14,6 +14,8 @@ public class MoneyBalanceRegister extends BusinessObject {
private static final long serialVersionUID = ConstSerializable.serialVersionUID; private static final long serialVersionUID = ConstSerializable.serialVersionUID;
private String setHouseName; private String setHouseName;
private String number;
private String currencyCode;
private String account; private String account;
private String infoAccount; private String infoAccount;
private BigDecimal remainderSum; private BigDecimal remainderSum;
@ -24,30 +26,6 @@ public class MoneyBalanceRegister extends BusinessObject {
private String companyFullName; private String companyFullName;
private Long companyId; private Long companyId;
public static MoneyBalanceRegister makeMoneyBalanceRegister(String setHouseName,
String account,
String infoAccount,
BigDecimal remainderSum,
BigDecimal blockedSum,
BigDecimal unblockedSum,
String inn,
Long sessionId,
String companyFullName,
Long companyId) {
MoneyBalanceRegister moneyBalanceRegister = new MoneyBalanceRegister();
moneyBalanceRegister.setSetHouseName(setHouseName);
moneyBalanceRegister.setAccount(account);
moneyBalanceRegister.setInfoAccount(infoAccount);
moneyBalanceRegister.setRemainderSum(remainderSum);
moneyBalanceRegister.setBlockedSum(blockedSum);
moneyBalanceRegister.setUnblockedSum(unblockedSum);
moneyBalanceRegister.setInn(inn);
moneyBalanceRegister.setSessionId(sessionId);
moneyBalanceRegister.setCompanyFullName(companyFullName);
moneyBalanceRegister.setCompanyId(companyId);
return moneyBalanceRegister;
}
public String getSetHouseName() { public String getSetHouseName() {
return setHouseName; return setHouseName;
} }
@ -56,6 +34,22 @@ public class MoneyBalanceRegister extends BusinessObject {
this.setHouseName = value; this.setHouseName = value;
} }
public String getNumber() {
return number;
}
public void setNumber(String value) {
this.number = value;
}
public String getCurrencyCode() {
return currencyCode;
}
public void setCurrencyCode(String value) {
this.currencyCode = value;
}
public String getAccount() { public String getAccount() {
return account; return account;
} }

View file

@ -0,0 +1,51 @@
package ru.clearing.classes.statics.data.register;
//todo в какой пэкэдж - в data.sdf; или data.registers;?
import ru.clearing.classes.ConstSerializable;
import ru.clearing.classes.objects.BusinessObject;
/**
* Пары файлов
*
* DB table: PAIR_SDF
**/
public class PairSdf extends BusinessObject {
private static final long serialVersionUID = ConstSerializable.serialVersionUID;
private String inSDfId;
private String inSDf;
private String outSDfId;
private String outSDf;
public String getInSDfId() {
return inSDfId;
}
public void setInSDfId(String value) {
this.inSDfId = value;
}
public String getInSDf() {
return inSDf;
}
public void setInSDf(String value) {
this.inSDf = value;
}
public String getOutSDfId() {
return outSDfId;
}
public void setOutSDfId(String value) {
this.outSDfId = value;
}
public String getOutSDf() {
return outSDf;
}
public void setOutSDf(String value) {
this.outSDf = value;
}
}

View file

@ -0,0 +1,51 @@
package ru.clearing.classes.statics.data.registry;
import ru.clearing.classes.ConstSerializable;
import ru.clearing.classes.objects.BusinessObject;
/**
* Список счетов ТКР
* <p>
* DB table: TRADING_CLEARING_REGISTRY_LIST
**/
public class TradingClearingRegistryList extends BusinessObject {
private static final long serialVersionUID = ConstSerializable.serialVersionUID;
private Long tradingClearingRegistryId;
private Long accountId;
private String currency;
private String status;
public Long getTradingClearingRegistryId() {
return tradingClearingRegistryId;
}
public void setTradingClearingRegistryId(Long value) {
this.tradingClearingRegistryId = value;
}
public Long getAccountId() {
return accountId;
}
public void setAccountId(Long value) {
this.accountId = value;
}
public String getCurrency() {
return currency;
}
public void setCurrency(String value) {
this.currency = value;
}
public String getStatus() {
return status;
}
public void setStatus(String value) {
this.status = value;
}
}

View file

@ -0,0 +1,28 @@
package ru.clearing.classes.statics.data.registry;
import ru.clearing.classes.ConstSerializable;
import ru.clearing.classes.objects.BusinessEvent;
import java.io.Serial;
/**
* Изменение состояния объекта Список счетов ТКР
* <p>
* DB table: TRADING_CLEARING_REGISTRY_LIST_HISTORY
**/
public class TradingClearingRegistryListHistory extends BusinessEvent<TradingClearingRegistryList> {
@Serial
private static final long serialVersionUID = ConstSerializable.serialVersionUID;
private TradingClearingRegistryList object;
@Override
public TradingClearingRegistryList getObject() {
return object;
}
@Override
public void setObject(TradingClearingRegistryList object) {
this.object = object;
}
}

View file

@ -6,6 +6,7 @@ import ru.spcex.platform.classes.base.interfaces.WithFileName;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.time.Instant; import java.time.Instant;
import java.time.LocalDate;
/** /**
* ДФ-06 Запрос на зачисление/списание денежных средств * ДФ-06 Запрос на зачисление/списание денежных средств
@ -28,6 +29,9 @@ public class SDf06 extends SpcexObjectBase implements WithFileName {
private String fileName; private String fileName;
private Instant generationTime; private Instant generationTime;
private Long generationId; private Long generationId;
private String Doc_Num;
private LocalDate Doc_Date;
private String pay_val;
public String getAccount() { public String getAccount() {
return account; return account;
@ -133,4 +137,25 @@ public class SDf06 extends SpcexObjectBase implements WithFileName {
this.generationId = value; this.generationId = value;
} }
public String getDoc_Num() {
return Doc_Num;
}
public void setDoc_Num(String value) {
this.Doc_Num=value;
}
public LocalDate getDoc_Date() {
return Doc_Date;
}
public void setDoc_Date(LocalDate value) {
this.Doc_Date=value;
}
public String getPay_val() {
return pay_val;
}
public void setPay_val(String value) {
this.pay_val=value;
}
} }

View file

@ -5,6 +5,7 @@ import ru.spcex.platform.classes.base.SpcexObjectBase;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.time.Instant; import java.time.Instant;
import java.time.LocalDate;
/** /**
* ДФ-07 Ответ на запрос по зачислению/списанию денежных средств * ДФ-07 Ответ на запрос по зачислению/списанию денежных средств
@ -28,6 +29,9 @@ public class SDf07 extends SpcexObjectBase {
private Instant generationTime; private Instant generationTime;
private Long generationId; private Long generationId;
private Long inSDfId; private Long inSDfId;
private String Doc_Num;
private LocalDate Doc_Date;
private String pay_val;
public String getAccount() { public String getAccount() {
return account; return account;
@ -141,4 +145,28 @@ public class SDf07 extends SpcexObjectBase {
this.inSDfId = value; this.inSDfId = value;
} }
public String getDoc_Num() {
return Doc_Num;
}
public void setDoc_Num(String value) {
this.Doc_Num = value;
}
public LocalDate getDoc_Date() {
return Doc_Date;
}
public void setDoc_Date(LocalDate value) {
this.Doc_Date = value;
}
public String getPay_val() {
return pay_val;
}
public void setPay_val(String value) {
this.pay_val = value;
}
} }

View file

@ -4,6 +4,7 @@ import ru.clearing.classes.ConstSerializable;
import ru.spcex.platform.classes.base.SpcexObjectBase; import ru.spcex.platform.classes.base.SpcexObjectBase;
import java.time.Instant; import java.time.Instant;
import java.time.LocalDate;
/** /**
* ДФ-54 Вывод свободных средств для инициаторов категории В с клирингового счета 30414 * ДФ-54 Вывод свободных средств для инициаторов категории В с клирингового счета 30414
@ -55,6 +56,11 @@ public class SDf54 extends SpcexObjectBase {
private String doc_result; private String doc_result;
private Instant generationTime; private Instant generationTime;
private Long generationId; private Long generationId;
private String Doc_Num;
private LocalDate Doc_Date;
private String Value_date;
private String Swift_ben;
private String Swift_intermed;
public String getSeg_type() { public String getSeg_type() {
return seg_type; return seg_type;
@ -392,4 +398,44 @@ public class SDf54 extends SpcexObjectBase {
this.generationId = value; this.generationId = value;
} }
public String getDoc_Num() {
return Doc_Num;
}
public void setDoc_Num(String value) {
this.Doc_Num = value;
}
public LocalDate getDoc_Date() {
return Doc_Date;
}
public void setDoc_Date(LocalDate value) {
this.Doc_Date = value;
}
public String getValue_date() {
return Value_date;
}
public void setValue_date(String value) {
this.Value_date = value;
}
public String getSwift_ben() {
return Swift_ben;
}
public void setSwift_ben(String value) {
this.Swift_ben = value;
}
public String getSwift_intermed() {
return Swift_intermed;
}
public void setSwift_intermed(String value) {
this.Swift_intermed = value;
}
} }

View file

@ -4,6 +4,7 @@ import ru.clearing.classes.ConstSerializable;
import ru.spcex.platform.classes.base.SpcexObjectBase; import ru.spcex.platform.classes.base.SpcexObjectBase;
import java.time.Instant; import java.time.Instant;
import java.time.LocalDate;
/** /**
* ДФ-55 Квитанция об обработке ДФ-54 * ДФ-55 Квитанция об обработке ДФ-54
@ -56,6 +57,11 @@ public class SDf55 extends SpcexObjectBase {
private String fileName; private String fileName;
private Instant generationTime; private Instant generationTime;
private Long generationId; private Long generationId;
private String Doc_Num;
private LocalDate Doc_Date;
private String Value_date;
private String Swift_ben;
private String Swift_intermed;
public String getSeg_type() { public String getSeg_type() {
return seg_type; return seg_type;
@ -401,4 +407,44 @@ public class SDf55 extends SpcexObjectBase {
this.generationId = value; this.generationId = value;
} }
public String getDoc_Num() {
return Doc_Num;
}
public void setDoc_Num(String value) {
this.Doc_Num = value;
}
public LocalDate getDoc_Date() {
return Doc_Date;
}
public void setDoc_Date(LocalDate value) {
this.Doc_Date = value;
}
public String getValue_date() {
return Value_date;
}
public void setValue_date(String value) {
this.Value_date = value;
}
public String getSwift_ben() {
return Swift_ben;
}
public void setSwift_ben(String value) {
this.Swift_ben = value;
}
public String getSwift_intermed() {
return Swift_intermed;
}
public void setSwift_intermed(String value) {
this.Swift_intermed = value;
}
} }

View file

@ -4,6 +4,7 @@ import ru.clearing.classes.ConstSerializable;
import ru.spcex.platform.classes.base.SpcexObjectBase; import ru.spcex.platform.classes.base.SpcexObjectBase;
import java.time.Instant; import java.time.Instant;
import java.time.LocalDate;
/** /**
* ДФ-57 Список транзакций о списании/зачислении за период по всем счетам (ТБС и КС) * ДФ-57 Список транзакций о списании/зачислении за период по всем счетам (ТБС и КС)
@ -53,6 +54,12 @@ public class SDf57 extends SpcexObjectBase {
private String fileName; private String fileName;
private Instant generationTime; private Instant generationTime;
private Long generationId; private Long generationId;
private String Doc_Num;
private LocalDate Doc_Date;
private String dt_in;
private String kt_in;
private String dt_out;
private String kt_out;
public Long getDbfId() { public Long getDbfId() {
return dbfId; return dbfId;
@ -374,4 +381,52 @@ public class SDf57 extends SpcexObjectBase {
this.generationId = value; this.generationId = value;
} }
public String getDoc_Num() {
return Doc_Num;
}
public void setDoc_Num(String value) {
this.Doc_Num = value;
}
public LocalDate getDoc_Date() {
return Doc_Date;
}
public void setDoc_Date(LocalDate value) {
this.Doc_Date = value;
}
public String getDt_in() {
return dt_in;
}
public void setDt_in(String value) {
this.dt_in = value;
}
public String getKt_in() {
return kt_in;
}
public void setKt_in(String value) {
this.kt_in = value;
}
public String getDt_out() {
return dt_out;
}
public void setDt_out(String value) {
this.dt_out = value;
}
public String getKt_out() {
return kt_out;
}
public void setKt_out(String value) {
this.kt_out = value;
}
} }

View file

@ -0,0 +1,85 @@
package ru.clearing.classes.statics.data.security;
import ru.clearing.classes.ConstSerializable;
import java.math.BigDecimal;
/**
* Валютные пары
* <p>
* DB table: CURRENCY_PAIR_SECURITY
**/
public class CurrencyPairSecurity extends Security {
private static final long serialVersionUID = ConstSerializable.serialVersionUID;
private BigDecimal baseUnitSize;
private Long currencyPairId;
private String code;
private String settlementType;
private String clearingOrganization;
private String settlementOrganization;
private Long securityId;
// extend: private String securitySymbol;
// extend: private String shortName;
// extend: private String fullName;
// extend: private String shortNameEng;
// extend: private String fullNameEng;
// extend: private String workflowStatus;
public BigDecimal getBaseUnitSize() {
return baseUnitSize;
}
public void setBaseUnitSize(BigDecimal value) {
this.baseUnitSize = value;
}
public Long getCurrencyPairId() {
return currencyPairId;
}
public void setCurrencyPairId(Long value) {
this.currencyPairId = value;
}
public String getCode() {
return code;
}
public void setCode(String value) {
this.code = value;
}
public String getSettlementType() {
return settlementType;
}
public void setSettlementType(String value) {
this.settlementType = value;
}
public String getClearingOrganization() {
return clearingOrganization;
}
public void setClearingOrganization(String value) {
this.clearingOrganization = value;
}
public String getSettlementOrganization() {
return settlementOrganization;
}
public void setSettlementOrganization(String value) {
this.settlementOrganization = value;
}
public Long getSecurityId() {
return securityId;
}
public void setSecurityId(Long value) {
this.securityId = value;
}
}

View file

@ -0,0 +1,28 @@
package ru.clearing.classes.statics.data.security;
import ru.clearing.classes.ConstSerializable;
import ru.clearing.classes.objects.BusinessEvent;
import java.io.Serial;
/**
* Изменение состояния объекта Валютные пары
* <p>
* DB table: CURRENCY_PAIR_SECURITY_HISTORY
**/
public class CurrencyPairSecurityHistory extends BusinessEvent<CurrencyPairSecurity> {
@Serial
private static final long serialVersionUID = ConstSerializable.serialVersionUID;
private CurrencyPairSecurity object;
@Override
public CurrencyPairSecurity getObject() {
return object;
}
@Override
public void setObject(CurrencyPairSecurity object) {
this.object = object;
}
}

View file

@ -251,6 +251,7 @@ public class RequirementsAndObligationCreation implements ISessionStage {
return switch (executionType) { return switch (executionType) {
case ExecutionFond -> RegistryFondBuilder.builder(); case ExecutionFond -> RegistryFondBuilder.builder();
case ExecutionDeposit -> RegistryDepoBuilder.builder(); case ExecutionDeposit -> RegistryDepoBuilder.builder();
case ExecutionCurrency -> throw new IllegalStateException("ExecutionCurrency not supported"); // todo ExecutionCurrency по CLS-613
}; };
} }

View file

@ -0,0 +1,40 @@
package ru.clearing.platform.dictionary;
/**
* Справочник способов доставки документа
* <p>
* Dictionary DB table: CURRENCY_PAIR_DICTIONARY
**/
public class CurrencyPairDictionary extends AbstractDictionary {
private static final long serialVersionUID = ConstDictionarySerializable.serialVersionUID;
private String baseCurrencyId;
private String quoteCurrencyId;
private String majorSign;
public String getBaseCurrencyId() {
return baseCurrencyId;
}
public void setBaseCurrencyId(String value) {
this.baseCurrencyId = value;
}
public String getQuoteCurrencyId() {
return quoteCurrencyId;
}
public void setQuoteCurrencyId(String value) {
this.quoteCurrencyId = value;
}
public String getMajorSign() {
return majorSign;
}
public void setMajorSign(String value) {
this.majorSign = value;
}
}

View file

@ -0,0 +1,13 @@
package ru.clearing.platform.dictionary;
/**
* Справочник типов расчетов валютных пар
*
* Dictionary DB table: CURRENCY_SETTLEMENT_TYPE_DICTIONARY
**/
public class CurrencySettlementTypeDictionary extends AbstractDictionary {
private static final long serialVersionUID = ConstDictionarySerializable.serialVersionUID;
}

View file

@ -0,0 +1,11 @@
package ru.clearing.platform.dictionary;
/**
* Справочник статусов обработки
*
* Dictionary DB table: GATEWAY_RESULT_STATUS_DICTIONARY
**/
public class GatewayResultStatusDictionary extends AbstractDictionary {
private static final long serialVersionUID = ConstDictionarySerializable.serialVersionUID;
}

View file

@ -0,0 +1,11 @@
package ru.clearing.platform.dictionary;
/**
* Справочник типов конвертируемости валюты
*
* Dictionary DB table: MAJOR_SIGN_DICTIONARY
**/
public class MajorSignDictionary extends AbstractDictionary {
private static final long serialVersionUID = ConstDictionarySerializable.serialVersionUID;
}

View file

@ -28,7 +28,7 @@ public class AccountHistoryMapStore extends TemplateEventMapStore<AccountHistory
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{"ID", "EVENT_TIME", "EVENT_TYPE", "EVENT_USER_ID", return new String[]{"ID", "EVENT_TIME", "EVENT_TYPE", "EVENT_USER_ID",
"ACCOUNT_ID", "CREATED_AT", "UPDATED_AT", "ACCOUNT", "ACCOUNT_TYPE", "RELATION_ID", "STATUS", "PROCESSING_SIGN", "COMPANY_ID" "ACCOUNT_ID", "CREATED_AT", "UPDATED_AT", "ACCOUNT", "ACCOUNT_TYPE", "RELATION_ID", "CURRENCY", "STATUS", "PROCESSING_SIGN", "COMPANY_ID"
}; };
} }
@ -47,6 +47,7 @@ public class AccountHistoryMapStore extends TemplateEventMapStore<AccountHistory
object.getAccount(), object.getAccount(),
object.getAccountType(), object.getAccountType(),
object.getRelationId(), object.getRelationId(),
object.getCurrency(),
object.getStatus(), object.getStatus(),
object.getProcessingSign(), object.getProcessingSign(),
object.getCompanyId() object.getCompanyId()

View file

@ -28,7 +28,7 @@ public class ClientCodeHistoryMapStore extends TemplateEventMapStore<ClientCodeH
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{"ID", "EVENT_TIME", "EVENT_USER_ID", "EVENT_TYPE", return new String[]{"ID", "EVENT_TIME", "EVENT_USER_ID", "EVENT_TYPE",
"CLIENT_CODE_ID", "COMPANY_ID", "CODE", "TRADING_CLEARING_REGISTRY_ID", "MONEY_ACCOUNT_ID", "DEPO_ACCOUNT_ID", "STATUS", "CREATED_AT", "UPDATED_AT" "CLIENT_CODE_ID", "COMPANY_ID", "CODE", "TRADING_CLEARING_REGISTRY_ID", "MONEY_ACCOUNT_ID", "DEPO_ACCOUNT_ID", "CURRENCY_ACCOUNT_ID", "STATUS", "CREATED_AT", "UPDATED_AT"
}; };
} }
@ -47,6 +47,7 @@ public class ClientCodeHistoryMapStore extends TemplateEventMapStore<ClientCodeH
object.getTradingClearingRegistryId(), object.getTradingClearingRegistryId(),
object.getMoneyAccountId(), object.getMoneyAccountId(),
object.getDepoAccountId(), object.getDepoAccountId(),
object.getCurrencyAccountId(),
object.getStatus(), object.getStatus(),
TimeUtil.toDateFromInstant(object.getCreated()), TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated()) TimeUtil.toDateFromInstant(object.getUpdated())

View file

@ -0,0 +1,58 @@
package ru.spcex.clearing.imdg.businessevent;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.security.CurrencyPairSecurity;
import ru.clearing.classes.statics.data.security.CurrencyPairSecurityHistory;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.clearing.imdg.base.TemplateEventMapStore;
import ru.spcex.platform.utils.time.TimeUtil;
@Component
public class CurrencyPairSecurityHistoryMapStore extends ASecurityHistoryMapStore<CurrencyPairSecurityHistory> {
public CurrencyPairSecurityHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_CurrencyPairSecurityHistory;
}
@Override
public String getTableName() {
return "CURRENCY_PAIR_SECURITY_HISTORY";
}
@Override
public String[] getFields() {
return new String[]{"ID", "EVENT_TIME", "EVENT_USER_ID", "EVENT_TYPE",
"CURRENCY_PAIR_SECURITY_ID", "BASE_UNIT_SIZE", "CURRENCY_PAIR_ID", "CODE", "SETTLEMENT_TYPE", "CLEARING_ORGANIZATION", "SETTLEMENT_ORGANIZATION", "SECURITY_ID", "CREATED_AT", "UPDATED_AT"
};
}
@Override
public Object[] objectToField(CurrencyPairSecurityHistory historyLog) {
CurrencyPairSecurity object = historyLog.getObject();
Object[] args = new Object[]{
historyLog.getId(),
TimeUtil.toDateFromInstant(historyLog.getEventTime()),
historyLog.getUserId(),
historyLog.getEventType(),
object.getId(),
object.getBaseUnitSize(),
object.getCurrencyPairId(),
object.getCode(),
object.getSettlementType(),
object.getClearingOrganization(),
object.getSettlementOrganization(),
object.getSecurityId(),
TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated())
};
return args;
}
}

View file

@ -0,0 +1,78 @@
package ru.spcex.clearing.imdg.businessevent;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.execution.ExecutionCurrency;
import ru.clearing.classes.statics.data.execution.ExecutionCurrencyHistory;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.clearing.imdg.base.TemplateEventMapStore;
import ru.spcex.platform.utils.time.TimeUtil;
@Component
public class ExecutionCurrencyHistoryMapStore extends TemplateEventMapStore<ExecutionCurrencyHistory> {
public ExecutionCurrencyHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_ExecutionCurrencyHistory;
}
@Override
public String getTableName() {
return "EXECUTION_CURRENCY_HISTORY";
}
@Override
public String[] getFields() {
return new String[]{"ID", "EVENT_TIME", "EVENT_USER_ID", "EVENT_TYPE",
"EXECUTION_CURRENCY_ID", "CREATED_AT", "UPDATED_AT", "EXCHANGE_EXECUTION_ID", "EXCHANGE_EXECUTION_TIME", "EXCHANGE_EXECUTION_MICROSECONDS", "TRADING_DATE", "SETTLEMENT_DATE", "SETTLEMENT_CODE", "SECURITY_ID", "SECURITY_SYMBOL", "SECURITY_NAME", "COMPANY_ID", "PARTY_TRADING_CLEARING_REGISTRY_ID", "PARTY_TRADING_CLEARING_REGISTRY", "COUNTER_PARTY_ID", "COUNTER_PARTY_TRADING_CLEARING_REGISTRY_ID", "COUNTER_PARTY_TRADING_CLEARING_REGISTRY", "MARKET", "PRICE", "LOTS", "SETTLEMENT_AMOUNT", "QUANTITY", "SIDE", "CURRENCY_CODE", "SETTLEMENT_ORGANIZATION", "COVERAGE_STATUS", "SESSION_ID", "DEPO_CODE", "CLEARING_DATE"
};
}
@Override
public Object[] objectToField(ExecutionCurrencyHistory historyLog) {
ExecutionCurrency object = historyLog.getObject();
Object[] args = new Object[]{
historyLog.getId(),
TimeUtil.toDateFromInstant(historyLog.getEventTime()),
historyLog.getUserId(),
historyLog.getEventType(),
object.getId(),
TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated()),
object.getExchangeExecutionId(),
TimeUtil.toDateFromInstant(object.getExchangeExecutionTime()),
TimeUtil.toDateFromInstant(object.getExchangeExecutionMicroseconds()),
TimeUtil.toDateFromLocalDate(object.getTradingDate()),
TimeUtil.toDateFromLocalDate(object.getSettlementDate()),
object.getSettlementCode(),
object.getSecurityId(),
object.getSecuritySymbol(),
object.getSecurityName(),
object.getCompanyId(),
object.getPartyTradingClearingRegistryId(),
object.getPartyTradingClearingRegistry(),
object.getCounterPartyId(),
object.getCounterPartyTradingClearingRegistryId(),
object.getCounterPartyTradingClearingRegistry(),
object.getMarket(),
object.getPrice(),
object.getLots(),
object.getSettlementAmount(),
object.getQuantity(),
object.getSide(),
object.getCurrencyCode(),
object.getSettlementOrganization(),
object.getCoverageStatus(),
object.getSessionId(),
object.getDepoCode(),
TimeUtil.toDateFromLocalDate(object.getClearingDate())
};
return args;
}
}

View file

@ -28,7 +28,7 @@ public class ListingHistoryMapStore extends TemplateEventMapStore<ListingHistory
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{"ID","EVENT_TIME", "EVENT_USER_ID", "EVENT_TYPE", return new String[]{"ID","EVENT_TIME", "EVENT_USER_ID", "EVENT_TYPE",
"LISTING_ID", "CREATED_AT", "UPDATED_AT", "SECURITY_ID", "LOT_SIZE", "MARKET", "SYMBOL_CODE", "SYMBOL_NAME", "TRADING_CURRENCY", "WORKFLOW_STATUS" "LISTING_ID", "CREATED_AT", "UPDATED_AT", "SECURITY_ID", "MARKET", "LOT_SIZE", "SYMBOL_CODE", "SYMBOL_NAME", "TRADING_CURRENCY", "WORKFLOW_STATUS", "MIN_STEP", "PRECISION"
}; };
} }
@ -45,12 +45,14 @@ public class ListingHistoryMapStore extends TemplateEventMapStore<ListingHistory
TimeUtil.toDateFromInstant(object.getCreated()), TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated()), TimeUtil.toDateFromInstant(object.getUpdated()),
object.getSecurityId(), object.getSecurityId(),
object.getLotSize(),
object.getMarket(), object.getMarket(),
object.getLotSize(),
object.getSymbolCode(), object.getSymbolCode(),
object.getSymbolName(), object.getSymbolName(),
object.getTradingCurrency(), object.getTradingCurrency(),
object.getWorkflowStatus() object.getWorkflowStatus(),
object.getMinStep(),
object.getPrecision()
}; };
return args; return args;
} }

View file

@ -0,0 +1,51 @@
package ru.spcex.clearing.imdg.businessevent;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.company.SettlementHouseProperties;
import ru.clearing.classes.statics.data.company.SettlementHousePropertiesHistory;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.clearing.imdg.base.TemplateEventMapStore;
import ru.spcex.platform.utils.time.TimeUtil;
@Component
public class SettlementHousePropertiesHistoryMapStore extends TemplateEventMapStore<SettlementHousePropertiesHistory> {
public SettlementHousePropertiesHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_SettlementHousePropertiesHistory;
}
@Override
public String getTableName() {
return "SETTLEMENT_HOUSE_PROPERTIES_HISTORY";
}
@Override
public String[] getFields() {
return new String[]{"ID","EVENT_TIME", "EVENT_USER_ID", "EVENT_TYPE",
"SETTLEMENT_HOUSE_PROPERTIES_ID", "COMPANY_ID", "CURRENCY_CODE"
};
}
@Override
public Object[] objectToField(SettlementHousePropertiesHistory historyLog) {
SettlementHouseProperties object=historyLog.getObject();
Object[] args = new Object[]{
historyLog.getId(),
TimeUtil.toDateFromInstant(historyLog.getEventTime()),
historyLog.getUserId(),
historyLog.getEventType(),
object.getId(),
object.getCompanyId(),
object.getCurrencyCode()
};
return args;
}
}

View file

@ -0,0 +1,55 @@
package ru.spcex.clearing.imdg.businessevent;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.registry.TradingClearingRegistryList;
import ru.clearing.classes.statics.data.registry.TradingClearingRegistryListHistory;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.clearing.imdg.base.TemplateEventMapStore;
import ru.spcex.platform.utils.time.TimeUtil;
@Component
public class TradingClearingRegistryListHistoryMapStore extends TemplateEventMapStore<TradingClearingRegistryListHistory> {
public TradingClearingRegistryListHistoryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_TradingClearingRegistryListHistory;
}
@Override
public String getTableName() {
return "TRADING_CLEARING_REGISTRY_LIST_HISTORY";
}
@Override
public String[] getFields() {
return new String[]{"ID", "EVENT_TIME", "EVENT_USER_ID", "EVENT_TYPE",
"TRADING_CLEARING_REGISTRY_LIST_ID", "TRADING_CLEARING_REGISTRY_ID", "ACCOUNT_ID", "CURRENCY", "STATUS", "CREATED_AT", "UPDATED_AT"
};
}
@Override
public Object[] objectToField(TradingClearingRegistryListHistory historyLog) {
TradingClearingRegistryList object = historyLog.getObject();
Object[] args = new Object[]{
historyLog.getId(),
TimeUtil.toDateFromInstant(historyLog.getEventTime()),
historyLog.getUserId(),
historyLog.getEventType(),
object.getId(),
object.getTradingClearingRegistryId(),
object.getAccountId(),
object.getCurrency(),
object.getStatus(),
TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated())
};
return args;
}
}

View file

@ -30,15 +30,10 @@ public class AccountMapStore extends TemplateMapStore<Account> {
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{ return new String[]{
"ID", "CREATED_AT", "UPDATED_AT", "ACCOUNT", "ACCOUNT_TYPE", "RELATION_ID", "STATUS", "PROCESSING_SIGN", "COMPANY_ID" "ID", "CREATED_AT", "UPDATED_AT", "ACCOUNT", "ACCOUNT_TYPE", "RELATION_ID", "CURRENCY", "STATUS", "PROCESSING_SIGN", "COMPANY_ID"
}; };
} }
@Override
public String[] getIndexingField() {
return new String[]{"account", "companyId"};
}
@Override @Override
public Account objectReader(ResultSet resultSet) throws SQLException { public Account objectReader(ResultSet resultSet) throws SQLException {
Account object = new Account(); Account object = new Account();
@ -48,6 +43,7 @@ public class AccountMapStore extends TemplateMapStore<Account> {
object.setAccount(resultSet.getObject("ACCOUNT", String.class)); object.setAccount(resultSet.getObject("ACCOUNT", String.class));
object.setAccountType(resultSet.getObject("ACCOUNT_TYPE", String.class)); object.setAccountType(resultSet.getObject("ACCOUNT_TYPE", String.class));
object.setRelationId(resultSet.getObject("RELATION_ID", Long.class)); object.setRelationId(resultSet.getObject("RELATION_ID", Long.class));
object.setCurrency(resultSet.getObject("CURRENCY", String.class));
object.setStatus(resultSet.getObject("STATUS", String.class)); object.setStatus(resultSet.getObject("STATUS", String.class));
object.setProcessingSign(resultSet.getObject("PROCESSING_SIGN", String.class)); object.setProcessingSign(resultSet.getObject("PROCESSING_SIGN", String.class));
object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class)); object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class));
@ -63,6 +59,7 @@ public class AccountMapStore extends TemplateMapStore<Account> {
object.getAccount(), object.getAccount(),
object.getAccountType(), object.getAccountType(),
object.getRelationId(), object.getRelationId(),
object.getCurrency(),
object.getStatus(), object.getStatus(),
object.getProcessingSign(), object.getProcessingSign(),
object.getCompanyId() object.getCompanyId()

View file

@ -30,7 +30,7 @@ public class ClientCodeMapStore extends TemplateMapStore<ClientCode> {
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{ return new String[]{
"ID", "COMPANY_ID", "CODE", "TRADING_CLEARING_REGISTRY_ID", "MONEY_ACCOUNT_ID", "DEPO_ACCOUNT_ID", "STATUS", "CREATED_AT", "UPDATED_AT" "ID", "COMPANY_ID", "CODE", "TRADING_CLEARING_REGISTRY_ID", "MONEY_ACCOUNT_ID", "DEPO_ACCOUNT_ID", "CURRENCY_ACCOUNT_ID", "STATUS", "CREATED_AT", "UPDATED_AT"
}; };
} }
@ -43,6 +43,7 @@ public class ClientCodeMapStore extends TemplateMapStore<ClientCode> {
object.setTradingClearingRegistryId(resultSet.getObject("TRADING_CLEARING_REGISTRY_ID", Long.class)); object.setTradingClearingRegistryId(resultSet.getObject("TRADING_CLEARING_REGISTRY_ID", Long.class));
object.setMoneyAccountId(resultSet.getObject("MONEY_ACCOUNT_ID", Long.class)); object.setMoneyAccountId(resultSet.getObject("MONEY_ACCOUNT_ID", Long.class));
object.setDepoAccountId(resultSet.getObject("DEPO_ACCOUNT_ID", Long.class)); object.setDepoAccountId(resultSet.getObject("DEPO_ACCOUNT_ID", Long.class));
object.setCurrencyAccountId(resultSet.getObject("CURRENCY_ACCOUNT_ID", Long.class));
object.setStatus(resultSet.getObject("STATUS", String.class)); object.setStatus(resultSet.getObject("STATUS", String.class));
object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT"));
object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT"));
@ -58,6 +59,7 @@ public class ClientCodeMapStore extends TemplateMapStore<ClientCode> {
object.getTradingClearingRegistryId(), object.getTradingClearingRegistryId(),
object.getMoneyAccountId(), object.getMoneyAccountId(),
object.getDepoAccountId(), object.getDepoAccountId(),
object.getCurrencyAccountId(),
object.getStatus(), object.getStatus(),
TimeUtil.toDateFromInstant(object.getCreated()), TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated()) TimeUtil.toDateFromInstant(object.getUpdated())

View file

@ -31,7 +31,8 @@ public class DepoBalanceRegisterMapStore extends TemplateMapStore<DepoBalanceReg
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{ return new String[]{
"ID", "CREATED_AT", "UPDATED_AT", "COMPANY_ID", "SESSION_ID", "DEPO_CODE", "QUANTITY", "SECURITY_SYMBOL" "ID", "CREATED_AT", "UPDATED_AT", "COMPANY_ID", "SESSION_ID", "SET_HOUSE_NAME", "NUMBER", "DEPO_CODE",
"QUANTITY", "SECURITY_SYMBOL"
}; };
} }
@ -43,6 +44,8 @@ public class DepoBalanceRegisterMapStore extends TemplateMapStore<DepoBalanceReg
object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT"));
object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class)); object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class));
object.setSessionId(resultSet.getObject("SESSION_ID", Long.class)); object.setSessionId(resultSet.getObject("SESSION_ID", Long.class));
object.setSetHouseName(resultSet.getObject("SET_HOUSE_NAME", String.class));
object.setNumber(resultSet.getObject("NUMBER", String.class));
object.setDepoCode(resultSet.getObject("DEPO_CODE", String.class)); object.setDepoCode(resultSet.getObject("DEPO_CODE", String.class));
object.setQuantity(resultSet.getObject("QUANTITY", BigDecimal.class)); object.setQuantity(resultSet.getObject("QUANTITY", BigDecimal.class));
object.setSecuritySymbol(resultSet.getObject("SECURITY_SYMBOL", String.class)); object.setSecuritySymbol(resultSet.getObject("SECURITY_SYMBOL", String.class));
@ -57,6 +60,8 @@ public class DepoBalanceRegisterMapStore extends TemplateMapStore<DepoBalanceReg
TimeUtil.toDateFromInstant(object.getUpdated()), TimeUtil.toDateFromInstant(object.getUpdated()),
object.getCompanyId(), object.getCompanyId(),
object.getSessionId(), object.getSessionId(),
object.getSetHouseName(),
object.getNumber(),
object.getDepoCode(), object.getDepoCode(),
object.getQuantity(), object.getQuantity(),
object.getSecuritySymbol() object.getSecuritySymbol()

View file

@ -0,0 +1,111 @@
package ru.spcex.clearing.imdg.businessobject;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.execution.ExecutionCurrency;
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 ExecutionCurrencyMapStore extends TemplateMapStore<ExecutionCurrency> {
public ExecutionCurrencyMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_ExecutionCurrency;
}
@Override
public String getTableName() {
return "EXECUTION_CURRENCY";
}
@Override
public String[] getFields() {
return new String[]{
"ID", "CREATED_AT", "UPDATED_AT", "EXCHANGE_EXECUTION_ID", "EXCHANGE_EXECUTION_TIME", "EXCHANGE_EXECUTION_MICROSECONDS", "TRADING_DATE", "SETTLEMENT_DATE", "SETTLEMENT_CODE", "SECURITY_ID", "SECURITY_SYMBOL", "SECURITY_NAME", "COMPANY_ID", "PARTY_TRADING_CLEARING_REGISTRY_ID", "PARTY_TRADING_CLEARING_REGISTRY", "COUNTER_PARTY_ID", "COUNTER_PARTY_TRADING_CLEARING_REGISTRY_ID", "COUNTER_PARTY_TRADING_CLEARING_REGISTRY", "MARKET", "PRICE", "LOTS", "SETTLEMENT_AMOUNT", "QUANTITY", "SIDE", "CURRENCY_CODE", "SETTLEMENT_ORGANIZATION", "COVERAGE_STATUS", "SESSION_ID", "DEPO_CODE", "CLEARING_DATE"
};
}
@Override
public ExecutionCurrency objectReader(ResultSet resultSet) throws SQLException {
ExecutionCurrency object = new ExecutionCurrency();
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.setExchangeExecutionMicroseconds(getInstantFromTimestamp(resultSet, "EXCHANGE_EXECUTION_MICROSECONDS"));
object.setTradingDate(getLocalDateFromSqlDate(resultSet, "TRADING_DATE"));
object.setSettlementDate(getLocalDateFromSqlDate(resultSet, "SETTLEMENT_DATE"));
object.setSettlementCode(resultSet.getObject("SETTLEMENT_CODE", String.class));
object.setSecurityId(resultSet.getObject("SECURITY_ID", Long.class));
object.setSecuritySymbol(resultSet.getObject("SECURITY_SYMBOL", String.class));
object.setSecurityName(resultSet.getObject("SECURITY_NAME", String.class));
object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class));
object.setPartyTradingClearingRegistryId(resultSet.getObject("PARTY_TRADING_CLEARING_REGISTRY_ID", Long.class));
object.setPartyTradingClearingRegistry(resultSet.getObject("PARTY_TRADING_CLEARING_REGISTRY", String.class));
object.setCounterPartyId(resultSet.getObject("COUNTER_PARTY_ID", Long.class));
object.setCounterPartyTradingClearingRegistryId(resultSet.getObject("COUNTER_PARTY_TRADING_CLEARING_REGISTRY_ID", Long.class));
object.setCounterPartyTradingClearingRegistry(resultSet.getObject("COUNTER_PARTY_TRADING_CLEARING_REGISTRY", String.class));
object.setMarket(resultSet.getObject("MARKET", String.class));
object.setPrice(resultSet.getObject("PRICE", BigDecimal.class));
object.setLots(resultSet.getObject("LOTS", BigDecimal.class));
object.setSettlementAmount(resultSet.getObject("SETTLEMENT_AMOUNT", BigDecimal.class));
object.setQuantity(resultSet.getObject("QUANTITY", BigDecimal.class));
object.setSide(resultSet.getObject("SIDE", String.class));
object.setCurrencyCode(resultSet.getObject("CURRENCY_CODE", String.class));
object.setSettlementOrganization(resultSet.getObject("SETTLEMENT_ORGANIZATION", String.class));
object.setCoverageStatus(resultSet.getObject("COVERAGE_STATUS", String.class));
object.setSessionId(resultSet.getObject("SESSION_ID", Long.class));
object.setDepoCode(resultSet.getObject("DEPO_CODE", String.class));
object.setClearingDate(getLocalDateFromSqlDate(resultSet, "CLEARING_DATE"));
return object;
}
@Override
public Object[] objectToField(ExecutionCurrency object) {
Object[] args = new Object[]{
object.getId(),
TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated()),
object.getExchangeExecutionId(),
TimeUtil.toDateFromInstant(object.getExchangeExecutionTime()),
TimeUtil.toDateFromInstant(object.getExchangeExecutionMicroseconds()),
TimeUtil.toDateFromLocalDate(object.getTradingDate()),
TimeUtil.toDateFromLocalDate(object.getSettlementDate()),
object.getSettlementCode(),
object.getSecurityId(),
object.getSecuritySymbol(),
object.getSecurityName(),
object.getCompanyId(),
object.getPartyTradingClearingRegistryId(),
object.getPartyTradingClearingRegistry(),
object.getCounterPartyId(),
object.getCounterPartyTradingClearingRegistryId(),
object.getCounterPartyTradingClearingRegistry(),
object.getMarket(),
object.getPrice(),
object.getLots(),
object.getSettlementAmount(),
object.getQuantity(),
object.getSide(),
object.getCurrencyCode(),
object.getSettlementOrganization(),
object.getCoverageStatus(),
object.getSessionId(),
object.getDepoCode(),
TimeUtil.toDateFromLocalDate(object.getClearingDate())
};
return args;
}
}

View file

@ -0,0 +1,66 @@
package ru.spcex.clearing.imdg.businessobject;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.clearing.classes.statics.data.register.GatewayResult;
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 GatewayResultMapStore extends TemplateMapStore<GatewayResult> {
public GatewayResultMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_GatewayResult;
}
@Override
public String getTableName() {
return "GATEWAY_RESULT";
}
@Override
public String[] getFields() {
return new String[]{
"ID", "CREATED_AT", "UPDATED_AT", "REQUEST_ID", "NAME_REQUEST", "REQUEST", "RESULT", "GATEWAY_RESULT_STATUS"
};
}
@Override
public GatewayResult objectReader(ResultSet resultSet) throws SQLException {
GatewayResult object = new GatewayResult();
object.setId(resultSet.getObject("ID", Long.class));
object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT"));
object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT"));
object.setRequestId(resultSet.getObject("REQUEST_ID", String.class));
object.setNameRequest(resultSet.getObject("NAME_REQUEST", String.class));
object.setRequest(resultSet.getObject("REQUEST", String.class));
object.setResult(resultSet.getObject("RESULT", String.class));
object.setGatewayResultStatus(resultSet.getObject("GATEWAY_RESULT_STATUS", String.class));
return object;
}
@Override
public Object[] objectToField(GatewayResult object) {
Object[] args = new Object[]{
object.getId(),
TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated()),
object.getRequestId(),
object.getNameRequest(),
object.getRequest(),
object.getResult(),
object.getGatewayResultStatus()
};
return args;
}
}

View file

@ -30,7 +30,9 @@ public class ListingMapStore extends TemplateMapStore<Listing> {
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{"ID", "CREATED_AT", "UPDATED_AT", "SECURITY_ID", "LOT_SIZE", "MARKET", "SYMBOL_CODE", "SYMBOL_NAME", "TRADING_CURRENCY", "WORKFLOW_STATUS"}; return new String[]{
"ID", "CREATED_AT", "UPDATED_AT", "SECURITY_ID", "MARKET", "LOT_SIZE", "SYMBOL_CODE", "SYMBOL_NAME", "TRADING_CURRENCY", "WORKFLOW_STATUS", "MIN_STEP", "PRECISION"
};
} }
@Override @Override
@ -40,12 +42,14 @@ public class ListingMapStore extends TemplateMapStore<Listing> {
object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT")); object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT"));
object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT"));
object.setSecurityId(resultSet.getObject("SECURITY_ID", Long.class)); object.setSecurityId(resultSet.getObject("SECURITY_ID", Long.class));
object.setLotSize(resultSet.getObject("LOT_SIZE", BigDecimal.class));
object.setMarket(resultSet.getObject("MARKET", String.class)); object.setMarket(resultSet.getObject("MARKET", String.class));
object.setLotSize(resultSet.getObject("LOT_SIZE", BigDecimal.class));
object.setSymbolCode(resultSet.getObject("SYMBOL_CODE", String.class)); object.setSymbolCode(resultSet.getObject("SYMBOL_CODE", String.class));
object.setSymbolName(resultSet.getObject("SYMBOL_NAME", String.class)); object.setSymbolName(resultSet.getObject("SYMBOL_NAME", String.class));
object.setTradingCurrency(resultSet.getObject("TRADING_CURRENCY", String.class)); object.setTradingCurrency(resultSet.getObject("TRADING_CURRENCY", String.class));
object.setWorkflowStatus(resultSet.getObject("WORKFLOW_STATUS", String.class)); object.setWorkflowStatus(resultSet.getObject("WORKFLOW_STATUS", String.class));
object.setMinStep(resultSet.getObject("MIN_STEP", BigDecimal.class));
object.setPrecision(resultSet.getObject("PRECISION", BigDecimal.class));
return object; return object;
} }
@ -56,12 +60,14 @@ public class ListingMapStore extends TemplateMapStore<Listing> {
TimeUtil.toDateFromInstant(object.getCreated()), TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated()), TimeUtil.toDateFromInstant(object.getUpdated()),
object.getSecurityId(), object.getSecurityId(),
object.getLotSize(),
object.getMarket(), object.getMarket(),
object.getLotSize(),
object.getSymbolCode(), object.getSymbolCode(),
object.getSymbolName(), object.getSymbolName(),
object.getTradingCurrency(), object.getTradingCurrency(),
object.getWorkflowStatus() object.getWorkflowStatus(),
object.getMinStep(),
object.getPrecision()
}; };
return args; return args;
} }

View file

@ -31,7 +31,7 @@ public class MoneyBalanceRegisterMapStore extends TemplateMapStore<MoneyBalanceR
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{ return new String[]{
"SET_HOUSE_NAME", "ACCOUNT", "INFO_ACCOUNT", "REMAINDER_SUM", "BLOCKED_SUM", "UNBLOCKED_SUM", "INN", "SESSION_ID", "COMPANY_FULL_NAME", "COMPANY_ID", "ID", "CREATED_AT", "UPDATED_AT" "SET_HOUSE_NAME", "NUMBER", "CREATED_AT", "CURRENCY_CODE", "COMPANY_ID", "ACCOUNT", "REMAINDER_SUM", "INFO_ACCOUNT", "COMPANY_FULL_NAME", "ID", "INN", "SESSION_ID", "BLOCKED_SUM", "UNBLOCKED_SUM", "UPDATED_AT"
}; };
} }
@ -39,17 +39,19 @@ public class MoneyBalanceRegisterMapStore extends TemplateMapStore<MoneyBalanceR
public MoneyBalanceRegister objectReader(ResultSet resultSet) throws SQLException { public MoneyBalanceRegister objectReader(ResultSet resultSet) throws SQLException {
MoneyBalanceRegister object = new MoneyBalanceRegister(); MoneyBalanceRegister object = new MoneyBalanceRegister();
object.setSetHouseName(resultSet.getObject("SET_HOUSE_NAME", String.class)); object.setSetHouseName(resultSet.getObject("SET_HOUSE_NAME", String.class));
object.setNumber(resultSet.getObject("NUMBER", String.class));
object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT"));
object.setCurrencyCode(resultSet.getObject("CURRENCY_CODE", String.class));
object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class));
object.setAccount(resultSet.getObject("ACCOUNT", 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.setRemainderSum(resultSet.getObject("REMAINDER_SUM", BigDecimal.class));
object.setBlockedSum(resultSet.getObject("BLOCKED_SUM", BigDecimal.class)); object.setInfoAccount(resultSet.getObject("INFO_ACCOUNT", String.class));
object.setUnblockedSum(resultSet.getObject("UNBLOCKED_SUM", BigDecimal.class)); object.setCompanyFullName(resultSet.getObject("COMPANY_FULL_NAME", String.class));
object.setId(resultSet.getObject("ID", Long.class));
object.setInn(resultSet.getObject("INN", String.class)); object.setInn(resultSet.getObject("INN", String.class));
object.setSessionId(resultSet.getObject("SESSION_ID", Long.class)); object.setSessionId(resultSet.getObject("SESSION_ID", Long.class));
object.setCompanyFullName(resultSet.getObject("COMPANY_FULL_NAME", String.class)); object.setBlockedSum(resultSet.getObject("BLOCKED_SUM", BigDecimal.class));
object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class)); object.setUnblockedSum(resultSet.getObject("UNBLOCKED_SUM", BigDecimal.class));
object.setId(resultSet.getObject("ID", Long.class));
object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT"));
object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT")); object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT"));
return object; return object;
} }
@ -58,17 +60,19 @@ public class MoneyBalanceRegisterMapStore extends TemplateMapStore<MoneyBalanceR
public Object[] objectToField(MoneyBalanceRegister object) { public Object[] objectToField(MoneyBalanceRegister object) {
Object[] args = new Object[]{ Object[] args = new Object[]{
object.getSetHouseName(), object.getSetHouseName(),
object.getNumber(),
TimeUtil.toDateFromInstant(object.getCreated()),
object.getCurrencyCode(),
object.getCompanyId(),
object.getAccount(), object.getAccount(),
object.getInfoAccount(),
object.getRemainderSum(), object.getRemainderSum(),
object.getBlockedSum(), object.getInfoAccount(),
object.getUnblockedSum(), object.getCompanyFullName(),
object.getId(),
object.getInn(), object.getInn(),
object.getSessionId(), object.getSessionId(),
object.getCompanyFullName(), object.getBlockedSum(),
object.getCompanyId(), object.getUnblockedSum(),
object.getId(),
TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated()) TimeUtil.toDateFromInstant(object.getUpdated())
}; };
return args; return args;

View file

@ -0,0 +1,64 @@
package ru.spcex.clearing.imdg.businessobject;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.register.PairSdf;
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 PairSdfMapStore extends TemplateMapStore<PairSdf> {
public PairSdfMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_PairSdf;
}
@Override
public String getTableName() {
return "PAIR_SDF";
}
@Override
public String[] getFields() {
return new String[]{
"ID", "CREATED_AT", "UPDATED_AT", "IN_S_DF_ID", "IN_S_DF", "OUT_S_DF_ID", "OUT_S_DF"
};
}
@Override
public PairSdf objectReader(ResultSet resultSet) throws SQLException {
PairSdf object = new PairSdf();
object.setId(resultSet.getObject("ID", Long.class));
object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT"));
object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT"));
object.setInSDfId(resultSet.getObject("IN_S_DF_ID", String.class));
object.setInSDf(resultSet.getObject("IN_S_DF", String.class));
object.setOutSDfId(resultSet.getObject("OUT_S_DF_ID", String.class));
object.setOutSDf(resultSet.getObject("OUT_S_DF", String.class));
return object;
}
@Override
public Object[] objectToField(PairSdf object) {
Object[] args = new Object[]{
object.getId(),
TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated()),
object.getInSDfId(),
object.getInSDf(),
object.getOutSDfId(),
object.getOutSDf()
};
return args;
}
}

View file

@ -0,0 +1,55 @@
package ru.spcex.clearing.imdg.businessobject;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.company.SettlementHouseProperties;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.clearing.imdg.base.TemplateMapStore;
import java.sql.ResultSet;
import java.sql.SQLException;
@Component
public class SettlementHousePropertiesMapStore extends TemplateMapStore<SettlementHouseProperties> {
public SettlementHousePropertiesMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_SettlementHouseProperties;
}
@Override
public String getTableName() {
return "SETTLEMENT_HOUSE_PROPERTIES";
}
@Override
public String[] getFields() {
return new String[]{
"ID", "COMPANY_ID", "CURRENCY_CODE"
};
}
@Override
public SettlementHouseProperties objectReader(ResultSet resultSet) throws SQLException {
SettlementHouseProperties object = new SettlementHouseProperties();
object.setId(resultSet.getObject("ID", Long.class));
object.setCompanyId(resultSet.getObject("COMPANY_ID", Long.class));
object.setCurrencyCode(resultSet.getObject("CURRENCY_CODE", String.class));
return object;
}
@Override
public Object[] objectToField(SettlementHouseProperties object) {
Object[] args = new Object[]{
object.getId(),
object.getCompanyId(),
object.getCurrencyCode()
};
return args;
}
}

View file

@ -0,0 +1,47 @@
package ru.spcex.clearing.imdg.dictionary;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.platform.dictionary.CurrencyPairDictionary;
import ru.spcex.clearing.imdg.base.DictionaryTMapStore;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import java.sql.ResultSet;
import java.sql.SQLException;
@Component
public class CurrencyPairDictionaryMapStore extends DictionaryTMapStore<CurrencyPairDictionary> {
public CurrencyPairDictionaryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_CurrencyPairDictionary;
}
@Override
public String getTableName() {
return "CURRENCY_PAIR_DICTIONARY";
}
@Override
public CurrencyPairDictionary getDictionaryObject() {
return new CurrencyPairDictionary();
}
@Override
protected CurrencyPairDictionary mapRow(ResultSet rs, int rowNum) throws SQLException {
CurrencyPairDictionary dictionary = getDictionaryObject();
dictionary.setId(rs.getLong("id"));
dictionary.setCode(rs.getString("code"));
dictionary.setName(rs.getString("name"));
dictionary.setBaseCurrencyId(rs.getString("baseCurrencyId"));
dictionary.setQuoteCurrencyId(rs.getString("quoteCurrencyId"));
dictionary.setMajorSign(rs.getString("majorSign"));
return dictionary;
}
}

View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.imdg.dictionary;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.platform.dictionary.CurrencySettlementTypeDictionary;
import ru.spcex.clearing.imdg.base.DictionaryTMapStore;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
@Component
public class CurrencySettlementTypeDictionaryMapStore extends DictionaryTMapStore<CurrencySettlementTypeDictionary> {
public CurrencySettlementTypeDictionaryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_CurrencySettlementTypeDictionary;
}
@Override
public String getTableName() {
return "CURRENCY_SETTLEMENT_TYPE_DICTIONARY";
}
@Override
public CurrencySettlementTypeDictionary getDictionaryObject() {
return new CurrencySettlementTypeDictionary();
}
}

View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.imdg.dictionary;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.platform.dictionary.GatewayResultStatusDictionary;
import ru.spcex.clearing.imdg.base.DictionaryTMapStore;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
@Component
public class GatewayResultStatusDictionaryMapStore extends DictionaryTMapStore<GatewayResultStatusDictionary> {
public GatewayResultStatusDictionaryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_GatewayResultStatusDictionary;
}
@Override
public String getTableName() {
return "GATEWAY_RESULT_STATUS_DICTIONARY";
}
@Override
public GatewayResultStatusDictionary getDictionaryObject() {
return new GatewayResultStatusDictionary();
}
}

View file

@ -0,0 +1,31 @@
package ru.spcex.clearing.imdg.dictionary;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.platform.dictionary.MajorSignDictionary;
import ru.spcex.clearing.imdg.base.DictionaryTMapStore;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
@Component
public class MajorSignDictionaryMapStore extends DictionaryTMapStore<MajorSignDictionary> {
public MajorSignDictionaryMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_MajorSignDictionary;
}
@Override
public String getTableName() {
return "MAJOR_SIGN_DICTIONARY";
}
@Override
public MajorSignDictionary getDictionaryObject() {
return new MajorSignDictionary();
}
}

View file

@ -0,0 +1,74 @@
package ru.spcex.clearing.imdg.object;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.security.CurrencyPairSecurity;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.clearing.imdg.businessobject.ASecurityMapStore;
import ru.spcex.platform.utils.time.TimeUtil;
import java.math.BigDecimal;
import java.sql.ResultSet;
import java.sql.SQLException;
@Component
public class CurrencyPairSecurityMapStore extends ASecurityMapStore<CurrencyPairSecurity> {
public CurrencyPairSecurityMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_CurrencyPairSecurity;
}
@Override
public String getTableName() {
return "CURRENCY_PAIR_SECURITY";
}
@Override
public String[] getFields() {
return new String[]{
"BASE_UNIT_SIZE", "CURRENCY_PAIR_ID", "CODE", "SETTLEMENT_TYPE", "CLEARING_ORGANIZATION", "SETTLEMENT_ORGANIZATION", "SECURITY_ID", "ID", "CREATED_AT", "UPDATED_AT"
};
}
@Override
public CurrencyPairSecurity objectReader(ResultSet resultSet) throws SQLException {
CurrencyPairSecurity object = new CurrencyPairSecurity();
object.setBaseUnitSize(resultSet.getObject("BASE_UNIT_SIZE", BigDecimal.class));
object.setCurrencyPairId(resultSet.getObject("CURRENCY_PAIR_ID", Long.class));
object.setCode(resultSet.getObject("CODE", String.class));
object.setSettlementType(resultSet.getObject("SETTLEMENT_TYPE", String.class));
object.setClearingOrganization(resultSet.getObject("CLEARING_ORGANIZATION", String.class));
object.setSettlementOrganization(resultSet.getObject("SETTLEMENT_ORGANIZATION", String.class));
object.setSecurityId(resultSet.getObject("SECURITY_ID", Long.class));
object.setId(resultSet.getObject("ID", Long.class));
object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT"));
object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT"));
fillBySecurity(object, object.getSecurityId());
return object;
}
@Override
public Object[] objectToField(CurrencyPairSecurity object) {
Object[] args = new Object[]{
object.getBaseUnitSize(),
object.getCurrencyPairId(),
object.getCode(),
object.getSettlementType(),
object.getClearingOrganization(),
object.getSettlementOrganization(),
object.getSecurityId(),
object.getId(),
TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated())
};
return args;
}
}

View file

@ -34,7 +34,7 @@ public class SDf06MapStore extends TemplateMapStore<SDf06> {
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{ return new String[]{
"ID", "ACCOUNT", "SUM", "MARKET", "TYPE", "DEAL", "CLIENT_N", "INN", "BIC", "SPEC", "NUMBER", "FILE_NAME", "GENERATION_TIME", "GENERATION_ID" "ID", "ACCOUNT", "SUM", "MARKET", "TYPE", "DEAL", "CLIENT_N", "INN", "BIC", "SPEC", "NUMBER", "FILE_NAME", "GENERATION_TIME", "GENERATION_ID", "_DOC__NUM", "_DOC__DATE", "PAY_VAL"
}; };
} }
@ -70,6 +70,9 @@ public class SDf06MapStore extends TemplateMapStore<SDf06> {
object.setFileName(resultSet.getObject("FILE_NAME", String.class)); object.setFileName(resultSet.getObject("FILE_NAME", String.class));
object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME")); object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME"));
object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class));
object.setDoc_Num(resultSet.getObject("_DOC__NUM", String.class));
object.setDoc_Date(getLocalDateFromSqlDate(resultSet, "_DOC__DATE"));
object.setPay_val(resultSet.getObject("PAY_VAL", String.class));
return object; return object;
} }
@ -89,7 +92,10 @@ public class SDf06MapStore extends TemplateMapStore<SDf06> {
object.getNumber(), object.getNumber(),
object.getFileName(), object.getFileName(),
TimeUtil.toDateFromInstant(object.getGenerationTime()), TimeUtil.toDateFromInstant(object.getGenerationTime()),
object.getGenerationId() object.getGenerationId(),
object.getDoc_Num(),
TimeUtil.toDateFromLocalDate(object.getDoc_Date()),
object.getPay_val()
}; };
return args; return args;
} }

View file

@ -34,7 +34,8 @@ public class SDf07MapStore extends TemplateMapStore<SDf07> {
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{ return new String[]{
"ID", "ACCOUNT", "SUM", "MARKET", "TYPE", "DEAL", "CLIENT_N", "INN", "BIC", "SPEC", "NUMBER", "RESULT", "GENERATION_TIME", "GENERATION_ID", "IN_S_DF_ID" "ID", "ACCOUNT", "SUM", "MARKET", "TYPE", "DEAL", "CLIENT_N", "INN", "BIC", "SPEC", "NUMBER", "RESULT",
"GENERATION_TIME", "GENERATION_ID", "IN_S_DF_ID", "_DOC__NUM", "_DOC__DATE", "PAY_VAL"
}; };
} }
@ -71,6 +72,9 @@ public class SDf07MapStore extends TemplateMapStore<SDf07> {
object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME")); object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME"));
object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class));
object.setInSDfId(resultSet.getObject("IN_S_DF_ID", Long.class)); object.setInSDfId(resultSet.getObject("IN_S_DF_ID", Long.class));
object.setDoc_Num(resultSet.getObject("_DOC__NUM", String.class));
object.setDoc_Date(getLocalDateFromSqlDate(resultSet, "_DOC__DATE"));
object.setPay_val(resultSet.getObject("PAY_VAL", String.class));
return object; return object;
} }
@ -91,7 +95,10 @@ public class SDf07MapStore extends TemplateMapStore<SDf07> {
object.getResult(), object.getResult(),
TimeUtil.toDateFromInstant(object.getGenerationTime()), TimeUtil.toDateFromInstant(object.getGenerationTime()),
object.getGenerationId(), object.getGenerationId(),
object.getInSDfId() object.getInSDfId(),
object.getDoc_Num(),
TimeUtil.toDateFromLocalDate(object.getDoc_Date()),
object.getPay_val()
}; };
return args; return args;
} }

View file

@ -33,7 +33,7 @@ public class SDf54MapStore extends TemplateMapStore<SDf54> {
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{ return new String[]{
"ID", "SEG_TYPE", "DOC_TYPE", "DOCNM_REF", "DOCNMPREV", "SBANKCODE", "C_ACC_DEB", "SBANKNAM1", "SBANKNAM2", "SBANKNAM3", "SBANKNAM4", "SBANKNAM5", "RBANKCODE", "C_ACC_CRED", "RBANKNAM1", "RBANKNAM2", "RBANKNAM3", "RBANKNAM4", "RBANKNAM5", "OP_TYPE", "OP_ORDER", "PAY_DATE", "PAY_VAL", "SUM_DEB", "SCLIENTN1", "SCLIENTN2", "SCLIENTN3", "SCLIENTN4", "INN_DEB", "KPP_DEB", "ACC_DEB", "RCLIENTN1", "RCLIENTN2", "RCLIENTN3", "RCLIENTN4", "INN_CRED", "KPP_CRED", "ACC_KR_1", "SPECIF_1", "SEND_TYPE", "DOC_RESULT", "GENERATION_TIME", "GENERATION_ID" "ID", "SEG_TYPE", "DOC_TYPE", "DOCNM_REF", "DOCNMPREV", "SBANKCODE", "C_ACC_DEB", "SBANKNAM1", "SBANKNAM2", "SBANKNAM3", "SBANKNAM4", "SBANKNAM5", "RBANKCODE", "C_ACC_CRED", "RBANKNAM1", "RBANKNAM2", "RBANKNAM3", "RBANKNAM4", "RBANKNAM5", "OP_TYPE", "OP_ORDER", "PAY_DATE", "PAY_VAL", "SUM_DEB", "SCLIENTN1", "SCLIENTN2", "SCLIENTN3", "SCLIENTN4", "INN_DEB", "KPP_DEB", "ACC_DEB", "RCLIENTN1", "RCLIENTN2", "RCLIENTN3", "RCLIENTN4", "INN_CRED", "KPP_CRED", "ACC_KR_1", "SPECIF_1", "SEND_TYPE", "DOC_RESULT", "GENERATION_TIME", "GENERATION_ID", "_DOC__NUM", "_DOC__DATE", "_VALUE_DATE", "_SWIFT_BEN", "_SWIFT_INTERMED"
}; };
} }
@ -98,6 +98,11 @@ public class SDf54MapStore extends TemplateMapStore<SDf54> {
object.setDoc_result(resultSet.getObject("DOC_RESULT", String.class)); object.setDoc_result(resultSet.getObject("DOC_RESULT", String.class));
object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME")); object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME"));
object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class));
object.setDoc_Num(resultSet.getObject("_DOC__NUM", String.class));
object.setDoc_Date(getLocalDateFromSqlDate(resultSet, "_DOC__DATE"));
object.setValue_date(resultSet.getObject("_VALUE_DATE", String.class));
object.setSwift_ben(resultSet.getObject("_SWIFT_BEN", String.class));
object.setSwift_intermed(resultSet.getObject("_SWIFT_INTERMED", String.class));
return object; return object;
} }
@ -146,7 +151,12 @@ public class SDf54MapStore extends TemplateMapStore<SDf54> {
object.getSend_type(), object.getSend_type(),
object.getDoc_result(), object.getDoc_result(),
TimeUtil.toDateFromInstant(object.getGenerationTime()), TimeUtil.toDateFromInstant(object.getGenerationTime()),
object.getGenerationId() object.getGenerationId(),
object.getDoc_Num(),
TimeUtil.toDateFromLocalDate(object.getDoc_Date()),
object.getValue_date(),
object.getSwift_ben(),
object.getSwift_intermed()
}; };
return args; return args;
} }

View file

@ -33,7 +33,14 @@ public class SDf55MapStore extends TemplateMapStore<SDf55> {
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{ return new String[]{
"ID", "SEG_TYPE", "DOC_TYPE", "DOCNM_REF", "DOCNMPREV", "SBANKCODE", "C_ACC_DEB", "SBANKNAM1", "SBANKNAM2", "SBANKNAM3", "SBANKNAM4", "SBANKNAM5", "RBANKCODE", "C_ACC_CRED", "RBANKNAM1", "RBANKNAM2", "RBANKNAM3", "RBANKNAM4", "RBANKNAM5", "OP_TYPE", "OP_ORDER", "PAY_DATE", "PAY_VAL", "SUM_DEB", "SCLIENTN1", "SCLIENTN2", "SCLIENTN3", "SCLIENTN4", "INN_DEB", "KPP_DEB", "ACC_DEB", "RCLIENTN1", "RCLIENTN2", "RCLIENTN3", "RCLIENTN4", "INN_CRED", "KPP_CRED", "ACC_KR_1", "SPECIF_1", "SEND_TYPE", "DOC_RESULT", "FILE_NAME", "GENERATION_TIME", "GENERATION_ID" "ID", "SEG_TYPE", "DOC_TYPE", "DOCNM_REF", "DOCNMPREV", "SBANKCODE", "C_ACC_DEB",
"SBANKNAM1", "SBANKNAM2", "SBANKNAM3", "SBANKNAM4", "SBANKNAM5", "RBANKCODE", "C_ACC_CRED",
"RBANKNAM1", "RBANKNAM2", "RBANKNAM3", "RBANKNAM4", "RBANKNAM5", "OP_TYPE", "OP_ORDER",
"PAY_DATE", "PAY_VAL", "SUM_DEB", "SCLIENTN1", "SCLIENTN2", "SCLIENTN3", "SCLIENTN4", "INN_DEB", "KPP_DEB",
"ACC_DEB", "RCLIENTN1", "RCLIENTN2", "RCLIENTN3", "RCLIENTN4", "INN_CRED", "KPP_CRED",
"ACC_KR_1", "SPECIF_1", "SEND_TYPE", "DOC_RESULT", "FILE_NAME",
"GENERATION_TIME", "GENERATION_ID",
"_DOC__NUM", "_DOC__DATE", "_VALUE_DATE", "_SWIFT_BEN", "_SWIFT_INTERMED"
}; };
} }
@ -99,6 +106,11 @@ public class SDf55MapStore extends TemplateMapStore<SDf55> {
object.setFileName(resultSet.getObject("FILE_NAME", String.class)); object.setFileName(resultSet.getObject("FILE_NAME", String.class));
object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME")); object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME"));
object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class));
object.setDoc_Num(resultSet.getObject("_DOC__NUM", String.class));
object.setDoc_Date(getLocalDateFromSqlDate(resultSet, "_DOC__DATE"));
object.setValue_date(resultSet.getObject("_VALUE_DATE", String.class));
object.setSwift_ben(resultSet.getObject("_SWIFT_BEN", String.class));
object.setSwift_intermed(resultSet.getObject("_SWIFT_INTERMED", String.class));
return object; return object;
} }
@ -148,7 +160,12 @@ public class SDf55MapStore extends TemplateMapStore<SDf55> {
object.getDoc_result(), object.getDoc_result(),
object.getFileName(), object.getFileName(),
TimeUtil.toDateFromInstant(object.getGenerationTime()), TimeUtil.toDateFromInstant(object.getGenerationTime()),
object.getGenerationId() object.getGenerationId(),
object.getDoc_Num(),
TimeUtil.toDateFromLocalDate(object.getDoc_Date()),
object.getValue_date(),
object.getSwift_ben(),
object.getSwift_intermed()
}; };
return args; return args;
} }

View file

@ -32,7 +32,7 @@ public class SDf57MapStore extends TemplateMapStore<SDf57> {
@Override @Override
public String[] getFields() { public String[] getFields() {
return new String[]{ return new String[]{
"ID", "DBF_ID", "DEAL_DEB", "DEAL_CRED", "SBANKCODE", "C_ACC_DEB", "SBANKNAM1", "SBANKNAM2", "SBANKNAM3", "SBANKNAM4", "SBANKNAM5", "RBANKCODE", "C_ACC_CRED", "RBANKNAM1", "RBANKNAM2", "RBANKNAM3", "RBANKNAM4", "RBANKNAM5", "OP_TYPE", "PAY_DATE", "EXT_DATE", "PAY_VAL", "SUM_DEB", "SCLIENTN1", "SCLIENTN2", "SCLIENTN3", "SCLIENTN4", "INN_DEB", "KPP_DEB", "ACC_DEB", "RCLIENTN1", "RCLIENTN2", "RCLIENTN3", "RCLIENTN4", "INN_CRED", "KPP_CRED", "ACC_KR", "SPECIF", "FILE_NAME", "GENERATION_TIME", "GENERATION_ID" "GENERATION_TIME", "ID", "DBF_ID", "DEAL_DEB", "DEAL_CRED", "SBANKCODE", "C_ACC_DEB", "SBANKNAM1", "SBANKNAM2", "SBANKNAM3", "SBANKNAM4", "SBANKNAM5", "RBANKCODE", "C_ACC_CRED", "RBANKNAM1", "RBANKNAM2", "RBANKNAM3", "RBANKNAM4", "RBANKNAM5", "OP_TYPE", "PAY_DATE", "EXT_DATE", "PAY_VAL", "SUM_DEB", "SCLIENTN1", "SCLIENTN2", "SCLIENTN3", "SCLIENTN4", "INN_DEB", "KPP_DEB", "ACC_DEB", "RCLIENTN1", "RCLIENTN2", "RCLIENTN3", "RCLIENTN4", "INN_CRED", "KPP_CRED", "ACC_KR", "SPECIF", "FILE_NAME", "GENERATION_ID", "_DOC__NUM", "_DOC__DATE", "DT_IN", "KT_IN", "DT_OUT", "KT_OUT"
}; };
} }
@ -53,6 +53,7 @@ public class SDf57MapStore extends TemplateMapStore<SDf57> {
@Override @Override
public SDf57 objectReader(ResultSet resultSet) throws SQLException { public SDf57 objectReader(ResultSet resultSet) throws SQLException {
SDf57 object = new SDf57(); SDf57 object = new SDf57();
object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME"));
object.setId(resultSet.getObject("ID", Long.class)); object.setId(resultSet.getObject("ID", Long.class));
object.setDbfId(resultSet.getObject("DBF_ID", Long.class)); object.setDbfId(resultSet.getObject("DBF_ID", Long.class));
object.setDeal_deb(resultSet.getObject("DEAL_DEB", String.class)); object.setDeal_deb(resultSet.getObject("DEAL_DEB", String.class));
@ -92,14 +93,20 @@ public class SDf57MapStore extends TemplateMapStore<SDf57> {
object.setAcc_kr(resultSet.getObject("ACC_KR", String.class)); object.setAcc_kr(resultSet.getObject("ACC_KR", String.class));
object.setSpecif(resultSet.getObject("SPECIF", String.class)); object.setSpecif(resultSet.getObject("SPECIF", String.class));
object.setFileName(resultSet.getObject("FILE_NAME", String.class)); object.setFileName(resultSet.getObject("FILE_NAME", String.class));
object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME"));
object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class));
object.setDoc_Num(resultSet.getObject("_DOC__NUM", String.class));
object.setDoc_Date(getLocalDateFromSqlDate(resultSet, "_DOC__DATE"));
object.setDt_in(resultSet.getObject("DT_IN", String.class));
object.setKt_in(resultSet.getObject("KT_IN", String.class));
object.setDt_out(resultSet.getObject("DT_OUT", String.class));
object.setKt_out(resultSet.getObject("KT_OUT", String.class));
return object; return object;
} }
@Override @Override
public Object[] objectToField(SDf57 object) { public Object[] objectToField(SDf57 object) {
Object[] args = new Object[]{ Object[] args = new Object[]{
TimeUtil.toDateFromInstant(object.getGenerationTime()),
object.getId(), object.getId(),
object.getDbfId(), object.getDbfId(),
object.getDeal_deb(), object.getDeal_deb(),
@ -139,8 +146,13 @@ public class SDf57MapStore extends TemplateMapStore<SDf57> {
object.getAcc_kr(), object.getAcc_kr(),
object.getSpecif(), object.getSpecif(),
object.getFileName(), object.getFileName(),
TimeUtil.toDateFromInstant(object.getGenerationTime()), object.getGenerationId(),
object.getGenerationId() object.getDoc_Num(),
TimeUtil.toDateFromLocalDate(object.getDoc_Date()),
object.getDt_in(),
object.getKt_in(),
object.getDt_out(),
object.getKt_out()
}; };
return args; return args;
} }

View file

@ -0,0 +1,64 @@
package ru.spcex.clearing.imdg.object;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import ru.clearing.classes.statics.data.registry.TradingClearingRegistryList;
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 TradingClearingRegistryListMapStore extends TemplateMapStore<TradingClearingRegistryList> {
public TradingClearingRegistryListMapStore(JdbcTemplate jdbcTemplate) {
super(jdbcTemplate);
}
@Override
public String getMapName() {
return IMDGDistributedNames.Map_TradingClearingRegistryList;
}
@Override
public String getTableName() {
return "TRADING_CLEARING_REGISTRY_LIST";
}
@Override
public String[] getFields() {
return new String[]{
"TRADING_CLEARING_REGISTRY_ID", "ACCOUNT_ID", "CURRENCY", "STATUS", "ID", "CREATED_AT", "UPDATED_AT"
};
}
@Override
public TradingClearingRegistryList objectReader(ResultSet resultSet) throws SQLException {
TradingClearingRegistryList object = new TradingClearingRegistryList();
object.setTradingClearingRegistryId(resultSet.getObject("TRADING_CLEARING_REGISTRY_ID", Long.class));
object.setAccountId(resultSet.getObject("ACCOUNT_ID", Long.class));
object.setCurrency(resultSet.getObject("CURRENCY", String.class));
object.setStatus(resultSet.getObject("STATUS", String.class));
object.setId(resultSet.getObject("ID", Long.class));
object.setCreated(getInstantFromTimestamp(resultSet, "CREATED_AT"));
object.setUpdated(getInstantFromTimestamp(resultSet, "UPDATED_AT"));
return object;
}
@Override
public Object[] objectToField(TradingClearingRegistryList object) {
Object[] args = new Object[]{
object.getTradingClearingRegistryId(),
object.getAccountId(),
object.getCurrency(),
object.getStatus(),
object.getId(),
TimeUtil.toDateFromInstant(object.getCreated()),
TimeUtil.toDateFromInstant(object.getUpdated())
};
return args;
}
}

View file

@ -14,7 +14,7 @@ public class HazelcastLifecycleSupport extends AbstractHazelcastLifecycleSupport
/** /**
* Рабочая версия БД. Требуется вручную сверять с DDL.sql и накручивать эту переменную. * Рабочая версия БД. Требуется вручную сверять с DDL.sql и накручивать эту переменную.
*/ */
public static final String CHECK_DB_VERSION = "1.0"; public static final String CHECK_DB_VERSION = "3.11";
private final Logger log = LoggerFactory.getLogger(this.getClass()); private final Logger log = LoggerFactory.getLogger(this.getClass());

View file

@ -2,5 +2,5 @@ package ru.spcex.platform.classes.base.interfaces;
public enum ExecutionType { public enum ExecutionType {
ExecutionDeposit, ExecutionFond; ExecutionDeposit, ExecutionFond, ExecutionCurrency;
} }

View file

@ -196,6 +196,20 @@ public final class IMDGDistributedNames {
public static final String Map_ExecutionFondHistory = "Map_ExecutionFondHistory"; public static final String Map_ExecutionFondHistory = "Map_ExecutionFondHistory";
public static final String Map_PriorityDictionary = "Map_PriorityDictionary"; public static final String Map_PriorityDictionary = "Map_PriorityDictionary";
public static final String Map_SCrossRate = "Map_SCrossRate"; public static final String Map_SCrossRate = "Map_SCrossRate";
public static final String Map_MajorSignDictionary = "Map_MajorSignDictionary";
public static final String Map_CurrencySettlementTypeDictionary = "Map_CurrencySettlementTypeDictionary";
public static final String Map_CurrencyPairDictionary = "Map_CurrencyPairDictionary";
public static final String Map_GatewayResultStatusDictionary = "Map_GatewayResultStatusDictionary";
public static final String Map_CurrencyPairSecurity = "Map_CurrencyPairSecurity";
public static final String Map_CurrencyPairSecurityHistory = "Map_CurrencyPairSecurityHistory";
public static final String Map_TradingClearingRegistryList = "Map_TradingClearingRegistryList";
public static final String Map_TradingClearingRegistryListHistory = "Map_TradingClearingRegistryListHistory";
public static final String Map_ExecutionCurrency = "Map_ExecutionCurrency";
public static final String Map_ExecutionCurrencyHistory = "Map_ExecutionCurrencyHistory";
public static final String Map_SettlementHouseProperties = "Map_SettlementHouseProperties";
public static final String Map_SettlementHousePropertiesHistory = "Map_SettlementHousePropertiesHistory";
public static final String Map_PairSdf = "Map_PairSdf";
public static final String Map_GatewayResult = "Map_GatewayResult";
//-------------------history and search tables //-------------------history and search tables
public static final String Map_SearchExecutionDeposit = "Map_SearchDeposit"; public static final String Map_SearchExecutionDeposit = "Map_SearchDeposit";

View file

@ -2,6 +2,8 @@ package ru.spcex.clearing.platform.messaging.domain.cud.account;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;
public class ClientCodeNewRequest { public class ClientCodeNewRequest {
@JsonProperty @JsonProperty
private Long companyId; private Long companyId;
@ -14,6 +16,8 @@ public class ClientCodeNewRequest {
@JsonProperty @JsonProperty
private Long depoAccountId; private Long depoAccountId;
@JsonProperty @JsonProperty
private List<Long> currencyAccountList;
@JsonProperty
private String status; private String status;
public Long getCompanyId() { public Long getCompanyId() {
@ -56,6 +60,14 @@ public class ClientCodeNewRequest {
this.depoAccountId = depoAccountId; this.depoAccountId = depoAccountId;
} }
public List<Long> getCurrencyAccountList() {
return currencyAccountList;
}
public void setCurrencyAccountList(List<Long> currencyAccountList) {
this.currencyAccountList = currencyAccountList;
}
public String getStatus() { public String getStatus() {
return status; return status;
} }

View file

@ -2,6 +2,8 @@ package ru.spcex.clearing.platform.messaging.domain.cud.account;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;
public class ClientCodeUpdateRequest { public class ClientCodeUpdateRequest {
@JsonProperty @JsonProperty
public Long id; //Идентификатор записи public Long id; //Идентификатор записи
@ -16,6 +18,8 @@ public class ClientCodeUpdateRequest {
@JsonProperty @JsonProperty
private Long depoAccountId; private Long depoAccountId;
@JsonProperty @JsonProperty
private List<Long> currencyAccountList;
@JsonProperty
private String status; private String status;
public Long getId() { public Long getId() {
@ -66,6 +70,14 @@ public class ClientCodeUpdateRequest {
this.depoAccountId = depoAccountId; this.depoAccountId = depoAccountId;
} }
public List<Long> getCurrencyAccountList() {
return currencyAccountList;
}
public void setCurrencyAccountList(List<Long> currencyAccountList) {
this.currencyAccountList = currencyAccountList;
}
public String getStatus() { public String getStatus() {
return status; return status;
} }